Home
last modified time | relevance | path

Searched refs:EchoRequest (Results 1 – 25 of 68) sorted by relevance

123

/third_party/grpc/src/proto/grpc/testing/
Decho.proto24 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/
Dmessage_allocator_end2end_test.cc59 const EchoRequest* req, EchoResponse* resp)> in SetAllocatorMutator()
65 experimental::CallbackServerContext* context, const EchoRequest* request, in Echo()
78 const EchoRequest* req, EchoResponse* resp)>
114 experimental::MessageAllocator<EchoRequest, EchoResponse>* allocator) { in CreateServer() argument
165 EchoRequest request; in SendRpcs()
213 : public experimental::MessageAllocator<EchoRequest, EchoResponse> {
216 : public experimental::MessageHolder<EchoRequest, EchoResponse> {
222 set_request(new EchoRequest); in MessageHolderImpl()
237 EchoRequest* ReleaseRequest() { in ReleaseRequest()
247 experimental::MessageHolder<EchoRequest, EchoResponse>* AllocateMessages() in AllocateMessages()
[all …]
Dmock_test.cc46 using grpc::testing::EchoRequest;
71 EchoRequest request; in DoEcho()
80 EchoRequest request; in DoRequestStream()
87 std::unique_ptr<ClientWriterInterface<EchoRequest>> cstream = in DoRequestStream()
106 EchoRequest request; in DoResponseStream()
129 EchoRequest request; in DoBidiStream()
134 std::unique_ptr<ClientReaderWriterInterface<EchoRequest, EchoResponse>> in DoBidiStream()
169 experimental::CallbackServerContext* context, const EchoRequest* request, in Echo()
195 EchoRequest req; in TEST_F()
224 EchoRequest req; in TEST_F()
[all …]
Dasync_end2end_test.cc52 using grpc::testing::EchoRequest;
309 EchoRequest send_request; in SendRpc()
310 EchoRequest recv_request; in SendRpc()
357 EchoRequest send_request; in TEST_P()
358 EchoRequest recv_request; in TEST_P()
466 EchoRequest send_request; in TEST_P()
467 EchoRequest recv_request; in TEST_P()
507 EchoRequest send_request; in TEST_P()
508 EchoRequest recv_request; in TEST_P()
553 EchoRequest send_request; in TEST_P()
[all …]
Dend2end_test.cc60 using grpc::testing::EchoRequest;
252 Status Echo(ServerContext* server_context, const EchoRequest* request, in Echo()
266 Status Echo(ServerContext* /*context*/, const EchoRequest* /*request*/, in Echo() argument
471 EchoRequest request; in SendRpc()
510 EchoRequest request; in TestRequestStreamServerCancel()
588 EchoRequest request; in TestResponseStreamServerCancel()
669 EchoRequest request; in TestBidiStreamServerCancel()
743 EchoRequest request; in TEST_P()
810 EchoRequest request; in TEST_P()
864 EchoRequest request; in TEST_P()
[all …]
Dstreaming_throughput_test.cc43 using grpc::testing::EchoRequest;
91 ServerReaderWriter<EchoResponse, EchoRequest>* stream, in BidiStream_Sender()
110 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
111 EchoRequest request; in BidiStream()
159 static void Drainer(ClientReaderWriter<EchoRequest, EchoResponse>* reader) { in Drainer() argument
175 EchoRequest request; in TEST_F()
Dtest_service_impl.h64 const EchoRequest* request, EchoResponse* response);
125 Status Echo(ServerContext* context, const EchoRequest* request, in Echo()
234 Status Echo1(ServerContext* context, const EchoRequest* request, in Echo1()
239 Status Echo2(ServerContext* context, const EchoRequest* request, in Echo2()
259 ServerReader<EchoRequest>* reader, in RequestStream()
272 EchoRequest request; in RequestStream()
308 Status ResponseStream(ServerContext* context, const EchoRequest* request, in ResponseStream()
364 ServerReaderWriter<EchoResponse, EchoRequest>* stream) { in BidiStream()
376 EchoRequest request; in BidiStream()
444 experimental::CallbackServerContext* context, const EchoRequest* request,
[all …]
Dhybrid_end2end_test.cc71 EchoRequest recv_request; in HandleEcho()
96 EchoRequest recv_request; in HandleRawEcho()
108 EchoRequest recv_request; in HandleClientStreaming()
110 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming()
127 EchoRequest recv_request; in HandleRawClientStreaming()
150 EchoRequest recv_request; in HandleServerStreaming()
174 EchoRequest recv_request; in HandleGenericEcho()
188 EchoRequest recv_request; in HandleGenericRequestStream()
228 Status Echo(ServerContext* /*context*/, const EchoRequest* request, in Echo()
330 EchoRequest send_request; in SendEcho()
[all …]
Dserver_early_return_test.cc52 ServerReader<EchoRequest>* reader, in RequestStream()
61 EchoRequest request; in RequestStream()
77 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
85 EchoRequest request; in BidiStream()
141 EchoRequest request; in DoBidiStream()
179 EchoRequest request; in DoRequestStream()
Dserver_interceptors_end2end_test.cc85 EchoRequest req; in Intercept()
89 SerializationTraits<EchoRequest>::Deserialize(&copied_buffer, &req) in Intercept()
156 static_cast<const EchoRequest*>(methods->GetSendMessage())->message(); in Intercept()
165 EchoRequest new_msg_;
187 static_cast<const EchoRequest*>(methods->GetSendMessage())->message(); in Intercept()
200 EchoRequest new_msg_;
215 EchoRequest req; in MakeBidiStreamingCall()
369 EchoRequest send_request; in TEST_F()
370 EchoRequest recv_request; in TEST_F()
442 EchoRequest send_request; in TEST_F()
[all …]
Dtest_service_impl.cc42 const EchoRequest* request, EchoResponse* response) { in MaybeEchoDeadline()
128 experimental::CallbackServerContext* context, const EchoRequest* request, in Echo()
134 const EchoRequest* request, EchoResponse* response) in Echo()
309 const EchoRequest* const req_; in Echo()
346 experimental::ServerReadReactor<EchoRequest>*
365 class Reactor : public ::grpc::experimental::ServerReadReactor<EchoRequest> { in RequestStream()
419 EchoRequest request_; in RequestStream()
434 experimental::CallbackServerContext* context, const EchoRequest* request) { in ResponseStream()
453 const EchoRequest* request, int server_try_cancel) in ResponseStream()
522 const EchoRequest* const request_; in ResponseStream()
[all …]
Dinterceptors_util.cc31 EchoRequest req; in MakeCall()
44 EchoRequest req; in MakeClientStreamingCall()
64 EchoRequest req; in MakeServerStreamingCall()
83 EchoRequest req; in MakeBidiStreamingCall()
102 EchoRequest send_request; in MakeAsyncCQCall()
124 EchoRequest send_request; in MakeAsyncCQServerStreamingCall()
156 EchoRequest req; in MakeCallbackCall()
Dserver_crash_test_client.cc36 using grpc::testing::EchoRequest;
44 EchoRequest request; in main()
60 EchoRequest request; in main()
Dclient_crash_test_server.cc34 using grpc::testing::EchoRequest;
50 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
51 EchoRequest request; in BidiStream()
Dserver_crash_test.cc37 using grpc::testing::EchoRequest;
54 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
56 EchoRequest request; in BidiStream()
69 const EchoRequest* /*request*/, in ResponseStream() argument
Dgeneric_end2end_test.cc42 using grpc::testing::EchoRequest;
116 EchoRequest send_request; in SendRpc()
117 EchoRequest recv_request; in SendRpc()
270 EchoRequest send_request; in TEST_F()
271 EchoRequest recv_request; in TEST_F()
329 EchoRequest send_request; in TEST_F()
330 EchoRequest recv_request; in TEST_F()
402 EchoRequest request; in TEST_F()
Dinterceptors_util.h105 Status Echo(ServerContext* context, const EchoRequest* request, in Echo()
117 grpc::ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
118 EchoRequest req; in BidiStream()
133 ServerReader<EchoRequest>* reader, in RequestStream()
140 EchoRequest req; in RequestStream()
149 Status ResponseStream(ServerContext* context, const EchoRequest* req, in ResponseStream()
/third_party/grpc/doc/
Dunit_testing.md12 rpc Echo(EchoRequest) returns (EchoResponse);
13 rpc BidiStream(stream EchoRequest) returns (stream EchoResponse);
23 …virtual ::grpc::Status Echo(::grpc::ClientContext* context, const ::grpc::testing::EchoRequest& re…
25 …std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testin…
26 …return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc:…
30 …virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::EchoRequest, ::grpc::testing::EchoRe…
46 … ::grpc::Status(::grpc::ClientContext* context, const ::grpc::testing::EchoRequest& request, ::grp…
47 …MOCK_METHOD1(BidiStreamRaw, ::grpc::ClientReaderWriterInterface< ::grpc::testing::EchoRequest, ::g…
93 EchoRequest request;
102 EchoRequest request;
[all …]
/third_party/grpc/test/cpp/ios/CronetTests/
DCppCronetEnd2EndTests.mm98 EchoRequest request;
147 EchoRequest request;
186 EchoRequest request;
207 EchoRequest request;
222 EchoRequest request;
237 EchoRequest request;
252 EchoRequest request;
270 EchoRequest request;
294 EchoRequest request;
327 EchoRequest request;
[all …]
DTestHelper.h65 const grpc::testing::EchoRequest* request,
69 grpc::ServerReader<grpc::testing::EchoRequest>* reader,
72 grpc::ServerContext* context, const grpc::testing::EchoRequest* request,
78 grpc::testing::EchoRequest>* stream);
DTestHelper.mm25 using grpc::testing::EchoRequest;
77 void MaybeEchoDeadline(ServerContext* context, const EchoRequest* request, EchoResponse* response) {
87 Status TestServiceImpl::Echo(ServerContext* context, const EchoRequest* request,
125 grpc::ServerReader<EchoRequest>* reader,
127 EchoRequest request;
137 Status TestServiceImpl::ResponseStream(ServerContext* context, const EchoRequest* request,
155 grpc::ServerReaderWriter<EchoResponse, EchoRequest>* stream) {
156 EchoRequest request;
/third_party/grpc/test/cpp/microbenchmarks/
Dcallback_test_service.cc51 const EchoRequest* /*request*/, EchoResponse* response) { in Echo() argument
64 experimental::ServerBidiReactor<EchoRequest, EchoResponse>*
68 : public experimental::ServerBidiReactor<EchoRequest, EchoResponse> { in BidiStream()
103 EchoRequest request_; in BidiStream()
Dfullstack_streaming_ping_pong.h57 EchoRequest send_request; in BM_StreamingPingPong()
58 EchoRequest recv_request; in BM_StreamingPingPong()
71 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPong()
150 EchoRequest send_request; in BM_StreamingPingPongMsgs()
151 EchoRequest recv_request; in BM_StreamingPingPongMsgs()
163 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPongMsgs()
254 EchoRequest send_request; in BM_StreamingPingPongWithCoalescingApi()
255 EchoRequest recv_request; in BM_StreamingPingPongWithCoalescingApi()
268 ServerAsyncReaderWriter<EchoResponse, EchoRequest> response_rw(&svr_ctx); in BM_StreamingPingPongWithCoalescingApi()
Dcallback_streaming_ping_pong.h38 : public grpc::experimental::ClientBidiReactor<EchoRequest, EchoResponse> {
41 ClientContext* cli_ctx, EchoRequest* request, in BidiClient()
111 EchoRequest* request_;
129 EchoRequest request; in BM_CallbackBidiStreaming()
/third_party/grpc/test/cpp/util/
Derror_details_test.cc32 testing::EchoRequest expected_details; in TEST()
44 testing::EchoRequest details; in TEST()
66 testing::EchoRequest expected_details; in TEST()
87 testing::EchoRequest expected_details; in TEST()
104 testing::EchoRequest expected_details; in TEST()

123