15#include <boost/foreach.hpp>
26 int hook_index_cb6_updated_;
48 const boost::posix_time::ptime& lb_modification_time,
50 bool globals_fetched =
false;
51 auto reconfig = audit_entries.empty();
52 auto cb_update = !reconfig;
69 auto range = index.equal_range(boost::make_tuple(
"dhcp6_global_parameter",
70 AuditEntry::ModificationType::DELETE));
71 if (range.first != range.second) {
79 globals =
getMgr().getPool()->getAllGlobalParameters6(backend_selector, server_selector);
86 external_cfg->sanityChecksLifetime(
"preferred-lifetime");
87 external_cfg->sanityChecksLifetime(
"valid-lifetime");
91 current_cfg->clearConfiguredGlobals();
93 globals_fetched =
true;
100 range = index.equal_range(boost::make_tuple(
"dhcp6_option_def",
101 AuditEntry::ModificationType::DELETE));
102 BOOST_FOREACH(
auto const& entry, range) {
103 current_cfg->getCfgOptionDef()->del(entry->getObjectId());
108 range = index.equal_range(boost::make_tuple(
"dhcp6_options",
109 AuditEntry::ModificationType::DELETE));
110 BOOST_FOREACH(
auto const& entry, range) {
111 current_cfg->getCfgOption()->del(entry->getObjectId());
114 range = index.equal_range(boost::make_tuple(
"dhcp6_client_class",
115 AuditEntry::ModificationType::DELETE));
116 BOOST_FOREACH(
auto const& entry, range) {
117 current_cfg->getClientClassDictionary()->removeClass(entry->getObjectId());
120 range = index.equal_range(boost::make_tuple(
"dhcp6_shared_network",
121 AuditEntry::ModificationType::DELETE));
122 BOOST_FOREACH(
auto const& entry, range) {
123 current_cfg->getCfgSharedNetworks6()->del(entry->getObjectId());
126 range = index.equal_range(boost::make_tuple(
"dhcp6_subnet",
127 AuditEntry::ModificationType::DELETE));
128 BOOST_FOREACH(
auto const& entry, range) {
132 auto subnet = current_cfg->getCfgSubnets6()->getBySubnetId(entry->getObjectId());
136 subnet->getSharedNetwork(network);
139 network->del(subnet->getID());
142 current_cfg->getCfgSubnets6()->del(entry->getObjectId());
159 if (!globals_fetched) {
163 if (reconfig || !updated_entries.empty()) {
165 globals =
getMgr().getPool()->getModifiedGlobalParameters6(backend_selector, server_selector,
166 lb_modification_time);
168 globals_fetched =
true;
176 if (reconfig || !updated_entries.empty()) {
178 getMgr().getPool()->getModifiedOptionDefs6(backend_selector, server_selector,
179 lb_modification_time);
180 for (
auto const& option_def : option_defs) {
181 if (!audit_entries.empty() && !
hasObjectId(updated_entries, option_def->getId())) {
184 external_cfg->getCfgOptionDef()->add(option_def);
192 if (reconfig || !updated_entries.empty()) {
195 lb_modification_time);
196 for (
auto const& option : options) {
197 if (!audit_entries.empty() && !
hasObjectId(updated_entries, option.getId())) {
200 external_cfg->getCfgOption()->add(option, option.space_name_);
208 if (reconfig || !updated_entries.empty()) {
216 client_classes.
createOptions(external_cfg->getCfgOptionDef());
218 external_cfg->setClientClassDictionary(boost::make_shared<ClientClassDictionary>(client_classes));
224 std::string global_allocator;
227 global_allocator = allocator->stringValue();
231 std::string global_pd_allocator;
234 global_pd_allocator = allocator->stringValue();
240 auto allocator_changed =
false;
246 allocator_changed = (global_allocator != allocator->stringValue());
251 if (!allocator_changed) {
254 allocator_changed = (global_pd_allocator != allocator->stringValue());
264 if (allocator_changed || reconfig) {
267 networks =
getMgr().getPool()->getAllSharedNetworks6(backend_selector, server_selector);
268 }
else if (!updated_entries.empty()) {
269 networks =
getMgr().getPool()->getModifiedSharedNetworks6(backend_selector, server_selector,
270 lb_modification_time);
272 for (
auto const& network : networks) {
273 if (!allocator_changed && cb_update && !
hasObjectId(updated_entries, network->getId())) {
282 network->setDefaultAllocatorType(global_allocator);
283 network->setDefaultPdAllocatorType(global_pd_allocator);
284 external_cfg->getCfgSharedNetworks6()->add(network);
292 if (allocator_changed || reconfig) {
295 subnets =
getMgr().getPool()->getAllSubnets6(backend_selector, server_selector);
297 }
else if (!updated_entries.empty()) {
300 subnets =
getMgr().getPool()->getModifiedSubnets6(backend_selector,
302 lb_modification_time);
305 for (
auto const& subnet : subnets) {
306 if (!audit_entries.empty() && !
hasObjectId(updated_entries, subnet->getID())) {
315 subnet->setDefaultAllocatorType(global_allocator);
316 subnet->setDefaultPdAllocatorType(global_pd_allocator);
317 external_cfg->getCfgSubnets6()->add(subnet);
325 external_cfg->sanityChecksLifetime(*cfg,
"preferred-lifetime");
326 external_cfg->sanityChecksLifetime(*cfg,
"valid-lifetime");
330 if (globals_fetched) {
333 bool ip_unique =
true;
334 auto ip_unique_param = external_cfg->getConfiguredGlobal(
"ip-reservations-unique");
336 ip_unique = ip_unique_param->boolValue();
344 external_cfg->addConfiguredGlobal(
"ip-reservations-unique",
Element::create(
true));
348 external_cfg->sanityChecksLifetime(*cfg,
"preferred-lifetime");
349 external_cfg->sanityChecksLifetime(*cfg,
"valid-lifetime");
367 callout_handle->setArgument(
"audit_entries", ptr);
static ElementPtr create(const Position &pos=ZERO_POSITION())
Server selector for associating objects in a database with specific servers.
void translateAndAddGlobalsToConfig(SrvConfigPtr external_cfg, data::StampedValueCollection &cb_globals) const
It translates the top level map parameters from flat naming format (e.g.
virtual void databaseConfigApply(const db::BackendSelector &backend_selector, const db::ServerSelector &server_selector, const boost::posix_time::ptime &lb_modification_time, const db::AuditEntryCollection &audit_entries)
DHCPv6 server specific method to fetch and apply back end configuration into the local configuration.
SrvConfigPtr createExternalCfg()
Creates an external configuration and returns pointer to it.
static CfgMgr & instance()
returns a single instance of Configuration Manager
void mergeIntoStagingCfg(const uint32_t seq)
Merges external configuration with the given sequence number into the staging configuration.
void mergeIntoCurrentCfg(const uint32_t seq)
Merges external configuration with the given sequence number into the current configuration.
SrvConfigPtr getStagingCfg()
Returns a pointer to the staging configuration.
SrvConfigPtr getCurrentCfg()
Returns a pointer to the current configuration.
Maintains a list of ClientClassDef's.
void createOptions(const CfgOptionDefPtr &cfg_option_def)
Iterates over the classes in the dictionary and recreates the options.
void initMatchExpr(uint16_t family)
Iterates over the classes in the dictionary and ensures that that match expressions are initialized.
static HostMgr & instance()
Returns a sole instance of the HostMgr.
static const isc::data::SimpleDefaults GLOBAL6_DEFAULTS
This table defines default global values for DHCPv6.
static int registerHook(const std::string &name)
Register Hook.
static bool calloutsPresent(int index)
Are callouts present?
static boost::shared_ptr< CalloutHandle > createCalloutHandle()
Return callout handle.
static void callCallouts(int index, CalloutHandle &handle)
Calls the callouts for a given hook.
Wrapper class around callout handle which automatically resets handle's state.
db::AuditEntryCollection fetchConfigElement(const db::AuditEntryCollection &audit_entries, const std::string &object_type) const
Returns audit entries for new or updated configuration elements of specific type to be fetched from t...
ConfigBackendMgrType & getMgr() const
Returns the instance of the Config Backend Manager used by this object.
#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.
boost::multi_index_container< StampedValuePtr, boost::multi_index::indexed_by< boost::multi_index::hashed_non_unique< boost::multi_index::tag< StampedValueNameIndexTag >, boost::multi_index::const_mem_fun< StampedValue, std::string, &StampedValue::getName > >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< StampedValueModificationTimeIndexTag >, boost::multi_index::const_mem_fun< BaseStampedElement, boost::posix_time::ptime, &BaseStampedElement::getModificationTime > > > > StampedValueCollection
Multi index container for StampedValue.
boost::multi_index_container< AuditEntryPtr, boost::multi_index::indexed_by< boost::multi_index::ordered_non_unique< boost::multi_index::tag< AuditEntryObjectTypeTag >, boost::multi_index::composite_key< AuditEntry, boost::multi_index::const_mem_fun< AuditEntry, std::string, &AuditEntry::getObjectType >, boost::multi_index::const_mem_fun< AuditEntry, AuditEntry::ModificationType, &AuditEntry::getModificationType > > >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< AuditEntryModificationTimeIdTag >, boost::multi_index::composite_key< AuditEntry, boost::multi_index::const_mem_fun< AuditEntry, boost::posix_time::ptime, &AuditEntry::getModificationTime >, boost::multi_index::const_mem_fun< AuditEntry, uint64_t, &AuditEntry::getRevisionId > > >, boost::multi_index::hashed_non_unique< boost::multi_index::tag< AuditEntryObjectIdTag >, boost::multi_index::const_mem_fun< AuditEntry, uint64_t, &AuditEntry::getObjectId > > > > AuditEntryCollection
Multi index container holding AuditEntry instances.
boost::shared_ptr< AuditEntryCollection > AuditEntryCollectionPtr
isc::log::Logger dhcpsrv_logger("dhcpsrv")
DHCP server library Logger.
boost::shared_ptr< const CfgGlobals > ConstCfgGlobalsPtr
Const shared pointer to a CfgGlobals instance.
boost::multi_index_container< SharedNetwork6Ptr, 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< SharedNetwork6, std::string, &SharedNetwork6::getName > >, 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 > > > > SharedNetwork6Collection
Multi index container holding shared networks.
boost::multi_index_container< Subnet6Ptr, 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 > >, boost::multi_index::ordered_non_unique< boost::multi_index::tag< SubnetModificationTimeIndexTag >, boost::multi_index::const_mem_fun< data::BaseStampedElement, boost::posix_time::ptime, &data::BaseStampedElement::getModificationTime > > > > Subnet6Collection
A collection of Subnet6 objects.
boost::shared_ptr< SrvConfig > SrvConfigPtr
Non-const pointer to the SrvConfig.
const isc::log::MessageID DHCPSRV_CFGMGR_CONFIG6_MERGED
boost::shared_ptr< SharedNetwork6 > SharedNetwork6Ptr
Pointer to SharedNetwork6 object.
boost::multi_index_container< OptionDescriptor, boost::multi_index::indexed_by< boost::multi_index::sequenced<>, boost::multi_index::hashed_non_unique< KeyFromKeyExtractor< boost::multi_index::const_mem_fun< Option, uint16_t, &Option::getType >, boost::multi_index::member< OptionDescriptor, OptionPtr, &OptionDescriptor::option_ > > >, boost::multi_index::hashed_non_unique< boost::multi_index::member< OptionDescriptor, bool, &OptionDescriptor::persistent_ > >, boost::multi_index::ordered_non_unique< boost::multi_index::const_mem_fun< data::BaseStampedElement, boost::posix_time::ptime, &data::BaseStampedElement::getModificationTime > >, boost::multi_index::hashed_non_unique< boost::multi_index::tag< OptionIdIndexTag >, boost::multi_index::const_mem_fun< data::BaseStampedElement, uint64_t, &data::BaseStampedElement::getId > >, boost::multi_index::hashed_non_unique< boost::multi_index::member< OptionDescriptor, bool, &OptionDescriptor::cancelled_ > > > > OptionContainer
Multi index container for DHCP option descriptors.
boost::multi_index_container< OptionDefinitionPtr, boost::multi_index::indexed_by< boost::multi_index::sequenced<>, boost::multi_index::hashed_non_unique< boost::multi_index::const_mem_fun< OptionDefinition, uint16_t, &OptionDefinition::getCode > >, boost::multi_index::hashed_non_unique< boost::multi_index::const_mem_fun< OptionDefinition, std::string, &OptionDefinition::getName > >, boost::multi_index::ordered_non_unique< boost::multi_index::const_mem_fun< data::BaseStampedElement, boost::posix_time::ptime, &data::StampedElement::getModificationTime > >, boost::multi_index::hashed_non_unique< boost::multi_index::tag< OptionIdIndexTag >, boost::multi_index::const_mem_fun< data::BaseStampedElement, uint64_t, &data::BaseStampedElement::getId > > > > OptionDefContainer
Multi index container for DHCP option definitions.
const isc::log::MessageID DHCPSRV_CFGMGR_IPV6_RESERVATIONS_NON_UNIQUE_IGNORED
boost::shared_ptr< CalloutHandle > CalloutHandlePtr
A shared pointer to a CalloutHandle object.
bool hasObjectId(const db::AuditEntryCollection &audit_entries, const uint64_t &object_id)
Checks if an object is in a collection od audit entries.
Defines the logger used by the top-level component of kea-lfc.
Tag used to access index by object type.