fixing for ft
authorHarshitha <gplkrsh2@illinois.edu>
Sun, 14 Oct 2012 22:12:12 +0000 (17:12 -0500)
committerHarshitha <gplkrsh2@illinois.edu>
Sun, 14 Oct 2012 22:12:12 +0000 (17:12 -0500)
src/ck-ldb/LBDatabase.C
src/ck-ldb/LBDatabase.h
src/ck-ldb/MetaBalancer.C
src/ck-ldb/MetaBalancer.h

index 3bda9e8f80b1ab34cb05e60ac91ea13d5baf1ab9..da1b411b1e170e845bd47e93025b64c4972a1099 100644 (file)
 #include "LBSimulation.h"
 #include "topology.h"
 
-#include "limits.h"
-
 #include "NullLB.h"
 
-#define VEC_SIZE 50
-#define IMB_TOLERANCE 1.1
-#define OUTOFWAY_TOLERANCE 2
-#define UTILIZATION_THRESHOLD 0.7
-#define NEGLECT_IDLE 2 // Should never be == 1
-#define MIN_STATS 6
-
-#   define DEBAD(x) /*CkPrintf x*/
-#   define EXTRA_FEATURE 0
-
 CkGroupID _lbdb;
 
 CkpvDeclare(int, numLoadBalancers);  /**< num of lb created */
@@ -113,9 +101,6 @@ LBAllocFn getLBAllocFn(char *lbname) {
     return lbRegistry.getLBAllocFn(lbname);
 }
 
-LBCreateFn getLBCreateFn(const char *lbname) {
-    return lbRegistry.search(lbname);
-}
 // create a load balancer group using the strategy name
 static void createLoadBalancer(const char *lbname)
 {
@@ -344,14 +329,11 @@ void LBDatabase::initnodeFn()
 
   _expectedLoad = new LBRealType[num_proc];
   for (proc=0; proc<num_proc; proc++) _expectedLoad[proc]=0.0;
-
-  //CkPrintf("Total objs in %d is %d\n", CkMyPe(), getLBDB()->ObjDataCount());
 }
 
 // called my constructor
 void LBDatabase::init(void)
 {
-  //thisProxy = CProxy_LBDatabase(thisgroup);
   myLDHandle = LDCreate();
   mystep = 0;
   nloadbalancers = 0;
@@ -364,7 +346,6 @@ void LBDatabase::init(void)
 #if CMK_LBDB_ON
   if (manualOn) TurnManualLBOn();
 #endif
-
 }
 
 LBDatabase::LastLBInfo::LastLBInfo()
@@ -481,8 +462,8 @@ void LBDatabase::pup(PUP::er& p)
        if(p.isUnpacking()) {
     nloadbalancers = 0;
                if (_lb_args.metaLbOn()) {
-               // if unpacking set metabalancer using the id
-       metabalancer = (MetaBalancer*)CkLocalBranch(_metalb);
+      // if unpacking set metabalancer using the id
+      metabalancer = (MetaBalancer*)CkLocalBranch(_metalb);
                }
   }
 }
index d8a10d97fa748ee7dcad0b3895e4e56c75ee00ba..e9d9ff3c03ac45db3c5bc836727b0ac1b52869e8 100644 (file)
@@ -6,9 +6,6 @@
 #ifndef LBDATABASE_H
 #define LBDATABASE_H
 
-
-//#include <charm++.h>
-//#include "ckreduction.h" 
 #include "lbdb.h"
 #include "LBDBManager.h"
 #include "lbdb++.h"
@@ -168,7 +165,7 @@ class DefaultFunction : public LBPredictorFunction {
 };
 
 
-class LBDatabase : public CBase_LBDatabase {
+class LBDatabase : public IrrGroup {
 public:
   LBDatabase(void)  { init(); }
   LBDatabase(CkMigrateMessage *m)  { init(); }
index 75044aa9631a74abb84399d7288284fe36195363..ff9dce475e4ed24d4471e4b9511be1e2859a61bf 100644 (file)
@@ -141,7 +141,7 @@ void MetaBalancer::init(void) {
 }
 
 void MetaBalancer::pup(PUP::er& p) {
-       IrrGroup::pup(p);
+       CBase_MetaBalancer::pup(p);
   if (p.isUnpacking()) {
     lbdatabase = (LBDatabase *)CkLocalBranch(_lbdb);
     metaRdnGroup = (MetaBalancerRedn*)CkLocalBranch(_metalbred);
@@ -823,6 +823,10 @@ void MetaBalancerRedn::init() {
   metabalancer = (MetaBalancer *)CkLocalBranch(_metalb);
 }
 
+void MetaBalancerRedn::pup(PUP::er& p) {
+       CBase_MetaBalancerRedn::pup(p);
+}
+
 void MetaBalancerRedn::ReceiveIterNo(int max_iter) {
   CkAssert(CkMyPe() == 0);
   if (metabalancer == NULL) {
index 055946575e709ff6b20b78b8b7f560162bfb0caa..dd3d82aff3cb4bc529454f91abb28b1efbe32c48 100644 (file)
@@ -28,8 +28,8 @@ class MetaLBInit : public Chare {
 
 class MetaBalancer : public CBase_MetaBalancer {
 public:
-  MetaBalancer(void)  { init(); }
-  MetaBalancer(CkMigrateMessage *m)  { init(); }
+  MetaBalancer(void) { init(); }
+  MetaBalancer(CkMigrateMessage *m) : CBase_MetaBalancer(m) { init(); }
   ~MetaBalancer()  {}
   
 private:
@@ -158,8 +158,9 @@ public:
 class MetaBalancerRedn : public CBase_MetaBalancerRedn {
   public:
     MetaBalancerRedn(void) {init();}
-    MetaBalancerRedn(CkMigrateMessage *m)  {init();}
+    MetaBalancerRedn(CkMigrateMessage *m) : CBase_MetaBalancerRedn(m)  {init();}
     ~MetaBalancerRedn()  {}
+    void pup(PUP::er& p);
     void ReceiveIterNo(int max_iter);
     void getMaxIter(int);