examples/charm++: Always use CkWallTimer, not CmiWallTimer (tested)
authorPhil Miller <mille121@illinois.edu>
Tue, 31 Jul 2012 23:15:13 +0000 (18:15 -0500)
committerPhil Miller <mille121@illinois.edu>
Tue, 31 Jul 2012 23:15:20 +0000 (18:15 -0500)
37 files changed:
examples/charm++/AllReduce/AllReduce.C
examples/charm++/AllReduce/AllReduce.h
examples/charm++/AllReduce/bench/AllReduce.C
examples/charm++/AllReduce/bench/AllReduce.h
examples/charm++/Maj_Min/jacobi2d.C
examples/charm++/Molecular2D/Patch.C
examples/charm++/NQueen/main.C
examples/charm++/PMEMimic/PMEMimic.C
examples/charm++/PMEMimic/PMEMimic/PMEMimic.C
examples/charm++/PMEMimic/PMEMimic_Parallel/PMEMimic.C
examples/charm++/barnes-charm/Main.cpp
examples/charm++/cell/md/md_config.h
examples/charm++/cell/md/pairCompute.C
examples/charm++/cell/md/pairCompute.ci
examples/charm++/cell/md/patch.C
examples/charm++/cell/md/selfCompute.C
examples/charm++/cell/md/selfCompute.ci
examples/charm++/ckdirect/matmul3d/matmul3d.C
examples/charm++/ckdirect/stencil3d/stencil3d.C
examples/charm++/cuda/overlapTestGPUManager/overlapTest.C
examples/charm++/cuda/overlapTestStream/overlapTest.C
examples/charm++/gaussSeidel3D/gaussSeidel3d.C
examples/charm++/jacobi1d/jacobi1d.C
examples/charm++/jacobi2d-iter/jacobi2d.C
examples/charm++/jacobi2d-sdag/jacobi2d.C
examples/charm++/jacobi2d-sdag/jacobi2d.ci
examples/charm++/jacobi3d-sdag/jacobi3d.C
examples/charm++/load_balancing/kNeighbor/kNeighbor.C
examples/charm++/load_balancing/stencil3d/stencil3d.C
examples/charm++/nodeHelper/fft-trans/fft1d.C
examples/charm++/nodeHelper/simpleLoopBench/hello.C
examples/charm++/piArray/pgm.C
examples/charm++/satisfiability/main.C
examples/charm++/topology/jacobi2d/jacobi2d.C
examples/charm++/topology/jacobi3d/jacobi3d.C
examples/charm++/topology/matmul2d/matmul2d.C
examples/charm++/topology/matmul3d/matmul3d.C

index 68935e307f95211249ca6e14fda0c4475036cd1d..01e483646f48c38a53896dfcede629a9fbb1688d 100644 (file)
@@ -30,7 +30,7 @@ main::main(CkArgMsg* m)
             CkNumPes(),units,allredSize);
 
     arr.init();
-    startTime = CmiWallTimer();
+    startTime = CkWallTimer();
     arr.dowork();
   }
 
index 8996d63f5d47f9187855f48b0a03de3a3f3d6acb..7ba7ead4a8f7976625efc9a23ff6ea02bedb55cb 100644 (file)
@@ -15,7 +15,7 @@ public:
          static int checkIn=0;
          checkIn++;
          if (checkIn==units) {
-                 CkPrintf("All done in %lf seconds\n",(CmiWallTimer()-startTime));
+                 CkPrintf("All done in %lf seconds\n",(CkWallTimer()-startTime));
                  CkExit();  
          }
   }
index a0bc01d42f15e1265deeac4084c30f7f87c12bc3..c583de72f3f9150039dcb9caedbdb3f9ee3a25b5 100644 (file)
@@ -39,7 +39,7 @@ main::main(CkArgMsg* m)
             CkNumPes(),units,allredSize);
 
     arr.init();
-    startTime = CmiWallTimer();
+    startTime = CkWallTimer();
     arr.dowork(baseSize);
   }
 
index c6070338e02a6c5a895159954bb749f816df966e..1ffbeb9fbde35981eadffd6cd4d564aa4f2038f2 100644 (file)
@@ -23,8 +23,8 @@ public:
          checkIn++;
          if (checkIn==units) {
                  checkIn = 0;
-                 // CkPrintf("All done in %lf seconds\n",(CmiWallTimer()-startTime));
-                 double newTime= CmiWallTimer();
+                 // CkPrintf("All done in %lf seconds\n",(CkWallTimer()-startTime));
+                 double newTime= CkWallTimer();
                  iterNo++;
                  timeForEach[sizeInd] += newTime-startTime;
                  if(iterNo==numItr)
@@ -39,7 +39,7 @@ public:
                          currentSize *= 2;
 
                  }
-                       startTime = CmiWallTimer();
+                       startTime = CkWallTimer();
                        arr.dowork(currentSize);
          }
   }
index 203848413e4b2361cd7b2f5892849364f50caaea..c46eb66e2dac35f354d6722fd332dab13424eaa2 100644 (file)
@@ -74,7 +74,7 @@ public:
     num_chares = majElements + minElements;
 
     //Start the computation
-    startTime = CmiWallTimer ();
+    startTime = CkWallTimer ();
     start = startTime;
     recieve_count = 0;
 #ifdef PRIOR
