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

Refactor tcp.start()

Browse Source
This commit is contained in:
Maxim Khomutov 2023-07-08 02:19:46 +03:00
parent f71958a0cc
commit b63d3ce963
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/core/tcp_server.py
View File

@ -112,15 +112,12 @@ class TCPServer:
async def start(self): async def start(self):
self.log.debug("Starting TCP server.") self.log.debug("Starting TCP server.")
srv_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server = await asyncio.start_server(self.handle_client, self.host, self.port, backlog=config.Game["players"]+1)
srv_sock.bind((self.host, self.port))
srv_sock.listen(config.Game["players"])
self.log.debug(f"Serving on {srv_sock.getsockname()}")
loop = asyncio.get_event_loop()
try: try:
self.log.debug(f"TCP server started on {server.sockets[0].getsockname()!r}")
while True: while True:
sock, _ = await loop.sock_accept(srv_sock) async with server:
loop.create_task(self.handle_client(sock)) await server.serve_forever()
except Exception as e: except Exception as e:
self.log.error(f"Error: {e}") self.log.error(f"Error: {e}")
traceback.print_exc() traceback.print_exc()