(state balancer.State)
| 7261 | } |
| 7262 | |
| 7263 | func (bpb *triggerRPCBlockBalancer) UpdateState(state balancer.State) { |
| 7264 | bpb.stateMu.Lock() |
| 7265 | defer bpb.stateMu.Unlock() |
| 7266 | bpb.childState = state |
| 7267 | if bpb.blockingPickerDone.HasFired() { // guard first one to get a picker sending ErrNoSubConnAvailable first |
| 7268 | if state.ConnectivityState == connectivity.Ready { |
| 7269 | bpb.ClientConn.UpdateState(state) // after the first rr picker update, only forward once READY for deterministic picker counts |
| 7270 | } |
| 7271 | } |
| 7272 | } |
| 7273 | |
| 7274 | // TestRPCBlockingOnPickerStatsCall tests the emission of a stats handler call |
| 7275 | // that represents the RPC had to block waiting for a new picker due to |
nothing calls this directly
no test coverage detected