From 4e2a529b0ea3175c9b98df5c4b5fa99541b5faee Mon Sep 17 00:00:00 2001 From: Sergey Krashevich Date: Sun, 2 Jul 2023 02:55:34 +0300 Subject: [PATCH] Refactor app.py and util.py to use a custom Queue implementation called LQueue instead of the existing Queue --- frigate/app.py | 4 ++-- frigate/util.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/frigate/app.py b/frigate/app.py index a57cd3bb2..254f61bdc 100644 --- a/frigate/app.py +++ b/frigate/app.py @@ -192,12 +192,12 @@ class FrigateApp: # Queues for clip processing self.event_queue: Queue = ff.Queue() self.event_processed_queue: Queue = ff.Queue() - self.video_output_queue: Queue = ff.Queue( + self.video_output_queue: Queue = LQueue( maxsize=len(self.config.cameras.keys()) * 2 ) # Queue for cameras to push tracked objects to - self.detected_frames_queue: Queue = ff.Queue( + self.detected_frames_queue: Queue = LQueue( maxsize=len(self.config.cameras.keys()) * 2 ) diff --git a/frigate/util.py b/frigate/util.py index ef372d5cb..8429b5b33 100755 --- a/frigate/util.py +++ b/frigate/util.py @@ -16,7 +16,7 @@ from collections import Counter from collections.abc import Mapping from multiprocessing import shared_memory from typing import Any, AnyStr, Optional, Tuple -from faster_fifo import Queue as FFQueue, DEFAULT_CIRCULAR_BUFFER_SIZE, DEFAULT_TIMEOUT +from faster_fifo import Queue as FFQueue, DEFAULT_CIRCULAR_BUFFER_SIZE, DEFAULT_TIMEOUT from queue import Full, Empty import time import cv2