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

flat_mutation_reader: return future from next_partition

Browse Source 
To allow it to asynchronously close underlying readers
on next_partition().

Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2021-01-10 18:09:51 +02:00
parent ff931c2ecc
commit 29002e3b48
26 changed files with 155 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
db/view/build_progress_virtual_reader.hh
View File

@@ -162,12 +162,13 @@ class build_progress_virtual_reader {
});
}
virtual void next_partition() override {
virtual future<> next_partition() override {
_end_of_stream = false;
clear_buffer_to_next_partition();
if (is_buffer_empty()) {
_underlying.next_partition();
return _underlying.next_partition();
}
return make_ready_future<>();
}
virtual future<> fast_forward_to(const dht::partition_range& pr, db::timeout_clock::time_point timeout) override {