vPing.py: Fixed IPs for VMs, Not DHCP

JIRA: FUNCTEST-3

Change-Id: Ib921262cfe153e47b88ba268199a66bc47950893
Signed-off-by: jose.lausuch <jose.lausuch@ericsson.com>

3 files changed, 60 insertions, 28 deletions

diff --git a/testcases/config_functest.yaml b/testcases/config_functest.yaml
index eb1c9a2cf..40eb024ad 100644
--- a/testcases/config_functest.yaml
+++ b/testcases/config_functest.yaml
@@ -35,3 +35,5 @@ vping:
     vm_flavor: m1.small #adapt to your environment
     vm_name_1: opnfv-vping-1
     vm_name_2: opnfv-vping-2
+    ip_1: 192.168.120.30
+    ip_2: 192.168.120.40
diff --git a/testcases/functest_utils.py b/testcases/functest_utils.py
index 7b61198d1..f879a1a95 100644
--- a/testcases/functest_utils.py
+++ b/testcases/functest_utils.py
@@ -163,6 +163,20 @@ def remove_interface_router(neutron_client, router_id, subnet_id):
         print "Error:", sys.exc_info()[0]
         return False
 
+def create_neutron_port(neutron_client, name, network_id, ip):
+    json_body = {'port': {
+    'admin_state_up': True,
+    'name': name,
+    'network_id': network_id,
+    'fixed_ips': [{"ip_address": ip}]
+    }}
+    try:
+        port = neutron_client.create_port(body=json_body)
+        return port['port']['id']
+    except:
+        print "Error:", sys.exc_info()[0]
+        return False
+
 
 def get_network_id(neutron_client, network_name):
     networks = neutron_client.list_networks()['networks']
diff --git a/testcases/vPing/CI/libraries/vPing.py b/testcases/vPing/CI/libraries/vPing.py
index 379bf9698..1cc73922c 100644
--- a/testcases/vPing/CI/libraries/vPing.py
+++ b/testcases/vPing/CI/libraries/vPing.py
@@ -53,6 +53,8 @@ VM_DELETE_TIMEOUT = 100
 PING_TIMEOUT = functest_yaml.get("vping").get("ping_timeout")
 NAME_VM_1 = functest_yaml.get("vping").get("vm_name_1")
 NAME_VM_2 = functest_yaml.get("vping").get("vm_name_2")
+IP_1 = functest_yaml.get("vping").get("ip_1")
+IP_2 = functest_yaml.get("vping").get("ip_2")
 GLANCE_IMAGE_NAME = functest_yaml.get("general").get("openstack").get("image_name")
 FLAVOR = functest_yaml.get("vping").get("vm_flavor")
 
@@ -135,23 +137,26 @@ def create_private_neutron_net(neutron):
 
 def cleanup(nova,neutron,network_dic):
     # delete both VMs
-    logger.info("Deleting Instances...")
-    logger.debug("Deleting '%s'..." %NAME_VM_1)
-    vm1 = nova.servers.find(name=NAME_VM_1)
-    nova.servers.delete(vm1)
-    #wait until VMs are deleted
-    if not waitVmDeleted(nova,vm1):
-        logger.error("Instance '%s' with cannot be deleted. Status is '%s'" % (NAME_VM_1,functest_utils.get_instance_status(nova_client,vm1)))
-    else:
-        logger.debug("Instance %s terminated." % NAME_VM_1)
-
-    logger.debug("Deleting '%s'..." %NAME_VM_2)
-    vm2 = nova.servers.find(name=NAME_VM_2)
-    nova.servers.delete(vm2)
-    if not waitVmDeleted(nova,vm2):
-        logger.error("Instance '%s' with cannot be deleted. Status is '%s'" % (NAME_VM_2,functest_utils.get_instance_status(nova_client,vm2)))
-    else:
-        logger.debug("Instance %s terminated." % NAME_VM_2)
+    logger.info("Cleaning up...")
+    vm1 = functest_utils.get_instance_by_name(nova, NAME_VM_1)
+    if vm1:
+        logger.debug("Deleting '%s'..." %NAME_VM_1)
+        nova.servers.delete(vm1)
+        #wait until VMs are deleted
+        if not waitVmDeleted(nova,vm1):
+            logger.error("Instance '%s' with cannot be deleted. Status is '%s'" % (NAME_VM_1,functest_utils.get_instance_status(nova_client,vm1)))
+        else:
+            logger.debug("Instance %s terminated." % NAME_VM_1)
+
+    vm2 = functest_utils.get_instance_by_name(nova, NAME_VM_2)
+    if vm2:
+        logger.debug("Deleting '%s'..." %NAME_VM_2)
+        vm2 = nova.servers.find(name=NAME_VM_2)
+        nova.servers.delete(vm2)
+        if not waitVmDeleted(nova,vm2):
+            logger.error("Instance '%s' with cannot be deleted. Status is '%s'" % (NAME_VM_2,functest_utils.get_instance_status(nova_client,vm2)))
+        else:
+            logger.debug("Instance %s terminated." % NAME_VM_2)
 
     # delete created network
     logger.info("Deleting network '%s'..." % NEUTRON_PRIVATE_NET_NAME)
