Home
last modified time | relevance | path

Searched refs:stub_ (Results 1 – 25 of 59) sorted by relevance

123

/external/tensorflow/tensorflow/compiler/xla/client/
Dclient.cc37 Client::Client(ServiceInterface* stub) : stub_(stub) {} in Client()
52 Status s = stub_->TransferToClient(&request, &response); in Transfer()
79 Status s = stub_->TransferToServer(&request, &response); in TransferToServer()
93 return absl::make_unique<GlobalData>(stub_, response.data()); in TransferToServer()
108 Status s = stub_->TransferToInfeed(&request, &response); in TransferToInfeed()
133 Status s = stub_->TransferFromOutfeed(&request, &response); in TransferFromOutfeed()
156 Status s = stub_->ResetDevice(&request, &response); in ResetDevice()
195 Status s = stub_->ComputeConstantGraph(&request, &response); in ComputeConstant()
241 Status s = stub_->Compile(&request, &response); in Compile()
263 Status s = stub_->Execute(&request, &response); in Execute()
[all …]
/external/grpc-grpc/test/cpp/end2end/
Dend2end_test.cc172 : stub_(grpc::testing::EchoTestService::NewStub(channel)) {} in Proxy()
178 return stub_->Echo(client_context.get(), *request, response); in Echo()
182 std::unique_ptr< ::grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anona0cada910111::Proxy
322 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
327 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anona0cada910111::End2endTest
388 auto stream = stub_->RequestStream(&context, &response); in TestRequestStreamServerCancel()
462 auto stream = stub_->ResponseStream(&context, request); in TestResponseStreamServerCancel()
538 auto stream = stub_->BidiStream(&context); in TestBidiStreamServerCancel()
606 Status s = stub_->Echo(&context, request, &response); in TEST_P()
673 Status s = stub_->Echo(&context, request, &response); in TEST_P()
[all …]
Dmock_test.cc66 explicit FakeClient(EchoTestService::StubInterface* stub) : stub_(stub) {} in FakeClient()
73 Status s = stub_->Echo(&context, request, &response); in DoEcho()
87 stub_->RequestStream(&context, &response); in DoRequestStream()
111 stub_->ResponseStream(&context, request); in DoResponseStream()
134 stream = stub_->BidiStream(&context); in DoBidiStream()
158 void ResetStub(EchoTestService::StubInterface* stub) { stub_ = stub; } in ResetStub()
161 EchoTestService::StubInterface* stub_; member in grpc::testing::__anon7521e91b0111::FakeClient
249 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
252 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon7521e91b0111::MockTest
261 FakeClient client(stub_.get()); in TEST_F()
[all …]
Dexception_test.cc76 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
80 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::ExceptionTest
93 Status s = stub_->Echo(&context, request, &response); in TEST_F()
105 auto stream = stub_->RequestStream(&context, &response); in TEST_F()
Draw_end2end_test.cc115 stub_.reset(); in TearDown()
135 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
139 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anonef537dfa0111::RawEnd2EndTest
177 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
202 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
231 stub_->AsyncRequestStream(&cli_ctx_, &recv_response_, cq_.get(), tag(1))); in TEST_F()
276 stub_->AsyncResponseStream(&cli_ctx_, send_request_, cq_.get(), tag(1))); in TEST_F()
319 cli_stream(stub_->AsyncBidiStream(&cli_ctx_, cq_.get(), tag(1))); in TEST_F()
Dnonblocking_test.cc94 stub_.reset(); in TearDown()
111 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
128 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
166 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anone80365650211::NonblockingTest
Dserver_early_return_test.cc127 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in SetUp()
152 auto stream = stub_->BidiStream(&context); in DoBidiStream()
190 auto stream = stub_->RequestStream(&context, &response); in DoRequestStream()
208 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anonce9b2c230111::ServerEarlyReturnTest
Dclient_callback_end2end_test.cc59 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
90 stub_->experimental_async()->Echo( in SendRpcs()
151 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon9967e77b0111::ClientCallbackEnd2endTest
219 stub_->experimental_async()->Echo( in TEST_F()
Dstreaming_throughput_test.cc150 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
153 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::End2endTest
169 auto stream = stub_->BidiStream(&context); in TEST_F()
/external/libchrome/mojo/public/cpp/bindings/
Dassociated_binding.h102 stub_.set_sink(std::move(impl)); in AssociatedBinding()
120 BindImpl(request.PassHandle(), &stub_,
138 Interface* impl() { return ImplRefTraits::GetRawPointer(&stub_.sink()); } in impl()
143 stub_.set_sink(std::move(new_impl)); in SwapImplForTesting()
148 typename Interface::template Stub_<ImplRefTraits> stub_;
/external/libchrome/mojo/public/cpp/bindings/lib/
Dbinding_state.h105 stub_.set_sink(std::move(impl)); in BindingState()
115 Interface::PassesAssociatedKinds_, Interface::HasSyncMethods_, &stub_, in Bind()
126 Interface* impl() { return ImplRefTraits::GetRawPointer(&stub_.sink()); } in impl()
129 stub_.set_sink(std::move(new_impl)); in SwapImplForTesting()
134 typename Interface::template Stub_<ImplRefTraits> stub_;
/external/tensorflow/tensorflow/compiler/xla/rpc/
Dgrpc_client_test.cc64 stub_.reset(new GRPCStub(xla_service_.get())); in GRPCClientTestBase()
65 client_.reset(new Client(stub_.get())); in GRPCClientTestBase()
75 std::unique_ptr<GRPCStub> stub_; member in xla::__anon456fbded0111::GRPCClientTestBase
81 ASSERT_NE(stub_, nullptr); in TEST_F()
/external/libchrome/mojo/public/js/
Dbindings.js188 this.stub_ = null;
215 this.stub_ = new this.interfaceType_.stubClass(this.impl_);
218 this.stub_, this.interfaceType_.kVersion);
235 this.stub_ = null;
468 this.stub_ = null;
482 this.stub_ = new this.interfaceType_.stubClass(this.impl_);
484 associatedInterfaceRequest.interfaceEndpointHandle, this.stub_,
502 this.stub_ = null;
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc76 stub_(stub), in ClientRpcContextUnaryImpl()
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_); in RunNextState()
112 auto* clone = new ClientRpcContextUnaryImpl(stub_, req_, next_issue_, in StartNewClone()
120 BenchmarkService::Stub* stub_; member in grpc::testing::ClientRpcContextUnaryImpl
347 stub_(stub), in ClientRpcContextStreamingPingPongImpl()
428 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone()
435 BenchmarkService::Stub* stub_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
478 stream_ = prepare_req_(stub_, &context_, cq); in StartInternal()
532 stub_(stub), in ClientRpcContextStreamingFromClientImpl()
583 stub_, req_, next_issue_, prepare_req_, callback_); in StartNewClone()
[all …]
/external/flatbuffers/grpc/samples/greeter/
Dclient.cpp13 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
26 auto status = stub_->SayHello(&context, request_msg, &response_msg); in SayHello()
50 auto stream = stub_->SayManyHellos(&context, request_msg); in SayManyHellos()
64 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
/external/grpc-grpc/examples/cpp/route_guide/
Droute_guide_client.cc73 : stub_(RouteGuide::NewStub(channel)) { in RouteGuideClient()
99 stub_->ListFeatures(&context, rect)); in ListFeatures()
128 stub_->RecordRoute(&context, &stats)); in RecordRoute()
158 stub_->RouteChat(&context)); in RouteChat()
192 Status status = stub_->GetFeature(&context, point, feature); in GetOneFeature()
214 std::unique_ptr<RouteGuide::Stub> stub_; member in RouteGuideClient
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_client.cc41 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
58 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
71 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
Dgreeter_async_client.cc40 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
68 stub_->PrepareAsyncSayHello(&context, request, &cq)); in SayHello()
102 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
Dgreeter_async_client2.cc41 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
57 stub_->PrepareAsyncSayHello(&call->context, request, &cq_); in SayHello()
114 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
/external/grpc-grpc/test/cpp/ext/filters/census/
Dstats_plugin_end2end_test.cc78 stub_ = EchoTestService::NewStub(::grpc::CreateChannel( in SetUp()
97 std::unique_ptr<EchoTestService::Stub> stub_; member in grpc::testing::__anon43cecb060111::StatsPluginEnd2EndTest
138 ::grpc::Status status = stub_->Echo(&context, request, &response); in TEST_F()
189 ::grpc::Status status = stub_->Echo(&context, request, &response); in TEST_F()
233 ::grpc::Status status = stub_->Echo(&context, request, &response); in TEST_F()
296 ::grpc::Status status = stub_->Echo(&context, request, &response); in TEST_F()
330 ::grpc::Status status = stub_->Echo(&context, request, &response); in TEST_F()
/external/grpc-grpc/doc/
Dunit_testing.md89 explicit FakeClient(EchoTestService::StubInterface* stub) : stub_(stub) {}
96 Status s = stub_->Echo(&context, request, &response);
108 stream = stub_->BidiStream(&context);
132 void ResetStub(EchoTestService::StubInterface* stub) { stub_ = stub; }
135 EchoTestService::StubInterface* stub_;
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_client.h31 : stub_(grpc::VerbsService::NewStub(client_channel)) {} in GrpcVerbsClient()
41 std::unique_ptr<grpc::VerbsService::Stub> stub_;
/external/grpc-grpc/examples/android/helloworld/app/src/main/cpp/
Dgrpc-helloworld.cc76 : stub_(Greeter::NewStub(channel)) {} in GreeterClient()
92 Status status = stub_->SayHello(&context, request, &reply); in SayHello()
102 std::unique_ptr<Greeter::Stub> stub_; member in GreeterClient
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_client.cc34 : stub_(channel), cq_(cq) {} in GrpcEagerClient()
42 &stub_, cq_, "/tensorflow.eager.EagerService/" #method, *request, \
57 ::grpc::GenericStub stub_;
/external/grpc-grpc/test/cpp/util/
Dcli_call_test.cc79 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
83 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::CliCallTest
99 Status s = stub_->Echo(&context, request, &response); in TEST_F()

123