File Manager

X7ROOT File Manager

Current Path: /usr/lib/python2.7/site-packages/cloudinit/config

usr / lib / python2.7 / site-packages / cloudinit / config /

📁 ..
📄 __init__.py(1.4 KB)
📄 __init__.pyc(1.31 KB)
📄 __init__.pyo(1.31 KB)
📄 cc_apt_configure.py(32.8 KB)
📄 cc_apt_configure.pyc(30.2 KB)
📄 cc_apt_configure.pyo(30.2 KB)
📄 cc_apt_pipelining.py(2.44 KB)
📄 cc_apt_pipelining.pyc(2.48 KB)
📄 cc_apt_pipelining.pyo(2.48 KB)
📄 cc_bootcmd.py(3.5 KB)
📄 cc_bootcmd.pyc(3.02 KB)
📄 cc_bootcmd.pyo(3.02 KB)
📄 cc_byobu.py(3.1 KB)
📄 cc_byobu.pyc(3.09 KB)
📄 cc_byobu.pyo(3.09 KB)
📄 cc_ca_certs.py(4.09 KB)
📄 cc_ca_certs.pyc(4.1 KB)
📄 cc_ca_certs.pyo(4.1 KB)
📄 cc_chef.py(13.17 KB)
📄 cc_chef.pyc(10.79 KB)
📄 cc_chef.pyo(10.79 KB)
📄 cc_debug.py(3.08 KB)
📄 cc_debug.pyc(3.35 KB)
📄 cc_debug.pyo(3.35 KB)
📄 cc_disable_ec2_metadata.py(1.56 KB)
📄 cc_disable_ec2_metadata.pyc(1.57 KB)
📄 cc_disable_ec2_metadata.pyo(1.57 KB)
📄 cc_disk_setup.py(32.8 KB)
📄 cc_disk_setup.pyc(28.91 KB)
📄 cc_disk_setup.pyo(28.91 KB)
📄 cc_emit_upstart.py(2 KB)
📄 cc_emit_upstart.pyc(2.15 KB)
📄 cc_emit_upstart.pyo(2.15 KB)
📄 cc_fan.py(2.83 KB)
📄 cc_fan.pyc(3.09 KB)
📄 cc_fan.pyo(3.09 KB)
📄 cc_final_message.py(2.35 KB)
📄 cc_final_message.pyc(2.39 KB)
📄 cc_final_message.pyo(2.39 KB)
📄 cc_foo.py(2.07 KB)
📄 cc_foo.pyc(702 B)
📄 cc_foo.pyo(702 B)
📄 cc_growpart.py(11.51 KB)
📄 cc_growpart.pyc(11.12 KB)
📄 cc_growpart.pyo(11.12 KB)
📄 cc_grub_dpkg.py(2.87 KB)
📄 cc_grub_dpkg.pyc(2.63 KB)
📄 cc_grub_dpkg.pyo(2.63 KB)
📄 cc_keys_to_console.py(2.36 KB)
📄 cc_keys_to_console.pyc(2.39 KB)
📄 cc_keys_to_console.pyo(2.39 KB)
📄 cc_landscape.py(3.93 KB)
📄 cc_landscape.pyc(4.02 KB)
📄 cc_landscape.pyo(4.02 KB)
📄 cc_locale.py(1.16 KB)
📄 cc_locale.pyc(1.16 KB)
📄 cc_locale.pyo(1.16 KB)
📄 cc_lxd.py(10.27 KB)
📄 cc_lxd.pyc(8.33 KB)
📄 cc_lxd.pyo(8.33 KB)
📄 cc_mcollective.py(5.08 KB)
📄 cc_mcollective.pyc(3.8 KB)
📄 cc_mcollective.pyo(3.8 KB)
📄 cc_migrator.py(3.07 KB)
📄 cc_migrator.pyc(3.18 KB)
📄 cc_migrator.pyo(3.18 KB)
📄 cc_mounts.py(17.24 KB)
📄 cc_mounts.pyc(14.59 KB)
📄 cc_mounts.pyo(14.59 KB)
📄 cc_ntp.py(20.19 KB)
📄 cc_ntp.pyc(15.74 KB)
📄 cc_ntp.pyo(15.74 KB)
📄 cc_package_update_upgrade_install.py(4.11 KB)
📄 cc_package_update_upgrade_install.pyc(4.01 KB)
📄 cc_package_update_upgrade_install.pyo(4.01 KB)
📄 cc_phone_home.py(3.92 KB)
📄 cc_phone_home.pyc(3.28 KB)
📄 cc_phone_home.pyo(3.28 KB)
📄 cc_power_state_change.py(7.65 KB)
📄 cc_power_state_change.pyc(7.8 KB)
📄 cc_power_state_change.pyo(7.8 KB)
📄 cc_puppet.py(8.86 KB)
📄 cc_puppet.pyc(7.06 KB)
📄 cc_puppet.pyo(7.06 KB)
📄 cc_resizefs.py(10.79 KB)
📄 cc_resizefs.pyc(9.15 KB)
📄 cc_resizefs.pyo(9.15 KB)
📄 cc_resolv_conf.py(3.43 KB)
📄 cc_resolv_conf.pyc(3.44 KB)
📄 cc_resolv_conf.pyo(3.44 KB)
📄 cc_rh_subscription.py(15.65 KB)
📄 cc_rh_subscription.pyc(13.5 KB)
📄 cc_rh_subscription.pyo(13.5 KB)
📄 cc_rightscale_userdata.py(3.76 KB)
📄 cc_rightscale_userdata.pyc(2.82 KB)
📄 cc_rightscale_userdata.pyo(2.82 KB)
📄 cc_rsyslog.py(14.1 KB)
📄 cc_rsyslog.pyc(10.56 KB)
📄 cc_rsyslog.pyo(10.56 KB)
📄 cc_runcmd.py(3.11 KB)
📄 cc_runcmd.pyc(2.73 KB)
📄 cc_runcmd.pyo(2.73 KB)
📄 cc_salt_minion.py(4.66 KB)
📄 cc_salt_minion.pyc(3.78 KB)
📄 cc_salt_minion.pyo(3.78 KB)
📄 cc_scripts_per_boot.py(1.2 KB)
📄 cc_scripts_per_boot.pyc(1.2 KB)
📄 cc_scripts_per_boot.pyo(1.2 KB)
📄 cc_scripts_per_instance.py(1.38 KB)
📄 cc_scripts_per_instance.pyc(1.38 KB)
📄 cc_scripts_per_instance.pyo(1.38 KB)
📄 cc_scripts_per_once.py(1.31 KB)
📄 cc_scripts_per_once.pyc(1.31 KB)
📄 cc_scripts_per_once.pyo(1.31 KB)
📄 cc_scripts_user.py(1.42 KB)
📄 cc_scripts_user.pyc(1.38 KB)
📄 cc_scripts_user.pyo(1.38 KB)
📄 cc_scripts_vendor.py(1.38 KB)
📄 cc_scripts_vendor.pyc(1.46 KB)
📄 cc_scripts_vendor.pyo(1.46 KB)
📄 cc_seed_random.py(4.39 KB)
📄 cc_seed_random.pyc(4.53 KB)
📄 cc_seed_random.pyo(4.53 KB)
📄 cc_set_hostname.py(2.95 KB)
📄 cc_set_hostname.pyc(2.72 KB)
📄 cc_set_hostname.pyo(2.72 KB)
📄 cc_set_passwords.py(8.45 KB)
📄 cc_set_passwords.pyc(7.62 KB)
📄 cc_set_passwords.pyo(7.62 KB)
📄 cc_snap.py(8.11 KB)
📄 cc_snap.pyc(7.54 KB)
📄 cc_snap.pyo(7.54 KB)
📄 cc_snap_config.py(5.37 KB)
📄 cc_snap_config.pyc(5.03 KB)
📄 cc_snap_config.pyo(5.03 KB)
📄 cc_snappy.py(9.69 KB)
📄 cc_snappy.pyc(9.27 KB)
📄 cc_snappy.pyo(9.27 KB)
📄 cc_spacewalk.py(2.89 KB)
📄 cc_spacewalk.pyc(2.91 KB)
📄 cc_spacewalk.pyo(2.91 KB)
📄 cc_ssh.py(10.59 KB)
📄 cc_ssh.pyc(9.11 KB)
📄 cc_ssh.pyo(9.11 KB)
📄 cc_ssh_authkey_fingerprints.py(3.43 KB)
📄 cc_ssh_authkey_fingerprints.pyc(3.94 KB)
📄 cc_ssh_authkey_fingerprints.pyo(3.94 KB)
📄 cc_ssh_import_id.py(2.88 KB)
📄 cc_ssh_import_id.pyc(2.72 KB)
📄 cc_ssh_import_id.pyo(2.72 KB)
📄 cc_timezone.py(1.15 KB)
📄 cc_timezone.pyc(1.15 KB)
📄 cc_timezone.pyo(1.15 KB)
📄 cc_ubuntu_advantage.py(6.08 KB)
📄 cc_ubuntu_advantage.pyc(6.12 KB)
📄 cc_ubuntu_advantage.pyo(6.12 KB)
📄 cc_ubuntu_drivers.py(5.66 KB)
📄 cc_ubuntu_drivers.pyc(4.63 KB)
📄 cc_ubuntu_drivers.pyo(4.63 KB)
📄 cc_update_etc_hosts.py(3.33 KB)
📄 cc_update_etc_hosts.pyc(2.99 KB)
📄 cc_update_etc_hosts.pyo(2.99 KB)
📄 cc_update_hostname.py(1.58 KB)
📄 cc_update_hostname.pyc(1.66 KB)
📄 cc_update_hostname.pyo(1.66 KB)
📄 cc_users_groups.py(7.06 KB)
📄 cc_users_groups.pyc(6.76 KB)
📄 cc_users_groups.pyo(6.76 KB)
📄 cc_write_files.py(4.95 KB)
📄 cc_write_files.pyc(5.13 KB)
📄 cc_write_files.pyo(5.13 KB)
📄 cc_yum_add_repo.py(4.27 KB)
📄 cc_yum_add_repo.pyc(3.88 KB)
📄 cc_yum_add_repo.pyo(3.88 KB)
📄 cc_zypper_add_repo.py(7.62 KB)
📄 cc_zypper_add_repo.pyc(7.12 KB)
📄 cc_zypper_add_repo.pyo(7.12 KB)
📄 schema.py(14.06 KB)
📄 schema.pyc(13.83 KB)
📄 schema.pyo(13.83 KB)

