Home
last modified time | relevance | path

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

/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dasync_unary_call.h35 class ClientAsyncResponseReader; variable
91 static ClientAsyncResponseReader<R>* Create( in Create()
96 ClientAsyncResponseReader<R>* result = in Create()
98 call.call(), sizeof(ClientAsyncResponseReader<R>))) in Create()
99 ClientAsyncResponseReader<R>(call, context); in Create()
201 static ClientAsyncResponseReader<R>* Create( in Create()
219 class ClientAsyncResponseReader final
224 GPR_CODEGEN_ASSERT(size == sizeof(ClientAsyncResponseReader)); in delete()
271 ClientAsyncResponseReader(::grpc::internal::Call call, in ClientAsyncResponseReader() function
400 class default_delete<::grpc::ClientAsyncResponseReader<R>> {
Dclient_context.h91 class ClientAsyncResponseReader; variable
442 friend class ::grpc::ClientAsyncResponseReader;
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dasync_unary_call.h35 class ClientAsyncResponseReader; variable
91 static ClientAsyncResponseReader<R>* Create( in Create()
96 ClientAsyncResponseReader<R>* result = in Create()
98 call.call(), sizeof(ClientAsyncResponseReader<R>))) in Create()
99 ClientAsyncResponseReader<R>(call, context); in Create()
201 static ClientAsyncResponseReader<R>* Create( in Create()
219 class ClientAsyncResponseReader final
224 GPR_CODEGEN_ASSERT(size == sizeof(ClientAsyncResponseReader)); in delete()
271 ClientAsyncResponseReader(::grpc::internal::Call call, in ClientAsyncResponseReader() function
400 class default_delete<::grpc::ClientAsyncResponseReader<R>> {
Dclient_context.h91 class ClientAsyncResponseReader; variable
442 friend class ::grpc::ClientAsyncResponseReader;
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dasync_unary_call.h83 static ClientAsyncResponseReader<R>* Create( in Create()
89 call.call(), sizeof(ClientAsyncResponseReader<R>))) in Create()
90 ClientAsyncResponseReader<R>(call, context, request, start); in Create()
98 class ClientAsyncResponseReader final
103 assert(size == sizeof(ClientAsyncResponseReader)); in delete()
166 ClientAsyncResponseReader(::grpc::internal::Call call, ClientContext* context, in ClientAsyncResponseReader() function
305 class default_delete<grpc::ClientAsyncResponseReader<R>> {
Dclient_context.h88 class ClientAsyncResponseReader; variable
391 friend class ::grpc::ClientAsyncResponseReader;
/external/tensorflow/tensorflow/core/tpu/kernels/
Dtpu_compilation_cache_grpc.h109 std::unique_ptr<::grpc::ClientAsyncResponseReader<ResponseType>>
113 return std::unique_ptr<::grpc::ClientAsyncResponseReader<ResponseType>>( in AsyncGetTpuProgram()
116 std::unique_ptr<::grpc::ClientAsyncResponseReader<ResponseType>>
120 return std::unique_ptr<::grpc::ClientAsyncResponseReader<ResponseType>>( in PrepareAsyncGetTpuProgram()
126 ::grpc::ClientAsyncResponseReader<ResponseType>* AsyncGetTpuProgramRaw(
129 ::grpc::ClientAsyncResponseReader<ResponseType>*
Dtpu_compilation_cache_grpc.cc65 ::grpc::ClientAsyncResponseReader<
75 ::grpc::ClientAsyncResponseReader<
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_client.cc29 using grpc::ClientAsyncResponseReader;
67 std::unique_ptr<ClientAsyncResponseReader<HelloReply> > rpc( in SayHello()
Dgreeter_async_client2.cc30 using grpc::ClientAsyncResponseReader;
109 std::unique_ptr<ClientAsyncResponseReader<HelloReply>> response_reader;
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/
Dgeneric_stub.h38 typedef ClientAsyncResponseReader<ByteBuffer> GenericClientAsyncResponseReader;
63 std::unique_ptr<ClientAsyncResponseReader<ResponseType>> PrepareUnaryCall( in PrepareUnaryCall()
66 return std::unique_ptr<ClientAsyncResponseReader<ResponseType>>( in PrepareUnaryCall()
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/
Dgeneric_stub.h38 typedef ClientAsyncResponseReader<ByteBuffer> GenericClientAsyncResponseReader;
63 std::unique_ptr<ClientAsyncResponseReader<ResponseType>> PrepareUnaryCall( in PrepareUnaryCall()
66 return std::unique_ptr<ClientAsyncResponseReader<ResponseType>>( in PrepareUnaryCall()
/external/grpc-grpc/test/cpp/codegen/
Dcompiler_test_golden143 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> AsyncMethodA1(::gr…
144 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(AsyncMethod…
146 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> PrepareAsyncMethod…
147 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(PrepareAsyn…
191 …::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* AsyncMethodA1Raw(::grpc::ClientCont…
192 …::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>* PrepareAsyncMethodA1Raw(::grpc::Cli…
537 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> AsyncMethodB1(::gr…
538 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(AsyncMethod…
540 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>> PrepareAsyncMethod…
541 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Response>>(PrepareAsyn…
[all …]
/external/grpc-grpc/include/grpcpp/generic/
Dgeneric_stub.h34 typedef ClientAsyncResponseReader<ByteBuffer> GenericClientAsyncResponseReader;
/external/tensorflow/tensorflow/core/profiler/rpc/client/
Dprofiler_client.h85 std::unique_ptr<::grpc::ClientAsyncResponseReader<ProfileResponse>> rpc_;
/external/flatbuffers/tests/
Dmonster_test.grpc.fb.h89 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>> AsyncStore(… in AsyncStore()
90 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>>(Asyn… in AsyncStore()
92 …std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>> PrepareAsyn… in PrepareAsyncStore()
93 …return std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>>(Prep… in PrepareAsyncStore()
125 …::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* AsyncStoreRaw(::grpc::Client…
126 …::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* PrepareAsyncStoreRaw(::grpc:…
Dmonster_test.grpc.fb.cc42 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncSt… in AsyncStoreRaw()
46 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::Prepare… in PrepareAsyncStoreRaw()
/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc316 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc()
426 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
467 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
886 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
928 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
973 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
1033 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
1092 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
1125 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
1161 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
Draw_end2end_test.cc176 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F()
201 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F()
Dnonblocking_test.cc127 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc()
Dthread_stress_test.cc356 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader;
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_unary_ping_pong.h79 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_UnaryPingPong()
Dbm_fullstack_trickle.cc393 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_PumpUnbalancedUnary_Trickle()
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc70 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>( in ClientRpcContextUnaryImpl()
129 std::function<std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>(
135 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>
321 static std::unique_ptr<grpc::ClientAsyncResponseReader<SimpleResponse>>
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc206 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in UnaryPingPong()