minor fix
authorHarshitha <gplkrsh2@illinois.edu>
Fri, 12 Oct 2012 15:18:34 +0000 (10:18 -0500)
committerHarshitha <gplkrsh2@illinois.edu>
Fri, 12 Oct 2012 15:18:34 +0000 (10:18 -0500)
examples/charm++/load_balancing/kNeighbor/kNeighbor.C
examples/charm++/load_balancing/kNeighbor/kNeighbor.ci
src/ck-ldb/MetaBalancer.C

index 6d3ad974ca6cf9dfd839d375f6af554f2c417848..ac416d9f084e46bbb817e9257a7e8a9974a44b68 100644 (file)
@@ -121,16 +121,18 @@ class Main: public CBase_Main {
        return;
       }
 
-      gStarttime = CkWallTimer();
-       array.commWithNeighbors();
+      gStarttime = CmiWallTimer();
+      for (int i=0; i<num_chares; i++)
+       array[i].commWithNeighbors();
     }
 
     void resumeIter() {
 #if DEBUG
       CkPrintf("Resume iteration at step %d\n", currentStep);
 #endif
-      gStarttime = CkWallTimer();
-       array.commWithNeighbors();
+      gStarttime = CmiWallTimer();
+      for (int i=0; i<num_chares; i++)
+       array[i].commWithNeighbors();
     }
 
     void terminate(CkReductionMsg *msg) {
@@ -156,7 +158,7 @@ class Main: public CBase_Main {
     void nextStep(CkReductionMsg  *msg) {
       maxTime = *((double *)msg->getData());
       delete msg;
-      double wholeStepTime = CkWallTimer() - gStarttime;
+      double wholeStepTime = CmiWallTimer() - 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);
@@ -281,7 +283,7 @@ class Block: public CBase_Block {
 
       // Send msgs to neighbors
       for (int i=0; i<numNeighbors; i++) {
-       //double memtimer = CkWallTimer();
+       //double memtimer = CmiWallTimer();
 
        toNeighborMsg *msg = iterMsg[i];
 
@@ -289,9 +291,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 = CkWallTimer();
+       //double entrytimer = CmiWallTimer();
        thisProxy(neighbors[i]).recvMsgs(msg);
-       //double entrylasttimer = CkWallTimer();
+       //double entrylasttimer = CmiWallTimer();
        //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);
        //}
@@ -310,7 +312,7 @@ class Block: public CBase_Block {
          iterMsg[i] = new(curIterMsgSize/4, 0) toNeighborMsg(curIterMsgSize/4);
       }
 
-      startTime = CkWallTimer();
+      startTime = CmiWallTimer();
       startInternalIteration();
     }
 
@@ -322,14 +324,14 @@ class Block: public CBase_Block {
 #endif
 
       iterMsg[fromNID] = m;
-      //recvTimes[fromNID] += (CkWallTimer() - startTime);
+      //recvTimes[fromNID] += (CmiWallTimer() - startTime);
 
       //get one step time and send it back to mainProxy
       numNborsRcvd++;
       if (numNborsRcvd == numNeighbors) {
        internalStepCnt++;
        if (internalStepCnt==CALCPERSTEP) {
-         double iterCommTime = CkWallTimer() - startTime;
+         double iterCommTime = CmiWallTimer() - startTime;
          contribute(sizeof(double), &iterCommTime, CkReduction::max_double);
          /*if(thisIndex==0){
            for(int i=0; i<numNeighbors; i++){
index 3144754c0a0e854c0a0db73cbdad1115e86883c9..58b6f1c18876d792137a578f57a615a41d36997e 100644 (file)
@@ -3,7 +3,6 @@ mainmodule kNeighbor {
   readonly int num_chares;
   readonly int gMsgSize;
   readonly int gLBFreq;
-  readonly int numSteps;
 
   message toNeighborMsg {
     int data[];
index ccf08e379a1b8cb76e5a6e3b1d5772996b985954..0e868940309c8443914cd9516ea90fc8f06ee429 100644 (file)
@@ -131,7 +131,9 @@ void MetaBalancer::init(void) {
   lb_in_progress = false;
 
   is_prev_lb_refine = -1;
-  periodicCall((void *) this);
+  if (_lb_args.metaLbOn()) {
+    periodicCall((void *) this);
+  }
 }
 
 void MetaBalancer::pup(PUP::er& p) {