X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?p=bottlenecks.git;a=blobdiff_plain;f=testsuites%2Fposca%2Ftestcase_script%2Fposca_factor_multistack_storage_parallel.py;fp=testsuites%2Fposca%2Ftestcase_script%2Fposca_factor_multistack_storage_parallel.py;h=8c623d418f3629b55ce18469c7dfbef8ce06fb84;hp=58f9dc8c27933078d3933e89eac401edda5bcef7;hb=c7e43d91f4a6babaff1f373b0a7ed102a876e7d3;hpb=ca207611e853332780f61b2a69b999a35e55d0c7

diff --git a/testsuites/posca/testcase_script/posca_factor_multistack_storage_parallel.py b/testsuites/posca/testcase_script/posca_factor_multistack_storage_parallel.py
index 58f9dc8c..8c623d41 100644
--- a/testsuites/posca/testcase_script/posca_factor_multistack_storage_parallel.py
+++ b/testsuites/posca/testcase_script/posca_factor_multistack_storage_parallel.py
@@ -50,10 +50,8 @@ def env_pre(test_config):
     stack_prepare._prepare_env_daemon(test_yardstick)
     quota_prepare.quota_env_prepare()
     if(test_config["contexts"]['yardstick_envpre']):
-        cmd = ('yardstick env prepare')
         LOG.info("yardstick environment prepare!")
-        yardstick_container = docker_env.yardstick_info['container']
-        stdout = docker_env.docker_exec_cmd(yardstick_container, cmd)
+        stdout = yardstick_task.yardstick_image_prepare()
         LOG.debug(stdout)
 
 
@@ -78,11 +76,11 @@ def do_test(test_config):
         loop_value = loop_value + 1
         with open(out_file) as f:
             data = json.load(f)
-            if data["status"] == 1:
+            if data["result"]["criteria"] == "PASS":
                 LOG.info("yardstick run success")
                 LOG.info("%s" % data["result"]["testcases"])
                 break
-            elif data["status"] == 2:
+            else:
                 LOG.error("yardstick error exit")
                 break
 
@@ -140,6 +138,7 @@ def run(test_config):
     numjobs = scenarios_conf["num_jobs"]
     direct = scenarios_conf["direct"]
     volume_num = scenarios_conf["volume_num"]
+    volume_size = scenarios_conf["volume_size"]
 
     result = []
 
@@ -151,7 +150,8 @@ def run(test_config):
                        "size": size,
                        "rwmixwrite": rwmixwrite,
                        "numjobs": numjobs,
-                       "direct": direct}
+                       "direct": direct,
+                       "volume_size": int(volume_size)}
         data_reply = do_test(case_config)
         result.append(data_reply)