From 715d29a1ecf50c7ee57cf3b642e64894298aad30 Mon Sep 17 00:00:00 2001 From: krivoshein Date: Fri, 27 Feb 2026 10:52:13 +0300 Subject: [PATCH] =?UTF-8?q?=D1=83=D0=B1=D1=80=D0=B0=D0=BB=20=D0=BC=D1=83?= =?UTF-8?q?=D1=81=D0=BE=D1=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Core/recognizesystem.cpp | 48 ++++++++++++---------------------------- 1 file changed, 14 insertions(+), 34 deletions(-) diff --git a/Core/recognizesystem.cpp b/Core/recognizesystem.cpp index 72e7095..33901ce 100644 --- a/Core/recognizesystem.cpp +++ b/Core/recognizesystem.cpp @@ -34,46 +34,29 @@ void RecognizeSystem::recognize(QTcpSocket *socket) int cntBytesAvl = 0; while((cntBytesAvl = socket->bytesAvailable()) > 0) { - - /* - if(cntBytesAvl < 4) - { - //if(!socket->waitForReadyRead(TCP_READ_TIMEOUT)) - //return; - socket->waitForReadyRead(TCP_READ_TIMEOUT); - continue; - } - */ - if (socket->state() != QTcpSocket::ConnectedState) { qDebug() << "RecognizeSystem::recognize socket->state() != QTcpSocket::ConnectedState"; return; } - /* - if(!socket->waitForReadyRead(TCP_READ_TIMEOUT)) - { - continue; - } - */ if(packetType == PacketType::TYPE_NONE) //определение первичного пакета - { - stream.startTransaction(); - stream >> packetType; + { + stream.startTransaction(); + stream >> packetType; - if(!stream.commitTransaction()) - { - socket->waitForReadyRead(TCP_READ_TIMEOUT); - continue; - } - //qDebug() << Tools::GetTime() << "CLIENT: type: " << packetType; - if(packetType == PacketType::TYPE_FILE) - socket->waitForReadyRead(10); - else - socket->waitForReadyRead(100); + if(!stream.commitTransaction()) + { + socket->waitForReadyRead(TCP_READ_TIMEOUT); + continue; } - //continue; + //qDebug() << Tools::GetTime() << "CLIENT: type: " << packetType; + if(packetType == PacketType::TYPE_FILE) + socket->waitForReadyRead(10); + else + socket->waitForReadyRead(100); + } + switch ((int)packetType) { @@ -164,9 +147,6 @@ void RecognizeSystem::recognize(QTcpSocket *socket) continue; } - //if(!socket->waitForReadyRead(TCP_READ_TIMEOUT)) - //continue; - if(fileSize - sizeReceiveData >= BLOCK_SIZE) tmpBlock = socket->read(BLOCK_SIZE); else