✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�in/�@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�	threading�Lock�_lock�_preload_modules�
�self�r�2/usr/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_UNIX�connectrr!�piperrZgetfdr�sendfdsr")r�fds�client�parent_r�child_w�child_r�parent_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>r3i�
z-c)rrr	rr!r#�WNOHANGr"rrrrZget_preparation_data�itemsr2r3r�arbitrary_address�bindrr$�chmod�listenr5�filenoZget_executable�_args_from_interpreter_flags�spawnv_passfds)r�pid�status�cmd�data�listener�address�alive_rZalive_wZfds_to_passZexe�argsrrBrr	isN























�










zForkServer.ensure_runningN)
�__name__�
__module__�__qualname__rr rr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�valrrrrC�s
�zmain.<locals>.<dictcomp>)
rJc
Ssg|]\}
}|
j�qSr)
�fileobj)r(�key�eventsrrr�
<listcomp>�r+zmain.<locals>.<listcomp>i
���r
z.forkserver: waitpid returned unexpected pid %drzToo many ({0:n}) fds to send)=r�current_processZ_inheritingrZimport_main_path�
__import__�ImportErrorr�_close_stdinr!r5�set_blockingrY�SIGCHLD�SIGINT�SIG_IGNrE�
set_wakeup_fdr2r3�	selectors�DefaultSelector�getsockname�_forkserverr�register�
EVENT_READ�select�
SystemExit�readr#rD�ChildProcessError�pop�waitstatus_to_exitcode�write_signed�BrokenPipeErrorr"�warnings�warn�acceptr�recvfdsr0r/�RuntimeError�format�fork�extend�values�
_serve_one�	Exception�sys�
excepthook�exc_info�stderr�flush�_exit�OSError�errnoZECONNABORTED)Zlistener_fdrSZpreloadr=r>�modnameZsig_rZsig_wrX�handlersZold_handlersZ	pid_to_fdrQ�selectorZrfdsrM�stsr:�
returncode�
sr7r;�code�
unused_fds�fd�
errr�main�s�











�
�

�























�





��












�








2

r�c	Csht�
d
�

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

q,|
^t_tj_	t_
t�|�
}t�
||�}|S)Nr`)rYrirEr!r"rmrr�_resource_trackerZ_fdr�duprZ_main)	r;r7r�r�rZr[r��parent_sentinelr�rrrr�+
s




�



r�c
CsNd
}
tj
}t|
�
|kr@t�||t|
�
�}|s6td�
�
|
|7}
q
t�|
�
dS)Nr+zunexpected EOFr
)�
SIGNED_STRUCT�sizer/r!rr�EOFError�unpack)r�rP�lengthr�rrr�read_signedB
s








r�cCs<t�
|
�
}|r8t�||�}|d
kr*td�
�
||d�}q
dS)Nr
zshould not get here)r��packr!�writer|)r��
n�msg�nbytesrrrrvL
s






rv)NN) r�r!rjrYr2�structr�rrx�rr�contextrrrr�__all__r0�Structr��objectrr�r�r�rvrmr	r
rrrrrr�<module>
s: