֦i܂ d Z dZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl m Z ddl m
Z
dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ d Z G d dej* ej, Z G d deej0 Z G d deej4 Z G d de Z G d deej: Z G d deeej> Z G d d eeej> Z! G d d e
jD Z#y) zEvent loop using a proactor and related classes.
A proactor is a "notify-on-completion" multiplexer. Currently a
proactor is only implemented on Windows with IOCP.
)BaseProactorEventLoop N ) base_events) constants)futures)
exceptions) protocols)sslproto)
transports)trsock)loggerc t j | | j d< |j | j d< d| j vr |j | j d< y y # t j
$ r5 | j j rt j d|d Y uw xY w# t j
$ r d | j d< Y y w xY w)Nsocketsocknamezgetsockname() failed on %rTexc_infopeername) r TransportSocket_extra getsocknamer error_loop get_debugr
warning getpeername) transportsocks 0/usr/lib64/python3.12/asyncio/proactor_events.py_set_socket_extrar s !'!7!7!=IX C'+'7'7'9 $ ))) 0+/+;+;+=I Z ( * << C ?? $ $ & NN,dT
CC || 0+/I Z ( 0s$ A/ B: /AB76B7:"C C c e Zd ZdZ d fd Zd Zd Zd Zd Zd Z d Z
e j fd Z
dd
Zd Zd Zd
Z xZS )_ProactorBasePipeTransportz*Base class for pipe and socket transports.c t | || | j | || _ | j | || _ d | _ d | _ d | _ d| _ d| _
d| _ d| _ d| _
| j
| j
j | j j! | j" j$ | |,| j j! t& j( |d y y )Nr F)super__init__
_set_extra_sock set_protocol_server_buffer _read_fut
_write_fut_pending_write
_conn_lost_closing_called_connection_lost _eof_written_attachr call_soon _protocolconnection_mader _set_result_unless_cancelledselfloopr protocolwaiterextraserver __class__s r r$ z#_ProactorBasePipeTransport.__init__2 s
%
(#
',$ ! << # LL "
T^^ ; ;TB JJ !E!E!'
/ c | j j g}| j |j d n | j r|j d | j ,|j d| j j | j |j d| j | j |j d| j | j r'|j dt | j | j r|j d dj d j | S )
Nclosedclosingzfd=zread=zwrite=zwrite_bufsize=z EOF writtenz<{}> )
r= __name__r& appendr. filenor* r+ r) lenr0 formatjoin)r7 infos r __repr__z#_ProactorBasePipeTransport.__repr__I s ''( :: KK !
]] KK " :: ! KK#djj / / 1 23 4 >> % KK% 12 3 ?? & KK& 34 5 << KK.T\\):(;< = KK
&}}SXXd^,,r> c " || j d< y )Npipe)r r7 r s r r% z%_ProactorBasePipeTransport._set_extra[ s " Fr> c || _ y Nr3 )r7 r9 s r r' z'_ProactorBasePipeTransport.set_protocol^ s !r> c | j S rO rP r7 s r get_protocolz'_ProactorBasePipeTransport.get_protocola s ~~ r> c | j S rO )r. rR s r
is_closingz%_ProactorBasePipeTransport.is_closingd s }} r> c . | j ry d| _ | xj dz
c_ | j s2| j &| j j | j d | j "| j j d | _ y y )NTr ) r. r- r) r+ r r2 _call_connection_lostr* cancelrR s r closez _ProactorBasePipeTransport.closeg sq ==
1 || 7 JJ !;!;T B >> % NN ! ! # !DN &r> c v | j - |d| t | | j j y y )Nzunclosed transport )source)r& ResourceWarningrY )r7 _warns r __del__z"_ProactorBasePipeTransport.__del__r s5 :: ! 'x0/$ O JJ "r> c 0 t |t r4| j j rDt j
d| |d n*| j j
||| | j d | j | y # | j | w xY w)Nz%r: %sTr )message exceptionr r9 )
isinstanceOSErrorr r r
debugcall_exception_handlerr3 _force_close)r7 excr` s r _fatal_errorz'_ProactorBasePipeTransport._fatal_errorw sy ##w'::'')LL44H
11 &!$!% $ 3
c "D c "s A.B Bc H | j S| j j s9| | j j d n| j j | | j r
| j
ry d| _ | xj dz
c_ | j r!| j j d | _ | j r!| j j d | _ d| _
d | _ | j j | j | y )NTr r )
_empty_waiterdone
set_result
set_exceptionr. r/ r- r+ rX r* r, r) r r2 rW )r7 rg s r rf z'_ProactorBasePipeTransport._force_close s )$2D2D2I2I2K{""--d3""005 ==T 9 9
1 ?? OO " " $ "DO >> NN ! ! # !DN
T 7 7=r> c | j ry | j j | t | j d rF| j j dk7 r)| j j
t j | j j d | _ | j }||j d | _
d| _ y # t | j d rF| j j dk7 r)| j j
t j | j j d | _ | j }||j d | _
d| _ w xY w)NshutdownT) r/ r3 connection_losthasattrr& rE ro r SHUT_RDWRrY r( _detach)r7 rg r< s r rW z0_ProactorBasePipeTransport._call_connection_lost s ' ' 0 NN * *3 / tzz:.4::3D3D3F"3L
##F$4$45 JJ DJ\\F! # +/D ( tzz:.4::3D3D3F"3L
##F$4$45 JJ DJ\\F! # +/D (s C B+E?c f | j }| j |t | j z
}|S rO )r, r) rF )r7 sizes r get_write_buffer_sizez0_ProactorBasePipeTransport.get_write_buffer_size s/ "" << # C % %D r> NNN)z Fatal error on pipe transport)rC
__module__ __qualname____doc__r$ rJ r% r' rS rU rY warningswarnr^ rh rf rW rw
__classcell__r= s @r r! r! . sQ 448$(/.-$#" " %MM
# >(0(r> r! c N e Zd ZdZ d fd Zd Zd Zd Zd Zd Z d
dZ
xZ S ) _ProactorReadPipeTransportzTransport for read pipes.c d| _ d| _ t |
|||||| t | | _ | j j | j d| _ y )Nrp TF) _pending_data_length_pausedr# r$ bytearray_datar r2
_loop_reading) r7 r8 r r9 r: r; r< buffer_sizer= s r r$ z#_ProactorReadPipeTransport.__init__ sT $&!
tXvufE {+
T / /0 r> c : | j xr
| j S rO )r r. rR s r
is_readingz%_ProactorReadPipeTransport.is_reading s << 5
$55r> c | j s | j ry d| _ | j j rt j
d| y y )NTz%r pauses reading)r. r r r r
rd rR s r
pause_readingz(_ProactorReadPipeTransport.pause_reading s? ==DLL :: ! LL,d 3 "r> c | j s | j sy d| _ | j &| j j | j
d | j }d| _ |dkD r4| j j | j | j d | | | j j rt j d| y y )NFrp z%r resumes reading) r. r r* r r2 r r _data_receivedr r r
rd )r7 lengths r resume_readingz)_ProactorReadPipeTransport.resume_reading s == >> ! JJ !3!3T :**$&! B;
JJ !4!4djj&6I6 R :: ! LL-t 4 "r> c . | j j rt j d| | j j }|s| j y y # t t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r r r
rd r3 eof_received
SystemExitKeyboardInterrupt
BaseExceptionrh rY )r7 keep_openrg s r
_eof_receivedz(_ProactorReadPipeTransport._eof_received s :: ! LL*D 1 335I JJL -. H
J s A B8BBc | j r| j dk( sJ || _ y |dk( r| j y t | j t
j r" t j | j | y | j j | y # t t f$ r t $ r }| j |d Y d }~y d }~ww xY w)Nrp r z3Fatal error: protocol.buffer_updated() call failed.)
r r r rb r3 r BufferedProtocol _feed_data_to_buffered_protor r r rh
data_received)r7 datar rg s r r z)_ProactorReadPipeTransport._data_received s << ,,2 22(.D % Q; dnni&@&@ A
66t~~tL
NN ( ( . 12
!!##12
s ! B C6C
Cc d}d } || j |u s| j | j sJ d | _ |j rQ|j }|dk( r |dkD r| j || y y t t
| j d | }n|j | j r |dkD r| j || y y | j s?| j j j | j | j | _ | j s&| j j | j |dkD r| j || y y # t $ rZ}| j s| j# |d n1| j j% rt' j( dd Y d }~wd }~wt* $ r}| j- | Y d }~d }~wt. $ r }| j# |d Y d }~d }~wt0 j2 $ r | j s Y w xY w# |dkD r| j || w w xY w)Nrp r z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr )r* r. rk resultr bytes
memoryviewr rX r r _proactor recv_intor& add_done_callbackr ConnectionAbortedErrorrh r r
rd ConnectionResetErrorrf rc r CancelledError)r7 futr r rg s r r z(_ProactorReadPipeTransport._loop_reading s . 2~~, 1G15 @ @!%88: ZZ\F { F {##D&1 A !DJJ!7!@AD JJL}}2 {##D&1 ) <E$ A E$ 2H0 $ H--AG=H0 H-G$ H0 $ H-0HH0 #H-*H0 ,H--H0 0I
)NNNi rO ) rC ry rz r{ r$ r r r r r r r~ r s @r r r s/ #486; 64&5$ /212r> r c R e Zd ZdZdZ fdZd Zd dZd Zd Z d Z
d Z d
Z xZ
S ) _ProactorBaseWritePipeTransportzTransport for write pipes.Tc 2 t | |i | d | _ y rO )r# r$ rj r7 argskwr= s r r$ z(_ProactorBaseWritePipeTransport.__init__N s
$%"% !r> c t |t t t f s!t dt | j | j r t d | j t d |sy | j rH| j t j k\ rt j d | xj dz
c_
y | j *| j J | j# t | y | j s!t | | _ | j% y | j j' | | j% y )Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progressz socket.send() raised exception.r )r )rb r r r TypeErrortyperC r0 RuntimeErrorrj r- r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
r r+ r)
_loop_writing_maybe_pause_protocolextend)r7 r s r writez%_ProactorBaseWritePipeTransport.writeR s $ : >?Dz**+-.
. ;< < ) IJ J ??)"M"MM @A OOq O ?? "<<' '' E$K 0 $T?DL & & (
LL % & & (r> c N || j
| j ry || j u sJ d | _ d| _ |r|j || j }d | _ |sx| j r&| j
j
| j d | j r)| j j t j | j n| j
j j | j | | _ | j j! sW| j dk( sJ t# | | _ | j j% | j& | j) n%| j j% | j& | j* )| j | j* j- d y y y # t. $ r}| j1 | Y d }~y d }~wt2 $ r }| j5 |d Y d }~y d }~ww xY w)Nr z#Fatal write error on pipe transport)r+ r. r, r r) r r2 rW r0 r& ro r SHUT_WR_maybe_resume_protocolr sendrk rF r r r rj rl r rf rc rh )r7 fr rg s r r z-_ProactorBaseWritePipeTransport._loop_writingx s & J} !8T]] ' '' "DO"#D
||| # ==JJ(()C)CTJ$$JJ''7 ++-"&**"6"6";";DJJ"M++- ..!333*-d)D'OO55d6H6HI..0OO55d6H6HI!!-$//2I""--d3 3J-# # c " " J c#H I I Js) G F=G H$&G<< H$H H$c yNT rR s r
can_write_eofz-_ProactorBaseWritePipeTransport.can_write_eof r> c $ | j y rO )rY rR s r write_eofz)_ProactorBaseWritePipeTransport.write_eof s
r> c & | j d y rO rf rR s r abortz%_ProactorBaseWritePipeTransport.abort $ r> c | j t d | j j | _ | j | j j d | j S )NzEmpty waiter is already set)rj r r
create_futurer+ rl rR s r _make_empty_waiterz2_ProactorBaseWritePipeTransport._make_empty_waiter sY ) <= = !ZZ 5 5 7 ?? " ) )$ /!!!r> c d | _ y rO )rj rR s r _reset_empty_waiterz3_ProactorBaseWritePipeTransport._reset_empty_waiter s
!r> NN)rC ry rz r{ _start_tls_compatibler$ r r r r r r r r~ r s @r r r H s7 $ "$)L'JR ""r> r c $ e Zd Z fdZd Z xZS )_ProactorWritePipeTransportc t | |i | | j j j | j
d | _ | j j | j y )N ) r# r$ r r recvr& r* r _pipe_closedr s r r$ z$_ProactorWritePipeTransport.__init__ sO
$%"% --224::rB (():):;r> c B |j ry |j dk( sJ | j r| j J y || j u sJ || j f d | _ | j | j t
y | j y )Nr> ) cancelledr r. r* r+ rf BrokenPipeErrorrY )r7 r s r r z(_ProactorWritePipeTransport._pipe_closed s ==? zz|s""" ==>>) )) dnn$;sDNN&;;$ ?? & o / 0 JJLr> )rC ry rz r$ r r~ r s @r r r s
<
r> r c R e Zd ZdZ d fd Zd Zd Zd Zd
dZd
dZ d
dZ
xZ S ) _ProactorDatagramTransporti c || _ d | _ d| _ t | ||||| t j | _ | j j | j y )Nr )r: r; ) _addressrj _buffer_sizer# r$ collectionsdequer) r r2 r )r7 r8 r r9 addressr: r; r= s r r$ z#_ProactorDatagramTransport.__init__ s^
! tXfEJ #((*
T / /0r> c t | | y rO r rM s r r% z%_ProactorDatagramTransport._set_extra $%r> c | j S rO )r rR s r rw z0_ProactorDatagramTransport.get_write_buffer_size s r> c & | j d y rO r rR s r r z _ProactorDatagramTransport.abort r r> c r t |t t t f st dt | |sy | j (|d | j fvrt d| j | j rT| j rH| j t j k\ rt j d | xj dz
c_ y | j j t | |f | xj t! | z
c_ | j" | j% | j' y )Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r )rb r r r r r r
ValueErrorr- r r r
r r) rD r rF r+ r r )r7 r addrs r sendtoz!_ProactorDatagramTransport.sendto s $ : >? J J(
( == $dDMM5J)J 3DMM?CE
E ??t}})"M"MM BC OOq O
U4[$ /0 SY& ?? "
""$r> c | j ry || j u sJ d | _ |r|j | j r| j r?| j r3| j
r&| j j | j d y | j j \ }}| xj t | z c_
| j 6| j j j | j | | _ n7| j j j | j || | _ | j j! | j" | j% y # t& $ r%}| j( j+ | Y d }~y d }~wt, $ r }| j/ |d Y d }~y d }~ww xY w)N)r z'Fatal write error on datagram transport)r- r+ r r) r r. r r2 rW popleftr rF r r r& r r r r rc r3 error_received Exceptionrh )r7 r r r rg s r r z(_ProactorDatagramTransport._loop_writing sd *$//) )) "DO
<>S(T^^-C-1]]
< < "DNjjl== D0 00t< - ==,!$dmm$D!$JD$ 00t< }}(!%!5!5!:!:4::;?=="J "&!5!5!>!>tzz?C}}"N ~~)001C1CD00t< / NN ) )# . .(( == ! 00t< sN G AG !,G .B G 92H HG4/H 4#HH HH !H>rx rO ) rC ry rz r r$ r% rw r r r r r~ r s @r r r s2 H59$( 1&! %: *D)=r> r c e Zd ZdZd Zd Zy) _ProactorDuplexPipeTransportzTransport for duplex pipes.c y)NFr rR s r r z*_ProactorDuplexPipeTransport.can_write_eofU s r> c t rO )NotImplementedErrorrR s r r z&_ProactorDuplexPipeTransport.write_eofX s !!r> N)rC ry rz r{ r r r r> r r r P s &"r> r c f e Zd ZdZej
j Z d fd Zd Z d Z
d Z xZ S )_ProactorSocketTransportz Transport for connected sockets.c X t | |||||| t j | y rO )r# r$ r _set_nodelayr6 s r r$ z!_ProactorSocketTransport.__init__c s(
tXvufE &r> c t | | y rO r rM s r r% z#_ProactorSocketTransport._set_extrah r r> c yr r rR s r r z&_ProactorSocketTransport.can_write_eofk r r> c | j s | j ry d| _ | j *| j j t
j y y r )r. r0 r+ r& ro r r rR s r r z"_ProactorSocketTransport.write_eofn sA ==D - - ?? " JJ / #r> rx )
rC ry rz r{ r
_SendfileMode
TRY_NATIVE_sendfile_compatibler$ r% r r r~ r s @r r r \ s4 +$22==48$('
&0r> r c e Zd Z fdZ d dZ d ddddddddZ d dZ d dZ d d Z d d
Z fd Z
d Z d
Z d Z
d!dZd Zd Zd Zd Zd Zd Zd Zd Zd dZd Z d"dZd Zd Zd Z xZ S )#r c t | t j d|j j
|| _ || _ d | _ i | _ |j | | j t j t j u r.t j | j" j% y y )NzUsing proactor: %s)r# r$ r
rd r= rC r _selector_self_reading_future_accept_futuresset_loop_make_self_pipe threadingcurrent_thread main_threadsignal
set_wakeup_fd_csockrE )r7 proactorr= s r r$ z BaseProactorEventLoop.__init__x s
)8+=+=+F+FG!!$(! ! $ # # %)>)>)@ @ !3!3!5 6 Ar> Nc " t | ||||| S rO )r )r7 r r9 r: r; r< s r _make_socket_transportz,BaseProactorEventLoop._make_socket_transport s 'dHf(-v7 7r> F) server_sideserver_hostnamer; r< ssl_handshake_timeoutssl_shutdown_timeoutc
t t j | |||||| |
} t | || || | j S )N)r r r; r< )r
SSLProtocolr _app_transport) r7 rawsockr9
sslcontextr: r r r; r< r r ssl_protocols r _make_ssl_transportz)BaseProactorEventLoop._make_ssl_transport sI ++h
F_&;%9 ;
!w ',V =***r> c " t | ||||| S rO )r )r7 r r9 r r: r; s r _make_datagram_transportz.BaseProactorEventLoop._make_datagram_transport s )$h*0%9 9r> c t | |||| S rO )r r7 r r9 r: r; s r _make_duplex_pipe_transportz1BaseProactorEventLoop._make_duplex_pipe_transport s +D,0(FEK Kr> c t | |||| S rO )r r s r _make_read_pipe_transportz/BaseProactorEventLoop._make_read_pipe_transport s )$hNNr> c t | |||| S rO )r r s r _make_write_pipe_transportz0BaseProactorEventLoop._make_write_pipe_transport s +4+/65J Jr> c | j r t d | j ry t j t j
u rt
j d | j | j | j j d | _
d | _ t | - y )Nz!Cannot close a running event looprp )
is_runningr is_closedr r r r
r _stop_accept_futures_close_self_piper rY r r# )r7 r= s r rY zBaseProactorEventLoop.close s ?? BC C >> # # %)>)>)@ @ $
!!#
r> c V K | j j || d { S 7 wrO )r r )r7 r ns r sock_recvz BaseProactorEventLoop.sock_recv s# ^^((q1111 )')c V K | j j || d { S 7 wrO )r r )r7 r bufs r sock_recv_intoz$BaseProactorEventLoop.sock_recv_into s# ^^--dC8888r- c V K | j j || d { S 7 wrO )r r )r7 r bufsizes r
sock_recvfromz#BaseProactorEventLoop.sock_recvfrom s# ^^,,T7;;;;r- c r K |s t | }| j j ||| d { S 7 wrO )rF r
recvfrom_into)r7 r r/ nbytess r sock_recvfrom_intoz(BaseProactorEventLoop.sock_recvfrom_into s1 XF^^11$VDDDDs .757c V K | j j || d { S 7 wrO )r r )r7 r r s r sock_sendallz"BaseProactorEventLoop.sock_sendall s# ^^((t4444r- c Z K | j j ||d| d { S 7 w)Nr )r r )r7 r r r s r sock_sendtoz!BaseProactorEventLoop.sock_sendto s' ^^**4q'BBBBs "+)+c K | j r |j dk7 r t d | j j || d { S 7 w)Nr z the socket must be non-blocking)_debug
gettimeoutr r connect)r7 r r s r sock_connectz"BaseProactorEventLoop.sock_connect sD ;;4??,1 >? ?^^++D'::::s A
A A
Ac T K | j j | d { S 7 wrO )r acceptrM s r sock_acceptz!BaseProactorEventLoop.sock_accept s! ^^**40000s (&(c K |j } t
j | j }|r|n|}|syt |d }|rt ||z | n|} t || }d}
t | |z
| }|dk r|
|
dkD r|j | S S | j j |||| d { ||z
}|
|z
}
^# t t j f$ r}t j
d d }~ww xY w# t $ r t j
d w xY w7 g# |
dkD r|j | w w xY ww)Nznot a regular filer l )rE AttributeErrorioUnsupportedOperationr SendfileNotAvailableErrorosfstatst_sizerc minseekr sendfile) r7 r fileoffsetcountrE errfsize blocksizeend_pos
total_sents r _sock_sendfile_nativez+BaseProactorEventLoop._sock_sendfile_native s_ M[[]F MHHV$,,E #E ;/ 05#fune,5VU#
" & 0) < >%
A~ &! nn--dD&)LLL)#i'
7 78 M 667KL L M M 667KL L M M A~ &! sh E C
D 6E +D$ E !D$ :D";D$
C=#C88C==E D E "D$ $D==E c j K |j }|j |j d { | j |j |||d d { |j |r|j
S S 7 P7 )# |j |r|j
w w xY ww)NF)fallback)r r r
sock_sendfiler& r r )r7 transprO rP rQ r s r _sendfile_nativez&BaseProactorEventLoop._sendfile_native s **, ''))) ( ++FLL$5: , < <
& & ( %%'
*<
& & ( %%' s8 4B3BB3#B B B #%B3 B %B00B3c | j !| j j d | _ | j j d | _ | j j d | _ | xj
dz c_ y )Nr )r rX _ssockrY r
_internal_fdsrR s r r) z&BaseProactorEventLoop._close_self_pipe sg $ $ 0 % % , , .(,D % a r> c t j \ | _ | _ | j j d | j j d | xj
dz
c_ y )NFr )r
socketpairr^ r setblockingr_ rR s r r z%BaseProactorEventLoop._make_self_pipe sN #)#4#4#6 T[ & & a r> c t ||j | j |ury | j j | j d }|| _ |j | j y # t j $ r Y y t t f$ r t $ r }| j d|| d Y d }~y d }~ww xY w)Ni z.Error on reading from the event loop self pipe)r` ra r8 )
r r r r r^ r _loop_self_readingr r r r r re )r7 r rg s r rd z(BaseProactorEventLoop._loop_self_reading s 9}
((1 ##DKK6A )*D %
7 7 8 (( -. ' 'K )
s" A, &A, ,B7B7B22B7c | j }|y |j d y # t $ r( | j rt j
dd Y y Y y w xY w)N z3Fail to write a null byte into the self-pipe socketTr )r r rc r= r
rd )r7 csocks r _write_to_selfz$BaseProactorEventLoop._write_to_self4 sU = , JJu ,{{ 0&*, ,s # ,AAc P d fd j y )Nc
| s| j \ }}j rt j d|| } j || dd|i
nj ||d|i j
ry j j } | j j < | j y # t $ r} j dk7 r9j d|t j d j! n.j r t j d d
Y d }~y Y d }~y Y d }~y d }~wt" j$ $ r j! Y y w xY w) Nz#%r got a new connection from %r: %rTr )r r; r< r r r rp zAccept failed on a socket)r` ra r zAccept failed on socket %rr )r r= r
rd r r r' r rB r rE r rc re r r rY r r )
r connr r9 rg r8 protocol_factoryr7 r< r r r r s
r r8 z2BaseProactorEventLoop._start_serving..loopK sw #
*=!"JD${{ %J%+T49 / 1H!- 00 (JD#-t"4V2G1E 1 G 33 (#-t"4V 4 E >>#NN))$/ 78$$T[[]3##D)
6;;=B&//#>%("("8"8">1
JJL[[LL!=!%6 6 ! ! ,,
s% BC C F A0E&FFrO )r2 ) r7 rl r r r< backlogr r r8 s ````` ``@r _start_servingz$BaseProactorEventLoop._start_servingF s
$ * $ *L
t r> c y rO r )r7
event_lists r _process_eventsz%BaseProactorEventLoop._process_eventss s r> c | j j D ] }|j | j j y rO )r valuesrX clear)r7 futures r r( z*BaseProactorEventLoop._stop_accept_futuresw s6 **113F MMO 4 ""$r> c | j j |j d }|r|j | j j | |j
y rO )r poprE rX r
_stop_servingrY )r7 r ru s r rx z#BaseProactorEventLoop._stop_serving| sG %%))$++-> MMO $$T*
r> rx rO r )r )NNd NN) rC ry rz r$ r r r r r" r$ rY r, r0 r3 r7 r9 r; r@ rC rW r\ r) r rd rh rn rq r( rx r~ r s @r r r v s 7 =A267 9=
+ $t"&!%
+ CG9
BF*.K
@D(,O AE)-J (29<E 5C;
1":
( 98,& >A-1,0+ Z
%
r> r )$r{ __all__rF rI r r| r
r r r r r r r r
r r logr
r _FlowControlMixin
BaseTransportr!
ReadTransportr WriteTransportr r DatagramTransportr Transportr r
BaseEventLoopr r r> r r s #
0$D!=!=!+!9!9DNP2!;!+!9!9P2fk"&@&0&?&?k"\"A ,A=!;!+!=!=A=H "#=#B#-#7#7 "0 9 > ) 3 304KK 5 5 Kr>