Russian Qt Forum

C++ (Qt)
connect(mClients[clientNumber].data(), SIGNAL(disconnected()),
            this, SLOT(slotRejectClient()));

C++ (Qt)
// Отключение клиента
int Server::slotRejectClient()
{
    int clientNumber = -1;
    // Поиск клиента, которого требуется отключить
    for (int i = 0; i < mMaxClients; i++)
    {
        if (mClients[i].data() != qobject_cast<QTcpSocket*>(sender()))
            continue;
        clientNumber = i;
        break;
    }
 
    if (clientNumber < 0)
        return -1;
 
    return this->disconnectClient(clientNumber);
}

C++ (Qt)
// Отключение и удаление клиента
int Server::disconnectClient(quint16 clientNumber)
{
    disconnect(mClients[clientNumber].data(), SIGNAL(readyRead()),
               this, SLOT(slotReceiveData()));
    disconnect(mClients[clientNumber].data(), SIGNAL(disconnected()),
               this, SLOT(slotRejectClient()));
    disconnect(mClients[clientNumber].data(), SIGNAL(error(QAbstractSocket::SocketError)),
               this, SLOT(slotClientSocketError(QAbstractSocket::SocketError)));
 
    if (!mClients[clientNumber].isNull())
    {
        // Сокет
        mClients[clientNumber].data()->close();
        mClients[clientNumber].data()->deleteLater();
        mClients[clientNumber] = 0;
    }
 
    emit signalSendTextToLog(QString("Клиент №%1 отключен!").arg(clientNumber));
 
    return 0;
}

C++ (Qt)
0	QAbstractSocketPrivate::canReadNotification	qabstractsocket.cpp		672	0x6cbc0172	
1	QAbstractSocketPrivate::readNotification	qabstractsocket_p.h		77	0x6cbff651	
2	QAbstractSocketEngine::readNotification		qabstractsocketengine.cpp	168	0x6cbb3855	
3	QReadNotifier::event				qnativesocketengine.cpp		1151	0x6cbcc009	
4	QApplicationPrivate::notify_helper		qapplication.cpp		4554	0xa8c020	
5	QApplication::notify				qapplication.cpp		3936	0xa89973	
6	QCoreApplication::notifyInternal		qcoreapplication.cpp		876	0x69dd3b76	
7	QCoreApplication::sendEvent			qcoreapplication.h		231	0x69e4488c	
8	qt_internal_proc				qeventdispatcher_win.cpp	484	0x69df92b7	
9	USER32!IsWindowVisible				C:\Windows\system32\user32.dll	0	0x76f3c4e7	
10	QCharRef::operator=				qstring.h			799	0x12112ca	
11	USER32!IsWindowVisible				C:\Windows\system32\user32.dll	0	0x76f3c5e7	
12	qt_fast_timer_proc				qeventdispatcher_win.cpp	428	0x69df90ec	
13	USER32!IsWindowVisible				C:\Windows\system32\user32.dll	0	0x76f3cc19	
14	??										0		
 
 

C++ (Qt)
mClients[i].data() != qobject_cast<QTcpSocket*>(sender())

C++ (Qt)
mClients[i].isNull() || mClients[i].data() != qobject_cast<QTcpSocket*>(sender())

C++ (Qt)
    // reset the read socket notifier state if we reentered inside the
    // readyRead() connected slot.
    if (readSocketNotifierStateSet && socketEngine &&
        readSocketNotifierState != socketEngine->isReadNotificationEnabled()) {
        socketEngine->setReadNotificationEnabled(readSocketNotifierState); // Тут у нас socketEngine = @0xfeeefeee
        readSocketNotifierStateSet = false;
    }

C++ (Qt)
QTimer::singleShot(1000, mClients[clientNumber].data(), SLOT(deleteLater()));

