Make manage_recordings into a process subclass

frigate/app.py

@@ -59,7 +59,7 @@ from frigate.ptz.autotrack import PtzAutoTrackerThread
 from frigate.ptz.onvif import OnvifController
 from frigate.record.cleanup import RecordingCleanup
 from frigate.record.export import migrate_exports
-from frigate.record.record import manage_recordings
+from frigate.record.record import ManageRecordings
 from frigate.review.review import manage_review_segments
 from frigate.stats.emitter import StatsEmitter
 from frigate.stats.util import stats_init
@@ -175,12 +175,7 @@ class FrigateApp:
                 self.processes["go2rtc"] = proc.info["pid"]
 
     def init_recording_manager(self) -> None:
-        recording_process = util.Process(
+        recording_process = ManageRecordings(self.config)
-            target=manage_recordings,
-            name="recording_manager",
-            args=(self.config,),
-            daemon=True,
-        )
         self.recording_process = recording_process
         recording_process.start()
         self.processes["recording"] = recording_process.pid or 0

frigate/record/record.py

@@ -1,50 +1,37 @@
 """Run recording maintainer and cleanup."""
 
 import logging
-import multiprocessing as mp
-import signal
-import threading
-from types import FrameType
-from typing import Optional
 
 from playhouse.sqliteq import SqliteQueueDatabase
-from setproctitle import setproctitle
 
+from frigate import util
 from frigate.config import FrigateConfig
 from frigate.models import Recordings, ReviewSegment
 from frigate.record.maintainer import RecordingMaintainer
-from frigate.util.services import listen
 
 logger = logging.getLogger(__name__)
 
 
-def manage_recordings(config: FrigateConfig) -> None:
+class ManageRecordings(util.Process):
-    stop_event = mp.Event()
+    def __init__(self, config: FrigateConfig):
-
+        super().__init__(name="frigate.recording_manager", daemon=True)
-    def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None:
+        self.config = config
-        stop_event.set()
-
-    signal.signal(signal.SIGTERM, receiveSignal)
-    signal.signal(signal.SIGINT, receiveSignal)
-
-    threading.current_thread().name = "process:recording_manager"
-    setproctitle("frigate.recording_manager")
-    listen()
 
+    def run(self):
         db = SqliteQueueDatabase(
-        config.database.path,
+            self.config.database.path,
             pragmas={
                 "auto_vacuum": "FULL",  # Does not defragment database
                 "cache_size": -512 * 1000,  # 512MB of cache
                 "synchronous": "NORMAL",  # Safe when using WAL https://www.sqlite.org/pragma.html#pragma_synchronous
             },
-        timeout=max(60, 10 * len([c for c in config.cameras.values() if c.enabled])),
+            timeout=max(60, sum(10 for c in self.config.cameras.values() if c.enabled)),
         )
         models = [ReviewSegment, Recordings]
         db.bind(models)
 
         maintainer = RecordingMaintainer(
-        config,
+            self.config,
-        stop_event,
+            self.stop_event,
         )
         maintainer.start()