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/qps/qpstest.proto
4 : #ifndef GRPC_test_2fcpp_2fqps_2fqpstest_2eproto__INCLUDED
5 : #define GRPC_test_2fcpp_2fqps_2fqpstest_2eproto__INCLUDED
6 :
7 : #include "test/cpp/qps/qpstest.pb.h"
8 :
9 : #include <grpc++/support/async_stream.h>
10 : #include <grpc++/impl/rpc_method.h>
11 : #include <grpc++/impl/proto_utils.h>
12 : #include <grpc++/impl/service_type.h>
13 : #include <grpc++/support/async_unary_call.h>
14 : #include <grpc++/support/status.h>
15 : #include <grpc++/support/stub_options.h>
16 : #include <grpc++/support/sync_stream.h>
17 :
18 : namespace grpc {
19 : class CompletionQueue;
20 : class Channel;
21 : class RpcService;
22 : class ServerCompletionQueue;
23 : class ServerContext;
24 : } // namespace grpc
25 :
26 : namespace grpc {
27 : namespace testing {
28 :
29 : class TestService GRPC_FINAL {
30 : public:
31 20 : class StubInterface {
32 : public:
33 20 : virtual ~StubInterface() {}
34 : virtual ::grpc::Status UnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::testing::SimpleResponse* response) = 0;
35 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>> AsyncUnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) {
36 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>>(AsyncUnaryCallRaw(context, request, cq));
37 : }
38 : std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>> StreamingCall(::grpc::ClientContext* context) {
39 : return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>>(StreamingCallRaw(context));
40 : }
41 : std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>> AsyncStreamingCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
42 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>>(AsyncStreamingCallRaw(context, cq, tag));
43 : }
44 : private:
45 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>* AsyncUnaryCallRaw(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) = 0;
46 : virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>* StreamingCallRaw(::grpc::ClientContext* context) = 0;
47 : virtual ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>* AsyncStreamingCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
48 : };
49 40 : class Stub GRPC_FINAL : public StubInterface {
50 : public:
51 : Stub(const std::shared_ptr< ::grpc::Channel>& channel);
52 : ::grpc::Status UnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::testing::SimpleResponse* response) GRPC_OVERRIDE;
53 1138495 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>> AsyncUnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) {
54 1138495 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>>(AsyncUnaryCallRaw(context, request, cq));
55 : }
56 1 : std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>> StreamingCall(::grpc::ClientContext* context) {
57 1 : return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>>(StreamingCallRaw(context));
58 : }
59 1 : std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>> AsyncStreamingCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
60 1 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>>(AsyncStreamingCallRaw(context, cq, tag));
61 : }
62 :
63 : private:
64 : std::shared_ptr< ::grpc::Channel> channel_;
65 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>* AsyncUnaryCallRaw(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
66 : ::grpc::ClientReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>* StreamingCallRaw(::grpc::ClientContext* context) GRPC_OVERRIDE;
67 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::SimpleRequest, ::grpc::testing::SimpleResponse>* AsyncStreamingCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
68 : const ::grpc::RpcMethod rpcmethod_UnaryCall_;
69 : const ::grpc::RpcMethod rpcmethod_StreamingCall_;
70 : };
71 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
72 :
73 : class Service : public ::grpc::SynchronousService {
74 : public:
75 2 : Service() : service_(nullptr) {}
76 : virtual ~Service();
77 : virtual ::grpc::Status UnaryCall(::grpc::ServerContext* context, const ::grpc::testing::SimpleRequest* request, ::grpc::testing::SimpleResponse* response);
78 : virtual ::grpc::Status StreamingCall(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::SimpleResponse, ::grpc::testing::SimpleRequest>* stream);
79 : ::grpc::RpcService* service() GRPC_OVERRIDE GRPC_FINAL;
80 : private:
81 : ::grpc::RpcService* service_;
82 : };
83 : class AsyncService GRPC_FINAL : public ::grpc::AsynchronousService {
84 : public:
85 : explicit AsyncService();
86 4 : ~AsyncService() {};
87 : void 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);
88 : void RequestStreamingCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::SimpleResponse, ::grpc::testing::SimpleRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
89 : };
90 : };
91 :
92 : class Worker GRPC_FINAL {
93 : public:
94 12 : class StubInterface {
95 : public:
96 12 : virtual ~StubInterface() {}
97 : std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>> RunTest(::grpc::ClientContext* context) {
98 : return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>>(RunTestRaw(context));
99 : }
100 : std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>> AsyncRunTest(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
101 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>>(AsyncRunTestRaw(context, cq, tag));
102 : }
103 : std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>> RunServer(::grpc::ClientContext* context) {
104 : return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>>(RunServerRaw(context));
105 : }
106 : std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>> AsyncRunServer(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
107 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>>(AsyncRunServerRaw(context, cq, tag));
108 : }
109 : private:
110 : virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>* RunTestRaw(::grpc::ClientContext* context) = 0;
111 : virtual ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>* AsyncRunTestRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
112 : virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>* RunServerRaw(::grpc::ClientContext* context) = 0;
113 : virtual ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>* AsyncRunServerRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
114 : };
115 24 : class Stub GRPC_FINAL : public StubInterface {
116 : public:
117 : Stub(const std::shared_ptr< ::grpc::Channel>& channel);
118 6 : std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>> RunTest(::grpc::ClientContext* context) {
119 6 : return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>>(RunTestRaw(context));
120 : }
121 : std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>> AsyncRunTest(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
122 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>>(AsyncRunTestRaw(context, cq, tag));
123 : }
124 6 : std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>> RunServer(::grpc::ClientContext* context) {
125 6 : return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>>(RunServerRaw(context));
126 : }
127 : std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>> AsyncRunServer(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
128 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>>(AsyncRunServerRaw(context, cq, tag));
129 : }
130 :
131 : private:
132 : std::shared_ptr< ::grpc::Channel> channel_;
133 : ::grpc::ClientReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>* RunTestRaw(::grpc::ClientContext* context) GRPC_OVERRIDE;
134 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ClientArgs, ::grpc::testing::ClientStatus>* AsyncRunTestRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
135 : ::grpc::ClientReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>* RunServerRaw(::grpc::ClientContext* context) GRPC_OVERRIDE;
136 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::ServerArgs, ::grpc::testing::ServerStatus>* AsyncRunServerRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
137 : const ::grpc::RpcMethod rpcmethod_RunTest_;
138 : const ::grpc::RpcMethod rpcmethod_RunServer_;
139 : };
140 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
141 :
142 : class Service : public ::grpc::SynchronousService {
143 : public:
144 12 : Service() : service_(nullptr) {}
145 : virtual ~Service();
146 : virtual ::grpc::Status RunTest(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::ClientStatus, ::grpc::testing::ClientArgs>* stream);
147 : virtual ::grpc::Status RunServer(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::ServerStatus, ::grpc::testing::ServerArgs>* stream);
148 : ::grpc::RpcService* service() GRPC_OVERRIDE GRPC_FINAL;
149 : private:
150 : ::grpc::RpcService* service_;
151 : };
152 : class AsyncService GRPC_FINAL : public ::grpc::AsynchronousService {
153 : public:
154 : explicit AsyncService();
155 : ~AsyncService() {};
156 : void RequestRunTest(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::ClientStatus, ::grpc::testing::ClientArgs>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
157 : void RequestRunServer(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::ServerStatus, ::grpc::testing::ServerArgs>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
158 : };
159 : };
160 :
161 : } // namespace testing
162 : } // namespace grpc
163 :
164 :
165 : #endif // GRPC_test_2fcpp_2fqps_2fqpstest_2eproto__INCLUDED
|
