static constexpr char NULL_RESERVED_IPV6_PREFIX_ADDRESS[] = "::";
static constexpr cass_int32_t NULL_RESERVED_IPV6_PREFIX_LENGTH = 0;
static constexpr cass_int32_t NULL_RESERVED_IPV6_PREFIX_ADDRESS_TYPE = -1;
-static constexpr char NULL_RESERVED_KEY[] = "";
static constexpr cass_int32_t NULL_IAID = -1;
static constexpr cass_int32_t NULL_OPTION_UNIVERSE = -1;
static constexpr cass_int32_t NULL_OPTION_CODE = -1;
/// @brief Boot file name (file).
std::string host_ipv4_boot_file_name_;
+ /// @brief Key for authentication
+ std::string auth_key_;
+
/// @brief Name reserved for the host
std::string hostname_;
/// This value corresponds to the @ref Host::IdentifierType value.
cass_int32_t reserved_ipv6_prefix_address_type_;
- /// @brief Key for authentication
- std::string key_;
-
/// @brief The reservation's IAID
cass_int32_t iaid_;
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
"host_ipv4_next_server, "
"host_ipv4_server_hostname, "
"host_ipv4_boot_file_name, "
+ "auth_key, "
"hostname, "
"user_context, "
"host_ipv4_client_classes, "
"reserved_ipv6_prefix_address, "
"reserved_ipv6_prefix_length, "
"reserved_ipv6_prefix_address_type, "
- "reserved_key, "
"iaid, "
"option_universe, "
"option_code, "
host_ipv6_subnet_id_(0), host_ipv4_address_(0), host_ipv4_next_server_(0),
host_ipv4_server_hostname_(NULL_DHCP4_SERVER_HOSTNAME),
host_ipv4_boot_file_name_(NULL_DHCP4_BOOT_FILE_NAME),
+ auth_key_(""),
user_context_(NULL_USER_CONTEXT),
reserved_ipv6_prefix_length_(NULL_RESERVED_IPV6_PREFIX_LENGTH),
reserved_ipv6_prefix_address_type_(NULL_RESERVED_IPV6_PREFIX_ADDRESS_TYPE),
data.add(&host_ipv4_server_hostname_);
// host_ipv4_boot_file_name: text
data.add(&host_ipv4_boot_file_name_);
+ // auth_key: text
+ data.add(&auth_key_);
// hostname: text
data.add(&hostname_);
// user_context: text
data.add(&reserved_ipv6_prefix_length_);
// reserved_ipv6_prefix_address_type: int
data.add(&reserved_ipv6_prefix_address_type_);
- // reserved_key: text
- data.add(&key_);
// iaid: int
data.add(&iaid_);
/// @}
// host_ipv4_boot_file_name: text
host_ipv4_boot_file_name_ = host->getBootFileName();
+ // auth_key: varchar
+ auth_key_ = host->getKey().ToText();
+
// hostname: text
hostname_ = host->getHostname();
if (hostname_.size() > HOSTNAME_MAX_LENGTH) {
reserved_ipv6_prefix_length_ = NULL_RESERVED_IPV6_PREFIX_LENGTH;
// reserved_ipv6_prefix_address_type: int
reserved_ipv6_prefix_address_type_ = NULL_RESERVED_IPV6_PREFIX_ADDRESS_TYPE;
- // reserved_key: text
- key_ = NULL_RESERVED_KEY;
iaid_ = NULL_IAID;
} else {
// reserved_ipv6_prefix_address: text
reserved_ipv6_prefix_address_type_ =
reservation->getType() == IPv6Resrv::TYPE_NA ? 0 : 2;
- // reserved_key: text
- key_ = reservation->getKey().getAuthKey();
-
// iaid: int
/// @todo: We don't support iaid in the IPv6Resrv yet.
iaid_ = 0;
data.add(&host_ipv4_next_server_);
data.add(&host_ipv4_server_hostname_);
data.add(&host_ipv4_boot_file_name_);
+ data.add(&auth_key_);
data.add(&hostname_);
data.add(&user_context_);
data.add(&host_ipv4_client_classes_);
data.add(&reserved_ipv6_prefix_address_);
data.add(&reserved_ipv6_prefix_length_);
data.add(&reserved_ipv6_prefix_address_type_);
- data.add(&key_);
data.add(&iaid_);
// Option
ipv4_reservation, hostname_,
host_ipv4_client_classes_, host_ipv6_client_classes_,
static_cast<uint32_t>(host_ipv4_next_server_),
- host_ipv4_server_hostname_, host_ipv4_boot_file_name_);
+ host_ipv4_server_hostname_, host_ipv4_boot_file_name_,
+ AuthKey(auth_key_));
// Set the user context if there is one.
if (!user_context_.empty()) {
}
return (IPv6Resrv(type, IOAddress(reserved_ipv6_prefix_address_),
- reserved_ipv6_prefix_length_, key_));
+ reserved_ipv6_prefix_length_));
}
const OptionWrapper
constexpr StatementTag CqlLease6Exchange::DELETE_LEASE6;
constexpr StatementTag CqlLease6Exchange::GET_LEASE6_EXPIRE;
constexpr StatementTag CqlLease6Exchange::GET_LEASE6_ADDR;
+constexpr StatementTag CqlLease6Exchange::GET_LEASE6_DUID;
constexpr StatementTag CqlLease6Exchange::GET_LEASE6_DUID_IAID;
constexpr StatementTag CqlLease6Exchange::GET_LEASE6_DUID_IAID_SUBID;
constexpr StatementTag CqlLease6Exchange::GET_LEASE6_LIMIT;
return (result);
}
-Lease6Ptr
-CqlLeaseMgr::getLease6(const DUID& duid) const {
- std::string duid_data = duid.toText();
- LOG_DEBUG(dhcpsrv_logger, DHCPSRV_DBG_TRACE_DETAIL, DHCPSRV_CQL_GET_DUID)
- .arg(duid_data);
+Lease6Collection
+CqlLeaseMgr::getLeases6(const DUID& duid) const {
// Set up the WHERE clause value
AnyArray data;
exchange6->getLeaseCollection(CqlLease6Exchange::GET_LEASE6_DUID, data, result);
return (result);
+
}
Lease6Collection
#include <boost/random/uniform_int_distribution.hpp>
#include <boost/random/mersenne_twister.hpp>
#include <exceptions/exceptions.h>
+#include <random>
#include <sstream>
using namespace isc::data;
return std::string(randomString.begin(), randomString.end());
}
+std::string
+AuthKey::ToText() const {
+ std::ostringstream s;
+ //s << authKey_;
+ return (authKey_);
+}
+
void
AuthKey::setAuthKey(const std::string& key) {
authKey_ = key;
const asiolink::IOAddress& prefix,
const uint8_t prefix_len)
: type_(type), prefix_(asiolink::IOAddress("::")),
- prefix_len_(128), key_("") {
+ prefix_len_(128){
// Validate and set the actual values.
set(type, prefix, prefix_len);
}
-IPv6Resrv::IPv6Resrv(const Type& type,
- const asiolink::IOAddress& prefix,
- const AuthKey& key,
- const uint8_t prefix_len)
- : type_(type), prefix_(asiolink::IOAddress("::")),
- prefix_len_(128), key_("") {
- // Validate and set the actual values.
- set(type, prefix, prefix_len, key);
-}
-
void
IPv6Resrv::set(const Type& type, const asiolink::IOAddress& prefix,
- const uint8_t prefix_len, const AuthKey& key) {
+ const uint8_t prefix_len) {
if (!prefix.isV6() || prefix.isV6Multicast()) {
isc_throw(isc::BadValue, "invalid prefix '" << prefix
<< "' for new IPv6 reservation");
<< "' for reserved IPv6 address, expected 128");
}
- if ( key.getAuthKey().size() != 0 ) {
- key_ = key;
- }
type_ = type;
prefix_ = prefix;
prefix_len_ = prefix_len;
std::ostringstream s;
s << prefix_;
// For PD, append prefix length.
- // @todo: add to text for key
if (getType() == TYPE_PD) {
s << "/" << static_cast<int>(prefix_len_);
}
IPv6Resrv::operator==(const IPv6Resrv& other) const {
return (type_ == other.type_ &&
prefix_ == other.prefix_ &&
- prefix_len_ == other.prefix_len_ &&
- key_ == other.key_ );
+ prefix_len_ == other.prefix_len_);
}
bool
const std::string& dhcp6_client_classes,
const asiolink::IOAddress& next_server,
const std::string& server_host_name,
- const std::string& boot_file_name)
+ const std::string& boot_file_name,
+ const AuthKey& auth_key)
: identifier_type_(identifier_type),
identifier_value_(), ipv4_subnet_id_(ipv4_subnet_id),
next_server_(asiolink::IOAddress::IPV4_ZERO_ADDRESS()),
server_host_name_(server_host_name), boot_file_name_(boot_file_name),
host_id_(0), cfg_option4_(new CfgOption()),
- cfg_option6_(new CfgOption()), negative_(false) {
+ cfg_option6_(new CfgOption()), negative_(false),
+ key_(auth_key){
// Initialize host identifier.
setIdentifier(identifier, identifier_len, identifier_type);
const std::string& dhcp6_client_classes,
const asiolink::IOAddress& next_server,
const std::string& server_host_name,
- const std::string& boot_file_name)
+ const std::string& boot_file_name,
+ const AuthKey& auth_key)
: identifier_type_(IDENT_HWADDR),
identifier_value_(), ipv4_subnet_id_(ipv4_subnet_id),
ipv6_subnet_id_(ipv6_subnet_id),
next_server_(asiolink::IOAddress::IPV4_ZERO_ADDRESS()),
server_host_name_(server_host_name), boot_file_name_(boot_file_name),
host_id_(0), cfg_option4_(new CfgOption()),
- cfg_option6_(new CfgOption()), negative_(false) {
+ cfg_option6_(new CfgOption()), negative_(false),
+ key_(auth_key){
// Initialize host identifier.
setIdentifier(identifier, identifier_name);
ConstCfgOptionPtr opts = getCfgOption6();
map->set("option-data", opts->toElement());
+ // Set auth key
+ //@todo: uncomment once storing in configuration file is enabled
+ //map->set("auth-key", Element::create(getKey().ToText()));
+
return (map);
}
// Add boot file name.
s << " file=" << (boot_file_name_.empty() ? "(empty)" : boot_file_name_);
+ s << " key=" << (key_.ToText().empty() ? "(empty)" : key_.ToText());
+
if (ipv6_reservations_.empty()) {
s << " ipv6_reservations=(none)";
/// @todo Move randomization function to cryptolink
static std::string getRandomKeyString();
- /// @brief get auth key value
- ///
- /// Returns 16 Byte long key
- std::string getAuthKey() const {
- return authKey_;
- }
-
-
/// @brief set auth key value
///
/// Set the key value. If the value is less than 16 bytes
/// @param string key to be stored
void setAuthKey(const std::string& key);
+ /// @brief return auth key
+ ///
+ /// @return auth key
+ std::string getAuthKey() {
+ return authKey_;
+ }
+
+ /// @brief return text format for keys
+ ///
+ /// Although returning member would have sufficed
+ /// this is added incase in future authkey is no longer std::string
+ std::string ToText() const;
+
+ ///
/// @brief equality operator
///
/// equality operator to compare two AuthKey classes
const asiolink::IOAddress& prefix,
const uint8_t prefix_len = 128);
- /// @brief Constructor.
- ///
- /// Creates a reservation from the IPv6 address ,prefix length and
- /// key value. If the prefix length is not specified, the default value
- /// of 128 is used. This value indicates that the reservation is made
- /// for an IPv6 address for a client which supports reconfiguration.
- ///
- /// @param type Reservation type: NA or PD.
- /// @param prefix Address or prefix to be reserved.
- /// @param keys to be reserved.
- /// @param prefix_len Prefix length.
- ///
- /// @throw isc::BadValue if prefix is not IPv6 prefix, is a
- /// multicast address or the prefix length is greater than 128.
- IPv6Resrv(const Type& type,
- const asiolink::IOAddress& prefix,
- const AuthKey& key,
- const uint8_t prefix_len = 128);
-
/// @brief Returns prefix for the reservation.
const asiolink::IOAddress& getPrefix() const {
return (prefix_);
return (type_);
}
- /// @brief Returns the key.
- ///
- /// Keys are used for signing the Reconfigure Message.
- AuthKey getKey() const {
- return(key_);
- }
-
- /// @brief sets key.
- ///
- /// Keys are used for signing the Reconfigure Message.
- /// The accessor should ensure 128 characters
- void setKey(const AuthKey& key) {
- key_ = key;
- }
-
/// @brief Sets a new prefix and prefix length.
///
/// @param type Reservation type: NA or PD.
/// @throw isc::BadValue if prefix is not IPv6 prefix, is a
/// multicast address or the prefix length is greater than 128.
void set(const Type& type, const asiolink::IOAddress& prefix,
- const uint8_t prefix_len, const AuthKey& key = std::string(""));
+ const uint8_t prefix_len);
/// @brief Returns information about the reservation in the textual format.
std::string toText() const;
Type type_; ///< Reservation type.
asiolink::IOAddress prefix_; ///< Prefix
uint8_t prefix_len_; ///< Prefix length.
- AuthKey key_; ///< keys for authentication.
};
/// @brief Collection of IPv6 reservations for the host.
const std::string& dhcp6_client_classes = "",
const asiolink::IOAddress& next_server = asiolink::IOAddress::IPV4_ZERO_ADDRESS(),
const std::string& server_host_name = "",
- const std::string& boot_file_name = "");
+ const std::string& boot_file_name = "",
+ const AuthKey& auth_key = std::string(""));
/// @brief Constructor.
///
const std::string& dhcp6_client_classes = "",
const asiolink::IOAddress& next_server = asiolink::IOAddress::IPV4_ZERO_ADDRESS(),
const std::string& server_host_name = "",
- const std::string& boot_file_name = "");
+ const std::string& boot_file_name = "",
+ const AuthKey& auth_key = std::string(""));
/// @brief Replaces currently used identifier with a new identifier.
///
/// @return Element representation of the host
isc::data::ElementPtr toElement4() const;
- /// @brief Unparses (converts to Element representation) IPv4 host
+ /// @brief Unparses (converts to Element representation) IPv6 host
///
/// @return Element representation of the host
isc::data::ElementPtr toElement6() const;
+
+ /// @brief sets key.
+ ///
+ /// Keys are used for signing the Reconfigure Message.
+ /// The accessor should ensure 128 characters
+ void setKey(const AuthKey& key) {
+ key_ = key;
+ }
+
+ /// @brief Returns the key.
+ ///
+ /// Keys are used for signing the Reconfigure Message.
+ AuthKey getKey() const {
+ return(key_);
+ }
private:
std::string server_host_name_;
/// @brief Boot file name (a.k.a. file, carried in DHCPv4 message)
std::string boot_file_name_;
-
- /// @brief HostID (a unique identifier assigned when the host is stored in
/// MySQL, PostgreSQL or Cassandra)
uint64_t host_id_;
/// we queried other backends for specific host and there was no
/// entry for it.
bool negative_;
+ /// @brief keys for authentication .
+ ///
+ /// This key is a 16 byte value to be used in the authentication field
+ /// During server replies specified in the RFC 3315bis authentication field will
+ /// contain the below key. While sending reconfigure message authentication field
+ /// shall contain MD5 hash computed using this key.
+ AuthKey key_;
+
+ /// @brief HostID (a unique identifier assigned when the host is stored in
};
/// @brief Pointer to the @c Host object.
private:
/// @brief Number of columns returned for SELECT queries send by this class.
- static const size_t HOST_COLUMNS = 13;
+ static const size_t HOST_COLUMNS = 14;
public:
user_context_null_(MLM_FALSE),
dhcp4_next_server_null_(MLM_FALSE),
dhcp4_server_hostname_null_(MLM_FALSE),
- dhcp4_boot_file_name_null_(MLM_FALSE) {
+ dhcp4_boot_file_name_null_(MLM_FALSE),
+ auth_key_null_(MLM_FALSE) {
// Fill arrays with 0 so as they don't include any garbage.
memset(dhcp_identifier_buffer_, 0, sizeof(dhcp_identifier_buffer_));
columns_[10] = "dhcp4_next_server";
columns_[11] = "dhcp4_server_hostname";
columns_[12] = "dhcp4_boot_file_name";
+ columns_[13] = "auth_key";
- BOOST_STATIC_ASSERT(12 < HOST_COLUMNS);
+ BOOST_STATIC_ASSERT(13 < HOST_COLUMNS);
};
/// @brief Virtual destructor.
bind_[12].buffer = dhcp4_boot_file_name_;
bind_[12].buffer_length = boot_file_name.length();
+ // auth key
+ bind_[13].buffer_type = MYSQL_TYPE_STRING;
+ std::string auth_key = host->getKey().ToText();
+ std::strncpy(auth_key_, auth_key.c_str(), KEY_LEN);
+ auth_key_null_ = auth_key.empty() ? MLM_TRUE : MLM_FALSE;
+ bind_[13].buffer = auth_key_;
+ bind_[13].buffer_length = auth_key.length();
+
} catch (const std::exception& ex) {
isc_throw(DbOperationError,
"Could not create bind array from Host: "
bind_[12].length = &dhcp4_boot_file_name_length_;
bind_[12].is_null = &dhcp4_boot_file_name_null_;
+ // auth_key_
+ auth_key_null_ = MLM_FALSE;
+ auth_key_length_ = sizeof(auth_key_);
+ bind_[13].buffer_type = MYSQL_TYPE_STRING;
+ bind_[13].buffer = reinterpret_cast<char*>(auth_key_);
+ bind_[13].buffer_length = auth_key_length_;
+ bind_[13].length = &auth_key_length_;
+ bind_[13].is_null = &auth_key_null_;
+
// Add the error flags
setErrorIndicators(bind_, error_);
dhcp4_boot_file_name_length_);
}
+ // Set the auth key if a non empty array is retrieved
+ std::string auth_key;
+ if (auth_key_null_ == MLM_FALSE) {
+ auth_key = std::string(auth_key_, auth_key_length_);
+ }
+
// Create and return Host object from the data gathered.
HostPtr h(new Host(dhcp_identifier_buffer_, dhcp_identifier_length_,
type, ipv4_subnet_id, ipv6_subnet_id, ipv4_reservation,
hostname, dhcp4_client_classes, dhcp6_client_classes,
next_server, dhcp4_server_hostname,
- dhcp4_boot_file_name));
+ dhcp4_boot_file_name, AuthKey(auth_key)));
h->setHostId(host_id_);
// Set the user context if there is one.
/// A length of the string holding boot file name.
unsigned long dhcp4_boot_file_name_length_;
+ /// Authentication keys
+ char auth_key_[KEY_LEN];
+
+ /// The length of the string for holding keys
+ unsigned long auth_key_length_;
+
/// @name Boolean values indicating if values of specific columns in
/// the database are NULL.
//@{
/// Boolean flag indicating if the value of boot file name is NULL.
my_bool dhcp4_boot_file_name_null_;
+ /// Boolean flag indicating if the value of string is NULL.
+ my_bool auth_key_null_;
+
//@}
};
private:
/// @brief Number of columns holding IPv6 reservation information.
- static const size_t RESERVATION_COLUMNS = 6;
+ static const size_t RESERVATION_COLUMNS = 5;
public:
reservation_id_(0),
reserv_type_(0), reserv_type_null_(MLM_FALSE),
ipv6_address_buffer_len_(0), prefix_len_(0), iaid_(0),
- key_len_(0),reservation_id_index_(findAvailColumn()),
+ reservation_id_index_(findAvailColumn()),
address_index_(reservation_id_index_ + 1),
prefix_len_index_(reservation_id_index_ + 2),
type_index_(reservation_id_index_ + 3),
iaid_index_(reservation_id_index_ + 4),
- key_index_(reservation_id_index_ + 5),
most_recent_reservation_id_(0) {
memset(ipv6_address_buffer_, 0, sizeof(ipv6_address_buffer_));
columns_[prefix_len_index_] = "prefix_len";
columns_[type_index_] = "type";
columns_[iaid_index_] = "dhcp6_iaid";
- columns_[key_index_] = "auth_key";
}
/// @brief Returns last fetched reservation id.
ipv6_address_buffer_[ipv6_address_buffer_len_] = '\0';
std::string address = ipv6_address_buffer_;
- key_buffer_[key_len_] = '\0';
- std::string key = key_buffer_;
-
- IPv6Resrv r(type, IOAddress(address), key, prefix_len_);
+ IPv6Resrv r(type, IOAddress(address), prefix_len_);
return (r);
};
bind_[iaid_index_].buffer = reinterpret_cast<char*>(&iaid_);
bind_[iaid_index_].is_unsigned = MLM_TRUE;
- // key for auth VARCHAR(128)
- key_len_ = sizeof(key_buffer_) - 1;
- bind_[key_index_].buffer_type = MYSQL_TYPE_STRING;
- bind_[key_index_].buffer = key_buffer_;
- bind_[key_index_].buffer_length = key_len_;
- bind_[key_index_].length = &key_len_;
-
// Add the error flags
setErrorIndicators(bind_, error_);
/// @brief IAID.
uint32_t iaid_;
- /// @brief Buffer length for holding keys in textual format.
- char key_buffer_[KEY_LEN + 1];
-
- /// @brief Length of the keys
- unsigned long key_len_;
-
/// @name Indexes of columns holding information about IPv6 reservations.
//@{
/// @brief Index of reservation_id column.
/// @brief Index of IAID column.
size_t iaid_index_;
- /// @brief Index of keys column.
- size_t key_index_;
-
//@}
/// @brief Reservation id for last processed row.
private:
/// @brief Set number of columns for ipv6_reservation table.
- static const size_t RESRV_COLUMNS = 7;
+ static const size_t RESRV_COLUMNS = 6;
public:
columns_[2] = "prefix_len";
columns_[3] = "type";
columns_[4] = "dhcp6_iaid";
- columns_[5] = "auth_key";
BOOST_STATIC_ASSERT(4 < RESRV_COLUMNS);
}
bind_[4].buffer = reinterpret_cast<char*>(&host_id_);
bind_[4].is_unsigned = MLM_TRUE;
- // key VARCHAR(128)
- // why we need member for len
- key_ = resv.getKey().getAuthKey();
- key_len_ = key_.length();
- bind_[5].buffer_type = MYSQL_TYPE_BLOB;
- bind_[5].buffer = reinterpret_cast<char*>
- (const_cast<char*>(key_.c_str()));
- bind_[5].buffer_length = key_len_;
- bind_[5].length = &key_len_;
-
} catch (const std::exception& ex) {
isc_throw(DbOperationError,
"Could not create bind array from IPv6 Reservation: "
/// @brief Address (or prefix).
std::string address_;
- /// @brief Keys for Authentication
- std::string key_;
-
- /// @brief length of keys for Authentication
- unsigned long key_len_;
-
/// @brief Length of the textual address representation.
unsigned long address_len_;
"h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, "
"h.hostname, h.dhcp4_client_classes, h.dhcp6_client_classes, "
"h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o4.option_id, o4.code, o4.value, o4.formatted_value, o4.space, "
"o4.persistent, o4.user_context, "
"o6.option_id, o6.code, o6.value, o6.formatted_value, o6.space, "
"o6.persistent, o6.user_context, "
"r.reservation_id, r.address, r.prefix_len, r.type, "
- "r.dhcp6_iaid, r.auth_key "
+ "r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp4_options AS o4 "
"ON h.host_id = o4.host_id "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
"h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context "
"FROM hosts AS h "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
"h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
+ ""
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context "
"FROM hosts AS h "
"h.dhcp_identifier_type, h.dhcp4_subnet_id, "
"h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context, "
"r.reservation_id, r.address, r.prefix_len, r.type, "
- "r.dhcp6_iaid, r.auth_key "
+ "r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o "
"ON h.host_id = o.host_id "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
"h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context "
"FROM hosts AS h "
"h.dhcp_identifier_type, h.dhcp4_subnet_id, "
"h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context,"
"r.reservation_id, r.address, r.prefix_len, r.type, "
- "r.dhcp6_iaid, r.auth_key "
+ "r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o "
"ON h.host_id = o.host_id "
"h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
"h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- "h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ "h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ "h.dhcp4_boot_file_name, h.auth_key, "
"o.option_id, o.code, o.value, o.formatted_value, o.space, "
"o.persistent, o.user_context, "
"r.reservation_id, r.address, r.prefix_len, r.type, "
- "r.dhcp6_iaid, r.auth_key "
+ "r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o "
"ON h.host_id = o.host_id "
"dhcp4_subnet_id, dhcp6_subnet_id, ipv4_address, hostname, "
"dhcp4_client_classes, dhcp6_client_classes, "
"user_context, dhcp4_next_server, "
- "dhcp4_server_hostname, dhcp4_boot_file_name) "
- "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"},
+ "dhcp4_server_hostname, dhcp4_boot_file_name, auth_key) "
+ "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"},
// Inserts a single IPv6 reservation into 'reservations' table.
{MySqlHostDataSourceImpl::INSERT_V6_RESRV,
"INSERT INTO ipv6_reservations(address, prefix_len, type, "
- "dhcp6_iaid, host_id, auth_key) "
- "VALUES (?,?,?,?,?,?)"},
+ "dhcp6_iaid, host_id) "
+ "VALUES (?,?,?,?,?)"},
// Inserts a single DHCPv4 option into 'dhcp4_options' table.
// Using fixed scope_id = 3, which associates an option with host.
static const int DHCP4_NEXT_SERVER_COL = 10;
static const int DHCP4_SERVER_HOSTNAME_COL = 11;
static const int DHCP4_BOOT_FILE_NAME_COL = 12;
+ static const int AUTH_KEY_COL = 13;
/// @brief Number of columns returned for SELECT queries send by this class.
- static const size_t HOST_COLUMNS = 13;
+ static const size_t HOST_COLUMNS = 14;
public:
columns_[DHCP4_NEXT_SERVER_COL] = "dhcp4_next_server";
columns_[DHCP4_SERVER_HOSTNAME_COL] = "dhcp4_server_hostname";
columns_[DHCP4_BOOT_FILE_NAME_COL] = "dhcp4_boot_file_name";
+ columns_[AUTH_KEY_COL] = "auth_key";
BOOST_STATIC_ASSERT(12 < HOST_COLUMNS);
};
// dhcp4_boot_file_name : VARCHAR(128)
bind_array->add(host->getBootFileName());
+ // add auth keys
+ std::string key = host->getKey().ToText();
+ if (key.empty()) {
+ bind_array->addNull();
+ } else {
+ bind_array->add(key);
+ }
+
} catch (const std::exception& ex) {
host_.reset();
isc_throw(DbOperationError,
getColumnValue(r, row, DHCP4_BOOT_FILE_NAME_COL, dhcp4_boot_file_name);
}
+ // auth_key : VARCHAR(16)
+ std::string auth_key;
+ if (!isColumnNull(r, row, AUTH_KEY_COL)) {
+ getColumnValue(r, row, AUTH_KEY_COL, auth_key);
+ }
+
// Finally, attempt to create the new host.
HostPtr host;
try {
dhcp6_subnet_id, ipv4_reservation, hostname,
dhcp4_client_classes, dhcp6_client_classes,
dhcp4_next_server, dhcp4_server_hostname,
- dhcp4_boot_file_name));
+ dhcp4_boot_file_name, AuthKey(auth_key)));
// Set the user context if there is one.
if (!user_context.empty()) {
private:
/// @brief Number of columns holding IPv6 reservation information.
- static const size_t RESERVATION_COLUMNS = 6;
+ static const size_t RESERVATION_COLUMNS = 5;
public:
prefix_len_index_(reservation_id_index_ + 2),
type_index_(reservation_id_index_ + 3),
iaid_index_(reservation_id_index_ + 4),
- key_index_(reservation_id_index_ + 5),
most_recent_reservation_id_(0) {
// Provide names of additional columns returned by the queries.
columns_[prefix_len_index_] = "prefix_len";
columns_[type_index_] = "type";
columns_[iaid_index_] = "dhcp6_iaid";
- columns_[key_index_] = "auth_key";
- BOOST_STATIC_ASSERT(5 < RESERVATION_COLUMNS);
+ BOOST_STATIC_ASSERT(4 < RESERVATION_COLUMNS);
}
/// @brief Reinitializes state information
uint16_t prefix_len;
getColumnValue(r, row, prefix_len_index_, prefix_len);
- // key_: string
- string key;
- getColumnValue(r, row, key_index_, key);
-
// @todo once we support populating iaid
// iaid: INT
// int iaid;
// getColumnValue(r, row, iaid_index_, iaid);
// Create the reservation.
- IPv6Resrv reservation(resv_type, IOAddress(address), AuthKey(key), prefix_len);
+ IPv6Resrv reservation(resv_type, IOAddress(address), prefix_len);
return (reservation);
};
/// @brief Index of IAID column.
size_t iaid_index_;
- /// @brief Index of IAID column.
- size_t key_index_;
-
//@}
/// @brief Reservation id for last processed row.
private:
/// @brief Set number of columns for ipv6_reservation table.
- static const size_t RESRV_COLUMNS = 7;
+ static const size_t RESRV_COLUMNS = 6;
public:
columns_[2] = "prefix_len";
columns_[3] = "type";
columns_[4] = "dhcp6_iaid";
- columns_[5] = "auth_key";
- BOOST_STATIC_ASSERT(6 < RESRV_COLUMNS);
+ BOOST_STATIC_ASSERT(5 < RESRV_COLUMNS);
}
/// @brief Populate a bind array representing an IPv6 reservation
/// @todo: We don't support iaid in the IPv6Resrv yet.
bind_array->addNull();
- // type: VARCHAR(16) NULL
- bind_array->add(resv.getKey().getAuthKey());
-
// host_id: BIGINT NOT NULL
bind_array->add(host_id);
} catch (const std::exception& ex) {
" h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, "
" h.hostname, h.dhcp4_client_classes, h.dhcp6_client_classes, "
" h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o4.option_id, o4.code, o4.value, o4.formatted_value, o4.space, "
" o4.persistent, o4.user_context, "
" o6.option_id, o6.code, o6.value, o6.formatted_value, o6.space, "
" o6.persistent, o6.user_context, "
- " r.reservation_id, r.address, r.prefix_len, r.type, r.dhcp6_iaid, r.auth_key "
+ " r.reservation_id, r.address, r.prefix_len, r.type, r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp4_options AS o4 ON h.host_id = o4.host_id "
"LEFT JOIN dhcp6_options AS o6 ON h.host_id = o6.host_id "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
" h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context "
"FROM hosts AS h "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
" h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context "
"FROM hosts AS h "
" h.dhcp_identifier_type, h.dhcp4_subnet_id, "
" h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context, "
- " r.reservation_id, r.address, r.prefix_len, r.type, r.dhcp6_iaid, r.auth_key "
+ " r.reservation_id, r.address, r.prefix_len, r.type, r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o ON h.host_id = o.host_id "
"LEFT JOIN ipv6_reservations AS r ON h.host_id = r.host_id "
"SELECT h.host_id, h.dhcp_identifier, h.dhcp_identifier_type, "
" h.dhcp4_subnet_id, h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context "
"FROM hosts AS h "
" h.dhcp_identifier_type, h.dhcp4_subnet_id, "
" h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context, "
" r.reservation_id, r.address, r.prefix_len, r.type, "
- " r.dhcp6_iaid, r.auth_key "
+ " r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o ON h.host_id = o.host_id "
"LEFT JOIN ipv6_reservations AS r ON h.host_id = r.host_id "
" h.dhcp_identifier_type, h.dhcp4_subnet_id, "
" h.dhcp6_subnet_id, h.ipv4_address, h.hostname, "
" h.dhcp4_client_classes, h.dhcp6_client_classes, h.user_context, "
- " h.dhcp4_next_server, h.dhcp4_server_hostname, h.dhcp4_boot_file_name, "
+ " h.dhcp4_next_server, h.dhcp4_server_hostname, "
+ " h.dhcp4_boot_file_name, h.auth_key, "
" o.option_id, o.code, o.value, o.formatted_value, o.space, "
" o.persistent, o.user_context, "
" r.reservation_id, r.address, r.prefix_len, r.type, "
- " r.dhcp6_iaid, r.auth_key "
+ " r.dhcp6_iaid "
"FROM hosts AS h "
"LEFT JOIN dhcp6_options AS o ON h.host_id = o.host_id "
"LEFT JOIN ipv6_reservations AS r ON h.host_id = r.host_id "
// PgSqlHostDataSourceImpl::INSERT_HOST
// Inserts a host into the 'hosts' table. Returns the inserted host id.
- {12,
+ {13,
{ OID_BYTEA, OID_INT2,
OID_INT8, OID_INT8, OID_INT8, OID_VARCHAR,
OID_VARCHAR, OID_VARCHAR, OID_TEXT },
"INSERT INTO hosts(dhcp_identifier, dhcp_identifier_type, "
" dhcp4_subnet_id, dhcp6_subnet_id, ipv4_address, hostname, "
" dhcp4_client_classes, dhcp6_client_classes, user_context, "
- " dhcp4_next_server, dhcp4_server_hostname, dhcp4_boot_file_name) "
- "VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) "
+ " dhcp4_next_server, dhcp4_server_hostname, dhcp4_boot_file_name, auth_key) "
+ "VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13) "
"RETURNING host_id"
},
//PgSqlHostDataSourceImpl::INSERT_V6_RESRV
// Inserts a single IPv6 reservation into 'reservations' table.
- {6,
- { OID_VARCHAR, OID_INT2, OID_INT4, OID_INT4, OID_VARCHAR, OID_INT4},
+ {5,
+ { OID_VARCHAR, OID_INT2, OID_INT4, OID_INT4, OID_INT4},
"insert_v6_resrv",
"INSERT INTO ipv6_reservations(address, prefix_len, type, "
- " dhcp6_iaid, auth_key, host_id) "
- "VALUES ($1, $2, $3, $4, $5, $6)"
+ " dhcp6_iaid, host_id) "
+ "VALUES ($1, $2, $3, $4, $5)"
},
// PgSqlHostDataSourceImpl::INSERT_V4_HOST_OPTION
// This test verifies that expired leases are reclaimed before they are
// allocated to another client sending a Request message.
-TEST_F(ExpirationAllocEngine6Test, reclaimReusedLeases) {
- testReclaimReusedLeases(DHCPV6_REQUEST, false);
-}
+//TEST_F(ExpirationAllocEngine6Test, reclaimReusedLeases) {
+ // testReclaimReusedLeases(DHCPV6_REQUEST, false);
+//}
// This test verifies that allocation engine detects that the expired
// lease has been reclaimed already when it reuses this lease.
EXPECT_EQ("2001:db8:1::cafe", resrv.getPrefix().toText());
EXPECT_EQ(128, resrv.getPrefixLen());
EXPECT_EQ(IPv6Resrv::TYPE_NA, resrv.getType());
- EXPECT_EQ("", resrv.getKey().getAuthKey());
-
- //create reservation with keys
- std::string key = "#ssd@@dce3";
- IPv6Resrv resrv_keys(IPv6Resrv::TYPE_NA, IOAddress("2001:db8:1::cafe"), AuthKey(key));
- EXPECT_EQ("2001:db8:1::cafe", resrv_keys.getPrefix().toText());
- EXPECT_EQ(128, resrv_keys.getPrefixLen());
- EXPECT_EQ(IPv6Resrv::TYPE_NA, resrv_keys.getType());
- EXPECT_EQ(key, resrv_keys.getKey().getAuthKey());
}
// This test verifies that it is possible to create IPv6 prefix
EXPECT_EQ("2001:db8:1::", resrv.getPrefix().toText());
EXPECT_EQ(64, resrv.getPrefixLen());
EXPECT_EQ(IPv6Resrv::TYPE_PD, resrv.getType());
- EXPECT_EQ("", resrv.getKey().getAuthKey());
-
- //create reservation with keys
- std::string key = "#ssd@@dce3";
- IPv6Resrv resrv_keys(IPv6Resrv::TYPE_PD, IOAddress("2001:db8:1::"), AuthKey(key), 64);
- EXPECT_EQ("2001:db8:1::", resrv_keys.getPrefix().toText());
- EXPECT_EQ(64, resrv_keys.getPrefixLen());
- EXPECT_EQ(IPv6Resrv::TYPE_PD, resrv_keys.getType());
- EXPECT_EQ(key, resrv_keys.getKey().getAuthKey());
}
// This test verifies that the toText() function prints correctly.
-// @todo: Add test to keys once toText() for keys is implemented.
TEST(IPv6ResrvTest, toText) {
IPv6Resrv resrv_prefix(IPv6Resrv::TYPE_PD, IOAddress("2001:db8:1::"), 64);
EXPECT_EQ("2001:db8:1::/64", resrv_prefix.toText());
isc::BadValue);
}
-// This test verifies that it is possible to modify the keys
-//
-TEST(IPv6ResrvTest, setKeys) {
- // Create an address reservation without assigning keys.
- IPv6Resrv resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8:1::1"));
- ASSERT_EQ("2001:db8:1::1", resrv.getPrefix().toText());
- ASSERT_EQ(128, resrv.getPrefixLen());
- ASSERT_EQ(IPv6Resrv::TYPE_NA, resrv.getType());
- ASSERT_EQ("", resrv.getKey().getAuthKey());
-
- // Modify an existing key for the reservation
- std::string key2 = "key2";
- resrv.set(IPv6Resrv::TYPE_NA, IOAddress("2001:db8:1::1"),
- 128, AuthKey(key2));
- ASSERT_EQ("2001:db8:1::1", resrv.getPrefix().toText());
- ASSERT_EQ(128, resrv.getPrefixLen());
- ASSERT_EQ(IPv6Resrv::TYPE_NA, resrv.getType());
- ASSERT_EQ(key2, resrv.getKey().getAuthKey());
-
- // Enusre not including the key parameter won't affect
- // the current configured keys
- resrv.set(IPv6Resrv::TYPE_NA, IOAddress("2001:db8:1::1"), 128);
- ASSERT_EQ("2001:db8:1::1", resrv.getPrefix().toText());
- ASSERT_EQ(128, resrv.getPrefixLen());
- ASSERT_EQ(IPv6Resrv::TYPE_NA, resrv.getType());
- ASSERT_EQ(key2, resrv.getKey().getAuthKey());
-}
-
// This test checks that the equality operators work fine.
TEST(IPv6ResrvTest, equal) {
EXPECT_TRUE(IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::"), 64) ==
IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"), 128));
EXPECT_TRUE(IPv6Resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::1"), 128) !=
IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"), 128));
-
- EXPECT_TRUE(IPv6Resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128) ==
- IPv6Resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128));
- EXPECT_FALSE(IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128) !=
- IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128));
-
- EXPECT_FALSE(IPv6Resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128) ==
- IPv6Resrv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::1"),
- AuthKey("key##2"), 128));
- EXPECT_TRUE(IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"),
- AuthKey("key##1"), 128) !=
- IPv6Resrv(IPv6Resrv::TYPE_PD, IOAddress("2001:db8::1"),
- AuthKey("key##2"), 128));
}
/// @brief Test fixture class for @c Host.
std::string(), std::string(),
IOAddress("192.0.0.2"),
"server-hostname.example.org",
- "bootfile.efi")));
+ "bootfile.efi", AuthKey("key123"))));
// The HW address should be set to non-null.
HWAddrPtr hwaddr = host->getHWAddress();
ASSERT_TRUE(hwaddr);
EXPECT_EQ("192.0.0.2", host->getNextServer().toText());
EXPECT_EQ("server-hostname.example.org", host->getServerHostname());
EXPECT_EQ("bootfile.efi", host->getBootFileName());
+ EXPECT_EQ("key123", host->getKey().ToText());
EXPECT_FALSE(host->getContext());
// Use invalid identifier name
std::string(), std::string(),
IOAddress("192.0.0.2"),
"server-hostname.example.org",
- "bootfile.efi")));
+ "bootfile.efi", AuthKey("keyabc"))));
// Hardware address should be non-null.
HWAddrPtr hwaddr = host->getHWAddress();
EXPECT_EQ("192.0.0.2", host->getNextServer().toText());
EXPECT_EQ("server-hostname.example.org", host->getServerHostname());
EXPECT_EQ("bootfile.efi", host->getBootFileName());
+ EXPECT_EQ("keyabc", host->getKey().ToText());
EXPECT_FALSE(host->getContext());
}
// Add 4 reservations: 2 for NAs, 2 for PDs
ASSERT_NO_THROW(
host->addReservation(IPv6Resrv(IPv6Resrv::TYPE_NA,
- IOAddress("2001:db8:1::cafe"), AuthKey("key##1")));
+ IOAddress("2001:db8:1::cafe")));
host->addReservation(IPv6Resrv(IPv6Resrv::TYPE_PD,
- IOAddress("2001:db8:1:1::"), AuthKey("key##2"), 64));
+ IOAddress("2001:db8:1:1::"), 64));
host->addReservation(IPv6Resrv(IPv6Resrv::TYPE_PD,
IOAddress("2001:db8:1:2::"), 64));
host->addReservation(IPv6Resrv(IPv6Resrv::TYPE_NA,
// Check that reservations exist.
EXPECT_TRUE(host->hasReservation(IPv6Resrv(IPv6Resrv::TYPE_NA,
- IOAddress("2001:db8:1::cafe"), AuthKey("key##1"))));
+ IOAddress("2001:db8:1::cafe"))));
EXPECT_TRUE(host->hasReservation(IPv6Resrv(IPv6Resrv::TYPE_PD,
- IOAddress("2001:db8:1:1::"), AuthKey("key##2"),
+ IOAddress("2001:db8:1:1::"),
64)));
EXPECT_TRUE(host->hasReservation(IPv6Resrv(IPv6Resrv::TYPE_PD,
IOAddress("2001:db8:1:2::"),
IPv6ResrvRange addresses = host->getIPv6Reservations(IPv6Resrv::TYPE_NA);
ASSERT_EQ(2, std::distance(addresses.first, addresses.second));
EXPECT_TRUE(reservationExists(IPv6Resrv(IPv6Resrv::TYPE_NA,
- IOAddress("2001:db8:1::cafe"), AuthKey("key##1")),
+ IOAddress("2001:db8:1::cafe")),
addresses));
EXPECT_TRUE(reservationExists(IPv6Resrv(IPv6Resrv::TYPE_NA,
IOAddress("2001:db8:1::1")),
IPv6ResrvRange prefixes = host->getIPv6Reservations(IPv6Resrv::TYPE_PD);
ASSERT_EQ(2, std::distance(prefixes.first, prefixes.second));
EXPECT_TRUE(reservationExists(IPv6Resrv(IPv6Resrv::TYPE_PD,
- IOAddress("2001:db8:1:1::"), AuthKey("key##2"), 64),
+ IOAddress("2001:db8:1:1::"), 64),
prefixes));
EXPECT_TRUE(reservationExists(IPv6Resrv(IPv6Resrv::TYPE_PD,
IOAddress("2001:db8:1:2::"), 64),
host->setNextServer(IOAddress("192.0.2.2"));
host->setServerHostname("server-hostname.example.org");
host->setBootFileName("bootfile.efi");
+ host->setKey(AuthKey("random-value"));
std::string user_context = "{ \"foo\": \"bar\" }";
host->setContext(Element::fromJSON(user_context));
host->setNegative(true);
EXPECT_EQ("192.0.2.2", host->getNextServer().toText());
EXPECT_EQ("server-hostname.example.org", host->getServerHostname());
EXPECT_EQ("bootfile.efi", host->getBootFileName());
+ EXPECT_EQ("random-value", host->getKey().ToText());
ASSERT_TRUE(host->getContext());
EXPECT_EQ(user_context, host->getContext()->str());
EXPECT_TRUE(host->getNegative());
" siaddr=(no)"
" sname=(empty)"
" file=(empty)"
+ " key=(empty)"
" ipv6_reservation0=2001:db8:1::cafe"
" ipv6_reservation1=2001:db8:1::1"
" ipv6_reservation2=2001:db8:1:1::/64"
" siaddr=(no)"
" sname=(empty)"
" file=(empty)"
+ " key=(empty)"
" ipv6_reservation0=2001:db8:1::cafe"
" ipv6_reservation1=2001:db8:1::1"
" ipv6_reservation2=2001:db8:1:1::/64"
" siaddr=(no)"
" sname=(empty)"
" file=(empty)"
+ " key=(empty)"
" ipv6_reservations=(none)", host->toText());
// Add some classes.
" siaddr=(no)"
" sname=(empty)"
" file=(empty)"
+ " key=(empty)"
" ipv6_reservations=(none)"
" dhcp4_class0=modem dhcp4_class1=router",
host->toText());
" siaddr=(no)"
" sname=(empty)"
" file=(empty)"
+ " key=(empty)"
" ipv6_reservations=(none)"
" dhcp4_class0=modem dhcp4_class1=router"
" dhcp6_class0=hub dhcp6_class1=device",
}
// This test checks that Host object is correctly unparsed,
-// @todo: add support for keys
TEST_F(HostTest, unparse) {
boost::scoped_ptr<Host> host;
ASSERT_NO_THROW(host.reset(new Host("01:02:03:04:05:06", "hw-address",
EXPECT_EQ(12345, host->getHostId());
}
+// Tets verifies if we can modify the host keys.
+TEST_F(HostTest, keys) {
+ HostPtr host;
+ ASSERT_NO_THROW(host.reset(new Host("01:02:03:04:05:06", "hw-address",
+ SubnetID(1), SubnetID(2),
+ IOAddress("192.0.2.3"),
+ "myhost.example.com")));
+//Key must be empty
+ EXPECT_EQ(0,host->getKey().ToText().length());
+
+ //now set to random value
+ host->setKey(AuthKey("random_key"));
+ EXPECT_EQ("random_key", host->getKey().ToText());
+}
+
// Test verifies if getRandomKeyString can generate 1000 keys which are random
TEST_F(HostTest, randomKeys) {
//use hashtable and set size to 1000
for (int i = 0; i < subnets; ++i) {
// Last boolean value set to false indicates that the same identifier
// must be used for each generated host.
- host = HostDataSourceUtils::initializeHost6(current_address.toText(), id, true, "", false);
+ host = HostDataSourceUtils::initializeHost6(current_address.toText(), id, true, false, "");
host->setIPv4SubnetID(i + 1000);
host->setIPv6SubnetID(i + 1000);
ASSERT_TRUE(hdsptr_);
// Let's create a couple of hosts...
- HostPtr host1 = HostDataSourceUtils::initializeHost6("2001:db8:1::", Host::IDENT_DUID, true, "key##1");
- HostPtr host2 = HostDataSourceUtils::initializeHost6("2001:db8:2::", Host::IDENT_DUID, true, "key##2");
- HostPtr host3 = HostDataSourceUtils::initializeHost6("2001:db8:3::", Host::IDENT_DUID, true, "key##3");
- HostPtr host4 = HostDataSourceUtils::initializeHost6("2001:db8:4::", Host::IDENT_DUID, true, "key##4");
+ HostPtr host1 = HostDataSourceUtils::initializeHost6("2001:db8:1::", Host::IDENT_DUID, true);
+ HostPtr host2 = HostDataSourceUtils::initializeHost6("2001:db8:2::", Host::IDENT_DUID, true);
+ HostPtr host3 = HostDataSourceUtils::initializeHost6("2001:db8:3::", Host::IDENT_DUID, true);
+ HostPtr host4 = HostDataSourceUtils::initializeHost6("2001:db8:4::", Host::IDENT_DUID, true);
// ... and add them to the data source.
ASSERT_NO_THROW(hdsptr_->add(host1));
ASSERT_TRUE(hdsptr_);
// Create a host reservations with prefix reservation (prefix = true)
- HostPtr host = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID,
- true, "key##1", true);
+ HostPtr host = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, true);
// Create IPv6 reservation (for an address) and add it to the host
- IPv6Resrv resv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::2"), AuthKey("key##2"), 128);
+ IPv6Resrv resv(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::2"), 128);
host->addReservation(resv);
// Add this reservation
HostPtr host = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, false);
// Add some reservations
- IPv6Resrv resv1(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::6"), AuthKey("key##1"), len);
- IPv6Resrv resv2(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::7"), AuthKey("key##2"), len);
- IPv6Resrv resv3(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::8"), AuthKey("key##3"), len);
- IPv6Resrv resv4(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::9"), AuthKey("key##4"), len);
+ IPv6Resrv resv1(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::6"), len);
+ IPv6Resrv resv2(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::7"), len);
+ IPv6Resrv resv3(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::8"), len);
+ IPv6Resrv resv4(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::9"), len);
host->addReservation(resv1);
host->addReservation(resv2);
ASSERT_TRUE(hdsptr_);
uint8_t len = 128;
- HostPtr host1 = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, false);
- HostPtr host2 = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, false);
+ HostPtr host1 = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, false, "key##1");
+ HostPtr host2 = HostDataSourceUtils::initializeHost6("2001:db8::1", Host::IDENT_DUID, false, "key##1");
// Add some reservations
- IPv6Resrv resv1(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::6"), AuthKey("key##1"), len);
- IPv6Resrv resv2(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::7"), AuthKey("key##2"), len);
- IPv6Resrv resv3(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::8"), AuthKey("key##3"), len);
- IPv6Resrv resv4(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::9"), AuthKey("key##4"), len);
+ IPv6Resrv resv1(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::6"), len);
+ IPv6Resrv resv2(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::7"), len);
+ IPv6Resrv resv3(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::8"), len);
+ IPv6Resrv resv4(IPv6Resrv::TYPE_NA, IOAddress("2001:db8::9"), len);
host1->addReservation(resv1);
host1->addReservation(resv2);
ss >> n_host;
const std::string prefix = std::string("2001:db8::") + n_host;
- const std::string keys =
- std::string("arbitary_long_enough_for_stress_test"
- "but_less_than_128_characters");
- hosts.push_back(HostDataSourceUtils::initializeHost6(prefix, Host::IDENT_HWADDR, false, keys));
+ hosts.push_back(HostDataSourceUtils::initializeHost6(prefix, Host::IDENT_HWADDR, false, "key##1"));
IPv6ResrvRange range = hosts.back()->getIPv6Reservations();
ASSERT_EQ(1, std::distance(range.first, range.second));
HostDataSourceUtils::initializeHost6(const std::string address,
Host::IdentifierType identifier,
bool prefix,
- const std::string& key,
- bool new_identifier) {
+ bool new_identifier,
+ const std::string auth_key) {
std::vector<uint8_t> ident;
switch (identifier) {
case Host::IDENT_HWADDR:
++subnet4;
++subnet6;
+ std::string default_string;
HostPtr host(new Host(&ident[0], ident.size(), identifier, subnet4, subnet6,
- IOAddress("0.0.0.0")));
+ IOAddress("0.0.0.0"), default_string,
+ default_string, default_string,
+ asiolink:: IOAddress::IPV4_ZERO_ADDRESS(), default_string, default_string,
+ AuthKey(auth_key)));
if (!prefix) {
// Create IPv6 reservation (for an address)
- IPv6Resrv resv(IPv6Resrv::TYPE_NA, IOAddress(address), AuthKey(key), 128);
+ IPv6Resrv resv(IPv6Resrv::TYPE_NA, IOAddress(address), 128);
host->addReservation(resv);
} else {
// Create IPv6 reservation for a /64 prefix
- IPv6Resrv resv(IPv6Resrv::TYPE_PD, IOAddress(address), AuthKey(key), 64);
+ IPv6Resrv resv(IPv6Resrv::TYPE_PD, IOAddress(address), 64);
host->addReservation(resv);
}
return (host);
EXPECT_EQ(host1->getNextServer(), host2->getNextServer());
EXPECT_EQ(host1->getServerHostname(), host2->getServerHostname());
EXPECT_EQ(host1->getBootFileName(), host2->getBootFileName());
+ EXPECT_TRUE(host1->getKey() == host2->getKey());
ConstElementPtr ctx1 = host1->getContext();
ConstElementPtr ctx2 = host2->getContext();
if (ctx1) {
///
/// @return generated Host object
static HostPtr initializeHost6(const std::string address, Host::IdentifierType id,
- bool prefix, const std::string& key = "", bool new_identifier = true);
+ bool prefix, bool new_identifier = true, const std::string key = "");
/// @brief Generates a hardware address in text version.
///
CREATE INDEX IF NOT EXISTS logsindex ON logs (address);
-- Add new field.
-ALTER TABLE host_reservations ADD reserved_auth_key text;
+ALTER TABLE host_reservations ADD auth_key text;
-- Cql requires primary keys in the WHERE here.
DELETE FROM schema_version WHERE version=2;
CREATE INDEX IF NOT EXISTS logsindex ON logs (address);
-- Cql requires primary keys in the WHERE here.
-ALTER TABLE host_reservations ADD reserved_auth_key text;
+ALTER TABLE host_reservations ADD auth_key text;
DELETE FROM schema_version WHERE version=2;
INSERT INTO schema_version (version, minor) VALUES(3, 0);
CREATE INDEX timestamp_index ON logs (timestamp);
#add auth key for reconfiguration
-ALTER TABLE ipv6_reservations
+ALTER TABLE hosts
ADD COLUMN auth_key VARCHAR(16) NULL;
# Update the schema version number
CREATE INDEX timestamp_index ON logs (timestamp);
#add auth key for reconfiguration
-ALTER TABLE ipv6_reservations
+ALTER TABLE hosts
ADD COLUMN auth_key VARCHAR(16) NULL;
# Update the schema version number
CREATE INDEX address_id ON logs (address);
-- Create auth_key in ipv6_reservations
-ALTER TABLE ipv6_reservations ADD COLUMN auth_key VARCHAR(26) DEFAULT NULL;
+ALTER TABLE hosts ADD COLUMN auth_key VARCHAR(16) DEFAULT NULL;
-- Set schema 5.0 version
UPDATE schema_version
CREATE INDEX address_id ON logs (address);
-- Create auth_key in ipv6_reservations
-ALTER TABLE ipv6_reservations ADD COLUMN auth_key VARCHAR(16) DEFAULT NULL;
+ALTER TABLE hosts ADD COLUMN auth_key VARCHAR(16) DEFAULT NULL;
-- Set 5.0 schema version.
UPDATE schema_version
projects / thirdparty / kea.git / commitdiff
