ikan Uploader :
Directory : /opt/alt/python37/lib/python3.7/site-packages/virtualenv/util/__pycache__/
Upload File : |
| Current File : //opt/alt/python37/lib/python3.7/site-packages/virtualenv/util/__pycache__/lock.cpython-37.pyc |
B
���a� � @ s� d Z ddlmZmZ ddlZddlZddlmZmZ ddl m
Z
ddl m Z m
Z
ddlmZmZ ddlmZ dd lmZ G d
d � d e�Zi Ze � Zee�G d d
� d
e��ZG dd� de�ZG dd� de�ZdZ dS )z7holds locking functionality that works across processes� )�absolute_import�unicode_literalsN)�ABCMeta�abstractmethod)�contextmanager)�Lock�RLock)�FileLock�Timeout)�
add_metaclass)�Pathc s8 e Zd Z� fdd�Zd
� fdd� Zd � fdd � Z� ZS ) �_CountedFileLockc s^ t j�|�}t j�|�s<yt �|� W n tk
r: Y nX tt| ��|� d| _ t
� | _ d S )Nr ) �os�path�dirname�isdir�makedirs�OSError�superr
�__init__�countr � thread_safe)�self� lock_file�parent)� __class__� �E/opt/alt/python37/lib/python3.7/site-packages/virtualenv/util/lock.pyr s z_CountedFileLock.__init__N皙�����?c s@ | j �0 | jdkr$tt| ��||� | jd7 _W d Q R X d S )Nr � )r r r r
�acquire)r �timeoutZ
poll_interval)r r r r s
z_CountedFileLock.acquireFc sD | j �4 | jdkr$tt| �j|d� t| jd d�| _W d Q R X d S )Nr )�forcer )r r r r
�release�max)r r" )r r r r# " s
z_CountedFileLock.release)Nr )F)�__name__�
__module__� __qualname__r r r# �
__classcell__r r )r r r
s r
c @ sf e Zd Zdd� Zdd� Zdd� Zdd� Zed d
� �Zed d � �Z ee
ddd���Z ee
dd� ��Z dS )� PathLockBasec C s" t |�}|�� r|�� n|| _d S )N)r �exists�resolver )r �folderr r r r r / s zPathLockBase.__init__c C s d� | jj| j�S )Nz{}({}))�formatr r% r )r r r r �__repr__3 s zPathLockBase.__repr__c C s t | �| j| �S )N)�typer )r �otherr r r �__div__6 s zPathLockBase.__div__c C s
| � |�S )N)r1 )r r0 r r r � __truediv__9 s zPathLockBase.__truediv__c C s t �d S )N)�NotImplementedError)r r r r � __enter__< s zPathLockBase.__enter__c C s t �d S )N)r3 )r �exc_type�exc_val�exc_tbr r r �__exit__@ s zPathLockBase.__exit__Fc C s t �d S )N)r3 )r �name�no_blockr r r � lock_for_keyD s zPathLockBase.lock_for_keyc C s t �d S )N)r3 )r9 r r r �non_reentrant_lock_for_keyI s z'PathLockBase.non_reentrant_lock_for_keyN)F)
r% r& r' r r. r1 r2 r r4 r8 r r; r< r r r r r) - s r) c sz e Zd Z� fdd�Zddd�Zedd� �Zdd � Zd
d � Zd d
� Z ddd�Z
edd� �Z e ddd��Z
e dd� �Z� ZS )�ReentrantFileLockc s t t| ��|� d | _d S )N)r r= r �_lock)r r, )r r r r P s zReentrantFileLock.__init__� c C s@ t | jd�|� �}t� |tkr.t|�t|< t| S Q R X d S )Nz{}.lock)�strr r- � _store_lock� _lock_storer
)r r9 r r r r � _create_lockT s
z ReentrantFileLock._create_lockc
C sF | d k rBt �0 | j� | jdkr.t�| jd � W d Q R X W d Q R X d S )Nr )rA r r rB �popr )�lockr r r � _del_lock[ s
zReentrantFileLock._del_lockc C s | � | j� d S )N)rF r> )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� t�d|j � |�
� |�� Y nX d S )Ng-C ��6?z/lock file %s present, will block until released) r r r@ r r r r
�logging�debugr 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 dd��Zedd � �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 �<module> s" !H
........