summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRex Lee <limingjiang@huawei.com>2017-04-24 01:57:19 +0000
committerGerrit Code Review <gerrit@opnfv.org>2017-04-24 01:57:19 +0000
commitaf7518c51362ce882972c4b2168dbbfa4f5dcb2d (patch)
treea87df5d38aa08fb012edc244831d4aa91dea0289
parentbd877d6bd6928ac4bdebdd292c15dc94241542f3 (diff)
parentb6454edc8d9cb7294cd2b63feb9a3b61fde35906 (diff)
Merge "Add a new runner to test end-to-end fast data path"
-rw-r--r--yardstick/benchmark/runners/iteration.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/yardstick/benchmark/runners/iteration.py b/yardstick/benchmark/runners/iteration.py
index c2376af48..29daa0d42 100644
--- a/yardstick/benchmark/runners/iteration.py
+++ b/yardstick/benchmark/runners/iteration.py
@@ -41,6 +41,10 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
interval = runner_cfg.get("interval", 1)
iterations = runner_cfg.get("iterations", 1)
run_step = runner_cfg.get("run_step", "setup,run,teardown")
+ delta = runner_cfg.get("delta", 2)
+ options_cfg = scenario_cfg['options']
+ initial_rate = options_cfg.get("rate", 100)
+ scenario_cfg['options']['rate'] = initial_rate
LOG.info("worker START, iterations %d times, class %s", iterations, cls)
runner_cfg['runner_id'] = os.getpid()
@@ -77,6 +81,10 @@ def _worker_process(queue, cls, method_name, scenario_cfg,
elif sla_action == "monitor":
LOG.warning("SLA validation failed: %s", assertion.args)
errors = assertion.args
+ elif sla_action == "rate-control":
+ scenario_cfg['options']['rate'] -= delta
+ sequence = 1
+ continue
except Exception as e:
errors = traceback.format_exc()
LOG.exception(e)