netlink-packet-route 0.30.0

netlink packet types
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207

// SPDX-License-Identifier: MIT

use std::net::{Ipv4Addr, Ipv6Addr};

use netlink_packet_core::{Emitable, NlaBuffer, Parseable};

use crate::tc::{
    TcAction, TcActionAttribute, TcActionGeneric, TcActionOption,
    TcActionTunnelKeyOption, TcActionType, TcStats2, TcStatsBasic,
    TcStatsQueue, TcTunnelKey, Tcf,
};

//      > tc actions add action tunnel_key set id 33 src_ip 1.2.3.4 dst_ip
//      > 2.3.4.5 dst_port 4789 tos 1 ttl 2
//      > tools/nl_dump.py dump_actions tunnel_key
//      Note: 5.15 and 6.8 kernels do NOT set NLA_F_NESTED for TCA_ACT_OPTIONS
#[test]
fn get_tunnel_key_vxlan_action_ipv4() {
    let raw = vec![
        0xD4, 0x00, 0x01, 0x00, 0x0F, 0x00, 0x01, 0x00, 0x74, 0x75, 0x6E, 0x6E,
        0x65, 0x6C, 0x5F, 0x6B, 0x65, 0x79, 0x00, 0x00, 0x44, 0x00, 0x04, 0x00,
        0x14, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x14, 0x00, 0x07, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x18, 0x00, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x7C, 0x00, 0x02, 0x80, 0x1C, 0x00, 0x02, 0x00,
        0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x03, 0x00, 0x00, 0x00,
        0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00,
        0x08, 0x00, 0x07, 0x00, 0x00, 0x00, 0x00, 0x21, 0x08, 0x00, 0x03, 0x00,
        0x01, 0x02, 0x03, 0x04, 0x08, 0x00, 0x04, 0x00, 0x02, 0x03, 0x04, 0x05,
        0x06, 0x00, 0x09, 0x00, 0x12, 0xB5, 0x00, 0x00, 0x05, 0x00, 0x0A, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x05, 0x00, 0x0C, 0x00, 0x01, 0x00, 0x00, 0x00,
        0x05, 0x00, 0x0D, 0x00, 0x02, 0x00, 0x00, 0x00, 0x24, 0x00, 0x01, 0x00,
        0xB0, 0x23, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xB0, 0x23, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
    ];

    let expected = TcAction {
        tab: 1,
        attributes: vec![
            TcActionAttribute::Kind("tunnel_key".to_string()),
            TcActionAttribute::Stats(vec![
                TcStats2::Basic(TcStatsBasic {
                    bytes: 0,
                    packets: 0,
                }),
                TcStats2::BasicHw(TcStatsBasic {
                    bytes: 0,
                    packets: 0,
                }),
                TcStats2::Queue(TcStatsQueue {
                    qlen: 0,
                    backlog: 0,
                    drops: 0,
                    requeues: 0,
                    overlimits: 0,
                }),
            ]),
            TcActionAttribute::Options(vec![
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::Parms(
                    TcTunnelKey {
                        generic: TcActionGeneric {
                            index: 2,
                            capab: 0,
                            action: TcActionType::Pipe,
                            refcnt: 1,
                            bindcnt: 0,
                        },
                        t_action: 1,
                    },
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncKeyId(
                    33,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncIpv4Src(
                    "1.2.3.4".parse::<Ipv4Addr>().unwrap(),
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncIpv4Dst(
                    "2.3.4.5".parse::<Ipv4Addr>().unwrap(),
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncDstPort(
                    4789,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::NoCsum(
                    false,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncTos(1)),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncTtl(2)),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::Tm(Tcf {
                    install: 9136,
                    lastuse: 9136,
                    expires: 0,
                    firstuse: 0,
                })),
            ]),
        ],
    };

    assert_eq!(expected, TcAction::parse(&NlaBuffer::new(&raw)).unwrap());

    let mut buf = vec![0; expected.buffer_len()];

    expected.emit(&mut buf);

    assert_eq!(buf, raw);
}

//      > tc actions add action tunnel_key set id 33 src_ip 2a00:1:: dst_ip
//      > 2a01:2:: dst_port 4789 tos 1 ttl 2
//      > tools/nl_dump.py dump_actions tunnel_key
//      Note: 5.15 and 6.8 kernels do NOT set NLA_F_NESTED for TCA_ACT_OPTIONS
#[test]
fn test_action_tunnel_key_vxlan_ipv6() {
    let raw = vec![
        0xEC, 0x00, 0x00, 0x00, 0x0F, 0x00, 0x01, 0x00, 0x74, 0x75, 0x6E, 0x6E,
        0x65, 0x6C, 0x5F, 0x6B, 0x65, 0x79, 0x00, 0x00, 0x44, 0x00, 0x04, 0x00,
        0x14, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x14, 0x00, 0x07, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x18, 0x00, 0x03, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x94, 0x00, 0x02, 0x80, 0x1C, 0x00, 0x02, 0x00,
        0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x03, 0x00, 0x00, 0x00,
        0x01, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00,
        0x08, 0x00, 0x07, 0x00, 0x00, 0x00, 0x00, 0x21, 0x14, 0x00, 0x05, 0x00,
        0x2A, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x14, 0x00, 0x06, 0x00, 0x2A, 0x01, 0x00, 0x02,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x06, 0x00, 0x09, 0x00, 0x12, 0xB5, 0x00, 0x00, 0x05, 0x00, 0x0A, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x05, 0x00, 0x0C, 0x00, 0x01, 0x00, 0x00, 0x00,
        0x05, 0x00, 0x0D, 0x00, 0x02, 0x00, 0x00, 0x00, 0x24, 0x00, 0x01, 0x00,
        0xFB, 0x71, 0x3A, 0x00, 0x00, 0x00, 0x00, 0x00, 0xFB, 0x71, 0x3A, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
        0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
    ];

    let expected = TcAction {
        tab: 0,
        attributes: vec![
            TcActionAttribute::Kind("tunnel_key".to_string()),
            TcActionAttribute::Stats(vec![
                TcStats2::Basic(TcStatsBasic {
                    bytes: 0,
                    packets: 0,
                }),
                TcStats2::BasicHw(TcStatsBasic {
                    bytes: 0,
                    packets: 0,
                }),
                TcStats2::Queue(TcStatsQueue {
                    qlen: 0,
                    backlog: 0,
                    drops: 0,
                    requeues: 0,
                    overlimits: 0,
                }),
            ]),
            TcActionAttribute::Options(vec![
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::Parms(
                    TcTunnelKey {
                        generic: TcActionGeneric {
                            index: 1,
                            capab: 0,
                            action: TcActionType::Pipe,
                            refcnt: 1,
                            bindcnt: 1,
                        },
                        t_action: 1,
                    },
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncKeyId(
                    33,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncIpv6Src(
                    "2a00:1::".parse::<Ipv6Addr>().unwrap(),
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncIpv6Dst(
                    "2a01:2::".parse::<Ipv6Addr>().unwrap(),
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncDstPort(
                    4789,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::NoCsum(
                    false,
                )),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncTos(1)),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::EncTtl(2)),
                TcActionOption::TunnelKey(TcActionTunnelKeyOption::Tm(Tcf {
                    install: 3830267,
                    lastuse: 3830267,
                    expires: 0,
                    firstuse: 0,
                })),
            ]),
        ],
    };

    assert_eq!(expected, TcAction::parse(&NlaBuffer::new(&raw)).unwrap());

    let mut buf = vec![0; expected.buffer_len()];

    expected.emit(&mut buf);

    assert_eq!(buf, raw);
}