python (3.12.0)
ˑe
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 defdZy) N)
TracebackType)finalOptionalType )events)
exceptions)tasks)Timeouttimeout
timeout_atc e Zd ZdZdZdZdZdZy)_StatecreatedactiveexpiringexpiredfinishedN)__name__
__module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITED D/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/asyncio/timeouts.pyr r s GGHG
Fr r c e Zd ZdZdee ddfdZdee fdZdee ddfdZde fdZ
de fd Z dd
Z
d eee d ee d
ee dee fdZddZy)r zAsynchronous context manager for cancelling overdue coroutines.
Use `timeout()` or `timeout_at()` rather than instantiating this class directly.
whenreturnNc X t j | _ d| _ d| _ || _ y)zSchedule a timeout that will trigger at a given loop time.
- If `when` is `None`, the timeout will never trigger.
- If `when < loop.time()`, the timeout will trigger on the next
iteration of the event loop.
N)r r _state_timeout_handler_task_when)selfr! s r __init__zTimeout.__init__! s% nn >B +/
r c | j S )z Return the current deadline.)r' r( s r r! z Timeout.when. s zzr c | j t j usJ | j t j ur#t d| j j
d || _ | j | j j |d| _ yt j }||j k r!|j | j | _ y|j || j | _ y)zReschedule the timeout.zCannot change state of z TimeoutN)r$ r r r RuntimeErrorvaluer' r% cancelr get_running_looptime call_soon _on_timeoutcall_at)r( r! loops r
reschedulezTimeout.reschedule2 s {{&..00 ;;fnn , )$++*;*;)<HE
, ! ! ( ( * <$(D !**,Dtyy{"(,t7G7G(H%(, T4;K;K(L%r c Z | j t j t j fv S )z$Is timeout expired during execution?)r$ r r r r+ s r r zTimeout.expiredH s {{v ???r c dg}| j t j u r8| j t | j d nd }|j d| dj
| }d| j j d| dS )N zwhen= z
<Timeout []>)r$ r r r' roundappendjoinr. )r( infor! info_strs r __repr__zTimeout.__repr__L ss t ;;&.. (+/::+A5Q'tD KK%v '88D>DKK - -.az;;r c K t j | _ t j | _ | j
j
| _ | j
t d | j | j | S w)Nz$Timeout should be used inside a task) r r r$ r
current_taskr&
cancelling _cancellingr- r6 r' r+ s r
__aenter__zTimeout.__aenter__T sa nn '')
::002 :: EF F
# s BBexc_typeexc_valexc_tbc K | j t j t j fv sJ | j !| j j d | _ | j t j u rVt j | _ | j j | j k r|t j u rt |y | j t j u rt j | _ y wN)r$ r r r r% r/ r r& uncancelrG r CancelledError TimeoutErrorr )r( rI rJ rK s r __aexit__zTimeout.__aexit__] s {{v~~v ??? , ! ! ( ( *$(D ! ;;&// ) ..DKzz""$(8(88XIbIb=b #/ [[FNN
* --DKs D Dc | j t j u sJ | j j t j
| _ d | _ y rM )r$ r r r& r/ r r% r+ s r r3 zTimeout._on_timeoutu s8 {{fnn,,
oo $ r )r" r )r" N)r r r __doc__r floatr) r! r6 boolr strrC rH r
BaseExceptionr rQ r3 r r r r r s
Xe_ huo Mx M4 M,@ @<# <4
./ -( '
$ 0%r r delayr" c r t j }t | |j | z S d S )a Timeout async context manager.
Useful in cases when you want to apply timeout logic around block
of code or in cases when asyncio.wait_for is not suitable. For example:
>>> async with asyncio.timeout(10): # 10 seconds timeout
... await long_running_task()
delay - value in seconds or None to disable timeout logic
long_running_task() is interrupted by raising asyncio.CancelledError,
the top-most affected timeout() context manager converts CancelledError
into TimeoutError.
N)r r0 r r1 )rX r5 s r r r } s5 " " $D %*;499;& FF FFr r! c t | S )ab Schedule the timeout at absolute time.
Like timeout() but argument gives absolute time in the same clock system
as loop.time().
Please note: it is not POSIX time but a time with
undefined starting base, e.g. the time of the system power on.
>>> async with asyncio.timeout_at(loop.time() + 10):
... await long_running_task()
when - a deadline when timeout occurs or None to disable timeout logic
long_running_task() is interrupted by raising asyncio.CancelledError,
the top-most affected timeout() context manager converts CancelledError
into TimeoutError.
)r )r! s r r
r
s & 4=r )enumtypesr typingr r r r9 r r r
__all__Enumr r rT r r
r r r <module>r` s ( ( TYY _% _% _%DG8E? Gw G(Xe_ r 
Browse
Usage
Versions