!A?h d dl Z d dlmZ d dlmZmZmZ ddlmZ ddlm Z ddlm
Z
dZ G d d
e j Z
e G d d Zd
ee defdZdee defdZdS ) N)
TracebackType)finalOptionalType )events)
exceptions)tasks)Timeouttimeout
timeout_atc " e Zd ZdZdZdZdZdZdS )_StatecreatedactiveexpiringexpiredfinishedN)__name__
__module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITED =/opt/alt/python-internal/lib64/python3.11/asyncio/timeouts.pyr r s' GGHG
FFFr r c e Zd Z dee ddfdZdee fdZdee ddfdZdefdZ de
fdZ dd Z d
ee
e d ee d ee dee fd
ZddZdS )r whenreturnNc T t j | _ d | _ d | _ || _ d S N)r r _state_timeout_handler_task_when)selfr! s r __init__zTimeout.__init__! s, n >B +/
r c | j S r$ )r( r) s r r! z Timeout.when. s
*zr c | j t j ur?| j t j u rt d t d| j j d || _ | j | j | d | _ d S t j
}|| k r!| | j
| _ d S | || j
| _ d S )Nz Timeout has not been enteredzCannot change state of z Timeout)r% r r r RuntimeErrorvaluer( r& cancelr get_running_looptime call_soon _on_timeoutcall_at)r) r! loops r
reschedulezTimeout.reschedule2 s % ;fn , ,{fn,,"#ABBB E$+*;EEE
, ! ( ( * * * <$(D ! ! !*,,Dtyy{{""(,t7G(H(H%%%(, T4;K(L(L%%%r c B | j t j t j fv S r$ )r% r r r r, s r r zTimeout.expiredI s 2{v ???r c dg}| j t j u r6| j t | j d nd }| d| d | }d| j j d| dS )N zwhen= z
<Timeout []>)r% r r r( roundappendjoinr/ )r) infor! info_strs r __repr__zTimeout.__repr__M sz t ;&. ( (+/:+A5Q'''tD KK ' ' '88D>>;DK -;;;;;;r c 6 K | j t j urt d t j }|t d t j | _ || _ | j | _ |
| j | S )Nz Timeout has already been enteredz$Timeout should be used inside a task) r% r r r. r
current_taskr r'
cancelling _cancellingr7 r( )r) tasks r
__aenter__zTimeout.__aenter__U s ;fn , , ABB B!## < EFF F n
:0022
### r exc_typeexc_valexc_tbc Z K | j | j d | _ | j t j u rJt j | _ | j | j k r|t j
u rt |n$| j t j u rt j
| _ d S r$ )r& r0 r% r r r r' uncancelrH r CancelledError TimeoutErrorr r )r) rK rL rM s r __aexit__zTimeout.__aexit__a s , ! ( ( * * *$(D ! ;&/ ) ) .DKz""$$(888XIb=b=b #/
[FN
*
* -DKtr c h | j t j | _ d | _ d S r$ )r' r0 r r r% r& r, s r r4 zTimeout._on_timeouty s-
o $ r )r" r )r" N)r r r r floatr* r! r7 boolr strrD rJ r
BaseExceptionr rR r4 r r r r r s?
Xe_ huo Mx M4 M M M M.@ @ @ @ @<# < < < <
4
./ -( '
$ 0% % % % % %r r delayr" c z t j }t | | | z nd S r$ )r r1 r r2 )rX r6 s r r r s< " $ $D %*;499;;&& F FFr r! c " t | S r$ )r )r! s r r
r
s $ 4==r )enumtypesr typingr r r r: r r r
__all__Enumr r rT r r
r r r <module>r` s@ ( ( ( ( ( ( ( ( ( ( TY c% c% c% c% c% c% c% c%LG8E? Gw G G G G(Xe_ r