| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 188 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
254 if (num_subchannels() == 0) return; in StartWatchingLocked()
258 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
266 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
329 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
347 if (num_ready_ > 0 || num_transient_failure_ == num_subchannels()) { in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
358 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
364 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
382 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
449 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 188 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
254 if (num_subchannels() == 0) return; in StartWatchingLocked()
258 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
266 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
329 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
347 if (num_ready_ > 0 || num_transient_failure_ == num_subchannels()) { in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
358 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
364 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
382 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
449 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 188 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
254 if (num_subchannels() == 0) return; in StartWatchingLocked()
258 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
266 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
329 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
347 if (num_ready_ > 0 || num_transient_failure_ == num_subchannels()) { in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
358 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
364 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
382 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
449 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 187 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
256 if (num_subchannels() == 0) return; in StartWatchingLocked()
260 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
268 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
331 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
357 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
363 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
381 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
448 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 182 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
253 if (num_subchannels() == 0) return; in StartWatchingLocked()
257 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
265 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
328 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
354 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
360 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
378 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
428 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| H A D | round_robin.cc | 188 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in Picker()
257 if (num_subchannels() == 0) return; in StartWatchingLocked()
261 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
269 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
332 } else if (num_transient_failure_ == num_subchannels()) { in MaybeUpdateRoundRobinConnectivityStateLocked()
358 ? p->subchannel_list_->num_subchannels() in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
364 num_subchannels()); in UpdateRoundRobinStateFromSubchannelStateCountsLocked()
382 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
449 if (latest_pending_subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 281 size_t num_subchannels = subchannel_list->num_subchannels(); in Picker() local
292 address_weights.reserve(num_subchannels); in Picker()
293 for (size_t i = 0; i < num_subchannels; ++i) { in Picker()
343 for (size_t i = 0; i < num_subchannels; ++i) { in Picker()
483 if (num_subchannels() == 0) return; in StartWatchingLocked()
485 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
491 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
587 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
654 size_t next_index = (Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
706 if (subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 281 size_t num_subchannels = subchannel_list->num_subchannels();
292 address_weights.reserve(num_subchannels);
293 for (size_t i = 0; i < num_subchannels; ++i) {
343 for (size_t i = 0; i < num_subchannels; ++i) {
483 if (num_subchannels() == 0) return;
485 for (size_t i = 0; i < num_subchannels(); ++i) {
491 for (size_t i = 0; i < num_subchannels(); i++) {
587 subchannel_list()->num_subchannels(),
654 size_t next_index = (Index() + 1) % subchannel_list()->num_subchannels();
706 if (subchannel_list_->num_subchannels() == 0) {
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/ |
| H A D | ring_hash.cc | 281 size_t num_subchannels = subchannel_list->num_subchannels(); in Picker() local
292 address_weights.reserve(num_subchannels); in Picker()
293 for (size_t i = 0; i < num_subchannels; ++i) { in Picker()
343 for (size_t i = 0; i < num_subchannels; ++i) { in Picker()
483 if (num_subchannels() == 0) return; in StartWatchingLocked()
485 for (size_t i = 0; i < num_subchannels(); ++i) { in StartWatchingLocked()
491 for (size_t i = 0; i < num_subchannels(); i++) { in StartWatchingLocked()
587 subchannel_list()->num_subchannels(), in UpdateConnectivityStateLocked()
654 size_t next_index = (Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
706 if (subchannel_list_->num_subchannels() == 0) { in UpdateLocked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 181 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
249 subchannel_list_->num_subchannels(), in OnConnectivityStateChange()
291 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
314 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
334 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 181 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
249 subchannel_list_->num_subchannels(), in OnConnectivityStateChange()
291 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
314 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
334 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 181 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
249 subchannel_list_->num_subchannels(), in OnConnectivityStateChange()
291 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
314 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
334 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 181 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
249 subchannel_list_->num_subchannels(), in OnConnectivityStateChange()
291 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
314 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
334 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 179 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
247 subchannel_list_->num_subchannels(), in OnConnectivityStateChange()
289 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
312 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
332 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/ |
| H A D | subchannel_list.h | 218 size_t num_subchannels() const { return subchannels_.size(); } in num_subchannels() function
325 sd->subchannel_list_->num_subchannels(), sd->subchannel_.get(), in OnUpdateLocked()
370 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in UnrefSubchannelLocked()
394 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in StartConnectivityWatchLocked()
415 subchannel_list_, Index(), subchannel_list_->num_subchannels(), in CancelConnectivityWatchLocked()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 191 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
212 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
379 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
450 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 189 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
208 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
376 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
463 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 192 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
213 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
383 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
456 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 191 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
212 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
380 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
453 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 189 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
208 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
376 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
463 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| H A D | pick_first.cc | 189 if (subchannel_list->num_subchannels() == 0) { in AttemptToConnectUsingLatestUpdateArgsLocked()
208 for (size_t i = 0; i < subchannel_list->num_subchannels(); ++i) { in AttemptToConnectUsingLatestUpdateArgsLocked()
376 (sd->Index() + 1) % subchannel_list()->num_subchannels(); in ProcessConnectivityChangeLocked()
463 for (size_t i = 0; i < subchannel_list()->num_subchannels(); ++i) { in ProcessUnselectedReadyLocked()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/hyperv/ |
| H A D | rndis_filter.c | 1294 init_packet->msg.v5_msg.subchn_req.num_subchannels = in rndis_set_subchannel()
1315 if (init_packet->msg.v5_msg.subchn_comp.num_subchannels > nvdev->num_chn - 1) { in rndis_set_subchannel()
1320 init_packet->msg.v5_msg.subchn_comp.num_subchannels; in rndis_set_subchannel()
|
| H A D | hyperv_net.h | 647 u32 num_subchannels; member
652 u32 num_subchannels; /* Actual number of subchannels allocated */ member
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/hyperv/ |
| H A D | rndis_filter.c | 1294 init_packet->msg.v5_msg.subchn_req.num_subchannels = in rndis_set_subchannel()
1315 if (init_packet->msg.v5_msg.subchn_comp.num_subchannels > nvdev->num_chn - 1) { in rndis_set_subchannel()
1320 init_packet->msg.v5_msg.subchn_comp.num_subchannels; in rndis_set_subchannel()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/hyperv/ |
| H A D | rndis_filter.c | 1294 init_packet->msg.v5_msg.subchn_req.num_subchannels = in rndis_set_subchannel()
1315 if (init_packet->msg.v5_msg.subchn_comp.num_subchannels > nvdev->num_chn - 1) { in rndis_set_subchannel()
1320 init_packet->msg.v5_msg.subchn_comp.num_subchannels; in rndis_set_subchannel()
|