mirrors/OpenRCT2
1
0
Fork 0
mirror of https://github.com/OpenRCT2/OpenRCT2 synced 2026-01-15 11:03:00 +01:00
Code Issues Releases Wiki Activity

Limit the count of packets processed per update

Browse Source
This commit is contained in:
ZehMatt
2021-07-29 02:26:02 +03:00
parent 6877b8214a
commit 4f54aa5c42
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/openrct2/network/NetworkBase.cpp
View File

@@ -49,6 +49,9 @@ static int32_t _pickup_peep_old_x = LOCATION_NULL;
// with uint16_t and needs some spare room for other data in the packet.
static constexpr uint32_t CHUNK_SIZE = 1024 * 63;
// If data is sent fast enough it would halt the entire server, process only a maximum amount.
static constexpr uint32_t MaxPacketsPerUpdate = 100;
# include "../Cheats.h"
# include "../ParkImporter.h"
# include "../Version.h"
@@ -1654,8 +1657,11 @@ void NetworkBase::Server_Send_EVENT_PLAYER_DISCONNECTED(const char* playerName,
bool NetworkBase::ProcessConnection(NetworkConnection& connection)
{
NetworkReadPacket packetStatus;
uint32_t countProcessed = 0;
do
{
countProcessed++;
packetStatus = connection.ReadPacket();
switch (packetStatus)
{
@@ -1681,7 +1687,7 @@ bool NetworkBase::ProcessConnection(NetworkConnection& connection)
// could not read anything from socket
break;
}
} while (packetStatus == NetworkReadPacket::Success);
} while (packetStatus == NetworkReadPacket::Success && countProcessed < MaxPacketsPerUpdate);
if (!connection.ReceivedPacketRecently())
{