H5Converter_misc.hpp

Go to the documentation of this file.

/*
 *  Copyright (c) 2022 Blue Brain Project
 *
 *  Distributed under the Boost Software License, Version 1.0.
 *    (See accompanying file LICENSE_1_0.txt or copy at
 *          http://www.boost.org/LICENSE_1_0.txt)
 *
 */
#pragma once
 
#include <type_traits>
 
#include "H5Inspector_misc.hpp"
#include "../H5DataType.hpp"
 
namespace HighFive {
namespace details {
 
template <class T>
struct is_std_string {
    static constexpr bool value =
        std::is_same<typename inspector<T>::base_type, std::string>::value;
};
 
template <class T, class V = void>
struct enable_shallow_copy
    : public std::enable_if<!is_std_string<T>::value && inspector<T>::is_trivially_copyable, V> {};
 
template <class T, class V = void>
struct enable_deep_copy
    : public std::enable_if<!is_std_string<T>::value && !inspector<T>::is_trivially_copyable, V> {};
 
template <class T, class V = void>
struct enable_string_copy: public std::enable_if<is_std_string<T>::value, V> {};
 
 
template <typename T, bool IsReadOnly>
struct ShallowCopyBuffer {
    using type = unqualified_t<T>;
    using hdf5_type =
        typename std::conditional<IsReadOnly,
                                  typename std::add_const<typename inspector<T>::hdf5_type>::type,
                                  typename inspector<T>::hdf5_type>::type;
 
    ShallowCopyBuffer() = delete;
 
    explicit ShallowCopyBuffer(typename std::conditional<IsReadOnly, const T&, T&>::type val)
        : ptr(inspector<T>::data(val)){};
 
    hdf5_type* getPointer() const {
        return ptr;
    }
 
    hdf5_type* begin() const {
        return getPointer();
    }
 
    void unserialize(T& /* val */) const {
        /* nothing to do. */
    }
 
  private:
    hdf5_type* ptr;
};
 
template <class T>
struct DeepCopyBuffer {
    using type = unqualified_t<T>;
    using hdf5_type = typename inspector<type>::hdf5_type;
 
    explicit DeepCopyBuffer(const std::vector<size_t>& _dims)
        : buffer(inspector<T>::getSize(_dims))
        , dims(_dims) {}
 
    hdf5_type* getPointer() {
        return buffer.data();
    }
 
    hdf5_type const* getPointer() const {
        return buffer.data();
    }
 
    hdf5_type* begin() {
        return getPointer();
    }
 
    hdf5_type const* begin() const {
        return getPointer();
    }
 
    void unserialize(T& val) const {
        inspector<type>::unserialize(buffer.data(), dims, val);
    }
 
  private:
    std::vector<hdf5_type> buffer;
    std::vector<size_t> dims;
};
 
enum class BufferMode { Read, Write };
 
 
inline size_t char_buffer_size(char const* const str, size_t max_string_length) {
    for (size_t i = 0; i <= max_string_length; ++i) {
        if (str[i] == '\0') {
            return i;
        }
    }
 
    return max_string_length;
}
 
 
template <typename T, BufferMode buffer_mode>
struct StringBuffer {
    using type = unqualified_t<T>;
    using hdf5_type = typename inspector<type>::hdf5_type;
 
    class StringView {
      public:
        StringView(StringBuffer<T, buffer_mode>& _buffer, size_t _i)
            : buffer(_buffer)
            , i(_i) {}
 
        void assign(char const* data, size_t length, StringPadding pad) {
            if (buffer.isVariableLengthString()) {
                if (pad == StringPadding::NullTerminated) {
                    buffer.variable_length_pointers[i] = data;
                } else {
                    buffer.variable_length_buffer[i] = std::string(data, length);
                    buffer.variable_length_pointers[i] = buffer.variable_length_buffer[i].data();
                }
            } else if (buffer.isFixedLengthString()) {
                // If the buffer is fixed-length and null-terminated, then
                // `buffer.string_length` doesn't include the null-character.
                if (length > buffer.string_length) {
                    throw std::invalid_argument("String length too big.");
                }
 
                memcpy(&buffer.fixed_length_buffer[i * buffer.string_size], data, length);
            }
        }
 
      private:
        StringBuffer<T, buffer_mode>& buffer;
        size_t i;
    };
 
 
    class StringConstView {
      public:
        StringConstView(const StringBuffer<T, buffer_mode>& _buffer, size_t _i)
            : buffer(_buffer)
            , i(_i) {}
 
        char const* data() const {
            if (buffer.isVariableLengthString()) {
                return buffer.variable_length_pointers[i];
            } else {
                return &buffer.fixed_length_buffer[i * buffer.string_size];
            }
        }
 
        size_t length() const {
            if (buffer.isNullTerminated()) {
                return char_buffer_size(data(), buffer.string_length);
            } else {
                return buffer.string_length;
            }
        }
 
      private:
        const StringBuffer<T, buffer_mode>& buffer;
        size_t i;
    };
 
 
    class Iterator {
      public:
        Iterator(StringBuffer<T, buffer_mode>& _buffer, size_t _pos)
            : buffer(_buffer)
            , pos(_pos) {}
 
        Iterator operator+(size_t n_strings) const {
            return Iterator(buffer, pos + n_strings);
        }
 
