Add support for illumos/OmniOS

cloudinit/cmd/main.py

@@ -36,7 +36,8 @@
 from cloudinit import reporting
 from cloudinit.reporting import events
 
-from cloudinit.settings import PER_INSTANCE, PER_ALWAYS, PER_ONCE, CLOUD_CONFIG
+from cloudinit.settings import (PER_INSTANCE, PER_ALWAYS, PER_ONCE,
+                                CLOUD_CONFIG, RUN_CLOUD_CONFIG)
 
 from cloudinit import atomic_helper
 
@@ -417,6 +418,15 @@ def main_init(name, args):
     _maybe_persist_instance_data(init)
     # Stage 6
     iid = init.instancify()
+    if init.is_new_instance():
+        util.multi_log("""
+
+*********************************************************
+* cloud-init is configuring this system, please wait... *
+*********************************************************
+
+""", console=True, stderr=True, log=LOG)
+
     LOG.debug(
         "[%s] %s will now be targeting instance id: %s. new=%s",
         mode,
@@ -686,7 +696,7 @@ def status_wrapper(name, args, data_d=None, link_d=None):
     if data_d is None:
         data_d = os.path.normpath("/var/lib/cloud/data")
     if link_d is None:
-        link_d = os.path.normpath("/run/cloud-init")
+        link_d = os.path.dirname(os.path.normpath(RUN_CLOUD_CONFIG))
 
     status_path = os.path.join(data_d, "status.json")
     status_link = os.path.join(link_d, "status.json")

cloudinit/config/cc_package_update_upgrade_install.py

@@ -56,8 +56,13 @@ def _multi_cfg_bool_get(cfg, *keys):
     return False
 
 
-def _fire_reboot(log, wait_attempts=6, initial_sleep=1, backoff=2):
-    subp.subp(REBOOT_CMD)
+def _fire_reboot(log, cloud, wait_attempts=6, initial_sleep=1, backoff=2):
+    try:
+        cmd = cloud.distro.shutdown_command(mode='reboot', delay='now',
+            message='Rebooting after package installation')
+    except:
+        cmd = REBOOT_CMD
+    subp.subp(cmd)
     start = time.time()
     wait_time = initial_sleep
     for _i in range(0, wait_attempts):
@@ -115,7 +120,7 @@ def handle(_name, cfg, cloud, log, _args):
             )
             # Flush the above warning + anything else out...
             logging.flushLoggers(log)
-            _fire_reboot(log)
+            _fire_reboot(log, cloud)
         except Exception as e:
             util.logexc(log, "Requested reboot did not happen!")
             errors.append(e)

cloudinit/config/cc_resizefs.py

@@ -10,12 +10,14 @@
 
 import errno
 import os
+import re
 import stat
 from textwrap import dedent
 
 from cloudinit import subp, util
 from cloudinit.config.schema import get_meta_doc, validate_cloudconfig_schema
 from cloudinit.settings import PER_ALWAYS
+from cloudinit import temp_utils
 
 NOBLOCK = "noblock"
 
@@ -120,6 +122,15 @@ def _can_skip_resize_ufs(mount_point, devpth):
     return False
 
 
+def _can_skip_resize_zfs(zpool, devpth):
+    try:
+        (out, _err) = subp.subp(['zpool', 'get', '-Hp', '-o', 'value',
+            'expandsz', zpool])
+        return out.strip() == '-'
+    except subp.ProcessExecutionError as e:
+        return False
+
+
 # Do not use a dictionary as these commands should be able to be used
 # for multiple filesystem types if possible, e.g. one command for
 # ext2, ext3 and ext4.
@@ -132,7 +143,10 @@ def _can_skip_resize_ufs(mount_point, devpth):
     ("hammer2", _resize_hammer2),
 ]
 
-RESIZE_FS_PRECHECK_CMDS = {"ufs": _can_skip_resize_ufs}
+RESIZE_FS_PRECHECK_CMDS = {
+    "ufs": _can_skip_resize_ufs,
+    "zfs": _can_skip_resize_zfs,
+}
 
 
 def can_skip_resize(fs_type, resize_what, devpth):
@@ -254,7 +268,12 @@ def handle(name, cfg, _cloud, log, args):
     info = "dev=%s mnt_point=%s path=%s" % (devpth, mount_point, resize_what)
     log.debug("resize_info: %s" % info)
 
-    devpth = maybe_get_writable_device_path(devpth, info, log)
+    if util.is_illumos() and fs_type == 'zfs':
+        # On illumos ZFS, the devices are just bare words like 'c0t0d0'
+        # which can be used directly as arguments for the resize.
+        pass
+    else:
+        devpth = maybe_get_writable_device_path(devpth, info, log)
     if not devpth:
         return  # devpath was not a writable block device
 

cloudinit/config/cc_set_passwords.py

@@ -236,7 +236,7 @@ def rand_user_password(pwlen=20):
 
 
 def chpasswd(distro, plist_in, hashed=False):
-    if util.is_BSD():
+    if util.is_BSD() or util.is_illumos():
         for pentry in plist_in.splitlines():
             u, p = pentry.split(":")
             distro.set_passwd(u, p, hashed=hashed)

cloudinit/distros/__init__.py

@@ -53,6 +53,7 @@
         "virtuozzo",
     ],
     "suse": ["opensuse", "sles"],
+    "illumos": ["omnios"],
 }
 
 LOG = logging.getLogger(__name__)