*j S r SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK
r
SSK r SSK
Jr SSK
Jr SSK
Jr SSK
Jr SS K
Jr SS
K
Jr SS K
Jr SS K
Jr SS
KJr \" \R S5 r\( a \R4 " S5 rS r " S S\R< 5 r " S S\R@ \RB 5 r" " S S\"5 r# " S S\"\RH 5 r%g! \ a Sr Nf = f! \ a Sr Nrf = f)zEvent loop using a selector and related classes.
A selector is a "notify-when-ready" multiplexer. For a subclass which
also includes support for signal handling, see the unix_events sub-module.
)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 8 ^ \ rS rSrSrS5U 4S jjrS5SSS.S jjr S5SSSS\R \R S.S jjr
S6S
jr U 4S jr S r
S
rS rS rS rSSS\R \R 4S jrSSS\R \R 4S jrSS\R \R 4S jrS rS rS rS rS rS rS rS r S r S r S5S jr S r S! r!S" r"S# r#S$ r$S7S% jr%S& r&S' r'S( r(S) r)S* r*S+ r+S, r,S5S- jr-S. r.S/ r/S0 r0S1 r1S2 r2S3 r3S4r4U =r5$ )8r 5 zBSelector event loop.
See events.EventLoop for API specification.
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 gg)NFT) 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 XUS45 Ub UR 5 gg)Remove a writer callback.FNT) 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)zAdd a reader callback.N)r2 r^ r* r r r s r
add_reader BaseSelectorEventLoop.add_reader\ # $$R( --r, c F U R U5 U R U5 $ )zRemove a reader callback.)r2 rS r* r s r
remove_reader#BaseSelectorEventLoop.remove_readera ! $$R(""2&&r, c L U R U5 U R " X/UQ76 g)zAdd a writer callback..N)r2 r r s r
add_writer BaseSelectorEventLoop.add_writerf r r, c F U R U5 U R U5 $ )r )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 Sh vN $ 7f)zReceive data from the socket.
The return value is a bytes object representing the data received.
The maximum amount of data to be received at once is specified by
nbytes.
r the socket must be non-blockingr N)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 Sh vN $ 7f)zReceive a datagram from a datagram socket.
The return value is a tuple of (bytes, address) representing the
datagram received and the address it came from.
The maximum amount of data to be received at once is specified by
nbytes.
r r r N)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 Sh vN $ 7f)zReceive data from the socket.
The received data is written into *buf* (a writable buffer).
The return value is a tuple of (number of bytes written, address).
r r r N)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 gU R 5 nUR 5 nU R U5 U R XPR XA[ U5 U/5 nUR [ R" " U R$ XVS95 UI Sh vN $ ! [ [ 4 a Sn Nf = f N 7f)m Send data to the socket.
The socket must be connected to a remote socket. This method
continues to send data from data until either all data has been
sent or an error occurs. None is returned on success. On error,
an exception is raised, and there is no way to determine how much
data, if any, was successfully processed by the receiving end of
the connection.
r r Nr )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 Sh vN $ 7f)r r r r N)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 Sh vN nUS u pBU R 5 nU R XQU5 UI Sh vN Sn$ N= N! Snf = f7f)zDConnect to a remote socket at address.
This method is a coroutine.
r r )familytypeprotoloopN)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 Sh vN $ N7f)a0 Accept a connection.
The socket must be bound to an address and listening for
connections. The return value is a pair (conn, address) where
conn is a new socket object usable to send and receive data on the
connection, and address is the address bound to the socket on the
other end of the connection.
r r N)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 )6r$
__module__ __qualname____firstlineno____doc__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 su
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? appendrk r: _looprM r r% r r r get_write_buffer_sizeformatjoin)r* inforr 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) _protocolrd )r* r5 s r re _SelectorTransport.set_protocolC s !#' r, c U R $ r1 )r rX s r get_protocol _SelectorTransport.get_protocolG s ~~ r, c U R $ r1 )rk rX s r r _SelectorTransport.is_closingJ s }} r, c \ U R 5 ( + =( a U R ( + $ r1 )r rl 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; rl rw 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) rk rl r^ r: _read_readyrw 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 ) rk rw rS r: ri rj 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 rf _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 rw 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 )
rj ri clearrw r r: rk 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 )rd r connection_lostr? rO rw rf 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 ri rX s r rx (_SelectorTransport.get_write_buffer_size s 3sDLL)**r, c j U R 5 ( d g U R R " X/UQ76 g r1 )r; rw r^ r s r r^ _SelectorTransport._add_reader s)
r3d3r, )
ri rk rj rw rl r rd rf r? r: )NN)zFatal error on transport)r$ rS rT rU max_sizer? r r} r re r r r; r< rA rO warningswarnr r r r rx r^ rY rZ r[ 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? rw 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 re )r* r5 r# s r re %_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.)rj 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.)
rj 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.)
rw 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 rj r !LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningri r? rp rj ri r r r r rw r r: r rv _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 ) itertoolsisliceri 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 )rj r? r r _adjust_leftover_buffer_maybe_resume_protocolri rw r r: r r rk 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 )ri 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 )rj ri r r? rp r r r rw r r: r r rk 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 )rk r ri 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 rj r r r
r ri extendr r rw 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 rw r ri 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 re r r r r r r r r r r r r r r r= r@ rO rY rZ r[ 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_sizerw 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 rx 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)rj 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 rj r r r
r ri r` r? rp r rj ri rw r r:
_sendto_readyrq r r r r r r rv 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 )ri r r r r r` r? rp r rj ri r rq r r r r r r r rw r r: rk 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 rg rh _buffer_factoryr r rx r r r rY rZ r[ s @r rF rF s8 !''OL59$( / !9 (%T1 1r, rF )&rV __all__rg 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+ ?C9 +C65C69DD