Home
last modified time | relevance | path

Searched refs:stub_ (Results 1 – 25 of 70) 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/rust/crates/grpcio-sys/grpc/src/core/lib/gprpp/
Dmpscq.h41 MultiProducerSingleConsumerQueue() : head_{&stub_}, tail_(&stub_) {} in MultiProducerSingleConsumerQueue()
43 GPR_ASSERT(head_.Load(MemoryOrder::RELAXED) == &stub_); in ~MultiProducerSingleConsumerQueue()
44 GPR_ASSERT(tail_ == &stub_); in ~MultiProducerSingleConsumerQueue()
67 Node stub_; variable
Dmpscq.cc33 return prev == &stub_; in Push()
46 if (tail == &stub_) { in PopAndCheckEnd()
67 Push(&stub_); in PopAndCheckEnd()
/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::__anon60fb6f6f0111::Proxy
322 stub_ = grpc::testing::EchoTestService::NewStub(channel_); in ResetStub()
327 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anon60fb6f6f0111::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::__anonecd97ab90111::FakeClient
249 stub_ = grpc::testing::EchoTestService::NewStub(channel); in ResetStub()
252 std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_; member in grpc::testing::__anonecd97ab90111::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::__anoncd5f51d80111::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::__anonc60f39430211::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::__anon1cb3fe010111::ServerEarlyReturnTest
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/tensorflow/tensorflow/core/data/service/
Ddata_service.cc73 grpc::Status status = stub_->WorkerHeartbeat(&client_ctx, req, &resp); in WorkerHeartbeat()
97 grpc::Status status = stub_->WorkerUpdate(&client_ctx, req, &resp); in WorkerUpdate()
111 grpc::Status status = stub_->GetDatasetDef(&client_ctx, req, &resp); in GetDatasetDef()
128 grpc::Status status = stub_->GetSplit(&client_ctx, req, &resp); in GetSplit()
148 grpc::Status status = stub_->GetOrRegisterDataset(&client_ctx, req, &resp); in RegisterDataset()
172 grpc::Status status = stub_->GetOrCreateJob(&client_ctx, req, &resp); in GetOrCreateJob()
189 grpc::Status status = stub_->ReleaseJobClient(&client_ctx, req, &resp); in ReleaseJobClient()
202 grpc::Status s = stub_->ClientHeartbeat(&ctx, req, &resp); in ClientHeartbeat()
215 grpc::Status s = stub_->GetWorkers(&ctx, req, &resp); in GetWorkers()
228 if (stub_) { in EnsureInitialized()
[all …]
/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.cc70 stub_.reset(new GRPCStub(xla_service_.get())); in GRPCClientTestBase()
71 client_.reset(new Client(stub_.get())); in GRPCClientTestBase()
81 std::unique_ptr<GRPCStub> stub_; member in xla::__anonb53a4ecb0111::GRPCClientTestBase
87 ASSERT_NE(stub_, nullptr); in TEST_F()
/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/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/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/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/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dclient.cc32 : stub_(grpc::DistributedRuntimeService::NewStub(std::move(channel))), in DistributedRuntimeClient()
95 status = stub_->Connect(&ctx, request, &response); in Connect()
153 ::grpc::Status status = stub_->EnumerateDevices(&ctx, request, &response); in EnumerateDevices()
179 ::grpc::Status status = stub_->Shutdown(&ctx, request, &response); in Shutdown()
212 ::grpc::Status status = stub_->KeyValueGet(&ctx, request, &response); in BlockingKeyValueGet()
237 ::grpc::Status status = stub_->KeyValueSet(&ctx, request, &response); in KeyValueSet()
258 ::grpc::Status status = stub_->Heartbeat(&ctx, request, &response); in HeartbeatLoop()
/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/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_client.cc111 : stub_(channel), thread_(thread), target_(target) { in GrpcEagerClient()
129 &stub_, cq_, "/tensorflow.eager.EagerService/" #method, *request, \
148 &stub_, cq_, "/tensorflow.eager.EagerService/" #method, *request, \
163 &stub_, cq_, "/tensorflow.eager.EagerService/CloseContext", *request, in CloseContextAsync()
195 &stub_, cq_, in StreamingEnqueueAsync()
215 ::grpc::GenericStub stub_;
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h121 explicit experimental_type(TemplatedGenericStub* stub) : stub_(stub) {} in experimental_type()
128 stub_->UnaryCallInternal(context, method, request, response, in UnaryCall()
139 stub_->PrepareUnaryCallInternal(context, method, request, response, in PrepareUnaryCall()
149 stub_->PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
153 TemplatedGenericStub* stub_;
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h121 explicit experimental_type(TemplatedGenericStub* stub) : stub_(stub) {} in experimental_type()
128 stub_->UnaryCallInternal(context, method, request, response, in UnaryCall()
139 stub_->PrepareUnaryCallInternal(context, method, request, response, in PrepareUnaryCall()
149 stub_->PrepareBidiStreamingCallInternal(context, method, reactor); in PrepareBidiStreamingCall()
153 TemplatedGenericStub* stub_;

123