ЦiySrSSKJr SSKrSSKrSSKJr SSKJr SSK J r \(aSSK r SSK J r Jr SS KJr SS KJr "S S 5r"S S5rS S/rg)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypecF\rSrSrSrSSjrS SjrS SjrSrg) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.cXlgNlock)selfrs Y/var/www/html/ai-image-ml/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] | NonerzBaseException | Noner zTracebackType | Noner$r%) __name__ __module__ __qualname____firstlineno____doc__rrr!__static_attributes__rrr r s:O","("( "  "rr cF\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_singletonloopexecutorc:[XX4S9UlXPlX`lg)N)r/r0)r_lock_loop _executor)r lock_filetimeoutr/r0r1r2s rrAsyncReadWriteLock.__init__8s#9d  !rc.URR$)z$:returns: the path to the lock file.)r4r7rs rr7AsyncReadWriteLock.lock_fileFszz###rc.URR$)z:returns: the default timeout.)r4r8rs rr8AsyncReadWriteLock.timeoutKszz!!!rc.URR$)z1:returns: whether blocking is enabled by default.)r4r/rs rr/AsyncReadWriteLock.blockingPszz"""rcUR$)z<:returns: the event loop (or ``None`` for the running loop).)r5rs rr1AsyncReadWriteLock.loopUszzrcUR$)z5:returns: the executor (or ``None`` for the default).)r6rs rr2AsyncReadWriteLock.executorZs~~rc# UR=(d [R"5nURUR[ R "U/UQ70UD65IShvN $N7fr)r5asyncioget_running_looprun_in_executorr6 functoolspartial)rfuncargskwargsr1s r_runAsyncReadWriteLock._run_sPzz7W557))$..):K:KD:bSW:b[a:bccccsA A)"A'#A)r/cx# 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 rONr)rMr4 acquire_readr rr8r/s rrQAsyncReadWriteLock.acquire_readcs8ii //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 rONr)rMr4 acquire_writer rRs rrV AsyncReadWriteLock.acquire_writeus8ii 00'iMMM/T:: NrTFforcech# 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`` rXN)rMr4r)rrYs 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 NrO)r4r8r/rQrrRs 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 NrO)r4r8r/rVrrRs r write_lockAsyncReadWriteLock.write_locksw ?jj((G  zz**H   <<< ! ,,. = !$,,. r_cj# URURR5IShvN gN7f)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. N)rMr4closers rrdAsyncReadWriteLock.closes#ii (()))s )313)r6r4r5))r7zstr | os.PathLike[str]r8floatr/boolr0rhr1 asyncio.AbstractEventLoop | Noner2futures.Executor | Noner$r%)r$str)r$rg)r$rh)r$ri)r$rj)rJzCallable[..., object]rKobjectrLrlr$rl)r8rgr/rhr$r )rYrhr$r%r)r8z float | Noner/z bool | Noner$zAsyncGenerator[None])r$r%)r&r'r(r)r*rpropertyr7r8r/r1r2rMrQrVrrr]rardr+r,rrr#r#%s;* " !15,0 ") " "  "  "/ "* "  "$$""##d;$;;$;4;;$.3 9!W[!!(!X\!!(*rr#)r* __future__rrErH contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r#__all__r,rrrwsOK"* & 8"#""$`*`*H' r