Added script for measuring impact of delay on OSM

Change-Id: I0117489e0c19358044099ed43c81a18f491c9d92
Signed-off-by: schillinge <ablu@mail.uni-paderborn.de>

diff --git a/examples/performance_measurements/osm_component_increasing_delay.py b/examples/performance_measurements/osm_component_increasing_delay.py
new file mode 100755 (executable)
index 0000000..460bf7a
--- /dev/null
+++ b/examples/performance_measurements/osm_component_increasing_delay.py
@@ -0,0 +1,183 @@
+#!/usr/bin/env python2
+# Copyright (c) 2019 Erik Schilling
+# ALL RIGHTS RESERVED.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+import csv
+import signal
+import time
+
+from emuvim.api.openstack.openstack_api_endpoint import OpenstackApiEndpoint
+from emuvim.api.osm.kafka import Kafka
+from emuvim.api.osm.lcm import LCM
+from emuvim.api.osm.mongo import Mongo
+from emuvim.api.osm.mysql import Mysql
+from emuvim.api.osm.nbi import NBI
+from emuvim.api.osm.ro import RO
+from emuvim.api.osm.zookeeper import Zookeeper
+from emuvim.dcemulator.net import DCNetwork
+from mininet.link import TCLink
+from mininet.log import setLogLevel
+
+setLogLevel('debug')
+
+MAX_MS_DELAY = 250
+STEP = 10
+
+
+class TimeoutException(Exception):
+    pass
+
+
+def timeout_handler(signum, frame):
+    raise TimeoutException
+
+
+signal.signal(signal.SIGALRM, timeout_handler)
+
+with open('osm_component_increasing_delay_%d.csv' % time.time(), 'w') as csvfile:
+    fieldnames = ['delay', 'startup', 'deployment', 'deletion', 'failed', 'other',
+                  'zookeeper', 'kafka', 'mongo', 'nbi', 'ro_db', 'ro', 'lcm',
+                  'rtt_ro_db_ms', 'rtt_db_ro_ms']
+    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
+    writer.writeheader()
+
+    for delay in range(0, MAX_MS_DELAY + 1, STEP):
+        start = time.time()
+        net = DCNetwork(monitor=False, enable_learning=True)
+        api = None
+        try:
+            signal.alarm(60 * 15)
+            dc1 = net.addDatacenter("dc1")
+            api = OpenstackApiEndpoint("0.0.0.0", 6001)
+            api.connect_datacenter(dc1)
+            api.connect_dc_network(net)
+
+            s1 = net.addSwitch('s1')
+
+            zookeeper_ip = '10.0.0.96'
+            kafka_ip = '10.0.0.97'
+            mongo_ip = '10.0.0.98'
+            nbi_ip = '10.0.0.99'
+            ro_db_ip = '10.0.0.100'
+            ro_ip = '10.0.0.101'
+            lcm_ip = '10.0.0.102'
+
+            d1 = net.addDocker('d1', dimage='ubuntu:trusty')
+
+            VERSION = 'releasefive-daily'
+
+            zookeeper = Zookeeper(net, zookeeper_ip)
+            kafka = Kafka(net, kafka_ip, zookeeper_ip)
+            mongo = Mongo(net, mongo_ip)
+            nbi = NBI(net, nbi_ip, mongo_ip, kafka_ip)
+            ro_db = Mysql(net, ro_db_ip)
+            ro = RO(net, ro_ip, ro_db_ip, version=VERSION)
+            lcm = LCM(net, lcm_ip, ro_ip, mongo_ip, kafka_ip)
+
+            net.addLink(d1, s1)
+            delay_string = '%dms' % delay
+            net.addLink(zookeeper.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(kafka.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(mongo.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(nbi.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(ro_db.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(ro.instance, s1, cls=TCLink, delay=delay_string)
+            net.addLink(lcm.instance, s1, cls=TCLink, delay=delay_string)
+
+            net.start()
+            api.start()
+
+            other_end = time.time()
+            zookeeper.start()
+            zookeeper_started = time.time()
+            kafka.start()
+            kafka_started = time.time()
+            mongo.start()
+            mongo_started = time.time()
+            nbi.start()
+            nbi_started = time.time()
+            ro_db.start()
+            ro_db_started = time.time()
+            ro.start()
+            ro_started = time.time()
+            lcm.start()
+            lcm_started = time.time()
+
+            vim_id = nbi.register_emulated_api('vim-emu1', api)
+            nbi.onboard_vnfd('../vnfs/ping_vnf')
+            nbi.onboard_vnfd('../vnfs/pong_vnf')
+            nsd_id = nbi.onboard_nsd('../services/pingpong_ns')
+
+            start_done = time.time()
+            signal.alarm(0)
+
+            result = net.pingFull(hosts=[ro.instance, ro_db.instance])
+            rtt_ro_db = result[0][2][3]
+            rtt_db_ro = result[1][2][3]
+
+            deploy_start = time.time()
+
+            ns_id = nbi.ns_create('pingpong-test-%d' % delay, nsd_id, vim_id)
+
+            _, num_failed = nbi.ns_wait_until_all_in_status('running', 'failed')
+
+            deployment_done = time.time()
+
+            nbi.ns_delete(ns_id)
+
+            nbi.ns_wait_until_all_in_status('terminated')
+
+            ns_delete_done = time.time()
+
+            writer.writerow({
+                'delay': delay,
+                'other': other_end - start,
+                'zookeeper': zookeeper_started - other_end,
+                'kafka': kafka_started - zookeeper_started,
+                'mongo': mongo_started - kafka_started,
+                'nbi': nbi_started - mongo_started,
+                'ro_db': ro_db_started - nbi_started,
+                'ro': ro_started - ro_db_started,
+                'lcm': lcm_started - ro_started,
+                'startup': start_done - start,
+                'deployment': deployment_done - deploy_start,
+                'deletion': ns_delete_done - deployment_done,
+                'failed': num_failed,
+                'rtt_ro_db_ms': rtt_ro_db,
+                'rtt_db_ro_ms': rtt_db_ro,
+            })
+            csvfile.flush()
+        except Exception as e:
+            print('caught: %s' % e)
+            writer.writerow({
+                'delay': delay,
+                'other': None,
+                'zookeeper': None,
+                'kafka': None,
+                'mongo': None,
+                'nbi': None,
+                'ro_db': None,
+                'ro': None,
+                'lcm': None,
+                'startup': None,
+                'deployment': None,
+                'deletion': None,
+                'failed': None,
+                'rtt_ro_db_ms': None,
+                'rtt_db_ro_ms': None,
+            })
+            csvfile.flush()
+        finally:
+            net.stop()
+            api.stop()