ó
Sħ`c@s¥dd
lZdd
l
Z
dd
lZdd
lZddlmZ
ddlmZ
ddl	m
Z

dd
lZddlm
Z
ddlmZ
ddlmZ
ddlmZ
dd	lmZ
dd
lmZ
ddlmZ
ddlmZ
dd
lmZ
ddlmZ
ddlmZ
ddlmZ 
ddl!m"Z"
ddl#m$Z$
ddl%m&Z&
ddl'm(Z(
ddl'm)Z)
ddl'm*Z*
dd
l+Zddl'm,Z,
ddlm-Z.
ddl/m0Z0
ddlm1Z1
ej2e3ƒ
Z4dej5f
d„ƒYZ6de$j7f
d„ƒYZ8de8f
d „ƒYZ9d!e9f
d"„ƒYZ:d#e8f
d$„ƒYZ;d%e8f
d&„ƒYZ<d'e$j7e$j=fd(„ƒYZ>d)ej?e$j=fd*„ƒYZ@d+e@f
d,„ƒYZAd-e@f
d.„ƒYZBd/e@f
d0„ƒYZCd1e@f
d2„ƒYZDd3e@f
d4„ƒYZEd5e@f
d6„ƒYZFd7e@f
d8„ƒYZGd9e@f
d:„ƒYZHd;e8f
d<„ƒYZId=eIf
d>„ƒYZJd?eIf
d@„ƒYZKd
S(AiÿÿÿÿN(
tlog(
tbase64(
t	timeutils(
tapi(
tinstance_actions(
tmanager(
trpcapi(
tcontext(
tdb(
t	exception(
tobjects(
tblock_device(
tweights(
ttest(
tfixtures(
tclient(
tintegrated_helpers(
tfakes(
tfake_block_device(
tfake_network(
t
fake_notifier(
tpolicy_fixture(
tuuidsentinel(
tfake(
tvolumetAltHostWeigherc
BseZ
dZd
„ZRS(sSUsed in the alternate host tests to return a pre-determined list of
    hosts.
    cCsCid
d6dd6dd6dd6d	d
6d	d6}|j|
j
d	ƒS(s Return a defined order of hosts.içt	selectionixt	alt_host1i	t	alt_host2išt	alt_host3ithost1thost2(tgetthost(tselft
host_statetweight_propertiesR((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt
_weigh_object.s

(t__name__t
__module__t__doc__R%(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR*s
tServersTestBasec
BsneZ
dZd
ZdZdZdZdZdZdZ	d„Z
d	„Zd
„Zd„Z
d„Zd
„ZRS(tv2tforceDeletetimageReft	flavorReft
accessIPv4t
accessIPv6treturn_reservation_idt	min_countc

CsEi|_t
t|ƒjƒ
tj|ƒ

|jd
ddƒ

|_dS(Nt	conductorRs'nova.conductor.manager.ConductorManager(tcomputestsuperR)tsetUpRtset_stub_network_methodst
start_serviceR2(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5?s

	



cCsUxNtd
dƒD]=}|j
j|
dƒ
}
|
d|kr@Pntjdƒ

qW|
S(Nii2tidtstatusgš™™™™™¹?(trangeRt
get_serverttimetsleep(R"tservertfrom_statust
i((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_wait_for_state_changeIs




cCs†xrtd
ƒ
D]d}y|j
j|
ƒ
}Wn(tjk
rS


d}tjdƒ

Pn
Xtjd|ƒ
tj	dƒ

q
W|j
|ƒ

dS(Ni2sGot 404, proceedingsFound_server=%sgš™™™™™¹?(R:RR;RtOpenStackApiNotFoundExceptiontNonetLOGtdebugR<R=tassertFalse(R"t	server_idt_retriestfound_server((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_wait_for_deletionRs






cCs!|jj
|
ƒ

|j|
ƒ

dS(
N(Rt
delete_serverRJ(R"RG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_delete_serverfs
c

Csid
|j6d|j
6S(Ns
172.19.0.2sfe80::2(t_access_ipv4_parametert_access_ipv6_parameter(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_access_ips_paramsks


cCs2|jd
|
|j
ƒ
|jd|
|jƒ
dS(Ns
172.19.0.2sfe80::2(tassertEqualRMRN(R"R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_verify_access_ipsos
	

(R&R'tapi_major_versiont_force_delete_parametert_image_ref_parametert_flavor_ref_parameterRMRNt_return_resv_id_parametert_min_count_parameterR5RARJRLRORQ(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR)5s







	
					tServersTestc
BsàeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z	d„Z
d	„Zd
„Zd„Z
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„ZRS(c
Cs4|jj
ƒ}
x|
D]}tjd
|ƒ
qWdS(Ns
server: %s(Rtget_serversRDRE(R"tserversR>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_get_serversws


c
Cs,tj
ƒ}
tjj|
ƒ
}d
„|Dƒ
S(Nc
Ss1i|]'}
t|
j
jdd
ƒƒ
|
j“qS(t
failed_buildsi(tinttstatsR thypervisor_hostname(t.0tnode((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pys
<dictcomp>s	
(Rtget_admin_contextR
tComputeNodeListtget_all(R"tctxtR3((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_node_build_failures}s


c
Cs‘|jj
|jkr.|j|j|jj
<ntjƒ}
xCt|jjƒƒ
D],}tjd
|j	j
ƒ
|j	j
|
ƒ

qPWtjdƒ

dS(sØRun the update_available_resource task on every compute manager

        This runs periodics on the computes in an undefined order; some child
        class redefined this function to force a specific order.
        s!Running periodic for compute (%s)sFinished with periodicsN(tcomputeR!R3RRbtlisttvaluesRDtinfoRtupdate_available_resource(R"tctxRg((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_run_periodics„s


	



c
Csùd
„}
|jd|
ƒ
|j
ƒ}|jji
|d6ƒ
}|d}|jj|ƒ
}|j||dƒ
|j|dƒ}|jd|dƒ
|j|ƒ

|jdg
t|j	ƒj
ƒƒ
ƒ
|jƒ
|jd	g
t|j	ƒj
ƒƒ
ƒ
dS(
Nc_stj
d
dddƒ‚
dS(Ntreasontt
instance_uuidR(R	tBuildAbortException(targstkwargs((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytthrow_error˜s

snova.virt.fake.FakeDriver.spawnR>R8tBUILDtERRORR9ii
(tstub_outt$_build_minimal_create_server_requestRtpost_serverR;RPRARLRhRfRiRm(R"RtR>tcreated_servertcreated_server_idRI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_create_server_with_error•s	





%


c
s
tj
d
g
ƒ

|jtjƒ

|jdd
ƒ

|jddd
ƒ

|_|j|jd<g‰‡f
d†}
|jd|
ƒ
|j	ƒ}|j
ji
|d6ƒ
}|d}|j
j|ƒ
}|j
||dƒ
|j|d	ƒ}|j
d
|dƒ
|j|ƒ

tˆƒ
S(NRR!Rgtcompute2cs ˆjd
ƒ

t
jdƒ
‚
dS(NtonesPlease retry me(tappendR
tTestingException(RrRs(
tfails(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRt»s


snova.virt.fake.FakeDriver.spawnR>R8RuRvR9(Rt	set_nodest
addCleanupt
restore_nodestflagsR7R}R3RwRxRRyR;RPRARLtlen(R"RtR>RzR{RI((
RsG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt+_test_create_server_with_error_with_retries°s"









c
Csh|jd
dddƒ
|j
ƒ}
|jd|
ƒ
|jƒ
|jddgt|jƒjƒƒ
ƒ
dS(Ntmax_attemptsitgroupt	scheduleri
(R…R‡RPRmRhRfRi(R"R((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt*test_create_server_with_error_with_retriesÏs






c
Csn|jd
dddƒ
|j
ƒ}
|jd|
ƒ
|jƒ
|jddgtt|jƒjƒƒ
ƒ
ƒ
dS(NRˆi
R‰RŠi(R…R‡RPRmRhtsortedRfRi(R"R((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt-test_create_server_with_error_with_no_retries×s






c

Csþ
i}
|jƒ}i
|
d
6}|j
tj|jj|ƒ
|jƒ|
|j<|j
tj|jj|ƒ
|j|jƒ
|
|j<|j
tj|jj|ƒ
|j|j	ƒ
|
|j	<|j
tj|jj|ƒ
|d|
d<|jj|ƒ
}t
jd|ƒ
|j|dƒ

|d}|jj
|ƒ
}|j||dƒ
|jjƒ}g|D]}|d^q[
}	|j||	ƒ
|j|dƒ}|jd|dƒ
|jjdtƒ
}x.|D]&}
|jd	|
ƒ
|jd
|
ƒ
qÃ
W|j|ƒ

dS(NR>tnamescreated_server: %sR8RutACTIVER9tdetailtimagetflavor(RxtassertRaisesRtOpenStackApiExceptionRRytget_invalid_imageRTR RURDREt
assertTrueR;RPRYtassertInRAtTrueRL(
R"R>tgood_servertpostRzR{RIRZt
st
server_ids((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_create_and_delete_serverßsB



















c
Cs\tj
ƒtjd
dƒ
}
tjd|
ƒ

|jtjƒ

tjƒ}|j	j
|ƒ

dS(Nthoursi
t
override_time(Rtutcnowtdatetimet	timedeltatset_time_overrideRƒtclear_time_overrideRRbRgt_reclaim_queued_deletes(R"tthe_pastRe((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_force_reclaim!
s




c
Csý|jd
dƒ

|j
ƒ}
|jji
|
d6ƒ
}tjd|ƒ
|j|dƒ

|d}|j|dƒ}|jd|dƒ
|j	t
j|jj|i
id	6ƒ
|jj
|ƒ

|j|dƒ}|jd
|dƒ
|jƒ
|j|ƒ

dS(Ntreclaim_instance_intervali
R>screated_server: %sR8RuRR9trestoretSOFT_DELETED(R…RxRRyRDRER–RARPR“RR”tpost_server_actionRKR§RJ(R"R>RzR{RI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_deferred_delete*
s 







c
Cs
|jd
dƒ

|j
ƒ}
|jji
|
d6ƒ
}tjd|ƒ
|j|dƒ

|d}|j|dƒ}|jd|dƒ
|jj	|ƒ

|j|dƒ}|jd	|dƒ
|jj
|i
id
6ƒ
|j|dƒ}|jd|dƒ
dS(NR¨iR>screated_server: %sR8RuRR9RªR©tDELETED(R…RxRRyRDRER–RARPRKR«(R"R>RzR{RI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_deferred_delete_restoreM
s





c
Cs”
|jd
dddƒ
|jddƒ

|j
ƒ}
|jji
|
d6ƒ
}tjd|ƒ
|j|d	ƒ

|d	}|j|d
ƒ}|jd|dƒ
|jj	|ƒ

|j|dƒ}|jd
|dƒ
|j
ƒ}
|jji
|
d6ƒ
}tjd|ƒ
|j|d	ƒ

|j|d
ƒ}|jd|dƒ
|j
tj|jj
|i
id6ƒ}|jd|jjƒ
|jd
|dƒ
dS(Nt	instancesi
R‰tquotaR¨iR>screated_server: %sR8RuRR9RªR©i“
(R…RxRRyRDRER–RARPRKR“RR”R«tresponsetstatus_code(R"R>tcreated_server1tcreated_server_id1t
found_server1tcreated_server2t
found_server2tex((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt&test_deferred_delete_restore_overquotam
s.







	


c
Csê|jd
dƒ

|j
ƒ}
|jji
|
d6ƒ
}tjd|ƒ
|j|dƒ

|d}|j|dƒ}|jd|dƒ
|jj	|ƒ

|j|dƒ}|jd	|dƒ
|jj
|i
i|j6ƒ
|j|ƒ

dS(
NR¨iR>screated_server: %sR8RuRR9Rª(
R…RxRRyRDRER–RARPRKR«RSRJ(R"R>RzR{RI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_deferred_delete_forceœ
s





c

Cs
|jƒ}
i}x&t
d
ƒ
D]}d||d|<qW||
d<i
|
d6}|jj|ƒ
}tjd|ƒ
|j|dƒ

|d}|jj|ƒ
}|j||dƒ
|j||j	dƒ
ƒ
|jj
dtƒ
}d	„|Dƒ
}	|	j	|ƒ
}|j|ƒ

|j||j	dƒ
ƒ
|jj
dtƒ
}d
„|Dƒ
}	|	j	|ƒ
}|j|ƒ

|j
|j	dƒ
ƒ

|j|ƒ

dS(Nisvalue_%sskey_%stmetadataR>screated_server: %sR8Rc
Ssi|]}
|
|
d“qS(
R8((R`R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pys
<dictcomp>Ô
s	c
Ssi|]}
|
|
d“qS(
R8((R`R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pys
<dictcomp>Ü
s	(RxR:RRyRDRER–R;RPR RYR˜tFalseRFRL(
R"R>R»R@RšRzR{RIRZt
server_map((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt test_create_server_with_metadata¼
s0


















c
Cs
|jƒ}
i
d
d6}||
d<i
|
d6}|j
j|ƒ
}|j|dƒ}|jd|dƒ
|j||jdƒ
ƒ
|d}|jd	d
ƒ

|j
j|i
id6ƒ
|j|dƒ}|jd|dƒ
i
d
d6}|jt	j
|j
j||ƒ}|jd|jj
ƒ
|jd|dƒ
|jt	j
|j
j|dƒ}|jd|jj
ƒ
|jd|dƒ
|j|ƒ

dS(Ntvalue_1tkey_1R»R>RuRR9R8tshelved_offload_timeiÿÿÿÿtshelvetSHELVEDtvalue_2tkey_2i™
(RxRRyRARPR R…R«R“RR”tpost_server_metadataR±R²tdelete_server_metadataRL(R"R>R»RšRzRIRGR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt3test_server_metadata_actions_negative_invalid_stateå
s2












	



	


c
	Csº|jƒ}
i
|
d
6}i}x&t
dƒ
D]}d||d|<q,W||d
d<|jj|ƒ
}tjd|ƒ
|j|dƒ

|d}|j|dƒ}i}id	|j6d
d6d|j	6d
|j
6i
dd6d6|d<|dj|jƒƒ

|jj
||ƒ
tjd|ƒ
|j|dƒ

|jj|ƒ
}|j||dƒ
|ji
dd6|jdƒ
ƒ
|jd
|jdƒ
ƒ
|j|d|j|jdƒ
dƒ
|j|ƒ

i}id	|j6id6|d<|jj
||ƒ
tjd|ƒ
|j|dƒ

|jj|ƒ
}|j||dƒ
|ji|jdƒ
ƒ
|jd
|jdƒ
ƒ
|j|d|j|jdƒ
dƒ
|j|ƒ

|j|ƒ

dS(NR>isvalue_%sskey_%sR»screated_server: %sR8Rus$76fa36fc-c930-4bf3-8c8a-ea2a2420deb6tblahRŽs
172.19.0.2sfe80::2tthingtsometrebuildsrebuilt server: %sR‘(RxR:RRyRDRER–RARTRMRNtupdateROR«R;RPR RQRL(	R"R>tserver_postR»R@RzR{RšRI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_create_and_rebuild_serversX




















 

















c
Cs¤|jƒ}
|j
ji
|
d
6ƒ
}tjd|ƒ
|d}|j|ƒ

|j
j|i
i
dd6d
6ƒ
|j
j|ƒ
}|j|ddƒ
|j	|ƒ

dS(NR>screated_server: %sR8snew-nameRŽ(
RxRRyRDRER–t
put_serverR;RPRL(R"R>RzRG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_rename_serverOs





!
c
CsN
|jƒ}
d
|
|j
<t|
|j<i
|
d6}|jj|ƒ
}|jd|ƒ
|d}|j|ddgƒ
|jƒ}
i
|
d6}|jj|ƒ
}|j	|dƒ

|d}|jj
dtdi
|d6ƒ}d„|Dƒ
}|j|ƒ
}	|j|	ƒ

|j
t|ƒ
d
ƒ
|j|ƒ

x|D]}
|j|
ƒ

q3
WdS(	NiR>treservation_idRoR8Rtsearch_optsc
Ssi|]}
|
|
d“qS(
R8((R`R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pys
<dictcomp>{s	(RxRWR˜RVRRyR—tassertNotInRCR–RYR tassertIsNoneRPR†RL(R"R>RšR±RÒRzR{RZR½RIRG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_create_multiple_serverscs,
























c
Cs 
g}
d
}|
jidd6t
j|ƒ
d6ƒ

tjd
ƒ
}|
jidd6t
j|ƒ
d6ƒ

|jƒ}|
|d<i
|d6}|jj|ƒ
}tj	d|ƒ
|j
|d	ƒ

