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

ddl	mZ
ddlm
Z

ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
dd
lm
Z

ddlmZmZ
ddlmZ
ddlmZ
ddlm Z 
ej!e"ƒ
Z#ddgZ$ej%j&d„ƒ
Z'ej%j&d„ƒ
Z(d„Z)d„Z*de+d„Z,ej%j-d„ƒ
Z.ej%j-d*d„
ƒ
Z0ej%j-d„ƒ
Z1ej%j-d„ƒ
Z2ej3j4dej5ej6fd„ƒYƒ
Z7ej%j&d „ƒ
Z8ej%j&d*d!„
ƒ
Z9ej%j&d"„ƒ
Z:ej3j4d#ej;ej6fd$„ƒYƒ
Z<ej=j&d%„ƒ
Z>d&„Z?d'„Z@ej%j&d(„ƒ
ZAd)„ZBd*S(+iÿÿÿÿ(
t	exception(
tlog(
texcutils(
t	uuidutils(
tcontains_eager(
t
joinedload(
tfunc(
ttext(
tutils(
tdb(
tapi(
t
api_models(
tmodels(t
_t_LW(
tobjects(
tbase(
tfieldstdeletedt
deleted_atcCsy|jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
}|jtjj|
kƒ
}|jƒ}|sut	j
d|
ƒ
‚
n|S(Nt_hostst	_metadatataggregate_id(tsessiontqueryRt	AggregatetoptionsRtfiltertidtfirstRtAggregateNotFound(tcontextRRt	aggregate((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_aggregate_get_from_db(s



cCsy|jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
}|jtjj|
kƒ
}|jƒ}|sut	j
d|
ƒ
‚
n|S(NRRR(RRRRRRRtuuidRRR(Rtaggregate_uuidRR ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_aggregate_get_from_db_by_uuid7s



cCs›yhtj
jj|ƒ
M
t||
ƒ
tjƒ}|ji|d
6|
d6ƒ

|j|j	ƒ

|SWdQXWn,t
jk
r–


tj
d
|d|
ƒ‚
n
XdS(NthostR(tdb_apitapi_context_managertwritertusingR!Rt
AggregateHosttupdatetsaveRtdb_exctDBDuplicateEntryRtAggregateHostExists(RRR%thost_ref((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_host_add_to_dbFs








cCs¢d
}tj
jj|ƒ
Z
t||
ƒ
|jjtjƒ
}|j	tjj
|
kƒ
}|jd|ƒ
jƒ}WdQX|d
kržt
jd|
d|ƒ‚
ndS(NiR%R(R&R'R(R)R!RRRR*RRt	filter_bytdeleteRtAggregateHostNotFound(RRR%tcountR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_host_delete_from_dbUs







i
c
Cs|jƒ}xò
t
|ƒ
D]ä
}yk
tjjj|ƒ
P

|jjtj	ƒ
j
d
|
ƒ
}|r‹|jtj	jj
|ƒ
ƒ
jdtƒ

ntƒ}|r
|jtj	jj
|ƒ
ƒ
}xE|jƒD]4}	|	j}
|	ji
||
d6ƒ

|j|
ƒ

qÅWng}xN|jƒD]@\}
}|
|kr1
q
n|ji|
d6|d6|
d
6ƒ

q
W|r
|jjtj	jjƒ|ƒ
n|SWdQXWqtjk
rü



tjƒN}
||dkrÈ
t|
_n+tdƒ
i|
d6|d6}tj |ƒ

WdQXqXqWdS(	NRtsynchronize_sessiontvaluetkeyi
sBAdd metadata failed for aggregate %(id)s after %(retries)s retriesRtretries(!tkeystrangeR&R'R(R)RRRtAggregateMetadataR2RR9tin_R3tFalsetsettallR+taddtitemstappendtexecutet	__table__tinsertR-R.Rtsave_and_reraise_exceptiontreraiseR
tLOGtwarning(RRtmetadatatmax_retriest
set_deletetall_keystattemptRtalready_existing_keystmeta_refR9tnew_entriesR8tctxttmsg((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_metadata_add_to_dbesJ




	



	




	









	





	
cCs€t||
ƒ
|j
jtjƒ
}|jtjj|
kƒ
}|jd
|ƒ
jƒ}|dkr|t	j
d|
d|ƒ‚
ndS(NR9iRtmetadata_key(R!RRRR=RRR2R3RtAggregateMetadataNotFound(RRR9RR5((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_metadata_delete_from_db–s




	
cCs×|jj
tjƒ
}|jtjj|
d
kƒ
}|jƒ}|s„tjƒ}|j|
ƒ

|j|jƒ

g|_	g|_
ntjd|
d
ƒ
‚
|rÓt
||j|ƒ
|jj|dg
ƒ
|j

n|S(Ntnametaggregate_nameR(RRRRRRZRR+R,RRRtAggregateNameExistsRVRtexpire(RtvaluesRLRR ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_aggregate_create_in_db¥s





	





cCsz|jj
tjƒ
jd
|
ƒ
jƒ
|jj
tjƒ
jtjj|
kƒ
jƒ}|dkrvt	j
d
|
ƒ
‚
ndS(NRi(RRRR=R2R3RRRRR(RRR5((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_aggregate_delete_from_db½s



cCs
t||
ƒ}t
}d
|krg|jd
ƒ
}d|krVi
|d
6|d<t}qg||dd
<n|jdƒ
}|dk	r¤t||
|jdƒ
d|ƒ

n|j|ƒ

y|j|j	ƒ

Wn<t
jk
r



d|krýtj
d|dƒ
‚
q
‚n
Xt||
ƒS(Ntavailability_zoneRLRNRZR[(R!tTruetpopR?tgettNoneRVR+R,RR-R.RR\(RRR^R RNtazRL((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_aggregate_update_to_dbÌs*




	










	

RcBsZ
eZ
dZiejƒd
6ejdeƒ
d6ejƒd6ejde	ƒ
d6ej
de	ƒ
d6Zdg
Zd„Ze
d	„ƒ
Zd
„Zed„ƒ
Zejd„ƒ
Zejd
„ƒ
Ze
ejjd„ƒ
ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
Z ed„ƒ
Z!RS(s1.3RtnullableR"RZthostsRLRac
Os&tt
|ƒj|
|Ž
t|_dS(
N(tsuperRt__init__R?t_in_api(tselftargstkwargs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyRkûs

cs'
xp|
jD]e}|d
kr%d}n6|dkr7q
n$|t
krU|ˆkrUq
n|}t|
|ˆ|ƒ
q
Wˆjdƒ
r’ˆd|
_nt‡f
d†t
Dƒ
ƒ
rÃd|
_t|
_	n||
_
|
jƒ
d|
kr#
tj
ƒ|
_tjdtd|
jd|
jƒƒ
|
jƒ
n|
S(NRLtmetadetailsR"c
3s|]}
|
ˆkV
qdS(
N((t.0t
f(
tdb_aggregate(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pys	<genexpr>
ss.Generating UUID %(uuid)s for aggregate %(agg)itagg(RtDEPRECATED_FIELDStsetattrRdR"tanyReRR?Rt_contexttobj_reset_changesRt
generate_uuidRJtdebugtdictRR,(RR RsR9tdb_key((
RssK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_from_db_objectÿs,

	






	
	



	


cCs1d
|jƒkr-t
jd|
ddƒ‚
ndS(NRitactiontreasonshosts updated inline(tobj_what_changedRtObjectActionError(RmR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_assert_no_hosts'
s

	

c

CsO|jr
t
Sy t|j|jƒ
t
|_Wntjk
rC


n
X|jSdS(
N(RlRbR!RxRRR(
Rm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytin_api-
s	






cCsRyt|
|ƒ}Wn&t
jk
r;


tj|
|ƒ}n
X|j|
|ƒ|ƒS(
N(R!RRR	t
aggregate_getR~(tclsRRRs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt	get_by_id9
s




cCsRyt|
|ƒ}Wn&t
jk
r;


tj|
|ƒ}n
X|j|
|ƒ|ƒS(
N(R$RRR	taggregate_get_by_uuidR~(R†RR#Rs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytget_by_uuidA
s





c
CsW|jj
tjƒ
jd
dƒ
jƒ}
|
rMtjtdƒ
i
|
d6ƒ
n|
dkS(NRis6Main database contains %(count)i unmigrated aggregatesR5(	RRtmain_modelsRR2R5RJRKR(Rtresult((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_ensure_migratedJ
s



	

c
CsW
|jd
ƒ
r*t
jddddƒ‚
n|j|jƒ
sWt
jddddƒ‚
n|jdƒ

|jƒ}
t|
ƒ
}d|
krž|jdƒ
|d<nd	|
krÚt	j
ƒ|
d	<tjd
td	|
d	ƒ
ƒ
nt
j|jd|ƒ
|
jddƒ}t|j|
d|ƒ
}|j|j||ƒ
|j|d<t
j|jd
|ƒ
dS(NRRtcreateR€salready createds'main database still contains aggregatesRLt	meta_dataR"s%Generated uuid %(uuid)s for aggregatescreate.startRs
create.end(tobj_attr_is_setRR‚RŒRxRƒtobj_get_changesR|RcRRzRJR{t
compute_utilstnotify_about_aggregate_updateReR_R~R(RmtupdatestpayloadRLRs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyRU
s6


	








	






	





c
Csê|jd
ƒ

|j
ƒ}
i
|jd6}d|
krF|
d|d<ntj|jd|ƒ
|
jddƒ
yt|j|j|
ƒ}Wn/t	j
k
r¹


tj|j|j|
ƒ}n
Xtj|jd|ƒ
|j
|j||ƒ
dS(NR,RRLRŽsupdateprop.startRsupdateprop.end(RƒRRR‘R’RxRcReRgRRR	taggregate_updateR~(RmR“R”Rs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyR,y
s$









	





cCs<
|jrt
}t}ntj}tj}i|jd
6|
d6}tj|j	d|ƒ
i}x™|
j
ƒD]‹\}}|dkrÞy||j	|j|ƒ
Wntj
k
r²


n
Xy|jj|ƒ

Wqõtk
rÚ


qõXqj|||<||j|<qjW||j	|j|ƒ
tj|j	d|ƒ
|jddg
ƒ

dS(NRRŽsupdatemetadata.startsupdatemetadata.endRRL(R„RYRVR	taggregate_metadata_deletetaggregate_metadata_addRR‘R’RxRCReRRXRLRctKeyErrorRy(RmR“tmetadata_deletetmetadata_addR”tto_addR9R8((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytupdate_metadata
s8	

		
	
























c

CsHyt|j
|jƒ
Wn*tjk
rC


tj|j
|jƒ
n
XdS(
N(R`RxRRRR	taggregate_delete(
Rm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytdestroy²
s


cCs}|jr"t
|j|j|
ƒ
ntj|j|j|
ƒ
|jdkrVg|_n|jj|
ƒ

|j	d
dg
ƒ

dS(NRRi(
R„R1RxRR	taggregate_host_addRiReRDRy(RmR%((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytadd_host¹
s	



cCsb|jr"t
|j|j|
ƒ
ntj|j|j|
ƒ
|jj|
ƒ

|jd
dg
ƒ

dS(NRRi(	R„R6RxRR	taggregate_host_deleteRitremoveRy(RmR%((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytdelete_hostÅ
s
	

c

Cs|jj
d
dƒS(NRa(RLRdRe(
Rm((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyRaÏ
s("t__name__t
__module__tVERSIONRtIntegerFieldt	UUIDFieldR?tStringFieldtListOfStringsFieldRbtDictOfStringsFieldtobj_extra_fieldsRktstaticmethodR~RƒtpropertyR„Rtremotable_classmethodR‡R‰R&tmain_context_managertreaderRŒt	remotableRR,RœRžR R£Ra(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyRés.






		(		

$"
c
Cs=|jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
}
|
jƒS(NRR(RRRRRRRA(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_get_all_from_dbÔ
s

cCs”|jj
tjƒ
jtd
ƒ
ƒ
jtdƒ
ƒ
}|jd
ƒ
}|jtjj	|
kƒ
}|rŠ|jdƒ
jtj
j|kƒ
}n|jƒS(NRR(
RRRRRRtjoinRR*R%R=R9RA(RR%R9R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_get_by_host_from_dbÝ
s





cCss|jj
tjƒ
}|jd
ƒ
}|jtjj|
kƒ
}|jt	d
ƒ
ƒ
}|jt
dƒ
ƒ
}|jƒS(NRR(RRRRR´RR=R9RRRRA(RR9R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_get_by_metadata_key_from_dbì
s



t
AggregateListcBs~eZ
dZi
ejd
ƒ
d6Zed„ƒ
Zed„ƒ
Ze	j
d„ƒ
Ze	j
dd„
ƒ
Z
e	j
dd„
ƒ
ZRS(	s1.2RRc

Csd|d
<t
|d<|S(NRR(ReR?(
Rs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_fill_deprecateds



cCskt|t
ƒst
|ƒ
}ng}x@|
D]8}x/|d
D]#}||kr<|j|ƒ

Pq<q<Wq+W|S(NRi(t
isinstanceR@RD(R†t
db_aggregatesRitfiltered_aggregatesRsR%((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_filter_db_aggregatess









cCsZgt|
ƒ
D]}|j
|ƒ
^q
}tj|
ƒ
}tj|
||
ƒ
tj||ƒS(
N(R³R¸R	taggregate_get_allRt
obj_make_listRR(R†RRttapi_db_aggregatesRº((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytget_alls

%


cCslgt|
|d
|ƒ
D]}|j
|ƒ
^q}tj|
|d
|ƒ
}tj|
||
ƒ
tj||ƒS(NR9(RµR¸R	taggregate_get_by_hostRR¾RR(R†RR%R9RtR¿Rº((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytget_by_hosts

.


cCsgt|
d
|ƒ

D]}|j
|ƒ
^q}tj|
d
|ƒ

}||}|dk	rn|j||ƒ}ntj|
||
ƒ
tj	|ƒS(NR9(
R¶R¸R	taggregate_get_by_metadata_keyReR¼RR¾RR(R†RR9RiRtR¿Rºtall_aggregates((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytget_by_metadata_key's
+





N(R¤R¥R¦RtListOfObjectsFieldR­R¸tclassmethodR¼RR¯RÀReRÂRÅ(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyR·÷
s


cCsRd
dlm
}
g|jj|jjƒ
jddƒ
j|
ƒ
D]}|d^q>S(Niÿÿÿÿ(
RRi(tnova.db.sqlalchemyRRRRRR2tlimit(RRÉRt
x((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_get_main_db_aggregate_ids4s

	
c	s7
t||
ƒ}|sdSt
|ƒ
}d
}xÿ|D]÷}y•tj||ƒ‰ddg‰
‡‡
fd†ˆjDƒ
}t||dˆjƒ

x!ˆjD]}t|||ƒ
q•W|d7}t	j
|ˆjƒ
Wq2tj
k
r



tjtdƒ
i
|d6ƒ
q2tjk
r(

}
tjt|ƒ
ƒ

q2Xq2W||fS(	NiRLRic
s.i|]$}
|
ˆ
krtˆ|
ƒ|
“qS((
tgetattr(Rqtfield(R R¢(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pys
<dictcomp>Hs	
i
s0Aggregate id %(id)i disappeared during migrationR(ii(RËtlenRR‡RR_RLRiR1R	RRRRRJRKRR\terrortstr(	RTR5tmain_db_idst	count_allt	count_hitRR^R%t
e((R R¢sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pytmigrate_aggregates<s.



















	


cCs9tj
ƒ}|jd
kr5|jtd|
ƒ
ƒ

ndS(Nt
postgresqls1ALTER SEQUENCE aggregates_id_seq RESTART WITH %i;(R&tget_api_engineRZRER(RR8tengine((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_adjust_autoincrementYs




c

Cs)|jj
tjtjjƒ
ƒ
jƒd
S(Ni(RRRtmaxRRRtone(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt_get_max_aggregate_idfscCs't|ƒ
pd
}t
||dƒ
dS(Nii
(ii(RÜRÙ(RTR5tmax_id((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt%migrate_aggregate_reset_autoincrementks


N(Ctoslo_dbRR-toslo_logR
tloggingt
oslo_utilsRRtsqlalchemy.ormRRtsqlalchemy.sqlRRtnova.computeRR‘tnovaR	RÈR
R&RRRŠt	nova.i18nR
RRtnova.objectsRRt	getLoggerR¤RJRuR'R±R!R$R1R6R?RVR(RYReR_R`RgtNovaObjectRegistrytregistertNovaPersistentObjectt
NovaObjectRR³RµR¶tObjectListBaseR·R°RËRÕRÙRÜRÞ(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/aggregate.pyt<module>sV















		
0	

ê		

<