| /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
| /** |
| * Copyright (c) 2014-2015, Regents of the University of California, |
| * Arizona Board of Regents, |
| * Colorado State University, |
| * University Pierre & Marie Curie, Sorbonne University, |
| * Washington University in St. Louis, |
| * Beijing Institute of Technology, |
| * The University of Memphis. |
| * |
| * This file is part of NFD (Named Data Networking Forwarding Daemon). |
| * See AUTHORS.md for complete list of NFD authors and contributors. |
| * |
| * NFD is free software: you can redistribute it and/or modify it under the terms |
| * of the GNU General Public License as published by the Free Software Foundation, |
| * either version 3 of the License, or (at your option) any later version. |
| * |
| * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; |
| * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR |
| * PURPOSE. See the GNU General Public License for more details. |
| * |
| * You should have received a copy of the GNU General Public License along with |
| * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>. |
| */ |
| |
| #include "face-manager.hpp" |
| |
| #include "core/network-interface.hpp" |
| #include "face/generic-link-service.hpp" |
| #include "face/tcp-factory.hpp" |
| #include "face/udp-factory.hpp" |
| #include "fw/face-table.hpp" |
| |
| #include <ndn-cxx/management/nfd-channel-status.hpp> |
| #include <ndn-cxx/management/nfd-face-status.hpp> |
| #include <ndn-cxx/management/nfd-face-event-notification.hpp> |
| |
| #ifdef HAVE_UNIX_SOCKETS |
| #include "face/unix-stream-factory.hpp" |
| #endif // HAVE_UNIX_SOCKETS |
| |
| #ifdef HAVE_LIBPCAP |
| #include "face/ethernet-factory.hpp" |
| #include "face/ethernet-transport.hpp" |
| #endif // HAVE_LIBPCAP |
| |
| #ifdef HAVE_WEBSOCKET |
| #include "face/websocket-factory.hpp" |
| #endif // HAVE_WEBSOCKET |
| |
| namespace nfd { |
| |
| NFD_LOG_INIT("FaceManager"); |
| |
| FaceManager::FaceManager(FaceTable& faceTable, |
| Dispatcher& dispatcher, |
| CommandValidator& validator) |
| : ManagerBase(dispatcher, validator, "faces") |
| , m_faceTable(faceTable) |
| { |
| registerCommandHandler<ndn::nfd::FaceCreateCommand>("create", |
| bind(&FaceManager::createFace, this, _2, _3, _4, _5)); |
| |
| registerCommandHandler<ndn::nfd::FaceDestroyCommand>("destroy", |
| bind(&FaceManager::destroyFace, this, _2, _3, _4, _5)); |
| |
| registerCommandHandler<ndn::nfd::FaceEnableLocalControlCommand>("enable-local-control", |
| bind(&FaceManager::enableLocalControl, this, _2, _3, _4, _5)); |
| |
| registerCommandHandler<ndn::nfd::FaceDisableLocalControlCommand>("disable-local-control", |
| bind(&FaceManager::disableLocalControl, this, _2, _3, _4, _5)); |
| |
| registerStatusDatasetHandler("list", bind(&FaceManager::listFaces, this, _1, _2, _3)); |
| registerStatusDatasetHandler("channels", bind(&FaceManager::listChannels, this, _1, _2, _3)); |
| registerStatusDatasetHandler("query", bind(&FaceManager::queryFaces, this, _1, _2, _3)); |
| |
| auto postNotification = registerNotificationStream("events"); |
| m_faceAddConn = |
| m_faceTable.afterAdd.connect(bind(&FaceManager::afterFaceAdded, this, _1, postNotification)); |
| m_faceRemoveConn = |
| m_faceTable.beforeRemove.connect(bind(&FaceManager::afterFaceRemoved, this, _1, postNotification)); |
| } |
| |
| void |
| FaceManager::setConfigFile(ConfigFile& configFile) |
| { |
| configFile.addSectionHandler("face_system", bind(&FaceManager::processConfig, this, _1, _2, _3)); |
| } |
| |
| void |
| FaceManager::createFace(const Name& topPrefix, const Interest& interest, |
| const ControlParameters& parameters, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| FaceUri uri; |
| if (!uri.parse(parameters.getUri())) { |
| NFD_LOG_TRACE("failed to parse URI"); |
| return done(ControlResponse(400, "Malformed command")); |
| } |
| |
| if (!uri.isCanonical()) { |
| NFD_LOG_TRACE("received non-canonical URI"); |
| return done(ControlResponse(400, "Non-canonical URI")); |
| } |
| |
| auto factory = m_factories.find(uri.getScheme()); |
| if (factory == m_factories.end()) { |
| return done(ControlResponse(501, "Unsupported protocol")); |
| } |
| |
| try { |
| factory->second->createFace(uri, |
| parameters.getFacePersistency(), |
| bind(&FaceManager::afterCreateFaceSuccess, |
| this, parameters, _1, done), |
| bind(&FaceManager::afterCreateFaceFailure, |
| this, _1, done)); |
| } |
| catch (const std::runtime_error& error) { |
| std::string errorMessage = "Face creation failed: "; |
| errorMessage += error.what(); |
| |
| NFD_LOG_ERROR(errorMessage); |
| return done(ControlResponse(500, errorMessage)); |
| } |
| catch (const std::logic_error& error) { |
| std::string errorMessage = "Face creation failed: "; |
| errorMessage += error.what(); |
| |
| NFD_LOG_ERROR(errorMessage); |
| return done(ControlResponse(500, errorMessage)); |
| } |
| } |
| |
| void |
| FaceManager::afterCreateFaceSuccess(ControlParameters& parameters, |
| const shared_ptr<Face>& newFace, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| m_faceTable.add(newFace); |
| parameters.setFaceId(newFace->getId()); |
| parameters.setUri(newFace->getRemoteUri().toString()); |
| parameters.setFacePersistency(newFace->getPersistency()); |
| |
| done(ControlResponse(200, "OK").setBody(parameters.wireEncode())); |
| } |
| |
| void |
| FaceManager::destroyFace(const Name& topPrefix, const Interest& interest, |
| const ControlParameters& parameters, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| shared_ptr<Face> target = m_faceTable.get(parameters.getFaceId()); |
| if (target) { |
| target->close(); |
| } |
| |
| done(ControlResponse(200, "OK").setBody(parameters.wireEncode())); |
| } |
| |
| void |
| FaceManager::afterCreateFaceFailure(const std::string& reason, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| NFD_LOG_DEBUG("Failed to create face: " << reason); |
| |
| done(ControlResponse(408, "Failed to create face: " + reason)); |
| } |
| |
| void |
| FaceManager::enableLocalControl(const Name& topPrefix, const Interest& interest, |
| const ControlParameters& parameters, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| Face* face = findFaceForLocalControl(interest, parameters, done); |
| if (!face) { |
| return; |
| } |
| |
| // TODO#3226 redesign enable-local-control |
| // For now, enable-local-control will enable all local fields in GenericLinkService. |
| auto service = dynamic_cast<face::GenericLinkService*>(face->getLinkService()); |
| if (service == nullptr) { |
| return done(ControlResponse(503, "LinkService type not supported")); |
| } |
| |
| face::GenericLinkService::Options options = service->getOptions(); |
| options.allowLocalFields = true; |
| service->setOptions(options); |
| |
| return done(ControlResponse(200, "OK: enable all local fields on GenericLinkService") |
| .setBody(parameters.wireEncode())); |
| } |
| |
| void |
| FaceManager::disableLocalControl(const Name& topPrefix, const Interest& interest, |
| const ControlParameters& parameters, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| Face* face = findFaceForLocalControl(interest, parameters, done); |
| if (!face) { |
| return; |
| } |
| |
| // TODO#3226 redesign disable-local-control |
| // For now, disable-local-control will disable all local fields in GenericLinkService. |
| auto service = dynamic_cast<face::GenericLinkService*>(face->getLinkService()); |
| if (service == nullptr) { |
| return done(ControlResponse(503, "LinkService type not supported")); |
| } |
| |
| face::GenericLinkService::Options options = service->getOptions(); |
| options.allowLocalFields = false; |
| service->setOptions(options); |
| |
| return done(ControlResponse(200, "OK: disable all local fields on GenericLinkService") |
| .setBody(parameters.wireEncode())); |
| } |
| |
| Face* |
| FaceManager::findFaceForLocalControl(const Interest& request, |
| const ControlParameters& parameters, |
| const ndn::mgmt::CommandContinuation& done) |
| { |
| shared_ptr<lp::IncomingFaceIdTag> incomingFaceIdTag = request.getTag<lp::IncomingFaceIdTag>(); |
| // NDNLPv2 says "application MUST be prepared to receive a packet without IncomingFaceId field", |
| // but it's fine to assert IncomingFaceId is available, because InternalFace lives inside NFD |
| // and is initialized synchronously with IncomingFaceId field enabled. |
| BOOST_ASSERT(incomingFaceIdTag != nullptr); |
| |
| auto face = m_faceTable.get(*incomingFaceIdTag); |
| if (face == nullptr) { |
| NFD_LOG_DEBUG("FaceId " << *incomingFaceIdTag << " not found"); |
| done(ControlResponse(410, "Face not found")); |
| return nullptr; |
| } |
| |
| if (face->getScope() == ndn::nfd::FACE_SCOPE_NON_LOCAL) { |
| NFD_LOG_DEBUG("Cannot enable local control on non-local FaceId " << face->getId()); |
| done(ControlResponse(412, "Face is non-local")); |
| return nullptr; |
| } |
| |
| return face.get(); |
| } |
| |
| void |
| FaceManager::listFaces(const Name& topPrefix, const Interest& interest, |
| ndn::mgmt::StatusDatasetContext& context) |
| { |
| auto now = time::steady_clock::now(); |
| for (const auto& face : m_faceTable) { |
| ndn::nfd::FaceStatus status = collectFaceStatus(*face, now); |
| context.append(status.wireEncode()); |
| } |
| context.end(); |
| } |
| |
| void |
| FaceManager::listChannels(const Name& topPrefix, const Interest& interest, |
| ndn::mgmt::StatusDatasetContext& context) |
| { |
| std::set<const ProtocolFactory*> seenFactories; |
| |
| for (const auto& kv : m_factories) { |
| const ProtocolFactory* factory = kv.second.get(); |
| bool inserted; |
| std::tie(std::ignore, inserted) = seenFactories.insert(factory); |
| |
| if (inserted) { |
| for (const auto& channel : factory->getChannels()) { |
| ndn::nfd::ChannelStatus entry; |
| entry.setLocalUri(channel->getUri().toString()); |
| context.append(entry.wireEncode()); |
| } |
| } |
| } |
| |
| context.end(); |
| } |
| |
| void |
| FaceManager::queryFaces(const Name& topPrefix, const Interest& interest, |
| ndn::mgmt::StatusDatasetContext& context) |
| { |
| ndn::nfd::FaceQueryFilter faceFilter; |
| const Name& query = interest.getName(); |
| try { |
| faceFilter.wireDecode(query[-1].blockFromValue()); |
| } |
| catch (const tlv::Error& e) { |
| NFD_LOG_DEBUG("Malformed query filter: " << e.what()); |
| return context.reject(ControlResponse(400, "Malformed filter")); |
| } |
| |
| auto now = time::steady_clock::now(); |
| for (const auto& face : m_faceTable) { |
| if (!doesMatchFilter(faceFilter, face)) { |
| continue; |
| } |
| ndn::nfd::FaceStatus status = collectFaceStatus(*face, now); |
| context.append(status.wireEncode()); |
| } |
| |
| context.end(); |
| } |
| |
| bool |
| FaceManager::doesMatchFilter(const ndn::nfd::FaceQueryFilter& filter, shared_ptr<Face> face) |
| { |
| if (filter.hasFaceId() && |
| filter.getFaceId() != static_cast<uint64_t>(face->getId())) { |
| return false; |
| } |
| |
| if (filter.hasUriScheme() && |
| filter.getUriScheme() != face->getRemoteUri().getScheme() && |
| filter.getUriScheme() != face->getLocalUri().getScheme()) { |
| return false; |
| } |
| |
| if (filter.hasRemoteUri() && |
| filter.getRemoteUri() != face->getRemoteUri().toString()) { |
| return false; |
| } |
| |
| if (filter.hasLocalUri() && |
| filter.getLocalUri() != face->getLocalUri().toString()) { |
| return false; |
| } |
| |
| if (filter.hasFaceScope() && |
| filter.getFaceScope() != face->getScope()) { |
| return false; |
| } |
| |
| if (filter.hasFacePersistency() && |
| filter.getFacePersistency() != face->getPersistency()) { |
| return false; |
| } |
| |
| if (filter.hasLinkType() && |
| filter.getLinkType() != face->getLinkType()) { |
| return false; |
| } |
| |
| return true; |
| } |
| |
| ndn::nfd::FaceStatus |
| FaceManager::collectFaceStatus(const Face& face, const time::steady_clock::TimePoint& now) |
| { |
| ndn::nfd::FaceStatus status; |
| |
| collectFaceProperties(face, status); |
| |
| time::steady_clock::TimePoint expirationTime = face.getExpirationTime(); |
| if (expirationTime != time::steady_clock::TimePoint::max()) { |
| status.setExpirationPeriod(std::max(time::milliseconds(0), |
| time::duration_cast<time::milliseconds>(expirationTime - now))); |
| } |
| |
| const face::FaceCounters& counters = face.getCounters(); |
| status.setNInInterests(counters.nInInterests) |
| .setNOutInterests(counters.nOutInterests) |
| .setNInDatas(counters.nInData) |
| .setNOutDatas(counters.nOutData) |
| .setNInNacks(counters.nInNacks) |
| .setNOutNacks(counters.nOutNacks) |
| .setNInBytes(counters.nInBytes) |
| .setNOutBytes(counters.nOutBytes); |
| |
| return status; |
| } |
| |
| template<typename FaceTraits> |
| void |
| FaceManager::collectFaceProperties(const Face& face, FaceTraits& traits) |
| { |
| traits.setFaceId(face.getId()) |
| .setRemoteUri(face.getRemoteUri().toString()) |
| .setLocalUri(face.getLocalUri().toString()) |
| .setFaceScope(face.getScope()) |
| .setFacePersistency(face.getPersistency()) |
| .setLinkType(face.getLinkType()); |
| } |
| |
| void |
| FaceManager::afterFaceAdded(shared_ptr<Face> face, |
| const ndn::mgmt::PostNotification& post) |
| { |
| ndn::nfd::FaceEventNotification notification; |
| notification.setKind(ndn::nfd::FACE_EVENT_CREATED); |
| collectFaceProperties(*face, notification); |
| |
| post(notification.wireEncode()); |
| } |
| |
| void |
| FaceManager::afterFaceRemoved(shared_ptr<Face> face, |
| const ndn::mgmt::PostNotification& post) |
| { |
| ndn::nfd::FaceEventNotification notification; |
| notification.setKind(ndn::nfd::FACE_EVENT_DESTROYED); |
| collectFaceProperties(*face, notification); |
| |
| post(notification.wireEncode()); |
| } |
| |
| void |
| FaceManager::processConfig(const ConfigSection& configSection, |
| bool isDryRun, |
| const std::string& filename) |
| { |
| bool hasSeenUnix = false; |
| bool hasSeenTcp = false; |
| bool hasSeenUdp = false; |
| bool hasSeenEther = false; |
| bool hasSeenWebSocket = false; |
| auto nicList = listNetworkInterfaces(); |
| |
| for (const auto& item : configSection) { |
| if (item.first == "unix") { |
| if (hasSeenUnix) { |
| BOOST_THROW_EXCEPTION(Error("Duplicate \"unix\" section")); |
| } |
| hasSeenUnix = true; |
| |
| processSectionUnix(item.second, isDryRun); |
| } |
| else if (item.first == "tcp") { |
| if (hasSeenTcp) { |
| BOOST_THROW_EXCEPTION(Error("Duplicate \"tcp\" section")); |
| } |
| hasSeenTcp = true; |
| |
| processSectionTcp(item.second, isDryRun); |
| } |
| else if (item.first == "udp") { |
| if (hasSeenUdp) { |
| BOOST_THROW_EXCEPTION(Error("Duplicate \"udp\" section")); |
| } |
| hasSeenUdp = true; |
| |
| processSectionUdp(item.second, isDryRun, nicList); |
| } |
| else if (item.first == "ether") { |
| if (hasSeenEther) { |
| BOOST_THROW_EXCEPTION(Error("Duplicate \"ether\" section")); |
| } |
| hasSeenEther = true; |
| |
| processSectionEther(item.second, isDryRun, nicList); |
| } |
| else if (item.first == "websocket") { |
| if (hasSeenWebSocket) { |
| BOOST_THROW_EXCEPTION(Error("Duplicate \"websocket\" section")); |
| } |
| hasSeenWebSocket = true; |
| |
| processSectionWebSocket(item.second, isDryRun); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(Error("Unrecognized option \"" + item.first + "\"")); |
| } |
| } |
| } |
| |
| void |
| FaceManager::processSectionUnix(const ConfigSection& configSection, bool isDryRun) |
| { |
| // ; the unix section contains settings of Unix stream faces and channels |
| // unix |
| // { |
| // path /var/run/nfd.sock ; Unix stream listener path |
| // } |
| |
| #if defined(HAVE_UNIX_SOCKETS) |
| std::string path = "/var/run/nfd.sock"; |
| |
| for (const auto& i : configSection) { |
| if (i.first == "path") { |
| path = i.second.get_value<std::string>(); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Unrecognized option \"" + |
| i.first + "\" in \"unix\" section")); |
| } |
| } |
| |
| if (!isDryRun) { |
| if (m_factories.count("unix") > 0) { |
| return; |
| } |
| |
| auto factory = make_shared<UnixStreamFactory>(); |
| m_factories.insert(std::make_pair("unix", factory)); |
| |
| auto channel = factory->createChannel(path); |
| channel->listen(bind(&FaceTable::add, &m_faceTable, _1), nullptr); |
| } |
| #else |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("NFD was compiled without Unix sockets support, " |
| "cannot process \"unix\" section")); |
| #endif // HAVE_UNIX_SOCKETS |
| } |
| |
| void |
| FaceManager::processSectionTcp(const ConfigSection& configSection, bool isDryRun) |
| { |
| // ; the tcp section contains settings of TCP faces and channels |
| // tcp |
| // { |
| // listen yes ; set to 'no' to disable TCP listener, default 'yes' |
| // port 6363 ; TCP listener port number |
| // } |
| |
| uint16_t port = 6363; |
| bool needToListen = true; |
| bool enableV4 = true; |
| bool enableV6 = true; |
| |
| for (const auto& i : configSection) { |
| if (i.first == "port") { |
| port = ConfigFile::parseNumber<uint16_t>(i, "tcp"); |
| NFD_LOG_TRACE("TCP port set to " << port); |
| } |
| else if (i.first == "listen") { |
| needToListen = ConfigFile::parseYesNo(i, "tcp"); |
| } |
| else if (i.first == "enable_v4") { |
| enableV4 = ConfigFile::parseYesNo(i, "tcp"); |
| } |
| else if (i.first == "enable_v6") { |
| enableV6 = ConfigFile::parseYesNo(i, "tcp"); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Unrecognized option \"" + |
| i.first + "\" in \"tcp\" section")); |
| } |
| } |
| |
| if (!enableV4 && !enableV6) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("IPv4 and IPv6 TCP channels have been disabled." |
| " Remove \"tcp\" section to disable TCP channels or" |
| " re-enable at least one channel type.")); |
| } |
| |
| if (!isDryRun) { |
| if (m_factories.count("tcp") > 0) { |
| return; |
| } |
| |
| auto factory = make_shared<TcpFactory>(); |
| m_factories.insert(std::make_pair("tcp", factory)); |
| |
| if (enableV4) { |
| tcp::Endpoint endpoint(boost::asio::ip::tcp::v4(), port); |
| shared_ptr<TcpChannel> v4Channel = factory->createChannel(endpoint); |
| if (needToListen) { |
| v4Channel->listen(bind(&FaceTable::add, &m_faceTable, _1), nullptr); |
| } |
| |
| m_factories.insert(std::make_pair("tcp4", factory)); |
| } |
| |
| if (enableV6) { |
| tcp::Endpoint endpoint(boost::asio::ip::tcp::v6(), port); |
| shared_ptr<TcpChannel> v6Channel = factory->createChannel(endpoint); |
| if (needToListen) { |
| v6Channel->listen(bind(&FaceTable::add, &m_faceTable, _1), nullptr); |
| } |
| |
| m_factories.insert(std::make_pair("tcp6", factory)); |
| } |
| } |
| } |
| |
| void |
| FaceManager::processSectionUdp(const ConfigSection& configSection, bool isDryRun, |
| const std::vector<NetworkInterfaceInfo>& nicList) |
| { |
| // ; the udp section contains settings of UDP faces and channels |
| // udp |
| // { |
| // port 6363 ; UDP unicast port number |
| // idle_timeout 600 ; idle time (seconds) before closing a UDP unicast face |
| // keep_alive_interval 25 ; interval (seconds) between keep-alive refreshes |
| |
| // ; NFD creates one UDP multicast face per NIC |
| // mcast yes ; set to 'no' to disable UDP multicast, default 'yes' |
| // mcast_port 56363 ; UDP multicast port number |
| // mcast_group 224.0.23.170 ; UDP multicast group (IPv4 only) |
| // } |
| |
| uint16_t port = 6363; |
| bool enableV4 = true; |
| bool enableV6 = true; |
| size_t timeout = 600; |
| size_t keepAliveInterval = 25; |
| bool useMcast = true; |
| auto mcastGroup = boost::asio::ip::address_v4::from_string("224.0.23.170"); |
| uint16_t mcastPort = 56363; |
| |
| for (const auto& i : configSection) { |
| if (i.first == "port") { |
| port = ConfigFile::parseNumber<uint16_t>(i, "udp"); |
| NFD_LOG_TRACE("UDP unicast port set to " << port); |
| } |
| else if (i.first == "enable_v4") { |
| enableV4 = ConfigFile::parseYesNo(i, "udp"); |
| } |
| else if (i.first == "enable_v6") { |
| enableV6 = ConfigFile::parseYesNo(i, "udp"); |
| } |
| else if (i.first == "idle_timeout") { |
| try { |
| timeout = i.second.get_value<size_t>(); |
| } |
| catch (const boost::property_tree::ptree_bad_data&) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid value for option \"" + |
| i.first + "\" in \"udp\" section")); |
| } |
| } |
| else if (i.first == "keep_alive_interval") { |
| try { |
| keepAliveInterval = i.second.get_value<size_t>(); |
| /// \todo Make use of keepAliveInterval |
| (void)(keepAliveInterval); |
| } |
| catch (const boost::property_tree::ptree_bad_data&) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid value for option \"" + |
| i.first + "\" in \"udp\" section")); |
| } |
| } |
| else if (i.first == "mcast") { |
| useMcast = ConfigFile::parseYesNo(i, "udp"); |
| } |
| else if (i.first == "mcast_port") { |
| mcastPort = ConfigFile::parseNumber<uint16_t>(i, "udp"); |
| NFD_LOG_TRACE("UDP multicast port set to " << mcastPort); |
| } |
| else if (i.first == "mcast_group") { |
| boost::system::error_code ec; |
| mcastGroup = boost::asio::ip::address_v4::from_string(i.second.get_value<std::string>(), ec); |
| if (ec) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid value for option \"" + |
| i.first + "\" in \"udp\" section")); |
| } |
| NFD_LOG_TRACE("UDP multicast group set to " << mcastGroup); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Unrecognized option \"" + |
| i.first + "\" in \"udp\" section")); |
| } |
| } |
| |
| if (!enableV4 && !enableV6) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("IPv4 and IPv6 UDP channels have been disabled." |
| " Remove \"udp\" section to disable UDP channels or" |
| " re-enable at least one channel type.")); |
| } |
| else if (useMcast && !enableV4) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("IPv4 multicast requested, but IPv4 channels" |
| " have been disabled (conflicting configuration options set)")); |
| } |
| |
| if (!isDryRun) { |
| shared_ptr<UdpFactory> factory; |
| bool isReload = false; |
| if (m_factories.count("udp") > 0) { |
| isReload = true; |
| factory = static_pointer_cast<UdpFactory>(m_factories["udp"]); |
| } |
| else { |
| factory = make_shared<UdpFactory>(); |
| m_factories.insert(std::make_pair("udp", factory)); |
| } |
| |
| if (!isReload && enableV4) { |
| udp::Endpoint endpoint(boost::asio::ip::udp::v4(), port); |
| shared_ptr<UdpChannel> v4Channel = factory->createChannel(endpoint, time::seconds(timeout)); |
| v4Channel->listen(bind(&FaceTable::add, &m_faceTable, _1), nullptr); |
| |
| m_factories.insert(std::make_pair("udp4", factory)); |
| } |
| |
| if (!isReload && enableV6) { |
| udp::Endpoint endpoint(boost::asio::ip::udp::v6(), port); |
| shared_ptr<UdpChannel> v6Channel = factory->createChannel(endpoint, time::seconds(timeout)); |
| v6Channel->listen(bind(&FaceTable::add, &m_faceTable, _1), nullptr); |
| |
| m_factories.insert(std::make_pair("udp6", factory)); |
| } |
| |
| std::set<shared_ptr<Face>> multicastFacesToRemove; |
| for (const auto& i : factory->getMulticastFaces()) { |
| multicastFacesToRemove.insert(i.second); |
| } |
| |
| if (useMcast && enableV4) { |
| std::vector<NetworkInterfaceInfo> ipv4MulticastInterfaces; |
| for (const auto& nic : nicList) { |
| if (nic.isUp() && nic.isMulticastCapable() && !nic.ipv4Addresses.empty()) { |
| ipv4MulticastInterfaces.push_back(nic); |
| } |
| } |
| |
| bool isNicNameNecessary = false; |
| #if defined(__linux__) |
| if (ipv4MulticastInterfaces.size() > 1) { |
| // On Linux if we have more than one MulticastUdpFace |
| // we need to specify the name of the interface |
| isNicNameNecessary = true; |
| } |
| #endif |
| |
| udp::Endpoint mcastEndpoint(mcastGroup, mcastPort); |
| for (const auto& nic : ipv4MulticastInterfaces) { |
| udp::Endpoint localEndpoint(nic.ipv4Addresses[0], mcastPort); |
| auto newFace = factory->createMulticastFace(localEndpoint, mcastEndpoint, |
| isNicNameNecessary ? nic.name : ""); |
| m_faceTable.add(newFace); |
| multicastFacesToRemove.erase(newFace); |
| } |
| } |
| |
| for (const auto& face : multicastFacesToRemove) { |
| face->close(); |
| } |
| } |
| } |
| |
| void |
| FaceManager::processSectionEther(const ConfigSection& configSection, bool isDryRun, |
| const std::vector<NetworkInterfaceInfo>& nicList) |
| { |
| // ; the ether section contains settings of Ethernet faces and channels |
| // ether |
| // { |
| // ; NFD creates one Ethernet multicast face per NIC |
| // mcast yes ; set to 'no' to disable Ethernet multicast, default 'yes' |
| // mcast_group 01:00:5E:00:17:AA ; Ethernet multicast group |
| // } |
| |
| #if defined(HAVE_LIBPCAP) |
| bool useMcast = true; |
| ethernet::Address mcastGroup(ethernet::getDefaultMulticastAddress()); |
| |
| for (const auto& i : configSection) { |
| if (i.first == "mcast") { |
| useMcast = ConfigFile::parseYesNo(i, "ether"); |
| } |
| else if (i.first == "mcast_group") { |
| mcastGroup = ethernet::Address::fromString(i.second.get_value<std::string>()); |
| if (mcastGroup.isNull()) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid value for option \"" + |
| i.first + "\" in \"ether\" section")); |
| } |
| NFD_LOG_TRACE("Ethernet multicast group set to " << mcastGroup); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Unrecognized option \"" + |
| i.first + "\" in \"ether\" section")); |
| } |
| } |
| |
| if (!isDryRun) { |
| shared_ptr<EthernetFactory> factory; |
| if (m_factories.count("ether") > 0) { |
| factory = static_pointer_cast<EthernetFactory>(m_factories["ether"]); |
| } |
| else { |
| factory = make_shared<EthernetFactory>(); |
| m_factories.insert(std::make_pair("ether", factory)); |
| } |
| |
| std::set<shared_ptr<Face>> multicastFacesToRemove; |
| for (const auto& i : factory->getMulticastFaces()) { |
| multicastFacesToRemove.insert(i.second); |
| } |
| |
| if (useMcast) { |
| for (const auto& nic : nicList) { |
| if (nic.isUp() && nic.isMulticastCapable()) { |
| try { |
| auto newFace = factory->createMulticastFace(nic, mcastGroup); |
| m_faceTable.add(newFace); |
| multicastFacesToRemove.erase(newFace); |
| } |
| catch (const EthernetFactory::Error& factoryError) { |
| NFD_LOG_ERROR(factoryError.what() << ", continuing"); |
| } |
| catch (const face::EthernetTransport::Error& faceError) { |
| NFD_LOG_ERROR(faceError.what() << ", continuing"); |
| } |
| } |
| } |
| } |
| |
| for (const auto& face : multicastFacesToRemove) { |
| face->close(); |
| } |
| } |
| #else |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("NFD was compiled without libpcap, cannot process \"ether\" section")); |
| #endif // HAVE_LIBPCAP |
| } |
| |
| void |
| FaceManager::processSectionWebSocket(const ConfigSection& configSection, bool isDryRun) |
| { |
| // ; the websocket section contains settings of WebSocket faces and channels |
| // websocket |
| // { |
| // listen yes ; set to 'no' to disable WebSocket listener, default 'yes' |
| // port 9696 ; WebSocket listener port number |
| // enable_v4 yes ; set to 'no' to disable listening on IPv4 socket, default 'yes' |
| // enable_v6 yes ; set to 'no' to disable listening on IPv6 socket, default 'yes' |
| // } |
| |
| #if defined(HAVE_WEBSOCKET) |
| uint16_t port = 9696; |
| bool needToListen = true; |
| bool enableV4 = true; |
| bool enableV6 = true; |
| |
| for (const auto& i : configSection) { |
| if (i.first == "port") { |
| port = ConfigFile::parseNumber<uint16_t>(i, "websocket"); |
| NFD_LOG_TRACE("WebSocket port set to " << port); |
| } |
| else if (i.first == "listen") { |
| needToListen = ConfigFile::parseYesNo(i, "websocket"); |
| } |
| else if (i.first == "enable_v4") { |
| enableV4 = ConfigFile::parseYesNo(i, "websocket"); |
| } |
| else if (i.first == "enable_v6") { |
| enableV6 = ConfigFile::parseYesNo(i, "websocket"); |
| } |
| else { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("Unrecognized option \"" + |
| i.first + "\" in \"websocket\" section")); |
| } |
| } |
| |
| if (!enableV4 && !enableV6) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("IPv4 and IPv6 WebSocket channels have been disabled." |
| " Remove \"websocket\" section to disable WebSocket channels or" |
| " re-enable at least one channel type.")); |
| } |
| |
| if (!enableV4 && enableV6) { |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("NFD does not allow pure IPv6 WebSocket channel.")); |
| } |
| |
| if (!isDryRun) { |
| if (m_factories.count("websocket") > 0) { |
| return; |
| } |
| |
| auto factory = make_shared<WebSocketFactory>(); |
| m_factories.insert(std::make_pair("websocket", factory)); |
| |
| shared_ptr<WebSocketChannel> channel; |
| |
| if (enableV6 && enableV4) { |
| websocket::Endpoint endpoint(boost::asio::ip::address_v6::any(), port); |
| channel = factory->createChannel(endpoint); |
| |
| m_factories.insert(std::make_pair("websocket46", factory)); |
| } |
| else if (enableV4) { |
| websocket::Endpoint endpoint(boost::asio::ip::address_v4::any(), port); |
| channel = factory->createChannel(endpoint); |
| |
| m_factories.insert(std::make_pair("websocket4", factory)); |
| } |
| |
| if (channel && needToListen) { |
| channel->listen(bind(&FaceTable::add, &m_faceTable, _1)); |
| } |
| } |
| #else |
| BOOST_THROW_EXCEPTION(ConfigFile::Error("NFD was compiled without WebSocket, " |
| "cannot process \"websocket\" section")); |
| #endif // HAVE_WEBSOCKET |
| } |
| |
| } // namespace nfd |