File: //usr/local/lib/python3.10/dist-packages/virtualenv/util/__pycache__/lock.cpython-310.pyc
o
3�h� � @ s� d Z ddlmZ ddlZddlZddlmZmZ ddlm Z m
Z
ddl m Z ddl
mZmZ ddlmZmZ e�e�ZG d d
� d
e�Zi Ze� ZG d d � d e�ZG d
d� de�ZG dd� de�Zg d�Z dS )z8holds locking functionality that works across processes.� )� annotationsN)�ABC�abstractmethod)�contextmanager�suppress)�Path)�Lock�RLock)�FileLock�Timeoutc s: e Zd Zd � fdd� Zd
� fdd� Zd� fd
d � Z� ZS )�_CountedFileLock�return�Nonec sh t j�|�}t j�|�s%tt��
t �|� W d � n1 s w Y t� �|� d| _ t
� | _ d S �Nr ) �os�path�dirname�isdirr �OSError�makedirs�super�__init__�countr � thread_safe)�self� lock_file�parent�� __class__� �?/usr/local/lib/python3.10/dist-packages/virtualenv/util/lock.pyr s
� z_CountedFileLock.__init__N皙�����?c sn | j j|d u r dn|d�st| j��| jdkr.z t� �||� W n
ty- | j �� � w | jd7 _d S )N���)�timeoutr � )r �acquirer r r r �
BaseException�release)r r# �
poll_intervalr r r r% s
�z_CountedFileLock.acquireFc s� | j �; | jdkr.| jdkrt� j|d� | jd8 _| jdkr6| j �� W d � d S W d � d S W d � d S 1 sAw Y d S )Nr r$ )�force)r r r r' )r r) r r r r' ' s
��"�z_CountedFileLock.release�r
r )Nr! �F)�__name__�
__module__� __qualname__r r% r' �
__classcell__r r r r r s
r c @ sb e Zd Zddd�Zddd�Zdd � Zed
d � �Zed d
� �Zee ddd���Z
ee dd� ��Z dS )� PathLockBaser
r c C s( t |�}|�� r|�� | _d S || _d S �N)r �exists�resolver )r �folderr r r r r 7 s zPathLockBase.__init__�strc C s | j j� d| j� d�S )N�(�))r r, r �r r r r �__repr__; s zPathLockBase.__repr__c C s t | �| j| �S r1 )�typer )r �otherr r r � __truediv__> s zPathLockBase.__truediv__c C � t �r1 ��NotImplementedErrorr8 r r r � __enter__A � zPathLockBase.__enter__c C r= r1 r> �r �exc_type�exc_val�exc_tbr r r �__exit__E rA zPathLockBase.__exit__Fc C r= r1 r> �r �name�no_blockr r r � lock_for_keyI � zPathLockBase.lock_for_keyc C r= r1 r> �r rH r r r �non_reentrant_lock_for_keyN rK z'PathLockBase.non_reentrant_lock_for_keyNr* )r
r5 r+ ) r, r- r. r r9 r< r r@ rF r rJ rM r r r r r0 6 s
r0 c s~ e Zd Zd� fdd� Zddd�Zedd � �Zdd
d �Zd d
� Zdd� Z ddd�Z
edd� �Z e ddd��Z
e dd� �Z� ZS ) �ReentrantFileLockr
r c s t � �|� d | _d S r1 )r r �_lock)r r4 r r r r U s
zReentrantFileLock.__init__� c C sX t | j|� d� �}t� |tvrt|�t|< t| W d � S 1 s%w Y d S �Nz.lock)r5 r � _store_lock� _lock_storer )r rH r r r r � _create_lockY 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 )rR r r rS �popr ��lockr r r � _del_lock` s
�P��zReentrantFileLock._del_lockc C s | � | j� d S r1 )rX rO r8 r r r �__del__g s zReentrantFileLock.__del__c C s | � � | _| �| j� d S r1 )rT rO �
_lock_filer8 r r r r@ j s
zReentrantFileLock.__enter__c C s" | � | j� | �| j� d | _d S r1 )�_releaserO rX rB r r r rF n s
zReentrantFileLock.__exit__Fc C s� t t�� t�t| j�� W d � n1 sw Y z|�d� W d S ty@ |r.� t� d|j
� |� � |�� Y d S w )Ng-C ��6?z/lock file %s present, will block until released) r r r r r5 r r% r �LOGGER�debugr r' )r rW rI r r r rZ s s
� �z ReentrantFileLock._lock_filec C s | � � d S r1 )r' rV r r r r[ � s zReentrantFileLock._releasec c s` � | � |�}z!z| �||� d V W | �|� n| �|� w W | �|� d }d S | �|� d }w r1 )rT rZ r[ rX )r rH rI rW r r r rJ � s �
�z ReentrantFileLock.lock_for_keyc c sF � t t| j|� d� ��� d V W d � d S 1 s w Y d S rQ )r r5 r rL r r r rM � s �"�z,ReentrantFileLock.non_reentrant_lock_for_keyr* )rP r+ )r, r- r. r rT � staticmethodrX rY r@ rF rZ r[ r rJ rM r/ r r r r rN T s
rN c @ s6 e Zd Zdd� Zdd� Zed dd��Zedd � �Zd
S ) � NoOpFileLockc C r= r1 r> r8 r r r r@ � � zNoOpFileLock.__enter__c C r= r1 r> rB r r r rF � r` zNoOpFileLock.__exit__Fc c � � d V d S r1 r rG r r r rJ � � �
zNoOpFileLock.lock_for_keyc c ra r1 r rL r r r rM � rb z'NoOpFileLock.non_reentrant_lock_for_keyNr+ )r, r- r. r@ rF r rJ rM r r r r r_ � s r_ )r_ rN r ) �__doc__�
__future__r �loggingr �abcr r �
contextlibr r �pathlibr � threadingr r �filelockr
r � getLoggerr, r\ r rS rR r0 rN r_ �__all__r r r r �<module> s"
! F