extract MigrationMsg from all LB strategies.
authorGengbin Zheng <gzheng@illinois.edu>
Sun, 3 Mar 2002 23:55:03 +0000 (23:55 +0000)
committerGengbin Zheng <gzheng@illinois.edu>
Sun, 3 Mar 2002 23:55:03 +0000 (23:55 +0000)
also Doxygen.

65 files changed:
src/ck-ldb/BaseLB.C
src/ck-ldb/BaseLB.ci
src/ck-ldb/BaseLB.h
src/ck-ldb/CentralLB.C
src/ck-ldb/CentralLB.ci
src/ck-ldb/CentralLB.h
src/ck-ldb/Comm1LB.C
src/ck-ldb/Comm1LB.h
src/ck-ldb/CommLB.C
src/ck-ldb/CommLB.h
src/ck-ldb/CommLBHeap.C
src/ck-ldb/CommLBHeap.h
src/ck-ldb/EveryLB.C
src/ck-ldb/GreedyRefLB.C
src/ck-ldb/GreedyRefLB.h
src/ck-ldb/HeapCentLB.C
src/ck-ldb/HeapCentLB.h
src/ck-ldb/LBComm.C
src/ck-ldb/LBComm.h
src/ck-ldb/LBDBManager.C
src/ck-ldb/LBDBManager.h
src/ck-ldb/LBDatabase.C
src/ck-ldb/LBDatabase.h
src/ck-ldb/LBMachineUtil.C
src/ck-ldb/LBMachineUtil.h
src/ck-ldb/LBOM.h
src/ck-ldb/LBObj.C
src/ck-ldb/LBObj.h
src/ck-ldb/MetisLB.C
src/ck-ldb/MetisLB.h
src/ck-ldb/NborBaseLB.C
src/ck-ldb/NborBaseLB.ci
src/ck-ldb/NborBaseLB.h
src/ck-ldb/NeighborLB.C
src/ck-ldb/NeighborLB.h
src/ck-ldb/NullLB.C
src/ck-ldb/NullLB.h
src/ck-ldb/ObjGraph.C
src/ck-ldb/ObjGraph.h
src/ck-ldb/RandCentLB.C
src/ck-ldb/RandCentLB.h
src/ck-ldb/RandRefLB.C
src/ck-ldb/RandRefLB.h
src/ck-ldb/RecBisectBfLB.C
src/ck-ldb/RecBisectBfLB.h
src/ck-ldb/RefineLB.C
src/ck-ldb/RefineLB.h
src/ck-ldb/Refiner.C
src/ck-ldb/Refiner.h
src/ck-ldb/Set.C
src/ck-ldb/Set.h
src/ck-ldb/WSLB.C
src/ck-ldb/WSLB.ci
src/ck-ldb/WSLB.h
src/ck-ldb/bitvecset.c
src/ck-ldb/bitvecset.h
src/ck-ldb/elements.h
src/ck-ldb/graph.c
src/ck-ldb/graph.h
src/ck-ldb/heap.C
src/ck-ldb/heap.h
src/ck-ldb/lbdb.C
src/ck-ldb/lbdb.h
src/ck-ldb/manager.C
src/ck-ldb/manager.h

index 6c11f2d3601b7166344381c65ea75a677ff237d7..47ffb960643c8c2c93fa4755450198a5b7fed6ab 100644 (file)
@@ -5,12 +5,18 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 #include <BaseLB.h>
 
-CkpvDeclare(int, numLoadBalancers);
-CkpvDeclare(int, hasNullLB);
+CkpvDeclare(int, numLoadBalancers);  /**< num of lb created */
+CkpvDeclare(int, hasNullLB);         /**< true if NullLB is created */
 
