diff options
| author | Franoosh <uinarf@autistici.org> | 2026-01-11 14:26:25 +0100 |
|---|---|---|
| committer | Franoosh <uinarf@autistici.org> | 2026-01-11 14:26:25 +0100 |
| commit | a241288241a9dc300014ecfc93c4f537900f3e9f (patch) | |
| tree | 679c1f1f26289966b5593d5260b6c8da96f0d117 /webserver.py | |
| parent | 632fdc7b31dc11ed478f7371676a09a2145eaba4 (diff) | |
| download | ZeroMQ_Video_Streaming-a241288241a9dc300014ecfc93c4f537900f3e9f.tar.gz ZeroMQ_Video_Streaming-a241288241a9dc300014ecfc93c4f537900f3e9f.tar.bz2 ZeroMQ_Video_Streaming-a241288241a9dc300014ecfc93c4f537900f3e9f.zip | |
Cleanup.
Diffstat (limited to 'webserver.py')
| -rw-r--r-- | webserver.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/webserver.py b/webserver.py index 7fa2e3c..3a95dca 100644 --- a/webserver.py +++ b/webserver.py @@ -85,7 +85,6 @@ async def zmq_bridge(): Parameters ---------- - None Returns ------- @@ -242,6 +241,9 @@ async def camera_route(websocket: WebSocket, client_id: str, camera_id: str) -> logger.info("Accepting websocket connection for '/ws/%s/%s'.", client_id, camera_id) await websocket.accept() ws_connections[client_id][camera_id] = {'ws': websocket} + # Ensure queue exists (zmq_bridge may not have created it yet) + if camera_id not in ws_queues[client_id]: + ws_queues[client_id][camera_id] = asyncio.Queue(maxsize=10) queue = ws_queues[client_id][camera_id] async def send_frames(): @@ -555,4 +557,5 @@ if __name__ == "__main__": port=8007, host='127.0.0.1', log_level='info', + # uds="/run/zmq_webserver.sock" ) |