wip

1 files changed, 28 insertions, 16 deletions

diff --git a/run_case_study.py b/run_case_study.py
index 9d07198..7da8f4e 100644
--- a/run_case_study.py
+++ b/run_case_study.py
@@ -2,12 +2,22 @@ import os
 import sys
 import re
 import csv
+import time
 import subprocess
+
+all_pids=[]
 def run(command):
     print(command)
-    #os.system(command)
+    os.system(command)
+def addpid(pid):
+    with open("./pids.txt", "a") as f:
+        f.write(str(pid) + "\n")
+
 
 def main():
+    with open("./pids.txt", "w") as f:
+        f.write("")
+
     pathName = sys.argv[1]
     tacle_pairs_path = "./all_pairs"
     tacle_baseline_path = "./baseline"
@@ -91,9 +101,6 @@ def main():
     pairID = 0
     i = 0
     for task in levelAB:
-        i+=1
-        if(i>1):
-            break;
         task1 = int(task[2])
         task2 = int(task[5])
         name1 = all_tasks[task1][2]
@@ -120,11 +127,11 @@ def main():
                 binary = "./baseline/bin/" + name1 +  arg
             else:
                 binary = dis_inputs[name1] + " | ./dis/" + name1 + arg
-            #proc = subprocess.open([binary + " &"], shell = True)
-            print(binary + " &" )
-            pid = 0#proc.pid
-            run("sudo echo " + pid + " > sudo /sys/fs/resctrl/level-ab-core-" + core + "/tasks")
-
+            proc = subprocess.Popen([binary], shell = True)
+            #print(binary + " &" )
+            pid = proc.pid
+            run("sudo echo " + str(pid) + " > sudo /sys/fs/resctrl/level-ab-core-" + core + "/tasks")
+            addpid(pid)
         else:
             pairID += 1
             arg1 =  " NULL -1 " + core + " 0 NULL NULL 0 " + str(pairID) + " " + period1 + " " + criticality
@@ -136,18 +143,20 @@ def main():
             else:
                 binary1 =  dis_inputs[name1] + " | ./dis/" + name1 + "_all" + arg1
                 binary2 =  dis_inputs[name2] + " | ./dis/" + name2 + "_all" + arg2
-            #proc1 = subprocess.Popen(["sudo numactl --membind=0 " + binary1 + " &"], shell = True)
-            #proc2 = subprocess.Popen(["sudo numactl --membind=1 " + binary2 + " &"], shell = True)
-            print("sudo numactl --membind=0 " + binary1 + " &")
-            print("sudo numactl --membind=1 " + binary2 + " &")
-            pid1 = 0#proc1.pid
-            pid2 = 0#proc2.pid
+            proc1 = subprocess.Popen(["sudo numactl --membind=0 " + binary1], shell = True)
+            proc2 = subprocess.Popen(["sudo numactl --membind=1 " + binary2], shell = True)
+            #print("sudo numactl --membind=0 " + binary1 + " &")
+            #print("sudo numactl --membind=1 " + binary2 + " &")
+            pid1 = proc2.pid + 1
+            pid2 = proc2.pid + 3
 
             run("sudo echo " + str(pid1) + " > sudo /sys/fs/resctrl/level-ab-core-" + core + "/tasks")
             run("sudo echo " + str(pid2) + " > sudo /sys/fs/resctrl/level-ab-core-" + core + "/tasks")
-    exit(1)
+            addpid(pid1)
+            addpid(pid2)
 
     for task in levelC:
+        continue
         i+=1
         if(i>8):
             break
@@ -177,5 +186,8 @@ def main():
         run("sudo echo " + str(pid) + " > sudo /sys/fs/resctrl/level-ab-ccx-" + ccx + "/tasks")
     #os.system("/playpen/mc2/liblitmus/release_ts")
     #os.system("ls")
+    time.sleep(3)
 if __name__ == "__main__":
     main()
+
+