9 "go.fd.io/govpp/binapi/ethernet_types"
10 "go.fd.io/govpp/binapi/interface_types"
11 "go.fd.io/govpp/binapi/ip_types"
16 MacAddress = ethernet_types.MacAddress
17 AddressWithPrefix = ip_types.AddressWithPrefix
18 IP4AddressWithPrefix = ip_types.IP4AddressWithPrefix
19 InterfaceIndex = interface_types.InterfaceIndex
28 NetConfigBase struct {
30 category string // what else to call this when `type` is reserved?
35 ip4AddrAllocator *Ip4AddressAllocator
39 networkNamespace string
44 NetworkNamespace struct {
48 NetworkBridge struct {
50 networkNamespace string
56 NetNs string = "netns"
59 Bridge string = "bridge"
62 type InterfaceAdder func(n *NetInterface) *Cmd
65 ipCommandMap = map[string]InterfaceAdder{
66 Veth: func(n *NetInterface) *Cmd {
67 return exec.Command("ip", "link", "add", n.name, "type", "veth", "peer", "name", n.peer.name)
69 Tap: func(n *NetInterface) *Cmd {
70 return exec.Command("ip", "tuntap", "add", n.name, "mode", "tap")
75 func newNetworkInterface(cfg NetDevConfig, a *Ip4AddressAllocator) (*NetInterface, error) {
76 var newInterface *NetInterface = &NetInterface{}
78 newInterface.ip4AddrAllocator = a
79 newInterface.name = cfg["name"].(string)
80 newInterface.networkNumber = DEFAULT_NETWORK_NUM
82 if interfaceType, ok := cfg["type"]; ok {
83 newInterface.category = interfaceType.(string)
86 if presetHwAddress, ok := cfg["preset-hw-address"]; ok {
87 newInterface.hwAddress, err = ethernet_types.ParseMacAddress(presetHwAddress.(string))
89 return &NetInterface{}, err
93 if netns, ok := cfg["netns"]; ok {
94 newInterface.networkNamespace = netns.(string)
97 if ip, ok := cfg["ip4"]; ok {
98 if n, ok := ip.(NetDevConfig)["network"]; ok {
99 newInterface.networkNumber = n.(int)
101 newInterface.ip4Address, err = newInterface.ip4AddrAllocator.NewIp4InterfaceAddress(
102 newInterface.networkNumber,
105 return &NetInterface{}, err
109 if _, ok := cfg["peer"]; !ok {
110 return newInterface, nil
113 peer := cfg["peer"].(NetDevConfig)
115 if newInterface.peer, err = newNetworkInterface(peer, a); err != nil {
116 return &NetInterface{}, err
119 return newInterface, nil
122 func (n *NetInterface) configureUpState() error {
123 err := setDevUp(n.Name(), "")
125 return fmt.Errorf("set link up failed: %v", err)
130 func (n *NetInterface) configureNetworkNamespace() error {
131 if n.networkNamespace != "" {
132 err := linkSetNetns(n.name, n.networkNamespace)
140 func (n *NetInterface) configureAddress() error {
141 if n.ip4Address != "" {
142 if err := addAddress(
154 func (n *NetInterface) configure() error {
155 cmd := ipCommandMap[n.Type()](n)
156 _, err := cmd.CombinedOutput()
158 return fmt.Errorf("creating interface '%v' failed: %v", n.Name(), err)
161 if err := n.configureUpState(); err != nil {
165 if err := n.configureNetworkNamespace(); err != nil {
169 if err := n.configureAddress(); err != nil {
173 if n.peer != nil && n.peer.name != "" {
174 if err := n.peer.configureUpState(); err != nil {
178 if err := n.peer.configureNetworkNamespace(); err != nil {
182 if err := n.peer.configureAddress(); err != nil {
190 func (n *NetInterface) unconfigure() {
194 func (n *NetInterface) Name() string {
198 func (n *NetInterface) Type() string {
202 func (n *NetInterface) addressWithPrefix() AddressWithPrefix {
203 address, _ := ip_types.ParseAddressWithPrefix(n.ip4Address)
207 func (n *NetInterface) ip4AddressWithPrefix() IP4AddressWithPrefix {
208 ip4Prefix, _ := ip_types.ParseIP4Prefix(n.ip4Address)
209 ip4AddressWithPrefix := ip_types.IP4AddressWithPrefix(ip4Prefix)
210 return ip4AddressWithPrefix
213 func (n *NetInterface) ip4AddressString() string {
214 return strings.Split(n.ip4Address, "/")[0]
217 func (b *NetConfigBase) Name() string {
221 func (b *NetConfigBase) Type() string {
225 func newNetNamespace(cfg NetDevConfig) (NetworkNamespace, error) {
226 var networkNamespace NetworkNamespace
227 networkNamespace.name = cfg["name"].(string)
228 networkNamespace.category = NetNs
229 return networkNamespace, nil
232 func (ns *NetworkNamespace) configure() error {
233 return addDelNetns(ns.name, true)
236 func (ns *NetworkNamespace) unconfigure() {
237 addDelNetns(ns.name, false)
240 func newBridge(cfg NetDevConfig) (NetworkBridge, error) {
241 var bridge NetworkBridge
242 bridge.name = cfg["name"].(string)
243 bridge.category = Bridge
244 for _, v := range cfg["interfaces"].([]interface{}) {
245 bridge.interfaces = append(bridge.interfaces, v.(string))
248 bridge.networkNamespace = ""
249 if netns, ok := cfg["netns"]; ok {
250 bridge.networkNamespace = netns.(string)
255 func (b *NetworkBridge) configure() error {
256 return addBridge(b.name, b.interfaces, b.networkNamespace)
259 func (b *NetworkBridge) unconfigure() {
260 delBridge(b.name, b.networkNamespace)
263 func delBridge(brName, ns string) error {
264 err := setDevDown(brName, ns)
269 err = addDelBridge(brName, ns, false)
277 func setDevUp(dev, ns string) error {
278 return setDevUpDown(dev, ns, true)
281 func setDevDown(dev, ns string) error {
282 return setDevUpDown(dev, ns, false)
285 func delLink(ifName string) {
286 cmd := exec.Command("ip", "link", "del", ifName)
290 func setDevUpDown(dev, ns string, isUp bool) error {
297 c := []string{"ip", "link", "set", "dev", dev, op}
298 cmd := appendNetns(c, ns)
301 return fmt.Errorf("error bringing %s device %s! (cmd: '%s')", dev, op, cmd)
306 func addDelNetns(name string, isAdd bool) error {
313 cmd := exec.Command("ip", "netns", op, name)
314 _, err := cmd.CombinedOutput()
316 return fmt.Errorf("add/del netns failed (cmd: '%s')", cmd)
321 func linkSetNetns(ifName, ns string) error {
322 cmd := exec.Command("ip", "link", "set", "dev", ifName, "up", "netns", ns)
325 return fmt.Errorf("error setting device '%s' to netns '%s: %v", ifName, ns, err)
330 func newCommand(s []string, ns string) *exec.Cmd {
331 return appendNetns(s, ns)
334 func appendNetns(s []string, ns string) *exec.Cmd {
337 // use default namespace
338 cmd = exec.Command(s[0], s[1:]...)
340 var args = []string{"netns", "exec", ns}
341 args = append(args, s[:]...)
342 cmd = exec.Command("ip", args...)
347 func addDelBridge(brName, ns string, isAdd bool) error {
354 var c = []string{"brctl", op, brName}
355 cmd := appendNetns(c, ns)
358 s := fmt.Sprintf("%s %s failed! err: '%s'", op, brName, err)
364 func addBridge(brName string, ifs []string, ns string) error {
365 err := addDelBridge(brName, ns, true)
370 for _, v := range ifs {
371 c := []string{"brctl", "addif", brName, v}
372 cmd := appendNetns(c, ns)
375 return fmt.Errorf("error adding %s to bridge %s: %s", v, brName, err)
378 err = setDevUp(brName, ns)