:j;!dZddlmZddlZddlZddlmZddlmZddl 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 o/home/mcse/projects/srt_converter/srt-converter-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__rrrrrrrs:O","("( "  "rrceZdZdZ dddddd ddZeddZeddZeddZedd Z edd Z dd Z ddd dd Z ddd ddZ ddddZed dd d!dZed dd d!dZd"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``. When ``None`` a dedicated single-thread executor is created and owned by this lock, ensuring every operation runs on the same thread (required for SQLite affinity); it is shut down by :meth:`close`. A caller-supplied executor is used as-is and never shut down here, so when no executor is passed remember to call :meth:`close` to release the owned one. .. 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__<s=#9gWcd  &$.!F%7A%Frc.|jjS)z$:returns: the path to the lock file.)r/r3rs rr3zAsyncReadWriteLock.lock_fileKszz###rc.|jjS)z:returns: the default timeout.)r/r4rs rr4zAsyncReadWriteLock.timeoutPszz!!!rc.|jjS)z1:returns: whether blocking is enabled by default.)r/r)rs rr)zAsyncReadWriteLock.blockingUszz"""rc|jS)z<:returns: the event loop (or ``None`` for the running loop).)r0rs rr+zAsyncReadWriteLock.loopZszzrc|jS)zi:returns: the executor used for ``run_in_executor`` (a dedicated single-thread one if none was supplied).)r2rs rr,zAsyncReadWriteLock.executor_s~~rcK|jxstj}|j|jt j |g|i|d{S7wr)r0asyncioget_running_looprun_in_executorr2 functoolspartial)rfuncargskwargsr+s r_runzAsyncReadWriteLock._rundsQzz7W557))$..):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_readhs;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_writezs;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. NFwait)rCr/closer1r2shutdownrs rrVzAsyncReadWriteLock.closesLii (()))    NN # # # /  *s)AA/AcXt|ddr|jjdyy)Nr1FrT)getattrr2rWrs r__del__zAsyncReadWriteLock.__del__s+ 4)5 1 NN # # # / 2r))r3zstr | os.PathLike[str]r4floatr)boolr*r]r+ asyncio.AbstractEventLoop | Noner,zfutures.Executor | Noner!r")r!str)r!r\)r!r])r!r^)r!zfutures.Executor)r@zCallable[..., object]rAobjectrBr`r!r`)r4r\r)r]r!r)rLr]r!r"r)r4z float | Noner)z bool | Noner!zAsyncGenerator[None])r!r")r#r$r%r&rpropertyr3r4r)r+r,rCrFrJrrrOrRrVrZr'rrr r &s?0 G !15,0 G) G G  G  G/ G* G  G$$""##d;$;$;4;$.3 9!W[!!(!X\!!( 00rr )r& __future__rr;r>concurrent.futuresr contextlibrtypingr _read_writeroscollections.abcr r concurrentr typesr rr __all__r'rrrlsRK"1* & 8"#""$l0l0`' r