@@ -104,7 +104,7 @@ public:
   void report (CkReductionMsg *msg)
   {
     recieve_count++;
-    double totaltime = CmiWallTimer () - startTime;
+    double totaltime = CkWallTimer () - startTime;
 //    printf("coming in report--------------------------------------------- rec=%d\n",recieve_count);
     if (2 == recieve_count)
 //      if(minElements+1 == recieve_count)
@@ -113,7 +113,7 @@ public:
          {
            CkPrintf
              ("Completed %d iterations; last iteration time: %.6lf total time=%f\n",
-              iterations, totaltime, CmiWallTimer () - start);
+              iterations, totaltime, CkWallTimer () - start);
 //         CkExit ();
                mainProxy.exiting();
          }
@@ -149,7 +149,7 @@ if(iterations==1) useThisCriticalPathForPriorities();
            recieve_count = 0;
            iterations++;
            // Call begin_iteration on all worker chares in array
-           startTime = CmiWallTimer ();
+           startTime = CkWallTimer ();
 #ifdef PRIOR
            opts = new CkEntryOptions ();
            opts1 = new CkEntryOptions ();
@@ -283,7 +283,7 @@ else
          opts->setPriority (-100);
          opts1->setPriority (100);
 
-//printf("-------- Jacobi[%d] sending message to next one at time=%f\n",thisIndex,CmiWallTimer());
+//printf("-------- Jacobi[%d] sending message to next one at time=%f\n",thisIndex,CkWallTimer());
          thisProxy[thisIndex + 1].begin_iteration (1, opts);
         for(int i=(thisIndex+1)*7;i<(thisIndex+1)*7+7;i++)
                 minorProxy[i].begin_iteration(1,opts1);
@@ -295,7 +295,7 @@ else
        }
       else
        {
-//                      printf("CAlling report Jacobi[%d] time=%f!!!!!!!!!!1\n",thisIndex,CmiWallTimer());
+//                      printf("CAlling report Jacobi[%d] time=%f!!!!!!!!!!1\n",thisIndex,CkWallTimer());
 
 //       else
 //         mainProxy.report ();
@@ -388,7 +388,7 @@ public:
   // The first step is to send the local state to the neighbors
   void begin_iteration (int i)
   {
-//printf("XXXXXXXXX Minor[%d] coming in begin_itertaion at time=%f\n",thisIndex,CmiWallTimer());
+//printf("XXXXXXXXX Minor[%d] coming in begin_itertaion at time=%f\n",thisIndex,CkWallTimer());
     useLB = 1;
     iterations++;
 
index 6d7cc6477f08d402fd47d628796d13fc38517e85..2da2042e2cd1d1a8714dd3dc29b3bb18e512d577 100644 (file)
@@ -29,7 +29,7 @@ double B = 1.0;                       // Force Calculation parameter 2
 
 // Entry point of Charm++ application
 Main::Main(CkArgMsg* msg) {
-  stepTime = CmiWallTimer();
+  stepTime = CkWallTimer();
   CkPrintf("\nLENNARD JONES MOLECULAR DYNAMICS RUNNING ...\n");
 
   numParts = DEFAULT_PARTICLES;
@@ -252,7 +252,7 @@ void Patch::checkNextStep(){
     incomingParticles.removeAll();
 
     if (thisIndex.x==0 && thisIndex.y==0 && stepCount%10==0) {
-      timer = CmiWallTimer();
+      timer = CkWallTimer();
       CkPrintf("Step %d Benchmark Time %f ms/step\n", stepCount, ((timer - stepTime)/10)*1000);
       stepTime = timer;
     }
index ce375d05927bb5fb07df85910fe46e8175dab453..5e95bf87359104d56a5f57bfca1d3a1e439e5daa 100644 (file)
@@ -89,7 +89,7 @@ Main::Main(CkArgMsg* msg)
             bitfield &= ~lsb;
         }
     }
-    starttimer = CmiWallTimer();//CkTimer();
+    starttimer = CkWallTimer();//CkTimer();
     counterGroup = counterInit();
     CkStartQD(CkIndex_Main::Quiescence1((DUMMYMSG *)0), &mainhandle);
 }
@@ -99,9 +99,9 @@ Main::Main(CkMigrateMessage* msg) {}
 void Main::Quiescence1(DUMMYMSG *msg)
 {
     int numSolutions = CProxy_counter(counterGroup).ckLocalBranch()->getTotalCount();
-    double endtimer = CmiWallTimer();
+    double endtimer = CkWallTimer();
     CkPrintf("There are %d Solutions to %d queens. Time=%f End time=%f\n",
-        2*numSolutions, numQueens, endtimer-starttimer, CmiWallTimer());
+        2*numSolutions, numQueens, endtimer-starttimer, CkWallTimer());
     CkExit();
 }
 
index d0d7d48ba3d49d7bbdd76f4885e5c981fd40a37c..3f500c565608732a1f7d028db8041fec4a019c96 100644 (file)
@@ -86,7 +86,7 @@ public:
       pme_z = CProxy_PMEPencil_Z::ckNew(2, opts_z);
 
       done_pme=0;
-      startTimer = CmiWallTimer();
+      startTimer = CkWallTimer();
       pme_x.start();
       
     };
@@ -98,7 +98,7 @@ public:
         {
             done_pme = 0;
 
-            CkPrintf("PME(%d, %d, %d) on %d PEs, %d iteration, avg time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), max_iter, (CmiWallTimer()-startTimer)/max_iter*1000);
+            CkPrintf("PME(%d, %d, %d) on %d PEs, %d iteration, avg time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), max_iter, (CkWallTimer()-startTimer)/max_iter*1000);
             CkExit();
         }
     }
index d0d7d48ba3d49d7bbdd76f4885e5c981fd40a37c..3f500c565608732a1f7d028db8041fec4a019c96 100644 (file)
@@ -86,7 +86,7 @@ public:
       pme_z = CProxy_PMEPencil_Z::ckNew(2, opts_z);
 
       done_pme=0;
-      startTimer = CmiWallTimer();
+      startTimer = CkWallTimer();
       pme_x.start();
       
     };
