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

refactoring

Browse Source
This commit is contained in:
Devaev Maxim 2020-10-09 11:58:19 +03:00
parent 5bfde6ceae
commit cf5bc84872
2 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
kvmd/aioproc.py
View File

@ -23,6 +23,7 @@
import asyncio
import asyncio.subprocess
import signal
import logging
from typing import Tuple
from typing import List
@ -46,6 +47,15 @@ async def read_process(cmd: List[str], err_to_null: bool=False) -> Tuple[asyncio
return (proc, stdout.decode(errors="ignore").strip())
async def log_process(cmd: List[str], logger: logging.Logger) -> asyncio.subprocess.Process: # pylint: disable=no-member
(proc, stdout) = await read_process(cmd)
if stdout:
log = (logger.info if proc.returncode == 0 else logger.error)
for line in stdout.split("\n"):
log("Console: %s", line)
return proc
def ignore_sigint() -> None:
signal.signal(signal.SIGINT, signal.SIG_IGN)

9
kvmd/plugins/msd/otg/helpers.py
View File

@ -59,13 +59,6 @@ async def unlock_drive(base_cmd: List[str]) -> None:
async def _run_helper(cmd: List[str]) -> None:
logger = get_logger(0)
logger.info("Executing helper %s ...", cmd)
(proc, stdout) = await aioproc.read_process(cmd)
if stdout:
log = (logger.info if proc.returncode == 0 else logger.error)
for line in stdout.split("\n"):
log("Console: %s", line)
proc = await aioproc.log_process(cmd, logger)
if proc.returncode != 0:
raise MsdError(f"Error while helper execution: pid={proc.pid}; retcode={proc.returncode}")