diff --git a/balancer_wrapper.go b/balancer_wrapper.go index 60084067b4e4..972c77ed0268 100644 --- a/balancer_wrapper.go +++ b/balancer_wrapper.go @@ -289,8 +289,6 @@ func (acbw *acBalancerWrapper) updateState(s connectivity.State, curAddr resolve } acbw.stateListener(scs) - acbw.mu.Lock() - defer acbw.mu.Unlock() for lis := range acbw.connectivityListeners { lis.OnStateChange(scs) }