mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-08 16:03:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage_service: raft topology: split get_excluded_nodes from exec_global_command

Browse Source 
Will be used later.
This commit is contained in:
Gleb Natapov
2023-09-07 16:45:20 +03:00
parent 897a7e599a
commit a49ae3ff87
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
service/storage_service.cc
View File

@@ -1090,10 +1090,14 @@ class topology_coordinator {
co_return guard;
}
future<node_to_work_on> exec_global_command(node_to_work_on&& node, const raft_topology_cmd& cmd) {
std::unordered_set<raft::server_id> exclude_nodes = parse_ignore_nodes(node);
std::unordered_set<raft::server_id> get_excluded_nodes(const node_to_work_on& node) {
auto exclude_nodes = parse_ignore_nodes(node);
exclude_nodes.insert(parse_replaced_node(node));
auto guard = co_await exec_global_command(std::move(node.guard), cmd, exclude_nodes, drop_guard_and_retake::yes);
return exclude_nodes;
}
future<node_to_work_on> exec_global_command(node_to_work_on&& node, const raft_topology_cmd& cmd) {
auto guard = co_await exec_global_command(std::move(node.guard), cmd, get_excluded_nodes(node), drop_guard_and_retake::yes);
co_return retake_node(std::move(guard), node.id);
};