File manager

3


 \��@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@seZ
dZd
d�Zdd�ZdS)rcs(|
j���f
d
d�}t
j|�j�|_dS)Ncs�j|
�
}|j
|�

dS)
N)�shareZ
send_bytes)�conn�pidr)
�new_sock��7/usr/lib64/python3.6/multiprocessing/resource_sharer.py�sends


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

zDupSocket.__init__c
	Cs*tj
|j�
�}
|
j�}tj|�
SQRXdS)
N)r�get_connectionrZ
recv_bytes�socketZ	fromshare)rr	rrrr
�detach$s

zDupSocket.detachN)�__name__�
__module__�__qualname__rrrrrr
rs�DupFdc@seZ
dZd
d�Zdd�ZdS)rcs4tj
|
�
��f
d
d�}�f
dd�}tj||�|_dS)Ncstj
|�|
�
dS)
N)rZsend_handle)r	r
)
�new_fdrr
r1s
zDupFd.__init__.<locals>.sendcstj
��

dS)
N)�osrr)
rrr
r3s
zDupFd.__init__.<locals>.close)rrrrr)r�fdrrr)
rr
r/s


zDupFd.__init__c
	Cs"tj
|j�
�}
tj|
�
SQRXdS)
N)rrrrZrecv_handle)rr	rrr
r7s
zDupFd.detachN)rrrrrrrrr
r-sc@sJeZ
dZd
d�Zdd�Zedd��
Zddd	�
Zd
d�Zdd
�Z	dd�Z
dS)�_ResourceSharerc

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r
r?s








z_ResourceSharer.__init__c
CsN|j�>
|j
dkr|j�
|jd
7_|
|f|j|j<|j
|jfSQRXdS)Nr)r&r(�_startr!r")rrrrrr
rIs





z_ResourceSharer.registerc
Cs<d
dlm
}

|\}}|
|tj�jd�}|j|tj�f�

|S)Nr)
�Client)
�authkey)�
connectionr,r�current_processr-rr�getpid)Zidentr,�address�key�
crrr
rRs




z_ResourceSharer.get_connectionNcCs�d
dlm
}
|j��
|jdk	r�||jtj�jd�}|jd�

|j�
|j	j
|
�

|j	j�rdtj
d�

|jj�
d|_	d|_d|_x |jj�D]\}\}}|�
q�W|jj�
WdQRXdS)Nr)
r,)
r-z._ResourceSharer thread did not stop when asked)r.r,r&r(rr/r-rrr)�joinZis_aliverZsub_warningr'r"�items�clear)rZtimeoutr,r3r2rrrrr
r[s"




















z_ResourceSharer.stopc
Csnx |jj
�D]\}
\}}|�
qW|jj�
|jj|j�

tj�|_|jdk	rX|jj	�
d|_d|_
d|_dS)
N)r"r5r6r#�appendr&r$r%r'rr(r))rr2rrrrr
r*ps













z_ResourceSharer._afterforkc
CsXd
dlm
}

tjd�

|
tj�jd�
|_|jj|_	t
j|jd�
}d|_
|j�
||_dS)Nr)
�Listenerz0starting listener and thread for sending handles)
r-)
�targetT)r.r8r�debugrr/r-r'r1r(r$ZThread�_serveZdaemon�startr))rr8�
trrr
r+~s








z_ResourceSharer._startc
Cs�tt
d
�r t
jt
jtdt
j��
x�y\|jj��H}
|
j�}|dkrBP|\}}|j	j
|�
\}}z||
|�
Wd|�
XWdQRXWq"


tj�s�t
jt
j��
Yq"Xq"WdS)N�pthread_sigmaskr)�hasattr�signalr>�	SIG_BLOCK�range�NSIGr'ZacceptZrecvr"�poprZ
is_exiting�sys�
excepthook�exc_info)rr	�msgr2Zdestination_pidrrrrr
r;�s 















z_ResourceSharer._serve)
N)rrrrr�staticmethodrrr*r+r;rrrr
r =s
		
r )rr@rrEr$�r�contextrr�__all__�platform�objectrrr rrrrrr
�<module>s 









`