Searched refs:QueuePicker (Results 1 – 10 of 10) sorted by relevance
373 class QueuePicker : public SubchannelPicker {375 explicit QueuePicker(RefCountedPtr<LoadBalancingPolicy> parent) in QueuePicker() function378 ~QueuePicker() override { parent_.reset(DEBUG_LOCATION, "QueuePicker"); } in ~QueuePicker()
95 LoadBalancingPolicy::PickResult LoadBalancingPolicy::QueuePicker::Pick( in Pick()
164 absl::make_unique<QueuePicker>(Ref())); in ResolvingLoadBalancingPolicy()
2361 absl::make_unique<LoadBalancingPolicy::QueuePicker>(nullptr)); in CreateResolverLocked()
327 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()
359 cluster_name, absl::make_unique<QueuePicker>( in UpdateStateLocked()369 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker")); in UpdateStateLocked()
483 config_route.action, absl::make_unique<QueuePicker>( in UpdateStateLocked()494 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker")); in UpdateStateLocked()
431 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker"))); in TryNextPriorityLocked()461 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker"))); in TryNextPriorityLocked()
331 absl::make_unique<QueuePicker>(p->Ref(DEBUG_LOCATION, "QueuePicker"))); in MaybeUpdateRoundRobinConnectivityStateLocked()
387 absl::make_unique<QueuePicker>(Ref(DEBUG_LOCATION, "QueuePicker")); in UpdateStateLocked()