29 #include <ndn-cxx/lp/tags.hpp> 30 #include <ndn-cxx/mgmt/nfd/fib-entry.hpp> 32 #include <boost/range/adaptor/transformed.hpp> 40 Dispatcher& dispatcher,
44 , m_faceTable(faceTable)
46 registerCommandHandler<ndn::nfd::FibAddNextHopCommand>(
"add-nexthop",
47 bind(&FibManager::addNextHop,
this, _2, _3, _4, _5));
48 registerCommandHandler<ndn::nfd::FibRemoveNextHopCommand>(
"remove-nexthop",
49 bind(&FibManager::removeNextHop,
this, _2, _3, _4, _5));
55 FibManager::addNextHop(
const Name& topPrefix,
const Interest& interest,
56 ControlParameters parameters,
57 const ndn::mgmt::CommandContinuation& done)
59 setFaceForSelfRegistration(interest, parameters);
61 const Name& prefix = parameters.getName();
62 FaceId faceId = parameters.getFaceId();
63 uint64_t cost = parameters.getCost();
66 <<
" faceid: " << faceId
67 <<
" cost: " << cost);
69 Face* face = m_faceTable.
get(faceId);
70 if (face !=
nullptr) {
71 fib::Entry* entry = m_fib.insert(prefix).first;
75 <<
" prefix:" << prefix
76 <<
" faceid: " << faceId
77 <<
" cost: " << cost);
79 return done(ControlResponse(200,
"Success").setBody(parameters.wireEncode()));
82 NFD_LOG_INFO(
"add-nexthop result: FAIL reason: unknown-faceid: " << faceId);
83 return done(ControlResponse(410,
"Face not found"));
88 FibManager::removeNextHop(
const Name& topPrefix,
const Interest& interest,
89 ControlParameters parameters,
90 const ndn::mgmt::CommandContinuation& done)
92 setFaceForSelfRegistration(interest, parameters);
94 NFD_LOG_TRACE(
"remove-nexthop prefix: " << parameters.getName()
95 <<
" faceid: " << parameters.getFaceId());
97 Face* face = m_faceTable.
get(parameters.getFaceId());
98 if (face !=
nullptr) {
99 fib::Entry* entry = m_fib.findExactMatch(parameters.getName());
100 if (entry !=
nullptr) {
102 NFD_LOG_DEBUG(
"remove-nexthop result: OK prefix: " << parameters.getName()
103 <<
" faceid: " << parameters.getFaceId());
117 done(ControlResponse(200,
"Success").setBody(parameters.wireEncode()));
121 FibManager::listEntries(
const Name& topPrefix,
const Interest& interest,
122 ndn::mgmt::StatusDatasetContext& context)
124 for (
const auto& entry : m_fib) {
125 const auto& nexthops = entry.getNextHops() |
126 boost::adaptors::transformed([] (
const fib::NextHop& nh) {
127 return ndn::nfd::NextHopRecord()
128 .setFaceId(nh.
getFace().getId())
131 context.append(ndn::nfd::FibEntry()
132 .setPrefix(entry.getPrefix())
133 .setNextHopRecords(std::begin(nexthops), std::end(nexthops))
140 FibManager::setFaceForSelfRegistration(
const Interest& request, ControlParameters& parameters)
142 bool isSelfRegistration = (parameters.getFaceId() == 0);
143 if (isSelfRegistration) {
144 shared_ptr<lp::IncomingFaceIdTag> incomingFaceIdTag = request.getTag<lp::IncomingFaceIdTag>();
148 BOOST_ASSERT(incomingFaceIdTag !=
nullptr);
149 parameters.setFaceId(*incomingFaceIdTag);
void registerStatusDatasetHandler(const std::string &verb, const ndn::mgmt::StatusDatasetHandler &handler)
#define NFD_LOG_DEBUG(expression)
void addNextHop(Face &face, uint64_t cost)
adds a NextHop record
Face * get(FaceId id) const
get face by FaceId
provides ControlCommand authorization according to NFD configuration file
#define NFD_LOG_INFO(expression)
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
FibManager(Fib &fib, const FaceTable &faceTable, Dispatcher &dispatcher, CommandAuthenticator &authenticator)
a collection of common functions shared by all NFD managers, such as communicating with the dispatche...
#define NFD_LOG_INIT(name)
#define NFD_LOG_TRACE(expression)
uint64_t FaceId
identifies a face
void removeNextHop(const Face &face)
removes a NextHop record
represents a nexthop record in FIB entry