mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-27 11:55:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

commitlog: coroutinize segment_manager::clear_reserve_segments

Browse Source
This commit is contained in:
Calle Wilund
2021-06-29 14:39:37 +00:00
parent ec430807fc
commit ad4e4e9ee4
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
db/commitlog/commitlog.cc
View File

@@ -1699,14 +1699,11 @@ future<> db::commitlog::segment_manager::clear_reserve_segments() {
tmp.emplace_back(std::move(s));
return true;
});
auto i = tmp.begin();
auto e = tmp.end();
return parallel_for_each(i, e, [this](const sstring& filename) {
co_await parallel_for_each(tmp, [this](const sstring& filename) {
clogger.debug("Deleting recycled segment file {}", filename);
return delete_file(filename);
}).finally([this, tmp = std::move(tmp)] {
}).finally([this] {
return do_pending_deletes();
});
}