add: support for H5Dflush and H5Drefesh. (#69)

This commit adds a wrappers for H5D{flush,refresh} and
adds two new methods `DataSet::{flush,refresh}`.

Author: radistmorse

include/highfive/H5DataSet.hpp

@@ -70,6 +70,15 @@ class DataSet: public Object,
     /// \param dims New size of the dataset
     void resize(const std::vector<size_t>& dims);
 
+#if H5_VERSION_GE(1, 10, 0)
+    /// \brief flush
+    void flush();
+#endif
+
+#if H5_VERSION_GE(1, 10, 2)
+    /// \brief refresh
+    void refresh();
+#endif
 
     /// \brief Get the dimensions of the whole DataSet.
     ///       This is a shorthand for getSpace().getDimensions()

include/highfive/bits/H5DataSet_misc.hpp

@@ -59,4 +59,16 @@ inline void DataSet::resize(const std::vector<size_t>& dims) {
     detail::h5d_set_extent(getId(), real_dims.data());
 }
 
+#if H5_VERSION_GE(1, 10, 0)
+inline void DataSet::flush() {
+    detail::h5d_flush(_hid);
+}
+#endif
+
+#if H5_VERSION_GE(1, 10, 2)
+inline void DataSet::refresh() {
+    detail::h5d_refresh(_hid);
+}
+#endif
+
 }  // namespace HighFive

include/highfive/bits/h5d_wrapper.hpp

@@ -74,6 +74,28 @@ inline herr_t h5d_write(hid_t dset_id,
     return err;
 }
 
+#if H5_VERSION_GE(1, 10, 0)
+inline herr_t h5d_flush(hid_t dset_id) {
+    herr_t err = H5Dflush(dset_id);
+    if (err < 0) {
+        HDF5ErrMapper::ToException<DataSetException>("Unable to flush the dataset.");
+    }
+
+    return err;
+}
+#endif
+
+#if H5_VERSION_GE(1, 10, 2)
+inline herr_t h5d_refresh(hid_t dset_id) {
+    herr_t err = H5Drefresh(dset_id);
+    if (err < 0) {
+        HDF5ErrMapper::ToException<DataSetException>("Unable to refresh the dataset.");
+    }
+
+    return err;
+}
+#endif
+
 inline haddr_t h5d_get_offset(hid_t dset_id) {
     uint64_t addr = H5Dget_offset(dset_id);
     if (addr == HADDR_UNDEF) {

tests/unit/tests_high_five_base.cpp

@@ -1588,6 +1588,9 @@ void readWriteShuffleDeflateTest() {
 
         dataset.write(array);
 
+#if H5_VERSION_GE(1, 10, 0)
+        dataset.flush();
+#endif
         file.flush();
     }
 
@@ -1651,6 +1654,9 @@ void readWriteSzipTest() {
 
         dataset.write(array);
 
+#if H5_VERSION_GE(1, 10, 0)
+        dataset.flush();
+#endif
         file.flush();
     }
 

tests/unit/tests_high_five_data_type.cpp

@@ -101,6 +101,10 @@ TEST_CASE("HighFiveCompounds") {
 
         file.flush();
 
+#if H5_VERSION_GE(1, 10, 2)
+        dataset.refresh();
+#endif
+
         std::vector<CSL1> result;
         dataset.select({0}, {2}).read(result);
 
@@ -120,6 +124,11 @@ TEST_CASE("HighFiveCompounds") {
         dataset.write(csl);
 
         file.flush();
+
+#if H5_VERSION_GE(1, 10, 2)
+        dataset.refresh();
+#endif
+
         std::vector<CSL2> result = {{{1, 1, 1}, {2, 3, 4}}};
         dataset.select({0}, {2}).read(result);
 
@@ -357,6 +366,10 @@ TEST_CASE("HighFiveEnum") {
 
         file.flush();
 
+#if H5_VERSION_GE(1, 10, 2)
+        dataset.refresh();
+#endif
+
         Position result;
         dataset.select(ElementSet({0})).read(result);
 
@@ -377,6 +390,10 @@ TEST_CASE("HighFiveEnum") {
 
         file.flush();
 
+#if H5_VERSION_GE(1, 10, 2)
+        dataset.refresh();
+#endif
+
         std::vector<Direction> result;
         dataset.read(result);