[Yt-svn] yt-commit r729 - branches/parallel_profiles/yt/lagos

[mturk at wrangler.dreamhost.com]

Author: mturk
Date: Sat Aug  9 15:03:29 2008
New Revision: 729
URL: http://yt.spacepope.org/changeset/729

Log:
Oops, a couple fixes to the profiles.



Modified:
   branches/parallel_profiles/yt/lagos/ParallelTools.py
   branches/parallel_profiles/yt/lagos/Profiles.py

Modified: branches/parallel_profiles/yt/lagos/ParallelTools.py
==============================================================================
--- branches/parallel_profiles/yt/lagos/ParallelTools.py	(original)
+++ branches/parallel_profiles/yt/lagos/ParallelTools.py	Sat Aug  9 15:03:29 2008
@@ -67,6 +67,8 @@
         if self.pos < len(self._grids):
             self.pos += 1
             return self._grids[self.pos - 1]
+        # This next line is debatable.
+        MPI.COMM_WORLD.Barrier()
         raise StopIteration
 
 class ParallelGridIterator(GridIterator):

Modified: branches/parallel_profiles/yt/lagos/Profiles.py
==============================================================================
--- branches/parallel_profiles/yt/lagos/Profiles.py	(original)
+++ branches/parallel_profiles/yt/lagos/Profiles.py	Sat Aug  9 15:03:29 2008
@@ -57,7 +57,7 @@
 
     def _get_dependencies(self, fields):
         return ParallelAnalysisInterface._get_dependencies(
-                    fields + self._get_bin_fields())
+                    self, fields + self._get_bin_fields())
 
     def _initialize_parallel(self, fields):
         if hasattr(self._data_source.hierarchy, 'queue'):
@@ -99,9 +99,9 @@
 
     def _finalize_parallel(self):
         for key in self.__data:
-            self.__data[key] = self._mpi_gather(self.__data[key])
+            self.__data[key] = self._mpi_allsum(self.__data[key])
         for key in self.__weight_data:
-            self.__weight_data[key] = self._mpi_gather(self.__weight_data[key])
+            self.__weight_data[key] = self._mpi_allsum(self.__weight_data[key])
         self.__used = self._mpi_allsum(self.__used)
 
     def _unlazy_add_fields(self, fields, weight, accumulation):