mirror of
https://github.com/blakeblackshear/frigate.git
synced 2024-11-21 19:07:46 +01:00
cafe0917c7
* __main__.py * app.py * models.py * plus.py * stats.py In addition a new module was introduced: types There all TypedDicts are included. Bitte geben Sie eine Commit-Beschreibung für Ihre Änderungen ein. Zeilen,
43 lines
1.4 KiB
Python
43 lines
1.4 KiB
Python
import datetime
|
|
import logging
|
|
import threading
|
|
import time
|
|
import os
|
|
import signal
|
|
|
|
from frigate.edgetpu import EdgeTPUProcess
|
|
from frigate.util import restart_frigate
|
|
from multiprocessing.synchronize import Event
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class FrigateWatchdog(threading.Thread):
|
|
def __init__(self, detectors: dict[str, EdgeTPUProcess], stop_event: Event):
|
|
threading.Thread.__init__(self)
|
|
self.name = "frigate_watchdog"
|
|
self.detectors = detectors
|
|
self.stop_event = stop_event
|
|
|
|
def run(self) -> None:
|
|
time.sleep(10)
|
|
while not self.stop_event.wait(10):
|
|
now = datetime.datetime.now().timestamp()
|
|
|
|
# check the detection processes
|
|
for detector in self.detectors.values():
|
|
detection_start = detector.detection_start.value
|
|
if detection_start > 0.0 and now - detection_start > 10:
|
|
logger.info(
|
|
"Detection appears to be stuck. Restarting detection process..."
|
|
)
|
|
detector.start_or_restart()
|
|
elif (
|
|
detector.detect_process is not None
|
|
and not detector.detect_process.is_alive()
|
|
):
|
|
logger.info("Detection appears to have stopped. Exiting frigate...")
|
|
restart_frigate()
|
|
|
|
logger.info(f"Exiting watchdog...")
|