B
- ;Q @ s d Z ddlmZmZ ddlZddlZddlmZmZ ddl m
Z
ddl m Z m
Z
ddlmZmZ ddlmZ dd lmZ G d
d d eZi Ze ZeeG d d
d
eZG dd deZG dd deZdZ dS )z7holds locking functionality that works across processes )absolute_importunicode_literalsN)ABCMetaabstractmethod)contextmanager)LockRLock)FileLockTimeout)
add_metaclass)Pathc s8 e Zd Z fddZd
fdd Zd fdd Z ZS ) _CountedFileLockc s^ t j|}t j|s )r r r r __del__c s zReentrantFileLock.__del__c C s | | _| | j d S )N)rC r>
_lock_file)r r r r r4 f s
zReentrantFileLock.__enter__c C s" | | j | | j d | _d S )N)_releaser> rF )r r5 r6 r7 r r r r8 j s zReentrantFileLock.__exit__Fc C sv yt t| j W n tk
r( Y nX y|d W n8 tk
rp |rN td|j |
| Y nX d S )Ng-C 6?z/lock file %s present, will block until released) r r r@ r r r r
loggingdebugr r# )r rE r: r r r rH o s z ReentrantFileLock._lock_filec C s | d S )N)r# )rE r r r rI s zReentrantFileLock._releasec c sH | |}z(z| || d V W d | | X W d | | d }X d S )N)rC rH rI rF )r r9 r: rE r r r r; s
z ReentrantFileLock.lock_for_keyc c s. t t| jd| d V W d Q R X d S )Nz{}.lock)r
r@ r r- )r r9 r r r r< s z,ReentrantFileLock.non_reentrant_lock_for_key)r? )F)F)r% r& r' r rC staticmethodrF rG r4 r8 rH rI r r; r< r( r r )r r r= O s
r= c @ s6 e Zd Zdd Zdd Zed ddZedd Zd
S ) NoOpFileLockc C s t d S )N)r3 )r r r r r4 s zNoOpFileLock.__enter__c C s t d S )N)r3 )r r5 r6 r7 r r r r8 s zNoOpFileLock.__exit__Fc c s
d V d S )Nr )r r9 r: r r r r; s zNoOpFileLock.lock_for_keyc c s
d V d S )Nr )r r9 r r r r< s z'NoOpFileLock.non_reentrant_lock_for_keyN)F)r% r& r' r4 r8 r r; r< r r r r rM s
rM )rM r= r
) __doc__
__future__r r rJ r abcr r
contextlibr threadingr r Zfilelockr r
Zsixr Zvirtualenv.util.pathr r
rB rA objectr) r= rM __all__r r r r s" !H