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

sstables: mutation_reader: Move mp_row_consumer::fast_forward_to() out of line

Browse Source
This commit is contained in:
Tomasz Grabiec
2017-04-10 20:22:11 +02:00
parent bb3e683783
commit a37712e9ae
1 changed files with 21 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
sstables/partition.cc
View File

@@ -813,25 +813,7 @@ public:
// must be after it.
//
// Returns false if skipping is not necessary.
bool fast_forward_to(position_range r) {
_fwd_range = std::move(r);
_out_of_range = _is_mutation_end;
_after_fwd_range_start = false;
_range_tombstones.forward_to(_fwd_range.start());
if (_ready && !_ready->relevant_for_range(*_schema, _fwd_range.start())) {
_ready = {};
}
if (_in_progress) {
advance_to(*_in_progress);
}
sstlog.trace("mp_row_consumer {}: fast_forward_to({}) => out_of_range={}, skip_in_progress={}", this, _fwd_range, _out_of_range, _skip_in_progress);
return !_in_progress || _skip_in_progress;
}
bool fast_forward_to(position_range);
const position_range& current_range() const {
return _fwd_range;
@@ -996,6 +978,26 @@ mp_row_consumer::push_ready_fragments() {
return proceed::yes;
}
bool mp_row_consumer::fast_forward_to(position_range r) {
_fwd_range = std::move(r);
_out_of_range = _is_mutation_end;
_after_fwd_range_start = false;
_range_tombstones.forward_to(_fwd_range.start());
if (_ready && !_ready->relevant_for_range(*_schema, _fwd_range.start())) {
_ready = {};
}
if (_in_progress) {
advance_to(*_in_progress);
}
sstlog.trace("mp_row_consumer {}: fast_forward_to({}) => out_of_range={}, skip_in_progress={}", this, _fwd_range, _out_of_range, _skip_in_progress);
return !_in_progress || _skip_in_progress;
}
static int adjust_binary_search_index(int idx) {
if (idx < 0) {
// binary search gives us the first index _greater_ than the key searched for,