QDataStream in(tcpSocket), теперь readyRead от tcpSocket идут в in, так?

[Ruzzz]

Т.е. если я использую QDataStream in(tcpSocket), то in возьмет на себя получение всех частей(чанков)? И мне просто остается пользоватся оператором in >> MY_VAR, но все еще следует проверять перед чтением этим tcpSocket->bytesAvailable(), так ли?

Если так, то могу ли я все это проделать при самом первой посылке readyRead от tcpSocket?

[Ruzzz]

И еще вопрос по readAll, он дает гарантию что прочитает все за один раз? Или нужно использовать что то типа:

Код

C++ (Qt)
    while(tcpSocket->state() == QAbstractSocket::ConnectedState) {
 
        if (!tcpSocket.waitForReadyRead(timeout)) return;
 
        block = tcpSocket.readAll();
        ...
 
    } // while

[Ruzzz]

Интересует именно обработка в qt заголовка 'CHUNKED', хотя может и еще какие нюансы есть

[kuzulis]

И еще вопрос по readAll, он дает гарантию что прочитает все за один раз?

Неа, если глянуть в исходники , то максимум за раз может прочитать <=4096 байт (если не путаю)!

т.е. прочитает ВСЕ что пришло в сокет - но это не значит что это ВСЕ - есть ВСЁ !

А обязательно использовать QDataStream ?

[kuzulis]

И я бы например читал вот таким макаром (пример без использования сигнала readyRead):

Код:

...
    QByteArray data;
    bool ret = sock->waitForReadyRead(таймаут ожидания прихода пакета данных в сокет);
    if (ret) {
        do {
            quint64 bav = sock->bytesAvailable();
            if (bav > 0) 
                data.append(read(bav));
            else return ошибка;
        } while (sock->waitForReadyRead(таймаут ожидания следующего байта в сокет);) //например около 5-50 мс, в зависимости от твоей идеологии приложения
        return data;
    } else return таймаут
...

[Ruzzz]

да исходники я изучаю, не всегда получается разобраться в них (
Тогда еще вопрос, почему это «if (bav > 0) … else return ошибка;» — разве это ошибка? Или если sock->waitForReadyRead вернул true, но прочитали 0 байт, значит ошибка?

[kuzulis]

Тогда еще вопрос, почему это «if (bav > 0) … else return ошибка;» — разве это ошибка? Или если sock->waitForReadyRead вернул true, но прочитали 0 байт, значит ошибка?

в данном случае - ДА! т.к. если ret = true - то это значит что пришел хотябы 1 байт пакета, и если после этого bytesAvailable вернет 0 - то значит это ошибка, т.к. вернуть должно >0

[Ruzzz]

Неа, если глянуть в исходники , то максимум за раз может прочитать <=4096 байт (если не путаю)!

Похоже что путаете ) Вот из qiodevice.cpp для QByteArray QIODevice::readAll():

Код

C++ (Qt)
    if (d->isSequential() || size() == 0) {
        // Read it in chunks. Use bytesAvailable() as an unreliable hint for
        // sequential devices, but try to read 4K as a minimum.
        int chunkSize = qMax(qint64(4096), bytesAvailable());
        qint64 totalRead = 0;
        forever {
            tmp.resize(tmp.size() + chunkSize);
            qint64 readBytes = read(tmp.data() + totalRead, chunkSize);
            tmp.chop(chunkSize - (readBytes < 0 ? 0 : readBytes));
            if (readBytes <= 0)
                return tmp;
            totalRead += readBytes;
            chunkSize = qMax(qint64(4096), bytesAvailable());
        }

Как видим - пытаемся прочитать минимум 4096, а максимуи сколько дают Причем в цикле пытаемся и пытаемся читать. И если мы ждем что нам должны что-то прислать, то только какая-либо ошибка может помешать нам считать все пришедшие данные. По-моему так.

Да и как видим если мы используем ReadAll, то перед этим не нужно проверять этим bytesAvailable, просто ReadAll это сделает, хотя все зависит от ситуации. В вот для read возможно стоит также проверить то что возвращает она. Вообще вот:

Код

C++ (Qt)
qint64 QIODevice::bytesAvailable() const
{
    Q_D(const QIODevice);
    if (!d->isSequential())
        return qMax(size() - d->pos, qint64(0));
    return d->buffer.size();
}

То есть bytesAvailable просто возвращает разницу размера и позиции внутреннего буфера. Так что я бы лучше проверял что возвращают функции read