FMTparallelwriter.hpp

Go to the documentation of this file.

#ifndef FMTparallelwriter_H_INCLUDED
#define FMTparallelwriter_H_INCLUDED
#include "FMTmodelparser.hpp"
#include <vector>
#include <string>
#include <memory>
#include <boost/thread/recursive_mutex.hpp>
#include "FMTutility.hpp"
 
#ifdef FMTWITHGDAL
class GDALDataset;
class OGRLayer;
#endif
 
namespace Models {
    class FMTmodel;
}
 
 
namespace Parallel
{
    // DocString: FMTparallelwriter
    class FMTEXPORT FMTparallelwriter : public Parser::FMTmodelparser
    {
        // DocString: FMTparallelwriter::outputstowrite
        std::vector<Core::FMToutput>outputstowrite;
        #ifdef FMTWITHGDAL
        // DocString: FMTparallelwriter::resultsdataset
        GDALDataset* resultsdataset;
        // DocString: FMTparallelwriter::resultslayer
        std::map<std::string,OGRLayer*> resultslayer;
        // DocString: FMTparallelwriter::driftlayer
        OGRLayer* driftlayer;
        #endif
        // DocString: FMTparallelwriter::mtx
        mutable boost::recursive_mutex mtx;
        // DocString: FMTparallelwriter::resultsminimaldrift;
        double resultsminimaldrift;
        // DocString: FMTparallelwriter::outputslevel
        Core::FMToutputlevel outputslevel;
        // DocString: FMTparallelwriter::alllayeroptions
        std::vector<std::string> alllayeroptions;
        // DocString: FMTparallelwriter::outputfirstperiod
        int outputfirstperiod;
        // DocString: FMTparallelwriter::outputlastperiod;
        int outputlastperiod;
        // DocString: FMTparallelwriter::projectdirectory;
        std::string projectdirectory;
        // DocString: FMTparallelwriter::projectname;
        std::string projectname;
    protected:
        // DocString: FMTparallelwriter::getdriftprobability()
        const std::map<std::string, std::map<double, std::vector<double>>>getdriftprobability(
            const std::map<std::string, std::vector<std::vector<double>>>& globalvalues,
            const std::map<std::string, std::vector<std::vector<double>>>& localvalues,
            const bool lower = true) const;
    public:
        // DocString: FMTparallelwriter::FMTparallelwriter()
        FMTparallelwriter() = default;
        // DocString: ~FMTparallelwrite()
        virtual ~FMTparallelwriter();
        // DocString: FMTparallelwriter::FMTparallelwriter(const FMTparallelwriter&)
        FMTparallelwriter(const FMTparallelwriter& rhs) = default;
        // DocString: FMTparallelwriter::operator=()
        FMTparallelwriter& operator = (const FMTparallelwriter& rhs) = default;
        // DocString: FMTparallelwriter::FMTparallelwriter(const std::string&,const std::string&,const std::vector<Core::FMToutput>&,const Models::FMTmodel&)
        FMTparallelwriter(const std::string& location,
            const std::string& driver,
            const std::vector<Core::FMToutput>& outputs,
            const std::vector<Models::FMTmodel*>& allmodels,
            std::vector<std::string>layersoptions = std::vector<std::string>(),
            double minimaldrift = 0.5,
            Core::FMToutputlevel outputlevel = Core::FMToutputlevel::totalonly);
        // DocString: FMTparallelwriter::FMTparallelwriter(const std::string&,const std::string&,std::vector<std::string>,Core::FMToutputlevel)
        FMTparallelwriter(const std::string& location,
            const std::string& driver,
            Core::FMToutputlevel outputlevel = Core::FMToutputlevel::totalonly,
            std::vector<std::string>layersoptions = std::vector<std::string>(),
            int firstperiod=1,
            int lastperiod=1,
            std::string primaryfilelocation = std::string());
        // DocString: FMTparallelwriter::setlayer
        void setlayer(const Models::FMTmodel* model);
        // DocString: FMTparallelwriter::write()
        void write(const std::string& modelname,
            const std::map<std::string, std::vector<std::vector<double>>>& results,
            const int& firstperiod, const int& lastperiod, const int& iteration) const;
        // DocString: FMTparallelwriter::getresults()
        std::map<std::string, std::vector<std::vector<double>>> getresults(const std::unique_ptr<Models::FMTmodel>& modelptr, const int& firstperiod, const int& lastperiod) const;
        // DocString: FMTparallelwriter::setdriftprobability()
        void setdriftprobability(const std::string& globalmodel, const std::string& localmodel) const;
        // DocString: FMTparallelwriter::getandwrite()
        void getandwrite(const std::unique_ptr<Models::FMTmodel>& modelptr, const std::vector<Core::FMToutput>& loutputs);
        // DocString: FMTparallelwriter::close()
        void close() noexcept;
        };
}
#endif