| /third_party/grpc/test/cpp/end2end/ |
| D | raw_end2end_test.cc | 227 grpc::GenericServerAsyncReader srv_stream(&srv_ctx_); in TEST_F() local
233 service->RequestRequestStream(&srv_ctx_, &srv_stream, cq_.get(), cq_.get(), in TEST_F()
239 srv_stream.Read(&recv_request_buffer_, tag(4)); in TEST_F()
245 srv_stream.Read(&recv_request_buffer_, tag(6)); in TEST_F()
251 srv_stream.Read(&recv_request_buffer_, tag(8)); in TEST_F()
257 srv_stream.Finish(send_response_buffer_, Status::OK, tag(9)); in TEST_F()
272 grpc::GenericServerAsyncWriter srv_stream(&srv_ctx_); in TEST_F() local
278 service->RequestResponseStream(&srv_ctx_, &recv_request_buffer_, &srv_stream, in TEST_F()
287 srv_stream.Write(send_response_buffer_, tag(3)); in TEST_F()
292 srv_stream.Write(send_response_buffer_, tag(5)); in TEST_F()
[all …]
|
| D | async_end2end_test.cc | 560 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_P() local
566 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
572 srv_stream.Read(&recv_request, tag(4)); in TEST_P()
577 srv_stream.Read(&recv_request, tag(6)); in TEST_P()
582 srv_stream.Read(&recv_request, tag(8)); in TEST_P()
586 srv_stream.Finish(send_response, Status::OK, tag(9)); in TEST_P()
605 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_P() local
613 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
622 srv_stream.Read(&recv_request, tag(4)); in TEST_P()
629 srv_stream.Read(&recv_request, tag(6)); in TEST_P()
[all …]
|
| D | filter_end2end_test.cc | 277 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F() local
286 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
300 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
307 srv_stream.Write(*send_buffer, tag(5)); in TEST_F()
319 srv_stream.Read(&recv_buffer, tag(8)); in TEST_F()
322 srv_stream.Finish(Status::OK, tag(9)); in TEST_F()
|
| D | hybrid_end2end_test.cc | 110 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming() local
111 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
117 srv_stream.Read(&recv_request, tag(i)); in HandleClientStreaming()
119 srv_stream.Finish(send_response, Status::OK, tag(100)); in HandleClientStreaming()
129 GenericServerAsyncReader srv_stream(&srv_ctx); in HandleRawClientStreaming() local
130 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleRawClientStreaming()
135 srv_stream.Read(&recv_buffer, tag(i)); in HandleRawClientStreaming()
143 srv_stream.Finish(*send_buffer, Status::OK, tag(100)); in HandleRawClientStreaming()
152 ServerAsyncWriter<EchoResponse> srv_stream(&srv_ctx); in HandleServerStreaming() local
153 service->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, cq, cq, in HandleServerStreaming()
[all …]
|
| D | generic_end2end_test.cc | 336 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F() local
345 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
359 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
366 srv_stream.Write(*send_buffer, tag(5)); in TEST_F()
378 srv_stream.Read(&recv_buffer, tag(8)); in TEST_F()
381 srv_stream.Finish(Status::OK, tag(9)); in TEST_F()
|
| D | server_interceptors_end2end_test.cc | 450 grpc::ServerAsyncReaderWriter<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_F() local
457 service.RequestBidiStream(&srv_ctx, &srv_stream, cq.get(), cq.get(), tag(2)); in TEST_F()
465 srv_stream.Read(&recv_request, tag(4)); in TEST_F()
470 srv_stream.Write(send_response, tag(5)); in TEST_F()
476 srv_stream.Read(&recv_request, tag(8)); in TEST_F()
479 srv_stream.Finish(Status::OK, tag(9)); in TEST_F()
|