Asynchronous collection of stats and informing lb period
authorHarshitha <gplkrsh2@illinois.edu>
Sun, 4 Mar 2012 22:15:33 +0000 (16:15 -0600)
committerHarshitha <gplkrsh2@illinois.edu>
Sun, 4 Mar 2012 22:15:33 +0000 (16:15 -0600)
src/ck-ldb/CentralLB.C
src/ck-ldb/CentralLB.ci
src/ck-ldb/CentralLB.h

index d4d051d98287f3cf4c075422b7b943ff2dec81c7..f06d77c8fed441a20068dee406d875e182d35284 100644 (file)
@@ -46,9 +46,7 @@ int load_balancer_created;
 
 double lb_migration_cost = 0.0;
 double lb_strategy_cost = 0.0;
-
 int lb_no_iterations = -1;
-
 double cur_max_pe_load = 0.0;
 double cur_avg_pe_load = 0.0;
 double prev_load = 0.0;
index ac6504062e57a4195a1ec2cf7b764ae0428025fd..3b0b77ec244b99f5460720af5346d6b1d151adf5 100644 (file)
@@ -20,9 +20,9 @@ group [migratable] CentralLB : BaseLB {
   entry void SendStats();
   entry void SendMinStats();
   entry void ReceiveStats(CkMarshalledCLBStatsMessage data);
+  entry void ReceiveMinStats(CkReductionMsg *msg);
   entry void ReceiveStatsViaTree(CkMarshalledCLBStatsMessage data);
   entry void ReceiveCounts(CkReductionMsg *);
-  entry void ReceiveMinStats(CkReductionMsg *msg);
   entry void LoadBalanceDecision(int period);
   entry void ReceiveIterationNo(CkReductionMsg *msg);
   entry void LoadBalance(void);
index ba5822b8f331bda838c2066d7eb654ce1a4329ab..17cfaccef5e11e90b990c9005e937953fca4a1b6 100644 (file)
@@ -100,8 +100,8 @@ public:
 
   void LoadBalanceDecision(int);
   void ReceiveIterationNo(CkReductionMsg *msg); // Receives the current iter no
-                                               // to be resumed via message
-  void ResumeClients(CkReductionMsg *);
+
+  void ResumeClients(CkReductionMsg *); // to be resumed via message
   void ReceiveMigration(LBMigrateMsg *);       // Receive migration data
   void ProcessReceiveMigration(CkReductionMsg  *);
 #if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))