File manager

U

e5d h�@s&
dZd
dl
Z
d
dlZd
dlZd
dlZee
d�r6ed7ZddlmZ
ddlmZ
ddlm	Z	
dd	lm
Z

dd
lmZ
ddlm
Z

ddlmZ
d
Zdded�dd�Zd ded�dd�Zee
d�r�d!ded�dd�Zd"ded�dd�ZGdd�dej�ZGdd�deej�ZGdd�d�ZGdd�d�ZdS)#)�StreamReader�StreamWriter�StreamReaderProtocol�open_connection�start_server�NZAF_UNIX)�open_unix_connection�start_unix_server�
)
�
coroutines)
�events)
�
exceptions)
�format_helpers)
�	protocols)
�logger)
�sleepi
)�loop�limitc	�st|dkrt�
�}ntjd
tdd�
t||d�}t||d��|j�f
dd�||
f|�
IdH\}}t|�||�}||fS)N�[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.��
�
stacklevel�rr�
rc
s�S�
N�r�
�protocolr�'/usr/lib64/python3.8/asyncio/streams.py�<lambda>5�z!open_connection.<locals>.<lambda>)	r�get_event_loop�warnings�warn�DeprecationWarningr
rZcreate_connectionr)	�host�portrr�kwds�reader�	transport�
_�writerrrrrs"

�



�
�
rc�sJ�dkrt�
��ntjd
tdd�
��
�fdd�}�j||
|f|�
IdHS)Nrrrcst�
�d
�}t
|��d�}
|
S�Nrr�r
r�r'r��client_connected_cbrrrr�factoryXs



�zstart_server.<locals>.factory)rr r!r"r#Z
create_server)r/r$r%rrr&r0rr.rr:s

�rc
�sr|
dkrt�
�}
ntjd
tdd�
t||
d�}t||
d��|
j�f
dd�|f|�
IdH\}}t|�||
�}||fS)Nrrrrrc
s�Srrrrrrrprz&open_unix_connection.<locals>.<lambda>)	rr r!r"r#r
rZcreate_unix_connectionr)�pathrrr&r'r(r)r*rrrrds 

�



�
�
rc�sH�dkrt�
��ntjd
tdd�
��
�fdd�}�j||
f|�
IdHS)Nrrrcst�
�d
�}t
|��d�}
|
Sr+r,r-r.rrr0~s



�z"start_unix_server.<locals>.factory)rr r!r"r#Zcreate_unix_server)r/r1rrr&r0rr.rrts

�rc@s>eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zd
S)�FlowControlMixinNcCs0|
dkrt�
�|_n|
|_d
|_d|_d
|_dS�NF)rr �_loop�_paused�
_drain_waiter�_connection_lost)�selfrrrr�__init__�s




zFlowControlMixin.__init__c

Cs d
|_|j
��rt�d|�
dS)NTz%r pauses writing)r5r4�	get_debugr�debug�
r8rrr�
pause_writing�s


zFlowControlMixin.pause_writingc
CsFd
|_|j
��rt�d|�
|j}
|
dk	rBd|_|
��sB|
�d�

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






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

n
|�|
�

dS�NT)r7r5r6r>r?�
set_exception�r8�excrArrr�connection_lost�s









z FlowControlMixin.connection_lostc
�s<|jrt
d
�
�
|jsdS|j}
|j��}
|
|_|
IdH
dS)NzConnection lost)r7�ConnectionResetErrorr5r6r4�
create_futurer@rrr�
_drain_helper�s







zFlowControlMixin._drain_helperc
Cst�
dSr)
�NotImplementedError�r8�streamrrr�_get_close_waiter�s
z"FlowControlMixin._get_close_waiter)
N)	�__name__�
__module__�__qualname__r9r=rBrGrJrNrrrrr2�s

	r2csbeZ
dZd
Zd�f
dd�	Zedd��
Zdd�Z�f
dd	�Zd
d�Z	dd
�Z
dd�Zdd�Z�Z
S)rNcsnt�j
|d
�

|
dk	r,t�|
�
|_|
j|_nd|_|dk	r@|
|_d|_d|_d|_	||_
d|_|j�
�|_dS)NrF)�superr9�weakref�ref�_stream_reader_wr�_source_traceback�_strong_reader�_reject_connection�_stream_writer�
_transport�_client_connected_cb�	_over_sslr4rI�_closed)r8Z
stream_readerr/r�
�	__class__rrr9�s











zStreamReaderProtocol.__init__c

Cs|jdkrdS|��Sr)
rUr<rrr�_stream_reader�s


z#StreamReaderProtocol._stream_readercCs�|jr6d
di
}|j
r|j
|d<|j�|�

