File: //usr/lib/python3/dist-packages/virtualenv/util/__pycache__/lock.cpython-310.pyc
o
$�"b� � @ 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 zt �|� W n ty Y nw tt| ��|� d| _ t
� | _ d S �Nr ) �os�path�dirname�isdir�makedirs�OSError�superr
�__init__�countr � thread_safe)�self� lock_file�parent�� __class__� �6/usr/lib/python3/dist-packages/virtualenv/util/lock.pyr s � z_CountedFileLock.__init__N皙�����?c sV | j � | jdkrtt| ��||� | jd7 _W d � d S 1 s$w Y d S )Nr � )r r r r
�acquire)r �timeout�
poll_intervalr r r r" s
"�z_CountedFileLock.acquireFc sZ | j � | jdkrtt| �j|d� t| jd d�| _W d � d S 1 s&w Y 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|�� | _d S || _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 � zPathLockBase.__repr__c C s t | �| j| �S r. )�typer �r �otherr r r �__div__6 r5 zPathLockBase.__div__c C s
| � |�S r. )r9 r7 r r r � __truediv__9 s
zPathLockBase.__truediv__c C � t �r. ��NotImplementedErrorr3 r r r � __enter__< � zPathLockBase.__enter__c C r; r. r< �r �exc_type�exc_val�exc_tbr r r �__exit__@ r? zPathLockBase.__exit__Fc C r; r. r< �r �name�no_blockr r r � lock_for_keyD � zPathLockBase.lock_for_keyc C r; r. r< )rF r r r �non_reentrant_lock_for_keyI rI z'PathLockBase.non_reentrant_lock_for_keyNr( )
r) r* r+ r r4 r9 r: r r> rD r rH rJ 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 r. )r rK r �_lock)r r1 r r r r P s
zReentrantFileLock.__init__� c C sX t | jd�|� �}t� |tvrt|�t|< t| W d � S 1 s%w Y d S �Nz{}.lock)�strr r2 � _store_lock� _lock_storer
)r rF r r r r � _create_lockT s $�z ReentrantFileLock._create_lockc C s� | d ur@t �0 | j� | jdkrt�| jd � W d � n1 s!w Y W d � d S W d � d S 1 s9w Y d S d S r )rP r r rQ �popr ��lockr r r � _del_lock[ s
� ��"��zReentrantFileLock._del_lockc C s | � | j� d S r. )rV rL r3 r r r �__del__c s zReentrantFileLock.__del__c C s | � � | _| �| j� d S r. )rR rL �
_lock_filer3 r r r r> f s
zReentrantFileLock.__enter__c C s" | � | j� | �| j� d | _d S r. )�_releaserL rV r@ r r r rD j s
zReentrantFileLock.__exit__Fc C sr z
t �t| j�� W n ty Y nw z|�d� W d S ty8 |r&� t�d|j � |�
� |�� Y d S w )Ng-C ��6?z/lock file %s present, will block until released) r r rO r r r" r
�logging�debugr r& )r rU rG r r r rX o s � �z ReentrantFileLock._lock_filec C s | � � d S r. )r& rT r r r rY � s zReentrantFileLock._releasec c s` � | � |�}z!z| �||� d V W | �|� n| �|� w W | �|� d }d S | �|� d }w r. )rR rX rY rV )r rF rG rU r r r rH � s �
�z ReentrantFileLock.lock_for_keyc c sF � t t| jd�|� ��� d V W d � d S 1 s w Y d S rN )r
rO r r2 �r rF r r r rJ � s �"�z,ReentrantFileLock.non_reentrant_lock_for_key)rM r( )r) r* r+ r rR � staticmethodrV rW r> rD rX rY r rH rJ r, r r r r rK O s
rK c @ s6 e Zd Zdd� Zdd� Zed dd��Zedd � �Zd
S ) � NoOpFileLockc C r; r. r< r3 r r r r> � � zNoOpFileLock.__enter__c C r; r. r< r@ r r r rD � r_ zNoOpFileLock.__exit__Fc c � � d V d S r. r rE r r r rH � � �
zNoOpFileLock.lock_for_keyc c r` r. r r\ r r r rJ � ra z'NoOpFileLock.non_reentrant_lock_for_keyNr( )r) r* r+ r> rD r rH rJ r r r r r^ � s r^ )r^ rK r
) �__doc__�
__future__r r rZ r �abcr r �
contextlibr � threadingr r �filelockr r
�sixr �virtualenv.util.pathr r
rQ rP �objectr- rK r^ �__all__r r r r �<module> s$ !H