$60 GRAYBYTE WORDPRESS FILE MANAGER $42



��Yf��@s�dd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
ddlmZ
dg
Z	ej
dkr�e	dg
7Z	Gd	d�de�Zn#e	d
g
7Z	Gdd
�d
e�Z
Gdd
�d
e�Ze�ZejZd
S)�N�
)
�process)
�	reduction)
�util�stop�win32�	DupSocketc@s.eZ
dZd
Zdd�Zdd�ZdS)rzPicklable wrapper for a socket.cs:|
j���f
d
d�}t
j|�j�|_dS)Ncs �j|
�
}|j
|�

dS)
N)�shareZ
send_bytes)�conn�pidr	)
�new_sock��D/opt/alt/python35/lib64/python3.5/multiprocessing/resource_sharer.py�sends

z DupSocket.__init__.<locals>.send)�dup�_resource_sharer�register�close�_id)�selfZsockrr
)
rr�__init__s

zDupSocket.__init__c
	Cs9tj
|j�
� }
|
j�}tj|�
SWd
QRXd
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.csLtj
|
�
��f
d
d�}�f
dd�}tj||�|_dS)Ncstj
|�|
�
dS)
N)rZsend_handle)r
r)
�new_fdr
rr1s
zDupFd.__init__.<locals>.sendcstj
��

dS)
N)�osrr
)
rr
rr3s
zDupFd.__init__.<locals>.close)r rrrr)r�fdrrr
)
rrr/s

zDupFd.__init__c
	Cs-tj
|j�
�}
tj|
�
SWd
QRXd
S)z-Get the fd.  This should only be called once.N)rrrrZrecv_handle)rr
r
r
rr7s
zDupFd.detachN)rrrrrrr
r
r
rr-s

c@sseZ
dZd
Zdd�Zdd�Zedd��
Zdd	d
�
Zdd�Z	d
d�Z
dd�ZdS)�_ResourceSharerz-Manager for resouces using background thread.c

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

	
	
	
z_ResourceSharer.__init__c
Csc|j�S
|j
d
kr#|j�
|jd7_|
|f|j|j<|j
|jfSWd
QRXd
S)z+Register resource, returning an identifier.Nr)r(r*�_startr#r$)rrrr
r
rrIs






z_ResourceSharer.registerc
CsTd
dlm
}

|\}}|
|dtj�j�

}|j|tj�f�

|S)z<Return connection from which to receive identified resource.r)
�Client�authkey)�
connectionr.r�current_processr/rr �getpid)Zidentr.�address�key�
cr
r
rrRs




z_ResourceSharer.get_connectionNcCs�d
dlm
}
|j��
|jdk	r�||jdtj�j�

}|jd�

|j�
|j	j
|
�

|j	j�r�tj
d�

|jj�
d|_	d|_d|_x*|jj�D]\}\}}|�
q�W|jj�
WdQRXdS)z:Stop the background thread and clear registered resources.r)
r.Nr/z._ResourceSharer thread did not stop when asked)r0r.r(r*rr1r/rrr+�joinZis_aliverZsub_warningr)r$�items�clear)rZtimeoutr.r5r4rrr
r
rr[s"














	
	
	
"

z_ResourceSharer.stopc
Cs�x*|jj
�D]\}
\}}|�
qW|jj�
|jj|j�

tj�|_|jdk	rx|jj	�
d|_d|_
d|_dS)
N)r$r7r8r%�appendr(r&r'r)rr*r+)rr4rrr
r
rr,ps
"







	
	
z_ResourceSharer._afterforkc
Cs�d
dlm
}

|jdks%t�
tjd�

|
dtj�j�
|_|jj	|_
tjd|j
�
}d|_|j�
||_dS)Nr)
�Listenerz0starting listener and thread for sending handlesr/�targetT)r0r:r)�AssertionErrorr�debugrr1r/r3r*r&ZThread�_serveZdaemon�startr+)rr:�
tr
r
rr-~s







	


z_ResourceSharer._startc
Cs�tt
d
�r.t
jt
jtdt
j��
x�yv|jj��`}
|
j�}|dkr_P|\}}|j	j
|�
\}}z||
|�
Wd|�
XWdQRXWq1


tj�s�t
jt
j��
Yq1Xq1WdS)N�pthread_sigmaskr)�hasattr�signalrA�	SIG_BLOCK�range�NSIGr)ZacceptZrecvr$�poprZ
is_exiting�sys�
excepthook�exc_info)rr
�msgr4Zdestination_pidrrr
r
rr>�s 















z_ResourceSharer._serve)rrrrrr�staticmethodrrr,r-r>r
r
r
rr"=s


		r")r rCrrHr&�rrr�__all__�platform�objectrrr"rrr
r
r
r�<module>s 





	


`