diff options
Diffstat (limited to 'cloudinit')
| -rw-r--r-- | cloudinit/distros/__init__.py | 5 | ||||
| -rw-r--r-- | cloudinit/sources/DataSourceConfigDrive.py | 49 | 
2 files changed, 40 insertions, 14 deletions
| diff --git a/cloudinit/distros/__init__.py b/cloudinit/distros/__init__.py index 74e95797..49b129ae 100644 --- a/cloudinit/distros/__init__.py +++ b/cloudinit/distros/__init__.py @@ -52,6 +52,7 @@ class Distro(object):      ci_sudoers_fn = "/etc/sudoers.d/90-cloud-init-users"      hostname_conf_fn = "/etc/hostname"      tz_zone_dir = "/usr/share/zoneinfo" +    random_seed_fn = "/var/lib/random-seed"      def __init__(self, name, cfg, paths):          self._paths = paths @@ -169,6 +170,10 @@ class Distro(object):              distros.extend(OSFAMILIES[family])          return distros +    def set_random_seed(self, seed): +        if self.random_seed_fn: +            util.write_file(self.random_seed_fn, seed, mode=0600) +      def update_hostname(self, hostname, fqdn, prev_hostname_fn):          applying_hostname = hostname diff --git a/cloudinit/sources/DataSourceConfigDrive.py b/cloudinit/sources/DataSourceConfigDrive.py index 835f2a9a..23f791aa 100644 --- a/cloudinit/sources/DataSourceConfigDrive.py +++ b/cloudinit/sources/DataSourceConfigDrive.py @@ -18,6 +18,7 @@  #    You should have received a copy of the GNU General Public License  #    along with this program.  If not, see <http://www.gnu.org/licenses/>. +import base64  import json  import os @@ -41,6 +42,30 @@ DEFAULT_METADATA = {  VALID_DSMODES = ("local", "net", "pass", "disabled") +class ConfigDriveHelper(object): +    def __init__(self, distro): +        self.distro = distro + +    def on_first_boot(self, data): +        if 'network_config' in data: +            LOG.debug("Updating network interfaces from config drive") +            self.distro.apply_network(data['network_config']) +        files = data.get('files') +        if files: +            LOG.debug("Writing %s injected files", len(files)) +            try: +                write_files(files) +            except IOError: +                util.logexc(LOG, "Failed writing files") +        random_seed = util.get_cfg_by_path(data, ('metadata', 'random_seed')) +        if random_seed is not None: +            LOG.debug("Writing random seed") +            try: +                self.distro.set_random_seed(random_seed) +            except IOError: +                util.logexc(LOG, "Failed writing random seed") + +  class DataSourceConfigDrive(sources.DataSource):      def __init__(self, sys_cfg, distro, paths):          sources.DataSource.__init__(self, sys_cfg, distro, paths) @@ -49,6 +74,7 @@ class DataSourceConfigDrive(sources.DataSource):          self.seed_dir = os.path.join(paths.seed_dir, 'config_drive')          self.version = None          self.ec2_metadata = None +        self.helper = ConfigDriveHelper(distro)      def __str__(self):          root = sources.DataSource.__str__(self) @@ -187,20 +213,8 @@ class DataSourceConfigDrive(sources.DataSource):          # instance-id          prev_iid = get_previous_iid(self.paths)          cur_iid = md['instance-id'] - -        if ('network_config' in results and self.dsmode == "local" and -            prev_iid != cur_iid): -            LOG.debug("Updating network interfaces from config drive (%s)", -                      dsmode) -            self.distro.apply_network(results['network_config']) - -        # file writing occurs in local mode (to be as early as possible) -        if self.dsmode == "local" and prev_iid != cur_iid and results['files']: -            LOG.debug("writing injected files") -            try: -                write_files(results['files']) -            except: -                util.logexc(LOG, "Failed writing files") +        if prev_iid != cur_iid and self.dsmode == "local": +            self.helper.on_first_boot(results)          # dsmode != self.dsmode here if:          #  * dsmode = "pass",  pass means it should only copy files and then @@ -338,6 +352,13 @@ def read_config_drive_dir_v2(source_dir, version="2012-08-10"):          except KeyError:              raise BrokenConfigDriveDir("No uuid entry in metadata") +    if 'random_seed' in results['metadata']: +        random_seed = results['metadata']['random_seed'] +        try: +            results['metadata']['random_seed'] = base64.b64decode(random_seed) +        except (ValueError, TypeError) as exc: +            raise BrokenConfigDriveDir("Badly formatted random_seed: %s" % exc) +      def read_content_path(item):          # do not use os.path.join here, as content_path starts with /          cpath = os.path.sep.join((source_dir, "openstack", | 
