1 files changed, 116 insertions, 0 deletions

diff --git a/baseline/source/extra.h b/baseline/source/extra.h
new file mode 100644
index 0000000..ca92812
--- /dev/null
+++ b/baseline/source/extra.h
@@ -0,0 +1,116 @@
+#include <time.h>
+#include <sys/mman.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <signal.h>
+#include <limits.h>
+
+#define L3_CACHE_SIZE (11264*1024)
+
+
+
+#define SET_UP char *thisProgram=argv[1];\
+    int maxJobs=atoi(argv[2]);\
+    char *thisCore=argv[3];\
+    char *otherCore=argv[4];\
+    char *otherProgram=argv[5];\
+    char *runID=argv[6];\
+    int output=atoi(argv[7]);\
+    pid_t killMe;\
+    struct timespec start, end;\
+    int jobsComplete;\
+    long progTime[maxJobs*output];\
+    char fileName[50];\
+    char *bigArray;\
+    int wasteCount;\
+    strcpy(fileName, runID);\
+    strcat(fileName, ".txt");\
+    mlockall(MCL_CURRENT || MCL_FUTURE);
+
+
+//if output==0, endless loop
+//avoids int overflow error with large numbers for background loops
+
+#define SAVE_RESULTS if(jobsComplete>-1) progTime[jobsComplete]=(end.tv_nsec-start.tv_nsec)+(1000000000*(end.tv_sec-start.tv_sec));
+
+#define WRITE_TO_FILE if (output){\
+    munlockall();\
+    FILE *fp=fopen(fileName, "a");\
+    if (fp == NULL) {\
+        perror("Error opening file. \n");\
+        exit(1);\
+    }\
+    for(jobsComplete=0; jobsComplete<maxJobs; jobsComplete++){\
+        fprintf(fp, "%s %s %s %s %d %ld %s %d \n",\
+        thisProgram, otherProgram, thisCore, otherCore, maxJobs,\
+        progTime[jobsComplete], runID, jobsComplete);\
+    }\
+    fclose(fp);\
+}
+
+// Call the wbinvld instruction (it's in a kernel module due to it being ring-0)
+#define FLUSH_CACHES FILE *fp = fopen("/proc/wbinvd", "r");\
+    if (fp == NULL) {\
+        perror("Cache flush module interface cannot be opened");\
+        exit(1);\
+    }\
+    char dummy;\
+    if (fread(&dummy, 1, 1, fp) == 0) {\
+        perror("Unable to access cache flush module interface");\
+        exit(1);\
+    }\
+    fclose(fp);
+
+//invoke start timer twice, stop timer to make sure timer and vars are in cache
+//#define START_TIMER clock_gettime(CLOCK_MONOTONIC, &start);\
+        clock_gettime(CLOCK_MONOTONIC, &end);\
+    clock_gettime(CLOCK_MONOTONIC, &start);\
+
+#define START_TIMER clock_gettime(CLOCK_MONOTONIC, &start);
+
+#define STOP_TIMER clock_gettime(CLOCK_MONOTONIC, &end);
+
+//waste a millisecond
+
+#define WASTE_TIME clock_gettime(CLOCK_MONOTONIC, &start);\
+do{clock_gettime(CLOCK_MONOTONIC, &end);}\
+while( (end.tv_sec*1000000000+end.tv_nsec)-(start.tv_sec*1000000000+start.tv_nsec) < 1000000);
+
+
+#define SLEEP nanosleep((const struct timespec[]){{0, 1000000}}, NULL);
+
+//#define LOOP_WASTE for(wasteCount=0; wasteCount<1000000; wasteCount++){}
+
+//at beginning of loop clear cache, waste some time
+//wasting time allows interfering process to build up some cache presence
+//using sleep instead of waste time loop causes problems
+//both sleeping and spinning give advantage to threaded task
+//#define START_LOOP if (output) {KILL_CACHE  START_TIMER}
+
+//#define START_LOOP if (output){START_TIMER}
+
+//#define STOP_LOOP if (output) {STOP_TIMER SAVE_RESULTS}
+//if (!output) {jobsComplete--;}
+
+#define START_LOOP FLUSH_CACHES START_TIMER
+#define STOP_LOOP STOP_TIMER SAVE_RESULTS
+
+
+/*
+Intended structure
+
+main
+SET_UP
+notice that STOP LOOP negates the ++ if outout=0
+for (jobsComplete=-1; jobsComplete<maxJobs; jobsComplete++){
+        KILL_CACHE
+        START_TIMER
+        tacleInit();
+        tacleMain();
+        STOP_TIMER
+        SAVE_RESULTS
+}
+WRITE_TO_FILE
+tacleReturn 
+*/