netlink_packet_route/link/
stats.rs

1// SPDX-License-Identifier: MIT
2
3use netlink_packet_utils::{
4    traits::{Emitable, Parseable},
5    DecodeError,
6};
7
8pub(crate) const LINK_STATS_LEN: usize = 96;
9
10#[derive(Debug, Clone, Copy, Eq, PartialEq, Default)]
11#[non_exhaustive]
12pub struct Stats {
13    /// total packets received
14    pub rx_packets: u32,
15    /// total packets transmitted
16    pub tx_packets: u32,
17    /// total bytes received
18    pub rx_bytes: u32,
19    /// total bytes transmitted
20    pub tx_bytes: u32,
21    /// bad packets received
22    pub rx_errors: u32,
23    /// packet transmit problems
24    pub tx_errors: u32,
25    /// no space in linux buffers
26    pub rx_dropped: u32,
27    /// no space available in linux
28    pub tx_dropped: u32,
29    /// multicast packets received
30    pub multicast: u32,
31    pub collisions: u32,
32
33    // detailed rx_errors
34    pub rx_length_errors: u32,
35    /// receiver ring buff overflow
36    pub rx_over_errors: u32,
37    /// received packets with crc error
38    pub rx_crc_errors: u32,
39    /// received frame alignment errors
40    pub rx_frame_errors: u32,
41    /// recv'r fifo overrun
42    pub rx_fifo_errors: u32,
43    /// receiver missed packet
44    pub rx_missed_errors: u32,
45
46    // detailed tx_errors
47    pub tx_aborted_errors: u32,
48    pub tx_carrier_errors: u32,
49    pub tx_fifo_errors: u32,
50    pub tx_heartbeat_errors: u32,
51    pub tx_window_errors: u32,
52
53    // for cslip etc
54    pub rx_compressed: u32,
55    pub tx_compressed: u32,
56
57    /// dropped, no handler found
58    pub rx_nohandler: u32,
59}
60
61buffer!(StatsBuffer(LINK_STATS_LEN) {
62    rx_packets: (u32, 0..4),
63    tx_packets: (u32, 4..8),
64    rx_bytes: (u32, 8..12),
65    tx_bytes: (u32, 12..16),
66    rx_errors: (u32, 16..20),
67    tx_errors: (u32, 20..24),
68    rx_dropped: (u32, 24..28),
69    tx_dropped: (u32, 28..32),
70    multicast: (u32, 32..36),
71    collisions: (u32, 36..40),
72    rx_length_errors: (u32, 40..44),
73    rx_over_errors: (u32, 44..48),
74    rx_crc_errors: (u32, 48..52),
75    rx_frame_errors: (u32, 52..56),
76    rx_fifo_errors: (u32, 56..60),
77    rx_missed_errors: (u32, 60..64),
78    tx_aborted_errors: (u32, 64..68),
79    tx_carrier_errors: (u32, 68..72),
80    tx_fifo_errors: (u32, 72..76),
81    tx_heartbeat_errors: (u32, 76..80),
82    tx_window_errors: (u32, 80..84),
83    rx_compressed: (u32, 84..88),
84    tx_compressed: (u32, 88..92),
85    rx_nohandler: (u32, 92..96),
86});
87
88impl<T: AsRef<[u8]>> Parseable<StatsBuffer<T>> for Stats {
89    fn parse(buf: &StatsBuffer<T>) -> Result<Self, DecodeError> {
90        Ok(Self {
91            rx_packets: buf.rx_packets(),
92            tx_packets: buf.tx_packets(),
93            rx_bytes: buf.rx_bytes(),
94            tx_bytes: buf.tx_bytes(),
95            rx_errors: buf.rx_errors(),
96            tx_errors: buf.tx_errors(),
97            rx_dropped: buf.rx_dropped(),
98            tx_dropped: buf.tx_dropped(),
99            multicast: buf.multicast(),
100            collisions: buf.collisions(),
101            rx_length_errors: buf.rx_length_errors(),
102            rx_over_errors: buf.rx_over_errors(),
103            rx_crc_errors: buf.rx_crc_errors(),
104            rx_frame_errors: buf.rx_frame_errors(),
105            rx_fifo_errors: buf.rx_fifo_errors(),
106            rx_missed_errors: buf.rx_missed_errors(),
107            tx_aborted_errors: buf.tx_aborted_errors(),
108            tx_carrier_errors: buf.tx_carrier_errors(),
109            tx_fifo_errors: buf.tx_fifo_errors(),
110            tx_heartbeat_errors: buf.tx_heartbeat_errors(),
111            tx_window_errors: buf.tx_window_errors(),
112            rx_compressed: buf.rx_compressed(),
113            tx_compressed: buf.tx_compressed(),
114            rx_nohandler: buf.rx_nohandler(),
115        })
116    }
117}
118
119impl Emitable for Stats {
120    fn buffer_len(&self) -> usize {
121        LINK_STATS_LEN
122    }
123
124    fn emit(&self, buffer: &mut [u8]) {
125        let mut buffer = StatsBuffer::new(buffer);
126        buffer.set_rx_packets(self.rx_packets);
127        buffer.set_tx_packets(self.tx_packets);
128        buffer.set_rx_bytes(self.rx_bytes);
129        buffer.set_tx_bytes(self.tx_bytes);
130        buffer.set_rx_errors(self.rx_errors);
131        buffer.set_tx_errors(self.tx_errors);
132        buffer.set_rx_dropped(self.rx_dropped);
133        buffer.set_tx_dropped(self.tx_dropped);
134        buffer.set_multicast(self.multicast);
135        buffer.set_collisions(self.collisions);
136        buffer.set_rx_length_errors(self.rx_length_errors);
137        buffer.set_rx_over_errors(self.rx_over_errors);
138        buffer.set_rx_crc_errors(self.rx_crc_errors);
139        buffer.set_rx_frame_errors(self.rx_frame_errors);
140        buffer.set_rx_fifo_errors(self.rx_fifo_errors);
141        buffer.set_rx_missed_errors(self.rx_missed_errors);
142        buffer.set_tx_aborted_errors(self.tx_aborted_errors);
143        buffer.set_tx_carrier_errors(self.tx_carrier_errors);
144        buffer.set_tx_fifo_errors(self.tx_fifo_errors);
145        buffer.set_tx_heartbeat_errors(self.tx_heartbeat_errors);
146        buffer.set_tx_window_errors(self.tx_window_errors);
147        buffer.set_rx_compressed(self.rx_compressed);
148        buffer.set_tx_compressed(self.tx_compressed);
149        buffer.set_rx_nohandler(self.rx_nohandler);
150    }
151}
netlink_packet_route/link/stats.rs

netlink_packet_route/link/
stats.rs
