// Copyright (C) 2012-2015 Internet Systems Consortium, Inc. ("ISC") // // Permission to use, copy, modify, and/or distribute this software for any // purpose with or without fee is hereby granted, provided that the above // copyright notice and this permission notice appear in all copies. // // THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH // REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY // AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT, // INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM // LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE // OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR // PERFORMANCE OF THIS SOFTWARE. #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "marker_file.h" #include "test_libraries.h" #include "test_data_files_config.h" #include #include #include #include #include #include using namespace isc; using namespace isc::asiolink; using namespace isc::config; using namespace isc::data; using namespace isc::dhcp; using namespace isc::dhcp::test; using namespace isc::hooks; using namespace std; namespace { /// @brief Prepends the given name with the DHCP4 source directory /// /// @param name file name of the desired file /// @return string containing the absolute path of the file in the DHCP source /// directory. std::string specfile(const std::string& name) { return (std::string(DHCP4_SRC_DIR) + "/" + name); } /// @brief Tests that the spec file is valid. /// Verifies that the Kea DHCPv4 configuration specification file is valid. TEST(Dhcp4SpecTest, basicSpec) { (isc::config::moduleSpecFromFile(specfile("dhcp4.spec"))); ASSERT_NO_THROW(isc::config::moduleSpecFromFile(specfile("dhcp4.spec"))); } class Dhcp4ParserTest : public ::testing::Test { protected: // Check that no hooks libraries are loaded. This is a pre-condition for // a number of tests, so is checked in one place. As this uses an // ASSERT call - and it is not clear from the documentation that Gtest // predicates can be used in a constructor - the check is placed in SetUp. virtual void SetUp() { std::vector libraries = HooksManager::getLibraryNames(); ASSERT_TRUE(libraries.empty()); } public: Dhcp4ParserTest() : rcode_(-1) { // Open port 0 means to not do anything at all. We don't want to // deal with sockets here, just check if configuration handling // is sane. srv_.reset(new Dhcpv4Srv(0)); // Create fresh context. globalContext()->copyContext(ParserContext(Option::V4)); resetConfiguration(); } public: // Checks if global parameter of name have expected_value void checkGlobalUint32(string name, uint32_t expected_value) { const Uint32StoragePtr uint32_defaults = globalContext()->uint32_values_; try { uint32_t actual_value = uint32_defaults->getParam(name); EXPECT_EQ(expected_value, actual_value); } catch (DhcpConfigError) { ADD_FAILURE() << "Expected uint32 with name " << name << " not found"; } } // Checks if the result of DHCP server configuration has // expected code (0 for success, other for failures). // Also stores result in rcode_ and comment_. void checkResult(ConstElementPtr status, int expected_code) { ASSERT_TRUE(status); comment_ = parseAnswer(rcode_, status); EXPECT_EQ(expected_code, rcode_); } ~Dhcp4ParserTest() { resetConfiguration(); // ... and delete the hooks library marker files if present unlink(LOAD_MARKER_FILE); unlink(UNLOAD_MARKER_FILE); }; /// @brief Returns an interface configuration used by the most of the /// unit tests. std::string genIfaceConfig() const { return ("\"interfaces-config\": {" " \"interfaces\": [ \"*\" ]" "}"); } /// @brief Create the simple configuration with single option. /// /// This function allows to set one of the parameters that configure /// option value. These parameters are: "name", "code", "data", /// "csv-format" and "space". /// /// @param param_value string holding option parameter value to be /// injected into the configuration string. /// @param parameter name of the parameter to be configured with /// param value. /// @return configuration string containing custom values of parameters /// describing an option. std::string createConfigWithOption(const std::string& param_value, const std::string& parameter) { std::map params; if (parameter == "name") { params["name"] = param_value; params["space"] = "dhcp4"; params["code"] = "56"; params["data"] = "ABCDEF0105"; params["csv-format"] = "False"; } else if (parameter == "space") { params["name"] = "dhcp-message"; params["space"] = param_value; params["code"] = "56"; params["data"] = "ABCDEF0105"; params["csv-format"] = "False"; } else if (parameter == "code") { params["name"] = "dhcp-message"; params["space"] = "dhcp4"; params["code"] = param_value; params["data"] = "ABCDEF0105"; params["csv-format"] = "False"; } else if (parameter == "data") { params["name"] = "dhcp-message"; params["space"] = "dhcp4"; params["code"] = "56"; params["data"] = param_value; params["csv-format"] = "False"; } else if (parameter == "csv-format") { params["name"] = "dhcp-message"; params["space"] = "dhcp4"; params["code"] = "56"; params["data"] = "ABCDEF0105"; params["csv-format"] = param_value; } return (createConfigWithOption(params)); } /// @brief Create simple configuration with single option. /// /// This function creates a configuration for a single option with /// custom values for all parameters that describe the option. /// /// @params params map holding parameters and their values. /// @return configuration string containing custom values of parameters /// describing an option. std::string createConfigWithOption(const std::map& params) { std::ostringstream stream; stream << "{ " << genIfaceConfig() << "," << "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"option-data\": [ {"; bool first = true; typedef std::pair ParamPair; BOOST_FOREACH(ParamPair param, params) { if (!first) { stream << ", "; } else { // cppcheck-suppress unreadVariable first = false; } if (param.first == "name") { stream << "\"name\": \"" << param.second << "\""; } else if (param.first == "space") { stream << "\"space\": \"" << param.second << "\""; } else if (param.first == "code") { stream << "\"code\": " << param.second << ""; } else if (param.first == "data") { stream << "\"data\": \"" << param.second << "\""; } else if (param.first == "csv-format") { stream << "\"csv-format\": " << param.second; } } stream << " } ]" " } ]," "\"valid-lifetime\": 4000 }"; return (stream.str()); } /// @brief Returns an option from the subnet. /// /// This function returns an option from a subnet to which the /// specified subnet address belongs. The option is identified /// by its code. /// /// @param subnet_address Address which belongs to the subnet from /// which the option is to be returned. /// @param option_code Code of the option to be returned. /// @param expected_options_count Expected number of options in /// the particular subnet. /// /// @return Descriptor of the option. If the descriptor holds a /// NULL option pointer, it means that there was no such option /// in the subnet. OptionDescriptor getOptionFromSubnet(const IOAddress& subnet_address, const uint16_t option_code, const uint16_t expected_options_count = 1) { Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(subnet_address); if (!subnet) { /// @todo replace toText() with the use of operator <<. ADD_FAILURE() << "A subnet for the specified address " << subnet_address.toText() << "does not exist in Config Manager"; } OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); if (expected_options_count != options->size()) { ADD_FAILURE() << "The number of options in the subnet '" << subnet_address.toText() << "' is different " " than expected number of options '" << expected_options_count << "'"; } // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx = options->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range = idx.equal_range(option_code); if (std::distance(range.first, range.second) > 1) { ADD_FAILURE() << "There is more than one option having the" " option code '" << option_code << "' in a subnet '" << subnet_address.toText() << "'. Expected " " at most one option"; } else if (std::distance(range.first, range.second) == 0) { return (OptionDescriptor(OptionPtr(), false)); } return (*range.first); } /// @brief Test invalid option parameter value. /// /// This test function constructs the simple configuration /// string and injects invalid option configuration into it. /// It expects that parser will fail with provided option code. /// /// @param param_value string holding invalid option parameter value /// to be injected into configuration string. /// @param parameter name of the parameter to be configured with /// param_value (can be any of "name", "code", "data") void testInvalidOptionParam(const std::string& param_value, const std::string& parameter) { ConstElementPtr x; std::string config = createConfigWithOption(param_value, parameter); ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); EXPECT_TRUE(errorContainsPosition(x, "")); } /// @brief Test invalid option parameter value. /// /// This test function constructs the simple configuration /// string and injects invalid option configuration into it. /// It expects that parser will fail with provided option code. /// /// @param params Map of parameters defining an option. void testInvalidOptionParam(const std::map& params) { ConstElementPtr x; std::string config = createConfigWithOption(params); ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); EXPECT_TRUE(errorContainsPosition(x, "")); } /// @brief Test option against given code and data. /// /// @param option_desc option descriptor that carries the option to /// be tested. /// @param expected_code expected code of the option. /// @param expected_data expected data in the option. /// @param expected_data_len length of the reference data. /// @param extra_data if true extra data is allowed in an option /// after tested data. void testOption(const OptionDescriptor& option_desc, uint16_t expected_code, const uint8_t* expected_data, size_t expected_data_len, bool extra_data = false) { // Check if option descriptor contains valid option pointer. ASSERT_TRUE(option_desc.option_); // Verify option type. EXPECT_EQ(expected_code, option_desc.option_->getType()); // We may have many different option types being created. Some of them // have dedicated classes derived from Option class. In such case if // we want to verify the option contents against expected_data we have // to prepare raw buffer with the contents of the option. The easiest // way is to call pack() which will prepare on-wire data. util::OutputBuffer buf(option_desc.option_->getData().size()); option_desc.option_->pack(buf); if (extra_data) { // The length of the buffer must be at least equal to size of the // reference data but it can sometimes be greater than that. This is // because some options carry suboptions that increase the overall // length. ASSERT_GE(buf.getLength() - option_desc.option_->getHeaderLen(), expected_data_len); } else { ASSERT_EQ(buf.getLength() - option_desc.option_->getHeaderLen(), expected_data_len); } // Verify that the data is correct. Do not verify suboptions and a header. const uint8_t* data = static_cast(buf.getData()); EXPECT_EQ(0, memcmp(expected_data, data + option_desc.option_->getHeaderLen(), expected_data_len)); } /// @brief Test option configuration. /// /// This function creates a configuration for a specified option using /// a map of parameters specified as the argument. The map holds /// name/value pairs which identifies option's configuration parameters: /// - name /// - space /// - code /// - data /// - csv-format. /// This function applies a new server configuration and checks that the /// option being configured is inserted into CfgMgr. The raw contents of /// this option are compared with the binary data specified as expected /// data passed to this function. /// /// @param params Map of parameters defining an option. /// @param option_code Option code. /// @param expected_data Array containing binary data expected to be stored /// in the configured option. /// @param expected_data_len Length of the array holding reference data. void testConfiguration(const std::map& params, const uint16_t option_code, const uint8_t* expected_data, const size_t expected_data_len) { std::string config = createConfigWithOption(params); ASSERT_TRUE(executeConfiguration(config, "parse option configuration")); // The subnet should now hold one option with the specified option code. OptionDescriptor desc = getOptionFromSubnet(IOAddress("192.0.2.24"), option_code); ASSERT_TRUE(desc.option_); testOption(desc, option_code, expected_data, expected_data_len); } /// @brief Parse and Execute configuration /// /// Parses a configuration and executes a configuration of the server. /// If the operation fails, the current test will register a failure. /// /// @param config Configuration to parse /// @param operation Operation being performed. In the case of an error, /// the error text will include the string "unable to .". /// /// @return true if the configuration succeeded, false if not. In the /// latter case, a failure will have been added to the current test. bool executeConfiguration(const std::string& config, const char* operation) { CfgMgr::instance().clear(); ConstElementPtr status; try { ElementPtr json = Element::fromJSON(config); status = configureDhcp4Server(*srv_, json); } catch (const std::exception& ex) { ADD_FAILURE() << "Unable to " << operation << ". " << "The following configuration was used: " << std::endl << config << std::endl << " and the following error message was returned:" << ex.what() << std::endl; return (false); } // The status object must not be NULL if (!status) { ADD_FAILURE() << "Unable to " << operation << ". " << "The configuration function returned a null pointer."; return (false); } // Store the answer if we need it. // Returned value should be 0 (configuration success) comment_ = parseAnswer(rcode_, status); if (rcode_ != 0) { string reason = ""; if (comment_) { reason = string(" (") + comment_->stringValue() + string(")"); } ADD_FAILURE() << "Unable to " << operation << ". " << "The configuration function returned error code " << rcode_ << reason; return (false); } return (true); } /// @brief Reset configuration database. /// /// This function resets configuration data base by /// removing all subnets and option-data. Reset must /// be performed after each test to make sure that /// contents of the database do not affect result of /// subsequent tests. void resetConfiguration() { string config = "{ " + genIfaceConfig() + "," + "\"hooks-libraries\": [ ], " "\"valid-lifetime\": 4000, " "\"subnet4\": [ ], " "\"dhcp-ddns\": { \"enable-updates\" : false }, " "\"option-def\": [ ], " "\"option-data\": [ ] }"; static_cast(executeConfiguration(config, "reset configuration database")); CfgMgr::instance().clear(); } boost::scoped_ptr srv_; ///< DHCP4 server under test int rcode_; ///< Return code from element parsing ConstElementPtr comment_; ///< Reason for parse fail isc::dhcp::ClientClasses classify_; ///< used in client classification }; // Goal of this test is a verification if a very simple config update // with just a bumped version number. That's the simplest possible // config update. TEST_F(Dhcp4ParserTest, version) { ConstElementPtr x; EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, Element::fromJSON("{\"version\": 0}"))); // returned value must be 0 (configuration accepted) checkResult(x, 0); } /// The goal of this test is to verify that the code accepts only /// valid commands and malformed or unsupported parameters are rejected. TEST_F(Dhcp4ParserTest, bogusCommand) { ConstElementPtr x; EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, Element::fromJSON("{\"bogus\": 5}"))); // returned value must be 1 (configuration parse error) checkResult(x, 1); } /// The goal of this test is to verify if wrongly defined subnet will /// be rejected. Properly defined subnet must include at least one /// pool definition. TEST_F(Dhcp4ParserTest, emptySubnet) { ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, Element::fromJSON("{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ ], " "\"valid-lifetime\": 4000 }"))); // returned value should be 0 (success) checkResult(status, 0); checkGlobalUint32("rebind-timer", 2000); checkGlobalUint32("renew-timer", 1000); checkGlobalUint32("valid-lifetime", 4000); } /// Check that the renew-timer doesn't have to be specified, in which case /// it is marked unspecified in the Subnet. TEST_F(Dhcp4ParserTest, unspecifiedRenewTimer) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value should be 0 (success) checkResult(status, 0); checkGlobalUint32("rebind-timer", 2000); checkGlobalUint32("valid-lifetime", 4000); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_TRUE(subnet->getT1().unspecified()); EXPECT_FALSE(subnet->getT2().unspecified()); EXPECT_EQ(2000, subnet->getT2()); EXPECT_EQ(4000, subnet->getValid()); // Check that subnet-id is 1 EXPECT_EQ(1, subnet->getID()); } /// Check that the rebind-timer doesn't have to be specified, in which case /// it is marked unspecified in the Subnet. TEST_F(Dhcp4ParserTest, unspecifiedRebindTimer) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value should be 0 (success) checkResult(status, 0); checkGlobalUint32("renew-timer", 1000); checkGlobalUint32("valid-lifetime", 4000); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_FALSE(subnet->getT1().unspecified()); EXPECT_EQ(1000, subnet->getT1()); EXPECT_TRUE(subnet->getT2().unspecified()); EXPECT_EQ(4000, subnet->getValid()); // Check that subnet-id is 1 EXPECT_EQ(1, subnet->getID()); } /// The goal of this test is to verify if defined subnet uses global /// parameter timer definitions. TEST_F(Dhcp4ParserTest, subnetGlobalDefaults) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // check if returned status is OK checkResult(status, 0); // Now check if the configuration was indeed handled and we have // expected pool configured. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ(1000, subnet->getT1()); EXPECT_EQ(2000, subnet->getT2()); EXPECT_EQ(4000, subnet->getValid()); // Check that subnet-id is 1 EXPECT_EQ(1, subnet->getID()); } // Goal of this test is to verify that multiple subnets get unique // subnet-ids. Also, test checks that it's possible to do reconfiguration // multiple times. TEST_F(Dhcp4ParserTest, multipleSubnets) { ConstElementPtr x; // Collection of four subnets for which subnet ids should be // autogenerated - ids are unspecified or set to 0. string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 0 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\" " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\" " " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); int cnt = 0; // Number of reconfigurations do { EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); CfgMgr::instance().commit(); const Subnet4Collection* subnets = CfgMgr::instance().getCurrentCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(4, subnets->size()); // We expect 4 subnets // Check subnet-ids of each subnet (it should be monotonously increasing) EXPECT_EQ(1, subnets->at(0)->getID()); EXPECT_EQ(2, subnets->at(1)->getID()); EXPECT_EQ(3, subnets->at(2)->getID()); EXPECT_EQ(4, subnets->at(3)->getID()); // Repeat reconfiguration process 10 times and check that the subnet-id // is set to the same value. Technically, just two iterations would be // sufficient, but it's nice to have a test that exercises reconfiguration // a bit. } while (++cnt < 10); } // This test checks that it is possible to assign arbitrary ids for subnets. TEST_F(Dhcp4ParserTest, multipleSubnetsExplicitIDs) { ConstElementPtr x; // Four subnets with arbitrary subnet ids. string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 1024 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 100 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"id\": 1 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\", " " \"id\": 34 " " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); int cnt = 0; // Number of reconfigurations do { EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); CfgMgr::instance().commit(); const Subnet4Collection* subnets = CfgMgr::instance().getCurrentCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(4, subnets->size()); // We expect 4 subnets // Verify that subnet ids are as expected. EXPECT_EQ(1024, subnets->at(0)->getID()); EXPECT_EQ(100, subnets->at(1)->getID()); EXPECT_EQ(1, subnets->at(2)->getID()); EXPECT_EQ(34, subnets->at(3)->getID()); // Repeat reconfiguration process 10 times and check that the subnet-id // is set to the same value. } while (++cnt < 3); } // Check that the configuration with two subnets having the same id is rejected. TEST_F(Dhcp4ParserTest, multipleSubnetsOverlapingIDs) { ConstElementPtr x; // Four subnets, two of them having the same id. string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 1024 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 100 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"id\": 1024 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\", " " \"id\": 34 " " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); EXPECT_TRUE(errorContainsPosition(x, "")); } // Goal of this test is to verify that a previously configured subnet can be // deleted in subsequent reconfiguration. TEST_F(Dhcp4ParserTest, reconfigureRemoveSubnet) { ConstElementPtr x; // All four subnets string config4 = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 1 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 2 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"id\": 3 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\", " " \"id\": 4 " " } ]," "\"valid-lifetime\": 4000 }"; // Three subnets (the last one removed) string config_first3 = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 1 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 2 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"id\": 3 " " } ]," "\"valid-lifetime\": 4000 }"; // Second subnet removed string config_second_removed = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 1 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"id\": 3 " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\", " " \"id\": 4 " " } ]," "\"valid-lifetime\": 4000 }"; // CASE 1: Configure 4 subnets, then reconfigure and remove the // last one. ElementPtr json = Element::fromJSON(config4); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); const Subnet4Collection* subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(4, subnets->size()); // We expect 4 subnets CfgMgr::instance().clear(); // Do the reconfiguration (the last subnet is removed) json = Element::fromJSON(config_first3); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(3, subnets->size()); // We expect 3 subnets now (4th is removed) // Check subnet-ids of each subnet (it should be monotonously increasing) EXPECT_EQ(1, subnets->at(0)->getID()); EXPECT_EQ(2, subnets->at(1)->getID()); EXPECT_EQ(3, subnets->at(2)->getID()); CfgMgr::instance().clear(); /// CASE 2: Configure 4 subnets, then reconfigure and remove one /// from in between (not first, not last) /// @todo: Uncomment subnet removal test as part of #3281. json = Element::fromJSON(config4); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); CfgMgr::instance().clear(); // Do reconfiguration json = Element::fromJSON(config_second_removed); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(3, subnets->size()); // We expect 4 subnets EXPECT_EQ(1, subnets->at(0)->getID()); // The second subnet (with subnet-id = 2) is no longer there EXPECT_EQ(3, subnets->at(1)->getID()); EXPECT_EQ(4, subnets->at(2)->getID()); } /// @todo: implement subnet removal test as part of #3281. // Checks if the next-server defined as global parameter is taken into // consideration. TEST_F(Dhcp4ParserTest, nextServerGlobal) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"next-server\": \"1.2.3.4\", " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // check if returned status is OK checkResult(status, 0); // Now check if the configuration was indeed handled and we have // expected pool configured. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ("1.2.3.4", subnet->getSiaddr().toText()); } // Checks if the next-server defined as subnet parameter is taken into // consideration. TEST_F(Dhcp4ParserTest, nextServerSubnet) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"next-server\": \"1.2.3.4\", " " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // check if returned status is OK checkResult(status, 0); // Now check if the configuration was indeed handled and we have // expected pool configured. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ("1.2.3.4", subnet->getSiaddr().toText()); } // Test checks several negative scenarios for next-server configuration: bogus // address, IPv6 adddress and empty string. TEST_F(Dhcp4ParserTest, nextServerNegative) { IfaceMgrTestConfig test_config(true); ConstElementPtr status; // Config with junk instead of next-server address string config_bogus1 = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"rebind-timer\": 2000, " " \"renew-timer\": 1000, " " \"next-server\": \"a.b.c.d\", " " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; // Config with IPv6 next server address string config_bogus2 = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"rebind-timer\": 2000, " " \"renew-timer\": 1000, " " \"next-server\": \"2001:db8::1\", " " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; // Config with empty next server address string config_bogus3 = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"rebind-timer\": 2000, " " \"renew-timer\": 1000, " " \"next-server\": \"\", " " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json1 = Element::fromJSON(config_bogus1); ElementPtr json2 = Element::fromJSON(config_bogus2); ElementPtr json3 = Element::fromJSON(config_bogus3); // check if returned status is always a failure EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json1)); checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); CfgMgr::instance().clear(); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json2)); checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); CfgMgr::instance().clear(); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json3)); checkResult(status, 0); EXPECT_FALSE(errorContainsPosition(status, "")); } // Checks if the next-server defined as global value is overridden by subnet // specific value. TEST_F(Dhcp4ParserTest, nextServerOverride) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"next-server\": \"192.0.0.1\", " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"next-server\": \"1.2.3.4\", " " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // check if returned status is OK checkResult(status, 0); // Now check if the configuration was indeed handled and we have // expected pool configured. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ("1.2.3.4", subnet->getSiaddr().toText()); } // Check whether it is possible to configure echo-client-id TEST_F(Dhcp4ParserTest, echoClientId) { ConstElementPtr status; string config_false = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"echo-client-id\": false," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; string config_true = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"echo-client-id\": true," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json_false = Element::fromJSON(config_false); ElementPtr json_true = Element::fromJSON(config_true); // Let's check the default. It should be true ASSERT_TRUE(CfgMgr::instance().echoClientId()); // Now check that "false" configuration is really applied. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json_false)); ASSERT_FALSE(CfgMgr::instance().echoClientId()); CfgMgr::instance().clear(); // Now check that "true" configuration is really applied. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json_true)); ASSERT_TRUE(CfgMgr::instance().echoClientId()); // In any case revert back to the default value (true) CfgMgr::instance().echoClientId(true); } // This test checks that the global match-client-id parameter is optional // and that values under the subnet are used. TEST_F(Dhcp4ParserTest, matchClientIdNoGlobal) { ConstElementPtr status; std::string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ " "{" " \"match-client-id\": true," " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" "}," "{" " \"match-client-id\": false," " \"pools\": [ { \"pool\": \"192.0.3.1 - 192.0.3.100\" } ]," " \"subnet\": \"192.0.3.0/24\"" "} ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); ASSERT_NO_THROW(status = configureDhcp4Server(*srv_, json)); checkResult(status, 0); CfgSubnets4Ptr cfg = CfgMgr::instance().getStagingCfg()->getCfgSubnets4(); Subnet4Ptr subnet1 = cfg->selectSubnet(IOAddress("192.0.2.1")); ASSERT_TRUE(subnet1); EXPECT_TRUE(subnet1->getMatchClientId()); Subnet4Ptr subnet2 = cfg->selectSubnet(IOAddress("192.0.3.1")); ASSERT_TRUE(subnet2); EXPECT_FALSE(subnet2->getMatchClientId()); } // This test checks that the global match-client-id parameter is used // when there is no such parameter under subnet and that the parameter // specified for a subnet overrides the global setting. TEST_F(Dhcp4ParserTest, matchClientIdGlobal) { ConstElementPtr status; std::string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"match-client-id\": true," "\"subnet4\": [ " "{" " \"match-client-id\": false," " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" "}," "{" " \"pools\": [ { \"pool\": \"192.0.3.1 - 192.0.3.100\" } ]," " \"subnet\": \"192.0.3.0/24\"" "} ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); ASSERT_NO_THROW(status = configureDhcp4Server(*srv_, json)); checkResult(status, 0); CfgSubnets4Ptr cfg = CfgMgr::instance().getStagingCfg()->getCfgSubnets4(); Subnet4Ptr subnet1 = cfg->selectSubnet(IOAddress("192.0.2.1")); ASSERT_TRUE(subnet1); EXPECT_FALSE(subnet1->getMatchClientId()); Subnet4Ptr subnet2 = cfg->selectSubnet(IOAddress("192.0.3.1")); ASSERT_TRUE(subnet2); EXPECT_TRUE(subnet2->getMatchClientId()); } // This test checks if it is possible to override global values // on a per subnet basis. TEST_F(Dhcp4ParserTest, subnetLocal) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"renew-timer\": 1, " " \"rebind-timer\": 2, " " \"valid-lifetime\": 4," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value should be 0 (configuration success) checkResult(status, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ(1, subnet->getT1()); EXPECT_EQ(2, subnet->getT2()); EXPECT_EQ(4, subnet->getValid()); } // This test checks that multiple pools can be defined and handled properly. // The test defines 2 subnets, each with 2 pools. TEST_F(Dhcp4ParserTest, multiplePools) { // Collection with two subnets, each with 2 pools. string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ " " { \"pool\": \"192.0.2.0/28\" }," " { \"pool\": \"192.0.2.200-192.0.2.255\" }" " ]," " \"subnet\": \"192.0.2.0/24\" " " }," " {" " \"pools\": [ " " { \"pool\": \"192.0.3.0/25\" }," " { \"pool\": \"192.0.3.128/25\" }" " ]," " \"subnet\": \"192.0.3.0/24\"" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json; ASSERT_NO_THROW(json = Element::fromJSON(config)); ConstElementPtr status; ASSERT_NO_THROW(status = configureDhcp4Server(*srv_, json)); checkResult(status, 0); const Subnet4Collection* subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(2, subnets->size()); // We expect 2 subnets // Check the first subnet const PoolCollection& pools1 = subnets->at(0)->getPools(Lease::TYPE_V4); ASSERT_EQ(2, pools1.size()); EXPECT_EQ("type=V4, 192.0.2.0-192.0.2.15", pools1[0]->toText()); EXPECT_EQ("type=V4, 192.0.2.200-192.0.2.255", pools1[1]->toText()); // There shouldn't be any TA or PD pools EXPECT_THROW(subnets->at(0)->getPools(Lease::TYPE_TA), BadValue); EXPECT_THROW(subnets->at(0)->getPools(Lease::TYPE_PD), BadValue); // Check the second subnet const PoolCollection& pools2 = subnets->at(1)->getPools(Lease::TYPE_V4); ASSERT_EQ(2, pools2.size()); EXPECT_EQ("type=V4, 192.0.3.0-192.0.3.127", pools2[0]->toText()); EXPECT_EQ("type=V4, 192.0.3.128-192.0.3.255", pools2[1]->toText()); // There shouldn't be any TA or PD pools EXPECT_THROW(subnets->at(0)->getPools(Lease::TYPE_TA).empty(), BadValue); EXPECT_THROW(subnets->at(0)->getPools(Lease::TYPE_PD).empty(), BadValue); } // Test verifies that a subnet with pool values that do not belong to that // pool are rejected. TEST_F(Dhcp4ParserTest, poolOutOfSubnet) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.4.0/28\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value must be 1 (values error) // as the pool does not belong to that subnet checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } // Goal of this test is to verify if pools can be defined // using prefix/length notation. There is no separate test for min-max // notation as it was tested in several previous tests. TEST_F(Dhcp4ParserTest, poolPrefixLen) { ConstElementPtr status; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.128/28\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value must be 0 (configuration accepted) checkResult(status, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ(1000, subnet->getT1()); EXPECT_EQ(2000, subnet->getT2()); EXPECT_EQ(4000, subnet->getValid()); } // The goal of this test is to check whether an option definition // that defines an option carrying an IPv4 address can be created. TEST_F(Dhcp4ParserTest, optionDefIpv4Address) { // Configuration string. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the particular option definition does not exist. OptionDefinitionPtr def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_FALSE(def); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // The option definition should now be available in the CfgMgr. def = CfgMgr::instance().getStagingCfg()->getCfgOptionDef()->get("isc", 100); ASSERT_TRUE(def); // Verify that the option definition data is valid. EXPECT_EQ("foo", def->getName()); EXPECT_EQ(100, def->getCode()); EXPECT_FALSE(def->getArrayType()); EXPECT_EQ(OPT_IPV4_ADDRESS_TYPE, def->getType()); EXPECT_TRUE(def->getEncapsulatedSpace().empty()); } // The goal of this test is to check whether an option definition // that defines an option carrying a record of data fields can // be created. TEST_F(Dhcp4ParserTest, optionDefRecord) { // Configuration string. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"record\"," " \"array\": False," " \"record-types\": \"uint16, ipv4-address, ipv6-address, string\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the particular option definition does not exist. OptionDefinitionPtr def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_FALSE(def); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // The option definition should now be available in the CfgMgr. def = CfgMgr::instance().getStagingCfg()->getCfgOptionDef()->get("isc", 100); ASSERT_TRUE(def); // Check the option data. EXPECT_EQ("foo", def->getName()); EXPECT_EQ(100, def->getCode()); EXPECT_EQ(OPT_RECORD_TYPE, def->getType()); EXPECT_FALSE(def->getArrayType()); EXPECT_TRUE(def->getEncapsulatedSpace().empty()); // The option comprises the record of data fields. Verify that all // fields are present and they are of the expected types. const OptionDefinition::RecordFieldsCollection& record_fields = def->getRecordFields(); ASSERT_EQ(4, record_fields.size()); EXPECT_EQ(OPT_UINT16_TYPE, record_fields[0]); EXPECT_EQ(OPT_IPV4_ADDRESS_TYPE, record_fields[1]); EXPECT_EQ(OPT_IPV6_ADDRESS_TYPE, record_fields[2]); EXPECT_EQ(OPT_STRING_TYPE, record_fields[3]); } // The goal of this test is to verify that multiple option definitions // can be created. TEST_F(Dhcp4ParserTest, optionDefMultiple) { // Configuration string. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo-2\"," " \"code\": 101," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the option definitions do not exist yet. ASSERT_FALSE(CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100)); ASSERT_FALSE(CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 101)); // Use the configuration string to create new option definitions. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Check the first definition we have created. OptionDefinitionPtr def1 = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_TRUE(def1); // Check the option data. EXPECT_EQ("foo", def1->getName()); EXPECT_EQ(100, def1->getCode()); EXPECT_EQ(OPT_UINT32_TYPE, def1->getType()); EXPECT_FALSE(def1->getArrayType()); EXPECT_TRUE(def1->getEncapsulatedSpace().empty()); // Check the second option definition we have created. OptionDefinitionPtr def2 = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 101); ASSERT_TRUE(def2); // Check the option data. EXPECT_EQ("foo-2", def2->getName()); EXPECT_EQ(101, def2->getCode()); EXPECT_EQ(OPT_IPV4_ADDRESS_TYPE, def2->getType()); EXPECT_FALSE(def2->getArrayType()); EXPECT_TRUE(def2->getEncapsulatedSpace().empty()); } // The goal of this test is to verify that the duplicated option // definition is not accepted. TEST_F(Dhcp4ParserTest, optionDefDuplicate) { // Configuration string. Both option definitions have // the same code and belong to the same option space. // This configuration should not be accepted. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo-2\"," " \"code\": 100," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the option definition does not exist yet. ASSERT_FALSE(CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100)); // Use the configuration string to create new option definitions. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } // The goal of this test is to verify that the option definition // comprising an array of uint32 values can be created. TEST_F(Dhcp4ParserTest, optionDefArray) { // Configuration string. Created option definition should // comprise an array of uint32 values. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": True," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the particular option definition does not exist. OptionDefinitionPtr def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_FALSE(def); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // The option definition should now be available in the CfgMgr. def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_TRUE(def); // Check the option data. EXPECT_EQ("foo", def->getName()); EXPECT_EQ(100, def->getCode()); EXPECT_EQ(OPT_UINT32_TYPE, def->getType()); EXPECT_TRUE(def->getArrayType()); EXPECT_TRUE(def->getEncapsulatedSpace().empty()); } // The purpose of this test to verify that encapsulated option // space name may be specified. TEST_F(Dhcp4ParserTest, optionDefEncapsulate) { // Configuration string. Included the encapsulated // option space name. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"sub-opts-space\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Make sure that the particular option definition does not exist. OptionDefinitionPtr def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_FALSE(def); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // The option definition should now be available in the CfgMgr. def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("isc", 100); ASSERT_TRUE(def); // Check the option data. EXPECT_EQ("foo", def->getName()); EXPECT_EQ(100, def->getCode()); EXPECT_EQ(OPT_UINT32_TYPE, def->getType()); EXPECT_FALSE(def->getArrayType()); EXPECT_EQ("sub-opts-space", def->getEncapsulatedSpace()); } /// The purpose of this test is to verify that the option definition /// with invalid name is not accepted. TEST_F(Dhcp4ParserTest, optionDefInvalidName) { // Configuration string. The option name is invalid as it // contains the % character. std::string config = "{ \"option-def\": [ {" " \"name\": \"invalid%name\"," " \"code\": 100," " \"type\": \"string\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The purpose of this test is to verify that the option definition /// with invalid type is not accepted. TEST_F(Dhcp4ParserTest, optionDefInvalidType) { // Configuration string. The option type is invalid. It is // "sting" instead of "string". std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"sting\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The purpose of this test is to verify that the option definition /// with invalid type is not accepted. TEST_F(Dhcp4ParserTest, optionDefInvalidRecordType) { // Configuration string. The third of the record fields // is invalid. It is "sting" instead of "string". std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"record\"," " \"array\": False," " \"record-types\": \"uint32,uint8,sting\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The goal of this test is to verify that the invalid encapsulated /// option space name is not accepted. TEST_F(Dhcp4ParserTest, optionDefInvalidEncapsulatedSpace) { // Configuration string. The encapsulated option space // name is invalid (% character is not allowed). std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"invalid%space%name\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The goal of this test is to verify that the encapsulated /// option space name can't be specified for the option that /// comprises an array of data fields. TEST_F(Dhcp4ParserTest, optionDefEncapsulatedSpaceAndArray) { // Configuration string. The encapsulated option space // name is set to non-empty value and the array flag // is set. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": True," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"valid-space-name\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The goal of this test is to verify that the option may not /// encapsulate option space it belongs to. TEST_F(Dhcp4ParserTest, optionDefEncapsulateOwnSpace) { // Configuration string. Option is set to encapsulate // option space it belongs to. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"isc\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } /// The purpose of this test is to verify that it is not allowed /// to override the standard option (that belongs to dhcp4 option /// space and has its definition) and that it is allowed to define /// option in the dhcp4 option space that has a code which is not /// used by any of the standard options. TEST_F(Dhcp4ParserTest, optionStandardDefOverride) { // Configuration string. The option code 109 is unassigned so it // can be used for a custom option definition in dhcp4 option space. std::string config = "{ \"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 109," " \"type\": \"string\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"dhcp4\"," " \"encapsulate\": \"\"" " } ]" "}"; ElementPtr json = Element::fromJSON(config); OptionDefinitionPtr def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("dhcp4", 109); ASSERT_FALSE(def); // Use the configuration string to create new option definition. ConstElementPtr status; EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // The option definition should now be available in the CfgMgr. def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("dhcp4", 109); ASSERT_TRUE(def); // Check the option data. EXPECT_EQ("foo", def->getName()); EXPECT_EQ(109, def->getCode()); EXPECT_EQ(OPT_STRING_TYPE, def->getType()); EXPECT_FALSE(def->getArrayType()); // The combination of option space and code is invalid. The 'dhcp4' option // space groups standard options and the code 3 is reserved for one of // them. config = "{ \"option-def\": [ {" " \"name\": \"routers\"," " \"code\": 3," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"dhcp4\"," " \"encapsulate\": \"\"" " } ]" "}"; json = Element::fromJSON(config); // Use the configuration string to create new option definition. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting parsing error (error code 1). checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); /// @todo The option 65 is a standard DHCPv4 option. However, at this point /// there is no definition for this option in libdhcp++, so it should be /// allowed to define it from the configuration interface. This test will /// have to be removed once definitions for remaining standard options are /// created. config = "{ \"option-def\": [ {" " \"name\": \"nis-server-addr\"," " \"code\": 65," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"dhcp4\"," " \"encapsulate\": \"\"" " } ]" "}"; json = Element::fromJSON(config); // Use the configuration string to create new option definition. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); // Expecting success. checkResult(status, 0); def = CfgMgr::instance().getStagingCfg()-> getCfgOptionDef()->get("dhcp4", 65); ASSERT_TRUE(def); // Check the option data. EXPECT_EQ("nis-server-addr", def->getName()); EXPECT_EQ(65, def->getCode()); EXPECT_EQ(OPT_IPV4_ADDRESS_TYPE, def->getType()); EXPECT_FALSE(def->getArrayType()); } // Goal of this test is to verify that global option // data is configured for the subnet if the subnet // configuration does not include options configuration. TEST_F(Dhcp4ParserTest, optionDataDefaults) { ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"ABCDEF0105\"," " \"csv-format\": False" " }," " {" " \"name\": \"default-ip-ttl\"," " \"space\": \"dhcp4\"," " \"code\": 23," " \"data\": \"01\"," " \"csv-format\": False" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_EQ(2, options->size()); // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx = options->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range = idx.equal_range(56); // Expect single option with the code equal to 56. ASSERT_EQ(1, std::distance(range.first, range.second)); const uint8_t foo_expected[] = { 0xAB, 0xCD, 0xEF, 0x01, 0x05 }; // Check if option is valid in terms of code and carried data. testOption(*range.first, 56, foo_expected, sizeof(foo_expected)); range = idx.equal_range(23); ASSERT_EQ(1, std::distance(range.first, range.second)); // Do another round of testing with second option. const uint8_t foo2_expected[] = { 0x01 }; testOption(*range.first, 23, foo2_expected, sizeof(foo2_expected)); } /// The goal of this test is to verify that two options having the same /// option code can be added to different option spaces. TEST_F(Dhcp4ParserTest, optionDataTwoSpaces) { // This configuration string is to configure two options // sharing the code 56 and having different definitions // and belonging to the different option spaces. // The option definition must be provided for the // option that belongs to the 'isc' option space. // The definition is not required for the option that // belongs to the 'dhcp4' option space as it is the // standard option. string config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"ABCDEF0105\"," " \"csv-format\": False" " }," " {" " \"name\": \"foo\"," " \"space\": \"isc\"," " \"code\": 56," " \"data\": \"1234\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 56," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]" "}"; ConstElementPtr status; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Options should be now available for the subnet. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); // Try to get the option from the space dhcp4. OptionDescriptor desc1 = subnet->getCfgOption()->get("dhcp4", 56); ASSERT_TRUE(desc1.option_); EXPECT_EQ(56, desc1.option_->getType()); // Try to get the option from the space isc. OptionDescriptor desc2 = subnet->getCfgOption()->get("isc", 56); ASSERT_TRUE(desc2.option_); EXPECT_EQ(56, desc1.option_->getType()); // Try to get the non-existing option from the non-existing // option space and expect that option is not returned. OptionDescriptor desc3 = subnet->getCfgOption()->get("non-existing", 56); ASSERT_FALSE(desc3.option_); } // The goal of this test is to verify that it is possible to // encapsulate option space containing some options with // another option. In this test we create base option that // encapsulates option space 'isc' that comprises two other // options. Also, for all options their definitions are // created. TEST_F(Dhcp4ParserTest, optionDataEncapsulate) { // @todo DHCP configurations has many dependencies between // parameters. First of all, configuration for subnet is // inherited from the global values. Thus subnet has to be // configured when all global values have been configured. // Also, an option can encapsulate another option only // if the latter has been configured. For this reason in this // test we created two-stage configuration where first we // created options that belong to encapsulated option space. // In the second stage we add the base option. Also, the Subnet // object is configured in the second stage so it is created // at the very end (when all other parameters are configured). // Starting stage 1. Configure sub-options and their definitions. string config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"foo\"," " \"space\": \"isc\"," " \"code\": 1," " \"data\": \"1234\"," " \"csv-format\": True" " }," " {" " \"name\": \"foo2\"," " \"space\": \"isc\"," " \"code\": 2," " \"data\": \"192.168.2.1\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 1," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo2\"," " \"code\": 2," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]" "}"; ConstElementPtr status; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); CfgMgr::instance().clear(); // Stage 2. Configure base option and a subnet. Please note that // the configuration from the stage 2 is repeated because BIND // configuration manager sends whole configuration for the lists // where at least one element is being modified or added. config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 3000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"base-option\"," " \"space\": \"dhcp4\"," " \"code\": 222," " \"data\": \"11\"," " \"csv-format\": True" " }," " {" " \"name\": \"foo\"," " \"space\": \"isc\"," " \"code\": 1," " \"data\": \"1234\"," " \"csv-format\": True" " }," " {" " \"name\": \"foo2\"," " \"space\": \"isc\"," " \"code\": 2," " \"data\": \"192.168.2.1\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"base-option\"," " \"code\": 222," " \"type\": \"uint8\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"dhcp4\"," " \"encapsulate\": \"isc\"" "}," "{" " \"name\": \"foo\"," " \"code\": 1," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo2\"," " \"code\": 2," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]" "}"; json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Get the subnet. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); // We should have one option available. OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_TRUE(options); ASSERT_EQ(1, options->size()); // Get the option. OptionDescriptor desc = subnet->getCfgOption()->get("dhcp4", 222); EXPECT_TRUE(desc.option_); EXPECT_EQ(222, desc.option_->getType()); // This option should comprise two sub-options. // One of them is 'foo' with code 1. OptionPtr option_foo = desc.option_->getOption(1); ASSERT_TRUE(option_foo); EXPECT_EQ(1, option_foo->getType()); // ...another one 'foo2' with code 2. OptionPtr option_foo2 = desc.option_->getOption(2); ASSERT_TRUE(option_foo2); EXPECT_EQ(2, option_foo2->getType()); } // Goal of this test is to verify options configuration // for a single subnet. In particular this test checks // that local options configuration overrides global // option setting. TEST_F(Dhcp4ParserTest, optionDataInSingleSubnet) { ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"AB\"," " \"csv-format\": False" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"ABCDEF0105\"," " \"csv-format\": False" " }," " {" " \"name\": \"default-ip-ttl\"," " \"space\": \"dhcp4\"," " \"code\": 23," " \"data\": \"01\"," " \"csv-format\": False" " } ]" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.24")); ASSERT_TRUE(subnet); OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_EQ(2, options->size()); // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx = options->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range = idx.equal_range(56); // Expect single option with the code equal to 100. ASSERT_EQ(1, std::distance(range.first, range.second)); const uint8_t foo_expected[] = { 0xAB, 0xCD, 0xEF, 0x01, 0x05 }; // Check if option is valid in terms of code and carried data. testOption(*range.first, 56, foo_expected, sizeof(foo_expected)); range = idx.equal_range(23); ASSERT_EQ(1, std::distance(range.first, range.second)); // Do another round of testing with second option. const uint8_t foo2_expected[] = { 0x01 }; testOption(*range.first, 23, foo2_expected, sizeof(foo2_expected)); } // The goal of this test is to check that the option carrying a boolean // value can be configured using one of the values: "true", "false", "0" // or "1". TEST_F(Dhcp4ParserTest, optionDataBoolean) { // Create configuration. Use standard option 19 (ip-forwarding). std::map params; params["name"] = "ip-forwarding"; params["space"] = "dhcp4"; params["code"] = "19"; params["data"] = "true"; params["csv-format"] = "true"; std::string config = createConfigWithOption(params); ASSERT_TRUE(executeConfiguration(config, "parse configuration with a" " boolean value")); // The subnet should now hold one option with the code 19. OptionDescriptor desc = getOptionFromSubnet(IOAddress("192.0.2.24"), 19); ASSERT_TRUE(desc.option_); // This option should be set to "true", represented as 0x1 in the option // buffer. uint8_t expected_option_data[] = { 0x1 }; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // Configure the option with the "1" value. This should have the same // effect as if "true" was specified. params["data"] = "1"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // The value of "1" with a few leading zeros should work too. params["data"] = "00001"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // Configure the option with the "false" value. params["data"] = "false"; // The option buffer should now hold the value of 0. expected_option_data[0] = 0; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // Specifying "0" should have the same effect as "false". params["data"] = "0"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // The same effect should be for multiple 0 chars. params["data"] = "00000"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // Bogus values should not be accepted. params["data"] = "bugus"; testInvalidOptionParam(params); params["data"] = "2"; testInvalidOptionParam(params); // Now let's test that it is possible to use binary format. params["data"] = "0"; params["csv-format"] = "false"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // The binary 1 should work as well. params["data"] = "1"; expected_option_data[0] = 1; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); // As well as an even number of digits. params["data"] = "01"; testConfiguration(params, 19, expected_option_data, sizeof(expected_option_data)); } // Goal of this test is to verify options configuration // for multiple subnets. TEST_F(Dhcp4ParserTest, optionDataInMultipleSubnets) { ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"0102030405060708090A\"," " \"csv-format\": False" " } ]" " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"option-data\": [ {" " \"name\": \"default-ip-ttl\"," " \"space\": \"dhcp4\"," " \"code\": 23," " \"data\": \"FF\"," " \"csv-format\": False" " } ]" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); Subnet4Ptr subnet1 = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.100")); ASSERT_TRUE(subnet1); OptionContainerPtr options1 = subnet1->getCfgOption()->getAll("dhcp4"); ASSERT_EQ(1, options1->size()); // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx1 = options1->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range1 = idx1.equal_range(56); // Expect single option with the code equal to 56. ASSERT_EQ(1, std::distance(range1.first, range1.second)); const uint8_t foo_expected[] = { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A }; // Check if option is valid in terms of code and carried data. testOption(*range1.first, 56, foo_expected, sizeof(foo_expected)); // Test another subnet in the same way. Subnet4Ptr subnet2 = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.3.102")); ASSERT_TRUE(subnet2); OptionContainerPtr options2 = subnet2->getCfgOption()->getAll("dhcp4"); ASSERT_EQ(1, options2->size()); const OptionContainerTypeIndex& idx2 = options2->get<1>(); std::pair range2 = idx2.equal_range(23); ASSERT_EQ(1, std::distance(range2.first, range2.second)); const uint8_t foo2_expected[] = { 0xFF }; testOption(*range2.first, 23, foo2_expected, sizeof(foo2_expected)); } // Verify that empty option name is rejected in the configuration. TEST_F(Dhcp4ParserTest, optionNameEmpty) { // Empty option names not allowed. testInvalidOptionParam("", "name"); } // Verify that empty option name with spaces is rejected // in the configuration. TEST_F(Dhcp4ParserTest, optionNameSpaces) { // Spaces in option names not allowed. testInvalidOptionParam("option foo", "name"); } // Verify that negative option code is rejected in the configuration. TEST_F(Dhcp4ParserTest, optionCodeNegative) { // Check negative option code -4. This should fail too. testInvalidOptionParam("-4", "code"); } // Verify that out of bounds option code is rejected in the configuration. TEST_F(Dhcp4ParserTest, optionCodeNonUint8) { // The valid option codes are uint16_t values so passing // uint16_t maximum value incremented by 1 should result // in failure. testInvalidOptionParam("257", "code"); } // Verify that zero option code is rejected in the configuration. TEST_F(Dhcp4ParserTest, optionCodeZero) { // Option code 0 is reserved and should not be accepted // by configuration parser. testInvalidOptionParam("0", "code"); } // Verify that option data which contains non hexadecimal characters // is rejected by the configuration. TEST_F(Dhcp4ParserTest, optionDataInvalidChar) { // Option code 0 is reserved and should not be accepted // by configuration parser. testInvalidOptionParam("01020R", "data"); } // Verify that option data containing '0x' prefix is rejected // by the configuration. TEST_F(Dhcp4ParserTest, optionDataUnexpectedPrefix) { // Option code 0 is reserved and should not be accepted // by configuration parser. testInvalidOptionParam("0x0102", "data"); } // Verify that either lower or upper case characters are allowed // to specify the option data. TEST_F(Dhcp4ParserTest, optionDataLowerCase) { ConstElementPtr x; std::string config = createConfigWithOption("0a0b0C0D", "data"); ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_EQ(1, options->size()); // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx = options->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range = idx.equal_range(56); // Expect single option with the code equal to 100. ASSERT_EQ(1, std::distance(range.first, range.second)); const uint8_t foo_expected[] = { 0x0A, 0x0B, 0x0C, 0x0D }; // Check if option is valid in terms of code and carried data. testOption(*range.first, 56, foo_expected, sizeof(foo_expected)); } // Verify that specific option object is returned for standard // option which has dedicated option class derived from Option. TEST_F(Dhcp4ParserTest, stdOptionData) { ConstElementPtr x; std::map params; params["name"] = "nis-servers"; params["space"] = "dhcp4"; // Option code 41 means nis-servers. params["code"] = "41"; // Specify option values in a CSV (user friendly) format. params["data"] = "192.0.2.10, 192.0.2.1, 192.0.2.3"; params["csv-format"] = "True"; std::string config = createConfigWithOption(params); ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_TRUE(options); ASSERT_EQ(1, options->size()); // Get the search index. Index #1 is to search using option code. const OptionContainerTypeIndex& idx = options->get<1>(); // Get the options for specified index. Expecting one option to be // returned but in theory we may have multiple options with the same // code so we get the range. std::pair range = idx.equal_range(DHO_NIS_SERVERS); // Expect single option with the code equal to NIS_SERVERS option code. ASSERT_EQ(1, std::distance(range.first, range.second)); // The actual pointer to the option is held in the option field // in the structure returned. OptionPtr option = range.first->option_; ASSERT_TRUE(option); // Option object returned for here is expected to be Option6IA // which is derived from Option. This class is dedicated to // represent standard option IA_NA. boost::shared_ptr option_addrs = boost::dynamic_pointer_cast(option); // If cast is unsuccessful than option returned was of a // different type than Option6IA. This is wrong. ASSERT_TRUE(option_addrs); // Get addresses from the option. Option4AddrLst::AddressContainer addrs = option_addrs->getAddresses(); // Verify that the addresses have been configured correctly. ASSERT_EQ(3, addrs.size()); EXPECT_EQ("192.0.2.10", addrs[0].toText()); EXPECT_EQ("192.0.2.1", addrs[1].toText()); EXPECT_EQ("192.0.2.3", addrs[2].toText()); } /// This test checks if Uint32Parser can really parse the whole range /// and properly err of out of range values. As we can't call Uint32Parser /// directly, we are exploiting the fact that it is used to parse global /// parameter renew-timer and the results are stored in uint32_defaults. /// We get the uint32_defaults using a getUint32Defaults functions which /// is defined only to access the values from this test. TEST_F(Dhcp4ParserTest, DISABLED_Uint32Parser) { ConstElementPtr status; // CASE 1: 0 - minimum value, should work EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, Element::fromJSON("{\"version\": 0," "\"renew-timer\": 0}"))); // returned value must be ok (0 is a proper value) checkResult(status, 0); checkGlobalUint32("renew-timer", 0); // CASE 2: 4294967295U (UINT_MAX) should work as well EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, Element::fromJSON("{\"version\": 0," "\"renew-timer\": 4294967295}"))); // returned value must be ok (0 is a proper value) checkResult(status, 0); checkGlobalUint32("renew-timer", 4294967295U); // CASE 3: 4294967296U (UINT_MAX + 1) should not work EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, Element::fromJSON("{\"version\": 0," "\"renew-timer\": 4294967296}"))); // returned value must be rejected (1 configuration error) checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); // CASE 4: -1 (UINT_MIN -1 ) should not work EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, Element::fromJSON("{\"version\": 0," "\"renew-timer\": -1}"))); // returned value must be rejected (1 configuration error) checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); } // The goal of this test is to verify that the standard option can // be configured to encapsulate multiple other options. TEST_F(Dhcp4ParserTest, stdOptionDataEncapsulate) { // The configuration is two stage process in this test. // In the first stage we create definitions of suboptions // that we will add to the base option. // Let's create some dummy options: foo and foo2. string config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"foo\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"code\": 1," " \"data\": \"1234\"," " \"csv-format\": True" " }," " {" " \"name\": \"foo2\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"code\": 2," " \"data\": \"192.168.2.1\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 1," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo2\"," " \"code\": 2," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"encapsulate\": \"\"" " } ]" "}"; ConstElementPtr status; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); CfgMgr::instance().clear(); // Once the definitions have been added we can configure the // standard option #17. This option comprises an enterprise // number and sub options. By convention (introduced in // std_option_defs.h) option named 'vendor-opts' // encapsulates the option space named 'vendor-opts-space'. // We add our dummy options to this option space and thus // they should be included as sub-options in the 'vendor-opts' // option. config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 3000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"vendor-encapsulated-options\"," " \"space\": \"dhcp4\"," " \"code\": 43," " \"data\": \"\"," " \"csv-format\": False" " }," " {" " \"name\": \"foo\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"code\": 1," " \"data\": \"1234\"," " \"csv-format\": True" " }," " {" " \"name\": \"foo2\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"code\": 2," " \"data\": \"192.168.2.1\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 1," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"encapsulate\": \"\"" " }," " {" " \"name\": \"foo2\"," " \"code\": 2," " \"type\": \"ipv4-address\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"vendor-encapsulated-options-space\"," " \"encapsulate\": \"\"" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]" "}"; json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Get the subnet. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); // We should have one option available. OptionContainerPtr options = subnet->getCfgOption()->getAll("dhcp4"); ASSERT_TRUE(options); ASSERT_EQ(1, options->size()); // Get the option. OptionDescriptor desc = subnet->getCfgOption()->get("dhcp4", DHO_VENDOR_ENCAPSULATED_OPTIONS); EXPECT_TRUE(desc.option_); EXPECT_EQ(DHO_VENDOR_ENCAPSULATED_OPTIONS, desc.option_->getType()); // Option with the code 1 should be added as a sub-option. OptionPtr option_foo = desc.option_->getOption(1); ASSERT_TRUE(option_foo); EXPECT_EQ(1, option_foo->getType()); // This option comprises a single uint32_t value thus it is // represented by OptionInt class. Let's get the // object of this type. boost::shared_ptr > option_foo_uint32 = boost::dynamic_pointer_cast >(option_foo); ASSERT_TRUE(option_foo_uint32); // Validate the value according to the configuration. EXPECT_EQ(1234, option_foo_uint32->getValue()); // Option with the code 2 should be added as a sub-option. OptionPtr option_foo2 = desc.option_->getOption(2); ASSERT_TRUE(option_foo2); EXPECT_EQ(2, option_foo2->getType()); // This option comprises the IPV4 address. Such option is // represented by OptionCustom object. OptionCustomPtr option_foo2_v4 = boost::dynamic_pointer_cast(option_foo2); ASSERT_TRUE(option_foo2_v4); // Get the IP address carried by this option and validate it. EXPECT_EQ("192.168.2.1", option_foo2_v4->readAddress().toText()); // Option with the code 3 should not be added. EXPECT_FALSE(desc.option_->getOption(3)); } // This test checks if vendor options can be specified in the config file // (in hex format), and later retrieved from configured subnet TEST_F(Dhcp4ParserTest, vendorOptionsHex) { // This configuration string is to configure two options // sharing the code 1 and belonging to the different vendor spaces. // (different vendor-id values). string config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"option-one\"," " \"space\": \"vendor-4491\"," // VENDOR_ID_CABLE_LABS = 4491 " \"code\": 100," // just a random code " \"data\": \"ABCDEF0105\"," " \"csv-format\": False" " }," " {" " \"name\": \"option-two\"," " \"space\": \"vendor-1234\"," " \"code\": 100," " \"data\": \"1234\"," " \"csv-format\": False" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1-192.0.2.10\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]" "}"; ConstElementPtr status; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Options should be now available for the subnet. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); // Try to get the option from the vendor space 4491 OptionDescriptor desc1 = subnet->getCfgOption()->get(VENDOR_ID_CABLE_LABS, 100); ASSERT_TRUE(desc1.option_); EXPECT_EQ(100, desc1.option_->getType()); // Try to get the option from the vendor space 1234 OptionDescriptor desc2 = subnet->getCfgOption()->get(1234, 100); ASSERT_TRUE(desc2.option_); EXPECT_EQ(100, desc1.option_->getType()); // Try to get the non-existing option from the non-existing // option space and expect that option is not returned. OptionDescriptor desc3 = subnet->getCfgOption()->get(5678, 100); ASSERT_FALSE(desc3.option_); } // This test checks if vendor options can be specified in the config file, // (in csv format), and later retrieved from configured subnet TEST_F(Dhcp4ParserTest, vendorOptionsCsv) { // This configuration string is to configure two options // sharing the code 1 and belonging to the different vendor spaces. // (different vendor-id values). string config = "{ " + genIfaceConfig() + "," + "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"foo\"," " \"space\": \"vendor-4491\"," " \"code\": 100," " \"data\": \"this is a string vendor-opt\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 100," " \"type\": \"string\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"vendor-4491\"," " \"encapsulate\": \"\"" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" " " } ]" "}"; ConstElementPtr status; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); // Options should be now available for the subnet. Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.5")); ASSERT_TRUE(subnet); // Try to get the option from the vendor space 4491 OptionDescriptor desc1 = subnet->getCfgOption()->get(VENDOR_ID_CABLE_LABS, 100); ASSERT_TRUE(desc1.option_); EXPECT_EQ(100, desc1.option_->getType()); // Try to get the non-existing option from the non-existing // option space and expect that option is not returned. OptionDescriptor desc2 = subnet->getCfgOption()->get(5678, 100); ASSERT_FALSE(desc2.option_); } // Tests of the hooks libraries configuration. All tests have the pre- // condition (checked in the test fixture's SetUp() method) that no hooks // libraries are loaded at the start of the tests. // Helper function to return a configuration containing an arbitrary number // of hooks libraries. std::string buildHooksLibrariesConfig(const std::vector& libraries) { const string quote("\""); // Create the first part of the configuration string. string config = "{ \"interfaces-config\": {" " \"interfaces\": [ \"*\" ]" "}," "\"hooks-libraries\": ["; // Append the libraries (separated by commas if needed) for (int i = 0; i < libraries.size(); ++i) { if (i > 0) { config += string(", "); } config += (quote + libraries[i] + quote); } // Append the remainder of the configuration. config += string( "]," "\"valid-lifetime\": 4000," "\"rebind-timer\": 2000," "\"renew-timer\": 1000," "\"option-data\": [ {" " \"name\": \"dhcp-message\"," " \"space\": \"dhcp4\"," " \"code\": 56," " \"data\": \"ABCDEF0105\"," " \"csv-format\": False" " }," " {" " \"name\": \"foo\"," " \"space\": \"isc\"," " \"code\": 56," " \"data\": \"1234\"," " \"csv-format\": True" " } ]," "\"option-def\": [ {" " \"name\": \"foo\"," " \"code\": 56," " \"type\": \"uint32\"," " \"array\": False," " \"record-types\": \"\"," " \"space\": \"isc\"," " \"encapsulate\": \"\"" " } ]," "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\"" " } ]" "}"); return (config); } // Convenience function for creating hooks library configuration with one or // two character string constants. std::string buildHooksLibrariesConfig(const char* library1 = NULL, const char* library2 = NULL) { std::vector libraries; if (library1 != NULL) { libraries.push_back(string(library1)); if (library2 != NULL) { libraries.push_back(string(library2)); } } return (buildHooksLibrariesConfig(libraries)); } // The goal of this test is to verify the configuration of hooks libraries if // none are specified. TEST_F(Dhcp4ParserTest, NoHooksLibraries) { // Parse a configuration containing no names. string config = buildHooksLibrariesConfig(); if (!executeConfiguration(config, "set configuration with no hooks libraries")) { FAIL() << "Unable to execute configuration"; } else { // No libraries should be loaded at the end of the test. std::vector libraries = HooksManager::getLibraryNames(); EXPECT_TRUE(libraries.empty()); } } // Verify parsing fails with one library that will fail validation. TEST_F(Dhcp4ParserTest, InvalidLibrary) { // Parse a configuration containing a failing library. string config = buildHooksLibrariesConfig(NOT_PRESENT_LIBRARY); ConstElementPtr status; ElementPtr json = Element::fromJSON(config); ASSERT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // The status object must not be NULL ASSERT_TRUE(status); // Returned value should not be 0 comment_ = parseAnswer(rcode_, status); EXPECT_NE(0, rcode_); } // Verify the configuration of hooks libraries with two being specified. TEST_F(Dhcp4ParserTest, LibrariesSpecified) { // Marker files should not be present. EXPECT_FALSE(checkMarkerFileExists(LOAD_MARKER_FILE)); EXPECT_FALSE(checkMarkerFileExists(UNLOAD_MARKER_FILE)); // Set up the configuration with two libraries and load them. string config = buildHooksLibrariesConfig(CALLOUT_LIBRARY_1, CALLOUT_LIBRARY_2); ASSERT_TRUE(executeConfiguration(config, "load two valid libraries")); // Expect two libraries to be loaded in the correct order (load marker file // is present, no unload marker file). std::vector libraries = HooksManager::getLibraryNames(); ASSERT_EQ(2, libraries.size()); EXPECT_TRUE(checkMarkerFile(LOAD_MARKER_FILE, "12")); EXPECT_FALSE(checkMarkerFileExists(UNLOAD_MARKER_FILE)); // Commit the changes so as we get the fresh configuration for the // second part of this test. CfgMgr::instance().commit(); // Unload the libraries. The load file should not have changed, but // the unload one should indicate the unload() functions have been run. config = buildHooksLibrariesConfig(); ASSERT_TRUE(executeConfiguration(config, "unloading libraries")); EXPECT_TRUE(checkMarkerFile(LOAD_MARKER_FILE, "12")); EXPECT_TRUE(checkMarkerFile(UNLOAD_MARKER_FILE, "21")); // Expect the hooks system to say that none are loaded. libraries = HooksManager::getLibraryNames(); EXPECT_TRUE(libraries.empty()); } // This test verifies that it is possible to select subset of interfaces // on which server should listen. TEST_F(Dhcp4ParserTest, selectedInterfaces) { IfaceMgrTestConfig test_config(true); ConstElementPtr x; string config = "{ \"interfaces-config\": {" " \"interfaces\": [ \"eth0\", \"eth1\" ]" "}," "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); ConstElementPtr status; // Make sure the config manager is clean and there is no hanging // interface configuration. EXPECT_FALSE(test_config.socketOpen("eth0", AF_INET)); EXPECT_FALSE(test_config.socketOpen("eth1", AF_INET)); // Apply configuration. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); CfgMgr::instance().getStagingCfg()->getCfgIface()->openSockets(AF_INET, 10000); // eth0 and eth1 were explicitly selected. eth2 was not. EXPECT_TRUE(test_config.socketOpen("eth0", AF_INET)); EXPECT_TRUE(test_config.socketOpen("eth1", AF_INET)); } // This test verifies that it is possible to configure the server in such a way // that it listens on all interfaces. TEST_F(Dhcp4ParserTest, allInterfaces) { IfaceMgrTestConfig test_config(true); ConstElementPtr x; // This configuration specifies two interfaces on which server should listen // but it also includes asterisk. The asterisk switches server into the // mode when it listens on all interfaces regardless of what interface names // were specified in the "interfaces" parameter. string config = "{ \"interfaces-config\": {" " \"interfaces\": [ \"eth0\", \"*\", \"eth1\" ]" "}," "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); ConstElementPtr status; // Make sure there is no old configuration. ASSERT_FALSE(test_config.socketOpen("eth0", AF_INET)); ASSERT_FALSE(test_config.socketOpen("eth1", AF_INET)); // Apply configuration. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); CfgMgr::instance().getStagingCfg()->getCfgIface()->openSockets(AF_INET, 10000); // All interfaces should be now active. ASSERT_TRUE(test_config.socketOpen("eth0", AF_INET)); ASSERT_TRUE(test_config.socketOpen("eth1", AF_INET)); } // This test verifies that it is possible to select subset of interfaces // and addresses. TEST_F(Dhcp4ParserTest, selectedInterfacesAndAddresses) { IfaceMgrTestConfig test_config(true); ConstElementPtr x; string config = "{ \"interfaces-config\": {" " \"interfaces\": [ \"eth0/10.0.0.1\", \"eth1/192.0.2.3\" ]" "}," "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); ConstElementPtr status; // Make sure the config manager is clean and there is no hanging // interface configuration. ASSERT_FALSE(test_config.socketOpen("eth0", "10.0.0.1")); ASSERT_FALSE(test_config.socketOpen("eth1", "192.0.2.3")); ASSERT_FALSE(test_config.socketOpen("eth1", "192.0.2.5")); // Apply configuration. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); ASSERT_TRUE(status); checkResult(status, 0); CfgMgr::instance().getStagingCfg()->getCfgIface()->openSockets(AF_INET, 10000); // An address on eth0 was selected EXPECT_TRUE(test_config.socketOpen("eth0", "10.0.0.1")); // The 192.0.2.3 address on eth1 was selected. EXPECT_TRUE(test_config.socketOpen("eth1", "192.0.2.3")); // The 192.0.2.5 was not selected, thus the socket should not // be bound to this address. EXPECT_FALSE(test_config.socketOpen("eth1", "192.0.2.5")); } // This test checks the ability of the server to parse a configuration // containing a full, valid dhcp-ddns (D2ClientConfig) entry. TEST_F(Dhcp4ParserTest, d2ClientConfig) { ConstElementPtr status; // Verify that the D2 configuraiton can be fetched and is set to disabled. D2ClientConfigPtr d2_client_config = CfgMgr::instance().getD2ClientConfig(); EXPECT_FALSE(d2_client_config->getEnableUpdates()); // Verify that the convenience method agrees. ASSERT_FALSE(CfgMgr::instance().ddnsEnabled()); string config_str = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," " \"dhcp-ddns\" : {" " \"enable-updates\" : true, " " \"server-ip\" : \"192.168.2.1\", " " \"server-port\" : 777, " " \"sender-ip\" : \"192.168.2.2\", " " \"sender-port\" : 778, " " \"max-queue-size\" : 2048, " " \"ncr-protocol\" : \"UDP\", " " \"ncr-format\" : \"JSON\", " " \"always-include-fqdn\" : true, " " \"allow-client-update\" : true, " " \"override-no-update\" : true, " " \"override-client-update\" : true, " " \"replace-client-name\" : true, " " \"generated-prefix\" : \"test.prefix\", " " \"qualifying-suffix\" : \"test.suffix.\" }," "\"valid-lifetime\": 4000 }"; // Convert the JSON string to configuration elements. ElementPtr config; ASSERT_NO_THROW(config = Element::fromJSON(config_str)); // Pass the configuration in for parsing. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, config)); // check if returned status is OK checkResult(status, 0); // Verify that DHCP-DDNS updating is enabled. EXPECT_TRUE(CfgMgr::instance().ddnsEnabled()); // Verify that the D2 configuration can be retrieved. d2_client_config = CfgMgr::instance().getD2ClientConfig(); ASSERT_TRUE(d2_client_config); // Verify that the configuration values are correct. EXPECT_TRUE(d2_client_config->getEnableUpdates()); EXPECT_EQ("192.168.2.1", d2_client_config->getServerIp().toText()); EXPECT_EQ(777, d2_client_config->getServerPort()); EXPECT_EQ("192.168.2.2", d2_client_config->getSenderIp().toText()); EXPECT_EQ(778, d2_client_config->getSenderPort()); EXPECT_EQ(2048, d2_client_config->getMaxQueueSize()); EXPECT_EQ(dhcp_ddns::NCR_UDP, d2_client_config->getNcrProtocol()); EXPECT_EQ(dhcp_ddns::FMT_JSON, d2_client_config->getNcrFormat()); EXPECT_TRUE(d2_client_config->getAlwaysIncludeFqdn()); EXPECT_TRUE(d2_client_config->getOverrideNoUpdate()); EXPECT_TRUE(d2_client_config->getOverrideClientUpdate()); EXPECT_TRUE(d2_client_config->getReplaceClientName()); EXPECT_EQ("test.prefix", d2_client_config->getGeneratedPrefix()); EXPECT_EQ("test.suffix.", d2_client_config->getQualifyingSuffix()); } // This test checks the ability of the server to handle a configuration // containing an invalid dhcp-ddns (D2ClientConfig) entry. TEST_F(Dhcp4ParserTest, invalidD2ClientConfig) { ConstElementPtr status; // Configuration string with an invalid D2 client config, // "server-ip" is invalid. string config_str = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\" } ]," " \"dhcp-ddns\" : {" " \"enable-updates\" : true, " " \"server-ip\" : \"bogus-value\", " " \"server-port\" : 5301, " " \"ncr-protocol\" : \"UDP\", " " \"ncr-format\" : \"JSON\", " " \"always-include-fqdn\" : true, " " \"allow-client-update\" : true, " " \"override-no-update\" : true, " " \"override-client-update\" : true, " " \"replace-client-name\" : true, " " \"generated-prefix\" : \"test.prefix\", " " \"qualifying-suffix\" : \"test.suffix.\" }," "\"valid-lifetime\": 4000 }"; // Convert the JSON string to configuration elements. ElementPtr config; ASSERT_NO_THROW(config = Element::fromJSON(config_str)); // Configuration should not throw, but should fail. EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, config)); // check if returned status is failed. checkResult(status, 1); EXPECT_TRUE(errorContainsPosition(status, "")); // Verify that the D2 configuraiton can be fetched and is set to disabled. D2ClientConfigPtr d2_client_config = CfgMgr::instance().getD2ClientConfig(); EXPECT_FALSE(d2_client_config->getEnableUpdates()); // Verify that the convenience method agrees. ASSERT_FALSE(CfgMgr::instance().ddnsEnabled()); } // This test checks if it is possible to specify relay information TEST_F(Dhcp4ParserTest, subnetRelayInfo) { ConstElementPtr status; // A config with relay information. string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"renew-timer\": 1, " " \"rebind-timer\": 2, " " \"valid-lifetime\": 4," " \"relay\": { " " \"ip-address\": \"192.0.2.123\"" " }," " \"subnet\": \"192.0.2.0/24\" } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(status = configureDhcp4Server(*srv_, json)); // returned value should be 0 (configuration success) checkResult(status, 0); Subnet4Ptr subnet = CfgMgr::instance().getStagingCfg()-> getCfgSubnets4()->selectSubnet(IOAddress("192.0.2.200")); ASSERT_TRUE(subnet); EXPECT_EQ("192.0.2.123", subnet->getRelayInfo().addr_.toText()); } // Goal of this test is to verify that multiple subnets can be configured // with defined client classes. TEST_F(Dhcp4ParserTest, classifySubnets) { ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"client-class\": \"alpha\" " " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"client-class\": \"beta\" " " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"client-class\": \"gamma\" " " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.101 - 192.0.5.150\" } ]," " \"subnet\": \"192.0.5.0/24\" " " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); const Subnet4Collection* subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(4, subnets->size()); // We expect 4 subnets // Let's check if client belonging to alpha class is supported in subnet[0] // and not supported in any other subnet (except subnet[3], which allows // everyone). ClientClasses classes; classes.insert("alpha"); EXPECT_TRUE (subnets->at(0)->clientSupported(classes)); EXPECT_FALSE(subnets->at(1)->clientSupported(classes)); EXPECT_FALSE(subnets->at(2)->clientSupported(classes)); EXPECT_TRUE (subnets->at(3)->clientSupported(classes)); // Let's check if client belonging to beta class is supported in subnet[1] // and not supported in any other subnet (except subnet[3], which allows // everyone). classes.clear(); classes.insert("beta"); EXPECT_FALSE(subnets->at(0)->clientSupported(classes)); EXPECT_TRUE (subnets->at(1)->clientSupported(classes)); EXPECT_FALSE(subnets->at(2)->clientSupported(classes)); EXPECT_TRUE (subnets->at(3)->clientSupported(classes)); // Let's check if client belonging to gamma class is supported in subnet[2] // and not supported in any other subnet (except subnet[3], which allows // everyone). classes.clear(); classes.insert("gamma"); EXPECT_FALSE(subnets->at(0)->clientSupported(classes)); EXPECT_FALSE(subnets->at(1)->clientSupported(classes)); EXPECT_TRUE (subnets->at(2)->clientSupported(classes)); EXPECT_TRUE (subnets->at(3)->clientSupported(classes)); // Let's check if client belonging to some other class (not mentioned in // the config) is supported only in subnet[3], which allows everyone. classes.clear(); classes.insert("delta"); EXPECT_FALSE(subnets->at(0)->clientSupported(classes)); EXPECT_FALSE(subnets->at(1)->clientSupported(classes)); EXPECT_FALSE(subnets->at(2)->clientSupported(classes)); EXPECT_TRUE (subnets->at(3)->clientSupported(classes)); // Finally, let's check class-less client. He should be allowed only in // the last subnet, which does not have any class restrictions. classes.clear(); EXPECT_FALSE(subnets->at(0)->clientSupported(classes)); EXPECT_FALSE(subnets->at(1)->clientSupported(classes)); EXPECT_FALSE(subnets->at(2)->clientSupported(classes)); EXPECT_TRUE (subnets->at(3)->clientSupported(classes)); } // This test verifies that the host reservations can be specified for // respective IPv4 subnets. TEST_F(Dhcp4ParserTest, reservations) { ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ " " { " " \"pools\": [ { \"pool\": \"192.0.2.1 - 192.0.2.100\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"id\": 123," " \"reservations\": [" " ]" " }," " {" " \"reservations\": [" " {" " \"duid\": \"01:02:03:04:05:06:07:08:09:0A\"," " \"ip-address\": \"192.0.3.112\"," " \"hostname\": \"\"" " }," " {" " \"hw-address\": \"01:02:03:04:05:06\"," " \"ip-address\": \"192.0.3.120\"," " \"hostname\": \"\"" " }" " ]," " \"pools\": [ { \"pool\": \"192.0.3.101 - 192.0.3.150\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"id\": 234" " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\"," " \"id\": 542," " \"reservations\": [" " {" " \"duid\": \"0A:09:08:07:06:05:04:03:02:01\"," " \"ip-address\": \"192.0.4.101\"," " \"hostname\": \"\"" " }," " {" " \"hw-address\": \"06:05:04:03:02:01\"," " \"ip-address\": \"192.0.4.102\"," " \"hostname\": \"\"" " }" " ]" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 0); // Make sure all subnets have been successfully configured. There is no // need to sanity check the subnet properties because it should have // been already tested by other tests. const Subnet4Collection* subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4()->getAll(); ASSERT_TRUE(subnets); ASSERT_EQ(3, subnets->size()); // Hosts configuration must be available. CfgHostsPtr hosts_cfg = CfgMgr::instance().getStagingCfg()->getCfgHosts(); ASSERT_TRUE(hosts_cfg); // Let's create an object holding hardware address of the host having // a reservation in the subnet having id of 234. For simplicity the // address is a collection of numbers from 1 to 6. std::vector hwaddr_vec; for (int i = 1; i < 7; ++i) { hwaddr_vec.push_back(static_cast(i)); } HWAddrPtr hwaddr(new HWAddr(hwaddr_vec, HTYPE_ETHER)); // Retrieve the reservation and sanity check the address reserved. ConstHostPtr host = hosts_cfg->get4(234, hwaddr); ASSERT_TRUE(host); EXPECT_EQ("192.0.3.120", host->getIPv4Reservation().toText()); // This reservation should be solely assigned to the subnet 234, // and not to other two. EXPECT_FALSE(hosts_cfg->get4(123, hwaddr)); EXPECT_FALSE(hosts_cfg->get4(542, hwaddr)); // Do the same test for the DUID based reservation. std::vector duid_vec; for (int i = 1; i < 0xb; ++i) { duid_vec.push_back(static_cast(i)); } DuidPtr duid(new DUID(duid_vec)); host = hosts_cfg->get4(234, HWAddrPtr(), duid); ASSERT_TRUE(host); EXPECT_EQ("192.0.3.112", host->getIPv4Reservation().toText()); EXPECT_FALSE(hosts_cfg->get4(123, HWAddrPtr(), duid)); EXPECT_FALSE(hosts_cfg->get4(542, HWAddrPtr(), duid)); // The HW address used for one of the reservations in the subnet 542 // consists of numbers from 6 to 1. So, let's just reverse the order // of the address from the previous test. hwaddr->hwaddr_.assign(hwaddr_vec.rbegin(), hwaddr_vec.rend()); host = hosts_cfg->get4(542, hwaddr); EXPECT_TRUE(host); EXPECT_EQ("192.0.4.102", host->getIPv4Reservation().toText()); // This reservation must not belong to other subnets. EXPECT_FALSE(hosts_cfg->get4(123, hwaddr)); EXPECT_FALSE(hosts_cfg->get4(234, hwaddr)); // Repeat the test for the DUID based reservation in this subnet. duid.reset(new DUID(std::vector(duid_vec.rbegin(), duid_vec.rend()))); host = hosts_cfg->get4(542, HWAddrPtr(), duid); ASSERT_TRUE(host); EXPECT_EQ("192.0.4.101", host->getIPv4Reservation().toText()); EXPECT_FALSE(hosts_cfg->get4(123, HWAddrPtr(), duid)); EXPECT_FALSE(hosts_cfg->get4(234, HWAddrPtr(), duid)); } // This test verifies that the bogus host reservation would trigger a // server configuration error. TEST_F(Dhcp4ParserTest, reservationBogus) { // Case 1: misspelled hw-address parameter. ConstElementPtr x; string config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ " " { " " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\"," " \"id\": 542," " \"reservations\": [" " {" " \"hw-addre\": \"06:05:04:03:02:01\"," " \"ip-address\": \"192.0.4.102\"," " \"hostname\": \"\"" " }" " ]" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(config); CfgMgr::instance().clear(); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); // Case 2: DUID and HW Address both specified. config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ " " { " " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\"," " \"id\": 542," " \"reservations\": [" " {" " \"duid\": \"01:02:03:04:05:06\"," " \"hw-address\": \"06:05:04:03:02:01\"," " \"ip-address\": \"192.0.4.102\"," " \"hostname\": \"\"" " }" " ]" " } ]," "\"valid-lifetime\": 4000 }"; json = Element::fromJSON(config); // Remove existing configuration, if any. CfgMgr::instance().clear(); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); // Case 3: Neither ip address nor hostname specified. config = "{ " + genIfaceConfig() + "," + "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ " " { " " \"pools\": [ { \"pool\": \"192.0.4.101 - 192.0.4.150\" } ]," " \"subnet\": \"192.0.4.0/24\"," " \"id\": 542," " \"reservations\": [" " {" " \"hw-address\": \"06:05:04:03:02:01\"" " }" " ]" " } ]," "\"valid-lifetime\": 4000 }"; json = Element::fromJSON(config); // Remove existing configuration, if any. CfgMgr::instance().clear(); EXPECT_NO_THROW(x = configureDhcp4Server(*srv_, json)); checkResult(x, 1); } /// The goal of this test is to verify that Host Reservation modes can be /// specified on a per-subnet basis. TEST_F(Dhcp4ParserTest, hostReservationPerSubnet) { /// - Configuration: /// - only addresses (no prefixes) /// - 4 subnets with: /// - 192.0.2.0/24 (all reservations enabled) /// - 192.0.3.0/24 (out-of-pool reservations) /// - 192.0.4.0/24 (reservations disabled) /// - 192.0.5.0/24 (reservations not specified) const char* hr_config = "{ " "\"rebind-timer\": 2000, " "\"renew-timer\": 1000, " "\"subnet4\": [ { " " \"pools\": [ { \"pool\": \"192.0.2.0/24\" } ]," " \"subnet\": \"192.0.2.0/24\", " " \"reservation-mode\": \"all\"" " }," " {" " \"pools\": [ { \"pool\": \"192.0.3.0/24\" } ]," " \"subnet\": \"192.0.3.0/24\", " " \"reservation-mode\": \"out-of-pool\"" " }," " {" " \"pools\": [ { \"pool\": \"192.0.4.0/24\" } ]," " \"subnet\": \"192.0.4.0/24\", " " \"reservation-mode\": \"disabled\"" " }," " {" " \"pools\": [ { \"pool\": \"192.0.5.0/24\" } ]," " \"subnet\": \"192.0.5.0/24\"" " } ]," "\"valid-lifetime\": 4000 }"; ElementPtr json = Element::fromJSON(hr_config); ConstElementPtr result; EXPECT_NO_THROW(result = configureDhcp4Server(*srv_, json)); // returned value should be 0 (success) checkResult(result, 0); // Let's get all subnets and check that there are 4 of them. ConstCfgSubnets4Ptr subnets = CfgMgr::instance().getStagingCfg()->getCfgSubnets4(); ASSERT_TRUE(subnets); const Subnet4Collection* subnet_col = subnets->getAll(); ASSERT_EQ(4, subnet_col->size()); // We expect 4 subnets // Let's check if the parsed subnets have correct HR modes. // Subnet 1 Subnet4Ptr subnet; subnet = subnets->selectSubnet(IOAddress("192.0.2.1")); ASSERT_TRUE(subnet); EXPECT_EQ(Subnet::HR_ALL, subnet->getHostReservationMode()); // Subnet 2 subnet = subnets->selectSubnet(IOAddress("192.0.3.1")); ASSERT_TRUE(subnet); EXPECT_EQ(Subnet::HR_OUT_OF_POOL, subnet->getHostReservationMode()); // Subnet 3 subnet = subnets->selectSubnet(IOAddress("192.0.4.1")); ASSERT_TRUE(subnet); EXPECT_EQ(Subnet::HR_DISABLED, subnet->getHostReservationMode()); // Subnet 4 subnet = subnets->selectSubnet(IOAddress("192.0.5.1")); ASSERT_TRUE(subnet); EXPECT_EQ(Subnet::HR_ALL, subnet->getHostReservationMode()); } }