mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-29 19:21:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf_fast_forward: use flat reader in test_reading_all

Browse Source 
Signed-off-by: Piotr Jastrzebski <piotr@scylladb.com>
This commit is contained in:
Piotr Jastrzebski
2018-01-21 18:38:54 +01:00
parent 899e471222
commit 177aa88dc1
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
tests/perf/perf_fast_forward.cc
View File

@@ -287,7 +287,7 @@ static test_result slice_rows(column_family& cf, int offset = 0, int n_read = 1)
return {before, fragments};
}
static test_result test_reading_all(mutation_reader& rd) {
static test_result test_reading_all(flat_mutation_reader& rd) {
metrics_snapshot before;
return {before, consume_all(rd)};
}
@@ -299,9 +299,9 @@ static test_result select_spread_rows(column_family& cf, int stride = 0, int n_r
}
auto slice = sb.build();
auto rd = mutation_reader_from_flat_mutation_reader(cf.make_reader(cf.schema(),
auto rd = cf.make_reader(cf.schema(),
query::full_partition_range,
slice));
slice);
return test_reading_all(rd);
}
@@ -313,7 +313,7 @@ static test_result test_slicing_using_restrictions(column_family& cf, int_range
}))
.build();
auto pr = dht::partition_range::make_singular(make_pkey(*cf.schema(), 0));
auto rd = mutation_reader_from_flat_mutation_reader(cf.make_reader(cf.schema(), pr, slice));
auto rd = cf.make_reader(cf.schema(), pr, slice);
return test_reading_all(rd);
}