aboutsummaryrefslogtreecommitdiffstats
path: root/functest/opnfv_tests/features/sfc/sfc.py
diff options
context:
space:
mode:
Diffstat (limited to 'functest/opnfv_tests/features/sfc/sfc.py')
-rwxr-xr-xfunctest/opnfv_tests/features/sfc/sfc.py30
1 files changed, 17 insertions, 13 deletions
diff --git a/functest/opnfv_tests/features/sfc/sfc.py b/functest/opnfv_tests/features/sfc/sfc.py
index e048d90f..1956eb37 100755
--- a/functest/opnfv_tests/features/sfc/sfc.py
+++ b/functest/opnfv_tests/features/sfc/sfc.py
@@ -351,11 +351,8 @@ def is_http_blocked(srv_prv_ip, client_ip):
return True
-def capture_err_logs(controller_clients, compute_clients, error):
- ovs_logger = ovs_utils.OVSLogger(
- os.path.join(os.getcwd(), 'ovs-logs'),
- FUNCTEST_RESULTS_DIR)
-
+def capture_err_logs(ovs_logger, controller_clients,
+ compute_clients, error):
timestamp = time.strftime("%Y%m%d-%H%M%S")
ovs_logger.dump_ovs_logs(controller_clients,
compute_clients,
@@ -404,10 +401,7 @@ def check_ssh(ips, retries=100):
# Measure the time it takes to update the classification rules
-def capture_time_log(compute_clients):
- ovs_logger = ovs_utils.OVSLogger(
- os.path.join(os.getcwd(), 'ovs-logs'),
- "test")
+def capture_time_log(ovs_logger, compute_clients):
i = 0
first_RSP = ""
start_time = time.time()
@@ -474,6 +468,10 @@ def main():
controller_clients = get_ssh_clients("controller")
compute_clients = get_ssh_clients("compute")
+ ovs_logger = ovs_utils.OVSLogger(
+ os.path.join(os.getcwd(), 'ovs-logs'),
+ FUNCTEST_RESULTS_DIR)
+
image_id = setup_glance(glance_client)
network_id = setup_neutron(neutron_client)
sg_id = setup_security_groups(neutron_client)
@@ -487,7 +485,8 @@ def main():
# Start measuring the time it takes to implement the classification rules
try:
- thread.start_new_thread(capture_time_log, (compute_clients,))
+ thread.start_new_thread(capture_time_log,
+ (ovs_logger, compute_clients,))
except Exception, e:
logger.error("Unable to start the thread that counts time %s" % e)
@@ -519,7 +518,8 @@ def main():
else:
error = ('\033[91mTEST 1 [FAILED] ==> SSH NOT BLOCKED\033[0m')
logger.error(error)
- capture_err_logs(controller_clients, compute_clients, error)
+ capture_err_logs(
+ ovs_logger, controller_clients, compute_clients, error)
update_json_results("Test 1: SSH Blocked", "Failed")
logger.info("Test HTTP")
@@ -529,7 +529,8 @@ def main():
else:
error = ('\033[91mTEST 2 [FAILED] ==> HTTP BLOCKED\033[0m')
logger.error(error)
- capture_err_logs(controller_clients, compute_clients, error)
+ capture_err_logs(
+ ovs_logger, controller_clients, compute_clients, error)
update_json_results("Test 2: HTTP works", "Failed")
logger.info("Changing the classification")
@@ -537,7 +538,8 @@ def main():
# Start measuring the time it takes to implement the classification rules
try:
- thread.start_new_thread(capture_time_log, (compute_clients,))
+ thread.start_new_thread(capture_time_log,
+ (ovs_logger, compute_clients,))
except Exception, e:
logger.error("Unable to start the thread that counts time %s" % e)
@@ -569,6 +571,8 @@ def main():
logger.error('\033[91mSFC TESTS: %s :( FOUND %s FAIL \033[0m' % (
status, json_results["failures"]))
+ ovs_logger.create_artifact_archive()
+
if args.report:
stop_time = time.time()
logger.debug("Promise Results json: " + str(json_results))