diff options
author | Zac Medico <zmedico@gentoo.org> | 2011-12-15 18:02:32 -0800 |
---|---|---|
committer | Zac Medico <zmedico@gentoo.org> | 2011-12-15 18:02:32 -0800 |
commit | 30d2d0a9db486c5a70848ad5d27b37a3ec48f271 (patch) | |
tree | 41a00a4003a65dce79b426bf444ea16d0494367c /pym/_emerge/SpawnProcess.py | |
parent | 915348ce34fc499ac295b8f0ffee9f0829803542 (diff) | |
download | portage-30d2d0a9db486c5a70848ad5d27b37a3ec48f271.tar.gz portage-30d2d0a9db486c5a70848ad5d27b37a3ec48f271.tar.bz2 portage-30d2d0a9db486c5a70848ad5d27b37a3ec48f271.zip |
SpawnProcess: work around array.fromfile() bugs
When I extended test_poll to test SpawnProcess array.fromfile() usage,
it exposed bugs in array.fromfile() that I couldn't find a way to
handle. So, use os.read() instead.
Diffstat (limited to 'pym/_emerge/SpawnProcess.py')
-rw-r--r-- | pym/_emerge/SpawnProcess.py | 31 |
1 files changed, 20 insertions, 11 deletions
diff --git a/pym/_emerge/SpawnProcess.py b/pym/_emerge/SpawnProcess.py index 84493fe42..c2f492873 100644 --- a/pym/_emerge/SpawnProcess.py +++ b/pym/_emerge/SpawnProcess.py @@ -165,11 +165,20 @@ class SpawnProcess(SubProcess): def _output_handler(self, fd, event): files = self._files - buf = self._read_buf(files.process, event) + while True: + buf = self._read_buf(fd, event) - if buf is not None: + if buf is None: + # not a POLLIN event, EAGAIN, etc... + break - if buf: + if not buf: + # EOF + self._unregister() + self.wait() + break + + else: if not self.background: write_successful = False failures = 0 @@ -217,9 +226,6 @@ class SpawnProcess(SubProcess): data = buf.tostring() files.log.write(data) files.log.flush() - else: - self._unregister() - self.wait() self._unregister_if_appropriate(event) @@ -230,15 +236,18 @@ class SpawnProcess(SubProcess): monitor the process from inside a poll() loop. """ - buf = self._read_buf(self._files.process, event) + while True: + buf = self._read_buf(fd, event) - if buf is not None: + if buf is None: + # not a POLLIN event, EAGAIN, etc... + break - if buf: - pass - else: + if not buf: + # EOF self._unregister() self.wait() + break self._unregister_if_appropriate(event) |