$46 GRAYBYTE WORDPRESS FILE MANAGER $88

U

i�f��@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�stopZwin32�	DupSocketc@s eZ
dZd
Zdd�Zdd�ZdS)rzPicklable wrapper for a socket.cs(|
����f
d
d�}t
�|�j�|_dS)Ncs��|
�
}|�
|�

dS�
N)�shareZ
send_bytes)�conn�pidr	�
Znew_sock��D/opt/alt/python38/lib64/python3.8/multiprocessing/resource_sharer.py�sends


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

zDupSocket.__init__c

Cs6t�
|j�
� }
|
��}t�|�
W5QR�SQRXd
S)z1Get the socket.  This should only be called once.N)r�get_connectionrZ
recv_bytes�socketZ	fromshare)rr
r	r
r
r�detach$s

zDupSocket.detachN��__name__�
__module__�__qualname__�__doc__rrr
r
r
rrs

�DupFdc@s eZ
dZd
Zdd�Zdd�ZdS)rz-Wrapper for fd which can be used at any time.cs4t�
|
�
��f
d
d�}�f
dd�}t�||�|_dS)Ncst�
|�|
�
dSr)rZsend_handle)r
r�
Znew_fdr
rr1s
zDupFd.__init__.<locals>.sendcst�
��

dSr)�osrr
r r
rr3s
zDupFd.__init__.<locals>.close)r!rrrr)r�fdrrr
r rr/s


zDupFd.__init__c

Cs.t�
|j�
�}
t�|
�
W5QR�SQRXd
S)z-Get the fd.  This should only be called once.N)rrrrZrecv_handle)rr
r
r
rr7s
zDupFd.detachNrr
r
r
rr-s

c@sNeZ
dZd
Zdd�Zdd�Zedd��
Zdd	d
�
Zdd�Z	d
d�Z
dd�ZdS)�_ResourceSharerz.Manager for resources using background thread.c

Cs@d
|_i|_
g|_t��|_d|_d|_d|_t	�
|tj�
dS)Nr
)
�_key�_cache�
_old_locks�	threading�Lock�_lock�	_listener�_address�_threadrZregister_after_forkr#�
_afterfork)
rr
r
rr?s








z_ResourceSharer.__init__c
CsZ|j�J
|j
d
kr|��
|jd7_|
|f|j|j<|j
|jfW5QR�SQRXd
S)z+Register resource, returning an identifier.Nr)r)r+�_startr$r%)rrrr
r
rrIs





z_ResourceSharer.registerc
Cs<d
dlm
}

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

|S)z<Return connection from which to receive identified resource.r�
�Client�
�authkey)�
connectionr0r�current_processr2rr!�getpid)Zidentr0�address�key�
cr
r
rrRs




z_ResourceSharer.get_connectionNc	Cs�d
dlm
}
|j��
|jdk	r�||jt��jd�}|�d�

|��
|j	�
|
�

|j	��rdt�
d�

|j��
d|_	d|_d|_|j��D]\}\}}|�
q�|j��
W5QRXdS)z:Stop the background thread and clear registered resources.rr/Nr1z._ResourceSharer thread did not stop when asked)r3r0r)r+rr4r2rrr,�joinZis_aliverZsub_warningr*r%�items�clear)rZtimeoutr0r8r7rrr
r
rr[s$




�













z_ResourceSharer.stopc
Csj|j�
�D]\}
\}}|�
q
|j��
|j�|j�

t��|_|jdk	rT|j�	�
d|_d|_
d|_dSr)r%r:r;r&�appendr)r'r(r*rr+r,)rr7rrr
r
rr-ps












z_ResourceSharer._afterforkc
Csjd
dlm
}

|jdkstd�
�
t�d�

|
t��jd�
|_|jj	|_
tj|j
d�
}d|_|��
||_dS)Nr)
�ListenerzAlready have Listenerz0starting listener and thread for sending handlesr1)
�targetT)r3r=r*�AssertionErrorr�debugrr4r2r6r+r'ZThread�_serveZdaemon�startr,)rr=�
tr
r
rr.~s










z_ResourceSharer._startc
	Cs�tt
d
�rt
�t
jt
���
zh|j���T}
|
��}|dkrHW5QR�Wq�|\}}|j�	|�
\}}z||
|�
W5|�
XW5QRXWq


t
��s�tj
t���
YqXqdS)N�pthread_sigmask)�hasattr�signalrD�	SIG_BLOCK�
valid_signalsr*ZacceptZrecvr%�poprZ
is_exiting�sys�
excepthook�exc_info)rr
�msgr7Zdestination_pidrrr
r
rrA�s













z_ResourceSharer._serve)
N)rrrrrr�staticmethodrrr-r.rAr
r
r
rr#=s


	


r#)r!rFrrJr'�r�contextrr�__all__�platform�objectrrr#rrr
r
r
r�<module>s 









`