Editing: cc_ntp.py

# Copyright (C) 2016 Canonical Ltd.
#
# Author: Ryan Harper <ryan.harper@canonical.com>
#
# This file is part of cloud-init. See LICENSE file for license information.

"""NTP: enable and configure ntp"""

from cloudinit.config.schema import (
    get_schema_doc, validate_cloudconfig_schema)
from cloudinit import log as logging
from cloudinit.settings import PER_INSTANCE
from cloudinit import temp_utils
from cloudinit import templater
from cloudinit import type_utils
from cloudinit import util

import copy
import os
import six
from textwrap import dedent

LOG = logging.getLogger(__name__)

frequency = PER_INSTANCE
NTP_CONF = '/etc/ntp.conf'
NR_POOL_SERVERS = 4
distros = ['centos', 'debian', 'fedora', 'opensuse', 'rhel', 'sles', 'ubuntu']

NTP_CLIENT_CONFIG = {
    'chrony': {
        'check_exe': 'chronyd',
        'confpath': '/etc/chrony.conf',
        'packages': ['chrony'],
        'service_name': 'chrony',
        'template_name': 'chrony.conf.{distro}',
        'template': None,
    },
    'ntp': {
        'check_exe': 'ntpd',
        'confpath': NTP_CONF,
        'packages': ['ntp'],
        'service_name': 'ntp',
        'template_name': 'ntp.conf.{distro}',
        'template': None,
    },
    'ntpdate': {
        'check_exe': 'ntpdate',
        'confpath': NTP_CONF,
        'packages': ['ntpdate'],
        'service_name': 'ntpdate',
        'template_name': 'ntp.conf.{distro}',
        'template': None,
    },
    'systemd-timesyncd': {
        'check_exe': '/lib/systemd/systemd-timesyncd',
        'confpath': '/etc/systemd/timesyncd.conf.d/cloud-init.conf',
        'packages': [],
        'service_name': 'systemd-timesyncd',
        'template_name': 'timesyncd.conf',
        'template': None,
    },
}

