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

db/size_estimates_virtual_reader: mark as blocked when obtaining local ranges

Browse Source
This commit is contained in:
Botond Dénes
2021-05-14 11:57:15 +03:00
parent b5cbd19383
commit ea2345c944
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
db/size_estimates_virtual_reader.cc
View File

@@ -250,7 +250,9 @@ future<> size_estimates_mutation_reader::get_next_partition() {
_end_of_stream = true;
return make_ready_future<>();
}
return get_local_ranges(_db).then([this] (auto&& ranges) {
return do_with(reader_permit::blocked_guard(_permit), [this] (reader_permit::blocked_guard&) {
return get_local_ranges(_db);
}).then([this] (auto&& ranges) {
auto estimates = this->estimates_for_current_keyspace(std::move(ranges));
auto mutations = db::system_keyspace::make_size_estimates_mutation(*_current_partition, std::move(estimates));
++_current_partition;