diff --git a/src/Pstream/mpi/UIPread.C b/src/Pstream/mpi/UIPread.C index b2e79e870e945d7c62317b62da8ab44d7923a227..5afc4a88f9e26d8b2715e620ed77f1a0ff10f591 100644 --- a/src/Pstream/mpi/UIPread.C +++ b/src/Pstream/mpi/UIPread.C @@ -97,7 +97,8 @@ Foam::UIPstream::UIPstream ); MPI_Get_count(&status, MPI_BYTE, &messageSize_); - profilingPstream::addWaitTime(); + // Assume these are from gathers ... + profilingPstream::addGatherTime(); externalBuf_.setCapacity(messageSize_); wantedSize = messageSize_; @@ -202,7 +203,8 @@ Foam::UIPstream::UIPstream(const int fromProcNo, PstreamBuffers& buffers) ); MPI_Get_count(&status, MPI_BYTE, &messageSize_); - profilingPstream::addWaitTime(); + // Assume these are from gathers ... + profilingPstream::addGatherTime(); externalBuf_.setCapacity(messageSize_); wantedSize = messageSize_; @@ -293,7 +295,7 @@ Foam::label Foam::UIPstream::read return 0; } - profilingPstream::addScatterTime(); + profilingPstream::addGatherTime(); // Check size of message read @@ -344,7 +346,7 @@ Foam::label Foam::UIPstream::read return 0; } - profilingPstream::addScatterTime(); + profilingPstream::addWaitTime(); if (debug) { diff --git a/src/Pstream/mpi/UOPwrite.C b/src/Pstream/mpi/UOPwrite.C index efa449835eb6d39716c247dfbb57c341935dec8a..c253f477e4358255de3ad95e29fbcf1981e092ef 100644 --- a/src/Pstream/mpi/UOPwrite.C +++ b/src/Pstream/mpi/UOPwrite.C @@ -85,7 +85,8 @@ bool Foam::UOPstream::write PstreamGlobals::MPICommunicators_[communicator] //MPI_COMM_WORLD ); - profilingPstream::addGatherTime(); + // Assume these are from scatters ... + profilingPstream::addScatterTime(); if (debug) { @@ -107,7 +108,8 @@ bool Foam::UOPstream::write PstreamGlobals::MPICommunicators_[communicator] //MPI_COMM_WORLD ); - profilingPstream::addWaitTime(); + // Assume these are from scatters ... + profilingPstream::addScatterTime(); if (debug) {