actions/itgmania212121
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

BUGFIX: Make sure all data exits sendbuffer before proceeding to blocking wait.

Browse Source
This commit is contained in:
Charles Lohr
2004-08-16 07:40:22 +00:00
parent e431570722
commit 472f2752fa
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
stepmania/src/NetworkSyncManager.cpp
+15 -9
View File
@@ -97,16 +97,18 @@ void NetworkSyncManager::PostStartUp(CString ServerIP)
WriteNT(m_packet, CString(PRODUCT_NAME_VER)); WriteNT(m_packet, CString(PRODUCT_NAME_VER));
NetPlayerClient->SendPack((char*)m_packet.Data,m_packet.Position);
ClearPacket(m_packet);
//Block until responce is received //Block until responce is received
//Move mode to blocking in order to give CPU back to the //Move mode to blocking in order to give CPU back to the
//system, and not wait. //system, and not wait.
bool dontExit = true; bool dontExit = true;
NetPlayerClient->blocking = true; NetPlayerClient->blocking = true;
//Following packet must get through, so we block for it.
NetPlayerClient->SendPack((char*)m_packet.Data,m_packet.Position);
ClearPacket(m_packet);
while (dontExit) while (dontExit)
{ {
ClearPacket(m_packet); ClearPacket(m_packet);
@@ -310,17 +312,21 @@ void NetworkSyncManager::StartRequest(short position)
else else
WriteNT(m_packet,CString("")); WriteNT(m_packet,CString(""));
NetPlayerClient->SendPack((char*)&m_packet.Data, m_packet.Position);
LOG->Trace("Waiting for RECV");
ClearPacket(m_packet);
//Block until go is recieved. //Block until go is recieved.
//Switch to blocking mode (this is the only //Switch to blocking mode (this is the only
//way I know how to get precievably instantanious results //way I know how to get precievably instantanious results
bool dontExit=true; bool dontExit=true;
NetPlayerClient->blocking=true; NetPlayerClient->blocking=true;
//The following packet HAS to get through, so we turn blocking on for it as well
NetPlayerClient->SendPack((char*)&m_packet.Data, m_packet.Position);
LOG->Trace("Waiting for RECV");
ClearPacket(m_packet);
while (dontExit) while (dontExit)
{ {
ClearPacket(m_packet); ClearPacket(m_packet);