kea_dhcp4_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
kea_dhcp4_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+# to be removed
if HAVE_PGSQL
kea_dhcp4_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+kea_dhcp4_LDADD += $(top_builddir)/src/lib/pgsql_lease_backend/libkea-pgsql-lease-backend.la
+kea_dhcp4_LDADD += $(top_builddir)/src/lib/pgsql_host_backend/libkea-pgsql-host-backend.la
endif
+# to be removed
if HAVE_MYSQL
kea_dhcp4_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+kea_dhcp4_LDADD += $(top_builddir)/src/lib/mysql_lease_backend/libkea-mysql-lease-backend.la
+kea_dhcp4_LDADD += $(top_builddir)/src/lib/mysql_host_backend/libkea-mysql-host-backend.la
endif
kea_dhcp4_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
#include <log/logger.h>
#include <cryptolink/cryptolink.h>
#include <process/cfgrpt/config_report.h>
-
+#include <dhcpsrv/memfile_lease_mgr.h>
#ifdef HAVE_MYSQL
-#include <dhcpsrv/mysql_lease_mgr.h>
+#include <mysql_lease_backend/mysql_lease_mgr.h>
#endif
#ifdef HAVE_PGSQL
-#include <dhcpsrv/pgsql_lease_mgr.h>
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
#endif
-#include <dhcpsrv/memfile_lease_mgr.h>
#include <boost/algorithm/string.hpp>
#include <boost/foreach.hpp>
#include <cc/command_interpreter.h>
#include <config/command_mgr.h>
#include <config/http_command_mgr.h>
+#include <database/database_connection.h>
#include <database/dbaccess_parser.h>
#include <database/backend_selector.h>
#include <database/server_selector.h>
#include <util/encode/encode.h>
#include <util/multi_threading_mgr.h>
+#ifdef HAVE_MYSQL
+#include <mysql_lease_backend/mysql_lease_mgr.h>
+#include <mysql_host_backend/mysql_host_data_source.h>
+#endif
+
+#ifdef HAVE_PGSQL
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
+#include <pgsql_host_backend/pgsql_host_data_source.h>
+#endif
+
#include <boost/algorithm/string.hpp>
#include <boost/lexical_cast.hpp>
using namespace isc::asiolink;
using namespace isc::config;
using namespace isc::data;
+using namespace isc::db;
using namespace isc::dhcp;
using namespace isc::hooks;
using namespace isc::process;
using namespace isc;
using namespace std;
+//
+// Register database backends
+//
namespace {
+// Code will be moved to appropriate hook library.
+#ifdef HAVE_MYSQL
+// Database backend will be registered at object initialization
+MySqlLeaseMgrInit mysql_init_lease;
+MySqlHostDataSourceInit mysql_init_host;
+#endif
+
+// Code will be moved to appropriate hook library.
+#ifdef HAVE_PGSQL
+// Database backend will be registered at object initialization
+PgSqlLeaseMgrInit pgsql_init_lease;
+PgSqlHostDataSourceInit pgsql_init_host;
+#endif
+
/// @brief Parser that takes care of global DHCPv4 parameters and utility
/// functions that work on global level.
///
DISTCLEANFILES += test_libraries.h
AM_CPPFLAGS = -I$(top_srcdir)/src/lib -I$(top_builddir)/src/lib
-AM_CPPFLAGS += -I$(top_srcdir)/src -I$(top_builddir)/src
AM_CPPFLAGS += -I$(top_srcdir)/src/bin -I$(top_builddir)/src/bin
+AM_CPPFLAGS += -I$(top_srcdir)/src -I$(top_builddir)/src
+
AM_CPPFLAGS += $(BOOST_INCLUDES) $(CRYPTO_CFLAGS) $(CRYPTO_INCLUDES)
AM_CPPFLAGS += -DTEST_DATA_BUILDDIR=\"$(abs_top_builddir)/src/bin/dhcp4/tests\"
AM_CPPFLAGS += -DINSTALL_PROG=\"$(abs_top_srcdir)/install-sh\"
# C++ tests
PROGRAM_TESTS = dhcp4_unittests
-dhcp4_unittests_SOURCES = d2_unittest.h d2_unittest.cc
-dhcp4_unittests_SOURCES += dhcp4_unittests.cc
+# This list is ordered alphabetically. When adding new files, please maintain
+# this order.
+dhcp4_unittests_SOURCES = classify_unittest.cc
+dhcp4_unittests_SOURCES += client_handler_unittest.cc
+dhcp4_unittests_SOURCES += config_parser_unittest.cc
+dhcp4_unittests_SOURCES += config_backend_unittest.cc
+dhcp4_unittests_SOURCES += ctrl_dhcp4_srv_unittest.cc
+dhcp4_unittests_SOURCES += http_control_socket_unittest.cc
+dhcp4_unittests_SOURCES += d2_unittest.h d2_unittest.cc
+dhcp4_unittests_SOURCES += decline_unittest.cc
+dhcp4_unittests_SOURCES += dhcp4_client.cc dhcp4_client.h
dhcp4_unittests_SOURCES += dhcp4_srv_unittest.cc
dhcp4_unittests_SOURCES += dhcp4_test_utils.cc dhcp4_test_utils.h
+dhcp4_unittests_SOURCES += dhcp4_unittests.cc
+dhcp4_unittests_SOURCES += dhcp4to6_ipc_unittest.cc
dhcp4_unittests_SOURCES += direct_client_unittest.cc
-dhcp4_unittests_SOURCES += ctrl_dhcp4_srv_unittest.cc
-dhcp4_unittests_SOURCES += http_control_socket_unittest.cc
-dhcp4_unittests_SOURCES += classify_unittest.cc
-dhcp4_unittests_SOURCES += config_backend_unittest.cc
-dhcp4_unittests_SOURCES += config_parser_unittest.cc
+dhcp4_unittests_SOURCES += dora_unittest.cc
dhcp4_unittests_SOURCES += fqdn_unittest.cc
-dhcp4_unittests_SOURCES += marker_file.cc
-dhcp4_unittests_SOURCES += dhcp4_client.cc dhcp4_client.h
+dhcp4_unittests_SOURCES += get_config_unittest.cc get_config_unittest.h
dhcp4_unittests_SOURCES += hooks_unittest.cc
-dhcp4_unittests_SOURCES += inform_unittest.cc
-dhcp4_unittests_SOURCES += dora_unittest.cc
dhcp4_unittests_SOURCES += host_options_unittest.cc
-dhcp4_unittests_SOURCES += release_unittest.cc
-dhcp4_unittests_SOURCES += parser_unittest.cc
-dhcp4_unittests_SOURCES += out_of_range_unittest.cc
-dhcp4_unittests_SOURCES += decline_unittest.cc
+dhcp4_unittests_SOURCES += host_unittest.cc
+dhcp4_unittests_SOURCES += inform_unittest.cc
dhcp4_unittests_SOURCES += kea_controller_unittest.cc
-dhcp4_unittests_SOURCES += dhcp4to6_ipc_unittest.cc
+dhcp4_unittests_SOURCES += marker_file.cc
+dhcp4_unittests_SOURCES += out_of_range_unittest.cc
+dhcp4_unittests_SOURCES += parser_unittest.cc
+dhcp4_unittests_SOURCES += release_unittest.cc
+
dhcp4_unittests_SOURCES += simple_parser4_unittest.cc
-dhcp4_unittests_SOURCES += get_config_unittest.cc get_config_unittest.h
dhcp4_unittests_SOURCES += shared_network_unittest.cc
-dhcp4_unittests_SOURCES += host_unittest.cc
dhcp4_unittests_SOURCES += vendor_opts_unittest.cc
-dhcp4_unittests_SOURCES += client_handler_unittest.cc
nodist_dhcp4_unittests_SOURCES = marker_file.h test_libraries.h
if HAVE_PGSQL
dhcp4_unittests_LDADD += $(top_builddir)/src/lib/pgsql/testutils/libpgsqltest.la
dhcp4_unittests_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+dhcp4_unittests_LDADD += $(top_builddir)/src/lib/pgsql_lease_backend/libkea-pgsql-lease-backend.la
+dhcp4_unittests_LDADD += $(top_builddir)/src/lib/pgsql_host_backend/libkea-pgsql-host-backend.la
endif
if HAVE_MYSQL
dhcp4_unittests_LDADD += $(top_builddir)/src/lib/mysql/testutils/libmysqltest.la
dhcp4_unittests_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+dhcp4_unittests_LDADD += $(top_builddir)/src/lib/mysql_lease_backend/libkea-mysql-lease-backend.la
+dhcp4_unittests_LDADD += $(top_builddir)/src/lib/mysql_host_backend/libkea-mysql-host-backend.la
endif
dhcp4_unittests_LDADD += $(top_builddir)/src/lib/database/testutils/libdatabasetest.la
// Verify that updates are disabled and we are no longer sending.
ASSERT_FALSE(mgr.ddnsEnabled());
ASSERT_FALSE(mgr.amSending());
+ mgr.clearQueue();
}
// Tests invalid config with TCP protocol
NameDhcpv4SrvTest()
: Dhcpv4SrvTest(),
d2_mgr_(CfgMgr::instance().getD2ClientMgr()),
- iface_mgr_test_config_(true)
- {
+ iface_mgr_test_config_(true) {
srv_ = boost::make_shared<NakedDhcpv4Srv>(0);
IfaceMgr::instance().openSockets4();
// Config DDNS to be enabled, all controls off
/// @param client_flags Mask of client FQDN flags which are true
/// @param response_flags Mask of expected FQDN flags in the response
void flagVsConfigScenario(const uint8_t client_flags,
- const uint8_t response_flags) {
+ const uint8_t response_flags) {
// Create fake interfaces and open fake sockets.
IfaceMgrTestConfig iface_config(true);
IfaceMgr::instance().openSockets4();
}
}
-
/// @brief Checks the value of an integer statistic for a given subnet.
///
/// @param subnet_id identifier of a subnet for which the statistic should be checked
lease->cltt_, 100, false, NO_CHECK_WITH_DHCID);
}
-
// Verifies that createNameChange request only generates requests
// if the situation dictates that it should. It checks:
//
EXPECT_EQ(Option4ClientFqdn::FULL, fqdn->getDomainNameType());
}
-
// Test that server generates client's hostname from the IP address assigned
// to it when Hostname option carries the top level domain-name.
TEST_F(NameDhcpv4SrvTest, processRequestTopLevelHostname) {
}
}
-
// Verifies that setting hostname-char-set sanitizes Hostname option
// values received from clients.
TEST_F(NameDhcpv4SrvTest, sanitizeHost) {
AM_LDFLAGS = -static
endif
+CLEANFILES = *.gcno *.gcda
+
EXTRA_DIST = dhcp6.dox dhcp6_hooks.dox dhcp4o6.dox
EXTRA_DIST += dhcp6_parser.yy
-
# convenience archive
noinst_LTLIBRARIES = libdhcp6.la
libdhcp6_la_SOURCES =
-libdhcp6_la_SOURCES += dhcp6_log.cc dhcp6_log.h
-libdhcp6_la_SOURCES += dhcp6_srv.cc dhcp6_srv.h
libdhcp6_la_SOURCES += ctrl_dhcp6_srv.cc ctrl_dhcp6_srv.h
libdhcp6_la_SOURCES += json_config_parser.cc json_config_parser.h
+libdhcp6_la_SOURCES += dhcp6_log.cc dhcp6_log.h
+libdhcp6_la_SOURCES += dhcp6_srv.cc dhcp6_srv.h
libdhcp6_la_SOURCES += dhcp6to4_ipc.cc dhcp6to4_ipc.h
libdhcp6_la_SOURCES += client_handler.cc client_handler.h
libdhcp6_la_SOURCES += dhcp6_lexer.ll location.hh
kea_dhcp6_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
kea_dhcp6_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+# to be removed
if HAVE_PGSQL
kea_dhcp6_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+kea_dhcp6_LDADD += $(top_builddir)/src/lib/pgsql_lease_backend/libkea-pgsql-lease-backend.la
+kea_dhcp6_LDADD += $(top_builddir)/src/lib/pgsql_host_backend/libkea-pgsql-host-backend.la
endif
+# to be removed
if HAVE_MYSQL
kea_dhcp6_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+kea_dhcp6_LDADD += $(top_builddir)/src/lib/mysql_lease_backend/libkea-mysql-lease-backend.la
+kea_dhcp6_LDADD += $(top_builddir)/src/lib/mysql_host_backend/libkea-mysql-host-backend.la
endif
kea_dhcp6_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
#include <log/logger.h>
#include <cryptolink/cryptolink.h>
#include <process/cfgrpt/config_report.h>
+#include <dhcpsrv/memfile_lease_mgr.h>
#ifdef HAVE_MYSQL
-#include <dhcpsrv/mysql_lease_mgr.h>
+#include <mysql_lease_backend/mysql_lease_mgr.h>
#endif
#ifdef HAVE_PGSQL
-#include <dhcpsrv/pgsql_lease_mgr.h>
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
#endif
-#include <dhcpsrv/memfile_lease_mgr.h>
#include <boost/tokenizer.hpp>
#include <boost/foreach.hpp>
#include <cc/command_interpreter.h>
#include <config/command_mgr.h>
#include <config/http_command_mgr.h>
+#include <database/database_connection.h>
#include <database/dbaccess_parser.h>
#include <dhcp6/ctrl_dhcp6_srv.h>
#include <dhcp6/dhcp6_log.h>
#include <util/multi_threading_mgr.h>
#include <util/triplet.h>
+#ifdef HAVE_MYSQL
+#include <mysql_lease_backend/mysql_lease_mgr.h>
+#include <mysql_host_backend/mysql_host_data_source.h>
+#endif
+
+#ifdef HAVE_PGSQL
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
+#include <pgsql_host_backend/pgsql_host_data_source.h>
+#endif
+
#include <boost/algorithm/string.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/scoped_ptr.hpp>
using namespace isc::asiolink;
using namespace isc::config;
using namespace isc::data;
+using namespace isc::db;
using namespace isc::dhcp;
using namespace isc::hooks;
using namespace isc::process;
using namespace isc;
using namespace std;
+//
+// Register database backends
+//
namespace {
+// Code will be moved to appropriate hook library.
+#ifdef HAVE_MYSQL
+// Database backend will be registered at object initialization
+MySqlLeaseMgrInit mysql_init_lease;
+MySqlHostDataSourceInit mysql_init_host;
+#endif
+
+// Code will be moved to appropriate hook library.
+#ifdef HAVE_PGSQL
+// Database backend will be registered at object initialization
+PgSqlLeaseMgrInit pgsql_init_lease;
+PgSqlHostDataSourceInit pgsql_init_host;
+#endif
+
/// @brief Checks if specified directory exists.
///
/// @param dir_path Path to a directory.
if HAVE_PGSQL
dhcp6_unittests_LDADD += $(top_builddir)/src/lib/pgsql/testutils/libpgsqltest.la
dhcp6_unittests_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+dhcp6_unittests_LDADD += $(top_builddir)/src/lib/pgsql_lease_backend/libkea-pgsql-lease-backend.la
+dhcp6_unittests_LDADD += $(top_builddir)/src/lib/pgsql_host_backend/libkea-pgsql-host-backend.la
endif
if HAVE_MYSQL
dhcp6_unittests_LDADD += $(top_builddir)/src/lib/mysql/testutils/libmysqltest.la
dhcp6_unittests_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+dhcp6_unittests_LDADD += $(top_builddir)/src/lib/mysql_lease_backend/libkea-mysql-lease-backend.la
+dhcp6_unittests_LDADD += $(top_builddir)/src/lib/mysql_host_backend/libkea-mysql-host-backend.la
endif
dhcp6_unittests_LDADD += $(top_builddir)/src/lib/database/testutils/libdatabasetest.la
kea_lfc_LDADD += $(top_builddir)/src/lib/http/libkea-http.la
kea_lfc_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
kea_lfc_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
-
-if HAVE_PGSQL
-kea_lfc_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
-endif
-
-if HAVE_MYSQL
-kea_lfc_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
-endif
-
kea_lfc_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
kea_lfc_LDADD += $(top_builddir)/src/lib/cc/libkea-cc.la
kea_lfc_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
SUBDIRS = bootp flex_option high_availability lease_cmds perfmon
if HAVE_MYSQL
+SUBDIRS += mysql_lb
+SUBDIRS += mysql_hb
SUBDIRS += mysql_cb
endif
if HAVE_PGSQL
+SUBDIRS += pgsql_lb
+SUBDIRS += pgsql_hb
SUBDIRS += pgsql_cb
endif
}
};
+template <typename T>
+struct Initializer {
+ /// @brief Constructor.
+ Initializer() : init_(new T()) {
+ }
+
+ /// @brief Destructo.
+ ~Initializer() = default;
+
+ /// @brief smart pointer to an instance of an initializer.
+ std::unique_ptr<T> init_;
+};
+
} // namespace db
} // namespace isc
#include <dhcpsrv/hosts_log.h>
#include <log/logger_support.h>
-#ifdef HAVE_MYSQL
-#include <dhcpsrv/mysql_host_data_source.h>
-#endif
-
-#ifdef HAVE_PGSQL
-#include <dhcpsrv/pgsql_host_data_source.h>
-#endif
-
#include <boost/algorithm/string.hpp>
#include <algorithm>
} // namespace dhcp
} // namespace isc
-
-//
-// Register database backends
-//
-
-using namespace isc::dhcp;
-
-namespace {
-
-// Code will be moved to appropriate hook library.
-#ifdef HAVE_MYSQL
-struct MySqlHostDataSourceInit {
- // Constructor registers
- MySqlHostDataSourceInit() {
- HostDataSourceFactory::registerFactory("mysql", factory, true);
- }
-
- // Destructor deregisters
- ~MySqlHostDataSourceInit() {
- HostDataSourceFactory::deregisterFactory("mysql", true);
- }
-
- // Factory class method
- static HostDataSourcePtr
- factory(const DatabaseConnection::ParameterMap& parameters) {
- LOG_INFO(hosts_logger, DHCPSRV_MYSQL_HOST_DB)
- .arg(DatabaseConnection::redactedAccessString(parameters));
- return (HostDataSourcePtr(new MySqlHostDataSource(parameters)));
- }
-};
-
-// Database backend will be registered at object initialization
-MySqlHostDataSourceInit mysql_init_;
-#endif
-
-// Code will be moved to appropriate hook library.
-#ifdef HAVE_PGSQL
-struct PgSqlHostDataSourceInit {
- // Constructor registers
- PgSqlHostDataSourceInit() {
- HostDataSourceFactory::registerFactory("postgresql", factory, true);
- }
-
- // Destructor deregisters
- ~PgSqlHostDataSourceInit() {
- HostDataSourceFactory::deregisterFactory("postgresql", true);
- }
-
- // Factory class method
- static HostDataSourcePtr
- factory(const DatabaseConnection::ParameterMap& parameters) {
- LOG_INFO(hosts_logger, DHCPSRV_PGSQL_HOST_DB)
- .arg(DatabaseConnection::redactedAccessString(parameters));
- return (HostDataSourcePtr(new PgSqlHostDataSource(parameters)));
- }
-};
-
-// Database backend will be registered at object initialization
-PgSqlHostDataSourceInit pgsql_init_;
-#endif
-
-} // end of anonymous namespace
#include <dhcpsrv/dhcpsrv_log.h>
#include <dhcpsrv/lease_mgr_factory.h>
#include <dhcpsrv/memfile_lease_mgr.h>
-#ifdef HAVE_MYSQL
-#include <dhcpsrv/mysql_lease_mgr.h>
-#endif
-#ifdef HAVE_PGSQL
-#include <dhcpsrv/pgsql_lease_mgr.h>
-#endif
-
#include <boost/algorithm/string.hpp>
#include <algorithm>
"contain the 'type' keyword");
}
- // Code will be moved to appropriate hook library.
-#ifdef HAVE_MYSQL
- // Factory method
- auto mysql_factory = [](const DatabaseConnection::ParameterMap& parameters) -> TrackingLeaseMgrPtr {
- LOG_INFO(dhcpsrv_logger, DHCPSRV_MYSQL_DB)
- .arg(DatabaseConnection::redactedAccessString(parameters));
- return (TrackingLeaseMgrPtr(new MySqlLeaseMgr(parameters)));
- };
- LeaseMgrFactory::registerFactory("mysql", mysql_factory, true);
-#endif
-
- // Code will be moved to appropriate hook library.
-#ifdef HAVE_PGSQL
- // Factory method
- auto pgsql_factory = [](const DatabaseConnection::ParameterMap& parameters) -> TrackingLeaseMgrPtr {
- LOG_INFO(dhcpsrv_logger, DHCPSRV_PGSQL_DB)
- .arg(DatabaseConnection::redactedAccessString(parameters));
- return (TrackingLeaseMgrPtr(new PgSqlLeaseMgr(parameters)));
- };
- LeaseMgrFactory::registerFactory("postgresql", pgsql_factory, true);
-#endif
-
// Factory method
auto memfile_factory = [](const DatabaseConnection::ParameterMap& parameters) -> TrackingLeaseMgrPtr {
LOG_INFO(dhcpsrv_logger, DHCPSRV_MEMFILE_DB)
}
getLeaseMgrPtr().reset();
LeaseMgrFactory::deregisterFactory("memfile", true);
- // Code will be moved to appropriate hook library.
-#ifdef HAVE_MYSQL
- LeaseMgrFactory::deregisterFactory("mysql", true);
-#endif
- // Code will be moved to appropriate hook library.
-#ifdef HAVE_PGSQL
- LeaseMgrFactory::deregisterFactory("postgresql", true);
-#endif
}
void
TESTS += libdhcpsrv_unittests
libdhcpsrv_unittests_SOURCES = run_unittests.cc
-libdhcpsrv_unittests_SOURCES += alloc_engine_utils.cc alloc_engine_utils.h
libdhcpsrv_unittests_SOURCES += alloc_engine_expiration_unittest.cc
libdhcpsrv_unittests_SOURCES += alloc_engine_hooks_unittest.cc
libdhcpsrv_unittests_SOURCES += alloc_engine4_unittest.cc
libdhcpsrv_unittests_SOURCES += multi_threading_config_parser_unittest.cc
libdhcpsrv_unittests_SOURCES += dhcp_parsers_unittest.cc
libdhcpsrv_unittests_SOURCES += ncr_generator_unittest.cc
-if HAVE_MYSQL
-libdhcpsrv_unittests_SOURCES += mysql_lease_mgr_unittest.cc
-libdhcpsrv_unittests_SOURCES += mysql_lease_extended_info_unittest.cc
-libdhcpsrv_unittests_SOURCES += mysql_host_data_source_unittest.cc
-endif
-if HAVE_PGSQL
-libdhcpsrv_unittests_SOURCES += pgsql_lease_mgr_unittest.cc
-libdhcpsrv_unittests_SOURCES += pgsql_lease_extended_info_unittest.cc
-libdhcpsrv_unittests_SOURCES += pgsql_host_data_source_unittest.cc
-endif
libdhcpsrv_unittests_SOURCES += pool_unittest.cc
libdhcpsrv_unittests_SOURCES += random_allocation_state_unittest.cc
libdhcpsrv_unittests_SOURCES += random_allocator_unittest.cc
#include <dhcpsrv/shared_network.h>
#include <dhcpsrv/host_mgr.h>
#include <dhcpsrv/parsers/client_class_def_parser.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <eval/eval_context.h>
#include <hooks/hooks_manager.h>
EXPECT_EQ("10.0.1.255", lease->addr_.toText());
}
-#ifdef HAVE_MYSQL
-/// @brief Extension of the fixture class to use the MySQL backend.
-class MySqlAllocEngine4Test : public AllocEngine4Test {
-public:
- /// @brief Constructor.
- MySqlAllocEngine4Test() {
- // Ensure we have the proper schema with no transient data.
- db::test::createMySQLSchema();
- factory_.create(db::test::validMySQLConnectionString());
- }
-
- /// @brief Destructor.
- ~MySqlAllocEngine4Test() {
- // If data wipe enabled, delete transient data otherwise destroy
- // the schema.
- db::test::destroyMySQLSchema();
- LeaseMgrFactory::destroy();
- }
-};
-
-// This test checks that simple allocation handles BOOTP queries.
-TEST_F(MySqlAllocEngine4Test, bootpAlloc4) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Check that we got a lease
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // Check that the lease is indeed in LeaseMgr
- Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- ASSERT_TRUE(from_mgr);
- // The MySQL database does not keep the hwtype for DHCPv4 leases.
- from_mgr->hwaddr_->htype_ = HTYPE_FDDI;
-
- // Now check that the lease in LeaseMgr has the same parameters
- detailCompareLease(lease, from_mgr);
-}
-
-// This test checks simple renewal handles BOOTP queries.
-TEST_F(MySqlAllocEngine4Test, bootpRenew4) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
-
- // Check that we got a lease.
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Do it again, this should amount to the renew of an existing lease
- Lease4Ptr lease2 = engine->allocateLease4(ctx);
-
- // Check that we got a lease.
- ASSERT_TRUE(lease2);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease2->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease2->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease2->addr_));
- ASSERT_TRUE(lease2->client_id_);
- EXPECT_TRUE(*lease2->client_id_ == *clientid_);
- ASSERT_TRUE(lease2->hwaddr_);
- EXPECT_TRUE(*lease2->hwaddr_ == *hwaddr_);
-
- // Lease already existed, so old_lease should be set.
- EXPECT_TRUE(ctx.old_lease_);
-
- // Check the renewed valid lifetime has the max value.
- EXPECT_EQ(infinity_lft, lease2->valid_lft_);
-}
-
-// This test checks that deleteRelease handles BOOTP leases.
-TEST_F(MySqlAllocEngine4Test, bootpDelete) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Check that we got a lease
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // Check that the lease is indeed in LeaseMgr
- Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- ASSERT_TRUE(from_mgr);
-
- // Now delete it.
- bool deleted = false;
- ASSERT_NO_THROW(deleted = LeaseMgrFactory::instance().deleteLease(lease));
- EXPECT_TRUE(deleted);
- from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- EXPECT_FALSE(from_mgr);
-}
-#endif
-
-#ifdef HAVE_PGSQL
-/// @brief Extension of the fixture class to use the PostgreSql backend.
-class PgSqlAllocEngine4Test : public AllocEngine4Test {
-public:
- /// @brief Constructor.
- PgSqlAllocEngine4Test() {
- // Ensure we have the proper schema with no transient data.
- db::test::createPgSQLSchema();
- factory_.create(db::test::validPgSQLConnectionString());
- }
-
- /// @brief Destructor.
- ~PgSqlAllocEngine4Test() {
- // If data wipe enabled, delete transient data otherwise destroy
- // the schema.
- db::test::destroyPgSQLSchema();
- LeaseMgrFactory::destroy();
- }
-};
-
-// This test checks that simple allocation handles BOOTP queries.
-TEST_F(PgSqlAllocEngine4Test, bootpAlloc4) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Check that we got a lease
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // Check that the lease is indeed in LeaseMgr
- Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- ASSERT_TRUE(from_mgr);
- // The PostgreSql database does not keep the hwtype for DHCPv4 leases.
- from_mgr->hwaddr_->htype_ = HTYPE_FDDI;
-
- // Now check that the lease in LeaseMgr has the same parameters
- detailCompareLease(lease, from_mgr);
-}
-
-// This test checks simple renewal handles BOOTP queries.
-TEST_F(PgSqlAllocEngine4Test, bootpRenew4) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
-
- // Check that we got a lease.
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Do it again, this should amount to the renew of an existing lease
- Lease4Ptr lease2 = engine->allocateLease4(ctx);
-
- // Check that we got a lease.
- ASSERT_TRUE(lease2);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease2->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease2->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease2->addr_));
- ASSERT_TRUE(lease2->client_id_);
- EXPECT_TRUE(*lease2->client_id_ == *clientid_);
- ASSERT_TRUE(lease2->hwaddr_);
- EXPECT_TRUE(*lease2->hwaddr_ == *hwaddr_);
-
- // Lease already existed, so old_lease should be set.
- EXPECT_TRUE(ctx.old_lease_);
-
- // Check the renewed valid lifetime has the max value.
- EXPECT_EQ(infinity_lft, lease2->valid_lft_);
-}
-
-// This test checks that deleteRelease handles BOOTP leases.
-TEST_F(PgSqlAllocEngine4Test, bootpDelete) {
- boost::scoped_ptr<AllocEngine> engine;
- ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
- ASSERT_TRUE(engine);
-
- AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
- false, true, "somehost.example.com.", false);
- subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
- ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
-
- // Make the query a BOOTP one.
- ctx.query_->addClass("BOOTP");
-
- Lease4Ptr lease = engine->allocateLease4(ctx);
- // The new lease has been allocated, so the old lease should not exist.
- ASSERT_FALSE(ctx.old_lease_);
-
- // Check that we got a lease
- ASSERT_TRUE(lease);
-
- // Check that is belongs to the right subnet and client.
- EXPECT_EQ(lease->subnet_id_, subnet_->getID());
- EXPECT_TRUE(subnet_->inRange(lease->addr_));
- EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
- ASSERT_TRUE(lease->client_id_);
- EXPECT_TRUE(*lease->client_id_ == *clientid_);
- ASSERT_TRUE(lease->hwaddr_);
- EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
-
- // Check the valid lifetime is infinite.
- uint32_t infinity_lft = Lease::INFINITY_LFT;
- EXPECT_EQ(infinity_lft, lease->valid_lft_);
-
- // Check that the lease is indeed in LeaseMgr
- Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- ASSERT_TRUE(from_mgr);
-
- // Now delete it.
- bool deleted = false;
- ASSERT_NO_THROW(deleted = LeaseMgrFactory::instance().deleteLease(lease));
- EXPECT_TRUE(deleted);
- from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
- EXPECT_FALSE(from_mgr);
-}
-#endif
-
// Verifies that offer_lft is non-zero, that an offered lease is stored
// in the lease database.
TEST_F(AllocEngine4Test, discoverOfferLft) {
#include <config.h>
#include <dhcp/pkt4.h>
#include <dhcp/pkt6.h>
+#include <dhcpsrv/allocator.h>
#include <dhcpsrv/host_mgr.h>
#include <dhcpsrv/parsers/client_class_def_parser.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
-#include <dhcpsrv/allocator.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <eval/eval_context.h>
#include <stats/stats_mgr.h>
#include <dhcp/duid.h>
#include <dhcp/option_data_types.h>
#include <dhcp_ddns/ncr_msg.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <hooks/hooks_manager.h>
#include <stats/stats_mgr.h>
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
#include <config.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <hooks/server_hooks.h>
});
}
-// The following tests require MySQL enabled.
-#if defined HAVE_MYSQL
-
-/// @brief Test fixture class for testing @ref CfgDbAccessTest using MySQL
-/// backend.
-class CfgMySQLDbAccessTest : public ::testing::Test {
-public:
-
- /// @brief Constructor.
- CfgMySQLDbAccessTest() {
- // Ensure we have the proper schema with no transient data.
- db::test::createMySQLSchema();
- }
-
- /// @brief Destructor.
- virtual ~CfgMySQLDbAccessTest() {
- // If data wipe enabled, delete transient data otherwise destroy the schema
- db::test::destroyMySQLSchema();
- LeaseMgrFactory::destroy();
- }
-};
-
-
-// Tests that MySQL lease manager and host data source can be created from a
-// specified configuration.
-TEST_F(CfgMySQLDbAccessTest, createManagers) {
- CfgDbAccess cfg;
- ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validMySQLConnectionString()));
- ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validMySQLConnectionString()));
- ASSERT_NO_THROW(cfg.createManagers());
-
- ASSERT_NO_THROW({
- LeaseMgr& lease_mgr = LeaseMgrFactory::instance();
- EXPECT_EQ("mysql", lease_mgr.getType());
- });
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("mysql", host_data_source->getType());
- });
-
- // Because of the lazy initialization of the HostMgr instance, it is
- // possible that the first call to the instance() function tosses
- // existing connection to the database created by the call to
- // createManagers(). Let's make sure that this doesn't happen.
- ASSERT_NO_THROW(HostMgr::instance());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("mysql", host_data_source->getType());
- });
-
- EXPECT_TRUE(HostMgr::instance().getIPReservationsUnique());
-}
-
-// Tests that the createManagers function utilizes the setting in the
-// CfgDbAccess class which controls whether the IP reservations must
-// be unique or can be non-unique.
-TEST_F(CfgMySQLDbAccessTest, createManagersIPResrvUnique) {
- CfgDbAccess cfg;
-
- cfg.setIPReservationsUnique(false);
-
- ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validMySQLConnectionString()));
- ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validMySQLConnectionString()));
- ASSERT_NO_THROW(cfg.createManagers());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("mysql", host_data_source->getType());
- });
-
- // Because of the lazy initialization of the HostMgr instance, it is
- // possible that the first call to the instance() function tosses
- // existing connection to the database created by the call to
- // createManagers(). Let's make sure that this doesn't happen.
- ASSERT_NO_THROW(HostMgr::instance());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("mysql", host_data_source->getType());
- });
-
- EXPECT_FALSE(HostMgr::instance().getIPReservationsUnique());
-}
-
-#endif
-
-// The following tests require PgSQL enabled.
-#if defined HAVE_PGSQL
-
-/// @brief Test fixture class for testing @ref CfgDbAccessTest using PgSQL
-/// backend.
-class CfgPgSQLDbAccessTest : public ::testing::Test {
-public:
-
- /// @brief Constructor.
- CfgPgSQLDbAccessTest() {
- // Ensure we have the proper schema with no transient data.
- db::test::createPgSQLSchema();
- }
-
- /// @brief Destructor.
- virtual ~CfgPgSQLDbAccessTest() {
- // If data wipe enabled, delete transient data otherwise destroy the schema
- db::test::destroyPgSQLSchema();
- LeaseMgrFactory::destroy();
- }
-};
-
-
-// Tests that PgSQL lease manager and host data source can be created from a
-// specified configuration.
-TEST_F(CfgPgSQLDbAccessTest, createManagers) {
- CfgDbAccess cfg;
- ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validPgSQLConnectionString()));
- ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validPgSQLConnectionString()));
- ASSERT_NO_THROW(cfg.createManagers());
-
- ASSERT_NO_THROW({
- LeaseMgr& lease_mgr = LeaseMgrFactory::instance();
- EXPECT_EQ("postgresql", lease_mgr.getType());
- });
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("postgresql", host_data_source->getType());
- });
-
- // Because of the lazy initialization of the HostMgr instance, it is
- // possible that the first call to the instance() function tosses
- // existing connection to the database created by the call to
- // createManagers(). Let's make sure that this doesn't happen.
- ASSERT_NO_THROW(HostMgr::instance());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("postgresql", host_data_source->getType());
- });
-
- EXPECT_TRUE(HostMgr::instance().getIPReservationsUnique());
-}
-
-// Tests that the createManagers function utilizes the setting in the
-// CfgDbAccess class which controls whether the IP reservations must
-// be unique or can be non-unique.
-TEST_F(CfgPgSQLDbAccessTest, createManagersIPResrvUnique) {
- CfgDbAccess cfg;
-
- cfg.setIPReservationsUnique(false);
-
- ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validPgSQLConnectionString()));
- ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validPgSQLConnectionString()));
- ASSERT_NO_THROW(cfg.createManagers());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("postgresql", host_data_source->getType());
- });
-
- // Because of the lazy initialization of the HostMgr instance, it is
- // possible that the first call to the instance() function tosses
- // existing connection to the database created by the call to
- // createManagers(). Let's make sure that this doesn't happen.
- ASSERT_NO_THROW(HostMgr::instance());
-
- ASSERT_NO_THROW({
- const HostDataSourcePtr& host_data_source =
- HostMgr::instance().getHostDataSource();
- ASSERT_TRUE(host_data_source);
- EXPECT_EQ("postgresql", host_data_source->getType());
- });
-
- EXPECT_FALSE(HostMgr::instance().getIPReservationsUnique());
-}
-
-#endif
-
} // end of anonymous namespace
#include <asiolink/io_address.h>
#include <dhcp/hwaddr.h>
#include <dhcpsrv/flq_allocator.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <boost/make_shared.hpp>
#include <gtest/gtest.h>
#include <config.h>
#include <asiolink/io_address.h>
#include <dhcpsrv/iterative_allocator.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <gtest/gtest.h>
#include <sstream>
#include <config.h>
#include <asiolink/io_address.h>
#include <dhcpsrv/random_allocator.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <boost/make_shared.hpp>
#include <gtest/gtest.h>
#include <set>
noinst_LTLIBRARIES = libdhcpsrvtest.la
-libdhcpsrvtest_la_SOURCES = concrete_lease_mgr.cc concrete_lease_mgr.h
+libdhcpsrvtest_la_SOURCES = alloc_engine_utils.cc alloc_engine_utils.h
+libdhcpsrvtest_la_SOURCES += concrete_lease_mgr.cc concrete_lease_mgr.h
libdhcpsrvtest_la_SOURCES += config_result_check.cc config_result_check.h
libdhcpsrvtest_la_SOURCES += dhcp4o6_test_ipc.cc dhcp4o6_test_ipc.h
libdhcpsrvtest_la_SOURCES += host_data_source_utils.cc host_data_source_utils.h
#include <stats/stats_mgr.h>
#include <dhcpsrv/testutils/test_utils.h>
-#include <dhcpsrv/tests/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
#include <boost/shared_ptr.hpp>
#include <boost/scoped_ptr.hpp>
SUBDIRS = . tests
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CPPFLAGS += $(MYSQL_CPPFLAGS)
+
AM_CXXFLAGS = $(KEA_CXXFLAGS)
CLEANFILES = *.gcno *.gcda
libkea_mysql_host_backend_la_SOURCES = mysql_host_data_source.cc mysql_host_data_source.h
libkea_mysql_host_backend_la_LIBADD = $(top_builddir)/src/lib/mysql/libkea-mysql.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/database/libkea-database.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/log/libkea-log.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/util/libkea-util.la
+libkea_mysql_host_backend_la_LIBADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libkea_mysql_host_backend_la_LIBADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS)
libkea_mysql_host_backend_la_LDFLAGS = $(MYSQL_LIBS)
#include <dhcpsrv/cfgmgr.h>
#include <dhcpsrv/dhcpsrv_log.h>
#include <dhcpsrv/host_mgr.h>
-#include <dhcpsrv/mysql_host_data_source.h>
+#include <mysql_host_data_source.h>
#include <dhcpsrv/timer_mgr.h>
#include <util/buffer.h>
#include <util/multi_threading_mgr.h>
#include <database/database_connection.h>
#include <database/db_exceptions.h>
#include <dhcpsrv/base_host_data_source.h>
+#include <dhcpsrv/host_data_source_factory.h>
#include <mysql/mysql_connection.h>
#include <stdint.h>
MySqlHostDataSourceImplPtr impl_;
};
+struct MySqlHostDataSourceInit {
+ // Constructor registers
+ MySqlHostDataSourceInit() {
+ isc::dhcp::HostDataSourceFactory::registerFactory("mysql", factory, true);
+ }
+
+ // Destructor deregisters
+ ~MySqlHostDataSourceInit() {
+ isc::dhcp::HostDataSourceFactory::deregisterFactory("mysql", true);
+ }
+
+ // Factory class method
+ static HostDataSourcePtr
+ factory(const isc::db::DatabaseConnection::ParameterMap& parameters) {
+ // TODO - fix messages
+ //LOG_INFO(hosts_logger, DHCPSRV_MYSQL_HOST_DB)
+ // .arg(DatabaseConnection::redactedAccessString(parameters));
+ return (HostDataSourcePtr(new MySqlHostDataSource(parameters)));
+ }
+};
+
}
}
--- /dev/null
+libmysql_host_backend_unittests
+SUBDIRS = .
+
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CXXFLAGS = $(KEA_CXXFLAGS)
+
+if USE_STATIC_LINK
+AM_LDFLAGS = -static
+endif
+
+CLEANFILES = *.gcno *.gcda
+
+TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND)
+
+TESTS =
+if HAVE_GTEST
+TESTS += libmysql_host_backend_unittests
+
+libmysql_host_backend_unittests_SOURCES = run_unittests.cc
+libmysql_host_backend_unittests_SOURCES += mysql_host_data_source_unittest.cc
+
+libmysql_host_backend_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES)
+libmysql_host_backend_unittests_CPPFLAGS += $(MYSQL_CPPFLAGS)
+
+libmysql_host_backend_unittests_CXXFLAGS = $(AM_CXXFLAGS)
+
+libmysql_host_backend_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS)
+libmysql_host_backend_unittests_LDFLAGS += $(MYSQL_LIBS)
+
+libmysql_host_backend_unittests_LDADD = $(top_builddir)/src/lib/mysql_host_backend/libkea-mysql-host-backend.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/testutils/libdhcpsrvtest.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/libkea-dhcpsrv.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/process/libkea-process.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/eval/libkea-eval.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp_ddns/libkea-dhcp_ddns.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/stats/libkea-stats.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/config/libkea-cfgclient.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/http/libkea-http.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/testutils/libdhcptest.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/mysql/testutils/libmysqltest.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/log/libkea-log.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/util/unittests/libutil_unittests.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/util/libkea-util.la
+libmysql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libmysql_host_backend_unittests_LDADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS) $(GTEST_LDADD)
+endif
+
+noinst_PROGRAMS = $(TESTS)
#include <dhcpsrv/testutils/test_utils.h>
#include <exceptions/exceptions.h>
#include <dhcpsrv/host.h>
-#include <dhcpsrv/mysql_host_data_source.h>
+#include <mysql_host_backend/mysql_host_data_source.h>
#include <dhcpsrv/testutils/generic_host_data_source_unittest.h>
#include <dhcpsrv/testutils/host_data_source_utils.h>
#include <dhcpsrv/host_mgr.h>
return (countRowsInTable("ipv6_reservations"));
}
+ /// @brief Initializer.
+ Initializer<MySqlHostDataSourceInit> init_;
};
/// @brief Check that database can be opened
/// MySqlHostMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(MySqlHostDataSource, OpenDatabase) {
+ Initializer<MySqlHostDataSourceInit> init;
// Schema needs to be created for the test to work.
destroyMySQLSchema();
createMySQLSchema();
/// MySqlHostMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(MySqlHostDataSource, OpenDatabaseMultiThreading) {
+ Initializer<MySqlHostDataSourceInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
/// in a unit test is next to impossible. That has to be done
/// as a system test.
TEST(MySqlHostDataSource, NoCallbackOnOpenFail) {
+ Initializer<MySqlHostDataSourceInit> init;
// Schema needs to be created for the test to work.
destroyMySQLSchema();
createMySQLSchema();
/// in a unit test is next to impossible. That has to be done
/// as a system test.
TEST(MySqlHostDataSource, NoCallbackOnOpenFailMultiThreading) {
+ Initializer<MySqlHostDataSourceInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
/// @brief Rollback and drop MySQL schema after the test.
virtual void TearDown();
+
+ /// @brief Initializer.
+ Initializer<MySqlHostDataSourceInit> init_;
};
void
return (connectionString(MYSQL_VALID_TYPE, INVALID_NAME, VALID_HOST,
VALID_USER, VALID_PASSWORD));
}
+
+ /// @brief Initializer.
+ Initializer<MySqlHostDataSourceInit> init_;
};
// This test verifies that reservations for a particular client can
testDbLostAndFailedAfterTimeoutCallback();
}
+/// @brief Test fixture class for testing @ref CfgDbAccessTest using MySQL
+/// backend.
+class CfgMySqlDbAccessTest : public ::testing::Test {
+public:
+
+ /// @brief Constructor.
+ CfgMySqlDbAccessTest() {
+ // Ensure we have the proper schema with no transient data.
+ db::test::createMySQLSchema();
+ }
+
+ /// @brief Destructor.
+ virtual ~CfgMySqlDbAccessTest() {
+ // If data wipe enabled, delete transient data otherwise destroy the schema
+ db::test::destroyMySQLSchema();
+ }
+
+ /// @brief Initializer.
+ Initializer<MySqlHostDataSourceInit> init_;
+};
+
+// Tests that MySQL lease manager and host data source can be created from a
+// specified configuration.
+TEST_F(CfgMySqlDbAccessTest, createManagers) {
+ CfgDbAccess cfg;
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString("type=memfile persist=false universe=4"));
+ ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validMySQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("mysql", host_data_source->getType());
+ });
+
+ // Because of the lazy initialization of the HostMgr instance, it is
+ // possible that the first call to the instance() function tosses
+ // existing connection to the database created by the call to
+ // createManagers(). Let's make sure that this doesn't happen.
+ ASSERT_NO_THROW(HostMgr::instance());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("mysql", host_data_source->getType());
+ });
+
+ EXPECT_TRUE(HostMgr::instance().getIPReservationsUnique());
+}
+
+// Tests that the createManagers function utilizes the setting in the
+// CfgDbAccess class which controls whether the IP reservations must
+// be unique or can be non-unique.
+TEST_F(CfgMySqlDbAccessTest, createManagersIPResrvUnique) {
+ CfgDbAccess cfg;
+
+ cfg.setIPReservationsUnique(false);
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString("type=memfile persist=false universe=6"));
+ ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validMySQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("mysql", host_data_source->getType());
+ });
+
+ // Because of the lazy initialization of the HostMgr instance, it is
+ // possible that the first call to the instance() function tosses
+ // existing connection to the database created by the call to
+ // createManagers(). Let's make sure that this doesn't happen.
+ ASSERT_NO_THROW(HostMgr::instance());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("mysql", host_data_source->getType());
+ });
+
+ EXPECT_FALSE(HostMgr::instance().getIPReservationsUnique());
+}
+
} // namespace
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <gtest/gtest.h>
+
+#include <util/unittests/run_all.h>
+#include <log/logger_support.h>
+
+int
+main(int argc, char* argv[]) {
+ ::testing::InitGoogleTest(&argc, argv);
+ isc::log::initLogger();
+ return (isc::util::unittests::run_all());
+}
SUBDIRS = . tests
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CPPFLAGS += $(MYSQL_CPPFLAGS)
+
AM_CXXFLAGS = $(KEA_CXXFLAGS)
CLEANFILES = *.gcno *.gcda
libkea_mysql_lease_backend_la_SOURCES = mysql_lease_mgr.cc mysql_lease_mgr.h
libkea_mysql_lease_backend_la_LIBADD = $(top_builddir)/src/lib/mysql/libkea-mysql.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/database/libkea-database.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/log/libkea-log.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/util/libkea-util.la
+libkea_mysql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libkea_mysql_lease_backend_la_LIBADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS)
libkea_mysql_lease_backend_la_LDFLAGS = $(MYSQL_LIBS)
#include <dhcpsrv/cfgmgr.h>
#include <dhcpsrv/dhcpsrv_log.h>
#include <dhcpsrv/lease_mgr_factory.h>
-#include <dhcpsrv/mysql_lease_mgr.h>
+#include <mysql_lease_mgr.h>
#include <dhcpsrv/timer_mgr.h>
#include <mysql/mysql_connection.h>
#include <util/multi_threading_mgr.h>
std::string timer_name_;
};
+struct MySqlLeaseMgrInit {
+ // Constructor registers
+ MySqlLeaseMgrInit() {
+ LeaseMgrFactory::registerFactory("mysql", factory, true);
+ }
+
+ // Destructor deregisters
+ ~MySqlLeaseMgrInit() {
+ LeaseMgrFactory::deregisterFactory("mysql", true);
+ }
+
+ // Factory class method
+ static TrackingLeaseMgrPtr
+ factory(const isc::db::DatabaseConnection::ParameterMap& parameters) {
+ // TODO - fix messages
+ //LOG_INFO(dhcpsrv_logger, DHCPSRV_MYSQL_DB)
+ // .arg(DatabaseConnection::redactedAccessString(parameters));
+ return (TrackingLeaseMgrPtr(new MySqlLeaseMgr(parameters)));
+ }
+};
+
} // namespace dhcp
} // namespace isc
--- /dev/null
+libmysql_lease_backend_unittests
+SUBDIRS = .
+
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CXXFLAGS = $(KEA_CXXFLAGS)
+
+if USE_STATIC_LINK
+AM_LDFLAGS = -static
+endif
+
+CLEANFILES = *.gcno *.gcda
+
+TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND)
+
+TESTS =
+if HAVE_GTEST
+TESTS += libmysql_lease_backend_unittests
+
+libmysql_lease_backend_unittests_SOURCES = run_unittests.cc
+libmysql_lease_backend_unittests_SOURCES += mysql_lease_mgr_unittest.cc
+libmysql_lease_backend_unittests_SOURCES += mysql_lease_extended_info_unittest.cc
+libmysql_lease_backend_unittests_SOURCES += mysql_bootp_unittest.cc
+
+libmysql_lease_backend_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES)
+libmysql_lease_backend_unittests_CPPFLAGS += $(MYSQL_CPPFLAGS)
+
+libmysql_lease_backend_unittests_CXXFLAGS = $(AM_CXXFLAGS)
+
+libmysql_lease_backend_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS)
+libmysql_lease_backend_unittests_LDFLAGS += $(MYSQL_LIBS)
+
+libmysql_lease_backend_unittests_LDADD = $(top_builddir)/src/lib/mysql_lease_backend/libkea-mysql-lease-backend.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/testutils/libdhcpsrvtest.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/libkea-dhcpsrv.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/process/libkea-process.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/eval/libkea-eval.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp_ddns/libkea-dhcp_ddns.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/stats/libkea-stats.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/config/libkea-cfgclient.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/http/libkea-http.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/testutils/libdhcptest.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/mysql/testutils/libmysqltest.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/mysql/libkea-mysql.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/log/libkea-log.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/util/unittests/libutil_unittests.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/util/libkea-util.la
+libmysql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libmysql_lease_backend_unittests_LDADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS) $(GTEST_LDADD)
+endif
+
+noinst_PROGRAMS = $(TESTS)
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <dhcpsrv/lease_mgr_factory.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/test_utils.h>
+#include <mysql/testutils/mysql_schema.h>
+#include <mysql_lease_backend/mysql_lease_mgr.h>
+#include <util/triplet.h>
+
+#include <gtest/gtest.h>
+
+using namespace isc::asiolink;
+using namespace isc::db;
+using namespace isc::db::test;
+using namespace isc::dhcp;
+using namespace isc::dhcp::test;
+using namespace isc::util;
+
+namespace {
+
+/// @brief Extension of the fixture class to use the MySQL backend.
+class MySqlAllocEngine4Test : public AllocEngine4Test {
+public:
+ /// @brief Constructor.
+ MySqlAllocEngine4Test() {
+ // Ensure we have the proper schema with no transient data.
+ isc::db::test::createMySQLSchema();
+ factory_.create(isc::db::test::validMySQLConnectionString());
+ }
+
+ /// @brief Destructor.
+ ~MySqlAllocEngine4Test() {
+ // If data wipe enabled, delete transient data otherwise destroy
+ // the schema.
+ isc::db::test::destroyMySQLSchema();
+ LeaseMgrFactory::destroy();
+ }
+
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
+};
+
+// This test checks that simple allocation handles BOOTP queries.
+TEST_F(MySqlAllocEngine4Test, bootpAlloc4) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Check that we got a lease
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // Check that the lease is indeed in LeaseMgr
+ Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ ASSERT_TRUE(from_mgr);
+ // The MySQL database does not keep the hwtype for DHCPv4 leases.
+ from_mgr->hwaddr_->htype_ = HTYPE_FDDI;
+
+ // Now check that the lease in LeaseMgr has the same parameters
+ detailCompareLease(lease, from_mgr);
+}
+
+// This test checks simple renewal handles BOOTP queries.
+TEST_F(MySqlAllocEngine4Test, bootpRenew4) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+
+ // Check that we got a lease.
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Do it again, this should amount to the renew of an existing lease
+ Lease4Ptr lease2 = engine->allocateLease4(ctx);
+
+ // Check that we got a lease.
+ ASSERT_TRUE(lease2);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease2->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease2->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease2->addr_));
+ ASSERT_TRUE(lease2->client_id_);
+ EXPECT_TRUE(*lease2->client_id_ == *clientid_);
+ ASSERT_TRUE(lease2->hwaddr_);
+ EXPECT_TRUE(*lease2->hwaddr_ == *hwaddr_);
+
+ // Lease already existed, so old_lease should be set.
+ EXPECT_TRUE(ctx.old_lease_);
+
+ // Check the renewed valid lifetime has the max value.
+ EXPECT_EQ(infinity_lft, lease2->valid_lft_);
+}
+
+// This test checks that deleteRelease handles BOOTP leases.
+TEST_F(MySqlAllocEngine4Test, bootpDelete) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Check that we got a lease
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // Check that the lease is indeed in LeaseMgr
+ Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ ASSERT_TRUE(from_mgr);
+
+ // Now delete it.
+ bool deleted = false;
+ ASSERT_NO_THROW(deleted = LeaseMgrFactory::instance().deleteLease(lease));
+ EXPECT_TRUE(deleted);
+ from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ EXPECT_FALSE(from_mgr);
+}
+
+}
#include <cc/data.h>
#include <dhcpsrv/testutils/generic_lease_extended_info_unittest.h>
#include <mysql/testutils/mysql_schema.h>
-#include <dhcpsrv/mysql_lease_mgr.h>
+#include <mysql_lease_backend/mysql_lease_mgr.h>
using namespace isc;
using namespace isc::asiolink;
static void destroySchema() {
destroyMySQLSchema();
}
+
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
};
/// @brief Test fixture class for extended info tests.
-class MySqlExtendedInfoTest :
- public isc::dhcp::test::GenericExtendedInfoTest<NakedMySqlLeaseMgr> { };
+class MySqlExtendedInfoTest : public isc::dhcp::test::GenericExtendedInfoTest<NakedMySqlLeaseMgr> {
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
+};
/// @brief Verifies that the lease manager can start.
TEST_F(MySqlExtendedInfoTest, startWithoutExtendedTables) {
#include <asiolink/io_address.h>
#include <dhcpsrv/lease_mgr_factory.h>
-#include <dhcpsrv/mysql_lease_mgr.h>
+#include <mysql_lease_backend/mysql_lease_mgr.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <dhcpsrv/testutils/generic_lease_mgr_unittest.h>
#include <dhcpsrv/testutils/mysql_generic_backend_unittest.h>
namespace {
-
/// @brief Test fixture class for testing MySQL Lease Manager
///
/// Opens the database prior to each test and closes it afterwards.
LeaseMgrFactory::create(validMySQLConnectionString());
lmptr_ = &(LeaseMgrFactory::instance());
}
+
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
};
/// @brief Check that database can be opened
/// MySqlLeaseMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(MySqlOpenTest, OpenDatabase) {
+ Initializer<MySqlLeaseMgrInit> init;
// Explicitly disable Multi-Threading.
MultiThreadingMgr::instance().setMode(false);
/// @brief Check that database can be opened with Multi-Threading
TEST(MySqlOpenTest, OpenDatabaseMultiThreading) {
+ Initializer<MySqlLeaseMgrInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
return (connectionString(MYSQL_VALID_TYPE, INVALID_NAME, VALID_HOST,
VALID_USER, VALID_PASSWORD));
}
+
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
};
/// @brief Verifies that loss of connectivity to MySQL is handled correctly.
testBigStats();
}
+/// @brief Test fixture class for testing @ref CfgDbAccessTest using MySQL
+/// backend.
+class CfgMySqlDbAccessTest : public ::testing::Test {
+public:
+
+ /// @brief Constructor.
+ CfgMySqlDbAccessTest() {
+ // Ensure we have the proper schema with no transient data.
+ db::test::createMySQLSchema();
+ }
+
+ /// @brief Destructor.
+ virtual ~CfgMySqlDbAccessTest() {
+ // If data wipe enabled, delete transient data otherwise destroy the schema
+ db::test::destroyMySQLSchema();
+ LeaseMgrFactory::destroy();
+ }
+
+ /// @brief Initializer.
+ Initializer<MySqlLeaseMgrInit> init_;
+};
+
+// Tests that MySQL lease manager and host data source can be created from a
+// specified configuration.
+TEST_F(CfgMySqlDbAccessTest, createManagers) {
+ CfgDbAccess cfg;
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validMySQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ LeaseMgr& lease_mgr = LeaseMgrFactory::instance();
+ EXPECT_EQ("mysql", lease_mgr.getType());
+ });
+}
+
} // namespace
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <gtest/gtest.h>
+
+#include <util/unittests/run_all.h>
+#include <log/logger_support.h>
+
+int
+main(int argc, char* argv[]) {
+ ::testing::InitGoogleTest(&argc, argv);
+ isc::log::initLogger();
+ return (isc::util::unittests::run_all());
+}
SUBDIRS = . tests
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CPPFLAGS += $(PGSQL_CPPFLAGS)
+
AM_CXXFLAGS = $(KEA_CXXFLAGS)
CLEANFILES = *.gcno *.gcda
libkea_pgsql_host_backend_la_SOURCES = pgsql_host_data_source.cc pgsql_host_data_source.h
libkea_pgsql_host_backend_la_LIBADD = $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/database/libkea-database.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/log/libkea-log.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/util/libkea-util.la
+libkea_pgsql_host_backend_la_LIBADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libkea_pgsql_host_backend_la_LIBADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS)
libkea_pgsql_host_backend_la_LDFLAGS = $(PGSQL_LIBS)
#include <dhcpsrv/cfgmgr.h>
#include <dhcpsrv/dhcpsrv_log.h>
#include <dhcpsrv/host_mgr.h>
-#include <dhcpsrv/pgsql_host_data_source.h>
+#include <pgsql_host_data_source.h>
#include <dhcpsrv/timer_mgr.h>
#include <util/buffer.h>
#include <util/multi_threading_mgr.h>
#include <database/database_connection.h>
#include <dhcpsrv/base_host_data_source.h>
+#include <dhcpsrv/host_data_source_factory.h>
#include <pgsql/pgsql_connection.h>
#include <pgsql/pgsql_exchange.h>
PgSqlHostDataSourceImplPtr impl_;
};
+struct PgSqlHostDataSourceInit {
+ // Constructor registers
+ PgSqlHostDataSourceInit() {
+ isc::dhcp::HostDataSourceFactory::registerFactory("postgresql", factory, true);
+ }
+
+ // Destructor deregisters
+ ~PgSqlHostDataSourceInit() {
+ isc::dhcp::HostDataSourceFactory::deregisterFactory("postgresql", true);
+ }
+
+ // Factory class method
+ static HostDataSourcePtr
+ factory(const isc::db::DatabaseConnection::ParameterMap& parameters) {
+ // TODO - fix messages
+ //LOG_INFO(hosts_logger, DHCPSRV_PGSQL_HOST_DB)
+ // .arg(DatabaseConnection::redactedAccessString(parameters));
+ return (HostDataSourcePtr(new PgSqlHostDataSource(parameters)));
+ }
+};
+
} // namespace dhcp
} // namespace isc
--- /dev/null
+libpgsql_host_backend_unittests
+SUBDIRS = .
+
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CXXFLAGS = $(KEA_CXXFLAGS)
+
+if USE_STATIC_LINK
+AM_LDFLAGS = -static
+endif
+
+CLEANFILES = *.gcno *.gcda
+
+TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND)
+
+TESTS =
+if HAVE_GTEST
+TESTS += libpgsql_host_backend_unittests
+
+libpgsql_host_backend_unittests_SOURCES = run_unittests.cc
+libpgsql_host_backend_unittests_SOURCES += pgsql_host_data_source_unittest.cc
+
+libpgsql_host_backend_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES)
+libpgsql_host_backend_unittests_CPPFLAGS += $(PGSQL_CPPFLAGS)
+
+libpgsql_host_backend_unittests_CXXFLAGS = $(AM_CXXFLAGS)
+
+libpgsql_host_backend_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS)
+libpgsql_host_backend_unittests_LDFLAGS += $(PGSQL_LIBS)
+
+libpgsql_host_backend_unittests_LDADD = $(top_builddir)/src/lib/pgsql_host_backend/libkea-pgsql-host-backend.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/testutils/libdhcpsrvtest.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/libkea-dhcpsrv.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/process/libkea-process.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/eval/libkea-eval.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp_ddns/libkea-dhcp_ddns.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/stats/libkea-stats.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/config/libkea-cfgclient.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/http/libkea-http.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/testutils/libdhcptest.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/pgsql/testutils/libpgsqltest.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/log/libkea-log.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/util/unittests/libutil_unittests.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/util/libkea-util.la
+libpgsql_host_backend_unittests_LDADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libpgsql_host_backend_unittests_LDADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS) $(GTEST_LDADD)
+endif
+
+noinst_PROGRAMS = $(TESTS)
\ No newline at end of file
#include <dhcpsrv/testutils/test_utils.h>
#include <exceptions/exceptions.h>
#include <dhcpsrv/host.h>
-#include <dhcpsrv/pgsql_host_data_source.h>
+#include <pgsql_host_backend/pgsql_host_data_source.h>
#include <dhcpsrv/testutils/generic_host_data_source_unittest.h>
#include <dhcpsrv/testutils/host_data_source_utils.h>
#include <dhcpsrv/host_mgr.h>
return (countRowsInTable("ipv6_reservations"));
}
+ /// @brief Initializer.
+ Initializer<PgSqlHostDataSourceInit> init_;
};
/// @brief Check that database can be opened
/// PgSqlHostMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(PgSqlHostDataSource, OpenDatabase) {
+ Initializer<PgSqlHostDataSourceInit> init;
// Schema needs to be created for the test to work.
destroyPgSQLSchema();
createPgSQLSchema();
/// PgSqlHostMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(PgSqlHostDataSource, OpenDatabaseMultiThreading) {
+ Initializer<PgSqlHostDataSourceInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
/// in a unit test is next to impossible. That has to be done
/// as a system test.
TEST(PgSqlHostDataSource, NoCallbackOnOpenFail) {
+ Initializer<PgSqlHostDataSourceInit> init;
// Schema needs to be created for the test to work.
destroyPgSQLSchema();
createPgSQLSchema();
/// in a unit test is next to impossible. That has to be done
/// as a system test.
TEST(PgSqlHostDataSource, NoCallbackOnOpenFailMultiThreading) {
+ Initializer<PgSqlHostDataSourceInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
/// @brief Rollback and drop PostgreSQL schema after the test.
virtual void TearDown();
+
+ /// @brief Initializer.
+ Initializer<PgSqlHostDataSourceInit> init_;
};
void
return (connectionString(PGSQL_VALID_TYPE, INVALID_NAME, VALID_HOST,
VALID_USER, VALID_PASSWORD));
}
+
+ /// @brief Initializer.
+ Initializer<PgSqlHostDataSourceInit> init_;
};
// This test verifies that reservations for a particular client can
testDbLostAndFailedAfterTimeoutCallback();
}
+/// @brief Test fixture class for testing @ref CfgDbAccessTest using PgSQL
+/// backend.
+class CfgPgSqlDbAccessTest : public ::testing::Test {
+public:
+
+ /// @brief Constructor.
+ CfgPgSqlDbAccessTest() {
+ // Ensure we have the proper schema with no transient data.
+ db::test::createPgSQLSchema();
+ }
+
+ /// @brief Destructor.
+ virtual ~CfgPgSqlDbAccessTest() {
+ // If data wipe enabled, delete transient data otherwise destroy the schema
+ db::test::destroyPgSQLSchema();
+ }
+
+ /// @brief Initializer.
+ Initializer<PgSqlHostDataSourceInit> init_;
+};
+
+// Tests that PostgreSQL lease manager and host data source can be created from a
+// specified configuration.
+TEST_F(CfgPgSqlDbAccessTest, createManagers) {
+ CfgDbAccess cfg;
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString("type=memfile persist=false universe=4"));
+ ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validPgSQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("postgresql", host_data_source->getType());
+ });
+
+ // Because of the lazy initialization of the HostMgr instance, it is
+ // possible that the first call to the instance() function tosses
+ // existing connection to the database created by the call to
+ // createManagers(). Let's make sure that this doesn't happen.
+ ASSERT_NO_THROW(HostMgr::instance());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("postgresql", host_data_source->getType());
+ });
+
+ EXPECT_TRUE(HostMgr::instance().getIPReservationsUnique());
+}
+
+// Tests that the createManagers function utilizes the setting in the
+// CfgDbAccess class which controls whether the IP reservations must
+// be unique or can be non-unique.
+TEST_F(CfgPgSqlDbAccessTest, createManagersIPResrvUnique) {
+ CfgDbAccess cfg;
+
+ cfg.setIPReservationsUnique(false);
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString("type=memfile persist=false universe=6"));
+ ASSERT_NO_THROW(cfg.setHostDbAccessString(db::test::validPgSQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("postgresql", host_data_source->getType());
+ });
+
+ // Because of the lazy initialization of the HostMgr instance, it is
+ // possible that the first call to the instance() function tosses
+ // existing connection to the database created by the call to
+ // createManagers(). Let's make sure that this doesn't happen.
+ ASSERT_NO_THROW(HostMgr::instance());
+
+ ASSERT_NO_THROW({
+ const HostDataSourcePtr& host_data_source =
+ HostMgr::instance().getHostDataSource();
+ ASSERT_TRUE(host_data_source);
+ EXPECT_EQ("postgresql", host_data_source->getType());
+ });
+
+ EXPECT_FALSE(HostMgr::instance().getIPReservationsUnique());
+}
+
} // namespace
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <gtest/gtest.h>
+
+#include <util/unittests/run_all.h>
+#include <log/logger_support.h>
+
+int
+main(int argc, char* argv[]) {
+ ::testing::InitGoogleTest(&argc, argv);
+ isc::log::initLogger();
+ return (isc::util::unittests::run_all());
+}
SUBDIRS = . tests
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CPPFLAGS += $(PGSQL_CPPFLAGS)
+
AM_CXXFLAGS = $(KEA_CXXFLAGS)
CLEANFILES = *.gcno *.gcda
libkea_pgsql_lease_backend_la_SOURCES = pgsql_lease_mgr.cc pgsql_lease_mgr.h
libkea_pgsql_lease_backend_la_LIBADD = $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/database/libkea-database.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/log/libkea-log.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/util/libkea-util.la
+libkea_pgsql_lease_backend_la_LIBADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libkea_pgsql_lease_backend_la_LIBADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS)
libkea_pgsql_lease_backend_la_LDFLAGS = $(PGSQL_LIBS)
#include <dhcpsrv/dhcpsrv_log.h>
#include <dhcpsrv/dhcpsrv_exceptions.h>
#include <dhcpsrv/lease_mgr_factory.h>
-#include <dhcpsrv/pgsql_lease_mgr.h>
+#include <pgsql_lease_mgr.h>
#include <dhcpsrv/timer_mgr.h>
#include <util/multi_threading_mgr.h>
std::string timer_name_;
};
+struct PgSqlLeaseMgrInit {
+ // Constructor registers
+ PgSqlLeaseMgrInit() {
+ LeaseMgrFactory::registerFactory("postgresql", factory, true);
+ }
+
+ // Destructor deregisters
+ ~PgSqlLeaseMgrInit() {
+ LeaseMgrFactory::deregisterFactory("postgresql", true);
+ }
+
+ // Factory class method
+ static TrackingLeaseMgrPtr
+ factory(const isc::db::DatabaseConnection::ParameterMap& parameters) {
+ // TODO - fix messages
+ //LOG_INFO(dhcpsrv_logger, DHCPSRV_PGSQL_DB)
+ // .arg(DatabaseConnection::redactedAccessString(parameters));
+ return (TrackingLeaseMgrPtr(new PgSqlLeaseMgr(parameters)));
+ }
+};
+
} // namespace dhcp
} // namespace isc
--- /dev/null
+libpgsql_lease_backend_unittests
+SUBDIRS = .
+
+AM_CPPFLAGS = -I$(top_builddir)/src/lib -I$(top_srcdir)/src/lib
+AM_CPPFLAGS += $(BOOST_INCLUDES)
+AM_CXXFLAGS = $(KEA_CXXFLAGS)
+
+if USE_STATIC_LINK
+AM_LDFLAGS = -static
+endif
+
+CLEANFILES = *.gcno *.gcda
+
+TESTS_ENVIRONMENT = $(LIBTOOL) --mode=execute $(VALGRIND_COMMAND)
+
+TESTS =
+if HAVE_GTEST
+TESTS += libpgsql_lease_backend_unittests
+
+libpgsql_lease_backend_unittests_SOURCES = run_unittests.cc
+libpgsql_lease_backend_unittests_SOURCES += pgsql_lease_mgr_unittest.cc
+libpgsql_lease_backend_unittests_SOURCES += pgsql_lease_extended_info_unittest.cc
+libpgsql_lease_backend_unittests_SOURCES += pgsql_bootp_unittest.cc
+
+libpgsql_lease_backend_unittests_CPPFLAGS = $(AM_CPPFLAGS) $(GTEST_INCLUDES)
+libpgsql_lease_backend_unittests_CPPFLAGS += $(PGSQL_CPPFLAGS)
+
+libpgsql_lease_backend_unittests_CXXFLAGS = $(AM_CXXFLAGS)
+
+libpgsql_lease_backend_unittests_LDFLAGS = $(AM_LDFLAGS) $(CRYPTO_LDFLAGS) $(GTEST_LDFLAGS)
+libpgsql_lease_backend_unittests_LDFLAGS += $(PGSQL_LIBS)
+
+libpgsql_lease_backend_unittests_LDADD = $(top_builddir)/src/lib/pgsql_lease_backend/libkea-pgsql-lease-backend.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/testutils/libdhcpsrvtest.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcpsrv/libkea-dhcpsrv.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/process/libkea-process.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/eval/libkea-eval.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp_ddns/libkea-dhcp_ddns.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/stats/libkea-stats.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/config/libkea-cfgclient.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/http/libkea-http.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/testutils/libdhcptest.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dhcp/libkea-dhcp++.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/hooks/libkea-hooks.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/pgsql/testutils/libpgsqltest.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/pgsql/libkea-pgsql.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/database/libkea-database.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/cc/libkea-cc.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/asiolink/libkea-asiolink.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/dns/libkea-dns++.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/cryptolink/libkea-cryptolink.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/log/libkea-log.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/util/unittests/libutil_unittests.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/util/libkea-util.la
+libpgsql_lease_backend_unittests_LDADD += $(top_builddir)/src/lib/exceptions/libkea-exceptions.la
+libpgsql_lease_backend_unittests_LDADD += $(LOG4CPLUS_LIBS) $(CRYPTO_LIBS) $(BOOST_LIBS) $(GTEST_LDADD)
+endif
+
+noinst_PROGRAMS = $(TESTS)
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <dhcpsrv/lease_mgr_factory.h>
+#include <dhcpsrv/testutils/alloc_engine_utils.h>
+#include <dhcpsrv/testutils/test_utils.h>
+#include <pgsql/testutils/pgsql_schema.h>
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
+#include <util/triplet.h>
+
+#include <gtest/gtest.h>
+
+using namespace isc::asiolink;
+using namespace isc::db;
+using namespace isc::db::test;
+using namespace isc::dhcp;
+using namespace isc::dhcp::test;
+using namespace isc::util;
+
+namespace {
+
+/// @brief Extension of the fixture class to use the PostgreSQL backend.
+class PgSqlAllocEngine4Test : public AllocEngine4Test {
+public:
+ /// @brief Constructor.
+ PgSqlAllocEngine4Test() {
+ // Ensure we have the proper schema with no transient data.
+ isc::db::test::createPgSQLSchema();
+ factory_.create(isc::db::test::validPgSQLConnectionString());
+ }
+
+ /// @brief Destructor.
+ ~PgSqlAllocEngine4Test() {
+ // If data wipe enabled, delete transient data otherwise destroy
+ // the schema.
+ isc::db::test::destroyPgSQLSchema();
+ LeaseMgrFactory::destroy();
+ }
+
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
+};
+
+// This test checks that simple allocation handles BOOTP queries.
+TEST_F(PgSqlAllocEngine4Test, bootpAlloc4) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Check that we got a lease
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // Check that the lease is indeed in LeaseMgr
+ Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ ASSERT_TRUE(from_mgr);
+ // The PostgreSql database does not keep the hwtype for DHCPv4 leases.
+ from_mgr->hwaddr_->htype_ = HTYPE_FDDI;
+
+ // Now check that the lease in LeaseMgr has the same parameters
+ detailCompareLease(lease, from_mgr);
+}
+
+// This test checks simple renewal handles BOOTP queries.
+TEST_F(PgSqlAllocEngine4Test, bootpRenew4) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+
+ // Check that we got a lease.
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Do it again, this should amount to the renew of an existing lease
+ Lease4Ptr lease2 = engine->allocateLease4(ctx);
+
+ // Check that we got a lease.
+ ASSERT_TRUE(lease2);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease2->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease2->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease2->addr_));
+ ASSERT_TRUE(lease2->client_id_);
+ EXPECT_TRUE(*lease2->client_id_ == *clientid_);
+ ASSERT_TRUE(lease2->hwaddr_);
+ EXPECT_TRUE(*lease2->hwaddr_ == *hwaddr_);
+
+ // Lease already existed, so old_lease should be set.
+ EXPECT_TRUE(ctx.old_lease_);
+
+ // Check the renewed valid lifetime has the max value.
+ EXPECT_EQ(infinity_lft, lease2->valid_lft_);
+}
+
+// This test checks that deleteRelease handles BOOTP leases.
+TEST_F(PgSqlAllocEngine4Test, bootpDelete) {
+ boost::scoped_ptr<AllocEngine> engine;
+ ASSERT_NO_THROW(engine.reset(new AllocEngine(0)));
+ ASSERT_TRUE(engine);
+
+ AllocEngine::ClientContext4 ctx(subnet_, clientid_, hwaddr_, IOAddress("0.0.0.0"),
+ false, true, "somehost.example.com.", false);
+ subnet_->setValid(Triplet<uint32_t>(1, 3, 5));
+ ctx.query_.reset(new Pkt4(DHCPREQUEST, 1234));
+
+ // Make the query a BOOTP one.
+ ctx.query_->addClass("BOOTP");
+
+ Lease4Ptr lease = engine->allocateLease4(ctx);
+ // The new lease has been allocated, so the old lease should not exist.
+ ASSERT_FALSE(ctx.old_lease_);
+
+ // Check that we got a lease
+ ASSERT_TRUE(lease);
+
+ // Check that is belongs to the right subnet and client.
+ EXPECT_EQ(lease->subnet_id_, subnet_->getID());
+ EXPECT_TRUE(subnet_->inRange(lease->addr_));
+ EXPECT_TRUE(subnet_->inPool(Lease::TYPE_V4, lease->addr_));
+ ASSERT_TRUE(lease->client_id_);
+ EXPECT_TRUE(*lease->client_id_ == *clientid_);
+ ASSERT_TRUE(lease->hwaddr_);
+ EXPECT_TRUE(*lease->hwaddr_ == *hwaddr_);
+
+ // Check the valid lifetime is infinite.
+ uint32_t infinity_lft = Lease::INFINITY_LFT;
+ EXPECT_EQ(infinity_lft, lease->valid_lft_);
+
+ // Check that the lease is indeed in LeaseMgr
+ Lease4Ptr from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ ASSERT_TRUE(from_mgr);
+
+ // Now delete it.
+ bool deleted = false;
+ ASSERT_NO_THROW(deleted = LeaseMgrFactory::instance().deleteLease(lease));
+ EXPECT_TRUE(deleted);
+ from_mgr = LeaseMgrFactory::instance().getLease4(lease->addr_);
+ EXPECT_FALSE(from_mgr);
+}
+
+}
#include <cc/data.h>
#include <dhcpsrv/testutils/generic_lease_extended_info_unittest.h>
#include <pgsql/testutils/pgsql_schema.h>
-#include <dhcpsrv/pgsql_lease_mgr.h>
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
using namespace isc;
using namespace isc::asiolink;
static void destroySchema() {
destroyPgSQLSchema();
}
+
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
};
/// @brief Test fixture class for extended info tests.
-class PgSqlExtendedInfoTest :
- public isc::dhcp::test::GenericExtendedInfoTest<NakedPgSqlLeaseMgr> { };
+class PgSqlExtendedInfoTest : public isc::dhcp::test::GenericExtendedInfoTest<NakedPgSqlLeaseMgr> {
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
+};
/// @brief Verifies that the lease manager can start.
TEST_F(PgSqlExtendedInfoTest, startWithoutExtendedTables) {
#include <asiolink/io_address.h>
#include <dhcpsrv/lease_mgr_factory.h>
-#include <dhcpsrv/pgsql_lease_mgr.h>
+#include <pgsql_lease_backend/pgsql_lease_mgr.h>
#include <dhcpsrv/testutils/test_utils.h>
#include <dhcpsrv/testutils/generic_lease_mgr_unittest.h>
#include <dhcpsrv/testutils/pgsql_generic_backend_unittest.h>
namespace {
-
/// @brief Test fixture class for testing PostgreSQL Lease Manager
///
/// Opens the database prior to each test and closes it afterwards.
LeaseMgrFactory::create(validPgSQLConnectionString());
lmptr_ = &(LeaseMgrFactory::instance());
}
+
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
};
/// @brief Check that database can be opened
/// PgSqlLeaseMgr test fixture set. This test checks that the database can be
/// opened: the fixtures assume that and check basic operations.
TEST(PgSqlOpenTest, OpenDatabase) {
+ Initializer<PgSqlLeaseMgrInit> init;
// Explicitly disable Multi-Threading.
MultiThreadingMgr::instance().setMode(false);
/// @brief Check that database can be opened with Multi-Threading
TEST(PgSqlOpenTest, OpenDatabaseMultiThreading) {
+ Initializer<PgSqlLeaseMgrInit> init;
// Enable Multi-Threading.
MultiThreadingTest mt(true);
return (connectionString(PGSQL_VALID_TYPE, INVALID_NAME, VALID_HOST,
VALID_USER, VALID_PASSWORD));
}
+
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
};
/// @brief Verifies that loss of connectivity to PostgreSQL is handled correctly.
testBigStats();
}
+/// @brief Test fixture class for testing @ref CfgDbAccessTest using PgSQL
+/// backend.
+class CfgPgSqlDbAccessTest : public ::testing::Test {
+public:
+
+ /// @brief Constructor.
+ CfgPgSqlDbAccessTest() {
+ // Ensure we have the proper schema with no transient data.
+ db::test::createPgSQLSchema();
+ }
+
+ /// @brief Destructor.
+ virtual ~CfgPgSqlDbAccessTest() {
+ // If data wipe enabled, delete transient data otherwise destroy the schema
+ db::test::destroyPgSQLSchema();
+ LeaseMgrFactory::destroy();
+ }
+
+ /// @brief Initializer.
+ Initializer<PgSqlLeaseMgrInit> init_;
+};
+
+// Tests that PostgreSQL lease manager and host data source can be created from a
+// specified configuration.
+TEST_F(CfgPgSqlDbAccessTest, createManagers) {
+ CfgDbAccess cfg;
+ ASSERT_NO_THROW(cfg.setLeaseDbAccessString(db::test::validPgSQLConnectionString()));
+ ASSERT_NO_THROW(cfg.createManagers());
+
+ ASSERT_NO_THROW({
+ LeaseMgr& lease_mgr = LeaseMgrFactory::instance();
+ EXPECT_EQ("postgresql", lease_mgr.getType());
+ });
+}
+
} // namespace
--- /dev/null
+// Copyright (C) 2024 Internet Systems Consortium, Inc. ("ISC")
+//
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#include <config.h>
+
+#include <gtest/gtest.h>
+
+#include <util/unittests/run_all.h>
+#include <log/logger_support.h>
+
+int
+main(int argc, char* argv[]) {
+ ::testing::InitGoogleTest(&argc, argv);
+ isc::log::initLogger();
+ return (isc::util::unittests::run_all());
+}
projects / thirdparty / kea.git / commitdiff
