ProtocolIdentification.hxx

Go to the documentation of this file.

 
#ifndef _OPENLCB_PROTOCOLIDENTIFICATION_HXX_
#define _OPENLCB_PROTOCOLIDENTIFICATION_HXX_
 
#include "openlcb/Defs.hxx"
//#include "openlcb/
 
namespace openlcb
{
 
class ProtocolIdentificationHandler : public IncomingMessageStateFlow
{
public:
    ProtocolIdentificationHandler(Node* node, uint64_t supported)
        : IncomingMessageStateFlow(node->iface())
        , node_(node)
        , payload_()
    {
        /* store the supported protocol as a payload */
        payload_ = node_id_to_buffer(supported);
 
        /* register our interest in the Protocol Identification Protocol */
        node_->iface()->dispatcher()->register_handler(
            this, Defs::MTI_PROTOCOL_SUPPORT_INQUIRY, Defs::MTI_EXACT);
    }
 
    ~ProtocolIdentificationHandler()
    {
        /* register our interest in the Protocol Identification Protocol */
        node_->iface()->dispatcher()->unregister_handler(
            this, Defs::MTI_PROTOCOL_SUPPORT_INQUIRY, Defs::MTI_EXACT);
    }
 
private:
    Action entry() OVERRIDE
    {
        if (nmsg()->dstNode != node_)
        {
            /* not for me */
            return release_and_exit();
        }
        /* hanlde messager */
        //LOG(INFO, "PIP Handle");
        return allocate_and_call(
            node_->iface()->addressed_message_write_flow(),
            STATE(fill_response_buffer));
    }
 
    Action fill_response_buffer()
    {
        /* grab our allocated buffer */
        auto *b = get_allocation_result(
            node_->iface()->addressed_message_write_flow());
        /* fill in response. */
        b->data()->reset(Defs::MTI_PROTOCOL_SUPPORT_REPLY, node_->node_id(), nmsg()->src, payload_);
 
        /* pass the response to the addressed message write flow */
        node_->iface()->addressed_message_write_flow()->send(b);
 
        return release_and_exit();
    }
 
    Node *node_;
 
    Payload payload_;
 
    DISALLOW_COPY_AND_ASSIGN(ProtocolIdentificationHandler);
};
 
} /* namespace openlcb */
 
#endif // _OPENLCB_PROTOCOLIDENTIFICATION_HXX_