blob: d8ef5e133b53ee53f87911b096483af7401b95bd [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
* Copyright (c) 2014-2024, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
* Washington University in St. Louis,
* Beijing Institute of Technology,
* The University of Memphis.
*
* This file is part of NFD (Named Data Networking Forwarding Daemon).
* See AUTHORS.md for complete list of NFD authors and contributors.
*
* NFD is free software: you can redistribute it and/or modify it under the terms
* of the GNU General Public License as published by the Free Software Foundation,
* either version 3 of the License, or (at your option) any later version.
*
* NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along with
* NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
*/
#include "rib/rib.hpp"
#include "tests/test-common.hpp"
#include "tests/daemon/global-io-fixture.hpp"
#include "tests/daemon/rib/create-route.hpp"
#include <boost/lexical_cast.hpp>
namespace nfd::tests {
using rib::Route;
BOOST_AUTO_TEST_SUITE(Rib)
BOOST_FIXTURE_TEST_SUITE(TestRib, GlobalIoFixture)
BOOST_AUTO_TEST_CASE(Parent)
{
rib::Rib rib;
Name name1("/");
rib.insert(name1, createRoute(1, 20));
Name name2("/hello");
rib.insert(name2, createRoute(2, 20));
Name name3("/hello/world");
rib.insert(name3, createRoute(3, 20));
shared_ptr<rib::RibEntry> ribEntry = rib.findParent(name3);
BOOST_REQUIRE(ribEntry != nullptr);
BOOST_CHECK_EQUAL(ribEntry->getRoutes().front().faceId, 2);
ribEntry = rib.findParent(name2);
BOOST_REQUIRE(ribEntry != nullptr);
BOOST_CHECK_EQUAL(ribEntry->getRoutes().front().faceId, 1);
Name name4("/hello/test/foo/bar");
rib.insert(name4, createRoute(3, 20));
ribEntry = rib.findParent(name4);
BOOST_REQUIRE(ribEntry != nullptr);
BOOST_CHECK(ribEntry->getRoutes().front().faceId == 2);
}
BOOST_AUTO_TEST_CASE(Children)
{
rib::Rib rib;
Name name1("/");
rib.insert(name1, createRoute(1, 20));
Name name2("/hello/world");
rib.insert(name2, createRoute(2, 20));
Name name3("/hello/test/foo/bar");
rib.insert(name3, createRoute(3, 20));
BOOST_CHECK_EQUAL((rib.find(name1)->second)->getChildren().size(), 2);
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getChildren().size(), 0);
BOOST_CHECK_EQUAL((rib.find(name3)->second)->getChildren().size(), 0);
Name name4("/hello");
rib.insert(name4, createRoute(4, 20));
BOOST_CHECK_EQUAL((rib.find(name1)->second)->getChildren().size(), 1);
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getChildren().size(), 0);
BOOST_CHECK_EQUAL((rib.find(name3)->second)->getChildren().size(), 0);
BOOST_CHECK_EQUAL((rib.find(name4)->second)->getChildren().size(), 2);
BOOST_CHECK_EQUAL((rib.find(name1)->second)->getChildren().front()->getName(), "/hello");
BOOST_CHECK_EQUAL((rib.find(name4)->second)->getParent()->getName(), "/");
BOOST_REQUIRE(static_cast<bool>((rib.find(name2)->second)->getParent()));
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getParent()->getName(), name4);
BOOST_REQUIRE(static_cast<bool>((rib.find(name3)->second)->getParent()));
BOOST_CHECK_EQUAL((rib.find(name3)->second)->getParent()->getName(), name4);
}
BOOST_AUTO_TEST_CASE(EraseFace)
{
rib::Rib rib;
Route route1 = createRoute(1, 20);
Name name1("/");
rib.insert(name1, route1);
Route route2 = createRoute(2, 20);
Name name2("/hello/world");
rib.insert(name2, route2);
Route route3 = createRoute(1, 20);
Name name3("/hello/world");
rib.insert(name3, route3);
Route route4 = createRoute(1, 20);
Name name4("/not/inserted");
rib.erase(name4, route4);
rib.erase(name1, route1);
BOOST_CHECK(rib.find(name1) == rib.end());
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getRoutes().size(), 2);
rib.erase(name2, route2);
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getRoutes().size(), 1);
BOOST_CHECK_EQUAL((rib.find(name2)->second)->getRoutes().front().faceId, 1);
rib.erase(name3, route3);
BOOST_CHECK(rib.find(name2) == rib.end());
rib.erase(name4, route4);
}
BOOST_AUTO_TEST_CASE(EraseRibEntry)
{
rib::Rib rib;
Name name1("/");
rib.insert(name1, createRoute(1, 20));
Route route2 = createRoute(2, 20);
Name name2("/hello");
rib.insert(name2, route2);
Name name3("/hello/world");
rib.insert(name3, createRoute(1, 20));
shared_ptr<rib::RibEntry> ribEntry1 = rib.find(name1)->second;
shared_ptr<rib::RibEntry> ribEntry2 = rib.find(name2)->second;
shared_ptr<rib::RibEntry> ribEntry3 = rib.find(name3)->second;
BOOST_CHECK(ribEntry1->getChildren().front() == ribEntry2);
BOOST_CHECK(ribEntry3->getParent() == ribEntry2);
rib.erase(name2, route2);
BOOST_CHECK(ribEntry1->getChildren().front() == ribEntry3);
BOOST_CHECK(ribEntry3->getParent() == ribEntry1);
}
BOOST_AUTO_TEST_CASE(Basic)
{
rib::Rib rib;
Route route1;
Name name1("/hello/world");
route1.faceId = 1;
route1.cost = 10;
route1.flags = ndn::nfd::ROUTE_FLAG_CHILD_INHERIT | ndn::nfd::ROUTE_FLAG_CAPTURE;
route1.expires = time::steady_clock::now() + 1500_ms;
rib.insert(name1, route1);
BOOST_CHECK_EQUAL(rib.size(), 1);
rib.insert(name1, route1);
BOOST_CHECK_EQUAL(rib.size(), 1);
Route route2;
Name name2("/hello/world");
route2.faceId = 1;
route2.cost = 100;
route2.flags = ndn::nfd::ROUTE_FLAG_CHILD_INHERIT;
route2.expires = time::steady_clock::now() + 0_s;
rib.insert(name2, route2);
BOOST_CHECK_EQUAL(rib.size(), 1);
route2.faceId = 2;
rib.insert(name2, route2);
BOOST_CHECK_EQUAL(rib.size(), 2);
BOOST_CHECK(rib.find(name1)->second->hasFaceId(route1.faceId));
BOOST_CHECK(rib.find(name1)->second->hasFaceId(route2.faceId));
Name name3("/foo/bar");
rib.insert(name3, route2);
BOOST_CHECK_EQUAL(rib.size(), 3);
route2.origin = ndn::nfd::ROUTE_ORIGIN_AUTOCONF;
rib.insert(name3, route2);
BOOST_CHECK_EQUAL(rib.size(), 4);
rib.erase(name3, route2);
BOOST_CHECK_EQUAL(rib.size(), 3);
Name name4("/hello/world");
rib.erase(name4, route2);
BOOST_CHECK_EQUAL(rib.size(), 3);
route2.origin = ndn::nfd::ROUTE_ORIGIN_APP;
rib.erase(name4, route2);
BOOST_CHECK_EQUAL(rib.size(), 2);
BOOST_CHECK(rib.find(name2, route2) == nullptr);
BOOST_CHECK(rib.find(name1, route1) != nullptr);
Name name5("/hello/world/666");
Name name6("/hello/world/cs/ua/edu");
BOOST_CHECK(rib.findLongestPrefix(name1, route1) != nullptr);
BOOST_CHECK(rib.findLongestPrefix(name5, route1) != nullptr);
BOOST_CHECK(rib.findLongestPrefix(name6, route1) != nullptr);
rib.erase(name1, route1);
BOOST_CHECK_EQUAL(rib.size(), 1);
}
BOOST_AUTO_TEST_CASE(Signals)
{
rib::Rib rib;
Route route;
Name name("/hello/world");
Route route1 = createRoute(1, 20, 10);
Route route2 = createRoute(2, 30, 20);
int nAfterInsertEntryInvocations = 0;
int nAfterAddRouteInvocations = 0;
int nBeforeRemoveRouteInvocations = 0;
int nAfterEraseEntryInvocations = 0;
rib.afterInsertEntry.connect([&] (const auto&) {
BOOST_CHECK_EQUAL(nAfterInsertEntryInvocations, 0);
BOOST_CHECK_EQUAL(nAfterAddRouteInvocations, 0);
BOOST_CHECK(rib.find(name) != rib.end());
nAfterInsertEntryInvocations++;
});
rib.afterAddRoute.connect([&] (const auto&) {
BOOST_CHECK_EQUAL(nAfterInsertEntryInvocations, 1);
BOOST_CHECK(rib.find(name) != rib.end());
BOOST_CHECK(rib.find(name, route) != nullptr);
nAfterAddRouteInvocations++;
});
rib.beforeRemoveRoute.connect([&] (const auto&) {
BOOST_CHECK_EQUAL(nAfterEraseEntryInvocations, 0);
BOOST_CHECK(rib.find(name) != rib.end());
BOOST_CHECK(rib.find(name, route) != nullptr);
nBeforeRemoveRouteInvocations++;
});
rib.afterEraseEntry.connect([&] (const auto&) {
BOOST_CHECK_EQUAL(nBeforeRemoveRouteInvocations, 2);
BOOST_CHECK_EQUAL(nAfterEraseEntryInvocations, 0);
BOOST_CHECK(rib.find(name) == rib.end());
nAfterEraseEntryInvocations++;
});
route = route1;
rib.insert(name, route);
BOOST_CHECK_EQUAL(nAfterInsertEntryInvocations, 1);
BOOST_CHECK_EQUAL(nAfterAddRouteInvocations, 1);
route = route2;
rib.insert(name, route);
BOOST_CHECK_EQUAL(nAfterInsertEntryInvocations, 1);
BOOST_CHECK_EQUAL(nAfterAddRouteInvocations, 2);
route = route1;
rib.erase(name, route);
BOOST_CHECK_EQUAL(nBeforeRemoveRouteInvocations, 1);
BOOST_CHECK_EQUAL(nAfterEraseEntryInvocations, 0);
route = route2;
rib.erase(name, route);
BOOST_CHECK_EQUAL(nBeforeRemoveRouteInvocations, 2);
BOOST_CHECK_EQUAL(nAfterEraseEntryInvocations, 1);
}
BOOST_AUTO_TEST_CASE(Print)
{
rib::Rib rib;
Route root = createRoute(1, 20);
Name name1("/");
root.expires = std::nullopt;
rib.insert(name1, root);
Route route1 = createRoute(2, 20);
Name name2("/hello");
route1.expires = std::nullopt;
rib.insert(name2, route1);
Route route2 = createRoute(3, 20);
Name name3("/hello/world");
route2.expires = std::nullopt;
rib.insert(name3, route2);
const std::string ribStr = std::string(R"TEXT(
RibEntry {
Name: /
Route(faceid: 1, origin: 20, cost: 0, flags: 0x0, never expires)
}
RibEntry {
Name: /hello
Route(faceid: 2, origin: 20, cost: 0, flags: 0x0, never expires)
}
RibEntry {
Name: /hello/world
Route(faceid: 3, origin: 20, cost: 0, flags: 0x0, never expires)
}
)TEXT").substr(1);
BOOST_CHECK_EQUAL(boost::lexical_cast<std::string>(rib), ribStr);
}
BOOST_AUTO_TEST_SUITE_END() // TestRib
BOOST_AUTO_TEST_SUITE_END() // Rib
} // namespace nfd::tests