changes for debugging

diff --git a/Robust/src/Benchmarks/Recovery/FileSystem/recovery/FileSystem.java b/Robust/src/Benchmarks/Recovery/FileSystem/recovery/FileSystem.java
index c66c30ab2f398617660dace928f36fab917b3597..d98bc43fc93806de2f1d5dab6377529beb341f51 100644 (file)
--- a/Robust/src/Benchmarks/Recovery/FileSystem/recovery/FileSystem.java
+++ b/Robust/src/Benchmarks/Recovery/FileSystem/recovery/FileSystem.java
@@ -33,8 +33,11 @@ public class FileSystem extends Thread {
       current=root.makeDirectory(global new GlobalString(String.valueOf(mid)));\r
     }\r
     Random r=new Random();\r
+    System.out.println("Starting FileSystem");\r
     char ptr[]=new char[1024];\r
-    for(int i=0;i<40000;i++) {\r
+    //for(int i=0;i<40000;i++) {\r
+    for(int i=0;i<15000;i++) {\r
+      System.out.println("i= " + i + "\n");\r
       atomic {\r
        for(int count=0;count<10;count++) {\r
          int value=r.nextInt(100);\r

diff --git a/Robust/src/Benchmarks/Recovery/FileSystem/recovery/makefile b/Robust/src/Benchmarks/Recovery/FileSystem/recovery/makefile
index 4d744bd5bf3ecec9abad92e7e2774f7c0121873a..b4ff273dbf459b6d0d58d4de8923e3f7d89da45a 100644 (file)
--- a/Robust/src/Benchmarks/Recovery/FileSystem/recovery/makefile
+++ b/Robust/src/Benchmarks/Recovery/FileSystem/recovery/makefile
@@ -3,7 +3,7 @@ SRC1=${MAINCLASS}.java \
      DistributedHashMap.java \
      Directory.java \
      DFile.java
-FLAGS= -recovery -recoverystats -transstats -dsm -dsmcaching -debug -optimize -mainclass ${MAINCLASS}
+FLAGS= -recovery -recoverystats -transstats -dsm -dsmcaching -debug -nooptimize -mainclass ${MAINCLASS}
 DSMFLAGS=-transstats -dsm -dsmcaching -optimize -mainclass ${MAINCLASS}
 default:
        ../../../../buildscript ${FLAGS} -o ${MAINCLASS} ${SRC1}

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c b/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
index 8959a1260cfb4c0d9a0dfef9ec408e2b984f0eb4..dbd4b745042ff99b45a94cbe3ae865ce8e510ba1 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
@@ -971,8 +971,7 @@ int processClientReq(fixed_data_t *fixed, trans_commit_data_t *transinfo,
     }
     else {
       tNode->status = TRANS_WAIT;
-//      printf("%s -> Waiting!! \ttransID : %u decision : %d status : %d \n",__func__,tNode->transid,tNode->decision,tNode->status);
-//      sleep(3);
+      printf("%s -> Waiting!! \ttransID : %u decision : %d status : %d \n",__func__,tNode->transid,tNode->decision,tNode->status);
       randomdelay();
     }
     

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/trans.c b/Robust/src/Runtime/DSTM/interface_recovery/trans.c
index 7591bc6cf3d8153cb183d6a12b62cefda1eb7c12..d82e2a95260d2704aa304f00f26e332c4bfd71e6 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/trans.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/trans.c
@@ -1534,7 +1534,7 @@ int transCommit() {
     objstrDelete(t_cache);
     t_chashDelete();
 #ifdef RECOVERY
-    if(deadmid != -1) { /* if deadmid is greater than or equal to 0,                           then there is dead machine. */
+    if(deadmid != -1) { /* if deadmid is greater than or equal to 0, then there is dead machine. */
       notifyLeaderDeadMachine(deadmid);
     }
 #endif
@@ -1881,7 +1881,7 @@ void restoreDuplicationState(unsigned int deadHost,unsigned int epoch_num)
     do {
       sdlist = getSocketLists();
   
-//      printf("%s -> I'm currently leader num : %d ping machines\n\n",__func__,epoch_num);
+      printf("%s -> I'm currently leader num : %d ping machines\n\n",__func__,epoch_num);
       if((flag = pingMachines(epoch_num,sdlist,&tList)) < 0) break;
 
       pthread_mutex_lock(&translist_mutex);
@@ -1911,9 +1911,9 @@ void restoreDuplicationState(unsigned int deadHost,unsigned int epoch_num)
   }while(0);
 
   if(flag < 0) {
-//    printf("%s -> higher epoch\n",__func__);
+    printf("%s -> higher epoch\n",__func__);
     while(okCommit != TRANS_OK) {
-//      printf("%s -> Waiting\n",__func__);
+      //printf("%s -> Waiting\n",__func__);
       randomdelay();
     }
     

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/translist.c b/Robust/src/Runtime/DSTM/interface_recovery/translist.c
index 8176fd5e31b2ef398ab774be769da1de5b3f5ca1..18e4416f22d8b9b8bc1229030bda5e36d0e0dcdb 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/translist.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/translist.c
@@ -102,7 +102,7 @@ tlist_t* tlistRemove(tlist_t* transList,unsigned int transid)
 {
 //  printf("%s -> REMOVE transID : %u \n",__func__,transid);
 
-  int flag = -1;
+  //int flag = -1;
   tlist_node_t* tmp;
   tlist_node_t* ptr = transList->head;
   tlist_node_t* prev = NULL;
@@ -133,7 +133,7 @@ tlist_t* tlistRemove(tlist_t* transList,unsigned int transid)
       prev->next = ptr->next;
       free(ptr);
       (transList->size)--;
-      flag = 0;
+      //flag = 0;
       transList->flag = 1;
       return transList;
     }