Skip to content

K
k3s
Commit cf706531 authored by Ted Yu's avatar Ted Yu Committed by Ted Yu
Browse files
Options

Use read lock for ServiceHasEndpoints

parent 0889c3e4
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
pkg/proxy/userspace/roundrobin.go
View file @ cf706531
...@@ -122,8 +122,8 @@ func isSessionAffinity(affinity *affinityPolicy) bool { ...@@ -122,8 +122,8 @@ func isSessionAffinity(affinity *affinityPolicy) bool {
// ServiceHasEndpoints checks whether a service entry has endpoints. // ServiceHasEndpoints checks whether a service entry has endpoints.
func (lb *LoadBalancerRR) ServiceHasEndpoints(svcPort proxy.ServicePortName) bool { func (lb *LoadBalancerRR) ServiceHasEndpoints(svcPort proxy.ServicePortName) bool {
lb.lock.Lock() lb.lock.RLock()
defer lb.lock.Unlock() defer lb.lock.RUnlock()
state, exists := lb.services[svcPort] state, exists := lb.services[svcPort]
// TODO: while nothing ever assigns nil to the map, *some* of the code using the map // TODO: while nothing ever assigns nil to the map, *some* of the code using the map
// checks for it. The code should all follow the same convention. // checks for it. The code should all follow the same convention.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment