Commit 8a10478b authored by Volker Springel's avatar Volker Springel
Browse files

use myMPI_Sendrecv() instead of MPI_Sendrecv() to allow processing of very large transfers

parent 30019281
......@@ -267,13 +267,13 @@ void fof<partset>::subfind_distribute_particles(MPI_Comm Communicator)
{
if(Send_count[target] > 0 || Recv_count[target] > 0)
{
MPI_Sendrecv(partBuf + Send_offset[target], Send_count[target] * sizeof(particle_data), MPI_BYTE, target, TAG_PDATA,
Tp->P + Recv_offset[target], Recv_count[target] * sizeof(particle_data), MPI_BYTE, target, TAG_PDATA,
Communicator, MPI_STATUS_IGNORE);
myMPI_Sendrecv(partBuf + Send_offset[target], Send_count[target] * sizeof(particle_data), MPI_BYTE, target, TAG_PDATA,
Tp->P + Recv_offset[target], Recv_count[target] * sizeof(particle_data), MPI_BYTE, target, TAG_PDATA,
Communicator, MPI_STATUS_IGNORE);
MPI_Sendrecv(subBuf + Send_offset[target], Send_count[target] * sizeof(subfind_data), MPI_BYTE, target, TAG_KEY,
Tp->PS + Recv_offset[target], Recv_count[target] * sizeof(subfind_data), MPI_BYTE, target, TAG_KEY,
Communicator, MPI_STATUS_IGNORE);
myMPI_Sendrecv(subBuf + Send_offset[target], Send_count[target] * sizeof(subfind_data), MPI_BYTE, target, TAG_KEY,
Tp->PS + Recv_offset[target], Recv_count[target] * sizeof(subfind_data), MPI_BYTE, target, TAG_KEY,
Communicator, MPI_STATUS_IGNORE);
}
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment