Add a BufReader benchmark for reads smaller than the buffer

collector/runtime-benchmarks/Cargo.toml

@@ -1,2 +1,2 @@
 [workspace]
-members = ["hashmap"]
+members = ["hashmap", "bufreader"]

collector/runtime-benchmarks/bufreader/Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "bufreader"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+benchlib = { path = "../../benchlib" }
+snap = "1.0.5"

collector/runtime-benchmarks/bufreader/src/main.rs

@@ -0,0 +1,34 @@
+use benchlib::benchmark::{black_box, BenchmarkSuite};
+use snap::{read::FrameDecoder, write::FrameEncoder};
+use std::io::{BufRead, BufReader, Write};
+
+const BYTES: usize = 64 * 1024 * 1024;
+
+fn main() {
+    let mut suite = BenchmarkSuite::new();
+
+    // Inspired by https://github.com/rust-lang/rust/issues/102727
+    // The pattern we want is a BufReader which wraps a Read impl where one Read::read call will
+    // never fill the whole BufReader buffer.
+    suite.register("bufreader-snappy", || {
+        let data = vec![0u8; BYTES];
+        move || {
+            let mut compressed = Vec::new();
+            FrameEncoder::new(&mut compressed)
+                .write_all(&data[..])
+                .unwrap();
+            let mut reader = BufReader::with_capacity(BYTES, FrameDecoder::new(&compressed[..]));
+
+            while let Ok(buf) = reader.fill_buf() {
+                if buf.is_empty() {
+                    break;
+                }
+                black_box(buf);
+                let len = buf.len();
+                reader.consume(len);
+            }
+        }
+    });
+
+    suite.run().unwrap();
+}