# This is Distro-specific configuration overrides of the base config
DISTRO_CLIENT_CONFIG = {
    'debian': {
        'chrony': {
            'confpath': '/etc/chrony/chrony.conf',
        },
    },
    'opensuse': {
        'chrony': {
            'service_name': 'chronyd',
        },
        'ntp': {
            'confpath': '/etc/ntp.conf',
            'service_name': 'ntpd',
        },
        'systemd-timesyncd': {
            'check_exe': '/usr/lib/systemd/systemd-timesyncd',
        },
    },
    'sles': {
        'chrony': {
            'service_name': 'chronyd',
        },
        'ntp': {
            'confpath': '/etc/ntp.conf',
            'service_name': 'ntpd',
        },
        'systemd-timesyncd': {
            'check_exe': '/usr/lib/systemd/systemd-timesyncd',
        },
    },
    'ubuntu': {
        'chrony': {
            'confpath': '/etc/chrony/chrony.conf',
        },
    },
}

# The schema definition for each cloud-config module is a strict contract for
# describing supported configuration parameters for each cloud-config section.
# It allows cloud-config to validate and alert users to invalid or ignored
# configuration options before actually attempting to deploy with said
# configuration.

schema = {
    'id': 'cc_ntp',
    'name': 'NTP',
    'title': 'enable and configure ntp',
    'description': dedent("""\
        Handle ntp configuration. If ntp is not installed on the system and
        ntp configuration is specified, ntp will be installed. If there is a
        default ntp config file in the image or one is present in the
        distro's ntp package, it will be copied to ``/etc/ntp.conf.dist``
        before any changes are made. A list of ntp pools and ntp servers can
        be provided under the ``ntp`` config key. If no ntp ``servers`` or
        ``pools`` are provided, 4 pools will be used in the format
        ``{0-3}.{distro}.pool.ntp.org``."""),
    'distros': distros,
    'examples': [
        dedent("""\
        # Override ntp with chrony configuration on Ubuntu
        ntp:
          enabled: true
          ntp_client: chrony  # Uses cloud-init default chrony configuration
        """),
        dedent("""\
        # Provide a custom ntp client configuration
        ntp:
          enabled: true
          ntp_client: myntpclient
          config:
             confpath: /etc/myntpclient/myntpclient.conf
             check_exe: myntpclientd
             packages:
               - myntpclient
             service_name: myntpclient
             template: |
                 ## template:jinja
                 # My NTP Client config
                 {% if pools -%}# pools{% endif %}
                 {% for pool in pools -%}
                 pool {{pool}} iburst
                 {% endfor %}
                 {%- if servers %}# servers
                 {% endif %}
                 {% for server in servers -%}
                 server {{server}} iburst
                 {% endfor %}
          pools: [0.int.pool.ntp.org, 1.int.pool.ntp.org, ntp.myorg.org]
          servers:
            - ntp.server.local
            - ntp.ubuntu.com
            - 192.168.23.2""")],
    'frequency': PER_INSTANCE,
    'type': 'object',
    'properties': {
        'ntp': {
            'type': ['object', 'null'],
            'properties': {
                'pools': {
                    'type': 'array',
                    'items': {
                        'type': 'string',
                        'format': 'hostname'
                    },
                    'uniqueItems': True,
                    'description': dedent("""\
                        List of ntp pools. If both pools and servers are
                         empty, 4 default pool servers will be provided of
                         the format ``{0-3}.{distro}.pool.ntp.org``.""")
                },
                'servers': {
                    'type': 'array',
                    'items': {
                        'type': 'string',
                        'format': 'hostname'
                    },
                    'uniqueItems': True,
                    'description': dedent("""\
                        List of ntp servers. If both pools and servers are
                         empty, 4 default pool servers will be provided with
                         the format ``{0-3}.{distro}.pool.ntp.org``.""")
                },
                'ntp_client': {
                    'type': 'string',
                    'default': 'auto',
                    'description': dedent("""\
                        Name of an NTP client to use to configure system NTP.
                         When unprovided or 'auto' the default client preferred
                         by the distribution will be used. The following
                         built-in client names can be used to override existing
                         configuration defaults: chrony, ntp, ntpdate,
                         systemd-timesyncd."""),
                },
                'enabled': {
                    'type': 'boolean',
                    'default': True,
                    'description': dedent("""\
                        Attempt to enable ntp clients if set to True.  If set
                         to False, ntp client will not be configured or
                         installed"""),
                },
                'config': {
                    'description': dedent("""\
                        Configuration settings or overrides for the
                         ``ntp_client`` specified."""),
                    'type': ['object'],
                    'properties': {
                        'confpath': {
                            'type': 'string',
                            'description': dedent("""\
                                The path to where the ``ntp_client``
                                 configuration is written."""),
                        },
                        'check_exe': {
                            'type': 'string',
                            'description': dedent("""\
                                The executable name for the ``ntp_client``.
                                 For example, ntp service ``check_exe`` is
                                 'ntpd' because it runs the ntpd binary."""),
                        },
                        'packages': {
                            'type': 'array',
                            'items': {
                                'type': 'string',
                            },
                            'uniqueItems': True,
                            'description': dedent("""\
                                List of packages needed to be installed for the
                                 selected ``ntp_client``."""),
                        },
                        'service_name': {
                            'type': 'string',
                            'description': dedent("""\
                                The systemd or sysvinit service name used to
                                 start and stop the ``ntp_client``
                                 service."""),
                        },
                        'template': {
                            'type': 'string',
                            'description': dedent("""\
                                Inline template allowing users to define their
                                 own ``ntp_client`` configuration template.
                                 The value must start with '## template:jinja'
                                 to enable use of templating support.
                                """),
                        },
                    },
                    # Don't use REQUIRED_NTP_CONFIG_KEYS to allow for override
                    # of builtin client values.
                    'required': [],
                    'minProperties': 1,  # If we have config, define something
                    'additionalProperties': False
                },
            },
            'required': [],
            'additionalProperties': False
        }
    }
}
REQUIRED_NTP_CONFIG_KEYS = frozenset([
    'check_exe', 'confpath', 'packages', 'service_name'])

