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
|
package driver
import (
"fmt"
"github.com/jsimonetti/rtnetlink/v2"
"github.com/jsimonetti/rtnetlink/v2/internal/unix"
"github.com/mdlayher/netlink"
)
// MacvlanMode represents the MACVLAN operating mode.
type MacvlanMode uint32
// MACVLAN modes.
const (
MacvlanModePrivate MacvlanMode = 0x1
MacvlanModeVEPA MacvlanMode = 0x2
MacvlanModeBridge MacvlanMode = 0x4
MacvlanModePassthru MacvlanMode = 0x8
MacvlanModeSource MacvlanMode = 0x10
)
// String returns a string representation of the MacvlanMode.
func (m MacvlanMode) String() string {
switch m {
case MacvlanModePrivate:
return "private"
case MacvlanModeVEPA:
return "vepa"
case MacvlanModeBridge:
return "bridge"
case MacvlanModePassthru:
return "passthru"
case MacvlanModeSource:
return "source"
default:
return fmt.Sprintf("unknown MacvlanMode value (%d)", m)
}
}
// MacvlanFlag represents MACVLAN flags.
type MacvlanFlag uint16
// MACVLAN flags.
const (
MacvlanFlagNopromisc MacvlanFlag = 0x1
MacvlanFlagNodst MacvlanFlag = 0x2
)
// MacvlanMacaddrMode represents the MACVLAN MAC address mode.
type MacvlanMacaddrMode uint32
// MACVLAN MAC address modes.
const (
MacvlanMacaddrAdd MacvlanMacaddrMode = 0x0
MacvlanMacaddrDel MacvlanMacaddrMode = 0x1
MacvlanMacaddrFlush MacvlanMacaddrMode = 0x2
MacvlanMacaddrSet MacvlanMacaddrMode = 0x3
)
// Macvlan represents a MACVLAN device configuration.
type Macvlan struct {
// Mode specifies the MACVLAN mode (private, vepa, bridge, passthru, source).
Mode *MacvlanMode
// Flags specifies MACVLAN flags (nopromisc, nodst).
Flags *MacvlanFlag
// MacaddrMode specifies the MAC address mode for source mode.
MacaddrMode *MacvlanMacaddrMode
// MacaddrData contains MAC addresses for source mode.
MacaddrData [][]byte
// MacaddrCount specifies the number of MAC addresses in source mode.
MacaddrCount *uint32
// BcQueueLen specifies the broadcast queue length.
BcQueueLen *uint32
// BcQueueLenUsed indicates if the broadcast queue length is being used.
BcQueueLenUsed *uint8
// BcCutoff specifies the broadcast cutoff value.
BcCutoff *int32
}
var _ rtnetlink.LinkDriver = &Macvlan{}
// New creates a new Macvlan instance.
func (m *Macvlan) New() rtnetlink.LinkDriver {
return &Macvlan{}
}
// Kind returns the MACVLAN interface kind.
func (m *Macvlan) Kind() string {
return "macvlan"
}
// Encode encodes the MACVLAN configuration into netlink attributes.
func (m *Macvlan) Encode(ae *netlink.AttributeEncoder) error {
if m.Mode != nil {
ae.Uint32(unix.IFLA_MACVLAN_MODE, uint32(*m.Mode))
}
if m.Flags != nil {
ae.Uint16(unix.IFLA_MACVLAN_FLAGS, uint16(*m.Flags))
}
if m.MacaddrMode != nil {
ae.Uint32(unix.IFLA_MACVLAN_MACADDR_MODE, uint32(*m.MacaddrMode))
}
if len(m.MacaddrData) > 0 {
ae.Nested(unix.IFLA_MACVLAN_MACADDR_DATA, func(nae *netlink.AttributeEncoder) error {
for i, mac := range m.MacaddrData {
nae.Bytes(uint16(i), mac)
}
return nil
})
}
if m.MacaddrCount != nil {
ae.Uint32(unix.IFLA_MACVLAN_MACADDR_COUNT, *m.MacaddrCount)
}
if m.BcQueueLen != nil {
ae.Uint32(unix.IFLA_MACVLAN_BC_QUEUE_LEN, *m.BcQueueLen)
}
if m.BcQueueLenUsed != nil {
ae.Uint8(unix.IFLA_MACVLAN_BC_QUEUE_LEN_USED, *m.BcQueueLenUsed)
}
if m.BcCutoff != nil {
ae.Int32(unix.IFLA_MACVLAN_BC_CUTOFF, *m.BcCutoff)
}
return nil
}
// Decode decodes netlink attributes into the MACVLAN configuration.
func (m *Macvlan) Decode(ad *netlink.AttributeDecoder) error {
for ad.Next() {
switch ad.Type() {
case unix.IFLA_MACVLAN_MODE:
mode := MacvlanMode(ad.Uint32())
m.Mode = &mode
case unix.IFLA_MACVLAN_FLAGS:
flags := MacvlanFlag(ad.Uint16())
m.Flags = &flags
case unix.IFLA_MACVLAN_MACADDR_MODE:
macaddrMode := MacvlanMacaddrMode(ad.Uint32())
m.MacaddrMode = &macaddrMode
case unix.IFLA_MACVLAN_MACADDR_DATA:
ad.Nested(func(nad *netlink.AttributeDecoder) error {
for nad.Next() {
m.MacaddrData = append(m.MacaddrData, nad.Bytes())
}
return nad.Err()
})
case unix.IFLA_MACVLAN_MACADDR_COUNT:
count := ad.Uint32()
m.MacaddrCount = &count
case unix.IFLA_MACVLAN_BC_QUEUE_LEN:
qlen := ad.Uint32()
m.BcQueueLen = &qlen
case unix.IFLA_MACVLAN_BC_QUEUE_LEN_USED:
used := ad.Uint8()
m.BcQueueLenUsed = &used
case unix.IFLA_MACVLAN_BC_CUTOFF:
cutoff := ad.Int32()
m.BcCutoff = &cutoff
}
}
return ad.Err()
}
|
