From a4c40bdaa28df486628fe6a1a0c0ffd9d46ba75c Mon Sep 17 00:00:00 2001
From: Rowan Powell <rp17@it-innovation.soton.ac.uk>
Date: Wed, 10 Jan 2018 15:38:01 +0000
Subject: [PATCH] Added simulation of demoserver shutdown

---
 src/mediaServiceSim/serviceSim.py | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/mediaServiceSim/serviceSim.py b/src/mediaServiceSim/serviceSim.py
index 3c53d96..a88b28a 100644
--- a/src/mediaServiceSim/serviceSim.py
+++ b/src/mediaServiceSim/serviceSim.py
@@ -139,10 +139,15 @@ class DemoServer(object):
 
     def configure(self, server_id, server_location):
         print("Configuring")
-        self.configure_VM()
+        self.configure_VM('starting')
+        self.configure_VM('running')
         time.sleep(1)
         self.configure_server(server_id, server_location)
 
+    def shutdown(self):
+        print("Shutting down")
+        self.configure_VM('stopping')
+
     def generate_clients(self):
         self.clients = []
         for i in range(self.clientCount):
@@ -165,13 +170,9 @@ class DemoServer(object):
         #        lp._generateServerConfig(id, locations[i], 8, '100G', '1T', self._selectDelay(len(ids))))
         self._sendInfluxDataBlock(server_conf_block)
 
-    def configure_VM(self):
-        print("Configuring VM nodes")
-        VM_conf_block = []
-        self._generateVMS('starting', 1, VM_conf_block)
-        self._generateVMS('running', 1, VM_conf_block)
-
-        self._sendInfluxDataBlock(VM_conf_block)
+    def configure_VM(self, state):
+        print("Configuring VM node")
+        self._sendInfluxData(self._generateVM(state, 1))
 
     def configure_ports(self):
         print("Configuring Servers")
@@ -259,9 +260,8 @@ class DemoServer(object):
         return self.simIterations
 
     # 'Private' methods ________________________________________________________
-    def _generateVMS(self, state, amount, datablock):
-        for i in range(0, amount):
-            datablock.append(lp._generateVMConfig(state, 1, '100G', '1T', self._selectDelay(amount)))
+    def _generateVM(self, state, delay):
+        return lp._generateVMConfig(state, 1, '100G', '1T', self._selectDelay(delay))
 
     def _cpuUsage(self, clientCount):
         cpuUsage = randint(0, 10)
@@ -382,5 +382,5 @@ while True:
 
     if itCount == 0:
         break
-demoServer.shutdown_VMs()
+demoServer.shutdown()
 print("\nFinished")
-- 
GitLab