summaryrefslogtreecommitdiffstats
path: root/benchmarks/tail-latency
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-04-09 10:55:27 -0400
committerDouglas Rumbaugh <dbr4@psu.edu>2025-04-09 10:55:27 -0400
commit7440266737210c7979178d1747cc3d68594f364f (patch)
tree47e7b6db037438adc14e81a2f4acd383411895f3 /benchmarks/tail-latency
parent47c8864758399a83b5a80e2a8a31ea316b06505d (diff)
downloaddynamic-extension-7440266737210c7979178d1747cc3d68594f364f.tar.gz
Disabled early abort for point lookups
I'm having some trouble getting "bad" query performance, so I'm going to try using PLs w/o early abort as a worst-case scenario. This should get the best per-shard performance scaling
Diffstat (limited to 'benchmarks/tail-latency')
-rw-r--r--benchmarks/tail-latency/insert_query_threads.cpp17
1 files changed, 9 insertions, 8 deletions
diff --git a/benchmarks/tail-latency/insert_query_threads.cpp b/benchmarks/tail-latency/insert_query_threads.cpp
index 0d92fde..d5939de 100644
--- a/benchmarks/tail-latency/insert_query_threads.cpp
+++ b/benchmarks/tail-latency/insert_query_threads.cpp
@@ -14,8 +14,8 @@
#include "framework/scheduling/FIFOScheduler.h"
#include "framework/scheduling/SerialScheduler.h"
#include "framework/util/Configuration.h"
-#include "query/rangecount.h"
-#include "shard/TrieSpline.h"
+#include "query/pointlookup.h"
+#include "shard/ISAMTree.h"
#include "standard_benchmarks.h"
#include "util/types.h"
@@ -26,8 +26,8 @@
#include "psu-util/timer.h"
typedef de::Record<uint64_t, uint64_t> Rec;
-typedef de::TrieSpline<Rec> Shard;
-typedef de::rc::Query<Shard> Q;
+typedef de::ISAMTree<Rec> Shard;
+typedef de::pl::Query<Shard> Q;
typedef de::DynamicExtension<Shard, Q, de::DeletePolicy::TOMBSTONE,
de::FIFOScheduler>
Ext;
@@ -64,7 +64,7 @@ void query_thread(Ext *extension, std::vector<QP> *queries) {
TIMER_STOP();
total_query_time.fetch_add(TIMER_RESULT());
- total_res.fetch_add(res);
+ total_res.fetch_add(res.size());
}
}
@@ -99,15 +99,16 @@ int main(int argc, char **argv) {
std::string q_fname = std::string(argv[3]);
auto data = read_sosd_file<Rec>(d_fname, n);
- auto queries = read_range_queries<QP>(q_fname, .0001);
+ //auto queries = read_range_queries<QP>(q_fname, .0001);
+ auto queries =read_sosd_point_lookups<QP>(q_fname, 100);
std::vector<size_t> sfs = {8}; //, 4, 8, 16, 32, 64, 128, 256, 512, 1024};
size_t buffer_size = 8000;
- std::vector<size_t> policies = {2};
+ std::vector<size_t> policies = {0, 1, 2};
std::vector<size_t> thread_counts = {8};
std::vector<size_t> modifiers = {0};
- std::vector<size_t> scale_factors = {2, 3, 4, 5, 6, 7, 8};
+ std::vector<size_t> scale_factors = {2, 4, 8, 16, 32, 64, 128, 256};
size_t insert_threads = 1;
size_t query_threads = 1;