X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3928c9b3860770cd5efbaa3515e9df6d09273e52..b9625f82f86db0674e911887addce45dca31b57f:/teshsuite/smpi/mpich3-test/pt2pt/sendall.c diff --git a/teshsuite/smpi/mpich3-test/pt2pt/sendall.c b/teshsuite/smpi/mpich3-test/pt2pt/sendall.c index 2f87e47eb0..5e679161d1 100644 --- a/teshsuite/smpi/mpich3-test/pt2pt/sendall.c +++ b/teshsuite/smpi/mpich3-test/pt2pt/sendall.c @@ -10,9 +10,9 @@ #include "mpi.h" #include "mpitest.h" -/* +/* * This test makes sure that each process can send to each other process. - * If there are bugs in the handling of request completions or in + * If there are bugs in the handling of request completions or in * queue operations, then this test may fail on them (it did with * early EagerShort handling). */ @@ -23,61 +23,59 @@ static int buffer[MAXPES][MYBUFSIZE]; #define NUM_RUNS 10 -int main ( int argc, char *argv[] ) +int main(int argc, char *argv[]) { - int i; - int count, size; - int self, npes; - double secs; - MPI_Request request[MAXPES]; - MPI_Status status; - - MTest_Init (&argc, &argv); - MPI_Comm_rank (MPI_COMM_WORLD, &self); - MPI_Comm_size (MPI_COMM_WORLD, &npes); - - if (npes > MAXPES) { - fprintf( stderr, "This program requires a comm_world no larger than %d", - MAXPES ); - MPI_Abort( MPI_COMM_WORLD, 1 ); - exit(1); - } - - for (size = 1; size <= MYBUFSIZE ; size += size) { - secs = -MPI_Wtime (); - for (count = 0; count < NUM_RUNS; count++) { - MPI_Barrier (MPI_COMM_WORLD); - - for (i = 0; i < npes; i++) { - if (i != self) - MPI_Irecv (buffer[i], size, MPI_INT, i, - MPI_ANY_TAG, MPI_COMM_WORLD, &request[i]); - } - - for (i = 0; i < npes; i++) { - if (i != self) - MPI_Send (buffer[self], size, MPI_INT, i, 0, MPI_COMM_WORLD); - } - - for (i = 0; i < npes; i++) { - if (i != self) - MPI_Wait (&request[i], &status); - } - - } - MPI_Barrier (MPI_COMM_WORLD); - secs += MPI_Wtime (); - - if (self == 0) { - secs = secs / (double) NUM_RUNS; - MTestPrintfMsg( 1, "length = %d ints\n", size ); - } + int i; + int count, size; + int self, npes; + double secs; + MPI_Request request[MAXPES]; + MPI_Status status; + + MTest_Init(&argc, &argv); + MPI_Comm_rank(MPI_COMM_WORLD, &self); + MPI_Comm_size(MPI_COMM_WORLD, &npes); + + if (npes > MAXPES) { + fprintf(stderr, "This program requires a comm_world no larger than %d", MAXPES); + MPI_Abort(MPI_COMM_WORLD, 1); + } + + for (size = 1; size <= MYBUFSIZE; size += size) { + secs = -MPI_Wtime(); + for (count = 0; count < NUM_RUNS; count++) { + MPI_Barrier(MPI_COMM_WORLD); + + for (i = 0; i < npes; i++) { + if (i != self) + MPI_Irecv(buffer[i], size, MPI_INT, i, + MPI_ANY_TAG, MPI_COMM_WORLD, &request[i]); + } + + for (i = 0; i < npes; i++) { + if (i != self) + MPI_Send(buffer[self], size, MPI_INT, i, 0, MPI_COMM_WORLD); + } + + for (i = 0; i < npes; i++) { + if (i != self) + MPI_Wait(&request[i], &status); + } + + } + MPI_Barrier(MPI_COMM_WORLD); + secs += MPI_Wtime(); + + if (self == 0) { + secs = secs / (double) NUM_RUNS; + MTestPrintfMsg(1, "length = %d ints\n", size); + } } - /* Simple completion is all that we normally ask of this program */ + /* Simple completion is all that we normally ask of this program */ - MTest_Finalize( 0 ); + MTest_Finalize(0); - MPI_Finalize(); - return 0; + MPI_Finalize(); + return 0; }