summaryrefslogtreecommitdiffstats
path: root/storperf/test_executor.py
diff options
context:
space:
mode:
authorMark Beierl <mark.beierl@emc.com>2016-05-08 10:09:47 -0400
committerMark Beierl <mark.beierl@emc.com>2016-05-09 09:34:44 -0400
commitedbced4cda35e63c9ddc4e40a67807cbfd6d6c20 (patch)
tree3bbb5b35d093556414ba6c50876813c529ed45e9 /storperf/test_executor.py
parentda56b4dac702713045aaeeedbab9234e1825ffe0 (diff)
Add plots
Adds matplotlib Adds support for generating graphs showing performance results Change-Id: Iba344baab89e35c0d5891a9d6b4c22c37666511e JIRA: STORPERF-44 JIRA: STORPERF-50 Signed-off-by: Mark Beierl <mark.beierl@emc.com>
Diffstat (limited to 'storperf/test_executor.py')
-rw-r--r--storperf/test_executor.py28
1 files changed, 24 insertions, 4 deletions
diff --git a/storperf/test_executor.py b/storperf/test_executor.py
index 309fbcb..6b9c441 100644
--- a/storperf/test_executor.py
+++ b/storperf/test_executor.py
@@ -32,6 +32,8 @@ class TestExecutor(object):
self.filename = None
self.precondition = True
self.warm = True
+ self._queue_depths = [1, 4, 8]
+ self._block_sizes = [512, 4096, 16384]
self.event_listeners = set()
self.metrics_converter = Converter()
self.metrics_emitter = CarbonMetricTransmitter()
@@ -51,6 +53,24 @@ class TestExecutor(object):
self.logger.debug("Set slaves to: " + str(slaves))
self._slaves = slaves
+ @property
+ def queue_depths(self):
+ return ','.join(self._queue_depths)
+
+ @queue_depths.setter
+ def queue_depths(self, queue_depths):
+ self.logger.debug("Set queue_depths to: " + str(queue_depths))
+ self._queue_depths = queue_depths.split(',')
+
+ @property
+ def block_sizes(self):
+ return ','.join(self._block_sizes)
+
+ @block_sizes.setter
+ def block_sizes(self, block_sizes):
+ self.logger.debug("Set block_sizes to: " + str(block_sizes))
+ self._block_sizes = block_sizes.split(',')
+
def register(self, event_listener):
self.event_listeners.add(event_listener)
@@ -138,11 +158,11 @@ class TestExecutor(object):
workload.filename = self.filename
if (workload_name.startswith("_")):
- iodepths = [32, ]
- blocksizes = [8192, ]
+ iodepths = [8, ]
+ blocksizes = [16384, ]
else:
- iodepths = [128, 16, 1]
- blocksizes = [8192, 4096, 512]
+ iodepths = self._queue_depths
+ blocksizes = self._block_sizes
workload.id = self.job_db.job_id