chore: migrate proxy benchmarks to Gungraun

Cargo.toml

@@ -103,7 +103,7 @@ proptest = "1.11"  # Property-based testing for comprehensive coverage
 yenc = "0.2.2"  # For benchmark comparison only
 
 [target.'cfg(all(target_os = "linux", any(target_arch = "x86_64", target_arch = "aarch64")))'.dev-dependencies]
-iai-callgrind = "0.16.1"  # Instruction-count benchmarking for hot path comparisons
+gungraun = "0.19.4"  # Callgrind instruction/branch/cache benchmarking
 
 [features]
 default = []

benches/cache_miss_roundtrip_callgrind.rs

@@ -1,4 +1,4 @@
-//! Callgrind benchmarks for the real cache-miss proxy roundtrip path.
+//! Gungraun benchmarks for the real cache-miss proxy roundtrip path.
 //!
 //! These benches drive a client socket through a live per-command proxy with
 //! metadata-only cache enabled or no configured cache. Each `ARTICLE` request
@@ -17,7 +17,7 @@ macro_rules! supported {
 }
 
 supported! {
-    use iai_callgrind::{
+    use gungraun::{
         Callgrind, LibraryBenchmarkConfig, library_benchmark, library_benchmark_group, main,
     };
     use nntp_proxy::config::{Cache, Config, Server};

benches/request_classifier_callgrind.rs

@@ -1,4 +1,4 @@
-//! Callgrind benchmarks for NNTP request verb classification.
+//! Gungraun benchmarks for NNTP request verb classification.
 //!
 //! The `request_line_*` benches exercise the current borrowed request-line parser.
 //!
@@ -14,7 +14,7 @@ macro_rules! supported {
 }
 
 supported! {
-    use iai_callgrind::{
+    use gungraun::{
         Callgrind, EntryPoint, LibraryBenchmarkConfig, library_benchmark, library_benchmark_group, main,
     };
     use nntp_proxy::protocol::{RequestContext, RequestKind};

benches/request_serialization.rs

@@ -47,8 +47,7 @@ impl FixedSink {
 }
 
 #[inline]
-fn write_request_slices(sink: &mut FixedSink, request: &RequestContext) -> usize {
-    sink.clear();
+fn append_request_slices(sink: &mut FixedSink, request: &RequestContext) -> usize {
     sink.write(request.verb());
     if !request.args().is_empty() {
         sink.write(b" ");
@@ -58,6 +57,12 @@ fn write_request_slices(sink: &mut FixedSink, request: &RequestContext) -> usize
     sink.len()
 }
 
+#[inline]
+fn write_request_slices(sink: &mut FixedSink, request: &RequestContext) -> usize {
+    sink.clear();
+    append_request_slices(sink, request)
+}
+
 fn request_context(line: &[u8]) -> RequestContext {
     RequestContext::parse(line).expect("valid request line")
 }
@@ -126,6 +131,48 @@ mod mixed_batch {
     }
 }
 
+mod upstream_window {
+    use super::{Bencher, FixedSink, append_request_slices, black_box, request_context};
+
+    const WINDOW: &[&str] = &[
+        "ARTICLE <a00@example.com>\r\n",
+        "ARTICLE <a01@example.com>\r\n",
+        "ARTICLE <a02@example.com>\r\n",
+        "ARTICLE <a03@example.com>\r\n",
+        "ARTICLE <a04@example.com>\r\n",
+        "ARTICLE <a05@example.com>\r\n",
+        "ARTICLE <a06@example.com>\r\n",
+        "ARTICLE <a07@example.com>\r\n",
+        "ARTICLE <a08@example.com>\r\n",
+        "ARTICLE <a09@example.com>\r\n",
+        "ARTICLE <a10@example.com>\r\n",
+        "ARTICLE <a11@example.com>\r\n",
+        "ARTICLE <a12@example.com>\r\n",
+        "ARTICLE <a13@example.com>\r\n",
+        "ARTICLE <a14@example.com>\r\n",
+        "ARTICLE <a15@example.com>\r\n",
+    ];
+
+    #[divan::bench(sample_count = 1000, sample_size = 100)]
+    fn sixteen_article_window(bencher: Bencher) {
+        let requests = WINDOW
+            .iter()
+            .map(|line| request_context(line.as_bytes()))
+            .collect::<Vec<_>>();
+
+        bencher
+            .counter(divan::counter::ItemsCount::new(requests.len()))
+            .bench(|| {
+                let mut sink = FixedSink::default();
+                sink.clear();
+                requests
+                    .iter()
+                    .map(|request| append_request_slices(black_box(&mut sink), black_box(request)))
+                    .sum::<usize>()
+            });
+    }
+}
+
 mod response_shape {
     use super::{Bencher, StatusCode, black_box, request_context};
 

flake.nix

@@ -132,6 +132,21 @@
       package = import ./nix/package.nix {
         inherit pkgs craneLib cargoToml;
       };
+
+      gungraunRunner = pkgs.rustPlatform.buildRustPackage rec {
+        pname = "gungraun-runner";
+        version = "0.19.4";
+        src = pkgs.fetchFromGitHub {
+          owner = "gungraun";
+          repo = "gungraun";
+          rev = "v${version}";
+          hash = "sha256-KWQ4wMNIdKY9FTmPd9ZdlSuCpQQBFhIKD2Ereo3JQaI=";
+        };
+        cargoHash = "sha256-+3toaUDLCmExC3EvNv1GEdUbHSBeShurp2Y+zvE/t0k=";
+        cargoBuildFlags = ["-p" pname];
+        cargoInstallFlags = ["-p" pname];
+        doCheck = false;
+      };
     in {
       apps.default =
         (flake-utils.lib.mkApp {
@@ -142,7 +157,7 @@
         };
 
       devShells.default = pkgs.mkShell {
-        nativeBuildInputs = basicNativeBuildInputs;
+        nativeBuildInputs = basicNativeBuildInputs ++ [gungraunRunner];
         buildInputs = devBuildInputs;
 
         shellHook = ''

scripts/audit-advisories

@@ -41,9 +41,10 @@ run cargo deny check advisories
 
 tree_for bincode
 tree_for paste
-tree_for proc-macro-error2
+tree_for proc-macro-error3
+tree_for gungraun
 
 echo
 echo "Upstream projects to watch:"
 echo "- foyer: https://github.com/foyer-rs/foyer"
-echo "- iai-callgrind: https://github.com/iai-callgrind/iai-callgrind"
+echo "- gungraun: https://github.com/gungraun/gungraun"