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

d
dl	mZ
d
dl	mZ
d
d	l	m
Z

d
dlZd
d
lmZ
d
dlmZmZmZ
d
dlmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
dlmZ
d
dlm Z 
d
dl!m"Z#
d
dlm$Z$
d
dl%m&Z&
ej'j(Z(ej)e*ƒ
Z+dZ,d„Z-d„Z.de/f
d„ƒYZ0dS(sœ
Track resources like memory and disk for a compute host.  Provides the
scheduler with useful information about availability through the ComputeNode
model.
iÿÿÿÿN(
tlog(
t	jsonutils(
timportutils(
tclaims(
tmonitors(
ttask_states(
t	vm_states(
t	exception(t
_t_LIt_LW(
tobjects(
tbase(
t	migration(
tmanager(
trequest(
trpc(
tclient(
tutils(
thardwaretcompute_resourcesc
Cso|j}
|j
}|
tjkr%tS|
tjtjgkrk|tjtj	tj
tjtjgkrktSt
S(
sxReturns True if the instance is in one of the resizing states.

    :param instance: `nova.objects.Instance` object
    (tvm_statet
task_stateRtRESIZEDtTruetACTIVEtSTOPPEDRtRESIZE_PREPtRESIZE_MIGRATINGtRESIZE_MIGRATEDt
RESIZE_FINISHt
REBUILDINGtFalse(tinstancetvmttask((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_instance_in_resize_state2s	
	

	


c

Cs
|jdkS(NtresizeR
t
evacuation(sresizes	migrations
evacuation(
tmigration_type(
R
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_is_trackable_migrationFs
tResourceTrackercBsñ
eZ
dZd
„Zejeƒ
d'd„
ƒ
Zejeƒ
d'd'd'd„ƒ
Z	ejeƒ
d'd'd„ƒ
Z
d'd'd'd'd„Zd'd„
Zd„Z
d„Zd	„Zejeƒ
d
„ƒ
Zejeƒ
d'dd„ƒ
Zejeƒ
d
„ƒ
Zed„ƒ
Zd„Zd„Zd„Zd„Zd„Zd„Zejeƒ
d„ƒ
Zd„Zd„Zd„Zd„Zd„Z dd„
Z!dd„
Z"d„Z#d„Z$e%d „
Z&d!„Z'd"„Z(d#„Z)d$„Z*d%„Z+d&„Z,RS((sgCompute helper class for keeping track of resource usage as instances
    are built and destroyed.
    cCsµ|
|_||_
d|_||_d|_tjtj	ƒ
|_
i|_i|_t
j|ƒ
}|j
|_
tjƒ|_tjƒ|_tj|_tj|_tj|_dS(
N(thosttdrivertNonetpci_trackertnodenametcompute_nodeRt
import_objecttCONFtcompute_stats_clasststatsttracked_instancesttracked_migrationsRtMonitorHandlerRtComputeNodet
old_resourcestscheduler_clienttSchedulerClienttram_allocation_ratiotcpu_allocation_ratiotdisk_allocation_ratio(tselfR*R+R.tmonitor_handler((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt__init__Ts
	
	
	
	
	

	
	






c	
Cs„
|jr |j
|ƒ

tjƒS|jrEtjtd
ƒ
d|ƒ


n|jrjtjtdƒ
d|ƒ


n|j	j
|ƒ
}tjdi|jj
d6|dd6ƒ
tjdi|jjd6|jd	d
ƒd6ƒ
tjj|
|jƒ}tj|
|||j|d|d|ƒ}|j}||_|j
|ƒ

|jrW
|jj|
||ƒ
n|j|
|ƒ
|
jƒ}|j|ƒ

|S(sÔIndicate that some resources are needed for an upcoming compute
        instance build operation.

        This should be called before the compute node is about to perform
        an instance build operation that will consume additional resources.

        :param context: security context
        :param instance: instance to reserve resources for.
        :type instance: nova.objects.instance.Instance object
        :param limits: Dict of oversubscription limits for memory, disk,
                       and CPUs.
        :returns: A Claim ticket representing the reserved resources.  It can
                  be used to revert the resource usage if an error occurs
                  during the instance build.
        sOHost field should not be set on the instance until resources have been claimed.R!sONode field should not be set on the instance until resources have been claimed.s;Memory overhead for %(flavor)d MB instance; %(overhead)d MBtflavort	memory_mbtoverheads9Disk overhead for %(flavor)d GB instance; %(overhead)d GBtdisk_gbitlimits(tdisabledt_set_instance_host_and_nodeRtNopClaimR*tLOGtwarningR
tnodeR+testimate_instance_overheadtdebugRARBtroot_gbtgetRtInstancePCIRequeststget_by_instance_uuidtuuidtClaimR/tclaimed_numa_topologyt
numa_topologyR-tclaim_instancet_update_usage_from_instancetelevatedt_update(	R>tcontextR!RERCtpci_requeststclaimtinstance_numa_topologyRX((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytinstance_claimes<	


	

	


	


	

	


	
	

	


cCs4|j}|j
|
||d
dd|d|d|ƒS(s'Create a claim for a rebuild operation.t	move_typeR&REt
image_metaR
(RAt_move_claim(R>RZR!RER`R
t
instance_type((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt
rebuild_claim¬s	


cCs|j|
||d
|d|ƒS(s3Create a claim for a resize or cold-migration move.R`RE(
Ra(R>RZR!RbR`RE((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytresize_claimµs
cCs)|p	i}|r"|j|ƒ

n|j
|
|||ƒ}|jrStjd
|ƒ
S|jj|ƒ
}tjdi|j	d6|dd6ƒ
tjdi|j
jd6|jddƒd6ƒ
t
j|ƒ
}	|j|	_|jr
x9|jjD](}
|
jdkrë|	jj|
ƒ

qëqëWntj|
|||||j|	d|d	|ƒ}||_g}|jr€
|jj|
|	|jƒ}ntjd
|ƒ
}
tjd|
d|jd
|jd|j d|jd|j!d|
d|jd|	ƒ	}||_"|j#ƒ
|j$|
||ƒ
|
j%ƒ}|j&|ƒ

|S(s¯Indicate that resources are needed for a move to this host.

        Move can be either a migrate/resize, live-migrate or an
        evacuate/rebuild operation.

        :param context: security context
        :param instance: instance object to reserve resources for
        :param new_instance_type: new instance_type being resized to
        :param image_meta: instance image metadata
        :param move_type: move type - can be one of 'migration', 'resize',
                         'live-migration', 'evacuate'
        :param limits: Dict of oversubscription limits for memory, disk,
        and CPUs
        :param migration: A migration object if one was already created
                          elsewhere for this operation
        :returns: A Claim ticket representing the reserved resources.  This
        should be turned into finalize  a resource claim or free
        resources after the compute operation is finished.
        R
s;Memory overhead for %(flavor)d MB instance; %(overhead)d MBRARBRCs9Disk overhead for %(flavor)d GB instance; %(overhead)d GBRDiRERRZt
instance_uuidtmigration_idtold_numa_topologytnew_numa_topologytold_pci_devicestnew_pci_devicestold_pci_requeststnew_pci_requestsN('t_claim_existing_migrationt_create_migrationRFRRHR+RLRIRMRBRARNROtpci_requesttget_pci_requests_from_flavorRRReR[trequestst
alias_nameR,tappendt	MoveClaimR/R
R-RVRTRt
PciDeviceListtMigrationContexttidRUtpci_devicestmigration_contexttsavet_update_usage_from_migrationRXRY(R>RZR!tnew_instance_typeR_R`RER
RCRlRR\tclaimed_pci_devices_objstclaimed_pci_devicestmig_contextRX((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRa¼s^


	
	



	


	
	






		

		

	
		

	
	
	
	

	
	
	




cCs¼tj
d
|
jƒƒ
}|j|_|j|_|jjƒ|_	|j
j|_|j|_
d|_|j|_|j|_|j|_|rœ||_ntj|ƒ
|_|jƒ
|S(sÒCreate a migration record for the upcoming resize.  This should
        be done while the COMPUTE_RESOURCES_SEMAPHORE is held so the resource
        claim will not be lost if the audit process starts.
        RZs
pre-migrating(Rt	MigrationRXR*tdest_computeR.t	dest_nodeR+tget_host_ip_addrt	dest_hostRARwtold_instance_type_idtnew_instance_type_idtstatusRRRetsource_computeRKtsource_nodeR't
migration_objtdetermine_migration_typetcreate(R>RZR!R|R_R
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRn
s 





	








cCsA|j|
_
|j|
_|jjƒ|
_d
|
_|
jƒ
dS(sG
Make an existing migration record count for resource tracking.

        If a migration record was created already before the request made
        it to this compute host, only set up the migration so it's included in
        resource tracking. This should be done while the
        COMPUTE_RESOURCES_SEMAPHORE is held.
        s
pre-migratingN(	R*RR.R‚R+RƒR„R‡Rz(R>R
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRm3
s



	
cCs2|j|
_|j|
_
|j|
_|
jƒ
d
S(sËTag the instance as belonging to this host.  This should be done
        while the COMPUTE_RESOURCES_SEMAPHORE is held so the resource claim
        will not be lost if the audit process starts.
        N(R*tlaunched_onR.RKRz(R>R!((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRGA
s


cCs d
|
_
d
|
_|
jƒ
d
S(s×Untag the instance so it no longer belongs to the host.

        This should be done while the COMPUTE_RESOURCES_SEMAPHORE is held so
        the resource claim will not be lost if the audit process starts.
        N(R,R*RKRz(R>R!((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_unset_instance_host_and_nodeK
s	
	
cCsD|j|
|d
t
ƒ

|jƒ
|j|ƒ

|j|
jƒƒ

dS(s%Remove usage from the given instance.t
is_removedN(RWRtclear_numa_topologyRŽRYRX(R>RZR!((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytabort_instance_claimU
s


tnew_cCs/
|d
|jkr+
|jj
|d
ƒ
\}}|s\|
jƒ}|j||||ƒ}n|dk	r+
|j|dkr+
|jd|d|ƒ
}|j|d|ƒ

}	|jrù|jd|d|ƒ
}
|
rùx$|
D]}|jj	||ƒ
qÖWqùn|j
|	ddƒ


|
jƒ}|j|ƒ

q+
ndS(	s0Remove usage for an incoming/outgoing migration.RRRwRUtprefixRxtsigniÿÿÿÿN(R5tpopRXt_get_instance_typeR,Rwt_get_migration_context_resourcet_get_usage_dictR-tfree_devicet
_update_usageRY(R>RZR!RbR“R
titypetctxtRUtusageRxt
pci_device((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytdrop_move_claim_
s(








	






cCsP|jr
d
S|d}||j
krL|j|
|ƒ
|j|
jƒƒ

nd
S(sRUpdate the resource usage and stats after a change in an
        instance
        NRR(RFR4RWRYRX(R>RZR!RR((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytupdate_usage|
s	



c

Cs
|jdkS(
N(R/R,(
R>((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRFŒ
scCs
|jr=|j
|ƒ

|j|
|ƒ
|jj|jƒ

d
S|j|
ƒ
|_|jrŒ|j
|ƒ

|j|
|ƒ
|jj|jƒ

d
Stj|
ƒ
|_|j|j_|j
|ƒ

|jj	ƒ
t
jtdƒ
i|jd6|j
d6ƒ
|j|
|ƒ
|jj|jƒ

d
S(sà
Initialize the compute node if it does not already exist.

        The resource tracker will be inoperable if compute_node
        is not defined. The compute_node will remain undefined if
        we fail to create it or if there is no associated service
        registered.

        If this method has to create a compute node it needs initial
        values - these come from resources.

        :param context: security context
        :param resources: initial values
        Ns4Compute_service record created for %(host)s:%(node)sR*RK(R/t_copy_resourcest_setup_pci_trackerR9tupdate_resource_statst_get_compute_nodeRR7R*RŒRItinfoR	R.(R>RZt	resources((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_init_compute_node
s&	





	











cCs|js‹|j
r|j
jnd}tj|
d
|ƒ

|_d|krj|jdƒ
}|jj|ƒ

n|jjj	ƒ}||j
_
ndS(Ntnode_idtpci_passthrough_devices(R-R/RwR,tpci_managert
PciDevTrackerR•t(update_devices_from_hypervisor_resourcesR3tto_device_pools_objtpci_device_pools(R>RZR¦tn_idtdev_jsont
dev_pools_obj((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR¢¾
s
	




	


cCs|jj
ƒ
|jj|
jd
ƒ
ƒ

tj|jƒ
|j_|j|j_|j|j_|j	|j_	|jj
|
ƒ

dS(s]Copy resource values to initialize compute_node and related
        data structures.
        R3N(R3tcleartdigest_statsROtcopytdeepcopyR/R;R<R=tupdate_from_virt_driver(R>R¦((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR¡Ê
s




cCsétj
ƒ}i}x\|jD]Q}y|j|ƒ

Wqtk
rl
}
tjtd
ƒ
i|d6|d6ƒ
qXqW|jƒ}t	|ƒ
rå||d<||d<|j
|d<tj|d<t
jdd	d|ƒ}|j|
d
|ƒ
n|S(sUGet the metrics from monitors and
        notify information to message bus.
        s3Cannot get the metrics from %(mon)s; error: %(exc)stmontexcR.tmetricsR*thost_iptservicetcomputescompute.metrics.update(RtMonitorMetricListRtpopulate_metricst	ExceptionRIRJR
tto_listtlenR*R1tmy_ipRtget_notifierR¥(R>RZR.R¹tmetrics_infotmonitorR¸tnotifier((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_get_host_metricsÛ
s"

















cCs™tj
td
ƒ
i
|jd6ƒ
|jj|jƒ
}tj|d<d|ks^|ddkrkd|d<n|j	|ƒ

|j
|ƒ

|j|
|ƒ
dS(sA
Override in-memory calculations of compute node resource usage based
        on data audited from the hypervisor layer.

        Add in resource claims in progress to account for operations that have
        declared a need for resources, but not necessarily retrieved them from
        the hypervisor layer yet.
        s>Auditing locally available compute resources for node %(node)sRKRºtcpu_infotN(RIR¥R	R.R+tget_available_resourceR1RÂR,t_verify_resourcest _report_hypervisor_resource_viewt_update_available_resource(R>RZR¦((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pytupdate_available_resourceô
s






cCsgd
„|Dƒ
}xP|
D]H}y||j|_
Wqtk
r^


tjdi
|jd6ƒ
qXqWdS(Nc
Ssi|]}
|
|
j“qS((
RR(t.0tinst((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pys
<dictcomp>s	sBMigration for instance %(uuid)s refers to another host's instance!RR(ReR!tKeyErrorRIRM(R>t
migrationst	instancestinstance_by_uuidR
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_pair_instances_to_migrationss






	c	CsW
|j|
|ƒ
|j
rdStjj|
|j|jd
ddddgƒ
}|j|
|ƒ
tjj	|
|j|jƒ}|j
||ƒ
|j|
|ƒ
|jƒ}|j
|ƒ

|jj|||ƒ
|jjjƒ}||j_|jƒ
|j|
|jƒ}tj|ƒ
|j_|j|
ƒ

tjtdƒ
i|jd6|jd6ƒ
dS(	Ntexpected_attrstsystem_metadataRURARys4Compute_service record updated for %(host)s:%(node)sR*RK(R§RFRtInstanceListtget_by_host_and_nodeR*R.t_update_usage_from_instancest
MigrationListt get_in_progress_by_host_and_nodeRÕt_update_usage_from_migrationst_find_orphaned_instancest_update_usage_from_orphansR-tclean_usageR3R­R/R®t_report_final_resource_viewRÇR
tdumpsR¹RYRIR¥R	(R>RZR¦RÓRÒtorphansR±R¹((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRÍs0	
	



	









cCsey tj
j|
|j|jƒSWn>tjk
r`


tjt	d
ƒ
i|jd6|jd6ƒ
n
XdS(s/Returns compute node for the host and nodename.s,No compute node record for %(host)s:%(node)sR*RKN(
RR7tget_by_host_and_nodenameR*R.RtNotFoundRIRJR
(R>RZ((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR¤Us
	



cCs±|
d
|
d}|
d|
d}|
d}|rU||
d}tj
d|ƒ
nd}tj
d	ƒ

|
jd
ƒ
}tj
di|jd6|d
6|d6|d6|d6ƒ
dS(s)
Log the hypervisor's view of free resources.

        This is just a snapshot of resource usage recorded by the
        virt driver.

        The following resources are logged:
            - free memory
            - free disk
            - free CPUs
            - assignable PCI devices
        RBtmemory_mb_usedtlocal_gbt
local_gb_usedtvcpust
vcpus_usedsHypervisor: free VCPUs: %stunknowns(Hypervisor: VCPU information unavailableR©s”Hypervisor/Node resource view: name=%(node)s free_ram=%(free_ram)sMB free_disk=%(free_disk)sGB free_vcpus=%(free_vcpus)s pci_devices=%(pci_devices)sRKtfree_ramt	free_diskt
free_vcpusRxN(RIRMROR.(R>R¦tfree_ram_mbtfree_disk_gbRéRîRx((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRÌ^s







	




c
Csè|jj
}
|
rK|
}|jj}tjtd
ƒ
i|
d6|d6ƒ
nd}d}|jjrut|jjƒ
ng}tjtdƒ
i|jd6|jj	d6|jj
d6|jjd	6|jjd
6|d6|d6|d
6ƒ
dS(s"
Report final calculate of physical memory, used virtual memory,
        disk, usable vCPUs, used virtual CPUs and PCI devices,
        including instance calculations and in-progress resource claims. These
        values will be exposed via the compute node table to the scheduler.
        s=Total usable vcpus: %(tcpu)s, total allocated vcpus: %(ucpu)sttcputucpuisÔFinal resource view: name=%(node)s phys_ram=%(phys_ram)sMB used_ram=%(used_ram)sMB phys_disk=%(phys_disk)sGB used_disk=%(used_disk)sGB total_vcpus=%(total_vcpus)s used_vcpus=%(used_vcpus)s pci_stats=%(pci_stats)sRKtphys_ramtused_ramt	phys_diskt	used_diskttotal_vcpust
used_vcpust	pci_statsN(
R/RéRêRIR¥R	R®tlistR.RBRæRçRè(R>RéRñRòRù((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRá‚s&






$
	











c

Cs5tj
|j|jƒs1tj|jƒ
|_tStS(
s+Check to see if any resources have changed.(tobj_basetobj_equal_primsR/R8R´RµRR (
R>((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt_resource_change§s


cCsC|jƒsd
S|j
j|jƒ

|jr?|jj|
ƒ

nd
S(s<Update partial stats locally and populate them to Scheduler.N(RýR9R£R/R-Rz(R>RZ((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRY®s


	
i
cCs@
|
d
}|
jddƒ}|j
j|
ƒ
}||d
7}||jddƒ7}|jj||7_|jj||7_|jj||
jddƒ7_|jj||
jddƒ7_|jj|jj|j_|jj	|jj|j_
|jj|j_
|dk}tj|j|
|ƒ}||j_dS(NRBRNiRDtephemeral_gbRéiÿÿÿÿ(ROR+RLR/RæRèRêRBRïRçRðR3t
num_instancestrunning_vmsRt!get_host_numa_usage_from_instanceRU(R>RR”t	mem_usaget
disk_usageRCtfreetupdated_numa_topology((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRš·s$






"
"	

	



cCs6|j}||
}
|r2|
|kr2t
||
ƒSdS(
N(RytgetattrR,(R>tresourceR!R“Ry((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR—Òs
	





cCsXt|ƒ
sd
S|j
}tjtdƒ
|ƒ
|j|jkoP|j|jk}|j	|jkot|j
|jk}|o€|}|jj|d
ƒ}d
}	d
}
d}|r)
|d|jkrö|j|
|d|ƒ}	|jd|ƒ}
d}q©
|j|
|d|ƒ}	|jd|d	dƒ
}
n€|ri
|ri
|j|
|d|ƒ}	|jd|ƒ}
d}n@|r©
|r©
|j|
|d|ƒ}	|jd|d	dƒ
}
n|	rT|j|	d|
ƒ

}|jrï
|rï
|jj|
|d
|ƒ

n|j|ƒ

|jr&|jjjƒ}
|
|j_ntjƒ}
|
|j_||	f|j|<nd
S(srUpdate usage for a single migration.  The record may
        represent an incoming or outbound migration.
        NsUpdating from migration %sitinstance_type_idR’RUi
told_R“R”(R(ReRIR¥R	RR*R‚R.RˆR‰R4ROR,R…R–R—R˜R-tupdate_pci_for_instanceRšR3R­R/R®RtPciDevicePoolListR5(R>RZR!R
RRtincomingtoutboundt	same_nodetrecordR›RUR”Rtobj((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR{Úsb
	











	

	
	



	

	

	





	



	



c
Csm
i}i}|jj
ƒ
xÜ|D]Ô}|j}y ||krN|j||<nWn)tjk
rz
}
tjd
|ƒ
q n
Xt||ƒ
sªtj	t
dƒ
d|ƒ


q n|j|dƒ}|sç|j
r |j
r |j
|j
kr |||<q q Wxn|jƒD]`}||j}	y|j|
|	|ƒ
Wq
tjk
rd



tj	t
dƒ
d|	jƒ


q
q
Xq
WdS(Ns Migration instance not found: %ss*Instance not resizing, skipping migration.Res.Flavor could not be found, skipping migration.(R5R²ReR!RtInstanceNotFoundRIRMR$RJR
ROR,t
updated_attvaluesR{tFlavorNotFoundRR(
R>RZRÒtfilteredRÓR
RRt
etother_migrationR!((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRÝ s8





	


















c	Csi
|d
}||jk}|o6|p6|dt
jk}|r^tj|ƒ
|j|<d}n|r}|jj|ƒ

d}n|jj||ƒ
tj	|jƒ
|j
_|s´|r
|jrÙ|jj|
|d|ƒ

n|j
jj|j
||ƒ
|j|j|ƒ
d|ƒ


n|jjƒ|j
_|jrS
|jjjƒ}||j
_ntjƒ|j
_dS(s#Update usage for a single instance.RRRi
iÿÿÿÿR”N(R4RtALLOW_RESOURCE_REMOVALRûtobj_to_primitiveR•R3tupdate_stats_for_instanceR´RµR/R-R

R9treportclienttupdate_instance_allocationRšR˜tcalculate_workloadtcurrent_workloadR­R®RR
(	R>RZR!RRRtis_new_instancetis_removed_instanceR”R
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRWIs2





	

	

	






	

cCs
|jj
ƒ
tjd
|j_tj|j_d|j_|jj	|jj|j_
|jj|jj|j_d|j_
d|j_x3|D]+}|jtjkr’|j|
|ƒ
q’q’W|jjj|j|jjƒƒ
td|jj
ƒ|j_
td|jjƒ|j_dS(súCalculate resource usage based on instance utilization.  This is
        different than the hypervisor's view as it will account for all
        instances assigned to the local compute host, even if they are not
        currently powered on.
        iiN(R4R²R1treserved_host_disk_mbR/Rètreserved_host_memory_mbRæRêRBRïRçRðR
R
RRR
RWR9R
tremove_deleted_instancesR
tmax(R>RZRÓR!((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRÚps"



	

	








c
	Cs€t|j
jƒƒ
}
t|jjƒƒ
}|
|B}|jjƒ}t|jƒƒ
}||}g|D]}||^qf}|S(
sm
Given the set of instances and migrations already account for
        by resource tracker, sanity check the hypervisor to determine
        if there are any "orphaned" instances left hanging around.

        Orphans could be consuming memory and should be accounted for in
        usage calculations to guard against potential out of memory
        errors.
        (t	frozensetR4tkeysR5R+tget_per_instance_usage(	R>tuuids1tuuids2tuuidsRtvuuidstorphan_uuidsRRRã((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRތs	





cCsaxZ|
D]R}|d
}tj
tdƒ
i|dd6|d
6ƒ
i
|d
6}|j|ƒ

qWdS(s$Include orphaned instances in usage.RBsNDetected running orphan instance: %(uuid)s (consuming %(memory_mb)s MB memory)RRN(RIRJR
Rš(R>RãtorphanRBR((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRß¡s




cCsrd
dddddddg}g|D]}||
kr%|^q%}|rntd	ƒ
|}t
jd
|ƒ
‚
ndS(NRéRBRçRÈRêRæRèRUsMissing keys: %streason(RRtInvalidInput(R>R¦t
resource_keyst
ktmissing_keysR.
((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyRˮs

	
	%


cCs1|jdk}|r&t
|d|ƒS|jSdS(s$Get the instance type from instance.R%s%sflavorN(
sresize(R'R
RA(R>RZR!R“R
tstashed_flavors((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR–¸s

cKsÂi}t|
t
jƒr_i|
jjd
6|
jjd6|
jjd6|
jjd6|
jd6}n1t|
t
j	ƒrƒt
j|
ƒ
}n
|j|
ƒ

x+dD]#}||kr—||||<q—q—W|S(s8Make a usage dict _update methods expect.

        Accepts a dict or an Instance or Flavor object, and a set of updates.
        Converts the object to a dict and applies the updates.

        :param object_or_dict: instance or flavor as an object or just a dict
        :param updates: key-value pairs to update the passed object.
                        Currently only considers 'numa_topology', all other
                        keys are ignored.

        :returns: a dict with all the information from object_or_dict updated
                  with updates
        RBRéRNRþRU(
s
numa_topology(
t
isinstanceRtInstanceRARBRéRNRþRUtFlavorRûR
tupdate(R>tobject_or_dicttupdatesRtkey((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR˜Ãs















N(-t__name__t
__module__t__doc__R@RtsynchronizedtCOMPUTE_RESOURCE_SEMAPHORER,R^RcRdRaRnRmRGRŽR‘RŸR tpropertyRFR§R¢R¡RÇRÎRÕRÍR¤RÌRáRýRYRšR—R{RÝR RWRÚRÞRßRËR–R˜(((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyR)OsX	
F


_		
	



	.					6			$	%				F	)'			
	
	(1R=
R´toslo_logRtloggingtoslo_serializationR
t
oslo_utilsRtnova.computeRRRRt	nova.conftnovaRt	nova.i18nRR	R
Rtnova.objectsRRûR
RŠtnova.pciRRªRRoRtnova.schedulerRR9Rt	nova.virtRtconfR1t	getLoggerR;
RIR?
R$R(tobjectR)(((sR/home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/resource_tracker.pyt<module>s4