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

Calculate cache size

Browse Source
This commit is contained in:
Nick Mowen 2023-07-23 12:11:41 -06:00
parent d0413e3ea8
commit 1639026242
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
frigate/record/maintainer.py
View File

@ -7,6 +7,7 @@ import multiprocessing as mp
import os import os
import queue import queue
import random import random
import shutil
import string import string
import subprocess as sp import subprocess as sp
import threading import threading
@ -28,6 +29,17 @@ from frigate.util.services import get_video_properties
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
def calculate_max_segment_count(config: FrigateConfig) -> int:
"""Calculate the maximum allowed segment count for each camera."""
# calculate total space allocated to cache
try:
total_cache = round(shutil.disk_usage(CACHE_DIR).total / pow(2, 20), 1)
except FileNotFoundError:
total_cache = 1074000000 # 1GiB
# assuming a safe
class SegmentInfo: class SegmentInfo:
def __init__( def __init__(
self, motion_box_count: int, active_object_count: int, average_dBFS: int self, motion_box_count: int, active_object_count: int, average_dBFS: int
@ -66,6 +78,7 @@ class RecordingMaintainer(threading.Thread):
self.object_recordings_info: dict[str, list] = defaultdict(list) self.object_recordings_info: dict[str, list] = defaultdict(list)
self.audio_recordings_info: dict[str, list] = defaultdict(list) self.audio_recordings_info: dict[str, list] = defaultdict(list)
self.end_time_cache: dict[str, Tuple[datetime.datetime, float]] = {} self.end_time_cache: dict[str, Tuple[datetime.datetime, float]] = {}
self.max_segment_count = calculate_max_segment_count(config)
async def move_files(self) -> None: async def move_files(self) -> None:
cache_files = sorted( cache_files = sorted(