async_datagram_test_helper.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_ASYNC_DATAGRAM_TEST_HELPER_HXX_
#define _UTILS_ASYNC_DATAGRAM_TEST_HELPER_HXX_
 
#include "utils/async_if_test_helper.hxx"
#include "openlcb/Datagram.hxx"
#include "openlcb/DatagramCan.hxx"
 
namespace openlcb {
 
class AsyncDatagramTest : public AsyncNodeTest
{
protected:
    AsyncDatagramTest() : datagram_support_(ifCan_.get(), 10, 2)
    {
    }
 
    CanDatagramService datagram_support_;
};
 
Pool* const g_incoming_datagram_allocator = mainBufferPool;
 
class TwoNodeDatagramTest : public AsyncDatagramTest
{
protected:
    enum
    {
        OTHER_NODE_ID = TEST_NODE_ID + 0x100,
        OTHER_NODE_ALIAS = 0x225,
    };
 
    NodeHandle other_handle()
    {
        NodeHandle ret;
        ret.id = OTHER_NODE_ID;
        ret.alias = OTHER_NODE_ALIAS;
        return ret;
    }
 
    void setup_other_node(bool separate_if)
    {
        if (separate_if)
        {
            otherIfCan_.reset(
                new IfCan(&g_executor, &can_hub0, 10, 10, 5));
            otherIfCan_->add_addressed_message_support();
            otherNodeIf_ = otherIfCan_.get();
            otherDatagramSupport_.reset(
                new CanDatagramService(otherNodeIf_, 10, 2));
            otherNodeDatagram_ = otherDatagramSupport_.get();
        }
        else
        {
            otherNodeIf_ = ifCan_.get();
            otherNodeDatagram_ = &datagram_support_;
        }
        run_x([this]() {
            otherNodeIf_->local_aliases()->add(OTHER_NODE_ID, OTHER_NODE_ALIAS);
        });
        expect_packet(":X19100225N02010D000103;"); // node up
        otherNode_.reset(new DefaultNode(otherNodeIf_, OTHER_NODE_ID));
        wait();
    }
 
    void expect_other_node_lookup()
    {
        expect_packet(":X1070222AN02010D000103;"); // looking for DST node
        expect_packet(":X10701225N02010D000103;"); // found dst node
        // expect_packet(":X1949022AN02010D000103;"); // hard-looking for DST node
        // expect_packet(":X19170225N02010D000103;"); // node ID verified
    }
 
    std::unique_ptr<DefaultNode> otherNode_;
    // Second objects if we want a bus-traffic test.
    std::unique_ptr<IfCan> otherIfCan_;
    IfCan* otherNodeIf_;
    std::unique_ptr<CanDatagramService> otherDatagramSupport_;
    CanDatagramService* otherNodeDatagram_;
};
 
} // namespace
 
 
#endif // _UTILS_ASYNC_DATAGRAM_TEST_HELPER_HXX_