- /* Repeat the test, but make one of the processes sleep */
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, partner, 10,
- MPI_BOTTOM, 0, MPI_INT, partner, 10, comm,
- MPI_STATUS_IGNORE );
- if (rank == dest) MTestSleep( 1 );
- /* Try to fill up the outgoing message buffers */
- tsend = MPI_Wtime();
- for (i=0; i<nmsg; i++) {
- MPI_Isend( buf[i], msgSize, MPI_CHAR, partner, testnum, comm,
- &r[i] );
- }
- tsend = MPI_Wtime() - tsend;
- for (i=0; i<nmsg; i++) {
- MPI_Recv( buf[i], msgSize, MPI_CHAR, partner, testnum, comm,
- MPI_STATUS_IGNORE );
- }
- MPI_Waitall( nmsg, r, MPI_STATUSES_IGNORE );
+ /* Repeat the test, but make one of the processes sleep */
+ MPI_Sendrecv(MPI_BOTTOM, 0, MPI_INT, partner, 10,
+ MPI_BOTTOM, 0, MPI_INT, partner, 10, comm, MPI_STATUS_IGNORE);
+ if (rank == dest)
+ MTestSleep(1);
+ /* Try to fill up the outgoing message buffers */
+ tsend = MPI_Wtime();
+ for (i = 0; i < nmsg; i++) {
+ MPI_Isend(buf[i], msgSize, MPI_INT, partner, testnum, comm, &r[i]);
+ }
+ tsend = MPI_Wtime() - tsend;
+ for (i = 0; i < nmsg; i++) {
+ MPI_Recv(buf[i], msgSize, MPI_INT, partner, testnum, comm, MPI_STATUS_IGNORE);
+ }
+ MPI_Waitall(nmsg, r, MPI_STATUSES_IGNORE);