*j
S r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK
r
SSK J
r
SSK Jr SSK Jr SSK Jr SSK Jr SS K Jr SS
K Jr SS K Jr SS KJr \" \R S
5 r\( a \R2 " S5 rS r " S S\
R: 5 r " S S\R> \R@ 5 r! " S S\!5 r" " S S\!\RF 5 r$g! \ a Sr
Nf = f! \ a Sr Nrf = f))BaseSelectorEventLoop N ) base_events) constants)events)futures) protocols)sslproto)
transports)trsock)loggersendmsg
SC_IOV_MAXFc v U R U5 n[ UR U- 5 $ ! [ a gf = fNF)get_keyboolr KeyError)selectorfdeventkeys >/opt/alt/python313/lib64/python3.13/asyncio/selector_events.py_test_selector_eventr * sA ( r" CJJ&'' s +
88c 4 ^ \ rS rSrS4U 4S jjrS4SSS.S jjr S4SSSS\R \R S.S jjr S5S jr
U 4S
jr S r S r
S
rS rS rSSS\R \R 4S jrSSS\R \R 4S jrSS\R \R 4S jrS rS rS rS rS rS rS rS rS r S r S4S jr S r S r S! r!S" r"S# r#S6S$ jr$S% r%S& r&S' r'S( r(S) r)S* r*S+ r+S4S, jr,S- r-S. r.S/ r/S0 r0S1 r1S2 r2S3r3U =r4$ )7r 5 Nc > [ TU ] 5 Uc [ R " 5 n[ R
" SUR R 5 Xl U R 5 [ R " 5 U l g )NzUsing selector: %s)
super__init__ selectorsDefaultSelectorr
debug __class____name__ _selector_make_self_pipeweakrefWeakValueDictionary _transports)selfr r# s r r BaseSelectorEventLoop.__init__; s_
002H )8+=+=+F+FG! "668 extraserverc > U R U5 [ XX#XE5 $ N)_ensure_fd_no_transport_SelectorSocketTransport)r* sockprotocolwaiterr. r/ s r _make_socket_transport,BaseSelectorEventLoop._make_socket_transportE s$ $$T*'H(-7 7r, F) server_sideserver_hostnamer. r/ ssl_handshake_timeoutssl_shutdown_timeoutc U R U5 [ R " XX4XVU U
S9n [ XU XxS9 U R $ )N)r; r< r- )r2 r
SSLProtocolr3 _app_transport) r* rawsockr5
sslcontextr6 r9 r: r. r/ r; r< ssl_protocols r _make_ssl_transport)BaseSelectorEventLoop._make_ssl_transportK sM
$$W- ++ J "7!5
! ', =***r, c @ U R U5 [ XUX4U5 $ r1 )r2 _SelectorDatagramTransport)r* r4 r5 addressr6 r. s r _make_datagram_transport.BaseSelectorEventLoop._make_datagram_transport] s( $$T*)$h*15B Br, c > U R 5 ( a [ S5 eU R 5 ( a g U R 5 [ TU ] 5 U R b" U R R 5 S U l g g )Nz!Cannot close a running event loop)
is_running RuntimeError is_closed_close_self_piper closer% r* r# s r rO BaseSelectorEventLoop.closec sg ?? BC C >>
>> % NN " !DN &r, c U R U R R 5 5 U R R 5 S U l U R R 5 S U l U =R
S- sl g )Nr )_remove_reader_ssockfilenorO _csock
_internal_fdsr* s r rN &BaseSelectorEventLoop._close_self_pipen s\ DKK . . 01 a r, c F [ R " 5 u U l U l U R R S5 U R R S5 U =R
S-
sl U R
U R R 5 U R 5 g )NFr ) socket
socketpairrT rV setblockingrW _add_readerrU _read_from_selfrX s r r& %BaseSelectorEventLoop._make_self_pipev sq #)#4#4#6 T[ & & a ++-t/C/CDr, c g r1 r* datas r _process_self_data(BaseSelectorEventLoop._process_self_data~ s r, c U R R S5 nU( d g U R U5 M7 ! [ a ME [ a g f = f)Ni )rT recvre InterruptedErrorBlockingIOErrorrc s r r_ %BaseSelectorEventLoop._read_from_self sV
{{''-''- $
"
s "9 9
A AAc 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 socketTexc_info)rV sendOSError_debugr
r" )r* csocks r _write_to_self$BaseSelectorEventLoop._write_to_self sU = , JJu ,{{ 0&*, ,s $ 0AAd c ` U R UR 5 U R XX4UXg5 g r1 )r^ rU _accept_connection)r* protocol_factoryr4 rA r/ backlogr; r< s r _start_serving$BaseSelectorEventLoop._start_serving s-
(?(?)W. Fr, c
[ US- 5 Hy n UR 5 u pU R ( a [ R " SXJU 5 U R S5 SU
0n U R
XXUXg5 n U R U 5 M{ g ! [ a M [ [ 4 a g [ a n
U
R [ R [ R [ R [ R 4; a} U R# SU
[$ R& " U5 S.5 U R) UR+ 5 5 U R- [. R0 U R2 XX4XVU5 S n
A
GMo e S n
A
ff = f)Nr z#%r got a new connection from %r: %rFpeernamez&socket.accept() out of system resource)message exceptionr[ )rangeacceptrr r
r" r] _accept_connection2 create_taskConnectionAbortedErrorrj ri rq errnoEMFILEENFILEENOBUFSENOMEMcall_exception_handlerr TransportSocketrS rU
call_laterr ACCEPT_RETRY_DELAYr{ )r* ry r4 rA r/ rz r; r< _connaddrr. r excs r rx (BaseSelectorEventLoop._accept_connection sU w{#A&
) ![[]
;;LL!F!'t5 ': $T* 11$Ev)A (O $ *
#%56
99 u||!& !> >
//#K%("("8"8">1
''
6OOI$@$@$($7$7$4J$+$8 : : '
s+ A B
FF, F5CE?>E??Fc # S nS n U" 5 nU R 5 n
U( a U R X(XJSX5UUS9 n OU R X(XUS9n U
I S h vN g N! [ a U R 5 S n
e f = f! [
[ 4 a e [ aD n U R ( a) SU S.n Ub XS' U b XS' U R U 5 S n A g S n A g S n A ff = f7f)NT)r6 r9 r. r/ r; r< )r6 r. r/ z3Error on transport creation for incoming connection)r r r5 transport)
create_futurerC r7
BaseExceptionrO
SystemExitKeyboardInterruptrr r )
r* ry r r. rA r/ r; r< r5 r r6 r contexts
r r )BaseSelectorEventLoop._accept_connection2 s
& 5')H'')F 4 4J $E*?)= 5 ? ! 7 76! 8 #
!
-. 5{{ N!$
'*2J' (+4K(++G44 5sS C AA;
A AA C A A88A; ;C5C
C CC c N Un[ U[ 5 ( d [ UR 5 5 nU R R U5 nU( a) UR 5 ( d [ SU< SU< 35 eg g ! [ [ [
4 a [ SU< 35 S ef = f)NzInvalid file object: zFile descriptor z is used by transport )
isinstanceintrU AttributeError TypeError
ValueErrorr) get
is_closingrL )r* r rU r s r r2 -BaseSelectorEventLoop._ensure_fd_no_transport s &#&&
K V]]_- $$((0 Y 1 1 3 3 "2&(> -!"
" 49 #Iz:
K #8!?@dJ
Ks A> >&B$c U R 5 [ R " X#U S 5 nU R R 5 R U5 nUc/ U R R
U[ R US 45 U$ UR UR snu pxU R R X[ R - XH45 Ub UR 5 U$ r1 )
_check_closedr Handler% get_mapr registerr
EVENT_READrd modifycancel r* r callbackargshandler maskreaderwriters r r^ !BaseSelectorEventLoop._add_reader s xtT:nn$$&**2. ; NN # #B (<(<%+TN
4
&)ZZ "D"6 NN ! !"Y-A-A&A#)"2
4!
r, c U R 5 ( a gU R R 5 R U5 nUc gUR UR
snu pEU[ R ) - nU( d U R R U5 O U R R XS U45 Ub UR 5 ggNFT) rM r% r r r rd r r
unregisterr r r* r r r r r s r rS $BaseSelectorEventLoop._remove_reader% s >> nn$$&**2. ;!$SXX v %%%% NN % %b ) NN ! !"T6N ; MMOr, c U R 5 [ R " X#U S 5 nU R R 5 R U5 nUc/ U R R
U[ R S U45 U$ UR UR snu pxU R R X[ R - Xt45 Ub UR 5 U$ r1 ) r r r r% r r r r EVENT_WRITErd r r r s r _add_writer!BaseSelectorEventLoop._add_writer8 s xtT:nn$$&**2. ; NN # #B (=(=%)6N
4
&)ZZ "D"6 NN ! !"Y-B-B&B#)"2
4!
r, c U R 5 ( a gU R R 5 R U5 nUc gUR UR
snu pEU[ R ) - nU( d U R R U5 O U R R XUS 45 Ub UR 5 ggr ) rM r% r r r rd r r r r r r s r _remove_writer$BaseSelectorEventLoop._remove_writerG s >> nn$$&**2. ;!$SXX v &&&& NN % %b ) NN ! !"VTN ; MMOr, c L U R U5 U R " X/UQ76 g r1 )r2 r^ r* r r r s r
add_reader BaseSelectorEventLoop.add_reader\ # $$R( --r, c F U R U5 U R U5 $ r1 )r2 rS r* r s r
remove_reader#BaseSelectorEventLoop.remove_readera ! $$R(""2&&r, c L U R U5 U R " X/UQ76 g r1 )r2 r r s r
add_writer BaseSelectorEventLoop.add_writerf r r, c F U R U5 U R U5 $ r1 )r2 r r s r
remove_writer#BaseSelectorEventLoop.remove_writerk r r, c # [ R " U5 U R ( a UR 5 S:w a [ S5 e UR U5 $ ! [ [ 4 a Of = fU R 5 nUR 5 nU R U5 U R X@R X1U5 nUR [ R " U R XES95 UI S h vN $ 7fNr the socket must be non-blockingr )r _check_ssl_socketrr
gettimeoutr rh rj ri r rU r2 r^
_sock_recvadd_done_callback functoolspartial_sock_read_done)r* r4 nfutr r s r sock_recv BaseSelectorEventLoop.sock_recvp s %%d+ ;;4??,1 >? ? 99Q< !12 "
[[] $$R(!!"oos!D d 2 2B F Hyy7 AC8
A C8A.+C8-A..BC82C53C8c X Ub UR 5 ( d U R U5 g g r1 ) cancelledr r* r r r s r r %BaseSelectorEventLoop._sock_read_done ( >!1!1!3!3 r " "4r, c UR 5 ( a g UR U5 nUR U5 g ! [ [ 4 a g [
[ 4 a e [ a nUR U5 S nAg S nAff = fr1 ) donerh
set_resultrj ri r r r
set_exception)r* r r4 r rd r s r r BaseSelectorEventLoop._sock_recv sw 88:: !99Q? ? >>#& & !12 "
[[] $$R(!!"&:&:CsK d 2 2B F Hyyr c UR 5 ( a g UR U5 nUR U5 g ! [ [ 4 a g [
[ 4 a e [ a nUR U5 S nAg S nAff = fr1 ) r r r rj ri r r r r )r* r r4 r nbytesr s r r %BaseSelectorEventLoop._sock_recv_into sx 88:: #^^C(F
NN6 " !12 -. # c " " #r c # [ R " U5 U R ( a UR 5 S:w a [ S5 e UR U5 $ ! [ [ 4 a Of = fU R 5 nUR 5 nU R U5 U R X@R X1U5 nUR [ R " U R XES95 UI S h vN $ 7fr )r r rr r r recvfromrj ri r rU r2 r^ _sock_recvfromr r r r )r* r4 bufsizer r r s r
sock_recvfrom#BaseSelectorEventLoop.sock_recvfrom s %%d+ ;;4??,1 >? ? ==) ) !12 "
[[] $$R(!!"&9&93gN d 2 2B F Hyyr c UR 5 ( a g UR U5 nUR U5 g ! [ [ 4 a g [
[ 4 a e [ a nUR U5 S nAg S nAff = fr1 ) r r r rj ri r r r r )r* r r4 r resultr s r r $BaseSelectorEventLoop._sock_recvfrom sx 88:: #]]7+F
NN6 " !12 -. # c " " #r c # [ R " U5 U R ( a UR 5 S:w a [ S5 eU( d [ U5 n UR
X#5 $ ! [ [ 4 a Of = fU R 5 nUR 5 nU R U5 U R XPR XAUU5 nUR [ R " U R" XVS95 UI S h vN $ 7fr )r r rr r r len
recvfrom_intorj ri r rU r2 r^ _sock_recvfrom_intor r r r )r* r4 r r r r r s r sock_recvfrom_into(BaseSelectorEventLoop.sock_recvfrom_into s %%d+ ;;4??,1 >? ?XF %%c2 2 !12 "
[[] $$R(!!"&>&>3"(* d 2 2B F Hyys7 AD A- ,D -B =D ?B BD DD c UR 5 ( a g UR X45 nUR U5 g ! [ [ 4 a g [
[ 4 a e [ a nUR U5 S nAg S nAff = fr1 ) r r r rj ri r r r r )r* r r4 r r r r s r r )BaseSelectorEventLoop._sock_recvfrom_into sz 88:: #''5F
NN6 " !12 -. # c " " #r c 0 # [ R " U5 U R ( a UR 5 S:w a [ S5 e UR U5 nU[ U5 :X a g U R 5 nUR 5 nU R U5 U R XPR XA[ U5 U/5 nUR [ R" " U R$ XVS95 UI S h vN $ ! [ [ 4 a Sn Nf = f N 7fr )r r rr r r rp rj ri r r rU r2 r
_sock_sendall
memoryviewr r r _sock_write_done)r* r4 rd r r r r s r sock_sendall"BaseSelectorEventLoop.sock_sendall s %%d+ ;;4??,1 >? ? $A
D > "
[[] $$R(!!"&8&8#",T"2QC9 d 3 3R G Iy !12 A s7 AD
C< B D7D8D<DDDDc F UR 5 ( a g US n UR X5S 5 nXV-
nU[ U5 :X a UR S 5 g XTS' g ! [ [ 4 a g [ [
4 a e [ a nUR U5 S nAg S nAff = fNr )
r rp rj ri r r r r r r )r* r r4 viewposstartr r s r r #BaseSelectorEventLoop._sock_sendall2 s 88:: A $v,'A
CI NN4 F !12 -. c " s A B ,B BB c # [ R " U5 U R ( a UR 5 S:w a [ S5 e UR X#5 $ ! [ [ 4 a Of = fU R 5 nUR 5 nU R U5 U R XPR XAUU5 nUR [ R " U R XVS95 UI S h vN $ 7fr )r r rr r r sendtorj ri r rU r2 r _sock_sendtor r r r )r* r4 rd rG r r r s r sock_sendto!BaseSelectorEventLoop.sock_sendtoH s %%d+ ;;4??,1 >? ? ;;t- - !12 "
[[] $$R(!!"&7&7D")+ d 3 3R G Iyys7 AC9
A C9A.+C9-A..BC93C64C9c UR 5 ( a g UR USU5 nUR U5 g ! [ [ 4 a g [
[ 4 a e [ a nUR U5 S nAg S nAff = fr
) r r r rj ri r r r r )r* r r4 rd rG r r s r r "BaseSelectorEventLoop._sock_sendtod sz 88:: D!W-A
NN1 !12 -. # c " " #s = BB(A>>Bc 0 # [ R " U5 U R ( a UR 5 S:w a [ S5 eUR
[ R :X d3 [ R ( a` UR
[ R :X aB U R X!R
UR UR U S9I S h vN nUS u pBU R 5 nU R XQU5 UI S h vN S n$ N= N! S nf = f7f)Nr r )familytypeprotoloop)r r rr r r r r[ AF_INET _HAS_IPv6AF_INET6_ensure_resolvedr r r
_sock_connect)r* r4 rG resolvedr r s r sock_connect"BaseSelectorEventLoop.sock_connects s
%%d+ ;;4??,1 >? ? ;;&.. (%%$++ *H ! 2 2 $))4:: 3 H #+1+ Aq!Q " 3g. 9 C Cs< C D
D 0D?D D
D D
D DDc UR 5 n UR U5 UR S 5 S ng ! [ [ 4 a_ U R U5 U R
X@R XU5 nUR [ R " U R XES95 Nq[ [ 4 a e [ a nUR U5 S nANS nAff = f! S nf = f)Nr )rU connectr rj ri r2 r _sock_connect_cbr r r r r r r r )r* r r4 rG r r r s r r" #BaseSelectorEventLoop._sock_connect s
[[] LL !
NN4 C# !12 M
( ( ,%%))3g?F ! !!!$"7"7K
M -. # c " " #
Cs9 7 C A,C#C %C>CC CC C c X Ub UR 5 ( d U R U5 g g r1 )r r r s r r &BaseSelectorEventLoop._sock_write_done r r, c UR 5 ( a g UR [ R [ R 5 nUS:w a [ USU 35 e UR
S 5 S ng ! [ [ 4 a N[ [ 4 a e [ a nUR U5 S nANDS nAff = f! S nf = f)Nr zConnect call failed )
r
getsockoptr[
SOL_SOCKETSO_ERRORrq r rj ri r r r r )r* r r4 rG errr s r r( &BaseSelectorEventLoop._sock_connect_cb s 88:: //&"3"3V__ECax c%9'#CDD
NN4 C !12 -. # c " " #
Cs< AA0 B9 0B6 B9 B6B1,B9 1B66B9 9B=c # [ R " U5 U R ( a UR 5 S:w a [ S5 eU R 5 nU R
X!5 UI S h vN $ N7f)Nr r )r r rr r r r _sock_accept)r* r4 r s r sock_accept!BaseSelectorEventLoop.sock_accept s\ %%d+ ;;4??,1 >? ? " #$yys A-A6/A40A6c UR 5 n UR 5 u pEUR S5 UR XE45 g ! [ [
4 a^ U R
U5 U R X0R X5 nUR [ R " U R X6S95 g [ [ 4 a e [ a nUR! U5 S nAg S nAff = f)NFr )rU r r] r rj ri r2 r^ r3 r r r r r r r r )r* r r4 r r rG r r s r r3 "BaseSelectorEventLoop._sock_accept s
[[]
, KKMMD U #
NND? + !12 L ( ( ,%%b*;*;SGF ! !!!$"6"6J
L -. # c " " #s #A A+C)5C)C$$C)c # U R UR UR 5 nUR 5 UR 5 I S h vN U R UR X#USS9I S h vN UR 5 U( a UR 5 XR UR ' $ Nh NE! UR 5 U( a UR 5 XR UR ' f = f7f)NF)fallback) r) _sock_fd
is_reading
pause_reading_make_empty_waiter
sock_sendfile_sock_reset_empty_waiterresume_reading)r* transpfileoffsetcountrA s r _sendfile_native&BaseSelectorEventLoop._sendfile_native s V__ - **, ''))) 7 ++FLL$5: , < <
& & ( %%'06 V__ - *<
& & ( %%'06 V__ -s> A C>
B6C> B: 2B83B: 6AC>8B: :AC;;C>c U H u p#UR UR snu pVU[ R - ( a7 Ub4 UR ( a U R U5 OU R
U5 U[ R - ( d M Uc M UR ( a U R U5 M U R
U5 M g r1 ) fileobjrd r r
_cancelledrS
_add_callbackr r )r*
event_listr r rI r r s r _process_events%BaseSelectorEventLoop._process_events s #IC(+ SXX %G%fi***v/A$$''0&&v.i++++0B$$''0&&v. $r, c b U R UR 5 5 UR 5 g r1 )rS rU rO )r* r4 s r
_stop_serving#BaseSelectorEventLoop._stop_serving s DKKM*
r, )rV r% rT r) r1 NNN)r )5r$
__module__ __qualname____firstlineno__r r7 r SSL_HANDSHAKE_TIMEOUTSSL_SHUTDOWN_TIMEOUTrC rH rO rN r& re r_ rt r{ rx r r2 r^ rS r r r r r r r r r r r r r r r r
r r r r$ r" r r( r4 r3 rF rM rP __static_attributes__
__classcell__r# s @r r r 5 sp 97%)$7 9=+ $t"+"A"A!*!?!? +& CGB " E
,& #'tS-6-L-L,5,J,JF D#"+"A"A!*!?!? 0)h D"+"A"A!*!?!? -5^ "
&
*.
'
.
'
,#! *#".#"2#" @,8
2.#* ," 7 / r, r c ^ \ rS rSrSrSrSU 4S jjrS rS rS r S r
S r S
r S r
S rS
r\R" 4S jrSS jrS rS rS rS rSrU =r$ )_SelectorTransporti i Nc > [ TU ] XA5 [ R " U5 U R S' UR 5 U R S' SU R ; a UR 5 U R S' X l
UR 5 U l SU l
U R U5 XPl [ R" " 5 U l SU l SU l SU l U R b U R R- U 5 XR. U R ' g ! [ a S U R S' Nf = f! [ R a S U R S' Nf = f)Nr[ socknamer~ Fr )r r r r _extra getsocknamerq getpeernamer[ errorr? rU r: _protocol_connected set_protocol_server collectionsdeque_buffer
_conn_lost_closing_paused_attachr) )r* r r4 r5 r. r/ r# s r r _SelectorTransport.__init__ s2
% & 6 6t < H +&*&6&6&8DKK
# T[[ (
/*.*:*:*< J'
#( (# "((*
<< # LL &*. '+ +&*DKK
# +
<<
/*. J'
/s# D) # E )EE#E.-E.c & U R R /nU R c UR S5 O"U R ( a UR S5 UR SU R
35 U R b U R R 5 ( d [ U R R U R
[ R 5 nU( a UR S5 OUR S5 [ U R R U R
[ R 5 nU( a SnOSnU R 5 nUR SU S U S
35 S R S R U5 5 $ )
Nclosedclosingzfd=z read=pollingz read=idlepollingidlezwrite=z<{}> )r# r$ r? appendrj r: _looprM r r% r r r get_write_buffer_sizeformatjoin)r* inforq stater s r __repr___SelectorTransport.__repr__$ s' ''( :: KK !
]] KK " c$-- )* :: !$***>*>*@*@*4::+?+?+/==):N:NPG N+ K(*4::+?+?+/==+4+@+@BG ! 002G KK'%
7)1= >}}SXXd^,,r, c & U R S 5 g r1 ) _force_closerX s r abort_SelectorTransport.abort@ s $ r, c Xl SU l g NT) _protocolrc )r* r5 s r rd _SelectorTransport.set_protocolC s !#' r, c U R $ r1 )r rX s r get_protocol _SelectorTransport.get_protocolG s ~~ r, c U R $ r1 )rj rX s r r _SelectorTransport.is_closingJ s }} r, c \ U R 5 ( + =( a U R ( + $ r1 )r rk rX s r r; _SelectorTransport.is_readingM s ??$$9T\\)99r, c U R 5 ( d g SU l U R R U R 5 U R R 5 ( a [ R " SU 5 g g )NTz%r pauses reading)r; rk rv rS r: get_debugr
r" rX s r r< _SelectorTransport.pause_readingP sV
!!$--0 :: ! ! LL,d 3 "r, c U R ( d U R ( d g SU l U R U R U R 5 U R
R
5 ( a [ R " SU 5 g g )NFz%r resumes reading) rj rk r^ r: _read_readyrv r r
r" rX s r rA !_SelectorTransport.resume_readingX sZ == (8(89 :: ! ! LL-t 4 "r, c d U R ( a g SU l U R R U R 5 U R ( da U =R
S-
sl U R R
U R 5 U R R U R S 5 g g NTr ) rj rv rS r: rh ri r call_soon_call_connection_lostrX s r rO _SelectorTransport.close` ss ==
!!$--0|| OOq O JJ % %dmm 4 JJ !;!;T B r, c U R bT U" SU < 3[ U S9 U R R 5 U R b U R R U 5 g g g )Nzunclosed transport )source)r? ResourceWarningrO re _detach)r* _warns r __del___SelectorTransport.__del__j sV :: ! 'x0/$ O JJ ||' $$T* ( "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 )Nz%r: %sTrn )r r r r5 ) r rq rv r r
r" r r r )r* r r s r _fatal_error _SelectorTransport._fatal_errorq sj c7 # #zz##%% XttD JJ - -" ! NN /
# r, c U R ( a g U R ( a? U R R 5 U R R U R
5 U R ( d, SU l U R R U R
5 U =R S-
sl U R R U R U5 g r )
ri rh clearrv r r: rj rS r r )r* r s r r _SelectorTransport._force_close s ?? << LL JJ % %dmm 4}} DM JJ % %dmm 4 1
T 7 7=r, c U R ( a U R R U5 U R R 5 S U l S U l S U l U R nUb UR U 5 S U l g g ! U R R 5 S U l S U l S U l U R nUb UR U 5 S U l f f = fr1 )rc r connection_lostr? rO rv re r )r* r r/ s r r (_SelectorTransport._call_connection_lost s $''..s3 JJ DJ !DN DJ\\F!t$ # "
JJ DJ !DN DJ\\F!t$ # "s ,B AC c H [ [ [ U R 5 5 $ r1 )summapr rh rX s r rw (_SelectorTransport.get_write_buffer_size s 3sDLL)**r, c j U R 5 ( d g U R R " X/UQ76 g r1 )r; rv r^ r s r r^ _SelectorTransport._add_reader s)
r3d3r, )
rh rj ri rv rk r rc re r? r: )NN)zFatal error on transport)r$ rS rT rU max_sizer? r r| r rd r r r; r< rA rO warningswarnr r r r rw r^ rX rY rZ s @r r\ r\ sp H
E/8-8 ( :45C %MM +
> $ +4 4r, r\ c ^ \ rS rSrSr\R R r SU 4S jjr U 4S jr
S r S r S r
S rS
rS rS rS
\SS4S jrS rS rS rS rU 4S jrS rS rU 4S jrSr U =r $ )r3 i TNc " > S U l [ TU ] XX5U5 SU l S U l [
( a U R U l OU R U l [ R " U R 5 U R R U R R U 5 U R R U R U R" U R$ 5 Ub, U R R [& R( US 5 g g r )_read_ready_cbr r _eof
_empty_waiter _HAS_SENDMSG_write_sendmsg _write_ready _write_sendr _set_nodelayr? rv r r connection_mader^ r: r r _set_result_unless_cancelled)r* r r4 r5 r6 r. r/ r# s r r !_SelectorSocketTransport.__init__ s #
Xf= ! < $ 3 3D $ 0 0D ,
T^^ ; ;TB
T - - !]]D,<,< > JJ !E!E!'
/ r, c > [ U[ R 5 ( a U R U l OU R
U l [ TU ] U5 g r1 )r r BufferedProtocol_read_ready__get_bufferr _read_ready__data_receivedr rd )r* r5 r# s r rd %_SelectorSocketTransport.set_protocol s? h : : ; ;"&">">D "&"A"AD
X&r, c $ U R 5 g r1 )r rX s r r $_SelectorSocketTransport._read_ready s r, c U R ( a g U R R S5 n[ U5 ( d [ S5 e U R R U5 nU( d U R 5 g U R R U5 g ! [
[ 4 a e [ a nU R US5 S nAg S nAff = f! [ [ 4 a g [
[ 4 a e [ a nU R US5 S nAg S nAff = f! [
[ 4 a e [ a nU R US5 S nAg S nAff = f)Nz%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.)ri r
get_bufferr rL r r r r r? r rj ri _read_ready__on_eofbuffer_updated)r* r r r s r r 0_SelectorSocketTransport._read_ready__get_buffer sE ?? ..++B/Cs88"#JKK ZZ))#.F $ $ & L NN ) )& 1- -. F
H !12 -. c#I J -. L J
L
L LsM 6B C D C6C
CD 'D DD E9EEc U R ( a g U R R U R 5 nU( d U R 5 g U R R U5 g ! [ [
4 a g [ [ 4 a e [ a nU R US5 S nAg S nAff = f! [ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nr z2Fatal error: protocol.data_received() call failed.)
ri r? rh r rj ri r r r r r r
data_received)r* rd r s r r 3_SelectorSocketTransport._read_ready__data_received s ?? ::??4==1D $ $ & K NN ( ( . !12 -. c#I J -. K I
K
K Ks5 %A. B8 .B5 B5B00B58C.C))C.c U R R 5 ( a [ R " SU 5 U R R 5 nU( a& U R R U R 5 g U R 5 g ! [ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.)
rv r r
r" r eof_receivedr r r r rS r: rO )r* keep_openr s r r ,_SelectorSocketTransport._read_ready__on_eof s :: ! ! LL*D 1 335I
JJ % %dmm 4 JJL -. H
J s B C*CCc [ 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 ( dc U R R# U5 n[ U5 US nU( d g U R0 R3 U R4 U R6 5 U R R9 U5 U R; 5 g ! [$ [& 4 a Nn[( [* 4 a e [, a nU R/ US5 S nAg S nAff = f)NzDdata argument must be a bytes, bytearray, or memoryview object, not z%Cannot call write() after write_eof()z(unable to write; sendfile is in progress socket.send() raised exception.r %Fatal write error on socket transport) r bytes bytearrayr r r r$ r rL r ri r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningrh r? rp rj ri r r r r rv r r: r ru _maybe_pause_protocol)r* rd r r s r write _SelectorSocketTransport.write sl $ : >?? ++/:+>+>*A C D
D 99 FG G ) IJ J ??)"M"MM @A OOq O ||
JJOOD) "$'+
JJ " "4==$2C2C D
D! ""$! $%56
12
!!#'NO
s ,E: :G G%F<<Gc L [ R " U R [ 5 $ r1 ) itertoolsislicerh r rX s r _get_sendmsg_buffer,_SelectorSocketTransport._get_sendmsg_bufferE s j99r, c U R ( a g U R R U R 5 5 nU R U5 U R 5 U R ( d U R R U R 5 U R b U R R S 5 U R ( a U R S 5 g U R ( a* U R R [ R" 5 g g g ! [$ [& 4 a g [( [* 4 a e [, a nU R R U R 5 U R R/ 5 U R1 US5 U R b U R R3 U5 S nAg S nAg S nAff = fNr )ri r? r r _adjust_leftover_buffer_maybe_resume_protocolrh rv r r: r r rj r r shutdownr[ SHUT_WRrj ri r r r r r r )r* r r s r r '_SelectorSocketTransport._write_sendmsgH sV ?? 8ZZ''(@(@(BCF ( ( 0
' ' )<<
))$--8%%1&&11$7==..t4YYJJ''7
!12 -. 6 JJ % %dmm 4 LL c#J K!!-""0055 . 6s :D G.GA9G
Gr returnc U R nU( aC UR 5 n[ U5 nXA:: a X- nOUR X1S 5 g U( a MB g g r1 )rh popleftr
appendleft)r* r bufferbb_lens r r 0_SelectorSocketTransport._adjust_leftover_bufferd sK AFE!!!G*- fr, c U R ( a g U R R 5 nU R R U5 nU[ U5 :w a U R R
XS 5 U R 5 U R ( d U R R U R 5 U R b U R R S 5 U R ( a U R S 5 g U R ( a* U R R! [" R$ 5 g g g ! [& [( 4 a g [* [, 4 a e [. a nU R R U R 5 U R R1 5 U R3 US5 U R b U R R5 U5 S nAg S nAg S nAff = fr )ri rh r r? rp r r r rv r r: r r rj r r r r[ r rj ri r r r r r r )r* r r r s r r $_SelectorSocketTransport._write_sendo sq ?? 8\\))+F
'ACK ''r
3
' ' )<<
))$--8%%1&&11$7==..t4YYJJ''7
!12 -. 6 JJ % %dmm 4 LL c#J K!!-""0055 . 6s A!E G6G6.A9G11G6c U R ( d U R ( a g SU l U R ( d* U R R [
R 5 g g r )rj r rh r? r r[ r rX s r write_eof"_SelectorSocketTransport.write_eof s; ==DII || JJ / r, c j U 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 R U Vs/ s H n[ U5 PM sn5 U R 5 U R ( aA U R R U R U R 5 U R 5 g g s snf )Nz*Cannot call writelines() after write_eof()z-unable to writelines; sendfile is in progressr r )r rL r ri r r r
r rh extendr r rv r r: r )r* list_of_datard s r
writelines#_SelectorSocketTransport.writelines s 99 KL L ) NO O ??)"M"MM @A OOq O , G,$Z -, GH << JJ " "4==$2C2C D & & ( Hs 1D0c gr rb rX s r
can_write_eof&_SelectorSocketTransport.can_write_eof s r, c > [ TU ] U5 S U l U R b% U R R [ S5 5 g g ! S U l U R b% U R R [ S5 5 f f = f)Nz Connection is closed by peer)r r r r r ConnectionError)r* r r# s r r ._SelectorSocketTransport._call_connection_lost s E G )# . $D !!-""00#$BCE . !%D !!-""00#$BCE .s A ;Bc U R b [ S5 eU R R 5 U l U R ( d U R R S 5 U R $ )NzEmpty waiter is already set)r rL rv r rh r rX s r r= +_SelectorSocketTransport._make_empty_waiter sV ) <= = !ZZ 5 5 7|| ) )$ /!!!r, c S U l g r1 )r rX s r r@ ,_SelectorSocketTransport._reset_empty_waiter s
!r, c 0 > S U l [ TU ] 5 g r1 )r r rO rP s r rO _SelectorSocketTransport.close s "
r, )r r r r rR ) r$ rS rT rU _start_tls_compatibler
_SendfileMode
TRY_NATIVE_sendfile_compatibler rd r r r r r r r r r r r r r r r= r@ rO rX rY rZ s @r r3 r3 s $22==48$(/2' #LJK2*%%N:88 c d 8>0)*E"" r, r3 c h ^ \ rS rSr\R
rSr S U 4S jjrS r S r
S
S jr S r Sr
U =r$ ) rF i c t > [ TU ] XX65 X@l SU l U R R U R R U 5 U R R U R U R U R 5 Ub, U R R [ R US 5 g g r
)
r r _address _buffer_sizerv r r r r^ r: r r r )r* r r4 r5 rG r6 r. r# s r r #_SelectorDatagramTransport.__init__ s
X5
T^^ ; ;TB
T - - !]]D,<,< > JJ !E!E!'
/ r, c U R $ r1 )r rX s r rw 0_SelectorDatagramTransport.get_write_buffer_size s r, c U R ( a g U R R U R 5 u pU R R X5 g ! [ [ 4 a g [ a% nU R R U5 S nAg S nAf[ [ 4 a e [ a nU R US5 S nAg S nAff = f)Nz&Fatal read error on datagram transport)ri r? r r r datagram_receivedrj ri rq error_receivedr r r r r* rd r r s r r &_SelectorDatagramTransport._read_ready s ?? 9 ,,T]];JD
NN , ,T 8 !12 / NN ) )# . . -. M c#K L L Ms) 'A C ) C 2B C /CC c [ U[ [ [ 45 ( d" [ S[ U5 R < 35 eU R ( a6 US U R 4; a [ SU R 35 eU R nU R ( a[ U R ( aJ U R [ R : a [ R " S5 U =R S-
sl g U R ( dM U R S ( a U R R# U5 g U R R% X5 g U R RA [ U5 U45 U =RB [E U5 U RF - -
sl! U RI 5 g ! [& [( 4 a3 U R* R- U R. U R0 5 N[2 a% nU R4 R7 U5 S nAg S nAf[8 [: 4 a e [< a nU R? US5 S nAg S nAff = f)Nz/data argument must be a bytes-like object, not z!Invalid address: must be None or r r r~ 'Fatal write error on datagram transport)%r r r r r r r$ r r ri r r r
r rh r_ r? rp r rj ri rv r r:
_sendto_readyrq r r r r r r ru r r _header_sizer r s r r !_SelectorDatagramTransport.sendto s $ : >?? ##':#6#6"9 ; <
< ==D$--00 7
GI I==D ??t}})"M"MM @A OOq O ||
;;z*JJOOD) JJ%%d1
U4[$ /0 SY):): :: ""$ $%56
J
&&t}}d6H6HI
--c2 12
!!BD
s1 /F6 8F6 6A I8 IH!! I>IIc U R ( a U R R 5 u pU =R [ U5 U R - - sl U R
S ( a U R R U5 O U R R X5 U R ( a M U R' 5 U R ( dI U R( R+ U R, 5 U R. ( a U R1 S 5 g g g ! [ [ 4 aK U R R X45 U =R [ U5 U R - -
sl M [ a% nU R R U5 S nAg S nAf[ [ 4 a e [" a nU R% US5 S nAg S nAff = f)Nr~ r )rh r r r r r_ r? rp r rj ri r rq r r r r r r r rv r r: rj r r s r r (_SelectorDatagramTransport._sendto_ready sc ll --/JD TT->->!> >
;;z*JJOOD)JJ%%d1 lll,
##%|| JJ % %dmm 4}}**40 $%56
'' 5!!SY1B1B%BB!
--c2 12
!!BD
s1 /D$
D$ $AG > G F'' G GG )r r rR r1 )r$ rS rT rU rf rg _buffer_factoryr r rw r r r rX rY rZ s @r rF rF s8 !''OL59$( / !9 (%T1 1r, rF )%__all__rf r r r osr r[ r r' ssl ImportError r r r r r r
r r logr
hasattrr sysconfr rq r
BaseEventLoopr _FlowControlMixin Transportr\ r3 DatagramTransportrF rb r, r r, s #
v}}i0 ZZ -
(F K 5 5 F Ra455#--a4Ha 1 aH k1!3Z5Q5Q k1e%
C$ s# C) =C7 )C43C47DD