Home
last modified time | relevance | path

Searched refs:response_reader (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_client2.cc56 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/
Dasync_end2end_test.cc316 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 …]
Dnonblocking_test.cc127 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()
Draw_end2end_test.cc176 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()
Dthread_stress_test.cc356 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/
Dfullstack_unary_ping_pong.h79 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_UnaryPingPong()
81 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_UnaryPingPong()
Dbm_fullstack_trickle.cc393 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/
Dexported_property_set_unittest.cc232 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/
Dwrites_per_rpc_test.cc206 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in UnaryPingPong() local
210 response_reader->Finish(&recv_response, &recv_status, tag(4)); in UnaryPingPong()