summaryrefslogtreecommitdiffstats
path: root/perform
diff options
context:
space:
mode:
authorAlbert Cheng <acheng@hdfgroup.org>2001-12-21 05:58:41 (GMT)
committerAlbert Cheng <acheng@hdfgroup.org>2001-12-21 05:58:41 (GMT)
commit7defffc7e4415e24c18cbb9dea1bd99c9798784e (patch)
tree58fd2096f6c2f6c1f70410643999fee07499f0a2 /perform
parent5560c64e256d3fc064072afbc0e3f14add0bc5a5 (diff)
downloadhdf5-7defffc7e4415e24c18cbb9dea1bd99c9798784e.zip
hdf5-7defffc7e4415e24c18cbb9dea1bd99c9798784e.tar.gz
hdf5-7defffc7e4415e24c18cbb9dea1bd99c9798784e.tar.bz2
[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)
Diffstat (limited to 'perform')
-rw-r--r--perform/pio_perf.c11
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: