exitIdle invokes the balancer's exitIdle method in the serializer.
()
| 169 | |
| 170 | // exitIdle invokes the balancer's exitIdle method in the serializer. |
| 171 | func (ccb *ccBalancerWrapper) exitIdle() { |
| 172 | ccb.serializer.TrySchedule(func(ctx context.Context) { |
| 173 | if ctx.Err() != nil || ccb.balancer == nil { |
| 174 | return |
| 175 | } |
| 176 | ccb.balancer.ExitIdle() |
| 177 | }) |
| 178 | } |
| 179 | |
| 180 | func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) { |
| 181 | ccb.cc.mu.Lock() |