|d	}|jj|ƒ
}|j||d	ƒ
|j
|d
ƒ}|jd|dƒ
|j|ƒ

dS(
Ns
Hello, World!s/helloworld.txttpathtcontentss/helloworld.ziptpersonalityR>screated_server: %sR8RuRR9(RR
tencode_as_bytestzlibtcompressRxRRyRDRER–R;RPRARL(R"RÙtdataR>RšRzR{RI((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt&test_create_server_with_injected_files‡s*
	


	










c
Cs\
|jƒ}
|j
ji
|
d
6ƒ
}|d}|j|dƒ}|jd|dƒ
i
id6}|jtj|j
j||ƒ}|jd|j	j
ƒ
|jd|dƒ
i
id6}|j
j||ƒ
|j|dƒ}|jd	|dƒ
i
id6}|jtj|j
j||ƒ}|jd|j	j
ƒ
|jd	|dƒ
|j|ƒ

dS(
NR>R8RuRR9sos-starti™
sos-stoptSHUTOFF(RxRRyRARPR“RR”R«R±R²RL(R"R>RzR{RIRšR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt.test_stop_start_servers_negative_invalid_state®s,






	









	


c
Cs¾|jƒ}
|j
ji
|
d
6ƒ
}|d}|j|dƒ}|jd|dƒ
i
id6}|jtj|j
j||ƒ}|jd|j	j
ƒ
|jd|dƒ
|j|ƒ

dS(NR>R8RuRR9trevertResizei™
(RxRRyRARPR“RR”R«R±R²RL(R"R>RzR{RIRšR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt1test_revert_resized_server_negative_invalid_stateØs







	


c
Cs0
|jd
t
ƒ

|jƒ}
|jji
|
d6ƒ
}|d}|j|dƒ}|jd|dƒ
i
idd6d	d
6d6}|jj||ƒ
|j|dƒ}|jd
|dƒ
i
idd6d	d
6d6}|jt	j
|jj||ƒ}|jd|jjƒ
|jd
|dƒ
|j
|ƒ

dS(Ntallow_resize_to_same_hostR>R8RuRR9t
2R-tAUTOsOS-DCF:diskConfigtresizetRESIZEt
VERIFY_RESIZEt
1i™
(R…R˜RxRRyRARPR«R“RR”R±R²RL(R"R>RzR{RIRšR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt)test_resize_server_negative_invalid_stateïs"









	


c
Cs¾|jƒ}
|j
ji
|
d
6ƒ
}|d}|j|dƒ}|jd|dƒ
i
id6}|jtj|j
j||ƒ}|jd|j	j
ƒ
|jd|dƒ
|j|ƒ

