bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

compaction_manager: stop_tasks: fixup indentation

Browse Source 
Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
Message-Id: <20220302081547.2205813-3-bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2022-03-02 10:15:47 +02:00
committed by Botond Dénes
parent 95cf4c1c6f
commit 3b5ba5c1a9
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
compaction/compaction_manager.cc
View File

@@ -522,16 +522,16 @@ future<> compaction_manager::stop_tasks(std::vector<lw_shared_ptr<task>> tasks,
t->stop(reason);
}
co_await parallel_for_each(tasks, [this] (auto& task) -> future<> {
try {
co_await task->compaction_done.get_future();
} catch (sstables::compaction_stopped_exception& e) {
// swallow stop exception if a given procedure decides to propagate it to the caller,
// as it happens with reshard and reshape.
} catch (...) {
cmlog.debug("Stopping task {} table={}: task returned error: {}", fmt::ptr(task.get()), fmt::ptr(task->compacting_table), std::current_exception());
throw;
}
cmlog.debug("Stopping task {} table={}: done", fmt::ptr(task.get()), fmt::ptr(task->compacting_table));
try {
co_await task->compaction_done.get_future();
} catch (sstables::compaction_stopped_exception&) {
// swallow stop exception if a given procedure decides to propagate it to the caller,
// as it happens with reshard and reshape.
} catch (...) {
cmlog.debug("Stopping task {} table={}: task returned error: {}", fmt::ptr(task.get()), fmt::ptr(task->compacting_table), std::current_exception());
throw;
}
cmlog.debug("Stopping task {} table={}: done", fmt::ptr(task.get()), fmt::ptr(task->compacting_table));
});
}