mirror of
https://github.com/kuitoi/kuitoi-Server.git
synced 2025-08-18 00:35:36 +00:00
Minor update
This commit is contained in:
parent
98ef332193
commit
98f86b2248
@ -143,7 +143,6 @@ class Client:
|
|||||||
header2 = recv2[:4]
|
header2 = recv2[:4]
|
||||||
data2 = recv2[4:]
|
data2 = recv2[4:]
|
||||||
int_header2 = int.from_bytes(header2, byteorder='little', signed=True)
|
int_header2 = int.from_bytes(header2, byteorder='little', signed=True)
|
||||||
self.log.debug(f"header2: {header2}; int_header2: {int_header2}; data2: {data2}")
|
|
||||||
t = asyncio.create_task(self.__handle_packet(data2, int_header2))
|
t = asyncio.create_task(self.__handle_packet(data2, int_header2))
|
||||||
self.__tasks.append(t)
|
self.__tasks.append(t)
|
||||||
data = data[:4 + int_header]
|
data = data[:4 + int_header]
|
||||||
@ -451,8 +450,8 @@ class Client:
|
|||||||
while self.__alive:
|
while self.__alive:
|
||||||
if len(self.__packets_queue) > 0:
|
if len(self.__packets_queue) > 0:
|
||||||
for index, packet in enumerate(self.__packets_queue):
|
for index, packet in enumerate(self.__packets_queue):
|
||||||
del self.__packets_queue[index]
|
|
||||||
self.log.debug(f"Packet: {packet}")
|
self.log.debug(f"Packet: {packet}")
|
||||||
|
del self.__packets_queue[index]
|
||||||
task = self._loop.create_task(self._handle_codes(packet))
|
task = self._loop.create_task(self._handle_codes(packet))
|
||||||
tasks.append(task)
|
tasks.append(task)
|
||||||
else:
|
else:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user