ó
Á}ac@s%dd
dddddddd	d
gZddl
Z
dd
lmZ
ddlZddlmZ
ddl	m
Z

ddlmZ
ddl
ZddlZddlmZ
ejjZejeƒ
Zdadadadaejjg
ZgZidd6dd6dd6Zd„Z ddl!m"Z"
d„Z#d„Z$d„Z%d„Z&d„Z'd„Z(d ej)f
d!„ƒYZ*dej+f
d"„ƒYZ,dd#„
Z-ddd$„Z.dd%„
Z/ddd&„Z0d'„Z1d(„Z2d)e3f
d*„ƒYZ4d+e3f
d,„ƒYZ5d-e
j6f
d.„ƒYZ7d/„Z8dS(0tinittcleanuptset_defaultstadd_extra_exmodstclear_extra_exmodstget_allowed_exmodstRequestContextSerializert
get_clientt
get_servertget_notifiertTRANSPORT_ALIASESiÿÿÿÿN(
tlog(
t	jsonutils(
t
periodic_task(
t	timeutils(
t
_trabbitscontego.rpc.impl_kombutqpidscontego.rpc.impl_qpidtzmqscontego.rpc.impl_zmqc

Cstj
|ƒ

dS(
N(t	messagingtset_transport_defaults(
tcontrol_exchange((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR2s
(
tcfgc

CsJtj
d
ddddgddddd	d
ƒ
g
}
|
}|j|ƒ

dS(Ntnotification_formattchoicestunversionedt	versionedtbothtdefaulttdeprecated_grouptDEFAULTthelpt(RtStrOptt
register_opts(tconftnotification_optstALL_OPTS((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR"6s





c
Cs
t|ƒ

t
ƒ}
tj|d
|
ƒ

atj|d
|
ƒ

attƒƒ
}|j	dkrŽtj
td|ƒ

atj
td|ddƒ
an~|j	dkrÓtj
td|ƒ

atj
td|ddg
ƒ
an9tj
td|ddƒ
atj
td|ddg
ƒ
adS(	Ntallowed_remote_exmodsRt
serializertdrivertnoopRttopicstversioned_notifications(
R"RRt
get_transportt	TRANSPORTtget_notification_transporttNOTIFICATION_TRANSPORTRtJsonPayloadSerializerRtNotifiertLEGACY_NOTIFIERtNOTIFIER(R#texmodsR'((s//usr/lib/python2.7/dist-packages/contego/rpc.pyREs.

	





	




	




	


cCsrtdk	st‚
tdk	s$t‚
tdk	s6t‚
tdk	sHt‚
tjƒ
tjƒ
daaaadS(
N(R-tNonetAssertionErrorR/R2R3R
(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR
bs







c
Gstj
|ƒ

dS(
N(tEXTRA_EXMODStextend(
targs((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRps
c
Cst2dS(
N(
R7(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRts
cCstt
S(
N(tALLOWED_EXMODSR7(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRxs
R0cBseZ
ed„ƒ
ZRS(
cCstj
|
d
tƒ

S(Ntconvert_instances(Rtto_primitivetTrue(tcontexttentity((s//usr/lib/python2.7/dist-packages/contego/rpc.pytserialize_entity}s(t__name__t
__module__tstaticmethodR@(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR0|s
c
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(cCs
|
|_dS(
N(
t_base(tselftbase((s//usr/lib/python2.7/dist-packages/contego/rpc.pyt__init__„s
cCs |js
|S|jj
|
|ƒS(
N(RDR@(RER>R?((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR@‡s
	

cCs |js
|S|jj
|
|ƒS(
N(RDtdeserialize_entity(RER>R?((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRHŒs
	

c
Cs
|
jƒS(
N(
tto_dict(RER>((s//usr/lib/python2.7/dist-packages/contego/rpc.pytserialize_context‘s
cCstj
jj|
ƒ
S(
N(tcontegoR>tRequestContextt	from_dict(RER>((s//usr/lib/python2.7/dist-packages/contego/rpc.pytdeserialize_context”s
(RARBRGR@RHRJRN(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR‚s
				c

Cstj
jt|tƒS(
N(RtTransportURLtparsetCONFR
(
turl_str((s//usr/lib/python2.7/dist-packages/contego/rpc.pytget_transport_url˜s
cCsntj
j}tjjg
g}tj|d
|ƒ

}|dk	sFt‚
t	|ƒ
}tj
||d|
d|ƒS(NR&tversion_capR'(RKR#RQt	exceptionRARR,R5R6Rt	RPCClient(ttargetRTR'R#R4R-((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRœs




	


cCs=tdk	st‚
t|ƒ
}tjt||
d
dd|ƒS(NtexecutorteventletR'(R-R5R6RRtget_rpc_server(RWt	endpointsR'((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR©s


	



cCsJtdk	st‚
|s4d
||
p*tjf}nttjd|ƒ
ƒ
S(Ns%s.%stpublisher_id(R2R5R6RQthosttLegacyValidatingNotifiertprepare(tserviceR]R\((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR	³s





c

Cs"tdk	st‚
tjd
|ƒ
S(NR\(R3R5R6R_(
R\((s//usr/lib/python2.7/dist-packages/contego/rpc.pytget_versioned_notifier»s

c
Cs"tƒ}
t
jtd
|d|
ƒ
S(NturlR&(RRR,RQ(RbR4((s//usr/lib/python2.7/dist-packages/contego/rpc.pytcreate_transportÀs
	


R^cBsDeZ
dZeZd
g
Zedƒ
Zd„Zd„Z	d„Z
RS(sDWraps an oslo.messaging Notifier and checks for allowed event_types.saggregate.addhost.endse%(event_type)s is not a versioned notification and not whitelisted. See ./doc/source/notification.rstcCsL|
|_x<d
ddddgD]%}t
||tj|j|ƒƒ
qWdS(Ntdebugtinfotwarnterrortcritical(tnotifiertsetattrt	functoolstpartialt_notify(RERitpriority((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRGÛs
	

	
cCsd
dht|
j
ƒƒ
kS(NRUR9(tsettkeys(REtpayload((s//usr/lib/python2.7/dist-packages/contego/rpc.pyt_is_wrap_exception_notificationáscCs‚||jkrb|j
|ƒ
rb|jrEt|ji
|d
6ƒ
‚
qbtj|ji
|d
6ƒ
nt|j|
ƒ|||ƒ
dS(Nt
event_type(	t'allowed_legacy_notification_event_typesRrtfatalR6tmessagetLOGtwarningtgetattrRi(RERntctxtRsRq((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRmês


	
(RARBt__doc__tFalseRuRtRRvRGRrRm(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR^Çs
				t
ClientWrappercBs eZ
d„Zed
„ƒ
ZRS(cCs|
|_t
jƒ|_dS(
N(t_clientRtutcnowtlast_access_time(REtclient((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRGös
	
c

Cstj
ƒ|_|jS(
N(RRR€R~(
RE((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRús
(RARBRGtpropertyR(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR}õs
	tClientRoutercBs5eZ
dZd
„Zdd„
Zejd„ƒ
ZRS(sËCreates and caches RPC clients that route to cells or the default.

    The default client connects to the API cell message queue. The rest of the
    clients connect to compute cell message queues.
    cCstt
|ƒjtƒ

i|_t|
ƒ
|jd
<|
j|_|
j|_t|
ddƒ|_
|jtj
jdtƒ
ƒ

dS(NRR't	overwrite(tsuperRƒRGRQtclientsR}RWRTRyR5R'trun_periodic_tasksRKR>RLR|(REtdefault_client((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRG
s

	



cCs|r|j}nd
}y|j
|j}WnZtk
rˆ


t|jƒ
}tj||jd|j	d|j
ƒ}t|ƒ
|j
|<n
X|S(NRRTR'(tuuidR†RtKeyErrorRct
transport_urlRRVRWRTR'R}(RER>tcell_mappingt	client_idRt	transport((s//usr/lib/python2.7/dist-packages/contego/rpc.pyR~
s







	

cspd
‰‡f
d†}t|j
jƒƒ
}x?|D]7\}}|dkr1|||jƒr1|j
|=q1q1WdS(Ni<cs-tj
|
ˆƒr)tjd
||
ƒ
tStS(Ns;Removing stale RPC client: %s as it was last accessed at %s(Rt
is_older_thanRwRdR=R|(RR€(
ttimeout(s//usr/lib/python2.7/dist-packages/contego/rpc.pytstale&
s


	



R(tlistR†titemsR€(RER>R‘t
items_copyRtclient_wrapper((
Rs//usr/lib/python2.7/dist-packages/contego/rpc.pyt_remove_stale_clients"
s



N(RARBR{RGR5R~R
R–(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyRƒ
s
	c
s"tj
ˆƒ
‡f
d
†ƒ
}
|
S(sCCalls decorated method only if versioned notifications are enabled.cs3tj
ƒr+tjjdkr+ˆ||
ŽSdSdS(NRR(sboths	versioned(R3t
is_enabledRQt
notificationsRR5(R9tkwargs(
t
f(s//usr/lib/python2.7/dist-packages/contego/rpc.pytwrapped7
s

	
	

(Rktwraps(RšR›((
Ršs//usr/lib/python2.7/dist-packages/contego/rpc.pytif_notifications_enabled5
s(9t__all__Rktoslo_logRtloggingtoslo_messagingRtoslo_serializationRtoslo_serviceR
t
oslo_utilsRtcontego.confRKtcontego.exceptiontcontego.i18nRR#RQt	getLoggerRARwR5R-R2R/R3RUR:R7R
Rtoslo_configRR"RR
RRRtNoOpSerializerR0t
SerializerRRSRRR	RaRctobjectR^R}t
PeriodicTasksRƒR(((s//usr/lib/python2.7/dist-packages/contego/rpc.pyt<module>sf









	













	
						

		.5