+++ /dev/null
-/*
- * Program to test that the "synchronous send" semantics
- * of point to point communications in MPI is (probably) satisfied.
- * This uses tests on the completions of the SENDS (unlike the MPI_Ssend
- * test) since the Issends return "immediately" but can not complete
- * until the matching receive begins.
- *
- * This program has been patterned off of "overtake.c"
- *
- * William Gropp
- * gropp@mcs.anl.gov
- */
-
-#include <stdio.h>
-#include "test.h"
-#include "mpi.h"
-
-#define SIZE 10000
-/* Amount of time in seconds to wait for the receipt of the second Ssend
- message */
-#define MAX_TIME 20
-static int src = 1;
-static int dest = 0;
-
-/* Prototypes for picky compilers */
-void Generate_Data ( int *, int );
-
-void Generate_Data( int *buffer, int buff_size)
-{
- int i;
-
- for (i = 0; i < buff_size; i++)
- buffer[i] = i+1;
-}
-
-int main( int argc, char **argv)
-{
- int rank; /* My Rank (0 or 1) */
- int act_size = 1000;
-/* int flag;*/
- int buffer[SIZE];
- double t0;
- char *Current_Test = NULL;
- MPI_Status status;
- MPI_Request r1, r2;
-
- MPI_Init(&argc, &argv);
- MPI_Comm_rank(MPI_COMM_WORLD, &rank);
-
- /* This test depends on a working wtime. Make a simple check */
- Current_Test = (char*)"Testing timer";
- t0 = MPI_Wtime();
- if (t0 == 0 && MPI_Wtime() == 0) {
- int loopcount = 1000000;
- /* This test is too severe (systems with fast
- processors and large MPI_Wtick values can
- fail. Try harder to test MPI_Wtime */
- while (loopcount-- && MPI_Wtime() == 0) ;
- if (loopcount <= 0) {
- fprintf( stderr,
- "MPI_WTIME is returning 0; a working value is needed\n\
-for this test.\n" );
- Test_Failed(Current_Test);
- MPI_Abort( MPI_COMM_WORLD, 1 );
- }
- t0 = MPI_Wtime();
- }
- /* Test that the timer increases */
-/* Current_Test = (char*)"Testing timer increases";*/
-/* for (flag=0; flag<1000000; flag++) {*/
-/* if (MPI_Wtime() > t0) break;*/
-/* }*/
-/* if (flag >= 1000000) {*/
-/* fprintf( stderr, "MPI_WTIME is not returning increasing values!\n" );*/
-/* Test_Failed(Current_Test);*/
-/* MPI_Abort( MPI_COMM_WORLD, 1 );*/
-/* }*/
-
- Current_Test = (char*)"Issend waits for recv";
- if (rank == src) {
- Test_Init("issendtest", rank);
- Generate_Data(buffer, SIZE);
- MPI_Recv( buffer, 0, MPI_INT, dest, 0, MPI_COMM_WORLD, &status );
- MPI_Send( buffer, 0, MPI_INT, dest, 0, MPI_COMM_WORLD );
- MPI_Issend( buffer, act_size, MPI_INT, dest, 1, MPI_COMM_WORLD, &r1 );
- MPI_Issend( buffer, act_size, MPI_INT, dest, 2, MPI_COMM_WORLD, &r2 );
- t0 = MPI_Wtime();
-/* flag = 0;*/
-/* while ( (MPI_Wtime() - t0) < MAX_TIME) {*/
-/* MPI_Test( &r1, &flag, &status );*/
-/* if (flag) {*/
-/* Test_Failed(Current_Test);*/
-/* break;*/
-/* }*/
-/* }*/
-/* if (!flag) */
-/* Test_Passed(Current_Test);*/
- MPI_Wait( &r2, &status );
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, dest, 13,
- MPI_BOTTOM, 0, MPI_INT, dest, 13,
- MPI_COMM_WORLD, &status );
- MPI_Wait( &r1, &status );
- Test_Waitforall( );
- {
- int rval = Summarize_Test_Results(); /* Returns number of tests;
- that failed */
- Test_Finalize();
- MPI_Finalize();
- return rval;
- }
-
- } else if (rank == dest) {
- /* Test 1 */
- MPI_Send( buffer, 0, MPI_INT, src, 0, MPI_COMM_WORLD );
- MPI_Recv( buffer, 0, MPI_INT, src, 0, MPI_COMM_WORLD, &status );
- MPI_Recv( buffer, act_size, MPI_INT, src, 2, MPI_COMM_WORLD, &status );
- MPI_Sendrecv( MPI_BOTTOM, 0, MPI_INT, src, 13,
- MPI_BOTTOM, 0, MPI_INT, src, 13,
- MPI_COMM_WORLD, &status );
- MPI_Recv( buffer, act_size, MPI_INT, src, 1, MPI_COMM_WORLD, &status );
-
- Test_Waitforall( );
- Test_Finalize();
- MPI_Finalize();
- } else {
- fprintf(stderr, "*** This program uses exactly 2 processes! ***\n");
- MPI_Abort( MPI_COMM_WORLD, 1 );
- }
-
- return 0;
-}
