o ~eI(@sddlmZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZddlmZerZddlZdd lmZejd krTdd lmZndd lmZed ZGd ddZe GdddZGdddee ZGdddeejZddgZ dS)) annotationsN)ABCabstractmethod) dataclass)local) TYPE_CHECKINGAny)Timeout) TracebackType) )SelfZfilelockc@s.eZdZdZdddZddd ZdddZdS)AcquireReturnProxyzDA context aware object that will release the lock file when exiting.lock BaseFileLockreturnNonecCs ||_dSNr)selfrr=D:\Projects\ConvertPro\env\Lib\site-packages\filelock/_api.py__init__"s zAcquireReturnProxy.__init__cC|jSrrrrrr __enter__%szAcquireReturnProxy.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonecCs|jdSr)rreleaserrrr!rrr__exit__(szAcquireReturnProxy.__exit__N)rrrr)rrrrrr r!r"rr)__name__ __module__ __qualname____doc__rrr%rrrrrs   rc@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@seZdZdZ   d>d?ddZd@ddZedAddZedBddZej dCddZe dDddZ e dDddZ ed@dd Z edEd!d"Z # $dFd#dd%dGd+d,ZdHdId/d0ZdJd2d3ZdKd:d;ZdDd:return: a flag indicating if this lock is thread local or not)r;rrrris_thread_locallszBaseFileLock.is_thread_localr,cC|jjS)z:return: path to the lock file)r>r-rrrrr-pzBaseFileLock.lock_filecCrA)za :return: the default timeout value, in seconds .. versionadded:: 2.0.0 )r>r/rrrrr/uszBaseFileLock.timeoutvalue float | strcCst||j_dS)zd Change the default timeout value. :param value: the new value, in seconds N)r.r>r/)rrCrrrr/~scCt)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.NotImplementedErrorrrrr_acquirezBaseFileLock._acquirecCrE)z>Releases the lock and sets self._context.lock_file_fd to None.rFrrrr_releaserIzBaseFileLock._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>r2rrrr is_lockeds zBaseFileLock.is_lockedcCrA)zP:return: The number of times this lock has been acquired (but not yet released).)r>r3rrrrr3rBzBaseFileLock.lock_counterN皙?)poll_intervallblocking float | None poll_intervalrMrNrc 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/warningswarnDeprecationWarningr3idr-time perf_counterrK_LOGGERdebugrHr sleep BaseExceptionmaxr) rr/rPrMrNmsglock_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)rKr>r3rVr-rYrZrJ)rrcr_r`rrrr#szBaseFileLock.releasercCs ||S)zE Acquire the lock. :return: the lock object )rbrrrrrszBaseFileLock.__enter__rrrr r!r"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)rcNrdrrrr__del__szBaseFileLock.__del__)r6r7T) r-r8r/r.r1r0r9r:rr)rr:)rr,)rr.)rCrDrr)rr)rr0)NrL) r/rOrPr.rMrOrNr:rr)F)rcr:rr)rrr&)r'r(r)r*rr@propertyr-r/setterrrHrJrKr3rbr#rr%rerrrrrLs>         L  r)! __future__r contextlibloggingr<rWrSabcrr dataclassesr threadingrtypingrr_errorr systypesr version_inforZtyping_extensions getLoggerrYrr+r5ContextDecoratorr__all__rrrrs6        S