dS(NR>R8RuRR9t
confirmResizei™
(RxRRyRARPR“RR”R«R±R²RL(R"R>RzR{RIRšR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt2test_confirm_resized_server_negative_invalid_states







	


c
CsÐ|jd
dddƒ
|jddddƒ
|j
ƒ}
|jji
|
d6ƒ
}|d}|j|d	ƒ}|jd
|dƒ
i
i
dd
6d6}|jtj|jj	||ƒ}|jd|j
jƒ
dS(Ntcoresi
R‰R°tramiR>R8RuRR9RäR-Ræi“
(R…RxRRyRARPR“RR”R«R±R²(R"R>RzR{RIRšR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_server_overquota&s







	

(R&R'R[RfRmR|R‡R‹RRR§R¬R®R¹RºR¾RÈRÏRÑRÖRÞRàRâRêRìRï(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRXus0								B			#	 	/	 	)	)	A		$	'	*		 	tServersTestV21c
BseZ
dZRS(
sv2.1(R&R'RR(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRð9s
tServersTestV219cBs¿eZ
dZedd
„Zedd„Zedd„Zedd„Zedd„Z	edd„Z
ded„Zd„Zd	„Z
d
„Zd„Zd„Zd
„Zd„Zd„ZRS(sv2.1cCsR|jƒ}|
r||d
<ni
|d6}|j
jd|ƒj}||dfS(NtdescriptionR>s/servers(RxRtapi_posttbody(R"tset_desctdescR>RšR±((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_create_server@s







cCsUtj
d
ƒ
}i
i
|d6d6}|r:||dd<n|jjd|
|ƒ
dS(NiRŽR>Ròs/servers/%s(Rtgenerate_random_alphanumericRtapi_put(R"RGRõRötnew_nameR>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_update_serverHs





cCs›tj
d
ƒ
}i}i|d6d|j6d|j6d|j6i
dd6d6|d	<|d	j|jƒƒ

|r€||d	d
<n|jjd|
|ƒ
dS(NiRŽs$76fa36fc-c930-4bf3-8c8a-ea2a2420deb6s
172.19.0.2sfe80::2RÊRËR»RÌRòs/servers/%s/action(	RRøRTRMRNRÍRORRó(R"RGRõRöRúRš((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_rebuild_serverOs













cCs;|j|
|ƒd
d}|j
||ƒ
|j|ƒ

dS(Ni
R8(R÷t_verify_server_descriptionRL(R"Rõt
expected_descR{((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_create_server_and_verify^s	


cCs'|j|
||ƒ
|j
|
|ƒ
dS(
N(RûRý(R"RGRõRþ((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_update_server_and_verifyfs
cCs'|j|
||ƒ
|j
|
|ƒ
dS(
N(RüRý(R"RGRõRþ((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_rebuild_server_and_verifyms
cCsä|jj
d
|
ƒ
}|jd}|j|
|dƒ
|rY|j||jdƒ
ƒ
n|jd|ƒ
|jj
dƒ
jd}d„|Dƒ
}|j|
ƒ
}|j|ƒ

|rÐ|j||jdƒ
ƒ
n|jd|ƒ
dS(Ns/servers/%sR>R8Ròs/servers/detailRZc
Ssi|]}
|
|
d“qS(
R8((R`R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pys
<dictcomp>ƒs	(Rtapi_getRôRPR RÔR–(R"RGRþtdesc_in_respR±RIRZR½((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRýts








cCsK|jt
jd
ƒ0}|jt|
ƒ
|jd|jjjƒ
WdQXdS(Ns.*Unexpected status code.*i
(	tassertRaisesRegexRR”R÷R˜RPR	R±R²(R"Rötcm((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_create_assertRaisesRegexs


cCsN|jt
jd
ƒ3}|j|
t|ƒ
|jd|jjjƒ
WdQXdS(Ns.*Unexpected status code.*i
(	R
RR”RûR˜RPR	R±R²(R"RGRöR
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_update_assertRaisesRegex”s


cCsN|jt
jd
ƒ3}|j|
t|ƒ
|jd|jjjƒ
WdQXdS(Ns.*Unexpected status code.*i
(	R
RR”RüR˜RPR	R±R²(R"RGRöR
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_rebuild_assertRaisesRegex›s


c

CsGd
|j_
|jtdƒ
|jtdƒ
|jƒ
|jtƒ

dS(Ns2.19stest descriptionRo(RtmicroversionRÿR˜R¼(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt#test_create_server_with_description¢s


c
Csd
|j_
|jtdƒdd}
|j|
tdƒ
|j|
tdƒ
|j|
tdƒ
|j|
ƒ

|j|
tdƒ
|j|
ƒ

dS(Ns2.19stest desc 1i
R8supdated descRos
updated desc2(RR	
R÷R˜R
R¼RL(R"RG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt#test_update_server_with_description­s

c
Cs¦d
|j_
|jtdƒd}
|
d}|j|
dƒ
|j|tdƒ
|j|tdƒ
|j|tdƒ
|j|ƒ

|j|tdƒ
|j|ƒ

dS(	Ns2.19stest desc 1i
R8Rusupdated descRos
updated desc2(RR	
R÷R˜RAR

R¼RL(R"R>RG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt$test_rebuild_server_with_descriptionÀs




c
CsÛd
|j_
|jtdƒdd}
d|j_
|j|
dtƒ


|j|
dƒ
|j|
dƒ
|j|
ƒ

|jtƒ
\}}|d}
d
|j_
|j|
|d	ƒ
|j|
ƒ

d|j_
|j	d
ƒ

dS(Ns2.19stest desc 1i
R8s2.18R
stest update 2.18stest rebuild 2.18RŽstest create 2.18(
RR	
R÷R˜RýR¼R
R
RLR
(R"RGt
server_reqR±((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_version_compatibilityÖs








c
Csd
|j_
|jdƒ

|jddƒ

|jtdƒdd}
|j|
dƒ
|j|
dƒ
|j|
ddƒ
|j|
ddƒ
dS(	Ns2.19tinvaliddstringt
xi
Röi
R8sinvalid\u0604string(RR	
R
R÷R˜R
R
(R"RG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_description_errorsös



N(R&R'RRR˜RCR÷RûRüRÿR
R

RýR
R
R
R

R
R
R
R
(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRñ=s&



							 tServerTestV220c
BsMeZ
dZd
„Zd„Zd„Zd„Zd„Zd„Zd„Z	RS(sv2.1c

Cs?tt
|ƒjƒ
d
|j_tj|ƒ

tjƒ|_	dS(Ns2.20(
R4R
R5RR	
RR6RRbRe(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5s




c
Cs?|jƒ}
i
|
d
6}|j
jd|ƒj}|
|d
fS(NR>s/servers(RxRRóRô(R"R>RšR±((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR÷s




c
CsT|jƒd
}
|
d}|j
|
dƒ
|jj|i
dd6ƒ
|j
|
dƒS(Ni
R8RuRÂR(R÷RARR«RC(R"R>RG((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_shelve_servers






cCs;tj
|jtjid
d6dd6dd6dd6ƒ
g
ƒS(Ns/dev/vdatdevice_nameRtsource_typetdestination_types$5d721593-f033-4f6d-ab6f-b5b067e61bc4t	volume_id(tblock_device_objtblock_device_make_listReRtFakeDbBlockDeviceDict(R"Re((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_fake_bdmss






c
	CsÛ
|jd
dƒ

|j
ƒ}
|jd|
dƒ
|
d}|jdtjƒ
tjtj	j
tjdƒtj	j
t
jdƒtj	j
tjd	ƒƒp\}}}tjd
dƒ
|_i
i
dd
6d6}|jjd||ƒ
|j|jƒ

|j|jƒ

WdQXtjtj	j
tjjdƒtj	j
tjdƒtj	j
tjdƒƒp\}}}	|j|jƒ
|_|jdd}
|jjd||
fƒ

|j|jƒ

|j|	jƒ

WdQX|j|ƒ

dS(NRÁiÿÿÿÿRÃR9R8snova.volume.cinder.API.gettis_microversion_supportedt _check_attach_and_reserve_volumet
attach_volumetversions3.44s$5d721593-f033-4f6d-ab6f-b5b067e61bc4tvolumeIdtvolumeAttachments!/servers/%s/os-volume_attachmentstbegin_detachingtget_by_instance_uuidt
detach_volumeiR
s$/servers/%s/os-volume_attachments/%s(R…R
RPRwRtstub_volume_getR
tnestedtmocktpatchtobjectRtcindertcompute_apitAPIRt
ComputeAPIR	tCinderAPIVersionNotAvailabletside_effectRRóR–tcalledR
tBlockDeviceMappingListR
Retreturn_valuet
api_deleteRL(R"RIRGtmock_cinder_mvtmock_reservetmock_attachtvolume_attachmentt
mock_checkt
mock_get_bdmstmock_rpct
attachment_id((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt(test_attach_detach_vol_to_shelved_server'sF















	













c
	Csø
|jd
dƒ

|j
ƒ}
|jd|
dƒ
|
d}|jdtjƒ
tjtj	j
tjdƒtj	j
t
jdƒtj	j
tjjd	ƒƒŠ\}}}tjd
dƒ
|_i
i
dd
6d6}|jjd||ƒjd}|j|jƒ

|j|jƒ

|j|dƒ

WdQXtjtj	j
tjjdƒtj	j
tjdƒtj	j
t
jdƒƒp\}}	}
|j|jƒ
|	_|	jdd}|jjd||fƒ

|j|jƒ

|j|
jƒ

WdQX|j|ƒ

dS(NRÁitSHELVED_OFFLOADEDR9R8snova.volume.cinder.API.getR
R
tattachR
s3.44s$5d721593-f033-4f6d-ab6f-b5b067e61bc4R 
R!
s!/servers/%s/os-volume_attachmentstdeviceR"
R#
t_local_cleanup_bdm_volumesR
s$/servers/%s/os-volume_attachments/%s(R…R
RPRwRR%
R
R&
R'
R(
R)
RR*
R+
R,
R	R.
R/
RRóRôR–R0
RÕR
R1
R
ReR2
R3
RL(R"RIRGR4
R5
tmock_volR7
tattach_responseR8
R9
tmock_clean_volsR;
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt2test_attach_detach_vol_to_shelved_offloaded_serverTsF














	















c
	Cs8|jd
dƒ

|j
ƒ}
|jd|
dƒ
|
d}|j|jƒ
}|jdtjƒ
tj	t
jjt
jdƒt
jjtjdƒt
jjt
jjd	ƒt
jjt
jjd
ƒt
jjt
jjdƒƒ”\}}}}}i
tj
d6|_i
i
dd
6d6}	|jjd||	ƒjd}
|j|jƒ

|jt
jtj
ƒ
|j|
dƒ

WdQXtj	t
jjt
jjdƒt
jjtjdƒt
jjtjdƒƒd\}}}
||_|jdd}|jjd||fƒ

|j|jƒ

|j|
jƒ

WdQX|j|ƒ

dS(NRÁiR=
R9R8snova.volume.cinder.API.getR
t*_check_volume_already_attached_to_instancetcheck_availability_zonetattachment_createtattachment_completes$5d721593-f033-4f6d-ab6f-b5b067e61bc4R 
R!
s!/servers/%s/os-volume_attachmentsR?
R"
R#
R@
R
s$/servers/%s/os-volume_attachments/%s(R…R
RPR
ReRwRR%
R
R&
R'
R(
R)
RR*
R+
R,
tuuidsR2
RRóRôR–R0
tassert_called_once_withtANYRÕR
R1
R3
RL(R"RIRGt	fake_bdmsR4
tmock_check_vol_attachedtmock_check_av_zonetmock_attach_createtmock_attachment_completeR7
RB
R8
R9
RC
R;
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt;test_attach_detach_vol_to_shelved_offloaded_server_new_flow€sV
















	





	











	




(
R&R'RRR5R÷R
R
R<
RD
RQ
(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR
	s
					-	,tServerRebuildTestCasecBsPeZ
dZd
Zd„Zd„Zejddejƒ

d„ƒ
Z	d„Z
RS(sv2.1s2.38cCsH|jj
|
d
ƒ
}
|
d}|jjjdi|d6dd6ƒ
dS(NR8sOS-EXT-SRV-ATTR:hosttdisableR!snova-computetbinary(RR;tapi_fixturet	admin_apitput_service(R"R>R!((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_disable_compute_for»s





c
CsÎ
tj
d
g
ƒ

|jtjƒ

|jdd
ƒ

|jddd
ƒ

|_d}
i
i|
d6dd6dd	6d
d6d6}|jj|ƒ
}|j	|j|d
ƒ
|j
|ƒ

tjj
jjj}|jj|ddƒ
i
i
|d6d6}|jjd|d|ddg
ƒ

|j|tjd|jjƒ
|jj|dƒ
}|j|
|ddƒ
|jd|dƒ
|jd|ddƒ
|jtj|jjd|d|ƒ}|jdtj|ƒ
ƒ
dS(sz
Creates a server with an image that is valid for the single compute
        that we have. Then rebuilds the server, passing in an image with
        metadata that does not fit the single compute which should result in
        a NoValidHost error. The ImagePropertiesFilter filter is enabled by
        default so that should filter out the host based on the image meta.
        RR!Rgs$155d900f-4e14-4e4c-a73d-069cbf4541e6R,RéR-t#test_rebuild_with_image_novalidhostRŽtnonetnetworksR>Rthw_architecturet	unicore32RÌs/servers/%s/actionR8tcheck_response_statusiô
trebuild_serverR‘RvR9s
No valid hosttfaulttmessagetNoValidHostN(RR‚RƒR„R…R7R}RRyRARX
tnovatteststunitR‘t#AUTO_DISK_CONFIG_ENABLED_IMAGE_UUIDtput_image_meta_keyRót _wait_for_action_fail_completionRtREBUILDRU
RV
R;RPR—R“RR”tsixt	text_type(R"toriginal_image_reftserver_req_bodyR>trebuild_image_reftrebuild_req_bodyR¸((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRY
ÅsB










	



	







s;nova.compute.resource_tracker.ResourceTracker.rebuild_claimtnew_callablecs@ˆ
jj
‰d
ˆ_‡f
d†}‡
f
d†}‡
f
d†}‡
f
d†}‡
f
d†}ˆ
jjjdƒ
}||ƒ
}||ƒ
}	ˆ
jidd6dd	6dd
6|	ƒ
i
idd6d
d6dd6dd6d6}
ˆ
jj	|
ƒ
}ˆ
j
ˆ
j|dƒ
ˆ
jjdƒ
jd}||di
dd6ƒ
||ƒ
}	|||	ƒ
||dƒ
}
ˆ
j
||
ƒ
|
|d}
|||
ƒ
tjjjjj}i
i
|d6d6}ˆ
jjd|d|ƒ
ˆ
jˆ
j|i
dd6ƒ
||ƒ
}	|||	ƒ
||dƒ
}
ˆ
j
||
ƒ
|
|d}
|||
ƒ
dS(sQ
Rebuilds a server with a different image which will run it through
        the scheduler to validate the image is still OK with the compute host
        that the instance is running on.

        Validates that additional resources are not allocated against the
        instance.host in Placement due to the rebuild on same host.
        s2.53c
s&ˆjd
|ƒ
j
}
|
dddS(Ns-os-hypervisors?hypervisor_hostname_pattern=%sthypervisorsiR8(R
Rô(R!tresp(
RV
(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_provider_uuid_by_host!s


c

sˆjj
d
|ƒ
jdS(Ns/resource_providers/%s/usagestusages(t
placement_apiR Rô(
t
provider_uuid(
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_provider_usages&s
	
c

sˆjj
d
|ƒ
jdS(Ns/allocations/%stallocations(Ru
R Rô(
tserver_uuid(
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_allocations_by_server_uuid*s
	
csGˆjj
d
|ƒ
j}|d|d<ˆjjd||
f|ƒjS(Ns/resource_providers/%st
generationtresource_provider_generations%/resource_providers/%s/inventories/%s(Ru
R Rôtput(trp_uuidtresource_classt	inventorytrp(
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_set_provider_inventory.s	


	

csLˆj|d
|
dƒ
ˆj|d|
dƒ
ˆj|d|
dƒ
dS(NtvcpustVCPURît	MEMORY_MBtdisktDISK_GB(
RP(R’t
allocation(
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytassertFlavorMatchesAllocation7s


iR„
R…
R‡
s$155d900f-4e14-4e4c-a73d-069cbf4541e6R,RéR-ttest_rebuild_with_new_imageRŽRZ
R[
R>Rs
/flavors/1R’i
ttotalR8t	resourcesRÌs/servers/%s/actionsOS-EXT-STS:task_stateN(RU
RV
R	
RgRt
_get_nodenameRCRPRRyRAR
RôR—Rc
Rd
Re
R‘RRf
Rót_wait_for_server_parameter(R"tmock_rebuild_claimRs
Rw
Rz
R‚
R‰
tnodenameR~
t	rp_usagesRm
R>R’tallocsRn
Ro
((RV
R"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRŠ
sR

		

%




















c
Cs
|jt
j|ƒ
ƒ

i
id
d6dd6dd6idd6t
jjd	6d
d6d
d6g
d
6d6}
|jj|
ƒ
}|j|j|dƒ}|jd|dƒ
tj	j
jjj
}i
i
|d6d6}|jjd|d|ddg
ƒ
}|jdtj|ƒ
ƒ
dS(s½Tests that trying to rebuild a volume-backed instance with a
        different image than what is in the root disk of the root volume
        will result in a 400 BadRequest error.
        RéR-t*test_volume_backed_rebuild_different_imageRŽRZ
R[
it
boot_indextuuidRR
R
tblock_device_mapping_v2R>RRoR‘R,RÌs/servers/%s/actionR8R^
i
sCUnable to rebuild with a different image for a volume-backed serverN(t
useFixturet
nova_fixturestCinderFixtureNewAttachFlowtIMAGE_BACKED_VOLRRyRARPRc
Rd
Re
R‘RRf
RóR—Rj
Rk
(R"Rm
R>Rn
Ro
Rr
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR“
ts,











	
(R&R'RRR	
RX
RY
R'
R(
tNonCallableMockRŠ
R“
(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRR
´s	
	O
_tProviderUsageBaseTestCasec
Bs¤eZ
dZd
Zd„Zd„Zd„Zd„Zd„Zd„Z	d„Z
d	„Zd
„Zd„Z
d„Zd
„Zd„Zd„Zd„Zd„ZRS(sp
Base test class for functional tests that check provider usage
    and consumer allocations in Placement during various operations.

    Subclasses must define a **compute_driver** attribute for the virt driver
    to use.

    This class sets up standard fixtures and controller services but does not
    start any compute services, that is left to the subclass.
    tlatestc
Cs3
|jd
|j
ƒ

tt|ƒjƒ
|jtjƒƒ

|jtj	|ƒ
ƒ

|jtj
ƒƒ

|jtjƒƒ
}
|
j|_
|jtjddƒ
ƒ
}|j|_|j|j_|j|_tjjjjj|ƒ

|jdƒ

|jdƒ
|_|jtjjjjjƒ

tj|ƒ

i|_dS(Ntcompute_drivertapi_versionsv2.1R2RŠ(R…Rž
R4Rœ
R5R—
RtRealPolicyFixtureR˜
tNeutronFixturetAllServicesCurrenttPlacementFixtureRRu
tOSAPIFixtureRV
R	
Rc
Rd
Re
R‘Rtstub_out_image_serviceR7tscheduler_serviceRƒtFakeImageService_resetRR6R3(R"t	placementRU
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5±s$












cCsFtj
|
g
ƒ

|jtjƒ

|jd
d|
ƒ

}||j|
<|S(sØStart a nova compute service on the given host

        :param host: the name of the host that will be associated to the
                     compute service.
        :return: the nova compute service object
        RgR!(RR‚RƒR„R7R3(R"R!Rg((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_start_computeÍs





cCs)|jj
d
|
ƒ
j}|dddS(Ns-os-hypervisors?hypervisor_hostname_pattern=%sRq
iR8(RV
R
Rô(R"R!Rr
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRs
Ús	

cCs|jj
d
|
ƒ
jdS(Ns/resource_providers/%s/usagesRt
(Ru
R Rô(R"Rv
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRw
ás
	
cCs|jj
d
|
ƒ
jdS(Ns/allocations/%sRx
(Ru
R Rô(R"Ry
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRz
ås
	
c

Cs|jj
d
ddƒ

jdS(Ns/traitsR
s1.6ttraits(Ru
R Rô(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_traitsés
c

Cs|jj
d
ƒ
jdS(Ns/resource_providerstresource_providers(Ru
R Rô(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_all_providersìs
	
cCs!|jj
d
|
ddƒ

jdS(Ns/resource_providers/%s/traitsR
s1.6Rª
(Ru
R Rô(R"Rv
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_provider_traitsðs
	


cCsN|jj
d
|
ƒ
j}i|dd6|d6}|jjd|
|ddƒ
S(sìThis will overwrite any existing traits.

        :param rp_uuid: UUID of the resource provider to update
        :param traits: list of trait strings to set on the provider
        :returns: APIResponse object with the results
        s/resource_providers/%sR{
R|
Rª
s/resource_providers/%s/traitsR
s1.6(Ru
R RôR}
(R"R~
Rª
tprovidertput_traits_req((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_set_provider_traitsõs	




	

cCs|jj
d
|
ƒ
jdS(Ns"/resource_providers/%s/inventoriestinventories(Ru
R Rô(R"R~
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_provider_inventorys
	
cCsL|j|
d
|dƒ
|j|
d|dƒ
|j|
d|dƒ
dS(NRƒ
R„
RîR…
R†
R‡
(
RP(R"R’Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR‰

s


cCsd|j|
d
|d
|dƒ
|j|
d|d|dƒ
|j|
d|d|dƒ
dS(NRƒ
R„
RîR…
R†
R‡
(
RP(R"t
old_flavort
new_flavorRˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytassertFlavorsMatchAllocations





cCsStj
ƒ}tj|i
|
d
6ƒ}|jdt|ƒ
dt|ƒ
ƒ
|djS(NRpi
s.Test expected a single migration, but found %ii(RRbRtmigration_get_all_by_filtersRPR†R•
(R"RpRet
migrations((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytget_migration_uuid_for_instances





c
	Csu|j|j
d
d|
ddddgƒ}d||d<tjd	|ƒ
|j
ji
|d
6ƒ
}|j|j|dƒ}|j||dƒ
|j|ƒ
}|j	|ƒ
}|j
|
|ƒ
xygt|jj
ƒƒ
D]!}||krÕ|j|ƒ
^qÕD]:}	|j	|	ƒ
}
|jid
d6d
d6d
d6|
ƒ
qúW|j|dƒ
}|jdt|ƒ
dƒ
||d}|j
|
|ƒ
|jƒ
|j	|ƒ
}|j
|
|ƒ
|j|dƒ
}|jdt|ƒ
dƒ
||d}|j
|
|ƒ
xygt|jj
ƒƒ
D]!}||kr|j|ƒ
^qD]:}	|j	|	ƒ
}
|jid
d6d
d6d
d6|
ƒ
q3W|S(sBoot an instance and check that the resource allocation is correct

        After booting an instance on the given host with a given flavor it
        asserts that both the providers usages and resource allocations match
        with the resources requested in the flavor. It also asserts that
        running the periodic update_available_resource call does not change the
        resource state.

        :param flavor: the flavor the instance will be booted with
        :param source_hostname: the name of the host the instance will be
                                booted on
        :return: the API representation of the booted instance
        ssome-servert	flavor_idR8t
image_uuids$155d900f-4e14-4e4c-a73d-069cbf4541e6R[
snova:%stavailability_zones
booting on %sR>RsOS-EXT-SRV-ATTR:hostiR„
R…
R‡
i
s8No allocation for the server on the host it is booted onRŒ
(RxRRDRjRyRARV
RPRs
Rw
R‰
RhR3tkeysRz
R†Rm(
R"R’tsource_hostnameR

RzR>tsource_rp_uuidt
source_usagesthostnameR~
Rt
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_boot_and_check_allocations$sR


	







%













%




cCsË|jj
|
d
ƒ

|j|
ƒ

tjdƒ

xmgt|jjƒƒ
D]}|j|ƒ
^qGD]:}|j	|ƒ
}|j
idd6dd6dd6|ƒ
q`W|j|
d
ƒ
}|j
dt|ƒ
ƒ
dS(s–Delete the instance and asserts that the allocations are cleaned

        :param server: The API representation of the instance to be deleted
        R8sinstance.delete.endiR„
R…
R‡
N(
RRKt_wait_until_deletedRt wait_for_versioned_notificationsRhR3R½
Rs
Rw
RPRz
R†(R"R>RÁ
R~
Rt
Rx
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_delete_and_check_allocationsus



2




c
Csctj
ƒ}
xCt|jjƒƒ
D],}tjd
|jjƒ
|jj	|
ƒ

q"Wtjdƒ

dS(sØRun the update_available_resource task on every compute manager

        This runs periodics on the computes in an undefined order; some child
        class redefined this function to force a specific order.
        s!Running periodic for compute (%s)sFinished with periodicsN(
RRbRhR3RiRDRjRR!Rk(R"RlRg((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRms

	



(R&R'R(R	
R5R©
Rs
Rw
Rz
R«
R­
R®
R±
R³
R‰
R¶
R¹
RÂ
RÅ
Rm(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRœ
£s$
		
											
	Q	tTraitsTrackingTestscBs/eZ
dZejjejd
ƒd„ƒ
ZRS(sfake.SmallFakeDrivert
get_traitscCsžd
dg}||
_|j
d
|jƒƒ
|jg|jƒƒ
|jddƒ
|_|jdƒ
}|j|t|j	|ƒ
ƒ
ƒ
|j
d
|jƒƒ
dS(Nt
CUSTOM_FOOtHW_CPU_X86_VMXR!R(R2
RÔR«
RPR­
R©
RgRs
RŒR®
R—(R"tmock_traitsRª
R~
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resource_provider_traits¡s
	


(	R&R'Rž
R'
R(
R)
RtSmallFakeDriverRË
(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRÆ
žs
tServerMovingTestscBs
eZ
dZeZd
Zd„Zd„Zd„Zd„Z	d„Z
d„Zd„Zd	„Z
d
„Zd„Zd„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Ze j!dde"j#dƒ
ƒ

d„ƒ
Z$d „Z%d!„Z&d"„Z'd#„Z(d$„Z)d)d%„
Z+d&„Z,d'„Z-d(„Z.RS(*sL
Tests moving servers while checking the resource allocations and usages

    These tests use two compute hosts. Boot a server on one of them then try to
    move the server to the other. At every step resource allocation of the
    server and the resource usages of the computes are queried from placement
    API and asserted.
    sfake.MediumFakeDriverc
Csètt
|ƒjƒ
tj|ƒ

|jtjƒ

|jd
dƒ
|_|jd
dƒ
|_	|j
jƒ}
|
d|_|
d|_
i
idd6t|j
dd	ƒ
d6dd
6|j
dd	d6dd
6d6}|j
j|ƒ
|_dS(NR!RRii
ttest_flavor3RŽRîiRƒ
R†
s$a22d5517-147c-4147-a0d1-e698df5cd4e3R8R’(R4RÍ
R5Rt
stub_notifierRƒtresetR©
tcompute1R}Rtget_flavorstflavor1tflavor2R]tpost_flavortflavor3(R"tflavorstflavor_body((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5¿s














cCsid
d6dd
6}||
S(NRR((R"R!t
other_host((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_other_hostnameÕs




c
Csutj
ƒ}
tjd
|jjjƒ
|jjj|
ƒ

tjd|jjjƒ
|jjj|
ƒ

tjdƒ

dS(Ns"Running periodic for compute1 (%s)s"Running periodic for compute2 (%s)sFinished with periodics(	RRbRDRjRÑ
RR!RkR}(R"Rl((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRmÚs
	


	


c

Cs|jd
dƒ

dS(Nt
dest_hostnameR(
t_test_resize_revert(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_revertës
c

Cs|jd
dƒ

dS(NRÛ
R(
RÜ
(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_revert_reverseîs
c

Cs|jd
dƒ

dS(NRÛ
R(
t_test_resize_confirm(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_confirmñs
c

Cs|jd
dƒ

dS(NRÛ
R(
Rß
(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_confirm_reverseôs
cCsí
|jd
t
ƒ

i
i
|dd6d6}|jj|
d|ƒ
|j|j|
dƒ
|j|ƒ
}|j||ƒ
|j|ƒ
}|j||ƒ
|j|
dƒ
}	|jdt	|	ƒ
ƒ
|	|d}
|j||
ƒ
|j
|
dƒ
}|j|ƒ
}	|	|d}|j||ƒ
|jƒ
|j|ƒ
}|j||ƒ
|j|ƒ
}|j||ƒ
|j|
dƒ
}	|jdt	|	ƒ
ƒ
|	|d}
|j||
ƒ
|j
|
dƒ
}|j|ƒ
}	|	|d}|j||ƒ
dS(NRãR8R-RæRèi
RŒ
(R…R¼RR«RARw
R‰
Rz
RPR†R¹
Rm(R"R>R´
Rµ
R¿
tdest_rp_uuidt
resize_reqRÀ
tdest_usagesRx
t
dest_alloctmigration_uuidtsource_alloctdest_allocation((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_resize_and_check_allocations÷s>





















cCs]
|j|
ƒ
}|j
|ƒ
}|j
|
ƒ
}|j|j|ƒ}|j||j|j||ƒ
i
dd
6}|jj|d|ƒ
|j	|j|dƒ
|j
ƒ
|j|ƒ
}|j|dƒ
}|j
|j|ƒ
|j|ƒ
}	|jidd6dd6dd6|	d|
ƒ
|jd	t|ƒ
ƒ
||d
}
|j
|j|
ƒ
|j|ƒ

dS(NRáR8RiR„
R…
R‡
sATarget host %s still has usage after the resize has been revertedi
RŒ
(RÚ
Rs
RÂ
RÓ
Ré
RÔ
RCRR«RARmRw
Rz
R‰
RPR†RÅ
(R"RÛ
R¾
R¿
Râ
R>RšRÀ
Rx
Rä
tsource_allocation((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRÜ
3s0



	














cCs |j|
ƒ
}|j
|ƒ
}|j
|
ƒ
}|j|j|ƒ}|j||j|j||ƒ
i
dd
6}|jj|d|ddg
ƒ

|j	|j|dƒ
|j
|dƒ
}|jdt|ƒ
ƒ
|j
|ƒ
}|j
|ƒ
}	|j|j|	ƒ
|jidd6dd	6dd
6|d|ƒ
|j|j|	ƒ
||d}
|j|j|
ƒ
|jƒ
|j
|ƒ
}	|j
|ƒ
}|j|j|	ƒ
|jidd6dd	6dd
6|d|ƒ
|j
|dƒ
}|jdt|ƒ
ƒ
||d}
|j|j|
ƒ
|j|ƒ

dS(
NRëR8R^
iÌRi
iR„
R…
R‡
sGThe source host %s still has usages after the resize has been confirmedRŒ
(RÚ
Rs
RÂ
RÓ
Ré
RÔ
RCRR«RARz
RPR†Rw
R‰
RmRÅ
(R"RÛ
R¾
R¿
Râ
R>RšRx
RÀ
Rä
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRß
YsL



	



	


















c
CsÎ
|jd
t
ƒ

i
i
|dd6d6}|jj|
d|ƒ
|j|j|
dƒ
|j|ƒ
}|j|||ƒ
|j|
dƒ
}|jdt	|ƒ
ƒ
||d}|j
||ƒ
|j|
dƒ
}	|j|	ƒ
}|jdt	|ƒ
ƒ
||d}|j
||ƒ
|jƒ
|j|ƒ
}|j|||ƒ
|j|
dƒ
}|jdt	|ƒ
ƒ
||d}|j
||ƒ
|j|	ƒ
}|jdt	|ƒ
ƒ
||d}|j
||ƒ
dS(NRãR8R-RæRèi
RŒ
(
R…R˜RR«RARw
R¶
Rz
RPR†R‰
R¹
Rm(
R"R>R´
Rµ
R~
Rã
Rt
Rx
Rˆ
Ræ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt*_resize_to_same_host_and_check_allocations›s8


















c
	CsS
|jj
d
|jjddƒdd}
|jj|
i
dd6ƒ
|jjj}|j|ƒ
}|j|j	|ƒ}|j
||j	|j|ƒ
i
dd6}|j
j|d|ƒ
|j|j
|d	ƒ
|jƒ
|j|ƒ
}|j|j	|ƒ
|j|dƒ
}|jd
t|ƒ
ƒ
||d}|j|j	|ƒ
|j|ƒ

