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

Timestamp:

Aug 5, 2012, 2:52:18 PM (13 years ago)

Author:

steve

Message:

Adding a simple geometry for parallel tests

File:

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

trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py

@@ -43 +43 @@
     #Determine minimum timestep across all processors
     pypar.reduce(domain.local_timestep, pypar.MIN, 0,
-                      buffer=domain.global_timestep,
-                      bypass=True)
+                      buffer=domain.global_timestep)#,
+                      #bypass=True)
 
     #pypar.allreduce(domain.local_timestep, pypar.MIN,
@@ -55 +55 @@
     #Broadcast minimal timestep to all processors
     t0 = time.time()
-    pypar.broadcast(domain.global_timestep, 0, bypass=True)
+    pypar.broadcast(domain.global_timestep, 0)#, bypass=True)
 
     domain.communication_broadcast_time += time.time()-t0
@@ -90 +90 @@
                         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)
 
 
@@ -100 +100 @@
                 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):