Lines Matching refs:self
34 def __init__(self):
35 self._forkserver_address = None
36 self._forkserver_alive_fd = None
37 self._forkserver_pid = None
38 self._inherited_fds = None
39 self._lock = threading.Lock()
40 self._preload_modules = ['__main__']
42 def _stop(self):
44 with self._lock:
45 self._stop_unlocked()
47 def _stop_unlocked(self):
48 if self._forkserver_pid is None:
52 os.close(self._forkserver_alive_fd)
53 self._forkserver_alive_fd = None
55 os.waitpid(self._forkserver_pid, 0)
56 self._forkserver_pid = None
58 if not util.is_abstract_socket_namespace(self._forkserver_address):
59 os.unlink(self._forkserver_address)
60 self._forkserver_address = None
62 def set_forkserver_preload(self, modules_names):
64 if not all(type(mod) is str for mod in self._preload_modules):
66 self._preload_modules = modules_names
68 def get_inherited_fds(self):
74 return self._inherited_fds
76 def connect_to_new_process(self, fds):
84 self.ensure_running()
88 client.connect(self._forkserver_address)
91 allfds = [child_r, child_w, self._forkserver_alive_fd,
105 def ensure_running(self):
112 with self._lock:
114 if self._forkserver_pid is not None:
116 pid, status = os.waitpid(self._forkserver_pid, os.WNOHANG)
121 os.close(self._forkserver_alive_fd)
122 self._forkserver_address = None
123 self._forkserver_alive_fd = None
124 self._forkserver_pid = None
129 if self._preload_modules:
148 cmd %= (listener.fileno(), alive_r, self._preload_modules,
159 self._forkserver_address = address
160 self._forkserver_alive_fd = alive_w
161 self._forkserver_pid = pid