From 5605f91ac1f46af1e050ae789c760de24db0bc69 Mon Sep 17 00:00:00 2001 From: "Roger A. Light" Date: Fri, 4 Jul 2014 12:09:51 +0100 Subject: [PATCH] Further reconnect fix. Change-Id: I4225b09eec7586deed80c2ddada314b647154096 --- src/paho/mqtt/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py index 9733571..77d939a 100755 --- a/src/paho/mqtt/client.py +++ b/src/paho/mqtt/client.py @@ -1224,7 +1224,7 @@ class Client(object): run = False self._state_mutex.acquire() - if self._state == mqtt_cs_disconnecting or run == False: + if self._state == mqtt_cs_disconnecting or run is False or self._thread_terminate is True: run = False self._state_mutex.release() else: @@ -1232,7 +1232,7 @@ class Client(object): time.sleep(1) self._state_mutex.acquire() - if self._state == mqtt_cs_disconnecting or run == False: + if self._state == mqtt_cs_disconnecting or run is False or self._thread_terminate is True: run = False self._state_mutex.release() else: -- 2.39.5