__doc__ = get_schema_doc(schema)  # Supplement python help()

def distro_ntp_client_configs(distro):
    """Construct a distro-specific ntp client config dictionary by merging
       distro specific changes into base config.

@param distro: String providing the distro class name.
    @returns: Dict of distro configurations for ntp clients.
    """
    dcfg = DISTRO_CLIENT_CONFIG
    cfg = copy.copy(NTP_CLIENT_CONFIG)
    if distro in dcfg:
        cfg = util.mergemanydict([cfg, dcfg[distro]], reverse=True)
    return cfg

def select_ntp_client(ntp_client, distro):
    """Determine which ntp client is to be used, consulting the distro
       for its preference.

@param ntp_client: String name of the ntp client to use.
    @param distro: Distro class instance.
    @returns: Dict of the selected ntp client or {} if none selected.
    """

# construct distro-specific ntp_client_config dict
    distro_cfg = distro_ntp_client_configs(distro.name)

# user specified client, return its config
    if ntp_client and ntp_client != 'auto':
        LOG.debug('Selected NTP client "%s" via user-data configuration',
                  ntp_client)
        return distro_cfg.get(ntp_client, {})

# default to auto if unset in distro
    distro_ntp_client = distro.get_option('ntp_client', 'auto')

clientcfg = {}
    if distro_ntp_client == "auto":
        for client in distro.preferred_ntp_clients:
            cfg = distro_cfg.get(client)
            if util.which(cfg.get('check_exe')):
                LOG.debug('Selected NTP client "%s", already installed',
                          client)
                clientcfg = cfg
                break

