| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.9/site-packages/hgext/remotefilelog/__pycache__/ |
Upload File : |
a
�+�b� � @ sN d dl mZ d dlmZmZmZmZ ejZG dd� de �Z
G dd� de �Z dS )� )�absolute_import)�hg�pycompat�sshpeer�utilc @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�connectionpoolc C s || _ t� | _d S �N)�_repo�dict�_pool)�selfZrepo� r
�H/usr/lib64/python3.9/site-packages/hgext/remotefilelog/connectionpool.py�__init__ s zconnectionpool.__init__c s� | j �|�}|d u r$t� }|| j |< d }t|�dkrvz.|�� }|j}t|t�r`|j� � d ur`d }W n t
yt Y n0 |d u r�t �| j j
i |�}t�|d�r�G � fdd�d|j�� � |_t||�}|S )Nr �_cleanupc s e Zd Zd� �fdd� Z� ZS )z"connectionpool.get.<locals>.mypeerNc s$ t �| d�r| j�� t�| ��� S )N�pipee)r � safehasattrr �close�superr )r �warn)� __class__�mypeerr
r r 1 s
z+connectionpool.get.<locals>.mypeer._cleanup)N)�__name__�
__module__� __qualname__r �
__classcell__r
�r )r r r 0 s r )r �get�list�len�pop�peer�
isinstance�
_sshv1peerZ _subprocessZpoll�
IndexErrorr r Zuir r r �
connection)r �path�pathpool�connr! r
r r r s*
zconnectionpool.getc C s2 t �| j�D ] }|D ] }|�� q|d d �= q d S r )r Z
itervaluesr r )r r' r( r
r
r r ? s
zconnectionpool.closeN)r r r r r r r
r
r
r r s &r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r% c C s || _ || _d S r )r r! )r Zpoolr! r
r
r r G s zconnection.__init__c C s | S r r
�r r
r
r � __enter__K s zconnection.__enter__c C s" |d u r| j �| � n| �� d S r )r �appendr )r �type�value� tracebackr
r
r �__exit__N s zconnection.__exit__c C s t �| jd�r| j�� d S )N�cleanup)r r r! r0 r) r
r
r r W s zconnection.closeN)r r r r r* r/ r r
r
r
r r% F s r% N) Z
__future__r Z mercurialr r r r Z sshv1peerr# �objectr r% r
r
r
r �<module> s 2