diff options
| author | tv <tv@krebsco.de> | 2026-10-30 18:28:14 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-30 18:28:14 +0100 |
| commit | 070d1c0711d33c8846ca5875afd363c41f9cc9a4 (patch) | |
| tree | 253eec85dbfd9f50ee79a79578a110bd2ad30a1d /src/transport/paths.rs | |
| parent | 450fc623a4488c226c57734f4bffe3bddaaacd19 (diff) | |
track connection type per path
Diffstat (limited to 'src/transport/paths.rs')
| -rw-r--r-- | src/transport/paths.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/transport/paths.rs b/src/transport/paths.rs index ab3c15f..581bf79 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 |
