Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/paramiko/__pycache__/packet.cpython-39.pyc
Ðазад
a s�h�^ � @ s� d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z m Z mZmZmZmZmZ ddlmZ ddlmZmZ ddlmZ d d � ZG d d � d e�Z d d� Z G dd� d�Z dS )z Packet handling � N)�HMAC)�util)� linefeed_byte� cr_byte_value� MSG_NAMES�DEBUG� xffffffff� zero_byte�byte_ord)�u)� SSHException�ProxyCommandFailure)�Messagec C s t | ||��� S �N)r �digest)�key�messageZ digest_class� r �/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/paramiko/packet.py� compute_hmac. s r c @ s e Zd ZdZdS )�NeedRekeyExceptionz1 Exception indicating a rekey is needed. N)�__name__� __module__� __qualname__�__doc__r r r r r 2 s r c C s. d }t | j�tu r*t| j�dkr*| jd }|S �Nr )�type�args�tuple�len)�e�argr r r � first_arg: s r" c @ s: e Zd ZdZedd�Zedd�Zedd�Zedd�Zdd� Z e dd� �Z dd � Z d d � Z d d � ZdDdd�ZdEdd�Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Z d,d-� Z dFd.d/�Z d0d1� Z d2d3� Z d4d5� Z!d6d7� Z"d8d9� Z#d:d;� Z$d<d=� Z%d>d?� Z&d@dA� Z'dBdC� Z(dS )G� Packetizerz9 Implementation of the base SSH packet protocol. � � c C s || _ d | _d| _d| _d| _d| _t� | _d| _d| _ d| _ d| _ d| _ d| _ d| _d| _d| _d| _d| _d | _d | _d| _d | _d | _t� | _t� | _d | _d | _d| _ d| _ d| _ d| _ d| _ d| _!d | _"d | _#t$�%� | _&d| _'t(�(� | _)d | _*d | _+d| _,d| _-d S )NFr � ).�_Packetizer__socket�_Packetizer__logger�_Packetizer__closed�_Packetizer__dump_packets�_Packetizer__need_rekey�_Packetizer__init_count�bytes�_Packetizer__remainder�_initial_kex_done�_Packetizer__sent_bytes�_Packetizer__sent_packets�_Packetizer__received_bytes� _Packetizer__received_packets�$_Packetizer__received_bytes_overflow�&_Packetizer__received_packets_overflow�_Packetizer__block_size_out�_Packetizer__block_size_in�_Packetizer__mac_size_out�_Packetizer__mac_size_in� _Packetizer__block_engine_out� _Packetizer__block_engine_in�_Packetizer__sdctr_out�_Packetizer__mac_engine_out�_Packetizer__mac_engine_in�_Packetizer__mac_key_out�_Packetizer__mac_key_in� _Packetizer__compress_engine_out� _Packetizer__compress_engine_in� _Packetizer__sequence_number_out� _Packetizer__sequence_number_in�_Packetizer__etm_out�_Packetizer__etm_in�_Packetizer__aead_out�_Packetizer__aead_in�_Packetizer__iv_out�_Packetizer__iv_in� threading�RLock�_Packetizer__write_lock� _Packetizer__keepalive_interval�time�_Packetizer__keepalive_last� _Packetizer__keepalive_callback�_Packetizer__timer� _Packetizer__handshake_complete�_Packetizer__timer_expired)�self�socketr r r �__init__Q sT zPacketizer.__init__c C s | j S r )r) �rU r r r �closed� s zPacketizer.closedc C s d| _ d S r )rC rX r r r �reset_seqno_out� s zPacketizer.reset_seqno_outc C s d| _ d S r )rD rX r r r �reset_seqno_in� s zPacketizer.reset_seqno_inc C s || _ dS )z? Set the Python log object to use for logging. N)r( )rU �logr r r �set_log� s zPacketizer.set_logFNc C sj || _ || _|| _|| _|| _|| _d| _d| _|| _|| _ | | _ | j dO _ | j dkrfd| _ d| _ dS )zd Switch outbound data cipher. :param etm: Set encrypt-then-mac from OpenSSH r � � FN) r: r< r6 r= r8 r? r0 r1 rE rG rI r, r+ ) rU � block_engine� block_size� mac_engine�mac_size�mac_keyZsdctr�etm�aeadZiv_outr r r �set_outbound_cipher� s z Packetizer.set_outbound_cipherc C sp || _ || _|| _|| _|| _d| _d| _d| _d| _|| _ || _ || _ | j dO _ | j dkrld| _ d| _ dS )zc Switch inbound data cipher. :param etm: Set encrypt-then-mac from OpenSSH r r$ r_ FN)r; r7 r> r9 r@ r2 r3 r4 r5 rF rH rJ r, r+ ) rU r` ra rb rc rd re rf Ziv_inr r r �set_inbound_cipher� s z Packetizer.set_inbound_cipherc C s || _ d S r )rA �rU Z compressorr r r �set_outbound_compressor� s z"Packetizer.set_outbound_compressorc C s || _ d S r )rB ri r r r �set_inbound_compressor� s z!Packetizer.set_inbound_compressorc C s d| _ | j�� d S �NT)r) r' �closerX r r r rm � s zPacketizer.closec C s || _ d S r �r* )rU �hexdumpr r r � set_hexdump� s zPacketizer.set_hexdumpc C s | j S r rn rX r r r � get_hexdump� s zPacketizer.get_hexdumpc C s | j S r )r9 rX r r r �get_mac_size_in� s zPacketizer.get_mac_size_inc C s | j S r )r8 rX r r r �get_mac_size_out� s zPacketizer.get_mac_size_outc C s | j S )z� Returns ``True`` if a new set of keys needs to be negotiated. This will be triggered during a packet read or write, so it should be checked after every read or write, or at least after every few. �r+ rX r r r � need_rekey� s zPacketizer.need_rekeyc C s || _ || _t�� | _dS )z� Turn on/off the callback keepalive. If ``interval`` seconds pass with no data read from or written to the socket, the callback will be executed and the timer will be reset. N)rN rQ rO rP )rU �interval�callbackr r r � set_keepalive� s zPacketizer.set_keepalivec C s d| _ d S rl )rT rX r r r � read_timer s zPacketizer.read_timerc C s( | j s$t�t|�| j�| _ | j �� dS )z� Tells `Packetizer` that the handshake process started. Starts a book keeping timer that can signal a timeout in the handshake process. :param float timeout: amount of seconds to wait before timing out N)rR rK �Timer�floatry �start)rU �timeoutr r r �start_handshake s zPacketizer.start_handshakec C s | j s dS | jrdS | jS )aR Checks if the handshake has timed out. If `start_handshake` wasn't called before the call to this function, the return value will always be `False`. If the handshake completed before a timeout was reached, the return value will be `False` :return: handshake time out status, as a `bool` F)rR rS rT rX r r r �handshake_timed_out s z Packetizer.handshake_timed_outc C s | j r | j �� d| _d| _dS )zF Tells `Packetizer` that the handshake has completed. FTN)rR �cancelrT rS rX r r r �complete_handshake# s z Packetizer.complete_handshakec C s8 t � }t| j�dkr>| jd|� }| j|d� | _|t|�8 }|dk�r4d}| �� rZt� �z6| j�|�}t|�dkrzt� �||7 }|t|�8 }W nd tjy� d}Y nN tj y� } z4t |�}|t j kr�d}n| j r�t� �n� W Y d}~n d}~0 0 |r>| j �rt� �|�r*t|�dk�r*| j�r*t� �| �� q>|S )a& Read as close to N bytes as possible, blocking as long as necessary. :param int n: number of bytes to read :return: the data read, as a `str` :raises: ``EOFError`` -- if the socket was closed before all the bytes could be read r NFT)r- r r. r �EOFErrorr' �recvrV r} �errorr" �errno�EAGAINr) r+ r �_check_keepalive)rU �n� check_rekey�outZ got_timeout�xr r! r r r �read_all, s> zPacketizer.read_allc C s t � � | _d}t|�dk�r d}z| j�|�}W n~ tjyH d}Y nh tjy� } z(t|�}|t j krpd}nd}W Y d }~n0d }~0 t y� � Y n t y� d}Y n0 |r�d}| j r�d}n |dkr�|dkr�d}|d7 }|dk r�t� �|t|�kr��q ||d � }qd S )Nr FT���� r^ )rO rP r r' �sendrV r} r� r" r� r� r � Exceptionr) r� )rU r� Z#iteration_with_zero_as_return_valueZ retry_writer� r r! r r r � write_all\ s< zPacketizer.write_allc C sr | j }t|vr || �|�7 }q|�t�}||d d� | _ |d|� }t|�dkrj|d tkrj|dd� }t|�S )z� Read a line from the socket. We assume no data is pending after the line, so it's okay to attempt large reads. r^ Nr r� )r. r � _read_timeout�indexr r r )rU r} �bufr� r r r �readline� s zPacketizer.readlinec C s@ |dd � }t �|d�}|d }|�dd�}|dd� | }|S )N� �bigr^ r& r )�int� from_bytes�to_bytes)rU ZivZ iv_counter_bZ iv_counterZinc_iv_counterZinc_iv_counter_bZnew_ivr r r �_inc_iv_counter� s zPacketizer._inc_iv_counterc C s@ |� � }t|d �}|tv r&t| }n d�|�}t|�}| j�� �z�| jdurZ| �|�}| �|�}| j r�| � t d�||�� | � t t � |d�� | jdu�r| jr�|dd� | j�|dd� � }nR| j�r |dd� | j�| j|dd� |dd� � }| �| j�| _n | j�|�}n|}| jdu�rr| j�srt�d| j�}|| j�rN|n| }|t| j|| j�d| j� 7 }| jd t @ } | dk�r�| j �s�t d ��| | _| � |� | j t|�7 _ | j!d7 _!| j!| j"k�p�| j | j#k} | �r"| j$�s"d } | � t | �| j!| j �� d| _%d| _&| �'� W | j�(� n | j�(� 0 dS ) zR Write a block of data using the current cipher, as an SSH block. r �${:x}Nz Write packet <{}>, length {}zOUT: r� �>Ir^ �/Sequence number rolled over during initial kex!z(Rekeying (hit {} packets, {} bytes sent)))Zasbytesr r �formatr rM �acquirerA � _build_packetr* �_logr r � format_binaryr: rE �updaterG ZencryptrI r� �struct�packrC r r? r= r8 r r/ r r� r0 r1 � REKEY_PACKETS� REKEY_BYTESr+ r4 r5 �_trigger_rekey�release) rU �data�cmd�cmd_nameZorig_len�packetr� �packed�payload�next_seqZ sent_too_much�msgr r r � send_message� st � �� ��� �� zPacketizer.send_messagec C sL | j | jdd�}| jr�t�d|dd� �d }|| j d }|dd� | j |dd� }| j | jdd�}t�d| j|�| }t| j || j �d| j� }t � ||�s�t d ��|}| j�r&t�d|dd� �d }|dd� }|| j d | j }|dd� | j |dd� }| j�| j||�}| �| j�| _| jdu�rF| j�sF| j�|�}| j�rb| �tt �|d �� | j�sr| j�rx|}n�t�d|dd� �d }|dd� } |t| � | j dk�r�t d ��| � || j t| � �} | d|t| � � }| |t| � d� } | jdu�r| j�|�}| | }| j�r8| �tt �|d �� | jdk�r�| j�s�| j�s�| d| j� }t�d| j|�| }t| j || j �d| j� }t � ||��s�t d ��t|d �} |d || � } | j�r�| �td �|| �� | jdu�r�| �| �} t | d d� �}| j|_ | jd t @ }|dk�r4| j �s4t d��|| _|| j d }| j |7 _ | j!d 7 _!| j"�r�| j#|7 _#| j$d 7 _$| j$| j%k�s�| j#| j&k�r�t d��nL| j!| j'k�s�| j | j(k�r�d}| �t|�| j!| j �� d| _#d| _$| �)� t| d �}|t*v �rt*| }n d�|�}| j�rD| �td�|t| ��� ||fS )z� Only one thread should ever be in this function (no other locking is done). :raises: `.SSHException` -- if the packet is mangled :raises: `.NeedRekeyException` -- if the transport should rekey T)r� r� Nr� r Fz>IIzMismatched MACzIN: zInvalid packet blockingr^ z"Got payload ({} bytes, {} padding)r� z+Remote transport is ignoring rekey requestsz,Rekeying (hit {} packets, {} bytes received)r� zRead packet <{}>, length {})+r� r7 rF r� �unpackr9 r� rD r r@ r> r Zconstant_time_bytes_eqr rH r; ZdecryptrJ r� r� r* r� r r� r r r� rB r Zseqnor r/ r2 r3 r+ r4 r5 �REKEY_PACKETS_OVERFLOW_MAX�REKEY_BYTES_OVERFLOW_MAXr� r� r� r )rU �headerZ packet_size� remainingr� �macZ mac_payloadZmy_macZaad�leftoverr� Z post_packet�paddingr� r� r� Zraw_packet_size�errr� r� r r r � read_message� s� �� �� � � �� �� �� ��� �� �� �zPacketizer.read_messagec C sH | j d u rd S tt|�t�r6|D ]}| j �||� q n| j �||� d S r )r( � issubclassr �listr\ )rU �levelr� �mr r r r� } s zPacketizer._logc C s@ | j r| jr| jrd S t�� }|| j| j kr<| �� || _d S r )rN r: r+ rO rP rQ )rU �nowr r r r� � s ���zPacketizer._check_keepalivec C sr t � � }z&| j�d�}t|�dkr(t� �W qnW n tjyB Y n0 | jrPt� �t � � }|| |krt�� �q|S )N� r )rO r' r� r r� rV r} r) )rU r} r| r� r� r r r r� � s zPacketizer._read_timeoutc C s� | j }| js| jrdnd}d| t|�| | }t�dt|�| d |�}||7 }| jsd| jd u rr|t| 7 }n|t � |�7 }|S )Nr� r& r_ z>IBr^ ) r6 rE rG r r� r� r< r: r �os�urandom)rU r� ZbsizeZaddlenr� r� r r r r� � s zPacketizer._build_packetc C s d| _ d S rl rt rX r r r r� � s zPacketizer._trigger_rekey)FFFN)FFN)F))r r r r �powr� r� r� r� rW �propertyrY rZ r[ r] rg rh rj rk rm rp rq rr rs ru rx ry r~ r r� r� r� r� r� r� r� r� r� r� r� r� r r r r r# A sZ 7 � ) � " 0( J r# ) r r� r� rV r� rK rO �hmacr Zparamikor Zparamiko.commonr r r r r r r Z paramiko.utilr Zparamiko.ssh_exceptionr r Zparamiko.messager r r� r r" r# r r r r �<module> s $
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка