ParallelDomainCollector.hpp

#ifndef PARALLELDOMAINCOLLECTOR_HPP
#define PARALLELDOMAINCOLLECTOR_HPP

#include "splash/domains/IParallelDomainCollector.hpp"
#include "splash/ParallelDataCollector.hpp"

namespace splash
{

    class ParallelDomainCollector : public IParallelDomainCollector, public ParallelDataCollector
    {
    private:
        static std::string getExceptionString(std::string func, std::string msg,
                const char *info);

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

    public:
        ParallelDomainCollector(MPI_Comm comm, MPI_Info info, const Dimensions topology,
                uint32_t maxFileHandles);

        virtual ~ParallelDomainCollector();

        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,
                const Domain requestDomain,
                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 writeDomain(int32_t id,
                const Dimensions globalSize,
                const Dimensions globalOffset,
                const CollectionType& type,
                uint32_t ndims,
                const Selection select,
                const char* name,
                const Domain globalDomain,
                DomDataClass dataClass,
                const void* buf) throw (DCException);

        void reserveDomain(int32_t id,
                const Dimensions globalSize,
                uint32_t ndims,
                const CollectionType& type,
                const char* name,
                const Domain domain,
                DomDataClass dataClass) throw (DCException);

        void reserveDomain(int32_t id,
                const Dimensions size,
                Dimensions *globalSize,
                Dimensions *globalOffset,
                uint32_t ndims,
                const CollectionType& type,
                const char* name,
                const Domain domain,
                DomDataClass dataClass) throw (DCException);

    protected:

        bool readDomainDataForRank(
                DataContainer *dataContainer,
                DomDataClass *dataClass,
                int32_t id,
                const char* name,
                const Domain requestDomain,
                bool lazyLoad) 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);

    };

}

#endif /* PARALLELDOMAINCOLLECTOR_HPP */