aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorMarco Capitani <[email protected]>2017-11-15 09:28:38 +0100
committerSander Vrijders <[email protected]>2017-11-17 15:17:31 +0000
commit9d21bf51eb1765e0bdb15ef3d8b8700327bf2f66 (patch)
tree2fcc1e3e7f82de54d894bf0bf8da7c3f281b6f05 /examples
parent134eae6b986709a6524afa1e1f18527cbe900eea (diff)
downloadrumba-9d21bf51eb1765e0bdb15ef3d8b8700327bf2f66.tar.gz
rumba-9d21bf51eb1765e0bdb15ef3d8b8700327bf2f66.zip
storyboard: make Client shutdown an argument
Before the shutdown call for the Client/ClientProcess was fixed to kill <pid>. Now it's passed as an argument to the Client constructor.
Diffstat (limited to 'examples')
-rw-r--r--examples/rinaperf_sb-usage.py58
1 files changed, 58 insertions, 0 deletions
diff --git a/examples/rinaperf_sb-usage.py b/examples/rinaperf_sb-usage.py
new file mode 100644
index 0000000..0e7ca72
--- /dev/null
+++ b/examples/rinaperf_sb-usage.py
@@ -0,0 +1,58 @@
+#!/usr/bin/env python
+
+from rumba.model import *
+from rumba.storyboard import *
+import rumba.testbeds.qemu as qemu
+import rumba.prototypes.irati as irati
+import rumba.log as log
+from rumba.utils import ExperimentManager
+
+log.set_logging_level('DEBUG')
+
+
+n1 = NormalDIF("n1")
+
+n1.add_policy("rmt.pff", "lfa")
+n1.add_policy("security-manager", "passwd")
+
+e1 = ShimEthDIF("e1")
+
+a = Node("a",
+ difs=[n1, e1],
+ dif_registrations={n1: [e1]})
+
+b = Node("b",
+ difs=[e1, n1],
+ dif_registrations={n1: [e1]})
+
+tb = qemu.Testbed(exp_name="example1",
+ username="root",
+ password="root")
+
+exp = irati.Experiment(tb, nodes=[a, b])
+
+
+# General setup (can be reused in other scripts as-is)
+storyboard = StoryBoard(duration=30)
+client = Client("rinaperf",
+ options="-t perf -s 1000 -D <duration>",
+ shutdown="")
+server = Server("rinaperf", options="-l", arrival_rate=0.5,
+ mean_duration=5, clients=[client])
+
+
+# Experiment-specific configuration:
+# (This can be done anytime before storyboard.start())
+
+storyboard.set_experiment(exp)
+storyboard.add_server((server, a))
+client.add_node(b)
+
+
+print(exp)
+
+with ExperimentManager(exp):
+ exp.swap_in()
+ exp.bootstrap_prototype()
+ storyboard.start()
+ input('ENTER')