|
��
dS|
|_|j}|dk	rT|�|
�

|
�d�
dk	|_	|j
dk	r�t|
|||j�|_|�
||j�}t
�|�
r�|j�|�

d|_dS)N�messagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.Zsource_tracebackZ
sslcontext)rXrVr4Zcall_exception_handler�abortrZr`�
set_transport�get_extra_infor\r[rrYr
ZiscoroutineZcreate_taskrW)r8r(�contextr'�resrrr�connection_made�s2
�















�
�


z$StreamReaderProtocol.connection_madecsx|j}|dk	r*|
dkr |�
�
n
|�|
�

|j��sV|
dkrJ|j�d�

n|j�|
�

t��|
�

d|_d|_	d|_
dSr)r`�feed_eofrDr]r>r?rRrGrUrYrZ)r8rFr'r^rrrG

s













z$StreamReaderProtocol.connection_lostcCs|j}|dk	r|�
|
�

dSr)r`�	feed_data)r8�datar'rrr�
data_received
s


z"StreamReaderProtocol.data_receivedc
Cs$|j}
|
dk	r|
�
�
|jr d
SdS)NFT)r`rhr\)r8r'rrr�eof_received 
s




z!StreamReaderProtocol.eof_receivedc
Cs|jSr)
r]rLrrrrN+
s
z&StreamReaderProtocol._get_close_waiterc
Cs"|j}
|
�
�r|
��s|
��
dSr)r]r>�	cancelled�	exception)r8�closedrrr�__del__.
s

zStreamReaderProtocol.__del__)NN)rOrPrQrVr9�propertyr`rgrGrkrlrNrp�
__classcell__rrr^rr�s	

rc@sreZ
dZd
d�Zdd�Zedd��
Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zdd�Zdd�Z
ddd�
Zdd�ZdS)rcCs4|
|_||_
||_||_|j��|_|j�d�

dSr)rZ�	_protocol�_readerr4rIZ
_complete_futr?)r8r(rr'rrrrr9@
s




zStreamWriter.__init__c
Cs@|jj
d
|j��g}
|jdk	r0|
�d|j���

d�d�|
�
�
S)N�
transport=zreader=�<{}>�
 )r_rOrZrt�append�format�join�r8�inforrr�__repr__J
s




zStreamWriter.__repr__c


Cs|jSr�
rZr<rrrr(P
szStreamWriter.transportcCs|j�
|
�

dSr)rZ�write�r8rjrrrrT
s
zStreamWriter.writecCs|j�
|
�

dSr)rZ�
writelinesr�rrrr�W
s
zStreamWriter.writelinesc

Cs
|j�
�Sr)rZ�	write_eofr<rrrr�Z
s
zStreamWriter.write_eofc

Cs
|j�
�Sr)rZ�
can_write_eofr<rrrr�]
s
zStreamWriter.can_write_eofc

Cs
|j�
�Sr)rZ�closer<rrrr�`
s
zStreamWriter.closec

Cs
|j�
�Sr)rZ�
is_closingr<rrrr�c
s
zStreamWriter.is_closingc

�s|j�
|�
IdH
dSr)rsrNr<rrr�wait_closedf
s
zStreamWriter.wait_closedNcCs|j�
|
|�Sr)rZrd)r8�name�defaultrrrrdi
s
zStreamWriter.get_extra_infoc
�sL|jdk	r |j�
�}
|
dk	r |
�
|j��r8td
�
IdH
|j��IdH
dS)Nr)rtrnrZr�rrsrJ)r8rFrrr�drainl
s








zStreamWriter.drain)
N)rOrPrQr9r}rqr(rr�r�r�r�r�r�rdr�rrrrr6
s




rc@s�eZ
dZd
Zed
fdd�
Zdd�Zdd�Zdd	�Zd
d�Z	dd
�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zd&dd�
Zd'dd�
Zd d!�Zd"d#�Zd$d%�Zd
S)(r
NcCsv|
d
k
rtd�
�
|
|_
|dkr*t��|_n||_t�|_d|_d|_d|_	d|_
d|_|j��rrt
�t�d�
�
|_dS)NrzLimit cannot be <= 0Fr	)�
ValueError�_limitrr r4�	bytearray�_buffer�_eof�_waiter�
_exceptionrZr5r:r
�
extract_stack�sys�	_getframerV)r8rrrrrr9�
s 












�zStreamReader.__init__c
Cs�d
g
}
|jr"|
�
t|j�
�d��

|jr2|
�
d�

|jtkrN|
�
d|j���

|jrf|
�
d|j���

|jr~|
�
d|j���

|jr�|
�
d|j���

