QA: Add tests for instance start/stop via RAPI

[ganeti-local] / test / ganeti.objects_unittest.py

diff --git a/test/ganeti.objects_unittest.py b/test/ganeti.objects_unittest.py
index 6b5cfe7..996a50d 100755 (executable)
--- a/test/ganeti.objects_unittest.py
+++ b/test/ganeti.objects_unittest.py
@@ -1,7 +1,7 @@
 #!/usr/bin/python
 #
 
-# Copyright (C) 2006, 2007, 2008 Google Inc.
+# Copyright (C) 2006, 2007, 2008, 2010 Google Inc.
 #
 # This program is free software; you can redistribute it and/or modify
 # it under the terms of the GNU General Public License as published by
@@ -26,6 +26,7 @@ import unittest
 
 from ganeti import constants
 from ganeti import objects
+from ganeti import errors
 
 import testutils
 
@@ -76,7 +77,12 @@ class TestClusterObject(unittest.TestCase):
       "ubuntu-hardy": {
         },
       }
-    self.fake_cl = objects.Cluster(hvparams=hvparams, os_hvp=os_hvp)
+    ndparams = {
+        constants.ND_OOB_PROGRAM: "/bin/cluster-oob"
+        }
+
+    self.fake_cl = objects.Cluster(hvparams=hvparams, os_hvp=os_hvp,
+                                   ndparams=ndparams)
     self.fake_cl.UpgradeConfig()
 
   def testGetHVDefaults(self):
@@ -141,6 +147,141 @@ class TestClusterObject(unittest.TestCase):
     self.assertEqual(self.fake_cl.os_hvp[os][constants.HT_XEN_PVM],
                      self.fake_cl.FillHV(fake_inst))
 
+  def testFillNdParamsCluster(self):
+    fake_node = objects.Node(name="test",
+                             ndparams={},
+                             group="testgroup")
+    fake_group = objects.NodeGroup(name="testgroup",
+                                   ndparams={})
+    self.assertEqual(self.fake_cl.ndparams,
+                     self.fake_cl.FillND(fake_node, fake_group))
+
+  def testFillNdParamsNodeGroup(self):
+    fake_node = objects.Node(name="test",
+                             ndparams={},
+                             group="testgroup")
+    group_ndparams = {
+        constants.ND_OOB_PROGRAM: "/bin/group-oob"
+        }
+    fake_group = objects.NodeGroup(name="testgroup",
+                                   ndparams=group_ndparams)
+    self.assertEqual(group_ndparams,
+                     self.fake_cl.FillND(fake_node, fake_group))
+
+  def testFillNdParamsNode(self):
+    node_ndparams = {
+        constants.ND_OOB_PROGRAM: "/bin/node-oob"
+        }
+    fake_node = objects.Node(name="test",
+                             ndparams=node_ndparams,
+                             group="testgroup")
+    fake_group = objects.NodeGroup(name="testgroup",
+                                   ndparams={})
+    self.assertEqual(node_ndparams,
+                     self.fake_cl.FillND(fake_node, fake_group))
+
+  def testFillNdParamsAll(self):
+    node_ndparams = {
+        constants.ND_OOB_PROGRAM: "/bin/node-oob"
+        }
+    fake_node = objects.Node(name="test",
+                             ndparams=node_ndparams,
+                             group="testgroup")
+    group_ndparams = {
+        constants.ND_OOB_PROGRAM: "/bin/group-oob"
+        }
+    fake_group = objects.NodeGroup(name="testgroup",
+                                   ndparams=group_ndparams)
+    self.assertEqual(node_ndparams,
+                     self.fake_cl.FillND(fake_node, fake_group))
+
+
+class TestOS(unittest.TestCase):
+  ALL_DATA = [
+    "debootstrap",
+    "debootstrap+default",
+    "debootstrap++default",
+    ]
+
+  def testSplitNameVariant(self):
+    for name in self.ALL_DATA:
+      self.assertEqual(len(objects.OS.SplitNameVariant(name)), 2)
+
+  def testVariant(self):
+    self.assertEqual(objects.OS.GetVariant("debootstrap"), "")
+    self.assertEqual(objects.OS.GetVariant("debootstrap+default"), "default")
+
+
+class TestInstance(unittest.TestCase):
+  def _GenericCheck(self, inst):
+    for i in [inst.all_nodes, inst.secondary_nodes]:
+      self.assertTrue(isinstance(inst.all_nodes, (list, tuple)),
+                      msg="Data type doesn't guarantee order")
+
+    self.assertTrue(inst.primary_node not in inst.secondary_nodes)
+    self.assertEqual(inst.all_nodes[0], inst.primary_node,
+                     msg="Primary node not first node in list")
+
+  def testNodesNoDisks(self):
+    inst = objects.Instance(name="fakeinst.example.com",
+      primary_node="pnode.example.com",
+      disks=[
+        ])
+
+    self._GenericCheck(inst)
+    self.assertEqual(len(inst.secondary_nodes), 0)
+    self.assertEqual(set(inst.all_nodes), set([inst.primary_node]))
+    self.assertEqual(inst.MapLVsByNode(), {
+      inst.primary_node: [],
+      })
+
+  def testNodesPlainDisks(self):
+    inst = objects.Instance(name="fakeinstplain.example.com",
+      primary_node="node3.example.com",
+      disks=[
+        objects.Disk(dev_type=constants.LD_LV, size=128,
+                     logical_id=("myxenvg", "disk25494")),
+        objects.Disk(dev_type=constants.LD_LV, size=512,
+                     logical_id=("myxenvg", "disk29071")),
+        ])
+
+    self._GenericCheck(inst)
+    self.assertEqual(len(inst.secondary_nodes), 0)
+    self.assertEqual(set(inst.all_nodes), set([inst.primary_node]))
+    self.assertEqual(inst.MapLVsByNode(), {
+      inst.primary_node: ["myxenvg/disk25494", "myxenvg/disk29071"],
+      })
+
+  def testNodesDrbdDisks(self):
+    inst = objects.Instance(name="fakeinstdrbd.example.com",
+      primary_node="node10.example.com",
+      disks=[
+        objects.Disk(dev_type=constants.LD_DRBD8, size=786432,
+          logical_id=("node10.example.com", "node15.example.com",
+                      12300, 0, 0, "secret"),
+          children=[
+            objects.Disk(dev_type=constants.LD_LV, size=786432,
+                         logical_id=("myxenvg", "disk0")),
+            objects.Disk(dev_type=constants.LD_LV, size=128,
+                         logical_id=("myxenvg", "meta0"))
+          ],
+          iv_name="disk/0")
+        ])
+
+    self._GenericCheck(inst)
+    self.assertEqual(set(inst.secondary_nodes), set(["node15.example.com"]))
+    self.assertEqual(set(inst.all_nodes),
+                     set([inst.primary_node, "node15.example.com"]))
+    self.assertEqual(inst.MapLVsByNode(), {
+      inst.primary_node: ["myxenvg/disk0", "myxenvg/meta0"],
+      "node15.example.com": ["myxenvg/disk0", "myxenvg/meta0"],
+      })
+
+    self.assertEqual(inst.FindDisk(0), inst.disks[0])
+    self.assertRaises(errors.OpPrereqError, inst.FindDisk, "hello")
+    self.assertRaises(errors.OpPrereqError, inst.FindDisk, 100)
+    self.assertRaises(errors.OpPrereqError, inst.FindDisk, 1)
+
 
 if __name__ == '__main__':
   testutils.GanetiTestProgram()