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.
107 lines
4.2 KiB
C++
107 lines
4.2 KiB
C++
#include <gtest/gtest.h>
|
|
#include <vanetza/common/manual_runtime.hpp>
|
|
#include <vanetza/geonet/cbr_aggregator.hpp>
|
|
#include <vanetza/geonet/location_table.hpp>
|
|
#include <vanetza/geonet/loctex_g5.hpp>
|
|
#include <vanetza/geonet/mib.hpp>
|
|
#include <vanetza/net/mac_address.hpp>
|
|
|
|
using namespace vanetza;
|
|
using namespace vanetza::geonet;
|
|
using vanetza::dcc::ChannelLoad;
|
|
using std::chrono::seconds;
|
|
|
|
class CbrAggregatorTest : public ::testing::Test
|
|
{
|
|
protected:
|
|
void SetUp() override
|
|
{
|
|
mib.reset(new MIB());
|
|
runtime.reset(new ManualRuntime(Clock::at("2017-05-20 17:36:00")));
|
|
location_table.reset(new LocationTable(*mib, *runtime));
|
|
}
|
|
|
|
void TearDown() override
|
|
{
|
|
location_table.reset();
|
|
runtime.reset();
|
|
mib.reset();
|
|
}
|
|
|
|
Timestamp timestamp_earlier(std::chrono::milliseconds ms)
|
|
{
|
|
Timestamp ts { runtime->now() };
|
|
ts -= Timestamp::duration_type { ms.count() * Timestamp::millisecond() };
|
|
return ts;
|
|
}
|
|
|
|
Address address(unsigned i)
|
|
{
|
|
Address addr;
|
|
addr.mid(create_mac_address(i));
|
|
return addr;
|
|
}
|
|
|
|
std::unique_ptr<LocTEX_G5> loctex_g5(Clock::duration age, double local, double one_hop)
|
|
{
|
|
std::unique_ptr<LocTEX_G5> entry { new LocTEX_G5() };
|
|
entry->local_update = Timestamp { runtime->now() - age };
|
|
entry->dcc_mco.local_cbr(ChannelLoad (local));
|
|
entry->dcc_mco.neighbour_cbr(ChannelLoad (one_hop));
|
|
return entry;
|
|
}
|
|
|
|
std::unique_ptr<Runtime> runtime;
|
|
std::unique_ptr<MIB> mib;
|
|
std::unique_ptr<LocationTable> location_table;
|
|
};
|
|
|
|
TEST_F(CbrAggregatorTest, init)
|
|
{
|
|
CbrAggregator cbra;
|
|
EXPECT_EQ(ChannelLoad(0.0), cbra.get_local_cbr());
|
|
EXPECT_EQ(ChannelLoad(0.0), cbra.get_one_hop_cbr());
|
|
EXPECT_EQ(ChannelLoad(0.0), cbra.get_two_hop_cbr());
|
|
EXPECT_EQ(ChannelLoad(0.0), cbra.get_global_cbr());
|
|
}
|
|
|
|
TEST_F(CbrAggregatorTest, local_cbr)
|
|
{
|
|
CbrAggregator cbra;
|
|
ChannelLoad cbr_target(0.6);
|
|
cbra.aggregate(ChannelLoad(0.1), *location_table, timestamp_earlier(seconds(5)), cbr_target);
|
|
EXPECT_EQ(ChannelLoad(0.1), cbra.get_local_cbr());
|
|
cbra.aggregate(ChannelLoad(0.2), *location_table, timestamp_earlier(seconds(5)), cbr_target);
|
|
EXPECT_EQ(ChannelLoad(0.2), cbra.get_local_cbr());
|
|
|
|
// no one-hop and two-hop values have been provided: previous local measurement should be maximum
|
|
EXPECT_EQ(ChannelLoad(0.1), cbra.get_global_cbr());
|
|
}
|
|
|
|
TEST_F(CbrAggregatorTest, shared_cbr)
|
|
{
|
|
location_table->get_or_create_entry(address(1)).extensions.insert(loctex_g5(seconds(3), 0.45, 0.5));
|
|
location_table->get_or_create_entry(address(2)).extensions.insert(loctex_g5(seconds(2), 0.4, 0.2));
|
|
location_table->get_or_create_entry(address(3)).extensions.insert(loctex_g5(seconds(4), 0.4, 0.45));
|
|
location_table->get_or_create_entry(address(4)).extensions.insert(loctex_g5(seconds(2), 0.35, 0.25));
|
|
|
|
CbrAggregator cbra;
|
|
cbra.aggregate(ChannelLoad(0.32), *location_table, timestamp_earlier(seconds(10)), ChannelLoad(0.6));
|
|
EXPECT_DOUBLE_EQ(0.32, cbra.get_local_cbr().value());
|
|
EXPECT_NEAR(0.4, cbra.get_one_hop_cbr().value(), 0.005); // second largest (one hop average = 0.4 < target = 0.6)
|
|
EXPECT_NEAR(0.45, cbra.get_two_hop_cbr().value(), 0.005); // second largest (two hop average = 0.35 < target = 0.6)
|
|
EXPECT_NEAR(0.45, cbra.get_global_cbr().value(), 0.005);
|
|
|
|
cbra.aggregate(ChannelLoad(0.34), *location_table, timestamp_earlier(seconds(10)), ChannelLoad(0.3));
|
|
EXPECT_DOUBLE_EQ(0.34, cbra.get_local_cbr().value());
|
|
EXPECT_NEAR(0.45, cbra.get_one_hop_cbr().value(), 0.005); // largest (two hop average above target)
|
|
EXPECT_NEAR(0.5, cbra.get_two_hop_cbr().value(), 0.005); // largest (two hop average above target)
|
|
EXPECT_NEAR(0.5, cbra.get_global_cbr().value(), 0.005);
|
|
|
|
cbra.aggregate(ChannelLoad(0.3), *location_table, timestamp_earlier(seconds(2)), ChannelLoad(0.3));
|
|
EXPECT_DOUBLE_EQ(0.3, cbra.get_local_cbr().value());
|
|
EXPECT_NEAR(0.4, cbra.get_one_hop_cbr().value(), 0.005); // average (0.375) above target: largest
|
|
EXPECT_NEAR(0.2, cbra.get_two_hop_cbr().value(), 0.005); // average (0.225) below target: second largest
|
|
EXPECT_NEAR(0.4, cbra.get_global_cbr().value(), 0.005);
|
|
}
|