#include <stdio.h>
#include "mpitest.h"
#include <stdlib.h>
+#include "mpicolltest.h"
/*
static char MTEST_Descrip[] = "";
*/
-int main( int argc, char *argv[] )
+int main(int argc, char *argv[])
{
int errs = 0;
int rank, size;
- int minsize = 2, count;
- MPI_Comm comm;
+ int minsize = 2, count;
+ MPI_Comm comm;
int *sendbuf, *recvbuf, *p;
int sendcount, recvcount;
int i, j;
MPI_Datatype sendtype, recvtype;
- MTest_Init( &argc, &argv );
+ MTest_Init(&argc, &argv);
- /* The following illustrates the use of the routines to
- run through a selection of communicators and datatypes.
- Use subsets of these for tests that do not involve combinations
- of communicators, datatypes, and counts of datatypes */
- while (MTestGetIntracommGeneral( &comm, minsize, 1 )) {
- if (comm == MPI_COMM_NULL) continue;
+ /* The following illustrates the use of the routines to
+ * run through a selection of communicators and datatypes.
+ * Use subsets of these for tests that do not involve combinations
+ * of communicators, datatypes, and counts of datatypes */
+ while (MTestGetIntracommGeneral(&comm, minsize, 1)) {
+ if (comm == MPI_COMM_NULL)
+ continue;
- /* Determine the sender and receiver */
- MPI_Comm_rank( comm, &rank );
- MPI_Comm_size( comm, &size );
-
- /* printf( "Size of comm = %d\n", size ); */
- for (count = 1; count < 65000; count = count * 2) {
-
- /* Create a send buf and a receive buf suitable for testing
- all to all. */
- sendcount = count;
- recvcount = count;
- sendbuf = (int *)malloc( count * size * sizeof(int) );
- recvbuf = (int *)malloc( count * size * sizeof(int) );
- sendtype = MPI_INT;
- recvtype = MPI_INT;
+ /* Determine the sender and receiver */
+ MPI_Comm_rank(comm, &rank);
+ MPI_Comm_size(comm, &size);
- if (!sendbuf || !recvbuf) {
- errs++;
- fprintf( stderr, "Failed to allocate sendbuf and/or recvbuf\n" );
- MPI_Abort( MPI_COMM_WORLD, 1 );
- exit(1);
- }
- for (i=0; i<count*size; i++)
- recvbuf[i] = -1;
- p = sendbuf;
- for (j=0; j<size; j++) {
- for (i=0; i<count; i++) {
- *p++ = j * size + rank + i;
- }
- }
+ /* printf("Size of comm = %d\n", size); */
+ for (count = 1; count < 65000; count = count * 2) {
- MPI_Alltoall( sendbuf, sendcount, sendtype,
- recvbuf, recvcount, recvtype, comm );
+ /* Create a send buf and a receive buf suitable for testing
+ * all to all. */
+ sendcount = count;
+ recvcount = count;
+ sendbuf = (int *) malloc(count * size * sizeof(int));
+ recvbuf = (int *) malloc(count * size * sizeof(int));
+ sendtype = MPI_INT;
+ recvtype = MPI_INT;
- p = recvbuf;
- for (j=0; j<size; j++) {
- for (i=0; i<count; i++) {
- if (*p != rank * size + j + i) {
- errs++;
- if (errs < 10) {
- fprintf( stderr, "Error with communicator %s and size=%d count=%d\n",
- MTestGetIntracommName(), size, count );
- fprintf( stderr, "recvbuf[%d,%d] = %d, should %d\n",
- j,i, *p, rank * size + j + i );
- }
- }
- p++;
- }
- }
+ if (!sendbuf || !recvbuf) {
+ errs++;
+ fprintf(stderr, "Failed to allocate sendbuf and/or recvbuf\n");
+ MPI_Abort(MPI_COMM_WORLD, 1);
+ }
+ for (i = 0; i < count * size; i++)
+ recvbuf[i] = -1;
+ p = sendbuf;
+ for (j = 0; j < size; j++) {
+ for (i = 0; i < count; i++) {
+ *p++ = j * size + rank + i;
+ }
+ }
+
+ MTest_Alltoall(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm);
+
+ p = recvbuf;
+ for (j = 0; j < size; j++) {
+ for (i = 0; i < count; i++) {
+ if (*p != rank * size + j + i) {
+ errs++;
+ if (errs < 10) {
+ fprintf(stderr, "Error with communicator %s and size=%d count=%d\n",
+ MTestGetIntracommName(), size, count);
+ fprintf(stderr, "recvbuf[%d,%d] = %d, should %d\n",
+ j, i, *p, rank * size + j + i);
+ }
+ }
+ p++;
+ }
+ }
#if MTEST_HAVE_MIN_MPI_VERSION(2,2)
/* check MPI_IN_PLACE, added in MPI-2.2 */
p = recvbuf;
- for (j=0; j<size; j++) {
- for (i=0; i<count; i++) {
+ for (j = 0; j < size; j++) {
+ for (i = 0; i < count; i++) {
*p++ = j * size + rank + i;
}
}
- MPI_Alltoall( MPI_IN_PLACE, -1/*ignored*/, MPI_DATATYPE_NULL/*ignored*/,
- recvbuf, recvcount, recvtype, comm );
+ MPI_Alltoall(MPI_IN_PLACE, -1 /*ignored */ , MPI_DATATYPE_NULL /*ignored */ ,
+ recvbuf, recvcount, recvtype, comm);
p = recvbuf;
- for (j=0; j<size; j++) {
- for (i=0; i<count; i++) {
+ for (j = 0; j < size; j++) {
+ for (i = 0; i < count; i++) {
if (*p != rank * size + j + i) {
errs++;
if (errs < 10) {
- fprintf( stderr, "Error (MPI_IN_PLACE) with communicator %s and size=%d count=%d\n",
- MTestGetIntracommName(), size, count );
- fprintf(stderr, "recvbuf[%d,%d] = %d, should be %d\n",
- j,i, *p, rank * size + j + i );
+ fprintf(stderr,
+ "Error (MPI_IN_PLACE) with communicator %s and size=%d count=%d\n",
+ MTestGetIntracommName(), size, count);
+ fprintf(stderr, "recvbuf[%d,%d] = %d, should be %d\n", j, i, *p,
+ rank * size + j + i);
}
}
p++;
}
#endif
- free( recvbuf );
- free( sendbuf );
- }
- MTestFreeComm( &comm );
+ free(recvbuf);
+ free(sendbuf);
+ }
+ MTestFreeComm(&comm);
}
-#if MTEST_HAVE_MIN_MPI_VERSION(2,2)
- /* Check to make sure that aliasing is disallowed correctly */
- MPI_Comm_set_errhandler(MPI_COMM_WORLD, MPI_ERRORS_RETURN);
- MPI_Comm_rank(MPI_COMM_WORLD, &rank);
- if (MPI_SUCCESS == MPI_Alltoall(&rank, 1, MPI_INT, &rank, 1, MPI_INT, MPI_COMM_WORLD))
- errs++;
-#endif
-
- MTest_Finalize( errs );
+ MTest_Finalize(errs);
MPI_Finalize();
return 0;
}
