From 8b09f0ad06e5ae941fc497754cc5778fae9018de Mon Sep 17 00:00:00 2001 From: George Paraskevopoulos Date: Tue, 13 Dec 2016 11:27:36 +0200 Subject: Introduce setup_scripts directory JIRA: SFC-52 Move every setup script to a separate directory. Change-Id: I99ea937a04d7580c7e85220091fe0c32213c587e Signed-off-by: George Paraskevopoulos --- .../odl-sfc/setup_scripts/prepare_odl_sfc.py | 90 ++++++++++++++++++++++ 1 file changed, 90 insertions(+) create mode 100755 tests/functest/odl-sfc/setup_scripts/prepare_odl_sfc.py (limited to 'tests/functest/odl-sfc/setup_scripts/prepare_odl_sfc.py') diff --git a/tests/functest/odl-sfc/setup_scripts/prepare_odl_sfc.py b/tests/functest/odl-sfc/setup_scripts/prepare_odl_sfc.py new file mode 100755 index 00000000..c3162cba --- /dev/null +++ b/tests/functest/odl-sfc/setup_scripts/prepare_odl_sfc.py @@ -0,0 +1,90 @@ +# +# Author: George Paraskevopoulos (geopar@intracom-telecom.com) +# Manuel Buil (manuel.buil@ericsson.com) +# Prepares the controller and the compute nodes for the odl-sfc testcase +# +# +# 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 +# + +import os +import sys +import subprocess +import paramiko +import functest.utils.functest_logger as ft_logger + +logger = ft_logger.Logger("ODL_SFC").getLogger() + +SFC_REPO_DIR = "/home/opnfv/repos/sfc" + +try: + INSTALLER_IP = os.environ['INSTALLER_IP'] +except: + logger.debug("INSTALLER_IP does not exist. We create 10.20.0.2") + INSTALLER_IP = "10.20.0.2" + +os.environ['ODL_SFC_LOG'] = "/home/opnfv/functest/results/odl-sfc.log" +os.environ['ODL_SFC_DIR'] = os.path.join(SFC_REPO_DIR, + "tests/functest/odl-sfc") +SETUP_SCRIPTS_DIR = os.path.join(os.environ['ODL_SFC_DIR'], 'setup_scripts') + +command = SETUP_SCRIPTS_DIR + ("/server_presetup_CI.bash | " + "tee -a ${ODL_SFC_LOG} 1>/dev/null 2>&1") + +output = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE) + +# This code is for debugging purposes +# for line in iter(output.stdout.readline, ''): +# i = line.rstrip() +# print(i) + +# Make sure the process is finished before checking the returncode +if not output.poll(): + output.wait() + +# Get return value +if output.returncode: + print("The presetup of the server did not work") + sys.exit(output.returncode) + +logger.info("The presetup of the server worked ") + +ssh_options = "-o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no" +ssh = paramiko.SSHClient() +ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) + +try: + ssh.connect(INSTALLER_IP, username="root", + password="r00tme", timeout=2) + command = "fuel node | grep compute | awk '{print $10}'" + logger.info("Executing ssh to collect the compute IPs") + (stdin, stdout, stderr) = ssh.exec_command(command) +except: + logger.debug("Something went wrong in the ssh to collect the computes IP") + +output = stdout.readlines() +for ip in output: + command = SETUP_SCRIPTS_DIR + ("/compute_presetup_CI.bash " + ip.rstrip() + + "| tee -a ${ODL_SFC_LOG} 1>/dev/null 2>&1") + + output = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE) + +# This code is for debugging purposes +# for line in iter(output.stdout.readline, ''): +# print(line) +# sys.stdout.flush() + + output.stdout.close() + + if not (output.poll()): + output.wait() + + # Get return value + if output.returncode: + print("The compute config did not work on compute %s" % ip) + sys.exit(output.returncode) + +sys.exit(0) -- cgit 1.2.3-korg