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/cpp/util/echo_duplicate.proto
4 :
5 : #include "test/cpp/util/echo_duplicate.pb.h"
6 : #include "test/cpp/util/echo_duplicate.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 cpp {
17 : namespace test {
18 : namespace util {
19 : namespace duplicate {
20 :
21 : static const char* TestService_method_names[] = {
22 : "/grpc.cpp.test.util.duplicate.TestService/Echo",
23 : };
24 :
25 2 : std::unique_ptr< TestService::Stub> TestService::NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options) {
26 2 : std::unique_ptr< TestService::Stub> stub(new TestService::Stub(channel));
27 2 : return stub;
28 : }
29 :
30 2 : TestService::Stub::Stub(const std::shared_ptr< ::grpc::Channel>& channel)
31 2 : : channel_(channel), rpcmethod_Echo_(TestService_method_names[0], ::grpc::RpcMethod::NORMAL_RPC, channel)
32 2 : {}
33 :
34 2 : ::grpc::Status TestService::Stub::Echo(::grpc::ClientContext* context, const ::grpc::cpp::test::util::EchoRequest& request, ::grpc::cpp::test::util::EchoResponse* response) {
35 2 : return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_Echo_, context, request, response);
36 : }
37 :
38 0 : ::grpc::ClientAsyncResponseReader< ::grpc::cpp::test::util::EchoResponse>* TestService::Stub::AsyncEchoRaw(::grpc::ClientContext* context, const ::grpc::cpp::test::util::EchoRequest& request, ::grpc::CompletionQueue* cq) {
39 0 : return new ::grpc::ClientAsyncResponseReader< ::grpc::cpp::test::util::EchoResponse>(channel_.get(), cq, rpcmethod_Echo_, context, request);
40 : }
41 :
42 0 : TestService::AsyncService::AsyncService() : ::grpc::AsynchronousService(TestService_method_names, 1) {}
43 :
44 170 : TestService::Service::~Service() {
45 85 : delete service_;
46 85 : }
47 :
48 0 : ::grpc::Status TestService::Service::Echo(::grpc::ServerContext* context, const ::grpc::cpp::test::util::EchoRequest* request, ::grpc::cpp::test::util::EchoResponse* response) {
49 : (void) context;
50 : (void) request;
51 : (void) response;
52 0 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
53 : }
54 :
55 0 : void TestService::AsyncService::RequestEcho(::grpc::ServerContext* context, ::grpc::cpp::test::util::EchoRequest* request, ::grpc::ServerAsyncResponseWriter< ::grpc::cpp::test::util::EchoResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
56 0 : AsynchronousService::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
57 0 : }
58 :
59 82 : ::grpc::RpcService* TestService::Service::service() {
60 82 : if (service_ != nullptr) {
61 0 : return service_;
62 : }
63 82 : service_ = new ::grpc::RpcService();
64 : service_->AddMethod(new ::grpc::RpcServiceMethod(
65 : TestService_method_names[0],
66 : ::grpc::RpcMethod::NORMAL_RPC,
67 : new ::grpc::RpcMethodHandler< TestService::Service, ::grpc::cpp::test::util::EchoRequest, ::grpc::cpp::test::util::EchoResponse>(
68 82 : std::mem_fn(&TestService::Service::Echo), this)));
69 82 : return service_;
70 : }
71 :
72 :
73 : } // namespace grpc
74 : } // namespace cpp
75 : } // namespace test
76 : } // namespace util
77 : } // namespace duplicate
78 :
|