iddlmZddlZddlmZmZmZddlmZdZ Gddej Z Gdd Z dd Z dS)) annotationsN)CancelledErroreventstasks) TracebackType)Timeouttimeoutc"eZdZdZdZdZdZdZdS)_StatecreatedactiveexpiringexpiredfinishedN)__name__ __module__ __qualname__CREATEDENTEREDEXPIRINGEXPIREDEXITED^/root/projects/butler/venv/lib/python3.11/site-packages/urllib3_future/contrib/ssa/_timeout.pyr r s'GGHG FFFrr cReZdZdZddZddZddZdd Zdd ZddZ ddZ ddZ dS)rzAsynchronous context manager for cancelling overdue coroutines. Use `timeout()` or `timeout_at()` rather than instantiating this class directly. when float | NonereturnNonecRtj|_d|_d|_||_dS)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)selfrs r__init__zTimeout.__init__s'n KO(,  rc|jS)zReturn the current deadline.)r%r&s rrz Timeout.when(s zrc|jtjur?|jtjurt dt d|jjd||_|j|j| d|_dStj }|| kr!| |j |_dS|||j |_dS)zReschedule the timeout.zTimeout has not been enteredzCannot change state of z TimeoutN)r"r rr RuntimeErrorvaluer%r#cancelrget_running_looptime call_soon _on_timeoutcall_at)r&rloops r reschedulezTimeout.reschedule,s ;fn , ,{fn,,"#ABBBE$+*;EEE   ,  ! ( ( * * * <$(D ! ! !*,,Dtyy{{""(,t7G(H(H%%%(, T4;K(L(L%%%rboolc@|jtjtjfvS)z$Is timeout expired during execution?)r"r rrr)s rrzTimeout.expiredCs{v???rstrcdg}|jtjur6|jt |jdnd}|d|d|}d|jjd|dS)Nzwhen= z )r"r rr%roundappendjoinr,)r&inforinfo_strs r__repr__zTimeout.__repr__Gszt ;&. ( (+/:+A5Q'''tD KK ' ' '88D>>;DK-;;;;;;r 'Timeout'cK|jtjurtdt j}|tdtj|_||_||j |S)Nz Timeout has already been enteredz$Timeout should be used inside a task) r"r rr+r current_taskrr$r4r%)r&tasks r __aenter__zTimeout.__aenter__Oso ;fn , ,ABB B!## <EFF Fn    ### rexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonec`K|jtjtjfvsJ|jJ|j |jd|_|jtjur#tj|_|turt|n$|jtjurtj |_dSN) r"r rrr$r#r-rr TimeoutErrorr)r&rIrKrMs r __aexit__zTimeout.__aexit__Zs {v~v?????z%%%  ,  ! ( ( * * *$(D ! ;&/ ) ) .DK>))#/*[FN * * -DKtrc|jtjusJ|jJ|jtj|_d|_dSrP)r"r rr$r-rr#r)s rr1zTimeout._on_timeoutssP{fn,,,,z%%% o $rN)rrrr )rr)rr5)rr7)rrD)rIrJrKrLrMrNrr )rr ) rrr__doc__r'rr4rrCrHrRr1rrrrrs    MMMM.@@@@<<<<    2%%%%%%rrdelayrrcxtj}t|||zndS)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)rr.rr/)rUr3s rr r }s7  " $ $D %*;499;;&& F FFr)rUrrr) __future__renumasynciorrrtypesr__all__Enumr rr rrrr]s"""""" 1111111111  TYe%e%e%e%e%e%e%e%PGGGGGGr