GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2026-01-29 09:01:54 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix socket timeout/zero based issues in tesmart (#49)

Browse Source
This commit is contained in:
David Shay
2021-05-18 06:11:05 -04:00
committed by GitHub
parent 274d609b71
commit 20c88b2170
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
kvmd/plugins/ugpio/tesmart.py
View File

@@ -80,12 +80,12 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
} }
def register_input(self, pin: int, debounce: float) -> None: def register_input(self, pin: int, debounce: float) -> None:
if not (0 < pin < 16): if not (0 <= pin < 16):
raise RuntimeError(f"Unsupported port number: {pin}") raise RuntimeError(f"Unsupported port number: {pin}")
_ = debounce _ = debounce
def register_output(self, pin: int, initial: Optional[bool]) -> None: def register_output(self, pin: int, initial: Optional[bool]) -> None:
if not (0 < pin < 16): if not (0 <= pin < 16):
raise RuntimeError(f"Unsupported port number: {pin}") raise RuntimeError(f"Unsupported port number: {pin}")
_ = initial _ = initial
@@ -112,7 +112,7 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
async def write(self, pin: int, state: bool) -> None: async def write(self, pin: int, state: bool) -> None:
if state: if state:
await self.__send_command(b"\x01%.2x" % (pin - 1)) await self.__send_command("{:c}{:c}".format(1, pin + 1).encode())
await self.__update_notifier.notify() await self.__update_notifier.notify()
await asyncio.sleep(self.__switch_delay) # Slowdown await asyncio.sleep(self.__switch_delay) # Slowdown
@@ -136,7 +136,8 @@ class Plugin(BaseUserGpioDriver): # pylint: disable=too-many-instance-attribute
try: try:
(reader, writer) = await asyncio.open_connection(self.__host, self.__port) (reader, writer) = await asyncio.open_connection(self.__host, self.__port)
sock = writer.get_extra_info("socket") sock = writer.get_extra_info("socket")
sock.settimeout(self.__timeout) # sock.settimeout(self.__timeout)
sock.settimeout(0)
except Exception as err: except Exception as err:
get_logger(0).error("Can't connect to Tesmart KVM [%s]:%d: %s", get_logger(0).error("Can't connect to Tesmart KVM [%s]:%d: %s",
self.__host, self.__port, tools.efmt(err)) self.__host, self.__port, tools.efmt(err))