+/// called in Charm Init to initialize Cpv variables.
 void _loadbalancerInit()
 {
 //CmiPrintf("[%d] initLBFrameWork()\n", CkMyPe());
@@ -34,9 +40,52 @@ void BaseLB::unregister() {
   theLbdb->RemoveLocalBarrierReceiver(receiver);
   CkpvAccess(numLoadBalancers) --;
 }
+
+void* LBMigrateMsg::alloc(int msgnum, size_t size, int* array, int priobits)
+{
+  int totalsize = size + array[0] * sizeof(MigrateInfo) 
+    + CkNumPes() * sizeof(char);
+
+  LBMigrateMsg* ret =
+    (LBMigrateMsg*)(CkAllocMsg(msgnum,totalsize,priobits));
+
+  ret->moves = (MigrateInfo*) ((char*)(ret)+ size);
+
+  ret->avail_vector = (char *)(ret->moves + array[0]);
+  return (void*)(ret);
+}
+
+void* LBMigrateMsg::pack(LBMigrateMsg* m)
+{
+  m->moves = (MigrateInfo*)
+    ((char*)(m->moves) - (char*)(&m->moves));
+
+  m->avail_vector =(char*)(m->avail_vector
+      - (char*)(&m->avail_vector));
+
+  return (void*)(m);
+}
+
+LBMigrateMsg* LBMigrateMsg::unpack(void *m)
+{
+  LBMigrateMsg* ret_val = (LBMigrateMsg*)(m);
+
+  ret_val->moves = (MigrateInfo*)
+    ((char*)(&ret_val->moves) 
+     + (size_t)(ret_val->moves));
+
+  ret_val->avail_vector =
+    (char*)((char*)(&ret_val->avail_vector)
+                           +(size_t)(ret_val->avail_vector));
+
+  return ret_val;
+}
+
 #else
 BaseLB::BaseLB() {}
 void BaseLB::unregister() {}
 #endif
 
 #include "BaseLB.def.h"
+
+/*@}*/
index 4e07efb2a68e0751679833a6ee9ab6511622749f..f0944492fee1190a930d462e7bc362cadb144295 100644 (file)
@@ -2,6 +2,8 @@ module BaseLB {
 
 extern module LBDatabase;
 
+message LBMigrateMsg;
+
 group BaseLB {
   entry void BaseLB(void);  
   entry void unregister(void);
index 85eb304379ef6baaef429440e113bdec52ad4b7a..ececd3b63402c9aaba81542c4ecccdfca645efe7 100644 (file)
@@ -1,9 +1,19 @@
+/**
+ \defgroup CkLdb  Charm++ Load Balancing Framework 
+*/
+/*@{*/
+
 #ifndef BASELB_H
 #define BASELB_H
 
 #include "LBDatabase.h"
 
 /// Base class for all LB strategies.
+/**
+  BaseLB is the base class for all LB strategy class.
+  it does some tracking about how many lb strategies are created.
+  it also defines some common functions.
+*/
 class BaseLB: public Group
 {
 protected:
@@ -14,4 +24,31 @@ public:
   void unregister(); 
 };
 
+/// migration decision for an obj.
+struct MigrateInfo {  
+    LDObjHandle obj;
+    int from_pe;
+    int to_pe;
+};
+
+/**
+  message contains the migration decision from LB strategies.
+*/
+class LBMigrateMsg : public CMessage_LBMigrateMsg {
+public:
+  int n_moves;
+  MigrateInfo* moves;
+
+  char * avail_vector;
+  int next_lb;
+
+  // Other methods & data members
+
+  static void* alloc(int msgnum, size_t size, int* array, int priobits);
+  static void* pack(LBMigrateMsg* in);
+  static LBMigrateMsg* unpack(void* in);
+};
+
 #endif
+
+/*@}*/
index 1f31a54170eea3b9a86ff43bd41256dbf4546a10..856019ee7b0439d19231cc25b13b4447aa924e06 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 #include "CentralLB.h"
 #include "CentralLB.def.h"
@@ -201,7 +206,7 @@ void CentralLB::ReceiveStats(CLBStatsMsg *m)
     
 //    CkPrintf("Before Calling Strategy\n");
 
-    CLBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
+    LBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
 
 //    CkPrintf("returned successfully\n");
     int num_proc = CkNumPes();
@@ -225,7 +230,7 @@ void CentralLB::ReceiveStats(CLBStatsMsg *m)
   
 }
 
-void CentralLB::ReceiveMigration(CLBMigrateMsg *m)
+void CentralLB::ReceiveMigration(LBMigrateMsg *m)
 {
   DEBUGF(("[%d] in ReceiveMigration %d moves\n",CkMyPe(),m->n_moves));
   migrates_expected = 0;
@@ -274,7 +279,7 @@ void CentralLB::ResumeClients()
   theLbdb->ResumeClients();
 }
 
-CLBMigrateMsg* CentralLB::Strategy(LDStats* stats,int count)
+LBMigrateMsg* CentralLB::Strategy(LDStats* stats,int count)
 {
   for(int j=0; j < count; j++) {
     int i;
@@ -322,51 +327,12 @@ CLBMigrateMsg* CentralLB::Strategy(LDStats* stats,int count)
   }
 
   int sizes=0;
-  CLBMigrateMsg* msg = new(&sizes,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&sizes,1) LBMigrateMsg;
   msg->n_moves = 0;
 
   return msg;
 }
 
-
-void* CLBMigrateMsg::alloc(int msgnum, size_t size, int* array, int priobits)
-{
-  int totalsize = size + array[0] * sizeof(CentralLB::MigrateInfo) 
-    + CkNumPes() * sizeof(char);
-
-  CLBMigrateMsg* ret =
-    (CLBMigrateMsg*)(CkAllocMsg(msgnum,totalsize,priobits));
-
-  ret->moves = (CentralLB::MigrateInfo*) ((char*)(ret)+ size);
-
-  ret->avail_vector = (char *)(ret->moves + array[0]);
-  return (void*)(ret);
-}
-
-void* CLBMigrateMsg::pack(CLBMigrateMsg* m)
-{
-  m->moves = (CentralLB::MigrateInfo*)
-    ((char*)(m->moves) - (char*)(&m->moves));
-
-  m->avail_vector =(char*)(m->avail_vector
-      - (char*)(&m->avail_vector));
-
-  return (void*)(m);
-}
-
-CLBMigrateMsg* CLBMigrateMsg::unpack(void *m)
-{
-  CLBMigrateMsg* ret_val = (CLBMigrateMsg*)(m);
-
-  ret_val->moves = (CentralLB::MigrateInfo*)
-    ((char*)(&ret_val->moves) 
-     + (size_t)(ret_val->moves));
-
-  ret_val->avail_vector =
-    (char*)((char*)(&ret_val->avail_vector)
-                           +(size_t)(ret_val->avail_vector));
-
-  return ret_val;
-}
-
 #endif
+
+/*@}*/
index 78c579b60e48c5412e74a6bd2d82f23b076f3a6f..ed2ec0f3b6a94520244bb4b1b1f89ed7460749fa 100644 (file)
@@ -11,14 +11,12 @@ message CLBStatsMsg{
  char       avail_vector[];
 };
 
-message CLBMigrateMsg;
-
 group CentralLB : BaseLB {
   entry void CentralLB(void);  
   entry void ProcessAtSync(void);
   entry void ReceiveStats(CLBStatsMsg*);
   entry void ResumeClients(void);
-  entry void ReceiveMigration(CLBMigrateMsg*); 
+  entry void ReceiveMigration(LBMigrateMsg*);  
 };
 
 };
index 4c2b0239b4aba6a927bc325546effbed89e640ba..abd30475d69d6aa7efa700ca6d64bdcdd24411eb 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef CENTRALLB_H
 #define CENTRALLB_H
 
@@ -17,7 +22,9 @@ void CreateCentralLB();
 void set_avail_vector(char * bitmap);
 
 class CLBStatsMsg;
-class CLBMigrateMsg;
+
+/// for backward compatibility
+typedef LBMigrateMsg  CLBMigrateMsg;
 
 class CentralLB : public CBase_CentralLB
 {
@@ -33,7 +40,7 @@ public:
   void ReceiveStats(CLBStatsMsg *);            // Receive stats on PE 0
   void ResumeClients(void);                     // Resuming clients needs
                                                // to be resumed via message
-  void ReceiveMigration(CLBMigrateMsg *);      // Receive migration data
+  void ReceiveMigration(LBMigrateMsg *);       // Receive migration data
 
   // Migrated-element callback
   static void staticMigrated(void* me, LDObjHandle h);
@@ -44,12 +51,6 @@ public:
 
   void set_avail_vector(char *new_vector);
 
-  struct MigrateInfo {  // Used in CLBMigrateMsg
-    LDObjHandle obj;
-    int from_pe;
-    int to_pe;
-  };
-
   struct LDStats {  // Passed to Strategy
     double total_walltime;
     double total_cputime;
@@ -66,7 +67,7 @@ public:
     LDCommData* commData;
   };
 
-   CLBMigrateMsg* callStrategy(LDStats* stats,int count){
+   LBMigrateMsg* callStrategy(LDStats* stats,int count){
        return Strategy(stats,count);
    };
 
@@ -77,7 +78,7 @@ public:
 
 protected:
   virtual CmiBool QueryBalanceNow(int) { return CmiTrue; };  
-  virtual CLBMigrateMsg* Strategy(LDStats* stats,int count);
+  virtual LBMigrateMsg* Strategy(LDStats* stats,int count);
 
 private:  
 
@@ -112,24 +113,8 @@ public:
   int next_lb;
 }; 
 
-class CLBMigrateMsg : public CMessage_CLBMigrateMsg {
-public:
-  int n_moves;
-  CentralLB::MigrateInfo* moves;
-  
-  char * avail_vector;
-  int next_lb;
-  
-  // Other methods & data members 
-
-  static void* alloc(int msgnum, size_t size, int* array, int priobits); 
-  static void* pack(CLBMigrateMsg* in); 
-  static CLBMigrateMsg* unpack(void* in); 
-}; 
-
 #endif /* CENTRALLB_H */
 
-
-
+/*@}*/
 
 
index d82cae2bba91c9f4168c76a3908e86140aab999f..c48d3b3885d8ae5c0f7763563da77c63e2b3d13f 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 #include <stdio.h>
 
@@ -168,7 +173,7 @@ void init(alloc_struct **a, graph * object_graph, int l, int b){
   }
 }
 
-CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
 {
   int pe,obj,com;
   double load_pe=0.0,mean_load =0.0;
@@ -302,7 +307,7 @@ CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
   }
 
   int migrate_count = migrateInfo.length();
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -317,5 +322,6 @@ CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
 
 #endif
 
+/*@}*/
 
 
index f81623f915b1931e35f431daf599032bae7f16a9..340c38befdf14f528e5665c7b35e7f7f14436601 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _Comm1LB_H_
 #define _Comm1LB_H_
 
@@ -35,7 +40,7 @@ public:
   Comm1LB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
   void alloc(int pe, int id, double load, int nmsg, int nbyte);
   double compute_cost(int id, int pe, int n_alloc, int &out_msg, int &out_byte); 
   int search(LDObjid oid, LDOMid mid);
@@ -46,4 +51,5 @@ private:
 #endif
 
 
+/*@}*/
 
index 3658521824670d42d21527b3717b3e3424ffb353..f50fa458044abb0355a8ab7747f2298334f5d96b 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 #include <stdio.h>
 
@@ -144,7 +149,7 @@ void init(double **a, graph * object_graph, int l, int b){
     }
 }
 
-CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
 {
     int pe,obj,com;
     double load_pe=0.0;
@@ -283,7 +288,7 @@ CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
     }
     
     int migrate_count = migrateInfo.length();
-    CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+    LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
     msg->n_moves = migrate_count;
     for(int i=0; i < migrate_count; i++) {
        MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -317,5 +322,5 @@ CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
 
 #endif
 
-
+/*@}*/
 
index 7e5fcf545872679f19d17248f0b06737a569882f..d644c82f5e1a0c1600ddd6a7a785a8b7b2abe093 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _COMMLB_H_
 #define _COMMLB_H_
 
@@ -36,9 +41,10 @@ public:
   obj_id * translate;
   int * htable;
   CommLB();
+  CommLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
   void alloc(int pe, int id, double load);
   double compute_com(int id,int pe); 
   int search(LDObjid oid, LDOMid mid);
@@ -50,7 +56,7 @@ private:
 
 
 
-
+/*@}*/
 
 
 
index 9cc06476a9154b7d6297175391a0ca34b09f1f02..2e2d715fd417cd50973346c2e3e8a3e2079d2307 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include "CommLBHeap.h"
 #include "charm++.h"
 
@@ -102,3 +107,5 @@ ObjectRecord *ObjectHeap::next(hIterator *iter){
   iter->next += 1;
   return h[iter->next - 1].info;
 }
+
+/*@}*/
index 269dc87328c57397667ee3b51b0501202f4cf7d5..aec1e0fcdb9e34c8a1e8857eae7196a0aed59b51 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef __COMM_LB_HEAP
 #define __COMM_LB_HEAP
 
@@ -57,3 +62,5 @@ public:
 };
 
 #endif
+
+/*@}*/
index 0433e549567c29f65797c89b71ee1e8650fe0965..d0b882e24b43907c51209d1a4df7ccc74f6287e1 100644 (file)
@@ -1,3 +1,8 @@
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 /*
  Startup routine for use when you include all the load balancers.
 */
@@ -17,3 +22,5 @@ void initEveryLB(void) {
 }
 
 #include "EveryLB.def.h"
+
+/*@}*/
index d46037d17d0de0f89270820fc20216b6b1fc9ba7..2a3cf0bf73d34df3b15aa9d6d32b9cacdb53e575 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -158,7 +163,7 @@ GreedyRefLB::BuildCpuArray(CentralLB::LDStats* stats, int count, int *peCount)
 
 
 
-CLBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   CkVec<MigrateInfo*> migrateInfo;
   int      pe, obj, heapSize, objCount;
@@ -254,7 +259,7 @@ CLBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
 
   int migrate_count=migrateInfo.length();
   CkPrintf("GreedyRefLB migrating %d elements\n",migrate_count);
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*) migrateInfo[i];
@@ -271,3 +276,5 @@ CLBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
 };
 
 #endif
+
+/*@}*/
index 142cff6f55a2db39a63ad282a0f5136ee07dc5e8..202c1f42adf68fed4a17c63139773021a191d54f 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _GREEDYREFLB_H_
 #define _GREEDYREFLB_H_
 
@@ -34,7 +39,9 @@ private:
        HeapData*      BuildCpuArray(CentralLB::LDStats*, int, int *);      
        HeapData*      BuildObjectArray(CentralLB::LDStats*, int, int *);      
        CmiBool        QueryBalanceNow(int step);
-       CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+       LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 };
 
 #endif /* _GREEDYREFLB_H_ */
+
+/*@}*/
index 554b8b10a514f62f6f0f71a993cfed379e1cd8f1..836e0f25c154d0eb5187fe07d637e52ff0e2c40b 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -161,7 +166,7 @@ HeapCentLB::BuildCpuArray(CentralLB::LDStats* stats,
   return data;
 }
 
-CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   CkVec<MigrateInfo*> migrateInfo;
   int      obj, heapSize, objCount;
@@ -213,7 +218,7 @@ CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
 
   int migrate_count=migrateInfo.length();
   CkPrintf("HeapCentLB migrating %d elements\n",migrate_count);
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*) migrateInfo[i];
@@ -227,6 +232,7 @@ CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
 #endif
 
 
+/*@}*/
 
 
 
index f91f84ef808b2d83aae3f2490c1cc0709966cf80..f3ac1e17e0e7da4d713959270cab3dd7ed6a36f6 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _HEAPCENTLB_H_
 #define _HEAPCENTLB_H_
 
@@ -33,7 +38,9 @@ private:
        HeapData*      BuildCpuArray(CentralLB::LDStats*, int, int *);      
        HeapData*      BuildObjectArray(CentralLB::LDStats*, int, int *);      
        CmiBool        QueryBalanceNow(int step);
-       CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+       LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 };
 
 #endif /* _HEAPCENTLB_H_ */
+
+/*@}*/
index 88cc0147426e729bc1b990546dd73b1d80602c95..d0bed41b67065753948330a6439ff9abcd29bfe6 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <converse.h>
 
 #if CMK_LBDB_ON
@@ -172,3 +177,5 @@ void LBCommTable::GetCommData(LDCommData* data)
 }
 
 #endif // CMK_LBDB_ON
