From 9403cdd2a568e039e9fcd08f1152478383e3b6f4 Mon Sep 17 00:00:00 2001 From: Pascal Vizeli Date: Sun, 26 Feb 2017 23:43:02 +0100 Subject: [PATCH] Bugfix mqtt socket error (#6256) --- homeassistant/components/mqtt/__init__.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/homeassistant/components/mqtt/__init__.py b/homeassistant/components/mqtt/__init__.py index 57ea0351168..238d3c09146 100644 --- a/homeassistant/components/mqtt/__init__.py +++ b/homeassistant/components/mqtt/__init__.py @@ -393,8 +393,7 @@ class MQTT(object): self.progress = {} self.birth_message = birth_message self._mqttc = None - self._subscribe_lock = asyncio.Lock(loop=hass.loop) - self._publish_lock = asyncio.Lock(loop=hass.loop) + self._paho_lock = asyncio.Lock(loop=hass.loop) if protocol == PROTOCOL_31: proto = mqtt.MQTTv31 @@ -434,7 +433,7 @@ class MQTT(object): This method must be run in the event loop and returns a coroutine. """ - with (yield from self._publish_lock): + with (yield from self._paho_lock): yield from self.hass.loop.run_in_executor( None, self._mqttc.publish, topic, payload, qos, retain) @@ -484,7 +483,7 @@ class MQTT(object): if topic in self.topics: return - with (yield from self._subscribe_lock): + with (yield from self._paho_lock): result, mid = yield from self.hass.loop.run_in_executor( None, self._mqttc.subscribe, topic, qos)