|
@@ -130,7 +130,8 @@ void GSATThreadMPI::mpiWait(GSATThreadMPI* gsat) {
|
|
}
|
|
}
|
|
|
|
|
|
void GSATThreadMPI::mpiNotify(int rank) {
|
|
void GSATThreadMPI::mpiNotify(int rank) {
|
|
|
|
+ MPI_Request request;
|
|
for(int i = 0; i < world_size; i++) {
|
|
for(int i = 0; i < world_size; i++) {
|
|
- MPI_Send(&rank, 1, MPI_INT, i, 0, MPI_COMM_WORLD);
|
|
|
|
|
|
+ MPI_Isend(&rank, 1, MPI_INT, i, 0, MPI_COMM_WORLD, &request);
|
|
}
|
|
}
|
|
}
|
|
}
|