| /third_party/grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 310 EchoRequest recv_request; in SendRpc() local
323 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
329 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
331 send_response.set_message(recv_request.message()); in SendRpc()
358 EchoRequest recv_request; in TEST_P() local
377 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
383 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_P()
385 send_response.set_message(recv_request.message()); in TEST_P()
389 static_cast<StatusCode>(recv_request.param().expected_error().code()), in TEST_P()
390 recv_request.param().expected_error().error_message()), in TEST_P()
[all …]
|
| D | generic_end2end_test.cc | 117 EchoRequest recv_request; in SendRpc() local
169 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
170 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
172 send_response.set_message(recv_request.message()); in SendRpc()
271 EchoRequest recv_request; in TEST_F() local
304 EXPECT_TRUE(ParseFromByteBuffer(&srv_recv_buffer, &recv_request)); in TEST_F()
305 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
307 send_response.set_message(recv_request.message()); in TEST_F()
330 EchoRequest recv_request; in TEST_F() local
361 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
[all …]
|
| D | hybrid_end2end_test.cc | 71 EchoRequest recv_request; in HandleEcho() local
73 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
76 send_response.set_message(recv_request.message()); in HandleEcho()
96 EchoRequest recv_request; in HandleRawEcho() local
97 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawEcho()
99 send_response.set_message(recv_request.message()); in HandleRawEcho()
108 EchoRequest recv_request; in HandleClientStreaming() local
116 send_response.mutable_message()->append(recv_request.message()); in HandleClientStreaming()
117 srv_stream.Read(&recv_request, tag(i)); in HandleClientStreaming()
127 EchoRequest recv_request; in HandleRawClientStreaming() local
[all …]
|
| D | filter_end2end_test.cc | 176 EchoRequest recv_request; in SendRpc() local
209 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
210 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
212 send_response.set_message(recv_request.message()); in SendRpc()
271 EchoRequest recv_request; in TEST_F() local
302 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
303 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
305 send_response.set_message(recv_request.message()); in TEST_F()
|
| D | server_interceptors_end2end_test.cc | 370 EchoRequest recv_request; in TEST_F() local
384 service.RequestEcho(&srv_ctx, &recv_request, &response_writer, cq.get(), in TEST_F()
390 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
395 send_response.set_message(recv_request.message()); in TEST_F()
443 EchoRequest recv_request; in TEST_F() local
465 srv_stream.Read(&recv_request, tag(4)); in TEST_F()
467 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
469 send_response.set_message(recv_request.message()); in TEST_F()
476 srv_stream.Read(&recv_request, tag(8)); in TEST_F()
526 EchoRequest recv_request; in TEST_F() local
[all …]
|
| D | nonblocking_test.cc | 127 EchoRequest recv_request; in SendRpc() local
143 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
151 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
153 send_response.set_message(recv_request.message()); in SendRpc()
|
| D | thread_stress_test.cc | 226 send_response.set_message(contexts_[i].recv_request.message()); in ProcessRpcs()
247 &contexts_[i].recv_request, in RefreshContext()
256 EchoRequest recv_request; member
|
| /third_party/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 | 369 EchoRequest recv_request; in BM_PumpUnbalancedUnary_Trickle() member
379 service.RequestEcho(&server_env[0]->ctx, &server_env[0]->recv_request, in BM_PumpUnbalancedUnary_Trickle()
382 service.RequestEcho(&server_env[1]->ctx, &server_env[1]->recv_request, in BM_PumpUnbalancedUnary_Trickle()
414 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in BM_PumpUnbalancedUnary_Trickle()
|
| /third_party/grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 169 EchoRequest recv_request; in UnaryPingPong() member
179 service.RequestEcho(&server_env[0]->ctx, &server_env[0]->recv_request, in UnaryPingPong()
182 service.RequestEcho(&server_env[1]->ctx, &server_env[1]->recv_request, in UnaryPingPong()
212 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in UnaryPingPong()
|