o #jO@sdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z e rBddl Z dd lmZmZdd lmZdd lmZGd d d ZGdddZd dgZdS)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec@s.eZdZdZdddZddd ZdddZdS) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.lockAsyncReadWriteLockreturnNonecCs ||_dSNr )selfr r[/var/www/html/Deteccion_Ine/venv/lib/python3.10/site-packages/filelock/_async_read_write.py__init__s z)AsyncAcquireReadWriteReturnProxy.__init__cs|jSrrrrrr __aenter__sz+AsyncAcquireReadWriteReturnProxy.__aenter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonecs|jIdHdSr)r release)rrrrrrr __aexit__sz*AsyncAcquireReadWriteReturnProxy.__aexit__N)r rrr)rr)rrrrrrrr)__name__ __module__ __qualname____doc__rrr rrrrr s   r c@seZdZdZ d;ddddddddZed?ddZed@ddZ edAddZ dBd%d&Z d;dd'dCd)d*Z d;dd'dCd+d,Z d-d.dDd0d1ZedEdd'dFd5d6ZedEdd'dFd7d8ZdGd9d:ZdS)Hra 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 | NonerrcCs6t||||d|_||_|du|_|ptdd|_dS)N)r&r'r) max_workers)r_lock_loop_owns_executorr _executor)rr*r,r&r'r(r)rrrr9s  zAsyncReadWriteLock.__init__strcC|jjS)z$:returns: the path to the lock file.)r2r*rrrrr*HzAsyncReadWriteLock.lock_filecCr7)z:returns: the default timeout.)r2r,rrrrr,Mr8zAsyncReadWriteLock.timeoutcCr7)z1:returns: whether blocking is enabled by default.)r2r&rrrrr&Rr8zAsyncReadWriteLock.blockingcC|jS)z<:returns: the event loop (or ``None`` for the running loop).)r3rrrrr(WzAsyncReadWriteLock.loopcCr9)z5:returns: the executor (or ``None`` for the default).)r5rrrrr)\r:zAsyncReadWriteLock.executorfuncCallable[..., object]argsobjectkwargscs8|jpt}||jtj|g|Ri|IdHSr)r3asyncioZget_running_loopZrun_in_executorr5 functoolspartial)rr;r=r?r(rrr_runas(zAsyncReadWriteLock._runr&r c&|j|jj||dIdHt|dS)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)rCr2 acquire_readr rr,r&rrrrFe zAsyncReadWriteLock.acquire_readcrE)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)rCr2 acquire_writer rGrrrrIwrHz AsyncReadWriteLock.acquire_writeFforcerKcs|j|jj|dIdHdS)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`` rJN)rCr2r)rrKrrrrs zAsyncReadWriteLock.release float | None bool | NoneAsyncGenerator[None]cCb|dur |jj}|dur|jj}|j||dIdHz dVW|IdHdS|IdHw)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)r2r,r&rFrrGrrr read_lock "zAsyncReadWriteLock.read_lockcCrO)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)r2r,r&rIrrGrrr write_lockrQzAsyncReadWriteLock.write_lockcs2||jjIdH|jr|jjdddSdS)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)rCr2closer4r5shutdownrrrrrTs zAsyncReadWriteLock.close)r%)r*r+r,r-r&r.r'r.r(r/r)r0rr)rr6)rr-)rr.)rr/)rr0)r;r<r=r>r?r>rr>)r,r-r&r.rr )rKr.rrr)r,rLr&rMrrN)rr)r!r"r#r$rpropertyr*r,r&r(r)rCrFrIrrrPrRrTrrrrr&s8       r)r$ __future__rr@rAconcurrent.futuresr contextlibrtypingrZ _read_writeroscollections.abcrr Z concurrentr typesr r r__all__rrrrs&       (