FM / backend

/usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend/

/usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
compat.py	995	0644	edit dl rm
compat_posix.py	334	0644	edit dl rm
compat_win32.py	1407	0644	edit dl rm
context.py	13847	0644	edit dl rm
fork_exec.py	1372	0644	edit dl rm
managers.py	1836	0644	edit dl rm
popen_loky_posix.py	7113	0644	edit dl rm
popen_loky_win32.py	5724	0644	edit dl rm
process.py	3526	0644	edit dl rm
queues.py	8990	0644	edit dl rm
reduction.py	9663	0644	edit dl rm
resource_tracker.py	14821	0644	edit dl rm
semlock.py	8918	0644	edit dl rm
spawn.py	9207	0644	edit dl rm
synchronize.py	11662	0644	edit dl rm
utils.py	5691	0644	edit dl rm
_posix_reduction.py	2223	0644	edit dl rm
_posix_wait.py	3319	0644	edit dl rm
_win_reduction.py	3724	0644	edit dl rm
_win_wait.py	1956	0644	edit dl rm
__init__.py	398	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend/fork_exec.py (1372B)

if sys.platform == "darwin" and sys.version_info < (3, 3):
    FileNotFoundError = OSError

def close_fds(keep_fds):  # pragma: no cover
    """Close all the file descriptors except those in keep_fds."""

# Make sure to keep stdout and stderr open for logging purpose
    keep_fds = set(keep_fds).union([1, 2])

# We try to retrieve all the open fds
    try:
        open_fds = set(int(fd) for fd in os.listdir('/proc/self/fd'))
    except FileNotFoundError:
        import resource
        max_nfds = resource.getrlimit(resource.RLIMIT_NOFILE)[0]
        open_fds = set(fd for fd in range(3, max_nfds))
        open_fds.add(0)

for i in open_fds - keep_fds:
        try:
            os.close(i)
        except OSError:
            pass

def fork_exec(cmd, keep_fds, env=None):

# copy the environment variables to set in the child process
    env = {} if env is None else env
    child_env = os.environ.copy()
    child_env.update(env)

pid = os.fork()
    if pid == 0:  # pragma: no cover
        close_fds(keep_fds)
        os.execve(sys.executable, cmd, child_env)
    else:
        return pid

############################################################################### # Launch a subprocess using forkexec and make sure only the needed fd are # shared in the two process. # # author: Thomas Moreau and Olivier Grisel # import os import sys if sys.platform == "darwin" and sys.version_info < (3, 3): FileNotFoundError = OSError def close_fds(keep_fds): # pragma: no cover """Close all the file descriptors except those in keep_fds.""" # Make sure to keep stdout and stderr open for logging purpose keep_fds = set(keep_fds).union([1, 2]) # We try to retrieve all the open fds try: open_fds = set(int(fd) for fd in os.listdir('/proc/self/fd')) except FileNotFoundError: import resource max_nfds = resource.getrlimit(resource.RLIMIT_NOFILE)[0] open_fds = set(fd for fd in range(3, max_nfds)) open_fds.add(0) for i in open_fds - keep_fds: try: os.close(i) except OSError: pass def fork_exec(cmd, keep_fds, env=None): # copy the environment variables to set in the child process env = {} if env is None else env child_env = os.environ.copy() child_env.update(env) pid = os.fork() if pid == 0: # pragma: no cover close_fds(keep_fds) os.execve(sys.executable, cmd, child_env) else: return pid