mirror of
https://github.com/barronwaffles/dwc_network_server_emulator.git
synced 2026-10-02 06:46:48 -05:00
move sleep in UDP handlers to threads
This commit is contained in:
@@ -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]):
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user