Name	Size	Mode	Actions
connection.cpython-38.opt-1.pyc	25013	0644	editdlrm
connection.cpython-38.opt-2.pyc	23014	0644	editdlrm
connection.cpython-38.pyc	25249	0644	editdlrm
context.cpython-38.opt-1.pyc	13033	0644	editdlrm
context.cpython-38.opt-2.pyc	11573	0644	editdlrm
context.cpython-38.pyc	13033	0644	editdlrm
forkserver.cpython-38.opt-1.pyc	8328	0644	editdlrm
forkserver.cpython-38.opt-2.pyc	7541	0644	editdlrm
forkserver.cpython-38.pyc	8374	0644	editdlrm
heap.cpython-38.opt-1.pyc	7626	0644	editdlrm
heap.cpython-38.opt-2.pyc	7446	0644	editdlrm
heap.cpython-38.pyc	7652	0644	editdlrm
managers.cpython-38.opt-1.pyc	41350	0644	editdlrm
managers.cpython-38.opt-2.pyc	37373	0644	editdlrm
managers.cpython-38.pyc	41561	0644	editdlrm
pool.cpython-38.opt-1.pyc	24990	0644	editdlrm
pool.cpython-38.opt-2.pyc	23122	0644	editdlrm
pool.cpython-38.pyc	25040	0644	editdlrm
popen_fork.cpython-38.opt-1.pyc	2584	0644	editdlrm
popen_fork.cpython-38.opt-2.pyc	2584	0644	editdlrm
popen_fork.cpython-38.pyc	2659	0644	editdlrm
popen_forkserver.cpython-38.opt-1.pyc	2432	0644	editdlrm
popen_forkserver.cpython-38.opt-2.pyc	2432	0644	editdlrm
popen_forkserver.cpython-38.pyc	2432	0644	editdlrm
popen_spawn_posix.cpython-38.opt-1.pyc	2223	0644	editdlrm
popen_spawn_posix.cpython-38.opt-2.pyc	2223	0644	editdlrm
popen_spawn_posix.cpython-38.pyc	2223	0644	editdlrm
popen_spawn_win32.cpython-38.opt-1.pyc	3439	0644	editdlrm
popen_spawn_win32.cpython-38.opt-2.pyc	3358	0644	editdlrm
popen_spawn_win32.cpython-38.pyc	3476	0644	editdlrm
process.cpython-38.opt-1.pyc	10366	0644	editdlrm
process.cpython-38.opt-2.pyc	8918	0644	editdlrm
process.cpython-38.pyc	11016	0644	editdlrm
queues.cpython-38.opt-1.pyc	9494	0644	editdlrm
queues.cpython-38.opt-2.pyc	9340	0644	editdlrm
queues.cpython-38.pyc	9569	0644	editdlrm
reduction.cpython-38.opt-1.pyc	8218	0644	editdlrm
reduction.cpython-38.opt-2.pyc	7478	0644	editdlrm
reduction.cpython-38.pyc	8218	0644	editdlrm
resource_sharer.cpython-38.opt-1.pyc	5212	0644	editdlrm
resource_sharer.cpython-38.opt-2.pyc	4792	0644	editdlrm
resource_sharer.cpython-38.pyc	5271	0644	editdlrm
resource_tracker.cpython-38.opt-1.pyc	5113	0644	editdlrm
resource_tracker.cpython-38.opt-2.pyc	4753	0644	editdlrm
resource_tracker.cpython-38.pyc	5200	0644	editdlrm
sharedctypes.cpython-38.opt-1.pyc	6999	0644	editdlrm
sharedctypes.cpython-38.opt-2.pyc	6735	0644	editdlrm
sharedctypes.cpython-38.pyc	7064	0644	editdlrm
shared_memory.cpython-38.opt-1.pyc	14177	0644	editdlrm
shared_memory.cpython-38.opt-2.pyc	11443	0644	editdlrm
shared_memory.cpython-38.pyc	14405	0644	editdlrm
spawn.cpython-38.opt-1.pyc	6652	0644	editdlrm
spawn.cpython-38.opt-2.pyc	6175	0644	editdlrm
spawn.cpython-38.pyc	6711	0644	editdlrm
synchronize.cpython-38.opt-1.pyc	10984	0644	editdlrm
synchronize.cpython-38.opt-2.pyc	10984	0644	editdlrm
synchronize.cpython-38.pyc	11306	0644	editdlrm
util.cpython-38.opt-1.pyc	11449	0644	editdlrm
util.cpython-38.opt-2.pyc	10629	0644	editdlrm
util.cpython-38.pyc	11501	0644	editdlrm
__init__.cpython-38.opt-1.pyc	677	0644	editdlrm
__init__.cpython-38.opt-2.pyc	677	0644	editdlrm
__init__.cpython-38.pyc	677	0644	editdlrm

