← Back
Editing: 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
Save File
Cancel