forked from florianl/go-tc
-
Notifications
You must be signed in to change notification settings - Fork 2
/
m_vlan.go
106 lines (97 loc) · 2.52 KB
/
m_vlan.go
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
package tc
import (
"fmt"
"github.com/mdlayher/netlink"
)
const (
tcaVLanUnspec = iota
tcaVLanTm
tcaVLanParms
tcaVLanPushVLanID
tcaVLanPushVLanProtocol
tcaVLanPad
tcaVLanPushVLanPriority
)
// VLan contains attribute of the VLan discipline
type VLan struct {
Parms *VLanParms
Tm *Tcft
PushID *uint16
PushProtocol *uint16
PushPriority *uint32
}
// VLanParms from from include/uapi/linux/tc_act/tc_vlan.h
type VLanParms struct {
Index uint32
Capab uint32
Action uint32
RefCnt uint32
BindCnt uint32
VLanAction uint32
}
// marshalVLan returns the binary encoding of Vlan
func marshalVlan(info *VLan) ([]byte, error) {
options := []tcOption{}
if info == nil {
return []byte{}, fmt.Errorf("VLan: %w", ErrNoArg)
}
// TODO: improve logic and check combinations
if info.Tm != nil {
return []byte{}, ErrNoArgAlter
}
if info.Parms != nil {
data, err := marshalStruct(info.Parms)
if err != nil {
return []byte{}, err
}
options = append(options, tcOption{Interpretation: vtBytes, Type: tcaVLanParms, Data: data})
}
if info.PushID != nil {
options = append(options, tcOption{Interpretation: vtUint16, Type: tcaVLanPushVLanID, Data: *info.PushID})
}
if info.PushProtocol != nil {
options = append(options, tcOption{Interpretation: vtUint16, Type: tcaVLanPushVLanProtocol, Data: *info.PushProtocol})
}
if info.PushPriority != nil {
options = append(options, tcOption{Interpretation: vtUint32, Type: tcaVLanPushVLanPriority, Data: *info.PushPriority})
}
return marshalAttributes(options)
}
// unmarshalVLan parses the VLan-encoded data and stores the result in the value pointed to by info.
func unmarshalVLan(data []byte, info *VLan) error {
ad, err := netlink.NewAttributeDecoder(data)
if err != nil {
return err
}
ad.ByteOrder = nativeEndian
for ad.Next() {
switch ad.Type() {
case tcaVLanParms:
parms := &VLanParms{}
if err := unmarshalStruct(ad.Bytes(), parms); err != nil {
return err
}
info.Parms = parms
case tcaVLanTm:
tcft := &Tcft{}
if err := unmarshalStruct(ad.Bytes(), tcft); err != nil {
return err
}
info.Tm = tcft
case tcaVLanPushVLanID:
tmp := ad.Uint16()
info.PushID = &tmp
case tcaVLanPushVLanProtocol:
tmp := ad.Uint16()
info.PushProtocol = &tmp
case tcaVLanPushVLanPriority:
tmp := ad.Uint32()
info.PushPriority = &tmp
case tcaVLanPad:
// padding does not contain data, we just skip it
default:
return fmt.Errorf("unmarshalVLan()\t%d\n\t%v", ad.Type(), ad.Bytes())
}
}
return nil
}