From 88efdbe2680f675b21c2d75ab940eac6e14e7e26 Mon Sep 17 00:00:00 2001 From: Kefu Chai Date: Wed, 15 Jun 2022 00:31:09 +0800 Subject: [PATCH] crimson/osd: use seastar::deferred_stop() trade `seastar::defer()` for `seastar::deferred_stop()` to simplify the code a little bit. Signed-off-by: Kefu Chai --- src/crimson/osd/main.cc | 17 +++++------------ 1 file changed, 5 insertions(+), 12 deletions(-) diff --git a/src/crimson/osd/main.cc b/src/crimson/osd/main.cc index 9076a58f309..823c82c03b1 100644 --- a/src/crimson/osd/main.cc +++ b/src/crimson/osd/main.cc @@ -14,6 +14,7 @@ #include #include #include +#include #include #include @@ -228,13 +229,9 @@ int main(int argc, const char* argv[]) ); } sharded_conf().start(init_params.name, cluster_name).get(); - auto stop_conf = seastar::defer([] { - sharded_conf().stop().get(); - }); + auto stop_conf = seastar::deferred_stop(sharded_conf()); sharded_perf_coll().start().get(); - auto stop_perf_coll = seastar::defer([] { - sharded_perf_coll().stop().get(); - }); + auto stop_perf_coll = seastar::deferred_stop(sharded_perf_coll()); local_conf().parse_config_files(conf_file_list).get(); local_conf().parse_env().get(); local_conf().parse_argv(config_proxy_args).get(); @@ -256,9 +253,7 @@ int main(int argc, const char* argv[]) if (uint16_t prom_port = config["prometheus_port"].as(); prom_port != 0) { prom_server.start("prometheus").get(); - stop_prometheus = seastar::make_shared(seastar::defer([&] { - prom_server.stop().get(); - })); + stop_prometheus = seastar::make_shared(seastar::deferred_stop(prom_server)); seastar::prometheus::config prom_config; prom_config.prefix = config["prometheus_prefix"].as(); @@ -294,9 +289,7 @@ int main(int argc, const char* argv[]) std::ref(*store), cluster_msgr, client_msgr, hb_front_msgr, hb_back_msgr).get(); - auto stop_osd = seastar::defer([&] { - osd.stop().get(); - }); + auto stop_osd = seastar::deferred_stop(osd); if (config.count("mkkey")) { make_keyring().get(); } -- 2.39.5