Home
last modified time | relevance | path

Searched refs:subchannel_wrapper (Results 1 – 3 of 3) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc630 const SubchannelWrapper* subchannel_wrapper = in Pick() local
634 GrpcLbClientStats* client_stats = subchannel_wrapper->client_stats(); in Pick()
650 if (!subchannel_wrapper->lb_token().empty()) { in Pick()
652 args.call_state->Alloc(subchannel_wrapper->lb_token().size() + 1)); in Pick()
653 strcpy(lb_token, subchannel_wrapper->lb_token().c_str()); in Pick()
657 result.subchannel = subchannel_wrapper->wrapped_subchannel(); in Pick()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_impl.cc332 auto* subchannel_wrapper = in Pick() local
335 locality_stats = subchannel_wrapper->locality_stats()->Ref().release(); in Pick()
339 result.subchannel = subchannel_wrapper->wrapped_subchannel(); in Pick()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc1492 for (auto* subchannel_wrapper : in ApplyUpdateInControlPlaneWorkSerializer() local
1494 subchannel_wrapper->ThrottleKeepaliveTime(new_keepalive_time); in ApplyUpdateInControlPlaneWorkSerializer()
2257 for (auto* subchannel_wrapper : subchannel_wrappers_) { in UpdateServiceConfigInControlPlaneLocked() local
2258 subchannel_wrapper->UpdateHealthCheckServiceName( in UpdateServiceConfigInControlPlaneLocked()
2600 SubchannelWrapper* subchannel_wrapper = in GetConnectedSubchannelInDataPlane() local
2603 subchannel_wrapper->connected_subchannel_in_data_plane(); in GetConnectedSubchannelInDataPlane()