U i�f�0�@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZdd
lZdd
lZddl m Z
ddl mZ
ddlm Z
ddl mZ
ddl mZ
ddl mZ
d d ddgZd Ze�d�
ZGdd�de�Zddd�
Zdd�Zdd�Zdd�Ze�ZejZejZejZejZd
S)�N�
)
� connection)
�process)
� reduction)
�resource_tracker)
�spawn)
�util�ensure_running�get_inherited_fds�connect_to_new_process�set_forkserver_preload�
�
qc@sDeZ
dZd
d�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dS)� ForkServerc

Cs.d|_d|_
d|_d|_t��|_d
g
|_dS)N�__main__)�_forkserver_address�_forkserver_alive_fd�_forkserver_pid�_inherited_fds� threadingZLock�_lock�_preload_modules�
�self�r�?/opt/alt/python38/lib64/python3.8/multiprocessing/forkserver.py�__init__"s





zForkServer.__init__c

Cs|j�
|�
�
W5QRXdS�
N)r�_stop_unlockedrrrr�_stop*s
zForkServer._stopc

CsV|jdkrdSt
�|j�

d|_t
�|jd
�
d|_t�|j�
sLt
�|j�

d|_dS)Nr
) r�os�closer�waitpidr�is_abstract_socket_namespacer�unlinkrrrrr/s





zForkServer._stop_unlockedcCs&td
d�|j
D�
�
std�
�
|
|_
dS)z>Set list of module names to try to load in forkserver process.c
ss|]}
t|
�
t
kV
qdSr)�type�str)�.0�modrrr� @sz4ForkServer.set_forkserver_preload..z&module_names must be a list of stringsN)�allr� TypeError)rZ modules_namesrrrr>s

z!ForkServer.set_forkserver_preloadc


Cs|jS)
z�Return list of fds inherited from parent process. This returns None if the current process was not started by fork server. )
rrrrrr DszForkServer.get_inherited_fdsc Cs�|��
t
|
�
d
tkr td�
�
t�tj�
��}|�|j�

t� �\}}t� �\}}|||j t��g}||
7}zNz&t�||�
||fWW�4W5QR�S


t� |�

t� |�

�YnXW5t� |�

t� |�

XW5QRXdS)a;
Request forkserver to create a child process. Returns a pair of fds (status_r, data_w). The calling process can read the child process's pid and (eventually) its returncode from status_r. The calling process should write to data_w the pickled preparation and process data. �ztoo many fdsN)r �len�MAXFDS_TO_SEND� ValueError�socket�AF_UNIXZconnectrr �piperrZgetfdr!rZsendfds)r�fdsZclientZparent_r�child_w�child_rZparent_wZallfdsrrrrLs(







�







