administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-07 11:45:24 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Handle websocket exception

Browse Source
This commit is contained in:
Nick Mowen 2023-11-07 15:18:24 -07:00
parent e0ea94572f
commit 9a787bbd3b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
frigate/output.py
View File

@ -20,8 +20,8 @@ from ws4py.server.wsgirefserver import (
WSGIServer, WSGIServer,
) )
from ws4py.server.wsgiutils import WebSocketWSGIApplication from ws4py.server.wsgiutils import WebSocketWSGIApplication
from ws4py.websocket import WebSocket
from frigate.comms.ws import WebSocket
from frigate.config import BirdseyeModeEnum, FrigateConfig from frigate.config import BirdseyeModeEnum, FrigateConfig
from frigate.const import BASE_DIR, BIRDSEYE_PIPE from frigate.const import BASE_DIR, BIRDSEYE_PIPE
from frigate.types import CameraMetricsTypes from frigate.types import CameraMetricsTypes
@ -175,7 +175,7 @@ class FFMpegConverter(threading.Thread):
os.close(stdin) os.close(stdin)
self.reading_birdseye = False self.reading_birdseye = False
def _write(self, b) -> None: def __write(self, b) -> None:
self.process.stdin.write(b) self.process.stdin.write(b)
if self.bd_pipe: if self.bd_pipe:
@ -215,7 +215,7 @@ class FFMpegConverter(threading.Thread):
while not self.stop_event.is_set(): while not self.stop_event.is_set():
try: try:
frame = self.input_queue.get(True, timeout=1) frame = self.input_queue.get(True, timeout=1)
self._write(frame) self.__write(frame)
except queue.Empty: except queue.Empty:
pass pass