B ��a��@s�dZddlmZmZddlZddlZddlmZmZddl m Z ddlmZm Z ddlmZmZddlmZdd lmZGd d�de�ZiZe�Zee�Gdd �d e��ZGdd�de�ZGdd�de�ZdZdS)z7holds locking functionality that works across processes�)�absolute_import�unicode_literalsN)�ABCMeta�abstractmethod)�contextmanager)�Lock�RLock)�FileLock�Timeout)� add_metaclass)�Pathcs8eZdZ�fdd�Zd �fdd� Zd�fdd � Z�ZS)�_CountedFileLockcs^tj�|�}tj�|�s)rrrr�__del__cszReentrantFileLock.__del__cCs|��|_|�|j�dS)N)rCr>� _lock_file)rrrrr4fs zReentrantFileLock.__enter__cCs"|�|j�|�|j�d|_dS)N)�_releaser>rF)rr5r6r7rrrr8jszReentrantFileLock.__exit__FcCsvyt�t|j��Wntk r(YnXy|�d�Wn8tk rp|rN�t�d|j �|� �|��YnXdS)Ng-C��6?z/lock file %s present, will block until released)rrr@rrr r �logging�debugrr#)rrEr:rrrrHoszReentrantFileLock._lock_filecCs|��dS)N)r#)rErrrrI�szReentrantFileLock._releasec csH|�|�}z(z|�||�dVWd|�|�XWd|�|�d}XdS)N)rCrHrIrF)rr9r:rErrrr;�s zReentrantFileLock.lock_for_keyc cs.tt|jd�|��dVWdQRXdS)Nz{}.lock)r r@rr-)rr9rrrr<�sz,ReentrantFileLock.non_reentrant_lock_for_key)r?)F)F)r%r&r'rrC�staticmethodrFrGr4r8rHrIrr;r<r(rr)rrr=Os r=c@s6eZdZdd�Zdd�Zeddd��Zedd ��Zd S)�NoOpFileLockcCst�dS)N)r3)rrrrr4�szNoOpFileLock.__enter__cCst�dS)N)r3)rr5r6r7rrrr8�szNoOpFileLock.__exit__Fccs dVdS)Nr)rr9r:rrrr;�szNoOpFileLock.lock_for_keyccs dVdS)Nr)rr9rrrr<�sz'NoOpFileLock.non_reentrant_lock_for_keyN)F)r%r&r'r4r8rr;r<rrrrrM�s rM)rMr=r )�__doc__� __future__rrrJr�abcrr� contextlibr� threadingrrZfilelockr r ZsixrZvirtualenv.util.pathrr rBrA�objectr)r=rM�__all__rrrr�s"!H