Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/conch/ssh/__pycache__/channel.cpython-39.pyc
Ðазад
a k�h�& � @ sT d Z ddlmZ ddlmZ ddlmZ ddlmZ eej �G dd� dej��Z dS ) z� The parent class for all the SSH Channels. Currently implemented channels are session, direct-tcp, and forwarded-tcp. Maintainer: Paul Swartz � )� implementer)� interfaces)�Logger)�logc @ s� e Zd ZU dZe� ZdZeed< d0dd�Z e d�dd �Z ed�d d �Z d d � Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Z d,d-� Z d.d/� Z dS )1� 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} N�namer 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/conch/ssh/channel.py�__init__9 s zSSHChannel.__init__)�returnc C s | � � �d�S )N�ascii)� __bytes__�decode�r r r r �__str__T s zSSHChannel.__str__c C s | j }|sd}d|| j| jf S )zD Return a byte string representation of the channel s Nones <SSHChannel %b (lw %d rw %d)>)r r r )r r r r r r W s �zSSHChannel.__bytes__c C sL | j d urt| j �pd}| jr,| j�d�}nd}d|� d|� d| j�� � �S )N�unknownr �Nonez SSHChannel z (z) on )r �strr r r � logPrefix)r r r r r r r$ e s zSSHChannel.logPrefixc C s | j �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��_log�info)r r r r r � channelOpenm s zSSHChannel.channelOpenc C s | j jd|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: {reason})�reasonN)r& �error)r r) r r r � openFailedv 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 sB |� dd��d�}t| d| d�}|r.||�S | jjd|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} � -� _r Zrequest_Nz#unhandled request for {requestType})� requestTyper )�replacer �getattrr& r' )r r4 r Zfoo�fr r r �requestReceived� s zSSHChannel.requestReceivedc C s | j jd|d� dS )zL Called when we receive data. @type data: L{bytes} zgot data {data})r N�r& �debug�r r r r r � dataReceived� s zSSHChannel.dataReceivedc C s | j jd||d� dS )z� Called when we receive extended data (usually standard error). @type dataType: L{int} @type data: L{str} z%got extended data {dataType} {data!r})�dataTyper Nr9 �r r= r r r r � extReceived� s �zSSHChannel.extReceivedc C s | j �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 | j �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 | j �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 rC � 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 rA )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 �appendrD r r rE r r ZsendExtendedDatar rA r> 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- �joinr; 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 rA 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 rO 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 rN �getHostr r r r rP % 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 rE . 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, 4 s zSSHChannel.startWriting)r r r r NNN) �__name__� __module__� __qualname__�__doc__r r& r �bytes�__annotations__r r# r r r$ r( r+ r1 r8 r< r? r@ rB rC r- r. rM rA rO rP rE r, r r r r r s> � r N) rT Zzope.interfacer Ztwisted.internetr Ztwisted.loggerr Ztwisted.pythonr Z ITransportr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка