manager-base.cpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
22 #include "manager-base.hpp"
23 #include <iostream>
24 
25 namespace nlsr {
26 namespace update {
27 
28 INIT_LOGGER(update.PrefixCommandProcessor);
29 
30 ManagerBase::ManagerBase(ndn::mgmt::Dispatcher& dispatcher,
31  const std::string& module)
32  : m_dispatcher(dispatcher)
33  , m_module(module)
34 {
35 }
36 
37 ndn::PartialName
38 ManagerBase::makeRelPrefix(const std::string& verb) const
39 {
40  return ndn::PartialName(m_module).append(verb);
41 }
42 
43 CommandManagerBase::CommandManagerBase(ndn::mgmt::Dispatcher& dispatcher,
44  NamePrefixList& namePrefixList,
45  Lsdb& lsdb,
46  const std::string& module)
47  : ManagerBase(dispatcher, module)
48  , m_namePrefixList(namePrefixList)
49  , m_lsdb(lsdb)
50 {
51 }
52 
53 void
55  const ndn::Interest& interest,
56  const ndn::mgmt::ControlParameters& parameters,
57  const ndn::mgmt::CommandContinuation& done)
58 {
59  const ndn::nfd::ControlParameters& castParams =
60  static_cast<const ndn::nfd::ControlParameters&>(parameters);
61 
62  // Only build a Name LSA if the added name is new
63  if (m_namePrefixList.insert(castParams.getName())) {
64  NLSR_LOG_INFO("Advertising name: " << castParams.getName() << "\n");
66  if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
67  NLSR_LOG_INFO("Saving name to the configuration file ");
68  if (afterAdvertise(castParams.getName()) == true) {
69  return done(ndn::nfd::ControlResponse(205, "OK").setBody(parameters.wireEncode()));
70  }
71  else {
72  return done(ndn::nfd::ControlResponse(406, "Failed to open configuration file.")
73  .setBody(parameters.wireEncode()));
74  }
75  }
76  return done(ndn::nfd::ControlResponse(200, "OK").setBody(parameters.wireEncode()));
77  }
78  else {
79  if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
80  // Save an already advertised prefix
81  NLSR_LOG_INFO("Saving an already advertised name: " << castParams.getName() << "\n");
82  if (afterAdvertise(castParams.getName()) == true) {
83  return done(ndn::nfd::ControlResponse(205, "OK").setBody(parameters.wireEncode()));
84  }
85  else {
86  return done(ndn::nfd::ControlResponse(406, "Prefix is already Saved/Failed to open configuration file.")
87  .setBody(parameters.wireEncode()));
88  }
89  }
90  return done(ndn::nfd::ControlResponse(204, "Prefix is already advertised/inserted.")
91  .setBody(parameters.wireEncode()));
92  }
93 }
94 
95 void
97  const ndn::Interest& interest,
98  const ndn::mgmt::ControlParameters& parameters,
99  const ndn::mgmt::CommandContinuation& done)
100 {
101  const ndn::nfd::ControlParameters& castParams =
102  static_cast<const ndn::nfd::ControlParameters&>(parameters);
103 
104  // Only build a Name LSA if the added name is new
105  if (m_namePrefixList.remove(castParams.getName())) {
106  NLSR_LOG_INFO("Withdrawing/Removing name: " << castParams.getName() << "\n");
108  if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
109  if (afterWithdraw(castParams.getName()) == true) {
110  return done(ndn::nfd::ControlResponse(205, "OK").setBody(parameters.wireEncode()));
111  }
112  else {
113  return done(ndn::nfd::ControlResponse(406, "Failed to open configuration file.")
114  .setBody(parameters.wireEncode()));
115  }
116  }
117  return done(ndn::nfd::ControlResponse(200, "OK").setBody(parameters.wireEncode()));
118  }
119  else {
120  if (castParams.hasFlags() && castParams.getFlags() == PREFIX_FLAG) {
121  // Delete an already withdrawn prefix
122  NLSR_LOG_INFO("Deleting an already withdrawn name: " << castParams.getName() << "\n");
123  if (afterWithdraw(castParams.getName()) == true) {
124  return done(ndn::nfd::ControlResponse(205, "OK").setBody(parameters.wireEncode()));
125  }
126  else {
127  return done(ndn::nfd::ControlResponse(406, "Prefix is already deleted/Failed to open configuration file.")
128  .setBody(parameters.wireEncode()));
129  }
130  }
131  return done(ndn::nfd::ControlResponse(204, "Prefix is already withdrawn/removed.")
132  .setBody(parameters.wireEncode()));
133  }
134 }
135 
136 } // namespace update
137 } // namespace nlsr
bool remove(const ndn::Name &name, const std::string &source="")
removes name from NamePrefixList
bool insert(const ndn::Name &name, const std::string &source="")
inserts name into NamePrefixList
void advertiseAndInsertPrefix(const ndn::Name &prefix, const ndn::Interest &interest, const ndn::mgmt::ControlParameters &parameters, const ndn::mgmt::CommandContinuation &done)
add desired name prefix to the advertised name prefix list or insert a prefix into the FIB if paramet...
#define INIT_LOGGER(name)
Definition: logger.hpp:35
ManagerBase(ndn::mgmt::Dispatcher &m_dispatcher, const std::string &module)
#define NLSR_LOG_INFO(x)
Definition: logger.hpp:39
Copyright (c) 2014-2019, The University of Memphis, Regents of the University of California, Arizona Board of Regents.
CommandManagerBase(ndn::mgmt::Dispatcher &m_dispatcher, NamePrefixList &m_namePrefixList, Lsdb &lsdb, const std::string &module)
void withdrawAndRemovePrefix(const ndn::Name &prefix, const ndn::Interest &interest, const ndn::mgmt::ControlParameters &parameters, const ndn::mgmt::CommandContinuation &done)
remove desired name prefix from the advertised name prefix list or remove a prefix from the FIB if pa...
bool buildAndInstallOwnNameLsa()
Builds a name LSA for this router and then installs it into the LSDB.
Definition: lsdb.cpp:145
virtual ndn::optional< bool > afterAdvertise(const ndn::Name &prefix)
save an advertised prefix to the nlsr configuration file returns bool from the overridden function wh...
virtual ndn::optional< bool > afterWithdraw(const ndn::Name &prefix)
save an advertised prefix to the nlsr configuration file returns bool from the overridden function wh...
ndn::PartialName makeRelPrefix(const std::string &verb) const
generate the relative prefix for a handler by appending the verb name to the module name ...