EiOSrSSKJr SSKrSSKrSSKJr SSKJr SSK J r SSK J r \ (aSSK r SS KJrJr SS KJr SS KJr "S S 5r"SS5rS S/rg)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypecF\rSrSrSrSSjrS SjrS SjrSrg) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.cXlgNlock)selfrs W/home/mande/repo/quber/.venv/lib/python3.13/site-packages/filelock/_async_read_write.py__init__)AsyncAcquireReadWriteReturnProxy.__init__s c"# UR$7frrrs r __aenter__+AsyncAcquireReadWriteReturnProxy.__aenter__syys cT# URR5IShvN gN7fr)rrelease)rexc_type exc_value tracebacks r __aexit__*AsyncAcquireReadWriteReturnProxy.__aexit__s ii!!!s (&(rN)rAsyncReadWriteLockreturnNone)r%r$)rztype[BaseException] | Noner zBaseException | Noner!zTracebackType | Noner%r&) __name__ __module__ __qualname____firstlineno____doc__rrr"__static_attributes__rrrrs:O","("( "  "rrcF\rSrSrSrSSSSSS.SSjjjr\SSj5r\SSj5r\SS j5r \SS j5r \SS j5r SS jr SSS .SSjjjr SSS .SSjjjrSS.S Sjjr\S!SS .S"Sjjj5r\S!SS .S"Sjjj5rS#SjrSrg)$r$&a Async wrapper around :class:`ReadWriteLock` for use in ``asyncio`` applications. Because Python's :mod:`sqlite3` module has no async API, all blocking SQLite operations are dispatched to a thread pool via ``loop.run_in_executor()``. Reentrancy, upgrade/downgrade rules, and singleton behavior are delegated to the underlying :class:`ReadWriteLock`. :param lock_file: path to the SQLite database file used as the lock :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :param is_singleton: if ``True``, reuse existing :class:`ReadWriteLock` instances for the same resolved path :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.21.0 TN)blocking is_singletonloopexecutorcn[XX4S9UlXPlUSLUlU=(d [ SS9Ulg)N)r0r1r) max_workers)r_lock_loop_owns_executorr _executor)r lock_filetimeoutr0r1r2r3s rrAsyncReadWriteLock.__init__9s6#9d  &$.!F%7A%Frc.URR$)z$:returns: the path to the lock file.)r6r:rs rr:AsyncReadWriteLock.lock_fileHszz###rc.URR$)z:returns: the default timeout.)r6r;rs rr;AsyncReadWriteLock.timeoutMszz!!!rc.URR$)z1:returns: whether blocking is enabled by default.)r6r0rs rr0AsyncReadWriteLock.blockingRszz"""rcUR$)z<:returns: the event loop (or ``None`` for the running loop).)r7rs rr2AsyncReadWriteLock.loopWszzrcUR$)z5:returns: the executor (or ``None`` for the default).)r9rs rr3AsyncReadWriteLock.executor\s~~rc# UR=(d [R"5nURUR[ R "U/UQ70UD65IShvN $N7fr)r7asyncioget_running_looprun_in_executorr9 functoolspartial)rfuncargskwargsr2s r_runAsyncReadWriteLock._runasPzz7W557))$..):K:KD:bSW:b[a:bccccsA A)"A'#A)r0cx# URURRXS9IShvN [US9$N 7f)a Acquire a shared read lock. See :meth:`ReadWriteLock.acquire_read` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds rRNr)rPr6 acquire_readrrr;r0s rrTAsyncReadWriteLock.acquire_reades8ii //iLLL/T:: M (:8:cx# URURRXS9IShvN [US9$N 7f)a Acquire an exclusive write lock. See :meth:`ReadWriteLock.acquire_write` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :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 rRNr)rPr6 acquire_writerrUs rrY AsyncReadWriteLock.acquire_writews8ii 00'iMMM/T:: NrWFforcech# URURRUS9IShvN gN7f)a  Release one level of the current lock. See :meth:`ReadWriteLock.release` for full semantics. :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)rPr6r)rr\s rrAsyncReadWriteLock.releases'ii **%i888s (202c# UcURRnUcURRnURXS9IShvN S7v UR 5IShvN gN#N!UR 5IShvN f=f7f)a[ Async context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :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 NrR)r6r;r0rTrrUs r read_lockAsyncReadWriteLock.read_locksw ?jj((G  zz**H;;; ! ,,. < !$,,. HAB A+B  A/B %A-&B -B /B BB  B c# UcURRnUcURRnURXS9IShvN S7v UR 5IShvN gN#N!UR 5IShvN f=f7f)a` Async context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :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 NrR)r6r;r0rYrrUs r write_lockAsyncReadWriteLock.write_locksw ?jj((G  zz**H   <<< ! ,,. = !$,,. rbc# URURR5IShvN UR(aURR SS9 ggN07f)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NF)wait)rPr6closer8r9shutdownrs rrhAsyncReadWriteLock.closesKii (()))    NN # # # /  *s)AA1A)r9r6r7r8))r:zstr | os.PathLike[str]r;floatr0boolr1rmr2 asyncio.AbstractEventLoop | Noner3futures.Executor | Noner%r&)r%str)r%rl)r%rm)r%rn)r%ro)rMzCallable[..., object]rNobjectrOrqr%rq)r;rlr0rmr%r)r\rmr%r&r)r;z float | Noner0z bool | Noner%zAsyncGenerator[None])r%r&)r'r(r)r*r+rpropertyr:r;r0r2r3rPrTrYrrr`rdrhr,r-rrr$r$&sD* G !15,0 G) G G  G  G/ G* G  G$$""##d;$;;$;4;;$.3 9!W[!!(!X\!!( 0rr$)r+ __future__rrHrKconcurrent.futuresr contextlibrtypingr _read_writeroscollections.abcr r concurrentr typesr rr$__all__r-rrr}sRK"1* & 8"#""$c0c0N' r