Change name

This commit is contained in:
Nick Mowen 2023-07-07 13:39:44 -06:00
parent ebfe669ac2
commit 3735aee7de
3 changed files with 12 additions and 8 deletions

View File

@ -26,7 +26,7 @@ from frigate.const import (
CLIPS_DIR, CLIPS_DIR,
CONFIG_DIR, CONFIG_DIR,
DEFAULT_DB_PATH, DEFAULT_DB_PATH,
DEFAULT_QUEUE_SIZE, DEFAULT_QUEUE_BUFFER_SIZE,
EXPORT_DIR, EXPORT_DIR,
MODEL_CACHE_DIR, MODEL_CACHE_DIR,
RECORD_DIR, RECORD_DIR,
@ -191,8 +191,8 @@ 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(DEFAULT_QUEUE_SIZE) self.event_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.event_processed_queue: Queue = ff.Queue(DEFAULT_QUEUE_SIZE) self.event_processed_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
self.video_output_queue: Queue = LQueue( self.video_output_queue: Queue = LQueue(
maxsize=len(self.config.cameras.keys()) * 2 maxsize=len(self.config.cameras.keys()) * 2
) )
@ -203,10 +203,10 @@ class FrigateApp:
) )
# Queue for recordings info # Queue for recordings info
self.recordings_info_queue: Queue = ff.Queue(DEFAULT_QUEUE_SIZE) self.recordings_info_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
# Queue for timeline events # Queue for timeline events
self.timeline_queue: Queue = ff.Queue(DEFAULT_QUEUE_SIZE) self.timeline_queue: Queue = ff.Queue(DEFAULT_QUEUE_BUFFER_SIZE)
def init_database(self) -> None: def init_database(self) -> None:
def vacuum_db(db: SqliteExtDatabase) -> None: def vacuum_db(db: SqliteExtDatabase) -> None:

View File

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

View File

@ -20,7 +20,11 @@ import yaml
from faster_fifo import Queue as FFQueue from faster_fifo import Queue as FFQueue
from ruamel.yaml import YAML from ruamel.yaml import YAML
from frigate.const import DEFAULT_QUEUE_SIZE, REGEX_HTTP_CAMERA_USER_PASS, REGEX_RTSP_CAMERA_USER_PASS from frigate.const import (
DEFAULT_QUEUE_BUFFER_SIZE,
REGEX_HTTP_CAMERA_USER_PASS,
REGEX_RTSP_CAMERA_USER_PASS,
)
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -68,7 +72,7 @@ class LimitedQueue(FFQueue):
def __init__( def __init__(
self, self,
maxsize=0, maxsize=0,
max_size_bytes=DEFAULT_QUEUE_SIZE, max_size_bytes=DEFAULT_QUEUE_BUFFER_SIZE,
loads=None, loads=None,
dumps=None, dumps=None,
): ):