{|j> d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm
Z
ddlm Z G d d
ej Z
G d d Zddd
dZd Zy))Runnerrun N )
coroutines)events)
exceptions)tasks) constantsc e Zd ZdZdZdZy)_Statecreated initializedclosedN)__name__
__module__ __qualname__CREATED INITIALIZEDCLOSED (/usr/lib64/python3.12/asyncio/runners.pyr r s G K
Fr r c L e Zd Z ddddZd Zd Zd Zd Zddd Zd
Z d Z
y) r Ndebug loop_factoryc t j | _ || _ || _ d | _ d | _ d| _ d| _ y )Nr F) r r _state_debug
_loop_factory_loop_context_interrupt_count_set_event_loop)selfr r s r __init__zRunner.__init__0 s: nn )
! $ r c & | j | S N)
_lazy_initr% s r __enter__zRunner.__enter__9 s r c $ | j y r( )close)r% exc_typeexc_valexc_tbs r __exit__zRunner.__exit__= s
r c H | j t j ury | j }t | |j |j
|j |j t j | j rt j d |j d | _ t j | _ y # | j rt j d j d | _ t j | _ w xY wr( )r r r r! _cancel_all_tasksrun_until_completeshutdown_asyncgensshutdown_default_executorr
THREAD_JOIN_TIMEOUTr$ r set_event_loopr- r )r% loops r r- z Runner.close@ s , ;;f 0 0 0 (::D d # # #D$;$;$= > # #..y/L/LM
O ##%%d+ JJL DJ --DK ##%%d+ JJL DJ --DKs
A$C AD!c < | j | j S r( )r) r! r* s r get_loopzRunner.get_loopQ s ) zzr contextc t j | st dj | t j
t
d | j | | j }| j j || }t j t j u rzt j t j t j" u rGt% j& | j( | } t j t j | nd }d| _ | j j- | |Yt j t j |u r3t j t j t j" S S S # t $ r d }Y w xY w# t. j0 $ r4 | j* dkD r#t3 |dd }| | dk( r
t5 w xY w# |Yt j t j |u r3t j t j t j" w w w xY w)Nz"a coroutine was expected, got {!r}z7Runner.run() cannot be called from a running event loopr< ) main_taskr uncancel)r iscoroutine
ValueErrorformatr _get_running_loop RuntimeErrorr) r" r! create_task threadingcurrent_thread main_threadsignal getsignalSIGINTdefault_int_handler functoolspartial
_on_sigintr# r4 r CancelledErrorgetattrKeyboardInterrupt)r% coror= tasksigint_handlerr@ s r r z
Runner.runV s =%%d+ A H H NO O # # % 1 IK
K
?mmGzz%%dG%< $ $ &)*?*?*A A /63M3MM & . .t$ ON
&
fmm^< "N ! I::006 *$$V]]3~E
fmmV-G-GH F +%
& "&
& (( $$q("4T:'HJ!O+-- *$$V]]3~E
fmmV-G-GH F +s, $F- 7F> - F;:F;>AHH A I%c $ | j t j u r t d | j t j u ry | j
Lt
j | _ | j s