[Python-checkins] r78798 - in python/branches/py3k: Lib/multiprocessing/forking.py Lib/multiprocessing/pool.py
florent.xicluna
python-checkins at python.org
Mon Mar 8 14:32:18 CET 2010
Author: florent.xicluna
Date: Mon Mar 8 14:32:17 2010
New Revision: 78798
Log:
Merged revisions 78777,78787,78790 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/trunk
........
r78777 | florent.xicluna | 2010-03-08 00:49:03 +0100 (lun, 08 mar 2010) | 4 lines
Backport the Popen.poll() protection from subprocess to multiprocessing. See #1731717.
It should fix transient failures on test_multiprocessing.
........
r78787 | florent.xicluna | 2010-03-08 08:21:16 +0100 (lun, 08 mar 2010) | 2 lines
Don't fail on a debug() statement, if the worker PID is (still) None.
........
r78790 | florent.xicluna | 2010-03-08 12:01:39 +0100 (lun, 08 mar 2010) | 2 lines
On finalize, don't try to join not started process.
........
Modified:
python/branches/py3k/ (props changed)
python/branches/py3k/Lib/multiprocessing/forking.py
python/branches/py3k/Lib/multiprocessing/pool.py
Modified: python/branches/py3k/Lib/multiprocessing/forking.py
==============================================================================
--- python/branches/py3k/Lib/multiprocessing/forking.py (original)
+++ python/branches/py3k/Lib/multiprocessing/forking.py Mon Mar 8 14:32:17 2010
@@ -104,7 +104,12 @@
def poll(self, flag=os.WNOHANG):
if self.returncode is None:
- pid, sts = os.waitpid(self.pid, flag)
+ try:
+ pid, sts = os.waitpid(self.pid, flag)
+ except os.error:
+ # Child process not yet created. See #1731717
+ # e.errno == errno.ECHILD == 10
+ return None
if pid == self.pid:
if os.WIFSIGNALED(sts):
self.returncode = -os.WTERMSIG(sts)
Modified: python/branches/py3k/Lib/multiprocessing/pool.py
==============================================================================
--- python/branches/py3k/Lib/multiprocessing/pool.py (original)
+++ python/branches/py3k/Lib/multiprocessing/pool.py Mon Mar 8 14:32:17 2010
@@ -448,12 +448,10 @@
if pool and hasattr(pool[0], 'terminate'):
debug('joining pool workers')
for p in pool:
- p.join()
- for w in pool:
- if w.exitcode is None:
+ if p.is_alive():
# worker has not yet exited
- debug('cleaning up worker %d' % w.pid)
- w.join()
+ debug('cleaning up worker %d' % p.pid)
+ p.join()
#
# Class whose instances are returned by `Pool.apply_async()`
More information about the Python-checkins
mailing list