ó
±EYc@s4dd
dddddddd	d
gZddl
Z
dd
lmZ
ddlZddlmZ
ddl	m
Z

ddlmZ
ddl
ZddlZddlZddlmZ
ddlmZ
ejjZejeƒ
Zdadadadaejjg
ZgZ idd6dd6dd6dd6dd6dd6Z!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(„Z/d)„Z0d*„Z1d+e2f
d,„ƒYZ3d-e2f
d.„ƒYZ4d/e
j5f
d0„ƒYZ6dS(1tinittcleanupt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
_(
tobjectstrabbits$nova.openstack.common.rpc.impl_kombutqpids#nova.openstack.common.rpc.impl_qpidtzmqs"nova.openstack.common.rpc.impl_zmqsnova.rpc.impl_kombusnova.rpc.impl_qpidsnova.rpc.impl_zmqc
Cs
tƒ}
t
j|d
|
dtƒ
at
j|d
|
dtƒ
attƒƒ
}|j	dkrt
j
td|ƒ

at
j
td|ddƒ
an~|j	dkrÕt
j
td|ƒ

at
j
td|dd	g
ƒ
an9t
j
td|ddƒ
at
j
td|dd	g
ƒ
adS(
Ntallowed_remote_exmodstaliasestunversionedt
serializertdrivertnooptbothttopicstversioned_notifications(
Rt	messagingt
get_transportR
t	TRANSPORTtget_notification_transporttNOTIFICATION_TRANSPORTRtJsonPayloadSerializertnotification_formattNotifiertLEGACY_NOTIFIERtNOTIFIER(tconftexmodsR((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRGs0	


	





	




	




	


cCsrtdk	st‚
tdk	s$t‚
tdk	s6t‚
tdk	sHt‚
tjƒ
tjƒ
daaaadS(
N(RtNonetAssertionErrorR!R%R&R
(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR
ds







c

Cstj
|ƒ

dS(
N(Rtset_transport_defaults(
tcontrol_exchange((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRos
c
Gstj
|ƒ

dS(
N(tEXTRA_EXMODStextend(
targs((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRss
c
Cst2dS(
N(
R-(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRws
cCstt
S(
N(tALLOWED_EXMODSR-(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR{s
R"cBseZ
ed„ƒ
ZRS(
cCstj
|
d
tƒ

S(Ntconvert_instances(Rtto_primitivetTrue(tcontexttentity((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytserialize_entity€s(t__name__t
__module__tstaticmethodR6(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR"s
c
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(cCs
|
|_dS(
N(
t_base(tselftbase((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyt__init__‡s
cCs |js
|S|jj
|
|ƒS(
N(R:R6(R;R4R5((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR6Šs
	

cCs |js
|S|jj
|
|ƒS(
N(R:tdeserialize_entity(R;R4R5((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR>s
	

c
Cs
|
jƒS(
N(
tto_dict(R;R4((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytserialize_context”s
cCstj
jj|
ƒ
S(
N(tnovaR4tRequestContextt	from_dict(R;R4((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytdeserialize_context—s
(R7R8R=R6R>R@RD(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR…s
				c

Cstj
jt|tƒS(
N(RtTransportURLtparsetCONFR
(
turl_str((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytget_transport_url›s
cCs:tdk	st‚
t|ƒ
}tjt|d
|
d|ƒS(Ntversion_capR(RR)R*RRt	RPCClient(ttargetRJR((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRŸs


	


cCs=tdk	st‚
t|ƒ
}tjt||
d
dd|ƒS(NtexecutorteventletR(RR)R*RRtget_rpc_server(RLt	endpointsR((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR¨s


	



cCsJtdk	st‚
|s4d
||
p*tjf}nttjd|ƒ
ƒ
S(Ns%s.%stpublisher_id(R%R)R*RGthosttLegacyValidatingNotifiertprepare(tserviceRRRQ((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR	²s





c

Cs"tdk	st‚
tjd
|ƒ
S(NRQ(R&R)R*RT(
RQ((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytget_versioned_notifierºs

c
Cs(tƒ}
t
jtd
|d|
dtƒ
S(NturlRR(RRRRGR
(RWR(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytcreate_transport¿s

	



RScrBs—
eZ
dZeZd
dddddddd	d
ddd
ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrgrZedsƒ
Zdt„Zdu„Z	dv„Z
RS(wsDWraps an oslo.messaging Notifier and checks for allowed event_types.saggregate.addhost.endsaggregate.addhost.startsaggregate.create.endsaggregate.create.startsaggregate.delete.endsaggregate.delete.startsaggregate.removehost.endsaggregate.removehost.startsaggregate.updatemetadata.endsaggregate.updatemetadata.startsaggregate.updateprop.endsaggregate.updateprop.starts	api.faultscompute.instance.create.endscompute.instance.create.errorscompute.instance.create_ip.ends compute.instance.create_ip.startscompute.instance.create.startscompute.instance.delete.endscompute.instance.delete_ip.ends compute.instance.delete_ip.startscompute.instance.delete.startscompute.instance.evacuatescompute.instance.existss"compute.instance.finish_resize.ends$compute.instance.finish_resize.starts+compute.instance.live.migration.abort.starts)compute.instance.live.migration.abort.ends-compute.instance.live_migration.post.dest.ends/compute.instance.live_migration.post.dest.starts)compute.instance.live_migration._post.ends+compute.instance.live_migration._post.starts'compute.instance.live_migration.pre.ends)compute.instance.live_migration.pre.starts1compute.instance.live_migration.rollback.dest.ends3compute.instance.live_migration.rollback.dest.starts-compute.instance.live_migration._rollback.ends/compute.instance.live_migration._rollback.startscompute.instance.pause.endscompute.instance.pause.startscompute.instance.power_off.ends compute.instance.power_off.startscompute.instance.power_on.endscompute.instance.power_on.startscompute.instance.reboot.endscompute.instance.reboot.startscompute.instance.rebuild.endscompute.instance.rebuild.errors"compute.instance.rebuild.scheduledscompute.instance.rebuild.startscompute.instance.rescue.endscompute.instance.rescue.starts#compute.instance.resize.confirm.ends%compute.instance.resize.confirm.startscompute.instance.resize.endscompute.instance.resize.errors compute.instance.resize.prep.ends"compute.instance.resize.prep.starts"compute.instance.resize.revert.ends$compute.instance.resize.revert.startscompute.instance.resize.startscompute.instance.restore.endscompute.instance.restore.startscompute.instance.resume.endscompute.instance.resume.startscompute.instance.shelve.ends#compute.instance.shelve_offload.ends%compute.instance.shelve_offload.startscompute.instance.shelve.startscompute.instance.shutdown.endscompute.instance.shutdown.startscompute.instance.snapshot.endscompute.instance.snapshot.starts compute.instance.soft_delete.ends"compute.instance.soft_delete.startscompute.instance.suspend.endscompute.instance.suspend.starts'compute.instance.trigger_crash_dump.ends)compute.instance.trigger_crash_dump.startscompute.instance.unpause.endscompute.instance.unpause.startscompute.instance.unrescue.endscompute.instance.unrescue.startscompute.instance.unshelve.startscompute.instance.unshelve.endscompute.instance.updatescompute.instance.volume.attachscompute.instance.volume.detachscompute.libvirt.errorscompute_task.build_instancesscompute_task.migrate_serverscompute_task.rebuild_serversHostAPI.power_action.endsHostAPI.power_action.startsHostAPI.set_enabled.endsHostAPI.set_enabled.startsHostAPI.set_maintenance.endsHostAPI.set_maintenance.startskeypair.create.startskeypair.create.endskeypair.delete.startskeypair.delete.endskeypair.import.startskeypair.import.endsnetwork.floating_ip.allocatesnetwork.floating_ip.associatesnetwork.floating_ip.deallocates network.floating_ip.disassociates!scheduler.select_destinations.ends#scheduler.select_destinations.startsservergroup.addmembersservergroup.createsservergroup.deletesvolume.usagese%(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(R;R^tpriority((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR=K
s
	

	
cCsd
dht|
j
ƒƒ
kS(Nt	exceptionR/(tsettkeys(R;tpayload((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyt_is_wrap_exception_notificationQ
scCs‚||jkrb|j
|ƒ
rb|jrEt|ji
|d
6ƒ
‚
qbtj|ji
|d
6ƒ
nt|j|
ƒ|||ƒ
dS(Nt
event_type(	t'allowed_legacy_notification_event_typesRhtfatalR*tmessagetLOGtwarningtgetattrR^(R;RctctxtRiRg((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRbZ
s


	
(R7R8t__doc__tFalseRkRjRRlR=RhRb(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRSÇsð

















































































































				t
ClientWrappercBs eZ
d„Zed
„ƒ
ZRS(cCs|
|_t
jƒ|_dS(
N(t_clientRtutcnowtlast_access_time(R;tclient((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR=f
s
	
c

Cstj
ƒ|_|jS(
N(RRuRvRt(
R;((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRwj
s
(R7R8R=tpropertyRw(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRse
s
	tClientRoutercBsGeZ
dZd
„Zdd„
Zejd„ƒ
Zd„Zd„Z	RS(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(NtdefaultRt	overwrite(tsuperRyR=RGtclientsRsRLRJRoR)Rtrun_periodic_tasksRAR4RBRr(R;tdefault_client((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyR=v
s

	

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


t|jƒ
}tj||jd|j	d|j
ƒ}t|ƒ
|j
|<n
X|S(NRzRJR(tuuidR}RwtKeyErrorRXt
transport_urlRRKRLRJRRs(R;R4tcell_mappingt	client_idRwt	transport((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRt‚
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_thanRmRYR3Rr(R„Rv(
ttimeout(s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytstale—
s


	



Rz(tlistR}titemsRv(R;R4Rˆt
items_copyR„tclient_wrapper((
R‡s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyt_remove_stale_clients“
s



cCsRytj
j|
|jƒj}Wntjjk
r>


d}n
X|j	|
d
|ƒ

S(NRƒ(
RtInstanceMappingtget_by_instance_uuidR€RƒRARdtInstanceMappingNotFoundR)Rt(R;R4tinstanceRƒ((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytby_instance¥
s

	



cCsOytj
j|
|ƒj}Wntjjk
r;


d}n
X|j|
d
|ƒ

S(NRƒ(	RtHostMappingtget_by_hostRƒRARdtHostMappingNotFoundR)Rt(R;R4RRRƒ((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pytby_host®
s

	



N(
R7R8RqR=R)RtR
RR’R–(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyRyp
s
			(7t__all__R`toslo_logRtloggingtoslo_messagingRtoslo_serializationRtoslo_serviceR
t
oslo_utilsRt	nova.confRAtnova.contexttnova.exceptiont	nova.i18nRRR'RGt	getLoggerR7RmR)RR%R!R&RdR0R-R
RR
RRRRtNoOpSerializerR"t
SerializerRRIRRR	RVRXtobjectRSRst
PeriodicTasksRy(((s=/home/tvault/.virtenv/lib/python2.7/site-packages/nova/rpc.pyt<module>sj









	

















							
		ž