message.grpc.pb.h 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554
  1. // Generated by the gRPC C++ plugin.
  2. // If you make any local change, they will be lost.
  3. // source: message.proto
  4. #ifndef GRPC_message_2eproto__INCLUDED
  5. #define GRPC_message_2eproto__INCLUDED
  6. #include "message.pb.h"
  7. #include <functional>
  8. #include <grpcpp/generic/async_generic_service.h>
  9. #include <grpcpp/support/async_stream.h>
  10. #include <grpcpp/support/async_unary_call.h>
  11. #include <grpcpp/support/client_callback.h>
  12. #include <grpcpp/client_context.h>
  13. #include <grpcpp/completion_queue.h>
  14. #include <grpcpp/support/message_allocator.h>
  15. #include <grpcpp/support/method_handler.h>
  16. #include <grpcpp/impl/proto_utils.h>
  17. #include <grpcpp/impl/rpc_method.h>
  18. #include <grpcpp/support/server_callback.h>
  19. #include <grpcpp/impl/server_callback_handlers.h>
  20. #include <grpcpp/server_context.h>
  21. #include <grpcpp/impl/service_type.h>
  22. #include <grpcpp/support/status.h>
  23. #include <grpcpp/support/stub_options.h>
  24. #include <grpcpp/support/sync_stream.h>
  25. namespace NavMessage {
  26. class NavExcutor final {
  27. public:
  28. static constexpr char const* service_full_name() {
  29. return "NavMessage.NavExcutor";
  30. }
  31. class StubInterface {
  32. public:
  33. virtual ~StubInterface() {}
  34. virtual ::grpc::Status Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::NavMessage::NavResponse* response) = 0;
  35. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> AsyncStart(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  36. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(AsyncStartRaw(context, request, cq));
  37. }
  38. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> PrepareAsyncStart(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  39. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(PrepareAsyncStartRaw(context, request, cq));
  40. }
  41. virtual ::grpc::Status Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::NavMessage::NavResponse* response) = 0;
  42. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> AsyncCancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  43. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(AsyncCancelRaw(context, request, cq));
  44. }
  45. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> PrepareAsyncCancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  46. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(PrepareAsyncCancelRaw(context, request, cq));
  47. }
  48. virtual ::grpc::Status ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::NavMessage::NavResponse* response) = 0;
  49. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> AsyncManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) {
  50. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(AsyncManualOperationRaw(context, request, cq));
  51. }
  52. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>> PrepareAsyncManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) {
  53. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>>(PrepareAsyncManualOperationRaw(context, request, cq));
  54. }
  55. class async_interface {
  56. public:
  57. virtual ~async_interface() {}
  58. virtual void Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) = 0;
  59. virtual void Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0;
  60. virtual void Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) = 0;
  61. virtual void Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0;
  62. virtual void ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) = 0;
  63. virtual void ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0;
  64. };
  65. typedef class async_interface experimental_async_interface;
  66. virtual class async_interface* async() { return nullptr; }
  67. class async_interface* experimental_async() { return async(); }
  68. private:
  69. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* AsyncStartRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) = 0;
  70. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* PrepareAsyncStartRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) = 0;
  71. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* AsyncCancelRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) = 0;
  72. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* PrepareAsyncCancelRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) = 0;
  73. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* AsyncManualOperationRaw(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) = 0;
  74. virtual ::grpc::ClientAsyncResponseReaderInterface< ::NavMessage::NavResponse>* PrepareAsyncManualOperationRaw(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) = 0;
  75. };
  76. class Stub final : public StubInterface {
  77. public:
  78. Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
  79. ::grpc::Status Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::NavMessage::NavResponse* response) override;
  80. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> AsyncStart(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  81. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(AsyncStartRaw(context, request, cq));
  82. }
  83. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> PrepareAsyncStart(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  84. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(PrepareAsyncStartRaw(context, request, cq));
  85. }
  86. ::grpc::Status Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::NavMessage::NavResponse* response) override;
  87. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> AsyncCancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  88. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(AsyncCancelRaw(context, request, cq));
  89. }
  90. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> PrepareAsyncCancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) {
  91. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(PrepareAsyncCancelRaw(context, request, cq));
  92. }
  93. ::grpc::Status ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::NavMessage::NavResponse* response) override;
  94. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> AsyncManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) {
  95. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(AsyncManualOperationRaw(context, request, cq));
  96. }
  97. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>> PrepareAsyncManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) {
  98. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>>(PrepareAsyncManualOperationRaw(context, request, cq));
  99. }
  100. class async final :
  101. public StubInterface::async_interface {
  102. public:
  103. void Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) override;
  104. void Start(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) override;
  105. void Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) override;
  106. void Cancel(::grpc::ClientContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) override;
  107. void ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response, std::function<void(::grpc::Status)>) override;
  108. void ManualOperation(::grpc::ClientContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response, ::grpc::ClientUnaryReactor* reactor) override;
  109. private:
  110. friend class Stub;
  111. explicit async(Stub* stub): stub_(stub) { }
  112. Stub* stub() { return stub_; }
  113. Stub* stub_;
  114. };
  115. class async* async() override { return &async_stub_; }
  116. private:
  117. std::shared_ptr< ::grpc::ChannelInterface> channel_;
  118. class async async_stub_{this};
  119. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* AsyncStartRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) override;
  120. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* PrepareAsyncStartRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) override;
  121. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* AsyncCancelRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) override;
  122. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* PrepareAsyncCancelRaw(::grpc::ClientContext* context, const ::NavMessage::NavCmd& request, ::grpc::CompletionQueue* cq) override;
  123. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* AsyncManualOperationRaw(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) override;
  124. ::grpc::ClientAsyncResponseReader< ::NavMessage::NavResponse>* PrepareAsyncManualOperationRaw(::grpc::ClientContext* context, const ::NavMessage::ManualCmd& request, ::grpc::CompletionQueue* cq) override;
  125. const ::grpc::internal::RpcMethod rpcmethod_Start_;
  126. const ::grpc::internal::RpcMethod rpcmethod_Cancel_;
  127. const ::grpc::internal::RpcMethod rpcmethod_ManualOperation_;
  128. };
  129. static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
  130. class Service : public ::grpc::Service {
  131. public:
  132. Service();
  133. virtual ~Service();
  134. virtual ::grpc::Status Start(::grpc::ServerContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response);
  135. virtual ::grpc::Status Cancel(::grpc::ServerContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response);
  136. virtual ::grpc::Status ManualOperation(::grpc::ServerContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response);
  137. };
  138. template <class BaseClass>
  139. class WithAsyncMethod_Start : public BaseClass {
  140. private:
  141. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  142. public:
  143. WithAsyncMethod_Start() {
  144. ::grpc::Service::MarkMethodAsync(0);
  145. }
  146. ~WithAsyncMethod_Start() override {
  147. BaseClassMustBeDerivedFromService(this);
  148. }
  149. // disable synchronous version of this method
  150. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  151. abort();
  152. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  153. }
  154. void RequestStart(::grpc::ServerContext* context, ::NavMessage::NavCmd* request, ::grpc::ServerAsyncResponseWriter< ::NavMessage::NavResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  155. ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
  156. }
  157. };
  158. template <class BaseClass>
  159. class WithAsyncMethod_Cancel : public BaseClass {
  160. private:
  161. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  162. public:
  163. WithAsyncMethod_Cancel() {
  164. ::grpc::Service::MarkMethodAsync(1);
  165. }
  166. ~WithAsyncMethod_Cancel() override {
  167. BaseClassMustBeDerivedFromService(this);
  168. }
  169. // disable synchronous version of this method
  170. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  171. abort();
  172. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  173. }
  174. void RequestCancel(::grpc::ServerContext* context, ::NavMessage::NavCmd* request, ::grpc::ServerAsyncResponseWriter< ::NavMessage::NavResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  175. ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
  176. }
  177. };
  178. template <class BaseClass>
  179. class WithAsyncMethod_ManualOperation : public BaseClass {
  180. private:
  181. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  182. public:
  183. WithAsyncMethod_ManualOperation() {
  184. ::grpc::Service::MarkMethodAsync(2);
  185. }
  186. ~WithAsyncMethod_ManualOperation() override {
  187. BaseClassMustBeDerivedFromService(this);
  188. }
  189. // disable synchronous version of this method
  190. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  191. abort();
  192. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  193. }
  194. void RequestManualOperation(::grpc::ServerContext* context, ::NavMessage::ManualCmd* request, ::grpc::ServerAsyncResponseWriter< ::NavMessage::NavResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  195. ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag);
  196. }
  197. };
  198. typedef WithAsyncMethod_Start<WithAsyncMethod_Cancel<WithAsyncMethod_ManualOperation<Service > > > AsyncService;
  199. template <class BaseClass>
  200. class WithCallbackMethod_Start : public BaseClass {
  201. private:
  202. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  203. public:
  204. WithCallbackMethod_Start() {
  205. ::grpc::Service::MarkMethodCallback(0,
  206. new ::grpc::internal::CallbackUnaryHandler< ::NavMessage::NavCmd, ::NavMessage::NavResponse>(
  207. [this](
  208. ::grpc::CallbackServerContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response) { return this->Start(context, request, response); }));}
  209. void SetMessageAllocatorFor_Start(
  210. ::grpc::MessageAllocator< ::NavMessage::NavCmd, ::NavMessage::NavResponse>* allocator) {
  211. ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(0);
  212. static_cast<::grpc::internal::CallbackUnaryHandler< ::NavMessage::NavCmd, ::NavMessage::NavResponse>*>(handler)
  213. ->SetMessageAllocator(allocator);
  214. }
  215. ~WithCallbackMethod_Start() override {
  216. BaseClassMustBeDerivedFromService(this);
  217. }
  218. // disable synchronous version of this method
  219. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  220. abort();
  221. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  222. }
  223. virtual ::grpc::ServerUnaryReactor* Start(
  224. ::grpc::CallbackServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) { return nullptr; }
  225. };
  226. template <class BaseClass>
  227. class WithCallbackMethod_Cancel : public BaseClass {
  228. private:
  229. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  230. public:
  231. WithCallbackMethod_Cancel() {
  232. ::grpc::Service::MarkMethodCallback(1,
  233. new ::grpc::internal::CallbackUnaryHandler< ::NavMessage::NavCmd, ::NavMessage::NavResponse>(
  234. [this](
  235. ::grpc::CallbackServerContext* context, const ::NavMessage::NavCmd* request, ::NavMessage::NavResponse* response) { return this->Cancel(context, request, response); }));}
  236. void SetMessageAllocatorFor_Cancel(
  237. ::grpc::MessageAllocator< ::NavMessage::NavCmd, ::NavMessage::NavResponse>* allocator) {
  238. ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(1);
  239. static_cast<::grpc::internal::CallbackUnaryHandler< ::NavMessage::NavCmd, ::NavMessage::NavResponse>*>(handler)
  240. ->SetMessageAllocator(allocator);
  241. }
  242. ~WithCallbackMethod_Cancel() override {
  243. BaseClassMustBeDerivedFromService(this);
  244. }
  245. // disable synchronous version of this method
  246. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  247. abort();
  248. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  249. }
  250. virtual ::grpc::ServerUnaryReactor* Cancel(
  251. ::grpc::CallbackServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) { return nullptr; }
  252. };
  253. template <class BaseClass>
  254. class WithCallbackMethod_ManualOperation : public BaseClass {
  255. private:
  256. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  257. public:
  258. WithCallbackMethod_ManualOperation() {
  259. ::grpc::Service::MarkMethodCallback(2,
  260. new ::grpc::internal::CallbackUnaryHandler< ::NavMessage::ManualCmd, ::NavMessage::NavResponse>(
  261. [this](
  262. ::grpc::CallbackServerContext* context, const ::NavMessage::ManualCmd* request, ::NavMessage::NavResponse* response) { return this->ManualOperation(context, request, response); }));}
  263. void SetMessageAllocatorFor_ManualOperation(
  264. ::grpc::MessageAllocator< ::NavMessage::ManualCmd, ::NavMessage::NavResponse>* allocator) {
  265. ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(2);
  266. static_cast<::grpc::internal::CallbackUnaryHandler< ::NavMessage::ManualCmd, ::NavMessage::NavResponse>*>(handler)
  267. ->SetMessageAllocator(allocator);
  268. }
  269. ~WithCallbackMethod_ManualOperation() override {
  270. BaseClassMustBeDerivedFromService(this);
  271. }
  272. // disable synchronous version of this method
  273. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  274. abort();
  275. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  276. }
  277. virtual ::grpc::ServerUnaryReactor* ManualOperation(
  278. ::grpc::CallbackServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) { return nullptr; }
  279. };
  280. typedef WithCallbackMethod_Start<WithCallbackMethod_Cancel<WithCallbackMethod_ManualOperation<Service > > > CallbackService;
  281. typedef CallbackService ExperimentalCallbackService;
  282. template <class BaseClass>
  283. class WithGenericMethod_Start : public BaseClass {
  284. private:
  285. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  286. public:
  287. WithGenericMethod_Start() {
  288. ::grpc::Service::MarkMethodGeneric(0);
  289. }
  290. ~WithGenericMethod_Start() override {
  291. BaseClassMustBeDerivedFromService(this);
  292. }
  293. // disable synchronous version of this method
  294. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  295. abort();
  296. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  297. }
  298. };
  299. template <class BaseClass>
  300. class WithGenericMethod_Cancel : public BaseClass {
  301. private:
  302. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  303. public:
  304. WithGenericMethod_Cancel() {
  305. ::grpc::Service::MarkMethodGeneric(1);
  306. }
  307. ~WithGenericMethod_Cancel() override {
  308. BaseClassMustBeDerivedFromService(this);
  309. }
  310. // disable synchronous version of this method
  311. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  312. abort();
  313. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  314. }
  315. };
  316. template <class BaseClass>
  317. class WithGenericMethod_ManualOperation : public BaseClass {
  318. private:
  319. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  320. public:
  321. WithGenericMethod_ManualOperation() {
  322. ::grpc::Service::MarkMethodGeneric(2);
  323. }
  324. ~WithGenericMethod_ManualOperation() override {
  325. BaseClassMustBeDerivedFromService(this);
  326. }
  327. // disable synchronous version of this method
  328. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  329. abort();
  330. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  331. }
  332. };
  333. template <class BaseClass>
  334. class WithRawMethod_Start : public BaseClass {
  335. private:
  336. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  337. public:
  338. WithRawMethod_Start() {
  339. ::grpc::Service::MarkMethodRaw(0);
  340. }
  341. ~WithRawMethod_Start() override {
  342. BaseClassMustBeDerivedFromService(this);
  343. }
  344. // disable synchronous version of this method
  345. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  346. abort();
  347. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  348. }
  349. void RequestStart(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  350. ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
  351. }
  352. };
  353. template <class BaseClass>
  354. class WithRawMethod_Cancel : public BaseClass {
  355. private:
  356. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  357. public:
  358. WithRawMethod_Cancel() {
  359. ::grpc::Service::MarkMethodRaw(1);
  360. }
  361. ~WithRawMethod_Cancel() override {
  362. BaseClassMustBeDerivedFromService(this);
  363. }
  364. // disable synchronous version of this method
  365. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  366. abort();
  367. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  368. }
  369. void RequestCancel(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  370. ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
  371. }
  372. };
  373. template <class BaseClass>
  374. class WithRawMethod_ManualOperation : public BaseClass {
  375. private:
  376. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  377. public:
  378. WithRawMethod_ManualOperation() {
  379. ::grpc::Service::MarkMethodRaw(2);
  380. }
  381. ~WithRawMethod_ManualOperation() override {
  382. BaseClassMustBeDerivedFromService(this);
  383. }
  384. // disable synchronous version of this method
  385. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  386. abort();
  387. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  388. }
  389. void RequestManualOperation(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  390. ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag);
  391. }
  392. };
  393. template <class BaseClass>
  394. class WithRawCallbackMethod_Start : public BaseClass {
  395. private:
  396. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  397. public:
  398. WithRawCallbackMethod_Start() {
  399. ::grpc::Service::MarkMethodRawCallback(0,
  400. new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
  401. [this](
  402. ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->Start(context, request, response); }));
  403. }
  404. ~WithRawCallbackMethod_Start() override {
  405. BaseClassMustBeDerivedFromService(this);
  406. }
  407. // disable synchronous version of this method
  408. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  409. abort();
  410. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  411. }
  412. virtual ::grpc::ServerUnaryReactor* Start(
  413. ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; }
  414. };
  415. template <class BaseClass>
  416. class WithRawCallbackMethod_Cancel : public BaseClass {
  417. private:
  418. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  419. public:
  420. WithRawCallbackMethod_Cancel() {
  421. ::grpc::Service::MarkMethodRawCallback(1,
  422. new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
  423. [this](
  424. ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->Cancel(context, request, response); }));
  425. }
  426. ~WithRawCallbackMethod_Cancel() override {
  427. BaseClassMustBeDerivedFromService(this);
  428. }
  429. // disable synchronous version of this method
  430. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  431. abort();
  432. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  433. }
  434. virtual ::grpc::ServerUnaryReactor* Cancel(
  435. ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; }
  436. };
  437. template <class BaseClass>
  438. class WithRawCallbackMethod_ManualOperation : public BaseClass {
  439. private:
  440. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  441. public:
  442. WithRawCallbackMethod_ManualOperation() {
  443. ::grpc::Service::MarkMethodRawCallback(2,
  444. new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
  445. [this](
  446. ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->ManualOperation(context, request, response); }));
  447. }
  448. ~WithRawCallbackMethod_ManualOperation() override {
  449. BaseClassMustBeDerivedFromService(this);
  450. }
  451. // disable synchronous version of this method
  452. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  453. abort();
  454. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  455. }
  456. virtual ::grpc::ServerUnaryReactor* ManualOperation(
  457. ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; }
  458. };
  459. template <class BaseClass>
  460. class WithStreamedUnaryMethod_Start : public BaseClass {
  461. private:
  462. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  463. public:
  464. WithStreamedUnaryMethod_Start() {
  465. ::grpc::Service::MarkMethodStreamed(0,
  466. new ::grpc::internal::StreamedUnaryHandler<
  467. ::NavMessage::NavCmd, ::NavMessage::NavResponse>(
  468. [this](::grpc::ServerContext* context,
  469. ::grpc::ServerUnaryStreamer<
  470. ::NavMessage::NavCmd, ::NavMessage::NavResponse>* streamer) {
  471. return this->StreamedStart(context,
  472. streamer);
  473. }));
  474. }
  475. ~WithStreamedUnaryMethod_Start() override {
  476. BaseClassMustBeDerivedFromService(this);
  477. }
  478. // disable regular version of this method
  479. ::grpc::Status Start(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  480. abort();
  481. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  482. }
  483. // replace default version of method with streamed unary
  484. virtual ::grpc::Status StreamedStart(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::NavMessage::NavCmd,::NavMessage::NavResponse>* server_unary_streamer) = 0;
  485. };
  486. template <class BaseClass>
  487. class WithStreamedUnaryMethod_Cancel : public BaseClass {
  488. private:
  489. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  490. public:
  491. WithStreamedUnaryMethod_Cancel() {
  492. ::grpc::Service::MarkMethodStreamed(1,
  493. new ::grpc::internal::StreamedUnaryHandler<
  494. ::NavMessage::NavCmd, ::NavMessage::NavResponse>(
  495. [this](::grpc::ServerContext* context,
  496. ::grpc::ServerUnaryStreamer<
  497. ::NavMessage::NavCmd, ::NavMessage::NavResponse>* streamer) {
  498. return this->StreamedCancel(context,
  499. streamer);
  500. }));
  501. }
  502. ~WithStreamedUnaryMethod_Cancel() override {
  503. BaseClassMustBeDerivedFromService(this);
  504. }
  505. // disable regular version of this method
  506. ::grpc::Status Cancel(::grpc::ServerContext* /*context*/, const ::NavMessage::NavCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  507. abort();
  508. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  509. }
  510. // replace default version of method with streamed unary
  511. virtual ::grpc::Status StreamedCancel(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::NavMessage::NavCmd,::NavMessage::NavResponse>* server_unary_streamer) = 0;
  512. };
  513. template <class BaseClass>
  514. class WithStreamedUnaryMethod_ManualOperation : public BaseClass {
  515. private:
  516. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  517. public:
  518. WithStreamedUnaryMethod_ManualOperation() {
  519. ::grpc::Service::MarkMethodStreamed(2,
  520. new ::grpc::internal::StreamedUnaryHandler<
  521. ::NavMessage::ManualCmd, ::NavMessage::NavResponse>(
  522. [this](::grpc::ServerContext* context,
  523. ::grpc::ServerUnaryStreamer<
  524. ::NavMessage::ManualCmd, ::NavMessage::NavResponse>* streamer) {
  525. return this->StreamedManualOperation(context,
  526. streamer);
  527. }));
  528. }
  529. ~WithStreamedUnaryMethod_ManualOperation() override {
  530. BaseClassMustBeDerivedFromService(this);
  531. }
  532. // disable regular version of this method
  533. ::grpc::Status ManualOperation(::grpc::ServerContext* /*context*/, const ::NavMessage::ManualCmd* /*request*/, ::NavMessage::NavResponse* /*response*/) override {
  534. abort();
  535. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  536. }
  537. // replace default version of method with streamed unary
  538. virtual ::grpc::Status StreamedManualOperation(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::NavMessage::ManualCmd,::NavMessage::NavResponse>* server_unary_streamer) = 0;
  539. };
  540. typedef WithStreamedUnaryMethod_Start<WithStreamedUnaryMethod_Cancel<WithStreamedUnaryMethod_ManualOperation<Service > > > StreamedUnaryService;
  541. typedef Service SplitStreamedService;
  542. typedef WithStreamedUnaryMethod_Start<WithStreamedUnaryMethod_Cancel<WithStreamedUnaryMethod_ManualOperation<Service > > > StreamedService;
  543. };
  544. } // namespace NavMessage
  545. #endif // GRPC_message_2eproto__INCLUDED