C++ (Qt)
// Получение данных от клиента, обработка
int Server::slotReceiveData()
{
    bool result = false;
    int clientNumber = 0;
    // Поиск клиента, который выслал данных о MMF
    for (int i = 0; i < mMaxClients; i++)
    {
        if (mClients[i].data() != qobject_cast<QTcpSocket*>(sender()))
            continue;
        result = true;
        clientNumber = i;
        break;
    }
 
    if (!result)
        return -1;
 
    quint16 sizeOfPackage = 0;
    quint8 packageType = 0;
    QByteArray package;
 
    // Парсинг всех пришедших данных
    while (true)
    {
        // Считывание пришедших данных
        if (!mClients[clientNumber].isNull())
            mReceivedData[clientNumber].append(mClients[clientNumber].data()->readAll());
 
        // Проверка на условие: принято недостаточно данных
        if (mReceivedData[clientNumber].size() < (quint16)sizeof(quint16))
            break;
 
        // Получение количества отправленных байт (0 - 1 байты)
        memcpy(&sizeOfPackage,
               mReceivedData[clientNumber].data(),
               sizeof(quint16));
 
        // Проверка на условие: принят не весь пакет целиком
        if (mReceivedData[clientNumber].size() < sizeOfPackage || sizeOfPackage == 0)
            break;
 
        // Получение типа сообщения (2ой байт)
        memcpy(&packageType,
               mReceivedData[clientNumber].data() + sizeof(quint16),
               sizeof(quint8));
 
        // Получение основной части пакета
        const int specialData = sizeof(quint16) + sizeof(quint8);
        package = mReceivedData[clientNumber].mid(specialData,
                                                  sizeOfPackage - specialData);
 
        // Удаление распарсенных данных
        mReceivedData[clientNumber] = mReceivedData[clientNumber].mid(sizeOfPackage);
 
        // Обработка пакета
        switch (packageType)
        {
        case PackageType::Command:
            result = this->parseCommandPackage(clientNumber, package);
            break;
        case PackageType::RegInfo:
            result = this->parseRegInfoPackage(clientNumber, package);
            break;
        case PackageType::MMFName:
            result = this->parseMMFPackage(clientNumber, package);
            break;
        case PackageType::DescriptionRequest:
            break;
        case PackageType::CoefficientRequest:
            break;
        }
 
        if (!result)
            break;
    }
 
    if (!result)
        this->slotDisconnectClient(clientNumber);
 
    return 0;
}

C++ (Qt)
// Запись информации в журнал
int MainWindow::slotAddTextToLog(const QString text)
{
    teLog->append(QDate::currentDate().toString("dd.MM.yyyy") +
                  " " +
                  QTime::currentTime().toString() + " - " + text);
 
    QCoreApplication::processEvents(); // Вот беда, судя по всему этот вызов обрабатывает не только UI-сообщения. Видимо в нем и была проблема
 
    return 0;
}

C++ (Qt)
QCoreApplication::processEvents();

QEventLoop::AllEvents - All events. Note that DeferredDelete events are processed specially. See QObject::deleteLater() for more details.
QEventLoop::ExcludeUserInputEvents - Do not process user input events, such as ButtonPress and KeyPress. Note that the events are not discarded; they will be delivered the next time processEvents() is called without the ExcludeUserInputEvents flag.
QEventLoop::ExcludeSocketNotifiers - Do not process socket notifier events. Note that the events are not discarded; they will be delivered the next time processEvents() is called without the ExcludeSocketNotifiers flag.

C++ (Qt)
QSocketNotifier: Invalid socket specified
QSocketNotifier: Internal error

C++ (Qt)
void SocketListener::addConnection_p (QTcpSocket *socket)
{
	connect (socket, SIGNAL (readyRead()), SLOT (readyRead()));
	connect (socket, SIGNAL (disconnected()), SLOT (disconnected()));
 
	sockets_.push_back ( {socket, false});
	qDebug () << "New connection" << socket->peerAddress ();
}
 
void SocketListener::readyRead()
{
	QTcpSocket *socket = qobject_cast <QTcpSocket *> (sender ());
	Q_CHECK_PTR (socket);
 
	do {
		const QString reply = Utils::readLineFromSocket (socket);
 
		if (!replyAnalizer_.setReply (reply, socket)) {
			qWarning () << "Socket reply is incorrect" << reply;
			socket->disconnectFromHost ();
		}
	} while (socket->canReadLine ());
}
 
void SocketListener::disconnected()
{
	QTcpSocket *socket = qobject_cast <QTcpSocket *> (sender ());
	Q_CHECK_PTR (socket);
 
	qDebug () << "Closed connection" << socket->peerAddress ();
 
	socket->deleteLater ();
	sockets_.erase (findSocket (socket));
}
 
SocketListener::Sockets::iterator SocketListener::findSocket (QTcpSocket *socket)
{
	return std::find_if (sockets_.begin(),
						 sockets_.end(),
	[socket] (const Socket & s) -> bool {
		return s.first == socket;
	}
						);
}