??????????????
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 173
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 174
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 175
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 176
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 177
Warning: Cannot modify header information - headers already sent by (output started at /home/mybf1/public_html/mentol.bf1.my/SS1.php:4) in /home/mybf1/public_html/mentol.bf1.my/SS1.php on line 178
=OXc @ 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 e f d
YZ d S( s
Packet handling
iN( 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 /usr/lib/python2.7/site-packages/paramiko/packet.pyt compute_hmac' s t NeedRekeyExceptionc B s e Z RS( ( t __name__t
__module__( ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyR + 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__sockett Nonet _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 /usr/lib/python2.7/site-packages/paramiko/packet.pyt __init__< sF c C s | j S( N( R ( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt closedj s c C s
| | _ d S( s?
Set the Python log object to use for logging.
N( R ( R@ t log( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_logn 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( R+ R- R' R. R) R0 R! R" R R R ( R@ t block_enginet
block_sizet
mac_enginet mac_sizet mac_keyt sdctr( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_outbound_ciphert 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( R, R( R/ R* R1 R# R$ R% R& R R R ( R@ RF RG RH RI RJ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_inbound_cipher s c C s
| | _ d S( N( R2 ( R@ t
compressor( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_outbound_compressor s c C s
| | _ d S( N( R3 ( R@ RN ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_inbound_compressor s c C s t | _ | j j d S( N( t TrueR R t close( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyRR s c C s
| | _ d S( N( R ( R@ t hexdump( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt set_hexdump s c C s | j S( N( R ( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt get_hexdump s c C s | j S( N( R* ( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt get_mac_size_in s c C s | j S( N( R) ( R@ ( ( s3 /usr/lib/python2.7/site-packages/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 ( R@ ( ( s3 /usr/lib/python2.7/site-packages/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( R9 R< R: R; ( R@ t intervalt callback( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt
set_keepalive s c C s
t | _ d S( N( RQ R? ( R@ ( ( s3 /usr/lib/python2.7/site-packages/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( R= R6 t Timert floatR\ t start( R@ t timeout( ( s3 /usr/lib/python2.7/site-packages/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`
( R= R R> R? ( R@ ( ( s3 /usr/lib/python2.7/site-packages/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( R= t cancelR R? RQ R> ( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt complete_handshake s
c C s t } t | j d k rN | j | } | j | | _ | t | 8} n x| d k rt } | j r{ t n yN | j j | } t | d k r t n | | 7} | t | 8} Wn t j k
r t
} n t j k
r} t | j
t k r@t | j
d k r@| j
d t j k r@t
} qt | j
t k rt | j
d k r| j
d t j k rq| j rt q n X| rQ | j rt n | rt | d k r| j rt 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 t lenR R Rb t EOFErrorR t recvRA R` RQ t errort typet argst tuplet errnot EAGAINt EINTRR R R t _check_keepalive( R@ t nt check_rekeyt outt got_timeoutt xt e( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt read_all s@
@ @ ! c C s t j | _ d } xt | d k rt } y | j j | } Wn t j k
rb t } n t j k
r} t
| j t k r t | j d k r | j d t
j k r t } q9t
| j t k rt | j d k r| j d t
j k rt } q9d } n* t k
r" n t k
r8d } n X| rZd } | j rd } qn+ | d k r{| d k r{d } n | d 7} | d k rt n | t | k rPn | | } q Wd S( Ni ii
i ( R: R; Re R R t sendRA R` RQ Rh Ri Rj Rk Rl Rm Rn R t ExceptionR Rf ( R@ Rr t# iteration_with_zero_as_return_valuet retry_writeRp Ru ( ( s3 /usr/lib/python2.7/site-packages/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 indexRe R R ( R@ R` t bufRp ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt readlineD s
"
c C s
t | } t | d } | t k r5 t | } n
d | } t | } | j j z| j d k r| | j | } n | j | } | j r | j
t d | | f | j
t t j
| d n | j d k r | j j | } n | } | j d k rEt j d | j | } | t | j | | j | j 7} n | j d t @| _ | j | | j t | 7_ | j d 7_ | j | j k s| j | j k r| j r| j
t d | j | j f 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 $%xs Write packet <%s>, length %ds OUT: s >Ii s( Rekeying (hit %d packets, %d bytes sent)N(" R R
R Re R8 t acquireR2 R t
_build_packetR t _logR R t
format_binaryR+ t updatet structt packR4 R R0 R. R) R R{ R! R" t
REKEY_PACKETSt REKEY_BYTESR R% R& t _trigger_rekeyt release( R@ t datat cmdt cmd_namet orig_lent packetRr t payload( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt send_messageS s@
&
$
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 | | st d qn t | d }
| d | |
!} | j r| j t d
| |
f n | j d k r5| 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 rTt d qTnc | j | j" k s| j | j# k rT| j t d | j | j f d | _ d | _ | j$ n t | d } | t% k r}t% | } n
d
| } | j r| j t d | t
| f 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
Rq s IN: s >Ii i s Invalid packet blockings >IIs Mismatched MACi s" Got payload (%d bytes, %d padding)s+ Remote transport is ignoring rekey requestss, Rekeying (hit %d packets, %d bytes received)s $%xs Read packet <%s>, length %dN(& Rv R( RQ R, R R R R R R R R t unpackRe R R* R R5 R R1 R/ t constant_time_bytes_eqR
R3 R
t seqnoR R# R$ R R% R& t REKEY_PACKETS_OVERFLOW_MAXt REKEY_BYTES_OVERFLOW_MAXR R R R ( R@ t headert packet_sizet leftoverR~ R t post_packett mact mac_payloadt my_mact paddingR t msgt raw_packet_sizeR R ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt read_message sn
#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
issubclassRi t listRD ( R@ t levelR t m( ( s3 /usr/lib/python2.7/site-packages/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( R9 R+ R R: R; R< ( R@ t now( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyRo s
c C s t j } x t r y5 | j j d } t | d k rH t n PWnl t j k
r` nY t k
r } t | j
t k r t | j
d k r | j
d t j
k r q n X| j r t n t j } | | | k r t j q q W| S( Ni i ( R: RQ R Rg Re Rf RA R` t EnvironmentErrorRi Rj Rk Rl Rn R ( R@ R` R_ Rt Ru R ( ( s3 /usr/lib/python2.7/site-packages/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' Re R R R- R+ R R t ost urandom( R@ R t bsizeR R ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyR s #
c C s
t | _ d S( N( RQ R ( R@ ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyR s (& R R t __doc__t powR R R R RB t propertyRC RE R RL RM RO RP RR RT RU RV RW RX R[ R\ Ra Rb Rd Rv R{ R R R R Ro R| R R ( ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyR / sB .
1 * , O
( R Rl R RA R R6 R: 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 Rx R t objectR ( ( ( s3 /usr/lib/python2.7/site-packages/paramiko/packet.pyt s 4