*jւ S r SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J
r
SSK J r SSK J r SSK J
r
SS K Jr SS
K Jr SS K Jr SS K Jr SS
KJr S r " S S\R* \R, 5 r " S S\\R0 5 r " S S\\R4 5 r " S S\5 r " S S\\R: 5 r " S S\\\R> 5 r " S S \\\R> 5 r! " S S \
RD 5 r#g) 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 [ R " U5 U R S' UR 5 U R S' SU R ; a UR 5 U R S' g g ! [ R
a8 U R R 5 ( a [ R " SUSS9 N{f = f! [ R
a S U R S' g f = f)Nsocketsocknamezgetsockname() failed on %rTexc_infopeername) r TransportSocket_extra getsocknamer error_loop get_debugr
warning getpeername) transportsocks >/opt/alt/python313/lib64/python3.13/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$ A2 C 2A B>=B>#C'&C'c ^ \ rS rSrSr SU 4S jjrS rS rS rS r S r
S r \ R 4S
jrSS jrS rS
rS rSrU =r$ )_ProactorBasePipeTransport. z*Base class for pipe and socket transports.c > [ TU ] XQ5 U R U5 X l U R U5 X`l S U l S U l S U l SU l SU l
SU l SU l SU l
U R
b U R
R U 5 U R R! U R" R$ U 5 Ub, U R R! [& R( US 5 g g )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% #_ProactorBasePipeTransport.__init__2 s
%
(#
',$ ! << # LL &
T^^ ; ;TB JJ !E!E!'
/ c U R R /nU R c UR S5 O"U R ( a UR S5 U R b, UR SU R R 5 35 U R b UR SU R < 35 U R b UR SU R < 35 U R ( a' UR S[ U R 5 35 U R ( a UR S5 SR S R U5 5 $ )
Nclosedclosingzfd=zread=zwrite=zwrite_bufsize=z EOF writtenz<{}> )
r> __name__r' appendr/ filenor+ r, r* lenr1 formatjoin)r8 infos r __repr__#_ProactorBasePipeTransport.__repr__I s ''( :: KK !
]] KK " :: ! KK#djj / / 1 23 4 >> % KK% 12 3 ?? & KK& 34 5 << KK.T\\):(;< = KK
&}}SXXd^,,r@ c XR S' g )Npipe)r r8 r s r r& %_ProactorBasePipeTransport._set_extra[ s " Fr@ c Xl g Nr4 )r8 r: s r r( '_ProactorBasePipeTransport.set_protocol^ s !r@ c U R $ rS rT r8 s r get_protocol'_ProactorBasePipeTransport.get_protocola s ~~ r@ c U R $ rS )r/ rW s r
is_closing%_ProactorBasePipeTransport.is_closingd s }} r@ c F U R ( a g SU l U =R S-
sl U R ( d3 U R c& U R R U R S 5 U R b" U R R 5 S U l g g )NTr ) r/ r. r* r, r r3 _call_connection_lostr+ cancelrW s r close _ProactorBasePipeTransport.closeg sq ==
1 || 7 JJ !;!;T B >> % NN ! ! # !DN &r@ c t U R b+ U" SU < 3[ U S9 U R R 5 g g )Nzunclosed transport )source)r' ResourceWarningr` )r8 _warns r __del__"_ProactorBasePipeTransport.__del__r s5 :: ! 'x0/$ O JJ "r@ c > [ U[ 5 ( a6 U R R 5 ( a [ R
" SXSS9 O*U R R
UUU U R S.5 U R U5 g ! U R U5 f = f)Nz%r: %sTr )message exceptionr r: )
isinstanceOSErrorr r r
debugcall_exception_handlerr4 _force_close)r8 excri s r _fatal_error'_ProactorBasePipeTransport._fatal_errorw s~ ##w''::''))LL44H
11 &!$!% $ 3
c "D c "s A5B B c ~ U R bY U R R 5 ( d: Uc U R R S 5 OU R R U5 U R ( a U R
( a g SU l U =R S-
sl U R ( a! U R R 5 S U l U R ( a! U R R 5 S U l SU l
S U l U R R U R U5 g )NTr r )
_empty_waiterdone
set_result
set_exceptionr/ r0 r. r, r_ r+ r- r* r r3 r^ )r8 rp s r ro '_ProactorBasePipeTransport._force_close s )$2D2D2I2I2K2K{""--d3""005 ==T 9 9
1 ?? OO " " $ "DO >> NN ! ! # !DN
T 7 7=r@ c . U R ( a g U R R U5 [ U R S5 ( aG U R R 5 S:w a) U R R
[ R 5 U R R 5 S U l U R nUb UR U 5 S U l
SU l g ! [ U R S5 ( aG U R R 5 S:w a) U R R
[ R 5 U R R 5 S U l U R nUb UR U 5 S U l
SU l f = f)NshutdownT) r0 r4 connection_losthasattrr' rG rz r SHUT_RDWRr` r) _detach)r8 rp r= s r r^ 0_ProactorBasePipeTransport._call_connection_lost s' ' ' 0 NN * *3 / tzz:..4::3D3D3F"3L
##F$4$45 JJ DJ\\F!t$ # +/D ( tzz:..4::3D3D3F"3L
##F$4$45 JJ DJ\\F!t$ # +/D (s C! !B3Fc h U R nU R b U[ U R 5 -
nU$ rS )r- r* rH )r8 sizes r get_write_buffer_size0_ProactorBasePipeTransport.get_write_buffer_size s/ "" << # C % %D r@ ) r* r0 r/ r. r1 r- r4 r+ r) r' r, NNN)z Fatal error on pipe transport)rE
__module__ __qualname____firstlineno____doc__r% rL r& r( rX r[ r` warningswarnrf rq ro r^ r __static_attributes__
__classcell__r> s @r r! r! . sV 448$(/.-$#" " %MM
# >(0( r@ r! c \ ^ \ rS rSrSr S U 4S jjrS rS rS rS r S r
S S jr S
r U =r
$ )
_ProactorReadPipeTransport zTransport for read pipes.c > SU l SU l [ TU ]
XX4XV5 [ U5 U l U R R U R 5 SU l g )Nr{ TF) _pending_data_length_pausedr$ r% bytearray_datar r3
_loop_reading) r8 r9 r r: r; r< r= buffer_sizer> s r r% #_ProactorReadPipeTransport.__init__ sN $&!
XuE {+
T / /0 r@ c T U R ( + =( a U R ( + $ rS )r r/ rW s r
is_reading%_ProactorReadPipeTransport.is_reading s << 5
$55r@ c U R ( d U R ( a g SU l U R R 5 ( a [ R
" SU 5 g g )NTz%r pauses reading)r/ r r r r
rm rW s r
pause_reading(_ProactorReadPipeTransport.pause_reading sB ==DLL :: ! ! LL,d 3 "r@ c U R ( d U R ( d g SU l U R c& U R R U R
S 5 U R nSU l US: a4 U R R U R U R S U U5 U R R 5 ( a [ R " SU 5 g g )NFr{ z%r resumes reading) r/ r r+ r r3 r r _data_receivedr r r
rm )r8 lengths r resume_reading)_ProactorReadPipeTransport.resume_reading s == >> ! JJ !3!3T :**$&! B;
JJ !4!4djj&6I6 R :: ! ! LL-t 4 "r@ c H U R R 5 ( a [ R " SU 5 U R R 5 nU( d U R 5 g g ! [ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r r r
rm r4 eof_received
SystemExitKeyboardInterrupt
BaseExceptionrq r` )r8 keep_openrp s r
_eof_received(_ProactorReadPipeTransport._eof_received s :: ! ! LL*D 1 335I JJL -. H
J s A+ +B!B B!c U R ( a X l g US:X a U R 5 g [ U R [
R 5 ( a# [
R " U R U5 g U R R U5 g ! [ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nr z3Fatal error: protocol.buffer_updated() call failed.)
r r r rk r4 r BufferedProtocol _feed_data_to_buffered_protor r r rq
data_received)r8 datar rp s r r )_ProactorReadPipeTransport._data_received s << )/ % Q; dnni&@&@ A A
66t~~tL
NN ( ( . 12
!!##12
s !B C2C Cc SnS n Ub~ S U l UR 5 ( aR UR 5 nUS:X a US: a U R X25 g g [ [ U R 5 S U 5 nOUR 5 U R ( a US: a U R X25 g g U R ( d? U R R R U R U R 5 U l U R ( d% U R R U R 5 US: a U R X25 g g ! [ af nU R ( d U R# US5 S nANKU R R% 5 ( a [& R( " SSS9 S nANS nAf[* a nU R- U5 S nANS nAf[. a nU R# US5 S nANS nAf[0 R2 a U R ( d e Nf = f! US: a U R X25 f f = f)Nr{ r z"Fatal read error on pipe transportz*Read error on pipe transport while closingTr )r+ ru resultr bytes
memoryviewr r_ r/ r r _proactor recv_intor' add_done_callbackr ConnectionAbortedErrorrq r r
rm ConnectionResetErrorro rl r CancelledError)r8 futr r rp s r r (_ProactorReadPipeTransport._loop_reading s . 2 "&88:: ZZ\F { F {##D1 A !DJJ!7!@AD JJL}}2 {##D1 ) <H2 4F<7H2 <
H/ G H2
H/,H>H2 )H/,H2 .H//H2 2I )r r r r+ )NNNi rS )rE r r r r r% r r r r r r r r r s @r r r s4 #486; 64&5$ /212 12r@ r c ^ ^ \ rS rSrSrSrU 4S jrS rS
S jrS r S r
S r S
r S r
S rU =r$ ) _ProactorBaseWritePipeTransportiH zTransport for write pipes.Tc 4 > [ TU ] " U0 UD6 S U l g rS )r$ r% rt r8 argskwr> s r r% (_ProactorBaseWritePipeTransport.__init__N s
$%"% !r@ c [ U[ [ [ 45 ( d! [ S[ U5 R 35 eU R ( a [ S5 eU R b [ S5 eU( d g U R ( aJ U R [ R : a [ R " S5 U =R S-
sl
g U R c U R! [ U5 S9 g U R" ( d! [ U5 U l U R% 5 g U R" R' U5 U R% 5 g )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 )rk r r r TypeErrortyperE r1 RuntimeErrorrt r. r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
r r,
_loop_writingr* _maybe_pause_protocolextend)r8 r s r write%_ProactorBaseWritePipeTransport.writeR s
$ : >??Dz**+-.
. ;< < ) IJ J ??)"M"MM @A OOq O ?? "
E$K 0 $T?DL & & (
LL % & & (r@ c V Ub U R c U R ( a g S U l SU l U( a UR 5 Uc U R nS U l U( d U R ( a& U R
R
U R S 5 U R ( a) U R R [ R 5 U R 5 OU R
R R U R U5 U l U R R! 5 ( dF [# U5 U l U R R% U R& 5 U R) 5 O%U R R% U R& 5 U R* b* U R c U R* R- S 5 g g g ! [. a nU R1 U5 S nAg S nAf[2 a nU R5 US5 S nAg S nAff = f)Nr z#Fatal write error on pipe transport)r, r/ r- r r* r r3 r^ r1 r' rz r SHUT_WR_maybe_resume_protocolr sendru rH r r r rt rv r ro rl rq )r8 fr rp s r r -_ProactorBaseWritePipeTransport._loop_writingx s & J} !8T]] "DO"#D
||| # ==JJ(()C)CTJ$$JJ''7 ++-"&**"6"6";";DJJ"M++--*-d)D'OO55d6H6HI..0OO55d6H6HI!!-$//2I""--d3 3J-# # c " " J c#H I I Js) !G F8G
H()G??
H( H##H(c gNT rW s r
can_write_eof-_ProactorBaseWritePipeTransport.can_write_eof r@ c $ U R 5 g rS )r` rW s r write_eof)_ProactorBaseWritePipeTransport.write_eof s
r@ c & U R S 5 g rS ro rW s r abort%_ProactorBaseWritePipeTransport.abort $ r@ c U R b [ S5 eU R R 5 U l U R c U R R S 5 U R $ )NzEmpty waiter is already set)rt r r
create_futurer, rv rW s r _make_empty_waiter2_ProactorBaseWritePipeTransport._make_empty_waiter sY ) <= = !ZZ 5 5 7 ?? " ) )$ /!!!r@ c S U l g rS )rt rW s r _reset_empty_waiter3_ProactorBaseWritePipeTransport._reset_empty_waiter s
!r@ )r* rt r- r, NN)rE r r r r _start_tls_compatibler% r r r r r r r r r r s @r r r H s< $ "$)L'JR "" "r@ r c . ^ \ rS rSrU 4S jrS rSrU =r$ )_ProactorWritePipeTransporti c > [ TU ] " U0 UD6 U R R R U R
S5 U l U R R U R 5 g )N ) r$ r% r r recvr' r+ r _pipe_closedr s r r% $_ProactorWritePipeTransport.__init__ sO
$%"% --224::rB (():):;r@ c UR 5 ( a g U R ( a g S U l U R b U R [ 5 5 g U R
5 g rS ) cancelledr/ r+ r, ro BrokenPipeErrorr` )r8 r s r r (_ProactorWritePipeTransport._pipe_closed sE ==?? == ?? & o / 0 JJLr@ )r+ )rE r r r r% r r r r s @r r r s <
r@ r c h ^ \ rS rSrSrSr S U 4S jjrS rS rS r S
S jr
S
S jr S
S
jr S r
U =r$ )_ProactorDatagramTransporti i c > X@l S U l SU l [ TU ] XX5US9 [
R " 5 U l U R R U R 5 g )Nr )r; r< ) _addressrt _buffer_sizer$ r% collectionsdequer* r r3 r )r8 r9 r r: addressr; r< r> s r r% #_ProactorDatagramTransport.__init__ sX
! XEJ #((*
T / /0r@ c [ X5 g rS r rP s r r& %_ProactorDatagramTransport._set_extra
$%r@ c U R $ rS )r rW s r r 0_ProactorDatagramTransport.get_write_buffer_size s r@ c & U R S 5 g rS r rW s r r _ProactorDatagramTransport.abort r r@ c [ U[ [ [ 45 ( d [ S[ U5 5 eU R b* US U R 4; a [ SU R 35 eU R ( a[ U R ( aJ U R [ R : a [ R " S5 U =R S-
sl g U R R [ U5 U45 U =R [! U5 U R" - -
sl U R$ c U R' 5 U R) 5 g )Nz,data argument must be bytes-like object (%r)z!Invalid address: must be None or z!socket.sendto() raised exception.r )rk r r r r r r
ValueErrorr. r r r
r r* rF r rH _header_sizer, r r )r8 r addrs r sendto!_ProactorDatagramTransport.sendto s $ : >?? J J(
( == $dDMM5J)J 3DMM?CE
E ??t}})"M"MM BC OOq O
U4[$ /0 SY):): :: ?? "
""$r@ c U R ( a g S U l U( a UR 5 U R ( a" U R ( aI U R ( a8 U R
( a& U R R U R S 5 g U R R 5 u p#U =R [ U5 U R - - sl
U R b6 U R R R U R U5 U l O4U R R R! U R UUS9U l U R R# U R$ 5 U R' 5 g ! [( a% nU R* R- U5 S nAg S nAf[. a nU R1 US5 S nAg S nAff = f)N)r
z'Fatal write error on datagram transport)r. r, r r* r r/ r r3 r^ popleftr rH r r r r' r r r r rl r4 error_received Exceptionrq )r8 r r r
rp s r r (_ProactorDatagramTransport._loop_writing s] * #DO
<->!> > }}("&**"6"6";";DJJ<@#B #'**"6"6"="=djj>BCG #> #I
OO - -d.@.@ A ' ' )
/ NN ) )# . . N c#L M M Ns0 F BF B>F
G$F;;
G$G G$c S n U R ( a& U( a U R R UW5 g g S U l Ubg UR 5 nU R
( a( S n U( a U R R UW5 g g U R b
X@R p2OUu p#U R ( a& U( a U R R UW5 g g U R b@ U R R R U R U R 5 U l O?U R R R U R U R 5 U l U R b% U R R U R 5 U( a U R R UW5 g g ! [ a% nU R R! U5 S nANOS nAf[" R$ a U R
( d e Nzf = f! U( a U R R UW5 f f = frS )r. r4 datagram_receivedr+ r r/ r r r r r' max_sizerecvfromr r rl r r r )r8 r r r
resrp s r r (_ProactorDatagramTransport._loop_reading# s ' =H 00t< ? "DNjjl== D0 00t< - ==,!$mm$!$JD 00t< }}(!%!5!5!:!:4::;?=="J "&!5!5!>!>tzz?C}}"N ~~)001C1CD00t< / NN ) )# . .(( == ! 00t< sM G -G /G #B G /2H
H G0+H 0)H H H H &I)r r* r rt r+ r, r rS )rE r r r r r r% r& r r r r r r r r s @r r r s< HL59$( 1&! %4 *D)= )=r@ r c $ \ rS rSrSrS rS rSrg) _ProactorDuplexPipeTransportiO zTransport for duplex pipes.c g)NFr rW s r r *_ProactorDuplexPipeTransport.can_write_eofT s r@ c [ erS )NotImplementedErrorrW s r r &_ProactorDuplexPipeTransport.write_eofW s !!r@ r N)rE r r r r r r r r r@ r r r O s &"r@ r c r ^ \ rS rSrSr\R R r SU 4S jjr S r
S r S r Sr
U =r$ ) _ProactorSocketTransporti[ z Transport for connected sockets.c T > [ TU ] XX4XV5 [ R " U5 g rS )r$ r% r _set_nodelayr7 s r r% !_ProactorSocketTransport.__init__b s"
XuE &r@ c [ X5 g rS r rP s r r& #_ProactorSocketTransport._set_extrag r r@ c gr r rW s r r &_ProactorSocketTransport.can_write_eofj r r@ c U R ( d U R ( a g SU l U R c* U R R [
R 5 g g r )r/ r1 r, r' rz r r rW s r r "_ProactorSocketTransport.write_eofm sA ==D - - ?? " JJ / #r@ )r1 r )rE r r r r r
_SendfileMode
TRY_NATIVE_sendfile_compatibler% r& r r r r r s @r r# r# [ s9 +$22==48$('
&0 0r@ r# c ^ \ rS rSrU 4S jr S S jr S!SSSSSSS.S jjr S S jr S"S jr S"S
jr S"S jr
U 4S jr S
r S r
S rS#S jrS rS rS rS rS rS rS rS rS!S jrS r S$S jrS rS r S r S r U =r $ )%r iu c > [ TU ] 5 [ R " SUR R
5 Xl Xl S U l 0 U l UR U 5 U R 5 [ R " 5 [ R " 5 L a/ [ R " U R" R% 5 5 g g )NzUsing proactor: %s)r$ r% r
rm r> rE r _selector_self_reading_future_accept_futuresset_loop_make_self_pipe threadingcurrent_thread main_threadsignal
set_wakeup_fd_csockrG )r8 proactorr> s r r% BaseProactorEventLoop.__init__w s
)8+=+=+F+FG!!$(! ! $ # # %)>)>)@ @ !3!3!5 6 Ar@ Nc [ XX#XE5 $ rS )r# )r8 r r: r; r< r= s r _make_socket_transport,BaseProactorEventLoop._make_socket_transport s 'H(-7 7r@ F) server_sideserver_hostnamer< r= ssl_handshake_timeoutssl_shutdown_timeoutc ` [ R " XX4XVU U
S9n [ XU XxS9 U R $ )N)rD rE r< r= )r
SSLProtocolr# _app_transport) r8 rawsockr:
sslcontextr; rB rC r< r= rD rE ssl_protocols r _make_ssl_transport)BaseProactorEventLoop._make_ssl_transport s? ++
&;%9 ;
! ', =***r@ c [ XX#XE5 $ rS )r )r8 r r: r r; r< s r _make_datagram_transport.BaseProactorEventLoop._make_datagram_transport s )$h*09 9r@ c [ U XX45 $ rS )r r8 r r: r; r< s r _make_duplex_pipe_transport1BaseProactorEventLoop._make_duplex_pipe_transport s +D,0FK Kr@ c [ XX#U5 $ rS )r rS s r _make_read_pipe_transport/BaseProactorEventLoop._make_read_pipe_transport s )$hNNr@ c [ U XX45 $ rS )r rS s r _make_write_pipe_transport0BaseProactorEventLoop._make_write_pipe_transport s +4+/6J Jr@ c > U R 5 ( a [ S5 eU R 5 ( a g [ R " 5 [ R
" 5 L a [ R " S5 U R 5 U R 5 U R R 5 S U l
S U l [ TU ]- 5 g )Nz!Cannot close a running event loopr{ )
is_runningr is_closedr7 r8 r9 r: r; _stop_accept_futures_close_self_piper r` r2 r$ )r8 r> s r r` BaseProactorEventLoop.close s ?? BC C >> # # %)>)>)@ @ $
!!#
r@ c T # U R R X5 I S h vN $ N7frS )r r )r8 r ns r sock_recv BaseProactorEventLoop.sock_recv s ^^((1111 (&(c T # U R R X5 I S h vN $ N7frS )r r )r8 r bufs r sock_recv_into$BaseProactorEventLoop.sock_recv_into s ^^--d8888rf c T # U R R X5 I S h vN $ N7frS )r r )r8 r bufsizes r
sock_recvfrom#BaseProactorEventLoop.sock_recvfrom s ^^,,T;;;;rf c z # U( d [ U5 nU R R XU5 I S h vN $ N7frS )rH r
recvfrom_into)r8 r rh nbytess r sock_recvfrom_into(BaseProactorEventLoop.sock_recvfrom_into s. XF^^11$VDDDDs 2;9;c T # U R R X5 I S h vN $ N7frS )r r )r8 r r s r sock_sendall"BaseProactorEventLoop.sock_sendall s ^^((4444rf c X # U R R XSU5 I S h vN $ N7f)Nr )r r )r8 r r r s r sock_sendto!BaseProactorEventLoop.sock_sendto s$ ^^**4q'BBBBs !*(*c # U R ( a UR 5 S:w a [ S5 eU R R X5 I S h vN $ N7f)Nr z the socket must be non-blocking)_debug
gettimeoutr r connect)r8 r r s r sock_connect"BaseProactorEventLoop.sock_connect sA ;;4??,1 >? ?^^++D::::s AAAAc T # U R R U5 I S h vN $ N7frS )r acceptrP s r sock_accept!BaseProactorEventLoop.sock_accept s ^^**40000rf c # UR 5 n [ R " U5 R nU( a UOUnU( d g[ US5 nU( a [ X4- U5 OUn [ X75 nSn
[ X-
U5 nUS:: a U
UR U5 $ U R R XX85 I S h vN X8-
nX-
n
MU ! [ [ R 4 a n[ R
" S5 eS nAff = f! [ a [ R
" S5 ef = f Nj! UR U5 f = f7f)Nznot a regular filer l )rG AttributeErrorioUnsupportedOperationr SendfileNotAvailableErrorosfstatst_sizerl minseekr sendfile) r8 r fileoffsetcountrG errfsize blocksizeend_pos
total_sents r _sock_sendfile_native+BaseProactorEventLoop._sock_sendfile_native s8 M[[]F MHHV$,,E #E ;/ 05#fne,5V#
0) < >%
IIf nn--d&LLL#'
7 78 M 667KL L M M 667KL L M M
IIf si EC D AE9D- E! D- D+D- D)C??DE!D((E+D- -E Ec v # UR 5 nUR 5 UR 5 I S h vN U R UR X#USS9I S h vN UR 5 U( a UR
5 $ $ NQ N.! UR 5 U( a UR
5 f f = f7f)NF)fallback)r r r
sock_sendfiler' r r )r8 transpr r r r s r _sendfile_native&BaseProactorEventLoop._sendfile_native s **, ''))) ( ++FLL$5: , < <
& & ( %%'
*<
& & ( %%' s8 4B9BB9 B B
B *B9
B *B66B9c U R b! U R R 5 S U l U R R 5 S U l U R R 5 S U l U =R
S- sl g )Nr )r3 r_ _ssockr` r<
_internal_fdsrW s r r` &BaseProactorEventLoop._close_self_pipe sg $ $ 0 % % , , .(,D % a r@ c [ R " 5 u U l U l U R R S5 U R R S5 U =R
S-
sl g )NFr )r
socketpairr r< setblockingr rW s r r6 %BaseProactorEventLoop._make_self_pipe sN #)#4#4#6 T[ & & a r@ c | Ub UR 5 U R ULa g U R R U R S5 nXl UR U R 5 g ! [ R a g [ [ 4 a e [ a nU R SUU S.5 S nAg S nAff = f)Ni z.Error on reading from the event loop self pipe)ri rj r9 )
r r3 r r r r _loop_self_readingr r r r r rn )r8 r rp s r r (BaseProactorEventLoop._loop_self_reading s 9}
((1 ##DKK6A )* %
7 7 8 (( -. ' 'K )
s" "A- &A- -B;B; B66B;c U R nUc g UR S5 g ! [ a+ U R ( a [ R
" SSS9 g g f = f)N z3Fail to write a null byte into the self-pipe socketTr )r< r rl r{ r
rm )r8 csocks r _write_to_self$BaseProactorEventLoop._write_to_self2 sU = , JJu ,{{ 0&*, ,s $ 0AAc T ^ ^^^^^^^ SUUU UUUUU4S jjmT R T5 g )Nc > U bp U R 5 u pTR ( a [ R " STX!5 T" 5 nT b TR XT SSU0TT
T S9 OTR XSU0TS9 TR
5 ( a g TR R T 5 n U TR T R 5 ' U R T5 g ! [ a nT R 5 S:w a> TR SU[ R " T 5 S.5 T R! 5 S nAg TR ( a [ R " S T SS
9 S nAg S nAg S nAf[" R$ a T R! 5 g f = f) Nz#%r got a new connection from %r: %rTr )rB r< r= rD rE rG r{ zAccept failed on a socket)ri rj r zAccept failed on socket %rr )r r{ r
rm rM r@ r^ r r r4 rG r rl rn r r r` r r )
r connr
r: rp r9 protocol_factoryr8 r= r rD rE rK s
r r9 2BaseProactorEventLoop._start_serving..loopI sj #
*=!"JD{{ %J%+T9 / 1H!- 00 JD#-t"4V2G1E 1 G 33 #-t"4V 4 E >>##NN))$/ 78$$T[[]3##D)
6;;=B&//#>%("("8"8">1
JJLL[[LL!=!%6 ! ,,
s+ BC C
F
A
E#2'E##'F
F
rS )r3 ) r8 r r rK r= backlogrD rE r9 s ````` ``@r _start_serving$BaseProactorEventLoop._start_servingD s
$ * $ *L
t r@ c g rS r )r8
event_lists r _process_events%BaseProactorEventLoop._process_eventsq s r@ c U R R 5 H nUR 5 M U R R 5 g rS )r4 valuesr_ clear)r8 futures r r_ *BaseProactorEventLoop._stop_accept_futuresu s6 **113F MMO 4 ""$r@ c U R R UR 5 S 5 nU( a UR 5 U R R U5 UR
5 g rS )r4 poprG r_ r
_stop_servingr` )r8 r r s r r #BaseProactorEventLoop._stop_servingz sG %%))$++-> MMO $$T*
r@ )r4 r< r r2 r3 r r rS r )r )NNd NN) rE r r r r% r@ rM rP rT rW rZ r` rd ri rm rr ru rx r~ r r r r` r6 r r r r r_ r r r r s @r r r u s 7 =A267 9=
+ $t"&!%
+ CG9
BF*.K
@D(,O AE)-J (29<E 5C;
1 8
( 98,& >A-1,0+ Z
%
r@ r )$r __all__r r r r r: r7 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 ,@=!;!+!=!=@=F "#=#B#-#7#7 "0 9 > ) 3 304JK 5 5 Jr@