radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-02-26 21:53:54 +01:00
Code Issues Activity

idk

Browse Source
This commit is contained in:
KubaPro010
2025-12-13 19:35:16 +01:00
parent 3a46e48446
commit 4ef85281ce
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
modules/web.py
View File

@@ -107,11 +107,6 @@ def websocket_server_process(shared_data: dict, imc_q: multiprocessing.Queue, ws
# create the asyncio loop and run server # create the asyncio loop and run server
async def runner(): async def runner():
clients = set() clients = set()
stop_evt = asyncio.Event()
async def shutdown_watcher():
await loop.run_in_executor(None, shutdown_evt.wait)
stop_evt.set()
async def handler_wrapper(websocket: ServerConnection): async def handler_wrapper(websocket: ServerConnection):
# register client # register client
@@ -139,9 +134,9 @@ def websocket_server_process(shared_data: dict, imc_q: multiprocessing.Queue, ws
# start server # start server
server = await websockets.serve(handler_wrapper, "0.0.0.0", 3001, server_header="RadioPlayer ws plugin", process_request=process_request) server = await websockets.serve(handler_wrapper, "0.0.0.0", 3001, server_header="RadioPlayer ws plugin", process_request=process_request)
broadcaster = asyncio.create_task(broadcast_worker(ws_q, clients)) broadcaster = asyncio.create_task(broadcast_worker(ws_q, clients))
watcher = asyncio.create_task(shutdown_watcher())
await stop_evt.wait() shutdown_evt.wait()
server.close()
ws_q.put(None) ws_q.put(None)
broadcaster.cancel() broadcaster.cancel()
@@ -150,8 +145,6 @@ def websocket_server_process(shared_data: dict, imc_q: multiprocessing.Queue, ws
await server.wait_closed() await server.wait_closed()
await broadcaster await broadcaster
watcher.cancel()
await watcher
loop = asyncio.new_event_loop() loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop) asyncio.set_event_loop(loop)