+
+/*@}*/
index 830eb32726eb8961cef49e92d65067bb785664b0..2ae4df27ba5ce12264acc2a3f21cc0ae90b50b82 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBCOMM_H
 #define LBCOMM_H
 
@@ -122,3 +127,5 @@ private:
 
 
 #endif
+
+/*@}*/
index 189ceca2fee9287893f0d300a608bcdf2dd76148..620341588859b412c8039bf48ec279e22819a6e7 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -346,3 +351,5 @@ void LocalBarrier::ResumeClients(void)
 }
 
 #endif
+
+/*@}*/
index 9218469920619f3885f863670cb218f518e1a965..358f36e781bd523f341ae61f4b171eaba03ead2c 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBDB_H
 #define LBDB_H
 
@@ -181,3 +186,4 @@ private:
 
 #endif
 
+/*@}*/
index 944f9b06e8498228125704a41acd4379b6a0d422..788ea1df0ee85802bef6fad033da5aaf829daf9c 100644 (file)
@@ -5,8 +5,12 @@
  * $Revision$
  *****************************************************************************/
 
-#include <converse.h>
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
 
+#include <converse.h>
 
 /*
  * This C++ file contains the Charm stub functions
@@ -90,3 +94,5 @@ LBDBInit::LBDBInit(CkArgMsg *m)
 #endif
   delete m;
 }
+
+/*@}*/
index e5e6874f6706f441b150b546274e9d6ebff54d95..297fa86a4149ed2e604b4668bc0e4ab160a96391 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBDATABASE_H
 #define LBDATABASE_H
 
@@ -134,3 +139,5 @@ private:
 };
 
 #endif /* LDATABASE_H */
+
+/*@}*/
index 2d97f401477a14abe38ac2ef750a5e57e0a5dff2..5d942ca82edbae43556879f6abb2adff2e6ce7f7 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include "LBMachineUtil.h"
 #include <stdlib.h>
 
@@ -108,3 +113,5 @@ void LBMachineUtil::TotalTime(double* walltime, double* cputime)
   *walltime = total_walltime;
   *cputime = total_cputime;
 }
+
+/*@}*/
index 4e758596da5f4ce021a1434704f62fd53b0877f6..6e80c9dc6e6f181a9949c871a6e96f1014aa1145 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _LDMACHINEUTIL_H_
 #define _LDMACHINEUTIL_H_
 
@@ -34,3 +39,5 @@ private:
 };
 
 #endif  // _LDMACHINEUTIL_H_
+
+/*@}*/
index 74c1c11e72b6f667a9c0cab15cd8c02e2e9a0113..17ed769fea2de54997922955ebe08fbff8ba2bbb 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBOM_H
 #define LBOM_H
 
@@ -48,3 +53,5 @@ private:
 };
 
 #endif
+
+/*@}*/
index 8fcedf3005987a24d3387e01b315f8f66a38f17c..e44ea0a8c1887ac31ef468c90e4c18231b1829ca 100644 (file)
@@ -5,8 +5,12 @@
  * $Revision$
  *****************************************************************************/
 
-#include <converse.h>
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
 
+#include <converse.h>
 
 #if CMK_LBDB_ON
 
@@ -50,3 +54,5 @@ void LBObj::StopTimer(double* walltime, double* cputime)
 }
 
 #endif
+
+/*@}*/
index f94715fe93b244f10d7b95a571747ce47da4648c..2e63be3e9c6cfeade9bfd21abe3e8b16cb8b2abc 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBOBJ_H
 #define LBOBJ_H
 
@@ -61,3 +66,5 @@ private:
 };
 
 #endif
+
+/*@}*/
index f876b083e80e6d77ed03c46d34f5b49d19db9b48..80d9ad75b75e1059a90d90734f5d33857895557f 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -98,10 +103,10 @@ extern "C" void METIS_mCPartGraphKway(int*, int*, int*, int*, int*, int*,
                                     int*, int*, int*, int*, int*,
                                     int*, int*);
 /*
-CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count,
+LBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count,
                                 int option=0)
 */
-CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   // CkPrintf("entering MetisLB::Strategy...\n");
   // CkPrintf("[%d] MetisLB strategy\n",CkMyPe());
@@ -311,7 +316,7 @@ CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
 
   int migrate_count=migrateInfo.length();
   //  CkPrintf("Migration Count = %d\n", migrate_count);
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -324,3 +329,5 @@ CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
 }
 
 #endif
+
+/*@}*/
index 66d78a74611b6d2d28e8410e48fc9bb94a7ff9ea..e713509662daead52b929eb4545aecbe756f9ba7 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _METISLB_H_
 #define _METISLB_H_
 
@@ -19,10 +24,12 @@ public:
   MetisLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 };
 
 #define WEIGHTED 1
 #define MULTI_CONSTRAINT 2
 
 #endif /* _METISLB_H_ */
+
+/*@}*/
index 328d185660e94895ae069611b75d719fbd6c514c..dcebc68756a6e18abfa38244d209438950782361 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef  WIN32
 #include <unistd.h>
 #endif
@@ -92,7 +97,7 @@ void NborBaseLB::FindNeighbors()
     neighbor_pes = new int[max_neighbors()];
     neighbors(neighbor_pes);
     mig_msgs_expected = num_neighbors();
-    mig_msgs = new NLBMigrateMsg*[num_neighbors()];
+    mig_msgs = new LBMigrateMsg*[num_neighbors()];
   }
 
 }
@@ -235,7 +240,7 @@ void NborBaseLB::ReceiveStats(NLBStatsMsg *m)
   if (stats_msg_count == clients && receive_stats_ready) {
     double strat_start_time = CmiWallTimer();
     receive_stats_ready = 0;
-    NLBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
+    LBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
 
     int i;
 
@@ -253,7 +258,7 @@ void NborBaseLB::ReceiveStats(NLBStatsMsg *m)
     
     // Now, send migrate messages to neighbors
     for(i=1; i < num_neighbors(); i++) {
-      NLBMigrateMsg* m2 = (NLBMigrateMsg*) CkCopyMsg((void**)&migrateMsg);
+      LBMigrateMsg* m2 = (LBMigrateMsg*) CkCopyMsg((void**)&migrateMsg);
       thisProxy [neighbor_pes[i]].ReceiveMigration(m2);
     }
     if (0 < num_neighbors())
@@ -276,7 +281,7 @@ void NborBaseLB::ReceiveStats(NLBStatsMsg *m)
   
 }
 
