kate/BadFish
1
0
Fork 0
mirror of https://github.com/sockspls/badfish synced 2025-07-12 20:19:15 +00:00
Code Issues Releases Wiki Activity

Always wait before posting the next call in _sync.

Browse source
This commit is contained in:
Joost VandeVondele 2018-12-29 19:01:10 +01:00 • committed by Stéphane Nicolet
parent ac43bef5c5
commit 267ca781cd
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/cluster.cpp
View file

@ -191,10 +191,11 @@ void signals_sync() {
uint64_t globalCounter; uint64_t globalCounter;
MPI_Allreduce(&signalsCallCounter, &globalCounter, 1, MPI_UINT64_T, MPI_MAX, MoveComm); // MoveComm needed MPI_Allreduce(&signalsCallCounter, &globalCounter, 1, MPI_UINT64_T, MPI_MAX, MoveComm); // MoveComm needed
if (signalsCallCounter < globalCounter) if (signalsCallCounter < globalCounter)
{
MPI_Wait(&reqSignals, MPI_STATUS_IGNORE);
signals_send(); signals_send();
}
assert(signalsCallCounter == globalCounter); assert(signalsCallCounter == globalCounter);
MPI_Wait(&reqSignals, MPI_STATUS_IGNORE); MPI_Wait(&reqSignals, MPI_STATUS_IGNORE);
signals_process(); signals_process();
@ -204,12 +205,14 @@ void signals_sync() {
if (gathersPosted < globalCounter) if (gathersPosted < globalCounter)
{ {
size_t recvBuffPerRankSize = Threads.size() * TTCacheSize; size_t recvBuffPerRankSize = Threads.size() * TTCacheSize;
MPI_Wait(&reqGather, MPI_STATUS_IGNORE);
MPI_Iallgather(MPI_IN_PLACE, 0, MPI_DATATYPE_NULL, MPI_Iallgather(MPI_IN_PLACE, 0, MPI_DATATYPE_NULL,
TTRecvBuff.data(), recvBuffPerRankSize * sizeof(KeyedTTEntry), MPI_BYTE, TTRecvBuff.data(), recvBuffPerRankSize * sizeof(KeyedTTEntry), MPI_BYTE,
TTComm, &reqGather); TTComm, &reqGather);
++gathersPosted; ++gathersPosted;
} }
assert(gathersPosted == globalCounter); assert(gathersPosted == globalCounter);
MPI_Wait(&reqGather, MPI_STATUS_IGNORE);
} }