Simplify vping_ssh

It directly calls ping from the ssh socket.
It fixes a possible missing security rule.

It stops blocking if vpings are in failure.

Change-Id: I64092a155bb134fa8b7d31d0d13f695e019540d1
Signed-off-by: Cédric Ollivier <cedric.ollivier@orange.com>
(cherry picked from commit 213ca8e4e4d155ed6d5626020e56c3a241d1dace)

8 files changed, 32 insertions, 98 deletions

diff --git a/docker/smoke/testcases.yaml b/docker/smoke/testcases.yaml
index 536819f1d..eb29142b4 100644
--- a/docker/smoke/testcases.yaml
+++ b/docker/smoke/testcases.yaml
@@ -11,7 +11,7 @@ tiers:
                 case_name: vping_ssh
                 project_name: functest
                 criteria: 100
-                blocking: true
+                blocking: false
                 description: >-
                     This test case verifies: 1) SSH to an instance using
                     floating IPs over the public network. 2) Connectivity
@@ -27,7 +27,7 @@ tiers:
                 case_name: vping_userdata
                 project_name: functest
                 criteria: 100
-                blocking: true
+                blocking: false
                 description: >-
                     This test case verifies:  1) Boot a VM with given userdata.
                     2) Connectivity between 2 instances over a private network.
diff --git a/functest/ci/config_functest.yaml b/functest/ci/config_functest.yaml
index beb5ce9b8..5dc938b6c 100644
--- a/functest/ci/config_functest.yaml
+++ b/functest/ci/config_functest.yaml
@@ -93,9 +93,9 @@ vping:
     private_subnet_name: vping-subnet
     private_subnet_cidr: 192.168.130.0/24
     router_name: vping-router
-    sg_name: vPing-sg
+    sg_name: vping-sg
     sg_desc: Security group for vPing test case
-    keypair_name: vPing-keypair
+    keypair_name: vping-keypair
     keypair_priv_file: /tmp/vPing-keypair
     keypair_pub_file: /tmp/vPing-keypair.pub
     vm_boot_timeout: 180
diff --git a/functest/ci/testcases.yaml b/functest/ci/testcases.yaml
index 0158d6b35..cb4e869bb 100644
--- a/functest/ci/testcases.yaml
+++ b/functest/ci/testcases.yaml
@@ -73,7 +73,7 @@ tiers:
                 case_name: vping_ssh
                 project_name: functest
                 criteria: 100
-                blocking: true
+                blocking: false
                 description: >-
                     This test case verifies: 1) SSH to an instance using
                     floating IPs over the public network. 2) Connectivity
@@ -89,7 +89,7 @@ tiers:
                 case_name: vping_userdata
                 project_name: functest
                 criteria: 100
-                blocking: true
+                blocking: false
                 description: >-
                     This test case verifies:  1) Boot a VM with given userdata.
                     2) Connectivity between 2 instances over a private network.
diff --git a/functest/opnfv_tests/openstack/vping/ping.sh b/functest/opnfv_tests/openstack/vping/ping.sh
deleted file mode 100644
index 15f5e84e1..000000000
--- a/functest/opnfv_tests/openstack/vping/ping.sh
+++ /dev/null
@@ -1,10 +0,0 @@
-#!/bin/sh
-
-
-ping -c 1 $1 2>&1 >/dev/null
-RES=$?
-if [ "Z$RES" = "Z0" ] ; then
-    echo 'vPing OK'
-else
-    echo 'vPing KO'
-fi
diff --git a/functest/opnfv_tests/openstack/vping/vping_base.py b/functest/opnfv_tests/openstack/vping/vping_base.py
index b1360d7c9..fc07f6173 100644
--- a/functest/opnfv_tests/openstack/vping/vping_base.py
+++ b/functest/opnfv_tests/openstack/vping/vping_base.py
@@ -47,6 +47,7 @@ class VPingBase(testcase.TestCase):
         self.image = None
         self.flavor = None
         self.vm1 = None
