from ganeti import constants
from ganeti import objects
+from ganeti import errors
import testutils
"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):
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 = [
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()