ó
±EYc@s¢
dd
lm
Z

ddlmZ
ddlZddlmZ
ddlmZ
ddl	m
Z

ddl	mZ
ddlm
Z

dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
d
g
Ze
jjde
jf
d„ƒYƒ
ZdZejjd„ƒ
Zejje d„
ƒ
Z!d„Z"d„Z#e
jjde
jf
d„ƒYƒ
Z$e
jjde
jf
d„ƒYƒ
Z%e
jjde
jf
d„ƒYƒ
Z&dS(iÿÿÿÿ(
t	jsonutils(
tversionutilsN(
tapi(
t
api_models(
t	exception(
tobjects(
tbase(
tfields(
tinstance(
tutils(
thardwaretrequested_destinationtRequestSpeccBseZ
dZiejƒd
6ejddeƒ

d6ejddeƒ

d6ejddeƒ

d6ejdeƒ
d	6ejdeƒ
d
6ejddeƒ

d6ejd
dƒ
d6ej	deƒ
d6ej	deƒ
d6ej	deƒ
d6ejdded
d>ƒ
d6ejddeƒ

d6ejddeƒ

d6ejddeƒ

d6ejdeƒ
d6ejƒd6Zd„Z
d„Zed„ƒ
Zed „ƒ
Zed!„ƒ
Zed"„ƒ
Zed#„ƒ
Zd$„Zd%„Zd&„Zd'„Zd(„Zd)„Zd*„Zd+„Zd,„Zed-„ƒ
Zd>d.„
Z d/„Z!d0„Z"d1„Z#d2„Z$d3„Z%ed4„ƒ
Z&e'd5„ƒ
Z(e'e)j*j+d6„ƒ
ƒ
Z,e-j.d7„ƒ
Z/e'e)j*j0d8„ƒ
ƒ
Z1d9„Z2e-j3d:„ƒ
Z4e'e)j*j0d;„ƒ
ƒ
Z5e-j3d<„ƒ
Z6d=„Z7RS(?s1.6tidt	ImageMetatnullabletimagetInstanceNUMATopologyt
numa_topologytInstancePCIRequeststpci_requestst
project_idtavailability_zonetFlavortflavortdefaulti
t
num_instancestignore_hoststforce_hoststforce_nodestDestinationRtSchedulerRetriestretrytSchedulerLimitstlimitst
InstanceGrouptinstance_grouptscheduler_hintst
instance_uuidcCsQtt
|ƒj|
|ƒ
tj|ƒ
}|dkrMd|
krM|
d=qMndS(Ni
iR(i
i(tsuperRtobj_make_compatibleR
tconvert_version_to_tuple(tselft	primitivettarget_version((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR(Fs





cCs<|
tkr+t
jd
ddd|
ƒ‚
n|j|
ƒ

dS(Ntactiont
obj_load_attrtreasonsattribute %s not lazy-loadable(tREQUEST_SPEC_OPTIONAL_ATTRSRtObjectActionErrortobj_set_defaults(R*tattrname((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR.Ms


	

c


Cs
|jj
S(
N(Rtvcpus(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR4Xsc


Cs
|jj
S(
N(Rt	memory_mb(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR5\sc


Cs
|jj
S(
N(Rtroot_gb(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR6`sc


Cs
|jj
S(
N(Rtephemeral_gb(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR7dsc


Cs
|jj
S(
N(Rtswap(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR8hscCsRt|
t
jƒr|
|_n0t|
tƒrEt
jj|
ƒ
|_n	d|_dS(
N(t
isinstanceRRRtdictt	from_dicttNone(R*R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_image_meta_from_imagels



cCsït|
t
jƒrt}nt|
tƒr6d
„}ndSdddddg}x™|D]‘}|dkr„t|d||
|ƒƒ
qV|dkr©|j||
|ƒƒ

qV|dkrÎ|j||
|ƒƒ

qVt||||
|ƒƒ
qVWdS(NcSs
|j|
ƒ
S(
N(
tget(t
xt
y((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt<lambda>ƒsRRtuuidRRR&(R9tobj_instancetInstancetgetattrR:tsetattrt_from_instance_pci_requestst_from_instance_numa_topology(R*Rtgettertinstance_fieldstfield((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_instancexs
	
	








cCs:t|
t
ƒr-tj}|j|
ƒ
|_n	|
|_dS(
N(R9R:RRt from_request_spec_instance_propsR(R*Rtpci_req_cls((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyRG”s


	

cCs:t|
t
ƒr-tjt
d
|
ƒ
ƒ
|_n	|
|_dS(NR(R9R:R
tinstance_topology_from_instanceR(R*R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyRHœs


cCsFt|
t
jƒr|
|_n$t|
tƒrBt
j|
|_ndS(
N(R9RRRR:(R*R((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_flavor£s


cCs(|
rtj
|j|
ƒnd|_dS(
N(RR;t_contextR<R (R*t
retry_dict((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_retry®scCs¼|
jd
ƒ
r$|
jd
ƒ
|_
n”|
jdƒ
tkr¯t|
jdƒ
ƒ
}t|
jdƒ
ƒ
}t|
jdƒ
ƒ
}tjd|d|d|ƒ|_
|j
jdg
ƒ

n	d|_
dS(	NR$t
group_updatedtgroup_policiestgroup_hostst
group_memberstpoliciesthoststmembers(R>R$tTruetlistRR#tobj_reset_changesR<(R*tfilter_propertiesRXRYRZ((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_populate_group_info²s






cCstj
|
ƒ
|_dS(
N(R!R;R"(R*tlimits_dict((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_limitsÆs
cCs9|
dkrd|_
dSd
„tj|
ƒ
Dƒ
|_
dS(Nc
Ss7i|]-\}
}t|t
ƒr'|n|g
|
“qS((R9R\(t.0thinttvalue((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pys
<dictcomp>Îs	
(R<R%tsixt	iteritems(R*t
hints_dict((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_hintsÉs


	

cCs&
|jd
dƒ}||
d
|ƒ

}|jdƒ
}|j
|ƒ

|jdƒ
}|j|ƒ

|jdƒ
}|j|ƒ

|jdƒ
|_|jdƒ
|_|jdƒ
|_|jd	iƒ}	|j|	ƒ

|jd
iƒ}
|j|
ƒ

|j	|ƒ

|jdiƒ}|j
|ƒ

|jƒ
|S(sØReturns a new RequestSpec object by hydrating it from legacy dicts.

        Deprecated.  A RequestSpec object is created early in the boot process
        using the from_components method.  That object will either be passed to
        places that require it, or it can be looked up with
        get_by_instance_uuid.  This method can be removed when there are no
        longer any callers.  Because the method is not remotable it is not tied
        to object versioning.

        That helper is not intended to leave the legacy dicts kept in the nova
        codebase, but is rather just for giving a temporary solution for
        populating the Spec object until we get rid of scheduler_utils'
        build_request_spec() and the filter_properties hydratation in the
        conductor.

        :param context: a context object
        :param request_spec: An old-style request_spec dictionary
        :param filter_properties: An old-style filter_properties dictionary
        Ri
Rtinstance_propertiest
instance_typeRRRR R"R%(R>R=RLRPRRRRSRaR_RhR2(tclstcontexttrequest_specR^RtspecRRRR R"R%((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytfrom_primitivesÑs(






















cCse|jd
ƒ
s|j
dkr#|S|j
j|
|ƒ}t|tƒrat|ƒ
dkra|dS|S(sConvenient helper for accessing a particular scheduler hint since
        it is hydrated by putting a single item into a list.

        In order to reduce the complexity, that helper returns a string if the
        requested hint is a list of only one value, and if not, returns the
        value directly (ie. the list). If the hint is not existing (or
        scheduler_hints is None), then it returns the default value.

        :param hint_name: name of the hint
        :param default: the default value if the hint is not there
        R%i
iN(tobj_attr_is_setR%R<R>R9R\tlen(R*t	hint_nameRthint_val((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytget_scheduler_hint

s




c

Cs,|jd
ƒ
r(|j
r(tj|j
ƒ
SiS(NR(RpRRtobj_to_primitive(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_to_legacy_image
sc
CsÆi}
d
ddddg}xX|D]P}|j|ƒ
s=q"n|dkr_t
||ƒ|
d<q"t
||ƒ|
|<q"Wddd	d
g}|jdƒ
s›|
Sx$|D]}t
|j|ƒ|
|<q¢W|
S(NRRRRR&RBR6R7R5R4R(RpRER(R*RRJRKt
flavor_fields((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_to_legacy_instance
s














c

Cs1itd
6t
|jjƒ
d6t
|jjƒ
d6S(NRTRVRU(R[tsetR$RYRX(
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_to_legacy_group_info,
s


c
Cs†i}
|jd
ƒ
s,|j
d
j|
d
<n
|j|
d
<|jƒ|
d<|jƒ|
d<|jdƒ
rx|j|
d<n
i|
d<|
S(s³
Returns a legacy request_spec dict from the RequestSpec object.

        Since we need to manage backwards compatibility and rolling upgrades
        within our RPC API, we need to accept to provide an helper for
        primitiving the right RequestSpec object into a legacy dict until we
        drop support for old Scheduler RPC API versions.
        If you don't understand why this method is needed, please don't use it.
        RRRiRRj(RpRRRRvRxR(R*treq_spec((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytto_legacy_request_spec_dict4
s	








c

sD
i}
ˆjd
ƒ
r.ˆj
r.ˆj
|
d
<nˆjdƒ
rVˆjrVˆj|
d<nˆjdƒ
r~ˆjr~ˆj|
d<nˆjdƒ
r¬ˆjr¬ˆjjƒ|
d<nˆjdƒ
rڈjrڈjjƒ|
d<nˆjdƒ
r
ˆjr
|
jˆj	ƒƒ

nˆjdƒ
r@
ˆj
r@
‡f
d†ˆj
Dƒ
|
d<n|
S(	s¸
Returns a legacy filter_properties dict from the RequestSpec object.

        Since we need to manage backwards compatibility and rolling upgrades
        within our RPC API, we need to accept to provide an helper for
        primitiving the right RequestSpec object into a legacy dict until we
        drop support for old Scheduler RPC API versions.
        If you don't understand why this method is needed, please don't use it.
        RRRR R"R$R%c
s"i|]}
ˆj|
ƒ
|
“qS((
Rt(RbRc(
R*(sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pys
<dictcomp>c
s	
(RpRRRR tto_dictR"R$tupdateRzR%(R*t
filt_props((
R*sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt to_legacy_filter_properties_dictJ
s"	














c
Cs$
||
ƒ
}
d
|
_||
_
||
_|
jdkrL|rL|
j|ƒ

n|
j|
_|
j|ƒ

|
j|ƒ

|
j|ƒ

|
j	|ƒ

|j
dƒ
|
_|j
dƒ
|
_|j
dƒ
|
_
|
j|j
diƒƒ

|
j|j
diƒƒ

|
j|j
diƒƒ

|	|
_|
jƒ
|
S(	sYReturns a new RequestSpec object hydrated by various components.

        This helper is useful in creating the RequestSpec from the various
        objects that are assembled early in the boot process.  This method
        creates a complete RequestSpec object with all properties set or
        intentionally left blank.

        :param context: a context object
        :param instance_uuid: the uuid of the instance to schedule
        :param image: a dict of properties for an image or volume
        :param flavor: a flavor NovaObject
        :param numa_topology: InstanceNUMATopology or None
        :param pci_requests: InstancePCIRequests
        :param filter_properties: a dict of properties for scheduling
        :param instance_group: None or an instance group NovaObject
        :param availability_zone: an availability_zone string
        i
RRRR R"R%N(RR&R$R<R_RR=RPRGRHR>RRRRSRaRhRR2(RkRlR&RRRRR^R$Rtspec_obj((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytfrom_componentsg
s(
	
	
	

















	

cCsƒ|
jt
j|d
ƒ
ƒ
}xM|
jD]B}|dkrOt|
|||ƒ
q&t|
|t||ƒƒ
q&W||
_|
jƒ
|
S(NRnR
R&(sids
instance_uuid(tobj_from_primitiveRtloadsRRFRERQR](RlRntdb_specRtkey((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_from_db_object”
s


	


cCsF|jj
tjƒ
jd
|
ƒ
jƒ}|sBtjd
|
ƒ
‚
n|S(NR&(tsessiontqueryRRt	filter_bytfirstRtRequestSpecNotFound(RlR&R…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_get_by_instance_uuid_from_db¢
s


	

cCs(|j|
|ƒ}|j
|
|ƒ|ƒS(
N(RR‡(RkRlR&R…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytget_by_instance_uuid¬
s
cCs-tj
ƒ}|j|
ƒ

|j|jƒ

|S(
N(RRR~tsaveRˆ(RltupdatesR…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt
_create_in_db±
s



c
CsR|jƒ}
|
rNi
t
j|jƒƒ
d
6}d|
krN|
d|d<qNn|S(sy
Serialize object to match the db model.

        We store copies of embedded objects rather than
        references to these objects because we want a snapshot of the request
        at this point.  If the references changed or were deleted we would
        not be able to reschedule this instance under the same conditions as
        it was originally scheduled with.
        RnR&(tobj_get_changesRtdumpsRu(R*Rt
db_updates((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_get_update_primitives¹
s	



c
Cse|jd
ƒ
r*t
jddddƒ‚
n|jƒ}
|j|j|
ƒ}|j|j||ƒ
dS(NR
R-tcreateR/salready created(RpRR1R•R‘RQR‡(R*RR…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR–Ë
s


cCs3tj
||
ƒ}|j|ƒ

|j|jƒ

|S(
N(RRR~RRˆ(RlR&RR…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_save_in_dbÖ
s
	
	



c
CsK|jƒ}
|j
|j|j|
ƒ}|j|j||ƒ
|jƒ
dS(
N(R•R—RQR&R‡R](R*RR…((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyRá
s


c

Cs)d|_
d|_|jd
dgƒ

dS(säClears the forced destination fields from the RequestSpec object.

        This method is for making sure we don't ask the scheduler to give us
        again the same destination(s) without persisting the modifications.
        RRN(R<RRR](
R*((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pytreset_forced_destinationsè
s	
	N(8t__name__t
__module__tVERSIONRtIntegerFieldtObjectFieldR[tStringFieldtFalsetListOfStringsFieldR<tDictOfListOfStringsFieldt	UUIDFieldR(R.tpropertyR4R5R6R7R8R=RLRGRHRPRSR_RaRhtclassmethodRoRtRvRxRzR|R€R‚tstaticmethodR‡tdbtapi_context_managertreaderRRtremotable_classmethodRŽtwriterR‘R•t	remotableR–R—RR˜(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR sv	























											0					-
	
	

s$00000000-0000-0000-0000-000000000000c
CsA|jj
tjƒ
jd
tƒ
jƒ}
|
r7|
dnd}|S(NR&Rn(RˆR‰RRRŠt	FAKE_UUIDR‹R<(RlR{tmarker((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt!_get_marker_for_migrate_instances
s


cCso|jj
tjƒ
jd
tƒ
jƒ
|
dk	rktjƒ}|jitd
6|
d6ƒ

|j	|jƒ

ndS(NR&Rn(
RˆR‰RRRŠR¬tdeleteR<R~R(RlR­t
db_mapping((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt+_set_or_delete_marker_for_migrate_instances	s




c
Cs€|
j}i
i
|
j
d
6d6}i}tj|||ƒ
tjj||
j
||
j|
j|
j	|d|
jƒ	}|jƒ
dS(NRBRi(
t
image_metaRBtscheduler_utilstsetup_instance_groupRRR‚RRRR<RR–(RlRRRmR^((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt_create_minimal_request_specs
	


	



cCsùt|ƒ
}d
ddddg}t
jj|di
td6dd	d
dd|
d
|d|ƒ
}t|ƒ
}d}xS|D]K}ytj||jƒ
Wqwt	j
k
rÁ


t||ƒ
|d7}qwXqwW|dkrâ|dj}nt||ƒ
||fS(sBCreates and persists a RequestSpec per instance not yet having it.tsystem_metadataRRRRtfilterstdeletedtsort_keyt
created_attsort_dirtasctlimitR­texpected_attrsii
iÿÿÿÿ(
R®RtInstanceListtget_by_filtersRŸRqRRŽRBRRŒRµR±(Rlt	max_countR­tattrst	instancest	count_allt	count_hitR((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt"migrate_instances_add_request_spec+s,
	







	












RcBs4eZ
dZiejƒd
6ejdeƒ
d6ZRS(s1.0thostRtnode(R™RšR›RRžR[(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyRIs

RcBsIeZ
dZiejƒd
6ejdƒ
d6Zed„ƒ
Zd„ZRS(s1.1tnum_attemptstComputeNodeListRYc
CsŠ|ƒ}d
od|kr|S|jd
ƒ
|_
g|jdƒ
D]*\}}tjd|
d|d|ƒ^qA}tjd|ƒ
|_|S(NRÉRYRlRÇthypervisor_hostnameR(R>RÉRtComputeNodeRÊRY(RkRlRRt	retry_objRÇRÈtcomputes((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR;ds	

=

c
Cs=g|jD]}
|
j
|
jg^q
}i|jd
6|d6S(NRÉRY(RYRÇRËRÉ(R*tcntlegacy_hosts((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR}us
(


(	R™RšR›RRœRR¤R;R}(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyRWs

R!cBs“eZ
dZiejd
dedd
ƒ
d6ejdedd
ƒd6ejdedd
ƒd6ejdedd
ƒd6Zed„ƒ
Z	d	„Z
RS(s1.0tNUMATopologyLimitsRRRtvcputdisk_gbR5cCs||
}|jƒ
|S(
N(
R2(RkR`R"((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR;‰s

c
CsIi}
x<|jD]1}t
||ƒdk	rt
||ƒ|
|<qqW|
S(
N(RRER<(R*R"RK((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR}“s





N(R™RšR›RRR[R<RœR¤R;R}(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyR!{s







('toslo_serializationRt
oslo_utilsR
Retnova.db.sqlalchemyRR¦RtnovaRRtnova.objectsRRRRCtnova.schedulerR	R³t	nova.virtR
R0tNovaObjectRegistrytregistert
NovaObjectRR¬R§R¨R®RªR<R±RµRÆRRR!(((sN/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/request_spec.pyt<module>s6









	
ÿÞ	
		


#