Synnefo » snf-ganeti » ganeti-local

    assert self.__class__._instance is None, "Attempt to modify Ganeti Context"

    object.__setattr__(self, name, value)

    """Adds a node to the configuration and lock manager.

    """

    # Add it to the configuration

    # If preseeding fails it'll not be added

    self.jobqueue.AddNode(node)

                          " candidate status: %s" % msg)

    else:

      _RedistributeAncillaryFiles(self, additional_nodes=[node])

class LUSetNodeParams(LogicalUnit):

    feedback_fn("adding instance %s to cluster config" % instance)

    # Declare that we don't want to remove the instance lock anymore, as we've

    # added the instance to the config

    del self.remove_locks[locking.LEVEL_INSTANCE]

    return self._config_data.cluster.rsahostkeypub

  @locking.ssynchronized(_config_lock)

    """Add an instance to the config.

    This should be used after creating a new instance.

                                        " MAC address '%s' already in use." %

                                        (instance.name, nic.mac))

    instance.serial_no = 1

    instance.ctime = instance.mtime = time.time()

      self._temporary_macs.discard(nic.mac)

    self._WriteConfig()

    """Ensures a given object has a valid UUID.

    @param item: the instance or node to be checked

    """

    if not item.uuid:

    return my_dict

  @locking.ssynchronized(_config_lock)

    """Add a node to the configuration.

    @type node: L{objects.Node}

    """

    logging.info("Adding node %s to configuration", node.name)

    node.serial_no = 1

    node.ctime = node.mtime = time.time()

    self.failUnlessRaises(errors.ConfigurationError, cfg.Update, fake_instance,

                          None)

    instance = cfg.GetInstanceInfo(cfg.GetInstanceList()[0])

    # first pass, must not fail

    cfg.Update(instance, None)