()
| 230 | } |
| 231 | |
| 232 | func (es *endpointSharding) ExitIdle() { |
| 233 | es.childMu.Lock() |
| 234 | defer es.childMu.Unlock() |
| 235 | for _, bw := range es.children.Load().All() { |
| 236 | if !bw.isClosed { |
| 237 | bw.child.ExitIdle() |
| 238 | } |
| 239 | } |
| 240 | } |
| 241 | |
| 242 | // updateState updates this component's state. It sends the aggregated state, |
| 243 | // and a picker with round robin behavior with all the child states present if |