cleanup
authorHarshitha <gplkrsh2@illinois.edu>
Mon, 15 Oct 2012 18:03:19 +0000 (13:03 -0500)
committerHarshitha <gplkrsh2@illinois.edu>
Mon, 15 Oct 2012 18:03:19 +0000 (13:03 -0500)
src/ck-ldb/CentralLB.C
src/ck-ldb/GreedyLB.C
src/ck-ldb/LBDatabase.C
src/ck-ldb/LBSimulation.C
src/ck-ldb/MetaBalancer.h
src/ck-ldb/RefineLB.C

index feeba01d5191f4482fe4ee2a95f855c0909540de..55c0a7f7cde8cbcc36f18765556252ede12b88c7 100644 (file)
@@ -49,11 +49,11 @@ static void getPredictedLoadWithMsg(BaseLB::LDStats* stats, int count,
                             LBMigrateMsg *, LBInfo &info, int considerComm);
 
 /*
-   void CreateCentralLB()
-   {
-   CProxy_CentralLB::ckNew(0);
-   }
- */
+void CreateCentralLB()
+{
+  CProxy_CentralLB::ckNew(0);
+}
+*/
 
 void CentralLB::staticStartLB(void* data)
 {
@@ -1074,12 +1074,14 @@ LBMigrateMsg* CentralLB::Strategy(LDStats* stats)
 
   LBMigrateMsg *msg = createMigrateMsg(stats);
 
-  int clients = CkNumPes();
-  LBInfo info(clients);
-  getPredictedLoadWithMsg(stats, clients, msg, info, 0);
-  LBRealType mLoad, mCpuLoad, totalLoad, totalLoadWComm;
-  info.getSummary(mLoad, mCpuLoad, totalLoad);
-  theLbdb->UpdateDataAfterLB(mLoad, mCpuLoad, totalLoad/clients);
+  if (_lb_args.metaLbOn()) {
+    int clients = CkNumPes();
+    LBInfo info(clients);
+    getPredictedLoadWithMsg(stats, clients, msg, info, 0);
+    LBRealType mLoad, mCpuLoad, totalLoad, totalLoadWComm;
+    info.getSummary(mLoad, mCpuLoad, totalLoad);
+    theLbdb->UpdateDataAfterLB(mLoad, mCpuLoad, totalLoad/clients);
+  }
 
   if (_lb_args.debug()) {
     double strat_end_time = CkWallTimer();
index aba514543cba5615a3ebb722929885760f73314e..808e59ca1c09f5165fe5ee4b5af1722d90ccbc43 100644 (file)
@@ -58,7 +58,6 @@ void GreedyLB::work(LDStats* stats)
   int *map = new int[n_pes];
 
   ProcArray *parr = new ProcArray(stats);
-  double bg_load = 0.0;
 
   std::vector<ProcInfo>  procs;
   for(pe = 0; pe < n_pes; pe++) {
@@ -66,7 +65,6 @@ void GreedyLB::work(LDStats* stats)
     if (stats->procs[pe].available) {
       map[pe] = procs.size();
       procs.push_back(ProcInfo(pe, stats->procs[pe].bg_walltime, 0.0, stats->procs[pe].pe_speed, true));
-      bg_load = stats->procs[pe].bg_walltime;
     }
   }
 
@@ -90,16 +88,6 @@ void GreedyLB::work(LDStats* stats)
     procs[pe].totalLoad() *= procs[pe].pe_speed();
   }
 
-  double max_load = 0;
-  double avg_load = 0;
-  for (pe = 0; pe<parr->procs.size(); pe++) {
-    if (parr->procs[pe].totalLoad() > max_load) {
-      max_load = parr->procs[pe].totalLoad();
-    }
-    avg_load += parr->procs[pe].totalLoad();
-  }
-  CkPrintf("Before GreedyLB max load: %lf avg load: %lf bg load: %lf\n", max_load, avg_load/procs.size(), bg_load/procs.size());
-
   // build object array
   std::vector<Vertex> objs;
 
@@ -154,16 +142,6 @@ void GreedyLB::work(LDStats* stats)
   if (_lb_args.debug()>0) 
     CkPrintf("[%d] %d objects migrating.\n", CkMyPe(), nmoves);
 
-  max_load = 0;
-  avg_load = 0;
-  for (pe = 0; pe<procs.size(); pe++) {
-    if (procs[pe].totalLoad() > max_load) {
-      max_load = procs[pe].totalLoad();
-    }
-    avg_load += procs[pe].totalLoad();
-  }
-  CkPrintf("GreedyLB> After lb max load: %lf avg load: %lf\n", max_load, avg_load/procs.size());
-
   if (_lb_args.debug()>1)  {
     CkPrintf("CharmLB> Min obj: %f  Max obj: %f\n", objs[objs.size()-1].getVertexLoad(), objs[0].getVertexLoad());
     CkPrintf("CharmLB> PE speed:\n");
@@ -176,10 +154,22 @@ void GreedyLB::work(LDStats* stats)
     CkPrintf("\n");
   }
 
-  stats->after_lb_max = max_load;
-  stats->after_lb_avg = avg_load/procs.size();
-  stats->is_prev_lb_refine = 0;
+  if (_lb_args.metaLbOn()) {
+    double max_load = 0;
+    double avg_load = 0;
+    for (pe = 0; pe<procs.size(); pe++) {
+      if (procs[pe].totalLoad() > max_load) {
+        max_load = procs[pe].totalLoad();
+      }
+      avg_load += procs[pe].totalLoad();
+    }
 
+    stats->after_lb_max = max_load;
+    stats->after_lb_avg = avg_load/procs.size();
+    stats->is_prev_lb_refine = 0;
+    if (_lb_args.debug() > 0)
+      CkPrintf("GreedyLB> After lb max load: %lf avg load: %lf\n", max_load, avg_load/procs.size());
+  }
 }
 
 #include "GreedyLB.def.h"
