diff options
| author |   mbeierl <mark.beierl@dell.com> | 2017-10-17 22:41:55 -0400 |
|---|---|---|
| committer | mbeierl <mark.beierl@dell.com> | 2017-10-17 22:55:10 -0400 |
| commit | 31b0e130755cbd425b26f740e5701768d77f98f0 (patch) | |
| tree | 03378d591eca659e037e7cad0b6f055d8a365378 /docker/storperf-master/storperf/utilities/data_handler.py | |
| parent | 477957139b2b782b899c9cb5603389ff0802b741 (diff) | |
Improving Reporting
Changes IOPS and BW to summation vs. average.
Adds fixed 0 y axis to all graphs
Change-Id: I3379597bda04b030424a25c7309a02c982fdb706
Signed-off-by: mbeierl <mark.beierl@dell.com>
Diffstat (limited to 'docker/storperf-master/storperf/utilities/data_handler.py')
| -rw-r--r-- | docker/storperf-master/storperf/utilities/data_handler.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/docker/storperf-master/storperf/utilities/data_handler.py b/docker/storperf-master/storperf/utilities/data_handler.py index 8a69180..b85517f 100644 --- a/docker/storperf-master/storperf/utilities/data_handler.py +++ b/docker/storperf-master/storperf/utilities/data_handler.py @@ -43,7 +43,12 @@ class DataHandler(object): for io_type in ('read', 'write'): metrics[metric][io_type] = {} - series = self._lookup_prior_data(executor, metric, io_type) + function = "sumSeries" + if 'mean' in metric: + function = "averageSeries" + + series = self._lookup_prior_data(executor, metric, io_type, + function) series = self._convert_timestamps_to_samples( executor, series) steady = self._evaluate_prior_data( @@ -85,7 +90,7 @@ class DataHandler(object): if steady_state and not workload_name.startswith('_'): executor.terminate_current_run() - def _lookup_prior_data(self, executor, metric, io_type): + def _lookup_prior_data(self, executor, metric, io_type, function): workload = executor.current_workload graphite_db = GraphiteDB() @@ -93,7 +98,8 @@ class DataHandler(object): # data we just sent to it now = int(time.time()) backtime = 60 * (executor.steady_state_samples + 1) - data_series = graphite_db.fetch_series(workload, + data_series = graphite_db.fetch_series(function, + workload, metric, io_type, now, |