return values.get();
}
+ void get_config_bl(uint64_t have_version,
+ ceph::buffer::list *bl,
+ uint64_t *got_version) {
+ get_config().get_config_bl(get_config_values(), have_version,
+ bl, got_version);
+ }
+ void get_defaults_bl(ceph::buffer::list *bl) {
+ get_config().get_defaults_bl(get_config_values(), bl);
+ }
// required by sharded<>
seastar::future<> start();
seastar::future<> stop() {
// ask for the mgrconfigure message
auto m = crimson::make_message<MMgrOpen>();
m->daemon_name = local_conf()->name.get_id();
+ local_conf().get_config_bl(0, &m->config_bl, &last_config_bl_version);
+ local_conf().get_defaults_bl(&m->config_defaults_bl);
return conn->send(std::move(m));
} else {
return seastar::now();
crimson::net::ConnectionRef conn;
seastar::timer<seastar::lowres_clock> report_timer;
crimson::common::Gated gate;
+ uint64_t last_config_bl_version = 0;
};
inline std::ostream& operator<<(std::ostream& out, const Client& client) {