(SOLVED) Data loss over tcp connection?

[giowck]

thanks for your answer. I looked at the source code from various examples... The problem is that i need a blocking function (no signals like readyRead() ...)

i only use socket.waitForReadyRead()... So how can i continue the function block only if i have all data?

Something like:

...
socket.waitForReadyRead();
 
inStream >> size;
 
if (size > socket.bytesAvailable())
      socket.waitForReadyRead();
 
instream >> database;
...

...
socket.waitForReadyRead();

inStream >> size;

if (size > socket.bytesAvailable())
      socket.waitForReadyRead();

instream >> database;
...

To copy to clipboard, switch view to plain text mode 

?

Sorry im new at network programming

[caduel]

well, while-loops are not network-specific, are they?

code taken from fortune client example

const int Timeout = 5 * 1000;
 
// wait for blocksize to arrive
while (socket.bytesAvailable() < (int)sizeof(quint16)) {
   if (!socket.waitForReadyRead(Timeout)) {
      emit error(socket.error(), socket.errorString());
      return;
   }
}
 
// read blockSize
quint16 blockSize;
QDataStream in(&socket);
in.setVersion(QDataStream::Qt_4_0);
in >> blockSize;
// blocksize does not include "itself"
 
// now we know how much data has to arrive in total
// wait for rest of the block...
while (socket.bytesAvailable() < blockSize) {
  if (!socket.waitForReadyRead(Timeout)) {
     emit error(socket.error(), socket.errorString());
     return;
}
 
// now we are sure that no 'short reads' can happen
instream >> database;

const int Timeout = 5 * 1000;

// wait for blocksize to arrive
while (socket.bytesAvailable() < (int)sizeof(quint16)) {
   if (!socket.waitForReadyRead(Timeout)) {
      emit error(socket.error(), socket.errorString());
      return;
   }
}

// read blockSize
quint16 blockSize;
QDataStream in(&socket);
in.setVersion(QDataStream::Qt_4_0);
in >> blockSize;
// blocksize does not include "itself"

// now we know how much data has to arrive in total
// wait for rest of the block...
while (socket.bytesAvailable() < blockSize) {
  if (!socket.waitForReadyRead(Timeout)) {
     emit error(socket.error(), socket.errorString());
     return;
}

// now we are sure that no 'short reads' can happen
instream >> database;

To copy to clipboard, switch view to plain text mode 

you have to take care if blockSize is the size of the complete package (including the 2 bytes of the quint16 of blocksize itself) or just the data part's size. in the fortune server example blocksize is only the data part

HTH

[giowck]

Hey thanks... BTW i solved the problem with this loop:

qint64 size;
    QString serverPass;
    quint16 reqType;
    QByteArray data;
 
    in >> size;
 
    while (tcpSocket->bytesAvailable() < size) {
        if (!tcpSocket->waitForReadyRead()) {
            qDebug() << "Not enough bytes!";
            disconnectFromServer();
            return false;
        }
    }
 
    in >> serverPass >> reqType >> data;

qint64 size;
    QString serverPass;
    quint16 reqType;
    QByteArray data;

    in >> size;

    while (tcpSocket->bytesAvailable() < size) {
        if (!tcpSocket->waitForReadyRead()) {
            qDebug() << "Not enough bytes!";
            disconnectFromServer();
            return false;
        }
    }

    in >> serverPass >> reqType >> data;

To copy to clipboard, switch view to plain text mode 

THANKS!!!