examples: add example for converged operator network

1 files changed, 201 insertions, 0 deletions

diff --git a/examples/converged-operator-network.py b/examples/converged-operator-network.py
new file mode 100755
index 0000000..058a04c
--- /dev/null
+++ b/examples/converged-operator-network.py
@@ -0,0 +1,201 @@
+#!/usr/bin/env python
+
+# Initial scale experiment for converged operator network
+# (ARCFIRE T4.2)
+
+from rumba.model import *
+from rumba.utils import ExperimentManager
+
+# import testbed plugins
+import rumba.testbeds.emulab as emulab
+import rumba.testbeds.jfed as jfed
+import rumba.testbeds.faketestbed as fake
+import rumba.testbeds.qemu as qemu
+
+# import prototype plugins
+import rumba.prototypes.ouroboros as our
+import rumba.prototypes.rlite as rl
+import rumba.prototypes.irati as irati
+
+log.set_logging_level('DEBUG')
+
+f1 = NormalDIF("fixed")
+l1 = NormalDIF("LTE")
+m1 = NormalDIF("metro1")
+m2 = NormalDIF("metro2")
+m3 = NormalDIF("metro3")
+c1 = NormalDIF("core")
+n1 = NormalDIF("overlay")
+
+f1e1 = ShimEthDIF("f1e1")
+f1e2 = ShimEthDIF("f1e2")
+
+l1e1 = ShimEthDIF("l1e1")
+
+m1f2 = ShimEthDIF("m1f2")
+m1f1 = ShimEthDIF("m1f1")
+
+m1e1 = ShimEthDIF("m1e1")
+m1e2 = ShimEthDIF("m1e2")
+m1e3 = ShimEthDIF("m1e3")
+m1e4 = ShimEthDIF("m1e4")
+m1e5 = ShimEthDIF("m1e5")
+m1e6 = ShimEthDIF("m1e6")
+
+m2l1 = ShimEthDIF("m2l1")
+
+m2e1 = ShimEthDIF("m2e1")
+m2e2 = ShimEthDIF("m2e2")
+m2e3 = ShimEthDIF("m2e3")
+m2e4 = ShimEthDIF("m2e4")
+m2e5 = ShimEthDIF("m2e5")
+m2e6 = ShimEthDIF("m2e6")
+
+m3e1 = ShimEthDIF("m3e1")
+m3e2 = ShimEthDIF("m3e2")
+m3e3 = ShimEthDIF("m3e3")
+m3e4 = ShimEthDIF("m3e4")
+m3e5 = ShimEthDIF("m3e5")
+m3e6 = ShimEthDIF("m3e6")
+
+m1c1 = ShimEthDIF("m1c1")
+m1c2 = ShimEthDIF("m1c2")
+
+m2c1 = ShimEthDIF("m2c1")
+m2c2 = ShimEthDIF("m2c2")
+
+m3c1 = ShimEthDIF("m3c1")
+m3c2 = ShimEthDIF("m3c2")
+
+c1e1 = ShimEthDIF("c1e1")
+c1e2 = ShimEthDIF("c1e2")
+c1e3 = ShimEthDIF("c1e3")
+c1e4 = ShimEthDIF("c1e4")
+
+f1n1 = Node("f1n1",
+            difs = [f1, m1f1, n1],
+            dif_registrations = {f1 : [m1f1], n1: [f1]},
+            client = True)
+
+f1n2 = Node("f1n2",
+            difs = [f1, m1f2, f1e1, f1e2],
+            dif_registrations = {f1: [m1f2, f1e1, f1e2]},
+            client = False)
+
+f1n3 = Node("f1n3",
+            difs = [f1, f1e1, n1],
+            dif_registrations = {f1: [f1e1], n1: [f1]},
+            client = True)
+
+f1n4 = Node("f1n4",
+            difs = [f1, f1e2, n1],
+            dif_registrations = {f1: [f1e2], n1: [f1]},
+            client = True)
+
+l1n1 = Node("l1n1",
+            difs = [n1, l1, m2l1, l1e1],
+            dif_registrations = {l1: [m2l1, l1e1], n1: [l1]})
+
+l1n2 = Node("l1n2",
+            difs = [n1, l1, l1e1],
+            dif_registrations = {l1: [l1e1], n1: [l1]},
+            client = True)
+
+m1n1 = Node("m1n1",
+            difs = [m1, m1e1, m1e6],
+            dif_registrations = {m1: [m1e1, m1e6]})
+
+m1n2 = Node("m1n2",
+            difs = [m1, m1e1, m1e2],
+            dif_registrations = {m1: [m1e1, m1e2]})
+m1n3 = Node("m1n3",
+            difs = [m1, m1e2, m1e3, m1c1],
+            dif_registrations = {m1: [m1e2, m1e3, m1c1]})
+m1n4 = Node("m1n4",
+            difs = [m1, m1e3, m1e4, m1c2],
+            dif_registrations = {m1: [m1e3, m1e4, m1c2]})
+m1n5 = Node("m1n5",
+            difs = [m1, m1e4, m1e5],
+            dif_registrations = {m1: [m1e4, m1e5]})
+m1n6 = Node("m1n6",
+            difs = [m1, f1, m1e5, m1e6, m1f2, m1f1, n1],
+            dif_registrations = {m1: [m1e5, m1e6],
+                                 f1: [m1f1, m1f2], n1: [f1, m1]})
+
+m2n1 = Node("m2n1",
+            difs = [m2, m2e1, m2e6],
+            dif_registrations = {m2: [m2e1, m2e6]})
+m2n2 = Node("m2n2",
+            difs = [m2, m2e1, m2e2],
+            dif_registrations = {m2: [m2e1, m2e2]})
+m2n3 = Node("m2n3",
+            difs = [m2, m2e2, m2e3, m2c1],
+            dif_registrations = {m2: [m2e2, m2e3, m2c1]})
+m2n4 = Node("m2n4",
+            difs = [m2, m2e3, m2e4, m2c2],
+            dif_registrations = {m2: [m2e3, m2e4, m2c2]})
+m2n5 = Node("m2n5",
+            difs = [m2, m2e4, m2e5],
+            dif_registrations = {m2: [m2e4, m2e5]})
+m2n6 = Node("m2n6",
+            difs = [m2, l1, m2e5, m2e6, m2l1, n1],
+            dif_registrations = {m2: [m2e5, m2e6], l1: [m2l1], n1: [l1, m2]})
+
+m3n1 = Node("m3n1",
+            difs = [m3, m3e1, m3e6],
+            dif_registrations = {m3: [m3e1, m3e6]})
+m3n2 = Node("m3n2",
+            difs = [m3, m3e1, m3e2],
+            dif_registrations = {m3: [m3e1, m3e2]})
+m3n3 = Node("m3n3",
+            difs = [m3, m3e2, m3e3, m3c1],
+            dif_registrations = {m3: [m3e2, m3e3, m3c1]})
+m3n4 = Node("m3n4",
+            difs = [m3, m3e3, m3e4, m3c2],
+            dif_registrations = {m3: [m3e3, m3e4, m3c2]})
+m3n5 = Node("m3n5",
+            difs = [n1, m3, m3e4, m3e5, m3c2],
+            dif_registrations = {m3: [m3e4, m3e5, m3c2], n1: [m3]})
+m3n6 = Node("m3n6",
+            difs = [m3, m3e5, m3e6, m3c1, n1],
+            dif_registrations = {m3: [m3e5, m3e6, m3c1], n1: [m3]})
+
+c1n1 = Node("c1n1",
+            difs = [n1, c1, m1, m2, m1c1, m2c1, c1e1, c1e4],
+            dif_registrations = {c1: [c1e1, c1e4], m1: [m1c1, c1],
+                                 m2: [m2c1, c1], n1: [m1, m2]})
+c1n2 = Node("c1n2",
+            difs = [n1, c1, m2, m3, m2c2, m3c1, c1e1, c1e2],
+            dif_registrations = {c1: [c1e1, c1e2], m2: [m2c2], m3: [c1, m2c2],
+                                 n1: [m2, m3]})
+c1n3 = Node("c1n3",
+            difs = [n1, c1, m3, m3c2, c1e2, c1e3],
+            dif_registrations = {c1: [c1e2, c1e3], m3: [c1, m3c2], n1: [m3]})
+c1n4 = Node("c1n4",
+            difs = [n1, c1, m1, m1c2, c1e3, c1e4],
+            dif_registrations = {c1: [c1e3, c1e4], m1: [c1, m1c2], n1: [m1]})
+
+tb = jfed.Testbed(exp_name   = "arcfiret42",
+                  proj_name  = "ARCFIRE",
+                  cert_file  = "/home/dstaesse/jfed/cert.pem",
+                  authority  = "exogeni.net",
+                  username   = "dstaesse")
+
+exp = rl.Experiment(tb, nodes = [f1n1, f1n2, f1n3, f1n4,
+                                l1n1, l1n2,
+                                m1n1, m1n2, m1n3, m1n4, m1n5, m1n6,
+                                m2n1, m2n2, m2n3, m2n4, m2n5, m2n6,
+                                m3n1, m3n2, m3n3, m3n4, m3n5, m3n6,
+                                c1n1, c1n2, c1n3, c1n4])
+
+print(exp)
+
+with ExperimentManager(exp):
+    exp.swap_in()
+    exp.install_prototype()
+    exp.bootstrap_prototype()
+    c1 = Client("rinaperf", options ="-i 10000 -s 1000 -c 0 -d overlay")
+    s1 = Server("rinaperf", arrival_rate=2, mean_duration=5,
+                options = "-l -d overlay", nodes = [c1n1], clients = [c1])
+    sb = StoryBoard(exp, duration=3600, servers = [s1])
+    sb.start()