mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-02 21:17:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

replica: coroutinize table::discard_sstables()

Browse Source 
Signed-off-by: Raphael S. Carvalho <raphaelsc@scylladb.com>
This commit is contained in:
Raphael S. Carvalho
2022-11-25 20:27:04 -03:00
parent 192b64a5ac
commit b9a33d5a91
1 changed files with 8 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
replica/table.cc
View File

@@ -1681,22 +1681,20 @@ future<db::replay_position> table::discard_sstables(db_clock::time_point truncat
cf.refresh_compound_sstable_set();
}
};
auto p = make_lw_shared<pruner>(*this, *_compaction_group);
return _cache.invalidate(row_cache::external_updater([p, truncated_at] {
p->prune(truncated_at);
tlogger.debug("cleaning out row cache");
})).then([this, p]() mutable {
// FIXME: indentation.
auto p = make_lw_shared<pruner>(*this, *_compaction_group);
co_await _cache.invalidate(row_cache::external_updater([p, truncated_at] {
p->prune(truncated_at);
tlogger.debug("cleaning out row cache");
}));
rebuild_statistics();
return parallel_for_each(p->remove, [this, p] (pruner::removed_sstable& r) {
co_await coroutine::parallel_for_each(p->remove, [this, p] (pruner::removed_sstable& r) {
if (r.enable_backlog_tracker) {
remove_sstable_from_backlog_tracker(p->cg.get_backlog_tracker(), r.sst);
}
return sstables::sstable_directory::delete_atomically({r.sst});
}).then([p] {
return make_ready_future<db::replay_position>(p->rp);
});
});
co_return p->rp;
}
void table::set_schema(schema_ptr s) {