administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-04 10:15:22 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

dont wait so long for queues

Browse Source
This commit is contained in:
Blake Blackshear 2023-02-03 18:30:11 -06:00
parent 66881eb89f
commit 5176c05e2e
5 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
frigate/events.py
View File

@ -67,7 +67,7 @@ class EventProcessor(threading.Thread):
while not self.stop_event.is_set(): while not self.stop_event.is_set():
try: try:
event_type, camera, event_data = self.event_queue.get(timeout=10) event_type, camera, event_data = self.event_queue.get(timeout=1)
except queue.Empty: except queue.Empty:
continue continue

2
frigate/object_detection.py
View File

@ -104,7 +104,7 @@ def run_detector(
while not stop_event.is_set(): while not stop_event.is_set():
try: try:
connection_id = detection_queue.get(timeout=5) connection_id = detection_queue.get(timeout=1)
except queue.Empty: except queue.Empty:
continue continue
input_frame = frame_manager.get( input_frame = frame_manager.get(

2
frigate/object_processing.py
View File

@ -901,7 +901,7 @@ class TrackedObjectProcessor(threading.Thread):
current_tracked_objects, current_tracked_objects,
motion_boxes, motion_boxes,
regions, regions,
) = self.tracked_objects_queue.get(True, 10) ) = self.tracked_objects_queue.get(True, 1)
except queue.Empty: except queue.Empty:
continue continue

2
frigate/output.py
View File

@ -463,7 +463,7 @@ def output_frames(config: FrigateConfig, video_output_queue):
current_tracked_objects, current_tracked_objects,
motion_boxes, motion_boxes,
regions, regions,
) = video_output_queue.get(True, 10) ) = video_output_queue.get(True, 1)
except queue.Empty: except queue.Empty:
continue continue

2
frigate/video.py
View File

@ -601,7 +601,7 @@ def process_frames(
break break
try: try:
frame_time = frame_queue.get(True, 10) frame_time = frame_queue.get(True, 1)
except queue.Empty: except queue.Empty:
continue continue