From f4baeb03c2c3e764afa26e9ae167ae250543751d Mon Sep 17 00:00:00 2001
From: fia <fia@spacesnek.rocks>
Date: Mon, 13 Jan 2025 14:25:16 +0100
Subject: [PATCH] benchmark/ycsb: drop cache before measurement start

---
 betree/haura-benchmarks/src/ycsb.rs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/betree/haura-benchmarks/src/ycsb.rs b/betree/haura-benchmarks/src/ycsb.rs
index 0e1504b9..1f31b9f3 100644
--- a/betree/haura-benchmarks/src/ycsb.rs
+++ b/betree/haura-benchmarks/src/ycsb.rs
@@ -89,6 +89,7 @@ pub fn a(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();
@@ -161,6 +162,7 @@ pub fn b(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();
@@ -226,6 +228,7 @@ pub fn c(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();
@@ -324,6 +327,7 @@ pub fn d(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();
@@ -409,7 +413,7 @@ pub fn e(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                                         let start_key = &keys[start_idx][..];
                                         let end_key = &keys[end_idx][..];
                                         // Consume the iterator to actually perform the scan
-                                        for _entry in ds.range(start_key..end_key).unwrap(){ }
+                                        for _entry in ds.range(start_key..end_key).unwrap() {}
                                     } else {
                                         // 5% inserts of new records
                                         let current = current_size.load(AtomicOrdering::Relaxed);
@@ -428,7 +432,7 @@ pub fn e(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
-
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();
@@ -503,6 +507,7 @@ pub fn f(mut client: KvClient, size: u64, threads: usize, runtime: u64) {
                 )
             })
             .collect::<Vec<_>>();
+        client.db.read().drop_cache().unwrap();
         let start = std::time::Instant::now();
         for (_t, tx) in threads.iter() {
             tx.send(start).unwrap();