blob: ceee9f78a2aac4f8eccc71d4b18294e2d3c00d9e [file] [log] [blame]
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -04001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Junxiao Shi1ad0b4b2017-08-18 14:19:14 +00002/*
Alexander Afanasyev1013fd02017-01-03 13:19:03 -08003 * Copyright (c) 2013-2017 Regents of the University of California.
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -04004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6 *
7 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8 * terms of the GNU Lesser General Public License as published by the Free Software
9 * Foundation, either version 3 of the License, or (at your option) any later version.
10 *
11 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13 * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14 *
15 * You should have received copies of the GNU General Public License and GNU Lesser
16 * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17 * <http://www.gnu.org/licenses/>.
18 *
19 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
20 */
21
22#include "face.hpp"
Junxiao Shia1478db2016-09-09 04:13:15 +000023#include "lp/tags.hpp"
Alexander Afanasyev3a6da362015-12-29 20:31:03 -080024#include "transport/tcp-transport.hpp"
Alexander Afanasyev57e00362016-06-23 13:22:54 -070025#include "transport/unix-transport.hpp"
Junxiao Shia1478db2016-09-09 04:13:15 +000026#include "util/dummy-client-face.hpp"
27#include "util/scheduler.hpp"
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040028
29#include "boost-test.hpp"
Alexander Afanasyeve4f8c3b2016-06-23 16:03:48 -070030#include "identity-management-time-fixture.hpp"
Alexander Afanasyevfc99b512017-01-04 11:10:36 -080031#include "test-home-fixture.hpp"
Spyridon Mastorakis429634f2015-02-19 17:35:33 -080032#include "make-interest-data.hpp"
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040033
34namespace ndn {
35namespace tests {
36
Junxiao Shia60d9362014-11-12 09:38:21 -070037using ndn::util::DummyClientFace;
Junxiao Shia60d9362014-11-12 09:38:21 -070038
Alexander Afanasyev80782e02017-01-04 13:16:54 -080039class FaceFixture : public IdentityManagementTimeFixture
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040040{
41public:
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -080042 explicit
Junxiao Shia1ea5062014-12-27 22:33:39 -070043 FaceFixture(bool enableRegistrationReply = true)
Junxiao Shif5b5ae22016-08-08 05:54:41 +000044 : face(io, m_keyChain, {true, enableRegistrationReply})
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040045 {
46 }
47
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -080048public:
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -080049 DummyClientFace face;
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040050};
51
Junxiao Shia1ea5062014-12-27 22:33:39 -070052class FacesNoRegistrationReplyFixture : public FaceFixture
Junxiao Shia60d9362014-11-12 09:38:21 -070053{
54public:
55 FacesNoRegistrationReplyFixture()
Junxiao Shia1ea5062014-12-27 22:33:39 -070056 : FaceFixture(false)
Junxiao Shia60d9362014-11-12 09:38:21 -070057 {
58 }
59};
60
Junxiao Shia1ea5062014-12-27 22:33:39 -070061BOOST_FIXTURE_TEST_SUITE(TestFace, FaceFixture)
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040062
Junxiao Shi103d8ed2016-08-07 20:34:10 +000063BOOST_AUTO_TEST_SUITE(Consumer)
64
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -040065BOOST_AUTO_TEST_CASE(ExpressInterestData)
66{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -080067 size_t nData = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -080068 face.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
69 [&] (const Interest& i, const Data& d) {
70 BOOST_CHECK(i.getName().isPrefixOf(d.getName()));
71 BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
72 ++nData;
73 },
Junxiao Shi103d8ed2016-08-07 20:34:10 +000074 bind([] { BOOST_FAIL("Unexpected Nack"); }),
75 bind([] { BOOST_FAIL("Unexpected timeout"); }));
Eric Newberry83872fd2015-08-06 17:01:24 -070076
Junxiao Shif5b5ae22016-08-08 05:54:41 +000077 advanceClocks(time::milliseconds(40));
Eric Newberry83872fd2015-08-06 17:01:24 -070078
Junxiao Shi85d90832016-08-04 03:19:46 +000079 face.receive(*makeData("/Bye/World/a"));
80 face.receive(*makeData("/Hello/World/a"));
Eric Newberry83872fd2015-08-06 17:01:24 -070081
Junxiao Shif5b5ae22016-08-08 05:54:41 +000082 advanceClocks(time::milliseconds(50), 2);
Eric Newberry83872fd2015-08-06 17:01:24 -070083
84 BOOST_CHECK_EQUAL(nData, 1);
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -080085 BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
86 BOOST_CHECK_EQUAL(face.sentData.size(), 0);
Eric Newberry83872fd2015-08-06 17:01:24 -070087
88 size_t nTimeouts = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -080089 face.expressInterest(Interest("/Hello/World/a/2", time::milliseconds(50)),
90 bind([]{}),
91 bind([]{}),
Junxiao Shi103d8ed2016-08-07 20:34:10 +000092 bind([&nTimeouts] { ++nTimeouts; }));
Junxiao Shif5b5ae22016-08-08 05:54:41 +000093 advanceClocks(time::milliseconds(200), 5);
Eric Newberry83872fd2015-08-06 17:01:24 -070094 BOOST_CHECK_EQUAL(nTimeouts, 1);
95}
96
Alexander Afanasyev1013fd02017-01-03 13:19:03 -080097BOOST_AUTO_TEST_CASE(ExpressMultipleInterestData)
98{
99 size_t nData = 0;
100
101 face.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
102 [&] (const Interest& i, const Data& d) {
103 ++nData;
104 },
105 bind([] { BOOST_FAIL("Unexpected Nack"); }),
106 bind([] { BOOST_FAIL("Unexpected timeout"); }));
107
108 face.expressInterest(Interest("/Hello/World/a", time::milliseconds(50)),
109 [&] (const Interest& i, const Data& d) {
110 ++nData;
111 },
112 bind([] { BOOST_FAIL("Unexpected Nack"); }),
113 bind([] { BOOST_FAIL("Unexpected timeout"); }));
114
115 advanceClocks(time::milliseconds(40));
116
117 face.receive(*makeData("/Hello/World/a/b"));
118
119 advanceClocks(time::milliseconds(50), 2);
120
121 BOOST_CHECK_EQUAL(nData, 2);
122 BOOST_CHECK_EQUAL(face.sentInterests.size(), 2);
123 BOOST_CHECK_EQUAL(face.sentData.size(), 0);
124}
125
Junxiao Shi76e0eb22016-08-08 05:54:10 +0000126BOOST_AUTO_TEST_CASE(ExpressInterestEmptyDataCallback)
127{
128 face.expressInterest(Interest("/Hello/World"),
129 nullptr,
130 bind([] { BOOST_FAIL("Unexpected Nack"); }),
131 bind([] { BOOST_FAIL("Unexpected timeout"); }));
132 advanceClocks(time::milliseconds(1));
133
134 BOOST_CHECK_NO_THROW(do {
135 face.receive(*makeData("/Hello/World/a"));
136 advanceClocks(time::milliseconds(1));
137 } while (false));
138}
139
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400140BOOST_AUTO_TEST_CASE(ExpressInterestTimeout)
141{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800142 size_t nTimeouts = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800143 face.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000144 bind([] { BOOST_FAIL("Unexpected Data"); }),
145 bind([] { BOOST_FAIL("Unexpected Nack"); }),
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800146 [&nTimeouts] (const Interest& i) {
147 BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
148 ++nTimeouts;
149 });
Eric Newberry83872fd2015-08-06 17:01:24 -0700150
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000151 advanceClocks(time::milliseconds(200), 5);
Eric Newberry83872fd2015-08-06 17:01:24 -0700152
153 BOOST_CHECK_EQUAL(nTimeouts, 1);
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800154 BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
155 BOOST_CHECK_EQUAL(face.sentData.size(), 0);
156 BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
Eric Newberry83872fd2015-08-06 17:01:24 -0700157}
158
Junxiao Shi76e0eb22016-08-08 05:54:10 +0000159BOOST_AUTO_TEST_CASE(ExpressInterestEmptyTimeoutCallback)
160{
161 face.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
162 bind([] { BOOST_FAIL("Unexpected Data"); }),
163 bind([] { BOOST_FAIL("Unexpected Nack"); }),
164 nullptr);
165 advanceClocks(time::milliseconds(40));
166
167 BOOST_CHECK_NO_THROW(do {
168 advanceClocks(time::milliseconds(6), 2);
169 } while (false));
170}
171
Eric Newberry83872fd2015-08-06 17:01:24 -0700172BOOST_AUTO_TEST_CASE(ExpressInterestNack)
173{
174 size_t nNacks = 0;
175
176 Interest interest("/Hello/World", time::milliseconds(50));
177
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800178 face.expressInterest(interest,
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000179 bind([] { BOOST_FAIL("Unexpected Data"); }),
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800180 [&] (const Interest& i, const lp::Nack& n) {
181 BOOST_CHECK(i.getName().isPrefixOf(n.getInterest().getName()));
182 BOOST_CHECK_EQUAL(i.getName(), "/Hello/World");
183 BOOST_CHECK_EQUAL(n.getReason(), lp::NackReason::DUPLICATE);
184 ++nNacks;
185 },
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000186 bind([] { BOOST_FAIL("Unexpected timeout"); }));
Eric Newberry83872fd2015-08-06 17:01:24 -0700187
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000188 advanceClocks(time::milliseconds(40));
Eric Newberry83872fd2015-08-06 17:01:24 -0700189
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000190 face.receive(makeNack(face.sentInterests.at(0), lp::NackReason::DUPLICATE));
Eric Newberry83872fd2015-08-06 17:01:24 -0700191
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000192 advanceClocks(time::milliseconds(50), 2);
Eric Newberry83872fd2015-08-06 17:01:24 -0700193
194 BOOST_CHECK_EQUAL(nNacks, 1);
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800195 BOOST_CHECK_EQUAL(face.sentInterests.size(), 1);
Eric Newberry83872fd2015-08-06 17:01:24 -0700196}
197
Alexander Afanasyev1013fd02017-01-03 13:19:03 -0800198BOOST_AUTO_TEST_CASE(ExpressMultipleInterestNack)
199{
200 size_t nNacks = 0;
201
202 Interest interest("/Hello/World", time::milliseconds(50));
203 interest.setNonce(1);
204
205 face.expressInterest(interest,
206 bind([] { BOOST_FAIL("Unexpected Data"); }),
207 [&] (const Interest& i, const lp::Nack& n) {
208 ++nNacks;
209 },
210 bind([] { BOOST_FAIL("Unexpected timeout"); }));
211
212 interest.setNonce(2);
213 face.expressInterest(interest,
214 bind([] { BOOST_FAIL("Unexpected Data"); }),
215 [&] (const Interest& i, const lp::Nack& n) {
216 ++nNacks;
217 },
218 bind([] { BOOST_FAIL("Unexpected timeout"); }));
219
220 advanceClocks(time::milliseconds(40));
221
222 face.receive(makeNack(face.sentInterests.at(1), lp::NackReason::DUPLICATE));
223
224 advanceClocks(time::milliseconds(50), 2);
225
226 BOOST_CHECK_EQUAL(nNacks, 2);
227 BOOST_CHECK_EQUAL(face.sentInterests.size(), 2);
228}
229
Junxiao Shi76e0eb22016-08-08 05:54:10 +0000230BOOST_AUTO_TEST_CASE(ExpressInterestEmptyNackCallback)
231{
232 face.expressInterest(Interest("/Hello/World"),
233 bind([] { BOOST_FAIL("Unexpected Data"); }),
234 nullptr,
235 bind([] { BOOST_FAIL("Unexpected timeout"); }));
236 advanceClocks(time::milliseconds(1));
237
238 BOOST_CHECK_NO_THROW(do {
239 face.receive(makeNack(face.sentInterests.at(0), lp::NackReason::DUPLICATE));
240 advanceClocks(time::milliseconds(1));
241 } while (false));
242}
243
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800244BOOST_AUTO_TEST_CASE(RemovePendingInterest)
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400245{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800246 const PendingInterestId* interestId =
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800247 face.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000248 bind([] { BOOST_FAIL("Unexpected data"); }),
249 bind([] { BOOST_FAIL("Unexpected nack"); }),
250 bind([] { BOOST_FAIL("Unexpected timeout"); }));
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800251 advanceClocks(time::milliseconds(10));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400252
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800253 face.removePendingInterest(interestId);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800254 advanceClocks(time::milliseconds(10));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400255
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000256 face.receive(*makeData("/Hello/World/%21"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000257 advanceClocks(time::milliseconds(200), 5);
Davide Pesaventoeee3e822016-11-26 19:19:34 +0100258
259 // avoid "test case [...] did not check any assertions" message from Boost.Test
260 BOOST_CHECK(true);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400261}
262
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000263BOOST_AUTO_TEST_CASE(RemoveAllPendingInterests)
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500264{
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800265 face.expressInterest(Interest("/Hello/World/0", time::milliseconds(50)),
266 bind([] { BOOST_FAIL("Unexpected data"); }),
267 bind([] { BOOST_FAIL("Unexpected nack"); }),
268 bind([] { BOOST_FAIL("Unexpected timeout"); }));
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500269
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800270 face.expressInterest(Interest("/Hello/World/1", time::milliseconds(50)),
271 bind([] { BOOST_FAIL("Unexpected data"); }),
272 bind([] { BOOST_FAIL("Unexpected nack"); }),
273 bind([] { BOOST_FAIL("Unexpected timeout"); }));
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500274
275 advanceClocks(time::milliseconds(10));
276
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800277 face.removeAllPendingInterests();
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500278 advanceClocks(time::milliseconds(10));
279
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800280 BOOST_CHECK_EQUAL(face.getNPendingInterests(), 0);
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500281
Junxiao Shi85d90832016-08-04 03:19:46 +0000282 face.receive(*makeData("/Hello/World/0"));
283 face.receive(*makeData("/Hello/World/1"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000284 advanceClocks(time::milliseconds(200), 5);
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500285}
286
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000287BOOST_AUTO_TEST_CASE(DestructionWithoutCancellingPendingInterests) // Bug #2518
288{
289 {
290 DummyClientFace face2(io, m_keyChain);
291 face2.expressInterest(Interest("/Hello/World", time::milliseconds(50)),
Alexander Afanasyeve6835fe2017-01-19 20:05:01 -0800292 nullptr, nullptr, nullptr);
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000293 advanceClocks(time::milliseconds(50), 2);
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000294 }
295
Davide Pesaventoeee3e822016-11-26 19:19:34 +0100296 advanceClocks(time::milliseconds(50), 2); // should not crash
297
298 // avoid "test case [...] did not check any assertions" message from Boost.Test
299 BOOST_CHECK(true);
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000300}
301
302BOOST_AUTO_TEST_SUITE_END() // Consumer
303
304BOOST_AUTO_TEST_SUITE(Producer)
305
Junxiao Shie7bb6c82016-08-08 23:16:35 +0000306BOOST_AUTO_TEST_CASE(PutData)
307{
308 BOOST_CHECK_EQUAL(face.sentData.size(), 0);
309
310 Data data("/4g7xxcuEow/KFvK5Kf2m");
311 signData(data);
312 face.put(data);
313
314 lp::CachePolicy cachePolicy;
315 cachePolicy.setPolicy(lp::CachePolicyType::NO_CACHE);
316 data.setTag(make_shared<lp::CachePolicyTag>(cachePolicy));
Eric Newberry4d261b62016-11-10 13:40:09 -0700317 data.setTag(make_shared<lp::CongestionMarkTag>(1));
Junxiao Shie7bb6c82016-08-08 23:16:35 +0000318 face.put(data);
319
320 advanceClocks(time::milliseconds(10));
321 BOOST_REQUIRE_EQUAL(face.sentData.size(), 2);
322 BOOST_CHECK(face.sentData[0].getTag<lp::CachePolicyTag>() == nullptr);
Eric Newberry4d261b62016-11-10 13:40:09 -0700323 BOOST_CHECK(face.sentData[0].getTag<lp::CongestionMarkTag>() == nullptr);
Junxiao Shie7bb6c82016-08-08 23:16:35 +0000324 BOOST_CHECK(face.sentData[1].getTag<lp::CachePolicyTag>() != nullptr);
Eric Newberry4d261b62016-11-10 13:40:09 -0700325 BOOST_CHECK(face.sentData[1].getTag<lp::CongestionMarkTag>() != nullptr);
Junxiao Shie7bb6c82016-08-08 23:16:35 +0000326}
327
Junxiao Shi859888f2017-09-12 14:29:16 +0000328BOOST_AUTO_TEST_CASE(PutMultipleData)
329{
330 bool hasInterest1 = false;
331 // register two Interest destinations
332 face.setInterestFilter("/", bind([&] {
333 hasInterest1 = true;
334 // sending Data right away from the first destination, don't care whether Interest goes to second destination
335 face.put(*makeData("/A/B"));
336 }));
337 face.setInterestFilter("/", bind([]{}));
338 advanceClocks(time::milliseconds(10));
339
340 face.receive(*makeInterest("/A"));
341 advanceClocks(time::milliseconds(10));
342 BOOST_CHECK(hasInterest1);
343 BOOST_CHECK_EQUAL(face.sentData.size(), 1);
344 BOOST_CHECK_EQUAL(face.sentData.at(0).getName(), "/A/B");
345
346 face.put(*makeData("/A/C"));
347 BOOST_CHECK_EQUAL(face.sentData.size(), 1); // additional Data are ignored
348}
349
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000350BOOST_AUTO_TEST_CASE(PutNack)
351{
Junxiao Shi79a7a162017-09-09 08:33:57 +0000352 face.setInterestFilter("/", bind([]{})); // register one Interest destination so that face can accept Nacks
353 advanceClocks(time::milliseconds(10));
354
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000355 BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
356
Junxiao Shi1ad0b4b2017-08-18 14:19:14 +0000357 face.put(makeNack("/unsolicited", 18645250, lp::NackReason::NO_ROUTE));
Junxiao Shie7bb6c82016-08-08 23:16:35 +0000358 advanceClocks(time::milliseconds(10));
Junxiao Shi1ad0b4b2017-08-18 14:19:14 +0000359 BOOST_CHECK_EQUAL(face.sentNacks.size(), 0); // unsolicited Nack would not be sent
Eric Newberry4d261b62016-11-10 13:40:09 -0700360
Junxiao Shi1ad0b4b2017-08-18 14:19:14 +0000361 face.receive(*makeInterest("/Hello/World", 14247162));
362 face.receive(*makeInterest("/another/prefix", 92203002));
363 advanceClocks(time::milliseconds(10));
364
365 face.put(makeNack("/Hello/World", 14247162, lp::NackReason::DUPLICATE));
366 advanceClocks(time::milliseconds(10));
367 BOOST_REQUIRE_EQUAL(face.sentNacks.size(), 1);
368 BOOST_CHECK_EQUAL(face.sentNacks[0].getReason(), lp::NackReason::DUPLICATE);
369 BOOST_CHECK(face.sentNacks[0].getTag<lp::CongestionMarkTag>() == nullptr);
370
371 auto nack = makeNack("/another/prefix", 92203002, lp::NackReason::NO_ROUTE);
Eric Newberry4d261b62016-11-10 13:40:09 -0700372 nack.setTag(make_shared<lp::CongestionMarkTag>(1));
373 face.put(nack);
Eric Newberry4d261b62016-11-10 13:40:09 -0700374 advanceClocks(time::milliseconds(10));
375 BOOST_REQUIRE_EQUAL(face.sentNacks.size(), 2);
Junxiao Shi1ad0b4b2017-08-18 14:19:14 +0000376 BOOST_CHECK_EQUAL(face.sentNacks[1].getReason(), lp::NackReason::NO_ROUTE);
Eric Newberry4d261b62016-11-10 13:40:09 -0700377 BOOST_CHECK(face.sentNacks[1].getTag<lp::CongestionMarkTag>() != nullptr);
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000378}
Ilya Moiseenko56b0bf82015-11-08 11:14:28 -0500379
Junxiao Shi79a7a162017-09-09 08:33:57 +0000380BOOST_AUTO_TEST_CASE(PutMultipleNack)
381{
Junxiao Shi859888f2017-09-12 14:29:16 +0000382 bool hasInterest1 = false, hasInterest2 = false;
383 // register two Interest destinations
384 face.setInterestFilter("/", [&] (const InterestFilter&, const Interest& interest) {
385 hasInterest1 = true;
386 // sending Nack right away from the first destination, Interest should still go to second destination
387 face.put(makeNack(interest, lp::NackReason::CONGESTION));
388 });
389 face.setInterestFilter("/", bind([&] { hasInterest2 = true; }));
Junxiao Shi79a7a162017-09-09 08:33:57 +0000390 advanceClocks(time::milliseconds(10));
391
392 face.receive(*makeInterest("/A", 14333271));
393 advanceClocks(time::milliseconds(10));
Junxiao Shi859888f2017-09-12 14:29:16 +0000394 BOOST_CHECK(hasInterest1);
395 BOOST_CHECK(hasInterest2);
Junxiao Shi79a7a162017-09-09 08:33:57 +0000396
Junxiao Shi859888f2017-09-12 14:29:16 +0000397 // Nack from first destination is received, should wait for a response from the other destination
398 BOOST_CHECK_EQUAL(face.sentNacks.size(), 0);
Junxiao Shi79a7a162017-09-09 08:33:57 +0000399
400 face.put(makeNack("/A", 14333271, lp::NackReason::NO_ROUTE)); // Nack from second destination
401 advanceClocks(time::milliseconds(10));
Junxiao Shi859888f2017-09-12 14:29:16 +0000402 BOOST_CHECK_EQUAL(face.sentNacks.size(), 1); // sending Nack after both destinations Nacked
Junxiao Shi79a7a162017-09-09 08:33:57 +0000403 BOOST_CHECK_EQUAL(face.sentNacks.at(0).getReason(), lp::NackReason::CONGESTION); // least severe reason
404
405 face.put(makeNack("/A", 14333271, lp::NackReason::DUPLICATE));
406 BOOST_CHECK_EQUAL(face.sentNacks.size(), 1); // additional Nacks are ignored
407}
408
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400409BOOST_AUTO_TEST_CASE(SetUnsetInterestFilter)
410{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800411 size_t nInterests = 0;
412 size_t nRegs = 0;
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400413 const RegisteredPrefixId* regPrefixId =
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800414 face.setInterestFilter("/Hello/World",
415 bind([&nInterests] { ++nInterests; }),
416 bind([&nRegs] { ++nRegs; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000417 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000418 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800419 BOOST_CHECK_EQUAL(nRegs, 1);
420 BOOST_CHECK_EQUAL(nInterests, 0);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400421
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000422 face.receive(Interest("/Hello/World/%21"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000423 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400424
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800425 BOOST_CHECK_EQUAL(nRegs, 1);
426 BOOST_CHECK_EQUAL(nInterests, 1);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400427
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000428 face.receive(Interest("/Bye/World/%21"));
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800429 advanceClocks(time::milliseconds(10000), 10);
430 BOOST_CHECK_EQUAL(nInterests, 1);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400431
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000432 face.receive(Interest("/Hello/World/%21/2"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000433 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800434 BOOST_CHECK_EQUAL(nInterests, 2);
435
436 // removing filter
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800437 face.unsetInterestFilter(regPrefixId);
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000438 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400439
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000440 face.receive(Interest("/Hello/World/%21/3"));
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800441 BOOST_CHECK_EQUAL(nInterests, 2);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400442
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000443 face.unsetInterestFilter(static_cast<const RegisteredPrefixId*>(nullptr));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000444 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400445
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000446 face.unsetInterestFilter(static_cast<const InterestFilterId*>(nullptr));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000447 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800448}
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400449
Junxiao Shi76e0eb22016-08-08 05:54:10 +0000450BOOST_AUTO_TEST_CASE(SetInterestFilterEmptyInterestCallback)
451{
452 face.setInterestFilter("/A", nullptr);
453 advanceClocks(time::milliseconds(1));
454
455 BOOST_CHECK_NO_THROW(do {
456 face.receive(*makeInterest("/A/1"));
457 advanceClocks(time::milliseconds(1));
458 } while (false));
459}
460
Joao Pereira0b3cac52015-07-02 14:49:49 -0400461BOOST_AUTO_TEST_CASE(SetUnsetInterestFilterWithoutSucessCallback)
462{
463 size_t nInterests = 0;
464 const RegisteredPrefixId* regPrefixId =
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800465 face.setInterestFilter("/Hello/World",
466 bind([&nInterests] { ++nInterests; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000467 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000468 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400469 BOOST_CHECK_EQUAL(nInterests, 0);
470
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000471 face.receive(Interest("/Hello/World/%21"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000472 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400473
474 BOOST_CHECK_EQUAL(nInterests, 1);
475
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000476 face.receive(Interest("/Bye/World/%21"));
Joao Pereira0b3cac52015-07-02 14:49:49 -0400477 advanceClocks(time::milliseconds(10000), 10);
478 BOOST_CHECK_EQUAL(nInterests, 1);
479
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000480 face.receive(Interest("/Hello/World/%21/2"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000481 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400482 BOOST_CHECK_EQUAL(nInterests, 2);
483
484 // removing filter
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800485 face.unsetInterestFilter(regPrefixId);
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000486 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400487
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000488 face.receive(Interest("/Hello/World/%21/3"));
Joao Pereira0b3cac52015-07-02 14:49:49 -0400489 BOOST_CHECK_EQUAL(nInterests, 2);
490
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000491 face.unsetInterestFilter(static_cast<const RegisteredPrefixId*>(nullptr));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000492 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400493
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000494 face.unsetInterestFilter(static_cast<const InterestFilterId*>(nullptr));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000495 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400496}
497
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800498BOOST_FIXTURE_TEST_CASE(SetInterestFilterFail, FacesNoRegistrationReplyFixture)
499{
500 // don't enable registration reply
501 size_t nRegFailed = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800502 face.setInterestFilter("/Hello/World",
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000503 bind([] { BOOST_FAIL("Unexpected Interest"); }),
504 bind([] { BOOST_FAIL("Unexpected success of setInterestFilter"); }),
505 bind([&nRegFailed] { ++nRegFailed; }));
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800506
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000507 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800508 BOOST_CHECK_EQUAL(nRegFailed, 0);
509
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000510 advanceClocks(time::milliseconds(2000), 5);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800511 BOOST_CHECK_EQUAL(nRegFailed, 1);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400512}
513
Joao Pereira0b3cac52015-07-02 14:49:49 -0400514BOOST_FIXTURE_TEST_CASE(SetInterestFilterFailWithoutSuccessCallback, FacesNoRegistrationReplyFixture)
515{
516 // don't enable registration reply
517 size_t nRegFailed = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800518 face.setInterestFilter("/Hello/World",
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000519 bind([] { BOOST_FAIL("Unexpected Interest"); }),
520 bind([&nRegFailed] { ++nRegFailed; }));
Joao Pereira0b3cac52015-07-02 14:49:49 -0400521
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000522 advanceClocks(time::milliseconds(25), 4);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400523 BOOST_CHECK_EQUAL(nRegFailed, 0);
524
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000525 advanceClocks(time::milliseconds(2000), 5);
Joao Pereira0b3cac52015-07-02 14:49:49 -0400526 BOOST_CHECK_EQUAL(nRegFailed, 1);
527}
528
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400529BOOST_AUTO_TEST_CASE(RegisterUnregisterPrefix)
530{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800531 size_t nRegSuccesses = 0;
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400532 const RegisteredPrefixId* regPrefixId =
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800533 face.registerPrefix("/Hello/World",
534 bind([&nRegSuccesses] { ++nRegSuccesses; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000535 bind([] { BOOST_FAIL("Unexpected registerPrefix failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400536
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000537 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400538 BOOST_CHECK_EQUAL(nRegSuccesses, 1);
539
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800540 size_t nUnregSuccesses = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800541 face.unregisterPrefix(regPrefixId,
542 bind([&nUnregSuccesses] { ++nUnregSuccesses; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000543 bind([] { BOOST_FAIL("Unexpected unregisterPrefix failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400544
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000545 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400546 BOOST_CHECK_EQUAL(nUnregSuccesses, 1);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400547}
548
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800549BOOST_FIXTURE_TEST_CASE(RegisterUnregisterPrefixFail, FacesNoRegistrationReplyFixture)
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400550{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800551 size_t nRegFailures = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800552 face.registerPrefix("/Hello/World",
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000553 bind([] { BOOST_FAIL("Unexpected registerPrefix success"); }),
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800554 bind([&nRegFailures] { ++nRegFailures; }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400555
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000556 advanceClocks(time::milliseconds(5000), 20);
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800557 BOOST_CHECK_EQUAL(nRegFailures, 1);
558}
559
560BOOST_AUTO_TEST_CASE(SimilarFilters)
561{
562 size_t nInInterests1 = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800563 face.setInterestFilter("/Hello/World",
564 bind([&nInInterests1] { ++nInInterests1; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000565 nullptr,
566 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800567
568 size_t nInInterests2 = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800569 face.setInterestFilter("/Hello",
570 bind([&nInInterests2] { ++nInInterests2; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000571 nullptr,
572 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400573
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800574 size_t nInInterests3 = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800575 face.setInterestFilter("/Los/Angeles/Lakers",
576 bind([&nInInterests3] { ++nInInterests3; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000577 nullptr,
578 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400579
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000580 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400581
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000582 face.receive(Interest("/Hello/World/%21"));
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000583 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400584
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800585 BOOST_CHECK_EQUAL(nInInterests1, 1);
586 BOOST_CHECK_EQUAL(nInInterests2, 1);
587 BOOST_CHECK_EQUAL(nInInterests3, 0);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400588}
589
590BOOST_AUTO_TEST_CASE(SetRegexFilterError)
591{
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800592 face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
593 [] (const Name&, const Interest&) {
594 BOOST_FAIL("InterestFilter::Error should have been triggered");
595 },
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000596 nullptr,
597 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400598
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000599 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400600
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800601 BOOST_REQUIRE_THROW(face.receive(Interest("/Hello/World/XXX/b/c")), InterestFilter::Error);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400602}
603
604BOOST_AUTO_TEST_CASE(SetRegexFilter)
605{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800606 size_t nInInterests = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800607 face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
608 bind([&nInInterests] { ++nInInterests; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000609 nullptr,
610 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400611
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000612 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400613
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800614 face.receive(Interest("/Hello/World/a")); // shouldn't match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400615 BOOST_CHECK_EQUAL(nInInterests, 0);
616
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800617 face.receive(Interest("/Hello/World/a/b")); // should match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400618 BOOST_CHECK_EQUAL(nInInterests, 1);
619
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800620 face.receive(Interest("/Hello/World/a/b/c")); // should match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400621 BOOST_CHECK_EQUAL(nInInterests, 2);
622
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800623 face.receive(Interest("/Hello/World/a/b/d")); // should not match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400624 BOOST_CHECK_EQUAL(nInInterests, 2);
625}
626
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400627BOOST_AUTO_TEST_CASE(SetRegexFilterAndRegister)
628{
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800629 size_t nInInterests = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800630 face.setInterestFilter(InterestFilter("/Hello/World", "<><b><c>?"),
631 bind([&nInInterests] { ++nInInterests; }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400632
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800633 size_t nRegSuccesses = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800634 face.registerPrefix("/Hello/World",
635 bind([&nRegSuccesses] { ++nRegSuccesses; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000636 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400637
Junxiao Shif5b5ae22016-08-08 05:54:41 +0000638 advanceClocks(time::milliseconds(25), 4);
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400639 BOOST_CHECK_EQUAL(nRegSuccesses, 1);
640
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800641 face.receive(Interest("/Hello/World/a")); // shouldn't match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400642 BOOST_CHECK_EQUAL(nInInterests, 0);
643
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800644 face.receive(Interest("/Hello/World/a/b")); // should match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400645 BOOST_CHECK_EQUAL(nInInterests, 1);
646
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800647 face.receive(Interest("/Hello/World/a/b/c")); // should match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400648 BOOST_CHECK_EQUAL(nInInterests, 2);
649
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800650 face.receive(Interest("/Hello/World/a/b/d")); // should not match
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400651 BOOST_CHECK_EQUAL(nInInterests, 2);
652}
653
Junxiao Shia1ea5062014-12-27 22:33:39 -0700654BOOST_FIXTURE_TEST_CASE(SetInterestFilterNoReg, FacesNoRegistrationReplyFixture) // Bug 2318
655{
656 // This behavior is specific to DummyClientFace.
657 // Regular Face won't accept incoming packets until something is sent.
658
659 int hit = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800660 face.setInterestFilter(Name("/"), bind([&hit] { ++hit; }));
661 face.processEvents(time::milliseconds(-1));
Junxiao Shia1ea5062014-12-27 22:33:39 -0700662
663 auto interest = make_shared<Interest>("/A");
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800664 face.receive(*interest);
665 face.processEvents(time::milliseconds(-1));
Junxiao Shia1ea5062014-12-27 22:33:39 -0700666
667 BOOST_CHECK_EQUAL(hit, 1);
668}
669
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000670BOOST_AUTO_TEST_SUITE_END() // Producer
671
Junxiao Shiae0b4182016-08-08 22:53:17 +0000672BOOST_AUTO_TEST_SUITE(IoRoutines)
673
Alexander Afanasyev8e158542014-11-18 00:47:18 -0500674BOOST_AUTO_TEST_CASE(ProcessEvents)
675{
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800676 face.processEvents(time::milliseconds(-1)); // io_service::reset()/poll() inside
Alexander Afanasyev8e158542014-11-18 00:47:18 -0500677
Alexander Afanasyevd3a55b22014-11-18 19:23:28 -0800678 size_t nRegSuccesses = 0;
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800679 face.registerPrefix("/Hello/World",
680 bind([&nRegSuccesses] { ++nRegSuccesses; }),
Junxiao Shi103d8ed2016-08-07 20:34:10 +0000681 bind([] { BOOST_FAIL("Unexpected setInterestFilter failure"); }));
Alexander Afanasyev8e158542014-11-18 00:47:18 -0500682
683 // io_service::poll() without reset
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800684 face.getIoService().poll();
Alexander Afanasyev8e158542014-11-18 00:47:18 -0500685 BOOST_CHECK_EQUAL(nRegSuccesses, 0);
686
Alexander Afanasyev9bdbb832015-12-30 12:54:22 -0800687 face.processEvents(time::milliseconds(-1)); // io_service::reset()/poll() inside
Alexander Afanasyev8e158542014-11-18 00:47:18 -0500688 BOOST_CHECK_EQUAL(nRegSuccesses, 1);
689}
690
Junxiao Shiae0b4182016-08-08 22:53:17 +0000691BOOST_AUTO_TEST_CASE(DestroyWithoutProcessEvents) // Bug 3248
692{
693 auto face2 = make_unique<Face>(io);
694 face2.reset();
695
696 io.poll(); // should not crash
Davide Pesaventoeee3e822016-11-26 19:19:34 +0100697
698 // avoid "test case [...] did not check any assertions" message from Boost.Test
699 BOOST_CHECK(true);
Junxiao Shiae0b4182016-08-08 22:53:17 +0000700}
701
702BOOST_AUTO_TEST_SUITE_END() // IoRoutines
703
704BOOST_AUTO_TEST_SUITE(Transport)
705
706using ndn::Transport;
707
Alexander Afanasyeve4f8c3b2016-06-23 16:03:48 -0700708struct PibDirWithDefaultTpm
709{
710 const std::string PATH = "build/keys-with-default-tpm";
711};
712
Alexander Afanasyev80782e02017-01-04 13:16:54 -0800713BOOST_FIXTURE_TEST_CASE(FaceTransport, IdentityManagementTimeFixture)
Alexander Afanasyev3a6da362015-12-29 20:31:03 -0800714{
Alexander Afanasyev3a6da362015-12-29 20:31:03 -0800715 BOOST_CHECK(Face().getTransport() != nullptr);
716
Alexander Afanasyevbb64c172015-12-29 20:32:45 -0800717 BOOST_CHECK(Face(shared_ptr<Transport>()).getTransport() != nullptr);
718 BOOST_CHECK(Face(shared_ptr<Transport>(), io).getTransport() != nullptr);
Alexander Afanasyev80782e02017-01-04 13:16:54 -0800719 BOOST_CHECK(Face(shared_ptr<Transport>(), io, m_keyChain).getTransport() != nullptr);
Alexander Afanasyev3a6da362015-12-29 20:31:03 -0800720
721 auto transport = make_shared<TcpTransport>("localhost", "6363"); // no real io operations will be scheduled
722 BOOST_CHECK(Face(transport).getTransport() == transport);
723 BOOST_CHECK(Face(transport, io).getTransport() == transport);
Alexander Afanasyev80782e02017-01-04 13:16:54 -0800724 BOOST_CHECK(Face(transport, io, m_keyChain).getTransport() == transport);
Alexander Afanasyev3a6da362015-12-29 20:31:03 -0800725}
726
Alexander Afanasyevcf490552016-06-27 22:51:36 -0700727class WithEnv : private IdentityManagementTimeFixture
728{
729public:
730 WithEnv()
731 {
732 if (getenv("NDN_CLIENT_TRANSPORT") != nullptr) {
733 m_oldTransport = getenv("NDN_CLIENT_TRANSPORT");
734 unsetenv("NDN_CLIENT_TRANSPORT");
735 }
736 }
737
738 void
739 configure(const std::string& faceUri)
740 {
741 setenv("NDN_CLIENT_TRANSPORT", faceUri.c_str(), true);
742 }
743
744 ~WithEnv()
745 {
746 if (!m_oldTransport.empty()) {
747 setenv("NDN_CLIENT_TRANSPORT", m_oldTransport.c_str(), true);
748 }
749 else {
750 unsetenv("NDN_CLIENT_TRANSPORT");
751 }
752 }
753
754private:
755 std::string m_oldTransport;
756};
757
758class WithConfig : private TestHomeFixture<DefaultPibDir>
759{
760public:
761 void
762 configure(const std::string& faceUri)
763 {
764 createClientConf({"transport=" + faceUri});
765 }
766};
767
768class WithEnvAndConfig : public WithEnv, public WithConfig
769{
770};
771
772typedef boost::mpl::vector<WithEnv, WithConfig> ConfigOptions;
773
774BOOST_FIXTURE_TEST_CASE(NoConfig, WithEnvAndConfig) // fixture configures test HOME and PIB/TPM path
Alexander Afanasyev57e00362016-06-23 13:22:54 -0700775{
776 shared_ptr<Face> face;
777 BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
778 BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
Alexander Afanasyev57e00362016-06-23 13:22:54 -0700779}
780
Alexander Afanasyevcf490552016-06-27 22:51:36 -0700781BOOST_FIXTURE_TEST_CASE_TEMPLATE(Unix, T, ConfigOptions, T)
782{
783 this->configure("unix://some/path");
Alexander Afanasyev57e00362016-06-23 13:22:54 -0700784
Alexander Afanasyevcf490552016-06-27 22:51:36 -0700785 shared_ptr<Face> face;
786 BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
787 BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
788}
789
790BOOST_FIXTURE_TEST_CASE_TEMPLATE(Tcp, T, ConfigOptions, T)
791{
792 this->configure("tcp://127.0.0.1:6000");
793
794 shared_ptr<Face> face;
795 BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
796 BOOST_CHECK(dynamic_pointer_cast<TcpTransport>(face->getTransport()) != nullptr);
797}
798
799BOOST_FIXTURE_TEST_CASE_TEMPLATE(WrongTransport, T, ConfigOptions, T)
800{
801 this->configure("wrong-transport:");
802
803 BOOST_CHECK_THROW(make_shared<Face>(), ConfigFile::Error);
804}
805
806BOOST_FIXTURE_TEST_CASE_TEMPLATE(WrongUri, T, ConfigOptions, T)
807{
808 this->configure("wrong-uri");
809
810 BOOST_CHECK_THROW(make_shared<Face>(), ConfigFile::Error);
811}
812
813BOOST_FIXTURE_TEST_CASE(EnvOverride, WithEnvAndConfig)
814{
815 this->WithEnv::configure("tcp://127.0.0.1:6000");
816 this->WithConfig::configure("unix://some/path");
817
818 shared_ptr<Face> face;
819 BOOST_REQUIRE_NO_THROW(face = make_shared<Face>());
820 BOOST_CHECK(dynamic_pointer_cast<TcpTransport>(face->getTransport()) != nullptr);
821}
822
823BOOST_FIXTURE_TEST_CASE(ExplicitTransport, WithEnvAndConfig)
824{
825 this->WithEnv::configure("wrong-uri");
826 this->WithConfig::configure("wrong-transport:");
827
828 auto transport = make_shared<UnixTransport>("unix://some/path");
829 shared_ptr<Face> face;
830 BOOST_REQUIRE_NO_THROW(face = make_shared<Face>(transport));
831 BOOST_CHECK(dynamic_pointer_cast<UnixTransport>(face->getTransport()) != nullptr);
832}
833
Junxiao Shiae0b4182016-08-08 22:53:17 +0000834BOOST_AUTO_TEST_SUITE_END() // Transport
835
Alexander Afanasyev57e00362016-06-23 13:22:54 -0700836BOOST_AUTO_TEST_SUITE_END() // TestFace
837
838} // namespace tests
Alexander Afanasyev5fc795f2014-10-20 23:06:56 -0400839} // namespace ndn