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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
#!/usr/bin/env python
##############################################################################
# Copyright (c) 2017 Huawei Technologies Co.,Ltd and others.
#
# 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
##############################################################################
'''This file is to do data-plane baseline test for
VM pair life-cycle events using netperf.
Testing steps are summarized below:
1. run_test load testcase configuration
2. Bottlenecks eliminates the environments limits/constraints
3. Bottlenecks tells Yardstick to prepare environment
4. Bottlenecks tells Yardstick to run test
3.1 to create stack
3.2 to install netperf
3.3 to send/forward packets for t2 seconds
3.4 record results and detroy stack
3.4 after every t1 seconds goto 3.1 and repeat the workflow
5. Bottlenecks collects testing results from Yardstick
6. Bottlenecks tells Yardstick to stop when time ends
or system fails the test
7. Bottlenecks sends testing data to bottlenecks-elk'''
import utils.logger as log
import uuid
import json
import os
import sys
import time
# import threading
# import datetime
import Queue
# from utils.parser import Parser as conf_parser
import utils.env_prepare.quota_prepare as quota_prepare
import utils.env_prepare.stack_prepare as stack_prepare
import utils.infra_setup.runner.yardstick as runner_yardstick
# import testsuites.posca.testcase_dashboard.posca_factor_throughputs as DashBoard # noqa
import utils.infra_setup.runner.docker_env as docker_env
# --------------------------------------------------
# logging configuration
# --------------------------------------------------
LOG = log.Logger(__name__).getLogger()
test_dict = {
"action": "runTestCase",
"args": {
"opts": {
"task-args": {}
},
"testcase": "netperf_bottlenecks"
}
}
testfile = os.path.basename(__file__)
testcase, file_format = os.path.splitext(testfile)
cidr = "/home/opnfv/repos/yardstick/samples/netperf_soak.yaml"
runner_DEBUG = True
q = Queue.Queue()
def env_pre(test_config):
test_yardstick = False
if "yardstick" in test_config["contexts"].keys():
test_yardstick = True
stack_prepare._prepare_env_daemon(test_yardstick)
quota_prepare.quota_env_prepare()
LOG.info("yardstick environment prepare!")
if(test_config["contexts"]['yardstick_envpre']):
stdout = runner_yardstick.yardstick_image_prepare()
LOG.debug(stdout)
def do_test(con_dic):
func_name = sys._getframe().f_code.co_name
out_file = ("/tmp/yardstick_" + str(uuid.uuid4()) + ".out")
parameter_info = dict(test_time=con_dic["scenarios"]["vim_pair_ttl"])
yardstick_container = docker_env.yardstick_info['container']
cmd = runner_yardstick.yardstick_command_parser(debug=runner_DEBUG,
cidr=cidr,
outfile=out_file,
parameter=parameter_info)
stdout = docker_env.docker_exec_cmd(yardstick_container, cmd)
LOG.info(stdout)
out_value = 0
loop_value = 0
while loop_value < 60:
time.sleep(2)
loop_value = loop_value + 1
with open(out_file) as f:
data = json.load(f)
if data["status"] == 1:
LOG.info("Success run yardstick netperf_soak test!")
out_value = 1
break
elif data["status"] == 2:
LOG.error("Failed run yardstick netperf_soak test!")
out_value = 0
break
q.put((out_value, func_name))
return out_value
def config_to_result(num, out_num, during_date, result):
testdata = {}
test_result = {}
test_result["number_of_stacks"] = float(num)
test_result["success_times"] = out_num
test_result["success_rate"] = out_num / num
test_result["duration_time"] = during_date
test_result["result"] = result
testdata["data_body"] = test_result
testdata["testcase"] = testcase
return testdata
def func_run(con_dic):
test_date = do_test(con_dic)
return test_date
def run(test_config):
con_dic = test_config["load_manager"]
env_pre(test_config)
LOG.info("yardstick environment prepare done!")
return func_run(con_dic)
|
