python (3.12.0)
ˑe) ( 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 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^ Z0 G d d!ejb Z2 G d" d#ejf Z4y# e$ r dZY w xY w)& 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 G/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/asyncio/base_events.py_format_handler F s= B'"j$/<BKK 6{ c h | t j k( ry| t j k( ryt | S )Nz<pipe>z<stdout>)
subprocessPIPESTDOUTr )fds r _format_piper& O 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_reuseportr1 X 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<t
|t r|dk( rd}n$t
|t r|dk( rd}n t | }|t j k( r7t j g}t r#|j t j n|g}t
| t r| j# d } d| v ry |D ]I } t j$ || t r |t j k( r
|||d| |||ffc S |||d| |ffc S y # t t f$ r Y y w xY w# t& $ r Y mw xY w)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 c s 6; ' Q**F,>,>?? 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 <genexpr>z(_interleave_addrinfos.<locals>.<genexpr> s
]
s )
collections OrderedDictrA listvaluesextend itertoolschain
from_iterable zip_longest) addrinfosfirst_address_family_countaddrinfos_by_familyaddrrE addrinfos_lists reordereds r _interleave_addrinfosrc s 7%113 1a , ,*, 'F#**40 1
.5578OI!A% +,K-G!-KLM A > :Q > > ?
??00 ! !? 3
r c | j s'| j }t |t t f ry t j | j y rO ) cancelled exceptionr
SystemExitKeyboardInterruptr _get_loopstop)futexcs r _run_until_complete_cbrm 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 )
rE r* r? r rF r9 rG r7 r, rn r/ s r _set_nodelayrq sj KKFNNFOO< < V / //
f 0 00 OOF . .0B0BA F 1 0
=r c y rO rP r/ s r rq rq s r c \ t &t | t j r t d y y )Nz"Socket cannot be of type SSLSocket)sslr SSLSocketr= r/ s r _check_ssl_socketrv 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 rk 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 rl s r r z)_SendfileFallbackProtocol.connection_lost s[ , {%%33#$BCE %%33C8 ##C(r c p | j y | j j j | _ y rO )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 wrO ) 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 rP r r rx rx s3 ) O )F
% FF
)r rx 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<z sockets=>) __class__r r r s r __repr__zServer.__repr__" s' 4>>**+9T\\4DAFFr c . | xj dz
c_ y rp )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 | & y rO )r doner )r waiterswaiters r r zServer._wakeup/ s8 --
*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 r0 s r r zServer._start_serving6 su ==
MM ,D KK
& JJ % %&&d.?.?dmmT%@%@**
, ,r c | j S rO )r r s r get_loopzServer.get_loopA s zzr c | j S rO )r r s r
is_servingzServer.is_servingD s }} r c T | j yt d | j D S )NrP c 3 F K | ] }t j | y wrO )r TransportSocket)rQ ss r rS z!Server.sockets.<locals>.<genexpr>K s F1V++A.Fs !)r tupler s r r zServer.socketsG 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 r0 s r closez Server.closeM s -- ?
+D JJ $ $T * +
% % 1--224 % % , , .(,D % " LLN #r c j K | j t j d d { y 7 wNr )r r sleepr s r
start_servingzServer.start_serving` 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_foreverf s $ $ 0 $!MNP
P ==
;< < $(JJ$<$<$>! -++ + + )-D %
,((
&&((( )-D %s` A&C)B 8B9B >CB C #C?C CC CC C CCc K | j | j dk( ry | j j }| j j | | d { y 7 wr )r r r r rA )r r s r r zServer.wait_closed{ sK == D$6$6!$; ))+
V$ s AA!A A!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
& -*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 _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!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 & | j | j 4t j || || }|j r
|j d= |S || j | | }n| j | || }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'JD%%**2. ))$5))$g)F t , r c 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 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 wrO r )
r r argsshellstdinstdoutstderrbufsizer kwargss
r _make_subprocess_transportz(BaseEventLoop._make_subprocess_transport s +!!s
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 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 rO )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 )messagerf asyncgen) r lenr rV clearr gatherrE zipr Exceptioncall_exception_handler)r
closing_agensagresultsresultrG s r shutdown_asyncgensz BaseEventLoop.shutdown_asyncgens s :*.'4??#
T__-
$1
2bbiik
2$ "$ $ 7 LFD&),++"99= B!' $ - 3$s$ A!C#C:
CC &C,!Cc K d| _ | j y | j }t j | j
|f }|j
| d { |j | |j r=t j d| dt d | j j d y y 7 c# |j | w xY ww) NT)targetr2 z:The executor did not finishing joining its threads within z seconds. )
stacklevelFwait)
r r r threadingThread _do_shutdownstartjoinis_aliverL rM RuntimeWarningshutdown)r timeoutfuturethreads r shutdown_default_executorz'BaseEventLoop.shutdown_default_executor4 s *.& ! ! ) ##%!!):):&K !LL KK ?? MM 33:)9F +
;
" " + + + 7
KK s1 AC C C!C %A C C CC c & | j j d | j s | j |j d y y # t
$ r;}| j s!| j |j | Y d }~y Y d }~y d }~ww xY w)NTrd )r rm r rD r rY r )r ro exs r rh zBaseEventLoop._do_shutdownL s~ D " " + + + 6>>#))&*;*;TB $ D>>#))&*>*>CC $ Ds AA B,B Bc x | j r t d t j t d y )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_runningU s> ?? 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 rv _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_forever\ 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 rv r isfuturer
ensure_future_log_destroy_pendingadd_done_callbackrm r r re rf remove_done_callbackr r^ )r ro new_tasks r run_until_completez BaseEventLoop.run_until_completet s
''//$$V$7 +0F ' !78
@
' '(> ?{{} LM M}} FKKM&2B2B2D " ' '(> ?s .B? ?5C44C7 7Dc d| _ y r )r r s r rj 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 rm r executors r r zBaseEventLoop.close s ?? BC C << ;; LLT * )-&)) %)D " 5 ) r c | j S rO )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 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 | 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 rA )r r r2 r
r s r r zBaseEventLoop._call_soon 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_thread 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_threadsafe/ 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_executor: 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_executorJ 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: ) rA rj r r r r* getaddrinfor info) r rC rD rE rF rG flagsmsgt0addrinfodts r _getaddrinfo_debugz BaseEventLoop._getaddrinfo_debugO s q!" JJ
+ , JJth' ( JJy) * JJy) *iin *C0
YY[%%dD&$uM
YY[2
%cU&c#d8,O
,, , KK
LL r r rE rF rG r c
K | j r
| j }nt j }| j d ||||||| d { S 7 wrO )r{ r r* r r )r rC rD rE rF rG r getaddr_funcs r r zBaseEventLoop.getaddrinfog sU ;; 22L!--L)) ,dFD%H H H Hs AAA Ac b K | j d t j || d { S 7 wrO )r r* getnameinfo)r sockaddrr s r r zBaseEventLoop.getnameinfoq 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+ rv _check_sendfile_params_sock_sendfile_nativer SendfileNotAvailableError_sock_sendfile_fallback)r r0 fileoffsetcountr rl s r
sock_sendfilezBaseEventLoop.sock_sendfileu 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 r0 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 r0 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+ rF r* r9 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 $ rQ}
d| d|
j
j
}t |
j | }
|j |
Y d }
~
d }
~
ww xY w7 g# t $ r)}
|j |
|
|
j d }
~
w |
|
j xY w# d x}}w xY ww)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%HD U # +/? Y+GQ1e &(
2 %(
Y % + / / 11 %(OyPV&W XX##D'2 2 2 *. -J 3 # 2 '',ir "|| 1 1 3 4 6
&cii 5%,,S112
3 %
)- -J sk E%<D B519D *D+D 0E%5 D>AD
D
DD E $EEE E""E%) rt rE rG r r0
local_addrr" r r happy_eyeballs_delay
interleave
all_errorsc F 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 { } n1 n/t j fd |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 g# t
$ r Y w xY w7 Kc 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 timerE rF rG r r !getaddrinfo() returned empty listc 3 b K | ]& }t j j | ( y wrO ) functoolspartialr )rQ r r laddr_infosr s r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>@ s4 ,! &&t'9'9'18[J ,s ,/r zcreate_connection failedr c 3 : K | ] }t | k( y wrO r )rQ rl models r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>O s GSs3x5 0 Gs zMultiple exceptions: {}r c 3 2 K | ] }t | y wrO r )rQ rl s r rS z2BaseEventLoop.create_connection.<locals>.<genexpr>T s %E3c#h%Es 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_raceExceptionGrouprU r allr rj rF _create_connection_transportr{ get_extra_infor r )r r rC rD rt rE rG r r0 r r" r r r r r infosr r subrl r r r r r s ` @@@r create_connectionz BaseEventLoop.create_connection st
&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 &+&? ? ! $-#;#;,%*, )t $5 5
a |-7 Gc3 GCc Gc 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
@(""_N ," ? # ! ! 5 H "&J 7s BJ!I6;J!I9*J!?I?I<I?*J!JJ!J$J!)A8J !AJ!3J 4AJ!9J!<I?? J J! J J!J!J J!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 r0 r rt r" r! r r r r r& r s r r z*BaseEventLoop._create_connection_transportr 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 rl 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
<sN BC: C "C#C &(C:C8C:C C5(C0+C:0C55C:c 4 K t j d w)Nz!sendfile syscall is not supportedr )r r r r r s r r# z BaseEventLoop._sendfile_native s 22 /1 1s c K |r|j | |r t |d nd}t | }d}t | } |rSt ||z
| }|dk r?||dkD r t |d r|j ||z |j d { S t
| d | } | j d |j | d { }
|
s?||dkD r t |d r|j ||z |j d { S |j d { |j | d |
||
z
}7 7 y7 ;7 $# |dkD r t |d r|j ||z |j d { 7 w xY ww)Ni @ r r ) 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 sx IIf ).Cu%E "
)&1 " #EJ$6 BI A~ ) A~'$"7 &:-.--/ ! ! "#z 2 ! 1 1$
t LL%
A~'$"7 &:-.--/ ! !
kkm## T%4[)d"
" M
"
$ A~'$"7 &:-.--/ ! !s <FE 8FD;F.E D=E 8FD?F E E E ;F=E ?FE 9F<E?=FFr c p K t t d t |t j st d| t |dd st d|d | j
}t j | |||||||d } |j |j | | j | j | }
| j |j } | d { | j" S 7 # t $ r2 |j |
j! | j! w xY ww)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 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)rE rG r
reuse_portallow_broadcastr0 c F K | | j t j k7 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 j ||| 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 j | } |r t3 | |r/| j5 t j6 t j8 d | j d |r| j; | |r |s| j= | | d { |} n |d | } | jC } | jE | | | | } | jF r4|rt) jH d||| | nt) jJ d|| | | d { | | fS # t$ $ r Y 0t& $ r"}t) j* d|| Y d }~Ud }~ww xY w7 c c}}w 7 # t& $ r/} | | j? |j@ | Y d } ~ d } ~ w | | j? xY w7 # | j? xY ww)Nz A UDP Socket was expected, got )r remote_addrrE rG r r3 r4 r c 3 6 K | ] \ }}|s | d | yw)=NrP )rQ kvs r rS z9BaseEventLoop.create_datagram_endpoint.<locals>.<genexpr> s $NDAqAs!A3Z$Ns
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))&rF r* r: r+ dictrj itemsr r) r= r r r= statS_ISSOCKosst_moderemoveFileNotFoundErrorr. r errorr rU r r1 r, r- SO_BROADCASTr r r rA r r* r{ r r ) r r r r6 rE rG r r3 r4 r0 optsproblemsr_addraddr_pairs_infor` err
addr_infosidxr famr pror) key addr_pairr
local_addressremote_addressrl r r r s r create_datagram_endpointz&BaseEventLoop.create_datagram_endpoint
s
* yyF - -- 5dX>@ @keu /z{#)e'1,;= 99$NDJJL$NN 008z<= =
U #F +Q;$%@AA%+UO\#B"D+&..0H ' 5 >D'
40E '(< ==> *Q-{"B 6 ==)<)D)DE IIj 1 &,UO%/$=$? #B
#$j/A{3C!D ;IC' *4 7CIN"+,A"B B&*&;&; f6G6G"'u4 '< 'A !A %")*M"N N7< ; 3CCG#&*C "* 437,
33:JsOC 0 ;;& <F;K;K;M#E)7i 'IaL,@ (Yq\-A )$#E #E
'$%FGGJ 6E
$ 2 &%0- !== %F,=,=U LD!&t,& " - -v/B/BAG$$U+! -0" ."&"3"3D."I I I!/ ;
$> !m##%##%11 (FF, ;; 0 & YJ ( ()X? LL
(""} - " 6 &5%/6 66 !A#E8 J +'
%J%%c**'
*
OO s C"P!%P!6P! AM7 P!0AP!N0A
P! N3($P!
B!N;.N9/N;5A3P!)P .P /P 3P!7 N- P!N- N("P!(N--P!3P!9N;; P$O.(P!.PP! P P P!c K |d d \ }}t |||||g|dd } | | gS |j |||||| d { S 7 w)Nrb r )rL r )
r r) rE rF rG r r rC rD r s
r r z BaseEventLoop._ensure_resolved st Ra[
dD$eJgabkJ 6M ))$V$05U * D D
D Ds ;AAAc K | j ||f|t j || d { }|st d|d |S 7 w)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] ++T4L171C1C27d , D D L0EFG G Ds *AAAr )
rE r r0 r rt
reuse_addressr3 r r r c
, K t |t r t d |
| t d |
| t d | t | ||| t d | (t
j dk( xr t j dk7 } g }|dk( rd g}n:t |t s$t |t j j s|g}n|}|D cg c] }| j |||| }}t j | d { }t! t" j$ j' | }d } |D ] }|\ }}}}} t) j( ||| }|j3 | | r/|j5 t( j6 t( j8 d |
r t; | t< rR|t( j> k( r?tA t( d
r/|j5 t( jB t( jD d |jG | d }|sS|D ] }|jQ n;| t d |jR t( jT k7 rt d| |g}|D ] }|jW d tY | ||||| | }|
r-|j[ t j\ d d { | j, rt/ j^ d| |S c c}w 7 # t( j* $ r* | j, rt/ j0 d
|||d Y w xY w# tH $ r:}tI |jJ d|d|jL jO d d }~ww xY w# |s|D ] }|jQ w w xY w7 խw)Nz*ssl argument must be an SSLContext or Noner r r posixcygwinr4 )rE r Fz:create_server() failed to create socket.socket(%r, %r, %r)Texc_info IPPROTO_IPV6r r z)Neither host/port nor sock were specifiedr r z
%r is serving)0r r r= r+ rv rC r r| platformr rT abcIterablerY r rW setrY rZ r[ r* rG r{ r warningrA r, r- SO_REUSEADDRr1 r@ r r) r` IPV6_V6ONLYr r. r r r r rF r9 r r r r r )r r rC rD rE r r0 r rt rZ r3 r r r r hostsfsr completedresrK socktyperG canonnamesarM 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' {'?'?@ $% 11$V8= 2 ? %B % ,,++E 55e<=E I%
% NC9<6B%B! %}}R5 A NN4($ " - -v/B/BDJ!&t, " &// 1 #FN ; (;(;(.(:(:(,.N "
7 N@ ! ' %
% | !LMMyyF . .. #EdX!NOOfG $D U # $ g'7W&;,. ! ! # ++a. ;; KK 0
E% , "<< ! ;; "NN ,G+-x O !
!0 # N %cii)+S\\-?-?-A2C DIMNN ! ' %
% !(
!s C
N K%+NK*.N2
M3 K-B'M3 ?L-M3 B(N<N=.N-9L*&M3 )L**M3 - M065M++M00M3 3 NN)rt 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 r4 T)r! r r r* z%r handled: (%r, %r))
rF r* r9 r+ rv r r{ r r r )r r r0 rt r r r r s r connect_accepted_socketz%BaseEventLoop.connect_accepted_socket" 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_pipe@ 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 rs rt s r connect_write_pipez BaseEventLoop.connect_write_pipeP s #%##%33D(FK LL
;; LL< 8
=(""
OO rv 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= )rA r& r" r$ r r rj )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_shellm 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 rO )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 looprf Fsource_tracebackhandle_traceback> rS rf r4 z+Object created at (most recent call last):
z+Handle created at (most recent call last):
r
r^ )getrF
__traceback__r r sortedrj traceback format_listrstripr rA r rG ) r r
rS rf r_ log_linesrR valuetbs r default_exception_handlerz'BaseEventLoop.default_exception_handler se
++i(9GKK , YI4K4KLH H g -$$0$$66$$66
& ' I '? 0C..CLE((WWY 2 25 9:F$**WWY 2 25 9:F$ U uBug . / 0 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 rf r
zeException in default exception handler while handling an unexpected error in custom exception handler) r r rg rh r- r rG r r) r r )r r
ctxthingrl 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 rO )
_cancelledr rA r r s r
_add_callbackzBaseEventLoop._add_callbackC s% % KK v & !r c H | j | | j y rO )r r; r s r _add_callback_signalsafez&BaseEventLoop._add_callback_signalsafeH s D 6" r c J |j r| xj dz
c_ y y rp )r r r s r _timer_handle_cancelledz%BaseEventLoop._timer_handle_cancelledM 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 rA r heapifyheappopr r _whenr maxr MAXIMUM_SELECT_TIMEOUT _selectorselectr> r rangepopleftr{ r _runr r re r ) r sched_count
new_scheduledr rn r r= end_timentodoir r s r r zBaseEventLoop._run_onceR s $//* 6 6 ' '+ 55
6 M //
1$$(-F%!((0
1
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 rO )r r r| #get_coroutine_origin_tracking_depthr #set_coroutine_origin_tracking_depthr DEBUG_STACK_DEPTHr enableds r rz z,BaseEventLoop._set_coroutine_origin_tracking sw =D!H!H I I 779
7 3 3++
- 3:/
3 3;;
= 3:/r c | j S rO )r{ r s r r zBaseEventLoop.get_debug s {{r c l || _ | j r | j | j | y y rO )r{ r rD rz r s r r zBaseEventLoop.set_debug s. ?? % %d&I&I7 S r rO )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 rv r r rj 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* r9 r rY r>
AI_PASSIVEro rq ru rx r{ r" r# r r r r r rZ r r r r rz r r rP r r r r s /<
) )-d * % ""%)$" 9=" $t"&!%!%
" CG"
@D(,"
AE)-" 04" ""7DG
"280DK40$ L *. %MM - :> 0 6: $ 26 &%(" =A 5 *
2 "#!1H7
A(,
A ./4 **.Z 59J#14T"&!%!%$ J#\ */"&!% #8-<#'-<^1"4 %*(,.2-1 .+b EID#./q267;$ D#N '(f.@.@%&a
D 59| #### "&!% |@ "&!% #<# # % &0__&0oo&0oo27%)1(,T
"#J %/OOJOO%/__$)1'+Dt #D'
*"0>dF0P'
-
N`
: Tr r )r r )r )5rT collections.abcconcurrent.futuresr r
r rY rC r* rA r" rf r r r| rL 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 s*
$
# ), %
FJ ' # J8v," 6=!G
>
A) 2 2 A)HnV
"
" nbuTF,, uTA
Cs D DD
Browse
Usage
Versions