fix syntax errors
authorGreg Koenig <koenig@uiuc.edu>
Sun, 22 Oct 2006 10:15:16 +0000 (10:15 +0000)
committerGreg Koenig <koenig@uiuc.edu>
Sun, 22 Oct 2006 10:15:16 +0000 (10:15 +0000)
src/arch/vmi/machine.c
src/ck-ldb/GridCommLB.C
src/ck-ldb/GridCommLB.h
src/ck-ldb/GridCommRefineLB.C
src/ck-ldb/GridCommRefineLB.h
src/ck-ldb/GridMetisLB.C

index 33bbd67cfa00615fa5faa2fa740fa815ac5c212b..264c184dd9d15a2413607ef9a46a68d7ff325b08 100644 (file)
@@ -2623,6 +2623,7 @@ void CmiGridQueueRegister (int gid, int nInts, int index1, int index2, int index
 void CmiGridQueueDeregister (int gid, int nInts, int index1, int index2, int index3)
 {
   int i;
+  int j;
 
 
   DEBUG_PRINT ("CmiGridQueueDeregister() called.\n");
@@ -2699,7 +2700,7 @@ int CmiGridQueueLookup (int gid, int nInts, int index1, int index2, int index3)
   key.index2 = index2;
   key.index3 = index3;
 
-  ptr = bsearch (&key, CMI_VMI_Grid_Objects, CMI_VMI_Grid_Objects_Index, sizeof (CMI_VMI_Grid_Objects_T), CMI_VMI_Grid_Objects_Compare);
+  ptr = bsearch (&key, CMI_VMI_Grid_Objects, CMI_VMI_Grid_Objects_Index, sizeof (CMI_VMI_Grid_Object_T), CMI_VMI_Grid_Objects_Compare);
 
   if (ptr != NULL) {
     return (1);
index 3999e1001afd2198a5f43fddae7ce4211cae4d6a..5d501b6044963db06ffcd61ff2fc59c6d712a731 100644 (file)
@@ -159,7 +159,7 @@ void GridCommLB::Initialize_PE_Data (CentralLB::LDStats *stats)
 /**************************************************************************
 **
 */
-int GridMetisLB::Available_PE_Count ()
+int GridCommLB::Available_PE_Count ()
 {
   int available_pe_count;
   int i;
@@ -179,7 +179,7 @@ int GridMetisLB::Available_PE_Count ()
 /**************************************************************************
 **
 */
-int GridMetisLB::Compute_Number_Of_Clusters ()
+int GridCommLB::Compute_Number_Of_Clusters ()
 {
   int max_cluster;
   int i;
@@ -229,6 +229,7 @@ void GridCommLB::Initialize_Object_Data (CentralLB::LDStats *stats)
 void GridCommLB::Examine_InterObject_Messages (CentralLB::LDStats *stats)
 {
   int i;
+  int j;
   LDCommData *com_data;
   int send_object;
   int send_pe;
index f6386eaf488c2f567d669e7561b97eb6227ca458..d6464833cd5f625b1cf96fa87c82dd110ca853d2 100644 (file)
@@ -63,7 +63,7 @@ class GridCommLB : public CentralLB
     void Initialize_Object_Data (CentralLB::LDStats *stats);
     void Examine_InterObject_Messages (CentralLB::LDStats *stats);
     void Map_NonMigratable_Objects_To_PEs ();
-    void Map_Migratable_Objects_To_PEs ();
+    void Map_Migratable_Objects_To_PEs (int cluster);
     int Find_Maximum_WAN_Object (int cluster);
     int Find_Minimum_WAN_PE (int cluster);
     void Assign_Object_To_PE (int target_object, int target_pe);
index cd34c4d62cffbb3b432c47b65b9141e938fb00f5..39bad564f342d15fcd159c3380ca66c501048d7a 100644 (file)
@@ -183,7 +183,51 @@ void GridCommRefineLB::Initialize_PE_Data (CentralLB::LDStats *stats)
 /**************************************************************************
 **
 */
-void GridCommLB::Initialize_Object_Data (CentralLB::LDStats *stats)
+int GridCommRefineLB::Available_PE_Count ()
+{
+  int available_pe_count;
+  int i;
+
+
+  available_pe_count = 0;
+  for (i = 0; i < Num_PEs; i++) {
+    if ((&PE_Data[i])->available) {
+      available_pe_count += 1;
+    }
+  }
+  return (available_pe_count);
+}
+
+
+
+/**************************************************************************
+**
+*/
+int GridCommRefineLB::Compute_Number_Of_Clusters ()
+{
+  int max_cluster;
+  int i;
+
+
+  max_cluster = 0;
+  for (i = 0; i < Num_PEs; i++) {
+    if ((&PE_Data[i])->cluster < 0) {
+      return (-1);
+    }
+
+    if ((&PE_Data[i])->cluster > max_cluster) {
+      max_cluster = (&PE_Data[i])->cluster;
+    }
+  }
+  return (max_cluster + 1);
+}
+
+
+
+/**************************************************************************
+**
+*/
+void GridCommRefineLB::Initialize_Object_Data (CentralLB::LDStats *stats)
 {
   int i;
 
@@ -209,9 +253,10 @@ void GridCommLB::Initialize_Object_Data (CentralLB::LDStats *stats)
 /**************************************************************************
 **
 */
-void GridCommLB::Examine_InterObject_Messages (CentralLB::LDStats *stats)
+void GridCommRefineLB::Examine_InterObject_Messages (CentralLB::LDStats *stats)
 {
   int i;
+  int j;
   LDCommData *com_data;
   int send_object;
   int send_pe;
@@ -312,7 +357,7 @@ void GridCommRefineLB::Remap_Objects_To_PEs (int cluster)
   for (i = 0; i < Num_PEs; i++) {
     if (cluster == (&PE_Data[i])->cluster) {
       num_cluster_pes += 1;
-      num_wan_msgs += (&PE_Data[j])->num_wan_msgs;
+      num_wan_msgs += (&PE_Data[i])->num_wan_msgs;
     }
   }
   avg_wan_msgs = num_wan_msgs / num_cluster_pes;
@@ -571,7 +616,7 @@ void GridCommRefineLB::work (CentralLB::LDStats *stats, int count)
   // If at least one available PE does not exist, return from load balancing.
   if (Available_PE_Count() < 1) {
     if (_lb_args.debug() > 0) {
-      CkPrintf ("[%d] GridCommLB finds no available PEs -- no balancing done.\n", CkMyPe());
+      CkPrintf ("[%d] GridCommRefineLB finds no available PEs -- no balancing done.\n", CkMyPe());
     }
 
     delete [] PE_Data;
@@ -584,7 +629,7 @@ void GridCommRefineLB::work (CentralLB::LDStats *stats, int count)
   Num_Clusters = Compute_Number_Of_Clusters ();
   if (Num_Clusters < 1) {
     if (_lb_args.debug() > 0) {
-      CkPrintf ("[%d] GridCommLB finds incomplete PE cluster map -- no balancing done.\n", CkMyPe());
+      CkPrintf ("[%d] GridCommRefineLB finds incomplete PE cluster map -- no balancing done.\n", CkMyPe());
     }
 
     delete [] PE_Data;
@@ -593,7 +638,7 @@ void GridCommRefineLB::work (CentralLB::LDStats *stats, int count)
   }
 
   if (_lb_args.debug() > 0) {
-    CkPrintf ("[%d] GridCommLB finds %d clusters.\n", CkMyPe(), Num_Clusters);
+    CkPrintf ("[%d] GridCommRefineLB finds %d clusters.\n", CkMyPe(), Num_Clusters);
   }
 
   // Initialize the Object_Data[] data structure.
index dbcc2870c88f5b4621e0fec422704232bd6936ca..639853b95ddd6f2a743426020c86b2ba4d63aab0 100644 (file)
@@ -60,6 +60,8 @@ class GridCommRefineLB : public CentralLB
   private:
     int Get_Cluster (int pe);
     void Initialize_PE_Data (CentralLB::LDStats *stats);
+    int Available_PE_Count ();
+    int Compute_Number_Of_Clusters ();
     void Initialize_Object_Data (CentralLB::LDStats *stats);
     void Examine_InterObject_Messages (CentralLB::LDStats *stats);
     void Place_Objects_On_PEs ();
index bb260a554b9f6fabe7542c1164fa6812a2ce36dc..930be20bd28798b0b571dd9c668ea58ddbb82735 100644 (file)
@@ -539,7 +539,7 @@ void GridMetisLB::Partition_ClusterObjects_Into_PEs (CentralLB::LDStats *stats,
     while (((!(&PE_Data[pe])->available) || ((&PE_Data[pe])->cluster != cluster)) && (pe < Num_PEs)) {
       pe += 1;
     }
-    if (pe >= Num_PEs) {
+    if (pe > Num_PEs) {
       CmiAbort ("GridMetisLB: Error computing partition to PE map!\n");
     }
   }
@@ -664,7 +664,7 @@ void GridMetisLB::Partition_ClusterObjects_Into_PEs (CentralLB::LDStats *stats,
   options[0] = 0;
   newmap = new int[num_migratable_cluster_objects];
 
-  CmiPrintf ("[%d] GridMetisLB partitioning %d objects in cluster %d into %d partitions\n", CmiMyPe(), num_migratable_cluster_objects, cluster, num_partitions);
+  CmiPrintf ("[%d] GridMetisLB is partitioning %d objects in cluster %d into %d partitions.\n", CmiMyPe(), num_migratable_cluster_objects, cluster, num_partitions);
 
   METIS_PartGraphRecursive (&num_migratable_cluster_objects, xadj, adjncy, vertex_weights, edge_weights, &weight_flag, &numbering_flag, &num_partitions, options, &edgecut, newmap);