dS(NR!RT
snova-computeiR8tdisabledR9RáRi
RŒ
(RV
tget_servicesR}R!RW
RÑ
RRs
RÂ
RÔ
Rë
RÖ
RCRR«RARmRw
R‰
Rz
RPR†RÅ
(	R"tcompute2_service_idRÁ
R~
R>RšRt
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_revert_same_hostÐs&











c
	Cs\
|jj
d
|jjddƒdd}
|jj|
i
dd6ƒ
|jjj}|j|ƒ
}|j|j	|ƒ}|j
||j	|j|ƒ
i
dd6}|j
j|d|d	d
g
ƒ

|j|j
|dƒ
|jƒ
|j|ƒ
}|j|j|ƒ
|j|dƒ
}|jdt|ƒ
ƒ
||d
}|j|j|ƒ
|j|ƒ

dS(NR!RT
snova-computeiR8Rì
R9RëR^
iÌRi
RŒ
(RV
Rí
R}R!RW
RÑ
RRs
RÂ
RÔ
Rë
RÖ
RCRR«RARmRw
R‰
Rz
RPR†RÅ
(	R"Rî
RÁ
R~
R>RšRt
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_confirm_same_hostðs(





	






c
CsÐ
i
id
d6dd6tj
jdd6dd6d	6}
|jj|
ƒ
}|jj}|j|ƒ
}|j|ƒ
}|j|ƒ
}|j	|j
|ƒ}|jd
tƒ

i
i
|dd6d
6}|jj
|d|ddg
ƒ
}	|j|	dddƒ
|jj|dƒ
}|j||dƒ
|j|ƒ
}
|j|j
|
ƒ
|j|ƒ
}|jidd6dd6dd6|ƒ
|j|dƒ
}|jdt|ƒ
ƒ
||d}
|j|j
|
ƒ
|j|ƒ

dS(Nttest_too_big_flavorRŽiRîi
Rƒ
iR†
R’RãR8R-RæR^
i
t
badRequestRa
s7No valid host was found. No valid host found for resizesOS-EXT-SRV-ATTR:hostiR„
R…
R‡
RŒ
(RtMediumFakeDriverRƒ
RRÕ
R}R!RÚ
Rs
RÂ
RÓ
R…R¼R«RPRV
R;Rw
R‰
Rz
R†RÅ
(R"RØ
t
big_flavorRÛ
R¾
R¿
Râ
R>Rã
Rr
RÀ
Rä
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_resize_not_enough_resourcesD











	












c
Cso|jj
}
|jj
}|j|j|
ƒ}|jjd
|
ddƒdd}|jjƒ
|jj|i
dd6ƒ
i
id6}|j	j
|d|ƒ
i|d	6d
d6}|j|j	||ƒ}|j|
ƒ
}|j|ƒ
}|j
|ƒ
}	|j|j|	ƒ
|j
|ƒ
}
|j|j|
ƒ
|j|dƒ
}|jdt|ƒ
ƒ
||d
}|j|j|ƒ
||d
}
|j|j|
ƒ
|j|jƒ

|jj|i
dd6ƒ
|j
|ƒ
}	|jidd6dd6dd6|	ƒ
|j
|ƒ
}
|j|j|
ƒ
|j|dƒ
}|jdt|ƒ
ƒ
||d
}
|j|j|
ƒ
|j|ƒ

dS(NR!RT
snova-computeiR8ttruetforced_downtevacuatesOS-EXT-SRV-ATTR:hostRR9iRŒ
tfalseR„
R…
R‡
i
(RÑ
R!R}RÂ
RÓ
RV
Rí
tstopRW
RR«RŽ
Rs
Rw
R‰
Rz
RPR†trestart_compute_serviceRÅ
(R"R¾
RÛ
R>tsource_compute_idRštexpected_paramsR¿
Râ
RÀ
Rä
Rx
Rê
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt
test_evacuateHsV




	


	






	







	








c
Cs‘|jj
}
|jj
}|j|j|
ƒ}|jjd
|
ddƒdd}|jjƒ
|jj|i
dd6ƒ
i
i|d
6t	d6d	6}|j
j|d|ƒ
i|d
6dd6}|j|j
||ƒ}|j
ƒ
|j|
ƒ
}|j|ƒ
}|j|ƒ
}	|j|j|	ƒ
|j|ƒ
}
|j|j|
ƒ
|j|dƒ
}|jd
t|ƒ
ƒ
||d}|j|j|ƒ
||d}
|j|j|
ƒ
|j|jƒ

|jj|i
dd6ƒ
|j
ƒ
|j|ƒ
}	|jidd6dd6dd6|	ƒ
|j|ƒ
}
|j|j|
ƒ
|j|dƒ
}|jdt|ƒ
ƒ
||d}
|j|j|
ƒ
|j|ƒ

dS(s#
Evacuating a server with a forced host bypasses the scheduler
        which means conductor has to create the allocations against the
        destination node. This test recreates the scenarios and asserts
        the allocations on the source and destination nodes are as expected.
        R!RT
snova-computeiR8Rö
R÷
tforceRø
sOS-EXT-SRV-ATTR:hostRR9iRŒ
Rù
R„
R…
R‡
i
N(RÑ
R!R}RÂ
RÓ
RV
Rí
Rú
RW
R˜RR«RŽ
RmRs
Rw
R‰
Rz
RPR†Rû
RÅ
(R"R¾
RÛ
R>Rü
RšRý
R¿
Râ
RÀ
Rä
Rx
Rê
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_evacuate_forced_hostˆsZ



	









	









	







c
	sDˆ
jj
}
ˆ
jj
}ˆ
j|ƒ
‰ˆ
jˆ
j|
ƒ}ˆ
jjd
|
ddƒdd}ˆ
jjƒ
ˆ
jj	|i
dd6ƒ
‡‡
fd†}t
jd	|ƒ;
ˆ
jj
|di
id
6ƒ
ˆ
jˆ
j|dƒ}WdQXˆ
jƒ
ˆ
j|
ƒ
}ˆ
j|ƒ
}ˆ
jˆ
j|ƒ
ˆ
jˆƒ
}ˆ
jidd
6dd6dd6|ƒ
ˆ
j|dƒ
}	ˆ
jdt|	ƒ
ƒ
|	|d}
ˆ
jˆ
j|
ƒ
ˆ
jˆ
jƒ

