diff options
| author | Douglas Rumbaugh <dbr4@psu.edu> | 2025-04-09 10:55:27 -0400 |
|---|---|---|
| committer | Douglas Rumbaugh <dbr4@psu.edu> | 2025-04-09 10:55:27 -0400 |
| commit | 7440266737210c7979178d1747cc3d68594f364f (patch) | |
| tree | 47e7b6db037438adc14e81a2f4acd383411895f3 /benchmarks/tail-latency/insert_query_threads.cpp | |
| parent | 47c8864758399a83b5a80e2a8a31ea316b06505d (diff) | |
| download | dynamic-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/insert_query_threads.cpp')
| -rw-r--r-- | benchmarks/tail-latency/insert_query_threads.cpp | 17 |
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; |