From a406956080074f657f4b02b929dcdf9830e9a9a2 Mon Sep 17 00:00:00 2001 From: SantaSpeen Date: Sat, 27 Jul 2024 12:12:41 +0300 Subject: [PATCH] [~] Minor --- src/core/udp_server.py | 12 +++++------- src/core/udp_server.pyi | 1 + 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/src/core/udp_server.py b/src/core/udp_server.py index 6d2b12c..d335249 100644 --- a/src/core/udp_server.py +++ b/src/core/udp_server.py @@ -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}") diff --git a/src/core/udp_server.pyi b/src/core/udp_server.pyi index f9cb6ef..9757923 100644 --- a/src/core/udp_server.pyi +++ b/src/core/udp_server.pyi @@ -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: ... \ No newline at end of file