v * d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ ej dk rd dlm
Z
nd dl m
Z
ej dk rdd
Z ndd Z d Z
d
Zdee d dfdZdee d dfdZ G d dej Ze
G d d ZdS ) N)
TracebackType)OptionalType) )final)r taskasyncio.Task[object]returnc . | d S N)uncancelr
s v/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/async_timeout/__init__.py_uncancel_taskr s
c d S r r s r r r s r z4.0.3)timeout
timeout_atTimeoutdelayr c t j }| | | z }nd}t || S )ar timeout 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 timeout(0.001):
... async with aiohttp.get('https://github.com') as r:
... await r.text()
delay - value in seconds or None to disable timeout logic
N)asyncioget_running_looptimer )r loopdeadlines r r r sA # % %D 99;;& 8T " ""r r c H t j }t | | S )a Schedule the timeout at absolute time.
deadline argument points on the 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 timeout_at(loop.time() + 10):
... async with aiohttp.get('https://github.com') as r:
... await r.text()
)r r r )r r s r r r 5 s" # % %D 8T " ""r c e Zd ZdZdZdZdZdS )_StateINITENTERTIMEOUTEXITN)__name__
__module__ __qualname__r# r$ r% r& r r r r" r" H s" D EG DDDr r" c e Zd ZdZdee dej ddfdZddZ dee
e d ee d
ee dee
fd Zdd Zdee
e d ee d
ee dee
fd
Zede
fd Zedee fd ZddZddZdeddfdZdeddfdZddZddZdee
e ddfdZddZdS )r ) _deadline_loop_state_timeout_handler_taskr r r Nc || _ t j | _ d | _ d | _ | d | _ d S | | d S r )r, r" r# r- r/ r. r+ update)selfr r s r __init__zTimeout.__init__d sL
k 7;
$ !DNNN KK ! ! ! ! !r c f t j dt d | | S )Nz>with timeout() is deprecated, use async with timeout() instead )
stacklevel)warningswarnDeprecationWarning _do_enterr2 s r __enter__zTimeout.__enter__q s;
L
r exc_typeexc_valexc_tbc 0 | | d S r _do_exitr2 r= r> r? s r __exit__zTimeout.__exit__z s
h tr c 2 K | | S r )r: r; s r
__aenter__zTimeout.__aenter__ s r c 4 K | | d S r rA rC s r __aexit__zTimeout.__aexit__ s
h tr c , | j t j k S )z$Is timeout expired during execution?)r- r" r% r; s r expiredzTimeout.expired s {fn,,r c | j S r )r+ r; s r r zTimeout.deadline s
~ r c | j t j t j fvr t d| j j | dS )z Reject scheduled timeout if any.invalid state N)r- r" r# r$ RuntimeErrorvalue_rejectr; s r rejectzTimeout.reject sG ;v{FL 9 9 9 C 0A C CDD D r c f d | _ | j "| j d | _ d S d S r )r/ r. cancelr; s r rP zTimeout._reject s=
, ! ( ( * * *$(D ! ! ! - ,r r c f | j }|t d | ||z dS )zAdvance timeout on delay seconds.
The delay can be negative.
Raise RuntimeError if shift is called when deadline is not scheduled
Nz1cannot shift timeout if deadline is not scheduled)r+ rN r1 )r2 r r s r shiftz
Timeout.shift s= > RSS S Hu$%%%%%r c : | j t j k rt d | j t j k rt d | j | j || _ | j t j k r| dS dS )aT Set deadline to absolute value.
deadline argument points on the time in the same clock system
as loop.time().
If new deadline is in the past the timeout is raised immediately.
Please note: it is not POSIX time but a time with
undefined starting base, e.g. the time of the system power on.
z1cannot reschedule after exit from context managerz!cannot reschedule expired timeoutN)
r- r" r& rN r% r. rS r+ r# _reschedule)r2 r s r r1 zTimeout.update s ;&+ % % RSS S ;&. ( ( BCC C , ! ( ( * * *! ;&+ % % & %r c | j t j k sJ | j }|d S | j }| j | j t j | _
||k r&| j | j | _ d S | j
|| j | _ d S r )r- r" r$ r+ r, r r. rS r current_taskr/ call_soon _on_timeoutcall_at)r2 r nows r rW zTimeout._reschedule s {fl****> Fjoo , ! ( ( * * * )++
s??$(J$8$89I$J$JD ! ! !$(J$6$6xAQ$R$RD ! ! !r c | j t j k r t d| j j t j | _ | d S )NrM )r- r" r# rN rO r$ rW r; s r r: zTimeout._do_enter sN ;&+ % % C 0A C CDD D l r c |t j u rL| j t j k r7| j J t
| j d | _ d | _ t j t j | _ |
d S r ) r CancelledErrorr- r" r% r/ r r. TimeoutErrorr& rP )r2 r= s r rB zTimeout._do_exit so w- - -$+ 2O2O:))) 4: & & &$(D ! DJ& & k tr c z | j J | j t j | _ d | _ d S r )r/ rS r" r% r- r. r; s r r[ zTimeout._on_timeout s; z%%%
n $ r )r r )r N) r' r( r) __slots__r floatr AbstractEventLoopr3 r< r
BaseExceptionr boolrD rF rH propertyrJ r rQ rP rU r1 rW r: rB r[ r r r r r O sE & NI " "/6/H "
" " " " 4
./ -( '
$ 4
./ -( '
$ - - - - X- (5/ X ) ) ) )
&5
&T
&
&
&
& u *S S S S
$}*=!>
4
% % % % % %r )r
r r N)r enumsysr7 typesr typingr r version_infor typing_extensionsr __version____all__rd r r Enumr" r r r r rr s
! ! ! ! ! ! ! ! v '''''' w
/#8E? #y # # # #*#% #Y # # # #& TY _% _% _% _% _% _% _% _% _% _%r