blob: 5d2d27e126ab3817deda423359b8912823e90009 [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/**
* Copyright (c) 2014-2020, The University of Memphis,
* Regents of the University of California
*
* This file is part of NLSR (Named-data Link State Routing).
* See AUTHORS.md for complete list of NLSR authors and contributors.
*
* NLSR 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.
*
* NLSR 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
* NLSR, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
*
**/
#include "route/fib.hpp"
#include "../test-common.hpp"
#include "../control-commands.hpp"
#include "adjacency-list.hpp"
#include "conf-parameter.hpp"
#include <ndn-cxx/util/dummy-client-face.hpp>
namespace nlsr {
namespace test {
using std::shared_ptr;
class FibFixture : public UnitTestTimeFixture
{
public:
FibFixture()
: face(std::make_shared<ndn::util::DummyClientFace>(m_ioService, m_keyChain))
, conf(*face, m_keyChain)
, interests(face->sentInterests)
{
Adjacent neighbor1(router1Name, ndn::FaceUri(router1FaceUri), 0, Adjacent::STATUS_ACTIVE, 0, router1FaceId);
adjacencies.insert(neighbor1);
Adjacent neighbor2(router2Name, ndn::FaceUri(router2FaceUri), 0, Adjacent::STATUS_ACTIVE, 0, router2FaceId);
adjacencies.insert(neighbor2);
Adjacent neighbor3(router3Name, ndn::FaceUri(router3FaceUri), 0, Adjacent::STATUS_ACTIVE, 0, router3FaceId);
adjacencies.insert(neighbor3);
conf.setMaxFacesPerPrefix(2);
fib = std::make_shared<Fib>(*face, m_scheduler, adjacencies, conf, m_keyChain);
fib->setEntryRefreshTime(1);
}
public:
std::shared_ptr<ndn::util::DummyClientFace> face;
std::shared_ptr<Fib> fib;
AdjacencyList adjacencies;
ConfParameter conf;
std::vector<ndn::Interest>& interests;
static const ndn::Name router1Name;
static const ndn::Name router2Name;
static const ndn::Name router3Name;
static const std::string router1FaceUri;
static const std::string router2FaceUri;
static const std::string router3FaceUri;
static const uint32_t router1FaceId;
static const uint32_t router2FaceId;
static const uint32_t router3FaceId;
};
const ndn::Name FibFixture::router1Name = "/ndn/router1";
const ndn::Name FibFixture::router2Name = "/ndn/router2";
const ndn::Name FibFixture::router3Name = "/ndn/router3";
const std::string FibFixture::router1FaceUri = "udp4://10.0.0.1";
const std::string FibFixture::router2FaceUri = "udp4://10.0.0.2";
const std::string FibFixture::router3FaceUri = "udp4://10.0.0.3";
const uint32_t FibFixture::router1FaceId = 1;
const uint32_t FibFixture::router2FaceId = 2;
const uint32_t FibFixture::router3FaceId = 3;
BOOST_FIXTURE_TEST_SUITE(TestFib, FibFixture)
BOOST_AUTO_TEST_CASE(NextHopsAdd)
{
NextHop hop1(router1FaceUri, 10);
NextHop hop2(router2FaceUri, 20);
NexthopList hops;
hops.addNextHop(hop1);
hops.addNextHop(hop2);
fib->update("/ndn/name", hops);
face->processEvents(ndn::time::milliseconds(-1));
// Should register faces 1 and 2 for /ndn/name
BOOST_REQUIRE_EQUAL(interests.size(), 2);
ndn::nfd::ControlParameters extractedParameters;
ndn::Name::Component verb;
std::vector<ndn::Interest>::iterator it = interests.begin();
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router1FaceId &&
verb == ndn::Name::Component("register"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router2FaceId &&
verb == ndn::Name::Component("register"));
}
BOOST_AUTO_TEST_CASE(NextHopsNoChange)
{
NextHop hop1(router1FaceUri, 10);
NextHop hop2(router2FaceUri, 20);
NexthopList oldHops;
oldHops.addNextHop(hop1);
oldHops.addNextHop(hop2);
fib->update("/ndn/name", oldHops);
face->processEvents(ndn::time::milliseconds(-1));
BOOST_REQUIRE_EQUAL(interests.size(), 2);
interests.clear();
fib->update("/ndn/name", oldHops);
face->processEvents(ndn::time::milliseconds(-1));
// Should register face 1 and 2 for /ndn/name
BOOST_REQUIRE_EQUAL(interests.size(), 2);
ndn::nfd::ControlParameters extractedParameters;
ndn::Name::Component verb;
std::vector<ndn::Interest>::iterator it = interests.begin();
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router1FaceId &&
verb == ndn::Name::Component("register"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router2FaceId &&
verb == ndn::Name::Component("register"));
}
BOOST_AUTO_TEST_CASE(NextHopsRemoveAll)
{
NextHop hop1(router1FaceUri, 10);
NextHop hop2(router2FaceUri, 20);
NexthopList oldHops;
oldHops.addNextHop(hop1);
oldHops.addNextHop(hop2);
fib->update("/ndn/name", oldHops);
face->processEvents(ndn::time::milliseconds(-1));
BOOST_REQUIRE_EQUAL(interests.size(), 2);
interests.clear();
NexthopList empty;
fib->update("/ndn/name", empty);
face->processEvents(ndn::time::milliseconds(-1));
// Should unregister faces 1 and 2 for /ndn/name
BOOST_CHECK_EQUAL(interests.size(), 2);
ndn::nfd::ControlParameters extractedParameters;
ndn::Name::Component verb;
std::vector<ndn::Interest>::iterator it = interests.begin();
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router1FaceId &&
verb == ndn::Name::Component("unregister"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router2FaceId &&
verb == ndn::Name::Component("unregister"));
}
BOOST_AUTO_TEST_CASE(NextHopsMaxPrefixes)
{
NextHop hop1(router1FaceUri, 10);
NextHop hop2(router2FaceUri, 20);
NextHop hop3(router3FaceUri, 30);
NexthopList hops;
hops.addNextHop(hop1);
hops.addNextHop(hop2);
hops.addNextHop(hop3);
fib->update("/ndn/name", hops);
face->processEvents(ndn::time::milliseconds(-1));
// Should only register faces 1 and 2 for /ndn/name
BOOST_CHECK_EQUAL(interests.size(), 2);
ndn::nfd::ControlParameters extractedParameters;
ndn::Name::Component verb;
std::vector<ndn::Interest>::iterator it = interests.begin();
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router1FaceId &&
verb == ndn::Name::Component("register"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router2FaceId &&
verb == ndn::Name::Component("register"));
}
BOOST_AUTO_TEST_CASE(NextHopsMaxPrefixesAfterRecalculation)
{
NextHop hop1(router1FaceUri, 10);
NextHop hop2(router2FaceUri, 20);
NexthopList hops;
hops.addNextHop(hop1);
hops.addNextHop(hop2);
fib->update("/ndn/name", hops);
face->processEvents(ndn::time::milliseconds(-1));
// FIB
// Name NextHops
// /ndn/name (faceId=1, cost=10), (faceId=2, cost=20)
BOOST_REQUIRE_EQUAL(interests.size(), 2);
interests.clear();
// Routing table is recalculated; a new more optimal path is found
NextHop hop3(router3FaceUri, 5);
hops.addNextHop(hop3);
fib->update("/ndn/name", hops);
face->processEvents(ndn::time::milliseconds(-1));
// To maintain a max 2 face requirement, face 3 should be registered and face 2 should be
// unregistered. Face 1 will also be re-registered.
//
// FIB
// Name NextHops
// /ndn/name (faceId=3, cost=5), (faceId=1, cost=10)
BOOST_CHECK_EQUAL(interests.size(), 3);
ndn::nfd::ControlParameters extractedParameters;
ndn::Name::Component verb;
std::vector<ndn::Interest>::iterator it = interests.begin();
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router3FaceId &&
verb == ndn::Name::Component("register"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router1FaceId &&
verb == ndn::Name::Component("register"));
++it;
extractRibCommandParameters(*it, verb, extractedParameters);
BOOST_CHECK(extractedParameters.getName() == "/ndn/name" &&
extractedParameters.getFaceId() == router2FaceId &&
verb == ndn::Name::Component("unregister"));
}
BOOST_FIXTURE_TEST_CASE(ScheduleFibEntryRefresh, FibFixture)
{
ndn::Name name1("/name/1");
FibEntry fe(name1);
fib->m_table.emplace(name1, fe);
int origSeqNo = fe.getSeqNo();
fib->scheduleEntryRefresh(fe,
[&] (FibEntry& entry) {
BOOST_CHECK_EQUAL(origSeqNo + 1, entry.getSeqNo());
});
this->advanceClocks(ndn::time::milliseconds(10), 1);
}
BOOST_AUTO_TEST_CASE(ShouldNotRefreshNeighborRoute) // #4799
{
NextHop hop1;
hop1.setConnectingFaceUri(router1FaceUri);
NexthopList hops;
hops.addNextHop(hop1);
// Simulate update for this neighbor from name prefix table
fib->update(router1Name, hops);
this->advanceClocks(ndn::time::seconds(1));
// Should not send the register interest
BOOST_CHECK_EQUAL(face->sentInterests.size(), 0);
}
BOOST_AUTO_TEST_SUITE_END()
} // namespace test
} // namespace nlsr