X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fc0a76c21f0bceb0314aee5d62f785ea8009495e..6a842fbc88eba9f783c6599c541577e70c49aa1a:/teshsuite/smpi/mpich3-test/rma/flush.c diff --git a/teshsuite/smpi/mpich3-test/rma/flush.c b/teshsuite/smpi/mpich3-test/rma/flush.c index 1f2147003c..502db1192a 100644 --- a/teshsuite/smpi/mpich3-test/rma/flush.c +++ b/teshsuite/smpi/mpich3-test/rma/flush.c @@ -10,7 +10,7 @@ #define ITER 100 -int main( int argc, char *argv[] ) +int main(int argc, char *argv[]) { int rank, nproc, i; int errors = 0, all_errors = 0; @@ -22,19 +22,21 @@ int main( int argc, char *argv[] ) MPI_Comm_size(MPI_COMM_WORLD, &nproc); if (nproc < 2) { - if (rank == 0) printf("Error: must be run with two or more processes\n"); + if (rank == 0) + printf("Error: must be run with two or more processes\n"); MPI_Abort(MPI_COMM_WORLD, 1); } /** Create using MPI_Win_create() **/ if (rank == 0) { - MPI_Alloc_mem(sizeof(int), MPI_INFO_NULL, &buf); - *buf = nproc-1; - } else - buf = NULL; + MPI_Alloc_mem(sizeof(int), MPI_INFO_NULL, &buf); + *buf = nproc - 1; + } + else + buf = NULL; - MPI_Win_create(buf, sizeof(int)*(rank == 0), 1, MPI_INFO_NULL, MPI_COMM_WORLD, &window); + MPI_Win_create(buf, sizeof(int) * (rank == 0), 1, MPI_INFO_NULL, MPI_COMM_WORLD, &window); /* Test flush of an empty epoch */ MPI_Win_lock(MPI_LOCK_SHARED, 0, 0, window); @@ -53,21 +55,22 @@ int main( int argc, char *argv[] ) * to the right. Each process, in turn, performs third-party * communication via process 0's window. */ if (rank > 0) { - MPI_Recv(NULL, 0, MPI_BYTE, rank-1, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE); + MPI_Recv(NULL, 0, MPI_BYTE, rank - 1, 0, MPI_COMM_WORLD, MPI_STATUS_IGNORE); } - MPI_Get_accumulate(&rank, 1, MPI_INT, &val, 1, MPI_INT, 0, 0, 1, MPI_INT, MPI_REPLACE, window); + MPI_Get_accumulate(&rank, 1, MPI_INT, &val, 1, MPI_INT, 0, 0, 1, MPI_INT, MPI_REPLACE, + window); MPI_Win_flush(0, window); - exp = (rank + nproc-1) % nproc; + exp = (rank + nproc - 1) % nproc; if (val != exp) { printf("%d - Got %d, expected %d\n", rank, val, exp); errors++; } - if (rank < nproc-1) { - MPI_Send(NULL, 0, MPI_BYTE, rank+1, 0, MPI_COMM_WORLD); + if (rank < nproc - 1) { + MPI_Send(NULL, 0, MPI_BYTE, rank + 1, 0, MPI_COMM_WORLD); } MPI_Barrier(MPI_COMM_WORLD); @@ -76,7 +79,8 @@ int main( int argc, char *argv[] ) MPI_Win_unlock(0, window); MPI_Win_free(&window); - if (buf) MPI_Free_mem(buf); + if (buf) + MPI_Free_mem(buf); MPI_Reduce(&errors, &all_errors, 1, MPI_INT, MPI_SUM, 0, MPI_COMM_WORLD);