Gemfury

triliodata-dev-stable-4-2 / python3-dmapi rpm

Repository URL to install this package:
Details
python3-dmapi / usr / lib / python3.6 / site-packages / dmapi / __pycache__ / utils.cpython-36.opt-1.pyc
3

ÿnaWªã@sÂdZddlZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlZddl
Z
ddlZddlZddlZddlZddlmZddlmZddlZddlmZddlmZddlmZddlmZ ddl!Z"dd	l#m$Z$dd
l#m%Z%ddl#m&Z&ddl#m'Z'dd
l#m(Z(ddl#m)Z)ddl*Z*ddl+m,Z,ddl-Z.ddl.m/Z/ddl0m1Z1m2Z2m3Z3m4Z4ddl.m5Z5e&j6dZ7e.j8j9Z9e j:e;Z<dZ=ej>dZ?dZ@dZAdZBdZCiaDeEed"rÊejFZGnejGZGd#d$ZHGd%d&d&eIZJGd'd(d(eJZKd)d*ZLd+d,ZMd-d.ZNdd0d1ZOdd2d3ZPd4d5ZQd6d7ZRd8d9ZSd:d;ZTd<d=ZUd>d?ZVd@dAZWddBdCZXejYdDdEZZejYddFdGZ[ejYdHdIZ\ddJdKZ]GdLdMdMeIZ^ddOdPZ_ddQdRZ`dSdTZadUdVZbdWdXZcdYdZZdGd[d\d\eIZedd]d^Zfdd_d`ZgdadbZhdcddZidedfZjdgdhZkdidjZlddkdlZmdmdnZnddodpZodqdrZpdsdtZqdudvZrdwdxZsdydzZtdd{d|Zud}d~ZvdddZwddZxdddZyddZzddZ{ddZ|ddZ}dS)zUtilities 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ÚmappingsÚblock_device_mappingÚimg_mappingsÚimg_block_device_mappingÚimage_idÚ
image_nameÚsizeÚchecksumÚgetfullargspeccCstjjrd}n
dtj}|S)NÚsudozsudo dmapi-rootwrap %s)ÚCONFZworkaroundsZdisable_rootwrapÚrootwrap_config)Úcmd©r&ú/usr/lib/python3.6/utils.pyÚget_root_helperUs
r(c@seZdZddZddZdS)ÚRootwrapProcessHelpercOst|d<tj||S)NÚroot_helper)r(rÚtrycmd)Úselfr%Úkwargsr&r&r'r+^s
zRootwrapProcessHelper.trycmdcOst|d<tj||S)Nr*)r(rÚexecute)r,r%r-r&r&r'r.bs
zRootwrapProcessHelper.executeN)Ú__name__Ú
__module__Ú__qualname__r+r.r&r&r&r'r)]sr)c@s8eZdZiZedddZddZddZdd	Zd
S)ÚRootwrapDaemonHelperzdaemon-client-lockcCsJy
|j|Stk
rDddlm}|jdd|g}||j|<|SXdS)Nr)Úclientr"zdmapi-rootwrap-daemon)Ú_clientsÚKeyErrorZ
oslo_rootwrapr3ZClient)Úclsr$r3Z
new_clientr&r&r'Ú_get_clientjs

