minor
[charm.git] / src / ck-core / ckmemcheckpoint.C
index 4b26f15ba401129e63a3ab829cb7553a06671b87..504c2eec70ff88065b9ff464edfff0f1f7e1041c 100644 (file)
@@ -520,7 +520,6 @@ void CkMemCheckPT::pupAllElements(PUP::er &p){
        }
        p | numElements;
        if(!p.isUnpacking()){
-               //CKLOCMGR_LOOP(mgr->checkpointRemoteIdx(p););
                CKLOCMGR_LOOP(MemElementPacker packer(mgr,p);mgr->iterate(packer););
        }
 #endif
@@ -603,8 +602,6 @@ static inline void _handleProcData(PUP::er &p)
 
 void CkMemCheckPT::sendProcData()
 {
-  if(CkMyPe()==0)
-     CkPrintf("begin send proc checkpoint data at %lf\n",CmiWallTimer()); 
   // find out size of buffer
   int size;
   {
@@ -622,15 +619,11 @@ void CkMemCheckPT::sendProcData()
   msg->pe = CkMyPe();
   msg->len = size;
   msg->reportPe = cpStarter;  //in case other processor isn't in checkpoint mode
-  if(CkMyPe()==0)
-     CkPrintf("end packing proc checkpoint data at %lf\n",CmiWallTimer()); 
   thisProxy[ChkptOnPe(CkMyPe())].recvProcData(msg);
 }
 
 void CkMemCheckPT::recvProcData(CkProcCheckPTMessage *msg)
 {
-  if(CkMyPe()==1)
-     CkPrintf("recv proc checkpoint data from 0 at %lf\n",CmiWallTimer()); 
   if (CpvAccess(procChkptBuf)) delete CpvAccess(procChkptBuf);
   CpvAccess(procChkptBuf) = msg;
   DEBUGF("[%d] CkMemCheckPT::recvProcData report to %d\n", CkMyPe(), msg->reportPe);
@@ -707,6 +700,7 @@ void CkMemCheckPT::report()
   CmiAssert(CpvAccess(procChkptBuf));
   //CkPrintf("[%d] Checkpoint object size: %d len: %d Processor data: %d \n", CkMyPe(), objsize, len, CpvAccess(procChkptBuf)->len);
 #else
+  if(CkMyPe()==0)
   CkPrintf("[%d] Checkpoint Processor data: %d \n", CkMyPe(), CpvAccess(procChkptBuf)->len);
 #endif
 }
@@ -965,13 +959,11 @@ void CkMemCheckPT::gotData()
 void CkMemCheckPT::updateLocations(int n, CkGroupID *g, CkArrayIndex *idx,int nowOnPe)
 {
 
-         CkPrintf("[%d] receive from %d at %lf\n",CkMyPe(),nowOnPe,CmiWallTimer());
   for (int i=0; i<n; i++) {
     CkLocMgr *mgr = CProxy_CkLocMgr(g[i]).ckLocalBranch();
     mgr->updateLocation(idx[i], nowOnPe);
   }
        thisProxy[nowOnPe].gotReply();
-               CkPrintf("[%d] reply to %d at %lf\n",CkMyPe(),nowOnPe,CmiWallTimer());
 }
 
 // restore array elements
@@ -1034,7 +1026,6 @@ void CkMemCheckPT::recoverArrayElements()
   for (int i=0; i<CkNumPes(); i++) {
     if (gmap[i].size() && i!=CkMyPe()&& i==thisFailedPe) {
       thisProxy[i].updateLocations(gmap[i].size(), gmap[i].getVec(), imap[i].getVec(), CkMyPe());
-       CkPrintf("[%d] send to %d at %lf\n",CkMyPe(),i,CmiWallTimer());
        flag++; 
          }
   }
@@ -1058,7 +1049,6 @@ if(flag == 0)
 }
 
 void CkMemCheckPT::gotReply(){
-    CkPrintf("[%d] got reply at %lf\n",CkMyPe(),CmiWallTimer());
     contribute(CkCallback(CkReductionTarget(CkMemCheckPT, finishUp), thisProxy));
 }
 
@@ -1078,12 +1068,6 @@ void CkMemCheckPT::recoverAll(CkArrayCheckPTMessage * msg,CkVec<CkGroupID> * gma
 #if STREAMING_INFORMHOME
                        mgr->resume(idx,p,CmiFalse);
 #else
-                       if(homePe == thisFailedPe && homePe!=CkMyPe()){
-                               mgr->resume(idx,p,CmiFalse);
-                               //mgr->resume(idx,p,CmiTrue);
-       // CkPrintf("[%d] send to crashed pe %d\n",CkMyPe(),thisFailedPe);
-      }
-      else
                                mgr->resume(idx,p,CmiFalse);
 #endif
                          /*CkLocRec_local *rec = loc.getLocalRecord();
@@ -1545,7 +1529,7 @@ void pingCheckHandler()
 {
 #if CMK_MEM_CHECKPOINT
   double now = CmiWallTimer();
-  if (lastPingTime > 0 && now - lastPingTime > 20 && !CkInLdb()) {
+  if (lastPingTime > 0 && now - lastPingTime > 4 && !CkInLdb()) {
     int i, pe, buddy;
     // tell everyone the buddy dies
     CkMemCheckPT *obj = CProxy_CkMemCheckPT(ckCheckPTGroupID).ckLocalBranch();