kNeighbor changes revert
authorHarshitha <gplkrsh2@illinois.edu>
Fri, 12 Oct 2012 17:13:30 +0000 (12:13 -0500)
committerHarshitha <gplkrsh2@illinois.edu>
Fri, 12 Oct 2012 17:13:30 +0000 (12:13 -0500)
examples/charm++/load_balancing/kNeighbor/kNeighbor.C

index ac416d9f084e46bbb817e9257a7e8a9974a44b68..6d3ad974ca6cf9dfd839d375f6af554f2c417848 100644 (file)
@@ -121,18 +121,16 @@ class Main: public CBase_Main {
        return;
       }
 
-      gStarttime = CmiWallTimer();
-      for (int i=0; i<num_chares; i++)
-       array[i].commWithNeighbors();
+      gStarttime = CkWallTimer();
+       array.commWithNeighbors();
     }
 
     void resumeIter() {
 #if DEBUG
       CkPrintf("Resume iteration at step %d\n", currentStep);
 #endif
-      gStarttime = CmiWallTimer();
-      for (int i=0; i<num_chares; i++)
-       array[i].commWithNeighbors();
+      gStarttime = CkWallTimer();
+       array.commWithNeighbors();
     }
 
     void terminate(CkReductionMsg *msg) {
@@ -158,7 +156,7 @@ class Main: public CBase_Main {
     void nextStep(CkReductionMsg  *msg) {
       maxTime = *((double *)msg->getData());
       delete msg;
-      double wholeStepTime = CmiWallTimer() - gStarttime;
+      double wholeStepTime = CkWallTimer() - gStarttime;
       timeRec[currentStep] = wholeStepTime/CALCPERSTEP;
       if(currentStep % 10 == 0)
        CkPrintf("Step %d with msg size %d finished: max=%f, total=%f\n", currentStep, currentMsgSize, maxTime/CALCPERSTEP, wholeStepTime/CALCPERSTEP);
@@ -283,7 +281,7 @@ class Block: public CBase_Block {
 
       // Send msgs to neighbors
       for (int i=0; i<numNeighbors; i++) {
-       //double memtimer = CmiWallTimer();
+       //double memtimer = CkWallTimer();
 
        toNeighborMsg *msg = iterMsg[i];
 
@@ -291,9 +289,9 @@ class Block: public CBase_Block {
        CkPrintf("[%d]: send msg to neighbor[%d]=%d\n", thisIndex, i, neighbors[i]);
 #endif
        msg->setMsgSrc(thisIndex, i);
-       //double entrytimer = CmiWallTimer();
+       //double entrytimer = CkWallTimer();
        thisProxy(neighbors[i]).recvMsgs(msg);
-       //double entrylasttimer = CmiWallTimer();
+       //double entrylasttimer = CkWallTimer();
        //if(thisIndex==0){
        //      CkPrintf("At current step %d to neighbor %d, msg creation time: %f, entrymethod fire time: %f\n", internalStepCnt, neighbors[i], entrytimer-memtimer, entrylasttimer-entrytimer);
        //}
@@ -312,7 +310,7 @@ class Block: public CBase_Block {
          iterMsg[i] = new(curIterMsgSize/4, 0) toNeighborMsg(curIterMsgSize/4);
       }
 
-      startTime = CmiWallTimer();
+      startTime = CkWallTimer();
       startInternalIteration();
     }
 
@@ -324,14 +322,14 @@ class Block: public CBase_Block {
 #endif
 
       iterMsg[fromNID] = m;
-      //recvTimes[fromNID] += (CmiWallTimer() - startTime);
+      //recvTimes[fromNID] += (CkWallTimer() - startTime);
 
       //get one step time and send it back to mainProxy
       numNborsRcvd++;
       if (numNborsRcvd == numNeighbors) {
        internalStepCnt++;
        if (internalStepCnt==CALCPERSTEP) {
-         double iterCommTime = CmiWallTimer() - startTime;
+         double iterCommTime = CkWallTimer() - startTime;
          contribute(sizeof(double), &iterCommTime, CkReduction::max_double);
          /*if(thisIndex==0){
            for(int i=0; i<numNeighbors; i++){