@@ -98,7 +98,7 @@ public:
         {
             done_pme = 0;
 
-            CkPrintf("PME(%d, %d, %d) on %d PEs, %d iteration, avg time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), max_iter, (CmiWallTimer()-startTimer)/max_iter*1000);
+            CkPrintf("PME(%d, %d, %d) on %d PEs, %d iteration, avg time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), max_iter, (CkWallTimer()-startTimer)/max_iter*1000);
             CkExit();
         }
     }
index efa9eb3a62c0d4a7e36de8bcb40981c2e7a3265b..ec2dd97797e3c59b34133812d2c4ac710fec6a64 100644 (file)
@@ -94,7 +94,7 @@ public:
       pme_z = CProxy_PMEPencil_Z::ckNew(2, opts_z);
 
       done_pme=0;
-      nextPhraseTimer = CmiWallTimer();
+      nextPhraseTimer = CkWallTimer();
       pme_x.nextPhrase();
       
     };
@@ -106,7 +106,7 @@ public:
         {
             done_pme = 0;
 
-            CkPrintf("\nPME(%d, %d, %d) on %d PEs (%d pes/node)(%d nodes)\n %d iteration, average time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), pes_per_node, CkNumPes()/pes_per_node, max_iter, (CmiWallTimer()-nextPhraseTimer)/max_iter*1000);
+            CkPrintf("\nPME(%d, %d, %d) on %d PEs (%d pes/node)(%d nodes)\n %d iteration, average time:%f(ms)\n", grid_x, grid_y, grid_z, CkNumPes(), pes_per_node, CkNumPes()/pes_per_node, max_iter, (CkWallTimer()-nextPhraseTimer)/max_iter*1000);
             CkExit();
         }
     }
