summaryrefslogtreecommitdiffstats
path: root/benchmarks/tail-latency/fixed_shard_count.cpp
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-02-10 17:19:10 -0500
committerDouglas Rumbaugh <dbr4@psu.edu>2025-02-10 17:19:10 -0500
commitc04efb2640421be7a24f851c08e290c89b7b46f2 (patch)
tree5fb53b391cc016af7502dd90299805ce9bff5bc8 /benchmarks/tail-latency/fixed_shard_count.cpp
parent33b97be9237300dbfcb3c649be2caeea79dda343 (diff)
downloaddynamic-extension-c04efb2640421be7a24f851c08e290c89b7b46f2.tar.gz
Migrated remaining tail latency benchmarks to new interface
Diffstat (limited to 'benchmarks/tail-latency/fixed_shard_count.cpp')
-rw-r--r--benchmarks/tail-latency/fixed_shard_count.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/benchmarks/tail-latency/fixed_shard_count.cpp b/benchmarks/tail-latency/fixed_shard_count.cpp
index fecf599..e980bcf 100644
--- a/benchmarks/tail-latency/fixed_shard_count.cpp
+++ b/benchmarks/tail-latency/fixed_shard_count.cpp
@@ -51,8 +51,8 @@ int main(int argc, char **argv) {
size_t buffer_size = 8000;
for (size_t i=0; i<shard_counts.size(); i++) {
- auto policy = new de::FixedShardCountPolicy<Shard,Q>(buffer_size, shard_counts[i], n);
- auto extension = new Ext(policy, buffer_size / 4, buffer_size);
+ auto policy = get_policy<Shard, Q>(shard_counts[i], buffer_size, 4, n);
+ auto extension = new Ext(std::move(policy));
/* warmup structure w/ 10% of records */
size_t warmup = .1 * n;
@@ -62,7 +62,7 @@ int main(int argc, char **argv) {
}
}
- extension->await_next_epoch();
+ extension->await_version();
TIMER_INIT();
@@ -76,7 +76,7 @@ int main(int argc, char **argv) {
auto insert_tput = (size_t) ((double) (n - warmup) / (double) TIMER_RESULT() *1.0e9);
- extension->await_next_epoch();
+ extension->await_version();
/* repeat the queries a bunch of times */
TIMER_START();