/usr/lib/python3/dist-packages/cloudinit/sources/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/sources/__pycache__/DataSourceOpenNebula.cpython-310.pyc (12434B)
o
th> @ s
d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m
Z
m Z m Z m
Z
eeZdZdZdgZdZG dd de jZG d d
d
eZG d d d eZG d
d dZdd Zdd Z dd Z d ddZ d ddZ dd Z eZ!ee j"ffgZ#dd Z$dS ) N)
atomic_helpernetsourcessubputilziid-dsopennebulanobody
context.sh)
EPOCHREALTIME EPOCHSECONDSRANDOMLINENOSECONDS_SRANDOM__vc @ sF e Zd ZdZdd Zdd Zdd Zdd Zed
d Z dd
dZ
dS )DataSourceOpenNebula
OpenNebulac C s4 t j| ||| d | _tj|jd| _d | _d S )N
opennebula) r
DataSource__init__seedospathjoinseed_dirnetwork)selfsys_cfgdistropaths r H/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceOpenNebula.pyr / s
z DataSourceOpenNebula.__init__c C s t j| }d|| j| jf S )Nz%s [seed=%s][dsmode=%s])r r __str__r dsmode)r rootr r r! r" 5 s z DataSourceOpenNebula.__str__c
C sl dt i}d }d }t}d| jv r| jd}| jg}|t |D ]Z}z&tj | jr4t
|| j |d}n| drHt
jt
|| j d}t||}W n% tyR Y q! ty_ } z|d }~w tjyn td| Y nw |r{|}td| nq!|sdS |d } t| |g} | |d
| jd g| _| jtjkrdS || _ |d | _ | | _ |d
| _ dS )Nz instance-id parseuserasuserz/dev)r' r z%s was not mountablezfound datasource in %sFmetadataDSMODEr# network-interfacesuserdataT) DEFAULT_IIDDEFAULT_PARSEUSERds_cfggetr extendfind_candidate_devsr r isdirread_context_disk_dirr
startswith functoolspartialr mount_cbNonContextDiskDirBrokenContextDiskDirMountFailedErrorLOGwarningdebug
mergemanydict_determine_dsmoder# r DSMODE_DISABLEDr r r( userdata_raw)
r defaultsresultsr r%
candidatescdevpartially_applied_funcexcmdr r r! _get_data9 sb
z DataSourceOpenNebula._get_datac C s$ | j | jv r d}nd}d|| jf S )z/Return the subplatform metadata source details.zseed-dirz config-diskz%s (%s))r r )r subplatform_typer r r! _get_subplatformv s z%DataSourceOpenNebula._get_subplatformc C s | j d ur| j S d S N)r )r r r r! network_config~ s
z#DataSourceOpenNebula.network_configFc C s. |d u r| j tjkr
d}nd}tj| ||S )NTF)r# r DSMODE_NETWORKr get_hostname)r fqdn
resolve_ip
metadata_onlyr r r! rO s
z!DataSourceOpenNebula.get_hostnameN)FFF) __name__
__module__ __qualname__dsnamer r" rI rK propertyrM rO r r r r! r + s =
r c @ e Zd ZdS )r8 NrS rT rU r r r r! r8 r8 c @ rX )r9 NrY r r r r! r9 rZ r9 c @ sp e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z dd Z dddZ
dd ZdS )OpenNebulaNetworkNc C s| || _ |d u r t|}tdd t| dd dD | _i | _| D ]\}}t d|}|r;|
d| j| < q%d S )Nc S s g | ]}|qS r r .0kr r r!
s z.OpenNebulaNetwork.__init__..c S s t | d S )N )r natural_sort_key)r^ r r r! s z,OpenNebulaNetwork.__init__..)keyz
^(.+)_MAC$r` ) contextget_physical_nics_by_mac collections OrderedDictsorteditemsifacescontext_devnamerematchgrouplower)r rd r system_nics_by_macr^ vmr r r! r s$ zOpenNebulaNetwork.__init__c C s" d dd |ddd D S )N.c S s g | ] }t t|d qS ) )strint)r] cr r r! r_ s z,OpenNebulaNetwork.mac2ip..: )r split)r macr r r! mac2ip s "zOpenNebulaNetwork.mac2ipc C s\ i }| |dd }|| jdd |r ||d< | |dd }|r,||d< |S )Ndns DNS addresses
search_domainsearch) get_fieldrz r0 rd r/ )r dev nameserversr} r r r r! get_nameservers s z!OpenNebulaNetwork.get_nameserversc C | |dS )Nmtur r r r r r! get_mtu zOpenNebulaNetwork.get_mtuc C s | |d| |S )Nip)r r| )r r r{ r r r! get_ip s zOpenNebulaNetwork.get_ipc C s< g }| |d}|r|| | |d}|r || |S )Nip6ip6_ula)r append)r r
addresses6r r r r r! get_ip6 s
zOpenNebulaNetwork.get_ip6c C | |ddS )Nip6_prefix_length64r r r r r! get_ip6_prefix z OpenNebulaNetwork.get_ip6_prefixc C r )Ngatewayr r r r r! get_gateway r z OpenNebulaNetwork.get_gatewayc C s | |d| |dS )N ip6_gatewaygateway6r r r r r! get_gateway6 s z OpenNebulaNetwork.get_gateway6c C r )Nmaskz
255.255.255.0r r r r r! get_mask r zOpenNebulaNetwork.get_maskc C s* | j d||f }|dv r|S |S )zreturn the field name in context for device dev.
context stores _ (example: eth0_DOMAIN).
an empty string for value will return default.r )Nr~ )rd r/ r upper)r r namedefaultvalr r r! r s zOpenNebulaNetwork.get_fieldc s0 i }d|d< i |d< i }| j D ]\}}| }| j||}i }d|i|d< g |d< | |}tt|}|d |
||d | | |} | ra| | |d
fdd | D | |}
|
rl|
|d
< | |} | rw| |d < | |} | r| |d < | |}
|
r|
|d
< |||< q||d< |S )Nry version ethernets
macaddressrm r /c s g | ]}|d qS )r r )r] iprefix6r r! r_ s z.OpenNebulaNetwork.gen_conf..gateway4r r r )rj ri ro rk r/ r ru r ipv4_mask_to_net_prefixr r r r r0 r r r r )r netconfr r{ r c_devdevconfr prefixr r r r r r r r! gen_conf sD
zOpenNebulaNetwork.gen_confrL )rS rT rU r r| r r r r r r r r r r r r r r! r[ s
r[ c C s@ g } dD ]}t |}| |D ] }|| vr | | qq| S )zE
Return a list of devices that may contain the context disk.
)z
LABEL=CONTEXTz LABEL=CDROMz TYPE=iso9660)r find_devs_withsortr )combinedfdevsdr r r! r1 & s
r1 c C s
dd| gS )Nsudoz-ur userr r r! switch_user_cmd5 s
r c C s
t dS )zDprint the shell environment variables within delimiters to be parsedz
printf "%s\0" _start_
[ $0 != 'sh' ] && set -o posix
set
[ $0 != 'sh' ] && set +o posix
printf "%s\0" _start_
)textwrapdedentr r r r!
varprinter9 s r c
C s d| v r td t d| t d }g }|dur!t|}|ddg tj||dj}i }|d d
d }|d |d }}t d
d t
|D } t dd t
|D }
t |
t |
D ]} | tv rpqi|
| } | dur| | | kr| || < qi|S )a< run content and return environment variables which changed
WARNING: the special variable _start_ is used to delimit content
a context.sh that defines this variable might break in unexpected
ways
compatible with posix shells such as dash and ash and any shell
which supports `set -o posix`
s _start_ zYUser defined _start_ variable in context.sh, this may breakcloud-init in unexpected ways.z{
%s
:
} > /dev/null
Nshz-e)dataz_start_ r` r ry c s | ]
}|j d ddV qdS =r` )maxsplitNrz r] variabler r r! }
z%parse_shell_config..c s r r r r r r r! r r )encoder; r< r r r0 r stdoutrz dictshlexsetkeysunion
EXCLUDED_VARSr/ )
contentr' bcmdcmdoutputretsectionsbeforeafterpre_envpost_envrc valuer r r! parse_shell_configF sD
r c
C sJ i }t D ]}tj| |}tj|r|||< q|s"td| df i }di d}d|v r|durNzt| W n tyM } z t dj
|d|d}~ww ztj| d} t | }
t
|
|d}W n* tjyv } zt d | |d}~w ty } ztd
| |d}~ww td |s|S ||d < d} d
|v rd
} nd|v rd} | r|| } dd | D |d d< dD ]}
|
|v r||
|d d< nqd|v r|d |d< n
d|v r|d |d< d|v r|d|d}|dkrz t|d |d< W n ty
td Y nw dd |D }|r#t||}| |d < |S ) z
read_context_disk_dir(source_dir):
read source_dir and return a tuple with metadata dict and user-data
string populated. If not a valid dir, raise a NonContextDiskDir
z%s: %szno files foundN)r+ r( r z'configured user '{user}' does not existr r& z Error processing context.sh: %sz Error reading context.sh: %szMissing context.shr( SSH_KEYSSH_PUBLIC_KEYc S s" g | ]
}t |r|d s|qS )#)lenr4 )r] liner r r! r_ s z)read_context_disk_dir..z public-keys) SET_HOSTNAMEHOSTNAME PUBLIC_IP IP_PUBLICETH0_IPzlocal-hostname USER_DATAr+ USERDATAUSERDATA_ENCODINGUSER_DATA_ENCODINGbase64z"Failed base64 decoding of userdatac S s g | ]
}t d |r|qS )z
^ETH\d+_IP.*$)rl rm r\ r r r! r_ s r* )CONTEXT_DISK_FILESr r r isfiler8 pwdgetpwnamKeyErrorr9 formatr load_text_filer r ProcessExecutionErrorIOErrorr/
splitlinesr b64d TypeErrorr; r< r[ r )
source_dirr r' foundaffnrd rC er r ssh_key_varlinesr^ encoding ipaddr_keysonetr r r! r3 s
r3 c s" t }t fdd| D S )Nc s$ g | ]\}} j |r||fqS r )
networking is_physical)r] rr nr r r! r_ s $ z,get_physical_nics_by_mac..)r get_interfaces_by_macr ri )r r r r r! re s re c C s t | tS rL )r list_from_depends datasources)dependsr r r! get_datasource_list r r rL )%rf r5 loggingr r rl r r cloudinitr r r r r getLoggerrS r; r, r- r r r r Exceptionr8 r9 r[ r1 r r r r3 re DataSourceOpenNebulaNetDEP_FILESYSTEMr
r r r r r! s:
c
G`