async gpio plugins

5 files changed, 10 insertions, 10 deletions

diff --git a/kvmd/plugins/ugpio/__init__.py b/kvmd/plugins/ugpio/__init__.py
index a3e24851..2a172c63 100644
--- a/kvmd/plugins/ugpio/__init__.py
+++ b/kvmd/plugins/ugpio/__init__.py
@@ -89,10 +89,10 @@ class BaseUserGpioDriver(BasePlugin):
     def cleanup(self) -> None:
         raise NotImplementedError
 
-    def read(self, pin: int) -> bool:
+    async def read(self, pin: int) -> bool:
         raise NotImplementedError
 
-    def write(self, pin: int, state: bool) -> None:
+    async def write(self, pin: int, state: bool) -> None:
         raise NotImplementedError
 
 
diff --git a/kvmd/plugins/ugpio/ezcoo.py b/kvmd/plugins/ugpio/ezcoo.py
index 04cb1c43..0605e54c 100644
--- a/kvmd/plugins/ugpio/ezcoo.py
+++ b/kvmd/plugins/ugpio/ezcoo.py
@@ -108,12 +108,12 @@ class Plugin(BaseUserGpioDriver):  # pylint: disable=too-many-instance-attribute
             if self.__proc.exitcode is not None:
                 self.__proc.join()
 
-    def read(self, pin: int) -> bool:
+    async def read(self, pin: int) -> bool:
         if not self.__is_online():
             raise GpioDriverOfflineError(self)
         return (self.__channel == pin)
 
-    def write(self, pin: int, state: bool) -> None:
+    async def write(self, pin: int, state: bool) -> None:
         if not self.__is_online():
             raise GpioDriverOfflineError(self)
         if state and (0 <= pin <= 3):
diff --git a/kvmd/plugins/ugpio/gpio.py b/kvmd/plugins/ugpio/gpio.py
index 06b4f6f1..646809ae 100644
--- a/kvmd/plugins/ugpio/gpio.py
+++ b/kvmd/plugins/ugpio/gpio.py
@@ -95,13 +95,13 @@ class Plugin(BaseUserGpioDriver):
             except Exception:
                 pass
 
-    def read(self, pin: int) -> bool:
+    async def read(self, pin: int) -> bool:
         assert self.__reader
         if pin in self.__input_pins:
             return self.__reader.get(pin)
         return bool(self.__output_lines[pin].get_value())
 
-    def write(self, pin: int, state: bool) -> None:
+    async def write(self, pin: int, state: bool) -> None:
         self.__output_lines[pin].set_value(int(state))
 
     def __str__(self) -> str:
diff --git a/kvmd/plugins/ugpio/hidrelay.py b/kvmd/plugins/ugpio/hidrelay.py
index e17e513f..119c4ee5 100644
--- a/kvmd/plugins/ugpio/hidrelay.py
+++ b/kvmd/plugins/ugpio/hidrelay.py
@@ -113,13 +113,13 @@ class Plugin(BaseUserGpioDriver):
         self.__close_device()
         self.__stop = True
 
-    def read(self, pin: int) -> bool:
+    async def read(self, pin: int) -> bool:
         try:
             return self.__inner_read(pin)
         except Exception:
             raise GpioDriverOfflineError(self)
 
-    def write(self, pin: int, state: bool) -> None:
+    async def write(self, pin: int, state: bool) -> None:
         try:
             return self.__inner_write(pin, state)
         except Exception:
diff --git a/kvmd/plugins/ugpio/otgbind.py b/kvmd/plugins/ugpio/otgbind.py
index cff2d912..dbf3b421 100644
--- a/kvmd/plugins/ugpio/otgbind.py
+++ b/kvmd/plugins/ugpio/otgbind.py
@@ -100,11 +100,11 @@ class Plugin(BaseUserGpioDriver):
     def cleanup(self) -> None:
         pass
 
-    def read(self, pin: int) -> bool:
+    async def read(self, pin: int) -> bool:
         _ = pin
         return os.path.islink(self.__get_driver_path(self.__udc))
 
-    def write(self, pin: int, state: bool) -> None:
+    async def write(self, pin: int, state: bool) -> None:
         _ = pin
         with open(self.__get_driver_path("bind" if state else "unbind"), "w") as ctl_file:
             ctl_file.write(f"{self.__udc}\n")