Home
last modified time | relevance | path

Searched refs:srv_stream (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc/test/cpp/end2end/
Draw_end2end_test.cc227 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 …]
Dasync_end2end_test.cc509 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_P() local
515 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
521 srv_stream.Read(&recv_request, tag(4)); in TEST_P()
526 srv_stream.Read(&recv_request, tag(6)); in TEST_P()
531 srv_stream.Read(&recv_request, tag(8)); in TEST_P()
535 srv_stream.Finish(send_response, Status::OK, tag(9)); in TEST_P()
554 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_P() local
562 service_->RequestRequestStream(&srv_ctx, &srv_stream, cq_.get(), cq_.get(), in TEST_P()
571 srv_stream.Read(&recv_request, tag(4)); in TEST_P()
578 srv_stream.Read(&recv_request, tag(6)); in TEST_P()
[all …]
Dfilter_end2end_test.cc266 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F() local
275 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
289 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
296 srv_stream.Write(*send_buffer, tag(5)); in TEST_F()
308 srv_stream.Read(&recv_buffer, tag(8)); in TEST_F()
311 srv_stream.Finish(Status::OK, tag(9)); in TEST_F()
Dgeneric_end2end_test.cc269 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F() local
278 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
292 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
299 srv_stream.Write(*send_buffer, tag(5)); in TEST_F()
311 srv_stream.Read(&recv_buffer, tag(8)); in TEST_F()
314 srv_stream.Finish(Status::OK, tag(9)); in TEST_F()
Dhybrid_end2end_test.cc103 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming() local
104 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
110 srv_stream.Read(&recv_request, tag(i)); in HandleClientStreaming()
112 srv_stream.Finish(send_response, Status::OK, tag(100)); in HandleClientStreaming()
122 GenericServerAsyncReader srv_stream(&srv_ctx); in HandleRawClientStreaming() local
123 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleRawClientStreaming()
128 srv_stream.Read(&recv_buffer, tag(i)); in HandleRawClientStreaming()
136 srv_stream.Finish(*send_buffer, Status::OK, tag(100)); in HandleRawClientStreaming()
145 ServerAsyncWriter<EchoResponse> srv_stream(&srv_ctx); in HandleServerStreaming() local
146 service->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, cq, cq, in HandleServerStreaming()
[all …]