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 /worker.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 'worker.py')
| -rw-r--r-- | worker.py | 9 |
1 files changed, 1 insertions, 8 deletions
@@ -122,7 +122,6 @@ class MonitorTask(Thread): Parameters ---------- - None Returns ------- @@ -161,7 +160,6 @@ class MonitorTask(Thread): Parameters ---------- - None Returns ------- @@ -340,7 +338,6 @@ class ServerWorker(Thread): # except Exception as exc: # logger.error("Sending camera metadata update to websocket failed: %r", exc) - return False def handle_video_message(self, msg: list) -> None: logger.debug("Received video message with data only.") @@ -352,7 +349,7 @@ class ServerWorker(Thread): self.video_threads[client_id][camera_id].queue.put(content[0]) # Send only [client_id, camera_id, jpeg_bytes] to the webserver: - # zmq subsciber can subscribe to a topic defined by the first + # zmq subscriber can subscribe to a topic defined by the first # part of the multipart message, so in order to allow for a # per camera subscription, we need to join client_id and camera_id topic = b':'.join([client_id, camera_id]) @@ -368,7 +365,6 @@ class ServerWorker(Thread): Parameters ---------- - None Returns ------- @@ -459,7 +455,6 @@ class ServerWorker(Thread): Parameters ---------- - None Returns ------- @@ -524,7 +519,6 @@ class VideoWorker(Thread): Parameters ---------- - None Returns ------- @@ -539,7 +533,6 @@ class VideoWorker(Thread): Parameters ---------- - None Returns ------- |