// Generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: uploadmsg.proto #include "uploadmsg.pb.h" #include "uploadmsg.grpc.pb.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace iv { static const char* Upload_method_names[] = { "/iv.Upload/upload", "/iv.Upload/query", "/iv.Upload/ctrl", }; std::unique_ptr< Upload::Stub> Upload::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) { (void)options; std::unique_ptr< Upload::Stub> stub(new Upload::Stub(channel)); return stub; } Upload::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel) : channel_(channel), rpcmethod_upload_(Upload_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_query_(Upload_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_ctrl_(Upload_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel) {} ::grpc::Status Upload::Stub::upload(::grpc::ClientContext* context, const ::iv::UploadRequest& request, ::iv::UploadReply* response) { return ::grpc::internal::BlockingUnaryCall< ::iv::UploadRequest, ::iv::UploadReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_upload_, context, request, response); } void Upload::Stub::experimental_async::upload(::grpc::ClientContext* context, const ::iv::UploadRequest* request, ::iv::UploadReply* response, std::function f) { ::grpc::internal::CallbackUnaryCall< ::iv::UploadRequest, ::iv::UploadReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_upload_, context, request, response, std::move(f)); } void Upload::Stub::experimental_async::upload(::grpc::ClientContext* context, const ::iv::UploadRequest* request, ::iv::UploadReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_upload_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::iv::UploadReply>* Upload::Stub::PrepareAsyncuploadRaw(::grpc::ClientContext* context, const ::iv::UploadRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::iv::UploadReply, ::iv::UploadRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_upload_, context, request); } ::grpc::ClientAsyncResponseReader< ::iv::UploadReply>* Upload::Stub::AsyncuploadRaw(::grpc::ClientContext* context, const ::iv::UploadRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncuploadRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Upload::Stub::query(::grpc::ClientContext* context, const ::iv::queryreq& request, ::iv::queryReply* response) { return ::grpc::internal::BlockingUnaryCall< ::iv::queryreq, ::iv::queryReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_query_, context, request, response); } void Upload::Stub::experimental_async::query(::grpc::ClientContext* context, const ::iv::queryreq* request, ::iv::queryReply* response, std::function f) { ::grpc::internal::CallbackUnaryCall< ::iv::queryreq, ::iv::queryReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_query_, context, request, response, std::move(f)); } void Upload::Stub::experimental_async::query(::grpc::ClientContext* context, const ::iv::queryreq* request, ::iv::queryReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_query_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::iv::queryReply>* Upload::Stub::PrepareAsyncqueryRaw(::grpc::ClientContext* context, const ::iv::queryreq& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::iv::queryReply, ::iv::queryreq, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_query_, context, request); } ::grpc::ClientAsyncResponseReader< ::iv::queryReply>* Upload::Stub::AsyncqueryRaw(::grpc::ClientContext* context, const ::iv::queryreq& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncqueryRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Upload::Stub::ctrl(::grpc::ClientContext* context, const ::iv::ctrlreq& request, ::iv::ctrlReply* response) { return ::grpc::internal::BlockingUnaryCall< ::iv::ctrlreq, ::iv::ctrlReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_ctrl_, context, request, response); } void Upload::Stub::experimental_async::ctrl(::grpc::ClientContext* context, const ::iv::ctrlreq* request, ::iv::ctrlReply* response, std::function f) { ::grpc::internal::CallbackUnaryCall< ::iv::ctrlreq, ::iv::ctrlReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_ctrl_, context, request, response, std::move(f)); } void Upload::Stub::experimental_async::ctrl(::grpc::ClientContext* context, const ::iv::ctrlreq* request, ::iv::ctrlReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_ctrl_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::iv::ctrlReply>* Upload::Stub::PrepareAsyncctrlRaw(::grpc::ClientContext* context, const ::iv::ctrlreq& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::iv::ctrlReply, ::iv::ctrlreq, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_ctrl_, context, request); } ::grpc::ClientAsyncResponseReader< ::iv::ctrlReply>* Upload::Stub::AsyncctrlRaw(::grpc::ClientContext* context, const ::iv::ctrlreq& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncctrlRaw(context, request, cq); result->StartCall(); return result; } Upload::Service::Service() { AddMethod(new ::grpc::internal::RpcServiceMethod( Upload_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Upload::Service, ::iv::UploadRequest, ::iv::UploadReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Upload::Service* service, ::grpc::ServerContext* ctx, const ::iv::UploadRequest* req, ::iv::UploadReply* resp) { return service->upload(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Upload_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Upload::Service, ::iv::queryreq, ::iv::queryReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Upload::Service* service, ::grpc::ServerContext* ctx, const ::iv::queryreq* req, ::iv::queryReply* resp) { return service->query(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Upload_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Upload::Service, ::iv::ctrlreq, ::iv::ctrlReply, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Upload::Service* service, ::grpc::ServerContext* ctx, const ::iv::ctrlreq* req, ::iv::ctrlReply* resp) { return service->ctrl(ctx, req, resp); }, this))); } Upload::Service::~Service() { } ::grpc::Status Upload::Service::upload(::grpc::ServerContext* context, const ::iv::UploadRequest* request, ::iv::UploadReply* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Upload::Service::query(::grpc::ServerContext* context, const ::iv::queryreq* request, ::iv::queryReply* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Upload::Service::ctrl(::grpc::ServerContext* context, const ::iv::ctrlreq* request, ::iv::ctrlReply* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } } // namespace iv