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

sstables: delete_atomically: delete sstables in a thread

Browse Source 
In prepaton for implementing a pending_delete log file.

Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2019-02-04 19:40:19 +02:00
parent 9ac04850a0
commit 70fda0eda0
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
sstables/sstables.cc
View File

@@ -3166,8 +3166,10 @@ delete_sstable_and_maybe_large_data_entries(shared_sstable sst, const db::large_
future<>
delete_atomically(std::vector<shared_sstable> ssts, const db::large_data_handler& large_data_handler) {
// FIXME: this needs to be done atomically (using a log file of sstables we intend to delete)
return parallel_for_each(ssts, [&large_data_handler] (shared_sstable sst) {
return delete_sstable_and_maybe_large_data_entries(sst, large_data_handler);
return seastar::async([ssts = std::move(ssts), &large_data_handler] {
parallel_for_each(ssts, [&large_data_handler] (shared_sstable sst) {
return delete_sstable_and_maybe_large_data_entries(sst, large_data_handler);
}).get();
});
}