Blunkall-Technologies/Archimedes
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

return to while

Browse Source
This commit is contained in:
Nathan
2025-04-17 18:40:18 -05:00
parent 5c32a86674
commit 24ab4a2f49
2 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
modules/ClientModule/src/ClientModule.cpp
View File

@@ -125,19 +125,16 @@ bool ClientModule::onEvent(const Archimedes::Event& event) {
void ClientModule::pollIncomingData() { void ClientModule::pollIncomingData() {
int numMsgs; while(running) {
do {
ISteamNetworkingMessage *pIncomingMsg = nullptr; ISteamNetworkingMessage *pIncomingMsg = nullptr;
numMsgs = interface->ReceiveMessagesOnConnection( connection, &pIncomingMsg, 1 ); int numMsgs = interface->ReceiveMessagesOnConnection( connection, &pIncomingMsg, 1 );
if ( numMsgs == 0 ) if ( numMsgs == 0 )
return; break;
if ( numMsgs < 0 ) if ( numMsgs < 0 )
std::cerr << "Error checking for messages" << std::endl; std::cerr << "Error checking for messages" << std::endl;
assert( numMsgs == 1 && pIncomingMsg ); assert( numMsgs == 1 && pIncomingMsg );
assert( pIncomingMsg->m_conn == connection ); assert( pIncomingMsg->m_conn == connection );
app->emitEvent(new CMEvent::DataRecievedEvent(pIncomingMsg)); app->emitEvent(new CMEvent::DataRecievedEvent(pIncomingMsg));
//numMsgs--; }
return;
} while (numMsgs > 0);
} }

3
modules/ServerModule/src/ServerModule.cpp
View File

@@ -209,7 +209,7 @@ void ServerModule::pollIncomingData() {
ISteamNetworkingMessage *pIncomingMsg = nullptr; ISteamNetworkingMessage *pIncomingMsg = nullptr;
int numMsgs = interface->ReceiveMessagesOnPollGroup( pollGroup, &pIncomingMsg, 1 ); int numMsgs = interface->ReceiveMessagesOnPollGroup( pollGroup, &pIncomingMsg, 1 );
if ( numMsgs == 0 ) if ( numMsgs == 0 )
return; break;
if ( numMsgs < 0 ) if ( numMsgs < 0 )
std::cerr << "Error checking for messages" << std::endl; std::cerr << "Error checking for messages" << std::endl;
assert( numMsgs == 1 && pIncomingMsg ); assert( numMsgs == 1 && pIncomingMsg );
@@ -217,6 +217,5 @@ void ServerModule::pollIncomingData() {
assert( itClient != clients.end() ); assert( itClient != clients.end() );
app->emitEvent(new SMEvent::DataRecievedEvent(pIncomingMsg)); app->emitEvent(new SMEvent::DataRecievedEvent(pIncomingMsg));
return;
} }
} }