ó
õEYc@@sü
dZd
dl
mZmZ
d
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
mZ
d
dlmZ
ddl
mZ
ddlmZ
dd	lmZmZmZ
dd
lmZmZ
yd
dl	mZ
Wn'ek
r



def
d
„ƒYZn
XejejejejhZdZ e!ƒZ"dZ#dj$dƒ
Z%ej&dƒ
Z'd(Z(d„e(Dƒ
Z)er›
e(d)7Z(e)j*eƒ

ne d „
Z+d!e,f
d"„ƒYZ-d#e-f
d$„ƒYZ.d%e-f
d&„ƒYZ/de1d'„Z2dS(*uTransport implementation.i(tabsolute_importtunicode_literalsN(
tcontextmanager(
tunpacki
(
tUnexpectedFrame(
titems(tSOL_TCPtTCP_USER_TIMEOUTtHAS_TCP_USER_TIMEOUT(t	get_errnotset_cloexec(
tSSLErrorRc
B@seZ
dZRS(
uDummy SSL exception.(t__name__t
__module__t__doc__(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR%s
i(iÿÿÿuAMQP

	ulatin_1u\[([\.0-9a-f:]+)\](?::(\d+))?uTCP_CORKuTCP_DEFER_ACCEPTuTCP_KEEPCNTuTCP_KEEPIDLEu
TCP_KEEPINTVLuTCP_LINGER2u
TCP_MAXSEGuTCP_NODELAYuTCP_QUICKACKu
TCP_SYNCNTuTCP_WINDOW_CLAMPc
C@s.h|]$}
tt
|
ƒrtt
|
ƒ’qS((thasattrtsockettgetattr(t.0topt((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pys	<setcomp>>s	uTCP_USER_TIMEOUTcC@s‘|
}tj
|ƒ
}|rT|jd
ƒ
}|jdƒ
r‡t|jdƒ
ƒ
}q‡n3d|kr‡|jdd
ƒ\}}t|ƒ
}n||fS(u1Convert hostname:port string to host, port tuple.i
iu
:(tIPV6_LITERALtmatchtgrouptinttrsplit(thosttdefaulttportt
m((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pytto_host_portEs







t_AbstractTransportcB@s­eZ
dZeZdddded
„Zd„Ze	d„ƒ
Z
d„Zd„Zd„Z
d„Zed„
Zd	„Zd
„Zd„Zd„Zed
„
Zd„ZRS(u-Common superclass for TCP and SSL transports.cK@sdt|_
d|_||_t|_t|
ƒ
\|_|_	||_
||_||_||_
dS(
N(tTruet	connectedtNonetsocktraise_on_initial_eintrtEMPTY_BUFFERt_read_bufferRRRtconnect_timeouttread_timeoutt
write_timeouttsocket_settings(tselfRR&R'R(R)R#tkwargs((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt__init__Ys	
	
	
	

	
	
	
c

C@s<|j|j
|j|jƒ
|j|j|j|jƒ
dS(
N(t_connectRRR&t_init_socketR)R'R((
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pytconnectfs


cc@s×|
dkr|j
V
n¼|j
}|jƒ}||
krH|j|
ƒ

nzky|j
V
WnXtk
r±
}
d
t|ƒ
krŠtjƒ‚
n!dt|ƒ
kr«tjƒ‚
n‚n
XWd|
|krÒ|j|ƒ

nXdS(Nu	timed outuThe operation did not complete(R!R"t
gettimeoutt
settimeoutRtstrRttimeout(R*R3R"tprevtexc((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pythaving_timeoutls"
	









cC@s
tj
|
|d
tjtƒ}xÝt|ƒ
D]Ï\}}|\}}}	}
}ydtj|||	ƒ|_yt|jtƒ
Wntk
rŽ


n
X|jj	|ƒ

|jj
|ƒ

WnFtjk
rø


|jjƒ
d|_|dt|ƒ
krú‚qúq+XPq+WdS(Nii
(RtgetaddrinfotSOCK_STREAMRt	enumerateR"R
RtNotImplementedErrorR1R/terrortcloseR!tlen(R*RRR3tentriest
itrestaftsocktypetprotot	canonnametsa((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR-ƒs$















	


cC@s

yº|jj
dƒ

|jjtjtjd
ƒ
|j|
ƒ

xctj|ftj	|ffD]C\}}|dk	r[|jjtj|t
jd|dƒƒ
q[q[W|jƒ
|j
tƒ

Wn@tttjfk
rü
}
t|ƒ
tkröt|_n‚n
XdS(Ni
tlli(R"R1R!t
setsockoptRt
SOL_SOCKETtSO_KEEPALIVEt_set_socket_optionstSO_SNDTIMEOtSO_RCVTIMEOtstructtpackt_setup_transportt_writetAMQP_PROTOCOL_HEADERtOSErrortIOErrorR;R	t_UNAVAILtFalseR (R*R)R'R(R3tintervalR5((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR.™s 







	
	





c@s‡f
d
†tDƒ
S(Nc
@s%i|]}
ˆjt
|
ƒ|
“qS((t
getsockoptR(RR(
R"(sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pys
<dictcomp>±s	(
tTCP_OPTS(R*R"((
R"sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt_get_tcp_socket_defaults¯scC@sød
}|jdk	r4ttj|jdƒ
ƒ
}n|
sv|jjttj	dƒ
t
rr|jjtt|ƒ
ndS|j|jƒ
}|j
tj	dƒ
t
r´|j
t|ƒ
n|j|
ƒ

x0t|ƒ
D]"\}}|jjt||ƒ
qÎWdS(Nig@@i
(R&R!RtmathtceilR"RGRRtTCP_NODELAYRRRYt
setdefaulttupdateR(R*R)tuser_timeoutttcp_optsRtval((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRJ´s












cC@std
ƒ
‚
dS(u#Read exactly n bytes from the peer.uMust be overriden in subclassN(
R:(R*t
ntinitial((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt_readÈsc


C@sd
S(u.Do any additional initialization of the class.N((
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyROÌsc


C@sd
S(u8Do any preliminary work in shutting down the connection.N((
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt_shutdown_transportÐscC@std
ƒ
‚
dS(u&Completely write a string to the peer.uMust be overriden in subclassN(
R:(R*t
s((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRPÔsc

C@sR|jdk	rE|jƒ
|jjtjƒ

|jjƒ
d|_nt|_dS(
N(	R"R!RetshutdownRt	SHUT_RDWRR<RUR (
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR<Øs






c
C@sz
|j}t
}y|d
tƒ}||7}|
d|ƒ\}}}|tkrƒ|tƒ
}||tƒ
}	dj||	gƒ
}
n||ƒ
}
||
7}t|dƒ
ƒ
}Wn™tjk
rÕ


||j|_‚nst	t
ttjfk
rG

}
t
|tƒr#
dt|ƒ
kr#
tjƒ‚
nt|ƒ
tkrA
t|_n‚n
X|dkra
|||
fStdj|ƒ
ƒ
‚
dS(Nis>BHIui
u	timed outiÎu&Received {0:#04x} while expecting 0xce(RdR$RtSIGNED_INT_MAXtjointordRR3R%RRRSRR;t
isinstanceR2R	RTRUR Rtformat(
R*Rtreadtread_frame_buffertframe_headert
frame_typetchanneltsizetpart1tpart2tpayloadtchR5((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt
read_frameãs4
	















!







cC@sny|j|
ƒ

WnVt
jk
r*


‚n@ttt
jfk
ri
}
t|ƒ
tkrct|_	n‚n
XdS(
N(
RPRR3RRRSR;R	RTRUR (R*RfR5((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pytwrite
s







N(RR
RRUR R!RR,R/RR6R-R.RYRJRdROReRPR<RRxRy(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRTs$


									"tSSLTransportcB@sqeZ
dZddd
„Zd„Zdd„
Zdd„
Zd„Ze	e
je
je
j
fd„Zd„ZRS(	uTransport that works over SSL.cK@sJt|t
ƒr|ni|_t|_tt|ƒj|
d
||


dS(NR&(RltdicttssloptsR$R%tsuperRzR,(R*RR&tsslR+((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR,
s

	

c

C@sA|j|j
|jpi
|_
|j
jƒ
|j
j|_d
S(u!Wrap the socket in an SSL object.N(t_wrap_socketR"R|tdo_handshakeRnt_quick_recv(
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRO
s!


cK@s)|r|j|
||St
j|
|
S(
N(t
_wrap_contextR~twrap_socket(R*R"tcontextR|((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR
s


cK@s(tj
|}||_|j|
|
S(
N(R~tcreate_default_contexttcheck_hostnameRƒ(R*R"R|R†tctx_optionstctx((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR‚$
s

	
c
C@sG|jd
k	rCy|jj}
Wntk
r3


d
SX|
ƒ|_nd
S(u:Unwrap a Python 2.6 SSL socket, so we can call shutdown().N(R"R!tunwraptAttributeError(R*R‰((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRe)
s





c	C@sé|j}|j
}y¥xžt|ƒ
|
krµy||
t|ƒ
ƒ
}WnLtjk
r’
}
|j|krŒ|r|jrtjƒ‚
qqn‚n
X|s¨td
ƒ
‚
n||7}qWWn


||_
‚n
X||
 ||
}|_
|S(Nu
Socket closed(	RR%R=RR;terrnoR#R3RS(	R*RbRct_errnostrecvtrbufRfR5tresult((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRd2
s(	
	













	


cC@sl|jj
}xY|
rgy||
ƒ
}Wnttfk
rD


d
}n
X|sZtdƒ
‚
n|
|}
qWdS(u+Write a string out to the SSL socket fully.iu
Socket closedN(R"Ryt
ValueErrorRŠRS(R*RfRyRb((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRPN
s
	






N(RR
RR!R,RORR‚ReRUR‹tENOENTtEAGAINtEINTRRdRP(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRz
s
			
tTCPTransportcB@s2eZ
dZd
„Zeejejfd„ZRS(u.Transport that deals directly with TCP socket.c

C@s+|jj
|_t|_|jj|_dS(
N(R"tsendallRPR$R%RR(
R*((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyROe
s
	
c	C@sé|j}|j
}y¥xžt|ƒ
|
krµy||
t|ƒ
ƒ
}WnLtjk
r’
}
|j|krŒ|r|jrtjƒ‚
qqn‚n
X|s¨td
ƒ
‚
n||7}qWWn


||_
‚n
X||
 ||
}|_
|S(u%Read exactly n bytes from the socket.u
Socket closed(	RR%R=RR;R‹R#R3RS(	R*RbRcRŒRRŽRfR5R((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyRdl
s(	
	














	

(	RR
RRORUR‹R’R“Rd(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyR”b
s
	cK@s+|rtnt
}||d
|
d||
S(u‹Create transport.

    Given a few parameters from the Connection constructor,
    select and create a subclass of _AbstractTransport.
    R&R~(RzR”(RR&R~R+t	transport((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt	Transport…
s
(uTCP_CORKuTCP_DEFER_ACCEPTuTCP_KEEPCNTuTCP_KEEPIDLEu
TCP_KEEPINTVLuTCP_LINGER2u
TCP_MAXSEGuTCP_NODELAYuTCP_QUICKACKu
TCP_SYNCNTuTCP_WINDOW_CLAMP(
uTCP_USER_TIMEOUT(3Rt
__future__RR
R‹RZtreRMRR~t
contextlibRRt
exceptionsRtfiveRtplatformRRRtutilsR	R
RtImportErrort	ExceptionR’R“R‘tEWOULDBLOCKRTt	AMQP_PORTtbytesR$RitencodeRQtcompileRtKNOWN_TCP_OPTSRXtaddRtobjectRRzR”R!RUR—(((sC/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/transport.pyt<module>
sH












	





¼R#