File manager

3


 \�_�@sH
dd
dddddgZddl
Z
ee
d	�r2ejd
dg�

dd
lmZ
ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
ddl
mZ
d!ZGdd�de
�ZGdd�de�Ze	d"ded�dd��
Ze	d#ded�dd��
Zee
d	��
re	d$ded�dd
��
Ze	d%ded�dd��
ZGdd�dej�ZGdd�deej�ZGdd
�d
�ZGd d�d�ZdS)&�StreamReader�StreamWriter�StreamReaderProtocol�open_connection�start_server�IncompleteReadError�LimitOverrunError�NZAF_UNIX�open_unix_connection�start_unix_server�
)
�
coroutines)
�compat)
�events)
�	protocols)
�	coroutine)
�logger��cs$eZ
dZ�f
d
d�Zdd�Z�ZS)rcs(t�j
d
t|
�
|f�

|
|_||_dS)Nz-%d bytes read on a total of %r expected bytes)�super�__init__�len�partial�expected)�selfrr)
�	__class__��'/usr/lib64/python3.6/asyncio/streams.pyr s



zIncompleteReadError.__init__c

Cst|�
|j
|jffS)
N)�typerr)
rrrr�
__reduce__&s
zIncompleteReadError.__reduce__)�__name__�
__module__�__qualname__rr�
__classcell__rr)
rrrscs$eZ
dZ�f
d
d�Zdd�Z�ZS)rcst�j
|
�

||_dS)
N)rr�consumed)r�messager#)
rrrr0s

zLimitOverrunError.__init__c

Cst|�
|j
d
|jffS)Nr)r�argsr#)
rrrrr4s
zLimitOverrunError.__reduce__)rr r!rrr"rr)
rrr*s)�loop�limitc	+sb|dkrtj
�}t||d
�}t||d��|j�f
dd�||
f|�
EdH\}}t|�||�}||fS)N)r'r&)
r&c
s�S)
Nrr)
�protocolrr�<lambda>Qsz!open_connection.<locals>.<lambda>)r�get_event_loopr
rZcreate_connectionr)	�host�portr&r'�kwds�reader�	transport�
_�writerr)
r(rr8s




 

c+s8�dkrtj
����
�fd
d�}�j||
|f|�
EdHS)Ncst�
�d
�}t
|��d�}
|
S)N)r'r&)
r&)r
r)r.r()�client_connected_cbr'r&rr�factoryqs



