diff --git a/src/mediaServiceSim/LineProtocolGenerator.py b/src/mediaServiceSim/LineProtocolGenerator.py index 25d19df73c2b977903f181b357adb9b790918989..1d95e4495add5e3745ab87d64bc58aa2721d3d1f 100644 --- a/src/mediaServiceSim/LineProtocolGenerator.py +++ b/src/mediaServiceSim/LineProtocolGenerator.py @@ -78,7 +78,7 @@ def _generateServerConfig(ID, location, cpu, mem, storage, time): # metric result = 'host_resource' # Tags - result += ',slide_id=' + quote_wrap(ID) + result += ',slice_id=' + quote_wrap(ID) result += ',location=' + quote_wrap(location) result += ' ' # Fields diff --git a/src/mediaServiceSim/__pycache__/LineProtocolGenerator.cpython-36.pyc b/src/mediaServiceSim/__pycache__/LineProtocolGenerator.cpython-36.pyc index f38f213dc30a01a2424732fbe023db717c3fe646..cf9cec5c15d858f591cc38897f4a9f587e1bd66d 100644 Binary files a/src/mediaServiceSim/__pycache__/LineProtocolGenerator.cpython-36.pyc and b/src/mediaServiceSim/__pycache__/LineProtocolGenerator.cpython-36.pyc differ diff --git a/src/mediaServiceSim/serviceSim.py b/src/mediaServiceSim/serviceSim.py index a88b28a54be5f0570e67b3caeab50d2ef65105c5..4cae8151727f6bb75f7523b25bd19cec1eaeeb70 100644 --- a/src/mediaServiceSim/serviceSim.py +++ b/src/mediaServiceSim/serviceSim.py @@ -106,7 +106,7 @@ class DemoClient(object): class DatabaseManager(): def __init__(self, influx_url, db_name): self.influx_url = influx_url - self.influxDB = db_name + self.influx_db = db_name def database_up(self): self._createDB() @@ -115,34 +115,28 @@ class DatabaseManager(): self._deleteDB() def _createDB(self): - self._sendInfluxQuery('CREATE DATABASE ' + self.influxDB) + self._sendInfluxQuery('CREATE DATABASE ' + self.influx_db) def _deleteDB(self): - self._sendInfluxQuery('DROP DATABASE ' + self.influxDB) + self._sendInfluxQuery('DROP DATABASE ' + self.influx_db) def _sendInfluxQuery(self, query): query = urllib.parse.urlencode({'q': query}) query = query.encode('ascii') - req = urllib.request.Request(self.influxURL + '/query ', query) + req = urllib.request.Request(self.influx_url + '/query ', query) urllib.request.urlopen(req) # DemoServer is the class that simulates the behaviour of the MPEG-DASH server class DemoServer(object): - def __init__(self, cc, si, db_url, db_name): + def __init__(self, cc, si, db_url, db_name, server_id, server_location): self.influxDB = db_name # InfluxDB database name self.id = uuid.uuid4() # MPEG-DASH server ID self.clientCount = cc # Number of clients to simulate self.simIterations = si # Number of iterations to make for this simulation self.influxURL = db_url # InfluxDB connection URL self.currentTime = int(round(time.time() * 1000)) # The current time - - def configure(self, server_id, server_location): - print("Configuring") - self.configure_VM('starting') - self.configure_VM('running') - time.sleep(1) - self.configure_server(server_id, server_location) + self._configure(server_id, server_location) def shutdown(self): print("Shutting down") @@ -259,10 +253,18 @@ class DemoServer(object): return self.simIterations - # 'Private' methods ________________________________________________________ def _generateVM(self, state, delay): return lp._generateVMConfig(state, 1, '100G', '1T', self._selectDelay(delay)) + # 'Private' methods ________________________________________________________ + def _configure(self, server_id, server_location): + print("Configuring") + self.configure_VM('starting') + self.configure_VM('running') + time.sleep(1) + self.configure_server(server_id, server_location) + self.generate_clients() + def _cpuUsage(self, clientCount): cpuUsage = randint(0, 10) @@ -370,8 +372,7 @@ time.sleep(2) database_manager.database_up() time.sleep(2) # configure servers -demoServer = DemoServer(clients, iterations, 'http://localhost:8186', 'testDB') -demoServer.configure("Server1", "Southampton") +demoServer = DemoServer(clients, iterations, 'http://localhost:8186', 'testDB', "Server1", "Southampton") # Start simulation print("Starting simulation") while True: