removing debugging messages

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c b/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
index 6e6c31682f9517b350359d96ee4b453978c93e9b..ef09f187b2ab3920ab409054fe3cb1bfee7a5394 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/dstmserver.c
@@ -457,8 +457,7 @@ void *dstmAccept(void *acceptfd) {
                                }
 
                                recv_data((int)acceptfd, buffer, size);
-
-
+        
                                oid = *((unsigned int *)buffer);
                                size = sizeof(unsigned int);
                                version = *((unsigned short *)(buffer+size));

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/mlookup.c b/Robust/src/Runtime/DSTM/interface_recovery/mlookup.c
index fa4cef88fff6715c08b8902b2f0d54022ca7db38..1d19b851480f1a9e446816c79d6cb369bdad8e12 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/mlookup.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/mlookup.c
@@ -221,12 +221,14 @@ int mhashGetDuplicate(void **dupeptr, int backup) { //how big?
        mhashlistnode_t *node;
 //     go through object store;
 //     track sizes, oids, and num
+//  printf("%s -> Before mutex lock\n",__func__);
        pthread_mutex_lock(&mlookup.locktable); 
+//  printf("%s -> After mutex lock\n",__func__);
 
   size =0;
   tempsize =0;
 
-       for(i = 0; i < mlookup.size; i++) {
+  for(i = 0; i < mlookup.size; i++) {
                if (mlookup.table[i].key != 0) {
                        node = &mlookup.table[i];
                        while(node != NULL) { // no nodes
@@ -245,6 +247,7 @@ int mhashGetDuplicate(void **dupeptr, int backup) { //how big?
                        }
                }
        }
+//  printf("%s -> size = %d\n",__func__,size);
 
   pthread_mutex_unlock(&mlookup.locktable);
 
@@ -264,7 +267,6 @@ int mhashGetDuplicate(void **dupeptr, int backup) { //how big?
        ptr += sizeof(unsigned int);
   *((int *)(ptr)) = size;
        ptr += sizeof(int);
-  void* ttt = *dupeptr;
 
        for(i = 0; i < numdupe; i++) {
     header = mhashSearch(oidsdupe[i]);

diff --git a/Robust/src/Runtime/DSTM/interface_recovery/trans.c b/Robust/src/Runtime/DSTM/interface_recovery/trans.c
index f69d750bbdf6281e1f4b2d879c4649e2f20d0772..4f98e5e1195b9ea833f6b5de47b265e99228ddfe 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface_recovery/trans.c
+++ b/Robust/src/Runtime/DSTM/interface_recovery/trans.c
@@ -1761,7 +1761,6 @@ int transComProcess(trans_req_data_t *tdata, trans_commit_data_t *transinfo) {
     }
 
     header->version += 1;
-    //printf("oid: %u, new header version: %d\n", oidmod[i], header->version);
     if(header->notifylist != NULL) {
 #ifdef RECOVERY
       if(header->isBackup != 0)   // if it is primary obj, notify
@@ -2501,6 +2500,9 @@ int allHostsLive() {
 
 #ifdef RECOVERY
 void duplicateLostObjects(unsigned int mid){
+  printf("Recovery Start");
+  time_t st = time(NULL);
+  time_t fi;
 #ifndef DEBUG
        printf("%s-> Start, mid: [%s]\n", __func__, midtoIPString(mid));  
 #endif
@@ -2583,6 +2585,10 @@ void duplicateLostObjects(unsigned int mid){
     freeSockWithLock(transPrefetchSockPool, backupMid, sd);
        }
 
+  fi = time(NULL);
+
+  printf("time elapse = %d",fi-st);
+
 #ifndef DEBUG
        printf("%s-> End\n", __func__);  
 #endif
@@ -2804,7 +2810,7 @@ int reqNotify(unsigned int *oidarry, unsigned short *versionarry, unsigned int n
     return -1;
   }
   ndata->numoid = numoid;
-  printf("%s -> ndata = %d numoid = %d\n",__func__,ndata,numoid);
+//  printf("%s -> ndata = %d numoid = %d\n",__func__,ndata,numoid);
   ndata->threadid = threadid;
   ndata->oidarry = oidarry;
   ndata->versionarry = versionarry;