/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/xds/ |
H A D | xds_client.cc | 81 class XdsClient::Notifier { 537 XdsClient::ChannelState::ChannelState(WeakRefCountedPtr<XdsClient> xds_client, in ChannelState() 578 XdsClient::ChannelState::AdsCallState* XdsClient::ChannelState::ads_calld() in ads_calld() 583 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() 2015 XdsClient::XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, in XdsClient() function in grpc_core::XdsClient 2036 XdsClient::~XdsClient() { in ~XdsClient() 2079 RefCountedPtr<XdsClient::ChannelState> XdsClient::GetOrCreateChannelStateLocked( in GetOrCreateChannelStateLocked() 2775 RefCountedPtr<XdsClient> XdsClient::GetOrCreate(const grpc_channel_args* args, in GetOrCreate() 2850 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgCopy() 2856 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgDestroy() [all …]
|
H A D | xds_client.h | 44 class XdsClient : public DualRefCounted<XdsClient> { 94 static RefCountedPtr<XdsClient> GetOrCreate(const grpc_channel_args* args, 98 XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, 100 ~XdsClient() override; 203 static RefCountedPtr<XdsClient> GetFromChannelArgs( 217 ChannelState(WeakRefCountedPtr<XdsClient> xds_client, 224 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client() 239 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 243 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 249 WeakRefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_client_stats.h | 41 class XdsClient; variable 130 XdsClusterDropStats(RefCountedPtr<XdsClient> xds_client, 143 RefCountedPtr<XdsClient> xds_client_; 204 XdsClusterLocalityStats(RefCountedPtr<XdsClient> xds_client, 218 RefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_server_config_fetcher.cc | 71 RefCountedPtr<XdsClient> xds_client_; 89 : public XdsClient::ListenerWatcherInterface { 91 ListenerWatcher(RefCountedPtr<XdsClient> xds_client, 123 const RefCountedPtr<XdsClient> xds_client_; 144 RefCountedPtr<XdsClient> xds_client, 197 RefCountedPtr<XdsClient> xds_client_; 369 RefCountedPtr<XdsClient> xds_client_; 384 : public XdsClient::RouteConfigWatcherInterface { 407 RefCountedPtr<XdsClient> xds_client, in XdsServerConfigFetcher() 450 RefCountedPtr<XdsClient> xds_client, in ListenerWatcher() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/xds/ |
H A D | xds_client.cc | 483 XdsClient::ChannelState::ChannelState(RefCountedPtr<XdsClient> xds_client, in ChannelState() 508 XdsClient::ChannelState::AdsCallState* XdsClient::ChannelState::ads_calld() in ads_calld() 513 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() 1778 XdsClient::XdsClient(std::shared_ptr<WorkSerializer> work_serializer, in XdsClient() function in grpc_core::XdsClient 1820 XdsClient::~XdsClient() { in ~XdsClient() 1826 void XdsClient::Orphan() { in Orphan() 2331 XdsClient* xds_client = static_cast<XdsClient*>(p); in ChannelArgCopy() 2337 XdsClient* xds_client = static_cast<XdsClient*>(p); in ChannelArgDestroy() 2344 XdsClient::ChannelArgCopy, XdsClient::ChannelArgDestroy, 2353 RefCountedPtr<XdsClient> XdsClient::GetFromChannelArgs( in GetFromChannelArgs() [all …]
|
H A D | xds_client.h | 42 class XdsClient : public InternallyRefCounted<XdsClient> { 83 XdsClient(std::shared_ptr<WorkSerializer> work_serializer, 87 ~XdsClient(); 143 static RefCountedPtr<XdsClient> GetFromChannelArgs( 167 ChannelState(RefCountedPtr<XdsClient> xds_client, grpc_channel* channel); 173 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client() 193 RefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_client_stats.h | 39 class XdsClient; variable 104 XdsClusterDropStats(RefCountedPtr<XdsClient> xds_client, 116 RefCountedPtr<XdsClient> xds_client_; 176 XdsClusterLocalityStats(RefCountedPtr<XdsClient> xds_client, 190 RefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_bootstrap.h | 37 class XdsClient; variable 62 static std::unique_ptr<XdsBootstrap> ReadFromFile(XdsClient* client,
|
/dports/devel/grpc/grpc-1.42.0/src/core/ext/xds/ |
H A D | xds_client.cc | 501 XdsClient::ChannelState::ChannelState(WeakRefCountedPtr<XdsClient> xds_client, in ChannelState() 542 XdsClient::ChannelState::AdsCallState* XdsClient::ChannelState::ads_calld() in ads_calld() 547 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() 2005 XdsClient::XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, in XdsClient() function in grpc_core::XdsClient 2026 XdsClient::~XdsClient() { in ~XdsClient() 2069 RefCountedPtr<XdsClient::ChannelState> XdsClient::GetOrCreateChannelStateLocked( in GetOrCreateChannelStateLocked() 2671 RefCountedPtr<XdsClient> XdsClient::GetOrCreate(const grpc_channel_args* args, in GetOrCreate() 2746 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgCopy() 2752 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgDestroy() 2769 RefCountedPtr<XdsClient> XdsClient::GetFromChannelArgs( in GetFromChannelArgs() [all …]
|
H A D | xds_client.h | 44 class XdsClient : public DualRefCounted<XdsClient> { 85 static RefCountedPtr<XdsClient> GetOrCreate(const grpc_channel_args* args, 89 XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, 91 ~XdsClient() override; 195 static RefCountedPtr<XdsClient> GetFromChannelArgs( 209 ChannelState(WeakRefCountedPtr<XdsClient> xds_client, 216 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client() 231 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 235 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 241 WeakRefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_client_stats.h | 41 class XdsClient; variable 130 XdsClusterDropStats(RefCountedPtr<XdsClient> xds_client, 143 RefCountedPtr<XdsClient> xds_client_; 204 XdsClusterLocalityStats(RefCountedPtr<XdsClient> xds_client, 218 RefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_server_config_fetcher.cc | 46 RefCountedPtr<XdsClient> xds_client, in FilterChainMatchManager() 79 const RefCountedPtr<XdsClient> xds_client_; 350 explicit XdsServerConfigFetcher(RefCountedPtr<XdsClient> xds_client, in XdsServerConfigFetcher() 394 class ListenerWatcher : public XdsClient::ListenerWatcherInterface { 399 RefCountedPtr<XdsClient> xds_client, in ListenerWatcher() 498 RefCountedPtr<XdsClient> xds_client_; 509 RefCountedPtr<XdsClient> xds_client_; 526 grpc_core::RefCountedPtr<grpc_core::XdsClient> xds_client = in grpc_server_config_fetcher_xds_create() 527 grpc_core::XdsClient::GetOrCreate(args, &error); in grpc_server_config_fetcher_xds_create()
|
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/xds/ |
H A D | xds_client.cc | 501 XdsClient::ChannelState::ChannelState(WeakRefCountedPtr<XdsClient> xds_client, in ChannelState() 542 XdsClient::ChannelState::AdsCallState* XdsClient::ChannelState::ads_calld() in ads_calld() 547 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() 2005 XdsClient::XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, in XdsClient() function in grpc_core::XdsClient 2026 XdsClient::~XdsClient() { in ~XdsClient() 2069 RefCountedPtr<XdsClient::ChannelState> XdsClient::GetOrCreateChannelStateLocked( in GetOrCreateChannelStateLocked() 2671 RefCountedPtr<XdsClient> XdsClient::GetOrCreate(const grpc_channel_args* args, in GetOrCreate() 2746 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgCopy() 2752 XdsClient* xds_client = static_cast<XdsClient*>(p); in XdsClientArgDestroy() 2769 RefCountedPtr<XdsClient> XdsClient::GetFromChannelArgs( in GetFromChannelArgs() [all …]
|
H A D | xds_client.h | 44 class XdsClient : public DualRefCounted<XdsClient> { 85 static RefCountedPtr<XdsClient> GetOrCreate(const grpc_channel_args* args, 89 XdsClient(std::unique_ptr<XdsBootstrap> bootstrap, 91 ~XdsClient() override; 195 static RefCountedPtr<XdsClient> GetFromChannelArgs( 209 ChannelState(WeakRefCountedPtr<XdsClient> xds_client, 216 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client() 231 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 235 ABSL_EXCLUSIVE_LOCKS_REQUIRED(&XdsClient::mu_); 241 WeakRefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_client_stats.h | 41 class XdsClient; variable 130 XdsClusterDropStats(RefCountedPtr<XdsClient> xds_client, 143 RefCountedPtr<XdsClient> xds_client_; 204 XdsClusterLocalityStats(RefCountedPtr<XdsClient> xds_client, 218 RefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_server_config_fetcher.cc | 46 RefCountedPtr<XdsClient> xds_client, in FilterChainMatchManager() 79 const RefCountedPtr<XdsClient> xds_client_; 350 explicit XdsServerConfigFetcher(RefCountedPtr<XdsClient> xds_client, in XdsServerConfigFetcher() 394 class ListenerWatcher : public XdsClient::ListenerWatcherInterface { 399 RefCountedPtr<XdsClient> xds_client, in ListenerWatcher() 498 RefCountedPtr<XdsClient> xds_client_; 509 RefCountedPtr<XdsClient> xds_client_; 526 grpc_core::RefCountedPtr<grpc_core::XdsClient> xds_client = in grpc_server_config_fetcher_xds_create() 527 grpc_core::XdsClient::GetOrCreate(args, &error); in grpc_server_config_fetcher_xds_create()
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/xds/ |
H A D | xds_client.cc | 74 XdsClient* g_xds_client = nullptr; 460 XdsClient::ChannelState::ChannelState(WeakRefCountedPtr<XdsClient> xds_client, in ChannelState() 493 XdsClient::ChannelState::AdsCallState* XdsClient::ChannelState::ads_calld() in ads_calld() 498 XdsClient::ChannelState::LrsCallState* XdsClient::ChannelState::lrs_calld() in lrs_calld() 1739 XdsClient::XdsClient(grpc_error** error) in XdsClient() function in grpc_core::XdsClient 1762 XdsClient::~XdsClient() { in ~XdsClient() 1787 void XdsClient::Orphan() { in Orphan() 1813 void XdsClient::WatchListenerData( in WatchListenerData() 1892 void XdsClient::WatchClusterData( in WatchClusterData() 2083 void XdsClient::ResetBackoff() { in ResetBackoff() [all …]
|
H A D | xds_client.h | 44 class XdsClient : public DualRefCounted<XdsClient> { 85 static RefCountedPtr<XdsClient> GetOrCreate(grpc_error** error); 88 explicit XdsClient(grpc_error** error); 89 ~XdsClient() override; 200 ChannelState(WeakRefCountedPtr<XdsClient> xds_client, 207 XdsClient* xds_client() const { return xds_client_.get(); } in xds_client() 227 WeakRefCountedPtr<XdsClient> xds_client_;
|
H A D | xds_client_stats.h | 41 class XdsClient; variable 130 XdsClusterDropStats(RefCountedPtr<XdsClient> xds_client, 143 RefCountedPtr<XdsClient> xds_client_; 204 XdsClusterLocalityStats(RefCountedPtr<XdsClient> xds_client, 218 RefCountedPtr<XdsClient> xds_client_;
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/xds/ |
H A D | cds.cc | 55 CdsLb(RefCountedPtr<XdsClient> xds_client, Args args); 64 class ClusterWatcher : public XdsClient::ClusterWatcherInterface { 104 RefCountedPtr<XdsClient> xds_client_; 273 CdsLb::CdsLb(RefCountedPtr<XdsClient> xds_client, Args args) in CdsLb() 359 RefCountedPtr<XdsClient> xds_client = in CreateLoadBalancingPolicy() 360 XdsClient::GetFromChannelArgs(*args.args); in CreateLoadBalancingPolicy()
|
H A D | lrs.cc | 79 LrsLb(RefCountedPtr<XdsClient> xds_client, Args args); 151 RefCountedPtr<XdsClient> xds_client_; 195 LrsLb::LrsLb(RefCountedPtr<XdsClient> xds_client, Args args) in LrsLb() 259 grpc_channel_args* new_args = XdsClient::RemoveFromChannelArgs(*args.args); in UpdateLocked() 361 RefCountedPtr<XdsClient> xds_client = in CreateLoadBalancingPolicy() 362 XdsClient::GetFromChannelArgs(*args.args); in CreateLoadBalancingPolicy()
|
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/xds/ |
H A D | cds.cc | 58 CdsLb(RefCountedPtr<XdsClient> xds_client, Args args); 67 class ClusterWatcher : public XdsClient::ClusterWatcherInterface { 132 RefCountedPtr<XdsClient> xds_client_; 234 CdsLb::CdsLb(RefCountedPtr<XdsClient> xds_client, Args args) in CdsLb() 437 RefCountedPtr<XdsClient> xds_client = XdsClient::GetOrCreate(&error); in CreateLoadBalancingPolicy()
|
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/resolver/xds/ |
H A D | xds_resolver.cc | 67 class ServiceConfigWatcher : public XdsClient::ServiceConfigWatcherInterface { 83 OrphanablePtr<XdsClient> xds_client_; 129 xds_client_ = MakeOrphanable<XdsClient>( in StartLocked()
|
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/xds/ |
H A D | cds.cc | 59 CdsLb(RefCountedPtr<XdsClient> xds_client, Args args); 69 class ClusterWatcher : public XdsClient::ClusterWatcherInterface { 150 XdsClient::ClusterWatcherInterface* watcher, 161 RefCountedPtr<XdsClient> xds_client_; 225 CdsLb::CdsLb(RefCountedPtr<XdsClient> xds_client, Args args) in CdsLb() 612 XdsClient::ClusterWatcherInterface* watcher, in CancelClusterDataWatch() 633 RefCountedPtr<XdsClient> xds_client = in CreateLoadBalancingPolicy() 634 XdsClient::GetFromChannelArgs(*args.args); in CreateLoadBalancingPolicy()
|
/dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/xds/ |
H A D | cds.cc | 59 CdsLb(RefCountedPtr<XdsClient> xds_client, Args args); 69 class ClusterWatcher : public XdsClient::ClusterWatcherInterface { 149 XdsClient::ClusterWatcherInterface* watcher, 160 RefCountedPtr<XdsClient> xds_client_; 278 CdsLb::CdsLb(RefCountedPtr<XdsClient> xds_client, Args args) in CdsLb() 665 XdsClient::ClusterWatcherInterface* watcher, in CancelClusterDataWatch() 686 RefCountedPtr<XdsClient> xds_client = in CreateLoadBalancingPolicy() 687 XdsClient::GetFromChannelArgs(*args.args); in CreateLoadBalancingPolicy()
|