From 61aafcb0ca6cab9c25d2df7d409f4fa8716ebe5f Mon Sep 17 00:00:00 2001 From: Yang Yu Date: Mon, 16 Apr 2018 17:19:44 +0800 Subject: Lazy creation of VM pairs for soak throuputs tests Add the lazy creation progress of VM pairs while testing dataplane traffic using netperf Change-Id: I3228ff444ea074b99cb1afaec138191358064e40 Signed-off-by: Yang Yu --- .../posca_factor_soak_throughputs.py | 92 ++++++++++++++++++---- 1 file changed, 76 insertions(+), 16 deletions(-) (limited to 'testsuites/posca/testcase_script') diff --git a/testsuites/posca/testcase_script/posca_factor_soak_throughputs.py b/testsuites/posca/testcase_script/posca_factor_soak_throughputs.py index b45ce932..2fd35006 100644 --- a/testsuites/posca/testcase_script/posca_factor_soak_throughputs.py +++ b/testsuites/posca/testcase_script/posca_factor_soak_throughputs.py @@ -28,18 +28,16 @@ import utils.logger as log import uuid import json import os -import sys import time -# import threading -# import datetime +import threading +import datetime import Queue -# from utils.parser import Parser as conf_parser +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 +import math # -------------------------------------------------- # logging configuration @@ -76,7 +74,6 @@ def env_pre(test_config): 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'] @@ -93,25 +90,30 @@ def do_test(con_dic): loop_value = loop_value + 1 with open(out_file) as f: data = json.load(f) - if data["status"] == 1: + if data["result"]["criteria"] == "PASS": LOG.info("Success run yardstick netperf_soak test!") out_value = 1 break - elif data["status"] == 2: + elif data["result"]["criteria"] == "FAIL": LOG.error("Failed run yardstick netperf_soak test!") out_value = 0 break - q.put((out_value, func_name)) + q.put((out_value, data["result"]["testcases"])) return out_value -def config_to_result(num, out_num, during_date, result): +def config_to_result( + test_duration, added_duration, vim_pair_ttl, + vim_pair_lazy_cre_delay, + vim_pair_num, vim_pair_success_num, 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["test_duration"] = test_duration + test_result["sum_duration"] = added_duration + test_result["vim_pair_ttl"] = vim_pair_ttl + test_result["vim_pair_cre_interval"] = vim_pair_lazy_cre_delay + test_result["vim_pair_num"] = vim_pair_num + test_result["vim_pair_success_num"] = vim_pair_success_num test_result["result"] = result testdata["data_body"] = test_result testdata["testcase"] = testcase @@ -129,4 +131,62 @@ def run(test_config): env_pre(test_config) LOG.info("yardstick environment prepare done!") - return func_run(con_dic) + test_duration = float( + con_dic["scenarios"]["test_duration_hours"]) * 3600 + vim_pair_ttl = float( + con_dic["scenarios"]["vim_pair_ttl"]) + vim_pair_lazy_cre_delay = float( + con_dic["scenarios"]["vim_pair_lazy_cre_delay"]) + vim_pair_num = int(math.ceil( + (test_duration - vim_pair_ttl) / vim_pair_lazy_cre_delay + ) + 1) + + threadings = [] + result = [] + vim_pair_success_num = 0 + + start_time = datetime.datetime.now() + + LOG.info("Data-path test duration are %i seconds", test_duration) + LOG.info("TTL of each VM pair are %i seconds", vim_pair_ttl) + LOG.info("Creation delay between VM pairs are %i seconds", + vim_pair_lazy_cre_delay) + LOG.info("Number of VM pairs to be created are %i", vim_pair_num) + + for vim_pair_index in xrange(0, vim_pair_num): + index_thread = threading.Thread(target=func_run, + args=(con_dic,)) + threadings.append(index_thread) + index_thread.start() + vim_pair_error = False + for wait_time in xrange(0, int(vim_pair_lazy_cre_delay)): + time.sleep(1) + while not q.empty(): + result.append(q.get()) + for one_result in result: + if '0' == one_result[0]: + vim_pair_error = True + break + if vim_pair_error: + break + for one_thread in threadings: + one_thread.join() + while not q.empty(): + result.append(q.get()) + for item in result: + vim_pair_success_num += int(item[0]) + + end_time = datetime.datetime.now() + added_duration = (end_time - start_time).seconds + LOG.info("Number of success VM pairs/threads are %s out %s ", + vim_pair_success_num, vim_pair_num) + + return_result = config_to_result( + test_duration, added_duration, vim_pair_ttl, + vim_pair_lazy_cre_delay, + vim_pair_num, vim_pair_success_num, result + ) + + conf_parser.result_to_file(return_result, test_config["out_file"]) + + return vim_pair_error -- cgit 1.2.3-korg