return out_value
-def config_to_result(num, out_num, during_date):
+def config_to_result(num, out_num, during_date, result):
testdata = {}
test_result = {}
- test_result["number_of_users"] = float(num)
+ 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
LOG.info("%s thread success %d times" % (num, out_num))
during_date = (endtime - starttime).seconds
- data_reply = config_to_result(num, out_num, during_date)
+ if out_num >= con_dic["scenarios"]['threshhold']:
+ criteria_result = "PASS"
+ else:
+ criteria_result = "FAIL"
+
+ data_reply = config_to_result(num, out_num, during_date,
+ criteria_result)
if "dashboard" in test_config["contexts"].keys():
DashBoard.dashboard_send_data(test_config['contexts'], data_reply)
conf_parser.result_to_file(data_reply, test_config["out_file"])
- if out_num < num:
- success_rate = ('%d/%d' % (out_num, num))
- LOG.error('error thread: %d '
- 'the successful rate is %s'
- % (num - out_num, success_rate))
+ if criteria_result is "FAIL":
break
LOG.info('END POSCA stress ping test')
+ return criteria_result
@classmethod
def testcase_out_dir(cls, testcase):
- file_time = time.strftime('%H_%M', time.localtime(time.time()))
- out_name = cls.bottlenecks_config["log_dir"] + testcase + file_time
+ suffix_name = os.getenv("SUFFIX_STRING")
+ if suffix_name is None:
+ file_suffix = time.strftime('%H_%M', time.localtime(time.time()))
+ else:
+ file_suffix = suffix_name
+ suffix_name = str(suffix_name)
+ suffix_name = "_" + suffix_name
+ out_name = cls.bottlenecks_config["log_dir"] + testcase + file_suffix
outfile_name = out_name + ".out"
return outfile_name