+        self.sec1 = None
 
     def run(self, **kwargs):  # pylint: disable=too-many-locals
         """
@@ -120,6 +121,12 @@ class VPingBase(testcase.TestCase):
         self.cloud.set_flavor_specs(
             self.flavor.id, getattr(config.CONF, 'flavor_extra_specs', {}))
 
+        self.sec1 = self.cloud.create_security_group(
+            getattr(config.CONF, 'vping_sg_name') + self.guid,
+            getattr(config.CONF, 'vping_sg_desc'))
+        self.cloud.create_security_group_rule(
+            self.sec1.id, protocol='icmp', direction='ingress')
+
         vm1_name = getattr(config.CONF, 'vping_vm_name_1') + self.guid
         self.logger.info(
             "Creating VM 1 instance with name: '%s'", vm1_name)
@@ -128,9 +135,12 @@ class VPingBase(testcase.TestCase):
             flavor=self.flavor.id,
             auto_ip=False, wait=True,
             timeout=getattr(config.CONF, 'vping_vm_boot_timeout'),
-            network=self.network.id)
+            network=self.network.id,
+            security_groups=[self.sec1.id])
         self.logger.debug("vm1: %s", self.vm1)
         self.vm1 = self.cloud.wait_for_server(self.vm1, auto_ip=False)
+        p_console = self.cloud.get_server_console(self.vm1.id)
+        self.logger.debug("vm1 console: \n%s", p_console)
 
     def _execute(self):
         """
