diff options
author | LiHuan <lihuanwk@126.com> | 2017-04-07 23:32:07 +0800 |
---|---|---|
committer | Jing Lu <lvjing5@huawei.com> | 2017-06-01 02:42:11 +0000 |
commit | c5d97cd1d1da2478ac12278fe898385165ba3087 (patch) | |
tree | 5b2579be4e9229ebca333b311a39715f05330ab2 /yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py | |
parent | 370632cc02a711289f9830616d4ded2f6a9341be (diff) |
Add a new monitor type: MultiMonitor that can run any number of other monitors at the same time.
JIRA: YARDSTICK-397
Change-Id: Ic5cb79f0820029e306373abead1ea43fac9abee2
Signed-off-by: LiHuan <lihuanwk@126.com>
(cherry picked from commit 747a3260fef52fb5f7da337bc149ec202a05be6e)
Diffstat (limited to 'yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py')
-rw-r--r-- | yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py b/yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py new file mode 100644 index 000000000..8df2ea282 --- /dev/null +++ b/yardstick/benchmark/scenarios/availability/monitor/monitor_multi.py @@ -0,0 +1,68 @@ +############################################################################## +# Copyright (c) 2017 Huan Li and others +# lihuansse@tongji.edu.cn +# All rights reserved. This program and the accompanying materials +# are made available under the terms of the Apache License, Version 2.0 +# which accompanies this distribution, and is available at +# http://www.apache.org/licenses/LICENSE-2.0 +############################################################################## + +from __future__ import absolute_import +import logging +import time + +from yardstick.benchmark.scenarios.availability.monitor import basemonitor + +LOG = logging.getLogger(__name__) + + +class MultiMonitor(basemonitor.BaseMonitor): + + __monitor_type__ = "multi-monitor" + + def __init__(self, config, context): + super(MultiMonitor, self).__init__(config, context) + + self.monitors = [] + monitor_type = self._config["monitor_type"] + monitor_cls = basemonitor.BaseMonitor.get_monitor_cls(monitor_type) + + monitor_number = self._config.get("monitor_number", 1) + for i in range(monitor_number): + monitor_ins = monitor_cls(self._config, self._context) + self.monitors.append(monitor_ins) + + def start_monitor(self): + for monitor in self.monitors: + monitor.start_monitor() + + def wait_monitor(self): + for monitor in self.monitors: + monitor.wait_monitor() + + def verify_SLA(self): + first_outage = time.time() + last_outage = 0 + + for monitor in self.monitors: + monitor_result = monitor.result() + monitor_first_outage = monitor_result.get('first_outage', None) + monitor_last_outage = monitor_result.get('last_outage', None) + + if monitor_first_outage is None or monitor_last_outage is None: + continue + + if monitor_first_outage < first_outage: + first_outage = monitor_first_outage + + if monitor_last_outage > last_outage: + last_outage = monitor_last_outage + LOG.debug("multi monitor result: %f , %f", first_outage, last_outage) + + outage_time = last_outage - first_outage + max_outage_time = self._config["sla"]["max_outage_time"] + if outage_time > max_outage_time: + LOG.error("SLA failure: %f > %f", outage_time, max_outage_time) + return False + else: + return True |