ó
±EYc@sË
dd
lm
Z
ddlmZ
ddlmZ
ddlmZ
ddlmZ
ddl	m
Z

ddlmZ

ddlmZ
dd	lmZ
ddlmZ
dd
lmZ
ejeƒ
ZdZi
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6i
dd
6fZejjdejejejfd„ƒYƒ
Zejjdejejfd„ƒYƒ
ZdS(iÿÿÿÿ(
tlog(
tversionutils(
tavailability_zones(
tdb(
t	exception(
t_LW(
tbase(
tservice(
tobjects(
tfieldsis4.0tcompute_rpcs4.4s4.5s4.6s4.7s4.8s4.9s4.10s4.11s4.12s4.13tServicecBs?eZ
dZiejd
eƒ
d6ejdeƒ
d6ejdeƒ
d6ejdeƒ
d6ejƒd6ejƒd6ejdeƒ
d	6ejdeƒ
d
6ejdƒ
d6ej	deƒ
d
6ejƒd6ejƒd6ZiZ
eZd„Z
d„Zd„Zed„ƒ
Zd„Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zeejed„
ƒ
ƒ
Zejed„
ƒ
Zejd„ƒ
Zd„Zejd„ƒ
Zejd„ƒ
Z d„Z!ejd„ƒ
Z"e#d „ƒ
Z$e#d!„ƒ
Z%eejed"„
ƒ
ƒ
Z&ejed#„
ƒ
Z'ejed$„
ƒ
Z(RS(%s1.20t	read_onlytidtnullablethosttbinaryttopictreport_counttdisabledtdisabled_reasontavailability_zonetComputeNodetcompute_nodetlast_seen_uptforced_downtversionc
OsMd
|kr'tj
ddddƒ‚
ntt|ƒj|
|Ž
t|_dS(NRtactiontinittreasonsVersion field is immutable(RtObjectActionErrortsuperRt__init__tSERVICE_VERSIONR(tselftargstkwargs((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyR s

	


cCsºtt
|ƒj|
||ƒ
tj|ƒ
}|d	krMd|
krM|
d=n|d
krod|
kro|
d=n|dkr‘d|
kr‘|
d=n|dkr¶|j|j|
|ƒ
ndS(
Ni
iRiRi
Ri
(i
i(i
i(i
i
(i
i
(RRt!obj_make_compatible_from_manifestR
tconvert_version_to_tuplet_do_compute_nodet_context(R"t	primitivettarget_versiontversion_manifestt_target_version((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyR%¡s













cCs`y+|d
}tj
j|
|dƒd}Wntk
r?


dSX|jd|d|ƒ|d<dS(NRRiR*R+R(RtComputeNodeListtget_all_by_hostt	Exceptiontobj_to_primitive(R"tcontextR)R+R*tcompute((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyR'²s


	




	

cCs›d}x{|
jD]p}||kr4||kr4qn|dkrFqq|dkrrt
|
tj|ƒ
||ƒ
q|||
|<qW||
_|
jƒ
|
S(NRRR(
savailability_zone(R	tsetattrRtget_attrnameR(tobj_reset_changes(R1Rt
db_servicet
allow_missingtkey((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt_from_db_objectÀs




 
	


cCsÖ|js*t
jd
dd|jƒƒ‚
ntjdi|
d6|jƒd6|jd6ƒ
|
dkrƒt
jd	dd
d|
ƒ‚
n|jdkr°t	j
j|j|jƒ}nt
j
d
|jƒ
‚
|d|_dS(Ntmethodt
obj_load_attrtobjtypes-Lazy-loading '%(attr)s' on %(name)s id %(id)stattrtnameR
RRRsattribute %s not lazy-loadablesnova-computet
service_idi(R(RtOrphanedObjectErrortobj_nametLOGtdebugR
RRRR-R.RtServiceNotFoundR(R"tattrnamet
compute_nodes((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyR;Ós 
	

	





	


	
cCs(tj
|
|ƒ}|j|
|ƒ|ƒS(
N(Rtservice_getR9(tclsR1R?R6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt	get_by_idîs
cCs+tj
|
||ƒ}|j|
|ƒ|ƒS(
N(Rtservice_get_by_host_and_topicR9(RHR1RRR6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_host_and_topicós
cCsGytj
|
||ƒ}Wntjk
r0


dSX|j|
|ƒ|ƒS(
N(Rtservice_get_by_host_and_binaryRtHostBinaryNotFoundR9(RHR1RRR6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_host_and_binaryøs
	



cCstj
||
ƒS(
N(Rtservice_get_by_compute_host(R1Rt	use_slave((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt_db_service_get_by_compute_host

scCs.|j|
|d
|ƒ
}|j
|
|ƒ|ƒS(NRP(RQR9(RHR1RRPR6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_compute_host
s
	
cCs+tj
|
||ƒ}|j|
|ƒ|ƒS(
N(RRLR9(RHR1RRR6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_args
s
c
Cso|jd
ƒ
sdS|jdƒ
s&dS|j
|j|jƒ}
|
|jkrktjd|jd|
ƒ‚
ndS(sEnforce that we are not older that the minimum version.

        This is a loose check to avoid creating or updating our service
        record if we would do so with a version that is older that the current
        minimum of all services. This could happen if we were started with
        older code by accident, either due to a rollback or an old and
        un-updated node suddenly coming back onto the network.

        There is technically a race here between the check and the update,
        but since the minimum version should always roll forward and never
        backwards, we don't need to worry about doing it atomically. Further,
        the consequence for getting this wrong is minor, in that we'll just
        fail to send messages that other services understand.
        RNRtthisvertminver(tobj_attr_is_settget_minimum_versionR(RRRt
ServiceTooOld(R"RU((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt_check_minimum_version
s






c
Cso|jd
ƒ
r*t
jddddƒ‚
n|jƒ
|jƒ}
tj|j|
ƒ}|j|j||ƒ
dS(NR
RtcreateRsalready created(	RVRRRYtobj_get_changesRtservice_createR(R9(R"tupdatesR6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyRZ+
s






c
Csh|jƒ}
|
j
d
dƒ
|jƒ
tj|j|j|
ƒ}|j|j||ƒ
|j	|
ƒ

dS(NR
(
R[tpoptNoneRYRtservice_updateR(R
R9t _send_status_update_notification(R"R]R6((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytsave5
s




c	Cs’t|
j
ƒƒ
jd
ddhƒ
rŽtj|ƒ
}tjdtjj|ƒ
dtj	dddt
jjƒd	t
j
jd
|ƒj|jƒ

ndS(NRRRt	publishert
event_typetobjectRRtprioritytpayload(tsettkeystintersectiontservice_notificationtServiceStatusPayloadtServiceStatusNotificationtnotificationtNotificationPublishertfrom_service_objt	EventTypeR	tNotificationActiontUPDATEtNotificationPrioritytINFOtemitR((R"R]Rg((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyRa?
s


	
	
	
	



c

Cstj
|j|jƒ
dS(
N(Rtservice_destroyR(R
(
R"((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytdestroyO
sc

Cs|jƒ
t
|_dS(
N(tclear_min_version_cachetTruet_SERVICE_VERSION_CACHING(
RH((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytenable_min_version_cacheS
s

c

Cs
i|_dS(
N(
t_MIN_VERSION_CACHE(
RH((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyRyX
scCstj
||
ƒS(
N(Rtservice_get_minimum_version(R1tbinariesRP((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt_db_service_get_minimum_version\
scs
td
„|Dƒ
ƒ
sPt
jtdƒ
dj|ƒ
ƒ
tjddddƒ‚
nˆjsvt‡f
d†|Dƒ
ƒ
rÀˆj	|
|d	|ƒ
}|rÖd
„|j
ƒDƒ
}ˆjj|ƒ

qÖn‡f
d†|Dƒ
}|rñt
|jƒƒ
}nd}t|ƒ
}|S(
Nc
ss|]}
|
jdƒ
V
qd
S(snova-N(
t
startswith(t.0R((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pys	<genexpr>c
ss>get_minimum_version called with likely-incorrect binaries `%s't
,RRWRsInvalid binary prefixc
3s|]}
|
ˆjkV
qdS(
N(
R}(R‚R(
RH(sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pys	<genexpr>j
s
RPc
Ss%i|]\}
}|pd|
“qS(
i((R‚RR((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pys
<dictcomp>o
s	
c
s i|]}
ˆj|
|
“qS((
R}(R‚R(
RH(sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pys
<dictcomp>t
s	
i(tallRBtwarningRtjoinRRR{tanyR€titemsR}tupdatetmintvaluestint(RHR1RRPtmin_versionsR((
RHsI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_minimum_version_multia
s*















cCs|j|
|g
d
|ƒ
S(NRP(
RŽ(RHR1RRP((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyRW
s
()t__name__t
__module__tVERSIONR	tIntegerFieldRztStringFieldtBooleanFieldtObjectFieldt
DateTimeFieldR}tFalseR{R R%R'tstaticmethodR9R;Rtremotable_classmethodRIRKRNRtselect_db_reader_modeRQRRRSRYt	remotableRZRbRaRxtclassmethodR|RyR€RŽRW(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyRcsX















					


	

	



tServiceListcBs‡eZ
dZi
ejd
ƒ
d6Zejd„ƒ
Zejed„
ƒ
Z	ejd„ƒ
Z
ejded„ƒ
Zejd„ƒ
Z
RS(	s1.19RRcCs1tj
|
|ƒ}tj|
||
ƒ
tj|ƒS(
N(Rtservice_get_all_by_topicRt
obj_make_listRR(RHR1Rtdb_services((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_topic¤
s

cCs7tj
|
|d
|ƒ
}tj|
||
ƒ
tj|ƒS(Ntinclude_disabled(Rtservice_get_all_by_binaryRRŸRR(RHR1RR¢R ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt
get_by_binary¬
s


cCs1tj
|
|ƒ}tj|
||
ƒ
tj|ƒS(
N(Rtservice_get_all_by_hostRRŸRR(RHR1RR ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_by_host³
s

cCsOtj
|
d
|ƒ

}|r0tj|
|ƒ}ntj|
||
ƒ
tj|ƒS(NR(Rtservice_get_allRtset_availability_zonesRRŸRR(RHR1Rt	set_zonesR ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_all¹
s




cCs7tj
|
|d
tƒ
}tj|
||
ƒ
tj|ƒS(NR¢(Rt#service_get_all_computes_by_hv_typeR—RRŸRR(RHR1thv_typeR ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pytget_all_computes_by_hv_typeÂ
s


N(RRR‘R	tListOfObjectsFieldRR™R¡R—R¤R¦R_RªR­(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyR‡
s


N( toslo_logRtloggingt
oslo_utilsR
tnovaRRRt	nova.i18nRtnova.notifications.objectsRRnRRkRtnova.objectsR	t	getLoggerRRBR!tSERVICE_VERSION_HISTORYtNovaObjectRegistrytregistertNovaPersistentObjectt
NovaObjecttNovaObjectDictCompatRtObjectListBaseR(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/service.pyt<module>sD

























ÿ#