Home
last modified time | relevance | path

Searched refs:response_rw (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h71 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPong()
72 service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(), in BM_StreamingPingPong()
95 response_rw.Read(&recv_request, tag(1)); // Start server recv in BM_StreamingPingPong()
106 response_rw.Write(send_response, tag(3)); in BM_StreamingPingPong()
117 response_rw.Finish(Status::OK, tag(1)); in BM_StreamingPingPong()
163 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPongMsgs()
164 service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(), in BM_StreamingPingPongMsgs()
186 response_rw.Read(&recv_request, tag(1)); // Start server recv in BM_StreamingPingPongMsgs()
197 response_rw.Write(send_response, tag(3)); in BM_StreamingPingPongMsgs()
206 response_rw.Finish(Status::OK, tag(1)); in BM_StreamingPingPongMsgs()
[all …]
Dfullstack_streaming_pump.h52 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_PumpStreamClientToServer()
53 service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(), in BM_PumpStreamClientToServer()
69 response_rw.Read(&recv_request, tag(0)); in BM_PumpStreamClientToServer()
76 response_rw.Read(&recv_request, tag(0)); in BM_PumpStreamClientToServer()
92 response_rw.Finish(Status::OK, tag(0)); in BM_PumpStreamClientToServer()
121 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_PumpStreamServerToClient()
122 service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(), in BM_PumpStreamServerToClient()
141 response_rw.Write(send_response, tag(1)); in BM_PumpStreamServerToClient()
153 response_rw.Finish(Status::OK, tag(1)); in BM_PumpStreamServerToClient()
Dbm_fullstack_trickle.cc273 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_PumpStreamServerToClient_Trickle() local
274 service.RequestBidiStream(&svr_ctx, &response_rw, fixture->cq(), in BM_PumpStreamServerToClient_Trickle()
293 response_rw.Write(send_response, tag(1)); in BM_PumpStreamServerToClient_Trickle()
321 response_rw.Finish(Status::OK, tag(1)); in BM_PumpStreamServerToClient_Trickle()