aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rwxr-xr-xexamples/geant.py302
-rwxr-xr-xexamples/isps.py127
2 files changed, 429 insertions, 0 deletions
diff --git a/examples/geant.py b/examples/geant.py
new file mode 100755
index 0000000..7fb59ad
--- /dev/null
+++ b/examples/geant.py
@@ -0,0 +1,302 @@
+#!/usr/bin/env python
+
+# An example script using the rumba package
+from rumba.model import *
+
+# import testbed plugins
+import rumba.testbeds.emulab as emulab
+import rumba.testbeds.jfed as jfed
+import rumba.testbeds.local as local
+import rumba.testbeds.qemu as qemu
+import rumba.testbeds.dockertb as docker
+
+# import prototype plugins
+import rumba.prototypes.ouroboros as our
+import rumba.prototypes.rlite as rl
+import rumba.prototypes.irati as irati
+
+import rumba.log as log
+
+from rumba.storyboard import *
+
+from rumba.utils import *
+
+import argparse
+import time
+
+log.set_logging_level('DEBUG')
+
+n1 = NormalDIF("n1")
+
+n1.add_policy("routing", "lfa")
+n1.add_policy("pff", "alternate")
+
+e1 = ShimEthDIF("e1")
+e2 = ShimEthDIF("e2")
+e3 = ShimEthDIF("e3")
+e4 = ShimEthDIF("e4")
+e5 = ShimEthDIF("e5")
+e6 = ShimEthDIF("e6")
+e7 = ShimEthDIF("e7")
+e8 = ShimEthDIF("e8")
+e9 = ShimEthDIF("e9")
+e10 = ShimEthDIF("e10")
+e11 = ShimEthDIF("e11")
+e12 = ShimEthDIF("e12")
+e13 = ShimEthDIF("e13")
+e14 = ShimEthDIF("e14")
+e15 = ShimEthDIF("e15")
+e16 = ShimEthDIF("e16")
+e17 = ShimEthDIF("e17")
+e18 = ShimEthDIF("e18")
+e19 = ShimEthDIF("e19")
+e20 = ShimEthDIF("e20")
+e21 = ShimEthDIF("e21")
+e22 = ShimEthDIF("e22")
+e23 = ShimEthDIF("e23")
+e24 = ShimEthDIF("e24")
+e25 = ShimEthDIF("e25")
+e26 = ShimEthDIF("e26")
+e27 = ShimEthDIF("e27")
+e28 = ShimEthDIF("e28")
+e29 = ShimEthDIF("e29")
+e30 = ShimEthDIF("e30")
+e31 = ShimEthDIF("e31")
+e32 = ShimEthDIF("e32")
+e33 = ShimEthDIF("e33")
+e34 = ShimEthDIF("e34")
+e35 = ShimEthDIF("e35")
+e36 = ShimEthDIF("e36")
+e37 = ShimEthDIF("e37")
+e38 = ShimEthDIF("e38")
+e39 = ShimEthDIF("e39")
+e40 = ShimEthDIF("e40")
+e41 = ShimEthDIF("e41")
+e42 = ShimEthDIF("e42")
+e43 = ShimEthDIF("e43")
+e44 = ShimEthDIF("e44")
+
+layers = [e1, e2, e3, e4, e5, e6, e7, e8, e9, e10,
+ e11, e12, e13, e14, e15, e16, e17, e18, e19, e20,
+ e21, e22, e23, e24, e25, e26, e27, e28, e29, e30,
+ e31, e32, e33, e34, e35, e36, e37, e38, e39, e40,
+ e41, e42, e43, e44]
+
+lisbon = Node("lisbon",
+ difs = [n1, e1, e2],
+ dif_registrations = {n1: [e1,e2]})
+
+madrid = Node("madrid",
+ difs = [n1, e1, e6, e9, e11],
+ dif_registrations = {n1 : [e1, e6, e9, e11]})
+
+london = Node("london",
+ difs = [n1, e2, e3, e4, e5],
+ dif_registrations = {n1 : [e2, e3, e4, e5]})
+
+dublin = Node("dublin",
+ difs = [n1, e3],
+ dif_registrations = {n1 : [e3]})
+
+paris = Node("paris",
+ difs = [n1, e4, e6, e7, e8],
+ dif_registrations = {n1 : [e4, e6, e7, e8]})
+
+brussels = Node("brussels",
+ difs = [n1, e5, e12],
+ dif_registrations = {n1 : [e5, e12]})
+
+luxemburg = Node("luxemburg",
+ difs = [n1, e7, e16],
+ dif_registrations = {n1 : [e7, e16]})
+
+bern = Node("bern",
+ difs = [n1, e8, e9, e10, e15],
+ dif_registrations = {n1 : [e8, e9, e10, e15]})
+
+roma = Node("roma",
+ difs = [n1, e10, e11, e13, e34, e28],
+ dif_registrations = {n1 : [e10, e11, e13, e34, e28]})
+
+amsterdam = Node("amsterdam",
+ difs = [n1, e12, e14, e17, e18],
+ dif_registrations = {n1 : [e12, e14, e17, e18]})
+
+valleta = Node("valleta",
+ difs = [n1, e13, e14],
+ dif_registrations = {n1 : [e13, e14]})
+
+berlin = Node("berlin",
+ difs = [n1, e15, e16, e17, e30, e31],
+ dif_registrations = {n1 : [e15, e16, e17, e30, e31]})
+
+copenhagen = Node("copenhagen",
+ difs = [n1, e18, e20, e22, e24, e19],
+ dif_registrations = {n1 : [e18, e20, e22, e24, e19]})
+
+oslo = Node("oslo",
+ difs = [n1, e20, e21],
+ dif_registrations = {n1 : [e20, e21]})
+
+stockholm = Node("stockholm",
+ difs = [n1, e21, e22],
+ dif_registrations = {n1 : [e21, e22]})
+
+tallin = Node("tallin",
+ difs = [n1, e24, e25],
+ dif_registrations = {n1 : [e24, e25]})
+
+riga = Node("riga",
+ difs = [n1, e25, e26],
+ dif_registrations = {n1 : [e25, e26]})
+
+vilnius = Node("vilnius",
+ difs = [n1, e26, e27],
+ dif_registrations = {n1 : [e26, e27]})
+
+warsaw = Node("warsaw",
+ difs = [n1, e27, e29],
+ dif_registrations = {n1 : [e27, e29]})
+
+praha = Node("praha",
+ difs = [n1, e29, e30, e32],
+ dif_registrations = {n1 : [e29, e30, e32]})
+
+viena = Node("viena",
+ difs = [n1, e32, e33, e35, e39, e28],
+ dif_registrations = {n1 : [e32, e33, e35, e39, e28]})
+
+budapest = Node("budapest",
+ difs = [n1, e33, e37, e38, e43],
+ dif_registrations = {n1 : [e33, e37, e38, e43]})
+
+athens = Node("athens",
+ difs = [n1, e39, e40, e44],
+ dif_registrations = {n1 : [e39, e40, e44]})
+
+ljubljana = Node("ljubljana",
+ difs = [n1, e35, e36],
+ dif_registrations = {n1 : [e35, e36]})
+
+zagreb = Node("zagreb",
+ difs = [n1, e36, e37],
+ dif_registrations = {n1 : [e36, e37]})
+
+sofia = Node("sofia",
+ difs = [n1, e38, e40, e42, e23],
+ dif_registrations = {n1 : [e38, e40, e42, e23]})
+
+bucharest = Node("bucharest",
+ difs = [n1, e42, e43, e41],
+ dif_registrations = {n1 : [e42, e43, e41]})
+
+nicosia = Node("nicosia",
+ difs = [n1, e44, e34],
+ dif_registrations = {n1 : [e44, e34]})
+
+ankara = Node("ankara",
+ difs = [n1, e23, e41],
+ dif_registrations = {n1 : [e23, e41]})
+
+moscow = Node("moscow",
+ difs = [n1, e31, e19],
+ dif_registrations = {n1 : [e31, e19]})
+
+tb = jfed.Testbed(exp_name = 'geant8',
+ cert_file = '/home/sander/cert.pem',
+ authority = 'wall1.ilabt.iminds.be',
+# authority = 'exogeni.net:umassvmsite',
+ username = 'sander',
+ exp_hours = '200')
+
+nodes = [lisbon, madrid, london, paris, dublin,
+ brussels, luxemburg, bern, roma, amsterdam,
+ valleta, berlin, copenhagen, oslo, stockholm,
+ tallin, riga, vilnius, warsaw, praha, viena,
+ budapest, athens, ljubljana, zagreb, sofia,
+ bucharest, nicosia, ankara, moscow]
+
+exp = our.Experiment(tb, nodes=nodes,
+ git_repo='https://bitbucket.org/sandervrijders/ouroboros.git',
+ git_branch='rand3')
+
+
+with ExperimentManager(exp, swap_out_strategy=AUTO_SWAPOUT):
+ exp.swap_in()
+ exp.install_prototype()
+ exp.bootstrap_prototype()
+ for layer in layers:
+ for i in range(1,4):
+
+ duration = 1220
+
+ sb = StoryBoard(duration + 30)
+
+ sb.set_experiment(exp)
+
+ for node in nodes:
+ s = Server(
+ "oping",
+ options="-l",
+ arrival_rate=0.01,
+ mean_duration=duration,
+ s_id='oping_' + node.name,
+ difs=n1
+ )
+
+ sb.add_server_on_node(s, node)
+
+ # Generate pings to check rtt, latency and drops
+ couples = {(a, b) for i, a in enumerate(nodes) for b in nodes[i+1:]}
+
+ time = 30
+
+ for node1, node2 in couples:
+
+ tag12 = '%s_%s' % (node1.name, node2.name)
+ tag21 = '%s_%s' % (node2.name, node1.name)
+
+ c_opt_base = "-d 940000 -i 100ms -D -n "
+
+ client12 = Client(
+ "oping",
+ options=c_opt_base + 'oping_' + node2.name,
+ shutdown="",
+ c_id='__rpc_' + tag12
+ )
+
+ client21 = Client(
+ "oping",
+ options=c_opt_base + 'oping_' + node1.name,
+ shutdown="",
+ c_id='__rpc_' + tag21
+ )
+
+ sb.schedule_action(
+ sb.run_client,
+ args=[client12, duration, node1, '__rpp_' + tag12],
+ c_time=time,
+ ev_id='ev_run_rp_' + tag12
+ )
+
+ sb.schedule_action(
+ sb.run_client,
+ args=[client21, duration, node2, '__rpp_' + tag21],
+ c_time=time,
+ ev_id='ev_run_rp_' + tag21
+ )
+
+ time += 0.4
+
+ sb.schedule_link_down(560, layer)
+ sb.schedule_link_up(750, layer)
+
+ prefix = layer.name + '_' + str(i)
+
+ sb.schedule_export_lsdb_total(390, prefix + '_lsdb.csv', n1)
+ sb.schedule_export_dif_bandwidth(410, prefix + '_1.csv', n1)
+ sb.schedule_export_dif_bandwidth(510, prefix + '_2.csv', n1)
+ sb.schedule_export_dif_bandwidth(610, prefix + '_3.csv', n1)
+ sb.schedule_export_dif_bandwidth(710, prefix + '_4.csv', n1)
+
+ sb.start()
diff --git a/examples/isps.py b/examples/isps.py
new file mode 100755
index 0000000..62a17ad
--- /dev/null
+++ b/examples/isps.py
@@ -0,0 +1,127 @@
+#!/usr/bin/env python
+
+from rumba.model import *
+import rumba.testbeds.jfed as jfed
+import rumba.prototypes.ouroboros as our
+
+import rumba.log as log
+
+from rumba.storyboard import *
+
+from rumba.utils import *
+
+import argparse
+import time
+
+log.set_logging_level('DEBUG')
+
+n0 = NormalDIF("n0")
+
+n1 = NormalDIF("n1")
+
+n2 = NormalDIF("n2")
+n2.add_policy("routing", "lfa")
+n2.add_policy("pff", "alternate")
+
+e0 = ShimEthDIF("e0")
+e1 = ShimEthDIF("e1")
+e2 = ShimEthDIF("e2")
+e3 = ShimEthDIF("e3")
+e4 = ShimEthDIF("e4")
+e5 = ShimEthDIF("e5")
+e6 = ShimEthDIF("e6")
+e7 = ShimEthDIF("e7")
+e8 = ShimEthDIF("e8")
+
+es = [e0, e1, e2, e3, e4, e5, e6, e7, e8]
+
+for e in es:
+ e.set_delay(5)
+
+end0 = Node("end0",
+ difs = [e0, e8, n2],
+ dif_registrations = {n2: [e0, e8]})
+
+end1 = Node("end1",
+ difs = [e4, e5, n2],
+ dif_registrations = {n2: [e4, e5]})
+
+isp10 = Node("isp10",
+ difs = [e0, e1, n2, n1],
+ dif_registrations = {n2: [e0, n1], n1: [e1]})
+
+isp11 = Node("isp11",
+ difs = [e1, e2, n1],
+ dif_registrations = {n1: [e1, e2]})
+
+isp12 = Node("isp12",
+ difs = [e2, e3, n1],
+ dif_registrations = {n1: [e2, e3]})
+
+isp13 = Node("isp13",
+ difs = [e3, e4, n2, n1],
+ dif_registrations = {n2: [e4, n1], n1: [e3]})
+
+isp00 = Node("isp00",
+ difs = [e8, e7, n2, n0],
+ dif_registrations = {n2: [e8, n0], n0: [e7]})
+
+isp01 = Node("isp01",
+ difs = [e7, e6, n0],
+ dif_registrations = {n0: [e7, e6]})
+
+isp02 = Node("isp02",
+ difs = [e6, e5, n2, n0],
+ dif_registrations = {n2: [e5, n0], n0: [e6]})
+
+tb = jfed.Testbed(exp_name = 'case3',
+ cert_file = '/home/sander/cert.pem',
+ username = 'sander',
+ exp_hours = '1')
+
+nodes = [end0, end1, isp10, isp11, isp12, isp13, isp00, isp01, isp02]
+
+exp = our.Experiment(tb, nodes=nodes,
+ git_repo='https://bitbucket.org/sandervrijders/ouroboros.git',
+ git_branch='rand3')
+
+duration = 120
+
+sb = StoryBoard(duration + 7)
+
+sb.set_experiment(exp)
+
+s = Server(
+ "oping",
+ options="-l",
+ arrival_rate=0.01,
+ mean_duration=duration + 4,
+ s_id='oping',
+ difs=n2
+)
+
+sb.add_server_on_node(s, end1)
+
+client = Client(
+ "oping",
+ options='-c 116000 -i 1 -D -n oping',
+ shutdown="",
+ c_id='__rpc_'
+)
+
+sb.schedule_action(
+ sb.run_client,
+ args=[client, duration, end0, '__rpp_'],
+ c_time=8,
+ ev_id='ev_run_rp'
+)
+
+sb.schedule_command(66, end1, 'irm i d n e5.end1 &')
+sb.schedule_command(66, end0, 'irm i d n e8.end0 &')
+
+with ExperimentManager(exp, swap_out_strategy=AUTO_SWAPOUT):
+ exp.swap_in()
+ exp.install_prototype()
+ exp.bootstrap_prototype()
+ sb.start()
+ sb.fetch_logs()