diff options
Diffstat (limited to 'pym/portage/util')
| -rw-r--r-- | pym/portage/util/_async/PopenProcess.py | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/pym/portage/util/_async/PopenProcess.py b/pym/portage/util/_async/PopenProcess.py index 7c42c85b3..c3ae6e9db 100644 --- a/pym/portage/util/_async/PopenProcess.py +++ b/pym/portage/util/_async/PopenProcess.py @@ -5,11 +5,23 @@ from _emerge.SubProcess import SubProcess class PopenProcess(SubProcess): - __slots__ = ("proc",) + __slots__ = ("pipe_reader", "proc",) def __init__(self, **kwargs): SubProcess.__init__(self, **kwargs) self.pid = self.proc.pid + self._registered = True def _start(self): - pass + if self.pipe_reader is not None: + self.pipe_reader.addExitListener(self._pipe_reader_exit) + self.pipe_reader.start() + + def _pipe_reader_exit(self, pipe_reader): + self._reg_id = self.scheduler.child_watch_add( + self.pid, self._child_watch_cb) + + def _child_watch_cb(self, pid, condition, user_data=None): + self._reg_id = None + self._waitpid_cb(pid, condition) + self.wait() |