Moved List related data structures into cklists.h in util.
authorMilind Bhandarkar <milind@cs.uiuc.edu>
Sun, 17 Dec 2000 07:39:19 +0000 (07:39 +0000)
committerMilind Bhandarkar <milind@cs.uiuc.edu>
Sun, 17 Dec 2000 07:39:19 +0000 (07:39 +0000)
16 files changed:
src/ck-core/charm++.h
src/ck-ldb/CkLists.h [deleted file]
src/ck-ldb/Comm1LB.C
src/ck-ldb/CommLB.C
src/ck-ldb/GreedyRefLB.C
src/ck-ldb/HeapCentLB.C
src/ck-ldb/LBDBManager.C
src/ck-ldb/LBDBManager.h
src/ck-ldb/MetisLB.C
src/ck-ldb/NeighborLB.C
src/ck-ldb/RandCentLB.C
src/ck-ldb/RandRefLB.C
src/ck-ldb/RecBisectBfLB.C
src/ck-ldb/RefineLB.C
src/ck-ldb/WSLB.C
src/scripts/Makefile

index 61be68b6c2d1176b77fbeebfd128778d511ff558..e16a0ef02bdceb566279d3fc99db88693b10b77c 100644 (file)
@@ -135,75 +135,7 @@ static inline void _CHECK_CID(CkChareID cid, int idx)
 static inline void _CHECK_CID(CkChareID, int){}
 #endif
 
-/* These came from init.h-- OSL, 3/20/2000 */
-
-template <class T>
-class CkQ {
-    T *block;
-    int blklen;
-    int first;
-    int len;
-  public:
-    CkQ() :first(0),len(0) {
-      block = new T[blklen=16];
-    }
-    ~CkQ() { delete[] block; }
-    int length(void) { return len; }
-    T deq(void) {
-      if(len>0) {
-        T &ret = block[first];
-        first = (first+1)%blklen;
-        len--;
-       return ret;
-      } else return T(0);
-    }
-    void enq(const T &elt) {
-      if(len==blklen) {
-       int newlen=len*2;
-        T *newblk = new T[newlen];
-        memcpy(newblk, block+first, sizeof(T)*(blklen-first));
-        memcpy(newblk+blklen-first, block, sizeof(T)*first);
-        delete[] block; block = newblk;
-        blklen = newlen; first = 0;
-      }
-      block[(first+len)%blklen] = elt;
-      len++;
-    }
-    //Peek at the n'th item from the queue
-    T& operator[](size_t n) 
-    {
-       n=(n+first)%blklen;
-       return block[n];
-    }
-};
-
-template <class T>
-class CkVec {
-    T *block;
-    int blklen,len;
-  public:
-    CkVec() {block=NULL;blklen=len=0;}
-    ~CkVec() { delete[] block; }
-    int &length(void) { return len; }
-    T *getVec(void) { return block; }
-    T& operator[](size_t n) { return block[n]; }
-    const T& operator[](size_t n) const { return block[n]; }
-    void insert(int pos, const T &elt) {
-      if(pos>=blklen) {
-       int newlen=pos*2+16;//Double length at each step
-        T *newblk = new T[newlen];
-        if (block!=NULL)
-               memcpy(newblk, block, sizeof(T)*blklen);
-        for(int i=blklen; i<newlen; i++) newblk[i] = T(0);
-        delete[] block; block = newblk;
-        blklen = newlen;
-      }
-      if (pos>=len) len=pos+1;
-      block[pos] = elt;
-    }
-    void insertAtEnd(const T &elt) {insert(length(),elt);}
-};
-
+#include "cklists.h"
 
 #include "ckarray.h"
 #include "ckstream.h"
