:P7s ~ d Z ddlZddlZddlZddlZddlZ eed re dz
Z ddlmZ ddlm Z ddlm
Z
dd lm Z dd
lm Z dd l
mZ dd lmZ d
ZdeddZdeddZ eed rd eddZd eddZ G d de j Z G d dee j Z G d d Z G d d ZdS ) ) StreamReader StreamWriterStreamReaderProtocolopen_connection start_server NAF_UNIX)open_unix_connectionstart_unix_server )
coroutines)events)
exceptions)format_helpers) protocols)logger)sleepi )limitc K t j }t || }t || |j fd| |fi | d {V \ }}t | || }||fS )Nr loopr c S N protocols z!open_connection..1 s )r
get_running_loopr r create_connectionr )
hostportr kwdsr reader transport_writerr s
@r r r s " " $ $D
D
1
1
1F#F666H//$. .(,. . . . . . . .LIq
)Xvt
<
r c n K t j fd} j |||fi | d {V S )Nc N t } t | }|S Nr r r r r% r client_connected_cbr r s r factoryz start_server..factoryN s6 E555'0C-13 3 3r )r
r
create_server)r. r" r# r r$ r/ r s ` ` @r r r 6 st ( " $ $D $#GT4@@4@@ @ @ @ @ @ @@r c K t j }t || }t || |j fd| fi | d {V \ }}t ||| }||fS )Nr r c S r r r s r r z&open_unix_connection..b s H r )r
r r r create_unix_connectionr ) pathr r$ r r% r& r' r( r s @r r r Z s N&(( E555'T::: 8T 8 d , ,&* , , , , , , , , 1 i64@@v~ r c l K t j fd} j ||fi | d {V S )Nc N t } t | }|S r+ r, r- s r r/ z"start_unix_server..factoryk s6 !D999F+F4G157 7 7HOr )r
r create_unix_server)r. r4 r r$ r/ r s ` ` @r r
r
f sn K&(( -T,WdCCdCCCCCCCCCr c 6 e Zd Z ddZd Zd Zd Zd Zd ZdS ) FlowControlMixinNc |t j d | _ n|| _ d| _ t j | _ d| _ d S )N )
stacklevelF)r
_get_event_loop_loop_paused collectionsdeque_drain_waiters_connection_lost)selfr s r __init__zFlowControlMixin.__init__~ sK < /1===DJJ DJ ) / 1 1 % r c t d| _ | j rt j d| d S d S )NTz%r pauses writing)r? r> get_debugr debugrD s r
pause_writingz FlowControlMixin.pause_writing sB : ! ! 4 L,d 3 3 3 3 3 4 4r c d| _ | j rt j d| | j D ]+}| s| d ,d S )NFz%r resumes writing)r? r> rG r rH rB done
set_resultrD waiters r resume_writingz FlowControlMixin.resume_writing ss : ! ! 5 L-t 4 4 4) ( (F;;==
(!!$''' ( (r c d| _ | j sd S | j D ]C}| s-|| d .| | Dd S NT)rC r? rB rL rM
set_exceptionrD excrO s r connection_lostz FlowControlMixin.connection_lost sv $ | F) . .F;;==
.;%%d++++((--- . .r c 2 K | j rt d | j sd S | j }| j | | d {V | j | d S # | j | w xY w)NzConnection lost)rC ConnectionResetErrorr? r>
create_futurerB appendremoverN s r
_drain_helperz FlowControlMixin._drain_helper s :&'899 9| F))++ ""6*** /LLLLLLL & &v . . . . .D & &v . . . .s A: : Bc t r )NotImplementedErrorrD streams r _get_close_waiterz"FlowControlMixin._get_close_waiter s !!r r ) __name__
__module__ __qualname__rE rJ rP rV r\ ra r r r r9 r9 t sx & & & &4 4 4 ( ( ( . . .
/
/
/" " " " "r r9 c j e Zd Z dZd fd Zed Zd Zd Z fdZ d Z
d Z d Z d
Z
xZS ) r Nc L t | |&t j | | _ |j | _ nd | _ ||| _ d| _ d | _ d | _ d | _
|| _ d| _ | j
| _ d S )Nr F)superrE weakrefref_stream_reader_wr_source_traceback_strong_reader_reject_connection_stream_writer_task
_transport_client_connected_cb _over_sslr> rY _closed)rD
stream_readerr. r __class__s r rE z StreamReaderProtocol.__init__ s
d### $%,[ %?%?D "%2%DD " "%)D " * #0D "' "
$7! z//11 r c < | j d S | S r )rj rI s r _stream_readerz#StreamReaderProtocol._stream_reader s" ! )4%%'''r c v | j }|j }|| _ || _ | d d u| _ d S )N
sslcontext)r> r& rn rp get_extra_inforr )rD r( r r& s r _replace_writerz$StreamReaderProtocol._replace_writer s> z$ $#"11,??tKr c X j rEddi} j r
j |d< j | d S _ j }|| d d u _ j
t | j _
| j }t j | r? fd} j | _ j | d _ d S d S )NmessagezpAn open stream was garbage collected prior to establishing network connection; call "stream.close()" explicitly.source_tracebackry c | r d S | }|4j d|d d S d S )Nz*Unhandled exception in client_connected_cb)r} exceptionr& ) cancelledcloser r> call_exception_handler)taskrU rD r& s r callbackz6StreamReaderProtocol.connection_made..callback s ~~'' !))) ..**C
99'S),)2; ;
")))))
'r )rm rk r> r abortrp rw
set_transportrz rr rq r rn r iscoroutine create_taskro add_done_callbackrl )rD r& contextr% resr s `` r connection_madez$StreamReaderProtocol.connection_made sg "
@G
%
E.2.D*+ J - -g 6 6 6 OO F#$ + + +"11,??tK $ 0".y$/5/3z#; #;D ++F,0,?A AC%c**
7 * * * * * * "Z 3 3C 8 8
,,X666"&D / 1 0r c | j }|,|| n| | | j s7|| j d n| j | t
| d | _ d | _ d | _
d | _ d S r ) rw feed_eofrS rs rL rM rg rV rj rn ro rp )rD rU r% ru s r rV z$StreamReaderProtocol.connection_lost
s $ {!!!!$$S)))| "" 0{ ''---- **3///
$$$!% "
r c F | j }|| | d S d S r )rw feed_data)rD datar% s r
data_receivedz"StreamReaderProtocol.data_received s2 $ T " " " " " r c R | j }|| | j rdS dS )NFT)rw r rr )rD r% s r eof_receivedz!StreamReaderProtocol.eof_received! s6 $ OO > 5tr c | j S r )rs r_ s r ra z&StreamReaderProtocol._get_close_waiter, s
|r c | j }| r*| s| d S d S d S # t $ r Y d S w xY wr )rs rL r r AttributeError)rD closeds r __del__z StreamReaderProtocol.__del__/ s #\F {{}}
#V%5%5%7%7
# """""
#
#
#
# DD s A
AANN)rb rc rd rk rE propertyrw r{ r rV r r ra r
__classcell__)ru s @r r r s 2 2 2 2 2 2( ( ( X(
L L L(' (' ('T $# # #
# # # # # # #r r c ~ e Zd Z d Zd Zed Zd Zd Zd Z d Z
d Z d Z d
Z
dd Zd
Zd d ddZd Zd S )r c || _ || _ || _ || _ | j | _ | j d d S r )rp _protocol_readerr> rY
_complete_futrM )rD r& r r% r s r rE zStreamWriter.__init__E sS #!
!Z 5 5 7 7 %%d+++++r c | j j d| j g}| j | d| j d d | S )N
transport=zreader=<{}> )ru rb rp r rZ formatjoinrD infos r __repr__zStreamWriter.__repr__O s] ')Ido)I)IJ < # KK2$,22 3 3 3}}SXXd^^,,,r c | j S r rp rI s r r& zStreamWriter.transportU s
r c : | j | d S r )rp writerD r s r r zStreamWriter.writeY s d#####r c : | j | d S r )rp
writelinesr s r r zStreamWriter.writelines\ s ""4(((((r c 4 | j S r )rp write_eofrI s r r zStreamWriter.write_eof_ s ((***r c 4 | j S r )rp
can_write_eofrI s r r zStreamWriter.can_write_eofb s ,,...r c 4 | j S r )rp r rI s r r zStreamWriter.closee s $$&&&r c 4 | j S r )rp
is_closingrI s r r zStreamWriter.is_closingh s ))+++r c J K | j | d {V d S r )r ra rI s r wait_closedzStreamWriter.wait_closedk s4 n..t44444444444r Nc 8 | j || S r )rp rz )rD namedefaults r rz zStreamWriter.get_extra_infon s --dG<< start_tlsrp r{ )rD ry r r r r
new_transports r r zStreamWriter.start_tls s Bn9E >jjll "j 2 2 OXz#_"7 3 9 9 9 9 9 9 9 9
( &&&&&r c | j sh| j r t j dt d S | t j d| t d S d S )Nzloop is closedz unclosed )rp r r> is_closedwarningswarnResourceWarningr rI s r r zStreamWriter.__del__ s ))++ Ez##%%
E
.@@@@@
2$ 2 2ODDDDD E Er r )rb rc rd rE r r r& r r r r r r r rz r r r r r r r r ; s , , ,- - - X $ $ $) ) )+ + +/ / /' ' ', , ,5 5 5= = = =- - -4 )-.2 ' ' ' ' ' E E E E Er r c e Zd ZdZedfdZd Zd Zd Zd Z d Z
d Z d Z d
Z
d Zd Zd
ZddZddZd Zd Zd ZdS )r Nc z |dk rt d || _ |t j | _ n|| _ t | _ d| _ d | _ d | _ d | _
d| _ | j r-t j t j d | _ d S d S )Nr zLimit cannot be <= 0Fr )
ValueError_limitr
r= r> bytearray_buffer_eof_waiter
_exceptionrp r? rG r
extract_stacksys _getframerk )rD r r s r rE zStreamReader.__init__ s A:: 344 4 < /11DJJ DJ {{ : ! ! "%3%A
a &" &"D " " " " "r c \ dg}| j r*| t | j d | j r| d | j t
k r | d| j | j r | d| j | j r | d| j | j r | d| j | j r| d d
d
| S ) Nr z byteseofzlimit=zwaiter=z
exception=r pausedr r ) r rZ lenr r _DEFAULT_LIMITr r rp r? r r r s r r zStreamReader.__repr__ s, < 6 KK3t|,,444 5 5 5 9 KK ;. ( ( KK... / / / < 4 KK2$,22 3 3 3 ? : KK8T_88 9 9 9 ? : KK8T_88 9 9 9 < " KK ! ! !}}SXXd^^,,,r c | j S r )r rI s r r zStreamReader.exception s
r c || _ | j }|2d | _ | s| | d S d S d S r )r r r rS rT s r rS zStreamReader.set_exception s] DL##%%
*$$S)))))
*
*r c | j }|2d | _ | s| d d S d S d S r )r r rM rN s r _wakeup_waiterzStreamReader._wakeup_waiter sY ? DL##%%
(!!$'''''
(
(r c || _ d S r r )rD r& s r r zStreamReader.set_transport s
#r c | j r?t | j | j k r$d| _ | j d S d S d S )NF)r? r r r rp resume_readingrI s r _maybe_resume_transportz$StreamReader._maybe_resume_transport sS < -C - - < < DL O * * , , , , , - - < rY )rD func_names r _wait_for_datazStreamReader._wait_for_data s < # 5 5 56 6
6 < - DL O * * , , ,z//11 , DLLL4DL s #
A9 9 Bc K d}t | } | | d {V }n# t j $ r}|j cY d }~S d }~wt j $ r}| j ||j r| j d |j |z = n| j |
t |j d d }~ww xY w|S )N
r )
r readuntilr IncompleteReadErrorpartialLimitOverrunErrorr
startswithconsumedclearr r args)rD sepseplenlinees r readlinezStreamReader.readline# s S
( ,,,,,,,,DD- 9 + ( ( (|&&sAJ77
%L!5!*v"5!566 ""$$$ ( ( * * * QVAY'' '
( s( 2 C A
C
C A:CC r c K t | }|dk rt d | j | j d} t | j }||z
|k rJ| j || }|dk rn|dz |z
}|| j k rt
j d| | j rBt | j }| j
t
j |d | d d {V || j k rt
j d| | j d ||z }| j d ||z = |
t | S ) Nr z,Separator should be at least one-byte stringTr 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 )rD separatorr offsetbuflenisepchunks r r zStreamReader.readuntilB s & Y Q;; KLL L ? &/ !* 3 &&F &((|((F;;2:: !f,DK''$6L y
B dl++ ""$$$ 4UDAAA %%k22 2 2 2 2 2 2 2= 3@ $+ .DdL L
L ^dVm^, L $- ( $$&&&U||r r c K | j | j |dk rdS |dk rQg } | | j d {V }|sn| | 9d | S | j s"| j s| d d {V t | j d | }| j d |= | |S )Nr r Tread)
r r r rZ r r r r r r )rD nblocksblockr s r r zStreamReader.read s * ? &/ ! 663 q55
F
% "ii 4 4444444
e$$$
%
88F## #| .DI .%%f-- - - - - - - - T\"1"%&& L! $$&&& r c K |dk rt d | j | j |dk rdS t | j |k r|| j rBt | j }| j t j || | d d {V t | j |k |t | j |k r.t | j }| j n&t | j d | }| j d |= |
|S )Nr z*readexactly size can not be less than zeror readexactly) r r r r r r r r r r r )rD r
incompleter s r r zStreamReader.readexactly sP
q55 IJJ J ? &/ ! 663$, !##y
D "4< 0 0
""$$$ 4ZCCC%%m44 4 4 4 4 4 4 4
$, !## t| ! ! &&D L bqb)**D RaR $$&&& r c | S r r rI s r __aiter__zStreamReader.__aiter__ s r c X K | d {V }|dk rt |S )Nr )r StopAsyncIteration)rD vals r __anext__zStreamReader.__anext__ s9 MMOO###### #::$ $
r )r )r )rb rc rd rk r rE r r rS r r r r r r r r r r r r r r r r r r s4 +$ " " " ",- - -$ * * *( ( ($ $ $- - -
. . .$ $ $, 8 >Y Y Y Y v1 1 1 1f' ' 'R r r r r )__all__r@ socketr r rh hasattr r r
r r r logr tasksr r r r r r
Protocolr9 r r r r r r r sf '
769 = <