Synnefo » snf-ganeti

  def _CheckIpolicy(self, cluster):

    """Checks the ipolicy.

    @type cluster: C{objects.Cluster}

    @param cluster: the cluster's configuration

    """

    if self.op.ipolicy:

      self.new_ipolicy = GetUpdatedIPolicy(cluster.ipolicy, self.op.ipolicy,

                                           group_policy=False)

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

      violations = set()

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

        instances = frozenset([inst for inst in all_instances

                               if compat.any(nuuid in group.members

                                             for nuuid in inst.all_nodes)])

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

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

        new = ComputeNewInstanceViolations(ipol, new_ipolicy, instances,

                                           self.cfg)

        if new:

          violations.update(new)

      if violations:

        self.LogWarning("After the ipolicy change the following instances"

                        " violate them: %s",

                        utils.CommaJoin(utils.NiceSort(violations)))

    self._CheckIpolicy(cluster)