From 0536a8260e7d0bc4f050b310b8bb4902da16fa59 Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 4 Nov 2026 21:40:54 +0100 Subject: benchmark delays by path --- src/simtest/bench.rs | 13 +++++++++++++ 1 file changed, 13 insertions(+) (limited to 'src/simtest/bench.rs') diff --git a/src/simtest/bench.rs b/src/simtest/bench.rs index 290fd7c..09cd82c 100644 --- a/src/simtest/bench.rs +++ b/src/simtest/bench.rs @@ -240,6 +240,8 @@ impl Totals { relay.carrying_bloom_bytes += stats.relay.carrying_bloom_bytes; relay.nothing_new_change_bytes += stats.relay.nothing_new_change_bytes; relay.nothing_new_bloom_bytes += stats.relay.nothing_new_bloom_bytes; + relay.off_tree += stats.relay.off_tree; + relay.off_tree_ms += stats.relay.off_tree_ms; for (_, peer_state) in node.peers_snapshot().await { totals.incidents.add(&peer_state.lock().await.incidents); } @@ -575,6 +577,17 @@ fn report( within(0.5), within(0.99), ); + let off_tree = r1.off_tree - r0.off_tree; + let along = propagation.count.saturating_sub(off_tree); + let _ = writeln!( + out, + " of those, along writers' trees: {along} (mean {} ms); not: {off_tree} (mean {} ms)", + propagation + .sum_ms + .saturating_sub(r1.off_tree_ms - r0.off_tree_ms) + / along.max(1), + (r1.off_tree_ms - r0.off_tree_ms) / off_tree.max(1), + ); // Where the late arrivals were: the nodes that had any, the most first. let mut late: Vec<(&str, u64, u64)> = during .0 -- cgit v1.3.1