index da1b411b1e170e845bd47e93025b64c4972a1099..4ea9fdf65797a3219365b13aabc8b6b336bcd333 100644 (file)
@@ -339,7 +339,7 @@ void LBDatabase::init(void)
   nloadbalancers = 0;
   new_ld_balancer = 0;
        if (_lb_args.metaLbOn()) {
-       metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
+               metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
        }
 
   CkpvAccess(lbdatabaseInited) = 1;
index f0047d24f3f0b84151bc63c868d7468fd5639f0d..f92c86a110775409c07746a74af8aab82def4a0e 100644 (file)
@@ -224,7 +224,8 @@ void LBInfo::print()
   CmiPrintf("Min : %f Max : %f  Average: %f AvgBgLoad: %f\n", minLoad, maxLoad, average, avgBgLoad);
   CmiPrintf("ProcObjLoad  Max : %f  Average: %f\n", maxProcObjLoad, avgProcObjLoad);
   CmiPrintf("CommLoad  Max : %f  Average: %f\n", maxComLoad, avgComLoad);
-  CmiPrintf("[%d] is Maxloaded maxload: %f ObjLoad %f BgLoad %f\n", max_loaded_proc, peLoads[max_loaded_proc], objLoads[max_loaded_proc], bgLoads[max_loaded_proc]);
+  CmiPrintf("[%d] is Maxloaded maxload: %f ObjLoad %f BgLoad %f\n",
+                       max_loaded_proc, peLoads[max_loaded_proc], objLoads[max_loaded_proc], bgLoads[max_loaded_proc]);
   // the min and max object (calculated in getLoadInfo)
   CmiPrintf("MinObj : %f  MaxObj : %f\n", minObjLoad, maxObjLoad, average);
   CmiPrintf("Non-local comm: %d msgs %lld bytes\n", msgCount, msgBytes);
index 8e7d58e312a9696cfb85de816b49cc135fc46ccf..0aa832f1e89733085d6e99c286c8f6bc7fd63b9d 100644 (file)
@@ -37,7 +37,9 @@ private:
   MetaBalancerRedn* metaRdnGroup;
 
 public:
-  inline static MetaBalancer * Object() { return CkpvAccess(metalbInited)?(MetaBalancer *)CkLocalBranch(_metalb):NULL; }
+  inline static MetaBalancer * Object() {
+    return CkpvAccess(metalbInited)?(MetaBalancer *)CkLocalBranch(_metalb):NULL;
+  }
 
   static void initnodeFn(void);
 
index c7e232090626ed7e120475150221bac173dd6211..f0bc990484b13b17c3f6461784271f1b539930b6 100644 (file)
@@ -51,11 +51,15 @@ void RefineLB::work(LDStats* stats)
       }
   }
 
-  stats->is_prev_lb_refine = 1;
-  stats->after_lb_avg = refiner.computeAverageLoad();
-  stats->after_lb_max = refiner.computeMax();
-
-  CkPrintf("RefineLB> Max load %lf Avg load %lf\n", stats->after_lb_max, stats->after_lb_avg);
+  if (_lb_args.metaLbOn()) {
+    stats->is_prev_lb_refine = 1;
+    stats->after_lb_avg = refiner.computeAverageLoad();
+    stats->after_lb_max = refiner.computeMax();
+
+    if (_lb_args.debug() > 0)
+      CkPrintf("RefineLB> Max load %lf Avg load %lf\n", stats->after_lb_max,
+          stats->after_lb_avg);
+  }
 
   // Free the refine buffers
   Refiner::FreeProcs(from_procs);