SantaSpeen/KuiToi-Server
1
0
Fork 0
mirror of https://github.com/kuitoi/kuitoi-Server.git synced 2026-02-16 02:20:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

[~] Minor

Browse Source
This commit is contained in:
Maxim Khomutov
2024-07-27 12:12:41 +03:00
parent 027c239424
commit a406956080
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/core/udp_server.py
View File

@@ -1,7 +1,7 @@
# Developed by KuiToi Dev
# File core.udp_server.py
# File core.udp_server
# Written by: SantaSpeen
# Core version: 0.4.5
# Core version: 0.4.7
# Licence: FPA
# (c) kuitoi.su 2024
import asyncio
@@ -9,7 +9,6 @@ import json
from core import utils
# noinspection PyProtectedMember
class UDPServer(asyncio.DatagramTransport):
transport = None
@@ -56,7 +55,7 @@ class UDPServer(asyncio.DatagramTransport):
ev.call_event("onChangePosition", data, player=client, pos=last_pos)
except Exception as e:
self.log.warning(f"Cannot parse position packet: {e}")
self.log.debug(f"data: '{data}', sup: {sub}")
self.log.debug(f"data: '{data}', sub: {sub}")
self.log.debug(f"last_pos ({type(last_pos)}): {last_pos}")
await client._send(data, to_all=True, to_self=False, to_udp=True)
case "X":
@@ -87,7 +86,6 @@ class UDPServer(asyncio.DatagramTransport):
self.log.debug("Starting UDP server.")
while self._core.run:
try:
await asyncio.sleep(0.2)
d = UDPServer
@@ -104,8 +102,8 @@ class UDPServer(asyncio.DatagramTransport):
await asyncio.sleep(0.2)
except OSError as e:
# self.run = False
# self.Core.run = False
self.run = False
self._core.run = False
self.log.error(f"Cannot bind port or other error: {e}")
except Exception as e:
self.log.error(f"Error: {e}")

1
src/core/udp_server.pyi
View File

@@ -26,5 +26,6 @@ class UDPServer(asyncio.DatagramTransport):
def connection_made(self, transport: DatagramTransport): ...
async def handle_datagram(self, data: bytes, addr: Tuple[str, int]):
def datagram_received(self, data: bytes, addr: Tuple[str, int]): ...
async def _print_pps(self) -> None: ...
async def _start(self) -> None: ...
async def _stop(self) -> None: ...