|j	r�|
�
d�

d	�
d
�|
�
�
S)Nr
z bytes�eofzlimit=zwaiter=z
exception=ruZpausedrvrw)r�rx�lenr�r��_DEFAULT_LIMITr�r�rZr5ryrzr{rrrr}�
s 


















zStreamReader.__repr__c


Cs|jSr)
r�r<rrrrn�
s
zStreamReader.exceptioncCs0|
|_|j
}|dk	r,d|_
|��s,|�|
�

dSr)r�r�rmrDrErrrrD�
s




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

dSr)r�rmr?r@rrr�_wakeup_waiter�
s




zStreamReader._wakeup_waitercCs
|
|_dSrr~)r8r(rrrrc�
szStreamReader.set_transportc

Cs*|jr&t
|j�
|jk
r&d
|_|j��
dSr3)r5r�r�r�rZ�resume_readingr<rrr�_maybe_resume_transport�
s


z$StreamReader._maybe_resume_transportc

Csd
|_|�
�
dSrC)r�r�r<rrrrh�
s

zStreamReader.feed_eofc


Cs|jo|j
Sr)r�r�r<rrr�at_eof�
szStreamReader.at_eofcCst|
sdS|j�
|
�

|��
|jdk	rp|jspt|j�
d
|jkrpz|j��
Wntk
rh


d|_YnXd|_dS)NrT)	r��extendr�rZr5r�r�Z
pause_readingrKr�rrrri�
s



��

zStreamReader.feed_datac�sX|jdk	rt
|
�d
��
�
|jr.d|_|j��
|j��|_z|jIdH
W5d|_XdS)NzF() called while another coroutine is already waiting for incoming dataF)r��RuntimeErrorr5rZr�r4rI)r8Z	func_namerrr�_wait_for_data�
s	


�




zStreamReader._wait_for_datac

�s�d
}
t|
�
}z|�
|
�
IdH}Wn�tjk
rN
}
z|jWY�Sd}~XYnhtjk
r�
}
zH|j�|
|j�r�|jd|j|�=n
|j�	�
|�
�
t|jd�
�
W5d}~XYnX|S)N�

r)
r��	readuntilr�IncompleteReadError�partial�LimitOverrunErrorr��
startswith�consumed�clearr�r��args)r8�sep�seplen�line�
errr�readline	s










 
zStreamReader.readliner�c�s�t|
�
}|d
krt
d�
�
|jdk	r(|j�
d
}t|j�
}|||kr||j�|
|�}|dkrZq�|d|}||jkr|t�d|��
|jr�t	|j�
}|j�
�
t�|d��
|�d�
IdH
q,||jkr�t�d|��
|jd||�}|jd||�=|�
�
t	|�
S)Nrz,Separator should be at least one-byte string���r	z2Separator is not found, and chunk exceed the limitr�z2Separator is found, but chunk is longer than limit)r�r�r�r��findr�rr�r��bytesr�r�r�r�)r8Z	separatorr��offsetZbuflenZisep�chunkrrrr�(s>










�







�


zStreamReader.readuntilr�c�s�|jdk	r|j�
|
d
krdS|
d
krVg}|�
|j�
IdH}|s@qL|�|�

q(d�|�
S|jsr|jsr|�d�
IdH
t|jd|
��
}|jd|
�=|�	�
|S)Nrr�read)
r�r�r�rxrzr�r�r�r�r�)r8�
nZblocks�blockrjrrrr��s"










zStreamReader.readc�s�|
d
krtd�
�
|j
dk	r |j
�
|
d
kr,dSt|j�
|
krr|jr`t|j�
}|j��
t�||
��
|�	d�
IdH
q,t|j�
|
kr�t|j�
}|j��
nt|jd|
��
}|jd|
�=|�
�
|S)Nrz*readexactly size can not be less than zeror�readexactly)r�r�r�r�r�r�r�rr�r�r�)r8r�Z
incompleterjrrrr��s&















zStreamReader.readexactlyc


Cs|Srrr<rrr�	__aiter__�s
zStreamReader.__aiter__c
�s|��IdH}
|
d
krt
�
|
S)Nr)r��StopAsyncIteration)r8�valrrr�	__anext__�s



zStreamReader.__anext__)
r�)
r�)rOrPrQrVr�r9r}rnrDr�rcr�rhr�rir�r�r�r�r�r�r�rrrrr
�
s$	
[
2)r
)NN)NN)
N)
N)�__all__Zsocketr�r!rS�hasattr�r
rrr
r�logrZtasksrr�rrrrZProtocolr2rrr
rrrr�<module>
sF











�!
�'

�
�DkP