Change much of the bus API to require DownUp types. Adjust lqtop and the (to be replaced) node manager.

This commit is contained in:
Herbert Wolverson 2024-07-02 11:44:53 -05:00
parent d07bfcf0d6
commit e1814cfc08
2 changed files with 8 additions and 8 deletions

View File

@ -52,10 +52,10 @@ impl TopWidget for TopFlows {
flow.local_ip.to_string(),
flow.remote_ip.to_string(),
flow.analysis.to_string(),
scale_bits(flow.bytes_sent[0]),
scale_bits(flow.bytes_sent[1]),
format!("{}/{}", flow.tcp_retransmits[0], flow.tcp_retransmits[1]),
format!("{:.1}/{:.1}", flow.rtt_nanos[0] as f64 / 1000000., flow.tcp_retransmits[1] as f64 / 1000000.),
scale_bits(flow.bytes_sent.down),
scale_bits(flow.bytes_sent.up),
format!("{}/{}", flow.tcp_retransmits.down, flow.tcp_retransmits.up),
format!("{:.1}/{:.1}", flow.rtt_nanos.down as f64 / 1000000., flow.tcp_retransmits.up as f64 / 1000000.),
flow.remote_asn_name.to_string(),
]);
}

View File

@ -50,10 +50,10 @@ impl TopWidget for TopHosts {
for host in self.stats.iter() {
t.add_row([
host.ip_address.to_string(),
scale_bits(host.bits_per_second.0),
scale_bits(host.bits_per_second.1),
scale_packets(host.packets_per_second.0),
scale_packets(host.packets_per_second.1),
scale_bits(host.bits_per_second.down),
scale_bits(host.bits_per_second.up),
scale_packets(host.packets_per_second.down),
scale_packets(host.packets_per_second.up),
format!("{:.2} ms", host.median_tcp_rtt),
host.tc_handle.to_string(),
]);