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

serial: decrease common_retries with read_retries

Browse Source
This commit is contained in:
Devaev Maxim 2020-06-04 05:52:50 +03:00
parent 333908b6a1
commit be9ce4e4ff
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
kvmd/plugins/hid/serial.py
View File

@ -313,9 +313,9 @@ class Plugin(BaseHid, multiprocessing.Process): # pylint: disable=too-many-inst
def __process_request(self, tty: serial.Serial, request: bytes) -> None: # pylint: disable=too-many-branches def __process_request(self, tty: serial.Serial, request: bytes) -> None: # pylint: disable=too-many-branches
logger = get_logger() logger = get_logger()
common_error_occured = False
common_retries = self.__common_retries common_retries = self.__common_retries
read_retries = self.__read_retries read_retries = self.__read_retries
error_occured = False
while common_retries and read_retries: while common_retries and read_retries:
if not self.__noop: if not self.__noop:
@ -351,7 +351,7 @@ class Plugin(BaseHid, multiprocessing.Process): # pylint: disable=too-many-inst
self.__state_flags.update(online=True) self.__state_flags.update(online=True)
return return
elif code == 0x20: # Done elif code == 0x20: # Done
if error_occured: if common_error_occured:
logger.info("Success!") logger.info("Success!")
self.__state_flags.update(online=True) self.__state_flags.update(online=True)
return return
@ -366,9 +366,8 @@ class Plugin(BaseHid, multiprocessing.Process): # pylint: disable=too-many-inst
else: else:
logger.error("Invalid response from HID: request=%r; code=0x%x", request, code) logger.error("Invalid response from HID: request=%r; code=0x%x", request, code)
common_error_occured = True
common_retries -= 1 common_retries -= 1
error_occured = True
self.__state_flags.update(online=False) self.__state_flags.update(online=False)
if common_retries and read_retries: if common_retries and read_retries: