Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/conch/ssh/__pycache__/forwarding.cpython-39.pyc
Ðазад
a k�h! � @ s� d Z ddlZddlmZmZ ddlmZmZ ddlm Z m Z G dd� dej �Z G dd � d ej �ZG d d � d e�ZG d d � d e�ZG dd� dej �Zdd� ZG dd� dej�Zdd� ZeZdd� ZeZdd� Zdd� ZdS ) z� This module contains the implementation of the TCP forwarding, which allows clients and servers to forward arbitrary TCP data across the connection. Maintainer: Paul Swartz � N)�channel�common)�protocol�reactor)�HostnameEndpoint�connectProtocolc @ s e Zd Zdd� Zdd� ZdS )�SSHListenForwardingFactoryc C s || _ || _|| _d S �N)�conn�hostport�klass)�self� connectionr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/conch/ssh/forwarding.py�__init__ s z#SSHListenForwardingFactory.__init__c C sF | j | jd�}t|�}||_|j|jf}t| j|�}| j�||� |S )N)r ) r r �SSHForwardingClient�client�host�port�packOpen_direct_tcpipr Z openChannel)r �addrr r Z addrTupleZchannelOpenDatar r r � buildProtocol s z(SSHListenForwardingFactory.buildProtocolN)�__name__� __module__� __qualname__r r r r r r r s r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �SSHListenForwardingChannelc C sH | j jd| jd� t| jj�dkr<| jjdd � }| �|� d| j_d S )Nz opened forwarding channel {id}��id� � )�_log�infor �lenr �buf�write)r � specificData�br r r � channelOpen$ s z&SSHListenForwardingChannel.channelOpenc C s | � � d S r )�closed�r �reasonr r r � openFailed+ s z%SSHListenForwardingChannel.openFailedc C s | j j�|� d S r )r � transportr% �r �datar r r � dataReceived. s z'SSHListenForwardingChannel.dataReceivedc C s | j j�� d S r )r r- �loseConnection�r r r r � eofReceived1 s z&SSHListenForwardingChannel.eofReceivedc C s0 t | d�r,| jjd| jd� | jj�� | `d S )Nr z%closing local forwarding channel {id}r )�hasattrr! r" r r r- r1 r2 r r r r) 4 s z!SSHListenForwardingChannel.closedN)r r r r( r, r0 r3 r) r r r r r # s r c @ s e Zd ZdZdS )� SSHListenClientForwardingChannels direct-tcpipN�r r r �namer r r r r5 ; s r5 c @ s e Zd ZdZdS )� SSHListenServerForwardingChannels forwarded-tcpipNr6 r r r r r8 @ s r8 c @ sD e Zd ZdZeZdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z dS )�SSHConnectForwardingChannela� Channel used for handling server side forwarding request. It acts as a client for the remote forwarding destination. @ivar hostport: C{(host, port)} requested by client as forwarding destination. @type hostport: L{tuple} or a C{sequence} @ivar client: Protocol connected to the forwarding destination. @type client: L{protocol.Protocol} @ivar clientBuf: Data received while forwarding channel is not yet connected. @type clientBuf: L{bytes} @var _reactor: Reactor used for TCP connections. @type _reactor: A reactor. @ivar _channelOpenDeferred: Deferred used in testing to check the result of C{channelOpen}. @type _channelOpenDeferred: L{twisted.internet.defer.Deferred} c O s0 t jj| g|�R i |�� || _d | _d| _d S )Nr )r � SSHChannelr r r � clientBuf)r r �args�kwr r r r _ s z$SSHConnectForwardingChannel.__init__c C s` | j jd| jd | jd d� t| j| jd | jd �}t|t| ��}|�| j| j � || _ dS )�, See: L{channel.SSHChannel} zconnecting to {host}:{port}r r �r r N) r! r" r r �_reactorr r Z addCallbacks� _setClient�_closeZ_channelOpenDeferred)r r& �ep�dr r r r( e s �z'SSHConnectForwardingChannel.channelOpenc C sr || _ | jjd| jd | jd d� | jr@| j j�| j� d| _| j jdd� rf| �| j jdd� � d| j _dS )z� Called when the connection was established to the forwarding destination. @param client: Client protocol connected to the forwarding destination. @type client: L{protocol.Protocol} zconnected to {host}:{port}r r r? Nr )r r! r" r r; r- r% r$ )r r r r r rA q s �z&SSHConnectForwardingChannel._setClientc C s, | j jd| jd | jd |d� | �� dS )z� Called when failed to connect to the forwarding destination. @param reason: Reason why connection failed. @type reason: L{twisted.python.failure.Failure} z,failed to connect to {host}:{port}: {reason}r r )r r r+ N)r! �errorr r1 r* r r r rB � s �z"SSHConnectForwardingChannel._closec C s( | j r| j j�|� n| j|7 _dS )r> N)r r- r% r; r. r r r r0 � s z(SSHConnectForwardingChannel.dataReceivedc C s< | j r8| jjd| jd� | j jr(| �� | j j�� | ` dS )r> z%closed remote forwarding channel {id}r N)r r! r" r r r1 r- r2 r r r r) � s z"SSHConnectForwardingChannel.closedN) r r r �__doc__r r@ r r( rA rB r0 r) r r r r r9 E s r9 c C s t |�\}}t|| ||d�S )N)� remoteWindow�remoteMaxPacket�avatar)�unpackOpen_direct_tcpipr9 )rG rH r/ rI ZremoteHPZorigHPr r r �openConnectForwardingClient� s �rK c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r c C s || _ d| _d S )N� )r r$ )r r r r r r � s z SSHForwardingClient.__init__c C s& | j r| j |7 _ n | j�|� d S r )r$ r r% r. r r r r0 � s z SSHForwardingClient.dataReceivedc C s | j r| j �� d | _ d S r )r r1 r* r r r �connectionLost� s z"SSHForwardingClient.connectionLostN)r r r r r0 rM r r r r r � s r c C sl | \}}|\}}t |t�r$|�d�}t |t�r8|�d�}t�|�t�d|� }t�|�t�d|� }|| S )a Pack the data suitable for sending in a CHANNEL_OPEN packet. @type destination: L{tuple} @param destination: A tuple of the (host, port) of the destination host. @type source: L{tuple} @param source: A tuple of the (host, port) of the source host. �utf-8�>L)� isinstance�str�encoder �NS�struct�pack)Z destination�source�connHost�connPort�origHost�origPortr �origr r r r � s r c C s� t �| �\}}t|t�r"|�d�}tt�d|dd� �d �}t �|dd� �\}}t|t�rh|�d�}tt�d|dd� �d �}||f||ffS )z#Unpack the data to a usable format.rN rO N� r �r ZgetNSrP �bytes�decode�intrT �unpack)r/ rW �restrX rY rZ r r r rJ � s rJ c C s | \}}t �|�t�d|� S )zv Pack the data for tcpip forwarding. @param peer: A tuple of the (host, port) . @type peer: L{tuple} rO )r rS rT rU )Zpeerr r r r r �packGlobal_tcpip_forward� s rc c C sF t �| �\}}t|t�r"|�d�}tt�d|d d� �d �}||fS )NrN rO r\ r r] )r/ r rb r r r r �unpackGlobal_tcpip_forward� s rd )rF rT Ztwisted.conch.sshr r Ztwisted.internetr r Ztwisted.internet.endpointsr r �Factoryr r: r r5 r8 r9 rK �Protocolr r ZpackOpen_forwarded_tcpiprJ ZunpackOpen_forwarded_tcpiprc rd r r r r �<module> s$ c
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка