aboutsummaryrefslogtreecommitdiff
path: root/rumba/elements
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@ugent.be>2018-05-30 16:22:56 +0200
committerSander Vrijders <sander.vrijders@ugent.be>2018-06-05 10:09:20 +0200
commit0baf4da9e699170fc64a9436f7fb2498c0599081 (patch)
tree1b5d500f979be8e59c28fbdfac03c5dad04de834 /rumba/elements
parenta389849c5b827fa5aac8ff93a1241c642cd300e6 (diff)
downloadrumba-0baf4da9e699170fc64a9436f7fb2498c0599081.tar.gz
rumba-0baf4da9e699170fc64a9436f7fb2498c0599081.zip
storyboard: Add function to export flows stats
This adds a function to export the bytes sent by flows in a certain DIF. It is implemented within the storyboard, which calls an abstract function in the Experiment class so that every prototype can implement it in its own specific way. This commit adds the implementation for Ouroboros. It exports it to a csv, with the first item the source IPCP, the second the destination IPCP and then the bytes sent on the flow.
Diffstat (limited to 'rumba/elements')
-rw-r--r--rumba/elements/experimentation.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/rumba/elements/experimentation.py b/rumba/elements/experimentation.py
index 1ae50f7..8f3f40a 100644
--- a/rumba/elements/experimentation.py
+++ b/rumba/elements/experimentation.py
@@ -525,6 +525,10 @@ class Experiment(object):
end = time.time()
logger.info("Swap-out took %.2f seconds", end - start)
+ @abc.abstractmethod
+ def export_dif_bandwidth(self, filename, dif):
+ raise Exception('Export DIF bandwidth method not implemented')
+
def to_dms_yaml(self, filename):
"""
Generate a YAML file of the experiment which can be fed to the