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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "config_proxy.h"
#include <filesystem>
#include "crimson/common/buffer_io.h"
namespace crimson::common {
ConfigProxy::ConfigProxy(const EntityName& name, std::string_view cluster)
{
if (seastar::this_shard_id() != 0) {
return;
}
// set the initial value on CPU#0
values.reset(seastar::make_lw_shared<ConfigValues>());
values.get()->name = name;
values.get()->cluster = cluster;
// and the only copy of md_config_impl<> is allocated on CPU#0
local_config.reset(new md_config_t{*values, obs_mgr, true});
if (name.is_mds()) {
local_config->set_val_default(*values, obs_mgr,
"keyring", "$mds_data/keyring");
} else if (name.is_osd()) {
local_config->set_val_default(*values, obs_mgr,
"keyring", "$osd_data/keyring");
}
}
seastar::future<> ConfigProxy::start()
{
// populate values and config to all other shards
if (!values) {
return seastar::make_ready_future<>();
}
return container().invoke_on_others([this](auto& proxy) {
return values.copy().then([config=local_config.get(),
&proxy](auto foreign_values) {
proxy.values.reset();
proxy.values = std::move(foreign_values);
proxy.remote_config = config;
return seastar::make_ready_future<>();
});
});
}
void ConfigProxy::show_config(ceph::Formatter* f) const {
get_config().show_config(*values, f);
}
seastar::future<> ConfigProxy::parse_config_files(const std::string& conf_files)
{
auto conffile_paths =
get_config().get_conffile_paths(*values,
conf_files.empty() ? nullptr : conf_files.c_str(),
&std::cerr,
CODE_ENVIRONMENT_DAEMON);
return seastar::do_with(std::move(conffile_paths), [this] (auto& paths) {
return seastar::repeat([path=paths.begin(), e=paths.end(), this]() mutable {
if (path == e) {
// tried all conffile, none of them works
return seastar::make_ready_future<seastar::stop_iteration>(
seastar::stop_iteration::yes);
}
return crimson::read_file(*path++).then([this](auto&& buf) {
return do_change([buf=std::move(buf), this](ConfigValues& values) {
if (get_config().parse_buffer(values, obs_mgr,
buf.get(), buf.size(),
&std::cerr) == 0) {
get_config().update_legacy_vals(values);
} else {
throw std::invalid_argument("parse error");
}
}).then([] {
// this one works!
return seastar::make_ready_future<seastar::stop_iteration>(
seastar::stop_iteration::yes);
});
}).handle_exception_type([] (const std::filesystem::filesystem_error&) {
return seastar::make_ready_future<seastar::stop_iteration>(
seastar::stop_iteration::no);
}).handle_exception_type([] (const std::invalid_argument&) {
return seastar::make_ready_future<seastar::stop_iteration>(
seastar::stop_iteration::no);
});
});
});
}
ConfigProxy::ShardedConfig ConfigProxy::sharded_conf;
}
|
