Home
last modified time | relevance | path

Searched refs:XdsClient (Results 1 – 25 of 66) sorted by relevance

123

/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/xds/
H A Dxds_client.cc81 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 Dxds_client.h44 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 Dxds_client_stats.h41 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 Dxds_server_config_fetcher.cc71 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 Dxds_client.cc483 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 Dxds_client.h42 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 Dxds_client_stats.h39 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 Dxds_bootstrap.h37 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 Dxds_client.cc501 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 Dxds_client.h44 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 Dxds_client_stats.h41 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 Dxds_server_config_fetcher.cc46 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 Dxds_client.cc501 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 Dxds_client.h44 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 Dxds_client_stats.h41 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 Dxds_server_config_fetcher.cc46 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 Dxds_client.cc74 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 Dxds_client.h44 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 Dxds_client_stats.h41 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 Dcds.cc55 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 Dlrs.cc79 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 Dcds.cc58 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 Dxds_resolver.cc67 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 Dcds.cc59 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 Dcds.cc59 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()

123