File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/docker/transport/__pycache__/sshconn.cpython-310.pyc
Back
o �h� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z ddl mZ ddlmZ e jjZG dd� dej�ZG dd � d e jj�ZG d d � d e jj�ZG d d � d e�ZdS )� N� )� constants� )�BaseHTTPAdapterc sT e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z � Z S )� SSHSocketc sj t � �tjtj� || _d | _d | _d| jv r!| j�d�\| _| _d| jv r0| j�d�\| _| _d | _ d S )N�:�@) �super�__init__�socket�AF_INET� SOCK_STREAM�host�port�user�split�proc)�selfr �� __class__� �K/usr/local/CyberCP/lib/python3.10/site-packages/docker/transport/sshconn.pyr s � zSSHSocket.__init__c K s� dg}| j r |d| j g }| jr|d| jg }|d| jdg }d }tjs*dd� }|}ttj�}|�dd � |�d d � t j ||t j t j |d �| _ d S ) N�sshz-lz-pz--�docker system dial-stdioc S s t � t jt j� d S �N)�signal�SIGINT�SIG_IGNr r r r �f. s z SSHSocket.connect.<locals>.f�LD_LIBRARY_PATH� SSL_CERT_FILE)�env�stdout�stdin� preexec_fn) r r r r �IS_WINDOWS_PLATFORM�dict�os�environ�pop� subprocess�Popen�PIPEr )r �kwargs�args� preexec_funcr r! r r r �connect" s( �zSSHSocket.connectc C s6 | j r| j jjr td��| j j�|�}| j j�� |S �Nz<SSH subprocess not initiated.connect() must be called first.)r r# �closed� Exception�write�flush)r �data�writtenr r r �_write? s zSSHSocket._writec C s | � |� d S r �r8 �r r6 r r r �sendallG s zSSHSocket.sendallc C s | � |�S r r9 r: r r r �sendJ s zSSHSocket.sendc C s | j std��| j j�|�S r1 )r r3 r" �read)r �nr r r �recvM s zSSHSocket.recvc C s | j s| �� | | j j_| j jS r )r r0 r" �channel)r �moder r r �makefileS s zSSHSocket.makefilec C s< | j r| j jjr d S | j j�d� | j j�� | j �� d S )Ns )r r# r2 r4 r5 � terminate�r r r r �closeZ s zSSHSocket.close) �__name__� __module__� __qualname__r r0 r8 r; r< r? rB rE � __classcell__r r r r r s r c s& e Zd Zd� fdd� Zdd� Z� ZS )� SSHConnectionN�< c s& t � jd|d� || _|| _|| _d S )N� localhost)�timeout)r r � ssh_transportrM �ssh_host)r rN rM r r r r r c s � zSSHConnection.__init__c C sP | j r| j �� }|�| j� |�d� nt| j�}|�| j� |�� || _d S )Nr ) rN � open_session� settimeoutrM � exec_commandr rO r0 �sock)r rS r r r r0 k s zSSHConnection.connect)NrK N)rF rG rH r r0 rI r r r r rJ b s rJ c s2 e Zd ZdZd � fdd� Zdd� Zd d � Z� ZS ) �SSHConnectionPoolr NrK � c s6 t � jd||d� d | _|| _|r|�� | _|| _d S )NrL )rM �maxsize)r r rN rM � get_transportrO )r � ssh_clientrM rV r r r r r { s � zSSHConnectionPool.__init__c C s t | j| j| j�S r )rJ rN rM rO rD r r r � _new_conn� s zSSHConnectionPool._new_connc C sx d }z | j j| j|d�}W n( ty! } ztj�| d�|�d }~w tjy5 | jr3tj� | d�d �Y nw |p;| � � S )N)�blockrM zPool is closed.z>Pool reached maximum size and no more connections are allowed.) �pool�getrZ �AttributeError�urllib3� exceptions�ClosedPoolError�queue�Empty�EmptyPoolErrorrY )r rM �conn�aer r r � _get_conn� s" ����� zSSHConnectionPool._get_conn)NrK rU N)rF rG rH �schemer rY rf rI r r r r rT x s rT c sb e Zd Zejjjg d� Zdejej df� fdd� Z dd� Z dd � Z dd d �Z � fd d�Z� ZS )�SSHHTTPAdapter)�poolsrM rX � ssh_params� max_pool_sizerK Fc sj d | _ |s| �|� | �� || _|�d�r |td�d � | _|| _|| _t|dd� d�| _ t � � � d S )Nzssh://c S s | � � S r )rE )�pr r r �<lambda>� s z)SSHHTTPAdapter.__init__.<locals>.<lambda>)� dispose_func) rX �_create_paramiko_client�_connectrO � startswith�lenrM rk �RecentlyUsedContainerri r r )r �base_urlrM �pool_connectionsrk � shell_outr r r r � s �zSSHHTTPAdapter.__init__c C s@ t �d��t j� t�� | _tj� |�}|j |j |j d�| _ tj�d�}tj�|�r�t�� }t|�� }|�|� W d � n1 sBw Y |�|j �}d|v r[t�|d �| j d< d|v rf|d | j d< |j d u rvd|v rv|d | j d< |j d u r�d|v r�|d | j d < d |v r�|d | j d < | j�� | j�t�� � d S ) N�paramiko)�hostnamer �usernamez ~/.ssh/config� proxycommandrS rx r r ry � identityfile� key_filename)�logging� getLogger�setLevel�WARNINGrw � SSHClientrX �urllib�parse�urlparserx r ry rj r' �path� expanduser�exists� SSHConfig�open�lookup� ProxyCommand�load_system_host_keys�set_missing_host_key_policy� RejectPolicy)r rt �ssh_config_file�confr � host_configr r r ro � s8 � � � z&SSHHTTPAdapter._create_paramiko_clientc C s" | j r| j jdi | j�� d S d S )Nr )rX r0 rj rD r r r rp � s �zSSHHTTPAdapter._connectNc C s� | j st| j | j| j| jd�S | jj�7 | j�|�}|r%|W d � S | j r1| j �� s1| � � t| j | j| j| jd�}|| j|< W d � |S 1 sMw Y |S )N)rX rM rV r ) rX rT rM rk rO ri �lockr\ rW rp )r �url�proxiesr[ r r r �get_connection� s2 � �� ��z SSHHTTPAdapter.get_connectionc s" t � �� | jr| j�� d S d S r )r rE rX rD r r r rE � s �zSSHHTTPAdapter.closer )rF rG rH �requests�adapters� HTTPAdapter� __attrs__r �DEFAULT_NUM_POOLS�DEFAULT_MAX_POOL_SIZEr ro rp r� rE rI r r r r rh � s � rh )r} r' ra r r r* � urllib.parser� rw �requests.adaptersr� r^ �urllib3.connection� r �basehttpadapterr � _collectionsrs r � connection�HTTPConnectionrJ �connectionpool�HTTPConnectionPoolrT rh r r r r �<module> s$ N'
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings