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

don't mark devices unavailable without ping try (#25710)

Browse Source
This commit is contained in:
David F. Mulcahey 2019-08-05 09:50:48 -04:00 committed by GitHub
parent ac5fcff1cd
commit 20b54c22f7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
homeassistant/components/zha/core/device.py
View File

@ -39,6 +39,7 @@ from .const import (
ATTR_QUIRK_CLASS, ATTR_QUIRK_CLASS,
ATTR_RSSI, ATTR_RSSI,
ATTR_VALUE, ATTR_VALUE,
CHANNEL_BASIC,
CHANNEL_POWER_CONFIGURATION, CHANNEL_POWER_CONFIGURATION,
CHANNEL_ZDO, CHANNEL_ZDO,
CLUSTER_COMMAND_SERVER, CLUSTER_COMMAND_SERVER,
@ -57,6 +58,7 @@ from .helpers import LogMixin
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
_KEEP_ALIVE_INTERVAL = 7200 _KEEP_ALIVE_INTERVAL = 7200
_UPDATE_ALIVE_INTERVAL = timedelta(seconds=60) _UPDATE_ALIVE_INTERVAL = timedelta(seconds=60)
_CHECKIN_GRACE_PERIODS = 2
class DeviceStatus(Enum): class DeviceStatus(Enum):
@ -81,6 +83,7 @@ class ZHADevice(LogMixin):
self._available_signal = "{}_{}_{}".format( self._available_signal = "{}_{}_{}".format(
self.name, self.ieee, SIGNAL_AVAILABLE self.name, self.ieee, SIGNAL_AVAILABLE
) )
self._checkins_missed_count = 2
self._unsub = async_dispatcher_connect( self._unsub = async_dispatcher_connect(
self.hass, self._available_signal, self.async_initialize self.hass, self._available_signal, self.async_initialize
) )
@ -204,9 +207,26 @@ class ZHADevice(LogMixin):
else: else:
difference = time.time() - self.last_seen difference = time.time() - self.last_seen
if difference > _KEEP_ALIVE_INTERVAL: if difference > _KEEP_ALIVE_INTERVAL:
if self._checkins_missed_count < _CHECKIN_GRACE_PERIODS:
self._checkins_missed_count += 1
if (
CHANNEL_BASIC in self.cluster_channels
and self.manufacturer != "LUMI"
):
self.debug(
"Attempting to checkin with device - missed checkins: %s",
self._checkins_missed_count,
)
self.hass.async_create_task(
self.cluster_channels[CHANNEL_BASIC].get_attribute_value(
ATTR_MANUFACTURER, from_cache=False
)
)
else:
self.update_available(False) self.update_available(False)
else: else:
self.update_available(True) self.update_available(True)
self._checkins_missed_count = 0
def update_available(self, available): def update_available(self, available):
"""Set sensor availability.""" """Set sensor availability."""