3
™©Þ[  ã               @   sd   d dl mZmZ d dlZd dlZd dlZd dlZddlmZm	Z	m
Z
mZmZmZ G dd„ deƒZdS )é    )Úabsolute_importÚdivisionNé   )ÚLockBaseÚ
LockFailedÚ	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 )ÚMkdirLockFilez"Lock file by creating a directory.TNc             C   s6   t j| |||ƒ tjj| jd| j| j| jf ƒ| _	dS )zs
        >>> lock = MkdirLockFile('somefile')
        >>> lock = MkdirLockFile('somefile', threaded=False)
        z%s.%s%sN)
r   Ú__init__ÚosÚpathÚjoinÚ	lock_fileÚhostnameÚtnameÚpidÚunique_name)Úselfr   ÚthreadedÚtimeout© r   úC/tmp/pip-install-65viz3iy/pip/pip/_vendor/lockfile/mkdirlockfile.pyr      s
    
zMkdirLockFile.__init__c             C   s  |d k	r|n| j }tjƒ }|d k	r2|dkr2||7 }|d kr@d}ntd|d ƒ}x¼ytj| jƒ W n’ tk
rò   tjƒ d }|j	t	j
kràtjj| jƒršd S |d k	rÔtjƒ |krÔ|dkrÆtd| j ƒ‚ntd| j ƒ‚tj|ƒ ntd| j ƒ‚Y qPX t| jdƒjƒ  d S qPW d S )	Nr   gš™™™™™¹?é
   r   z&Timeout waiting to acquire lock for %sz%s is already lockedzfailed to create %sÚwb)r   ÚtimeÚmaxr   Úmkdirr   ÚOSErrorÚsysÚexc_infoÚerrnoÚEEXISTr   Úexistsr   r	   r
   Úsleepr   ÚopenÚclose)r   r   Úend_timeÚwaitÚerrr   r   r   Úacquire   s2    
zMkdirLockFile.acquirec             C   sP   | j ƒ std| j ƒ‚ntjj| jƒs4t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   r$   r   r   ÚunlinkÚrmdirr   )r   r   r   r   ÚreleaseA   s    zMkdirLockFile.releasec             C   s   t jj| jƒS )N)r   r   r$   r   )r   r   r   r   r,   I   s    zMkdirLockFile.is_lockedc             C   s   | j ƒ otjj| jƒS )N)r,   r   r   r$   r   )r   r   r   r   Úi_am_lockingL   s    zMkdirLockFile.i_am_lockingc             C   sJ   t jj| jƒrFx*t j| jƒD ]}t jt jj| j|ƒƒ qW t j| jƒ d S )N)r   r   r$   r   Úlistdirr-   r   r.   )r   Únamer   r   r   Ú
break_lockP   s    zMkdirLockFile.break_lock)TN)N)
Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r+   r/   r,   r0   r3   r   r   r   r   r      s   

&r   )Ú
__future__r   r   r   r   r    r"   Ú r   r   r   r   r	   r
   r   r   r   r   r   Ú<module>   s    