-void NborBaseLB::ReceiveMigration(NLBMigrateMsg *msg)
+void NborBaseLB::ReceiveMigration(LBMigrateMsg *msg)
 {
   if (neighbor_pes == 0) FindNeighbors();
 
@@ -298,7 +303,7 @@ void NborBaseLB::ReceiveMigration(NLBMigrateMsg *msg)
 
   //  CkPrintf("[%d] in ReceiveMigration %d moves\n",CkMyPe(),msg->n_moves);
   for(int neigh=0; neigh < mig_msgs_received;neigh++) {
-    NLBMigrateMsg* m = mig_msgs[neigh];
+    LBMigrateMsg* m = mig_msgs[neigh];
     for(int i=0; i < m->n_moves; i++) {
       MigrateInfo& move = m->moves[i];
       const int me = CkMyPe();
@@ -336,7 +341,7 @@ void NborBaseLB::ResumeClients()
   theLbdb->ResumeClients();
 }
 
-NLBMigrateMsg* NborBaseLB::Strategy(LDStats* stats,int count)
+LBMigrateMsg* NborBaseLB::Strategy(LDStats* stats,int count)
 {
   for(int j=0; j < count; j++) {
     CkPrintf(
@@ -353,7 +358,7 @@ NLBMigrateMsg* NborBaseLB::Strategy(LDStats* stats,int count)
   myStats.n_comm = 0;
 
   int sizes=0;
-  NLBMigrateMsg* msg = new(&sizes,1) NLBMigrateMsg;
+  LBMigrateMsg* msg = new(&sizes,1) LBMigrateMsg;
   msg->n_moves = 0;
 
   return msg;
@@ -371,34 +376,7 @@ int NborBaseLB::NeighborIndex(int pe)
     return peslot;
 }
 
-void* NLBMigrateMsg::alloc(int msgnum, size_t size, int* array, int priobits)
-{
-  int totalsize = size + array[0] * sizeof(NborBaseLB::MigrateInfo);
-
-  NLBMigrateMsg* ret =
-    (NLBMigrateMsg*)(CkAllocMsg(msgnum,totalsize,priobits));
-
-  ret->moves = (NborBaseLB::MigrateInfo*) ((char*)(ret)+ size);
-
-  return (void*)(ret);
-}
-
-void* NLBMigrateMsg::pack(NLBMigrateMsg* m)
-{
-  m->moves = (NborBaseLB::MigrateInfo*)
-    ((char*)(m->moves) - (char*)(&m->moves));
-
-  return (void*)(m);
-}
-
-NLBMigrateMsg* NLBMigrateMsg::unpack(void *m)
-{
-  NLBMigrateMsg* ret_val = (NLBMigrateMsg*)(m);
-
-  ret_val->moves = (NborBaseLB::MigrateInfo*)
-    ((char*)(&ret_val->moves) + (size_t)(ret_val->moves));
+#endif
 
-  return ret_val;
-}
 
-#endif
+/*@{*/
index 385c4e66e7fcb524b90d5df3ffb534dbbcbf7741..42a7b800342c5f5dcc6ba9e0785e4a38f3bdafae 100644 (file)
@@ -10,13 +10,11 @@ message NLBStatsMsg {
   LDCommData commData[];
 };
 
-message NLBMigrateMsg;
-
 group NborBaseLB: BaseLB {
   entry void NborBaseLB(void);  
   entry void ReceiveStats(NLBStatsMsg*);
   entry void ResumeClients(void);
-  entry void ReceiveMigration(NLBMigrateMsg*); 
+  entry void ReceiveMigration(LBMigrateMsg*);  
 };
 
 };
index ea5fc1485c1ebcdc2026e0a6018279ebb78328a1..1be9e1366fa32ae3c272f952f7ee048920d422d1 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef NBORBASELB_H
 #define NBORBASELB_H
 
@@ -15,8 +20,10 @@ extern CkGroupID nborBaselb;
 
 void CreateNborBaseLB();
 
+/// for backward compatibility
+typedef LBMigrateMsg NLBMigrateMsg;
+
 class NLBStatsMsg;
-class NLBMigrateMsg;
 
 class NborBaseLB : public CBase_NborBaseLB
 {
@@ -29,7 +36,7 @@ public:
 
   void ReceiveStats(NLBStatsMsg *);            // Receive stats on PE 0
   void ResumeClients();
-  void ReceiveMigration(NLBMigrateMsg *);      // Receive migration data
+  void ReceiveMigration(LBMigrateMsg *);       // Receive migration data
 
   // Migrated-element callback
   static void staticMigrated(void* me, LDObjHandle h);
@@ -38,12 +45,6 @@ public:
   void MigrationDone(void);  // Call when migration is complete
   int step() { return mystep; };
 
-  struct MigrateInfo {  // Used in NLBMigrateMsg
-    LDObjHandle obj;
-    int from_pe;
-    int to_pe;
-  };
-
   struct LDStats {  // Passed to Strategy
     int from_pe;
     double total_walltime;
@@ -66,7 +67,7 @@ public:
 protected:
   virtual CmiBool QueryBalanceNow(int) { return CmiTrue; };  
   virtual CmiBool QueryMigrateStep(int) { return CmiTrue; };  
-  virtual NLBMigrateMsg* Strategy(LDStats* stats,int count);
+  virtual LBMigrateMsg* Strategy(LDStats* stats,int count);
 
   virtual int max_neighbors() {
     if (CkNumPes() > 2) return 2;
@@ -113,7 +114,7 @@ private:
   LDStats* statsDataList;
   int migrates_completed;
   int migrates_expected;
-  NLBMigrateMsg** mig_msgs;
+  LBMigrateMsg** mig_msgs;
   int mig_msgs_received;
   int mig_msgs_expected;
   int* neighbor_pes;
@@ -139,16 +140,6 @@ public:
   LDCommData *commData;
 }; 
 
-class NLBMigrateMsg : public CMessage_NLBMigrateMsg {
-public:
-  int n_moves;
-  NborBaseLB::MigrateInfo* moves;
-
-  // Other methods & data members 
-  
-  static void* alloc(int msgnum, size_t size, int* array, int priobits); 
-  static void* pack(NLBMigrateMsg* in); 
-  static NLBMigrateMsg* unpack(void* in); 
-}; 
-
 #endif /* NBORBASELB_H */
+
+/*@}*/
index 3bddf06e30c3acb7ef4cdfc9b0e71e213c79332e..3c81e58747addd7b056da67da7cd7909994c62cf 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -32,7 +37,7 @@ NeighborLB::NeighborLB()
     CkPrintf("[%d] NeighborLB created\n",CkMyPe());
 }
 
-NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
+LBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] Strategy starting\n",CkMyPe());
   // Compute the average load to see if we are overloaded relative
@@ -159,7 +164,7 @@ NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
   //  if (migrate_count > 0) {
   //    CkPrintf("PE %d migrating %d elements\n",CkMyPe(),migrate_count);
   //  }
-  NLBMigrateMsg* msg = new(&migrate_count,1) NLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*) migrateInfo[i];
@@ -172,3 +177,5 @@ NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
 };
 
 #endif
+
+/*@}*/
index 8aa0d2023f576c49513bc46ae57209e0fd600c64..e923555823c30c4d76d6fe004afd3674c3e013d1 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _NEIGHBORLB_H_
 #define _NEIGHBORLB_H_
 
@@ -44,7 +49,9 @@ private:
       _n[3] = (me + npe - bigstep) % npe;
   };
 
