cjr d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z G d d Z
G d de
Z G d d
Z G d d Z
G d
d Z G d de Zda ej" Z G d dej& Z e Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d Z d Z eZ!eZ"eZ#e Z$ dd l%mZmZmZm Z eZ&eZ'eZ(e Z) e+ed rd Z, ejZ e,! yy# e*$ r Y (w xY w)")AbstractEventLoopPolicyAbstractEventLoopAbstractServerHandle TimerHandleget_event_loop_policyset_event_loop_policyget_event_loopset_event_loopnew_event_loopget_child_watcherset_child_watcher_set_running_loopget_running_loop_get_running_loop N )format_helpersc > e Zd Z dZd
dZd Zd Zd Zd Zd Z d Z
y) r ) _callback_args
_cancelled_loop_source_traceback_repr __weakref___contextNc " |t j }|| _ || _ || _ || _ d| _ d | _ | j j r.t j t j d | _
y d | _
y )NFr ) contextvars copy_contextr r r r r r get_debugr
extract_stacksys _getframer )selfcallbackargsloopcontexts '/usr/lib64/python3.12/asyncio/events.py__init__zHandle.__init__$ sx ?!..0G
!
:: !%3%A%A
a &"D " &*D " c h | j j g}| j r|j d | j 9|j t j | j | j | j r,| j d }|j d|d d|d |S )N cancelledz created at r :r ) __class____name__r appendr r _format_callback_sourcer r )r$ infoframes r)
_repr_infozHandle._repr_info3 s ''( ?? KK $ >> % KK>>
,
- ! !**2.E KK+eAhZqq
; < r+ c | j | j S | j }dj dj | S )Nz<{}> )r r6 formatjoin)r$ r4 s r) __repr__zHandle.__repr__? s9 :: !:: }}SXXd^,,r+ c | j S N)r r$ s r) get_contextzHandle.get_contextE s }} r+ c | j s@d| _ | j j rt | | _ d | _ d | _ y y )NT)r r r reprr r r r> s r) cancelz
Handle.cancelH s@ "DOzz##% "$Z
!DN DJ r+ c | j S r= )r r> s r) r- zHandle.cancelledS s r+ c | j j | j g| j d } y # t t
f$ r t $ rw}t j | j | j }d| }||| d}| j r| j |d< | j j | Y d }~d } y d }~ww xY w)NzException in callback )message exceptionhandlesource_traceback) r runr r
SystemExitKeyboardInterrupt
BaseExceptionr r3 r r call_exception_handler)r$ exccbmsgr( s r) _runz Handle._runV s 7 DMM dnn :tzz : -. 7 77
,B*2$/C G
%%.2.D.D*+ JJ - -g 6 6 7s 16 CA+C Cr= ) r1
__module__ __qualname__ __slots__r* r6 r; r? rB r- rQ r+ r) r r s/ ; I
*
- r+ r c h e Zd Z ddgZd
fd Z fdZd Zd Zd Zd Z d Z
d
Z fd Z d Z
xZS )r
_scheduled_whenc x t | |||| | j r
| j d= || _ d| _ y )Nr. F)superr* r rX rW )r$ whenr% r& r' r( r0 s r) r* zTimerHandle.__init__o s;
4w7 ! !&&r*
r+ c t | }| j rdnd}|j |d| j |S )N r zwhen=)rZ r6 r insertrX )r$ r4 posr0 s r) r6 zTimerHandle._repr_infov s; w!#??a C5 -. r+ c , t | j S r= )hashrX r> s r) __hash__zTimerHandle.__hash__| s DJJ r+ c ` t |t r| j |j k S t S r=
isinstancer rX NotImplementedr$ others r) __lt__zTimerHandle.__lt__ % e[ ):: + + r+ c t |t r,| j |j k xs | j | S t S r= re r rX __eq__rf rg s r) __le__zTimerHandle.__le__ 3 e[ ):: +At{{5/A A r+ c ` t |t r| j |j kD S t S r= rd rg s r) __gt__zTimerHandle.__gt__ rj r+ c t |t r,| j |j kD xs | j | S t S r= rl rg s r) __ge__zTimerHandle.__ge__ ro r+ c t |t rj| j |j k( xrO | j |j k( xr4 | j |j k( xr | j
|j
k( S t S r= )re r rX r r r rf rg s r) rm zTimerHandle.__eq__ sl e[ )JJ%++- 8NNeoo58JJ%++-8 OOu'7'77
9 r+ c p | j s| j j | t | y r= )r r _timer_handle_cancelledrZ rB )r$ r0 s r) rB zTimerHandle.cancel s& JJ . .t 4
r+ c | j S r= )rX r> s r) r[ zTimerHandle.when s
zzr+ r= )r1 rR rS rT r* r6 rb ri rn rq rs rm rB r[
__classcell__)r0 s @r) r r j sB A w'I
r+ r c > e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
y )
r c t r= NotImplementedErrorr> s r) closezAbstractServer.close s C!!r+ c t r= r{ r> s r) get_loopzAbstractServer.get_loop s B!!r+ c t r= r{ r> s r)
is_servingzAbstractServer.is_serving A!!r+ c K t wr= r{ r> s r)
start_servingz AbstractServer.start_serving s
"!
c K t wr= r{ r> s r)
serve_foreverz AbstractServer.serve_forever s "!r c K t wr= r{ r> s r) wait_closedzAbstractServer.wait_closed s 8!!r c K | S wr= rU r> s r)
__aenter__zAbstractServer.__aenter__ s s c ` K | j | j d { y 7 wr= )r} r )r$ rN s r) __aexit__zAbstractServer.__aexit__ s!
s $.,.N) r1 rR rS r} r r r r r r r rU r+ r) r r s- 6""""""!r+ r c
e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z d
d d Z d
d d
Z
d
d dZd Zd Zd
d
ddZd
d dZd Zd ZddddddZdIdZ dJd
dddd
d
d
d
d
d
d
d dZ dJej2 ej4 d
d d
d
d
d
d
d d
d ZdKd d d!Z d"d
d
d
d#d$Z dLd
d
d
d
d
d%d&Z dLd
d d
d
d
d d'd(Z d
d
d
d)d*Z dJdddd
d
d
d
d+d,Z!d- Z"d. Z#e$jJ e$jJ e$jJ d/d0Z&e$jJ e$jJ e$jJ d/d1Z'd2 Z(d3 Z)d4 Z*d5 Z+d6 Z,d7 Z-d8 Z.dId9Z/d: Z0d; Z1d< Z2d= Z3dKd
d d>Z4d? Z5d@ Z6dA Z7dB Z8dC Z9dD Z:dE Z;dF Zy
)Mr c t r= r{ r> s r) run_foreverz AbstractEventLoop.run_forever 8!!r+ c t r= r{ )r$ futures r) run_until_completez$AbstractEventLoop.run_until_complete s "!r+ c t r= r{ r> s r) stopzAbstractEventLoop.stop s
"!r+ c t r= r{ r> s r)
is_runningz AbstractEventLoop.is_running r r+ c t r= r{ r> s r) is_closedzAbstractEventLoop.is_closed r r+ c t r= r{ r> s r) r} zAbstractEventLoop.close s "!r+ c K t wr= r{ r> s r) shutdown_asyncgensz$AbstractEventLoop.shutdown_asyncgens s :!!r c K t wr= r{ r> s r) shutdown_default_executorz+AbstractEventLoop.shutdown_default_executor s <!!r c t r= r{ )r$ rG s r) rv z)AbstractEventLoop._timer_handle_cancelled r r+ N)r( c 0 | j d|g|d|iS )Nr r( )
call_laterr$ r% r( r& s r) call_soonzAbstractEventLoop.call_soon s tq(CTC7CCr+ c t r= r{ )r$ delayr% r( r& s r) r z AbstractEventLoop.call_later !!r+ c t r= r{ )r$ r[ r% r( r& s r) call_atzAbstractEventLoop.call_at r r+ c t r= r{ r> s r) timezAbstractEventLoop.time r r+ c t r= r{ r> s r)
create_futurez AbstractEventLoop.create_future r r+ )namer( c t r= r{ )r$ coror r( s r) create_taskz AbstractEventLoop.create_task r r+ c t r= r{ r s r) call_soon_threadsafez&AbstractEventLoop.call_soon_threadsafe" r r+ c t r= r{ )r$ executorfuncr& s r) run_in_executorz!AbstractEventLoop.run_in_executor% r r+ c t r= r{ )r$ r s r) set_default_executorz&AbstractEventLoop.set_default_executor( r r+ r )familytypeprotoflagsc K t wr= r{ )r$ hostportr r r r s r) getaddrinfoz AbstractEventLoop.getaddrinfo- !! c K t wr= r{ )r$ sockaddrr s r) getnameinfoz AbstractEventLoop.getnameinfo1 !!r ) sslr r r sock
local_addrserver_hostnamessl_handshake_timeoutssl_shutdown_timeouthappy_eyeballs_delay
interleavec K t wr= r{ )r$ protocol_factoryr r r r r r r r r r r r r s r) create_connectionz#AbstractEventLoop.create_connection4 s "!r d T)
r r r backlogr
reuse_address
reuse_portr r r c
K t wr= r{ )r$ r r r r r r r r r r r r r s r)
create_serverz AbstractEventLoop.create_server> s / ` "!r )fallbackc K t wr= r{ )r$ transportfileoffsetcountr s r) sendfilezAbstractEventLoop.sendfilex s "!r F) server_sider r r c K t wr= r{ )r$ r protocol
sslcontextr r r r s r) start_tlszAbstractEventLoop.start_tls s
"!r )r r r r r c K t wr= r{ )r$ r pathr r r r r s r) create_unix_connectionz(AbstractEventLoop.create_unix_connection s "!r )r r r r r r c K t wr= r{ ) r$ r r r r r r r r s r) create_unix_serverz$AbstractEventLoop.create_unix_server s 8 "!r )r r r c K t wr= r{ )r$ r r r r r s r) connect_accepted_socketz)AbstractEventLoop.connect_accepted_socket s
"!r )r r r r r allow_broadcastr c K t wr= r{ ) r$ r r remote_addrr r r r r r r s r) create_datagram_endpointz*AbstractEventLoop.create_datagram_endpoint s
8 "!r c K t wr= r{ r$ r pipes r) connect_read_pipez#AbstractEventLoop.connect_read_pipe s $ "!r c K t wr= r{ r s r) connect_write_pipez$AbstractEventLoop.connect_write_pipe s % "!r )stdinstdoutstderrc K t wr= r{ )r$ r cmdr r r kwargss r) subprocess_shellz"AbstractEventLoop.subprocess_shell
"!r c K t wr= r{ )r$ r r r r r& r s r) subprocess_execz!AbstractEventLoop.subprocess_exec
r r c t r= r{ r$ fdr% r& s r)
add_readerz AbstractEventLoop.add_reader r r+ c t r= r{ r$ r s r)
remove_readerz AbstractEventLoop.remove_reader r r+ c t r= r{ r s r)
add_writerz AbstractEventLoop.add_writer r r+ c t r= r{ r s r)
remove_writerz AbstractEventLoop.remove_writer" r r+ c K t wr= r{ )r$ r nbytess r) sock_recvzAbstractEventLoop.sock_recv' r r c K t wr= r{ )r$ r bufs r) sock_recv_intoz AbstractEventLoop.sock_recv_into* r r c K t wr= r{ )r$ r bufsizes r)
sock_recvfromz AbstractEventLoop.sock_recvfrom- r r c K t wr= r{ )r$ r r r s r) sock_recvfrom_intoz$AbstractEventLoop.sock_recvfrom_into0 r r c K t wr= r{ )r$ r datas r) sock_sendallz AbstractEventLoop.sock_sendall3 r r c K t wr= r{ )r$ r r addresss r) sock_sendtoz AbstractEventLoop.sock_sendto6 r r c K t wr= r{ )r$ r r s r) sock_connectz AbstractEventLoop.sock_connect9 r r c K t wr= r{ )r$ r s r) sock_acceptz AbstractEventLoop.sock_accept< r r c K t wr= r{ )r$ r r r r r s r)
sock_sendfilez AbstractEventLoop.sock_sendfile? r r c t r= r{ )r$ sigr% r& s r) add_signal_handlerz$AbstractEventLoop.add_signal_handlerE r r+ c t r= r{ )r$ r# s r) remove_signal_handlerz'AbstractEventLoop.remove_signal_handlerH r r+ c t r= r{ )r$ factorys r) set_task_factoryz"AbstractEventLoop.set_task_factoryM r r+ c t r= r{ r> s r) get_task_factoryz"AbstractEventLoop.get_task_factoryP r r+ c t r= r{ r> s r) get_exception_handlerz'AbstractEventLoop.get_exception_handlerU r r+ c t r= r{ )r$ handlers r) set_exception_handlerz'AbstractEventLoop.set_exception_handlerX r r+ c t r= r{ r$ r( s r) default_exception_handlerz+AbstractEventLoop.default_exception_handler[ r r+ c t r= r{ r2 s r) rM z(AbstractEventLoop.call_exception_handler^ r r+ c t r= r{ r> s r) r zAbstractEventLoop.get_debugc r r+ c t r= r{ )r$ enableds r) set_debugzAbstractEventLoop.set_debugf r r+ )r NN)r Nr= )?r1 rR rS r r r r r r} r r rv r r r r r r r r r r r r socket AF_UNSPEC
AI_PASSIVEr r r r r r r r r
subprocessPIPEr r r r r r
r
r r r r r r r r! r$ r& r) r+ r- r0 r3 rM r r8 rU r+ r) r r s? """"" """ " 26 D :> " 6: """
)-d "
=A """ "#!1"" 59"$4 "&!%!%$" 598" &&##$DT"&!% 8"t"#'" %*(,.2-1
" *."4 "&!% " *.""s"&!% ""L "&!%
" EI!"./q59d7;$ !"J " " &0__&0oo&0oo" %/OO%/__%/__"""""
"""""""""(," ""
""
""""
""r+ r c , e Zd Z d Zd Zd Zd Zd Zy)r c t r= r{ r> s r) r z&AbstractEventLoopPolicy.get_event_loopm s ( "!r+ c t r= r{ r$ r' s r) r
z&AbstractEventLoopPolicy.set_event_loopw r r+ c t r= r{ r> s r) r z&AbstractEventLoopPolicy.new_event_loop{ s J "!r+ c t r= r{ r> s r) r z)AbstractEventLoopPolicy.get_child_watcher s .!!r+ c t r= r{ )r$ watchers r) r
z)AbstractEventLoopPolicy.set_child_watcher s 2!!r+ N)r1 rR rS r r
r r r
rU r+ r) r r j s 7"""""r+ r c T e Zd Z dZ G d dej
Zd Zd Zd Z d Z
y)BaseDefaultEventLoopPolicyNc e Zd ZdZdZy)!BaseDefaultEventLoopPolicy._LocalNF)r1 rR rS r _set_calledrU r+ r) _LocalrJ s r+ rL c . | j | _ y r= )rL _localr> s r) r* z#BaseDefaultEventLoopPolicy.__init__ s kkm r+ c | j j | j j st j t j
u rd} t
j d }|rG|j j d }|dk( s|j d sn|j }|dz
}|rF dd l
}|j dt | | j! | j# | j j *t% d t j j& z | j j S # t $ r Y w xY w)
Nr] r r1 asynciozasyncio.r z There is no current event loop)
stacklevelz,There is no current event loop in thread %r.)rN r rK threadingcurrent_thread main_threadr" r# f_globalsget
startswithf_backAttributeErrorwarningswarnDeprecationWarningr
r RuntimeErrorr )r$ rQ fmodulerZ s r) r z)BaseDefaultEventLoopPolicy.get_event_loop s4
KK %KK++((*i.C.C.EEJ
$MM!$ [[__Z 8F "i /63D3DZ3P A !OJ
MM:,
E 3 3 5 6 ;; $ M!*!9!9!;!@!@ A B
B {{ ) "
s E EEc d| j _ |2t |t s"t dt | j d || j _ y )NTz s r) r z)BaseDefaultEventLoopPolicy.new_event_loop s
!!##r+ ) r1 rR rS rd rR localrL r* r r
r rU r+ r) rH rH s3
M $ !B!$r+ rH c e Zd ZdZy) _RunningLoopr9 N)r1 rR rS loop_pidrU r+ r) rg rg s Hr+ rg c 6 t } | t d | S )Nzno running event loop)r r] r' s r) r r s'
D |233 Kr+ c d t j \ } }| |t j k( r| S y y r= )
_running_looprh osgetpid) running_looppids r) r r s: &..L# C299;$6 %7 r+ c D | t j ft _ y r= )rm rn rl rh rj s r) r r s #BIIK 0Mr+ c ` t 5 t
ddlm} | ad d d y # 1 sw Y y xY w)Nr DefaultEventLoopPolicy)_lock_event_loop_policy rt rs s r) _init_event_loop_policyrx s! % 0!7!9
s $-c 0 t
t t S r= )rv rx rU r+ r) r r s ,! ! r+ c r | 2t | t s"t dt | j d | ay )NzDpolicy must be an instance of AbstractEventLoopPolicy or None, not 'ra )re r rb r r1 rv )policys r) r r sC : *V5L"M^_cdj_k_t_t^uuvwxx r+ c P t } | | S t j S r= )r r r ) current_loops r) r r s/ %&L " 1 1 33r+ c 8 t j | y r= )r r
rj s r) r
r
0 s M**40r+ c 4 t j S r= )r r rU r+ r) r r 5 s I " 1 1 33r+ c 4 t j S r= )r r rU r+ r) r r : s L " 4 4 66r+ c 6 t j | S r= )r r
)rF s r) r
r
? s ; " 4 4W ==r+ )r r r r forkc t t j t _ t d t j d y )Nr. )rv rH rL rN r signal
set_wakeup_fdrU r+ r) on_forkr ] s0 )(B(I(I(K %$ R r+ )after_in_child).__all__r rm r r: r= r" rR rw r r r r r r rH rv Lockru re rg rl r r r rx r r r r
r r r
_py__get_running_loop_py__set_running_loop_py_get_running_loop_py_get_event_loop_asyncio_c__get_running_loop_c__set_running_loop_c_get_running_loop_c_get_event_loop ImportErrorhasattrr register_at_forkrU r+ r) r s] '
J JZ<& <~'! '!TT" T"n " "DD$!8 D$V 9??
1:
4 1
4
7
> * ) ' #
'< < -,*& 2v! Bw/ s = C2 2C:9C: