#include <seastar/core/app-template.hh>
#include <seastar/core/reactor.hh>
+#include <seastar/core/alien.hh>
#include <seastar/core/scollectd.hh>
#include <seastar/core/metrics_api.hh>
#include <boost/program_options.hpp>
#include <seastar/core/print.hh>
#include <seastar/util/log.hh>
#include <seastar/util/log-cli.hh>
+#include <seastar/net/native-stack.hh>
#include <boost/program_options.hpp>
#include <boost/make_shared.hpp>
#include <fstream>
#include <cstdlib>
+#include "program_options.hh"
+
namespace seastar {
namespace bpo = boost::program_options;
+using namespace std::chrono_literals;
+
static
-reactor_config
-reactor_config_from_app_config(app_template::config cfg) {
- reactor_config ret;
- ret.auto_handle_sigint_sigterm = cfg.auto_handle_sigint_sigterm;
- ret.task_quota = cfg.default_task_quota;
- return ret;
+app_template::seastar_options
+seastar_options_from_config(app_template::config cfg) {
+ app_template::seastar_options opts;
+ opts.name = std::move(cfg.name);
+ opts.description = std::move(cfg.description);
+ opts.auto_handle_sigint_sigterm = std::move(cfg.auto_handle_sigint_sigterm);
+ opts.reactor_opts.task_quota_ms.set_default_value(cfg.default_task_quota / 1ms);
+ opts.reactor_opts.max_networking_io_control_blocks.set_default_value(cfg.max_networking_aio_io_control_blocks);
+ return opts;
}
-app_template::app_template(app_template::config cfg)
- : _cfg(std::move(cfg))
- , _opts(_cfg.name + " options")
+app_template::seastar_options::seastar_options()
+ : program_options::option_group(nullptr, "seastar")
+ , reactor_opts(this)
+ , metrics_opts(this)
+ , smp_opts(this)
+ , scollectd_opts(this)
+ , log_opts(this)
+{
+}
+
+app_template::app_template(app_template::seastar_options opts)
+ : _alien(std::make_unique<alien::instance>())
+ , _smp(std::make_shared<smp>(*_alien))
+ , _opts(std::move(opts))
+ , _app_opts(_opts.name + " options")
, _conf_reader(get_default_configuration_reader()) {
- _opts.add_options()
+
+ if (!alien::internal::default_instance) {
+ alien::internal::default_instance = _alien.get();
+ }
+ _app_opts.add_options()
("help,h", "show help message")
;
+ _app_opts.add_options()
+ ("help-seastar", "show help message about seastar options")
+ ;
+ _app_opts.add_options()
+ ("help-loggers", "print a list of logger names and exit")
+ ;
+
+ {
+ program_options::options_description_building_visitor visitor;
+ _opts.describe(visitor);
+ _opts_conf_file.add(std::move(visitor).get_options_description());
+ }
+
+ _seastar_opts.add(_opts_conf_file);
+}
+
+app_template::app_template(app_template::config cfg)
+ : app_template(seastar_options_from_config(std::move(cfg)))
+{
+}
- smp::register_network_stacks();
- _opts_conf_file.add(reactor::get_options_description(reactor_config_from_app_config(_cfg)));
- _opts_conf_file.add(seastar::metrics::get_options_description());
- _opts_conf_file.add(smp::get_options_description());
- _opts_conf_file.add(scollectd::get_options_description());
- _opts_conf_file.add(log_cli::get_options_description());
+app_template::~app_template() = default;
- _opts.add(_opts_conf_file);
+const app_template::seastar_options& app_template::options() const {
+ return _opts;
}
app_template::configuration_reader app_template::get_default_configuration_reader() {
}
boost::program_options::options_description& app_template::get_options_description() {
- return _opts;
+ return _app_opts;
}
boost::program_options::options_description& app_template::get_conf_file_options_description() {
boost::program_options::options_description_easy_init
app_template::add_options() {
- return _opts.add_options();
+ return _app_opts.add_options();
}
void
app_template::add_positional_options(std::initializer_list<positional_option> options) {
for (auto&& o : options) {
- _opts.add(boost::make_shared<bpo::option_description>(o.name, o.value_semantic, o.help));
+ _app_opts.add(boost::make_shared<bpo::option_description>(o.name, o.value_semantic, o.help));
_pos_opts.add(o.name, o.max_count);
}
}
}
int
-app_template::run(int ac, char ** av, std::function<future<int> ()>&& func) {
+app_template::run(int ac, char ** av, std::function<future<int> ()>&& func) noexcept {
return run_deprecated(ac, av, [func = std::move(func)] () mutable {
auto func_done = make_lw_shared<promise<>>();
engine().at_exit([func_done] { return func_done->get_future(); });
}
int
-app_template::run(int ac, char ** av, std::function<future<> ()>&& func) {
+app_template::run(int ac, char ** av, std::function<future<> ()>&& func) noexcept {
return run(ac, av, [func = std::move(func)] {
return func().then([] () {
return 0;
}
int
-app_template::run_deprecated(int ac, char ** av, std::function<void ()>&& func) {
+app_template::run_deprecated(int ac, char ** av, std::function<void ()>&& func) noexcept {
#ifdef SEASTAR_DEBUG
fmt::print("WARNING: debug mode. Not for benchmarking or production\n");
#endif
+ boost::program_options::options_description all_opts;
+ all_opts.add(_app_opts);
+ all_opts.add(_seastar_opts);
+
bpo::variables_map configuration;
try {
bpo::store(bpo::command_line_parser(ac, av)
- .options(_opts)
+ .options(all_opts)
.positional(_pos_opts)
.run()
, configuration);
return 2;
}
if (configuration.count("help")) {
- if (!_cfg.description.empty()) {
- std::cout << _cfg.description << "\n";
+ if (!_opts.description.empty()) {
+ std::cout << _opts.description << "\n";
}
- std::cout << _opts << "\n";
+ std::cout << _app_opts << "\n";
+ return 1;
+ }
+ if (configuration.count("help-seastar")) {
+ std::cout << _seastar_opts << "\n";
return 1;
}
- if (configuration["help-loggers"].as<bool>()) {
+ if (configuration.count("help-loggers")) {
log_cli::print_available_loggers(std::cout);
return 1;
}
return 1;
}
+ {
+ program_options::variables_map_extracting_visitor visitor(configuration);
+ _opts.mutate(visitor);
+ }
+ _opts.reactor_opts._argv0 = std::string(av[0]);
+ _opts.reactor_opts._auto_handle_sigint_sigterm = _opts.auto_handle_sigint_sigterm;
+ if (auto* native_stack = dynamic_cast<net::native_stack_options*>(_opts.reactor_opts.network_stack.get_selected_candidate_opts())) {
+ native_stack->_hugepages = _opts.smp_opts.hugepages;
+ }
+
// Needs to be before `smp::configure()`.
try {
- apply_logging_settings(log_cli::extract_settings(configuration));
+ apply_logging_settings(log_cli::extract_settings(_opts.log_opts));
} catch (const std::runtime_error& exn) {
std::cout << "logging configuration error: " << exn.what() << '\n';
return 1;
}
- configuration.emplace("argv0", boost::program_options::variable_value(std::string(av[0]), false));
try {
- smp::configure(configuration, reactor_config_from_app_config(_cfg));
+ _smp->configure(_opts.smp_opts, _opts.reactor_opts);
} catch (...) {
std::cerr << "Could not initialize seastar: " << std::current_exception() << std::endl;
return 1;
// No need to wait for this future.
// func is waited on via engine().run()
(void)engine().when_started().then([this] {
- return seastar::metrics::configure(this->configuration()).then([this] {
+ return seastar::metrics::configure(_opts.metrics_opts).then([this] {
// set scollectd use the metrics configuration, so the later
// need to be set first
- scollectd::configure( this->configuration());
+ scollectd::configure( _opts.scollectd_opts);
});
}).then(
std::move(func)
}
});
auto exit_code = engine().run();
- smp::cleanup();
+ _smp->cleanup();
return exit_code;
}
projects / ceph.git / blobdiff