        void operator+=(size_t n_strings) {
            pos += n_strings;
        }
 
        StringView operator*() {
            return StringView(buffer, pos);
        }
 
        StringConstView operator*() const {
            return StringConstView(buffer, pos);
        }
 
      private:
        StringBuffer<T, buffer_mode>& buffer;
        size_t pos;
    };
 
    StringBuffer(std::vector<size_t> _dims, const DataType& _file_datatype)
        : file_datatype(_file_datatype.asStringType())
        , padding(file_datatype.getPadding())
        , string_size(file_datatype.isVariableStr() ? size_t(-1) : file_datatype.getSize())
        , string_length(string_size - size_t(isNullTerminated()))
        , dims(_dims) {
        if (string_size == 0 && isNullTerminated()) {
            throw DataTypeException(
                "Fixed-length, null-terminated need at least one byte to store the "
                "null-character.");
        }
 
        auto n_strings = compute_total_size(dims);
        if (isVariableLengthString()) {
            variable_length_buffer.resize(n_strings);
            variable_length_pointers.resize(n_strings);
        } else {
            char pad = padding == StringPadding::SpacePadded ? ' ' : '\0';
            fixed_length_buffer.assign(n_strings * string_size, pad);
        }
    }
 
    bool isVariableLengthString() const {
        return file_datatype.isVariableStr();
    }
 
    bool isFixedLengthString() const {
        return file_datatype.isFixedLenStr();
    }
 
    bool isNullTerminated() const {
        return file_datatype.getPadding() == StringPadding::NullTerminated;
    }
 
 
    void* getPointer() {
        if (file_datatype.isVariableStr()) {
            return variable_length_pointers.data();
        } else {
            return fixed_length_buffer.data();
        }
    }
 
    Iterator begin() {
        return Iterator(*this, 0ul);
    }
 
    void unserialize(T& val) {
        inspector<type>::unserialize(begin(), dims, val);
    }
 
  private:
    StringType file_datatype;
    StringPadding padding;
    size_t string_size;    // Size of buffer required to store the string.
                           // Meaningful for fixed length strings only.
    size_t string_length;  // Semantic length of string.
    std::vector<size_t> dims;
 
    std::vector<char> fixed_length_buffer;
    std::vector<std::string> variable_length_buffer;
    std::vector<
        typename std::conditional<buffer_mode == BufferMode::Write, const char, char>::type*>
        variable_length_pointers;
};
 
 
template <typename T, typename Enable = void>
struct Writer;
 
template <typename T>
struct Writer<T, typename enable_shallow_copy<T>::type>: public ShallowCopyBuffer<T, true> {
  private:
    using super = ShallowCopyBuffer<T, true>;
 
  public:
    explicit Writer(const T& val, const DataType& /* file_datatype */)
        : super(val){};
};
 
template <typename T>
struct Writer<T, typename enable_deep_copy<T>::type>: public DeepCopyBuffer<T> {
    explicit Writer(const T& val, const DataType& /* file_datatype */)
        : DeepCopyBuffer<T>(inspector<T>::getDimensions(val)) {
        inspector<T>::serialize(val, this->begin());
    }
};
 
template <typename T>
struct Writer<T, typename enable_string_copy<T>::type>: public StringBuffer<T, BufferMode::Write> {
    explicit Writer(const T& val, const DataType& _file_datatype)
        : StringBuffer<T, BufferMode::Write>(inspector<T>::getDimensions(val), _file_datatype) {
        inspector<T>::serialize(val, this->begin());
    }
};
 
template <typename T, typename Enable = void>
struct Reader;
 
template <typename T>
struct Reader<T, typename enable_shallow_copy<T>::type>: public ShallowCopyBuffer<T, false> {
  private:
    using super = ShallowCopyBuffer<T, false>;
    using type = typename super::type;
 
  public:
    Reader(const std::vector<size_t>&, type& val, const DataType& /* file_datatype */)
        : super(val) {}
};
 
template <typename T>
struct Reader<T, typename enable_deep_copy<T>::type>: public DeepCopyBuffer<T> {
  private:
    using super = DeepCopyBuffer<T>;
    using type = typename super::type;
 
  public:
    Reader(const std::vector<size_t>& _dims, type&, const DataType& /* file_datatype */)
        : super(_dims) {}
};
 
 
template <typename T>
struct Reader<T, typename enable_string_copy<T>::type>: public StringBuffer<T, BufferMode::Write> {
  public:
    explicit Reader(const std::vector<size_t>& _dims,
                    const T& /* val */,
                    const DataType& _file_datatype)
        : StringBuffer<T, BufferMode::Write>(_dims, _file_datatype) {}
};
 
struct data_converter {
    template <typename T>
    static Writer<T> serialize(const typename inspector<T>::type& val,
                               const DataType& file_datatype) {
        return Writer<T>(val, file_datatype);
    }
 
    template <typename T>
    static Reader<T> get_reader(const std::vector<size_t>& dims,
                                T& val,
                                const DataType& file_datatype) {
        // TODO Use bufferinfo for recursive_ndim
        auto effective_dims = details::squeezeDimensions(dims, inspector<T>::recursive_ndim);
        inspector<T>::prepare(val, effective_dims);
        return Reader<T>(effective_dims, val, file_datatype);
    }
};
 
}  // namespace details
}  // namespace HighFive