Передача данных в отдельном потоке. Сервер не успевает обработать данные. Опции

[kibsoft]

Есть сервер и клиент (отсылает данные, например файл):
Клиент:

void FileSender::sendFile()
{
    QFile file(filePath);
    if (file.open(QIODevice::ReadOnly)) {//если файл открылся
        QByteArray dataForPeer;//массив для данных
        QDataStream out(&dataForPeer, QIODevice::WriteOnly);//выходной поток
        QByteArray byteArray;//поток байтов из файла
        while(!file.atEnd()) {//пока не конец файла
             byteArray=file.read(1024);//читаем по килобайту
             out << quint16(0) << FILEBYTES << byteArray;
             out.device()->seek(0);
             out << quint16(dataForPeer.size() - sizeof(quint16));
             tcpSocket->write(dataForPeer);

             dataForPeer.clear();//очищаем массив для отправки серверу
        }
        //отправка уведомления об окончании передачи файла
        out << quint16(0) << SENDING_FINISHED;
        out.device()->seek(0);
        out << quint16(dataForPeer.size() - sizeof(quint16));
        tcpSocket->write(dataForPeer);

        file.close();//закрываем файл
    }
}

На сервере есть слот, соединенный с сигналом readyRead сокета, но видимо данные приходят так быстро, что сервер не успевает сделать нужные действия (а именно записать на диск). Что можно придумать? Можно ли как то на клиенте узнать считаны ли данные сервером или нет(и ждать этого момента)? В голову приходит только одно: от сервера высылать уведомление о принятых данных, чтобы клиент мог дальше передавать их (но мне кажется, что что-то не то).

[BRE]

Покажи как читаются данные на другой стороне.

[kibsoft]

/*
  Слот для обработки принятых из сокета данных.
*/
void FileWriter::readBytes()
{
    QTcpSocket *tcpSocket=(QTcpSocket*)sender();//получаем сокет
    QDataStream in(tcpSocket);
    quint16 nextBlockSize=0;//размер принятого блока
    for(;;) {
        if(!nextBlockSize) {
            if(tcpSocket->bytesAvailable()<sizeof(quint16)) break;//если данных принято меньше 2 байт, то выходим

            in>>nextBlockSize;//получаем размер блока
        }

        if(tcpSocket->bytesAvailable()<nextBlockSize) break;//если все данные получены, то продолжаем работать

        quint8 request;//получаем запрос
        in>>request;
        TypeOfRequest type=(TypeOfRequest)request;
        if (type==FILEBYTES) {//если данные - файл, то записываем их на жесткий диск
            writeBytes(in);
        }
        else if (type==SENDING_FINISHED) {//если пир окончил отправку файла, то отправляем ему
            sendFinishMessage(tcpSocket);//уведомление об окончании его принятия
        }
        nextBlockSize=0;
    }   
}

/*
  Функция записи принятых данных в файл. Параметры: поток данных из сокета(reference).
*/
void FileWriter::writeBytes(QDataStream &in)
{
    QByteArray bytes;
    in>>bytes;//получаем нужные байты
    QFile file("D:/ref.dat");
    if (file.open(QIODevice::Append)) {
        file.write(bytes);//записываем байты
        file.close();
    }
}


/*
  Функция отправки сообщения об окончании принятия файла. Параметры: принимающий сокет.
*/
void FileWriter::sendFinishMessage(QTcpSocket *tcpSocket)
{
    QByteArray dataForPeer;//массив для данных
    QDataStream out(&dataForPeer, QIODevice::WriteOnly);//выходной поток
    out << quint16(0) << quint8(RECEIVING_FINISHED);//соообщение об окончании
    out.device()->seek(0);
    out << quint16(dataForPeer.size() - sizeof(quint16));
    tcpSocket->write(dataForPeer);
}

[BRE]

Посмотри примеры еще раз и обрати внимание на то, как определена эта переменная:

void FileWriter::readBytes()
{
    ....
    quint16 nextBlockSize=0;//размер принятого блока
    ....

[kibsoft]

Посмотри примеры еще раз и обрати внимание на то, как определена эта переменная:

void FileWriter::readBytes()
{
    ....
    quint16 nextBlockSize=0;//размер принятого блока
    ....

Спасибо, что подсказали. Объявил в хедере. Но все равно сервер не успевает записывать данные.
В консоль вывел количество раз запуска слота и записи данных. Передается файл размером 42Кб:

1 //слот о принятии данных вызван
Writing: 1 //запись
Writing: 2
2
3
4
5
6

На самом деле, если я передаю по 1 Кб, то дожно быть около 42 вызовов.. Или я что-то не так думаю?

[BRE]

Может быть не так, алгоритм Нагла думаю включен, поэтому TCP-стек скорее всего пакеты объединяет.

[kibsoft]

Может быть не так, алгоритм Нагла думаю включен, поэтому TCP-стек скорее всего пакеты объединяет.

Щас продебажил, на сервере (в слоте обработки) сокет действительно собирает пакеты не по 1024 байта, как отсылаются, а иногда по 30Кб даже, поэтому мой обработчик естественно не может определить по флагам(FILEBYTES) нужно ли записывать инфу. Как можно этого избежать? Если отключить алгоритм Нагла, то будет в разы медленней? И вообще можно ли его отключить? И вообще есть у кого-то какие-нибудь предложения?

[BRE]

А не нужно отключать алгоритм Нагла, нужно придерживаться при чтении своего же протокола.
Ты пишешь по 1K, а при чтении читаешь все, со всеми управляющими командами. А нужно читать так же как пишешь по 1K.

[kibsoft]

А не нужно отключать алгоритм Нагла, нужно придерживаться при чтении своего же протокола.
Ты пишешь по 1K, а при чтении читаешь все, со всеми управляющими командами. А нужно читать так же как пишешь по 1K.

Т.е. не использовать QDataStream, а использовать read у объекта сокета? Не совсем понимаю как это реализовать.

[BRE]

Проверь несколько раз, сколько байт (какими порциями) реально читает эта функция из сокета:

void FileWriter::writeBytes(QDataStream &in)
{
    QByteArray bytes;
    in>>bytes;

    qDebug() << "Read data size from socket:" << bytes.size();

    QFile file("D:/ref.dat");
    if (file.open(QIODevice::Append)) {
        file.write(bytes);//записываем байты
        file.close();
    }
}