iydZddlmZddlZddlZddlmZddlmZddl m Z erddl Z ddl m Z mZdd lmZdd lmZGd d ZGd dZd dgZdS)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec*eZdZdZddZddZddZdS) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.lockAsyncReadWriteLockreturnNonec||_dSNr)selfrs d/srv/www/vhosts/g4struct/public_html/venv/lib/python3.11/site-packages/filelock/_async_read_write.py__init__z)AsyncAcquireReadWriteReturnProxy.__init__s  cK|jSrrrs r __aenter__z+AsyncAcquireReadWriteReturnProxy.__aenter__syrexc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecHK|jd{VdSr)rrelease)rrrr s r __aexit__z*AsyncAcquireReadWriteReturnProxy.__aexit__s4 i!!!!!!!!!!!rN)rrrr)rr)rrrrr r!rr)__name__ __module__ __qualname____doc__rrr$rrr r sVOO""""""rr c eZdZdZ d.dddddd/dZed0dZed1dZed2dZed3dZ ed4dZ d5dZ d.dd d6d"Z d.dd d6d#Z d$d%d7d'Zed8dd d9d+Zed8dd d9d,Zd:d-ZdS);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_singletonloopexecutor lock_filestr | os.PathLike[str]timeoutfloatr,boolr-r. asyncio.AbstractEventLoop | Noner/futures.Executor | NonerrcRt|||||_||_||_dS)N)r,r-)r_lock_loop _executor)rr0r2r,r-r.r/s rrzAsyncReadWriteLock.__init__8s/#9gWcddd  !rstrc|jjS)z$:returns: the path to the lock file.)r8r0rs rr0zAsyncReadWriteLock.lock_fileFsz##rc|jjS)z:returns: the default timeout.)r8r2rs rr2zAsyncReadWriteLock.timeoutKsz!!rc|jjS)z1:returns: whether blocking is enabled by default.)r8r,rs rr,zAsyncReadWriteLock.blockingPsz""rc|jS)z<:returns: the event loop (or ``None`` for the running loop).)r9rs rr.zAsyncReadWriteLock.loopUs zrc|jS)z5:returns: the executor (or ``None`` for the default).)r:rs rr/zAsyncReadWriteLock.executorZs ~rfuncCallable[..., object]argsobjectkwargscK|jptj}||jt j|g|Ri|d{VSr)r9asyncioget_running_looprun_in_executorr: functoolspartial)rrArCrEr.s r_runzAsyncReadWriteLock._run_sbz7W577))$.):KD:bSW:b:b:b[a:b:bcccccccccrr,r cvK||jj||d{Vt|S)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 rMNr)rLr8 acquire_readr rr2r,s rrOzAsyncReadWriteLock.acquire_readcsHii /8iLLLLLLLLL/T::::rcvK||jj||d{Vt|S)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 rMNr)rLr8 acquire_writer rPs rrRz AsyncReadWriteLock.acquire_writeusHii 0'HiMMMMMMMMM/T::::rFforcerTcXK||jj|d{VdS)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`` rSN)rLr8r#)rrTs rr#zAsyncReadWriteLock.releases;ii *%i88888888888r float | None bool | NoneAsyncGenerator[None]cK| |jj}| |jj}|||d{V dWV|d{VdS#|d{VwxYw)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 NrM)r8r2r,rOr#rPs r read_lockzAsyncReadWriteLock.read_locks ?j(G  z*H(;;;;;;;;; ! EEEE,,.. $,,.. AA:cK| |jj}| |jj}|||d{V dWV|d{VdS#|d{VwxYw)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 NrM)r8r2r,rRr#rPs r write_lockzAsyncReadWriteLock.write_locks ?j(G  z*H  8 <<<<<<<<< ! EEEE,,.. $,,.. r[cTK||jjd{VdS)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. N)rLr8closers rr_zAsyncReadWriteLock.closes7ii ()))))))))))r)r+)r0r1r2r3r,r4r-r4r.r5r/r6rr)rr;)rr3)rr4)rr5)rr6)rArBrCrDrErDrrD)r2r3r,r4rr )rTr4rrr)r2rVr,rWrrX)rr)r%r&r'r(rpropertyr0r2r,r.r/rLrOrRr#rrZr]r_r)rrrr%s* " !15,0 " " " " " "$$$X$"""X"###X#XXdddd;$;;;;;;$;4;;;;;;$.3 9 9 9 9 9 9!W[!!!!!!(!X\!!!!!!(******rr)r( __future__rrGrJ contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r__all__r)rrrjs!KK""""""****** &&&&&&$ III88888888""""""######""""""""$`*`*`*`*`*`*`*`*H' r