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

Sync the first cycle with imgwriter after calling .cycleloop

Browse Source
This commit is contained in:
Sven Sager
2021-10-24 14:28:33 +02:00
parent bc8a13da1b
commit 36ff69aaa6
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
revpimodio2/helper.py
View File

@@ -516,9 +516,6 @@ class ProcimgWriter(Thread):
mrk_warn = True mrk_warn = True
bytesbuff = bytearray(self._modio._length) bytesbuff = bytearray(self._modio._length)
# First sync of cycle time to start the main loop and match exact time
sleep(self._refresh - (default_timer() % self._refresh))
while not self._work.is_set(): while not self._work.is_set():
ot = default_timer() ot = default_timer()

5
revpimodio2/modio.py
View File

@@ -767,10 +767,10 @@ class RevPiModIO(object):
# Zykluszeit übernehmen # Zykluszeit übernehmen
old_cycletime = self._imgwriter.refresh old_cycletime = self._imgwriter.refresh
if not cycletime == self._imgwriter.refresh: if not cycletime == self._imgwriter.refresh:
# Set new cycle time and wait one imgwriter cycle to sync fist cycle
self._imgwriter.refresh = cycletime self._imgwriter.refresh = cycletime
# Zeitänderung in _imgwriter neuladen
self._imgwriter.newdata.clear() self._imgwriter.newdata.clear()
self._imgwriter.newdata.wait(self._imgwriter._refresh)
# Benutzerevent # Benutzerevent
self.exitsignal.clear() self.exitsignal.clear()
@@ -781,6 +781,7 @@ class RevPiModIO(object):
cycleinfo = helpermodule.Cycletools(self._imgwriter.refresh, self) cycleinfo = helpermodule.Cycletools(self._imgwriter.refresh, self)
e = None # Exception e = None # Exception
ec = None # Return value of cycle_function ec = None # Return value of cycle_function
self._imgwriter.newdata.clear()
try: try:
while ec is None and not cycleinfo.last: while ec is None and not cycleinfo.last:
# Auf neue Daten warten und nur ausführen wenn set() # Auf neue Daten warten und nur ausführen wenn set()