// Generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: protobuf.proto #include "protobuf.pb.h" #include "protobuf.grpc.pb.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace namespace_uploadpic { static const char* upload_pic_servicer_method_names[] = { "/namespace_uploadpic.upload_pic_servicer/Upload", "/namespace_uploadpic.upload_pic_servicer/ListFeatures", }; std::unique_ptr< upload_pic_servicer::Stub> upload_pic_servicer::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) { (void)options; std::unique_ptr< upload_pic_servicer::Stub> stub(new upload_pic_servicer::Stub(channel, options)); return stub; } upload_pic_servicer::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) : channel_(channel), rpcmethod_Upload_(upload_pic_servicer_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel) , rpcmethod_ListFeatures_(upload_pic_servicer_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel) {} ::grpc::ClientWriter< ::namespace_uploadpic::ChunkOneLine>* upload_pic_servicer::Stub::UploadRaw(::grpc::ClientContext* context, ::namespace_uploadpic::Reply* response) { return ::grpc::internal::ClientWriterFactory< ::namespace_uploadpic::ChunkOneLine>::Create(channel_.get(), rpcmethod_Upload_, context, response); } void upload_pic_servicer::Stub::async::Upload(::grpc::ClientContext* context, ::namespace_uploadpic::Reply* response, ::grpc::ClientWriteReactor< ::namespace_uploadpic::ChunkOneLine>* reactor) { ::grpc::internal::ClientCallbackWriterFactory< ::namespace_uploadpic::ChunkOneLine>::Create(stub_->channel_.get(), stub_->rpcmethod_Upload_, context, response, reactor); } ::grpc::ClientAsyncWriter< ::namespace_uploadpic::ChunkOneLine>* upload_pic_servicer::Stub::AsyncUploadRaw(::grpc::ClientContext* context, ::namespace_uploadpic::Reply* response, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncWriterFactory< ::namespace_uploadpic::ChunkOneLine>::Create(channel_.get(), cq, rpcmethod_Upload_, context, response, true, tag); } ::grpc::ClientAsyncWriter< ::namespace_uploadpic::ChunkOneLine>* upload_pic_servicer::Stub::PrepareAsyncUploadRaw(::grpc::ClientContext* context, ::namespace_uploadpic::Reply* response, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncWriterFactory< ::namespace_uploadpic::ChunkOneLine>::Create(channel_.get(), cq, rpcmethod_Upload_, context, response, false, nullptr); } ::grpc::ClientReader< ::namespace_uploadpic::Response>* upload_pic_servicer::Stub::ListFeaturesRaw(::grpc::ClientContext* context, const ::namespace_uploadpic::Request& request) { return ::grpc::internal::ClientReaderFactory< ::namespace_uploadpic::Response>::Create(channel_.get(), rpcmethod_ListFeatures_, context, request); } void upload_pic_servicer::Stub::async::ListFeatures(::grpc::ClientContext* context, const ::namespace_uploadpic::Request* request, ::grpc::ClientReadReactor< ::namespace_uploadpic::Response>* reactor) { ::grpc::internal::ClientCallbackReaderFactory< ::namespace_uploadpic::Response>::Create(stub_->channel_.get(), stub_->rpcmethod_ListFeatures_, context, request, reactor); } ::grpc::ClientAsyncReader< ::namespace_uploadpic::Response>* upload_pic_servicer::Stub::AsyncListFeaturesRaw(::grpc::ClientContext* context, const ::namespace_uploadpic::Request& request, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncReaderFactory< ::namespace_uploadpic::Response>::Create(channel_.get(), cq, rpcmethod_ListFeatures_, context, request, true, tag); } ::grpc::ClientAsyncReader< ::namespace_uploadpic::Response>* upload_pic_servicer::Stub::PrepareAsyncListFeaturesRaw(::grpc::ClientContext* context, const ::namespace_uploadpic::Request& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncReaderFactory< ::namespace_uploadpic::Response>::Create(channel_.get(), cq, rpcmethod_ListFeatures_, context, request, false, nullptr); } upload_pic_servicer::Service::Service() { AddMethod(new ::grpc::internal::RpcServiceMethod( upload_pic_servicer_method_names[0], ::grpc::internal::RpcMethod::CLIENT_STREAMING, new ::grpc::internal::ClientStreamingHandler< upload_pic_servicer::Service, ::namespace_uploadpic::ChunkOneLine, ::namespace_uploadpic::Reply>( [](upload_pic_servicer::Service* service, ::grpc::ServerContext* ctx, ::grpc::ServerReader<::namespace_uploadpic::ChunkOneLine>* reader, ::namespace_uploadpic::Reply* resp) { return service->Upload(ctx, reader, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( upload_pic_servicer_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMING, new ::grpc::internal::ServerStreamingHandler< upload_pic_servicer::Service, ::namespace_uploadpic::Request, ::namespace_uploadpic::Response>( [](upload_pic_servicer::Service* service, ::grpc::ServerContext* ctx, const ::namespace_uploadpic::Request* req, ::grpc::ServerWriter<::namespace_uploadpic::Response>* writer) { return service->ListFeatures(ctx, req, writer); }, this))); } upload_pic_servicer::Service::~Service() { } ::grpc::Status upload_pic_servicer::Service::Upload(::grpc::ServerContext* context, ::grpc::ServerReader< ::namespace_uploadpic::ChunkOneLine>* reader, ::namespace_uploadpic::Reply* response) { (void) context; (void) reader; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status upload_pic_servicer::Service::ListFeatures(::grpc::ServerContext* context, const ::namespace_uploadpic::Request* request, ::grpc::ServerWriter< ::namespace_uploadpic::Response>* writer) { (void) context; (void) request; (void) writer; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } } // namespace namespace_uploadpic