\jk58dZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZddlmZmZmZmZmZdd lmZmZmZmZmZdd lmZe r dd lmZmZdd l m!Z!dd l"m#Z#ddl m$Z$ddlm%Z%e dZ&edZ'GddZ(GddZ)ddgZ*y)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING ParamSpecTypeVar)_append_exception_context_ensure_current_process_fork_transition_raise_chained_errors_register_fork_object)_BackendOutcome _capture_call _drain_future_future_result_wait_until_done) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackType)NoReturn)AcquireReturnProxy_P_RczeZdZdZ dddddd ddZed dZed!dZed"dZed#d Z ed$d Z e d%dd d&d Z e d%dd d&d Z d'dZddd d(dZddd d(dZddd)dZd*dZd+dZd,dZ d-dZed.dZd*dZed"dZd*dZd*dZd*dZy)/AsyncReadWriteLocka Async wrapper around :class:`ReadWriteLock` for use in ``asyncio`` applications. This wrapper dispatches every blocking SQLite operation to a thread pool via ``loop.run_in_executor()`` because Python's :mod:`sqlite3` module has no async API. It delegates reentrancy, upgrade/downgrade rules, and singleton behavior 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`` this lock creates and owns a dedicated single-thread executor so every operation runs on the same thread (SQLite affinity requires this) and shuts it down in :meth:`close`. This lock uses a caller-supplied executor as-is and never shuts it down, so after passing no executor call :meth:`close` to release the owned one. .. versionadded:: 3.21.0 TN)blocking is_singletonloopexecutorcftj}||_d|_d|_t |t 5t|||||_||_ |du|_ |xs td|_ tj|k7r d}t| dddy#1swYyxYw)NF)rr r ) max_workersz:AsyncReadWriteLock construction cannot continue after fork)osgetpid _creator_pid_fork_invalidated_closedrr r_lock_loop_owns_executorr _executor RuntimeError) self lock_filetimeoutrr r!r" creator_pidmsgs M/root/.hermes/venv/lib/python3.12/site-packages/filelock/_async_read_write.py__init__zAsyncReadWriteLock.__init__9siik '!& d#   (&y'H[ghDJDJ"*d"2D %J);)JDNyy{k)R"3''*  ( ( (s AB''B0c.|jjS)zThe path to the lock file.)r*r0r/s r4r0zAsyncReadWriteLock.lock_fileQszz###c.|jjS)zThe default timeout.)r*r1r7s r4r1zAsyncReadWriteLock.timeoutVszz!!!r8c.|jjS)z'Whether blocking is enabled by default.)r*rr7s r4rzAsyncReadWriteLock.blocking[szz"""r8c|jS)z2The event loop (or ``None`` for the running loop).)r+r7s r4r!zAsyncReadWriteLock.loop`szzr8c|jS)z_The executor used for ``run_in_executor`` (a dedicated single-thread one if none was supplied).)r-r7s r4r"zAsyncReadWriteLock.executores~~r8rcTK||jj}||jj}|j||d{d} d |j |d{y7'#t$r}|}d}~wwxYw7#|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 Nr=)r*r1r acquire_read BaseException_release_in_contextr/r1r body_errorerrors r4 read_lockzAsyncReadWriteLock.read_lockjs ?jj((G  zz**H(;;;+/  7  **:6 6 6 < J   7$**:6 6 6`AB( A1 B(A3B(+B,B(3 B<A??BB B( B%B!B%%B(cTK||jj}||jj}|j||d{d} d |j |d{y7'#t$r}|}d}~wwxYw7#|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 Nr=)r*r1r acquire_writer@rArBs r4 write_lockzAsyncReadWriteLock.write_locks ?jj((G  zz**H  8 <<<+/  7  **:6 6 6 = J   7$**:6 6 6rFcK |jd{y7#t$r}| t||d}~wwxYwwN)releaser@r )r/rC release_errors r4rAz&AsyncReadWriteLock._release_in_contexts< ,,.  %)-D  s(?? <7<?cK|j|jtj|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 r=Nlock)_raise_if_unusable _run_acquire functoolspartialr*r? AsyncAcquireReadWriteReturnProxyr/r1rs r4r?zAsyncReadWriteLock.acquire_readsS ! 1 1$**2I2I7]e fggg/T:: hAA$A"A$cK|j|jtj|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 r=NrO)rQrRrSrTr*rHrUrVs r4rHz AsyncReadWriteLock.acquire_writesS ! 1 1$**2J2JG^f ghhh/T:: irWFforcecKt|jry|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`` NrY)r _inherited_runr*rL)r/rZs r4rLzAsyncReadWriteLock.releases8 ! ?? ii **%i888sAA A A cKt|jry|jry|j|jj } t |d{t|d|_|jy7'#tj$r[} t|d{7n(#t$r}|j||Yd}~nd}~wwxYwd|_|jd}~wwxYww)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NT)r r\r)_submitr*closerasyncioCancelledErrorrr@_raise_cancelled_error_shutdown_owned_executorr)r/ close_future cancellationrDs r4r`zAsyncReadWriteLock.closes ! ??  << ||DJJ$4$45  "<0 0 0 |$  %%' 1%%  A#L111  A++L%@@ ADL  ) ) +  slA C6 BBB #C6BC3B.'B*(B.-C.. C7C C.CC..C33C6c>K|j|} t|d{t|y7#tj$r} t |d{7nU#tj$r}|j ||Yd}~n+d}~wt $r}|j ||Yd}~nd}~wwxYw t |j|jjd{7#t $r}|j ||Yd}~d}~wwxYwd}~wwxYwwrK) r_rrarbrrcr@r*rLr)r/acquireacquire_futurerf acquire_errorrDs r4rRzAsyncReadWriteLock._run_acquiresg. ">2 2 2 ~& 3%%  A#N333)) I++L-HH  A++L%@@ A A#DLL1C1C$DEEE ! A++L%@@  A sD646 D6D AAADB12B D B1B,'D,B11D51C-&C)'C-,D- D6D D DDDDc*K|j|g|i|} t|d{t|S7#tj$rC} t |d{7#t $r}|j ||Yd}~d}~wwxYwd}~wwxYwwrK)r_rrarbrr@rcr)r/funcargskwargsfuturerfrDs r4r]zAsyncReadWriteLock._runsd4T4V4 "6* * *f%% +%%  A#F+++ ! A++L%@@  A saB:8: B:BA#AA#"B # B,B>B BB  BBc |jxstjj|jt t j|g|i|SrK)r+raget_running_looprun_in_executorr-rrSrT)r/rlrmrns r4r_zAsyncReadWriteLock._submitsK 8g668II NN    d 4T 4V 4  r8c|jx}%||ur!|jx} t||||_||_t|yrK) __context__r r )rfrDcontextcancellation_contexts r4rcz)AsyncReadWriteLock._raise_cancelled_errorsO(( (G 5':U(4(@(@@$M)'3GH'.L $(e$r8cV|jr|jjdyy)NFwait)r,r-shutdownr7s r4rdz+AsyncReadWriteLock._shutdown_owned_executor%s%    NN # # # / r8c`|jxs!tj|jk7SrK)r(r%r&r'r7s r4r\zAsyncReadWriteLock._inherited)s$%%I8I8I)IIr8ct|jrd|jd}t||jrd}t j |y)NzAsyncReadWriteLock on z4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.)r r\r0r.r)sqlite3ProgrammingError)r/r3s r4rQz%AsyncReadWriteLock._raise_if_unusable-sP! ??*4>>*::noCs# # <<8C**3/ / r8cd|_y)NT)r(r7s r4_reset_after_fork_in_childz-AsyncReadWriteLock._reset_after_fork_in_child6s !%r8ctjt|ddk(r+t|ddr|jj dyyy)Nr'r,Frx)r%r&getattrr-rzr7s r4__del__zAsyncReadWriteLock.__del__9sG 99;'$= ='$P`bgBh NN # # # /Ci =r8))r0zstr | os.PathLike[str]r1floatrboolr rr! asyncio.AbstractEventLoop | Noner"zfutures.Executor | NonereturnNone)rstr)rr)rr)rr)rzfutures.ExecutorrK)r1z float | Nonerz bool | NonerzAsyncGenerator[None])rCBaseException | Nonerr)r1rrrrrU)rZrrr)rr)rhz Callable[[], AcquireReturnProxy]rr)rlCallable[_P, _R]rm_P.argsrn _P.kwargsrr)rlrrmrrnrrz#asyncio.Future[_BackendOutcome[_R]])rfzasyncio.CancelledErrorrDr@rr)__name__ __module__ __qualname____doc__r5propertyr0r1rr!r"rrErIrAr?rHrLr`rRr]r_ staticmethodrcrdr\rQrrr8r4rr#s0( !15,0()((  (  (/(*( (0$$""##7W[7707X\770;$;&;4;&.39 (6'$ & $ -4 @I , %%0JJ0&0r8rc8eZdZdZddZddZ ddZy) rUzEContext-aware object that releases the async read/write lock on exit.c||_yrKrO)r/rPs r4r5z)AsyncAcquireReadWriteReturnProxy.__init__Cs  r8c"K|jSwrKrOr7s r4 __aenter__z+AsyncAcquireReadWriteReturnProxy.__aenter__Fsyys cTK|jjd{y7wrK)rPrL)r/exc_type exc_value tracebacks r4 __aexit__z*AsyncAcquireReadWriteReturnProxy.__aexit__Is ii!!!s (&(N)rPrrr)rr)rztype[BaseException] | NonerrrzTracebackType | Nonerr)rrrrr5rrrr8r4rUrU@s:O","("( "  "r8rU)+r __future__rrarSr%r}concurrent.futuresr contextlibrtypingrrr_apir r r r r_asyncrrrrr _read_writercollections.abcrr concurrentrtypesrrrrrrrU__all__rr8r4rsK" 1*44dc&8"#(t_ T]Z0Z0z""&' r8