Revision 075a29be test/ganeti.rapi.rlib2_unittest.py
b/test/ganeti.rapi.rlib2_unittest.py | ||
---|---|---|
728 | 728 |
self.assertRaises(http.HttpBadRequest, handler.PUT) |
729 | 729 |
|
730 | 730 |
|
731 |
class TestParseMigrateInstanceRequest(testutils.GanetiTestCase): |
|
732 |
def setUp(self): |
|
733 |
testutils.GanetiTestCase.setUp(self) |
|
734 |
|
|
735 |
self.Parse = rlib2._ParseMigrateInstanceRequest |
|
736 |
|
|
731 |
class TestInstanceMigrate(testutils.GanetiTestCase): |
|
737 | 732 |
def test(self): |
733 |
clfactory = _FakeClientFactory(_FakeClient) |
|
734 |
|
|
738 | 735 |
name = "instYooho6ek" |
739 | 736 |
|
740 | 737 |
for cleanup in [False, True]: |
... | ... | |
743 | 740 |
"cleanup": cleanup, |
744 | 741 |
"mode": mode, |
745 | 742 |
} |
746 |
op = self.Parse(name, data) |
|
747 |
self.assert_(isinstance(op, opcodes.OpInstanceMigrate)) |
|
743 |
|
|
744 |
handler = _CreateHandler(rlib2.R_2_instances_name_migrate, [name], {}, |
|
745 |
data, clfactory) |
|
746 |
job_id = handler.PUT() |
|
747 |
|
|
748 |
cl = clfactory.GetNextClient() |
|
749 |
self.assertRaises(IndexError, clfactory.GetNextClient) |
|
750 |
|
|
751 |
(exp_job_id, (op, )) = cl.GetNextSubmittedJob() |
|
752 |
self.assertEqual(job_id, exp_job_id) |
|
753 |
self.assertTrue(isinstance(op, opcodes.OpInstanceMigrate)) |
|
748 | 754 |
self.assertEqual(op.instance_name, name) |
749 | 755 |
self.assertEqual(op.mode, mode) |
750 | 756 |
self.assertEqual(op.cleanup, cleanup) |
757 |
self.assertFalse(hasattr(op, "dry_run")) |
|
758 |
self.assertFalse(hasattr(op, "force")) |
|
759 |
|
|
760 |
self.assertRaises(IndexError, cl.GetNextSubmittedJob) |
|
751 | 761 |
|
752 | 762 |
def testDefaults(self): |
763 |
clfactory = _FakeClientFactory(_FakeClient) |
|
764 |
|
|
753 | 765 |
name = "instnohZeex0" |
754 | 766 |
|
755 |
op = self.Parse(name, {}) |
|
756 |
self.assert_(isinstance(op, opcodes.OpInstanceMigrate)) |
|
767 |
handler = _CreateHandler(rlib2.R_2_instances_name_migrate, [name], {}, {}, |
|
768 |
clfactory) |
|
769 |
job_id = handler.PUT() |
|
770 |
|
|
771 |
cl = clfactory.GetNextClient() |
|
772 |
self.assertRaises(IndexError, clfactory.GetNextClient) |
|
773 |
|
|
774 |
(exp_job_id, (op, )) = cl.GetNextSubmittedJob() |
|
775 |
self.assertEqual(job_id, exp_job_id) |
|
776 |
self.assertTrue(isinstance(op, opcodes.OpInstanceMigrate)) |
|
757 | 777 |
self.assertEqual(op.instance_name, name) |
758 | 778 |
self.assertFalse(hasattr(op, "mode")) |
759 | 779 |
self.assertFalse(hasattr(op, "cleanup")) |
780 |
self.assertFalse(hasattr(op, "dry_run")) |
|
781 |
self.assertFalse(hasattr(op, "force")) |
|
782 |
|
|
783 |
self.assertRaises(IndexError, cl.GetNextSubmittedJob) |
|
760 | 784 |
|
761 | 785 |
|
762 | 786 |
class TestParseRenameInstanceRequest(testutils.GanetiTestCase): |
Also available in: Unified diff