+++ /dev/null
-#include "mpi.h"
-#include <stdio.h>
-#include <stdlib.h>
-#include "dtypes.h"
-#include "gcomm.h"
-
-#if defined(NEEDS_STDLIB_PROTOTYPES)
-#include "protofix.h"
-#endif
-
-int verbose = 0;
-/*
- Multiple completions
-
- This is similar to a test in allpair.f, but with an expanded range of
- datatypes and communicators.
- */
-
-int main( int argc, char **argv )
-{
-MPI_Datatype *types;
-void **inbufs, **outbufs;
-char **names;
-int *counts, *bytesize, ntype;
-MPI_Comm comms[20];
-int ncomm = 20, rank, np, partner, tag;
-int i, j, k, err, toterr, world_rank;
-MPI_Status status, statuses[2];
-int flag, index, outcount, indices[2];
-char *obuf;
-MPI_Request requests[2];
-
-
-MPI_Init( &argc, &argv );
-
-AllocateForData( &types, &inbufs, &outbufs, &counts, &bytesize,
- &names, &ntype );
-GenerateData( types, inbufs, outbufs, counts, bytesize, names, &ntype );
-
-MPI_Comm_rank( MPI_COMM_WORLD, &world_rank );
-MakeComms( comms, 20, &ncomm, 0 );
-
-/* Test over a wide range of datatypes and communicators */
-err = 0;
-for (i=0; i<ncomm; i++) {
- MPI_Comm_rank( comms[i], &rank );
- MPI_Comm_size( comms[i], &np );
- if (np < 2) continue;
- tag = i;
- /* This is the test.
- sender: receiver:
- irecv irecv
- isend
- testsome (all fail)
- testany (all fail)
- sendrecv sendrecv
- isend
- sendrecv sendrecv
- testsome (both may) waitsome (both may)
- waitall waitsome (must get other, if any)
- waitsome (outcount = undefined)
- This test DEPENDS on the handling of null requests, since the several
- waits/tests may complete everything "early".
- */
- for (j=0; j<ntype; j++) {
- if (world_rank == 0 && verbose)
- fprintf( stdout, "Testing type %s\n", names[j] );
- /* This test does an irsend between both partners, with
- a sendrecv after the irecv used to guarentee that the
- irsend has a matching receive
- */
- if (rank == 0) {
- /* Sender */
- partner = np - 1;
-#if 0
- MPIR_PrintDatatypePack( stdout, counts[j], types[j], 0, 0 );
-#endif
- obuf = outbufs[j];
- for (k=0; k<bytesize[j]; k++)
- obuf[k] = 0;
-
- MPI_Irecv(outbufs[j], counts[j], types[j], partner, tag,
- comms[i], &requests[0] );
-
- MPI_Isend( inbufs[j], counts[j], types[j], partner, tag,
- comms[i], &requests[1] );
-
- /* Note that the send may have completed */
- MPI_Testsome( 1, &requests[0], &outcount, indices, statuses );
- if (outcount != 0) {
- fprintf( stderr, "MPI_Testsome returned outcount = %d\n",
- outcount );
- err++;
- }
- MPI_Testany( 1, &requests[0], &index, &flag, &status );
- if (flag) {
- fprintf( stderr, "MPI_Testany returned flag = true\n" );
- err++;
- }
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- comms[i], &status );
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- comms[i], &status );
- /* We EXPECT both to succeed, but they may not */
- MPI_Testsome( 2, requests, &outcount, indices, statuses );
- MPI_Waitall( 2, requests, statuses );
-
- /* Check the received data */
- if (CheckDataAndPrint( inbufs[j], outbufs[j], bytesize[j],
- names[j], j )) {
- err++;
- }
- }
- else if (rank == np - 1) {
- /* receiver */
- partner = 0;
- obuf = outbufs[j];
- for (k=0; k<bytesize[j]; k++)
- obuf[k] = 0;
-
- MPI_Irecv(outbufs[j], counts[j], types[j], partner, tag,
- comms[i], &requests[0] );
-
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- comms[i], &status );
-
- MPI_Isend( inbufs[j], counts[j], types[j], partner, tag,
- comms[i], &requests[1] );
-
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- MPI_BOTTOM, 0, MPI_INT, partner, ncomm+i,
- comms[i], &status );
-
- MPI_Waitsome( 2, requests, &outcount, indices, statuses );
- MPI_Waitsome( 2, requests, &outcount, indices, statuses );
- MPI_Waitsome( 2, requests, &outcount, indices, statuses );
- if (outcount != MPI_UNDEFINED) {
- err++;
- fprintf( stderr,
- "MPI_Waitsome did not return outcount = MPI_UNDEFINED\n" );
- }
-
- if (CheckDataAndPrint( inbufs[j], outbufs[j], bytesize[j],
- names[j], j )) {
- err++;
- }
-
- MPI_Waitall(1, &requests[1], &status );
- }
- }
- }
-
-if (err > 0) {
- fprintf( stderr, "%d errors on %d\n", err, rank );
- }
- MPI_Allreduce( &err, &toterr, 1, MPI_INT, MPI_SUM, MPI_COMM_WORLD );
- if (world_rank == 0) {
- if (toterr == 0) {
- printf( " No Errors\n" );
- }
- else {
- printf (" Found %d errors\n", toterr );
- }
- }
-FreeDatatypes( types, inbufs, outbufs, counts, bytesize, names, ntype );
-FreeComms( comms, ncomm );
-MPI_Finalize();
-
-return err;
-}
