/snap/core20/2769/usr/lib/python3/dist-packages/cloudinit/config
NameSizeModeActions
schemas/-0755rm
__pycache__/-0755rm
cc_ansible.py79270644editdlrm
cc_apk_configure.py43310644editdlrm
cc_apt_configure.py389930644editdlrm
cc_apt_pipelining.py18900644editdlrm
cc_bootcmd.py17970644editdlrm
cc_byobu.py27910644editdlrm
cc_ca_certs.py88770644editdlrm
cc_chef.py124790644editdlrm
cc_disable_ec2_metadata.py16420644editdlrm
cc_disk_setup.py303160644editdlrm
cc_fan.py19970644editdlrm
cc_final_message.py25710644editdlrm
cc_growpart.py188090644editdlrm
cc_grub_dpkg.py55240644editdlrm
cc_install_hotplug.py32670644editdlrm
cc_keyboard.py15270644editdlrm
cc_keys_to_console.py21380644editdlrm
cc_landscape.py31310644editdlrm
cc_locale.py12210644editdlrm
cc_lxd.py137610644editdlrm
cc_mcollective.py42070644editdlrm
cc_mounts.py185980644editdlrm
cc_ntp.py194260644editdlrm
cc_package_update_upgrade_install.py40880644editdlrm
cc_phone_home.py38390644editdlrm
cc_power_state_change.py62330644editdlrm
cc_puppet.py109760644editdlrm
cc_reset_rmc.py44320644editdlrm
cc_resizefs.py108900644editdlrm
cc_resolv_conf.py32060644editdlrm
cc_rh_subscription.py155770644editdlrm
cc_rsyslog.py118230644editdlrm
cc_runcmd.py16400644editdlrm
cc_salt_minion.py40530644editdlrm
cc_scripts_per_boot.py12980644editdlrm
cc_scripts_per_instance.py12950644editdlrm
cc_scripts_per_once.py12710644editdlrm
cc_scripts_user.py12820644editdlrm
cc_scripts_vendor.py12920644editdlrm
cc_seed_random.py30680644editdlrm
cc_set_hostname.py34810644editdlrm
cc_set_passwords.py95840644editdlrm
cc_snap.py34000644editdlrm
cc_spacewalk.py27080644editdlrm
cc_ssh.py112660644editdlrm
cc_ssh_authkey_fingerprints.py38500644editdlrm
cc_ssh_import_id.py55620644editdlrm
cc_timezone.py11670644editdlrm
cc_ubuntu_autoinstall.py30210644editdlrm
cc_ubuntu_drivers.py41740644editdlrm
cc_ubuntu_pro.py139730644editdlrm
cc_update_etc_hosts.py25220644editdlrm
cc_update_hostname.py22300644editdlrm
cc_users_groups.py29300644editdlrm
cc_wireguard.py68250644editdlrm
cc_write_files.py61400644editdlrm
cc_write_files_deferred.py13080644editdlrm
cc_yum_add_repo.py46410644editdlrm
cc_zypper_add_repo.py50520644editdlrm
modules.py135430644editdlrm
schema.py520780644editdlrm
__init__.py400644editdlrm
Edit: /snap/core20/2769/usr/lib/python3/dist-packages/cloudinit/config/cc_reset_rmc.py (4432B)
# (c) Copyright IBM Corp. 2020 All Rights Reserved # # Author: Aman Kumar Sinha # # This file is part of cloud-init. See LICENSE file for license information. """Reset RMC: Reset rsct node id Reset RMC module is IBM PowerVM Hypervisor specific Reliable Scalable Cluster Technology (RSCT) is a set of software components, that together provide a comprehensive clustering environment (RAS features) for IBM PowerVM based virtual machines. RSCT includes the Resource monitoring and control (RMC) subsystem. RMC is a generalized framework used for managing, monitoring, and manipulating resources. RMC runs as a daemon process on individual machines and needs creation of unique node id and restarts during VM boot. More details refer https://www.ibm.com/support/knowledgecenter/en/SGVKBA_3.2/admin/bl503_ovrv.htm This module handles - creation of the unique RSCT node id to every instance/virtual machine and ensure once set, it isn't changed subsequently by cloud-init. In order to do so, it restarts RSCT service. Prerequisite of using this module is to install RSCT packages. """ import logging import os from cloudinit import subp, util from cloudinit.cloud import Cloud from cloudinit.config import Config from cloudinit.config.schema import MetaSchema from cloudinit.distros import ALL_DISTROS from cloudinit.settings import PER_INSTANCE meta: MetaSchema = { "id": "cc_reset_rmc", "distros": [ALL_DISTROS], "frequency": PER_INSTANCE, "activate_by_schema_keys": [], } # This module is undocumented in our schema docs __doc__ = "" # RMCCTRL is expected to be in system PATH (/opt/rsct/bin) # The symlink for RMCCTRL and RECFGCT are # /usr/sbin/rsct/bin/rmcctrl and # /usr/sbin/rsct/install/bin/recfgct respectively. RSCT_PATH = "/opt/rsct/install/bin" RMCCTRL = "rmcctrl" RECFGCT = "recfgct" LOG = logging.getLogger(__name__) NODE_ID_FILE = "/etc/ct_node_id" def handle(name: str, cfg: Config, cloud: Cloud, args: list) -> None: # Ensuring node id has to be generated only once during first boot if cloud.datasource.platform_type == "none": LOG.debug("Skipping creation of new ct_node_id node") return if not os.path.isdir(RSCT_PATH): LOG.debug("module disabled, RSCT_PATH not present") return orig_path = os.environ.get("PATH") try: add_path(orig_path) reset_rmc() finally: if orig_path: os.environ["PATH"] = orig_path else: del os.environ["PATH"] def reconfigure_rsct_subsystems(): # Reconfigure the RSCT subsystems, which includes removing all RSCT data # under the /var/ct directory, generating a new node ID, and making it # appear as if the RSCT components were just installed try: out = subp.subp([RECFGCT])[0] LOG.debug(out.strip()) return out except subp.ProcessExecutionError: util.logexc(LOG, "Failed to reconfigure the RSCT subsystems.") raise def get_node_id(): try: fp = util.load_text_file(NODE_ID_FILE) node_id = fp.split("\n")[0] return node_id except Exception: util.logexc(LOG, "Failed to get node ID from file %s." % NODE_ID_FILE) raise def add_path(orig_path): # Adding the RSCT_PATH to env standard path # So thet cloud init automatically find and # run RECFGCT to create new node_id. suff = ":" + orig_path if orig_path else "" os.environ["PATH"] = RSCT_PATH + suff return os.environ["PATH"] def rmcctrl(): # Stop the RMC subsystem and all resource managers so that we can make # some changes to it try: return subp.subp([RMCCTRL, "-z"]) except Exception: util.logexc(LOG, "Failed to stop the RMC subsystem.") raise def reset_rmc(): LOG.debug("Attempting to reset RMC.") node_id_before = get_node_id() LOG.debug("Node ID at beginning of module: %s", node_id_before) # Stop the RMC subsystem and all resource managers so that we can make # some changes to it rmcctrl() reconfigure_rsct_subsystems() node_id_after = get_node_id() LOG.debug("Node ID at end of module: %s", node_id_after) # Check if new node ID is generated or not # by comparing old and new node ID if node_id_after == node_id_before: msg = "New node ID did not get generated." LOG.error(msg) raise RuntimeError(msg)