-  NLBMigrateMsg* Strategy(NborBaseLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(NborBaseLB::LDStats* stats, int count);
 };
 
 #endif /* _NeighborLB_H_ */
+
+/*@}*/
index 50defcb36a359f5e59460af81208c19470f265a5..66ead70879ad4121176fcafef9ea609c80643c5b 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 #include <BaseLB.h>
 #include "NullLB.h"
@@ -72,3 +77,6 @@ void NullLB::migrationsDone(void) {}
 #endif
 
 #include "NullLB.def.h"
+
+
+/*@}*/
index c6efda7fc56865b9476f6daecafaa3bdbc3acba0..6b44d3bc3bcea9c2a4f615a3816d765a3eba6789 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef __CK_NULLLB_H
 #define __CK_NULLLB_H
 
@@ -33,3 +38,6 @@ public:
 };
 
 #endif /* def(thisHeader) */
+
+
+/*@}*/
index 60cb000006c978b378682d1c747c970b19bfcf45..2459b04f6a8806c4a84e5079c9ace1e0e1ebb70e 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include "ObjGraph.h"
 
 static const double alpha = 30.e-6;
@@ -165,4 +170,4 @@ ObjGraph::Node* ObjGraph::find_node(LDOMid edge_omid, LDObjid edge_id)
 
 
 
-
+/*@}*/
index 51e84939f60b5b26fbb09573171da204ca076a7f..10ddb5770e73d00240f5a22efcb9369c5dd6f7aa 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _OBJGRAPH_H_
 #define _OBJGRAPH_H_
 
@@ -78,3 +83,5 @@ private:
 };
 
 #endif
+
+/*@}*/
index 856e7155a0ef4eea74441e3d6a42fb762a823d1f..7da33423518f2f9f8d5fda6174b9bb63eb6fa8ab 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -38,7 +43,7 @@ CmiBool RandCentLB::QueryBalanceNow(int _step)
   return CmiTrue;
 }
 
-CLBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] RandCentLB strategy\n",CkMyPe());
 
@@ -64,7 +69,7 @@ CLBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
   }
 
   int migrate_count=migrateInfo.length();
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -77,3 +82,6 @@ CLBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
 };
 
 #endif
+
+
+/*@}*/
index b4bff5868c644ab57740acc999e4d1e8544ef1aa..7ebe3024f8c078087387764c1daa260ef1051bcd 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _RANDCENTLB_H_
 #define _RANDCENTLB_H_
 
@@ -19,7 +24,9 @@ public:
   RandCentLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 };
 
 #endif /* _RANDCENTLB_H_ */
+
+/*@}*/
index 1dee339794095f7ccc6b2ceafc8b8c4c23a54513..6864c250180226d9108efc8c3a58ec3c6f6784a0 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -40,7 +45,7 @@ CmiBool RandRefLB::QueryBalanceNow(int _step)
   return CmiTrue;
 }
 
-CLBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] RandRefLB strategy\n",CkMyPe());
 
@@ -74,7 +79,7 @@ CLBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
   }
 
   int migrate_count=migrateInfo.length();
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -90,3 +95,6 @@ CLBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
 };
 
 #endif
+
+
+/*@}*/
index 83a95056b2764976b63083a7ff88d11c8ecb4531..948a8e16b3976030cafcd17d3ac1042369703436 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _RANDREFLB_H_
 #define _RANDREFLB_H_
 
@@ -19,7 +24,10 @@ public:
   RandRefLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 };
 
 #endif /* _RANDCENTLB_H_ */
+
+
+/*@}*/
index ab0100d6e8382402a90c8d06da5e275bba74dda3..ebd2a00b56eb5588a0cf1eb22d8180f1e418c2a4 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -59,7 +64,7 @@ CmiBool RecBisectBfLB::QueryBalanceNow(int _step)
   return CmiTrue;
 }
 
-CLBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats, 
+LBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats, 
                                       int numPartitions)
 {
   int i;
@@ -122,7 +127,7 @@ CLBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats,
   free(partitions);
 
   int migrate_count=migrateInfo.length();
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   CkPrintf("Moving %d elements\n",migrate_count);
   for(i=0; i < migrate_count; i++) {
@@ -339,3 +344,4 @@ void RecBisectBfLB::recursivePartition(int numParts, Graph *g,
 #endif
 
 
+/*@}*/
index 61c02455e3c442231c5a4c249b2a25ed581d21d5..228de11cdb5e04847fa30f7840a3118ef135a672 100644 (file)
@@ -5,6 +5,10 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
 
 #ifndef _RECBISECTBFLB_H_
 #define _RECBISECTBFLB_H_
@@ -40,7 +44,7 @@ public:
   RecBisectBfLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 
   Graph * convertGraph(ObjGraph *og);
   
@@ -63,3 +67,6 @@ private:
 
 
 #endif /* _RECBISECTBFLB_H_ */
+
+
+/*@}*/
index 70613c0dcc7429c1aad9057c7e0f81deaa7590e6..e9b3e6887a1d17e22937b66b5b544eb45a15851b 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <charm++.h>
 
 #if CMK_LBDB_ON
@@ -189,7 +194,7 @@ int RefineLB::refine()
 }
 */
 
-CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
+LBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   int obj, pe;
 
@@ -262,7 +267,7 @@ CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
   }
 
   int migrate_count=migrateInfo.length();
-  CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*)migrateInfo[i];
@@ -279,3 +284,6 @@ CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
 };
 
 #endif
+
+
+/*@}*/
index 662ab81490086c0bb348517e9621d4c8ad9693ff..8b460ee5ee08b6952380412fa4a0d51ae94ed3aa 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _REFINELB_H_
 #define _REFINELB_H_
 
@@ -38,7 +43,7 @@ public:
   RefineLB(CkMigrateMessage *m) {}
 private:
   CmiBool QueryBalanceNow(int step);
-  CLBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
+  LBMigrateMsg* Strategy(CentralLB::LDStats* stats, int count);
 
 protected:
 /*
@@ -53,3 +58,5 @@ protected:
 };
 
 #endif /* _REFINELB_H_ */
+
+/*@}*/
index ad9583ab6f436b4fb3df3662db32a58534bfc059..4e433b1210470a29c0a11bf20f864d1d2e05d458 100644 (file)
@@ -5,8 +5,14 @@
  * $Revision$
  *****************************************************************************/
 
-// This code is derived from RefineLB.C, and RefineLB.C should
-// be rewritten to use this, so there is no code duplication
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
+/** This code is derived from RefineLB.C, and RefineLB.C should
+ be rewritten to use this, so there is no code duplication
+*/
 
 #include "Refiner.h"
 
@@ -299,3 +305,6 @@ void Refiner::Refine(int count, CentralLB::LDStats* stats,
     }
   }
 };
