measure deflated chunks

1 files changed, 8 insertions, 1 deletions

diff --git a/src/simtest/bench.rs b/src/simtest/bench.rs
index ae22fd1..19603d2 100644
--- a/src/simtest/bench.rs
+++ b/src/simtest/bench.rs
@@ -892,6 +892,7 @@ async fn bench_bridge() {
     let received = |node: &AppState| node.traffic.total().received;
     let (z0, b0) = (received(&z), b.traffic.total().sent);
     let p0 = z.stats.snapshot().propagation;
+    let served0 = b.stats.snapshot().relay;
     let mut rng = crate::testrand::Rng::new(72);
     let started = Instant::now();
     for i in 0..writes {
@@ -910,6 +911,7 @@ async fn bench_bridge() {
 
     let (z1, b1) = (received(&z), b.traffic.total().sent);
     let p1 = z.stats.snapshot().propagation;
+    let served1 = b.stats.snapshot().relay;
     let diff = |c1: Counter, c0: Counter| (c1.messages - c0.messages, c1.bytes - c0.bytes);
     let mib = |bytes: u64| bytes as f64 / f64::from(1 << 20);
     let total = (writes * BRIDGE_VALUE) as u64;
@@ -936,7 +938,8 @@ async fn bench_bridge() {
          written: {:.1} MiB in {:.1} s; z converged {} ms after the last write\n  \
          b sent (to a and z): SYNC {} messages, {:.1} MiB; BLOB {} messages, {:.1} MiB\n  \
          z received: SYNC {} messages, {:.1} MiB; BLOB {} messages, {:.1} MiB: {:.2} times what was written\n  \
-         z's delays: {} changes, mean {} ms, half within {}, 99% within {}",
+         z's delays: {} changes, mean {} ms, half within {}, 99% within {}\n  \
+         b's blob chunks: {} served, {} of them deflated; {:.1} MiB as {:.1} MiB",
         BRIDGE_VALUE / 1024,
         1000 / BRIDGE_EVERY.as_millis(),
         mib(total),
@@ -955,5 +958,9 @@ async fn bench_bridge() {
         propagation.sum_ms / propagation.count.max(1),
         within(0.5),
         within(0.99),
+        served1.chunks_served - served0.chunks_served,
+        served1.chunks_deflated - served0.chunks_deflated,
+        mib(served1.chunk_bytes - served0.chunk_bytes),
+        mib(served1.chunk_bytes_sent - served0.chunk_bytes_sent),
     );
 }