Changeset 8497 for trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py

Timestamp:

Aug 7, 2012, 12:22:48 PM (13 years ago)

Author:

steve

Message:

Move over to opl machine

File:

• trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py (modified) (4 diffs)

trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py

@@ -41 +41 @@
     t0 = time.time()
 
-    allreduce = False
+    allreduce = True
     
     if allreduce:
-        #pypar.allreduce(domain.local_timestep, pypar.MIN,
-        #              buffer=domain.global_timestep,
-        #              bypass=True)
+        pypar.allreduce(domain.local_timestep, pypar.MIN,
+                      buffer=domain.global_timestep,
+                      bypass=True)
         domain.communication_reduce_time += time.time()-t0
     else:
@@ -62 +62 @@
         domain.communication_broadcast_time += time.time()-t0
 
-    old_fux_timestep = domain.flux_timestep
+    #old_flux_timestep = domain.flux_timestep
     domain.flux_timestep = domain.global_timestep[0]
     
@@ -93 +93 @@
                         Xout[:,i] = num.take(Q_cv, Idf)
 
-                    pypar.send(Xout, int(send_proc), use_buffer=True)#, bypass=True)
+                    pypar.send(Xout, int(send_proc), use_buffer=True, bypass=True)
 
 
@@ -103 +103 @@
                 X   = domain.ghost_recv_dict[iproc][2]
 
-                X = pypar.receive(int(iproc), buffer=X)#, bypass=True)
+                X = pypar.receive(int(iproc), buffer=X, bypass=True)
 
                 for i, q in enumerate(domain.conserved_quantities):