z RootwrapDaemonHelper._get_clientcCs|j||_dS)N)r7r3)r,r$r&r&r'Ú__init__uszRootwrapDaemonHelper.__init__cOsx|jdd}y|j||\}}d}Wn8tjk
r\}zdtj|}}d}WYdd}~XnX|rp|rp|rpd}||fS)NÚdiscard_warningsFÚT)Úpopr.rÚProcessExecutionErrorÚsixÚ	text_type)r,Úargsr-r9ÚoutÚerrZfailedZexnr&r&r'r+xszRootwrapDaemonHelper.trycmdcOsdd|D}|jdtj}|jdd}|jdd}|jdd}|jdd	}|jd
dg}d}	t|trv|}	dg}nt|tr|g}tjd
j|}
t	j
td|
|dxh|dkr|d	8}ytj}t	j
|td|
|jj||\}}
}tj|}t	j
|d|
||d|	rL||krLtj|
}
tj|}tj||
||
d|
|fStjk
r}z |tjks|tjkr´|r´td}t	j
|||j|j|j|j|jd|sÐt	j
|td|
n2t	j
|td|
|rtjtjjdddWYdd}~Xq°Xq°WdS)NcSsg|]}t|qSr&)Ústr)Ú.0Úcr&r&r'ú
<listcomp>sz0RootwrapDaemonHelper.execute.<locals>.<listcomp>ÚloglevelÚ
log_errorsÚ
process_inputÚdelay_on_retryTÚattemptséÚcheck_exit_coderFú zHExecuting RootwrapDaemonHelper.execute cmd=[%(cmd)r] kwargs=[%(kwargs)r])r%r-zRunning cmd (subprocess): %szECMD "%(sanitized_cmd)s" returned: %(return_code)s in %(end_time)0.3fs)Ú
sanitized_cmdZreturn_codeÚend_time)Ú	exit_codeÚstdoutÚstderrr%zS%(desc)r
command: %(cmd)r
exit code: %(code)r
stdout: %(stdout)r
stderr: %(stderr)r)Zdescr%ÚcoderQrRz%r failed. Not Retrying.z%r failed. Retrying.ééÈgY@)r;ÚloggingÚDEBUGÚ
isinstanceÚboolÚintrZ
mask_passwordÚjoinÚLOGÚinforÚtimerrr3r.rr<ZLOG_ALL_ERRORSZLOG_FINAL_ERRORÚdescriptionr%rPrQrRZsleepÚrandomÚSystemRandomZrandint)r,r%r-rFrGrHrIrJrLZignore_exit_coderNZ
start_timeÚ
returncoder@rArOÚformatr&r&r'r.st





zRootwrapDaemonHelper.executeN)	r/r0r1r4Úsynchronizedr7r8r+r.r&r&r&r'r2gs

r2cOsDd|kr8|jdr8tjr*ttjj||Stj||Stj||S)z3Convenience wrapper around oslo's execute() method.Úrun_as_root)Úgetr#Úuse_rootwrap_daemonr2r$r.r)r)r%r-r&r&r'r.Ós
r.cOs(dddg}|j||j|t||S)z+Convenience wrapper to execute ssh command.Zsshz-oz
BatchMode=yes)ÚappendÚextendr.)Údestr%r-Zssh_cmdr&r&r'Ússh_executeÞs


