blob: f734a5495f6a1aa3a016a1b088ee7c14d13d405a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// Copyright (C) 2018-2024 Internet Systems Consortium, Inc. ("ISC")
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
#include <config.h>
#include <process/config_ctl_info.h>
using namespace isc::data;
using namespace isc::util;
namespace isc {
namespace process {
void
ConfigDbInfo::setAccessString(const std::string& access_str, bool test_mode) {
access_str_ = access_str;
access_params_.clear();
if (!test_mode) {
access_params_ = db::DatabaseConnection::parse(access_str_);
}
}
bool
ConfigDbInfo::equals(const ConfigDbInfo& other) const {
return (access_params_ == other.access_params_);
}
isc::data::ElementPtr
ConfigDbInfo::toElement() const {
return (isc::db::DatabaseConnection::toElementDbAccessString(access_str_));
}
bool
ConfigDbInfo::getParameterValue(const std::string& name, std::string& value) const {
auto param = access_params_.find(name);
if (param == access_params_.end()) {
return (false);
}
value = param->second;
return (true);
}
//******** ConfigControlInfo ********//
ConfigControlInfo::ConfigControlInfo(const ConfigControlInfo& other)
: config_fetch_wait_time_(other.config_fetch_wait_time_) {
for (auto const& db : other.db_infos_) {
addConfigDatabase(db.getAccessString());
}
}
void
ConfigControlInfo::addConfigDatabase(const std::string& access_str) {
ConfigDbInfo new_db;
new_db.setAccessString(access_str);
for (auto const& db : db_infos_) {
if (new_db == db) {
// we have a duplicate!
isc_throw(BadValue, "database with access parameters: "
<< access_str << " already exists");
}
}
db_infos_.push_back(new_db);
}
const ConfigDbInfo&
ConfigControlInfo::findConfigDb(const std::string& param_name,
const std::string& param_value) {
for (auto const& db : db_infos_) {
std::string db_value;
if (db.getParameterValue(param_name, db_value) && (param_value == db_value)) {
return (db);
}
}
return (EMPTY_DB());
}
const ConfigDbInfo&
ConfigControlInfo::EMPTY_DB() {
static ConfigDbInfo empty;
return (empty);
}
void
ConfigControlInfo::clear() {
db_infos_.clear();
config_fetch_wait_time_ = Optional<uint16_t>(30, true);
}
void
ConfigControlInfo::merge(const ConfigControlInfo& other) {
if (!other.db_infos_.empty()) {
db_infos_ = other.db_infos_;
}
}
ElementPtr
ConfigControlInfo::toElement() const {
ElementPtr result = Element::createMap();
ElementPtr db_list = Element::createList();
for (auto const& db_info : db_infos_) {
db_list->add(db_info.toElement());
}
result->set("config-databases", db_list);
if (!config_fetch_wait_time_.unspecified()) {
result->set("config-fetch-wait-time",
Element::create(static_cast<int>(config_fetch_wait_time_)));
}
return (result);
}
bool
ConfigControlInfo::equals(const ConfigControlInfo& other) const {
return ((db_infos_ == other.db_infos_) &&
(config_fetch_wait_time_.get() == other.config_fetch_wait_time_.get()));
}
} // end of namespace isc::process
} // end of namespace isc
|
