mirror of
https://github.com/blakeblackshear/frigate.git
synced 2026-02-05 10:45:21 +03:00
Cleanup process close
This commit is contained in:
parent
b087d55580
commit
f553cb053a
@ -53,8 +53,15 @@ def listen_to_audio(
|
|||||||
stop_event = mp.Event()
|
stop_event = mp.Event()
|
||||||
audio_threads: list[threading.Thread] = []
|
audio_threads: list[threading.Thread] = []
|
||||||
|
|
||||||
|
def exit_process() -> None:
|
||||||
|
for thread in audio_threads:
|
||||||
|
thread.join()
|
||||||
|
|
||||||
|
logger.info("Exiting audio detector...")
|
||||||
|
|
||||||
def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None:
|
def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None:
|
||||||
stop_event.set()
|
stop_event.set()
|
||||||
|
exit_process()
|
||||||
|
|
||||||
signal.signal(signal.SIGTERM, receiveSignal)
|
signal.signal(signal.SIGTERM, receiveSignal)
|
||||||
signal.signal(signal.SIGINT, receiveSignal)
|
signal.signal(signal.SIGINT, receiveSignal)
|
||||||
@ -69,14 +76,6 @@ def listen_to_audio(
|
|||||||
audio_threads.append(audio)
|
audio_threads.append(audio)
|
||||||
audio.start()
|
audio.start()
|
||||||
|
|
||||||
while not stop_event.is_set():
|
|
||||||
pass
|
|
||||||
|
|
||||||
for thread in audio_threads:
|
|
||||||
thread.join()
|
|
||||||
|
|
||||||
logger.info("Exiting audio detector...")
|
|
||||||
|
|
||||||
|
|
||||||
class AudioTfl:
|
class AudioTfl:
|
||||||
def __init__(self, stop_event: mp.Event):
|
def __init__(self, stop_event: mp.Event):
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user