Further reconnect fix.

Change-Id: I4225b09eec7586deed80c2ddada314b647154096

diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py
index 973357194b5432166aee38dd7efb65df55bd82d7..77d939a923213c4c5831bca890839c0950d430f4 100755 (executable)
--- 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: