mirror of
https://github.com/kubernetes/kubernetes.git
synced 2026-05-28 04:04:39 -04:00
Fix deleted UDP endpoint detection
This commit is contained in:
parent
b4ce3a55bc
commit
65de5de81f
1 changed files with 2 additions and 1 deletions
|
|
@ -308,7 +308,8 @@ func detectStaleConntrackEntries(oldEndpointsMap, newEndpointsMap EndpointsMap,
|
|||
// serving to not serving. If it did change stale entries for the old
|
||||
// endpoint have to be cleared.
|
||||
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
|
||||
break
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue