10565156540

Committed 26 Aug 2024 06:27PM UTC coverage: 54.122%. First build

Build # 10565156540

Build Type

Pull #1080

github

Committed by

champtar

Commit Message

build: update github.com/vishvananda/netlink to 1.3.0

This includes a breaking change:
https://github.com/vishvananda/netlink/commit/acdc658b8
route.Dst is now a zero IPNet instead of nil

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

Pull Request Pull Request #1080: build: update github.com/vishvananda/netlink to 1.3.0

Run Details

2 of 12 new or added lines in 4 files covered. (16.67%)

4655 of 8601 relevant lines covered (54.12%)

27.36 hits per line

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

0.0

/pkg/utils/conntrack.go

// Copyright 2020 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 utils

import (
        "fmt"
        "net"

        "github.com/vishvananda/netlink"
        "golang.org/x/sys/unix"
)

// Assigned Internet Protocol Numbers
// https://www.iana.org/assignments/protocol-numbers/protocol-numbers.xhtml
const (
        PROTOCOL_TCP  = 6
        PROTOCOL_UDP  = 17
        PROTOCOL_SCTP = 132
)

// getNetlinkFamily returns the Netlink IP family constant
func getNetlinkFamily(isIPv6 bool) netlink.InetFamily {
        if isIPv6 {
                return unix.AF_INET6
        }
        return unix.AF_INET
}

// DeleteConntrackEntriesForDstIP delete the conntrack entries for the connections
// specified by the given destination IP and protocol
func DeleteConntrackEntriesForDstIP(dstIP string, protocol uint8) error {
        ip := net.ParseIP(dstIP)
        if ip == nil {
                return fmt.Errorf("error deleting connection tracking state, bad IP %s", ip)
        }
        family := getNetlinkFamily(ip.To4() == nil)

        filter := &netlink.ConntrackFilter{}
        filter.AddIP(netlink.ConntrackOrigDstIP, ip)
        filter.AddProtocol(protocol)

        _, err := netlink.ConntrackDeleteFilters(netlink.ConntrackTable, family, filter)
        if err != nil {
                return fmt.Errorf("error deleting connection tracking state for protocol: %d IP: %s, error: %v", protocol, ip, err)
        }
        return nil
}

// DeleteConntrackEntriesForDstPort delete the conntrack entries for the connections specified
// by the given destination port, protocol and IP family
func DeleteConntrackEntriesForDstPort(port uint16, protocol uint8, family netlink.InetFamily) error {
        filter := &netlink.ConntrackFilter{}
        filter.AddProtocol(protocol)
        filter.AddPort(netlink.ConntrackOrigDstPort, port)

        _, err := netlink.ConntrackDeleteFilters(netlink.ConntrackTable, family, filter)
        if err != nil {
                return fmt.Errorf("error deleting connection tracking state for protocol: %d Port: %d, error: %v", protocol, port, err)
        }
        return nil
}

1	// Copyright 2020 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 utils
16
17	import (
18	"fmt"
19	"net"
20
21	"github.com/vishvananda/netlink"
22	"golang.org/x/sys/unix"
23	)
24
25	// Assigned Internet Protocol Numbers
26	// https://www.iana.org/assignments/protocol-numbers/protocol-numbers.xhtml
27	const (
28	PROTOCOL_TCP = 6
29	PROTOCOL_UDP = 17
30	PROTOCOL_SCTP = 132
31	)
32
33	// getNetlinkFamily returns the Netlink IP family constant
34	func getNetlinkFamily(isIPv6 bool) netlink.InetFamily {	×
35	if isIPv6 {	×
36	return unix.AF_INET6	×
37	}	×
38	return unix.AF_INET	×
39	}
40
41	// DeleteConntrackEntriesForDstIP delete the conntrack entries for the connections
42	// specified by the given destination IP and protocol
43	func DeleteConntrackEntriesForDstIP(dstIP string, protocol uint8) error {	×
44	ip := net.ParseIP(dstIP)	×
45	if ip == nil {	×
46	return fmt.Errorf("error deleting connection tracking state, bad IP %s", ip)	×
47	}	×
48	family := getNetlinkFamily(ip.To4() == nil)	×
49		×
50	filter := &netlink.ConntrackFilter{}	×
51	filter.AddIP(netlink.ConntrackOrigDstIP, ip)	×
52	filter.AddProtocol(protocol)	×
53		×
NEW 54	_, err := netlink.ConntrackDeleteFilters(netlink.ConntrackTable, family, filter)	×
55	if err != nil {	×
56	return fmt.Errorf("error deleting connection tracking state for protocol: %d IP: %s, error: %v", protocol, ip, err)	×
57	}	×
58	return nil	×
59	}
60
61	// DeleteConntrackEntriesForDstPort delete the conntrack entries for the connections specified
62	// by the given destination port, protocol and IP family
63	func DeleteConntrackEntriesForDstPort(port uint16, protocol uint8, family netlink.InetFamily) error {	×
64	filter := &netlink.ConntrackFilter{}	×
65	filter.AddProtocol(protocol)	×
66	filter.AddPort(netlink.ConntrackOrigDstPort, port)	×
67		×
NEW 68	_, err := netlink.ConntrackDeleteFilters(netlink.ConntrackTable, family, filter)	×
69	if err != nil {	×
70	return fmt.Errorf("error deleting connection tracking state for protocol: %d Port: %d, error: %v", protocol, port, err)	×
71	}	×
72	return nil	×
73	}

containernetworking / plugins / 10565156540

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