SantaSpeen/KuiToi-Server
1
0
Fork 0
mirror of https://github.com/kuitoi/kuitoi-Server.git synced 2025-08-17 16:25:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove some debug data!

Browse Source
This commit is contained in:
Maxim Khomutov 2023-07-20 01:34:39 +03:00
parent 310c47162c
commit 78d323644d
1 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/core/udp_server.py
View File

@ -9,6 +9,7 @@ import asyncio
from core import utils from core import utils
# noinspection PyProtectedMember
class UDPServer(asyncio.DatagramTransport): class UDPServer(asyncio.DatagramTransport):
transport = None transport = None
@ -20,11 +21,8 @@ class UDPServer(asyncio.DatagramTransport):
self.host = host self.host = host
self.port = port self.port = port
self.run = False self.run = False
# self.transport = transport
def connection_made(self, transport): def connection_made(self, transport): ...
self.log.debug("set connection transport")
# self.transport = self.transport()
async def handle_datagram(self, data, addr): async def handle_datagram(self, data, addr):
try: try:
@ -33,15 +31,14 @@ class UDPServer(asyncio.DatagramTransport):
client = self.Core.get_client(cid=cid) client = self.Core.get_client(cid=cid)
if client: if client:
if client._udp_sock != (self.transport, addr):
client._udp_sock = (self.transport, addr)
self.log.debug(f"Set UDP Sock for CID: {cid}")
match code: match code:
case "p": case "p": # Ping packet
self.log.debug(f"[{cid}] Send ping")
# TODO: Call event onSentPing # TODO: Call event onSentPing
self.transport.sendto(b"p", addr) # Send ping self.transport.sendto(b"p", addr)
case "Z": case "Z": # Position packet
if client._udp_sock != (self.transport, addr):
client._udp_sock = (self.transport, addr)
self.log.debug(f"Set UDP Sock for CID: {cid}")
# TODO: Call event onChangePosition # TODO: Call event onChangePosition
if client: if client:
await client._send(data[2:], to_all=True, to_self=False, to_udp=True) await client._send(data[2:], to_all=True, to_self=False, to_udp=True)
@ -86,7 +83,6 @@ class UDPServer(asyncio.DatagramTransport):
self.run = True self.run = True
while not self.transport.is_closing(): while not self.transport.is_closing():
await asyncio.sleep(0.2) await asyncio.sleep(0.2)
self.log.info("UDP сервер сдох 1")
except OSError as e: except OSError as e:
self.log.error("Cannot bind port or other error") self.log.error("Cannot bind port or other error")
self.log.exception(e) self.log.exception(e)