diff options
Diffstat (limited to 'run_case_study_dag.py')
| -rwxr-xr-x | run_case_study_dag.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/run_case_study_dag.py b/run_case_study_dag.py index 0a5c5fe..516458f 100755 --- a/run_case_study_dag.py +++ b/run_case_study_dag.py | |||
| @@ -87,6 +87,7 @@ def main(pathName): | |||
| 87 | 87 | ||
| 88 | ### Allocate Cache Ways ### | 88 | ### Allocate Cache Ways ### |
| 89 | run('mount -t resctrl resctrl /sys/fs/resctrl') | 89 | run('mount -t resctrl resctrl /sys/fs/resctrl') |
| 90 | # run('sudo echo "L3:0=0000;1=0000;2=0000;3=ffff" | sudo tee /sys/fs/resctrl/schemata') | ||
| 90 | run('sudo echo "L3:0=0000;1=0000;2=0000;3=000f" | sudo tee /sys/fs/resctrl/schemata') | 91 | run('sudo echo "L3:0=0000;1=0000;2=0000;3=000f" | sudo tee /sys/fs/resctrl/schemata') |
| 91 | for core in range(16): | 92 | for core in range(16): |
| 92 | if core not in all_cores: | 93 | if core not in all_cores: |
| @@ -98,10 +99,11 @@ def main(pathName): | |||
| 98 | mask = mask[:in_ccx] +'f'+ mask[in_ccx+1:] | 99 | mask = mask[:in_ccx] +'f'+ mask[in_ccx+1:] |
| 99 | if ccx == 0: | 100 | if ccx == 0: |
| 100 | run('echo "L3:0=' + mask + ';1=0000;2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) | 101 | run('echo "L3:0=' + mask + ';1=0000;2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) |
| 102 | # run('echo "L3:0=ffff;1=0000;2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) | ||
| 101 | if ccx == 1: | 103 | if ccx == 1: |
| 102 | run('echo "L3:0=0000;1=' + mask + ';2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) | 104 | run('echo "L3:0=0000;1=' + mask + ';2=0000;3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) |
| 103 | if ccx == 2: | 105 | if ccx == 2: |
| 104 | run('echo "L3:0=0000;1=0000;2='+ mask +';3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) | 106 | run('echo "L3:0=0000;1=0000;2=' + mask + ';3=0000" > /sys/fs/resctrl/core-{}/schemata'.format(core)) |
| 105 | if ccx == 3: | 107 | if ccx == 3: |
| 106 | run('echo "L3:0=0000;1=0000;2=0000;3=' + mask + '" > /sys/fs/resctrl/core-{}/schemata'.format(core)) | 108 | run('echo "L3:0=0000;1=0000;2=0000;3=' + mask + '" > /sys/fs/resctrl/core-{}/schemata'.format(core)) |
| 107 | 109 | ||
| @@ -129,9 +131,11 @@ def main(pathName): | |||
| 129 | return 1 | 131 | return 1 |
| 130 | # single tasks | 132 | # single tasks |
| 131 | if launch[0] == '0': | 133 | if launch[0] == '0': |
| 132 | binary = binary_path + binary_name + "_single" | 134 | # binary = binary_path + binary_name + "_single" |
| 135 | binary = binary_path + binary_name + "_single_no_litmus" | ||
| 133 | # Arg format: <unique name> <num_iters> <core> <NULL runID> <save?> <period> <crit lvl> | 136 | # Arg format: <unique name> <num_iters> <core> <NULL runID> <save?> <period> <crit lvl> |
| 134 | arg = " " + task_name + " " + num_iters +" " + core_num +" " + run_id +" " + save_result+" " + period +" " + crt_level + " "+ phase | 137 | # arg = " " + task_name + " " + num_iters +" " + core_num +" " + run_id +" " + save_result+" " + period +" " + crt_level + " "+ phase |
| 138 | arg = " " + task_name + " " + num_iters +" " + core_num +" " + run_id +" " + save_result+" " | ||
| 135 | # print(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg) | 139 | # print(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg) |
| 136 | bench_tsk = subprocess.Popen(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg, shell=True, executable='/bin/bash', stderr=stderr_file) | 140 | bench_tsk = subprocess.Popen(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg, shell=True, executable='/bin/bash', stderr=stderr_file) |
| 137 | pid_str = ID2PID(binary + " " + task_name) | 141 | pid_str = ID2PID(binary + " " + task_name) |
