FM / billiard

/opt/imh-python/lib/python3.9/site-packages/billiard/

/opt/imh-python/lib/python3.9/site-packages/billiard

Name	Size	Mode	Actions
dummy/	-	0755	rm
__pycache__/	-	0755	rm
common.py	4140	0644	edit dl rm
compat.py	8148	0644	edit dl rm
connection.py	32647	0644	edit dl rm
context.py	13154	0644	edit dl rm
einfo.py	5064	0644	edit dl rm
exceptions.py	1272	0644	edit dl rm
forkserver.py	8282	0644	edit dl rm
heap.py	9154	0644	edit dl rm
managers.py	36757	0644	edit dl rm
pool.py	68829	0644	edit dl rm
popen_fork.py	2552	0644	edit dl rm
popen_forkserver.py	1770	0644	edit dl rm
popen_spawn_posix.py	1922	0644	edit dl rm
popen_spawn_win32.py	3543	0644	edit dl rm
process.py	11055	0644	edit dl rm
queues.py	12739	0644	edit dl rm
reduction.py	9382	0644	edit dl rm
resource_sharer.py	5299	0644	edit dl rm
semaphore_tracker.py	4846	0644	edit dl rm
sharedctypes.py	6665	0644	edit dl rm
spawn.py	11740	0644	edit dl rm
synchronize.py	12962	0644	edit dl rm
util.py	6259	0644	edit dl rm
_ext.py	872	0644	edit dl rm
_win.py	2919	0644	edit dl rm
__init__.py	1557	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/billiard/popen_fork.py (2552B)

import os
import sys
import errno

from .common import TERM_SIGNAL

__all__ = ['Popen']

#
# Start child process using fork
#

class Popen:
    method = 'fork'
    sentinel = None

def __init__(self, process_obj):
        sys.stdout.flush()
        sys.stderr.flush()
        self.returncode = None
        self._launch(process_obj)

def duplicate_for_child(self, fd):
        return fd

def poll(self, flag=os.WNOHANG):
        if self.returncode is None:
            while True:
                try:
                    pid, sts = os.waitpid(self.pid, flag)
                except OSError 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)
                else:
                    assert os.WIFEXITED(sts)
                    self.returncode = os.WEXITSTATUS(sts)
        return self.returncode

def wait(self, timeout=None):
        if self.returncode is None:
            if timeout is not None:
                from .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 terminate(self):
        if self.returncode is None:
            try:
                os.kill(self.pid, TERM_SIGNAL)
            except OSError as exc:
                if getattr(exc, 'errno', None) != errno.ESRCH:
                    if self.wait(timeout=0.1) is None:
                        raise

def _launch(self, process_obj):
        code = 1
        parent_r, child_w = os.pipe()
        self.pid = os.fork()
        if self.pid == 0:
            try:
                os.close(parent_r)
                if 'random' in sys.modules:
                    import random
                    random.seed()
                code = process_obj._bootstrap()
            finally:
                os._exit(code)
        else:
            os.close(child_w)
            self.sentinel = parent_r

def close(self):
        if self.sentinel is not None:
            try:
                os.close(self.sentinel)
            finally:
                self.sentinel = None

import os import sys import errno from .common import TERM_SIGNAL __all__ = ['Popen'] # # Start child process using fork # class Popen: method = 'fork' sentinel = None def __init__(self, process_obj): sys.stdout.flush() sys.stderr.flush() self.returncode = None self._launch(process_obj) def duplicate_for_child(self, fd): return fd def poll(self, flag=os.WNOHANG): if self.returncode is None: while True: try: pid, sts = os.waitpid(self.pid, flag) except OSError 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) else: assert os.WIFEXITED(sts) self.returncode = os.WEXITSTATUS(sts) return self.returncode def wait(self, timeout=None): if self.returncode is None: if timeout is not None: from .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 terminate(self): if self.returncode is None: try: os.kill(self.pid, TERM_SIGNAL) except OSError as exc: if getattr(exc, 'errno', None) != errno.ESRCH: if self.wait(timeout=0.1) is None: raise def _launch(self, process_obj): code = 1 parent_r, child_w = os.pipe() self.pid = os.fork() if self.pid == 0: try: os.close(parent_r) if 'random' in sys.modules: import random random.seed() code = process_obj._bootstrap() finally: os._exit(code) else: os.close(child_w) self.sentinel = parent_r def close(self): if self.sentinel is not None: try: os.close(self.sentinel) finally: self.sentinel = None