3
\me
@ s6
d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZ
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl m Z m Z d dlm Z d dl!m"Z"m#Z# d dlm$Z$m%Z% d dl&m'Z' d dl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 d d l1m2Z2 d d
l3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mm?Z? da@e jAeBZCe
jDd iZEd
ejF ejG ZHd}ZId~ZJdd ZKe$ dddZLe$ dddZMdd d ZNdd d ZOePePd!d"d#ZQd$d% ZRG d&d' d'ZSG d(d) d)eTZUG d*d+ d+eTZVd,d- ZWdd.d/ZXdd0d1ZYdd2d3ZZdd5d6Z[dd7d8Z\dd9e+d:d;d<Z]d=d> Z^d?d@ Z_dAdB Z`ddDdEZadFdG ZbeceddHdIdJZedKdL ZfdCdCde jgdCfdMdNZhe$ dOdP Zie$ dQdR Zje$ dSdT Zke$ dUdV Zle$ dWdX Zme$ dYdZ Zndd\d]Zodd^d_Zpdd`daZqddbdcZre$ ddde Zsdfdg Zte$ dhdi ZuddjdkZvddldmZwdndo ZxddpdqZyde/e- eddrdsdtZzej{dudv Z|ej{dwdx Z}dydz Z~d{d| ZdddZdddZdedffddZdddZdd9edd:ddZdd9edd:ddZdddZdddZdd Ze ddddgZdddZdddZed:ddZdd Zdd Zdd Zdd Zdd ZdddZdddZdddZdddZdddZdddZdd ZdddZe$ dd Zdd Zed:ddZdddZdddZdddĄZddƄ ZddȄ Zddʄ Zdececd˜dd̈́Ze
jePdΜddЄZdd҄ ZddԄ Zddք ZdddلZedffddۄZdd݄ Zddd߄Zej{dd Zdd ZdddZdd Zdd ZdddZdd Zdd Zdd Ze$ dd Zdd Zdd Zdd[deeddddZdd Zdd ZecedddZecedddZececdddZececdd d
Zece,ec d d d
ZddCdddddZdd ZÐdddZĐdddZŐdddZƐd d Zǐd d ZȐd d! Zɐd"d# Ze$ d$d% Zːd&d' Z̐dd)d*Z͐d+d, Zΐd-d. Zϐd/d0 ZeCd[fd1d2Zѐd3d4 ZҐd5d6 ZӐd7d8 ZԐd9d: ZՐd;d< Zdd=d>ZeCd[fd?d@ZecedAdBdCZe0dDZڐde)dEef eڐdFdGdHZېdIdJ Zdde
jjDfdKdLZސddNdOZߐdPdQ ZddRdSZdTdU ZddVdWZdXdY ZdZd[ Zdd\d]Zdd_d`Zdadb ZddcddZdedf Zdgdh Zdidj ZddmdnZe%G dodp dpe dpdqdrdsdtgZdd~d[duecece.ec eedvdwdxZd~dyececedzd{d|ZdS ( N) b64decode)deque
namedtuple)suppress)EACCESENOENT) lru_cachetotal_ordering)Path)CallableDequeDictListMappingOptionalSequenceTypeVar)parse)
featuresimportermergersnetsafeyamlsubp
temp_utils
type_utils
url_helperversion) CFG_BUILTIN_z_-.()true1onyesoff0nofalsec C s" t tttj jjdd d S )N. )tuplemapintosunamereleasesplit r1 r1 /usr/lib/python3.6/util.pykernel_versionR s r3 c C s t j ddgd| d}|jj S )zReturn the sanitized string output by `dpkg --print-architecture`.
N.B. This function is wrapped in functools.lru_cache, so repeated calls
won't shell out every time.
Zdpkgz--print-architectureT)capturetarget)r stdoutstrip)r5 outr1 r1 r2 get_dpkg_architectureV s r9 c s ddddd}i yt j ddgd| d }x:|jj D ],}|jd
\}}}||kr4|j || < q4W fd d |j D }t|rtjd
dj | W nF t j
k
r } z(tjd| t dd |j D W Y d d }~X nX S )Ncodename descriptionidr/ )ZCodenameZ DescriptionzDistributor IDZRelease lsb_releasez--allT)r4 r5 :c s g | ]}| kr|qS r1 r1 ).0k)datar1 r2
s s z lsb_release..z.Missing fields in lsb_release --all output: %s,z#Unable to get lsb_release --all: %sc s s | ]}|d fV qdS )Z UNAVAILABLENr1 )r? vr1 r1 r2 | s z lsb_release..) r r6
splitlines partitionr7 valueslenLOGwarningjoinProcessExecutionErrordict) r5 Zfmapr8 linefnamer valmissingerrr1 )rA r2 r= c s( (r= utf-8c C s t | tr| S | j|S )N)
isinstancestrdecode)blobencodingr1 r1 r2
decode_binary s
rZ c C s t | tr| S | j|S )N)rU bytesencode)textrY r1 r1 r2 encode_text s
r^ )rA returnc C sB t | tstdt| y t| ddS tjk
r< | S X dS )zbase64 decode data
If data is base64 encoded bytes, return b64decode(data).
If not, return data unmodified.
@param data: data as bytes. TypeError is raised if not bytes.
z data is '%s', expected bytesT)ZvalidateN)rU r[ TypeErrortyper binasciiError)rA r1 r1 r2 maybe_b64decode s
rd c C sP | j dd}| j dkrLt|trL| j }|r<|jr<|j}nd}|j|dS |S )NT)rW r] zutf-8surrogateescape)Z get_payloadZget_content_maintyperU r[ Z get_charsetZ input_codecrW )partZ cte_payloadcharsetrY r1 r1 r2 fully_decoded_payload s
rh c @ s& e Zd Zd ddZdd Zdd ZdS )
SeLinuxGuardFc C s< yt jd| _W n tk
r* d | _Y nX || _|| _d S )Nselinux)r
import_modulerj ImportErrorpath recursive)selfrm rn r1 r1 r2 __init__ s zSeLinuxGuard.__init__c C s | j r| j j rdS dS d S )NTF)rj is_selinux_enabled)ro r1 r1 r2 __enter__ s zSeLinuxGuard.__enter__c C s | j s| j j rd S tjj| js*d S tjj| j}y"tj|}| j j||tj W n t
k
rn d S X t j d|| j
y| j j|| j
d W n4 t
k
r } zt jd|| j
| W Y d d }~X nX d S )Nz,Restoring selinux mode for %s (recursive=%s))rn z,restorecon failed on %s,%s maybe badness? %s)rj rq r- rm lexistsrealpathlstatZ matchpathconstatST_MODEOSErrorrJ debugrn Z
restoreconrK )ro Z excp_typeZ
excp_valueZexcp_tracebackrm Zstatser1 r1 r2 __exit__ s,
zSeLinuxGuard.__exit__N)F)__name__
__module__ __qualname__rp rr r{ r1 r1 r1 r2 ri s
ri c @ s e Zd ZdS )MountFailedErrorN)r| r} r~ r1 r1 r1 r2 r s r c @ s e Zd ZdS )DecompressionErrorN)r| r} r~ r1 r1 r1 r2 r s r c O st t j }|dkr\y| || t jd W qp tk
rX ttdtj| t jd Y qpX ntjd|tj| d S )Nr z&Failed forking and calling callback %s z(Forked child %s who will run callback %s) r- fork_exit ExceptionlogexcrJ r obj_namery )Zchild_cbargskwargsZfidr1 r1 r2 fork_cb s
r c C sB t | tr| dkS t}|r&t|| }t| j j |kr>dS dS )NTF)rU bool TRUE_STRINGSlistrV lowerr7 )rQ addons check_setr1 r1 r2 is_true s
r c C sB t | tr| dkS t}|r&t|| }t| j j |kr>dS dS )NFT)rU r
FALSE_STRINGSr rV r r7 )rQ r r r1 r1 r2 is_false s
r c C s | sdS t | tr| S t| |S )NF)rU r r )rQ r r1 r1 r2 translate_bool s
r c s8 t j stjtj dj fddtd| D S )N c s g | ]} j qS r1 )Zchoice)r? Z_x)r select_fromr1 r2 rB " s z rand_str..r )randomZ SystemRandomstring
ascii_lettersdigitsrL range)strlenr r1 )r r r2 rand_str s r c C s. |sd}x t ddd | }|| kr
P q
W |S )Nr )r r )r )Z
dictionaryZpostfixZnewkeyr1 r1 r2
rand_dict_key% s r )instance_data_file)r_ c C s ddl m}m}m} y t| }W n2 tk
rR } z|jtkr@i S W Y dd}~X nX |rtj j
|ry ||| |}t j d|| W nH |k
r Y n6 |k
r } zt j
d||t| W Y dd}~X nX |dkri S t|i dS )z>Read a yaml config with optional template, and convert to dictr )JinjaLoadError
NotJinjaError render_jinja_payload_from_fileNz?Applied instance data in '%s' to configuration loaded from '%s'z:Could not apply Jinja template '%s' to '%s'. Exception: %s)default)Z!cloudinit.handlers.jinja_templater r r load_fileIOErrorerrnor r- rm existsrJ ry rK repr load_yaml)rP r r r r Z config_filerz r1 r1 r2 read_conf/ s8
r c G s t t| S )N)sorted
uniq_merge)listsr1 r1 r2 uniq_merge_sorteda s r c G sJ g }x<| D ]4}t |tr4|j jd}dd |D }|j| q
W t|S )NrC c S s g | ] }|r|qS r1 r1 )r? ar1 r1 r2 rB s s z uniq_merge..)rU rV r7 r0 extend uniq_list)r Z
combined_lista_listr1 r1 r2 r m s
r c C sl x t j D ]\}}| j||} q
W g }x | D ]}|tkr,|j| q,W x|D ]}| j|d} qLW | j } | S )Nr )FN_REPLACEMENTSitemsreplace
FN_ALLOWEDappendr7 )fnr@ rD Zremovalsr1 r1 r2 clean_filenamex s
r Tc C s yLt jt| }tjtjd dd| }|r8t|j S |j S W d Q R X W n8 t k
r } z |rf| S t
t ||W Y d d }~X nX d S )Nrbr ) ioBytesIOr^
contextlibclosinggzipZGzipFilerZ readr r rV )rA quietrW bufZghrz r1 r1 r2 decomp_gzip s r c C s | sdS | j dd}|d j }t|dkr:|d j }nd }| sX|dksX|j dkr\d }| sv|dksv|j dkrzd }||fS )Nr> r r r) z-1Znone)NN)r0 r7 rI r )Zug_pairZ ug_partedugr1 r1 r2 extract_usergroup s r )root_dirr_ c C sl t }x`tjtjj| dD ]H}tjj|s.q tjj|dd }|j }|r |jddkr |||< q W |S )Nz*.pyr r( r ) rN globr- rm rL isfilebasenamer7 find)r entriesrP modnamer1 r1 r2 get_modules_from_dir s r c C s, t | d}|j| |j W d Q R X d S )Nw)openwriteflush)conpathr] Zwfhr1 r1 r2 write_to_console s
r c
C s |rt jj| |rd}d}tjj|rxyt|| d}W n< tk
rv d}t jj| d |rr|j t
j | Y nX |r| rt jj| |r| d dkr|j || d d n |j || d S ) Nz /dev/consoleFTz Failed to write to /dev/console
r r r ) sysstderrr r- rm r r rx r6 logloggingZWARNING) r] Zconsoler r Z log_levelZfallback_to_stdoutr Zwriting_to_console_workedZ
console_errorr1 r1 r2 multi_log s(
r c C s dt j kS )NZLinux)platformsystemr1 r1 r1 r2 is_Linux s r c C s$ dt j krdS t j dkr dS dS )NZBSDTZ DragonFlyF)r r r1 r1 r1 r2 is_BSD s
r c C s t d dkS )Nvariantfreebsd) system_infor1 r1 r1 r2
is_FreeBSD s r c C s t d dkS )Nr dragonfly)r r1 r1 r1 r2 is_DragonFlyBSD s r c C s t d dkS )Nr netbsd)r r1 r1 r1 r2 is_NetBSD s r c C s t d dkS )Nr openbsd)r r1 r1 r1 r2
is_OpenBSD s r Fc C s || kr |S t | | S )N)r )yobjkeyr r1 r1 r2 get_cfg_option_bool s r c C s* || kr |S | | }t |ts&t|}|S )N)rU rV )r r r rQ r1 r1 r2 get_cfg_option_str s
r c C s t t| ||dS )N)r )r, r )r r r r1 r1 r2 get_cfg_option_int s r c C s | sd} t jj| si S t| }d}d|kr0d}tj||}|r|j }d|d kr`|d |d< |d j jdd |d< |d d krd
|d< |d |d |d d S i S )
zReturn a dictionary of distro info fields from /etc/redhat-release.
Dict keys will align with /etc/os-release keys:
ID, VERSION_ID, VERSION_CODENAME
z/etc/redhat-releasezA(?P.+) release (?P[\d\.]+) \((?P[^)]+)\)Z Virtuozzoz)(?P.+) release (?P[\d\.]+)namer: z linuxr zred hat enterpriseredhatr )ID
VERSION_IDVERSION_CODENAME) r- rm r r rematch groupdictr rG )Z release_fileZredhat_releaseZ redhat_regexr groupr1 r1 r2 _parse_redhat_release s( r c C sv d} d}d}i }d}t jjdr,ttd}|s:d}t }|r|jdd} |jdd}d| ksfd| krptj }nn| d ks| d
kr|jd d}nP| d kr| r|jd d}n4|jd
d}|st j
d|jdd}|r|j d }| dkrd} nt r
tj
j } tj }nbd}z(y tj }W n tk
r2 Y nX W d d }x|D ]}|rBd}qBW |sftjd X |S | ||fS )Nr Fz/etc/os-releaseTr r slessusealpinephotonZ PRETTY_NAME virtuozzor z [^ ]+ \((?P[^)]+)\)VERSIONr: rhelr r zPUnable to determine distribution, template expansion may have unexpected results)r r r )r- rm r load_shell_contentr r getr machiner r r r r r r/ distr rJ rK ) Z distro_nameZdistro_versionZflavorZ
os_releaseZos_release_rhelr r foundentryr1 r1 r2 get_linux_distro@ sZ
r
c C sv | d j }d}|dkrf| d d j }|d*kr6|}qr|d+krDd}qr|d krRd}qr|d,kr`d}qrd}n |d-krr|}|S ).Nr unknownlinuxr r almalinuxr archcentos
cloudlinuxdebian eurolinuxfedoramariner miraclelinux openeuler opencloudos openmandrivar r rockyr tencentosr ubuntu linuxmintmintr opensuse
opensuse-leapopensuse-microosopensuse-tumbleweedsle_hpc sle-micror windowsdarwinr 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 r! r" r# r )r$ r% r r r r )r )infor r Z
linux_distr1 r1 r2 _get_variant~ s` r' c C s< t j t j t j t j tt j t d} t| | d< | S )N)r r r/ pythonr. r r )r r r/ Zpython_versionr r. r
r' )r& r1 r1 r2 r s
r c C sX || kr |S | | dkr g S | | }t |tr@dd |D }|S t |tsRt|}|gS )a
Gets the C{key} config option from C{yobj} as a list of strings. If the
key is present as a single string it will be returned as a list with one
string arg.
@param yobj: The configuration object.
@param key: The configuration key to get.
@param default: The default to return if key is not found.
@return: The configuration option as a list of strings or default if key
is not found.
Nc S s g | ]}|qS r1 r1 )r? rD r1 r1 r2 rB s z'get_cfg_option_list..)rU r rV )r r r rQ Zcvalr1 r1 r2 get_cfg_option_list s
r) c C s> t |tr|jd}| }x |D ]}||kr.|S || }q W |S )a Return the value of the item at path C{keyp} in C{yobj}.
example:
get_cfg_by_path({'a': {'b': {'num': 4}}}, 'a/b/num') == 4
get_cfg_by_path({'a': {'b': {'num': 4}}}, 'c/d') == None
@param yobj: A dictionary.
@param keyp: A path inside yobj. it can be a '/' delimited string,
or an iterable.
@param default: The default to return if the path does not exist.
@return: The value of the item at keyp."
is not found./)rU rV r0 )r Zkeypr Zcurtokr1 r1 r2 get_cfg_by_path s
r, c C s t | |\}}t|| ||fS )N)get_output_cfgredirect_output)cfgmodeoutfmterrfmtr1 r1 r2 fixup_output s
r3 c
C s t tjjdr tjd d S |s(tj}|s2tj}dd }| rtjd|| | j dd\}}|dksn|d krd
}|dkr~d }t
||}n0|d krt j |d
t j
|d} | j}n td| |rtj|j |j || krtjd|| tj|j |j d S |rtjd|| |j dd\}}|dks:|d krXd
}|dkrLd }t
||}n2|d kr~t j |d
t j
|d} | j}n td| |rtj|j |j d S )NZ_CLOUD_INIT_SAVE_STDOUTz5Not redirecting output due to _CLOUD_INIT_SAVE_STDOUTc S s> t jd ytjdj} W n tk
r. Y n X t j| dS )a Reconfigure umask and group ID to create output files securely.
This is passed to subprocess.Popen as preexec_fn, so it is executed in
the context of the newly-created process. It:
* sets the umask of the process so created files aren't world-readable
* if an adm group exists in the system, sets that as the process' GID
(so that the created file(s) are owned by root:adm)
ZadmN)r- umaskgrpgetgrnamgr_gidKeyErrorsetgid)Zgroup_idr1 r1 r2 set_subprocess_umask_and_gid s
z5redirect_output..set_subprocess_umask_and_gidzRedirecting %s to %s r >z>>abwb|T)shellstdinZ
preexec_fnz"Invalid type for output format: %sz!Invalid type for error format: %s)r r- environr rJ ry r r6 r r0 r
subprocessPopenPIPErB r` dup2fileno)
r1 r2 Zo_outZo_errr; r0 argZowithZnew_fpprocr1 r1 r2 r.
s`
r. )sourcesr_ c C sV |rt t| } i }x<| D ]4}|rtj|}|s8tj }tj|}|j||}qW |S )aF Merge multiple dicts according to the dict merger rules.
Dict merger rules can be found in cloud-init documentation. If no mergers
have been specified, entries will be recursively added, but no values
get replaced if they already exist. Functionally, this means that the
highest priority keys must be specified first.
Example:
a = {
"a": 1,
"b": 2,
"c": [1, 2, 3],
"d": {
"a": 1,
"b": 2,
},
}
b = {
"a": 10,
"c": [4],
"d": {
"a": 3,
"f": 10,
},
"e": 20,
}
mergemanydict([a, b]) results in:
{
'a': 1,
'b': 2,
'c': [1, 2, 3],
'd': {
'a': 1,
'b': 2,
'f': 10,
},
'e': 20,
}
)r reversedr Zdict_extract_mergersZdefault_mergersZ constructmerge)rK reverseZ
merged_cfgr/ Zmergers_to_applyZmergerr1 r1 r2
mergemanydictZ s *
rO c c s. t j }zt j| | V W d t j| X d S )N)r- getcwdchdir)ZndirZcurrr1 r1 r2 rQ s
rQ c c s& t j| }z
|V W d t j| X d S )N)r- r5 )Zn_mskoldr1 r1 r2 r5 s
r5 c C s dj | |d|dS )Nz{0:{fill}{align}{size}}^)fillZalignsize)format)r] rT Zmax_lenr1 r1 r2 center s rW c C s t jd| tj| d S )NzRecursively deleting %s)rJ ry shutilZrmtree)rm r1 r1 r2 del_dir s rY r c C sj y.t |||\}}}|| d< || d< || d< dS tjk
rd } z|jtjkrRdS W Y d d }~X nX d S )Nz user-dataz vendor-dataz meta-dataTF) read_seededr UrlErrorcodeZ NOT_FOUND)rT baseexttimeoutmdudvdrz r1 r1 r2 read_optional_seed s rd c C s i }| sddg}n(t jj| jddt jj| jddg}t|}dd |D }d }x2|D ]*}t jjt jj|drZt jj|d}P qZW d }x2|D ]*}t jjt jj|drt jj|d}P qW |r|r||d < ||d
< n |r||d < |S ) Nz/var/lib/cloud/data/sslz /var/lib/cloud/instance/data/sslrA Zsslc S s g | ]}|rt jj|r|qS r1 )r- rm isdir)r? dr1 r1 r2 rB s z%fetch_ssl_details..zcert.pemzkey.pem cert_filekey_file)r- rm rL Z
get_ipath_curZ get_cpathr r )pathsZ ssl_detailsZssl_cert_pathsrg rf rh r1 r1 r2 fetch_ssl_details s0
rj c C s |}t | } y\tjdt| | tj| }|d krBtjd |}n t||sbtd|tj |f |}W n tj
tt fk
r } zd}d }t |drt
|drt
|d}n t |drt
|drt
|d}|r|dj|jd |jd |d 7 }n|d
j|d 7 }tj| W Y d d }~X nX |S ) NzKAttempting to load yaml from string of length %s with allowed root types %sz-loaded blob returned None, returning default.z2Yaml load allows %s root types, but got %s insteadzFailed loading yaml blobZ context_markZ problem_markz5. Invalid format at line {line} column {col}: "{err}"r )rO colrS z. {err})rS )rZ rJ ry rI r loadrU r` r r Z YAMLError
ValueErrorhasattrgetattrrV rO columnrK )rX r ZallowedZloadedZ convertedrz msgZmarkr1 r1 r2 r s<
r
c C sV | j ddkr@| jdd| }| jdd| }| jdd| }nTtjrj| d dkrjtj| jdkrj| d7 } d | d|f }d | d|f }d | d|f }tj|||d
}d } |j rt
t |j i d } tj|||d
}
d } |
j r|
j } d } ytj|||d
}
W n2 tj
k
r. } ztjd | W Y d d }~X n X |
j rB|
j } n
tjd
| | | fS )Nz%sr z user-dataz vendor-dataz meta-datar r* r z%s%s%s)r` retries)r z!Error in vendor-data response: %sz Error in vendor-data responser )r r r Z%NOCLOUD_SEED_URL_APPEND_FORWARD_SLASHr urlparseZqueryr Zread_file_or_urlokr rZ contentsr\ rJ ry )r^ r_ r` rs Z file_retriesZud_urlZvd_urlZmd_urlZmd_respra Zud_resprb rc Zvd_resprz r1 r1 r2 r[
s<
r[ c s t tj dd}dd |D } fdd|D }g }xh|D ]`}y |jttjj ||d W q< tk
r } z |jt krt
j d | W Y dd}~X q.c s& g | ] }t jjt jj |r|qS r1 )r- rm r rL )r? rx )confdr1 r2 rB > s )r z,REDACTED config part %s/%s for non-root userN)
r r- listdirr r rm rL rx r r rJ rK rO )ry r Zconfscfgsr rz r1 )ry r2 read_conf_d5 s
r| c C s t }i }yt| |d}W n8 tk
rR } z |jtkrBtjd| W Y dd}~X n X |j| d}d|kr|d }|rt|t st
d| t j |f qt |j
}n tjj| dr| d}|rtjj|rt||d}|j| t|S )a Read yaml file along with optional ".d" directory, return merged config
Given a yaml file, load the file as a dictionary. Additionally, if there
exists a same-named directory with .d extension, read all files from
that directory in order and return the merged config. The template
file is optional and will be applied to any applicable jinja file
in the configs.
For example, this function can read both /etc/cloud/cloud.cfg and all
files in /etc/cloud/cloud.cfg.d and merge all configs into a single dict.
)r z)REDACTED config part %s for non-root userNr Zconf_dz8Config file %s contains 'conf_d' with non-string type %sz.d)r r rx r r rJ rK r rU rV r` r r r7 r- rm re r|
appendleftrO )Zcfgfiler r{ r/ rz ry Z confd_cfgr1 r1 r2 read_conf_with_confdS s.
r~ c C s t t| dS )N)cmdline)r read_cc_from_cmdline)r r1 r1 r2 read_conf_from_cmdline s r c C s | d krt } d| } d}d}t|}t|}t| }g }| j|}x`|dkr| j||| }|dk rl|}|jtj| || | j jdd | j||| }qHW dj|S )Nr< z cc:Zend_ccr z\nr ) get_cmdlinerI r r r Zunquotelstripr rL ) r Z tag_beginZtag_endZbegin_lZend_lZclentokensZbeginendr1 r1 r2 r s&
r c C s2 | j d}|dks"| |d dkr&| S | jddS )Nr r r
z
)r r )rv posr1 r1 r2 dos2unix s
r HostnameFqdnInfohostnamefqdn
is_defaultc C s d}d| kr,| d }t | d|jdd }nld| krf| d jddkrf| d }| d d|jd }n2|jd|dj}d| kr| d }n|j|d \}}t|||S )
a Get hostname and fqdn from config if present and fallback to cloud.
@param cfg: Dictionary of merged user-data configuration (from init.cfg).
@param cloud: Cloud instance from init.cloudify().
@param metadata_only: Boolean, set True to only query cloud meta-data,
returning None if not present in meta-data.
@return: a namedtuple of
, , (str, str, bool).
Values can be none when
metadata_only is True and no cfg or metadata provides hostname info.
is_default is a bool and
it's true only if hostname is localhost and was
returned by util.get_hostname() as a default.
This is used to differentiate with a user-defined
localhost hostname.
Fr r r( r NT)r
metadata_only)r )r r0 r get_hostnamer r )r/ Zcloudr r r r r1 r1 r2 get_hostname_fqdn s
r
/etc/hostsc C s d}yvxpt |j D ]`}|jd}|dkr6|d| }|j }|sDq|j }t|dk rZq| |dd kr|d }P qW W n tk
r Y nX |S )a
For each host a single line should be present with
the following information:
IP_address canonical_hostname [aliases...]
Fields of the entry are separated by any number of blanks and/or tab
characters. Text from a "#" character until the end of the line is a
comment, and is ignored. Host names may contain only alphanumeric
characters, minus signs ("-"), and periods ("."). They must begin with
an alphabetic character and end with an alphanumeric character.
Optional aliases provide for name changes, alternate spellings, shorter
hostnames, or generic hostnames (for example, localhost).
N#r r r) r )r rF r r7 r0 rI r )r filenamer rO Zhashpostoksr1 r1 r2 get_fqdn_from_hosts s$
r c C s< t j| }|j}tdkrt }d }i }x|D ]}ydtj|dddtjtj}g ||< x>|D ]6\}} }
} } || j d| | d f |j
| d qXW W q, tj tj fk
r Y q,X q,W |a|rt
jd| yNtt tj|jjdrd S W dQ R X tj|d}|d d
d }
|
tkS tj tj fk
r6 d S X dS )
a determine if a url's network address is resolvable, return a boolean
This also attempts to be resilent against dns redirection.
Note, that normal nsswitch resolution is used here. So in order
to avoid any utilization of 'search' entries in /etc/resolv.conf
we have to append '.'.
The top level 'invalid' domain is invalid per RFC. And example.com
should also not exist. The '__cloud_init_expected_not_found__' entry will
be resolved inside the search list.
Ndoes-not-exist.example.com.example.invalid.!__cloud_init_expected_not_found__r z%s: %sz detected dns redirection: %sz[]T F)r r r )r rt r _DNS_REDIRECT_IPsetsocketZ getaddrinfoZ SOCK_STREAMZ AI_CANONNAMEr addZgaierrorerrorrJ ry r rm r Z
is_ip_addressZnetlocr7 )urlZ
parsed_urlr ZbadipsZbadnamesZ
badresultsZinameresultZ_famZ_stypeZ_protoZcnameZsockaddrZaddrr1 r1 r2
is_resolvable s<
r c C s t j } | S )N)r Z gethostname)r r1 r1 r2 r ; s r c C s* yt j| d S t jk
r$ d S X d S )Nr )r
gethostbyaddrZherror)Zipr1 r1 r2 r @ s r c C s t tjd| t| fdS )z5determine if this url is resolvable (existing or ip).zResolving URL: )logfuncrq funcr )log_timerJ ry r )r r1 r1 r2 is_resolvable_urlG s
r c C s\ | dkr dS t jd| x>| D ]6}y t|r.z
/dev/msdosfs/z
/dev/iso9660/z TYPE=vfatz TYPE=iso9660)r
startswithr )criteriaoformattagno_cacherm devlistlabelr1 r1 r2 find_devs_with_freebsdr s
r c C s g }d }d }| r8| j dr$| jd}| j dr8| jd}tjdddgdgd}xx|jj D ]j} |sf|rtjd| gdd gd\}
} |rd
| |
krqZ|d krd |
krqZ|d
krd |
krqZ|jd| qZW |S )NzLABEL=zTYPE=sysctlz-nz hw.disknamesr )rcsZ mscdlabelr z
label "%s"iso9660zISO filesystemvfatz/dev/)r r r r6 r0 r ) r r r r rm r r _typer8 devZ
mscdlabel_outr r1 r1 r2 find_devs_with_netbsd s(
r c C s t j dddgdgd}g }xd|jj jdD ]P}|jds zfd0:r r cdic S s g | ] }d | qS )z/dev/r1 )r? r r1 r1 r2 rB s z*find_devs_with_openbsd..r r )r r6 rstripr0 rw r r )r r r r rm r8 r r r1 r1 r2 find_devs_with_openbsd s
r c C s t j dddgdgd}dd t|jj dd D }| d
krJd d |D }n(| dkrbdd |D }n| rrtjd| dd |D S )Nr z-nz
kern.disksr )r c S s( g | ] }|j d r|j d r|qS )ra Zvn)r )r? r r1 r1 r2 rB s z/find_devs_with_dragonflybsd..T)rN z TYPE=iso9660c S s g | ]}|j dr|qS )r acd)r r )r )r? r r1 r1 r2 rB s LABEL=CONFIG-2 TYPE=vfatc S s g | ]}|j ds|qS )r r )r r )r )r? r r1 r1 r2 rB s zUnexpected criteria: %sc S s g | ] }d | qS )z/dev/r1 )r? r r1 r1 r2 rB s )r r )r r r6 r0 rJ ry )r r r r rm r8 r r1 r1 r2 find_devs_with_dragonflybsd s r c
C sJ t rt| ||||S t r,t| ||||S t rBt| ||||S t rXt| ||||S dg}g }| rt|jd| |r|jd| |r|j ddg |r|jd| |r|j| || }yt
j
|ddgd \}} W n: t
j k
r }
z|
j t
krd
}n W Y d d }
~
X nX g } x*|j D ] } | j } | r$| j| q$W | S ) z
find devices matching given criteria (via blkid)
criteria can be *one* of:
TYPE=
LABEL=