| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
| /* |
| * Copyright (c) 2014-2021, 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 { |
| |
| class FibFixture : public UnitTestTimeFixture |
| { |
| public: |
| FibFixture() |
| : face(m_ioService, m_keyChain) |
| , conf(face, m_keyChain) |
| , adjacencies(conf.getAdjacencyList()) |
| , fib(face, m_scheduler, adjacencies, conf, m_keyChain) |
| , interests(face.sentInterests) |
| { |
| enableRegistrationReplyWithFaceId(); |
| advanceClocks(1_s); |
| |
| 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.setEntryRefreshTime(1); |
| } |
| |
| void |
| enableRegistrationReplyWithFaceId() { |
| face.onSendInterest.connect([this] (const ndn::Interest& interest) { |
| static const ndn::Name localhostRegistration("/localhost/nfd/rib"); |
| if (!localhostRegistration.isPrefixOf(interest.getName())) |
| return; |
| |
| ndn::nfd::ControlParameters params(interest.getName().get(-5).blockFromValue()); |
| if (!params.hasFaceId()) { |
| params.setFaceId(1); |
| } |
| params.setOrigin(ndn::nfd::ROUTE_ORIGIN_APP); |
| if (interest.getName().get(3) == ndn::name::Component("register")) { |
| params.setCost(0); |
| } |
| |
| ndn::nfd::ControlResponse resp; |
| resp.setCode(200); |
| resp.setBody(params.wireEncode()); |
| |
| ndn::Data data(interest.getName()); |
| data.setContent(resp.wireEncode()); |
| |
| m_keyChain.sign(data, ndn::security::SigningInfo(ndn::security::SigningInfo::SIGNER_TYPE_SHA256)); |
| |
| face.getIoService().post([this, data] { face.receive(data); }); |
| }); |
| } |
| |
| public: |
| ndn::util::DummyClientFace face; |
| |
| ConfParameter conf; |
| AdjacencyList& adjacencies; |
| Fib fib; |
| 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() == router1FaceId && |
| verb == ndn::Name::Component("register")); |
| |
| ++it; |
| 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() == router2FaceId && |
| verb == ndn::Name::Component("unregister")); |
| } |
| |
| BOOST_FIXTURE_TEST_CASE(ScheduleFibEntryRefresh, FibFixture) |
| { |
| ndn::Name name1("/name/1"); |
| FibEntry fe; |
| fe.name = name1; |
| int origSeqNo = fe.seqNo; |
| fib.m_table.emplace(name1, std::move(fe)); |
| |
| fib.scheduleEntryRefresh(fe, |
| [&] (FibEntry& entry) { |
| BOOST_CHECK_EQUAL(origSeqNo + 1, entry.seqNo); |
| }); |
| 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_CASE(PrefixWithdrawalFibUpdateBug) // #5179 |
| { |
| fib.setEntryRefreshTime(3600); |
| conf.setMaxFacesPerPrefix(3); |
| |
| // Three adjacencies of Neu |
| Adjacent neighbor1("/ndn/memphis/router-memphis", |
| ndn::FaceUri("udp4://10.0.0.9:6363"), 21, Adjacent::STATUS_ACTIVE, 0, router1FaceId); |
| adjacencies.insert(neighbor1); |
| |
| Adjacent neighbor2("/ndn/michigan/router-michigan", |
| ndn::FaceUri("udp4://10.0.0.13:6363"), 14, Adjacent::STATUS_ACTIVE, 0, router2FaceId); |
| adjacencies.insert(neighbor2); |
| |
| Adjacent neighbor3("/ndn/savi/router-savi", |
| ndn::FaceUri("udp4://10.0.0.26:6363"), 15, Adjacent::STATUS_ACTIVE, 0, router3FaceId); |
| adjacencies.insert(neighbor3); |
| |
| // Wustl advertises /test |
| NexthopList nhl1; |
| nhl1.addNextHop(NextHop("udp4://10.0.0.13:6363", 28)); |
| nhl1.addNextHop(NextHop("udp4://10.0.0.9:6363", 38)); |
| nhl1.addNextHop(NextHop("udp4://10.0.0.26:6363", 44)); |
| fib.update("/test", nhl1); |
| |
| // Memphis advertises /test |
| NexthopList nhl2; |
| nhl2.addNextHop(NextHop("udp4://10.0.0.9:6363", 21)); |
| nhl2.addNextHop(NextHop("udp4://10.0.0.13:6363", 26)); |
| nhl2.addNextHop(NextHop("udp4://10.0.0.26:6363", 42)); |
| fib.update("/test", nhl2); |
| |
| advanceClocks(10_ms); |
| face.sentInterests.clear(); |
| // Memphis withdraws /test |
| // NamePrefixTable calls this saying we need to install the Wu routes |
| // instead of the existing Memphis' cheaper routes |
| fib.update("/test", nhl1); |
| |
| advanceClocks(10_ms); |
| int numRegister = 0; |
| // Do not expect any unregisters, just registers which will update the cost in NFD |
| for (const auto& i : face.sentInterests) { |
| if (i.getName().getPrefix(4) == "/localhost/nfd/rib/unregister/") { |
| BOOST_CHECK(false); |
| } |
| else { |
| ++numRegister; |
| } |
| } |
| BOOST_CHECK_EQUAL(numRegister, 3); |
| } |
| |
| BOOST_AUTO_TEST_SUITE_END() |
| |
| } // namespace test |
| } // namespace nlsr |