Skip to content

Commit d2ed0d9

Browse files
committed
Removed barriers for multibunch simulation.
1 parent c39e6d1 commit d2ed0d9

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

ring_of_CPUs_multiturn.py

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -98,8 +98,6 @@ def __init__(self, sim_content, N_pieces_per_transfer=1, force_serial = False, c
9898

9999
self.sim_content.init_all()
100100

101-
self.comm.Barrier() # only for stdoutp
102-
103101
if self.I_am_the_master:
104102
print2logandstdo('PyPARIS simulation -- multiturn parallelization')#, mode='w+')
105103
print2logandstdo(comm_info)
@@ -115,8 +113,6 @@ def __init__(self, sim_content, N_pieces_per_transfer=1, force_serial = False, c
115113
print2logandstdo('Running on %s'%socket.gethostname())
116114
print2logandstdo('Interpreter at %s'%sys.executable)
117115

118-
self.comm.Barrier() # only for stdoutp
119-
120116
self.left = int(np.mod(self.myid-1, self.N_nodes))
121117
self.right = int(np.mod(self.myid+1, self.N_nodes))
122118

@@ -133,8 +129,6 @@ def __init__(self, sim_content, N_pieces_per_transfer=1, force_serial = False, c
133129
list_bunches = sim_content.init_master()
134130
self.bunches_to_be_treated.extend(list_bunches)
135131

136-
self.comm.Barrier()
137-
138132
def run(self):
139133

140134

@@ -260,7 +254,6 @@ def run(self):
260254
iteration+=1
261255

262256
# (TEMPORARY!) To stop
263-
self.comm.Barrier()
264257
# if iteration==10000:
265258
# break
266259
# (TEMPORARY!)

0 commit comments

Comments
 (0)