ForkMaster/netgen
1
0
Fork 0
mirror of https://github.com/NGSolve/netgen.git synced 2025-02-03 16:50:34 +05:00
Code Issues Packages Projects Releases Wiki Activity

missed waits

Browse Source
This commit is contained in:
Joachim Schoeberl 2024-12-01 17:19:45 +01:00
parent 75504c3a6d
commit 8c1882226c
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
libsrc/meshing/parallelmesh.cpp
View File

@ -1220,8 +1220,7 @@ namespace netgen
recvrequests[0] = comm.IBcast (nnames); recvrequests[0] = comm.IBcast (nnames);
MyMPI_WaitAll (recvrequests); MyMPI_WaitAll (recvrequests);
*/ */
NgMPI_Requests requ; comm.IBcast (nnames).Wait();
requ += comm.IBcast (nnames);
// cout << "nnames = " << FlatArray(nnames) << endl; // cout << "nnames = " << FlatArray(nnames) << endl;
materials.SetSize(nnames[0]); materials.SetSize(nnames[0]);
@ -1236,7 +1235,7 @@ namespace netgen
recvrequests[0] = comm.IBcast (name_sizes); recvrequests[0] = comm.IBcast (name_sizes);
MyMPI_WaitAll (recvrequests); MyMPI_WaitAll (recvrequests);
*/ */
requ += comm.IBcast (name_sizes); comm.IBcast (name_sizes).Wait();
int tot_size = 0; int tot_size = 0;
for (int k = 0; k < tot_nn; k++) tot_size += name_sizes[k]; for (int k = 0; k < tot_nn; k++) tot_size += name_sizes[k];
@ -1246,8 +1245,7 @@ namespace netgen
Array<char> compiled_names(tot_size); Array<char> compiled_names(tot_size);
// recvrequests[0] = comm.IBcast (compiled_names); // recvrequests[0] = comm.IBcast (compiled_names);
// MyMPI_WaitAll (recvrequests); // MyMPI_WaitAll (recvrequests);
requ += comm.IBcast (compiled_names); comm.IBcast (compiled_names).Wait();
requ.WaitAll();
tot_nn = tot_size = 0; tot_nn = tot_size = 0;
auto write_names = [&] (auto & array) { auto write_names = [&] (auto & array) {