Home
last modified time | relevance | path

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

/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h77 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_StreamingPingPong() local
94 request_rw->Write(send_request, tag(0)); // Start client send in BM_StreamingPingPong()
96 request_rw->Read(&recv_response, tag(2)); // Start client recv in BM_StreamingPingPong()
116 request_rw->WritesDone(tag(0)); in BM_StreamingPingPong()
120 request_rw->Finish(&recv_status, tag(2)); in BM_StreamingPingPong()
169 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_StreamingPingPongMsgs() local
185 request_rw->Write(send_request, tag(0)); // Start client send in BM_StreamingPingPongMsgs()
187 request_rw->Read(&recv_response, tag(2)); // Start client recv in BM_StreamingPingPongMsgs()
205 request_rw->WritesDone(tag(0)); in BM_StreamingPingPongMsgs()
208 request_rw->Finish(&recv_status, tag(2)); in BM_StreamingPingPongMsgs()
[all …]
Dfullstack_streaming_pump.h58 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamClientToServer() local
72 request_rw->Write(send_request, tag(1)); in BM_PumpStreamClientToServer()
84 request_rw->WritesDone(tag(1)); in BM_PumpStreamClientToServer()
94 request_rw->Finish(&final_status, tag(1)); in BM_PumpStreamClientToServer()
127 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamServerToClient() local
138 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient()
145 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient()
Dbm_fullstack_trickle.cc279 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamServerToClient_Trickle() local
290 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()
298 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()
323 request_rw->Finish(&status, tag(2)); in BM_PumpStreamServerToClient_Trickle()
328 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()