-
Notifications
You must be signed in to change notification settings - Fork 48
/
f_basic.go
93 lines (85 loc) · 2.43 KB
/
f_basic.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
package tc
import (
"fmt"
"github.com/mdlayher/netlink"
)
const (
tcaBasicUnspec = iota
tcaBasicClassID
tcaBasicEmatches
tcaBasicAct
tcaBasicPolice
tcaBasicPCNT
)
// Basic contains attributes of the basic discipline
type Basic struct {
ClassID *uint32
Police *Police
Ematch *Ematch
Actions *[]*Action
}
// unmarshalBasic parses the Basic-encoded data and stores the result in the value pointed to by info.
func unmarshalBasic(data []byte, info *Basic) error {
ad, err := netlink.NewAttributeDecoder(data)
if err != nil {
return err
}
var multiError error
for ad.Next() {
switch ad.Type() {
case tcaBasicPolice:
pol := &Police{}
err := unmarshalPolice(ad.Bytes(), pol)
multiError = concatError(multiError, err)
info.Police = pol
case tcaBasicClassID:
info.ClassID = uint32Ptr(ad.Uint32())
case tcaBasicEmatches:
ematch := &Ematch{}
err := unmarshalEmatch(ad.Bytes(), ematch)
multiError = concatError(multiError, err)
info.Ematch = ematch
case tcaBasicAct:
actions := &[]*Action{}
err := unmarshalActions(ad.Bytes(), actions)
multiError = concatError(multiError, err)
info.Actions = actions
case tcaBasicPCNT:
continue
default:
return fmt.Errorf("unmarshalBasic()\t%d\n\t%v", ad.Type(), ad.Bytes())
}
}
return concatError(multiError, ad.Err())
}
// marshalBasic returns the binary encoding of Basic
func marshalBasic(info *Basic) ([]byte, error) {
options := []tcOption{}
if info == nil {
return []byte{}, fmt.Errorf("Basic: %w", ErrNoArg)
}
var multiError error
// TODO: improve logic and check combinations
if info.ClassID != nil {
options = append(options, tcOption{Interpretation: vtUint32, Type: tcaBasicClassID, Data: uint32Value(info.ClassID)})
}
if info.Ematch != nil {
data, err := marshalEmatch(info.Ematch)
multiError = concatError(multiError, err)
options = append(options, tcOption{Interpretation: vtBytes, Type: tcaBasicEmatches, Data: data})
}
if info.Police != nil {
data, err := marshalPolice(info.Police)
multiError = concatError(multiError, err)
options = append(options, tcOption{Interpretation: vtBytes, Type: tcaBasicPolice, Data: data})
}
if info.Actions != nil {
data, err := marshalActions(0, *info.Actions)
multiError = concatError(multiError, err)
options = append(options, tcOption{Interpretation: vtBytes, Type: tcaBasicAct, Data: data})
}
if multiError != nil {
return []byte{}, multiError
}
return marshalAttributes(options)
}