GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2025-12-12 09:10:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

using BatchReader for ATX

Browse Source
This commit is contained in:
Devaev Maxim 2020-09-05 12:23:39 +03:00
parent 482eeec3e7
commit a06a1e40f4
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
kvmd/plugins/atx/gpio.py
View File

@ -71,9 +71,14 @@ class Plugin(BaseAtx): # pylint: disable=too-many-instance-attributes
self.__click_delay = click_delay self.__click_delay = click_delay
self.__long_click_delay = long_click_delay self.__long_click_delay = long_click_delay
self.__state_poll = state_poll self.__state_notifier = aiotools.AioNotifier()
self.__region = aiotools.AioExclusiveRegion(AtxIsBusyError, self.__state_notifier)
self.__region = aiotools.AioExclusiveRegion(AtxIsBusyError) self.__reader = gpio.BatchReader(
pins=[self.__power_led_pin, self.__hdd_led_pin],
interval=state_poll,
notifier=self.__state_notifier,
)
@classmethod @classmethod
def get_plugin_options(cls) -> Dict: def get_plugin_options(cls) -> Dict:
@ -96,8 +101,8 @@ class Plugin(BaseAtx): # pylint: disable=too-many-instance-attributes
"enabled": True, "enabled": True,
"busy": self.__region.is_busy(), "busy": self.__region.is_busy(),
"leds": { "leds": {
"power": (gpio.read(self.__power_led_pin) ^ self.__power_led_inverted), "power": (self.__reader.get(self.__power_led_pin) ^ self.__power_led_inverted),
"hdd": (gpio.read(self.__hdd_led_pin) ^ self.__hdd_led_inverted), "hdd": (self.__reader.get(self.__hdd_led_pin) ^ self.__hdd_led_inverted),
}, },
} }
@ -108,7 +113,10 @@ class Plugin(BaseAtx): # pylint: disable=too-many-instance-attributes
if state != prev_state: if state != prev_state:
yield state yield state
prev_state = state prev_state = state
await asyncio.sleep(self.__state_poll) await self.__state_notifier.wait()
async def systask(self) -> None:
await self.__reader.poll()
async def cleanup(self) -> None: async def cleanup(self) -> None:
for (name, pin) in [ for (name, pin) in [