#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] |