mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

repair: row_level: coroutinize repair_meta::repair_row_level_stop()

Browse Source 
Not really helping anything, but a coroutine is a safer platform for
future changes in administrative APIs.
This commit is contained in:
Avi Kivity
2024-09-04 15:03:00 +03:00
parent 587b6fe400
commit ffbb973063
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
repair/row_level.cc
View File

@@ -1598,10 +1598,10 @@ public:
// RPC API
future<> repair_row_level_stop(gms::inet_address remote_node, sstring ks_name, sstring cf_name, dht::token_range range, shard_id dst_cpu_id) {
if (remote_node == myip()) {
return stop();
co_return co_await stop();
}
stats().rpc_call_nr++;
return _messaging.send_repair_row_level_stop(msg_addr(remote_node),
co_return co_await _messaging.send_repair_row_level_stop(msg_addr(remote_node),
_repair_meta_id, std::move(ks_name), std::move(cf_name), std::move(range), dst_cpu_id);
}