1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
#!/usr/bin/env python3
# vi: ts=4 expandtab
#
# Copyright (C) 2021 VMware Inc.
#
# This file is part of cloud-init. See LICENSE file for license information.
from cloudinit import distros, helpers
from cloudinit import log as logging
from cloudinit import net, subp, util
from cloudinit.distros import rhel_util as rhutil
from cloudinit.settings import PER_INSTANCE
LOG = logging.getLogger(__name__)
class Distro(distros.Distro):
systemd_hostname_conf_fn = "/etc/hostname"
network_conf_dir = "/etc/systemd/network/"
systemd_locale_conf_fn = "/etc/locale.conf"
resolve_conf_fn = "/etc/systemd/resolved.conf"
renderer_configs = {
"networkd": {
"resolv_conf_fn": resolve_conf_fn,
"network_conf_dir": network_conf_dir,
}
}
# Should be fqdn if we can use it
prefer_fqdn = True
def __init__(self, name, cfg, paths):
distros.Distro.__init__(self, name, cfg, paths)
# This will be used to restrict certain
# calls from repeatly happening (when they
# should only happen say once per instance...)
self._runner = helpers.Runners(paths)
self.osfamily = "photon"
self.init_cmd = ["systemctl"]
def exec_cmd(self, cmd, capture=True):
LOG.debug("Attempting to run: %s", cmd)
try:
(out, err) = subp.subp(cmd, capture=capture)
if err:
LOG.warning(
"Running %s resulted in stderr output: %s", cmd, err
)
return True, out, err
return False, out, err
except subp.ProcessExecutionError:
util.logexc(LOG, "Command %s failed", cmd)
return True, None, None
def generate_fallback_config(self):
key = "disable_fallback_netcfg"
disable_fallback_netcfg = self._cfg.get(key, True)
LOG.debug("%s value is: %s", key, disable_fallback_netcfg)
if not disable_fallback_netcfg:
return net.generate_fallback_config()
LOG.info(
"Skipping generate_fallback_config. Rely on PhotonOS default "
"network config"
)
return None
def apply_locale(self, locale, out_fn=None):
# This has a dependancy on glibc-i18n, user need to manually install it
# and enable the option in cloud.cfg
if not out_fn:
out_fn = self.systemd_locale_conf_fn
locale_cfg = {
"LANG": locale,
}
rhutil.update_sysconfig_file(out_fn, locale_cfg)
# rhutil will modify /etc/locale.conf
# For locale change to take effect, reboot is needed or we can restart
# systemd-localed. This is equivalent of localectl
cmd = ["systemctl", "restart", "systemd-localed"]
self.exec_cmd(cmd)
def install_packages(self, pkglist):
# self.update_package_sources()
self.package_command("install", pkgs=pkglist)
def _write_hostname(self, hostname, filename):
if filename and filename.endswith("/previous-hostname"):
util.write_file(filename, hostname)
else:
ret, _out, err = self.exec_cmd(
["hostnamectl", "set-hostname", str(hostname)]
)
if ret:
LOG.warning(
(
"Error while setting hostname: %s\nGiven hostname: %s",
err,
hostname,
)
)
def _read_system_hostname(self):
sys_hostname = self._read_hostname(self.systemd_hostname_conf_fn)
return (self.systemd_hostname_conf_fn, sys_hostname)
def _read_hostname(self, filename, default=None):
if filename and filename.endswith("/previous-hostname"):
return util.load_file(filename).strip()
_ret, out, _err = self.exec_cmd(["hostname", "-f"])
return out.strip() if out else default
def _get_localhost_ip(self):
return "127.0.1.1"
def set_timezone(self, tz):
distros.set_etc_timezone(tz=tz, tz_file=self._find_tz_file(tz))
def package_command(self, command, args=None, pkgs=None):
if not pkgs:
pkgs = []
cmd = ["tdnf", "-y"]
if args and isinstance(args, str):
cmd.append(args)
elif args and isinstance(args, list):
cmd.extend(args)
cmd.append(command)
pkglist = util.expand_package_list("%s-%s", pkgs)
cmd.extend(pkglist)
ret, _out, err = self.exec_cmd(cmd)
if ret:
LOG.error("Error while installing packages: %s", err)
def update_package_sources(self):
self._runner.run(
"update-sources",
self.package_command,
["makecache"],
freq=PER_INSTANCE,
)
|
