Ожидание чтения и сокращение загрузки процессора. Опции

[dasV]

Добрый день уважаемые. Я новичок в qt да и в c++ поэтому бейте меня и посылайте на RTFM.


Есть Вот такой код

QString M_class::ReadSocket()
{
    QTime TimeOut;
    TimeOut.start();
    while(!socket.waitForReadyRead())
        {    
            QCoreApplication::processEvents();
            if(TimeOut.elapsed()>=6000)
            {
                return(0);
            }
        }
    return(socket.readAll());
}

Так вот он создает нагрузку на процессор, а если ожидание затягивается, то и вовсе становится неприятно что я такой вот пожиратель тактов.

Можно ли справить ситуацию?? Сразу оговорюсь что программа консольная и в ней нет Q_OBJECT с вызовом QTimer::timeout ()

Да еще вопрос, к месту ли тут QCoreApplication::processEvents()???

С уважением

[dasV]

Доброго времени суток уважаемые.
Сделал как и сказано было, однако возникла проблема, если первый раз я произвожу запись из функции socketEncrypted() после чего читаю вполне нормально данные полученные от сервера, то второй раз, данные записать не удается. Точнее функция возвращает мне количество записанных данных, однако на деле ничего на сервер не приходит.

Может кто то сталкивался с такой проблемой?

Раскрывающийся текст

void ssl_class::socketReadyRead()
{

    QString tmp;
    bool ok;
    int i; // он вообще то не оч нужен, но так..пусть будет =)

    switch(state)
    {
       case StartSession:
       {
        tmp=xmlParser(socket.readAll());
        SessionID=tmp.toInt(&ok, 10);
        if(!ok)
        {
            if(SessionID<=0)
            {
                //MSG : ошибка логин или пароль, не верны
                emit finish();
            }
        }
        tmp="GET "+get+"/CloseSession?SessionID="+ QString::number(SessionID)+" \r\n";
        i = socket.write(tmp.toUtf8());

        if(i==-1)
        {
            //MSG : Ошибка при записи
        }
        else
        {
            //MSG : записали много байт
        }

        state=CloseSession;

           break;
       }

       case CloseSession:
       {
            tmp=xmlParser(socket.readAll());
            SessionID=tmp.toInt(&ok, 10);
            if(!ok)
            {
                if(SessionID==0)
                {
                    //MSG : все хорошо
                }
            }
            emit finish();
           break;
       }
    }
}

Заранее спасибо.

[igor_bogomolov]

Может я уже немного не в тему и не вовремя, но я бы использовал другую конструкцию. Предлогалось уже использовать сигналы и слоты, так и не понял почему этого не сделали. Я бы использовал следущую конструкцию:

Создал свой класс, наследник от QThread:

class ThreadSocket : public QThread
{
    Q_OBJECT
    
    ...
    QTcpSocket *socket;
    QMutex mutex;
    QWaitCondition cond;
    QByteArray DataIn; 
    ...    
protected:
    void run();
    ...

private slots:
    void readSocket();
    ...
}

Переопредилил Run следущим образом:

void ThreadSocket::run()
{
    const int Timeout = 6 * 1000;
    
    emit SendServer("first_command"); // отправляем данные для записи в соккет
    mutex.lock();
    if ( cond.wait(&mutex, Timeout) ) { // ожидаем ответ. Если получили, разбираем данные и отправляем след. команду
        ... //  разбираем данные, в общем любые требуемые действия.
        DataIn.clear();
        
        emit SendServer("second_command"); // отправляем данные для записи в соккет
        if ( cond.wait(&mutex, Timeout) ) {// ожидаем ответ.
            ... //  разбираем данные, в общем любые требуемые действия.
            DataIn.clear();
            
            // и т.д.
            ...
            ...
            ...
            ...
            
        } else {
            emit displayMessage("Timeout №2"); // отправляем сообщение об ошибке.
        }
    } else {
        emit displayMessage("Timeout №1"); // отправляем сообщение об ошибке.
    }
    mutex.unlock();
            ...
}

SLOT. Чтение динных с сервера:

void ThreadSocket::readSocket()
{
    if ( socket->canReadLine() ) {
        mutex.lock(); // -----------------------
        DataIn = DataIn + socket.readAll();//     |   mutex здесь впринципе не нужен )))
        mutex.unlock(); //-----------------------
        cond.wakeOne();
    }
}

Надеюсь мысль понятна


[offtop]
Простите, но почему я не могу редактировать сообщения?
И как сделать Раскрывающийся текст. А то я обрамил все в тег "Скрытый текст", думал что это оно, теперь и не знаю, читается ли код?
[\offtop]