z!ForkServer.connect_to_new_processc
s�
|j�
�~
t
��
|jd
k r`t�|jtj�\}
}|
sBW5QR�d
St�|j�

d
|_ d
|_d
|_d}|j r�ddh�t�d�
}�f
dd�|� �D�
}ni}t�tj�
��}t�d�
}|�|�

t�|�
s�t�|d �
|��
t��\}}ztzV|��|g} ||��||j |f;}t��} | g
t��}|d |g7}t�| || �}
Wn


t�|�

�YnXW5t�|�

X||_ ||_|
|_W5QRXW5QRXd
S)z�Make sure that a fork server is running. This can be called from any process. Note that usually a child process will just reuse the forkserver started by its parent, so ensure_running() will do nothing. NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)� main_path�sys_path�ignorec
si|]\}
}|
�kr|
|�qSrr)r'�
x�
y�
Zdesired_keysrr� �sz-ForkServer.ensure_running..r1i�
z-c)rrr rr r"�WNOHANGr!rrrrZget_preparation_data�itemsr0r1rZarbitrary_addressZbindrr#�chmodZlistenr2�filenoZget_executableZ_args_from_interpreter_flagsZspawnv_passfds)r�pidZstatus�cmd�data�listenerZaddress�alive_rZalive_wZfds_to_passZexe�argsrr;rr isN

















�








zForkServer.ensure_runningN) �__name__� __module__�__qualname__rrrrr rr rrrrr srcCs�|rdd
|kr8|dk r8dt�
�_zt�|�

W5t�
�`X|D]&}zt|�

Wq<tk r`


Yqk �r�
}
z|j?t?j@k�r̂W5d}~XYnX�
qW5QRXW5QRXdS)zRun forkserver.rNTFc

WsdSrr)
Z_unusedrrr�sigchld_handler�szmain..sigchld_handlerc
Ssi|]\}
}|
t�|
|��qSr)
�signal)r'�sig�valrrrr<�s
�zmain..)
r@c
Ssg|]\}
}|
j�qSr)
Zfileobj)r'�keyZeventsrrr� �szmain..r�zNot at EOF?i
�����r
zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %dzToo many ({0:n}) fds to send)ArZcurrent_processZ_inheritingrZimport_main_path� __import__�ImportErrorrZ_close_stdinr r2�set_blockingrK�SIGCHLD�SIGINT�SIG_IGNr>� set_wakeup_fdr0r1� selectorsZDefaultSelectorZgetsockname�_forkserverr�registerZ EVENT_READZselect�read�AssertionError� SystemExitr"r=�ChildProcessError�pop�WIFSIGNALED�WTERMSIG� WIFEXITED�format�WEXITSTATUS�write_signed�BrokenPipeErrorr!�warnings�warnZacceptrZrecvfdsr.r-�RuntimeError�fork�_exit�extend�values� _serve_one� Exception�sys� excepthook�exc_info�stderr�flush�OSError�errnoZECONNABORTED)Zlistener_fdrEZpreloadr6r7�modnameZsig_rZsig_wrJ�handlersZold_handlersZ pid_to_fdrDZselectorZrfdsrA�stsr4� returncode�
sr3r5�code� unused_fds�fd�
errr�main�s�










�
� 
�





 
 











�� 



�  



��










�









r�c Csht�
d
�

|��D]\}}t�||�
q|D]}t�|�

q,|
^t_tj_ t_ t�|�
}t� ||�}|S)NrQ)rKrXr>r r!rZrrZ_resource_trackerZ_fdr�duprZ_main) r5r3r~ryrLrMrZparent_sentinelr}rrrro1
s



�


roc
CsNd
}
tj
}t|
�
|kr@t�||t|
�
�}|s6td�
�
|
|7}
q t�|
�
dS)NrPzunexpected EOFr
)� SIGNED_STRUCT�sizer-r r\�EOFErrorZunpack)rrCZlengthr|rrr�read_signedH
s







r�cCs<t�
|
�
}|r8t�||�}|d
kr*td�
�
||d�}q dS)Nr
zshould not get here)r�Zpackr �writerj)r�
n�msg�nbytesrrrrfR
s





rf)NN) rwr rYrKr0Zstructrqrrh�rr�contextrrrr�__all__r.ZStructr��objectrr�ror�rfrZr r rrrrrr�
s>