diff --git a/src/ck-ldb/CkLists.h b/src/ck-ldb/CkLists.h
deleted file mode 100644 (file)
index 8e94ce9..0000000
+++ /dev/null
@@ -1,47 +0,0 @@
-/*****************************************************************************
- * $Source$
- * $Author$
- * $Date$
- * $Revision$
- *****************************************************************************/
-
-#ifndef _CKLISTS_H_
-#define _CKLISTS_H_
-
-#ifndef  WIN32
-#include <unistd.h>
-#endif
-
-class CkVector {
-public:
-  CkVector() { items = new void*[blk_sz]; in_use = 0; cur_sz = blk_sz; };
-  CkVector(size_t n) { items = new void*[n]; in_use = 0; cur_sz = n;  };
-  ~CkVector() { if (items) delete [] items; }
-
-  void*& operator[](size_t n) { return items[n]; };
-
-  void push_back(void* item) {
-    if (cur_sz == in_use) grow_list();
-    items[in_use] = item;
-    in_use++;
-  };
-
-  size_t size() { return in_use; };
-
-private:
-  void grow_list() {
-    void** old_items = items;
-    cur_sz *= 2;
-    items = new void*[cur_sz];
-    for(int i=0; i < in_use; i++)
-      items[i] = old_items[i];
-    delete [] old_items;
-  };
-    
-  enum { blk_sz = 1000 };               
-  void** items;
-  int in_use;
-  int cur_sz;
-};
-
-#endif
index a3b5055e1855e8fb6a37d5da0f24977235f8811c..6e9e4dbc658c4837b9b85e365669aa772998d64c 100644 (file)
@@ -10,7 +10,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "Comm1LB.h"
 #include "Comm1LB.def.h"
@@ -170,7 +170,7 @@ CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
 
   //  CkPrintf("[%d] Comm1LB strategy\n",CkMyPe());
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   alloc_array = new alloc_struct *[count+1];
 
@@ -249,7 +249,7 @@ CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
     migrateMe->obj = stats[spe].objData[mpos].handle;
     migrateMe->from_pe = spe;
     migrateMe->to_pe = pe;
-    migrateInfo.push_back((void *)migrateMe);
+    migrateInfo.insertAtEnd(migrateMe);
   }
 
   int out_msg,out_byte,min_msg,min_byte;
@@ -291,11 +291,11 @@ CLBMigrateMsg* Comm1LB::Strategy(CentralLB::LDStats* stats, int count)
       migrateMe->obj = stats[spe].objData[mpos].handle;
       migrateMe->from_pe = spe;
       migrateMe->to_pe = minpe;
-      migrateInfo.push_back((void *)migrateMe);
+      migrateInfo.insertAtEnd(migrateMe);
     }
   }
 
-  int migrate_count = migrateInfo.size();
+  int migrate_count = migrateInfo.length();
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
index 196c57f5e6d39016d565f9cdd70ec7f2f6ad50f7..3532b2dcb7c48f7450cc9240614602c1ed76f2b9 100644 (file)
@@ -10,7 +10,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "CommLB.h"
 #include "CommLB.def.h"
@@ -142,7 +142,7 @@ CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
     
     //  CkPrintf("[%d] CommLB strategy\n",CkMyPe());
     
-    CkVector migrateInfo;
+    CkVec<MigrateInfo*> migrateInfo;
     
     alloc_array = new double *[count+1];
     
@@ -227,7 +227,7 @@ CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
        migrateMe->obj = stats[spe].objData[mpos].handle;
        migrateMe->from_pe = spe;
        migrateMe->to_pe = pe;
-       migrateInfo.push_back((void *)migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
     }
     
     
@@ -266,11 +266,11 @@ CLBMigrateMsg* CommLB::Strategy(CentralLB::LDStats* stats, int count)
            migrateMe->obj = stats[spe].objData[mpos].handle;
            migrateMe->from_pe = spe;
            migrateMe->to_pe = minpe;
-           migrateInfo.push_back((void *)migrateMe);
+           migrateInfo.insertAtEnd(migrateMe);
        }
     }
     
