github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

Add retries to conntracker.ClearEntries()

Browse Source 
Signed-off-by: Daman Arora <aroradaman@gmail.com>
This commit is contained in:
Adrian Moisey 2025-01-30 20:09:30 +02:00
parent 90a42e0dc0
commit b6f49d0728
No known key found for this signature in database
GPG Key ID: 41AE4AE32747C7CF
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/proxy/conntrack/conntrack.go
View File

@ -75,7 +75,15 @@ func (ct *conntracker) ClearEntries(ipFamily uint8, filters ...netlink.CustomCon
return 0, nil return 0, nil
} }
n, err := ct.handler.ConntrackDeleteFilters(netlink.ConntrackTable, netlink.InetFamily(ipFamily), filters...) var n uint
var err error
err = retry.OnError(util.MaxAttemptsEINTR, util.ShouldRetryOnEINTR, func() error {
var count uint
count, err = ct.handler.ConntrackDeleteFilters(netlink.ConntrackTable, netlink.InetFamily(ipFamily), filters...)
n += count
return err
})
if err != nil { if err != nil {
return int(n), fmt.Errorf("error deleting conntrack entries, error: %w", err) return int(n), fmt.Errorf("error deleting conntrack entries, error: %w", err)
} }