From a13c6739cab86f196fbc8a220f0d238c3544bae9 Mon Sep 17 00:00:00 2001 From: Zac Medico Date: Tue, 16 Oct 2012 10:31:34 -0700 Subject: PopenProcess: integrate PipeReader support --- pym/portage/util/_async/PopenProcess.py | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) (limited to 'pym/portage/util/_async') 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() -- cgit v1.2.3-1-g7c22