Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

U

e5d�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�2/usr/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)Nc
ss|]}
t|
�
t
kV
qdSr)�type�str)�.0�modrrr�	<genexpr>@sz4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of strings)�allr�	TypeError)rZ
modules_namesrrrr>s

z!ForkServer.set_forkserver_preloadc


Cs|jSr)
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)N�ztoo many fds)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
��
|jdk	r`t�|jtj�\}
}|
sBW5QR�dSt�|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||_	||_|
|_W5QRXW5QRXdS)
NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)�	main_path�sys_path�ignorec
si|]\}
}|
�kr|
|�qSrr)r'�
x�
y�
Zdesired_keysrr�
<dictcomp>�sz-ForkServer.ensure_running.<locals>.<dictcomp>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`


Yq<Xq<t��
t	�
�\}}t	�|d�
t	�|d�
dd�}tj
|tjtji}	dd�|	��D�
}
t�|�

i}tjtj|d����}t�����}
|��t_|
�|tj�
|
�|
tj�
|
�|tj�
�znd	d
�|
��D�
}|�
r"�
qB�
q"|
|k�
rPt�
||k�rBt	�|d�
zt	�dt	j�\}}Wnt k
�
r�


Y�qBYnX|d
k�
r��qB|�!|d�}|dk	�r0t	�"|�
�
r�t	�#|�
}n&t	�$|�
�
s�t%d�&||��
�
t	�'|�
}zt(||�
Wnt)k
�r"


YnXt	�*|�

nt+�,d|�

�
qf||k�r�|�-�d
�
�,}t.�/|t0d�}t1|�
t0k�r�t2d�&t1|�
�
�
�
|^}}}|�*�
t	�3�}|d
k�r4d}zpz<|�*�
|
�*�
|
|||g}|�5|�6��

t7||||
�}Wn.t8k
�r 


t9j:t9�;��
t9j<�=�
YnXW5t	�4|�

XnNzt(||�
Wnt)k
�rX


YnX|||<t	�*|�

|D]}t	�*|�

�qpW5QRXWn4t>k
�r�
}
z|j?t?j@k�r��W5d}~XYnX�
qW5QRXW5QRXdS)NrTFc

WsdSrr)
Z_unusedrrr�sigchld_handler�szmain.<locals>.sigchld_handlerc
Ssi|]\}
}|
t�|
|��qSr)
�signal)r'�sig�valrrrr<�s
�zmain.<locals>.<dictcomp>)
r@c
Ssg|]\}
}|
j�qSr)
Zfileobj)r'�keyZeventsrrr�
<listcomp>�szmain.<locals>.<listcomp>i
���r
zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %drzToo 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�
SystemExit�readr"r=�ChildProcessError�pop�WIFSIGNALED�WTERMSIG�	WIFEXITED�AssertionError�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)NrP)rKrWr>r r!rYrrZ_resource_trackerZ_fdr�duprZ_main)	r5r3r}rxrLrMr~Zparent_sentinelr|rrrrn1
s




�



rnc
CsNd
}
tj
}t|
�
|kr@t�||t|
�
�}|s6td�
�
|
|7}
q
t�|
�
dS)N�zunexpected EOFr
)�
SIGNED_STRUCT�sizer-r r\�EOFErrorZunpack)r~rCZlengthr{rrr�read_signedH
s








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






re)NN) rvr rXrKr0Zstructrprrg�rr�contextrrrr�__all__r.ZStructr��objectrr�rnr�rerYr	r
rrrrrr�<module>
s>













