Fixes percentage

Author: tainagdcoleman

wfcommons/wfperf/wfperf_benchmark.py

@@ -45,26 +45,29 @@ def main():
 
     with save_dir.joinpath(f"{name}_cpu.txt").open("w+") as fp_cpu, save_dir.joinpath(f"{name}_memory.txt").open("w+") as fp_mem:
         num_cores = os.cpu_count()
-        cpu_threads = int(num_cores * args.percent_cpu)
-        mem_threads = int(num_cores * (1 - args.percent_cpu))
+        cpu_threads = int(args.percent_cpu*10)
+        mem_threads = int(10 - cpu_threads)
+        
         print(cpu_threads, mem_threads)
-        print("Starting CPU benchmark...")
-        sysbench_cpu_args = [arg for arg in other if arg.startswith("--cpu")] + [f"--threads={cpu_threads}"]
-        proc_cpu = subprocess.Popen(
-            [
-                "time", "timeout", f"{args.time}s", "sysbench", "cpu", 
-                *sysbench_cpu_args, "run"
-            ], 
-            stdout=fp_cpu, stderr=fp_cpu
-        )
-    
-        print("Starting Memory benchmark...")     
-        sysbench_mem_args = [arg for arg in other if arg.startswith("--memory")] + [f"--time={args.time}", f"--threads={mem_threads}"]
-        proc_mem = subprocess.Popen(
-            ["time", "sysbench", "memory", "run",*sysbench_mem_args], 
-            stdout=fp_mem, stderr=fp_mem
-        )
 
+        for _ in range(num_cores):
+            print("Starting CPU benchmark...")
+            sysbench_cpu_args = [arg for arg in other if arg.startswith("--cpu")] + [f"--threads={cpu_threads}"]
+            proc_cpu = subprocess.Popen(
+                [
+                    "time", "timeout", f"{args.time}s", "sysbench", "cpu", 
+                    *sysbench_cpu_args, "run"
+                ], 
+                stdout=fp_cpu, stderr=fp_cpu
+            )
+        
+            print("Starting Memory benchmark...")     
+            sysbench_mem_args = [arg for arg in other if arg.startswith("--memory")] + [f"--time={args.time}", f"--threads={mem_threads}"]
+            proc_mem = subprocess.Popen(
+                ["time", "sysbench", "memory", "run",*sysbench_mem_args], 
+                stdout=fp_mem, stderr=fp_mem
+            )
+            
         proc_cpu.wait()
         proc_mem.wait()