✘✘ GRAYBYTE WORDPRESS FILE MANAGER ✘✘

a

�i�@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
dg
Z
ejdkrxe
dg
7Z
Gd	d�de�Z
ne
d
g
7Z
Gdd
�d
e�ZGdd
�d
e�Ze�ZejZd
S)�N�
)
�process)
�	reduction)
�util�stop�win32�	DupSocketc@seZ
dZd
d�Zdd�ZdS)rcs(|
����f
d
d�}t
�|�j�|_dS)Ncs��|
�
}|�
|�

dS�
N)�share�
send_bytes)�conn�pidr
�
Znew_sock��7/usr/lib64/python3.9/multiprocessing/resource_sharer.py�sends


z DupSocket.__init__.<locals>.send)�dup�_resource_sharer�register�close�_id)�self�sockrrrr�__init__s

zDupSocket.__init__c
CsBt�
|j�
�"}
|
��}t�|�
Wd�
S1s40


Y
dSr	)r�get_connectionr�
recv_bytes�socketZ	fromshare)rrr
rrr�detach$s

zDupSocket.detachN��__name__�
__module__�__qualname__rrrrrrrs�DupFdc@seZ
dZd
d�Zdd�ZdS)r"cs4t�
|
�
��f
d
d�}�f
dd�}t�||�|_dS)Ncst�
|�|
�
dSr	)r�send_handle)rr
�
Znew_fdrrr1s
zDupFd.__init__.<locals>.sendcst�
��

dSr	)�osrrr$rrr3s
zDupFd.__init__.<locals>.close)r%rrrr)r�fdrrrr$rr/s


zDupFd.__init__c
Cs:t�
|j�
�}
t�|
�
Wd�
S1s,0


Y
dSr	)rrrr�recv_handle)rrrrrr7s
zDupFd.detachNrrrrrr"-sc@sJeZ
dZd
d�Zdd�Zedd��
Zddd	�
Zd
d�Zdd
�Z	dd�Z
dS)�_ResourceSharerc

Cs:d
|_i|_
t��|_d|_d|_d|_t�	|t
j�
dS)Nr
)�_key�_cache�	threading�Lock�_lock�	_listener�_address�_threadr�register_after_forkr(�
_afterfork)
rrrrr?s







z_ResourceSharer.__init__cCsf|j�L
|j
dur|��
|jd
7_|
|f|j|j<|j
|jfWd�
S1sX0


Y
dS)Nr)r-r/�_startr)r*)rrrrrrrHs





z_ResourceSharer.registerc
Cs<d
dlm
}

|\}}|
|t��jd�}|�|t��f�

|S)Nr�
�Client�
�authkey)�
connectionr5r�current_processr7rr%�getpid)�identr5�address�key�
crrrrQs




z_ResourceSharer.get_connectionNcCs�d
dlm
}
|j��
|jdu
r�||jt��jd�}|�d�

|��
|j	�
|
�

|j	��rdt�
d�

|j��
d|_	d|_d|_|j��D]\}\}}|�
q�|j��
Wd�
n1s�0


Y
dS)Nrr4r6z._ResourceSharer thread did not stop when asked)r8r5r-r/rr9r7rrr0�join�is_aliver�sub_warningr.r*�items�clear)r�timeoutr5r>r=rrrrrrZs$




�













z_ResourceSharer.stopc
Cs\|j�
�D]\}
\}}|�
q
|j��
|j��
|jdu
rF|j��
d|_d|_d|_dSr	)	r*rBrCr-�_at_fork_reinitr.rr/r0)rr=rrrrrr2os












z_ResourceSharer._afterforkc
CsXd
dlm
}

t�d�

|
t��jd�
|_|jj|_	t
j|jd�
}d|_
|��
||_dS)Nr)
�Listenerz0starting listener and thread for sending handlesr6)
�targetT)r8rFr�debugrr9r7r.r<r/r+�Thread�_serve�daemon�startr0)rrF�
trrrr3zs








z_ResourceSharer._startc
Cs�tt
d
�rt
�t
jt
���
z�|j���f}
|
��}|durJWd�
Wq�|\}}|j�	|�
\}}z||
|�
W|�
n|�
0Wd�
n1s�0


Y
Wq


t
��s�tj
t���
Yq0qdS)N�pthread_sigmask)�hasattr�signalrN�	SIG_BLOCK�
valid_signalsr.�accept�recvr*�popr�
is_exiting�sys�
excepthook�exc_info)rr�msgr=�destination_pidrrrrrrJ�s










2


z_ResourceSharer._serve)
N)rr r!rr�staticmethodrrr2r3rJrrrrr(=s		


r()r%rPrrWr+�r�contextrr�__all__�platform�objectrr"r(rrrrrr�<module>s 









\