* PURPOSE. THE SOFTWARE PROVIDED HEREUNDER IS ON AN "AS IS" BASIS AND IBM
* CORP. HAS NO OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES,
* ENHANCEMENTS, OR MODIFICATIONS.
- * ***************************************************************************
**/
#include <stdio.h>
#include <mpi.h>
int *out;
int *in;
-
out = malloc(MAXLEN * 64 * sizeof(int));
in = malloc(MAXLEN * sizeof(int));
for (k = 0; k < j; k++) {
if (in[k] != k + rank * j) {
- fprintf(stderr,
- "task %d bad answer (%d) at index %d k of %d (should be %d)",
- rank, in[k], k, j, (k + rank * j));
+ fprintf(stderr, "task %d bad answer (%d) at index %d k of %d (should be %d)",rank, in[k], k, j, (k + rank * j));
return (0);
}
}
return (success);
}
-/**
- * small test: the root sends a single distinct double to other processes
- **/
+/** small test: the root sends a single distinct double to other processes */
static int small_test(int rank, int size)
{
int success = 1;
}
}
- retval =
- MPI_Scatter(sndbuf, sendcount, MPI_DOUBLE, &rcvd, recvcount,
- MPI_DOUBLE, root, MPI_COMM_WORLD);
+ retval = MPI_Scatter(sndbuf, sendcount, MPI_DOUBLE, &rcvd, recvcount, MPI_DOUBLE, root, MPI_COMM_WORLD);
if (root == rank) {
free(sndbuf);
}
if (retval != MPI_SUCCESS) {
- fprintf(stderr, "(%s:%d) MPI_Scatter() returned retval=%d\n", __FILE__,
- __LINE__, retval);
+ fprintf(stderr, "(%s:%d) MPI_Scatter() returned retval=%d\n", __FILE__, __LINE__, retval);
return 0;
}
// verification
return (success);
}
-
-
int main(int argc, char **argv)
{
int size, rank;
-
MPI_Init(&argc, &argv);
MPI_Comm_size(MPI_COMM_WORLD, &size);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
else
printf("\t[%d] ok.\n", rank);
-
MPI_Barrier(MPI_COMM_WORLD);
/* test 2 */