revpi/revpipyload
1
0
Fork 0
mirror of https://github.com/naruxde/revpipyload.git synced 2025-11-08 23:23:52 +01:00
Code Issues Packages Releases Wiki Activity

Eventüberwachung von RevPiModIO in MQTT im Thread starten

Browse Source
This commit is contained in:
Sven Sager
2018-09-06 13:37:49 +02:00
parent 50f829f1c6
commit c1afa0b33b
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
revpipyload/mqttserver.py
View File

@@ -147,10 +147,6 @@ class MqttServer(Thread):
io.reg_event(self._evt_io) io.reg_event(self._evt_io)
self._exported_ios.append(io) self._exported_ios.append(io)
# Eventüberwachung starten
if self._send_events:
self._rpi.mainloop(blocking=False)
proginit.logger.debug("created revpimodio2 object") proginit.logger.debug("created revpimodio2 object")
def _on_connect(self, client, userdata, flags, rc): def _on_connect(self, client, userdata, flags, rc):
@@ -279,6 +275,10 @@ class MqttServer(Thread):
) )
self._mq.loop_start() self._mq.loop_start()
# Eventüberwachung starten
if self._send_events:
self._rpi.mainloop(blocking=False)
# mainloop # mainloop
while not self.__exit: while not self.__exit:
self._evt_data.clear() self._evt_data.clear()
@@ -287,6 +287,10 @@ class MqttServer(Thread):
if self._reloadmodio: if self._reloadmodio:
self._loadrevpimodio() self._loadrevpimodio()
# Eventüberwachung erneut starten
if self._send_events:
self._rpi.mainloop(blocking=False)
# Werte laden, wenn nicht autorefresh # Werte laden, wenn nicht autorefresh
if not self._send_events: if not self._send_events:
self._rpi.readprocimg() self._rpi.readprocimg()