diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h --- a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h +++ b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h @@ -35,107 +35,113 @@ class StubInterface { public: virtual ~StubInterface() {} - std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>> ResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { - return std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>>(ResetKeyRaw(context, response)); + std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::CreateNewBackupRequest>> CreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::CreateNewBackupRequest>>(CreateNewBackupRaw(context, response)); } - std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>> AsyncResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { - return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>>(AsyncResetKeyRaw(context, response, cq, tag)); + std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>> AsyncCreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>>(AsyncCreateNewBackupRaw(context, response, cq, tag)); } - std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>> PrepareAsyncResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>>(PrepareAsyncResetKeyRaw(context, response, cq)); + std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>> PrepareAsyncCreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>>(PrepareAsyncCreateNewBackupRaw(context, response, cq)); } - virtual ::grpc::Status SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::google::protobuf::Empty* response) = 0; - std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>> AsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>>(AsyncSendLogRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::SendLogRequest>> SendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::SendLogRequest>>(SendLogRaw(context, response)); } - std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>> PrepareAsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>>(PrepareAsyncSendLogRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>> AsyncSendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>>(AsyncSendLogRaw(context, response, cq, tag)); } - virtual ::grpc::Status PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::backup::PullBackupKeyResponse* response) = 0; - std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>> AsyncPullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>>(AsyncPullBackupKeyRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>> PrepareAsyncSendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>>(PrepareAsyncSendLogRaw(context, response, cq)); } - std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>> PrepareAsyncPullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>>(PrepareAsyncPullBackupKeyRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> PullBackupKey(::grpc::ClientContext* context) { + return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(PullBackupKeyRaw(context)); } - std::unique_ptr< ::grpc::ClientReaderInterface< ::backup::PullCompactionResponse>> PullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request) { - return std::unique_ptr< ::grpc::ClientReaderInterface< ::backup::PullCompactionResponse>>(PullCompactionRaw(context, request)); + std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> AsyncPullBackupKey(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(AsyncPullBackupKeyRaw(context, cq, tag)); } - std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>> AsyncPullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq, void* tag) { - return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>>(AsyncPullCompactionRaw(context, request, cq, tag)); + std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> PrepareAsyncPullBackupKey(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(PrepareAsyncPullBackupKeyRaw(context, cq)); } - std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>> PrepareAsyncPullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>>(PrepareAsyncPullCompactionRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> PullCompaction(::grpc::ClientContext* context) { + return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(PullCompactionRaw(context)); + } + std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> AsyncPullCompaction(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(AsyncPullCompactionRaw(context, cq, tag)); + } + std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> PrepareAsyncPullCompaction(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(PrepareAsyncPullCompactionRaw(context, cq)); } class async_interface { public: virtual ~async_interface() {} - virtual void ResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::ResetKeyRequest>* reactor) = 0; - virtual void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, std::function) = 0; - virtual void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, ::grpc::ClientUnaryReactor* reactor) = 0; - virtual void PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, std::function) = 0; - virtual void PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0; - virtual void PullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest* request, ::grpc::ClientReadReactor< ::backup::PullCompactionResponse>* reactor) = 0; + virtual void CreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::CreateNewBackupRequest>* reactor) = 0; + virtual void SendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::SendLogRequest>* reactor) = 0; + virtual void PullBackupKey(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullBackupKeyRequest,::backup::PullBackupKeyResponse>* reactor) = 0; + virtual void PullCompaction(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullCompactionRequest,::backup::PullCompactionResponse>* reactor) = 0; }; typedef class async_interface experimental_async_interface; virtual class async_interface* async() { return nullptr; } class async_interface* experimental_async() { return async(); } private: - virtual ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>* ResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) = 0; - virtual ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>* AsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) = 0; - virtual ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>* PrepareAsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) = 0; - virtual ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>* AsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) = 0; - virtual ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::Empty>* PrepareAsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) = 0; - virtual ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>* AsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) = 0; - virtual ::grpc::ClientAsyncResponseReaderInterface< ::backup::PullBackupKeyResponse>* PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) = 0; - virtual ::grpc::ClientReaderInterface< ::backup::PullCompactionResponse>* PullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request) = 0; - virtual ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>* AsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq, void* tag) = 0; - virtual ::grpc::ClientAsyncReaderInterface< ::backup::PullCompactionResponse>* PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq) = 0; + virtual ::grpc::ClientWriterInterface< ::backup::CreateNewBackupRequest>* CreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) = 0; + virtual ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>* AsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) = 0; + virtual ::grpc::ClientAsyncWriterInterface< ::backup::CreateNewBackupRequest>* PrepareAsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) = 0; + virtual ::grpc::ClientWriterInterface< ::backup::SendLogRequest>* SendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) = 0; + virtual ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>* AsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) = 0; + virtual ::grpc::ClientAsyncWriterInterface< ::backup::SendLogRequest>* PrepareAsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) = 0; + virtual ::grpc::ClientReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* PullBackupKeyRaw(::grpc::ClientContext* context) = 0; + virtual ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* AsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0; + virtual ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) = 0; + virtual ::grpc::ClientReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* PullCompactionRaw(::grpc::ClientContext* context) = 0; + virtual ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* AsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0; + virtual ::grpc::ClientAsyncReaderWriterInterface< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) = 0; }; class Stub final : public StubInterface { public: Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); - std::unique_ptr< ::grpc::ClientWriter< ::backup::ResetKeyRequest>> ResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { - return std::unique_ptr< ::grpc::ClientWriter< ::backup::ResetKeyRequest>>(ResetKeyRaw(context, response)); + std::unique_ptr< ::grpc::ClientWriter< ::backup::CreateNewBackupRequest>> CreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return std::unique_ptr< ::grpc::ClientWriter< ::backup::CreateNewBackupRequest>>(CreateNewBackupRaw(context, response)); + } + std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>> AsyncCreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>>(AsyncCreateNewBackupRaw(context, response, cq, tag)); } - std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>> AsyncResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { - return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>>(AsyncResetKeyRaw(context, response, cq, tag)); + std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>> PrepareAsyncCreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>>(PrepareAsyncCreateNewBackupRaw(context, response, cq)); } - std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>> PrepareAsyncResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>>(PrepareAsyncResetKeyRaw(context, response, cq)); + std::unique_ptr< ::grpc::ClientWriter< ::backup::SendLogRequest>> SendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return std::unique_ptr< ::grpc::ClientWriter< ::backup::SendLogRequest>>(SendLogRaw(context, response)); } - ::grpc::Status SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::google::protobuf::Empty* response) override; - std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>> AsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>>(AsyncSendLogRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>> AsyncSendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>>(AsyncSendLogRaw(context, response, cq, tag)); } - std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>> PrepareAsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>>(PrepareAsyncSendLogRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>> PrepareAsyncSendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>>(PrepareAsyncSendLogRaw(context, response, cq)); } - ::grpc::Status PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::backup::PullBackupKeyResponse* response) override; - std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>> AsyncPullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>>(AsyncPullBackupKeyRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> PullBackupKey(::grpc::ClientContext* context) { + return std::unique_ptr< ::grpc::ClientReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(PullBackupKeyRaw(context)); } - std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>> PrepareAsyncPullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>>(PrepareAsyncPullBackupKeyRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> AsyncPullBackupKey(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(AsyncPullBackupKeyRaw(context, cq, tag)); } - std::unique_ptr< ::grpc::ClientReader< ::backup::PullCompactionResponse>> PullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request) { - return std::unique_ptr< ::grpc::ClientReader< ::backup::PullCompactionResponse>>(PullCompactionRaw(context, request)); + std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>> PrepareAsyncPullBackupKey(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>>(PrepareAsyncPullBackupKeyRaw(context, cq)); } - std::unique_ptr< ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>> AsyncPullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq, void* tag) { - return std::unique_ptr< ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>>(AsyncPullCompactionRaw(context, request, cq, tag)); + std::unique_ptr< ::grpc::ClientReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> PullCompaction(::grpc::ClientContext* context) { + return std::unique_ptr< ::grpc::ClientReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(PullCompactionRaw(context)); } - std::unique_ptr< ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>> PrepareAsyncPullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq) { - return std::unique_ptr< ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>>(PrepareAsyncPullCompactionRaw(context, request, cq)); + std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> AsyncPullCompaction(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(AsyncPullCompactionRaw(context, cq, tag)); + } + std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>> PrepareAsyncPullCompaction(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>>(PrepareAsyncPullCompactionRaw(context, cq)); } class async final : public StubInterface::async_interface { public: - void ResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::ResetKeyRequest>* reactor) override; - void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, std::function) override; - void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, ::grpc::ClientUnaryReactor* reactor) override; - void PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, std::function) override; - void PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, ::grpc::ClientUnaryReactor* reactor) override; - void PullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest* request, ::grpc::ClientReadReactor< ::backup::PullCompactionResponse>* reactor) override; + void CreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::CreateNewBackupRequest>* reactor) override; + void SendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::SendLogRequest>* reactor) override; + void PullBackupKey(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullBackupKeyRequest,::backup::PullBackupKeyResponse>* reactor) override; + void PullCompaction(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullCompactionRequest,::backup::PullCompactionResponse>* reactor) override; private: friend class Stub; explicit async(Stub* stub): stub_(stub) { } @@ -147,17 +153,19 @@ private: std::shared_ptr< ::grpc::ChannelInterface> channel_; class async async_stub_{this}; - ::grpc::ClientWriter< ::backup::ResetKeyRequest>* ResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) override; - ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* AsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) override; - ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* PrepareAsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) override; - ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>* AsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) override; - ::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>* PrepareAsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) override; - ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>* AsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) override; - ::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>* PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) override; - ::grpc::ClientReader< ::backup::PullCompactionResponse>* PullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request) override; - ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>* AsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq, void* tag) override; - ::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>* PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq) override; - const ::grpc::internal::RpcMethod rpcmethod_ResetKey_; + ::grpc::ClientWriter< ::backup::CreateNewBackupRequest>* CreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) override; + ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>* AsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) override; + ::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>* PrepareAsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) override; + ::grpc::ClientWriter< ::backup::SendLogRequest>* SendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) override; + ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>* AsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) override; + ::grpc::ClientAsyncWriter< ::backup::SendLogRequest>* PrepareAsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) override; + ::grpc::ClientReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* PullBackupKeyRaw(::grpc::ClientContext* context) override; + ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* AsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) override; + ::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) override; + ::grpc::ClientReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* PullCompactionRaw(::grpc::ClientContext* context) override; + ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* AsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) override; + ::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) override; + const ::grpc::internal::RpcMethod rpcmethod_CreateNewBackup_; const ::grpc::internal::RpcMethod rpcmethod_SendLog_; const ::grpc::internal::RpcMethod rpcmethod_PullBackupKey_; const ::grpc::internal::RpcMethod rpcmethod_PullCompaction_; @@ -168,28 +176,28 @@ public: Service(); virtual ~Service(); - virtual ::grpc::Status ResetKey(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::ResetKeyRequest>* reader, ::google::protobuf::Empty* response); - virtual ::grpc::Status SendLog(::grpc::ServerContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response); - virtual ::grpc::Status PullBackupKey(::grpc::ServerContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response); - virtual ::grpc::Status PullCompaction(::grpc::ServerContext* context, const ::backup::PullCompactionRequest* request, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* writer); + virtual ::grpc::Status CreateNewBackup(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* reader, ::google::protobuf::Empty* response); + virtual ::grpc::Status SendLog(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::SendLogRequest>* reader, ::google::protobuf::Empty* response); + virtual ::grpc::Status PullBackupKey(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* stream); + virtual ::grpc::Status PullCompaction(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* stream); }; template - class WithAsyncMethod_ResetKey : public BaseClass { + class WithAsyncMethod_CreateNewBackup : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: - WithAsyncMethod_ResetKey() { + WithAsyncMethod_CreateNewBackup() { ::grpc::Service::MarkMethodAsync(0); } - ~WithAsyncMethod_ResetKey() override { + ~WithAsyncMethod_CreateNewBackup() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status CreateNewBackup(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestResetKey(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::google::protobuf::Empty, ::backup::ResetKeyRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + void RequestCreateNewBackup(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::google::protobuf::Empty, ::backup::CreateNewBackupRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncClientStreaming(0, context, reader, new_call_cq, notification_cq, tag); } }; @@ -205,12 +213,12 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::SendLogRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestSendLog(::grpc::ServerContext* context, ::backup::SendLogRequest* request, ::grpc::ServerAsyncResponseWriter< ::google::protobuf::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag); + void RequestSendLog(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::google::protobuf::Empty, ::backup::SendLogRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag); } }; template @@ -225,12 +233,12 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { + ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestPullBackupKey(::grpc::ServerContext* context, ::backup::PullBackupKeyRequest* request, ::grpc::ServerAsyncResponseWriter< ::backup::PullBackupKeyResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag); + void RequestPullBackupKey(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncBidiStreaming(2, context, stream, new_call_cq, notification_cq, tag); } }; template @@ -245,35 +253,35 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { + ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestPullCompaction(::grpc::ServerContext* context, ::backup::PullCompactionRequest* request, ::grpc::ServerAsyncWriter< ::backup::PullCompactionResponse>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncServerStreaming(3, context, request, writer, new_call_cq, notification_cq, tag); + void RequestPullCompaction(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncBidiStreaming(3, context, stream, new_call_cq, notification_cq, tag); } }; - typedef WithAsyncMethod_ResetKey > > > AsyncService; + typedef WithAsyncMethod_CreateNewBackup > > > AsyncService; template - class WithCallbackMethod_ResetKey : public BaseClass { + class WithCallbackMethod_CreateNewBackup : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: - WithCallbackMethod_ResetKey() { + WithCallbackMethod_CreateNewBackup() { ::grpc::Service::MarkMethodCallback(0, - new ::grpc::internal::CallbackClientStreamingHandler< ::backup::ResetKeyRequest, ::google::protobuf::Empty>( + new ::grpc::internal::CallbackClientStreamingHandler< ::backup::CreateNewBackupRequest, ::google::protobuf::Empty>( [this]( - ::grpc::CallbackServerContext* context, ::google::protobuf::Empty* response) { return this->ResetKey(context, response); })); + ::grpc::CallbackServerContext* context, ::google::protobuf::Empty* response) { return this->CreateNewBackup(context, response); })); } - ~WithCallbackMethod_ResetKey() override { + ~WithCallbackMethod_CreateNewBackup() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status CreateNewBackup(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerReadReactor< ::backup::ResetKeyRequest>* ResetKey( + virtual ::grpc::ServerReadReactor< ::backup::CreateNewBackupRequest>* CreateNewBackup( ::grpc::CallbackServerContext* /*context*/, ::google::protobuf::Empty* /*response*/) { return nullptr; } }; template @@ -283,25 +291,20 @@ public: WithCallbackMethod_SendLog() { ::grpc::Service::MarkMethodCallback(1, - new ::grpc::internal::CallbackUnaryHandler< ::backup::SendLogRequest, ::google::protobuf::Empty>( + new ::grpc::internal::CallbackClientStreamingHandler< ::backup::SendLogRequest, ::google::protobuf::Empty>( [this]( - ::grpc::CallbackServerContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response) { return this->SendLog(context, request, response); }));} - void SetMessageAllocatorFor_SendLog( - ::grpc::MessageAllocator< ::backup::SendLogRequest, ::google::protobuf::Empty>* allocator) { - ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(1); - static_cast<::grpc::internal::CallbackUnaryHandler< ::backup::SendLogRequest, ::google::protobuf::Empty>*>(handler) - ->SetMessageAllocator(allocator); + ::grpc::CallbackServerContext* context, ::google::protobuf::Empty* response) { return this->SendLog(context, response); })); } ~WithCallbackMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::SendLogRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerUnaryReactor* SendLog( - ::grpc::CallbackServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) { return nullptr; } + virtual ::grpc::ServerReadReactor< ::backup::SendLogRequest>* SendLog( + ::grpc::CallbackServerContext* /*context*/, ::google::protobuf::Empty* /*response*/) { return nullptr; } }; template class WithCallbackMethod_PullBackupKey : public BaseClass { @@ -310,25 +313,21 @@ public: WithCallbackMethod_PullBackupKey() { ::grpc::Service::MarkMethodCallback(2, - new ::grpc::internal::CallbackUnaryHandler< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>( + new ::grpc::internal::CallbackBidiHandler< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>( [this]( - ::grpc::CallbackServerContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response) { return this->PullBackupKey(context, request, response); }));} - void SetMessageAllocatorFor_PullBackupKey( - ::grpc::MessageAllocator< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* allocator) { - ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(2); - static_cast<::grpc::internal::CallbackUnaryHandler< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>*>(handler) - ->SetMessageAllocator(allocator); + ::grpc::CallbackServerContext* context) { return this->PullBackupKey(context); })); } ~WithCallbackMethod_PullBackupKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { + ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerUnaryReactor* PullBackupKey( - ::grpc::CallbackServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) { return nullptr; } + virtual ::grpc::ServerBidiReactor< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* PullBackupKey( + ::grpc::CallbackServerContext* /*context*/) + { return nullptr; } }; template class WithCallbackMethod_PullCompaction : public BaseClass { @@ -337,36 +336,37 @@ public: WithCallbackMethod_PullCompaction() { ::grpc::Service::MarkMethodCallback(3, - new ::grpc::internal::CallbackServerStreamingHandler< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( + new ::grpc::internal::CallbackBidiHandler< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( [this]( - ::grpc::CallbackServerContext* context, const ::backup::PullCompactionRequest* request) { return this->PullCompaction(context, request); })); + ::grpc::CallbackServerContext* context) { return this->PullCompaction(context); })); } ~WithCallbackMethod_PullCompaction() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { + ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerWriteReactor< ::backup::PullCompactionResponse>* PullCompaction( - ::grpc::CallbackServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/) { return nullptr; } + virtual ::grpc::ServerBidiReactor< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* PullCompaction( + ::grpc::CallbackServerContext* /*context*/) + { return nullptr; } }; - typedef WithCallbackMethod_ResetKey > > > CallbackService; + typedef WithCallbackMethod_CreateNewBackup > > > CallbackService; typedef CallbackService ExperimentalCallbackService; template - class WithGenericMethod_ResetKey : public BaseClass { + class WithGenericMethod_CreateNewBackup : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: - WithGenericMethod_ResetKey() { + WithGenericMethod_CreateNewBackup() { ::grpc::Service::MarkMethodGeneric(0); } - ~WithGenericMethod_ResetKey() override { + ~WithGenericMethod_CreateNewBackup() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status CreateNewBackup(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } @@ -383,7 +383,7 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::SendLogRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } @@ -400,7 +400,7 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { + ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } @@ -417,28 +417,28 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { + ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template - class WithRawMethod_ResetKey : public BaseClass { + class WithRawMethod_CreateNewBackup : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: - WithRawMethod_ResetKey() { + WithRawMethod_CreateNewBackup() { ::grpc::Service::MarkMethodRaw(0); } - ~WithRawMethod_ResetKey() override { + ~WithRawMethod_CreateNewBackup() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status CreateNewBackup(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestResetKey(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + void RequestCreateNewBackup(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncClientStreaming(0, context, reader, new_call_cq, notification_cq, tag); } }; @@ -454,12 +454,12 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::SendLogRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestSendLog(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag); + void RequestSendLog(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag); } }; template @@ -474,12 +474,12 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { + ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestPullBackupKey(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag); + void RequestPullBackupKey(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncBidiStreaming(2, context, stream, new_call_cq, notification_cq, tag); } }; template @@ -494,34 +494,34 @@ BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { + ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - void RequestPullCompaction(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncWriter< ::grpc::ByteBuffer>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { - ::grpc::Service::RequestAsyncServerStreaming(3, context, request, writer, new_call_cq, notification_cq, tag); + void RequestPullCompaction(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { + ::grpc::Service::RequestAsyncBidiStreaming(3, context, stream, new_call_cq, notification_cq, tag); } }; template - class WithRawCallbackMethod_ResetKey : public BaseClass { + class WithRawCallbackMethod_CreateNewBackup : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: - WithRawCallbackMethod_ResetKey() { + WithRawCallbackMethod_CreateNewBackup() { ::grpc::Service::MarkMethodRawCallback(0, new ::grpc::internal::CallbackClientStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( - ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->ResetKey(context, response); })); + ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->CreateNewBackup(context, response); })); } - ~WithRawCallbackMethod_ResetKey() override { + ~WithRawCallbackMethod_CreateNewBackup() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status CreateNewBackup(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* ResetKey( + virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* CreateNewBackup( ::grpc::CallbackServerContext* /*context*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template @@ -531,20 +531,20 @@ public: WithRawCallbackMethod_SendLog() { ::grpc::Service::MarkMethodRawCallback(1, - new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( + new ::grpc::internal::CallbackClientStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( - ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->SendLog(context, request, response); })); + ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->SendLog(context, response); })); } ~WithRawCallbackMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { + ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::SendLogRequest>* /*reader*/, ::google::protobuf::Empty* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerUnaryReactor* SendLog( - ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } + virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* SendLog( + ::grpc::CallbackServerContext* /*context*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithRawCallbackMethod_PullBackupKey : public BaseClass { @@ -553,20 +553,21 @@ public: WithRawCallbackMethod_PullBackupKey() { ::grpc::Service::MarkMethodRawCallback(2, - new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( + new ::grpc::internal::CallbackBidiHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( - ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->PullBackupKey(context, request, response); })); + ::grpc::CallbackServerContext* context) { return this->PullBackupKey(context); })); } ~WithRawCallbackMethod_PullBackupKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { + ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - virtual ::grpc::ServerUnaryReactor* PullBackupKey( - ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } + virtual ::grpc::ServerBidiReactor< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* PullBackupKey( + ::grpc::CallbackServerContext* /*context*/) + { return nullptr; } }; template class WithRawCallbackMethod_PullCompaction : public BaseClass { @@ -575,105 +576,25 @@ public: WithRawCallbackMethod_PullCompaction() { ::grpc::Service::MarkMethodRawCallback(3, - new ::grpc::internal::CallbackServerStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( + new ::grpc::internal::CallbackBidiHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( - ::grpc::CallbackServerContext* context, const::grpc::ByteBuffer* request) { return this->PullCompaction(context, request); })); + ::grpc::CallbackServerContext* context) { return this->PullCompaction(context); })); } ~WithRawCallbackMethod_PullCompaction() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { - abort(); - return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); - } - virtual ::grpc::ServerWriteReactor< ::grpc::ByteBuffer>* PullCompaction( - ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/) { return nullptr; } - }; - template - class WithStreamedUnaryMethod_SendLog : public BaseClass { - private: - void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} - public: - WithStreamedUnaryMethod_SendLog() { - ::grpc::Service::MarkMethodStreamed(1, - new ::grpc::internal::StreamedUnaryHandler< - ::backup::SendLogRequest, ::google::protobuf::Empty>( - [this](::grpc::ServerContext* context, - ::grpc::ServerUnaryStreamer< - ::backup::SendLogRequest, ::google::protobuf::Empty>* streamer) { - return this->StreamedSendLog(context, - streamer); - })); - } - ~WithStreamedUnaryMethod_SendLog() override { - BaseClassMustBeDerivedFromService(this); - } - // disable regular version of this method - ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::google::protobuf::Empty* /*response*/) override { - abort(); - return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); - } - // replace default version of method with streamed unary - virtual ::grpc::Status StreamedSendLog(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::backup::SendLogRequest,::google::protobuf::Empty>* server_unary_streamer) = 0; - }; - template - class WithStreamedUnaryMethod_PullBackupKey : public BaseClass { - private: - void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} - public: - WithStreamedUnaryMethod_PullBackupKey() { - ::grpc::Service::MarkMethodStreamed(2, - new ::grpc::internal::StreamedUnaryHandler< - ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>( - [this](::grpc::ServerContext* context, - ::grpc::ServerUnaryStreamer< - ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* streamer) { - return this->StreamedPullBackupKey(context, - streamer); - })); - } - ~WithStreamedUnaryMethod_PullBackupKey() override { - BaseClassMustBeDerivedFromService(this); - } - // disable regular version of this method - ::grpc::Status PullBackupKey(::grpc::ServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) override { - abort(); - return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); - } - // replace default version of method with streamed unary - virtual ::grpc::Status StreamedPullBackupKey(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::backup::PullBackupKeyRequest,::backup::PullBackupKeyResponse>* server_unary_streamer) = 0; - }; - typedef WithStreamedUnaryMethod_SendLog > StreamedUnaryService; - template - class WithSplitStreamingMethod_PullCompaction : public BaseClass { - private: - void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} - public: - WithSplitStreamingMethod_PullCompaction() { - ::grpc::Service::MarkMethodStreamed(3, - new ::grpc::internal::SplitServerStreamingHandler< - ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( - [this](::grpc::ServerContext* context, - ::grpc::ServerSplitStreamer< - ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* streamer) { - return this->StreamedPullCompaction(context, - streamer); - })); - } - ~WithSplitStreamingMethod_PullCompaction() override { - BaseClassMustBeDerivedFromService(this); - } - // disable regular version of this method - ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* /*writer*/) override { + ::grpc::Status PullCompaction(::grpc::ServerContext* /*context*/, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* /*stream*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } - // replace default version of method with split streamed - virtual ::grpc::Status StreamedPullCompaction(::grpc::ServerContext* context, ::grpc::ServerSplitStreamer< ::backup::PullCompactionRequest,::backup::PullCompactionResponse>* server_split_streamer) = 0; + virtual ::grpc::ServerBidiReactor< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* PullCompaction( + ::grpc::CallbackServerContext* /*context*/) + { return nullptr; } }; - typedef WithSplitStreamingMethod_PullCompaction SplitStreamedService; - typedef WithStreamedUnaryMethod_SendLog > > StreamedService; + typedef Service StreamedUnaryService; + typedef Service SplitStreamedService; + typedef Service StreamedService; }; } // namespace backup diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.cc b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.cc --- a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.cc +++ b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.cc @@ -22,7 +22,7 @@ namespace backup { static const char* BackupService_method_names[] = { - "/backup.BackupService/ResetKey", + "/backup.BackupService/CreateNewBackup", "/backup.BackupService/SendLog", "/backup.BackupService/PullBackupKey", "/backup.BackupService/PullCompaction", @@ -35,161 +35,145 @@ } BackupService::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) - : channel_(channel), rpcmethod_ResetKey_(BackupService_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel) - , rpcmethod_SendLog_(BackupService_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) - , rpcmethod_PullBackupKey_(BackupService_method_names[2], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) - , rpcmethod_PullCompaction_(BackupService_method_names[3], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel) + : channel_(channel), rpcmethod_CreateNewBackup_(BackupService_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel) + , rpcmethod_SendLog_(BackupService_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel) + , rpcmethod_PullBackupKey_(BackupService_method_names[2], options.suffix_for_stats(),::grpc::internal::RpcMethod::BIDI_STREAMING, channel) + , rpcmethod_PullCompaction_(BackupService_method_names[3], options.suffix_for_stats(),::grpc::internal::RpcMethod::BIDI_STREAMING, channel) {} -::grpc::ClientWriter< ::backup::ResetKeyRequest>* BackupService::Stub::ResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { - return ::grpc::internal::ClientWriterFactory< ::backup::ResetKeyRequest>::Create(channel_.get(), rpcmethod_ResetKey_, context, response); +::grpc::ClientWriter< ::backup::CreateNewBackupRequest>* BackupService::Stub::CreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return ::grpc::internal::ClientWriterFactory< ::backup::CreateNewBackupRequest>::Create(channel_.get(), rpcmethod_CreateNewBackup_, context, response); } -void BackupService::Stub::async::ResetKey(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::ResetKeyRequest>* reactor) { - ::grpc::internal::ClientCallbackWriterFactory< ::backup::ResetKeyRequest>::Create(stub_->channel_.get(), stub_->rpcmethod_ResetKey_, context, response, reactor); +void BackupService::Stub::async::CreateNewBackup(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::CreateNewBackupRequest>* reactor) { + ::grpc::internal::ClientCallbackWriterFactory< ::backup::CreateNewBackupRequest>::Create(stub_->channel_.get(), stub_->rpcmethod_CreateNewBackup_, context, response, reactor); } -::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* BackupService::Stub::AsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { - return ::grpc::internal::ClientAsyncWriterFactory< ::backup::ResetKeyRequest>::Create(channel_.get(), cq, rpcmethod_ResetKey_, context, response, true, tag); +::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>* BackupService::Stub::AsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return ::grpc::internal::ClientAsyncWriterFactory< ::backup::CreateNewBackupRequest>::Create(channel_.get(), cq, rpcmethod_CreateNewBackup_, context, response, true, tag); } -::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* BackupService::Stub::PrepareAsyncResetKeyRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { - return ::grpc::internal::ClientAsyncWriterFactory< ::backup::ResetKeyRequest>::Create(channel_.get(), cq, rpcmethod_ResetKey_, context, response, false, nullptr); +::grpc::ClientAsyncWriter< ::backup::CreateNewBackupRequest>* BackupService::Stub::PrepareAsyncCreateNewBackupRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return ::grpc::internal::ClientAsyncWriterFactory< ::backup::CreateNewBackupRequest>::Create(channel_.get(), cq, rpcmethod_CreateNewBackup_, context, response, false, nullptr); } -::grpc::Status BackupService::Stub::SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::google::protobuf::Empty* response) { - return ::grpc::internal::BlockingUnaryCall< ::backup::SendLogRequest, ::google::protobuf::Empty, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_SendLog_, context, request, response); +::grpc::ClientWriter< ::backup::SendLogRequest>* BackupService::Stub::SendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response) { + return ::grpc::internal::ClientWriterFactory< ::backup::SendLogRequest>::Create(channel_.get(), rpcmethod_SendLog_, context, response); } -void BackupService::Stub::async::SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, std::function f) { - ::grpc::internal::CallbackUnaryCall< ::backup::SendLogRequest, ::google::protobuf::Empty, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_SendLog_, context, request, response, std::move(f)); +void BackupService::Stub::async::SendLog(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::ClientWriteReactor< ::backup::SendLogRequest>* reactor) { + ::grpc::internal::ClientCallbackWriterFactory< ::backup::SendLogRequest>::Create(stub_->channel_.get(), stub_->rpcmethod_SendLog_, context, response, reactor); } -void BackupService::Stub::async::SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response, ::grpc::ClientUnaryReactor* reactor) { - ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_SendLog_, context, request, response, reactor); +::grpc::ClientAsyncWriter< ::backup::SendLogRequest>* BackupService::Stub::AsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq, void* tag) { + return ::grpc::internal::ClientAsyncWriterFactory< ::backup::SendLogRequest>::Create(channel_.get(), cq, rpcmethod_SendLog_, context, response, true, tag); } -::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>* BackupService::Stub::PrepareAsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::google::protobuf::Empty, ::backup::SendLogRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_SendLog_, context, request); +::grpc::ClientAsyncWriter< ::backup::SendLogRequest>* BackupService::Stub::PrepareAsyncSendLogRaw(::grpc::ClientContext* context, ::google::protobuf::Empty* response, ::grpc::CompletionQueue* cq) { + return ::grpc::internal::ClientAsyncWriterFactory< ::backup::SendLogRequest>::Create(channel_.get(), cq, rpcmethod_SendLog_, context, response, false, nullptr); } -::grpc::ClientAsyncResponseReader< ::google::protobuf::Empty>* BackupService::Stub::AsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { - auto* result = - this->PrepareAsyncSendLogRaw(context, request, cq); - result->StartCall(); - return result; +::grpc::ClientReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* BackupService::Stub::PullBackupKeyRaw(::grpc::ClientContext* context) { + return ::grpc::internal::ClientReaderWriterFactory< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>::Create(channel_.get(), rpcmethod_PullBackupKey_, context); } -::grpc::Status BackupService::Stub::PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::backup::PullBackupKeyResponse* response) { - return ::grpc::internal::BlockingUnaryCall< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_PullBackupKey_, context, request, response); +void BackupService::Stub::async::PullBackupKey(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullBackupKeyRequest,::backup::PullBackupKeyResponse>* reactor) { + ::grpc::internal::ClientCallbackReaderWriterFactory< ::backup::PullBackupKeyRequest,::backup::PullBackupKeyResponse>::Create(stub_->channel_.get(), stub_->rpcmethod_PullBackupKey_, context, reactor); } -void BackupService::Stub::async::PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, std::function f) { - ::grpc::internal::CallbackUnaryCall< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_PullBackupKey_, context, request, response, std::move(f)); +::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* BackupService::Stub::AsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return ::grpc::internal::ClientAsyncReaderWriterFactory< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>::Create(channel_.get(), cq, rpcmethod_PullBackupKey_, context, true, tag); } -void BackupService::Stub::async::PullBackupKey(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response, ::grpc::ClientUnaryReactor* reactor) { - ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_PullBackupKey_, context, request, response, reactor); +::grpc::ClientAsyncReaderWriter< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>* BackupService::Stub::PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return ::grpc::internal::ClientAsyncReaderWriterFactory< ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>::Create(channel_.get(), cq, rpcmethod_PullBackupKey_, context, false, nullptr); } -::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>* BackupService::Stub::PrepareAsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_PullBackupKey_, context, request); +::grpc::ClientReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* BackupService::Stub::PullCompactionRaw(::grpc::ClientContext* context) { + return ::grpc::internal::ClientReaderWriterFactory< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>::Create(channel_.get(), rpcmethod_PullCompaction_, context); } -::grpc::ClientAsyncResponseReader< ::backup::PullBackupKeyResponse>* BackupService::Stub::AsyncPullBackupKeyRaw(::grpc::ClientContext* context, const ::backup::PullBackupKeyRequest& request, ::grpc::CompletionQueue* cq) { - auto* result = - this->PrepareAsyncPullBackupKeyRaw(context, request, cq); - result->StartCall(); - return result; +void BackupService::Stub::async::PullCompaction(::grpc::ClientContext* context, ::grpc::ClientBidiReactor< ::backup::PullCompactionRequest,::backup::PullCompactionResponse>* reactor) { + ::grpc::internal::ClientCallbackReaderWriterFactory< ::backup::PullCompactionRequest,::backup::PullCompactionResponse>::Create(stub_->channel_.get(), stub_->rpcmethod_PullCompaction_, context, reactor); } -::grpc::ClientReader< ::backup::PullCompactionResponse>* BackupService::Stub::PullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request) { - return ::grpc::internal::ClientReaderFactory< ::backup::PullCompactionResponse>::Create(channel_.get(), rpcmethod_PullCompaction_, context, request); +::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* BackupService::Stub::AsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { + return ::grpc::internal::ClientAsyncReaderWriterFactory< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>::Create(channel_.get(), cq, rpcmethod_PullCompaction_, context, true, tag); } -void BackupService::Stub::async::PullCompaction(::grpc::ClientContext* context, const ::backup::PullCompactionRequest* request, ::grpc::ClientReadReactor< ::backup::PullCompactionResponse>* reactor) { - ::grpc::internal::ClientCallbackReaderFactory< ::backup::PullCompactionResponse>::Create(stub_->channel_.get(), stub_->rpcmethod_PullCompaction_, context, request, reactor); -} - -::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>* BackupService::Stub::AsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq, void* tag) { - return ::grpc::internal::ClientAsyncReaderFactory< ::backup::PullCompactionResponse>::Create(channel_.get(), cq, rpcmethod_PullCompaction_, context, request, true, tag); -} - -::grpc::ClientAsyncReader< ::backup::PullCompactionResponse>* BackupService::Stub::PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, const ::backup::PullCompactionRequest& request, ::grpc::CompletionQueue* cq) { - return ::grpc::internal::ClientAsyncReaderFactory< ::backup::PullCompactionResponse>::Create(channel_.get(), cq, rpcmethod_PullCompaction_, context, request, false, nullptr); +::grpc::ClientAsyncReaderWriter< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>* BackupService::Stub::PrepareAsyncPullCompactionRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { + return ::grpc::internal::ClientAsyncReaderWriterFactory< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>::Create(channel_.get(), cq, rpcmethod_PullCompaction_, context, false, nullptr); } BackupService::Service::Service() { AddMethod(new ::grpc::internal::RpcServiceMethod( BackupService_method_names[0], ::grpc::internal::RpcMethod::CLIENT_STREAMING, - new ::grpc::internal::ClientStreamingHandler< BackupService::Service, ::backup::ResetKeyRequest, ::google::protobuf::Empty>( + new ::grpc::internal::ClientStreamingHandler< BackupService::Service, ::backup::CreateNewBackupRequest, ::google::protobuf::Empty>( [](BackupService::Service* service, ::grpc::ServerContext* ctx, - ::grpc::ServerReader<::backup::ResetKeyRequest>* reader, + ::grpc::ServerReader<::backup::CreateNewBackupRequest>* reader, ::google::protobuf::Empty* resp) { - return service->ResetKey(ctx, reader, resp); + return service->CreateNewBackup(ctx, reader, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( BackupService_method_names[1], - ::grpc::internal::RpcMethod::NORMAL_RPC, - new ::grpc::internal::RpcMethodHandler< BackupService::Service, ::backup::SendLogRequest, ::google::protobuf::Empty, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( + ::grpc::internal::RpcMethod::CLIENT_STREAMING, + new ::grpc::internal::ClientStreamingHandler< BackupService::Service, ::backup::SendLogRequest, ::google::protobuf::Empty>( [](BackupService::Service* service, ::grpc::ServerContext* ctx, - const ::backup::SendLogRequest* req, + ::grpc::ServerReader<::backup::SendLogRequest>* reader, ::google::protobuf::Empty* resp) { - return service->SendLog(ctx, req, resp); + return service->SendLog(ctx, reader, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( BackupService_method_names[2], - ::grpc::internal::RpcMethod::NORMAL_RPC, - new ::grpc::internal::RpcMethodHandler< BackupService::Service, ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( + ::grpc::internal::RpcMethod::BIDI_STREAMING, + new ::grpc::internal::BidiStreamingHandler< BackupService::Service, ::backup::PullBackupKeyRequest, ::backup::PullBackupKeyResponse>( [](BackupService::Service* service, ::grpc::ServerContext* ctx, - const ::backup::PullBackupKeyRequest* req, - ::backup::PullBackupKeyResponse* resp) { - return service->PullBackupKey(ctx, req, resp); + ::grpc::ServerReaderWriter<::backup::PullBackupKeyResponse, + ::backup::PullBackupKeyRequest>* stream) { + return service->PullBackupKey(ctx, stream); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( BackupService_method_names[3], - ::grpc::internal::RpcMethod::SERVER_STREAMING, - new ::grpc::internal::ServerStreamingHandler< BackupService::Service, ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( + ::grpc::internal::RpcMethod::BIDI_STREAMING, + new ::grpc::internal::BidiStreamingHandler< BackupService::Service, ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( [](BackupService::Service* service, ::grpc::ServerContext* ctx, - const ::backup::PullCompactionRequest* req, - ::grpc::ServerWriter<::backup::PullCompactionResponse>* writer) { - return service->PullCompaction(ctx, req, writer); + ::grpc::ServerReaderWriter<::backup::PullCompactionResponse, + ::backup::PullCompactionRequest>* stream) { + return service->PullCompaction(ctx, stream); }, this))); } BackupService::Service::~Service() { } -::grpc::Status BackupService::Service::ResetKey(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::ResetKeyRequest>* reader, ::google::protobuf::Empty* response) { +::grpc::Status BackupService::Service::CreateNewBackup(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::CreateNewBackupRequest>* reader, ::google::protobuf::Empty* response) { (void) context; (void) reader; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } -::grpc::Status BackupService::Service::SendLog(::grpc::ServerContext* context, const ::backup::SendLogRequest* request, ::google::protobuf::Empty* response) { +::grpc::Status BackupService::Service::SendLog(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::SendLogRequest>* reader, ::google::protobuf::Empty* response) { (void) context; - (void) request; + (void) reader; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } -::grpc::Status BackupService::Service::PullBackupKey(::grpc::ServerContext* context, const ::backup::PullBackupKeyRequest* request, ::backup::PullBackupKeyResponse* response) { +::grpc::Status BackupService::Service::PullBackupKey(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::backup::PullBackupKeyResponse, ::backup::PullBackupKeyRequest>* stream) { (void) context; - (void) request; - (void) response; + (void) stream; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } -::grpc::Status BackupService::Service::PullCompaction(::grpc::ServerContext* context, const ::backup::PullCompactionRequest* request, ::grpc::ServerWriter< ::backup::PullCompactionResponse>* writer) { +::grpc::Status BackupService::Service::PullCompaction(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::backup::PullCompactionResponse, ::backup::PullCompactionRequest>* stream) { (void) context; - (void) request; - (void) writer; + (void) stream; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h --- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h +++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h @@ -56,6 +56,9 @@ extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_backup_2eproto; ::PROTOBUF_NAMESPACE_ID::Metadata descriptor_table_backup_2eproto_metadata_getter(int index); namespace backup { +class CreateNewBackupRequest; +struct CreateNewBackupRequestDefaultTypeInternal; +extern CreateNewBackupRequestDefaultTypeInternal _CreateNewBackupRequest_default_instance_; class PullBackupKeyRequest; struct PullBackupKeyRequestDefaultTypeInternal; extern PullBackupKeyRequestDefaultTypeInternal _PullBackupKeyRequest_default_instance_; @@ -68,43 +71,40 @@ class PullCompactionResponse; struct PullCompactionResponseDefaultTypeInternal; extern PullCompactionResponseDefaultTypeInternal _PullCompactionResponse_default_instance_; -class ResetKeyRequest; -struct ResetKeyRequestDefaultTypeInternal; -extern ResetKeyRequestDefaultTypeInternal _ResetKeyRequest_default_instance_; class SendLogRequest; struct SendLogRequestDefaultTypeInternal; extern SendLogRequestDefaultTypeInternal _SendLogRequest_default_instance_; } // namespace backup PROTOBUF_NAMESPACE_OPEN +template<> ::backup::CreateNewBackupRequest* Arena::CreateMaybeMessage<::backup::CreateNewBackupRequest>(Arena*); template<> ::backup::PullBackupKeyRequest* Arena::CreateMaybeMessage<::backup::PullBackupKeyRequest>(Arena*); template<> ::backup::PullBackupKeyResponse* Arena::CreateMaybeMessage<::backup::PullBackupKeyResponse>(Arena*); template<> ::backup::PullCompactionRequest* Arena::CreateMaybeMessage<::backup::PullCompactionRequest>(Arena*); template<> ::backup::PullCompactionResponse* Arena::CreateMaybeMessage<::backup::PullCompactionResponse>(Arena*); -template<> ::backup::ResetKeyRequest* Arena::CreateMaybeMessage<::backup::ResetKeyRequest>(Arena*); template<> ::backup::SendLogRequest* Arena::CreateMaybeMessage<::backup::SendLogRequest>(Arena*); PROTOBUF_NAMESPACE_CLOSE namespace backup { // =================================================================== -class ResetKeyRequest PROTOBUF_FINAL : - public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.ResetKeyRequest) */ { +class CreateNewBackupRequest PROTOBUF_FINAL : + public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.CreateNewBackupRequest) */ { public: - inline ResetKeyRequest() : ResetKeyRequest(nullptr) {} - virtual ~ResetKeyRequest(); - explicit constexpr ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + inline CreateNewBackupRequest() : CreateNewBackupRequest(nullptr) {} + virtual ~CreateNewBackupRequest(); + explicit constexpr CreateNewBackupRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); - ResetKeyRequest(const ResetKeyRequest& from); - ResetKeyRequest(ResetKeyRequest&& from) noexcept - : ResetKeyRequest() { + CreateNewBackupRequest(const CreateNewBackupRequest& from); + CreateNewBackupRequest(CreateNewBackupRequest&& from) noexcept + : CreateNewBackupRequest() { *this = ::std::move(from); } - inline ResetKeyRequest& operator=(const ResetKeyRequest& from) { + inline CreateNewBackupRequest& operator=(const CreateNewBackupRequest& from) { CopyFrom(from); return *this; } - inline ResetKeyRequest& operator=(ResetKeyRequest&& from) noexcept { + inline CreateNewBackupRequest& operator=(CreateNewBackupRequest&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { @@ -122,26 +122,27 @@ static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } - static const ResetKeyRequest& default_instance() { + static const CreateNewBackupRequest& default_instance() { return *internal_default_instance(); } enum DataCase { + kUserID = 1, kNewKey = 2, kCompactionChunk = 3, DATA_NOT_SET = 0, }; - static inline const ResetKeyRequest* internal_default_instance() { - return reinterpret_cast( - &_ResetKeyRequest_default_instance_); + static inline const CreateNewBackupRequest* internal_default_instance() { + return reinterpret_cast( + &_CreateNewBackupRequest_default_instance_); } static constexpr int kIndexInFileMessages = 0; - friend void swap(ResetKeyRequest& a, ResetKeyRequest& b) { + friend void swap(CreateNewBackupRequest& a, CreateNewBackupRequest& b) { a.Swap(&b); } - inline void Swap(ResetKeyRequest* other) { + inline void Swap(CreateNewBackupRequest* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); @@ -149,7 +150,7 @@ ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } - void UnsafeArenaSwap(ResetKeyRequest* other) { + void UnsafeArenaSwap(CreateNewBackupRequest* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); @@ -157,17 +158,17 @@ // implements Message ---------------------------------------------- - inline ResetKeyRequest* New() const final { - return CreateMaybeMessage(nullptr); + inline CreateNewBackupRequest* New() const final { + return CreateMaybeMessage(nullptr); } - ResetKeyRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final { - return CreateMaybeMessage(arena); + CreateNewBackupRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final { + return CreateMaybeMessage(arena); } void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; - void CopyFrom(const ResetKeyRequest& from); - void MergeFrom(const ResetKeyRequest& from); + void CopyFrom(const CreateNewBackupRequest& from); + void MergeFrom(const CreateNewBackupRequest& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; @@ -181,13 +182,13 @@ inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; - void InternalSwap(ResetKeyRequest* other); + void InternalSwap(CreateNewBackupRequest* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { - return "backup.ResetKeyRequest"; + return "backup.CreateNewBackupRequest"; } protected: - explicit ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); + explicit CreateNewBackupRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); @@ -206,11 +207,15 @@ // accessors ------------------------------------------------------- enum : int { - kUserIdFieldNumber = 1, + kUserIDFieldNumber = 1, kNewKeyFieldNumber = 2, kCompactionChunkFieldNumber = 3, }; - // string userId = 1; + // string userID = 1; + bool has_userid() const; + private: + bool _internal_has_userid() const; + public: void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); @@ -268,9 +273,10 @@ void clear_data(); DataCase data_case() const; - // @@protoc_insertion_point(class_scope:backup.ResetKeyRequest) + // @@protoc_insertion_point(class_scope:backup.CreateNewBackupRequest) private: class _Internal; + void set_has_userid(); void set_has_newkey(); void set_has_compactionchunk(); @@ -280,10 +286,10 @@ template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; union DataUnion { constexpr DataUnion() : _constinit_{} {} ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr newkey_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr compactionchunk_; } data_; @@ -332,6 +338,13 @@ static const SendLogRequest& default_instance() { return *internal_default_instance(); } + enum DataCase { + kUserID = 1, + kBackupID = 2, + kLogData = 3, + DATA_NOT_SET = 0, + }; + static inline const SendLogRequest* internal_default_instance() { return reinterpret_cast( &_SendLogRequest_default_instance_); @@ -407,10 +420,15 @@ // accessors ------------------------------------------------------- enum : int { - kUserIdFieldNumber = 1, - kDataFieldNumber = 2, + kUserIDFieldNumber = 1, + kBackupIDFieldNumber = 2, + kLogDataFieldNumber = 3, }; - // string userId = 1; + // string userID = 1; + bool has_userid() const; + private: + bool _internal_has_userid() const; + public: void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); @@ -426,32 +444,71 @@ std::string* _internal_mutable_userid(); public: - // bytes data = 2; - void clear_data(); - const std::string& data() const; - void set_data(const std::string& value); - void set_data(std::string&& value); - void set_data(const char* value); - void set_data(const void* value, size_t size); - std::string* mutable_data(); - std::string* release_data(); - void set_allocated_data(std::string* data); + // string backupID = 2; + bool has_backupid() const; + private: + bool _internal_has_backupid() const; + public: + void clear_backupid(); + const std::string& backupid() const; + void set_backupid(const std::string& value); + void set_backupid(std::string&& value); + void set_backupid(const char* value); + void set_backupid(const char* value, size_t size); + std::string* mutable_backupid(); + std::string* release_backupid(); + void set_allocated_backupid(std::string* backupid); + private: + const std::string& _internal_backupid() const; + void _internal_set_backupid(const std::string& value); + std::string* _internal_mutable_backupid(); + public: + + // bytes logData = 3; + bool has_logdata() const; + private: + bool _internal_has_logdata() const; + public: + void clear_logdata(); + const std::string& logdata() const; + void set_logdata(const std::string& value); + void set_logdata(std::string&& value); + void set_logdata(const char* value); + void set_logdata(const void* value, size_t size); + std::string* mutable_logdata(); + std::string* release_logdata(); + void set_allocated_logdata(std::string* logdata); private: - const std::string& _internal_data() const; - void _internal_set_data(const std::string& value); - std::string* _internal_mutable_data(); + const std::string& _internal_logdata() const; + void _internal_set_logdata(const std::string& value); + std::string* _internal_mutable_logdata(); public: + void clear_data(); + DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.SendLogRequest) private: class _Internal; + void set_has_userid(); + void set_has_backupid(); + void set_has_logdata(); + + inline bool has_data() const; + inline void clear_has_data(); template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr data_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr backupid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr logdata_; + } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- @@ -494,6 +551,13 @@ static const PullBackupKeyRequest& default_instance() { return *internal_default_instance(); } + enum DataCase { + kUserID = 1, + kBackupID = 2, + kRequestBytes = 3, + DATA_NOT_SET = 0, + }; + static inline const PullBackupKeyRequest* internal_default_instance() { return reinterpret_cast( &_PullBackupKeyRequest_default_instance_); @@ -569,10 +633,15 @@ // accessors ------------------------------------------------------- enum : int { - kUserIdFieldNumber = 1, - kPakeKeyFieldNumber = 2, + kUserIDFieldNumber = 1, + kBackupIDFieldNumber = 2, + kRequestBytesFieldNumber = 3, }; - // string userId = 1; + // string userID = 1; + bool has_userid() const; + private: + bool _internal_has_userid() const; + public: void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); @@ -588,32 +657,71 @@ std::string* _internal_mutable_userid(); public: - // bytes pakeKey = 2; - void clear_pakekey(); - const std::string& pakekey() const; - void set_pakekey(const std::string& value); - void set_pakekey(std::string&& value); - void set_pakekey(const char* value); - void set_pakekey(const void* value, size_t size); - std::string* mutable_pakekey(); - std::string* release_pakekey(); - void set_allocated_pakekey(std::string* pakekey); + // string backupID = 2; + bool has_backupid() const; + private: + bool _internal_has_backupid() const; + public: + void clear_backupid(); + const std::string& backupid() const; + void set_backupid(const std::string& value); + void set_backupid(std::string&& value); + void set_backupid(const char* value); + void set_backupid(const char* value, size_t size); + std::string* mutable_backupid(); + std::string* release_backupid(); + void set_allocated_backupid(std::string* backupid); + private: + const std::string& _internal_backupid() const; + void _internal_set_backupid(const std::string& value); + std::string* _internal_mutable_backupid(); + public: + + // bytes requestBytes = 3; + bool has_requestbytes() const; + private: + bool _internal_has_requestbytes() const; + public: + void clear_requestbytes(); + const std::string& requestbytes() const; + void set_requestbytes(const std::string& value); + void set_requestbytes(std::string&& value); + void set_requestbytes(const char* value); + void set_requestbytes(const void* value, size_t size); + std::string* mutable_requestbytes(); + std::string* release_requestbytes(); + void set_allocated_requestbytes(std::string* requestbytes); private: - const std::string& _internal_pakekey() const; - void _internal_set_pakekey(const std::string& value); - std::string* _internal_mutable_pakekey(); + const std::string& _internal_requestbytes() const; + void _internal_set_requestbytes(const std::string& value); + std::string* _internal_mutable_requestbytes(); public: + void clear_data(); + DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.PullBackupKeyRequest) private: class _Internal; + void set_has_userid(); + void set_has_backupid(); + void set_has_requestbytes(); + + inline bool has_data() const; + inline void clear_has_data(); template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr pakekey_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr backupid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr requestbytes_; + } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- @@ -656,6 +764,12 @@ static const PullBackupKeyResponse& default_instance() { return *internal_default_instance(); } + enum DataCase { + kResponseBytes = 1, + kEncryptedBackupKey = 2, + DATA_NOT_SET = 0, + }; + static inline const PullBackupKeyResponse* internal_default_instance() { return reinterpret_cast( &_PullBackupKeyResponse_default_instance_); @@ -731,9 +845,34 @@ // accessors ------------------------------------------------------- enum : int { - kEncryptedBackupKeyFieldNumber = 1, + kResponseBytesFieldNumber = 1, + kEncryptedBackupKeyFieldNumber = 2, }; - // bytes encryptedBackupKey = 1; + // bytes responseBytes = 1; + bool has_responsebytes() const; + private: + bool _internal_has_responsebytes() const; + public: + void clear_responsebytes(); + const std::string& responsebytes() const; + void set_responsebytes(const std::string& value); + void set_responsebytes(std::string&& value); + void set_responsebytes(const char* value); + void set_responsebytes(const void* value, size_t size); + std::string* mutable_responsebytes(); + std::string* release_responsebytes(); + void set_allocated_responsebytes(std::string* responsebytes); + private: + const std::string& _internal_responsebytes() const; + void _internal_set_responsebytes(const std::string& value); + std::string* _internal_mutable_responsebytes(); + public: + + // bytes encryptedBackupKey = 2; + bool has_encryptedbackupkey() const; + private: + bool _internal_has_encryptedbackupkey() const; + public: void clear_encryptedbackupkey(); const std::string& encryptedbackupkey() const; void set_encryptedbackupkey(const std::string& value); @@ -749,15 +888,29 @@ std::string* _internal_mutable_encryptedbackupkey(); public: + void clear_data(); + DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.PullBackupKeyResponse) private: class _Internal; + void set_has_responsebytes(); + void set_has_encryptedbackupkey(); + + inline bool has_data() const; + inline void clear_has_data(); template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr encryptedbackupkey_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr responsebytes_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr encryptedbackupkey_; + } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- @@ -800,6 +953,13 @@ static const PullCompactionRequest& default_instance() { return *internal_default_instance(); } + enum DataCase { + kUserID = 1, + kBackupID = 2, + kRequestBytes = 3, + DATA_NOT_SET = 0, + }; + static inline const PullCompactionRequest* internal_default_instance() { return reinterpret_cast( &_PullCompactionRequest_default_instance_); @@ -875,10 +1035,15 @@ // accessors ------------------------------------------------------- enum : int { - kUserIdFieldNumber = 1, - kMessageFieldNumber = 2, + kUserIDFieldNumber = 1, + kBackupIDFieldNumber = 2, + kRequestBytesFieldNumber = 3, }; - // string userId = 1; + // string userID = 1; + bool has_userid() const; + private: + bool _internal_has_userid() const; + public: void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); @@ -894,32 +1059,71 @@ std::string* _internal_mutable_userid(); public: - // bytes message = 2; - void clear_message(); - const std::string& message() const; - void set_message(const std::string& value); - void set_message(std::string&& value); - void set_message(const char* value); - void set_message(const void* value, size_t size); - std::string* mutable_message(); - std::string* release_message(); - void set_allocated_message(std::string* message); + // string backupID = 2; + bool has_backupid() const; + private: + bool _internal_has_backupid() const; + public: + void clear_backupid(); + const std::string& backupid() const; + void set_backupid(const std::string& value); + void set_backupid(std::string&& value); + void set_backupid(const char* value); + void set_backupid(const char* value, size_t size); + std::string* mutable_backupid(); + std::string* release_backupid(); + void set_allocated_backupid(std::string* backupid); + private: + const std::string& _internal_backupid() const; + void _internal_set_backupid(const std::string& value); + std::string* _internal_mutable_backupid(); + public: + + // bytes requestBytes = 3; + bool has_requestbytes() const; private: - const std::string& _internal_message() const; - void _internal_set_message(const std::string& value); - std::string* _internal_mutable_message(); + bool _internal_has_requestbytes() const; + public: + void clear_requestbytes(); + const std::string& requestbytes() const; + void set_requestbytes(const std::string& value); + void set_requestbytes(std::string&& value); + void set_requestbytes(const char* value); + void set_requestbytes(const void* value, size_t size); + std::string* mutable_requestbytes(); + std::string* release_requestbytes(); + void set_allocated_requestbytes(std::string* requestbytes); + private: + const std::string& _internal_requestbytes() const; + void _internal_set_requestbytes(const std::string& value); + std::string* _internal_mutable_requestbytes(); public: + void clear_data(); + DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.PullCompactionRequest) private: class _Internal; + void set_has_userid(); + void set_has_backupid(); + void set_has_requestbytes(); + + inline bool has_data() const; + inline void clear_has_data(); template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr message_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr userid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr backupid_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr requestbytes_; + } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- @@ -963,8 +1167,9 @@ return *internal_default_instance(); } enum DataCase { - kCompactionChunk = 1, - kLogChunk = 2, + kResponseBytes = 1, + kCompactionChunk = 2, + kLogChunk = 3, DATA_NOT_SET = 0, }; @@ -1043,10 +1248,31 @@ // accessors ------------------------------------------------------- enum : int { - kCompactionChunkFieldNumber = 1, - kLogChunkFieldNumber = 2, + kResponseBytesFieldNumber = 1, + kCompactionChunkFieldNumber = 2, + kLogChunkFieldNumber = 3, }; - // bytes compactionChunk = 1; + // bytes responseBytes = 1; + bool has_responsebytes() const; + private: + bool _internal_has_responsebytes() const; + public: + void clear_responsebytes(); + const std::string& responsebytes() const; + void set_responsebytes(const std::string& value); + void set_responsebytes(std::string&& value); + void set_responsebytes(const char* value); + void set_responsebytes(const void* value, size_t size); + std::string* mutable_responsebytes(); + std::string* release_responsebytes(); + void set_allocated_responsebytes(std::string* responsebytes); + private: + const std::string& _internal_responsebytes() const; + void _internal_set_responsebytes(const std::string& value); + std::string* _internal_mutable_responsebytes(); + public: + + // bytes compactionChunk = 2; bool has_compactionchunk() const; private: bool _internal_has_compactionchunk() const; @@ -1066,7 +1292,7 @@ std::string* _internal_mutable_compactionchunk(); public: - // bytes logChunk = 2; + // bytes logChunk = 3; bool has_logchunk() const; private: bool _internal_has_logchunk() const; @@ -1091,6 +1317,7 @@ // @@protoc_insertion_point(class_scope:backup.PullCompactionResponse) private: class _Internal; + void set_has_responsebytes(); void set_has_compactionchunk(); void set_has_logchunk(); @@ -1103,6 +1330,7 @@ union DataUnion { constexpr DataUnion() : _constinit_{} {} ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr responsebytes_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr compactionchunk_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr logchunk_; } data_; @@ -1120,104 +1348,153 @@ #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wstrict-aliasing" #endif // __GNUC__ -// ResetKeyRequest +// CreateNewBackupRequest -// string userId = 1; -inline void ResetKeyRequest::clear_userid() { - userid_.ClearToEmpty(); +// string userID = 1; +inline bool CreateNewBackupRequest::_internal_has_userid() const { + return data_case() == kUserID; +} +inline bool CreateNewBackupRequest::has_userid() const { + return _internal_has_userid(); +} +inline void CreateNewBackupRequest::set_has_userid() { + _oneof_case_[0] = kUserID; } -inline const std::string& ResetKeyRequest::userid() const { - // @@protoc_insertion_point(field_get:backup.ResetKeyRequest.userId) +inline void CreateNewBackupRequest::clear_userid() { + if (_internal_has_userid()) { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& CreateNewBackupRequest::userid() const { + // @@protoc_insertion_point(field_get:backup.CreateNewBackupRequest.userID) return _internal_userid(); } -inline void ResetKeyRequest::set_userid(const std::string& value) { +inline void CreateNewBackupRequest::set_userid(const std::string& value) { _internal_set_userid(value); - // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.userId) + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.userID) } -inline std::string* ResetKeyRequest::mutable_userid() { - // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.userId) +inline std::string* CreateNewBackupRequest::mutable_userid() { + // @@protoc_insertion_point(field_mutable:backup.CreateNewBackupRequest.userID) return _internal_mutable_userid(); } -inline const std::string& ResetKeyRequest::_internal_userid() const { - return userid_.Get(); +inline const std::string& CreateNewBackupRequest::_internal_userid() const { + if (_internal_has_userid()) { + return data_.userid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } -inline void ResetKeyRequest::_internal_set_userid(const std::string& value) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +inline void CreateNewBackupRequest::_internal_set_userid(const std::string& value) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void ResetKeyRequest::set_userid(std::string&& value) { - - userid_.Set( +inline void CreateNewBackupRequest::set_userid(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.userID) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.userId) + // @@protoc_insertion_point(field_set_rvalue:backup.CreateNewBackupRequest.userID) } -inline void ResetKeyRequest::set_userid(const char* value) { +inline void CreateNewBackupRequest::set_userid(const char* value) { GOOGLE_DCHECK(value != nullptr); - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.ResetKeyRequest.userId) -} -inline void ResetKeyRequest::set_userid(const char* value, - size_t size) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.ResetKeyRequest.userId) -} -inline std::string* ResetKeyRequest::_internal_mutable_userid() { - - return userid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); -} -inline std::string* ResetKeyRequest::release_userid() { - // @@protoc_insertion_point(field_release:backup.ResetKeyRequest.userId) - return userid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); -} -inline void ResetKeyRequest::set_allocated_userid(std::string* userid) { - if (userid != nullptr) { - - } else { - + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.CreateNewBackupRequest.userID) +} +inline void CreateNewBackupRequest::set_userid(const char* value, + size_t size) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } - userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, + data_.userid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.userId) + // @@protoc_insertion_point(field_set_pointer:backup.CreateNewBackupRequest.userID) +} +inline std::string* CreateNewBackupRequest::_internal_mutable_userid() { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.userid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* CreateNewBackupRequest::release_userid() { + // @@protoc_insertion_point(field_release:backup.CreateNewBackupRequest.userID) + if (_internal_has_userid()) { + clear_has_data(); + return data_.userid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void CreateNewBackupRequest::set_allocated_userid(std::string* userid) { + if (has_data()) { + clear_data(); + } + if (userid != nullptr) { + set_has_userid(); + data_.userid_.UnsafeSetDefault(userid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(userid); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.CreateNewBackupRequest.userID) } // bytes newKey = 2; -inline bool ResetKeyRequest::_internal_has_newkey() const { +inline bool CreateNewBackupRequest::_internal_has_newkey() const { return data_case() == kNewKey; } -inline bool ResetKeyRequest::has_newkey() const { +inline bool CreateNewBackupRequest::has_newkey() const { return _internal_has_newkey(); } -inline void ResetKeyRequest::set_has_newkey() { +inline void CreateNewBackupRequest::set_has_newkey() { _oneof_case_[0] = kNewKey; } -inline void ResetKeyRequest::clear_newkey() { +inline void CreateNewBackupRequest::clear_newkey() { if (_internal_has_newkey()) { data_.newkey_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); clear_has_data(); } } -inline const std::string& ResetKeyRequest::newkey() const { - // @@protoc_insertion_point(field_get:backup.ResetKeyRequest.newKey) +inline const std::string& CreateNewBackupRequest::newkey() const { + // @@protoc_insertion_point(field_get:backup.CreateNewBackupRequest.newKey) return _internal_newkey(); } -inline void ResetKeyRequest::set_newkey(const std::string& value) { +inline void CreateNewBackupRequest::set_newkey(const std::string& value) { _internal_set_newkey(value); - // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.newKey) + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.newKey) } -inline std::string* ResetKeyRequest::mutable_newkey() { - // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.newKey) +inline std::string* CreateNewBackupRequest::mutable_newkey() { + // @@protoc_insertion_point(field_mutable:backup.CreateNewBackupRequest.newKey) return _internal_mutable_newkey(); } -inline const std::string& ResetKeyRequest::_internal_newkey() const { +inline const std::string& CreateNewBackupRequest::_internal_newkey() const { if (_internal_has_newkey()) { return data_.newkey_.Get(); } return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } -inline void ResetKeyRequest::_internal_set_newkey(const std::string& value) { +inline void CreateNewBackupRequest::_internal_set_newkey(const std::string& value) { if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); @@ -1225,8 +1502,8 @@ } data_.newkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void ResetKeyRequest::set_newkey(std::string&& value) { - // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.newKey) +inline void CreateNewBackupRequest::set_newkey(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.newKey) if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); @@ -1234,9 +1511,9 @@ } data_.newkey_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.newKey) + // @@protoc_insertion_point(field_set_rvalue:backup.CreateNewBackupRequest.newKey) } -inline void ResetKeyRequest::set_newkey(const char* value) { +inline void CreateNewBackupRequest::set_newkey(const char* value) { GOOGLE_DCHECK(value != nullptr); if (!_internal_has_newkey()) { clear_data(); @@ -1245,9 +1522,9 @@ } data_.newkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.ResetKeyRequest.newKey) + // @@protoc_insertion_point(field_set_char:backup.CreateNewBackupRequest.newKey) } -inline void ResetKeyRequest::set_newkey(const void* value, +inline void CreateNewBackupRequest::set_newkey(const void* value, size_t size) { if (!_internal_has_newkey()) { clear_data(); @@ -1258,9 +1535,9 @@ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.ResetKeyRequest.newKey) + // @@protoc_insertion_point(field_set_pointer:backup.CreateNewBackupRequest.newKey) } -inline std::string* ResetKeyRequest::_internal_mutable_newkey() { +inline std::string* CreateNewBackupRequest::_internal_mutable_newkey() { if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); @@ -1269,8 +1546,8 @@ return data_.newkey_.Mutable( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } -inline std::string* ResetKeyRequest::release_newkey() { - // @@protoc_insertion_point(field_release:backup.ResetKeyRequest.newKey) +inline std::string* CreateNewBackupRequest::release_newkey() { + // @@protoc_insertion_point(field_release:backup.CreateNewBackupRequest.newKey) if (_internal_has_newkey()) { clear_has_data(); return data_.newkey_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); @@ -1278,7 +1555,7 @@ return nullptr; } } -inline void ResetKeyRequest::set_allocated_newkey(std::string* newkey) { +inline void CreateNewBackupRequest::set_allocated_newkey(std::string* newkey) { if (has_data()) { clear_data(); } @@ -1290,44 +1567,44 @@ arena->Own(newkey); } } - // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.newKey) + // @@protoc_insertion_point(field_set_allocated:backup.CreateNewBackupRequest.newKey) } // bytes compactionChunk = 3; -inline bool ResetKeyRequest::_internal_has_compactionchunk() const { +inline bool CreateNewBackupRequest::_internal_has_compactionchunk() const { return data_case() == kCompactionChunk; } -inline bool ResetKeyRequest::has_compactionchunk() const { +inline bool CreateNewBackupRequest::has_compactionchunk() const { return _internal_has_compactionchunk(); } -inline void ResetKeyRequest::set_has_compactionchunk() { +inline void CreateNewBackupRequest::set_has_compactionchunk() { _oneof_case_[0] = kCompactionChunk; } -inline void ResetKeyRequest::clear_compactionchunk() { +inline void CreateNewBackupRequest::clear_compactionchunk() { if (_internal_has_compactionchunk()) { data_.compactionchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); clear_has_data(); } } -inline const std::string& ResetKeyRequest::compactionchunk() const { - // @@protoc_insertion_point(field_get:backup.ResetKeyRequest.compactionChunk) +inline const std::string& CreateNewBackupRequest::compactionchunk() const { + // @@protoc_insertion_point(field_get:backup.CreateNewBackupRequest.compactionChunk) return _internal_compactionchunk(); } -inline void ResetKeyRequest::set_compactionchunk(const std::string& value) { +inline void CreateNewBackupRequest::set_compactionchunk(const std::string& value) { _internal_set_compactionchunk(value); - // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.compactionChunk) + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.compactionChunk) } -inline std::string* ResetKeyRequest::mutable_compactionchunk() { - // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.compactionChunk) +inline std::string* CreateNewBackupRequest::mutable_compactionchunk() { + // @@protoc_insertion_point(field_mutable:backup.CreateNewBackupRequest.compactionChunk) return _internal_mutable_compactionchunk(); } -inline const std::string& ResetKeyRequest::_internal_compactionchunk() const { +inline const std::string& CreateNewBackupRequest::_internal_compactionchunk() const { if (_internal_has_compactionchunk()) { return data_.compactionchunk_.Get(); } return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } -inline void ResetKeyRequest::_internal_set_compactionchunk(const std::string& value) { +inline void CreateNewBackupRequest::_internal_set_compactionchunk(const std::string& value) { if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); @@ -1335,8 +1612,8 @@ } data_.compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void ResetKeyRequest::set_compactionchunk(std::string&& value) { - // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.compactionChunk) +inline void CreateNewBackupRequest::set_compactionchunk(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.CreateNewBackupRequest.compactionChunk) if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); @@ -1344,9 +1621,9 @@ } data_.compactionchunk_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.compactionChunk) + // @@protoc_insertion_point(field_set_rvalue:backup.CreateNewBackupRequest.compactionChunk) } -inline void ResetKeyRequest::set_compactionchunk(const char* value) { +inline void CreateNewBackupRequest::set_compactionchunk(const char* value) { GOOGLE_DCHECK(value != nullptr); if (!_internal_has_compactionchunk()) { clear_data(); @@ -1355,9 +1632,9 @@ } data_.compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.ResetKeyRequest.compactionChunk) + // @@protoc_insertion_point(field_set_char:backup.CreateNewBackupRequest.compactionChunk) } -inline void ResetKeyRequest::set_compactionchunk(const void* value, +inline void CreateNewBackupRequest::set_compactionchunk(const void* value, size_t size) { if (!_internal_has_compactionchunk()) { clear_data(); @@ -1368,9 +1645,9 @@ ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.ResetKeyRequest.compactionChunk) + // @@protoc_insertion_point(field_set_pointer:backup.CreateNewBackupRequest.compactionChunk) } -inline std::string* ResetKeyRequest::_internal_mutable_compactionchunk() { +inline std::string* CreateNewBackupRequest::_internal_mutable_compactionchunk() { if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); @@ -1379,8 +1656,8 @@ return data_.compactionchunk_.Mutable( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } -inline std::string* ResetKeyRequest::release_compactionchunk() { - // @@protoc_insertion_point(field_release:backup.ResetKeyRequest.compactionChunk) +inline std::string* CreateNewBackupRequest::release_compactionchunk() { + // @@protoc_insertion_point(field_release:backup.CreateNewBackupRequest.compactionChunk) if (_internal_has_compactionchunk()) { clear_has_data(); return data_.compactionchunk_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); @@ -1388,7 +1665,7 @@ return nullptr; } } -inline void ResetKeyRequest::set_allocated_compactionchunk(std::string* compactionchunk) { +inline void CreateNewBackupRequest::set_allocated_compactionchunk(std::string* compactionchunk) { if (has_data()) { clear_data(); } @@ -1400,277 +1677,833 @@ arena->Own(compactionchunk); } } - // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.compactionChunk) + // @@protoc_insertion_point(field_set_allocated:backup.CreateNewBackupRequest.compactionChunk) } -inline bool ResetKeyRequest::has_data() const { +inline bool CreateNewBackupRequest::has_data() const { return data_case() != DATA_NOT_SET; } -inline void ResetKeyRequest::clear_has_data() { +inline void CreateNewBackupRequest::clear_has_data() { _oneof_case_[0] = DATA_NOT_SET; } -inline ResetKeyRequest::DataCase ResetKeyRequest::data_case() const { - return ResetKeyRequest::DataCase(_oneof_case_[0]); +inline CreateNewBackupRequest::DataCase CreateNewBackupRequest::data_case() const { + return CreateNewBackupRequest::DataCase(_oneof_case_[0]); } // ------------------------------------------------------------------- // SendLogRequest -// string userId = 1; +// string userID = 1; +inline bool SendLogRequest::_internal_has_userid() const { + return data_case() == kUserID; +} +inline bool SendLogRequest::has_userid() const { + return _internal_has_userid(); +} +inline void SendLogRequest::set_has_userid() { + _oneof_case_[0] = kUserID; +} inline void SendLogRequest::clear_userid() { - userid_.ClearToEmpty(); + if (_internal_has_userid()) { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } inline const std::string& SendLogRequest::userid() const { - // @@protoc_insertion_point(field_get:backup.SendLogRequest.userId) + // @@protoc_insertion_point(field_get:backup.SendLogRequest.userID) return _internal_userid(); } inline void SendLogRequest::set_userid(const std::string& value) { _internal_set_userid(value); - // @@protoc_insertion_point(field_set:backup.SendLogRequest.userId) + // @@protoc_insertion_point(field_set:backup.SendLogRequest.userID) } inline std::string* SendLogRequest::mutable_userid() { - // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.userId) + // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.userID) return _internal_mutable_userid(); } inline const std::string& SendLogRequest::_internal_userid() const { - return userid_.Get(); + if (_internal_has_userid()) { + return data_.userid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } inline void SendLogRequest::_internal_set_userid(const std::string& value) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void SendLogRequest::set_userid(std::string&& value) { - - userid_.Set( + // @@protoc_insertion_point(field_set:backup.SendLogRequest.userID) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.SendLogRequest.userId) + // @@protoc_insertion_point(field_set_rvalue:backup.SendLogRequest.userID) } inline void SendLogRequest::set_userid(const char* value) { GOOGLE_DCHECK(value != nullptr); - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.SendLogRequest.userId) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.SendLogRequest.userID) } inline void SendLogRequest::set_userid(const char* value, - size_t size) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.SendLogRequest.userId) + size_t size) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.SendLogRequest.userID) } inline std::string* SendLogRequest::_internal_mutable_userid() { - - return userid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.userid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* SendLogRequest::release_userid() { - // @@protoc_insertion_point(field_release:backup.SendLogRequest.userId) - return userid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + // @@protoc_insertion_point(field_release:backup.SendLogRequest.userID) + if (_internal_has_userid()) { + clear_has_data(); + return data_.userid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } } inline void SendLogRequest::set_allocated_userid(std::string* userid) { + if (has_data()) { + clear_data(); + } if (userid != nullptr) { - - } else { - + set_has_userid(); + data_.userid_.UnsafeSetDefault(userid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(userid); + } } - userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, - GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.userId) + // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.userID) } -// bytes data = 2; -inline void SendLogRequest::clear_data() { - data_.ClearToEmpty(); +// string backupID = 2; +inline bool SendLogRequest::_internal_has_backupid() const { + return data_case() == kBackupID; } -inline const std::string& SendLogRequest::data() const { - // @@protoc_insertion_point(field_get:backup.SendLogRequest.data) - return _internal_data(); +inline bool SendLogRequest::has_backupid() const { + return _internal_has_backupid(); } -inline void SendLogRequest::set_data(const std::string& value) { - _internal_set_data(value); - // @@protoc_insertion_point(field_set:backup.SendLogRequest.data) +inline void SendLogRequest::set_has_backupid() { + _oneof_case_[0] = kBackupID; } -inline std::string* SendLogRequest::mutable_data() { - // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.data) - return _internal_mutable_data(); -} -inline const std::string& SendLogRequest::_internal_data() const { - return data_.Get(); -} -inline void SendLogRequest::_internal_set_data(const std::string& value) { - - data_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); -} -inline void SendLogRequest::set_data(std::string&& value) { - - data_.Set( - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.SendLogRequest.data) -} -inline void SendLogRequest::set_data(const char* value) { - GOOGLE_DCHECK(value != nullptr); - - data_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.SendLogRequest.data) -} -inline void SendLogRequest::set_data(const void* value, - size_t size) { - - data_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.SendLogRequest.data) -} -inline std::string* SendLogRequest::_internal_mutable_data() { - - return data_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); -} -inline std::string* SendLogRequest::release_data() { - // @@protoc_insertion_point(field_release:backup.SendLogRequest.data) - return data_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); -} -inline void SendLogRequest::set_allocated_data(std::string* data) { - if (data != nullptr) { - - } else { - +inline void SendLogRequest::clear_backupid() { + if (_internal_has_backupid()) { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); } - data_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), data, - GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.data) -} - -// ------------------------------------------------------------------- - -// PullBackupKeyRequest - -// string userId = 1; -inline void PullBackupKeyRequest::clear_userid() { - userid_.ClearToEmpty(); } -inline const std::string& PullBackupKeyRequest::userid() const { - // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.userId) - return _internal_userid(); +inline const std::string& SendLogRequest::backupid() const { + // @@protoc_insertion_point(field_get:backup.SendLogRequest.backupID) + return _internal_backupid(); } -inline void PullBackupKeyRequest::set_userid(const std::string& value) { - _internal_set_userid(value); - // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.userId) +inline void SendLogRequest::set_backupid(const std::string& value) { + _internal_set_backupid(value); + // @@protoc_insertion_point(field_set:backup.SendLogRequest.backupID) } -inline std::string* PullBackupKeyRequest::mutable_userid() { - // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.userId) - return _internal_mutable_userid(); +inline std::string* SendLogRequest::mutable_backupid() { + // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.backupID) + return _internal_mutable_backupid(); } -inline const std::string& PullBackupKeyRequest::_internal_userid() const { - return userid_.Get(); +inline const std::string& SendLogRequest::_internal_backupid() const { + if (_internal_has_backupid()) { + return data_.backupid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } -inline void PullBackupKeyRequest::_internal_set_userid(const std::string& value) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +inline void SendLogRequest::_internal_set_backupid(const std::string& value) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void PullBackupKeyRequest::set_userid(std::string&& value) { - - userid_.Set( +inline void SendLogRequest::set_backupid(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.SendLogRequest.backupID) + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.userId) + // @@protoc_insertion_point(field_set_rvalue:backup.SendLogRequest.backupID) } -inline void PullBackupKeyRequest::set_userid(const char* value) { +inline void SendLogRequest::set_backupid(const char* value) { GOOGLE_DCHECK(value != nullptr); - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyRequest.userId) -} -inline void PullBackupKeyRequest::set_userid(const char* value, - size_t size) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyRequest.userId) + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.SendLogRequest.backupID) } -inline std::string* PullBackupKeyRequest::_internal_mutable_userid() { - - return userid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +inline void SendLogRequest::set_backupid(const char* value, + size_t size) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.SendLogRequest.backupID) } -inline std::string* PullBackupKeyRequest::release_userid() { - // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.userId) - return userid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); +inline std::string* SendLogRequest::_internal_mutable_backupid() { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.backupid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } -inline void PullBackupKeyRequest::set_allocated_userid(std::string* userid) { - if (userid != nullptr) { - +inline std::string* SendLogRequest::release_backupid() { + // @@protoc_insertion_point(field_release:backup.SendLogRequest.backupID) + if (_internal_has_backupid()) { + clear_has_data(); + return data_.backupid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } else { - + return nullptr; } - userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, - GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.userId) +} +inline void SendLogRequest::set_allocated_backupid(std::string* backupid) { + if (has_data()) { + clear_data(); + } + if (backupid != nullptr) { + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(backupid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(backupid); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.backupID) } -// bytes pakeKey = 2; -inline void PullBackupKeyRequest::clear_pakekey() { - pakekey_.ClearToEmpty(); +// bytes logData = 3; +inline bool SendLogRequest::_internal_has_logdata() const { + return data_case() == kLogData; +} +inline bool SendLogRequest::has_logdata() const { + return _internal_has_logdata(); +} +inline void SendLogRequest::set_has_logdata() { + _oneof_case_[0] = kLogData; +} +inline void SendLogRequest::clear_logdata() { + if (_internal_has_logdata()) { + data_.logdata_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } -inline const std::string& PullBackupKeyRequest::pakekey() const { - // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.pakeKey) - return _internal_pakekey(); +inline const std::string& SendLogRequest::logdata() const { + // @@protoc_insertion_point(field_get:backup.SendLogRequest.logData) + return _internal_logdata(); } -inline void PullBackupKeyRequest::set_pakekey(const std::string& value) { - _internal_set_pakekey(value); - // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.pakeKey) +inline void SendLogRequest::set_logdata(const std::string& value) { + _internal_set_logdata(value); + // @@protoc_insertion_point(field_set:backup.SendLogRequest.logData) } -inline std::string* PullBackupKeyRequest::mutable_pakekey() { - // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.pakeKey) - return _internal_mutable_pakekey(); +inline std::string* SendLogRequest::mutable_logdata() { + // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.logData) + return _internal_mutable_logdata(); } -inline const std::string& PullBackupKeyRequest::_internal_pakekey() const { - return pakekey_.Get(); +inline const std::string& SendLogRequest::_internal_logdata() const { + if (_internal_has_logdata()) { + return data_.logdata_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } -inline void PullBackupKeyRequest::_internal_set_pakekey(const std::string& value) { - - pakekey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +inline void SendLogRequest::_internal_set_logdata(const std::string& value) { + if (!_internal_has_logdata()) { + clear_data(); + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logdata_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void PullBackupKeyRequest::set_pakekey(std::string&& value) { - - pakekey_.Set( +inline void SendLogRequest::set_logdata(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.SendLogRequest.logData) + if (!_internal_has_logdata()) { + clear_data(); + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logdata_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.pakeKey) + // @@protoc_insertion_point(field_set_rvalue:backup.SendLogRequest.logData) } -inline void PullBackupKeyRequest::set_pakekey(const char* value) { +inline void SendLogRequest::set_logdata(const char* value) { GOOGLE_DCHECK(value != nullptr); - - pakekey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyRequest.pakeKey) -} -inline void PullBackupKeyRequest::set_pakekey(const void* value, - size_t size) { - - pakekey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyRequest.pakeKey) -} -inline std::string* PullBackupKeyRequest::_internal_mutable_pakekey() { - - return pakekey_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); -} -inline std::string* PullBackupKeyRequest::release_pakekey() { - // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.pakeKey) - return pakekey_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); -} -inline void PullBackupKeyRequest::set_allocated_pakekey(std::string* pakekey) { - if (pakekey != nullptr) { - - } else { - + if (!_internal_has_logdata()) { + clear_data(); + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } - pakekey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), pakekey, - GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.pakeKey) + data_.logdata_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.SendLogRequest.logData) +} +inline void SendLogRequest::set_logdata(const void* value, + size_t size) { + if (!_internal_has_logdata()) { + clear_data(); + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logdata_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.SendLogRequest.logData) +} +inline std::string* SendLogRequest::_internal_mutable_logdata() { + if (!_internal_has_logdata()) { + clear_data(); + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.logdata_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* SendLogRequest::release_logdata() { + // @@protoc_insertion_point(field_release:backup.SendLogRequest.logData) + if (_internal_has_logdata()) { + clear_has_data(); + return data_.logdata_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void SendLogRequest::set_allocated_logdata(std::string* logdata) { + if (has_data()) { + clear_data(); + } + if (logdata != nullptr) { + set_has_logdata(); + data_.logdata_.UnsafeSetDefault(logdata); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(logdata); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.logData) +} + +inline bool SendLogRequest::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void SendLogRequest::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline SendLogRequest::DataCase SendLogRequest::data_case() const { + return SendLogRequest::DataCase(_oneof_case_[0]); +} +// ------------------------------------------------------------------- + +// PullBackupKeyRequest + +// string userID = 1; +inline bool PullBackupKeyRequest::_internal_has_userid() const { + return data_case() == kUserID; +} +inline bool PullBackupKeyRequest::has_userid() const { + return _internal_has_userid(); +} +inline void PullBackupKeyRequest::set_has_userid() { + _oneof_case_[0] = kUserID; +} +inline void PullBackupKeyRequest::clear_userid() { + if (_internal_has_userid()) { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullBackupKeyRequest::userid() const { + // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.userID) + return _internal_userid(); +} +inline void PullBackupKeyRequest::set_userid(const std::string& value) { + _internal_set_userid(value); + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.userID) +} +inline std::string* PullBackupKeyRequest::mutable_userid() { + // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.userID) + return _internal_mutable_userid(); +} +inline const std::string& PullBackupKeyRequest::_internal_userid() const { + if (_internal_has_userid()) { + return data_.userid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullBackupKeyRequest::_internal_set_userid(const std::string& value) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullBackupKeyRequest::set_userid(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.userID) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.userID) +} +inline void PullBackupKeyRequest::set_userid(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyRequest.userID) +} +inline void PullBackupKeyRequest::set_userid(const char* value, + size_t size) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyRequest.userID) +} +inline std::string* PullBackupKeyRequest::_internal_mutable_userid() { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.userid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullBackupKeyRequest::release_userid() { + // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.userID) + if (_internal_has_userid()) { + clear_has_data(); + return data_.userid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullBackupKeyRequest::set_allocated_userid(std::string* userid) { + if (has_data()) { + clear_data(); + } + if (userid != nullptr) { + set_has_userid(); + data_.userid_.UnsafeSetDefault(userid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(userid); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.userID) +} + +// string backupID = 2; +inline bool PullBackupKeyRequest::_internal_has_backupid() const { + return data_case() == kBackupID; +} +inline bool PullBackupKeyRequest::has_backupid() const { + return _internal_has_backupid(); +} +inline void PullBackupKeyRequest::set_has_backupid() { + _oneof_case_[0] = kBackupID; +} +inline void PullBackupKeyRequest::clear_backupid() { + if (_internal_has_backupid()) { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullBackupKeyRequest::backupid() const { + // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.backupID) + return _internal_backupid(); +} +inline void PullBackupKeyRequest::set_backupid(const std::string& value) { + _internal_set_backupid(value); + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.backupID) +} +inline std::string* PullBackupKeyRequest::mutable_backupid() { + // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.backupID) + return _internal_mutable_backupid(); +} +inline const std::string& PullBackupKeyRequest::_internal_backupid() const { + if (_internal_has_backupid()) { + return data_.backupid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullBackupKeyRequest::_internal_set_backupid(const std::string& value) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullBackupKeyRequest::set_backupid(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.backupID) + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.backupID) +} +inline void PullBackupKeyRequest::set_backupid(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyRequest.backupID) +} +inline void PullBackupKeyRequest::set_backupid(const char* value, + size_t size) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyRequest.backupID) +} +inline std::string* PullBackupKeyRequest::_internal_mutable_backupid() { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.backupid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullBackupKeyRequest::release_backupid() { + // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.backupID) + if (_internal_has_backupid()) { + clear_has_data(); + return data_.backupid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullBackupKeyRequest::set_allocated_backupid(std::string* backupid) { + if (has_data()) { + clear_data(); + } + if (backupid != nullptr) { + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(backupid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(backupid); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.backupID) +} + +// bytes requestBytes = 3; +inline bool PullBackupKeyRequest::_internal_has_requestbytes() const { + return data_case() == kRequestBytes; +} +inline bool PullBackupKeyRequest::has_requestbytes() const { + return _internal_has_requestbytes(); +} +inline void PullBackupKeyRequest::set_has_requestbytes() { + _oneof_case_[0] = kRequestBytes; +} +inline void PullBackupKeyRequest::clear_requestbytes() { + if (_internal_has_requestbytes()) { + data_.requestbytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullBackupKeyRequest::requestbytes() const { + // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.requestBytes) + return _internal_requestbytes(); +} +inline void PullBackupKeyRequest::set_requestbytes(const std::string& value) { + _internal_set_requestbytes(value); + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.requestBytes) +} +inline std::string* PullBackupKeyRequest::mutable_requestbytes() { + // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.requestBytes) + return _internal_mutable_requestbytes(); +} +inline const std::string& PullBackupKeyRequest::_internal_requestbytes() const { + if (_internal_has_requestbytes()) { + return data_.requestbytes_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullBackupKeyRequest::_internal_set_requestbytes(const std::string& value) { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullBackupKeyRequest::set_requestbytes(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.requestBytes) + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.requestBytes) +} +inline void PullBackupKeyRequest::set_requestbytes(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyRequest.requestBytes) +} +inline void PullBackupKeyRequest::set_requestbytes(const void* value, + size_t size) { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyRequest.requestBytes) +} +inline std::string* PullBackupKeyRequest::_internal_mutable_requestbytes() { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.requestbytes_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullBackupKeyRequest::release_requestbytes() { + // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.requestBytes) + if (_internal_has_requestbytes()) { + clear_has_data(); + return data_.requestbytes_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullBackupKeyRequest::set_allocated_requestbytes(std::string* requestbytes) { + if (has_data()) { + clear_data(); + } + if (requestbytes != nullptr) { + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(requestbytes); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(requestbytes); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.requestBytes) +} + +inline bool PullBackupKeyRequest::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void PullBackupKeyRequest::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline PullBackupKeyRequest::DataCase PullBackupKeyRequest::data_case() const { + return PullBackupKeyRequest::DataCase(_oneof_case_[0]); +} +// ------------------------------------------------------------------- + +// PullBackupKeyResponse + +// bytes responseBytes = 1; +inline bool PullBackupKeyResponse::_internal_has_responsebytes() const { + return data_case() == kResponseBytes; +} +inline bool PullBackupKeyResponse::has_responsebytes() const { + return _internal_has_responsebytes(); +} +inline void PullBackupKeyResponse::set_has_responsebytes() { + _oneof_case_[0] = kResponseBytes; +} +inline void PullBackupKeyResponse::clear_responsebytes() { + if (_internal_has_responsebytes()) { + data_.responsebytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullBackupKeyResponse::responsebytes() const { + // @@protoc_insertion_point(field_get:backup.PullBackupKeyResponse.responseBytes) + return _internal_responsebytes(); +} +inline void PullBackupKeyResponse::set_responsebytes(const std::string& value) { + _internal_set_responsebytes(value); + // @@protoc_insertion_point(field_set:backup.PullBackupKeyResponse.responseBytes) +} +inline std::string* PullBackupKeyResponse::mutable_responsebytes() { + // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyResponse.responseBytes) + return _internal_mutable_responsebytes(); +} +inline const std::string& PullBackupKeyResponse::_internal_responsebytes() const { + if (_internal_has_responsebytes()) { + return data_.responsebytes_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullBackupKeyResponse::_internal_set_responsebytes(const std::string& value) { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullBackupKeyResponse::set_responsebytes(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullBackupKeyResponse.responseBytes) + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyResponse.responseBytes) +} +inline void PullBackupKeyResponse::set_responsebytes(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyResponse.responseBytes) +} +inline void PullBackupKeyResponse::set_responsebytes(const void* value, + size_t size) { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyResponse.responseBytes) +} +inline std::string* PullBackupKeyResponse::_internal_mutable_responsebytes() { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.responsebytes_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullBackupKeyResponse::release_responsebytes() { + // @@protoc_insertion_point(field_release:backup.PullBackupKeyResponse.responseBytes) + if (_internal_has_responsebytes()) { + clear_has_data(); + return data_.responsebytes_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullBackupKeyResponse::set_allocated_responsebytes(std::string* responsebytes) { + if (has_data()) { + clear_data(); + } + if (responsebytes != nullptr) { + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(responsebytes); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(responsebytes); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyResponse.responseBytes) } -// ------------------------------------------------------------------- - -// PullBackupKeyResponse - -// bytes encryptedBackupKey = 1; +// bytes encryptedBackupKey = 2; +inline bool PullBackupKeyResponse::_internal_has_encryptedbackupkey() const { + return data_case() == kEncryptedBackupKey; +} +inline bool PullBackupKeyResponse::has_encryptedbackupkey() const { + return _internal_has_encryptedbackupkey(); +} +inline void PullBackupKeyResponse::set_has_encryptedbackupkey() { + _oneof_case_[0] = kEncryptedBackupKey; +} inline void PullBackupKeyResponse::clear_encryptedbackupkey() { - encryptedbackupkey_.ClearToEmpty(); + if (_internal_has_encryptedbackupkey()) { + data_.encryptedbackupkey_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } inline const std::string& PullBackupKeyResponse::encryptedbackupkey() const { // @@protoc_insertion_point(field_get:backup.PullBackupKeyResponse.encryptedBackupKey) @@ -1685,181 +2518,554 @@ return _internal_mutable_encryptedbackupkey(); } inline const std::string& PullBackupKeyResponse::_internal_encryptedbackupkey() const { - return encryptedbackupkey_.Get(); + if (_internal_has_encryptedbackupkey()) { + return data_.encryptedbackupkey_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } inline void PullBackupKeyResponse::_internal_set_encryptedbackupkey(const std::string& value) { - - encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); + if (!_internal_has_encryptedbackupkey()) { + clear_data(); + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullBackupKeyResponse::set_encryptedbackupkey(std::string&& value) { - - encryptedbackupkey_.Set( + // @@protoc_insertion_point(field_set:backup.PullBackupKeyResponse.encryptedBackupKey) + if (!_internal_has_encryptedbackupkey()) { + clear_data(); + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.encryptedbackupkey_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyResponse.encryptedBackupKey) } inline void PullBackupKeyResponse::set_encryptedbackupkey(const char* value) { GOOGLE_DCHECK(value != nullptr); - - encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); + if (!_internal_has_encryptedbackupkey()) { + clear_data(); + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); // @@protoc_insertion_point(field_set_char:backup.PullBackupKeyResponse.encryptedBackupKey) } inline void PullBackupKeyResponse::set_encryptedbackupkey(const void* value, - size_t size) { - - encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); + size_t size) { + if (!_internal_has_encryptedbackupkey()) { + clear_data(); + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.encryptedbackupkey_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); // @@protoc_insertion_point(field_set_pointer:backup.PullBackupKeyResponse.encryptedBackupKey) } inline std::string* PullBackupKeyResponse::_internal_mutable_encryptedbackupkey() { - - return encryptedbackupkey_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + if (!_internal_has_encryptedbackupkey()) { + clear_data(); + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.encryptedbackupkey_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* PullBackupKeyResponse::release_encryptedbackupkey() { // @@protoc_insertion_point(field_release:backup.PullBackupKeyResponse.encryptedBackupKey) - return encryptedbackupkey_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + if (_internal_has_encryptedbackupkey()) { + clear_has_data(); + return data_.encryptedbackupkey_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } } inline void PullBackupKeyResponse::set_allocated_encryptedbackupkey(std::string* encryptedbackupkey) { + if (has_data()) { + clear_data(); + } if (encryptedbackupkey != nullptr) { - - } else { - + set_has_encryptedbackupkey(); + data_.encryptedbackupkey_.UnsafeSetDefault(encryptedbackupkey); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(encryptedbackupkey); + } } - encryptedbackupkey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), encryptedbackupkey, - GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyResponse.encryptedBackupKey) } +inline bool PullBackupKeyResponse::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void PullBackupKeyResponse::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline PullBackupKeyResponse::DataCase PullBackupKeyResponse::data_case() const { + return PullBackupKeyResponse::DataCase(_oneof_case_[0]); +} // ------------------------------------------------------------------- // PullCompactionRequest -// string userId = 1; +// string userID = 1; +inline bool PullCompactionRequest::_internal_has_userid() const { + return data_case() == kUserID; +} +inline bool PullCompactionRequest::has_userid() const { + return _internal_has_userid(); +} +inline void PullCompactionRequest::set_has_userid() { + _oneof_case_[0] = kUserID; +} inline void PullCompactionRequest::clear_userid() { - userid_.ClearToEmpty(); + if (_internal_has_userid()) { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } inline const std::string& PullCompactionRequest::userid() const { - // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.userId) + // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.userID) return _internal_userid(); } inline void PullCompactionRequest::set_userid(const std::string& value) { _internal_set_userid(value); - // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.userId) + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.userID) } inline std::string* PullCompactionRequest::mutable_userid() { - // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.userId) + // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.userID) return _internal_mutable_userid(); } inline const std::string& PullCompactionRequest::_internal_userid() const { - return userid_.Get(); + if (_internal_has_userid()) { + return data_.userid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } inline void PullCompactionRequest::_internal_set_userid(const std::string& value) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullCompactionRequest::set_userid(std::string&& value) { - - userid_.Set( + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.userID) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.userId) + // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.userID) } inline void PullCompactionRequest::set_userid(const char* value) { GOOGLE_DCHECK(value != nullptr); - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.PullCompactionRequest.userId) + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullCompactionRequest.userID) } inline void PullCompactionRequest::set_userid(const char* value, - size_t size) { - - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionRequest.userId) + size_t size) { + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.userid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionRequest.userID) } inline std::string* PullCompactionRequest::_internal_mutable_userid() { - - return userid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + if (!_internal_has_userid()) { + clear_data(); + set_has_userid(); + data_.userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.userid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* PullCompactionRequest::release_userid() { - // @@protoc_insertion_point(field_release:backup.PullCompactionRequest.userId) - return userid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + // @@protoc_insertion_point(field_release:backup.PullCompactionRequest.userID) + if (_internal_has_userid()) { + clear_has_data(); + return data_.userid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } } inline void PullCompactionRequest::set_allocated_userid(std::string* userid) { + if (has_data()) { + clear_data(); + } if (userid != nullptr) { - - } else { - + set_has_userid(); + data_.userid_.UnsafeSetDefault(userid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(userid); + } } - userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, - GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.userId) + // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.userID) } -// bytes message = 2; -inline void PullCompactionRequest::clear_message() { - message_.ClearToEmpty(); +// string backupID = 2; +inline bool PullCompactionRequest::_internal_has_backupid() const { + return data_case() == kBackupID; } -inline const std::string& PullCompactionRequest::message() const { - // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.message) - return _internal_message(); +inline bool PullCompactionRequest::has_backupid() const { + return _internal_has_backupid(); } -inline void PullCompactionRequest::set_message(const std::string& value) { - _internal_set_message(value); - // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.message) +inline void PullCompactionRequest::set_has_backupid() { + _oneof_case_[0] = kBackupID; } -inline std::string* PullCompactionRequest::mutable_message() { - // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.message) - return _internal_mutable_message(); +inline void PullCompactionRequest::clear_backupid() { + if (_internal_has_backupid()) { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } -inline const std::string& PullCompactionRequest::_internal_message() const { - return message_.Get(); +inline const std::string& PullCompactionRequest::backupid() const { + // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.backupID) + return _internal_backupid(); } -inline void PullCompactionRequest::_internal_set_message(const std::string& value) { - - message_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +inline void PullCompactionRequest::set_backupid(const std::string& value) { + _internal_set_backupid(value); + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.backupID) } -inline void PullCompactionRequest::set_message(std::string&& value) { - - message_.Set( +inline std::string* PullCompactionRequest::mutable_backupid() { + // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.backupID) + return _internal_mutable_backupid(); +} +inline const std::string& PullCompactionRequest::_internal_backupid() const { + if (_internal_has_backupid()) { + return data_.backupid_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullCompactionRequest::_internal_set_backupid(const std::string& value) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullCompactionRequest::set_backupid(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.backupID) + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.message) + // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.backupID) } -inline void PullCompactionRequest::set_message(const char* value) { +inline void PullCompactionRequest::set_backupid(const char* value) { GOOGLE_DCHECK(value != nullptr); - - message_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:backup.PullCompactionRequest.message) -} -inline void PullCompactionRequest::set_message(const void* value, - size_t size) { - - message_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionRequest.message) -} -inline std::string* PullCompactionRequest::_internal_mutable_message() { - - return message_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); -} -inline std::string* PullCompactionRequest::release_message() { - // @@protoc_insertion_point(field_release:backup.PullCompactionRequest.message) - return message_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); -} -inline void PullCompactionRequest::set_allocated_message(std::string* message) { - if (message != nullptr) { - + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullCompactionRequest.backupID) +} +inline void PullCompactionRequest::set_backupid(const char* value, + size_t size) { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.backupid_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionRequest.backupID) +} +inline std::string* PullCompactionRequest::_internal_mutable_backupid() { + if (!_internal_has_backupid()) { + clear_data(); + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.backupid_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullCompactionRequest::release_backupid() { + // @@protoc_insertion_point(field_release:backup.PullCompactionRequest.backupID) + if (_internal_has_backupid()) { + clear_has_data(); + return data_.backupid_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } else { - + return nullptr; + } +} +inline void PullCompactionRequest::set_allocated_backupid(std::string* backupid) { + if (has_data()) { + clear_data(); + } + if (backupid != nullptr) { + set_has_backupid(); + data_.backupid_.UnsafeSetDefault(backupid); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(backupid); + } } - message_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), message, + // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.backupID) +} + +// bytes requestBytes = 3; +inline bool PullCompactionRequest::_internal_has_requestbytes() const { + return data_case() == kRequestBytes; +} +inline bool PullCompactionRequest::has_requestbytes() const { + return _internal_has_requestbytes(); +} +inline void PullCompactionRequest::set_has_requestbytes() { + _oneof_case_[0] = kRequestBytes; +} +inline void PullCompactionRequest::clear_requestbytes() { + if (_internal_has_requestbytes()) { + data_.requestbytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullCompactionRequest::requestbytes() const { + // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.requestBytes) + return _internal_requestbytes(); +} +inline void PullCompactionRequest::set_requestbytes(const std::string& value) { + _internal_set_requestbytes(value); + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.requestBytes) +} +inline std::string* PullCompactionRequest::mutable_requestbytes() { + // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.requestBytes) + return _internal_mutable_requestbytes(); +} +inline const std::string& PullCompactionRequest::_internal_requestbytes() const { + if (_internal_has_requestbytes()) { + return data_.requestbytes_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullCompactionRequest::_internal_set_requestbytes(const std::string& value) { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullCompactionRequest::set_requestbytes(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.requestBytes) + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.requestBytes) +} +inline void PullCompactionRequest::set_requestbytes(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullCompactionRequest.requestBytes) +} +inline void PullCompactionRequest::set_requestbytes(const void* value, + size_t size) { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.requestbytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.message) + // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionRequest.requestBytes) +} +inline std::string* PullCompactionRequest::_internal_mutable_requestbytes() { + if (!_internal_has_requestbytes()) { + clear_data(); + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.requestbytes_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullCompactionRequest::release_requestbytes() { + // @@protoc_insertion_point(field_release:backup.PullCompactionRequest.requestBytes) + if (_internal_has_requestbytes()) { + clear_has_data(); + return data_.requestbytes_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullCompactionRequest::set_allocated_requestbytes(std::string* requestbytes) { + if (has_data()) { + clear_data(); + } + if (requestbytes != nullptr) { + set_has_requestbytes(); + data_.requestbytes_.UnsafeSetDefault(requestbytes); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(requestbytes); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.requestBytes) } +inline bool PullCompactionRequest::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void PullCompactionRequest::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline PullCompactionRequest::DataCase PullCompactionRequest::data_case() const { + return PullCompactionRequest::DataCase(_oneof_case_[0]); +} // ------------------------------------------------------------------- // PullCompactionResponse -// bytes compactionChunk = 1; +// bytes responseBytes = 1; +inline bool PullCompactionResponse::_internal_has_responsebytes() const { + return data_case() == kResponseBytes; +} +inline bool PullCompactionResponse::has_responsebytes() const { + return _internal_has_responsebytes(); +} +inline void PullCompactionResponse::set_has_responsebytes() { + _oneof_case_[0] = kResponseBytes; +} +inline void PullCompactionResponse::clear_responsebytes() { + if (_internal_has_responsebytes()) { + data_.responsebytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } +} +inline const std::string& PullCompactionResponse::responsebytes() const { + // @@protoc_insertion_point(field_get:backup.PullCompactionResponse.responseBytes) + return _internal_responsebytes(); +} +inline void PullCompactionResponse::set_responsebytes(const std::string& value) { + _internal_set_responsebytes(value); + // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.responseBytes) +} +inline std::string* PullCompactionResponse::mutable_responsebytes() { + // @@protoc_insertion_point(field_mutable:backup.PullCompactionResponse.responseBytes) + return _internal_mutable_responsebytes(); +} +inline const std::string& PullCompactionResponse::_internal_responsebytes() const { + if (_internal_has_responsebytes()) { + return data_.responsebytes_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); +} +inline void PullCompactionResponse::_internal_set_responsebytes(const std::string& value) { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); +} +inline void PullCompactionResponse::set_responsebytes(std::string&& value) { + // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.responseBytes) + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); + // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionResponse.responseBytes) +} +inline void PullCompactionResponse::set_responsebytes(const char* value) { + GOOGLE_DCHECK(value != nullptr); + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); + // @@protoc_insertion_point(field_set_char:backup.PullCompactionResponse.responseBytes) +} +inline void PullCompactionResponse::set_responsebytes(const void* value, + size_t size) { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.responsebytes_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); + // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionResponse.responseBytes) +} +inline std::string* PullCompactionResponse::_internal_mutable_responsebytes() { + if (!_internal_has_responsebytes()) { + clear_data(); + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.responsebytes_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); +} +inline std::string* PullCompactionResponse::release_responsebytes() { + // @@protoc_insertion_point(field_release:backup.PullCompactionResponse.responseBytes) + if (_internal_has_responsebytes()) { + clear_has_data(); + return data_.responsebytes_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } +} +inline void PullCompactionResponse::set_allocated_responsebytes(std::string* responsebytes) { + if (has_data()) { + clear_data(); + } + if (responsebytes != nullptr) { + set_has_responsebytes(); + data_.responsebytes_.UnsafeSetDefault(responsebytes); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(responsebytes); + } + } + // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionResponse.responseBytes) +} + +// bytes compactionChunk = 2; inline bool PullCompactionResponse::_internal_has_compactionchunk() const { return data_case() == kCompactionChunk; } @@ -1969,7 +3175,7 @@ // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionResponse.compactionChunk) } -// bytes logChunk = 2; +// bytes logChunk = 3; inline bool PullCompactionResponse::_internal_has_logchunk() const { return data_case() == kLogChunk; } diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc --- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc +++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc @@ -17,23 +17,21 @@ PROTOBUF_PRAGMA_INIT_SEG namespace backup { -constexpr ResetKeyRequest::ResetKeyRequest( +constexpr CreateNewBackupRequest::CreateNewBackupRequest( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) - , _oneof_case_{}{} -struct ResetKeyRequestDefaultTypeInternal { - constexpr ResetKeyRequestDefaultTypeInternal() + : _oneof_case_{}{} +struct CreateNewBackupRequestDefaultTypeInternal { + constexpr CreateNewBackupRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} - ~ResetKeyRequestDefaultTypeInternal() {} + ~CreateNewBackupRequestDefaultTypeInternal() {} union { - ResetKeyRequest _instance; + CreateNewBackupRequest _instance; }; }; -PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT ResetKeyRequestDefaultTypeInternal _ResetKeyRequest_default_instance_; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT CreateNewBackupRequestDefaultTypeInternal _CreateNewBackupRequest_default_instance_; constexpr SendLogRequest::SendLogRequest( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) - , data_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} + : _oneof_case_{}{} struct SendLogRequestDefaultTypeInternal { constexpr SendLogRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} @@ -45,8 +43,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT SendLogRequestDefaultTypeInternal _SendLogRequest_default_instance_; constexpr PullBackupKeyRequest::PullBackupKeyRequest( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) - , pakekey_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} + : _oneof_case_{}{} struct PullBackupKeyRequestDefaultTypeInternal { constexpr PullBackupKeyRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} @@ -58,7 +55,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PullBackupKeyRequestDefaultTypeInternal _PullBackupKeyRequest_default_instance_; constexpr PullBackupKeyResponse::PullBackupKeyResponse( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : encryptedbackupkey_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} + : _oneof_case_{}{} struct PullBackupKeyResponseDefaultTypeInternal { constexpr PullBackupKeyResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} @@ -70,8 +67,7 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PullBackupKeyResponseDefaultTypeInternal _PullBackupKeyResponse_default_instance_; constexpr PullCompactionRequest::PullCompactionRequest( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) - , message_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} + : _oneof_case_{}{} struct PullCompactionRequestDefaultTypeInternal { constexpr PullCompactionRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} @@ -100,41 +96,49 @@ const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_backup_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { ~0u, // no _has_bits_ - PROTOBUF_FIELD_OFFSET(::backup::ResetKeyRequest, _internal_metadata_), + PROTOBUF_FIELD_OFFSET(::backup::CreateNewBackupRequest, _internal_metadata_), ~0u, // no _extensions_ - PROTOBUF_FIELD_OFFSET(::backup::ResetKeyRequest, _oneof_case_[0]), + PROTOBUF_FIELD_OFFSET(::backup::CreateNewBackupRequest, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::ResetKeyRequest, userid_), ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, - PROTOBUF_FIELD_OFFSET(::backup::ResetKeyRequest, data_), + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::backup::CreateNewBackupRequest, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, _internal_metadata_), ~0u, // no _extensions_ - ~0u, // no _oneof_case_ + PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, userid_), + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, _internal_metadata_), ~0u, // no _extensions_ - ~0u, // no _oneof_case_ + PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, userid_), - PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, pakekey_), + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, _internal_metadata_), ~0u, // no _extensions_ - ~0u, // no _oneof_case_ + PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, encryptedbackupkey_), + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, _internal_metadata_), ~0u, // no _extensions_ - ~0u, // no _oneof_case_ + PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, userid_), - PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, message_), + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, _internal_metadata_), ~0u, // no _extensions_ @@ -142,19 +146,20 @@ ~0u, // no _weak_field_map_ ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, data_), }; static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = { - { 0, -1, sizeof(::backup::ResetKeyRequest)}, + { 0, -1, sizeof(::backup::CreateNewBackupRequest)}, { 9, -1, sizeof(::backup::SendLogRequest)}, - { 16, -1, sizeof(::backup::PullBackupKeyRequest)}, - { 23, -1, sizeof(::backup::PullBackupKeyResponse)}, - { 29, -1, sizeof(::backup::PullCompactionRequest)}, - { 36, -1, sizeof(::backup::PullCompactionResponse)}, + { 18, -1, sizeof(::backup::PullBackupKeyRequest)}, + { 27, -1, sizeof(::backup::PullBackupKeyResponse)}, + { 35, -1, sizeof(::backup::PullCompactionRequest)}, + { 44, -1, sizeof(::backup::PullCompactionResponse)}, }; static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = { - reinterpret_cast(&::backup::_ResetKeyRequest_default_instance_), + reinterpret_cast(&::backup::_CreateNewBackupRequest_default_instance_), reinterpret_cast(&::backup::_SendLogRequest_default_instance_), reinterpret_cast(&::backup::_PullBackupKeyRequest_default_instance_), reinterpret_cast(&::backup::_PullBackupKeyResponse_default_instance_), @@ -164,31 +169,36 @@ const char descriptor_table_protodef_backup_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = "\n\014backup.proto\022\006backup\032\033google/protobuf/" - "empty.proto\"V\n\017ResetKeyRequest\022\016\n\006userId" - "\030\001 \001(\t\022\020\n\006newKey\030\002 \001(\014H\000\022\031\n\017compactionCh" - "unk\030\003 \001(\014H\000B\006\n\004data\".\n\016SendLogRequest\022\016\n" - "\006userId\030\001 \001(\t\022\014\n\004data\030\002 \001(\014\"7\n\024PullBacku" - "pKeyRequest\022\016\n\006userId\030\001 \001(\t\022\017\n\007pakeKey\030\002" - " \001(\014\"3\n\025PullBackupKeyResponse\022\032\n\022encrypt" - "edBackupKey\030\001 \001(\014\"8\n\025PullCompactionReque" - "st\022\016\n\006userId\030\001 \001(\t\022\017\n\007message\030\002 \001(\014\"O\n\026P" - "ullCompactionResponse\022\031\n\017compactionChunk" - "\030\001 \001(\014H\000\022\022\n\010logChunk\030\002 \001(\014H\000B\006\n\004data2\262\002\n" - "\rBackupService\022\?\n\010ResetKey\022\027.backup.Rese" - "tKeyRequest\032\026.google.protobuf.Empty\"\000(\001\022" - ";\n\007SendLog\022\026.backup.SendLogRequest\032\026.goo" - "gle.protobuf.Empty\"\000\022N\n\rPullBackupKey\022\034." - "backup.PullBackupKeyRequest\032\035.backup.Pul" - "lBackupKeyResponse\"\000\022S\n\016PullCompaction\022\035" - ".backup.PullCompactionRequest\032\036.backup.P" - "ullCompactionResponse\"\0000\001b\006proto3" + "empty.proto\"_\n\026CreateNewBackupRequest\022\020\n" + "\006userID\030\001 \001(\tH\000\022\020\n\006newKey\030\002 \001(\014H\000\022\031\n\017com" + "pactionChunk\030\003 \001(\014H\000B\006\n\004data\"Q\n\016SendLogR" + "equest\022\020\n\006userID\030\001 \001(\tH\000\022\022\n\010backupID\030\002 \001" + "(\tH\000\022\021\n\007logData\030\003 \001(\014H\000B\006\n\004data\"\\\n\024PullB" + "ackupKeyRequest\022\020\n\006userID\030\001 \001(\tH\000\022\022\n\010bac" + "kupID\030\002 \001(\tH\000\022\026\n\014requestBytes\030\003 \001(\014H\000B\006\n" + "\004data\"V\n\025PullBackupKeyResponse\022\027\n\rrespon" + "seBytes\030\001 \001(\014H\000\022\034\n\022encryptedBackupKey\030\002 " + "\001(\014H\000B\006\n\004data\"]\n\025PullCompactionRequest\022\020" + "\n\006userID\030\001 \001(\tH\000\022\022\n\010backupID\030\002 \001(\tH\000\022\026\n\014" + "requestBytes\030\003 \001(\014H\000B\006\n\004data\"h\n\026PullComp" + "actionResponse\022\027\n\rresponseBytes\030\001 \001(\014H\000\022" + "\031\n\017compactionChunk\030\002 \001(\014H\000\022\022\n\010logChunk\030\003" + " \001(\014H\000B\006\n\004data2\310\002\n\rBackupService\022M\n\017Crea" + "teNewBackup\022\036.backup.CreateNewBackupRequ" + "est\032\026.google.protobuf.Empty\"\000(\001\022=\n\007SendL" + "og\022\026.backup.SendLogRequest\032\026.google.prot" + "obuf.Empty\"\000(\001\022R\n\rPullBackupKey\022\034.backup" + ".PullBackupKeyRequest\032\035.backup.PullBacku" + "pKeyResponse\"\000(\0010\001\022U\n\016PullCompaction\022\035.b" + "ackup.PullCompactionRequest\032\036.backup.Pul" + "lCompactionResponse\"\000(\0010\001b\006proto3" ; static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_backup_2eproto_deps[1] = { &::descriptor_table_google_2fprotobuf_2fempty_2eproto, }; static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_backup_2eproto_once; const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_backup_2eproto = { - false, false, 753, descriptor_table_protodef_backup_2eproto, "backup.proto", + false, false, 953, descriptor_table_protodef_backup_2eproto, "backup.proto", &descriptor_table_backup_2eproto_once, descriptor_table_backup_2eproto_deps, 1, 6, schemas, file_default_instances, TableStruct_backup_2eproto::offsets, file_level_metadata_backup_2eproto, file_level_enum_descriptors_backup_2eproto, file_level_service_descriptors_backup_2eproto, @@ -205,26 +215,25 @@ // =================================================================== -class ResetKeyRequest::_Internal { +class CreateNewBackupRequest::_Internal { public: }; -ResetKeyRequest::ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) +CreateNewBackupRequest::CreateNewBackupRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); - // @@protoc_insertion_point(arena_constructor:backup.ResetKeyRequest) + // @@protoc_insertion_point(arena_constructor:backup.CreateNewBackupRequest) } -ResetKeyRequest::ResetKeyRequest(const ResetKeyRequest& from) +CreateNewBackupRequest::CreateNewBackupRequest(const CreateNewBackupRequest& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_userid().empty()) { - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_userid(), - GetArena()); - } clear_has_data(); switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } case kNewKey: { _internal_set_newkey(from._internal_newkey()); break; @@ -237,41 +246,43 @@ break; } } - // @@protoc_insertion_point(copy_constructor:backup.ResetKeyRequest) + // @@protoc_insertion_point(copy_constructor:backup.CreateNewBackupRequest) } -void ResetKeyRequest::SharedCtor() { -userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +void CreateNewBackupRequest::SharedCtor() { clear_has_data(); } -ResetKeyRequest::~ResetKeyRequest() { - // @@protoc_insertion_point(destructor:backup.ResetKeyRequest) +CreateNewBackupRequest::~CreateNewBackupRequest() { + // @@protoc_insertion_point(destructor:backup.CreateNewBackupRequest) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } -void ResetKeyRequest::SharedDtor() { +void CreateNewBackupRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); if (has_data()) { clear_data(); } } -void ResetKeyRequest::ArenaDtor(void* object) { - ResetKeyRequest* _this = reinterpret_cast< ResetKeyRequest* >(object); +void CreateNewBackupRequest::ArenaDtor(void* object) { + CreateNewBackupRequest* _this = reinterpret_cast< CreateNewBackupRequest* >(object); (void)_this; } -void ResetKeyRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { +void CreateNewBackupRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } -void ResetKeyRequest::SetCachedSize(int size) const { +void CreateNewBackupRequest::SetCachedSize(int size) const { _cached_size_.Set(size); } -void ResetKeyRequest::clear_data() { -// @@protoc_insertion_point(one_of_clear_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.CreateNewBackupRequest) switch (data_case()) { + case kUserID: { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } case kNewKey: { data_.newkey_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); break; @@ -288,30 +299,29 @@ } -void ResetKeyRequest::Clear() { -// @@protoc_insertion_point(message_clear_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::Clear() { +// @@protoc_insertion_point(message_clear_start:backup.CreateNewBackupRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - userid_.ClearToEmpty(); clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } -const char* ResetKeyRequest::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { +const char* CreateNewBackupRequest::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // string userId = 1; + // string userID = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_userid(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.ResetKeyRequest.userId")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.CreateNewBackupRequest.userID")); CHK_(ptr); } else goto handle_unusual; continue; @@ -353,18 +363,18 @@ #undef CHK_ } -::PROTOBUF_NAMESPACE_ID::uint8* ResetKeyRequest::_InternalSerialize( +::PROTOBUF_NAMESPACE_ID::uint8* CreateNewBackupRequest::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { - // @@protoc_insertion_point(serialize_to_array_start:backup.ResetKeyRequest) + // @@protoc_insertion_point(serialize_to_array_start:backup.CreateNewBackupRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { + // string userID = 1; + if (_internal_has_userid()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->_internal_userid().data(), static_cast(this->_internal_userid().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "backup.ResetKeyRequest.userId"); + "backup.CreateNewBackupRequest.userID"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } @@ -385,26 +395,26 @@ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); } - // @@protoc_insertion_point(serialize_to_array_end:backup.ResetKeyRequest) + // @@protoc_insertion_point(serialize_to_array_end:backup.CreateNewBackupRequest) return target; } -size_t ResetKeyRequest::ByteSizeLong() const { -// @@protoc_insertion_point(message_byte_size_start:backup.ResetKeyRequest) +size_t CreateNewBackupRequest::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:backup.CreateNewBackupRequest) size_t total_size = 0; ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_userid()); - } - switch (data_case()) { + // string userID = 1; + case kUserID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_userid()); + break; + } // bytes newKey = 2; case kNewKey: { total_size += 1 + @@ -432,32 +442,33 @@ return total_size; } -void ResetKeyRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { -// @@protoc_insertion_point(generalized_merge_from_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { +// @@protoc_insertion_point(generalized_merge_from_start:backup.CreateNewBackupRequest) GOOGLE_DCHECK_NE(&from, this); - const ResetKeyRequest* source = - ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( + const CreateNewBackupRequest* source = + ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { - // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.ResetKeyRequest) + // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.CreateNewBackupRequest) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { - // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.ResetKeyRequest) + // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.CreateNewBackupRequest) MergeFrom(*source); } } -void ResetKeyRequest::MergeFrom(const ResetKeyRequest& from) { -// @@protoc_insertion_point(class_specific_merge_from_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::MergeFrom(const CreateNewBackupRequest& from) { +// @@protoc_insertion_point(class_specific_merge_from_start:backup.CreateNewBackupRequest) GOOGLE_DCHECK_NE(&from, this); _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - if (from.userid().size() > 0) { - _internal_set_userid(from._internal_userid()); - } switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } case kNewKey: { _internal_set_newkey(from._internal_newkey()); break; @@ -472,33 +483,32 @@ } } -void ResetKeyRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { -// @@protoc_insertion_point(generalized_copy_from_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { +// @@protoc_insertion_point(generalized_copy_from_start:backup.CreateNewBackupRequest) if (&from == this) return; Clear(); MergeFrom(from); } -void ResetKeyRequest::CopyFrom(const ResetKeyRequest& from) { -// @@protoc_insertion_point(class_specific_copy_from_start:backup.ResetKeyRequest) +void CreateNewBackupRequest::CopyFrom(const CreateNewBackupRequest& from) { +// @@protoc_insertion_point(class_specific_copy_from_start:backup.CreateNewBackupRequest) if (&from == this) return; Clear(); MergeFrom(from); } -bool ResetKeyRequest::IsInitialized() const { +bool CreateNewBackupRequest::IsInitialized() const { return true; } -void ResetKeyRequest::InternalSwap(ResetKeyRequest* other) { +void CreateNewBackupRequest::InternalSwap(CreateNewBackupRequest* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - userid_.Swap(&other->userid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); swap(data_, other->data_); swap(_oneof_case_[0], other->_oneof_case_[0]); } -::PROTOBUF_NAMESPACE_ID::Metadata ResetKeyRequest::GetMetadata() const { +::PROTOBUF_NAMESPACE_ID::Metadata CreateNewBackupRequest::GetMetadata() const { return GetMetadataStatic(); } @@ -518,22 +528,29 @@ SendLogRequest::SendLogRequest(const SendLogRequest& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_userid().empty()) { - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_userid(), - GetArena()); - } - data_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_data().empty()) { - data_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_data(), - GetArena()); + clear_has_data(); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kLogData: { + _internal_set_logdata(from._internal_logdata()); + break; + } + case DATA_NOT_SET: { + break; + } } // @@protoc_insertion_point(copy_constructor:backup.SendLogRequest) } void SendLogRequest::SharedCtor() { -userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); -data_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +clear_has_data(); } SendLogRequest::~SendLogRequest() { @@ -544,8 +561,9 @@ void SendLogRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - data_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + if (has_data()) { + clear_data(); + } } void SendLogRequest::ArenaDtor(void* object) { @@ -558,14 +576,36 @@ _cached_size_.Set(size); } +void SendLogRequest::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.SendLogRequest) + switch (data_case()) { + case kUserID: { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kBackupID: { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kLogData: { + data_.logdata_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + void SendLogRequest::Clear() { // @@protoc_insertion_point(message_clear_start:backup.SendLogRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - userid_.ClearToEmpty(); - data_.ClearToEmpty(); + clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -576,19 +616,28 @@ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // string userId = 1; + // string userID = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_userid(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.SendLogRequest.userId")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.SendLogRequest.userID")); CHK_(ptr); } else goto handle_unusual; continue; - // bytes data = 2; + // string backupID = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { - auto str = _internal_mutable_data(); + auto str = _internal_mutable_backupid(); + ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.SendLogRequest.backupID")); + CHK_(ptr); + } else goto handle_unusual; + continue; + // bytes logData = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) { + auto str = _internal_mutable_logdata(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; @@ -621,20 +670,30 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { + // string userID = 1; + if (_internal_has_userid()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->_internal_userid().data(), static_cast(this->_internal_userid().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "backup.SendLogRequest.userId"); + "backup.SendLogRequest.userID"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } - // bytes data = 2; - if (this->data().size() > 0) { + // string backupID = 2; + if (_internal_has_backupid()) { + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + this->_internal_backupid().data(), static_cast(this->_internal_backupid().length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "backup.SendLogRequest.backupID"); + target = stream->WriteStringMaybeAliased( + 2, this->_internal_backupid(), target); + } + + // bytes logData = 3; + if (_internal_has_logdata()) { target = stream->WriteBytesMaybeAliased( - 2, this->_internal_data(), target); + 3, this->_internal_logdata(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -653,20 +712,32 @@ // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_userid()); - } - - // bytes data = 2; - if (this->data().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_data()); + switch (data_case()) { + // string userID = 1; + case kUserID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_userid()); + break; + } + // string backupID = 2; + case kBackupID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_backupid()); + break; + } + // bytes logData = 3; + case kLogData: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_logdata()); + break; + } + case DATA_NOT_SET: { + break; + } } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); @@ -698,11 +769,22 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - if (from.userid().size() > 0) { - _internal_set_userid(from._internal_userid()); - } - if (from.data().size() > 0) { - _internal_set_data(from._internal_data()); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kLogData: { + _internal_set_logdata(from._internal_logdata()); + break; + } + case DATA_NOT_SET: { + break; + } } } @@ -727,8 +809,8 @@ void SendLogRequest::InternalSwap(SendLogRequest* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - userid_.Swap(&other->userid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); - data_.Swap(&other->data_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata SendLogRequest::GetMetadata() const { @@ -751,22 +833,29 @@ PullBackupKeyRequest::PullBackupKeyRequest(const PullBackupKeyRequest& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_userid().empty()) { - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_userid(), - GetArena()); - } - pakekey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_pakekey().empty()) { - pakekey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_pakekey(), - GetArena()); + clear_has_data(); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kRequestBytes: { + _internal_set_requestbytes(from._internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } // @@protoc_insertion_point(copy_constructor:backup.PullBackupKeyRequest) } void PullBackupKeyRequest::SharedCtor() { -userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); -pakekey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +clear_has_data(); } PullBackupKeyRequest::~PullBackupKeyRequest() { @@ -777,8 +866,9 @@ void PullBackupKeyRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - pakekey_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + if (has_data()) { + clear_data(); + } } void PullBackupKeyRequest::ArenaDtor(void* object) { @@ -791,14 +881,36 @@ _cached_size_.Set(size); } +void PullBackupKeyRequest::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.PullBackupKeyRequest) + switch (data_case()) { + case kUserID: { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kBackupID: { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kRequestBytes: { + data_.requestbytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + void PullBackupKeyRequest::Clear() { // @@protoc_insertion_point(message_clear_start:backup.PullBackupKeyRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - userid_.ClearToEmpty(); - pakekey_.ClearToEmpty(); + clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -809,19 +921,28 @@ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // string userId = 1; + // string userID = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_userid(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullBackupKeyRequest.userId")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullBackupKeyRequest.userID")); CHK_(ptr); } else goto handle_unusual; continue; - // bytes pakeKey = 2; + // string backupID = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { - auto str = _internal_mutable_pakekey(); + auto str = _internal_mutable_backupid(); + ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullBackupKeyRequest.backupID")); + CHK_(ptr); + } else goto handle_unusual; + continue; + // bytes requestBytes = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) { + auto str = _internal_mutable_requestbytes(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; @@ -854,20 +975,30 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { + // string userID = 1; + if (_internal_has_userid()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->_internal_userid().data(), static_cast(this->_internal_userid().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "backup.PullBackupKeyRequest.userId"); + "backup.PullBackupKeyRequest.userID"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } - // bytes pakeKey = 2; - if (this->pakekey().size() > 0) { + // string backupID = 2; + if (_internal_has_backupid()) { + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + this->_internal_backupid().data(), static_cast(this->_internal_backupid().length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "backup.PullBackupKeyRequest.backupID"); + target = stream->WriteStringMaybeAliased( + 2, this->_internal_backupid(), target); + } + + // bytes requestBytes = 3; + if (_internal_has_requestbytes()) { target = stream->WriteBytesMaybeAliased( - 2, this->_internal_pakekey(), target); + 3, this->_internal_requestbytes(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -886,20 +1017,32 @@ // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_userid()); - } - - // bytes pakeKey = 2; - if (this->pakekey().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_pakekey()); + switch (data_case()) { + // string userID = 1; + case kUserID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_userid()); + break; + } + // string backupID = 2; + case kBackupID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_backupid()); + break; + } + // bytes requestBytes = 3; + case kRequestBytes: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); @@ -931,11 +1074,22 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - if (from.userid().size() > 0) { - _internal_set_userid(from._internal_userid()); - } - if (from.pakekey().size() > 0) { - _internal_set_pakekey(from._internal_pakekey()); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kRequestBytes: { + _internal_set_requestbytes(from._internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } } @@ -960,8 +1114,8 @@ void PullBackupKeyRequest::InternalSwap(PullBackupKeyRequest* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - userid_.Swap(&other->userid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); - pakekey_.Swap(&other->pakekey_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata PullBackupKeyRequest::GetMetadata() const { @@ -984,16 +1138,25 @@ PullBackupKeyResponse::PullBackupKeyResponse(const PullBackupKeyResponse& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_encryptedbackupkey().empty()) { - encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_encryptedbackupkey(), - GetArena()); + clear_has_data(); + switch (from.data_case()) { + case kResponseBytes: { + _internal_set_responsebytes(from._internal_responsebytes()); + break; + } + case kEncryptedBackupKey: { + _internal_set_encryptedbackupkey(from._internal_encryptedbackupkey()); + break; + } + case DATA_NOT_SET: { + break; + } } // @@protoc_insertion_point(copy_constructor:backup.PullBackupKeyResponse) } void PullBackupKeyResponse::SharedCtor() { -encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +clear_has_data(); } PullBackupKeyResponse::~PullBackupKeyResponse() { @@ -1004,7 +1167,9 @@ void PullBackupKeyResponse::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - encryptedbackupkey_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + if (has_data()) { + clear_data(); + } } void PullBackupKeyResponse::ArenaDtor(void* object) { @@ -1017,13 +1182,32 @@ _cached_size_.Set(size); } +void PullBackupKeyResponse::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.PullBackupKeyResponse) + switch (data_case()) { + case kResponseBytes: { + data_.responsebytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kEncryptedBackupKey: { + data_.encryptedbackupkey_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + void PullBackupKeyResponse::Clear() { // @@protoc_insertion_point(message_clear_start:backup.PullBackupKeyResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - encryptedbackupkey_.ClearToEmpty(); + clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -1034,9 +1218,17 @@ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // bytes encryptedBackupKey = 1; + // bytes responseBytes = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { + auto str = _internal_mutable_responsebytes(); + ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); + CHK_(ptr); + } else goto handle_unusual; + continue; + // bytes encryptedBackupKey = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_encryptedbackupkey(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); @@ -1070,10 +1262,16 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // bytes encryptedBackupKey = 1; - if (this->encryptedbackupkey().size() > 0) { + // bytes responseBytes = 1; + if (_internal_has_responsebytes()) { + target = stream->WriteBytesMaybeAliased( + 1, this->_internal_responsebytes(), target); + } + + // bytes encryptedBackupKey = 2; + if (_internal_has_encryptedbackupkey()) { target = stream->WriteBytesMaybeAliased( - 1, this->_internal_encryptedbackupkey(), target); + 2, this->_internal_encryptedbackupkey(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -1092,13 +1290,25 @@ // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - // bytes encryptedBackupKey = 1; - if (this->encryptedbackupkey().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_encryptedbackupkey()); + switch (data_case()) { + // bytes responseBytes = 1; + case kResponseBytes: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_responsebytes()); + break; + } + // bytes encryptedBackupKey = 2; + case kEncryptedBackupKey: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_encryptedbackupkey()); + break; + } + case DATA_NOT_SET: { + break; + } } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); @@ -1130,8 +1340,18 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - if (from.encryptedbackupkey().size() > 0) { - _internal_set_encryptedbackupkey(from._internal_encryptedbackupkey()); + switch (from.data_case()) { + case kResponseBytes: { + _internal_set_responsebytes(from._internal_responsebytes()); + break; + } + case kEncryptedBackupKey: { + _internal_set_encryptedbackupkey(from._internal_encryptedbackupkey()); + break; + } + case DATA_NOT_SET: { + break; + } } } @@ -1156,7 +1376,8 @@ void PullBackupKeyResponse::InternalSwap(PullBackupKeyResponse* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - encryptedbackupkey_.Swap(&other->encryptedbackupkey_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata PullBackupKeyResponse::GetMetadata() const { @@ -1179,22 +1400,29 @@ PullCompactionRequest::PullCompactionRequest(const PullCompactionRequest& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_userid().empty()) { - userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_userid(), - GetArena()); - } - message_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_message().empty()) { - message_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_message(), - GetArena()); + clear_has_data(); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kRequestBytes: { + _internal_set_requestbytes(from._internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } // @@protoc_insertion_point(copy_constructor:backup.PullCompactionRequest) } void PullCompactionRequest::SharedCtor() { -userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); -message_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +clear_has_data(); } PullCompactionRequest::~PullCompactionRequest() { @@ -1205,8 +1433,9 @@ void PullCompactionRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - message_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + if (has_data()) { + clear_data(); + } } void PullCompactionRequest::ArenaDtor(void* object) { @@ -1219,14 +1448,36 @@ _cached_size_.Set(size); } +void PullCompactionRequest::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.PullCompactionRequest) + switch (data_case()) { + case kUserID: { + data_.userid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kBackupID: { + data_.backupid_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kRequestBytes: { + data_.requestbytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + void PullCompactionRequest::Clear() { // @@protoc_insertion_point(message_clear_start:backup.PullCompactionRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - userid_.ClearToEmpty(); - message_.ClearToEmpty(); + clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -1237,19 +1488,28 @@ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // string userId = 1; + // string userID = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_userid(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullCompactionRequest.userId")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullCompactionRequest.userID")); CHK_(ptr); } else goto handle_unusual; continue; - // bytes message = 2; + // string backupID = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { - auto str = _internal_mutable_message(); + auto str = _internal_mutable_backupid(); + ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "backup.PullCompactionRequest.backupID")); + CHK_(ptr); + } else goto handle_unusual; + continue; + // bytes requestBytes = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) { + auto str = _internal_mutable_requestbytes(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; @@ -1282,20 +1542,30 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { + // string userID = 1; + if (_internal_has_userid()) { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->_internal_userid().data(), static_cast(this->_internal_userid().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "backup.PullCompactionRequest.userId"); + "backup.PullCompactionRequest.userID"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } - // bytes message = 2; - if (this->message().size() > 0) { + // string backupID = 2; + if (_internal_has_backupid()) { + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + this->_internal_backupid().data(), static_cast(this->_internal_backupid().length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "backup.PullCompactionRequest.backupID"); + target = stream->WriteStringMaybeAliased( + 2, this->_internal_backupid(), target); + } + + // bytes requestBytes = 3; + if (_internal_has_requestbytes()) { target = stream->WriteBytesMaybeAliased( - 2, this->_internal_message(), target); + 3, this->_internal_requestbytes(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -1314,20 +1584,32 @@ // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - // string userId = 1; - if (this->userid().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( - this->_internal_userid()); - } - - // bytes message = 2; - if (this->message().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_message()); + switch (data_case()) { + // string userID = 1; + case kUserID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_userid()); + break; + } + // string backupID = 2; + case kBackupID: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize( + this->_internal_backupid()); + break; + } + // bytes requestBytes = 3; + case kRequestBytes: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } - if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); @@ -1359,11 +1641,22 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - if (from.userid().size() > 0) { - _internal_set_userid(from._internal_userid()); - } - if (from.message().size() > 0) { - _internal_set_message(from._internal_message()); + switch (from.data_case()) { + case kUserID: { + _internal_set_userid(from._internal_userid()); + break; + } + case kBackupID: { + _internal_set_backupid(from._internal_backupid()); + break; + } + case kRequestBytes: { + _internal_set_requestbytes(from._internal_requestbytes()); + break; + } + case DATA_NOT_SET: { + break; + } } } @@ -1388,8 +1681,8 @@ void PullCompactionRequest::InternalSwap(PullCompactionRequest* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - userid_.Swap(&other->userid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); - message_.Swap(&other->message_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata PullCompactionRequest::GetMetadata() const { @@ -1414,6 +1707,10 @@ _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); clear_has_data(); switch (from.data_case()) { + case kResponseBytes: { + _internal_set_responsebytes(from._internal_responsebytes()); + break; + } case kCompactionChunk: { _internal_set_compactionchunk(from._internal_compactionchunk()); break; @@ -1459,6 +1756,10 @@ void PullCompactionResponse::clear_data() { // @@protoc_insertion_point(one_of_clear_start:backup.PullCompactionResponse) switch (data_case()) { + case kResponseBytes: { + data_.responsebytes_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } case kCompactionChunk: { data_.compactionchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); break; @@ -1492,17 +1793,25 @@ ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); CHK_(ptr); switch (tag >> 3) { - // bytes compactionChunk = 1; + // bytes responseBytes = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { - auto str = _internal_mutable_compactionchunk(); + auto str = _internal_mutable_responsebytes(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; - // bytes logChunk = 2; + // bytes compactionChunk = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { + auto str = _internal_mutable_compactionchunk(); + ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); + CHK_(ptr); + } else goto handle_unusual; + continue; + // bytes logChunk = 3; + case 3: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) { auto str = _internal_mutable_logchunk(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); @@ -1536,16 +1845,22 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - // bytes compactionChunk = 1; + // bytes responseBytes = 1; + if (_internal_has_responsebytes()) { + target = stream->WriteBytesMaybeAliased( + 1, this->_internal_responsebytes(), target); + } + + // bytes compactionChunk = 2; if (_internal_has_compactionchunk()) { target = stream->WriteBytesMaybeAliased( - 1, this->_internal_compactionchunk(), target); + 2, this->_internal_compactionchunk(), target); } - // bytes logChunk = 2; + // bytes logChunk = 3; if (_internal_has_logchunk()) { target = stream->WriteBytesMaybeAliased( - 2, this->_internal_logchunk(), target); + 3, this->_internal_logchunk(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { @@ -1565,14 +1880,21 @@ (void) cached_has_bits; switch (data_case()) { - // bytes compactionChunk = 1; + // bytes responseBytes = 1; + case kResponseBytes: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_responsebytes()); + break; + } + // bytes compactionChunk = 2; case kCompactionChunk: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_compactionchunk()); break; } - // bytes logChunk = 2; + // bytes logChunk = 3; case kLogChunk: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( @@ -1615,6 +1937,10 @@ (void) cached_has_bits; switch (from.data_case()) { + case kResponseBytes: { + _internal_set_responsebytes(from._internal_responsebytes()); + break; + } case kCompactionChunk: { _internal_set_compactionchunk(from._internal_compactionchunk()); break; @@ -1662,8 +1988,8 @@ // @@protoc_insertion_point(namespace_scope) } // namespace backup PROTOBUF_NAMESPACE_OPEN -template<> PROTOBUF_NOINLINE ::backup::ResetKeyRequest* Arena::CreateMaybeMessage< ::backup::ResetKeyRequest >(Arena* arena) { - return Arena::CreateMessageInternal< ::backup::ResetKeyRequest >(arena); +template<> PROTOBUF_NOINLINE ::backup::CreateNewBackupRequest* Arena::CreateMaybeMessage< ::backup::CreateNewBackupRequest >(Arena* arena) { + return Arena::CreateMessageInternal< ::backup::CreateNewBackupRequest >(arena); } template<> PROTOBUF_NOINLINE ::backup::SendLogRequest* Arena::CreateMaybeMessage< ::backup::SendLogRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::SendLogRequest >(arena); diff --git a/native/cpp/CommonCpp/grpc/protos/backup.proto b/native/cpp/CommonCpp/grpc/protos/backup.proto --- a/native/cpp/CommonCpp/grpc/protos/backup.proto +++ b/native/cpp/CommonCpp/grpc/protos/backup.proto @@ -5,17 +5,17 @@ import "google/protobuf/empty.proto"; service BackupService { - rpc ResetKey(stream ResetKeyRequest) returns (google.protobuf.Empty) {} - rpc SendLog(SendLogRequest) returns (google.protobuf.Empty) {} - rpc PullBackupKey(PullBackupKeyRequest) returns (PullBackupKeyResponse) {} - rpc PullCompaction(PullCompactionRequest) returns (stream PullCompactionResponse) {} + rpc CreateNewBackup(stream CreateNewBackupRequest) returns (google.protobuf.Empty) {} + rpc SendLog(stream SendLogRequest) returns (google.protobuf.Empty) {} + rpc PullBackupKey(stream PullBackupKeyRequest) returns (stream PullBackupKeyResponse) {} + rpc PullCompaction(stream PullCompactionRequest) returns (stream PullCompactionResponse) {} } -// ResetKey +// CreateNewBackup -message ResetKeyRequest { - string userId = 1; +message CreateNewBackupRequest { oneof data { + string userID = 1; bytes newKey = 2; bytes compactionChunk = 3; } @@ -24,31 +24,44 @@ // SendLog message SendLogRequest { - string userId = 1; - bytes data = 2; + oneof data { + string userID = 1; + string backupID = 2; + bytes logData = 3; + } } // PullBackupKey message PullBackupKeyRequest { - string userId = 1; - bytes pakeKey = 2; + oneof data { + string userID = 1; + string backupID = 2; + bytes requestBytes = 3; + } } message PullBackupKeyResponse { - bytes encryptedBackupKey = 1; + oneof data { + bytes responseBytes = 1; + bytes encryptedBackupKey = 2; + } } // PullCompaction message PullCompactionRequest { - string userId = 1; - bytes message = 2; + oneof data { + string userID = 1; + string backupID = 2; + bytes requestBytes = 3; + } } message PullCompactionResponse { oneof data { - bytes compactionChunk = 1; - bytes logChunk = 2; + bytes responseBytes = 1; + bytes compactionChunk = 2; + bytes logChunk = 3; } }