֦i2 4 d dl Z d dlZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlZd dlZ d dlZddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lm Z dd lm Z dd
lm Z ddlm Z ddl m!Z! dZ"dZ#dZ$ e%ed Z&dZ'd Z(d Z)d Z*d%dZ+d&dZ,d Z- e%ed rd Z.nd Z.d Z/ G d d ej` Z1 G d! d"ejd Z3 G d# d$ejh Z5y# e$ r dZY w xY w)' N ) constants)
coroutines)events)
exceptions)futures) protocols)sslproto) staggered)tasks)timeouts)
transports)trsock)logger)
BaseEventLoopServerd g ?AF_INET6iQ c | j }t t |dd t j rt |j S t | S )N__self__) _callback
isinstancegetattrr Taskreprr str)handlecbs ,/usr/lib64/python3.12/asyncio/base_events.py_format_handler G s= B'"j$/<BKK 6{ c h | t j k( ry| t j k( ryt | S )Nzz)
subprocessPIPESTDOUTr )fds r _format_piper' P s+ Z__ z Bxr! c t t d s t d | j t j t j
d y # t $ r t d w xY w)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 s` 6> *DEE J OOF - -v/B/BA F J I J
J Js /A
A"c P t t d sy |dt j t j hvs| y |t j k( rt j }n%|t j
k( rt j }ny |d}n,>?? L v!!!""
"" """ | D% TS[ D# 42: t9D !!!~~ JJv 'h$ {{6"
d{ R &R6?? 24T47,KKK4T4L88 ; :& 2 s* 7 F ;9F7FFF F%$F%c t j }| D ]$ }|d }||vrg ||< || j | & t |j }g }|dkD r%|j |d d |dz
|d d |dz
= |j d t j j t
j | D |S )Nr r c 3 $ K | ] }||
y wN ).0as r z(_interleave_addrinfos.. s!
a
]
s )
collections OrderedDictrB listvaluesextend itertoolschain
from_iterable zip_longest) addrinfosfirst_address_family_countaddrinfos_by_familyaddrrF addrinfos_lists reordereds r _interleave_addrinfosrd s 7%113a , ,*, 'F#**40
.5578OI!A% +,K-G!-KLM A > :Q > > ?
??00 ! !? 3
r! c | j s'| j }t |t t f ry t j | j y rP ) cancelled exceptionr
SystemExitKeyboardInterruptr _get_loopstop)futexcs r _run_until_complete_cbrn sB ==?mmo cJ(9: ;
c !r! TCP_NODELAYc 4 | j t j t j hv rl| j t j
k( rN| j t j k( r0| j t j t j d y y y y Nr )
rF r+ r@ r rG r: rH r8 r- ro r0 s r _set_nodelayrr sj KKFNNFOO< < V / //
f 0 00 OOF . .0B0BA F 1 0
=r! c y rP rQ r0 s r rr rr s r! c \ t &t | t j r t d y y )Nz"Socket cannot be of type SSLSocket)sslr SSLSocketr> r0 s r _check_ssl_socketrw s'
:dCMM:<== ;r! c B e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z y
) _SendfileFallbackProtocolc t |t j s t d || _ |j | _ |j | _ |j | _
|j |j | | j r*| j j j | _ y d | _ y )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__z"_SendfileFallbackProtocol.__init__ s &*">">? LM M ))+ &,&7&7&9#&,&=&=# D! & &$(OO$9$9$G$G$ID !$(D !r! c K | j j r t d | j }|y | d { y 7 w)NzConnection closed by peer)r|
is_closingConnectionErrorr )r rl s r drainz _SendfileFallbackProtocol.drain s< ?? % % '!"=> >## ; s :AAAc t d )Nz?Invalid state: connection should have been established already. RuntimeError)r transports r connection_madez)_SendfileFallbackProtocol.connection_made s N O Or! c | j B|%| j j t d n| j j | | j j | y )Nz Connection is closed by peer)r
set_exceptionr r~ connection_lost)r rm s r r z)_SendfileFallbackProtocol.connection_lost s[ , {%%33#$BCE %%33C8 ##C(r! c p | j y | j j j | _ y rP )r r| r r r s r
pause_writingz'_SendfileFallbackProtocol.pause_writing s, , $ 5 5 C C E r! c b | j y | j j d d | _ y )NF)r
set_resultr s r resume_writingz(_SendfileFallbackProtocol.resume_writing s- ( ((/ $ r! c t d Nz'Invalid state: reading should be pausedr )r datas r
data_receivedz'_SendfileFallbackProtocol.data_received DEEr! c t d r r r s r eof_receivedz&_SendfileFallbackProtocol.eof_received r r! c < K | j j | j | j r| j j | j
| j
j
| j r| j j y y wrP ) r| r r~ r resume_readingr cancelr r r s r restorez!_SendfileFallbackProtocol.restore ss $$T[[1 & & OO * * , ,
! ! ( ( * & & KK & & ( 's BB N) __name__
__module__ __qualname__r r r r r r r r r rQ r! r ry ry s3 ) O )F
% FF
)r! ry c h e Zd Z ddZd Zd Zd Zd Zd Zd Z d Z
e d
Z d Z
d Zd
Zd Zy)r Nc || _ || _ d| _ g | _ || _ || _ || _ || _ || _ d| _ d | _
y )Nr F) r _sockets
_active_count_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 zServer.__init__ sU
!1
'&;#%9"
$(!r! c P d| j j d| j dS )N) __class__r r r s r __repr__zServer.__repr__# s' 4>>**+9T\\4DAFFr! c . | xj dz
c_ y rq )r r s r _attachzServer._attach& s a r! c | xj dz c_ | j dk( r | j | j y y y )Nr r )r r _wakeupr s r _detachzServer._detach* s; a "t}}'< LLN (= "r! c | | j }d | _ |D ]$ }|j r|j d & y rP )r doner )r waiterswaiters r r zServer._wakeup0 s3 --
F;;=!!$' r! c
* | j ry d| _ | j D ]p }|j | j | j j | j || j | | j | j | j r y NT)
r r listenr r _start_servingr r r r )r r1 s r r zServer._start_serving7 sp ==
MMD KK
& JJ % %&&d.?.?dmmT%@%@**
, "r! c | j S rP )r r s r get_loopzServer.get_loopB s zzr! c | j S rP )r r s r
is_servingzServer.is_servingE s }} r! c T | j yt d | j D S )NrQ c 3 F K | ] }t j | y wrP )r TransportSocket)rR ss r rT z!Server.sockets..L s F
1V++A.
s !)r tupler s r r zServer.socketsH s$ == F
FFFr! c P | j }|y d | _ |D ] }| j j | d| _ | j ;| j j s!| j j
d | _ | j dk( r| j y y )NFr ) r r
_stop_servingr r r r r r )r r r1 s r closez Server.closeN s -- ?
D JJ $ $T *
% % 1--224 % % , , .(,D % " LLN #r! c j K | j t j d d { y 7 w)Nr )r r sleepr s r
start_servingzServer.start_servinga s% kk!n s )313c K | j t d| d | j t d| d | j | j j | _ | j d { d | _ y 7
# t j $ r1 | j | j d { 7 # xY ww xY w# d | _ w xY ww)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_foreverzServer.serve_foreverg s $ $ 0 $!MNP
P ==
;< < $(JJ$<$<$>! -++ + + )-D %
,((
&&((( )-D %s` A&C)B 8B9B >CB C #C?C CC CC C CCc K | j y | j j }| j j | | d { y 7 wrP )r r r rB )r r s r r zServer.wait_closed| sE ( == ))+
V$ s A A A ArP )r r r r r r r r r r r propertyr r r r r rQ r! r r r s[ >B ) G ( , G G
& -*r! r c e Zd Zd Zd Zd ZddddZd Zd Zd\ddd d
Z d\d dddddd d
dZ
d]dZ d^dZ d^dZ
d\dZd Zd Zd Zd Zd Zd Zd Zd\dZd Zd Zd Zd Zd Zd Z d! Z e j> fd"Z d# Z!d$ Z"dd%d&Z#dd%d'Z$dd%d(Z%d) Z&d* Z'd+ Z(dd%d,Z)d- Z*d. Z+d/ Z,d0d0d0d0d1d2Z-d_d3Z.d`d d4d5Z/d6 Z0d7 Z1d8 Z2d\d9Z3 d^dd0d0d0dddddddd d: d;Z4 dad<Z5d`d d4d=Z6d> Z7d? Z8d dddd@dAZ9 d^d0d0d0ddddBdCZ:d0e;jx d0d0d1dDZ=dE Z> d^e;j~ e;j ddFdddddd dG
dHZAddddIdJZBdK ZCdL ZDdM ZEeFj eFj eFj d d d0ddddN dOZHeFj eFj eFj d d d0ddddN dPZIdQ ZJdR ZKdS ZLdT ZMdU ZNdV ZOdW ZPdX ZQdY ZRdZ ZSd[ ZTy)br c d| _ d| _ d| _ t j | _ g | _ d | _ d| _ d | _ t j d j | _
d | _ | j t! j" d| _ d | _ d | _ d| _ d | _ t/ j0 | _ d| _ d| _ y )Nr F monotonicg?) _timer_cancelled_count_closed _stoppingrU deque_ready
_scheduled_default_executor
_internal_fds
_thread_idtimeget_clock_info
resolution_clock_resolution_exception_handler set_debugr _is_debug_modeslow_callback_duration_current_handle
_task_factory"_coroutine_origin_tracking_enabled&_coroutine_origin_tracking_saved_depthweakrefWeakSet
_asyncgens_asyncgens_shutdown_called_executor_shutdown_calledr s r r zBaseEventLoop.__init__ s &'# !'') !% !%!4!4[!A!L!L "& z0023 '*# # !27/6:3 "//+*/').&r! c d| j j d| j d| j d| j d S )Nr z running=z closed=z debug=r )r r
is_running is_closed get_debugr s r r zBaseEventLoop.__repr__ sP ''( $//2C1D Enn&'wt~~/?.@
C
r! c 0 t j | S )Nr )r Futurer s r r zBaseEventLoop.create_future s :~~4((r! N)namecontextc 4 | j | j 3t j || || }|j rM|j d= n?|| j | | }n| j | || }t j
|| |~S # ~w xY w)N)r r r
r
)
_check_closedr r r _source_traceback_set_task_name)r coror r
tasks r create_taskzBaseEventLoop.create_task s
%::dD'JD%%**2.))$5))$g)F t , s B Bc D |t | s t d || _ y )Nz'task factory must be a callable or None)callabler> r )r factorys r set_task_factoryz BaseEventLoop.set_task_factory s* x'8 EF F $r! c | j S rP )r r s r get_task_factoryz BaseEventLoop.get_task_factory s J!!!r! )extraserverc t rP NotImplementedError)r r1 protocolr r r s r _make_socket_transportz$BaseEventLoop._make_socket_transport s &!!r! FT) server_sideserver_hostnamer r r r call_connection_madec t rP r ) r rawsockr
sslcontextr r! r" r r r r r# s r _make_ssl_transportz!BaseEventLoop._make_ssl_transport s
$!!r! c t rP r )r r1 r addressr r s r _make_datagram_transportz&BaseEventLoop._make_datagram_transport s (!!r! c t rP r r piper r r s r _make_read_pipe_transportz'BaseEventLoop._make_read_pipe_transport s )!!r! c t rP r r, s r _make_write_pipe_transportz(BaseEventLoop._make_write_pipe_transport s *!!r! c K t wrP r )
r r argsshellstdinstdoutstderrbufsizer kwargss
r _make_subprocess_transportz(BaseEventLoop._make_subprocess_transport s +!!s
c t rP r r s r _write_to_selfz BaseEventLoop._write_to_self s "!r! c t rP r )r
event_lists r _process_eventsz BaseEventLoop._process_events s &!!r! c 2 | j r t d y )NzEvent loop is closed)r r r s r r zBaseEventLoop._check_closed s << 56 6 r! c 2 | j r t d y )Nz!Executor shutdown has been called)r r r s r _check_default_executorz%BaseEventLoop._check_default_executor# s ) ) BC C *r! c | j j | | j s+| j | j |j y y rP )r discardr call_soon_threadsafer acloser agens r _asyncgen_finalizer_hookz&BaseEventLoop._asyncgen_finalizer_hook' s? %~~ % %d&6&6
F r! c | j r t j d|dt | | j j | y )Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() callsource)r warningswarnResourceWarningr addrF s r _asyncgen_firstiter_hookz&BaseEventLoop._asyncgen_firstiter_hook, sA * * MM)$ 21 2
.
D!r! c K d| _ t | j sy t | j }| j j t j |D cg c] }|j c}ddi d { }t || D ]. \ }}t |t s| j d|||d 0 y c c}w 7 Gw)NTreturn_exceptionsz;an error occurred during closing of asynchronous generator )messagerg asyncgen) r lenr rW clearr gatherrE zipr Exceptioncall_exception_handler)r
closing_agensagresultsresultrG s r shutdown_asyncgensz BaseEventLoop.shutdown_asyncgens5 s :*.'4??#
T__-
$1
2MbbiikM
2$ "$ $ 7LFD&),++"99= B!' $ - 8 3$s$ A!C#C:
CC &C,!Cc K d| _ | j y | j }t j | j
|f }|j
t j | 4 d { | d { d d d d { |j y 7 /7 '7 # 1 d { 7 sw Y )xY w# t $ r? t j d| dt d | j j d Y y w xY ww) NT)targetr2 z:The executor did not finishing joining its threads within z seconds. )
stacklevelFwait)r r r threadingThread _do_shutdownstartr
timeoutjoin TimeoutErrorrL rM RuntimeWarningshutdown)r rj futurethreads r shutdown_default_executorz'BaseEventLoop.shutdown_default_executorN s *.& ! ! ) ##%!!):):&K ''00 10
KKM 1 1000 8 MM 007y C(Q
8
" " + + + 7 8s AD
B? 4B$5B? 8B*>B&?B* B? B(B? D
$B? &B*(B? *B<0B3 1B<8B? ?ADD
DD
c Z | j j d | j s"| j t j
|d y y # t $ rP}| j s6|j s!| j |j | Y d }~y Y d }~y Y d }~y d }~ww xY w)NTrd ) r rn r rD r _set_result_unless_cancelledrY rf r )r ro exs r rh zBaseEventLoop._do_shutdownf s D " " + + + 6>>#))'*N*N*0$8 $ D>>#F,<,<,>))&*>*>CC -?# Ds A
A B* ?? CD D # # % 1 IK
K 2r! c | j | j | j | j t j
} t
j | _ t j | j | j t j | | j | j rn d| _ d | _ t j d | j d t j | y # d| _ d | _ t j d | j d t j | w xY w)N) firstiter finalizerF)r rw _set_coroutine_origin_tracking_debugsysget_asyncgen_hooksrf get_identr set_asyncgen_hooksrP rH r _set_running_loop _run_oncer )r old_agen_hookss r run_foreverzBaseEventLoop.run_foreverw s ) ++DKK8 //1 4 ' 1 1 3DO " "T-J-J-1-J-J
L
$ $T * >> "DN "DO $ $T * / / 6 " "N 3 #DN "DO $ $T * / / 6 " "N 3s A8D AEc " | j | j t j | }t j
|| }|rd|_ |j t | j |j t |j s t d |j S # |r0|j r |j s|j xY w# |j t w xY w)Nr Fz+Event loop stopped before Future completed.)r rw r isfuturer
ensure_future_log_destroy_pendingadd_done_callbackrn r r rf rg remove_done_callbackr r^ )r ro new_tasks r run_until_completez BaseEventLoop.run_until_complete s
''//$$V$7 +0F ' !78
@
' '(> ?{{} LM M}} FKKM&2B2B2D " ' '(> ?s .B? ?5C44C7 7Dc d| _ y r )r r s r rk zBaseEventLoop.stop s
r! c n | j r t d | j ry | j rt j
d| d| _ | j j | j j d| _ | j }|d | _
|j d y y )Nz!Cannot close a running event loopzClose %rTFrd ) r r r r| r debugr rV r r r rn r executors r r zBaseEventLoop.close s ?? BC C << ;; LLT * )-&)) %)D " 5 ) r! c | j S rP )r r s r r zBaseEventLoop.is_closed s 8||r! c | j s4 |d| t | | j s| j y y y )Nzunclosed event loop rJ )r rN r r )r _warns r __del__zBaseEventLoop.__del__ s= ~~ (1?4 P??$
% r! c | j d uS rP )r r s r r zBaseEventLoop.is_running s 8t+,r! c , t j S rP )r r r s r r zBaseEventLoop.time s ~~ r! r
c | t d | j | j |z |g|d|i}|j r
|j d= |S )Nzdelay must not be Noner
r )r> call_atr r )r delaycallbackr
r2 timers r
call_laterzBaseEventLoop.call_later sd = 45 5 TYY[5 0( .T .%,. " "''+ r! c P | t d | j | j r"| j | j |d t j |||| | }|j r
|j d= t j | j | d|_
|S )Nzwhen cannot be Noner r T) r> r r|
_check_thread_check_callbackr TimerHandler heapqheappushr )r whenr r
r2 r s r r zBaseEventLoop.call_at s < 12 2 ;; 9 5""44wG " "''+
t. r! c | j | j r"| j | j |d | j ||| }|j
r
|j
d= |S )N call_soonr )r r| r r
_call_soonr r r r
r2 r s r r zBaseEventLoop.call_soon sf
;; ; 7 49 # #((,
r! c t j | st j | rt d| d t | st d| d| y )Nz coroutines cannot be used with z()z"a callable object was expected by z(), got )r iscoroutineiscoroutinefunctionr> r )r r methods r r z BaseEventLoop._check_callback( sg " "8 ,..x81&<>
>!4VH = l$%
% "r! c t j ||| | }|j r
|j d= | j j | |S )Nr )r Handler r rB )r r r2 r
r s r r zBaseEventLoop._call_soon2 sD xtW= # #((, 6"
r! c | | j y t j }|| j k7 r t d y )NzMNon-thread-safe operation invoked on an event loop other than the current one)r rf r r )r thread_ids r r zBaseEventLoop._check_thread9 sG ?? " '') ' '(
( (r! c | j | j r| j |d | j ||| }|j r
|j d= | j |S )NrD r )r r| r r r r; r s r rD z"BaseEventLoop.call_soon_threadsafeJ sc 0 ;; +A B 49 # #((,
r! c < | j | j r| j |d |E| j }| j |'t
j j d }|| _ t
j |j |g| | S )Nrun_in_executorasyncio)thread_name_prefixr )
r r| r r rA
concurrentr ThreadPoolExecutor wrap_futuresubmit)r r funcr2 s r r z BaseEventLoop.run_in_executorU s ;; '8 9 --H ( ( * %--@@'0 A *2&"" HOOD (4 (t5 5r! c p t |t j j s t d || _ y )Nz,executor must be ThreadPoolExecutor instance)r r r r r> r r s r set_default_executorz"BaseEventLoop.set_default_executore s, (J$6$6$I$IJ JK K!) r! c " | d|g}|r|j d| |r|j d| |r|j d| |r|j d| dj | }t j d| | j }t j |||||| } | j |z
}
d| d |
d
z d d | }|
| j k\ rt j | | S t j | | S )
N:zfamily=ztype=zproto=zflags=, zGet address info %szGetting address info z took g @@z.3fzms: ) rB rk r r r r+ getaddrinfor info) r rD rE rF rG rH flagsmsgt0addrinfodts r _getaddrinfo_debugz BaseEventLoop._getaddrinfo_debugj s q!" JJ
+ , JJth' ( JJy) * JJy) *iin *C0
YY[%%dD&$uM
YY[2
%cU&c#d8,O
,, , KK
LL r! r rF rG rH r c
K | j r
| j }nt j }| j d ||||||| d { S 7 wrP )r| r r+ r r )r rD rE rF rG rH r getaddr_funcs r r zBaseEventLoop.getaddrinfo sU ;; 22L!--L)) ,dFD%H H H Hs AAA Ac b K | j d t j || d { S 7 wrP )r r+ getnameinfo)r sockaddrr s r r zBaseEventLoop.getnameinfo s2 )) &$$h7 7 7 7s &/-/)fallbackc Z K | j r |j dk7 r t d t | | j |||| | j |||| d { S 7 # t j $ r
}|s Y d }~nd }~ww xY w| j |||| d { 7 S w)Nr z the socket must be non-blocking) r|
gettimeoutr, rw _check_sendfile_params_sock_sendfile_nativer SendfileNotAvailableError_sock_sendfile_fallback)r r1 fileoffsetcountr rm s r
sock_sendfilezBaseEventLoop.sock_sendfile s ;;4??,1 >? ?$ ##D$> 33D$4:EC C
C C33 11$28%A A A AsN A
B+
A+ $A)%A+ (B+)A+ +B >BB+B B+%B(&B+c B K t j d|d|d w)Nz-syscall sendfile is not available for socket z
and file z combinationr r r r1 r r r s r r z#BaseEventLoop._sock_sendfile_native s4 22;D8 D x|
-. .s c 8 K |r|j | |rt |t j nt j }t | }d} |rt ||z
| }|dk rnYt | d | }| j
d |j | d { } | sn#| j ||d | d { || z
}p||dkD r"t |d r|j ||z S S S 7 S7 5# |dkD r"t |d r|j ||z w w w xY ww)Nr seek)
r minr !SENDFILE_FALLBACK_READBUFFER_SIZE bytearray
memoryviewr readinto sock_sendallr* )
r r1 r r r blocksizebuf
total_sentviewreads
r r z%BaseEventLoop._sock_sendfile_fallback s1 IIf
yBB C#EE "
/ #EJ$6 BI A~ !#z 2 ! 1 1$
t LL''d5Dk:::d"
A~'$"7 &:-. #8~ M ; A~'$"7 &:-. #8~sC A
DAC. C* C. 6C,7 C. (D*C. ,C. .)DDc dt |dd vr t d |j t j k( s t d |It |t st dj | |dk rt dj | t |t st dj | |dk rt dj | y )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> formatr s r r z$BaseEventLoop._check_sendfile_params s gdFC0 0 CD DyyF . .. JK K eS) AHHOQ Qz AHHOQ Q&#&BII
A: BII
r! c K g } |j | |\ }}}}} d }
t j ||| }
|
j d |G|D ]! \ } }}}} | |k7 r |
j | n" |r|j t d|d | j |
| d { |
d x}}S # t $ rP}
d| dt |
j
}t |
j | }
|j |
Y d }
~
d }
~
ww xY w7 f# t $ r)}
|j |
|
|
j d }
~
w |
|
j xY w# d x}}w xY ww)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 lfamilyladdrrm r s r
_connect_sockzBaseEventLoop._connect_sock s 2
-(+4(ua# .==U%HD U # +/?+GQ1e &( 2 %(
0@ % + / / 11 %(OyPV&W XX##D'2 2 2 *. -J 1 # 2 '',ir#c(..2B1C E &cii 5%,,S11
2
3 %
)- -J sk E$AD D DD E $E EE E!!E$) ru rF rH r r1
local_addrr" r r happy_eyeballs_delay
interleave
all_errorsc D K |
|s t d |
|r|s t d |}
|
|s t d |
|s t d | t | |
|d}||| t d j ||f|t j || d { }|s t d | : j | |t j || d { s
t d d |r t
|| }g |
%|D ] } j | d { } n0 n.t j fd |D |
d { d }|ʉD cg c] }|D ] }|
c}} |r t d t dk( rd t d t fd
D rd t dj dj d D | t d |j t j k7 rt d| j# ||||
| | d { \ }} j$ r+|j' d }t) j* d||||| ||fS 7 7 7 f# t
$ r Y w xY w7 Jc c}}w # d w xY w7 kw)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 0 K | ]
}|ffd yw)c * j | S rP )r )r r laddr_infosr s r z;BaseEventLoop.create_connection...] s $2D2D &+3r! NrQ )rR r r r r s r rT z2BaseEventLoop.create_connection..Z s' ).H )1 ).s r r zcreate_connection failedc 3 : K | ] }t | k( y wrP r )rR rm models r rT z2BaseEventLoop.create_connection..p s GJSs3x5 0Js zMultiple exceptions: {}r c 3 2 K | ] }t | y wrP r )rR rm s r rT z2BaseEventLoop.create_connection..u s %E*3c#h*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, rw _ensure_resolvedr+ r: r/ rd r r staggered_raceExceptionGrouprU r allr rk rG _create_connection_transportr| get_extra_infor r )r r rD rE ru rF rH r r1 r r" r r r r r infosr subrm r r r r r s ` @@@r create_connectionz BaseEventLoop.create_connection sv
&s JK K "s "A B B "O ,S CE
E +C BD
D d # +
0BJ t / NP P //t V''uE 0 N NE ABB%$($9$9 v ++5 d %: %, , #!"EFF " -eZ@J#+ %H!%)%7%7 &+&? ? !& ( 6 6 ).
) |-7 GZc3Cc3cZ G
&! ,-G TT:!+ (m+ !$JqM 2 GJ GG",Q- / &&?&F&F II%E*%E E'G H H | KM MyyF . .. !8AC C %)$E$E "C "7!5 %F %7 7 8 ;; ++H5D LL: tT9h
@(""mN ," ? # ! ! H "&J 7s BJ I5;J I8*J ?I>I;I>*J JJ J#J (A8J AJ 2J 3AJ 8J ;I>> J J
J J J JJ c
. K |j d | }| j } |r.t |t rd n|}
| j |||
| |||| } n| j ||| } | d { | |fS 7 # | j
xY ww)NFr! r" r r )r r r boolr' r r ) r r1 r ru r" r! r r r r r& r s r r z*BaseEventLoop._create_connection_transport s
#%##% !+C!6CJ 00h
F ' &;%9 1 ;I 33D(FKI LL
(""
OO s0 A,B/A? 4A=5A? 9B=A? ?BBc K |j r t d t |dt j j
}|t j j
u rt d| |t j j u r | j |||| d { S |st d| | j |||| d { S 7 0# t j $ r
}|s Y d }~Id }~ww xY w7 )w)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 r rm s r sendfilezBaseEventLoop.sendfile s , ! 56 6y"8 ..::< 9**66 6 :9-HJ
J 9**55 5
! 2 29d395 B B B ++4-9:
: ,,Y-3U< < <B 77
r r r
SSLProtocolr r r r r
BaseExceptionr r _app_transport) r r r r& r! r" r r r ssl_protocol
conmade_cb resume_cbs r start_tlszBaseEventLoop.start_tls sB
; CD D*cnn5!n&'
' y"95A YM)IJL
L ##% ++ (J "7!5!& ( ! |,^^L$@$@)L
NN9#;#;< LL ***
OO s0 C D6 C8 %C6&C8 * D66C8 8;D33D6)rF rH r
reuse_portallow_broadcastr1 c F K | | j t j k( rt d| |s |s
|s|s|s|s|rGt ||||||| }
dj d |
j
D } t d| d | j d d } nb|s|s|dk( r t d ||fd
ff}
nt t d r|t j k( r||fD ] }|t |t rt d |rO|d d
vrH t j t j | j rt j" | ||f||fff}
ni }d|fd|ffD ] \ }}| t |t, rt/ | dk( s t d | j1 ||t j2 ||| d { }|s t' d |D ] \ }}}}}||f}||vrd d g||< ||| |< ! |j
D cg c] \ }}|r|d |r|d ||f }
}}|
s t d g }|
D ] \ \ }}\ }}d } d } t j |t j2 | } |r t5 | |r/| j7 t j8 t j: d | j d |r| j= | |r |s| j? | | d { |} n |d | } | jE } | jG | | | | } | jH r4|rt) jJ d||| | nt) jL d|| | | d { | | fS # t$ $ r Y 0t& $ r"}t) j* d|| Y d }~Ud }~ww xY w7 c c}}w 7 # t& $ r/} | | jA |jB | Y d } ~ d } ~ w | | jA xY w7 # | jA xY ww)Nz$A datagram socket was expected, got )r remote_addrrF rH r r3 r4 r c 3 6 K | ] \ }}|s | d | yw)=NrQ )rR kvs r rT z9BaseEventLoop.create_datagram_endpoint..= s! $NLDAqAs!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 rb z2-tuple is expectedr r z can not get address informationr z@Datagram endpoint local_addr=%r remote_addr=%r created: (%r, %r)z2Datagram endpoint remote_addr=%r created: (%r, %r))'rG r+ r: r, dictrk itemsr r* r= r r r> statS_ISSOCKosst_moderemoveFileNotFoundErrorr/ r errorr rU r r; r2 r- r. SO_BROADCASTr r r rB r r* r| r r ) r r r r6 rF rH r r3 r4 r1 optsproblemsr_addraddr_pairs_infora err
addr_infosidxr famr pror) key addr_pairr
local_addressremote_addressrm r r r s r create_datagram_endpointz&BaseEventLoop.create_datagram_endpoint+ s
* yyF . .. :4(CE Ekeu /z{#)e'1,;= 99$NDJJL$NN 008z<= =
U #F +Q;$%@AA%+UO\#B"D+&..0H ' 5D'
40E '(< == 6 *Q-{"B 6 ==)<)D)DE IIj 1 &,UO%/$=$? #B
#$j/A{3C!DIC' *4 7CIN"+,A"B B&*&;&; f6G6G"'u4 '< 'A !A %")*M"N N7< 3CCG#&*C "* 437,
33:JsOC 0 8= "E& r, rw rC r r} platformr rU abcIterablerY r rW setrZ r[ r\ r+ rG r| r warningrB r- r. SO_REUSEADDRr@ r r2 rA r* r` IPV6_V6ONLYr r/ r r
EADDRNOTAVAILr r rG r: r r r r r ) r r rD rE rF r r1 r ru rZ r3 r r r r hostsfsr completedresrL socktyperH canonnamesarM r r r s r
create_serverzBaseEventLoop.create_server s c4 HI I , CE
E + BD
D d # t / NP P $ "7 2 Os||x7O
Grz T3' {'?'?@ $% #d 11$V8= 2 ? #
% ,,++E 55e<=E I4
% C9<6B%B! %}}R5 A NN4($ " - -v/B/BDJ "bV^^V__,M&M&t, " &// 1 #FN ; (;(;(.(:(:(,.
@ "
; !V !:?%@%$d1g%%@#C D D ! '
!( | !LMMyyF . .. #EdX!NOOfGD U # g'7W&;,. ! ! # ++a. ;; KK 0
c% , "<< ! ;; "NN ,G+-x O !
!4 # @ #%c#hnn&6 8 99(;(;; #KKM JJL #{{ &s 3 $ %cii 54? @ &A ! '
!( !(
!s C
Q L(+QL-.Q2
P L0C P !M02P P
P B(Q?P? .Q09M-)P ,M--P 0 P9A=P6P <PPP P<<Q)ru r r c r K |j t j k7 rt d| |
|s t d |
|s t d | t | | j |||dd|| d { \ }}| j r)|j d }t j d||| ||fS 7 @w) Nr r r r5 T)r! r r r+ z%r handled: (%r, %r))
rG r+ r: r, rw r r| r r r )r r r1 ru r r r r s r connect_accepted_socketz%BaseEventLoop.connect_accepted_socketR s
99** * A$ JK K ,S CE
E +C BD
D d #$($E$E "C"7!5 %F %7 7 8 ;; ++H5D LL/y( K("" 7s A2B74B55AB7c K | }| j }| j ||| } | d { | j r&t j
d|j
|| ||fS 7 :# |j xY ww)Nz Read pipe %r connected: (%r, %r))r r. r r| r r filenor r r- r r r s r connect_read_pipez BaseEventLoop.connect_read_pipep s #%##%2246J LL
;; LL; 8
=(""
OO + +BA0 A.A0 6B.A0 0BBc K | }| j }| j ||| } | d { | j r&t j
d|j
|| ||fS 7 :# |j xY ww)Nz!Write pipe %r connected: (%r, %r))r r0 r r| r r ru rv s r connect_write_pipez BaseEventLoop.connect_write_pipe s #%##%33D(FK LL
;; LL< 8
=(""
OO rx c r |g}| |j dt | |1|t j k( r |j dt | n>| |j dt | | |j dt | t j
dj
| y )Nzstdin=zstdout=stderr=zstdout=zstderr= )rB r' r# r% r r rk )r r r4 r5 r6 r s r _log_subprocessz BaseEventLoop._log_subprocess s u KK& e!4 56 7 &J,=,="= KK. f)=(>? @! gl6&:%; <=! gl6&:%; <= SXXd^$r! ) r4 r5 r6 universal_newlinesr3 r7 encodingerrorstextc K t |t t f s t d |r t d |s t d |dk7 r t d | r t d | t d |
t d | }
d }| j rd |z }| j |||| | j |
|d
||||fi | d { }| j r|t j d || ||
fS 7 -w) 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} r9 r r )r r cmdr4 r5 r6 r~ r3 r7 r r r r8 r debug_logr s r subprocess_shellz BaseEventLoop.subprocess_shell s #s|, 34 4 ?@ @ 12 2 a< 01 1 12 2 45 5 23 3#% ;; /4I E66 B9$99 c4KCIK K ;;90 KK)Y 7("" Ks B=C/?C- .C/c K |r t d |r t d |dk7 r t d | r t d | t d |
t d |f| z } | }d }| j rd|}| j |||| | j ||d ||||fi |
d { }| j r|t j
d
|| ||fS 7 -w) Nr zshell must be Falser r r r r zexecute program Fr )r, r| r} r9 r r )r r programr4 r5 r6 r~ r3 r7 r r r r2 r8
popen_argsr r r s r subprocess_execz BaseEventLoop.subprocess_exec s ?@ @ 23 3 a< 01 1 12 2 45 5 23 3 Z$&
#% ;; +7+6I E66 B9$99 j% ;;90 KK)Y 7("" s B"C$C%.Cc | j S rP )r r s r get_exception_handlerz#BaseEventLoop.get_exception_handler s &&&r! c J |t | st d| || _ y )Nz+A callable object or None is expected, got )r r> r )r handlers r set_exception_handlerz#BaseEventLoop.set_exception_handler s:
x'8 ##*+ / 0
0") r! c |j d }|sd}|j d }|t | ||j f}nd}d|vr;| j /| j j r| j j |d< |g}t | D ] }|dv r|| }|dk( r:dj
t j | }d }||j z
}nJ|dk( r:dj
t j | }d
}||j z
}n t | }|j | d | t j d j
| |
y )NrS z!Unhandled exception in event looprg Fsource_tracebackhandle_traceback> rS rg r5 z+Object created at (most recent call last):
z+Handle created at (most recent call last):
r
r^ )getrG
__traceback__r r sortedrk traceback format_listrstripr rB r rG ) r r
rS rg r_ log_linesrR valuetbs r default_exception_handlerz'BaseEventLoop.default_exception_handler s`
++i(9GKK , YI4K4KLH H g -$$0$$66$$66
& ' I '?C..CLE((WWY 2 25 9:F$**WWY 2 25 9:F$ U uBug . / # TYYy)H=r! c | j | j | y d }|j d }||j d }||j d }| t |d r|j }|*t |d r |j | j | | y | j | | y # t t f$ r t $ r t j dd Y y w xY w# t t f$ r t $ r[} | j d ||d
n:# t t f$ r t $ r t j d d Y nw xY wY d }~y Y d }~y d }~ww xY w) Nz&Exception in default exception handlerTr^ r ro r get_contextrunz$Unhandled error in exception handler)rS rg r
zeException in default exception handler while handling an unexpected error in custom exception handler) r r rh ri r- r rG r r* r r )r r
ctxthingrm s r rZ z$BaseEventLoop.call_exception_handler+ sv * " " *
,..w7$
0 F+= $KK 1E= #KK 1E$
)F ++-C?wsE':GGD 3 3T7C++D':3 12
, E&*,
,0 12
0022#I%(#*4
#$56 $ 0 LL "? +/000
0sM B8 BC- %C- 8/C*)C*-E D E /E E
EEE c V |j s | j j | y y rP )
_cancelledr rB r r s r
_add_callbackzBaseEventLoop._add_callbacks s% % KK v & !r! c H | j | | j y rP )r r; r s r _add_callback_signalsafez&BaseEventLoop._add_callback_signalsafex s D 6" r! c J |j r| xj dz
c_ y y rq )r r r s r _timer_handle_cancelledz%BaseEventLoop._timer_handle_cancelled} s$ A ' '1 , ' r! c d t | j }|t kD rr| j |z t kD r\g }| j D ]' }|j
rd|_ |j
| ) t j | || _ d| _ n| j rz| j d j
ra| xj dz c_ t j | j }d|_ | j r| j d j
rad }| j s | j rd}nP| j rD| j d j }t t d|| j z
t }| j" j% | }| j' | d }| j | j( z }| j rm| j d }|j |k\ rnNt j | j }d|_ | j j
| | j rmt | j }t+ | D ] } | j j- }|j
r*| j. rr || _ | j }
|j3 | j |
z
} | | j4 k\ r t7 j8 dt; | | d | _ |j3 d }y # d | _ w xY w)NFr r z Executing %s took %.3f seconds) rU r _MIN_SCHEDULED_TIMER_HANDLESr %_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr rB r heapifyheappopr r _whenr maxr MAXIMUM_SELECT_TIMEOUT _selectorselectr> r rangepopleftr| r _runr r rf r ) r sched_count
new_scheduledr rj r r= end_timentodoir r s r r zBaseEventLoop._run_once s $//* 6 6 ' '+ 55
6 M //$$(-F%!((0 *
MM- ( +DO*+D ' //dooa&8&C&C++q0+ t7$)! //dooa&8&C&C
;;$..G
__??1%++D#a !346LMG^^**73
Z(
99;!7!77oo__Q'F||x']]4??3F %F KK v &
oo DKK u A[[((*F {{ 0+1D( BKKM r)BT 8 88 'G'5f'=rC ,0D(
! " ,0D(s
A)L&& L/c t | t | j k( ry |rDt j | _ t j
t j || _ y t j
| j || _ y rP )r r r} #get_coroutine_origin_tracking_depthr #set_coroutine_origin_tracking_depthr DEBUG_STACK_DEPTHr enableds r r{ z,BaseEventLoop._set_coroutine_origin_tracking sw =D!H!H I I 779
7 3 3++
- 3:/
3 3;;
= 3:/r! c | j S rP )r| r s r r zBaseEventLoop.get_debug s {{r! c l || _ | j r | j | j | y y rP )r| r rD r{ r s r r zBaseEventLoop.set_debug s. ?? % %d&I&I7 S r! rP )NNNr< )r )r N)FNN)Ur r r r r r r r r r r' r* r. r0 r9 r; r> r rA rH rP r_ rq rh rw r r rk r r rL rM r r r r r r r r r rD r r r r r r r r r r r r r% r# r$ r2 rV r+ r: r rY r?
AI_PASSIVErq rs rw rz r} r# r$ r r r r r rZ r r r r r{ r r rQ r! r r r s /<
) )-d 4 % ""%)$" 9=" $t"&!%!%
" CG"
@D(,"
AE)-" 04" ""7DG
"20DK40$ L *. %MM - :> 0 6: $ 26 &%(" =A 5 *
2 "#!1H7
A(,
A ./4 *).X 59Q#14T"&!%!%$ Q#j */"&!% #8-<#'-<^1"4 %*(,.2-1 .+b EID#./q267;$ D#N '(f.@.@%&a
D 59K #### "&!% K^ "&!% #<# # % &0__&0oo&0oo27%)1(,T
"#J %/OOJOO%/__$)1'+Dt #D'
*"0>dF0P'
-
N`
: Tr! r )r r )r )6rU collections.abcconcurrent.futuresr r r rZ rC r+ rA r# rf r r r} rL r ru ImportErrorr5 r r r r r r r
r r r
r r logr __all__r r r* rA r r r' r2 rM rd rn rr rw Protocolry AbstractServerr AbstractEventLoopr rQ r! r r s-
$
# ), %
FJ ' # J8v," 6=!G
>
A) 2 2 A)HBV
"
" BJPTF,, PTk
Cs D
DD