| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/ |
| D | pick_first.cc | 90 policy->channel_control_helper(), args) { in PickFirstSubchannelList()
203 channel_control_helper()->UpdateState( in AttemptToConnectUsingLatestUpdateArgsLocked()
321 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
325 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
339 p->channel_control_helper()->RequestReresolution(); in ProcessConnectivityChangeLocked()
342 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
351 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
355 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
391 p->channel_control_helper()->RequestReresolution(); in ProcessConnectivityChangeLocked()
400 p->channel_control_helper()->UpdateState( in ProcessConnectivityChangeLocked()
[all …]
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 57 delegate_args.channel_control_helper = std::move(delegating_helper); in ForwardingLoadBalancingPolicy()
142 return parent_->channel_control_helper()->CreateSubchannel(args); in CreateSubchannel()
147 parent_->channel_control_helper()->UpdateState( in UpdateState()
152 parent_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
157 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
252 return parent_->channel_control_helper()->CreateSubchannel(args); in CreateSubchannel()
257 parent_->channel_control_helper()->UpdateState( in UpdateState()
262 parent_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
267 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | resolving_lb_policy.cc | 114 return parent_->channel_control_helper()->CreateSubchannel(args); in CreateSubchannel()
120 parent_->channel_control_helper()->UpdateState(state, std::move(picker)); in UpdateState()
135 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
163 channel_control_helper()->UpdateState(GRPC_CHANNEL_CONNECTING, in ResolvingLoadBalancingPolicy()
216 channel_control_helper()->UpdateState( in OnResolverError()
251 lb_policy_args.channel_control_helper = in CreateLbPolicyLocked()
282 channel_control_helper()->AddTraceEvent(ChannelControlHelper::TRACE_INFO, in ConcatenateAndAddChannelTraceLocked()
|
| D | lb_policy.h | 333 std::unique_ptr<ChannelControlHelper> channel_control_helper; member
406 ChannelControlHelper* channel_control_helper() const { in channel_control_helper() function
|
| D | lb_policy.cc | 42 channel_control_helper_(std::move(args.channel_control_helper)) {} in LoadBalancingPolicy()
|
| D | client_channel.cc | 2195 lb_policy_args.channel_control_helper = in CreateLbPolicyLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | child_policy_handler.cc | 45 return parent_->channel_control_helper()->CreateSubchannel( in CreateSubchannel()
72 parent_->channel_control_helper()->UpdateState(state, status, in UpdateState()
90 parent_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
97 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
264 lb_policy_args.channel_control_helper = in CreateChildPolicy()
279 channel_control_helper()->AddTraceEvent( in CreateChildPolicy()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/ |
| D | round_robin.cc | 118 policy->channel_control_helper(), args) { in RoundRobinSubchannelList()
325 p->channel_control_helper()->UpdateState( in MaybeUpdateRoundRobinConnectivityStateLocked()
329 p->channel_control_helper()->UpdateState( in MaybeUpdateRoundRobinConnectivityStateLocked()
338 p->channel_control_helper()->UpdateState( in MaybeUpdateRoundRobinConnectivityStateLocked()
425 p->channel_control_helper()->RequestReresolution(); in ProcessConnectivityChangeLocked()
455 channel_control_helper()->UpdateState( in UpdateLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/priority/ |
| D | priority.cc | 349 channel_control_helper()->UpdateState(child->connectivity_state(), in HandleChildConnectivityStateChangeLocked()
398 channel_control_helper()->UpdateState(child->connectivity_state(), in HandleChildConnectivityStateChangeLocked()
429 channel_control_helper()->UpdateState( in TryNextPriorityLocked()
459 channel_control_helper()->UpdateState( in TryNextPriorityLocked()
478 channel_control_helper()->UpdateState( in TryNextPriorityLocked()
498 channel_control_helper()->UpdateState(child->connectivity_state(), in SelectPriorityLocked()
578 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
748 priority_->priority_policy_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
755 return priority_->priority_policy_->channel_control_helper() in CreateSubchannel()
770 priority_->priority_policy_->channel_control_helper()->AddTraceEvent(severity, in AddTraceEvent()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | lrs.cc | 272 channel_control_helper()->UpdateState(state_, std::move(lrs_picker)); in MaybeUpdatePickerLocked()
281 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
324 return lrs_policy_->channel_control_helper()->CreateSubchannel(args); in CreateSubchannel()
344 lrs_policy_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
350 lrs_policy_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
|
| D | xds_cluster_impl.cc | 470 channel_control_helper()->UpdateState(GRPC_CHANNEL_READY, absl::Status(), in MaybeUpdatePickerLocked()
485 channel_control_helper()->UpdateState(state_, status_, in MaybeUpdatePickerLocked()
495 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
562 xds_cluster_impl_policy_->channel_control_helper()->CreateSubchannel( in CreateSubchannel()
567 return xds_cluster_impl_policy_->channel_control_helper()->CreateSubchannel( in CreateSubchannel()
594 xds_cluster_impl_policy_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
600 xds_cluster_impl_policy_->channel_control_helper()->AddTraceEvent(severity, in AddTraceEvent()
|
| D | cds.cc | 236 return parent_->channel_control_helper()->CreateSubchannel(std::move(address), in CreateSubchannel()
249 parent_->channel_control_helper()->UpdateState(state, status, in UpdateState()
259 parent_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
265 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
501 args.channel_control_helper = absl::make_unique<Helper>(Ref()); in OnClusterChanged()
551 channel_control_helper()->UpdateState( in OnError()
570 channel_control_helper()->UpdateState( in OnResourceDoesNotExist()
|
| D | eds.cc | 264 return eds_policy_->channel_control_helper()->CreateSubchannel(args); in CreateSubchannel()
287 eds_policy_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
341 eds_policy_->channel_control_helper()->UpdateState( in OnError()
354 eds_policy_->channel_control_helper()->UpdateState( in OnResourceDoesNotExist()
690 channel_control_helper()->UpdateState( in CreateChildPolicyConfigLocked()
747 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
772 channel_control_helper()->UpdateState(GRPC_CHANNEL_READY, in MaybeUpdateDropPickerLocked()
778 channel_control_helper()->UpdateState(child_state_, in MaybeUpdateDropPickerLocked()
|
| D | xds_cluster_manager.cc | 379 channel_control_helper()->UpdateState(connectivity_state, status, in UpdateStateLocked()
441 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
545 ->channel_control_helper() in CreateSubchannel()
591 ->channel_control_helper() in RequestReresolution()
601 ->channel_control_helper() in AddTraceEvent()
|
| D | xds_routing.cc | 502 channel_control_helper()->UpdateState(connectivity_state, std::move(picker)); in UpdateStateLocked()
556 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
653 return xds_routing_child_->xds_routing_policy_->channel_control_helper() in CreateSubchannel()
690 xds_routing_child_->xds_routing_policy_->channel_control_helper() in RequestReresolution()
697 xds_routing_child_->xds_routing_policy_->channel_control_helper() in AddTraceEvent()
|
| D | xds_cluster_resolver.cc | 353 return xds_cluster_resolver_policy_->channel_control_helper() in CreateSubchannel()
371 xds_cluster_resolver_policy_->channel_control_helper()->UpdateState( in UpdateState()
378 xds_cluster_resolver_policy_->channel_control_helper()->AddTraceEvent( in AddTraceEvent()
1030 channel_control_helper()->UpdateState( in CreateChildPolicyConfigLocked()
1068 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/ |
| D | weighted_target.cc | 397 channel_control_helper()->UpdateState(connectivity_state, status, in UpdateStateLocked()
455 lb_policy_args.channel_control_helper = in CreateChildPolicyLocked()
595 return weighted_child_->weighted_target_policy_->channel_control_helper() in CreateSubchannel()
609 weighted_child_->weighted_target_policy_->channel_control_helper() in RequestReresolution()
616 weighted_child_->weighted_target_policy_->channel_control_helper() in AddTraceEvent()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 681 parent_->channel_control_helper()->CreateSubchannel(std::move(address), in CreateSubchannel()
721 parent_->channel_control_helper()->UpdateState( in UpdateState()
735 parent_->channel_control_helper()->RequestReresolution(); in RequestReresolution()
742 parent_->channel_control_helper()->AddTraceEvent(severity, message); in AddTraceEvent()
1232 grpclb_policy()->channel_control_helper()->RequestReresolution(); in OnBalancerStatusReceivedLocked()
1632 lb_policy_args.channel_control_helper = absl::make_unique<Helper>(Ref()); in CreateChildPolicyLocked()
|