blob: 2372e24e4b81bb8b858f6c4382488b5e3845d001 [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
* Copyright (c) 2013-2023 Regents of the University of California.
*
* This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
*
* ndn-cxx library is free software: you can redistribute it and/or modify it under the
* terms of the GNU Lesser General Public License as published by the Free Software
* Foundation, either version 3 of the License, or (at your option) any later version.
*
* ndn-cxx library 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 Lesser General Public License for more details.
*
* You should have received copies of the GNU General Public License and GNU Lesser
* General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
* <http://www.gnu.org/licenses/>.
*
* See AUTHORS.md for complete list of ndn-cxx authors and contributors.
*/
#include "ndn-cxx/face.hpp"
#include "ndn-cxx/lp/tags.hpp"
#include "ndn-cxx/transport/tcp-transport.hpp"
#include "ndn-cxx/transport/unix-transport.hpp"
#include "ndn-cxx/util/config-file.hpp"
#include "ndn-cxx/util/dummy-client-face.hpp"
#include "tests/test-common.hpp"
#include "tests/unit/io-key-chain-fixture.hpp"
#include <boost/logic/tribool.hpp>
namespace ndn {
namespace tests {
using ndn::util::DummyClientFace;
using std::bind;
struct WantPrefixRegReply;
struct NoPrefixRegReply;
template<typename PrefixRegReply = WantPrefixRegReply>
class FaceFixture : public IoKeyChainFixture
{
protected:
FaceFixture()
: face(m_io, m_keyChain, {true, !std::is_same_v<PrefixRegReply, NoPrefixRegReply>})
{
static_assert(std::is_same_v<PrefixRegReply, WantPrefixRegReply> ||
std::is_same_v<PrefixRegReply, NoPrefixRegReply>, "");
}
/** \brief Execute a prefix registration, and optionally check the name in callback.
* \return whether the prefix registration succeeded.
*/
bool
runPrefixReg(std::function<void(const RegisterPrefixSuccessCallback&,
const RegisterPrefixFailureCallback&)> f)
{
boost::logic::tribool result = boost::logic::indeterminate;
f([&] (auto) { result = true; },
[&] (auto, auto) { result = false; });
advanceClocks(1_ms);
BOOST_REQUIRE(!boost::logic::indeterminate(result));
return static_cast<bool>(result);
}
/** \brief Execute a prefix unregistration, and optionally check the name in callback.
* \return whether the prefix unregistration succeeded.
*/
bool
runPrefixUnreg(std::function<void(const UnregisterPrefixSuccessCallback&,
const UnregisterPrefixFailureCallback&)> f)
{
boost::logic::tribool result = boost::logic::indeterminate;
f([&] { result = true; },
[&] (auto) { result = false; });
advanceClocks(1_ms);
BOOST_REQUIRE(!boost::logic::indeterminate(result));
return static_cast<bool>(result);
}
protected:
DummyClientFace face;
};
BOOST_FIXTURE_TEST_SUITE(TestFace, FaceFixture<>)
BOOST_AUTO_TEST_SUITE(ExpressInterest)
BOOST_AUTO_TEST_CASE(ReplyData)
{
size_t nData = 0;
face.expressInterest(*makeInterest("/Hello/World", true, 50_ms),
[&] (const Interest& i, const Data& d) {
BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
++nData;
},
bind([] { BOOST_FAIL("Unexpected Nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(40_ms);
face.receive(*makeData("/Bye/World/a"));
face.receive(*makeData("/Hello/World/a"));
advanceClocks(50_ms, 2);
BOOST_CHECK_EQUAL(nData, 1);
BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
BOOST_CHECK_EQUAL(face.sentData.size(), 0);
size_t nTimeouts = 0;
face.expressInterest(*makeInterest("/Hello/World/a/2", false, 50_ms),
bind([]{}),
bind([]{}),
bind([&nTimeouts] { ++nTimeouts; }));
advanceClocks(200_ms, 5);
BOOST_CHECK_EQUAL(nTimeouts, 1);
}
BOOST_AUTO_TEST_CASE(MultipleData)
{
size_t nData = 0;
face.expressInterest(*makeInterest("/Hello/World", true, 50_ms),
[&] (const auto&, const auto&) { ++nData; },
bind([] { BOOST_FAIL("Unexpected Nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
face.expressInterest(*makeInterest("/Hello/World/a", true, 50_ms),
[&] (const auto&, const auto&) { ++nData; },
bind([] { BOOST_FAIL("Unexpected Nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(40_ms);
face.receive(*makeData("/Hello/World/a/b"));
advanceClocks(50_ms, 2);
BOOST_CHECK_EQUAL(nData, 2);
BOOST_CHECK_EQUAL(face.sentInterests.size(), 2);
BOOST_CHECK_EQUAL(face.sentData.size(), 0);
}
BOOST_AUTO_TEST_CASE(EmptyDataCallback)
{
face.expressInterest(*makeInterest("/Hello/World", true),
nullptr,
bind([] { BOOST_FAIL("Unexpected Nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
BOOST_CHECK_NO_THROW(do {
face.receive(*makeData("/Hello/World/a"));
advanceClocks(1_ms);
} while (false));
}
BOOST_AUTO_TEST_CASE(Timeout)
{
size_t nTimeouts = 0;
face.expressInterest(*makeInterest("/Hello/World", false, 50_ms),
bind([] { BOOST_FAIL("Unexpected Data"); }),
bind([] { BOOST_FAIL("Unexpected Nack"); }),
[&nTimeouts] (const Interest& i) {
BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
++nTimeouts;
});
advanceClocks(200_ms, 5);
BOOST_CHECK_EQUAL(nTimeouts, 1);
BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
BOOST_CHECK_EQUAL(face.sentData.size(), 0);
BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
}
BOOST_AUTO_TEST_CASE(EmptyTimeoutCallback)
{
face.expressInterest(*makeInterest("/Hello/World", false, 50_ms),
bind([] { BOOST_FAIL("Unexpected Data"); }),
bind([] { BOOST_FAIL("Unexpected Nack"); }),
nullptr);
advanceClocks(40_ms);
BOOST_CHECK_NO_THROW(do {
advanceClocks(6_ms, 2);
} while (false));
}
BOOST_AUTO_TEST_CASE(ReplyNack)
{
size_t nNacks = 0;
auto interest = makeInterest("/Hello/World", false, 50_ms);
face.expressInterest(*interest,
bind([] { BOOST_FAIL("Unexpected Data"); }),
[&] (const Interest& i, const lp::Nack& n) {
BOOST_CHECK(i.getName().isPrefixOf(n.getInterest().getName()));
BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
BOOST_CHECK_EQUAL(n.getReason(), lp::NackReason::DUPLICATE);
++nNacks;
},
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(40_ms);
face.receive(makeNack(face.sentInterests.at(0), lp::NackReason::DUPLICATE));
advanceClocks(50_ms, 2);
BOOST_CHECK_EQUAL(nNacks, 1);
BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
}
BOOST_AUTO_TEST_CASE(MultipleNacks)
{
size_t nNacks = 0;
auto interest = makeInterest("/Hello/World", false, 50_ms, 1);
face.expressInterest(*interest,
bind([] { BOOST_FAIL("Unexpected Data"); }),
[&] (const auto&, const auto&) { ++nNacks; },
bind([] { BOOST_FAIL("Unexpected timeout"); }));
interest->setNonce(2);
face.expressInterest(*interest,
bind([] { BOOST_FAIL("Unexpected Data"); }),
[&] (const auto&, const auto&) { ++nNacks; },
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(40_ms);
face.receive(makeNack(face.sentInterests.at(1), lp::NackReason::DUPLICATE));
advanceClocks(50_ms, 2);
BOOST_CHECK_EQUAL(nNacks, 2);
BOOST_CHECK_EQUAL(face.sentInterests.size(), 2);
}
BOOST_AUTO_TEST_CASE(EmptyNackCallback)
{
face.expressInterest(*makeInterest("/Hello/World"),
bind([] { BOOST_FAIL("Unexpected Data"); }),
nullptr,
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
BOOST_CHECK_NO_THROW(do {
face.receive(makeNack(face.sentInterests.at(0), lp::NackReason::DUPLICATE));
advanceClocks(1_ms);
} while (false));
}
BOOST_AUTO_TEST_CASE(PutDataFromDataCallback) // Bug 4596
{
face.expressInterest(*makeInterest("/localhost/notification/1"),
[&] (const auto&, const auto&) {
face.put(*makeData("/chronosync/sampleDigest/1"));
}, nullptr, nullptr);
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.sentInterests.back().getName(), "/localhost/notification/1");
face.receive(*makeInterest("/chronosync/sampleDigest", true));
advanceClocks(10_ms);
face.put(*makeData("/localhost/notification/1"));
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.sentData.back().getName(), "/chronosync/sampleDigest/1");
}
BOOST_AUTO_TEST_CASE(DestroyWithPendingInterest)
{
auto face2 = make_unique<DummyClientFace>(m_io, m_keyChain);
face2->expressInterest(*makeInterest("/Hello/World", false, 50_ms),
nullptr, nullptr, nullptr);
advanceClocks(50_ms, 2);
face2.reset();
advanceClocks(50_ms, 2); // should not crash - Bug 2518
// avoid "test case [...] did not check any assertions" message from Boost.Test
BOOST_CHECK(true);
}
BOOST_AUTO_TEST_CASE(Handle)
{
auto hdl = face.expressInterest(*makeInterest("/Hello/World", true, 50_ms),
bind([] { BOOST_FAIL("Unexpected data"); }),
bind([] { BOOST_FAIL("Unexpected nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
hdl.cancel();
advanceClocks(1_ms);
face.receive(*makeData("/Hello/World/%21"));
advanceClocks(200_ms, 5);
// cancel after destructing face
auto face2 = make_unique<DummyClientFace>(m_io, m_keyChain);
auto hdl2 = face2->expressInterest(*makeInterest("/Hello/World", true, 50_ms),
bind([] { BOOST_FAIL("Unexpected data"); }),
bind([] { BOOST_FAIL("Unexpected nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
face2.reset();
advanceClocks(1_ms);
hdl2.cancel(); // should not crash
advanceClocks(1_ms);
// avoid "test case [...] did not check any assertions" message from Boost.Test
BOOST_CHECK(true);
}
BOOST_AUTO_TEST_SUITE_END() // ExpressInterest
BOOST_AUTO_TEST_CASE(RemoveAllPendingInterests)
{
face.expressInterest(*makeInterest("/Hello/World/0", false, 50_ms),
bind([] { BOOST_FAIL("Unexpected data"); }),
bind([] { BOOST_FAIL("Unexpected nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
face.expressInterest(*makeInterest("/Hello/World/1", false, 50_ms),
bind([] { BOOST_FAIL("Unexpected data"); }),
bind([] { BOOST_FAIL("Unexpected nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(10_ms);
face.removeAllPendingInterests();
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.getNPendingInterests(), 0);
face.receive(*makeData("/Hello/World/0"));
face.receive(*makeData("/Hello/World/1"));
advanceClocks(200_ms, 5);
}
BOOST_AUTO_TEST_SUITE(Producer)
BOOST_AUTO_TEST_CASE(PutData)
{
BOOST_CHECK_EQUAL(face.sentData.size(), 0);
Data data("/4g7xxcuEow/KFvK5Kf2m");
signData(data);
face.put(data);
lp::CachePolicy cachePolicy;
cachePolicy.setPolicy(lp::CachePolicyType::NO_CACHE);
data.setTag(make_shared<lp::CachePolicyTag>(cachePolicy));
data.setTag(make_shared<lp::CongestionMarkTag>(1));
face.put(data);
advanceClocks(10_ms);
BOOST_REQUIRE_EQUAL(face.sentData.size(), 2);
BOOST_CHECK(face.sentData[0].getTag<lp::CachePolicyTag>() == nullptr);
BOOST_CHECK(face.sentData[0].getTag<lp::CongestionMarkTag>() == nullptr);
BOOST_CHECK(face.sentData[1].getTag<lp::CachePolicyTag>() != nullptr);
BOOST_CHECK(face.sentData[1].getTag<lp::CongestionMarkTag>() != nullptr);
}
BOOST_AUTO_TEST_CASE(PutDataLoopback)
{
bool hasInterest1 = false, hasData = false;
// first InterestFilter allows loopback and should receive Interest
face.setInterestFilter("/", [&] (const InterestFilter&, const Interest&) {
hasInterest1 = true;
// do not respond with Data right away, so Face must send Interest to forwarder
});
// second InterestFilter disallows loopback and should not receive Interest
face.setInterestFilter(InterestFilter("/").allowLoopback(false),
bind([] { BOOST_ERROR("Unexpected Interest on second InterestFilter"); }));
face.expressInterest(*makeInterest("/A", true),
bind([&] { hasData = true; }),
bind([] { BOOST_FAIL("Unexpected nack"); }),
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
BOOST_CHECK_EQUAL(hasInterest1, true); // Interest looped back
BOOST_CHECK_EQUAL(face.sentInterests.size(), 1); // Interest sent to forwarder
BOOST_CHECK_EQUAL(hasData, false); // waiting for Data
face.put(*makeData("/A/B")); // first InterestFilter responds with Data
advanceClocks(1_ms);
BOOST_CHECK_EQUAL(hasData, true);
BOOST_CHECK_EQUAL(face.sentData.size(), 0); // do not spill Data to forwarder
}
BOOST_AUTO_TEST_CASE(PutMultipleData)
{
bool hasInterest1 = false;
// register two Interest destinations
face.setInterestFilter("/", bind([&] {
hasInterest1 = true;
// sending Data right away from the first destination, don't care whether Interest goes to second destination
face.put(*makeData("/A/B"));
}));
face.setInterestFilter("/", bind([]{}));
advanceClocks(10_ms);
face.receive(*makeInterest("/A", true));
advanceClocks(10_ms);
BOOST_CHECK(hasInterest1);
BOOST_CHECK_EQUAL(face.sentData.size(), 1);
BOOST_CHECK_EQUAL(face.sentData.at(0).getName(), "/A/B");
face.put(*makeData("/A/C"));
BOOST_CHECK_EQUAL(face.sentData.size(), 1); // additional Data are ignored
}
BOOST_AUTO_TEST_CASE(PutNack)
{
face.setInterestFilter("/", bind([]{})); // register one Interest destination so that face can accept Nacks
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
face.put(makeNack(*makeInterest("/unsolicited", false, std::nullopt, 18645250),
lp::NackReason::NO_ROUTE));
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.sentNacks.size(), 0); // unsolicited Nack would not be sent
auto interest1 = makeInterest("/Hello/World", false, std::nullopt, 14247162);
face.receive(*interest1);
auto interest2 = makeInterest("/another/prefix", false, std::nullopt, 92203002);
face.receive(*interest2);
advanceClocks(10_ms);
face.put(makeNack(*interest1, lp::NackReason::DUPLICATE));
advanceClocks(10_ms);
BOOST_REQUIRE_EQUAL(face.sentNacks.size(), 1);
BOOST_CHECK_EQUAL(face.sentNacks[0].getReason(), lp::NackReason::DUPLICATE);
BOOST_CHECK(face.sentNacks[0].getTag<lp::CongestionMarkTag>() == nullptr);
auto nack = makeNack(*interest2, lp::NackReason::NO_ROUTE);
nack.setTag(make_shared<lp::CongestionMarkTag>(1));
face.put(nack);
advanceClocks(10_ms);
BOOST_REQUIRE_EQUAL(face.sentNacks.size(), 2);
BOOST_CHECK_EQUAL(face.sentNacks[1].getReason(), lp::NackReason::NO_ROUTE);
BOOST_CHECK(face.sentNacks[1].getTag<lp::CongestionMarkTag>() != nullptr);
}
BOOST_AUTO_TEST_CASE(PutMultipleNack)
{
bool hasInterest1 = false, hasInterest2 = false;
// register two Interest destinations
face.setInterestFilter("/", [&] (const InterestFilter&, const Interest& interest) {
hasInterest1 = true;
// sending Nack right away from the first destination, Interest should still go to second destination
face.put(makeNack(interest, lp::NackReason::CONGESTION));
});
face.setInterestFilter("/", bind([&] { hasInterest2 = true; }));
advanceClocks(10_ms);
auto interest = makeInterest("/A", false, std::nullopt, 14333271);
face.receive(*interest);
advanceClocks(10_ms);
BOOST_CHECK(hasInterest1);
BOOST_CHECK(hasInterest2);
// Nack from first destination is received, should wait for a response from the other destination
BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
face.put(makeNack(*interest, lp::NackReason::NO_ROUTE)); // Nack from second destination
advanceClocks(10_ms);
BOOST_CHECK_EQUAL(face.sentNacks.size(), 1); // sending Nack after both destinations Nacked
BOOST_CHECK_EQUAL(face.sentNacks.at(0).getReason(), lp::NackReason::CONGESTION); // least severe reason
face.put(makeNack(*interest, lp::NackReason::DUPLICATE));
BOOST_CHECK_EQUAL(face.sentNacks.size(), 1); // additional Nacks are ignored
}
BOOST_AUTO_TEST_CASE(PutMultipleNackLoopback)
{
bool hasInterest1 = false, hasNack = false;
// first InterestFilter allows loopback and should receive Interest
face.setInterestFilter("/", [&] (const InterestFilter&, const Interest& interest) {
hasInterest1 = true;
face.put(makeNack(interest, lp::NackReason::CONGESTION));
});
// second InterestFilter disallows loopback and should not receive Interest
face.setInterestFilter(InterestFilter("/").allowLoopback(false),
bind([] { BOOST_ERROR("Unexpected Interest on second InterestFilter"); }));
auto interest = makeInterest("/A", false, std::nullopt, 28395852);
face.expressInterest(*interest,
bind([] { BOOST_FAIL("Unexpected data"); }),
[&] (const Interest&, const lp::Nack& nack) {
hasNack = true;
BOOST_CHECK_EQUAL(nack.getReason(), lp::NackReason::CONGESTION);
},
bind([] { BOOST_FAIL("Unexpected timeout"); }));
advanceClocks(1_ms);
BOOST_CHECK_EQUAL(hasInterest1, true); // Interest looped back
BOOST_CHECK_EQUAL(face.sentInterests.size(), 1); // Interest sent to forwarder
BOOST_CHECK_EQUAL(hasNack, false); // waiting for Nack from forwarder
face.receive(makeNack(*interest, lp::NackReason::NO_ROUTE));
advanceClocks(1_ms);
BOOST_CHECK_EQUAL(hasNack, true);
}
BOOST_AUTO_TEST_SUITE_END() // Producer
BOOST_AUTO_TEST_SUITE(RegisterPrefix)
BOOST_FIXTURE_TEST_CASE(Failure, FaceFixture<NoPrefixRegReply>)
{
BOOST_CHECK(!runPrefixReg([&] (const auto& success, const auto& failure) {
face.registerPrefix("/Hello/World", success, failure);
this->advanceClocks(5_s, 20); // wait for command timeout
}));
}
BOOST_AUTO_TEST_CASE(Handle)
{
RegisteredPrefixHandle hdl;
auto doReg = [&] {
return runPrefixReg([&] (const auto& success, const auto& failure) {
hdl = face.registerPrefix("/Hello/World", success, failure);
});
};
auto doUnreg = [&] {
return runPrefixUnreg([&] (const auto& success, const auto& failure) {
hdl.unregister(success, failure);
});
};
// despite the "undefined behavior" warning, we try not to crash, but no API guarantee for this
BOOST_CHECK(!doUnreg());
// cancel after unregister
BOOST_CHECK(doReg());
BOOST_CHECK(doUnreg());
hdl.cancel();
advanceClocks(1_ms);
// unregister after cancel
BOOST_CHECK(doReg());
hdl.cancel();
advanceClocks(1_ms);
BOOST_CHECK(!doUnreg());
// cancel after destructing face
auto face2 = make_unique<DummyClientFace>(m_io, m_keyChain);
hdl = face2->registerPrefix("/Hello/World/2", nullptr,
bind([] { BOOST_FAIL("Unexpected registerPrefix failure"); }));
advanceClocks(1_ms);
face2.reset();
advanceClocks(1_ms);
hdl.cancel(); // should not crash
advanceClocks(1_ms);
// unregister after destructing face
auto face3 = make_unique<DummyClientFace>(m_io, m_keyChain);
hdl = face3->registerPrefix("/Hello/World/3", nullptr,
bind([] { BOOST_FAIL("Unexpected registerPrefix failure"); }));
advanceClocks(1_ms);
face3.reset();
advanceClocks(1_ms);
BOOST_CHECK(!doUnreg());
}
BOOST_AUTO_TEST_SUITE_END() // RegisterPrefix
BOOST_AUTO_TEST_SUITE(SetInterestFilter)
BOOST_AUTO_TEST_CASE(SetAndCancel)
{
size_t nInterests = 0;
size_t nRegs = 0;
auto hdl = face.setInterestFilter("/Hello/World",
bind([&nInterests] { ++nInterests; }),
bind([&nRegs] { ++nRegs; }),
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nRegs, 1);
BOOST_CHECK_EQUAL(nInterests, 0);
face.receive(*makeInterest("/Hello/World/%21"));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nRegs, 1);
BOOST_CHECK_EQUAL(nInterests, 1);
face.receive(*makeInterest("/Bye/World/%21"));
advanceClocks(10000_ms, 10);
BOOST_CHECK_EQUAL(nInterests, 1);
face.receive(*makeInterest("/Hello/World/%21/2"));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nInterests, 2);
// removing filter
hdl.cancel();
advanceClocks(25_ms, 4);
face.receive(*makeInterest("/Hello/World/%21/3"));
BOOST_CHECK_EQUAL(nInterests, 2);
}
BOOST_AUTO_TEST_CASE(EmptyInterestCallback)
{
face.setInterestFilter("/A", nullptr);
advanceClocks(1_ms);
BOOST_CHECK_NO_THROW(do {
face.receive(*makeInterest("/A/1"));
advanceClocks(1_ms);
} while (false));
}
BOOST_AUTO_TEST_CASE(WithoutSuccessCallback)
{
size_t nInterests = 0;
auto hdl = face.setInterestFilter("/Hello/World",
bind([&nInterests] { ++nInterests; }),
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nInterests, 0);
face.receive(*makeInterest("/Hello/World/%21"));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nInterests, 1);
face.receive(*makeInterest("/Bye/World/%21"));
advanceClocks(10000_ms, 10);
BOOST_CHECK_EQUAL(nInterests, 1);
face.receive(*makeInterest("/Hello/World/%21/2"));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nInterests, 2);
// removing filter
hdl.cancel();
advanceClocks(25_ms, 4);
face.receive(*makeInterest("/Hello/World/%21/3"));
BOOST_CHECK_EQUAL(nInterests, 2);
}
BOOST_FIXTURE_TEST_CASE(Failure, FaceFixture<NoPrefixRegReply>)
{
// don't enable registration reply
size_t nRegFailed = 0;
face.setInterestFilter("/Hello/World",
bind([] { BOOST_FAIL("Unexpected Interest"); }),
bind([] { BOOST_FAIL("Unexpected success of setInterestFilter"); }),
bind([&nRegFailed] { ++nRegFailed; }));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nRegFailed, 0);
advanceClocks(2000_ms, 5);
BOOST_CHECK_EQUAL(nRegFailed, 1);
}
BOOST_FIXTURE_TEST_CASE(FailureWithoutSuccessCallback, FaceFixture<NoPrefixRegReply>)
{
// don't enable registration reply
size_t nRegFailed = 0;
face.setInterestFilter("/Hello/World",
bind([] { BOOST_FAIL("Unexpected Interest"); }),
bind([&nRegFailed] { ++nRegFailed; }));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nRegFailed, 0);
advanceClocks(2000_ms, 5);
BOOST_CHECK_EQUAL(nRegFailed, 1);
}
BOOST_AUTO_TEST_CASE(SimilarFilters)
{
size_t nInInterests1 = 0;
face.setInterestFilter("/Hello/World",
bind([&nInInterests1] { ++nInInterests1; }),
nullptr,
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
size_t nInInterests2 = 0;
face.setInterestFilter("/Hello",
bind([&nInInterests2] { ++nInInterests2; }),
nullptr,
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
size_t nInInterests3 = 0;
face.setInterestFilter("/Los/Angeles/Lakers",
bind([&nInInterests3] { ++nInInterests3; }),
nullptr,
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
face.receive(*makeInterest("/Hello/World/%21"));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nInInterests1, 1);
BOOST_CHECK_EQUAL(nInInterests2, 1);
BOOST_CHECK_EQUAL(nInInterests3, 0);
}
BOOST_AUTO_TEST_CASE(RegexFilter)
{
size_t nInInterests = 0;
face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
bind([&nInInterests] { ++nInInterests; }),
nullptr,
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
face.receive(*makeInterest("/Hello/World/a")); // shouldn't match
BOOST_CHECK_EQUAL(nInInterests, 0);
face.receive(*makeInterest("/Hello/World/a/b")); // should match
BOOST_CHECK_EQUAL(nInInterests, 1);
face.receive(*makeInterest("/Hello/World/a/b/c")); // should match
BOOST_CHECK_EQUAL(nInInterests, 2);
face.receive(*makeInterest("/Hello/World/a/b/d")); // should not match
BOOST_CHECK_EQUAL(nInInterests, 2);
}
BOOST_AUTO_TEST_CASE(RegexFilterError)
{
face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
[] (const Name&, const Interest&) {
BOOST_FAIL("InterestFilter::Error should have been triggered");
},
nullptr,
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
BOOST_CHECK_THROW(face.receive(*makeInterest("/Hello/World/XXX/b/c")), InterestFilter::Error);
}
BOOST_AUTO_TEST_CASE(RegexFilterAndRegisterPrefix)
{
size_t nInInterests = 0;
face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
bind([&nInInterests] { ++nInInterests; }));
size_t nRegSuccesses = 0;
face.registerPrefix("/Hello/World",
bind([&nRegSuccesses] { ++nRegSuccesses; }),
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
advanceClocks(25_ms, 4);
BOOST_CHECK_EQUAL(nRegSuccesses, 1);
face.receive(*makeInterest("/Hello/World/a")); // shouldn't match
BOOST_CHECK_EQUAL(nInInterests, 0);
face.receive(*makeInterest("/Hello/World/a/b")); // should match
BOOST_CHECK_EQUAL(nInInterests, 1);
face.receive(*makeInterest("/Hello/World/a/b/c")); // should match
BOOST_CHECK_EQUAL(nInInterests, 2);
face.receive(*makeInterest("/Hello/World/a/b/d")); // should not match
BOOST_CHECK_EQUAL(nInInterests, 2);
}
BOOST_FIXTURE_TEST_CASE(WithoutRegisterPrefix, FaceFixture<NoPrefixRegReply>) // Bug 2318
{
// This behavior is specific to DummyClientFace.
// Regular Face won't accept incoming packets until something is sent.
int hit = 0;
face.setInterestFilter(Name("/"), bind([&hit] { ++hit; }));
face.processEvents(time::milliseconds(-1));
face.receive(*makeInterest("/A"));
face.processEvents(time::milliseconds(-1));
BOOST_CHECK_EQUAL(hit, 1);
}
BOOST_AUTO_TEST_CASE(Handle)
{
int hit = 0;
InterestFilterHandle hdl = face.setInterestFilter(Name("/"), bind([&hit] { ++hit; }));
face.processEvents(-1_ms);
face.receive(*makeInterest("/A"));
face.processEvents(-1_ms);
BOOST_CHECK_EQUAL(hit, 1);
hdl.cancel();
face.processEvents(-1_ms);
face.receive(*makeInterest("/B"));
face.processEvents(-1_ms);
BOOST_CHECK_EQUAL(hit, 1);
// cancel after destructing face
auto face2 = make_unique<DummyClientFace>(m_io, m_keyChain);
InterestFilterHandle hdl2 = face2->setInterestFilter("/Hello/World/2", nullptr);
advanceClocks(1_ms);
face2.reset();
advanceClocks(1_ms);
hdl2.cancel(); // should not crash
advanceClocks(1_ms);
}
BOOST_AUTO_TEST_SUITE_END() // SetInterestFilter
BOOST_AUTO_TEST_CASE(ProcessEvents)
{
face.processEvents(time::milliseconds(-1)); // io_service::reset()/poll() inside
size_t nRegSuccesses = 0;
face.registerPrefix("/Hello/World",
bind([&nRegSuccesses] { ++nRegSuccesses; }),
bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
// io_service::poll() without reset
face.getIoService().poll();
BOOST_CHECK_EQUAL(nRegSuccesses, 0);
face.processEvents(time::milliseconds(-1)); // io_service::reset()/poll() inside
BOOST_CHECK_EQUAL(nRegSuccesses, 1);
}
BOOST_AUTO_TEST_CASE(DestroyWithoutProcessEvents) // Bug 3248
{
auto face2 = make_unique<Face>(m_io);
face2.reset();
m_io.poll(); // should not crash
// avoid "test case [...] did not check any assertions" message from Boost.Test
BOOST_CHECK(true);
}
BOOST_AUTO_TEST_SUITE(Transport)
using ndn::Transport;
struct PibDirWithDefaultTpm
{
const std::string PATH = "build/keys-with-default-tpm";
};
BOOST_FIXTURE_TEST_CASE(FaceTransport, IoKeyChainFixture)
{
BOOST_CHECK(Face().getTransport() != nullptr);
BOOST_CHECK(Face(shared_ptr<Transport>()).getTransport() != nullptr);
BOOST_CHECK(Face(shared_ptr<Transport>(), m_io).getTransport() != nullptr);
BOOST_CHECK(Face(shared_ptr<Transport>(), m_io, m_keyChain).getTransport() != nullptr);
auto transport = make_shared<TcpTransport>("localhost", "6363"); // no real io operations will be scheduled
BOOST_CHECK(Face(transport).getTransport() == transport);
BOOST_CHECK(Face(transport, m_io).getTransport() == transport);
BOOST_CHECK(Face(transport, m_io, m_keyChain).getTransport() == transport);
}
class WithEnv
{
public:
WithEnv()
{
if (getenv("NDN_CLIENT_TRANSPORT") != nullptr) {
m_oldTransport = getenv("NDN_CLIENT_TRANSPORT");
unsetenv("NDN_CLIENT_TRANSPORT");
}
}
void
configure(const std::string& faceUri)
{
setenv("NDN_CLIENT_TRANSPORT", faceUri.data(), true);
}
~WithEnv()
{
if (!m_oldTransport.empty()) {
setenv("NDN_CLIENT_TRANSPORT", m_oldTransport.data(), true);
}
else {
unsetenv("NDN_CLIENT_TRANSPORT");
}
}
private:
std::string m_oldTransport;
};
class WithConfig : private TestHomeFixture<DefaultPibDir>
{
public:
void
configure(const std::string& faceUri)
{
createClientConf({"transport=" + faceUri});
}
};
class WithEnvAndConfig : public WithEnv, public WithConfig
{
};
typedef boost::mpl::vector<WithEnv, WithConfig> ConfigOptions;
BOOST_FIXTURE_TEST_CASE(NoConfig, WithEnvAndConfig) // fixture configures test HOME and PIB/TPM path
{
shared_ptr<Face> face;
BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(Unix, T, ConfigOptions, T)
{
this->configure("unix://some/path");
shared_ptr<Face> face;
BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(Tcp, T, ConfigOptions, T)
{
this->configure("tcp://127.0.0.1:6000");
shared_ptr<Face> face;
BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
BOOST_CHECK(dynamic_pointer_cast<TcpTransport>(face->getTransport()) != nullptr);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(WrongTransport, T, ConfigOptions, T)
{
this->configure("wrong-transport:");
BOOST_CHECK_THROW(make_shared<Face>(), ConfigFile::Error);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(WrongUri, T, ConfigOptions, T)
{
this->configure("wrong-uri");
BOOST_CHECK_THROW(make_shared<Face>(), ConfigFile::Error);
}
BOOST_FIXTURE_TEST_CASE(EnvOverride, WithEnvAndConfig)
{
this->WithEnv::configure("tcp://127.0.0.1:6000");
this->WithConfig::configure("unix://some/path");
shared_ptr<Face> face;
BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
BOOST_CHECK(dynamic_pointer_cast<TcpTransport>(face->getTransport()) != nullptr);
}
BOOST_FIXTURE_TEST_CASE(ExplicitTransport, WithEnvAndConfig)
{
this->WithEnv::configure("wrong-uri");
this->WithConfig::configure("wrong-transport:");
auto transport = make_shared<UnixTransport>("unix://some/path");
shared_ptr<Face> face;
BOOST_REQUIRE_NO_THROW(face = make_shared<Face>(transport));
BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
}
BOOST_AUTO_TEST_SUITE_END() // Transport
BOOST_AUTO_TEST_SUITE_END() // TestFace
} // namespace tests
} // namespace ndn