Home
last modified time | relevance | path

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

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.h133 ::grpc::ServerAsyncResponseWriter<CreateSessionResponse>* response, in RequestCreateSession()
141 ::grpc::ServerAsyncResponseWriter<ExtendSessionResponse>* response, in RequestExtendSession()
149 ::grpc::ServerAsyncResponseWriter<PartialRunSetupResponse>* response, in RequestPartialRunSetup()
157 ::grpc::ServerAsyncResponseWriter<RunStepResponse>* response, in RequestRunStep()
165 ::grpc::ServerAsyncResponseWriter<CloseSessionResponse>* response, in RequestCloseSession()
173 ::grpc::ServerAsyncResponseWriter<ListDevicesResponse>* response, in RequestListDevices()
181 ::grpc::ServerAsyncResponseWriter<ResetResponse>* response, in RequestReset()
189 ::grpc::ServerAsyncResponseWriter<MakeCallableResponse>* response, in RequestMakeCallable()
197 ::grpc::ServerAsyncResponseWriter<RunCallableResponse>* response, in RequestRunCallable()
205 ::grpc::ServerAsyncResponseWriter<ReleaseCallableResponse>* response, in RequestReleaseCallable()
Dgrpc_call.h155 ::grpc::ServerAsyncResponseWriter<ResponseMessage>*,
265 ::grpc::ServerAsyncResponseWriter<ResponseMessage> responder_;
/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/
Dasync_generic_service.h31 typedef ServerAsyncResponseWriter<ByteBuffer> GenericServerAsyncResponseWriter;
Dserver_context.h48 class ServerAsyncResponseWriter; variable
251 friend class ::grpc::ServerAsyncResponseWriter;
Dasync_unary_call.h200 class ServerAsyncResponseWriter final
203 explicit ServerAsyncResponseWriter(ServerContext* ctx) in ServerAsyncResponseWriter() function
/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()