ó
±EYc@s
dZd
dl
Z
d
dlmZ
d
dlmZ
d
dlZd
dl	m
Z

d
dl	mZ
d
dlZd
dl
mZ
d
dl
mZ
d
d	l
mZ
d
d
lmZ
d
dl
mZ
d
dlmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
dlmZmZm Z m!Z!
d
dlm"Z"
d
dlm#Z#
d
dlm$Z$
d
dlm%Z%
d
dl&mZ'
d
dlm(Z(
d
dl)m*Z+
d
d	l)mZ,
d
dlm-Z-
d
d	lmZ
ej.e/ƒ
Z0ej1Z1de#j2f
d„ƒYZ3dej4f
d„ƒYZ5dS(s3Handles database requests from other nova services.iÿÿÿÿN(
tcfg(
tlog(
texcutils(
tversionutils(
trpcapi(
ttask_states(
tutils(
twrap_instance_event(
t	vm_states(
tlive_migrate(
tmigrate(
tbase(
t	exception(t
_t_LEt_LIt_LW(
timage(
tmanager(
tnetwork(
tobjects(
trpc(
tclient(
tservicegrouptConductorManagercBs_eZ
dZejd
dƒ
Zd„Zd„Zd„Zd„Z	d„Z
d„Zd	„ZRS(
sô
Mission: Conduct things.

    The methods in the base API for nova-conductor are various proxy operations
    performed on behalf of the nova-compute service running on compute nodes.
    Compute nodes are not allowed to directly access the database, so this set
    of methods allows them to get specific work done without locally accessing
    the database.

    The nova-conductor service also exposes an API in the 'compute_task'
    namespace.  See the ComputeTaskManager class for details.
    tversions3.0c
OsBtt
|ƒjd
d|
|Ž

tƒ|_|jj|jƒ

dS(Ntservice_namet	conductor(tsuperRt__init__tComputeTaskManagertcompute_task_mgrtadditional_endpointstappend(tselftargstkwargs((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRBs




c
CsgS(
N((R"tcontext((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytprovider_fw_rule_get_allIscCs>yt|
|ƒ||ŽSWnt
k
r9


tjƒ‚
n
Xd
S(s

Dispatch a call to an object method.

        This ensures that object methods get called and any exception
        that is raised gets wrapped in an ExpectedException for forwarding
        back to the caller (without spamming the conductor logs).
        N(tgetattrt	Exceptiont	messagingtExpectedException(R"ttargettmethodR#R$((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt_object_dispatchMs


cCsÕtj
j|||ƒ}t|
g
t|ƒ
ƒ
}|j||||ƒ}t|tj
ƒrÑ||}	tj|	ƒ
}
tj|j	ƒ
}|
|k}|
d
|d
k}
|s³|
rÑ|j
d|	d|ƒ}qÑn|S(Nittarget_versiontversion_manifest(tnova_objectt
NovaObjecttobj_class_from_namettupletlistR-t
isinstanceRtconvert_version_to_tupletVERSIONtobj_to_primitive(R"R%tobjnamet	objmethodtobject_versionsR#R$tobjclasstresultR.trequested_versiontactual_versiontdo_backporttother_major_version((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytobject_class_action_versions[s"	






	





	


cCsÏ|jƒ}|j
||||ƒ}tƒ}x…|jjƒD]t\}	}
|j|	ƒ
s^q=n|j|	ƒ
sŒt||	ƒt||	ƒkr=|
j||	t||	ƒƒ||	<q=q=W|jƒ|d
<||fS(sPerform an action on an object.tobj_what_changed(	t	obj_cloneR-tdicttfieldstitemstobj_attr_is_setR'tto_primitiveRC(R"R%tobjinstR:R#R$toldobjR=tupdatestnametfield((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt
object_actionts

	





c	Csƒ||jƒ}t
jd
i|jƒd6|d6djg|jƒD]\}}d||f^qCƒ
d6ƒ
|jd|d|ƒS(	Ns9Backporting %(obj)s to %(ver)s with versions %(manifest)stobjtvert
,s%s=%stmanifestR.R/(tobj_nametLOGtdebugtjoinRGR8(R"R%RJR;R+RMRQ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytobject_backport_versionsˆs

	




4

c


Cstj
jƒ
dS(
N(RtServicetclear_min_version_cache(
R"((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytreset“s
(
t__name__t
__module__t__doc__R)tTargetR+RR&R-RBRORXR[(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR3s						RcBsX
eZ
dZejd
dddƒZd„Zd„Zeje	j
e	je	je	j
e	je	je	je	je	je	je	je	je	je	je	jƒeddƒ
dedd	„ƒ
ƒ
Zd
„Zd„Zd„Zeddƒ
d
„ƒ
Z d„Z!dd„
Z"d„Z#d„Z$d„Z%ded„Z&d„Z'dd„
Z(e)ddd„Z*RS(sM
Namespace for compute methods.

    This class presents an rpc API for nova-conductor under the 'compute_task'
    namespace.  The methods here are compute operations that are invoked
    by the API service.  These methods see the operation to completion, which
    may involve coordinating activities on multiple compute nodes.
    t	namespacetcompute_taskRs1.15c

Csztt
|ƒjƒ
tjƒ|_tjƒ|_tjƒ|_	t
jƒ|_tj
ƒ|_tjd
tjƒ|_dS(Ntcompute(RRRtcompute_rpcapit
ComputeAPIRtAPIt	image_apiRtnetwork_apiRtservicegroup_apitscheduler_clienttSchedulerClientRtget_notifiertCONFthosttnotifier(
R"((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR¢s






c

Cs/tj
td
ƒ
ƒ

dt_tjƒ|_dS(NsReloading compute RPC API(RUtinfoRtNoneRctLAST_VERSIONRd(
R"((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR[«s

	
tprefixRcCs&
|rRt|t
jƒrRd
dddg}tjj|
tjƒ|d|ƒ
}n|r‡t|tjƒr‡tjj|
|dƒ}n|rº|rº|rº|j|
|||||ƒ
nh|r
|r
|r
|j	}
t
j|
d|
ƒ(
|j|
|||d|	|
|ƒ
WdQXn	t
ƒ‚
dS(	Ntmetadatatsystem_metadatat
info_cachetsecurity_groupstexpected_attrstidtcold_migratetfilter_properties(R5R0R1RtInstancet_from_db_objecttFlavort	get_by_idt
_live_migratetuuidt
compute_utilst
EventReportert
_cold_migratetNotImplementedError(R"R%tinstancetscheduler_hinttlivetrebuildtflavortblock_migrationtdisk_over_committreservationstclean_shutdowntrequest_spectattrst
instance_uuid((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytmigrate_server²s&	
	
	






	





cCs&tj
|jƒ
}|sQtjj|
|j|||j|j|d|j
ƒ	}n	||_|j|
|||||ƒ}	|j
ƒ}
y|	jƒ
Wnt
tjk
r7

}
|j}|sÂtj}ni|d
6dd6}
|j|
|jd|
||
ƒ
|j|jkr
tdƒ
}ntdƒ
}tjd|ƒ
‚
nÒtjk
r­

}
tjƒS
|j}|sq
tj}ni|d
6dd6}
|j|
|jd|
||
ƒ
WdQXn\tk
r
}
tjƒ;
i|jd
6dd6}
|j|
|jd|
||
ƒ
WdQXn
X|jƒr"|jƒ
ndS(Ntvm_statet
task_stateR‘s$No valid host found for cold migratesNo valid host found for resizetreason(Rtget_image_from_system_metadataRtRtRequestSpectfrom_componentsR€t
numa_topologytpci_requestsRptavailability_zoneR‰t_build_cold_migrate_tasktto_legacy_request_spec_dicttexecuteRtNoValidHostR’RtACTIVEt_set_vm_state_and_notifyRxtinstance_type_idR
tUnsupportedPolicyExceptionRtsave_and_reraise_exceptionR(RCtsave(R"R%R…R‰RzRŒRRŽRttasktlegacy_spectexR’RLtmsg((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRƒàsX
	


	





	












	
















cCs#tj
|
|d
||||ƒ
dS(NRa(tscheduler_utilstset_vm_state_and_notify(R"R%RR,RLR§RŽ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR !
s

cCs™y/|o|js.|j
j|
|d
|ƒ

nWn1tk
rb


tdƒ
}tj|d|ƒ


dSXd|jd<y|jƒ
Wntj	k
r”


n
XdS(Ntrequested_networkssFailed to deallocate networksR…tFalsetnetwork_allocated(
tno_allocateRgtdeallocate_for_instanceR(RRURRtR¤tInstanceNotFound(R"R%R…R«R¨((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt_cleanup_allocated_networks'
s
	









cCs |j|
|||||ƒ
dS(
N(
R(R"R%R…R†RŠR‹RŽ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytlive_migrate_instance=
s
cCs#|jd
ƒ
}ddd„}tjd|
jƒƒ
}	||	_d|	_|j|	_|j	|	_
d|	_|jdƒ
r™|j
j|	_|j
j|	_n|j|	_|j|	_|	jƒ
|j|
|||||	|ƒ}
y|
jƒ
Wn2
tjtjtjtjtjtjtjtjtjtjtj tj!tj"tj#tj$fk
r•

}
t%j&ƒ.
||
|||j'ƒ
d|	_|	j(ƒ
WdQXnŠt)k
r
}
t*j+t,dƒ
i|jd	6|d
6dt-ƒ

||
||t.j/|j0ƒ
d|	_|	j(ƒ
tj1dt2j3|ƒ
ƒ
‚
n
XdS(
NRmcSsUi
i
|
jd
6d6}t
j||
jddtd|d|dtjƒ||ƒ
dS(NR€tinstance_propertiesRaR‘R’R“texpected_task_state(R€R©RªRERt	MIGRATING(R%R…R§R’R“RŽ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt
_set_vm_stateG
s
	




	
R%tacceptedslive-migrationR‰terrorsKMigration of instance %(instance_id)s to host %(dest)s unexpectedly failed.tinstance_idtdesttexc_infoR”(4tgetRpRt	Migrationtelevatedtdest_computetstatusR€RRmtsource_computetmigration_typeRHR‰Rxtold_instance_type_idtnew_instance_type_idR¡tcreatet_build_live_migrate_taskRRRžtComputeHostNotFoundtComputeServiceUnavailabletInvalidHypervisorTypetInvalidCPUInfotUnableToMigrateToSelftDestinationHypervisorTooOldtInvalidLocalStoragetInvalidSharedStoragetHypervisorUnavailabletInstanceInvalidStatetMigrationPreCheckErrort MigrationPreCheckClientExceptiont$LiveMigrationWithOldNovaNotSupportedtMigrationSchedulerRPCErrorRR£R’R¤R(RUR¸RtTrueRtERRORR“tMigrationErrortsixt	text_type(R"R%R…R†RŠR‹RŽtdestinationR¶t	migrationR¥R§((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRC
s`

	
	


	



























	







	


cCs1tj
|
||||||j|j|j|ƒ
S(
N(R	tLiveMigrationTaskRcRhRi(R"R%R…RÚRŠR‹RÛRŽ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRƆ
s





c	Cs(tj
|
||||||j|jƒS(
N(R
t
MigrationTaskRcRi(R"R%R…R‰RŽRŒR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR›‘
s




c	Csžy&tj
j|
|jƒ}|jƒ
Wnqtjk
r™


tjƒN}tj	j
|
d
ƒ}|dkrln#tjdi
|jd6ƒ
t
|_WdQXdSXdS(Nsnova-osapi_computeis^BuildRequest not found for instance %(uuid)s, likely due to an older nova-api service running.R€(RtBuildRequesttget_by_instance_uuidR€tdestroyRtBuildRequestNotFoundRR£RYtget_minimum_versionRURVR¬treraise(R"R%R…t
build_requesttexc_ctxttservice_version((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt_destroy_build_requestš
s




	

	

cCs ytj
j|
|jƒ}Wn(tjk
rF


tjd
d|ƒ


dSXytj	j
|
|dƒ}Wntjk
r…


|jƒ
dSX|j
|_
|jƒ
|S(NsSInstance was not mapped to a cell, likely due to an older nova-api service running.R…Rm(RtInstanceMappingRßR€RtInstanceMappingNotFoundRURVRptHostMappingtget_by_hosttHostMappingNotFoundRàtcell_mappingR¤(R"R%R…Rmtinst_mappingthost_mapping((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt_populate_instance_mappingµ
s 

	










cCsõ|r.t|t
jƒr.t
jj|ƒ
}n|jd
ƒ
}|r„t|t
jƒr„t
jj|
|dƒ}t|d
|ƒ

}ni}yEtj	||dj
ƒ
tj|
||ƒ}|j|
||ƒ}
Wn™t
k
rj

}
itjd6dd6}xk|D]c}|j|
|j
d|||ƒ
y|j|
|ƒ
Wntjk
rN



n
X|j|
||ƒ
qÿWdSXxƒ
tjj||
ƒD]l
\}}y|jƒ
Wn3tjtjfk
rÐ



tjdd|ƒ


q
n
Xtj|ƒ
}tj ||ƒ
t
j!j"|
|j
ƒ}|jd	iƒjd
dƒ}|dk
r‰|j#|
||ƒ}y|j|
|ƒ
Wq‰tjk
r…


|r|j$ƒ
ndSXn|j%j&|
d|d|dd
|d|d|d|d|d|d|d|d|dd|dƒ

q
WdS(Nt
instance_typeRxiR’R“tbuild_instancessInstance deleted during buildR…tretrytnum_attemptsi
RmRRŽRztadmin_passwordtinjected_filesR«Rvtblock_device_mappingtnodetnodenametlimits('R5RtNetworkRequestListtfrom_tuplesR¼R}R~RER©tpopulate_retryR€tbuild_request_spect_schedule_instancesR(RRÖRpR RçRRáR±RØtmovestziptrefreshR°tInstanceInfoCacheNotFoundRURVtcopytdeepcopytpopulate_filter_propertiestBlockDeviceMappingListRßRðRàRctbuild_and_run_instance(R"R%t	instancesRRzRõRöR«RvR÷t
legacy_bdmR‰RŽthoststexcRLR…Rmtlocal_filter_propstbdmsRôRî((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRòÓ
s€



	






















"







	
	
	

	

	














cCsDtj
|
||ƒ
tjj|
||ƒ}|jj|
|ƒ}|S(
N(R©tsetup_instance_groupRR–tfrom_primitivesRitselect_destinations(R"R%RŽRztspec_objR
((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyRÿ0s

	


csí|j}‡f
d
†}|j
tjkr_tj|_|jdtjƒ

ˆj	j
|
|ƒ
nŠ|j
tjkr¶d}|j
dƒ
}|r,
tj|
d|jƒƒ
y||
|ƒ}Wnhtjk
r"



tj|_
|jƒ
tdƒ
|}tj|d|ƒ


tjd|jd|ƒ‚
n
XWdQXnyëtj|
d	|jƒÍ
|so
i}	tj|
||g
ƒ}n"|jƒ
|jƒ}	|jƒ}tj|	|jƒ
ˆj|
||	ƒ}
|
d
}tj|	|ƒ
|d|d}}
ˆj	j |
||d
|d|	d|
ƒ
WdQXWqétj!tj"fk
rc


d|_|jƒ
tj#t$dƒ
d|ƒ


dSt%k
r²


t&j'ƒ1
d|_|jƒ
tjt(dƒ
d|ƒ


WdQXqéXn3tjt(dƒ
d|ƒ


tj|_
|jƒ
dSdS(Ncs5|
rˆjj
||
d
tƒ
Stjddƒ
‚
dS(Ntshow_deletedtimage_idt(RfR¼R¬Rt
ImageNotFound(tctxR
(
R"(sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pytsafe_image_show=s

R´tshelved_image_idtget_image_infos4Unshelve attempted but the image %s cannot be found.R…R¹R”tschedule_instancesiRmRùRRzRøs)No valid host found for unshelve instances,Unshelve attempted but an error has occurreds@Unshelve attempted but vm_state not SHELVED or SHELVED_OFFLOADED()RtR’RtSHELVEDRtPOWERING_ONR“R¤t
UNSHELVINGRctstart_instancetSHELVED_OFFLOADEDRpR¼RR‚R€RR
RÖR
RUR¸tUnshelveExceptionR©Rþtreset_forced_destinationst to_legacy_filter_properties_dictRœRýRÿR
tunshelve_instanceRžR¢twarningRR(RR£R(R"R%R…RŽtsys_metaR
RR
R”RzR
t
host_stateRmRø((
R"sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR$
:sz
	













	

	







	










	




	









	








c$Cs«tj
|
d
|jƒ
d}}|sÕ
|
s]i
|jg
d6}tj|
||g
ƒ}
nG|
jpig|
_|
jj|jƒ

|
j	ƒ
|
j
ƒ}|
jƒ}
yH|j|
|
|ƒ}|j
dƒ
}|d|d|d}}}WqÕ
tjk
r`

}
tjƒN
|j|
|jd
i|jd6dd6||
ƒ
tjtd	ƒ
d
|ƒ


WdQXqÕ
tjk
rÑ

}
tjƒN
|j|
|jd
i|jd6dd6||
ƒ
tjtdƒ
d
|ƒ


WdQXqÕ
Xnytjj|
|jdƒ}Wn-tjk
r#


tjd
d
|ƒ


d}n
Xtj|j|
|dƒ
|jj |
d
|d|d|d|d|d|d|d|	d|
d|d|d|d|d|ƒ

WdQXdS(Ntrebuild_servertignore_hostsiRmRùRúR’R“sNo valid host found for rebuildR…s0Server with unsupported policy cannot be rebuiltR·s5No migration record for the rebuild/evacuate request.srebuild.scheduledtnew_passRöt	image_reftorig_image_reftorig_sys_metadataR
trecreateton_shared_storagetpreserve_ephemeralRÛRø(!RR‚R€RpRmR©RþR)
R!R"
R#
RœRÿtpopRRžRR£R R’RUR%
RR¢RR½tget_by_instance_and_statustMigrationNotFoundByStatusRVtnotify_about_instance_usageRnRctrebuild_instance(R"R%R…R,
R+
RöR*
R-
R
R.
R/
R0
RmRŽRøRúRzR
t	host_dictR§RÛ((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR5
“st




































	


















N(+R\R]R^R)R_R+RR[texpected_exceptionsRRžRÈRÇRÉRÊRËRÌRÍRÎRÏRÐRÑRÒRÓR¢RRpRÕR‘RƒR R±R²RRÆR›RçRðRòRÿR$
R¬R5
(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyR—sJ			














	

	A			E					 [	
\
(6R^R
toslo_configRtoslo_logR
tloggingtoslo_messagingR)t
oslo_utilsRRRØtnova.computeRRcRRRtnova.compute.utilsRRtnova.conductor.tasksR	R
tnova.dbRtnovaRt	nova.i18nR
RRRRRRRtnova.objectsR0Rtnova.schedulerRRiR©Rt	getLoggerR\RURltManagerRtBaseR(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/nova/conductor/manager.pyt<module>s>













"










	d