提交 ba73da85 编写于 作者: R Roger A. Light

Merge branch 'external-loop-publish-qos0' of...

Merge branch 'external-loop-publish-qos0' of git://github.com/jeeger/paho.mqtt.python into external-loop-publish-qos0
......@@ -3004,7 +3004,9 @@ class Client(object):
if err.errno != EAGAIN:
raise
if self._thread is None:
# If we have an external event loop registered, use that instead
# of calling lling loop_write() directly.
if self._thread is None and self.socket_register_write is None:
if self._in_callback_mutex.acquire(False):
self._in_callback_mutex.release()
return self.loop_write()
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册