if not clientcfg:
            client = distro.preferred_ntp_clients[0]
            LOG.debug(
                'Selected distro preferred NTP client "%s", not yet installed',
                client)
            clientcfg = distro_cfg.get(client)
    else:
        LOG.debug('Selected NTP client "%s" via distro system config',
                  distro_ntp_client)
        clientcfg = distro_cfg.get(distro_ntp_client, {})

return clientcfg

def install_ntp_client(install_func, packages=None, check_exe="ntpd"):
    """Install ntp client package if not already installed.

@param install_func: function.  This parameter is invoked with the contents
    of the packages parameter.
    @param packages: list.  This parameter defaults to ['ntp'].
    @param check_exe: string.  The name of a binary that indicates the package
    the specified package is already installed.
    """
    if util.which(check_exe):
        return
    if packages is None:
        packages = ['ntp']

install_func(packages)

def rename_ntp_conf(confpath=None):
    """Rename any existing ntp client config file

@param confpath: string. Specify a path to an existing ntp client
    configuration file.
    """
    if os.path.exists(confpath):
        util.rename(confpath, confpath + ".dist")

def generate_server_names(distro):
    """Generate a list of server names to populate an ntp client configuration
    file.

@param distro: string.  Specify the distro name
    @returns: list: A list of strings representing ntp servers for this distro.
    """
    names = []
    pool_distro = distro
    # For legal reasons x.pool.sles.ntp.org does not exist,
    # use the opensuse pool
    if distro == 'sles':
        pool_distro = 'opensuse'
    for x in range(0, NR_POOL_SERVERS):
        name = "%d.%s.pool.ntp.org" % (x, pool_distro)
        names.append(name)
    return names

