Merge pull request #1076 from peixiu/bug1456172

Add fio test on data disk

qemu/tests/cfg/fio_windows.cfg

 - fio_windows:
     type = fio_windows
     only Windows
-    cmd_timeout = 600
-    log_file = "C:\fio_log.txt"
-    image_snapshot = yes
+    images += " disk1"
+    image_name_disk1 = images/storage
+    image_size_disk1 = 2G
+    remove_image_disk1 = yes
+    force_create_image_disk1 = yes
+    disk_index = 1
+    disk_letter = I
+    fio_file_name = "C\:\\fio_system_disk_test I\:\\fio_data_disk_test"
+    fio_log_file = "C:\fio_log_sys.txt C:\fio_log_data.txt"
+    cmd_timeout = 300
     i386, i686:
         install_path = "C:\Program Files\fio"
         install_cmd = 'msiexec /a DRIVE:\fio-x86.msi /qn TARGETDIR="${install_path}"'
@@ -11,6 +18,7 @@
         install_path = "C:\Program Files (x86)\fio"
         install_cmd = 'msiexec /a DRIVE:\fio-x64.msi /qn TARGETDIR="${install_path}"'
     #config_cmd = 'setx -m path "%PATH%;${install_path}\fio;"'
-    fio_cmd = '"${install_path}\fio\fio.exe" --name=fiotest --rw=randrw --iodepth=4 --bs=4k'
-    fio_cmd += ' --size=1G --ioengine=windowsaio --numjobs=4 --runtime=${cmd_timeout} > ${log_file}'
+    fio_cmd = '"${install_path}\fio\fio.exe" --rw=randrw --bs=4k --iodepth=4 --direct=1'
+    fio_cmd += ' --filename=%s --name=fiotest_%s --ioengine=windowsaio --thread --group_reporting'
+    fio_cmd += ' --numjobs=4 --size=1G --runtime=${cmd_timeout} > %s'
 

qemu/tests/fio_windows.py

@@ -5,8 +5,6 @@ import logging
 from virttest import error_context
 from virttest import utils_misc
 
-from avocado.core import exceptions
-
 
 @error_context.context_aware
 def run(test, params, env):
@@ -14,7 +12,7 @@ def run(test, params, env):
     KVM guest stop test:
     1) Log into a guest
     2) Check is fio.msi installed, install it if not installed.
-    3) Start fio in guest
+    3) Start fio test on both sys and data disk in guest
     4) Get the result
 
     :param test: kvm test object
@@ -23,8 +21,10 @@ def run(test, params, env):
     """
 
     install_path = params["install_path"].rstrip("\\")
-    log_file = params.get("log_file")
-    fio_cmd = params.get("fio_cmd")
+    fio_log_file = params.objects("fio_log_file")
+    fio_file_name = params.objects("fio_file_name")
+    fio_cmd_sys = params.get("fio_cmd") % (fio_file_name[0], "sys", fio_log_file[0])
+    fio_cmd_data = params.get("fio_cmd") % (fio_file_name[1], "data", fio_log_file[1])
     timeout = float(params.get("login_timeout", 360))
     cmd_timeout = int(params.get("cmd_timeout", "360"))
     check_installed_cmd = 'dir "%s"|findstr /I fio' % install_path
@@ -33,31 +33,45 @@ def run(test, params, env):
 
     vm = env.get_vm(params["main_vm"])
     vm.verify_alive()
-    session = vm.wait_for_login(timeout=timeout)
+    session_sys = vm.wait_for_login(timeout=timeout)
+    session_data = vm.wait_for_login(timeout=timeout)
+
+    error_context.context("Format disk", logging.info)
+    utils_misc.format_windows_disk(session_sys, params["disk_index"],
+                                   mountpoint=params["disk_letter"])
     try:
-        installed = session.cmd_status(check_installed_cmd) == 0
+        installed = session_sys.cmd_status(check_installed_cmd) == 0
         if not installed:
-            dst = r"%s:\\" % utils_misc.get_winutils_vol(session)
+            dst = r"%s:\\" % utils_misc.get_winutils_vol(session_sys)
 
             error_context.context("Install fio in guest", logging.info)
             install_cmd = params["install_cmd"]
             install_cmd = re.sub(r"DRIVE:\\+", dst, install_cmd)
-            session.cmd(install_cmd, timeout=180)
+            session_sys.cmd(install_cmd, timeout=180)
             time.sleep(30)
             config_cmd = params.get("config_cmd")
             if config_cmd:
-                session.cmd(config_cmd)
+                session_sys.cmd(config_cmd)
 
         error_context.context("Start fio in guest.", logging.info)
-        s, o = session.cmd_status_output(fio_cmd, timeout=(cmd_timeout+60))
-        if s:
-            raise exceptions.TestError("Failed to run fio, output: %s" % o)
+        # FIXME:Here use the timeout=(cmd_timeout*2)
+        # Will determine a better specific calculation later
+        fio_thread_data = utils_misc.InterruptedThread(session_data.cmd_status_output,
+                                                       (fio_cmd_data, (cmd_timeout*2)))
+        fio_thread_data.start()
+        status_sys, output_sys = session_sys.cmd_status_output(fio_cmd_sys,
+                                                               timeout=(cmd_timeout*2))
+        status_data, output_data = fio_thread_data.join()
+        if status_sys or status_data:
+            test.error("Failed to run fio, output: %s\n%s" % (output_sys, output_data))
 
     finally:
         error_context.context("Copy fio log from guest to host.", logging.info)
         try:
-            vm.copy_files_from(log_file, test.resultsdir)
+            vm.copy_files_from(fio_log_file[0], test.resultsdir)
+            vm.copy_files_from(fio_log_file[1], test.resultsdir)
         except Exception, err:
             logging.warn("Log file copy failed: %s" % err)
-        if session:
-            session.close()
+        session_data.close()
+        if session_sys:
+            session_sys.close()