Ignore:
Timestamp:
Aug 7, 2012, 10:27:18 AM (13 years ago)
Author:
steve
Message:

Wierd result on 2 processors merimbula_profile

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/anuga_core/source/anuga_parallel/parallel_generic_communications.py

    r8490 r8495  
    4141    t0 = time.time()
    4242
    43     #Determine minimum timestep across all processors
    44     pypar.reduce(domain.local_timestep, pypar.MIN, 0,
    45                       buffer=domain.global_timestep)#,
    46                       #bypass=True)
     43    allreduce = False
     44   
     45    if allreduce:
     46        #pypar.allreduce(domain.local_timestep, pypar.MIN,
     47        #              buffer=domain.global_timestep,
     48        #              bypass=True)
     49        domain.communication_reduce_time += time.time()-t0
     50    else:
     51        pypar.reduce(domain.local_timestep, pypar.MIN, 0,
     52                      buffer=domain.global_timestep,
     53                      bypass=True)
    4754
    48     #pypar.allreduce(domain.local_timestep, pypar.MIN,
    49     #                  buffer=domain.global_timestep,
    50     #                  bypass=True)
    51 
    52     domain.communication_reduce_time += time.time()-t0
     55        domain.communication_reduce_time += time.time()-t0
    5356
    5457
    55     #Broadcast minimal timestep to all processors
    56     t0 = time.time()
    57     pypar.broadcast(domain.global_timestep, 0)#, bypass=True)
     58        #Broadcast minimal timestep to all processors
     59        t0 = time.time()
     60        pypar.broadcast(domain.global_timestep, 0)#, bypass=True)
    5861
    59     domain.communication_broadcast_time += time.time()-t0
     62        domain.communication_broadcast_time += time.time()-t0
    6063
    6164    old_fux_timestep = domain.flux_timestep
Note: See TracChangeset for help on using the changeset viewer.