qiydZddlmZddlZddlZddlmZddlmZddl m Z erddl Z ddl m Z mZdd lmZdd lmZGd d ZGd dZd dgZy)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec8eZdZdZddZddZ ddZy) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.c||_yNlock)selfrs L/opt/pipecat/venv/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__rrrrrr r s:O","("( "  "rr ceZdZdZ dddddd ddZeddZeddZeddZedd Z edd Z dd Z ddd dd Z ddd ddZ ddddZeddd d dZeddd d dZd!dZy)"ra 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_singletonloopexecutorcHt|||||_||_||_y)N)r(r))r_lock_loop _executor)r lock_filetimeoutr(r)r*r+s rrzAsyncReadWriteLock.__init__8s%#9gWcd  !rc.|jjS)z$:returns: the path to the lock file.)r-r0rs rr0zAsyncReadWriteLock.lock_fileFszz###rc.|jjS)z:returns: the default timeout.)r-r1rs rr1zAsyncReadWriteLock.timeoutKszz!!!rc.|jjS)z1:returns: whether blocking is enabled by default.)r-r(rs rr(zAsyncReadWriteLock.blockingPszz"""rc|jS)z<:returns: the event loop (or ``None`` for the running loop).)r.rs rr*zAsyncReadWriteLock.loopUszzrc|jS)z5:returns: the executor (or ``None`` for the default).)r/rs rr+zAsyncReadWriteLock.executorZs~~rcK|jxstj}|j|jt j |g|i|d{S7wr)r.asyncioget_running_looprun_in_executorr/ functoolspartial)rfuncargskwargsr*s r_runzAsyncReadWriteLock._run_sQzz7W557))$..):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 rANr)r@r- acquire_readr rr1r(s rrCzAsyncReadWriteLock.acquire_readcs;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 rANr)r@r- acquire_writer rDs rrGz AsyncReadWriteLock.acquire_writeus;ii 00'HiMMM/T:: NrEFforcecnK|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`` rHN)r@r-r)rrIs 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 NrA)r-r1r(rCrrDs 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 NrA)r-r1r(rGrrDs r write_lockzAsyncReadWriteLock.write_locks{ ?jj((G  zz**H  8 <<< ! ,,. = !$,,. rMcjK|j|jjd{y7w)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. N)r@r-closers rrQzAsyncReadWriteLock.closes$ii (()))s )313))r0zstr | os.PathLike[str]r1floatr(boolr)rTr* asyncio.AbstractEventLoop | Noner+futures.Executor | Noner r!)r str)r rS)r rT)r rU)r rV)r=zCallable[..., object]r>objectr?rXr rX)r1rSr(rTr r )rIrTr r!r)r1z float | Noner(z bool | Noner zAsyncGenerator[None])r r!)r"r#r$r%rpropertyr0r1r(r*r+r@rCrGrrrLrOrQr&rrrr%s1* " !15,0 ") " "  "  "/ "* "  "$$""##d;$;$;4;$.3 9!W[!!(!X\!!(*rr)r% __future__rr8r; contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r__all__r&rrrcsOK"* & 8"#""$`*`*H' r