Synnefo » snf-ganeti

    # In Exec(), we warn about mirrored instances that have primary and

    # secondary living in separate node groups. To fully verify that

    # volumes for these instances are healthy, we will need to do an

    # extra call to their secondaries. We ensure here those nodes will

    # be locked.

    for inst in inst_names:

      if all_inst_info[inst].disk_template in constants.DTS_INT_MIRROR:

        node_names.update(all_inst_info[inst].secondary_nodes)

    # We detect here the nodes that will need the extra RPC calls for verifying

    # split LV volumes; they should be locked.

    extra_lv_nodes = set()

    for inst in self.my_inst_info.values():

      if inst.disk_template in constants.DTS_INT_MIRROR:

        group = self.my_node_info[inst.primary_node].group

        for nname in inst.secondary_nodes:

          if self.all_node_info[nname].group != group:

            extra_lv_nodes.add(nname)

    unlocked_lv_nodes = \

        extra_lv_nodes.difference(self.glm.list_owned(locking.LEVEL_NODE))

    if unlocked_lv_nodes:

      raise errors.OpPrereqError("these nodes could be locked: %s" %

                                 utils.CommaJoin(unlocked_lv_nodes))

    self.extra_lv_nodes = list(extra_lv_nodes)

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

    if self.extra_lv_nodes and vg_name is not None:

      extra_lv_nvinfo = \

          self.rpc.call_node_verify(self.extra_lv_nodes,

                                    {constants.NV_LVLIST: vg_name},

                                    self.cfg.GetClusterName())

    else:

      extra_lv_nvinfo = {}

    for node, result in extra_lv_nvinfo.items():

      self._UpdateNodeVolumes(self.all_node_info[node], result.payload,

                              node_image[node], vg_name)

    # We will get spurious "unknown volume" warnings if any node of this group

    # is secondary for an instance whose primary is in another group. To avoid

    # them, we find these instances and add their volumes to node_vol_should.

    for inst in self.all_inst_info.values():

      for secondary in inst.secondary_nodes:

        if (secondary in self.my_node_info

            and inst.name not in self.my_inst_info):

          inst.MapLVsByNode(node_vol_should)

          break