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.52 ▾
|
ó
±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 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 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* 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 l5 Z. d d l. m6 Z6 e. j7 j8 Z8 e j9 e: Z; i d d 6d d 6d d 6d d 6Z< d a> e j? d Z@ d ZA dt ZB du ZC dv ZD i aE d( d d) ZF d* ZG d+ ZH d, eI f d- YZJ d. eJ f d/ YZK d0 ZL d1 ZM d2 ZN d3 d4 ZO dw ZP dx ZQ d d d8 ZR d eP d9 ZS d: ZT d; ZU d< ZV d= ZW d> ZX d? ZY d@ ZZ dA Z[ dB Z\ dC Z] dD Z^ dE Z_ dF Z` d dG dH Za d dI Zb e jc dJ Zd dK Ze dL Zf e jc d dM Zg e jc dN Zh d dO Zi dP eI f dQ YZj d ek dR Zl dS Zm ek dT Zn dU Zo dV Zp dW Zq dX Zr dY eI f dZ YZs d d[ d d\ Zt d d d] Zu d^ Zv d_ Zw d` Zx da Zy db Zz d d dc Z{ dd Z| d de Z} df Z~ dg Z dh Z di Z d dj Z dk Z ek dl Z dm Z
d dn Z do Z dp d[ dq dr Z ds Z d S(y s Utilities and helper functions.iÿÿÿÿN( t saxutils( 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_utilsi t SECONDi< t MINUTEi t HOURiQ t DAYs nova-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 checksumg©?c C s8 | d k r! t j d d } n t j t j t j } t j d d | } | j | | | f | j | z/ y | j
d } Wn t j k
r t SXWd | j
Xd } t | t j | k rt j t d t d t j | d
t | t St j | | \ } } }
| d k o7|
| k S( s Sends a vpn negotiation packet and returns the server session.
Returns Boolean indicating whether the vpn_server is listening.
Basic packet structure is below.
Client packet (14 bytes)::
0 1 8 9 13
+-+--------+-----+
|x| cli_id |?????|
+-+--------+-----+
x = packet identifier 0x38
cli_id = 64 bit identifier
? = unknown, probably flags/padding
Server packet (26 bytes)::
0 1 8 9 13 14 21 2225
+-+--------+-----+--------+----+
|x| srv_id |?????| cli_id |????|
+-+--------+-----+--------+----+
x = packet identifier 0x40
cli_id = 64 bit identifier
? = unknown, probably flags/padding
bit 9 was 1 and the rest were 0 in testing
i l ÿÿÿÿ s !BQxxxxxi8 i Ns
!BQxxxxxQxxxxs7 Expected to receive %(exp)s bytes, but actually %(act)st expt acti@ ( t Nonet randomt randintt sockett AF_INETt
SOCK_DGRAMt structt packt sendtot
settimeoutt recvt timeoutt Falset closet lent calcsizet LOGt warningR t dictt unpack( t addresst portR0 t
session_idt sockt datat receivedt fmtt
identifiert server_sesst client_sess( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt vpn_pingh s&
%c C s& t j j r d } n
d t j } | S( Nt sudos sudo nova-rootwrap %s( t CONFt workaroundst disable_rootwrapt rootwrap_config( t cmd( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_root_helper s
c C s! t j r t t j St Sd S( N( RE t use_rootwrap_daemont RootwrapDaemonHelperRH t RootwrapProcessHelper( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _get_rootwrap_helper¤ s
RM c B s e Z d Z d Z RS( c O s t | d <t j | | S( Nt root_helper( RJ R t trycmd( t selfRI t kwargs( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRP ¬ s
c O s t | d <t j | | S( NRO ( RJ R t execute( RQ RI RR ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRS ° s
( t __name__t
__module__RP RS ( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRM « s RL c 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 clientRD s nova-rootwrap-daemon( t _clientst KeyErrort
oslo_rootwrapRV t Client( t clsRH RV t
new_client( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _get_client¸ s
c C s | j | | _ d S( N( R] RV ( RQ RH ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt __init__Ã 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 popR1 RS R t ProcessExecutionErrort sixt text_typet True( RQ t argsRR R_ t outt errt failedt exn( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRP Æ 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]RI RR 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 strRa t loggingt DEBUGR% Re R1 t
isinstancet boolt intR t
mask_passwordt joinR5 t infoR t timeR R
RV RS R Rb t LOG_ALL_ERRORSt LOG_FINAL_ERRORt descriptionRI Ru Rv Rw t sleepR& R' ( RQ RI RR t cRk Rl Rm Rn Ro Rp t ignore_exit_codeRr t
start_timet
returncodeRg Rh Rt t format( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRS Ó sr
( RT RU RW t synchronizedR] R^ RP RS ( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRL µ 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 getRE RK RL RH RS RM R ( RI RR ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRS 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 extendRS ( t destRI RR t ssh_cmd( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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.R ( R R1 RE RK RL RH RP RM R ( Rf RR ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRP 3 s
i c C sE d } g t | D] } t j | ^ q } d | d j | f S( Nt% 01234567890abcdefghijklmnopqrstuvwxyzs %s-%sR` ( R R& t choiceR ( t topicR! t
characterst _xt choices( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt generate_uid> s (t 23456789t ABCDEFGHJKLMNPQRSTUVWXYZt abcdefghijkmnopqrstuvwxyzc C sL | s t j } n d } d | k rK | j d d \ } } t | } n | d k r` | } n t j } | d k r t d n | d k r | d k r¨ d } n t j d | d | j d | j
} | | k r<| j
} d | j k r| d 8} d | j d } n
| j d } t j d | d | d | } n | j
} d | j k rr| d 8} d | j d } n
| j d } t j d | d | d | } n¢| d k rc| d k rÁd } n t j d d d | d | j
} | | k r;t j d d d | d | j
d } t j d d d | d | j
d
} qBt 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 rB| 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( RE t instance_usage_audit_periodt splitR R% R t utcnowt
ValueErrort datetimeR¡ R£ R¢ t timedeltat replace( t unitt beforet offsett rightnowt endR£ R¡ t begin( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt last_completed_audit_periodP 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( R% RE t password_lengthR& t SystemRandomR t shuffleR3 R R R ( t lengtht symbolgroupst rt st passwordt symbolst _i( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt generate_password¬ s "
/
c C s y¿ t d d d d d d | } d } g | d j d D] } t j | | ^ q; } g | D]! } | d k r` | j d
^ q` } | d d k r | d St d | } t j | Wn@ t k
r} t d i | d
6| d 6} t j | n Xd S( Nt ips -ft inet6s -ot addrt shows* \s+inet6\s+([0-9a-f:]+)/\d+\s+scope\s+linki s
i s# Link Local address is not found.:%ss3 Couldn't get Link Local IP of %(interface)s :%(ex)st interfacet ex(
RS R« t ret searchR% t groupR
R t
NovaExceptiont Exception( RÇ t if_strt conditiont xt linkst wR9 t msgRÈ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_my_linklocalÐ s 2. c C s t j | i d d 6d d 6 S( s: Escapes a string so it is valid within XML or XHTML.
s "t "s 't '( R t escape( t value( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt xhtml_escapeá 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( R% R} Rc t binary_typeRd t encode( RØ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt utf8è s
c C s3 t | | r | St t d t | d S( s< Checks that obj is of type cls, and lets PyLint infer types.s Expected object of type: %sN( R} RÍ R
Rz ( t objR[ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt check_isinstanceø 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 AddrFormatErrorR5 t errorR ( t
server_strR9 R: ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt parse_server_stringÿ s
$
c C s@ y t j | d d j t SWn t t j f k
r; t SXd S( Nt versioni ( Rá t IPNetworkt cidrRe t TypeErrorRä R1 ( R9 ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt is_valid_ipv6_cidr s
c C s% t j | d d } t | j S( NRè i ( Rá t IPAddressRz t ipv6( R9 RÅ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_shortened_ipv6$ s c C s" t j | d d } t | j S( NRè i ( Rá Ré Rz Rê ( R9 t net( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_shortened_ipv6_cidr) s c C sb y t j | Wn t j k
r( t SX| j d } t | d k sZ | d d k r^ t St S( sb Check if address is valid
The provided address can be a IPv6 or a IPv4
CIDR address.
t /i R` ( Rá Ré Rä R1 R« R3 Re ( R9 t
ip_segment( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
is_valid_cidr. s c C s< t j | j d k r d St j | j d k r8 d Sd S( sh Returns the IP version of a network (IPv4 or IPv6).
Raises AddrFormatError if invalid network.
i t IPv6i t IPv4N( Rá Ré Rè ( t network( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_ip_versionE 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è Rë Rä ( RÃ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt safe_ip_formatP 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( R% Rù ( t hostt path( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt format_remote_path_ s c C sl t j s
d St j r" t j } n d } x:t j D]/} | j d \ } } t j | } t
| t j | } xé | 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
Wq5 Wd S( sð 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:
'nova.api.ec2.cloud:nova.notifications.notify_decorator'
Parameters of the decorator is as follows.
(See nova.notifications.notify_decorator)
name - name of the function
function - object of the function
Nc S s t j | p t j | S( N( t inspectt ismethodt
isfunction( RÝ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt is_method s Rà s %s.%ss %s.%s.%s( RE t monkey_patchRc t PY2Rý Rþ t monkey_patch_modulesR« R t import_classt
__import__t pyclbrt
readmodule_ext itemsR} t Classt
getmemberst setattrt Functiont syst modules( R t module_and_decoratort modulet decorator_namet decoratort module_datat keyRØ t clzt methodt func( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR m s(
$s /devc C s2 t j j | | } | r. | t | 7} n | S( s Return a path to a particular device.
>>> make_dev_path('xvdc')
/dev/xvdc
>>> make_dev_path('xvdc', 1)
/dev/xvdc1
( t osRû R Rz ( t devt partitiont baseRû ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
make_dev_path 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(
sr 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 nova-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( R3 R5 R6 R ( t name( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt truncate_hostnameº s s latin-1t ignores [ _]t -s [^\w.-]+R` s .-N( R} Rc Rd RÛ t PY3t decodeRÉ t subt lowert stripR% ( R t default_nameR ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt sanitize_hostname« s
c
+ sâ d f d } f d } f d } t } i } x@ | j D]2 \ } } | | | | | | <| | | | qR Wz d VWd xF | 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 S( Nt has_key( t hasattr( t thing( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt is_dict_likeÞ s c s0 | r | j | | St | | | Sd S( N( R t getattr( R, t attrt default( R- ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR á s c s- | r | | | <n t | | | d S( N( R ( R, R/ t val( R- ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt set_valueç s
c s' | r | | =n
t | | d S( N( t delattr( R, R/ ( R- ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt deleteí s
N( t objectR (
RÝ RR R R2 R4 t NOT_PRESENTt
old_valuesR/ t new_valuet old_value( ( R- s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt temporary_mutationÓ s c C sU d d d t j d d t j d d t j d d g } d j t d | S( s! Generate an Ethernet MAC address.iú i i> i iÿ Rà c S s d | S( Ns %02x( ( RÐ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt <lambda> s ( R& R' R t map( t mac( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt generate_mac_address s
c C sP y# t d | d t \ } } | SWn& t j k
rK t j d | n Xd S( s# Secure helper to read file as root.t catR t file_pathN( RS Re R Rb R t FileNotFound( R@ Rg t _err( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt read_file_as_root s
c c s | d k r t j } n t j | j } | | k rR t d | | d t n z d VWd | | k r t d | | d t n Xd S( sg Temporarily chown a path.
:param owner_uid: UID of temporary owner (defaults to current user)
t chownR N( R% R t getuidt statt st_uidRS Re ( Rû t owner_uidt orig_uid( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt temporary_chown 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 copyRE t tempdirt tempfilet mkdtempt shutilt rmtreet OSErrorR5 Rå R ( RR t argdictt tmpdirt e( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRM 0 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__R t walk_class_hierarchy( t clazzt encounteredt subclasst subsubclass( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRW ? 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( RQ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR^ P s c C s | j j | d S( N( R] R ( RQ t undo_func( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt undo_withS s c C s% x t | j D]
} | q Wd S( N( t reversedR] ( RQ R^ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _rollbackV 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_exceptionR5 R Ra ( RQ RÓ RR ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt rollback_and_reraiseZ s
N( RT RU t __doc__R^ R_ Ra R% Rc ( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR\ L 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 -LR N( Rh Ri Rj ( Rk s vfat( R R RS ( t fsRû t labelR Rf t label_opt( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRg g s
c C su y | j | t j Wn> t k
rX } | j t j k rR | j d t j qY n X| j } | j | f S( sÆ Return num bytes from the end of the file, and remaining byte count.
:param file_like_object: The file to read
:param num: The number of bytes to return
:returns (data, remaining)
i ( t seekR t SEEK_ENDt IOErrort errnot EINVALt SEEK_SETt tellt read( t file_like_objectt numRU t remaining( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
last_bytes s c C sI i } x< | D]4 } | r/ | j d r/ q
n | d | | d <q
W| S( Nt deletedRØ R ( R ( t metadatat include_deletedt resultt item( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt metadata_to_dict s
c C sF g } x9 t j | D]( \ } } | j t d | d | q W| S( NR RØ ( Rc t iteritemsR R7 ( R} R R RØ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt dict_to_metadata¡ s c C s- t | d t r | d St | d Sd S( NR} ( R} R7 R ( t instance( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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_metadataR~ ( R R} R7 R Re ( R ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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ë RT ( t ft base_ft arg_namest at kwt _default( Rf t dec( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
_decorator» s $
( t functoolst wraps( R R ( Rf ( R s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _decorator_checkerº s !( ( Rf R ( ( Rf s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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( RQ t target( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR^ Ó 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 ExpectedExceptionRc t reraiset exc_info( Rf RR RU ( R ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt wrapperÙ s ( R. R R R ( RQ R R ( ( R s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt __getattr__Ö s ( RT RU Rd R^ R¡ ( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR Î 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( R} Rc t string_typesR% R
R t InvalidInputR3 ( RØ R R£ R¤ RÓ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt check_string_lengthâ s c C sù y t t | } Wn@ t t f k
rX t d } t j d | i | d 6 n X| d k r§ | | k r§ t d } t j d | i | d 6| d 6 q§ n | d k rõ | | k rõ t d } t j d | i | d 6| d 6 qõ n | S( sB Make sure that value is a valid integer, potentially within range.s! %(value_name)s must be an integert reasont
value_names' %(value_name)s must be >= %(min_value)dt min_values' %(value_name)s must be <= %(max_value)dt max_valueN( R Rz R t UnicodeEncodeErrorR
R R¦ R% ( RØ R Rª R« RÓ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt validate_integerþ s&
c s@ t j 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 s& d k r j n | | S( N( R% t update_store( Rf RR ( t _contextR ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt context_wrapper$ s
( t common_contextt get_currentR R t eventlett spawn( R Rf RR R° ( ( R¯ R s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR´ s
!c sD t j 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 s* d k r j n | | d S( N( R% R® ( Rf RR ( R¯ R ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR° ; s
N( R± R² R R R³ t spawn_n( R Rf RR R° ( ( R¯ R s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRµ / 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( R} Rc R¥ R1 R& ( R1 ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt is_none_stringF s c C s# t d k r t St j j a t S( N( t _IS_NEUTRONR% t novaR÷ t
is_neutron( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRº O s c C s@ t } | d k r< | j j } | d k r< t } q< n | S( Nt disabled( R1 R% R' R& Re ( t auto_disk_config_rawt auto_disk_config_disabledt adc_lowered( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt is_auto_disk_config_disabledY s c C s( | d k r t | } n | j d S( Nt image_auto_disk_config( R% R R ( R t sys_meta( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt" get_auto_disk_config_from_instanceb s c C s
| j d S( Nt auto_disk_config( R ( t image_properties( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt% get_auto_disk_config_from_image_propsh s c C s i } t d } xa t j | j d i D]D \ } } | t k rJ 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_PREFIXRc R R t SM_SKIP_KEYSt
safe_truncateRd t SM_INHERITABLE_KEYSt maxR% ( t
image_metat flavort system_metat
prefix_formatR RØ R8 ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_system_metadata_from_imagel s"
(
c C sÇ i } i } t | t s0 t | d t } n x t j | D]u \ } } | d k r^ q@ n | j t r | t t } n | t
k r q@ n | t k r« | | | <q@ | | | <q@ W| | d <| S( NR~ RÆ ( R} R7 R Re Rc R R% t
startswithRÉ R3 RÊ RÌ ( RÐ RÎ RÆ R RØ ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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( RL R R
t Git VIM_IMAGE_ATTRIBUTESRa R% R ( t volumeRÆ RÎ R/ R1 ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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( R} Rc Rd RÛ t hashlibt md5t hexdigest( t base_str( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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( R} Rc Rd RÛ RÜ t sha256RÞ ( Rß ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt get_sha256_strÈ 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 WxF | 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( R ( t resource( t
resource_type( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _get_idÿ s c S sD t | t r | g } n t g | D] } t j | | ^ q% S( N( R} Rz t anyRÉ t match( t pattern_listt stringt pattern( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
_match_any 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¦ qh n2 | r¼ | | sh | rØ | | rØ qh n | | | <qh W| S( Nt resource_idR RØ ( R Rc R ( Rä t search_filtt input_metadatat idst keys_filtert
values_filtert output_metadatat kt v( Ræ Rì ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt _filter_metadata s R R} R RØ s %s_idN( R} R7 R% R R R ( Rå t
resource_listt search_filtst
metadata_typeRö t formatted_metadata_listt resR} t filtRô Rõ ( ( Ræ Rì Rå s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/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_encodeR1 t safe_decodeRe t UnicodeDecodeError( RØ R» t b_valuet decode_okt u_value( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyRË 7 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 %sR= N(
t delete_cached_fileR1 R Rû t getmtimet _FILE_CACHEt
setdefaultR R5 t debugt openRw Re ( t filenamet force_reloadt reloadedR t
cache_infot fap( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt read_cached_fileK 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? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyR d 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 UTCt ZN( R R¬ t strftimet tzinfot tznameR% ( t att date_stringt tz( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt isotimeo s ! c C s
| j d S( Ns %Y-%m-%dT%H:%M:%S.%f( R ( R ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt strtime} s t Propertyt Valuec
C sI t j | | g } d | _ xê t | j D]Ö \ } } t | t r^ t j | } n | d k r t j
t j | | } n | rô t | t j rô d | k rô | j j
d } | } x= | D] } | j | | g d } qÎ Wq1 | j | | g q1 Wt j r+t j | j GHn t j | j j GHd S( sô Print a `dict` as a table of two columns.
:param dct: `dict` to print
:param dict_property: name of the first column
:param wrap: wrapping for the second column
:param dict_value: header label for the value (second) column
t li s \nR` N( t prettytablet PrettyTablet alignt sortedR R} R7 Rc Rd t textwrapt fillR¥ R' R« t add_rowR R Rþ t
get_stringR$ (
t dctt
dict_propertyt wrapt
dict_valuet ptRô Rõ t linest col1t line( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
print_dict s" $
c O s t j | } t | j p g } | j t | j | } t j | d k rc | j d n g | D] } | | k rj | ^ qj } | t | } | S( sé Check that the supplied args are sufficient for calling a function.
>>> validate_args(lambda a: None)
Traceback (most recent call last):
...
MissingArgs: Missing argument(s): a
>>> validate_args(lambda a, b, c, d: None, 0, c=1)
Traceback (most recent call last):
...
MissingArgs: Missing argument(s): b, d
:param fn: the function to check
:param arg: the positional arguments supplied
:param kwargs: the keyword arguments supplied
i N( Rý R R3 t defaultsRf Rc t get_method_selfR% Ra ( t fnRf RR t argspect num_defaultst
required_argst argt missing( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt
validate_args¢ s %( s min_rams min_disks disk_formatR ( R R R R ( R R s sizes checksumR s disk_formats min_rams min_disk( R R R ( R R ( Rd t
contextlibRL R® Rs R RÜ Rý R R R& RÉ RP R( R+ R
RN R" R t xml.saxR R³ Rá t oslo_concurrencyR R t oslo_contextR R± t oslo_logR R{ t oslo_messagingR t
oslo_utilsR R R R R R
R Rc t six.movesR t nova.confR¹ R t nova.i18nR
R R R t nova.networkR t confRE t getLoggerRT R5 t
TIME_UNITSR% R¸ t synchronized_with_prefixR RÉ RÌ RÊ RÙ R RC RJ RN R5 RM RL RS R RP R t DEFAULT_PASSWORD_SYMBOLSt EASIER_PASSWORD_SYMBOLSR· RÂ RÔ RÙ RÜ RÞ Rç Rì Rï Rñ Rô Rø Rù Rü R R R) t contextmanagerR: R> RC RJ RM RW R\ R1 Rg R{ R R R
R R R R§ R R´ Rµ R· Rº R¿ RÂ RÅ RÒ RÔ RÛ Rà Râ Rý RË R R R R R. R7 ( ( ( s? /home/tvault/.virtenv/lib/python2.7/site-packages/nova/utils.pyt <module> sú "
4
k \$ / (1
a !