From a6c17386c4e76576f578795947c1763e06f06f46 Mon Sep 17 00:00:00 2001 From: Douglas Rumbaugh Date: Wed, 7 Jun 2023 12:04:13 -0400 Subject: Bugfixes for query state processing function --- benchmarks/sampling_tput.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'benchmarks') diff --git a/benchmarks/sampling_tput.cpp b/benchmarks/sampling_tput.cpp index 3d38d6a..b25b15f 100644 --- a/benchmarks/sampling_tput.cpp +++ b/benchmarks/sampling_tput.cpp @@ -91,6 +91,8 @@ static void sample_benchmark(ExtendedWSS *tree, size_t k, size_t trial_cnt) WRec sample_set[k]; + size_t total_samples = 0; + de::wss_query_parms parms; parms.rng = g_rng; parms.sample_size = k; @@ -100,6 +102,7 @@ static void sample_benchmark(ExtendedWSS *tree, size_t k, size_t trial_cnt) auto start = std::chrono::high_resolution_clock::now(); for (int j=0; j < batch_size; j++) { auto res = tree->query(&parms); + total_samples += res.size(); } auto stop = std::chrono::high_resolution_clock::now(); @@ -108,7 +111,7 @@ static void sample_benchmark(ExtendedWSS *tree, size_t k, size_t trial_cnt) progress_update(1.0, progbuf); - size_t throughput = (((double)(trial_cnt * k) / (double) total_time) * 1e9); + size_t throughput = (((double)(total_samples) / (double) total_time) * 1e9); fprintf(stdout, "%ld\n", throughput); fflush(stdout); @@ -147,7 +150,7 @@ int main(int argc, char **argv) size_t insert_cnt = record_count - warmup_cnt; insert_benchmark(&sampling_lsm, &datafile, insert_cnt, delete_prop); -// sample_benchmark(&sampling_lsm, 1000, 10000); + sample_benchmark(&sampling_lsm, 1000, 10000); delete_bench_env(); fflush(stdout); -- cgit v1.2.3