a xd'@sddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZdd lmZed ZGd d d Ze Gd ddZGdddee ZGdddeejZdd gZdS)) annotationsN)ABCabstractmethod) dataclass)local) TracebackType)Any)TimeoutZfilelockc@sBeZdZdZdddddZdddd Zd d d dd ddZdS)AcquireReturnProxyzDA context aware object that will release the lock file when exiting. BaseFileLockNone)lockreturncCs ||_dSNr)selfrrE/var/www/html/Ranjet/env/lib/python3.9/site-packages/filelock/_api.py__init__szAcquireReturnProxy.__init__rcCs|jSrrrrrr __enter__szAcquireReturnProxy.__enter__type[BaseException] | NoneBaseException | NoneTracebackType | Noneexc_type exc_value tracebackrcCs|jdSr)rreleaserrrrrrr__exit__szAcquireReturnProxy.__exit__N)__name__ __module__ __qualname____doc__rrr"rrrrr sr c@sBeZdZUdZded<ded<ded<dZd ed <d Zded <dS) FileLockContextzL A dataclass which holds the context for a ``BaseFileLock`` object. str lock_filefloattimeoutintmodeNz int | None lock_file_fdr lock_counter)r#r$r%r&__annotations__r.r/rrrrr'(s  r'c@seZdZdZdS)ThreadLocalFileContextzB A thread local version of the ``FileLockContext`` class. N)r#r$r%r&rrrrr1Asr1c@seZdZdZd6ddddd d d d Zdd ddZedd ddZedd ddZej dd dddZe d d ddZ e d d ddZ edd ddZ edd ddZd7d dd"d#dd#dd$d%d&d'Zd8dd d)d*d+Zdd d,d-Zd.d/d0d d1d2d3Zd d d4d5Zd S)9r z+Abstract base class for a file lock object.Tzstr | os.PathLike[Any]r*r,boolr )r)r+r- thread_localrcCs4||_t|||d}|r tntfi||_dS)a Create a new lock object. :param lock_file: path to the file :param timeout: default timeout when acquiring the lock, in seconds. It will be used as fallback value in the acquire method, if no timeout value (``None``) is given. If you want to disable the timeout, set it to a negative value. A timeout of 0 means, that there is exactly one attempt to acquire the file lock. :param mode: file permissions for the lockfile. :param thread_local: Whether this object's internal context should be thread local or not. If this is set to ``False`` then the lock will be reentrant across threads. )r)r+r-N)_is_thread_localosfspathr1r'_context)rr)r+r-r5kwargsrrrrJs zBaseFileLock.__init__rcCs|jS)z>:return: a flag indicating if this lock is thread local or not)r6rrrris_thread_localgszBaseFileLock.is_thread_localr(cCs|jjS)z:return: path to the lock file)r9r)rrrrr)kszBaseFileLock.lock_filecCs|jjS)za :return: the default timeout value, in seconds .. versionadded:: 2.0.0 )r9r+rrrrr+pszBaseFileLock.timeoutz float | str)valuercCst||j_dS)zd Change the default timeout value. :param value: the new value, in seconds N)r*r9r+)rr<rrrr+yscCstdS)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.NNotImplementedErrorrrrr_acquireszBaseFileLock._acquirecCstdS)z>Releases the lock and sets self._context.lock_file_fd to None.Nr=rrrr_releaseszBaseFileLock._releasecCs |jjduS)z :return: A boolean indicating if the lock file is holding the lock currently. .. versionchanged:: 2.0.0 This was previously a method and is now a property. N)r9r.rrrr is_lockeds zBaseFileLock.is_lockedcCs|jjS)zb :return: The number of times this lock has been acquired (but not yet released). )r9r/rrrrr/szBaseFileLock.lock_counterN皙?)poll_intervallblockingz float | Noner )r+ poll_intervalrCrDrc Cs@|dur|jj}|dur0d}tj|tdd|}|jjd7_t|}|j}t }z|j stt d||| |j rt d||qqX|durt d ||t|qXd |krt |krnnt d ||t|qXd }t ||||t|qXWn,ty4td |jjd|j_Yn0t|d S)a_ Try to acquire the file lock. :param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~timeout` is and if ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired :param poll_interval: interval of trying to acquire the lock file :param poll_intervall: deprecated, kept for backwards compatibility, use ``poll_interval`` instead :param blocking: defaults to True. If False, function will return immediately if it cannot obtain a lock on the first attempt. Otherwise, this method will block until the timeout expires or the lock is acquired. :raises Timeout: if fails to acquire lock within the timeout period :return: a context object that will unlock the file when the context is exited .. code-block:: python # You can use this method in the context manager (recommended) with lock.acquire(): pass # Or use an equivalent try-finally construct: lock.acquire() try: pass finally: lock.release() .. versionchanged:: 2.0.0 This method returns now a *proxy* object instead of *self*, so that it can be used in a with statement without side effects. Nz+use poll_interval instead of poll_intervall) stacklevelr z#Attempting to acquire lock %s on %szLock %s acquired on %sFz+Failed to immediately acquire lock %s on %srz"Timeout on acquiring lock %s on %sz2Lock %s not acquired on %s, waiting %s seconds ...r)r9r+warningswarnDeprecationWarningr/idr)time perf_counterrA_LOGGERdebugr?r sleep BaseExceptionmaxr ) rr+rErCrDmsglock_id lock_filename start_timerrracquires<(   zBaseFileLock.acquireF)forcercCsf|jrb|jjd8_|jjdks&|rbt||j}}td|||d|j_td||dS)a* Releases the file lock. Please note, that the lock is only completely released, if the lock counter is 0. Also note, that the lock file itself is not automatically deleted. :param force: If true, the lock counter is ignored and the lock is released in every case/ r rz#Attempting to release lock %s on %szLock %s released on %sN)rAr9r/rKr)rNrOr@)rrXrTrUrrrr szBaseFileLock.releasecCs ||S)zE Acquire the lock. :return: the lock object )rWrrrrrszBaseFileLock.__enter__rrrrcCs |dS)z Release the lock. :param exc_type: the exception type if raised :param exc_value: the exception value if raised :param traceback: the exception traceback if raised Nr r!rrrr"s zBaseFileLock.__exit__cCs|jdddS)z'Called when the lock object is deleted.T)rXNrYrrrr__del__szBaseFileLock.__del__)r2r3T)NrB)F)r#r$r%r&rr;propertyr)r+setterrr?r@rAr/rWr rr"rZrrrrr Gs< M r ) __future__r contextlibloggingr7rLrHabcrrZ dataclassesr threadingrtypesrtypingr_errorr getLoggerrNr r'r1ContextDecoratorr __all__rrrrs*       V