blob: 03e2f42ef089cc8bd242a2adc900f290381314b2 [file] [log] [blame]
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
Steve DiBenedettoef04f272014-06-04 14:28:31 -06003 * Copyright (c) 2014, Regents of the University of California,
4 * Arizona Board of Regents,
5 * Colorado State University,
6 * University Pierre & Marie Curie, Sorbonne University,
7 * Washington University in St. Louis,
8 * Beijing Institute of Technology,
9 * The University of Memphis
Alexander Afanasyev9bcbc7c2014-04-06 19:37:37 -070010 *
11 * This file is part of NFD (Named Data Networking Forwarding Daemon).
12 * See AUTHORS.md for complete list of NFD authors and contributors.
13 *
14 * NFD is free software: you can redistribute it and/or modify it under the terms
15 * of the GNU General Public License as published by the Free Software Foundation,
16 * either version 3 of the License, or (at your option) any later version.
17 *
18 * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
19 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
20 * PURPOSE. See the GNU General Public License for more details.
21 *
22 * You should have received a copy of the GNU General Public License along with
23 * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
Steve DiBenedettoef04f272014-06-04 14:28:31 -060024 */
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070025
26#include "face-manager.hpp"
27
Steve DiBenedettobf6a93d2014-03-21 14:03:02 -060028#include "core/logger.hpp"
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -060029#include "core/network-interface.hpp"
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070030#include "fw/face-table.hpp"
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070031#include "face/tcp-factory.hpp"
32#include "face/udp-factory.hpp"
Alexander Afanasyev613e2a92014-04-15 13:36:58 -070033#include "core/config-file.hpp"
Steve DiBenedettofbb40a82014-03-11 19:40:15 -060034
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -060035#ifdef HAVE_UNIX_SOCKETS
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070036#include "face/unix-stream-factory.hpp"
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -060037#endif // HAVE_UNIX_SOCKETS
38
Alexander Afanasyev885a85b2014-04-12 21:01:13 -070039#ifdef HAVE_LIBPCAP
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070040#include "face/ethernet-factory.hpp"
Alexander Afanasyev885a85b2014-04-12 21:01:13 -070041#endif // HAVE_LIBPCAP
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070042
Wentao Shang53df1632014-04-21 12:01:32 -070043#ifdef HAVE_WEBSOCKET
44#include "face/websocket-factory.hpp"
45#endif // HAVE_WEBSOCKET
46
Alexander Afanasyev4a771362014-04-24 21:29:33 -070047#include <ndn-cxx/management/nfd-face-event-notification.hpp>
Chengyu Fan320d2332014-10-29 16:40:33 -060048#include <ndn-cxx/management/nfd-face-query-filter.hpp>
Davide Pesavento52a18f92014-04-10 00:55:01 +020049
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070050namespace nfd {
51
52NFD_LOG_INIT("FaceManager");
53
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -060054const Name FaceManager::COMMAND_PREFIX("/localhost/nfd/faces");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070055
56const size_t FaceManager::COMMAND_UNSIGNED_NCOMPS =
57 FaceManager::COMMAND_PREFIX.size() +
58 1 + // verb
Steve DiBenedetto7564d972014-03-24 14:28:46 -060059 1; // verb parameters
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070060
61const size_t FaceManager::COMMAND_SIGNED_NCOMPS =
62 FaceManager::COMMAND_UNSIGNED_NCOMPS +
Steve DiBenedetto2c2b8892014-02-27 11:46:48 -070063 4; // (timestamp, nonce, signed info tlv, signature tlv)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070064
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -060065const FaceManager::SignedVerbAndProcessor FaceManager::SIGNED_COMMAND_VERBS[] =
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070066 {
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -060067 SignedVerbAndProcessor(
Steve DiBenedetto7564d972014-03-24 14:28:46 -060068 Name::Component("create"),
69 &FaceManager::createFace
70 ),
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070071
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -060072 SignedVerbAndProcessor(
Steve DiBenedetto7564d972014-03-24 14:28:46 -060073 Name::Component("destroy"),
74 &FaceManager::destroyFace
75 ),
76
77 SignedVerbAndProcessor(
78 Name::Component("enable-local-control"),
79 &FaceManager::enableLocalControl
80 ),
81
82 SignedVerbAndProcessor(
83 Name::Component("disable-local-control"),
84 &FaceManager::disableLocalControl
85 ),
Steve DiBenedettoabe9e972014-02-20 15:37:04 -070086 };
87
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -060088const FaceManager::UnsignedVerbAndProcessor FaceManager::UNSIGNED_COMMAND_VERBS[] =
89 {
90 UnsignedVerbAndProcessor(
91 Name::Component("list"),
92 &FaceManager::listFaces
93 ),
Steve DiBenedettofbb40a82014-03-11 19:40:15 -060094
95 UnsignedVerbAndProcessor(
96 Name::Component("events"),
97 &FaceManager::ignoreUnsignedVerb
98 ),
Steve DiBenedettoef04f272014-06-04 14:28:31 -060099
100 UnsignedVerbAndProcessor(
101 Name::Component("channels"),
102 &FaceManager::listChannels
103 ),
Chengyu Fan320d2332014-10-29 16:40:33 -0600104
105 UnsignedVerbAndProcessor(
106 Name::Component("query"),
107 &FaceManager::listQueriedFaces
108 ),
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600109 };
110
Steve DiBenedettoef04f272014-06-04 14:28:31 -0600111const Name FaceManager::FACES_LIST_DATASET_PREFIX("/localhost/nfd/faces/list");
112const size_t FaceManager::FACES_LIST_DATASET_NCOMPS = FACES_LIST_DATASET_PREFIX.size();
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600113
Steve DiBenedettoef04f272014-06-04 14:28:31 -0600114const Name FaceManager::FACE_EVENTS_PREFIX("/localhost/nfd/faces/events");
115
116const Name FaceManager::CHANNELS_LIST_DATASET_PREFIX("/localhost/nfd/faces/channels");
117const size_t FaceManager::CHANNELS_LIST_DATASET_NCOMPS = CHANNELS_LIST_DATASET_PREFIX.size();
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700118
Chengyu Fan320d2332014-10-29 16:40:33 -0600119const Name FaceManager::FACES_QUERY_DATASET_PREFIX("/localhost/nfd/faces/query");
120const size_t FaceManager::FACES_QUERY_DATASET_NCOMPS = FACES_QUERY_DATASET_PREFIX.size() + 1;
121
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700122FaceManager::FaceManager(FaceTable& faceTable,
Vince Lehman5144f822014-07-23 15:12:56 -0700123 shared_ptr<InternalFace> face,
124 ndn::KeyChain& keyChain)
125 : ManagerBase(face, FACE_MANAGER_PRIVILEGE, keyChain)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700126 , m_faceTable(faceTable)
Vince Lehman5144f822014-07-23 15:12:56 -0700127 , m_faceStatusPublisher(m_faceTable, *m_face, FACES_LIST_DATASET_PREFIX, keyChain)
128 , m_channelStatusPublisher(m_factories, *m_face, CHANNELS_LIST_DATASET_PREFIX, keyChain)
Junxiao Shi15b12e72014-08-09 19:56:24 -0700129 , m_notificationStream(*m_face, FACE_EVENTS_PREFIX, keyChain)
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600130 , m_signedVerbDispatch(SIGNED_COMMAND_VERBS,
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600131 SIGNED_COMMAND_VERBS +
132 (sizeof(SIGNED_COMMAND_VERBS) / sizeof(SignedVerbAndProcessor)))
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600133 , m_unsignedVerbDispatch(UNSIGNED_COMMAND_VERBS,
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600134 UNSIGNED_COMMAND_VERBS +
135 (sizeof(UNSIGNED_COMMAND_VERBS) / sizeof(UnsignedVerbAndProcessor)))
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600136
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700137{
138 face->setInterestFilter("/localhost/nfd/faces",
139 bind(&FaceManager::onFaceRequest, this, _2));
Steve DiBenedettofbb40a82014-03-11 19:40:15 -0600140
141 m_faceTable.onAdd += bind(&FaceManager::onAddFace, this, _1);
142 m_faceTable.onRemove += bind(&FaceManager::onRemoveFace, this, _1);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700143}
144
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600145FaceManager::~FaceManager()
146{
147
148}
149
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700150void
151FaceManager::setConfigFile(ConfigFile& configFile)
152{
153 configFile.addSectionHandler("face_system",
Steve DiBenedetto1a3c6732014-03-13 06:44:05 -0600154 bind(&FaceManager::onConfig, this, _1, _2, _3));
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700155}
156
157
158void
Steve DiBenedetto1a3c6732014-03-13 06:44:05 -0600159FaceManager::onConfig(const ConfigSection& configSection,
160 bool isDryRun,
161 const std::string& filename)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700162{
163 bool hasSeenUnix = false;
164 bool hasSeenTcp = false;
165 bool hasSeenUdp = false;
166 bool hasSeenEther = false;
Wentao Shang53df1632014-04-21 12:01:32 -0700167 bool hasSeenWebSocket = false;
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700168
Davide Pesaventob499a602014-11-18 22:36:56 +0100169 const std::vector<NetworkInterfaceInfo> nicList(listNetworkInterfaces());
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600170
Davide Pesaventob499a602014-11-18 22:36:56 +0100171 for (const auto& item : configSection)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700172 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100173 if (item.first == "unix")
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700174 {
175 if (hasSeenUnix)
176 throw Error("Duplicate \"unix\" section");
177 hasSeenUnix = true;
178
Davide Pesaventob499a602014-11-18 22:36:56 +0100179 processSectionUnix(item.second, isDryRun);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700180 }
Davide Pesaventob499a602014-11-18 22:36:56 +0100181 else if (item.first == "tcp")
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700182 {
183 if (hasSeenTcp)
184 throw Error("Duplicate \"tcp\" section");
185 hasSeenTcp = true;
186
Davide Pesaventob499a602014-11-18 22:36:56 +0100187 processSectionTcp(item.second, isDryRun);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700188 }
Davide Pesaventob499a602014-11-18 22:36:56 +0100189 else if (item.first == "udp")
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700190 {
191 if (hasSeenUdp)
192 throw Error("Duplicate \"udp\" section");
193 hasSeenUdp = true;
194
Davide Pesaventob499a602014-11-18 22:36:56 +0100195 processSectionUdp(item.second, isDryRun, nicList);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700196 }
Davide Pesaventob499a602014-11-18 22:36:56 +0100197 else if (item.first == "ether")
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700198 {
199 if (hasSeenEther)
200 throw Error("Duplicate \"ether\" section");
201 hasSeenEther = true;
202
Davide Pesaventob499a602014-11-18 22:36:56 +0100203 processSectionEther(item.second, isDryRun, nicList);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700204 }
Davide Pesaventob499a602014-11-18 22:36:56 +0100205 else if (item.first == "websocket")
Wentao Shang53df1632014-04-21 12:01:32 -0700206 {
207 if (hasSeenWebSocket)
208 throw Error("Duplicate \"websocket\" section");
209 hasSeenWebSocket = true;
210
Davide Pesaventob499a602014-11-18 22:36:56 +0100211 processSectionWebSocket(item.second, isDryRun);
Wentao Shang53df1632014-04-21 12:01:32 -0700212 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700213 else
214 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100215 throw Error("Unrecognized option \"" + item.first + "\"");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700216 }
217 }
218}
219
220void
221FaceManager::processSectionUnix(const ConfigSection& configSection, bool isDryRun)
222{
Steve DiBenedettodbcb1a12014-11-17 11:04:21 -0700223 // ; the unix section contains settings of Unix stream faces and channels
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700224 // unix
225 // {
Steve DiBenedettodbcb1a12014-11-17 11:04:21 -0700226 // path /var/run/nfd.sock ; Unix stream listener path
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700227 // }
228
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600229#if defined(HAVE_UNIX_SOCKETS)
230
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700231 std::string path = "/var/run/nfd.sock";
232
233 for (ConfigSection::const_iterator i = configSection.begin();
234 i != configSection.end();
235 ++i)
236 {
237 if (i->first == "path")
238 {
239 path = i->second.get_value<std::string>();
240 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700241 else
242 {
243 throw ConfigFile::Error("Unrecognized option \"" + i->first + "\" in \"unix\" section");
244 }
245 }
246
247 if (!isDryRun)
248 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300249 if (m_factories.count("unix") > 0)
250 {
251 return;
252 // shared_ptr<UnixStreamFactory> factory
253 // = static_pointer_cast<UnixStreamFactory>(m_factories["unix"]);
254 // shared_ptr<UnixStreamChannel> unixChannel = factory->findChannel(path);
255
256 // if (static_cast<bool>(unixChannel))
257 // {
258 // return;
259 // }
260 }
261
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700262 shared_ptr<UnixStreamFactory> factory = make_shared<UnixStreamFactory>();
263 shared_ptr<UnixStreamChannel> unixChannel = factory->createChannel(path);
264
Steve DiBenedettodbcb1a12014-11-17 11:04:21 -0700265 // Should acceptFailed callback be used somehow?
266 unixChannel->listen(bind(&FaceTable::add, &m_faceTable, _1),
267 UnixStreamChannel::ConnectFailedCallback());
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700268
269 m_factories.insert(std::make_pair("unix", factory));
270 }
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600271#else
Steve DiBenedettodbcb1a12014-11-17 11:04:21 -0700272 throw ConfigFile::Error("NFD was compiled without Unix sockets support, "
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300273 "cannot process \"unix\" section");
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600274#endif // HAVE_UNIX_SOCKETS
275
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700276}
277
278void
279FaceManager::processSectionTcp(const ConfigSection& configSection, bool isDryRun)
280{
281 // ; the tcp section contains settings of TCP faces and channels
282 // tcp
283 // {
284 // listen yes ; set to 'no' to disable TCP listener, default 'yes'
285 // port 6363 ; TCP listener port number
286 // }
287
288 std::string port = "6363";
289 bool needToListen = true;
Steve DiBenedetto95152872014-04-11 12:40:59 -0600290 bool enableV4 = true;
291 bool enableV6 = true;
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700292
293 for (ConfigSection::const_iterator i = configSection.begin();
294 i != configSection.end();
295 ++i)
296 {
297 if (i->first == "port")
298 {
299 port = i->second.get_value<std::string>();
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600300 try
301 {
302 uint16_t portNo = boost::lexical_cast<uint16_t>(port);
303 NFD_LOG_TRACE("TCP port set to " << portNo);
304 }
305 catch (const std::bad_cast& error)
306 {
307 throw ConfigFile::Error("Invalid value for option " +
Steve DiBenedetto95152872014-04-11 12:40:59 -0600308 i->first + "\" in \"tcp\" section");
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600309 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700310 }
311 else if (i->first == "listen")
312 {
313 needToListen = parseYesNo(i, i->first, "tcp");
314 }
Steve DiBenedetto95152872014-04-11 12:40:59 -0600315 else if (i->first == "enable_v4")
316 {
317 enableV4 = parseYesNo(i, i->first, "tcp");
318 }
319 else if (i->first == "enable_v6")
320 {
321 enableV6 = parseYesNo(i, i->first, "tcp");
322 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700323 else
324 {
325 throw ConfigFile::Error("Unrecognized option \"" + i->first + "\" in \"tcp\" section");
326 }
327 }
328
Steve DiBenedetto95152872014-04-11 12:40:59 -0600329 if (!enableV4 && !enableV6)
330 {
331 throw ConfigFile::Error("IPv4 and IPv6 channels have been disabled."
332 " Remove \"tcp\" section to disable TCP channels or"
333 " re-enable at least one channel type.");
334 }
335
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700336 if (!isDryRun)
337 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300338 if (m_factories.count("tcp") > 0)
339 {
340 return;
341 }
342
Davide Pesaventob499a602014-11-18 22:36:56 +0100343 shared_ptr<TcpFactory> factory = make_shared<TcpFactory>(port);
Steve DiBenedetto95152872014-04-11 12:40:59 -0600344 m_factories.insert(std::make_pair("tcp", factory));
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700345
Steve DiBenedetto95152872014-04-11 12:40:59 -0600346 if (enableV4)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700347 {
Steve DiBenedetto95152872014-04-11 12:40:59 -0600348 shared_ptr<TcpChannel> ipv4Channel = factory->createChannel("0.0.0.0", port);
349 if (needToListen)
350 {
351 // Should acceptFailed callback be used somehow?
352 ipv4Channel->listen(bind(&FaceTable::add, &m_faceTable, _1),
353 TcpChannel::ConnectFailedCallback());
354 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700355
Steve DiBenedetto95152872014-04-11 12:40:59 -0600356 m_factories.insert(std::make_pair("tcp4", factory));
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700357 }
358
Steve DiBenedetto95152872014-04-11 12:40:59 -0600359 if (enableV6)
360 {
361 shared_ptr<TcpChannel> ipv6Channel = factory->createChannel("::", port);
362 if (needToListen)
363 {
364 // Should acceptFailed callback be used somehow?
365 ipv6Channel->listen(bind(&FaceTable::add, &m_faceTable, _1),
366 TcpChannel::ConnectFailedCallback());
367 }
368
369 m_factories.insert(std::make_pair("tcp6", factory));
370 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700371 }
372}
373
374void
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600375FaceManager::processSectionUdp(const ConfigSection& configSection,
376 bool isDryRun,
Davide Pesaventob499a602014-11-18 22:36:56 +0100377 const std::vector<NetworkInterfaceInfo>& nicList)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700378{
379 // ; the udp section contains settings of UDP faces and channels
380 // udp
381 // {
382 // port 6363 ; UDP unicast port number
383 // idle_timeout 30 ; idle time (seconds) before closing a UDP unicast face
384 // keep_alive_interval 25; interval (seconds) between keep-alive refreshes
385
386 // ; NFD creates one UDP multicast face per NIC
387 // mcast yes ; set to 'no' to disable UDP multicast, default 'yes'
388 // mcast_port 56363 ; UDP multicast port number
389 // mcast_group 224.0.23.170 ; UDP multicast group (IPv4 only)
390 // }
391
392 std::string port = "6363";
Steve DiBenedetto95152872014-04-11 12:40:59 -0600393 bool enableV4 = true;
394 bool enableV6 = true;
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700395 size_t timeout = 30;
396 size_t keepAliveInterval = 25;
397 bool useMcast = true;
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600398 std::string mcastGroup = "224.0.23.170";
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700399 std::string mcastPort = "56363";
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600400
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700401
402 for (ConfigSection::const_iterator i = configSection.begin();
403 i != configSection.end();
404 ++i)
405 {
406 if (i->first == "port")
407 {
408 port = i->second.get_value<std::string>();
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600409 try
410 {
411 uint16_t portNo = boost::lexical_cast<uint16_t>(port);
412 NFD_LOG_TRACE("UDP port set to " << portNo);
413 }
414 catch (const std::bad_cast& error)
415 {
416 throw ConfigFile::Error("Invalid value for option " +
417 i->first + "\" in \"udp\" section");
418 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700419 }
Steve DiBenedetto95152872014-04-11 12:40:59 -0600420 else if (i->first == "enable_v4")
421 {
422 enableV4 = parseYesNo(i, i->first, "udp");
423 }
424 else if (i->first == "enable_v6")
425 {
426 enableV6 = parseYesNo(i, i->first, "udp");
427 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700428 else if (i->first == "idle_timeout")
429 {
430 try
431 {
432 timeout = i->second.get_value<size_t>();
433 }
434 catch (const std::exception& e)
435 {
436 throw ConfigFile::Error("Invalid value for option \"" +
437 i->first + "\" in \"udp\" section");
438 }
439 }
440 else if (i->first == "keep_alive_interval")
441 {
442 try
443 {
444 keepAliveInterval = i->second.get_value<size_t>();
Alexander Afanasyevefea8fe2014-03-23 00:00:35 -0700445
446 /// \todo Make use of keepAliveInterval
447 (void)(keepAliveInterval);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700448 }
449 catch (const std::exception& e)
450 {
451 throw ConfigFile::Error("Invalid value for option \"" +
452 i->first + "\" in \"udp\" section");
453 }
454 }
455 else if (i->first == "mcast")
456 {
457 useMcast = parseYesNo(i, i->first, "udp");
458 }
459 else if (i->first == "mcast_port")
460 {
461 mcastPort = i->second.get_value<std::string>();
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600462 try
463 {
464 uint16_t portNo = boost::lexical_cast<uint16_t>(mcastPort);
465 NFD_LOG_TRACE("UDP multicast port set to " << portNo);
466 }
467 catch (const std::bad_cast& error)
468 {
469 throw ConfigFile::Error("Invalid value for option " +
470 i->first + "\" in \"udp\" section");
471 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700472 }
473 else if (i->first == "mcast_group")
474 {
475 using namespace boost::asio::ip;
476 mcastGroup = i->second.get_value<std::string>();
477 try
478 {
479 address mcastGroupTest = address::from_string(mcastGroup);
480 if (!mcastGroupTest.is_v4())
481 {
482 throw ConfigFile::Error("Invalid value for option \"" +
483 i->first + "\" in \"udp\" section");
484 }
485 }
486 catch(const std::runtime_error& e)
487 {
488 throw ConfigFile::Error("Invalid value for option \"" +
489 i->first + "\" in \"udp\" section");
490 }
491 }
492 else
493 {
494 throw ConfigFile::Error("Unrecognized option \"" + i->first + "\" in \"udp\" section");
495 }
496 }
497
Steve DiBenedetto95152872014-04-11 12:40:59 -0600498 if (!enableV4 && !enableV6)
499 {
500 throw ConfigFile::Error("IPv4 and IPv6 channels have been disabled."
501 " Remove \"udp\" section to disable UDP channels or"
502 " re-enable at least one channel type.");
503 }
504 else if (useMcast && !enableV4)
505 {
506 throw ConfigFile::Error("IPv4 multicast requested, but IPv4 channels"
507 " have been disabled (conflicting configuration options set)");
508 }
509
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700510 /// \todo what is keep alive interval used for?
511
512 if (!isDryRun)
513 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300514 shared_ptr<UdpFactory> factory;
515 bool isReload = false;
516 if (m_factories.count("udp") > 0) {
517 isReload = true;
518 factory = static_pointer_cast<UdpFactory>(m_factories["udp"]);
519 }
520 else {
Davide Pesaventob499a602014-11-18 22:36:56 +0100521 factory = make_shared<UdpFactory>(port);
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300522 m_factories.insert(std::make_pair("udp", factory));
523 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700524
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300525 if (!isReload && enableV4)
Steve DiBenedetto95152872014-04-11 12:40:59 -0600526 {
527 shared_ptr<UdpChannel> v4Channel =
528 factory->createChannel("0.0.0.0", port, time::seconds(timeout));
529
530 v4Channel->listen(bind(&FaceTable::add, &m_faceTable, _1),
531 UdpChannel::ConnectFailedCallback());
532
533 m_factories.insert(std::make_pair("udp4", factory));
534 }
535
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300536 if (!isReload && enableV6)
Steve DiBenedetto95152872014-04-11 12:40:59 -0600537 {
538 shared_ptr<UdpChannel> v6Channel =
539 factory->createChannel("::", port, time::seconds(timeout));
540
541 v6Channel->listen(bind(&FaceTable::add, &m_faceTable, _1),
542 UdpChannel::ConnectFailedCallback());
543 m_factories.insert(std::make_pair("udp6", factory));
544 }
545
546 if (useMcast && enableV4)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700547 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100548 std::vector<NetworkInterfaceInfo> ipv4MulticastInterfaces;
549 for (const auto& nic : nicList)
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600550 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100551 if (nic.isUp() && nic.isMulticastCapable() && !nic.ipv4Addresses.empty())
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600552 {
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200553 ipv4MulticastInterfaces.push_back(nic);
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600554 }
555 }
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200556
557 bool isNicNameNecessary = false;
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200558#if defined(__linux__)
559 if (ipv4MulticastInterfaces.size() > 1)
560 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100561 // On Linux if we have more than one MulticastUdpFace
562 // we need to specify the name of the interface
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200563 isNicNameNecessary = true;
564 }
565#endif
566
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300567 std::list<shared_ptr<MulticastUdpFace> > multicastFacesToRemove;
568 for (UdpFactory::MulticastFaceMap::const_iterator i =
569 factory->getMulticastFaces().begin();
570 i != factory->getMulticastFaces().end();
571 ++i)
572 {
573 multicastFacesToRemove.push_back(i->second);
574 }
575
Davide Pesaventob499a602014-11-18 22:36:56 +0100576 for (const auto& nic : ipv4MulticastInterfaces)
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200577 {
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200578 shared_ptr<MulticastUdpFace> newFace;
Davide Pesaventob499a602014-11-18 22:36:56 +0100579 newFace = factory->createMulticastFace(nic.ipv4Addresses[0].to_string(),
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200580 mcastGroup,
581 mcastPort,
Davide Pesaventob499a602014-11-18 22:36:56 +0100582 isNicNameNecessary ? nic.name : "");
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200583 addCreatedFaceToForwarder(newFace);
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300584 multicastFacesToRemove.remove(newFace);
585 }
586
587 for (std::list<shared_ptr<MulticastUdpFace> >::iterator i =
588 multicastFacesToRemove.begin();
589 i != multicastFacesToRemove.end();
590 ++i)
591 {
592 (*i)->close();
593 }
594 }
595 else
596 {
597 std::list<shared_ptr<MulticastUdpFace> > multicastFacesToRemove;
598 for (UdpFactory::MulticastFaceMap::const_iterator i =
599 factory->getMulticastFaces().begin();
600 i != factory->getMulticastFaces().end();
601 ++i)
602 {
603 multicastFacesToRemove.push_back(i->second);
604 }
605
606 for (std::list<shared_ptr<MulticastUdpFace> >::iterator i =
607 multicastFacesToRemove.begin();
608 i != multicastFacesToRemove.end();
609 ++i)
610 {
611 (*i)->close();
Giulio Grassi6d7176d2014-04-16 16:08:48 +0200612 }
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600613 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700614 }
615}
616
617void
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600618FaceManager::processSectionEther(const ConfigSection& configSection,
619 bool isDryRun,
Davide Pesaventob499a602014-11-18 22:36:56 +0100620 const std::vector<NetworkInterfaceInfo>& nicList)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700621{
622 // ; the ether section contains settings of Ethernet faces and channels
623 // ether
624 // {
625 // ; NFD creates one Ethernet multicast face per NIC
626 // mcast yes ; set to 'no' to disable Ethernet multicast, default 'yes'
627 // mcast_group 01:00:5E:00:17:AA ; Ethernet multicast group
628 // }
629
Alexander Afanasyev885a85b2014-04-12 21:01:13 -0700630#if defined(HAVE_LIBPCAP)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700631 bool useMcast = true;
Davide Pesaventob499a602014-11-18 22:36:56 +0100632 ethernet::Address mcastGroup(ethernet::getDefaultMulticastAddress());
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700633
634 for (ConfigSection::const_iterator i = configSection.begin();
635 i != configSection.end();
636 ++i)
637 {
638 if (i->first == "mcast")
639 {
640 useMcast = parseYesNo(i, i->first, "ether");
641 }
642
643 else if (i->first == "mcast_group")
644 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100645 mcastGroup = ethernet::Address::fromString(i->second.get_value<std::string>());
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600646 if (mcastGroup.isNull())
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700647 {
648 throw ConfigFile::Error("Invalid value for option \"" +
649 i->first + "\" in \"ether\" section");
650 }
651 }
652 else
653 {
654 throw ConfigFile::Error("Unrecognized option \"" + i->first + "\" in \"ether\" section");
655 }
656 }
657
658 if (!isDryRun)
659 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300660 shared_ptr<EthernetFactory> factory;
661 if (m_factories.count("ether") > 0) {
662 factory = static_pointer_cast<EthernetFactory>(m_factories["ether"]);
663 }
664 else {
Davide Pesaventob499a602014-11-18 22:36:56 +0100665 factory = make_shared<EthernetFactory>();
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300666 m_factories.insert(std::make_pair("ether", factory));
667 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700668
669 if (useMcast)
670 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300671 std::list<shared_ptr<EthernetFace> > multicastFacesToRemove;
672 for (EthernetFactory::MulticastFaceMap::const_iterator i =
673 factory->getMulticastFaces().begin();
674 i != factory->getMulticastFaces().end();
675 ++i)
676 {
677 multicastFacesToRemove.push_back(i->second);
678 }
679
Davide Pesaventob499a602014-11-18 22:36:56 +0100680 for (const auto& nic : nicList)
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600681 {
Davide Pesaventob499a602014-11-18 22:36:56 +0100682 if (nic.isUp() && nic.isMulticastCapable())
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600683 {
684 try
685 {
686 shared_ptr<EthernetFace> newFace =
Davide Pesaventob60cc122014-03-19 19:26:02 +0100687 factory->createMulticastFace(nic, mcastGroup);
Alexander Afanasyevbbe3f0c2014-03-23 11:44:01 -0700688
689 addCreatedFaceToForwarder(newFace);
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300690 multicastFacesToRemove.remove(newFace);
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600691 }
692 catch (const EthernetFactory::Error& factoryError)
693 {
694 NFD_LOG_ERROR(factoryError.what() << ", continuing");
695 }
696 catch (const EthernetFace::Error& faceError)
697 {
698 NFD_LOG_ERROR(faceError.what() << ", continuing");
699 }
700 }
701 }
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300702
703 for (std::list<shared_ptr<EthernetFace> >::iterator i =
704 multicastFacesToRemove.begin();
705 i != multicastFacesToRemove.end();
706 ++i)
707 {
708 (*i)->close();
709 }
710 }
711 else
712 {
713 std::list<shared_ptr<EthernetFace> > multicastFacesToRemove;
714 for (EthernetFactory::MulticastFaceMap::const_iterator i =
715 factory->getMulticastFaces().begin();
716 i != factory->getMulticastFaces().end();
717 ++i)
718 {
719 multicastFacesToRemove.push_back(i->second);
720 }
721
722 for (std::list<shared_ptr<EthernetFace> >::iterator i =
723 multicastFacesToRemove.begin();
724 i != multicastFacesToRemove.end();
725 ++i)
726 {
727 (*i)->close();
728 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700729 }
730 }
Steve DiBenedetto4aca99c2014-03-11 11:27:54 -0600731#else
732 throw ConfigFile::Error("NFD was compiled without libpcap, cannot process \"ether\" section");
Alexander Afanasyev885a85b2014-04-12 21:01:13 -0700733#endif // HAVE_LIBPCAP
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700734}
735
Wentao Shang53df1632014-04-21 12:01:32 -0700736void
737FaceManager::processSectionWebSocket(const ConfigSection& configSection, bool isDryRun)
738{
739 // ; the websocket section contains settings of WebSocket faces and channels
740 // websocket
741 // {
742 // listen yes ; set to 'no' to disable WebSocket listener, default 'yes'
743 // port 9696 ; WebSocket listener port number
744 // enable_v4 yes ; set to 'no' to disable listening on IPv4 socket, default 'yes'
745 // enable_v6 yes ; set to 'no' to disable listening on IPv6 socket, default 'yes'
746 // }
747
748#if defined(HAVE_WEBSOCKET)
749
750 std::string port = "9696";
751 bool needToListen = true;
752 bool enableV4 = true;
753 bool enableV6 = true;
754
755 for (ConfigSection::const_iterator i = configSection.begin();
756 i != configSection.end();
757 ++i)
758 {
759 if (i->first == "port")
760 {
761 port = i->second.get_value<std::string>();
762 try
763 {
764 uint16_t portNo = boost::lexical_cast<uint16_t>(port);
765 NFD_LOG_TRACE("WebSocket port set to " << portNo);
766 }
767 catch (const std::bad_cast& error)
768 {
769 throw ConfigFile::Error("Invalid value for option " +
770 i->first + "\" in \"websocket\" section");
771 }
772 }
773 else if (i->first == "listen")
774 {
775 needToListen = parseYesNo(i, i->first, "websocket");
776 }
777 else if (i->first == "enable_v4")
778 {
779 enableV4 = parseYesNo(i, i->first, "websocket");
780 }
781 else if (i->first == "enable_v6")
782 {
783 enableV6 = parseYesNo(i, i->first, "websocket");
784 }
785 else
786 {
787 throw ConfigFile::Error("Unrecognized option \"" +
788 i->first + "\" in \"websocket\" section");
789 }
790 }
791
792 if (!enableV4 && !enableV6)
793 {
794 throw ConfigFile::Error("IPv4 and IPv6 channels have been disabled."
795 " Remove \"websocket\" section to disable WebSocket channels or"
796 " re-enable at least one channel type.");
797 }
798
799 if (!enableV4 && enableV6)
800 {
801 throw ConfigFile::Error("NFD does not allow pure IPv6 WebSocket channel.");
802 }
803
804 if (!isDryRun)
805 {
Alexander Afanasyev5959b012014-06-02 19:18:12 +0300806 if (m_factories.count("websocket") > 0)
807 {
808 return;
809 }
810
Davide Pesaventob499a602014-11-18 22:36:56 +0100811 shared_ptr<WebSocketFactory> factory = make_shared<WebSocketFactory>(port);
Wentao Shang53df1632014-04-21 12:01:32 -0700812 m_factories.insert(std::make_pair("websocket", factory));
Wentao Shang53df1632014-04-21 12:01:32 -0700813
814 if (enableV6 && enableV4)
815 {
Steve DiBenedettoef04f272014-06-04 14:28:31 -0600816 shared_ptr<WebSocketChannel> ip46Channel = factory->createChannel("::", port);
Wentao Shang53df1632014-04-21 12:01:32 -0700817 if (needToListen)
818 {
819 ip46Channel->listen(bind(&FaceTable::add, &m_faceTable, _1));
820 }
821
822 m_factories.insert(std::make_pair("websocket46", factory));
823 }
824 else if (enableV4)
825 {
Steve DiBenedettoef04f272014-06-04 14:28:31 -0600826 shared_ptr<WebSocketChannel> ipv4Channel = factory->createChannel("0.0.0.0", port);
Wentao Shang53df1632014-04-21 12:01:32 -0700827 if (needToListen)
828 {
829 ipv4Channel->listen(bind(&FaceTable::add, &m_faceTable, _1));
830 }
831
832 m_factories.insert(std::make_pair("websocket4", factory));
833 }
834 }
835#else
836 throw ConfigFile::Error("NFD was compiled without WebSocket, "
837 "cannot process \"websocket\" section");
838#endif // HAVE_WEBSOCKET
839}
840
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700841
842void
843FaceManager::onFaceRequest(const Interest& request)
844{
845 const Name& command = request.getName();
846 const size_t commandNComps = command.size();
847
Steve DiBenedettocd4ee5f2014-12-08 16:09:11 -0700848 if (commandNComps <= COMMAND_PREFIX.size())
849 {
850 // command is too short to have a verb
851 NFD_LOG_DEBUG("command result: malformed");
852 sendResponse(command, 400, "Malformed command");
853 return;
854 }
855
856 const Name::Component& verb = command.at(COMMAND_PREFIX.size());
857
858 const auto unsignedVerbProcessor = m_unsignedVerbDispatch.find(verb);
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600859 if (unsignedVerbProcessor != m_unsignedVerbDispatch.end())
860 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700861 NFD_LOG_DEBUG("command result: processing verb: " << verb);
Alexander Afanasyevf6980282014-05-13 18:28:40 -0700862 (unsignedVerbProcessor->second)(this, request);
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600863 }
864 else if (COMMAND_UNSIGNED_NCOMPS <= commandNComps &&
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600865 commandNComps < COMMAND_SIGNED_NCOMPS)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700866 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700867 NFD_LOG_DEBUG("command result: unsigned verb: " << command);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700868 sendResponse(command, 401, "Signature required");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700869 }
870 else if (commandNComps < COMMAND_SIGNED_NCOMPS ||
871 !COMMAND_PREFIX.isPrefixOf(command))
872 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700873 NFD_LOG_DEBUG("command result: malformed");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700874 sendResponse(command, 400, "Malformed command");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700875 }
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600876 else
877 {
878 validate(request,
879 bind(&FaceManager::onValidatedFaceRequest, this, _1),
880 bind(&ManagerBase::onCommandValidationFailed, this, _1, _2));
881 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700882}
883
884void
885FaceManager::onValidatedFaceRequest(const shared_ptr<const Interest>& request)
886{
887 const Name& command = request->getName();
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600888 const Name::Component& verb = command[COMMAND_PREFIX.size()];
889 const Name::Component& parameterComponent = command[COMMAND_PREFIX.size() + 1];
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700890
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -0600891 SignedVerbDispatchTable::const_iterator signedVerbProcessor = m_signedVerbDispatch.find(verb);
892 if (signedVerbProcessor != m_signedVerbDispatch.end())
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700893 {
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600894 ControlParameters parameters;
895 if (!extractParameters(parameterComponent, parameters))
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700896 {
897 sendResponse(command, 400, "Malformed command");
898 return;
899 }
900
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700901 NFD_LOG_DEBUG("command result: processing verb: " << verb);
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600902 (signedVerbProcessor->second)(this, *request, parameters);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700903 }
904 else
905 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700906 NFD_LOG_DEBUG("command result: unsupported verb: " << verb);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700907 sendResponse(command, 501, "Unsupported command");
908 }
909
910}
911
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700912void
Alexander Afanasyevbbe3f0c2014-03-23 11:44:01 -0700913FaceManager::addCreatedFaceToForwarder(const shared_ptr<Face>& newFace)
914{
915 m_faceTable.add(newFace);
916
Junxiao Shi6e694322014-04-03 10:27:13 -0700917 //NFD_LOG_DEBUG("Created face " << newFace->getRemoteUri() << " ID " << newFace->getId());
Alexander Afanasyevbbe3f0c2014-03-23 11:44:01 -0700918}
919
920void
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700921FaceManager::onCreated(const Name& requestName,
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600922 ControlParameters& parameters,
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700923 const shared_ptr<Face>& newFace)
924{
Alexander Afanasyevbbe3f0c2014-03-23 11:44:01 -0700925 addCreatedFaceToForwarder(newFace);
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600926 parameters.setFaceId(newFace->getId());
Steve DiBenedetto25999282014-05-22 15:25:12 -0600927 parameters.setUri(newFace->getRemoteUri().toString());
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700928
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600929 sendResponse(requestName, 200, "Success", parameters.wireEncode());
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700930}
931
932void
933FaceManager::onConnectFailed(const Name& requestName, const std::string& reason)
934{
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -0700935 NFD_LOG_DEBUG("Failed to create face: " << reason);
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600936 sendResponse(requestName, 408, reason);
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700937}
938
939void
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600940FaceManager::createFace(const Interest& request,
941 ControlParameters& parameters)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700942{
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600943 const Name& requestName = request.getName();
Steve DiBenedetto51d242a2014-03-31 13:46:43 -0600944 ndn::nfd::FaceCreateCommand command;
945
946 if (!validateParameters(command, parameters))
947 {
948 sendResponse(requestName, 400, "Malformed command");
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600949 NFD_LOG_TRACE("invalid control parameters URI");
Steve DiBenedetto51d242a2014-03-31 13:46:43 -0600950 return;
951 }
952
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700953 FaceUri uri;
Steve DiBenedetto51d242a2014-03-31 13:46:43 -0600954 if (!uri.parse(parameters.getUri()))
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700955 {
956 sendResponse(requestName, 400, "Malformed command");
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600957 NFD_LOG_TRACE("failed to parse URI");
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700958 return;
959 }
960
961 FactoryMap::iterator factory = m_factories.find(uri.getScheme());
962 if (factory == m_factories.end())
963 {
964 sendResponse(requestName, 501, "Unsupported protocol");
965 return;
966 }
967
Steve DiBenedettoca53ac62014-03-27 19:58:40 -0600968 try
969 {
970 factory->second->createFace(uri,
971 bind(&FaceManager::onCreated,
972 this, requestName, parameters, _1),
973 bind(&FaceManager::onConnectFailed,
974 this, requestName, _1));
975 }
976 catch (const std::runtime_error& error)
977 {
978 std::string errorMessage = "NFD error: ";
979 errorMessage += error.what();
980
981 NFD_LOG_ERROR(errorMessage);
982 sendResponse(requestName, 500, errorMessage);
983 }
984 catch (const std::logic_error& error)
985 {
986 std::string errorMessage = "NFD error: ";
987 errorMessage += error.what();
988
989 NFD_LOG_ERROR(errorMessage);
990 sendResponse(requestName, 500, errorMessage);
991 }
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700992}
993
994
995void
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600996FaceManager::destroyFace(const Interest& request,
997 ControlParameters& parameters)
Steve DiBenedettoabe9e972014-02-20 15:37:04 -0700998{
Steve DiBenedetto7564d972014-03-24 14:28:46 -0600999 const Name& requestName = request.getName();
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001000 ndn::nfd::FaceDestroyCommand command;
1001
1002 if (!validateParameters(command, parameters))
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001003 {
1004 sendResponse(requestName, 400, "Malformed command");
1005 return;
1006 }
1007
1008 shared_ptr<Face> target = m_faceTable.get(parameters.getFaceId());
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001009 if (static_cast<bool>(target))
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001010 {
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001011 target->close();
1012 }
Steve DiBenedettoba749052014-03-22 19:54:53 -06001013
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001014 sendResponse(requestName, 200, "Success", parameters.wireEncode());
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001015
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001016}
1017
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -06001018void
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001019FaceManager::onAddFace(shared_ptr<Face> face)
1020{
Junxiao Shi6e694322014-04-03 10:27:13 -07001021 ndn::nfd::FaceEventNotification notification;
Chengyu Fanf9c2bb12014-10-06 11:52:44 -06001022 notification.setKind(ndn::nfd::FACE_EVENT_CREATED);
1023 face->copyStatusTo(notification);
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001024
Junxiao Shi6e694322014-04-03 10:27:13 -07001025 m_notificationStream.postNotification(notification);
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001026}
1027
1028void
1029FaceManager::onRemoveFace(shared_ptr<Face> face)
1030{
Junxiao Shi6e694322014-04-03 10:27:13 -07001031 ndn::nfd::FaceEventNotification notification;
Chengyu Fanf9c2bb12014-10-06 11:52:44 -06001032 notification.setKind(ndn::nfd::FACE_EVENT_DESTROYED);
1033 face->copyStatusTo(notification);
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001034
Junxiao Shi6e694322014-04-03 10:27:13 -07001035 m_notificationStream.postNotification(notification);
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001036}
1037
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001038bool
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001039FaceManager::extractLocalControlParameters(const Interest& request,
1040 ControlParameters& parameters,
1041 ControlCommand& command,
1042 shared_ptr<LocalFace>& outFace,
1043 LocalControlFeature& outFeature)
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001044{
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001045 if (!validateParameters(command, parameters))
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001046 {
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001047 sendResponse(request.getName(), 400, "Malformed command");
1048 return false;
1049 }
1050
1051 shared_ptr<Face> face = m_faceTable.get(request.getIncomingFaceId());
1052
1053 if (!static_cast<bool>(face))
1054 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -07001055 NFD_LOG_DEBUG("command result: faceid " << request.getIncomingFaceId() << " not found");
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001056 sendResponse(request.getName(), 410, "Face not found");
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001057 return false;
1058 }
1059 else if (!face->isLocal())
1060 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -07001061 NFD_LOG_DEBUG("command result: cannot enable local control on non-local faceid " <<
1062 face->getId());
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001063 sendResponse(request.getName(), 412, "Face is non-local");
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001064 return false;
1065 }
1066
1067 outFace = dynamic_pointer_cast<LocalFace>(face);
1068 outFeature = static_cast<LocalControlFeature>(parameters.getLocalControlFeature());
1069
1070 return true;
1071}
1072
1073void
1074FaceManager::enableLocalControl(const Interest& request,
1075 ControlParameters& parameters)
1076{
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001077 ndn::nfd::FaceEnableLocalControlCommand command;
1078
1079
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001080 shared_ptr<LocalFace> face;
1081 LocalControlFeature feature;
1082
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001083 if (extractLocalControlParameters(request, parameters, command, face, feature))
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001084 {
1085 face->setLocalControlHeaderFeature(feature, true);
1086 sendResponse(request.getName(), 200, "Success", parameters.wireEncode());
1087 }
1088}
1089
1090void
1091FaceManager::disableLocalControl(const Interest& request,
1092 ControlParameters& parameters)
1093{
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001094 ndn::nfd::FaceDisableLocalControlCommand command;
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001095 shared_ptr<LocalFace> face;
1096 LocalControlFeature feature;
1097
Steve DiBenedetto51d242a2014-03-31 13:46:43 -06001098 if (extractLocalControlParameters(request, parameters, command, face, feature))
Steve DiBenedetto7564d972014-03-24 14:28:46 -06001099 {
1100 face->setLocalControlHeaderFeature(feature, false);
1101 sendResponse(request.getName(), 200, "Success", parameters.wireEncode());
1102 }
1103}
1104
Steve DiBenedettofbb40a82014-03-11 19:40:15 -06001105void
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -06001106FaceManager::listFaces(const Interest& request)
1107{
1108 const Name& command = request.getName();
1109 const size_t commandNComps = command.size();
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001110
Steve DiBenedettoef04f272014-06-04 14:28:31 -06001111 if (commandNComps < FACES_LIST_DATASET_NCOMPS ||
1112 !FACES_LIST_DATASET_PREFIX.isPrefixOf(command))
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -06001113 {
Alexander Afanasyevbf9edee2014-03-31 23:05:27 -07001114 NFD_LOG_DEBUG("command result: malformed");
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -06001115 sendResponse(command, 400, "Malformed command");
1116 return;
1117 }
1118
Steve DiBenedettoef04f272014-06-04 14:28:31 -06001119 m_faceStatusPublisher.publish();
1120}
1121
1122void
1123FaceManager::listChannels(const Interest& request)
1124{
1125 NFD_LOG_DEBUG("in listChannels");
1126 const Name& command = request.getName();
1127 const size_t commandNComps = command.size();
1128
1129 if (commandNComps < CHANNELS_LIST_DATASET_NCOMPS ||
1130 !CHANNELS_LIST_DATASET_PREFIX.isPrefixOf(command))
1131 {
1132 NFD_LOG_DEBUG("command result: malformed");
1133 sendResponse(command, 400, "Malformed command");
1134 return;
1135 }
1136
1137 NFD_LOG_DEBUG("publishing");
1138 m_channelStatusPublisher.publish();
Steve DiBenedetto9f6c3642014-03-10 17:02:27 -06001139}
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001140
Chengyu Fan320d2332014-10-29 16:40:33 -06001141void
1142FaceManager::listQueriedFaces(const Interest& request)
1143{
1144 NFD_LOG_DEBUG("in listQueriedFaces");
1145 const Name& query = request.getName();
1146 const size_t queryNComps = query.size();
1147
1148 if (queryNComps < FACES_QUERY_DATASET_NCOMPS ||
1149 !FACES_QUERY_DATASET_PREFIX.isPrefixOf(query))
1150 {
1151 NFD_LOG_DEBUG("query result: malformed");
Chengyu Fanab205c22014-11-18 10:58:41 -07001152 sendNack(query);
Chengyu Fan320d2332014-10-29 16:40:33 -06001153 return;
1154 }
1155
1156 ndn::nfd::FaceQueryFilter faceFilter;
1157 try
1158 {
1159 faceFilter.wireDecode(query[-1].blockFromValue());
1160 }
1161 catch (tlv::Error&)
1162 {
1163 NFD_LOG_DEBUG("query result: malformed filter");
Chengyu Fanab205c22014-11-18 10:58:41 -07001164 sendNack(query);
Chengyu Fan320d2332014-10-29 16:40:33 -06001165 return;
1166 }
1167
1168 FaceQueryStatusPublisher
1169 faceQueryStatusPublisher(m_faceTable, *m_face, query, faceFilter, m_keyChain);
1170
1171 faceQueryStatusPublisher.publish();
1172}
1173
Alexander Afanasyev5959b012014-06-02 19:18:12 +03001174shared_ptr<ProtocolFactory>
1175FaceManager::findFactory(const std::string& protocol)
1176{
1177 FactoryMap::iterator factory = m_factories.find(protocol);
1178 if (factory != m_factories.end())
1179 return factory->second;
1180 else
1181 return shared_ptr<ProtocolFactory>();
1182}
1183
Steve DiBenedettoabe9e972014-02-20 15:37:04 -07001184} // namespace nfd