+
+
+/*@}*/
index 3388db4021aa2643d62fb75bcce304bcc4d39216..575c6694176d9a02ea0dc874f74083a2a81d86d4 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _REFINER_H_
 #define _REFINER_H_
 
@@ -49,3 +54,6 @@ private:
 };
 
 #endif /* _REFINER_H_ */
+
+
+/*@}*/
index 09f08b31736730a10c684e27159d072fee34b303..a410fb931c4503c66097f214a6d4563b4ecde1b0 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include "Set.h"
 #include "elements.h"
 #include <iostream.h>
@@ -120,3 +125,6 @@ void Set::print()
     p = p->next;
   }
 }
+
+
+/*@}*/
index 960434f6482191bd49ea7cace003eaddb76604f5..fa532858ff06571c9a80c083981eee31767ed084 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef SET_DEFS_H
 #define SET_DEFS_H
 
@@ -47,3 +52,5 @@ public:
 };
 
 #endif
+
+/*@}*/
index 965f76ffbd124f195f040c1d370fb56111ccdfb7..1c9a01ad79848667dc999668b34581b4d72fc8aa 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef  WIN32
 #include <unistd.h>
 #endif
@@ -103,7 +108,7 @@ void WSLB::FindNeighbors()
     neighbor_pes = new int[num_neighbors()];
     neighbors(neighbor_pes);
     mig_msgs_expected = num_neighbors();
-    mig_msgs = new WSLBMigrateMsg*[num_neighbors()];
+    mig_msgs = new LBMigrateMsg*[num_neighbors()];
   }
 
 }
@@ -260,7 +265,7 @@ void WSLB::ReceiveStats(WSLBStatsMsg *m)
   if (stats_msg_count == clients && receive_stats_ready) {
     double strat_start_time = CmiWallTimer();
     receive_stats_ready = 0;
-    WSLBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
+    LBMigrateMsg* migrateMsg = Strategy(statsDataList,clients);
 
     int i;
 
@@ -296,7 +301,7 @@ void WSLB::ReceiveStats(WSLBStatsMsg *m)
   
 }
 
-void WSLB::ReceiveMigration(WSLBMigrateMsg *msg)
+void WSLB::ReceiveMigration(LBMigrateMsg *msg)
 {
   if (neighbor_pes == 0) FindNeighbors();
 
@@ -318,7 +323,7 @@ void WSLB::ReceiveMigration(WSLBMigrateMsg *msg)
 
   //  CkPrintf("[%d] in ReceiveMigration %d moves\n",CkMyPe(),msg->n_moves);
   for(int neigh=0; neigh < mig_msgs_received;neigh++) {
-    WSLBMigrateMsg* m = mig_msgs[neigh];
+    LBMigrateMsg* m = mig_msgs[neigh];
     for(int i=0; i < m->n_moves; i++) {
       MigrateInfo& move = m->moves[i];
       const int me = CkMyPe();
@@ -376,7 +381,7 @@ CmiBool WSLB::QueryBalanceNow(int step)
   return CmiTrue;
 }
 
-WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
+LBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] Strategy starting\n",CkMyPe());
   // Compute the average load to see if we are overloaded relative
@@ -532,7 +537,7 @@ WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
   //    CkPrintf("PE %d: Sent away %d of %d objects\n",
   //        CkMyPe(),migrate_count,myStats.obj_data_sz);
   //  }
-  WSLBMigrateMsg* msg = new(&migrate_count,1) WSLBMigrateMsg;
+  LBMigrateMsg* msg = new(&migrate_count,1) LBMigrateMsg;
   msg->n_moves = migrate_count;
   for(i=0; i < migrate_count; i++) {
     MigrateInfo* item = (MigrateInfo*) migrateInfo[i];
@@ -544,36 +549,8 @@ WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
   return msg;
 };
 
-void* WSLBMigrateMsg::alloc(int msgnum, size_t size, int* array, int priobits)
-{
-  int totalsize = size + array[0] * sizeof(WSLB::MigrateInfo);
-
-  WSLBMigrateMsg* ret =
-    (WSLBMigrateMsg*)(CkAllocMsg(msgnum,totalsize,priobits));
-
-  ret->moves = (WSLB::MigrateInfo*) ((char*)(ret)+ size);
-
-  return (void*)(ret);
-}
-
-void* WSLBMigrateMsg::pack(WSLBMigrateMsg* m)
-{
-  m->moves = (WSLB::MigrateInfo*)((char*)(m->moves) - (char*)(&m->moves));
-
-  return (void*)(m);
-}
-
-WSLBMigrateMsg* WSLBMigrateMsg::unpack(void *m)
-{
-  WSLBMigrateMsg* ret_val = (WSLBMigrateMsg*)(m);
-
-  ret_val->moves = (WSLB::MigrateInfo*)
-    ((char*)(&ret_val->moves) + (size_t)(ret_val->moves));
-
-  return ret_val;
-}
-
 #include "WSLB.def.h"
 #endif
 
 
+/*@}*/
index c059cf7554b5d1222284fca5bbadfa31e22f9f67..f7f3286cebe35824b3838bb7935f2b3e3e2495dd 100644 (file)
@@ -6,13 +6,12 @@ extern module BaseLB;
 readonly CkGroupID wslb;
 
 message WSLBStatsMsg;
-message WSLBMigrateMsg;
 
 group WSLB: BaseLB {
   entry void WSLB(void);  
   entry void ReceiveStats(WSLBStatsMsg*);
   entry void ResumeClients(void);
-  entry void ReceiveMigration(WSLBMigrateMsg*);        
+  entry void ReceiveMigration(LBMigrateMsg*);  
 };
 
 };
index e55e16e97fec21404e3de1c51ef4f6c0f44fe092..0f910bfc51c91971bf7f3157022048e3e3b71fde 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef NEIGHBORLB_H
 #define NEIGHBORLB_H
 
@@ -14,7 +19,6 @@
 void CreateWSLB();
 
 class WSLBStatsMsg;
