DefaultOutputPlugin.hpp

Go to the documentation of this file.

 
#ifndef OPENSWMM_ENGINE_DEFAULT_OUTPUT_PLUGIN_HPP
#define OPENSWMM_ENGINE_DEFAULT_OUTPUT_PLUGIN_HPP
 
#include "../../../include/openswmm/plugin_sdk/IOutputPlugin.hpp"
 
#include <string>
#include <atomic>
#include <cstdio>
#include <vector>
 
namespace openswmm {

class DefaultOutputPlugin final : public IOutputPlugin {
public:
    explicit DefaultOutputPlugin(std::string out_path);
    ~DefaultOutputPlugin() override = default;
 
    // -----------------------------------------------------------------------
    // IOutputPlugin interface
    // -----------------------------------------------------------------------
 
    PluginState state() const noexcept override { return state_; }
 
    int initialize(const std::vector<std::string>& init_args,
                   const IPluginComponentInfo* info) override;
 
    int validate(const SimulationContext& ctx) override;
 
    int prepare(const SimulationContext& ctx) override;
 
    int update(const SimulationSnapshot& snapshot) override;
 
    int finalize(const SimulationContext& ctx) override;
 
    const char* last_error_message() const noexcept override {
        return last_error_.c_str();
    }
 
private:
    std::string         out_path_;
    PluginState         state_      = PluginState::UNLOADED;
    std::string         last_error_;
    int                 step_count_ = 0;
 
    FILE*               out_file_   = nullptr;
    int                 n_subcatch_ = 0;
    int                 n_nodes_    = 0;
    int                 n_links_    = 0;
    int                 n_polluts_  = 0;
    int                 n_subcatch_vars_ = 0;
    int                 n_node_vars_ = 0;
    int                 n_link_vars_ = 0;
    int                 flow_units_code_ = 0;
    long                id_start_pos_     = 0;
    long                input_start_pos_  = 0;
    long                output_start_pos_ = 0;
    int                 n_periods_  = 0;
 
    // Static-object header is written from the SimulationContext (internal
    // units), so it still needs these two factors. Per-timestep results arrive
    // pre-converted by the engine boundary and need no plugin-side conversion.
    double ucf_length_    = 1.0;
    double ucf_landarea_  = 1.0;
 
    // Per-object report flags, captured during prepare() from SimulationContext
    std::vector<char> subcatch_rpt_flag_;
    std::vector<char> node_rpt_flag_;
    std::vector<char> link_rpt_flag_;
 
    static constexpr int MAGIC_NUMBER = 516114522;
    static constexpr int VERSION      = 60000;     // SWMM 6.0.000
    static constexpr int MAX_SYS_RESULTS = 15;
 
    void writeHeader(const SimulationContext& ctx);
    void writeID(const char* id);
    void writeInt4(int value);
    void writeReal4(float value);
    void writeReal8(double value);
};
 
} /* namespace openswmm */
 
#endif /* OPENSWMM_ENGINE_DEFAULT_OUTPUT_PLUGIN_HPP */