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

Refactor queue size

Browse Source
This commit is contained in:
Nick Mowen 2023-07-10 18:10:51 -06:00
parent 7c0d25f9da
commit c4f0b6c9f5
3 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
frigate/app.py
View File

@ -199,8 +199,12 @@ class FrigateApp:
def init_queues(self) -> None:
# Queues for clip processing
self.event_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.event_processed_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.event_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys())
)
self.event_processed_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys())
)
self.video_output_queue: Queue = mp.Queue(
maxsize=len(self.config.cameras.keys()) * 2
)
@ -211,10 +215,14 @@ class FrigateApp:
)
# Queue for recordings info
self.recordings_info_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.recordings_info_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys())
)
# Queue for timeline events
self.timeline_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.timeline_queue: Queue = ff.Queue(
DEFAULT_QUEUE_BUFFER_SIZE * len(self.config.cameras.keys())
)
def init_database(self) -> None:
def vacuum_db(db: SqliteExtDatabase) -> None:

2
frigate/const.py
View File

@ -49,4 +49,4 @@ MAX_PLAYLIST_SECONDS = 7200 # support 2 hour segments for a single playlist to
# Queue Values
DEFAULT_QUEUE_BUFFER_SIZE = 2000 * 1000 # 2MB
DEFAULT_QUEUE_BUFFER_SIZE = 1000 * 1000 # 1MB

2
frigate/http.py
View File

@ -900,7 +900,7 @@ def create_event(camera_name, label):
except Exception as e:
return make_response(
jsonify({"success": False, "message": f"An unknown error occurred: {e}"}),
404,
500,
)
return make_response(