Gemfury

triliodata-3-4 / contego deb

Repository URL to install this package:
Details
contego / home / tvault / .virtenv / lib / python2.7 / site-packages / nova / compute / api.pyc
ó
±EYc@s%dZddlZddlZddlZddlZddlZddlZddlZddlm	Z
ddlmZ
ddlmZddlmZddlmZddlmZdd	lmZdd
lmZddlZddlmZddlmZdd
lmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z$ddlm%Z%ddlm&Z'ddlm(Z(ddlm)Z)ddl*Zddl+m#Z,ddlm-Z.ddlm/Z/ddl0m1Z1ddlm2Z2ddlm3Z3ddlm4Z4ddl5m6Z6ddl5m7Z7ddl5m8Z8dd l5m9Z9dd!lm:Z:dd"lm;Z;dd#lm<Z<dd$l=m>Z?dd%l@mAZAdd&l@mBZBdd'lmCZCdd(lmDZDddlEm1ZFdd
lEmZGdd)lEmHZIdd*lEmJZKdd+lEmLZMdd,lEmNZOdd-lPmQZRddlSZdd.lmTZTdd/lUmVZWddlUm&ZXdd0lmYZYddlm&Z&dd1lZm[Z[dd2l\m]Z]e
j^e_Z`ejaeTjbd3d4Zbejae3jcd5ebd6d7ZcejdjeZed8Zfd9gZgd:Zhd;Zid<Zjd=Zkd>Zlememfend?Zod@ZpdAZqdBZrdCZsdDe1jtfdEYZudFe1jtfdGYZvdHe1jtfdIYZwdJe1jtfdKYZxdLe1jtfdMYZydNe1jteBjzfdOYZ{dS(PsHandles all requests relating to compute resources (e.g. guest VMs,
networking and storage of VMs, and compute hosts on which they run).iÿÿÿÿN(tlog(t
exceptions(t	jsonutils(texcutils(tstrutils(t	timeutils(tunits(t	uuidutils(trange(tavailability_zones(tblock_device(topts(tflavors(tinstance_actions(tpower_state(trpcapi(ttask_states(tutils(t	vm_states(t	conductor(tcontext(tcrypto(tbase(t	exception(texception_wrapper(thooks(t_(t_LE(t_LI(t_LW(timage(tkeymgr(tnetwork(tmodel(topenstack_driver(tsecurity_group_base(t
notifications(tobjects(tfields(tkeypair(tquotas(tsecurity_group(trequest(trpc(tclient(tservicegroup(thardware(tcindertservicetcomputetget_notifiertbinarysnova-apiiÿÿtdefaultshw_video:ram_max_mbtUpdatet
UpdateMetatDeletetAddcsodk	r+ttr+tndk	rVttrVtnfd}|S(sÓDecorator to check VM and/or task state before entry to API functions.

    If the instance is in the wrong state, or has not been successfully
    started at least once the wrapper will raise an exception.
    cs+tjfd}|S(Ncsìdk	rK|jkrKtjddd|jd|jdjndk	r|jkrtjddd|jd|jdjnrÖ|jrÖtjddd|jd|jdjn|||||S(Ntattrtvm_statet
instance_uuidtstatetmethodt
task_statetlaunched_at(tNoneR:RtInstanceInvalidStatetuuidt__name__R>R?(tselfRtinstancetargstkw(tftmust_have_launchedR>R:(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytinner}s(									(t	functoolstwraps(RHRJ(RIR>R:(RHsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytouter|s'N(R@t
isinstancetset(R:R>RIRM((RIR>R:sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcheck_instance_stateoscs"tjfd}|S(Ncs7|js!tjd|jn|||||S(Ntinstance_id(thostRtInstanceNotReadyRB(RDRRERFtkwargs(tfunction(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytwrappeds	(RKRL(RURV((RUsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcheck_instance_hostscs"tjfd}|S(NcsA|jr+|jr+tjd|jn|||||S(NR;(tlockedtis_adminRtInstanceIsLockedRB(RDRRERFRT(RU(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRJ¢s(RKRL(RURJ((RUsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcheck_instance_lock¡scsfd}j|_|S(Ncs#|j||||||S(N(t_validate_cell(RDRRERFRT(tfn(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_wrapped«s
(RC(R]R^((R]sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcheck_instance_cellªscCs|dt|jt|jD}xI|jD];\}}||ksa|||kr9d|g||<q9q9W|S(svReturn a dict describing how to change orig to new.  The keys
    correspond to values that have changed; the value will be a list
    of one or two elements.  The first element of the list will be
    either '+' or '-', indicating whether the key was updated or
    deleted; if the key was updated, the list will contain a second
    element, giving the updated value.
    cSsi|]}dg|qS(t-((t.0tk((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys
<dictcomp>»s	t+(ROtkeystitems(torigtnewtresulttkeytvalue((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
_diff_dict²s
	,tAPIcBseZdZdddddZedZdZdZdZ	dZ
dddZdZdd	Z
d
ZdZdZed
ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ e!dZ"edZ#de!e$e$dZ%edZ&d Z'd!Z(d"Z)d#Z*d$Z+d%Z,d&Z-d'Z.e$e!d(Z/d)Z0d*Z1e2j3d+ddddddddddddddddddddddde!e$e$d,Z4ddd-Z5d.Z6d/Z7d0Z8d1Z9d2Z:d3Z;d4Z<d5Z=d6Z>de$d7Z?de$d8Z@de$d9ZAeBeCeDd:dd;dd<e!d=ZEd>ZFeBeCeDd:dd;dd<e$d?ZGeBeDd:eHjIgd@ZJeBeDd<e$dAZKe!e!dBZLeBeMeCeDd:eHjNeHjOge!e!dCZPeBeMeCeDd:eHjQgdDZReBeMeCeDd:eHjSdEZTdFZUdGZVddHZWdddddddIZXedJZYddddddKZZdLZ[eCeDd:eHjNeHjQeHj\eHj]gddMZ^eCeDd:eHjNeHjQeHj\eHj]gddNZ_ddOZ`ddPZaeDd:eHjNeHjQeHj]gddQZbeBdRZceDd:edeHjed;dgdSZfeDd:edeHjgd;ehjidTZjeBeCeDd:eHjNeHjQeHjOgddUZkeBeCeDd:eHjlgdVZmeBeCeDd:eHjlgddWZnedXZoeBeCeDd:eHjNeHjQgde!dYZpeBeDd:eHjNeHjQeHj\eHj]ge!dZZqeBeDd:eHjrge!d[ZseBeDd:eHjreHjtgd\ZueBd]ZveBd^ZweBeCeDd:eHjNgd_ZxeBeCeDd:eHj\gd`ZyeMdaZzeMdbZ{eBeCeDd:eHjNgdcZ|eBeCeDd:eHj]gddZ}eBeDd:eHjNeHjQeHjOgdde!deZ~eBeDd:eHjgdfZeBeCeDd:eHjNgddgZeMdhZeMdiZeMdjZeMdkZeMdlZeMdmZeMdnZeMdoZeMdpZeMddqZdrZdsZdtZeBeCduZeBeCdvZe$dwZdxZdyZdzZeBeDd:eHjNeHj\eHjQeHjleHjIeHjreHjtgdddd{Zd|Zd}Zd~ZeBeDd:eHjNeHj\eHjQeHjleHjIeHjreHjtgdZeBeDd:eHjNeHj\eHj]eHjQeHjleHjIgdZeBeDd:eHjNeHj\eHjQgd;dgdZeBeDd:eHjNeHj\eHjQgd;dgdZdZdZdZdZ eBeDd:eHjNeHj\eHj]eHjQgd;ddZ¡eBeDd:eHjNeHj\eHj]eHjQgd;de$dZ¢eBeCeDd:eHjNeHj\gde$dZ£eBeCeDd:eHjNgd;ehj¤gdZ¥eBeCeDd;ehj¤gdZ¦eDd:eHjNeHjQeHjOgdddZ§dZ¨ddZ©dZªdZ«dZ¬dZdZ®dZ¯dZ°RS(s-API for interacting with the compute manager.cKsà|ptj|_|p$tj|_|p9tj|_|pNtj|_	t
j|_
tj
|_tj|_tj|_tjdtj|_tjjrÆtj|_ntt|j|dS(NR1(RRlt	image_apiR tnetwork_apiR/t
volume_apiR"t#get_openstack_security_group_drivertsecurity_group_apitconsoleauth_rpcapitConsoleAuthAPItcompute_rpcapit
ComputeAPIRtComputeTaskAPItcompute_task_apiR-tservicegroup_apiR+R2tCONFRRtnotifiertephemeral_storage_encryptiontenabledRtkey_managertsupert__init__(RDRmRnRoRqRT((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÆscCs<yt|dSWn$tk
r7tj|_|jSXdS(Nt
_cell_type(tgetattrtAttributeErrort
cells_optst
get_cell_typeR(RD((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt	cell_type×s

cCs>|jdkrdS|j}|s:tjd|jndS(NtapiR;(Rt	cell_nameRtInstanceUnknownCellRB(RDRER((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR\ßs		cCs#tjj||j|dtdS(Ntwant_result(R%tInstanceActiontaction_startRBtFalse(RDRREtaction((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_record_action_startçscCs|dkrdSy tjj|dt|Wn tjk
rRtjnXd}d}x>|D]6\}}t|t|}t|t|}qfWy tjj|d|d|WnDtjk
r}d|j	dkr÷tj
qtjnXdS(sgEnforce quota limits on injected files.

        Raises a QuotaError if any limit is exceeded.
        Ntinjected_filesitinjected_file_path_bytestinjected_file_content_bytestovers(R@R%tQuotastlimit_checktlenRt	OverQuotatOnsetFileLimitExceededtmaxRTtOnsetFilePathLimitExceededtOnsetFileContentLimitExceeded(RDRRtmax_pathtmax_contenttpathtcontenttexc((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_injected_file_quotaës(csfdjD}jddkr|jdrz|jdd|d}||jdd|d<q|jdd|d<njddkr|jdrî|jdd|d}||jdd|d<q|jdd|d<n|S(Ncs5i|]+}||d|d|qS(tin_usetreserved((Ratres(R(tusages(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys
<dictcomp>s	tcoresiÿÿÿÿt	instancesitram(Rdtget(RDR(R¤tdeltastheadroomthcthr((R(R¤sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
_get_headroomscCs¥||d}t|jdijtd}||d|}	y>tjd|}
|
jd|d|d|	d	|d
|Wntjk
r}|jd}
|jd}|jd
}
i|d6|d6|	d6}|j	|
|
|}|jdd}|dr(t
||d|d}n|drTt
||d|d|}n|dkrotd}nB||ko|knr¡|j||||Std|}||krÉt
|n
d||f}td|d|d|	}|j|||
|\}}}}i|d6|jd6|d6|d6|d6}||krctjd|ntjd|tjd|d|d|d|nX||
fS(s4Enforce quota limits on number of instances created.tvcpustextra_specsit	memory_mbRR¦R¥R§t
project_idtuser_idR(RR¤is+Cannot run any more instances of this type.s,Can only run %s more instances of this type.s%s-%stpidt	min_countt	max_counttmsgsS%(overs)s quota exceeded for %(pid)s, tried to run %(min_count)d instances. %(msg)ssm%(overs)s quota exceeded for %(pid)s, tried to run between %(min_count)d and %(max_count)d instances. %(msg)streqtusedtallowed(tintR¨t	VIDEO_RAMR%RtreserveRRRTRtminRt_check_num_instances_quotatstrtdictt_get_over_quota_detailR±tLOGtdebugtTooManyInstances(RDRt
instance_typeR´RµR±R²t	req_corestvram_mbtreq_ramR(RRR¤R©RªR¹R¶t
num_instancest	requestedtreqsttotal_allowedstusedstparams((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¾&sb$





		
	
	
c	Csªg}g}g}x[|D]S}|jt|||jt|||||jt||qWtdj||||f\}}}}||||fS(Ns, (tappendR¿tmaptjoin(	RDRªRR(RÊRËRÍRÌtresource((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÁms
	!c
Cs|si}nt|ts?td}tjd|nt|}ytjj|d|Wn9tj	k
r }|j
dd}tjd|nXxØtj
|D]Ç\}}y$tj|tj|ddWn.tjk
r}	tjd|	jnXt|dkrEtd	}tjd|nt|dkr±td
}tjd|q±q±WdS(s,Enforce quota limits on metadata properties.sMetadata type should be dict.treasontmetadata_itemsR(R¹t
min_lengthiiÿs1Metadata property key greater than 255 characterss3Metadata property value greater than 255 charactersN(RNRÀRRtInvalidMetadataRR%RRRRTtMetadataLimitExceededtsixt	iteritemsRtcheck_string_lengthtInvalidInputtformat_messagetInvalidMetadataSize(
RDRtmetadataR¶tnum_metadataRtquota_metadataRbtvte((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _check_metadata_properties_quotays.	
cCsZxS|D]K}|dkrqn|jj||stjd|jd|qqWdS(sYCheck if the security group requested exists and belongs to
        the project.
        R4R±tsecurity_group_idN(RqR¨RtSecurityGroupNotFoundForProjectR±(RDRt	secgroupstsecgroup((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_requested_secgroupss
	cCs>|dk	r(|jr|S|j}n|jj|||S(s£Check if the networks requested belongs to the project
        and the fixed IP address for each network provided is within
        same the network block
        N(R@tno_allocatet	as_tuplesRntvalidate_networks(RDRtrequested_networksRµ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_requested_networks¦s	cCsØ|jdi}|dkr0|jd}n|dkrN|jd}n|ttjkrrd}d}n|dk	r |jj||}|d}n|dk	rÎ|jj||}|d}n||fS(sChoose kernel and ramdisk appropriate for the instance.

        The kernel and ramdisk can be chosen in one of three ways:

            1. Passed in with create-instance request.

            2. Inherited from image.

            3. Forced to None by using `null_kernel` FLAG.
        t
propertiest	kernel_idt
ramdisk_idtidN(R¨R@R¿Rytnull_kernelRm(RDRRïRðRtimage_propertiestkernel_imaget
ramdisk_image((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_handle_kernel_and_ramdisk¹s
	

cCsÐd}d}|r±d|kr±|jd}|dkrQ|jd\}}q±|dkrd|kr|jd\}}q®|jd\}}}q±tjddn|sÃtj}n|||fS(Nt:iis::RÓs!Unable to parse availability_zone(R@tcounttsplitRRÛRytdefault_schedule_zone(Rtavailability_zonetforced_hosttforced_nodetc((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytparse_availability_zoneås	cCs4tj|}|r0|r0tjd|ndS(NR(Rtis_auto_disk_config_disabledRtAutoDiskConfigDisabledByImage(RDtauto_disk_config_imgtauto_disk_configRtauto_disk_config_disabled((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt!_ensure_auto_disk_config_is_validscCs|jdi}tj|}|j|||jd|dkr[tj|}ni|jdd6|jdd6|jdd6|d6S(NRîRñtos_typetarchitecturetvm_modeR(R¨Rt%get_auto_disk_config_from_image_propsRR@Rtbool_from_string(RDRRRóR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_inherit_properties_from_image
s	cCsgi|d6|d6|dd6}ytj|}Wn0ttfk
rbtjtd|}nX|S(NRBtnameiRøsGFailed to set instance name using multi_instance_display_name_template.(Ryt$multi_instance_display_name_templatetKeyErrort	TypeErrorRÂRR(RDRBtdisplay_nametindexRÎtnew_name((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _new_instance_name_from_templates
cCs|j}|j|j|j|}||_|jddstj|dkrl|j|j|_qtj||_n|S(Nthostnamet(	RRRBR¨R@Rtsanitize_hostnamet_default_host_nameR(RDRRERt
original_nameR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_apply_instance_name_template*s		cCs\|rHytj|dt}WqNtk
rDtjd|qNXnt}|rXtSdS(NtstricttoptionR(RR
tTruet
ValueErrorRtConfigDriveInvalidValueR(RDtconfig_drivetbool_val((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_config_drive6s

c	Cs»|s
dS|ddkr/tjd|n|jdi}|jdd}|dkrttjd|n|d	t|jd
pdkr¨tjnt|jdp½dtj}t|jd
pßd}	|dk	rI|j	rI|j
}
|
dk	r·|
tj9}
||
krFtjd|
d|qFq·nn|dtj}
|
dkr·|	|
krtjd|
d|	n||
kr·tj
d|
d|q·ndS(Ntstatustactivetimage_idRîtimg_config_drivetoptionalt	mandatoryRR°tmin_ramitmin_disktsizetvolume_sizetimage_min_disktroot_gbtflavor_sizet
image_size(soptionals	mandatory(RtImageNotActiveR¨tInvalidImageConfigDriveRºtFlavorMemoryTooSmallRtGiR@t	is_volumeR+tVolumeSmallerThanMinDisktFlavorDiskSmallerThanImagetFlavorDiskSmallerThanMinDisk(RDRR$RRÅtroot_bdmRótconfig_drive_optionR,R/t	dest_size((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_requested_imageEs:	%"	
			cCs°|jdi}|jdg}|jdt}|jdg}|rgtj|d|}ntttj|}|r¬|j||}|j	||}n|S(NRîtblock_device_mappingtbdm_v2tmappings(
R¨RR
tfrom_legacy_mappingR@tlistRÐtBlockDeviceDictt_prepare_image_mappingt_merge_bdms_lists(RDRÅt
image_metatroot_device_nameRótimage_defined_bdmstlegacy_image_definedt
image_mapping((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_image_defined_bdmss		cCs£g}tttj|}tttj|}|jdri|ri|jtj|dn|jdr|r|jtj|ddn|S(Ntephemeral_gbtswap(tanytfilterR
tnew_format_is_ephemeraltnew_format_is_swapR¨RÏtcreate_blank_bdm(RDRÅR<tflavor_defined_bdmsthave_ephemeral_bdmsthave_swap_bdms((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_flavor_defined_bdms«scCsAtd|D}|g|D]}|d|kr |^q S(sòOverride any block devices from the first list by device name

        :param overridable_mappings: list which items are overridden
        :param overrider_mappings: list which items override

        :returns: A merged list of bdms
        css#|]}|dr|dVqdS(tdevice_nameN((Ratbdm((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys	<genexpr>ÄsRU(RO(RDtoverridable_mappingstoverrider_mappingstdevice_namesRV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRC¼s
c	Cs|jdpd}	|jdd}
|
rxf|D][}|jddkr4tj|jd|	kr4td|	}tj|q4q4Wn|j|||	}
tj|
dk	}|rätj	||
|	d	|}n'|rd
}t
t||}n|j|
|}|dks5|dkrnt
td|rntd
}tj|qnn||j||7}tj||S(NREtvdat	image_refRtdestination_typetvolumeRUsHThe volume cannot be assigned the same device name as the root device %stno_rootcSs)|jddko'|jddkS(Nt
boot_indexitsource_typeR(R¨(RV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytnot_image_and_root_bdmïsicSs|ddkS(NR`R]((RV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt<lambda>úss7Cannot attach one or more volumes to multiple instances(R¨R
t	strip_devRRtInvalidRequestRItget_root_bdmR@R?R@RMRCRLRÐRTtblock_device_objt!block_device_make_list_from_dicts(RDRtbase_optionsRÅRDR´RµR<t
legacy_bdmRER[RVR¶RFtroot_in_image_bdmsRa((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_and_transform_bdmÊs@
	
		
cCs3|sdifS|jj||}|d|fS(NRñ(R@RmR¨(RDRt
image_hrefR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
_get_images
cCs=|j|||j|||j|||||dS(N(RãR R;(RDRR$RRÅRÞtfiles_to_injectR8((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_checks_for_create_and_rebuild
sc#Cs|dr#tjd|dn|rt|}|tkr\tjd|dtnytj|Wqtjjk
rtj	qXn|j
|||j|||}|j||||\}}|j
|}|d'kr'|
d'k	r'tjj||j|
}|j}nd'}tjtj|jdi}ytjj|}Wn;tk
r¤}tdtj|}tj|nXtj ||}i}t!j"|} |j#j$|| |i|d6|d	6|püd
d6|p	d
d6t%j&d
6t'j(d6|d6|jd6|j)d6|dd6|dd6|dd6|dd6|dd6|d6|	d6|d6|
d6|d6t*d6|p¦id6|d6|d6|
d 6|d!6d"d#6| d$6|d%6|d&6}!|j+||}"|!j,|"|!||fS((siVerify all the input parameters regardless of the provisioning
        strategy being performed.
        tdisabledt	flavor_idRñtlengthtmaxsizeRîs!Invalid image metadata. Error: %streservation_idR[RRïRðRR:RR²R±tinstance_type_idR°R®R-RJRtdisplay_descriptiont	user_datatkey_nametkey_dataRXRÞtaccess_ip_v4taccess_ip_v6RûREitprogresstpci_requestst
numa_topologytsystem_metadataN(-RtFlavorNotFoundRtMAX_USERDATA_SIZEtInstanceUserDataTooLargetbase64tdecodestringtbinasciitErrortInstanceUserDataMalformedRèRíRöR!R@R%tKeyPairtget_by_nameR²t
public_keyR
tprepend_devtproperties_root_device_nameR¨t	ImageMetat	from_dictRRRØt	text_typeRdR.tnuma_get_constraintstpci_requesttget_pci_requests_from_flavorRnt#create_pci_requests_for_sriov_portsRtNOSTATERtBUILDINGR±RRtupdate(#RDRRÅt	boot_metaRlR$RïRðRRvRxRytsecurity_groupsRûRwRÞRzR{RìRRRtRµtltmax_network_counttkey_pairRERDRâR¶R~Rtpci_request_infoRhtoptions_from_image((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _validate_and_build_base_optionss
				








c
CsÉ|j||||\}}|jj|}|jj|tjd|g}g}g}y~xwt|D]i}ttj	}t
jj|||||d|d||
|d	}|j
t
jd|}||_|j|t
jdg|_|
r#|jj
j|
n|j|||||||||	dt	}|j||||}t
j|d|d	|jd
|jd|}|j
|j|t
jd|}||_|j|_d|_|j
|j||j
|j||j||
r¶|rt
jj|d|
|j}yt
jj |d|d
Wqt!j"k
rt#d}t!j$|qXnt
j%j&||
j|jgnt'j(||dt)j*ddddqrWWnØt+k
rºt,j-¹z¦x3|D]+}y|j.Wqt!j/k
r1qXqWx3|D]+}y|j.Wq=t!j0k
rgq=Xq=Wx3|D]+}y|j.Wqst!j1k
rqsXqsWWd|j2XWdQXnX|j3|S(NsGoing to run %s instances...R~R}RûRR%tcreate_instanceRER;R±tblock_device_mappingstserver_group_membersis)Quota exceeded, too many servers in groupR0R(4R¾Rqtpopulate_security_groupstensure_defaultRÂRÃRR¿RBtuuid4R%tRequestSpectfrom_componentstcreatetInstanceRtKeyPairListtkeypairsRÏt create_db_entry_for_new_instanceRt#_bdm_validate_set_size_and_instancetBuildRequestR±tInstanceMappingR;R@tcell_mappingt_create_block_device_mappingRRøR²RRRRt
QuotaErrort
InstanceGrouptadd_membersR$tsend_update_with_statesRRt	ExceptionRtsave_and_reraise_exceptiontdestroytObjectActionErrortInstanceMappingNotFoundtBuildRequestNotFoundtrollbacktcommit(RDRRÅR´RµRhRRR<tshutdown_terminatetinstance_grouptcheck_server_group_quotatfilter_propertiesRRÉR(R¦tinstance_mappingstbuild_requeststiR;treq_specREt
build_requesttinst_mappingRøR¶tinstance_mapping((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_provision_instancess¦			

	
					

		










cCs¢|s
iSx|D]}|rDtj|jdddkrDqn"|rf|jddkrfqn|jd}|jd}|r¬|jj||}|d}n|jdry'|d}|jj||}	|	SWqtk
rtjd	|qXq|ry|jj||}
Wn9tj	k
rCn#tk
retj
d	|nX|
jd
tstjd	|nt
j|
SqWiS(sIf we are booting from a volume, we need to get the
        volume details from Cinder and make sure we pass the
        metadata back accordingly.
        RURtaR_it	volume_idtsnapshot_idR$Rñtbootable(R
tget_device_letterR¨Rotget_snapshotRmRµRtInvalidBDMImagetCinderConnectionFailedtInvalidBDMVolumeRtInvalidBDMVolumeNotBootableRtget_image_metadata_from_volume(RDRR<RiRVRÊRËtsnapshotR$RDR]((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_bdm_image_metadatas@




cCsP|s|jdrdS|jdjd}|s=dStjj||S(Ntscheduler_hintstgroup(R¨R%R²tget_by_uuid(RRÀt
group_hint((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_requested_instance_group3sc%CsS|dkrtjd}n|p*dg}|p6d}|pB|}|pNg}|rr|j||\}}nd}|j|||}|jd|d||j|||||||||	|
|||
|||||||||\}} }!| |krtjn9| |krNt	j
tdi|d6| d6| }n|j||||||||}|j
|||||||j|j||}"|j||||||||||"|||!
}#x$|#D]}$|j||$tjqãW|jj|d	|#d|d
|d|d|d
|d|d|dt	|#|fS(sVerify all the input parameters regardless of the provisioning
        strategy being performed and schedule the instance(s) for
        creation.
        trR4iRRsSmax count reduced from %(max_count)d to %(max_net_count)d due to network port quotaRµt
