Synnefo » snf-ganeti

      all_instances = self.cfg.GetAllInstancesInfo().values()

      violations = set()

      for group in self.cfg.GetAllNodeGroupsInfo().values():

        new_ipolicy = objects.FillIPolicy(self.new_ipolicy, group.ipolicy)

        ipol = masterd.instance.CalculateGroupIPolicy(cluster, group)

        new = ComputeNewInstanceViolations(ipol, new_ipolicy, instances,

    for inst in self.my_inst_info.values():

      if inst.disk_template in constants.DTS_INT_MIRROR:

          if self.all_node_info[nuuid].group != self.group_uuid:

            extra_lv_nodes.add(nuuid)

                  utils.CommaJoin(secondary_nodes),

                  code=self.ETYPE_WARNING)

    if any(es_flags.values()):

      if instance.disk_template not in constants.DTS_EXCL_STORAGE:

        # Disk template not compatible with exclusive_storage: no instance

                      " gnt-cluster repair-disk-sizes", idx)

    if instance.disk_template in constants.DTS_INT_MIRROR:

      instance_groups = {}

      for node_uuid in instance_nodes:

                  instance.name, "instance has offline secondary node(s) %s",

                  utils.CommaJoin(self.cfg.GetNodeNames(inst_nodes_offline)))

    # ... or ghost/non-vm_capable nodes

      self._ErrorIf(node_image[node_uuid].ghost, constants.CV_EINSTANCEBADNODE,

                    instance.name, "instance lives on ghost node %s",

                    self.cfg.GetNodeName(node_uuid))

      instdisk[inst_uuid] = {}

    assert compat.all(len(statuses) == len(instanceinfo[inst].disks) and

                      compat.all(isinstance(s, (tuple, list)) and

                                 len(s) == 2 for s in statuses)

                      for inst, nuuids in instdisk.items()

      if instance.admin_state == constants.ADMINST_OFFLINE:

        i_offline += 1

        if nuuid not in node_image:

          gnode = self.NodeImage(uuid=nuuid)

          gnode.ghost = (nuuid not in self.all_node_info)