32 #include <ndn-cxx/lp/tags.hpp> 33 #include <ndn-cxx/mgmt/nfd/fib-entry.hpp> 35 #include <boost/range/adaptor/transformed.hpp> 45 , m_faceTable(faceTable)
47 registerCommandHandler<ndn::nfd::FibAddNextHopCommand>(
"add-nexthop",
48 bind(&FibManager::addNextHop,
this, _2, _3, _4, _5));
49 registerCommandHandler<ndn::nfd::FibRemoveNextHopCommand>(
"remove-nexthop",
50 bind(&FibManager::removeNextHop,
this, _2, _3, _4, _5));
56 FibManager::addNextHop(
const Name& topPrefix,
const Interest& interest,
57 ControlParameters parameters,
58 const ndn::mgmt::CommandContinuation& done)
60 setFaceForSelfRegistration(interest, parameters);
61 const Name& prefix = parameters.getName();
62 FaceId faceId = parameters.getFaceId();
63 uint64_t cost = parameters.getCost();
65 if (prefix.size() > Fib::getMaxDepth()) {
66 NFD_LOG_DEBUG(
"fib/add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
67 "): FAIL prefix-too-long");
68 return done(ControlResponse(414,
"FIB entry prefix cannot exceed " +
69 to_string(Fib::getMaxDepth()) +
" components"));
72 Face* face = m_faceTable.
get(faceId);
73 if (face ==
nullptr) {
74 NFD_LOG_DEBUG(
"fib/add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
75 "): FAIL unknown-faceid");
76 return done(ControlResponse(410,
"Face not found"));
82 NFD_LOG_TRACE(
"fib/add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
"): OK");
83 return done(ControlResponse(200,
"Success").setBody(parameters.wireEncode()));
87 FibManager::removeNextHop(
const Name& topPrefix,
const Interest& interest,
88 ControlParameters parameters,
89 const ndn::mgmt::CommandContinuation& done)
91 setFaceForSelfRegistration(interest, parameters);
92 const Name& prefix = parameters.getName();
93 FaceId faceId = parameters.getFaceId();
95 done(ControlResponse(200,
"Success").setBody(parameters.wireEncode()));
97 Face* face = m_faceTable.
get(faceId);
98 if (face ==
nullptr) {
99 NFD_LOG_TRACE(
"fib/remove-nexthop(" << prefix <<
',' << faceId <<
"): OK no-face");
104 if (entry ==
nullptr) {
105 NFD_LOG_TRACE(
"fib/remove-nexthop(" << prefix <<
',' << faceId <<
"): OK no-entry");
112 NFD_LOG_TRACE(
"fib/remove-nexthop(" << prefix <<
',' << faceId <<
"): OK entry-erased");
115 NFD_LOG_TRACE(
"fib/remove-nexthop(" << prefix <<
',' << faceId <<
"): OK nexthop-removed");
120 FibManager::listEntries(
const Name& topPrefix,
const Interest& interest,
121 ndn::mgmt::StatusDatasetContext& context)
123 for (
const auto& entry : m_fib) {
124 const auto& nexthops = entry.getNextHops() |
125 boost::adaptors::transformed([] (
const fib::NextHop& nh) {
126 return ndn::nfd::NextHopRecord()
127 .setFaceId(nh.
getFace().getId())
130 context.append(ndn::nfd::FibEntry()
131 .setPrefix(entry.getPrefix())
132 .setNextHopRecords(std::begin(nexthops), std::end(nexthops))
139 FibManager::setFaceForSelfRegistration(
const Interest& request, ControlParameters& parameters)
141 bool isSelfRegistration = (parameters.getFaceId() == 0);
142 if (isSelfRegistration) {
143 shared_ptr<lp::IncomingFaceIdTag> incomingFaceIdTag = request.getTag<lp::IncomingFaceIdTag>();
147 BOOST_ASSERT(incomingFaceIdTag !=
nullptr);
148 parameters.setFaceId(*incomingFaceIdTag);
void registerStatusDatasetHandler(const std::string &verb, const ndn::mgmt::StatusDatasetHandler &handler)
Entry * findExactMatch(const Name &prefix)
Performs an exact match lookup.
void erase(const Name &prefix)
std::pair< Entry *, bool > insert(const Name &prefix)
Find or insert a FIB entry.
Face * get(FaceId id) const
get face by FaceId
Provides ControlCommand authorization according to NFD configuration file.
A collection of common functions shared by all NFD managers, such as communicating with the dispatche...
Copyright (c) 2014-2015, Regents of the University of California, Arizona Board of Regents...
void addOrUpdateNextHop(Face &face, EndpointId endpointId, uint64_t cost)
adds a NextHop record
FibManager(fib::Fib &fib, const FaceTable &faceTable, Dispatcher &dispatcher, CommandAuthenticator &authenticator)
#define NFD_LOG_INIT(name)
void removeNextHop(const Face &face, EndpointId endpointId)
removes the NextHop record for face with the given endpointId
uint64_t FaceId
identifies a face
Represents a nexthop record in a FIB entry.