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

Use eager tasks in ssdp (#111696)

Browse Source 
There are a few places where we are likely to never suspend here
This commit is contained in:
J. Nick Koston 2024-02-28 05:56:07 -10:00 committed by GitHub
parent d164039bba
commit f95e5c1196
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
homeassistant/components/ssdp/__init__.py
View File

@ -51,6 +51,7 @@ from homeassistant.helpers.network import NoURLAvailableError, get_url
from homeassistant.helpers.system_info import async_get_system_info from homeassistant.helpers.system_info import async_get_system_info
from homeassistant.helpers.typing import ConfigType from homeassistant.helpers.typing import ConfigType
from homeassistant.loader import async_get_ssdp, bind_hass from homeassistant.loader import async_get_ssdp, bind_hass
from homeassistant.util.async_ import create_eager_task
DOMAIN = "ssdp" DOMAIN = "ssdp"
SSDP_SCANNER = "scanner" SSDP_SCANNER = "scanner"
@ -335,7 +336,10 @@ class Scanner:
async def _async_stop_ssdp_listeners(self) -> None: async def _async_stop_ssdp_listeners(self) -> None:
"""Stop the SSDP listeners.""" """Stop the SSDP listeners."""
await asyncio.gather( await asyncio.gather(
*(listener.async_stop() for listener in self._ssdp_listeners), *(
create_eager_task(listener.async_stop())
for listener in self._ssdp_listeners
),
return_exceptions=True, return_exceptions=True,
) )
@ -399,7 +403,10 @@ class Scanner:
) )
) )
results = await asyncio.gather( results = await asyncio.gather(
*(listener.async_start() for listener in self._ssdp_listeners), *(
create_eager_task(listener.async_start())
for listener in self._ssdp_listeners
),
return_exceptions=True, return_exceptions=True,
) )
failed_listeners = [] failed_listeners = []
@ -446,7 +453,8 @@ class Scanner:
self.hass.async_create_task( self.hass.async_create_task(
self._ssdp_listener_process_callback_with_lookup( self._ssdp_listener_process_callback_with_lookup(
ssdp_device, dst, source ssdp_device, dst, source
) ),
eager_start=True,
) )
return return
@ -501,7 +509,8 @@ class Scanner:
if callbacks: if callbacks:
ssdp_change = SSDP_SOURCE_SSDP_CHANGE_MAPPING[source] ssdp_change = SSDP_SOURCE_SSDP_CHANGE_MAPPING[source]
self.hass.async_create_task( self.hass.async_create_task(
_async_process_callbacks(callbacks, discovery_info, ssdp_change) _async_process_callbacks(callbacks, discovery_info, ssdp_change),
eager_start=True,
) )
# Config flows should only be created for alive/update messages from alive devices # Config flows should only be created for alive/update messages from alive devices