Git-Mirrors/rnsh
1
0
Fork 0
mirror of https://github.com/markqvist/rnsh.git synced 2025-01-05 20:30:53 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Keep a copy of child return code.

Browse Source
This commit is contained in:
Aaron Heise 2023-02-09 15:44:22 -06:00
parent feeb60d249
commit 9186a64962
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
rnsh/process.py
View File

@ -174,6 +174,7 @@ class CallbackSubprocess:
self._terminated_cb = terminated_callback
self._pid: int | None = None
self._child_fd: int | None = None
self._return_code: int | None = None
def terminate(self, kill_delay: float = 1.0):
"""
@ -287,10 +288,10 @@ class CallbackSubprocess:
def poll():
# self.log.debug("poll")
try:
pid, rc = os.waitpid(self._pid, os.WNOHANG)
if rc is not None and not process_exists(self._pid):
self.log.debug(f"polled return code {rc}")
self._terminated_cb(rc)
pid, self._return_code = os.waitpid(self._pid, os.WNOHANG)
if self._return_code is not None and not process_exists(self._pid):
self.log.debug(f"polled return code {self._return_code}")
self._terminated_cb(self._return_code)
self._loop.call_later(CallbackSubprocess.PROCESS_POLL_TIME, poll)
except Exception as e:
self.log.debug(f"Error in process poll: {e}")
@ -307,6 +308,10 @@ class CallbackSubprocess:
tty_add_reader_callback(self._child_fd, functools.partial(reader, self._child_fd, self._stdout_cb), self._loop)
@property
def return_code(self) -> int | None:
return self._return_code
async def main():
"""
A test driver for the CallbackProcess class.