^j$dZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z e rddlmZmZdd lmZdd lmZe d Ze d ZGd dZGddZddgZy)zIAsync wrapper around :class:`SoftReadWriteLock` for use with ``asyncio``.) annotationsN)asynccontextmanager) TYPE_CHECKING ParamSpecTypeVar)SoftReadWriteLock)AsyncGeneratorCallable)futures) TracebackType_P_Rc @eZdZdZ ddddddddd ddZeddZedd Zedd Zedd Z edd Z e ddd d dZ e ddd d dZ ddd  d!dZ ddd  d!dZddd"dZd#dZd#dZd$dZy)%AsyncSoftReadWriteLocka Async wrapper around :class:`SoftReadWriteLock` for ``asyncio`` applications. The sync class's blocking filesystem operations run on a thread pool via ``loop.run_in_executor()``. The underlying :class:`SoftReadWriteLock` handles reentrancy, upgrade/downgrade rules, fork handling, heartbeat and TTL stale detection, and singleton behavior. :param lock_file: path to the lock file; sidecar state/write/readers live next to it :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately on contention :param is_singleton: if ``True``, reuse existing :class:`SoftReadWriteLock` instances per resolved path :param heartbeat_interval: seconds between heartbeat refreshes; default 30 s :param stale_threshold: seconds of mtime inactivity before a marker is stale; defaults to ``3 * heartbeat_interval`` :param poll_interval: seconds between acquire retries under contention; default 0.25 s :param loop: event loop for ``run_in_executor``; ``None`` uses the running loop :param executor: executor for ``run_in_executor``; ``None`` uses the default executor .. versionadded:: 3.27.0 Tg>@Ng?)blocking is_singletonheartbeat_intervalstale_threshold poll_intervalloopexecutorc tj|_t||||||||_||_| |_y)N)rrrrr)osgetpid _creator_pidr _lock_loop _executor) self lock_filetimeoutrrrrrrrs c/var/www/ramen.bs-engineer-server.com/venv/lib/python3.12/site-packages/filelock/_soft_rw/_async.py__init__zAsyncSoftReadWriteLock.__init__,sCIIK&  %1+'   !c.|jjS)z4The path to the lock file passed to the constructor.)rr!r s r#r!z AsyncSoftReadWriteLock.lock_fileFszz###r%c.|jjS)z\The default timeout applied when ``acquire_read`` / ``acquire_write`` is called without one.)rr"r's r#r"zAsyncSoftReadWriteLock.timeoutKszz!!!r%c.|jjS)zYWhether ``acquire_*`` defaults to blocking; ``False`` makes contention raise immediately.)rrr's r#rzAsyncSoftReadWriteLock.blockingPszz"""r%c|jS)zNThe event loop used for ``run_in_executor``, or ``None`` for the running loop.)rr's r#rzAsyncSoftReadWriteLock.loopUszzr%c|jS)zPThe executor used for ``run_in_executor``, or ``None`` for the default executor.)rr's r#rzAsyncSoftReadWriteLock.executorZs~~r%rcK|j||d{ d|jd{y7#7#|jd{7wxYww)a Async context manager that acquires and releases a shared read lock. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds r,N) acquire_readreleaser r"rs r# read_lockz AsyncSoftReadWriteLock.read_lock_sR(;;; ! ,,. < !$,,. >A=AAA?AAAAAAcK|j||d{ d|jd{y7#7#|jd{7wxYww)a Async context manager that acquires and releases an exclusive write lock. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds r,N) acquire_writer/r0s r# write_lockz!AsyncSoftReadWriteLock.write_lockqsR  8 <<< ! ,,. = !$,,. r2cK|j|j|jj||d{t |S7w)a. Acquire a shared read lock. See :meth:`SoftReadWriteLock.acquire_read` for reentrancy / upgrade / fork semantics. The blocking work runs inside ``run_in_executor`` so other coroutines on the same loop keep progressing while this call waits. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default :returns: a proxy usable as an async context manager to release the lock :raises RuntimeError: if a write lock is already held, if this instance was invalidated by :func:`os.fork`, or if :meth:`close` was called :raises Timeout: if the lock cannot be acquired within *timeout* seconds r,Nlock)_raise_if_inherited_runrr.$AsyncAcquireSoftReadWriteReturnProxyr0s r#r.z#AsyncSoftReadWriteLock.acquire_readsG&   "ii //8iLLL3>> M> Nr<FforcecK|jtjk(r0|j|jj |d{yy7w)z Release one level of the current lock. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` r>N)rrrr:rr/)r r?s r#r/zAsyncSoftReadWriteLock.releasesD    +))DJJ..e)< < < ,    +))DJJ,,- - - , -sA A A Ac||jtjk7rd|jd}t |y)NzAsyncSoftReadWriteLock on z4 was inherited across fork; construct a new instance)rrrr! RuntimeError)r msgs r#r9z*AsyncSoftReadWriteLock._raise_if_inheriteds:    +.t~~.>>rsCs# # ,r%cK|jxstj}|j|jt j |g|i|d{S7wN)rasyncioget_running_looprun_in_executorr functoolspartial)r funcargskwargsrs r#r:zAsyncSoftReadWriteLock._runsQzz7W557))$..):K:KD:bSW:b[a:bccccsAA"A A"))r!zstr | os.PathLike[str]r"floatrboolrrRrrQr float | NonerrQr asyncio.AbstractEventLoop | Nonerfutures.Executor | NonereturnNone)rVstr)rVrQ)rVrR)rVrT)rVrUrG)r"rSr bool | NonerVzAsyncGenerator[None])r"rSrrYrVr;)r?rRrVrW)rVrW)rMzCallable[_P, _R]rNz_P.argsrOz _P.kwargsrVr)__name__ __module__ __qualname____doc__r$propertyr!r"rrrrr1r5r.r4r/rBr9r:r%r#rrs0" !$((,#15,0")""  "  """&""/"*" "4$$""##!W[!!"!X\!!$'+?GK?#?9D? -?0'+?GK?#?9D? -?..3 =. $ dr%rc8eZdZdZddZddZ ddZy) r;zTAsync context-aware object that releases an :class:`AsyncSoftReadWriteLock` on exit.c||_yrGr7)r r8s r#r$z-AsyncAcquireSoftReadWriteReturnProxy.__init__s  r%c"K|jSwrGr7r's r# __aenter__z/AsyncAcquireSoftReadWriteReturnProxy.__aenter__syys cTK|jjd{y7wrG)r8r/)r exc_type exc_value tracebacks r# __aexit__z.AsyncAcquireSoftReadWriteReturnProxy.__aexit__s ii!!!s (&(N)r8rrVrW)rVr)reztype[BaseException] | NonerfzBaseException | NonergzTracebackType | NonerVrW)rZr[r\r]r$rcrhr_r%r#r;r;s:^","("( "  "r%r;)r] __future__rrHrKr contextlibrtypingrrr_syncr collections.abcr r concurrentr typesr rrrr;__all__r_r%r#rqsfO" *44$8"#t_ T]sdsdl""&+ r%