modelRunState.h

Go to the documentation of this file.

 
// Copyright (c) 2013-2015 OpenM++
// This code is licensed under the MIT license (see LICENSE.txt for details)
 
#ifndef MODEL_RUN_STATE_H
#define MODEL_RUN_STATE_H
 
#include <chrono>
#include <list>
#include <mutex>
#include <forward_list>
using namespace std;
 
#include "libopenm/omModel.h"
#include "helper.h"
 
namespace openm
{
    class ModelRunState : public virtual IModelRunState, private RunState
    {
    public:
        ModelRunState(void) : RunState() { };
 
        ModelStatus status(void) override;
 
        bool isFinal(void) override;
 
        bool isError(void) override;
 
        bool isShutdownOrFinal(void) override;
 
        RunState get(void) override;
 
        ModelStatus updateStatus(ModelStatus i_status) override;
 
        void updateProgress(int i_count, double i_value = 0.0) override;
 
    private:
        recursive_mutex theMutex;                       // mutex to lock status upadte operations
 
    private:
        ModelRunState(const ModelRunState & i_state) = delete;
        ModelRunState & operator=(const ModelRunState & i_state) = delete;
 
    };
 
    class RunStateHolder
    {
    public:
        RunStateHolder(void) { }
 
        tuple<bool, RunState> get(int i_runId, int i_subId);
 
        void add(int i_runId, int i_subId) { add(i_runId, i_subId, RunState()); };
 
        void add(int i_runId, int i_subId, RunState i_state);
 
        ModelStatus updateStatus(int i_runId, int i_subId, ModelStatus i_status, bool i_isFinalUpdate = true);
 
        bool updateProgress(int i_runId, int i_subId, int i_count, double i_value);
 
        const map<pair<int, int>, RunState> saveUpdated(bool i_isNow = false);
 
        IRowBaseVec saveToRowVector(int i_runId);
 
        const RunState fromRowVector(const IRowBaseVec & i_src);
 
    private:
        recursive_mutex theMutex;                           // mutex to lock access operations
        map<pair<int, int>, RunState> stateMap;             // store of current runs state for all sub-values, key: (run id, sub-value id) pair
        map<pair<int, int>, RunState> updateStateMap;       // run states updated since last save call
        chrono::system_clock::time_point lastSaveTime = chrono::system_clock::time_point::min();   // last time of save
 
    private:
        RunStateHolder(const RunStateHolder & i_state) = delete;
        RunStateHolder & operator=(const RunStateHolder & i_state) = delete;
    };
}
 
#endif  // MODEL_RUN_STATE_H