Ytukyg

I'm working on a simple Qt application for video streaming over TCP. There is a device (server side) that start listening for incoming connections. When a new connection is created, the server start to send images to the client. On the other side, the client receive and display the images.
I've read a lot about IPC on Qt, datastream and transactions, but I'm yet struggling with reading the incoming data. I know that TCP divide a long block in several packets, that's the point I'm in trouble.

Here is my code for sending ..

void CameraServer::sendData(const QImage &img)

{

    if (mTcpClient->state() == QTcpSocket::ConnectedState) {



        QByteArray imgArray = QByteArray::fromRawData((const char*) img.bits(), img.byteCount());



        // init

        QByteArray data;

        QDataStream outStream(&data, QIODevice::WriteOnly);

        outStream.setDevice(mTcpClient);

        outStream.setVersion(QDataStream::Qt_5_11);



        // serialize

        outStream << imgArray.size();

        outStream << imgArray;



        // send

        mTcpClient.write(data);

        mTcpClient->waitForBytesWritten();

        mTcpClient->flush();



        qDebug() << "Sent" << data.size() << "bytes";

}

.. and for reading.

void VCameraClient::readData()

{

    qDebug() << "Received" << mTcpSocket->bytesAvailable() << "bytes";





    if (size == 0) {

        // read the image size

        // toBeRead is a class private member

        inputStream >> toBeRead;

    }



    // read partial data

    // byteArr is a class private member

    if (mTcpSocket->bytesAvailable() < toBeRead) {

        byteArr.append(mTcpSocket->read(mTcpSocket->bytesAvailable()));



        // update the size to be read

        toBeRead -= byteArr.size();

    }



    // read completed

    if (toBeRead <= 0) {

        mframe = QImage((const uchar*) byteArr.data(), 640, 480, QImage::FormatRGB888);

        emit newFrameRead(mFrame);

    }

}

Could anyone help me, please? How to use QDataStream transactions properly?