index 4d595fe1657a8aefa33cc770aacd72c28a0a897b..473c1a857a44276f9a240a4edca860f1d15baa5e 100644 (file)
@@ -225,11 +225,11 @@ void Main::startSimulation(){
     CkPrintf("[main] rmin: (%f,%f,%f), rsize: %f\n", rmin[0], rmin[1], rmin[2], rsize);
     CkPrintf("**********************************\n");
 #ifndef NO_TIME
-    start = CmiWallTimer();
-    iterationStart = CmiWallTimer();
+    start = CkWallTimer();
+    iterationStart = CkWallTimer();
 #endif
     if(i == 2){
-      totalStart = CmiWallTimer();
+      totalStart = CkWallTimer();
     }
     CkCallback cb(CkIndex_TreePiece::doBuildTree(), pieces);
     CkStartQD(cb);
@@ -243,7 +243,7 @@ void Main::startSimulation(){
     // completed calculating theirs
     updateTopLevelMoments();
 #ifndef NO_TIME
-    end = CmiWallTimer();
+    end = CkWallTimer();
 #endif
     CkPrintf("[main] Tree building ... %f s\n", (end-start));
 #ifdef PRINT_TREE
@@ -251,47 +251,47 @@ void Main::startSimulation(){
 #endif
 #ifndef NO_PARTITION
 #ifndef NO_TIME
-    start = CmiWallTimer();
+    start = CkWallTimer();
 #endif
     chunks.partition(CkCallbackResumeThread());
 #ifndef NO_TIME
-    end = CmiWallTimer();
+    end = CkWallTimer();
 #endif
     CkPrintf("[main] Partitioning ...  %f s\n", (end-start));
 #endif
 #ifndef NO_FORCES
 #ifndef NO_TIME
-    start = CmiWallTimer();
+    start = CkWallTimer();
 #endif
     chunks.ComputeForces(CkCallbackResumeThread());
 #ifndef NO_TIME
-    end = CmiWallTimer();
+    end = CkWallTimer();
 #endif
     CkPrintf("[main] Forces ...  %f s\n", (end-start));
 #endif
 #ifndef NO_ADVANCE
 #ifndef NO_TIME
-    start = CmiWallTimer();
+    start = CkWallTimer();
 #endif
     chunks.advance(CkCallbackResumeThread());
 #ifndef NO_TIME
-    end = CmiWallTimer();
+    end = CkWallTimer();
 #endif
     CkPrintf("[main] Advance ... %f s\n", (end-start));
 #endif
 #ifndef NO_CLEANUP
 #ifndef NO_TIME
-    start = CmiWallTimer();
+    start = CkWallTimer();
 #endif
     pieces.cleanup(CkCallbackResumeThread());
 #ifndef NO_TIME
-    end = CmiWallTimer();
+    end = CkWallTimer();
 #endif
     CkPrintf("[main] Clean up ... %f s\n", (end-start));
 #endif
     i++;
 #ifndef NO_TIME
-    totalEnd = CmiWallTimer();
+    totalEnd = CkWallTimer();
 #endif
     CkPrintf("[main] Total ... %f s\n", (totalEnd-iterationStart));
 #ifndef NO_LB
@@ -304,7 +304,7 @@ void Main::startSimulation(){
     topLevelRoots.length() = 0;
     tnow = tnow + dtime;
   }
-  totalEnd = CmiWallTimer();
+  totalEnd = CkWallTimer();
 
   CkPrintf("[main] Completed simulation: %f s\n", (totalEnd-totalStart));
 #ifdef OUTPUT_ACC
index 5ba5818b483b0da9592a913715bf3e9b01ce01e3..417850193f21090d03225500da435064c3e3a632 100644 (file)
   #if ENABLE_USER_EVENTS != 0
     #define NetworkProgress  \
       {  \
-        double __start_time__ = CmiWallTimer();  \
+        double __start_time__ = CkWallTimer();  \
         CmiMachineProgressImpl();  \
-        traceUserBracketEvent(PROJ_USER_EVENT_MACHINEPROGRESS, __start_time__, CmiWallTimer());  \
+        traceUserBracketEvent(PROJ_USER_EVENT_MACHINEPROGRESS, __start_time__, CkWallTimer());  \
       }
   #else
     #define NetworkProgress  CmiMachineProgressImpl();
index 662f20c9417dc56157087f52f2d7e06aae2fe836..03095cdbfbf54b0bbc4de0191bd3f4276363b0da 100644 (file)
@@ -123,7 +123,7 @@ void PairCompute::doCalc_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __start_time__ = CmiWallTimer();
+    double __start_time__ = CkWallTimer();
   #endif
 
   // DMK - DEBUG
@@ -165,7 +165,7 @@ void PairCompute::doCalc_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __end_time__ = CmiWallTimer();
+    double __end_time__ = CkWallTimer();
     traceUserBracketEvent(PROJ_USER_EVENT_PAIRCOMPUTE_DOCALC_CALLBACK, __start_time__, __end_time__);
   #endif
 }
index 0d60813b23b7798549634c50d4827ea340111ef9..464f0619cd1af651a72b477ee201200c71bee822 100644 (file)
@@ -40,7 +40,7 @@ module pairCompute {
       // DMK - DEBUG
       #if (ENABLE_USER_EVENTS != 0) && defined(CMK_CELL) && (CMK_CELL == 0)
         if (numParticles != 256) { CkPrintf("[DEBUG] :: PairCompute::doCalc() - Called with numParticles:%d...\n", numParticles); }
-        double __start_time__ = CmiWallTimer();
+        double __start_time__ = CkWallTimer();
       #endif
 
       // Calculate the electrostatic force (coulumb's law) between the particles
@@ -373,7 +373,7 @@ module pairCompute {
 
       // DMK - DEBUG
       #if (ENABLE_USER_EVENTS != 0) && defined(CMK_CELL) && (CMK_CELL == 0)
-        double __end_time__ = CmiWallTimer();
+        double __end_time__ = CkWallTimer();
         double deltaTime = __end_time__ - __start_time__;
         traceUserBracketEvent(PROJ_USER_EVENT_PAIRCOMPUTE_DOCALC_WORK, __start_time__, __end_time__);
         if (deltaTime > 0.002) {
index 97fa43e8a53bddc5da9c9229421281267fea31e5..cb789b925384442007fa2ef51abc695da0c569fd 100644 (file)
@@ -256,7 +256,7 @@ void Patch::integrate_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __start_time__ = CmiWallTimer();
+    double __start_time__ = CkWallTimer();
   #endif
 
   // DMK - DEBUG
@@ -281,7 +281,7 @@ void Patch::integrate_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __end_time__ = CmiWallTimer();
+    double __end_time__ = CkWallTimer();
     traceUserBracketEvent(PROJ_USER_EVENT_PATCH_INTEGRATE_CALLBACK, __start_time__, __end_time__);
   #endif
 }
index 950396ae6cf04bf21fe308ab6df60afb7b1ef34c..d4b30865d9eac7e2840fad0b796503b04ac2c5df 100644 (file)
@@ -83,7 +83,7 @@ void SelfCompute::doCalc_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __start_time__ = CmiWallTimer();
+    double __start_time__ = CkWallTimer();
   #endif
 
   // DMK - DEBUG
@@ -105,7 +105,7 @@ void SelfCompute::doCalc_callback() {
 
   // DMK - DEBUG
   #if ENABLE_USER_EVENTS != 0
-    double __end_time__ = CmiWallTimer();
+    double __end_time__ = CkWallTimer();
     traceUserBracketEvent(PROJ_USER_EVENT_SELFCOMPUTE_DOCALC_CALLBACK, __start_time__, __end_time__);
   #endif
 }
index 5cb62ba2c85ecb82fe7b9d89690a4157772e4cbe..59cbdb6d4ef28e0a3974ed52a98d66947d24d805 100644 (file)
@@ -32,7 +32,7 @@ module selfCompute {
 
       // DMK - DEBUG
       #if (ENABLE_USER_EVENTS != 0) && defined(CMK_CELL) && (CMK_CELL == 0)
-        double __start_time__ = CmiWallTimer();
+        double __start_time__ = CkWallTimer();
       #endif
 
       // Calculate the electrostatic force (coulumb's law) between the particles
@@ -176,7 +176,7 @@ module selfCompute {
 
       // DMK - DEBUG
       #if (ENABLE_USER_EVENTS != 0) && defined(CMK_CELL) && (CMK_CELL == 0)
-        double __end_time__ = CmiWallTimer();
+        double __end_time__ = CkWallTimer();
         traceUserBracketEvent(PROJ_USER_EVENT_SELFCOMPUTE_DOCALC_WORK, __start_time__, __end_time__);
       #endif
 
index efca98277fa4d332432fbde254da68cddb446ec3..d8c2d0be5d41da149863bdab282ac70079c86572 100644 (file)
@@ -90,7 +90,7 @@ Main::Main(CkArgMsg* m) {
 
   // Start the computation
   numIterations = 0;
-  startTime = CmiWallTimer();
+  startTime = CkWallTimer();
 #if USE_CKDIRECT
   compute.setupChannels();
 #else
@@ -101,7 +101,7 @@ Main::Main(CkArgMsg* m) {
 void Main::done() {
   numIterations++;
   if(numIterations == 1) {
-    firstTime = CmiWallTimer();
+    firstTime = CkWallTimer();
 #if USE_CKDIRECT
     CkPrintf("FIRST ITER TIME %f secs\n", firstTime - setupTime);
 #else
@@ -110,7 +110,7 @@ void Main::done() {
     compute.resetArrays();
   } else {
     if(numIterations == NUM_ITER) {
-      endTime[numIterations-2] = CmiWallTimer() - firstTime;
+      endTime[numIterations-2] = CkWallTimer() - firstTime;
       double sum = 0;
       for(int i=0; i<NUM_ITER-1; i++)
        sum += endTime[i];
@@ -121,19 +121,19 @@ void Main::done() {
 #endif
       CkExit();
     } else {
-      endTime[numIterations-2] = CmiWallTimer() - firstTime;
+      endTime[numIterations-2] = CkWallTimer() - firstTime;
       compute.resetArrays();
     }
   }
 }
 
 void Main::resetDone() {
-  firstTime = CmiWallTimer();
+  firstTime = CkWallTimer();
   compute.beginCopying();
 }
 
 void Main::setupDone() {
-  setupTime = CmiWallTimer();
+  setupTime = CkWallTimer();
   CkPrintf("SETUP TIME %f secs\n", setupTime - startTime);
   compute.beginCopying();
 }
index f6962b0b02974e45933155f0bf7eb6fc8281a6df..115dc7ec0decff75c489c9753391ed92960cb15e 100644 (file)
@@ -39,7 +39,7 @@ class Main : public CBase_Main {
     CProxy_StencilPoint array = 
         CProxy_StencilPoint::ckNew(charesx*charesy*charesz);
     CkPrintf("main: dim: %d,%d,%d charedim: %d,%d,%d num_iterations: %d\n", dimx, dimy, dimz, charesx, charesy, charesz, num_iterations);
-    startSetup = CmiWallTimer();
+    startSetup = CkWallTimer();
 #ifdef USE_CKDIRECT
     array.setupChannels();
 #else
@@ -48,11 +48,11 @@ class Main : public CBase_Main {
   }
 
   void doneSetup(){
-    start = CmiWallTimer();
+    start = CkWallTimer();
   }
   
   void done(CkReductionMsg *msg){
-    end = CmiWallTimer();
+    end = CkWallTimer();
     CkPrintf("Total time: %f sec\n", end-startSetup);
     CkPrintf("Computation time per iteration: %f sec\n", (end-start)/(num_iterations-1));
     CkPrintf("Total computations: %f\n", *(double *)msg->getData());
index 7bdbcd57922ea4a457226833982a8bf6562eb942..e66b4829630e7f7aee7e6bbd898237a7e6d55a39 100644 (file)
@@ -23,14 +23,14 @@ Main::Main(CkArgMsg *m) {
 
   workers = CProxy_Workers::ckNew(numChares); 
 
-  startTime = CmiWallTimer(); 
+  startTime = CkWallTimer(); 
     
   workers.setupBuffers(); 
 }
 
 void Main::finishWork(CkReductionMsg *m) {
   delete m;
-  CkPrintf("Elapsed time: %f s\n", CmiWallTimer() - startTime);  
+  CkPrintf("Elapsed time: %f s\n", CkWallTimer() - startTime);  
   CkExit(); 
 }
 
index a8a4d8ea058c193196a7fdb69f62e31165552dbf..c1b6169f7e7c142fbfd248845e7ebe591bea11d0 100644 (file)
@@ -20,14 +20,14 @@ Main::Main(CkArgMsg *m) {
 
   workers = CProxy_Workers::ckNew(numChares); 
 
-  startTime = CmiWallTimer(); 
+  startTime = CkWallTimer(); 
     
   workers.beginWork(); 
 }
 
 void Main::finishWork(CkReductionMsg *m) {
   delete m;
-  CkPrintf("Elapsed time: %f s\n", CmiWallTimer() - startTime);  
+  CkPrintf("Elapsed time: %f s\n", CkWallTimer() - startTime);  
   CkExit(); 
 }
 
index 01517d6734143a84cca8d766f10b2960c7751b10..d07ef0175a745613c3debf319a077c7db7143674 100644 (file)
@@ -135,7 +135,7 @@ public:
     // Create new array of worker chares
     array = CProxy_GaussSeidel::ckNew(num_chare_x, num_chare_y, num_chare_z); 
 
-    startTime = CmiWallTimer();
+    startTime = CkWallTimer();
 
     //Start the computation
     array.doStep();
@@ -144,7 +144,7 @@ public:
   // Each worker reports back to here when it completes an iteration
   void report() {
     iterations++;
-    endTime = CmiWallTimer();
+    endTime = CkWallTimer();
     CkPrintf("Average time for each of the first %d iteration: %f\n", iterations ,(endTime - startTime)/(iterations));
     if(iterations >= MAX_ITER){
       CkExit();
index ffcd1a2c5fed014c99a2f7f0ffac56e0e1074b24..f7c1e98cc46a8fd0c7938a384b5cc0cd973e9c46 100644 (file)
@@ -81,7 +81,7 @@ class Main : public CBase_Main
     void report(CkReductionMsg *msg) {
       iterations++;
       if(iterations == WARM_ITER)
-       startTime = CmiWallTimer();
+       startTime = CkWallTimer();
       double error = *((double *)msg->getData());
 
       if(iterations < MAX_ITER) {
@@ -89,7 +89,7 @@ class Main : public CBase_Main
        array.begin_iteration();
       } else {
        CkPrintf("Completed %d iterations\n", MAX_ITER-1);
-        endTime = CmiWallTimer();
+        endTime = CkWallTimer();
         CkPrintf("Time elapsed per iteration: %f\n", (endTime - startTime)/(MAX_ITER-1-WARM_ITER));
         CkExit();
       }
index 0d6ea3355057e77bdb191788346e32fdb662d385..006aedbd4c088b9bac8f0a5854e6e15a125f3efe 100644 (file)
@@ -71,7 +71,7 @@ public:
         liveVizInit(cfg,a,c);
 
         //Start the computation
-        startTime = CmiWallTimer();
+        startTime = CkWallTimer();
         recieve_count = 0;
         array.begin_iteration();
     }
@@ -79,7 +79,7 @@ public:
     // Each worker reports back to here when it completes an iteration
     void report(int row, int col) {
         recieve_count++;
-        double totaltime = CmiWallTimer() - startTime;
+        double totaltime = CkWallTimer() - startTime;
         if (num_chares == recieve_count) {
             if (iterations == total_iterations) {
                 CkPrintf("Completed %d iterations; last iteration time: %.6lf\n", iterations, totaltime);
@@ -89,7 +89,7 @@ public:
                 recieve_count=0;
                 iterations++;
                 // Call begin_iteration on all worker chares in array
-                startTime = CmiWallTimer();
+                startTime = CkWallTimer();
                 array.begin_iteration();
             }
         }
index e175fd966e7446f34d1ec0a87513938bc2e64d54..ebf209c36eae37958bba6f17a5d9d6fdd90f39a3 100644 (file)
@@ -112,7 +112,7 @@ public:
        CkPrintf("Difference %.10g Satisfied Threshhold %.10g in %d Iterations\n", maxdifference,THRESHHOLD,iterations);
       else
        CkPrintf("Completed %d Iterations , Difference %lf fails threshhold\n", iterations,maxdifference);
-      endTime = CmiWallTimer();
+      endTime = CkWallTimer();
       CkPrintf("Time elapsed per iteration: %f\n", (endTime - startTime)/(maxiterations-1-WARM_ITER));
       CkExit();
   }
index ae9b7fe82de52f74a446e3ff56c8e246616daaa3..3f81409c1a4f7b067b760228f544d950b1c6776e 100644 (file)
@@ -24,7 +24,7 @@ mainmodule jacobi2d {
        }
       }
       atomic "start_timed_portion" {
-       startTime = CmiWallTimer();
+       startTime = CkWallTimer();
        array.doStep(CkCallback(CkIndex_Main::report(NULL), thisProxy),
                     maxiterations);
       }
index 2ec8bc1a776fd67ec12af48d43dee8a9ac65882a..d9263ac79e3d24117b357d07d843981f6c69c81d 100644 (file)
@@ -128,12 +128,12 @@ class Main : public CBase_Main {
       iterations++;
       if (iterations <= WARM_ITER) {
        if (iterations == WARM_ITER)
-         startTime = CmiWallTimer();
+         startTime = CkWallTimer();
        array.doStep();
       }
       else {
        CkPrintf("Completed %d iterations\n", MAX_ITER-1);
-       endTime = CmiWallTimer();
+       endTime = CkWallTimer();
        CkPrintf("Time elapsed per iteration: %f\n", (endTime - startTime)/(MAX_ITER-1-WARM_ITER));
         CkExit();
       }
index 35c462cb24ebebf0a04dcdc16bcda583622a315c..6d3ad974ca6cf9dfd839d375f6af554f2c417848 100644 (file)
@@ -121,7 +121,7 @@ class Main: public CBase_Main {
        return;
       }
 
-      gStarttime = CmiWallTimer();
+      gStarttime = CkWallTimer();
        array.commWithNeighbors();
     }
 
@@ -129,7 +129,7 @@ class Main: public CBase_Main {
 #if DEBUG
       CkPrintf("Resume iteration at step %d\n", currentStep);
 #endif
-      gStarttime = CmiWallTimer();
+      gStarttime = CkWallTimer();
        array.commWithNeighbors();
     }
 
@@ -156,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);
@@ -281,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];
 
@@ -289,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);
        //}
@@ -310,7 +310,7 @@ class Block: public CBase_Block {
          iterMsg[i] = new(curIterMsgSize/4, 0) toNeighborMsg(curIterMsgSize/4);
       }
 
-      startTime = CmiWallTimer();
+      startTime = CkWallTimer();
       startInternalIteration();
     }
 
@@ -322,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++){
index 5163b1eaa547eafb6cbccc2c0a73dfc8505d185f..d247fbb4e8622dc4f5510630dba11978ef815ee7 100644 (file)
@@ -122,7 +122,7 @@ class Main : public CBase_Main {
       array = CProxy_Stencil::ckNew(num_chare_x, num_chare_y, num_chare_z);
 
       //Start the computation
-      startTime = CmiWallTimer();
+      startTime = CkWallTimer();
       array.doStep();
     }
 
@@ -304,7 +304,7 @@ class Stencil: public CBase_Stencil {
       constrainBC();
 
       if(thisIndex.x == 0 && thisIndex.y == 0 && thisIndex.z == 0) {
-       endTime = CmiWallTimer();
+       endTime = CkWallTimer();
        CkPrintf("[%d] Time per iteration: %f %f\n", iterations, (endTime - startTime), endTime);
       }
 
@@ -312,7 +312,7 @@ class Stencil: public CBase_Stencil {
        contribute(0, 0, CkReduction::concat, CkCallback(CkIndex_Main::report(), mainProxy));
       else {
        if(thisIndex.x == 0 && thisIndex.y == 0 && thisIndex.z == 0)
-         startTime = CmiWallTimer();
+         startTime = CkWallTimer();
        if(iterations % LBPERIOD == 0)
          {
            // auto tune the LBPeriod to half as long as it takes to run the iters between LB steps
index e40b5df24b231a7f25ea6c496904965b522403af..c7c9d254dd6930a8b749084ba1bbb72d820c4962 100644 (file)
@@ -239,9 +239,9 @@ struct fft : public CBase_fft {
     //kick off thread computation
     //FuncNodeHelper *nth = nodeHelperProxy[CkMyNode()].ckLocalBranch();
     //nth->parallelizeFunc(doCalc, numTasks, numTasks, thisIndex, numTasks, 1, 1, plan, 0, NULL);
-    double ffttime = CmiWallTimer();
+    double ffttime = CkWallTimer();
     NodeHelper_Parallelize(doCalc, 1, plan, numTasks, 0, numTasks-1);    
-    CkPrintf("FFT time: %.3f (ms)\n", (CmiWallTimer()-ffttime)*1e3);
+    CkPrintf("FFT time: %.3f (ms)\n", (CkWallTimer()-ffttime)*1e3);
   }
 
   void initValidation() {
index 10484943379a111ed37fe6d9e696a89bb4c2d5f7..a144b93255e901b610776e43db23e8ddbe443f6f 100644 (file)
@@ -50,11 +50,11 @@ int openMPWork(int start, int end) {
 }
 
 extern "C" void doCalc(int first, int last, void *result, int paramNum, void * param) {    
-    //double tstart = CmiWallTimer();
+    //double tstart = CkWallTimer();
     
        work(first, last, result);
     
-       //tstart = CmiWallTimer() - tstart;
+       //tstart = CkWallTimer() - tstart;
     //printf("start=%d, end=%d, time: %f,result: %d on proc %d\n",first, last, tstart,result,CkMyPe());
 }
 
@@ -103,15 +103,15 @@ Main::Main(CkArgMsg* m) {
        int result;
        double starttime, endtime;
        for(int i=0; i<3; i++){
-               starttime = CmiWallTimer();
+               starttime = CkWallTimer();
                work(0, loopTimes, &result);            
-               endtime = CmiWallTimer();
+               endtime = CkWallTimer();
                CkPrintf("Calibration %d: the loop takes %.3f us with result %d\n", i+1,  (endtime-starttime)*1e6, result);
        }
        int results[5];
-       starttime = CmiWallTimer();
+       starttime = CkWallTimer();
        for(int i=0; i<5; i++) work(0, loopTimes, results+i);
-       endtime = CmiWallTimer();
+       endtime = CkWallTimer();
        double avgtime = (endtime-starttime)*1e6/5; //in the unit of us
        CkPrintf("Calibration: avg time %.3f us of 5 consecutive runs, so a 100us-loop will iterate %d times\n", avgtime, (int)(loopTimes*100.0/avgtime));
                
@@ -124,7 +124,7 @@ void Main::done(void) {
     if (numElemFinished < totalElems) {
         return;
     } else {
-               mainTimes[mainStep] = (CmiWallTimer() - timestamp)*1e6;
+               mainTimes[mainStep] = (CkWallTimer() - timestamp)*1e6;
         mainStep++;
         numElemFinished=0;
         if (mainStep < TEST_REPEAT_TIMES) {
@@ -177,7 +177,7 @@ void Main::doTests(CkQdMsg *msg) {
         }
     }
     
-       timestamp = CmiWallTimer(); //record the start time of the whole test
+       timestamp = CkWallTimer(); //record the start time of the whole test
     for (int i=0; i<totalElems; i++) {
         allTestsProxy[i].doTest(mainStep, curTestMode);
         //allTestsProxy[8].doTest(mainStep, curTestMode);
@@ -224,7 +224,7 @@ void TestInstance::doTest(int curstep, int curTestMode) {
        hasTest = 1;
        int result;
        
-    double timerec = CmiWallTimer();
+    double timerec = CkWallTimer();
     
     if(curTestMode == 0){
            NodeHelper_Parallelize(doCalc, 0, NULL, numChunks, 0, loopTimes-1, 1, &result, NODEHELPER_INT_SUM);
@@ -232,7 +232,7 @@ void TestInstance::doTest(int curstep, int curTestMode) {
         result = openMPWork(0, loopTimes-1);
     }
     
-    allTimes[curstep]=(CmiWallTimer()-timerec)*1e6;
+    allTimes[curstep]=(CkWallTimer()-timerec)*1e6;
        allResults[curstep] = result;
        
     mainProxy.done();
index fb7bb3f1f003dd661f2037e2dd77f6415761bd09..41167eb85708d9d4fc422860eba6eb29336cfc9b 100644 (file)
@@ -23,14 +23,14 @@ main::main(CkArgMsg * m)
   nc = atoi(m->argv[2]);
   delete m;
 
-  starttime = CmiWallTimer();
+  starttime = CkWallTimer();
 
   //FIXME
   //CkGroupID gid = CkCreatePropMap();
   //CProxy_piPart  arr = CProxy_piPart::ckNew(nc, gid);
   CProxy_piPart  arr = CProxy_piPart::ckNew(nc);
 
-  CkPrintf("At time %lf, array created.\n", (CmiWallTimer()-starttime));
+  CkPrintf("At time %lf, array created.\n", (CkWallTimer()-starttime));
 
 #if USE_REDUCTION
   arr.setReductionClient(reductionHandler,(void *)NULL);
@@ -39,7 +39,7 @@ main::main(CkArgMsg * m)
   responders = nc;
   count = 0;
   mainhandle = thishandle; // readonly initialization
-  CkPrintf("At time %lf, main exits.\n", (CmiWallTimer()-starttime));
+  CkPrintf("At time %lf, main exits.\n", (CkWallTimer()-starttime));
 }
 
 void main::results(int cnt) 
@@ -49,7 +49,7 @@ void main::results(int cnt)
   if (0 == --responders) 
 #endif
   {
-    endtime = CmiWallTimer();
+    endtime = CkWallTimer();
     CkPrintf("At time %lf, pi=: %f \n", (endtime-starttime), 4.0*count/(ns*nc));
     CkExit();
   }
index 3b3ac91ea3ece0954d4243df840280b7360c4367..ab4794e785a0aff1d63f79e8637d9d018c05f429 100644 (file)
@@ -261,7 +261,7 @@ Main::Main(CkArgMsg* msg)
 
     /* read file */
 
-    starttimer = CmiWallTimer();
+    starttimer = CkWallTimer();
 
     /*read information from file */
     gzFile in = gzopen(msg->argv[1], "rb");
@@ -300,7 +300,7 @@ Main::Main(CkArgMsg* msg)
         CkPrintf(" This problem is solved by pre-processing\n");
         CkExit();
     }
-    readfiletimer = CmiWallTimer();
+    readfiletimer = CkWallTimer();
     /*fire the first chare */
     /* 1)Which variable is assigned which value this time, (variable, 1), current clauses status vector(), literal array activities */
 
@@ -385,7 +385,7 @@ Main::Main(CkMigrateMessage* msg) {}
 void Main::done(CkVec<int> assignment)
 {
 
-    double endtimer = CmiWallTimer();
+    double endtimer = CkWallTimer();
 
     CkPrintf("\nFile reading and processing time:         %f\n", readfiletimer-starttimer);
     CkPrintf("Solving time:                             %f\n", endtimer - readfiletimer);
index 614982ce67579b22512b6485789c6bc24e016719..2bcfb0af0343676cf47abae030d877e280b63cff 100644 (file)
@@ -104,14 +104,14 @@ class Main : public CBase_Main
     void report(CkReductionMsg *msg) {
       iterations++;
       if(iterations == 5)
-       startTime = CmiWallTimer();
+       startTime = CkWallTimer();
       double error = *((double *)msg->getData());
 
       if (error > 0.001 && iterations < MAX_ITER) {
        array.begin_iteration();
       } else {
        CkPrintf("Completed %d iterations\n", iterations);
-        endTime = CmiWallTimer();
+        endTime = CkWallTimer();
         CkPrintf("Time elapsed per iteration: %f\n", (endTime - startTime)/(MAX_ITER-5));
         CkExit();
       }
index ef7479a08afe2d4d93503a94092f2d9856de02df..faa8544408efbf8e9bdbb438c62a0af29a5b1f3a 100644 (file)
@@ -190,11 +190,11 @@ class Main : public CBase_Main {
     void report() {
       if (iterations == 0) {
        iterations++;
-       startTime = CmiWallTimer();
+       startTime = CkWallTimer();
        array.begin_iteration();
       }
       else {
-       endTime = CmiWallTimer();
+       endTime = CkWallTimer();
        CkPrintf("TIME : %f\n", (endTime - startTime)/(MAX_ITER-1));
         CkExit();
       }
index adac27fc92e78f51935c98ce12ae28679d7217e9..7a115419af96c81ec1f93dfadebd44431cc79df3 100644 (file)
@@ -57,7 +57,7 @@ Main::Main(CkArgMsg* m) {
   compute = CProxy_Compute::ckNew(num_chares_per_dim, num_chares_per_dim);
 
   // Start the computation
-  startTime = CmiWallTimer();
+  startTime = CkWallTimer();
   if(num_chares_per_dim == 1){
     compute(0,0).compute();
   }
@@ -68,7 +68,7 @@ Main::Main(CkArgMsg* m) {
 }
 
 void Main::done(){
-  endTime = CmiWallTimer();
+  endTime = CkWallTimer();
   CkPrintf("Fin: %f sec\n", endTime-startTime);
   CkExit();
 }
index 572bbbedab902b538102199ed56349dc38888bc4..c83e2a172f8b65b98f05282d9f7b3ac9ae238738 100644 (file)
@@ -88,19 +88,19 @@ Main::Main(CkArgMsg* m) {
 
   // Start the computation
   numIterations = 0;
-  startTime = CmiWallTimer();
+  startTime = CkWallTimer();
   compute.beginCopying();
 }
 
 void Main::done() {
   numIterations++;
   if(numIterations == 1) {
-    firstTime = CmiWallTimer();
+    firstTime = CkWallTimer();
     CkPrintf("FIRST ITER TIME %f secs\n", firstTime - startTime);
   }
 
   if(numIterations == NUM_ITER) {
-    endTime = CmiWallTimer();
+    endTime = CkWallTimer();
     CkPrintf("AVG TIME %f secs\n", (endTime - firstTime)/(NUM_ITER-1));
     CkExit();
   } else {