FileMgr

✏️ /usr/local/lib/python3.9/site-packages/billiard/popen_forkserver.py

✕ Tutup

import io
import os

from . import reduction
from . import context
from . import forkserver
from . import popen_fork
from . import spawn

__all__ = ['Popen']

#
# Wrapper for an fd used while launching a process
#

class _DupFd:

def __init__(self, ind):
        self.ind = ind

def detach(self):
        return forkserver.get_inherited_fds()[self.ind]

#
# Start child process using a server process
#

class Popen(popen_fork.Popen):
    method = 'forkserver'
    DupFd = _DupFd

def __init__(self, process_obj):
        self._fds = []
        super().__init__(process_obj)

def duplicate_for_child(self, fd):
        self._fds.append(fd)
        return len(self._fds) - 1

def _launch(self, process_obj):
        prep_data = spawn.get_preparation_data(process_obj._name)
        buf = io.BytesIO()
        context.set_spawning_popen(self)
        try:
            reduction.dump(prep_data, buf)
            reduction.dump(process_obj, buf)
        finally:
            context.set_spawning_popen(None)

self.sentinel, w = forkserver.connect_to_new_process(self._fds)
        with io.open(w, 'wb', closefd=True) as f:
            f.write(buf.getbuffer())
        self.pid = forkserver.read_unsigned(self.sentinel)

def poll(self, flag=os.WNOHANG):
        if self.returncode is None:
            from .connection import wait
            timeout = 0 if flag == os.WNOHANG else None
            if not wait([self.sentinel], timeout):
                return None
            try:
                self.returncode = forkserver.read_unsigned(self.sentinel)
            except (OSError, EOFError):
                # The process ended abnormally perhaps because of a signal
                self.returncode = 255
        return self.returncode

Batal

⬅ site-packages 28 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📁 __pycache__	dir	—	08/05/25 20:25	0755	📂
📁 dummy	dir	—	08/05/25 20:25	0755	📂
🐍 __init__.py	py	1.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 _ext.py	py	872 B	08/05/25 20:25	0644	✏️ ⬇
🐍 _win.py	py	2.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 common.py	py	4 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 compat.py	py	8 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 connection.py	py	31.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 context.py	py	12.8 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 einfo.py	py	4.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 exceptions.py	py	1.2 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 forkserver.py	py	8.1 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 heap.py	py	8.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 managers.py	py	35.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 pool.py	py	67.2 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 popen_fork.py	py	2.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 popen_forkserver.py	py	1.7 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 popen_spawn_posix.py	py	1.9 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 popen_spawn_win32.py	py	3.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 process.py	py	10.8 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 queues.py	py	12.4 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 reduction.py	py	9.2 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 resource_sharer.py	py	5.2 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 semaphore_tracker.py	py	4.7 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 sharedctypes.py	py	6.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 spawn.py	py	11.5 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 synchronize.py	py	12.7 KB	08/05/25 20:25	0644	✏️ ⬇
🐍 util.py	py	6.1 KB	08/05/25 20:25	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission