Skip to content

Commit 1ca8ff9

Browse files
committed
re-do termination synchronization
1 parent f270c3f commit 1ca8ff9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

mpisppy/cylinders/spoke.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ def got_kill_signal(self):
2626
to see if the Hub terminated
2727
"""
2828
shutdown_buf = self.receive_buffers[self._make_key(Field.SHUTDOWN, 0)]
29-
self.get_receive_buffer(shutdown_buf, Field.SHUTDOWN, 0)
30-
return shutdown_buf[0] == 1.0
29+
self.get_receive_buffer(shutdown_buf, Field.SHUTDOWN, 0, synchronize=False)
30+
return self.allreduce_or(shutdown_buf[0] == 1.0)
3131

3232
@abc.abstractmethod
3333
def main(self):

0 commit comments

Comments
 (0)