dtj,dZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z mZmZmZmZmZddlmZe rdd lmZmZdd lmZdd lmZdd lmZe d Ze dZGddZ GddZ!ddgZ"dS)zIAsync wrapper around :class:`SoftReadWriteLock` for use with ``asyncio``.) annotationsN)asynccontextmanager) TYPE_CHECKING ParamSpecTypeVar)_BackendOutcome _capture_call _drain_future_future_result_raise_cancelled_error_wait_until_done)SoftReadWriteLock)AsyncGeneratorCallable)futures) TracebackType)AcquireReturnProxy_P_Rc BeZdZdZ d;ddddddddddZed?dZed@dZ edAdZ e dBdd dCd#Z e dBdd dCd$Z dBdd dDd&Z dBdd dDd'Zd(d)dEd+ZdFd,ZdFd-ZdGd0ZdHd8ZdId:ZdS)JAsyncSoftReadWriteLocka 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_intervalloopexecutor lock_filestr | os.PathLike[str]timeoutfloatrboolrrr float | Nonerr asyncio.AbstractEventLoop | Noner futures.Executor | NonereturnNonec tj|_t||||||||_||_| |_dS)N)rrrrr)osgetpid _creator_pidr_lock_loop _executor) selfr!r#rrrrrrr s V/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/filelock/_soft_rw/_async.py__init__zAsyncSoftReadWriteLock.__init__7sQIKK&  %1+'     !strc|jjS)z4The path to the lock file passed to the constructor.)r/r!r2s r3r!z AsyncSoftReadWriteLock.lock_fileQsz##r5c|jjS)z\The default timeout applied when ``acquire_read`` / ``acquire_write`` is called without one.)r/r#r8s r3r#zAsyncSoftReadWriteLock.timeoutVsz!!r5c|jjS)zYWhether ``acquire_*`` defaults to blocking; ``False`` makes contention raise immediately.)r/rr8s r3rzAsyncSoftReadWriteLock.blocking[sz""r5c|jS)zNThe event loop used for ``run_in_executor``, or ``None`` for the running loop.)r0r8s r3rzAsyncSoftReadWriteLock.loop`s zr5c|jS)zPThe executor used for ``run_in_executor``, or ``None`` for the default executor.)r1r8s r3r zAsyncSoftReadWriteLock.executores ~r5r bool | NoneAsyncGenerator[None]cK|||d{V dWV|d{VdS#|d{VwxYw)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_readreleaser2r#rs r3 read_lockz AsyncSoftReadWriteLock.read_lockjs(;;;;;;;;; ! EEEE,,.. $,,.. AAcK|||d{V dWV|d{VdS#|d{VwxYw)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_writerBrCs r3 write_lockz!AsyncSoftReadWriteLock.write_lock|s  8 <<<<<<<<< ! EEEE,,.. $,,.. rE$AsyncAcquireSoftReadWriteReturnProxycK||tj|jj||d{Vt |S)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 _run_acquire functoolspartialr/rArIrCs r3rAz#AsyncSoftReadWriteLock.acquire_readsi&   """ 1$*2I7]e f f fggggggggg3>>>>r5cK||tj|jj||d{Vt |S)a Acquire an exclusive write lock. See :meth:`SoftReadWriteLock.acquire_write` for the two-phase writer-preferring semantics. The blocking work runs inside ``run_in_executor``. :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 read lock is already held, if a write lock is held by a different thread, 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=NrK)rMrNrOrPr/rGrIrCs r3rGz$AsyncSoftReadWriteLock.acquire_writesi&   """ 1$*2JG^f g g ghhhhhhhhh3>>>>r5FforcerScK|jtjkr)||jj|d{VdSdS)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`` rRN)r.r,r-_runr/rB)r2rSs r3rBzAsyncSoftReadWriteLock.releasesW   + +))DJ.e)<< < < < < < < < < < , +r5cK|jtjkr'||jjd{VdSdS)zRRelease any held lock and release the underlying filesystem resources. Idempotent.N)r.r,r-rUr/closer8s r3rWzAsyncSoftReadWriteLock.closesQ   + +))DJ,-- - - - - - - - - - , +r5cr|jtjkrd|jd}t |dS)NzAsyncSoftReadWriteLock on z4 was inherited across fork; construct a new instance)r.r,r-r! RuntimeError)r2msgs r3rMz*AsyncSoftReadWriteLock._raise_if_inheriteds>   + +st~sssCs## # , +r5acquire Callable[[], AcquireReturnProxy]cK||} t|d{Vn#tj$r} t |d{Vn'#t $r}t ||Yd}~nd}~wwxYw t ||jjd{Vn'#t $r}t ||Yd}~nd}~wwxYwd}~wwxYwt|dSN) _submitr asyncioCancelledErrorr BaseExceptionr r/rBr )r2r[acquire_future cancellationerrors r3rNz#AsyncSoftReadWriteLock._run_acquiresY g.. ">22 2 2 2 2 2 2 2 2%    <#N3333333333  < < <&|U;;;;;;;; < <#DLL1C$D$DEEEEEEEEEE  < < <&|U;;;;;;;; <   ~&&&&&sb/CAC A9A4/C4A99C=2B0/C0 C:C CCCCfuncCallable[_P, _R]args_P.argskwargs _P.kwargsrc K|j|g|Ri|} t|d{VnV#tj$rD} t |d{Vn'#t $r}t ||Yd}~nd}~wwxYwd}~wwxYwt|Sr^)r_r r`rar rbr r )r2rfrhrjfuturerdres r3rUzAsyncSoftReadWriteLock._runsd4T444V44 "6** * * * * * * * *%    <#F++++++++++  < < <&|U;;;;;;;; <    f%%%s8+A>AA9 A5A0+A90A55A99A>#asyncio.Future[_BackendOutcome[_R]]c |jptj}||jt t j|g|Ri|Sr^)r0r`get_running_looprun_in_executorr1r rOrP)r2rfrhrjrs r3r_zAsyncSoftReadWriteLock._submitsQz7W577##DNM9CTUYCk\`CkCkCkdjCkCklllr5)r)r!r"r#r$rr%rr%rr$rr&rr$rr'r r(r)r*)r)r6)r)r$)r)r%)r)r')r)r(r^)r#r&rr>r)r?)r#r&rr>r)rI)rSr%r)r*)r)r*)r[r\r)r*)rfrgrhrirjrkr)r)rfrgrhrirjrkr)rn)__name__ __module__ __qualname____doc__r4propertyr!r#rrr rrDrHrArGrBrWrMrNrUr_r5r3rr!sF0" !$((,#15,0""""""4$$$X$"""X"###X#XX!W[!!!!!!"!X\!!!!!!$'+?GK??????0'+?GK??????..3 = = = = = =.... $$$$ ''''( & & & &mmmmmmr5rc*eZdZdZddZddZddZdS)rIzTAsync context-aware object that releases an :class:`AsyncSoftReadWriteLock` on exit.rLrr)r*c||_dSr^rK)r2rLs r3r4z-AsyncAcquireSoftReadWriteReturnProxy.__init__s  r5cK|jSr^rKr8s r3 __aenter__z/AsyncAcquireSoftReadWriteReturnProxy.__aenter__syr5exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecHK|jd{VdSr^)rLrB)r2r|r~rs r3 __aexit__z.AsyncAcquireSoftReadWriteReturnProxy.__aexit__s4 i!!!!!!!!!!!r5N)rLrr)r*)r)r)r|r}r~rrrr)r*)rrrsrtrur4r{rrwr5r3rIrIsV^^""""""r5rI)#ru __future__rr`rOr, contextlibrtypingrrrfilelock._asyncrr r r r r _syncrcollections.abcrr concurrentrtypesr filelock._apirrrrrI__all__rwr5r3rsOO"""""" ******4444444444%$$$$$188888888""""""######000000Yt__ WT]]WmWmWmWmWmWmWmWmt""""""""&+ r5