Adding support for parallel recovery.
authorEsteban Meneses <emenese2@illinois.edu>
Thu, 7 Jun 2012 19:43:41 +0000 (14:43 -0500)
committerEsteban Meneses <emenese2@illinois.edu>
Thu, 7 Jun 2012 19:43:41 +0000 (14:43 -0500)
src/ck-core/ckreduction.C

index e32561922cae962a73cc32abe03d1e201e865062..316aae725e9b966e223e056c89ba528b07fab750 100644 (file)
@@ -399,7 +399,6 @@ void CkReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
 
        // if object is an immigrant recovery object, we send the contribution to the source PE
        if(CpvAccess(_currentObj)->mlogData->immigrantRecFlag){
-               //DELETE CkPrintf("[%d] Sending contribution via message %d\n",CkMyPe(),m->redNo);
        thisProxy[CpvAccess(_currentObj)->mlogData->immigrantSourcePE].contributeViaMessage(m);
                return;
        }
@@ -408,7 +407,6 @@ void CkReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
     CpvAccess(_currentObj) = this;
 
        // adding contribution
-       //DELETE if(CkMyPe() == 4) CkPrintf("[%d] Adding local contribution %d\n",CkMyPe(),m->redNo);
        addContribution(m);
 
     CpvAccess(_currentObj) = oldObj;
@@ -420,8 +418,6 @@ void CkReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
 #if defined(_FAULT_CAUSAL_)
 void CkReductionMgr::contributeViaMessage(CkReductionMsg *m){
 
-       //DELETE CkPrintf("[%d] Receiving contribution via message %d %d\n",CkMyPe(),m->redNo,redNo);
-       
        // adding contribution
     addContribution(m);
 }
@@ -655,8 +651,6 @@ void CkReductionMgr::finishReduction(void)
   }
   //CkPrintf("[%d]finishReduction called for redNo %d with nContrib %d at %.6f\n",CkMyPe(),redNo, nContrib,CmiWallTimer());
 #if (defined(_FAULT_CAUSAL_))
-       //DELETE CkPrintf("[%d] finishReduction %d %d %d %d\n",CkMyPe(),nContrib,(lcount+adj(redNo).lcount),nRemote,treeKids()); 
-       //CODING
        if (nContrib<(lcount+adj(redNo).lcount)-CpvAccess(_numImmigrantRecObjs)){
         DEBR((AA"Need more local messages %d %d\n"AB,nContrib,(lcount+adj(redNo).lcount)));
                return;//Need more local messages
@@ -682,7 +676,11 @@ void CkReductionMgr::finishReduction(void)
   {//Pass data up tree to parent
     DEBR((AA"Passing reduced data up to parent node %d.\n"AB,treeParent()));
     DEBR((AA"Message gcount is %d+%d+%d.\n"AB,result->gcount,gcount,adj(redNo).gcount));
+#if (defined(_FAULT_CAUSAL_))
+    result->gcount+=gcount+adj(redNo).gcount-CpvAccess(_numImmigrantRecObjs);
+#else
     result->gcount+=gcount+adj(redNo).gcount;
+#endif
     thisProxy[treeParent()].RecvMsg(result);
   }
   else