mgmt: TablesConfigSection constructor accepts Forwarder&
refs #2181
Change-Id: I1a87dd573f25f3806bc1b1f3c60ec9eef0eca4e3
diff --git a/daemon/mgmt/tables-config-section.cpp b/daemon/mgmt/tables-config-section.cpp
index 8422a5b..5095da8 100644
--- a/daemon/mgmt/tables-config-section.cpp
+++ b/daemon/mgmt/tables-config-section.cpp
@@ -24,9 +24,7 @@
*/
#include "tables-config-section.hpp"
-
#include "core/logger.hpp"
-#include "core/config-file.hpp"
namespace nfd {
@@ -34,180 +32,113 @@
const size_t TablesConfigSection::DEFAULT_CS_MAX_PACKETS = 65536;
-TablesConfigSection::TablesConfigSection(Cs& cs,
- Pit& pit,
- Fib& fib,
- StrategyChoice& strategyChoice,
- Measurements& measurements,
- NetworkRegionTable& networkRegionTable)
- : m_cs(cs)
- // , m_pit(pit)
- // , m_fib(fib)
- , m_strategyChoice(strategyChoice)
- // , m_measurements(measurements)
- , m_networkRegionTable(networkRegionTable)
- , m_areTablesConfigured(false)
+TablesConfigSection::TablesConfigSection(Forwarder& forwarder)
+ : m_forwarder(forwarder)
+ , m_isConfigured(false)
{
-
}
void
TablesConfigSection::setConfigFile(ConfigFile& configFile)
{
configFile.addSectionHandler("tables",
- bind(&TablesConfigSection::processConfig, this, _1, _2, _3));
+ bind(&TablesConfigSection::processConfig, this, _1, _2));
}
-
void
-TablesConfigSection::ensureTablesAreConfigured()
+TablesConfigSection::ensureConfigured()
{
- if (m_areTablesConfigured) {
+ if (m_isConfigured) {
return;
}
NFD_LOG_INFO("Setting CS max packets to " << DEFAULT_CS_MAX_PACKETS);
- m_cs.setLimit(DEFAULT_CS_MAX_PACKETS);
+ m_forwarder.getCs().setLimit(DEFAULT_CS_MAX_PACKETS);
- m_areTablesConfigured = true;
+ m_isConfigured = true;
}
void
-TablesConfigSection::processConfig(const ConfigSection& configSection,
- bool isDryRun,
- const std::string& filename)
+TablesConfigSection::processConfig(const ConfigSection& section, bool isDryRun)
{
- // tables
- // {
- // cs_max_packets 65536
- //
- // strategy_choice
- // {
- // / /localhost/nfd/strategy/best-route
- // /localhost /localhost/nfd/strategy/multicast
- // /localhost/nfd /localhost/nfd/strategy/best-route
- // /ndn/broadcast /localhost/nfd/strategy/multicast
- // }
- //
- // network_region
- // {
- // /example/region1
- // /example/region2
- // }
- // }
+ typedef boost::optional<const ConfigSection&> OptionalNode;
size_t nCsMaxPackets = DEFAULT_CS_MAX_PACKETS;
-
- boost::optional<const ConfigSection&> csMaxPacketsNode =
- configSection.get_child_optional("cs_max_packets");
-
+ OptionalNode csMaxPacketsNode = section.get_child_optional("cs_max_packets");
if (csMaxPacketsNode) {
- boost::optional<size_t> valCsMaxPackets =
- configSection.get_optional<size_t>("cs_max_packets");
-
- if (!valCsMaxPackets) {
- BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid value for option \"cs_max_packets\""
- " in \"tables\" section"));
- }
-
- nCsMaxPackets = *valCsMaxPackets;
+ nCsMaxPackets = ConfigFile::parseNumber<size_t>(*csMaxPacketsNode, "cs_max_packets", "tables");
}
- boost::optional<const ConfigSection&> strategyChoiceSection =
- configSection.get_child_optional("strategy_choice");
-
+ OptionalNode strategyChoiceSection = section.get_child_optional("strategy_choice");
if (strategyChoiceSection) {
processStrategyChoiceSection(*strategyChoiceSection, isDryRun);
}
- boost::optional<const ConfigSection&> networkRegionSection =
- configSection.get_child_optional("network_region");
-
+ OptionalNode networkRegionSection = section.get_child_optional("network_region");
if (networkRegionSection) {
processNetworkRegionSection(*networkRegionSection, isDryRun);
}
- if (!isDryRun) {
- NFD_LOG_INFO("Setting CS max packets to " << nCsMaxPackets);
-
- m_cs.setLimit(nCsMaxPackets);
- m_areTablesConfigured = true;
+ if (isDryRun) {
+ return;
}
+
+ NFD_LOG_INFO("Setting CS max packets to " << nCsMaxPackets);
+ m_forwarder.getCs().setLimit(nCsMaxPackets);
+
+ m_isConfigured = true;
}
void
-TablesConfigSection::processStrategyChoiceSection(const ConfigSection& configSection,
- bool isDryRun)
+TablesConfigSection::processStrategyChoiceSection(const ConfigSection& section, bool isDryRun)
{
- // strategy_choice
- // {
- // / /localhost/nfd/strategy/best-route
- // /localhost /localhost/nfd/strategy/multicast
- // /localhost/nfd /localhost/nfd/strategy/best-route
- // /ndn/broadcast /localhost/nfd/strategy/multicast
- // }
+ StrategyChoice& sc = m_forwarder.getStrategyChoice();
std::map<Name, Name> choices;
- for (const auto& prefixAndStrategy : configSection) {
- const Name prefix(prefixAndStrategy.first);
- if (choices.find(prefix) != choices.end()) {
- BOOST_THROW_EXCEPTION(ConfigFile::Error("Duplicate strategy choice for prefix \"" +
- prefix.toUri() + "\" in \"strategy_choice\" "
- "section"));
+ for (const auto& prefixAndStrategy : section) {
+ Name prefix(prefixAndStrategy.first);
+ Name strategy(prefixAndStrategy.second.get_value<std::string>());
+
+ if (!sc.hasStrategy(strategy)) {
+ BOOST_THROW_EXCEPTION(ConfigFile::Error(
+ "Unknown strategy \"" + prefixAndStrategy.second.get_value<std::string>() +
+ "\" for prefix \"" + prefix.toUri() + "\" in \"strategy_choice\" section"));
}
- const std::string strategyString(prefixAndStrategy.second.get_value<std::string>());
- if (strategyString.empty()) {
- BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid strategy choice \"\" for prefix \"" +
- prefix.toUri() + "\" in \"strategy_choice\" "
- "section"));
+ if (!choices.emplace(prefix, strategy).second) {
+ BOOST_THROW_EXCEPTION(ConfigFile::Error(
+ "Duplicate strategy choice for prefix \"" + prefix.toUri() +
+ "\" in \"strategy_choice\" section"));
}
-
- const Name strategyName(strategyString);
- if (!m_strategyChoice.hasStrategy(strategyName)) {
- BOOST_THROW_EXCEPTION(ConfigFile::Error("Invalid strategy choice \"" +
- strategyName.toUri() + "\" for prefix \"" +
- prefix.toUri() + "\" in \"strategy_choice\" "
- "section"));
- }
-
- choices[prefix] = strategyName;
}
+ if (isDryRun) {
+ return;
+ }
for (const auto& prefixAndStrategy : choices) {
- if (!isDryRun && !m_strategyChoice.insert(prefixAndStrategy.first, prefixAndStrategy.second)) {
- BOOST_THROW_EXCEPTION(ConfigFile::Error("Failed to set strategy \"" +
- prefixAndStrategy.second.toUri() + "\" for "
- "prefix \"" + prefixAndStrategy.first.toUri() +
- "\" in \"strategy_choicev\""));
+ if (!sc.insert(prefixAndStrategy.first, prefixAndStrategy.second)) {
+ BOOST_THROW_EXCEPTION(ConfigFile::Error(
+ "Failed to set strategy \"" + prefixAndStrategy.second.toUri() + "\" for "
+ "prefix \"" + prefixAndStrategy.first.toUri() + "\" in \"strategy_choicev\""));
}
}
}
void
-TablesConfigSection::processNetworkRegionSection(const ConfigSection& configSection,
- bool isDryRun)
+TablesConfigSection::processNetworkRegionSection(const ConfigSection& section, bool isDryRun)
{
- // network_region
- // {
- // /example/region1
- // /example/region2
- // }
-
- if (!isDryRun) {
- m_networkRegionTable.clear();
+ if (isDryRun) {
+ return;
}
- for (const auto& pair : configSection) {
- const Name region(pair.first);
-
- if (!isDryRun) {
- m_networkRegionTable.insert(region);
- }
+ NetworkRegionTable& nrt = m_forwarder.getNetworkRegionTable();
+ nrt.clear();
+ for (const auto& pair : section) {
+ Name region(pair.first);
+ nrt.insert(region);
}
}
-
} // namespace nfd
diff --git a/daemon/mgmt/tables-config-section.hpp b/daemon/mgmt/tables-config-section.hpp
index 82cb877..4aff010 100644
--- a/daemon/mgmt/tables-config-section.hpp
+++ b/daemon/mgmt/tables-config-section.hpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/**
- * Copyright (c) 2014-2015, Regents of the University of California,
+ * Copyright (c) 2014-2016, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -26,67 +26,66 @@
#ifndef NFD_MGMT_TABLES_CONFIG_SECTION_HPP
#define NFD_MGMT_TABLES_CONFIG_SECTION_HPP
-#include "table/fib.hpp"
-#include "table/pit.hpp"
-#include "table/cs.hpp"
-#include "table/measurements.hpp"
-#include "table/network-region-table.hpp"
-#include "table/strategy-choice.hpp"
-
+#include "fw/forwarder.hpp"
#include "core/config-file.hpp"
namespace nfd {
-/**
- * \brief Provides parsing for `tables` configuration file section.
+/** \brief handles 'tables' config section
*
- * This class enables configuration of CS, PIT, FIB, Strategy Choice, Measurements, and
- * Network Region tables.
+ * This class recognizes a config section that looks like
+ * \code{.unparsed}
+ * tables
+ * {
+ * cs_max_packets 65536
+ *
+ * strategy_choice
+ * {
+ * / /localhost/nfd/strategy/best-route
+ * /localhost /localhost/nfd/strategy/multicast
+ * /localhost/nfd /localhost/nfd/strategy/best-route
+ * /ndn/broadcast /localhost/nfd/strategy/multicast
+ * }
+ *
+ * network_region
+ * {
+ * /example/region1
+ * /example/region2
+ * }
+ * }
+ * \endcode
*/
-class TablesConfigSection
+class TablesConfigSection : noncopyable
{
public:
- TablesConfigSection(Cs& cs,
- Pit& pit,
- Fib& fib,
- StrategyChoice& strategyChoice,
- Measurements& measurements,
- NetworkRegionTable& networkRegionTable);
+ explicit
+ TablesConfigSection(Forwarder& forwarder);
void
setConfigFile(ConfigFile& configFile);
+ /** \brief apply default configuration, if tables section was omitted in configuration file
+ */
void
- ensureTablesAreConfigured();
+ ensureConfigured();
private:
+ void
+ processConfig(const ConfigSection& section, bool isDryRun);
void
- processConfig(const ConfigSection& configSection,
- bool isDryRun,
- const std::string& filename);
+ processStrategyChoiceSection(const ConfigSection& section, bool isDryRun);
void
- processStrategyChoiceSection(const ConfigSection& configSection,
- bool isDryRun);
-
- void
- processNetworkRegionSection(const ConfigSection& configSection,
- bool isDryRun);
+ processNetworkRegionSection(const ConfigSection& section, bool isDryRun);
private:
- Cs& m_cs;
- // Pit& m_pit;
- // Fib& m_fib;
- StrategyChoice& m_strategyChoice;
- // Measurements& m_measurements;
- NetworkRegionTable& m_networkRegionTable;
-
- bool m_areTablesConfigured;
-
private:
-
static const size_t DEFAULT_CS_MAX_PACKETS;
+
+ Forwarder& m_forwarder;
+
+ bool m_isConfigured;
};
} // namespace nfd
diff --git a/daemon/nfd.cpp b/daemon/nfd.cpp
index 5d6bec7..b3369db 100644
--- a/daemon/nfd.cpp
+++ b/daemon/nfd.cpp
@@ -155,12 +155,7 @@
ConfigFile config(&ignoreRibAndLogSections);
general::setConfigFile(config);
- TablesConfigSection tablesConfig(m_forwarder->getCs(),
- m_forwarder->getPit(),
- m_forwarder->getFib(),
- m_forwarder->getStrategyChoice(),
- m_forwarder->getMeasurements(),
- m_forwarder->getNetworkRegionTable());
+ TablesConfigSection tablesConfig(*m_forwarder);
tablesConfig.setConfigFile(config);
m_authenticator->setConfigFile(config);
@@ -176,7 +171,7 @@
config.parse(m_configSection, false, INTERNAL_CONFIG);
}
- tablesConfig.ensureTablesAreConfigured();
+ tablesConfig.ensureConfigured();
// add FIB entry for NFD Management Protocol
Name topPrefix("/localhost/nfd");
@@ -196,12 +191,7 @@
general::setConfigFile(config);
- TablesConfigSection tablesConfig(m_forwarder->getCs(),
- m_forwarder->getPit(),
- m_forwarder->getFib(),
- m_forwarder->getStrategyChoice(),
- m_forwarder->getMeasurements(),
- m_forwarder->getNetworkRegionTable());
+ TablesConfigSection tablesConfig(*m_forwarder);
tablesConfig.setConfigFile(config);
m_authenticator->setConfigFile(config);