Close logpipe

This commit is contained in:
Nick Mowen 2023-06-19 16:47:32 -06:00
parent f8b2643ca8
commit edd7e14237

View File

@ -50,7 +50,6 @@ def listen_to_audio(
audio_threads: list[threading.Thread] = [] audio_threads: list[threading.Thread] = []
def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None: def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None:
logger.error(f"Received end signal")
stop_event.set() stop_event.set()
signal.signal(signal.SIGTERM, receiveSignal) signal.signal(signal.SIGTERM, receiveSignal)
@ -244,6 +243,6 @@ class AudioEventMaintainer(threading.Thread):
while not self.stop_event.is_set(): while not self.stop_event.is_set():
self.read_audio() self.read_audio()
stop_ffmpeg(self.audio_listener, logger)
self.pipe_file.close() self.pipe_file.close()
logger.error(f"Exiting audio runner") stop_ffmpeg(self.audio_listener, logger)
self.logpipe.close()