switch one point-to-point to group reduction.
authorGengbin Zheng <gzheng@illinois.edu>
Tue, 22 Nov 2011 21:39:49 +0000 (15:39 -0600)
committerGengbin Zheng <gzheng@illinois.edu>
Tue, 22 Nov 2011 21:39:49 +0000 (15:39 -0600)
src/ck-core/ckmemcheckpoint.C
src/ck-core/ckmemcheckpoint.ci

index 6d82761293cce97a5d2d743991c7ec648bd588b9..7ebee14243727d4e7714d54a80e1c4ae251c9a8a 100644 (file)
@@ -821,7 +821,8 @@ void CkMemCheckPT::recoverBuddies()
 
 #if 1
   if (expectCount == 0) {
-    thisProxy[0].quiescence(CkCallback(CkIndex_CkMemCheckPT::recoverArrayElements(), thisProxy));
+    contribute(CkCallback(CkReductionTarget(CkMemCheckPT, recoverArrayElements), thisProxy));
+    //thisProxy[0].quiescence(CkCallback(CkIndex_CkMemCheckPT::recoverArrayElements(), thisProxy));
   }
 #else
   if (CkMyPe() == 0) {
@@ -838,7 +839,8 @@ void CkMemCheckPT::gotData()
   if (ackCount == expectCount) {
     ackCount = 0;
     expectCount = -1;
-    thisProxy[0].quiescence(CkCallback(CkIndex_CkMemCheckPT::recoverArrayElements(), thisProxy));
+    //thisProxy[0].quiescence(CkCallback(CkIndex_CkMemCheckPT::recoverArrayElements(), thisProxy));
+    contribute(CkCallback(CkReductionTarget(CkMemCheckPT, recoverArrayElements), thisProxy));
   }
 }
 
index f95f576df68fc20c9ac32d469ccac80997e20e76..5ea573b3a821da3976ee9d9c02ce74be9281a938 100644 (file)
@@ -29,7 +29,7 @@ module CkMemCheckpoint {
        entry void removeArrayElements();
        entry void recoverBuddies();
        entry void recoverEntry(CkArrayCheckPTMessage *msg);
-       entry void recoverArrayElements();
+       entry [reductiontarget] void recoverArrayElements();
        entry void finishUp();
        entry void quiescence(CkCallback&);
         entry void inmem_restore(CkArrayCheckPTMessage *m);