Changeset 2976

Timestamp:

07/02/09 16:47:34 (4 months ago)

Author:

kraftche

Message:

limit size of bcasts to 258 MB

Files:

• MOAB/trunk/parallel/MBParallelComm.cpp (modified) (2 diffs)

MOAB/trunk/parallel/MBParallelComm.cpp

@@ -42 +42 @@
 #endif
 
-#define INITIAL_BUFF_SIZE 1024
+const int INITIAL_BUFF_SIZE = 1024;
+const int MAX_BCAST_SIZE = (1<<28);
 
 //#define DEBUG_PACKING 1
@@ -592 +593 @@
     buff.resize(buff_size);
 
-  success = MPI_Bcast( &buff[0], buff_size, MPI_UNSIGNED_CHAR, from_proc, procConfig.proc_comm() );
-  if (MPI_SUCCESS != success) {
-    result = MB_FAILURE;
-    RRA("MPI_Bcast of buffer failed.");
+  size_t offset = 0;
+  while (buff_size) {
+    int size = std::min( buff_size, MAX_BCAST_SIZE );
+    success = MPI_Bcast( &buff[offset], size, MPI_UNSIGNED_CHAR, from_proc, procConfig.proc_comm() );
+    if (MPI_SUCCESS != success) {
+      result = MB_FAILURE;
+      RRA("MPI_Bcast of buffer failed.");
+    }
+    
+    offset += size;
+    buff_size -= size;
   }