radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-02-27 14:13:55 +01:00
Code Issues Activity

logger

Browse Source
This commit is contained in:
KubaPro010
2025-12-13 21:22:24 +01:00
parent 7525fcd02f
commit 1610dcf1d6
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
modules/web.py
View File

@@ -7,7 +7,12 @@ import asyncio
import websockets import websockets
from websockets import ServerConnection, Request, Response, Headers from websockets import ServerConnection, Request, Response, Headers
from . import Track, PlayerModule, Path from . import Track, PlayerModule, Path, log95
from typing import TextIO
_log_out: TextIO
assert _log_out # pyright: ignore[reportUnboundVariable]
MAIN_PATH_DIR = Path("/home/user/mixes") MAIN_PATH_DIR = Path("/home/user/mixes")
@@ -162,6 +167,8 @@ def websocket_server_process(shared_data: dict, imc_q: multiprocessing.Queue, ws
class Module(PlayerModule): class Module(PlayerModule):
def __init__(self): def __init__(self):
self.logger = log95.log95("WEB", output=_log_out)
self.manager = multiprocessing.Manager() self.manager = multiprocessing.Manager()
self.data = self.manager.dict() self.data = self.manager.dict()
self.imc_q = multiprocessing.Queue() self.imc_q = multiprocessing.Queue()
@@ -250,5 +257,6 @@ class Module(PlayerModule):
if self.ws_process.is_alive(): if self.ws_process.is_alive():
self.ws_process.kill() self.ws_process.kill()
self.ws_process.join(timeout=1) self.ws_process.join(timeout=1)
self.logger.info(f"Stopped the ws process ({self.ws_process.is_alive()=} {self.ipc_thread.is_alive()=} {self.ipc_thread_running=})")
module = Module() module = Module()