diff options
Diffstat (limited to 'storperf/test_executor.py')
| -rw-r--r-- | storperf/test_executor.py | 28 |
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 |