From b60b5daa668899d528c70c1d4858421eb71e73a6 Mon Sep 17 00:00:00 2001 From: liyin Date: Tue, 25 Oct 2016 00:39:22 -0400 Subject: Modify POSCA code into PEP8 style JIRA: BOTTLENECK-102 Modify all the code in the testcase POSCA into PEP8 style. Using more standard way to realize our function. Change-Id: Ic014678db454b8a36b36395c32b4769f6cf700be Signed-off-by: liyin --- testsuites/posca/run_posca.py | 22 ++-- .../testcase_script/posca_factor_cpu_burden.py | 120 ++++++++++-------- .../testcase_script/posca_factor_rx_cache_size.py | 110 ++++++++++------- .../testcase_script/posca_factor_rx_pkt_size.py | 123 ++++++++++++------- .../posca_factor_system_bandwidth.py | 134 +++++++++++++-------- .../testcase_script/posca_factor_tx_cache_size.py | 113 +++++++++-------- .../testcase_script/posca_factor_tx_pkt_size.py | 127 +++++++++++-------- 7 files changed, 450 insertions(+), 299 deletions(-) (limited to 'testsuites') diff --git a/testsuites/posca/run_posca.py b/testsuites/posca/run_posca.py index 9f90b3c7..48376b54 100755 --- a/testsuites/posca/run_posca.py +++ b/testsuites/posca/run_posca.py @@ -8,32 +8,36 @@ # http://www.apache.org/licenses/LICENSE-2.0 ############################################################################## -import os import sys import subprocess INTERPRETER = "/usr/bin/python" -#------------------------------------------------------ +# ------------------------------------------------------ # run posca testcase # ------------------------------------------------------ + + def posca_run(arg): - print "========== run posca ===========" + print("========== run posca ==========") if(arg == "factor_system_bandwidth"): - print "========== run posca_system_bandwidth ===========" - cmd = '/home/opnfv/bottlenecks/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py' - pargs = [INTERPRETER,cmd] + print("========== run posca_system_bandwidth ===========") + cmd = '/home/opnfv/bottlenecks/testsuites/posca/testcase_script/\ + posca_factor_system_bandwidth.py' + pargs = [INTERPRETER, cmd] sub_result = subprocess.Popen(pargs) sub_result.wait() + def posca_env_check(): - print "========== posca env check ===========" + print("========== posca env check ===========") + def main(): - para_testname = sys.argv[0] + # para_testname = sys.argv[0] para_test_arg = sys.argv[1] posca_env_check() posca_run(para_test_arg) sys.exit(0) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_cpu_burden.py b/testsuites/posca/testcase_script/posca_factor_cpu_burden.py index 0b3b2319..8a51a3d2 100644 --- a/testsuites/posca/testcase_script/posca_factor_cpu_burden.py +++ b/testsuites/posca/testcase_script/posca_factor_cpu_burden.py @@ -15,103 +15,121 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_cpu_burden.yaml") + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() - -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" - -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6): - save_dic={} - save_dic['tx_pkt_size']=input_1 - save_dic['rx_cache_size']=input_2 - save_dic['tx_cache_size']=input_3 - save_dic['throughput ']=input_4 - save_dic['latency']=input_5 - save_dic['cpu_load']=input_6 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_cpu_burden_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, input_3, + input_4, input_5, input_6): + save_dic = {} + save_dic['tx_pkt_size'] = input_1 + save_dic['rx_cache_size'] = input_2 + save_dic['tx_cache_size'] = input_3 + save_dic['throughput '] = input_4 + save_dic['latency'] = input_5 + save_dic['cpu_load'] = input_6 + with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\ + factor_tx_cache_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") + def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_throughput']=config.get("config","throughput") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_pkt_s']=config.get("config","pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") - - con_dic['test_rx_flavor']=config.get("flavor_config","rx_flavor") - con_dic['test_tx_flavor']=config.get("flavor_config","tx_flavor") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_throughput'] = config.get("config", "throughput") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_pkt_s'] = config.get("config", "pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") + con_dic['test_rx_flavor'] = config.get("flavor_config", "rx_flavor") + con_dic['test_tx_flavor'] = config.get("flavor_config", "tx_flavor") return con_dic + def posca_run(con_dic): - print "========== run posca system bandwidth ===========" + print("========== run posca system bandwidth ===========") test_pkt_s_a = con_dic['test_pkt_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + test_rx_cache_s_e = con_dic['test_rx_cache_s'].split(',') + test_tx_cache_s_e = con_dic['test_tx_cache_s'].split(',') + time_new = time.strftime('%H_%M', time.localtime(time.time())) for test_pkt_s_e in test_pkt_s_a: - print "Package size %s"%(test_pkt_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],con_dic['test_rx_flavor'],con_dic['test_tx_flavor'],test_pkt_s_e,test_pkt_s_e)) + print("Package size %s") % (test_pkt_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e)) order_result = order_excute.read() - test_id = order_result.find("task_id") + task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id)) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\ + sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) test_result = cmd_excute.read() bandwidth = test_result.find("bandwidth") cpu_load = test_result.find("cpu_load") latency = test_result.find("latency") - posca_output_result(time_new,test_pkt_s_e,con_dic['test_rx_cache_s'],con_dic['test_tx_cache_s']) - if (bandwidth < con_dic['test_throughput']) and (latency < con_dic['test_latency']): + posca_output_result(time_new, test_pkt_s_e, con_dic['test_rx_cache_s'], + con_dic['test_tx_cache_s']) + if (bandwidth < con_dic['test_throughput\ + ']) and (latency < con_dic['test_latency']): if cpu_load > con_dic['test_cpu_load']: return True else: - print "%s,%s,%s"%(bandwidth,latency,cpu_load) + print("%s,%s,%s") % (bandwidth, latency, cpu_load) else: - print "%s,%s,%s"%(bandwidth,latency,cpu_load) + print("%s,%s,%s") % (bandwidth, latency, cpu_load) return False + def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist for \ + the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py b/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py index e049ad26..cfbd278e 100644 --- a/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py +++ b/testsuites/posca/testcase_script/posca_factor_rx_cache_size.py @@ -15,103 +15,123 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_rx_cache_size.yaml") + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5): - save_dic={} - save_dic['tx_pkt_size']=input_1 - save_dic['tx_cache_size']=input_2 - save_dic['throughput ']=input_3 - save_dic['latency']=input_4 - save_dic['cpu_load']=input_5 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_rx_cache_size_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, + input_3, input_4, input_5): + save_dic = {} + save_dic['tx_pkt_size'] = input_1 + save_dic['tx_cache_size'] = input_2 + save_dic['throughput '] = input_3 + save_dic['latency'] = input_4 + save_dic['cpu_load'] = input_5 + with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\ + factor_tx_cache_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") + def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_throughput']=config.get("config","throughput") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_pkt_s']=config.get("config","pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_throughput'] = config.get("config", "throughput") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_pkt_s'] = config.get("config", "pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") return con_dic + def posca_run(con_dic): - print "========== run posca system bandwidth ===========" + print("========== run posca system bandwidth ===========") test_pkt_s_a = con_dic['test_pkt_s'].split(',') test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',') + time_new = time.strftime('%H_%M', time.localtime(time.time())) bandwidth_tmp = 1 for test_pkt_s_e in test_pkt_s_a: for test_tx_cache_s_e in test_tx_cache_s_a: - print "Package size %s"%(test_pkt_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_pkt_s_e,test_pkt_s_e,test_tx_cache_s_e,con_dic['test_rx_cache_s'])) + print("Package size %s") % (test_pkt_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_pkt_s_e, test_rx_cache_s_a, + test_tx_cache_s_e)) order_result = order_excute.read() task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id)) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\ + sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) test_result = cmd_excute.read() bandwidth = test_result.find("bandwidth") cpu_load = test_result.find("cpu_load") latency = test_result.find("latency") - posca_output_result(time_new,test_pkt_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) - if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']): - if abs(bandwidth_tmp-bandwidth)/bandwidth <0.05: + posca_output_result(time_new, test_pkt_s_e, test_rx_cache_s_a, + bandwidth, latency, cpu_load) + if (cpu_load < con_dic['test_cpu_load\ + ']) and (latency < con_dic['test_latency']): + if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05): return True else: - print "%s,%s"%(bandwidth,test_tx_cache_s_e) + print("%s,%s") % (bandwidth, test_tx_cache_s_e) else: - print "%s,%s"%(bandwidth,test_tx_cache_s_e) + print("%s,%s") % (bandwidth, test_tx_cache_s_e) return False + def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist \ + for the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py b/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py index 61da136a..5de25949 100644 --- a/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py +++ b/testsuites/posca/testcase_script/posca_factor_rx_pkt_size.py @@ -15,108 +15,139 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_rx_pkt_size.yaml") + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6): - save_dic={} - save_dic['tx_pkt_size']=input_1 - save_dic['rx_cache_size']=input_2 - save_dic['tx_cache_size']=input_3 - save_dic['throughput']=input_4 - save_dic['latency']=input_5 - save_dic['cpu_load']=input_6 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_rx_pkt_size_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, input_3, + input_4, input_5, input_6): + save_dic = {} + save_dic['tx_pkt_size'] = input_1 + save_dic['rx_cache_size'] = input_2 + save_dic['tx_cache_size'] = input_3 + save_dic['throughput'] = input_4 + save_dic['latency'] = input_5 + save_dic['cpu_load'] = input_6 + with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\ + factor_tx_cache_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") + def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes") - con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes") + con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") return con_dic + def posca_run(con_dic): - print "========== run posca system bandwidth ===========" + print("========== run posca system bandwidth ===========") test_tx_pkt_s_a = con_dic['test_tx_pkt_s'].split(',') + test_rx_pkt_s_e = con_dic['test_rx_pkt_s'].split(',') test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',') test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + time_new = time.strftime('%H_%M', time.localtime(time.time())) bandwidth_tmp = 1 for test_rx_cache_s_e in test_rx_cache_s_a: for test_tx_cache_s_e in test_tx_cache_s_a: for test_tx_pkt_s_e in test_tx_pkt_s_a: - print "%s,%s,%s"%(test_tx_pkt_s_e,test_tx_cache_s_e,test_rx_cache_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e)) + print("%s,%s,%s") % (test_tx_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_rx_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e)) order_result = order_excute.read() task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id)) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\ + sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) test_result = cmd_excute.read() bandwidth = test_result.find("bandwidth") cpu_load = test_result.find("cpu_load") latency = test_result.find("latency") - posca_output_result(time_new,test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) - if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']): - if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05): - print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + posca_output_result(time_new, test_rx_pkt_s_e, + test_rx_cache_s_e, + bandwidth, latency, cpu_load) + if (cpu_load < con_dic['test_cpu_load\ + ']) and (latency < con_dic['test_latency']): + if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05): + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return True else: bandwidth_tmp = bandwidth else: - print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return False def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist \ + for the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py b/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py index 878fa2d4..f3e950b6 100644 --- a/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py +++ b/testsuites/posca/testcase_script/posca_factor_system_bandwidth.py @@ -15,109 +15,137 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_system_bandwidth.yaml") + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6): - save_dic={} - save_dic['tx_pkt_size']=input_1 - save_dic['rx_cache_size']=input_2 - save_dic['tx_cache_size']=input_3 - save_dic['throughput ']=input_4 - save_dic['latency']=input_5 - save_dic['cpu_load']=input_6 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_system_bandwidth_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, input_3, + input_4, input_5, input_6): + save_dic = {} + save_dic['tx_pkt_size'] = input_1 + save_dic['rx_cache_size'] = input_2 + save_dic['tx_cache_size'] = input_3 + save_dic['throughput '] = input_4 + save_dic['latency'] = input_5 + save_dic['cpu_load'] = input_6 + with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\ + factor_tx_cache_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") -def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" +def posca_config_read(config_str): + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes") - con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes") + con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") return con_dic + def posca_run(con_dic): - print "========== run posca system bandwidth ===========" + print("========== run posca system bandwidth ===========") + test_rx_pkt_s_e = 87380 test_tx_pkt_s_a = con_dic['test_tx_pkt_s'].split(',') - # test_rx_pkt_s_a = con_dic['test_rx_pkt_s'].split(',') test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',') test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + time_new = time.strftime('%H_%M', time.localtime(time.time())) bandwidth_tmp = 1 for test_rx_cache_s_e in test_rx_cache_s_a: for test_tx_cache_s_e in test_tx_cache_s_a: for test_tx_pkt_s_e in test_tx_pkt_s_a: - print "%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e)) + print("%s,%s,%s") % (test_tx_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_rx_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e)) order_result = order_excute.read() - test_id = order_result.find("task_id") + task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id)) - test_result = cmd_excute.read() - bandwidth = test_result.find("bandwidth") - cpu_load = test_result.find("cpu_load") - latency = test_result.find("latency") - posca_output_result(time_new,test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) - if (cpu_load < con_dic['test_cpu_load']) and (latency < con_dic['test_latency']): - if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05): - print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\ + sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) + bandwidth = cmd_excute.find("bandwidth") + cpu_load = cmd_excute.find("cpu_load") + latency = cmd_excute.find("latency") + posca_output_result(time_new, test_rx_pkt_s_e, + test_rx_cache_s_e, + bandwidth, latency, cpu_load) + if (cpu_load < con_dic['test_cpu_load\ + ']) and (latency < con_dic['test_latency']): + if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05): + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return True else: bandwidth_tmp = bandwidth else: - print "%s,%s,%s,%s,%s,%s"%(test_tx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return True def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist for \ + the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py b/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py index 525f91de..a8d1a485 100644 --- a/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py +++ b/testsuites/posca/testcase_script/posca_factor_tx_cache_size.py @@ -15,103 +15,122 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_tx_cache_size.yaml") + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5): - save_dic={} - save_dic['tx_pkt_size']=input_1 - save_dic['rx_cache_size']=input_2 - save_dic['throughput ']=input_3 - save_dic['latency']=input_4 - save_dic['cpu_load']=input_5 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_tx_cache_size_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, input_3, input_4, input_5): + save_dic = {} + save_dic['tx_pkt_size'] = input_1 + save_dic['rx_cache_size'] = input_2 + save_dic['throughput '] = input_3 + save_dic['latency'] = input_4 + save_dic['cpu_load'] = input_5 + with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/\ + factor_tx_cache_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") -def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" +def posca_config_read(config_str): + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_throughput']=config.get("config","throughput") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_pkt_s']=config.get("config","pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_throughput'] = config.get("config", "throughput") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_pkt_s'] = config.get("config", "pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") return con_dic + def posca_run(con_dic): - print "========== run posca system bandwidth ===========" + print("========== run posca system bandwidth ===========") test_pkt_s_a = con_dic['test_pkt_s'].split(',') test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + test_tx_cache_s_e = con_dic['test_tx_cache_s'].split(',') + time_new = time.strftime('%H_%M', time.localtime(time.time())) bandwidth_tmp = 1 for test_pkt_s_e in test_pkt_s_a: for test_rx_cache_s_e in test_rx_cache_s_a: - print "Package size %s"%(test_pkt_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_pkt_s_e,test_pkt_s_e,con_dic['test_tx_cache_s'],test_rx_cache_s_e)) + print("Package size %s") % (test_pkt_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e)) order_result = order_excute.read() - test_id = order_result.find("task_id") + task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],test_id)) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/testre\ + sults?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) test_result = cmd_excute.read() bandwidth = test_result.find("bandwidth") cpu_load = test_result.find("cpu_load") latency = test_result.find("latency") - posca_output_result(time_new,test_pkt_s_e,test_rx_cache_s_e,bandwidth,latency,cpu_load) - if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']): - if abs(bandwidth_tmp-bandwidth)/bandwidth <0.05: + posca_output_result(time_new, test_pkt_s_e, test_rx_cache_s_e, + bandwidth, latency, cpu_load) + if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_\ + throughput'] > 0.05) and (latency < con_dic['test_\ + latency']) and (cpu_load < con_dic['test_cpu_load']): + if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05): return True else: - print "%s,%s"%(bandwidth,test_rx_cache_s_e) + print("%s,%s") % (bandwidth, test_rx_cache_s_e) else: - print "%s,%s"%(bandwidth,test_rx_cache_s_e) + print("%s,%s") % (bandwidth, test_rx_cache_s_e) return False + def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist for\ + the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() diff --git a/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py b/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py index 4b44c853..47cc5e75 100644 --- a/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py +++ b/testsuites/posca/testcase_script/posca_factor_tx_pkt_size.py @@ -15,108 +15,139 @@ import logging import ConfigParser import json -#------------------------------------------------------ +# ------------------------------------------------------ # parser for configuration files in each test case # ------------------------------------------------------ parser = argparse.ArgumentParser() -parser.add_argument("-c", "--conf", - help="configuration files for the testcase, in yaml format", - default="/home/opnfv/bottlenecks/testsuites/posca/testcase_cfg/posca_factor_tx_pkt_size.yaml") +parser.add_argument("-c", + "--conf", + help="configuration files for the testcase,\ + in yaml format", + default="/home/opnfv/bottlenecks/testsuites/posca/\ + testcase_cfg/posca_factor_tx_pkt_size.yaml") args = parser.parse_args() -cmd="curl -i" -order_arg="-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \"args\": \"../samples/netperf.yaml\"}'" +cmd = "curl -i" +order_arg = "-H \"Content-Type: application/json\" -X POST -d \'{\"cmd\": \ + \"start\", \"opts\":{\"output-file\": \"/tem/yardstick.out\"}, \ + \"args\": \"../samples/netperf.yaml\"}'" -#-------------------------------------------------- +# -------------------------------------------------- # logging configuration -#-------------------------------------------------- +# -------------------------------------------------- logger = logging.getLogger(__name__) + def posca_env_check(): - print "========== posca system bandwidth env check ===========" - if os.path.exists(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/'): + print("========== posca system bandwidth env check ===========") + filepath = r"/home/opnfv/bottlenecks/testsuites/posca/test_result/" + if os.path.exists(filepath): return True else: os.mkdirs(r'/home/opnfv/bottlenecks/testsuites/posca/test_result/') -def posca_output_result(time_new,input_1,input_2,input_3,input_4,input_5,input_6): - save_dic={} - save_dic['rx_pkt_size']=input_1 - save_dic['tx_cache_size']=input_2 - save_dic['tx_cache_size']=input_3 - save_dic['throughput']=input_4 - save_dic['latency']=input_5 - save_dic['cpu_load']=input_6 - with open("/home/opnfv/bottlenecks/testsuites/posca/test_result/factor_tx_pkt_size_%s.json"%(time_new),"a") as f: - f.write(json.dumps(save_dic,f)) + +def posca_output_result(time_new, input_1, input_2, input_3, + input_4, input_5, input_6): + save_dic = {} + save_dic['rx_pkt_size'] = input_1 + save_dic['tx_cache_size'] = input_2 + save_dic['tx_cache_size'] = input_3 + save_dic['throughput'] = input_4 + save_dic['latency'] = input_5 + save_dic['cpu_load'] = input_6 + with open("/home/opnfv/bottlenecks/testsuites/posca/\ + test_result/factor_tx_pkt_size_%s.json" % (time_new), "a") as f: + f.write(json.dumps(save_dic, f)) f.write("\n") + def posca_config_read(config_str): - print "========== posca system bandwidth config read ===========" + print("========== posca system bandwidth config read ===========") con_dic = {} config = ConfigParser.ConfigParser() - with open(config_str,"rd") as cfgfile: + with open(config_str, "rd") as cfgfile: config.readfp(cfgfile) - con_dic['test_ip']=config.get("config","test_ip") - con_dic['test_tool']=config.get("config","tool") - con_dic['test_time']=config.get("config","test_time") - con_dic['test_protocol']=config.get("config","protocol") - con_dic['test_tx_pkt_s']=config.get("config","tx pkt sizes") - con_dic['test_rx_pkt_s']=config.get("config","rx pkt sizes") - con_dic['test_tx_cache_s']=config.get("config","tx cache sizes") - con_dic['test_rx_cache_s']=config.get("config","rx cache sizes") - con_dic['test_cpu_load']=config.get("config","cpu load") - con_dic['test_latency']=config.get("config","latency") + con_dic['test_ip'] = config.get("config", "test_ip") + con_dic['test_tool'] = config.get("config", "tool") + con_dic['test_time'] = config.get("config", "test_time") + con_dic['test_protocol'] = config.get("config", "protocol") + con_dic['test_tx_pkt_s'] = config.get("config", "tx pkt sizes") + con_dic['test_rx_pkt_s'] = config.get("config", "rx pkt sizes") + con_dic['test_tx_cache_s'] = config.get("config", "tx cache sizes") + con_dic['test_rx_cache_s'] = config.get("config", "rx cache sizes") + con_dic['test_cpu_load'] = config.get("config", "cpu load") + con_dic['test_latency'] = config.get("config", "latency") return con_dic -def posca_run(con_dic): - print "========== run posca system bandwidth ===========" +def posca_run(con_dic): + print("========== run posca system bandwidth ===========") test_rx_pkt_s_a = con_dic['test_rx_pkt_s'].split(',') test_tx_cache_s_a = con_dic['test_tx_cache_s'].split(',') test_rx_cache_s_a = con_dic['test_rx_cache_s'].split(',') - time_new = time.strftime('%H_%M',time.localtime(time.time())) + time_new = time.strftime('%H_%M', time.localtime(time.time())) bandwidth_tmp = 1 for test_rx_cache_s_e in test_rx_cache_s_a: for test_tx_cache_s_e in test_tx_cache_s_a: for test_rx_pkt_s_e in test_rx_pkt_s_a: - print "%s,%s,%s"%(test_rx_pkt_s_e,test_tx_cache_s_e,test_rx_cache_s_e) - order_excute = os.popen("%s %s http://%s/api/v3/yardstick/tasks/task %s %s %s"%(cmd,order_arg,con_dic['test_ip'],test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e)) + print("%s,%s,%s") % (test_rx_pkt_s_e, test_tx_cache_s_e, + test_rx_cache_s_e) + order_excute = os.popen("%s %s http://%s/api/v3/yardstick/\ + tasks/task %s %s %s" % (cmd, order_arg, con_dic['test_ip'], + test_rx_pkt_s_e, test_rx_cache_s_e, + test_tx_cache_s_e)) order_result = order_excute.read() task_id = order_result.find("task_id") time.sleep(con_dic['test_time']) - cmd_excute = os.popen( "%s http://%s/api/v3/yardstick/testresults?task_id=%s"%(cmd,con_dic['test_ip'],task_id)) + cmd_excute = os.popen("%s http://%s/api/v3/yardstick/test\ + results?task_id=%s" % (cmd, con_dic['test_ip'], task_id)) test_result = cmd_excute.read() bandwidth = test_result.find("bandwidth") cpu_load = test_result.find("cpu_load") latency = test_result.find("latency") - posca_output_result(time_new,test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) - if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_throughput'] >0.05) and (latency < con_dic['test_latency']) and (cpu_load < con_dic['test_cpu_load']): - if (abs(bandwidth_tmp-bandwidth)/bandwidth <0.05): - print "%s,%s,%s,%s,%s,%s"%(test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + posca_output_result(time_new, test_rx_pkt_s_e, + test_rx_cache_s_e, test_tx_cache_s_e, + bandwidth, latency, cpu_load) + if (abs(bandwidth-con_dic['test_throughput'])/con_dic['test_\ + throughput'] > 0.05) and (latency < con_dic['test_\ + latency']) and (cpu_load < con_dic['test_cpu_load']): + if (abs(bandwidth_tmp-bandwidth)/bandwidth < 0.05): + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return True else: bandwidth_tmp = bandwidth else: - print "%s,%s,%s,%s,%s,%s"%(test_rx_pkt_s_e,test_rx_cache_s_e,test_tx_cache_s_e,bandwidth,latency,cpu_load) + print("%s,%s,%s,%s,%s,%s") % (test_rx_pkt_s_e, + test_rx_cache_s_e, + test_tx_cache_s_e, + bandwidth, + latency, + cpu_load) return False def main(): if not (args.conf): - logger.error("Configuration files do not exist for the specified testcases") - exit(-1) + logger.error("Configuration files do not exist \ + for the specified testcases") + os.exit(-1) else: - testcase_cfg = args.conf + testcase_cfg = args.conf - con_dic=posca_config_read(testcase_cfg) + con_dic = posca_config_read(testcase_cfg) posca_env_check() posca_run(con_dic) time.sleep(5) -if __name__=='__main__': +if __name__ == '__main__': main() -- cgit 1.2.3-korg