mpi: fix detection of local messages in receiver

faasm · Feb 26, 2024 · 7ec2294 · 7ec2294
1 parent 4d738ad
commit 7ec2294
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/mpi/MpiWorld.cpp b/src/mpi/MpiWorld.cpp
@@ -607,7 +607,8 @@ void MpiWorld::doRecv(std::shared_ptr<MPIMessage>& m,
     assert(m->count() <= count);
 
     const std::string otherHost = getHostForRank(m->destination());
-    bool isLocal = otherHost == thisHost;
+    bool isLocal =
+      getHostForRank(m->destination()) == getHostForRank(m->sender());
 
     if (m->count() > 0) {
         if (isLocal) {