diff --git a/grudge/execution.py b/grudge/execution.py index a12c6dbe029958611cf66ea24baeef1d39ff31d6..a7aaf28c44018989b3977ee64a0a0a9522cd6461 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 96c460a3d4e5e8b5af825121427328606b806444..db2b8fc88894cba18a1fa397a82599010d580f28 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")(