U -eI(@sddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZddlmZerddlZdd lmZejd krdd lmZn dd lmZed ZGd ddZe GdddZGdddee ZGdddeejZddgZ dS)) annotationsN)ABCabstractmethod) dataclass)local) TYPE_CHECKINGAny)Timeout) TracebackType) )SelfZfilelockc@sBeZdZdZdddddZdddd Zd d d dd ddZdS)AcquireReturnProxyzDA context aware object that will release the lock file when exiting. BaseFileLockNone)lockreturncCs ||_dSNr)selfrrN/var/www/html/Darija-Ai-Train/env/lib/python3.8/site-packages/filelock/_api.py__init__"szAcquireReturnProxy.__init__rcCs|jSrrrrrr __enter__%szAcquireReturnProxy.__enter__type[BaseException] | NoneBaseException | NoneTracebackType | Noneexc_type exc_value tracebackrcCs|jdSr)rreleaserr!r"r#rrr__exit__(szAcquireReturnProxy.__exit__N)__name__ __module__ __qualname____doc__rrr&rrrrrsrc@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__r2r3rrrrr+1s  r+c@seZdZdZdS)ThreadLocalFileContextz8A thread local version of the ``FileLockContext`` class.N)r'r(r)r*rrrrr5Hsr5c@seZdZdZd7ddddd d d d Zdd ddZedd ddZedd ddZej dd dddZe d d ddZ e d d ddZ edd ddZ edd ddZd8d dd"d#dd#dd$d%d&d'Zd9dd d)d*d+Zd,d d-d.Zd/d0d1d d2d3d4Zd d d5d6Zd S):rz+Abstract base class for a file lock object.Tzstr | os.PathLike[str]r.r0boolr)r-r/r1 thread_localrcCs0||_t|||d}|r tntf||_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/r1N)_is_thread_localosfspathr5r+_context)rr-r/r1r9kwargsrrrrOs zBaseFileLock.__init__rcCs|jS)z>:return: a flag indicating if this lock is thread local or not)r:rrrris_thread_locallszBaseFileLock.is_thread_localr,cCs|jjS)z:return: path to the lock file)r=r-rrrrr-pszBaseFileLock.lock_filecCs|jjS)za :return: the default timeout value, in seconds .. versionadded:: 2.0.0 )r=r/rrrrr/uszBaseFileLock.timeoutz float | str)valuercCst||j_dS)zd Change the default timeout value. :param value: the new value, in seconds N)r.r=r/)rr@rrrr/~scCstdS)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.NrArrrr_releaseszBaseFileLock._releasecCs |jjdk S)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=r2rrrr is_lockeds zBaseFileLock.is_lockedcCs|jjS)zP:return: The number of times this lock has been acquired (but not yet released).)r=r3rrrrr3szBaseFileLock.lock_counterN皙?)poll_intervallblockingz float | Noner)r/ poll_intervalrGrHrc Cs:|dkr|jj}|dk r0d}tj|tdd|}|jjd7_t|}|j}t }z|j stt d||| |j rt d||q|dkrt d ||t|d |krt |krnnt d ||t|d }t ||||t|qXWn.tk r.td |jjd|j_YnXt|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)r=r/warningswarnDeprecationWarningr3idr-time perf_counterrE_LOGGERdebugrCr sleep BaseExceptionmaxr) rr/rIrGrHmsglock_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)rEr=r3rOr-rRrSrD)rr\rXrYrrrr$szBaseFileLock.releasercCs ||S)zE Acquire the lock. :return: the lock object )r[rrrrrszBaseFileLock.__enter__rrrr 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)r\Nr]rrrr__del__szBaseFileLock.__del__)r6r7T)NrF)F)r'r(r)r*rr?propertyr-r/setterrrCrDrEr3r[r$rr&r^rrrrrLs< L r)! __future__r contextlibloggingr;rPrLabcrr dataclassesr threadingrtypingrr_errorr systypesr version_inforZtyping_extensions getLoggerrRrr+r5ContextDecoratorr__all__rrrrs4        S