Changes to increase garbage collector heap

[IRC.git] / Robust / src / Runtime / DSTM / interface / signal.c

diff --git a/Robust/src/Runtime/DSTM/interface/signal.c b/Robust/src/Runtime/DSTM/interface/signal.c
index 9433e4fbe9bd4d28269d889807adabaff3c1cf87..6cd99c6c914324395cd9f7fe02911d7e90112032 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface/signal.c
+++ b/Robust/src/Runtime/DSTM/interface/signal.c
@@ -9,7 +9,8 @@ extern int nmhashSearch;
 extern int nprehashSearch;
 extern int nRemoteSend;
 extern int nSoftAbort;
-extern int numprefetchsites;
+extern unsigned int myIpAddr;
+
 void handle();
 extern pfcstats_t *evalPrefetch;
 
@@ -23,13 +24,6 @@ void transStatsHandler(int sig, siginfo_t* info, void *context) {
   printf("nprehashSearch = %d\n", nprehashSearch);
   printf("nRemoteReadSend = %d\n", nRemoteSend);
   printf("nSoftAbort = %d\n", nSoftAbort);
-  //TODO Remove later
-  /*
-     int i;
-     for(i=0; i<numprefetchsites; i++) {
-     printf("siteid = %d,  callCount = %d\n", i, evalPrefetch[i].callcount);
-     }
-   */
   exit(0);
 #endif
 }
@@ -45,3 +39,181 @@ void handle() {
   sigaction(SIGUSR1, &siga, 0);
 #endif
 }
+/*
+
+   double getMax(double *array, int size) {
+   int i;
+   double max = array[0];
+   for(i = 0; i < size; i++) { // for 2 MCS
+    if(max <= array[i])
+      max = array[i];
+   }
+   return max;
+   }
+
+   double getMin(double *array, int size) {
+   int i;
+   double min = array[0];
+   for(i = 0; i < size; i++) { //for 2 MCs
+    if(min > array[i])
+      min = array[i];
+   }
+   return min;
+   }
+
+   int getthreadid() {
+   int val;
+   if(((128<<24)|(195<<16)|(175<<8)|84) == myIpAddr)
+    val = 0;
+   else if(((128<<24)|(195<<16)|(175<<8)|86) == myIpAddr)
+    val = 1;
+   else if(((128<<24)|(195<<16)|(175<<8)|87) == myIpAddr)
+    val = 2;
+   else if(((128<<24)|(195<<16)|(175<<8)|88) == myIpAddr)
+    val = 3;
+   else
+    val = 4;
+   printf("threadid/mid = %d\n", val);
+   return val;
+   }
+
+   double getfast(int siteid, int threadid) {
+   int i, j, k;
+   double fast = 0.0;
+   //for(i = 0; i < 2; i++) { // for 2 MC
+   for(i = 0; i < 5; i++) { // for 5 MC
+    if(i == threadid)
+      continue;
+    for(k= 0; k<countstats[i]; k++) {
+      if(fast < threadstats[i][siteid][k])
+        fast = threadstats[i][siteid][k];
+    }
+   }
+   return fast;
+   }
+
+   void sortascending() {
+   int i;
+   for(i = 0 ; i < 5; i++) {
+
+   }
+   }
+
+   void bubblesort() {
+   const int size = 5; // 5MCS
+   int siteid;
+   for(siteid = 0; siteid < 15; siteid++) {
+    int k;
+    for(k=0; k<counttransCommit; k++) {
+      int i;
+      for(i=0; i < size-1; i++) {
+        int j;
+        for(j=0; j < size-1-i; j++) {
+          if(threadstats[j][siteid][k] > threadstats[j+1][siteid][k]) {
+            double temp;
+            temp = threadstats[j+1][siteid][k];
+            threadstats[j+1][siteid][k] = threadstats[j][siteid][k];
+            threadstats[j][siteid][k] = temp;
+          }
+        }
+      } //end of sorting
+    } // end for each transaction
+   } // end for each siteid
+   }
+
+   double avgofthreads(int siteid, int threadid) {
+   double total = 0.0;
+   int k;
+   for(k = 0; k<counttransCommit; k++) {
+    total += threadstats[threadid][siteid][k];
+   }
+   double avg = 0.0;
+   avg = total/counttransCommit;
+   return avg;
+   }
+
+   double avgfast(int siteid, int threadid) {
+   int i, j, k;
+   double fast;
+   for(k = 0; k<counttransCommit; k++) {
+    fast = 0.0;
+    for(i = 0; i <5; i++) { //for 5 mC
+      if(i == threadid)
+        continue;
+      if(fast < threadstats[i][siteid][k]) {
+        fast = threadstats[i][siteid][k];
+      }
+    }
+    avgfasttime[k] = fast;
+   }
+   double total= 0.0;
+   for(k = 0; k<counttransCommit; k++) {
+    total += avgfasttime[k];
+   }
+   return (total/counttransCommit);
+   }
+
+   double avgslow(int siteid, int threadid) {
+   int i, j, k;
+   double slow;
+   for(k = 0; k<counttransCommit; k++) {
+    slow = 1.0;
+    for(i = 0; i < 2; i++) { //for 2 mC
+      if(i == threadid)
+        continue;
+      if(slow > threadstats[i][siteid][k]) {
+        slow = threadstats[i][siteid][k];
+      }
+    }
+    avgslowtime[k] =  slow;
+   }
+   double total= 0.0;
+   for(k = 0; k<counttransCommit; k++) {
+    total += avgslowtime[k];
+   }
+   return (total/counttransCommit);
+   }
+
+   double getslowest(int siteid, int threadid) {
+   int i, j, k;
+   double slow = 1.0;
+   //for(i = 0; i < 2; i++) { // for 2 MC
+   for(i = 0; i < 5; i++) { // for 5 MC
+    if(i == threadid)
+      continue;
+    for(k= 0; k<countstats[i]; k++) {
+      if(slow > threadstats[i][siteid][k]) {
+        slow = threadstats[i][siteid][k];
+      }
+    }
+   }
+   return slow;
+   }
+
+   double getavg(int siteid, int threadid) {
+   double total=0.0;
+   int i, j, k;
+   int totalcount = 0;
+   //for(i = 0; i < 2; i++) { //for 2 MC
+   for(i = 0; i < 5; i++) { //for 5 MC
+    if(i == threadid)
+      continue;
+    for(k= 0; k<countstats[i]; k++) {
+      total += threadstats[i][siteid][k];
+    }
+    totalcount +=countstats[i];
+   }
+   double avg = total/totalcount;
+   return avg;
+   }
+
+   double getavgperthd(int siteid, int threadid) {
+   double total=0.0;
+   int i, j, k;
+   for(k= 0; k<countstats[threadid]; k++) {
+    total += threadstats[threadid][siteid][k];
+   }
+   double avg = total/countstats[threadid];
+   return avg;
+   }
+ */