HdfProxy.h

/*-----------------------------------------------------------------------
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.  See the NOTICE file
distributed with this work for additional information
regarding copyright ownership.  The ASF licenses this file
to you under the Apache License, Version 2.0 (the
"License"; you may not use this file except in compliance
with the License.  You may obtain a copy of the License at
 
  http://www.apache.org/licenses/LICENSE-2.0
 
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express or implied.  See the License for the
specific language governing permissions and limitations
under the License.
-----------------------------------------------------------------------*/
#pragma once
 
#include "AbstractHdfProxy.h"
 
#include <unordered_map>
 
namespace EML2_NS
{
    class HdfProxy : public AbstractHdfProxy
    {
    public:
 
        HdfProxy(gsoap_resqml2_0_1::eml20__DataObjectReference* partialObject) : AbstractHdfProxy(partialObject) {}
 
        HdfProxy(const COMMON_NS::DataObjectReference& dor) : AbstractHdfProxy(dor) {}
 
        virtual ~HdfProxy() { close(); }
 
        void open() override;
 
        DLL_IMPORT_OR_EXPORT bool isOpened() const final { return hdfFile != -1; }
 
        void close() final;
 
        COMMON_NS::AbstractObject::numericalDatatypeEnum getNumericalDatatype(const std::string& groupName) final;
 
        int getHdfDatatypeClassInDataset(const std::string& datasetName) final;
 
        void writeItemizedListOfList(const std::string& groupName,
            const std::string& name,
            COMMON_NS::AbstractObject::numericalDatatypeEnum cumulativeLengthDatatype,
            const void* cumulativeLength,
            uint64_t cumulativeLengthSize,
            COMMON_NS::AbstractObject::numericalDatatypeEnum elementsDatatype,
            const void* elements,
            uint64_t elementsSize) final;
 
        std::vector<uint32_t> getElementCountPerDimension(const std::string & datasetName) final;
 
        DLL_IMPORT_OR_EXPORT void setCompressionLevel(unsigned int newCompressionLevel) final {
            compressionLevel = newCompressionLevel > 9 ? 9 : newCompressionLevel;
        }
 
        void writeArrayNd(const std::string& groupName,
            const std::string& name,
            COMMON_NS::AbstractObject::numericalDatatypeEnum datatype,
            const void* values,
            const uint64_t* numValuesInEachDimension,
            unsigned int numDimensions) final;
 
        void createArrayNd(
            const std::string& groupName,
            const std::string& name,
            COMMON_NS::AbstractObject::numericalDatatypeEnum datatype,
            const uint64_t* numValuesInEachDimension,
            unsigned int numDimensions
        ) final;
 
        void writeArrayNdSlab(
            const std::string& groupName,
            const std::string& name,
            COMMON_NS::AbstractObject::numericalDatatypeEnum datatype,
            const void* values,
            const uint64_t* numValuesInEachDimension,
            const uint64_t* offsetValuesInEachDimension,
            unsigned int numDimensions
        ) final;
 
        void writeGroupAttributes(const std::string& groupName,
            const std::vector<std::string>& attributeNames,
            const std::vector<std::string>& values) final;
 
        void writeGroupAttribute(const std::string& groupName,
            const std::string& attributeName,
            const std::vector<std::string>& values) final;
 
        void writeGroupAttributes(const std::string& groupName,
            const std::vector<std::string>& attributeNames,
            const std::vector<double>& values) final;
 
        void writeGroupAttributes(const std::string& groupName,
            const std::vector<std::string>& attributeNames,
            const std::vector<int>& values) final;
 
        void writeDatasetAttributes(const std::string& datasetName,
            const std::vector<std::string>& attributeNames,
            const std::vector<std::string>& values) final;
 
        void writeDatasetAttribute(const std::string& datasetName,
            const std::string& attributeName,
            const std::vector<std::string>& values) final;
 
        void writeDatasetAttributes(const std::string& datasetName,
            const std::vector<std::string>& attributeNames,
            const std::vector<double>& values) final;
 
        void writeDatasetAttributes(const std::string& datasetName,
            const std::vector<std::string>& attributeNames,
            const std::vector<int>& values) final;
 
        std::string readStringAttribute(const std::string& obj_name,
            const std::string& attr_name) const final;
 
        std::vector<std::string> readStringArrayAttribute(const std::string& obj_name,
            const std::string& attr_name) const final;
 
        double readDoubleAttribute(const std::string& obj_name,
            const std::string& attr_name) const final;
 
        int64_t readInt64Attribute(const std::string& obj_name,
            const std::string& attr_name) const final;
 
        void readArrayNdOfDoubleValues(const std::string& datasetName, double* values) final;
 