-    int migrate_count = migrateInfo.size();
+    int migrate_count = migrateInfo.length();
     CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
     msg->n_moves = migrate_count;
     for(int i=0; i < migrate_count; i++) {
index 250afc1c0f9e7ca237f6297b66807205f16aab4a..db699c627ddb7dd1aebc6edee7e7d42f428ebbe2 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 #include "GreedyRefLB.h"
 #include "GreedyRefLB.def.h"
 
@@ -154,7 +154,7 @@ GreedyRefLB::BuildCpuArray(CentralLB::LDStats* stats, int count, int *peCount)
 
 CLBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
 {
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
   int      pe, obj, heapSize, objCount;
   HeapData *cpuData = BuildCpuArray(stats, count, &heapSize);
   HeapData *objData = BuildObjectArray(stats, count, &objCount);
@@ -241,12 +241,12 @@ CLBMigrateMsg* GreedyRefLB::Strategy(CentralLB::LDStats* stats, int count)
   migrateMe->obj = stats[pe].objData[obj].handle;
   migrateMe->from_pe = pe;
   migrateMe->to_pe = to_procs[pe][obj];
-  migrateInfo.push_back((void*)migrateMe);
+  migrateInfo.insertAtEnd(migrateMe);
       }
     }
   }
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CkPrintf("GreedyRefLB migrating %d elements\n",migrate_count);
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
index 4e89bd5877e612d4674c570be5eba8174af1d05e..934a14393c11b0674ac42f6062bde7a92c0366c2 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 #include "HeapCentLB.h"
 #include "HeapCentLB.def.h"
 
