| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_client2.cc | 60 call->response_reader = in SayHello()
64 call->response_reader->StartCall(); in SayHello()
69 call->response_reader->Finish(&call->reply, &call->status, (void*)call); in SayHello()
113 std::unique_ptr<ClientAsyncResponseReader<HelloReply>> response_reader; member
|
| /third_party/grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 137 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc() local
140 response_reader->StartCall(); in SendRpc()
141 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
|
| D | async_end2end_test.cc | 320 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc() local
326 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
373 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
380 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
477 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
489 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
518 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
533 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
937 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
939 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
[all …]
|
| D | cfstream_test.cc | 189 call->response_reader = in SendAsyncRpc()
192 call->response_reader->StartCall(); in SendAsyncRpc()
193 call->response_reader->Finish(&call->reply, &call->status, (void*)call); in SendAsyncRpc()
241 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader; member
|
| D | raw_end2end_test.cc | 176 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F() local
180 response_reader->Finish(&recv_response_, &recv_status_, tag(4)); in TEST_F()
201 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F() local
205 response_reader->Finish(&recv_response_, &recv_status_, tag(4)); in TEST_F()
|
| D | thread_stress_test.cc | 363 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader; member
371 call->response_reader = in AsyncSendRpc()
373 call->response_reader->Finish(&call->response, &call->status, in AsyncSendRpc()
|
| D | interceptors_util.cc | 109 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in MakeAsyncCQCall() local
111 response_reader->Finish(&recv_response, &recv_status, tag(1)); in MakeAsyncCQCall()
|
| D | server_interceptors_end2end_test.cc | 381 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F() local
387 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_F()
633 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F() local
636 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_F()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | fullstack_unary_ping_pong.h | 79 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_UnaryPingPong()
81 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_UnaryPingPong()
|
| D | bm_fullstack_trickle.cc | 391 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_PumpUnbalancedUnary_Trickle() local
395 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_PumpUnbalancedUnary_Trickle()
|
| /third_party/grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 190 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in UnaryPingPong() local
194 response_reader->Finish(&recv_response, &recv_status, tag(4)); in UnaryPingPong()
|