blob: 33e0113798fc8496cc4b7676025f168ad80cd8eb [file] [log] [blame]
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2011-2015 Regents of the University of California.
Alexander Afanasyevab1d5602011-08-17 19:17:18 -07004 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08005 * This file is part of ndnSIM. See AUTHORS for complete list of ndnSIM authors and
6 * contributors.
Alexander Afanasyevab1d5602011-08-17 19:17:18 -07007 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -08008 * ndnSIM is free software: you can redistribute it and/or modify it under the terms
9 * of the GNU General Public License as published by the Free Software Foundation,
10 * either version 3 of the License, or (at your option) any later version.
Alexander Afanasyevab1d5602011-08-17 19:17:18 -070011 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -080012 * ndnSIM is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
13 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
14 * PURPOSE. See the GNU General Public License for more details.
Alexander Afanasyevab1d5602011-08-17 19:17:18 -070015 *
Alexander Afanasyev60a7b622014-12-20 17:04:07 -080016 * You should have received a copy of the GNU General Public License along with
17 * ndnSIM, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
18 **/
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070019
Alexander Afanasyev0c395372014-12-20 15:54:02 -080020#include "ndn-l3-protocol.hpp"
Alexander Afanasyev45b92d42011-08-14 23:11:38 -070021
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070022#include "ns3/packet.h"
Alexander Afanasyev45b92d42011-08-14 23:11:38 -070023#include "ns3/node.h"
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070024#include "ns3/log.h"
25#include "ns3/callback.h"
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070026#include "ns3/uinteger.h"
27#include "ns3/trace-source-accessor.h"
28#include "ns3/object-vector.h"
Alexander Afanasyevcbe92ae2011-12-16 13:06:18 -080029#include "ns3/pointer.h"
Alexander Afanasyev4975f732011-12-20 17:52:19 -080030#include "ns3/simulator.h"
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070031
Alexander Afanasyeva91aab42016-09-08 15:47:38 -070032#include "ndn-net-device-link-service.hpp"
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080033
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080034#include "../helper/ndn-stack-helper.hpp"
Spyridon Mastorakisde1f7732014-12-05 22:43:34 -080035#include "cs/ndn-content-store.hpp"
Alexander Afanasyev52e9aa92011-11-15 20:23:20 -080036
Alexander Afanasyevdde1e812015-01-06 14:26:09 -080037#include <boost/property_tree/info_parser.hpp>
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070038
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080039#include "ns3/ndnSIM/NFD/daemon/fw/forwarder.hpp"
Alexander Afanasyeva91aab42016-09-08 15:47:38 -070040#include "ns3/ndnSIM/NFD/daemon/face/internal-face.hpp"
41#include "ns3/ndnSIM/NFD/daemon/face/internal-transport.hpp"
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080042#include "ns3/ndnSIM/NFD/daemon/mgmt/fib-manager.hpp"
43#include "ns3/ndnSIM/NFD/daemon/mgmt/face-manager.hpp"
44#include "ns3/ndnSIM/NFD/daemon/mgmt/strategy-choice-manager.hpp"
Alexander Afanasyeva91aab42016-09-08 15:47:38 -070045#include "ns3/ndnSIM/NFD/daemon/mgmt/forwarder-status-manager.hpp"
46// #include "ns3/ndnSIM/NFD/daemon/mgmt/general-config-section.hpp"
47#include "ns3/ndnSIM/NFD/daemon/mgmt/tables-config-section.hpp"
48#include "ns3/ndnSIM/NFD/daemon/mgmt/command-validator.hpp"
49
Spyridon Mastorakis8fde22b2015-08-19 23:12:44 -070050#include "ns3/ndnSIM/NFD/rib/rib-manager.hpp"
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080051
52#include "ns3/ndnSIM/NFD/daemon/face/null-face.hpp"
Alexander Afanasyeva91aab42016-09-08 15:47:38 -070053#include "ns3/ndnSIM/NFD/daemon/face/internal-face.hpp"
54
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080055#include "ns3/ndnSIM/NFD/core/config-file.hpp"
Alexander Afanasyeva91aab42016-09-08 15:47:38 -070056
57#include <ndn-cxx/mgmt/dispatcher.hpp>
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080058
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080059NS_LOG_COMPONENT_DEFINE("ndn.L3Protocol");
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070060
61namespace ns3 {
Alexander Afanasyev2b4c9472012-08-09 15:00:38 -070062namespace ndn {
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070063
Alexander Afanasyev2b4c9472012-08-09 15:00:38 -070064const uint16_t L3Protocol::ETHERNET_FRAME_TYPE = 0x7777;
Alexander Afanasyev016a5d82013-07-15 10:41:29 -070065const uint16_t L3Protocol::IP_STACK_PORT = 9695;
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070066
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080067NS_OBJECT_ENSURE_REGISTERED(L3Protocol);
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070068
Alexander Afanasyev06dba7c2013-02-21 11:36:26 -080069TypeId
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080070L3Protocol::GetTypeId(void)
Alexander Afanasyev08d984e2011-08-13 19:20:22 -070071{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -080072 static TypeId tid =
73 TypeId("ns3::ndn::L3Protocol")
74 .SetGroupName("ndn")
75 .SetParent<Object>()
76 .AddConstructor<L3Protocol>()
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080077
78 .AddTraceSource("OutInterests", "OutInterests",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070079 MakeTraceSourceAccessor(&L3Protocol::m_outInterests),
80 "ns3::ndn::L3Protocol::InterestTraceCallback")
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080081 .AddTraceSource("InInterests", "InInterests",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070082 MakeTraceSourceAccessor(&L3Protocol::m_inInterests),
83 "ns3::ndn::L3Protocol::InterestTraceCallback")
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -080084
85 ////////////////////////////////////////////////////////////////////
86
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070087 .AddTraceSource("OutData", "OutData", MakeTraceSourceAccessor(&L3Protocol::m_outData),
88 "ns3::ndn::L3Protocol::DataTraceCallback")
89 .AddTraceSource("InData", "InData", MakeTraceSourceAccessor(&L3Protocol::m_inData),
90 "ns3::ndn::L3Protocol::DataTraceCallback")
Alexander Afanasyevdc6fae82015-01-08 21:44:15 -080091
92 ////////////////////////////////////////////////////////////////////
93
94 .AddTraceSource("SatisfiedInterests", "SatisfiedInterests",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070095 MakeTraceSourceAccessor(&L3Protocol::m_satisfiedInterests),
96 "ns3::ndn::L3Protocol::SatisfiedInterestsCallback")
Alexander Afanasyevdc6fae82015-01-08 21:44:15 -080097 .AddTraceSource("TimedOutInterests", "TimedOutInterests",
Alexander Afanasyevd6453cd2015-08-20 21:45:36 -070098 MakeTraceSourceAccessor(&L3Protocol::m_timedOutInterests),
99 "ns3::ndn::L3Protocol::TimedOutInterestsCallback")
Alexander Afanasyevdc6fae82015-01-08 21:44:15 -0800100 ;
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700101 return tid;
102}
103
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800104class L3Protocol::Impl {
105private:
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800106 Impl()
107 {
108 // Do not modify initial config file. Use helpers to set specific NFD parameters
109 std::string initialConfig =
110 "general\n"
111 "{\n"
112 "}\n"
113 "\n"
114 "tables\n"
115 "{\n"
116 " cs_max_packets 100\n"
117 "\n"
118 " strategy_choice\n"
119 " {\n"
120 " / /localhost/nfd/strategy/best-route\n"
Alexander Afanasyevc3c7f042015-08-21 11:38:00 -0700121 " /localhost /localhost/nfd/strategy/multicast\n"
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800122 " /localhost/nfd /localhost/nfd/strategy/best-route\n"
Alexander Afanasyevc3c7f042015-08-21 11:38:00 -0700123 " /ndn/multicast /localhost/nfd/strategy/multicast\n"
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800124 " }\n"
125 "}\n"
126 "\n"
127 // "face_system\n"
128 // "{\n"
129 // "}\n"
130 "\n"
131 "authorizations\n"
132 "{\n"
133 " authorize\n"
134 " {\n"
135 " certfile any\n"
136 " privileges\n"
137 " {\n"
138 " faces\n"
139 " fib\n"
140 " strategy-choice\n"
141 " }\n"
142 " }\n"
143 "}\n"
144 "\n"
145 "rib\n"
146 "{\n"
147 " localhost_security\n"
148 " {\n"
149 " trust-anchor\n"
150 " {\n"
151 " type any\n"
152 " }\n"
153 " }\n"
154 "}\n"
155 "\n";
156
157 std::istringstream input(initialConfig);
158 boost::property_tree::read_info(input, m_config);
159 }
160
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800161 friend class L3Protocol;
162
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700163 std::shared_ptr<nfd::Forwarder> m_forwarder;
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800164
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700165 std::shared_ptr<nfd::Face> m_internalFace;
166 std::shared_ptr<::ndn::Face> m_internalClientFace;
167 std::unique_ptr<nfd::CommandValidator> m_validator;
168
169 std::shared_ptr<nfd::Face> m_internalRibFace;
170 std::shared_ptr<::ndn::Face> m_internalRibClientFace;
171
172 std::unique_ptr<::ndn::mgmt::Dispatcher> m_dispatcher;
173 std::shared_ptr<nfd::FibManager> m_fibManager;
174 std::shared_ptr<nfd::FaceManager> m_faceManager;
175 std::shared_ptr<nfd::StrategyChoiceManager> m_strategyChoiceManager;
176 std::shared_ptr<nfd::ForwarderStatusManager> m_forwarderStatusManager;
177 std::shared_ptr<nfd::rib::RibManager> m_ribManager;
Spyridon Mastorakisde1f7732014-12-05 22:43:34 -0800178
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800179 nfd::ConfigSection m_config;
180
Spyridon Mastorakisde1f7732014-12-05 22:43:34 -0800181 Ptr<ContentStore> m_csFromNdnSim;
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800182};
183
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800184L3Protocol::L3Protocol()
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800185 : m_impl(new Impl())
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700186{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800187 NS_LOG_FUNCTION(this);
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700188}
189
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800190L3Protocol::~L3Protocol()
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700191{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800192 NS_LOG_FUNCTION(this);
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700193}
194
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800195void
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800196L3Protocol::initialize()
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800197{
198 m_impl->m_forwarder = make_shared<nfd::Forwarder>();
199
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800200 initializeManagement();
spirosmastorakis0df15ba2015-11-14 08:46:24 -0800201
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700202 nfd::FaceTable& faceTable = m_impl->m_forwarder->getFaceTable();
203 faceTable.addReserved(nfd::face::makeNullFace(), nfd::face::FACEID_NULL);
204 faceTable.addReserved(nfd::face::makeNullFace(FaceUri("contentstore://")), nfd::face::FACEID_CONTENT_STORE);
205
spirosmastorakis0df15ba2015-11-14 08:46:24 -0800206 if (!this->getConfig().get<bool>("ndnSIM.disable_rib_manager", false)) {
207 Simulator::ScheduleWithContext(m_node->GetId(), Seconds(0), &L3Protocol::initializeRibManager, this);
208 }
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800209
Alexander Afanasyevdc6fae82015-01-08 21:44:15 -0800210 m_impl->m_forwarder->beforeSatisfyInterest.connect(std::ref(m_satisfiedInterests));
211 m_impl->m_forwarder->beforeExpirePendingInterest.connect(std::ref(m_timedOutInterests));
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800212}
213
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800214class IgnoreSections
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800215{
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800216public:
217 IgnoreSections(const std::vector<std::string>& ignored)
218 : m_ignored(ignored)
219 {
220 }
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800221
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800222 void
223 operator()(const std::string& filename, const std::string& sectionName,
224 const nfd::ConfigSection& section, bool isDryRun)
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800225
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800226 {
227 if (std::find(m_ignored.begin(), m_ignored.end(), sectionName) == m_ignored.end()) {
228 nfd::ConfigFile::throwErrorOnUnknownSection(filename, sectionName, section, isDryRun);
229 }
230 }
231private:
232 std::vector<std::string> m_ignored;
233};
234
235void
Alexander Afanasyevca3c67e2016-09-08 15:48:23 -0700236L3Protocol::injectInterest(const Interest& interest)
237{
238 m_impl->m_internalFace->sendInterest(interest);
239}
240
241void
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800242L3Protocol::initializeManagement()
243{
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800244 auto& forwarder = m_impl->m_forwarder;
245 using namespace nfd;
246
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700247 std::tie(m_impl->m_internalFace, m_impl->m_internalClientFace) = face::makeInternalFace(StackHelper::getKeyChain());
248 forwarder->getFaceTable().addReserved(m_impl->m_internalFace, face::FACEID_INTERNAL_FACE);
249 m_impl->m_dispatcher.reset(new ::ndn::mgmt::Dispatcher(*m_impl->m_internalClientFace, StackHelper::getKeyChain()));
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800250
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700251 m_impl->m_validator.reset(new CommandValidator());
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800252
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700253 m_impl->m_fibManager.reset(new FibManager(forwarder->getFib(),
254 bind(&Forwarder::getFace, forwarder.get(), _1),
255 *m_impl->m_dispatcher,
256 *m_impl->m_validator));
257
258 // Cannot be disabled for now
259 // if (!this->getConfig().get<bool>("ndnSIM.disable_face_manager", false)) {
260 m_impl->m_faceManager.reset(new FaceManager(forwarder->getFaceTable(),
261 *m_impl->m_dispatcher,
262 *m_impl->m_validator));
263 // }
264 // else {
265 // this->getConfig().get_child("authorizations").get_child("authorize").get_child("privileges").erase("faces");
266 // }
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800267
spirosmastorakis0df15ba2015-11-14 08:46:24 -0800268 if (!this->getConfig().get<bool>("ndnSIM.disable_strategy_choice_manager", false)) {
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700269 m_impl->m_strategyChoiceManager.reset(new StrategyChoiceManager(forwarder->getStrategyChoice(),
270 *m_impl->m_dispatcher,
271 *m_impl->m_validator));
spirosmastorakis0df15ba2015-11-14 08:46:24 -0800272 }
273 else {
274 this->getConfig().get_child("authorizations").get_child("authorize").get_child("privileges").erase("strategy-choice");
275 }
276
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700277 if (!this->getConfig().get<bool>("ndnSIM.disable_forwarder_status_manager", false)) {
278 m_impl->m_forwarderStatusManager.reset(new ForwarderStatusManager(*forwarder, *m_impl->m_dispatcher));
spirosmastorakis0df15ba2015-11-14 08:46:24 -0800279 }
280
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700281 ConfigFile config(&ConfigFile::ignoreUnknownSection);
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800282
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800283 TablesConfigSection tablesConfig(forwarder->getCs(),
284 forwarder->getPit(),
285 forwarder->getFib(),
286 forwarder->getStrategyChoice(),
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700287 forwarder->getMeasurements(),
288 forwarder->getNetworkRegionTable());
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800289 tablesConfig.setConfigFile(config);
290
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700291 m_impl->m_validator->setConfigFile(config);
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800292
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700293 // if (!this->getConfig().get<bool>("ndnSIM.disable_face_manager", false)) {
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800294 m_impl->m_faceManager->setConfigFile(config);
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700295 // }
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800296
297 // apply config
298 config.parse(m_impl->m_config, false, "ndnSIM.conf");
299
300 tablesConfig.ensureTablesAreConfigured();
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800301
302 // add FIB entry for NFD Management Protocol
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700303 Name topPrefix("/localhost/nfd");
304 auto entry = forwarder->getFib().insert(topPrefix).first;
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800305 entry->addNextHop(m_impl->m_internalFace, 0);
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700306 m_impl->m_dispatcher->addTopPrefix(topPrefix, false);
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800307}
308
Spyridon Mastorakis8fde22b2015-08-19 23:12:44 -0700309void
310L3Protocol::initializeRibManager()
311{
312 using namespace nfd;
313
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700314 std::tie(m_impl->m_internalRibFace, m_impl->m_internalRibClientFace) = face::makeInternalFace(StackHelper::getKeyChain());
315 m_impl->m_forwarder->getFaceTable().add(m_impl->m_internalRibFace);
316 m_impl->m_ribManager = make_shared<rib::RibManager>(*(m_impl->m_internalRibClientFace),
Spyridon Mastorakis8fde22b2015-08-19 23:12:44 -0700317 StackHelper::getKeyChain());
318
319 ConfigFile config([] (const std::string& filename, const std::string& sectionName,
320 const ConfigSection& section, bool isDryRun) {
321 // Ignore "log" and sections belonging to NFD,
322 // but raise an error if we're missing a handler for a "rib" section.
323 if (sectionName != "rib" || sectionName == "log") {
324 // do nothing
325 }
326 else {
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700327 // missing RIB section
Spyridon Mastorakis8fde22b2015-08-19 23:12:44 -0700328 ConfigFile::throwErrorOnUnknownSection(filename, sectionName, section, isDryRun);
329 }
330 });
331
332 m_impl->m_ribManager->setConfigFile(config);
333
334 // apply config
335 config.parse(m_impl->m_config, false, "ndnSIM.conf");
336
337 m_impl->m_ribManager->registerWithNfd();
338
339 m_impl->m_ribManager->enableLocalControlHeader();
340}
341
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800342shared_ptr<nfd::Forwarder>
343L3Protocol::getForwarder()
344{
345 return m_impl->m_forwarder;
346}
347
348shared_ptr<nfd::FibManager>
349L3Protocol::getFibManager()
350{
351 return m_impl->m_fibManager;
352}
353
354shared_ptr<nfd::StrategyChoiceManager>
355L3Protocol::getStrategyChoiceManager()
356{
357 return m_impl->m_strategyChoiceManager;
358}
359
Alexander Afanasyevdde1e812015-01-06 14:26:09 -0800360nfd::ConfigSection&
361L3Protocol::getConfig()
362{
363 return m_impl->m_config;
364}
365
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700366/*
367 * This method is called by AddAgregate and completes the aggregation
Alexander Afanasyev4aac5572012-08-09 10:49:55 -0700368 * by setting the node in the ndn stack
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700369 */
370void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800371L3Protocol::NotifyNewAggregate()
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700372{
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800373 if (m_node == nullptr) {
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800374 m_node = GetObject<Node>();
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800375 if (m_node != nullptr) {
Spyridon Mastorakis8fde22b2015-08-19 23:12:44 -0700376 initialize();
377
Spyridon Mastorakisde1f7732014-12-05 22:43:34 -0800378 NS_ASSERT(m_impl->m_forwarder != nullptr);
379 m_impl->m_csFromNdnSim = GetObject<ContentStore>();
380 if (m_impl->m_csFromNdnSim != nullptr) {
381 m_impl->m_forwarder->setCsFromNdnSim(m_impl->m_csFromNdnSim);
382 }
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700383 }
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800384 }
Alexander Afanasyevd9fecdd2012-06-08 16:22:24 -0700385
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800386 Object::NotifyNewAggregate();
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700387}
388
Alexander Afanasyev06dba7c2013-02-21 11:36:26 -0800389void
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800390L3Protocol::DoDispose(void)
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700391{
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800392 NS_LOG_FUNCTION(this);
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700393
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700394 // MUST HAPPEN BEFORE Simulator IS DESTROYED
395 m_impl.reset();
396
397 nfd::scheduler::getGlobalScheduler().cancelAllEvents();
398
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700399 m_node = 0;
Alexander Afanasyevd02a5d62011-11-21 11:01:51 -0800400
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800401 Object::DoDispose();
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700402}
403
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800404nfd::FaceId
405L3Protocol::addFace(shared_ptr<Face> face)
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700406{
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800407 NS_LOG_FUNCTION(this << face.get());
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700408
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800409 m_impl->m_forwarder->addFace(face);
410
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700411 std::weak_ptr<Face> weakFace = face;
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800412
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700413 // // Connect Signals to TraceSource
414 face->afterReceiveInterest.connect([this, weakFace](const Interest& interest) {
415 shared_ptr<Face> face = weakFace.lock();
416 if (face != nullptr) {
417 this->m_inInterests(interest, *face);
418 }
419 });
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800420
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700421 face->afterReceiveData.connect([this, weakFace](const Data& data) {
422 shared_ptr<Face> face = weakFace.lock();
423 if (face != nullptr) {
424 this->m_inData(data, *face);
425 }
426 });
Alexander Afanasyevac541b12016-09-12 19:45:53 -0700427 // TODO Add nack signals
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800428
Alexander Afanasyevac541b12016-09-12 19:45:53 -0700429 auto tracingLink = face->getLinkService();
430 NS_LOG_LOGIC("Adding trace sources for afterSendInterest and afterSendData");
431 tracingLink->afterSendInterest.connect([this, weakFace](const Interest& interest) {
432 shared_ptr<Face> face = weakFace.lock();
433 if (face != nullptr) {
434 this->m_outInterests(interest, *face);
435 }
436 });
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700437
Alexander Afanasyevac541b12016-09-12 19:45:53 -0700438 tracingLink->afterSendData.connect([this, weakFace](const Data& data) {
439 shared_ptr<Face> face = weakFace.lock();
440 if (face != nullptr) {
441 this->m_outData(data, *face);
442 }
443 });
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700444
Alexander Afanasyevac541b12016-09-12 19:45:53 -0700445 // TODO Add nack signals
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800446
447 return face->getId();
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700448}
449
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800450shared_ptr<Face>
451L3Protocol::getFaceById(nfd::FaceId id) const
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700452{
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800453 return m_impl->m_forwarder->getFaceTable().get(id);
Alexander Afanasyevc5a23e22011-09-07 00:37:36 -0700454}
455
Spyridon Mastorakise4f0d3c2014-10-29 13:20:03 -0700456shared_ptr<Face>
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800457L3Protocol::getFaceByNetDevice(Ptr<NetDevice> netDevice) const
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700458{
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800459 for (const auto& i : m_impl->m_forwarder->getFaceTable()) {
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700460 auto linkService = dynamic_cast<NetDeviceLinkService*>(i->getLinkService());
461 if (linkService == nullptr)
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800462 continue;
Alexander Afanasyevaebf5cf2012-08-28 17:32:17 -0700463
Alexander Afanasyeva91aab42016-09-08 15:47:38 -0700464 if (linkService->GetNetDevice() == netDevice)
Spyridon Mastorakis9760bd02014-11-12 13:32:55 -0800465 return i;
466 }
Spyridon Mastorakise4f0d3c2014-10-29 13:20:03 -0700467 return nullptr;
Alexander Afanasyev08d984e2011-08-13 19:20:22 -0700468}
469
Alexander Afanasyev6b2a3c02015-01-03 02:04:23 -0800470Ptr<L3Protocol>
471L3Protocol::getL3Protocol(Ptr<Object> node)
472{
473 Ptr<L3Protocol> retval = node->GetObject<L3Protocol>();
474 NS_ASSERT_MSG(retval != nullptr, "L3Protocol is not aggregated on this object");
475 return retval;
476}
477
Alexander Afanasyevbe55cf62014-12-20 17:51:09 -0800478} // namespace ndn
479} // namespace ns3