| /third_party/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 | 38 : xds_client_(std::move(xds_client)) { in XdsServerConfigFetcher()
39 GPR_ASSERT(xds_client_ != nullptr); in XdsServerConfigFetcher()
47 std::move(watcher), args, xds_client_); in StartWatch()
52 xds_client_->WatchListenerData(listening_address, in StartWatch()
66 xds_client_->CancelListenerDataWatch(it->second.listening_address, in CancelWatch()
75 return xds_client_->interested_parties(); in interested_parties()
87 xds_client_(std::move(xds_client)) {} in ListenerWatcher()
101 this, xds_client_.get(), listener.ToString().c_str()); in OnListenerChanged()
168 xds_client_->certificate_provider_store() in UpdateXdsCertificateProvider()
187 new_identity_provider = xds_client_->certificate_provider_store() in UpdateXdsCertificateProvider()
[all …]
|
| 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 | 414 MutexLock lock(&parent_->xds_client_->mu_); in OnConnectivityStateChange()
467 xds_client_(std::move(xds_client)), in ChannelState()
471 xds_client_.get(), server.server_uri.c_str()); in ChannelState()
484 xds_client_.reset(DEBUG_LOCATION, "ChannelState"); in ~ChannelState()
|
| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_client_stats.cc | 40 : xds_client_(std::move(xds_client)), in XdsClusterDropStats()
46 xds_client_->RemoveClusterDropStats(lrs_server_name_, cluster_name_, in ~XdsClusterDropStats()
48 xds_client_.reset(DEBUG_LOCATION, "DropStats"); in ~XdsClusterDropStats()
70 : xds_client_(std::move(xds_client)), in XdsClusterLocalityStats()
77 xds_client_->RemoveClusterLocalityStats(lrs_server_name_, cluster_name_, in ~XdsClusterLocalityStats()
79 xds_client_.reset(DEBUG_LOCATION, "LocalityStats"); in ~XdsClusterLocalityStats()
|
| D | xds_client_stats.h | 116 RefCountedPtr<XdsClient> xds_client_;
190 RefCountedPtr<XdsClient> xds_client_;
|
| D | xds_client.h | 173 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client()
193 RefCountedPtr<XdsClient> xds_client_; variable
|
| D | xds_client.cc | 483 xds_client_(std::move(xds_client)), in ChannelState()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/ |
| D | xds_resolver.cc | 190 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon0bd98fcd0111::XdsResolver
241 if (resolver_->xds_client_ == nullptr) { in RunInWorkSerializer()
515 xds_client_ = XdsClient::GetOrCreate(&error); in StartLocked()
524 grpc_pollset_set_add_pollset_set(xds_client_->interested_parties(), in StartLocked()
530 xds_client_->AddChannelzLinkage(parent_channelz_node); in StartLocked()
534 xds_client_->WatchListenerData(server_name_, std::move(watcher)); in StartLocked()
541 if (xds_client_ != nullptr) { in ShutdownLocked()
543 xds_client_->CancelListenerDataWatch(server_name_, listener_watcher_, in ShutdownLocked()
547 xds_client_->CancelRouteConfigDataWatch( in ShutdownLocked()
554 xds_client_->RemoveChannelzLinkage(parent_channelz_node); in ShutdownLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | cds.cc | 160 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anona4cab1b20111::CdsLb
273 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in CdsLb()
276 xds_client_.get()); in CdsLb()
292 if (xds_client_ != nullptr) { in ShutdownLocked()
302 xds_client_.reset(DEBUG_LOCATION, "CdsLb"); in ShutdownLocked()
351 xds_client_->WatchClusterData(config_->cluster(), std::move(watcher)); in UpdateLocked()
376 xds_client_->WatchClusterData(name, std::move(watcher)); in GenerateDiscoveryMechanismForCluster()
427 this, name.c_str(), xds_client_.get(), cluster_data.ToString().c_str()); in OnClusterChanged()
599 xds_client_->certificate_provider_store() in UpdateXdsCertificateProvider()
637 xds_client_->certificate_provider_store() in UpdateXdsCertificateProvider()
[all …]
|
| D | xds_cluster_resolver.cc | 332 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon9699b2f90111::XdsClusterResolverLb
397 parent()->xds_client_->WatchEndpointData(GetXdsClusterResolverResourceName(), in Start()
409 parent()->xds_client_->CancelEndpointDataWatch( in Orphan()
554 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterResolverLb()
558 xds_client_.get()); in XdsClusterResolverLb()
581 xds_client_->AddChannelzLinkage(parent_channelz_node); in XdsClusterResolverLb()
584 grpc_pollset_set_add_pollset_set(xds_client_->interested_parties(), in XdsClusterResolverLb()
611 xds_client_->RemoveChannelzLinkage(parent_channelz_node); in ShutdownLocked()
614 grpc_pollset_set_del_pollset_set(xds_client_->interested_parties(), in ShutdownLocked()
617 xds_client_.reset(DEBUG_LOCATION, "XdsClusterResolverLb"); in ShutdownLocked()
[all …]
|
| D | lrs.cc | 151 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anonbac676690111::LrsLb
196 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in LrsLb()
199 this, xds_client_.get()); in LrsLb()
225 xds_client_.reset(); in ShutdownLocked()
252 locality_stats_ = xds_client_->AddClusterLocalityStats( in UpdateLocked()
|
| D | eds.cc | 183 : xds_client_.get(); in xds_client()
201 OrphanablePtr<XdsClient> xds_client_; member in grpc_core::__anona97502f40111::EdsLb
423 xds_client_.reset(); in ShutdownLocked()
450 xds_client_ = MakeOrphanable<XdsClient>( in UpdateLocked()
458 xds_client_.get()); in UpdateLocked()
495 if (xds_client_ != nullptr) xds_client_->ResetBackoff(); in ResetBackoffLocked()
730 args_to_add.emplace_back(xds_client_->MakeChannelArg()); in CreateChildPolicyArgsLocked()
|
| D | xds_cluster_impl.cc | 260 RefCountedPtr<XdsClient> xds_client_; member in grpc_core::__anon93b706d90111::XdsClusterImplLb
379 : LoadBalancingPolicy(std::move(args)), xds_client_(std::move(xds_client)) { in XdsClusterImplLb()
382 this, xds_client_.get()); in XdsClusterImplLb()
410 xds_client_.reset(); in ShutdownLocked()
434 drop_stats_ = xds_client_->AddClusterDropStats( in UpdateLocked()
555 xds_cluster_impl_policy_->xds_client_->AddClusterLocalityStats( in CreateSubchannel()
|