QTcpSocket writing reading problem

[Misenko]

Hi all

I have two network applications, something like client and server.
On the server side I write data to socket which is in QByteArray.

qint64 size = socket->write(array);
		qDebug() << "written" << size;

qint64 size = socket->write(array);
		qDebug() << "written" << size;

To copy to clipboard, switch view to plain text mode 

On the client side in slot which is connected to readyRead signal I first read quint32 which is size of data and then I read data to QByteArray.

QDataStream socketStream(socket);
 
    quint32 size;
    socketStream >> size;
    qDebug() << "size" << size;
    qDebug() << "socketAvailable" << quint32(socket->bytesAvailable());
 
    if (quint32(socket->bytesAvailable()) < size)
    		return;
 
    QByteArray array = socket->read(size);

QDataStream socketStream(socket);
    
    quint32 size;
    socketStream >> size;
    qDebug() << "size" << size;
    qDebug() << "socketAvailable" << quint32(socket->bytesAvailable());
    
    if (quint32(socket->bytesAvailable()) < size)
    		return;
    
    QByteArray array = socket->read(size);

To copy to clipboard, switch view to plain text mode 

So qDebug() on server side give me

warning: written 17980
warning: written 224 
warning: written 135176

warning: written 17980
warning: written 224 
warning: written 135176

To copy to clipboard, switch view to plain text mode 

but on teh client side

warning: size 17976 
warning: socketAvailable 17976 
 
warning: size 220 
warning: socketAvailable 220 
 
warning: size 135172 
warning: socketAvailable 98300

warning: size 17976 
warning: socketAvailable 17976 

warning: size 220 
warning: socketAvailable 220 

warning: size 135172 
warning: socketAvailable 98300

To copy to clipboard, switch view to plain text mode 

First four warnings are correct becouse I read size which is 4 bytes so it is smaller but the last two do not match. Every time I write to socket more then 98304 bytes it doesnt let me to read them all and I do not know why. In the second calling of client slot when is readyRead emit again there are all data available but I cant read it exactly becouse I have already read their size before. How can I solve this problem? Thanks.

[mummy]

Look for http://doc.trolltech.com/4.4/qabstra...readBufferSize on client side and http://doc.trolltech.com/4.4/qabstractsocket.html#flush on server side.

[caduel]

i) you have to make sure that enough data is available before reading your block size, too
ii) you have to store the size you read (in some member variable)
iii) you have to check whether you already have the block size, if not: see i); else wait for "block size bytes available *without* reading a blocksize again"

HTH

[Misenko]

Thanks for responding.

to caduel:
How can I make sure that enough data is available before reading block size?

The problem is that I have connected readyRead signal from socket to slot which take that socket and create new thread to read data from it. So I cant make member variable which will be size becouse when next readyRead is emited with rest of data next thread is created. Isnt there any way how can I wait in thread for rest of data or how can I set how much data must be written for emiting readyRead? I cant use socket->waitForReadyRead(xyz) in thread becouse I do not know how long to wait becouse sometime for one piece of data which I write on server side 2 or 3 or more times readyRead is emited.

[caduel]

try a method/class like (untested)

class InputProcessor : public QObject
{
Q_OBJECT
 
QIODevice *input_;
qint64 blocksize_;
QDataStream datastream_;
 
public:
   InputProcessor(QIODevice *input, QObject *parent=0)
   : QObject(parent)
   , blocksize_(0)
   , input_(input)
   , datastream(input)
   {
      connect(input_, SIGNAL(readyRead()), SLOT(slotProcessInput()));
   }
 
public slots:
// connect tcp socket readyRead() here
void slotProcessInput()
{
    // if we do not have a block size, wait for enough bytes
    if (blocksize_==0)
    { // wait for blocksize
       if (input_->bytesAvailable() < sizeof(qint64))
         return;
       datastream_ >> blocksize_;
    }
 
    // now we know the size of the transmitted block: wait for the data
    if (input_->bytesAvailable() < blocksize_)
      return; // we will be called again
 
   // all data here, read block:
   // datastream_ >> ...;
 
   blocksize_ = 0; // wait for next block (size)
}
 
};

class InputProcessor : public QObject
{
Q_OBJECT

QIODevice *input_;
qint64 blocksize_;
QDataStream datastream_;

public:
   InputProcessor(QIODevice *input, QObject *parent=0)
   : QObject(parent)
   , blocksize_(0)
   , input_(input)
   , datastream(input)
   {
      connect(input_, SIGNAL(readyRead()), SLOT(slotProcessInput()));
   }

public slots:
// connect tcp socket readyRead() here
void slotProcessInput()
{
    // if we do not have a block size, wait for enough bytes
    if (blocksize_==0)
    { // wait for blocksize
       if (input_->bytesAvailable() < sizeof(qint64))
         return;
       datastream_ >> blocksize_;
    }

    // now we know the size of the transmitted block: wait for the data
    if (input_->bytesAvailable() < blocksize_)
      return; // we will be called again

   // all data here, read block:
   // datastream_ >> ...;

   blocksize_ = 0; // wait for next block (size)
}

};

To copy to clipboard, switch view to plain text mode 

(I have not tried to compile that. Please post if it is buggy.)

HTH