jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-20 03:37:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Catch ConnectionResetError when writing MJPEG in camera (#66245)

Browse Source
This commit is contained in:
uvjustin 2022-02-11 04:25:31 +08:00 committed by GitHub
parent 9fa2bdd3fd
commit c222be0958
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
homeassistant/components/camera/__init__.py
View File

@ -221,7 +221,12 @@ async def async_get_mjpeg_stream(
"""Fetch an mjpeg stream from a camera entity.""" """Fetch an mjpeg stream from a camera entity."""
camera = _get_camera_from_entity_id(hass, entity_id) camera = _get_camera_from_entity_id(hass, entity_id)
return await camera.handle_async_mjpeg_stream(request) try:
stream = await camera.handle_async_mjpeg_stream(request)
except ConnectionResetError:
stream = None
_LOGGER.debug("Error while writing MJPEG stream to transport")
return stream
async def async_get_still_stream( async def async_get_still_stream(
@ -783,7 +788,11 @@ class CameraMjpegStream(CameraView):
async def handle(self, request: web.Request, camera: Camera) -> web.StreamResponse: async def handle(self, request: web.Request, camera: Camera) -> web.StreamResponse:
"""Serve camera stream, possibly with interval.""" """Serve camera stream, possibly with interval."""
if (interval_str := request.query.get("interval")) is None: if (interval_str := request.query.get("interval")) is None:
stream = await camera.handle_async_mjpeg_stream(request) try:
stream = await camera.handle_async_mjpeg_stream(request)
except ConnectionResetError:
stream = None
_LOGGER.debug("Error while writing MJPEG stream to transport")
if stream is None: if stream is None:
raise web.HTTPBadGateway() raise web.HTTPBadGateway()
return stream return stream