eswyft/homekit
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

polaris/protocol: ping improvements

Browse Source
This commit is contained in:
Evgeny Zinoviev 2022-07-02 15:41:06 +03:00
parent 28560dbba9
commit 9b280e3518
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/polaris/protocol.py
View File

@ -1011,13 +1011,15 @@ class UDPConnection(threading.Thread, ConnectionStatusListener):
self._logger.error(f'{lpfx} rm path: removing from outgoing_queue raised an exception: {str(exc)}')
# ping pong
if self.outgoing_time_1st != 0 and self.status == ConnectionStatus.CONNECTED:
if not message and self.outgoing_time_1st != 0 and self.status == ConnectionStatus.CONNECTED:
now = time.time()
out_delta = now - self.outgoing_time
in_delta = now - self.incoming_time
if not message and max(out_delta, in_delta) > PING_FREQUENCY:
if max(out_delta, in_delta) > PING_FREQUENCY:
self._logger.debug(f'{lpfx} no activity: in for {in_delta:.2f}s, out for {out_delta:.2f}s, time to ping the damn thing')
message = WrappedMessage(PingMessage(), ack=True)
# add it to outgoing_queue in order to be aggressively resent in future (if needed)
self.outgoing_queue.insert(0, message)
return message