teshsuite/smpi/isp/umpire/type-no-free3.c

   1 /* -*- Mode: C; -*- */
   2 /* Creator: Bronis R. de Supinski (bronis@llnl.gov) Tue Dec 10 2002 */
   3
   4 /* type-no-free3.c -- create many types, failing to free some */
   5 /*                    much like type-no-free2.c but use types */
   6 /*                    to communicate and thus exercise umpire more */
   7
   8 #ifndef lint
   9 static char *rcsid =
  10   "$Header: /usr/gapps/asde/cvs-vault/umpire/tests/type-no-free3.c,v 1.2 2003/01/13 18:31:49 bronis Exp $";
  11 #endif
  12
  13 /* NOTE: Some value of ITERATIONS will imply resource exhaustion */
  14 /*       either in Umpire or MPI no matter how things are implemented */
  15 /*       the best we can hope for is to fail gracefully... */
  16 /* 10000 breaks umpire due to running out of memory as of 12/12/02... */
  17 /* FAILURE IS NOT GRACEFUL AS OF THIS TIME... */
  18 #define ITERATIONS                  10
  19 #define TYPES_PER_ITERATION          3
  20 #define TYPES_LOST_PER_ITERATION     1
  21 #define TYPES_TO_COMMIT              1
  22
  23
  24 #include <stdio.h>
  25 #include <string.h>
  26 #include "mpi.h"
  27
  28
  29 #define buf_size 128
  30
  31 int
  32 main (int argc, char **argv)
  33 {
  34   int nprocs = -1;
  35   int rank = -1;
  36   int i, j, partner, buf_j;
  37   int buf[buf_size * TYPES_TO_COMMIT];
  38   char processor_name[128];
  39   int namelen = 128;
  40   MPI_Datatype newtype[TYPES_PER_ITERATION];
  41   MPI_Request reqs[TYPES_TO_COMMIT];
  42   MPI_Status statuses[TYPES_TO_COMMIT];
  43
  44   /* init */
  45   MPI_Init (&argc, &argv);
  46   MPI_Comm_size (MPI_COMM_WORLD, &nprocs);
  47   MPI_Comm_rank (MPI_COMM_WORLD, &rank);
  48   MPI_Get_processor_name (processor_name, &namelen);
  49   printf ("(%d) is alive on %s\n", rank, processor_name);
  50   fflush (stdout);
  51
  52   if (nprocs < 2) {
  53     printf ("Not enough tasks\n");
  54     MPI_Finalize();
  55
  56     return 0;
  57   }
  58
  59   MPI_Barrier (MPI_COMM_WORLD);
  60
  61   if ((nprocs % 2 == 0) ||
  62       (rank != nprocs - 1)) {
  63     partner = (rank % 2) ? rank - 1 : rank + 1;
  64
  65     for (i = 0; i < ITERATIONS; i++) {
  66       for (j = 0; j < TYPES_PER_ITERATION; j++) {
  67         MPI_Type_contiguous (buf_size, MPI_INT, &newtype[j]);
  68
  69         buf_j = j + TYPES_TO_COMMIT - TYPES_PER_ITERATION;
  70
  71         if (buf_j >= 0) {
  72           MPI_Type_commit (&newtype[j]);
  73
  74           if (rank % 2) {
  75             MPI_Irecv (&buf[buf_j*buf_size], 1, newtype[j],
  76                        partner, buf_j, MPI_COMM_WORLD, &reqs[buf_j]);
  77           }
  78           else {
  79             MPI_Isend (&buf[buf_j*buf_size], 1, newtype[j],
  80                        partner, buf_j, MPI_COMM_WORLD, &reqs[buf_j]);
  81           }
  82         }
  83
  84         if (j < TYPES_PER_ITERATION - TYPES_LOST_PER_ITERATION) {
  85           MPI_Type_free (&newtype[j]);
  86         }
  87       }
  88
  89       MPI_Waitall (TYPES_TO_COMMIT, reqs, statuses);
  90     }
  91   }
  92
  93   MPI_Barrier (MPI_COMM_WORLD);
  94
  95   printf ("(%d) Finished normally\n", rank);
  96   MPI_Finalize ();
  97
  98   return 0;
  99 }
 100
 101 /* EOF */