ó
°‹EYc@s 
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlmZ
d
dl	m
Z

d
dlmZm
Z
mZmZmZmZmZ
d
dlmZmZ
d
dlmZmZ
d
dlmZ
d	„Zd
ef
d„ƒYZd„Zd
ef
d„ƒYZ dS(s
Packet handling
iÿÿÿÿN(
tHMAC(
tutil(t
linefeed_bytet
cr_byte_valuetasbytest	MSG_NAMEStDEBUGt	xfffffffft	zero_byte(t
utbyte_ord(tSSHExceptiontProxyCommandFailure(
tMessagecCst||
|ƒj
ƒS(
N(Rtdigest(tkeytmessagetdigest_class((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytcompute_hmac)s
tNeedRekeyExceptionc
BseZ
dZRS(
s1
    Exception indicating a rekey is needed.
    (t__name__t
__module__t__doc__(((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyR-s
c
CsDd}
t
|jƒ
tkr@t|jƒ
d
kr@|jd
}
n|
S(Ni(tNonettypetargsttupletlen(t
etarg((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt	first_arg4s

*

t
PacketizercBsR
eZ
dZed
dƒZed
dƒZed
dƒZed
dƒZd„Ze	d„ƒ
Z
d„Zed„
Z
d„Zd„Zd	„Zd
„Zd„Zd„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zed„
Zd„Zd„Zd„Zd„Z d„Z!d„Z"d„Z#d„Z$d„Z%RS(s9
    Implementation of the base SSH packet protocol.
    iicCsT
|
|_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
|_tj ƒ|_!d
|_"t#j#ƒ|_$d|_%d|_&t|_'t|_(dS(Nii()t_Packetizer__socketRt_Packetizer__loggertFalset_Packetizer__closedt_Packetizer__dump_packetst_Packetizer__need_rekeyt_Packetizer__init_counttbytest_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	threadingtRLockt_Packetizer__write_lockt_Packetizer__keepalive_intervalttimet_Packetizer__keepalive_lastt_Packetizer__keepalive_callbackt_Packetizer__timert_Packetizer__handshake_completet_Packetizer__timer_expired(tselftsocket((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt__init__KsF
	
	
	
	
	
	
	
	
	
	
	
		
	
	
	
	
	
	
	
	


	
	
	
		

		
	
c


Cs|jS(
N(
R#(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytclosedyscCs
|
|_d
S(s?
        Set the Python log object to use for logging.
        N(
R!(RHtlog((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_log}scCs|
|_||_
||_||_||_||_d
|_d
|_|jdO_|jdkr{d
|_t	|_
ndS(s.
        Switch outbound data cipher.
        ii
iN(R3R5R/R6R1R8R)R*R&R"R%(RHtblock_enginet
block_sizet
mac_enginetmac_sizetmac_keytsdctr((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_outbound_cipherƒs	
	
	
	
	
	
	
	

	
cCsˆ|
|_||_
||_||_||_d
|_d
|_d
|_d
|_|j	dO_	|j	dkr„d
|_	t
|_ndS(s-
        Switch inbound data cipher.
        iiiN(R4R0R7R2R9R+R,R-R.R&R"R%(RHRNRORPRQRR((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_inbound_cipher—s	
	
	
	
	
	
	
	
	

	
cCs
|
|_dS(
N(
R:(RHt
compressor((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_outbound_compressor¬s
cCs
|
|_dS(
N(
R;(RHRV((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_inbound_compressor¯s
c

Cst|_
|jjƒ
dS(
N(tTrueR#R tclose(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyRZ²s
	
cCs
|
|_dS(
N(
R$(RHthexdump((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytset_hexdump¶s
c


Cs|jS(
N(
R$(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytget_hexdump¹s
c


Cs|jS(
N(
R2(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytget_mac_size_in¼s
c


Cs|jS(
N(
R1(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytget_mac_size_out¿s
c


Cs|jS(
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((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt
need_rekeyÂscCs%|
|_||_
tjƒ|_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(RARDRBRC(RHtintervaltcallback((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt
set_keepaliveÊs	
	
c

Cs
t|_
dS(
N(RYRG(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt
read_timerÔs
cCs;|js7t
jt|
ƒ
|jƒ|_|jjƒ
nd
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(RER>tTimertfloatRdtstart(RHttimeout((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytstart_handshake×s	

c


Cs!|js
t
S|jrt
S|jS(
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`
        (RER"RFRG(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pythandshake_timed_outãs

	

	

c

Cs/|jr+|jj
ƒ
t|_t|_nd
S(sF
        Tells `Packetizer` that the handshake has completed.
        N(REtcancelR"RGRYRF(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytcomplete_handshakeós	


	
cCs¦
tƒ}t
|jƒ
d
krN|j|
 }|j|
|_|
t
|ƒ
8}
nxQ
|
d
kr¡
t}|jƒr{tƒ‚
nyN|jj|
ƒ
}t
|ƒ
d
kr®tƒ‚
n||7}|
t
|ƒ
8}
Wn}tj	k
rå


t
}ndtjk
rH

}
t|ƒ
}|t
jkr
t
}qI
|t
jkr-
qI
|jrB
tƒ‚
qI
‚n
X|rQ|jrd
tƒ‚
n|r‘
t
|ƒ
d
kr‘
|jr‘
tƒ‚
n|jƒ
qQqQW|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'RR(R"RjtEOFErrorR trecvRIRhRYterrorRterrnotEAGAINtEINTRR#R%Rt_check_keepalive(RHt
ntcheck_rekeytouttgot_timeoutt
xRR((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytread_allüsB	
















	


	

	


	

!


cCso
tjƒ|_
d
}xS
t|
ƒ
d
krj
t}y|jj|
ƒ
}Wnštjk
rb


t}ntj	k
r¹
}
t
|ƒ
}|tjkr˜t}qã|tj
kr°t}qãd}n*tk
rÌ


‚ntk
râ


d}n
X|r
d
}|jr/
d}q/
n+|d
kr%
|dkr%
d}n|d7}|d
krG
tƒ‚
n|t|
ƒ
kr]
Pn|
|}
qWdS(Niiÿÿÿÿi
i
(RBRCRR"R tsendRIRhRYRoRRpRqRrRt	ExceptionR#Rm(RHRvt#iteration_with_zero_as_return_valuetretry_writeRtRR((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt	write_all/
s@







	



	
		








	
	







cCs’|j}x#t
|kr.||j|
ƒ
7}qW|jt
ƒ
}||d
|_|| }t|ƒ
dkrˆ|dtkrˆ|d }nt|ƒ
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
iiÿÿÿÿ(R(Rt
_read_timeouttindexRRR	(RHRhtbufRt((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytreadlineZ
s	






"


c	Cst|
ƒ
}
t
|
d
ƒ
}|tkr5t|}n
d|}t|
ƒ
}|jjƒ
z¦
|jdk	r||j|
ƒ
}
n|j|
ƒ
}|j	rÍ|j
td||fƒ
|j
ttj
|dƒƒ
n|jdk	rñ|jj|ƒ
}n|}|jdk	rE
tjd|jƒ|}|t|j||jƒ|j 7}n|jdt@|_|j|ƒ

|jt|ƒ
7_|jd7_|j|jkp«
|j|jk}|rý
|jrý
|j
td|j|jfƒ
d
|_d
|_|j ƒ
nWd|jj!ƒ
XdS(	sR
        Write a block of data using the current cipher, as an SSH block.
        is$%xsWrite packet <%s>, length %dsOUT: s>Ii
s(Rekeying (hit %d packets, %d bytes sent)N("RR
RRR@tacquireR:Rt
_build_packetR$t_logRR
t
format_binaryR3tupdatetstructtpackR<RR8R6R1RR~R)R*t
REKEY_PACKETStREKEY_BYTESR%R-R.t_trigger_rekeytrelease(	RHtdatatcmdtcmd_nametorig_lentpacketRvtpayloadt
sent_too_much((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytsend_messagei
sN












	

















	
	
c
Cs½|j|j
d
tƒ

}
|jdk	r<|jj|
ƒ
}
n|jrd|jtt	j
|
dƒƒ
ntjd|
d ƒd}|
d}|t
|ƒ
|j
dkr´tdƒ
‚
n|j||jt
|ƒ
ƒ
}||t
|ƒ
 }||t
|ƒ
}|jdk	r 
|jj|ƒ
}n|jrH
|jtt	j
|dƒƒ
n||}|jdkrÍ
||j }tjd|j|ƒ|}t|j||jƒ|j }	t	j|	|ƒsÍ
tdƒ
‚
qÍ
nt|dƒ
}
|d	||
!}|jr|jtd
||
fƒ
n|jdk	r5|j|ƒ
}nt|d	ƒ
}|j|_|jd	t@|_||jd}
|j|
7_|jd	7_|jrñ|j|
7_|jd	7_|j|j ksß|j|j!krTtdƒ
‚
qTnc|j|j"ks|j|j#krT|jtd|j|jfƒ
d|_d|_|j$ƒ
nt|dƒ
}|t%kr}t%|}n
d
|}|jr³|jtd|t
|ƒ
fƒ
n||fS(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
        RusIN: s>IiisInvalid packet blockings>IIsMismatched MACi
s"Got payload (%d bytes, %d padding)s+Remote transport is ignoring rekey requestss,Rekeying (hit %d packets, %d bytes received)s$%xsRead packet <%s>, length %dN(&RyR0RYR4RR‡R$R…RR
R†RˆtunpackRRR2R‰R=RR9R7tconstant_time_bytes_eqR
R;R
tseqnoRR+R,R%R-R.tREKEY_PACKETS_OVERFLOW_MAXtREKEY_BYTES_OVERFLOW_MAXRŠR‹RŒR(RHtheadertpacket_sizetleftoverRR’tpost_packettmactmac_payloadtmy_mactpaddingR“tmsgtraw_packet_sizeRR((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pytread_messageŸ
s„


	





 




	














	








	










	
	






	



cCsf|jdkrdStt|ƒ
tƒrOx7|D]}|jj|
|ƒ
q/Wn|jj|
|ƒ
dS(
N(R!Rt
issubclassRtlistRL(RHtlevelR£t
m((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyR…ù
s





c
Cs]|js|j
s|jr!dStjƒ}
|
|j|jkrY|jƒ
|
|_ndS(
N(RAR3R%RBRCRD(RHtnow((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyRss



	




cCsÖtjƒ}xÃt
rÑy5|jjd
ƒ
}t|ƒ
dkrHtƒ‚
nPWnAtjk
r`


n.tk
r
}
t	|ƒ
t
jkr‡qŽ‚n
X|jr£tƒ‚
ntjƒ}|||
krtjƒ‚
qqW|S(Ni€i(
RBRYR RnRRmRIRhtEnvironmentErrorRRpRrR#(RHRhRgRxRRª((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyRs&

	










	




cCs’|j}d
|t
|
ƒ
d|}tjdt
|
ƒ
|d|ƒ}||
7}|jsj|jdkr{|t|7}n|tj	|ƒ
7}|S(Niis>IBi
(
R/RRˆR‰R5R3RRtosturandom(RHR“tbsizeR¢R’((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyR„%s	

#



c

Cs
t|_
dS(
N(RYR%(
RH((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyRŒ4s(&RRRtpowRŠR‹R™RšRJtpropertyRKRMR"RTRURWRXRZR\R]R^R_R`RcRdRiRjRlRyR~R‚R•R¥R…RsRR„RŒ(((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyR;sB
	.											
					3	+		6	Z			
		(!RRpR¬RIRˆR>RBthmacRtparamikoR
tparamiko.commonRRRRRRRtparamiko.py3compatR	R
tparamiko.ssh_exceptionRRtparamiko.messageR
RR{RRtobjectR(((sD/home/tvault/.virtenv/lib/python2.7/site-packages/paramiko/packet.pyt<module>s 






4