diff options
Diffstat (limited to 'src/simtest/bench.rs')
| -rw-r--r-- | src/simtest/bench.rs | 13 |
1 files changed, 13 insertions, 0 deletions
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 |