mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-28 10:41:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

commitlog: coroutinize segment_manager::shutdown_all_segments

Browse Source
This commit is contained in:
Calle Wilund
2021-06-29 14:45:22 +00:00
parent 2f048e658b
commit 4678d1fbec
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
db/commitlog/commitlog.cc
View File

@@ -1724,10 +1724,9 @@ future<> db::commitlog::segment_manager::shutdown_all_segments() {
// #8952 - calls that do sync/cycle can end up altering
// _segments (end_flush()->discard_unused())
auto def_copy = _segments;
return parallel_for_each(def_copy, [] (sseg_ptr s) {
return s->shutdown().then([](sseg_ptr s) {
clogger.debug("Shutdown segment {}", *s);
});
co_await parallel_for_each(def_copy, [] (sseg_ptr s) -> future<> {
co_await s->shutdown();
clogger.debug("Shutdown segment {}", *s);
});
}