
#include <HbmLB.h>


Public Member Functions | |
| HbmLB (const CkLBOptions &) | |
| HbmLB (CkMigrateMessage *m) | |
| ~HbmLB () | |
| void | AtSync (void) |
| void | ProcessAtSync (void) |
| void | ReceiveStats (double t, int frompe, int fromlevel) |
| void | ResumeClients (double result) |
| void | ResumeClients (int balancing) |
| void | ReceiveMigrationCount (int, int lblevel) |
| void | ReceiveMigrationDelta (double t, int lblevel, int level) |
| void | Migrated (LDObjHandle h, int waitBarrier) |
| void | ObjMigrated (LDObjData data, LDCommData *cdata, int n) |
| void | collectCommData (int objIdx, CkVec< LDCommData > &comms) |
| void | MigrationDone (int balancing) |
| void | NotifyObjectMigrationDone (int level, int lblevel) |
| virtual void | Loadbalancing (int level) |
| void | LoadbalancingDone (int level) |
| void | ReceiveResumeClients (int fromlevel, int balancing) |
| void | reportLBQulity (double mload, double mCpuLoad, double totalload, int nmsgs, double bytesentry) |
Static Public Member Functions | |
| static void | staticAtSync (void *) |
| static void | staticMigrated (void *me, LDObjHandle h, int waitBarrier) |
Protected Member Functions | |
| virtual bool | QueryBalanceNow (int) |
| virtual bool | QueryMigrateStep (int) |
| virtual void | work (LDStats *stats) |
| virtual int | useMem () |
| int | NeighborIndex (int pe, int atlevel) |
Protected Attributes | |
| MyHmbHierarchyTree * | tree |
| CkVec< LevelData * > | levelData |
| int | currentLevel |
| int | lbLevel |
Private Member Functions | |
| void | FindNeighbors () |
Private Attributes | |
| int | foundNeighbors |
| LDStats | myStats |
| int | migrate_expected |
| LBMigrateMsg ** | mig_msgs |
| int | mig_msgs_received |
| int | cur_ld_balancer |
| double | start_lb_time |
| double | maxLoad |
| double | maxCpuLoad |
| double | maxCommBytes |
| int | maxCommCount |
| double | totalLoad |
| double | maxMem |
| int | vector_n_moves |
| CkVec< LDObjHandle > | newObjs |
Data Structures | |
| class | LevelData |
| struct | MigrationRecord |
Definition at line 70 of file HbmLB.h.
| HbmLB::HbmLB | ( | CkMigrateMessage * | m | ) | [inline] |
| static void HbmLB::staticMigrated | ( | void * | me, | |
| LDObjHandle | h, | |||
| int | waitBarrier | |||
| ) | [static] |
int HbmLB::foundNeighbors [private] |
LDStats HbmLB::myStats [private] |
Definition at line 111 of file HbmLB.h.
Referenced by collectCommData(), MigrationDone(), ObjMigrated(), ProcessAtSync(), ReceiveMigrationDelta(), and ResumeClients().
MyHmbHierarchyTree* HbmLB::tree [protected] |
Definition at line 122 of file HbmLB.h.
Referenced by FindNeighbors(), HbmLB(), LoadbalancingDone(), MigrationDone(), ReceiveStats(), and ~HbmLB().
CkVec<LevelData *> HbmLB::levelData [protected] |
Definition at line 185 of file HbmLB.h.
Referenced by collectCommData(), FindNeighbors(), Loadbalancing(), LoadbalancingDone(), Migrated(), MigrationDone(), NeighborIndex(), NotifyObjectMigrationDone(), ObjMigrated(), ProcessAtSync(), ReceiveMigrationCount(), ReceiveMigrationDelta(), ReceiveResumeClients(), ReceiveStats(), ResumeClients(), and useMem().
int HbmLB::currentLevel [protected] |
int HbmLB::lbLevel [protected] |
Definition at line 188 of file HbmLB.h.
Referenced by MigrationDone(), NotifyObjectMigrationDone(), and ReceiveMigrationCount().
int HbmLB::migrate_expected [private] |
LBMigrateMsg** HbmLB::mig_msgs [private] |
int HbmLB::mig_msgs_received [private] |
int HbmLB::cur_ld_balancer [private] |
double HbmLB::start_lb_time [private] |
Definition at line 197 of file HbmLB.h.
Referenced by Loadbalancing(), ProcessAtSync(), and ResumeClients().
double HbmLB::maxLoad [private] |
double HbmLB::maxCpuLoad [private] |
double HbmLB::maxCommBytes [private] |
int HbmLB::maxCommCount [private] |
double HbmLB::totalLoad [private] |
Definition at line 203 of file HbmLB.h.
Referenced by HbmLB(), LoadbalancingDone(), reportLBQulity(), and ResumeClients().
double HbmLB::maxMem [private] |
int HbmLB::vector_n_moves [private] |
CkVec<LDObjHandle> HbmLB::newObjs [private] |
1.5.5