Synnefo » snf-ganeti » ganeti-local

    # future we might want to have different behaviors depending on the value

    # of self.recalculate_locks[locking.LEVEL_NODE]

    wanted_nodes = []

      wanted_nodes.append(instance.primary_node)

      if not primary_only:

        wanted_nodes.extend(instance.secondary_nodes)

                                 errors.ECODE_STATE)

    # Get instance information

    # Check if node groups for locked instances are still correct

    for (instance_name, inst) in self.instances.items():

    if self.wanted_names is None:

      self.wanted_names = self.glm.list_owned(locking.LEVEL_INSTANCE)

  def _EnsureChildSizes(self, disk):

    """Ensure children of the disk have the needed disk size.

    node = self.cfg.GetNodeInfo(self.op.node_name)

    assert node is not None

    masternode = self.cfg.GetMasterNode()

    if node.name == masternode:

      raise errors.OpPrereqError("Node is the master node, failover to another"

                                 " node is required", errors.ECODE_INVAL)

      if node.name in instance.all_nodes:

        raise errors.OpPrereqError("Instance %s is still running on the node,"

                                   " please remove first" % instance_name,

        instances_keep = []

        # Build list of instances to release

          if (instance.disk_template in constants.DTS_INT_MIRROR and

              self.op.node_name in instance.all_nodes):

            instances_keep.append(instance_name)

      assert self.op.use_locking, "Locking was not used"

      self.wanted_names = self.glm.list_owned(locking.LEVEL_INSTANCE)

  def _ComputeBlockdevStatus(self, node, instance_name, dev):

    """Returns the status of a block device

                                 errors.ECODE_STATE)

    # Get instance information

    # Check if node groups for locked instances are still correct

    for instance_name in owned_instances: