Fix incorrect reconnect.

Fix incorrect reconnect that occurred if calling loop_stop() before
disconnect().

Change-Id: I50c0880b1773a0570511ed6473f81f3a6d13d4c8

diff --git a/ChangeLog.txt b/ChangeLog.txt
index a960c4f463c458e5331bb794f947a1b1540962c0..0827387a814d3dc8f231bd26a6b2fe4fc41b97db 100644 (file)
--- a/ChangeLog.txt
+++ b/ChangeLog.txt
@@ -1,3 +1,9 @@
+v1.0.1
+======
+
+- Fix incorrect reconnect that occurred if calling loop_stop() before
+  disconnect().
+
 v1.0
 ====
 

diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py
index ad9d64032faa5d261c365359346f83b58152047e..973357194b5432166aee38dd7efb65df55bd82d7 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:
+            if self._state == mqtt_cs_disconnecting or run == False:
                 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:
+                if self._state == mqtt_cs_disconnecting or run == False:
                     run = False
                     self._state_mutex.release()
                 else: