| /external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/ |
| D | xds_client_stats.cc | 51 xds_client_(std::move(xds_client)), in XdsClusterDropStats()
57 xds_client_.get(), this, std::string(lrs_server_name_).c_str(), in XdsClusterDropStats()
67 xds_client_.get(), this, std::string(lrs_server_name_).c_str(), in ~XdsClusterDropStats()
71 xds_client_->RemoveClusterDropStats(lrs_server_name_, cluster_name_, in ~XdsClusterDropStats()
73 xds_client_.reset(DEBUG_LOCATION, "DropStats"); in ~XdsClusterDropStats()
104 xds_client_(std::move(xds_client)), in XdsClusterLocalityStats()
112 xds_client_.get(), this, std::string(lrs_server_name_).c_str(), in XdsClusterLocalityStats()
123 xds_client_.get(), this, std::string(lrs_server_name_).c_str(), in ~XdsClusterLocalityStats()
128 xds_client_->RemoveClusterLocalityStats(lrs_server_name_, cluster_name_, in ~XdsClusterLocalityStats()
130 xds_client_.reset(DEBUG_LOCATION, "LocalityStats"); in ~XdsClusterLocalityStats()
|
| D | xds_server_config_fetcher.cc | 31 : xds_client_(std::move(xds_client)) { in XdsServerConfigFetcher()
32 GPR_ASSERT(xds_client_ != nullptr); in XdsServerConfigFetcher()
43 xds_client_->WatchListenerData( in StartWatch()
59 xds_client_->CancelListenerDataWatch(it->second.listening_address, in CancelWatch()
68 return xds_client_->interested_parties(); in interested_parties()
109 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anonc52f70f40111::XdsServerConfigFetcher
|
| D | xds_client_stats.h | 143 RefCountedPtr<XdsClient> xds_client_;
218 RefCountedPtr<XdsClient> xds_client_;
|
| D | xds_client.h | 211 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client()
231 WeakRefCountedPtr<XdsClient> xds_client_; variable
|
| D | xds_client.cc | 413 MutexLock lock(&parent_->xds_client_->mu_); in OnConnectivityStateChange()
466 xds_client_(std::move(xds_client)), in ChannelState()
470 xds_client_.get(), server.server_uri.c_str()); in ChannelState()
483 xds_client_.reset(DEBUG_LOCATION, "ChannelState"); in ~ChannelState()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/xds/ |
| D | xds_resolver.cc | 188 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon6328d4090111::XdsResolver
239 if (resolver_->xds_client_ == nullptr) { in RunInWorkSerializer()
567 xds_client_ = XdsClient::GetOrCreate(&error); in StartLocked()
576 grpc_pollset_set_add_pollset_set(xds_client_->interested_parties(), in StartLocked()
582 xds_client_->AddChannelzLinkage(parent_channelz_node); in StartLocked()
586 xds_client_->WatchListenerData(server_name_, std::move(watcher)); in StartLocked()
593 if (xds_client_ != nullptr) { in ShutdownLocked()
595 xds_client_->CancelListenerDataWatch(server_name_, listener_watcher_, in ShutdownLocked()
599 xds_client_->CancelRouteConfigDataWatch( in ShutdownLocked()
606 xds_client_->RemoveChannelzLinkage(parent_channelz_node); in ShutdownLocked()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | cds.cc | 137 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon5aa779ee0111::CdsLb
244 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in CdsLb()
247 xds_client_.get()); in CdsLb()
263 if (xds_client_ != nullptr) { in ShutdownLocked()
269 xds_client_->CancelClusterDataWatch(config_->cluster(), cluster_watcher_); in ShutdownLocked()
271 xds_client_.reset(DEBUG_LOCATION, "CdsLb"); in ShutdownLocked()
308 xds_client_->CancelClusterDataWatch(old_config->cluster(), in UpdateLocked()
318 xds_client_->WatchClusterData(config_->cluster(), std::move(watcher)); in UpdateLocked()
325 this, xds_client_.get(), cluster_data.ToString().c_str()); in OnClusterChanged()
471 xds_client_->certificate_provider_store() in UpdateXdsCertificateProvider()
[all …]
|
| D | xds_cluster_resolver.cc | 325 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon57cf7ab50111::XdsClusterResolverLb
390 parent()->xds_client_->WatchEndpointData(GetXdsClusterResolverResourceName(), in Start()
402 parent()->xds_client_->CancelEndpointDataWatch( in Orphan()
530 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterResolverLb()
534 xds_client_.get()); in XdsClusterResolverLb()
557 xds_client_->AddChannelzLinkage(parent_channelz_node); in XdsClusterResolverLb()
560 grpc_pollset_set_add_pollset_set(xds_client_->interested_parties(), in XdsClusterResolverLb()
587 xds_client_->RemoveChannelzLinkage(parent_channelz_node); in ShutdownLocked()
590 grpc_pollset_set_del_pollset_set(xds_client_->interested_parties(), in ShutdownLocked()
593 xds_client_.reset(DEBUG_LOCATION, "XdsClusterResolverLb"); in ShutdownLocked()
[all …]
|
| D | xds_cluster_impl.cc | 262 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anonff2650950111::XdsClusterImplLb
381 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterImplLb()
384 this, xds_client_.get()); in XdsClusterImplLb()
412 xds_client_.reset(); in ShutdownLocked()
436 drop_stats_ = xds_client_->AddClusterDropStats( in UpdateLocked()
557 xds_cluster_impl_policy_->xds_client_->AddClusterLocalityStats( in CreateSubchannel()
|