mirror/hdf5
2
0
Fork 0
mirror of https://github.com/HDFGroup/hdf5.git synced 2025-03-25 17:00:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

[svn-r5376] Description:

Browse Source 
Added the calculation and printing (when debug >=3) of the
    MPI_write/read statistics.
Platforms tested:
    modi4
This commit is contained in:
Albert Cheng 2002-05-07 12:34:59 -05:00
parent c038daacec
commit 3a9882a2e5
1 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
perform/pio_perf.c
View File

@ -413,12 +413,16 @@ run_test(iotype iot, parameters parms)
int comm_size;
long raw_size;
minmax total_mm;
minmax *write_mpi_mm_table;
minmax *write_mm_table;
minmax *write_gross_mm_table;
minmax *read_mpi_mm_table;
minmax *read_mm_table;
minmax *read_gross_mm_table;
minmax write_mpi_mm = {0.0, 0.0, 0.0, 0};
minmax write_mm = {0.0, 0.0, 0.0, 0};
minmax write_gross_mm = {0.0, 0.0, 0.0, 0};
minmax read_mpi_mm = {0.0, 0.0, 0.0, 0};
minmax read_mm = {0.0, 0.0, 0.0, 0};
minmax read_gross_mm = {0.0, 0.0, 0.0, 0};
@ -441,12 +445,19 @@ run_test(iotype iot, parameters parms)
MPI_Comm_size(pio_comm_g, &comm_size);
write_mpi_mm_table = malloc(parms.num_iters * sizeof(minmax));
write_mm_table = malloc(parms.num_iters * sizeof(minmax));
write_gross_mm_table = malloc(parms.num_iters * sizeof(minmax));
read_mpi_mm_table = malloc(parms.num_iters * sizeof(minmax));
read_mm_table = malloc(parms.num_iters * sizeof(minmax));
read_gross_mm_table = malloc(parms.num_iters * sizeof(minmax));
for (i = 0; i < parms.num_iters; ++i) {
write_mpi_mm_table[i].min = 0.0;
write_mpi_mm_table[i].max = 0.0;
write_mpi_mm_table[i].sum = 0.0;
write_mpi_mm_table[i].num = 0;
write_mm_table[i].min = 0.0;
write_mm_table[i].max = 0.0;
write_mm_table[i].sum = 0.0;
@ -457,6 +468,11 @@ run_test(iotype iot, parameters parms)
write_gross_mm_table[i].sum = 0.0;
write_gross_mm_table[i].num = 0;
read_mpi_mm_table[i].min = 0.0;
read_mpi_mm_table[i].max = 0.0;
read_mpi_mm_table[i].sum = 0.0;
read_mpi_mm_table[i].num = 0;
read_mm_table[i].min = 0.0;
read_mm_table[i].max = 0.0;
read_mm_table[i].sum = 0.0;
@ -475,6 +491,12 @@ run_test(iotype iot, parameters parms)
MPI_Barrier(pio_comm_g);
res = do_pio(parms);
/* gather all of the "mpi write" times */
t = get_time(res.timers, HDF5_MPI_WRITE);
get_minmax(&write_mpi_mm, t);
write_mpi_mm_table[i] = write_mpi_mm;
/* gather all of the "write" times */
t = get_time(res.timers, HDF5_FINE_WRITE_FIXED_DIMS);
get_minmax(&write_mm, t);
@ -487,6 +509,12 @@ run_test(iotype iot, parameters parms)
write_gross_mm_table[i] = write_gross_mm;
/* gather all of the "mpi read" times */
t = get_time(res.timers, HDF5_MPI_READ);
get_minmax(&read_mpi_mm, t);
read_mpi_mm_table[i] = read_mpi_mm;
/* gather all of the "read" times */
t = get_time(res.timers, HDF5_FINE_READ_FIXED_DIMS);
get_minmax(&read_mm, t);
@ -501,6 +529,14 @@ run_test(iotype iot, parameters parms)
pio_time_destroy(res.timers);
}
/* show mpi write statics */
if (pio_debug_level >= 3) {
/* output all of the times for all iterations */
print_indent(3);
output_report("MPI Write details:\n");
output_all_info(write_mpi_mm_table, parms.num_iters, 4);
}
/* accumulate and output the max, min, and average "write" times */
if (pio_debug_level >= 3) {
/* output all of the times for all iterations */
@ -543,6 +579,14 @@ run_test(iotype iot, parameters parms)
output_report("Average Throughput: %.2f MB/s\n",
total_mm.sum / total_mm.num);
/* show mpi read statics */
if (pio_debug_level >= 3) {
/* output all of the times for all iterations */
print_indent(3);
output_report("MPI Read details:\n");
output_all_info(read_mpi_mm_table, parms.num_iters, 4);
}
/* accumulate and output the max, min, and average "read" times */
if (pio_debug_level >= 3) {
/* output all of the times for all iterations */
@ -586,6 +630,8 @@ run_test(iotype iot, parameters parms)
total_mm.sum / total_mm.num);
/* clean up our mess */
free(write_mpi_mm_table);
free(read_mpi_mm_table);
free(write_mm_table);
free(read_mm_table);
free(write_gross_mm_table);