From ae2e2e1d322202b729d6a4d59fbd297c7cdf90cb Mon Sep 17 00:00:00 2001 From: Ellis Date: Mon, 26 Feb 2018 10:05:39 -0600 Subject: [PATCH] Fix whitespace --- grudge/execution.py | 5 ++--- test/test_mpi_communication.py | 3 --- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/grudge/execution.py b/grudge/execution.py index a12c6dbe..a7aaf28c 100644 --- a/grudge/execution.py +++ b/grudge/execution.py @@ -334,7 +334,8 @@ class ExecutionMapper(mappers.Evaluator, # Do all instructions complete before futures? # FIXME: We CANNOT have any possibility of deadlock - # One option is to add an attribute that tells the scheduler that this should not be foreced + # One option is to add an attribute that tells the scheduler that this + # should not be foreced class RecvFuture: def __init__(self, recv_req, insn_name, remote_data_host, queue): @@ -352,7 +353,6 @@ class ExecutionMapper(mappers.Evaluator, remote_data = cl.array.to_device(self.queue, self.remote_data_host) return [(self.insn_name, remote_data)], [] - class SendFuture: def __init__(self, send_request): self.send_request = send_request @@ -365,7 +365,6 @@ class ExecutionMapper(mappers.Evaluator, self.send_request.wait() return [], [] - return [], [RecvFuture(recv_req, insn.name, remote_data_host, self.queue), SendFuture(send_req)] diff --git a/test/test_mpi_communication.py b/test/test_mpi_communication.py index 96c460a3..db2b8fc8 100644 --- a/test/test_mpi_communication.py +++ b/test/test_mpi_communication.py @@ -78,9 +78,6 @@ def simple_mpi_communication_entrypoint(): sym.interp(sym.BTAG_ALL, "all_faces")( sym.interp("vol", sym.BTAG_ALL)(sym.var("myfunc")))) - # FIXME: Since this is the second call to bind, something wierd happens with MPITagCollector - # and MPITagDistributor. I think it has distributed mesh but does not have any - # OppositePartitionFaceSwap operators bound_face_swap = bind(vol_discr, sym.interp("int_faces", "all_faces")( sym.OppositeInteriorFaceSwap("int_faces")( -- GitLab