Обрыв соединения QTcpSocket Опции

[OrSOn]

Всем добрый день! Столкнулся с довольно неприятной проблемой при работе с сокетами... Суть проблемы в следующем:

Имеется сервер и клиент, для общения используют сокеты. В некий момент времени клиент рушится (ну или связь падает, не суть важно), при этом сервер пытается что-то писать в сокет, что приводит к ошибке. Чтобы избежать этого, пробовал ввести проверку

if( tcpSocket->state() != 3 )
    return;
tcpSocket->flush();

Так вот случаются ситуации, что проверка состояния проходит, а сразу после нее до начала проталкивания информации клиент падает и на tcpSocket->flush() снова вылетаю с ошибкой.

Если кто сталкивался с подобным, подскажите, пожалуйста, как это можно обойти...

Сообщение отредактировал OrSOn - 16.2.2010, 14:48

[OrSOn]

Ну все будет сложно сюда перенести, ибо много, я ключевые вещи вставлю...

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

Объявление класса

#ifndef NTHREAD_H
#define NTHREAD_H

#include <QThread>
#include <QTcpSocket>
#include <QTimer>


struct PrioritySocket {
    QTcpSocket * tSocket;
    int prior;
};

struct HashStruct {
    QByteArray hashArr;
    QString filePath;
};

class NThread : public QThread
{
    Q_OBJECT

public:
    NThread( int num );

    void run();
    void readBD(QString & DBName,QString & DBHost, QString & DBUser,QString &  DBPassword,QString & DBDriver);
    bool isFree();
    void unlockDB( QString bName );
    void setIsFree( bool isFree );
    void stopCurrentWork();
    void updateHashMap();
    int myNum;

signals:
    void error(QTcpSocket::SocketError socketError);
    void needDB( QString bName, int threadName );
    void endThreadSocket( PrioritySocket *pSocket );
    void unlockBase( QString bName );
    void readF();

private:
    QMap<QString, HashStruct> hashMap;
    QString neededDB;
    bool dbLocked;
    QTcpSocket *tcpSocket;
    int socketDescriptor;
    QString text;
    bool HasBD;
    int CountFile;
    QString KARTADRIVER;
    QString KARTAHOST;
    QString KARTAGISDATA;
    QString KARTALISTS;
    quint32 blockSize;
    bool threadEnd;
    bool freeThread;
    PrioritySocket *priorSocket;
    bool setSocketFlag;

    int blockLength;

    void setThreadSocketFn();

public slots:
    void readFortune();
    void endThread();
    void setThreadSocket( PrioritySocket *pSocket );
    void setIsFree();
};

#endif

конструктор

NThread::NThread( int num )
: QThread(0)
{
                  myNum = num;
    moveToThread( this );
    setBaseValues();

}

Run

void NThread::run()
{
    connect( this, SIGNAL( readF() ), this, SLOT( readFortune() ), Qt::QueuedConnection );
    exec();
}

Функция установки текущего рабочего сокета на поток (сокет создается в основном потоке и передается на обратоку в один из потоков)

void NThread::setThreadSocket( PrioritySocket *pSocket )
{
    priorSocket = pSocket;    
    tcpSocket = priorSocket->tSocket;

    connect(tcpSocket, SIGNAL(disconnected()), this, SLOT(setIsFree()), Qt::DirectConnection);

    emit readF();
    connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(readFortune()), Qt::QueuedConnection);
}

Соответственно, вызывается эта функция из основного потока, после чего поток начинает реагировать на появление информации в сокете. Отвязывается сокет от потока при завершении передачи или при обрыве связи

void NThread::setIsFree()
{
    disconnect(tcpSocket, SIGNAL(disconnected()), this, SLOT(setIsFree()));
    priorSocket->prior = -1;
    emit endThreadSocket( priorSocket ); //Сигнал основному потоку, что данный сокет завершил текущую работу, удалить, если связь прервалась или поставить в очередь, если есть еще запросы с него.
    freeThread = true;
    
}

Вот примерно такая структура...