o 2j;!@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 rU/var/www/html/whisper/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>dddddd?ddZed@ddZedAddZedBddZedCddZ edDdd Z dEd&d'Z d>dd(dFd*d+Z d>dd(dFd,d-Z d.d/dGd1d2ZedHdd(dId6d7ZedHdd(dId8d9ZdJd:d;ZdJdr@r(rrr_runds(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 rGNr)rFr2 acquire_readr rr,r&rrrrIh zAsyncReadWriteLock.acquire_readcrH)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 rGNr)rFr2 acquire_writer rJrrrrLzrKz AsyncReadWriteLock.acquire_writeFforcerNcs|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`` rMN)rFr2r)rrNrrrrs 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 NrG)r2r,r&rIrrJrrr read_lock "zAsyncReadWriteLock.read_lockcCrR)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 NrG)r2r,r&rLrrJrrr write_lockrTzAsyncReadWriteLock.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. NFwait)rFr2closer4r5shutdownrrrrrXs zAsyncReadWriteLock.closecCs"t|ddr|jjdddSdS)Nr4FrV)getattrr5rYrrrr__del__s zAsyncReadWriteLock.__del__)r%)r*r+r,r-r&r.r'r.r(r/r)r0rr)rr6)rr-)rr.)rr/)rr;)r<r=r>r?r@r?rr?)r,r-r&r.rr )rNr.rrr)r,rOr&rPrrQ)rr)r!r"r#r$rpropertyr*r,r&r(r)rFrIrLrrrSrUrXr[rrrrr&s:         r)r$ __future__rrArDconcurrent.futuresr contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r__all__rrrrs&       1