o lh3@sbdZddlZddlZddlZddlZzddlZWn ey#dZYnwzddlZWn ey5dZYnwzddlZWn eyGdZYnwze Wn e yWe Z YnwgdZ dZ daddZGddde ZGd d d eZGd d d eZGd ddeZGdddeZGdddeZdZereZdSereZdSeZedureddSdS)zD A platform independent file lock that supports the with-statement. N)Timeout BaseFileLockWindowsFileLock UnixFileLock SoftFileLockFileLockz3.0.12cCstpttatS)z0Returns the logger instance used in this module.)_loggerlogging getLogger__name__r r :/var/www/html/env/lib/python3.10/site-packages/filelock.pyloggerLsrc@ eZdZdZddZddZdS)rzN Raised when the lock could not be acquired in *timeout* seconds. cCs ||_dS N) lock_file)selfrr r r __init__[szTimeout.__init__cCsd|j}|S)Nz)The file lock '{}' could not be acquired.)formatr)rtempr r r __str__bszTimeout.__str__N)r __module__ __qualname____doc__rrr r r r rUs rc@s$eZdZddZddZddZdS)_Acquire_ReturnProxycCs ||_dSNlock)rrr r r rusz_Acquire_ReturnProxy.__init__cC|jSrrrr r r __enter__ysz_Acquire_ReturnProxy.__enter__cCs|jdSr)rreleaserexc_type exc_value tracebackr r r __exit__|s z_Acquire_ReturnProxy.__exit__N)r rrrr!r'r r r r rss rc@seZdZdZdddZeddZeddZejd dZd d Z d d Z eddZ dddZ dddZ ddZddZddZdS) rz3 Implements the base class of a file lock. cCs&||_d|_||_t|_d|_dS)rNr) _lock_file _lock_file_fdtimeout threadingLock _thread_lock _lock_counter)rrr+r r r rs  zBaseFileLock.__init__cCr)z, The path to the lock file. )r)r r r r rszBaseFileLock.lock_filecCr)a~ You can set a default timeout for the filelock. 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. .. versionadded:: 2.0.0 )_timeoutr r r r r+szBaseFileLock.timeoutcCst||_dSr)floatr0)rvaluer r r r+s cCt)z Platform dependent. If the file lock could be acquired, self._lock_file_fd holds the file descriptor of the lock file. NotImplementedErrorr r r r _acquireszBaseFileLock._acquirecCr3)zH Releases the lock and sets self._lock_file_fd to None. r4r r r r _releaseszBaseFileLock._releasecCs |jduS)z True, if the object holds the file lock. .. versionchanged:: 2.0.0 This was previously a method and is now a property. N)r*r r r r is_lockeds zBaseFileLock.is_lockedN皙?c CsV|dur|j}|j|jd7_Wdn1swYt|}|j}t}zY |j|jsAtd||| Wdn1sKwY|jr\t d||n(|dkrut||krutd||t |jtd|||t |q.Wn |jt d|jd|_Wd1swYt|d S) aY Acquires the file lock or fails with a :exc:`Timeout` error. .. 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() :arg float timeout: The maximum time waited for the file lock. If ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired. If ``timeout`` is None, the default :attr:`~timeout` is used. :arg float poll_intervall: We check once in *poll_intervall* seconds if we can acquire the file lock. :raises Timeout: if the lock could not be acquired in *timeout* seconds. .. 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. NTz#Attempting to acquire lock %s on %szLock %s acquired on %srz"Timeout on acquiring lock %s on %sz2Lock %s not acquired on %s, waiting %s seconds ...r)r+r.r/idr)timer8rdebugr6inforsleepmaxr)rr+poll_intervalllock_id lock_filename start_timer r r acquiresJ$     zBaseFileLock.acquireFcCs|jH|jr;|jd8_|jdks|rCt|}|j}td|||d|_td||WddSWddSWddS1sNwYdS)aV Releases the file lock. Please note, that the lock is only completly released, if the lock counter is 0. Also note, that the lock file itself is not automatically deleted. :arg bool 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) r.r8r/r;r)rr=r7r>)rforcerBrCr r r r"%s(    zBaseFileLock.releasecCs ||Sr)rEr r r r r!BzBaseFileLock.__enter__cCs |dSrr"r#r r r r'FrGzBaseFileLock.__exit__cCs|jdddS)NT)rFrHr r r r __del__Js zBaseFileLock.__del__)r()Nr9)F)r rrrrpropertyrr+setterr6r7r8rEr"r!r'rIr r r r rs$       J rc@r)rze Uses the :func:`msvcrt.locking` function to hard lock the lock file on windows systems. c Cs|tjtjBtjB}z t|j|}Wn tyYdSwz t|tj dWnt tfy8t |YdSw||_ dSNr:) osO_RDWRO_CREATO_TRUNCopenr)OSErrormsvcrtlockingLK_NBLCKIOErrorcloser*r open_modefdr r r r6Xs  zWindowsFileLock._acquirecCsN|j}d|_t|tjdt|z t|jWdSty&YdSwrL) r*rSrTLK_UNLCKrMrWremover)rRrrZr r r r7hs  zWindowsFileLock._releaseNr rrrr6r7r r r r rRs rc@r)rzR Uses the :func:`fcntl.flock` to hard lock the lock file on unix systems. c CsftjtjBtjB}t|j|}z t|tjtj BWnt t fy-t |YdSw||_ dSr)rMrNrOrPrQr)fcntlflockLOCK_EXLOCK_NBrVrRrWr*rXr r r r6~s zUnixFileLock._acquirecCs(|j}d|_t|tjt|dSr)r*r_r`LOCK_UNrMrWr]r r r r7s  zUnixFileLock._releaseNr^r r r r rys rc@r)rz8 Simply watches the existence of the lock file. c CsNtjtjBtjBtjB}z t|j|}Wn ttfy!YdSw||_ dSr) rMO_WRONLYrOO_EXCLrPrQr)rVrRr*rXr r r r6szSoftFileLock._acquirecCs:t|jd|_z t|jWdStyYdSwr)rMrWr*r\r)rRr r r r r7s  zSoftFileLock._releaseNr^r r r r rs rz only soft file lock is available)rr rMr,r<warnings ImportErrorrSr_ TimeoutError NameErrorrR__all__ __version__rrrobjectrrrrrrwarnr r r r sZ         R'!