*j= B S SK r S SKr S SKrS SKrS SKrS SKrS SKrS SKrS SK r S SK
r
S SK r S SK r S SK
r
S SKrS SKrS SKr S SKrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS
KJr SS KJ r SS KJ r SS
KJ r SSKJ r SSK J!r! Sr"Sr#Sr$\%" \S5 r&Sr'S r(S r)S r*S%S jr+S&S jr,S r-\%" \S5 ( a S r.OS r.S r/ " S S \R` 5 r1 " S! S"\Rd 5 r3 " S# S$\Rh 5 r5g! \ a Sr Nf = f)' N ) constants)
coroutines)events)
exceptions)futures) protocols)sslproto) staggered)tasks)timeouts)
transports)trsock)logger)
BaseEventLoopServerd g ?AF_INET6iQ c U R n[ [ USS 5 [ R 5 ( a [ UR 5 $ [ U 5 $ )N__self__) _callback
isinstancegetattrr Taskreprr str)handlecbs :/opt/alt/python313/lib64/python3.13/asyncio/base_events.py_format_handler G s@ B'"j$/<<BKK 6{ c l U [ R :X a gU [ R :X a g[ U 5 $ )Nzz)
subprocessPIPESTDOUTr )fds r _format_piper' P s+ Z__ z Bxr! c [ [ S5 ( d [ S5 e U R [ R [ R
S5 g ! [ a [ S5 ef = f)N SO_REUSEPORTz)reuse_port not supported by socket moduler zTreuse_port not supported by socket module, SO_REUSEPORT defined but not implemented.)hasattrsocket
ValueError
setsockopt
SOL_SOCKETr) OSErrorsocks r _set_reuseportr2 Y sc 6> * *DEE J OOF - -v/B/BA F J I J
J Js /A A(c [ [ S5 ( d g US[ R [ R 1; d U c g U[ R :X a [ R nO&U[ R
:X a [ R nOg Uc SnOH[
U[ 5 ( a US:X a SnO*[
U[ 5 ( a US:X a SnO [ U5 nU[ R :X a< [ R /n[ ( a UR [ R 5 OU/n[
U [ 5 ( a U R# S5 n SU ; a g U HJ n [ R$ " X5 [ ( a U[ R :X a
XUSXXV44s $ XUSX44s $ g ! [ [ 4 a g f = f! [& a Mr f = f)N inet_ptonr r! idna%)r* r+ IPPROTO_TCP IPPROTO_UDP SOCK_STREAM
SOCK_DGRAMr bytesr int TypeErrorr, AF_UNSPECAF_INET _HAS_IPv6appendr decoder4 r/ ) hostportfamilytypeprotoflowinfoscopeidafsafs r _ipaddr_inforM d s 6; ' ' Q**F,>,>?? L v!!!""
"" """ | D% TS[ D# 42: t9D !!!~~ 9 JJv 'h$ {{6"
d{ R &yR6?? 2T,KKKTL88 ; :& 2 s* F* (_interleave_addrinfos.. s
a
s )
collections OrderedDictrB listvaluesextend itertoolschain
from_iterable zip_longest) addrinfosfirst_address_family_countaddrinfos_by_familyaddrrF addrinfos_lists reordereds r _interleave_addrinfosre s &113a ,*, '#**40
.5578OI!A% +,K-G!-KLM A > :Q > > ?
??00 ! !? 3
r! c U R 5 ( d, U R 5 n[ U[ [ 45 ( a g [
R " U 5 R 5 g rP ) cancelled exceptionr
SystemExitKeyboardInterruptr _get_loopstop)futexcs r _run_until_complete_cbro sG ==??mmo cJ(9: ; ;
c !r! TCP_NODELAYc < U R [ R [ R 1; an U R [ R
:X aO U R [ R :X a0 U R [ R [ R S5 g g g g Nr )
rF r+ r@ r rG r: rH r8 r- rp r0 s r _set_nodelayrs sj KKFNNFOO< < V / //
f 0 00 OOF . .0B0BA F 1 0
=r! c g rP rQ r0 s r rs rs s r! c h [ b+ [ U [ R 5 ( a [ S5 eg g )Nz"Socket cannot be of type SSLSocket)sslr SSLSocketr> r0 s r _check_ssl_socketrx s*
:dCMM::<== ;r! c J \ rS rSrS rS rS rS rS rS r S r
S r S
r S r
g )
_SendfileFallbackProtocol c [ U[ R 5 ( d [ S5 eXl UR 5 U l UR 5 U l UR U l
UR 5 UR U 5 U R ( a* U R R R 5 U l g S U l g )Nz.transport should be _FlowControlMixin instance)r r _FlowControlMixinr>
_transport get_protocol_proto
is_reading_should_resume_reading_protocol_paused_should_resume_writing
pause_reading set_protocol_loop
create_future_write_ready_fut)selftransps r __init__"_SendfileFallbackProtocol.__init__ s &*">">?? LM M ))+ &,&7&7&9#&,&=&=# D! & &$(OO$9$9$G$G$ID !$(D !r! c # U R R 5 ( a [ S5 eU R nUc g UI S h vN g N7f)NzConnection closed by peer)r~
is_closingConnectionErrorr )r rm s r drain _SendfileFallbackProtocol.drain s> ?? % % ' '!"=> >## ; s A A
AA
c [ S5 e)Nz?Invalid state: connection should have been established already. RuntimeErrorr transports r connection_made)_SendfileFallbackProtocol.connection_made s N O Or! c U R bC Uc% U R R [ S5 5 OU R R U5 U R R U5 g )Nz Connection is closed by peer)r
set_exceptionr r connection_lost)r rn s r r )_SendfileFallbackProtocol.connection_lost s[ , {%%33#$BCE %%33C8 ##C(r! c r U R b g U R R R 5 U l g rP )r r~ r r r s r
pause_writing'_SendfileFallbackProtocol.pause_writing s, , $ 5 5 C C E r! c d U R c g U R R S5 S U l g NF)r
set_resultr s r resume_writing(_SendfileFallbackProtocol.resume_writing s- ( ((/ $ r! c [ S5 eNz'Invalid state: reading should be pausedr )r datas r
data_received'_SendfileFallbackProtocol.data_received DEEr! c [ S5 er r r s r eof_received&_SendfileFallbackProtocol.eof_received r r! c R # U R R U R 5 U R ( a U R R 5 U R
b U R
R
5 U R ( a U R R 5 g g 7frP ) r~ r r r resume_readingr cancelr r r s r restore!_SendfileFallbackProtocol.restore sr $$T[[1 & & OO * * , ,
! ! ( ( * & & KK & & ( 's B%B')r r r r~ r N)__name__
__module__ __qualname____firstlineno__r r r r r r r r r __static_attributes__rQ r! r rz rz s3 ) O )F
% FF
)r! rz c ~ \ rS rSr SS jrS rS rS rS rS r S r
S
r \ S 5 r
S rS
rS rS rS rS rSrg)r i Nc Xl X l [ R " 5 U l / U l X0l XPl X@l X`l Xpl
SU l S U l g r )
r _socketsweakrefWeakSet_clients_waiters_protocol_factory_backlog _ssl_context_ssl_handshake_timeout_ssl_shutdown_timeout_serving_serving_forever_fut)r loopsocketsprotocol_factory ssl_contextbacklogssl_handshake_timeoutssl_shutdown_timeouts r r Server.__init__ sO
)
!1
'&;#%9"
$(!r! c R SU R R SU R < S3$ )N) __class__r r r s r __repr__Server.__repr__% s' 4>>**+9T\\4DAFFr! c : U R R U5 g rP )r addr s r _attachServer._attach( s
)$r! c U R R U5 [ U R 5 S:X a U R c U R 5 g g g Nr )r discardlenr _wakeupr s r _detachServer._detach, s?
i( t}} "t}}'< LLN (= "r! c U R nS U l U H+ nUR 5 ( a M UR S 5 M- g rP )r doner )r waiterswaiters r r Server._wakeup1 s5 --
F;;==!!$' r! c
4 U R ( a g SU l U R Ho nUR U R 5 U R R U R XR X R U R U R 5 Mq g NT)
r r listenr r _start_servingr r r r )r r1 s r r Server._start_serving8 sl ==
MMD KK
& JJ % %&&.?.?mmT%@%@**
, "r! c U R $ rP )r r s r get_loopServer.get_loopC s zzr! c U R $ rP )r r s r
is_servingServer.is_servingF s }} r! c V U R c g[ S U R 5 5 $ )NrQ c 3 N # U H n[ R " U5 v M g 7frP )r TransportSocket)rR ss r rT !Server.sockets..M s F
1V++A..
s #%)r tupler s r r Server.socketsI s$ == F
FFFr! c v U R nUc g S U l U H nU R R U5 M SU l U R b@ U R R 5 ( d! U R R
5 S U l [ U R 5 S:X a U R 5 g g )NFr )
r r
_stop_servingr r r r r r r )r r r1 s r close Server.closeO s -- ?
D JJ $ $T *
% % 1--2244 % % , , .(,D % t}} " LLN #r! c f U R R 5 H nUR 5 M g rP )r copyr r s r
close_clientsServer.close_clientsb # ++-I OO .r! c f U R R 5 H nUR 5 M g rP )r r abortr s r
abort_clientsServer.abort_clientsf r r! c l # U R 5 [ R " S5 I S h vN g N7fr )r r sleepr s r
start_servingServer.start_servingj s$ kk!n s *424c # U R b [ SU < S35 eU R c [ SU < S35 eU R 5 U R R 5 U l U R I S h vN S U l g N
! [ R a1 U R 5 U R 5 I S h vN e ! e = ff = f! S U l f = f7f)Nzserver z, is already being awaited on serve_forever()z
is closed)
r r r r r r r CancelledErrorr wait_closedr s r
serve_foreverServer.serve_foreverp s $ $ 0 $!MNP
P ==
;< < $(JJ$<$<$>! -++ + + )-D %
,((
&&((( )-D %s` A*C -B <B
=B C
B C!#C CC
C C
CC C C c # U R c g U R R 5 nU R R U5 UI S h vN g N7frP )r r r rB )r r s r r Server.wait_closed s? * == ))+
V$ s A A A A) r r r r r r r r r r r rP )r r r r r r r r r r r r propertyr r r r r r r r rQ r! r r r se >B) G%
( , G G
& -*r! r c
\ rS rSrS rS rS rSSS.S jrS rS r S`SSS
.S jjr
S`S SSSSSS
S.S jjr SaS jr SbS jr
SbS jr S`S jrS rS rS rS rS rS rS rS`S jrS rS rS rS rS r S! r S" r S# r S$ r \!RD 4S% jr#S& r$S' r%SS(.S) jr&SS(.S* jr'SS(.S+ jr(S, r)S- r*S. r+SS(.S/ jr,S0 r-S1 r.S2 r/S3S3S3S3S4.S5 jr0ScS6 jr1SdS
S7.S8 jjr2S9 r3S: r4S; r5S`S< jr6 SbSS3S3S3SSSSSSSS S=. S> jjr7 SeS? jr8SdS
S7.S@ jjr9SA r:SB r;S SSSSC.SD jr< SbS3S3S3SSSSE.SF jjr=S3\>R~ S3S3S4.SG jr@SH rA Sb\>R \>R SSISSSSSSS
SJ. SK jjrDSSSSL.SM jrESN rFSO rGSP rH\IR \IR \IR S S
S3SSSSQ. SR jrK\IR \IR \IR S S S3SSSSQ. SS jrLST rMSU rNSV rOSW rPSX rQSY rRSZ rSS[ rTS\ rUS] rVS^ rWS_rXg)fr i c SU l SU l SU l [ R " 5 U l / U l S U l SU l S U l [ R " S5 R U l
S U l U R [ R" " 5 5 S U l SU l S U l S U l SU l S U l [0 R2 " 5 U l SU l SU l g )Nr F monotonicg?) _timer_cancelled_count_closed _stoppingrV deque_ready
_scheduled_default_executor
_internal_fds
_thread_idtimeget_clock_info
resolution_clock_resolution_exception_handler set_debugr _is_debug_mode_old_agen_hooksslow_callback_duration_current_handle
_task_factory"_coroutine_origin_tracking_enabled&_coroutine_origin_tracking_saved_depthr r
_asyncgens_asyncgens_shutdown_called_executor_shutdown_calledr s r r BaseEventLoop.__init__ s &'# !'') !% !%!4!4[!A!L!L "& z0023 # '*# # !27/6:3 "//+*/').&r! c SU R R SU R 5 SU R 5 SU R 5 S3 $ )Nr z running=z closed=z debug=r )r r
is_running is_closed get_debugr s r r BaseEventLoop.__repr__ sP ''( $//2C1D Enn&'wt~~/?.@
C
r! c * [ R " U S9$ )Nr )r Futurer s r r BaseEventLoop.create_future s ~~4((r! N)namecontextc U R 5 U R b, Ub X4S' U R " X40 UD6nUR U5 O8[ R " U4XUS.UD6nUR
( a
UR
S UA$ ! Af = f)Nr8 )r r7 r8 )
_check_closedr' set_namer r _source_traceback)r coror7 r8 kwargstasks r create_taskBaseEventLoop.create_task s
)"$+y!%%d;F;D MM$ ::dT'TVTD%%**2. s B B c L Ub [ U5 ( d [ S5 eXl g )Nz'task factory must be a callable or None)callabler> r' )r factorys r set_task_factory BaseEventLoop.set_task_factory s& x'8'8 EF F $r! c U R $ rP )r' r s r get_task_factory BaseEventLoop.get_task_factory s !!!r! )extraserverc [ erP NotImplementedError)r r1 protocolr rK rL s r _make_socket_transport$BaseEventLoop._make_socket_transport
"!r! FT) server_sideserver_hostnamerK rL r r call_connection_madec [ erP rN ) r rawsockrP
sslcontextr rT rU rK rL r r rV s r _make_ssl_transport!BaseEventLoop._make_ssl_transport s
"!r! c [ erP rN )r r1 rP addressr rK s r _make_datagram_transport&BaseEventLoop._make_datagram_transport rS r! c [ erP rN r piperP r rK s r _make_read_pipe_transport'BaseEventLoop._make_read_pipe_transport
rS r! c [ erP rN ra s r _make_write_pipe_transport(BaseEventLoop._make_write_pipe_transport rS r! c # [ e7frP rN )
r rP argsshellstdinstdoutstderrbufsizerK r? s
r _make_subprocess_transport(BaseEventLoop._make_subprocess_transport s
"!s c [ erP rN r s r _write_to_self BaseEventLoop._write_to_self s
"!r! c [ erP rN )r
event_lists r _process_events BaseEventLoop._process_events& s !!r! c < U R ( a [ S5 eg )NzEvent loop is closed)r r r s r r; BaseEventLoop._check_closed* s << 56 6 r! c < U R ( a [ S5 eg )Nz!Executor shutdown has been called)r, r r s r _check_default_executor%BaseEventLoop._check_default_executor. s ) ) BC C *r! c U R R U5 U R 5 ( d+ U R U R UR 5 5 g g rP )r* r r0 call_soon_threadsaferA acloser agens r _asyncgen_finalizer_hook&BaseEventLoop._asyncgen_finalizer_hook2 sB %~~ % %d&6&6
F r! c U R ( a [ R " SU< S3[ U S9 U R R U5 g )Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() callsource)r+ warningswarnResourceWarningr* r r s r _asyncgen_firstiter_hook&BaseEventLoop._asyncgen_firstiter_hook7 sA * * MM)$ 21 2
.
D!r! c # SU l [ U R 5 ( d g [ U R 5 nU R R 5 [
R " U Vs/ s H o"R 5 PM snSS06I S h vN n[ X15 H5 u pE[ U[ 5 ( d M U R SU< 3UUS.5 M7 g s snf NN7f)NTreturn_exceptionsz;an error occurred during closing of asynchronous generator )messagerh asyncgen) r+ r r* rX clearr gatherr zipr Exceptioncall_exception_handler)r
closing_agensagresultsresultr s r shutdown_asyncgens BaseEventLoop.shutdown_asyncgens@ s *.'4??##
T__-
$1
2MbiikM
2$ "$ $ 7LF&),,++"99= B!' $ - 8 3$s$ A&C (C
C C 'C 7$C c # SU l U R c g U R 5 n[ R " U R
U4S9nUR
5 [ R " U5 IS h vN UI S h vN S S S 5 IS h vN UR 5 g N/ N' N! , IS h vN ( d f N.= f! [ a: [ R " SU S3[ SS9 U R R SS9 g f = f7f) NT)targetri z:The executor did not finishing joining its threads within z seconds. )
stacklevelFwait)r, r r threadingThread _do_shutdownstartr
timeoutjoin TimeoutErrorr r RuntimeWarningshutdown)r r futurethreads r shutdown_default_executor'BaseEventLoop.shutdown_default_executorY s *.& ! ! ) ##%!!):):&K ''00 10
KKM 1 1000 8 MM 007y C(Q
8
" " + + + 7 8s AD
C 3B#4C 7B)=B%>B) C
B'C D
#C %B)'C )C /B2 0 C <C ADD
DD
c t U R R SS9 U R 5 ( d" U R [ R
US 5 g g ! [ aZ nU R 5 ( d; UR 5 ( d! U R UR U5 S nAg S nAg S nAg S nAff = f)NTr ) r r r0 r~ r _set_result_unless_cancelledr rg r )r r exs r r BaseEventLoop._do_shutdownq s D " " + + + 6>>##))'*N*N*0$8 $ D>>##F,<,<,>,>))&*>*>CC -?# Ds AA
B7 AB22B7c U R 5 ( a [ S5 e[ R " 5 b [ S5 eg )Nz"This event loop is already runningz7Cannot run the event loop while another loop is running)r/ r r _get_running_loopr s r _check_running BaseEventLoop._check_running{ sA ?? CD D # # % 1 IK
K 2r! c ` U R 5 U R 5 U R U R 5 [ R
" 5 U l [ R " 5 U l [ R " U R U R S9 [ R " U 5 g )N) firstiter finalizer)r; r _set_coroutine_origin_tracking_debugsysget_asyncgen_hooksr$ r get_identr set_asyncgen_hooksr r r _set_running_loopr s r _run_forever_setup BaseEventLoop._run_forever_setup s
++DKK8 " 5 5 7 #--/ 3333
&r! c SU l S U l [ R " S 5 U R S5 U R
b% [ R " U R
6 S U l g g r )r r r r r r$ r r r s r _run_forever_cleanup"BaseEventLoop._run_forever_cleanup s[ & ++E2 + " "D$8$8 9#'D ,r! c U R 5 U R 5 U R ( a OM$ U R 5 g ! U R 5 f = frP )r _run_oncer r r s r run_foreverBaseEventLoop.run_forever sJ ! ( >>
% % 'D % % 's %A Ac V U R 5 U R 5 [ R " U5 ( + n[ R
" XS9nU( a SUl UR [ 5 U R 5 UR [ 5 UR 5 ( d [ S5 eUR 5 $ ! U( a: UR 5 ( a% UR 5 ( d UR 5 e = f! UR [ 5 f = f)Nr4 Fz+Event loop stopped before Future completed.)r; r r isfuturer
ensure_future_log_destroy_pendingadd_done_callbackro r r rg rh remove_done_callbackr r )r r new_tasks r run_until_complete BaseEventLoop.run_until_complete s
''//$$V7 +0F ' !78
@
' '(> ?{{}} LM M}} FKKMM&2B2B2D2D " ' '(> ?s 4C
ADD D(c SU l g r )r r s r rl BaseEventLoop.stop s r! c U R 5 ( a [ S5 eU R ( a g U R ( a [ R
" SU 5 SU l U R R 5 U R R 5 SU l U R nUb S U l
UR SS9 g g )Nz!Cannot close a running event loopzClose %rTFr ) r/ r r r r debugr r r r, r r r executors r r BaseEventLoop.close s ?? BC C << ;; LLT * )-&)) %)D " 5 ) r! c U R $ rP )r r s r r0 BaseEventLoop.is_closed s ||r! c U R 5 ( d7 U" SU < 3[ U S9 U R 5 ( d U R 5 g g g )Nzunclosed event loop r )r0 r r/ r )r _warns r __del__BaseEventLoop.__del__ sC ~~ (1?4 P??$$
% r! c U R S L$ rP )r r s r r/ BaseEventLoop.is_running s t+,r! c , [ R " 5 $ rP )r r r s r r BaseEventLoop.time s ~~ r! )r8 c Uc [ S5 eU R " U R 5 U- U/UQ7SU06nUR ( a
UR S U$ )Nzdelay must not be Noner8 r: )r> call_atr r= )r delaycallbackr8 ri timers r
call_laterBaseEventLoop.call_later
s] = 45 5 TYY[5 0( .T .%,. " "''+ r! c d Uc [ S5 eU R 5 U R ( a" U R 5 U R US5 [
R " XX@U5 nUR ( a
UR S [ R " U R U5 SUl
U$ )Nzwhen cannot be Noner r: T) r> r; r
_check_thread_check_callbackr TimerHandler= heapqheappushr )r whenr r8 ri r s r r BaseEventLoop.call_at% s
< 12 2 ;; 9 5""44wG " "''+
t. r! c U R 5 U R ( a" U R 5 U R US5 U R XU5 nUR
( a
UR
S U$ )N call_soonr: )r; r r r
_call_soonr= r r r8 ri r s r r BaseEventLoop.call_soon7 s_
;; ; 7 9 # #((,
r! c [ R " U5 ( d [ R " U5 ( a [ SU S35 e[ U5 ( d [ SU SU< 35 eg )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r iscoroutineiscoroutinefunctionr> rD )r r methods r r BaseEventLoop._check_callbackJ sp " "8 , ,..x881&<>
>!!4VH = l$%
% "r! c [ R " XX5 nUR ( a
UR S U R R U5 U$ )Nr: )r Handler= r rB )r r ri r8 r s r r BaseEventLoop._call_soonT s@ xt= # #((, 6"
r! c ~ U R c g [ R " 5 nXR :w a [ S5 eg )NzMNon-thread-safe operation invoked on an event loop other than the current one)r r r r )r thread_ids r r BaseEventLoop._check_thread[ s@ ?? " '') ' '(
( (r! c U R 5 U R ( a U R US5 U R XU5 nUR ( a
UR S U R 5 U$ )Nr~ r: )r; r r r r= rr r s r r~ "BaseEventLoop.call_soon_threadsafel s^ ;; +A B 9 # #((,
r! c > U R 5 U R ( a U R US5 UcB U R nU R 5 Uc# [
R R SS9nXl [ R " UR " U/UQ76 U S9$ )Nrun_in_executorasyncio)thread_name_prefixr4 )
r; r r r r{
concurrentr ThreadPoolExecutor wrap_futuresubmit)r r funcri s r r BaseEventLoop.run_in_executorw s ;; '8 9 --H ( ( * %--@@'0 A *2&"" OOD (4 (t5 5r! c x [ U[ R R 5 ( d [ S5 eXl g )Nz,executor must be ThreadPoolExecutor instance)r r r r r> r r s r set_default_executor"BaseEventLoop.set_default_executor s- (J$6$6$I$IJJ JK K!) r! c X U SU< 3/nU( a UR SU< 35 U( a UR SU< 35 U( a UR SU< 35 U( a UR SU< 35 SR U5 n[ R " SU5 U R 5 n[
R " XX4XV5 n U R 5 U-
n
SU S U
S
- S S U < 3nXR : a [ R " U5 U $ [ R " U5 U $ )
N:zfamily=ztype=zproto=zflags=, zGet address info %szGetting address info z took g @@z.3fzms: ) rB r r r r r+ getaddrinfor% info) r rD rE rF rG rH flagsmsgt0addrinfodts r _getaddrinfo_debug BaseEventLoop._getaddrinfo_debug s q!" JJ
+ , JJth' ( JJy) * JJy) *iin *C0
YY[%%d&M
YY[2
%cU&c#d8,O
,, , KK
LL r! r rF rG rH r c
# U R ( a
U R nO[ R nU R S XqX#XEU5 I S h vN $ N7frP )r r r+ r r )r rD rE rF rG rH r getaddr_funcs r r BaseEventLoop.getaddrinfo sN ;; 22L!--L)) ,dDH H H Hs AA A
Ac ` # U R S [ R X5 I S h vN $ N7frP )r r+ getnameinfo)r sockaddrr s r r" BaseEventLoop.getnameinfo s/ )) &$$h7 7 7 7s %.,.)fallbackc f # U R ( a UR 5 S:w a [ S5 e[ U5 U R XX45 U R XX45 I S h vN $ N! [ R a nU( d e S nAOS nAff = fU R XX45 I S h vN $ 7f)Nr z the socket must be non-blocking) r
gettimeoutr, rx _check_sendfile_params_sock_sendfile_nativer SendfileNotAvailableError_sock_sendfile_fallback)r r1 fileoffsetcountr% rn s r
sock_sendfileBaseEventLoop.sock_sendfile s ;;4??,1 >? ?$ ##D> 33D4:C C
C C33 11$28A A A AsN AB1A- &A+'A- *B1+A- -BB B1BB1+B.,B1c H # [ R " SU< SU< S35 e7f)Nz-syscall sendfile is not available for socket z
and file z combinationr r* r r1 r, r- r. s r r) #BaseEventLoop._sock_sendfile_native s3 22;D8 D x|
-. .s "c # [ US5 ( a UR U5 U( a [ U[ R 5 O[ R n[ U5 nSn U( a [ XG-
U5 nUS:: a O][
U5 S U nU R S UR U5 I S h vN n U ( d O"U R XS U 5 I S h vN Xy-
nMy UUS: a& [ US5 ( a UR X7- 5 $ $ $ N\ N:! US: a& [ US5 ( a UR X7- 5 f f f = f7f)Nseekr )
r* r6 minr !SENDFILE_FALLBACK_READBUFFER_SIZE bytearray
memoryviewr readinto sock_sendall)
r r1 r, r- r. blocksizebuf
total_sentviewreads
r r+ %BaseEventLoop._sock_sendfile_fallback s5 4 IIf
yBB C#EE "
/ #E$6 BI A~ !#z 2 ! 1 1$
t LL''5Dk:::"
A~'$"7"7 &-. #8~ M ; A~'$"7"7 &-. #8~sC A!E$A D /D 0#D D D -E D D .D>>Ec S[ USS5 ; a [ S5 eUR [ R :X d [ S5 eUbO [ U[ 5 ( d [ SR U5 5 eUS:: a [ SR U5 5 e[ U[ 5 ( d [ SR U5 5 eUS: a [ SR U5 5 eg )Nbmodez$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r z0offset must be a non-negative integer (got {!r})) r r, rG r+ r: r r= r> formatr3 s r r( $BaseEventLoop._check_sendfile_params s gdFC0 0 CD DyyF . .. JK K eS)) AHHOQ Qz AHHOQ Q&#&&BII
A: BII
r! c # / nUR " U5 Uu pVpxn S n
[ R " XVUS9n
U
R S5 UbN U H! u n pX:w a M U
R U 5 O) U( a UR 5 e[ SU< S35 eU R X5 I S h vN U
S =p$ ! [ aR n
SU < S[ U
5 R
5 3n[ U
R U5 n
UR U
5 S n
A
M S n
A
ff = f Nh! [ a n
UR U
5 e S n
A
ff = f! U
b" U
R 5 e ! [ a e f = fe = f! S =pf = f7f)NrF rG rH F*error while attempting to bind on address : z&no matching local address with family=z found) rB r+ setblockingbindr/ r lowererrnopop sock_connectr )r r addr_infolocal_addr_infos
my_exceptionsrF type_rH _r] r1 lfamilyladdrrn r s r
_connect_sockBaseEventLoop._connect_sock s
-(+4(u( .
}}FeL '#/3C/Aq", $ 6 IIe , !
4D )"/"3"3"5 5"),SF9TZ*["\ \''666 *. -J 9 ' 6#++0)2c#hnn6F5G!I #*#))S"9C ) 0 0 5 5
6 7
$$S)
JJL
)- -J s E.:D B6-?D ,D-D 2E.6
D AD
D
DD
D8!D33D88D; ;E#EE#
E E# E E##E& &E++E.) rv rF rH r r1
local_addrrU r r happy_eyeballs_delay
interleave
all_errorsc ^ ^^^# U
b U( d [ S5 eU
c U( a U( d [ S5 eUn
U b U( d [ S5 eU b U( d [ S5 eUb [ U5 U
b Uc SnUc UGb Ub [ S5 eT R X#4U[ R XgT S9I S h vN nU( d [ S5 eU b< T R X[ R UUT S9I S h vN mT( d [ S5 eOS mU( a [
UU5 n/ mU
c& U H n T R TUT5 I S h vN n O0 O-[ R " UUU 4S jU 5 U
T S
9I S h vN S nUc T VVs/ s H nU H nUPM M snnm U( a [ S T5 e[ T5 S:X a TS eT( a] [ TS 5 m[ U4S
jT 5 5 ( a TS e[ SR SR S T 5 5 5 5 e[! S 5 eO;Uc [ S5 eUR" [ R :w a [ SU< 35 eT R% XXJU U S9I S h vN u nnT R& ( a+ UR) S5 n[* R, " SXUUU5 UU4$ GN GN GN! [
a GM f = f GNus snnf ! S mf = f Nr7f)Nz+server_hostname is only meaningful with sslz:You must set server_hostname when using ssl without a host1ssl_handshake_timeout is only meaningful with ssl0ssl_shutdown_timeout is only meaningful with sslr 8host/port and sock can not be specified at the same timerF rG rH r r !getaddrinfo() returned empty listc 3 : ># U H nU4UUU4S jjv M g7f)c * > TR TU T5 $ rP )rY )r r laddr_infosr s r ;BaseEventLoop.create_connection... s $2D2D &+3r! NrQ )rR r r rg r s r rT 2BaseEventLoop.create_connection.. s& ).H )1 ).s r4 r zcreate_connection failedc 3 @ ># U H n[ U5 T:H v M g 7frP r )rR rn models r rT rj s GJSs3x5 0Js zMultiple exceptions: {}r c 3 8 # U H n[ U5 v M g 7frP rl )rR rn s r rT rj s %E*3c#hh*s z5host and port was not specified and no sock specified"A Stream Socket was expected, got )r r r+ z %r connected to %s:%r: (%r, %r))r, rx _ensure_resolvedr+ r: r/ re rY r staggered_raceExceptionGroupr r allrF r r rG _create_connection_transportr get_extra_infor r )r r rD rE rv rF rH r r1 r[ rU r r r\ r] r^ infosr subrn r rP r rg rm s ` @@@r create_connection BaseEventLoop.create_connection' s ( &s JK K "s "A B B "O ,S CE
E +C BD
D d # +
0BJ t / NP P // V''u 0 N NE ABB%$($9$9 ++5 d %: %, , #!"EFF # # -eZ@J#+ %H!%)%7%7 &+&? ? !& ( 6 6 ).
) |-7 GZc3Cc3cZ G
&! ,-G TT:!+ (m+# #JqM 2 GJ GGG",Q- / &&?&F&F II%E*%E E'G H H ++E FF% . | KM MyyF . .. !8AC C %)$E$E C"7!5 %F %7 7 8 ;; ++H5D LL: T9h
@(""sN ," ? # ! ! H& "&J 7s B.K64K 5=K62K 36K6*K KK*K6/K$0K6?K'K6BK- 0AK6K4AK6 K6K
K! K6 K!!K6'K6-K11K6c 2 # UR S5 U" 5 nU R 5 n U( a- [ U[ 5 ( a S OUn
U R XXXTUUS9n OU R XU 5 n U I S h vN X4$ N! U R
5 e = f7f)NFrT rU r r )rL r r boolrZ rQ r ) r r1 r rv rU rT r r rP r rY r s r rt *BaseEventLoop._create_connection_transport s
#%##% !+C!6!6CJ 00
'&;%9 1 ;I 33DFKI LL
""
OO s0 A/B2B 7A?8B <B?B BBc # UR 5 ( a [ S5 e[ US[ R R
5 nU[ R R
L a [ SU< 35 eU[ R R L a U R XX45 I S h vN $ U( d [ SU< 35 eU R XX45 I S h vN $ N4! [ R a nU( d e S nANSS nAff = f N/7f)NzTransport is closing_sendfile_compatiblez(sendfile is not supported for transport zHfallback is disabled and native sendfile is not supported for transport ) r r r r
_SendfileMode UNSUPPORTED
TRY_NATIVE_sendfile_nativer r* _sendfile_fallback)r r r, r- r. r% rE rn s r sendfileBaseEventLoop.sendfile s 0 ! ! 56 6y"8 ..::< 9**66 6 :9-HJ
J 9**55 5
! 2 2939 B B B ++4-9:
: ,,Y-3< < <B 77
r? rH r@ rA s r r BaseEventLoop._sendfile_fallback s} 4 IIf ).Cu%E "
)&1 " #E$6 BI A~ ) A~'$"7"7 &-.--/ ! ! "#z 2 ! 1 1$
t LL%
A~'$"7"7 &-.--/ ! !
T%4[)kkm##"
" M
" $ A~'$"7"7 &-.--/ ! !s AF4 E, 0=F4-E$.F43.E, !E&" E, .=F4+E(,F41'E, E* E, $F4&E, (F4*E, ,>F1*F-+F11F4r{ c V # [ c [ S5 e[ U[ R 5 ( d [ SU< 35 e[ USS5 ( d [ SU< S35 eU R
5 n[ R " XX8XEUUSS9 n UR 5 U( ad SS K
J n
[ X*5 ( aN [ US
S 5 n U b> U R n U ( a+ U R R U 5 U R 5 UR! U 5 U R# U R$ U5 n
U R# UR& 5 n UI S h vN U R. $ N! [( a2 UR+ 5 U
R- 5 UR- 5 e f = f7f) Nz"Python ssl module is not availablez@sslcontext is expected to be an instance of ssl.SSLContext, got _start_tls_compatibleFz
transport z is not supported by start_tls())r r rV r )StreamReaderProtocol_stream_reader)rv r r
SSLContextr> r r r
SSLProtocolr streamsr _buffer _incomingr r r r r r
BaseExceptionr r _app_transport)r r rP rY rT rU r r r ssl_protocolr
stream_readerbuffer
conmade_cb resume_cbs r start_tlsBaseEventLoop.start_tls$ s ; CD D*cnn55!n&'
' y"95AA YM)IJL
L ##% ++ J "7!5!& ( ! 5(99 '2BD I
, * 2 2F $..44V< |,^^L$@$@)L
NN9#;#;< LL ***
OO s0 EF)E* E(E* F)(E* *.q s $NLDAAZs!A3ZLs
!!zKsocket modifier keyword arguments can not be used when sock is specified. ()Fr zunexpected address familyNNAF_UNIXzstring is expected)r z2Unable to check or remove stale UNIX socket %r: %rr r z2-tuple is expectedrc rd z can not get address informationrI z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))'rG r+ r: r, dictr itemsrL r* r r r r> statS_ISSOCKosst_moderemoveFileNotFoundErrorr/ r errorr r rp r; r2 r- r. SO_BROADCASTrM rQ r rB r r^ r r r ) r r r[ r rF rH r r r r1 optsproblemsr_addraddr_pairs_inforb err
addr_infosidxrv famrV pror] key addr_pairr
local_addressremote_addressrn rP r r s r create_datagram_endpoint&BaseEventLoop.create_datagram_endpoint_ s yyF . .. :4(CE Ekeu /z#)e'1,;= 99$NDJJL$NN 008z<= =
U #F +Q;$%@AA%+O\#B"D++&..0H ' 5D'
40E0E '(< == 6 *Q-{"B 6 ==)<)D)DEE IIj 1 &,O%/$=$? #B
#$j/A{3C!DIC' *4 7 7CIN"+,A"B B&*&;&; f6G6G"'4 '< 'A !A %")*M"N N7< 3CCG#&*C "* 437,
33:JsOC 0 8= "E& Uc [ S5 eURX [( RZ :w a [ SU< 35 eU/nU H nUR] S 5 M [_ XUXU U
5 n U( a. U Ra 5 [ Rb " S5 I S h vN U R, ( a [. Rd " SU 5 U $ s snf GN! [( R* a. U R, ( a [. R0 " S
UUUS S 9 GM f = f! [L a nSU< S[ U5 RO 5 < 3nURP [P RR :X aN URU 5 URW 5 U R, ( a [. R0 " U5 S nAGMI [M URP U5 S eS nAff = fs sn f ! U( d U H nURW 5 M f f = f GN]7f)Nz*ssl argument must be an SSLContext or Noner` ra rb posixcygwinr5 )rF r Fz:create_server() failed to create socket.socket(%r, %r, %r)Texc_info IPPROTO_IPV6rJ rK z%could not bind on any address out of z)Neither host/port nor sock were specifiedro r z
%r is serving)3r r| r> r, rx r r7 r platformr rV abcIterabler r r setr[ r\ r] r+ r r r warningrB r- r. SO_REUSEADDRr@ r r2 SO_KEEPALIVErA r* r IPV6_V6ONLYrM r/ rN rO
EADDRNOTAVAILrP r rG r: rL r r r r ) r r rD rE rF r r1 r rv r r r r r r r hostsfsrv completedresrL socktyperH canonnamesar r r rL s r
create_serverBaseEventLoop.create_server sE : c4 HI I , CE
E + BD
D d # t / NP P $ "7 2 Os||x7O
Grz T3'' {'?'?@@ $% #d 11$V8= 2 ? #
% ,,++E 55e<=E I7
% C9<6B%B! %}}R5 A NN4($ " - -v/B/BDJ "bV^^V__,M&M&t,! " - -v/B/BDJ
" &// 1 #FN ; ; (;(;(.(:(:(,.
@ "
A !\ !:?%@%$d1g%%@#C D D ! '
!( | !LMMyyF . .. #EdX!NOOfGD U # '7&;,. ! ! # ++a. ;; KK 0
i% , "<< ! ;; "NN ,G+-x O !
!: # @ #%c#hnn&6 8 99(;(;; #KKM JJL #{{ &s 3 $ %cii 54? @ &A ! '
!( !(
!s C*S',N6S' N; .S'R> N>6DR>
P R> 4R9
R> B8S'S$4S'>=P ;R> ?P R>
R6
BR1R> R11R66R> >#S!!S')rv r r c
# UR [ R :w a [ SU< 35 eUb U( d [ S5 eUb U( d [ S5 eUb [ U5 U R X!USSUUS9I S h vN u pgU R ( a) UR S5 n[ R " SX&U5 Xg4$ NC7f) Nro r` ra r5 T)rT r r r+ z%r handled: (%r, %r))
rG r+ r: r, rx rt r ru r r )r r r1 rv r r r rP s r connect_accepted_socket%BaseEventLoop.connect_accepted_socket s
99** * A$ JK K ,S CE
E +C BD
D d #$($E$E C"7!5 %F %7 7 ;; ++H5D LL/( K"" 7s A=C?C ACc # U" 5 nU R 5 nU R X#U5 n UI S h vN U R ( a& [ R
" SUR
5 XS5 XS4$ N>! UR 5 e = f7f)Nz Read pipe %r connected: (%r, %r))r rc r r r r filenor r rb rP r r s r connect_read_pipe BaseEventLoop.connect_read_pipe s} #%##%2246J LL
;; LL;
=""
OO + *B A3 A1A3 :B 1A3 3BB c # U" 5 nU R 5 nU R X#U5 n UI S h vN U R ( a& [ R
" SUR
5 XS5 XS4$ N>! UR 5 e = f7f)Nz!Write pipe %r connected: (%r, %r))r rf r r r r r r s r connect_write_pipe BaseEventLoop.connect_write_pipe s} #%##%33DFK LL
;; LL<
=""
OO r c ~ U/nUb UR S[ U5 35 Ub2 U[ R :X a UR S[ U5 35 O@Ub UR S[ U5 35 Ub UR S[ U5 35 [ R
" SR
U5 5 g )Nzstdin=zstdout=stderr=zstdout=zstderr= )rB r' r# r% r r r )r r rk rl rm r s r _log_subprocess BaseEventLoop._log_subprocess s u KK& e!4 56 7 &J,=,="= KK. f)=(>? @! gl6&:%; <=! gl6&:%; <= SXXd^$r! ) rk rl rm universal_newlinesrj rn encodingerrorstextc # [ U[ [ 45 ( d [ S5 eU( a [ S5 eU( d [ S5 eUS:w a [ S5 eU ( a [ S5 eU b [ S5 eU
b [ S5 eU" 5 n
S nU R ( a S U- nU R XXE5 U R " XS
X4XX40 U D6I S h vN nU R ( a Ub [ R " S X5 X4$ N27f) Nzcmd must be a string universal_newlines must be Falsezshell must be Truer bufsize must be 0text must be Falseencoding must be Noneerrors must be Nonezrun shell command %rT%s: %r) r r< r r, r r ro r r )r r cmdrk rl rm r rj rn r r r r? rP debug_logr s r subprocess_shell BaseEventLoop.subprocess_shell s
#s|,, 34 4 ?@ @ 12 2 a< 01 1 12 2 45 5 23 3#% ;; /4I 6 B 99 4KCIK K ;;90 KK) 7"" Ks CD D 3D c # U( a [ S5 eU( a [ S5 eUS:w a [ S5 eU ( a [ S5 eU b [ S5 eU
b [ S5 eU4U - nU" 5 nS nU R ( a SU< 3nU R UX4U5 U R " XS X4UU40 U
D6I S h vN nU R ( a Ub [ R
" S
UU5 UU4$ N47f) Nr zshell must be Falser r r r r zexecute program Fr )r, r r ro r r )r r programrk rl rm r rj rn r r r ri r?
popen_argsrP r r s r subprocess_exec BaseEventLoop.subprocess_exec s ?@ @ 23 3 a< 01 1 12 2 45 5 23 3 Z$&
#% ;; +7+6I E6 B 99 % ;;90 KK)Y 7("" s B7C09C.:5C0c U R $ rP )r! r s r get_exception_handler#BaseEventLoop.get_exception_handler s &&&r! c T Ub [ U5 ( d [ SU< 35 eXl g )Nz+A callable object or None is expected, got )rD r> r! )r handlers r set_exception_handler#BaseEventLoop.set_exception_handler s6 x'8'8 ##*+ / 0
0") r! c UR S5 nU( d SnUR S5 nUb [ U5 X3R 4nOSnSU; aA U R b4 U R R ( a U R R US' U/n[ U5 H nUS; a M X nUS:X a: SR
[ R " U5 5 nS nXxR 5 -
nOKUS:X a: SR
[ R " U5 5 nS
nXxR 5 -
nO [ U5 nUR U S U 35 M [ R " S R
U5 US
9 g )Nr z!Unhandled exception in event looprh Fsource_tracebackhandle_traceback> r rh r5 z+Object created at (most recent call last):
z+Handle created at (most recent call last):
rK
r )getrG
__traceback__r& r= sortedr traceback format_listrstripr rB r r ) r r8 r rh r log_linesr valuetbs r default_exception_handler'BaseEventLoop.default_exception_handler1 sS ++i(9GKK , Y4K4KLH H g -$$0$$66$$66
& ' I '?C..LE((WWY 2 25 9:F$**WWY 2 25 9:F$ U uBug . / # TYYy)H=r! c U R c U R U5 g S nUR S5 nUc UR S5 nUc UR S5 nUb! [ US5 ( a UR 5 nUb. [ US5 ( a UR U R X5 g U R X5 g ! [ [ 4 a e [ a [
R " SSS9 g f = f! [ [ 4 a e [ aY n U R S UUS
.5 S nAg ! [ [ 4 a e [ a [
R " S SS9 S nAg f = fS nAff = f) Nz&Exception in default exception handlerTr r@ r r get_contextrunz$Unhandled error in exception handler)r rh r8 zeException in default exception handler while handling an unexpected error in custom exception handler) r! r ri rj r r r r r* r r )r r8 ctxthingrn s r r $BaseEventLoop.call_exception_handlerc sr 0 " " *
,..w7$
0 F+= $KK 1E= #KK 1E$
)F)F ++-C?wsE':':GGD 3 3TC++D:3 12
, E&*,
,0 12
0022#I%(#*4
#$56 $ 0 LL "? +/0 00
0sG C BC9 2C9 /C65C69E,D../E$ E'#E$$E''E,c ^ UR ( d U R R U5 g g rP )
_cancelledr rB r r s r
_add_callbackBaseEventLoop._add_callback s" KK v & !r! c F U R U5 U R 5 g rP )r' rr r& s r _add_callback_signalsafe&BaseEventLoop._add_callback_signalsafe s 6" r! c R UR ( a U =R S-
sl g g rr )r r r& s r _timer_handle_cancelled%BaseEventLoop._timer_handle_cancelled s! ' '1 , ' r! c [ U R 5 nU[ : a{ U R U- [ : ad / nU R H. nUR
( a SUl M UR
U5 M0 [ R " U5 X l SU l OU R ( a U R S R
( am U =R S- sl [ R " U R 5 nSUl U R ( a U R S R
( a Mm S nU R ( d U R ( a SnOTU R ( aC U R S R U R 5 -
nU[ : a [ nOUS: a SnU R R! U5 nU R# U5 S nU R 5 U R$ - nU R ( au U R S nUR U: a OU[ R " U R 5 nSUl U R R
U5 U R ( a Mu [ U R 5 n[' U5 H nU R R) 5 nUR
( a M0 U R* ( as X0l U R 5 n UR/ 5 U R 5 U -
n
XR0 : a! [2 R4 " S[7 U5 U
5 S U l M UR/ 5 M S ng ! S U l f = f)NFr r z Executing %s took %.3f seconds) r r _MIN_SCHEDULED_TIMER_HANDLESr %_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr% rB r heapifyheappopr r _whenr MAXIMUM_SELECT_TIMEOUT _selectorselectrv r rangepopleftr r& _runr% r r r ) r sched_count
new_scheduledr r ru end_timentodoir r s r r BaseEventLoop._run_once s $//* 6 6 ' '+ 55
6 M //$$(-F%!((0 *
MM- ( +O*+D ' //dooa&8&C&C++q0+ t7$)! //dooa&8&C&C&C
;;$..G
__ooa(.. 0 6: $ 26 &%(" =A 5 *
2 "#!1H7
A(,
A ./4 *..b 59T#14T"&!%!%$ T#p */"&!% #8,<#',<\1"4 %*(,.2-1 9+x EID#./q267;$ D#N '(f.@.@%&a
D 59O #### "&!% Of "&!% #<# # % &0__&0oo&0oo27%)1(,T
"#J %/OOJOO%/__$)1'+Dt #D'
*"0>dH0T'
-
Qf
: Tr! r )r r )r )6rV collections.abcconcurrent.futuresr rO r r[ r r+ r r# r r r r r r rv ImportErrorr5 r r r r r r r
r r r
r r logr __all__r0 r1 r* rA r5 r r' r2 rM re ro rs rx Protocolrz AbstractServerr AbstractEventLoopr rQ r! r rU s+
$
# ), %
FJ ' # J8v," 6=!!G
>
A) 2 2 A)HKV
"
" K\DTF,, DT}
Cs D D D