This commit is contained in:
Richard Oudkerk 2013-02-26 13:00:15 +00:00
commit 5b8a3242c4
3 changed files with 46 additions and 6 deletions

View file

@ -10,6 +10,7 @@
import os
import sys
import signal
import errno
from multiprocessing import util, process
@ -109,12 +110,17 @@ if sys.platform != 'win32':
def poll(self, flag=os.WNOHANG):
if self.returncode is None:
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
while True:
try:
pid, sts = os.waitpid(self.pid, flag)
except os.error as e:
if e.errno == errno.EINTR:
continue
# Child process not yet created. See #1731717
# e.errno == errno.ECHILD == 10
return None
else:
break
if pid == self.pid:
if os.WIFSIGNALED(sts):
self.returncode = -os.WTERMSIG(sts)