@@ -157,7 +157,7 @@ HeapCentLB::BuildCpuArray(CentralLB::LDStats* stats,
 
 CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
 {
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
   int      obj, heapSize, objCount;
   HeapData *cpuData = BuildCpuArray(stats, count, &heapSize);
   HeapData *objData = BuildObjectArray(stats, count, &objCount);
@@ -189,7 +189,7 @@ CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
       migrateMe->obj = stats[pe].objData[id].handle;
       migrateMe->from_pe = pe;
       migrateMe->to_pe = dest;
-      migrateInfo.push_back((void*)migrateMe);
+      migrateInfo.insertAtEnd(migrateMe);
     }
 
     //Insert the least loaded processor with load updated back into the heap
@@ -202,7 +202,7 @@ CLBMigrateMsg* HeapCentLB::Strategy(CentralLB::LDStats* stats, int count)
     cpuData[location] = minCpu;
   }
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CkPrintf("HeapCentLB migrating %d elements\n",migrate_count);
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
index e053143ef981cf617b4f2572c9d146795e845331..89db1a95e03c447accaddf3132d173cbe8dcb992 100644 (file)
@@ -29,8 +29,8 @@ LDOMHandle LBDB::AddOM(LDOMid _userID, void* _userData,
 
   LBOM* om = new LBOM(this,_userID,_userData,_callbacks);
   if (om != NULL) {
-    newhandle.handle = oms.size();
-    oms.push_back(om);
+    newhandle.handle = oms.length();
+    oms.insertAtEnd(om);
   } else newhandle.handle = -1;
   om->DepositHandle(newhandle);
   omCount++;
@@ -48,8 +48,8 @@ LDObjHandle LBDB::AddObj(LDOMHandle _h, LDObjid _id,
   
   LBObj *obj = new LBObj(this,_h,_id,_userData,_migratable);
   if (obj != NULL) {
-    newhandle.handle = objs.size();
-    objs.push_back(obj);
+    newhandle.handle = objs.length();
+    objs.insertAtEnd(obj);
   } else {
     newhandle.handle = -1;
   }
@@ -136,7 +136,7 @@ int LBDB::ObjDataCount()
 
 void LBDB::GetObjData(LDObjData *dp)
 {
-  for(int i = 0; i < objs.size(); i++) {
+  for(int i = 0; i < objs.length(); i++) {
     LBObj* obj = (LBObj*) objs[i];
     if ( obj->registered )
       *dp++ = obj->ObjData();
@@ -162,7 +162,7 @@ void LBDB::Migrated(LDObjHandle h)
 {
   // Object migrated, inform load balancers
 
-  for(int i=0; i < migrateCBList.size(); i++) {
+  for(int i=0; i < migrateCBList.length(); i++) {
     MigrateCB* cb = (MigrateCB*)migrateCBList[i];
     (cb->fn)(cb->data,h);
   }
@@ -176,7 +176,7 @@ void LBDB::NotifyMigrated(LDMigratedFn fn, void* data)
 
   callbk->fn = fn;
   callbk->data = data;
-  migrateCBList.push_back((void*)callbk);
+  migrateCBList.insertAtEnd((void*)callbk);
 }
 
 void LBDB::BackgroundLoad(double* walltime, double* cputime)
@@ -209,7 +209,7 @@ LDBarrierClient LocalBarrier::AddClient(LDResumeFn fn, void* data)
 
   LDBarrierClient ret_val;
   ret_val.serial = max_client;
-  clients.push_back((void*)new_client);
+  clients.insertAtEnd((void*)new_client);
   max_client++;
 
   client_count++;
@@ -235,7 +235,7 @@ LDBarrierReceiver LocalBarrier::AddReceiver(LDBarrierFn fn, void* data)
 
   LDBarrierReceiver ret_val;
   ret_val.serial = max_receiver;
-  receivers.push_back(new_receiver);
+  receivers.insertAtEnd(new_receiver);
   max_receiver++;
 
   return ret_val;
index 46af9ce455ced27d5d118ba1d143eaf116404c4b..0bd62108f041bbedb4364a081b694ebe631bdeb0 100644 (file)
@@ -10,7 +10,7 @@
 
 #include "converse.h"
 #include "lbdb.h"
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "LBObj.h"
 #include "LBOM.h"
@@ -47,8 +47,8 @@ private:
     LDBarrierFn fn;
   };
 
-  CkVector clients;
-  CkVector receivers;
+  CkVec<void*> clients;
+  CkVec<void*> receivers;
 
   int cur_refcount;
   int max_client;
@@ -148,9 +148,9 @@ private:
     void* data;
   };
 
-  typedef CkVector OMList;
-  typedef CkVector ObjList;
-  typedef CkVector MigrateCBList;
+  typedef CkVec<void*> OMList;
+  typedef CkVec<void*> ObjList;
+  typedef CkVec<void*> MigrateCBList;
 
   LBCommTable* commTable;
   OMList oms;
index 65c4cccd5af31fd15bbf1bd5b5b798d0067b58bb..b926900b41673a551b767d052d65cfe9c8ca0b48 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "MetisLB.h"
 #include "MetisLB.def.h"
@@ -99,7 +99,7 @@ CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   // CkPrintf("entering MetisLB::Strategy...\n");
   // CkPrintf("[%d] MetisLB strategy\n",CkMyPe());
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   int i, j, m;
   int option = 0;
@@ -294,7 +294,7 @@ CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
        migrateMe->obj = handles[i];
        migrateMe->from_pe = origmap[i];
        migrateMe->to_pe = newmap[i];
-       migrateInfo.push_back(migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
       }
     }
   }
@@ -303,7 +303,7 @@ CLBMigrateMsg* MetisLB::Strategy(CentralLB::LDStats* stats, int count)
   if(newmap != origmap)
     delete[] newmap;
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   //  CkPrintf("Migration Count = %d\n", migrate_count);
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
index 2f0512d6fcba4c9478f90f83ded5bfc7713e7f7d..4f3dd3794d56d3de037fab8eadf5ae3492db85de 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "heap.h"
 #include "NeighborLB.h"
@@ -46,7 +46,7 @@ NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
   }
   avgload /= (count+1);
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   if (myload > avgload) {
     //    CkPrintf("[%d] OVERLOAD My load is %f, average load is %f\n",
@@ -123,7 +123,7 @@ NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
       migrateMe->obj = myStats.objData[obj->Id].handle;
       migrateMe->from_pe = me;
       migrateMe->to_pe = p->Id;
-      migrateInfo.push_back((void*)migrateMe);
+      migrateInfo.insertAtEnd(migrateMe);
 
       objs_here--;
       
@@ -149,7 +149,7 @@ NLBMigrateMsg* NeighborLB::Strategy(NborBaseLB::LDStats* stats, int count)
   }  
 
   // Now build the message to actually perform the migrations
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   //  if (migrate_count > 0) {
   //    CkPrintf("PE %d migrating %d elements\n",CkMyPe(),migrate_count);
   //  }
index 288359355600ef4964074dd7b57579cd28339cbd..379e97c8fb80f7a06aab332c36b28566552d06ba 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "RandCentLB.h"
 #include "RandCentLB.def.h"
@@ -37,7 +37,7 @@ CLBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] RandCentLB strategy\n",CkMyPe());
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   for(int pe=0; pe < count; pe++) {
     //    CkPrintf("[%d] PE %d : %d Objects : %d Communication\n",
@@ -52,13 +52,13 @@ CLBMigrateMsg* RandCentLB::Strategy(CentralLB::LDStats* stats, int count)
          migrateMe->obj = stats[pe].objData[obj].handle;
          migrateMe->from_pe = pe;
          migrateMe->to_pe = dest;
-         migrateInfo.push_back((void*)migrateMe);
+         migrateInfo.insertAtEnd(migrateMe);
        }
       }
     }
   }
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
index 8c5396b5be26e9be8268d512feeb338ce6d9e712..dcfd9efba9a6d4f64c75e470169a21064ed48bd9 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 #include "Refiner.h"
 
 #include "RandRefLB.h"
