[Yt-svn] commit/yt: MatthewTurk: Commenting out a few barriers that are preceded by or follow immediately after

[Bitbucket]

1 new changeset in yt:

http://bitbucket.org/yt_analysis/yt/changeset/789c54e13ffd/
changeset:   r3815:789c54e13ffd
branch:      yt
user:        MatthewTurk
date:        2011-03-11 20:56:16
summary:     Commenting out a few barriers that are preceded by or follow immediately after
a collective operation.
affected #:  1 file (6 bytes)

--- a/yt/utilities/parallel_tools/parallel_analysis_interface.py	Fri Mar 11 11:29:48 2011 -0800
+++ b/yt/utilities/parallel_tools/parallel_analysis_interface.py	Fri Mar 11 13:56:16 2011 -0600
@@ -152,7 +152,7 @@
             retval = func(self, *args, **kwargs)
             self._processing = False
         retval = MPI.COMM_WORLD.bcast(retval, root=self._owner)
-        MPI.COMM_WORLD.Barrier()
+        #MPI.COMM_WORLD.Barrier()
         return retval
     return single_proc_results
 
@@ -235,7 +235,7 @@
                 all_clear = 0
         else:
             all_clear = None
-        MPI.COMM_WORLD.Barrier()
+        #MPI.COMM_WORLD.Barrier()
         all_clear = MPI.COMM_WORLD.bcast(all_clear, root=0)
         if not all_clear: raise RuntimeError
     if parallel_capable: return root_only
@@ -632,14 +632,14 @@
 
     @parallel_passthrough
     def _mpi_joindict(self, data):
-        self._barrier()
+        #self._barrier()
         if MPI.COMM_WORLD.rank == 0:
             for i in range(1,MPI.COMM_WORLD.size):
                 data.update(MPI.COMM_WORLD.recv(source=i, tag=0))
         else:
             MPI.COMM_WORLD.send(data, dest=0, tag=0)
         data = MPI.COMM_WORLD.bcast(data, root=0)
-        self._barrier()
+        #self._barrier()
         return data
 
     @parallel_passthrough
@@ -1081,7 +1081,7 @@
 
     @parallel_passthrough
     def _mpi_bcast_pickled(self, data):
-        self._barrier()
+        #self._barrier()
         data = MPI.COMM_WORLD.bcast(data, root=0)
         return data
 
@@ -1115,7 +1115,7 @@
 
     @parallel_passthrough
     def _mpi_allsum(self, data):
-        self._barrier()
+        #self._barrier()
         # We use old-school pickling here on the assumption the arrays are
         # relatively small ( < 1e7 elements )
         if isinstance(data, na.ndarray) and data.dtype != na.bool:

Repository URL: https://bitbucket.org/yt_analysis/yt/

--

This is a commit notification from bitbucket.org. You are receiving
this because you have the service enabled, addressing the recipient of
this email.