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 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 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 d l" m# Z# e
j$ j% Z% e j& e' Z( d d Z* d Z+ d d d Z, d Z- d Z. d d d Z/ d d Z0 d d Z1 d Z2 d Z3 e4 e5 d d d Z6 d d d d d Z7 d d d Z8 d! Z9 d" Z: d# Z; d$ Z< d% Z= d& Z> d' Z? d( Z@ d) ZA d* ZB d+ ZC d, ZD d- ZE d. ZF d/ eG f d0 YZH d1 ZI d2 eG f d3 YZJ d S(4 s& Compute-related Utilities and helpers.iÿÿÿÿN( t log( t block_device( t power_state( t task_states( t exception( t _LW( t model( t
notifications( t base( t instance( t objects( t fields( t rpc( t
safe_utils( t utils( t driverc C sÕ d } t | d r- | j j d d } n y | sE | j } n Wn> t k
r y t j | } Wq t k
r d } q Xn X| s | j j } n t
j | d } t d | } | | d <| | d <| S( s7 Converts exceptions to a dict for use in notifications.iô t kwargst codeiÿ R t messageN(
t hasattrR t gett format_messaget Exceptiont sixt text_typet Nonet __class__t __name__R t
safe_truncatet dict( t faultR R t u_messaget
fault_dict( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt exception_to_dict0 s$
c C sS d } | rF | d k rF | d } | rF d j t j | } qF n t j | S( Nt iô i ( t joint tracebackt format_tbR R ( t exc_infot
error_codet detailst tb( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt _get_fault_detailsP s
c C sl t j d | } t j | _ | j | _ | j t | d | | j } t | | | _
| j d S( s) Adds the specified fault to the database.t contextR N( R
t
InstanceFaultt CONFt hostt uuidt
instance_uuidt updateR! R R* R( t create( R+ R R R& t
fault_messaget fault_objR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt add_instance_fault_from_excY s c C s/ t j | | } t | | j | d | S( sÈ Validates (or generates) a device name for instance.
This method is a wrapper for get_next_device_name that gets the list
of used devices and the root device from a block device mapping.
t root( R t instance_block_mappingt get_next_device_namet values( R t bdmst devicet mappings( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt get_device_name_for_instancef s c G s¬ g t j | D] } | j r | j ^ q } | | k rJ | j | n x[ t j | D]J } | j } | sZ t | | | } | | _ | j | j | qZ qZ Wd S( s. Generate missing device names for an instance.N( t itertoolst chaint device_namet appendR8 t save( R t root_device_namet block_device_listst bdmt dev_listt dev( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt! default_device_names_for_instanceq s
c C sÁ d } d } | r] y t j | \ } } Wq] t t t f k
rY t j d | q] Xn | so t j } n y t j t j | d } Wn, t t t f k
r½ t j d | n Xt
j rÓ d } n | | k r t j
d i | d 6| d 6 n t } x* | D]" } t j | } | j | qWt
j r| j }
|
j rg| j d n |
j r| j d qn | st | } n | | k r¹t j d | n | | S(
sÎ Validates (or generates) a device name for instance.
If device is not set, it will generate a unique device appropriate
for the instance. It uses the root_device_name (if provided) and
the list of used devices to find valid device names. If the device
name is valid but applicable to a different backend (for example
/dev/vdc is specified but the backend uses /dev/xvdc), the device
name will be converted to the appropriate format.
t pathi s /dev/xvds* Using %(prefix)s instead of %(req_prefix)st prefixt
req_prefixt bt cN( R R t match_devicet TypeErrort AttributeErrort
ValueErrorR t InvalidDevicePatht DEFAULT_ROOT_DEV_NAMEt prepend_devR t is_xenapit LOGt debugt sett get_device_lettert addt
get_flavort ephemeral_gbt swapt _get_unused_lettert DevicePathInUse( R t device_name_listRC R; RK t
req_letterRJ t used_letterst device_patht lettert flavor( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR8
sD
c C sV | d k rL t | t j r* | j } n
| d } t j j | | } n | j S( NR/ ( R t
isinstanceR
t InstanceR/ t BlockDeviceMappingListt get_by_instance_uuidt root_bdm( R+ R R: R/ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt get_root_bdmà s
c C sH t | | | } | d k r% | j St | t j r? | j S| d S( Nt image_ref( Rk R t is_volumeRf R
Rg Rl ( R+ R R: Rj ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt is_volume_backed_instanceÏ s c C st g t j D] } t j D] } | | ^ q q
} t t t j | } t | | } | j d d | d S( Nt keyc S s | j d d S( Ni t `( t rjust( t x( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt <lambda>á s i ( t stringt ascii_lowercaseRX t listt sort( Rb t secondt firstt doublest all_letterst letters( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR^ Û s c C st | j j | | } y | | SWnJ t k
ro t j t d i | d 6| d 6| d 6| d 6d | | SXd S( s Get a value of a specified type from image metadata.
@param instance: The instance object
@param key: The name of the property to get
@param type: The python type the value is be returned as
@param default: The value to return if key is not set or not the right type
s^ Metadata value %(value)s for %(key)s is not of type %(type)s. Using default value %(default)s.t valueRo t typet defaultR N( t system_metadataR RQ RV t warningR ( R Ro R~ R R} ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt get_value_from_system_metadataå s
c C s½ t j | \ } } t j | | | } | d k rH t j | } n t j | }
t d t | d t | d | d |
} | r | j | n t
| | | d d | d | d S( sþ Generates 'exists' notification for an instance for usage auditing
purposes.
:param notifier: a messaging.Notifier
:param current_period: if True, this will generate a usage for the
current usage period; if False, this will generate a usage for the
previous audit period.
:param ignore_missing_network_data: if True, log any exceptions generated
while getting network info; if False, raise the exception.
:param system_metadata: system_metadata DB entries for the instance,
if not None. *NOTE*: Currently unused here in trunk, but needed for
potential custom modifications.
:param extra_usage_info: Dictionary containing extra values to add or
override in the notification if not None.
t audit_period_beginningt audit_period_endingt bandwidtht
image_metat existsR t extra_usage_infoN( R t audit_period_boundst bandwidth_usageR R t instance_sys_metaR R t strR1 t notify_about_instance_usage( t notifierR+ t instance_reft current_periodt ignore_missing_network_dataR R t audit_startt audit_endt bwR t
extra_info( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt notify_usage_existsø s c C s | s i } n t j | | | | | } | rc t | } t j | d d | | j | n | j d r~ | j }
n | j }
|
| d | | d S( s¦ Send a notification about an instance.
:param notifier: a messaging.Notifier
:param event_suffix: Event type like "delete.start" or "exists"
:param network_info: Networking information, if provided.
:param system_metadata: system_metadata DB entries for the instance,
if provided.
:param extra_usage_info: Dictionary containing extra values to add or
override in the notification.
R R t errors compute.instance.%sN( R t info_from_instanceR! RV RW R1 t endswithR t info( R R+ R t event_suffixt network_infoR R R t
usage_infot
fault_payloadt method( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR # s
s nova-computec
C sM t | } g } | d k r¦ x
| D]z } xq | j D]c } | j t j d | d d d | d d | d d | d d | d d | d d | d
q8 Wq% Wn t j d | }
t j d | d d d
| d |
} t j d | d t j
j d t j
d | d | d | d t j d d d | d | d | } | j | d S( sF Send versioned notification about the action made on the instance
:param instance: the instance which the action performed on
:param host: the host emitting the notification
:param action: the name of the action
:param phase: the phase of the action
:param binary: the binary emitting the notification
t labelt networkt mact addresst metat port_uuidt idt versionR@ t devnameR R t ip_addressesRe R+ t priorityt publisherR. t binaryt
event_typet objectt actiont phaset payloadN( t get_nw_info_for_instanceR t fixed_ipsRA t instance_notificationt IpPayloadt
FlavorPayloadt InstanceActionPayloadt InstanceActionNotificationR t NotificationPriorityt INFOt notification_baset NotificationPublishert EventTypet emit(
R+ R R. R¯ R° R¬ R t ipst vift ipRe R± t notification( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt notify_about_instance_actionD s<
c C s- t j d d } | j | d | | d S( s³ Send a notification about server group update.
:param event_suffix: Event type like "create.start" or "create.end"
:param sg_payload: payload for server group update
t servicet servergroups servergroup.%sN( R t get_notifierR ( R+ R t
sg_payloadR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt notify_about_server_group_updateo s c C sw | j d d } | sD | j d d } | sD t j d d Sn t j d d d | } | j | d | | d S( s´ Send a notification about aggregate update.
:param event_suffix: Event type like "create.start" or "create.end"
:param aggregate_payload: payload for aggregate update
t aggregate_idt namesN No aggregate id or name specified for this notification and it will be ignoredNRÄ t aggregateR. s aggregate.%s( R R RV RW R RÆ R ( R+ R t aggregate_payloadt aggregate_identifierR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt notify_about_aggregate_updatez s
c C sb | j d } | s/ t j t d | d St j d d d | } | j | d | | d S( s$ Send a notification about host update.
:param event_suffix: Event type like "create.start" or "create.end"
:param host_payload: payload for host update. It is a dict and there
should be at least the 'host_name' key in this
dict.
t host_namesP No host name specified for the notification of HostAPI.%s and it will be ignoredNRÄ t apiR. s
HostAPI.%s( R RV R R R RÆ R ( R+ R t host_payloadt host_identifierR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt notify_about_host_update s c C s) | j d k r t j j g S| j j S( N( t
info_cacheR t
network_modelt NetworkInfot hydrateR ( R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR² ¡ s c C s# | j d k r | j j n d S( sW Refresh the info cache for an instance.
:param instance: The instance object.
N( RÔ R t refresh( R+ R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt refresh_info_cache_for_instance§ s c C sÔ d } | j } | j } | r9 | r9 t | | } n | rH | } n | } t d | j d | j d | j d | j d | j d | | d | j | j
d | j | j d
| j
| j d | j | j
} | S( Nc S s | r t | Sd S( NR" ( R ( t s( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt
null_safe_str± s t volume_idt tenant_idt user_idt availability_zonet instance_idt last_refreshedt readst
read_bytest writest write_bytes( t tot_last_refreshedt curr_last_refreshedt maxR RÜ t
project_idRÞ Rß R0 t tot_readst
curr_readst tot_read_bytest curr_read_bytest
tot_writest curr_writest tot_write_bytest curr_write_bytes( t vol_usageRÛ t
tot_refreshedt curr_refreshedt last_refreshed_timeR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt usage_volume_info° s,
c C sG | t j k r d St j t j t j g } | | k r= d n d } | S( s< Checks if the current instance state requires a HARD reboot.t HARDt SOFT( R t RUNNINGR t REBOOT_STARTEDt REBOOT_PENDINGt REBOOTING( t
task_statet current_power_statet
soft_typest reboot_type( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt get_reboot_typeÏ s c C sÈ g } x» t j D] } y t j | } x} | D]u } | t j t j f k rV q2 n xN | | D]B } | d } | t j k r | j d d } n | j | qa Wq2 WWq t k
r¿ q Xq W| S( sR Get the machine's ip addresses
:returns: list of Strings of ip addresses
t addrt %i ( t netifacest
interfacest ifaddressest AF_INETt AF_INET6t splitRA RQ ( t addressest interfacet
iface_datat familyR£ R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt get_machine_ipsÙ s
c sq f d } i } | | d d k rD | d | d <n | | d d k rm | d | d <n | S( sC Calculate any quota adjustment required at a particular point
in the resize cycle.
:param context: the request context
:param new_flavor: the target instance type
:param old_flavor: the original instance type
:param sense: the sense of the adjustment, 1 indicates a
forward adjustment, whereas -1 indicates a
reversal of a prior adjustment
:param compare: the direction of the comparison, 1 indicates
we're checking for positive deltas, whereas
-1 indicates negative deltas
c s | | S( N( ( t resource( t
new_flavort
old_flavort sense( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt _quota_delta s t vcpusi t corest memory_mbt ram( ( R+ R R R t compareR t deltas( ( R R R sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt resize_quota_deltaò s c C s t | | | d d S( sF Calculate deltas required to adjust quota for an instance upsize.
i ( R ( R+ R R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt upsize_quota_delta s c C s t | | j | j d d S( sP Calculate deltas required to reverse a prior upsizing
quota adjustment.
iÿÿÿÿ( R R R ( R+ R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt reverse_upsize_quota_delta s c C s4 | j d } | j d } t | | | d d S( sH Calculate deltas required to adjust quota for an instance downsize.
t oldt newi iÿÿÿÿ( R[ R ( R+ R R R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt downsize_quota_delta s c C sS t j d | } | rO t j j | | \ } } | j d | d | | n | S( s If there are deltas to reserve, construct a Quotas object and
reserve the deltas for the given project.
:param context: The nova request context.
:param deltas: A dictionary of the proposed delta changes.
:param instance: The instance we're operating on, so that
quotas can use the correct project_id/user_id.
:return: nova.objects.quotas.Quotas
R+ Ré RÞ ( R
t Quotast quotast ids_from_instancet reserve( R+ R R R! Ré RÞ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt reserve_quota_delta" s
c C s: x3 d d d g D]" } | | j k r | j | =q q Wd S( Nt
shelved_att shelved_image_idt shelved_host( R ( R Ro ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt( remove_shelved_keys_from_system_metadata5 s t
EventReporterc B s) e Z d Z d Z d Z d Z RS( s1 Context manager to report instance action events.c G s | | _ | | _ | | _ d S( N( R+ t
event_namet instance_uuids( t selfR+ R* R+ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt __init__? s c C s: x3 | j D]( } t j j | j | | j d t q
W| S( Nt want_result( R+ R
t InstanceActionEventt event_startR+ R* t False( R, R/ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt __enter__D s c C sF x? | j D]4 } t j j | j | | j d | d | d t q
Wt S( Nt exc_valt exc_tbR. ( R+ R
R/ t event_finish_with_failureR+ R* R1 ( R, t exc_typeR3 R4 R/ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt __exit__K s
( R t
__module__t __doc__R- R2 R7 ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR) < s c s" t j d f d } | S( s Wraps a method to log the event taken on the instance, and result.
This decorator wraps a method to log the start and result of an event, as
part of an action taken on an instance.
R c s% t j f d } | S( Nc s} t j } t j | | | | | } | d d } d j j } t | | | | | | | SWd QXd S( NR R/ s {0}_{1}( R
t get_wrapped_functiont inspectt getcallargst formatR R) ( R, R+ t argsR t wrapped_funct
keyed_argsR0 R* ( t functionRJ ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt decorated_function\ s ( t functoolst wraps( RA RB ( RJ ( RA sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt helperY s !
( R t expects_func_args( RJ RE ( ( RJ sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt wrap_instance_eventS s t UnlimitedSemaphorec B s) e Z d Z d Z e d Z RS( c C s d S( N( ( R, ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR2 k s c C s d S( N( ( R, R6 R3 R4 ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyR7 n s c C s d S( Ni ( ( R, ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt balanceq s ( R R8 R2 R7 t propertyRI ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyRH j s (K R9 RC R; R> Rt R$ R t oslo_logR R t novaR t nova.computeR R t nova.confR t nova.i18nR t nova.networkR RÕ R t nova.notifications.objectsR R» R R´ R
t nova.objectsR R R
R t nova.virtR t confR- t getLoggerR RV R R! R* R5 R= RH R8 Rk Rn R^ R R1 t TrueR R RÃ RÈ RÎ RÓ R² RÙ Rö R R R R R R R$ R( R® R) RG RH ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/compute/utils.pyt <module> sz =
* *