Home
last modified time | relevance | path

Searched refs:QueuePicker (Results 1 – 8 of 8) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dlb_policy.h373 class QueuePicker : public SubchannelPicker {
375 explicit QueuePicker(RefCountedPtr<LoadBalancingPolicy> parent) in QueuePicker() function
378 ~QueuePicker() override { parent_.reset(DEBUG_LOCATION, "QueuePicker"); } in ~QueuePicker()
Dlb_policy.cc95 LoadBalancingPolicy::PickResult LoadBalancingPolicy::QueuePicker::Pick( in Pick()
Dclient_channel.cc2364 absl::make_unique<LoadBalancingPolicy::QueuePicker>(nullptr)); in CreateResolverLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc327 absl::make_unique<QueuePicker>( in ProcessConnectivityChangeLocked()
344 absl::make_unique<QueuePicker>( in ProcessConnectivityChangeLocked()
357 absl::make_unique<QueuePicker>( in ProcessConnectivityChangeLocked()
414 absl::make_unique<QueuePicker>( in ProcessConnectivityChangeLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc359 cluster_name, absl::make_unique<QueuePicker>( in UpdateStateLocked()
369 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker")); in UpdateStateLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc331 absl::make_unique<QueuePicker>(p->Ref(DEBUG_LOCATION, "QueuePicker"))); in MaybeUpdateRoundRobinConnectivityStateLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc428 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker"))); in TryNextPriorityLocked()
458 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker"))); in TryNextPriorityLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc387 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker")); in UpdateStateLocked()