3 �Pf�@sdddlmZmZddlZddlZddlZddlZddlmZm Z m Z mZmZm Z Gdd�de�ZdS)�)�absolute_import�divisionN�)�LockBase� LockFailed� NotLocked� NotMyLock�LockTimeout� AlreadyLockedc@sDeZdZdZddd�Zddd�Zdd �Zd d�Zdd �Zdd�Z dS)� MkdirLockFilez"Lock file by creating a directory.TNcCs6tj||||�tjj|jd|j|j|jf�|_ dS)zs >>> lock = MkdirLockFile('somefile') >>> lock = MkdirLockFile('somefile', threaded=False) z%s.%s%sN) r�__init__�os�path�join� lock_fileZhostnameZtname�pid�unique_name)�selfrZthreaded�timeout�r�#/usr/lib/python3.6/mkdirlockfile.pyrs zMkdirLockFile.__init__cCs|dk r|n|j}tj�}|dk r2|dkr2||7}|dkr@d}ntd|d�}x�ytj|j�Wn�tk r�tj�d}|j t j kr�tjj|j �r�dS|dk r�tj�|kr�|dkr�td|j��ntd|j��tj|�ntd|j��YqPXt|j d�j�dSqPWdS) Nrg��?� rz&Timeout waiting to acquire lock for %sz%s is already lockedzfailed to create %s�wb)r�time�maxr �mkdirr�OSError�sys�exc_info�errnoZEEXISTr�existsrr r Zsleepr�open�close)rrZend_time�wait�errrrr�acquires2 zMkdirLockFile.acquirecCsP|j�std|j��ntjj|j�s4td|j��tj|j�tj|j �dS)Nz%s is not lockedz%s is locked, but not by me) � is_lockedrrr r rr�unlink�rmdirr)rrrr�releaseAszMkdirLockFile.releasecCstjj|j�S)N)r rr r)rrrrr&IszMkdirLockFile.is_lockedcCs|j�otjj|j�S)N)r&r rr r)rrrr�i_am_lockingLszMkdirLockFile.i_am_lockingcCsJtjj|j�rFx*tj|j�D]}tjtjj|j|��qWtj|j�dS)N)r rr r�listdirr'rr()r�namerrr� break_lockPszMkdirLockFile.break_lock)TN)N) �__name__� __module__�__qualname__�__doc__rr%r)r&r*r-rrrrrs &r)Z __future__rrrr rr�rrrrr r rrrrr�s