Home
last modified time | relevance | path

Searched refs:ServerAsyncResponseWriter (Results 1 – 21 of 21) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.h131 ::grpc::ServerAsyncResponseWriter<CreateSessionResponse>* response, in RequestCreateSession()
139 ::grpc::ServerAsyncResponseWriter<ExtendSessionResponse>* response, in RequestExtendSession()
147 ::grpc::ServerAsyncResponseWriter<PartialRunSetupResponse>* response, in RequestPartialRunSetup()
155 ::grpc::ServerAsyncResponseWriter<RunStepResponse>* response, in RequestRunStep()
163 ::grpc::ServerAsyncResponseWriter<CloseSessionResponse>* response, in RequestCloseSession()
171 ::grpc::ServerAsyncResponseWriter<ListDevicesResponse>* response, in RequestListDevices()
179 ::grpc::ServerAsyncResponseWriter<ResetResponse>* response, in RequestReset()
187 ::grpc::ServerAsyncResponseWriter<MakeCallableResponse>* response, in RequestMakeCallable()
195 ::grpc::ServerAsyncResponseWriter<RunCallableResponse>* response, in RequestRunCallable()
203 ::grpc::ServerAsyncResponseWriter<ReleaseCallableResponse>* response, in RequestReleaseCallable()
Dgrpc_call.h143 ::grpc::ServerAsyncResponseWriter<ResponseMessage>*,
253 ::grpc::ServerAsyncResponseWriter<ResponseMessage> responder_;
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service.h113 ::grpc::ServerAsyncResponseWriter<CreateContextResponse>* response, in RequestCreateContext()
121 ::grpc::ServerAsyncResponseWriter<EnqueueResponse>* response, in RequestEnqueue()
129 ::grpc::ServerAsyncResponseWriter<WaitQueueDoneResponse>* response, in RequestWaitQueueDone()
137 ::grpc::ServerAsyncResponseWriter<KeepAliveResponse>* response, in RequestKeepAlive()
145 ::grpc::ServerAsyncResponseWriter<CloseContextResponse>* response, in RequestCloseContext()
153 ::grpc::ServerAsyncResponseWriter<RegisterFunctionResponse>* response, in RequestRegisterFunction()
161 ::grpc::ServerAsyncResponseWriter<SendTensorResponse>* response, in RequestSendTensor()
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc30 using grpc::ServerAsyncResponseWriter;
132 ServerAsyncResponseWriter<HelloReply> responder_;
DREADME.md220 ServerAsyncResponseWriter<HelloReply> responder;
/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc55 ServerAsyncResponseWriter<ResponseType>*, in AsyncQpsServerTest()
253 grpc::ServerAsyncResponseWriter<ResponseType>*, in ServerRpcContextUnaryImpl()
271 grpc::ServerAsyncResponseWriter<ResponseType>(srv_ctx_.get()); in Reset()
299 grpc::ServerAsyncResponseWriter<ResponseType>*, void*)>
302 grpc::ServerAsyncResponseWriter<ResponseType> response_writer_;
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dserver_context.h48 class ServerAsyncResponseWriter; variable
251 friend class ::grpc::ServerAsyncResponseWriter;
Dasync_generic_service.h31 typedef ServerAsyncResponseWriter<ByteBuffer> GenericServerAsyncResponseWriter;
Dasync_unary_call.h200 class ServerAsyncResponseWriter final
203 explicit ServerAsyncResponseWriter(ServerContext* ctx) in ServerAsyncResponseWriter() function
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service_impl.h68 ::grpc::ServerAsyncResponseWriter<GetRemoteAddressResponse>* response, in RequestGetRemoteAddress()
/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc313 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
423 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
464 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
876 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
922 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
967 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
1012 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
1089 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
1122 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
Dthread_stress_test.cc237 new grpc::ServerAsyncResponseWriter<EchoResponse>( in RefreshContext()
247 std::unique_ptr<grpc::ServerAsyncResponseWriter<EchoResponse>>
Dnonblocking_test.cc124 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
Draw_end2end_test.cc173 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx_); in TEST_F()
Dhybrid_end2end_test.cc63 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho()
/external/grpc-grpc/test/cpp/server/
Dserver_request_call_test.cc60 ServerAsyncResponseWriter<testing::EchoResponse> responder(&ctx); in TEST()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_unary_ping_pong.h57 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_UnaryPingPong()
Dbm_fullstack_trickle.cc372 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_PumpUnbalancedUnary_Trickle()
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc186 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in UnaryPingPong()
/external/grpc-grpc/test/cpp/codegen/
Dcompiler_test_golden245 …verContext* context, ::grpc::testing::Request* request, ::grpc::ServerAsyncResponseWriter< ::grpc:…
394 …c::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc:…
588 …verContext* context, ::grpc::testing::Request* request, ::grpc::ServerAsyncResponseWriter< ::grpc:…
626 …c::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc:…
/external/flatbuffers/tests/
Dmonster_test.grpc.fb.h168 … context, flatbuffers::grpc::Message<Monster>* request, ::grpc::ServerAsyncResponseWriter< flatbuf… in RequestStore()