Fix keep_alive conformance test

HBMQTT-12
pull/8/head
Nicolas Jouanin 2015-07-27 15:00:50 +02:00
rodzic 269b194f5e
commit 7ce1c62637
2 zmienionych plików z 2 dodań i 1 usunięć

Wyświetl plik

@ -16,7 +16,7 @@ from hbmqtt.utils import format_client_message, gen_client_id
_defaults = {
'bind-address': 'localhost',
'bind-port': 1883,
'timeout-disconnect-delay': 10
'timeout-disconnect-delay': 2
}

Wyświetl plik

@ -136,6 +136,7 @@ class ProtocolHandler:
keepalive_timeout = self.session.keep_alive
if keepalive_timeout <= 0:
keepalive_timeout = None
self.logger.debug("Read keepalive timeout=%s s" % str(keepalive_timeout))
fixed_header = yield from asyncio.wait_for(MQTTFixedHeader.from_stream(self.session.reader), keepalive_timeout)
if fixed_header:
cls = packet_class(fixed_header)