| /external/grpc-grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 306 EchoRequest recv_request; in SendRpc() local
319 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
325 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
327 send_response.set_message(recv_request.message()); in SendRpc()
416 EchoRequest recv_request; in TEST_P() local
436 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
441 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_P()
443 send_response.set_message(recv_request.message()); in TEST_P()
457 EchoRequest recv_request; in TEST_P() local
479 service_->RequestEcho(&srv_ctx, &recv_request, resp_writer_ptr, cq_.get(), in TEST_P()
[all …]
|
| D | generic_end2end_test.cc | 110 EchoRequest recv_request; in SendRpc() local
154 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
155 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
157 send_response.set_message(recv_request.message()); in SendRpc()
205 EchoRequest recv_request; in TEST_F() local
237 EXPECT_TRUE(ParseFromByteBuffer(&srv_recv_buffer, &recv_request)); in TEST_F()
238 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
240 send_response.set_message(recv_request.message()); in TEST_F()
263 EchoRequest recv_request; in TEST_F() local
294 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
[all …]
|
| D | hybrid_end2end_test.cc | 64 EchoRequest recv_request; in HandleEcho() local
66 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
69 send_response.set_message(recv_request.message()); in HandleEcho()
89 EchoRequest recv_request; in HandleRawEcho() local
90 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawEcho()
92 send_response.set_message(recv_request.message()); in HandleRawEcho()
101 EchoRequest recv_request; in HandleClientStreaming() local
109 send_response.mutable_message()->append(recv_request.message()); in HandleClientStreaming()
110 srv_stream.Read(&recv_request, tag(i)); in HandleClientStreaming()
120 EchoRequest recv_request; in HandleRawClientStreaming() local
[all …]
|
| D | filter_end2end_test.cc | 165 EchoRequest recv_request; in SendRpc() local
198 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
199 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
201 send_response.set_message(recv_request.message()); in SendRpc()
260 EchoRequest recv_request; in TEST_F() local
291 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
292 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
294 send_response.set_message(recv_request.message()); in TEST_F()
|
| D | nonblocking_test.cc | 117 EchoRequest recv_request; in SendRpc() local
133 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
141 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
143 send_response.set_message(recv_request.message()); in SendRpc()
|
| D | thread_stress_test.cc | 219 send_response.set_message(contexts_[i].recv_request.message()); in ProcessRpcs()
240 &contexts_[i].recv_request, in RefreshContext()
249 EchoRequest recv_request; member
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_unary_ping_pong.h | 56 EchoRequest recv_request; in BM_UnaryPingPong() member
66 service.RequestEcho(&server_env[0]->ctx, &server_env[0]->recv_request, in BM_UnaryPingPong()
69 service.RequestEcho(&server_env[1]->ctx, &server_env[1]->recv_request, in BM_UnaryPingPong()
102 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in BM_UnaryPingPong()
|
| D | fullstack_streaming_ping_pong.h | 58 EchoRequest recv_request; in BM_StreamingPingPong() local
95 response_rw.Read(&recv_request, tag(1)); // Start server recv in BM_StreamingPingPong()
151 EchoRequest recv_request; in BM_StreamingPingPongMsgs() local
186 response_rw.Read(&recv_request, tag(1)); // Start server recv in BM_StreamingPingPongMsgs()
255 EchoRequest recv_request; in BM_StreamingPingPongWithCoalescingApi() local
310 response_rw.Read(&recv_request, tag(3)); // Start server recv in BM_StreamingPingPongWithCoalescingApi()
|
| D | fullstack_streaming_pump.h | 46 EchoRequest recv_request; in BM_PumpStreamClientToServer() local
69 response_rw.Read(&recv_request, tag(0)); in BM_PumpStreamClientToServer()
76 response_rw.Read(&recv_request, tag(0)); in BM_PumpStreamClientToServer()
|
| D | bm_fullstack_trickle.cc | 371 EchoRequest recv_request; in BM_PumpUnbalancedUnary_Trickle() member
381 service.RequestEcho(&server_env[0]->ctx, &server_env[0]->recv_request, in BM_PumpUnbalancedUnary_Trickle()
384 service.RequestEcho(&server_env[1]->ctx, &server_env[1]->recv_request, in BM_PumpUnbalancedUnary_Trickle()
416 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in BM_PumpUnbalancedUnary_Trickle()
|
| /external/grpc-grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 185 EchoRequest recv_request; in UnaryPingPong() member
195 service.RequestEcho(&server_env[0]->ctx, &server_env[0]->recv_request, in UnaryPingPong()
198 service.RequestEcho(&server_env[1]->ctx, &server_env[1]->recv_request, in UnaryPingPong()
228 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in UnaryPingPong()
|