Enhance the proper stopping. Still [Errno 9] Bad file descriptor happen sometimes

This commit is contained in:
Sébastien Lucas
2017-05-31 22:25:30 +02:00
parent 200703f37e
commit 9806caca85
2 changed files with 9 additions and 1 deletions
+8 -1
View File
@@ -17,6 +17,8 @@ def process_gateway_messages(gateway, client, stop_event):
while not stop_event.is_set():
try:
packet = gateway._queue.get()
if packet is None:
continue
_LOGGER.debug("data from queuee: " + format(packet))
sid = packet.get("sid", None)
@@ -67,6 +69,8 @@ def process_mqtt_messages(gateway, client, stop_event):
while not stop_event.is_set():
try:
data = client._queue.get()
if data is None:
continue
_LOGGER.debug("data from mqtt: " + format(data))
sid = data.get("sid", None)
@@ -81,8 +85,11 @@ def process_mqtt_messages(gateway, client, stop_event):
def exit_handler(signal, frame):
print('Exiting')
stop_event.set()
gateway.stop()
t3.join()
client.disconnect()
t2.join()
gateway.stop()
t1.join()
if __name__ == "__main__":
_LOGGER.info("Loading config file...")