MPICheckpointWriter.h

Go to the documentation of this file.

 
#ifndef MPICHECKPOINTWRITER_H_
#define MPICHECKPOINTWRITER_H_
 
#include <string>
 
#include "plugins/PluginBase.h"
#ifdef ENABLE_MPI
#include "utils/MPI_Info_object.h"
#endif
 
class MPICheckpointWriter : public PluginBase {
public:
    
    MPICheckpointWriter(){}
    MPICheckpointWriter(unsigned long writeFrequency
                       , std::string outputPrefix, bool incremental=true
                       , std::string datarep=std::string(""));
    //~MPICheckpointWriter() {};
    
    void readXML(XMLfileUnits& xmlconfig);
    
    void init(ParticleContainer *particleContainer,
              DomainDecompBase *domainDecomp, Domain *domain);
    void endStep(
            ParticleContainer *particleContainer,
            DomainDecompBase *domainDecomp, Domain *domain,
            unsigned long simstep
    );
    void finish(ParticleContainer *particleContainer,
                DomainDecompBase *domainDecomp, Domain *domain);
    
    std::string getPluginName() {
        return std::string("MPICheckpointWriter");
    }
    static PluginBase* createInstance() { return new MPICheckpointWriter(); }
private:
    static const char _magicVersion[56];
    static const int _endiannesstest;
    
    std::string _outputPrefix;
    unsigned long   _writeFrequency;
    bool    _incremental;
    bool    _appendTimestamp;
    std::string _datarep;
    bool    _measureTime;
#ifdef ENABLE_MPI
    MPI_Info_object _mpiinfo;
#endif
    unsigned long   _particlesbuffersize = 0;
};
 
#endif /*MPICHECKPOINTWRITER_H_*/