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>([
this] (
auto&&,
auto&&... args) {
48 addNextHop(std::forward<decltype(args)>(args)...);
50 registerCommandHandler<ndn::nfd::FibRemoveNextHopCommand>([
this] (
auto&&,
auto&&... args) {
51 removeNextHop(std::forward<decltype(args)>(args)...);
54 listEntries(std::forward<decltype(args)>(args)...);
59 FibManager::addNextHop(
const Interest& interest, ControlParameters parameters,
60 const CommandContinuation& done)
62 setFaceForSelfRegistration(interest, parameters);
63 const Name& prefix = parameters.getName();
64 FaceId faceId = parameters.getFaceId();
65 uint64_t cost = parameters.getCost();
68 NFD_LOG_DEBUG(
"add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
69 ") -> FAIL prefix-too-long");
70 return done(ControlResponse(414,
"FIB entry prefix cannot exceed " +
74 Face* face = m_faceTable.
get(faceId);
75 if (face ==
nullptr) {
76 NFD_LOG_DEBUG(
"add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
77 ") -> FAIL unknown-faceid");
78 return done(ControlResponse(410,
"Face not found"));
81 fib::Entry* entry = m_fib.
insert(prefix).first;
84 NFD_LOG_TRACE(
"add-nexthop(" << prefix <<
',' << faceId <<
',' << cost <<
") -> OK");
85 return done(ControlResponse(200,
"OK").setBody(parameters.wireEncode()));
89 FibManager::removeNextHop(
const Interest& interest, ControlParameters parameters,
90 const CommandContinuation& done)
92 setFaceForSelfRegistration(interest, parameters);
93 const Name& prefix = parameters.getName();
94 FaceId faceId = parameters.getFaceId();
96 done(ControlResponse(200,
"OK").setBody(parameters.wireEncode()));
98 Face* face = m_faceTable.
get(faceId);
99 if (face ==
nullptr) {
100 NFD_LOG_TRACE(
"remove-nexthop(" << prefix <<
',' << faceId <<
") -> OK no-face");
105 if (entry ==
nullptr) {
106 NFD_LOG_TRACE(
"remove-nexthop(" << prefix <<
',' << faceId <<
") -> OK no-entry");
113 NFD_LOG_TRACE(
"remove-nexthop(" << prefix <<
',' << faceId <<
") -> OK no-nexthop");
116 NFD_LOG_TRACE(
"remove-nexthop(" << prefix <<
',' << faceId <<
") -> OK entry-erased");
119 NFD_LOG_TRACE(
"remove-nexthop(" << prefix <<
',' << faceId <<
") -> OK nexthop-removed");
125 FibManager::listEntries(ndn::mgmt::StatusDatasetContext& context)
127 for (
const auto& entry : m_fib) {
128 const auto& nexthops = entry.getNextHops() |
129 boost::adaptors::transformed([] (
const fib::NextHop& nh) {
130 return ndn::nfd::NextHopRecord()
131 .setFaceId(nh.getFace().getId())
132 .setCost(nh.getCost());
134 context.append(ndn::nfd::FibEntry()
135 .setPrefix(entry.getPrefix())
136 .setNextHopRecords(std::begin(nexthops), std::end(nexthops))
143 FibManager::setFaceForSelfRegistration(
const Interest& request, ControlParameters& parameters)
146 if (isSelfRegistration) {
147 auto incomingFaceIdTag = request.getTag<lp::IncomingFaceIdTag>();
151 BOOST_ASSERT(incomingFaceIdTag !=
nullptr);
152 parameters.setFaceId(*incomingFaceIdTag);
Provides ControlCommand authorization according to NFD's configuration file.
Face * get(FaceId id) const noexcept
Get face by FaceId.
FibManager(fib::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...
void registerStatusDatasetHandler(const std::string &verb, const ndn::mgmt::StatusDatasetHandler &handler)
Represents the Forwarding Information Base (FIB).
@ NEXTHOP_REMOVED
the nexthop is removed and the fib entry stays
@ FIB_ENTRY_REMOVED
the nexthop is removed and the fib entry is removed
@ NO_SUCH_NEXTHOP
the nexthop is not found
std::pair< Entry *, bool > insert(const Name &prefix)
Find or insert a FIB entry.
Entry * findExactMatch(const Name &prefix)
Performs an exact match lookup.
RemoveNextHopResult removeNextHop(Entry &entry, const Face &face)
Remove the NextHop record for face from entry.
static constexpr size_t getMaxDepth()
Maximum number of components in a FIB entry prefix.
void addOrUpdateNextHop(Entry &entry, Face &face, uint64_t cost)
Add a NextHop record.
#define NFD_LOG_INIT(name)
constexpr FaceId INVALID_FACEID
Indicates an invalid FaceId.
uint64_t FaceId
Identifies a face.