| /third_party/grpc/src/proto/grpc/testing/ |
| D | echo.proto | 24 rpc Echo(EchoRequest) returns (EchoResponse);
25 rpc Echo1(EchoRequest) returns (EchoResponse);
26 rpc Echo2(EchoRequest) returns (EchoResponse);
32 rpc RequestStream(stream EchoRequest) returns (EchoResponse);
33 rpc ResponseStream(EchoRequest) returns (stream EchoResponse);
34 rpc BidiStream(stream EchoRequest) returns (stream EchoResponse);
35 rpc Unimplemented(EchoRequest) returns (EchoResponse);
39 rpc Echo(EchoRequest) returns (EchoResponse);
40 rpc Echo1(EchoRequest) returns (EchoResponse);
41 rpc Echo2(EchoRequest) returns (EchoResponse);
[all …]
|
| /third_party/grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 53 using grpc::testing::EchoResponse;
311 EchoResponse send_response; in SendRpc()
312 EchoResponse recv_response; in SendRpc()
317 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
320 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in SendRpc()
359 EchoResponse send_response; in TEST_P()
360 EchoResponse recv_response; in TEST_P()
365 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
373 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_P()
468 EchoResponse send_response; in TEST_P()
[all …]
|
| D | mock_test.cc | 47 using grpc::testing::EchoResponse;
72 EchoResponse response; in DoEcho()
81 EchoResponse response; in DoRequestStream()
107 EchoResponse response; in DoResponseStream()
111 std::unique_ptr<ClientReaderInterface<EchoResponse>> cstream = in DoResponseStream()
130 EchoResponse response; in DoBidiStream()
134 std::unique_ptr<ClientReaderWriterInterface<EchoRequest, EchoResponse>> in DoBidiStream()
170 EchoResponse* response) override { in Echo()
196 EchoResponse resp; in TEST_F()
225 EchoResponse resp; in TEST_F()
[all …]
|
| D | message_allocator_end2end_test.cc | 59 const EchoRequest* req, EchoResponse* resp)> in SetAllocatorMutator()
66 EchoResponse* response) override { in Echo()
78 const EchoRequest* req, EchoResponse* resp)>
114 experimental::MessageAllocator<EchoRequest, EchoResponse>* allocator) { in CreateServer()
166 EchoResponse response; in SendRpcs()
213 : public experimental::MessageAllocator<EchoRequest, EchoResponse> {
216 : public experimental::MessageHolder<EchoRequest, EchoResponse> {
223 set_response(new EchoResponse); in MessageHolderImpl()
247 experimental::MessageHolder<EchoRequest, EchoResponse>* AllocateMessages() in AllocateMessages()
277 const EchoRequest* req, EchoResponse* resp) { in TEST_P()
[all …]
|
| D | end2end_test.cc | 61 using grpc::testing::EchoResponse;
253 EchoResponse* response) override { in Echo()
267 EchoResponse* response) override { in Echo()
472 EchoResponse response; in SendRpc()
511 EchoResponse response; in TestRequestStreamServerCancel()
589 EchoResponse response; in TestResponseStreamServerCancel()
670 EchoResponse response; in TestBidiStreamServerCancel()
744 EchoResponse response; in TEST_P()
811 EchoResponse response; in TEST_P()
865 EchoResponse response; in TEST_P()
[all …]
|
| D | streaming_throughput_test.cc | 44 using grpc::testing::EchoResponse;
91 ServerReaderWriter<EchoResponse, EchoRequest>* stream, in BidiStream_Sender() argument
93 EchoResponse response; in BidiStream_Sender()
110 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream() argument
159 static void Drainer(ClientReaderWriter<EchoRequest, EchoResponse>* reader) { in Drainer()
160 EchoResponse response; in Drainer()
|
| D | hybrid_end2end_test.cc | 70 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho()
72 EchoResponse send_response; in HandleEcho()
98 EchoResponse send_response; in HandleRawEcho()
109 EchoResponse send_response; in HandleClientStreaming()
110 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming()
128 EchoResponse send_response; in HandleRawClientStreaming()
151 EchoResponse send_response; in HandleServerStreaming()
152 ServerAsyncWriter<EchoResponse> srv_stream(&srv_ctx); in HandleServerStreaming()
176 EchoResponse send_response; in HandleGenericEcho()
189 EchoResponse send_response; in HandleGenericRequestStream()
[all …]
|
| D | interceptors_util.cc | 35 EchoResponse resp; in MakeCall()
48 EchoResponse resp; in MakeClientStreamingCall()
68 EchoResponse resp; in MakeServerStreamingCall()
84 EchoResponse resp; in MakeBidiStreamingCall()
103 EchoResponse recv_response; in MakeAsyncCQCall()
109 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in MakeAsyncCQCall()
125 EchoResponse recv_response; in MakeAsyncCQServerStreamingCall()
131 std::unique_ptr<ClientAsyncReader<EchoResponse>> cli_stream( in MakeAsyncCQServerStreamingCall()
163 EchoResponse resp; in MakeCallbackCall()
|
| D | test_service_impl.h | 64 const EchoRequest* request, EchoResponse* response);
126 EchoResponse* response) { in Echo()
235 EchoResponse* response) { in Echo1()
240 EchoResponse* response) { in Echo2()
260 EchoResponse* response) { in RequestStream()
309 ServerWriter<EchoResponse>* writer) { in ResponseStream()
333 EchoResponse response; in ResponseStream()
364 ServerReaderWriter<EchoResponse, EchoRequest>* stream) { in BidiStream() argument
377 EchoResponse response; in BidiStream()
445 EchoResponse* response) override;
[all …]
|
| D | server_crash_test.cc | 38 using grpc::testing::EchoResponse;
54 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream() argument
57 EchoResponse response; in BidiStream()
70 ServerWriter<EchoResponse>* writer) override { in ResponseStream()
71 EchoResponse response; in ResponseStream()
|
| D | exception_test.cc | 43 EchoResponse* /*response*/) override { in Echo() argument
48 EchoResponse* /*response*/) override { in RequestStream() argument
88 EchoResponse response; in TEST_F()
101 EchoResponse response; in TEST_F()
|
| D | test_service_impl.cc | 42 const EchoRequest* request, EchoResponse* response) { in MaybeEchoDeadline()
129 EchoResponse* response) { in Echo()
134 const EchoRequest* request, EchoResponse* response) in Echo()
310 EchoResponse* const resp_; in Echo()
348 experimental::CallbackServerContext* context, EchoResponse* response) { in RequestStream()
367 Reactor(experimental::CallbackServerContext* ctx, EchoResponse* response, in RequestStream()
418 EchoResponse* const response_; in RequestStream()
432 experimental::ServerWriteReactor<EchoResponse>*
450 : public ::grpc::experimental::ServerWriteReactor<EchoResponse> { in ResponseStream()
523 EchoResponse response_; in ResponseStream()
[all …]
|
| D | server_interceptors_end2end_test.cc | 121 EchoResponse* resp = in Intercept()
122 static_cast<EchoResponse*>(methods->GetRecvMessage()); in Intercept()
216 EchoResponse resp; in MakeBidiStreamingCall()
371 EchoResponse send_response; in TEST_F()
372 EchoResponse recv_response; in TEST_F()
377 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_F()
381 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in TEST_F()
444 EchoResponse send_response; in TEST_F()
445 EchoResponse recv_response; in TEST_F()
450 grpc::ServerAsyncReaderWriter<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_F()
[all …]
|
| D | client_crash_test_server.cc | 35 using grpc::testing::EchoResponse;
50 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream() argument
52 EchoResponse response; in BidiStream()
|
| D | server_early_return_test.cc | 53 EchoResponse* response) override { in RequestStream()
77 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream() argument
86 EchoResponse response; in BidiStream()
142 EchoResponse response; in DoBidiStream()
180 EchoResponse response; in DoRequestStream()
|
| D | generic_end2end_test.cc | 43 using grpc::testing::EchoResponse;
118 EchoResponse send_response; in SendRpc()
119 EchoResponse recv_response; in SendRpc()
272 EchoResponse send_response; in TEST_F()
273 EchoResponse recv_response; in TEST_F()
331 EchoResponse send_response; in TEST_F()
332 EchoResponse recv_response; in TEST_F()
403 EchoResponse response; in TEST_F()
|
| D | thread_stress_test.cc | 44 using grpc::testing::EchoResponse;
61 EchoResponse* response) override { in Echo()
225 EchoResponse send_response; in ProcessRpcs()
244 new grpc::ServerAsyncResponseWriter<EchoResponse>( in RefreshContext()
254 std::unique_ptr<grpc::ServerAsyncResponseWriter<EchoResponse>>
281 EchoResponse response; in SendRpc()
360 EchoResponse response;
363 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader;
|
| /third_party/grpc/doc/ |
| D | unit_testing.md | 12 rpc Echo(EchoRequest) returns (EchoResponse);
13 rpc BidiStream(stream EchoRequest) returns (stream EchoResponse);
23 …context, const ::grpc::testing::EchoRequest& request, ::grpc::testing::EchoResponse* response) = 0;
25 …ReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testing::EchoResponse>> BidiStream(::…
26 …ReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testing::EchoResponse>>(BidiStreamRaw…
30 …ReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testing::EchoResponse>* BidiStreamRaw…
46 …t* context, const ::grpc::testing::EchoRequest& request, ::grpc::testing::EchoResponse* response));
47 …ReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testing::EchoResponse>*(::grpc::Clien…
94 EchoResponse response;
103 EchoResponse response;
[all …]
|
| /third_party/grpc/test/cpp/ios/CronetTests/ |
| D | CppCronetEnd2EndTests.mm | 99 EchoResponse response;
148 EchoResponse response;
187 EchoResponse response;
208 EchoResponse response;
223 EchoResponse response;
238 EchoResponse response;
253 EchoResponse response;
271 EchoResponse response;
295 EchoResponse response;
328 EchoResponse response;
[all …]
|
| D | TestHelper.h | 66 grpc::testing::EchoResponse* response);
70 grpc::testing::EchoResponse* response);
73 grpc::ServerWriter<grpc::testing::EchoResponse>* writer);
77 grpc::ServerReaderWriter<grpc::testing::EchoResponse,
|
| D | TestHelper.mm | 26 using grpc::testing::EchoResponse;
77 void MaybeEchoDeadline(ServerContext* context, const EchoRequest* request, EchoResponse* response) {
88 EchoResponse* response) {
126 EchoResponse* response) {
138 grpc::ServerWriter<EchoResponse>* writer) {
139 EchoResponse response;
155 grpc::ServerReaderWriter<EchoResponse, EchoRequest>* stream) {
157 EchoResponse response;
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | callback_test_service.cc | 51 const EchoRequest* /*request*/, EchoResponse* response) { in Echo()
64 experimental::ServerBidiReactor<EchoRequest, EchoResponse>*
68 : public experimental::ServerBidiReactor<EchoRequest, EchoResponse> { in BidiStream()
104 EchoResponse response_; in BidiStream()
|
| D | fullstack_streaming_ping_pong.h | 55 EchoResponse send_response; in BM_StreamingPingPong()
56 EchoResponse recv_response; in BM_StreamingPingPong()
71 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPong()
148 EchoResponse send_response; in BM_StreamingPingPongMsgs()
149 EchoResponse recv_response; in BM_StreamingPingPongMsgs()
163 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPongMsgs()
252 EchoResponse send_response; in BM_StreamingPingPongWithCoalescingApi()
253 EchoResponse recv_response; in BM_StreamingPingPongWithCoalescingApi()
268 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPongWithCoalescingApi()
|
| D | callback_streaming_ping_pong.h | 38 : public grpc::experimental::ClientBidiReactor<EchoRequest, EchoResponse> {
42 EchoResponse* response) in BidiClient()
112 EchoResponse* response_;
130 EchoResponse response; in BM_CallbackBidiStreaming()
|
| D | fullstack_unary_ping_pong.h | 45 EchoResponse send_response; in BM_UnaryPingPong()
46 EchoResponse recv_response; in BM_UnaryPingPong()
57 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer; in BM_UnaryPingPong()
79 std::unique_ptr<ClientAsyncResponseReader<EchoResponse>> response_reader( in BM_UnaryPingPong()
|