|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /proc/self/root/usr/lib/python2.7/site-packages/paramiko/ |
Upload File : |
�
x�\c @ s d Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
d d l m Z m
Z
m Z m Z m Z m Z m Z d d l m Z m Z d d l m Z m Z d d l m Z d � Z d
e f d � � YZ d � Z d
e f d � � YZ d S( s
Packet handling
i����N( t HMAC( t util( t
linefeed_bytet
cr_byte_valuet asbytest MSG_NAMESt DEBUGt xfffffffft zero_byte( t ut byte_ord( t SSHExceptiont ProxyCommandFailure( t Messagec C s t | | | � j � S( N( R t digest( t keyt messaget digest_class( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt compute_hmac. s t NeedRekeyExceptionc B s e Z d Z RS( s1
Exception indicating a rekey is needed.
( t __name__t
__module__t __doc__( ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR 2 s c C sD d } t | j � t k r@ t | j � d k r@ | j d } n | S( Ni ( t Nonet typet argst tuplet len( t et arg( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt first_arg: s *t
Packetizerc B sR e Z d Z e d d � Z e d d � Z e d d � Z e d d � Z d � Z e d � � Z
d � Z e d � Z
d � Z d � Z d � Z d
� Z d � Z d � Z d
� Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z e d � Z d � Z d � Z d � Z d � Z d � Z! d � Z" d � Z# d � Z$ d � Z% RS( s9
Implementation of the base SSH packet protocol.
i i c C sT | | _ d | _ t | _ t | _ t | _ d | _ t � | _ d | _
d | _ d | _ d | _
d | _ d | _ d | _ d | _ d | _ d | _ d | _ d | _ t | _ d | _ d | _ t � | _ t � | _ d | _ d | _ d | _ d | _ t j � | _! d | _" t# j# � | _$ d | _% d | _& t | _' t | _( d S( Ni i () t _Packetizer__socketR t _Packetizer__loggert Falset _Packetizer__closedt _Packetizer__dump_packetst _Packetizer__need_rekeyt _Packetizer__init_countt bytest _Packetizer__remaindert _Packetizer__sent_bytest _Packetizer__sent_packetst _Packetizer__received_bytest _Packetizer__received_packetst$ _Packetizer__received_bytes_overflowt& _Packetizer__received_packets_overflowt _Packetizer__block_size_outt _Packetizer__block_size_int _Packetizer__mac_size_outt _Packetizer__mac_size_int _Packetizer__block_engine_outt _Packetizer__block_engine_int _Packetizer__sdctr_outt _Packetizer__mac_engine_outt _Packetizer__mac_engine_int _Packetizer__mac_key_outt _Packetizer__mac_key_int _Packetizer__compress_engine_outt _Packetizer__compress_engine_int _Packetizer__sequence_number_outt _Packetizer__sequence_number_int threadingt RLockt _Packetizer__write_lockt _Packetizer__keepalive_intervalt timet _Packetizer__keepalive_lastt _Packetizer__keepalive_callbackt _Packetizer__timert _Packetizer__handshake_completet _Packetizer__timer_expired( t selft socket( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt __init__Q sF c C s | j S( N( R# ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt closed s c C s
| | _ d S( s?
Set the Python log object to use for logging.
N( R! ( RH t log( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_log� s c C s | | _ | | _ | | _ | | _ | | _ | | _ d | _ d | _ | j d O_ | j d k r{ d | _ t | _
n d S( s.
Switch outbound data cipher.
i i i N( R3 R5 R/ R6 R1 R8 R) R* R& R" R% ( RH t block_enginet
block_sizet
mac_enginet mac_sizet mac_keyt sdctr( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_outbound_cipher� s c C s� | | _ | | _ | | _ | | _ | | _ d | _ d | _ d | _ d | _ | j d O_ | j d k r� d | _ t
| _ n d S( s-
Switch inbound data cipher.
i i i N( R4 R0 R7 R2 R9 R+ R, R- R. R& R" R% ( RH RN RO RP RQ RR ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_inbound_cipher� s c C s
| | _ d S( N( R: ( RH t
compressor( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_outbound_compressor� s c C s
| | _ d S( N( R; ( RH RV ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_inbound_compressor� s c C s t | _ | j j � d S( N( t TrueR# R t close( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyRZ � s c C s
| | _ d S( N( R$ ( RH t hexdump( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt set_hexdump� s c C s | j S( N( R$ ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt get_hexdump� s c C s | j S( N( R2 ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt get_mac_size_in� s c C s | j S( N( R1 ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt get_mac_size_out� s c C s | j S( s�
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% ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt
need_rekey� s c C s% | | _ | | _ t j � | _ d S( s�
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( RA RD RB RC ( RH t intervalt callback( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt
set_keepalive� s c C s
t | _ d S( N( RY RG ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt
read_timer� s c C s; | j s7 t j t | � | j � | _ | j j � n d S( s�
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( RE R> t Timert floatRd t start( RH t timeout( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt start_handshake� s c C s! | j s
t S| j r t S| j S( sR
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`
( RE R" RF RG ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt handshake_timed_out� s
c C s/ | j r+ | j j � t | _ t | _ n d S( sF
Tells `Packetizer` that the handshake has completed.
N( RE t cancelR" RG RY RF ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt complete_handshake s
c C s� t � } t | j � d k rN | j | } | j | | _ | t | � 8} n xQ| d k r�t } | j � r{ t � � n yN | j j | � } t | � d k r� t � � n | | 7} | t | � 8} Wn} t j k
r� t
} nd t j k
rH} t | � } | t
j k rt
} qI| t
j k r-qI| j rBt � � qI� n X| rQ | j rdt � � n | r�t | � d k r�| j r�t � � n | j � qQ qQ W| S( s&
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
i ( R' R R( R" Rj t EOFErrorR t recvRI Rh RY t errorR t errnot EAGAINt EINTRR# R% R t _check_keepalive( RH t nt check_rekeyt outt got_timeoutt xR R ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt read_all
sB
! c C so t j � | _ d } xSt | � d k rjt } y | j j | � } Wn� t j k
rb t } n� t j k
r� } t
| � } | t j k r� t } q� | t j
k r� t } q� d } n* t k
r� � n t k
r� d } n X| rd } | j r/d } q/n+ | d k r%| d k r%d } n | d 7} | d k rGt � � n | t | � k r]Pn | | } q Wd S( Ni i����i
i ( RB RC R R" R t sendRI Rh RY Ro R Rp Rq Rr R t ExceptionR# Rm ( RH Rv t# iteration_with_zero_as_return_valuet retry_writeRt R R ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt write_all= s@
c C s� | j } x# t | k r. | | j | � 7} q W| j t � } | | d | _ | | } t | � d k r� | d t k r� | d } n t | � S( s�
Read a line from the socket. We assume no data is pending after the
line, so it's okay to attempt large reads.
i i i����( R( R t
_read_timeoutt indexR R R ( RH Rh t bufRt ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt readlineh s
"
c
C s" t | � } t | d � } | t k r5 t | } n d j | � } t | � } | j j � z�| j d k r� | j | � } n | j | � } | j
r� | j t d j | | � � | j t t
j | d � � n | j d k r� | j j | � } n | } | j d k rLt j d | j � | } | t | j | | j � | j 7} n | j d t @| _ | j | � | j t | � 7_ | j d 7_ | j | j k p�| j | j k } | r | j r d } | j t | j | j | j � � d | _ d | _ | j! � n Wd | j j" � Xd S( sR
Write a block of data using the current cipher, as an SSH block.
i s ${:x}s Write packet <{}>, length {}s OUT: s >Ii s( Rekeying (hit {} packets, {} bytes sent)N(# R R
R t formatR R@ t acquireR: R t
_build_packetR$ t _logR R t
format_binaryR3 t updatet structt packR< R R8 R6 R1 R R~ R) R* t
REKEY_PACKETSt REKEY_BYTESR% R- R. t _trigger_rekeyt release(
RH t datat cmdt cmd_namet orig_lent packetRv t payloadt
sent_too_mucht msg( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt send_messagew sN
c C s� | j | j d t �} | j d k r< | j j | � } n | j rd | j t t j
| d � � n t j d | d � d } | d } | t
| � | j d k r� t d � � n | j | | j t
| � � } | | t
| � } | | t
| � } | j d k r | j j | � } n | j rH| j t t j
| d � � n | | } | j d k r�| | j } t j d | j | � | } t | j | | j � | j } t j | | � s�t d � � q�n t | d � }
| d | |
!} | j r| j t d
j | |
� � n | j d k r7| j | � } n t | d � } | j | _ | j d t @| _ | | j d }
| j |
7_ | j d 7_ | j r�| j |
7_ | j d 7_ | j | j! k s�| j | j" k r^t d � � q^nk | j | j# k s| j | j$ k r^d } | j t | j | j | j � � d | _ d | _ | j% � n t | d � } | t& k r�t& | } n d
j | � } | j r�| j t d j | t
| � � � n | | f S( s�
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
Ru s IN: s >Ii i s Invalid packet blockings >IIs Mismatched MACi s" Got payload ({} bytes, {} padding)s+ Remote transport is ignoring rekey requestss, Rekeying (hit {} packets, {} bytes received)s ${:x}s Read packet <{}>, length {}N(' Ry R0 RY R4 R R� R$ R� R R R� R� t unpackR R R2 R� R= R R9 R7 t constant_time_bytes_eqR
R� R; R
t seqnoR R+ R, R% R- R. t REKEY_PACKETS_OVERFLOW_MAXt REKEY_BYTES_OVERFLOW_MAXR� R� R� R ( RH t headert packet_sizet leftoverR� R� t post_packett mact mac_payloadt my_mact paddingR� R� t raw_packet_sizet errR� R� ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt read_message� s�
c C sf | j d k r d St t | � t � rO x7 | D] } | j j | | � q/ Wn | j j | | � d S( N( R! R t
issubclassR t listRL ( RH t levelR� t m( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR� s
c C s] | j s | j s | j r! d St j � } | | j | j k rY | j � | | _ n d S( N( RA R3 R% RB RC RD ( RH t now( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyRs s
c C s� t j � } x� t r� y5 | j j d � } t | � d k rH t � � n PWnA t j k
r` n. t k
r� } t | � t
j k r� q� � n X| j r� t � � n t j � } | | | k r t j � � q q W| S( Ni� i (
RB RY R Rn R Rm RI Rh t EnvironmentErrorR Rp Rr R# ( RH Rh Rg Rx R R� ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR - s& c C s� | j } d | t | � d | } t j d t | � | d | � } | | 7} | j sj | j d k r{ | t | 7} n | t j | � 7} | S( Ni i s >IBi (
R/ R R� R� R5 R3 R R t ost urandom( RH R� t bsizeR� R� ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR� C s #
c C s
t | _ d S( N( RY R% ( RH ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR� R s (& R R R t powR� R� R� R� RJ t propertyRK RM R" RT RU RW RX RZ R\ R] R^ R_ R` Rc Rd Ri Rj Rl Ry R~ R� R� R� R� Rs R R� R� ( ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyR A sB .
3 + : f
(! R Rp R� RI R� R> RB t hmacR t paramikoR t paramiko.commonR R R R R R R t paramiko.py3compatR R
t paramiko.ssh_exceptionR R t paramiko.messageR
R R{ R R t objectR ( ( ( s3 /tmp/pip-install-A1qMVe/paramiko/paramiko/packet.pyt <module> s 4