From 6e045a9116d556ac65ac708c8620aaa606a0ef99 Mon Sep 17 00:00:00 2001
From: Quentin Bazin <quent42340@gmail.com>
Date: Mon, 16 Oct 2023 22:16:27 +0200
Subject: [PATCH] [Server] Now able to process more than one packet per tick.

---
 source/server/network/Server.cpp | 49 ++++++++++++++++++--------------
 1 file changed, 27 insertions(+), 22 deletions(-)

diff --git a/source/server/network/Server.cpp b/source/server/network/Server.cpp
index ca3b5604..6a3e39e7 100644
--- a/source/server/network/Server.cpp
+++ b/source/server/network/Server.cpp
@@ -87,7 +87,7 @@ void Server::handleNewConnections() {
 			Network::Packet outPacket;
 			outPacket << Network::Command::ClientOk << client.id << m_isSingleplayer;
 			client.tcpSocket->send(outPacket);
-			// client.tcpSocket->setBlocking(false);
+			client.tcpSocket->setBlocking(false);
 
 			if (m_connectionCallback)
 				m_connectionCallback(client, packet);
@@ -108,31 +108,36 @@ void Server::handleClientMessages() {
 		ClientInfo &client = m_info.clients()[i];
 		if (m_selector.isReady(*client.tcpSocket)) {
 			Network::Packet packet;
-			sf::Socket::Status status = client.tcpSocket->receive(packet);
-			if (status == sf::Socket::Done) {
-				Network::Command command;
-				packet >> command;
-
-				// gkDebug() << "TCP message received:" << Network::commandToString(command);
-
-				if (m_isRunning) {
-					for (auto &it : m_commands) {
-						if (command == it.first)
-							it.second(client, packet);
-
-						if (command == Network::Command::ClientDisconnect) {
-							disconnectClient(client);
-							--i;
-
-							break;
+			sf::Socket::Status status;
+			int packetsProcessed = 0;
+			do {
+				status = client.tcpSocket->receive(packet);
+				if (status == sf::Socket::Done) {
+					Network::Command command;
+					packet >> command;
+
+					// gkDebug() << "TCP message received:" << Network::commandToString(command);
+
+					if (m_isRunning) {
+						for (auto &it : m_commands) {
+							if (command == it.first)
+								it.second(client, packet);
+
+							if (command == Network::Command::ClientDisconnect) {
+								disconnectClient(client);
+								--i;
+
+								break;
+							}
 						}
 					}
 				}
+				else if (status == sf::Socket::Disconnected) {
+					disconnectClient(client);
+					--i;
+				}
 			}
-			else if (status == sf::Socket::Disconnected) {
-				disconnectClient(client);
-				--i;
-			}
+			while ((status == sf::Socket::Done || status == sf::Socket::Disconnected) && packetsProcessed++ < 100);
 		}
 	}
 }