o i'@sddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZddlmZerDdd lmZed ZGd d d Ze Gd ddZGdddee ZGdddeejZdd gZdS)) annotationsN)ABCabstractmethod) dataclass)local) TYPE_CHECKINGAny)Timeout) TracebackTypefilelockc@s.eZdZdZdddZddd ZdddZdS)AcquireReturnProxyzDA context aware object that will release the lock file when exiting.lock BaseFileLockreturnNonecCs ||_dSNr)selfrrH/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/filelock/_api.py__init__s zAcquireReturnProxy.__init__cC|jSrrrrrr __enter__szAcquireReturnProxy.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCs|jdSr)rreleaserrrrrrr__exit__!szAcquireReturnProxy.__exit__N)rrrrrrrrrrrr rr)__name__ __module__ __qualname____doc__rrr#rrrrr s   r c@sBeZdZUdZded<ded<ded<dZd ed <d Zded <dS) FileLockContextzBA dataclass which holds the context for a ``BaseFileLock`` object.str lock_filefloattimeoutintmodeNz int | None lock_file_fdr lock_counter)r&r'r(r)__annotations__r1r2rrrrr**s  r*c@seZdZdZdS)ThreadLocalFileContextz8A thread local version of the ``FileLockContext`` class.N)r&r'r(r)rrrrr4Asr4c@seZdZdZ   d=d>ddZd?ddZed@ddZedAddZej dBddZe dCddZ e dCddZ ed?dd Z edDd!d"Z # $dEd#dd%dFd+d,ZdGdHd/d0ZdId1d2ZdJd9d:ZdCd;d<Zd#S)Krz+Abstract base class for a file lock object.Tr,str | os.PathLike[Any]r.r-r0r/ thread_localboolrrcCs4||_t|||d}|rtntdi||_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.r0Nr)_is_thread_localosfspathr4r*_context)rr,r.r0r8kwargsrrrrHs zBaseFileLock.__init__cCr)z>:return: a flag indicating if this lock is thread local or not)r:rrrris_thread_localeszBaseFileLock.is_thread_localr+cC|jjS)z:return: path to the lock file)r=r,rrrrr,izBaseFileLock.lock_filecCr@)za :return: the default timeout value, in seconds .. versionadded:: 2.0.0 )r=r.rrrrr.nszBaseFileLock.timeoutvalue float | strcCst||j_dS)zd Change the default timeout value. :param value: the new value, in seconds N)r-r=r.)rrBrrrr.wscCt)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.NotImplementedErrorrrrr_acquirezBaseFileLock._acquirecCrD)z>Releases the lock and sets self._context.lock_file_fd to None.rErrrr_releaserHzBaseFileLock._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)r=r1rrrr is_lockeds zBaseFileLock.is_lockedcCr@)zP:return: The number of times this lock has been acquired (but not yet released).)r=r2rrrrr2rAzBaseFileLock.lock_counterN皙?)poll_intervallblocking float | None poll_intervalrLrMr c Cs4|dur|jj}|durd}tj|tdd|}|jjd7_t|}|j}t }zV |j s;t d||| |j rFt d||n:|d urUt d ||t|d |krct |krpnn t d ||t|d }t ||||t|q-Wntytd |jjd|j_wt|dS)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 Tz#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)r=r.warningswarnDeprecationWarningr2idr,time perf_counterrJ_LOGGERdebugrGr sleep BaseExceptionmaxr ) rr.rOrLrMmsglock_id lock_filename start_timerrracquiresD(    zBaseFileLock.acquireFforcecCsn|jr3|jjd8_|jjdks|r5t||j}}td|||d|j_td||dSdSdS)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)rJr=r2rUr,rXrYrI)rrbr^r_rrrr!szBaseFileLock.releasecCs ||S)zE Acquire the lock. :return: the lock object )rarrrrrszBaseFileLock.__enter__rrrrrr cCs |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)rbNrcrrrr__del__szBaseFileLock.__del__)r5r6T) r,r7r.r-r0r/r8r9rr)rr9)rr+)rr-)rBrCrr)rr)rr/)NrK) r.rNrOr-rLrNrMr9rr )F)rbr9rrr$r%)r&r'r(r)rr?propertyr,r.setterrrGrIrJr2rar!rr#rdrrrrrEs>         L  r) __future__r contextlibloggingr;rVrRabcrr dataclassesr threadingrtypingrr_errorr typesr getLoggerrXr r*r4ContextDecoratorr__all__rrrrs.      S