File manager

U

e5d��@s�dd
lZdd
l
Z
ddlmZmZ
ejs.ed�
�
ddlmZ
ddlm	Z	
ddlm
Z

ddlmZ
d	g
ZGd
d�de
�ZGdd	�d	e	j�Zd
S)
�N�
)�	reduction�set_spawning_popenz,No support for sending fds between processes)
�
forkserver)
�
popen_fork)
�spawn)
�util�Popenc@seZ
dZd
d�Zdd�ZdS)�_DupFdcCs
|
|_dS�
N)
�ind)�selfr�r�8/usr/lib64/python3.8/multiprocessing/popen_forkserver.py�__init__s
z_DupFd.__init__c

Cst�
�|jSr)rZget_inherited_fdsr)
r
rrr�detachs
z
_DupFd.detachN)�__name__�
__module__�__qualname__rrrrrrr
s
r
csBeZ
dZd
ZeZ�f
dd�Zdd�Zdd�Ze	j
f
dd	�
Z�ZS)
r	rcsg|_t
��|
�

dSr)�_fds�superr)r
�process_obj�
�	__class__rrr!s

zPopen.__init__cCs|j�
|
�

t|j�
d
S)Nr)r�append�len)r
�fdrrr�duplicate_for_child%s

zPopen.duplicate_for_childc	Cs�t�
|
j�
}t��}t|�

zt�||�
t�|
|�
W5td�

Xt�	|j
�
\|_}t�
|�
}t�|tj||jf�|_t|d
dd��}|�|���

W5QRXt�|j�
|_dS)N�wbT)
�closefd)rZget_preparation_data�_name�io�BytesIOrr�dumprZconnect_to_new_processr�sentinel�os�duprZFinalizeZ	close_fds�	finalizer�open�write�	getbuffer�read_signed�pid)r
rZ	prep_dataZbuf�
wZ	_parent_w�
frrr�_launch)s










�

z
Popen._launchc	Csr|jdkrld
dl
m}
|
tjkr$d
nd}||jg
|�s:dSzt�|j�
|_Wntt	fk
rj


d|_YnX|jS)Nr
)
�wait�)
�
returncodeZmultiprocessing.connectionr0r%�WNOHANGr$rr+�OSError�EOFError)r
�flagr0Ztimeoutrrr�poll=s








z
Popen.poll)
rrr�methodr
ZDupFdrrr/r%r3r7�
__classcell__rrrrr	s

)r!r%�contextrrZHAVE_SEND_HANDLE�ImportError�rrrr�__all__�objectr
r	rrrr�<module>
s