Merge pull request #101 from Dirk007/ping_timeout

Remove double check for keepalive
wialon · Mar 13, 2020 · b66193e · b66193e
2 parents 6311c46 + 61d40a6
commit b66193e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/gmqtt/mqtt/connection.py b/gmqtt/mqtt/connection.py
@@ -19,7 +19,7 @@ def __init__(self, transport: asyncio.Transport, protocol: MQTTProtocol, clean_s
         self._last_data_in = time.monotonic()
         self._last_data_out = time.monotonic()
 
-        self._keep_connection_callback = asyncio.get_event_loop().call_later(self._keepalive, self._keep_connection)
+        self._keep_connection_callback = asyncio.get_event_loop().call_later(self._keepalive / 2, self._keep_connection)
 
     @classmethod
     async def create_connection(cls, host, port, ssl, clean_session, keepalive, loop=None):
@@ -36,9 +36,9 @@ def _keep_connection(self):
             asyncio.ensure_future(self.close())
             return
 
-        if time.monotonic() - self._last_data_in >= self._keepalive:
+        if time.monotonic() - self._last_data_in >= 0.8 * self._keepalive:
             self._send_ping_request()
-        self._keep_connection_callback = asyncio.get_event_loop().call_later(self._keepalive, self._keep_connection)
+        self._keep_connection_callback = asyncio.get_event_loop().call_later(self._keepalive / 2, self._keep_connection)
 
     def put_package(self, pkg):
         self._last_data_in = time.monotonic()