/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_master_service_impl.h | 131 ::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()
|
D | grpc_call.h | 143 ::grpc::ServerAsyncResponseWriter<ResponseMessage>*, 253 ::grpc::ServerAsyncResponseWriter<ResponseMessage> responder_;
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_service.h | 113 ::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/ |
D | greeter_async_server.cc | 30 using grpc::ServerAsyncResponseWriter; 132 ServerAsyncResponseWriter<HelloReply> responder_;
|
D | README.md | 220 ServerAsyncResponseWriter<HelloReply> responder;
|
/external/grpc-grpc/test/cpp/qps/ |
D | server_async.cc | 55 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/ |
D | server_context.h | 48 class ServerAsyncResponseWriter; variable 251 friend class ::grpc::ServerAsyncResponseWriter;
|
D | async_generic_service.h | 31 typedef ServerAsyncResponseWriter<ByteBuffer> GenericServerAsyncResponseWriter;
|
D | async_unary_call.h | 200 class ServerAsyncResponseWriter final 203 explicit ServerAsyncResponseWriter(ServerContext* ctx) in ServerAsyncResponseWriter() function
|
/external/tensorflow/tensorflow/contrib/verbs/ |
D | grpc_verbs_service_impl.h | 68 ::grpc::ServerAsyncResponseWriter<GetRemoteAddressResponse>* response, in RequestGetRemoteAddress()
|
/external/grpc-grpc/test/cpp/end2end/ |
D | async_end2end_test.cc | 313 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()
|
D | thread_stress_test.cc | 237 new grpc::ServerAsyncResponseWriter<EchoResponse>( in RefreshContext() 247 std::unique_ptr<grpc::ServerAsyncResponseWriter<EchoResponse>>
|
D | nonblocking_test.cc | 124 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
|
D | raw_end2end_test.cc | 173 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx_); in TEST_F()
|
D | hybrid_end2end_test.cc | 63 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho()
|
/external/grpc-grpc/test/cpp/server/ |
D | server_request_call_test.cc | 60 ServerAsyncResponseWriter<testing::EchoResponse> responder(&ctx); in TEST()
|
/external/grpc-grpc/test/cpp/microbenchmarks/ |
D | fullstack_unary_ping_pong.h | 57 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_UnaryPingPong()
|
D | bm_fullstack_trickle.cc | 372 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_PumpUnbalancedUnary_Trickle()
|
/external/grpc-grpc/test/cpp/performance/ |
D | writes_per_rpc_test.cc | 186 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in UnaryPingPong()
|
/external/grpc-grpc/test/cpp/codegen/ |
D | compiler_test_golden | 245 …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/ |
D | monster_test.grpc.fb.h | 168 … context, flatbuffers::grpc::Message<Monster>* request, ::grpc::ServerAsyncResponseWriter< flatbuf… in RequestStore()
|