Synnefo » snf-ganeti

  """

  cmd = utils.ShellQuoteArgs(["cat", filename])

  for node in qa_config.get("nodes"):

# "gnt-cluster info" fields

  """

  master = qa_config.GetMasterNode()

  infocmd = "gnt-cluster info"

  ret = None

  for l in info_out.splitlines():

    m = _CIFIELD_RE.match(l)

  cvcmd = "gnt-cluster verify"

  mnode = qa_config.GetMasterNode()

  if errors:

                             fail=True)

    actual = _GetCVErrorCodes(cvout)

    expected = compat.UniqueFrozenset(e for (_, e, _) in errors)

    fh.write("%s %s write\n" % (rapi_user, rapi_secret))

    fh.flush()

    try:

      AssertCommand(["mkdir", "-p", rapi_dir])

      AssertCommand(["mv", tmpru, pathutils.RAPI_USERS_FILE])

      if spec:

        cmd.append("--specs-%s=%s=%d" % (spec_type, spec_val, spec))

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

  if vgname:

  master = qa_config.GetMasterNode()

  # Assert that OOB is unavailable for all nodes

                                   "gnt-node list --verbose --no-headers -o"

                                   " powered")

  AssertEqual(compat.all(powered == "(unavail)"

  AssertCommand(["gnt-cluster", "epo", "--all", "some_arg"], fail=True)

  # Unless --all is given master is not allowed to be in the list

  # This shouldn't fail

  AssertCommand(["gnt-cluster", "epo", "-f", "--all"])

  # All instances should have been stopped now

                                   "gnt-instance list --no-headers -o status")

  # ERROR_down because the instance is stopped but not recorded as such

  AssertEqual(compat.all(status == "ERROR_down"

  AssertCommand(["gnt-cluster", "epo", "--on", "-f", "--all"])

  # All instances should have been started now

                                   "gnt-instance list --no-headers -o status")

  AssertEqual(compat.all(status == "running"

                         for status in result_output.splitlines()), True)

  AssertCommand(["gnt-debug", "delay", "1"])

  AssertCommand(["gnt-debug", "delay", "--no-master", "1"])

  AssertCommand(["gnt-debug", "delay", "--no-master",

def TestClusterReservedLvs():

         "--rapi-certificate=/dev/null"]

  AssertCommand(cmd, fail=True)

                                         pathutils.RAPI_CERT_FILE)

  try:

    # Custom RAPI certificate

    utils.GenerateSelfSignedSslCert(fh.name, validity=validity)

    try:

      AssertCommand(["gnt-cluster", "renew-crypto", "--force",

                     "--rapi-certificate=%s" % tmpcert])

    cds_fh.write("\n")

    cds_fh.flush()

    try:

      AssertCommand(["gnt-cluster", "renew-crypto", "--force",

                     "--cluster-domain-secret=%s" % tmpcds])

    if len(instances) < 1:

      raise qa_error.Error("Burnin needs at least one instance")

    try:

      # Run burnin

      cmd = [script,

  f.seek(0)

  # Upload file to master node

  try:

    # Copy file to all nodes

    AssertCommand(["gnt-cluster", "copyfile", testname])

  """cluster-verify reports exclusive_storage set only on one node.

  """

  es_val = _GetBoolClusterField("exclusive_storage")

  assert not es_val

  AssertCommand(_BuildSetESCmd(True, node_name))

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

  lvname1 = _QA_LV_PREFIX + "vol1"

  lvname2 = _QA_LV_PREFIX + "vol2"

  AssertCommand(["lvcreate", "-L1G", "-n", lvname1, vgname], node=node_name)

  AssertClusterVerify(fail=True, errors=[constants.CV_ENODEORPHANLV])

  AssertCommand(["lvcreate", "-L1G", "-n", lvname2, vgname], node=node_name)