DomainCollector.hpp

#ifndef DOMAINCOLLECTOR_HPP
#define DOMAINCOLLECTOR_HPP

#include "splash/domains/IDomainCollector.hpp"
#include "splash/SerialDataCollector.hpp"
#include "splash/Dimensions.hpp"
#include "splash/Selection.hpp"
#include "splash/DCException.hpp"

namespace splash
{

    class DomainCollector : public IDomainCollector, public SerialDataCollector
    {
    public:
        DomainCollector(uint32_t maxFileHandles);

        virtual ~DomainCollector();

        Domain getGlobalDomain(int32_t id,
                const char* name) throw (DCException);

        Domain getLocalDomain(int32_t id,
                const char* name) throw (DCException);

        DataContainer *readDomain(int32_t id,
                const char* name,
                Domain domain,
                DomDataClass* dataClass,
                bool lazyLoad = false) throw (DCException);

        void readDomainLazy(DomainData *domainData) throw (DCException);

        void writeDomain(int32_t id,
                const CollectionType& type,
                uint32_t ndims,
                const Selection select,
                const char* name,
                const Domain localDomain,
                const Domain globalDomain,
                DomDataClass dataClass,
                const void* buf) throw (DCException);

        void appendDomain(int32_t id,
                const CollectionType& type,
                size_t count,
                const char *name,
                const Domain localDomain,
                const Domain globalDomain,
                const void *buf) throw (DCException);

        void appendDomain(int32_t id,
                const CollectionType& type,
                size_t count,
                size_t offset,
                size_t striding,
                const char *name,
                const Domain localDomain,
                const Domain globalDomain,
                const void *buf) throw (DCException);

    protected:
        void writeDomainAttributes(
                int32_t id,
                const char *name,
                DomDataClass dataClass,
                const Domain localDomain,
                const Domain globalDomain) throw (DCException);

        bool readDomainInfoForRank(
                Dimensions mpiPosition,
                int32_t id,
                const char* name,
                const Domain requestDomain,
                Domain &fileDomain) throw (DCException);

        bool readDomainDataForRank(
                DataContainer *dataContainer,
                DomDataClass *dataClass,
                Dimensions mpiPosition,
                int32_t id,
                const char* name,
                const Domain requestDomain,
                bool lazyLoad) throw (DCException);

        void readGridInternal(
                DataContainer *dataContainer,
                Dimensions mpiPosition,
                int32_t id,
                const char* name,
                const Domain &clientDomain,
                const Domain &requestDomain) throw (DCException);

        void readPolyInternal(
                DataContainer *dataContainer,
                Dimensions mpiPosition,
                int32_t id,
                const char* name,
                const Dimensions &dataSize,
                const Domain &clientDomain,
                bool lazyLoad) throw (DCException);

        void readGlobalSizeFallback(int32_t id,
                const char *dataName,
                hsize_t* data,
                Dimensions *mpiPosition) throw (DCException);

        void readGlobalOffsetFallback(int32_t id,
                const char *dataName,
                hsize_t* data,
                Dimensions *mpiPosition) throw (DCException);
    };

}

#endif /* DOMAINCOLLECTOR_HPP */