RoutableMessage.hxx

Go to the documentation of this file.

 
#ifndef _OPENLCB_ROUTABLEMESSAGE_HXX_
#define _OPENLCB_ROUTABLEMESSAGE_HXX_
 
// ============ WARNING =============
// This code is not used currently.
// ============ WARNING =============
 
#include "utils/Hub.hxx"
#include "utils/SimpleQueue.hxx"
 
namespace openlcb
{
 
struct RoutableMessage;
 
//typedef shared_ptr<HubData>
 
struct RoutableMessage
{
    openlcb::NodeHandle dst_;
    Buffer<GenMessage> *genMessage_;
    Buffer<HubData> *tcpMessage_;
    TypedQueue<Buffer<HubData>> gcMessages_;
    TypedQueue<Buffer<CanHubData>> canMessages_;
    void *skipMember_;
    RoutableMessage()
        : genMessage_ {nullptr}
        , tcpMessage_ {nullptr}
    {
    }
 
    ~RoutableMessage()
    {
        if (genMessage_)
        {
            genMessage_->unref();
        }
        if (tcpMessage_)
        {
            tcpMessage_->unref();
        }
        while (!gcMessages_.empty())
        {
            auto *f = gcMessages_.pop_front();
            f->unref();
        }
        while (!canMessages_.empty())
        {
            auto *f = canMessages_.pop_front();
            f->unref();
        }
    }
};
 
} // namespace openlcb
 
#endif // _OPENLCB_ROUTABLEMESSAGE_HXX_