From 8ffafa8d29a6eca64544e32a497626e66b17fb4f Mon Sep 17 00:00:00 2001 From: edmaas Date: Mon, 28 Nov 2016 13:51:06 +0100 Subject: [PATCH] added test for basic functionality of resource limit service --- .../unittests/test_sonata_dummy_gatekeeper.py | 48 +++++++++++++++++++ 1 file changed, 48 insertions(+) diff --git a/src/emuvim/test/unittests/test_sonata_dummy_gatekeeper.py b/src/emuvim/test/unittests/test_sonata_dummy_gatekeeper.py index 4b9df14..c96e1ba 100755 --- a/src/emuvim/test/unittests/test_sonata_dummy_gatekeeper.py +++ b/src/emuvim/test/unittests/test_sonata_dummy_gatekeeper.py @@ -151,3 +151,51 @@ class testSonataDummyGatekeeper(SimpleTestTopology): # stop Mininet network self.stopNet() initialize_GK() + + def test_GK_stress_service(self): + # create network + self.createNet(ndatacenter=2, nhosts=2) + # connect dummy GK to data centers + sdkg1 = SonataDummyGatekeeperEndpoint("0.0.0.0", 5000) + sdkg1.connectDatacenter(self.dc[0]) + sdkg1.connectDatacenter(self.dc[1]) + # run the dummy gatekeeper (in another thread, don't block) + sdkg1.start() + # start Mininet network + self.startNet() + time.sleep(1) + + print "starting tests" + # board package + files = {"package": open("misc/sonata-stress-service.son", "rb")} + r = requests.post("http://127.0.0.1:5000/packages", files=files) + self.assertEqual(r.status_code, 201) + self.assertTrue(json.loads(r.text).get("service_uuid") is not None) + + # instantiate service + self.service_uuid = json.loads(r.text).get("service_uuid") + r2 = requests.post("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": self.service_uuid})) + self.assertEqual(r2.status_code, 201) + + # give the emulator some time to instantiate everything + time.sleep(2) + + # check get request APIs + r3 = requests.get("http://127.0.0.1:5000/packages") + self.assertEqual(len(json.loads(r3.text).get("service_uuid_list")), 1) + r4 = requests.get("http://127.0.0.1:5000/instantiations") + self.assertEqual(len(json.loads(r4.text).get("service_instantiations_list")), 1) + + # stop the service + service_instance_uuid = json.loads(r2.text).get("service_instance_uuid") + self.assertTrue(service_instance_uuid is not None) + requests.delete("http://127.0.0.1:5000/instantiations", data=json.dumps({"service_uuid": self.service_uuid, "service_instance_uuid":service_instance_uuid})) + + r5 = requests.get("http://127.0.0.1:5000/instantiations") + self.assertTrue(len(json.loads(r5.text).get("service_instantiations_list")), 0) # note that there was 1 instance before + + # stop Mininet network + self.stopNet() + initialize_GK() + + -- 2.17.1