@@ -38,7 +38,7 @@ CLBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
 {
   //  CkPrintf("[%d] RandRefLB strategy\n",CkMyPe());
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   int** from_procs = Refiner::AllocProcs(count,stats);
   int pe;
@@ -62,12 +62,12 @@ CLBMigrateMsg* RandRefLB::Strategy(CentralLB::LDStats* stats, int count)
        migrateMe->obj = stats[pe].objData[obj].handle;
        migrateMe->from_pe = pe;
        migrateMe->to_pe = to_procs[pe][obj];
-       migrateInfo.push_back((void*)migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
       }
     }
   }
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
index 326f44b6ce66e96865e5705e44164c4df2b2e547..5695c58a40b11d80b35a17881e8725af8da97e6b 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 
 #include "RecBisectBfLB.h"
@@ -100,7 +100,7 @@ CLBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats,
   
   //  printPartitions(partitions);
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   for (i=0; i<partitions->max; i++) {
     //    CmiPrintf("[%d] (%d) : \t", i, partitions->partitions[i].size);
@@ -118,7 +118,7 @@ CLBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats,
        migrateMe->obj = stats[n.proc].objData[n.index].handle;
        migrateMe->from_pe = n.proc;
        migrateMe->to_pe = i;
-       migrateInfo.push_back((void*)migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
       }
     }
     free(partitions->partitions[i].nodeArray);
