/
lib
/
python3.9
/
site-packages
/
virtualenv
/
util
/
__pycache__
/
Upload File
HOME
a ��:i� � @ s� d Z ddlZddlZddlmZmZ ddlmZ ddlm Z ddl m Z m Z ddl mZmZ G dd � d e�Zi Ze � ZG d d � d ed �ZG d d� de�ZG dd� de�Zg d�ZdS )z7holds locking functionality that works across processes� N)�ABCMeta�abstractmethod)�contextmanager)�Path)�Lock�RLock)�FileLock�Timeoutc s8 e Zd Z� fdd�Zd � fdd� Zd � fdd � Z� ZS ) �_CountedFileLockc sX t j�|�}t j�|�s:zt �|� W n ty8 Y n0 t� �|� d| _t � | _ d S �Nr ) �os�path�dirname�isdir�makedirs�OSError�super�__init__�countr � thread_safe)�self� lock_file�parent�� __class__� �8/usr/lib/python3.9/site-packages/virtualenv/util/lock.pyr s z_CountedFileLock.__init__N皙�����?c sN | j j|d u rdn|d�s$t| j��| jdkr<t� �||� | jd7 _d S )N���)�timeoutr � )r �acquirer r r r )r r Z poll_intervalr r r r! s z_CountedFileLock.acquireFc sh | j �N | jdkr | j �� | jdkr4t� j|d� t| jd d�| _W d � n1 sZ0 Y d S )Nr r )�force)r r �releaser �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 | j j� d| j� d�S )N�(�))r r% r �r r r r �__repr__2 s zPathLockBase.__repr__c C s t | �| j| �S r* )�typer �r �otherr r r �__div__5 s zPathLockBase.__div__c C s | � |�S r* )r5 r3 r r r � __truediv__8 s zPathLockBase.__truediv__c C s t �d S r* ��NotImplementedErrorr0 r r r � __enter__; s zPathLockBase.__enter__c C s t �d S r* r7 �r �exc_typeZexc_valZexc_tbr r r �__exit__? s zPathLockBase.__exit__Fc C s t �d S r* r7 �r �name�no_blockr r r � lock_for_keyC s zPathLockBase.lock_for_keyc C s t �d S r* r7 �r r> r r r �non_reentrant_lock_for_keyH s z'PathLockBase.non_reentrant_lock_for_keyN)F) r% r& r' r r1 r5 r6 r r9 r< r r@ rB r r r r r) - s r) )� metaclassc 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 � �|� d | _d S r* )r r �_lock)r r- r r r r O s zReentrantFileLock.__init__� c C sX t | j|� d� �}t�, |tvr.t|�t|< t| W d � S 1 sJ0 Y d S �Nz.lock)�strr � _store_lock� _lock_storer )r r> r r r r � _create_lockS s z ReentrantFileLock._create_lockc C sn | d urjt �N | j�( | jdkr.t�| jd � W d � n1 sB0 Y W d � n1 s`0 Y d S r )rI r r rJ �popr ��lockr r r � _del_lockZ s zReentrantFileLock._del_lockc C s | � | j� d S r* )rO rE r0 r r r �__del__b s zReentrantFileLock.__del__c C s | � � | _| �| j� d S r* )rK rE � _lock_filer0 r r r r9 e s zReentrantFileLock.__enter__c C s" | � | j� | �| j� d | _d S r* )�_releaserE rO r: r r r r< i s zReentrantFileLock.__exit__Fc C sr zt �t| j�� W n ty& Y n0 z|�d� W n6 tyl |rJ� t�d|j � |� � |�� Y n0 d S )Ng-C ��6?z/lock file %s present, will block until released) r r rH r r r! r �logging�debugr r# )r rN r? r r r rQ n s z ReentrantFileLock._lock_filec C s | � � d S r* )r# rM r r r rR s zReentrantFileLock._releasec c s` | � |�}z@z | �||� d V W | �|� n | �|� 0 W | �|� d }n| �|� d }0 d S r* )rK rQ rR rO )r r> r? rN r r r r@ � s � z ReentrantFileLock.lock_for_keyc c sB t t| j|� d� ��� d V W d � n1 s40 Y d S rG )r rH r rA r r r rB � s z,ReentrantFileLock.non_reentrant_lock_for_key)rF )F)F)r% r& r' r rK � staticmethodrO rP r9 r< rQ rR r r@ rB r( r r r r rD N s rD c @ s6 e Zd Zdd� Zdd� Zed dd��Zedd � �Zd S ) � NoOpFileLockc C s t �d S r* r7 r0 r r r r9 � s zNoOpFileLock.__enter__c C s t �d S r* r7 r: r r r r< � s zNoOpFileLock.__exit__Fc c s d V d S r* r r= r r r r@ � s zNoOpFileLock.lock_for_keyc c s d V d S r* r rA r r r rB � s z'NoOpFileLock.non_reentrant_lock_for_keyN)F)r% r& r' r9 r< r r@ rB r r r r rV � s rV )rV rD r )�__doc__rS r �abcr r � contextlibr �pathlibr � threadingr r Zfilelockr r r rJ rI r) rD rV �__all__r r r r �<module> s !H