blob: 9f52acd62daaadca52a5e19d858054a5483102aa [file] [log] [blame]
Alexander Afanasyevc169a812014-05-20 20:37:29 -04001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -07002/**
Alexander Afanasyevc169a812014-05-20 20:37:29 -04003 * Copyright (c) 2013-2014 Regents of the University of California.
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07006 *
Alexander Afanasyevc169a812014-05-20 20:37:29 -04007 * 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.
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -070020 *
21 * Based on code originally written by Jeff Thompson <jefft0@remap.ucla.edu>
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -070022 */
23
Alexander Afanasyev09c613f2014-01-29 00:23:58 -080024#include "face.hpp"
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070025#include "detail/face-impl.hpp"
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -070026
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070027#include "interest.hpp"
28#include "data.hpp"
29#include "security/identity-certificate.hpp"
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080030
31#include "util/time.hpp"
32#include "util/random.hpp"
Jeff Thompsonb982b6d2013-07-15 18:15:45 -070033
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -070034namespace ndn {
Alexander Afanasyevb790d952014-01-24 12:07:53 -080035
Alexander Afanasyevf7ca3202014-02-14 22:28:31 -080036Face::Face()
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -070037 : m_nfdController(new nfd::Controller(*this))
38 , m_isDirectNfdFibManagementRequested(false)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070039 , m_impl(make_shared<Impl>(ref(*this)))
Jeff Thompsonfb29cda2013-08-24 10:26:54 -070040{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070041 const std::string socketName = UnixTransport::getDefaultSocketName(m_impl->m_config);
Alexander Afanasyevf73f0632014-05-12 18:02:37 -070042 construct(make_shared<UnixTransport>(socketName),
Alexander Afanasyev505646e2014-02-24 20:13:37 -080043 make_shared<boost::asio::io_service>());
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080044}
45
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -080046Face::Face(const shared_ptr<boost::asio::io_service>& ioService)
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -070047 : m_nfdController(new nfd::Controller(*this))
48 , m_isDirectNfdFibManagementRequested(false)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070049 , m_impl(make_shared<Impl>(ref(*this)))
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -080050{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070051 const std::string socketName = UnixTransport::getDefaultSocketName(m_impl->m_config);
Alexander Afanasyevf73f0632014-05-12 18:02:37 -070052 construct(make_shared<UnixTransport>(socketName),
Alexander Afanasyev505646e2014-02-24 20:13:37 -080053 ioService);
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -080054}
55
Alexander Afanasyev691c3ce2014-04-23 14:28:04 -070056class NullIoDeleter
57{
58public:
59 void
60 operator()(boost::asio::io_service*)
61 {
62 }
63};
64
65Face::Face(boost::asio::io_service& ioService)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070066 : m_nfdController(make_shared<nfd::Controller>(ref(*this)))
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -070067 , m_isDirectNfdFibManagementRequested(false)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070068 , m_impl(make_shared<Impl>(ref(*this)))
Alexander Afanasyev691c3ce2014-04-23 14:28:04 -070069{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070070 const std::string socketName = UnixTransport::getDefaultSocketName(m_impl->m_config);
Alexander Afanasyevf73f0632014-05-12 18:02:37 -070071 construct(make_shared<UnixTransport>(socketName),
Alexander Afanasyev691c3ce2014-04-23 14:28:04 -070072 shared_ptr<boost::asio::io_service>(&ioService, NullIoDeleter()));
73}
74
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -080075Face::Face(const std::string& host, const std::string& port/* = "6363"*/)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070076 : m_nfdController(make_shared<nfd::Controller>(ref(*this)))
77 , m_impl(make_shared<Impl>(ref(*this)))
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080078{
Alexander Afanasyevf73f0632014-05-12 18:02:37 -070079 construct(make_shared<TcpTransport>(host, port),
Alexander Afanasyev505646e2014-02-24 20:13:37 -080080 make_shared<boost::asio::io_service>());
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080081}
82
Alexander Afanasyevf7ca3202014-02-14 22:28:31 -080083Face::Face(const shared_ptr<Transport>& transport)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070084 : m_nfdController(make_shared<nfd::Controller>(ref(*this)))
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -070085 , m_isDirectNfdFibManagementRequested(false)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070086 , m_impl(make_shared<Impl>(ref(*this)))
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080087{
88 construct(transport,
Alexander Afanasyev505646e2014-02-24 20:13:37 -080089 make_shared<boost::asio::io_service>());
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080090}
91
92Face::Face(const shared_ptr<Transport>& transport,
Alexander Afanasyev691c3ce2014-04-23 14:28:04 -070093 boost::asio::io_service& ioService)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070094 : m_nfdController(make_shared<nfd::Controller>(ref(*this)))
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -070095 , m_isDirectNfdFibManagementRequested(false)
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -070096 , m_impl(make_shared<Impl>(ref(*this)))
Alexander Afanasyev0222fba2014-02-09 23:16:02 -080097{
Alexander Afanasyev691c3ce2014-04-23 14:28:04 -070098 construct(transport,
99 shared_ptr<boost::asio::io_service>(&ioService, NullIoDeleter()));
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -0800100}
101
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800102void
103Face::construct(const shared_ptr<Transport>& transport,
Alexander Afanasyev505646e2014-02-24 20:13:37 -0800104 const shared_ptr<boost::asio::io_service>& ioService)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800105{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700106 m_impl->m_pitTimeoutCheckTimerActive = false;
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800107 m_transport = transport;
108 m_ioService = ioService;
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800109
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700110 m_impl->m_pitTimeoutCheckTimer = make_shared<monotonic_deadline_timer>(ref(*m_ioService));
111 m_impl->m_processEventsTimeoutTimer = make_shared<monotonic_deadline_timer>(ref(*m_ioService));
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800112
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600113 std::string protocol = "nrd-0.1";
114
115 try
Alexander Afanasyevefe3ab22014-02-19 14:57:50 -0800116 {
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700117 protocol = m_impl->m_config.getParsedConfiguration().get<std::string>("protocol");
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600118 }
Alexander Afanasyev2a7f7202014-04-23 14:25:29 -0700119 catch (boost::property_tree::ptree_bad_path& error)
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600120 {
121 // protocol not specified
122 }
Alexander Afanasyev2a7f7202014-04-23 14:25:29 -0700123 catch (boost::property_tree::ptree_bad_data& error)
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600124 {
125 throw ConfigFile::Error(error.what());
126 }
127
128 if (isSupportedNrdProtocol(protocol))
129 {
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -0700130 // do nothing
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600131 }
Steve DiBenedettoacab8802014-03-24 11:15:57 -0600132 else if (isSupportedNfdProtocol(protocol))
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600133 {
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -0700134 m_isDirectNfdFibManagementRequested = true;
Alexander Afanasyevefe3ab22014-02-19 14:57:50 -0800135 }
Jeff Thompsonfb29cda2013-08-24 10:26:54 -0700136 else
Steve DiBenedettoc07b3a22014-03-19 12:32:52 -0600137 {
138 throw Face::Error("Cannot create controller for unsupported protocol \"" + protocol + "\"");
139 }
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800140}
141
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800142const PendingInterestId*
143Face::expressInterest(const Interest& interest, const OnData& onData, const OnTimeout& onTimeout)
144{
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800145 if (!m_transport->isConnected())
146 m_transport->connect(*m_ioService,
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800147 bind(&Face::onReceiveElement, this, _1));
148
Alexander Afanasyevf73f0632014-05-12 18:02:37 -0700149 shared_ptr<Interest> interestToExpress = make_shared<Interest>(interest);
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800150
Alexander Afanasyev4e50b972014-03-25 10:57:50 -0700151 // If the same ioService thread, dispatch directly calls the method
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700152 m_ioService->dispatch(bind(&Impl::asyncExpressInterest, m_impl,
Alexander Afanasyev4e50b972014-03-25 10:57:50 -0700153 interestToExpress, onData, onTimeout));
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800154
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800155 return reinterpret_cast<const PendingInterestId*>(interestToExpress.get());
156}
157
158const PendingInterestId*
159Face::expressInterest(const Name& name,
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -0800160 const Interest& tmpl,
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800161 const OnData& onData, const OnTimeout& onTimeout/* = OnTimeout()*/)
162{
Alexander Afanasyev9c578182014-05-14 17:28:28 -0700163 return expressInterest(Interest(tmpl)
164 .setName(name)
165 .setNonce(0),
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800166 onData, onTimeout);
167}
168
169void
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -0800170Face::put(const Data& data)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800171{
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800172 if (!m_transport->isConnected())
173 m_transport->connect(*m_ioService,
Alexander Afanasyev6d48bc12014-02-18 00:10:51 -0800174 bind(&Face::onReceiveElement, this, _1));
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800175
Alexander Afanasyev5964fb72014-02-18 12:42:45 -0800176 if (!data.getLocalControlHeader().empty(false, true))
177 {
Alexander Afanasyev83018352014-02-18 19:52:15 -0800178 m_transport->send(data.getLocalControlHeader().wireEncode(data, false, true),
179 data.wireEncode());
Alexander Afanasyev5964fb72014-02-18 12:42:45 -0800180 }
181 else
182 {
Alexander Afanasyev83018352014-02-18 19:52:15 -0800183 m_transport->send(data.wireEncode());
Alexander Afanasyev5964fb72014-02-18 12:42:45 -0800184 }
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800185}
186
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800187void
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -0800188Face::removePendingInterest(const PendingInterestId* pendingInterestId)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800189{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700190 m_ioService->post(bind(&Impl::asyncRemovePendingInterest, m_impl, pendingInterestId));
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800191}
192
193
Alexander Afanasyevee8bb1e2014-05-02 17:39:54 -0700194
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800195const RegisteredPrefixId*
Alexander Afanasyev90164962014-03-06 08:29:59 +0000196Face::setInterestFilter(const InterestFilter& interestFilter,
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800197 const OnInterest& onInterest,
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700198 const RegisterPrefixSuccessCallback& onSuccess,
199 const RegisterPrefixFailureCallback& onFailure,
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700200 const IdentityCertificate& certificate)
201{
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700202 shared_ptr<InterestFilterRecord> filter =
203 make_shared<InterestFilterRecord>(interestFilter, onInterest);
204
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700205 return m_impl->registerPrefix(interestFilter.getPrefix(), filter,
206 onSuccess, onFailure,
207 certificate);
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700208}
209
210const RegisteredPrefixId*
Alexander Afanasyev90164962014-03-06 08:29:59 +0000211Face::setInterestFilter(const InterestFilter& interestFilter,
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700212 const OnInterest& onInterest,
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700213 const RegisterPrefixFailureCallback& onFailure,
214 const IdentityCertificate& certificate)
215{
216 shared_ptr<InterestFilterRecord> filter =
217 make_shared<InterestFilterRecord>(interestFilter, onInterest);
218
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700219 return m_impl->registerPrefix(interestFilter.getPrefix(), filter,
220 RegisterPrefixSuccessCallback(), onFailure,
221 certificate);
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700222}
223
224const RegisteredPrefixId*
225Face::setInterestFilter(const InterestFilter& interestFilter,
226 const OnInterest& onInterest,
227 const RegisterPrefixSuccessCallback& onSuccess,
228 const RegisterPrefixFailureCallback& onFailure,
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700229 const Name& identity)
230{
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700231 shared_ptr<InterestFilterRecord> filter =
232 make_shared<InterestFilterRecord>(interestFilter, onInterest);
233
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700234 return m_impl->registerPrefix(interestFilter.getPrefix(), filter,
235 onSuccess, onFailure,
236 identity);
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700237}
238
239const RegisteredPrefixId*
240Face::setInterestFilter(const InterestFilter& interestFilter,
241 const OnInterest& onInterest,
242 const RegisterPrefixFailureCallback& onFailure,
243 const Name& identity)
244{
245 shared_ptr<InterestFilterRecord> filter =
246 make_shared<InterestFilterRecord>(interestFilter, onInterest);
247
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700248 return m_impl->registerPrefix(interestFilter.getPrefix(), filter,
249 RegisterPrefixSuccessCallback(), onFailure,
250 identity);
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700251}
252
253
254const InterestFilterId*
255Face::setInterestFilter(const InterestFilter& interestFilter,
256 const OnInterest& onInterest)
257{
258 shared_ptr<InterestFilterRecord> filter =
259 make_shared<InterestFilterRecord>(interestFilter, onInterest);
260
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700261 getIoService().post(bind(&Impl::asyncSetInterestFilter, m_impl, filter));
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700262
263 return reinterpret_cast<const InterestFilterId*>(filter.get());
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700264}
265
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700266const RegisteredPrefixId*
267Face::registerPrefix(const Name& prefix,
268 const RegisterPrefixSuccessCallback& onSuccess,
269 const RegisterPrefixFailureCallback& onFailure,
270 const IdentityCertificate& certificate)
271{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700272 return m_impl->registerPrefix(prefix, shared_ptr<InterestFilterRecord>(),
273 onSuccess, onFailure,
274 certificate);
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700275}
276
277const RegisteredPrefixId*
278Face::registerPrefix(const Name& prefix,
279 const RegisterPrefixSuccessCallback& onSuccess,
280 const RegisterPrefixFailureCallback& onFailure,
281 const Name& identity)
282{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700283 return m_impl->registerPrefix(prefix, shared_ptr<InterestFilterRecord>(),
284 onSuccess, onFailure,
285 identity);
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700286}
287
288
289void
Alexander Afanasyev7682ccb2014-02-20 10:29:35 -0800290Face::unsetInterestFilter(const RegisteredPrefixId* registeredPrefixId)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800291{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700292 m_ioService->post(bind(&Impl::asyncUnregisterPrefix, m_impl, registeredPrefixId,
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700293 UnregisterPrefixSuccessCallback(), UnregisterPrefixFailureCallback()));
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800294}
295
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700296void
297Face::unsetInterestFilter(const InterestFilterId* interestFilterId)
298{
299 m_ioService->post(bind(&Impl::asyncUnsetInterestFilter, m_impl, interestFilterId));
300}
Yingdi Yue66bf2a2014-04-28 17:07:36 -0700301
302void
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700303Face::unregisterPrefix(const RegisteredPrefixId* registeredPrefixId,
304 const UnregisterPrefixSuccessCallback& onSuccess,
305 const UnregisterPrefixFailureCallback& onFailure)
306{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700307 m_ioService->post(bind(&Impl::asyncUnregisterPrefix, m_impl, registeredPrefixId,
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700308 onSuccess, onFailure));
309}
310
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800311void
Alexander Afanasyevaa0e7da2014-03-17 14:37:33 -0700312Face::processEvents(const time::milliseconds& timeout/* = time::milliseconds::zero()*/,
313 bool keepThread/* = false*/)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800314{
315 try
316 {
Alexander Afanasyevaa0e7da2014-03-17 14:37:33 -0700317 if (timeout < time::milliseconds::zero())
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800318 {
319 // do not block if timeout is negative, but process pending events
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800320 m_ioService->poll();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800321 return;
322 }
323
Alexander Afanasyevaa0e7da2014-03-17 14:37:33 -0700324 if (timeout > time::milliseconds::zero())
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800325 {
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700326 m_impl->m_processEventsTimeoutTimer->expires_from_now(time::milliseconds(timeout));
327 m_impl->m_processEventsTimeoutTimer->async_wait(&fireProcessEventsTimeout);
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800328 }
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800329
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800330 if (keepThread) {
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800331 // work will ensure that m_ioService is running until work object exists
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700332 m_impl->m_ioServiceWork = make_shared<boost::asio::io_service::work>(ref(*m_ioService));
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800333 }
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800334
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800335 m_ioService->run();
336 m_ioService->reset(); // so it is possible to run processEvents again (if necessary)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800337 }
Alexander Afanasyevfdbfc6d2014-04-14 15:12:11 -0700338 catch (Face::ProcessEventsTimeout&)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800339 {
340 // break
Alexander Afanasyev1f5486e2014-07-10 17:45:49 -0700341 m_impl->m_ioServiceWork.reset();
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800342 m_ioService->reset();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800343 }
Alexander Afanasyev2a7f7202014-04-23 14:25:29 -0700344 catch (std::exception&)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800345 {
Alexander Afanasyev1f5486e2014-07-10 17:45:49 -0700346 m_impl->m_ioServiceWork.reset();
Alexander Afanasyevf39c5372014-02-17 19:42:56 -0800347 m_ioService->reset();
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700348 m_impl->m_pendingInterestTable.clear();
349 m_impl->m_registeredPrefixTable.clear();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800350 throw;
351 }
Jeff Thompsonfb29cda2013-08-24 10:26:54 -0700352}
353
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800354void
Jeff Thompson0050abe2013-09-17 12:50:25 -0700355Face::shutdown()
Jeff Thompson517ffa82013-08-05 16:04:34 -0700356{
Alexander Afanasyev7dced462014-03-19 15:12:32 -0700357 m_ioService->post(bind(&Face::asyncShutdown, this));
358}
359
360void
361Face::asyncShutdown()
362{
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700363 m_impl->m_pendingInterestTable.clear();
364 m_impl->m_registeredPrefixTable.clear();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800365
Alexander Afanasyev984ad192014-05-02 19:11:15 -0700366 if (m_transport->isConnected())
367 m_transport->close();
368
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700369 m_impl->m_pitTimeoutCheckTimer->cancel();
370 m_impl->m_processEventsTimeoutTimer->cancel();
371 m_impl->m_pitTimeoutCheckTimerActive = false;
Alexander Afanasyev1f5486e2014-07-10 17:45:49 -0700372
373 m_impl->m_ioServiceWork.reset();
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -0700374}
375
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800376void
377Face::fireProcessEventsTimeout(const boost::system::error_code& error)
378{
379 if (!error) // can fire for some other reason, e.g., cancelled
380 throw Face::ProcessEventsTimeout();
Jeff Thompsonaa4e6db2013-07-15 17:25:23 -0700381}
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800382
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800383
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800384void
Alexander Afanasyev6d48bc12014-02-18 00:10:51 -0800385Face::onReceiveElement(const Block& blockFromDaemon)
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800386{
Alexander Afanasyev6d48bc12014-02-18 00:10:51 -0800387 const Block& block = nfd::LocalControlHeader::getPayload(blockFromDaemon);
388
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800389 if (block.type() == Tlv::Interest)
390 {
Alexander Afanasyevf73f0632014-05-12 18:02:37 -0700391 shared_ptr<Interest> interest = make_shared<Interest>();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800392 interest->wireDecode(block);
Alexander Afanasyev6d48bc12014-02-18 00:10:51 -0800393 if (&block != &blockFromDaemon)
394 interest->getLocalControlHeader().wireDecode(blockFromDaemon);
Alexander Afanasyeva68aa7f2014-02-11 15:42:33 -0800395
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700396 m_impl->processInterestFilters(*interest);
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800397 }
398 else if (block.type() == Tlv::Data)
399 {
Alexander Afanasyevf73f0632014-05-12 18:02:37 -0700400 shared_ptr<Data> data = make_shared<Data>();
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800401 data->wireDecode(block);
Alexander Afanasyev6d48bc12014-02-18 00:10:51 -0800402 if (&block != &blockFromDaemon)
403 data->getLocalControlHeader().wireDecode(blockFromDaemon);
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800404
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700405 m_impl->satisfyPendingInterests(*data);
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800406
Alexander Afanasyev258ec2b2014-05-14 16:15:37 -0700407 if (m_impl->m_pendingInterestTable.empty()) {
408 m_impl->m_pitTimeoutCheckTimer->cancel(); // this will cause checkPitExpire invocation
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800409 }
410 }
Yingdi Yuf9fa52f2014-02-06 12:27:32 -0800411 // ignore any other type
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800412}
413
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800414
Alexander Afanasyev0222fba2014-02-09 23:16:02 -0800415
416} // namespace ndn