GRAYBYTE WORDPRESS FILE MANAGER6849

a

�DOg 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�N�AF_UNIX)�open_unix_connection�start_unix_server�
)
�
coroutines)
�events)
�
exceptions)
�format_helpers)
�	protocols)
�logger)
�sleepi
)�loop�limitc	�sx|durt�
�}ntjd
tdd�
t||d�}t||d��|j�f
dd�||
fi|�
�
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.9/asyncio/streams.py�<lambda>5�z!open_connection.<locals>.<lambda>)	r�get_event_loop�warnings�warn�DeprecationWarningr
r�create_connectionr)	�host�portrr�kwds�reader�	transport�
_�writerrrrrs

�


�
�
rc�sN�durt�
��ntjd
tdd�
��
�fdd�}�j||
|fi|�
�
IdHS)Nrrrcst�
�d
�}t
|��d�}
|
S�Nrr�r
r�r)r��client_connected_cbrrrr�factoryXs



�zstart_server.<locals>.factory)rr!r"r#r$�
create_server)r1r&r'rrr(r2rr0rr:s

�rc
�sv|
durt�
�}
ntjd
tdd�
t||
d�}t||
d��|
j�f
dd�|fi|�
�
IdH\}}t|�||
�}||fS)Nrrrrrc
s�Srrrrrrrpr z&open_unix_connection.<locals>.<lambda>)	rr!r"r#r$r
rZcreate_unix_connectionr)�pathrrr(r)r*r+r,rrrrds

�


�
�
rc�sL�durt�
��ntjd
tdd�
��
�fdd�}�j||
fi|�
�
IdHS)Nrrrcst�
�d
�}t
|��d�}
|
Sr-r.r/r0rrr2~s



�z"start_unix_server.<locals>.factory)rr!r"r#r$Zcreate_unix_server)r1r4rrr(r2rr0rr	ts

�r	c@s>eZ
dZddd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zd
S)�FlowControlMixinNcCs0|
durt�
�|_n|
|_d
|_d|_d
|_dS�NF)rr!�_loop�_paused�
_drain_waiter�_connection_lost)�selfrrrr�__init__�s




zFlowControlMixin.__init__c

Cs d
|_|j
��rt�d|�
dS)NTz%r pauses writing)r8r7�	get_debugr�debug�
r;rrr�
pause_writing�s


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

dS)NFz%r resumes writing)r8r7r=rr>r9�done�
set_result�r;�waiterrrr�resume_writing�s






zFlowControlMixin.resume_writingcCsVd
|_|j
sdS|j}|dur"dSd|_|��r4dS|
durH|�d�

n
|�|
�

dS�NT)r:r8r9rArB�
set_exception�r;�excrDrrr�connection_lost�s









z FlowControlMixin.connection_lostc
�s<|jrt
d
�
�
|jsdS|j}
|j��}
|
|_|
IdH
dS)NzConnection lost)r:�ConnectionResetErrorr8r9r7�
create_futurerCrrr�
_drain_helper�s







zFlowControlMixin._drain_helperc
Cst�
dSr)
�NotImplementedError�r;�streamrrr�_get_close_waiter�s
z"FlowControlMixin._get_close_waiter)
N)	�__name__�
__module__�__qualname__r<r@rErJrMrQrrrrr5�s

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

|
du
r,t�|
�
|_|
j|_nd|_|du
r@|
|_d|_d|_d|_	||_
d|_|j�
�|_dS)NrF)�superr<�weakref�ref�_stream_reader_wr�_source_traceback�_strong_reader�_reject_connection�_stream_writer�
_transport�_client_connected_cb�	_over_sslr7rL�_closed)r;Z
stream_readerr1r�
�	__class__rrr<�s











zStreamReaderProtocol.__init__c

Cs|jdurdS|��Sr)
rXr?rrr�_stream_reader�s


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

|
��
dS|
|_|j}|du
rT|�|
�

|
�d�
du
|_	|j
du
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)r[rYr7Zcall_exception_handler�abortr]rc�
set_transport�get_extra_infor_r^rr\rZiscoroutineZcreate_taskrZ)r;r*�contextr)�resrrr�connection_made�s0
�















�
�


z$StreamReaderProtocol.connection_madecsx|j}|du
r*|
dur |�
�
n
|�|
�

|j��sV|
durJ|j�d�

n|j�|
�

t��|
�

