Searched refs:picker_ (Results 1 – 7 of 7) sorted by relevance
196 : picker_(std::move(picker)) {} in RefCountedPicker()197 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()200 std::unique_ptr<SubchannelPicker> picker_; member in grpc_core::__anonff2650950111::XdsClusterImplLb::RefCountedPicker217 RefCountedPtr<RefCountedPicker> picker_; member in grpc_core::__anonff2650950111::XdsClusterImplLb::Picker272 RefCountedPtr<RefCountedPicker> picker_; member in grpc_core::__anonff2650950111::XdsClusterImplLb287 picker_(std::move(picker)) { in Picker()317 if (picker_ == nullptr) { // Should never happen. in Pick()328 PickResult result = picker_->Pick(args); in Pick()410 picker_.reset(); in ShutdownLocked()464 auto drop_picker = absl::make_unique<Picker>(this, picker_); in MaybeUpdatePickerLocked()[all …]
86 : name_(std::move(name)), picker_(std::move(picker)) {} in ChildPickerWrapper()87 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()93 std::unique_ptr<SubchannelPicker> picker_; member in grpc_core::__anon99c9fe3e0111::XdsClusterManagerLb::ChildPickerWrapper
181 : RangeSampler(range), picker_(range) { in ThreadUnsafeUnigramSampler()186 return picker_.Pick(rnd); in Sample()190 return static_cast<float>(picker_.get_weight(value)) / picker_.total_weight(); in Probability()195 kint32max - picker_.total_weight()); in Update()198 picker_.set_weight(value, picker_.get_weight(value) + 1); in Update()
177 random::WeightedPicker picker_;
134 : picker_(std::move(picker)) {} in RefCountedPicker()135 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()138 std::unique_ptr<SubchannelPicker> picker_; member in grpc_core::__anon1a946ba90111::PriorityLb::ChildPriority::RefCountedPicker145 : picker_(std::move(picker)) {} in RefCountedPickerWrapper()146 PickResult Pick(PickArgs args) override { return picker_->Pick(args); } in Pick()149 RefCountedPtr<RefCountedPicker> picker_; member in grpc_core::__anon1a946ba90111::PriorityLb::ChildPriority::RefCountedPickerWrapper
89 : picker_(std::move(picker)) {} in ChildPickerWrapper()90 PickResult Pick(PickArgs args) { return picker_->Pick(args); } in Pick()93 std::unique_ptr<SubchannelPicker> picker_; member in grpc_core::__anon28d8a0b30111::WeightedTargetLb::ChildPickerWrapper
180 return picker_.get(); in picker()352 std::unique_ptr<LoadBalancingPolicy::SubchannelPicker> picker_; member in grpc_core::__anon983758c10111::ChannelData2441 picker_.swap(picker); in UpdateStateAndPickerLocked()2443 if (picker_ == nullptr || state == GRPC_CHANNEL_SHUTDOWN) { in UpdateStateAndPickerLocked()2469 picker_->Pick(LoadBalancingPolicy::PickArgs()); in DoPingLocked()