zstart_server.<locals>.factory)rr*Z
create_server)r2r+r,r&r'r-r3r)r2r'r&rrVs
c
+s`|
dkrtj
�}
t||
d
�}t||
d��|
j�f
dd�|f|�
EdH\}}t|�||
�}||fS)N)r'r&)
r&c
s�S)
Nrr)
r(rrr)�sz&open_unix_connection.<locals>.<lambda>)rr*r
rZcreate_unix_connectionr)�pathr&r'r-r.r/r0r1r)
r(rr	}s






c+s6�dkrtj
����
�fd
d�}�j||
f|�
EdHS)Ncst�
�d
�}t
|��d�}
|
S)N)r'r&)
r&)r
r)r.r()r2r'r&rrr3�s



z"start_unix_server.<locals>.factory)rr*Zcreate_unix_server)r2r4r&r'r-r3r)r2r'r&rr
�s
c@s:eZ
dZddd�
Zdd�Zdd�Zdd	�Zed
d��
Zd
S)
�FlowControlMixinNcCs0|
dkrtj
�|_n|
|_d
|_d|_d
|_dS)NF)rr*�_loop�_paused�
_drain_waiter�_connection_lost)rr&rrrr�s




zFlowControlMixin.__init__c

Cs d
|_|j
j�rtjd|�
dS)NTz%r pauses writing)r7r6�	get_debugr�debug)
rrrr�
pause_writing�s


zFlowControlMixin.pause_writingc
CsFd
|_|j
j�rtjd|�
|j}
|
dk	rBd|_|
j�sB|
jd�

dS)NFz%r resumes writing)r7r6r:rr;r8�done�
set_result)r�waiterrrr�resume_writing�s






zFlowControlMixin.resume_writingcCsVd
|_|j
sdS|j}|dkr"dSd|_|j�r4dS|
dkrH|jd�

n
|j|
�

dS)NT)r9r7r8r=r>�
set_exception)r�excr?rrr�connection_lost�s









z FlowControlMixin.connection_lostc
cs<|jrt
d
�
�
|jsdS|j}
|jj�}
|
|_|
EdH
dS)NzConnection lost)r9�ConnectionResetErrorr7r8r6�
create_future)rr?rrr�
_drain_helper�s






zFlowControlMixin._drain_helper)
N)	rr r!rr<r@rCrrFrrrrr5�s


	r5csBeZ
dZd�f
dd�	Zdd�Z�f
dd�Zdd	�Zd
d�Z�ZS)
rNcs*t�j
|d
�

|
|_d|_||_d|_dS)N)
r&F)rr�_stream_reader�_stream_writer�_client_connected_cb�	_over_ssl)rZ
stream_readerr2r&)
rrrr�s





zStreamReaderProtocol.__init__cCsd|jj
|
�

|
jd
�
dk	|_|jdk	r`t|
||j|j�|_|j|j|j�}tj	|�
r`|jj
|�

dS)NZ
sslcontext)rG�
set_transport�get_extra_inforJrIrr6rHrZiscoroutineZcreate_task)rr/�resrrr�connection_made�s












z$StreamReaderProtocol.connection_madecsF|jdk	r*|
dkr|jj
�
n|jj|
�

t�j|
�

d|_d|_dS)
N)rG�feed_eofrArrCrH)rrB)
rrrrC�s






z$StreamReaderProtocol.connection_lostcCs|jj
|
�

dS)
N)rG�	feed_data)r�datarrr�
data_received
s
z"StreamReaderProtocol.data_receivedc


Cs|jj
�
|jrd
SdS)NFT)rGrOrJ)
rrrr�eof_received
s



z!StreamReaderProtocol.eof_received)NN)	rr r!rrNrCrRrSr"rr)
rrr�s
	
c@sfeZ
dZd
d�Zdd�Zedd��
Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zddd�
Ze
dd��
ZdS)rcCs|
|_||_
||_||_dS)
N)�
_transport�	_protocol�_readerr6)rr/r(r.r&rrrr
s


zStreamWriter.__init__c
Cs:|jj
d
|jg}
|jdk	r,|
jd|j�

ddj|
�
S)Nztransport=%rz	reader=%rz<%s>�
 )rrrTrV�append�join)r�inforrr�__repr__!
s




zStreamWriter.__repr__c


Cs|jS)
N)
rT)
rrrrr/'
szStreamWriter.transportcCs|jj
|
�

dS)
N)rT�write)rrQrrrr\+
s
zStreamWriter.writecCs|jj
|
�

dS)
N)rT�
writelines)rrQrrrr].
s
zStreamWriter.writelinesc


Cs
|jj
�S)
N)rT�	write_eof)
rrrrr^1
s
zStreamWriter.write_eofc


Cs
|jj
�S)
N)rT�
can_write_eof)
rrrrr_4
s
zStreamWriter.can_write_eofc


Cs
|jj
�S)
N)rT�close)
rrrrr`7
s
zStreamWriter.closeNcCs|jj
|
|�S)
N)rTrL)r�name�defaultrrrrL:
s
zStreamWriter.get_extra_infoc
csN|jdk	r |jj
�}
|
dk	r |
�
|jdk	r:|jj�r:dV
|jj�EdH
dS)
N)rV�	exceptionrTZ
is_closingrUrF)rrBrrr�drain=
s	









zStreamWriter.drain)
N)rr r!rr[�propertyr/r\r]r^r_r`rLrrdrrrrr
s

c@s�eZ
dZed
fdd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Zdd�Z
edd��
Zedd��
Zed'dd�
�
Zed)dd�
�
Zed d!��
Zejr�ed"d#��
Zed$d%��
Zejr�d&d#�Zd
S)*r
NcCsZ|
d
k
rtd�
�
|
|_
|dkr*tj�|_n||_t�|_d|_d|_d|_	d|_
d|_dS)NrzLimit cannot be <= 0F)�
ValueError�_limitrr*r6�	bytearray�_buffer�_eof�_waiter�
_exceptionrTr7)rr'r&rrrrX
s








zStreamReader.__init__c
Cs�d
g
}
|jr |
j
dt|j�
�

|jr0|
j
d�

|jtkrJ|
j
d|j�

|jr`|
j
d|j�

|jrv|
j
d|j�

|jr�|
j
d|j�

|j	r�|
j
d�

d	d
j
|
�
S)Nr
z%d bytes�eofzl=%dzw=%rze=%rzt=%rZpausedz<%s>rW)rirXrrjrg�_DEFAULT_LIMITrkrlrTr7rY)rrZrrrr[k
s 


















zStreamReader.__repr__c


Cs|jS)
N)
rl)
rrrrrc}
s
zStreamReader.exceptioncCs0|
|_|j
}|dk	r,d|_
|j�s,|j|
�

