Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.2.8-5.2 ▾
|
python3-dmapi-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
dmapi
/
__pycache__
/
utils.cpython-39.pyc
|
|---|
a
[r`eWª ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
Z
ddlZddlZddlZddlZddlmZ ddlmZ ddlZddlmZ ddlmZ ddlm Z ddl m Z ddl!Z"dd l#m$Z$ dd
l#m%Z% dd l#m&Z& dd l#m'Z' dd
l#m(Z( ddl#m)Z) ddl*Z*ddl+m,Z, ddl-Z.ddl.m/Z/ ddl0m1Z1m2Z2m3Z3m4Z4 ddl.m5Z5 e& 6d¡Z7e.j8j9Z9e :e;¡Z<dZ=e >d¡Z?dZ@dZAdZBdZCi aDeEedrÊejFZGnejGZGdd ZHG d d d eIZJG d d d eJZKd d! ZLd"d# ZMd$d% ZNdd'd(ZOd
d)d*ZPd+d, ZQd-d. ZRd/d0 ZSd1d2 ZTd3d4 ZUd5d6 ZVd7d8 ZWdd9d:ZXejYd;d< ZZejYdd=d>Z[ejYd?d@ Z\ddAdBZ]G dCdD dDeIZ^ddFdGZ_ddHdIZ`dJdK ZadLdM ZbdNdO ZcdPdQ ZdG dRdS dSeIZeddTdUZfddVdWZgdXdY ZhdZd[ Zid\d] Zjd^d_ Zkd`da ZlddbdcZmddde ZnddfdgZodhdi Zpdjdk Zqdldm Zrdndo Zsdpdq ZtddrdsZudtdu ZvddvdwZwdxdy Zxddzd{Zyd|d} Zzd~d Z{dd Z|dd Z}dS )z Utilities and helper functions.é N)Ú
exceptions)Úloading)Ú lockutils)Ú processutils)Úcontext)Úlog)Ú encodeutils)Úexcutils)Ú importutils)Ústrutils)Ú timeutils)Úunits)Úrange)Ú exception)Ú_Ú_LEÚ_LIÚ_LW)Ú
safe_utilszosprofiler.profilerzdmapi-Zimage_)Úmin_ramÚmin_diskÚ disk_formatÚcontainer_format)ZmappingsZblock_device_mappingZ img_mappingsZimg_block_device_mapping)Zimage_idZ
image_nameÚsizeZchecksumr r r r Úgetfullargspecc C s t jjrd} n
dt j } | S )NÚsudozsudo dmapi-rootwrap %s)ÚCONFZ workaroundsZdisable_rootwrapÚrootwrap_config)Úcmd© r ú//usr/lib/python3.9/site-packages/dmapi/utils.pyÚget_root_helperU s
r! c @ s e Zd Zdd Zdd ZdS )ÚRootwrapProcessHelperc O s t |d< tj|i |¤S ©NZ root_helper)r! r Útrycmd©Úselfr Úkwargsr r r r$ ^ s
z RootwrapProcessHelper.trycmdc O s t |d< tj|i |¤S r# )r! r Úexecuter% r r r r( b s
z RootwrapProcessHelper.executeN)Ú__name__Ú
__module__Ú __qualname__r$ r( r r r r r" ] s r" c @ s8 e Zd Zi Zeddd Zdd Zdd Zdd Zd
S ) ÚRootwrapDaemonHelperzdaemon-client-lockc C sN z | j | W S tyH ddlm} | dd|g¡}|| j |< | Y S 0 d S )Nr )Úclientr zdmapi-rootwrap-daemon)Ú_clientsÚKeyErrorZ
oslo_rootwrapr- ZClient)Úclsr r- Z
new_clientr r r Ú _get_clientj s ÿ
z RootwrapDaemonHelper._get_clientc C s | |¡| _d S ©N)r1 r- )r& r r r r Ú__init__u s z RootwrapDaemonHelper.__init__c
O s| | dd¡}z | j|i |¤\}}d}W n: tjyb } z dt |¡ }}d}W Y d }~n
d }~0 0 |st|rt|rtd}||fS )NÚdiscard_warningsFÚ T)Úpopr( r ÚProcessExecutionErrorÚsixÚ text_type)r& Úargsr' r4 ÚoutÚerrZfailedZexnr r r r$ x s zRootwrapDaemonHelper.trycmdc
O s dd |D }| dtj¡}| dd ¡}| dd ¡}| dd¡}| dd ¡}| d
d g¡}d } t|trv| } d g}nt|tr|g}t d
|¡¡}
t
t d|
|d¡ |d kr|d 8 }zt ¡ } t
|td|
¡ | j ||¡\} }
}t ¡ | }t
|d|
| |d¡ | sF| |vrFt |
¡}
t |¡}tj| |
||
d|
|fW S tjy } z¤|tjks|tjkr¬|s¬td}t
|||j|j|j|j|jd¡ |sÈt
|td|
¡ n2t
|td|
¡ |rút t ¡ dd¡d ¡ W Y d }~q¬d }~0 0 q¬d S )Nc S s g | ] }t |qS r )Ústr)Ú.0Úcr r r Ú
<listcomp> ó z0RootwrapDaemonHelper.execute.<locals>.<listcomp>ÚloglevelÚ
log_errorsÚ
process_inputÚdelay_on_retryTÚattemptsé Úcheck_exit_coder Fú zHExecuting RootwrapDaemonHelper.execute cmd=[%(cmd)r] kwargs=[%(kwargs)r]©r r' z Running cmd (subprocess): %szECMD "%(sanitized_cmd)s" returned: %(return_code)s in %(end_time)0.3fs)Ú
sanitized_cmdZ return_codeÚend_time)Ú exit_codeÚstdoutÚstderrr zS%(desc)r
command: %(cmd)r
exit code: %(code)r
stdout: %(stdout)r
stderr: %(stderr)r)Zdescr ÚcoderN rO z%r failed. Not Retrying.z%r failed. Retrying.é éÈ g Y@) r6 ÚloggingÚDEBUGÚ
isinstanceÚboolÚintr Z
mask_passwordÚjoinÚLOGÚinfor Útimer r r- r( r r7 ZLOG_ALL_ERRORSZLOG_FINAL_ERRORÚ descriptionr rM rN rO ÚsleepÚrandomÚ SystemRandomZrandint)r& r r' rB rC rD rE rF rH Zignore_exit_coderK Z
start_timeÚ
returncoder; r< rL Úformatr r r r(
s
þ
ÿÿ
þý
ü
ÿþ ü ÿ ÿÿz RootwrapDaemonHelper.executeN) r) r* r+ r. Ú synchronizedr1 r3 r$ r( r r r r r, g s
r, c O sP d|v r@| d¡r@tjr.ttjj| i |¤S t j| i |¤S tj| i |¤S )z3Convenience wrapper around oslo's execute() method.Ú run_as_root)Úgetr Úuse_rootwrap_daemonr, r r( r" r rJ r r r r( Ó s
ÿÿr( c O s* g d¢}| | ¡ | |¡ t|i |¤S )z+Convenience wrapper to execute ssh command.)Zsshz-oz
BatchMode=yes)ÚappendÚextendr( )Údestr r' Zssh_cmdr r r Ú ssh_executeÞ s
ri c O sJ | dd¡r:tjr(ttjj| i |¤S t j| i |¤S tj| i |¤S )z2Convenience wrapper around oslo's trycmd() method.rc F)rd r re r, r r$ r" r ©r: r' r r r r$ æ s
ÿÿr$ é c s, d fddt |D }d| d |¡f S )NZ%01234567890abcdefghijklmnopqrstuvwxyzc s g | ]}t ¡ ¡qS r )r^ r_ Úchoice)r> Z_x©Z
charactersr r r@ ó rA z generate_uid.<locals>.<listcomp>z%s-%sr5 )r rX )Ztopicr Úchoicesr rm r Ú generate_uidñ s ro c C s& | s
t j} d}d| v r.| dd¡\} }t|}|dur<|}nt ¡ }| dvrXttd| dkr|dkrnd}tj||j |j
d}||krÌ|j
}d|j kr²|d8 }d |j d }n
|j d }tj|||d}|j
}d|j krô|d8 }d |j d }n
|j d }tj|||d}n | d
kr|dkr*d}tjd||j
d}||krttjd||j
d d}tjd||j
d d}ntjd||j
d d}n| d krÚtj||j |j |j
d
}||krÈ|tj dd }|tj dd }nD| dkr |j
|ddd}||kr|tj dd }|tj dd }||fS )a§ 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.
r ú@rG N)ÚmonthÚdayÚyearÚhourz,Time period must be hour, day, month or yearrq )rr rq rs é rs é rr )rt rr rq rs )Zdaysrt )ZminuteÚsecondZ microsecond)Zhours)r Zinstance_usage_audit_periodÚsplitrW r ÚutcnowÚ
ValueErrorr Údatetimerq rs rr Z timedeltaÚreplace)ZunitÚbeforeÚoffsetZrightnowÚendrs rq Zbeginr r r Úlast_completed_audit_period÷ s
þ
þ
þþþ
ý
r c C s8 | du st | tjr| S t | tjs.t | ¡} | d¡S )z³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
Núutf-8)rU r8 Z binary_typer9 Úencode)Úvaluer r r Úutf8T s
r c C s¤ ztt | ¡r| dfW S | d¡dkrF| ddd¡ d¡\}}||fW S | d¡dkr^| dfW S | d¡\}}||fW S tt jfy t t d| ¡ Y dS 0 d S )
zô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.
r5 z]:éÿÿÿÿú[rG ú:zInvalid server_string: %s)r5 r5 N)
ÚnetaddrZ
valid_ipv6Úfindr| rx rz ÚAddrFormatErrorrY Úerrorr )Z
server_strÚaddressÚportr r r Úparse_server_stringd s
r c C s t j| dd}t| ¡ S ©Né )Úversion)r Ú IPAddressr= Zipv6)r Zaddrr r r Úget_shortened_ipv6 s r c C s t j| dd}t|jS r )r Z IPNetworkr= Zcidr)r Znetr r r Úget_shortened_ipv6_cidr s r c C s< z t | ¡jdkr d| W S W n tt jfy6 Y n0 | S )zTransform ip string to "safe" format.
Will return ipv4 addresses unchanged, but will nest ipv6 addresses
inside square brackets.
r z[%s])r r r Ú TypeErrorr )Zipr r r Úsafe_ip_format s r c C s | du r |S dt | |f S )zÌ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.
Nz%s:%s)r )ÚhostÚpathr r r Úformat_remote_path s r c C s t js
dS t d¡ tjr"tj} ndd } t jD ]Ò}| d¡\}}t
|¡}t | t
|¡}t| ¡ D ]\}}t|t
jrÂt
d||f ¡}t || ¡D ]$\} }
t|| |d||| f |
qt|t
jrjt
d||f ¡}
ttj| ||d||f |
qjq0dS )aÿ 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
Nz0Monkey patching dmapi is deprecated for removal.c S s t | ¡pt | ¡S r2 )ÚinspectÚismethodZ
isfunction)Úobjr r r Ú is_methodÀ s z monkey_patch.<locals>.is_methodr z%s.%sz%s.%s.%s)r Ú monkey_patchrY Úwarningr8 ÚPY2r r Zmonkey_patch_modulesrx r
Z import_classÚ
__import__ÚpyclbrZ
readmodule_exÚlistÚitemsrU ZClassZ
getmembersÚsetattrZFunctionÚsysÚmodules) r Zmodule_and_decoratorÚmoduleZdecorator_nameÚ decoratorZ module_dataÚkeyr ZclzÚmethodÚfuncr r r r © s.
ÿ ÿr c C s dd }t | tjr0| dd¡} tjr0| d¡} || } t dd| ¡} t dd| ¡} | ¡ } | d ¡} | dkr~|d
ur~||S | S ) as 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 s6 t | dkr*t td| | d d
d¡ | d d
S )Né? zJHostname %(hostname)s is longer than 63, truncate it to %(truncated_name)s)ÚhostnameZtruncated_name)ÚlenrY r r )Únamer r r Útruncate_hostnameè s
þz,sanitize_hostname.<locals>.truncate_hostnamezlatin-1Úignorez[ _]ú-z[^\w.-]+r5 z.-N)
rU r8 r9 r ÚPY3ÚdecodeÚreÚsubÚlowerÚstrip)r® Z default_namer± r r r Úsanitize_hostnameÙ s
rº c
+ sæ dd fdd} fdd} fdd}t }i }t| ¡ D ]$\}}|| ||||< || || qBz@d V W t| ¡ D ](\}} | |u r|| | q~|| || q~n8t| ¡ D ](\}} | |u rÒ|| | q¶|| || q¶0 d S )
a4 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 | dpt| tS )NZhas_key)ÚhasattrrU Údict)Úthingr r r Ú is_dict_like s z(temporary_mutation.<locals>.is_dict_likec s$ | r| ||¡S t| ||S d S r2 )rd Úgetattr)r½ ÚattrÚdefault©r¾ r r rd s z temporary_mutation.<locals>.getc s" | r|| |< n t | || d S r2 )r¥ )r½ rÀ Úvalr r r Ú set_value s
z%temporary_mutation.<locals>.set_valuec s | r| |= n
t | | d S r2 )Údelattr)r½ rÀ r r r Údelete s z"temporary_mutation.<locals>.deleteN)Úobjectr£ r¤ )
r r' rd rÄ rÆ Z NOT_PRESENTZ
old_valuesrÀ Ú new_valueÚ old_valuer r r Útemporary_mutation s& ü rÊ c
c s| |du rt ¡ }t | ¡j}||kr6tjjj| |d z$dV W ||krxtjjj| |d n ||krvtjjj| |d 0 dS )zgTemporarily chown a path.
:param owner_uid: UID of temporary owner (defaults to current user)
N)Úuid)ÚosÚgetuidÚstatÚst_uidÚdmapiZprivsepr Úchown)r Z owner_uidZorig_uidr r r Útemporary_chown6 s ÿrÒ c k sÄ | ¡ }d|vrtj|d< tjf i |¤}zN|V W zt |¡ W qÀ tyv } z t t
d|¡ W Y d }~qÀd }~0 0 nFzt |¡ W n4 ty¼ } z t t
d|¡ W Y d }~n
d }~0 0 0 d S )NÚdirzCould not remove tmpdir: %s) Úcopyr ÚtempdirÚtempfileZmkdtempÚshutilÚrmtreeÚOSErrorrY r r )r' ZargdictZtmpdirÚer r r rÕ J s
(ýrÕ c c sH |sg }| ¡ D ]2}||vr| |¡ t||D ]
}|V q0|V qdS )z:Walk class hierarchy, yielding most derived classes first.N)Ú__subclasses__rf Úwalk_class_hierarchy)ZclazzZ encounteredÚsubclassZ subsubclassr r r rÜ Y s
rÜ c @ s2 e Zd ZdZdd Zdd Zdd Zd d d
ZdS ) Ú UndoManagerziProvides a mechanism to facilitate rolling back a series of actions
when an exception is raised.
c C s
g | _ d S r2 )Ú
undo_stack)r& r r r r3 j s zUndoManager.__init__c C s | j |¡ d S r2 )rß rf ©r& Z undo_funcr r r Ú undo_withm s zUndoManager.undo_withc C s t | jD ]
}| q
d S r2 )Úreversedrß rà r r r Ú _rollbackp s zUndoManager._rollbackNc K sJ t ¡ . |r tj|fi |¤ | ¡ W d n1 s<0 Y dS )z¦Rollback a series of actions then re-raise the exception.
.. note:: (sirp) This should only be called within an
exception handler.
N)r Úsave_and_reraise_exceptionrY r rã )r& Úmsgr' r r r Úrollback_and_reraiset s
z UndoManager.rollback_and_reraise)N)r) r* r+ Ú__doc__r3 rá rã ræ r r r r rÞ f s
rÞ Fc C sn | dkrdg}n
dd| g}| dv r.| dg¡ |rR| dv r@d}nd }| ||g¡ | |¡ t|d
|i d S ) zç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
ZswapZmkswapÚmkfsz-t)Zext3Zext4Zntfsz-F)ZmsdosZvfatz-nz-Lrc N)rg rf r( )Zfsr Zlabelrc r: Z label_optr r r rè s
rè c C s2 i }| D ]$}|s | d¡r q|d ||d < q|S )NZdeletedr rª ©rd )ÚmetadataÚinclude_deletedÚresultÚitemr r r Úmetadata_to_dict s rî c C s0 g }t | ¡ D ]\}}| t||d¡ q|S )N)rª r )r£ r¤ rf r¼ )rê rì rª r r r r Údict_to_metadata£ s rï c C s& t | d tr| d S t| d S d S )Nrê )rU r¼ rî ©Úinstancer r r Ú
instance_metaª s rò c C s8 | d¡si S t| d tr$| d S t| d ddS d S )NZsystem_metadataT©rë )rd rU r¼ rî rð r r r Úinstance_sys_meta± s
ÿrô c s fdd}|S )Nc s t ¡ fdd}|S )Nc sV t | ¡}t |¡\}}}}|s4|s4t t|kr<| S td|jjd d S )Nz^Decorated function %(f_name)s does not have the arguments expected by the decorator %(d_name)s)Zf_nameZd_name)r Zget_wrapped_functionr Ú
getargspecÚsetr r) )ÚfZbase_fÚ arg_namesÚaÚkwZ_default)r: Údecr r Ú
_decorator½ s
ÿýzAexpects_func_args.<locals>._decorator_checker.<locals>._decorator)Ú functoolsÚwraps)rû rü ©r: )rû r Ú_decorator_checker¼ s z-expects_func_args.<locals>._decorator_checkerr )r: r r rÿ r Úexpects_func_args» s r c @ s e Zd ZdZdd Zdd ZdS )ÚExceptionHelperzrClass to wrap another and translate the ClientExceptions raised by its
function calls to the actual ones.
c C s
|| _ d S r2 )Ú_target)r& Útargetr r r r3 Õ s zExceptionHelper.__init__c s& t | j| t ¡ fdd}|S )Nc
sH z | i |¤W S t jyB } ztj|j W Y d }~n
d }~0 0 d S r2 )Ú messagingZExpectedExceptionr8 ZreraiseÚexc_info)r: r' rÚ ©r¬ r r ÚwrapperÛ s z,ExceptionHelper.__getattr__.<locals>.wrapper)r¿ r rý rþ )r& r° r r r r Ú __getattr__Ø s zExceptionHelper.__getattr__N)r) r* r+ rç r3 r r r r r r Ð s r c C s t | tjs6|du r td}n td| }tj|d|du rB| }t| |k rltd||d }tj|d|rt| |krtd||d }tj|ddS ) zã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
Nz$The input is not a string or unicodez %s is not a string or unicode)Úmessagez?%(name)s has a minimum character requirement of %(min_length)s.)r° Ú
min_lengthz1%(name)s has more than %(max_length)s characters.)r° Ú
max_length)rU r8 Ú string_typesr r Ú InvalidInputr¯ )r r° r r rå r r r Úcheck_string_lengthä s"
ÿ ÿr c
C sN zt | |||¡W S tyH } z tjt |¡dW Y d}~n
d}~0 0 dS )aA 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
)ÚreasonN)r Úvalidate_integerrz r r r8 r9 )r r° Z min_valueZ max_valuerÚ r r r r s
r c C s2 t sd S t ¡ } d }| r.| j| ¡ | ¡ d}|S )N)Úhmac_keyZbase_idZ parent_id)Úprofilerrd r Z get_base_idZget_id)ZprofZ
trace_infor r r Ú_serialize_profile_info s ýr c s@ t ¡ t t ¡ fdd}tj|g|¢R i |¤S )am 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 s6 d ur ¡ r(tr(tjf i ¤ | i |¤S r2 ©Z update_storer Úinitrj ©Z_contextr¬ Z
profiler_infor r Úcontext_wrapper- s
z spawn.<locals>.context_wrapper)Úcommon_contextÚ get_currentr rý rþ ÚeventletÚspawn©r¬ r: r' r r r r r s
r c sD t ¡ t t ¡ fdd}tj|g|¢R i |¤ dS )ao 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 ur ¡ r(tr(tjf i ¤ | i |¤ d S r2 r rj r r r r G s
z spawn_n.<locals>.context_wrapperN)r r r rý rþ r Úspawn_nr r r r r : s
r c C s t | tjsdS | ¡ dkS )z/Check if a string represents a None value.
FZnone)rU r8 r
r¸ )rà r r r Úis_none_stringT s r c C s( d}| d ur$| ¡ ¡ }|dkr$d}|S )NFZdisabledT)r¹ r¸ )Zauto_disk_config_rawZauto_disk_config_disabledZ adc_loweredr r r Ú is_auto_disk_config_disabled] s r c C s |d u rt | }| d¡S )NZimage_auto_disk_config)rô rd )rñ Zsys_metar r r Ú"get_auto_disk_config_from_instancef s r! c C s
| d¡S )NZauto_disk_configré )Zimage_propertiesr r r Ú%get_auto_disk_config_from_image_propsl s r" c C s´ i }t d }t| di ¡ ¡ D ].\}}|tv r2q tt |¡d}|||| < q tD ]Z}| |¡}|dkr|r| d¡dkr|d }nt |pd|d }|d u r¢qT|||| < qT|S ) Nz%sÚ
propertieséÿ r r ZvhdZroot_gbr )
ÚSM_IMAGE_PROP_PREFIXr£ rd r¤ Ú SM_SKIP_KEYSÚ
safe_truncater8 r9 ÚSM_INHERITABLE_KEYSÚmax)Ú
image_metaZflavorÚ system_metaZ
prefix_formatrª r rÈ r r r Ú get_system_metadata_from_imagep s"
r, c C s i }i }t | ts t| dd} t| ¡ D ]P\}}|d u r<q*| t¡rV|ttd
}|tv r`q*|t v rr|||< q*|||< q*||d< |S )NTró r# )
rU r¼ rî r£ r¤ Ú
startswithr% r¯ r& r( )r+ r* r# rª r r r r Ú get_image_from_system_metadata s
r. c C sj t | di ¡¡}d|i}| dd¡tj |d< tD ](}| |d ¡}|dv r4t|pTd||< q4d|d< |S )NZvolume_image_metadatar# r r )r r ZactiveÚstatus)rÔ rd r
ZGiÚVIM_IMAGE_ATTRIBUTESr6 rW )Zvolumer# r* rÀ rà r r r Ú get_image_metadata_from_volume© s r1 c C s$ t | tjr| d¡} t | ¡ ¡ S )zReturns string that represents MD5 hash of base_str (in hex format).
If base_str is a Unicode string, encode it to UTF-8.
r )rU r8 r9 r ÚhashlibZmd5Ú hexdigest©Zbase_strr r r Ú get_hash_str s
r5 c C s$ t | tjr| d¡} t | ¡ ¡ S )a@ 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.
r )rU r8 r9 r r2 Zsha256r3 r4 r r r Úget_sha256_strÌ s
r6 c C s t | }tjst |d¡}|S )z½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.
r )Úreprr8 r´ r9 )r Zobj_reprr r r Úget_obj_repr_unicodeÙ s r8 c s® t |tr|g}fdd dd fdd}g }|D ]n}dkr^|du rRd }| |i ¡}|D ]}||||}qbt| ¡ D ]&\} }
| d
| d |
d |i¡ qq:|S )
am 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 dkr| d¡S d S )Nrñ Zuuidré )Úresource)Ú
resource_typer r Ú_get_id s z4filter_and_format_resource_metadata.<locals>._get_idc s& t | tr| g} t fdd| D S )Nc s g | ]}t | ¡qS r )r¶ Úmatch)r> Úpattern©Ústringr r r@ s ÿzKfilter_and_format_resource_metadata.<locals>._match_any.<locals>.<listcomp>)rU r= Úany)Z pattern_listr? r r> r Ú
_match_any s
ÿz7filter_and_format_resource_metadata.<locals>._match_anyc s | dg ¡}| dg ¡}| dg ¡}i }|r< | |vr<i S t| ¡ D ]N\}}|rp|rp||sp||spqHn |r~||rH|r||sqH|||< qH|S )NZ resource_idrª r )rd r£ r¤ ) r9 Z search_filtZinput_metadataZidsZ keys_filterZ
values_filterZoutput_metadataÚkÚv)r; rA r r Ú_filter_metadata s* ÿþÿÿ
z=filter_and_format_resource_metadata.<locals>._filter_metadatarñ Nrê rª r z%s_id)rU r¼ rd r£ r¤ rf ) r: Z
resource_listZ search_filtsZ
metadata_typerD Zformatted_metadata_listÚresrê ZfiltrB rC r )r; rA r: r Ú#filter_and_format_resource_metadataå s$ '
ÿ
rF c C sR t | ¡d|
}d}|sNzt |¡}d}W q tyJ |dd
}Y q0 q|S )zpSafely truncates unicode strings such that their encoded length is
no greater than the length provided.
NFTr
)r Z safe_encodeZ safe_decodeÚUnicodeDecodeError)r ÚlengthZb_valueZ decode_okZu_valuer r r r' G s
r' c C s |r t | d}tj | ¡}t | i ¡}|r<|| dd¡krt d| ¡ t | }|
¡ |d< W d n1 sr0 Y ||d< d}||d fS )z¿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.
FÚmtimer zReloading cached file %sÚdataNT) Údelete_cached_filerÌ r ÚgetmtimeÚ _FILE_CACHEÚ
setdefaultrd rY ÚdebugÚopenÚread)ÚfilenameZ force_reloadZreloadedrI Ú
cache_infoZfapr r r Úread_cached_file[ s
*rT c C s | t v rt | = dS )zLDelete cached file if present.
:param filename: filename to delete
N)rM )rR r r r rK t s rK c C sD | s t ¡ } | d¡}| jr(| j d¡nd}||dv r:dn|7 }|S )zsCurrent time as ISO string,
as timeutils.isotime() is deprecated
:returns: Current time in ISO format
z%Y-%m-%dT%H:%M:%SNÚUTC)rU z UTC+00:00ÚZ)r ry ÚstrftimeZtzinfoÚtzname)ÚatZ date_stringZtzr r r Úisotime s
rZ c C s
| d¡S )Nz%Y-%m-%dT%H:%M:%S.%f)rW )rY r r r Ústrtime s r[ c C s¦ | j r | j S | jdkr6z | ¡ jW S ty4 Y n0 z
| ¡ W S tjyT Y n0 t| j }|D ].}|| _ z| ¡ W S tjy Y qd0 qdt d| ¡dS )añ 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.
ZimagezICould not find requested endpoint for any of the following interfaces: %sN)
Zendpoint_overrideZ service_typeZget_endpoint_dataZ catalog_urlÚAttributeErrorÚ get_endpointÚks_excZEndpointNotFoundr£ Ú interface)Z ksa_adapterZ
interfacesr_ r r r r] s.
ÿÿr] c C s" t tdst d¡ dS tj | d¡}d}d }zzXt |tjtjB tj B ¡}d}t
d|¡}| d| ¡ t ||¡ t d d
| i¡ W nä t y } zj|j
t
jkrÀt d | |d ¡ d}n:t ¡ " t d
| |d ¡ W d n1 sð0 Y W Y d }~njd }~0 tyn } zHt ¡ " t d
| |d ¡ W d n1 sP0 Y W Y d }~n
d }~0 0 W |d urt |¡ zt |¡ W n0 tyÄ } zt |¡ W Y d }~n
d }~0 0 nV|d urÜt |¡ zt |¡ W n0 ty } zt |¡ W Y d }~n
d }~0 0 0 |S )NÚO_DIRECTz/This python runtime does not support direct I/OFz.directio.testTi r
ó xz#Path '%(path)s' supports direct I/Or z5Path '%(path)s' does not support direct I/O: '%(ex)s')r Úexz7Error on '%(path)s' while checking direct I/O: '%(ex)s')r» rÌ rY rO r rX rP ÚO_CREATÚO_WRONLYr` ÚmmapÚwriterÙ ÚerrnoÚEINVALr rä r Ú ExceptionÚcloseÚunlinkr )ÚdirpathZtestfileZ hasDirectIOÚfdZ
align_sizeÚmrÚ rb r r r Úsupports_direct_ioÆ sZ
ÿ ÿ
þ6
ÿ<
ù
ro c C s& t jrt | ¡d S t | ¡d S d S )Nr )r8 r r rõ r r r r r Úget_func_valid_keysö s rp )rk )NN)N)N)N)NF)F)Nr N)NN)NN)N)N)F)N)~rç Ú
contextlibrÔ r{ rg rý r2 r re rÌ r¢ r^ r¶ r× r¦ rÖ r[ r Z
keystoneauth1r r^ r Z
ks_loadingr Zoslo_concurrencyr r Z oslo_contextr r Zoslo_logr rS Zoslo_messagingr Z
oslo_utilsr r r
r r r
r8 Z six.movesr Z
dmapi.confrÐ r Z
dmapi.i18nr r r r r Z
try_importr Zconfr Z getLoggerr) rY Z _IS_NEUTRONZsynchronized_with_prefixrb r% r( r& r0 rM r» r rõ r! rÇ r" r, r( ri r$ ro r r r r r r r r rº ÚcontextmanagerrÊ rÒ rÕ rÜ rÞ rè rî rï rò rô r r r r r r r r r r! r" r, r. r1 r5 r6 r8 rF r' rT rK rZ r[ r] ro rp r r r r Ú<module> sÔ
l
] 0
(
4
ÿ
b
50