B
    Kkd8
  ã               @   sL   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	 G dd„ deƒZ
dS )é    )Úabsolute_importNé   )ÚLockBaseÚ	NotLockedÚ	NotMyLockÚLockTimeoutÚAlreadyLockedc               @   sD   e Zd ZdZddd„Zddd„Zdd	„ Zd
d„ Zdd„ Zdd„ Z	dS )ÚSymlinkLockFilez'Lock access to a file using symlink(2).TNc             C   s(   t  | |||¡ tj | j¡d | _d S )Nr   )r   Ú__init__ÚosÚpathÚsplitÚunique_name)Úselfr   ÚthreadedÚtimeout© r   úE/tmp/pip-install-gxxfd9b7/pip/pip/_vendor/lockfile/symlinklockfile.pyr
      s    zSymlinkLockFile.__init__c             C   sÊ   |d k	r|n| j }t ¡ }|d k	r2|dkr2||7 }x’yt | j| j¡ W nt tk
r¼   |  ¡ rdd S |d k	ržt ¡ |krž|dkrtd| j	 ƒ‚nt
d| j	 ƒ‚t |d k	r²|d nd¡ Y q4X d S q4W d S )Nr   z&Timeout waiting to acquire lock for %sz%s is already lockedé
   gš™™™™™¹?)r   Útimer   Úsymlinkr   Ú	lock_fileÚOSErrorÚi_am_lockingr   r   r   Úsleep)r   r   Úend_timer   r   r   Úacquire   s$    
 zSymlinkLockFile.acquirec             C   s>   |   ¡ std| j ƒ‚n|  ¡ s.td| j ƒ‚t | j¡ d S )Nz%s is not lockedz%s is locked, but not by me)Ú	is_lockedr   r   r   r   r   Úunlinkr   )r   r   r   r   Úrelease6   s
    zSymlinkLockFile.releasec             C   s   t j | j¡S )N)r   r   Úislinkr   )r   r   r   r   r   =   s    zSymlinkLockFile.is_lockedc             C   s    t j | j¡ot  | j¡| jkS )N)r   r   r    r   Úreadlinkr   )r   r   r   r   r   @   s    zSymlinkLockFile.i_am_lockingc             C   s   t j | j¡rt  | j¡ d S )N)r   r   r    r   r   )r   r   r   r   Ú
break_lockD   s    zSymlinkLockFile.break_lock)TN)N)
Ú__name__Ú
__module__Ú__qualname__Ú__doc__r
   r   r   r   r   r"   r   r   r   r   r	   
   s   

#r	   )Ú
__future__r   r   r   Ú r   r   r   r   r   r	   r   r   r   r   Ú<module>   s   