fixed power issue and extra.h first job issue

1 files changed, 11 insertions, 6 deletions

diff --git a/run_case_study_dag.py b/run_case_study_dag.py
index d4f12e1..e2c4607 100755
--- a/run_case_study_dag.py
+++ b/run_case_study_dag.py
@@ -99,18 +99,20 @@ def main(pathName):
         in_ccx = core % 4
         mask = "0000"
         mask = mask[:in_ccx] +'f'+ mask[in_ccx+1:]
+        run('echo {},{} > /sys/fs/resctrl/core-{}/cpus_list'.format(core,core+16, core))
+        # run('echo {} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
         if ccx == 0:
-            run('echo {} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
+            # run('echo {},{} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
             run('echo "L3:0=' + mask + ';1=0000;2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core))
             # run('echo "L3:0=ffff;1=0000;2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core))
         if ccx == 1:
-            run('echo {} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
+            # run('echo {},{} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
             run('echo "L3:0=0000;1=' + mask + ';2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core))
         if ccx == 2:
-            run('echo {} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
+            # run('echo {},{} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
             run('echo "L3:0=0000;1=0000;2=' + mask + ';3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core))
         if ccx == 3:
-            run('echo {} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
+            # run('echo {},{} > /sys/fs/resctrl/core-{}/cpus_list'.format(core, core))
             run('echo "L3:0=0000;1=0000;2=0000;3=' + mask + '" > /sys/fs/resctrl/core-{}/schemata'.format(core))
 
     # return 1
@@ -143,13 +145,14 @@ def main(pathName):
                 # Arg format: <unique name> <num_iters> <core> <NULL runID> <save?> <period> <crit lvl> <phase>
                 arg = " " + task_name  + " " + num_iters +" " +  core_num +" " +  run_id +" " + save_result+" " + period +" " +  crt_level + " "+ phase
                 bench_tsk = subprocess.Popen(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg, shell=True, executable='/bin/bash', stderr=stderr_file)
+
             else:
-                # Arg format: <unique name> <num_iters> <core> <NULL runID> 
+                # Arg format: <unique name> <num_iters> <core> <NULL runID> <save?> 
                 binary =  binary_path + binary_name + "_single_no_litmus"
                 arg = " " + task_name  + " " + num_iters +" " +  core_num +" " +  run_id +" " + save_result+" "     
                 bench_tsk = subprocess.Popen(input_cmd[binary_name] + " |  numactl --interleave=all taskset -c " +  core_num + " " + binary + arg, shell=True, executable='/bin/bash', stderr=stderr_file)
             
-            # print(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg) 
+            print(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg) 
             # print(binary)
             # print(arg)
             pid_str = ID2PID(binary + " " + task_name)
@@ -195,6 +198,8 @@ def main(pathName):
             
             run("echo " + pid1_str + " > /sys/fs/resctrl/core-" + str(phys_core) + "/tasks")
             run("echo " + pid2_str + " > /sys/fs/resctrl/core-" + str(phys_core) + "/tasks")
+            # run("wait " + pid1_str)
+            # run("wait " + pid2_str)
             pairID += 1
 
 if __name__ == "__main__":