47#include <boost/algorithm/string.hpp>
48#include <boost/lexical_cast.hpp>
54#include <netinet/in.h>
98 bool echo_client_id = getBoolean(global,
"echo-client-id");
99 cfg->setEchoClientId(echo_client_id);
102 uint32_t probation_period =
103 getUint32(global,
"decline-probation-period");
104 cfg->setDeclinePeriod(probation_period);
107 uint16_t dhcp4o6_port = getUint16(global,
"dhcp4o6-port");
108 cfg->setDhcp4o6Port(dhcp4o6_port);
113 cfg->setContext(user_context);
117 std::string server_tag = getString(global,
"server-tag");
118 cfg->setServerTag(server_tag);
134 bool ip_reservations_unique = getBoolean(global,
"ip-reservations-unique");
135 cfg->setIPReservationsUnique(ip_reservations_unique);
147 if (!dest || !from) {
159 for (
auto const& net : *networks) {
170 for (
auto const& subnet : *subnets) {
188 cfg->sanityChecksLifetime(
"valid-lifetime");
193 sharedNetworksSanityChecks(*networks, global->get(
"shared-networks"));
215 std::set<string> names;
218 for (
auto const& net : networks) {
223 bool authoritative = net->getAuthoritative();
224 string iface = net->getIface();
229 for (
auto const& subnet : *subnets) {
230 if (subnet->getAuthoritative() != authoritative) {
233 <<
" has different authoritative setting "
234 << subnet->getAuthoritative()
235 <<
" than the shared-network itself: "
240 iface = subnet->getIface();
244 if (subnet->getIface().empty()) {
248 if (subnet->getIface() != iface) {
250 <<
" has specified interface " << subnet->getIface()
251 <<
", but earlier subnet in the same shared-network"
252 <<
" or the shared-network itself used " << iface);
257 txt += subnet->toText() +
" ";
262 if (net->getName().empty()) {
264 << txt <<
" is missing mandatory 'name' parameter");
268 if (names.find(net->getName()) != names.end()) {
270 "name " << net->getName() <<
" defined twice.");
272 names.insert(net->getName());
302 bool sock_changed = (sock_cfg && current_sock_cfg &&
303 !sock_cfg->equals(*current_sock_cfg));
310 if (!sock_cfg || !current_sock_cfg || sock_changed) {
343 string parameter_name;
353 mutable_cfg = boost::const_pointer_cast<Element>(config_set);
368 Dhcp4ConfigParser global_parser;
371 global_parser.parseEarly(srv_config, mutable_cfg);
376 parameter_name =
"option-def";
379 parser.
parse(cfg_option_def, option_defs);
384 parameter_name =
"option-data";
387 parser.
parse(cfg_option, option_datas);
391 if (control_socket) {
392 parameter_name =
"control-socket";
394 parser.
parse(*srv_config, control_socket);
398 if (multi_threading) {
399 parameter_name =
"multi-threading";
401 parser.
parse(*srv_config, multi_threading);
404 bool multi_threading_enabled =
true;
405 uint32_t thread_count = 0;
406 uint32_t queue_size = 0;
408 multi_threading_enabled, thread_count, queue_size);
411 ConstElementPtr queue_control = mutable_cfg->get(
"dhcp-queue-control");
413 parameter_name =
"dhcp-queue-control";
415 srv_config->setDHCPQueueControl(parser.
parse(queue_control, multi_threading_enabled));
419 ConstElementPtr reservations_lookup_first = mutable_cfg->get(
"reservations-lookup-first");
420 if (reservations_lookup_first) {
421 parameter_name =
"reservations-lookup-first";
422 if (multi_threading_enabled) {
425 srv_config->setReservationsLookupFirst(reservations_lookup_first->boolValue());
429 mutable_cfg->get(
"host-reservation-identifiers");
430 if (hr_identifiers) {
431 parameter_name =
"host-reservation-identifiers";
433 parser.
parse(hr_identifiers);
438 parameter_name =
"sanity-checks";
440 parser.
parse(*srv_config, sanity_checks);
444 mutable_cfg->get(
"expired-leases-processing");
445 if (expiration_cfg) {
446 parameter_name =
"expired-leases-processing";
455 if (hooks_libraries) {
456 parameter_name =
"hooks-libraries";
458 HooksConfig& libraries = srv_config->getHooksConfig();
459 hooks_parser.parse(libraries, hooks_libraries);
461 multi_threading_enabled);
470 parameter_name =
"dhcp-ddns";
474 d2_client_cfg = parser.
parse(dhcp_ddns);
478 if (client_classes) {
479 parameter_name =
"client-classes";
482 parser.
parse(client_classes, AF_INET);
483 srv_config->setClientClassDictionary(dictionary);
488 if (lease_database) {
489 parameter_name =
"lease-database";
491 std::string access_string;
492 parser.
parse(access_string, lease_database);
494 cfg_db_access->setLeaseDbAccessString(access_string);
498 if (hosts_database) {
499 parameter_name =
"hosts-database";
501 std::string access_string;
502 parser.
parse(access_string, hosts_database);
504 cfg_db_access->setHostDbAccessString(access_string);
508 if (hosts_databases) {
509 parameter_name =
"hosts-databases";
511 for (
auto const& it : hosts_databases->listValue()) {
513 std::string access_string;
514 parser.
parse(access_string, it);
515 cfg_db_access->setHostDbAccessString(access_string);
521 if (shared_networks) {
522 parameter_name =
"shared-networks";
530 parser.parse(cfg, shared_networks);
534 global_parser.copySubnets4(srv_config->getCfgSubnets4(), cfg);
539 parameter_name =
"subnet4";
542 subnets_parser.
parse(srv_config, subnet4);
547 parameter_name =
"reservations";
549 HostReservationsListParser<HostReservationParser4> parser;
550 parser.parse(SUBNET_ID_GLOBAL, reservations, hosts);
551 for (
auto const& h : hosts) {
552 srv_config->getCfgHosts()->add(h);
557 if (config_control) {
558 parameter_name =
"config-control";
571 const std::map<std::string, ConstElementPtr>& values_map =
572 mutable_cfg->mapValue();
574 for (
auto const& config_pair : values_map) {
575 parameter_name = config_pair.first;
578 if ((config_pair.first ==
"option-def") ||
579 (config_pair.first ==
"option-data") ||
580 (config_pair.first ==
"control-socket") ||
581 (config_pair.first ==
"multi-threading") ||
582 (config_pair.first ==
"dhcp-queue-control") ||
583 (config_pair.first ==
"host-reservation-identifiers") ||
584 (config_pair.first ==
"interfaces-config") ||
585 (config_pair.first ==
"sanity-checks") ||
586 (config_pair.first ==
"expired-leases-processing") ||
587 (config_pair.first ==
"hooks-libraries") ||
588 (config_pair.first ==
"dhcp-ddns") ||
589 (config_pair.first ==
"client-classes") ||
590 (config_pair.first ==
"lease-database") ||
591 (config_pair.first ==
"hosts-database") ||
592 (config_pair.first ==
"hosts-databases") ||
593 (config_pair.first ==
"subnet4") ||
594 (config_pair.first ==
"shared-networks") ||
595 (config_pair.first ==
"reservations") ||
596 (config_pair.first ==
"config-control") ||
597 (config_pair.first ==
"loggers") ||
598 (config_pair.first ==
"compatibility")) {
612 if ( (config_pair.first ==
"renew-timer") ||
613 (config_pair.first ==
"rebind-timer") ||
614 (config_pair.first ==
"valid-lifetime") ||
615 (config_pair.first ==
"min-valid-lifetime") ||
616 (config_pair.first ==
"max-valid-lifetime") ||
617 (config_pair.first ==
"decline-probation-period") ||
618 (config_pair.first ==
"dhcp4o6-port") ||
619 (config_pair.first ==
"echo-client-id") ||
620 (config_pair.first ==
"match-client-id") ||
621 (config_pair.first ==
"authoritative") ||
622 (config_pair.first ==
"next-server") ||
623 (config_pair.first ==
"server-hostname") ||
624 (config_pair.first ==
"boot-file-name") ||
625 (config_pair.first ==
"server-tag") ||
626 (config_pair.first ==
"reservations-global") ||
627 (config_pair.first ==
"reservations-in-subnet") ||
628 (config_pair.first ==
"reservations-out-of-pool") ||
629 (config_pair.first ==
"calculate-tee-times") ||
630 (config_pair.first ==
"t1-percent") ||
631 (config_pair.first ==
"t2-percent") ||
632 (config_pair.first ==
"cache-threshold") ||
633 (config_pair.first ==
"cache-max-age") ||
634 (config_pair.first ==
"hostname-char-set") ||
635 (config_pair.first ==
"hostname-char-replacement") ||
636 (config_pair.first ==
"ddns-send-updates") ||
637 (config_pair.first ==
"ddns-override-no-update") ||
638 (config_pair.first ==
"ddns-override-client-update") ||
639 (config_pair.first ==
"ddns-replace-client-name") ||
640 (config_pair.first ==
"ddns-generated-prefix") ||
641 (config_pair.first ==
"ddns-qualifying-suffix") ||
642 (config_pair.first ==
"ddns-update-on-renew") ||
643 (config_pair.first ==
"ddns-use-conflict-resolution") ||
644 (config_pair.first ==
"ddns-conflict-resolution-mode") ||
645 (config_pair.first ==
"ddns-ttl-percent") ||
646 (config_pair.first ==
"store-extended-info") ||
647 (config_pair.first ==
"statistic-default-sample-count") ||
648 (config_pair.first ==
"statistic-default-sample-age") ||
649 (config_pair.first ==
"early-global-reservations-lookup") ||
650 (config_pair.first ==
"ip-reservations-unique") ||
651 (config_pair.first ==
"reservations-lookup-first") ||
652 (config_pair.first ==
"parked-packet-limit") ||
653 (config_pair.first ==
"allocator") ||
654 (config_pair.first ==
"offer-lifetime") ||
655 (config_pair.first ==
"stash-agent-options") ) {
662 if (config_pair.first ==
"user-context") {
668 "unsupported global configuration parameter: " << config_pair.first
669 <<
" (" << config_pair.second->getPosition() <<
")");
673 parameter_name =
"<post parsing>";
676 global_parser.parse(srv_config, mutable_cfg);
681 global_parser.sanityChecks(srv_config, mutable_cfg);
684 if (!d2_client_cfg) {
687 d2_client_cfg->validateContents();
688 srv_config->setD2ClientConfig(d2_client_cfg);
691 .arg(parameter_name).arg(ex.what());
702 "Control-socket, hook-libraries, and D2 configuration "
703 "were sanity checked, but not applied.");
711 bool check_only,
bool extra_checks) {
714 "Can't parse NULL config");
719 .arg(server.redactConfig(config_set)->str());
737 string params =
"universe=4 persist=false";
738 cfg_db->setAppendedParameters(params);
739 cfg_db->createManagers();
740 }
catch (
const std::exception& ex) {
746 std::ostringstream err;
756 }
catch (
const std::exception& ex) {
757 err <<
"Error setting packet queue controls after server reconfiguration: "
776 server.discardPackets();
777 server.getCBControl()->reset();
781 string parameter_name;
790 mutable_cfg = boost::const_pointer_cast<Element>(config_set);
794 parameter_name =
"interfaces-config";
798 parser.
parse(cfg_iface, ifaces_config);
802 .arg(parameter_name).arg(ex.what());
809 " processing error");
869 bool multi_threading_enabled =
true;
870 uint32_t thread_count = 0;
871 uint32_t queue_size = 0;
873 multi_threading_enabled, thread_count, queue_size);
874 libraries.loadLibraries(multi_threading_enabled);
892 server.getCBControl()->databaseConfigFetch(srv_config,
895 std::ostringstream err;
896 err <<
"during update from config backend database: " << ex.what();
902 std::ostringstream err;
903 err <<
"during update from config backend database: "
904 <<
"undefined configuration parsing error";
919 if (notify_libraries) {
920 return (notify_libraries);
927 }
catch (
const std::exception& ex) {
928 std::ostringstream err;
929 err <<
"Error initializing hooks: "
A generic exception that is thrown if a parameter given to a method is considered invalid in that con...
This is a base class for exceptions thrown from the DNS library module.
static IOServiceMgr & instance()
Access the IOServiceMgr singleton instance.
static std::string getHash(const isc::data::ConstElementPtr &config)
returns a hash of a given Element structure
static CommandMgr & instance()
CommandMgr is a singleton class.
static ElementPtr create(const Position &pos=ZERO_POSITION())
static ElementPtr createMap(const Position &pos=ZERO_POSITION())
Creates an empty MapElement type ElementPtr.
Parse Database Parameters.
void parse(std::string &access_string, isc::data::ConstElementPtr database_config)
Parse configuration value.
static CfgMgr & instance()
returns a single instance of Configuration Manager
static void extract(data::ConstElementPtr value, bool &enabled, uint32_t &thread_count, uint32_t &queue_size)
Extract multi-threading parameters from a given configuration.
Parser for a list of client class definitions.
ClientClassDictionaryPtr parse(isc::data::ConstElementPtr class_def_list, uint16_t family, bool check_dependencies=true)
Parse configuration entries.
void parse(isc::data::ConstElementPtr cfg, isc::dhcp::SrvConfig &srv_cfg)
Parse compatibility flags.
Parser for the control-socket structure.
void parse(SrvConfig &srv_cfg, isc::data::ConstElementPtr value)
"Parses" control-socket structure
static isc::data::ConstElementPtr finishConfigHookLibraries(isc::data::ConstElementPtr config)
Configuration checker for hook libraries.
Parser for D2ClientConfig.
D2ClientConfigPtr parse(isc::data::ConstElementPtr d2_client_cfg)
Parses a given dhcp-ddns element into D2ClientConfig.
static size_t setAllDefaults(isc::data::ConstElementPtr d2_config)
Sets all defaults for D2 client configuration.
Acts as a storage vault for D2 client configuration.
Parser for the configuration of DHCP packet queue controls.
data::ElementPtr parse(const isc::data::ConstElementPtr &control_elem, bool multi_threading_enabled)
Parses content of the "dhcp-queue-control".
To be removed. Please use ConfigError instead.
Parser for the configuration parameters pertaining to the processing of expired leases.
void parse(isc::data::ConstElementPtr expiration_config, isc::dhcp::CfgExpirationPtr expiration)
Parses parameters in the JSON map, pertaining to the processing of the expired leases.
static void printRegistered()
Prints out all registered backends.
Parser for a list of host identifiers for DHCPv4.
void parse(isc::data::ConstElementPtr ids_list)
Parses a list of host identifiers.
static IfaceMgr & instance()
IfaceMgr is a singleton class.
Parser for the configuration of interfaces.
void parse(const CfgIfacePtr &config, const isc::data::ConstElementPtr &values)
Parses content of the "interfaces-config".
static void setRuntimeOptionDefs(const OptionDefSpaceContainer &defs)
Copies option definitions created at runtime.
static void revertRuntimeOptionDefs()
Reverts uncommitted changes to runtime option definitions.
Simple parser for multi-threading structure.
void parse(SrvConfig &srv_cfg, const isc::data::ConstElementPtr &value)
parses JSON structure.
Parser for option data values within a subnet.
void parse(const CfgOptionPtr &cfg, isc::data::ConstElementPtr option_data_list, bool encapsulate=true)
Parses a list of options, instantiates them and stores in cfg.
Parser for a list of option definitions.
void parse(CfgOptionDefPtr cfg, isc::data::ConstElementPtr def_list)
Parses a list of option definitions, create them and store in cfg.
Class of option definition space container.
Simple parser for sanity-checks structure.
void parse(SrvConfig &srv_cfg, const isc::data::ConstElementPtr &value)
parses JSON structure
static size_t deriveParameters(isc::data::ElementPtr global)
Derives (inherits) all parameters from global to more specific scopes.
static size_t setAllDefaults(isc::data::ElementPtr global)
Sets all defaults for DHCPv4 configuration.
static const uint32_t CFGSEL_ALL4
IPv4 related config.
this class parses list of DHCP4 subnets
size_t parse(SrvConfigPtr cfg, data::ConstElementPtr subnets_list, bool encapsulate_options=true)
parses contents of the list
static const TimerMgrPtr & instance()
Returns pointer to the sole instance of the TimerMgr.
Wrapper class that holds hooks libraries configuration.
void verifyLibraries(const isc::data::Element::Position &position, bool multi_threading_enabled) const
Verifies that libraries stored in libraries_ are valid.
Parser for hooks library list.
static bool unloadLibraries()
Unload libraries.
static void prepareUnloadLibraries()
Prepare the unloading of libraries.
Implements parser for config control information, "config-control".
ConfigControlInfoPtr parse(const data::ConstElementPtr &config_control)
Parses a configuration control Element.
static MultiThreadingMgr & instance()
Returns a single instance of Multi Threading Manager.
Parsers for client class definitions.
This file contains several functions and constants that are used for handling commands and responses ...
Contains declarations for loggers used by the DHCPv4 server component.
#define isc_throw(type, stream)
A shortcut macro to insert known values into exception arguments.
#define LOG_ERROR(LOGGER, MESSAGE)
Macro to conveniently test error output and log it.
#define LOG_INFO(LOGGER, MESSAGE)
Macro to conveniently test info output and log it.
#define LOG_WARN(LOGGER, MESSAGE)
Macro to conveniently test warn output and log it.
#define LOG_DEBUG(LOGGER, LEVEL, MESSAGE)
Macro to conveniently test debug output and log it.
const int CONTROL_RESULT_ERROR
Status code indicating a general failure.
ConstElementPtr createAnswer()
Creates a standard config/command level success answer message (i.e.
ConstElementPtr parseAnswer(int &rcode, const ConstElementPtr &msg)
const int CONTROL_RESULT_SUCCESS
Status code indicating a successful operation.
boost::shared_ptr< const Element > ConstElementPtr
boost::shared_ptr< Element > ElementPtr
void configureCommandChannel()
Initialize the command channel based on the staging configuration.
const isc::log::MessageID DHCP4_CONFIG_START
boost::shared_ptr< D2ClientConfig > D2ClientConfigPtr
Defines a pointer for D2ClientConfig instances.
const isc::log::MessageID DHCP4_PARSER_EXCEPTION
boost::shared_ptr< CfgOption > CfgOptionPtr
Non-const pointer.
SharedNetworksListParser< SharedNetwork4Parser > SharedNetworks4ListParser
Type of the shared networks list parser for IPv4.
boost::shared_ptr< CfgOptionDef > CfgOptionDefPtr
Non-const pointer.
boost::shared_ptr< CfgDbAccess > CfgDbAccessPtr
A pointer to the CfgDbAccess.
const isc::log::MessageID DHCP4_RESERVATIONS_LOOKUP_FIRST_ENABLED
isc::data::ConstElementPtr processDhcp4Config(isc::data::ConstElementPtr config_set)
Process a DHCPv4 confguration and return an answer stating if the configuration is valid,...
boost::shared_ptr< CfgIface > CfgIfacePtr
A pointer to the CfgIface .
const isc::log::MessageID DHCP4_CONFIG_PACKET_QUEUE
const isc::log::MessageID DHCP4_PARSER_COMMIT_EXCEPTION
boost::shared_ptr< SrvConfig > SrvConfigPtr
Non-const pointer to the SrvConfig.
const isc::log::MessageID DHCP4_PARSER_FAIL
std::vector< HostPtr > HostCollection
Collection of the Host objects.
boost::multi_index_container< Subnet4Ptr, boost::multi_index::indexed_by< boost::multi_index::ordered_unique< boost::multi_index::tag< SubnetSubnetIdIndexTag >, boost::multi_index::const_mem_fun< Subnet, SubnetID, &Subnet::getID > >, boost::multi_index::ordered_unique< boost::multi_index::tag< SubnetPrefixIndexTag >, boost::multi_index::const_mem_fun< Subnet, std::string, &Subnet::toText > > > > Subnet4SimpleCollection
A simple collection of Subnet4 objects.
const int DBG_DHCP4_COMMAND
Debug level used to log receiving commands.
const isc::log::MessageID DHCP4_PARSER_COMMIT_FAIL
boost::shared_ptr< ClientClassDictionary > ClientClassDictionaryPtr
Defines a pointer to a ClientClassDictionary.
isc::data::ConstElementPtr configureDhcp4Server(Dhcpv4Srv &server, isc::data::ConstElementPtr config_set, bool check_only, bool extra_checks)
Configure DHCPv4 server (Dhcpv4Srv) with a set of configuration values.
boost::shared_ptr< CfgSubnets4 > CfgSubnets4Ptr
Non-const pointer.
const isc::log::MessageID DHCP4_CONFIG_COMPLETE
boost::multi_index_container< SharedNetwork4Ptr, boost::multi_index::indexed_by< boost::multi_index::random_access< boost::multi_index::tag< SharedNetworkRandomAccessIndexTag > >, boost::multi_index::hashed_non_unique< boost::multi_index::tag< SharedNetworkIdIndexTag >, boost::multi_index::const_mem_fun< data::BaseStampedElement, uint64_t, &data::BaseStampedElement::getId > >, boost::multi_index::ordered_unique< boost::multi_index::tag< SharedNetworkNameIndexTag >, boost::multi_index::const_mem_fun< SharedNetwork4, std::string, &SharedNetwork4::getName > >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< SharedNetworkServerIdIndexTag >, boost::multi_index::const_mem_fun< Network4, asiolink::IOAddress, &Network4::getServerId > >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< SharedNetworkModificationTimeIndexTag >, boost::multi_index::const_mem_fun< data::BaseStampedElement, boost::posix_time::ptime, &data::BaseStampedElement::getModificationTime > > > > SharedNetwork4Collection
Multi index container holding shared networks.
boost::shared_ptr< CfgSharedNetworks4 > CfgSharedNetworks4Ptr
Pointer to the configuration of IPv4 shared networks.
isc::log::Logger dhcp4_logger(DHCP4_APP_LOGGER_NAME)
Base logger for DHCPv4 server.
boost::shared_ptr< ConfigControlInfo > ConfigControlInfoPtr
Defines a pointer to a ConfigControlInfo.
Defines the logger used by the top-level component of kea-lfc.