/usr/local/lib/python3.6/site-packages/datasets/utils/__pycache__
Edit: /usr/local/lib/python3.6/site-packages/datasets/utils/__pycache__/filelock.cpython-36.pyc (10484B)
3
<%Eg5 & @ sl d Z ddlZddlZddlZddlZy ddlZW n ek
rH dZY nX y ddlZW n ek
rn dZY nX y ddlZW n ek
r dZY nX ye W n e
k
r e Z Y nX ddddddgZ d Z
dad
d ZG d d de ZG d
d dZG dd dZG dd deZG dd deZG dd deZdZerDeZn$erPeZneZedk rhejd dS )zD
A platform independent file lock that supports the with-statement.
NTimeout BaseFileLockWindowsFileLock UnixFileLock SoftFileLockFileLockz3.0.12c C s t p tjta t S )z0Returns the logger instance used in this module.)_loggerlogging getLogger__name__ r r A/usr/local/lib/python3.6/site-packages/datasets/utils/filelock.pyloggerP s r c @ s e Zd ZdZdd Zdd ZdS )r zN
Raised when the lock could not be acquired in *timeout*
seconds.
c C s
|| _ dS ) N) lock_file)selfr r r r
__init___ s zTimeout.__init__c C s d| j d}|S )NzThe file lock 'z' could not be acquired.)r )r tempr r r
__str__e s zTimeout.__str__N)r
__module__ __qualname____doc__r r r r r r
r Y s c @ s$ e Zd Zdd Zdd Zdd ZdS )_Acquire_ReturnProxyc C s
|| _ d S )N)lock)r r r r r
r v s z _Acquire_ReturnProxy.__init__c C s | j S )N)r )r r r r
__enter__z s z _Acquire_ReturnProxy.__enter__c C s | j j d S )N)r release)r exc_type exc_value tracebackr r r
__exit__} s
z _Acquire_ReturnProxy.__exit__N)r r r r r r r r r r
r u s r c @ s e Zd ZdZd!ddZedd Zedd Zejd
d Zd d Z d
d Z
edd Z d"ddZ d#ddZ
dd Zdd Zdd Zeeed d d ZdS )$r z3
Implements the base class of a file lock.
Nc C sB |dk r |nd}| j ||}|| _d| _|| _tj | _d| _dS )r N r )hash_filename_if_too_long
_lock_file
_lock_file_fdtimeout threadingLock _thread_lock
_lock_counter)r r r% max_filename_lengthr r r
r s
zBaseFileLock.__init__c C s | j S )z,
The path to the lock file.
)r# )r r r r
r s zBaseFileLock.lock_filec C s | j S )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*
)_timeout)r r r r
r% s zBaseFileLock.timeoutc C s t || _dS )r N)floatr+ )r valuer r r
r% s
c C s
t dS )z
Platform dependent. If the file lock could be
acquired, self._lock_file_fd holds the file descriptor
of the lock file.
N)NotImplementedError)r r r r
_acquire s zBaseFileLock._acquirec C s
t dS )zH
Releases the lock and sets self._lock_file_fd to None.
N)r. )r r r r
_release s zBaseFileLock._releasec C s
| j dk S )z{
True, if the object holds the file lock.
This was previously a method and is now a property.
N)r$ )r r r r
is_locked s zBaseFileLock.is_locked皙?c C sL |dkr| j }| j | jd7 _W dQ R X t| }| j}tj }yx| j, | jsvt jd| d| | j W dQ R X | jrt jd| d| P qH|dkrtj | |krt jd| d| t
| jqHt jd| d | d
| d tj | qHW W n2 | j t d| jd | _W dQ R X Y nX t
| 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.
Nr zAttempting to acquire lock z on zLock z
acquired on r zTimeout on acquiring lock z not acquired on z
, waiting z seconds ...)r )r% r( r) idr# timer1 r debugr/ r sleepmaxr )r r% Zpoll_intervalllock_id
lock_filename
start_timer r r
acquire s6 " zBaseFileLock.acquireFc C s | j t | jrv| jd8 _| jdks*|rvt| }| j}t jd| d| | j d| _t jd| d| W dQ R X dS )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 r zAttempting to release lock z on zLock z
released on N)r( r1 r) r3 r# r r5 r0 )r forcer8 r9 r r r
r " s
"zBaseFileLock.releasec C s | j | S )N)r; )r r r r
r ? s zBaseFileLock.__enter__c C s | j d S )N)r )r r r r r r r
r C s zBaseFileLock.__exit__c C s | j dd d S )NT)r< )r )r r r r
__del__G s zBaseFileLock.__del__)path
max_lengthreturnc C sr t jj|}t||krj|dkrjt jj|}tt|}|d |t| d d | d }t jj||S |S d S )Nr z...z.lock)osr> basenamelendirnamestrhashjoin)r r> r? filenamerE Zhashed_filenameZ new_filenamer r r
r" K s $z&BaseFileLock.hash_filename_if_too_long)rJ N)Nr2 )F)r r r r r propertyr r% setterr/ r0 r1 r; r r r r= rF intr" r r r r
r s
G
c s2 e Zd ZdZd fdd Zdd Zdd Z ZS ) r ze
Uses the :func:`msvcrt.locking` function to hard lock the lock file on
windows systems.
r Nc s2 ddl m} t j|||d d|| j | _d S )Nr )relative_to_absolute_path)r% r* z\\?\)Z
file_utilsrN superr r r# )r r r% r* rN ) __class__r r
r ` s zWindowsFileLock.__init__c C sx t jt jB t jB }yt j| j|}W n tk
r8 Y n
rE f_namemaxrO r )r r r% r* )rP r r
r s zUnixFileLock.__init__c C sb t jt jB t jB }t j| j|}ytj|tjtj B W n t
k
rV t j | Y nX || _ d S )N)
rB rQ rR rS rT r# fcntlflockZLOCK_EXZLOCK_NBrU rX r$ )r rY rZ r r r
r/ s zUnixFileLock._acquirec C s( | j }d | _ tj|tj tj| d S )N)r$ r_ r` ZLOCK_UNrB rX )r rZ r r r
r0 s
zUnixFileLock._releaserJ )rJ N)r r r r r r/ r0 r\ r r )rP r
r s c @ s e Zd ZdZdd Zdd ZdS )r z8
Simply watches the existence of the lock file.
c C sJ t jt jB t jB t jB }yt j| j|}W n tk
r> Y nX || _d S )N) rB O_WRONLYrR O_EXCLrS rT r# rU r$ )r rY rZ r r r
r/ s zSoftFileLock._acquirec C s< t j| j d | _yt j| j W n tk
r6 Y nX d S )N)rB rX r$ r[ r# rU )r r r r
r0 s zSoftFileLock._releaseN)r r r r r/ r0 r r r r
r s
z only soft file lock is available)r r rB r& r4 warnings ImportErrorrV r_ TimeoutError NameErrorrU __all__ __version__r r r r r r r r r warnr r r r
sX
Y/%!