Skip to content

Commit 64901fb

Browse files
committed
refactor bounds sync to base class
1 parent 1ca8ff9 commit 64901fb

File tree

1 file changed

+10
-14
lines changed

1 file changed

+10
-14
lines changed

mpisppy/cylinders/hub.py

+10-14
Original file line numberDiff line numberDiff line change
@@ -291,6 +291,11 @@ def send_terminate(self):
291291
self.put_send_buffer(self.send_buffers[Field.SHUTDOWN], Field.SHUTDOWN)
292292
return
293293

294+
def sync_bounds(self):
295+
self.receive_outerbounds()
296+
self.receive_innerbounds()
297+
self.send_boundsout()
298+
294299

295300
class PHHub(Hub):
296301

@@ -317,22 +322,14 @@ def sync(self):
317322
"""
318323
Manages communication with Spokes
319324
"""
320-
self.send_ws()
321-
self.send_nonants()
322-
self.send_boundsout()
323-
self.receive_outerbounds()
324-
self.receive_innerbounds()
325-
if self.opt.extensions is not None:
326-
self.opt.extobject.sync_with_spokes()
325+
self.sync_ws()
326+
self.sync_nonants()
327+
self.sync_bounds()
328+
self.sync_extensions()
327329

328330
def sync_with_spokes(self):
329331
self.sync()
330332

331-
def sync_bounds(self):
332-
self.receive_outerbounds()
333-
self.receive_innerbounds()
334-
self.send_boundsout()
335-
336333
def sync_extensions(self):
337334
if self.opt.extensions is not None:
338335
self.opt.extobject.sync_with_spokes()
@@ -431,8 +428,7 @@ def sync(self, send_nonants=True):
431428
"""
432429
if send_nonants:
433430
self.send_nonants()
434-
self.receive_outerbounds()
435-
self.receive_innerbounds()
431+
self.sync_bounds()
436432
# in case LShaped ever gets extensions
437433
if getattr(self.opt, "extensions", None) is not None:
438434
self.opt.extobject.sync_with_spokes()

0 commit comments

Comments
 (0)