diff options
| -rwxr-xr-x | examples/geant.py | 302 | ||||
| -rwxr-xr-x | examples/isps.py | 127 |
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() |