aboutsummaryrefslogtreecommitdiffstats
path: root/src/transport/paths.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-30 18:28:14 +0100
committertv <tv@krebsco.de>2026-10-30 18:28:14 +0100
commite3b386c2aa9970f2f999f07ac43b7eb8fe319d8d (patch)
tree58cd1542f9d1ddcd398c209ccaf11ffc345eb3f4 /src/transport/paths.rs
parent0ef6785b09d74878f66449f18cf45fe54f8b2f5a (diff)
track connection type per path
Diffstat (limited to 'src/transport/paths.rs')
-rw-r--r--src/transport/paths.rs5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/transport/paths.rs b/src/transport/paths.rs
index a8c7c49..76d22b6 100644
--- a/src/transport/paths.rs
+++ b/src/transport/paths.rs
@@ -361,6 +361,7 @@ impl Table {
.and_then(|path| path.rtt)
.map(|rtt| rtt.as_secs_f64() * 1000.0),
down: path.is_some_and(|path| path.is_down(now)),
+ connection: None,
}
}
}
@@ -472,9 +473,11 @@ impl Paths {
self.located(infos)
}
- /// `infos` with where each path goes (`located`); asked outside the table's lock.
+ /// `infos` with where each path goes (`located`) and the transport's connection
+ /// there; asked outside the table's lock.
fn located(&self, mut infos: Vec<PathInfo>) -> Vec<PathInfo> {
for info in &mut infos {
+ info.connection = self.connection(&info.address);
info.address = self.location(&info.address);
}
infos