summaryrefslogtreecommitdiff
path: root/kvmd/plugins
diff options
context:
space:
mode:
authorMaxim Devaev <[email protected]>2021-09-07 08:55:49 +0300
committerMaxim Devaev <[email protected]>2021-09-07 10:31:28 +0300
commitcc5b2a42b8acbaa3bc62a8a1850370f19a44d392 (patch)
tree9c43b7dbdce2309c555002278d2f78eb5fe3a626 /kvmd/plugins
parentce5cd50d51797ac9ba642bf70aa5e36b4997cbe4 (diff)
refactoring
Diffstat (limited to 'kvmd/plugins')
-rw-r--r--kvmd/plugins/ugpio/__init__.py12
-rw-r--r--kvmd/plugins/ugpio/ezcoo.py8
-rw-r--r--kvmd/plugins/ugpio/ipmi.py3
-rw-r--r--kvmd/plugins/ugpio/otgbind.py13
-rw-r--r--kvmd/plugins/ugpio/pwm.py3
-rw-r--r--kvmd/plugins/ugpio/tesmart.py3
-rw-r--r--kvmd/plugins/ugpio/wol.py17
7 files changed, 7 insertions, 52 deletions
diff --git a/kvmd/plugins/ugpio/__init__.py b/kvmd/plugins/ugpio/__init__.py
index e2f5943e..eae65891 100644
--- a/kvmd/plugins/ugpio/__init__.py
+++ b/kvmd/plugins/ugpio/__init__.py
@@ -75,19 +75,21 @@ class BaseUserGpioDriver(BasePlugin):
return set(UserGpioModes.ALL)
def register_input(self, pin: int, debounce: float) -> None:
- raise NotImplementedError
+ _ = pin
+ _ = debounce
def register_output(self, pin: int, initial: Optional[bool]) -> None:
- raise NotImplementedError
+ _ = pin
+ _ = initial
def prepare(self) -> None:
- raise NotImplementedError
+ pass
async def run(self) -> None:
- raise NotImplementedError
+ await aiotools.wait_infinite()
async def cleanup(self) -> None:
- raise NotImplementedError
+ pass
async def read(self, pin: int) -> bool:
raise NotImplementedError
diff --git a/kvmd/plugins/ugpio/ezcoo.py b/kvmd/plugins/ugpio/ezcoo.py
index 6a19445c..81e199e8 100644
--- a/kvmd/plugins/ugpio/ezcoo.py
+++ b/kvmd/plugins/ugpio/ezcoo.py
@@ -85,14 +85,6 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
"protocol": Option(1, type=functools.partial(valid_number, min=1, max=2)),
}
- def register_input(self, pin: int, debounce: float) -> None:
- _ = pin
- _ = debounce
-
- def register_output(self, pin: int, initial: Optional[bool]) -> None:
- _ = pin
- _ = initial
-
def prepare(self) -> None:
assert self.__proc is None
self.__proc = multiprocessing.Process(target=self.__serial_worker, daemon=True)
diff --git a/kvmd/plugins/ugpio/ipmi.py b/kvmd/plugins/ugpio/ipmi.py
index 9ff33da4..26ea9dbb 100644
--- a/kvmd/plugins/ugpio/ipmi.py
+++ b/kvmd/plugins/ugpio/ipmi.py
@@ -131,9 +131,6 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
prev = new
await asyncio.sleep(self.__state_poll)
- async def cleanup(self) -> None:
- pass
-
async def read(self, pin: int) -> bool:
if not self.__online:
raise GpioDriverOfflineError(self)
diff --git a/kvmd/plugins/ugpio/otgbind.py b/kvmd/plugins/ugpio/otgbind.py
index de8ed5b6..6dec46c9 100644
--- a/kvmd/plugins/ugpio/otgbind.py
+++ b/kvmd/plugins/ugpio/otgbind.py
@@ -23,8 +23,6 @@
import os
import asyncio
-from typing import Optional
-
from ...logging import get_logger
from ...inotify import InotifyMask
@@ -52,14 +50,6 @@ class Plugin(BaseUserGpioDriver):
self.__udc = udc
self.__driver = ""
- def register_input(self, pin: int, debounce: float) -> None:
- _ = pin
- _ = debounce
-
- def register_output(self, pin: int, initial: Optional[bool]) -> None:
- _ = pin
- _ = initial
-
def prepare(self) -> None:
(self.__udc, self.__driver) = usb.find_udc(self.__udc)
get_logger().info("Using UDC %s", self.__udc)
@@ -93,9 +83,6 @@ class Plugin(BaseUserGpioDriver):
except Exception:
logger.exception("Unexpected OTG-bind watcher error")
- async def cleanup(self) -> None:
- pass
-
async def read(self, pin: int) -> bool:
_ = pin
return os.path.islink(self.__get_driver_path(self.__udc))
diff --git a/kvmd/plugins/ugpio/pwm.py b/kvmd/plugins/ugpio/pwm.py
index 92989049..582bbb50 100644
--- a/kvmd/plugins/ugpio/pwm.py
+++ b/kvmd/plugins/ugpio/pwm.py
@@ -97,9 +97,6 @@ class Plugin(BaseUserGpioDriver):
logger.error("Can't get PWM chip %d channel %d: %s",
self.__chip, pin, tools.efmt(err))
- async def run(self) -> None:
- await aiotools.wait_infinite()
-
async def cleanup(self) -> None:
for (pin, pwm) in self.__pwms.items():
try:
diff --git a/kvmd/plugins/ugpio/tesmart.py b/kvmd/plugins/ugpio/tesmart.py
index 310510d3..7fbd37db 100644
--- a/kvmd/plugins/ugpio/tesmart.py
+++ b/kvmd/plugins/ugpio/tesmart.py
@@ -89,9 +89,6 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
raise RuntimeError(f"Unsupported port number: {pin}")
_ = initial
- def prepare(self) -> None:
- pass
-
async def run(self) -> None:
prev_active = -2
while True:
diff --git a/kvmd/plugins/ugpio/wol.py b/kvmd/plugins/ugpio/wol.py
index 02eb9a8c..842ebd47 100644
--- a/kvmd/plugins/ugpio/wol.py
+++ b/kvmd/plugins/ugpio/wol.py
@@ -66,23 +66,6 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
"mac": Option("", type=valid_mac, if_empty=""),
}
- def register_input(self, pin: int, debounce: float) -> None:
- _ = pin
- _ = debounce
-
- def register_output(self, pin: int, initial: Optional[bool]) -> None:
- _ = pin
- _ = initial
-
- def prepare(self) -> None:
- get_logger(0).info("Probing driver %s on MAC %s and %s:%d ...", self, self.__mac, self.__ip, self.__port)
-
- async def run(self) -> None:
- await aiotools.wait_infinite()
-
- async def cleanup(self) -> None:
- pass
-
async def read(self, pin: int) -> bool:
_ = pin
return False