Skip to content
Snippets Groups Projects
Commit 22095b50 authored by Boris Martin's avatar Boris Martin
Browse files

potential fix

parent 6e764f7c
No related branches found
No related tags found
No related merge requests found
Pipeline #12712 failed
...@@ -465,6 +465,7 @@ namespace gmshfem::field ...@@ -465,6 +465,7 @@ namespace gmshfem::field
MPI_Waitall(receiveRequests.size(), receiveRequests.data(), MPI_STATUSES_IGNORE); MPI_Waitall(receiveRequests.size(), receiveRequests.data(), MPI_STATUSES_IGNORE);
size_t total_size = std::reduce(recvSizes.begin(), recvSizes.end()); size_t total_size = std::reduce(recvSizes.begin(), recvSizes.end());
allSharedDofsArray.resize(total_size); allSharedDofsArray.resize(total_size);
// 2) Transfer dofs indices
sendRequests.clear(); sendRequests.resize(ranks.size()); sendRequests.clear(); sendRequests.resize(ranks.size());
receiveRequests.clear(); receiveRequests.resize(ranks.size()); receiveRequests.clear(); receiveRequests.resize(ranks.size());
size_t currentOffset = 0; size_t currentOffset = 0;
...@@ -476,6 +477,10 @@ namespace gmshfem::field ...@@ -476,6 +477,10 @@ namespace gmshfem::field
MPI_Waitall(sendRequests.size(), sendRequests.data(), MPI_STATUSES_IGNORE); MPI_Waitall(sendRequests.size(), sendRequests.data(), MPI_STATUSES_IGNORE);
MPI_Waitall(receiveRequests.size(), receiveRequests.data(), MPI_STATUSES_IGNORE); MPI_Waitall(receiveRequests.size(), receiveRequests.data(), MPI_STATUSES_IGNORE);
MPI_Barrier(MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD);
// 3) Add my dofs to the global array
for (auto entry: myOwnedDofs) {
allSharedDofsArray.push_back(entry);
}
if(rank == 0) { if(rank == 0) {
msg::info << "Gathered allSharedDofsArray with peer-to-peer comms." << msg::endl; msg::info << "Gathered allSharedDofsArray with peer-to-peer comms." << msg::endl;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment