| /external/grpc-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 | 372 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_PumpUnbalancedUnary_Trickle() member
373 ServerEnv() : response_writer(&ctx) {} in BM_PumpUnbalancedUnary_Trickle()
382 &server_env[0]->response_writer, fixture->cq(), in BM_PumpUnbalancedUnary_Trickle()
385 &server_env[1]->response_writer, fixture->cq(), in BM_PumpUnbalancedUnary_Trickle()
403 senv->response_writer.Finish(send_response, Status::OK, tag(3)); 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 | 186 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in UnaryPingPong() member
187 ServerEnv() : response_writer(&ctx) {} in UnaryPingPong()
196 &server_env[0]->response_writer, fixture->cq(), in UnaryPingPong()
199 &server_env[1]->response_writer, fixture->cq(), in UnaryPingPong()
216 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in UnaryPingPong()
228 service.RequestEcho(&senv->ctx, &senv->recv_request, &senv->response_writer, in UnaryPingPong()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 313 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc() local
319 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
328 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
423 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
436 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
444 response_writer.Finish(send_response, Status::OK, tag(3)); in TEST_P()
464 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
477 auto resp_writer_ptr = &response_writer; in TEST_P()
876 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P() local
890 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
[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 | 124 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc() local
133 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
144 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
|
| D | thread_stress_test.cc | 220 contexts_[i].response_writer->Finish(send_response, Status::OK, in ProcessRpcs()
236 contexts_[i].response_writer.reset( in RefreshContext()
241 contexts_[i].response_writer.get(), cq_.get(), in RefreshContext()
248 response_writer; member
|
| D | hybrid_end2end_test.cc | 63 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho() local
66 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
73 response_writer.Finish(send_response, Status::OK, tag(2)); in HandleEcho()
84 GenericServerAsyncResponseWriter response_writer(&srv_ctx); in HandleRawEcho() local
86 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
94 response_writer.Finish(*send_buffer, Status::OK, tag(2)); in HandleRawEcho()
|