L3 and irqs

4 files changed, 37 insertions, 35 deletions

diff --git a/dag_example b/dag_example
index 233528f..ce39489 100644
--- a/dag_example
+++ b/dag_example
@@ -1,4 +1,4 @@
-1, mser_qcif, mser001, 5, 0, 1, 1, 100, 1, 0, sift_qcif, sift001

-0, mser_qcif, mser002, 3, 1, 2, 1, 10, 1, 0

-1, svm_qcif, svm001, 6, 0, 3, 1, 50, 1, 0, localization_qcif, localization001

-0, tracking_qcif, tracking001, 3, 2, 4, 1, 9, 1, 0

+1, mser_qcif, mser001, 5, 1, 1, 1, 100, 1, 0, sift_qcif, sift001

+0, mser_qcif, mser002, 3, 2, 2, 1, 10, 1, 0

+1, svm_qcif, svm001, 6, 2, 3, 1, 50, 1, 0, localization_qcif, localization001

+0, tracking_qcif, tracking001, 3, 3, 4, 1, 20, 1, 17

diff --git a/deadline_misses b/deadline_misses
index a6fe6a8..7025d8b 100644
--- a/deadline_misses
+++ b/deadline_misses
@@ -1,13 +1,11 @@
-(tracking001/2814:2) HAZARDOUS: Level-B tardy 1763167 ns, relative tardiness 0.195907
-(tracking001/2814:3) HAZARDOUS: Level-B tardy 403976 ns, relative tardiness 0.044886
-(svm001/2797:2) HAZARDOUS: Level-B tardy 102712074 ns, relative tardiness 2.054241
-(svm001/2797:3) HAZARDOUS: Level-B tardy 139940064 ns, relative tardiness 2.798801
-(localization001/2800:3) HAZARDOUS: Level-B tardy 178370600 ns, relative tardiness 3.567412
-(svm001/2797:4) HAZARDOUS: Level-B tardy 196180824 ns, relative tardiness 3.923616
-(localization001/2800:4) HAZARDOUS: Level-B tardy 232648236 ns, relative tardiness 4.652965
-(svm001/2797:5) HAZARDOUS: Level-B tardy 250110392 ns, relative tardiness 5.002208
-(localization001/2800:5) HAZARDOUS: Level-B tardy 286745163 ns, relative tardiness 5.734903
-(svm001/2797:6) HAZARDOUS: Level-B tardy 304772054 ns, relative tardiness 6.095441
-(localization001/2800:6) HAZARDOUS: Level-B tardy 341417704 ns, relative tardiness 6.828354
-(localization001/2800:7) HAZARDOUS: Level-B tardy 351348831 ns, relative tardiness 7.026977
-(svm001/2797:7) HAZARDOUS: Level-B tardy 351960956 ns, relative tardiness 7.039219
+(svm001/7932:2) HAZARDOUS: Level-B tardy 105144502 ns, relative tardiness 2.102890
+(localization001/7935:3) HAZARDOUS: Level-B tardy 121353473 ns, relative tardiness 2.427069
+(svm001/7932:3) HAZARDOUS: Level-B tardy 121694991 ns, relative tardiness 2.433900
+(localization001/7935:4) HAZARDOUS: Level-B tardy 137671344 ns, relative tardiness 2.753427
+(svm001/7932:4) HAZARDOUS: Level-B tardy 138065691 ns, relative tardiness 2.761314
+(localization001/7935:5) HAZARDOUS: Level-B tardy 154064855 ns, relative tardiness 3.081297
+(svm001/7932:5) HAZARDOUS: Level-B tardy 154402852 ns, relative tardiness 3.088057
+(localization001/7935:6) HAZARDOUS: Level-B tardy 170382265 ns, relative tardiness 3.407645
+(svm001/7932:6) HAZARDOUS: Level-B tardy 170731922 ns, relative tardiness 3.414638
+(localization001/7935:7) HAZARDOUS: Level-B tardy 186729966 ns, relative tardiness 3.734599
+(svm001/7932:7) HAZARDOUS: Level-B tardy 187062334 ns, relative tardiness 3.741247
diff --git a/redirect_irq.sh b/redirect_irq.sh
new file mode 100644
index 0000000..8435abf
--- /dev/null
+++ b/redirect_irq.sh
@@ -0,0 +1,13 @@
+#!/bin/bash
+# Redirect all interrupts to core 0
+# i=0
+for IRQ in /proc/irq/*
+do
+    # Skip default_smp_affinity
+    if [ -d $IRQ ]; then
+        irqList[$i]=$(cat $IRQ/smp_affinity_list)
+        echo 0 2> /dev/null > $IRQ/smp_affinity_list
+        echo $IRQ:  $(cat $IRQ/smp_affinity_list)
+    fi
+    i=$(( $i + 1 ))
+done
\ No newline at end of file
diff --git a/run_case_study_dag.py b/run_case_study_dag.py
index d9a0563..0a5c5fe 100755
--- a/run_case_study_dag.py
+++ b/run_case_study_dag.py
@@ -44,7 +44,7 @@ def ID2PID(lookupID):
     res = None
     # Find benchmark PID (avoid getting shell or numactl PID)
     try:
-        res = subprocess.check_output("pgrep -af ' " + lookupID + " ' | grep -v numactl", shell=True)
+        res = subprocess.check_output("pgrep -af '" + lookupID + "' | grep -v numactl", shell=True)
     except:
         res = None
     if res:
@@ -56,14 +56,6 @@ def ID2PID(lookupID):
 def main(pathName):
     with open("./pids.txt", "w") as f:
         f.write("")
-
-    tacle_pairs_path = "./all_pairs"
-    tacle_baseline_path = "./baseline"
-    dis_path = "./dis"
-    # List of lists
-    # Each list represents the parameters for a task as:
-    # [id, suite, binary name, criticality level (0-base), pet us (unused), period ms, wss (unused)]
-    all_tasks = []
    
     input_cmd = {}
     # Load input command for each binary
@@ -72,9 +64,6 @@ def main(pathName):
         for line in f:
             name, cmd = line.split(maxsplit=1)
             input_cmd[name.replace("./", "")] = cmd.replace("./", "./SD-VBS/").strip()
-    # for k in input_cmd:
-    #     print(k, input_cmd[k])
-    # return 1
 
     task_launches = []
     max_core = 0
@@ -85,8 +74,8 @@ def main(pathName):
             parameters = line.split(",")
             task_launches.append(parameters)
             core_num = int(parameters[CORE_NUM]) % 16
-            if max_core < core_num:
-                max_core = core_num
+            # if max_core < core_num:
+            #     max_core = core_num
             all_cores.add(core_num)
             # if parameters[0] == '1':
             #     other_core_num = int(parameters[OTHER_CORE_NUM]) % 16
@@ -98,7 +87,7 @@ def main(pathName):
 
     ### Allocate Cache Ways ###
     run('mount -t resctrl resctrl /sys/fs/resctrl') 
-#    run('echo "L3:0=0000,1=0000,2=0000,3=0000" > /sys/fs/resctrl/schemata')
+    run('sudo echo "L3:0=0000;1=0000;2=0000;3=000f" | sudo tee /sys/fs/resctrl/schemata')
     for core in range(16):
         if core not in all_cores:
             continue
@@ -145,7 +134,7 @@ def main(pathName):
             arg = " " + task_name  + " " + num_iters +" " +  core_num +" " +  run_id +" " + save_result+" " + period +" " +  crt_level + " "+ phase
             # print(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg)
             bench_tsk = subprocess.Popen(input_cmd[binary_name] + " | numactl --interleave=all " + binary + arg, shell=True, executable='/bin/bash', stderr=stderr_file)
-            pid_str = ID2PID(task_name)
+            pid_str = ID2PID(binary + " " + task_name)
             if not pid_str:
                 print("Unable to launch {} as a solo task! Exiting...".format(task_name))
                 return 1
@@ -170,11 +159,13 @@ def main(pathName):
             # print(input_cmd[other_binary_name] + " | numactl --membind=1 " + other_binary + arg2)
             bench_tsk1 = subprocess.Popen(input_cmd[binary_name] + " | numactl --membind=0 " + binary + arg1, shell=True, executable='/bin/bash', stderr=stderr_file)
             bench_tsk2 = subprocess.Popen(input_cmd[other_binary_name] + " | numactl --membind=1 " + other_binary + arg2, shell=True, executable='/bin/bash', stderr=stderr_file)
-            pid1_str = ID2PID(task_name)
-            pid2_str = ID2PID(other_task_name)
+            # print(binary + " " + task_name,other_binary + " " +other_task_name)
+            pid1_str = ID2PID(binary + " " + task_name)
+            pid2_str = ID2PID(other_binary + " " +other_task_name)
             if not pid1_str or not pid2_str:
                 print("Unable to launch {} and {} in a pair! Exiting...".format(task_name, other_task_name))
                 return 1
+            
             run("echo " + pid1_str + " > /sys/fs/resctrl/core-" + str(phys_core) + "/tasks")
             run("echo " + pid2_str + " > /sys/fs/resctrl/core-" + str(phys_core) + "/tasks")
             pairID += 1