        void readArrayNdOfDoubleValues(
            const std::string& datasetName,
            double* values,
            uint64_t const* numValuesInEachDimension,
            uint64_t const* offsetInEachDimension,
            unsigned int numDimensions
        ) final;
 
        void readArrayNdOfDoubleValues(
            const std::string& datasetName, double* values,
            uint64_t const* blockCountPerDimension,
            uint64_t const* offsetInEachDimension,
            uint64_t const* strideInEachDimension,
            uint64_t const* blockSizeInEachDimension,
            unsigned int numDimensions) final;
 
        void selectArrayNdOfValues(
            const std::string& datasetName,
            uint64_t const* blockCountPerDimension,
            uint64_t const* offsetInEachDimension,
            uint64_t const* strideInEachDimension,
            uint64_t const* blockSizeInEachDimension,
            unsigned int numDimensions,
            bool newSelection,
            hdf5_hid_t& dataset,
            hdf5_hid_t& filespace) final;
 
        void readArrayNdOfDoubleValues(
            hdf5_hid_t dataset,
            hdf5_hid_t filespace,
            void* values,
            uint64_t slabSize) final;
 
        void readArrayNdOfFloatValues(const std::string& datasetName, float* values) final;
 
        void readArrayNdOfFloatValues(
            const std::string& datasetName,
            float* values,
            uint64_t const* numValuesInEachDimension,
            uint64_t const* offsetInEachDimension,
            unsigned int numDimensions
        ) final;
 
        void readArrayNdOfInt64Values(const std::string& datasetName, int64_t* values) final;
 
        void readArrayNdOfInt64Values(
            const std::string& datasetName,
            int64_t* values,
            uint64_t const* numValuesInEachDimension,
            uint64_t const* offsetInEachDimension,
            unsigned int numDimensions) final;
 
        void readArrayNdOfUInt64Values(const std::string& datasetName, uint64_t* values) final;
 
        void readArrayNdOfIntValues(const std::string& datasetName, int* values) final;
 
        void readArrayNdOfIntValues(
            const std::string& datasetName,
            int* values,
            uint64_t const* numValuesInEachDimension,
            uint64_t const* offsetInEachDimension,
            unsigned int numDimensions
        ) final;
 
        void readArrayNdOfUIntValues(const std::string& datasetName, unsigned int* values) final;
 
        void readArrayNdOfShortValues(const std::string& datasetName, short* values) final;
 
        void readArrayNdOfUShortValues(const std::string& datasetName, unsigned short* values) final;
 
        void readArrayNdOfInt8Values(const std::string& datasetName, int8_t* values) final;
 
        void readArrayNdOfUInt8Values(const std::string& datasetName, uint8_t* values) final;
 
        bool exist(const std::string& absolutePathInHdfFile) const final;
 
        bool isCompressed(const std::string& datasetName) final;
 
        std::vector<uint32_t> getElementCountPerChunkDimension(const std::string & datasetName) final;
 
    protected:
 
        HdfProxy(gsoap_resqml2_0_1::_eml20__EpcExternalPartReference* fromGsoap) :
            AbstractHdfProxy(fromGsoap) {}
 
        HdfProxy(const std::string & packageDirAbsolutePath, const std::string & externalFilePath, COMMON_NS::DataObjectRepository::openingMode hdfPermissionAccess = COMMON_NS::DataObjectRepository::openingMode::READ_ONLY);
 
        void readArrayNdOfValues(const std::string& datasetName, void* values, hdf5_hid_t datatype);
 
        void readArrayNdOfValues(
            const std::string& datasetName,
            void* values,
            uint64_t const* numValuesInEachDimension,
            uint64_t const* offsetInEachDimension,
            unsigned int numDimensions,
            hdf5_hid_t datatype);
 
        void readArrayNdOfValues(
            const std::string& datasetName,
            void* values,
            uint64_t const* blockCountPerDimension,
            uint64_t const* offsetInEachDimension,
            uint64_t const* strideInEachDimension,
            uint64_t const* blockSizeInEachDimension,
            unsigned int numDimensions,
            hdf5_hid_t datatype);
 
        void readArrayNdOfValues(
            hdf5_hid_t dataset,
            hdf5_hid_t filespace,
            void* values,
            uint64_t slabSize,
            hdf5_hid_t datatype);
 
        void writeUuidAttribute();
 
        hdf5_hid_t openOrCreateGroup(const std::string& groupName);
 
        hdf5_hid_t hdfFile = -1;
 
        unsigned int compressionLevel = 0;
 
        std::unique_ptr<hdf5_hid_t> dsetPlistId;
 
        std::unordered_map< std::string, hdf5_hid_t > openedGroups;
    };
}