aboutsummaryrefslogtreecommitdiffstats
path: root/src/simtest/soak.rs
diff options
context:
space:
mode:
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