X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=functest%2Fopnfv_tests%2Fopenstack%2Fvmtp%2Fvmtp.py;fp=functest%2Fopnfv_tests%2Fopenstack%2Fvmtp%2Fvmtp.py;h=edff99cb2c9c8041d91afa384e19daea28cb8bdf;hb=3668a839dd9b869a3162c8aa2d98a152d22b7244;hp=822c1b652b89bf1c16a09c646d9498601e16f6b9;hpb=6a4195b2dbdfeecb6b75450d28039097fd71d8eb;p=functest.git

diff --git a/functest/opnfv_tests/openstack/vmtp/vmtp.py b/functest/opnfv_tests/openstack/vmtp/vmtp.py
index 822c1b652..edff99cb2 100644
--- a/functest/opnfv_tests/openstack/vmtp/vmtp.py
+++ b/functest/opnfv_tests/openstack/vmtp/vmtp.py
@@ -33,6 +33,7 @@ from xtesting.core import testcase
 
 from functest.core import singlevm
 from functest.utils import env
+from functest.utils import functest_utils
 
 
 class Vmtp(singlevm.VmReady2):
@@ -148,8 +149,15 @@ class Vmtp(singlevm.VmReady2):
             del new_env['OS_TENANT_ID']
         except Exception:  # pylint: disable=broad-except
             pass
+        extra_args = ""
+        if env.get("VMTP_HYPERVISORS"):
+            hypervisors = functest_utils.convert_ini_to_list(
+                env.get("VMTP_HYPERVISORS"))
+            for hypervisor in hypervisors:
+                extra_args = "{} --hypervisor {} ".format(
+                    extra_args, hypervisor)
         cmd = ['vmtp', '-d', '--json', '{}/vmtp.json'.format(self.res_dir),
-               '-c', self.config]
+               '-c', self.config, extra_args]
         output = subprocess.check_output(
             cmd, stderr=subprocess.STDOUT, env=new_env).decode("utf-8")
         self.__logger.info("%s\n%s", " ".join(cmd), output)