Mit default zusammenführen

This commit is contained in:
2019-08-31 13:31:20 +02:00
7 changed files with 52 additions and 137 deletions

View File

@@ -429,7 +429,7 @@ Thread
<h3 style="background-color:#FFFFFF;color:#FF0000">
Class Attributes</h3>
<table>
<tr><td>__slots__</td></tr><tr><td>ioerrors</td></tr><tr><td>maxioerrors</td></tr><tr><td>refresh</td></tr>
<tr><td>__slots__</td></tr><tr><td>refresh</td></tr>
</table>
<h3 style="background-color:#FFFFFF;color:#FF0000">
Class Methods</h3>
@@ -452,24 +452,12 @@ Methods</h3>
<td><a style="color:#0000FF" href="#ProcimgWriter._collect_events">_collect_events</a></td>
<td>Aktiviert oder Deaktiviert die Eventueberwachung.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter._get_ioerrors">_get_ioerrors</a></td>
<td>Ruft aktuelle Anzahl der Fehler ab.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter._gotioerror">_gotioerror</a></td>
<td>IOError Verwaltung fuer autorefresh.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter.get_maxioerrors">get_maxioerrors</a></td>
<td>Gibt die Anzahl der maximal erlaubten Fehler zurueck.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter.get_refresh">get_refresh</a></td>
<td>Gibt Zykluszeit zurueck.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter.run">run</a></td>
<td>Startet die automatische Prozessabbildsynchronisierung.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter.set_maxioerrors">set_maxioerrors</a></td>
<td>Setzt die Anzahl der maximal erlaubten Fehler.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#ProcimgWriter.set_refresh">set_refresh</a></td>
<td>Setzt die Zykluszeit in Millisekunden.</td>
</tr><tr>
@@ -521,39 +509,6 @@ True aktiviert / False deaktiviert
<dd>
True, wenn Anforderung erfolgreich war
</dd>
</dl><a NAME="ProcimgWriter._get_ioerrors" ID="ProcimgWriter._get_ioerrors"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter._get_ioerrors</h3>
<b>_get_ioerrors</b>(<i></i>)
<p>
Ruft aktuelle Anzahl der Fehler ab.
</p><dl>
<dt>Returns:</dt>
<dd>
Aktuelle Fehleranzahl
</dd>
</dl><a NAME="ProcimgWriter._gotioerror" ID="ProcimgWriter._gotioerror"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter._gotioerror</h3>
<b>_gotioerror</b>(<i>e=None</i>)
<p>
IOError Verwaltung fuer autorefresh.
</p><dl>
<dt><i>e</i></dt>
<dd>
Exception to log if debug is enabled
</dd>
</dl><a NAME="ProcimgWriter.get_maxioerrors" ID="ProcimgWriter.get_maxioerrors"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter.get_maxioerrors</h3>
<b>get_maxioerrors</b>(<i></i>)
<p>
Gibt die Anzahl der maximal erlaubten Fehler zurueck.
</p><dl>
<dt>Returns:</dt>
<dd>
Anzahl erlaubte Fehler
</dd>
</dl><a NAME="ProcimgWriter.get_refresh" ID="ProcimgWriter.get_refresh"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter.get_refresh</h3>
@@ -571,18 +526,7 @@ ProcimgWriter.run</h3>
<b>run</b>(<i></i>)
<p>
Startet die automatische Prozessabbildsynchronisierung.
</p><a NAME="ProcimgWriter.set_maxioerrors" ID="ProcimgWriter.set_maxioerrors"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter.set_maxioerrors</h3>
<b>set_maxioerrors</b>(<i>value</i>)
<p>
Setzt die Anzahl der maximal erlaubten Fehler.
</p><dl>
<dt><i>value</i></dt>
<dd>
Anzahl erlaubte Fehler
</dd>
</dl><a NAME="ProcimgWriter.set_refresh" ID="ProcimgWriter.set_refresh"></a>
</p><a NAME="ProcimgWriter.set_refresh" ID="ProcimgWriter.set_refresh"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
ProcimgWriter.set_refresh</h3>
<b>set_refresh</b>(<i>value</i>)

View File

@@ -122,6 +122,9 @@ Methods</h3>
<td><a style="color:#0000FF" href="#RevPiModIO._set_cycletime">_set_cycletime</a></td>
<td>Setzt Aktualisierungsrate der Prozessabbild-Synchronisierung.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#RevPiModIO._set_debug">_set_debug</a></td>
<td>Setzt debugging Status um mehr Meldungen zu erhalten oder nicht.</td>
</tr><tr>
<td><a style="color:#0000FF" href="#RevPiModIO._set_maxioerrors">_set_maxioerrors</a></td>
<td>Setzt Anzahl der maximal erlaubten Fehler bei Prozessabbildzugriff.</td>
</tr><tr>
@@ -407,6 +410,17 @@ Setzt Aktualisierungsrate der Prozessabbild-Synchronisierung.
<dd>
<class 'int'> in Millisekunden
</dd>
</dl><a NAME="RevPiModIO._set_debug" ID="RevPiModIO._set_debug"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
RevPiModIO._set_debug</h3>
<b>_set_debug</b>(<i>value</i>)
<p>
Setzt debugging Status um mehr Meldungen zu erhalten oder nicht.
</p><dl>
<dt><i>value</i></dt>
<dd>
Wenn True, werden umfangreiche Medungen angezeigt
</dd>
</dl><a NAME="RevPiModIO._set_maxioerrors" ID="RevPiModIO._set_maxioerrors"></a>
<h3 style="background-color:#FFFFFF;color:#FF0000">
RevPiModIO._set_maxioerrors</h3>

View File

@@ -82,15 +82,9 @@ revpimodio2.helper.EventCallback.run?4()
revpimodio2.helper.EventCallback.stop?4()
revpimodio2.helper.EventCallback?1(func, name, value)
revpimodio2.helper.ProcimgWriter._collect_events?5(value)
revpimodio2.helper.ProcimgWriter._get_ioerrors?5()
revpimodio2.helper.ProcimgWriter._gotioerror?5(e=None)
revpimodio2.helper.ProcimgWriter.get_maxioerrors?4()
revpimodio2.helper.ProcimgWriter.get_refresh?4()
revpimodio2.helper.ProcimgWriter.ioerrors?7
revpimodio2.helper.ProcimgWriter.maxioerrors?7
revpimodio2.helper.ProcimgWriter.refresh?7
revpimodio2.helper.ProcimgWriter.run?4()
revpimodio2.helper.ProcimgWriter.set_maxioerrors?4(value)
revpimodio2.helper.ProcimgWriter.set_refresh?4(value)
revpimodio2.helper.ProcimgWriter.stop?4()
revpimodio2.helper.ProcimgWriter?1(parentmodio)
@@ -157,6 +151,7 @@ revpimodio2.modio.RevPiModIO._get_replace_io_file?5()
revpimodio2.modio.RevPiModIO._get_simulator?5()
revpimodio2.modio.RevPiModIO._gotioerror?5(action, e=None)
revpimodio2.modio.RevPiModIO._set_cycletime?5(milliseconds)
revpimodio2.modio.RevPiModIO._set_debug?5(value)
revpimodio2.modio.RevPiModIO._set_maxioerrors?5(value)
revpimodio2.modio.RevPiModIO._simulate_ioctl?5(request, arg=b'')
revpimodio2.modio.RevPiModIO.autorefresh_all?4()

View File

@@ -12,8 +12,6 @@ Auf alle IOs kann der Benutzer Funktionen als Events registrieren. Diese
fuehrt das Modul bei Datenaenderung aus.
"""
import warnings
__all__ = [
"RevPiModIO", "RevPiModIOSelected", "RevPiModIODriver",
"RevPiNetIO", "RevPiNetIOSelected", "RevPiNetIODriver"
@@ -35,8 +33,6 @@ INP = 300
OUT = 301
MEM = 302
warnings.simplefilter(action="always")
class DeviceNotFoundError(Exception):

View File

@@ -348,12 +348,10 @@ class Device(object):
if not self._modio._imgwriter.is_alive():
# Alte Einstellungen speichern
imgmaxioerrors = self._modio._imgwriter.maxioerrors
imgrefresh = self._modio._imgwriter.refresh
# ImgWriter mit alten Einstellungen erstellen
self._modio._imgwriter = ProcimgWriter(self._modio)
self._modio._imgwriter.maxioerrors = imgmaxioerrors
self._modio._imgwriter.refresh = imgrefresh
self._modio._imgwriter.start()

View File

@@ -290,7 +290,7 @@ class ProcimgWriter(Thread):
"""
__slots__ = "__dict_delay", "__eventth", "_eventqth", "__eventwork", \
"_adjwait", "_eventq", "_ioerror", "_maxioerrors", "_modio", \
"_adjwait", "_eventq", "_modio", \
"_refresh", "_work", "daemon", "lck_refresh", "newdata"
def __init__(self, parentmodio):
@@ -303,8 +303,6 @@ class ProcimgWriter(Thread):
self.__eventwork = False
self._adjwait = 0
self._eventq = queue.Queue()
self._ioerror = 0
self._maxioerrors = 0
self._modio = parentmodio
self._refresh = 0.05
self._work = Event()
@@ -429,34 +427,6 @@ class ProcimgWriter(Thread):
return True
def _get_ioerrors(self):
"""Ruft aktuelle Anzahl der Fehler ab.
@return Aktuelle Fehleranzahl"""
return self._ioerror
def _gotioerror(self, e=None):
"""IOError Verwaltung fuer autorefresh.
@param e Exception to log if debug is enabled
"""
self._ioerror += 1
if self._maxioerrors != 0 and self._ioerror >= self._maxioerrors:
raise RuntimeError(
"reach max io error count {0} on process image".format(
self._maxioerrors
)
)
warnings.warn(
"count {0} io errors on process image".format(self._ioerror),
RuntimeWarning
)
if self._modio._debug and e is not None:
warnings.warn(str(e), RuntimeWarning)
def get_maxioerrors(self):
"""Gibt die Anzahl der maximal erlaubten Fehler zurueck.
@return Anzahl erlaubte Fehler"""
return self._maxioerrors
def get_refresh(self):
"""Gibt Zykluszeit zurueck.
@return <class 'int'> Zykluszeit in Millisekunden"""
@@ -473,9 +443,8 @@ class ProcimgWriter(Thread):
# Lockobjekt holen und Fehler werfen, wenn nicht schnell genug
if not self.lck_refresh.acquire(timeout=self._adjwait):
warnings.warn(
"cycle time of {0} ms exceeded on lock".format(
int(self._refresh * 1000)
),
"cycle time of {0} ms exceeded during executing function"
"".format(int(self._refresh * 1000)),
RuntimeWarning
)
# Verzögerte Events pausieren an dieser Stelle
@@ -513,7 +482,7 @@ class ProcimgWriter(Thread):
fh.flush()
except IOError as e:
self._gotioerror(e)
self._modio._gotioerror("autorefresh", e)
self.lck_refresh.release()
continue
@@ -547,9 +516,8 @@ class ProcimgWriter(Thread):
self._adjwait -= 0.001
if self._adjwait < 0:
warnings.warn(
"cycle time of {0} ms exceeded".format(
int(self._refresh * 1000)
),
"cycle time of {0} ms exceeded several times - can not"
" hold cycle time!".format(int(self._refresh * 1000)),
RuntimeWarning
)
self._adjwait = 0
@@ -565,17 +533,6 @@ class ProcimgWriter(Thread):
"""Beendet die automatische Prozessabbildsynchronisierung."""
self._work.set()
def set_maxioerrors(self, value):
"""Setzt die Anzahl der maximal erlaubten Fehler.
@param value Anzahl erlaubte Fehler"""
if type(value) == int:
if value >= 0:
self._maxioerrors = value
else:
raise ValueError("value must be 0 or a positive integer")
else:
raise TypeError("value must be <class 'int'>")
def set_refresh(self, value):
"""Setzt die Zykluszeit in Millisekunden.
@param value <class 'int'> Millisekunden"""
@@ -588,6 +545,4 @@ class ProcimgWriter(Thread):
"refresh time must be 5 to 2000 milliseconds"
)
ioerrors = property(_get_ioerrors)
maxioerrors = property(get_maxioerrors, set_maxioerrors)
refresh = property(get_refresh, set_refresh)

View File

@@ -80,7 +80,7 @@ class RevPiModIO(object):
# Private Variablen
self.__cleanupfunc = None
self._buffedwrite = False
self._debug = debug
self._debug = False
self._exit = Event()
self._imgwriter = None
self._ioerror = 0
@@ -107,6 +107,9 @@ class RevPiModIO(object):
# Event für Benutzeraktionen
self.exitsignal = Event()
# Wert über setter setzen
self.debug = debug
try:
self._run_on_pi = S_ISCHR(osstat(self._procimg).st_mode)
except Exception:
@@ -234,7 +237,8 @@ class RevPiModIO(object):
else:
# Device-Type nicht gefunden
warnings.warn(
"device type '{0}' unknown".format(device["type"]),
"device type '{0}' on position {1} unknown"
"".format(device["type"], device["position"]),
Warning
)
dev_new = None
@@ -409,10 +413,7 @@ class RevPiModIO(object):
def _get_ioerrors(self):
"""Getter function.
@return Aktuelle Anzahl gezaehlter Fehler"""
if self._looprunning:
return self._imgwriter._ioerror
else:
return self._ioerror
return self._ioerror
def _get_length(self):
"""Getter function.
@@ -457,13 +458,15 @@ class RevPiModIO(object):
"reach max io error count {0} on process image"
"".format(self._maxioerrors)
)
warnings.warn(
"got io error during {0} and count {1} errors now"
"".format(action, self._ioerror),
RuntimeWarning
)
if self._debug and e is not None:
warnings.warn(str(e), RuntimeWarning)
if self._debug:
warnings.warn(
"got io error during '{0}' and count {1} errors now | {2}"
"".format(action, self._ioerror, str(e)),
RuntimeWarning
)
else:
warnings.warn("got io error on process image", RuntimeWarning)
def _set_cycletime(self, milliseconds):
"""Setzt Aktualisierungsrate der Prozessabbild-Synchronisierung.
@@ -476,12 +479,23 @@ class RevPiModIO(object):
else:
self._imgwriter.refresh = milliseconds
def _set_debug(self, value):
"""Setzt debugging Status um mehr Meldungen zu erhalten oder nicht.
@param value Wenn True, werden umfangreiche Medungen angezeigt"""
if not isinstance(value, bool):
raise TypeError("value must be <class 'bool'>")
self._debug = value
if value:
warnings.filterwarnings("always", module="revpimodio2")
else:
warnings.filterwarnings("default", module="revpimodio2")
def _set_maxioerrors(self, value):
"""Setzt Anzahl der maximal erlaubten Fehler bei Prozessabbildzugriff.
@param value Anzahl erlaubte Fehler"""
if type(value) == int and value >= 0:
self._maxioerrors = value
self._imgwriter.maxioerrors = value
else:
raise ValueError("value must be 0 or a positive integer")
@@ -963,7 +977,6 @@ class RevPiModIO(object):
def resetioerrors(self):
"""Setzt aktuellen IOError-Zaehler auf 0 zurueck."""
self._ioerror = 0
self._imgwriter._ioerror = 0
def setdefaultvalues(self, device=None):
"""Alle Outputbuffer werden auf die piCtory default Werte gesetzt.
@@ -1087,7 +1100,7 @@ class RevPiModIO(object):
return workokay
debug = property(_get_debug)
debug = property(_get_debug, _set_debug)
configrsc = property(_get_configrsc)
cycletime = property(_get_cycletime, _set_cycletime)
ioerrors = property(_get_ioerrors)