dS)
N)rlrk�	cancelledrA)rrBr?rrrrA�
s




zStreamReader.set_exceptionc
Cs*|j}
|
dk	r&d|_|
j
�s&|
jd�

dS)
N)rkror>)rr?rrr�_wakeup_waiter�
s




zStreamReader._wakeup_waitercCs
|
|_dS)
N)
rT)rr/rrrrK�
szStreamReader.set_transportc

Cs*|jr&t
|j�
|jk
r&d
|_|jj�
dS)NF)r7rrirgrT�resume_reading)
rrrr�_maybe_resume_transport�
s


z$StreamReader._maybe_resume_transportc

Csd
|_|j
�
dS)NT)rjrp)
rrrrrO�
s

zStreamReader.feed_eofc


Cs|jo|j
S)
N)rjri)
rrrr�at_eof�
szStreamReader.at_eofcCsv|
sdS|jj
|
�

|j�
|jdk	rr|jrrt|j�
d
|jkrry|jj�
Wntk
rj


d|_YnXd|_dS)NrT)	ri�extendrprTr7rrgZ
pause_reading�NotImplementedError)rrQrrrrP�
s







zStreamReader.feed_dataccsV|jdk	rt
d
|
�
�
|jr,d|_|jj�
|jj�|_z|jEdH
Wdd|_XdS)NzH%s() called while another coroutine is already waiting for incoming dataF)rk�RuntimeErrorr7rTrqr6rE)rZ	func_namerrr�_wait_for_data�
s








zStreamReader._wait_for_datac
cs�d
}
t|
�
}y|j
|
�
EdH}Wn�tk
rB
}
z|jSd}~Xnftk
r�
}
zJ|jj|
|j�rv|jd|j|�=n
|jj�
|j	�
t
|jd�
�
WYdd}~XnX|S)N�

r)r�	readuntilrrrri�
startswithr#�clearrrrfr%)r�sep�seplen�line�
errr�readline�
s










 
zStreamReader.readlinerxccs�t|
�
}|d
krt
d�
�
|jdk	r(|j�
d
}x�t|j�
}|||kr||jj|
|�}|dkr\P|d|}||jkr|td|��
|jr�t|j�
}|jj	�
t
|d��
|jd�
EdH
q.W||jkr�td|��
|jd||�}|jd||�=|j�
t|�
S)Nrz,Separator should be at least one-byte stringrz2Separator is not found, and chunk exceed the limitryz2Separator is found, but chunk is longer than limit���)
rrfrlri�findrgrrj�bytesr{rrwrr)rZ	separatorr}�offsetZbuflenZisep�chunkrrrry�
s:























zStreamReader.readuntilrccs�|jdk	r|j�
|
d
krdS|
d
krZg}x&|j
|j�
EdH}|sBP|j|�

q*Wdj|�
S|jrz|jrz|jd�
EdH
t|jd|
��
}|jd|
�=|j	�
|S)Nr��read)
rlr�rgrXrYrirjrwr�rr)r�
nZblocks�blockrQrrrr�Ps$












zStreamReader.readccs�|
d
krtd�
�
|j
dk	r |j
�
|
d
kr,dSxFt|j�
|
krr|jr`t|j�
}|jj�
t||
��
|jd�
EdH
q.Wt|j�
|
kr�t|j�
}|jj�
nt|jd|
��
}|jd|
�=|j	�
|S)Nrz*readexactly size can not be less than zeror��readexactly)
rfrlrrirjr�r{rrwrr)rr�Z
incompleterQrrrr��s&
















zStreamReader.readexactlyc


Cs|S)
Nr)
rrrr�	__aiter__�szStreamReader.__aiter__c
cs|j�EdH}
|
d
krt
�
|
S)Nr�)r��StopAsyncIteration)r�valrrr�	__anext__�s


zStreamReader.__anext__c


Cs|S)
Nr)
rrrrr��s
)
rxr�)
r�)rr r!rnrr[rcrArprKrrrOrsrPrrwr�ryr�r�r
ZPY35r�r�ZPY352rrrrr
V
s,	 
[
2*
i
)NN)NN)
N)
N)�__all__Zsocket�hasattrrt�rr
rrr�logrrn�EOFErrorr�	Exceptionrrrr	r
ZProtocolr5rrr
rrrr�<module>s@













"



B3G