diff options
| author | Zac Medico <zmedico@gentoo.org> | 2012-10-17 18:23:11 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2012-10-17 18:23:11 -0700 |
| commit | b0d85ce135496bb241d2d5714ac330710dfa0b72 (patch) | |
| tree | 550b2e07d43a88d228b419209b5f7d04537fcf2e /pym/portage/util/_async | |
| parent | 56d2d7554ecd8dcae3d42c0862d1c3bb1cc08186 (diff) | |
| download | portage-b0d85ce135496bb241d2d5714ac330710dfa0b72.tar.gz portage-b0d85ce135496bb241d2d5714ac330710dfa0b72.tar.bz2 portage-b0d85ce135496bb241d2d5714ac330710dfa0b72.zip | |
PopenProcess: child_watch_add if no pipe_reader
Diffstat (limited to 'pym/portage/util/_async')
| -rw-r--r-- | pym/portage/util/_async/PopenProcess.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/pym/portage/util/_async/PopenProcess.py b/pym/portage/util/_async/PopenProcess.py index 37d32f260..2fc56d295 100644 --- a/pym/portage/util/_async/PopenProcess.py +++ b/pym/portage/util/_async/PopenProcess.py @@ -7,13 +7,15 @@ class PopenProcess(SubProcess): __slots__ = ("pipe_reader", "proc",) - def __init__(self, **kwargs): - SubProcess.__init__(self, **kwargs) + def _start(self): + self.pid = self.proc.pid self._registered = True - def _start(self): - if self.pipe_reader is not None: + if self.pipe_reader is None: + self._reg_id = self.scheduler.child_watch_add( + self.pid, self._child_watch_cb) + else: try: self.pipe_reader.scheduler = self.scheduler except AttributeError: |