Mirrors/blakeblackshear.frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2025-10-27 10:52:11 +01:00
Code Issues Projects Releases Wiki Activity

Improve restart timing (#10709)

Browse Source
This commit is contained in:
Nicolas Mowen 2024-03-27 09:03:13 -06:00 committed by GitHub
parent d5989c91a8
commit 559e6910c4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
frigate/app.py
View File

@ -666,6 +666,11 @@ class FrigateApp:
logger.info("Stopping...") logger.info("Stopping...")
self.stop_event.set() self.stop_event.set()
# Stop Communicators
self.inter_process_communicator.stop()
self.inter_config_updater.stop()
self.inter_detection_proxy.stop()
for detector in self.detectors.values(): for detector in self.detectors.values():
detector.stop() detector.stop()
@ -702,8 +707,3 @@ class FrigateApp:
queue.get_nowait() queue.get_nowait()
queue.close() queue.close()
queue.join_thread() queue.join_thread()
# Stop Communicators
self.inter_process_communicator.stop()
self.inter_config_updater.stop()
self.inter_detection_proxy.stop()

2
frigate/output/output.py
View File

@ -79,7 +79,7 @@ def output_frames(
websocket_thread.start() websocket_thread.start()
while not stop_event.is_set(): while not stop_event.is_set():
(topic, data) = detection_subscriber.get_data(timeout=10) (topic, data) = detection_subscriber.get_data(timeout=1)
if not topic: if not topic:
continue continue