#include <stdio.h>
#include <stdlib.h>
-int add ( double *, double *, int *, MPI_Datatype * );
+int add(double *, double *, int *, MPI_Datatype *);
/*
* User-defined operation on a long value (tests proper handling of
* possible pipelining in the implementation of reductions with user-defined
* operations).
*/
-int add( double *invec, double *inoutvec, int *len, MPI_Datatype *dtype )
+int add(double *invec, double *inoutvec, int *len, MPI_Datatype * dtype)
{
int i, n = *len;
- for (i=0; i<n; i++) {
- inoutvec[i] = invec[i] + inoutvec[i];
+ for (i = 0; i < n; i++) {
+ inoutvec[i] = invec[i] + inoutvec[i];
}
return 0;
}
-int main( int argc, char **argv )
+int main(int argc, char **argv)
{
MPI_Op op;
- int i, rank, size, bufsize, errcnt = 0, toterr;
+ int i, rank, size, bufsize, errcnt = 0, toterr;
double *inbuf, *outbuf, value;
-
- MPI_Init( &argc, &argv );
- MPI_Comm_rank( MPI_COMM_WORLD, &rank );
- MPI_Comm_size( MPI_COMM_WORLD, &size );
- MPI_Op_create( (MPI_User_function *)add, 1, &op );
-
+
+ MPI_Init(&argc, &argv);
+ MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+ MPI_Comm_size(MPI_COMM_WORLD, &size);
+ MPI_Op_create((MPI_User_function *) add, 1, &op);
+
bufsize = 1;
while (bufsize < 100000) {
- inbuf = (double *)malloc( bufsize * sizeof(double) );
- outbuf = (double *)malloc( bufsize * sizeof(double) );
- if (! inbuf || ! outbuf) {
- fprintf( stderr, "Could not allocate buffers for size %d\n",
- bufsize );
- errcnt++;
- break;
- }
+ inbuf = (double *) malloc(bufsize * sizeof(double));
+ outbuf = (double *) malloc(bufsize * sizeof(double));
+ if (!inbuf || !outbuf) {
+ fprintf(stderr, "Could not allocate buffers for size %d\n", bufsize);
+ errcnt++;
+ break;
+ }
- value = (rank & 0x1) ? 1.0 : -1.0;
- for (i=0; i<bufsize; i++) {
- inbuf[i] = value;
- outbuf[i] = 100.0;
- }
- MPI_Allreduce( inbuf, outbuf, bufsize, MPI_DOUBLE, op,
- MPI_COMM_WORLD );
- /* Check values */
- value = (size & 0x1) ? -1.0 : 0.0;
- for (i=0; i<bufsize; i++) {
- if (outbuf[i] != value) {
- if (errcnt < 10)
- printf( "outbuf[%d] = %f, should = %f\n", i, outbuf[i],
- value );
- errcnt ++;
- }
- }
- free( inbuf );
- free( outbuf );
- bufsize *= 2;
+ value = (rank & 0x1) ? 1.0 : -1.0;
+ for (i = 0; i < bufsize; i++) {
+ inbuf[i] = value;
+ outbuf[i] = 100.0;
+ }
+ MPI_Allreduce(inbuf, outbuf, bufsize, MPI_DOUBLE, op, MPI_COMM_WORLD);
+ /* Check values */
+ value = (size & 0x1) ? -1.0 : 0.0;
+ for (i = 0; i < bufsize; i++) {
+ if (outbuf[i] != value) {
+ if (errcnt < 10)
+ printf("outbuf[%d] = %f, should = %f\n", i, outbuf[i], value);
+ errcnt++;
+ }
+ }
+ free(inbuf);
+ free(outbuf);
+ bufsize *= 2;
}
-
- MPI_Allreduce( &errcnt, &toterr, 1, MPI_INT, MPI_SUM, MPI_COMM_WORLD );
- MPI_Comm_rank( MPI_COMM_WORLD, &rank );
+
+ MPI_Allreduce(&errcnt, &toterr, 1, MPI_INT, MPI_SUM, MPI_COMM_WORLD);
+ MPI_Comm_rank(MPI_COMM_WORLD, &rank);
if (rank == 0) {
- if (toterr == 0)
- printf( " No Errors\n" );
- else
- printf( "*! %d errors!\n", toterr );
+ if (toterr == 0)
+ printf(" No Errors\n");
+ else
+ printf("*! %d errors!\n", toterr);
}
- MPI_Op_free( &op );
- MPI_Finalize( );
+ MPI_Op_free(&op);
+ MPI_Finalize();
return 0;
}
-