d|_d|_	d|_
dSr)rc�feed_eofrGr`rArBrUrJrXr\r])r;rIr)rarrrJ

s













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

dSr)rc�	feed_data)r;�datar)rrr�
data_received
s


z"StreamReaderProtocol.data_receivedc
Cs$|j}
|
du
r|
�
�
|jr d
SdS)NFT)rcrkr_)r;r)rrr�eof_received 
s




z!StreamReaderProtocol.eof_receivedc
Cs|jSr)
r`rOrrrrQ+
s
z&StreamReaderProtocol._get_close_waiterc
Cs"|j}
|
�
�r|
��s|
��
dSr)r`rA�	cancelled�	exception)r;�closedrrr�__del__.
s

zStreamReaderProtocol.__del__)NN)rRrSrTrYr<�propertyrcrjrJrnrorQrs�
__classcell__rrrarr�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)r]�	_protocol�_readerr7rLZ
_complete_futrB)r;r*rr)rrrrr<@
s



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

d�d�|
�
�
S)N�
transport=zreader=�<{}>�
 )rbrRr]rw�append�format�join�r;�inforrr�__repr__J
s




zStreamWriter.__repr__c


Cs|jSr�
r]r?rrrr*P
szStreamWriter.transportcCs|j�
|
�

dSr)r]�write�r;rmrrrr�T
s
zStreamWriter.writecCs|j�
|
�

dSr)r]�
writelinesr�rrrr�W
s
zStreamWriter.writelinesc

Cs
|j�
�Sr)r]�	write_eofr?rrrr�Z
s
zStreamWriter.write_eofc

Cs
|j�
�Sr)r]�
can_write_eofr?rrrr�]
s
zStreamWriter.can_write_eofc

Cs
|j�
�Sr)r]�closer?rrrr�`
s
zStreamWriter.closec

Cs
|j�
�Sr)r]�
is_closingr?rrrr�c
s
zStreamWriter.is_closingc

�s|j�
|�
IdH
dSr)rvrQr?rrr�wait_closedf
s
zStreamWriter.wait_closedNcCs|j�
|
|�Sr)r]rg)r;�name�defaultrrrrgi
s
zStreamWriter.get_extra_infoc
�sL|jdu
r |j�
�}
|
du
r |
�
|j��r8td
�
IdH
|j��IdH
dS)Nr)rwrqr]r�rrvrM)r;rIrrr�drainl
s








zStreamWriter.drain)
N)rRrSrTr<r�rtr*r�r�r�r�r�r�r�rgr�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�
�
|
|_
|dur*t��|_n||_t�|_d|_d|_d|_	d|_
d|_|j��rrt
�t�d�
�
|_dS)NrzLimit cannot be <= 0Fr
)�
ValueError�_limitrr!r7�	bytearray�_buffer�_eof�_waiter�
_exceptionr]r8r=r�
extract_stack�sys�	_getframerY)r;rrrrrr<�
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=rxZpausedryrz)r�r{�lenr�r��_DEFAULT_LIMITr�r�r]r8r|r}r~rrrr��
s 


















zStreamReader.__repr__c


Cs|jSr)
r�r?rrrrq�
s
zStreamReader.exceptioncCs0|
|_|j
}|du
r,d|_
|��s,|�|
�

dSr)r�r�rprGrHrrrrG�
s




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

dSr)r�rprBrCrrr�_wakeup_waiter�
s




zStreamReader._wakeup_waitercCs
|
|_dSrr�)r;r*rrrrf�
szStreamReader.set_transportc

Cs*|jr&t
|j�
|jk
r&d
|_|j��
dSr6)r8r�r�r�r]�resume_readingr?rrr�_maybe_resume_transport�
s


z$StreamReader._maybe_resume_transportc

Csd
|_|�
�
dSrF)r�r�r?rrrrk�
s

zStreamReader.feed_eofc


Cs|jo|j
Sr)r�r�r?rrr�at_eof�
szStreamReader.at_eofcCsr|
sdS|j�
|
�

|��
|jdu
rn|jsnt|j�
d
|jkrnz|j��
Wntyf


d|_Yn0d|_dS)NrT)	r��extendr�r]r8r�r�Z
pause_readingrNr�rrrrl�
s



��

zStreamReader.feed_datac�s^|jdu
rt
|
�d
��
�
|jr.d|_|j��
|j��|_z|jIdH
Wd|_nd|_0dS)NzF() called while another coroutine is already waiting for incoming dataF)r��RuntimeErrorr8r]r�r7rL)r;�	func_namerrr�_wait_for_data�
s	


�




zStreamReader._wait_for_datac

�s�d
}
t|
�
}z|�
|
�
IdH}Wn�tjyL
}
z|jWYd}~Sd}~0tjy�
}
zP|j�|
|j�r�|jd|j|�=n
|j�	�
|�
�
t|jd�
�
WYd}~n
d}~00|S)N�

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










$
zStreamReader.readliner�c�s�t|
�
}|d
krt
d�
�
|jdu
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�)r;�	separatorr��offset�buflenZisep�chunkrrrr�(s<










�







�


zStreamReader.readuntilr�c�s�|jdu
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�r{r}r�r�r�r�r�)r;�
nZblocks�blockrmrrrr��s"










zStreamReader.readc�s�|
d
krtd�
�
|j
du
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�)r;r�Z
incompletermrrrr��s&















zStreamReader.readexactlyc


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



zStreamReader.__anext__)
r�)
r�)rRrSrTrYr�r<r�rqrGr�rfr�rkr�rlr�r�r�r�r�r�r�rrrrr
�
s$	
[
2)r
)NN)NN)
N)
N)�__all__�socketr�r"rV�hasattr�rrr
rr�logrZtasksrr�rrrr	�Protocolr5rrr
rrrr�<module>
s>











�!
�'

�
�DkP