U -e5@sldZddlZddlZddlZddlZz ddlZWnek rHdZYnXz ddlZWnek rndZYnXz ddlZWnek rdZYnXze Wne k re Z YnXddddddgZ d Z dad d ZGd dde ZGd ddZGdddZGdddeZGdddeZGdddeZdZerDeZn$erPeZneZedk rheddS)zD A platform independent file lock that supports the with-statement. NTimeout BaseFileLockWindowsFileLock UnixFileLock SoftFileLockFileLockz3.0.12cCstp ttatS)z0Returns the logger instance used in this module.)_loggerlogging getLogger__name__r r X/var/www/html/Darija-Ai-Train/env/lib/python3.8/site-packages/datasets/utils/filelock.pyloggerPsrc@s 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|jd}|S)NzThe file lock 'z' could not be acquired.r)rtempr r r __str__eszTimeout.__str__N)r __module__ __qualname____doc__rrr r r r rYsc@s$eZdZddZddZddZdS)_Acquire_ReturnProxycCs ||_dSNlock)rrr r r rwsz_Acquire_ReturnProxy.__init__cCs|jSrrrr r r __enter__{sz_Acquire_ReturnProxy.__enter__cCs|jdSr)rreleaserexc_type exc_value tracebackr r r __exit__~s z_Acquire_ReturnProxy.__exit__N)r rrrrr%r r r r rvsrc@seZdZdZd ddZeddZedd Zejd d Zd d Z d dZ eddZ d!ddZ d"ddZ ddZddZddZeeedddZdS)#rz3 Implements the base class of a file lock. NcCsB|dk r |nd}|||}||_d|_||_t|_d|_dS)rNr)hash_filename_if_too_long _lock_file _lock_file_fdtimeout threadingLock _thread_lock _lock_counterrrr+max_filename_lengthr r r rs  zBaseFileLock.__init__cCs|jS)z, The path to the lock file. )r)rr r r rszBaseFileLock.lock_filecCs|jS)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. *New in version 2.0.0* )_timeoutrr r r r+szBaseFileLock.timeoutcCst||_dSr)floatr2)rvaluer r r r+s cCs tdS)z Platform dependent. If the file lock could be acquired, self._lock_file_fd holds the file descriptor of the lock file. NNotImplementedErrorrr r r _acquireszBaseFileLock._acquirecCs tdS)zH Releases the lock and sets self._lock_file_fd to None. Nr5rr r r _releaseszBaseFileLock._releasecCs |jdk S)z{ True, if the object holds the file lock. This was previously a method and is now a property. N)r*rr r r is_lockedszBaseFileLock.is_locked皙?c CsJ|dkr|j}|j|jd7_W5QRXt|}|j}t}z|j,|jsttd|d|| W5QRX|jrtd|d|q qF|dkrt||krtd|d|t |jqFtd|d |d |d t |qFWn2|jt d|jd|_W5QRXYnXt |d S) a  Acquires the file lock or fails with a :exc:`Timeout` error. ```py # 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. This method returns now a *proxy* object instead of *self*, so that it can be used in a with statement without side effects. NzAttempting to acquire lock  on Lock z acquired on rzTimeout on acquiring lock z not acquired on z , waiting z seconds ...r)r+r.r/idr)timer9rdebugr7rsleepmaxr)rr+Zpoll_intervalllock_id lock_filename start_timer r r acquires6" zBaseFileLock.acquireFc Cs|jt|jrv|jd8_|jdks*|rvt|}|j}td|d||d|_td|d|W5QRXdS)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;rzAttempting to release lock r<r=z released on N)r.r9r/r>r)rr@r8)rforcerCrDr r r r #s "zBaseFileLock.releasecCs ||Sr)rFrr r r r?szBaseFileLock.__enter__cCs |dSrr r!r r r r%CszBaseFileLock.__exit__cCs|jdddS)NT)rGrHrr r r __del__Gs zBaseFileLock.__del__)path max_lengthreturncCsrtj|}t||krj|dkrjtj|}tt|}|d|t|dd|d}tj||S|SdS)Nrz...z.lock)osrJbasenamelendirnamestrhashjoin)rrJrKfilenamerQZhashed_filenameZ new_filenamer r r r(Ks   $z&BaseFileLock.hash_filename_if_too_long)r&N)Nr:)F)r rrrrpropertyrr+setterr7r8r9rFr rr%rIrRintr(r r r r rs$       G cs2eZdZdZd fdd ZddZdd ZZS) rze Uses the :func:`msvcrt.locking` function to hard lock the lock file on windows systems. r&Ncs2ddlm}tj|||dd||j|_dS)Nr;)relative_to_absolute_pathr+r1z\\?\)Z file_utilsrYsuperrrr))rrr+r1rY __class__r r r`s zWindowsFileLock.__init__cCsxtjtjBtjB}zt|j|}Wntk r8YnYnX||_dSr) rNO_WRONLYr`O_EXCLrarbr)rcr*rgr r r r7szSoftFileLock._acquirecCs<t|jd|_zt|jWntk r6YnXdSr)rNrfr*rir)rcrr r r r8s zSoftFileLock._releaseN)r rrrr7r8r r r r rs z only soft file lock is available)rr rNr,r?warnings ImportErrorrdro TimeoutError NameErrorrc__all__ __version__rrrrrrrrrwarnr r r r sZ          X/%!