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

Create out SHM

Browse Source
This commit is contained in:
Nicolas Mowen 2025-06-11 08:10:34 -06:00
parent 02144402e5
commit 225010c570
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
frigate/camera/maintainer.py
View File

@ -19,7 +19,7 @@ from frigate.const import SHM_FRAMES_VAR
from frigate.models import Regions from frigate.models import Regions
from frigate.util import Process as FrigateProcess from frigate.util import Process as FrigateProcess
from frigate.util.builtin import empty_and_close_queue from frigate.util.builtin import empty_and_close_queue
from frigate.util.image import SharedMemoryFrameManager from frigate.util.image import SharedMemoryFrameManager, UntrackedSharedMemory
from frigate.util.object import get_camera_regions_grid from frigate.util.object import get_camera_regions_grid
from frigate.video import capture_camera, track_camera from frigate.video import capture_camera, track_camera
@ -54,6 +54,7 @@ class CameraMaintainer(threading.Thread):
CameraConfigUpdateEnum.remove, CameraConfigUpdateEnum.remove,
], ],
) )
self.detector_camera_publisher = DetectorCameraPublisher()
self.shm_count = self.__calculate_shm_frame_count() self.shm_count = self.__calculate_shm_frame_count()
def __init_historical_regions(self) -> None: def __init_historical_regions(self) -> None:
@ -127,7 +128,6 @@ class CameraMaintainer(threading.Thread):
return return
if runtime: if runtime:
# TODO we have to send a ZMQ message to the object detector with the same out event
self.detection_out_events[name] = mp.Event() self.detection_out_events[name] = mp.Event()
self.camera_metrics[name] = CameraMetrics() self.camera_metrics[name] = CameraMetrics()
self.ptz_metrics[name] = PTZMetrics(autotracker_enabled=False) self.ptz_metrics[name] = PTZMetrics(autotracker_enabled=False)
@ -137,6 +137,11 @@ class CameraMaintainer(threading.Thread):
max(self.config.model.width, self.config.model.height), max(self.config.model.width, self.config.model.height),
) )
try:
UntrackedSharedMemory(name=f"out-{name}", create=True, size=20 * 6 * 4)
except FileExistsError:
pass
camera_process = FrigateProcess( camera_process = FrigateProcess(
target=track_camera, target=track_camera,
name=f"camera_processor:{name}", name=f"camera_processor:{name}",
@ -229,5 +234,6 @@ class CameraMaintainer(threading.Thread):
for camera in self.camera_metrics.keys(): for camera in self.camera_metrics.keys():
self.__stop_camera_process(camera) self.__stop_camera_process(camera)
self.detector_camera_publisher.stop()
self.update_subscriber.stop() self.update_subscriber.stop()
self.frame_manager.cleanup() self.frame_manager.cleanup()