передача данных через QTcpSocket Опции Подписка на тему Сообщить другу Версия для печати Скачать тему Подписка на этот форум Режимы отображения Переключить на: Древовидный Переключить на: Стандартный Линейный

[kas]

здравствуйте! возникла проблема с QTcpSocket. Есть простой клиент, который читает блоками файл и отправляет его на сервер. Сервер: получает данные и записывает их на диск. И возникает такая проблема, что при приеме данных, в некоторый момент времени перестает посылаться сигнал readyRead. При этом данные в буфер сокета записываются и они доступны для чтения. Кто-нибудь сталкивался с такой проблемой? Подскажите в чем может быть причина. Заранее спасибо.

[ViGOur]

В коде.
Покажи код, его думаю немного должно быть...

[inviZ]

kas, скорее всего в обработчике readyRead ты считываешь из буфера только одно сообщение. А буфер на самом деле может уже содержать несколько. Но лучше покажи код.

[kas]

inviZ, спасибо всем за отклик. я уже нашел причину данного глюка.

[ViGOur]

Так опиши решение для следующих страждуших!

[Lemon]

черт...плохо, что топикстартер не описал решения.
Помогите решить идентичную проблему.
Код потокового класса сервера:

void dbClientThread::run()
{    
    s=new QTcpSocket(this);
    if (s->setSocketDescriptor(ID)) 
    {    
        connect(s, SIGNAL(readyRead()), this, SLOT(incomingData()));                    
        exec();        
    }    
}


void dbClientThread::incomingData()
{    
    int n;
    quint16 res;
    quint16 blockSize=0;    
    QDataStream in(s);    
    in.setVersion(QDataStream::Qt_4_6);
    forever
    {
        n=s->bytesAvailable();
        if (blockSize==0)
        {
            if (n<sizeof(quint16))
                break;
            in>>blockSize;
        }
        
        if (n>=(2*sizeof(quint16)))
        {                
            in>>res;
            switch (res)
            {
            case ReqConnect:
                processingConnection(in);            
                break;
            case ReqExecSQuery:
                executionSQuery(in);
                break;
        }        
        blockSize=0;
    }
}

Далее processingConnection

void dbClientThread::processingConnection(QDataStream &in)
{
    ...
    in>>UserName;
    in>>UserPass;        
    ...
    if (user->ConnectToDataBase(DataSource,SessionName))
    {
        ....
                //отправляет результат
        p=s->bytesAvailable();// Здесь p=0 буффер пуст перед записью ответа            
        out<<quint16(0)<<quint16(ResSUCCESS);
        out.device()->seek(0);
        out<<quint16(msg.size()-sizeof(quint16));
        s->write(msg);
    }
    
}

Теперь код клиента, а именно его readyRead связанный слот

void KP_Client::on_getData()
{
    QDataStream in(&s);
    in.setVersion(QDataStream::Qt_4_6);
    QString status,data;        
    int rows=0,column=0;
    quint16    blockSize=0;
    quint16 res;    
    int n;
    forever 
    {
        n=s.bytesAvailable();
        if (blockSize==0)
        {
            if (n<sizeof(quint16))
                break;
            in>>blockSize;
        }        
        if (n>=(2*sizeof(quint16)))
        {            
            in>>res;
            switch (res)
            {
            case ResSUCCESS:                
                ui.statusBar->showMessage(SUCCESS);    
                p=s.bytesAvailable();//p=0 получает ответ от сервера о подключении
                break;
            case ResFAILED:
                in>>status;
                ui.statusBar->showMessage(status);
                break;
            case ResData:
                    ...
                break;
            }
        }    
        blockSize=0;
    }
}

А собственно проблема в том, что после подключения и отправки рез-та (out<<quint16(0)<<quint16(ResSUCCESS)) у сервера больше не сигналит readyRead(), больше ничего от клиента он не принимает. Подключал слот к stateChanged - состояние не меняется, стабильно = 3(соединение установлено)
(qt 4.7.1 VS 2008)

[PAFOS]

Может быть не в этом проблема, но все равно у тебя баг:

void dbClientThread::run()
{
s=new QTcpSocket(this);
....

у тебя родительский объект будет экземпляр dbClientThread, который создан в потоке А.
а сам создаваемый объект будет находится в потоке Б

В связи с этим сигналы от QTcpSocket будут обрабатываться в потоке А (или могут вообще до него не доходить, я точно не помню)

Я делаю так:

dbClientThread *thread = new dbClientThread();
thread->start();
thread->moveToThread(thread); // теперь все методы dbClientThread будут обрабатываться в потоке, который был создан в методе run(). т.е. теперь thread обрабатывает сам себя

ну и в методе dbClientThread::run() при создании сокета не указывай родителя.

[Lemon]

Проблему решило
dbClientThread *thread = new dbClientThread(..., this);
заменить на
dbClientThread *thread = new dbClientThread(...);
хотя преспокойно this стоит в примере
threadfortune
PAFOS большое спасибо за помощь и за исчерпывающее разьеснение

[PAFOS]

Ты уверен что приложение работает так как ты хочешь?))

Поставь в отладчике точку останова на методе void dbClientThread::run()
и на void dbClientThread::incomingData()
когда приложение брякнется, ты увидишь что в методе void dbClientThread::run() у тебя выполняется созданный поток а в методе void dbClientThread::incomingData() выполняется главный)

Получается мнимая многопоточность, товарищ.

Вот мини-проект с доказательствами)

Эскизы прикрепленных изображений

Уменьшено Р Т‘Р С• 72% 950 x 662 (48.02 килобайт)

Уменьшено Р Т‘Р С• 70% 876 x 739 (54.47 килобайт)

 

Прикрепленные файлы

 Threads.zip ( 2.72 килобайт ) Кол-во скачиваний: 143

 

[Алексей1153]

PAFOS, зачётный шрифт