Synnefo » snf-ganeti » ganeti-local

        for use_client in [True, False]:

          rapi_instance = RunTest(qa_rapi.TestRapiInstanceAdd, pnode,

                                  use_client)

          RunCommonInstanceTests(rapi_instance)

          RunTest(qa_rapi.TestRapiInstanceRemove, rapi_instance, use_client)

          del rapi_instance

def TestRapiInstanceAdd(node, use_client):

    memory = utils.ParseUnit(qa_config.get("mem"))

    disk_sizes = [utils.ParseUnit(size) for size in qa_config.get("disk")]

    if use_client:

      disks = [{"size": size} for size in disk_sizes]

      nics = [{}]

      beparams = {

        constants.BE_MEMORY: memory,

        }

      job_id = _rapi_client.CreateInstance(constants.INSTANCE_CREATE,

                                           instance["name"],

                                           constants.DT_PLAIN,

                                           disks, nics,

                                           os=qa_config.get("os"),

                                           pnode=node["primary"],

                                           beparams=beparams)

    else:

      body = {

        "name": instance["name"],

        "os": qa_config.get("os"),

        "disk_template": constants.DT_PLAIN,

        "pnode": node["primary"],

        "memory": memory,

        "disks": disk_sizes,

        }

      (job_id, ) = _DoTests([

        ("/2/instances", _VerifyReturnsJob, "POST", body),

        ])

def TestRapiInstanceRemove(instance, use_client):

  if use_client:

    job_id = _rapi_client.DeleteInstance(instance["name"])

  else:

    (job_id, ) = _DoTests([

      ("/2/instances/%s" % instance["name"], _VerifyReturnsJob, "DELETE", None),

      ])