ˆ
jj	|i
dd6ƒ
ˆ
jƒ
ˆ
j|ƒ
}ˆ
jˆ
j|ƒ
ˆ
j|dƒ
}	ˆ
jdt|	ƒ
ƒ
|	|d}
ˆ
jˆ
j|
ƒ
dS(s“Tests that the allocations on the destination node are cleaned up
        when the rebuild move claim fails due to insufficient resources.
        R!RT
snova-computeiR8Rö
R÷
cs8ˆ
jˆƒ
}ˆ
j
ˆ
j|ƒ
tjd
dƒ
‚
dS(NRnt!test_evacuate_claim_on_dest_fails(Rw
R‰
RÓ
R	tComputeResourcesUnavailable(RrRsRä
(Râ
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytfake_move_claimós

	
snova.compute.claims.MoveClaimRø
RvNRƒ
RîR†
i
RŒ
Rù
(RÑ
R!R}Rs
RÂ
RÓ
RV
Rí
Rú
RW
R'
R(
RR«RARmRw
R‰
Rz
RPR†Rû
(R"R¾
RÛ
R>Rü
RR¿
RÀ
Rä
Rx
Rê
((Râ
R"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR
ÙsF




	
	







	





c
	sPˆ
jj
}
ˆ
jj
}ˆ
j|ƒ
‰ˆ
jˆ
j|
ƒ}ˆ
jjd
|
ddƒdd}ˆ
jjƒ
ˆ
jj	|i
dd6ƒ
‡‡
fd†}t
jjˆ
jj
d	|ƒ;
ˆ
jj|di
id
6ƒ
ˆ
jˆ
j|dƒ}WdQXˆ
jƒ
ˆ
j|
ƒ
}ˆ
j|ƒ
}ˆ
jˆ
j|ƒ
ˆ
jˆƒ
}ˆ
jidd
6dd6dd6|ƒ
ˆ
j|dƒ
}	ˆ
jdt|	ƒ
ƒ
|	|d}
ˆ
jˆ
j|
ƒ
ˆ
jˆ
jƒ

ˆ
jj	|i
dd6ƒ
ˆ
jƒ
ˆ
j|ƒ
}ˆ
jˆ
j|ƒ
ˆ
j|dƒ
}	ˆ
jdt|	ƒ
ƒ
|	|d}
ˆ
jˆ
j|
ƒ
dS(s­Tests that the allocations on the destination node are cleaned up
        automatically when the claim is made but the actual rebuild
        via the driver fails.

        R!RT
snova-computeiR8Rö
R÷
cs5ˆ
jˆƒ
}ˆ
j
ˆ
j|ƒ
tjd
ƒ
‚
dS(Nt#test_evacuate_rebuild_on_dest_fails(Rw
R‰
RÓ
R
R€(RrRsRä
(Râ
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytfake_rebuild<	s

RÌRø
RvNRƒ
RîR†
i
RŒ
Rù
(RÑ
R!R}Rs
RÂ
RÓ
RV
Rí
Rú
RW
R'
R(
R)
tdriverRR«RARmRw
R‰
Rz
RPR†Rû
(R"R¾
RÛ
R>Rü
RR¿
RÀ
Rä
Rx
Rê
((Râ
R"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR'	sH




	
	








	





cCsÏ|jd
dƒ

|j
|j|
ƒ}i
id6}|jj|d|ƒ
|j|j|dƒ
|j|ƒ
}|j|j|ƒ
|j|dƒ
}|j	dt
|ƒ
ƒ
||d}|j|j|ƒ
|S(NRÁiÿÿÿÿRÂR8RÃi
RŒ
(R…RÂ
RÓ
RR«RARw
R‰
Rz
RPR†(R"RÁ
R~
R>treqRÀ
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt'_boot_then_shelve_and_check_allocationsp	s










c
Csä|jj
}
|j|
ƒ
}|j|
|ƒ}i
id
6}|jj|d|ƒ
|j|j|dƒ
|j|ƒ
}|j|j	|ƒ
|j
|dƒ
}|jdt|ƒ
ƒ
||d}|j|j	|ƒ
|j
|ƒ

dS(NtunshelveR8Ri
RŒ
(RÑ
R!Rs
RRR«RARw
R‰
RÓ
Rz
RPR†RÅ
(R"R¾
R¿
R>RRÀ
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_shelve_unshelve†	s










cCs©i
id
6}|jj
|
d|ƒ
|j|j|
idd6dd6ƒ
|j|ƒ
}|jidd6dd6dd	6|ƒ
|j|
dƒ
}|jdt|ƒ
ƒ
dS(
Nt
shelveOffloadR8R=
R9sOS-EXT-SRV-ATTR:hostiR„
R…
R‡
(RR«RŽ
RCRw
RPRz
R†(R"R>R¿
RRÀ
Rx
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt%_shelve_offload_and_check_allocationsŸ	s











c
Cse
|jj
}
|j|
ƒ
}|j|
|ƒ}|j||ƒ
|jjd
|
ddƒdd}|jj|i
dd6ƒ
i
id6}|jj	|d|ƒ
|j
|j|d	ƒ}|d
}|j||j|
ƒ
ƒ
|j|ƒ
}|j
|ƒ
}|j|j|ƒ
|j|dƒ
}	|jdt|	ƒ
ƒ
|	|d}
|j|j|
ƒ
|j|ƒ

dS(
NR!RT
snova-computeiR8Rì
R9R	RsOS-EXT-SRV-ATTR:hosti
RŒ
(RÑ
R!Rs
RRRV
Rí
RW
RR«RARPRÚ
Rw
R‰
RÓ
Rz
R†RÅ
(R"R¾
R¿
R>tsource_service_idRtcurrent_hostnametcurrent_rp_uuidtcurrent_usagesRx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt&test_shelve_offload_unshelve_diff_host°	s.

















c
Cse
|jj
}
|j|
ƒ
}|j|
|ƒ}|j||ƒ
|jjd
|j|
ƒ
ddƒdd}|jj|i
dd6ƒ
i
id6}|j	j
|d|ƒ
|j|j	|d	ƒ}|d
}|j||
ƒ
|j|ƒ
}|j
|ƒ
}|j|j|ƒ
|j|dƒ
}	|jdt|	ƒ
ƒ
|	|d}
|j|j|
ƒ
|j|ƒ

dS(
NR!RT
snova-computeiR8Rì
R9R	RsOS-EXT-SRV-ATTR:hosti
RŒ
(RÑ
R!Rs
RRRV
Rí
RÚ
RW
RR«RARPRw
R‰
RÓ
Rz
R†RÅ
(R"R¾
R¿
R>R
RRRRRx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt&test_shelve_offload_unshelve_same_hostÖ	s.
















c
Css
|jj
}
|jj
}|j|
ƒ
}|j|ƒ
}|j|j|
ƒ}i
i|d
6td6td6d6}|jj|d|ƒ
|j	|j|i|d6dd6ƒ
|j
ƒ
|j|ƒ
}|jid	d
6d	d6d	d6|ƒ
|j|ƒ
}|j|j|ƒ
|j
|dƒ
}	|jd
t|	ƒ
ƒ
|j||	ƒ
|	|d}
|j|j|
ƒ
|j|ƒ

dS(NR!tblock_migrationRÿ
sos-migrateLiveR8sOS-EXT-SRV-ATTR:hostRR9iRîR†
Rƒ
i
RŒ
(RÑ
R!R}Rs
RÂ
RÓ
R˜RR«RŽ
RmRw
R‰
Rz
RPR†RÔRÅ
(R"R¾
RÛ
R¿
Râ
R>RšRÀ
Rä
Rx
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_live_migrate_forceü	s6



















c
Csl
|jj
}
|jj
}|j|
ƒ
}|j|ƒ
}|j|j|
ƒ}i
i|d
6td6d6}|jj|d|ƒ
|j	|j|i|d6dd6ƒ
|j
ƒ
|j|ƒ
}|jidd	6dd
6dd6|ƒ
|j|ƒ
}|j|j|ƒ
|j
|dƒ
}	|jdt|	ƒ
ƒ
|j||	ƒ
|	|d
}
|j|j|
ƒ
|j|ƒ

dS(NR!Rsos-migrateLiveR8sOS-EXT-SRV-ATTR:hostRR9iRîR†
Rƒ
i
RŒ
(RÑ
R!R}Rs
RÂ
RÓ
R˜RR«RŽ
RmRw
R‰
Rz
RPR†RÔRÅ
(R"R¾
RÛ
R¿
Râ
R>RšRÀ
Rä
Rx
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_live_migrate$
s4



















c
s¿
d	ˆ_
ˆjj}
ˆjj}ˆj|
ƒ
}ˆj|ƒ
}ˆjˆj|
ƒ}tt‡f
d
†}t	j
dd|ƒ

L
i
i|d6td6d6}ˆjj
|d|ƒ
ˆj|dg
ƒ}Wd	QXˆj|
|d
ƒ
ˆj|dƒ

ˆj|ˆj
ƒ
ˆj|ƒ
}	ˆjˆj|	ƒ
ˆj|ƒ
}
ˆjidd
6dd6dd6|
ƒ
ˆj|dƒ
}ˆjdt|ƒ
ƒ
ˆj||ƒ
ˆjˆj||dƒ
ˆj|ƒ

d	S(sÚ
Tests the case that the LiveMigrationTask in conductor has
        called the scheduler which picked a host and created allocations
        against it in Placement, but then when the conductor task calls
        check_can_live_migrate_destination on the destination compute it
        fails. The allocations on the destination compute node should be
        cleaned up before the conductor task asks the scheduler for another
        host to try the live migration.
        cs#|d
ˆ_t
jddƒ
‚
dS(NR!Rnt!test_live_migrate_pre_check_fails(tfailed_hostnameR	tMigrationPreCheckError(Rtinstancetsrc_compute_infotdst_compute_infoRtdisk_over_commit(
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt'fake_check_can_live_migrate_destination\
s

	
s<nova.virt.fake.FakeDriver.check_can_live_migrate_destinationR/
R!Rsos-migrateLiveR8terrorNtsource_computetdest_computeiRƒ
RîR†
i
RŒ
(RCRRÑ
R!R}Rs
RÂ
RÓ
R¼R'
R(
R˜RR«t_wait_for_migration_statusRPRÕRw
R‰
Rz
R†R—RÅ
(R"R¾
RÛ
R¿
Râ
R>RRšt	migrationRÀ
Rä
Rx
((
R"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRJ
s<		














s,nova.virt.fake.FakeDriver.pre_live_migrationR/
t7test_live_migrate_rollback_cleans_dest_node_allocationscCs”
|jj
}|jj
}|j|ƒ
}|j|ƒ
}|j|j|ƒ}i
i|d
6td6d6}|jj|d|ƒ
|j	|dg
ƒ}|j
|j|i
dd6ƒ}|j||dƒ
|j||dƒ
|j
|ƒ
}	|j|j|	ƒ
|j
|ƒ
}
|jid	d
6d	d6d	d6|
ƒ
|j|dƒ
}|jd
t|ƒ
ƒ
|j||ƒ
|j|j||dƒ
|j|ƒ

dS(s0
Tests the case that when live migration fails, either during the
        call to pre_live_migration on the destination, or during the actual
        live migration in the virt driver, the allocations on the destination
        node are rolled back since the instance is still on the source node.
        R!Rsos-migrateLiveR8RsOS-EXT-STS:task_stateRR iRƒ
RîR†
i
RŒ
N(RÑ
R!R}Rs
RÂ
RÓ
R˜RR«R!RŽ
RCRPRw
R‰
Rz
R†R—RÅ
(R"tmock_pre_live_migrationR¾
RÛ
R¿
Râ
R>RšR"RÀ
Rä
Rx
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR#’
s6













c
s'
ˆjj
j‰ˆjˆjˆƒ‰
‡‡
‡fd
†}
ˆjd|
ƒ
ˆjjˆ
di
d
d6ƒ
ˆj	ˆ
t
jdƒ
ˆjˆƒ
}ˆj
|ƒ
}ˆj|ƒ
}ˆjidd6dd6dd	6|ƒ
ˆj
ˆƒ
}ˆj|ƒ
}ˆjˆj|ƒ
ˆjˆ
dƒ
}ˆj||ƒ
d
S(sÃTests that allocations are removed from the destination node by
        the compute service when a cold migrate / resize fails and a reschedule
        request is sent back to conductor.
        c	sوjˆƒ
}ˆj
|ƒ
}ˆj|ƒ
}ˆjˆj|ƒ
ˆjˆ
d
ƒ
}ˆj||ƒ
ˆj
ˆƒ
}ˆj|ƒ
}ˆjˆj|ƒ
ˆjˆ
d
ƒ
}ˆj|ƒ
}ˆj||ƒ
tj	dƒ
‚
dS(NR8sSimulated _prep_resize failure.(
RÚ
Rs
Rw
R‰
RÓ
Rz
R—R¹
R
R€(	RrRsRÛ
Râ
Rä
Rx
R¿
RÀ
Ræ
(R"R>R¾
(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytfake_prep_resizeÖ
s










s0nova.compute.manager.ComputeManager._prep_resizeR8tmigratetcompute_prep_resizeiRƒ
RîR†
N(RÑ
RR!RÂ
RÓ
RwRR«RCRh
RtMIGRATERÚ
Rs
Rw
R‰
Rz
R—(R"R%RÛ
Râ
t
failed_usagesR¿
RÀ
Rx
((R"R>R¾
sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt)test_rescheduling_when_migrating_instanceÍ
s&

	







c
s)
ˆ
jj
d
ˆ
jjddƒdd}ˆ
jj|i
dd6ƒ
ˆ
jjj}ˆ
j|ƒ
‰ˆ
jˆ
j	|ƒ}‡‡
fd†}ˆ
j
d	|
|ƒ
ˆ
jd
tƒ

i
i
ˆ
j
dd6d6}ˆ
jj|d|ƒ
ˆ
j|tj|ƒ
ˆ
j|ƒ
}ˆ
j|ƒ
}	ˆ
jˆ
j	|	ƒ
d
S(s‘Tests that when we resize to the same host and resize fails in
        the given method, we cleanup the allocations before rescheduling.
        R!RT
snova-computeiR8Rì
R9cs;ˆ
jˆƒ
}ˆ
j
ˆ
jˆ
j|ƒ
tjd
ƒ
‚
dS(NsSimulated resize failure.(Rw
R¶
RÓ
RÔ
R
R€(RrRsRt
(R~
R"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pytfake_resize_methods


s&nova.compute.manager.ComputeManager.%sRãR-RæN(RV
Rí
R}R!RW
RÑ
RRs
RÂ
RÓ
RwR…R˜RÔ
RR«Rh
RRçRw
R‰
(
R"tfailing_methodt
event_nameRî
RÁ
R>R+Rã
R¿
RÀ
((R~
R"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt(_test_resize_to_same_host_instance_failss(









c

Cs|jd
dƒ
dS(Nt_prep_resizeR'(
R.(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt*test_resize_to_same_host_prep_resize_fails-s

c

Cs|jd
dƒ
dS(Nt_resize_instancetcompute_resize_instance(
R.(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt-test_resize_instance_fails_allocation_cleanup1s

c

Cs|jd
dƒ
dS(Nt_finish_resizetcompute_finish_resize(
R.(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt+test_finish_resize_fails_allocation_cleanup5s

c	sˆjˆj
d
dˆjddddgƒ}ˆj
ji
|d6ƒ
}ˆjˆj
|dƒ}|d	}ˆj|ƒ
}ˆjd
dƒ

ˆjd
dƒ

ˆjd
d
ƒ

ˆjd
dƒ

ˆjdƒ
}ˆjdƒ
}	ˆjd
ƒ
}
ˆjdƒ
}idd6|d6idd6|	d6id
d6|
d6idd6|d6g}ˆjdtdg
ddƒ
ˆj	j
ƒ
ˆjdƒ
ˆ_	‡‡
‡fd†}
tj
j‰ˆjd|
ƒ
dˆ_|d%krÆ
dn|}tˆ
d|ƒ}ˆjd|ddƒ
|d}i
i
ˆjdd6d6}ˆj
j||ƒ
|ˆ
krÓˆjˆj
|dƒ}ˆj|ƒ
}ˆjˆj|ƒ
||	|
|f}idd6dd 6dd!6}xn
|D]%}ˆj|ƒ
}ˆj||ƒ
q§Wn>
ˆjˆj
|d"ƒ}|jd	ƒ
}|ˆ
d}ˆj||ƒ
|ˆ
d}ˆj|ƒ
}ˆj|ƒ
}ˆjˆj|ƒ
||	|
|f}idd6dd 6dd!6}x?|D]7}||kr£q‹nˆj|ƒ
}ˆj||ƒ
q‹Wtjƒ}i
|dd#6}tjj||ƒ}ˆjd$t|jƒ
ƒ
d%S(&s…Test that when a resize attempt fails, the retry comes from the
        supplied host_list, and does not call the scheduler.
        ssome-serverRº
R8R»
s$155d900f-4e14-4e4c-a73d-069cbf4541e6R[
R>RsOS-EXT-SRV-ATTR:hostR!RRRRRŽR•
tweight_classess.AltHostWeigherR‰tfilter_schedulerRŠcs>ˆjˆ
kr-ˆjd
7_t
dƒ
‚
nˆ||
Ž
dS(Ni
R%(t	num_failst	Exception(RrRs(tactual_prep_resizeRR"(sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR%]s



s0nova.compute.manager.ComputeManager._prep_resizeiiiRˆR-RæRvR„
R…
R‡
RèRpi
N(RxRRÓ
RyRARs
R©
R…R&R¦
Rú
R7tcompute_managertComputeManagerR/RwR9RCtminRÔ
R«Rw
R‰
RPR RRbR
t
MigrationListtget_by_filtersR†(R"Rtnum_altsR

RzR>t	inst_hostt	uuid_origtuuid_selt	uuid_alt1t	uuid_alt2t	uuid_alt3thostsR%tattemptsRy
RÝRÀ
ttarget_uuidstempty_usagettarget_uuidtusagetnew_server_hostt
expected_hostt	uuid_destRä
RetfiltersR¸
((R;RR"sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt'_test_resize_reschedule_uses_host_lists9s„


	

	


















	

	






	






	














c

Cs|jd
dƒ

dS(NRi
(
RR(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt-test_resize_reschedule_uses_host_lists_1_failœs
c

Cs|jd
dƒ

dS(NRi(
RR(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt.test_resize_reschedule_uses_host_lists_3_failsŸs
c

Cs|jd
dddƒ
dS(NRiRAi
(
RR(
R"((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt6test_resize_reschedule_uses_host_lists_not_enough_alts¢s
N(/R&R'R(R˜tREQUIRES_LOCKINGRž
R5RÚ
RmRÝ
RÞ
Rà
Rá
Ré
RÜ
Rß
Rë
Rï
Rð
Rõ
Rþ
RR
RRR
RRRRRRR'
R(
R
R€R#R*R.R0R3R6RCRRRSRTRU(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRÍ
°sR								<	&	B	5	 	!	7	@	Q	N	I				&	&	(	&	H
6	3	-			c		tServerLiveMigrateForceAndAbortc
Bs/eZ
dZd
Zd„Zd„Zd„ZRS(sìTest Server live migrations, which delete the migration or
    force_complete it, and check the allocations after the operations.

    The test are using fakedriver to handle the force_completion and deletion
    of live migration.
    sfake.FakeLiveMigrateDriverc
Cs]tt
|ƒjƒ
|jd
dƒ
|_|jd
dƒ
|_|jjƒ}
|
d|_dS(NR!RRi(	R4RWR5R©
RÑ
R}RRÒ
RÓ
(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5°s



c
Csœ
|jj
}
|jj
}|j|
ƒ
}|j|ƒ
}|j|j|
ƒ}i
i|d
6td6d6}|jj|d|ƒ
|j	|dg
ƒ}|jj
|d|dƒ
|j|j|i|d6dd6ƒ
|jƒ
|j
|ƒ
}|jid	d
6d	d6d	d6|ƒ
|j
|ƒ
}	|j|j|	ƒ
|j|dƒ
}
|jd
t|
ƒ
ƒ
|j||
ƒ
|
|d}|j|j|ƒ
|j|ƒ

dS(NR!Rsos-migrateLiveR8trunningsOS-EXT-SRV-ATTR:hostRR9iRîR†
Rƒ
i
RŒ
(RÑ
R!R}Rs
RÂ
RÓ
R˜RR«R!tforce_complete_migrationRŽ
RmRw
R‰
Rz
RPR†RÔRÅ
(R"R¾
RÛ
R¿
Râ
R>RšR"RÀ
Rä
Rx
Rè
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt test_live_migrate_force_complete¹s:



















c
Csœ
|jj
}
|jj
}|j|
ƒ
}|j|ƒ
}|j|j|
ƒ}i
i|d
6td6d6}|jj|d|ƒ
|j	|dg
ƒ}|jj
|d|dƒ
|j|j|i|
d6dd6ƒ
|jƒ
|j
|dƒ
}|jd	t|ƒ
ƒ
|j||ƒ
|j|ƒ
}	|j|j|	ƒ
||d
}
|j|j|
ƒ
|j|ƒ
}|jidd6dd
6dd6|ƒ
|j|ƒ

dS(NR!Rsos-migrateLiveR8RXsOS-EXT-SRV-ATTR:hostRR9i
RŒ
iRîR†
Rƒ
(RÑ
R!R}Rs
RÂ
RÓ
R˜RR«R!tdelete_migrationRŽ
RmRz
RPR†RÔRw
R‰
RÅ
(R"R¾
RÛ
R¿
Râ
R>RšR"Rx
RÀ
Rê
Rä
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_live_migrate_deleteäs8


















(R&R'R(Rž
R5RZR\(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRW¦s
			+tServerRescheduleTestsc
Bs/eZ
dZd
Zd„Zd„Zd„ZRS(sèTests server create scenarios which trigger a reschedule during
    a server build and validates that allocations in Placement
    are properly cleaned up.

    Uses a fake virt driver that fails the build on the first attempt.
    sfake.FakeRescheduleDriverc
Cs]tt
|ƒjƒ
|jd
dƒ
|_|jd
dƒ
|_|jjƒ}
|
d|_dS(NR!RRi(	R4R]R5R©
RÑ
R}RRÒ
RÓ
(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5s




cCsid
d6dd
6}||
S(NRR((R"R!RÙ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRÚ
!s




c

	Cs
|j|j
d
d|jddddgƒ}
|j
ji
|
d6ƒ
}|j|j
|dƒ}|d	}|j|ƒ
}tjd
|ƒ
tjd|ƒ
|j|ƒ
}|j|ƒ
}|j	|ƒ
}|j
idd
6dd6dd6|ƒ
|j	|ƒ
}	|j
|j|	ƒ
dS(s±Tests that allocations, created by the scheduler, are cleaned
        from the source node when the build fails on that node and is
        rescheduled to another node.
        ssome-serverRº
R8R»
s$155d900f-4e14-4e4c-a73d-069cbf4541e6R[
R>RsOS-EXT-SRV-ATTR:hostsfailed on %ss
booting on %siRƒ
RîR†
N(RxRRÓ
RyRARÚ
RDRjRs
Rw
R‰
(
R"R

RzR>RÛ
Rtfailed_rp_uuidRâ
R)Rä
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt'test_rescheduling_when_booting_instance&s$


	








(R&R'R(Rž
R5RÚ
R_(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR]s
		tServerBuildAbortTestsc
Bs&eZ
dZd
Zd„Zd„ZRS(sêTests server create scenarios which trigger a build abort during
    a server build and validates that allocations in Placement
    are properly cleaned up.

    Uses a fake virt driver that aborts the build on the first attempt.
    sfake.FakeBuildAbortDriverc
CsHtt
|ƒjƒ
|jd
dƒ
|_|jjƒ}
|
d|_dS(NR!Ri(R4R`R5R©
RÑ
RRÒ
RÓ
(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5Ps

c
	Cs³|j|j
d
d|jddddgƒ}
|j
ji
|
d6ƒ
}|j|j
|dƒ
|jjj}|j|ƒ
}|j	|ƒ
}|j
id	d
6d	d6d	d6|ƒ
d
S(s‹Tests that allocations, created by the scheduler, are cleaned
        from the source node when the build is aborted on that node.
        ssome-serverRº
R8R»
s$155d900f-4e14-4e4c-a73d-069cbf4541e6R[
R>RviRƒ
RîR†
N(RxRRÓ
RyRARÑ
RR!Rs
Rw
R‰
(R"R

RzRR^R)((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt test_abort_when_booting_instanceXs


	


(R&R'R(Rž
R5Ra(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR`Fs	tServerUnshelveSpawnFailTestsc
Bs&eZ
dZd
Zd„Zd„ZRS(s·Tests server unshelve scenarios which trigger a
    VirtualInterfaceCreateException during driver.spawn() and validates that
    allocations in Placement are properly cleaned up.
    s fake.FakeUnshelveSpawnFailDriverc
CsEtt
|ƒjƒ
|jd
ƒ
|_|jjƒ}
|
d|_dS(NRi(R4RbR5R©
RÑ
RRÒ
RÓ
(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5us

c
	CsÃ
|jj
j}
|j|
ƒ
}|j|ƒ
}|jid
d6d
d6d
d6|ƒ
|j|jdd|jddd	d
dƒ}|jj	i
|d6ƒ
}|j
|j|d
ƒ
|j|ƒ
}|j|j|ƒ
|jdd
ƒ

|jj|di
dd6ƒ
|j|j|idd6dd6ƒ
|j|ƒ
}|jid
d6d
d6d
d6|ƒ
|jj|di
dd6ƒ
|j|tjdƒ
|j|ƒ
}|jid
d6d
d6d
d6|ƒ
dS(s–Tests that allocations, created by the scheduler, are cleaned
        from the target node when the unshelve driver.spawn fails on that node.
        iRƒ
RîR†
sunshelve-spawn-failRº
R8R»
s$155d900f-4e14-4e4c-a73d-069cbf4541e6R[
RZ
R>RRÁRÂR=
R9sOS-EXT-SRV-ATTR:hostR	tcompute_unshelve_instanceN(RÑ
RR!Rs
Rw
R‰
RxRRÓ
RyRAR…R«RCRŽ
Rh
RtUNSHELVE(R"RÁ
R~
Rt
R

R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt/test_driver_spawn_fail_when_unshelving_instance}s6





	











(R&R'R(Rž
R5Re(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRbms	tServerSoftDeleteTestsc
Bs2eZ
dZd
„Zd„Zd„Zd„ZRS(sfake.SmallFakeDriverc
CsEtt
|ƒjƒ
|jd
ƒ
|_|jjƒ}
|
d|_dS(NRi(R4RfR5R©
RÑ
RRÒ
RÓ
(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5¯s

cCsG
|jj
|
d
ƒ

|j|j|
dƒ}
|jƒ
|j|ƒ
}|j|ƒ
}|j|j|ƒ
|j|
d
ƒ
}|j	dt
|ƒ
ƒ
||d}|j|j|ƒ
tjƒ}|j
j|ƒ

|jƒ
|j|ƒ
}|j|j|ƒ
|j|
d
ƒ
}|j	dt
|ƒ
ƒ
||d}|j|j|ƒ
dS(NR8Rªi
RŒ
(RRKRARmRs
Rw
R‰
RÓ
Rz
RPR†RRbRÑ
R¥(R"R>RÁ
R~
Rt
Rx
Rˆ
Re((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt!_soft_delete_and_check_allocation·s&












c
Cs
|jd
dƒ

|j
j}
|j|
ƒ
}|j|j|
ƒ}|j||
ƒ
tjƒt	j
ddƒ
}tjd|ƒ

|jtj
ƒ

tjƒ}|j
j|ƒ

|j|ƒ

|j|ƒ
}|jidd6dd6dd	6|ƒ
|j|d
ƒ
}|jdt|ƒ
ƒ
dS(stAsserts that the automatic reclaim of soft deleted instance cleans
        up the allocations in placement.
        R¨iRži
RŸiR„
R…
R‡
R8N(R…RÑ
R!Rs
RÂ
RÓ
RgRR R¡R¢R£RƒR¤RRbR¥RÃ
Rw
RPRz
R†(R"RÁ
R~
R>R¦ReRt
Rx
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_soft_delete_then_reclaimØs"










c
Cs
|jd
dƒ

|j
j}
|j|
ƒ
}|j|j|
ƒ}|j||
ƒ
i
id6}|jj|d|ƒ
|j	|j|dƒ}|j
|ƒ
}|j|j|ƒ
|j|dƒ
}|j
dt|ƒ
ƒ
||d}|j|j|ƒ
|jd
dƒ

|j|ƒ

d	S(
siAsserts that restoring a soft deleted instance keeps the proper
        allocation in placement.
        R¨iR©R8Ri
RŒ
iN(R…RÑ
R!Rs
RÂ
RÓ
RgRR«RARw
R‰
Rz
RPR†RÅ
(R"RÁ
R~
R>RšRt
Rx
Rˆ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_soft_delete_then_restoreús"









(R&R'Rž
R5RgRhRi(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRf«s
		!	"tTraitsBasedSchedulingTestc
Bs8eZ
dZd
Zd„Zd„Zd„Zd„ZRS(s?Tests for requesting a server with required traits in Placementsfake.SmallFakeDriverc
Cstt
|ƒjƒ
|jd
ƒ
|_|jdƒ
|_|jjƒ}
|
d|_|j	j
|jdi
i
dd6d6ƒ
dS(NRRiR8trequiredstrait:HW_CPU_X86_VMXtextra_specs(R4RjR5R©
RÑ
R}RRÒ
tflavor_with_traitRV
tpost_extra_spec(R"R×
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR5"
s





	


c
	CsE|j|j
d
ddd|jdddƒ}
|j
ji
|
d6ƒ
S(	Nstrait-based-serverR»
s$76fa36fc-c930-4bf3-8c8a-ea2a2420deb6Rº
R8R[
RZ
R>(RxRRmRy(R"R

((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR÷.
s




c
Csj|j|j
jƒ
}
|j|
d
g
ƒ
|jƒ}|j|j|dƒ}|j|j
j|dƒ
dS(s®Tests that a server create request using a required trait ends
        up on the single compute node resource provider that also has that
        trait in Placement.
        RÉ
RsOS-EXT-SRV-ATTR:hostN(Rs
RÑ
R!R±
R÷RARV
RP(R"R~
R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyttest_traits_based_scheduling6
s



c
Csa|jƒ}
|j
|j|
d
ƒ}
|j|
dƒ

|jd|
ƒ
|jd|
ddƒ
dS(s¦Tests that a server create request using a required trait
        fails to find a valid host since no compute node resource providers
        have the trait.
        RvsOS-EXT-SRV-ATTR:hostR`
s
No valid hostRa
N(R÷RARV
RÕR—(R"R>((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt*test_traits_based_scheduling_no_valid_hostE
s


(R&R'R(Rž
R5R÷RoRp(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRj
s
			tServerTestV256CommoncBs;eZ
dZd
ZeZd„Zd„Zed„ƒ
Z	RS(sv2.1s2.56c
CsHxAdD]9}
tj
|
g
ƒ

|jtjƒ

|jdd|
ƒ


qWdS(NRRthost3RgR!(shost1shost2Rr(RR‚RƒR„R7(R"R!((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_setup_compute_serviceX
s



c
CsS|jd
dƒ
}
|
j
i
dd6ƒ

i
|
d6}|jjd|ƒj}|dS(NR»
s$a2459075-d96c-40d5-893e-577ff92e721ctautoR[
R>s/servers(RxRÍRRóRô(R"R>RšR±((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR÷_
s
	
	




c
Cs5id
dgd6ddgd
6dd
gd6}
|
|S(NRRrR((R!ttarget_other_hosts((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt_get_target_and_other_hostsg
s



(
R&R'RRR	
R˜t	ADMIN_APIRsR÷tstaticmethodRv(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRqS
s


		t)ServerTestV256SingleCellMultiHostTestCasec
BseZ
dZd
„ZRS(s„Happy path test where we create a server on one host, migrate it to
    another host of our choosing and ensure it lands there.
    c
CsŽ|jƒ}
|j
|
d
ƒ}
|
d}|j|ƒ
d}|jj|
di
i
|d6d6ƒ
|jj|
dƒ
}
|j||
dƒ
dS(NRusOS-EXT-SRV-ATTR:hostiR8R!R&(R÷RARvRR«R;RP(R"R>tsource_hostttarget_host((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt(test_migrate_server_to_host_in_same_cells
s







(R&R'R(R|(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyRyo
s
t ServerTestV256RescheduleTestCasecBs;eZ
ejjejdd
ejddƒ
ƒ
d„ƒ
Z	RS(R/R/
RnsTest ExceptioncCs©|jƒ}|j
|d
ƒ}|j|dƒ
\}}|jtj|jj|di
i
|d6d6ƒ
|jd|
j	ƒ
|jj
|dƒ
}|j||dƒ
dS(NRusOS-EXT-SRV-ATTR:hostR8R!R&i
(R÷RARvR“RR”RR«RPt
call_countR;tassertNotEqual(R"tmock_prep_resizeR>RIR{RÙ
((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt"test_migrate_server_not_reschedule
s


	



(
R&R'R'
R(
R)
R<R=R	tMigrationErrorR(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyR}
s
	
(LR¡R<RÛR'
toslo_logRtloggingtoslo_serializationR
t
oslo_utilsRRj
tnova.computeRR+
RRR<RRc
RRR	R
tnova.objectsRR
tnova.schedulerRR
t
nova.testsRR˜
tnova.tests.functional.apiRtnova.tests.functionalRtnova.tests.unit.api.openstackRtnova.tests.unitRRRtnova.tests.unit.image.fakeRRRI
t	nova.virtRRt	getLoggerR&RDtBaseHostWeigherRt_IntegratedTestBaseR)RXRðRñR
tInstanceHelperMixinRR
tTestCaseRœ
RÆ
RÍ
RWR]R`RbRfRjRqRyR}(((sG/usr/lib/python2.7/dist-packages/dmapi/tests/functional/test_servers.pyt<module>st



























@ÿÿÆÌ«	
î	
úÿÿÿÿúi7'>r6