model_loader.h

Go to the documentation of this file.

 
#pragma once
 
#include <knp/core/impexp.h>
#include <knp/framework/io/input_converter.h>
#include <knp/framework/model.h>
#include <knp/framework/monitoring/observer.h>
 
#include <filesystem>
#include <functional>
#include <memory>
#include <unordered_map>
#include <utility>
#include <vector>
 
 
namespace knp::framework
{
class KNP_DECLSPEC ModelLoader
{
public:
    using InputChannelMap = std::unordered_map<core::UID, io::input::DataGenerator, core::uid_hash>;
 
public:
    ModelLoader(std::shared_ptr<core::Backend> backend, InputChannelMap i_map)
        : backend_(backend), i_map_(std::move(i_map))
    {
    }
 
    ModelLoader(const ModelLoader &) = delete;
    ModelLoader operator=(const ModelLoader &) = delete;
 
public:
    void load(knp::framework::Model &model);
 
public:
    io::output::OutputChannel &get_output_channel(const core::UID &channel_uid);
    const io::output::OutputChannel &get_output_channel(const core::UID &channel_uid) const;
 
    io::input::InputChannel &get_input_channel(const core::UID &channel_uid);
    const io::input::InputChannel &get_input_channel(const core::UID &channel_uid) const;
 
    auto &get_inputs() noexcept { return in_channels_; }
 
    auto &get_outputs() noexcept { return out_channels_; }
 
    std::shared_ptr<core::Backend> get_backend() { return backend_; }
 
private:
    template <typename GenType>
    void init_channels(
        knp::framework::Model &model, const std::unordered_multimap<core::UID, core::UID, core::uid_hash> &channels,
        GenType channel_gen);
 
    void gen_input_channel(knp::framework::Model &model, const core::UID &, const std::vector<core::UID> &);
    void gen_output_channel(knp::framework::Model &model, const core::UID &, const std::vector<core::UID> &);
 
private:
    knp::core::BaseData base_;
    std::shared_ptr<core::Backend> backend_;
 
    InputChannelMap i_map_;
    // cppcheck-suppress unusedStructMember
    std::vector<knp::framework::io::input::InputChannel> in_channels_;
    // cppcheck-suppress unusedStructMember
    std::vector<knp::framework::io::output::OutputChannel> out_channels_;
};
}  // namespace knp::framework