diff --git a/read_context.hh b/read_context.hh index 2b5ac29a43..e8ad9a7d13 100644 --- a/read_context.hh +++ b/read_context.hh @@ -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<>(); } diff --git a/row_cache.cc b/row_cache.cc index b449ac73a2..37142a0f96 100644 --- a/row_cache.cc +++ b/row_cache.cc @@ -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); } diff --git a/row_cache.hh b/row_cache.hh index 6df280ab4b..bf0b5c3a30 100644 --- a/row_cache.hh +++ b/row_cache.hh @@ -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); void on_partition_hit(); void on_partition_miss();