diff --git a/src/v/cluster/config_frontend.cc b/src/v/cluster/config_frontend.cc index f61d6bfe81d0..a1bb8b9e3fff 100644 --- a/src/v/cluster/config_frontend.cc +++ b/src/v/cluster/config_frontend.cc @@ -30,9 +30,6 @@ config_frontend::config_frontend( , _as(as) , _self(config::node().node_id()) {} -ss::future<> config_frontend::start() { return ss::now(); } -ss::future<> config_frontend::stop() { return ss::now(); } - /** * RPC wrapper on do_patch, to dispatch to the controller leader * if we aren't it. diff --git a/src/v/cluster/config_frontend.h b/src/v/cluster/config_frontend.h index ccdfc38f8567..7b1059d67f23 100644 --- a/src/v/cluster/config_frontend.h +++ b/src/v/cluster/config_frontend.h @@ -45,9 +45,6 @@ class config_frontend final { ss::future set_status(config_status&, model::timeout_clock::time_point); - ss::future<> start(); - ss::future<> stop(); - void set_next_version(config_version v); private: diff --git a/src/v/cluster/config_manager.cc b/src/v/cluster/config_manager.cc index 5a27e295231c..02bcf2b37fe6 100644 --- a/src/v/cluster/config_manager.cc +++ b/src/v/cluster/config_manager.cc @@ -217,7 +217,7 @@ ss::future<> config_manager::start() { } ss::future<> config_manager::stop() { - vlog(clusterlog.info, "stopping cluster::config_manager..."); + vlog(clusterlog.info, "Stopping Config Manager..."); _reconcile_wait.broken(); co_await _gate.close(); } diff --git a/src/v/cluster/controller_backend.cc b/src/v/cluster/controller_backend.cc index 4522a6c3d6d4..b16ce0ddfd36 100644 --- a/src/v/cluster/controller_backend.cc +++ b/src/v/cluster/controller_backend.cc @@ -266,6 +266,7 @@ controller_backend::controller_backend( , _as(as) {} ss::future<> controller_backend::stop() { + vlog(clusterlog.info, "Stopping Controller Backend..."); _housekeeping_timer.cancel(); return _gate.close(); } diff --git a/src/v/cluster/feature_manager.cc b/src/v/cluster/feature_manager.cc index 2a9f91709222..5fa6f381206b 100644 --- a/src/v/cluster/feature_manager.cc +++ b/src/v/cluster/feature_manager.cc @@ -155,6 +155,7 @@ ss::future<> feature_manager::start() { co_return; } ss::future<> feature_manager::stop() { + vlog(clusterlog.info, "Stopping Feature Manager..."); _group_manager.local().unregister_leadership_notification( _leader_notify_handle); _hm_backend.local().unregister_node_callback(_health_notify_handle); diff --git a/src/v/cluster/health_manager.cc b/src/v/cluster/health_manager.cc index 118abf415917..605ab983ef3e 100644 --- a/src/v/cluster/health_manager.cc +++ b/src/v/cluster/health_manager.cc @@ -53,6 +53,7 @@ ss::future<> health_manager::start() { } ss::future<> health_manager::stop() { + vlog(clusterlog.info, "Stopping Health Manager..."); _timer.cancel(); return _gate.close(); } diff --git a/src/v/cluster/health_monitor_backend.cc b/src/v/cluster/health_monitor_backend.cc index 8d82361f74f9..0ccdd7e654a8 100644 --- a/src/v/cluster/health_monitor_backend.cc +++ b/src/v/cluster/health_monitor_backend.cc @@ -116,6 +116,7 @@ void health_monitor_backend::unregister_node_callback( } ss::future<> health_monitor_backend::stop() { + vlog(clusterlog.info, "Stopping Health Monitor Backend..."); _raft_manager.local().unregister_leadership_notification( _leadership_notification_handle); diff --git a/src/v/cluster/health_monitor_frontend.cc b/src/v/cluster/health_monitor_frontend.cc index c55a361376fc..061503f932f9 100644 --- a/src/v/cluster/health_monitor_frontend.cc +++ b/src/v/cluster/health_monitor_frontend.cc @@ -30,6 +30,7 @@ ss::future<> health_monitor_frontend::start() { } ss::future<> health_monitor_frontend::stop() { + vlog(clusterlog.info, "Stopping Health Monitor Frontend..."); if (ss::this_shard_id() == refresher_shard) { if (_refresh_timer.armed()) { _refresh_timer.cancel(); diff --git a/src/v/cluster/members_backend.cc b/src/v/cluster/members_backend.cc index f69505b91d60..0c129f621712 100644 --- a/src/v/cluster/members_backend.cc +++ b/src/v/cluster/members_backend.cc @@ -58,6 +58,7 @@ members_backend::members_backend( } ss::future<> members_backend::stop() { + vlog(clusterlog.info, "Stopping Members Backend..."); _retry_timer.cancel(); _new_updates.broken(); return _bg.close(); diff --git a/src/v/cluster/members_frontend.cc b/src/v/cluster/members_frontend.cc index 38dc0c2af4fa..785acfe7e1e1 100644 --- a/src/v/cluster/members_frontend.cc +++ b/src/v/cluster/members_frontend.cc @@ -43,10 +43,6 @@ members_frontend::members_frontend( , _feature_table(feature_table) , _as(as) {} -ss::future<> members_frontend::start() { return ss::now(); } - -ss::future<> members_frontend::stop() { return ss::now(); } - ss::future members_frontend::finish_node_reallocations(model::node_id id) { auto leader = _leaders.local().get_leader(model::controller_ntp); diff --git a/src/v/cluster/members_frontend.h b/src/v/cluster/members_frontend.h index 83178d45b7f0..ec970eaa0920 100644 --- a/src/v/cluster/members_frontend.h +++ b/src/v/cluster/members_frontend.h @@ -39,9 +39,6 @@ class members_frontend { ss::sharded&, ss::sharded&); - ss::future<> start(); - ss::future<> stop(); - ss::future decommission_node(model::node_id); ss::future recommission_node(model::node_id); ss::future finish_node_reallocations(model::node_id); diff --git a/src/v/cluster/metrics_reporter.cc b/src/v/cluster/metrics_reporter.cc index bba05716dfda..b02dc279c596 100644 --- a/src/v/cluster/metrics_reporter.cc +++ b/src/v/cluster/metrics_reporter.cc @@ -127,6 +127,7 @@ ss::future<> metrics_reporter::start() { } ss::future<> metrics_reporter::stop() { + vlog(clusterlog.info, "Stopping Metrics Reporter..."); _tick_timer.cancel(); co_await _gate.close(); } diff --git a/src/v/cluster/partition_leaders_table.cc b/src/v/cluster/partition_leaders_table.cc index 1f976923b624..7f2d98fa259d 100644 --- a/src/v/cluster/partition_leaders_table.cc +++ b/src/v/cluster/partition_leaders_table.cc @@ -27,6 +27,8 @@ partition_leaders_table::partition_leaders_table( : _topic_table(topic_table) {} ss::future<> partition_leaders_table::stop() { + vlog(clusterlog.info, "Stopping Partition Leaders Table..."); + while (!_leader_promises.empty()) { auto it = _leader_promises.begin(); for (auto& promise : it->second) { diff --git a/src/v/cluster/scheduling/leader_balancer.cc b/src/v/cluster/scheduling/leader_balancer.cc index 493ef0f36539..80ebfd27596f 100644 --- a/src/v/cluster/scheduling/leader_balancer.cc +++ b/src/v/cluster/scheduling/leader_balancer.cc @@ -192,6 +192,7 @@ ss::future<> leader_balancer::start() { } ss::future<> leader_balancer::stop() { + vlog(clusterlog.info, "Stopping Leader Balancer..."); _leaders.unregister_leadership_change_notification( _raft0->ntp(), _leader_notify_handle); _members.unregister_maintenance_state_change_notification(