fix Socket implementation with new NetworkManager API

This commit is contained in:
Tropical 2026-03-22 04:24:14 -05:00
parent 90bdcd47d4
commit 0a348b7f2f

View file

@ -461,15 +461,24 @@ void Socket::SocketOutputStreamNetwork::writeWithFlags(byteArray b,
return; return;
} }
#ifdef _XBOX
bool lowPriority = ((flags & QNET_SENDDATA_LOW_PRIORITY) ==
QNET_SENDDATA_LOW_PRIORITY);
bool requireAck = lowPriority;
#else
bool lowPriority = false;
bool requireAck = ((flags & NON_QNET_SENDDATA_ACK_REQUIRED) ==
NON_QNET_SENDDATA_ACK_REQUIRED);
#endif
if (m_queueIdx == SOCKET_SERVER_END) { if (m_queueIdx == SOCKET_SERVER_END) {
// printf( "Sent %u bytes of data from \"%ls\" to \"%ls\"\n", // printf( "Sent %u bytes of data from \"%ls\" to \"%ls\"\n",
// buffer.dwDataSize, // buffer.dwDataSize,
// hostPlayer->GetGamertag(), // hostPlayer->GetGamertag(),
// m_socket->networkPlayer->GetGamertag()); // m_socket->networkPlayer->GetGamertag());
hostPlayer->SendData( hostPlayer->SendData(socketPlayer, buffer.pbyData,
socketPlayer, buffer.pbyData, buffer.dwDataSize, buffer.dwDataSize, lowPriority, requireAck);
QNET_SENDDATA_RELIABLE | QNET_SENDDATA_SEQUENTIAL | flags);
// DWORD queueSize = hostPlayer->GetSendQueueSize( NULL, // DWORD queueSize = hostPlayer->GetSendQueueSize( NULL,
// QNET_GETSENDQUEUESIZE_BYTES ); if( queueSize > 24000 ) // QNET_GETSENDQUEUESIZE_BYTES ); if( queueSize > 24000 )
@ -483,9 +492,8 @@ void Socket::SocketOutputStreamNetwork::writeWithFlags(byteArray b,
// m_socket->networkPlayer->GetGamertag(), // m_socket->networkPlayer->GetGamertag(),
// hostPlayer->GetGamertag()); // hostPlayer->GetGamertag());
socketPlayer->SendData( socketPlayer->SendData(hostPlayer, buffer.pbyData,
hostPlayer, buffer.pbyData, buffer.dwDataSize, buffer.dwDataSize, lowPriority, requireAck);
QNET_SENDDATA_RELIABLE | QNET_SENDDATA_SEQUENTIAL | flags);
} }
} }
} }