|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/site-packages/paramiko/__pycache__/ |
U
P��g�^ � @ 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 �</opt/cppython/lib/python3.8/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�tkr*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 tjk
r� d}Y nL tj k
r� } z,t
|�}|t j kr�d}n| j
r�t� �n� W 5 d}~X Y nX |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�rd}z| j�|�}W n� tjk
rJ d}Y nj tjk
r� } z t|�}|t j
krtd}nd}W 5 d }~X Y n, t k
r� � Y n t k
r� d}Y nX |r�d}| j
r�d}n |dkr�|dkr�d}|d7 }|dk r�t� �|t|�k�r�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|kr || �|�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 s6 |� � }t|d �}|tkr&t| }n
d�|�}t|�}| j�� �z�| jdk rZ| �|�}| � |�}| j
r�| � t d�||�� | � t t
�|d�� | jdk �r| jr�|dd� | j�|dd� � }nR| j�r |dd� | j�| j|dd� |dd� � }| �| j�| _n | j�|�}n|}| jdk �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 5 | j�� X 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 �acquire�releaserA �
_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) rU �data�cmd�cmd_nameZorig_len�packetr� �packed�payload�next_seqZ
sent_too_much�msgr r r � send_message� s~
�
�
� ���
� � 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�| _| jdk �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� } | jdk �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
�|| �� | jdk �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*k�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 krd 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 st t � � }z&| j�d�}t|�dkr(t� �W qpW n tjk
rD Y nX | jrRt� �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 krr|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 $