| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | fullstack_unary_ping_pong.h | 57 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_UnaryPingPong() member
58 ServerEnv() : response_writer(&ctx) {} in BM_UnaryPingPong()
67 &server_env[0]->response_writer, fixture->cq(), in BM_UnaryPingPong()
70 &server_env[1]->response_writer, fixture->cq(), in BM_UnaryPingPong()
90 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in BM_UnaryPingPong()
102 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in BM_UnaryPingPong()
|
| D | bm_fullstack_trickle.cc | 370 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_PumpUnbalancedUnary_Trickle() member
371 ServerEnv() : response_writer(&ctx) {} in BM_PumpUnbalancedUnary_Trickle()
380 &server_env[0]->response_writer, fixture->cq(), in BM_PumpUnbalancedUnary_Trickle()
383 &server_env[1]->response_writer, fixture->cq(), in BM_PumpUnbalancedUnary_Trickle()
401 senv->response_writer.Finish(send_response, Status::OK, tag(3)); 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 | 170 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in UnaryPingPong() member
171 ServerEnv() : response_writer(&ctx) {} in UnaryPingPong()
180 &server_env[0]->response_writer, fixture->cq(), in UnaryPingPong()
183 &server_env[1]->response_writer, fixture->cq(), in UnaryPingPong()
200 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in UnaryPingPong()
212 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in UnaryPingPong()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 317 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc() local
323 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
332 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
365 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
377 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
386 response_writer.Finish( in TEST_P()
474 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
487 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
495 response_writer.Finish(send_response, Status::OK, tag(3)); in TEST_P()
515 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
[all …]
|
| D | raw_end2end_test.cc | 173 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx_); in TEST_F() local
178 service->RequestEcho(&srv_ctx_, &recv_request_, &response_writer, cq_.get(), in TEST_F()
184 response_writer.Finish(send_response_, Status::OK, tag(3)); in TEST_F()
198 grpc::GenericServerAsyncResponseWriter response_writer(&srv_ctx_); in TEST_F() local
203 service->RequestEcho(&srv_ctx_, &recv_request_buffer_, &response_writer, in TEST_F()
212 response_writer.Finish(send_response_buffer_, Status::OK, tag(3)); in TEST_F()
|
| D | nonblocking_test.cc | 134 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc() local
143 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
154 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
|
| D | thread_stress_test.cc | 227 contexts_[i].response_writer->Finish(send_response, Status::OK, in ProcessRpcs()
243 contexts_[i].response_writer.reset( in RefreshContext()
248 contexts_[i].response_writer.get(), cq_.get(), in RefreshContext()
255 response_writer; member
|
| D | hybrid_end2end_test.cc | 70 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho() local
73 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
80 response_writer.Finish(send_response, Status::OK, tag(2)); in HandleEcho()
91 GenericServerAsyncResponseWriter response_writer(&srv_ctx); in HandleRawEcho() local
93 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
101 response_writer.Finish(*send_buffer, Status::OK, tag(2)); in HandleRawEcho()
|
| D | server_interceptors_end2end_test.cc | 377 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_F() local
384 service.RequestEcho(&srv_ctx, &recv_request, &response_writer, cq.get(), in TEST_F()
396 response_writer.Finish(send_response, Status::OK, tag(3)); in TEST_F()
|