Line data Source code
1 : // Generated by the gRPC protobuf plugin.
2 : // If you make any local change, they will be lost.
3 : // source: test/proto/test.proto
4 :
5 : #include "test/proto/test.pb.h"
6 : #include "test/proto/test.grpc.pb.h"
7 :
8 : #include <grpc++/channel.h>
9 : #include <grpc++/impl/client_unary_call.h>
10 : #include <grpc++/impl/rpc_service_method.h>
11 : #include <grpc++/impl/service_type.h>
12 : #include <grpc++/support/async_unary_call.h>
13 : #include <grpc++/support/async_stream.h>
14 : #include <grpc++/support/sync_stream.h>
15 : namespace grpc {
16 : namespace testing {
17 :
18 : static const char* TestService_method_names[] = {
19 : "/grpc.testing.TestService/EmptyCall",
20 : "/grpc.testing.TestService/UnaryCall",
21 : "/grpc.testing.TestService/StreamingOutputCall",
22 : "/grpc.testing.TestService/StreamingInputCall",
23 : "/grpc.testing.TestService/FullDuplexCall",
24 : "/grpc.testing.TestService/HalfDuplexCall",
25 : };
26 :
27 4 : std::unique_ptr< TestService::Stub> TestService::NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options) {
28 4 : std::unique_ptr< TestService::Stub> stub(new TestService::Stub(channel));
29 4 : return stub;
30 : }
31 :
32 4 : TestService::Stub::Stub(const std::shared_ptr< ::grpc::Channel>& channel)
33 : : channel_(channel), rpcmethod_EmptyCall_(TestService_method_names[0], ::grpc::RpcMethod::NORMAL_RPC, channel)
34 : , rpcmethod_UnaryCall_(TestService_method_names[1], ::grpc::RpcMethod::NORMAL_RPC, channel)
35 : , rpcmethod_StreamingOutputCall_(TestService_method_names[2], ::grpc::RpcMethod::SERVER_STREAMING, channel)
36 : , rpcmethod_StreamingInputCall_(TestService_method_names[3], ::grpc::RpcMethod::CLIENT_STREAMING, channel)
37 : , rpcmethod_FullDuplexCall_(TestService_method_names[4], ::grpc::RpcMethod::BIDI_STREAMING, channel)
38 4 : , rpcmethod_HalfDuplexCall_(TestService_method_names[5], ::grpc::RpcMethod::BIDI_STREAMING, channel)
39 4 : {}
40 :
41 0 : ::grpc::Status TestService::Stub::EmptyCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) {
42 0 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_EmptyCall_, context, request, response);
43 : }
44 :
45 0 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* TestService::Stub::AsyncEmptyCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
46 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>(channel_.get(), cq, rpcmethod_EmptyCall_, context, request);
47 : }
48 :
49 4 : ::grpc::Status TestService::Stub::UnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::testing::SimpleResponse* response) {
50 4 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_UnaryCall_, context, request, response);
51 : }
52 :
53 0 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>* TestService::Stub::AsyncUnaryCallRaw(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) {
54 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>(channel_.get(), cq, rpcmethod_UnaryCall_, context, request);
55 : }
56 :
57 0 : ::grpc::ClientReader< ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::StreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request) {
58 0 : return new ::grpc::ClientReader< ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), rpcmethod_StreamingOutputCall_, context, request);
59 : }
60 :
61 0 : ::grpc::ClientAsyncReader< ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::AsyncStreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request, ::grpc::CompletionQueue* cq, void* tag) {
62 0 : return new ::grpc::ClientAsyncReader< ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), cq, rpcmethod_StreamingOutputCall_, context, request, tag);
63 : }
64 :
65 0 : ::grpc::ClientWriter< ::grpc::testing::StreamingInputCallRequest>* TestService::Stub::StreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response) {
66 0 : return new ::grpc::ClientWriter< ::grpc::testing::StreamingInputCallRequest>(channel_.get(), rpcmethod_StreamingInputCall_, context, response);
67 : }
68 :
69 0 : ::grpc::ClientAsyncWriter< ::grpc::testing::StreamingInputCallRequest>* TestService::Stub::AsyncStreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
70 0 : return new ::grpc::ClientAsyncWriter< ::grpc::testing::StreamingInputCallRequest>(channel_.get(), cq, rpcmethod_StreamingInputCall_, context, response, tag);
71 : }
72 :
73 0 : ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::FullDuplexCallRaw(::grpc::ClientContext* context) {
74 0 : return new ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), rpcmethod_FullDuplexCall_, context);
75 : }
76 :
77 0 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::AsyncFullDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
78 0 : return new ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), cq, rpcmethod_FullDuplexCall_, context, tag);
79 : }
80 :
81 0 : ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::HalfDuplexCallRaw(::grpc::ClientContext* context) {
82 0 : return new ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), rpcmethod_HalfDuplexCall_, context);
83 : }
84 :
85 0 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* TestService::Stub::AsyncHalfDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
86 0 : return new ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(channel_.get(), cq, rpcmethod_HalfDuplexCall_, context, tag);
87 : }
88 :
89 0 : TestService::AsyncService::AsyncService() : ::grpc::AsynchronousService(TestService_method_names, 6) {}
90 :
91 2 : TestService::Service::~Service() {
92 1 : delete service_;
93 1 : }
94 :
95 0 : ::grpc::Status TestService::Service::EmptyCall(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response) {
96 : (void) context;
97 : (void) request;
98 : (void) response;
99 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
100 : }
101 :
102 0 : void TestService::AsyncService::RequestEmptyCall(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
103 0 : AsynchronousService::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
104 0 : }
105 :
106 0 : ::grpc::Status TestService::Service::UnaryCall(::grpc::ServerContext* context, const ::grpc::testing::SimpleRequest* request, ::grpc::testing::SimpleResponse* response) {
107 : (void) context;
108 : (void) request;
109 : (void) response;
110 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
111 : }
112 :
113 0 : void TestService::AsyncService::RequestUnaryCall(::grpc::ServerContext* context, ::grpc::testing::SimpleRequest* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::SimpleResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
114 0 : AsynchronousService::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
115 0 : }
116 :
117 0 : ::grpc::Status TestService::Service::StreamingOutputCall(::grpc::ServerContext* context, const ::grpc::testing::StreamingOutputCallRequest* request, ::grpc::ServerWriter< ::grpc::testing::StreamingOutputCallResponse>* writer) {
118 : (void) context;
119 : (void) request;
120 : (void) writer;
121 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
122 : }
123 :
124 0 : void TestService::AsyncService::RequestStreamingOutputCall(::grpc::ServerContext* context, ::grpc::testing::StreamingOutputCallRequest* request, ::grpc::ServerAsyncWriter< ::grpc::testing::StreamingOutputCallResponse>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
125 0 : AsynchronousService::RequestServerStreaming(2, context, request, writer, new_call_cq, notification_cq, tag);
126 0 : }
127 :
128 0 : ::grpc::Status TestService::Service::StreamingInputCall(::grpc::ServerContext* context, ::grpc::ServerReader< ::grpc::testing::StreamingInputCallRequest>* reader, ::grpc::testing::StreamingInputCallResponse* response) {
129 : (void) context;
130 : (void) reader;
131 : (void) response;
132 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
133 : }
134 :
135 0 : void TestService::AsyncService::RequestStreamingInputCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::testing::StreamingInputCallResponse, ::grpc::testing::StreamingInputCallRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
136 0 : AsynchronousService::RequestClientStreaming(3, context, reader, new_call_cq, notification_cq, tag);
137 0 : }
138 :
139 0 : ::grpc::Status TestService::Service::FullDuplexCall(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream) {
140 : (void) context;
141 : (void) stream;
142 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
143 : }
144 :
145 0 : void TestService::AsyncService::RequestFullDuplexCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
146 0 : AsynchronousService::RequestBidiStreaming(4, context, stream, new_call_cq, notification_cq, tag);
147 0 : }
148 :
149 0 : ::grpc::Status TestService::Service::HalfDuplexCall(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream) {
150 : (void) context;
151 : (void) stream;
152 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
153 : }
154 :
155 0 : void TestService::AsyncService::RequestHalfDuplexCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
156 0 : AsynchronousService::RequestBidiStreaming(5, context, stream, new_call_cq, notification_cq, tag);
157 0 : }
158 :
159 1 : ::grpc::RpcService* TestService::Service::service() {
160 1 : if (service_ != nullptr) {
161 0 : return service_;
162 : }
163 1 : service_ = new ::grpc::RpcService();
164 : service_->AddMethod(new ::grpc::RpcServiceMethod(
165 : TestService_method_names[0],
166 : ::grpc::RpcMethod::NORMAL_RPC,
167 : new ::grpc::RpcMethodHandler< TestService::Service, ::grpc::testing::Empty, ::grpc::testing::Empty>(
168 1 : std::mem_fn(&TestService::Service::EmptyCall), this)));
169 : service_->AddMethod(new ::grpc::RpcServiceMethod(
170 : TestService_method_names[1],
171 : ::grpc::RpcMethod::NORMAL_RPC,
172 : new ::grpc::RpcMethodHandler< TestService::Service, ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>(
173 1 : std::mem_fn(&TestService::Service::UnaryCall), this)));
174 : service_->AddMethod(new ::grpc::RpcServiceMethod(
175 : TestService_method_names[2],
176 : ::grpc::RpcMethod::SERVER_STREAMING,
177 : new ::grpc::ServerStreamingHandler< TestService::Service, ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(
178 1 : std::mem_fn(&TestService::Service::StreamingOutputCall), this)));
179 : service_->AddMethod(new ::grpc::RpcServiceMethod(
180 : TestService_method_names[3],
181 : ::grpc::RpcMethod::CLIENT_STREAMING,
182 : new ::grpc::ClientStreamingHandler< TestService::Service, ::grpc::testing::StreamingInputCallRequest, ::grpc::testing::StreamingInputCallResponse>(
183 1 : std::mem_fn(&TestService::Service::StreamingInputCall), this)));
184 : service_->AddMethod(new ::grpc::RpcServiceMethod(
185 : TestService_method_names[4],
186 : ::grpc::RpcMethod::BIDI_STREAMING,
187 : new ::grpc::BidiStreamingHandler< TestService::Service, ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(
188 1 : std::mem_fn(&TestService::Service::FullDuplexCall), this)));
189 : service_->AddMethod(new ::grpc::RpcServiceMethod(
190 : TestService_method_names[5],
191 : ::grpc::RpcMethod::BIDI_STREAMING,
192 : new ::grpc::BidiStreamingHandler< TestService::Service, ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>(
193 1 : std::mem_fn(&TestService::Service::HalfDuplexCall), this)));
194 1 : return service_;
195 : }
196 :
197 :
198 : static const char* UnimplementedService_method_names[] = {
199 : "/grpc.testing.UnimplementedService/UnimplementedCall",
200 : };
201 :
202 0 : std::unique_ptr< UnimplementedService::Stub> UnimplementedService::NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options) {
203 0 : std::unique_ptr< UnimplementedService::Stub> stub(new UnimplementedService::Stub(channel));
204 0 : return stub;
205 : }
206 :
207 0 : UnimplementedService::Stub::Stub(const std::shared_ptr< ::grpc::Channel>& channel)
208 0 : : channel_(channel), rpcmethod_UnimplementedCall_(UnimplementedService_method_names[0], ::grpc::RpcMethod::NORMAL_RPC, channel)
209 0 : {}
210 :
211 0 : ::grpc::Status UnimplementedService::Stub::UnimplementedCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) {
212 0 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_UnimplementedCall_, context, request, response);
213 : }
214 :
215 0 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* UnimplementedService::Stub::AsyncUnimplementedCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
216 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>(channel_.get(), cq, rpcmethod_UnimplementedCall_, context, request);
217 : }
218 :
219 0 : UnimplementedService::AsyncService::AsyncService() : ::grpc::AsynchronousService(UnimplementedService_method_names, 1) {}
220 :
221 0 : UnimplementedService::Service::~Service() {
222 0 : delete service_;
223 0 : }
224 :
225 0 : ::grpc::Status UnimplementedService::Service::UnimplementedCall(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response) {
226 : (void) context;
227 : (void) request;
228 : (void) response;
229 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
230 : }
231 :
232 0 : void UnimplementedService::AsyncService::RequestUnimplementedCall(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
233 0 : AsynchronousService::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
234 0 : }
235 :
236 0 : ::grpc::RpcService* UnimplementedService::Service::service() {
237 0 : if (service_ != nullptr) {
238 0 : return service_;
239 : }
240 0 : service_ = new ::grpc::RpcService();
241 : service_->AddMethod(new ::grpc::RpcServiceMethod(
242 : UnimplementedService_method_names[0],
243 : ::grpc::RpcMethod::NORMAL_RPC,
244 : new ::grpc::RpcMethodHandler< UnimplementedService::Service, ::grpc::testing::Empty, ::grpc::testing::Empty>(
245 0 : std::mem_fn(&UnimplementedService::Service::UnimplementedCall), this)));
246 0 : return service_;
247 : }
248 :
249 :
250 : static const char* ReconnectService_method_names[] = {
251 : "/grpc.testing.ReconnectService/Start",
252 : "/grpc.testing.ReconnectService/Stop",
253 : };
254 :
255 0 : std::unique_ptr< ReconnectService::Stub> ReconnectService::NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options) {
256 0 : std::unique_ptr< ReconnectService::Stub> stub(new ReconnectService::Stub(channel));
257 0 : return stub;
258 : }
259 :
260 0 : ReconnectService::Stub::Stub(const std::shared_ptr< ::grpc::Channel>& channel)
261 : : channel_(channel), rpcmethod_Start_(ReconnectService_method_names[0], ::grpc::RpcMethod::NORMAL_RPC, channel)
262 0 : , rpcmethod_Stop_(ReconnectService_method_names[1], ::grpc::RpcMethod::NORMAL_RPC, channel)
263 0 : {}
264 :
265 0 : ::grpc::Status ReconnectService::Stub::Start(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) {
266 0 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_Start_, context, request, response);
267 : }
268 :
269 0 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* ReconnectService::Stub::AsyncStartRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
270 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>(channel_.get(), cq, rpcmethod_Start_, context, request);
271 : }
272 :
273 0 : ::grpc::Status ReconnectService::Stub::Stop(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::ReconnectInfo* response) {
274 0 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_Stop_, context, request, response);
275 : }
276 :
277 0 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::ReconnectInfo>* ReconnectService::Stub::AsyncStopRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
278 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::testing::ReconnectInfo>(channel_.get(), cq, rpcmethod_Stop_, context, request);
279 : }
280 :
281 0 : ReconnectService::AsyncService::AsyncService() : ::grpc::AsynchronousService(ReconnectService_method_names, 2) {}
282 :
283 0 : ReconnectService::Service::~Service() {
284 0 : delete service_;
285 0 : }
286 :
287 0 : ::grpc::Status ReconnectService::Service::Start(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response) {
288 : (void) context;
289 : (void) request;
290 : (void) response;
291 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
292 : }
293 :
294 0 : void ReconnectService::AsyncService::RequestStart(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
295 0 : AsynchronousService::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
296 0 : }
297 :
298 0 : ::grpc::Status ReconnectService::Service::Stop(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::ReconnectInfo* response) {
299 : (void) context;
300 : (void) request;
301 : (void) response;
302 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
303 : }
304 :
305 0 : void ReconnectService::AsyncService::RequestStop(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::ReconnectInfo>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
306 0 : AsynchronousService::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
307 0 : }
308 :
309 0 : ::grpc::RpcService* ReconnectService::Service::service() {
310 0 : if (service_ != nullptr) {
311 0 : return service_;
312 : }
313 0 : service_ = new ::grpc::RpcService();
314 : service_->AddMethod(new ::grpc::RpcServiceMethod(
315 : ReconnectService_method_names[0],
316 : ::grpc::RpcMethod::NORMAL_RPC,
317 : new ::grpc::RpcMethodHandler< ReconnectService::Service, ::grpc::testing::Empty, ::grpc::testing::Empty>(
318 0 : std::mem_fn(&ReconnectService::Service::Start), this)));
319 : service_->AddMethod(new ::grpc::RpcServiceMethod(
320 : ReconnectService_method_names[1],
321 : ::grpc::RpcMethod::NORMAL_RPC,
322 : new ::grpc::RpcMethodHandler< ReconnectService::Service, ::grpc::testing::Empty, ::grpc::testing::ReconnectInfo>(
323 0 : std::mem_fn(&ReconnectService::Service::Stop), this)));
324 0 : return service_;
325 : }
326 :
327 :
328 : } // namespace grpc
329 : } // namespace testing
330 :
|
