Synnefo » snf-ganeti

def IsExclusiveStorageInstanceTestEnabled():

  test_name = "exclusive-storage-instance-tests"

  if qa_config.TestEnabled(test_name):

    vgname = qa_config.get("vg-name", constants.DEFAULT_VG)

    vgscmd = utils.ShellQuoteArgs([

      "vgs", "--noheadings", "-o", "pv_count", vgname,

      ])

    nodes = qa_config.GetConfig()["nodes"]

    for node in nodes:

      try:

        pvnum = int(qa_utils.GetCommandOutput(node.primary, vgscmd))

      except Exception, e:

        msg = ("Cannot get the number of PVs on %s, needed by '%s': %s" %

               (node.primary, test_name, e))

        raise qa_error.Error(msg)

      if pvnum < 2:

        raise qa_error.Error("Node %s has not enough PVs (%s) to run '%s'" %

                             (node.primary, pvnum, test_name))

    res = True

  else:

    res = False

  return res

    (IsExclusiveStorageInstanceTestEnabled,