@@ -126,7 +126,7 @@ CLBMigrateMsg* RecBisectBfLB::Strategy(CentralLB::LDStats* stats,
   free(partitions->partitions);
   free(partitions);
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
   CkPrintf("Moving %d elements\n",migrate_count);
index 6ef9f266389efdd9ecd57e313175cc3f8337d4f1..d088ff981c18a31da999431e6759e13a1b5f0bea 100644 (file)
@@ -9,7 +9,7 @@
 
 #if CMK_LBDB_ON
 
-#include "CkLists.h"
+#include "cklists.h"
 
 #include "RefineLB.h"
 #include "RefineLB.def.h"
@@ -216,7 +216,7 @@ CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
 
   refiner.Refine(count,stats,from_procs,to_procs);
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
 /*
   for (int pe=0; pe < P; pe++) {
@@ -231,7 +231,7 @@ CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
        migrateMe->obj = c->handle;
        migrateMe->from_pe = c->oldProcessor;
        migrateMe->to_pe = c->processor;
-       migrateInfo.push_back((void*)migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
       }
       nextCompute.id++;
       c = (computeInfo *) processors[pe].computeSet->
@@ -250,12 +250,12 @@ CLBMigrateMsg* RefineLB::Strategy(CentralLB::LDStats* stats, int count)
        migrateMe->obj = stats[pe].objData[obj].handle;
        migrateMe->from_pe = pe;
        migrateMe->to_pe = to_procs[pe][obj];
-       migrateInfo.push_back((void*)migrateMe);
+       migrateInfo.insertAtEnd(migrateMe);
       }
     }
   }
 
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   CLBMigrateMsg* msg = new(&migrate_count,1) CLBMigrateMsg;
   msg->n_moves = migrate_count;
   for(int i=0; i < migrate_count; i++) {
index 08c44fb4bb26272493380591b0a4cfb47ef825a4..177fd852a00c63e5232e2640b1889dda16d54cda 100644 (file)
@@ -10,7 +10,7 @@
 #endif
 #include <charm++.h>
 #include <LBDatabase.h>
-#include <CkLists.h>
+#include <cklists.h>
 #include "heap.h"
 #include "WSLB.h"
 #include "WSLB.def.h"
@@ -424,7 +424,7 @@ WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
 
   avgload /= (unvacated_neighbors+1);
 
-  CkVector migrateInfo;
+  CkVec<MigrateInfo*> migrateInfo;
 
   // If we want to vacate, we always dump our load, otherwise
   // only if we are overloaded
@@ -512,7 +512,7 @@ WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
       migrateMe->obj = myStats.objData[obj->Id].handle;
       migrateMe->from_pe = me;
       migrateMe->to_pe = p->Id;
-      migrateInfo.push_back((void*)migrateMe);
+      migrateInfo.insertAtEnd(migrateMe);
 
       objs_here--;
       
@@ -537,7 +537,7 @@ WSLBMigrateMsg* WSLB::Strategy(WSLB::LDStats* stats, int count)
   }  
 
   // Now build the message to actually perform the migrations
-  int migrate_count=migrateInfo.size();
+  int migrate_count=migrateInfo.length();
   //  if (migrate_count) {
   //    CkPrintf("PE %d: Sent away %d of %d objects\n",
   //        CkMyPe(),migrate_count,myStats.obj_data_sz);
index 7f70d6fb07618356d6120927a3c5fa9f2323de49..ca7c85ff9fc9dc6c062d2d696d2738e810dd5933 100644 (file)
@@ -101,7 +101,7 @@ CVHEADERS=cpthreads.h converse.h conv-mach.h conv-mach.sh \
 
 # The .c files are there to be #included by clients whole
 # This is a bit unusual, but makes client linking simpler.
-UTILHEADERS=pup.h pup_c.h ckhashtable.h \
+UTILHEADERS=pup.h pup_c.h ckhashtable.h cklists.h \
        sockRoutines.h sockRoutines.c
 
 CKHEADERS=ck.h ckstream.h envelope.h init.h qd.h charm.h charm++.h \
@@ -112,7 +112,7 @@ CKHEADERS=ck.h ckstream.h envelope.h init.h qd.h charm.h charm++.h \
          CentralLB.h RandCentLB.h RecBisectBfLB.h \
          RefineLB.h HeapCentLB.h CommLB.h Comm1LB.h \
          MetisLB.h NborBaseLB.h \
-         NeighborLB.h WSLB.h GreedyRefLB.h RandRefLB.h CkLists.h \
+         NeighborLB.h WSLB.h GreedyRefLB.h RandRefLB.h \
       ampi.h ampif.h BlueGene.h \
          $(CVHEADERS)