- Timestamp:
- Sep 15, 2008, 2:04:22 PM (16 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
anuga_core/source/anuga_parallel/parallel_shallow_water.py
r4884 r5763 118 118 for pid in range(self.numproc): 119 119 #print 'P%d calling broadcast from %d' %(self.processor, pid) 120 self.local_timestep[0] = self. timestep120 self.local_timestep[0] = self.flux_timestep 121 121 pypar.broadcast(self.local_timestep, pid, bypass=True) 122 122 self.local_timesteps[pid] = self.local_timestep[0] 123 123 124 self.timestep = min(self.local_timesteps) 124 self.flux_timestep = min(self.local_timesteps) 125 126 #print 'Flux Timestep %d P%d_%d' %(self.flux_timestep, self.processor, self.numproc) 125 127 126 128 pypar.barrier() … … 147 149 import time 148 150 #Compute minimal timestep across all processes 149 self.local_timestep[0] = self. timestep151 self.local_timestep[0] = self.flux_timestep 150 152 use_reduce_broadcast = True 151 153 if use_reduce_broadcast: … … 158 160 #Alternative: Try using straight send and receives 159 161 t0 = time.time() 160 self.global_timestep[0] = self. timestep162 self.global_timestep[0] = self.flux_timestep 161 163 162 164 if self.processor == 0: … … 183 185 self.communication_broadcast_time += time.time()-t0 184 186 185 186 self.timestep = self.global_timestep[0] 187 #old_timestep = self.flux_timestep 188 self.flux_timestep = self.global_timestep[0] 189 #print 'Flux Timestep %15.5e %15.5e P%d_%d' %(self.flux_timestep, old_timestep, self.processor, self.numproc) 187 190 188 191 # LINDA:
Note: See TracChangeset
for help on using the changeset viewer.