tests: use common exec_cmd helper

Replace the open coded version of exec_cmd with this helper.

Signed-off-by: Daniel Wagner <[email protected]>

Author: igaw

tests/nvme_fw_log_test.py

@@ -26,8 +26,6 @@
     1. Execute fw-log on a device.
 """
 
-import subprocess
-
 from nvme_test import TestNVMe
 
 
@@ -58,11 +56,7 @@ def get_fw_log(self):
                 - 0 on success, error code on failure.
         """
         fw_log_cmd = f"{self.nvme_bin} fw-log {self.ctrl}"
-        proc = subprocess.Popen(fw_log_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        return proc.wait()
+        return self.exec_cmd(fw_log_cmd)
 
     def test_fw_log(self):
         """ Testcase main """

tests/nvme_get_features_test.py

@@ -84,21 +84,13 @@ def get_mandatory_features(self, feature_id):
                 get_feat_cmd = f"{self.nvme_bin} get-feature {self.ctrl} " + \
                     f"--feature-id={str(feature_id)} " + \
                     f"--cdw11={str(vector)} --human-readable"
-                proc = subprocess.Popen(get_feat_cmd,
-                                        shell=True,
-                                        stdout=subprocess.PIPE,
-                                        encoding='utf-8')
-                self.assertEqual(proc.wait(), 0)
+                self.assertEqual(self.exec_cmd(get_feat_cmd), 0)
         else:
             get_feat_cmd = f"{self.nvme_bin} get-feature {self.ctrl} " + \
                 f"--feature-id={str(feature_id)} --human-readable"
             if str(feature_id) == "0x05":
                 get_feat_cmd += f" --namespace-id={self.default_nsid}"
-            proc = subprocess.Popen(get_feat_cmd,
-                                    shell=True,
-                                    stdout=subprocess.PIPE,
-                                    encoding='utf-8')
-            self.assertEqual(proc.wait(), 0)
+            self.assertEqual(self.exec_cmd(get_feat_cmd), 0)
 
     def test_get_mandatory_features(self):
         """ Testcase main """

tests/nvme_get_lba_status_test.py

@@ -12,8 +12,6 @@
     1. Execute get-lba-status on a device.
 """
 
-import subprocess
-
 from nvme_test import TestNVMe
 
 
@@ -56,11 +54,7 @@ def get_lba_status(self):
             f"--max-dw={str(self.max_dw)} " + \
             f"--action={str(self.action)} " + \
             f"--range-len={str(self.range_len)}"
-        proc = subprocess.Popen(get_lba_status_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        return proc.wait()
+        return self.exec_cmd(get_lba_status_cmd)
 
     def test_get_lba_status(self):
         """ Testcase main """

tests/nvme_id_ns_test.py

@@ -27,8 +27,6 @@
     2. Execute id-ns on all namespaces
 """
 
-import subprocess
-
 from nvme_test import TestNVMe
 
 
@@ -62,11 +60,7 @@ def get_id_ns(self, nsid):
         """
         id_ns_cmd = f"{self.nvme_bin} id-ns {self.ctrl} " + \
             f"--namespace-id={str(nsid)}"
-        proc = subprocess.Popen(id_ns_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        return proc.wait()
+        return self.exec_cmd(id_ns_cmd)
 
     def get_id_ns_all(self):
         """

tests/nvme_lba_status_log_test.py

@@ -12,8 +12,6 @@
     1. Execute lba-status-log on a device.
 """
 
-import subprocess
-
 from nvme_test import TestNVMe
 
 
@@ -46,11 +44,7 @@ def get_lba_stat_log(self):
                 - 0 on success, error code on failure.
         """
         lba_stat_log_cmd = f"{self.nvme_bin} lba-status-log {self.ctrl}"
-        proc = subprocess.Popen(lba_stat_log_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        return proc.wait()
+        return self.exec_cmd(lba_stat_log_cmd)
 
     def test_lba_stat_log(self):
         """ Testcase main """

tests/nvme_test.py

@@ -486,11 +486,7 @@ def get_smart_log(self, nsid):
         """
         smart_log_cmd = f"{self.nvme_bin} smart-log {self.ctrl} " + \
             f"--namespace-id={str(nsid)}"
-        proc = subprocess.Popen(smart_log_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        err = proc.wait()
+        err = self.exec_cmd(smart_log_cmd)
         self.assertEqual(err, 0, "ERROR : nvme smart log failed")
         return err
 
@@ -506,11 +502,7 @@ def get_id_ctrl(self, vendor=False):
         else:
             id_ctrl_cmd = f"{self.nvme_bin} id-ctrl " +\
                 f"--vendor-specific {self.ctrl}"
-        proc = subprocess.Popen(id_ctrl_cmd,
-                                shell=True,
-                                stdout=subprocess.PIPE,
-                                encoding='utf-8')
-        err = proc.wait()
+        err = self.exec_cmd(id_ctrl_cmd)
         self.assertEqual(err, 0, "ERROR : nvme id controller failed")
         return err