From ed1cd052dbcf794b03d12db7a434ed923027872d Mon Sep 17 00:00:00 2001 From: Nicolas Mowen Date: Wed, 14 Feb 2024 07:31:33 -0700 Subject: [PATCH] Cleanup --- frigate/comms/config_updater.py | 21 +-------------------- 1 file changed, 1 insertion(+), 20 deletions(-) diff --git a/frigate/comms/config_updater.py b/frigate/comms/config_updater.py index 3aaa54ee3..62890fe36 100644 --- a/frigate/comms/config_updater.py +++ b/frigate/comms/config_updater.py @@ -2,7 +2,6 @@ import multiprocessing as mp import os -import threading from multiprocessing.synchronize import Event as MpEvent from typing import Callable, Optional @@ -30,28 +29,10 @@ class ConfigPublisher(Communicator): self.socket.send_pyobj(payload) def subscribe(self, receiver: Callable) -> None: - self._dispatcher = receiver - self.reader_thread = threading.Thread(target=self.read) - self.reader_thread.start() - - def read(self) -> None: - while not self.stop_event.wait(0.5): - while True: # load all messages that are queued - try: - (topic, value) = self.socket.recv_pyobj(flags=zmq.NOBLOCK) - - response = self._dispatcher(topic, value) - - if response is not None: - self.socket.send_pyobj(response) - else: - self.socket.send_pyobj([]) - except zmq.ZMQError: - break + pass # this class does not subscribe def stop(self) -> None: self.stop_event.set() - self.reader_thread.join() self.socket.close() self.context.destroy()