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 | 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 | 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 | 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_unittest.cc | 232 dbus::MessageReader response_reader(response.get()); in TEST_F() local 234 ASSERT_TRUE(response_reader.PopArray(&dict_reader)); in TEST_F() 239 ASSERT_FALSE(response_reader.HasMoreData()); in TEST_F() 258 dbus::MessageReader response_reader(response.get()); in TEST_F() local 261 ASSERT_TRUE(response_reader.PopArray(&dict_reader)); in TEST_F() 285 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()
|