| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
| /** |
| * Copyright (c) 2014 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 |
| * |
| * 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 "fw/ncc-strategy.hpp" |
| #include "strategy-tester.hpp" |
| #include "tests/face/dummy-face.hpp" |
| #include "tests/core/limited-io.hpp" |
| |
| #include "tests/test-common.hpp" |
| |
| namespace nfd { |
| namespace tests { |
| |
| BOOST_FIXTURE_TEST_SUITE(FwNccStrategy, BaseFixture) |
| |
| // NccStrategy is fairly complex. |
| // The most important property is: |
| // it remembers which upstream is the fastest to return Data, |
| // and favors this upstream in subsequent Interests. |
| BOOST_AUTO_TEST_CASE(FavorRespondingUpstream) |
| { |
| LimitedIo limitedIo; |
| Forwarder forwarder; |
| typedef StrategyTester<fw::NccStrategy> NccStrategyTester; |
| shared_ptr<NccStrategyTester> strategy = make_shared<NccStrategyTester>(boost::ref(forwarder)); |
| strategy->onAction += bind(&LimitedIo::afterOp, &limitedIo); |
| |
| shared_ptr<DummyFace> face1 = make_shared<DummyFace>(); |
| shared_ptr<DummyFace> face2 = make_shared<DummyFace>(); |
| shared_ptr<DummyFace> face3 = make_shared<DummyFace>(); |
| forwarder.addFace(face1); |
| forwarder.addFace(face2); |
| forwarder.addFace(face3); |
| |
| Fib& fib = forwarder.getFib(); |
| shared_ptr<fib::Entry> fibEntry = fib.insert(Name()).first; |
| fibEntry->addNextHop(face1, 10); |
| fibEntry->addNextHop(face2, 20); |
| |
| StrategyChoice& strategyChoice = forwarder.getStrategyChoice(); |
| strategyChoice.install(strategy); |
| strategyChoice.insert(Name(), strategy->getName()); |
| |
| Pit& pit = forwarder.getPit(); |
| |
| // first Interest: strategy knows nothing and follows routing |
| shared_ptr<Interest> interest1p = makeInterest("ndn:/0Jm1ajrW/%00"); |
| Interest& interest1 = *interest1p; |
| interest1.setInterestLifetime(time::milliseconds(8000)); |
| shared_ptr<pit::Entry> pitEntry1 = pit.insert(interest1).first; |
| |
| pitEntry1->insertOrUpdateInRecord(face3, interest1); |
| strategy->afterReceiveInterest(*face3, interest1, fibEntry, pitEntry1); |
| |
| // forwards to face1 because routing says it's best |
| limitedIo.run(LimitedIo::UNLIMITED_OPS, time::milliseconds(1)); |
| BOOST_REQUIRE_EQUAL(strategy->m_sendInterestHistory.size(), 1); |
| BOOST_CHECK_EQUAL(strategy->m_sendInterestHistory[0].get<1>(), face1); |
| |
| // forwards to face2 because face1 doesn't respond |
| limitedIo.run(LimitedIo::UNLIMITED_OPS, time::milliseconds(500)); |
| BOOST_REQUIRE_EQUAL(strategy->m_sendInterestHistory.size(), 2); |
| BOOST_CHECK_EQUAL(strategy->m_sendInterestHistory[1].get<1>(), face2); |
| |
| // face2 responds |
| shared_ptr<Data> data1p = makeData("ndn:/0Jm1ajrW/%00"); |
| Data& data1 = *data1p; |
| strategy->beforeSatisfyPendingInterest(pitEntry1, *face2, data1); |
| limitedIo.run(LimitedIo::UNLIMITED_OPS, time::milliseconds(500)); |
| |
| // second Interest: strategy knows face2 is best |
| shared_ptr<Interest> interest2p = makeInterest("ndn:/0Jm1ajrW/%00%01"); |
| Interest& interest2 = *interest2p; |
| interest2.setInterestLifetime(time::milliseconds(8000)); |
| shared_ptr<pit::Entry> pitEntry2 = pit.insert(interest2).first; |
| |
| pitEntry2->insertOrUpdateInRecord(face3, interest2); |
| strategy->afterReceiveInterest(*face3, interest2, fibEntry, pitEntry2); |
| |
| // forwards to face2 because it responds previously |
| limitedIo.run(LimitedIo::UNLIMITED_OPS, time::milliseconds(1)); |
| BOOST_REQUIRE_GE(strategy->m_sendInterestHistory.size(), 3); |
| BOOST_CHECK_EQUAL(strategy->m_sendInterestHistory[2].get<1>(), face2); |
| } |
| |
| BOOST_AUTO_TEST_SUITE_END() |
| |
| } // namespace tests |
| } // namespace nfd |