@@ -229,16 +234,20 @@ def main():
     # tune (e.g. flavor, images, network) to your specific openstack configuration here
 
     # create VM
-    logger.info("Creating instance '%s'..." % NAME_VM_1)
+    logger.debug("Creating port 'vping-port-1' with IP %s..." %IP_1)
+    port_id=functest_utils.create_neutron_port(neutron_client, "vping-port-1", network_id, IP_1)
+    if not port_id:
+        logger.error("Unable to create port.")
+        exit(-1)
+    logger.info("Creating instance '%s' with IP %s..." %(NAME_VM_1,IP_1))
     logger.debug("Configuration:\n name=%s \n flavor=%s \n image=%s \n network=%s \n" %(NAME_VM_1,flavor,image,network_id))
     vm1 = nova_client.servers.create(
         name               = NAME_VM_1,
         flavor             = flavor,
         image              = image,
-        nics               = [{"net-id": network_id}]
+        #nics               = [{"net-id": network_id, "v4-fixed-ip": IP_1}]
+        nics               = [{"port-id": port_id}]
     )
-
-
     #wait until VM status is active
     if not waitVmActive(nova_client,vm1):
         logger.error("Instance '%s' cannot be booted. Status is '%s'" % (NAME_VM_1,functest_utils.get_instance_status(nova_client,vm1)))
@@ -248,11 +257,12 @@ def main():
         logger.info("Instance '%s' is ACTIVE." % NAME_VM_1)
 
     #retrieve IP of first VM
-    logger.debug("Fetching IP...")
-    server = functest_utils.get_instance_by_name(nova_client, NAME_VM_1)
+    #logger.debug("Fetching IP...")
+    #server = functest_utils.get_instance_by_name(nova_client, NAME_VM_1)
     # theoretically there is only one IP address so we take the first element of the table
     # Dangerous! To be improved!
-    test_ip = server.networks.get(NEUTRON_PRIVATE_NET_NAME)[0]
+    #test_ip = server.networks.get(NEUTRON_PRIVATE_NET_NAME)[0]
+    test_ip=IP_1
     logger.debug("Instance '%s' got %s" %(NAME_VM_1,test_ip))
 
     # boot VM 2
@@ -260,16 +270,22 @@ def main():
     # the long chain corresponds to the ping procedure converted with base 64
     # tune (e.g. flavor, images, network) to your specific openstack configuration here
     u = "#!/bin/sh\n\nwhile true; do\n ping -c 1 %s 2>&1 >/dev/null\n RES=$?\n if [ \"Z$RES\" = \"Z0\" ] ; then\n  echo 'vPing OK'\n break\n else\n  echo 'vPing KO'\n fi\n sleep 1\ndone\n"%test_ip
-
     # create VM
-    logger.info("Creating instance '%s'..." % NAME_VM_2)
+
+    logger.debug("Creating port 'vping-port-2' with IP %s..." %IP_2)
+    port_id=functest_utils.create_neutron_port(neutron_client, "vping-port-2", network_id, IP_2)
+    if not port_id:
+        logger.error("Unable to create port.")
+        exit(-1)
+    logger.info("Creating instance '%s' with IP %s..." %(NAME_VM_2,IP_2))
     logger.debug("Configuration:\n name=%s \n flavor=%s \n image=%s \n network=%s \n userdata= \n%s" %(NAME_VM_2,flavor,image,network_id,u))
     vm2 = nova_client.servers.create(
         name               = NAME_VM_2,
         flavor             = flavor,
         image              = image,
-        nics               = [{"net-id": network_id}],
-        userdata           = u,
+        #nics               = [{"net-id": network_id, "v4-fixed-ip": IP_2}],
+        nics               = [{"port-id": port_id}],
+        userdata           = u
     )
 
     if not waitVmActive(nova_client,vm2):