Synnefo » snf-ganeti » ganeti-local

  """

  results = []

  for val in exts:

    results.append("%s%s" % (new_id, val))

  return results

_config_lock = locking.SharedLock()

def _ValidateConfig(data):

  """Verifies that a configuration objects looks valid.

      self._cfg_file = constants.CLUSTER_CONF_FILE

    else:

      self._cfg_file = cfg_file

    self._temporary_drbds = {}

    self._temporary_macs = set()

    # Note: in order to prevent errors when resolving our name in

    """

    existing = set()

    if include_temporary:

    existing.update(self._AllLVs())

    existing.update(self._config_data.instances.keys())

    existing.update(self._config_data.nodes.keys())

    existing.update([i.uuid for i in self._AllUUIDObjects() if i.uuid])

    return existing

    """Generate an unique UUID.

    This checks the current node, instances and disk names for

    @return: the unique id

    """

  @locking.ssynchronized(_config_lock, shared=1)

    """Generate an unique ID.

    This is just a wrapper over the unlocked version.

    """

  def _AllMACs(self):

    """Return all MACs present in the config.

    """

    if not item.uuid:

    elif item.uuid in self._AllIDs(temporary=True):

      raise errors.ConfigurationError("Cannot add '%s': UUID already in use" %

                                      (item.name, item.uuid))

    modified = False

    for item in self._AllUUIDObjects():

      if item.uuid is None:

        modified = True

    if modified:

      self._WriteConfig()

  def _DistributeConfig(self, feedback_fn):

    """Distribute the configuration to the other nodes.

    """

    assert feedback_fn is None or callable(feedback_fn)

    # Warn on config errors, but don't abort the save - the

    # configuration has already been modified, and we can't revert;

    # the best we can do is to warn the user and save as is, leaving

    """Drop per-execution-context reservations

    """