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 / dmapi deb
Repository URL to install this package:
|
Version:
4.0.102 ▾
|
ó
Xpö^c @ 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 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 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 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* Z* d d l+ m, Z, d d l- Z. d d l. m/ Z/ d d l0 m1 Z1 m2 Z2 m3 Z3 m4 Z4 d d l. m5 Z5 e& j6 d Z7 e. j8 j9 Z9 e j: e; Z< d Z> e j? d Z@ d ZA d` ZB da ZC db ZD i aE d" ZF d# eG f d$ YZH d% eH f d& YZI d' ZJ d( ZK d) ZL d* d+ ZM dc ZN d d d/ ZO d eN d0 ZP d1 ZQ d2 ZR d3 ZS d4 ZT d5 ZU d6 ZV d7 ZW d d8 ZX e jY d9 ZZ d: Z[ e jY d d; Z\ e jY d< Z] d d= Z^ d> eG f d? YZ_ d e` d@ Za e` dA Zb dB Zc dC Zd dD Ze dE Zf dF eG f dG YZg d dH d dI Zh d d dJ Zi dK Zj dL Zk dM Zl dN Zm dO Zn d d dP Zo dQ Zp d dR Zq dS Zr dT Zs dU Zt dV Zu dW Zv d dX Zw dY Zx e` dZ Zy d[ Zz d d\ Z{ d] Z| d^ Z} d_ Z~ d S(d s Utilities and helper functions.iÿÿÿÿN( t
exceptions( t loading( t lockutils( t processutils( t context( t log( t encodeutils( t excutils( t importutils( t strutils( t timeutils( t units( t range( t exception( t _t _LEt _LIt _LW( t
safe_utilss osprofiler.profilers dmapi-t image_t min_ramt min_diskt disk_formatt container_formatt mappingst block_device_mappingt img_mappingst img_block_device_mappingt image_idt
image_namet sizet checksumc C s& t j j r d } n
d t j } | S( Nt sudos sudo dmapi-rootwrap %s( t CONFt workaroundst disable_rootwrapt rootwrap_config( t cmd( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_root_helperQ s
t RootwrapProcessHelperc B s e Z d Z d Z RS( c O s t | d <t j | | S( Nt root_helper( R& R t trycmd( t selfR% t kwargs( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR) Z s
c O s t | d <t j | | S( NR( ( R& R t execute( R* R% R+ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR, ^ s
( t __name__t
__module__R) R, ( ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR' Y s t RootwrapDaemonHelperc B s> e Z i Z e d d Z d Z d Z d Z RS( s daemon-client-lockc C s] y | j | SWnG t k
rX d d l m } | j d d | g } | | j | <| SXd S( Niÿÿÿÿ( t clientR s dmapi-rootwrap-daemon( t _clientst KeyErrort
oslo_rootwrapR0 t Client( t clsR$ R0 t
new_client( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _get_clientf s
c C s | j | | _ d S( N( R7 R0 ( R* R$ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt __init__q s c O s | j d t } y" | j | | \ } } t } Wn2 t j k
rh } d t j | } } t } n X| r
| r
| r
d } n | | f S( Nt discard_warningst ( t popt FalseR, R t ProcessExecutionErrort sixt text_typet True( R* t argsR+ R9 t outt errt failedt exn( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR) t s
c O s g | D] } t | ^ q } | j d t j } | j d d } | j d d } | j d t } | j d d } | j d d g } t }
t | t r¹ | }
d g } n t | t rÔ | g } n t
j d j | } t
j t d
i | d 6| d 6 xñ| d k r| d 8} yá t j } t
j | t d
| | j j | | \ }
} } t j | } t
j | d i | d 6|
d 6| d 6 |
rÿ|
| k rÿt
j | } t
j | } t j d |
d | d | d | n | | f SWqt j k
rÿ} | t j k sD| t j k r| rt d } t
j | | i | j d 6| j d 6| j d 6| j d 6| j d 6 n | s½t
j | t d | q t
j | t d | | r t j t j d d d q qXqWd S( Nt loglevelt
log_errorst
process_inputt delay_on_retryt attemptsi t check_exit_codei t sH Executing RootwrapDaemonHelper.execute cmd=[%(cmd)r] kwargs=[%(kwargs)r]R% R+ s Running cmd (subprocess): %ssE CMD "%(sanitized_cmd)s" returned: %(return_code)s in %(end_time)0.3fst
sanitized_cmdt return_codet end_timet exit_codet stdoutt stderrsS %(desc)r
command: %(cmd)r
exit code: %(code)r
stdout: %(stdout)r
stderr: %(stderr)rt desct codes %r failed. Not Retrying.s %r failed. Retrying.i iÈ g Y@(! t strR; t loggingt DEBUGt NoneR@ R< t
isinstancet boolt intR t
mask_passwordt joint LOGt infoR t timeR R R0 R, R R= t LOG_ALL_ERRORSt LOG_FINAL_ERRORt descriptionR% RP RQ RR t sleept randomt randint( R* R% R+ t cRF RG RH RI RJ RK t ignore_exit_codeRM t
start_timet
returncodeRB RC RO t format( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR, sr
( R- R. R1 t synchronizedR7 R8 R) R, ( ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR/ c s
c O sc d | k rS | j d rS t j r= t t j j | | St j | | Sn t j | | S( s3 Convenience wrapper around oslo's execute() method.t run_as_root( t getR! t use_rootwrap_daemonR/ R$ R, R' R ( R% R+ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR, Î s
c O s6 d d d g } | j | | j | t | | S( s+ Convenience wrapper to execute ssh command.t sshs -os
BatchMode=yes( t appendt extendR, ( t destR% R+ t ssh_cmd( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt ssh_executeÙ s
c O sZ | j d t rJ t j r4 t t j j | | St j | | Sn t j | | S( s2 Convenience wrapper around oslo's trycmd() method.Rm ( Rn R< R! Ro R/ R$ R) R' R ( RA R+ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR) á s
i c C sE d } g t | D] } t j | ^ q } d | d j | f S( Nt% 01234567890abcdefghijklmnopqrstuvwxyzs %s-%sR: ( R Re t choiceR] ( t topicR t
characterst _xt choices( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt generate_uidì s (t 23456789t ABCDEFGHJKLMNPQRSTUVWXYZt abcdefghijkmnopqrstuvwxyzc C sR | s t j } n d } d | k rK | j d d \ } } t | } n | d k r` | } n t j } | d k r t t d n | d k r¦| d k r® d } n t j d | d | j
d | j } | | k rB| j } d | j
k r| d 8} d | j
d } n
| j
d } t j d | d | d | } n | j } d | j
k rx| d 8} d | j
d } n
| j
d } t j d | d | d | } n¢| d k ri| d k rÇd } n t j d d d | d | j } | | k rAt j d d d | d | j d } t j d d d | d | j d
} qHt j d d d | d | j d } nß | d k ràt j d | d | j d | j
d | j } | | k rÇ| t j
d d } n | t j
d d } nh | d k rH| j d | d
d d d } | | k r/| t j
d d } n | t j
d d } n | | f S( s§ This method gives you the most recently *completed* audit period.
arguments:
units: string, one of 'hour', 'day', 'month', 'year'
Periods normally begin at the beginning (UTC) of the
period unit (So a 'day' period begins at midnight UTC,
a 'month' unit on the 1st, a 'year' on Jan, 1)
unit string may be appended with an optional offset
like so: 'day@18' This will begin the period at 18:00
UTC. 'month@15' starts a monthly period on the 15th,
and year@3 begins a yearly one on March 1st.
before: Give the audit period most recently completed before
<timestamp>. Defaults to now.
returns: 2 tuple of datetimes (begin, end)
The begin timestamp of this audit period is the same as the
end of the previous.
i t @i t montht dayt yeart hours, Time period must be hour, day, month or yeari i t dayst minutet secondt microsecondt hoursN( s months days years hour( R! t instance_usage_audit_periodt splitR[ RX R
t utcnowt
ValueErrorR t datetimeR R R t timedeltat replace( t unitt beforet offsett rightnowt endR R t begin( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt last_completed_audit_periodù sx
! ! c C sÅ | d k r t j } n t j } g | D] } | j | ^ q+ } | j | | | } | t | 8} d j | } | j g t
| D] } | j | ^ q | j | d j | S( s Generate a random password from the supplied symbol groups.
At least one symbol from each group will be included. Unpredictable
results if length is less than the number of symbol groups.
Believed to be reasonably secure (with a reasonable password length!)
R: N( RX R! t password_lengthRe t SystemRandomRw t shufflet lenR] Rr R ( t lengtht symbolgroupst rt st passwordt symbolst _i( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt generate_passwordU s "
/
c C sS | d k s t | t j r" | St | t j sF t j | } n | j d S( s³ Try to turn a string into utf-8 if possible.
The original code was copied from the utf8 function in
http://github.com/facebook/tornado/blob/master/tornado/escape.py
s utf-8N( RX RY R> t binary_typeR? t encode( t value( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt utf8z s
c C sÖ y t j | r | d f S| j d d k r_ | j d d d j d \ } } | | f S| j d d k r~ | d f S| j d \ } } | | f SWn1 t t j f k
rÑ t j t d | d SXd S(
sô Parses the given server_string and returns a tuple of host and port.
If it's not a combination of host part and port, the port element
is an empty string. If the input is invalid expression, return a tuple of
two empty strings.
R: s ]:iÿÿÿÿt [i t :s Invalid server_string: %sN( R: R: (
t netaddrt
valid_ipv6t findR R R t AddrFormatErrorR^ t errorR ( t
server_strt addresst port( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt parse_server_string s
$
c C s% t j | d d } t | j S( Nt versioni ( Rª t IPAddressRU t ipv6( R° t addr( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_shortened_ipv6§ s c C s" t j | d d } t | j S( NR³ i ( Rª t IPNetworkRU t cidr( R° t net( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_shortened_ipv6_cidr¬ s c C sE y$ t j | j d k r# d | SWn t t j f k
r@ n X| S( s Transform ip string to "safe" format.
Will return ipv4 addresses unchanged, but will nest ipv6 addresses
inside square brackets.
i s [%s]( Rª R´ R³ t TypeErrorR ( t ip( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt safe_ip_format± s c C s$ | d k r | Sd t | | f S( sÌ Returns remote path in format acceptable for scp/rsync.
If host is IPv6 address literal, return '[host]:path', otherwise
'host:path' is returned.
If host is None, only path is returned.
s %s:%sN( RX R¾ ( t hostt path( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt format_remote_pathÀ s c C s t j s
d St j d t j r/ t j } n d } x@t j D]5} | j d \ } } t
j | } t | t
j | } xï t | j D]Û \ } } t | t
j rt
j d | | f } xI t j | | D]2 \ } }
t | | | d | | | f |
qâ Wn t | t
j r t
j d | | f }
t t j | | | d | | f |
q q WqB Wd S( sÿ DEPRECATED: If the CONF.monkey_patch set as True,
this function patches a decorator
for all functions in specified modules.
You can set decorators for each modules
using CONF.monkey_patch_modules.
The format is "Module path:Decorator function".
Example:
'dmapi.api.ec2.cloud:dmapi.notifications.notify_decorator'
Parameters of the decorator is as follows.
(See dmapi.notifications.notify_decorator)
name - name of the function
function - object of the function
Ns0 Monkey patching dmapi is deprecated for removal.c S s t j | p t j | S( N( t inspectt ismethodt
isfunction( t obj( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt is_methodæ s R© s %s.%ss %s.%s.%s( R! t monkey_patchR^ t warningR> t PY2RÂ RÃ t monkey_patch_modulesR R t import_classt
__import__t pyclbrt
readmodule_ext listt itemsRY t Classt
getmemberst setattrt Functiont syst modules( RÆ t module_and_decoratort modulet decorator_namet decoratort module_datat keyR¦ t clzt methodt func( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRÇ Ï s*
$c C s d } t | t j rK | j d d } t j rK | j d } qK n | | } t j d d | } t j d d | } | j } | j d } | d k r¾ | d k r¾ | | S| S(
ss Return a hostname which conforms to RFC-952 and RFC-1123 specs except
the length of hostname.
Window, Linux, and Dnsmasq has different limitation:
Windows: 255 (net_bios limits to 15, but window will truncate it)
Linux: 64
Dnsmasq: 63
Due to dmapi-network will leverage dnsmasq to set hostname, so we chose
63.
c S sE t | d k r= t j t d i | d 6| d d 6 n | d S( Ni? sJ Hostname %(hostname)s is longer than 63, truncate it to %(truncated_name)st hostnamet truncated_name( R R^ RÈ R ( t name( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt truncate_hostname s s latin-1t ignores [ _]t -s [^\w.-]+R: s .-N( RY R> R? R¥ t PY3t decodet ret subt lowert stripRX ( Rà t default_nameRã ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt sanitize_hostnameÿ s
c
+ sî d f d } f d } f d } t } i } xF t | j D]2 \ } } | | | | | | <| | | | qX Wz d VWd xL t | j D]8 \ } } | | k rÕ | | | q | | | | q WXd S( s4 Temporarily set the attr on a particular object to a given value then
revert when finished.
One use of this is to temporarily set the read_deleted flag on a context
object:
with temporary_mutation(context, read_deleted="yes"):
do_something_that_needed_deleted_objects()
c S s t | d p t | t S( Nt has_key( t hasattrRY t dict( t thing( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt is_dict_like2 s c s0 | r | j | | St | | | Sd S( N( Rn t getattr( Rñ t attrt default( Rò ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRn 5 s c s- | r | | | <n t | | | d S( N( RÓ ( Rñ Rô t val( Rò ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt set_value; s
c s' | r | | =n
t | | d S( N( t delattr( Rñ Rô ( Rò ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt deleteA s
N( t objectRÏ RÐ (
RÅ R+ Rn R÷ Rù t NOT_PRESENTt
old_valuesRô t new_valuet old_value( ( Rò s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt temporary_mutation' s c C s` d d d t j d d t j d d t j d d g } d j g | D] } d | ^ qI S( s! Generate an Ethernet MAC address.iú i i> i iÿ R© s %02x( Re Rf R] ( t mact x( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt generate_mac_addressX s
c c s | d k r t j } n t j | j } | | k rU t j j j | d | n z d VWd | | k r t j j j | d | n Xd S( sg Temporarily chown a path.
:param owner_uid: UID of temporary owner (defaults to current user)
t uidN( RX t ost getuidt statt st_uidt dmapit privsepRÀ t chown( RÀ t owner_uidt orig_uid( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt temporary_chownk s c k s
| j } d | k r( t j | d <n t j | } z | VWd y t j | Wn) t k
r } t j t
d | n XXd S( Nt dirs Could not remove tmpdir: %s( t copyR! t tempdirt tempfilet mkdtempt shutilt rmtreet OSErrorR^ R® R ( R+ t argdictt tmpdirt e( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR s c c sj | s g } n xT | j D]F } | | k r | j | x t | | D] } | VqK W| Vq q Wd S( s: Walk class hierarchy, yielding most derived classes first.N( t __subclasses__Rq t walk_class_hierarchy( t clazzt encounteredt subclasst subsubclass( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR s
t UndoManagerc B s5 e Z d Z d Z d Z d Z d d Z RS( si Provides a mechanism to facilitate rolling back a series of actions
when an exception is raised.
c C s
g | _ d S( N( t
undo_stack( R* ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR8 s c C s | j j | d S( N( R Rq ( R* t undo_func( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt undo_with¢ s c C s% x t | j D]
} | q Wd S( N( t reversedR ( R* R! ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _rollback¥ s c K s: t j ( | r& t j | | n | j Wd QXd S( s¦ Rollback a series of actions then re-raise the exception.
.. note:: (sirp) This should only be called within an
exception handler.
N( R t save_and_reraise_exceptionR^ R
R$ ( R* t msgR+ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt rollback_and_reraise© s
N( R- R. t __doc__R8 R" R$ RX R' ( ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR s
c C s | d k r d g } n d d | g } | d k rF | j d g n | r} | d k ra d } n d } | j | | g n | j | t d
| | d S( sç Format a file or block device
:param fs: Filesystem type (examples include 'swap', 'ext3', 'ext4'
'btrfs', etc.)
:param path: Path to file or block device to format
:param label: Volume label to use
t swapt mkswapt mkfss -tt ext3t ext4t ntfss -Ft msdost vfats -ns -LRm N( R, R- R. ( R/ R0 ( Rr Rq R, ( t fsRÀ t labelRm RA t label_opt( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR+ ¶ s
c C sI i } x< | D]4 } | r/ | j d r/ q
n | d | | d <q
W| S( Nt deletedR¦ RÜ ( Rn ( t metadatat include_deletedt resultt item( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt metadata_to_dictÏ s
c C sI g } x< t | j D]( \ } } | j t d | d | q W| S( NRÜ R¦ ( RÏ RÐ Rq Rð ( R5 R7 RÜ R¦ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt dict_to_metadataØ s c C s- t | d t r | d St | d Sd S( NR5 ( RY Rð R9 ( t instance( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt
instance_metaß s c C sF | j d s i St | d t r. | d St | d d t Sd S( Nt system_metadataR6 ( Rn RY Rð R9 R@ ( R; ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt instance_sys_metaæ s
c s f d } | S( Nc s% t j f d } | S( Nc s t j | } t j | \ } } } } | sN | sN t t | k rX | St d i | j d 6 j d 6 d S( Ns^ Decorated function %(f_name)s does not have the arguments expected by the decorator %(d_name)st f_namet d_name( R t get_wrapped_functionRÂ t
getargspect setR¼ R- ( t ft base_ft arg_namest at kwt _default( RA t dec( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt
_decoratorò s $
( t functoolst wraps( RJ RK ( RA ( RJ s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _decorator_checkerñ s !( ( RA RN ( ( RA s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt expects_func_argsð s t ExceptionHelperc B s e Z d Z d Z d Z RS( sr Class to wrap another and translate the ClientExceptions raised by its
function calls to the actual ones.
c C s
| | _ d S( N( t _target( R* t target( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR8
s c s4 t | j | t j f d } | S( Nc s> y | | SWn& t j k
r9 } t j | j n Xd S( N( t messagingt ExpectedExceptionR> t reraiset exc_info( RA R+ R ( Rß ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt wrapper s ( Ró RQ RL RM ( R* Râ RW ( ( Rß s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt __getattr__
s ( R- R. R( R8 RX ( ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRP s i c C sû t | t j sR | d k r- t d } n t d | } t j d | n | d k rg | } n t | | k r¬ t d i | d 6| d 6} t j d | n | r÷ t | | k r÷ t d i | d 6| d 6} t j d | n d S(
sã Check the length of specified string
:param value: the value of the string
:param name: the name of the string
:param min_length: the min_length of the string
:param max_length: the max_length of the string
s$ The input is not a string or unicodes %s is not a string or unicodet messages? %(name)s has a minimum character requirement of %(min_length)s.Râ t
min_lengths1 %(name)s has more than %(max_length)s characters.t
max_lengthN( RY R> t string_typesRX R R
t InvalidInputR ( R¦ Râ RZ R[ R& ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt check_string_length s c C sO y t j | | | | SWn. t k
rJ } t j d t j | n Xd S( sA Make sure that value is a valid integer, potentially within range.
:param value: value of the integer
:param name: name of the integer
:param min_value: min_value of the integer
:param max_value: max_value of the integer
:returns: integer
:raise: InvalidInput If value is not a valid integer
t reasonN( R t validate_integerR R
R] R> R? ( R¦ Râ t min_valuet max_valueR ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR` 5 s
c C sS t s
d St j } d } | rO i | j d 6| j d 6| j d 6} n | S( Nt hmac_keyt base_idt parent_id( t profilerRX Rn Rc t get_base_idt get_id( t proft
trace_info( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _serialize_profile_infoE s
c sL t j t t j f d } t j | | | S( sm Passthrough method for eventlet.spawn.
This utility exists so that it can be stubbed for testing without
interfering with the service spawns.
It will also grab the context from the threadlocal store and add it to
the store on the new thread. This allows for continuity in logging the
context when using this method to spawn a new thread.
c sB d k r j n r5 t r5 t j n | | S( N( RX t update_storeRf t init( RA R+ ( t _contextRß t
profiler_info( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt context_wrapperb s
( t common_contextt get_currentRk RL RM t eventlett spawn( Rß RA R+ Rp ( ( Rn Rß Ro s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRt U s
$
c sP t j t t j f d } t j | | | d S( so Passthrough method for eventlet.spawn_n.
This utility exists so that it can be stubbed for testing without
interfering with the service spawns.
It will also grab the context from the threadlocal store and add it to
the store on the new thread. This allows for continuity in logging the
context when using this method to spawn a new thread.
c sF d k r j n r5 t r5 t j n | | d S( N( RX Rl Rf Rm ( RA R+ ( Rn Rß Ro ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRp | s
N( Rq Rr Rk RL RM Rs t spawn_n( Rß RA R+ Rp ( ( Rn Rß Ro s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRu o s
$
c C s& t | t j s t S| j d k S( s/ Check if a string represents a None value.
t none( RY R> R\ R< Rê ( Rö ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt is_none_string s c C s@ t } | d k r< | j j } | d k r< t } q< n | S( Nt disabled( R< RX Rë Rê R@ ( t auto_disk_config_rawt auto_disk_config_disabledt adc_lowered( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt is_auto_disk_config_disabled s c C s( | d k r t | } n | j d S( Nt image_auto_disk_config( RX R> Rn ( R; t sys_meta( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt" get_auto_disk_config_from_instance s c C s
| j d S( Nt auto_disk_config( Rn ( t image_properties( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt% get_auto_disk_config_from_image_props¡ s c C s i } t d } xd t | j d i j D]D \ } } | t k rM q/ n t t j | d } | | | | <q/ Wx t D]
} | j | } | d k rã | rã | j d d k rÇ | d } qã t | pÓ d | d } n | d k rõ q~ n | | | | <q~ W| S( Ns %st
propertiesiÿ R R t vhdt root_gbi ( t SM_IMAGE_PROP_PREFIXRÏ Rn RÐ t SM_SKIP_KEYSt
safe_truncateR> R? t SM_INHERITABLE_KEYSt maxRX ( t
image_metat flavort system_metat
prefix_formatRÜ R¦ Rý ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_system_metadata_from_image¥ s"
+
c C sÊ i } i } t | t s0 t | d t } n x t | j D]u \ } } | d k ra qC n | j t r | t t } n | t
k r qC n | t k r® | | | <qC | | | <qC W| | d <| S( NR6 R ( RY Rð R9 R@ RÏ RÐ RX t
startswithR R R R ( R R R RÜ R¦ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_image_from_system_metadataÁ s
c C s t j | j d i } i | d 6} | j d d t j | d <xE t D]= } | j | d } | d k rL t | p| d | | <qL qL Wd | d <| S(
Nt volume_image_metadataR R i R R t activet status( R s min_disk( R Rn R t Git VIM_IMAGE_ATTRIBUTESR; RX R[ ( t volumeR R Rô Rö ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_image_metadata_from_volumeÞ s
c C s7 t | t j r$ | j d } n t j | j S( s Returns string that represents MD5 hash of base_str (in hex format).
If base_str is a Unicode string, encode it to UTF-8.
s utf-8( RY R> R? R¥ t hashlibt md5t hexdigest( t base_str( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_hash_str÷ s c C s7 t | t j r$ | j d } n t j | j S( s@ Returns string that represents sha256 hash of base_str (in hex format).
sha1 and md5 are known to be breakable, so sha256 is a better option
when the hash is being used for security purposes. If hashing passwords
or anything else that needs to be retained for a long period a salted
hash is better.
s utf-8( RY R> R? R¥ R t sha256R ( R ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_sha256_str s c C s. t | } t j s* t j | d } n | S( s½ Returns a string representation of an object converted to unicode.
In the case of python 3, this just returns the repr() of the object,
else it converts the repr() to unicode.
s utf-8( t reprR> Ræ R? ( RÅ t obj_repr( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt get_obj_repr_unicode s c s t | t r | g } n f d d f d } g } x¶ | D]® } d k r | d k ry d } n | j | i } n x | D] } | | | | } q WxL t | j D]8 \ } }
| j i | d 6|
d 6 | d 6 qÄ WqR W| S(
sm Get all metadata for a list of resources after filtering.
Search_filts is a list of dictionaries, where the values in the dictionary
can be string or regex string, or a list of strings/regex strings.
Let's call a dict a 'filter block' and an item in the dict
a 'filter'. A tag is returned if it matches ALL the filters in
a filter block. If more than one values are specified for a
filter, a tag is returned if it matches ATLEAST ONE value of the filter. If
more than one filter blocks are specified, the tag should match ALL the
filter blocks.
For example:
search_filts = [{'key': ['key1', 'key2'], 'value': 'val1'},
{'value': 'val2'}]
The filter translates to 'match any tag for which':
((key=key1 AND value=val1) OR (key=key2 AND value=val1)) AND
(value=val2)
This example filter will never match a tag.
:param resource_type: The resource type as a string, e.g. 'instance'
:param resource_list: List of resource objects
:param search_filts: Filters to filter metadata to be returned. Can be
dict (e.g. {'key': 'env', 'value': 'prod'}, or a list of dicts
(e.g. [{'key': 'env'}, {'value': 'beta'}]. Note that the values
of the dict can be regular expressions.
:param metadata_type: Provided to search for a specific metadata type
(e.g. 'system_metadata')
:returns: List of dicts where each dict is of the form {'key':
'somekey', 'value': 'somevalue', 'instance_id':
'some-instance-uuid-aaa'} if resource_type is 'instance'.
c s d k r | j d Sd S( NR; t uuid( Rn ( t resource( t
resource_type( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _get_idD s c S sD t | t r | g } n t g | D] } t j | | ^ q% S( N( RY RU t anyRè t match( t pattern_listt stringt pattern( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt
_match_anyH s c sí | j d g } | j d g } | j d g } i } | rX | | k rX i Sx t | j D]z \ } } | r© | r© | | r© | | r© qk n2 | r¿ | | sk | rÛ | | rÛ qk n | | | <qk W| S( Nt resource_idRÜ R¦ ( Rn RÏ RÐ ( R¤ t search_filtt input_metadatat idst keys_filtert
values_filtert output_metadatat kt v( R¦ R¬ ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt _filter_metadataN s R; R5 RÜ R¦ s %s_idN( RY Rð RX Rn RÏ RÐ Rq ( R¥ t
resource_listt search_filtst
metadata_typeR¶ t formatted_metadata_listt resR5 t filtR´ Rµ ( ( R¦ R¬ R¥ s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt# filter_and_format_resource_metadata s" '
c C sa t j | | } t } xA | s\ y t j | } t } Wq t k
rX | d } q Xq W| S( sp Safely truncates unicode strings such that their encoded length is
no greater than the length provided.
iÿÿÿÿ( R t safe_encodeR< t safe_decodeR@ t UnicodeDecodeError( R¦ R t b_valuet decode_okt u_value( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyR | s
c C s² | r t | n t } t j j | } t j | i } | s\ | | j d d k r¤ t j d | t
| } | j | d <Wd QX| | d <t } n | | d f S( s¿ Read from a file if it has been modified.
:param force_reload: Whether to reload the file.
:returns: A tuple with a boolean specifying if the data is fresh
or not.
t mtimei s Reloading cached file %st dataN(
t delete_cached_fileR< R RÀ t getmtimet _FILE_CACHEt
setdefaultRn R^ t debugt opent readR@ ( t filenamet force_reloadt reloadedRÄ t
cache_infot fap( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt read_cached_file s
c C s | t k r t | =n d S( sL Delete cached file if present.
:param filename: filename to delete
N( RÈ ( RÍ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRÆ © s c C se | s t j } n | j d } | j r? | j j d n d } | | d k rZ d n | 7} | S( ss Current time as ISO string,
as timeutils.isotime() is deprecated
:returns: Current time in ISO format
s %Y-%m-%dT%H:%M:%St UTCs UTC+00:00t ZN( s UTCs UTC+00:00( R
R t strftimet tzinfot tznameRX ( t att date_stringt tz( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt isotime´ s ! c C s
| j d S( Ns %Y-%m-%dT%H:%M:%S.%f( RÕ ( RØ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt strtime s c C sÑ | j r | j S| j d k rG y | j j SWqG t k
rC qG Xn y | j SWn t j k
rk n Xt | j } x< | D]4 } | | _ y | j SWq t j k
rµ q Xq Wt j d | d S( sñ Get the endpoint URL represented by a keystoneauth1 Adapter.
This method is equivalent to what
ksa_adapter.get_endpoint()
should do, if it weren't for a panoply of bugs.
:param ksa_adapter: keystoneauth1.adapter.Adapter, appropriately set up
with an endpoint_override; or service_type, interface
(list) and auth/service_catalog.
:return: String endpoint URL.
:raise EndpointNotFound: If endpoint discovery fails.
t imagesI Could not find requested endpoint for any of the following interfaces: %sN(
t endpoint_overridet service_typet get_endpoint_datat catalog_urlt AttributeErrort get_endpointt ks_exct EndpointNotFoundRÏ t interface( t ksa_adaptert
interfacesRæ ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyRã Æ s*
c C sÈ t t d s t j d t St j j | d } t } d } z>yw t j | t j
t j Bt j B } d } t
j
d | } | j d | t j | | t j d i | d 6 WnÀ t k
r:} | j t j k rt j d i | d 6| d
6 t } q~t j # t j d i | d 6| d
6 Wd QXnD t k
r}} t j # t j d i | d 6| d
6 Wd QXn XWd | d k rt j | n y t j | Wn t k
rÂn XX| S( Nt O_DIRECTs/ This python runtime does not support direct I/Os .directio.testi iÿÿÿÿR s# Path '%(path)s' supports direct I/ORÀ s5 Path '%(path)s' does not support direct I/O: '%(ex)s't exs7 Error on '%(path)s' while checking direct I/O: '%(ex)s'( Rï R R^ RÊ R< RÀ R] R@ RX RË t O_CREATt O_WRONLYRé t mmapt writeR t errnot EINVALR R% R® t Exceptiont closet unlink( t dirpatht testfilet hasDirectIOt fdt
align_sizet mR ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt supports_direct_ioû sD
#
#
( s min_rams min_disks disk_formatR ( R R R R ( R R s sizeR R s disk_formats min_rams min_disk( R} R~ R ( R( t
contextlibR R Rï RL R RÂ Rí R RÍ Re Rè R RÕ R R` Rs t
keystoneauth1R Rä R t
ks_loadingRª t oslo_concurrencyR R t oslo_contextR Rq t oslo_logR RV t oslo_messagingRS t
oslo_utilsR R R R R
R R> t six.movesR t
dmapi.confR R
t
dmapi.i18nR R R R R t
try_importRf t confR! t getLoggerR- R^ RX t _IS_NEUTRONt synchronized_with_prefixRl R R R R RÈ R& Rú R' R/ R, Ru R) R| t DEFAULT_PASSWORD_SYMBOLSR R£ R§ R² R· R» R¾ RÁ RÇ Rí t contextmanagerRÿ R R
R R R R< R+ R9 R: R< R> RO RP R^ R` Rk Rt Ru Rw R| R R R R R R R R¢ R½ R RÒ RÆ RÛ RÜ Rã Rú ( ( ( s/ /usr/lib/python2.7/dist-packages/dmapi/utils.pyt <module> sÔ "
k \% 0 (1
a 5