Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-4 / contego deb
Repository URL to install this package:
|
Version:
3.4.36 ▾
|
ó
±EYc @ s d Z d d l Z d d l Z d d l Z d d l 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 d d
l m Z d d l m Z d d l 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 d d l m Z d d l m! Z" d d l# m$ Z% d d l# m& Z' d a) e
j* e+ Z, e j- d Z. e j- d Z/ e j- e j0 râd n d Z1 e j2 j3 Z3 d Z4 d Z5 d e6 f d YZ7 d S( sø
Manages information about the host OS and hypervisor.
This class encapsulates a connection to the libvirt
daemon and provides certain higher level APIs around
the raw libvirt API. These APIs are then used by all
the other libvirt related classes
iÿÿÿÿN( t greenio( t greenthread( t patcher( t tpool( t log( t excutils( t importutils( t units( t versionutils( t context( t exception( t _( t _LE( t _LI( t _LW( t rpc( t utils( t event( t config( t guestt sockett threadingt Queuet queuet QEMUt Xent Hostc B s$ e Z e d2 d2 d Z d Z d Z e d Z d Z e d Z
e d Z e d Z d Z
d Z d
Z d Z d Z d
Z d Z d Z d Z e d Z d Z d2 d2 d2 e j d Z d2 d2 d2 d Z d2 d2 d2 d Z d Z d Z d Z d Z e! d Z" e! d Z# e! e! d Z$ e! e! d Z% d Z& d Z' d Z( d! Z) d" Z* d# Z+ d2 d$ Z, d% Z- d& Z. d' Z/ d( Z0 d) Z1 d* Z2 d+ Z3 d, Z4 d- d. Z5 d- d/ Z6 d0 Z7 d1 Z8 RS(3 c C s t d k r t j d a n | | _ | | _ | | _ | | _ t | _ d | _
d | _ d | _ t
j | _ d | _ i | _ d | _ d S( Nt libvirti ( R t NoneR t
import_modulet _urit
_read_onlyt _conn_event_handlert _lifecycle_event_handlert Falset _skip_list_all_domainst _capst _hostnamet
_wrapped_connR t Lockt _wrapped_conn_lockt _event_queuet _events_delayedt _lifecycle_delay( t selft urit read_onlyt conn_event_handlert lifecycle_event_handler( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt __init__O s c C s x t r t j q Wd S( sê Receives async events coming in from libvirtd.
This is a native thread which runs the default
libvirt event loop implementation. This processes
any incoming async events from libvirtd and queues
them for later dispatch. This thread is only
permitted to use libvirt python APIs, and the
driver.queue_event method. In particular any use
of logging is forbidden, since it will confuse
eventlet's greenthread integration
N( t TrueR t virEventRunDefaultImpl( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _native_threadj s
c C s x t r | j q Wd S( sæ Dispatches async events coming in from libvirtd.
This is a green thread which waits for events to
arrive from the libvirt event loop thread. This
then dispatches the events to the compute manager.
N( R2 t _dispatch_events( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _dispatch_threadz s c C s° | } | j } d } | t j k r3 t j } nQ | t j k rN t j } n6 | t j k ri t j } n | t j
k r t j } n | d k r¬ | j t j
| | n d S( s Receives lifecycle events from libvirt.
NB: this method is executing in a native thread, not
an eventlet coroutine. It can only invoke other libvirt
APIs, or use self._queue_event(). Any use of logging APIs
in particular is forbidden.
N( t
UUIDStringR R t VIR_DOMAIN_EVENT_STOPPEDt virteventt EVENT_LIFECYCLE_STOPPEDt VIR_DOMAIN_EVENT_STARTEDt EVENT_LIFECYCLE_STARTEDt VIR_DOMAIN_EVENT_SUSPENDEDt EVENT_LIFECYCLE_PAUSEDt VIR_DOMAIN_EVENT_RESUMEDt EVENT_LIFECYCLE_RESUMEDt _queue_eventt LifecycleEvent( t connt domR t detailt opaqueR, t uuidt
transition( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _event_lifecycle_callback
s
c C s% i | d 6| d 6} | j | d S( NRC t reason( RA ( R, RC RJ RF t
close_info( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _close_callback s c C s y | j t SWnf t j k
rz } | j t j t j f k rt | j t j t j f k rt t
j d t S n Xd S( Ns Connection to libvirt broke(
t
getLibVersionR2 R t libvirtErrort get_error_codet VIR_ERR_SYSTEM_ERRORt VIR_ERR_INTERNAL_ERRORt get_error_domaint VIR_FROM_REMOTEt VIR_FROM_RPCt LOGt debugR" ( RC t e( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _test_connection£ s
c C s9 t | d k r d St j t d t | d S( Ni s8 Can not handle authentication request for %d credentials( t lenR
t
NovaExceptionR ( t credsRF ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _connect_auth_cb± s
c C sv t j t j t j t j t j t j g t j d g } d } | rN t j
} n t j t j
t j f t j | | | S( Ni ( R t VIR_CRED_AUTHNAMEt VIR_CRED_ECHOPROMPTt VIR_CRED_REALMt VIR_CRED_PASSPHRASEt VIR_CRED_NOECHOPROMPTt VIR_CRED_EXTERNALR R\ R t VIR_CONNECT_ROR t
proxy_callt virDomaint
virConnectt openAuth( R- R. t autht flags( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _connect¹ s c C sP | j d k r d S| j j | d j } | j j | | j j d S( sä Puts an event on the queue for dispatch.
This method is called by the native event thread to
put events on the queue for later dispatch by the
green thread. Any use of logging APIs is forbidden.
Nt ( R) R t putt encodet _event_notify_sendt writet flush( R, R t c( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyRA Î s c C sQ y" | j j d } | s! t Wn t k
r6 d SXd } x | j j sÅ y\ | j j d t } t | t
j r | j | n! d | k rª d | k rª | } n Wq@ t
j k
rÁ q@ Xq@ W| d k rÖ d S| d } | j b | | j k rGt | d } t d | } d | _ | j d k rG| j t | qGn Wd QXd S( s¦ Wait for & dispatch events from native thread
Blocks until native thread indicates some events
are ready. Then dispatches all queued events.
i Nt blockRC RJ s Connection to libvirt lost: %s( t _event_notify_recvt readt AssertionErrort
ValueErrorR R) t emptyt getR" t
isinstanceR9 RB t _event_emit_delayedt native_Queuet EmptyR( R& t strR R ( R, t _ct last_close_eventR RC RJ t msg( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyR5 á s2
c sÈ f d } | j j j k rg j | j j j j | j d t j d | j n | j t j
k r· t j j
j | } | j | j <| j | | n
j | d S( s Emit events - possibly delayed.c s$ | d } j j | j d d S( s Callback function for greenthread. Called
to cleanup the _events_delayed dictionary when an event
was called.
i N( R* t popRG R ( t gtt argst kwargsR ( R, ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
event_cleanup
s
s3 Removed pending event for %s due to lifecycle eventN( RG R* t keyst cancelR R RU RV RH R9 R: R t spawn_afterR+ t _event_emitt link( R, R R
t id_( ( R, sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyRz s
c C s# | j d k r | j | n d S( N( R! R ( R, R ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyR ( s c C s% t j | _ yF t j \ } } t j | d d | _ t j | d d | _ WnÉ t t
f k
r t j t j
t j } | j d | j d t j t j
t j } | j d | j d f | j \ } } | j d d | _ t j | } | j d d | _ n Xd S( s° Create a self-pipe for the native thread to synchronize on.
This code is taken from the eventlet tpool module, under terms
of the Apache License v2.0.
t wbi t rbt localhosti2 i N( s localhosti ( R{ R R) t ost pipeR t GreenPipeRn Rs t ImportErrort NotImplementedErrort
native_socketR t AF_INETt SOCK_STREAMt bindt listent connectt getsocknamet acceptt makefilet GreenSocket( R, t rpipet wpipet sockt csockt nsockt addrt gsock( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _init_events_pipe, s
c C sm | j t j d t j d | j | _ | j j t | j j t j d t
j | j d S( sê Initializes the libvirt events subsystem.
This requires running a native thread to provide the
libvirt event loop integration. This forwards events
to a green thread which does the actual dispatching.
s Starting native event threadt targets Starting green dispatch threadN(
R¥ RU RV t native_threadingt ThreadR4 t
_event_threadt setDaemonR2 t startR t spawnR6 ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _init_eventsE s
c C s
t j d | j d } z | j | j | j } Wd d } | sM d } n | j d k ru | j t | | n X| | _ y0 t j d | | j d t
j | j | Wn: t
k
rë } t j t d i | j d 6| d 6 n Xy- t j d t | | j | j d Wne t t f k
rD} t j d | n= t
j k
r} t j t d i | j d 6| d 6 n X| S(
Ns Connecting to libvirt: %ss Failed to connect to libvirts# Registering for lifecycle events %ss. URI %(uri)s does not support events: %(error)sR- t errors% Registering for connection events: %ssV The version of python-libvirt does not support registerCloseCallback or is too old: %ss9 URI %(uri)s does not support connection events: %(error)s( RU RV R R Rj R R t boolR& t domainEventRegisterAnyR t VIR_DOMAIN_EVENT_ID_LIFECYCLERI t Exceptiont warningR R} t registerCloseCallbackRL t TypeErrort AttributeErrorRN ( R, t wrapped_connt disable_reasonRW ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _get_new_connectionX s<
c C sC | j 4 | j } | s* | j | r9 | j } n Wd QX| S( N( R( R& RX R¹ ( R, R· ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _get_connection s
c C s y | j } Wn t j k
r } t j t d | t d t j d d d | } t j
d j t j
d | t j d t j n X| S( sÏ Returns a connection to the hypervisor
This method should be used to create and return a well
configured connection to the hypervisor.
:returns: a libvirt.virConnect object
s Connection to libvirt failed: %st ipt methodRj RJ t computes compute.libvirt.errort host( Rº R RN RU R
R t dictt CONFt my_ipR t get_notifierR® t nova_contextt get_admin_contextt HypervisorUnavailableR¾ ( R, RC t ext payload( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_connection s c C s d S( N( ( R t err( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _libvirt_error_handler¨ s c C s4 t j | j d t j | j t | _ d S( N( R t registerErrorHandlerRÊ R t virEventRegisterDefaultImplR R2 t _initialized( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
initialize s
c C sÆ | j } y¡ | d k rF | j } | | t j | rF t Sn | d k r} | j } | | t j | r} t Sn | d k r¨ | j } | | k r¨ t Sn t SWn t k
rÁ t SXd S( s Check libvirt version, hypervisor version, and hypervisor type
:param hv_type: hypervisor driver from the top of this file.
N(
RÈ R RM R t convert_version_to_intR" t
getVersiont getTypeR2 R² ( R, t lv_vert hv_vert hv_typet opRC t libvirt_versiont hypervisor_versiont hypervisor_type( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _version_check¶ s&
c C s% | j d | d | d | d t j S( NRÒ RÓ RÔ RÕ ( RÙ t operatort lt( R, RÒ RÓ RÔ ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt has_min_versionÓ s c C s% | j d | d | d | d t j S( NRÒ RÓ RÔ RÕ ( RÙ RÚ t ne( R, RÒ RÓ RÔ ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt has_version× s c C s | j | j S( s» Retrieve libvirt domain object for an instance.
:param instance: an nova.objects.Instance object
Attempt to lookup the libvirt domain objects
corresponding to the Nova instance, based on
its name. If not found it will raise an
exception.InstanceNotFound exception. On other
errors, it will raise an exception.NovaException
exception.
:returns: a libvirt.Domain object
( t _get_domain_by_namet name( R, t instance( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
get_domainÜ s c C s t j | j | S( s¦ Retrieve libvirt domain object for an instance.
:param instance: an nova.objects.Instance object
:returns: a nova.virt.libvirt.Guest object
( t
libvirt_guestt GuestRâ ( R, Rá ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_guestì s c C s y | j } | j | SWnz t j k
r } | j } | t j k rb t j d | n t d i | d 6| d 6| d 6} t j | n Xd S( sÆ Retrieve libvirt domain object given an instance id.
All libvirt error handling should be handled in this method and
relevant nova exceptions should be raised in response.
t instance_idsW Error from libvirt while looking up %(instance_id)s: [Error Code %(error_code)s] %(ex)st
error_codeRÆ N(
RÈ t
lookupByIDR RN RO t VIR_ERR_NO_DOMAINR
t InstanceNotFoundR RZ ( R, Ræ RC RÆ Rç R ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _get_domain_by_idö s
c C s y | j } | j | SWnz t j k
r } | j } | t j k rb t j d | n t d i | d 6| d 6| d 6} t j | n Xd S( sÈ Retrieve libvirt domain object given an instance name.
All libvirt error handling should be handled in this method and
relevant nova exceptions should be raised in response.
Ræ sY Error from libvirt while looking up %(instance_name)s: [Error Code %(error_code)s] %(ex)st
instance_nameRç RÆ N(
RÈ t lookupByNameR RN RO Ré R
Rê R RZ ( R, Rì RC RÆ Rç R ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyRß s
c C s2 t j } | s | t j B} n | j j | S( N( R t VIR_CONNECT_LIST_DOMAINS_ACTIVEt! VIR_CONNECT_LIST_DOMAINS_INACTIVERÈ t listAllDomains( R, t only_runningRi ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _list_instance_domains_fast" s c C s g } g } | j j d k r xj | j j D]S } y3 | j | } | j | | j | j Wq7 t j k
r q7 q7 Xq7 Wn | r | Sxi | j j D]U } y5 | j | } | j | k rè | j | n Wq® t j k
rq® q® Xq® W| S( Ni (
RÈ t numOfDomainst
listDomainsIDRë t appendR7 R
Rê t listDefinedDomainsRß ( R, Rñ t uuidst domst idRD Rà ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _list_instance_domains_slow) s(
c C s2 g | j d | d | D] } t j | ^ q S( s0 Get a list of Guest objects for nova instances
:param only_running: True to only return running instances
:param only_guests: True to filter out any host domain (eg Dom-0)
See method "list_instance_domains" for more information.
:returns: list of Guest objects
Rñ t only_guests( t list_instance_domainsRã Rä ( R, Rñ Rû RD ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt list_guestsD s
c C sÅ | j sd y | j | } Wqd t j t f k
r` } t j t d i | d 6 t | _ qd Xn | j r | j | } n g } x9 | D]1 } | r° | j
d k r° q n | j | q W| S( s~ Get a list of libvirt.Domain objects for nova instances
:param only_running: True to only return running instances
:param only_guests: True to filter out any host domain (eg Dom-0)
Query libvirt to a get a list of all libvirt.Domain objects
that correspond to nova instances. If the only_running parameter
is true this list will only include active domains, otherwise
inactive domains will be included too. If the only_guests parameter
is true the list will have any "host" domain (aka Xen Domain-0)
filtered out.
:returns: list of libvirt.Domain objects
sK Unable to use bulk domain list APIs, falling back to slow code path: %(ex)sRÆ i ( R# Rò R RN R¶ RU t infoR
R2 Rú t IDRõ ( R, Rñ Rû t alldomsRÆ Rø RD ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyRü Q s
c C sY | j j \ } } } t } x. t | D] } | | r1 | j | q1 q1 W| S( s Get the set of CPUs that are online on the host
Method is only used by NUMA code paths which check on
libvirt version >= 1.0.4. getCPUMap() was introduced in
libvirt 1.0.0.
:returns: set of online CPUs, raises libvirtError on error
( RÈ t getCPUMapt sett ranget add( R, t cpust cpu_mapt onlinet online_cpust cpu( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_online_cpusw s
c C sM | j sF| j j } t j t d | t j | _ | j j | t t
d rF| j j j j
d k rFyh | j j | j j j j g t
j } | rÞ t j } | j | | j | j j j _ n WqCt
j k
r?} | j } | t
j k r9t j t d i | j d 6| d 6 q@ qCXqFn | j S( s Returns the host capabilities information
Returns an instance of config.LibvirtConfigCaps representing
the capabilities of the host.
Note: The result is cached in the member attribute _caps.
:returns: a config.LibvirtConfigCaps object
s Libvirt host capabilities %st( VIR_CONNECT_BASELINE_CPU_EXPAND_FEATURESsE URI %(uri)s does not support full set of host capabilities: %(error)sR- R® N( R$ RÈ t getCapabilitiesRU Rþ R
t vconfigt LibvirtConfigCapst parse_strt hasattrR R¾ R t modelR t baselineCPUt to_xmlR t LibvirtConfigCPUt featuresRN RO t VIR_ERR_NO_SUPPORTR³ R R ( R, t xmlstrR R RÆ Rç ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_capabilities s,
c C s | j j S( sL Get hypervisor type.
:returns: hypervisor type (ex. qemu)
( RÈ RÑ ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_driver_type° s c C s | j j S( sS Get hypervisor version.
:returns: hypervisor version (ex. 12003)
( RÈ RÐ ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_version¹ s c C sm | j j } | j d k r- | | _ n9 | | j k rf t j t d i | j d 6| d 6 n | j S( s' Returns the hostname of the hypervisor.sS Hostname has changed from %(old)s to %(new)s. A restart is required to take effect.t oldt newN( RÈ t getHostnameR% R RU R® R ( R, t hostname( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_hostname s
c C s½ | d k r t j } nO | d k r0 t j } n7 | d k rH t j } n t d } t j | | y | j } | j | | SWn/ t j k
r¸ } | j
t j k r¹ d Sn Xd S( s Find a secret.
usage_type: one of 'iscsi', 'ceph', 'rbd' or 'volume'
usage_id: name of resource in secret
t iscsit rbdt cepht volumes Invalid usage_type: %sN( s rbds ceph(
R t VIR_SECRET_USAGE_TYPE_ISCSIt VIR_SECRET_USAGE_TYPE_CEPHt VIR_SECRET_USAGE_TYPE_VOLUMER R
RZ RÈ t secretLookupByUsageRN RO t VIR_ERR_NO_SECRETR ( R, t
usage_typet usage_idt usage_type_constR RC RW ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt find_secretÎ s c C s. t j } t | _ t | _ | | _ | d k r? d | _ nO | d k rW d | _ n7 | d k ro d | _ n t d } t j | | | j
} yP t j d | | j
} | j | } | d k rå | j | n | SWn= t j k
r)t j t j t d | Wd QXn Xd S(
s Create a secret.
:param usage_type: one of 'iscsi', 'ceph', 'rbd' or 'volume'
'rbd' will be converted to 'ceph'.
:param usage_id: name of resource in secret
:param password: optional secret value to set
R! R" R R# s Invalid usage_type: %ss Secret XML: %ss$ Error defining a secret with XML: %sN( s rbds ceph( R
t LibvirtConfigSecretR" t ephemeralt privateR* R) R R
RZ R RU RV RÈ t secretDefineXMLR t setValueR RN R t save_and_reraise_exceptionR® R ( R, R) R* t passwordt secret_confR t xmlRC t secret( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
create_secretå s.
c C s/ | j | | } | d k r+ | j n d S( s
Delete a secret.
usage_type: one of 'iscsi', 'ceph', 'rbd' or 'volume'
usage_id: name of resource in secret
N( R, R t undefine( R, R) R* R6 ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
delete_secret s c C s | j j S( s{ Returns hardware information about the Node.
Note that the memory size is reported in MiB instead of KiB.
( RÈ t getInfo( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt _get_hardware_info s c C s | j d S( s- Returns the total numbers of cpu in the host.i ( R; ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
get_cpu_count s c C s | j d S( so Get the total memory size(MB) of physical computer.
:returns: the total amount of memory(MB).
i ( R; ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_memory_mb_total s c C sº t j j d k r d St d } | j j } Wd QX| j d } | j d } | j d } t j j d k rid } xÖ | j
d
t D]Â } y t | j
| d } Wn@ t j k
rý } t j t d i | j d
6| d 6 q n X| j d k r| | 7} q | | t | | d t | | d t | | d 7} q W| t j St | | d t | | d t | | d }
| j |
t j Sd S( sm Get the used memory size(MB) of physical computer.
:returns: the total usage of memory(MB).
t LINUX2t LINUX3i s
/proc/meminfoNs MemFree:s Buffers:s Cached:t xenRû i sC couldn't obtain the memory from domain: %(uuid)s, exception: %(ex)sRG RÆ i ( R> R? ( t syst platformt uppert openRt t splitt indexRÀ R t virt_typeRý R" t intt _get_domain_infoRN RU R³ R RG Rù R t KiR= ( R, t fpt mt idx1t idx2t idx3t usedR t dom_memRW t avail( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt get_memory_mb_used# s0
# 8c C s3 | j j t j d } | j d | d <| S( s9 Returns the current CPU state of the host with frequency.i i t frequency( RÈ t getCPUStatsR t VIR_NODE_CPU_STATS_ALL_CPUSR; ( R, t stats( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt
get_cpu_statsL s c C s | j j | S( s Defines a domain, but does not start it.
:param xml: XML domain definition of the guest.
:returns: a virDomain instance
( RÈ t defineXML( R, R5 ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt write_instance_configU s c C s | j j | S( sW Lookup a node device by its name.
:returns: a virNodeDevice instance
( RÈ t nodeDeviceLookupByName( R, Rà ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt device_lookup_by_name^ s i c C s | j j d | S( sP Lookup pci devices.
:returns: a list of virNodeDevice instance
t pci( RÈ t listDevices( R, Ri ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt list_pci_devicesf s c C s | j j | | S( s5 Compares the given CPU description with the host CPU.( RÈ t
compareCPU( R, t xmlDescRi ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt compare_cpum s c C sy y` t d d K } x= | j D]/ } | j d j d } d | k r" t Sq" Wt SWd QXWn t k
rt t SXd S( s¯ Returns whether kernel configuration CGROUP_SCHED is enabled
CONFIG_CGROUP_SCHED may be disabled in some kernel configs to
improve scheduler latency.
s /proc/self/mountst ri t ,R N( RD t readlinesRE R2 R" t IOError( R, t fdt linet bits( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt is_cpu_control_policy_capableq s
c C s t t d d d k S( sZ Determines whether libvirt is supporting dump XML suitable for
migration.
t VIR_DOMAIN_XML_MIGRATABLEN( t getattrR R ( R, ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt is_migratable_xml_flag s N(9 t __name__t
__module__R" R R1 R4 R6 t staticmethodRI RL RX R\ Rj RA R5 Rz R R¥ R R¹ Rº RÈ RÊ RÎ RÚ RÛ RÙ RÜ RÞ Râ Rå Rë Rß R2 Rò Rú Rý Rü R
R R R R R, R7 R9 R; R< R= RS RX RZ R\ R_ Rb Rj Rm ( ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyR M sh * 1
& % "
) (8 t __doc__RÚ R R RA R t eventletR R R R t oslo_logR t loggingt
oslo_utilsR R R R t sixt nova.conft novaR RÃ R
t nova.i18nR R R
R R R t nova.virtR R9 t nova.virt.libvirtR R
R Rã R R t getLoggerRn RU t originalR R§ t PY2R{ t confRÀ t HV_DRIVER_QEMUt
HV_DRIVER_XENt objectR ( ( ( sK /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/host.pyt <module> sH