diff --git a/balancer_conn_wrappers.go b/balancer_conn_wrappers.go index bc965f0a..8029e2c4 100644 --- a/balancer_conn_wrappers.go +++ b/balancer_conn_wrappers.go @@ -151,6 +151,7 @@ func (ccb *ccBalancerWrapper) watcher() { for acbw := range scs { ccb.cc.removeAddrConn(acbw.getAddrConn(), errConnDrain) } + ccb.UpdateBalancerState(connectivity.Connecting, nil) return default: }