tests/unit-tests/face.t.cpp - ndn-cxx - Gitiles

 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
 /**
  * Copyright (c) 2013-2015 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 "face.hpp"
 #include "util/scheduler.hpp"
 #include "security/key-chain.hpp"
 #include "util/dummy-client-face.hpp"

 #include "boost-test.hpp"
 #include "unit-test-time-fixture.hpp"
 #include "make-interest-data.hpp"

 namespace ndn {
 namespace tests {

 using ndn::util::DummyClientFace;
 using ndn::util::makeDummyClientFace;

 class FaceFixture : public UnitTestTimeFixture
 {
 public:
   explicit
   FaceFixture(bool enableRegistrationReply = true)
     : face(makeDummyClientFace(io, { true, enableRegistrationReply }))
   {
   }

 public:
   shared_ptr<DummyClientFace> face;
 };

 class FacesNoRegistrationReplyFixture : public FaceFixture
 {
 public:
   FacesNoRegistrationReplyFixture()
     : FaceFixture(false)
   {
   }
 };

 BOOST_FIXTURE_TEST_SUITE(TestFace, FaceFixture)

 BOOST_AUTO_TEST_CASE(ExpressInterestData)
 {
   size_t nData = 0;
   face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
                         [&] (const Interest& i, const Data& d) {
                           BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
                           ++nData;
                         },
                         bind([] {
                             BOOST_FAIL("Unexpected timeout");
                           }));

   advanceClocks(time::milliseconds(1), 40);

   face->receive(*util::makeData("/Bye/World/!"));
   face->receive(*util::makeData("/Hello/World/!"));

   advanceClocks(time::milliseconds(1), 100);

   BOOST_CHECK_EQUAL(nData, 1);
   BOOST_CHECK_EQUAL(face->sentInterests.size(), 1);
   BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);

   face->expressInterest(Interest("/Hello/World/!", time::milliseconds(50)),
                         [&] (const Interest& i, const Data& d) {
                           BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
                           ++nData;
                         },
                         bind([] {
                             BOOST_FAIL("Unexpected timeout");
                           }));
   advanceClocks(time::milliseconds(1), 40);
   face->receive(*util::makeData("/Hello/World/!/1/xxxxx"));

   advanceClocks(time::milliseconds(1), 100);

   BOOST_CHECK_EQUAL(nData, 2);
   BOOST_CHECK_EQUAL(face->sentInterests.size(), 2);
   BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);

   size_t nTimeouts = 0;
   face->expressInterest(Interest("/Hello/World/!/2", time::milliseconds(50)),
                         bind([]{}),
                         bind([&nTimeouts] {
                             ++nTimeouts;
                           }));
   advanceClocks(time::milliseconds(10), 100);
   BOOST_CHECK_EQUAL(nTimeouts, 1);
 }

 BOOST_AUTO_TEST_CASE(ExpressInterestTimeout)
 {
   size_t nTimeouts = 0;
   face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
                         bind([] {
                             BOOST_FAIL("Unexpected data");
                           }),
                         bind([&nTimeouts] {
                             ++nTimeouts;
                           }));

   advanceClocks(time::milliseconds(10), 100);

   BOOST_CHECK_EQUAL(nTimeouts, 1);
   BOOST_CHECK_EQUAL(face->sentInterests.size(), 1);
   BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);
 }

 BOOST_AUTO_TEST_CASE(RemovePendingInterest)
 {
   const PendingInterestId* interestId =
     face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
                           bind([] {
                               BOOST_FAIL("Unexpected data");
                             }),
                           bind([] {
                               BOOST_FAIL("Unexpected timeout");
                             }));
   advanceClocks(time::milliseconds(10));

   face->removePendingInterest(interestId);
   advanceClocks(time::milliseconds(10));

   face->receive(*util::makeData("/Hello/World/!"));
   advanceClocks(time::milliseconds(10), 100);
 }

 BOOST_AUTO_TEST_CASE(SetUnsetInterestFilter)
 {
   size_t nInterests = 0;
   size_t nRegs = 0;
   const RegisteredPrefixId* regPrefixId =
     face->setInterestFilter("/Hello/World",
                             bind([&nInterests] { ++nInterests; }),
                             bind([&nRegs] { ++nRegs; }),
                             bind([] {
                                 BOOST_FAIL("Unexpected setInterestFilter failure");
                               }));
   advanceClocks(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nRegs, 1);
   BOOST_CHECK_EQUAL(nInterests, 0);

   face->receive(Interest("/Hello/World/!"));
   advanceClocks(time::milliseconds(10), 10);

   BOOST_CHECK_EQUAL(nRegs, 1);
   BOOST_CHECK_EQUAL(nInterests, 1);

   face->receive(Interest("/Bye/World/!"));
   advanceClocks(time::milliseconds(10000), 10);
   BOOST_CHECK_EQUAL(nInterests, 1);

   face->receive(Interest("/Hello/World/!/2"));
   advanceClocks(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nInterests, 2);

   // removing filter
   face->unsetInterestFilter(regPrefixId);
   advanceClocks(time::milliseconds(10), 10);

   face->receive(Interest("/Hello/World/!/3"));
   BOOST_CHECK_EQUAL(nInterests, 2);

   face->unsetInterestFilter(static_cast<const RegisteredPrefixId*>(0));
   advanceClocks(time::milliseconds(10), 10);

   face->unsetInterestFilter(static_cast<const InterestFilterId*>(0));
   advanceClocks(time::milliseconds(10), 10);
 }

 BOOST_FIXTURE_TEST_CASE(SetInterestFilterFail, FacesNoRegistrationReplyFixture)
 {
   // 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(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nRegFailed, 0);

   advanceClocks(time::milliseconds(1000), 10);
   BOOST_CHECK_EQUAL(nRegFailed, 1);
 }

 BOOST_AUTO_TEST_CASE(RegisterUnregisterPrefix)
 {
   size_t nRegSuccesses = 0;
   const RegisteredPrefixId* regPrefixId =
     face->registerPrefix("/Hello/World",
                          bind([&nRegSuccesses] { ++nRegSuccesses; }),
                          bind([] {
                              BOOST_FAIL("Unexpected registerPrefix failure");
                            }));

   advanceClocks(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nRegSuccesses, 1);

   size_t nUnregSuccesses = 0;
   face->unregisterPrefix(regPrefixId,
                          bind([&nUnregSuccesses] { ++nUnregSuccesses; }),
                          bind([] {
                              BOOST_FAIL("Unexpected unregisterPrefix failure");
                            }));

   advanceClocks(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nUnregSuccesses, 1);
 }

 BOOST_FIXTURE_TEST_CASE(RegisterUnregisterPrefixFail, FacesNoRegistrationReplyFixture)
 {
   size_t nRegFailures = 0;
   face->registerPrefix("/Hello/World",
                        bind([] {
                            BOOST_FAIL("Unexpected registerPrefix success");
                          }),
                        bind([&nRegFailures] { ++nRegFailures; }));

   advanceClocks(time::milliseconds(1000), 100);
   BOOST_CHECK_EQUAL(nRegFailures, 1);
 }

 BOOST_AUTO_TEST_CASE(SimilarFilters)
 {
   size_t nInInterests1 = 0;
   face->setInterestFilter("/Hello/World",
                           bind([&nInInterests1] { ++nInInterests1; }),
                           RegisterPrefixSuccessCallback(),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));

   size_t nInInterests2 = 0;
   face->setInterestFilter("/Hello",
                           bind([&nInInterests2] { ++nInInterests2; }),
                           RegisterPrefixSuccessCallback(),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));

   size_t nInInterests3 = 0;
   face->setInterestFilter("/Los/Angeles/Lakers",
                           bind([&nInInterests3] { ++nInInterests3; }),
                           RegisterPrefixSuccessCallback(),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));

   advanceClocks(time::milliseconds(10), 10);

   face->receive(Interest("/Hello/World/!"));
   advanceClocks(time::milliseconds(10), 10);

   BOOST_CHECK_EQUAL(nInInterests1, 1);
   BOOST_CHECK_EQUAL(nInInterests2, 1);
   BOOST_CHECK_EQUAL(nInInterests3, 0);
 }

 BOOST_AUTO_TEST_CASE(SetRegexFilterError)
 {
   face->setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
                           [] (const Name&, const Interest&) {
                             BOOST_FAIL("InterestFilter::Error should have been triggered");
                           },
                           RegisterPrefixSuccessCallback(),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));

   advanceClocks(time::milliseconds(10), 10);

   BOOST_REQUIRE_THROW(face->receive(Interest("/Hello/World/XXX/b/c")), InterestFilter::Error);
 }

 BOOST_AUTO_TEST_CASE(SetRegexFilter)
 {
   size_t nInInterests = 0;
   face->setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
                           bind([&nInInterests] { ++nInInterests; }),
                           RegisterPrefixSuccessCallback(),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));

   advanceClocks(time::milliseconds(10), 10);

   face->receive(Interest("/Hello/World/a"));     // shouldn't match
   BOOST_CHECK_EQUAL(nInInterests, 0);

   face->receive(Interest("/Hello/World/a/b"));   // should match
   BOOST_CHECK_EQUAL(nInInterests, 1);

   face->receive(Interest("/Hello/World/a/b/c")); // should match
   BOOST_CHECK_EQUAL(nInInterests, 2);

   face->receive(Interest("/Hello/World/a/b/d")); // should not match
   BOOST_CHECK_EQUAL(nInInterests, 2);
 }

 BOOST_AUTO_TEST_CASE(SetRegexFilterAndRegister)
 {
   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(time::milliseconds(10), 10);
   BOOST_CHECK_EQUAL(nRegSuccesses, 1);

   face->receive(Interest("/Hello/World/a")); // shouldn't match
   BOOST_CHECK_EQUAL(nInInterests, 0);

   face->receive(Interest("/Hello/World/a/b")); // should match
   BOOST_CHECK_EQUAL(nInInterests, 1);

   face->receive(Interest("/Hello/World/a/b/c")); // should match
   BOOST_CHECK_EQUAL(nInInterests, 2);

   face->receive(Interest("/Hello/World/a/b/d")); // should not match
   BOOST_CHECK_EQUAL(nInInterests, 2);
 }

 BOOST_FIXTURE_TEST_CASE(SetInterestFilterNoReg, FacesNoRegistrationReplyFixture) // 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));

   auto interest = make_shared<Interest>("/A");
   face->receive(*interest);
   face->processEvents(time::milliseconds(-1));

   BOOST_CHECK_EQUAL(hit, 1);
 }

 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(ExpressInterestWithLocalControlHeader)
 {
   Interest i("/Hello/World");
   i.setNextHopFaceId(1000);
   i.setIncomingFaceId(2000);

   face->expressInterest(i, bind([]{}), bind([]{}));
   advanceClocks(time::milliseconds(10));

   BOOST_REQUIRE_EQUAL(face->sentInterests.size(), 1);
   // only NextHopFaceId is allowed to go out
   BOOST_CHECK(face->sentInterests[0].getLocalControlHeader().hasNextHopFaceId());
   BOOST_CHECK(!face->sentInterests[0].getLocalControlHeader().hasIncomingFaceId());
   BOOST_CHECK_EQUAL(face->sentInterests[0].getNextHopFaceId(), 1000);
 }

 BOOST_AUTO_TEST_CASE(ReceiveInterestWithLocalControlHeader)
 {
   face->setInterestFilter("/Hello/World",
                           [] (const InterestFilter&, const Interest& i) {
                             BOOST_CHECK(i.getLocalControlHeader().hasNextHopFaceId());
                             BOOST_CHECK(i.getLocalControlHeader().hasIncomingFaceId());
                             BOOST_CHECK_EQUAL(i.getNextHopFaceId(), 1000);
                             BOOST_CHECK_EQUAL(i.getIncomingFaceId(), 2000);
                           },
                           bind([]{}),
                           bind([] {
                               BOOST_FAIL("Unexpected setInterestFilter failure");
                             }));
   advanceClocks(time::milliseconds(10));

   Interest i("/Hello/World/!");
   i.setNextHopFaceId(1000);
   i.setIncomingFaceId(2000);

   face->receive(i);
   advanceClocks(time::milliseconds(10));
 }

 BOOST_AUTO_TEST_CASE(PutDataWithLocalControlHeader)
 {
   shared_ptr<Data> d = util::makeData("/Bye/World/!");
   d->setIncomingFaceId(2000);
   d->getLocalControlHeader().setNextHopFaceId(1000); // setNextHopFaceId is intentionally
                                                      // not exposed directly

   face->put(*d);
   advanceClocks(time::milliseconds(10));

   BOOST_REQUIRE_EQUAL(face->sentDatas.size(), 1);
   BOOST_CHECK(!face->sentDatas[0].getLocalControlHeader().hasNextHopFaceId());
   BOOST_CHECK(!face->sentDatas[0].getLocalControlHeader().hasIncomingFaceId());
 }

 BOOST_AUTO_TEST_CASE(ReceiveDataWithLocalControlHeader)
 {
   face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
                         [&] (const Interest& i, const Data& d) {
                           BOOST_CHECK(d.getLocalControlHeader().hasNextHopFaceId());
                           BOOST_CHECK(d.getLocalControlHeader().hasIncomingFaceId());
                           BOOST_CHECK_EQUAL(d.getIncomingFaceId(), 2000);
                           BOOST_CHECK_EQUAL(d.getLocalControlHeader().getNextHopFaceId(), 1000);
                         },
                         bind([] {
                             BOOST_FAIL("Unexpected timeout");
                           }));

   advanceClocks(time::milliseconds(10));

   shared_ptr<Data> d = util::makeData("/Hello/World/!");
   d->setIncomingFaceId(2000);
   d->getLocalControlHeader().setNextHopFaceId(1000); // setNextHopFaceId is intentionally
                                                      // not exposed directly
   face->receive(*d);

   advanceClocks(time::milliseconds(10), 100);
 }

 BOOST_AUTO_TEST_CASE(DestructionWithoutCancellingPendingInterests) // Bug #2518
 {
   face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
                         bind([]{}), bind([]{}));
   advanceClocks(time::milliseconds(10), 10);

   face.reset();

   advanceClocks(time::milliseconds(10), 10);
   // should not segfault
 }

 BOOST_AUTO_TEST_SUITE_END()

 } // tests
 } // namespace ndn
	/* -- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -- */
	/**
	* Copyright (c) 2013-2015 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 "face.hpp"
	#include "util/scheduler.hpp"
	#include "security/key-chain.hpp"
	#include "util/dummy-client-face.hpp"

	#include "boost-test.hpp"
	#include "unit-test-time-fixture.hpp"
	#include "make-interest-data.hpp"

	namespace ndn {
	namespace tests {

	using ndn::util::DummyClientFace;
	using ndn::util::makeDummyClientFace;

	class FaceFixture : public UnitTestTimeFixture
	{
	public:
	explicit
	FaceFixture(bool enableRegistrationReply = true)
	: face(makeDummyClientFace(io, { true, enableRegistrationReply }))
	{
	}

	public:
	shared_ptr<DummyClientFace> face;
	};

	class FacesNoRegistrationReplyFixture : public FaceFixture
	{
	public:
	FacesNoRegistrationReplyFixture()
	: FaceFixture(false)
	{
	}
	};

	BOOST_FIXTURE_TEST_SUITE(TestFace, FaceFixture)

	BOOST_AUTO_TEST_CASE(ExpressInterestData)
	{
	size_t nData = 0;
	face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
	[&] (const Interest& i, const Data& d) {
	BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
	++nData;
	},
	bind([] {
	BOOST_FAIL("Unexpected timeout");
	}));

	advanceClocks(time::milliseconds(1), 40);

	face->receive(*util::makeData("/Bye/World/!"));
	face->receive(*util::makeData("/Hello/World/!"));

	advanceClocks(time::milliseconds(1), 100);

	BOOST_CHECK_EQUAL(nData, 1);
	BOOST_CHECK_EQUAL(face->sentInterests.size(), 1);
	BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);

	face->expressInterest(Interest("/Hello/World/!", time::milliseconds(50)),
	[&] (const Interest& i, const Data& d) {
	BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
	++nData;
	},
	bind([] {
	BOOST_FAIL("Unexpected timeout");
	}));
	advanceClocks(time::milliseconds(1), 40);
	face->receive(*util::makeData("/Hello/World/!/1/xxxxx"));

	advanceClocks(time::milliseconds(1), 100);

	BOOST_CHECK_EQUAL(nData, 2);
	BOOST_CHECK_EQUAL(face->sentInterests.size(), 2);
	BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);

	size_t nTimeouts = 0;
	face->expressInterest(Interest("/Hello/World/!/2", time::milliseconds(50)),
	bind([]{}),
	bind([&nTimeouts] {
	++nTimeouts;
	}));
	advanceClocks(time::milliseconds(10), 100);
	BOOST_CHECK_EQUAL(nTimeouts, 1);
	}

	BOOST_AUTO_TEST_CASE(ExpressInterestTimeout)
	{
	size_t nTimeouts = 0;
	face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
	bind([] {
	BOOST_FAIL("Unexpected data");
	}),
	bind([&nTimeouts] {
	++nTimeouts;
	}));

	advanceClocks(time::milliseconds(10), 100);

	BOOST_CHECK_EQUAL(nTimeouts, 1);
	BOOST_CHECK_EQUAL(face->sentInterests.size(), 1);
	BOOST_CHECK_EQUAL(face->sentDatas.size(), 0);
	}

	BOOST_AUTO_TEST_CASE(RemovePendingInterest)
	{
	const PendingInterestId* interestId =
	face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
	bind([] {
	BOOST_FAIL("Unexpected data");
	}),
	bind([] {
	BOOST_FAIL("Unexpected timeout");
	}));
	advanceClocks(time::milliseconds(10));

	face->removePendingInterest(interestId);
	advanceClocks(time::milliseconds(10));

	face->receive(*util::makeData("/Hello/World/!"));
	advanceClocks(time::milliseconds(10), 100);
	}

	BOOST_AUTO_TEST_CASE(SetUnsetInterestFilter)
	{
	size_t nInterests = 0;
	size_t nRegs = 0;
	const RegisteredPrefixId* regPrefixId =
	face->setInterestFilter("/Hello/World",
	bind([&nInterests] { ++nInterests; }),
	bind([&nRegs] { ++nRegs; }),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));
	advanceClocks(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nRegs, 1);
	BOOST_CHECK_EQUAL(nInterests, 0);

	face->receive(Interest("/Hello/World/!"));
	advanceClocks(time::milliseconds(10), 10);

	BOOST_CHECK_EQUAL(nRegs, 1);
	BOOST_CHECK_EQUAL(nInterests, 1);

	face->receive(Interest("/Bye/World/!"));
	advanceClocks(time::milliseconds(10000), 10);
	BOOST_CHECK_EQUAL(nInterests, 1);

	face->receive(Interest("/Hello/World/!/2"));
	advanceClocks(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nInterests, 2);

	// removing filter
	face->unsetInterestFilter(regPrefixId);
	advanceClocks(time::milliseconds(10), 10);

	face->receive(Interest("/Hello/World/!/3"));
	BOOST_CHECK_EQUAL(nInterests, 2);

	face->unsetInterestFilter(static_cast<const RegisteredPrefixId*>(0));
	advanceClocks(time::milliseconds(10), 10);

	face->unsetInterestFilter(static_cast<const InterestFilterId*>(0));
	advanceClocks(time::milliseconds(10), 10);
	}

	BOOST_FIXTURE_TEST_CASE(SetInterestFilterFail, FacesNoRegistrationReplyFixture)
	{
	// 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(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nRegFailed, 0);

	advanceClocks(time::milliseconds(1000), 10);
	BOOST_CHECK_EQUAL(nRegFailed, 1);
	}

	BOOST_AUTO_TEST_CASE(RegisterUnregisterPrefix)
	{
	size_t nRegSuccesses = 0;
	const RegisteredPrefixId* regPrefixId =
	face->registerPrefix("/Hello/World",
	bind([&nRegSuccesses] { ++nRegSuccesses; }),
	bind([] {
	BOOST_FAIL("Unexpected registerPrefix failure");
	}));

	advanceClocks(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nRegSuccesses, 1);

	size_t nUnregSuccesses = 0;
	face->unregisterPrefix(regPrefixId,
	bind([&nUnregSuccesses] { ++nUnregSuccesses; }),
	bind([] {
	BOOST_FAIL("Unexpected unregisterPrefix failure");
	}));

	advanceClocks(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nUnregSuccesses, 1);
	}

	BOOST_FIXTURE_TEST_CASE(RegisterUnregisterPrefixFail, FacesNoRegistrationReplyFixture)
	{
	size_t nRegFailures = 0;
	face->registerPrefix("/Hello/World",
	bind([] {
	BOOST_FAIL("Unexpected registerPrefix success");
	}),
	bind([&nRegFailures] { ++nRegFailures; }));

	advanceClocks(time::milliseconds(1000), 100);
	BOOST_CHECK_EQUAL(nRegFailures, 1);
	}

	BOOST_AUTO_TEST_CASE(SimilarFilters)
	{
	size_t nInInterests1 = 0;
	face->setInterestFilter("/Hello/World",
	bind([&nInInterests1] { ++nInInterests1; }),
	RegisterPrefixSuccessCallback(),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));

	size_t nInInterests2 = 0;
	face->setInterestFilter("/Hello",
	bind([&nInInterests2] { ++nInInterests2; }),
	RegisterPrefixSuccessCallback(),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));

	size_t nInInterests3 = 0;
	face->setInterestFilter("/Los/Angeles/Lakers",
	bind([&nInInterests3] { ++nInInterests3; }),
	RegisterPrefixSuccessCallback(),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));

	advanceClocks(time::milliseconds(10), 10);

	face->receive(Interest("/Hello/World/!"));
	advanceClocks(time::milliseconds(10), 10);

	BOOST_CHECK_EQUAL(nInInterests1, 1);
	BOOST_CHECK_EQUAL(nInInterests2, 1);
	BOOST_CHECK_EQUAL(nInInterests3, 0);
	}

	BOOST_AUTO_TEST_CASE(SetRegexFilterError)
	{
	face->setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
	[] (const Name&, const Interest&) {
	BOOST_FAIL("InterestFilter::Error should have been triggered");
	},
	RegisterPrefixSuccessCallback(),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));

	advanceClocks(time::milliseconds(10), 10);

	BOOST_REQUIRE_THROW(face->receive(Interest("/Hello/World/XXX/b/c")), InterestFilter::Error);
	}

	BOOST_AUTO_TEST_CASE(SetRegexFilter)
	{
	size_t nInInterests = 0;
	face->setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
	bind([&nInInterests] { ++nInInterests; }),
	RegisterPrefixSuccessCallback(),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));

	advanceClocks(time::milliseconds(10), 10);

	face->receive(Interest("/Hello/World/a")); // shouldn't match
	BOOST_CHECK_EQUAL(nInInterests, 0);

	face->receive(Interest("/Hello/World/a/b")); // should match
	BOOST_CHECK_EQUAL(nInInterests, 1);

	face->receive(Interest("/Hello/World/a/b/c")); // should match
	BOOST_CHECK_EQUAL(nInInterests, 2);

	face->receive(Interest("/Hello/World/a/b/d")); // should not match
	BOOST_CHECK_EQUAL(nInInterests, 2);
	}

	BOOST_AUTO_TEST_CASE(SetRegexFilterAndRegister)
	{
	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(time::milliseconds(10), 10);
	BOOST_CHECK_EQUAL(nRegSuccesses, 1);

	face->receive(Interest("/Hello/World/a")); // shouldn't match
	BOOST_CHECK_EQUAL(nInInterests, 0);

	face->receive(Interest("/Hello/World/a/b")); // should match
	BOOST_CHECK_EQUAL(nInInterests, 1);

	face->receive(Interest("/Hello/World/a/b/c")); // should match
	BOOST_CHECK_EQUAL(nInInterests, 2);

	face->receive(Interest("/Hello/World/a/b/d")); // should not match
	BOOST_CHECK_EQUAL(nInInterests, 2);
	}

	BOOST_FIXTURE_TEST_CASE(SetInterestFilterNoReg, FacesNoRegistrationReplyFixture) // 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));

	auto interest = make_shared<Interest>("/A");
	face->receive(*interest);
	face->processEvents(time::milliseconds(-1));

	BOOST_CHECK_EQUAL(hit, 1);
	}

	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(ExpressInterestWithLocalControlHeader)
	{
	Interest i("/Hello/World");
	i.setNextHopFaceId(1000);
	i.setIncomingFaceId(2000);

	face->expressInterest(i, bind([]{}), bind([]{}));
	advanceClocks(time::milliseconds(10));

	BOOST_REQUIRE_EQUAL(face->sentInterests.size(), 1);
	// only NextHopFaceId is allowed to go out
	BOOST_CHECK(face->sentInterests[0].getLocalControlHeader().hasNextHopFaceId());
	BOOST_CHECK(!face->sentInterests[0].getLocalControlHeader().hasIncomingFaceId());
	BOOST_CHECK_EQUAL(face->sentInterests[0].getNextHopFaceId(), 1000);
	}

	BOOST_AUTO_TEST_CASE(ReceiveInterestWithLocalControlHeader)
	{
	face->setInterestFilter("/Hello/World",
	[] (const InterestFilter&, const Interest& i) {
	BOOST_CHECK(i.getLocalControlHeader().hasNextHopFaceId());
	BOOST_CHECK(i.getLocalControlHeader().hasIncomingFaceId());
	BOOST_CHECK_EQUAL(i.getNextHopFaceId(), 1000);
	BOOST_CHECK_EQUAL(i.getIncomingFaceId(), 2000);
	},
	bind([]{}),
	bind([] {
	BOOST_FAIL("Unexpected setInterestFilter failure");
	}));
	advanceClocks(time::milliseconds(10));

	Interest i("/Hello/World/!");
	i.setNextHopFaceId(1000);
	i.setIncomingFaceId(2000);

	face->receive(i);
	advanceClocks(time::milliseconds(10));
	}

	BOOST_AUTO_TEST_CASE(PutDataWithLocalControlHeader)
	{
	shared_ptr<Data> d = util::makeData("/Bye/World/!");
	d->setIncomingFaceId(2000);
	d->getLocalControlHeader().setNextHopFaceId(1000); // setNextHopFaceId is intentionally
	// not exposed directly

	face->put(*d);
	advanceClocks(time::milliseconds(10));

	BOOST_REQUIRE_EQUAL(face->sentDatas.size(), 1);
	BOOST_CHECK(!face->sentDatas[0].getLocalControlHeader().hasNextHopFaceId());
	BOOST_CHECK(!face->sentDatas[0].getLocalControlHeader().hasIncomingFaceId());
	}

	BOOST_AUTO_TEST_CASE(ReceiveDataWithLocalControlHeader)
	{
	face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
	[&] (const Interest& i, const Data& d) {
	BOOST_CHECK(d.getLocalControlHeader().hasNextHopFaceId());
	BOOST_CHECK(d.getLocalControlHeader().hasIncomingFaceId());
	BOOST_CHECK_EQUAL(d.getIncomingFaceId(), 2000);
	BOOST_CHECK_EQUAL(d.getLocalControlHeader().getNextHopFaceId(), 1000);
	},
	bind([] {
	BOOST_FAIL("Unexpected timeout");
	}));

	advanceClocks(time::milliseconds(10));

	shared_ptr<Data> d = util::makeData("/Hello/World/!");
	d->setIncomingFaceId(2000);
	d->getLocalControlHeader().setNextHopFaceId(1000); // setNextHopFaceId is intentionally
	// not exposed directly
	face->receive(*d);

	advanceClocks(time::milliseconds(10), 100);
	}

	BOOST_AUTO_TEST_CASE(DestructionWithoutCancellingPendingInterests) // Bug #2518
	{
	face->expressInterest(Interest("/Hello/World", time::milliseconds(50)),
	bind([]{}), bind([]{}));
	advanceClocks(time::milliseconds(10), 10);

	face.reset();

	advanceClocks(time::milliseconds(10), 10);
	// should not segfault
	}

	BOOST_AUTO_TEST_SUITE_END()

	} // tests
	} // namespace ndn