10565167464

Committed 26 Aug 2024 06:28PM UTC coverage: 54.132%. First build

Build # 10565167464

Build Type

Pull #1074

github

Committed by

champtar

Commit Message

macvlan: add bcqueuelen setting

This setting was introduced in Linux 5.11
https://github.com/torvalds/linux/commit/d4bff72c8
https://github.com/iproute2/iproute2/commit/42f5642a4

Signed-off-by: Etienne Champetier <e.champetier@ateme.com>

Pull Request Pull Request #1074: macvlan: add bcqueuelen setting

Run Details

4 of 14 new or added lines in 4 files covered. (28.57%)

4657 of 8603 relevant lines covered (54.13%)

27.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/ip/route_linux.go

// Copyright 2015-2017 CNI authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package ip

import (
        "net"

        "github.com/vishvananda/netlink"
)

// AddRoute adds a universally-scoped route to a device.
func AddRoute(ipn *net.IPNet, gw net.IP, dev netlink.Link) error {
        return netlink.RouteAdd(&netlink.Route{
                LinkIndex: dev.Attrs().Index,
                Scope:     netlink.SCOPE_UNIVERSE,
                Dst:       ipn,
                Gw:        gw,
        })
}

// AddHostRoute adds a host-scoped route to a device.
func AddHostRoute(ipn *net.IPNet, gw net.IP, dev netlink.Link) error {
        return netlink.RouteAdd(&netlink.Route{
                LinkIndex: dev.Attrs().Index,
                Scope:     netlink.SCOPE_HOST,
                Dst:       ipn,
                Gw:        gw,
        })
}

// AddDefaultRoute sets the default route on the given gateway.
func AddDefaultRoute(gw net.IP, dev netlink.Link) error {
        var defNet *net.IPNet
        if gw.To4() != nil {
                _, defNet, _ = net.ParseCIDR("0.0.0.0/0")
        } else {
                _, defNet, _ = net.ParseCIDR("::/0")
        }
        return AddRoute(defNet, gw, dev)
}

// IsIPNetZero check if the IPNet is "0.0.0.0/0" or "::/0"
// This is needed as go-netlink replaces nil Dst with a '0' IPNet since
// https://github.com/vishvananda/netlink/commit/acdc658b8613655ddb69f978e9fb4cf413e2b830
func IsIPNetZero(ipnet *net.IPNet) bool {
        if ipnet == nil {
                return true
        }
        if ones, _ := ipnet.Mask.Size(); ones != 0 {
                return false
        }
        return ipnet.IP.Equal(net.IPv4zero) || ipnet.IP.Equal(net.IPv6zero)
}

1	// Copyright 2015-2017 CNI authors
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14
15	package ip
16
17	import (
18	"net"
19
20	"github.com/vishvananda/netlink"
21	)
22
23	// AddRoute adds a universally-scoped route to a device.
24	func AddRoute(ipn *net.IPNet, gw net.IP, dev netlink.Link) error {	×
25	return netlink.RouteAdd(&netlink.Route{	×
26	LinkIndex: dev.Attrs().Index,	×
27	Scope: netlink.SCOPE_UNIVERSE,	×
28	Dst: ipn,	×
29	Gw: gw,	×
30	})	×
31	}	×
32
33	// AddHostRoute adds a host-scoped route to a device.
34	func AddHostRoute(ipn *net.IPNet, gw net.IP, dev netlink.Link) error {	×
35	return netlink.RouteAdd(&netlink.Route{	×
36	LinkIndex: dev.Attrs().Index,	×
37	Scope: netlink.SCOPE_HOST,	×
38	Dst: ipn,	×
39	Gw: gw,	×
40	})	×
41	}	×
42
43	// AddDefaultRoute sets the default route on the given gateway.
44	func AddDefaultRoute(gw net.IP, dev netlink.Link) error {	×
45	var defNet *net.IPNet	×
46	if gw.To4() != nil {	×
47	_, defNet, _ = net.ParseCIDR("0.0.0.0/0")	×
48	} else {	×
49	_, defNet, _ = net.ParseCIDR("::/0")	×
50	}	×
51	return AddRoute(defNet, gw, dev)	×
52	}
53
54	// IsIPNetZero check if the IPNet is "0.0.0.0/0" or "::/0"
55	// This is needed as go-netlink replaces nil Dst with a '0' IPNet since
56	// https://github.com/vishvananda/netlink/commit/acdc658b8613655ddb69f978e9fb4cf413e2b830
NEW 57	func IsIPNetZero(ipnet *net.IPNet) bool {	×
NEW 58	if ipnet == nil {	×
NEW 59	return true	×
NEW 60	}	×
NEW 61	if ones, _ := ipnet.Mask.Size(); ones != 0 {	×
NEW 62	return false	×
NEW 63	}	×
NEW 64	return ipnet.IP.Equal(net.IPv4zero) \|\| ipnet.IP.Equal(net.IPv6zero)	×
65	}

containernetworking / plugins / 10565167464

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous