← Back
Editing: channel.cpython-38.pyc
U W[|& � @ sh d Z ddlmZmZ ddlmZ ddlmZ ddlm Z m Z ddl m Z ee j �G dd� dej��Zd S ) z� The parent class for all the SSH Channels. Currently implemented channels are session, direct-tcp, and forwarded-tcp. Maintainer: Paul Swartz � )�division�absolute_import)� implementer)�log)� nativeString� intToBytes)� interfacesc @ s� e Zd ZdZdZd.dd�Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� ZdS )/� SSHChannela� A class that represents a multiplexed channel over an SSH connection. The channel has a local window which is the maximum amount of data it will receive, and a remote which is the maximum amount of data the remote side will accept. There is also a maximum packet size for any individual data packet going each way. @ivar name: the name of the channel. @type name: L{bytes} @ivar localWindowSize: the maximum size of the local window in bytes. @type localWindowSize: L{int} @ivar localWindowLeft: how many bytes are left in the local window. @type localWindowLeft: L{int} @ivar localMaxPacket: the maximum size of packet we will accept in bytes. @type localMaxPacket: L{int} @ivar remoteWindowLeft: how many bytes are left in the remote window. @type remoteWindowLeft: L{int} @ivar remoteMaxPacket: the maximum size of a packet the remote side will accept in bytes. @type remoteMaxPacket: L{int} @ivar conn: the connection this channel is multiplexed through. @type conn: L{SSHConnection} @ivar data: any data to send to the other side when the channel is requested. @type data: L{bytes} @ivar avatar: an avatar for the logged-in user (if a server channel) @ivar localClosed: True if we aren't accepting more data. @type localClosed: L{bool} @ivar remoteClosed: True if the other side isn't accepting more data. @type remoteClosed: L{bool} Nr c C sn |pd| _ | j | _|pd| _|| _|| _d| _|| _|| _|| _d| _ d| _ g | _ d| _ d| _ d| _d | _d S )Ni i � � � r )ZlocalWindowSize�localWindowLeft�localMaxPacket�remoteWindowLeft�remoteMaxPacket� areWriting�conn�data�avatar� specificData�buf�extBuf�closingZ localClosedZ remoteClosed�id)�selfZ localWindowr Z remoteWindowr r r r � r �;/usr/lib/python3/dist-packages/twisted/conch/ssh/channel.py�__init__: s zSSHChannel.__init__c C s t | �� �S )N)r � __bytes__�r r r r �__str__O s zSSHChannel.__str__c C s6 | j }|sd}d| d t| j� d t| j� d S )zD Return a byte string representation of the channel s Nones <SSHChannel s (lw s rw s )>)�namer r r )r r r r r r S s �����zSSHChannel.__bytes__c C s> | j d k rt| j �pd}| j}|r*t|�}d||| j�� f S )N�unknownzSSHChannel %s (%s) on %s)r �strr r r � logPrefix)r r r r r r r# a s �zSSHChannel.logPrefixc C s t �d� dS )z� Called when the channel is opened. specificData is any data that the other side sent us when opening the channel. @type specificData: L{bytes} z channel openN�r �msg)r r r r r � channelOpenj s zSSHChannel.channelOpenc C s t �d| � dS )z� Called when the open failed for some reason. reason.desc is a string descrption, reason.code the SSH error code. @type reason: L{error.ConchError} z"other side refused open reason: %sNr$ )r �reasonr r r � openFailedt s zSSHChannel.openFailedc C sr | j | | _ | js&| js&d| _| �� | jrB| j}d| _| �|� | jrn| j}g | _|D ]\}}| �||� qXdS )z� Called when bytes are added to the remote window. By default it clears the data buffers. @type data: L{bytes} Tr N)r r r � startWritingr �writer � writeExtended)r r �b�typer r r �addWindowBytes~ s zSSHChannel.addWindowBytesc C s> t |�dd��}t| d| d�}|r,||�S t�d| � dS )aJ Called when a request is sent to this channel. By default it delegates to self.request_<requestType>. If this function returns true, the request succeeded, otherwise it failed. @type requestType: L{bytes} @type data: L{bytes} @rtype: L{bool} � -� _z request_%sNzunhandled request for %sr )r �replace�getattrr r% )r Z requestTyper Zfoo�fr r r �requestReceived� s zSSHChannel.requestReceivedc C s t �dt|� � dS )zL Called when we receive data. @type data: L{bytes} z got data %sN�r r% �repr�r r r r r � dataReceived� s zSSHChannel.dataReceivedc C s t �d|t|�f � dS )z� Called when we receive extended data (usually standard error). @type dataType: L{int} @type data: L{str} zgot extended data %s %sNr5 �r ZdataTyper r r r � extReceived� s zSSHChannel.extReceivedc C s t �d� dS )zD Called when the other side will send no more data. z remote eofNr$ r r r r � eofReceived� s zSSHChannel.eofReceivedc C s t �d� | �� dS )zD Called when the other side has closed the channel. z remote closeN)r r% �loseConnectionr r r r � closeReceived� s zSSHChannel.closeReceivedc C s t �d� dS )z� Called when the channel is closed. This means that both our side and the remote side have closed the channel. �closedNr$ r r r r r> � s zSSHChannel.closedc C s� | j r| j |7 _ dS t|�}|| jkr^|d| j� || jd� }| _ d| _| �� | j}| j}| jj}td||�}|D ]}|| |||| � � q|| j|8 _| j r�| j s�| � � dS )z� Write some data to the channel. If there is not enough remote window available, buffer until it is. Otherwise, split the data into packets of length remoteMaxPacket and send them. @type data: L{bytes} Nr ) r �lenr r � stopWritingr r ZsendData�ranger r< )r r �topZrmpr* �r�offsetr r r r* � s& � zSSHChannel.writec C s | j rD| j d d |kr0| j d d |7 < n| j �||g� dS t|�| jkr�|d| j� ||| jd� gg }| _ d| _| �� t|�| jkr�| j�| ||d| j� � || jd� }| j| j8 _q�|r�| j�| ||� | jt|�8 _| j �r| � � dS )a Send extended data to this channel. If there is not enough remote window available, buffer until there is. Otherwise, split the data into packets of length remoteMaxPacket and send them. @type dataType: L{int} @type data: L{bytes} ���r r N) r �appendr? r r r@ r r ZsendExtendedDatar r< r9 r r r r+ � s, � �zSSHChannel.writeExtendedc C s | � d�|�� dS )z� Part of the Transport interface. Write a list of strings to the channel. @type data: C{list} of L{str} r N)r* �joinr7 r r r � writeSequence s zSSHChannel.writeSequencec C s" d| _ | js | js | j�| � dS )zr Close the channel if there is no buferred data. Otherwise, note the request and return. r N)r r r r Z sendCloser r r r r< s zSSHChannel.loseConnectionc C s | j j�� S )z� See: L{ITransport.getPeer} @return: The remote address of this connection. @rtype: L{SSHTransportAddress}. )r � transport�getPeerr r r r rJ ! s zSSHChannel.getPeerc C s | j j�� S )z� See: L{ITransport.getHost} @return: An address describing this side of the connection. @rtype: L{SSHTransportAddress}. )r rI �getHostr r r r rK + s zSSHChannel.getHostc C s dS )z� Called when the remote buffer is full, as a hint to stop writing. This can be ignored, but it can be helpful. Nr r r r r r@ 5 s zSSHChannel.stopWritingc C s dS )ze Called when the remote buffer has more room, as a hint to continue writing. Nr r r r r r) < s zSSHChannel.startWriting)r r r r NNN)�__name__� __module__� __qualname__�__doc__r r r r r# r& r( r. r4 r8 r: r; r= r> r* r+ rH r< rJ rK r@ r) r r r r r s: � r N)rO Z __future__r r Zzope.interfacer Ztwisted.pythonr Ztwisted.python.compatr r Ztwisted.internetr Z ITransportZLoggerr r r r r �<module> s
Save File
Cancel