max_net_countR¦RÀtadmin_passwordRRìRR<RiN(R@Rtgenerate_uidRmRÕt_check_auto_disk_configRRtPortLimitExceededRÂtinfoRRkRoR8RÚRÈRR
tCREATERwtbuild_instancesR(%RDRRÅRlRïRðR´RµRRvRxRyRRûRwRÞRRÝRzR{RìRR<RRÀRtRiR½R¿R$RRhRÜRR¾R¦RE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_create_instance?sj	
			
				
cCs|jd}|dkr|jddkr|jddkr|jddkro|jdd}q|jd	d}n|S(
NR+R`tblankR\tlocaltguest_formatRKiRJ(R¨R@(RÅRVR*((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_volume_sizes!cCs$g}xtj|D]}tjd||d}|dks|dkrTqntj|siqn|jd}|dkrd}n|stj}ntji|dd6d	d
6dd6d
d6|d6t	d6dd6}|j
|||d<|ddkrqn|j|qW|S(s5Extract and format blank devices from image mappings.sImage bdm %stvirtualtamitrootRçRKtdeviceRURåR`RæR\tdisktdevice_typetdelete_on_terminationiÿÿÿÿR_R+i(R
tmappings_prepend_devRÂRÃtis_swap_or_ephemeralR¨Rytdefault_ephemeral_formatRARRèRÏ(RDRÅR>tprepared_mappingsRVtvirtual_nameRçtvalues((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRB¥s6
		
cCswtjdt|d|j|j|||||j}x/|D]'}|j|||_|j|_qHW|S(sêEnsure the bdms are valid, then set size and associate with instance

        Because this method can be called multiple times when more than one
        instance is booted in a single request it makes a copy of the bdm list.
        sblock_device_mapping %sR;(	RÂRÃR@RBt
_validate_bdmt	obj_cloneRèR+R;(RDRRERÅR<tinstance_block_device_mappingRV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¬Ìs

cCsCtj|}x-|D]%}|jdkr1qn|jqWdS(Ni(tcopytdeepcopyR+tupdate_or_create(RDR<tdb_block_device_mappingRV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR°Þs

c	sÑd}tg|D]-}|jdk	r|jdkr|j^q}d|ksb||rtjdt|d|tjnx$|D]}|j}|j	}	|j
}
|
dk	rV|
|jdkrVy|j||
Wn#t
k
rtjd|
nX|jdkr°|jdkr°|jr°tjd	td
q°q|	dk	rîyD|jj||	}|jj||d||jd|_Wq°tjtjfk
rÈq°t
k
rêtjd|	q°Xq|dk	rmy4|jj||}|jp'|jd|_Wq°tjk
rGq°t
k
ritjd|q°Xq|jdkr|jdkr|jrtjd	td
qqWtfd|D}
|
dkrïtjntj|}t|dkr1td}tj d|n|rl|djpGd}|dkrltj!qlnt"j#}|dkrÍtg|D]}|jdkr|^q}||krÍtj$qÍndS(Ncs$tfdtd DS(Nc3s-|]#\}}|d|dkVqdS(iN((RaRÃtel(R(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys	<genexpr>ñsiÿÿÿÿ(tallt	enumerate(R((RsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_subsequent_listîsis;Invalid block device mapping boot sequence for instance: %sRER[RñRR]tmessagesLImages with destination_type 'volume' need to have a non-zero size specifiedR*RåsJBlank volumes (source: 'blank', dest: 'volume') need to have non-zero sizec3s1|]'}tj|r|jp(dVqdS(RJN(R
RNR+(RaRV(RÅ(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys	<genexpr>0sRJis#More than one swap drive requested.tdetailsRKRæ(%tsortedR_R@RÂRÃR@RtInvalidBDMBootSequenceRËRÊR$R¨RmRµRÏR`R\R+t
InvalidBDMRRotcheck_attachRÐt
InvalidVolumeRÑRÎtInvalidBDMSnapshottsumtInvalidBDMEphemeralSizeR
tget_bdm_swap_listRtInvalidBDMFormattInvalidBDMSwapSizeRytmax_local_block_devicestInvalidBDMLocalsLimit(RDRRERÅR RRVtboot_indexesRËRÊR$R]tsnaptephemeral_sizet	swap_listR¶t	swap_sizet	max_localt	num_local((RÅsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRöìs	
!	
			





	cCs¬|jd}|jdr0|jd}nd}|dkr`|j|j}||_n|dkr¨|dkr¨|}|j|j}tj|||_	ndS(s,Populate instance display_name and hostname.RRiN(
R¨tobj_attr_is_setR@t_default_display_nameRBRRRRR(RDRERÉRRtdefault_hostname((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_populate_instance_namesHs	cCsd|S(Ns	Server %s((RDR;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRcscCsd|S(Ns	Server-%s((RDR;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRfsc	Cs`||_tj|_tj|_tj}	|j	|	_
tj|	_
|	|_||_d|_d|_tjjr|jj|dtjj|_n	d|_|jdsÀi|_ntj||_tj||}
|
jd|j |jj!|
||_"|j#||||_$|dkr\|j%dkr\|j&|||}n|S(s&Build the beginning of a new instance.RrRtimage_base_image_refiRN('tlaunch_indexRRR:Rt
SCHEDULINGR>R%tInstanceInfoCacheRBR;t
network_modeltNetworkInfotnetwork_infot
info_cachetflavorR@t
old_flavort
new_flavorRyR{R|R}t
create_keytkey_sizetephemeral_key_uuidRRRtinstance_sys_metatget_system_metadata_from_imaget
setdefaultR[RRRR½RR(RDRRERRRRÅRÉR½R"tsystem_meta((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_populate_instance_for_createis:									c	Cs9|j||||||||	|
r5|jn|S(sTCreate an entry in the DB for this new instance,
        including any related table updates (such as security group,
        etc).

        This is called by the scheduler after a location for the
        instance has been determined.

        :param create_instance: Determines if the instance is created here or
            just populated for later creation. This is done so that this code
            can be shared with cellsv1 which needs the instance creation to
            happen here. It should be removed and this method cleaned up when
            cellsv1 is a distant memory.
        (R-R§(RDRRÅRRER)R<RÉRR½R((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR«s

cCs?x8|D]0}|jrtd}tjd|qqWdS(s=Check whether multiple instances are created from port id(s).sUnable to launch multiple instances with a single configured port ID. Please launch your instance one by one with different ports.RÓN(tport_idRRtMultiplePortsNotApplicable(RDRìt
requested_netR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt,_check_multiple_instances_with_neutron_ports²s
	cCsHxA|D]9}|jr|jrtd}tjd|qqWdS(s?Check whether multiple instances are created with specified ip.s?max_count cannot be greater than 1 if an fixed_ip is specified.RÓN(t
network_idtaddressRRt InvalidFixedIpAndMaxCountRequest(RDRìR0R¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt+_check_multiple_instances_with_specified_ip¼s
Rc!#Cs |rJ|dk	rJ|dkrJ|j|tjrJ|j|qJn|
r¡tj|jt}|dkr¡|
|kr¡t	d}t
j|q¡ntj
||||} |j|||||||||	|
|||
||||||||||d| d|d|d|S(sôProvision instances, sending instance information to the
        scheduler.  The scheduler will determine where the instance(s)
        go and will handle creating the DB entries.

        Returns a tuple of (instances, reservation_id)
        is0The requested availability zone is not availableRÀRiR½R¿N(R@R5Rt
is_neutronR1R	tget_availability_zonestelevatedRRRRdtscheduler_utilstbuild_filter_propertiesRä(!RDRRÅRlRïRðR´RµRRvRxRyR)RûRüRýRwRÞRRÝR<RzR{RìRRRÖRiR½R¿tavailable_zonesR¶RÀ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR§Ås<
					c	Ks±|jd}|dkrdS|r1|r1dS|rj|jdi}tj|}|jd}n0tj|}|jd}tjd|}|j|||dS(NRRîRñRtsys_meta(R¨R@RR	R)t"get_auto_disk_config_from_instanceR(	RDRERtextra_instance_updatesRtimage_propsRR[R<((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRßús	c
CsÖd}ytjj||}Wntjk
r5nX|dksQ|jdkrytjj||}WqÒtj	k
rdSXnMt
j||j6ytjj||}Wntj	k
rËdSXWdQX|S(sñHelper method for pulling an instance object from a database.

        During the transition to cellsv2 there is some complexity around
        retrieving an instance from the database which this method hides. If
        there is an instance mapping then query the cell for the instance, if
        no mapping exists then query the configured nova database.

        Once we are past the point that all deployments can be assumed to be
        migrated to cellsv2 this method can go away.
        N(R@R%R®tget_by_instance_uuidRR¹R¯R¨RØtInstanceNotFoundtnova_contextttarget_cell(RDRRBtinst_mapRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_lookup_instances$	
cCsØ|j||}tjj|d}|dkr7tS|rÔtj||\}}|j|||j||}y<|j	|j
||j}|dk	r®|j
nWntjk
rÏ|jnXtStS(s¿Handle deletion if the instance has not reached a cell yet

        Deletion before an instance reaches a cell needs to be handled
        differently. What we're attempting to do is delete the BuildRequest
        before the api level conductor does.  If we succeed here then the boot
        request stops before reaching a cell.  If not then the instance will
        need to be looked up in a cell db and the normal delete path taken.
        snova-osapi_computeiN(t_attempt_delete_of_buildrequestR%tServicetget_minimum_versionRt
quotas_objtids_from_instancet_create_reservationsR>R¼RERBR@R·RRAR»R(RDRREtdeletedtservice_versionR±R²R(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_delete_while_booting@s*			
cCsBy&tjj||j}|jWntjk
r=tSXtS(N(	R%RR@RBR·RRºRR(RDRREt	build_req((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRFzs	cKsZ|jr&tjtdd|dS|jsg|j||rEdS|j||j}|sgdSntj	j
||j}tj||\}}|j
tjtjfkrg|jjd}	tjtd|	d|y|jj||	Wqgtjtjfk
r:}
tjtd|
jd|qgtk
rctjtdd|qgXn|j}d}y|j|d|_ |j!|j"|||||}|j#dkrç||||d	d|j$dS|j
tjk}
|jr³|
r³yt%j&|j'||d
||j(t%j&|j'||d|d|j|j$tjtd
i|j
d6d|dSWq³tj)k
r¯|j*q³Xn|j
tj+krØ|j,||nt-}yÔ|
stj.j/|j0|j}|j1j2|}n|s±|t3j4t3j5fkr`tjtdd||j6dS|j7||t8j9|j
tj:kr|j6n||||d	|j;nWntj<k
rÈnX|rõ|j=||||||j$nWn]tj>k
r|rV|j6qVn7tk
rUt?j@|rL|j6nWdQXnXdS(Nsinstance termination disabledREtshelved_image_ids8Working on deleting snapshot %s from shelved instance...s5Failed to delete snapshot from shelved instance (%s).sNSomething wrong happened when trying to delete snapshot from shelved instance.iRtreservationss%s.starts%s.endRsIInstance deleted and does not have host field, its vm_state is %(state)s.R<s<Instance is already in deleting state, ignoring this request(Atdisable_terminateRÂRáRRRRNRERBR%tBlockDeviceMappingListR@RIRJR:RtSHELVEDtSHELVED_OFFLOADEDRR¨RmtdeleteRt
ImageNotFoundtImageNotAuthorizedtwarningRRÜRµRR>R@RR|tsaveRKRR¼t
compute_utilstnotify_about_instance_usageRzR·R¸trefreshtRESIZEDt_confirm_resize_on_deletingRRGtget_by_compute_hostR8Rxt
service_is_upRtDELETINGt
SOFT_DELETINGR»RR
tDELETEtSOFT_DELETEDRQtComputeHostNotFoundt
_local_deleteRARR¶(RDRREtdelete_typetcbtinstance_attrstbdmsR±R²RËRtoriginal_task_stateR(tshelved_offloadedtis_local_deleteR0((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_deletes¼			

	
	
	




		
	




cCs`d}xdD]y}y\tjj|j|j|}tjtdi|j	d6|j
d6d|d|PWq
tjk
rq
Xq
W|s³tjtdd|d|dS|j
}ytj||}Wn7tk
rtjtd	|j	d|d|dSXtj|||}|j||tj|jj|||||jd
tdS(Ntfinishedt
confirmingsLFound an unconfirmed migration during delete, id: %(id)s, status: %(status)sRñR"RREs.Instance may have been confirmed during deletes2Migration %s may have been confirmed during deletetcast(sfinisheds
confirming(R@R%t	Migrationtget_by_instance_and_statusR8RBRÂRáRRñR"RtMigrationNotFoundByStatustsource_computeR[tdownsize_quota_deltaRtreserve_quota_deltaRR
tCONFIRM_RESIZERttconfirm_resizeRQR(RDRREt	migrationR"tsrc_hostR©R(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR_s<
	



	


cCs§|tjtjfkrO|j}|j}|jjdd}|j|}	n|jj}|jj}	t	j
d|}
|
jd|d|ddd|d	|	|
S(
Nshw_video:ram_max_mbiRR±R²R¦iÿÿÿÿR¥R§(RtRESIZE_MIGRATEDt
RESIZE_FINISHR$R®R¯R¨R°R#R%RR¼(RDRRERlR±R²R$tinstance_vcpusRÇtinstance_memory_mbR(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRKJs			cCsd|kr|jdk	rtj|jjd}|r|jd|jkrX|Stjdi|jdd6|jd6d|qndS(	swLookup a connector dict from the bdm.connection_info if set

        Gets the stashed connector dict out of the bdm.connection_info if set
        and the connector host matches the instance host.

        :param bdm: nova.objects.block_device.BlockDeviceMapping
        :param instance: nova.objects.instance.Instance
        :returns: volume connector dict or None
        tconnection_infot	connectorRRsFound stashed volume connector for instance but connector host %(connector_host)s does not match the instance host %(instance_host)s.tconnector_hostt
instance_hostREN(RR@RtloadsR¨RRRÂRÃ(RDRVRER((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_stashed_volume_connectorbs
	c	Csÿ|j}xì|D]ä}|jríy|j||}|rY|jj||j|ntjd|jd||jj||j|j	|j
r°|jj||jnWqítk
ré}t
d}tj||d|qíXn|jqWdS(sThe method deletes the bdm records and, if a bdm is a volume, call
        the terminate connection and the detach volume via the Volume API.
        sLUnable to find connector for volume %s, not attempting terminate_connection.REs)Ignoring volume cleanup failure due to %sN(R8R4RRotterminate_connectionRÊRÂRÃtdetachRBRïRVRµRRYR·(	RDRkRERR8RVRRterr_str((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_local_cleanup_bdm_volumes|s(
	
	
	c
CsW|jtjkr.tjtdd|ntjtd|jd|t	j
|j||d||j}|j
dkrô|j}zV|jtjkrÐt|tjd}|jd|_n|jj||Wd||_Xn|j|||||||dt|j}	|jt	j
|j||d	|d|	dS(
NsRinstance is in SHELVED_OFFLOADED state, cleanup the instance's info from database.REs2instance's host %s is down, deleting from databases%s.startRRtshelved_hostRæs%s.end(R:RRURÂRáRRYRRRR[R\RzR8RRtobj_basetget_attrnameR¨Rntdeallocate_for_instanceRRRR·(
RDRRERkRhRiR8t	orig_hosttsysmetaR<((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRgs2
		
	
cCs]|r7tj|_d|_tj|_|jn"|j	j
|||d|dddS(NRQRhRV(RtDELETEDR:R@R>Rtutcnowt
terminated_atRZRttterminate_instance(RDRRERkRQRæ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
_do_deleteÃs	
cCs]|r7tj|_d|_tj|_|jn"|j	j
|||d|dddS(NRQRhtforce_delete(RRR:R@R>RRRRZRtR(RDRRERkRQRæ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_do_force_deleteÏs	
cCsT|r7tj|_d|_tj|_|jn|j	j
||d|dS(NRQ(RReR:R@R>RRRRZRttsoft_delete_instance(RDRRERkRQRæ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_do_soft_deleteÛs	
R:R>RIc	CsEtjdd||j||d|jdtjdtjdS(sTerminate an instance.s$Going to try to soft delete instanceREtsoft_deleteR>t
deleted_atN(RÂRÃRoRRRcRR(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRçs
	cCs&|j||d|jdtjdS(NRVR>(RoRRRb(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_delete_instanceôscCs'tjdd||j||dS(sTerminate an instance.s"Going to try to terminate instanceREN(RÂRÃR(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRVøsc	Cs|j}tj||\}}|j||ddd|d|\}}|j||tjy|jr®tj	|_
d|_|j
ddg|jj||n1tj|_d|_
d|_|j
ddg|jWn.tk
rtj|jWdQXnXdS(s:Restore a previously deleted (but not reclaimed) instance.iR±R²texpected_task_stateN(t
get_flavorRIRJR¾RR
tRESTORERRRt	RESTORINGR>R@RRZRttrestore_instanceRtACTIVER:R¼RµRR¶R»(RDRRER#R±R²RÉR(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytrestores(				

cCs&|j||d|jdtjdS(s4Force delete an instance in any vm_state/task_state.RR>N(RoRRRb(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRscCsttjdd|tj|_d|_|jddg|j||t	j
|jj||d|d|dS(NsGoing to try to stop instanceREiRtdo_casttclean_shutdown(
RÂRÃRtPOWERING_OFFR>R|RZR@RR
tSTOPRtt
stop_instance(RDRRER¤R¥((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
force_stop&s	cCs|j||||dS(sStop an instance.N(R©(RDRRER¤R¥((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytstop2scCs_tjdd|tj|_|jddg|j||tj	|j
j||dS(sStart an instance.sGoing to try to start instanceRERN(RÂRÃRtPOWERING_ONR>RZR@RR
tSTARTRttstart_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytstart:s
cCs@tjdd||j||tj|jj||dS(s"Trigger crash dump in an instance.sTry to trigger crash dumpREN(RÂRÃRR
tTRIGGER_CRASH_DUMPRtttrigger_crash_dump(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR°Ks
cCs:ytjj||}Wntjk
r5d}nX|S(N(R%R®R@RR¹R@(RDRR;RD((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_instance_map_or_noneXs	
cCstjj|d}|dkr:tjj||d|S|j||}|r|jdk	rtj	||j tjj||d|}WdQXnè|rh|jdkrhy"tj
j||}|j}Wqt
jk
rd|j||}|rF|jdk	rFtj	||j tjj||d|}WdQXqetjj||d|}qXntjj||d|}|S(Nsnova-osapi_computeitexpected_attrs(R%RGRHR¨RØR±R¯R@RBRCRR@RERRº(RDRR;R²RMRDRERO((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
_get_instancecs:			
			
					cCsÅ|sg}n|jddddgy`tj|retjdd||j|||}n"tjd|tjd|Wn6tjk
rÀtjd	|tjd|nX|S(
s1Get a single instance with the given instance_id.RÞRRR"sFetching instance by UUIDR;s!Failed to fetch instance by id %sRQsInvalid instance id %s(	textendRtis_uuid_likeRÂRÃR³RRAt	InvalidID(RDRRQR²RE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¨s 	
cs|dkri}ntjdt|ifd}fd}	fd}
fd}idd6dd	6d
d6|d6|	d
6|
d6|d6}xtj|D]\}
}y||
}Wntk
rî||
<q·Xt|tjr||<q·y||Wq·t	k
r6t
jSXq·WdkpPdk}|}|r{|r{tjdd}nt
jj
d|d|d|d|}t
jdg|D]}|j^q¸}|ræ|t|n|}yt
jjt
jj}Wn&tjk
r3t
jdg}nwXtj|by4|jd|d|d|d|d|}Wn&tjk
r£t
jdg}nXWdQX|rÀ|t|n|}|dksÞ|dkr|jd|d|d|d|d|}nt
jdg}d}|}t
jdtt||j
|j
|j
}|r|j||}n|S(snGet all instances filtered by one of the given parameters.

        If there is no filter and the context is an admin, it will retrieve
        all instances in the system.

        Deleted instances will be returned by default, unless there is a
        search option that says otherwise.

        The results will be sorted based on the list of sort keys in the
        'sort_keys' parameter (first value is primary sort key, second value is
        secondary sort ket, etc.). For each sort key, the associated sort
        direction is based on the list of sort directions in the 'sort_dirs'
        parameter.
        sSearching by: %scs&tjj|}|jd<dS(NRu(R%tFlavortget_by_flavor_idRñ(RqR#(Rtfilters(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_remap_flavor_filterÊscsd|jddd<dS(Ns^%s$t.s\.tip(treplace(tfixed_ip(R¹(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_remap_fixed_ip_filterÎscstj|d<dS(NRÞ(RR(RÞ(R¹(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_remap_metadata_filterÓscstj|d<dS(NR(RR(RÞ(R¹(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_remap_system_metadata_filterÖsR[RRRR±t	tenant_idR#R¾RÞRtip6R¼s,Removing limit for DB query due to IP filtertlimittmarkert	sort_keyst	sort_dirsR%R²Nicstfd}|S(Ncs'|jkrtSj|jtS(N(RBRtaddR(RE(t
seen_uuids(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_filter.	s(RO(RÊ((RÉsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_get_unique_filter_method+	s	(R@RÂRÃR¿RØRÙRRNtstring_typesRR%tInstanceListtBuildRequestListtget_by_filtersRERtCellMappingRØt
CELL0_UUIDRtCellMappingNotFoundRBRCt_get_instances_by_filterstMarkerNotFoundR@RMt
_ip_filter(RDRtsearch_optsRÄRÅR²RÆRÇRºR¿RÀRÁtfilter_mappingtoptRjtremap_objectt	filter_ipt
orig_limitRÂROtbuild_req_instancest
cell0_mappingtcell0_instancestcell_instancesRËt
filter_methodR¦((RR¹sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_all²s	




				
				
cstjt|jdtjt|jdfd}g}xF|D]>}||r[|j||rt||krPqq[q[Wtjd|S(NR¼RÃcstj|}x|D]}xx|jD]j}|jd}|sJq)n|jd}|dkrtj|s|dkr)j|r)tSq)WqWtS(NR3tversionii(R[tget_nw_info_for_instancet	fixed_ipsR¨tmatchRR(REtnw_infotvifR¾R3Râ(tipv4_ftipv6_f(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_match_instanceI	s
R%(tretcompileR¿R¨RÏRR%RÍ(tinst_modelsR¹RÄRêtresult_objsRE((RèRésE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÕD	s


c	Cs\ddddg}|r(|j|ntjj|d|d|d|d|d	|d
|S(NRÞRR"RR¹RÄRÅR²RÆRÇ(R´R%RÍRÏ(	RDRR¹RÄRÅR²RÆRÇR&((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÓ^	s			c
Cs¤|jdr||j||j||j}|ro|jdk	rotj||j|jWdQXq |jn$y<t	j
j||j}|j}|j||jWnåt
jk
rddddddd	d
g}|j||j}|rg|jdk	rgtj||j:t	jj||jd|}|j||jWdQXq t	jj||jd|}|j||jnX|S(shUpdates a single Instance object with some updates dict.

        Returns the updated instance.
        RñNR#tpci_devicesR~ttagsRÞRRR"R²(RRR±RBR¯R@RBRCRZR%RR@RERRºR¨RØ(RDRREtupdatesRDROR²((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytupdate_instancei	s@	

		
					
		
	
c	Cs³t|d|}tj||rRtjtdd|d|tjn|j|||dd|}t	j
|_|jdd	g|jj|||d|||S(
s
Backup the given instance

        :param instance: nova.objects.instance.Instance object
        :param name: name of the backup
        :param backup_type: 'daily' or 'weekly'
        :param rotation: int representing how many backups to keep around;
            None if rotation shouldn't be used (as in the case of snapshots)
        :param extra_properties: dict of extra image properties to include
                                 when creating the image.
        :returns: A dict containing image metadata
        tbackup_types4It's not supported to backup volume backed instance.RREtbackuptextra_propertiesRRñN(RÀR[tis_volume_backed_instanceRÂRáRRRdt
_create_imageRtIMAGE_BACKUPR>RZR@Rttbackup_instance(	RDRRERRótrotationRõt
props_copyRD((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRô¶	s
		cCs[|j|||dd|}tj|_|jddg|jj|||d|S(sGSnapshot the given instance.

        :param instance: nova.objects.instance.Instance object
        :param name: name of the snapshot
        :param extra_properties: dict of extra image properties to include
                                 when creating the image.
        :returns: A dict containing image metadata
        RÔRõRRñN(R÷RtIMAGE_SNAPSHOT_PENDINGR>RZR@Rttsnapshot_instance(RDRRERRõRD((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÔß	s	cCsi|jd6t|jd6|d6}|j|p6i|j|||}|dkr~|jdd|jddn|jj||S(sµCreate new image entry in the image service.  This new image
        will be reserved for the compute manager to upload a snapshot
        or backup.

        :param context: security context
        :param instance: nova.objects.instance.Instance object
        :param name: string for name of the snapshot
        :param image_type: snapshot | backup
        :param extra_properties: dict of extra image properties to include

        R;R²t
image_typeRÔtdisk_formattcontainer_formatN(	RBR¿R²Rt&_initialize_instance_snapshot_metadatatpopR@RmR§(RDRRERRþRõRîRD((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR÷ù	s

cCsrtj|j}|ji|d6td6|d}x!tjD]}|j|dqAW|j|pji|S(s?Initialize new metadata for a snapshot of the given instance.

        :param instance: nova.objects.instance.Instance object
        :param name: string for name of the snapshot
        :param extra_properties: dict of extra metadata properties to include

        :returns: the new instance snapshot metadata
        Rt	is_publicRîN(	Rtget_image_from_system_metadataRRRRyt non_inheritable_image_propertiesRR@(RDRERRõRDRîRi((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR
s

cCsn|j|||}d|d<xdD]}|j|dq&W|d}xdD]}|j|dqQW|jr|j|d<nt}	|jtjkr1y|jj	||t
}	Wq1tjtj
tjtfk
r-}
tj|jjd	rq.tjtd
i|
d6d|d
|q1Xntjj||j}g}xÍ|D]Å}
|
jrkqVn|
jr|jj||
j}td|d}tj d|dd
||jj!||d||d}t"j#|d|
}|j$}n|
j$}|j%|qVW|	r>|jj&|||n|r[||d<t
|d<n|j'j(||S(sSnapshot the given volume-backed instance.

        :param instance: nova.objects.instance.Instance object
        :param name: name of the backup or snapshot
        :param extra_properties: dict of extra image properties to include

        :returns: the new image metadata
        iR*RRÿRîR<R=REtimage_os_require_quiesces(Skipping quiescing instance: %(reason)s.RÓRREssnapshot for %sRs!Creating snapshot from volume %s.RñRv(scontainer_formatsdisk_formatN(sblock_device_mappingsbdm_v2sroot_device_name()RRR@RERR:RR¢Rttquiesce_instanceRRtInstanceQuiesceNotSupportedtQemuGuestAgentNotEnabledt
NovaExceptiontNotImplementedErrorRR
RR¨RÂRáRR%RSR@RBt	no_deviceR4RoRÊRRÃtcreate_snapshot_forceR
tsnapshot_from_bdmtget_image_mappingRÏtunquiesce_instanceRmR§(RDRRERRõRDR9RîRitquiescedterrRktmappingRVR]RÔtmapping_dict((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytsnapshot_volume_backed3
s`



	

	
			
	

cCs3|dkr|j||n|j||dS(sReboot the given instance.tSOFTN(t_soft_reboott_hard_reboot(RDRREtreboot_type((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytreboot
scCsadg}tj|_|jd||j||tj|jj	|d|dddddS(NRREtblock_device_infoRR(
R@Rt	REBOOTINGR>RZRR
tREBOOTRttreboot_instance(RDRRER((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR
s	cCstj|_dtjtjtjtjtjtjtj	g}|j
d||j||tj
|jj|d|dddddS(NRRERRtHARD(RtREBOOTING_HARDR>R@RtREBOOT_PENDINGtREBOOT_STARTEDtRESUMINGt	UNPAUSINGt
SUSPENDINGRZRR
RRtR(RDRRER((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR
scs-jpd}|pg}|jdi}|jdt}	|jd}
|j||\}|jd|jtj|}|j||||||j	|dd\}
}fd}|j|
}j|t
j_|_|
p&d_|p5d_d_j|jddg|}tjj|j}|j|tjytjj|j}Wntjk
rÓd}nX|jj|d	d
|d|d|d
|d|d|d|	dj d|d|dS(s8Rebuild the given instance with the provided attributes.RRÞtpreserve_ephemeralRRcs~tj}x<tjjD]%}|jtjr%j|=q%q%Wtj}jj|j	|S(sÂRemove old image properties that we're storing as instance
            system metadata.  These properties start with 'image_'.
            Then add the properties for the new image.
            (
RÀRR@Rdt
startswithRtSM_IMAGE_PROP_PREFIXR*RRZ(torig_sys_metadataRitnew_sys_metadata(R#RRE(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_reset_image_metadataÃ
s
iRREtnew_passRR[torig_image_refR)RkRRtrequest_specRTN(!R[R¨RRmRßRR[ReRoRöR@RRRt
REBUILDINGR>RïRðR|RZR%RSR@RBRR
tREBUILDR¥RtRequestSpecNotFoundRwtrebuild_instanceRR(RDRRERlRÝRnRTR-RÞR&RR$R8RïRðR+RR)RkR.((R#RREsE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytrebuild«
sP
		
			
cCs|j}tjj||jd}tj||}tj|||}tj	|_
y|jddgWn.t
k
r¡tj|jWdQXnXd|_|jtjjrÎ|jn|j||tj|jj||||j|jpgdS(s=Reverts a resize, deleting the 'new' instance in the process.RpRNt	reverting(R8R%RsRtRBR[treverse_upsize_quota_deltaRxRtRESIZE_REVERTINGR>RZR@RµRR¶R»R"RytcellstenableR¼RR
t
REVERT_RESIZERtt
revert_resizetdest_computeRQ(RDRRER8R{R©R(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR:	s*	

	


cCsË|j}|dkr6tjj||jd}ntj||}tj|||}d|_	|j
tjj
r|jn|j||tj|jj||||j|jpÃgdS(s;Confirms a migration/resize and deletes the 'old' instance.RpRqN(R8R@R%RsRtRBR[RwRxR"RZRyR7R8R¼RR
RyRtRzRvRQ(RDRRER{R8R©R(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRz,s"		


cCs|jtjd|j}|j|_|d|_|d|_d|_|j|jkridpld|_	|j
dS(s"Special API cell logic for resize.RRñRptresizeR{N(R¼R%RsR8RBR;told_instance_type_idtnew_instance_type_idR"tmigration_typeR§(RR(REtcurrent_instance_typetnew_instance_typetmig((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_resize_cells_supportJs


	cKsÐ|j|||j}|s>tjdd||}nstj|dd}|jddkr±|jddkr±tj||r±t	d}t
jd|n|sÌt
jd	|n|d
}	|d
}
tjdi|	d6|
d
6d||d|dk}|rC|jdrCt
jd	|n|rm|rm|j
dkrmt
jn|rhtj|||}ytj|||}
Wqzt
jk
rd}|jd}
|jd}|jd}|j|
||}|j|||
|\}}}}tjtdi|d6|jd6t
jd|d|d|d|qzXntjd|}
tj|_d|_|j||j dd#gigd6}t"j#sÜ|dj$|j%n|j
dkr|j&||
|||n|s&|j'||t(j)n|j'||t(j*y)tj+j,||j-}|d|_.Wnt
j/k
rd#}nXi|d6}|j0j1|||d|d|d |
j2p¼gd!|d"|d#S($sResize (ie, migrate) a running instance.

        If flavor_id is None, the process is considered a migration, keeping
        the original flavor_id. If flavor_id is not None, the instance should
        be migrated to a new host and resized to the new flavor_id.
        s&flavor_id is None. Assuming migration.REtread_deletedtnoR-is*Resize to zero disk flavor is not allowed.RÓRqRs^Old instance type %(current_instance_type_name)s, new instance type %(new_instance_type_name)stcurrent_instance_type_nametnew_instance_type_nameRñRpR1R(RR¤s?%(overs)s quota exceeded for %(pid)s, tried to resize instance.R³R·R¸R¹RRtignore_hostsRRÀtscheduler_hintR#RQR¥R.N(3RßRRÂRÃRtget_flavor_by_flavor_idR¨R[RöRRtCannotResizeDiskRRtCannotResizeToSameFlavortupsize_quota_deltaRxRRTRRÁRYRR±RÄR%RRtRESIZE_PREPR>R|RRZR@Rytallow_resize_to_same_hostRÏRRRCRR
tMIGRATEtRESIZER¥R@RBRHR1Rwtresize_instanceRQ(RDRRERqR¥R>R@RARÓRFRGtsame_instance_typeR©R(RRR¤RªRËRÌRÍRÀR.RI((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR<as		


	


		



	

	


	

cCs»tj|_|jddg|j||tjtj	||sd|j
}|j|||d}|d}|jj
|d|d|d|n|jj|d|d|dS(	swShelve an instance.

        Shuts down an instance and frees it up to be removed from the
        hypervisor.
        Rs
%s-shelvedRÔRñRER$R¥N(RtSHELVINGR>RZR@RR
tSHELVER[RöRR÷Rttshelve_instancetshelve_offload_instance(RDRRER¥RRDR$((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytshelveÛs	
	
cCs?tj|_|jddg|jj|d|d|dS(s.Remove a shelved instance from the hypervisor.RRER¥N(RtSHELVING_OFFLOADINGR>RZR@RtRW(RDRRER¥((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytshelve_offloadôscCstj|_|jddg|j||tjytj	j
||j}Wntj
k
rmd}nX|jj|||dS(sRestore a shelved instance.RN(Rt
UNSHELVINGR>RZR@RR
tUNSHELVER%R¥R@RBRR1Rwtunshelve_instance(RDRRER.((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytunshelveþs	
cCs |jj|d|d|dS(s6Add fixed_ip from specified network to given instance.RER2N(Rttadd_fixed_ip_to_instance(RDRRER2((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytadd_fixed_ipscCs |jj|d|d|dS(s9Remove fixed_ip from specified network to given instance.RER3N(Rttremove_fixed_ip_from_instance(RDRRER3((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytremove_fixed_ipscCsLtj|_|jddg|j||tj|jj	||dS(sPause the given instance.RN(
RtPAUSINGR>RZR@RR
tPAUSERttpause_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytpausescCsLtj|_|jddg|j||tj|jj	||dS(sUnpause the given instance.RN(
RR$R>RZR@RR
tUNPAUSERttunpause_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytunpause(scCs|jj|d|S(s,Retrieve diagnostics for the given instance.RE(Rttget_diagnostics(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRj2scCs|jj|d|S(s,Retrieve diagnostics for the given instance.RE(Rttget_instance_diagnostics(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRk7scCsLtj|_|jddg|j||tj|jj	||dS(sSuspend the given instance.RN(
RR%R>RZR@RR
tSUSPENDRttsuspend_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytsuspend=scCsLtj|_|jddg|j||tj|jj	||dS(sResume the given instance.RN(
RR#R>RZR@RR
tRESUMERttresume_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytresumeGsc

Cstjj||j}xE|D]=}|jr|jj||j}|jj||qqWtj	|||rt
d}	tjd|jd|	nt
j|_|jdd	g|j||tj|jj|d|d|d|d|d	S(
sRescue the given instance.s&Cannot rescue a volume-backed instanceRQRÓRREtrescue_passwordtrescue_image_refR¥N(R%RSR@RBRÊRoR¨tcheck_attachedR[RöRRtInstanceNotRescuableRtRESCUINGR>RZR@RR
tRESCUERttrescue_instance(
RDRRERrRsR¥RkRVtvolRÓ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytrescueQs 	
	cCsOtj|_|jddg|j||tj|jj	|d|dS(sUnrescue the given instance.RREN(
Rt
UNRESCUINGR>RZR@RR
tUNRESCUERttunrescue_instance(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytunrescuelscCsUtj|_|jddg|j||tj|jj	|d|d|dS(sÕSet the root/admin password for the given instance.

        @param context: Nova auth context.
        @param instance: Nova instance object.
        @param password: The admin password for the instance.
        RRER,N(
RtUPDATING_PASSWORDR>RZR@RR
tCHANGE_PASSWORDRttset_admin_password(RDRREtpassword((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRws

cCsl|jj|d|d|}|jj||d||d|d|d|jd|di|dd6S(	s!Get a url to an instance Console.REtconsole_typettokenRRtporttinternal_access_patht
access_urlturl(Rttget_vnc_consoleRrtauthorize_consoleRB(RDRRERtconnect_info((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRs
cCs"|jj|d|d|}|S(s)Used in a child cell to get console info.RER(RtR(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_vnc_connect_infoscCsl|jj|d|d|}|jj||d||d|d|d|jd|di|dd6S(	s!Get a url to an instance Console.RERRRRRRRR(Rttget_spice_consoleRrRRB(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR s
cCs"|jj|d|d|}|S(s)Used in a child cell to get console info.RER(RtR(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_spice_connect_infoscCsl|jj|d|d|}|jj||d||d|d|d|jd|di|dd6S(	s!Get a url to an instance Console.RERRRRRRRR(Rttget_rdp_consoleRrRRB(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR´s
cCs"|jj|d|d|}|S(s)Used in a child cell to get console info.RER(RtR(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_rdp_connect_infoÁscCsl|jj|d|d|}|jj||d||d|d|d|jd|di|dd6S(	sGet a url to a serial console.RERRRRRRRR(Rttget_serial_consoleRrRRB(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÈs
cCs"|jj|d|d|}|S(s+Used in a child cell to get serial console.RER(RtR(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_serial_console_connect_infoÕscCsl|jj|d|d|}|jj||d||d|d|d|jd|di|dd6S(	sGet a url to a MKS console.RERRRRRRRR(Rttget_mks_consoleRrRRB(RDRRERR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÜs
cCs|jj|d|d|S(s#Get console output for an instance.REttail_length(Rttget_console_output(RDRRER((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRèscCsv|j|jk}|jr%|r%dS|j}tjdd|d|t|_|r_dnd|_|jdS(sLock the given instance.NtLockingRREtownertadmin(R±RXR8RÂRÃRt	locked_byRZ(RDRREtis_owner((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytlockîs	cCsG|j|jk}|rdnd}|j}|rC||krCtStS(NRR(R±RRR(RDRRERtexpect_locked_byR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytis_expected_locked_byûs	cCsE|j}tjdd|d|t|_d|_|jdS(sUnlock the given instance.t	UnlockingRREN(R8RÂRÃRRXR@RRZ(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytunlock
s
		cCs|jj|d|dS(s!Reset networking on the instance.REN(Rtt
reset_network(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR 
scCs|jj|d|dS(s%Inject network info for the instance.REN(Rttinject_network_info(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¡
sc	Cs|r^tjd|ddddd|jddd|ddd	dd
|d|
}|jn'|jj||||d
|d|}|S(NRR`R]R\R;R_RÊRURçtdisk_busRî(R%tBlockDeviceMappingRBR@R§Rttreserve_block_device_name(	RDRRERìRÊR¢Rîtis_local_creationt
volume_bdm((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_create_volume_bdm
s	
		cCsE|jj||}|jj||d||jj||dS(NRE(RoR¨tcheck_availability_zonetreserve_volume(RDRRÊRER]((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _check_attach_and_reserve_volume2
sc	Cs|j||||d|d|}y-|j||||jj|||Wn.tk
rtj|jWdQXnX|jS(sAttach an existing volume to an existing instance.

        This method is separated to make it possible for cells version
        to override it.
        R¢RîN(	R§RªRtt
attach_volumeRµRR¶R·RU(RDRRERÊRìR¢RîR¦((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_attach_volume8
s	

cCs|j||||d|d|dt}y3|j||||jj|||j|Wn.tk
rtj|j	WdQXnX|j
S(sAttach an existing volume to an instance in shelved offloaded state.

        Attaching a volume for an instance in shelved offloaded state requires
        to perform the regular check to see if we can attach and reserve the
        volume then we need to call the attach method on the volume API
        to mark the volume as 'in-use'.
        The instance at this stage is not managed by a compute manager
        therefore the actual attachment will be performed once the
        instance will be unshelved.
        R¢RîR¥N(R§RRªRotattachRBRµRR¶R·RU(RDRRERÊRìR¢RîR¦((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _attach_volume_shelved_offloadedK
s


cCs{|r+tj|r+tjd|n|jtjk}|r_|j||||||S|j||||||S(s2Attach an existing volume to an existing instance.R(	R
tmatch_deviceRtInvalidDevicePathR:RRUR®R¬(RDRRERÊRìR¢Rîtis_shelved_offloaded((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR«g
s	cCs4|jj||d||jj||ddS(NRERñ(Rotcheck_detachtbegin_detaching(RDRR]RE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_check_and_begin_detach
sc	Cs~|j||||jdi}d}|rT|j|krT||jd}n|jj|d|d|dd|dS(sDetach volume from instance.

        This method is separated to make it easier for cells version
        to override.
        tattachmentst
attachment_idRERÊRñN(R´R¨R@RBRtt
detach_volume(RDRRER]RµR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_detach_volume
scCsL|j|||tjj||d|jg}|j|||dS(soDetach a volume from an instance in shelved offloaded state.

        If the instance is shelved offloaded we just need to cleanup volume
        calling the volume api detach, the volume api terminate_connection
        and delete the bdm record.
        If the volume has delete_on_termination option set then we call the
        volume api delete as well.
        RñN(R´R%R£tget_by_volume_idRBR(RDRRER]Rk((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _detach_volume_shelved_offloaded
s		cCs?|jtjkr(|j|||n|j|||dS(s!Detach a volume from an instance.N(R:RRURºR¸(RDRRER]((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR·¢
sc	Cs»|ddkr)tjd|dn|jdij|jshtd}tjd|n|ddkrtd	}tjd|nt|d
t|d
krÚtd}tjd|n|jj|||jj	||d||jj
||d|jj||dy.|jj
|d|d
|dd|dWnRtk
r¶tj3|jj||d|jj||dWdQXnXdS(s$Swap volume attached to an instance.t
attach_statustdetachedRÊRñRµs/Old volume is attached to a different instance.RÓtattacheds-New volume must be detached in order to swap.R*s+New volume must be the same size or larger.REt
old_volume_idt
new_volume_idN(RtVolumeUnattachedR¨RBRRRºRoR²RR³R©Rttswap_volumeRµRR¶troll_detachingtunreserve_volume(RDRREt
old_volumet
new_volumeR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÁ®
s0 	


c
Cs(|jj|d|d|d|d|S(s5Use hotplug to add an network adapter to an instance.RER2R.trequested_ip(Rttattach_interface(RDRRER2R.RÆ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÇÏ
scCs |jj|d|d|dS(s+Detach an network adapter from an instance.RER.N(Rttdetach_interface(RDRRER.((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÈÚ
scCs|jj||jS(s-Get all metadata associated with an instance.(tdbtinstance_metadata_getRB(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_instance_metadataã
scCs|j||ddS(Nt
metadata_typeRÞ(t_get_all_instance_metadata(RDRtsearch_filts((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_all_instance_metadataç
scCs|j||ddS(NRÌR(RÍ(RDRRÎ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_all_system_metadataë
scCs=|j|diddgddg}tjd|||S(sGet all metadata.R¹RÆt
created_atRÇtdescRE(RÓRt#filter_and_format_resource_metadata(RDRRÎRÌR¦((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÍï
s
	cCs7|j||jj|d|didg|6dS(s0Delete the given metadata item from an instance.REtdiffR`N(tdelete_metadata_keyRttchange_instance_metadata(RDRRERi((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytdelete_instance_metadata÷
s
cCst|j}|r|}nt|j}|j||j||||_|jt||j}|jj|d|d||S(s¥Updates or creates instance metadata.

        If delete is True, metadata items that are not specified in the
        `metadata` argument will be deleted.

        RERÔ(RÀRÞRRãRZRkRtRÖ(RDRRERÞRVRft	_metadataRÔ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytupdate_instance_metadatas	
	
c
Cstjd|pdd|tj|_|jddg|j||tj	yt
jj||j
}Wntjk
rd}nX|tkr|rt
jj||}	|	sÌtjd|nd}|	d}
|rt
jd|
jd|
j}||_qny2|jj|||d|d	|d
|d|Wn<tjk
r}tjtj|||WdQXnXdS(
s&Migrate a server lively to a new host.s+Going to try to live migrate instance to %ssanother hostRERRRitnodetblock_migrationtdisk_over_commitR.tasyncN( RÂRÃRt	MIGRATINGR>RZR@RR
tLIVE_MIGRATIONR%R¥R@RBRR1RtComputeNodeListtget_all_by_hostRftDestinationRRthypervisor_hostnametrequested_destinationRwtlive_migrate_instancetoslo_exceptionstMessagingTimeoutRR¶R[tadd_instance_fault_from_exc(
RDRRERÛRÜt	host_nametforceRÝR.tnodesttargettdestinationtmessaging_timeout((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytlive_migrates@	
	

		
	c	Cstjdd|tjj|||j}|jdkrjtjd|d|jd|jddn|j	||t
j|jj
|||d	S(
sÇForce live migration to complete.

        :param context: Security context
        :param instance: The instance that is being migrated
        :param migration_id: ID of ongoing migration

        s0Going to try to force live migration to completeREtrunningtmigration_idR;R<R=sforce completeN(RÂRÃR%Rstget_by_id_and_instanceRBR"RtInvalidMigrationStateRR
tLIVE_MIGRATION_FORCE_COMPLETERttlive_migration_force_complete(RDRRERñR{((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytlive_migrate_force_completeYs				c	Cs£tjj|||j}tjd|jd||jdkrptj	d|d|jd|jddn|j
||tj|j
j|||jd	S(
sÓAbort an in-progress live migration.

        :param context: Security context
        :param instance: The instance that is being migrated
        :param migration_id: ID of in-progress live migration

        s!Going to cancel live migration %sRERðRñR;R<R=sabort live migrationN(R%RsRòRBRÂRÃRñR"RRóRR
tLIVE_MIGRATION_CANCELRttlive_migration_abort(RDRRERñR{((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytlive_migrate_abortys			
cCstjdd||j}tjj||}|jj|rntjt	d|t
jd|ntj
|_|jddg|j||tjtj|d|jd|jd|jd	d
dd}	|rë||	_n|	jtj|j||d
ytjj||j}
Wnt
jk
rFd}
nX|tkrÌ|rÌtj j!||}|st
j"d|nd}|d}|
rÌtj#d|jd|j$}
|
|
_%qÌn|j&j'|d|d|dddddddddddt(d|d|d|
S(séRunning evacuate to target host.

        Checking vm compute host state, if the host not in expected_state,
        raising an exception.

        :param instance: The instance to evacuate
        :param host: Target host. if not set, the scheduler will pick up one
        :param on_shared_storage: True if instance files on shared storage
        :param admin_password: password to set on rebuilt instance
        :param force: Force the evacuation to the specific host target

        svm evacuation scheduledREsHInstance compute service state on %s expected to be down, but it was up.RRRRvtsource_nodeR;R"tacceptedR?t
evacuationtevacuateiRÚR,RR[R-R)Rktrecreateton_shared_storageR.N()RÂRÃRRR%RGR`RxRaterrorRRtComputeServiceInUseRR/R>RZR@RR
tEVACUATERsRÚRBR;R§R[R\RzR¥R@R1RRàRáRfRâRãRäRwR2R(RDRRERRRÿRÝRêt	inst_hostR0R{R.RëRìRí((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRýsb					
	

		cCstjj||S(s)Get all migrations for the given filters.(R%t
MigrationListRÏ(RDRR¹((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_migrationsìscCstjj|||S(s.Get all migrations of an instance in progress.(R%Rtget_in_progress_by_instance(RDRR;R?((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt&get_migrations_in_progress_by_instanceðs	cCstjj|||S(s'Get the migration of an instance by id.(R%RsRò(RDRRñR;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt get_migration_by_id_and_instanceös	cCsbtjj||ddg}|jj||j||ii|jdd6|d6d6}|S(NR²RERñtvolumeIdRÔ(R%R£t
get_by_volumeRttvolume_snapshot_createRER¨(RDRRÊtcreate_infoRVRÔ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRüs	
cCsAtjj||ddg}|jj||j|||dS(NR²RE(R%R£R
Rttvolume_snapshot_deleteRE(RDRRÊRËtdelete_infoRV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR
	s	c
Csótjt}tjt}tjt}xP|D]H}x?|j||D]+}||j|||jj|qMWq4Wx7|D]/}	x&||	jD]}||j|	qWqWx2|D]*}|jj|||||d|qÁWdS(NRR(	tcollectionstdefaultdictR@t_get_relevant_hostsRÏRBR;Rttexternal_instance_event(
RDRR¦teventstinstances_by_hosttevents_by_hostthosts_by_instanceRERRtevent((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRs


	cCst}|j|j|jdk	r|jj}tjj||}|j|j	|j|j
tjdi|j
d6|d6n|S(NsSInstance %(instance)s is migrating, copying events to all relevant hosts: %(hosts)sREthosts(RORÈRRtmigration_contextR@RñR%Rst	get_by_idR;RvRÂRÃRB(RDRRERRñR{((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR)s		
cCsÏ|jr¿yg|jD]}|jdkr|^qd}|jrStjj}nH|jrktjj}n0|j	j
|}|rtjjptjj}WqËt
k
r»tjj}qËXntjj}|S(Nsnova-computei(RRtservicesR3tforced_downt
fields_objt
HostStatustDOWNRptMAINTENANCERxRatUPtUNKNOWNt
IndexErrortNONE(RDRER0thost_statustalive((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_instance_host_status7s			
cCst}t}xn|D]f}|jrf|j|krV|j|}|||j<qr||j}ntjj}|||j<qW|S(N(RÀRRR'RRR$RB(RDt
instance_listthost_status_dictt
host_statusesRER%((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_instances_host_statusesJs		
	N(±RCt
__module__t__doc__R@RtpropertyRR\RR RR¾RÁRãRèRíRötstaticmethodRÿRRRRR!R;RIRTRCRkRmRoRRÈRRÕRÚRRäRèRBR¬R°RöRRRR-R«R1R5Rtadd_hookR§RßRERNRFRoR_RKRRRgRRRR[R_RPRRRVRReR£RR©RWR¢tERRORRªtSTOPPEDR®tALLOW_TRIGGER_CRASH_DUMPR°R±R³R¨RáRÕRÓRòtPAUSEDt	SUSPENDEDRôRÔR÷RRRROtALLOW_SOFT_REBOOTRtALLOW_HARD_REBOOTRtALLOW_REBOOTRR3R^R:RzRCR<RXRTRZRUR^R`RbRfRiRjRkRnRqRztRESCUEDR~RRRRRRRRRRRRRRR R¡R§RªR¬R®R«R´R¸RºR·RÁRÇRÈRËRÏRÐRÍR×RÙRïRÞRöRùRýRRRRR
RRR'R+(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRlÃs				#	F	!			,						M				<			u	{.	P	'			\				2	
							)	/	:			1				)
	!'$
		8				M%LY$!w$$$$!



	
								!				7$U			
				tHostAPIcBsìeZdZddZedZedZdZ	edZ
edZdedZdZ
d	Zd
ZdZdZd
ZdZdddZdZdddZdZdZRS(s@Sub-set of the Compute Manager API for managing host operations.cCs;|ptj|_tj|_tt|jdS(N(	RtRuRR-RlRxR~R:R(RDR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR]scCsftjj||}|s0tjd|n|r^|jj|r^tjd|n|dS(s1Raise HostNotFound if compute host doesn't exist.RR(R%RGR`RtHostNotFoundRxRatComputeServiceUnavailable(RDRRét
must_be_upR0((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_assert_host_existsbscCsn|j||}i|d6|d6}tj|d||jj|d|d|}tj|d||S(s:Sets the specified host's ability to accept new instances.RéR|sset_enabled.startRRsset_enabled.end(R>R[tnotify_about_host_updateRtset_host_enabled(RDRRéR|tpayloadRh((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR@ks			cCs.|j||dt}|jj|d|S(s:Returns the result of calling "uptime" on the target host.R=RR(R>RRtget_host_uptime(RDRRé((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRBzs	cCsn|j||}i|d6|d6}tj|d||jj|d|d|}tj|d||S(s*Reboots, shuts down or powers up the host.RéRspower_action.startRRspower_action.end(R>R[R?Rthost_power_action(RDRRéRRARh((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRCs			cCst|j||}i|d6|d6}tj|d||jj|d|d|d|}tj|d||S(s`Start/Stop host maintenance window. On start, it triggers
        guest VMs evacuation.
        Rétmodesset_maintenance.startt
host_paramRRsset_maintenance.end(R>R[R?Rthost_maintenance_mode(RDRRéRDRARh((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytset_host_maintenances		c
Cs³|dkri}n|jdd}d|kr<t}ntjj||d|}g}xO|D]G}x>tj|D] \}}	|||	krzPqzqzW|j|qdW|S(sReturns a list of services, optionally filtering the results.

        If specified, 'filters' should be a dictionary containing services
        attributes and matching values.  Ie, to get a list of services for
        the 'compute' topic, use filters={'topic': 'compute'}.
        RpRût	set_zonesN(	R@RRR%tServiceListRáRØRÙRÏ(
RDRR¹RHRpRtret_servicesR0Ritval((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytservice_get_all s			
cCstjj||S(s+Get service entry for the given service id.(R%RGR(RDRt
service_id((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytservice_get_by_id¸scCstjj||S(s1Get service entry for the given compute hostname.(R%RGR`(RDRRé((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytservice_get_by_compute_host¼scCs3tjj|||}|j||j|S(s-Performs the actual service update operation.(R%RGtget_by_argsRRZ(RDRRéR3tparams_to_updateR0((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_service_updateÀs
cCs|j||||S(sEnable / Disable a service.

        For compute services, this stops new builds and migrations going to
        the host.
        (RR(RDRRéR3RQ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytservice_updateÇscCstjj||jdS(s/Performs the actual Service deletion operation.N(R%RGRR·(RDRRM((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_service_deleteÐscCs|j||dS(sDeletes the specified service.N(RT(RDRRM((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytservice_deleteÔscCstjj||S(s'Return all instances on the given host.(R%RÍtget_by_host(RDRRé((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytinstance_get_all_by_hostØsc	Cs%|jj||||d|d|S(sfReturn the task logs within a given range, optionally
        filtering by host and/or state.
        RRR<(RÉttask_log_get_all(RDRt	task_nametperiod_beginningt
period_endingRRR<((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRXÜs
cCstjj|t|S(s4Return compute node entry for particular integer ID.(R%tComputeNodeRRº(RDRt
compute_id((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcompute_node_getçscCstjj|d|d|S(NRÄRÅ(R%Ràtget_by_pagination(RDRRÄRÅ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcompute_node_get_allës	cCstjj||S(N(R%Ràtget_by_hypervisor(RDRthypervisor_match((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt!compute_node_search_by_hypervisorïscCs|jj|S(N(RÉtcompute_node_statistics(RDR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRdósN(RCR,R-R@RRR>twrap_exceptionR@RBRCRGRLRNRORRRSRTRURWRXR^R`RcRd(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR:Zs(										
		tInstanceActionAPIcBs)eZdZdZdZdZRS(sASub-set of the Compute Manager API for managing instance actions.cCstjj||jS(N(R%tInstanceActionListR@RB(RDRRE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytactions_getús	cCstjj||j|S(N(R%Rtget_by_request_idRB(RDRREt
request_id((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytaction_get_by_request_idþs	cCstjj||S(N(R%tInstanceActionEventListt
get_by_action(RDRREt	action_id((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytaction_events_gets	(RCR,R-RhRkRo(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRf÷s		tAggregateAPIcBs¿eZdZdZedZdZdZdZedZ	edZ
edZde
d	Zd
ZdZedZed
ZRS(s@Sub-set of the Compute Manager API for managing host aggregates.cKs8tj|_tj|_tt|j|dS(N(RtRutscheduler_clienttSchedulerClientR~RpR(RDRT((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR	scCsXtjd|}||_|r4i|d6|_n|j|jj||g|S(s$Creates the model for the aggregate.RRû(R%t	AggregateRRÞR§Rqtupdate_aggregates(RDRtaggregate_nameRût	aggregate((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcreate_aggregates	
cCstjj||S(sGet an aggregate by id.(R%RsR(RDRtaggregate_id((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
get_aggregatescCstjj|S(sGet all the aggregates.(R%t
AggregateListRá(RDR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_aggregate_listscCstjj||S(s9Get all the aggregates where the given host is presented.(R%RzRV(RDRtcompute_host((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_aggregates_by_host"scCs·tjj||}d|kr@|jd|_|jn|j||d|dt|r|j|t	j
|_n|jj
||g|jdr³tjn|S(s&Update the properties of an aggregate.RRvtaction_nameRû(R%RsRRRRZtis_safe_to_update_aztAGGREGATE_ACTION_UPDATEtupdate_metadataRRt
updated_atRqRtR¨R	treset_cache(RDRRxRõRv((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytupdate_aggregate&s


cCstjj||}|j||d|dt|j||jj||g|rv|jdrvt	j
ntj|_
|S(sUpdates the aggregate metadata.RvR~Rû(R%RsRRtAGGREGATE_ACTION_UPDATE_METARRqRtR¨R	RRRR(RDRRxRÞRv((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytupdate_aggregate_metadata9s

cCs¥i|d6}tj|d|tjj||}t|jdkrqtd}tj	d|d|n|j
|jj||tj|d|dS(sDeletes the aggregate.Rxsdelete.startisHost aggregate is not emptyRÓs
delete.endN(
R[tnotify_about_aggregate_updateR%RsRRRRRtInvalidAggregateActionDeleteR·Rqtdelete_aggregate(RDRRxtaggregate_payloadRvR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRHs
		
	cCsãd|krß|dsBtd|j}|j||j|n|pN|j}tjj|dd|}g|D]4}	|	j|dkrs|	j|jkrs|	j^qs}
|
rßtd|
}|j||j|qßndS(sDetermine if updates alter an aggregate's availability zone.

            :param context: local context
            :param metadata: Target metadata for updating aggregate
            :param aggregate: Aggregate to update
            :param hosts: Hosts to check. If None, aggregate.hosts is used
            :type hosts: list
            :action_name: Calling method for logging purposes

        Rûs;Aggregate %s does not support empty named availability zoneRs4One or more hosts already in availability zone(s) %sN(	RRt_raise_invalid_aggregate_excRñRR%Rztget_by_metadata_keyRû(RDRRÞRvRR~R¶t_hoststhost_aggregatestaggtconflicting_azs((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRZs"

	

	
!	cCs¹|tkr'tjd|d|nu|tkrNtjd|d|nN|tkrutjd|d|n'|tkrtjd|d|ntj	t
d|dS(NRxRÓsUnexpected aggregate action %s(tAGGREGATE_ACTION_ADDRtInvalidAggregateActionAddRtInvalidAggregateActionUpdateRt InvalidAggregateActionUpdateMetatAGGREGATE_ACTION_DELETERR
R(RDR~RxRÓ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRzs				cCs,|r(|jdr(tj||ndS(NRû(R¨R	t#update_host_availability_zone_cache(RDRRétaggregate_meta((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_update_az_cache_for_hosts	cCsúi|d6|d6}tj|d|tjj||tjj||}|j||jd|gd||j	||j
j||g|j|||j|j
j|d|d|d||ji|jd6tj|d	||S(
sAdds the host to an aggregate.RxRés
addhost.startRRvRERRRsaddhost.end(R[RR%RGR`RsRRRÞtadd_hostRqRtRRttadd_aggregate_hostRR(RDRRxRéRRv((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytadd_host_to_aggregates&

	
	cCsÁi|d6|d6}tj|d|tjj||tjj||}|j||jj	||g|j
|||j|jj
|d|d|d|tj|d||S(s Removes host from the aggregate.RxRésremovehost.startRvRERRsremovehost.end(R[RR%RGR`RsRtdelete_hostRqRtRRÞRttremove_aggregate_host(RDRRxRéRRv((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytremove_host_from_aggregate®s 

	
	N(RCR,R-RReRwRyR{R}RRRR@RRRRRR(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRps						t
KeypairAPIcBsÂeZdZejejddZejejdeddZdZ	dZ
eejdZ
eejd	Zd
ZdZedZddd
ZdZRS(s9Subset of the Compute Manager API for managing key pairs.R0RR2R3snova-apicCsHi|jd6|jd6|d6}|j}|j|d||dS(NRÂR²Rxs
keypair.%s(R±R²R2Rá(RDRtevent_suffixtkeypair_nameRAtnotify((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_notifyÌs


csdtjtjdjfd|D}||krZtjdtdnytj|dddd	Wn,tj	k
r¥tjdtd
nXt
jj|d|}yt
jj
|d|dWn tjk
rþtjnXdS(Ns_- Rc3s!|]}|kr|VqdS(N((Ratx(t
safe_chars(sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pys	<genexpr>×sRÓs'Keypair name contains unsafe charactersRÕit
max_lengthiÿsAKeypair name must be string and between 1 and 255 characters longt	key_pairs(tstringtdigitst
ascii_lettersRÑRtInvalidKeypairRRRÚRÛR%RRøRRtKeypairLimitExceeded(RDRR²Rxtkey_typetclean_valueRø((R¥sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt_validate_new_key_pairÕs		cCs|j|||||j|d||j||}tj|}||_||_||_||_||_	|j
|j|d||S(s/Import a key pair using an existing public key.simport.starts
import.end(R¯R£t_generate_fingerprintR%RR²RttypetfingerprintRR§(RDRR²RxRRR²R'((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytimport_key_pairês					
c	Cs§|j|||||j|d||j||\}}}tj|}||_||_||_||_||_	|j
|j|d|||fS(sCreate a new key pair.screate.starts
create.end(R¯R£t_generate_key_pairR%RR²RR±R²RR§(	RDRR²RxRtprivate_keyRR²R'((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcreate_key_pairs					
cCs<|tjkrtj|S|tjkr8tj|SdS(N(tkeypair_objtKEYPAIR_TYPE_SSHRtgenerate_fingerprinttKEYPAIR_TYPE_X509tgenerate_x509_fingerprint(RDRR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR°s
cCs9|tjkrtjS|tjkr5tj|SdS(N(R·R¸Rtgenerate_key_pairRºtgenerate_winrm_x509_cert(RDR²R((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR´s
cCs@|j|d|tjj||||j|d|dS(sDelete a keypair by name.sdelete.starts
delete.endN(R£R%Rtdestroy_by_name(RDRR²Rx((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytdelete_key_pair#scCstjj||d|d|S(sList key pairs.RÄRÅ(R%R©tget_by_user(RDRR²RÄRÅ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt
get_key_pairs*s	cCstjj|||S(sGet a keypair by name.(R%RR(RDRR²Rx((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_key_pair/sN(RCR,R-RKtpartialR+R2RReR£R¯R·R¸R³R¶R°R´R¿R@RÁRÂ(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÄs 						tSecurityGroupAPIcBs
eZdZeZdZdZdZdZdZ	ddedZdddddZdZ
d	Zd
ZdZdZd
ZdZdZdZdZdZdZdZdZdZdZedZdZRS(s`Sub-set of the Compute API related to managing security groups
    and security group rules
    cKs)tt|j|tj|_dS(N(R~RÄRRtRu(RDRT((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR<scCs¸y|j}Wn.tk
r@td|}|j|nXtj|d|dddd|r´tj||r´tdi|d6|d	6|jd
6}|j|ndS(s	Validate given security group property.

        :param value:          the value to validate, as a string or unicode
        :param property:       the property, either 'name' or 'description'
        :param allowed:        the range of characters allowed
        s,Security group %s is not a string or unicodeRRÕiR¦iÿs_Value (%(value)s) for parameter Group%(property)s is invalid. Content limited to '%(allowed)s'.RjR¹R.N(	tstripRRtraise_invalid_propertyRRÚRëRåt
capitalize(RDRjR.R¹RKR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytvalidate_property@s
	cCs|jj|dS(sÃEnsure that a context has a security group.

        Creates a security group for the security context if it does not
        already exist.

        :param context: the security context
        N(RÉtsecurity_group_ensure_default(RDR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR£[scCs7tjd|}y|jddWn-tjk
rUtd}|j|nXtjt	d|d|y|j
|i|jd6|jd6|d6|d	6}y|j
j||}Wn1tjk
rötd
|}|j|nX|jWn.tk
r2tj|jWdQXnX|S(NRRis)Quota exceeded, too many security groups.sCreate Security Group %sR²R±Rtdescriptions Security group %s already exists(R%RR¼RRRtraise_over_quotaRÂRáRR£R²R±RÉtsecurity_group_createtSecurityGroupExiststraise_group_already_existsR¼RµRR¶R»(RDRRRÊR(R¶R×t	group_ref((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytcreate_security_groupes.




c	Csw|dtkr4td|d}|j|ni|d6|d6}dg}|jj||d|d|}|S(NRs"Unable to update system group '%s'RÊsrules.grantee_groupRñtcolumns_to_join(tRO_SECURITY_GROUPSRtraise_invalid_groupRÉtsecurity_group_update(	RDRR)RRÊR¶R×RÑRÏ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytupdate_security_groups	

		cCs |j|dg}yH|r>|jj||j|d|S|r]|jj||d|SWn;tjk
r}|r|j}|j|qnXdS(NtrulesRÑ(	R£RÉtsecurity_group_get_by_nameR±tsecurity_group_getRtNotFoundRÜtraise_not_found(RDRRRñt
map_exceptiontcolstexpR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¨s 
	c	Csû|j|g}|s|r|rXx0|D]%}|j|jj|||q,Wn|r÷x-|D]"}|j|jj||qeWq÷nf|jrÙ|rÁd|krÁ|jj|}q÷|jj||}n|r÷|jj||}n|S(Ntall_tenants(R£RÏRÉR×RØRYtsecurity_group_get_alltsecurity_group_get_by_project(	RDRtnamestidstprojectRÖtgroupsRRñ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR@§s&


&	cCs|dtkr4td|d}|j|n|jj||dritd}|j|ntjd|}tj||\}}y |j	d|d|dd	Wn$t
k
rÙtjt
d
nXtjtd|dd||jj||d|jdS(NRs"Unable to delete system group '%s'RñsSecurity group is still in useRR±R²Riÿÿÿÿs3Failed to update usages deallocating security groupsDelete security group %s(RÒRRÓRÉtsecurity_group_in_useR%RRItids_from_security_groupR¼RµRÂRRRáRtsecurity_group_destroyR¼(RDRR)R¶R(t
quota_projectt
quota_user((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR·Ås&	
cCsL|s
tS|jd}|s#tSx"|D]}||dkr*tSq*WtS(smCheck if the security group is already associated
           with the instance. If Yes, return True.
        R¦RB(RR¨R(RDR)R;R¦tinst((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytis_associated_with_serveràs
cCs|jj||j|}|j}|j||rUtjd|dd|n|jj|j||d|j	r|j
j|||j	ndS(s#Add security group to the instance.RäRñRQN(RÉR×R±RBRëRtSecurityGroupExistsForInstancetinstance_add_security_groupR8RRRttrefresh_instance_security_rules(RDRREtsecurity_group_nameR)R;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytadd_to_instanceòs			
		cCs|jj||j|}|j}|j||sUtjd|dd|n|jj|j||d|j	r|j
j|||j	ndS(s7Remove the security group associated with the instance.RäRñRQN(RÉR×R±RBRëRt!SecurityGroupNotExistsForInstancetinstance_remove_security_groupR8RRRtRî(RDRRERïR)R;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytremove_from_instances			
		cCs\|j|y|jj||SWn1tjk
rWtd|}|j|nXdS(NsRule (%s) not found(R£RÉtsecurity_group_rule_getRRÙRRÚ(RDRRñR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_rules
cCstjj|d|}y*|t|}tjj|d|Wn-tjk
rqtd}|j|nXt	d}g}xe|D]]}	|j
j||	}
|j|
t
j|i|d6|
jd6|
jd6|
jd6qW|j|d||S(	sùAdd security group rule(s) to security group.

        Note: the Nova security group API doesn't support adding multiple
        security group rules at once but the EC2 one does. Therefore,
        this function is written to support both.
        tsecurity_group_ruless.Quota exceeded, too many security group rules.sNSecurity group %(name)s added %(protocol)s ingress (%(from_port)s:%(to_port)s)Rtprotocolt	from_porttto_portRñ(R%RRøRRRRRRËRRÉtsecurity_group_rule_createRÏRÂRáR÷RøRùttrigger_rules_refresh(RDRRñRtvalsRøt	projectedR¶RÖRátrule((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt	add_rules$s$



cCstd}xl|D]d}|j||}tj|i|dd6|jd6|jd6|jd6|jj||qW|j	|d|ddS(NsPSecurity group %(name)s removed %(protocol)s ingress (%(from_port)s:%(to_port)s)RR÷RøRùRñ(
RRõRÂRáR÷RøRùRÉtsecurity_group_rule_destroyRû(RDRR)trule_idsR¶trule_idRþ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytremove_rulesBs


cCs(x!|D]}|jj||qWdS(N(RÉt#security_group_default_rule_destroy(RDRRR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytremove_default_rulesQs
cCs,g|D]}|jj||^q}|S(N(RÉt"security_group_default_rule_create(RDRRüRáRÖ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytadd_default_rulesUs%cCsmxf|jj|D]R}d}xC|D](}|j||j|kr&Pq&q&W|jdpdtSqWtS(sxIndicates whether the specified rule values are already
           defined in the default security group rules.
        tcidrRøRùR÷Rñ(scidrs	from_portsto_portsprotocol(RÉt security_group_default_rule_listR¨RR(RDRRõRþRdRi((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytdefault_rule_existsZs
cCsCy|jj|}Wn&tk
r>d}tj|nX|S(Ns'cannot get default security group rules(RÉR	RµRt SecurityGroupDefaultRuleNotFound(RDRRÖR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_all_default_rulesgs
cCs|jj||S(N(RÉtsecurity_group_default_rule_get(RDRRñ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_default_rulepscCs?yt|SWn*tk
r:td}|j|nXdS(Ns#Security group id should be integer(RºRRRÆ(RDRñR¶((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytvalidate_idss

cCs@x9|D]1}|jdk	r|jj|||jqqWdS(N(RRR@RtRî(RDRR¦RE((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt _refresh_instance_security_ruleszs
	cCs)tjj||}|j||dS(s@Called when a rule is added to or removed from a security_group.N(R%RÍtget_by_security_group_idR(RDRRñR¦((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRûscCs)tjj||}|j||dS(s°Called when a security group gains a new or loses a member.

        Sends an update request to each compute node for each instance for
        which this is relevant.
        N(R%RÍt!get_by_grantee_security_group_idsR(RDRt	group_idsR¦((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyttrigger_members_refreshs	cCs@|r|jj||jSg|jD]}i|jd6^q&S(NR(RÉtsecurity_group_get_by_instanceRBRR(RDRREtdetailedR×((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pytget_instance_security_groupss
cCs|stjStj|S(N(R%tSecurityGroupListtsecurity_group_objtmake_secgroup_list(RDR((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyR¢s
N(RCR,R-Rt
id_is_uuidRRÈR£RÐRÕR@R¨R@R·RëRðRóRõRÿRRRR
RRRRRûRRR¢(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyRÄ4s8			
													
							
(|R-RRRùRKRëR¨RBtoslo_logRtloggingtoslo_messagingRRætoslo_serializationRt
oslo_utilsRRRRRRØt	six.movesRtnovaR	R
t
nova.cellsRRtnova.computeRR
RRRtRRR[RRt	nova.conftnova.consoleauthRrRRBRtnova.dbRRRRt	nova.i18nRRRRRRR tnova.networkR!Rtnova.network.security_groupR"R#R$R%tnova.objectsRRfR&RR'R·R(RIR)Rtnova.pciR*Rtnova.policyR+tnova.schedulerR,RqR9R-t	nova.virtR.tnova.volumeR/t	getLoggerRCRÂRÃR2RetconfRyRRÒR»RRRRR@RRPRWR[R_RktBaseRlR:RfRpRtSecurityGroupBaseRÄ(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/api.pyt<module>sÌ			(						ÿÿÿÿÿÿÿÿÿÿÿÿÿÿ¥½p
triliodata-3-4 / contego deb

Products

About

Resources

Contact Gemfury
