Updates for dynamic rate limitingnew-concurrency

1 files changed, 7 insertions, 3 deletions

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;