ó
Éec@s
dd
lm
Z
ddlmZ
ddlmZ
ddlmZ
ddl	m
Z

ddl	mZ
ddlmZ
ddlm
Z

ejeƒ
Zd	Zi
d
d6f
Zdfd
„ƒYZe
jjde
je
je
jfd„ƒYƒ
Ze
jjde
je
jfd„ƒYƒ
ZdS(iÿÿÿÿ(
tlog(
tversionutils(
t	exception(
t_LW(
tbase(
tfields(
tdb(
tobjectsis4.13tcompute_rpctServicec
Bs)eZ
dZiZeZd
Zd„ZRS(s1.20ic
Os4d
|kr'tj
ddddƒ‚
nt|_dS(NtversiontactiontinittreasonsVersion field is immutable(RtObjectActionErrortSERVICE_VERSIONR
(tselftargstkwargs((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt__init__&s


	

(t__name__t
__module__tVERSIONt_MIN_VERSION_CACHEtFalset_SERVICE_VERSION_CACHINGRR(((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyR	s


cBsgeZ
dZi
ejd
eƒ
d6ejƒd6ejdeƒ
d6ejdeƒ
d6ejdeƒ
d6ejƒd6ejƒd	6ejdeƒ
d
6ejdeƒ
d6ej	dƒ
d
6ej
deƒ
d6ejƒd6ejƒd6ZiZeZ
d„Zd„Zd„Zed„ƒ
Zd„Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zeejed„
ƒ
ƒ
Zejed„
ƒ
Zejd„ƒ
Zd„Zej d„ƒ
Z!ej d„ƒ
Z"d „Z#d!„Z$ej d"„ƒ
Z%e&d#„ƒ
Z'e&d$„ƒ
Z(eejed%„
ƒ
ƒ
Z)ejed&„
ƒ
Z*ejed'„
ƒ
Z+RS((s2.0t	read_onlytidtuuidtnullablethosttbinaryttopictreport_counttdisabledtdisabled_reasontavailability_zonetComputeNodetcompute_nodetlast_seen_uptforced_downR
c
OsMd
|kr'tj
ddddƒ‚
ntt|ƒj|
|Ž
t|_dS(NR
RRR
sVersion field is immutable(RRtsuperR	RRR
(RRR((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRQs

	


cCsÜtt
|ƒj|
||ƒ
tj|ƒ
}|dkrMd|
krM|
d=n|dkrod|
kro|
d=n|d
kr‘d|
kr‘|
d=n|dkr³d	|
kr³|
d	=n|dkrØ|j|j|
|ƒ
ndS(Ni
iRiR
iR(i
R'i
(i
i(i
i(i
i(i
i
(i
i
(R)R	t!obj_make_compatible_from_manifestR
tconvert_version_to_tuplet_do_compute_nodet_context(Rt	primitivettarget_versiontversion_manifestt_target_version((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyR*Zs

















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


dSX|jd|d|ƒ|d<dS(NR%RiR/R0R&(RtComputeNodeListtget_all_by_hostt	Exceptiontobj_to_primitive(RtcontextR.R0R/tcompute((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyR,ks



	




	

cCs½d}x|
jD]’}||kr4||kr4qn|dkrFqq|dkrrt
|
tj|ƒ
||ƒ
q|dkr”|j|ƒ
r”qq|||
|<qW||
_|
jƒ
|
S(NR$R&R
R(
R$(RtsetattrRtget_attrnametgetR-tobj_reset_changes(R6tservicet
db_servicet
allow_missingtkey((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt_from_db_objectvs






 

	

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)stattrtnameRR&RR
sattribute %s not lazy-loadablestvault-contegot
service_idi(R-RtOrphanedObjectErrortobj_nametLOGtdebugRRRRR2R3RtServiceNotFoundR&(Rtattrnamet
compute_nodes((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRBŠs 
	

	





	



	

cCs(tj
|
|ƒ}|j|
|ƒ|ƒS(
N(Rtservice_getR@(tclsR6RFR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt	get_by_idŸs
cCs(tj
|
|ƒ}|j|
|ƒ|ƒS(
N(Rtservice_get_by_uuidR@(ROR6tservice_uuidR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_uuid¤s
cCs+tj
|
||ƒ}|j|
|ƒ|ƒS(
N(Rtservice_get_by_host_and_topicR@(ROR6RR R=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_host_and_topic©s
cCsGytj
|
||ƒ}Wntjk
r0


dSX|j|
|ƒ|ƒS(
N(Rtservice_get_by_host_and_binaryRtHostBinaryNotFoundR@(ROR6RRR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_host_and_binary®s
	



cCstj
||
ƒS(
N(Rtservice_get_by_compute_host(R6Rt	use_slave((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt_db_service_get_by_compute_host·scCs.|j|
|d
|ƒ
}|j
|
|ƒ|ƒS(NRZ(R[R@(ROR6RRZR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_compute_host¼s
	
cCs+tj
|
||ƒ}|j|
|ƒ|ƒS(
N(RRVR@(ROR6RRR=((s9/usr/lib/python2.7/dist-packages/dmapi/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.
        R
NRtthisvertminver(tobj_attr_is_settget_minimum_versionR-RR
Rt
ServiceTooOld(RR_((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt_check_minimum_versionÇs







c
Cs®|jd
ƒ
r*t
jddddƒ‚
n|jƒ
|jƒ}
d|
krltjƒ|
d<|
d|_ntj	|j
|
ƒ}|j|j
||ƒ
|jt
jjƒ

dS(NRRtcreateR
salready createdR(R`RRRctobj_get_changest	uuidutilst
generate_uuidRRtservice_createR-R@t_send_notificationRtNotificationActiontCREATE(RtupdatesR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRdÝs








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

dS(NR(
RetpoptNoneRcRtservice_updateR-RR@t _send_status_update_notification(RRlR=((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytsaveís




cCs>t|
j
ƒƒ
jd
ddhƒ
r:|jtjjƒ

ndS(NR"R#R((tsettkeystintersectionRiRRjtUPDATE(RRl((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRp÷s


c	Csetj
|ƒ
}tjd
tjj|ƒ
dtjddd|
ƒdtjj	d|ƒj
|jƒ

dS(Nt	publishert
event_typetobjectR<Rtprioritytpayload(tservice_notificationtServiceStatusPayloadtServiceStatusNotificationtnotificationtNotificationPublishertfrom_service_objt	EventTypeRtNotificationPrioritytINFOtemitR-(RRRz((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRiüs

	
	
	
	

	

c

Cs-tj
|j|jƒ
|jtjjƒ

dS(
N(Rtservice_destroyR-RRiRRjtDELETE(
R((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytdestroy
s
c

Cs|jƒ
t
|_dS(
N(tclear_min_version_cachetTrueR(
RO((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytenable_min_version_cache
s

c

Cs
i|_dS(
N(
R(
RO((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRˆ
scCstj
||
ƒS(
N(Rtservice_get_minimum_version(R6tbinariesRZ((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt_db_service_get_minimum_version
scs

td
„|Dƒ
ƒ
sJt
jddj|ƒ
ƒ
tjddddƒ‚
nˆjspt‡f
d†|Dƒ
ƒ
rºˆj|
|d	|ƒ
}|rÐd
„|j	ƒDƒ
}ˆj
j|ƒ

qÐn‡f
d†|Dƒ
}|rët|j
ƒƒ
}nd}t|ƒ
}|S(
Nc
ss|]}
|
jdƒ
V
qd
S(snova-N(
t
startswith(t.0R((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pys	<genexpr>
ss>get_minimum_version called with likely-incorrect binaries `%s't
,RRaR
sInvalid binary prefixc
3s|]}
|
ˆjkV
qdS(
N(
R(RR(
RO(s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pys	<genexpr>#
s
RZc
Ss%i|]\}
}|pd|
“qS(
i((RRR
((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pys
<dictcomp>(
s	
c
s i|]}
ˆj|
|
“qS((
R(RR(
RO(s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pys
<dictcomp>-
s	
i(tallRItwarningtjoinRRRtanyRtitemsRtupdatetmintvaluestint(ROR6RŒRZtmin_versionsR
((
ROs9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_minimum_version_multi
s*
	















cCs|j|
|g
d
|ƒ
S(NRZ(
R›(ROR6RRZ((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyRa8
s
(,RRRRtIntegerFieldR‰t	UUIDFieldtStringFieldtBooleanFieldtObjectFieldt
DateTimeFieldRRRRR*R,tstaticmethodR@RBRtremotable_classmethodRPRSRURXRtselect_db_reader_modeR[R\R]Rct	remotableRdRqRpRiR‡tclassmethodRŠRˆRR›Ra(((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyR	9s^

















						


	
		



tServiceListcBs‡eZ
dZi
ejd
ƒ
d6Zejd„ƒ
Zejed„
ƒ
Z	ejd„ƒ
Z
ejded„ƒ
Zejd„ƒ
Z
RS(	s1.0R	RcCs1tj
|
|ƒ}tj|
||
ƒ
tj|ƒS(
N(Rtservice_get_all_by_topicRt
obj_make_listRR	(ROR6R tdb_services((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_topicG
s

cCs7tj
|
|d
|ƒ
}tj|
||
ƒ
tj|ƒS(Ntinclude_disabled(Rtservice_get_all_by_binaryRR©RR	(ROR6RR¬Rª((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt
get_by_binaryM
s


cCs1tj
|
|ƒ}tj|
||
ƒ
tj|ƒS(
N(Rtservice_get_all_by_hostRR©RR	(ROR6RRª((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_by_hostT
s

cCsOtj
|
d
|ƒ

}|r0tj|
|ƒ}ntj|
||
ƒ
tj|ƒS(NR"(Rtservice_get_alltavailability_zonestset_availability_zonesRR©RR	(ROR6R"t	set_zonesRª((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_allZ
s




cCs7tj
|
|d
tƒ
}tj|
||
ƒ
tj|ƒS(NR¬(Rt#service_get_all_computes_by_hv_typeRRR©RR	(ROR6thv_typeRª((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pytget_all_computes_by_hv_typec
s


N(RRRRtListOfObjectsFieldRR£R«RR®R°RnRµR¸(((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyR§?
s


N(toslo_logRtloggingt
oslo_utilsR
tdmapiRt
dmapi.i18nRt
dmapi.objectsRRRRt	getLoggerRRIRtSERVICE_VERSION_HISTORYR	tContegoObjectRegistrytregistertContegoPersistentObjectt
ContegoObjecttContegoObjectDictCompattObjectListBaseR§(((s9/usr/lib/python2.7/dist-packages/dmapi/objects/service.pyt<module>s"







ÿ