Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / contego deb
Repository URL to install this package:
|
Version:
4.0.109 ▾
|
ó
±EYc @ sA d d l m Z d d l m Z d d l m Z d d l m Z d d l m
Z
d d l Z d d l m
Z
d d l m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z e j j Z e j e Z e j j d
e j e j f d Y Z e j j d e j e j f d Y Z d S( iÿÿÿÿ( t exception( t log( t jsonutils( t uuidutils( t versionutilsN( t db( t _LW( t objects( t base( t fields( t pci_device_poolt ComputeNodec B sñ e Z d Z i e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d 6e j d 6e j d 6e j d
6e j d 6e j d 6e j d
6e j d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j d e d 6e j
d d 6e j d d e d 6e j d 6e j d 6e j d 6Z d! Z
e d" Z e d# Z e j d$ Z e j d% Z e j d& Z e j e d' Z e d( Z e d) Z e d* Z e d+ Z d, Z d- Z d. Z e j d/ Z e j e d0 Z! e j d1 Z" d2 Z# RS(3 s 1.16t read_onlyt idt uuidt nullablet
service_idt hostt vcpust memory_mbt local_gbt
vcpus_usedt memory_mb_usedt
local_gb_usedt hypervisor_typet hypervisor_versiont hypervisor_hostnamet free_ram_mbt free_disk_gbt current_workloadt running_vmst cpu_infot disk_available_leastt metricst statst host_ipt
numa_topologyt HVSpect supported_hv_specst PciDevicePoolListt pci_device_poolst cpu_allocation_ratiot ram_allocation_ratiot disk_allocation_ratioc C s± t t | j | | t j | } | d k rM d | k rM | d =qM n | d k rr d | k rr | d =qr n | d k r d | k r | d =n d | k r | d =q n | d k r%| j d
d k r%y- t j j | j
| d } | j | d
<Wq%t j
t f k
r!d | d
<q%Xn | d k rGd | k rG| d =n | d k rid | k ri| d =n | d k rd | k r| d =n | d k rd | k r| d =n d S( Ni i R+ i R i R* R) i
R R iÿÿÿÿi i R$ i R# i R" ( i i ( i i ( i i ( i i
( i i ( i i ( i i ( i i ( t superR t obj_make_compatibleR t convert_version_to_tuplet gett NoneR t Servicet get_by_compute_hostt _contextR
R t ComputeHostNotFoundt KeyError( t selft primitivet target_versiont service( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR- a s8
!
c C së d | k s | d d k r² d | k r² | d d k r² y t j j | j | d } Wn t j k
rx d | _ d SXy | j | _ Wqç t t j f k
r® d | _ qç Xn5 d | k rÞ | d d k rÞ | d | _ n d | _ d S( NR R (
R0 R R1 t get_by_idR3 R t ServiceNotFoundR t AttributeErrort OrphanedObjectError( t computet
db_computeR9 ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _host_from_db_object s c
C sê t d d d d g } t | j | } xå | D]Ý } | | } | d k sf | d k sf | d k rÿ | d k r{ d } n | d k rÿ t t | } | d k r· | d k r· d } n | d k rØ | d k rØ d
} n | d k rü | d k rü d } qü qÿ n t | | | q2 W| d } | r8t j | | _ n | j d } | rt j | } g | D] }
t
j j |
^ qc} | | _
n | j d
} | d k rºt j | } n | | _ | | _ | j | | | j | S( NR" R& R R( R) R* R+ g g 0@g ø?g ð?t supported_instancest pci_stats( t setR R0 t getattrt CONFt setattrR t loadsR" R/ R R% t from_listR& R
t from_pci_statsR( R3 R@ t obj_reset_changes( t contextR> R? t
special_casesR t keyt valueR" t sup_instst hv_specst hv_specRB ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _from_db_object£ sL
"
c C s( t j | | } | j | | | S( N( R t compute_node_getRR ( t clsRK t
compute_idR? ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR: è s c C s2 t j | | } | d } | j | | | S( Ni ( R t compute_nodes_get_by_service_idRR ( RT RK R t db_computesR? ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt get_by_service_idï s
c C s+ t j | | | } | j | | | S( N( R t% compute_node_get_by_host_and_nodenameRR ( RT RK R t nodenameR? ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt get_by_host_and_nodename÷ s c C s t j | | | } | d S( Ni ( t ComputeNodeListt get_all_by_host( RT RK R t use_slavet computes( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt% get_first_node_by_host_for_old_compatþ s c C s8 | j d d } | d k r4 t j | | d <n d S( NR" ( t popR0 R t dumps( t updatesR" ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _convert_stats_to_db_format s c C s/ | j d d } | r+ t | | d <n d S( NR# ( Ra R0 t str( Rc R# ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _convert_host_ip_to_db_format s c C sW | j d d } | d k rS g | D] } | j ^ q% } t j | | d <n d S( NR& RA ( Ra R0 t to_listR Rb ( Rc RP RQ ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt) _convert_supported_instances_to_db_format s c C sP d | k rL | j d } | d k r? t j | j } n | | d <n d S( NR( RB ( Ra R0 R Rb t obj_to_primitive( Rc t pools( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _convert_pci_stats_to_db_format s
c C sá t j j | j | j } | s% t Sxµ | D] } | j t j j k rP d } nX | j t j j
k rn d } n: | j t j j k r d } n t j
t d | j q, | | j k r, t | | | _ | j q, q, Wt S( s2 Update inventory records from legacy model values.R R R s+ Unknown inventory class %s for compute node( R t
InventoryListt! get_all_by_resource_provider_uuidR3 R t Falset resource_classR t
ResourceClasst VCPUt MEMORY_MBt DISK_GBt LOGt warningR t obj_what_changedRD t totalt savet True( R6 t inventory_listt inventoryRM ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt update_inventory# s$
c C s¶ | j j d d } d | | j f } t j d | j d | j d | } y | j WnT t j k
r± t j j | j | j } | j
| k r² | | _
| j q² n X| S( Nt .i s
compute-%s-%sRK R t name( R t splitR R t ResourceProviderR3 t createt db_exct DBDuplicateEntryt get_by_uuidR~ Rx ( R6 t shortnamet rp_namet rp( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _ensure_resource_provider> s c C s! | j } t j d | j d | d t j j d | j d d d d d d d
d d | j } | j t j d | j d | d t j j
d | j d d d d d d d
d d | j } | j t j d | j d | d t j j
d | j d d d d d d d
d d | j } | j d S(
s Create the initial inventory objects for this compute node.
This is only ever called once, either for the first time when a compute
is created, or after an upgrade where the required services have
reached the required version.
RK t resource_providerRo Rw t reservedi t min_uniti t max_unitt step_sizet allocation_ratioN( R R t InventoryR3 R Rp Rq R R) R Rr R R* Rs R R+ ( R6 R t cput memt disk( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt create_inventoryN s>
c C sÅ | j d r* t j d d d d n | j } d | k rb t j | d <| d | _ n | j | | j | | j | | j
| t j | j
| } | j | j
| | d S( NR
t actionR t reasons already createdR ( t obj_attr_is_setR t ObjectActionErrort obj_get_changesR t
generate_uuidR Rd Rf Rh Rk R t compute_node_createR3 RR ( R6 Rc R? ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR } s
c C s
| j } | j d d | j | | j | | j | | j | t j | j | j
| } | j | j | | d S( NR
( R Ra R0 Rd Rf Rh Rk R t compute_node_updateR3 R
RR ( R6 t prune_statsRc R? ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyRx s
c C s t j | j | j d S( N( R t compute_node_deleteR3 R
( R6 ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt destroy s c
C s¦ d d d d d d d d d d
d d d
g
} x1 | D]) } | | k r4 t | | | | q4 q4 Wd | k r¢ | d } g | D] } t j j | ^ q~ | _ n d S( NR R R R R R R R$ R R R R R# RA ( RF R R% RH R& ( R6 t resourcest keysRM t sit s( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt update_from_virt_driver¡ s
($ t __name__t
__module__t VERSIONR t IntegerFieldRy t UUIDFieldt StringFieldt DictOfNullableStringsFieldt IPAddressFieldt ListOfObjectsFieldt ObjectFieldt
FloatFieldR- t staticmethodR@ RR R t remotable_classmethodR: RX R[ Rn R` Rd Rf Rh Rk R| R R t remotableR Rx R R£ ( ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR # sf
% E /
R\ c B s¥ e Z d Z i e j d d 6Z e j d Z e j d d d Z e j d Z
e j e d Z e
e j e d Z e j e d Z RS(
s 1.15R R c C s. t j | } t j | | | t j | S( N( R t compute_node_get_allR t
obj_make_listR R ( RT RK RW ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt get_allÍ s c C s: t j | d | d | } t j | | | t j | S( Nt limitt marker( R t" compute_node_get_all_by_paginationR R³ R R ( RT RK Rµ R¶ RW ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt get_by_paginationÓ s c C s1 t j | | } t j | | | t j | S( N( R t! compute_node_search_by_hypervisorR R³ R R ( RT RK t hypervisor_matchRW ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt get_by_hypervisorÚ s c C sR y t j | | } Wn t j k
r2 g } n Xt j | | | t j | S( N( R RV R R; R R³ R R ( RT RK R R^ RW ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _get_by_serviceã s
c C s t j | | S( N( R t compute_node_get_all_by_host( RK R R^ ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt _db_compute_node_get_all_by_hostï s c C s7 | j | | d | } t j | | | t j | S( NR^ ( R¾ R R³ R R ( RT RK R R^ RW ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR] ô s N( R¤ R¥ R¦ R R¬ R R° R´ R0 R¸ R» Rn R¼ R¯ R t select_db_reader_modeR¾ R] ( ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyR\ µ s (! t oslo_dbR R t oslo_logR t loggingt oslo_serializationR t
oslo_utilsR R t nova.conft novaR t nova.i18nR R t nova.objectsR R R
t confRE t getLoggerR¤ Rt t NovaObjectRegistryt registert NovaPersistentObjectt
NovaObjectR t ObjectListBaseR\ ( ( ( sN /home/tvault/.virtenv/lib/python2.7/site-packages/nova/objects/compute_node.pyt <module> s& ÿ