From c1afa0b33b978d48464abda0469e5532cf2721e0 Mon Sep 17 00:00:00 2001 From: NaruX Date: Thu, 6 Sep 2018 13:37:49 +0200 Subject: [PATCH] =?UTF-8?q?Event=C3=BCberwachung=20von=20RevPiModIO=20in?= =?UTF-8?q?=20MQTT=20im=20Thread=20starten?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- revpipyload/mqttserver.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/revpipyload/mqttserver.py b/revpipyload/mqttserver.py index f880453..3ce3978 100644 --- a/revpipyload/mqttserver.py +++ b/revpipyload/mqttserver.py @@ -147,10 +147,6 @@ class MqttServer(Thread): io.reg_event(self._evt_io) self._exported_ios.append(io) - # Eventüberwachung starten - if self._send_events: - self._rpi.mainloop(blocking=False) - proginit.logger.debug("created revpimodio2 object") def _on_connect(self, client, userdata, flags, rc): @@ -279,6 +275,10 @@ class MqttServer(Thread): ) self._mq.loop_start() + # Eventüberwachung starten + if self._send_events: + self._rpi.mainloop(blocking=False) + # mainloop while not self.__exit: self._evt_data.clear() @@ -287,6 +287,10 @@ class MqttServer(Thread): if self._reloadmodio: self._loadrevpimodio() + # Eventüberwachung erneut starten + if self._send_events: + self._rpi.mainloop(blocking=False) + # Werte laden, wenn nicht autorefresh if not self._send_events: self._rpi.readprocimg()