QTcpSocket в QThread - PullRequest
Новая
       38

QTcpSocket в QThread

1 голос
/ 09 октября 2009

У меня есть простой поток подключения к серверу. При вызове функции receiveString происходит сбой. Однако, когда вы выполняете тот же код в run (), он завершается успешно. Что нужно для работы функции receiveString?

Я пробовал оба 

bool TestServerThread::receiveString(QTcpSocket& sock, QString& str)
bool TestServerThread::receiveString(QTcpSocket* sock, QString& str)

Фактический код: 

TestServerThread::TestServerThread(int socketDescriptor, QObject *parent) : QThread(parent), socketDescriptor(socketDescriptor)
{
}


bool TestServerThread::receiveString(QTcpSocket& sock, QString& str)
{
    if(sock.isValid())
    {
        if(!sock.waitForReadyRead(30))
        {
            qWarning() << "fail"; // fails here
            return false;
        }
        QByteArray buf = sock.readAll();
        str = buf;
    }
}

void TestServerThread::run()
{
    QTcpSocket sock;
    if (!sock.setSocketDescriptor(socketDescriptor)) {
        emit error(sock.error());
        return;
    }

    bool ok = true;
    while(ok)
    {
        QString str;
        //if(ok) ok = receiveString(sock, str);

        if(!sock.waitForReadyRead(30))
        {
            qWarning() << "false";
        }
        QByteArray buf = sock.readAll(); // same routine succeeds
        str = buf;
        qWarning() << str;

        qWarning() << "Received: " << str;
        if(ok) ok = sendString(sock, "kaka");
    }
    sock.disconnectFromHost();
    sock.waitForDisconnected();
}

Ответы [ 2 ]

2 голосов
/ 12 октября 2009

Либо ваш код испортил стек процесса, либо значение тайм-аута недостаточно.

1 голос
/ 12 октября 2009

Что такое возвращаемое значение или QTcpSocket::errorString()? 

//...
if(!sock.waitForReadyRead(30))
{
    qWarning() << "fails " << sock.errorString(); // fails here
    emit error(sock.error());
    return false;
}
//...

Обратите внимание, что во время выполнения вы всегда читаете данные в сокете, даже если QTcpSocket::waitForReadyRead вернул false.
Вы уверены, что не получаете ту же ошибку в run, как в receiveString, но чтение завершается успешно, потому что вы игнорируете эту ошибку?

Будет ли run все еще успешным, если вы используете этот код: 

bool ok = true;
while(ok)
{
    QString str;
    //if(ok) ok = receiveString(sock, str);

    if(sock.waitForReadyRead(30))
    {
        QByteArray buf = sock.readAll(); // same routine succeeds
        str = buf;
        qWarning() << str;
        qWarning() << "Received: " << str;
        if(ok) 
        {
            ok = sendString(sock, "kaka");
        }
    }
    else
    {
         qWarning() << "fails " << sock.errorString();
         ok = false;
    }
}
...