src/ck-ldb/CentralLB.ci

   1 module CentralLB {
   2
   3 extern module BaseLB;
   4 extern module LBDatabase;
   5
   6 include "CentralLBMsg.h";
   7
   8 readonly CkGroupID loadbalancer;
   9
  10 //message CLBStatsMsg;
  11
  12 initnode void lbinit(void);
  13
  14 group [migratable] CentralLB : BaseLB {
  15   entry void CentralLB(const CkLBOptions &);
  16   entry void ProcessAtSync(void);
  17   entry void SendStats();
  18   entry void ReceiveStats(CkMarshalledCLBStatsMessage data);
  19   entry void ReceiveStatsViaTree(CkMarshalledCLBStatsMessage data);
  20   entry void ReceiveCounts(CkReductionMsg *);
  21   entry void LoadBalance(void);
  22   entry [threaded] void t_LoadBalance(void);
  23   entry void ResumeClients(int);
  24   entry void ResumeClients(CkReductionMsg *);
  25   entry void changeFreq(int);
  26   entry void ScatterMigrationResults(LBScatterMsg *);
  27   entry void ReceiveMigration(LBMigrateMsg*);
  28   entry void ReceiveMigration(LBScatterMsg*);
  29   entry void ProcessReceiveMigration(CkReductionMsg  *);
  30   entry void ProcessMigrationDecision(CkReductionMsg *);
  31   entry void MissMigrate(int);
  32   entry void CheckForRealloc();
  33   entry void ResumeFromReallocCheckpoint();
  34   entry void MigrationDoneImpl(int);
  35   entry void WillIbekilled(std::vector <char> avail, int);
  36   entry void StartCleanup();
  37 };
  38
  39 };