SourceReactor.hh

#pragma once

#include <reactor-sdk/reactor-sdk.hh>
using namespace std;
using namespace sdk;

class SourceReactor : public Reactor {
public:
    struct Parameters : public SystemParametersStandalone<int> {
        REACTOR_PARAMETER(int, iterations, "Number of iterations", 1, 100, 10);
        REACTOR_PARAMETER(int, n_ports, "Size of multiports", 1, 10, 1);

        Parameters(Reactor *container)
            :   SystemParametersStandalone<int>(container) {
            register_parameters (iterations, n_ports);
        }
    };
private:
    LogicalAction<int> sch{"sch", this};
    
    Parameters parameters{this};

    REACTION_SCOPE_START(SourceReactor, Parameters)
        std::string name = "Source";
        int itr = 0;
        int rsp_itr = 0;

        void add_reactions(SourceReactor *reactor);
    REACTION_SCOPE_END(this, parameters)

public:                                                         
    SourceReactor(const std::string &name, Environment *env)
        : Reactor(name, env) {}
    SourceReactor(const std::string &name, Reactor *container)
        : Reactor(name, container) {}

    MultiportInput<int> rsp{"rsp", this};
    MultiportOutput<int> req{"req", this};

    void construction() override;
    void wiring() override;
};