Home
last modified time | relevance | path

Searched refs:resolver_ (Results 1 – 25 of 52) sorted by relevance

123

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc175 : resolver_(std::move(resolver)), in FakeResolverResponseSetter()
184 RefCountedPtr<FakeResolver> resolver_; member in grpc_core::FakeResolverResponseSetter
192 if (!resolver_->shutdown_) { in SetReresolutionResponseLocked()
193 resolver_->reresolution_result_ = std::move(result_); in SetReresolutionResponseLocked()
194 resolver_->has_reresolution_result_ = has_result_; in SetReresolutionResponseLocked()
201 if (!resolver_->shutdown_) { in SetResponseLocked()
202 resolver_->next_result_ = std::move(result_); in SetResponseLocked()
203 resolver_->has_next_result_ = true; in SetResponseLocked()
204 resolver_->MaybeSendResultLocked(); in SetResponseLocked()
211 if (!resolver_->shutdown_) { in SetFailureLocked()
[all …]
Dfake_resolver.h85 RefCountedPtr<FakeResolver> resolver_; variable
/external/google-breakpad/src/processor/
Dstack_frame_symbolizer.cc54 resolver_(resolver) { } in StackFrameSymbolizer()
74 if (!resolver_) return kError; // no resolver. in FillSourceLineInfo()
82 if (resolver_->HasModule(frame->module)) { in FillSourceLineInfo()
83 resolver_->FillSourceLineInfo(frame); in FillSourceLineInfo()
84 return resolver_->IsModuleCorrupt(frame->module) ? in FillSourceLineInfo()
102 bool load_success = resolver_->LoadModuleUsingMemoryBuffer( in FillSourceLineInfo()
106 if (resolver_->ShouldDeleteMemoryBufferAfterLoadModule()) { in FillSourceLineInfo()
111 resolver_->FillSourceLineInfo(frame); in FillSourceLineInfo()
112 return resolver_->IsModuleCorrupt(frame->module) ? in FillSourceLineInfo()
137 return resolver_ ? resolver_->FindWindowsFrameInfo(frame) : NULL; in FindWindowsFrameInfo()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc85 RefCountedPtr<XdsResolver> resolver_; member in grpc_core::__anonead745500111::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::__anonead745500111::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 …]
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc88 if (response_generator != nullptr) response_generator->resolver_ = this; in FakeResolver()
149 FakeResolver* resolver = closure_arg->generator->resolver_; in SetResponseLocked()
158 GPR_ASSERT(resolver_ != nullptr); in SetResponse()
165 grpc_combiner_scheduler(resolver_->combiner())), in SetResponse()
172 FakeResolver* resolver = closure_arg->generator->resolver_; in SetReresolutionResponseLocked()
180 GPR_ASSERT(resolver_ != nullptr); in SetReresolutionResponse()
188 grpc_combiner_scheduler(resolver_->combiner())), in SetReresolutionResponse()
195 FakeResolver* resolver = closure_arg->generator->resolver_; in SetFailureLocked()
202 GPR_ASSERT(resolver_ != nullptr); in SetFailure()
208 grpc_combiner_scheduler(resolver_->combiner())), in SetFailure()
Dfake_resolver.h78 FakeResolver* resolver_ = nullptr; // Do not own. variable
/external/protobuf/src/google/protobuf/util/
Dtype_resolver_util_test.cc67 resolver_.reset(NewTypeResolverForDescriptorPool( in DescriptorPoolTypeResolverTest()
171 std::unique_ptr<TypeResolver> resolver_; member in google::protobuf::util::__anon294036ab0111::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 …]
/external/webrtc/examples/peerconnection/client/
Dpeer_connection_client.cc46 : callback_(NULL), resolver_(NULL), state_(NOT_CONNECTED), my_id_(-1) {} in PeerConnectionClient()
110 resolver_ = new rtc::AsyncResolver(); in Connect()
111 resolver_->SignalDone.connect(this, &PeerConnectionClient::OnResolveResult); in Connect()
112 resolver_->Start(server_address_); in Connect()
120 if (resolver_->GetError() != 0) { in OnResolveResult()
122 resolver_->Destroy(false); in OnResolveResult()
123 resolver_ = NULL; in OnResolveResult()
126 server_address_ = resolver_->address(); in OnResolveResult()
210 if (resolver_ != NULL) { in Close()
211 resolver_->Destroy(false); in Close()
[all …]
/external/google-breakpad/src/google_breakpad/processor/
Dstack_frame_symbolizer.h95 virtual bool HasImplementation() { return resolver_ && supplier_; } in HasImplementation()
97 SourceLineResolverInterface* resolver() { return resolver_; } in resolver()
102 SourceLineResolverInterface* resolver_; variable
/external/tflite-support/tensorflow_lite_support/cc/task/core/
Dtflite_engine.cc70 resolver_(std::move(resolver)), in TfLiteEngine()
71 verifier_(resolver_.get()) {} in TfLiteEngine()
74 : model_(), resolver_(std::move(resolver)), verifier_(resolver_.get()) {} in TfLiteEngine()
249 FindCustomOp, resolver_.get()); in InitInterpreter()
270 if (tflite::InterpreterBuilder(*model_, *resolver_)( in InitInterpreter()
/external/tensorflow/tensorflow/core/profiler/rpc/client/
Dremote_profiler_session_manager.cc55 resolver_ = resolver; in RemoteProfilerSessionManager()
57 resolver_ = [](absl::string_view addr) { return std::string(addr); }; in RemoteProfilerSessionManager()
87 std::string resolved_service_address = resolver_(service_address); in Init()
Dremote_profiler_session_manager.h78 AddressResolver resolver_ TF_GUARDED_BY(mutex_);
/external/webrtc/p2p/base/
Dturn_port.cc232 resolver_(NULL), in TurnPort()
274 resolver_(NULL), in TurnPort()
299 if (resolver_) { in ~TurnPort()
300 resolver_->Destroy(false); in ~TurnPort()
795 if (resolver_) in ResolveTurnAddress()
800 resolver_ = socket_factory()->CreateAsyncResolver(); in ResolveTurnAddress()
801 resolver_->SignalDone.connect(this, &TurnPort::OnResolveResult); in ResolveTurnAddress()
802 resolver_->Start(address); in ResolveTurnAddress()
806 RTC_DCHECK(resolver == resolver_); in OnResolveResult()
811 if (resolver_->GetError() != 0 && (server_address_.proto == PROTO_TCP || in OnResolveResult()
[all …]
Dstun_port.cc434 if (!resolver_) { in ResolveStunAddress()
435 resolver_.reset(new AddressResolver(socket_factory())); in ResolveStunAddress()
436 resolver_->SignalDone.connect(this, &UDPPort::OnResolveResult); in ResolveStunAddress()
441 resolver_->Resolve(stun_addr); in ResolveStunAddress()
445 RTC_DCHECK(resolver_.get() != nullptr); in OnResolveResult()
448 if (error != 0 || !resolver_->GetResolvedAddress( in OnResolveResult()
/external/tensorflow/tensorflow/lite/delegates/hexagon/builders/tests/
Dbatch_seq_config_test.cc99 resolver_.reset(new ops::builtin::BuiltinOpResolver()); in Init()
100 InterpreterBuilder(*model_, *resolver_)(&interpreter_); in Init()
166 std::unique_ptr<tflite::OpResolver> resolver_; member in tflite::TestModel
/external/webrtc/rtc_base/
Dphysical_socket_server.cc121 resolver_(nullptr) { in PhysicalSocket()
236 resolver_ = new AsyncResolver(); in Connect()
237 resolver_->SignalDone.connect(this, &PhysicalSocket::OnResolveResult); in Connect()
238 resolver_->Start(addr); in Connect()
473 if (resolver_) { in Close()
474 resolver_->Destroy(false); in Close()
475 resolver_ = nullptr; in Close()
500 if (resolver != resolver_) { in OnResolveResult()
504 int error = resolver_->GetError(); in OnResolveResult()
506 error = DoConnect(resolver_->address()); in OnResolveResult()
/external/tensorflow/tensorflow/lite/tools/evaluation/stages/
Dtflite_inference_stage.cc112 resolver_.reset(new ops::builtin::BuiltinOpResolver); in Init()
113 InterpreterBuilder(*model_, *resolver_)(&interpreter_); in Init()
Dtflite_inference_stage.h81 std::unique_ptr<ops::builtin::BuiltinOpResolver> resolver_; variable
/external/tensorflow/tensorflow/lite/testing/nnapi_tflite_zip_tests/
Dtflite_driver.cc201 resolver_.reset(new ops::builtin::BuiltinRefOpResolver); in TfLiteDriver()
203 resolver_.reset(new ops::builtin::BuiltinOpResolver); in TfLiteDriver()
238 InterpreterBuilder(*model_, *resolver_)(&interpreter_); in LoadModel()
Dtflite_driver.h73 std::unique_ptr<OpResolver> resolver_; variable
/external/tensorflow/tensorflow/lite/kernels/
Dtest_util.cc195 if (!resolver_) { in BuildInterpreter()
203 resolver_ = std::unique_ptr<OpResolver>(resolver); in BuildInterpreter()
205 CHECK(InterpreterBuilder(GetModel(buffer_pointer), *resolver_)( in BuildInterpreter()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_resolver.cc253 OrphanablePtr<Resolver> resolver_; member in grpc_core::__anon2c3b4bdc0111::XdsClusterResolverLb::LogicalDNSDiscoveryMechanism
472 resolver_ = ResolverRegistry::CreateResolver( in Start()
477 if (resolver_ == nullptr) { in Start()
481 resolver_->StartLocked(); in Start()
486 parent(), index(), this, resolver_.get()); in Start()
496 parent(), index(), this, resolver_.get()); in Orphan()
498 resolver_.reset(); in Orphan()
/external/libtextclassifier/native/utils/
Dtflite-model-executor.cc332 : model_(std::move(model)), resolver_(BuildOpResolver()) {} in TfLiteModelExecutor()
336 : model_(std::move(model)), resolver_(std::move(resolver)) {} in TfLiteModelExecutor()
341 tflite::InterpreterBuilder(*model_, *resolver_)(&interpreter); in CreateInterpreter()
/external/tensorflow/tensorflow/lite/python/optimize/
Dcalibration_wrapper.h99 std::unique_ptr<tflite::ops::builtin::BuiltinOpResolver> resolver_; variable
/external/tensorflow/tensorflow/lite/testing/
Dtflite_driver.h97 std::unique_ptr<OpResolver> resolver_; variable

123