UV\
@ sp d d l m Z d d l Z d d l Z d d l m Z m Z m Z m Z m Z m
Z
Gd d d e Z d S) )absolute_importN )LockBase
LockFailed NotLocked NotMyLock LockTimeout
AlreadyLockedc @ sU e Z d Z d Z d d d Z d d Z d d Z d d
Z d d Z d S)
LinkLockFilezLock access to a file using atomic property of link(2).
>>> lock = LinkLockFile('somefile')
>>> lock = LinkLockFile('somefile', threaded=False)
Nc C st y t | j d j Wn% t k
rA t d | j Yn X| d k rT | n | j } t j } | d k r | d k r | | 7} x y t j | j | j Wn t
k
rgt j | j j } | d k r d S| d k r@t j | k r@t j
| j | d k r-t d | j n t d | j t j | d k r\| d p_d Yq Xd Sq Wd S) Nwbzfailed to create %sr z&Timeout waiting to acquire lock for %sz%s is already locked
g?)open unique_namecloseIOErrorr timeouttimeoslink lock_fileOSErrorstatst_nlinkunlinkr pathr sleep)selfr end_timeZnlinks r /linklockfile.pyacquire s0
(zLinkLockFile.acquirec C sn | j s" t d | j n( t j j | j sJ t d | j t j | j t j | j d S)Nz%s is not lockedz%s is locked, but not by me) is_lockedr r r existsr r r r )r r r r release7 s zLinkLockFile.releasec C s t j j | j S)N)r r r# r )r r r r r" ? s zLinkLockFile.is_lockedc C s: | j o9 t j j | j o9 t j | j j d k S)Nr )r" r r r# r r r )r r r r i_am_lockingB s zLinkLockFile.i_am_lockingc C s) t j j | j r% t j | j d S)N)r r r# r r )r r r r
break_lockG s zLinkLockFile.break_lock) __name__
__module__ __qualname____doc__r! r$ r" r% r& r r r r r
s & r
) Z
__future__r r r r r r r r r r
r r r r <module> s .