| /third_party/grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 178 : resolver_(std::move(resolver)), in FakeResolverResponseSetter()
187 RefCountedPtr<FakeResolver> resolver_; member in grpc_core::FakeResolverResponseSetter
195 if (!resolver_->shutdown_) { in SetReresolutionResponseLocked()
196 resolver_->reresolution_result_ = std::move(result_); in SetReresolutionResponseLocked()
197 resolver_->has_reresolution_result_ = has_result_; in SetReresolutionResponseLocked()
204 if (!resolver_->shutdown_) { in SetResponseLocked()
205 resolver_->next_result_ = std::move(result_); in SetResponseLocked()
206 resolver_->has_next_result_ = true; in SetResponseLocked()
207 resolver_->MaybeSendResultLocked(); in SetResponseLocked()
214 if (!resolver_->shutdown_) { in SetFailureLocked()
[all …]
|
| D | fake_resolver.h | 85 RefCountedPtr<FakeResolver> resolver_; variable
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | resolving_lb_policy.cc | 113 if (parent_->resolver_ == nullptr) return nullptr; // Shutting down. in CreateSubchannel()
119 if (parent_->resolver_ == nullptr) return; // Shutting down. in UpdateState()
124 if (parent_->resolver_ == nullptr) return; // Shutting down. in RequestReresolution()
129 parent_->resolver_->RequestReresolutionLocked(); in RequestReresolution()
134 if (parent_->resolver_ == nullptr) return; // Shutting down. in AddTraceEvent()
154 resolver_ = ResolverRegistry::CreateResolver( in ResolvingLoadBalancingPolicy()
159 GPR_ASSERT(resolver_ != nullptr); in ResolvingLoadBalancingPolicy()
165 resolver_->StartLocked(); in ResolvingLoadBalancingPolicy()
169 GPR_ASSERT(resolver_ == nullptr); in ~ResolvingLoadBalancingPolicy()
174 if (resolver_ != nullptr) { in ShutdownLocked()
[all …]
|
| D | resolving_lb_policy.h | 129 OrphanablePtr<Resolver> resolver_; variable
|
| D | client_channel.cc | 362 OrphanablePtr<Resolver> resolver_; member in grpc_core::__anon713362c70111::ChannelData
1732 if (chand_->resolver_ == nullptr) return nullptr; // Shutting down. in CreateSubchannel()
1775 if (chand_->resolver_ == nullptr) return; // Shutting down. in UpdateState()
1793 if (chand_->resolver_ == nullptr) return; // Shutting down. in RequestReresolution()
1797 chand_->resolver_->RequestReresolutionLocked(); in RequestReresolution()
1802 if (chand_->resolver_ == nullptr) return; // Shutting down. in AddTraceEvent()
2004 if (resolver_ == nullptr) return; in OnResolverResultChangedLocked()
2125 if (resolver_ == nullptr) { in OnResolverErrorLocked()
2353 resolver_ = ResolverRegistry::CreateResolver( in CreateResolverLocked()
2358 GPR_ASSERT(resolver_ != nullptr); in CreateResolverLocked()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/ |
| D | xds_resolver.cc | 85 RefCountedPtr<XdsResolver> resolver_; member in grpc_core::__anoncdfece4f0111::XdsResolver::Notifier
94 : resolver_(std::move(resolver)) {} in ListenerWatcher()
96 new Notifier(resolver_, std::move(listener)); in OnListenerChanged()
98 void OnError(grpc_error* error) override { new Notifier(resolver_, error); } in OnError()
99 void OnResourceDoesNotExist() override { new Notifier(resolver_); } in OnResourceDoesNotExist()
102 RefCountedPtr<XdsResolver> resolver_; member in grpc_core::__anoncdfece4f0111::XdsResolver::ListenerWatcher
108 : resolver_(std::move(resolver)) {} in RouteConfigWatcher()
110 new Notifier(resolver_, std::move(route_config)); in OnRouteConfigChanged()
112 void OnError(grpc_error* error) override { new Notifier(resolver_, error); } in OnError()
113 void OnResourceDoesNotExist() override { new Notifier(resolver_); } in OnResourceDoesNotExist()
[all …]
|
| /third_party/protobuf/src/google/protobuf/util/ |
| D | type_resolver_util_test.cc | 67 resolver_.reset(NewTypeResolverForDescriptorPool( in DescriptorPoolTypeResolverTest()
171 std::unique_ptr<TypeResolver> resolver_; member in google::protobuf::util::__anon268d68170111::DescriptorPoolTypeResolverTest
176 ASSERT_TRUE(resolver_ in TEST_F()
305 ASSERT_TRUE(resolver_ in TEST_F()
316 ASSERT_TRUE(resolver_ in TEST_F()
337 resolver_ in TEST_F()
347 resolver_ in TEST_F()
357 resolver_ in TEST_F()
369 resolver_ in TEST_F()
383 resolver_ in TEST_F()
[all …]
|
| D | json_util_test.cc | 85 std::unique_ptr<TypeResolver> resolver_; member in google::protobuf::util::__anon4f7e94fe0111::JsonUtilTest
|
| /third_party/boost/libs/beast/example/http/client/async/ |
| D | http_client_async.cpp | 43 tcp::resolver resolver_; member in session
54 : resolver_(net::make_strand(ioc)) in session()
75 resolver_.async_resolve( in run()
|
| /third_party/boost/libs/asio/example/cpp03/icmp/ |
| D | ping.cpp | 28 : resolver_(io_context), socket_(io_context, icmp::v4()), in pinger()
31 destination_ = *resolver_.resolve(icmp::v4(), destination, "").begin(); in pinger()
132 icmp::resolver resolver_; member in pinger
|
| /third_party/boost/libs/beast/example/websocket/client/async/ |
| D | websocket_client_async.cpp | 43 tcp::resolver resolver_; member in session
53 : resolver_(net::make_strand(ioc)) in session()
70 resolver_.async_resolve( in run()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/icmp/ |
| D | ping.cpp | 28 : resolver_(io_context), socket_(io_context, icmp::v4()), in pinger()
31 destination_ = *resolver_.resolve(icmp::v4(), destination, "").begin(); in pinger()
132 icmp::resolver resolver_; member in pinger
|
| /third_party/boost/libs/asio/example/cpp03/http/client/ |
| D | async_client.cpp | 25 : resolver_(io_context), in client()
39 resolver_.async_resolve(server, "http", in client()
176 tcp::resolver resolver_; member in client
|
| /third_party/boost/libs/beast/example/http/client/async-ssl/ |
| D | http_client_async_ssl.cpp | 47 tcp::resolver resolver_; member in session
58 : resolver_(ex) in session()
87 resolver_.async_resolve( in run()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/client/ |
| D | async_client.cpp | 25 : resolver_(io_context), in client()
39 resolver_.async_resolve(server, "http", in client()
176 tcp::resolver resolver_; member in client
|
| /third_party/boost/libs/beast/example/websocket/client/async-ssl/ |
| D | websocket_client_async_ssl.cpp | 48 tcp::resolver resolver_; member in session
59 : resolver_(net::make_strand(ioc)) in session()
76 resolver_.async_resolve( in run()
|
| /third_party/boost/libs/beast/example/websocket/client/async-ssl-system-executor/ |
| D | websocket_client_async_ssl_system_executor.cpp | 49 tcp::resolver resolver_; member in session
59 : resolver_(ex) in session()
84 resolver_.async_resolve( in run()
|
| /third_party/boost/libs/beast/example/http/client/async-ssl-system-executor/ |
| D | http_client_async_ssl_system_executor.cpp | 48 tcp::resolver resolver_; member in session
57 : resolver_(strand) in session()
95 resolver_.async_resolve( in run()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/google_c2p/ |
| D | google_c2p_resolver.cc | 61 RefCountedPtr<GoogleCloud2ProdResolver> resolver_; member in grpc_core::__anon09306df30111::GoogleCloud2ProdResolver::MetadataQuery
113 : resolver_(std::move(resolver)) { in MetadataQuery()
163 resolver_->work_serializer_->Run( in MaybeCallOnDone()
165 OnDone(resolver_.get(), &response_, error); in MaybeCallOnDone()
|
| /third_party/boost/libs/beast/example/http/client/crawl/ |
| D | http_crawl.cpp | 152 tcp::resolver resolver_; member in worker
167 , resolver_(ex_) in worker()
199 resolver_.async_resolve( in do_get_host()
|
| /third_party/skia/third_party/externals/tint/src/resolver/ |
| D | resolver_test_helper.cc | 22 TestHelper::TestHelper() : resolver_(std::make_unique<Resolver>(this)) {} in TestHelper()
|
| D | resolver_test_helper.h | 42 Resolver* r() const { return resolver_.get(); } in r()
114 std::unique_ptr<Resolver> resolver_;
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_resolver.cc | 260 OrphanablePtr<Resolver> resolver_; member in grpc_core::__anon2ee263bb0111::XdsClusterResolverLb::LogicalDNSDiscoveryMechanism
493 resolver_ = ResolverRegistry::CreateResolver( in Start()
499 if (resolver_ == nullptr) { in Start()
503 resolver_->StartLocked(); in Start()
508 parent(), index(), this, resolver_.get()); in Start()
518 parent(), index(), this, resolver_.get()); in Orphan()
520 resolver_.reset(); in Orphan()
|
| /third_party/nghttp2/src/ |
| D | asio_client_session_impl.h | 116 tcp::resolver resolver_; variable
|
| D | asio_client_session_impl.cc | 46 resolver_(io_service), in session_impl()
75 resolver_.async_resolve({host, service}, in start_resolve()
|