Ashin Walpola
d107534eb2
obu-firmware builds against the vanetza-idf C-ITS library, which until now came from the colleague's microbu-esp32c5 tree beside the repository and was not tracked here, so a clone of this repository could not build the firmware it ships. The library alone is now part of obu-firmware, as obu-firmware/external/vanetza-idf: their external/vanetza-idf at commit cf4b99f, unchanged (9775 files; see its PROVENANCE.md). CMake takes it from there by default; -DVANETZA_IDF_DIR still points the build elsewhere. The rest of the colleague's tree (their own VAM firmware, PKI tooling, station-link Python tools, the V2X2MAP bridge) stays out of this repository and gitignored; nothing is pushed to their repository. NOTES.md, docs/06, TODO.md and the pcap verifier's usage line point at the new location.
83 lines
2.9 KiB
C++
83 lines
2.9 KiB
C++
#include <gtest/gtest.h>
|
|
#include <vanetza/common/manual_runtime.hpp>
|
|
#include <vanetza/geonet/mib.hpp>
|
|
#include <vanetza/geonet/router.hpp>
|
|
#include <boost/optional.hpp>
|
|
|
|
#include <vanetza/geonet/tests/fake_interfaces.hpp>
|
|
|
|
using namespace vanetza;
|
|
using namespace vanetza::geonet;
|
|
|
|
TEST(Router, shb_round_trip)
|
|
{
|
|
// mock interfaces
|
|
FakeRequestInterface req_ifc;
|
|
FakeTransportInterface ind_ifc;
|
|
|
|
// init router
|
|
ManagementInformationBase mib;
|
|
ManualRuntime runtime;
|
|
Router router(runtime, mib);
|
|
Address gn_addr;
|
|
gn_addr.mid(MacAddress { 0, 0, 0, 0, 0, 1});
|
|
router.set_address(gn_addr);
|
|
router.set_access_interface(&req_ifc);
|
|
router.set_transport_handler(UpperProtocol::IPv6, &ind_ifc);
|
|
|
|
// initialize shb request
|
|
ShbDataRequest shb_request(mib);
|
|
shb_request.upper_protocol = UpperProtocol::IPv6;
|
|
|
|
// create down packet
|
|
const ByteBuffer send_payload { 89, 27, 1, 4, 18, 85 };
|
|
std::unique_ptr<DownPacket> packet_down { new DownPacket() };
|
|
packet_down->layer(OsiLayer::Transport) = ByteBuffer(send_payload);
|
|
|
|
// get count of current requests in buffer
|
|
const auto requests_before = req_ifc.m_requests;
|
|
|
|
// add request with our test down packet
|
|
auto confirm = router.request(shb_request, std::move(packet_down));
|
|
|
|
// check expected behavior
|
|
ASSERT_TRUE(confirm.accepted());
|
|
EXPECT_EQ(requests_before + 1, req_ifc.m_requests);
|
|
|
|
// extract payload from last received request/packet
|
|
ASSERT_TRUE(req_ifc.m_last_packet.get() != nullptr);
|
|
ByteBuffer net_payload;
|
|
for (const auto layer : osi_layer_range<OsiLayer::Network, OsiLayer::Application>()) {
|
|
ByteBuffer tmp;
|
|
req_ifc.m_last_packet->layer(layer).convert(tmp);
|
|
std::copy(tmp.begin(), tmp.end(), std::back_inserter(net_payload));
|
|
}
|
|
ASSERT_EQ(req_ifc.m_last_packet->size(OsiLayer::Network, OsiLayer::Application), net_payload.size());
|
|
|
|
// create up packet
|
|
std::unique_ptr<UpPacket> packet_up { new UpPacket(CohesivePacket(net_payload, OsiLayer::Network)) };
|
|
ASSERT_EQ(
|
|
size(*req_ifc.m_last_packet, min_osi_layer(), max_osi_layer()),
|
|
size(*packet_up, OsiLayer::Network)
|
|
);
|
|
|
|
// get count of current indications
|
|
const auto indications_before = ind_ifc.m_indications;
|
|
|
|
// indicate up packet
|
|
router.indicate(std::move(packet_up), {1, 2, 3, 4, 5, 6}, cBroadcastMacAddress);
|
|
EXPECT_EQ(indications_before + 1, ind_ifc.m_indications);
|
|
|
|
// get indicated packet
|
|
ASSERT_NE(nullptr, ind_ifc.m_last_packet.get());
|
|
CohesivePacket* received_payload_ptr = boost::get<CohesivePacket>(ind_ifc.m_last_packet.get());
|
|
|
|
// check expected behavior
|
|
ASSERT_NE(nullptr, received_payload_ptr);
|
|
auto received_payload_range = (*received_payload_ptr)[OsiLayer::Transport];
|
|
const ByteBuffer received_payload = ByteBuffer {
|
|
received_payload_range.begin(), received_payload_range.end()
|
|
};
|
|
EXPECT_EQ(send_payload, received_payload);
|
|
}
|