openlcb/NetworkState.hxx

 
#ifndef _OPENLCB_OLCBNETWORKSTATE_HXX_
#define _OPENLCB_OLCBNETWORKSTATE_HXX_
 
#include "utils/NetworkState.hxx"
 
namespace openlcb
{
 
class NetworkState : public ::NetworkState
{
public:
    NetworkState(Node *node, WriteHelper *write_helper,
                     uint64_t event_on, uint64_t event_off)
        : writeHelper_(write_helper)
        , bit_(node, event_on, event_off, true)
        , bitPC_(&bit_)
    {
    }
 
private:
    void set_callback(std::function<void()> cb) override
    {
        bit_.set_change_callback(cb);
    }
 
    void toggle(Notifiable *done) override
    {
        bit_.toggle_state();
        bitPC_.SendEventReport(writeHelper_, done);
    }
 
    void set_state(bool state, Notifiable *done) override
    {
        bit_.set_state(state);
        bitPC_.SendEventReport(writeHelper_, done);
    }
 
    State get_state() override
    {
        switch (bit_.get_current_state())
        {
            case EventState::VALID:
                return State::VALID;
            case EventState::INVALID:
                return State::INVALID;
            default:
                return State::UNKNOWN;
        }
    }
 
    bool is_state_known() override
    {
        return bit_.is_network_state_known();
    }
 
    void initiate_query(BarrierNotifiable *done) override
    {
        bitPC_.SendQueryConsumer(writeHelper_, done);
    }
 
    void reset() override
    {
        bit_.reset();
    }
 
    WriteHelper *writeHelper_;
 
    CallbackNetworkInitializedBit bit_;
 
    BitEventPC bitPC_;
};
 
} // namespace openlcb
 
#endif // _OPENLCB_OLCBNETWORKSTATE_HXX_