Searched refs:response_reader (Results 1 – 9 of 9) sorted by relevance
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_async_client2.cc | 56 call->response_reader = in SayHello()
60 call->response_reader->StartCall(); in SayHello()
65 call->response_reader->Finish(&call->reply, &call->status, (void*)call); in SayHello()
109 std::unique_ptr<ClientAsyncResponseReader<HelloReply>> response_reader; member
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | nonblocking_test.cc | 127 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc() local
130 response_reader->StartCall(); in SendRpc()
131 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
|
| D | async_end2end_test.cc | 316 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc() local
322 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
426 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
438 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
467 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
482 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
886 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
888 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
928 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P() local
930 response_reader->ReadInitialMetadata(tag(4)); in TEST_P()
[all …]
|
| 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 | 356 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader; member
364 call->response_reader = in AsyncSendRpc()
366 call->response_reader->Finish(&call->response, &call->status, in AsyncSendRpc()
|
| /external/grpc-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 | 393 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_PumpUnbalancedUnary_Trickle() local
397 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_PumpUnbalancedUnary_Trickle()
|
| /external/libbrillo/brillo/dbus/ |
| D | exported_property_set_test.cc | 231 dbus::MessageReader response_reader(response.get()); in TEST_F() local
233 ASSERT_TRUE(response_reader.PopArray(&dict_reader)); in TEST_F()
238 ASSERT_FALSE(response_reader.HasMoreData()); in TEST_F()
257 dbus::MessageReader response_reader(response.get()); in TEST_F() local
260 ASSERT_TRUE(response_reader.PopArray(&dict_reader)); in TEST_F()
284 ASSERT_FALSE(response_reader.HasMoreData()); in TEST_F()
|
| /external/grpc-grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 206 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in UnaryPingPong() local
210 response_reader->Finish(&recv_response, &recv_status, tag(4)); in UnaryPingPong()
|