From 12ce2dc1649e50b8cf8943dbe80516bbe2cd4a55 Mon Sep 17 00:00:00 2001 From: Arseniy Obolenskiy Date: Sun, 6 Jul 2025 15:06:34 +0200 Subject: [PATCH] Handle MPI_Iprobe errors --- modules/runners/src/runners.cpp | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/modules/runners/src/runners.cpp b/modules/runners/src/runners.cpp index 524ceb8ea..0925349f5 100644 --- a/modules/runners/src/runners.cpp +++ b/modules/runners/src/runners.cpp @@ -24,7 +24,11 @@ void UnreadMessagesDetector::OnTestEnd(const ::testing::TestInfo& /*test_info*/) int flag = -1; MPI_Status status; - MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, &status); + const int iprobe_res = MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, &status); + if (iprobe_res != MPI_SUCCESS) { + std::cerr << std::format("[ PROCESS {} ] [ ERROR ] MPI_Iprobe failed with code {}", rank, iprobe_res) << '\n'; + MPI_Abort(MPI_COMM_WORLD, iprobe_res); + } if (flag != 0) { std::cerr