U
UV\
@ sP d dl mZ d dlZd dlZddlmZmZmZmZm Z m
Z
G dd deZ dS ) )absolute_importN )LockBase
LockFailed NotLocked NotMyLock LockTimeout
AlreadyLockedc @ s: e Zd ZdZd
ddZdd Zdd Zd d
Zd d ZdS ) LinkLockFilezLock access to a file using atomic property of link(2).
>>> lock = LinkLockFile('somefile')
>>> lock = LinkLockFile('somefile', threaded=False)
Nc C s zt | jd W n" tk
r6 td| j Y nX |d k rD|n| j}t }|d k rj|dkrj||7 }zt| j| j W n t
k
r t | jj }|dkrY d S |d k rt |krt
| j |dkrtd| j ntd| j t|d k r
|d p d Y qjX d S qjd 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 Zend_timeZnlinks r /linklockfile.pyacquire s2 $zLinkLockFile.acquirec C sP | std| j n tj| js4td| j t| j t| 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| jS N)r r r" r r# r r r r! ? s zLinkLockFile.is_lockedc C s( | o&tj| jo&t| jjdkS )Nr )r! r r r" r r r r# r r r i_am_lockingB s
zLinkLockFile.i_am_lockingc C s t j| jrt | j d S r% )r r r" r r r# r r r
break_lockG s zLinkLockFile.break_lock)N) __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