@@ -153,6 +163,7 @@ class VPingBase(testcase.TestCase):
         """
         assert self.cloud
         self.cloud.delete_server(self.vm1, wait=True)
+        self.cloud.delete_security_group(self.sec1.id)
         self.cloud.delete_image(self.image)
         self.cloud.remove_router_interface(self.router, self.subnet.id)
         self.cloud.delete_router(self.router.id)
diff --git a/functest/opnfv_tests/openstack/vping/vping_ssh.py b/functest/opnfv_tests/openstack/vping/vping_ssh.py
index 21a433884..8cc251d1d 100644
--- a/functest/opnfv_tests/openstack/vping/vping_ssh.py
+++ b/functest/opnfv_tests/openstack/vping/vping_ssh.py
@@ -15,8 +15,6 @@ import tempfile
 import time
 
 import paramiko
-import pkg_resources
-from scp import SCPClient
 from xtesting.core import testcase
 from xtesting.energy import energy
 
@@ -39,7 +37,7 @@ class VPingSSH(vping_base.VPingBase):
         super(VPingSSH, self).__init__(**kwargs)
         self.logger = logging.getLogger(__name__)
         self.vm2 = None
-        self.sec = None
+        self.sec2 = None
         self.fip = None
         self.keypair = None
         self.ssh = paramiko.SSHClient()
@@ -66,14 +64,14 @@ class VPingSSH(vping_base.VPingBase):
             with open(self.key_filename, 'w') as private_key_file:
                 private_key_file.write(self.keypair.private_key)
 
-            self.sec = self.cloud.create_security_group(
+            self.sec2 = self.cloud.create_security_group(
                 getattr(config.CONF, 'vping_sg_name') + self.guid,
                 getattr(config.CONF, 'vping_sg_desc'))
             self.cloud.create_security_group_rule(
-                self.sec.id, port_range_min='22', port_range_max='22',
+                self.sec2.id, port_range_min='22', port_range_max='22',
                 protocol='tcp', direction='ingress')
             self.cloud.create_security_group_rule(
-                self.sec.id, protocol='icmp', direction='ingress')
+                self.sec2.id, protocol='icmp', direction='ingress')
 
             vm2_name = "{}-{}-{}".format(
                 getattr(config.CONF, 'vping_vm_name_2'), "ssh", self.guid)
@@ -85,24 +83,20 @@ class VPingSSH(vping_base.VPingBase):
                 auto_ip=False, wait=True,
                 timeout=getattr(config.CONF, 'vping_vm_boot_timeout'),
                 network=self.network.id,
-                security_groups=[self.sec.id])
+                security_groups=[self.sec2.id])
             self.logger.debug("vm2: %s", self.vm2)
             self.fip = self.cloud.create_floating_ip(
                 network=self.ext_net.id, server=self.vm2)
             self.logger.debug("floating_ip2: %s", self.fip)
             self.vm2 = self.cloud.wait_for_server(self.vm2, auto_ip=False)
-
+            p_console = self.cloud.get_server_console(self.vm2.id)
+            self.logger.debug("vm2 console: \n%s", p_console)
             return self._execute()
         except Exception:  # pylint: disable=broad-except
             self.logger.exception('Unexpected error running vping_ssh')
             return testcase.TestCase.EX_RUN_ERROR
 
     def _do_vping(self):
-        """
-        Execute ping command.
-
-        Override from super
-        """
         time.sleep(10)
         self.ssh.set_missing_host_key_policy(paramiko.client.AutoAddPolicy())
         self.ssh.connect(
@@ -111,72 +105,10 @@ class VPingSSH(vping_base.VPingBase):
             key_filename=self.key_filename,
             timeout=getattr(config.CONF, 'vping_vm_ssh_connect_timeout'))
         self.logger.debug("ssh: %s", self.ssh)
-        if not self._transfer_ping_script():
-            return testcase.TestCase.EX_RUN_ERROR
-        return self._do_vping_ssh()
-
-    def _transfer_ping_script(self):
-        """
-        Transfert vping script to VM.
-
-        Uses SCP to copy the ping script via the SSH client
-        :param ssh: the SSH client
-        :return:
-        """
-        self.logger.info("Trying to transfer ping.sh")
-        scp = SCPClient(self.ssh.get_transport())
-        ping_script = pkg_resources.resource_filename(
-            'functest.opnfv_tests.openstack.vping', 'ping.sh')
-        try:
-            scp.put(ping_script, "~/")
-        except Exception:  # pylint: disable=broad-except
-            self.logger.error("Cannot SCP the file '%s'", ping_script)
-            return False
-
-        cmd = 'chmod 755 ~/ping.sh'
-        (_, stdout, _) = self.ssh.exec_command(cmd)
-        for line in stdout.readlines():
-            print line
-
-        return True
-
-    def _do_vping_ssh(self):
-        """
-        Execute ping command via SSH.
-
-        Pings the test_ip via the SSH client
-        :param ssh: the SSH client used to issue the ping command
-        :param test_ip: the IP for the ping command to use
-        :return: exit_code (int)
-        """
-        exit_code = testcase.TestCase.EX_TESTCASE_FAILED
-        self.logger.info("Waiting for ping...")
-
-        sec = 0
-        cmd = '~/ping.sh ' + self.vm1.private_v4
-        flag = False
-
-        while True:
-            time.sleep(1)
-            (_, stdout, _) = self.ssh.exec_command(cmd)
-            output = stdout.readlines()
-
-            for line in output:
-                if "vPing OK" in line:
-                    self.logger.info("vPing detected!")
-                    exit_code = testcase.TestCase.EX_OK
-                    flag = True
-                    break
-                elif sec == getattr(config.CONF, 'vping_ping_timeout'):
-                    self.logger.info("Timeout reached.")
-                    flag = True
-                    break
-            if flag:
-                break
-            log = "Pinging %s. Waiting for response..." % self.vm1.private_v4
-            self.logger.debug(log)
-            sec += 1
-        return exit_code
+        (_, stdout, _) = self.ssh.exec_command(
+            'ping -c 1 ' + self.vm1.private_v4)
+        self.logger.debug("ping output: %s", stdout)
+        return stdout.channel.recv_exit_status()
 
     def clean(self):
         assert self.cloud
@@ -184,7 +116,7 @@ class VPingSSH(vping_base.VPingBase):
         self.cloud.delete_server(
             self.vm2, wait=True,
             timeout=getattr(config.CONF, 'vping_vm_delete_timeout'))
-        self.cloud.delete_security_group(self.sec.id)
+        self.cloud.delete_security_group(self.sec2.id)
         self.cloud.delete_keypair(self.keypair.id)
         self.cloud.delete_floating_ip(self.fip.id)
         super(VPingSSH, self).clean()
diff --git a/functest/opnfv_tests/openstack/vping/vping_userdata.py b/functest/opnfv_tests/openstack/vping/vping_userdata.py
index 9551c4b5d..056598d71 100644
--- a/functest/opnfv_tests/openstack/vping/vping_userdata.py
+++ b/functest/opnfv_tests/openstack/vping/vping_userdata.py
@@ -52,6 +52,8 @@ class VPingUserdata(vping_base.VPingBase):
                 userdata=self._get_userdata())
             self.logger.debug("vm2: %s", self.vm2)
             self.vm2 = self.cloud.wait_for_server(self.vm2, auto_ip=False)
+            p_console = self.cloud.get_server_console(self.vm1.id)
+            self.logger.debug("vm2 console: \n%s", p_console)
 
             return self._execute()
         except Exception:  # pylint: disable=broad-except
diff --git a/tox.ini b/tox.ini
index 8c04eb3b8..8da348f4a 100644
--- a/tox.ini
+++ b/tox.ini
@@ -107,7 +107,6 @@ commands = nosetests {[testenv:py35]dirs}
 basepython = python2.7
 files =
   functest/opnfv_tests/openstack/rally/scenario/support/instance_dd_test.sh
-  functest/opnfv_tests/openstack/vping/ping.sh
   functest/ci/download_images.sh
   build.sh
 commands = bashate {[testenv:bashate]files}