aboutsummaryrefslogtreecommitdiffstats
path: root/src/simtest/soak.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 15:44:44 +0100
committertv <tv@krebsco.de>2026-11-06 15:44:44 +0100
commit722d240dfa8ded58adb83282036e7e14fe70379d (patch)
tree28b3b840ab8c0300d5b8041349d5785dd1d1e251 /src/simtest/soak.rs
parentd6f6c7aad904e650e6c7371dbd4776f6f0be2388 (diff)
soak records by set
Diffstat (limited to 'src/simtest/soak.rs')
-rw-r--r--src/simtest/soak.rs8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/simtest/soak.rs b/src/simtest/soak.rs
index 5a1234b..c9c9c19 100644
--- a/src/simtest/soak.rs
+++ b/src/simtest/soak.rs
@@ -281,6 +281,10 @@ async fn soak_with_churn() {
};
let recorded = records(nodes[0].clone()).await.len();
let written_during = written(&nodes);
+ let (unreached_written, reached_written) = nodes
+ .iter()
+ .map(crate::swarm::working_links::written_by_set)
+ .fold((0, 0), |(u, r), (nu, nr)| (u + nu, r + nr));
let end_tasks = tokio::runtime::Handle::current()
.metrics()
.num_alive_tasks();
@@ -297,8 +301,8 @@ async fn soak_with_churn() {
println!(
" per node at most: {peers} peers, round trips of {rtts}, throughput of \
{throughputs}, traffic of {traffic}; {heals} heals; {recorded} members with links \
- recorded, {written_during} records written (by the nodes running at the end); \
- tasks alive {warm_tasks} after the warm-up, {end_tasks} at the end"
+ recorded, {written_during} records written (by the nodes running at the end; \
+ {unreached_written} changing unreached, {reached_written} reached); tasks alive {warm_tasks} after the warm-up, {end_tasks} at the end"
);
// The quiet phase: what the swarm sends with nothing to pass on, once the links