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 | e3b386c2aa9970f2f999f07ac43b7eb8fe319d8d (patch) | |
| tree | 58cd1542f9d1ddcd398c209ccaf11ffc345eb3f4 /src/transport/paths.rs | |
| parent | 0ef6785b09d74878f66449f18cf45fe54f8b2f5a (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 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 |
