DCParallelDataSet.hpp

#ifndef DCPARALLELDATASET_HPP
#define DCPARALLELDATASET_HPP

#include "splash/core/DCDataSet.hpp"


namespace splash
{

    class DCParallelDataSet : public DCDataSet
    {
    public:

        DCParallelDataSet(const std::string name) :
        DCDataSet(name)
        {
            dsetWriteProperties = H5Pcreate(H5P_DATASET_XFER);
            H5Pset_dxpl_mpio(dsetWriteProperties, H5FD_MPIO_COLLECTIVE);

            dsetReadProperties = H5Pcreate(H5P_DATASET_XFER);
            H5Pset_dxpl_mpio(dsetReadProperties, H5FD_MPIO_COLLECTIVE);

            checkExistence = false;
        }

        virtual ~DCParallelDataSet()
        {
            H5Pclose(dsetWriteProperties);
            H5Pclose(dsetReadProperties);
        }

        void setWriteIndependent()
        {
            H5Pset_dxpl_mpio(dsetWriteProperties, H5FD_MPIO_INDEPENDENT);
        }
    };
}

#endif /* DCPARALLELDATASET_HPP */