Skip to content

P
paho.mqtt.python

镜像 / Eclipse Foundation / paho.mqtt.python
大约 1 年 前同步成功

通知 2
Star 0
Fork 0
P
paho.mqtt.python

体验新版 GitCode，发现更多精彩内容 >>

提交 5605f91a 编写于 作者: R Roger A. Light
浏览文件
操作

Further reconnect fix. 

Change-Id: I4225b09eec7586deed80c2ddada314b647154096
上级 87521d8c
隐藏空白更改
内联 并排
Showing with 2 addition and 2 deletion
src/paho/mqtt/client.py
浏览文件 @ 5605f91a
...@@ -1224,7 +1224,7 @@ class Client(object): ...@@ -1224,7 +1224,7 @@ class Client(object):
run = False run = False
self._state_mutex.acquire() 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 run = False
self._state_mutex.release() self._state_mutex.release()
else: else:
...@@ -1232,7 +1232,7 @@ class Client(object): ...@@ -1232,7 +1232,7 @@ class Client(object):
time.sleep(1) time.sleep(1)
self._state_mutex.acquire() 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 run = False
self._state_mutex.release() self._state_mutex.release()
else: else:
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或