def write_ntp_config_template(distro_name, servers=None, pools=None,
                              path=None, template_fn=None, template=None):
    """Render a ntp client configuration for the specified client.

@param distro_name: string.  The distro class name.
    @param servers: A list of strings specifying ntp servers. Defaults to empty
    list.
    @param pools: A list of strings specifying ntp pools. Defaults to empty
    list.
    @param path: A string to specify where to write the rendered template.
    @param template_fn: A string to specify the template source file.
    @param template: A string specifying the contents of the template. This
    content will be written to a temporary file before being used to render
    the configuration file.

@raises: ValueError when path is None.
    @raises: ValueError when template_fn is None and template is None.
    """
    if not servers:
        servers = []
    if not pools:
        pools = []

if len(servers) == 0 and len(pools) == 0:
        pools = generate_server_names(distro_name)
        LOG.debug(
            'Adding distro default ntp pool servers: %s', ','.join(pools))

if not path:
        raise ValueError('Invalid value for path parameter')

if not template_fn and not template:
        raise ValueError('Not template_fn or template provided')

params = {'servers': servers, 'pools': pools}
    if template:
        tfile = temp_utils.mkstemp(prefix='template_name-', suffix=".tmpl")
        template_fn = tfile[1]  # filepath is second item in tuple
        util.write_file(template_fn, content=template)

templater.render_to_file(template_fn, path, params)
    # clean up temporary template
    if template:
        util.del_file(template_fn)

def reload_ntp(service, systemd=False):
    """Restart or reload an ntp system service.

@param service: A string specifying the name of the service to be affected.
    @param systemd: A boolean indicating if the distro uses systemd, defaults
    to False.
    @returns: A tuple of stdout, stderr results from executing the action.
    """
    if systemd:
        cmd = ['systemctl', 'reload-or-restart', service]
    else:
        cmd = ['service', service, 'restart']
    util.subp(cmd, capture=True)

