teshsuite/smpi/isp/umpire/persistent3.c

   1 /* -*- Mode: C; -*- */
   2 /* Creator: Bronis R. de Supinski (bronis@llnl.gov) Thu Nov 30 2000 */
   3 /* persistent3.c -- do some MPI persistent calls */
   4 /* including freeing an active request - the effect of which */
   5 /* is implementation dependent - usually a detected error */
   6 /* in this test, the error is made in only task rank 0... */
   7
   8 #include <stdio.h>
   9 #include "mpi.h"
  10
  11 #define buf_size 128
  12
  13 int
  14 main (int argc, char **argv)
  15 {
  16   int nprocs = -1;
  17   int rank = -1;
  18   char processor_name[128];
  19   int namelen = 128;
  20   int buf0[buf_size];
  21   int buf1[buf_size];
  22   MPI_Request aReq[2], free_req;
  23   MPI_Status aStatus[2];
  24
  25   MPI_Status status;
  26
  27   /* init */
  28   MPI_Init (&argc, &argv);
  29   MPI_Comm_size (MPI_COMM_WORLD, &nprocs);
  30   MPI_Comm_rank (MPI_COMM_WORLD, &rank);
  31   MPI_Get_processor_name (processor_name, &namelen);
  32   printf ("(%d) is alive on %s\n", rank, processor_name);
  33   fflush (stdout);
  34
  35   MPI_Barrier (MPI_COMM_WORLD);
  36
  37   if (nprocs < 2) {
  38       printf ("not enough tasks\n");
  39   }
  40   else {
  41     if (rank == 0) {
  42       memset (buf0, 0, buf_size);
  43
  44       MPI_Send_init (buf0, buf_size, MPI_INT, 1, 0, MPI_COMM_WORLD, &aReq[0]);
  45       MPI_Recv_init (buf1, buf_size, MPI_INT, 1, 0, MPI_COMM_WORLD, &aReq[1]);
  46
  47       MPI_Start (&aReq[0]);
  48       MPI_Start (&aReq[1]);
  49
  50       MPI_Waitall (2, aReq, aStatus);
  51
  52       memset (buf0, 1, buf_size);
  53
  54       MPI_Startall (2, aReq);
  55
  56       /* free an active request... */
  57       free_req = aReq[1];
  58       MPI_Request_free (&free_req);
  59
  60       MPI_Waitall (2, aReq, aStatus);
  61     }
  62     else if (rank == 1) {
  63       memset (buf1, 1, buf_size);
  64
  65       MPI_Recv_init (buf0, buf_size, MPI_INT, 0, 0, MPI_COMM_WORLD, &aReq[0]);
  66       MPI_Send_init (buf1, buf_size, MPI_INT, 0, 0, MPI_COMM_WORLD, &aReq[1]);
  67
  68       MPI_Start (&aReq[0]);
  69       MPI_Start (&aReq[1]);
  70
  71       MPI_Waitall (2, aReq, aStatus);
  72
  73       memset (buf1, 0, buf_size);
  74
  75       MPI_Startall (2, aReq);
  76
  77       MPI_Waitall (2, aReq, aStatus);
  78     }
  79   }
  80
  81   MPI_Barrier (MPI_COMM_WORLD);
  82
  83   MPI_Request_free (&aReq[0]);
  84
  85   MPI_Finalize ();
  86   printf ("(%d) Finished normally\n", rank);
  87 }
  88
  89 /* EOF */