Searched refs:num_subchannels (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 144 last_ready_index_(num_subchannels() - 1) { in RoundRobinSubchannelList()
238 subchannel_list_->num_subchannels()); in RoundRobin()
350 if (next_ready_index < subchannel_list_->num_subchannels()) { in DoPickLocked()
438 if (num_subchannels() == 0) return; in StartWatchingLocked()
442 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
453 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
515 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
539 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
545 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
565 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 195 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
308 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
334 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
355 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in RenewConnectivityWatchLocked()
373 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StopConnectivityWatchLocked()
389 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
422 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UpdateConnectedSubchannelLocked()
447 sd->subchannel_list_->num_subchannels(), sd->subchannel_, in OnConnectivityChangedLocked()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 253 if (subchannel_list_ != nullptr && subchannel_list_->num_subchannels() > 0) { in StartPickingLocked()
364 if (subchannel_list->num_subchannels() == 0) { in UpdateLocked()
388 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in UpdateLocked()
397 subchannel_list->num_subchannels()); in UpdateLocked()
523 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
|