mirror of
https://github.com/valitydev/yandex-tank.git
synced 2024-11-06 10:25:17 +00:00
Cumulative autostops
This commit is contained in:
Mikhail Epikhin
parent
9b6f5dc17f
commit
4713c45c1f
295
Tank/Plugins/TotalAutostop.py
Normal file
295
Tank/Plugins/TotalAutostop.py
Normal file
@ -0,0 +1,295 @@
|
||||
from Tank import Utils
|
||||
from Tank.Core import AbstractPlugin
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, AggregateResultListener
|
||||
from Tank.Plugins.ConsoleOnline import AbstractInfoWidget, ConsoleOnlinePlugin
|
||||
from Tank.Plugins.Phantom import PhantomPlugin
|
||||
from Tank.Plugins.Autostop import AbstractCriteria
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tank.Plugins.Autostop import AutostopWidget
|
||||
|
||||
from collections import deque
|
||||
import logging
|
||||
import re
|
||||
|
||||
class TotalAutostopPlugin(AbstractPlugin, AggregateResultListener):
|
||||
SECTION='autostop'
|
||||
@staticmethod
|
||||
def get_key():
|
||||
return __file__;
|
||||
|
||||
def configure(self):
|
||||
autostop = self.core.get_plugin_of_type(AutostopPlugin)
|
||||
autostop.add_criteria_class(TotalFracTimeCriteria)
|
||||
autostop.add_criteria_class(TotalHTTPCodesCriteria)
|
||||
autostop.add_criteria_class(TotalNetCodesCriteria)
|
||||
autostop.add_criteria_class(TotalNegativeHTTPCodesCriteria)
|
||||
|
||||
def prepare_test(self):
|
||||
pass
|
||||
|
||||
def start_test(self):
|
||||
pass
|
||||
|
||||
def end_test(self, retcode):
|
||||
pass
|
||||
|
||||
class TotalFracTimeCriteria(AbstractCriteria):
|
||||
@staticmethod
|
||||
def get_type_string():
|
||||
return 'total_time'
|
||||
|
||||
def __init__(self, autostop, param_str):
|
||||
AbstractCriteria.__init__(self)
|
||||
param = param_str.split(',')
|
||||
self.seconds_count = 0
|
||||
self.rt_limit = Utils.expand_to_milliseconds(param[0])
|
||||
self.frac = param[1][:-1]
|
||||
self.seconds_limit = Utils.expand_to_seconds(param[2])
|
||||
self.autostop = autostop
|
||||
self.data = deque()
|
||||
|
||||
def notify(self, aggregate_second):
|
||||
failcnt = 0
|
||||
cnt = 0
|
||||
for i in reversed(aggregate_second.overall.times_dist):
|
||||
if i['from'] >= self.rt_limit : failcnt += i['count'];
|
||||
cnt += i['count']
|
||||
value = float(failcnt) / cnt
|
||||
self.data.append(value)
|
||||
if len(self.data) > self.seconds_limit:
|
||||
self.data.popleft()
|
||||
self.real_frac = float(sum(self.data)) / len(self.data) * 100
|
||||
if self.real_frac >= float(self.frac) and len(self.data) >= self.seconds_limit:
|
||||
self.cause_second = aggregate_second
|
||||
self.log.debug(self.explain())
|
||||
self.autostop.add_counting(self)
|
||||
return True
|
||||
#raise ValueError("Hakuna Matata!")
|
||||
return False
|
||||
|
||||
def get_rc(self):
|
||||
return self.RC_TIME
|
||||
|
||||
def explain(self):
|
||||
items = (round(self.real_frac, 2), self.rt_limit, self.seconds_limit, self.cause_second.time)
|
||||
return "%s%% responses times higher than %sms for %ss, ended at: %s" % items
|
||||
|
||||
def widget_explain(self):
|
||||
items = (round(self.real_frac, 2), self.rt_limit, self.seconds_limit)
|
||||
return ("%s%% Times >%sms for %ss" % items, self.real_frac)
|
||||
|
||||
class TotalHTTPCodesCriteria(AbstractCriteria):
|
||||
@staticmethod
|
||||
def get_type_string():
|
||||
return 'total_http'
|
||||
|
||||
def __init__(self, autostop, param_str):
|
||||
AbstractCriteria.__init__(self)
|
||||
self.seconds_count = 0
|
||||
self.codes_mask = param_str.split(',')[0].lower()
|
||||
self.codes_regex = re.compile(self.codes_mask.replace("x", '.'))
|
||||
self.autostop = autostop
|
||||
self.data = deque()
|
||||
|
||||
level_str = param_str.split(',')[1].strip()
|
||||
if level_str[-1:] == '%':
|
||||
self.level = float(level_str[:-1])
|
||||
self.is_relative = True
|
||||
else:
|
||||
self.level = int(level_str)
|
||||
self.is_relative = False
|
||||
self.seconds_limit = Utils.expand_to_seconds(param_str.split(',')[2])
|
||||
|
||||
def notify(self, aggregate_second):
|
||||
matched_responses = self.count_matched_codes(self.codes_regex, aggregate_second.overall.http_codes)
|
||||
if self.is_relative:
|
||||
if aggregate_second.overall.RPS:
|
||||
matched_responses = float(matched_responses) / aggregate_second.overall.RPS * 100
|
||||
else:
|
||||
matched_responses = 1
|
||||
self.log.debug("HTTP codes matching mask %s: %s/%s", self.codes_mask, matched_responses, self.level)
|
||||
self.data.append(matched_responses)
|
||||
if len(self.data) > self.seconds_limit : self.data.popleft()
|
||||
|
||||
# based on moment
|
||||
# for i in self.data:
|
||||
# if i < self.level: return False
|
||||
# self.cause_second = aggregate_second
|
||||
# self.log.debug(self.explain())
|
||||
# self.autostop.add_counting(self)
|
||||
# return True
|
||||
|
||||
# based on avg
|
||||
x = 1
|
||||
if self.is_relative : x = len(self.data)
|
||||
if (sum(self.data) / x) >= self.level and len(self.data) >= self.seconds_limit:
|
||||
self.cause_second = aggregate_second
|
||||
self.log.debug(self.explain())
|
||||
self.autostop.add_counting(self)
|
||||
return True
|
||||
return False
|
||||
|
||||
def get_rc(self):
|
||||
return self.RC_HTTP
|
||||
|
||||
def get_level_str(self):
|
||||
if self.is_relative:
|
||||
level_str = str(self.level) + "%"
|
||||
else:
|
||||
level_str = self.level
|
||||
return level_str
|
||||
|
||||
def explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "%s codes count higher than %s for %ss, ended at: %s" % items
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "%s codes count higher than %s for %ss, started at: %s" % items
|
||||
|
||||
def widget_explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("HTTP %s>%s for %ss" % items, sum(self.data))
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("HTTP %s>%s for %ss" % items, 1.0)
|
||||
|
||||
class TotalNetCodesCriteria(AbstractCriteria):
|
||||
@staticmethod
|
||||
def get_type_string():
|
||||
return 'total_net'
|
||||
|
||||
def __init__(self, autostop, param_str):
|
||||
AbstractCriteria.__init__(self)
|
||||
self.seconds_count = 0
|
||||
self.codes_mask = param_str.split(',')[0].lower()
|
||||
self.codes_regex = re.compile(self.codes_mask.replace("x", '.'))
|
||||
self.autostop = autostop
|
||||
self.data = deque()
|
||||
|
||||
level_str = param_str.split(',')[1].strip()
|
||||
if level_str[-1:] == '%':
|
||||
self.level = float(level_str[:-1])
|
||||
self.is_relative = True
|
||||
else:
|
||||
self.level = int(level_str)
|
||||
self.is_relative = False
|
||||
self.seconds_limit = Utils.expand_to_seconds(param_str.split(',')[2])
|
||||
|
||||
|
||||
def notify(self, aggregate_second):
|
||||
codes = aggregate_second.overall.net_codes.copy()
|
||||
if '0' in codes.keys(): codes.pop('0')
|
||||
matched_responses = self.count_matched_codes(self.codes_regex, codes)
|
||||
if self.is_relative:
|
||||
if aggregate_second.overall.RPS:
|
||||
matched_responses = float(matched_responses) / aggregate_second.overall.RPS * 100
|
||||
self.log.debug("Net codes matching mask %s: %s%%/%s", self.codes_mask, round(matched_responses, 2), self.get_level_str())
|
||||
else:
|
||||
matched_responses = 1
|
||||
else : self.log.debug("Net codes matching mask %s: %s/%s", self.codes_mask, matched_responses, self.get_level_str())
|
||||
|
||||
self.data.append(matched_responses)
|
||||
if len(self.data) > self.seconds_limit : self.data.popleft()
|
||||
|
||||
x = 1
|
||||
if self.is_relative : x = len(self.data)
|
||||
if (sum(self.data) / x) >= self.level and len(self.data) >= self.seconds_limit:
|
||||
self.cause_second = aggregate_second
|
||||
self.log.debug(self.explain())
|
||||
self.autostop.add_counting(self)
|
||||
return True
|
||||
return False
|
||||
|
||||
def get_rc(self):
|
||||
return self.RC_NET
|
||||
|
||||
def get_level_str(self):
|
||||
if self.is_relative:
|
||||
level_str = str(self.level) + "%"
|
||||
else:
|
||||
level_str = str(self.level)
|
||||
return level_str
|
||||
|
||||
def explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "%s net codes count higher than %s for %ss, ended at: %s" % items
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "%s net codes count higher than %s for %ss, started at: %s" % items
|
||||
|
||||
def widget_explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("Net %s>%s for %ss" % items, self.level)
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("Net %s>%s for %ss" % items, self.level)
|
||||
|
||||
class TotalNegativeHTTPCodesCriteria(AbstractCriteria):
|
||||
@staticmethod
|
||||
def get_type_string():
|
||||
return 'negative_http'
|
||||
|
||||
def __init__(self, autostop, param_str):
|
||||
AbstractCriteria.__init__(self)
|
||||
self.seconds_count = 0
|
||||
self.codes_mask = param_str.split(',')[0].lower()
|
||||
self.codes_regex = re.compile(self.codes_mask.replace("x", '.'))
|
||||
self.autostop = autostop
|
||||
self.data = deque()
|
||||
|
||||
level_str = param_str.split(',')[1].strip()
|
||||
if level_str[-1:] == '%':
|
||||
self.level = float(level_str[:-1])
|
||||
self.is_relative = True
|
||||
else:
|
||||
self.level = int(level_str)
|
||||
self.is_relative = False
|
||||
self.seconds_limit = Utils.expand_to_seconds(param_str.split(',')[2])
|
||||
|
||||
def notify(self, aggregate_second):
|
||||
matched_responses = self.count_matched_codes(self.codes_regex, aggregate_second.overall.http_codes)
|
||||
if self.is_relative:
|
||||
if aggregate_second.overall.RPS:
|
||||
matched_responses = float(matched_responses) / aggregate_second.overall.RPS * 100
|
||||
matched_responses = 100 - matched_responses
|
||||
else:
|
||||
matched_responses = 1
|
||||
self.log.debug("HTTP codes matching mask not %s: %s/%s", self.codes_mask, round(matched_responses, 1), self.level)
|
||||
else :
|
||||
matched_responses = aggregate_second.overall.RPS - matched_responses
|
||||
self.log.debug("HTTP codes matching mask not %s: %s/%s", self.codes_mask, matched_responses, self.level)
|
||||
self.data.append(matched_responses)
|
||||
if len(self.data) > self.seconds_limit : self.data.popleft()
|
||||
|
||||
x = 1
|
||||
if self.is_relative : x = len(self.data)
|
||||
if (sum(self.data) / x) >= self.level and len(self.data) >= self.seconds_limit:
|
||||
self.cause_second = aggregate_second
|
||||
self.log.debug(self.explain())
|
||||
self.autostop.add_counting(self)
|
||||
return True
|
||||
return False
|
||||
|
||||
def get_rc(self):
|
||||
return self.RC_HTTP
|
||||
|
||||
def get_level_str(self):
|
||||
if self.is_relative:
|
||||
level_str = str(self.level) + "%"
|
||||
else:
|
||||
level_str = self.level
|
||||
return level_str
|
||||
|
||||
def explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "Not %s codes count higher than %s for %ss, ended at: %s" % items
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit, self.cause_second.overall.time)
|
||||
return "Not %s codes count higher than %s for %ss, started at: %s" % items
|
||||
|
||||
def widget_explain(self):
|
||||
if self.is_relative:
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("HTTP not %s>%s for %ss" % items, sum(self.data))
|
||||
items = (self.codes_mask, self.get_level_str(), self.seconds_limit)
|
||||
return ("HTTP not %s>%s for %ss" % items, 1.0)
|
||||
124
Tests/TotalAutostopTest.py
Normal file
124
Tests/TotalAutostopTest.py
Normal file
@ -0,0 +1,124 @@
|
||||
from Tank.Core import TankCore
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, SecondAggregateData
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tank.Plugins.TotalAutostop import TotalAutostopPlugin
|
||||
from Tests.TankTests import TankTestCase
|
||||
import os
|
||||
import tempfile
|
||||
import unittest
|
||||
|
||||
|
||||
class TotalAutostopTestCase(TankTestCase):
|
||||
def setUp(self):
|
||||
self.core = TankCore()
|
||||
name = tempfile.mkstemp()[1]
|
||||
self.core.config.set_out_file(name)
|
||||
self.core.load_configs(['Tests/config/totalautostop.conf'])
|
||||
self.core.load_plugins()
|
||||
# self.core.plugins_configure()
|
||||
self.foo = self.core.get_plugin_of_type(TotalAutostopPlugin)
|
||||
# self.foo = TotalAutostopPlugin(self.core)
|
||||
|
||||
def tearDown(self):
|
||||
del self.foo
|
||||
self.foo = None
|
||||
|
||||
#def callback(self, data):
|
||||
#self.data = SecondAggregateData(data)
|
||||
|
||||
def test_run(self):
|
||||
data = list()
|
||||
|
||||
for i in range(0, 20):
|
||||
data.append(SecondAggregateData())
|
||||
data[i].overall.times_dist = [
|
||||
{'count': 10, 'to': 10, 'from': 0},
|
||||
{'count': i+1, 'to': 20, 'from': 10}]
|
||||
|
||||
self.foo.core.set_option(TotalAutostopPlugin.SECTION, "autostop", "total_time(10ms,10%,3s)")
|
||||
|
||||
self.foo.configure()
|
||||
self.foo.prepare_test()
|
||||
|
||||
self.foo.start_test()
|
||||
|
||||
Atstp
|
||||
|
||||
print self.core.get_plugin_of_type(AutostopPlugin).custom_criterias
|
||||
for x in data:
|
||||
self.core.get_plugin_of_type(AutostopPlugin).aggregate_second(x)
|
||||
#print x.overall.times_dist[-1]['count']
|
||||
if self.foo.is_test_finished() < 0:
|
||||
raise RuntimeError()
|
||||
self.foo.end_test(0)
|
||||
|
||||
# def test_run_time(self):
|
||||
# data = self.get_test_second()
|
||||
|
||||
# self.foo.core.set_option(self.foo.SECTION, "autostop", "schi_time (100ms, 90%, 3s)\n")
|
||||
|
||||
# self.foo.configure()
|
||||
# self.foo.prepare_test()
|
||||
|
||||
# self.foo.start_test()
|
||||
# for n in range(1, 15):
|
||||
# self.foo.aggregate_second(data)
|
||||
# if self.foo.is_test_finished() < 0:
|
||||
# raise RuntimeError()
|
||||
# self.foo_end_test(0)
|
||||
|
||||
# def test_run_http(self):
|
||||
# data = self.get_test_second()
|
||||
|
||||
# self.foo.core.set_option(self.foo.SECTION, "autostop", "http (200, 10, 5 )\nhttp (3xx, 1.5%, 10m)")
|
||||
|
||||
# self.foo.configure()
|
||||
# self.foo.prepare_test()
|
||||
|
||||
# self.foo.start_test()
|
||||
# for n in range(1, 15):
|
||||
# self.foo.aggregate_second(data)
|
||||
# if self.foo.is_test_finished() < 0:
|
||||
# raise RuntimeError()
|
||||
# self.foo.end_test(0)
|
||||
|
||||
# def test_run_net(self):
|
||||
# data = self.get_test_second()
|
||||
|
||||
# self.foo.core.set_option(self.foo.SECTION, "autostop", "net (71, 1, 5)\nnet (xx, 1.5%, 10m )")
|
||||
|
||||
# self.foo.configure()
|
||||
# self.foo.prepare_test()
|
||||
|
||||
# self.foo.start_test()
|
||||
# for n in range(1, 15):
|
||||
# self.foo.aggregate_second(data)
|
||||
# if self.foo.is_test_finished() < 0:
|
||||
# raise RuntimeError()
|
||||
# self.foo.end_test(0)
|
||||
|
||||
# def test_run_inst(self):
|
||||
# data = self.get_test_second()
|
||||
|
||||
# self.foo.core.set_option(self.foo.SECTION, "autostop", "instances (5, 5)\ninstances (90%, 10m)")
|
||||
|
||||
# self.foo.configure()
|
||||
# self.foo.prepare_test()
|
||||
|
||||
# self.foo.start_test()
|
||||
# for n in range(1, 15):
|
||||
# self.foo.aggregate_second(data)
|
||||
# if self.foo.is_test_finished() < 0:
|
||||
# raise RuntimeError()
|
||||
# self.foo.end_test(0)
|
||||
|
||||
# def test_run_multiconf(self):
|
||||
# self.foo.core.set_option(self.foo.SECTION, "autostop", "instances (5, 5)\ninstances (90%, 10m) instances (90%, 10m)")
|
||||
|
||||
# self.foo.configure()
|
||||
# self.foo.prepare_test()
|
||||
# self.assertEquals(3, len(self.foo.criterias))
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
||||
34
Tests/TotalFracTimeCriteriaTest.py
Normal file
34
Tests/TotalFracTimeCriteriaTest.py
Normal file
@ -0,0 +1,34 @@
|
||||
from Tank.Core import TankCore
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, SecondAggregateData
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tests.TankTests import TankTestCase
|
||||
from Tank.Plugins.TotalAutostop import TotalFracTimeCriteria
|
||||
import os
|
||||
import tempfile
|
||||
import unittest
|
||||
|
||||
|
||||
class TotalFracTimeCriteriaTest(TankTestCase):
|
||||
def setUp(self):
|
||||
self.criteria = TotalFracTimeCriteria(None, "10ms, 50%, 3s")
|
||||
|
||||
def tearDown(self):
|
||||
del self.criteria
|
||||
self.criteria = None
|
||||
def test_run(self):
|
||||
data = list()
|
||||
for i in range(0,20):
|
||||
data = SecondAggregateData()
|
||||
data.time = "2012-09-25 18:18:18"
|
||||
data.overall.times_dist = [
|
||||
{'count': 10, 'to': 10, 'from': 0},
|
||||
{'count': i+1, 'to': 20, 'from': 10}]
|
||||
try:
|
||||
self.criteria.notify(data)
|
||||
except:
|
||||
break
|
||||
if i != 11 : raise RuntimeError()
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
||||
51
Tests/TotalHTTPCodesCriteriaTest.py
Normal file
51
Tests/TotalHTTPCodesCriteriaTest.py
Normal file
@ -0,0 +1,51 @@
|
||||
from Tank.Core import TankCore
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, SecondAggregateData
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tests.TankTests import TankTestCase
|
||||
from Tank.Plugins.TotalAutostop import TotalHTTPCodesCriteria
|
||||
import os
|
||||
import tempfile
|
||||
import unittest
|
||||
|
||||
|
||||
class TotalHTTPCodesCriteriaTest(TankTestCase):
|
||||
def setUp(self):
|
||||
self.relcriteria = TotalHTTPCodesCriteria(None, "50x, 10%, 3s")
|
||||
self.abscriteria = TotalHTTPCodesCriteria(None, "50x, 30, 4s")
|
||||
|
||||
def tearDown(self):
|
||||
del self.relcriteria
|
||||
self.relcriteria = None
|
||||
|
||||
del self.abscriteria
|
||||
self.abscriteria = None
|
||||
|
||||
def test_run_relative(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 100 + i*2
|
||||
data.overall.http_codes = {'200': 100, '501': i, '503': i}
|
||||
try:
|
||||
self.relcriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 7 : raise RuntimeError()
|
||||
|
||||
def test_run_absolute(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 100 + i*2
|
||||
data.overall.http_codes = {'200': 100, '501': i, '503': i}
|
||||
try:
|
||||
self.abscriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 6 : raise RuntimeError()
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
50
Tests/TotalNegativeHTTPCodesCriteriaTest.py
Normal file
50
Tests/TotalNegativeHTTPCodesCriteriaTest.py
Normal file
@ -0,0 +1,50 @@
|
||||
from Tank.Core import TankCore
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, SecondAggregateData
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tests.TankTests import TankTestCase
|
||||
from Tank.Plugins.TotalAutostop import TotalNegativeHTTPCodesCriteria
|
||||
import os
|
||||
import tempfile
|
||||
import unittest
|
||||
|
||||
|
||||
class TotalNegativeHTTPCodesCriteriaTest(TankTestCase):
|
||||
def setUp(self):
|
||||
self.relcriteria = TotalNegativeHTTPCodesCriteria(None, "2xx, 10%, 3s")
|
||||
self.abscriteria = TotalNegativeHTTPCodesCriteria(None, "20x, 30, 4s")
|
||||
|
||||
def tearDown(self):
|
||||
del self.relcriteria
|
||||
self.relcriteria = None
|
||||
|
||||
del self.abscriteria
|
||||
self.abscriteria = None
|
||||
|
||||
def test_run_relative(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 200 + 2*i
|
||||
data.overall.http_codes = {'200': 100, '201': 100, '501': i, '503': i}
|
||||
try:
|
||||
self.relcriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 13 : raise RuntimeError()
|
||||
|
||||
def test_run_absolute(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 200 + 2*i
|
||||
data.overall.http_codes = {'200': 100, '201': 100, '302': i*2}
|
||||
try:
|
||||
self.abscriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 6 : raise RuntimeError()
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
52
Tests/TotalNetCodesCriteriaTest.py
Normal file
52
Tests/TotalNetCodesCriteriaTest.py
Normal file
@ -0,0 +1,52 @@
|
||||
from Tank.Core import TankCore
|
||||
from Tank.Plugins.Aggregator import AggregatorPlugin, SecondAggregateData
|
||||
from Tank.Plugins.Autostop import AutostopPlugin
|
||||
from Tests.TankTests import TankTestCase
|
||||
from Tank.Plugins.TotalAutostop import TotalNetCodesCriteria
|
||||
import os
|
||||
import tempfile
|
||||
import unittest
|
||||
|
||||
|
||||
class TotalNetCodesCriteriaTest(TankTestCase):
|
||||
def setUp(self):
|
||||
self.relcriteria = TotalNetCodesCriteria(None, "110, 37%, 3s")
|
||||
self.abscriteria = TotalNetCodesCriteria(None, "71, 30, 2s")
|
||||
|
||||
def tearDown(self):
|
||||
del self.relcriteria
|
||||
self.relcriteria = None
|
||||
|
||||
del self.abscriteria
|
||||
self.abscriteria = None
|
||||
|
||||
def test_run_relative(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 100 + i**2
|
||||
data.overall.net_codes = {'0': 100, '110': i**2}
|
||||
try:
|
||||
self.relcriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 9 : raise RuntimeError()
|
||||
|
||||
def test_run_absolute(self):
|
||||
data = list()
|
||||
for i in range(1,20):
|
||||
data = SecondAggregateData()
|
||||
data.overall.time = "2012-09-25 18:18:18"
|
||||
data.overall.RPS = 100 + i**2 + i
|
||||
data.overall.net_codes = {'0': 100, '71': i**2, '110' : i}
|
||||
try:
|
||||
self.abscriteria.notify(data)
|
||||
except AttributeError:
|
||||
break
|
||||
if i != 5 : raise RuntimeError()
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest.main()
|
||||
|
||||
Loading…
Reference in New Issue
Block a user