teshsuite/smpi/isp/umpire/persistent2.c

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