X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=src%2Femuvim%2Ftest%2Ftest_resourcemodel.py;h=1817a2502048056d800ef4c605a0d0e3993a4054;hb=7cd3c2529e5b926d0ca11bbaaa106cb8875059a4;hp=a11bc8b96c7c9a0f7e0671a5cf86c6b25cc803a4;hpb=74df3cccdfe2e8171d38645ee8de961c57e26bbe;p=osm%2Fvim-emu.git diff --git a/src/emuvim/test/test_resourcemodel.py b/src/emuvim/test/test_resourcemodel.py index a11bc8b..1817a25 100644 --- a/src/emuvim/test/test_resourcemodel.py +++ b/src/emuvim/test/test_resourcemodel.py @@ -1,9 +1,9 @@ import time import os from emuvim.test.base import SimpleTestTopology -from emuvim.dcemulator.resourcemodel import BaseResourceModel, ResourceFlavor -from emuvim.dcemulator.resourcemodel.upb.simple import UpbSimpleCloudDcRM -from emuvim.dcemulator.resourcemodel import ResourceModelRegistrar +from emuvim.dcemulator.resourcemodel import BaseResourceModel, ResourceFlavor, NotEnoughResourcesAvailable, ResourceModelRegistrar +from emuvim.dcemulator.resourcemodel.upb.simple import UpbSimpleCloudDcRM, UpbOverprovisioningCloudDcRM, UpbDummyRM + class testResourceModel(SimpleTestTopology): @@ -92,7 +92,7 @@ class testUpbSimpleCloudDcRM(SimpleTestTopology): Test the UpbSimpleCloudDc resource model. """ - def testAllocation(self): + def testAllocationComputations(self): """ Test the allocation procedures and correct calculations. :return: @@ -117,19 +117,16 @@ class testUpbSimpleCloudDcRM(SimpleTestTopology): self.assertEqual(float(c2.cpu_quota) / c2.cpu_period, E_CPU / MAX_CU * 1) # validate compute result self.assertEqual(float(c2.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128) # validate memory result - c3 = createDummyContainerObject("c3", flavor="medium") - res = rm.allocate(c3) # calculate allocation + rm.allocate(c3) # calculate allocation self.assertEqual(float(c3.cpu_quota) / c3.cpu_period, E_CPU / MAX_CU * 4) # validate compute result self.assertEqual(float(c3.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 256) # validate memory result - c4 = createDummyContainerObject("c4", flavor="large") rm.allocate(c4) # calculate allocation self.assertEqual(float(c4.cpu_quota) / c4.cpu_period, E_CPU / MAX_CU * 8) # validate compute result self.assertEqual(float(c4.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 512) # validate memory result - c5 = createDummyContainerObject("c5", flavor="xlarge") rm.allocate(c5) # calculate allocation self.assertEqual(float(c5.cpu_quota) / c5.cpu_period, E_CPU / MAX_CU * 16) # validate compute result @@ -162,7 +159,7 @@ class testUpbSimpleCloudDcRM(SimpleTestTopology): rm.allocate(c7) # calculate allocation rm.allocate(c8) # calculate allocation rm.allocate(c9) # calculate allocation - except Exception as e: + except NotEnoughResourcesAvailable as e: self.assertIn("Not enough compute", e.message) exception = True self.assertTrue(exception) @@ -191,7 +188,7 @@ class testUpbSimpleCloudDcRM(SimpleTestTopology): rm.allocate(c6) # calculate allocation rm.allocate(c7) # calculate allocation rm.allocate(c8) # calculate allocation - except Exception as e: + except NotEnoughResourcesAvailable as e: self.assertIn("Not enough memory", e.message) exception = True self.assertTrue(exception) @@ -260,4 +257,83 @@ class testUpbSimpleCloudDcRM(SimpleTestTopology): self.stopNet() +class testUpbOverprovisioningCloudDcRM(SimpleTestTopology): + """ + Test the UpbOverprovisioningCloudDc resource model. + """ + + def testAllocationComputations(self): + """ + Test the allocation procedures and correct calculations. + :return: + """ + # config + E_CPU = 1.0 + MAX_CU = 3 + E_MEM = 512 + MAX_MU = 2048 + # create dummy resource model environment + reg = ResourceModelRegistrar(dc_emulation_max_cpu=E_CPU, dc_emulation_max_mem=E_MEM) + rm = UpbOverprovisioningCloudDcRM(max_cu=MAX_CU, max_mu=MAX_MU) + reg.register("test_dc", rm) + + c1 = createDummyContainerObject("c1", flavor="small") + rm.allocate(c1) # calculate allocation + self.assertAlmostEqual(float(c1.cpu_quota) / c1.cpu_period, E_CPU / MAX_CU * 1.0, places=5) + self.assertAlmostEqual(float(c1.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128) + self.assertAlmostEqual(rm.cpu_op_factor, 1.0) + + c2 = createDummyContainerObject("c2", flavor="small") + rm.allocate(c2) # calculate allocation + self.assertAlmostEqual(float(c2.cpu_quota) / c2.cpu_period, E_CPU / MAX_CU * 1.0, places=5) + self.assertAlmostEqual(float(c2.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128) + self.assertAlmostEqual(rm.cpu_op_factor, 1.0) + + c3 = createDummyContainerObject("c3", flavor="small") + rm.allocate(c3) # calculate allocation + self.assertAlmostEqual(float(c3.cpu_quota) / c3.cpu_period, E_CPU / MAX_CU * 1.0, places=5) + self.assertAlmostEqual(float(c3.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128) + self.assertAlmostEqual(rm.cpu_op_factor, 1.0) + + # from this container onwards, we should go to over provisioning mode: + c4 = createDummyContainerObject("c4", flavor="small") + rm.allocate(c4) # calculate allocation + self.assertAlmostEqual(float(c4.cpu_quota) / c4.cpu_period, E_CPU / MAX_CU * (float(3) / 4), places=5) + self.assertAlmostEqual(float(c4.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128, places=5) + self.assertAlmostEqual(rm.cpu_op_factor, 0.75) + + c5 = createDummyContainerObject("c5", flavor="small") + rm.allocate(c5) # calculate allocation + self.assertAlmostEqual(float(c5.cpu_quota) / c5.cpu_period, E_CPU / MAX_CU * (float(3) / 5), places=5) + self.assertAlmostEqual(float(c5.mem_limit/1024/1024), float(E_MEM) / MAX_MU * 128) + self.assertAlmostEqual(rm.cpu_op_factor, 0.6) + + +class testUpbDummyRM(SimpleTestTopology): + """ + Test the UpbDummyRM resource model. + """ + + def testAllocationComputations(self): + """ + Test the allocation procedures and correct calculations. + :return: + """ + # config + E_CPU = 1.0 + MAX_CU = 3 + E_MEM = 512 + MAX_MU = 2048 + # create dummy resource model environment + reg = ResourceModelRegistrar(dc_emulation_max_cpu=E_CPU, dc_emulation_max_mem=E_MEM) + rm = UpbDummyRM(max_cu=MAX_CU, max_mu=MAX_MU) + reg.register("test_dc", rm) + + c1 = createDummyContainerObject("c1", flavor="small") + rm.allocate(c1) # calculate allocation + self.assertEqual(len(rm._allocated_compute_instances), 1) + + c2 = createDummyContainerObject("c2", flavor="small") + rm.allocate(c2) # calculate allocation + self.assertEqual(len(rm._allocated_compute_instances), 2)