QTCPSocket в отдельном потоке.

[Old]

А как в ожидание уйти?

Просто выйти из слота обработчика.

Мне изначально неизвестен размер пакета.

У вас в m_buffer будут все данные, ищите в нем начальный/конечный маркер, или как там вы длину определяете.

А readAll(); это что?

QByteArray QIODevice::readAll()

Сокет наследник QIODevice.

[stix357]

А как в ожидание уйти?

Просто выйти из слота обработчика.

Мне изначально неизвестен размер пакета.

У вас в m_buffer будут все данные, ищите в нем начальный/конечный маркер, или как там вы длину определяете.

А readAll(); это что?

QByteArray QIODevice::readAll()

Сокет наследник QIODevice.

Хм, огромное спасибо. Мой дурацкий цикл идет нафиг.
А как мне узнать сколько я получил в порции(пакете), не пересчитывая каждый раз m_buffer ?

[Пантер]

> А как мне узнать сколько я получил в порции(пакете), не пересчитывая каждый раз m_buffer ?
Конкретизируй вопрос.

[stix357]

> А как мне узнать сколько я получил в порции(пакете), не пересчитывая каждый раз m_buffer ?
Конкретизируй вопрос.

Ммм ... Вот такая штука по совету Old (Да хранят его боги!) получилась

Код

C++ (Qt)
// Слот обработки сигнала readyRead()
void TCPClientQt::onReadData()
{
 
    QString strArr="";
    int pos;
    m_ReadBuffer += m_pTcpSocket->readAll();
    //m_ptxtInfo->append(QTime::currentTime().toString("hh:mm:ss.zzz")
                       //+" onReadData "+QString::number(m_ReadBuffer.size()));
    //m_count=m_pTcpSocket->bytesAvailable()+m_count;m_count=+m_count;
    // Мы все вычитываем в буфер m_buffer
    // Здесь мы можем проверить находится ли в буфере полный пакет данных для обработки, если да - обрабатываем его и выкусываем из буфера
    if(!isBegin && m_ReadBuffer.contains("+WIND:83:"))
    {
        pos=17;
        strArr=m_ReadBuffer.left(pos);
        m_ptxtInfo->append(QTime::currentTime().toString("hh:mm:ss.zzz")
                           +" Begin "+QString::fromAscii("+WIND:83:"));
        isBegin=true;
    }
    if(!isEnd && m_ReadBuffer.contains("+WIND:85:"))
    {
        pos=m_ReadBuffer.indexOf("+WIND:85:");
        strArr=m_ReadBuffer.right(17);
        m_ptxtInfo->append(QTime::currentTime().toString("hh:mm:ss.zzz")
                           +" End "+QString::fromAscii("+WIND:85:"));
       isEnd=true;
    }
    m_ptxtInfo->append(QTime::currentTime().toString("hh:mm:ss.zzz")
                       +" Recive "+QString::number(m_count));
    //Если в буфере осталась только часть пакета, то просто выходим и ждем следующую порцию данных
}
 

Я хочу узнать сколько прибежало в пакете, дабы посчитать сумму не бегая каждый раз по размеру m_ReadBuffer.size() - вроде это накладно, каждый раз пересчитывается размер массива.
m_count=m_pTcpSocket->bytesAvailable()+m_count;
но m_pTcpSocket->bytesAvailable() равно 0

[Пантер]

Вызвать лишний раз QByteArray::size не страшно. Там вообще наверное инлайновый метод.

[Old]

но m_pTcpSocket->bytesAvailable() равно 0

Это вы после чтения вызываете? Конечно там 0 будет.

И не увидел у вас выкусывание уже обработанного пакета из m_buffer?

[stix357]

Это вы после чтения вызываете? Конечно там 0 будет.

Я полагал, что там все одно цикл чтения, пока пакеты бегут.

И не увидел у вас выкусывание уже обработанного пакета из m_buffer?

А это черновик пока (отдельная прога для тестирования) без выкусывания Еще в поток упихать надо.

[Old]

Еще в поток упихать надо.

Зачем? Там долгая обработка пакета?

[stix357]

Еще в поток упихать надо.

Зачем? Там долгая обработка пакета?

Не, это модуль, который встраивается в основную программу.
И там в отдельном потоке приходят сигналы еще с 2-х устройств. Встроенные платы АЦП.
Одна стробирующие импульсы выдает по прохождению трубы в установке через каждые 50 мм.
А труба летит со скоростью 700 мм/сек.
А вторая плата АЦП температуру привода выдает.
И мне данные со своей части с ними увязать надо.

[Пантер]

Еще в поток упихать надо.

Зачем? Там долгая обработка пакета?

Не, это модуль, который встраивается в основную программу.
И там в отдельном потоке приходят сигналы еще с 2-х устройств. Встроенные платы АЦП.
Одна стробирующие импульсы выдает по прохождению трубы в установке через каждые 50 мм.
А труба летит со скоростью 700 мм/сек.
А вторая плата АЦП температуру привода выдает.
И мне данные со своей части с ними увязать надо.

У меня есть прога для парсинга данных от автомобильных трекеров. Идет чтение бинарных данных из сокета, парсинг их, формирование xml и выдача его наружу. Одновременно обрабатывается сейчас до 3К трекеров - загрузка процессора меньше 10%. Да, ассинхронка с одним основным потоком. А данные трекеры шлют часто, пакетов по 10 в секунду может быть.

[stix357]

У меня есть прога для парсинга данных от автомобильных трекеров. Идет чтение бинарных данных из сокета, парсинг их, формирование xml и выдача его наружу. Одновременно обрабатывается сейчас до 3К трекеров - загрузка процессора меньше 10%. Да, ассинхронка с одним основным потоком. А данные трекеры шлют часто, пакетов по 10 в секунду может быть.

А тут еще надо параллельно график в Гуе для оператора выводить, по мере поступления данных. Вот и приходится с потоками возится.

[Пантер]

У меня есть прога для парсинга данных от автомобильных трекеров. Идет чтение бинарных данных из сокета, парсинг их, формирование xml и выдача его наружу. Одновременно обрабатывается сейчас до 3К трекеров - загрузка процессора меньше 10%. Да, ассинхронка с одним основным потоком. А данные трекеры шлют часто, пакетов по 10 в секунду может быть.

А тут еще надо параллельно график в Гуе для оператора выводить, по мере поступления данных. Вот и приходится с потоками возится.

Тогда далаются 2 потока - в одном гуй живет, а в другом все общение с девайсами. И прячется все за каким-нибудь Фасадом.

[Пантер]

А еще можно разделить на гуй и сервис.