summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJordan Henderson <jhenderson@hdfgroup.org>2017-02-20 15:03:45 (GMT)
committerJordan Henderson <jhenderson@hdfgroup.org>2017-02-20 15:03:45 (GMT)
commit973594f6ae445978697eb2333d14009ddb2ab103 (patch)
tree517ac1e0773c0da545a59d4d36b42448d3db0e03
parent77f155da5d001bee33a63f0199431b8d6bdc4170 (diff)
downloadhdf5-973594f6ae445978697eb2333d14009ddb2ab103.zip
hdf5-973594f6ae445978697eb2333d14009ddb2ab103.tar.gz
hdf5-973594f6ae445978697eb2333d14009ddb2ab103.tar.bz2
Fix issue with uninitialized chunk index during chunk re-insertion into
index
-rw-r--r--src/H5Dmpio.c14
1 files changed, 12 insertions, 2 deletions
diff --git a/src/H5Dmpio.c b/src/H5Dmpio.c
index 210163a..f3c8cb9 100644
--- a/src/H5Dmpio.c
+++ b/src/H5Dmpio.c
@@ -1516,12 +1516,17 @@ H5D__link_chunk_filtered_collective_io(H5D_io_info_t *io_info, const H5D_type_in
for (i = 0; i < collective_chunk_list_num_entries; i++) {
udata.chunk_block = collective_chunk_list[i].new_chunk;
udata.common.scaled = collective_chunk_list[i].chunk_info.scaled;
+ udata.chunk_idx = collective_chunk_list[i].chunk_info.index;
+
+#ifdef PARALLEL_COMPRESS_DEBUG
+ HDfprintf(debug_file, "| Reinserting chunk at index %llu.\n", udata.chunk_idx);
+#endif
if ((index_info.storage->ops->insert)(&index_info, &udata, io_info->dset) < 0)
HGOTO_ERROR(H5E_DATASET, H5E_CANTINSERT, FAIL, "unable to insert chunk address into index")
#ifdef PARALLEL_COMPRESS_DEBUG
- HDfprintf(debug_file, "| Successfully inserted chunk at address %a into the chunk index.\n", udata.chunk_block.offset);
+ HDfprintf(debug_file, "| Successfully inserted chunk at address %a into the chunk index at index %llu.\n", udata.chunk_block.offset, udata.chunk_idx);
#endif
} /* end for */
@@ -2056,12 +2061,17 @@ H5D__multi_chunk_filtered_collective_io(H5D_io_info_t *io_info, const H5D_type_i
for (j = 0; j < collective_chunk_list_num_entries; j++) {
udata.chunk_block = collective_chunk_list[j].new_chunk;
udata.common.scaled = collective_chunk_list[j].chunk_info.scaled;
+ udata.chunk_idx = collective_chunk_list[j].chunk_info.index;
+
+#ifdef PARALLEL_COMPRESS_DEBUG
+ HDfprintf(debug_file, "| Reinserting chunk at index %llu.\n", udata.chunk_idx);
+#endif
if ((index_info.storage->ops->insert)(&index_info, &udata, io_info->dset) < 0)
HGOTO_ERROR(H5E_DATASET, H5E_CANTINSERT, FAIL, "unable to insert chunk address into index")
#ifdef PARALLEL_COMPRESS_DEBUG
- HDfprintf(debug_file, "| Successfully inserted chunk at address %a into the chunk index.\n", udata.chunk_block.offset);
+ HDfprintf(debug_file, "| Successfully inserted chunk at address %a into the chunk index at index %llu.\n", udata.chunk_block.offset, udata.chunk_idx);
#endif
} /* end for */