From 8c1882226c681f31a4116022fa485e737c021a3e Mon Sep 17 00:00:00 2001 From: Joachim Schoeberl Date: Sun, 1 Dec 2024 17:19:45 +0100 Subject: [PATCH] missed waits --- libsrc/meshing/parallelmesh.cpp | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/libsrc/meshing/parallelmesh.cpp b/libsrc/meshing/parallelmesh.cpp index 9fad0603..a1c9065b 100644 --- a/libsrc/meshing/parallelmesh.cpp +++ b/libsrc/meshing/parallelmesh.cpp @@ -1220,8 +1220,7 @@ namespace netgen recvrequests[0] = comm.IBcast (nnames); MyMPI_WaitAll (recvrequests); */ - NgMPI_Requests requ; - requ += comm.IBcast (nnames); + comm.IBcast (nnames).Wait(); // cout << "nnames = " << FlatArray(nnames) << endl; materials.SetSize(nnames[0]); @@ -1236,7 +1235,7 @@ namespace netgen recvrequests[0] = comm.IBcast (name_sizes); MyMPI_WaitAll (recvrequests); */ - requ += comm.IBcast (name_sizes); + comm.IBcast (name_sizes).Wait(); int tot_size = 0; for (int k = 0; k < tot_nn; k++) tot_size += name_sizes[k]; @@ -1246,8 +1245,7 @@ namespace netgen Array compiled_names(tot_size); // recvrequests[0] = comm.IBcast (compiled_names); // MyMPI_WaitAll (recvrequests); - requ += comm.IBcast (compiled_names); - requ.WaitAll(); + comm.IBcast (compiled_names).Wait(); tot_nn = tot_size = 0; auto write_names = [&] (auto & array) {