blob: 57230cddc0cc857e598465a1f1e0a9829c1e5e82 [file] [log] [blame]
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/**
* Copyright (c) 2014-2016, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
* Washington University in St. Louis,
* Beijing Institute of Technology,
* The University of Memphis.
*
* This file is part of NFD (Named Data Networking Forwarding Daemon).
* See AUTHORS.md for complete list of NFD authors and contributors.
*
* NFD is free software: you can redistribute it and/or modify it under the terms
* of the GNU General Public License as published by the Free Software Foundation,
* either version 3 of the License, or (at your option) any later version.
*
* NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along with
* NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
*/
#include "tables-config-section.hpp"
namespace nfd {
const size_t TablesConfigSection::DEFAULT_CS_MAX_PACKETS = 65536;
TablesConfigSection::TablesConfigSection(Forwarder& forwarder)
: m_forwarder(forwarder)
, m_isConfigured(false)
{
}
void
TablesConfigSection::setConfigFile(ConfigFile& configFile)
{
configFile.addSectionHandler("tables",
bind(&TablesConfigSection::processConfig, this, _1, _2));
}
void
TablesConfigSection::ensureConfigured()
{
if (m_isConfigured) {
return;
}
m_forwarder.getCs().setLimit(DEFAULT_CS_MAX_PACKETS);
m_isConfigured = true;
}
void
TablesConfigSection::processConfig(const ConfigSection& section, bool isDryRun)
{
typedef boost::optional<const ConfigSection&> OptionalNode;
size_t nCsMaxPackets = DEFAULT_CS_MAX_PACKETS;
OptionalNode csMaxPacketsNode = section.get_child_optional("cs_max_packets");
if (csMaxPacketsNode) {
nCsMaxPackets = ConfigFile::parseNumber<size_t>(*csMaxPacketsNode, "cs_max_packets", "tables");
}
OptionalNode strategyChoiceSection = section.get_child_optional("strategy_choice");
if (strategyChoiceSection) {
processStrategyChoiceSection(*strategyChoiceSection, isDryRun);
}
OptionalNode networkRegionSection = section.get_child_optional("network_region");
if (networkRegionSection) {
processNetworkRegionSection(*networkRegionSection, isDryRun);
}
if (isDryRun) {
return;
}
m_forwarder.getCs().setLimit(nCsMaxPackets);
m_isConfigured = true;
}
void
TablesConfigSection::processStrategyChoiceSection(const ConfigSection& section, bool isDryRun)
{
StrategyChoice& sc = m_forwarder.getStrategyChoice();
std::map<Name, Name> choices;
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"));
}
if (!choices.emplace(prefix, strategy).second) {
BOOST_THROW_EXCEPTION(ConfigFile::Error(
"Duplicate strategy choice for prefix \"" + prefix.toUri() +
"\" in \"strategy_choice\" section"));
}
}
if (isDryRun) {
return;
}
for (const auto& prefixAndStrategy : choices) {
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& section, bool isDryRun)
{
if (isDryRun) {
return;
}
NetworkRegionTable& nrt = m_forwarder.getNetworkRegionTable();
nrt.clear();
for (const auto& pair : section) {
Name region(pair.first);
nrt.insert(region);
}
}
} // namespace nfd