ó
čEYc@sAdd
lZdd
l
Z
dd
lZdd
lZdd
lZddlmZ
ddlmZ
dd
l	Z	dd
l
Z
ddlmZ
ddlm
Z

ddl
mZ
ejeƒ
Ze	jrÂdndZddgZd	Zd
ZdZdZd
ef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZ def
d„ƒYZ!de"f
d„ƒYZ#d„Z$d„Z%de"f
d „ƒYZ&d!ef
d"„ƒYZ'd#„Z(d$„Z)d%e"f
d&„ƒYZ*d'Z+d(Z,d)e#f
d*„ƒYZ-d+ej.f
d,„ƒYZ/d
S(-iÿÿÿÿN(
t	jsonutils(
t	timeutils(
t
_(
t_LE(
t_utilst
exceptionstbuiltinss2.0soslo.versionsoslo.messaget_RemotetRPCExceptioncBs eZ
edƒ
Zdd
„
ZRS(s*An unknown RPC related exception occurred.cKs||_|
sƒy|j
|}
Wqƒtk
r


tjtd
ƒ
ƒ

x-|jƒD]\}}tjd||ƒ
qPW|j
}
qƒXntt	|ƒj
|
ƒ

dS(Ns1Exception in string format operation, kwargs are:s%s: %s(tkwargstmsg_fmtt	ExceptiontLOGt	exceptionRtitemsterrortsuperRt__init__(tselftmessageR	tnametvalue((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRPs
	



N(t__name__t
__module__RR
tNoneR(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRMs
tTimeoutcBs,eZ
dZed
ƒ
Zdddd„ZRS(s§Signifies that a timeout has occurred.

    This exception is raised if the rpc_response_timeout is reached while
    waiting for a response from the remote side.
    seTimeout while waiting on RPC response - topic: "%(topic)s", RPC method: "%(method)s" info: "%(info)s"c	Csk|
|_||_
||_tt|ƒjdd
|
p?tdƒ
d|pQtdƒ
d|pctdƒ
ƒ

dS(söInitiates Timeout object.

        :param info: Extra info to convey to the user
        :param topic: The topic that the rpc call was sent to
        :param method: The name of the rpc method being
                                called
        tinfos	<unknown>ttopictmethodN(RRRRRRRR(RRRR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRns	
	
	




N(RRt__doc__RR
RR(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRds
tDuplicateMessageErrorcBseZ
edƒ
ZRS(
s1Found duplicate message(%(msg_id)s). Skipping it.(RRRR
(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR€s
tInvalidRPCConnectionReusecBseZ
edƒ
ZRS(
s#Invalid reuse of an RPC connection.(RRRR
(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR„s
tUnsupportedRpcVersioncBseZ
edƒ
ZRS(
sCSpecified RPC version, %(version)s, not supported by this endpoint.(RRRR
(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR ˆs
tUnsupportedRpcEnvelopeVersioncBseZ
edƒ
ZRS(
sLSpecified RPC envelope version, %(version)s, not supported by this endpoint.(RRRR
(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR!s
tRpcVersionCapErrorcBseZ
edƒ
ZRS(
s6Specified RPC version cap, %(version_cap)s, is too low(RRRR
(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR"’s
t
Connectionc
BseZ
dZd
„ZRS(søA connection, returned by rpc.create_connection().

    This class represents a connection to the message bus used for rpc.
    An instance of this class should never be created by users of the rpc API.
    Use rpc.create_connection() instead.
    c


Cs
tƒ‚
d
S(sîClose the connection.

        This method must be called when the connection will no longer be used.
        It will ensure that any resources associated with the connection, such
        as a network connection, and cleaned up.
        N(
tNotImplementedError(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytcloses(RRRR%(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR#–s
c
Csötj
|Œ}
|d
}i}t|dƒr:|j}ntj|jjƒ
}tj|jjƒ
}|j	t
ƒ
r§|j	t
ƒ
r§|tt
ƒ
 }|tt
ƒ
 }ni|d6|d6tj|ƒ
d6|
d6|jd6|d6}t
j|ƒ
}|S(sfPrepares exception data to be sent over rpc.

    Failure_info should be a sys.exc_info() tuple.

    i
R	tclasstmoduleRttbtargs(t	tracebacktformat_exceptionthasattrR	tsixt	text_typet	__class__RRtendswitht_REMOTE_POSTFIXtlenR)Rtdumps(tfailure_infoR(tfailureR	tcls_nametmod_nametdatat	json_data((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytserialize_remote_exception§s(















csí
tj
tj|ƒ
ƒ
}|jd
gƒ}|jddƒddj|ƒ
‰|jdƒ
}|jdƒ
}|tkr€t}n|tkr´||
kr´tj	||jdƒ
|ƒSyot
|ƒ

tj|}t
||ƒ}t|tƒsûtdƒ
‚
n||jdgƒ|jd	iƒŽ}Wn3tttfk
rX



tj	||jdƒ
|ƒSXt|ƒ
}‡f
d
†}	t|jt|f
i|	d6|	d6ƒ}
d
|tf|
_y
|
|_Wn(tk
rè



ˆf
|jd|_n
X|S(NR(Rts

R&R'sCan only deserialize ExceptionsR)R	c


sˆS(
N((
R(
R(sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt<lambda>ìst__str__t__unicode__s%s%si
(RtloadsR-R.tgettjoint_EXCEPTIONS_MODULESt_EXCEPTIONS_MODULEtoslo_messagingtRemoteErrort
__import__tsystmodulestgetattrt
issubclassRt	TypeErrortAttributeErrortImportErrorttypeRR1RR/R)(R8tallowed_remote_exmodsR5ttraceRR'tmodtklasstex_typetstr_overridetnew_ex_type((
RsS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytdeserialize_remote_exceptionÌs8

#


	







+










tCommonRpcContextcBsDeZ
d„Zd
„Zd„Zed„ƒ
Zd„Zd„ZRS(c
Ks
|
|_dS(
N(
tvalues(RR	((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRÿs
cCs3y|j|
SWnt
k
r.


t|
ƒ
‚
n
XdS(
N(RXtKeyErrorRL(Rtkey((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__getattr__
s




c

Cstj
|jƒ
S(
N(tcopytdeepcopyRX(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytto_dict
s
cCs
||
S(
N((tclsRX((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt	from_dict
sc

Cs|j|j
ƒƒ
S(
N(R`R^(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR]
s
c


CsdS(
N((
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytupdate_store
s(	RRRR[R^tclassmethodR`R]Ra(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRWþs
				tClientExceptionc
BseZ
dZd
„ZRS(sáEncapsulates actual exception expected to be hit by a RPC proxy object.

    Merely instantiating it records the current exception information, which
    will be passed back to the RPC client without exceptional logging.
    c

Cstj
ƒ|_dS(
N(RGtexc_infot	_exc_info(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR
s
(RRRR(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRc
s
c
Cs!itt
6tj|ƒ
t6}
|
S(
N(t_RPC_ENVELOPE_VERSIONt_VERSION_KEYRR3t_MESSAGE_KEY(traw_msgtmsg((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt
serialize_msg!
s

c
s„tˆt
ƒsˆSttf}
tt‡f
d
†|
ƒƒ
sAˆStjtˆtƒsmt	dˆtƒ
‚
nt
jˆtƒ
}|S(Nc

s
|ˆkS(
N((
RZ(
Rj(sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR<G
stversion(t
isinstancetdictRgRhtalltmaptutilstversion_is_compatibleRfR!RR?(Rjtbase_envelope_keysRi((
RjsS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytdeserialize_msg*
s
	


t
DecayingTimercBs)eZ
dd„
Zd
„Zdd„
ZRS(cCstj
d
|
ƒ
|_dS(Ntduration(R
t	StopWatcht_watch(RRv((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRX
s
c


Cs|jj
ƒ
dS(
N(Rxtstart(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRy[
s
cOs||jd
dƒ}|jjdtƒ
}|dkr7|S|dk
r_|
dk	r_|
||Ž
n|dkro|St||ƒS(Ntmaximumtreturn_nonei(tpopRRxtleftovertTruetmin(Rttimeout_callbackR)R	Rztleft((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pytcheck_return^
s






N(RRRRRyR‚(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRuW
s
	tlistentsendtConnectionContextc
BsMeZ
dZd
„Zd„Zd„Zd„Zd„Zd„Zd„Z	RS(sThe class that is actually returned to the create_connection() caller.

    This is essentially a wrapper around Connection that supports 'with'.
    It can also return a new Connection, or one from a pool.

    The function will also catch when an instance of this class is to be
    deleted.  With that we can return Connections to the pool on exceptions
    and so forth without making the caller be responsible for catching them.
    If possible the function makes sure to return a connection to the pool.
    cCsad
|_
|
|_|tk}|r6|
jƒ|_
n|
j|ƒ
|_
||_||j
_d
S(s2Create a new connection, or get one from the pool.N(Rt
connectiontconnection_pooltPURPOSE_SENDR@tcreatetpooled(RR‡tpurposeRŠ((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR‰
s	
	



	
c


Cs|S(
s3When with ConnectionContext() is used, return self.((
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt	__enter__–
sc

CsÔ|jrÐ|j
rŸzsy|jjƒ
Wn[tk
rƒ


tjtd
ƒ
ƒ

y|jjƒ
Wntk
rm


n
X|jj	ƒ|_n
XWd|jj
|jƒ

Xn%y|jjƒ
Wntk
rÃ


n
Xd|_ndS(s{If the connection came from a pool, clean it up and put it back.
        If it did not come from a pool, close it.
        s%Fail to reset the connection, drop itN(R†RŠtresetRRR
RR%R‡R‰tputR(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt_doneš
s$	
	














c
Cs|jƒ
d
S(s*End of 'with' statement.  We're done here.N(
R(Rtexc_typet	exc_valueR(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__exit__´
sc


Cs|jƒ
d
S(s>Caller is done with this connection.  Make sure we cleaned up.N(
R(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__del__¸
sc


Cs|jƒ
d
S(s$Caller is done with this connection.N(
R(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR%¼
scCs&|jrt
|j|
ƒStƒ‚
d
S(s1Proxy all other calls to the Connection instance.N(R†RIR(RRZ((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR[À
s	
(
RRRRRŒRR’R“R%R[(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR…}
s
	
					tConfigOptsProxycBsfeZ
dZd
„Zd„Zd„Zd„Zd„Zd„Zd„Z	de
jf
d	„ƒYZRS(
s¾Proxy for oslo_config.cfg.ConfigOpts.

    Values from the query part of the transport url (if they are both present
    and valid) override corresponding values from the configuration.
    cCs)|
|_||_
||_|jƒ
dS(
N(t_conft_urlt_groupt_validate_query(Rtconfturltgroup((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRÏ
s
	
	
	
c
CsHxA|jj
D]3}
|j|j|j|j|j|jƒ|

q
WdS(
N(R–tquerytGroupAttrProxyR•R—(RR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR˜Õ
s




cCsVt|j
|
ƒ}t||j
jƒrR|
|jkrR|j|j
|
||jƒS|S(
N(RIR•Rmt	GroupAttrR—RR–(RRR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR[Û
s

$

cCs
|j|
ƒ
S(
N(
R[(RR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__getitem__á
s
cCs
|
|jkS(
N(
R•(RR((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__contains__ä
s
c

Cs
t|j
ƒ
S(
N(titerR•(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__iter__ç
s
c

Cs
t|j
ƒ
S(
N(R2R•(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt__len__ê
s
Rc
BsMeZ
dZeƒZd
„Zd„Zd„Zd„Zd„Z	d„Z
RS(s?Internal helper proxy for oslo_config.cfg.ConfigOpts.GroupAttr.cCs(|
|_||_
||_||_dS(
N(R•t_group_nameR—R–(RR™t
group_nameR›Rš((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRò
s
	
	
	
cCsit|j
|
ƒ}|jjj|
|jƒ}||jkr@|S|jj|
|jƒ}|d
j	|ƒ
S(Ntopt(
RIR—R–RœR@t_VOID_MARKERR•t
_get_opt_infoR¤RN(Rtopt_nametopt_value_conft
opt_value_urltopt_info((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR[ø
s



cCs
|j|
ƒ
S(
N(
R[(RR©((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRŸs
cCs
|
|jkS(
N(
R—(RR©((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR s
c

Cs
t|j
ƒ
S(
N(R¡R—(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR¢	s
c

Cs
t|j
ƒ
S(
N(R2R—(
R((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR£s
(RRRtobjectR§RR[RŸR R¢R£(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyRí
s
						(
RRRRR˜R[RŸR R¢R£tcollectionstMappingR(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyR”È
s							(0R®R\tloggingRGR*toslo_serializationRt
oslo_utilsR
R-RDtoslo_messaging._i18nRRRRqt	getLoggerRRtPY2RCRBRfRgRhR1RRRRRR R!R"R­R#R:RVRWRcRkRtRutPURPOSE_LISTENRˆR…R¯R”(((sS/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/_drivers/common.pyt<module>sJ









!
	%	2
			-"
K