Changeset 8495

Timestamp:

Aug 7, 2012, 10:27:18 AM (13 years ago)

Author:

steve

Message:

Wierd result on 2 processors merimbula_profile

Location:

trunk/anuga_core/source/anuga_parallel

Files:

• parallel_generic_communications.py (modified) (1 diff)
• run_parallel_sw_merimbula.py (modified) (1 diff)
• run_parallel_sw_merimbula_profile.py (modified) (1 diff)

trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py

@@ -41 +41 @@
     t0 = time.time()
 
-    #Determine minimum timestep across all processors
-    pypar.reduce(domain.local_timestep, pypar.MIN, 0,
-                      buffer=domain.global_timestep)#,
-                      #bypass=True)
+    allreduce = False
+    
+    if allreduce:
+        #pypar.allreduce(domain.local_timestep, pypar.MIN,
+        #              buffer=domain.global_timestep,
+        #              bypass=True)
+        domain.communication_reduce_time += time.time()-t0
+    else:
+        pypar.reduce(domain.local_timestep, pypar.MIN, 0,
+                      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
+        domain.communication_reduce_time += time.time()-t0
 
 
-    #Broadcast minimal timestep to all processors
-    t0 = time.time()
-    pypar.broadcast(domain.global_timestep, 0)#, bypass=True)
+        #Broadcast minimal timestep to all processors
+        t0 = time.time()
+        pypar.broadcast(domain.global_timestep, 0)#, bypass=True)
 
-    domain.communication_broadcast_time += time.time()-t0
+        domain.communication_broadcast_time += time.time()-t0
 
     old_fux_timestep = domain.flux_timestep

trunk/anuga_core/source/anuga_parallel/run_parallel_sw_merimbula.py

@@ -111 +111 @@
 domain.set_flow_algorithm('2_0')   
 
+
 #domain.smooth = False
 #domain.set_default_order(2)

trunk/anuga_core/source/anuga_parallel/run_parallel_sw_merimbula_profile.py

@@ -42 +42 @@
 #--------------------------------------------------------------------------
 
-mesh_filename = "merimbula_10785_1.tsh" ; x0 = 756000.0 ; x1 = 756500.0
-#mesh_filename = "merimbula_43200.tsh"   ; x0 = 756000.0 ; x1 = 756500.0
+#mesh_filename = "merimbula_10785_1.tsh" ; x0 = 756000.0 ; x1 = 756500.0
+mesh_filename = "merimbula_43200.tsh"   ; x0 = 756000.0 ; x1 = 756500.0
 #mesh_filename = "test-100.tsh" ; x0 = 0.25 ; x1 = 0.5