Constanta-Design/RRJClient
4
0
Fork 0
mirror of https://gitea.msk.dinamika-avia.ru/Constanta-Design/RRJClient.git synced 2026-03-28 05:25:39 +03:00
Code Issues Packages Projects Releases Wiki Activity

feat: add server blocked behaviour

Browse Source
This commit is contained in:
semenov
2024-09-12 12:16:41 +03:00
parent e9cd136238
commit f2163b97b5
26 changed files with 172 additions and 114 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
Core/tcpclient.cpp
View File

@@ -89,11 +89,11 @@ void TCPClient::sendFile()
countSend = 0;
}
void TCPClient::sendUnityConnect()
void TCPClient::sendQTConnect()
{
QDataStream stream(socket);
stream.setVersion(QDataStream::Qt_DefaultCompiledVersion);
stream << PacketType::TYPE_CHANGEPACKAGERESPONSE;
QString value = QString::number(PacketType::TYPE_QT);
socket->write(value.toUtf8());
socket->waitForBytesWritten();
}
@@ -106,15 +106,15 @@ void TCPClient::setDisconnect()
void TCPClient::sendDisable()
{
// QDataStream stream(socket);
// stream.setVersion(QDataStream::Qt_DefaultCompiledVersion);
QDataStream stream(socket);
stream.setVersion(QDataStream::Qt_DefaultCompiledVersion);
// QByteArray data;
// data = emit sigGetXmlAnswer("END");
QByteArray data;
data = emit sigGetXmlAnswer("DISABLE");
// stream << PacketType::TYPE_XMLANSWER;
// stream << data;
// socket->waitForBytesWritten();
stream << PacketType::TYPE_XMLANSWER;
stream << data;
socket->waitForBytesWritten();
}
void TCPClient::waitRead(int time)
@@ -162,14 +162,18 @@ void TCPClient::slotMessageEntered(QString message)
void TCPClient::slotConnectNotify()
{
if(socket->state() != QTcpSocket::ConnectedState){
emit sigSendDebugLog("Connect invalid");
emit sigConnectionState(false);
return;
}else{
emit sigSendDebugLog("Connect complete");
emit sigConnectionState(true);
}
if(socket->state() != QTcpSocket::ConnectedState)
{
emit sigSendDebugLog("Connect invalid");
emit sigConnectionState(false);
return;
}
else
{
emit sigSendDebugLog("Connect complete");
emit sigConnectionState(true);
sendQTConnect();
}
}
void TCPClient::slotReadyRead()
@@ -178,9 +182,10 @@ void TCPClient::slotReadyRead()
emit sigSendDebugLog("WRONG SOCKET");
return;
}
// qDebug() << "Transaction before recognize: " << socket->isTransactionStarted();
// if(socket->isTransactionStarted()) return;
// qDebug() << "Transaction before recognize: " << socket->isTransactionStarted();
// if(socket->isTransactionStarted()) return;
emit sigRecognize(socket);
}