ó
±EYc@s²
dd
lZddl
mZ
ddlmZ
ddlmZ
ddlmZ
ddlm	Z	
ddl
mZ
ddl
mZ
dd	lmZ
dd
lmZ
ddlmZ
ddl
mZ
ddl
mZ
dd
lmZ
ddlmZ
dg
Zeed„Zd„Zed„
Zd„Zd„Zd„Z ej!j"dej#ej$ej%fd„ƒYƒ
Z&ej!j"dej'ej$fd„ƒYƒ
Z(ej)j*d„ƒ
Z+d„Z,d
S(iÿÿÿÿN(
t	exception(
t	uuidutils(
tversionutils(
tcontains_eager(
t
joinedload(
tutils(
tdb(
tapi(
t
api_models(
tmodels(
tobjects(
tbase(
tfieldsthostscCs||jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
}|jsT|jd|jƒ
}n|rx|
rx|j	|
|kƒ
}n|S(Nt	_policiest_memberst
project_id(
tsessiontqueryRt
InstanceGrouptoptionsRtis_admint	filter_byRtfilter(tcontexttid_fieldtidR((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_instance_group_get_query%s



	



cCs|jj
|
ƒ
jd
|ƒ
S(Ntgroup_id(RRR(Rtmodel_classR((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_instance_group_model_get_query0s
c
CsÊg}tƒ}x1|D])}	|j
t|	|ƒƒ

|j|	ƒ

qWx€|D]x}
|
|krbqJn|
ƒ}i
|d
6}|
||<|j|ƒ

|jj
|ƒ

|rµ|j|ƒ

n|j|ƒ

qJW|S(NR(tsettaddtgetattrtappendtupdateR(
RRtitemstitem_modelstfieldRtappend_to_modelsR	talready_existingtdb_itemtitemtmodeltvalues((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_instance_group_model_add4s"
	








	










c	Csjt|t
j|
jƒ}|jt
jjjt|ƒ
ƒ
ƒ
}t|t
j||j	ƒd
|
jd|
j
ƒ
S(NtpolicyR'(RRtInstanceGroupPolicyRRR.tin_RR-tallR(RtgrouptpoliciesR((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_instance_group_policies_addIs







c	Csjt|t
j|
jƒ}|jt
jjjt|ƒ
ƒ
ƒ
}t|t
j||j	ƒd
|
jd|
j
ƒ
S(Nt
instance_uuidR'(RRtInstanceGroupMemberRRR5R0RR-R1R(RR2tmembersR((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_instance_group_members_addTs







cCs |jj
tjƒ
jtjtjjjt|ƒ
ƒ
ƒj	tjj
|
kƒ
jtd
ƒ
ƒ
j
ƒ}|s~tjd|
ƒ
‚
nt|tj||jd|jƒS(NRt
group_uuidR5(RRRRt	outerjoinR6R5R0RRtuuidRRtfirstRtInstanceGroupNotFoundR-RR(RR9R7R2((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt#_instance_group_members_add_by_uuid_s








RcBsqeZ
dZiejƒd
6ejdeƒ
d6ejdeƒ
d6ejƒd6ejdeƒ
d6ejdeƒ
d6ejdeƒ
d6ejdeƒ
d	6Zd
„Z	e
d„ƒ
Ze
ej
jd„ƒ
ƒ
Ze
ej
jd
„ƒ
ƒ
Ze
ej
jd„ƒ
ƒ
Ze
ej
jd„ƒ
ƒ
Ze
ej
jd„ƒ
ƒ
Ze
ej
jd!d!d„ƒ
ƒ
Ze
ej
jd„ƒ
ƒ
Ze
ej
jd„ƒ
ƒ
Zd„Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zed„ƒ
Z ej!d„ƒ
Z"ej!d„ƒ
Z#e$d„
Z%ej!d„ƒ
Z&ej!d„ƒ
Z'ejd„ƒ
Z(ej!d!d„
ƒ
Z)ej!d „ƒ
Z*RS("s1.10Rtnullabletuser_idRR;tnameR3R7R
cCs,tj
|ƒ
}|dkr(i|
d<ndS(Ni
itmetadetails(i
i(Rtconvert_version_to_tuple(tselft	primitivettarget_version((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytobj_make_compatibles

cCsŒxr|
jD]g}|t
kr"q
nitd
6dd6}||krct||ƒrc|||
|<q
|||
|<q
W||
_|
jƒ
|
S(sjMethod to help with migration to objects.

        Converts a database entity to a formal object.
        tdeletedt
deleted_atN(RtLAZY_LOAD_FIELDStFalsetNonethasattrt_contexttobj_reset_changes(Rtinstance_grouptdb_instR&tignore((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_from_db_object”s






	


cCsCt|d
t
jjd|
ƒ
jƒ}|s?tjd|
ƒ
‚
n|S(NRRR9(RRRR;R<RR=(RR;tgrp((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_from_db_by_uuid®s	




cCsCt|d
t
jjd|
ƒ
jƒ}|s?tjd|
ƒ
‚
n|S(NRRR9(RRRRR<RR=(RRRT((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_from_db_by_id¸s	




cCs=t|ƒ
j
d
|
ƒ
jƒ}|s9tjd|
ƒ
‚
n|S(NRAR9(RRR<RR=(RRART((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_from_db_by_nameÂs


cCs[|jj
tjƒ
jd
|
ƒ
jƒ}|sBtjddƒ
‚
ntj	||j
ƒ}|S(NR5R9t(RRRR6RR<RR=RRVR(RR5t
grp_memberRT((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_from_db_by_instanceÊs




cCsÁt|d
t
jjd|
ƒ
jƒ}|s?tjd|
ƒ
‚
ntj|ƒ
}|jddƒ}|jddƒ}|j
|ƒ

|dk	ržt|||ƒ
n|dk	r½t|||ƒ
n|S(NRRR9R3R7(
RRRR;R<RR=tcopytpopRLR#R4R8(RR9R,RTtvalues_copyR3R7((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_save_in_dbÔs	









cCs¬y-tj
ƒ}|j|
ƒ

|j|jƒ

Wn*tjk
rY


tjd
|
dƒ
‚
n
X|rxt	|||ƒ|_
n	g|_
|rŸt|||ƒ|_n	g|_|S(NR9R;(
RRR#tsaveRtdb_exctDBDuplicateEntryRtInstanceGroupIdExistsR4RR8R(RR,R3R7R2((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt
_create_in_dbês






	
	
	
	cCs§t|d
t
jjd|
ƒ
}|jƒdkrEtjd|
ƒ
‚
n|jƒj}t
j	t
j
g}x0|D](}|jj|ƒ
j
d|ƒ
jƒ
qmW|jƒ
dS(NRRiR9R(RRRR;tcountRR=R<RR/R6RRRtdelete(RR9tqryRtinstance_modelsR+((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_destroy_in_db
s	

	






&cCst||
|ƒS(
N(
R>(RR9R7((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_add_members_in_db
s	
cCsN|
d
kr+tj
dddd|
ƒ‚
n|jƒ|_|jd
g
ƒ

dS(NR
tactiont
obj_load_attrtreasonsunable to load %s(RtObjectActionErrort	get_hostsR
RO(RDtattrname((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyRk
s

	

cCsjd}y|j
|
|ƒ}Wntjk
r2


n
X|dkrTtj|
|ƒ}n|j|
|ƒ|ƒS(
N(RLRURR=Rtinstance_group_getRS(tclsRR;tdb_group((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_by_uuid#
s






cCsŽy|j|
|ƒ}Wn_t
jk
rw


tj|
|
jƒ}x!|D]}|j|krE|SqEWt
jd
|ƒ
‚
n
X|j|
|ƒ|ƒS(NR9(RWRR=tInstanceGroupListt_get_main_by_project_idRRARS(RqRRARrtigstig((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_by_name.
s


	






cCsjd}y|j
|
|ƒ}Wntjk
r2


n
X|dkrTtj|
|ƒ}n|j|
|ƒ|ƒS(
N(RLRZRR=Rtinstance_group_get_by_instanceRS(RqRR5Rr((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_by_instance_uuid;
s





	

cCs3tj
|ƒ
r|j|
|ƒS|j|
|ƒSdS(
N(R
tis_uuid_likeRsRx(RqRthint((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_by_hintG
s
c
Csç|jƒ}
d
|
kr-t
jdd
ƒ
‚
n|
s7dSt|
ƒ
}|j|d<y|j|j|j|
ƒ}WnEt
jk
r¶


tj	|j|j|
ƒ
tj
|j|jƒ}n
X|j|j||ƒ
tj
|jd|ƒ
dS(s$Save updates to this instance group.R
R&Ntserver_group_idR#(tobj_get_changesRtInstanceGroupSaveExceptiontdictR;R^RNR=Rtinstance_group_updateRpRSt
compute_utilst notify_about_server_group_update(RDtupdatestpayloadRr((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyR_N
s










c
Csq|jj
|j|jƒ}
xE|jD]:}|j|ƒ
r%|||
|kr%|
|||<q%q%W|jƒ
d
S(sRefreshes the instance group.N(t	__class__RsRNR;Rtobj_attr_is_setRO(RDtcurrentR&((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytrefresho
s


#

cCsQ
|jd
ƒ
r*t
jddddƒ‚
n|jƒ}t|ƒ
}|jd
dƒ
|jddƒ}|jddƒ}d|kr¡tjƒ|_	|j	|d<n|
sóy2t
j|j|j	ƒ
t
jdddd	ƒ‚
Wqót
j
k
rï


qóXn|j|j|d|d|ƒ}|j|j||ƒ
|j	|d
<tj|jd|ƒ
dS(NRRjtcreateRlsalready createdR3R7R;salready created in mainR~(RˆRRmRRR\RLR
t
generate_uuidR;RRpRNR=RcRSRƒR„(RDt	skipcheckR…R†R3R7Rr((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_createx
s4











	







	




c


Cs|jƒ
dS(
N(
RŽ(
RD((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyR‹™
sc
Cs{i
|jd
6}
y|j
|j|jƒ
Wn*tjk
rV


tj|j|jƒ
n
X|jƒ
tj	|jd|
ƒ
dS(NR~Re(
R;RhRNRR=Rtinstance_group_deleteRORƒR„(RDR†((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytdestroy
s







cCs“i|d
6|d6}y6|j|
||ƒ}g|D]}|d^q3}Wn)t
jk
ru


tj|
||ƒ}n
Xtj|
d|ƒ
t|ƒ
S(NR~tinstance_uuidsR5t	addmember(RiRR=Rtinstance_group_members_addRƒR„tlist(RqRR9R‘R†R7tmember((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytadd_members¨
s





	
!




	


cCs†|j}|
r(t
|ƒ
t
|
ƒ
}ni|d
6td6}tjj|jd|ƒ

}tt
g|D]}|jrd|j^qdƒ
ƒ
S(s
Get a list of hosts for non-deleted instances in the group

        This method allows you to get a list of the hosts where instances in
        this group are currently running.  There's also an option to exclude
        certain instance UUIDs from this calculation.

        R;RHtfilters(	R7RRKR
tInstanceListtget_by_filtersRNR”thost(RDtexcludetfilter_uuidsR—t	instancestinstance((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyRn·
s		




	

cCsI|j}i|d
6|
d6t
d6}tjj|jd|ƒ

}t|ƒ
S(s=Count the number of instances in a group belonging to a user.R;R@RHR—(R7RKR
R˜R™RNtlen(RDR@RœR—R((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytcount_members_by_userÉ
s
	


	
N(+t__name__t
__module__tVERSIONRtIntegerFieldtStringFieldtTruet	UUIDFieldtListOfStringsFieldRGtstaticmethodRStdb_apitapi_context_managertreaderRURVRWRZtwriterR^RLRcRhRiRkRtremotable_classmethodRsRxRztclassmethodR}t	remotableR_RŠRKRŽR‹RR–RnR (((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyRosV






	
	
	

	

	


		
!	!
RtcBsueZ
dZi
ejd
ƒ
d6Zeejjdd„
ƒ
ƒ
Z
ed„ƒ
Ze
jd„ƒ
Ze
jd„ƒ
ZRS(s1.7RR
cCs7t|ƒ
}|
dk	r-|jd
|
ƒ
}n|jƒS(NR(RRLRR1(RRR((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_from_dbä
s


cCs1tj
|
|ƒ}tj|
||
ƒ
tj|ƒS(
N(Rt$instance_group_get_all_by_project_idRt
obj_make_listR
R(RqRRtmain_db_groups((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyRuì
s	
	

cCsJ|j|
d
|ƒ

}t
j|
|ƒ}tj|
||
ƒ
tj||ƒS(NR(R±RR²RR³R
R(RqRRt
api_db_groupsR´((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_by_project_idó
s

	
	

cCsA|j|
ƒ
}t
j|
ƒ
}tj|
||
ƒ
tj||ƒS(
N(R±Rtinstance_group_get_allRR³R
R(RqRRµR´((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pytget_allû
s


N(R¡R¢R£RtListOfObjectsFieldR©RªR«R¬RLR±R¯RuRR®R¶R¸(((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyRtÓ
s

	
cCsL|jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
jddƒ
j|
ƒ
jƒS(NRRRHi(	RRtmain_modelsRRRRtlimitR1(RR»((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt_get_main_instance_groupss



	
cCsÆt||
ƒ}d
}xž|D]–}t
jd|d|jd|jd|jd|jd|jd|jƒ}y|j	d	t
ƒ

Wntjk
r”


n
Xt
j||jƒ
|d
7}qWt|ƒ
|fS(NiRR@RR;RAR3R7Ri
(R¼R
RR@RR;RAR3R7RŽR¦RRbRªRRŸ(RRdtmain_groupstdoneRrR2((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt!migrate_instance_groups_to_api_db
s"





	
	
	
	
	






(-R[toslo_dbRR`t
oslo_utilsR
Rtsqlalchemy.ormRRtnova.computeRRƒtnovaRtnova.db.sqlalchemyRRªRR	RºR
tnova.objectsRRRJRLRRR-R4R8R>tNovaObjectRegistrytregistertNovaPersistentObjectt
NovaObjecttNovaObjectDictCompatRtObjectListBaseRttmain_context_managerR¬R¼R¿(((sP/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/instance_group.pyt<module>s:











					

ÿc
/