§ ôÝþiOãóÆ—dZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z e rddl Z dd lmZmZdd lmZdd lmZGd „d ¦«ZGd„d¦«Zd dgZdS)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.é)Ú annotationsN)ÚThreadPoolExecutor)Úasynccontextmanager)Ú TYPE_CHECKINGé)Ú ReadWriteLock)ÚAsyncGeneratorÚCallable)Úfutures)Ú TracebackTypecó*—eZdZdZdd„Zdd„Zdd„ZdS)Ú AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.ÚlockÚAsyncReadWriteLockÚreturnÚNonecó—||_dS©N©r)Úselfrs ú[/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/filelock/_async_read_write.pyÚ__init__z)AsyncAcquireReadWriteReturnProxy.__init__s €ØˆŒ ˆ ˆ ócƒóK—|jSrr©rs rÚ __aenter__z+AsyncAcquireReadWriteReturnProxy.__aenter__sèè€ØŒyÐrÚexc_typeútype[BaseException] | NoneÚ exc_valueúBaseException | NoneÚ tracebackúTracebackType | NonecƒóHK—|j ¦«ƒd{V—†dSr)rÚrelease)rrrr!s rÚ __aexit__z*AsyncAcquireReadWriteReturnProxy.__aexit__s4èè€ð Œi×ÒÑ!Ô!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!rN)rrrr)rr)rrrr r!r"rr)Ú__name__Ú __module__Ú __qualname__Ú__doc__rrr%©rrrrsV€€€€€ØOÐOððððððððð"ð"ð"ð"ð"ð"rrcó —eZdZdZ d.dddddœd/d„Zed0d„¦«Zed1d„¦«Zed2d„¦«Zed3d„¦«Z ed4d„¦«Z d5d„Z 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_singletonÚloopÚexecutorÚ lock_fileústr | os.PathLike[str]ÚtimeoutÚfloatr-Úboolr.r/ú asyncio.AbstractEventLoop | Noner0úfutures.Executor | Nonerrcó„—t||||¬¦«|_||_|du|_|pt d¬¦«|_dS)N)r-r.r)Ú max_workers)rÚ_lockÚ_loopÚ_owns_executorrÚ _executor)rr1r3r-r.r/r0s rrzAsyncReadWriteLock.__init__9sM€õ# 9¨gÀÐWcÐdÑdÔdˆŒ ؈Œ Ø&¨$Ð.ˆÔØ!ÐFÕ%7ÀAÐ%FÑ%FÔ%FˆŒˆˆrÚstrcó—|jjS)z$:returns: the path to the lock file.)r:r1rs rr1zAsyncReadWriteLock.lock_fileHs€ðŒzÔ#Ð#rcó—|jjS)z:returns: the default timeout.)r:r3rs rr3zAsyncReadWriteLock.timeoutMs€ðŒzÔ!Ð!rcó—|jjS)z1:returns: whether blocking is enabled by default.)r:r-rs rr-zAsyncReadWriteLock.blockingRs€ðŒzÔ"Ð"rcó—|jS)z<:returns: the event loop (or ``None`` for the running loop).)r;rs rr/zAsyncReadWriteLock.loopWs €ðŒzÐrcó—|jS)z5:returns: the executor (or ``None`` for the default).)r=rs rr0zAsyncReadWriteLock.executor\s €ðŒ~ÐrÚfuncúCallable[..., object]ÚargsÚobjectÚkwargscó¢K—|jptj¦«}| |jt j|g|¢Ri|¤Ž¦«ƒd{V—†Sr)r;ÚasyncioÚget_running_loopÚrun_in_executorr=Ú functoolsÚpartial)rrDrFrHr/s rÚ_runzAsyncReadWriteLock._runasbèè€ØŒzÐ7WÔ5Ñ7Ô7ˆØ×)Ò)¨$¬.½)Ô:KÈDÐ:bÐSWÐ:bÐ:bÐ:bÐ[aÐ:bÐ:bÑcÔcÐcÐcÐcÐcÐcÐcÐcr©r-rcƒóvK—| |jj||¬¦«ƒd{V—†t|¬¦«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 rPNr)rOr:Ú acquire_readr©rr3r-s rrRzAsyncReadWriteLock.acquire_readesHèè€ðiŠi˜œ Ô/°À8ˆiÑLÔLÐLÐLÐLÐLÐLÐLÐLÝ/°TÐ:Ñ:Ô:Ð:rcƒóvK—| |jj||¬¦«ƒd{V—†t|¬¦«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 rPNr)rOr:Ú acquire_writerrSs rrUz AsyncReadWriteLock.acquire_writewsHèè€ðiŠi˜œ Ô0°'ÀHˆiÑMÔMÐMÐMÐMÐMÐMÐMÐMÝ/°TÐ:Ñ:Ô:Ð:rF©ÚforcerWcƒóXK—| |jj|¬¦«ƒd{V—†dS)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`` rVN)rOr:r$)rrWs rr$zAsyncReadWriteLock.release‰s;èè€ðiŠi˜œ Ô*°%ˆiÑ8Ô8Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ð8rú float | Noneú bool | NoneúAsyncGenerator[None]cóúK—|€ |jj}|€ |jj}| ||¬¦«ƒd{V—† dWV—| ¦«ƒd{V—†dS#| ¦«ƒd{V—†wxYw)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 NrP)r:r3r-rRr$rSs rÚ read_lockzAsyncReadWriteLock.read_lock–s®èè€ð ˆ?Ø”jÔ(ˆGØ Ð Ø”zÔ*ˆHØ×Ò °(ÐÑ;Ô;Ð;Ð;Ð;Ð;Ð;Ð;Ð;ð !Ø ˆEˆEˆEˆEà—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð Ð Ð ø$—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð Ð øøøó ½AÁA:cóúK—|€ |jj}|€ |jj}| ||¬¦«ƒd{V—† dWV—| ¦«ƒd{V—†dS#| ¦«ƒd{V—†wxYw)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 NrP)r:r3r-rUr$rSs rÚ write_lockzAsyncReadWriteLock.write_lock«s®èè€ð ˆ?Ø”jÔ(ˆGØ Ð Ø”zÔ*ˆHØ× Ò  °8Ð Ñ<Ô<Ð<Ð<Ð<Ð<Ð<Ð<Ð<ð !Ø ˆEˆEˆEˆEà—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð Ð Ð ø$—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð Ð øøør^cƒóœK—| |jj¦«ƒd{V—†|jr|j d¬¦«dSdS)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)rOr:Úcloser<r=Úshutdownrs rrczAsyncReadWriteLock.closeÀseèè€ðiŠi˜œ Ô(Ñ)Ô)Ð)Ð)Ð)Ð)Ð)Ð)Ð)Ø Ô ð 0Ø ŒN× #Ò #¨Ð #Ñ /Ô /Ð /Ð /Ð /ð 0ð 0r)r,)r1r2r3r4r-r5r.r5r/r6r0r7rr)rr>)rr4)rr5)rr6)rr7)rDrErFrGrHrGrrG)r3r4r-r5rr)rWr5rrr)r3rYr-rZrr[)rr)r&r'r(r)rÚpropertyr1r3r-r/r0rOrRrUr$rr]r`rcr*rrrr&sú€€€€€ððð*ð Gð Ø!Ø15Ø,0ð Gð Gð Gð Gð Gð Gðð$ð$ð$ñ„Xð$ðð"ð"ð"ñ„Xð"ðð#ð#ð#ñ„Xð#ððððñ„Xðððððñ„Xððdðdðdðdð;È$ð;ð;ð;ð;ð;ð;ð$;È4ð;ð;ð;ð;ð;ð;ð$.3ð 9ð 9ð 9ð 9ð 9ð 9ðð!ÐW[ð!ð!ð!ð!ð!ñÔð!ð(ð!ÐX\ð!ð!ð!ð!ð!ñÔð!ð( 0ð 0ð 0ð 0ð 0ð 0rr)r)Ú __future__rrJrMÚconcurrent.futuresrÚ contextlibrÚtypingrÚ _read_writerÚosÚcollections.abcr r Ú concurrentr Útypesr rrÚ__all__r*rrúrps3ðØKÐKà"Ð"Ð"Ð"Ð"Ð"à€€€ØÐÐÐØ1Ð1Ð1Ð1Ð1Ð1Ø*Ð*Ð*Ð*Ð*Ð*Ø Ð Ð Ð Ð Ð à&Ð&Ð&Ð&Ð&Ð&àð$Ø €I€I€IØ8Ð8Ð8Ð8Ð8Ð8Ð8Ð8Ø"Ð"Ð"Ð"Ð"Ð"Ø#Ð#Ð#Ð#Ð#Ð#ð"ð"ð"ð"ð"ñ"ô"ð"ð$c0ðc0ðc0ðc0ðc0ñc0ôc0ðc0ðN'Øð €€€r