+ j/Rt^RIHt^RIt^RIt^RIt^RIHt^RIH t H t H t ^RI H t HtHtHtHtHt^RIHt] 'd!^RIHtHt^RIHt^R IHt^R IHt^R IHt] !R 4t ] !R 4t!!RR4t"!RR4t#RR.t$R#)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)LeaseCompromise_P_Rc]tRt^"tRtR5RRRRRRRRR R R RR RR R/RRlllt]RRl4t]RRl4t]RRl4t ]RRl4t ]RRl4t ]RRl4t ]RRl4t ]R6RR/RRlll4t]R6RR/R R!lll4tR6RR/R"R#llltR6RR/R$R%llltR&R'/R(R)lltR*R+ltR,R-ltR.R/ltR0R1ltR2R3ltR4tR#)7AsyncSoftReadWriteLocka9 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, the heartbeat and stale eviction, and singleton behavior. :param lock_file: path to the lock file; the protocol directory lives next to it as ``.rw`` :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 a holder record may stay unchanged before a contender evicts it; defaults to ``3 * heartbeat_interval`` :param poll_interval: seconds between acquire retries under contention; default 0.25 s :param on_compromise: called from the heartbeat thread with a :class:`~filelock.LeaseCompromise` when the hold is lost :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 blockingT is_singletonheartbeat_intervalg>@stale_thresholdN poll_intervalg? on_compromiseloopexecutorcDV^8dQhRRRRRRRRRRR R R RR R RRRRRR/ #) lock_filezstr | os.PathLike[str]timeoutfloatrboolrrr float | Nonerrz(Callable[[LeaseCompromise], None] | Noner asyncio.AbstractEventLoop | Nonerfutures.Executor | NonereturnNone)formats"Y/home/luca/screen-checking/.venv/lib/python3.14/site-packages/filelock/_soft_rw/_async.py __annotate__#AsyncSoftReadWriteLock.__annotate__;sy"")""  "  """&""@"/"*" "c  \P!4Vn\VVVVVVVVR7VnWnWnR#))rrrrrrN)osgetpid _creator_pidr _lock_loop _executor) selfr"r#rrrrrrrrs &&&$$$$$$$$r-__init__AsyncSoftReadWriteLock.__init__;sBIIK&  %1+''    !r0cV^8dQhRR/#)r!r)strr+)r,s"r-r.r/Xs$$3$r0c .VPP#)z4The path to the lock file passed to the constructor.)r5r"r8s&r-r" AsyncSoftReadWriteLock.lock_fileWszz###r0cV^8dQhRR/#)r!r)r$r+)r,s"r-r.r/]s"""r0c .VPP#)z\The default timeout applied when ``acquire_read`` / ``acquire_write`` is called without one.)r5r#r>s&r-r#AsyncSoftReadWriteLock.timeout\szz!!!r0cV^8dQhRR/#)r!r)r%r+)r,s"r-r.r/bs##$#r0c .VPP#)zYWhether ``acquire_*`` defaults to blocking; ``False`` makes contention raise immediately.)r5rr>s&r-rAsyncSoftReadWriteLock.blockingaszz"""r0cV^8dQhRR/#)r!r)z int | Noner+)r,s"r-r.r/gs%%J%r0c .VPP#)z_The generation the current hold was granted at, a fencing token; ``None`` when no lock is held.)r5 generationr>s&r-rH!AsyncSoftReadWriteLock.generationfzz$$$r0cV^8dQhRR/#)r!r)zLeaseCompromise | Noner+)r,s"r-r.r/ls%%2%r0c .VPP#)z;How the current hold was lost, or ``None`` while it stands.)r5 compromiser>s&r-rM!AsyncSoftReadWriteLock.compromisekrJr0cV^8dQhRR/#)r!r)r'r+)r,s"r-r.r/qs6r0c VP#)zNThe event loop used for ``run_in_executor``, or ``None`` for the running loop.)r6r>s&r-rAsyncSoftReadWriteLock.looppszzr0cV^8dQhRR/#)r!r)r(r+)r,s"r-r.r/vs1r0c VP#)zPThe executor used for ``run_in_executor``, or ``None`` for the default executor.)r7r>s&r-rAsyncSoftReadWriteLock.executorus~~r0c$V^8dQhRRRRRR/#r!r#r&r bool | Noner)zAsyncGenerator[None]r+)r,s"r-r.r/{s"!!|!!`t!r0c "VPWR7GRjxL R5xVP4GRjxL R#L$L TP4GRjxL i;i5i)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 rN) acquire_readreleaser8r#rs&&$r- read_lock AsyncSoftReadWriteLock.read_lockzsN;;; ! ,,. < !$,,. >A=AAA?AAAAAAc$V^8dQhRRRRRR/#rVr+)r,s"r-r.r/s"!! !+!au!r0c "VPWR7GRjxL R5xVP4GRjxL R#L$L TP4GRjxL i;i5i)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 rYN) acquire_writer[r\s&&$r- write_lock!AsyncSoftReadWriteLock.write_locksN   <<< ! ,,. = !$,,. r_c$V^8dQhRRRRRR/#r!r#r&rrWr)$AsyncAcquireSoftReadWriteReturnProxyr+)r,s"r-r.r/$??#?9D? -?r0c "VP4VP\P!VPP WR74GRjxL \ VR7#L5i)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 rYNlock)_raise_if_inherited _run_acquire functoolspartialr5rZrgr\s&&$r-rZ#AsyncSoftReadWriteLock.acquire_readsO&   " 1 1$**2I2I7 fggg3>> hAA$A"A$c$V^8dQhRRRRRR/#rfr+)r,s"r-r.r/rhr0c "VP4VP\P!VPP WR74GRjxL \ VR7#L5i)a Acquire an exclusive write lock. See :meth:`SoftReadWriteLock.acquire_write` for the 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 rYNrj)rlrmrnror5rbrgr\s&&$r-rb$AsyncSoftReadWriteLock.acquire_writesO&   " 1 1$**2J2JG ghhh3>> irqforceFc V^8dQhRRRR/#)r!rur%r)r*r+)r,s"r-r.r/s = =d =t =r0c "VP\P!48Xd2VPVPP VR7GRjxL R#R#L5i)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`` )ruN)r4r2r3_runr5r[)r8rus&$r-r[AsyncSoftReadWriteLock.releasesC    +))DJJ..e)< < < , s&r-r}AsyncSoftReadWriteLock.closes=    +))DJJ,,- - - , -sA AA AcV^8dQhRR/#r{r+)r,s"r-r.r/s$$T$r0c VP\P!48wdRVP R2p\ V4hR#)zAsyncSoftReadWriteLock on z4 was inherited across fork; construct a new instanceN)r4r2r3r" RuntimeError)r8msgs& r-rl*AsyncSoftReadWriteLock._raise_if_inheriteds:    +.t~~.>>rsCs# # ,r0c V^8dQhRRRR/#)r!acquirez Callable[[], AcquireReturnProxy]r)r*r+)r,s"r-r.r/s''*J't'r0c "VPV4p\V4GRjxL \T4R#L \Pdp\ T4GRjxL M# \ dp\ Y44Rp?MRp?ii;i\ TPTPP44GRjxL h \ dp\ Y44Rp?hRp?ii;iRp?ii;i5iN) _submitr asyncioCancelledErrorr BaseExceptionr r5r[r )r8racquire_future cancellationerrors&& r-rm#AsyncSoftReadWriteLock._run_acquires g. ">2 2 2 ~& 3%%  <#N333  <&|;; < <#DLL1C1C$DEEE ! <&|;;  < sC)757 C)7C& A"AA"!C!" B- A=8C!=BC!1B>7B:8B>=C!> C CC!CC!!C&&C)c(V^8dQhRRRRRRRR/#) r!funcCallable[_P, _R]args_P.argskwargs _P.kwargsr)rr+)r,s"r-r.r/s* & &/ & &9 &Y[ &r0c $"VP!V.VO5/VBp\V4GRjxL \T4#L \Pd?p\ T4GRjxL h \ dp\ YV4Rp?hRp?ii;iRp?ii;i5ir)rr rrr rr r )r8rrrfuturerrs&&*, r-rxAsyncSoftReadWriteLock._runsd4T4V4 "6* * *f%% +%%  <#F+++ ! <&|;;  < saB:8: B:B A%A!A%$B% B0 B;BBBB  Bc(V^8dQhRRRRRRRR/#) r!rrrrrrr)z#asyncio.Future[_BackendOutcome[_R]]r+)r,s"r-r.r/s2mm$m-4m@Im ,mr0c  VP;'g\P!4pVPVP\ \ P!V.VO5/VB4#r)r6rget_running_looprun_in_executorr7rrnro)r8rrrrs&&*, r-rAsyncSoftReadWriteLock._submitsOzz77W557##DNNM9CTCTUYCk\`CkdjCkllr0)r4r7r5r6)r)__name__ __module__ __qualname____firstlineno____doc__r9propertyr"r#rrHrMrrrr]rcrZrbr[r}rlrmrxr__static_attributes__r+r0r-rr"sw0"  " " "%)")-" $"CG"26"-1""8$$""##%%%%!W[!!"!X\!!"?GK??.?GK??. =U =. $ '( &mmr0rc>]tRtRtRtRRltRRltRRltR tR #) rgi zTAsync context-aware object that releases an :class:`AsyncSoftReadWriteLock` on exit.c V^8dQhRRRR/#)r!rkrr)r*r+)r,s"r-r.1AsyncAcquireSoftReadWriteReturnProxy.__annotate__s3r0c WnR#rrj)r8rks&&r-r9-AsyncAcquireSoftReadWriteReturnProxy.__init__s r0cV^8dQhRR/#)r!r)rr+)r,s"r-r.rs"8r0c ""VP#5irrjr>s&r- __aenter__/AsyncAcquireSoftReadWriteReturnProxy.__aenter__syys c(V^8dQhRRRRRRRR/#) r!exc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackzTracebackType | Noner)r*r+)r,s"r-r.rs2"","("( "  "r0c V"VPP4GRjxL R#L5ir)rkr[)r8rrrs&&&&r- __aexit__.AsyncAcquireSoftReadWriteReturnProxy.__aexit__s ii!!!s )')rjN) rrrrrr9rrrr+r0r-rgrg s^""r0rg)%r __future__rrrnr2 contextlibrtypingrrrfilelock._asyncrrr r r r _syncr collections.abcrr concurrentrtypesr filelock._apirfilelock._leaserrrrrg__all__r+r0r-rsxO" *44%8"#0/t_ T]fmfmR""&+ r0