File manager

3


 \/�@sRdd
dgZddl
mZ
dg
ZGdd
�d
e�Zdd�Zdd	d�
ZGd
d�de�ZdS)
�Client�Listener�Pipe�)
�QueueNc@sBeZ
dZddd�
Zdd�Zdd�Zed	d
��
Zdd�Zd
d�Z	d
S)rN�
cCst|�
|_
dS)
N)r�_backlog_queue)�self�addressZfamilyZbacklog�r
�8/usr/lib64/python3.6/multiprocessing/dummy/connection.py�__init__s
zListener.__init__c

Cst|j
j��S)
N)�
Connectionr�get)
rr
r
r�accepts
zListener.acceptc

Cs
d|_dS)
N)
r)
rr
r
r�closes
zListener.closec


Cs|jS)
N)
r)
rr
r
r�<lambda>szListener.<lambda>c


Cs|S)
Nr
)
rr
r
r�	__enter__s
zListener.__enter__c
Cs|j�
dS)
N)
r)r�exc_type�	exc_value�exc_tbr
r
r�__exit__"s
zListener.__exit__)NNr)
�__name__�
__module__�__qualname__rrr�propertyr	rrr
r
r
rrs
c
Cs&t�t�}
}|j
||
f�

t|
|�S)
N)r�putr
)r	�_in�_outr
r
rr
&s


Tc
Cs"t�t�}
}t
|
|�t
||
�fS)
N)rr
)Zduplex�
a�
br
r
rr,s

c@s6eZ
dZd
d�Zd
dd�
Zdd�Zdd	�Zd
d�ZdS)r
cCs,||_|
|_
|j|_|_|
j|_|_dS)
N)rrr�sendZ
send_bytesrZrecvZ
recv_bytes)rrrr
r
rr3s



zConnection.__init__�c	CsN|jj
�d
krdS|
dk
rdS|jj�
|jjj|
�

WdQRX|jj
�d
kS)NrTgF)rZqsizeZ	not_empty�wait)rZtimeoutr
r
r�poll9s







zConnection.pollc


CsdS)
Nr
)
rr
r
rrBs
zConnection.closec


Cs|S)
Nr
)
rr
r
rrEs
zConnection.__enter__c
Cs|j�
dS)
N)
r)rrrrr
r
rrHs
zConnection.__exit__N)
r!)rrrrr#rrrr
r
r
rr
1s

	r
)
T)	�__all__ZqueuerZfamilies�objectrr
rr
r
r
r
r�<module>
s