administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-05 18:55:23 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Only use enabled cameras

Browse Source
This commit is contained in:
Nick Mowen 2023-07-10 19:39:30 -06:00
parent c4f0b6c9f5
commit d7d65be8d2
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
frigate/app.py
View File

@ -200,28 +200,28 @@ class FrigateApp:
def init_queues(self) -> None: def init_queues(self) -> None:
# Queues for clip processing # Queues for clip processing
self.event_queue: Queue = ff.Queue( self.event_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys()) DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
) )
self.event_processed_queue: Queue = ff.Queue( self.event_processed_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys()) DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
) )
self.video_output_queue: Queue = mp.Queue( self.video_output_queue: Queue = mp.Queue(
maxsize=len(self.config.cameras.keys()) * 2 maxsize=sum(camera.enabled for camera in self.config.cameras.values()) * 2
) )
# Queue for cameras to push tracked objects to # Queue for cameras to push tracked objects to
self.detected_frames_queue: Queue = mp.Queue( self.detected_frames_queue: Queue = mp.Queue(
maxsize=len(self.config.cameras.keys()) * 2 maxsize=sum(camera.enabled for camera in self.config.cameras.values()) * 2
) )
# Queue for recordings info # Queue for recordings info
self.recordings_info_queue: Queue = ff.Queue( self.recordings_info_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys()) DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
) )
# Queue for timeline events # Queue for timeline events
self.timeline_queue: Queue = ff.Queue( self.timeline_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys()) DEFAULT_QUEUE_BUFFER_SIZE * sum(camera.enabled for camera in self.config.cameras.values())
) )
def init_database(self) -> None: def init_database(self) -> None: