Mit direct_io zusammenführen

2025-11-08 13:53:53 +01:00 · 2019-07-31 21:33:27 +02:00
parent 37101b3a84 527a4aa078
commit 4b1b0d30e4
7 changed files with 250 additions and 88 deletions
--- a/doc/revpimodio2.modio.html
+++ b/doc/revpimodio2.modio.html
@@ -122,6 +122,9 @@ Methods</h3>
 <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>
+<td><a style="color:#0000FF" href="#RevPiModIO._simulate_ioctl">_simulate_ioctl</a></td>
+<td>Simuliert IOCTL Funktionen auf procimg Datei.</td>
+</tr><tr>
 <td><a style="color:#0000FF" href="#RevPiModIO.autorefresh_all">autorefresh_all</a></td>
 <td>Setzt alle Devices in autorefresh Funktion.</td>
 </tr><tr>
@@ -170,7 +173,7 @@ Static Methods</h3>
 <a NAME="RevPiModIO.__init__" ID="RevPiModIO.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiModIO (Constructor)</h3>
-<b>RevPiModIO</b>(<i>autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None</i>)
+<b>RevPiModIO</b>(<i>autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert die Grundfunktionen.
 </p><dl>
@@ -198,6 +201,9 @@ Gibt bei allen Fehlern komplette Meldungen aus
 </dd><dt><i>replace_io_file</i></dt>
 <dd>
 Replace IO Konfiguration aus Datei laden
+</dd><dt><i>direct_output</i></dt>
+<dd>
+Write outputs immediately to process image (slow)
 </dd>
 </dl><a NAME="RevPiModIO.__del__" ID="RevPiModIO.__del__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
@@ -390,6 +396,20 @@ Setzt Anzahl der maximal erlaubten Fehler bei Prozessabbildzugriff.
 <dd>
 Anzahl erlaubte Fehler
 </dd>
+</dl><a NAME="RevPiModIO._simulate_ioctl" ID="RevPiModIO._simulate_ioctl"></a>
+<h3 style="background-color:#FFFFFF;color:#FF0000">
+RevPiModIO._simulate_ioctl</h3>
+<b>_simulate_ioctl</b>(<i>request, arg=b''</i>)
+<p>
+Simuliert IOCTL Funktionen auf procimg Datei.
+</p><dl>
+<dt><i>request</i></dt>
+<dd>
+IO Request
+</dd><dt><i>arg:</i></dt>
+<dd>
+Request argument
+</dd>
 </dl><a NAME="RevPiModIO.autorefresh_all" ID="RevPiModIO.autorefresh_all"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiModIO.autorefresh_all</h3>
@@ -660,7 +680,7 @@ Static Methods</h3>
 <a NAME="RevPiModIODriver.__init__" ID="RevPiModIODriver.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiModIODriver (Constructor)</h3>
-<b>RevPiModIODriver</b>(<i>virtdev, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, debug=False, replace_io_file=None</i>)
+<b>RevPiModIODriver</b>(<i>virtdev, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert die Grundfunktionen.
 </p><p>
@@ -720,7 +740,7 @@ Static Methods</h3>
 <a NAME="RevPiModIOSelected.__init__" ID="RevPiModIOSelected.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiModIOSelected (Constructor)</h3>
-<b>RevPiModIOSelected</b>(<i>deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None</i>)
+<b>RevPiModIOSelected</b>(<i>deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert nur fuer angegebene Devices die Grundfunktionen.
 </p><p>
--- a/doc/revpimodio2.netio.html
+++ b/doc/revpimodio2.netio.html
@@ -423,7 +423,7 @@ Static Methods</h3>
 <a NAME="RevPiNetIO.__init__" ID="RevPiNetIO.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiNetIO (Constructor)</h3>
-<b>RevPiNetIO</b>(<i>address, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None</i>)
+<b>RevPiNetIO</b>(<i>address, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert die Grundfunktionen.
 </p><dl>
@@ -448,6 +448,9 @@ Gibt bei allen Fehlern komplette Meldungen aus
 </dd><dt><i>replace_io_file</i></dt>
 <dd>
 Replace IO Konfiguration aus Datei laden
+</dd><dt><i>direct_output</i></dt>
+<dd>
+Write outputs immediately to process image (slow)
 </dd>
 </dl><a NAME="RevPiNetIO._create_myfh" ID="RevPiNetIO._create_myfh"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
@@ -539,7 +542,7 @@ Static Methods</h3>
 <a NAME="RevPiNetIODriver.__init__" ID="RevPiNetIODriver.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiNetIODriver (Constructor)</h3>
-<b>RevPiNetIODriver</b>(<i>address, virtdev, autorefresh=False, monitoring=False, syncoutputs=True, debug=False, replace_io_file=None</i>)
+<b>RevPiNetIODriver</b>(<i>address, virtdev, autorefresh=False, monitoring=False, syncoutputs=True, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert die Grundfunktionen.
 </p><p>
@@ -602,7 +605,7 @@ Static Methods</h3>
 <a NAME="RevPiNetIOSelected.__init__" ID="RevPiNetIOSelected.__init__"></a>
 <h3 style="background-color:#FFFFFF;color:#FF0000">
 RevPiNetIOSelected (Constructor)</h3>
-<b>RevPiNetIOSelected</b>(<i>address, deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None</i>)
+<b>RevPiNetIOSelected</b>(<i>address, deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None, direct_output=False</i>)
 <p>
 Instantiiert nur fuer angegebene Devices die Grundfunktionen.
 </p><p>
--- a/eric-revpimodio2.api
+++ b/eric-revpimodio2.api
@@ -157,6 +157,7 @@ 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_maxioerrors?5(value)
+revpimodio2.modio.RevPiModIO._simulate_ioctl?5(request, arg=b'')
 revpimodio2.modio.RevPiModIO.autorefresh_all?4()
 revpimodio2.modio.RevPiModIO.cleanup?4()
 revpimodio2.modio.RevPiModIO.configrsc?7
@@ -180,9 +181,9 @@ revpimodio2.modio.RevPiModIO.setdefaultvalues?4(device=None)
 revpimodio2.modio.RevPiModIO.simulator?7
 revpimodio2.modio.RevPiModIO.syncoutputs?4(device=None)
 revpimodio2.modio.RevPiModIO.writeprocimg?4(device=None)
-revpimodio2.modio.RevPiModIO?1(autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None)
-revpimodio2.modio.RevPiModIODriver?1(virtdev, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, debug=False, replace_io_file=None)
-revpimodio2.modio.RevPiModIOSelected?1(deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None)
+revpimodio2.modio.RevPiModIO?1(autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None, direct_output=False)
+revpimodio2.modio.RevPiModIODriver?1(virtdev, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, debug=False, replace_io_file=None, direct_output=False)
+revpimodio2.modio.RevPiModIOSelected?1(deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, procimg=None, configrsc=None, simulator=False, debug=False, replace_io_file=None, direct_output=False)
 revpimodio2.netio.NetFH._connect?5()
 revpimodio2.netio.NetFH._direct_send?5(send_bytes, recv_count)
 revpimodio2.netio.NetFH.clear_dirtybytes?4(position=None)
@@ -209,9 +210,9 @@ revpimodio2.netio.RevPiNetIO.disconnect?4()
 revpimodio2.netio.RevPiNetIO.get_jconfigrsc?4()
 revpimodio2.netio.RevPiNetIO.net_cleardefaultvalues?4(device=None)
 revpimodio2.netio.RevPiNetIO.net_setdefaultvalues?4(device=None)
-revpimodio2.netio.RevPiNetIO?1(address, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None)
-revpimodio2.netio.RevPiNetIODriver?1(address, virtdev, autorefresh=False, monitoring=False, syncoutputs=True, debug=False, replace_io_file=None)
-revpimodio2.netio.RevPiNetIOSelected?1(address, deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None)
+revpimodio2.netio.RevPiNetIO?1(address, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None, direct_output=False)
+revpimodio2.netio.RevPiNetIODriver?1(address, virtdev, autorefresh=False, monitoring=False, syncoutputs=True, debug=False, replace_io_file=None, direct_output=False)
+revpimodio2.netio.RevPiNetIOSelected?1(address, deviceselection, autorefresh=False, monitoring=False, syncoutputs=True, simulator=False, debug=False, replace_io_file=None, direct_output=False)
 revpimodio2.netio._sysdeldirty?8
 revpimodio2.netio._sysexit?8
 revpimodio2.netio._sysflush?8
--- a/revpimodio2/helper.py
+++ b/revpimodio2/helper.py
@@ -483,7 +483,7 @@ class ProcimgWriter(Thread):
                fh.seek(0)
                bytesbuff = bytearray(fh.read(self._modio._length))

-                if self._modio._monitoring:
+                if self._modio._monitoring or self._modio._direct_output:
                    # Inputs und Outputs in Puffer
                    for dev in self._modio._lst_refresh:
                        with dev._filelock:
--- a/revpimodio2/io.py
+++ b/revpimodio2/io.py
@@ -5,11 +5,9 @@ __copyright__ = "Copyright (C) 2018 Sven Sager"
 __license__ = "LGPLv3"

 import struct
-import warnings
 from re import match as rematch
 from threading import Event
-from revpimodio2 import RISING, FALLING, BOTH, INP, OUT, MEM, consttostr
-from .netio import RevPiNetIO
+from revpimodio2 import RISING, FALLING, BOTH, INP, MEM, consttostr
 try:
    # Funktioniert nur auf Unix
    from fcntl import ioctl
@@ -264,7 +262,8 @@ class IOBase(object):

    """

-    __slots__ = "_bitaddress", "_bitlength", "_byteorder", "_defaultvalue", \
+    __slots__ = "__bit_ioctl_off", "__bit_ioctl_on", \
+        "_bitaddress", "_bitlength", "_byteorder", "_defaultvalue", \
        "_iotype", "_length", "_name", "_parentdevice", \
        "_signed", "_slc_address", "bmk", "export"

@@ -290,6 +289,8 @@ class IOBase(object):
        self._bitlength = int(valuelist[2])
        self._length = 1 if self._bitaddress == 0 else int(self._bitlength / 8)

+        self.__bit_ioctl_off = None
+        self.__bit_ioctl_on = None
        self._byteorder = byteorder
        self._iotype = iotype
        self._name = valuelist[0]
@@ -350,6 +351,12 @@ class IOBase(object):
                except Exception:
                    self._defaultvalue = False

+            # Ioctl für Bitsetzung setzen
+            self.__bit_ioctl_off = \
+                self._get_address().to_bytes(2, "little") \
+                + self._bitaddress.to_bytes(1, "little")
+            self.__bit_ioctl_on = self.__bit_ioctl_off + b'\x01'
+
    def __bool__(self):
        """<class 'bool'>-Wert der Klasse.
        @return <class 'bool'> Nur False wenn False oder 0 sonst True"""
@@ -518,10 +525,72 @@ class IOBase(object):
    def set_value(self, value):
        """Setzt den Wert des IOs.
        @param value IO-Wert als <class bytes'> oder <class 'bool'>"""
-        if self._iotype == OUT:
-            if self._bitaddress >= 0:
-                # Versuchen egal welchen Typ in Bool zu konvertieren
-                value = bool(value)
+        if self._iotype == INP:
+            if self._parentdevice._modio._simulator:
+                raise RuntimeError(
+                    "can not write to output '{0}' in simulator mode"
+                    "".format(self._name)
+                )
+            else:
+                raise RuntimeError(
+                    "can not write to input '{0}'".format(self._name)
+                )
+        if self._iotype == MEM:
+            raise RuntimeError(
+                "can not write to memory '{0}'".format(self._name)
+            )
+
+        if self._bitaddress >= 0:
+            # Versuchen egal welchen Typ in Bool zu konvertieren
+            value = bool(value)
+
+            if self._parentdevice._modio._direct_output:
+                # Direktes Schreiben der Outputs
+
+                if self._parentdevice._modio._run_on_pi:
+                    # IOCTL auf dem RevPi
+                    with self._parentdevice._modio._myfh_lck:
+                        try:
+                            # Set value durchführen (Funktion K+16)
+                            ioctl(
+                                self._parentdevice._modio._myfh,
+                                19216,
+                                self.__bit_ioctl_on if value
+                                else self.__bit_ioctl_off
+                            )
+                        except Exception as e:
+                            self._parentdevice._modio._gotioerror("ioset", e)
+
+                elif hasattr(self._parentdevice._modio._myfh, "ioctl"):
+                    # IOCTL über Netzwerk
+                    with self._parentdevice._modio._myfh_lck:
+                        try:
+                            self._parentdevice._modio._myfh.ioctl(
+                                19216,
+                                self.__bit_ioctl_on if value
+                                else self.__bit_ioctl_off
+                            )
+                        except Exception as e:
+                            self._parentdevice._modio._gotioerror(
+                                "net_ioset", e)
+
+                else:
+                    # IOCTL in Datei simulieren
+                    try:
+                        # Set value durchführen (Funktion K+16)
+                        self._parentdevice._modio._simulate_ioctl(
+                            19216,
+                            self.__bit_ioctl_on if value
+                            else self.__bit_ioctl_off
+                        )
+                    except Exception as e:
+                        self._parentdevice._modio._gotioerror("file_ioset", e)
+
+            else:
+                # Gepuffertes Schreiben der Outputs
+
+                # Für Bitoperationen sperren
+                self._parentdevice._filelock.acquire()

                # ganzes Byte laden
                byte_buff = self._parentdevice._ba_devdata[self._slc_address]
@@ -542,39 +611,37 @@ class IOBase(object):
                    self._parentdevice._ba_devdata[self._slc_address] = \
                        int_byte.to_bytes(int_len, byteorder=self._byteorder)

-            else:
-                if type(value) == bytes:
-                    if self._length == len(value):
-                        self._parentdevice._ba_devdata[self._slc_address] = \
-                            value
-                    else:
-                        raise ValueError(
-                            "'{0}' requires a <class 'bytes'> object of "
-                            "length {1}, but {2} was given".format(
-                                self._name, self._length, len(value)
-                            )
-                        )
-                else:
-                    raise TypeError(
-                        "'{0}' requires a <class 'bytes'> object, not {1}"
-                        "".format(self._name, type(value))
+                self._parentdevice._filelock.release()
+
+        else:
+            if type(value) != bytes:
+                raise TypeError(
+                    "'{0}' requires a <class 'bytes'> object, not {1}".format(
+                        self._name, type(value)
                    )
-
-        elif self._iotype == INP:
-            if self._parentdevice._modio._simulator:
-                raise RuntimeError(
-                    "can not write to output '{0}' in simulator mode"
-                    "".format(self._name)
                )
+
+            if self._length != len(value):
+                raise ValueError(
+                    "'{0}' requires a <class 'bytes'> object of "
+                    "length {1}, but {2} was given".format(
+                        self._name, self._length, len(value)
+                    )
+                )
+
+            if self._parentdevice._modio._direct_output:
+                with self._parentdevice._modio._myfh_lck:
+                    try:
+                        self._parentdevice._modio._myfh.seek(
+                            self._get_address()
+                        )
+                        self._parentdevice._modio._myfh.write(value)
+                        if self._parentdevice._modio._buffedwrite:
+                            self._parentdevice._modio._myfh.flush()
+                    except IOError as e:
+                        self._parentdevice._modio._gotioerror("ioset", e)
            else:
-                raise RuntimeError(
-                    "can not write to input '{0}'".format(self._name)
-                )
-
-        elif self._iotype == MEM:
-            raise RuntimeError(
-                "can not write to memory '{0}'".format(self._name)
-            )
+                self._parentdevice._ba_devdata[self._slc_address] = value

    def unreg_event(self, func=None, edge=None):
        """Entfernt ein Event aus der Eventueberwachung.
@@ -856,24 +923,7 @@ class IntIOCounter(IntIO):
                "can not reset counter, while system is in simulator mode"
            )

-        if isinstance(self._parentdevice._modio, RevPiNetIO):
-            # IOCTL über Netzwerk
-            with self._parentdevice._modio._myfh_lck:
-                try:
-                    self._parentdevice._modio._myfh.ioctl(
-                        19220, self.__ioctl_arg
-                    )
-                except Exception as e:
-                    self._parentdevice._modio._gotioerror("net_ioctl", e)
-
-        elif self._parentdevice._modio._procimg != "/dev/piControl0":
-            # NOTE: Soll hier eine 0 in den Input geschrieben werden?
-            warnings.warn(
-                "this will work on a revolution pi only",
-                RuntimeWarning
-            )
-
-        else:
+        if self._parentdevice._modio._run_on_pi:
            # IOCTL auf dem RevPi
            with self._parentdevice._modio._myfh_lck:
                try:
@@ -883,7 +933,27 @@ class IntIOCounter(IntIO):
                        19220, self.__ioctl_arg
                    )
                except Exception as e:
-                    self._parentdevice._modio._gotioerror("ioctl", e)
+                    self._parentdevice._modio._gotioerror("iorst", e)
+
+        elif hasattr(self._parentdevice._modio._myfh, "ioctl"):
+            # IOCTL über Netzwerk
+            with self._parentdevice._modio._myfh_lck:
+                try:
+                    self._parentdevice._modio._myfh.ioctl(
+                        19220, self.__ioctl_arg
+                    )
+                except Exception as e:
+                    self._parentdevice._modio._gotioerror("net_iorst", e)
+
+        else:
+            # IOCTL in Datei simulieren
+            try:
+                # Set value durchführen (Funktion K+20)
+                self._parentdevice._modio._simulate_ioctl(
+                    19220, self.__ioctl_arg
+                )
+            except Exception as e:
+                self._parentdevice._modio._gotioerror("file_iorst", e)


 class IntIOReplaceable(IntIO):
--- a/revpimodio2/modio.py
+++ b/revpimodio2/modio.py
@@ -9,9 +9,11 @@ from configparser import ConfigParser
 from json import load as jload
 from multiprocessing import cpu_count
 from os import access, F_OK, R_OK
+from os import stat as osstat
 from queue import Empty
 from revpimodio2 import acheck, DeviceNotFoundError, BOTH, RISING, FALLING
 from signal import signal, SIG_DFL, SIGINT, SIGTERM
+from stat import S_ISCHR
 from threading import Thread, Event, Lock
 from timeit import default_timer

@@ -30,17 +32,17 @@ class RevPiModIO(object):
    """

    __slots__ = "__cleanupfunc", "_autorefresh", "_buffedwrite", \
-        "_configrsc", "_exit", "_imgwriter", "_ioerror", "_length", \
-        "_looprunning", "_lst_devselect", "_lst_refresh", "_maxioerrors", \
-        "_myfh", "_myfh_lck", "_monitoring", "_procimg", "_simulator", \
-        "_syncoutputs", "_th_mainloop", "_waitexit", \
+        "_configrsc", "_direct_output", "_exit", "_imgwriter", "_ioerror", \
+        "_length", "_looprunning", "_lst_devselect", "_lst_refresh", \
+        "_maxioerrors", "_myfh", "_myfh_lck", "_monitoring", "_procimg", \
+        "_simulator", "_syncoutputs", "_th_mainloop", "_waitexit", \
        "core", "app", "device", "exitsignal", "io", "summary", "_debug", \
-        "_lck_replace_io", "_replace_io_file"
+        "_lck_replace_io", "_replace_io_file", "_run_on_pi"

    def __init__(
            self, autorefresh=False, monitoring=False, syncoutputs=True,
            procimg=None, configrsc=None, simulator=False, debug=False,
-            replace_io_file=None):
+            replace_io_file=None, direct_output=False):
        """Instantiiert die Grundfunktionen.

        @param autorefresh Wenn True, alle Devices zu autorefresh hinzufuegen
@@ -51,12 +53,14 @@ class RevPiModIO(object):
        @param simulator Laedt das Modul als Simulator und vertauscht IOs
        @param debug Gibt bei allen Fehlern komplette Meldungen aus
        @param replace_io_file Replace IO Konfiguration aus Datei laden
+        @param direct_output Write outputs immediately to process image (slow)

        """
        # Parameterprüfung
        acheck(
            bool, autorefresh=autorefresh, monitoring=monitoring,
-            syncoutputs=syncoutputs, simulator=simulator, debug=debug
+            syncoutputs=syncoutputs, simulator=simulator, debug=debug,
+            direct_output=direct_output
        )
        acheck(
            str, procimg_noneok=procimg, configrsc_noneok=configrsc,
@@ -65,6 +69,7 @@ class RevPiModIO(object):

        self._autorefresh = autorefresh
        self._configrsc = configrsc
+        self._direct_output = direct_output
        self._monitoring = monitoring
        self._procimg = "/dev/piControl0" if procimg is None else procimg
        self._simulator = simulator
@@ -103,6 +108,11 @@ class RevPiModIO(object):
        # Event für Benutzeraktionen
        self.exitsignal = Event()

+        try:
+            self._run_on_pi = S_ISCHR(osstat(self._procimg).st_mode)
+        except Exception:
+            self._run_on_pi = False
+
        # Nur Konfigurieren, wenn nicht vererbt
        if type(self) == RevPiModIO:
            self._configure(self.get_jconfigrsc())
@@ -471,6 +481,57 @@ class RevPiModIO(object):
        else:
            raise ValueError("value must be 0 or a positive integer")

+    def _simulate_ioctl(self, request, arg=b''):
+        """Simuliert IOCTL Funktionen auf procimg Datei.
+        @param request IO Request
+        @param arg: Request argument"""
+        if request == 19216:
+            # Einzelnes Bit setzen
+            byte_address = int.from_bytes(arg[:2], byteorder="little")
+            bit_address = arg[2]
+            new_value = bool(0 if len(arg) <= 3 else arg[3])
+
+            # Simulatonsmodus schreibt direkt in Datei
+            with self._myfh_lck:
+                self._myfh.seek(byte_address)
+                int_byte = int.from_bytes(
+                    self._myfh.read(1), byteorder="little"
+                )
+                int_bit = 1 << bit_address
+
+                if not bool(int_byte & int_bit) == new_value:
+                    if new_value:
+                        int_byte += int_bit
+                    else:
+                        int_byte -= int_bit
+
+                    self._myfh.seek(byte_address)
+                    self._myfh.write(int_byte.to_bytes(1, byteorder="little"))
+                    if self._buffedwrite:
+                        self._myfh.flush()
+
+        elif request == 19220:
+            # FIXME: Implement
+            # Counterwert auf 0 setzen
+            dev_position = arg[0]
+            bit_field = int.from_bytes(arg[2:], byteorder="little")
+            io_byte = -1
+
+            for i in range(16):
+                if bool(bit_field & 1 << i):
+                    io_byte = self.device[dev_position].offset \
+                        + int(self.device[dev_position]._lst_counter[i])
+                    break
+
+            if io_byte == -1:
+                raise RuntimeError("count not reset counter io in file")
+
+            with self._myfh_lck:
+                self._myfh.seek(io_byte)
+                self._myfh.write(b'\x00\x00\x00\x00')
+                if self._buffedwrite:
+                    self._myfh.flush()
+
    def autorefresh_all(self):
        """Setzt alle Devices in autorefresh Funktion."""
        for dev in self.device:
@@ -880,7 +941,7 @@ class RevPiModIO(object):
                # FileHandler sperren
                dev._filelock.acquire()

-                if self._monitoring:
+                if self._monitoring or self._direct_output:
                    # Alles vom Bus einlesen
                    dev._ba_devdata[:] = bytesbuff[dev._slc_devoff]
                else:
@@ -968,6 +1029,9 @@ class RevPiModIO(object):
        @return True, wenn Arbeiten an allen Devices erfolgreich waren

        """
+        if self._direct_output:
+            return True
+
        if self._monitoring:
            raise RuntimeError(
                "can not write process image, while system is in monitoring "
@@ -1046,7 +1110,8 @@ class RevPiModIOSelected(RevPiModIO):
    def __init__(
            self, deviceselection, autorefresh=False, monitoring=False,
            syncoutputs=True, procimg=None, configrsc=None,
-            simulator=False, debug=False, replace_io_file=None):
+            simulator=False, debug=False, replace_io_file=None,
+            direct_output=False):
        """Instantiiert nur fuer angegebene Devices die Grundfunktionen.

        Der Parameter deviceselection kann eine einzelne
@@ -1059,7 +1124,7 @@ class RevPiModIOSelected(RevPiModIO):
        """
        super().__init__(
            autorefresh, monitoring, syncoutputs, procimg, configrsc,
-            simulator, debug, replace_io_file
+            simulator, debug, replace_io_file, direct_output
        )

        # Device liste erstellen
@@ -1114,7 +1179,7 @@ class RevPiModIODriver(RevPiModIOSelected):
    def __init__(
            self, virtdev, autorefresh=False, monitoring=False,
            syncoutputs=True, procimg=None, configrsc=None, debug=False,
-            replace_io_file=None):
+            replace_io_file=None, direct_output=False):
        """Instantiiert die Grundfunktionen.

        Parameter 'monitoring' und 'simulator' stehen hier nicht zur
@@ -1127,7 +1192,7 @@ class RevPiModIODriver(RevPiModIOSelected):
        # Parent mit monitoring=False und simulator=True laden
        super().__init__(
            virtdev, autorefresh, False, syncoutputs, procimg, configrsc,
-            True, debug, replace_io_file
+            True, debug, replace_io_file, direct_output
        )


--- a/revpimodio2/netio.py
+++ b/revpimodio2/netio.py
@@ -490,7 +490,7 @@ class RevPiNetIO(_RevPiModIO):
    def __init__(
            self, address, autorefresh=False, monitoring=False,
            syncoutputs=True, simulator=False, debug=False,
-            replace_io_file=None):
+            replace_io_file=None, direct_output=False):
        """Instantiiert die Grundfunktionen.

        @param address: IP-Adresse <class 'str'> / (IP, Port) <class 'tuple'>
@@ -500,6 +500,7 @@ class RevPiNetIO(_RevPiModIO):
        @param simulator Laedt das Modul als Simulator und vertauscht IOs
        @param debug Gibt bei allen Fehlern komplette Meldungen aus
        @param replace_io_file Replace IO Konfiguration aus Datei laden
+        @param direct_output Write outputs immediately to process image (slow)

        """
        check_ip = compile(
@@ -549,7 +550,8 @@ class RevPiNetIO(_RevPiModIO):
            None,
            simulator,
            debug,
-            replace_io_file
+            replace_io_file,
+            direct_output
        )

        # Netzwerkfilehandler anlegen
@@ -661,7 +663,7 @@ class RevPiNetIOSelected(RevPiNetIO):
    def __init__(
            self, address, deviceselection, autorefresh=False,
            monitoring=False, syncoutputs=True, simulator=False, debug=False,
-            replace_io_file=None):
+            replace_io_file=None, direct_output=False):
        """Instantiiert nur fuer angegebene Devices die Grundfunktionen.

        Der Parameter deviceselection kann eine einzelne
@@ -675,7 +677,7 @@ class RevPiNetIOSelected(RevPiNetIO):
        """
        super().__init__(
            address, autorefresh, monitoring, syncoutputs, simulator, debug,
-            replace_io_file
+            replace_io_file, direct_output
        )

        # Device liste erstellen
@@ -729,7 +731,8 @@ class RevPiNetIODriver(RevPiNetIOSelected):

    def __init__(
            self, address, virtdev, autorefresh=False, monitoring=False,
-            syncoutputs=True, debug=False, replace_io_file=None):
+            syncoutputs=True, debug=False, replace_io_file=None,
+            direct_output=False):
        """Instantiiert die Grundfunktionen.

        Parameter 'monitoring' und 'simulator' stehen hier nicht zur
@@ -743,5 +746,5 @@ class RevPiNetIODriver(RevPiNetIOSelected):
        # Parent mit monitoring=False und simulator=True laden
        super().__init__(
            address, virtdev, autorefresh, False, syncoutputs, True, debug,
-            replace_io_file
+            replace_io_file, direct_output
        )