*#h5dZddlZddlZddlZddlZ ddlZ ddlZ ddlZ e gdZ dZ dadZGdde ZGdd ZGd d ZGd d eZGddeZGddeZdZereZyereZyeZeej.dyy#e$rdZYwxYw#e$rdZYwxYw#e$rdZYwxYw#e $re Z YwxYw)zD A platform independent file lock that supports the with-statement. N)Timeout BaseFileLockWindowsFileLock UnixFileLock SoftFileLockFileLockz3.0.12cPtxstjtatS)z0Returns the logger instance used in this module.)_loggerlogging getLogger__name__T/var/www/html/sandstorm/venv/lib/python3.12/site-packages/datasets/utils/filelock.pyloggerrPs4**84G NrceZdZdZdZdZy)rzN Raised when the lock could not be acquired in *timeout* seconds. c||_y N lock_file)selfrs r__init__zTimeout.__init___s#rc&d|jd}|S)NzThe file lock 'z' could not be acquired.r)rtemps r__str__zTimeout.__str__es  00HI rN)r __module__ __qualname____doc__rrrrrrrYs  rrceZdZdZdZdZy)_Acquire_ReturnProxyc||_yNlock)rr%s rrz_Acquire_ReturnProxy.__init__ws  rc|jSr#r$rs r __enter__z_Acquire_ReturnProxy.__enter__{s yyrc8|jjyr#)r%releaserexc_type exc_value tracebacks r__exit__z_Acquire_ReturnProxy.__exit__~s rN)r rrrr(r/rrrr!r!vsrr!ceZdZdZddZedZedZejdZdZ dZ ed Z dd Z dd Z d Zd ZdZdededefdZy)rz3 Implements the base class of a file lock. Nc||nd}|j||}||_d|_||_t j |_d|_y)rNr)hash_filename_if_too_long _lock_file _lock_file_fdtimeout threadingLock _thread_lock _lock_counter)rrr6max_filename_lengths rrzBaseFileLock.__init__s\5H5T1Z]229>QR # " &NN, rc|jS)z, The path to the lock file. )r4r's rrzBaseFileLock.lock_files rc|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* )_timeoutr's rr6zBaseFileLock.timeouts}}rc$t||_yr)floatr>)rvalues rr6zBaseFileLock.timeoutse  rct)z Platform dependent. If the file lock could be acquired, self._lock_file_fd holds the file descriptor of the lock file. NotImplementedErrorr's r_acquirezBaseFileLock._acquires "##rct)zH Releases the lock and sets self._lock_file_fd to None. rCr's r_releasezBaseFileLock._releases "##rc|jduS)z{ True, if the object holds the file lock. This was previously a method and is now a property. N)r5r's r is_lockedzBaseFileLock.is_lockeds!!--rc | |j}|j5|xjdz c_dddt|}|j}t j } |j5|j s/tjd|d||jddd|j r tjd|d|n|dk\rNt j |z |kDr4tjd|d|t|jtjd|d |d |d t j| t| S#1swYMxYw#1swYxYw#|j5td|jdz |_ddd#1swYxYwxYw) 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$)r6r9r:idr4timerIrdebugrErsleepmaxr!)rr6poll_intervalllock_id lock_filename start_times racquirezBaseFileLock.acquiresD ?llG   $   ! #  $T( YY[  &&(>>)DWITR_Q`'ab ( >>HNNU7)=#PQ\diikJ&>&HHNN%?y]O#\]!$//22HNNy(9- SaRbbnoJJ~.!$..= $ $((  "" D%(D,>,>,B%C" D  D sHE<% F2c&|j|Sr#)rWr's rr(zBaseFileLock.__enter__?s  rc$|jyr#r*r+s rr/zBaseFileLock.__exit__Cs rc(|jdy)NT)rYr\r's r__del__zBaseFileLock.__del__Gs 4  rpath max_lengthreturncJtjj|}t||kDru|dkDrptjj |}t t |}|d|t|z dz dz|zdz}tjj||S|S)Nrz...z.lock)osr_basenamelendirnamestrhashjoin)rr_r`filenamerghashed_filename new_filenames rr3z&BaseFileLock.hash_filename_if_too_longKs77##D) x=: %*q.ggood+G!$x.1O#$Kj33G&G!&KLuTWffippL77<<6 6KrN)Ng?)F)r rrrrpropertyrr6setterrErGrIrWr*r(r/r^rhintr3rrrrrs4    ^^$$..E/N8cssrrc0eZdZdZdfd ZdZdZxZS)rze Uses the :func:`msvcrt.locking` function to hard lock the lock file on windows systems. cjddlm}t| |||d||jz|_y)NrK)relative_to_absolute_pathr6r;z\\?\) file_utilsrusuperrrr4)rrr6r;ru __class__s rrzWindowsFileLock.__init__`s19 GI\]#&?&OOrcjtjtjztjz} tj|j |} t j|t jd||_ y#t$rtj|YywxYw#t$rYywxYwNrK) rdO_RDWRO_CREATO_TRUNCopenr4msvcrtlockingLK_NBLCKr5OSErrorcloser open_modefds rrEzWindowsFileLock._acquirefsII *RZZ7  ()4B (r6??A6&("         s# B&%BB#"B#& B21B2c|j}d|_tj|tjdt j | t j |jy#t$rYywxYwr{) r5rrLK_UNLCKrdrremover4rrrs rrGzWindowsFileLock._releasevse   !r6??A.    IIdoo &    sA// A;:A;rnr rrrrrErG __classcell__rys@rrrZs P  rrc0eZdZdZdfd ZdZdZxZS)rzR Uses the :func:`fcntl.flock` to hard lock the lock file on unix systems. ctjtjj|j}t ||||y)Nrv)rdstatvfsr_rg f_namemaxrxr)rrr6r;rys rrzUnixFileLock.__init__s: jj)CDNN GI\]rcjtjtjztjz}tj|j |} t j|t jt jz||_ y#t$rtj|YywxYwr#) rdr|r}r~rr4fcntlflockLOCK_EXLOCK_NBr5rrrs rrEzUnixFileLock._acquiresII *RZZ7 WWT__i 0 $ KKEMMEMM9 :"$D    HHRL  s5BB21B2c|j}d|_tj|tjt j |yr#)r5rrLOCK_UNrdrrs rrGzUnixFileLock._releases7   ! B &  rrnrrs@rrrs^  rrceZdZdZdZdZy)rz8 Simply watches the existence of the lock file. ctjtjztjztjz} tj |j |}||_y#t$rYywxYwr#) rdO_WRONLYr}O_EXCLr~rr4r5rrs rrEzSoftFileLock._acquireseKK"**,ryy82::E  $)4B"$D      s A-- A98A9ctj|jd|_ tj|jy#t $rYywxYwr#)rdrr5rr4rr's rrGzSoftFileLock._releasesM ##$!  IIdoo &   sA AAN)r rrrrErGrrrrrs rrz only soft file lock is available)rr rdr7rOwarnings ImportErrorrr TimeoutError NameErrorr__all__ __version__r rrr!rrrrrwarnrrrrs(4     l:  PPn(l(^<J<B  H HH 89_ H  F  ELsDBB!B.B;BB!B+*B+.B87B8;CC