File: //opt/saltstack/salt/lib/python3.10/site-packages/zmq/ssh/__pycache__/forward.cpython-310.pyc
o
;j� � @ s\ d Z ddlZddlZddlZe�d�ZG dd� dej�ZG dd� dej�Z dd � Z
d gZ dS )
a
Sample script showing how to do local port forwarding over paramiko.
This script connects to the requested SSH server and sets up local port
forwarding (the openssh -L option) from a local port through a tunneled
connection to a destination reachable from the SSH server machine.
� NZsshc @ s e Zd ZdZdZdS )�
ForwardServerTN)�__name__�
__module__� __qualname__Zdaemon_threadsZallow_reuse_address� r r �C/opt/saltstack/salt/lib/python3.10/site-packages/zmq/ssh/forward.pyr " s r c @ s e Zd Zdd� ZdS )�Handlerc
C sB z| j �d| j| jf| j�� �}W n ty. } zt�d| j| j|� W Y d }~d S d }~ww |d u r>t�d| j| j� d S t�d| j�� �d|�� �d| j| jf��� t � | j|gg g �\}}}| j|v rz| j�
d�}t |�dkrun |� |� ||v r�|�
d�}t |�dkr�n| j� |� qV|�
� | j�
� t�d � d S )
Nz direct-tcpipz$Incoming request to %s:%d failed: %rz9Incoming request to %s:%d was rejected by the SSH server.zConnected! Tunnel open z -> Ti r zTunnel closed )�
ssh_transportZ open_channel�
chain_host�
chain_port�request� getpeername� Exception�logger�debug�select�recv�len�send�close)�selfZchan�e�r�w�x�datar r r �handle( sT
�����&�
�
zHandler.handleN)r r r r r r r r r ' s r c s. G � ��fdd�dt �}td| f|��� d S )Nc s e Zd Z� Z�Z�ZdS )z!forward_tunnel.<locals>.SubHanderN)r r r r
r r r �� remote_host� remote_port� transportr r � SubHanderW s r! z 127.0.0.1)r r Z
serve_forever)Z
local_portr r r r! r r r �forward_tunnelS s r" ) �__doc__�loggingr Z socketserver� getLoggerr ZThreadingTCPServerr ZBaseRequestHandlerr r" �__all__r r r r �<module> s
,