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

multishard_mutation_query: create_readr(): use the caller's priority class

Browse Source 
The priority class the shard reader was created with was hardcoded to be
`service::get_local_sstable_query_read_priority()`. At the time this
code was written, priority classes could not be passed to other shards,
so this method, receiving its priority class parameters from another
shard, could not use it. This is now fixed, so we can just use whatever
the caller wants us to use.

Signed-off-by: Botond Dénes <bdenes@scylladb.com>
Message-Id: <20190823115111.68711-1-bdenes@scylladb.com>
This commit is contained in:
Botond Dénes
2019-08-23 14:51:11 +03:00
committed by Tomasz Grabiec
parent 080989d296
commit 18581cfb76
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
multishard_mutation_query.cc
View File

@@ -262,7 +262,7 @@ flat_mutation_reader read_context::create_reader(
schema_ptr schema,
const dht::partition_range& pr,
const query::partition_slice& ps,
const io_priority_class&,
const io_priority_class& pc,
tracing::trace_state_ptr trace_state,
mutation_reader::forwarding) {
const auto shard = engine().cpu_id();
@@ -290,8 +290,6 @@ flat_mutation_reader read_context::create_reader(
rm.rparts = make_foreign(std::make_unique<reader_meta::remote_parts>(table.read_concurrency_semaphore()));
}
//TODO need a way to transport io_priority_calls across shards
auto& pc = service::get_local_sstable_query_read_priority();
rm.rparts->range = std::make_unique<const dht::partition_range>(pr);
rm.rparts->slice = std::make_unique<const query::partition_slice>(ps);
rm.rparts->read_operation = table.read_in_progress();