ó
²£ýac@sdd
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S(/tinittcleanupt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
_trabbitsdmapi.rpc.impl_kombutqpidsdmapi.rpc.impl_qpidtzmqsdmapi.rpc.impl_zmqc

Cstj
|ƒ

dS(
N(t	messagingtset_transport_defaults(
tcontrol_exchange((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR7s
(
tcfgc

Cs\tj
d
ddddgddddd	d
ƒ
tjdd	dƒ

g}
|
}|j|ƒ

dS(
Ntnotification_formattchoicestunversionedt	versionedtbothtdefaulttdeprecated_grouptDEFAULTthelptthosts   (RtStrOpttHostAddressOptt
register_opts(tconftnotification_optstALL_OPTS((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR$=s






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/site-packages/dmapi/rpc.pyROs.

	





	




	




	


cCs*tj
ƒ
tj
ƒ
daaaadS(
N(R/R
R1tNoneR4R5(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR
ls



c
Gstj
|ƒ

dS(
N(tEXTRA_EXMODStextend(
targs((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRzs
c
Cst2dS(
N(
R8(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR~s
cCstt
S(
N(tALLOWED_EXMODSR8(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR‚s
R2cBseZ
ed„ƒ
ZRS(
cCstj
|
d
tƒ

S(Ntconvert_instances(Rtto_primitivetTrue(tcontexttentity((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytserialize_entity‡s(t__name__t
__module__tstaticmethodRA(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR2†s
c
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(cCs
|
|_dS(
N(
t_base(tselftbase((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyt__init__Žs
cCs |js
|S|jj
|
|ƒS(
N(RERA(RFR?R@((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRA‘s
	

cCs |js
|S|jj
|
|ƒS(
N(REtdeserialize_entity(RFR?R@((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRI–s
	

c
Cs
|
jƒS(
N(
tto_dict(RFR?((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytserialize_context›s
cCstj
jj|
ƒ
S(
N(tdmapiR?tRequestContextt	from_dict(RFR?((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytdeserialize_contextžs
(RBRCRHRARIRKRO(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRŒs
				c

Cstj
jt|tƒS(
N(RtTransportURLtparsetCONFR
(
turl_str((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytget_transport_url¢s
cCs\tj
j}tjjg
g}tj|d
|ƒ

}t|ƒ
}tj||d|
d|ƒS(NR(tversion_capR)(	RLR%RRt	exceptionRBRR.Rt	RPCClient(ttargetRUR)R%R6R/((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR¦s



	


cCs+t|ƒ
}t
jt||
d
dd|ƒS(NtexecutorteventletR)(RRtget_rpc_serverR/(RXt	endpointsR)((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR³s
	



cCs8|s"d
||
ptj
f}nttjd|ƒ
ƒ
S(Ns%s.%stpublisher_id(RRR!tLegacyValidatingNotifierR4tprepare(tserviceR!R]((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR	½s


c

Cstj
d
|ƒ
S(NR](R5R_(
R]((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytget_versioned_notifierÅsc
Cs"tƒ}
t
jtd
|d|
ƒ
S(NturlR((RRR.RR(RbR6((s-/usr/lib/python2.7/site-packages/dmapi/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(RFRitpriority((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRHås
	

	
cCsd
dht|
j
ƒƒ
kS(NRVR:(tsettkeys(RFtpayload((s-/usr/lib/python2.7/site-packages/dmapi/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_typesRrtfataltAssertionErrortmessagetLOGtwarningtgetattrRi(RFRntctxtRsRq((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRmôs


	
(RBRCt__doc__tFalseRuRtRRwRHRrRm(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR^Ñs
				t
ClientWrappercBs eZ
d„Zed
„ƒ
ZRS(cCs|
|_t
jƒ|_dS(
N(t_clientRtutcnowtlast_access_time(RFtclient((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRH
s
	
c

Cstj
ƒ|_|jS(
N(RR€RR(
RF((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR‚
s
(RBRCRHtpropertyR‚(((s-/usr/lib/python2.7/site-packages/dmapi/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„RHRRtclientsR~RXRURzR7R)trun_periodic_tasksRLR?RMR}(RFtdefault_client((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyRH
s

	

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


t|jƒ
}tj||jd|j	d|j
ƒ}t|ƒ
|j
|<n
X|S(NRRUR)(tuuidR‡R‚tKeyErrorRct
transport_urlRRWRXRUR)R~(RFR?tcell_mappingt	client_idR‚t	transport((s-/usr/lib/python2.7/site-packages/dmapi/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_thanRxRdR>R}(RŽR(
ttimeout(s-/usr/lib/python2.7/site-packages/dmapi/rpc.pytstale2
s


	



R(tlistR‡titemsR(RFR?R’t
items_copyRŽtclient_wrapper((
R‘s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyt_remove_stale_clients.
s



N(RBRCR|RHR7RR
R—(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyR„

s
	
(8t__all__Rktoslo_logRtloggingtoslo_messagingRtoslo_serializationRtoslo_serviceR
t
oslo_utilsRt
dmapi.confRLtdmapi.exceptiont
dmapi.i18nRR%RRt	getLoggerRBRxR7R/R4R1R5RVR;R8R
Rtoslo_configRR$RR
RRRtNoOpSerializerR2t
SerializerRRTRRR	RaRctobjectR^R~t
PeriodicTasksR„(((s-/usr/lib/python2.7/site-packages/dmapi/rpc.pyt<module>sd









	












	
						

		.