From 7aeac3c52569c8c7aa37930550aef2744c6f91ec Mon Sep 17 00:00:00 2001 From: Toad King Date: Thu, 22 May 2014 06:31:08 -0400 Subject: [PATCH] move sleep in UDP handlers to threads --- gamespy_natneg_server.py | 2 +- gamespy_qr_server.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/gamespy_natneg_server.py b/gamespy_natneg_server.py index 2351e66..2a894d6 100644 --- a/gamespy_natneg_server.py +++ b/gamespy_natneg_server.py @@ -52,7 +52,6 @@ class GameSpyNatNegServer(object): while 1: recv_data, addr = s.recvfrom(2048) - time.sleep(0.05) packet_thread = threading.Thread(target=self.handle_packet, args=(s, recv_data, addr)) packet_thread.start() @@ -60,6 +59,7 @@ class GameSpyNatNegServer(object): def handle_packet(self, s, recv_data, addr): logger.log(logging.DEBUG, "Connection from %s:%d..." % (addr[0], addr[1])) logger.log(logging.DEBUG, utils.pretty_print_hex(recv_data)) + time.sleep(0.05) # Make sure it's a legal packet if recv_data[0:6] != bytearray([0xfd, 0xfc, 0x1e, 0x66, 0x6a, 0xb2]): diff --git a/gamespy_qr_server.py b/gamespy_qr_server.py index ed898c6..81237c4 100644 --- a/gamespy_qr_server.py +++ b/gamespy_qr_server.py @@ -81,13 +81,13 @@ class GameSpyQRServer(object): while 1: recv_data, address = self.socket.recvfrom(2048) - time.sleep(0.05) packet_thread = threading.Thread(target=self.handle_packet, args=(self.socket, recv_data, address)) packet_thread.start() def handle_packet(self, socket, recv_data, address): db = gs_database.GamespyDatabase() + time.sleep(0.05) # Tetris DS overlay 10 @ 02144184 - Handle responses back to server # Tetris DS overlay 10 @ 02144184 - Handle responses back to server