Synnefo » snf-ganeti

- The ``/2/nodes/[node_name]/evacuate`` RAPI resource was changed to use

  body parameters, see :doc:`RAPI documentation <rapi>`. The server does

  not maintain backwards-compatibility as the underlying operation

  changed in an incompatible way. The RAPI client can talk to old

  servers, but it needs to be told so as the return value changed.

Evacuates instances off a node.

Returns a job ID. The result of the job will contain the IDs of the

individual jobs submitted to evacuate the node.

Body parameters:

.. opcode_params:: OP_NODE_EVACUATE

   :exclude: nodes

Up to and including Ganeti 2.4 query arguments were used. Those are no

longer supported. The new request can be detected by the presence of the

:pyeval:`rlib2._NODE_EVAC_RES1` feature string.

_NODE_EVAC_RES1 = "node-evac-res1"

                   dry_run=False, early_release=None,

                   primary=None, secondary=None, accept_old=False):

    @type primary: bool

    @param primary: Whether to evacuate primary instances

    @type secondary: bool

    @param secondary: Whether to evacuate secondary instances

    @type accept_old: bool

    @param accept_old: Whether caller is ready to accept old-style (pre-2.5)

        results

    @rtype: string, or a list for pre-2.5 results

    @return: Job ID or, if C{accept_old} is set and server is pre-2.5,

      list of (job ID, instance name, new secondary node); if dry_run was

      specified, then the actual move jobs were not submitted and the job IDs

      will be C{None}

    if _NODE_EVAC_RES1 in self.GetFeatures():

      body = {}

      if iallocator is not None:

        body["iallocator"] = iallocator

      if remote_node is not None:

        body["remote_node"] = remote_node

      if early_release is not None:

        body["early_release"] = early_release

      if primary is not None:

        body["primary"] = primary

      if secondary is not None:

        body["secondary"] = secondary

    else:

      # Pre-2.5 request format

      body = None

      if not accept_old:

        raise GanetiApiError("Server is version 2.4 or earlier and caller does"

                             " not accept old-style results (parameter"

                             " accept_old)")

      if primary or primary is None or not (secondary is None or secondary):

        raise GanetiApiError("Server can only evacuate secondary instances")

      if iallocator:

        query.append(("iallocator", iallocator))

      if remote_node:

        query.append(("remote_node", remote_node))

      if early_release:

        query.append(("early_release", 1))

                              (GANETI_RAPI_VERSION, node)), query, body)

# Feature string for node evacuation with LU-generated jobs

_NODE_EVAC_RES1 = "node-evac-res1"

    return [_INST_CREATE_REQV1, _INST_REINSTALL_REQV1, _NODE_MIGRATE_REQV1,

            _NODE_EVAC_RES1]

    """Evacuate all instances off a node.

    op = baserlib.FillOpcode(opcodes.OpNodeEvacuate, self.request_body, {

      "node_name": self.items[0],

      "dry_run": self.dryRun(),

      })

    return baserlib.SubmitJob([op])

    self.assertEqual(client._NODE_EVAC_RES1, rlib2._NODE_EVAC_RES1)

    self.rapi.AddResponse(serializer.DumpJson([rlib2._NODE_EVAC_RES1]))

    self.assertEqual(serializer.LoadJson(self.rapi.GetLastRequestData()),

                     { "remote_node": "node-2", })

    self.assertEqual(self.rapi.CountPending(), 0)

    self.rapi.AddResponse(serializer.DumpJson([rlib2._NODE_EVAC_RES1]))

    self.assertEqual(serializer.LoadJson(self.rapi.GetLastRequestData()),

                     { "iallocator": "hail", })

    self.assertEqual(self.rapi.CountPending(), 0)

  def testEvacuateNodeOldResponse(self):

    self.rapi.AddResponse(serializer.DumpJson([]))

    self.assertRaises(client.GanetiApiError, self.client.EvacuateNode,

                      "node-4", accept_old=False)

    self.assertEqual(self.rapi.CountPending(), 0)

    self.rapi.AddResponse(serializer.DumpJson([]))

    self.assertRaises(client.GanetiApiError, self.client.EvacuateNode,

                      "node-4", accept_old=True)

    self.assertEqual(self.rapi.CountPending(), 0)

    self.rapi.AddResponse(serializer.DumpJson([]))

    self.assertRaises(client.GanetiApiError, self.client.EvacuateNode,

                      "node-4", accept_old=True, primary=True)

    self.assertEqual(self.rapi.CountPending(), 0)

    self.rapi.AddResponse(serializer.DumpJson([]))

    self.assertRaises(client.GanetiApiError, self.client.EvacuateNode,

                      "node-4", accept_old=True, secondary=False)

    self.assertEqual(self.rapi.CountPending(), 0)

    for sec in [True, None]:

      self.rapi.AddResponse(serializer.DumpJson([]))

      self.rapi.AddResponse(serializer.DumpJson([["res", "foo"]]))

      result = self.client.EvacuateNode("node-3", iallocator="hail",

                                        dry_run=True, accept_old=True,

                                        primary=False, secondary=sec)

      self.assertEqual(result, [["res", "foo"]])

      self.assertItems(["node-3"])

      self.assertQuery("iallocator", ["hail"])

      self.assertFalse(self.rapi.GetLastRequestData())

      self.assertDryRun()

      self.assertEqual(self.rapi.CountPending(), 0)