\jOdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z e rddl Z dd lmZmZdd lmZdd lmZGd d ZGddZd dgZy)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec8eZdZdZddZddZ ddZy) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.c||_yNlock)selfrs D/root/env/lib/python3.12/site-packages/filelock/_async_read_write.py__init__z)AsyncAcquireReadWriteReturnProxy.__init__s  c"K|jSwrrrs r __aenter__z+AsyncAcquireReadWriteReturnProxy.__aenter__syys cTK|jjd{y7wr)rrelease)rexc_type exc_value tracebacks r __aexit__z*AsyncAcquireReadWriteReturnProxy.__aexit__s ii!!!s (&(N)rAsyncReadWriteLockreturnNone)r!r )rztype[BaseException] | NonerzBaseException | NonerzTracebackType | Noner!r")__name__ __module__ __qualname____doc__rrrrrrrs:O","("( "  "rrceZdZdZ dddddd ddZeddZeddZeddZedd Z edd Z dd Z ddd dd Z ddd ddZ ddddZeddd d dZeddd d dZd!dZy)"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_singletonloopexecutorcvt|||||_||_|du|_|xs t d|_y)N)r)r*r) max_workers)r_lock_loop_owns_executorr _executor)r lock_filetimeoutr)r*r+r,s rrzAsyncReadWriteLock.__init__9s=#9gWcd  &$.!F%7A%Frc.|jjS)z$:returns: the path to the lock file.)r/r3rs rr3zAsyncReadWriteLock.lock_fileHszz###rc.|jjS)z:returns: the default timeout.)r/r4rs rr4zAsyncReadWriteLock.timeoutMszz!!!rc.|jjS)z1:returns: whether blocking is enabled by default.)r/r)rs rr)zAsyncReadWriteLock.blockingRszz"""rc|jS)z<:returns: the event loop (or ``None`` for the running loop).)r0rs rr+zAsyncReadWriteLock.loopWszzrc|jS)z5:returns: the executor (or ``None`` for the default).)r2rs rr,zAsyncReadWriteLock.executor\s~~rcK|jxstj}|j|jt j |g|i|d{S7wr)r0asyncioget_running_looprun_in_executorr2 functoolspartial)rfuncargskwargsr+s r_runzAsyncReadWriteLock._runasQzz7W557))$..):K:KD:bSW:b[a:bccccsAA"A A"r)cK|j|jj||d{t|S7w)a7 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 rDNr)rCr/ acquire_readrrr4r)s rrFzAsyncReadWriteLock.acquire_reades;ii //8iLLL/T:: M,A?AcK|j|jj||d{t|S7w)aZ 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 rDNr)rCr/ acquire_writerrGs rrJz AsyncReadWriteLock.acquire_writews;ii 00'HiMMM/T:: NrHFforcecnK|j|jj|d{y7w)a2 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`` rKN)rCr/r)rrLs rrzAsyncReadWriteLock.releases(ii **%i888s +535c"K||jj}||jj}|j||d{ d|j d{y7#7#|j d{7wxYww)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 NrD)r/r4r)rFrrGs r read_lockzAsyncReadWriteLock.read_locks{ ?jj((G  zz**H(;;; ! ,,. < !$,,. HAB A- BA1B'A/(B/B1B BB  Bc"K||jj}||jj}|j||d{ d|j d{y7#7#|j d{7wxYww)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 NrD)r/r4r)rJrrGs r write_lockzAsyncReadWriteLock.write_locks{ ?jj((G  zz**H  8 <<< ! ,,. = !$,,. rPcK|j|jjd{|jr|jj dyy7.w)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)rCr/closer1r2shutdownrs rrUzAsyncReadWriteLock.closesLii (()))    NN # # # /  *s)AA/A))r3zstr | os.PathLike[str]r4floatr)boolr*rYr+ asyncio.AbstractEventLoop | Noner,futures.Executor | Noner!r")r!str)r!rX)r!rY)r!rZ)r!r[)r@zCallable[..., object]rAobjectrBr]r!r])r4rXr)rYr!r)rLrYr!r"r)r4z float | Noner)z bool | Noner!zAsyncGenerator[None])r!r")r#r$r%r&rpropertyr3r4r)r+r,rCrFrJrrrOrRrUr'rrr r &s:* G !15,0 G) G G  G  G/ G* G  G$$""##d;$;$;4;$.3 9!W[!!(!X\!!( 0rr )r& __future__rr;r>concurrent.futuresr contextlibrtypingr _read_writeroscollections.abcr r concurrentr typesr rr __all__r'rrrisRK"1* & 8"#""$c0c0N' r