device-c.grpc.pb.cc 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424
  1. // Generated by the gRPC C++ plugin.
  2. // If you make any local change, they will be lost.
  3. // source: device/v3/device-c.proto
  4. #include "device/v3/device-c.pb.h"
  5. #include "device/v3/device-c.grpc.pb.h"
  6. #include <functional>
  7. #include <grpcpp/support/async_stream.h>
  8. #include <grpcpp/support/async_unary_call.h>
  9. #include <grpcpp/impl/channel_interface.h>
  10. #include <grpcpp/impl/client_unary_call.h>
  11. #include <grpcpp/support/client_callback.h>
  12. #include <grpcpp/support/message_allocator.h>
  13. #include <grpcpp/support/method_handler.h>
  14. #include <grpcpp/impl/rpc_service_method.h>
  15. #include <grpcpp/support/server_callback.h>
  16. #include <grpcpp/impl/server_callback_handlers.h>
  17. #include <grpcpp/server_context.h>
  18. #include <grpcpp/impl/service_type.h>
  19. #include <grpcpp/support/sync_stream.h>
  20. namespace Device {
  21. namespace V3 {
  22. static const char* Device_method_names[] = {
  23. "/Device.V3.Device/Open",
  24. "/Device.V3.Device/Close",
  25. "/Device.V3.Device/Get",
  26. "/Device.V3.Device/Set",
  27. "/Device.V3.Device/Update",
  28. "/Device.V3.Device/Add",
  29. "/Device.V3.Device/Del",
  30. "/Device.V3.Device/Action",
  31. "/Device.V3.Device/Message",
  32. };
  33. std::unique_ptr< Device::Stub> Device::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) {
  34. (void)options;
  35. std::unique_ptr< Device::Stub> stub(new Device::Stub(channel, options));
  36. return stub;
  37. }
  38. Device::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options)
  39. : channel_(channel), rpcmethod_Open_(Device_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  40. , rpcmethod_Close_(Device_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  41. , rpcmethod_Get_(Device_method_names[2], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  42. , rpcmethod_Set_(Device_method_names[3], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  43. , rpcmethod_Update_(Device_method_names[4], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  44. , rpcmethod_Add_(Device_method_names[5], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  45. , rpcmethod_Del_(Device_method_names[6], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  46. , rpcmethod_Action_(Device_method_names[7], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  47. , rpcmethod_Message_(Device_method_names[8], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
  48. {}
  49. ::grpc::Status Device::Stub::Open(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::Device::V3::OpenReply* response) {
  50. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Open_, context, request, response);
  51. }
  52. void Device::Stub::async::Open(::grpc::ClientContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response, std::function<void(::grpc::Status)> f) {
  53. ::grpc::internal::CallbackUnaryCall< ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Open_, context, request, response, std::move(f));
  54. }
  55. void Device::Stub::async::Open(::grpc::ClientContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response, ::grpc::ClientUnaryReactor* reactor) {
  56. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Open_, context, request, response, reactor);
  57. }
  58. ::grpc::ClientAsyncResponseReader< ::Device::V3::OpenReply>* Device::Stub::PrepareAsyncOpenRaw(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::grpc::CompletionQueue* cq) {
  59. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::OpenReply, ::Device::V3::OpenRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Open_, context, request);
  60. }
  61. ::grpc::ClientAsyncResponseReader< ::Device::V3::OpenReply>* Device::Stub::AsyncOpenRaw(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::grpc::CompletionQueue* cq) {
  62. auto* result =
  63. this->PrepareAsyncOpenRaw(context, request, cq);
  64. result->StartCall();
  65. return result;
  66. }
  67. ::grpc::Status Device::Stub::Close(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::Device::V3::OpenReply* response) {
  68. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Close_, context, request, response);
  69. }
  70. void Device::Stub::async::Close(::grpc::ClientContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response, std::function<void(::grpc::Status)> f) {
  71. ::grpc::internal::CallbackUnaryCall< ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Close_, context, request, response, std::move(f));
  72. }
  73. void Device::Stub::async::Close(::grpc::ClientContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response, ::grpc::ClientUnaryReactor* reactor) {
  74. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Close_, context, request, response, reactor);
  75. }
  76. ::grpc::ClientAsyncResponseReader< ::Device::V3::OpenReply>* Device::Stub::PrepareAsyncCloseRaw(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::grpc::CompletionQueue* cq) {
  77. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::OpenReply, ::Device::V3::OpenRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Close_, context, request);
  78. }
  79. ::grpc::ClientAsyncResponseReader< ::Device::V3::OpenReply>* Device::Stub::AsyncCloseRaw(::grpc::ClientContext* context, const ::Device::V3::OpenRequest& request, ::grpc::CompletionQueue* cq) {
  80. auto* result =
  81. this->PrepareAsyncCloseRaw(context, request, cq);
  82. result->StartCall();
  83. return result;
  84. }
  85. ::grpc::Status Device::Stub::Get(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  86. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Get_, context, request, response);
  87. }
  88. void Device::Stub::async::Get(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  89. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Get_, context, request, response, std::move(f));
  90. }
  91. void Device::Stub::async::Get(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  92. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Get_, context, request, response, reactor);
  93. }
  94. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncGetRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  95. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Get_, context, request);
  96. }
  97. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncGetRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  98. auto* result =
  99. this->PrepareAsyncGetRaw(context, request, cq);
  100. result->StartCall();
  101. return result;
  102. }
  103. ::grpc::Status Device::Stub::Set(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  104. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Set_, context, request, response);
  105. }
  106. void Device::Stub::async::Set(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  107. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Set_, context, request, response, std::move(f));
  108. }
  109. void Device::Stub::async::Set(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  110. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Set_, context, request, response, reactor);
  111. }
  112. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncSetRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  113. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Set_, context, request);
  114. }
  115. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncSetRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  116. auto* result =
  117. this->PrepareAsyncSetRaw(context, request, cq);
  118. result->StartCall();
  119. return result;
  120. }
  121. ::grpc::Status Device::Stub::Update(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  122. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Update_, context, request, response);
  123. }
  124. void Device::Stub::async::Update(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  125. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Update_, context, request, response, std::move(f));
  126. }
  127. void Device::Stub::async::Update(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  128. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Update_, context, request, response, reactor);
  129. }
  130. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncUpdateRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  131. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Update_, context, request);
  132. }
  133. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncUpdateRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  134. auto* result =
  135. this->PrepareAsyncUpdateRaw(context, request, cq);
  136. result->StartCall();
  137. return result;
  138. }
  139. ::grpc::Status Device::Stub::Add(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  140. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Add_, context, request, response);
  141. }
  142. void Device::Stub::async::Add(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  143. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Add_, context, request, response, std::move(f));
  144. }
  145. void Device::Stub::async::Add(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  146. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Add_, context, request, response, reactor);
  147. }
  148. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncAddRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  149. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Add_, context, request);
  150. }
  151. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncAddRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  152. auto* result =
  153. this->PrepareAsyncAddRaw(context, request, cq);
  154. result->StartCall();
  155. return result;
  156. }
  157. ::grpc::Status Device::Stub::Del(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  158. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Del_, context, request, response);
  159. }
  160. void Device::Stub::async::Del(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  161. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Del_, context, request, response, std::move(f));
  162. }
  163. void Device::Stub::async::Del(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  164. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Del_, context, request, response, reactor);
  165. }
  166. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncDelRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  167. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Del_, context, request);
  168. }
  169. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncDelRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  170. auto* result =
  171. this->PrepareAsyncDelRaw(context, request, cq);
  172. result->StartCall();
  173. return result;
  174. }
  175. ::grpc::Status Device::Stub::Action(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  176. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Action_, context, request, response);
  177. }
  178. void Device::Stub::async::Action(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  179. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Action_, context, request, response, std::move(f));
  180. }
  181. void Device::Stub::async::Action(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  182. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Action_, context, request, response, reactor);
  183. }
  184. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncActionRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  185. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Action_, context, request);
  186. }
  187. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncActionRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  188. auto* result =
  189. this->PrepareAsyncActionRaw(context, request, cq);
  190. result->StartCall();
  191. return result;
  192. }
  193. ::grpc::Status Device::Stub::Message(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::Device::V3::DoResponse* response) {
  194. return ::grpc::internal::BlockingUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Message_, context, request, response);
  195. }
  196. void Device::Stub::async::Message(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, std::function<void(::grpc::Status)> f) {
  197. ::grpc::internal::CallbackUnaryCall< ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Message_, context, request, response, std::move(f));
  198. }
  199. void Device::Stub::async::Message(::grpc::ClientContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response, ::grpc::ClientUnaryReactor* reactor) {
  200. ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Message_, context, request, response, reactor);
  201. }
  202. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::PrepareAsyncMessageRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  203. return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::Device::V3::DoResponse, ::Device::V3::DoRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Message_, context, request);
  204. }
  205. ::grpc::ClientAsyncResponseReader< ::Device::V3::DoResponse>* Device::Stub::AsyncMessageRaw(::grpc::ClientContext* context, const ::Device::V3::DoRequest& request, ::grpc::CompletionQueue* cq) {
  206. auto* result =
  207. this->PrepareAsyncMessageRaw(context, request, cq);
  208. result->StartCall();
  209. return result;
  210. }
  211. Device::Service::Service() {
  212. AddMethod(new ::grpc::internal::RpcServiceMethod(
  213. Device_method_names[0],
  214. ::grpc::internal::RpcMethod::NORMAL_RPC,
  215. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  216. [](Device::Service* service,
  217. ::grpc::ServerContext* ctx,
  218. const ::Device::V3::OpenRequest* req,
  219. ::Device::V3::OpenReply* resp) {
  220. return service->Open(ctx, req, resp);
  221. }, this)));
  222. AddMethod(new ::grpc::internal::RpcServiceMethod(
  223. Device_method_names[1],
  224. ::grpc::internal::RpcMethod::NORMAL_RPC,
  225. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::OpenRequest, ::Device::V3::OpenReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  226. [](Device::Service* service,
  227. ::grpc::ServerContext* ctx,
  228. const ::Device::V3::OpenRequest* req,
  229. ::Device::V3::OpenReply* resp) {
  230. return service->Close(ctx, req, resp);
  231. }, this)));
  232. AddMethod(new ::grpc::internal::RpcServiceMethod(
  233. Device_method_names[2],
  234. ::grpc::internal::RpcMethod::NORMAL_RPC,
  235. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  236. [](Device::Service* service,
  237. ::grpc::ServerContext* ctx,
  238. const ::Device::V3::DoRequest* req,
  239. ::Device::V3::DoResponse* resp) {
  240. return service->Get(ctx, req, resp);
  241. }, this)));
  242. AddMethod(new ::grpc::internal::RpcServiceMethod(
  243. Device_method_names[3],
  244. ::grpc::internal::RpcMethod::NORMAL_RPC,
  245. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  246. [](Device::Service* service,
  247. ::grpc::ServerContext* ctx,
  248. const ::Device::V3::DoRequest* req,
  249. ::Device::V3::DoResponse* resp) {
  250. return service->Set(ctx, req, resp);
  251. }, this)));
  252. AddMethod(new ::grpc::internal::RpcServiceMethod(
  253. Device_method_names[4],
  254. ::grpc::internal::RpcMethod::NORMAL_RPC,
  255. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  256. [](Device::Service* service,
  257. ::grpc::ServerContext* ctx,
  258. const ::Device::V3::DoRequest* req,
  259. ::Device::V3::DoResponse* resp) {
  260. return service->Update(ctx, req, resp);
  261. }, this)));
  262. AddMethod(new ::grpc::internal::RpcServiceMethod(
  263. Device_method_names[5],
  264. ::grpc::internal::RpcMethod::NORMAL_RPC,
  265. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  266. [](Device::Service* service,
  267. ::grpc::ServerContext* ctx,
  268. const ::Device::V3::DoRequest* req,
  269. ::Device::V3::DoResponse* resp) {
  270. return service->Add(ctx, req, resp);
  271. }, this)));
  272. AddMethod(new ::grpc::internal::RpcServiceMethod(
  273. Device_method_names[6],
  274. ::grpc::internal::RpcMethod::NORMAL_RPC,
  275. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  276. [](Device::Service* service,
  277. ::grpc::ServerContext* ctx,
  278. const ::Device::V3::DoRequest* req,
  279. ::Device::V3::DoResponse* resp) {
  280. return service->Del(ctx, req, resp);
  281. }, this)));
  282. AddMethod(new ::grpc::internal::RpcServiceMethod(
  283. Device_method_names[7],
  284. ::grpc::internal::RpcMethod::NORMAL_RPC,
  285. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  286. [](Device::Service* service,
  287. ::grpc::ServerContext* ctx,
  288. const ::Device::V3::DoRequest* req,
  289. ::Device::V3::DoResponse* resp) {
  290. return service->Action(ctx, req, resp);
  291. }, this)));
  292. AddMethod(new ::grpc::internal::RpcServiceMethod(
  293. Device_method_names[8],
  294. ::grpc::internal::RpcMethod::NORMAL_RPC,
  295. new ::grpc::internal::RpcMethodHandler< Device::Service, ::Device::V3::DoRequest, ::Device::V3::DoResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(
  296. [](Device::Service* service,
  297. ::grpc::ServerContext* ctx,
  298. const ::Device::V3::DoRequest* req,
  299. ::Device::V3::DoResponse* resp) {
  300. return service->Message(ctx, req, resp);
  301. }, this)));
  302. }
  303. Device::Service::~Service() {
  304. }
  305. ::grpc::Status Device::Service::Open(::grpc::ServerContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response) {
  306. (void) context;
  307. (void) request;
  308. (void) response;
  309. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  310. }
  311. ::grpc::Status Device::Service::Close(::grpc::ServerContext* context, const ::Device::V3::OpenRequest* request, ::Device::V3::OpenReply* response) {
  312. (void) context;
  313. (void) request;
  314. (void) response;
  315. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  316. }
  317. ::grpc::Status Device::Service::Get(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  318. (void) context;
  319. (void) request;
  320. (void) response;
  321. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  322. }
  323. ::grpc::Status Device::Service::Set(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  324. (void) context;
  325. (void) request;
  326. (void) response;
  327. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  328. }
  329. ::grpc::Status Device::Service::Update(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  330. (void) context;
  331. (void) request;
  332. (void) response;
  333. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  334. }
  335. ::grpc::Status Device::Service::Add(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  336. (void) context;
  337. (void) request;
  338. (void) response;
  339. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  340. }
  341. ::grpc::Status Device::Service::Del(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  342. (void) context;
  343. (void) request;
  344. (void) response;
  345. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  346. }
  347. ::grpc::Status Device::Service::Action(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  348. (void) context;
  349. (void) request;
  350. (void) response;
  351. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  352. }
  353. ::grpc::Status Device::Service::Message(::grpc::ServerContext* context, const ::Device::V3::DoRequest* request, ::Device::V3::DoResponse* response) {
  354. (void) context;
  355. (void) request;
  356. (void) response;
  357. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  358. }
  359. } // namespace Device
  360. } // namespace V3