def supplemental_schema_validation(ntp_config):
    """Validate user-provided ntp:config option values.

This function supplements flexible jsonschema validation with specific
    value checks to aid in triage of invalid user-provided configuration.

@param ntp_config: Dictionary of configuration value under 'ntp'.

@raises: ValueError describing invalid values provided.
    """
    errors = []
    missing = REQUIRED_NTP_CONFIG_KEYS.difference(set(ntp_config.keys()))
    if missing:
        keys = ', '.join(sorted(missing))
        errors.append(
            'Missing required ntp:config keys: {keys}'.format(keys=keys))
    elif not any([ntp_config.get('template'),
                  ntp_config.get('template_name')]):
        errors.append(
            'Either ntp:config:template or ntp:config:template_name values'
            ' are required')
    for key, value in sorted(ntp_config.items()):
        keypath = 'ntp:config:' + key
        if key == 'confpath':
            if not all([value, isinstance(value, six.string_types)]):
                errors.append(
                    'Expected a config file path {keypath}.'
                    ' Found ({value})'.format(keypath=keypath, value=value))
        elif key == 'packages':
            if not isinstance(value, list):
                errors.append(
                    'Expected a list of required package names for {keypath}.'
                    ' Found ({value})'.format(keypath=keypath, value=value))
        elif key in ('template', 'template_name'):
            if value is None:  # Either template or template_name can be none
                continue
            if not isinstance(value, six.string_types):
                errors.append(
                    'Expected a string type for {keypath}.'
                    ' Found ({value})'.format(keypath=keypath, value=value))
        elif not isinstance(value, six.string_types):
            errors.append(
                'Expected a string type for {keypath}.'
                ' Found ({value})'.format(keypath=keypath, value=value))

if errors:
        raise ValueError(r'Invalid ntp configuration:\n{errors}'.format(
            errors='\n'.join(errors)))

def handle(name, cfg, cloud, log, _args):
    """Enable and configure ntp."""
    if 'ntp' not in cfg:
        LOG.debug(
            "Skipping module named %s, not present or disabled by cfg", name)
        return
    ntp_cfg = cfg['ntp']
    if ntp_cfg is None:
        ntp_cfg = {}  # Allow empty config which will install the package

# TODO drop this when validate_cloudconfig_schema is strict=True
    if not isinstance(ntp_cfg, (dict)):
        raise RuntimeError(
            "'ntp' key existed in config, but not a dictionary type,"
            " is a {_type} instead".format(_type=type_utils.obj_name(ntp_cfg)))

validate_cloudconfig_schema(cfg, schema)

# Allow users to explicitly enable/disable
    enabled = ntp_cfg.get('enabled', True)
    if util.is_false(enabled):
        LOG.debug("Skipping module named %s, disabled by cfg", name)
        return

# Select which client is going to be used and get the configuration
    ntp_client_config = select_ntp_client(ntp_cfg.get('ntp_client'),
                                          cloud.distro)

# Allow user ntp config to override distro configurations
    ntp_client_config = util.mergemanydict(
        [ntp_client_config, ntp_cfg.get('config', {})], reverse=True)

supplemental_schema_validation(ntp_client_config)
    rename_ntp_conf(confpath=ntp_client_config.get('confpath'))

template_fn = None
    if not ntp_client_config.get('template'):
        template_name = (
            ntp_client_config.get('template_name').replace('{distro}',
                                                           cloud.distro.name))
        template_fn = cloud.get_template_filename(template_name)
        if not template_fn:
            msg = ('No template found, not rendering %s' %
                   ntp_client_config.get('template_name'))
            raise RuntimeError(msg)

write_ntp_config_template(cloud.distro.name,
                              servers=ntp_cfg.get('servers', []),
                              pools=ntp_cfg.get('pools', []),
                              path=ntp_client_config.get('confpath'),
                              template_fn=template_fn,
                              template=ntp_client_config.get('template'))

install_ntp_client(cloud.distro.install_packages,
                       packages=ntp_client_config['packages'],
                       check_exe=ntp_client_config['check_exe'])
    try:
        reload_ntp(ntp_client_config['service_name'],
                   systemd=cloud.distro.uses_systemd())
    except util.ProcessExecutionError as e:
        LOG.exception("Failed to reload/start ntp service: %s", e)
        raise

# vi: ts=4 expandtab

X7ROOT File Manager

Editing: cc_ntp.py

Upload File

Create Folder