Fix a bug in the init
authorHarshitha <gplkrsh2@illinois.edu>
Sat, 20 Oct 2012 23:42:45 +0000 (18:42 -0500)
committerHarshitha <gplkrsh2@illinois.edu>
Sat, 20 Oct 2012 23:42:45 +0000 (18:42 -0500)
examples/charm++/load_balancing/kNeighbor/kNeighbor.C
src/ck-core/cklocation.C
src/ck-ldb/GreedyLB.C
src/ck-ldb/LBDatabase.C
src/ck-ldb/MetaBalancer.C

index 98a3267612c44bec6981e5635080cdb06df0a4b1..6d3ad974ca6cf9dfd839d375f6af554f2c417848 100644 (file)
@@ -72,10 +72,10 @@ class Main: public CBase_Main {
       }
 
       num_chares = atoi(m->argv[1]);
-//      if(num_chares < CkNumPes()) {
-//     printf("Warning: #elements is forced to be equal to #pes\n");
-//     num_chares = CkNumPes();
-//      }
+      if(num_chares < CkNumPes()) {
+       printf("Warning: #elements is forced to be equal to #pes\n");
+       num_chares = CkNumPes();
+      }
 
       numSteps = atoi(m->argv[2]);
       currentMsgSize = atoi(m->argv[3]);
index 95038019eef6f3396c0c514663185d85b5eafdf7..b26c11e4fe7ecc6a006aea91e24eac81b60fcaeb 100644 (file)
@@ -1413,10 +1413,8 @@ CkLocRec_local::CkLocRec_local(CkLocMgr *mgr,CmiBool fromMigration,
         enable_measure = CmiTrue;
        bounced  = CmiFalse;
        the_lbdb=mgr->getLBDB();
-  if (_lb_args.metaLbOn()) {
-    the_metalb=mgr->getMetaBalancer();
-  }
-        LDObjid ldid = idx2LDObjid(idx);
+       the_metalb=mgr->getMetaBalancer();
+       LDObjid ldid = idx2LDObjid(idx);
 #if CMK_GLOBAL_LOCATION_UPDATE
         ldid.locMgrGid = mgr->getGroupID().idx;
 #endif        
@@ -3199,11 +3197,9 @@ void CkLocMgr::initLB(CkGroupID lbdbID_, CkGroupID metalbID_)
        if (the_lbdb == 0)
                CkAbort("LBDatabase not yet created?\n");
        DEBL((AA"Connected to load balancer %p\n"AB,the_lbdb));
-  if (_lb_args.metaLbOn()) {
-    the_metalb = (MetaBalancer *)CkLocalBranch(metalbID_);
-    if (the_metalb == 0)
-      CkAbort("MetaBalancer not yet created?\n");
-  }
+       the_metalb = (MetaBalancer *)CkLocalBranch(metalbID_);
+       if (the_metalb == 0)
+               CkAbort("MetaBalancer not yet created?\n");
 
        // Register myself as an object manager
        LDOMid myId;
index 808e59ca1c09f5165fe5ee4b5af1722d90ccbc43..962393f33af79bbb41ad428a2348507d8a764461 100644 (file)
@@ -57,8 +57,6 @@ void GreedyLB::work(LDStats* stats)
   int n_pes = stats->nprocs();
   int *map = new int[n_pes];
 
-  ProcArray *parr = new ProcArray(stats);
-
   std::vector<ProcInfo>  procs;
   for(pe = 0; pe < n_pes; pe++) {
     map[pe] = -1;
index 4ea9fdf65797a3219365b13aabc8b6b336bcd333..e9027dc18fd384daa5d0fac7a8a91e3bc7fe85f2 100644 (file)
@@ -338,9 +338,7 @@ void LBDatabase::init(void)
   mystep = 0;
   nloadbalancers = 0;
   new_ld_balancer = 0;
-       if (_lb_args.metaLbOn()) {
-               metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
-       }
+       metabalancer = NULL;
 
   CkpvAccess(lbdatabaseInited) = 1;
 #if CMK_LBDB_ON
index a3fb3f05942a2a6479a62f50f622775394694766..9ab9ee105ccabea5aa74a8df0c84444a15fe3649 100644 (file)
@@ -82,8 +82,8 @@ CkpvDeclare(int, metalbInited);  /**< true if metabalancer is inited */
 // mainchare
 MetaLBInit::MetaLBInit(CkArgMsg *m) {
 #if CMK_LBDB_ON
-  _metalb = CProxy_MetaBalancer::ckNew();
   _metalbred = CProxy_MetaBalancerRedn::ckNew();
+  _metalb = CProxy_MetaBalancer::ckNew();
 #endif
   delete m;
 }
@@ -701,7 +701,7 @@ void MetaBalancer::ResetAdaptive() {
 // This is required for PEs with no objs
 void MetaBalancer::periodicCall(void *ad) {
   MetaBalancer *s = (MetaBalancer *)ad;
-  CcdCallFnAfterOnPE((CcdVoidFn)checkForNoObj, (void *)s, 500, CkMyPe());
+  CcdCallFnAfterOnPE((CcdVoidFn)checkForNoObj, (void *)s, 10, CkMyPe());
 }
 
 void MetaBalancer::checkForNoObj(void *ad) {
@@ -842,7 +842,8 @@ void MetaBalancer::GetLBDataForLB(int lb_type, double& lb_max_avg_ratio,
 }
 
 void MetaBalancerRedn::init() {
-  metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
+//  metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
+  metabalancer = NULL;
 }
 
 void MetaBalancerRedn::pup(PUP::er& p) {