o h#@sddlZddlZddlZddlmZddlmZmZmZdZ dZ dee ddfd d Z d ee ddfd d Z GdddejZejdkrXGdddZeGdddejZdSeGdddZdS)N) TracebackType)OptionalTypefinalz5.0.1)timeout timeout_atTimeoutdelayreturnrcCs,t}|dur||}nd}t||S)artimeout 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 loopdeadlinerj/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/async_timeout/__init__.pyrs   rrcCst}t||S)aSchedule 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)rrrrrr#s rc@seZdZdZdZdZdZdS)_StateINITENTERTIMEOUTEXITN)__name__ __module__ __qualname__rrrrrrrrr6s r) c@sZeZdZdZdeddfddZdefddZdefd d Zdefd d Z defd dZ dS)_Expired_valvalr NcCs ||_dSNr)selfrrrr__init__B z_Expired.__init__cC|jSr rr!rrr__call__Ez_Expired.__call__cCr$r rr%rrr__bool__Hr'z_Expired.__bool__cC t|jSr )reprrr%rrr__repr__Kr#z_Expired.__repr__cCr)r )strrr%rrr__str__Nr#z_Expired.__str__) rrr __slots__boolr"r&r(r,r+r-rrrrr?srcseZdZdeedejddffdd Zede ffdd Z edeefd d Z dd d Z d eddfddZ deddfddZZS)rrrr Ncst|dSr )superr"r!rr __class__rrr"VsTimeout.__init__csttSr )rr0expiredr%r2rrr5[sTimeout.expiredcCs|Sr )whenr%rrrrbsTimeout.deadlinecCs|ddS) Reject scheduled timeout if any.N rescheduler%rrrrejectfsTimeout.rejectr cCs*|}|dur td|||dSzAdvance 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)r7 RuntimeErrorr;r!r rrrrshiftls Timeout.shiftcCs||dS)lSet 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. Nr:r!rrrrupdatexs Timeout.updater N)rrrrfloatr AbstractEventLoopr"propertyrr5rr<rArE __classcell__rrr2rrQs  c @seZdZdZdeedejddfddZd$dd Z d ee e d ee d ee dee fd dZede fddZedeefddZd%ddZd%ddZdeddfddZdeddfddZd%ddZd%ddZd ee e ddfd d!Zd%d"d#ZdS)&r) _deadline_loop_state_timeout_handler_taskrrr NcCs:||_tj|_d|_d|_|durd|_dS||dSr )rMrrrNrPrOrLrEr1rrrr"s r4cs||Sr ) _do_enterr%rrr __aenter__szTimeout.__aenter__exc_typeexc_valexc_tbcs||dSr )_do_exit)r!rSrTrUrrr __aexit__s zTimeout.__aexit__cCs |jtjkS)z$Is timeout expired during execution?)rNrrr%rrrr5s r6cCr$r )rLr%rrrrsr8cCs0|jtjtjfvrtd|jj|dS)r9invalid state N)rNrrrr?value_rejectr%rrrr<s r=cCs(d|_|jdur|jd|_dSdSr )rPrOcancelr%rrrrZs    zTimeout._rejectr cCs(|j}|dur td|||dSr>)rLr?rEr@rrrrAsrBcCs^|jtjkr td|jtjkrtd|jdur|j||_|jtjkr-| dSdS)rCz1cannot reschedule after exit from context managerz!cannot reschedule expired timeoutN) rNrrr?rrOr[rLr _reschedulerDrrrrEs      rFcCs||jtjksJ|j}|durdS|j}|jdur |jt |_ ||kr3|j |j |_dS|j ||j |_dSr )rNrrrLrMr rOr[r current_taskrP call_soon _on_timeoutcall_at)r!rnowrrrr\s    zTimeout._reschedulecCs2|jtjkrtd|jjtj|_|dS)NrX)rNrrr?rYrr\r%rrrrQs  zTimeout._do_entercCsJ|tjur|jtjkr|jdusJd|_d|_tjtj|_| dSr ) r CancelledErrorrNrrrPrO TimeoutErrorrrZ)r!rSrrrrVszTimeout._do_exitcCs*|jdusJ|jtj|_d|_dSr )rPr[rrrNrOr%rrrr_s  zTimeout._on_timeout)r rrG)rrrr.rrHr rIr"rRr BaseExceptionrr/rWrJr5rr<rZrArEr\rQrVr_rrrrrs>         )r enumsystypesrtypingrrr __version____all__rHrrEnumr version_inforrrrrrs   5