[svn-r4748] Purpose:

    Bug fix
Description:
    All processes, including those that are not part of the PIO test
    sub-communicator, all attempted to run the PIO test.  It resulted
    in failures for those processes that are not supposed to get involved.
Solution:
    The function that creates the sub-communicator also returns a
    parameter indicating if the process is included in the PIO test
    sub-communicator.  Then only those processes will really do the
    PIO test.
Platforms tested:
    eirene (pp) and Modi4 (pp)

1 files changed, 8 insertions, 3 deletions

diff --git a/perform/pio_perf.c b/perform/pio_perf.c
index 731df9b..104cf5f 100644
--- a/perform/pio_perf.c
+++ b/perform/pio_perf.c
@@ -217,7 +217,7 @@ static void run_test_loop(FILE *output, struct options *options);
 static int run_test(FILE *output, iotype iot, parameters parms);
 static void get_minmax(minmax *mm);
 static minmax accumulate_minmax_stuff(minmax *mm, int count);
-static int create_comm_world(int num_procs);
+static int create_comm_world(int num_procs, int *doing_pio);
 static int destroy_comm_world(void);
 static void output_report(FILE *output, const char *fmt, ...);
 static void print_indent(register FILE *output, register int indent);
@@ -305,6 +305,7 @@ run_test_loop(FILE *output, struct options *opts)
 {
     parameters parms;
     long num_procs;
+    int		doing_pio;		/* if this process is doing PIO */
     int io_runs = PIO_HDF5 | PIO_MPI | PIO_RAW; /* default to run all tests */
 
     if (opts->io_types & ~0x7) {
@@ -332,10 +333,12 @@ run_test_loop(FILE *output, struct options *opts)
 
         parms.num_procs = num_procs;
 
-        if (create_comm_world(parms.num_procs) != SUCCESS) {
+        if (create_comm_world(parms.num_procs, &doing_pio) != SUCCESS) {
             /* do something harsh */
         }
 
+	/* only processes doing PIO will run the tests */
+	if (doing_pio){
         output_report(output, "Number of processors = %ld\n", parms.num_procs);
 
         /* multiply the xfer buffer size by 2 for each loop iteration */
@@ -364,6 +367,7 @@ run_test_loop(FILE *output, struct options *opts)
         if (destroy_comm_world() != SUCCESS) {
             /* do something harsh */
         }
+	}
     }
 }
 
@@ -525,7 +529,7 @@ accumulate_minmax_stuff(minmax *mm, int count)
  * Modifications:
  */
 static int
-create_comm_world(int num_procs)
+create_comm_world(int num_procs, int *doing_pio)
 {
     /* MPI variables */
     int     mrc, ret_value;     /* return values                */
@@ -567,6 +571,7 @@ create_comm_world(int num_procs)
     MPI_Comm_rank(pio_comm_g, &pio_mpi_rank_g);
 
 done:
+    *doing_pio = color;
     return ret_value;
 
 error_done: