From fbe7dcdce1f7c81248c7086cac5d3f6a375b0c42 Mon Sep 17 00:00:00 2001
From: Douglas Rumbaugh <dbr4@psu.edu>
Date: Wed, 29 Oct 2025 11:50:51 -0400
Subject: Updates for dynamic rate limiting

---
 benchmarks/tail-latency/stall_benchmark_vptree.cpp | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

(limited to 'benchmarks/tail-latency/stall_benchmark_vptree.cpp')

diff --git a/benchmarks/tail-latency/stall_benchmark_vptree.cpp b/benchmarks/tail-latency/stall_benchmark_vptree.cpp
index 26df573..f89617b 100644
--- a/benchmarks/tail-latency/stall_benchmark_vptree.cpp
+++ b/benchmarks/tail-latency/stall_benchmark_vptree.cpp
@@ -57,13 +57,12 @@ void insert_thread(Ext *extension, std::vector<Rec> *records, size_t start_idx,
   TIMER_INIT();
 
   for (size_t i = start_idx; i < stop_idx; i++) {
-    TIMER_START();
+  TIMER_START();
     while (!extension->insert((*records)[i], rng)) {
       usleep(1);
     }
     TIMER_STOP();
-
-    fprintf(stdout, "I\t%ld\n", TIMER_RESULT());
+      fprintf(stdout, "I\t%ld\n", TIMER_RESULT());
   }
 }
 
@@ -103,6 +102,11 @@ int main(int argc, char **argv) {
   config.buffer_flush_trigger = buffer_size;
   // config.buffer_flush_trigger = 4000;
   config.maximum_threads = internal_thread_cnt;
+  config.rt_level_scale = scale_factor;
+
+  if (rate_limit == 0) {
+    config.dynamic_ratelimiting = true;
+  }
 
   g_thrd_cnt = internal_thread_cnt;
 
-- 
cgit v1.2.3