-class WSLBMigrateMsg;
 
 class WSLB : public CBase_WSLB
 {
@@ -27,7 +31,7 @@ public:
 
   void ReceiveStats(WSLBStatsMsg *);           // Receive stats on PE 0
   void ResumeClients();
-  void ReceiveMigration(WSLBMigrateMsg *);     // Receive migration data
+  void ReceiveMigration(LBMigrateMsg *);       // Receive migration data
 
   // Migrated-element callback
   static void staticMigrated(void* me, LDObjHandle h);
@@ -36,12 +40,6 @@ public:
   void MigrationDone(void);  // Call when migration is complete
   int step() { return mystep; };
 
-  struct MigrateInfo {  // Used in WSLBMigrateMsg
-    LDObjHandle obj;
-    int from_pe;
-    int to_pe;
-  };
-
   struct LDStats {  // Passed to Strategy
     int from_pe;
     double total_walltime;
@@ -58,7 +56,7 @@ public:
 
 protected:
   virtual CmiBool QueryBalanceNow(int);
-  virtual WSLBMigrateMsg* Strategy(LDStats* stats,int count);
+  virtual LBMigrateMsg* Strategy(LDStats* stats,int count);
   virtual int num_neighbors() {
     return (CkNumPes() > 5) ? 4 : (CkNumPes()-1);
   };
@@ -104,7 +102,7 @@ private:
   LDStats* statsDataList;
   int migrates_completed;
   int migrates_expected;
-  WSLBMigrateMsg** mig_msgs;
+  LBMigrateMsg** mig_msgs;
   int mig_msgs_received;
   int mig_msgs_expected;
   int* neighbor_pes;
@@ -132,16 +130,8 @@ public:
   CmiBool vacate_me;
 }; 
 
-class WSLBMigrateMsg : public CMessage_WSLBMigrateMsg {
-public:
-  int n_moves;
-  WSLB::MigrateInfo* moves;
-
-  // Other methods & data members 
-  
-  static void* alloc(int msgnum, size_t size, int* array, int priobits); 
-  static void* pack(WSLBMigrateMsg* in); 
-  static WSLBMigrateMsg* unpack(void* in); 
-}; 
 
 #endif /* NEIGHBORLB_H */
+
+
+/*@}*/
index 01d42b6b79bb757b4d2e101fe917ce24326946b3..0d3a4382367c319eaa17ef8f1289cbb6cacdde55 100644 (file)
@@ -5,6 +5,12 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
+
 #include <stdio.h>
 #include <stdlib.h>
 #include "bitvecset.h"
@@ -107,3 +113,5 @@ void bvset_enumerate(BV_Set * s, int **list, int *size)
       printf("%d ", (*list)[i]);
   }
 }
+
+/*@}*/
index ebda0741e00c050406697729364b4646a6909f36..cb3c1458683dd340a77feacb02d4c009b5a37e85 100644 (file)
@@ -5,8 +5,13 @@
  * $Revision$
  *****************************************************************************/
 
-#ifndef _BITVECSET_H
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 
+#ifndef _BITVECSET_H
 #define  _BITVECSET_H
 
 typedef struct {
@@ -16,5 +21,6 @@ typedef struct {
 } BV_Set ;
 
 
-
 #endif
+
+/*@}*/
index 0854f9372944239fb9f8192a35ed0f3009dc30f3..4bb62c59842f4dd20ec309917d0ac131fddb01bc 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef ELEMENTS_DEFS_H
 #define ELEMENTS_DEFS_H
 
@@ -57,3 +62,5 @@ public:
 };
 
 #endif
+
+/*@}*/
index 372ee202d3eb063d20be684aef18e26a5bdb7ba8..7d1a44eb40ff62ec0b8952771a86f07e4e056eed 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include "converse.h"
 #include "graph.h"
 #include <stdlib.h>
@@ -167,3 +172,5 @@ float graph_weightof(Graph *g, int vertex) {
   return g->vertices[vertex].weight;
 
 }
+
+/*@}*/
index 29872984be93e34fcc549273170f3611012b7bdb..d9a193158d0bfadcc369fe1bb4d5319c3bda2bd2 100644 (file)
@@ -5,8 +5,12 @@
  * $Revision$
  *****************************************************************************/
 
-#ifndef _GRAPH_H
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
 
+#ifndef _GRAPH_H
 #define _GRAPH_H
 
 typedef struct {
@@ -29,3 +33,5 @@ typedef struct {
 Graph * generateRandomGraph(int numNodex);
 
 #endif
+
+/*@}*/
index 9010dbb975bc0f39782d611f0b975b10fed44fe4..7b551eda726e3b4f45a071e4fc7f62cb742cbb7a 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 class manheap;
 class maxHeap;
 #include "heap.h"
@@ -213,3 +218,5 @@ InfoRecord *maxHeap::next(heapIterator *iter){
   iter->next += 1;
   return h[iter->next - 1].info;
 }
+
+/*@}*/
index 83fbfad755f78847220ced180627cb0df0284a80..cea26665ba60beb45b1169f79946de5dbe930bdb 100644 (file)
 ***  All rights reserved.
 **/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef _HEAP_H_
 #define _HEAP_H_
 
@@ -74,3 +79,5 @@ public:
 
 
 #endif /* _HEAP_H_ */
+
+/*@}*/
index 28f2e8bd04657a3660cfd92e1a7249abc381afb1..e8ed12ab58b741f07b0d21aeb9e1fd2c07ca1bbe 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #include <converse.h>
 
 #if CMK_LBDB_ON
@@ -314,3 +319,5 @@ CmiBool LDObjIDEqual(const LDObjid i1, const LDObjid i2)
 }
 
 #endif // CMK_LBDB_ON
+
+/*@}*/
index fdb8dce335363edfb97522bcfbc5744ec80acd85..f1e0fcb59af0377aadedacd24f612549d3781498 100644 (file)
@@ -5,6 +5,11 @@
  * $Revision$
  *****************************************************************************/
 
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef LBDBH_H
 #define LBDBH_H
 
@@ -191,3 +196,5 @@ CmiBool LDObjIDEqual(const LDObjid i1, const LDObjid i2);
 #endif /* _cplusplus */
 
 #endif /* LBDBH_H */
+
+/*@}*/
index 75ff919f6aaaac1cdfcf21f9a74200c1a3fe8599..ac734f2799be0cea839a354549a83411142beab5 100644 (file)
@@ -1,13 +1,18 @@
-#include "manager.h"
-#include "CentralLB.h"
-#include "converse.h"
-#include "conv-ccs.h"
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
 
-/* Cluster Manager Code, 
+/** Cluster Manager Code, 
    Accpets external bit vectors and then feeds it into the 
    loadbalancer so that programs can shrink and expand. 
 */
 
+#include "manager.h"
+#include "CentralLB.h"
+#include "converse.h"
+#include "conv-ccs.h"
+
 CkGroupID manager_group_id;
 extern int load_balancer_created;
 int group_created;
@@ -31,5 +36,4 @@ void manager_init(){
 
 
 
-
-
+/*@}*/
index 74910dd0dedffbc2b2987c58cc57dff36991415b..d2ffb69fbadd598d4fe6f1405a61d1be0141a511 100644 (file)
@@ -1,7 +1,12 @@
+/**
+ * \addtogroup CkLdb
+*/
+/*@{*/
+
 #ifndef MANAGER_H
 #define MANAGER_H
 
-/* Cluster Manager Code, 
+/** Cluster Manager Code, 
    Accpets external bit vectors and then feeds it into the 
    loadbalancer so that programs can shrink and expand. 
 */
@@ -10,7 +15,7 @@ void manager_init(void);
 
 #endif
 
-
+/*@}*/