OXIESEC PANEL
- Current Dir:
/
/
snap
/
core
/
17200
/
usr
/
lib
/
python3.5
/
multiprocessing
Server IP: 139.59.38.164
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
__init__.py
923 bytes
11/22/2023 03:35:02 PM
rw-r--r--
📁
__pycache__
-
02/18/2024 07:58:21 PM
rwxr-xr-x
📄
connection.py
30.13 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
context.py
10.42 KB
11/22/2023 03:35:02 PM
rw-r--r--
📁
dummy
-
02/18/2024 07:58:20 PM
rwxr-xr-x
📄
forkserver.py
7.78 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
heap.py
8.13 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
managers.py
35.12 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
pool.py
24.14 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
popen_fork.py
2.27 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
popen_forkserver.py
1.92 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
popen_spawn_posix.py
1.87 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
popen_spawn_win32.py
2.93 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
process.py
8.75 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
queues.py
10.9 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
reduction.py
7.92 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
resource_sharer.py
5.19 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
semaphore_tracker.py
4.71 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
sharedctypes.py
6.08 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
spawn.py
8.64 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
synchronize.py
11.77 KB
11/22/2023 03:35:02 PM
rw-r--r--
📄
util.py
10.99 KB
11/22/2023 03:35:02 PM
rw-r--r--
Editing: popen_forkserver.py
Close
import io import os from . import reduction if not reduction.HAVE_SEND_HANDLE: raise ImportError('No support for sending fds between processes') from . import context from . import forkserver from . import popen_fork from . import spawn from . import util __all__ = ['Popen'] # # Wrapper for an fd used while launching a process # class _DupFd(object): 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) util.Finalize(self, os.close, (self.sentinel,)) with 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 multiprocessing.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