Spaces:
Build error
Build error
| import os | |
| import signal | |
| from . import util | |
| __all__ = ['Popen'] | |
| # | |
| # Start child process using fork | |
| # | |
| class Popen(object): | |
| method = 'fork' | |
| def __init__(self, process_obj): | |
| util._flush_std_streams() | |
| self.returncode = None | |
| self.finalizer = None | |
| self._launch(process_obj) | |
| def duplicate_for_child(self, fd): | |
| return fd | |
| def poll(self, flag=os.WNOHANG): | |
| if self.returncode is None: | |
| try: | |
| pid, sts = os.waitpid(self.pid, flag) | |
| except OSError: | |
| # Child process not yet created. See #1731717 | |
| # e.errno == errno.ECHILD == 10 | |
| return None | |
| if pid == self.pid: | |
| self.returncode = os.waitstatus_to_exitcode(sts) | |
| return self.returncode | |
| def wait(self, timeout=None): | |
| if self.returncode is None: | |
| if timeout is not None: | |
| from multiprocessing.connection import wait | |
| if not wait([self.sentinel], timeout): | |
| return None | |
| # This shouldn't block if wait() returned successfully. | |
| return self.poll(os.WNOHANG if timeout == 0.0 else 0) | |
| return self.returncode | |
| def _send_signal(self, sig): | |
| if self.returncode is None: | |
| try: | |
| os.kill(self.pid, sig) | |
| except ProcessLookupError: | |
| pass | |
| except OSError: | |
| if self.wait(timeout=0.1) is None: | |
| raise | |
| def terminate(self): | |
| self._send_signal(signal.SIGTERM) | |
| def kill(self): | |
| self._send_signal(signal.SIGKILL) | |
| def _launch(self, process_obj): | |
| code = 1 | |
| parent_r, child_w = os.pipe() | |
| child_r, parent_w = os.pipe() | |
| self.pid = os.fork() | |
| if self.pid == 0: | |
| try: | |
| os.close(parent_r) | |
| os.close(parent_w) | |
| code = process_obj._bootstrap(parent_sentinel=child_r) | |
| finally: | |
| os._exit(code) | |
| else: | |
| os.close(child_w) | |
| os.close(child_r) | |
| self.finalizer = util.Finalize(self, util.close_fds, | |
| (parent_r, parent_w,)) | |
| self.sentinel = parent_r | |
| def close(self): | |
| if self.finalizer is not None: | |
| self.finalizer() | |