diff options
author | Maxim Devaev <[email protected]> | 2021-09-07 08:55:49 +0300 |
---|---|---|
committer | Maxim Devaev <[email protected]> | 2021-09-07 10:31:28 +0300 |
commit | cc5b2a42b8acbaa3bc62a8a1850370f19a44d392 (patch) | |
tree | 9c43b7dbdce2309c555002278d2f78eb5fe3a626 /kvmd/plugins | |
parent | ce5cd50d51797ac9ba642bf70aa5e36b4997cbe4 (diff) |
refactoring
Diffstat (limited to 'kvmd/plugins')
-rw-r--r-- | kvmd/plugins/ugpio/__init__.py | 12 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/ezcoo.py | 8 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/ipmi.py | 3 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/otgbind.py | 13 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/pwm.py | 3 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/tesmart.py | 3 | ||||
-rw-r--r-- | kvmd/plugins/ugpio/wol.py | 17 |
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 |