rkcOs>|jddr2tjr$ttjj||Stj||Stj||S)z2Convenience wrapper around oslo's trycmd() method.reF)rfr#rgr2r$r+r)r)r?r-r&r&r'r+æs
r+écs,dfddt|D}d|dj|fS)NZ%01234567890abcdefghijklmnopqrstuvwxyzcsg|]}tjjqSr&)r`raZchoice)rCZ_x)Ú
charactersr&r'rEósz generate_uid.<locals>.<listcomp>z%s-%sr:)rr[)ZtopicrÚchoicesr&)rmr'Úgenerate_uidñsrocCs&|s
tj}d}d|kr.|jdd\}}t|}|dk	r<|}ntj}|dkrXttd	|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|dkr|dkr*d}tjd||j
d
}||krttjd||j
dd
}tjd||j
dd
}ntjd||j
dd
}n|dkrÚtj||j|j	|j
d
}||krÈ|tjdd}|tjdd}nD|dkr|j
|ddd}||kr|tjdd}|tjdd}||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ú@rKNÚmonthÚdayÚyearÚhourz,Time period must be hour, day, month or year)rrrqrséé)rtrrrqrs)Zdays)ZminuteÚsecondZmicrosecond)Zhours)rqrrrsrt)r#Zinstance_usage_audit_periodÚsplitrZrÚutcnowÚ
ValueErrorrÚdatetimerqrsrrZ	timedeltaÚreplace)ZunitZbeforeÚoffsetZrightnowÚendrsrqZbeginr&r&r'Úlast_completed_audit_period÷sx













rcCs8|dkst|tjr|St|tjs.tj|}|jdS)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

    Nzutf-8)rXr=Zbinary_typer>Úencode)Úvaluer&r&r'Úutf8Ts

rcCsyltj|r|dfS|jddkrB|jdddjd\}}||fS|jdd	krX|dfS|jd\}}||fSttjfk
rtjt	d|d
SXdS)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.
    r:z]:rKú[ú:zInvalid server_string: %sNéÿÿÿÿr)r:r:)
ÚnetaddrZ
valid_ipv6Úfindr|rxrzÚAddrFormatErrorr\Úerrorr)Z
server_strÚaddressZportr&r&r'Úparse_server_stringds
rcCstj|dd}t|jS)Né)Úversion)rÚ	IPAddressrBZipv6)rZaddrr&r&r'Úget_shortened_ipv6srcCstj|dd}t|jS)Nr)r)rZ	IPNetworkrBZcidr)rZnetr&r&r'Úget_shortened_ipv6_cidrsrcCs<ytj|jdkrd|SWnttjfk
r6YnX|S)zTransform ip string to "safe" format.

    Will return ipv4 addresses unchanged, but will nest ipv6 addresses
    inside square brackets.
    rz[%s])rrrÚ	TypeErrorr)Zipr&r&r'Úsafe_ip_formatsrcCs|dkr|Sdt||fS)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_pathsrcCstjs
dStjdtjr"tj}ndd}xätjD]Ú}|j	d\}}t
j|}t|t
j|}xªt|jD]\}}t|t
jrÊt
jd||f}x4tj||D]$\}	}
t||	|d|||	f|
q¢Wt|t
jrnt
jd||f}
ttj|||d||f|
qnWq2WdS)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.cSstj|ptj|S)N)ÚinspectÚismethodZ
isfunction)Úobjr&r&r'Ú	is_methodÀszmonkey_patch.<locals>.is_methodrz%s.%sz%s.%s.%s)r#Úmonkey_patchr\Úwarningr=ÚPY2rrZmonkey_patch_modulesrxr
Zimport_classÚ
__import__ÚpyclbrZ
readmodule_exÚlistÚitemsrXZClassZ
getmembersÚsetattrZFunctionÚsysÚmodules)rZmodule_and_decoratorÚmoduleZdecorator_nameZ	decoratorZmodule_dataÚkeyrZclzÚmethodÚfuncr&r&r'r©s*


rcCsdd}t|tjr0|jdd}tjr0|jd}||}tjdd|}tjdd|}|j}|j	d	}|dkr~|d
k	r~||S|S)asReturn 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.

       cSs6t|dkr*tjtd||ddd|ddS)Né?zJHostname %(hostname)s is longer than 63, truncate it to %(truncated_name)s)ÚhostnameZtruncated_name)Úlenr\rr)Únamer&r&r'Útruncate_hostnameès
z,sanitize_hostname.<locals>.truncate_hostnamezlatin-1Úignorez[ _]ú-z[^\w.-]+r:z.-N)
rXr=r>rÚPY3ÚdecodeÚreÚsubÚlowerÚstrip)r©Zdefault_namer¬r&r&r'Úsanitize_hostnameÙs

rµc
+s¸ddfdd}fdd}fdd}t}i}x4t|jD]$\}}||||||<||||qDWz
d	VWd	x8t|jD](\}}	|	|kr¢|||q||||	qWXd	S)
a4Temporarily 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()
    cSst|dpt|tS)NZhas_key)ÚhasattrrXÚdict)Úthingr&r&r'Úis_dict_likesz(temporary_mutation.<locals>.is_dict_likecs$|r|j||St|||SdS)N)rfÚgetattr)r¸ÚattrÚdefault)r¹r&r'rfsztemporary_mutation.<locals>.getcs"|r|||<nt|||dS)N)r¡)r¸r»Úval)r¹r&r'Ú	set_values
z%temporary_mutation.<locals>.set_valuecs|r||=n
t||dS)N)Údelattr)r¸r»)r¹r&r'Údeletesz"temporary_mutation.<locals>.deleteN)Úobjectrr )
rr-rfr¾rÀZNOT_PRESENTZ
old_valuesr»Ú	new_valueZ	old_valuer&)r¹r'Útemporary_mutations
rÃc
csb|dkrtj}tj|j}||kr6tjjj||dz
dVWd||kr\tjjj||dXdS)zgTemporarily chown a path.

    :param owner_uid: UID of temporary owner (defaults to current user)
    N)Zuid)ÚosÚgetuidÚstatÚst_uidÚdmapiZprivseprÚchown)rZ	owner_uidZorig_uidr&r&r'Útemporary_chown6s
rÊcksz|j}d|krtj|d<tjf|}z
|VWdytj|Wn2tk
rr}ztj	t
d|WYdd}~XnXXdS)NÚdirzCould not remove tmpdir: %s)Úcopyr#ÚtempdirÚtempfileZmkdtempÚshutilZrmtreeÚOSErrorr\rr)r-ZargdictZtmpdirÚer&r&r'rÍJs

rÍccsP|sg}xB|jD]6}||kr|j|xt||D]
}|Vq4W|VqWdS)z:Walk class hierarchy, yielding most derived classes first.N)Ú__subclasses__rhÚwalk_class_hierarchy)ZclazzZencounteredÚsubclassZsubsubclassr&r&r'rÓYs

rÓc@s2eZdZdZddZddZddZdd	d
ZdS)ÚUndoManagerziProvides a mechanism to facilitate rolling back a series of actions
    when an exception is raised.
    cCs
g|_dS)N)Ú
undo_stack)r,r&r&r'r8jszUndoManager.__init__cCs|jj|dS)N)rÖrh)r,Ú	undo_funcr&r&r'Ú	undo_withmszUndoManager.undo_withcCsxt|jD]
}|qWdS)N)ÚreversedrÖ)r,r×r&r&r'Ú	_rollbackpszUndoManager._rollbackNc
Ks2tj |rtj|f||jWdQRXdS)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_exceptionr\rrÚ)r,Úmsgr-r&r&r'Úrollback_and_reraisets
z UndoManager.rollback_and_reraise)N)r/r0r1Ú__doc__r8rØrÚrÝr&r&r&r'rÕfs
rÕFcCsn|dkrdg}n
dd|g}|dkr.|jdg|rR|dkr@d}nd}|j||g|j|t|d
|idS)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Úext3Úext4Úntfsz-FÚmsdosÚvfatz-nz-LreN)ràrárâ)rãrä)rirhr.)ZfsrZlabelrer?Z	label_optr&r&r'rßs

rßcCs8i}x.|D]&}|r |jdr q
|d||d<q
W|S)NZdeletedrr¥)rf)ÚmetadataÚinclude_deletedÚresultÚitemr&r&r'Úmetadata_to_dicts
récCs4g}x*t|jD]\}}|jt||dqW|S)N)r¥r)rr rhr·)rårçr¥rr&r&r'Údict_to_metadata£srêcCs&t|dtr|dSt|dSdS)Nrå)rXr·ré)Úinstancer&r&r'Ú
instance_metaªsrìcCs8|jdsiSt|dtr$|dSt|dddSdS)NZsystem_metadataT)ræ)rfrXr·ré)rër&r&r'Úinstance_sys_meta±s
rícsfdd}|S)Ncstjfdd}|S)NcsVtj|}tj|\}}}}|s4|s4tt|kr<|Std|jjddS)Nz^Decorated function %(f_name)s does not have the arguments expected by the decorator %(d_name)s)Zf_nameZd_name)rZget_wrapped_functionrÚ
getargspecÚsetrr/)ÚfZbase_fZ	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¼sz-expects_func_args.<locals>._decorator_checkerr&)r?r÷r&)r?r'Úexpects_func_args»srøc@s eZdZdZddZddZdS)ÚExceptionHelperzrClass to wrap another and translate the ClientExceptions raised by its
    function calls to the actual ones.
    cCs
||_dS)N)Ú_target)r,Útargetr&r&r'r8ÕszExceptionHelper.__init__cs&t|j|tjfdd}|S)Ncs@y
||Stjk
r:}ztj|jWYdd}~XnXdS)N)Ú	messagingZExpectedExceptionr=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__ØszExceptionHelper.__getattr__N)r/r0r1rÞr8rÿr&r&r&r'rùÐsrùcCst|tjs6|dkrtd}ntd|}tj|d|dkrB|}t||krltd||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)rXr=Ústring_typesrrÚInvalidInputrª)rr«rrrÜr&r&r'Úcheck_string_lengthäs
rcCsJytj||||Stk
rD}ztjtj|dWYdd}~XnXdS)aAMake 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_integerrzrrr=r>)rr«Z	min_valueZ	max_valuerÑr&r&r'rs
rcCs2tsdStj}d}|r.|j|j|jd}|S)N)Úhmac_keyZbase_idZ	parent_id)ÚprofilerrfrZget_base_idZget_id)ZprofZ
trace_infor&r&r'Ú_serialize_profile_infosr
cs:tjttjfdd}tj|f||S)amPassthrough 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.
    cs.dk	rjr$tr$tjf||S)N)Úupdate_storer	Úinit)r?r-)Ú_contextr§Ú
profiler_infor&r'Úcontext_wrapper-s
zspawn.<locals>.context_wrapper)Úcommon_contextÚget_currentr
rõröÚeventletÚspawn)r§r?r-rr&)r
r§rr'r s

rcs>tjttjfdd}tj|f||dS)aoPassthrough 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.
    cs2dk	rjr$tr$tjf||dS)N)rr	r)r?r-)r
r§rr&r'rGs
z spawn_n.<locals>.context_wrapperN)rrr
rõrörÚspawn_n)r§r?r-rr&)r
r§rr'r:s

rcCst|tjsdS|jdkS)z/Check if a string represents a None value.
    FZnone)rXr=rr³)r½r&r&r'Úis_none_stringTsrcCs(d}|dk	r$|jj}|dkr$d}|S)NFZdisabledT)r´r³)Zauto_disk_config_rawZauto_disk_config_disabledZadc_loweredr&r&r'Úis_auto_disk_config_disabled]srcCs|dkrt|}|jdS)NZimage_auto_disk_config)rírf)rëZsys_metar&r&r'Ú"get_auto_disk_config_from_instancefsrcCs
|jdS)NZauto_disk_config)rf)Zimage_propertiesr&r&r'Ú%get_auto_disk_config_from_image_propslsrcCs¼i}td}xFt|jdijD].\}}|tkr4q"ttj|d}||||<q"WxbtD]Z}|j|}|dkr|r|jddkr|d}nt	|pd|d}|dkr¨qZ||||<qZW|S)	Nz%sÚ
propertieséÿrrZvhdZroot_gbr)
ÚSM_IMAGE_PROP_PREFIXrrfr ÚSM_SKIP_KEYSÚ
safe_truncater=r>ÚSM_INHERITABLE_KEYSÚmax)Ú
image_metaZflavorÚsystem_metaZ
prefix_formatr¥rrÂr&r&r'Úget_system_metadata_from_imageps"


r"cCsi}i}t|tst|dd}x`t|jD]P\}}|dkr>q,|jtrX|ttd}|tkrbq,|t	krt|||<q,|||<q,W||d<|S)NT)rær)
rXr·rérr Ú
startswithrrªrr)r!r rr¥rr&r&r'Úget_image_from_system_metadatas 


r$cCsntj|jdi}d|i}|jddtj|d<x0tD](}|j|d}|d	kr6t|pVd||<q6Wd|d<|S)
NZvolume_image_metadatarrrrrZactiveZstatus)rr)rÌrfr
ZGiÚVIM_IMAGE_ATTRIBUTESr;rZ)Zvolumerr r»r½r&r&r'Úget_image_metadata_from_volume©s
r&cCs$t|tjr|jd}tj|jS)zReturns string that represents MD5 hash of base_str (in hex format).

    If base_str is a Unicode string, encode it to UTF-8.
    zutf-8)rXr=r>rÚhashlibZmd5Ú	hexdigest)Úbase_strr&r&r'Úget_hash_strÂs
r*cCs$t|tjr|jd}tj|jS)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.
    zutf-8)rXr=r>rr'Zsha256r()r)r&r&r'Úget_sha256_strÌs
r+cCst|}tjstj|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.
    zutf-8)Úreprr=r¯r>)rZobj_reprr&r&r'Úget_obj_repr_unicodeÙsr-c
sºt|tr|g}fddddfdd}g}x~|D]v}dkr`|dkrTd	}|j|i}x|D]}||||}qfWx6t|jD]&\}	}
|jd
|	d|
d|iqWq<W|S)
amGet 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'.
    csdkr|jdSdS)NrëZuuid)rf)Úresource)Ú
resource_typer&r'Ú_get_idsz4filter_and_format_resource_metadata.<locals>._get_idcs&t|tr|g}tfdd|DS)Ncsg|]}tj|qSr&)r±Úmatch)rCÚpattern)Ústringr&r'rEszKfilter_and_format_resource_metadata.<locals>._match_any.<locals>.<listcomp>)rXrBÚany)Zpattern_listr3r&)r3r'Ú
_match_anys
z7filter_and_format_resource_metadata.<locals>._match_anyc	s¨|jdg}|jdg}|jdg}i}|r<||kr<iSxft|jD]V\}}|rv|rv||rv||rvqJn"|r||sJ|r||rqJ|||<qJW|S)NZresource_idr¥r)rfrr )	r.Zsearch_filtZinput_metadataZidsZkeys_filterZ
values_filterZoutput_metadataÚkÚv)r0r5r&r'Ú_filter_metadatas z=filter_and_format_resource_metadata.<locals>._filter_metadatarëNrår¥rz%s_id)rXr·rfrr rh)r/Z
resource_listZsearch_filtsZ
metadata_typer8Zformatted_metadata_listÚresråZfiltr6r7r&)r0r5r/r'Ú#filter_and_format_resource_metadataås"'


r:cCsXtj|d|}d}x<|sRytj|}d}Wqtk
rN|dd}YqXqW|S)zpSafely truncates unicode strings such that their encoded length is
    no greater than the length provided.
    NFTrKr)rZsafe_encodeZsafe_decodeÚUnicodeDecodeError)rZlengthZb_valueZ	decode_okZu_valuer&r&r'rGs
rc
Cs|rt|d}tjj|}tj|i}|s>||jddkrvtjd|t	|}|j
|d<WdQRX||d<d}||dfS)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ÚmtimerzReloading cached file %sÚdataNT)Údelete_cached_filerÄrÚgetmtimeÚ_FILE_CACHEÚ
setdefaultrfr\ÚdebugÚopenÚread)ÚfilenameZforce_reloadZreloadedr<Ú
cache_infoZfapr&r&r'Úread_cached_file[s	
rGcCs|tkrt|=dS)zLDelete cached file if present.

    :param filename: filename to delete
    N)r@)rEr&r&r'r>tsr>cCsD|stj}|jd}|jr(|jjdnd}||dkr: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ú	UTC+00:00ÚZ)rHrI)rryÚstrftimeZtzinfoZtzname)ÚatZdate_stringZtzr&r&r'Úisotimes
rMcCs
|jdS)Nz%Y-%m-%dT%H:%M:%S.%f)rK)rLr&r&r'ÚstrtimesrNcCs¦|jr|jS|jdkr6y
|jjStk
r4YnXy|jStjk
rTYnXt|j	}x2|D]*}||_	y|jStjk
rYqfXqfWtjd|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_overrideZservice_typeZget_endpoint_dataZcatalog_urlÚAttributeErrorÚget_endpointÚks_excZEndpointNotFoundrÚ	interface)Zksa_adapterZ
interfacesrRr&r&r'rPs*





rPc*CsttdstjddStjj|d}d}d}zyXtj|tjtjBtj	B}d}t
j
d|}|jd|tj||tjd	d
|iWn´tk
rö}zP|j
t
jkrÀtjd||dd}n&tjtjd
||dWdQRXWYdd}~XnJtk
r>}z,tjtjd
||dWdQRXWYdd}~XnXWd|dk	rXtj|ytj|Wn.tk
r}ztj|WYdd}~XnXX|S)NÚO_DIRECTz/This python runtime does not support direct I/OFz.directio.testTirKóxz#Path '%(path)s' supports direct I/Orz5Path '%(path)s' does not support direct I/O: '%(ex)s')rÚexz7Error on '%(path)s' while checking direct I/O: '%(ex)s'r)r¶rÄr\rBrr[rCÚO_CREATÚO_WRONLYrSÚmmapÚwriterÐÚerrnoZEINVALr	rÛrÚ	ExceptionÚcloseÚunlinkr)ÚdirpathZtestfileZhasDirectIOÚfdZ
align_sizeÚmrÑrUr&r&r'Úsupports_direct_ioÆsD


&
,


racCs&tjrtj|dStj|dSdS)Nr)r=rrrîr!)r§r&r&r'Úget_func_valid_keysösrb)rrrr)rrrr)rrrr rrrr)rl)NN)N)N)N)NF)F)NrN)NN)NN)N)N)F)N)~rÞÚ
contextlibrÌr{rZrõr'rrXrÄrr`r±rÏr¢rÎr^rZ
keystoneauth1rrQrZ
ks_loadingrZoslo_concurrencyrrZoslo_contextrrZoslo_logrrVZoslo_messagingrüZ
oslo_utilsrr	r
rrr
r=Z	six.movesrZ
dmapi.confrÈrZ
dmapi.i18nrrrrrZ
try_importr	Zconfr#Z	getLoggerr/r\Z_IS_NEUTRONZsynchronized_with_prefixrdrrrr%r@r¶r!rîr(rÁr)r2r.rkr+rorrrrrrrrrµÚcontextmanagerrÃrÊrÍrÓrÕrßrérêrìrírørùrrr
rrrrrrr"r$r&r*r+r-r:rrGr>rMrNrPrarbr&r&r&r'Ú<module>sÒ



l

]0
(5



	


		




a

50
triliodata-dev-stable-4-2 / python3-dmapi rpm

Products

About

Resources

Contact Gemfury
