Constanta-Design/RRJServer
4
0
Fork 0
mirror of https://gitea.msk.dinamika-avia.ru/Constanta-Design/RRJServer.git synced 2026-03-28 19:55:48 +03:00
Code Issues Packages Projects Releases Wiki Activity

Работает сокет стрим

Browse Source
This commit is contained in:
Кривошеин Андрей
2026-02-26 17:59:17 +03:00
parent a0e54c0e18
commit 2c96821f36
1 changed files with 32 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
LibServer/Systems/sendsystem.cpp
View File

@@ -364,8 +364,7 @@ void SendSystem::slot_sendFileBlock_forQtClient(QString path)
void SendSystem::slot_sendFileBlockByteArray(QByteArray array, PacketType packetType)
{
if(client->getClientType() == TypeClientAutorization::TYPE_QT_CLIENT ||
client->getClientType() == TypeClientAutorization::TYPE_GUI)
if(client->getClientType() == TypeClientAutorization::TYPE_GUI)
{
QDataStream stream(socket);
stream.setVersion(QDataStream::Qt_DefaultCompiledVersion);
@@ -388,12 +387,43 @@ void SendSystem::slot_sendFileBlockByteArray(QByteArray array, PacketType packet
{
QByteArray chunk = array.mid(bytesSended, sendFileBlockSize);
stream << chunk;
//bytesSended = socket->write(chunk);
waitWrittenData("sendFileBlockByteArray");
bytesSended += chunk.length();
}
}
else if(client->getClientType() == TypeClientAutorization::TYPE_QT_CLIENT)
{
QDataStream stream(socket);
stream.setVersion(QDataStream::Qt_DefaultCompiledVersion);
qint64 size = array.size();
qint64 bytesSended = 0;
if (size == 0)
{
Logger::instance().log(" WARNING! Zero size ",LogLevel::ERROR);
return;
}
stream << packetType; //Отправляем тип блока
stream << size;
waitWrittenData("sendFileBlockByteArray");
while (bytesSended < size)
{
QByteArray chunk = array.mid(bytesSended, sendFileBlockSize);
//stream << chunk;
bytesSended = socket->write(chunk);
waitWrittenData("sendFileBlockByteArray");
bytesSended += chunk.length();
}
}
else
{
slot_sendPacketType(packetType);