Synnefo » snf-ganeti » ganeti-local

  ECLUSTERDANGLINGNODES = (TNODE, "ECLUSTERDANGLINGNODES")

  ECLUSTERDANGLINGINST = (TNODE, "ECLUSTERDANGLINGINST")

    self.all_node_info = self.cfg.GetAllNodesInfo()

    feedback_fn("* Verifying all nodes belong to an existing group")

    # We do this verification here because, should this bogus circumstance

    # occur, it would never be catched by VerifyGroup, which only acts on

    # nodes/instances reachable from existing node groups.

    dangling_nodes = set(node.name for node in self.all_node_info.values()

                         if node.group not in self.all_group_info)

    dangling_instances = {}

    no_node_instances = []

    for inst in self.all_inst_info.values():

      if inst.primary_node in dangling_nodes:

        dangling_instances.setdefault(inst.primary_node, []).append(inst.name)

      elif inst.primary_node not in self.all_node_info:

        no_node_instances.append(inst.name)

    pretty_dangling = [

        "%s (%s)" %

        (node.name,

         utils.CommaJoin(dangling_instances.get(node.name,

                                                ["no instances"])))

        for node in dangling_nodes]

    self._ErrorIf(bool(dangling_nodes), self.ECLUSTERDANGLINGNODES, None,

                  "the following nodes (and their instances) belong to a non"

                  " existing group: %s", utils.CommaJoin(pretty_dangling))

    self._ErrorIf(bool(no_node_instances), self.ECLUSTERDANGLINGINST, None,

                  "the following instances have a non-existing primary-node:"

                  " %s", utils.CommaJoin(no_node_instances))