mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-07 15:33:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

replica: distributed_loader: reindent process_sstable_dir

Browse Source 
Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2022-05-19 12:59:29 +03:00
parent 33179c8647
commit 8080e98309
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
replica/distributed_loader.cc
View File

@@ -91,15 +91,14 @@ distributed_loader::process_sstable_dir(sharded<sstables::sstable_directory>& di
return utils::directories::verify_owner_and_mode(d.sstable_dir());
});
// FIXME: indentation
co_await dir.invoke_on_all([&dir, sort_sstables_according_to_owner] (sstables::sstable_directory& d) -> future<> {
co_await dir.invoke_on_all([&dir, sort_sstables_according_to_owner] (sstables::sstable_directory& d) -> future<> {
// Supposed to be called with the node either down or on behalf of maintenance tasks
// like nodetool refresh
co_await d.process_sstable_dir(service::get_local_streaming_priority(), sort_sstables_according_to_owner);
co_await d.move_foreign_sstables(dir);
});
co_await d.move_foreign_sstables(dir);
});
co_await dir.invoke_on_all(&sstables::sstable_directory::commit_directory_changes);
co_await dir.invoke_on_all(&sstables::sstable_directory::commit_directory_changes);
}
future<>