blob: 2fc56d2955b79bd42aaef1d6a34c8fc85d84bf2f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
# Copyright 2012 Gentoo Foundation
# Distributed under the terms of the GNU General Public License v2
from _emerge.SubProcess import SubProcess
class PopenProcess(SubProcess):
__slots__ = ("pipe_reader", "proc",)
def _start(self):
self.pid = self.proc.pid
self._registered = True
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:
pass
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()
|
