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

gpio read is very fast

Browse Source
This commit is contained in:
Devaev Maxim 2020-09-05 08:29:25 +03:00
parent 0c85248987
commit e162d84d56
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
kvmd/apps/kvmd/ugpio.py
View File

@ -66,6 +66,7 @@ class _GpioInput:
self.__channel = channel
self.__pin: int = config.pin # gpio.set_input(config.pin) # Configured in UserGpio/BatchReader
self.__inverted: bool = config.inverted
self.__reader = reader
def get_scheme(self) -> Dict:
@ -85,13 +86,15 @@ class _GpioOutput: # pylint: disable=too-many-instance-attributes
self.__channel = channel
self.__pin: int = gpio.set_output(config.pin, (config.initial ^ config.inverted))
self.__inverted: bool = config.inverted
self.__switch: bool = config.switch
self.__pulse_delay: float = config.pulse.delay
self.__min_pulse_delay: float = config.pulse.min_delay
self.__max_pulse_delay: float = config.pulse.max_delay
self.__busy_delay: float = config.busy_delay
self.__state = config.initial
self.__region = aiotools.AioExclusiveRegion(GpioChannelIsBusyError, notifier)
def get_scheme(self) -> Dict:
@ -107,7 +110,7 @@ class _GpioOutput: # pylint: disable=too-many-instance-attributes
def get_state(self) -> Dict:
busy = self.__region.is_busy()
return {
"state": (self.__state if not busy else False),
"state": (self.__read() if not busy else False),
"busy": busy,
}
@ -121,15 +124,11 @@ class _GpioOutput: # pylint: disable=too-many-instance-attributes
if not self.__switch:
raise GpioSwitchNotSupported()
async with self.__region:
# Состояние проверяется только при изменении
real_state = self.__read()
if state != real_state:
if state != self.__read():
self.__write(state)
self.__state = state
get_logger(0).info("Switched %s to %d", self, state)
await asyncio.sleep(self.__busy_delay)
return True
self.__state = real_state
await asyncio.sleep(self.__busy_delay)
return False