!A?hx& 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 dlZd dlZ d dlZn
# e$ r dZY nw xY wddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lm Z dd lm Z dd lm Z dd
lm Z ddl m!Z! dZ"dZ#dZ$ e%e d Z&dZ'd Z(d Z)d Z*d$dZ+d%dZ,d Z- e%e d rd Z.nd Z.d Z/ G d d ej0 Z1 G d d!ej2 Z3 G d" d#ej4 Z5dS )& N ) constants)
coroutines)events)
exceptions)futures) protocols)sslproto) staggered)tasks)
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 @/opt/alt/python-internal/lib64/python3.11/asyncio/base_events.py_format_handler G sF B'"j$//<< BK 6{{ c h | t j k rdS | t j k rdS t | S )Nz<pipe>z<stdout>)
subprocessPIPESTDOUTr )fds r _format_piper& P s2 Z_ x z zBxxr c t t d st d | t j t j d d S # 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_reuseportr1 Y s 6> * * JDEEE J OOF -v/BA F F F F F J J J I J J
J Js +A A-c ^ t t d sd S |dt j t j hvs| d S |t j k r
t j }n |t j k r
t j }nd S |d}net
|t r |dk rd}nGt
|t r |dk rd}n) t | }n# t t f$ r Y d S w xY w|t j k r4t j
g}t r | t j n|g}t
| t r| d } d| v rd S |D ]V} t j || t r |t j k r
|||d| |||ffc S |||d| |ffc S # t& $ r Y Sw xY wd S )N inet_ptonr r idna%)r) r* IPPROTO_TCP IPPROTO_UDP SOCK_STREAM
SOCK_DGRAMr bytesr int TypeErrorr+ AF_UNSPECAF_INET _HAS_IPv6appendr decoder3 r. ) hostportfamilytypeprotoflowinfoscopeidafsafs r _ipaddr_inforL d s 6; ' ' Q*F,>??? Lt v!!!"
" " ""t | D% TS[[ D# 42:: t99DD:& 44 !!!~ ( JJv ' ' 'h$ #{{6""
d{{ t R & & &
9R6? 2 24T47,KKKKK4T4L8888 D 4s* 5C CC6F F
F*)F*c t j }| D ].}|d }||vrg ||< || | /t | }g }|dk r4| |d d |dz
|d d |dz
= | d t j t
j | D |S )Nr r c 3 K | ]}||V d S N ).0as r <genexpr>z(_interleave_addrinfos.<locals>.<genexpr> s0
]
]]] r )
collections OrderedDictrA listvaluesextend itertoolschain
from_iterable zip_longest) addrinfosfirst_address_family_countaddrinfos_by_familyaddrrE addrinfos_lists reordereds r _interleave_addrinfosrc s% 7%133 1 1a , , ,*, 'F#**40000.557788OI!A%% +,K-G!-K,KLMMM A > :Q > > ?
?00 !? 3
r c | s2| }t |t t f rd S t j | d S rO ) cancelled exceptionr
SystemExitKeyboardInterruptr _get_loopstop)futexcs r _run_until_complete_cbrm sa ==?? mmoo cJ(9: ; ;
F c !!!!!r TCP_NODELAYc | j t j t j hv rW| j t j k rD| j t j k r1| t j t j d d S d S d S d S Nr )
rE r* r? r rF r9 rG r7 r, rn r/ s r _set_nodelayrq sn KFNFO< < < V ///
f 000 OOF .0BA F F F F F
= <//00r c d S rO rP r/ s r rq rq s r c j t )t | t j rt d d S d S )Nz"Socket cannot be of type SSLSocket)sslr SSLSocketr= r/ s r _check_ssl_socketrv s1
:dCM::<=== r c D e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) _SendfileFallbackProtocolc t |t j st d || _ | | _ | | _ |j | _
| | | | j
r%| j j
| _ d S d | _ d S )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 &*">?? N LMM M ))++ &,&7&7&9&9#&,&=# D!!! & )$(O$9$G$G$I$ID ! ! !$(D ! ! !r c K | j rt d | j }|d S | d {V d S )NzConnection closed by peer)r{
is_closingConnectionErrorr )r rk s r drainz _SendfileFallbackProtocol.drain sR ? % % ' ' ?!"=>> ># ; F r c t d )Nz?Invalid state: connection should have been established already. RuntimeError)r transports r connection_madez)_SendfileFallbackProtocol.connection_made s N O O Or c | j D|(| j t d n| j | | j | d S )Nz Connection is closed by peer)r
set_exceptionr r} connection_lost)r rl s r r z)_SendfileFallbackProtocol.connection_lost sw , {%33#$BCCE E E E %33C888 ##C(((((r c ^ | j d S | j j | _ d S rO )r r{ r r r s r
pause_writingz'_SendfileFallbackProtocol.pause_writing s/ , F $ 5 C C E E r c Z | j d S | j d d | _ d S )NF)r
set_resultr s r resume_writingz(_SendfileFallbackProtocol.resume_writing s5 ( F ((/// $ r c t d Nz'Invalid state: reading should be pausedr )r datas r
data_receivedz'_SendfileFallbackProtocol.data_received DEEEr c t d r r r s r eof_receivedz&_SendfileFallbackProtocol.eof_received r r c K | j | j | j r| j | j | j | j r| j d S d S rO ) r{ r r} r resume_readingr cancelr r r s r restorez!_SendfileFallbackProtocol.restore s $$T[111 & - O * * , , , ,
! ( ( * * * & ) K & & ( ( ( ( ( ) )r N) __name__
__module__ __qualname__r r r r r r r r r rP r r rx rx s ) ) ) O O O ) ) )F F F
% % % F F FF F F
)
)
)
)
)r rx c p e Zd Z ddZd Zd Zd Zd Zd Zd Z d Z
e d
Z d Z
d Zd
Zd ZdS )r Nc || _ || _ d| _ g | _ || _ || _ || _ || _ || _ d| _ d | _
d S )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__ s[
!1
'&;#%9"
$(!!!r c 2 d| j j d| j dS )N<z sockets=>) __class__r r r s r __repr__zServer.__repr__# s" F4>*FFT\FFFFr c & | xj dz
c_ d S rp )r r s r _attachzServer._attach& s a r c z | xj dz c_ | j dk r | j | d S d S d S )Nr r )r r _wakeupr s r _detachzServer._detach* sJ a " "t}'< LLNNNNN # "'<'<r c ~ | j }d | _ |D ]+}| s| | ,d S rO )r doner )r waiterswaiters r r zServer._wakeup0 sN -
* *F;;==
*!!&))) * *r c
| j rd S d| _ | j D ]U}| | j | j | j || j | | j | j | j Vd S NT)
r r listenr r _start_servingr r r r )r r0 s r r zServer._start_serving7 s = F
M , ,D KK
& & & J % %&d.?dmT%@*
,
,
,
, , ,r c | j S rO )r r s r get_loopzServer.get_loopB s
zr c | j S rO )r r s r
is_servingzServer.is_servingE s
} r c P | j dS t d | j D S )NrP c 3 > K | ]}t j | V d S rO )r TransportSocket)rQ ss r rS z!Server.sockets.<locals>.<genexpr>L s- FF1V+A..FFFFFFr )r tupler s r r zServer.socketsH s. = 2FF
FFFFFFr c 8 | j }|d S d | _ |D ] }| j | d| _ | j 9| j s | j d | _ | j dk r| d S d S )NFr ) r r
_stop_servingr r r r r r )r r r0 s r closez Server.closeN s - ? F
+ +D J $ $T * * * *
% 1-2244
2 % , , . . .(,D % " " LLNNNNN # "r c f K | t j d d {V d S )Nr )r r sleepr s r
start_servingzServer.start_servinga s@ k!nn r c K | j t d| d | j t d| d | | j | _ | j d {V nH# t j $ r6 | | d {V # xY ww xY w d | _ d S # d | _ w xY w)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 N$NNNP P
P = ; ; ; ;<< < $(J$<$<$>$>! -+ + + + + + + + +(
&&(((((((((
, )-D % % %D % , , , ,s6 *
A8 7C
8B=.B76B=7B99B==C
Cc K | j | j d S | j }| j | | d {V d S rO )r r r r rA )r r s r r zServer.wait_closed| sX = DM$9 F))++
V$$$ r rO )r r r r r r r r r r r propertyr r r r r rP r r r r s >B ) ) ) ) G G G * * * , , , G G XG
& - - -* r r c
J 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 Zd 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;Z4 dad<Z5d`d d4d=Z6d> Z7d? Z8d dddd@dAZ9 d^d0d0d0ddddBdCZ:d0e;j< d0d0d1dDZ=dE Z> d^e;j? e;j@ ddFdddddd dG
dHZAddddIdJZBdK ZCdL ZDdM ZEeFjG eFjG eFjG d d d0ddddN dOZHeFjG eFjG eFjG d d d0ddddN dPZIdQ ZJdR ZKdS ZLdT ZMdU ZNdV ZOdW ZPdX ZQdY ZRdZ ZSd[ ZTdS )br c d| _ d| _ d| _ t j | _ g | _ d | _ d| _ d | _ t j d j | _
d | _ | t! j d| _ d | _ d | _ d| _ d | _ t/ j | _ d| _ d| _ d S )Nr F monotonicg?) _timer_cancelled_count_closed _stoppingrT 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[!A!A!L "& z022333 '*# # !27/6:3 "/++*/').&&&r c d| j j d| d| d| d S )Nr z running=z closed=z debug=r )r r
is_running is_closed get_debugr s r r zBaseEventLoop.__repr__ sp
C'
C
C$//2C2C
C
Cnn&&
C
C/3~~/?/?
C
C
C
r c . t j | S )Nr )r Futurer s r r zBaseEventLoop.create_future s :~4((((r N)namecontextc | | j (t j || || }|j r|j d= nF|| | | }n| | || }t j || |S )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'JJJD%
/*2.))$55))$g)FF t , , , r c V | t | st d || _ d S )Nz'task factory must be a callable or None)callabler= r )r factorys r set_task_factoryz BaseEventLoop.set_task_factory s9 x'8'8 EFF F $r c | j S rO )r r s r get_task_factoryz BaseEventLoop.get_task_factory s J!!r )extraserverc t rO NotImplementedError)r r0 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 rO r ) r rawsockr
sslcontextr r r! r r r r r" s r _make_ssl_transportz!BaseEventLoop._make_ssl_transport s
$!!r c t rO r )r r0 r addressr r s r _make_datagram_transportz&BaseEventLoop._make_datagram_transport s (!!r c t rO r r piper r r s r _make_read_pipe_transportz'BaseEventLoop._make_read_pipe_transport s )!!r c t rO r r+ s r _make_write_pipe_transportz(BaseEventLoop._make_write_pipe_transport s *!!r c K t rO r )
r r argsshellstdinstdoutstderrbufsizer kwargss
r _make_subprocess_transportz(BaseEventLoop._make_subprocess_transport s +!!r c t rO r r s r _write_to_selfz BaseEventLoop._write_to_self s "!r c t rO r )r
event_lists r _process_eventsz BaseEventLoop._process_events s &!!r c 2 | j rt d d S )NzEvent loop is closed)r r r s r r
zBaseEventLoop._check_closed s% < 7 566 6 7 7r c 2 | j rt d d S )Nz!Executor shutdown has been called)r r r s r _check_default_executorz%BaseEventLoop._check_default_executor
s) ) D BCC C D Dr c | j | | s/| | j | d S d S rO )r discardr call_soon_threadsafer acloser agens r _asyncgen_finalizer_hookz&BaseEventLoop._asyncgen_finalizer_hook s^ %%%~~ G % %d&6
F F F F F G Gr c | j r t j d|dt | | j | d S )Nzasynchronous generator z3 was scheduled after loop.shutdown_asyncgens() callsource)r warningswarnResourceWarningr addrE s r _asyncgen_firstiter_hookz&BaseEventLoop._asyncgen_firstiter_hook s_ * . M2$ 2 2 2
.
.
.
.
D!!!!!r c p K d| _ t | j sd S t | j }| j t j d |D ddi d {V }t || D ]6\ }}t |t r |
d|||d 7d S )NTc 6 g | ]}| S rP )rD )rQ ags r
<listcomp>z4BaseEventLoop.shutdown_asyncgens.<locals>.<listcomp>) s
2
2
2bbiikk
2
2
2r return_exceptionsz;an error occurred during closing of asynchronous generator )messagerf asyncgen) r lenr rV clearr gatherzipr Exceptioncall_exception_handler)r
closing_agensresultsresultrF s r shutdown_asyncgensz BaseEventLoop.shutdown_asyncgens s :*.'4?##
F T_--
2
2M
2
2
2$ "$ $ $ $ $ $ $ $ 7 7 LFD&),,
++ B9= B B!' $ - - r c K d| _ | j d S | }t j | j |f }| | d {V | d S # | w xY w)NT)targetr1 )r r r threadingThread _do_shutdownstartjoin)r futurethreads r shutdown_default_executorz'BaseEventLoop.shutdown_default_executor5 s <)-& ! ) F##%%!):&KKK LLLLLLL KKMMMMMFKKMMMMs A7 7B
c : | j d | s | |j d d S d S # t
$ r@}| s!| |j | Y d }~d S Y d }~d S d }~ww xY w)NTwait)r shutdownr rC r r[ r )r rh exs r re zBaseEventLoop._do_shutdownB s D " + + + 6 6 6>>##
C))&*;TBBBBB
C
C D D D>>##
D))&*>CCCCCCCCC
D
D
D
D
D
D Ds A
A
B/BBc | rt d t j t d d S )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_runningz BaseEventLoop._check_runningK sS ?? E CDD D # % % 1 IK K
K 2 1r c | | | | j t j } t
j | _ t j | j
| j t j
| | | j rn d| _ d | _ t j
d | d t j | d S # d| _ d | _ t j
d | d t j | w xY w)N) firstiter finalizerTF)r
rr _set_coroutine_origin_tracking_debugsysget_asyncgen_hooksrc get_identr set_asyncgen_hooksrO rG r _set_running_loop _run_oncer )r old_agen_hookss r run_foreverzBaseEventLoop.run_foreverR s[ ) ++DK888 /11 4 ' 1 3 3DO "T-J-1-J
L
L
L
L
$T * * *
>
"DN "DO $T * * * / / 6 6 6 "N 3 3 3 3 #DN "DO $T * * * / / 6 6 6 "N 3 3 3s A*D
AEc | | t j | }t j || }|rd|_ | t | nD# |r<|
r(| s| xY w |
t n # |
t w xY w|
st d | S )Nr Fz+Event loop stopped before Future completed.)r
rr r isfuturer
ensure_future_log_destroy_pendingadd_done_callbackrm r r re rf remove_done_callbackr r_ )r rh new_tasks r run_until_completez BaseEventLoop.run_until_completej sI
'///$V$777 0 +0F ' !7888
@
#FKKMM
#&2B2B2D2D
# """
' '(> ? ? ? ?F ' '(> ? ? ? ?{{}} N LMM M}} s 9B
C. ACC. . D
c d| _ d S r )r r s r rj zBaseEventLoop.stop s
r c h | rt d | j rd S | j rt j d| d| _ | j | j d| _ | j
}| d | _
| d d S d S )Nz!Cannot close a running event loopzClose %rTFrl ) r r r rw r debugr rX r r r rn r executors r r zBaseEventLoop.close s ?? D BCC C < F ; + LT * * * )-&) %)D " 5 ) ) ) ) ) r c | j S rO )r r s r r zBaseEventLoop.is_closed s
8|r c | s@ |d| t | | s| d S d S d S )Nzunclosed event loop rI )r rM r r )r _warns r __del__zBaseEventLoop.__del__ sk ~~ E111?4 P P P P??$$
r c | j d uS rO )r r s r r zBaseEventLoop.is_running s 8t+,r c * t j S rO )r r r s r r zBaseEventLoop.time s ~ r r c |t d | j | |z |g|R d|i}|j r|j d= |S )Nzdelay must not be Noner r )r= call_atr r )r delaycallbackr r1 timers r
call_laterzBaseEventLoop.call_later su = 455 5 TYY[[5 0( .T . . .%,. . " ,'+ r c D |t d | | j r*| | |d t j |||| | }|j r|j d= t j | j
| d|_
|S )Nzwhen cannot be Noner r T) r= r
rw
_check_thread_check_callbackr TimerHandler heapqheappushr )r whenr r r1 r s r r zBaseEventLoop.call_at s < 122 2 ; 6 9 5 5 5"44wGG " ,'+
t... r c | | j r*| | |d | ||| }|j r|j d= |S )N call_soonr )r
rw r r
_call_soonr r r r r1 r s r r zBaseEventLoop.call_soon s}
; 8 ; 7 7 7 499 # -(,
r c t j | st j | rt d| d t | st d| d| d S )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 s "8 , , >.x88 ><&<<<> >
>!! %$V $ $ $ $% %
% % %r c t j ||| | }|j r|j d= | j | |S )Nr )r Handler r rA )r r r1 r r s r r zBaseEventLoop._call_soon
sH xtW== # -(, 6"""
r c t | j d S t j }|| j k rt d d S )NzMNon-thread-safe operation invoked on an event loop other than the current one)r rc rz r )r thread_ids r r zBaseEventLoop._check_thread sP ? " F ')) ' ' '( (
( ( 'r c | | j r| |d | ||| }|j r|j d= | |S )NrC r )r
rw r r r r: r s r rC z"BaseEventLoop.call_soon_threadsafe% s{ 0 ; C +A B B B 499 # -(,
r c 4 | | j r| |d |D| j }| |'t
j d }|| _ t
j |j |g|R | S )Nrun_in_executorasyncio)thread_name_prefixr )
r
rw r r r@
concurrentr ThreadPoolExecutor wrap_futuresubmit)r r funcr1 s r r z BaseEventLoop.run_in_executor0 s ; : '8 9 9 9 -H ( ( * * * %-@@'0 A *2&" HOD (4 ( ( (t5 5 5 5r c p t |t j j st d || _ d S )Nz,executor must be ThreadPoolExecutor instance)r r r r r= r r s r set_default_executorz"BaseEventLoop.set_default_executor@ s8 (J$6$IJJ L JKK K!) r c H | d|g}|r| d| |r| d| |r| d| |r| d| d | }t j d| | }t j |||||| } | |z
}
d| d |
d
z d d | }|
| j k rt j | nt j | | S )
N:zfamily=ztype=zproto=zflags=, zGet address info %szGetting address info z took g @@z.3fzms: ) rA rg r r r r* getaddrinfor info) r rC rD rE rF rG flagsmsgt0addrinfodts r _getaddrinfo_debugz BaseEventLoop._getaddrinfo_debugE sY !!!!" - JJ+++ , , , ) JJ't'' ( ( ( + JJ))) * * * + JJ))) * * *iinn *C000
YY[[%dD&$uMM
YY[[2
OcOOcOOO8OO
, , , K L r r rE rF rG r c
K | j r| j }n t j }| d ||||||| d {V S rO )rw r r* r r )r rC rD rE rF rG r getaddr_funcs r r zBaseEventLoop.getaddrinfo] sr ; . 2LL!-L)) ,dFD%H H H H H H H H Hr c V K | d t j || d {V S rO )r r* getnameinfo)r sockaddrr s r r zBaseEventLoop.getnameinfog sH )) &$h7 7 7 7 7 7 7 7 7r )fallbackc h K | j r'| dk rt d t | | |||| | |||| d {V S # t j $ r
}|s Y d }~nd }~ww xY w| |||| d {V S )Nr z the socket must be non-blocking) rw
gettimeoutr+ rv _check_sendfile_params_sock_sendfile_nativer SendfileNotAvailableError_sock_sendfile_fallback)r r0 fileoffsetcountr rl s r
sock_sendfilezBaseEventLoop.sock_sendfilek s9 ; @4??,,11 >?? ?$ ##D$>>> 33D$4:EC C C C C C C C
C3
11$28%A A A A A A A A As A7 7BBBc < K t j d|d|d )Nz-syscall sendfile is not available for socket z
and file z combinationr r r r0 r r r s r r z#BaseEventLoop._sock_sendfile_nativez s@ 2
-D
-
-
-
-
-. . .r c | K |r| | |rt |t j n t j }t | }d} |rt ||z
| }|dk rnft | d | }| d |j | d {V } | sn*| ||d | d {V || z
}||dk r)t |d r| ||z S S S # |dk r)t |d r| ||z w w w xY w)Nr Tseek)
r minr !SENDFILE_FALLBACK_READBUFFER_SIZE bytearray
memoryviewr readinto sock_sendallr) )
r r0 r r r blocksizebuf
total_sentviewreads
r r z%BaseEventLoop._sock_sendfile_fallback s IIf
FCyB C C C#E ""
/
# #EJ$6 B BI A~~ !#z z2 ! 1 1$
t L LLLLLLL ''d5D5k:::::::::d"
# A~~'$"7"7~ &:-.... ~zA~~'$"7"7~ &:-.... ~s
BD 2D;c dt |dd vrt d |j t j k st d |_t |t s"t d | |dk r"t d | t |t s"t d | |dk r"t d | d S )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+ rF r* r9 r r< r= formatr s r r z$BaseEventLoop._check_sendfile_params s) gdFC00 0 0 CDD DyF ... JKK K eS))
Q AHHOOQ Q Qzz AHHOOQ Q Q&#&& BII
A:: BII
:r c K g } |j | |\ }}}}} d }
t j ||| }
|
d ||D ]\ } }}}} | |k r |
| n# t $ rS}
d| d|
j }t |
j | }
| |
Y d }
~
d }
~
ww xY w|r| t d|d | |
| d {V |
d x}}S # t $ r1}
| |
|
|
d }
~
w |
|
xY w# d x}}w xY w)NrE rF rG F*error while attempting to bind on address : z&no matching local address with family=z found) rA r* setblockingbindr. strerrorlowererrnopop sock_connectr )r r addr_infolocal_addr_infos
my_exceptionsrE type_rG _r( r0 lfamilyladdrrl r s r
_connect_sockzBaseEventLoop._connect_sock s 2
-(((+4(ua$ .=U%HHHD U # # # +/? Y Y+GQ1e &((
2 %((( " 2 2 2 6', 6 6 "| 1 1 3 3 6 6
&ci 5 5%,,S111111112 % Y + / / 1 11 %&W&W&W&W X XX##D'22 2 2 2 2 2 2 2 *. -J % % %
)- -J - - - -sO ?D# !A86D# 8
CA C D# CA D# #
E5-,E E55E8 8E>) rt rE rG r r0
local_addrr! r r happy_eyeballs_delay
interleavec x K |
|st d |
|r|st d |}
| |st d | |st d |t | |
|d}|||t d ||f|t j || d {V }|st d | = | |t j || d {V st d nd |rt
|| }g |
5|D ]1} | d {V } n# t
$ r Y .w xY wn/t j fd |D |
d {V \ }}}|d D t dk rd t d t fd
D rd t d
d d D # d w xY wn8|t d |j t j k rt d| ||||
| | d {V \ }} j r.| d }t' j d||||| ||fS )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 timerE rF rG r r !getaddrinfo() returned empty listc 3 P K | ] }t j j | V !d S rO ) functoolspartialr )rQ r r laddr_infosr s r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>5 sR , ,! &t'9'18[J J , , , , , ,r r c g | ] }|D ]}|
S rP rP )rQ subrl s r rS z3BaseEventLoop.create_connection.<locals>.<listcomp>; s% G G Gc3 G GCc G G G Gr r c 3 > K | ]}t | k V d S rO r )rQ rl models r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>B s. G GSs3xx5 0 G G G G G Gr zMultiple exceptions: {}r c 3 4 K | ]}t | V d S rO r )rQ rl s r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>G s( %E%E3c#hh%E%E%E%E%E%Er 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+ rv _ensure_resolvedr* r9 r. rc r r staggered_racerW r allr rg rF _create_connection_transportrw get_extra_infor r )r r rC rD rt rE rG r r0 r r! r r r r infosr r r r r r r s ` @@@r create_connectionz BaseEventLoop.create_connection s
&s & JKK K "s "
B "A B B B "O ,S , CE E
E +C + BD D
D d # # # +
0BJ t / NP P P //t V'uE 0 N N N N N N N NE
C ABBB%$($9$9 v +5 d %: %, %, , , , , , , # G!"EFFFG #
A-eZ@@J#+ % ! !H!%)%7%7 &+&? &? ? ? ? ? ? ? " ! ! ! ! $-#;, , , , , ,%*, , , )t $5 $5 $5 5 5 5 5 5 5
a | G GZ G G G
&:!++ (m+ !$JqM 2 2 G G G GJ G G GGG 0",Q- / &&?&F&F II%E%E*%E%E%E E E'G 'G H H H "&J%%%% $ | KM M MyF ... !AAAC C C %)$E$E "C "7!5 %F %7 %7 7 7 7 7 7 7 8 ; @ ++H55D L: tT9h
@
@
@(""s D>>
E
E
BH H#c
\ K | d | }| } |r7t |t rd n|}
| |||
| |||| } n| ||| } | d {V n# | xY w| |fS )NFr r! r r )r r r boolr& r r ) r r0 r rt r! r r r r r r% r s r r z*BaseEventLoop._create_connection_transporte s
##%%##%% L!+C!6!6?CJ 00h
F ' &;%9 1 ; ;II 33D(FKKI LLLLLLLL OO (""s B B'c K | rt d t |dt j j }|t j j u rt d| |t j j u r> | |||| d {V S # t j $ r
}|s Y d }~nd }~ww xY w|st d| |
|||| d {V S )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 rl s r sendfilezBaseEventLoop.sendfile s , ! ! 7 566 6y"8 .:< < 9*6 6 6 H9HHJ J
J 9*5 5 5
! 2 29d395 B B B B B B B B B 7
: 9+49 9: :
: ,,Y-3U< < < < < < < < <s B B:-B55B:c . K t j d )Nz!sendfile syscall is not supportedr )r r r r r s r r z BaseEventLoop._sendfile_native s 2 /1 1 1r c K |r| | |rt |d nd}t | }d}t | } |rct ||z
| }|dk rJ||dk r(t |d r| ||z | d {V S t
| d | } | d |j | d {V }
|
sJ||dk r(t |d r| ||z | d {V S | d {V |
| d |
||
z
}(# |dk r(t |d r| ||z | d {V w xY w)Ni @ r Tr ) r r r rx r) r r r r r write) r r r r r r r r rG r r s r r z BaseEventLoop._sendfile_fallback s IIf ).9Cu%%%E ""
)&11 "
# * #EJ$6 B BI A~~ ) A~~'$"7"7~ &:-...--// ! ! ! ! ! ! ! ! "#z z2 ! 1 1$
t L LLLLLLL &%
A~~'$"7"7~ &:-...--// ! ! ! ! ! ! ! !
kkmm####### T%4%[)))d"
# A~~'$"7"7~ &:-...--// ! ! ! ! ! ! ! !s E8 5<E8 :>E8 8A
Gr c K t t d t |t j st d| t |dd st d|d | }t j | |||||||d } | |
| | | j | }
| |j
} | d {V nK# t $ r> | |
| w xY w| j S )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 r" )rt r r
SSLContextr= 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 s
; CDD D*cn55 '&!& &' '
' y"95AA LJYJJJL L
L ##%% + (J "7!5!& ( ( ( !!! |,,,^^L$@)LL
NN9#;<< LLLLLLLL OO **s
:D AE )rE rG r
reuse_portallow_broadcastr0 c K | | j t j k rt d| s s
|s|s|s|s|rZt ||||| }
d d |
D } t d| d | d d } ns s |dk rt d ||fd
ff}
nt t d r|t j k rfD ](}|$t |t st d )rd d
vry t j t j
j rt j n8# t$ $ r Y n,t& $ r }t) j d| Y d }~nd }~ww xY w||ffff}
ni }dfdffD ]\ }}|t |t, rt/ | dk st d | ||t j ||| d {V }|st' d |D ]"\ }}}}}||f}||vrd d g||< ||| |< #fd| D }
|
st d g }|
D ]\ \ }}\ }}d } d } t j |t j | } |rt5 | |r+| t j t j d | d r| | r |s | | | d {V |} n\# t& $ r0}| | |j! | Y d }~d }~w | | xY w|d | } | " } | # | | | | } | j$ r2rt) j% d| | nt) j& d| | | d {V n# | xY w| | fS )Nz$A datagram socket was expected, got )r remote_addrrE rG r r. r/ r c 3 . K | ]\ }}|| d | V dS )=NrP )rQ kvs r rS z9BaseEventLoop.create_datagram_endpoint.<locals>.<genexpr> s5 $N$NDAqA$NZZAZZ$N$N$N$N$N$Nr 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 z2-tuple is expectedr r c F g | ] \ }}r|d r|d ||f S )r Nr rP )rQ key addr_pairr r1 s r rS z:BaseEventLoop.create_datagram_endpoint.<locals>.<listcomp>B sU #E #E #E)7i '#E,5aL,@ ( -A-6q\-A )$-A-A-Ar 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))'rF r* r9 r+ dictrg itemsr r) r8 r r r= statS_ISSOCKosst_moderemoveFileNotFoundErrorr. r errorr rW r r: r1 r, r- SO_BROADCASTr r r rA r r) rw r r ) r r r r1 rE rG r r. r/ r0 optsproblemsr_addraddr_pairs_infor` err
addr_infosidxr famr pror( r< r
local_addressremote_addressrl r r r s `` r create_datagram_endpointz&BaseEventLoop.create_datagram_endpoint sR
* yF ... C4CCE E E
=k
=
= #
=',
=
="1
= z{#)e'1,;= = = 99$N$NDJJLL$N$N$NNN <08< < <= = =
U # # #FF 2
H+ 2
HQ;;$%@AAA%+UO\#B"D++ .
H&.0H0H ' 5 > >D'
40E0E' '(< = ==
6*Q-{"B"B 6 =)<)<)DEE 2 Ij 1 1 1, " 6 6 6 &5%/6 6 6 6 6 6 6 66 &,UO%/$=$? #B
#$j/A{3C!D ; ;IC' *4 7 7 CCIINN"+,A"B"B B&*&;&; f6G"'u4 '< 'A 'A !A !A !A !A !A !A % O")*M"N"N N7< ; ; 3CCG#&*C "* 4 437,
33:JsOC 0 0#E #E #E #E #E;E;K;K;M;M#E #E #E
' H$%FGGGJ 6E
$
$ 2 &%0- != %F,=U L L LD! -&t,,,& G " -v/BAG G G$$U+++! 1 -000" 0 . J"&"3"3D."I"I I I I I I I I!/ E + + +'
%J%c********'
!m###%%##%%11 (FF, , ; ?
? 0 & YJ J J J ( ()X? ? ? LLLLLLLL OO (""sC 1?E1 1
F&= F&F!!F&$B-M
N$ &N N$ P( (P?c K |d d \ }}t |||||g|dd R } | | gS | |||||| d {V S )Nr: r )rL r )
r r( rE rF rG r r rC rD r s
r r z BaseEventLoop._ensure_resolved s RaR[
dD$eJgabbkJJJ 6M ))$V$05U * D D D D D D D D
Dr c K | ||f|t j || d {V }|st d|d |S )N)rE rF r r z getaddrinfo(z) returned empty list)r r* r9 r. )r rC rD rE r r s r _create_server_getaddrinfoz(BaseEventLoop._create_server_getaddrinfo s ++T4L171C27d , D D D D D D D D HFFFFGG G r r )
rE r r0 r rt
reuse_addressr. r r r c
K t |t rt d | |t d | |t d |t | ||t d | t
j dk ot j dk } g }|dk rd g}n:t |t s t |t j j s|g}n|} fd|D }t j | d {V }t t j | }d } |D ]}|\ }}}}} t' j ||| }n5# t& j $ r# j rt- j d
|||d Y Tw xY w| | | r+| t& j t& j d |
rt9 | t: rP|t& j k r@t? t& d
r+| t& j t& j! d |" | # tF $ r}d|d|j$ % }|j& tL j' k rI|( |) j rt- j | Y d }~tG |j& | d d }~ww xY w|s tG dd |D d }|s|D ]}|) n\# |s|D ]}|) w w xY w|t d |j* t& j+ k rt d| |g}|D ]}|, d t[ ||||| | }|
r.|. t j/ d d {V j rt- j0 d| |S )Nz*ssl argument must be an SSLContext or Noner r r posixcygwinr4 c B g | ]} | S ))rE r )rV )rQ rC rE r rD r s r rS z/BaseEventLoop.create_server.<locals>.<listcomp> sG % % % 11$V8= 2 ? ? % % %r Fz:create_server() failed to create socket.socket(%r, %r, %r)Texc_info IPPROTO_IPV6r r z%could not bind on any address out of c g | ]
}|d S ) rP )rQ r s r rS z/BaseEventLoop.create_server.<locals>.<listcomp> s %@%@%@$d1g%@%@%@r z)Neither host/port nor sock were specifiedr r z
%r is serving)1r r r= r+ rv rB r rx platformr rT abcIterabler rY setrY rZ r[ r* rF rw r warningrA r, r- SO_REUSEADDRr1 r@ r r) r^ IPV6_V6ONLYr r. r r r
EADDRNOTAVAILr r rF r9 r r r r r ) r r rC rD rE r r0 r rt rW r. r r r r hostsfsr completedresrK socktyperG canonnamesarL r r s ` ``` r
create_serverzBaseEventLoop.create_server s2 c4 J HII I , CE E
E + BD D
D d # # # t / NP P P $ "7 2 Os|x7O
Grzz T3''
{'?@@
% % % % % % % #% % %B ,+++++++E 55e<<==E I2
% '@ '@C9<6B%B! %}R5 A A!< ! ! ! ; O "N ,G+-x O O O O !
! NN4((($ J " -v/BDJ J J! -&t,,, " . &/ 1 1 #FN ; ; 2 (;(.(:(,. . .
@ "
" @ @ @ @ #%""cl&8&8&:&:&: < 9(;;; #KKMMM JJLLL #{ 4 &s 3 3 3 $HHHH %ci 5 54? @ D!'%@%@%%@%@%@%@#C D D D ! % ' % %
! % ' % %
%% | !LMMMyF ... !Nd!N!NOOOfG $ $D U # # # #g'7W&;,. . ! ! ! # # # +a.. ; 1 K 0 0 0
sb 5
L2 EL2 /F L2 F B-L2 :IL2
K3A7K.L2 K..K33#L2 2 M)rt r r c z K |j t j k rt d| ||st d ||st d |t | | |||dd|| d {V \ }}| j r,| d }t j d||| ||fS ) Nr r r r4 T)r r r r* z%r handled: (%r, %r))
rF r* r9 r+ rv r rw r r r )r r r0 rt r r r r s r connect_accepted_socketz%BaseEventLoop.connect_accepted_socket" s!
9* * * J$ J JKK K ,S , CE E
E +C + BD D
D d # # #$($E$E "C"7!5 %F %7 %7 7 7 7 7 7 7 8 ; L ++H55D L/y( K K K(""r c K | }| }| ||| } | d {V n# | xY w| j r)t j d| || ||fS )Nz Read pipe %r connected: (%r, %r))r r- r rw r r filenor r r, r r r s r connect_read_pipez BaseEventLoop.connect_read_pipe@ s ##%%##%%2246JJ LLLLLLLL OO ; = L; 8
=
=
=("" A Ac K | }| }| ||| } | d {V n# | xY w| j r)t j d| || ||fS )Nz!Write pipe %r connected: (%r, %r))r r/ r rw r r rt ru s r connect_write_pipez BaseEventLoop.connect_write_pipeP s ##%%##%%33D(FKK LLLLLLLL OO ; = L< 8
=
=
=(""rw c |g}|%| dt | |6|t j k r&| dt | nN|%| dt | |%| dt | t j d | d S )Nzstdin=zstdout=stderr=zstdout=zstderr= )rA r& r" r$ r r rg )r r r3 r4 r5 r s r _log_subprocessz BaseEventLoop._log_subprocess` s u KK6 e!4!466 7 7 7 &J,="="= KK? f)=)=?? @ @ @ @! <l6&:&: < <===! <l6&:&: < <=== SXXd^^$$$$$r ) r3 r4 r5 universal_newlinesr2 r6 encodingerrorstextc
K t |t t f st d |rt d |st d |dk rt d | rt d | t d |
t d | }
d }| j r d |z }| |||| | j |
|d
||||fi | d {V }| j r|t j d || ||
fS ) 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+ rw r| r8 r r )r r cmdr3 r4 r5 r} r2 r6 r~ r r r7 r debug_logr s r subprocess_shellz BaseEventLoop.subprocess_shellm s #s|,, 5 344 4 A ?@@ @ 3 122 2 a<< 011 1 3 122 2 455 5 233 3##%% ; C /4I E66 B B B9$9 c4K KCIK K K K K K K K ; 890 K)Y 7 7 7(""r c K |rt d |rt d |dk rt d | rt d | t d |
t d |f| z } | }d }| j r d|}| |||| | j ||d ||||fi |
d {V }| j r|t j d
|| ||fS ) Nr zshell must be Falser r r r r zexecute program Fr )r+ rw r| r8 r r )r r programr3 r4 r5 r} r2 r6 r~ r r r1 r7
popen_argsr r r s r subprocess_execz BaseEventLoop.subprocess_exec sb A ?@@ @ 4 233 3 a<< 011 1 3 122 2 455 5 233 3 Z$&
##%% ; C 7766I E66 B B B9$9 j% ; 890 K)Y 7 7 7(""r c | j S rO )r r s r get_exception_handlerz#BaseEventLoop.get_exception_handler s &&r c \ |!t | st d| || _ d S )Nz+A callable object or None is expected, got )r r= r )r handlers r set_exception_handlerz#BaseEventLoop.set_exception_handler sN
x'8'8 /#* / / 0 0
0") r c | d }|sd}| d }|t | ||j f}nd}d|vr"| j | j j r| j j |d< |g}t | D ]}|dv r|| }|dk rAd t j | }d }|| z
}nV|dk rAd t j | }d
}|| z
}nt | }| | d | t j
d | |
d S )NrU z!Unhandled exception in event looprf Fsource_tracebackhandle_traceback> rU rf r4 z+Object created at (most recent call last):
z+Handle created at (most recent call last):
r
r\ )getrF
__traceback__r r sortedrg traceback format_listrstripr rA r rF ) r r rU rf r] log_linesr< valuetbs r default_exception_handlerz'BaseEventLoop.default_exception_handler s
++i(( :9GKK ,, YI4KLHH H g - -$0$6 1 $6
& ' I '?? 0 0C...CLE(((WWY 25 9 9::F$***WWY 25 9 9::F$ U . .u . . / / / / TYYy))H======r c | j P | | d S # t t f$ r t $ r t j dd Y d S w xY w | | | d S # t t f$ r t $ rc} | d||d n7# t t f$ r t $ r t j dd Y n
w xY wY d }~d S Y d }~d S d }~ww xY w)Nz&Exception in default exception handlerTr\ z$Unhandled error in exception handler)rU rf r zeException in default exception handler while handling an unexpected error in custom exception handler)r r rg rh r( r rF )r r rl s r r\ z$BaseEventLoop.call_exception_handler s * " *
,..w77777 12
,
,
, E&*, , , , , , ,
,
0''g66666 12
0
0
0022#I%(#*4 4
#$56 $ 0 0 0 L "? +/0 0 0 0 0 00 0 0 0 0 0 0
0sE ! 1AAA2 2C0B('C+(1C C+C C++C0c N |j s | j | d S d S rO )
_cancelledr rA r r s r
_add_callbackzBaseEventLoop._add_callback4 s6 % ' K v & & & & & ' 'r c Z | | | d S rO )r r: r s r _add_callback_signalsafez&BaseEventLoop._add_callback_signalsafe9 s1 D 6""" r c : |j r| xj dz
c_ d S d S rp )r r r s r _timer_handle_cancelledz%BaseEventLoop._timer_handle_cancelled> s4 A - ' '1 , ' ' ' ' - -r c t | j }|t k rf| j |z t k rSg }| j D ]&}|j rd|_ | | 't j | || _ d| _ nb| j r[| j d j rI| xj dz c_ t j | j }d|_ | j r| j d j Id }| j
s| j rd}nQ| j rJ| j d j }t t d|| z
t }| j | }| | d }| | j z }| j rZ| j d }|j |k rnAt j | j }d|_ | j
| | j Zt | j
}t+ | D ]} | j
}|j r#| j r || _ | }
| | |
z
} | | j k r#t7 j dt; | | d | _ # d | _ w xY w| d }d S )NFr r z Executing %s took %.3f seconds) rW r _MIN_SCHEDULED_TIMER_HANDLESr %_MIN_CANCELLED_TIMER_HANDLES_FRACTIONr rA r heapifyheappopr r _whenr maxr MAXIMUM_SELECT_TIMEOUT _selectorselectr= r rangepopleftrw r _runr r re r ) r sched_count
new_scheduledr timeoutr r< end_timentodoir r s r r} zBaseEventLoop._run_onceC s $/** 6 6 6 '+ 55
6
6 M /
1
1$ 1(-F%%!((0000 M- ( ( ( +DO*+D ' ' /
*doa&8&C
*++q0++ t77$)! /
*doa&8&C
*
; N$. NGG
_ N?1%+D#a !3446LMMG^**733
Z(((
99;;!77o '_Q'F|x'']4?33F %F K v & & &
o ' DK u A[((**F
{
0+1D( BKKMMM r)BT 888 'G'5f'='=rC C C ,0D((4D(////
s
A4K Kc t | t | j k rd S |r7t j | _ t j t j nt j | j || _ d S rO )r r rx #get_coroutine_origin_tracking_depthr #set_coroutine_origin_tracking_depthr DEBUG_STACK_DEPTHr enableds r rv z,BaseEventLoop._set_coroutine_origin_tracking s ==D!H I I I I F =799
7 3+
-
-
-
-
3;
=
=
= 3:///r c | j S rO )rw r s r r zBaseEventLoop.get_debug s
{r c v || _ | r | | j | d S d S rO )rw r rC rv r s r r zBaseEventLoop.set_debug sG ?? T % %d&I7 S S S S S T Tr rO )NNNr7 )r )r N)FNN)Ur r r r r r r r r r r& r) r- r/ r8 r: r= r
r@ rG rO r` rj re rr r r rj r r rK rL r r r r r r r r r rC r r r r r r r r r r r r r r r r- rS r* r9 r rV r>
AI_PASSIVErp rr rv ry r| r" r# r r r r r r\ r r r r} rv r r rP r r r r s / / /<
) ) ) )-d * % % % " " ""%)$" " " " " 9=" $t"&!%!%
" " " " " CG" " " "
@D(," " " "
AE)-" " " " 04" " " " " " "" " "7 7 7D D DG G G
" " " 2 D D DK K K4 4 40$ $ $ L * * *. %M - - - :> 0 6: $ 26 &% % % ( ( (" =A 5 5 5 * * *
2 "#!1H H H H H7 7 7 7
A(,
A
A
A
A
A . . ./ / /4 **. *. *. *.Z 59G#14T"&!%!%$G# G# G# G# G#V */"&!% # # # #8-<#'-< -< -< -< -<^1 1 1" " "4 %*(,.2-1 .+ .+ .+ .+ .+b EID#./q267;$ D# D# D# D# D#N '(f.@%&a
D
D
D
D
D 59I ## "&!% I I I I IZ "&!% # # # # #<# # # # # # % % % &0_&0o&0o27%)1(,T
"# "# "# "# "#J %/OJO%/_$)1'+Dt # # # # #D' ' '
* * *"0> 0> 0>d70 70 70r' ' '
- - -
N N N`
:
:
: T T T T Tr r )r r )r )6rT collections.abcconcurrent.futuresr r r r rY rB r* r@ r" rc r r rx rK r rt ImportErrorr4 r r r r r r r
r r r
r logr __all__r r r) r@ r r r& r1 rL rc rm rq rv Protocolrx AbstractServerr AbstractEventLoopr rP r r <module>r sh
JJJJ
CCC $
# ), %
GFJ ' ' # J J J8 8 8 8v ," " " 76=!!
G G G G
> > >
A) A) A) A) A) 2 A) A) A)Hn n n n nV
" n n nbeT eT eT eT eTF, eT eT eT eT eTs A AA