netlink_packet_route/rtnl/link/nlas/
stats64.rs1use netlink_packet_utils::{
4 traits::{Emitable, Parseable},
5 DecodeError,
6};
7
8pub const LINK_STATS64_LEN: usize = 192;
9buffer!(Stats64Buffer(LINK_STATS64_LEN) {
10 rx_packets: (u64, 0..8),
11 tx_packets: (u64, 8..16),
12 rx_bytes: (u64, 16..24),
13 tx_bytes: (u64, 24..32),
14 rx_errors: (u64, 32..40),
15 tx_errors: (u64, 40..48),
16 rx_dropped: (u64, 48..56),
17 tx_dropped: (u64, 56..64),
18 multicast: (u64, 64..72),
19 collisions: (u64, 72..80),
20 rx_length_errors: (u64, 80..88),
21 rx_over_errors: (u64, 88..96),
22 rx_crc_errors: (u64, 96..104),
23 rx_frame_errors: (u64, 104..112),
24 rx_fifo_errors: (u64, 112..120),
25 rx_missed_errors: (u64, 120..128),
26 tx_aborted_errors: (u64, 128..136),
27 tx_carrier_errors: (u64, 136..144),
28 tx_fifo_errors: (u64, 144..152),
29 tx_heartbeat_errors: (u64, 152..160),
30 tx_window_errors: (u64, 160..168),
31 rx_compressed: (u64, 168..176),
32 tx_compressed: (u64, 176..184),
33 rx_nohandler: (u64, 184..192),
34});
35
36#[derive(Debug, Clone, Copy, Eq, PartialEq)]
37#[non_exhaustive]
38pub struct Stats64 {
39 pub rx_packets: u64,
41 pub tx_packets: u64,
43 pub rx_bytes: u64,
45 pub tx_bytes: u64,
47 pub rx_errors: u64,
49 pub tx_errors: u64,
51 pub rx_dropped: u64,
53 pub tx_dropped: u64,
55 pub multicast: u64,
57 pub collisions: u64,
58
59 pub rx_length_errors: u64,
61 pub rx_over_errors: u64,
63 pub rx_crc_errors: u64,
65 pub rx_frame_errors: u64,
67 pub rx_fifo_errors: u64,
69 pub rx_missed_errors: u64,
71
72 pub tx_aborted_errors: u64,
74 pub tx_carrier_errors: u64,
75 pub tx_fifo_errors: u64,
76 pub tx_heartbeat_errors: u64,
77 pub tx_window_errors: u64,
78
79 pub rx_compressed: u64,
81 pub tx_compressed: u64,
82
83 pub rx_nohandler: u64,
85}
86
87impl<T: AsRef<[u8]>> Parseable<Stats64Buffer<T>> for Stats64 {
88 fn parse(buf: &Stats64Buffer<T>) -> Result<Self, DecodeError> {
89 Ok(Self {
90 rx_packets: buf.rx_packets(),
91 tx_packets: buf.tx_packets(),
92 rx_bytes: buf.rx_bytes(),
93 tx_bytes: buf.tx_bytes(),
94 rx_errors: buf.rx_errors(),
95 tx_errors: buf.tx_errors(),
96 rx_dropped: buf.rx_dropped(),
97 tx_dropped: buf.tx_dropped(),
98 multicast: buf.multicast(),
99 collisions: buf.collisions(),
100 rx_length_errors: buf.rx_length_errors(),
101 rx_over_errors: buf.rx_over_errors(),
102 rx_crc_errors: buf.rx_crc_errors(),
103 rx_frame_errors: buf.rx_frame_errors(),
104 rx_fifo_errors: buf.rx_fifo_errors(),
105 rx_missed_errors: buf.rx_missed_errors(),
106 tx_aborted_errors: buf.tx_aborted_errors(),
107 tx_carrier_errors: buf.tx_carrier_errors(),
108 tx_fifo_errors: buf.tx_fifo_errors(),
109 tx_heartbeat_errors: buf.tx_heartbeat_errors(),
110 tx_window_errors: buf.tx_window_errors(),
111 rx_compressed: buf.rx_compressed(),
112 tx_compressed: buf.tx_compressed(),
113 rx_nohandler: buf.rx_nohandler(),
114 })
115 }
116}
117
118impl Emitable for Stats64 {
119 fn buffer_len(&self) -> usize {
120 LINK_STATS64_LEN
121 }
122
123 fn emit(&self, buffer: &mut [u8]) {
124 let mut buffer = Stats64Buffer::new(buffer);
125 buffer.set_rx_packets(self.rx_packets);
126 buffer.set_tx_packets(self.tx_packets);
127 buffer.set_rx_bytes(self.rx_bytes);
128 buffer.set_tx_bytes(self.tx_bytes);
129 buffer.set_rx_errors(self.rx_errors);
130 buffer.set_tx_errors(self.tx_errors);
131 buffer.set_rx_dropped(self.rx_dropped);
132 buffer.set_tx_dropped(self.tx_dropped);
133 buffer.set_multicast(self.multicast);
134 buffer.set_collisions(self.collisions);
135 buffer.set_rx_length_errors(self.rx_length_errors);
136 buffer.set_rx_over_errors(self.rx_over_errors);
137 buffer.set_rx_crc_errors(self.rx_crc_errors);
138 buffer.set_rx_frame_errors(self.rx_frame_errors);
139 buffer.set_rx_fifo_errors(self.rx_fifo_errors);
140 buffer.set_rx_missed_errors(self.rx_missed_errors);
141 buffer.set_tx_aborted_errors(self.tx_aborted_errors);
142 buffer.set_tx_carrier_errors(self.tx_carrier_errors);
143 buffer.set_tx_fifo_errors(self.tx_fifo_errors);
144 buffer.set_tx_heartbeat_errors(self.tx_heartbeat_errors);
145 buffer.set_tx_window_errors(self.tx_window_errors);
146 buffer.set_rx_compressed(self.rx_compressed);
147 buffer.set_tx_compressed(self.tx_compressed);
148 buffer.set_rx_nohandler(self.rx_nohandler);
149 }
150}