1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
##############################################################################
# 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, data):
super(MultiMonitor, self).__init__(config, context, data)
self.monitors = []
self.monitor_data = data
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.monitor_data)
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
|
