mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-28 22:17:14 +00:00
Fix deleted UDP endpoint detection
This commit is contained in:
parent
c75e833026
commit
b84713348c
@ -308,7 +308,8 @@ func detectStaleConntrackEntries(oldEndpointsMap, newEndpointsMap EndpointsMap,
|
|||||||
// serving to not serving. If it did change stale entries for the old
|
// serving to not serving. If it did change stale entries for the old
|
||||||
// endpoint have to be cleared.
|
// endpoint have to be cleared.
|
||||||
for i := range newEndpointsMap[svcPortName] {
|
for i := range newEndpointsMap[svcPortName] {
|
||||||
if newEndpointsMap[svcPortName][i].String() == ep.String() {
|
if newEndpointsMap[svcPortName][i].String() == ep.String() &&
|
||||||
|
newEndpointsMap[svcPortName][i].IsServing() == ep.IsServing() {
|
||||||
deleted = false
|
deleted = false
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user