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:
4.3.1.2-4.3 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.6
/
site-packages
/
contego
/
__pycache__
/
utils.cpython-36.pyc
|
|---|
3
ÒƜe/# ã @ sf d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
m Z d dl m
Z
d dlZd dlZd dlZy d dlZW n ek
r¬ d dlZY nX d dlmZ yd dlmZ W n ek
rê ddlmZ Y nX d dlZej e Z ej j Z dZ!d Z"d
gZ#d d gZ$d
dgZ%i Z&i Z'xe%D ]Z(g e&e(< x8e$D ]0Z)ej*e)de(i ej+ej,B Z-e&e( j.e- qDW g e'e(< x8e#D ]0Z)ej*e)de(i ej+ej,B Z-e'e( j.e- qW q2W d3ddZ/dd Z0dd Z1dd Z2dd Z3dd Z4d d Z5d d Z6ej7ej7ej7d!fd"d#Z8d4d%d&Z9d'd( Z:G d)d* d*e;Z<d+d, Z=ej>d-d. Z?d/d0 Z@d1d2 ZAdS )5é N)Úsleep)ÚProcess)Ú processutils)Ústrutils)Úlogé z//i z$(%(key)s[0-9]*\s*[=]\s*)[^\s^\'^\"]+z.(%(key)s[0-9]*\s*[=]\s*[\"\'])[^\"\']*([\"\'])z-([-]{2}%(key)s[0-9]*\s+)[^\'^\"^=^\s]+([\s]*)ÚdataÚsecretÚkeyú***c C s¦ d| }d| d }t | tr(dj| } t | trxntD ]P}|| j kr8x t| D ]}tj||| } qRW x t | D ]}tj||| } qrW q8W nt | t
r¢t j | | S )Nz\g<1>z\g<2>ú )
Ú
isinstanceÚlistÚjoinÚstrÚ_SANITIZE_KEYSÚlowerÚ_SANITIZE_PATTERNS_2ÚreÚsubÚ_SANITIZE_PATTERNS_1Údictr Zmask_dict_password)Úmessager Z substitute1Z substitute2r
Úpattern© r ú/usr/lib/python3.6/utils.pyÚsanitize_message; s
r c G s` y4t | |d}|j |j r2td tj|d W n& tk
rZ } z
|W Y d d }~X nX d S )N)ÚtargetÚargsé
)r ÚstartZis_aliver ÚosÚutimeÚ Exception)ÚmethodÚprogress_tracking_file_pathr ÚprocessÚexr r r Ú run_processL s r( c C s@ t j t jt j}t jtj|j dtjd| d d
dd
S )Ni Z256sé é é ) ÚsocketZAF_INETZ
SOCK_DGRAMZ inet_ntoaÚfcntlZioctlÚfilenoÚstructÚpack)ZifnameÚsr r r Úget_ip_addressY s
r2 c C s< ddd}t j }|j| ||dd}|d k r4|S tj S )Nc S s" | j ||r| j|||S d S d S )N)Z
has_optionÚget)ÚcfgZSectionZOptionZKeyr r r Úget_config_valuec s z$get_lan_ip.<locals>.get_config_valueZDEFAULTZmy_ip)N)Ú ConfigParserÚreadr, Z gethostname)Z config_filer5 r4 Zipr r r Ú
get_lan_ipb s
r8 c C sT yt j| W n@ tk
rN } z$|jtjkr<t jj| s> n W Y dd}~X nX dS )zeCreate a directory (and any ancestor directories required)
:param path: Directory to create
N)r! ÚmakedirsÚOSErrorÚerrnoZEEXISTÚpathÚisdir)r< Úexcr r r Ú ensure_treer s r? c
C s& t | d tj| d W dQ R X dS )zy Utility to simulate the filesystem "touch" command.
Args:
file_path (str): Path to file to be touched.
ÚaN)Úopenr! r" )Z file_pathr r r Ú
touch_file s
rB c C s t jd| |f y$t| d}|j| W d Q R X W nJ tk
r } z.td t| d}|j| W d Q R X W Y d d }~X nX d S )Nzupdate_progress %s: %sr@ r )ÚLOGÚinforA Úwriter# r )r% Z progress_msgÚprogress_tracking_filer' r r r Úupdate_progress s rG c C sh y t | d
}|j S Q R X W nD tk
rb } z(td t | d
}|j S Q R X W Y d d }~X nX d S )NÚrr )rA Ú readlinesr# r )r% rF r' r r r Ú get_progress s rJ Fc C s t j| |||dd}|S )NF)ÚstdinÚstdoutÚstderrÚshell)Ú
subprocessÚPopen)ÚcmdrK rL rM rN r& r r r Úrun_cmd¥ s rR é c C s¼ yd}xB| j d krH|dkr&||kr&P t| |d7 }|d k rt| qW | jj | j}|rtjd| tjd|t | j
j d|d |S t k
r¶ } z
|W Y d d }~X nX d S )Nr r z
Result was %sz7Execution error %(exit_code)d (%(stderr)s). cmd %(cmd)szutf-8)Z exit_coderM rQ )
Zpollr rB rK ÚcloseÚ
returncoderC ÚerrorZ exceptionr rM r7 r# )r& rQ Z
sleep_timeZ no_of_countZ
progress_fileÚcountZ _returncoder' r r r Ú poll_process² s*
rX c
K sî dd }yº|j dd }|j dd }|j dd }| dkrb|t dddg dddd ||d
| g}n^| d krÀ|j d d }|j d
d }|t dddd d
g d ddd |d|d
| d | d |g}|S tk
rè } z
| W Y d d } ~ X nX d S )Nc S s2 x,|D ]$}| | d krt d|| d f qW d S )Nz8Required parameter: %s for %s connection can not be NonerQ )r# )ÚlocalsÚkeysr
r r r Ú
_key_checkÒ s
z!get_cmd_specs.<locals>._key_checkÚauthorized_keyÚuserÚhostZsshz-ozStrictHostKeyChecking=noz-iú@ZscpÚ source_pathÚ dest_pathz-rú:z/*)r3 rY r# )
rQ Úkwargsr[ r\ r] r^ Zcmdspecr` ra r' r r r Ú
get_cmd_specsÑ s< rd c @ s e Zd Zdd ZdS )Úget_dummy_objectc K s | j j| d S )N)Ú__dict__Úupdate)Úselfrc r r r Ú__init__ÿ s zget_dummy_object.__init__N)Ú__name__Ú
__module__Ú __qualname__ri r r r r re þ s re c C s
| j dS )Nz%Y-%m-%dT%H:%M:%S.%f)Zstrftime)Zatr r r Ústrtime s rm c k sz | j }d|krtj|d< tjf |}z
|V W d ytj| W n2 tk
rr } ztj t
d| W Y d d }~X nX X d S )NÚdirzCould not remove tmpdir: %s) ÚcopyÚCONFÚtempdirÚtempfileZmkdtempÚshutilZrmtreer: rC rV Z_LE)rc ZargdictZtmpdirÚer r r rq s
rq c C sZ y4| j ddjdd }| |d
}tj|d d S tk
rT } z| S d}~X nX dS )zl
Replaces single quote with double quotes.
It Parses the Backing File and returns json.
ú'ú"rb r NÚfileÚfilename)ÚreplaceÚfindÚjsonÚloadsr# )Z backing_fileZjson_key_positionZbacking_file_contextr' r r r Ú"parse_encrypted_image_backing_file s r} c C sd y*| r(t jddtjd|| \}}|s(dS W n4 tk
r^ } ztjdj| || dS d}~X nX dS )z2 This utility method changes permission of device.Zsudoz
nova-rootwrapÚchmodTz+cannot change permission of {0} to {1}. {2}FN)r Zexecuterp Zrootwrap_configr# rC rD Úformat)ZdeviceZpermÚoutÚerrr' r r r Úchange_device_permission! s
r )r )rS r N)Br! r{ r; r, r- r/ rO r Ztimer Zmultiprocessingr Zoslo_concurrencyr Ú
contextlibrr rs r6 Ú ImportErrorZ configparserZ
oslo_utilsr Zoslo_logr ZloggingZnova.openstack.commonZ contego.confZcontegoZ getLoggerrj rC Zconfrp Z
URL_PREFIXZRWRWRWZ_FORMAT_PATTERNS_1Z_FORMAT_PATTERNS_2r r r r
r ÚcompileÚDOTALLÚ
IGNORECASEZreg_exÚappendr r( r2 r8 r? rB rG rJ ÚPIPErR rX rd Úobjectre rm Úcontextmanagerrq r} r r r r r Ú<module> s|
-