Qt, Threads, Sockets...

[i-cpp]

Я в Qt новичок. Подскажите где накосячил. Код компилется норм. Но если отправлять данные несколько раз подряд, подключение есть, а данные могут прийти, а могут и не прийти. Возможно нужно синхронизировать потоки, но я никак не соображу. Помогите, пжлст!!! Ниже частичная реализация thread.cpp и server.cpp:

server.cpp

#include <QtGui>
#include <QtNetwork>
#include "server.h"
#include "thread.h"
// ----------------------------------------------------------------------
void server::startServer(int nPORT)
{
    // создаем сервер и слушаем порт
    m_pTcpServer = new QTcpServer(this);
    m_pTcpServer->setMaxPendingConnections(100);
    if (!m_pTcpServer->listen(QHostAddress::Any, nPORT)) {
        m_pTerminal->append(QDateTime::currentDateTime().toString()
            + " : Server error <<" + m_pTcpServer->errorString() + ">>");
        m_pTcpServer->close();
        return;
    }
    // slotNewConnection() происходит при новом подключении к m_pTcpServer
    connect(m_pTcpServer, SIGNAL(newConnection()), this, SLOT(slotNewConnection()));
}
// ----------------------------------------------------------------------
void server::slotNewConnection()
{
    QTcpSocket* pClientSocket;
    pClientSocket = m_pTcpServer->nextPendingConnection(); // возращаем следующее подключение
    ClientThread *th = new ClientThread(*pClientSocket);
    connect(th, SIGNAL(finished()), th, SLOT(deleteLater()));
    connect(th, SIGNAL(finished()), this, SLOT(slotClientThreadFinished()));
    connect(th, SIGNAL(sendMsg(QString)), this, SLOT(slotRecvMsg(QString)));
    th->start();
    m_pTerminal->append(QDateTime::currentDateTime().toString()
        + " : connect from " + pClientSocket->peerAddress().toString());
}
// ----------------------------------------------------------------------
void server::slotClientThreadFinished()
{
    m_pTerminal->append(QDateTime::currentDateTime().toString()+" : client thread finished!");
}
// ----------------------------------------------------------------------
void server::slotRecvMsg(QString msg)
{
    m_pTerminal->append(QDateTime::currentDateTime().toString() + msg);
}

thread.cpp

#include "thread.h"
// ----------------------------------------------------------------------
ClientThread::ClientThread(QTcpSocket &pSocket)
{
    pClientSocket = &pSocket;
}
// ----------------------------------------------------------------------
void ClientThread::run()
{
    ui_t = QDateTime::currentDateTime().toTime_t(); // запомнить время подключения

    connect(pClientSocket, SIGNAL(disconnected()), pClientSocket, SLOT(deleteLater()));
    connect(pClientSocket, SIGNAL(disconnected()), this, SLOT(slotDisconnectClient()));
    connect(pClientSocket, SIGNAL(readyRead()), this, SLOT(slotReadClient()));

    exec();
}
// ----------------------------------------------------------------------
void ClientThread::slotReadClient()
{
    QByteArray block;
    block = pClientSocket->readAll();
    client_data += block;
}
// ----------------------------------------------------------------------
void ClientThread::slotDisconnectClient()
{
    emit sendMsg(client_data);
    emit finished();
}

[i-cpp]

почему-то данные считываются только из последнего подключения. Все потоки работают только с последним сокетом.

блокирую глобальные переменные mutex'ами не помогат; метод тыка не работает)