|
@@ -25,9 +25,9 @@ func checkConntrackProgrammable(nlh *netlink.Handle) error {
|
|
|
|
|
|
// DeleteConntrackEntries deletes all the conntrack connections on the host for the specified IP
|
|
// DeleteConntrackEntries deletes all the conntrack connections on the host for the specified IP
|
|
// Returns the number of flows deleted for IPv4, IPv6 else error
|
|
// Returns the number of flows deleted for IPv4, IPv6 else error
|
|
-func DeleteConntrackEntries(nlh *netlink.Handle, ipv4List []net.IP, ipv6List []net.IP) (uint, uint, error) {
|
|
|
|
|
|
+func DeleteConntrackEntries(nlh *netlink.Handle, ipv4List []net.IP, ipv6List []net.IP) error {
|
|
if err := checkConntrackProgrammable(nlh); err != nil {
|
|
if err := checkConntrackProgrammable(nlh); err != nil {
|
|
- return 0, 0, err
|
|
|
|
|
|
+ return err
|
|
}
|
|
}
|
|
|
|
|
|
var totalIPv4FlowPurged uint
|
|
var totalIPv4FlowPurged uint
|
|
@@ -54,7 +54,7 @@ func DeleteConntrackEntries(nlh *netlink.Handle, ipv4List []net.IP, ipv6List []n
|
|
log.G(context.TODO()).Debugf("DeleteConntrackEntries purged ipv4:%d, ipv6:%d", totalIPv4FlowPurged, totalIPv6FlowPurged)
|
|
log.G(context.TODO()).Debugf("DeleteConntrackEntries purged ipv4:%d, ipv6:%d", totalIPv4FlowPurged, totalIPv6FlowPurged)
|
|
}
|
|
}
|
|
|
|
|
|
- return totalIPv4FlowPurged, totalIPv6FlowPurged, nil
|
|
|
|
|
|
+ return nil
|
|
}
|
|
}
|
|
|
|
|
|
func DeleteConntrackEntriesByPort(nlh *netlink.Handle, proto types.Protocol, ports []uint16) error {
|
|
func DeleteConntrackEntriesByPort(nlh *netlink.Handle, proto types.Protocol, ports []uint16) error {
|