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

Rename row_cache::create_underlying_flat_reader to

Browse Source 
create_underlying_reader

Signed-off-by: Piotr Jastrzebski <piotr@scylladb.com>
This commit is contained in:
Piotr Jastrzebski
2017-12-13 11:58:12 +01:00
parent 49993e56a9
commit 14d98aaa0b
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
read_context.hh
View File

@@ -67,7 +67,7 @@ public:
}
auto& snap = _cache.snapshot_for_phase(phase);
_reader = {}; // See issue #2644
_reader = _cache.create_underlying_flat_reader(_read_context, snap, _range);
_reader = _cache.create_underlying_reader(_read_context, snap, _range);
_reader_creation_phase = phase;
}
_reader->next_partition();
@@ -100,7 +100,7 @@ public:
_reader = {}; // See issue #2644
}
}
_reader = _cache.create_underlying_flat_reader(_read_context, snapshot, _range);
_reader = _cache.create_underlying_reader(_read_context, snapshot, _range);
_reader_creation_phase = phase;
return make_ready_future<>();
}

2
row_cache.cc
View File

@@ -49,7 +49,7 @@ using namespace cache;
thread_local seastar::thread_scheduling_group row_cache::_update_thread_scheduling_group(1ms, 0.2);
flat_mutation_reader
row_cache::create_underlying_flat_reader(read_context& ctx, mutation_source& src, const dht::partition_range& pr) {
row_cache::create_underlying_reader(read_context& ctx, mutation_source& src, const dht::partition_range& pr) {
ctx.on_underlying_created();
return src.make_flat_mutation_reader(_schema, pr, ctx.slice(), ctx.pc(), ctx.trace_state(), streamed_mutation::forwarding::yes);
}

2
row_cache.hh
View File

@@ -340,7 +340,7 @@ private:
logalloc::allocating_section _update_section;
logalloc::allocating_section _populate_section;
logalloc::allocating_section _read_section;
flat_mutation_reader create_underlying_flat_reader(cache::read_context&, mutation_source&, const dht::partition_range&);
flat_mutation_reader create_underlying_reader(cache::read_context&, mutation_source&, const dht::partition_range&);
flat_mutation_reader make_scanning_reader(const dht::partition_range&, lw_shared_ptr<cache::read_context>);
void on_partition_hit();
void on_partition_miss();