Method run

YACReaderLibrary/yacreader_local_server.cpp:83–211

include #include #include */

#include <QTextStream>
#include <QDateTime>*/
void YACReaderClientConnectionWorker::run()
{
    /*{
        QFile f(QString("c:/temp/thread%1.txt").arg(count));
        f.open(QIODevice::Append);
        QTextStream out(&f);
        out << QString("Thread%1 starts").arg(count) << endl;
        f.close();
        }
        uint t1 = QDateTime::currentMSecsSinceEpoch();*/

    quint64 libraryId;
    ComicDB comic;
    OpenComicSource source = { OpenComicSource::ReadingList, 0 };
    qulonglong nextComicId;
    int tries = 0;
    int dataAvailable = 0;
    QByteArray packageSize;
    clientConnection->waitForReadyRead(1000);
    while (((long unsigned int)packageSize.size() < sizeof(quint32)) && (tries < 20)) {
        packageSize.append(clientConnection->read(sizeof(quint32) - packageSize.size()));
        clientConnection->waitForReadyRead(100);
        if (dataAvailable == packageSize.size()) {
            tries++;
        }
        dataAvailable = packageSize.size();
    }
    if (tries == 20) {
        QLOG_ERROR() << "Local connection: unable to read the message size" << clientConnection->errorString();
        return;
    }

    QDataStream sizeStream(packageSize);
    sizeStream.setVersion(QDataStream::Qt_4_8);
    quint32 totalSize = 0;
    sizeStream >> totalSize;

    tries = 0;
    QByteArray data;
    int dataRead = 0;
    while ((quint32)data.size() < totalSize && tries < 200) {
        data.append(clientConnection->readAll());
        if ((quint32)data.length() < totalSize)
            clientConnection->waitForReadyRead(100);
        if (dataRead == data.length()) // no bytes were read
            tries++;
        dataRead = data.length();
    }
    if (tries == 200) {
        QLOG_ERROR() << QString("Local connection: unable to read message (%1,%2)").arg(data.size()).arg(totalSize);
        return;
    }
    QDataStream dataStream(data);
    quint8 msgType;
    dataStream >> msgType;

    switch (msgType) {
    case YACReader::RequestComicInfo: {