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 ]

a

XC?hn/�@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
gd	�
Zd
Ze�d�
ZGdd
�d
e�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/python39/lib64/python3.9/multiprocessing/forkserver.py�__init__"s






zForkServer.__init__c

Cs2|j�
|�
�
Wd�
n1s$0


Y
dS�
N)r�_stop_unlockedrrrr�_stop*s
zForkServer._stopc

CsV|jdurdSt
�|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
uV
qdSr)�type�str)�.0�modrrr�	<genexpr>@�z4ForkServer.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}zvz:t
�||�
||fWWt�|�

t�|�

Wd�
S


t�|�

t�|�

�Yn0Wt�|�

t�|�

nt�|�

t�|�

0Wd�
n1�
s0


Y
dS)N�ztoo many fds)r	�len�MAXFDS_TO_SEND�
ValueError�socket�AF_UNIXZconnectrr �piperrZgetfdrZsendfdsr!)r�fdsZclientZparent_r�child_w�child_rZparent_wZallfdsrrrrLs2







�






�








�

z!ForkServer.connect_to_new_processc
s�
|j�
��
t
��
|jdu
rbt�|jtj�\}
}|
sDWd�
dSt�|j�

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

t�|�
s�t�|d�
|��
t��\}}z~zV|��|g}	||��||j
|f;}t��}
|
g
t��}|d	|g7}t�|
||	�}
Wn


t�|�

�Yn0Wt�|�

nt�|�

0||_	||_|
|_Wd�
n1�
s�0


Y
Wd�
n1�
s�0


Y
dS)
NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)�	main_path�sys_path�ignorec
si|]\}
}|
�vr|
|�qSrr)r'�
x�
y�
Zdesired_keysrr�
<dictcomp>�r*z-ForkServer.ensure_running.<locals>.<dictcomp>r2i�
z-c)rrr	rr r"�WNOHANGr!rrrrZget_preparation_data�itemsr1r2rZarbitrary_addressZbindrr#�chmodZlistenr3�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�|rjd
|vr@|du
r@dt�
�_zt�|�

Wt�
�`n
t�
�`0|D]$}zt|�

WqDtyf


YqD0qDt��
t	�
�\}}t	�|d�
t	�|d�
dd�}tj
|tjtji}	dd�|	��D�
}
t�|�

i}tjtj|d����}t�����}
|��t_|
�|tj�
|
�|
tj�
|
�|tj�
�zPd	d
�|
��D�
}|�
r(�
qH�
q(|
|v�
rVt�
||v�rt	�|d�
zt	�dt	j�\}}Wnt �
y�


Y�qYn0|d
k�
r��q|�!|d�}|du
�
r�t	�"|�
}zt#||�
Wnt$�
y�


Yn0t	�%|�

nt&�'d|�

�
ql||v�rt|�(�d
�
�<}t)�*|t+d�}t,|�
t+k�rXt-d�.t,|�
�
�
�
|^}}}|�%�
t	�/�}|d
k�rd}zxz<|�%�
|
�%�
|
|||g}|�0|�1��

t2||||
�}Wn,t3�y�


t4j5t4�6��
t4j7�8�
Yn0Wt	�9|�

nt	�9|�

0nLzt#||�
Wnt$�y*


Yn0|||<t	�%|�

|D]}t	�%|�

�qBWd�
n1�sj0


Y
Wn6t:�y�
}
z|j;t;j<k�r��WYd}~n
d}~00�
q$Wd�
n1�s�0


Y
Wd�
n1�s�0


Y
dS)NrTFc

WsdSrr)
Z_unusedrrr�sigchld_handler�szmain.<locals>.sigchld_handlerc
Ssi|]\}
}|
t�|
|��qSr)
�signal)r'�sig�valrrrr=�s
�zmain.<locals>.<dictcomp>)
rAc
Ssg|]\}
}|
j�qSr)
Zfileobj)r'�keyZeventsrrr�
<listcomp>�r*zmain.<locals>.<listcomp>i
���r
z.forkserver: waitpid returned unexpected pid %drzToo many ({0:n}) fds to send)=rZcurrent_processZ_inheritingrZimport_main_path�
__import__�ImportErrorrZ_close_stdinr r3�set_blockingrL�SIGCHLD�SIGINT�SIG_IGNr?�
set_wakeup_fdr1r2�	selectorsZDefaultSelectorZgetsockname�_forkserverr�registerZ
EVENT_READZselect�
SystemExit�readr"r>�ChildProcessError�pop�waitstatus_to_exitcode�write_signed�BrokenPipeErrorr!�warnings�warnZacceptrZrecvfdsr/r.�RuntimeError�format�fork�extend�values�
_serve_one�	Exception�sys�
excepthook�exc_info�stderr�flush�_exit�OSError�errnoZECONNABORTED)Zlistener_fdrFZpreloadr7r8�modnameZsig_rZsig_wrK�handlersZold_handlersZ	pid_to_fdrEZselectorZrfdsrB�stsr5�
returncode�
sr4r6�code�
unused_fds�fd�
errr�main�s�











�
�

�























�





��












�








2

r}c	Csht�
d
�

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

q,|
^t_tj_	t_
t�|�
}t�
||�}|S)NrQ)rLrXr?r r!rZrrZ_resource_trackerZ_fdr�duprZ_main)	r6r4rzrurMrNr{Zparent_sentinelryrrrrj+
s




�



rjc
CsNd
}
tj
}t|
�
|kr@t�||t|
�
�}|s6td�
�
|
|7}
q
t�|
�
dS)Nr*zunexpected EOFr
)�
SIGNED_STRUCT�sizer.r r]�EOFErrorZunpack)r{rDZlengthrxrrr�read_signedB
s








r�cCs<t�
|
�
}|r8t�||�}|d
kr*td�
�
||d�}q
dS)Nr
zshould not get here)rZpackr �writere)r{�
n�msg�nbytesrrrraL
s






ra)NN) rsr rYrLr1Zstructrlrrc�rr�contextrrrr�__all__r/ZStructr�objectrr}rjr�rarZr	r
rrrrrr�<module>
s: