qtforum.de

Code: Alles auswählen

class QSocketEngine : public QThread
{
    Q_OBJECT

    private:
        QAbstractSocket *m_pTcpSocket;

	private slots:
        void SocketStateChanged(QAbstractSocket::SocketState socketState);
        void displayError( QAbstractSocket::SocketError socketError);
        void ReadFromSocket();

    protected:
        void run();

    public:
        explicit QSocketEngine(QObject *parent = 0);
};

Code: Alles auswählen

QSocketEngine::QSocketEngine(QObject *parent) :
    QThread(parent)
{
    // neuen Tcp-Socket erstellen
    m_pTcpSocket = new QTcpSocket();

    //--- Objekt in diesen Thread 'verschieben'
    m_pTcpSocket->moveToThread(this);

    connect(m_pTcpSocket,   SIGNAL(readyRead()),
            this,           SLOT(ReadFromSocket() ) );
    connect(m_pTcpSocket,   SIGNAL(error( QAbstractSocket::SocketError)),
            this,           SLOT(displayError(QAbstractSocket::SocketError) ), Qt::DirectConnection);
    connect(m_pTcpSocket,   SIGNAL(stateChanged(QAbstractSocket::SocketState)),
            this,           SLOT(SocketStateChanged(QAbstractSocket::SocketState)), Qt::DirectConnection);
}

void QSocketEngine::run()
{
    static int nConnect = 0;

    qDebug() << "Thread begin";

    do
    {
        qDebug() << "PollForServer - Try Nr" << nConnect;
        nConnect++;
        blockSize = 0;

        // Falls in Verwendung, Socket zurücksetzen
        m_pTcpSocket->abort();

        // Mit dem Server verbinden
        m_pTcpSocket->connectToHost("192.168.1.1", 4000);

    }
    while(!m_pTcpSocket->waitForConnected());

    qDebug() << "Thread end";
}

void QSocketEngine::SocketStateChanged(QAbstractSocket::SocketState socketState)
{
...
...