diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h index 2c2d10aba..4e53b98a1 100644 --- a/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h +++ b/native/cpp/CommonCpp/grpc/_generated/backup.grpc.pb.h @@ -1,682 +1,682 @@ // @generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: backup.proto #ifndef GRPC_backup_2eproto__INCLUDED #define GRPC_backup_2eproto__INCLUDED #include "backup.pb.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace backup { class BackupService final { public: static constexpr char const* service_full_name() { return "backup.BackupService"; } class StubInterface { public: virtual ~StubInterface() {} std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>> ResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response) { return std::unique_ptr< ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>>(ResetKeyRaw(context, response)); } std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>> AsyncResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* 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::ResetKeyRequest>> PrepareAsyncResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>>(PrepareAsyncResetKeyRaw(context, response, cq)); } virtual ::grpc::Status SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::backup::SendLogResponse* response) = 0; std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>> AsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>>(AsyncSendLogRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>> PrepareAsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>>(PrepareAsyncSendLogRaw(context, request, cq)); } 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::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::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::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::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)); } class async_interface { public: virtual ~async_interface() {} virtual void ResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::ClientWriteReactor< ::backup::ResetKeyRequest>* reactor) = 0; virtual void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* response, std::function) = 0; virtual void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* 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; }; typedef class async_interface experimental_async_interface; virtual class async_interface* async() { return nullptr; } class async_interface* experimental_async() { return async(); } - private: + private: virtual ::grpc::ClientWriterInterface< ::backup::ResetKeyRequest>* ResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response) = 0; virtual ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>* AsyncResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq, void* tag) = 0; virtual ::grpc::ClientAsyncWriterInterface< ::backup::ResetKeyRequest>* PrepareAsyncResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>* AsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::backup::SendLogResponse>* 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; }; 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, ::backup::ResetKeyResponse* response) { return std::unique_ptr< ::grpc::ClientWriter< ::backup::ResetKeyRequest>>(ResetKeyRaw(context, response)); } std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>> AsyncResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* 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::ResetKeyRequest>> PrepareAsyncResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>>(PrepareAsyncResetKeyRaw(context, response, cq)); } ::grpc::Status SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::backup::SendLogResponse* response) override; std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>> AsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>>(AsyncSendLogRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>> PrepareAsyncSendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>>(PrepareAsyncSendLogRaw(context, request, 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::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::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::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::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)); } class async final : public StubInterface::async_interface { public: void ResetKey(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::ClientWriteReactor< ::backup::ResetKeyRequest>* reactor) override; void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* response, std::function) override; void SendLog(::grpc::ClientContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* 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; private: friend class Stub; explicit async(Stub* stub): stub_(stub) { } Stub* stub() { return stub_; } Stub* stub_; }; class async* async() override { return &async_stub_; } private: std::shared_ptr< ::grpc::ChannelInterface> channel_; class async async_stub_{this}; ::grpc::ClientWriter< ::backup::ResetKeyRequest>* ResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response) override; ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* AsyncResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq, void* tag) override; ::grpc::ClientAsyncWriter< ::backup::ResetKeyRequest>* PrepareAsyncResetKeyRaw(::grpc::ClientContext* context, ::backup::ResetKeyResponse* response, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>* AsyncSendLogRaw(::grpc::ClientContext* context, const ::backup::SendLogRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::backup::SendLogResponse>* 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_; const ::grpc::internal::RpcMethod rpcmethod_SendLog_; const ::grpc::internal::RpcMethod rpcmethod_PullBackupKey_; const ::grpc::internal::RpcMethod rpcmethod_PullCompaction_; }; static std::unique_ptr NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); class Service : public ::grpc::Service { public: Service(); virtual ~Service(); virtual ::grpc::Status ResetKey(::grpc::ServerContext* context, ::grpc::ServerReader< ::backup::ResetKeyRequest>* reader, ::backup::ResetKeyResponse* response); virtual ::grpc::Status SendLog(::grpc::ServerContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* 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); }; template class WithAsyncMethod_ResetKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_ResetKey() { ::grpc::Service::MarkMethodAsync(0); } ~WithAsyncMethod_ResetKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::backup::ResetKeyResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestResetKey(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::backup::ResetKeyResponse, ::backup::ResetKeyRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncClientStreaming(0, context, reader, new_call_cq, notification_cq, tag); } }; template class WithAsyncMethod_SendLog : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_SendLog() { ::grpc::Service::MarkMethodAsync(1); } ~WithAsyncMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestSendLog(::grpc::ServerContext* context, ::backup::SendLogRequest* request, ::grpc::ServerAsyncResponseWriter< ::backup::SendLogResponse>* 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); } }; template class WithAsyncMethod_PullBackupKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_PullBackupKey() { ::grpc::Service::MarkMethodAsync(2); } ~WithAsyncMethod_PullBackupKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous 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, ""); } 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); } }; template class WithAsyncMethod_PullCompaction : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_PullCompaction() { ::grpc::Service::MarkMethodAsync(3); } ~WithAsyncMethod_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, ""); } 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); } }; typedef WithAsyncMethod_ResetKey > > > AsyncService; template class WithCallbackMethod_ResetKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_ResetKey() { ::grpc::Service::MarkMethodCallback(0, new ::grpc::internal::CallbackClientStreamingHandler< ::backup::ResetKeyRequest, ::backup::ResetKeyResponse>( [this]( ::grpc::CallbackServerContext* context, ::backup::ResetKeyResponse* response) { return this->ResetKey(context, response); })); } ~WithCallbackMethod_ResetKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::backup::ResetKeyResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerReadReactor< ::backup::ResetKeyRequest>* ResetKey( ::grpc::CallbackServerContext* /*context*/, ::backup::ResetKeyResponse* /*response*/) { return nullptr; } }; template class WithCallbackMethod_SendLog : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_SendLog() { ::grpc::Service::MarkMethodCallback(1, new ::grpc::internal::CallbackUnaryHandler< ::backup::SendLogRequest, ::backup::SendLogResponse>( [this]( ::grpc::CallbackServerContext* context, const ::backup::SendLogRequest* request, ::backup::SendLogResponse* response) { return this->SendLog(context, request, response); }));} void SetMessageAllocatorFor_SendLog( ::grpc::MessageAllocator< ::backup::SendLogRequest, ::backup::SendLogResponse>* allocator) { ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(1); static_cast<::grpc::internal::CallbackUnaryHandler< ::backup::SendLogRequest, ::backup::SendLogResponse>*>(handler) ->SetMessageAllocator(allocator); } ~WithCallbackMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* SendLog( ::grpc::CallbackServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*response*/) { return nullptr; } }; template class WithCallbackMethod_PullBackupKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_PullBackupKey() { ::grpc::Service::MarkMethodCallback(2, new ::grpc::internal::CallbackUnaryHandler< ::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); } ~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 { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* PullBackupKey( ::grpc::CallbackServerContext* /*context*/, const ::backup::PullBackupKeyRequest* /*request*/, ::backup::PullBackupKeyResponse* /*response*/) { return nullptr; } }; template class WithCallbackMethod_PullCompaction : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_PullCompaction() { ::grpc::Service::MarkMethodCallback(3, new ::grpc::internal::CallbackServerStreamingHandler< ::backup::PullCompactionRequest, ::backup::PullCompactionResponse>( [this]( ::grpc::CallbackServerContext* context, const ::backup::PullCompactionRequest* request) { return this->PullCompaction(context, request); })); } ~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 { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerWriteReactor< ::backup::PullCompactionResponse>* PullCompaction( ::grpc::CallbackServerContext* /*context*/, const ::backup::PullCompactionRequest* /*request*/) { return nullptr; } }; typedef WithCallbackMethod_ResetKey > > > CallbackService; typedef CallbackService ExperimentalCallbackService; template class WithGenericMethod_ResetKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_ResetKey() { ::grpc::Service::MarkMethodGeneric(0); } ~WithGenericMethod_ResetKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::backup::ResetKeyResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithGenericMethod_SendLog : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_SendLog() { ::grpc::Service::MarkMethodGeneric(1); } ~WithGenericMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithGenericMethod_PullBackupKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_PullBackupKey() { ::grpc::Service::MarkMethodGeneric(2); } ~WithGenericMethod_PullBackupKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous 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, ""); } }; template class WithGenericMethod_PullCompaction : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_PullCompaction() { ::grpc::Service::MarkMethodGeneric(3); } ~WithGenericMethod_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, ""); } }; template class WithRawMethod_ResetKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_ResetKey() { ::grpc::Service::MarkMethodRaw(0); } ~WithRawMethod_ResetKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::backup::ResetKeyResponse* /*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) { ::grpc::Service::RequestAsyncClientStreaming(0, context, reader, new_call_cq, notification_cq, tag); } }; template class WithRawMethod_SendLog : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_SendLog() { ::grpc::Service::MarkMethodRaw(1); } ~WithRawMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*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); } }; template class WithRawMethod_PullBackupKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_PullBackupKey() { ::grpc::Service::MarkMethodRaw(2); } ~WithRawMethod_PullBackupKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous 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, ""); } 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); } }; template class WithRawMethod_PullCompaction : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_PullCompaction() { ::grpc::Service::MarkMethodRaw(3); } ~WithRawMethod_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, ""); } 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); } }; template class WithRawCallbackMethod_ResetKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_ResetKey() { ::grpc::Service::MarkMethodRawCallback(0, new ::grpc::internal::CallbackClientStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->ResetKey(context, response); })); } ~WithRawCallbackMethod_ResetKey() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status ResetKey(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::backup::ResetKeyRequest>* /*reader*/, ::backup::ResetKeyResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* ResetKey( ::grpc::CallbackServerContext* /*context*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithRawCallbackMethod_SendLog : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_SendLog() { ::grpc::Service::MarkMethodRawCallback(1, new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->SendLog(context, request, response); })); } ~WithRawCallbackMethod_SendLog() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendLog(::grpc::ServerContext* /*context*/, const ::backup::SendLogRequest* /*request*/, ::backup::SendLogResponse* /*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; } }; template class WithRawCallbackMethod_PullBackupKey : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_PullBackupKey() { ::grpc::Service::MarkMethodRawCallback(2, new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->PullBackupKey(context, request, response); })); } ~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 { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* PullBackupKey( ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithRawCallbackMethod_PullCompaction : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_PullCompaction() { ::grpc::Service::MarkMethodRawCallback(3, new ::grpc::internal::CallbackServerStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const::grpc::ByteBuffer* request) { return this->PullCompaction(context, request); })); } ~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, ::backup::SendLogResponse>( [this](::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::backup::SendLogRequest, ::backup::SendLogResponse>* 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*/, ::backup::SendLogResponse* /*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,::backup::SendLogResponse>* 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 { 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; }; typedef WithSplitStreamingMethod_PullCompaction SplitStreamedService; typedef WithStreamedUnaryMethod_SendLog > > StreamedService; }; } // namespace backup #endif // GRPC_backup_2eproto__INCLUDED diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc index 280249b79..cf4ab8fe7 100644 --- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc +++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc @@ -1,2098 +1,2132 @@ // @generated by the protocol buffer compiler. DO NOT EDIT! // source: backup.proto #include "backup.pb.h" #include #include #include #include #include #include #include #include // @@protoc_insertion_point(includes) #include PROTOBUF_PRAGMA_INIT_SEG namespace backup { constexpr ResetKeyRequest::ResetKeyRequest( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) : userid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) , _oneof_case_{}{} struct ResetKeyRequestDefaultTypeInternal { constexpr ResetKeyRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~ResetKeyRequestDefaultTypeInternal() {} union { ResetKeyRequest _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT ResetKeyRequestDefaultTypeInternal _ResetKeyRequest_default_instance_; constexpr ResetKeyResponse::ResetKeyResponse( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) : success_(false){} struct ResetKeyResponseDefaultTypeInternal { constexpr ResetKeyResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~ResetKeyResponseDefaultTypeInternal() {} union { ResetKeyResponse _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT ResetKeyResponseDefaultTypeInternal _ResetKeyResponse_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){} struct SendLogRequestDefaultTypeInternal { constexpr SendLogRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~SendLogRequestDefaultTypeInternal() {} union { SendLogRequest _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT SendLogRequestDefaultTypeInternal _SendLogRequest_default_instance_; constexpr SendLogResponse::SendLogResponse( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) : success_(false){} struct SendLogResponseDefaultTypeInternal { constexpr SendLogResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~SendLogResponseDefaultTypeInternal() {} union { SendLogResponse _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT SendLogResponseDefaultTypeInternal _SendLogResponse_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){} struct PullBackupKeyRequestDefaultTypeInternal { constexpr PullBackupKeyRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~PullBackupKeyRequestDefaultTypeInternal() {} union { PullBackupKeyRequest _instance; }; }; 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) , success_(false){} struct PullBackupKeyResponseDefaultTypeInternal { constexpr PullBackupKeyResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~PullBackupKeyResponseDefaultTypeInternal() {} union { PullBackupKeyResponse _instance; }; }; 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){} struct PullCompactionRequestDefaultTypeInternal { constexpr PullCompactionRequestDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~PullCompactionRequestDefaultTypeInternal() {} union { PullCompactionRequest _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PullCompactionRequestDefaultTypeInternal _PullCompactionRequest_default_instance_; constexpr PullCompactionResponse::PullCompactionResponse( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) - : compactionchunk_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) - , logchunk_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} + : _oneof_case_{}{} struct PullCompactionResponseDefaultTypeInternal { constexpr PullCompactionResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} ~PullCompactionResponseDefaultTypeInternal() {} union { PullCompactionResponse _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PullCompactionResponseDefaultTypeInternal _PullCompactionResponse_default_instance_; } // namespace backup static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_backup_2eproto[8]; static constexpr ::PROTOBUF_NAMESPACE_ID::EnumDescriptor const** file_level_enum_descriptors_backup_2eproto = nullptr; static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_backup_2eproto = nullptr; 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_), ~0u, // no _extensions_ PROTOBUF_FIELD_OFFSET(::backup::ResetKeyRequest, _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_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::ResetKeyResponse, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::ResetKeyResponse, success_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, userid_), PROTOBUF_FIELD_OFFSET(::backup::SendLogRequest, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::SendLogResponse, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::SendLogResponse, success_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, userid_), PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyRequest, pakekey_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, success_), PROTOBUF_FIELD_OFFSET(::backup::PullBackupKeyResponse, encryptedbackupkey_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, userid_), PROTOBUF_FIELD_OFFSET(::backup::PullCompactionRequest, message_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, _internal_metadata_), ~0u, // no _extensions_ - ~0u, // no _oneof_case_ + PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, _oneof_case_[0]), ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, compactionchunk_), - PROTOBUF_FIELD_OFFSET(::backup::PullCompactionResponse, logchunk_), + ::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)}, { 9, -1, sizeof(::backup::ResetKeyResponse)}, { 15, -1, sizeof(::backup::SendLogRequest)}, { 22, -1, sizeof(::backup::SendLogResponse)}, { 28, -1, sizeof(::backup::PullBackupKeyRequest)}, { 35, -1, sizeof(::backup::PullBackupKeyResponse)}, { 42, -1, sizeof(::backup::PullCompactionRequest)}, { 49, -1, sizeof(::backup::PullCompactionResponse)}, }; static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = { reinterpret_cast(&::backup::_ResetKeyRequest_default_instance_), reinterpret_cast(&::backup::_ResetKeyResponse_default_instance_), reinterpret_cast(&::backup::_SendLogRequest_default_instance_), reinterpret_cast(&::backup::_SendLogResponse_default_instance_), reinterpret_cast(&::backup::_PullBackupKeyRequest_default_instance_), reinterpret_cast(&::backup::_PullBackupKeyResponse_default_instance_), reinterpret_cast(&::backup::_PullCompactionRequest_default_instance_), reinterpret_cast(&::backup::_PullCompactionResponse_default_instance_), }; const char descriptor_table_protodef_backup_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = "\n\014backup.proto\022\006backup\"V\n\017ResetKeyReques" "t\022\016\n\006userId\030\001 \001(\t\022\020\n\006newKey\030\002 \001(\014H\000\022\031\n\017c" "ompactionChunk\030\003 \001(\014H\000B\006\n\004data\"#\n\020ResetK" "eyResponse\022\017\n\007success\030\001 \001(\010\".\n\016SendLogRe" "quest\022\016\n\006userId\030\001 \001(\t\022\014\n\004data\030\002 \001(\014\"\"\n\017S" "endLogResponse\022\017\n\007success\030\001 \001(\010\"7\n\024PullB" "ackupKeyRequest\022\016\n\006userId\030\001 \001(\t\022\017\n\007pakeK" "ey\030\002 \001(\014\"D\n\025PullBackupKeyResponse\022\017\n\007suc" "cess\030\001 \001(\010\022\032\n\022encryptedBackupKey\030\002 \001(\014\"8" "\n\025PullCompactionRequest\022\016\n\006userId\030\001 \001(\t\022" - "\017\n\007message\030\002 \001(\014\"C\n\026PullCompactionRespon" - "se\022\027\n\017compactionChunk\030\001 \001(\014\022\020\n\010logChunk\030" - "\002 \001(\0142\265\002\n\rBackupService\022A\n\010ResetKey\022\027.ba" - "ckup.ResetKeyRequest\032\030.backup.ResetKeyRe" - "sponse\"\000(\001\022<\n\007SendLog\022\026.backup.SendLogRe" - "quest\032\027.backup.SendLogResponse\"\000\022N\n\rPull" - "BackupKey\022\034.backup.PullBackupKeyRequest\032" - "\035.backup.PullBackupKeyResponse\"\000\022S\n\016Pull" - "Compaction\022\035.backup.PullCompactionReques" - "t\032\036.backup.PullCompactionResponse\"\0000\001b\006p" - "roto3" + "\017\n\007message\030\002 \001(\014\"O\n\026PullCompactionRespon" + "se\022\031\n\017compactionChunk\030\001 \001(\014H\000\022\022\n\010logChun" + "k\030\002 \001(\014H\000B\006\n\004data2\265\002\n\rBackupService\022A\n\010R" + "esetKey\022\027.backup.ResetKeyRequest\032\030.backu" + "p.ResetKeyResponse\"\000(\001\022<\n\007SendLog\022\026.back" + "up.SendLogRequest\032\027.backup.SendLogRespon" + "se\"\000\022N\n\rPullBackupKey\022\034.backup.PullBacku" + "pKeyRequest\032\035.backup.PullBackupKeyRespon" + "se\"\000\022S\n\016PullCompaction\022\035.backup.PullComp" + "actionRequest\032\036.backup.PullCompactionRes" + "ponse\"\0000\001b\006proto3" ; static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_backup_2eproto_once; const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_backup_2eproto = { - false, false, 805, descriptor_table_protodef_backup_2eproto, "backup.proto", + false, false, 817, descriptor_table_protodef_backup_2eproto, "backup.proto", &descriptor_table_backup_2eproto_once, nullptr, 0, 8, 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, }; PROTOBUF_ATTRIBUTE_WEAK ::PROTOBUF_NAMESPACE_ID::Metadata descriptor_table_backup_2eproto_metadata_getter(int index) { ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&descriptor_table_backup_2eproto); return descriptor_table_backup_2eproto.file_level_metadata[index]; } // Force running AddDescriptors() at dynamic initialization time. PROTOBUF_ATTRIBUTE_INIT_PRIORITY static ::PROTOBUF_NAMESPACE_ID::internal::AddDescriptorsRunner dynamic_init_dummy_backup_2eproto(&descriptor_table_backup_2eproto); namespace backup { // =================================================================== class ResetKeyRequest::_Internal { public: }; ResetKeyRequest::ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.ResetKeyRequest) } ResetKeyRequest::ResetKeyRequest(const ResetKeyRequest& 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 kNewKey: { _internal_set_newkey(from._internal_newkey()); break; } case kCompactionChunk: { _internal_set_compactionchunk(from._internal_compactionchunk()); break; } case DATA_NOT_SET: { break; } } // @@protoc_insertion_point(copy_constructor:backup.ResetKeyRequest) } void ResetKeyRequest::SharedCtor() { userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); clear_has_data(); } ResetKeyRequest::~ResetKeyRequest() { // @@protoc_insertion_point(destructor:backup.ResetKeyRequest) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void ResetKeyRequest::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)_this; } void ResetKeyRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void ResetKeyRequest::SetCachedSize(int size) const { _cached_size_.Set(size); } void ResetKeyRequest::clear_data() { // @@protoc_insertion_point(one_of_clear_start:backup.ResetKeyRequest) switch (data_case()) { case kNewKey: { data_.newkey_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); break; } case kCompactionChunk: { data_.compactionchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); break; } case DATA_NOT_SET: { break; } } _oneof_case_[0] = DATA_NOT_SET; } void ResetKeyRequest::Clear() { // @@protoc_insertion_point(message_clear_start:backup.ResetKeyRequest) ::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) { #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; 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_(ptr); } else goto handle_unusual; continue; // bytes newKey = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_newkey(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; // bytes compactionChunk = 3; case 3: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) { auto str = _internal_mutable_compactionchunk(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* ResetKeyRequest::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.ResetKeyRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string userId = 1; if (this->userid().size() > 0) { ::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"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } // bytes newKey = 2; if (_internal_has_newkey()) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_newkey(), target); } // bytes compactionChunk = 3; if (_internal_has_compactionchunk()) { target = stream->WriteBytesMaybeAliased( 3, this->_internal_compactionchunk(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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) return target; } size_t ResetKeyRequest::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.ResetKeyRequest) 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()) { // bytes newKey = 2; case kNewKey: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_newkey()); break; } // bytes compactionChunk = 3; case kCompactionChunk: { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_compactionchunk()); 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_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void ResetKeyRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.ResetKeyRequest) GOOGLE_DCHECK_NE(&from, this); const ResetKeyRequest* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.ResetKeyRequest) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.ResetKeyRequest) MergeFrom(*source); } } void ResetKeyRequest::MergeFrom(const ResetKeyRequest& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.ResetKeyRequest) 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 kNewKey: { _internal_set_newkey(from._internal_newkey()); break; } case kCompactionChunk: { _internal_set_compactionchunk(from._internal_compactionchunk()); break; } case DATA_NOT_SET: { break; } } } void ResetKeyRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.ResetKeyRequest) if (&from == this) return; Clear(); MergeFrom(from); } void ResetKeyRequest::CopyFrom(const ResetKeyRequest& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.ResetKeyRequest) if (&from == this) return; Clear(); MergeFrom(from); } bool ResetKeyRequest::IsInitialized() const { return true; } void ResetKeyRequest::InternalSwap(ResetKeyRequest* 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 { return GetMetadataStatic(); } // =================================================================== class ResetKeyResponse::_Internal { public: }; ResetKeyResponse::ResetKeyResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.ResetKeyResponse) } ResetKeyResponse::ResetKeyResponse(const ResetKeyResponse& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); success_ = from.success_; // @@protoc_insertion_point(copy_constructor:backup.ResetKeyResponse) } void ResetKeyResponse::SharedCtor() { success_ = false; } ResetKeyResponse::~ResetKeyResponse() { // @@protoc_insertion_point(destructor:backup.ResetKeyResponse) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void ResetKeyResponse::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); } void ResetKeyResponse::ArenaDtor(void* object) { ResetKeyResponse* _this = reinterpret_cast< ResetKeyResponse* >(object); (void)_this; } void ResetKeyResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void ResetKeyResponse::SetCachedSize(int size) const { _cached_size_.Set(size); } void ResetKeyResponse::Clear() { // @@protoc_insertion_point(message_clear_start:backup.ResetKeyResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; success_ = false; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* ResetKeyResponse::_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) { // bool success = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) { success_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* ResetKeyResponse::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.ResetKeyResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bool success = 1; if (this->success() != 0) { target = stream->EnsureSpace(target); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(1, this->_internal_success(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.ResetKeyResponse) return target; } size_t ResetKeyResponse::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.ResetKeyResponse) 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; // bool success = 1; if (this->success() != 0) { total_size += 1 + 1; } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void ResetKeyResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.ResetKeyResponse) GOOGLE_DCHECK_NE(&from, this); const ResetKeyResponse* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.ResetKeyResponse) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.ResetKeyResponse) MergeFrom(*source); } } void ResetKeyResponse::MergeFrom(const ResetKeyResponse& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.ResetKeyResponse) 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.success() != 0) { _internal_set_success(from._internal_success()); } } void ResetKeyResponse::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.ResetKeyResponse) if (&from == this) return; Clear(); MergeFrom(from); } void ResetKeyResponse::CopyFrom(const ResetKeyResponse& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.ResetKeyResponse) if (&from == this) return; Clear(); MergeFrom(from); } bool ResetKeyResponse::IsInitialized() const { return true; } void ResetKeyResponse::InternalSwap(ResetKeyResponse* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); swap(success_, other->success_); } ::PROTOBUF_NAMESPACE_ID::Metadata ResetKeyResponse::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class SendLogRequest::_Internal { public: }; SendLogRequest::SendLogRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.SendLogRequest) } 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()); } // @@protoc_insertion_point(copy_constructor:backup.SendLogRequest) } void SendLogRequest::SharedCtor() { userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); data_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } SendLogRequest::~SendLogRequest() { // @@protoc_insertion_point(destructor:backup.SendLogRequest) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void SendLogRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); data_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void SendLogRequest::ArenaDtor(void* object) { SendLogRequest* _this = reinterpret_cast< SendLogRequest* >(object); (void)_this; } void SendLogRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void SendLogRequest::SetCachedSize(int size) const { _cached_size_.Set(size); } 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(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* SendLogRequest::_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; 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_(ptr); } else goto handle_unusual; continue; // bytes data = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_data(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* SendLogRequest::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.SendLogRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string userId = 1; if (this->userid().size() > 0) { ::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"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } // bytes data = 2; if (this->data().size() > 0) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_data(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.SendLogRequest) return target; } size_t SendLogRequest::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.SendLogRequest) 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()); } // bytes data = 2; if (this->data().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_data()); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void SendLogRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.SendLogRequest) GOOGLE_DCHECK_NE(&from, this); const SendLogRequest* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.SendLogRequest) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.SendLogRequest) MergeFrom(*source); } } void SendLogRequest::MergeFrom(const SendLogRequest& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.SendLogRequest) 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()); } if (from.data().size() > 0) { _internal_set_data(from._internal_data()); } } void SendLogRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.SendLogRequest) if (&from == this) return; Clear(); MergeFrom(from); } void SendLogRequest::CopyFrom(const SendLogRequest& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.SendLogRequest) if (&from == this) return; Clear(); MergeFrom(from); } bool SendLogRequest::IsInitialized() const { return true; } 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()); } ::PROTOBUF_NAMESPACE_ID::Metadata SendLogRequest::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class SendLogResponse::_Internal { public: }; SendLogResponse::SendLogResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.SendLogResponse) } SendLogResponse::SendLogResponse(const SendLogResponse& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); success_ = from.success_; // @@protoc_insertion_point(copy_constructor:backup.SendLogResponse) } void SendLogResponse::SharedCtor() { success_ = false; } SendLogResponse::~SendLogResponse() { // @@protoc_insertion_point(destructor:backup.SendLogResponse) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void SendLogResponse::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); } void SendLogResponse::ArenaDtor(void* object) { SendLogResponse* _this = reinterpret_cast< SendLogResponse* >(object); (void)_this; } void SendLogResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void SendLogResponse::SetCachedSize(int size) const { _cached_size_.Set(size); } void SendLogResponse::Clear() { // @@protoc_insertion_point(message_clear_start:backup.SendLogResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; success_ = false; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* SendLogResponse::_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) { // bool success = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) { success_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* SendLogResponse::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.SendLogResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bool success = 1; if (this->success() != 0) { target = stream->EnsureSpace(target); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(1, this->_internal_success(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.SendLogResponse) return target; } size_t SendLogResponse::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.SendLogResponse) 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; // bool success = 1; if (this->success() != 0) { total_size += 1 + 1; } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void SendLogResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.SendLogResponse) GOOGLE_DCHECK_NE(&from, this); const SendLogResponse* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.SendLogResponse) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.SendLogResponse) MergeFrom(*source); } } void SendLogResponse::MergeFrom(const SendLogResponse& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.SendLogResponse) 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.success() != 0) { _internal_set_success(from._internal_success()); } } void SendLogResponse::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.SendLogResponse) if (&from == this) return; Clear(); MergeFrom(from); } void SendLogResponse::CopyFrom(const SendLogResponse& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.SendLogResponse) if (&from == this) return; Clear(); MergeFrom(from); } bool SendLogResponse::IsInitialized() const { return true; } void SendLogResponse::InternalSwap(SendLogResponse* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); swap(success_, other->success_); } ::PROTOBUF_NAMESPACE_ID::Metadata SendLogResponse::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class PullBackupKeyRequest::_Internal { public: }; PullBackupKeyRequest::PullBackupKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.PullBackupKeyRequest) } 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()); } // @@protoc_insertion_point(copy_constructor:backup.PullBackupKeyRequest) } void PullBackupKeyRequest::SharedCtor() { userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); pakekey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } PullBackupKeyRequest::~PullBackupKeyRequest() { // @@protoc_insertion_point(destructor:backup.PullBackupKeyRequest) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void PullBackupKeyRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); pakekey_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void PullBackupKeyRequest::ArenaDtor(void* object) { PullBackupKeyRequest* _this = reinterpret_cast< PullBackupKeyRequest* >(object); (void)_this; } void PullBackupKeyRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void PullBackupKeyRequest::SetCachedSize(int size) const { _cached_size_.Set(size); } 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(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* PullBackupKeyRequest::_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; 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_(ptr); } else goto handle_unusual; continue; // bytes pakeKey = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_pakekey(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* PullBackupKeyRequest::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.PullBackupKeyRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string userId = 1; if (this->userid().size() > 0) { ::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"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } // bytes pakeKey = 2; if (this->pakekey().size() > 0) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_pakekey(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.PullBackupKeyRequest) return target; } size_t PullBackupKeyRequest::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.PullBackupKeyRequest) 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()); } // bytes pakeKey = 2; if (this->pakekey().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_pakekey()); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void PullBackupKeyRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.PullBackupKeyRequest) GOOGLE_DCHECK_NE(&from, this); const PullBackupKeyRequest* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.PullBackupKeyRequest) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.PullBackupKeyRequest) MergeFrom(*source); } } void PullBackupKeyRequest::MergeFrom(const PullBackupKeyRequest& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.PullBackupKeyRequest) 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()); } if (from.pakekey().size() > 0) { _internal_set_pakekey(from._internal_pakekey()); } } void PullBackupKeyRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.PullBackupKeyRequest) if (&from == this) return; Clear(); MergeFrom(from); } void PullBackupKeyRequest::CopyFrom(const PullBackupKeyRequest& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.PullBackupKeyRequest) if (&from == this) return; Clear(); MergeFrom(from); } bool PullBackupKeyRequest::IsInitialized() const { return true; } 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()); } ::PROTOBUF_NAMESPACE_ID::Metadata PullBackupKeyRequest::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class PullBackupKeyResponse::_Internal { public: }; PullBackupKeyResponse::PullBackupKeyResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.PullBackupKeyResponse) } 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()); } success_ = from.success_; // @@protoc_insertion_point(copy_constructor:backup.PullBackupKeyResponse) } void PullBackupKeyResponse::SharedCtor() { encryptedbackupkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); success_ = false; } PullBackupKeyResponse::~PullBackupKeyResponse() { // @@protoc_insertion_point(destructor:backup.PullBackupKeyResponse) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void PullBackupKeyResponse::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); encryptedbackupkey_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void PullBackupKeyResponse::ArenaDtor(void* object) { PullBackupKeyResponse* _this = reinterpret_cast< PullBackupKeyResponse* >(object); (void)_this; } void PullBackupKeyResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void PullBackupKeyResponse::SetCachedSize(int size) const { _cached_size_.Set(size); } 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(); success_ = false; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* PullBackupKeyResponse::_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) { // bool success = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) { success_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); 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); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* PullBackupKeyResponse::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.PullBackupKeyResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bool success = 1; if (this->success() != 0) { target = stream->EnsureSpace(target); target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(1, this->_internal_success(), target); } // bytes encryptedBackupKey = 2; if (this->encryptedbackupkey().size() > 0) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_encryptedbackupkey(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.PullBackupKeyResponse) return target; } size_t PullBackupKeyResponse::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.PullBackupKeyResponse) 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; // bytes encryptedBackupKey = 2; if (this->encryptedbackupkey().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_encryptedbackupkey()); } // bool success = 1; if (this->success() != 0) { total_size += 1 + 1; } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void PullBackupKeyResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.PullBackupKeyResponse) GOOGLE_DCHECK_NE(&from, this); const PullBackupKeyResponse* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.PullBackupKeyResponse) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.PullBackupKeyResponse) MergeFrom(*source); } } void PullBackupKeyResponse::MergeFrom(const PullBackupKeyResponse& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.PullBackupKeyResponse) 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.encryptedbackupkey().size() > 0) { _internal_set_encryptedbackupkey(from._internal_encryptedbackupkey()); } if (from.success() != 0) { _internal_set_success(from._internal_success()); } } void PullBackupKeyResponse::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.PullBackupKeyResponse) if (&from == this) return; Clear(); MergeFrom(from); } void PullBackupKeyResponse::CopyFrom(const PullBackupKeyResponse& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.PullBackupKeyResponse) if (&from == this) return; Clear(); MergeFrom(from); } bool PullBackupKeyResponse::IsInitialized() const { return true; } 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(success_, other->success_); } ::PROTOBUF_NAMESPACE_ID::Metadata PullBackupKeyResponse::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class PullCompactionRequest::_Internal { public: }; PullCompactionRequest::PullCompactionRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.PullCompactionRequest) } 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()); } // @@protoc_insertion_point(copy_constructor:backup.PullCompactionRequest) } void PullCompactionRequest::SharedCtor() { userid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); message_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } PullCompactionRequest::~PullCompactionRequest() { // @@protoc_insertion_point(destructor:backup.PullCompactionRequest) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void PullCompactionRequest::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); userid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); message_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } void PullCompactionRequest::ArenaDtor(void* object) { PullCompactionRequest* _this = reinterpret_cast< PullCompactionRequest* >(object); (void)_this; } void PullCompactionRequest::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void PullCompactionRequest::SetCachedSize(int size) const { _cached_size_.Set(size); } 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(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* PullCompactionRequest::_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; 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_(ptr); } else goto handle_unusual; continue; // bytes message = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_message(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* PullCompactionRequest::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.PullCompactionRequest) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // string userId = 1; if (this->userid().size() > 0) { ::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"); target = stream->WriteStringMaybeAliased( 1, this->_internal_userid(), target); } // bytes message = 2; if (this->message().size() > 0) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_message(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.PullCompactionRequest) return target; } size_t PullCompactionRequest::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.PullCompactionRequest) 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()); } // bytes message = 2; if (this->message().size() > 0) { total_size += 1 + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( this->_internal_message()); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( _internal_metadata_, total_size, &_cached_size_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void PullCompactionRequest::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.PullCompactionRequest) GOOGLE_DCHECK_NE(&from, this); const PullCompactionRequest* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.PullCompactionRequest) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.PullCompactionRequest) MergeFrom(*source); } } void PullCompactionRequest::MergeFrom(const PullCompactionRequest& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.PullCompactionRequest) 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()); } if (from.message().size() > 0) { _internal_set_message(from._internal_message()); } } void PullCompactionRequest::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.PullCompactionRequest) if (&from == this) return; Clear(); MergeFrom(from); } void PullCompactionRequest::CopyFrom(const PullCompactionRequest& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.PullCompactionRequest) if (&from == this) return; Clear(); MergeFrom(from); } bool PullCompactionRequest::IsInitialized() const { return true; } 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()); } ::PROTOBUF_NAMESPACE_ID::Metadata PullCompactionRequest::GetMetadata() const { return GetMetadataStatic(); } // =================================================================== class PullCompactionResponse::_Internal { public: }; PullCompactionResponse::PullCompactionResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena) { SharedCtor(); RegisterArenaDtor(arena); // @@protoc_insertion_point(arena_constructor:backup.PullCompactionResponse) } PullCompactionResponse::PullCompactionResponse(const PullCompactionResponse& from) : ::PROTOBUF_NAMESPACE_ID::Message() { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); - compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_compactionchunk().empty()) { - compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_compactionchunk(), - GetArena()); - } - logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - if (!from._internal_logchunk().empty()) { - logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_logchunk(), - GetArena()); + clear_has_data(); + switch (from.data_case()) { + case kCompactionChunk: { + _internal_set_compactionchunk(from._internal_compactionchunk()); + break; + } + case kLogChunk: { + _internal_set_logchunk(from._internal_logchunk()); + break; + } + case DATA_NOT_SET: { + break; + } } // @@protoc_insertion_point(copy_constructor:backup.PullCompactionResponse) } void PullCompactionResponse::SharedCtor() { -compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); -logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); +clear_has_data(); } PullCompactionResponse::~PullCompactionResponse() { // @@protoc_insertion_point(destructor:backup.PullCompactionResponse) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } void PullCompactionResponse::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); - compactionchunk_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); - logchunk_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + if (has_data()) { + clear_data(); + } } void PullCompactionResponse::ArenaDtor(void* object) { PullCompactionResponse* _this = reinterpret_cast< PullCompactionResponse* >(object); (void)_this; } void PullCompactionResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } void PullCompactionResponse::SetCachedSize(int size) const { _cached_size_.Set(size); } +void PullCompactionResponse::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:backup.PullCompactionResponse) + switch (data_case()) { + case kCompactionChunk: { + data_.compactionchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case kLogChunk: { + data_.logchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + void PullCompactionResponse::Clear() { // @@protoc_insertion_point(message_clear_start:backup.PullCompactionResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; - compactionchunk_.ClearToEmpty(); - logchunk_.ClearToEmpty(); + clear_data(); _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } const char* PullCompactionResponse::_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) { // bytes compactionChunk = 1; case 1: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_compactionchunk(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; // bytes logChunk = 2; case 2: if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { auto str = _internal_mutable_logchunk(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); CHK_(ptr); } else goto handle_unusual; continue; default: { handle_unusual: if ((tag & 7) == 4 || tag == 0) { ctx->SetLastTag(tag); goto success; } ptr = UnknownFieldParse(tag, _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), ptr, ctx); CHK_(ptr != nullptr); continue; } } // switch } // while success: return ptr; failure: ptr = nullptr; goto success; #undef CHK_ } ::PROTOBUF_NAMESPACE_ID::uint8* PullCompactionResponse::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:backup.PullCompactionResponse) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; // bytes compactionChunk = 1; - if (this->compactionchunk().size() > 0) { + if (_internal_has_compactionchunk()) { target = stream->WriteBytesMaybeAliased( 1, this->_internal_compactionchunk(), target); } // bytes logChunk = 2; - if (this->logchunk().size() > 0) { + if (_internal_has_logchunk()) { target = stream->WriteBytesMaybeAliased( 2, this->_internal_logchunk(), target); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { 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.PullCompactionResponse) return target; } size_t PullCompactionResponse::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:backup.PullCompactionResponse) 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; - // bytes compactionChunk = 1; - if (this->compactionchunk().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_compactionchunk()); - } - - // bytes logChunk = 2; - if (this->logchunk().size() > 0) { - total_size += 1 + - ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( - this->_internal_logchunk()); + switch (data_case()) { + // bytes compactionChunk = 1; + case kCompactionChunk: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_compactionchunk()); + break; + } + // bytes logChunk = 2; + case kLogChunk: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_logchunk()); + 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_); } int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); SetCachedSize(cached_size); return total_size; } void PullCompactionResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:backup.PullCompactionResponse) GOOGLE_DCHECK_NE(&from, this); const PullCompactionResponse* source = ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( &from); if (source == nullptr) { // @@protoc_insertion_point(generalized_merge_from_cast_fail:backup.PullCompactionResponse) ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); } else { // @@protoc_insertion_point(generalized_merge_from_cast_success:backup.PullCompactionResponse) MergeFrom(*source); } } void PullCompactionResponse::MergeFrom(const PullCompactionResponse& from) { // @@protoc_insertion_point(class_specific_merge_from_start:backup.PullCompactionResponse) 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.compactionchunk().size() > 0) { - _internal_set_compactionchunk(from._internal_compactionchunk()); - } - if (from.logchunk().size() > 0) { - _internal_set_logchunk(from._internal_logchunk()); + switch (from.data_case()) { + case kCompactionChunk: { + _internal_set_compactionchunk(from._internal_compactionchunk()); + break; + } + case kLogChunk: { + _internal_set_logchunk(from._internal_logchunk()); + break; + } + case DATA_NOT_SET: { + break; + } } } void PullCompactionResponse::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_copy_from_start:backup.PullCompactionResponse) if (&from == this) return; Clear(); MergeFrom(from); } void PullCompactionResponse::CopyFrom(const PullCompactionResponse& from) { // @@protoc_insertion_point(class_specific_copy_from_start:backup.PullCompactionResponse) if (&from == this) return; Clear(); MergeFrom(from); } bool PullCompactionResponse::IsInitialized() const { return true; } void PullCompactionResponse::InternalSwap(PullCompactionResponse* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - compactionchunk_.Swap(&other->compactionchunk_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); - logchunk_.Swap(&other->logchunk_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata PullCompactionResponse::GetMetadata() const { return GetMetadataStatic(); } // @@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::ResetKeyResponse* Arena::CreateMaybeMessage< ::backup::ResetKeyResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::ResetKeyResponse >(arena); } template<> PROTOBUF_NOINLINE ::backup::SendLogRequest* Arena::CreateMaybeMessage< ::backup::SendLogRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::SendLogRequest >(arena); } template<> PROTOBUF_NOINLINE ::backup::SendLogResponse* Arena::CreateMaybeMessage< ::backup::SendLogResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::SendLogResponse >(arena); } template<> PROTOBUF_NOINLINE ::backup::PullBackupKeyRequest* Arena::CreateMaybeMessage< ::backup::PullBackupKeyRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::PullBackupKeyRequest >(arena); } template<> PROTOBUF_NOINLINE ::backup::PullBackupKeyResponse* Arena::CreateMaybeMessage< ::backup::PullBackupKeyResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::PullBackupKeyResponse >(arena); } template<> PROTOBUF_NOINLINE ::backup::PullCompactionRequest* Arena::CreateMaybeMessage< ::backup::PullCompactionRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::PullCompactionRequest >(arena); } template<> PROTOBUF_NOINLINE ::backup::PullCompactionResponse* Arena::CreateMaybeMessage< ::backup::PullCompactionResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::backup::PullCompactionResponse >(arena); } PROTOBUF_NAMESPACE_CLOSE // @@protoc_insertion_point(global_scope) #include diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h index df03c9e66..38e0bb278 100644 --- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h +++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h @@ -1,2342 +1,2476 @@ // @generated by the protocol buffer compiler. DO NOT EDIT! // source: backup.proto #ifndef GOOGLE_PROTOBUF_INCLUDED_backup_2eproto #define GOOGLE_PROTOBUF_INCLUDED_backup_2eproto #include #include #include #if PROTOBUF_VERSION < 3015000 #error This file was generated by a newer version of protoc which is #error incompatible with your Protocol Buffer headers. Please update #error your headers. #endif #if 3015008 < PROTOBUF_MIN_PROTOC_VERSION #error This file was generated by an older version of protoc which is #error incompatible with your Protocol Buffer headers. Please #error regenerate this file with a newer version of protoc. #endif #include #include #include #include #include #include #include #include #include #include // IWYU pragma: export #include // IWYU pragma: export #include // @@protoc_insertion_point(includes) #include #define PROTOBUF_INTERNAL_EXPORT_backup_2eproto PROTOBUF_NAMESPACE_OPEN namespace internal { class AnyMetadata; } // namespace internal PROTOBUF_NAMESPACE_CLOSE // Internal implementation detail -- do not use these members. struct TableStruct_backup_2eproto { static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[] PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::PROTOBUF_NAMESPACE_ID::internal::AuxiliaryParseTableField aux[] PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[8] PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[]; static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[]; static const ::PROTOBUF_NAMESPACE_ID::uint32 offsets[]; }; 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 PullBackupKeyRequest; struct PullBackupKeyRequestDefaultTypeInternal; extern PullBackupKeyRequestDefaultTypeInternal _PullBackupKeyRequest_default_instance_; class PullBackupKeyResponse; struct PullBackupKeyResponseDefaultTypeInternal; extern PullBackupKeyResponseDefaultTypeInternal _PullBackupKeyResponse_default_instance_; class PullCompactionRequest; struct PullCompactionRequestDefaultTypeInternal; extern PullCompactionRequestDefaultTypeInternal _PullCompactionRequest_default_instance_; class PullCompactionResponse; struct PullCompactionResponseDefaultTypeInternal; extern PullCompactionResponseDefaultTypeInternal _PullCompactionResponse_default_instance_; class ResetKeyRequest; struct ResetKeyRequestDefaultTypeInternal; extern ResetKeyRequestDefaultTypeInternal _ResetKeyRequest_default_instance_; class ResetKeyResponse; struct ResetKeyResponseDefaultTypeInternal; extern ResetKeyResponseDefaultTypeInternal _ResetKeyResponse_default_instance_; class SendLogRequest; struct SendLogRequestDefaultTypeInternal; extern SendLogRequestDefaultTypeInternal _SendLogRequest_default_instance_; class SendLogResponse; struct SendLogResponseDefaultTypeInternal; extern SendLogResponseDefaultTypeInternal _SendLogResponse_default_instance_; } // namespace backup PROTOBUF_NAMESPACE_OPEN 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::ResetKeyResponse* Arena::CreateMaybeMessage<::backup::ResetKeyResponse>(Arena*); template<> ::backup::SendLogRequest* Arena::CreateMaybeMessage<::backup::SendLogRequest>(Arena*); template<> ::backup::SendLogResponse* Arena::CreateMaybeMessage<::backup::SendLogResponse>(Arena*); PROTOBUF_NAMESPACE_CLOSE namespace backup { // =================================================================== class ResetKeyRequest PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.ResetKeyRequest) */ { public: inline ResetKeyRequest() : ResetKeyRequest(nullptr) {} virtual ~ResetKeyRequest(); explicit constexpr ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); ResetKeyRequest(const ResetKeyRequest& from); ResetKeyRequest(ResetKeyRequest&& from) noexcept : ResetKeyRequest() { *this = ::std::move(from); } inline ResetKeyRequest& operator=(const ResetKeyRequest& from) { CopyFrom(from); return *this; } inline ResetKeyRequest& operator=(ResetKeyRequest&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const ResetKeyRequest& default_instance() { return *internal_default_instance(); } enum DataCase { kNewKey = 2, kCompactionChunk = 3, DATA_NOT_SET = 0, }; static inline const ResetKeyRequest* internal_default_instance() { return reinterpret_cast( &_ResetKeyRequest_default_instance_); } static constexpr int kIndexInFileMessages = 0; friend void swap(ResetKeyRequest& a, ResetKeyRequest& b) { a.Swap(&b); } inline void Swap(ResetKeyRequest* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(ResetKeyRequest* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline ResetKeyRequest* New() const final { return CreateMaybeMessage(nullptr); } ResetKeyRequest* 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); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(ResetKeyRequest* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.ResetKeyRequest"; } protected: explicit ResetKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kUserIdFieldNumber = 1, kNewKeyFieldNumber = 2, kCompactionChunkFieldNumber = 3, }; // string userId = 1; void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); void set_userid(std::string&& value); void set_userid(const char* value); void set_userid(const char* value, size_t size); std::string* mutable_userid(); std::string* release_userid(); void set_allocated_userid(std::string* userid); private: const std::string& _internal_userid() const; void _internal_set_userid(const std::string& value); std::string* _internal_mutable_userid(); public: // bytes newKey = 2; bool has_newkey() const; private: bool _internal_has_newkey() const; public: void clear_newkey(); const std::string& newkey() const; void set_newkey(const std::string& value); void set_newkey(std::string&& value); void set_newkey(const char* value); void set_newkey(const void* value, size_t size); std::string* mutable_newkey(); std::string* release_newkey(); void set_allocated_newkey(std::string* newkey); private: const std::string& _internal_newkey() const; void _internal_set_newkey(const std::string& value); std::string* _internal_mutable_newkey(); public: // bytes compactionChunk = 3; bool has_compactionchunk() const; private: bool _internal_has_compactionchunk() const; public: void clear_compactionchunk(); const std::string& compactionchunk() const; void set_compactionchunk(const std::string& value); void set_compactionchunk(std::string&& value); void set_compactionchunk(const char* value); void set_compactionchunk(const void* value, size_t size); std::string* mutable_compactionchunk(); std::string* release_compactionchunk(); void set_allocated_compactionchunk(std::string* compactionchunk); private: const std::string& _internal_compactionchunk() const; void _internal_set_compactionchunk(const std::string& value); std::string* _internal_mutable_compactionchunk(); public: void clear_data(); DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.ResetKeyRequest) private: class _Internal; void set_has_newkey(); void set_has_compactionchunk(); 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_; union DataUnion { constexpr DataUnion() : _constinit_{} {} ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr newkey_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr compactionchunk_; } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class ResetKeyResponse PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.ResetKeyResponse) */ { public: inline ResetKeyResponse() : ResetKeyResponse(nullptr) {} virtual ~ResetKeyResponse(); explicit constexpr ResetKeyResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); ResetKeyResponse(const ResetKeyResponse& from); ResetKeyResponse(ResetKeyResponse&& from) noexcept : ResetKeyResponse() { *this = ::std::move(from); } inline ResetKeyResponse& operator=(const ResetKeyResponse& from) { CopyFrom(from); return *this; } inline ResetKeyResponse& operator=(ResetKeyResponse&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const ResetKeyResponse& default_instance() { return *internal_default_instance(); } static inline const ResetKeyResponse* internal_default_instance() { return reinterpret_cast( &_ResetKeyResponse_default_instance_); } static constexpr int kIndexInFileMessages = 1; friend void swap(ResetKeyResponse& a, ResetKeyResponse& b) { a.Swap(&b); } inline void Swap(ResetKeyResponse* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(ResetKeyResponse* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline ResetKeyResponse* New() const final { return CreateMaybeMessage(nullptr); } ResetKeyResponse* 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 ResetKeyResponse& from); void MergeFrom(const ResetKeyResponse& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(ResetKeyResponse* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.ResetKeyResponse"; } protected: explicit ResetKeyResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kSuccessFieldNumber = 1, }; // bool success = 1; void clear_success(); bool success() const; void set_success(bool value); private: bool _internal_success() const; void _internal_set_success(bool value); public: // @@protoc_insertion_point(class_scope:backup.ResetKeyResponse) private: class _Internal; template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; bool success_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class SendLogRequest PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.SendLogRequest) */ { public: inline SendLogRequest() : SendLogRequest(nullptr) {} virtual ~SendLogRequest(); explicit constexpr SendLogRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); SendLogRequest(const SendLogRequest& from); SendLogRequest(SendLogRequest&& from) noexcept : SendLogRequest() { *this = ::std::move(from); } inline SendLogRequest& operator=(const SendLogRequest& from) { CopyFrom(from); return *this; } inline SendLogRequest& operator=(SendLogRequest&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const SendLogRequest& default_instance() { return *internal_default_instance(); } static inline const SendLogRequest* internal_default_instance() { return reinterpret_cast( &_SendLogRequest_default_instance_); } static constexpr int kIndexInFileMessages = 2; friend void swap(SendLogRequest& a, SendLogRequest& b) { a.Swap(&b); } inline void Swap(SendLogRequest* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(SendLogRequest* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline SendLogRequest* New() const final { return CreateMaybeMessage(nullptr); } SendLogRequest* 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 SendLogRequest& from); void MergeFrom(const SendLogRequest& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(SendLogRequest* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.SendLogRequest"; } protected: explicit SendLogRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kUserIdFieldNumber = 1, kDataFieldNumber = 2, }; // string userId = 1; void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); void set_userid(std::string&& value); void set_userid(const char* value); void set_userid(const char* value, size_t size); std::string* mutable_userid(); std::string* release_userid(); void set_allocated_userid(std::string* userid); private: const std::string& _internal_userid() const; void _internal_set_userid(const std::string& value); 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); private: const std::string& _internal_data() const; void _internal_set_data(const std::string& value); std::string* _internal_mutable_data(); public: // @@protoc_insertion_point(class_scope:backup.SendLogRequest) private: class _Internal; 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_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class SendLogResponse PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.SendLogResponse) */ { public: inline SendLogResponse() : SendLogResponse(nullptr) {} virtual ~SendLogResponse(); explicit constexpr SendLogResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); SendLogResponse(const SendLogResponse& from); SendLogResponse(SendLogResponse&& from) noexcept : SendLogResponse() { *this = ::std::move(from); } inline SendLogResponse& operator=(const SendLogResponse& from) { CopyFrom(from); return *this; } inline SendLogResponse& operator=(SendLogResponse&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const SendLogResponse& default_instance() { return *internal_default_instance(); } static inline const SendLogResponse* internal_default_instance() { return reinterpret_cast( &_SendLogResponse_default_instance_); } static constexpr int kIndexInFileMessages = 3; friend void swap(SendLogResponse& a, SendLogResponse& b) { a.Swap(&b); } inline void Swap(SendLogResponse* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(SendLogResponse* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline SendLogResponse* New() const final { return CreateMaybeMessage(nullptr); } SendLogResponse* 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 SendLogResponse& from); void MergeFrom(const SendLogResponse& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(SendLogResponse* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.SendLogResponse"; } protected: explicit SendLogResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kSuccessFieldNumber = 1, }; // bool success = 1; void clear_success(); bool success() const; void set_success(bool value); private: bool _internal_success() const; void _internal_set_success(bool value); public: // @@protoc_insertion_point(class_scope:backup.SendLogResponse) private: class _Internal; template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; bool success_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class PullBackupKeyRequest PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.PullBackupKeyRequest) */ { public: inline PullBackupKeyRequest() : PullBackupKeyRequest(nullptr) {} virtual ~PullBackupKeyRequest(); explicit constexpr PullBackupKeyRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); PullBackupKeyRequest(const PullBackupKeyRequest& from); PullBackupKeyRequest(PullBackupKeyRequest&& from) noexcept : PullBackupKeyRequest() { *this = ::std::move(from); } inline PullBackupKeyRequest& operator=(const PullBackupKeyRequest& from) { CopyFrom(from); return *this; } inline PullBackupKeyRequest& operator=(PullBackupKeyRequest&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const PullBackupKeyRequest& default_instance() { return *internal_default_instance(); } static inline const PullBackupKeyRequest* internal_default_instance() { return reinterpret_cast( &_PullBackupKeyRequest_default_instance_); } static constexpr int kIndexInFileMessages = 4; friend void swap(PullBackupKeyRequest& a, PullBackupKeyRequest& b) { a.Swap(&b); } inline void Swap(PullBackupKeyRequest* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(PullBackupKeyRequest* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline PullBackupKeyRequest* New() const final { return CreateMaybeMessage(nullptr); } PullBackupKeyRequest* 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 PullBackupKeyRequest& from); void MergeFrom(const PullBackupKeyRequest& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(PullBackupKeyRequest* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.PullBackupKeyRequest"; } protected: explicit PullBackupKeyRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kUserIdFieldNumber = 1, kPakeKeyFieldNumber = 2, }; // string userId = 1; void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); void set_userid(std::string&& value); void set_userid(const char* value); void set_userid(const char* value, size_t size); std::string* mutable_userid(); std::string* release_userid(); void set_allocated_userid(std::string* userid); private: const std::string& _internal_userid() const; void _internal_set_userid(const std::string& value); 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); private: const std::string& _internal_pakekey() const; void _internal_set_pakekey(const std::string& value); std::string* _internal_mutable_pakekey(); public: // @@protoc_insertion_point(class_scope:backup.PullBackupKeyRequest) private: class _Internal; 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_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class PullBackupKeyResponse PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.PullBackupKeyResponse) */ { public: inline PullBackupKeyResponse() : PullBackupKeyResponse(nullptr) {} virtual ~PullBackupKeyResponse(); explicit constexpr PullBackupKeyResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); PullBackupKeyResponse(const PullBackupKeyResponse& from); PullBackupKeyResponse(PullBackupKeyResponse&& from) noexcept : PullBackupKeyResponse() { *this = ::std::move(from); } inline PullBackupKeyResponse& operator=(const PullBackupKeyResponse& from) { CopyFrom(from); return *this; } inline PullBackupKeyResponse& operator=(PullBackupKeyResponse&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const PullBackupKeyResponse& default_instance() { return *internal_default_instance(); } static inline const PullBackupKeyResponse* internal_default_instance() { return reinterpret_cast( &_PullBackupKeyResponse_default_instance_); } static constexpr int kIndexInFileMessages = 5; friend void swap(PullBackupKeyResponse& a, PullBackupKeyResponse& b) { a.Swap(&b); } inline void Swap(PullBackupKeyResponse* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(PullBackupKeyResponse* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline PullBackupKeyResponse* New() const final { return CreateMaybeMessage(nullptr); } PullBackupKeyResponse* 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 PullBackupKeyResponse& from); void MergeFrom(const PullBackupKeyResponse& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(PullBackupKeyResponse* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.PullBackupKeyResponse"; } protected: explicit PullBackupKeyResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kEncryptedBackupKeyFieldNumber = 2, kSuccessFieldNumber = 1, }; // bytes encryptedBackupKey = 2; void clear_encryptedbackupkey(); const std::string& encryptedbackupkey() const; void set_encryptedbackupkey(const std::string& value); void set_encryptedbackupkey(std::string&& value); void set_encryptedbackupkey(const char* value); void set_encryptedbackupkey(const void* value, size_t size); std::string* mutable_encryptedbackupkey(); std::string* release_encryptedbackupkey(); void set_allocated_encryptedbackupkey(std::string* encryptedbackupkey); private: const std::string& _internal_encryptedbackupkey() const; void _internal_set_encryptedbackupkey(const std::string& value); std::string* _internal_mutable_encryptedbackupkey(); public: // bool success = 1; void clear_success(); bool success() const; void set_success(bool value); private: bool _internal_success() const; void _internal_set_success(bool value); public: // @@protoc_insertion_point(class_scope:backup.PullBackupKeyResponse) private: class _Internal; template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr encryptedbackupkey_; bool success_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class PullCompactionRequest PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.PullCompactionRequest) */ { public: inline PullCompactionRequest() : PullCompactionRequest(nullptr) {} virtual ~PullCompactionRequest(); explicit constexpr PullCompactionRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); PullCompactionRequest(const PullCompactionRequest& from); PullCompactionRequest(PullCompactionRequest&& from) noexcept : PullCompactionRequest() { *this = ::std::move(from); } inline PullCompactionRequest& operator=(const PullCompactionRequest& from) { CopyFrom(from); return *this; } inline PullCompactionRequest& operator=(PullCompactionRequest&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const PullCompactionRequest& default_instance() { return *internal_default_instance(); } static inline const PullCompactionRequest* internal_default_instance() { return reinterpret_cast( &_PullCompactionRequest_default_instance_); } static constexpr int kIndexInFileMessages = 6; friend void swap(PullCompactionRequest& a, PullCompactionRequest& b) { a.Swap(&b); } inline void Swap(PullCompactionRequest* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(PullCompactionRequest* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline PullCompactionRequest* New() const final { return CreateMaybeMessage(nullptr); } PullCompactionRequest* 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 PullCompactionRequest& from); void MergeFrom(const PullCompactionRequest& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(PullCompactionRequest* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.PullCompactionRequest"; } protected: explicit PullCompactionRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kUserIdFieldNumber = 1, kMessageFieldNumber = 2, }; // string userId = 1; void clear_userid(); const std::string& userid() const; void set_userid(const std::string& value); void set_userid(std::string&& value); void set_userid(const char* value); void set_userid(const char* value, size_t size); std::string* mutable_userid(); std::string* release_userid(); void set_allocated_userid(std::string* userid); private: const std::string& _internal_userid() const; void _internal_set_userid(const std::string& value); 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); private: const std::string& _internal_message() const; void _internal_set_message(const std::string& value); std::string* _internal_mutable_message(); public: // @@protoc_insertion_point(class_scope:backup.PullCompactionRequest) private: class _Internal; 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_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; friend struct ::TableStruct_backup_2eproto; }; // ------------------------------------------------------------------- class PullCompactionResponse PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:backup.PullCompactionResponse) */ { public: inline PullCompactionResponse() : PullCompactionResponse(nullptr) {} virtual ~PullCompactionResponse(); explicit constexpr PullCompactionResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); PullCompactionResponse(const PullCompactionResponse& from); PullCompactionResponse(PullCompactionResponse&& from) noexcept : PullCompactionResponse() { *this = ::std::move(from); } inline PullCompactionResponse& operator=(const PullCompactionResponse& from) { CopyFrom(from); return *this; } inline PullCompactionResponse& operator=(PullCompactionResponse&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { CopyFrom(from); } return *this; } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { return GetDescriptor(); } static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { return GetMetadataStatic().descriptor; } static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } static const PullCompactionResponse& default_instance() { return *internal_default_instance(); } + enum DataCase { + kCompactionChunk = 1, + kLogChunk = 2, + DATA_NOT_SET = 0, + }; + static inline const PullCompactionResponse* internal_default_instance() { return reinterpret_cast( &_PullCompactionResponse_default_instance_); } static constexpr int kIndexInFileMessages = 7; friend void swap(PullCompactionResponse& a, PullCompactionResponse& b) { a.Swap(&b); } inline void Swap(PullCompactionResponse* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); } else { ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } void UnsafeArenaSwap(PullCompactionResponse* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); } // implements Message ---------------------------------------------- inline PullCompactionResponse* New() const final { return CreateMaybeMessage(nullptr); } PullCompactionResponse* 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 PullCompactionResponse& from); void MergeFrom(const PullCompactionResponse& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; size_t ByteSizeLong() const final; const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; int GetCachedSize() const final { return _cached_size_.Get(); } private: inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; void InternalSwap(PullCompactionResponse* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { return "backup.PullCompactionResponse"; } protected: explicit PullCompactionResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); public: ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; private: static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { return ::descriptor_table_backup_2eproto_metadata_getter(kIndexInFileMessages); } public: // nested types ---------------------------------------------------- // accessors ------------------------------------------------------- enum : int { kCompactionChunkFieldNumber = 1, kLogChunkFieldNumber = 2, }; // bytes compactionChunk = 1; + bool has_compactionchunk() const; + private: + bool _internal_has_compactionchunk() const; + public: void clear_compactionchunk(); const std::string& compactionchunk() const; void set_compactionchunk(const std::string& value); void set_compactionchunk(std::string&& value); void set_compactionchunk(const char* value); void set_compactionchunk(const void* value, size_t size); std::string* mutable_compactionchunk(); std::string* release_compactionchunk(); void set_allocated_compactionchunk(std::string* compactionchunk); private: const std::string& _internal_compactionchunk() const; void _internal_set_compactionchunk(const std::string& value); std::string* _internal_mutable_compactionchunk(); public: // bytes logChunk = 2; + bool has_logchunk() const; + private: + bool _internal_has_logchunk() const; + public: void clear_logchunk(); const std::string& logchunk() const; void set_logchunk(const std::string& value); void set_logchunk(std::string&& value); void set_logchunk(const char* value); void set_logchunk(const void* value, size_t size); std::string* mutable_logchunk(); std::string* release_logchunk(); void set_allocated_logchunk(std::string* logchunk); private: const std::string& _internal_logchunk() const; void _internal_set_logchunk(const std::string& value); std::string* _internal_mutable_logchunk(); public: + void clear_data(); + DataCase data_case() const; // @@protoc_insertion_point(class_scope:backup.PullCompactionResponse) private: class _Internal; + void set_has_compactionchunk(); + void set_has_logchunk(); + + 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 compactionchunk_; - ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr logchunk_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr compactionchunk_; + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr logchunk_; + } data_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + friend struct ::TableStruct_backup_2eproto; }; // =================================================================== // =================================================================== #ifdef __GNUC__ #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wstrict-aliasing" #endif // __GNUC__ // ResetKeyRequest // string userId = 1; inline void ResetKeyRequest::clear_userid() { userid_.ClearToEmpty(); } inline const std::string& ResetKeyRequest::userid() const { // @@protoc_insertion_point(field_get:backup.ResetKeyRequest.userId) return _internal_userid(); } inline void ResetKeyRequest::set_userid(const std::string& value) { _internal_set_userid(value); // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.userId) } inline std::string* ResetKeyRequest::mutable_userid() { // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.userId) return _internal_mutable_userid(); } inline const std::string& ResetKeyRequest::_internal_userid() const { return userid_.Get(); } inline void ResetKeyRequest::_internal_set_userid(const std::string& value) { userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void ResetKeyRequest::set_userid(std::string&& value) { userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.userId) } inline void ResetKeyRequest::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 { } userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.userId) } // bytes newKey = 2; inline bool ResetKeyRequest::_internal_has_newkey() const { return data_case() == kNewKey; } inline bool ResetKeyRequest::has_newkey() const { return _internal_has_newkey(); } inline void ResetKeyRequest::set_has_newkey() { _oneof_case_[0] = kNewKey; } inline void ResetKeyRequest::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) return _internal_newkey(); } inline void ResetKeyRequest::set_newkey(const std::string& value) { _internal_set_newkey(value); // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.newKey) } inline std::string* ResetKeyRequest::mutable_newkey() { // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.newKey) return _internal_mutable_newkey(); } inline const std::string& ResetKeyRequest::_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) { if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); data_.newkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } 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) if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); data_.newkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.newkey_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.newKey) } inline void ResetKeyRequest::set_newkey(const char* value) { GOOGLE_DCHECK(value != nullptr); if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); data_.newkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.newkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); // @@protoc_insertion_point(field_set_char:backup.ResetKeyRequest.newKey) } inline void ResetKeyRequest::set_newkey(const void* value, size_t size) { if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); data_.newkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.newkey_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); // @@protoc_insertion_point(field_set_pointer:backup.ResetKeyRequest.newKey) } inline std::string* ResetKeyRequest::_internal_mutable_newkey() { if (!_internal_has_newkey()) { clear_data(); set_has_newkey(); data_.newkey_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } 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) if (_internal_has_newkey()) { clear_has_data(); return data_.newkey_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } else { return nullptr; } } inline void ResetKeyRequest::set_allocated_newkey(std::string* newkey) { if (has_data()) { clear_data(); } if (newkey != nullptr) { set_has_newkey(); data_.newkey_.UnsafeSetDefault(newkey); ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); if (arena != nullptr) { arena->Own(newkey); } } // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.newKey) } // bytes compactionChunk = 3; inline bool ResetKeyRequest::_internal_has_compactionchunk() const { return data_case() == kCompactionChunk; } inline bool ResetKeyRequest::has_compactionchunk() const { return _internal_has_compactionchunk(); } inline void ResetKeyRequest::set_has_compactionchunk() { _oneof_case_[0] = kCompactionChunk; } inline void ResetKeyRequest::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) return _internal_compactionchunk(); } inline void ResetKeyRequest::set_compactionchunk(const std::string& value) { _internal_set_compactionchunk(value); // @@protoc_insertion_point(field_set:backup.ResetKeyRequest.compactionChunk) } inline std::string* ResetKeyRequest::mutable_compactionchunk() { // @@protoc_insertion_point(field_mutable:backup.ResetKeyRequest.compactionChunk) return _internal_mutable_compactionchunk(); } inline const std::string& ResetKeyRequest::_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) { if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } 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) if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.compactionchunk_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.ResetKeyRequest.compactionChunk) } inline void ResetKeyRequest::set_compactionchunk(const char* value) { GOOGLE_DCHECK(value != nullptr); if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); // @@protoc_insertion_point(field_set_char:backup.ResetKeyRequest.compactionChunk) } inline void ResetKeyRequest::set_compactionchunk(const void* value, size_t size) { if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } data_.compactionchunk_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); // @@protoc_insertion_point(field_set_pointer:backup.ResetKeyRequest.compactionChunk) } inline std::string* ResetKeyRequest::_internal_mutable_compactionchunk() { if (!_internal_has_compactionchunk()) { clear_data(); set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } 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) if (_internal_has_compactionchunk()) { clear_has_data(); return data_.compactionchunk_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } else { return nullptr; } } inline void ResetKeyRequest::set_allocated_compactionchunk(std::string* compactionchunk) { if (has_data()) { clear_data(); } if (compactionchunk != nullptr) { set_has_compactionchunk(); data_.compactionchunk_.UnsafeSetDefault(compactionchunk); ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); if (arena != nullptr) { arena->Own(compactionchunk); } } // @@protoc_insertion_point(field_set_allocated:backup.ResetKeyRequest.compactionChunk) } inline bool ResetKeyRequest::has_data() const { return data_case() != DATA_NOT_SET; } inline void ResetKeyRequest::clear_has_data() { _oneof_case_[0] = DATA_NOT_SET; } inline ResetKeyRequest::DataCase ResetKeyRequest::data_case() const { return ResetKeyRequest::DataCase(_oneof_case_[0]); } // ------------------------------------------------------------------- // ResetKeyResponse // bool success = 1; inline void ResetKeyResponse::clear_success() { success_ = false; } inline bool ResetKeyResponse::_internal_success() const { return success_; } inline bool ResetKeyResponse::success() const { // @@protoc_insertion_point(field_get:backup.ResetKeyResponse.success) return _internal_success(); } inline void ResetKeyResponse::_internal_set_success(bool value) { success_ = value; } inline void ResetKeyResponse::set_success(bool value) { _internal_set_success(value); // @@protoc_insertion_point(field_set:backup.ResetKeyResponse.success) } // ------------------------------------------------------------------- // SendLogRequest // string userId = 1; inline void SendLogRequest::clear_userid() { userid_.ClearToEmpty(); } inline const std::string& SendLogRequest::userid() const { // @@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) } inline std::string* SendLogRequest::mutable_userid() { // @@protoc_insertion_point(field_mutable:backup.SendLogRequest.userId) return _internal_mutable_userid(); } inline const std::string& SendLogRequest::_internal_userid() const { return userid_.Get(); } inline void SendLogRequest::_internal_set_userid(const std::string& value) { userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void SendLogRequest::set_userid(std::string&& value) { userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@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) } 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) } inline std::string* SendLogRequest::_internal_mutable_userid() { return 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()); } inline void SendLogRequest::set_allocated_userid(std::string* userid) { if (userid != nullptr) { } else { } userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.userId) } // bytes data = 2; inline void SendLogRequest::clear_data() { data_.ClearToEmpty(); } inline const std::string& SendLogRequest::data() const { // @@protoc_insertion_point(field_get:backup.SendLogRequest.data) return _internal_data(); } inline void SendLogRequest::set_data(const std::string& value) { _internal_set_data(value); // @@protoc_insertion_point(field_set:backup.SendLogRequest.data) } 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 { } data_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), data, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.SendLogRequest.data) } // ------------------------------------------------------------------- // SendLogResponse // bool success = 1; inline void SendLogResponse::clear_success() { success_ = false; } inline bool SendLogResponse::_internal_success() const { return success_; } inline bool SendLogResponse::success() const { // @@protoc_insertion_point(field_get:backup.SendLogResponse.success) return _internal_success(); } inline void SendLogResponse::_internal_set_success(bool value) { success_ = value; } inline void SendLogResponse::set_success(bool value) { _internal_set_success(value); // @@protoc_insertion_point(field_set:backup.SendLogResponse.success) } // ------------------------------------------------------------------- // 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 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 { return userid_.Get(); } inline void PullBackupKeyRequest::_internal_set_userid(const std::string& value) { userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullBackupKeyRequest::set_userid(std::string&& value) { 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); 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) } inline std::string* PullBackupKeyRequest::_internal_mutable_userid() { return userid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* PullBackupKeyRequest::release_userid() { // @@protoc_insertion_point(field_release:backup.PullBackupKeyRequest.userId) return userid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } inline void PullBackupKeyRequest::set_allocated_userid(std::string* userid) { if (userid != nullptr) { } else { } userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.userId) } // bytes pakeKey = 2; inline void PullBackupKeyRequest::clear_pakekey() { pakekey_.ClearToEmpty(); } inline const std::string& PullBackupKeyRequest::pakekey() const { // @@protoc_insertion_point(field_get:backup.PullBackupKeyRequest.pakeKey) return _internal_pakekey(); } inline void PullBackupKeyRequest::set_pakekey(const std::string& value) { _internal_set_pakekey(value); // @@protoc_insertion_point(field_set:backup.PullBackupKeyRequest.pakeKey) } inline std::string* PullBackupKeyRequest::mutable_pakekey() { // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyRequest.pakeKey) return _internal_mutable_pakekey(); } inline const std::string& PullBackupKeyRequest::_internal_pakekey() const { return pakekey_.Get(); } inline void PullBackupKeyRequest::_internal_set_pakekey(const std::string& value) { pakekey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullBackupKeyRequest::set_pakekey(std::string&& value) { pakekey_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.PullBackupKeyRequest.pakeKey) } inline void PullBackupKeyRequest::set_pakekey(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 { } pakekey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), pakekey, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyRequest.pakeKey) } // ------------------------------------------------------------------- // PullBackupKeyResponse // bool success = 1; inline void PullBackupKeyResponse::clear_success() { success_ = false; } inline bool PullBackupKeyResponse::_internal_success() const { return success_; } inline bool PullBackupKeyResponse::success() const { // @@protoc_insertion_point(field_get:backup.PullBackupKeyResponse.success) return _internal_success(); } inline void PullBackupKeyResponse::_internal_set_success(bool value) { success_ = value; } inline void PullBackupKeyResponse::set_success(bool value) { _internal_set_success(value); // @@protoc_insertion_point(field_set:backup.PullBackupKeyResponse.success) } // bytes encryptedBackupKey = 2; inline void PullBackupKeyResponse::clear_encryptedbackupkey() { encryptedbackupkey_.ClearToEmpty(); } inline const std::string& PullBackupKeyResponse::encryptedbackupkey() const { // @@protoc_insertion_point(field_get:backup.PullBackupKeyResponse.encryptedBackupKey) return _internal_encryptedbackupkey(); } inline void PullBackupKeyResponse::set_encryptedbackupkey(const std::string& value) { _internal_set_encryptedbackupkey(value); // @@protoc_insertion_point(field_set:backup.PullBackupKeyResponse.encryptedBackupKey) } inline std::string* PullBackupKeyResponse::mutable_encryptedbackupkey() { // @@protoc_insertion_point(field_mutable:backup.PullBackupKeyResponse.encryptedBackupKey) return _internal_mutable_encryptedbackupkey(); } inline const std::string& PullBackupKeyResponse::_internal_encryptedbackupkey() const { return encryptedbackupkey_.Get(); } inline void PullBackupKeyResponse::_internal_set_encryptedbackupkey(const std::string& value) { encryptedbackupkey_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullBackupKeyResponse::set_encryptedbackupkey(std::string&& value) { 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()); // @@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()); // @@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()); } inline std::string* PullBackupKeyResponse::release_encryptedbackupkey() { // @@protoc_insertion_point(field_release:backup.PullBackupKeyResponse.encryptedBackupKey) return encryptedbackupkey_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } inline void PullBackupKeyResponse::set_allocated_encryptedbackupkey(std::string* encryptedbackupkey) { if (encryptedbackupkey != nullptr) { } else { } encryptedbackupkey_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), encryptedbackupkey, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullBackupKeyResponse.encryptedBackupKey) } // ------------------------------------------------------------------- // PullCompactionRequest // string userId = 1; inline void PullCompactionRequest::clear_userid() { userid_.ClearToEmpty(); } inline const std::string& PullCompactionRequest::userid() const { // @@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) } inline std::string* PullCompactionRequest::mutable_userid() { // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.userId) return _internal_mutable_userid(); } inline const std::string& PullCompactionRequest::_internal_userid() const { return userid_.Get(); } inline void PullCompactionRequest::_internal_set_userid(const std::string& value) { userid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullCompactionRequest::set_userid(std::string&& value) { userid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@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) } 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) } inline std::string* PullCompactionRequest::_internal_mutable_userid() { return 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()); } inline void PullCompactionRequest::set_allocated_userid(std::string* userid) { if (userid != nullptr) { } else { } userid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), userid, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.userId) } // bytes message = 2; inline void PullCompactionRequest::clear_message() { message_.ClearToEmpty(); } inline const std::string& PullCompactionRequest::message() const { // @@protoc_insertion_point(field_get:backup.PullCompactionRequest.message) return _internal_message(); } inline void PullCompactionRequest::set_message(const std::string& value) { _internal_set_message(value); // @@protoc_insertion_point(field_set:backup.PullCompactionRequest.message) } inline std::string* PullCompactionRequest::mutable_message() { // @@protoc_insertion_point(field_mutable:backup.PullCompactionRequest.message) return _internal_mutable_message(); } inline const std::string& PullCompactionRequest::_internal_message() const { return message_.Get(); } inline void PullCompactionRequest::_internal_set_message(const std::string& value) { message_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullCompactionRequest::set_message(std::string&& value) { message_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionRequest.message) } inline void PullCompactionRequest::set_message(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) { } else { } message_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), message, GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionRequest.message) } // ------------------------------------------------------------------- // PullCompactionResponse // bytes compactionChunk = 1; +inline bool PullCompactionResponse::_internal_has_compactionchunk() const { + return data_case() == kCompactionChunk; +} +inline bool PullCompactionResponse::has_compactionchunk() const { + return _internal_has_compactionchunk(); +} +inline void PullCompactionResponse::set_has_compactionchunk() { + _oneof_case_[0] = kCompactionChunk; +} inline void PullCompactionResponse::clear_compactionchunk() { - compactionchunk_.ClearToEmpty(); + if (_internal_has_compactionchunk()) { + data_.compactionchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } inline const std::string& PullCompactionResponse::compactionchunk() const { // @@protoc_insertion_point(field_get:backup.PullCompactionResponse.compactionChunk) return _internal_compactionchunk(); } inline void PullCompactionResponse::set_compactionchunk(const std::string& value) { _internal_set_compactionchunk(value); // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.compactionChunk) } inline std::string* PullCompactionResponse::mutable_compactionchunk() { // @@protoc_insertion_point(field_mutable:backup.PullCompactionResponse.compactionChunk) return _internal_mutable_compactionchunk(); } inline const std::string& PullCompactionResponse::_internal_compactionchunk() const { - return compactionchunk_.Get(); + if (_internal_has_compactionchunk()) { + return data_.compactionchunk_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } inline void PullCompactionResponse::_internal_set_compactionchunk(const std::string& value) { - - compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); + if (!_internal_has_compactionchunk()) { + clear_data(); + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullCompactionResponse::set_compactionchunk(std::string&& value) { - - compactionchunk_.Set( + // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.compactionChunk) + if (!_internal_has_compactionchunk()) { + clear_data(); + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.compactionchunk_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionResponse.compactionChunk) } inline void PullCompactionResponse::set_compactionchunk(const char* value) { GOOGLE_DCHECK(value != nullptr); - - compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); + if (!_internal_has_compactionchunk()) { + clear_data(); + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); // @@protoc_insertion_point(field_set_char:backup.PullCompactionResponse.compactionChunk) } inline void PullCompactionResponse::set_compactionchunk(const void* value, - size_t size) { - - compactionchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); + size_t size) { + if (!_internal_has_compactionchunk()) { + clear_data(); + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.compactionchunk_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionResponse.compactionChunk) } inline std::string* PullCompactionResponse::_internal_mutable_compactionchunk() { - - return compactionchunk_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + if (!_internal_has_compactionchunk()) { + clear_data(); + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.compactionchunk_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* PullCompactionResponse::release_compactionchunk() { // @@protoc_insertion_point(field_release:backup.PullCompactionResponse.compactionChunk) - return compactionchunk_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + if (_internal_has_compactionchunk()) { + clear_has_data(); + return data_.compactionchunk_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } } inline void PullCompactionResponse::set_allocated_compactionchunk(std::string* compactionchunk) { + if (has_data()) { + clear_data(); + } if (compactionchunk != nullptr) { - - } else { - + set_has_compactionchunk(); + data_.compactionchunk_.UnsafeSetDefault(compactionchunk); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(compactionchunk); + } } - compactionchunk_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), compactionchunk, - GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionResponse.compactionChunk) } // bytes logChunk = 2; +inline bool PullCompactionResponse::_internal_has_logchunk() const { + return data_case() == kLogChunk; +} +inline bool PullCompactionResponse::has_logchunk() const { + return _internal_has_logchunk(); +} +inline void PullCompactionResponse::set_has_logchunk() { + _oneof_case_[0] = kLogChunk; +} inline void PullCompactionResponse::clear_logchunk() { - logchunk_.ClearToEmpty(); + if (_internal_has_logchunk()) { + data_.logchunk_.Destroy(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + clear_has_data(); + } } inline const std::string& PullCompactionResponse::logchunk() const { // @@protoc_insertion_point(field_get:backup.PullCompactionResponse.logChunk) return _internal_logchunk(); } inline void PullCompactionResponse::set_logchunk(const std::string& value) { _internal_set_logchunk(value); // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.logChunk) } inline std::string* PullCompactionResponse::mutable_logchunk() { // @@protoc_insertion_point(field_mutable:backup.PullCompactionResponse.logChunk) return _internal_mutable_logchunk(); } inline const std::string& PullCompactionResponse::_internal_logchunk() const { - return logchunk_.Get(); + if (_internal_has_logchunk()) { + return data_.logchunk_.Get(); + } + return ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(); } inline void PullCompactionResponse::_internal_set_logchunk(const std::string& value) { - - logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); + if (!_internal_has_logchunk()) { + clear_data(); + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } inline void PullCompactionResponse::set_logchunk(std::string&& value) { - - logchunk_.Set( + // @@protoc_insertion_point(field_set:backup.PullCompactionResponse.logChunk) + if (!_internal_has_logchunk()) { + clear_data(); + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logchunk_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); // @@protoc_insertion_point(field_set_rvalue:backup.PullCompactionResponse.logChunk) } inline void PullCompactionResponse::set_logchunk(const char* value) { GOOGLE_DCHECK(value != nullptr); - - logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); + if (!_internal_has_logchunk()) { + clear_data(); + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, + ::std::string(value), GetArena()); // @@protoc_insertion_point(field_set_char:backup.PullCompactionResponse.logChunk) } inline void PullCompactionResponse::set_logchunk(const void* value, - size_t size) { - - logchunk_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( - reinterpret_cast(value), size), GetArena()); + size_t size) { + if (!_internal_has_logchunk()) { + clear_data(); + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + data_.logchunk_.Set( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( + reinterpret_cast(value), size), + GetArena()); // @@protoc_insertion_point(field_set_pointer:backup.PullCompactionResponse.logChunk) } inline std::string* PullCompactionResponse::_internal_mutable_logchunk() { - - return logchunk_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); + if (!_internal_has_logchunk()) { + clear_data(); + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); + } + return data_.logchunk_.Mutable( + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } inline std::string* PullCompactionResponse::release_logchunk() { // @@protoc_insertion_point(field_release:backup.PullCompactionResponse.logChunk) - return logchunk_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + if (_internal_has_logchunk()) { + clear_has_data(); + return data_.logchunk_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + } else { + return nullptr; + } } inline void PullCompactionResponse::set_allocated_logchunk(std::string* logchunk) { + if (has_data()) { + clear_data(); + } if (logchunk != nullptr) { - - } else { - + set_has_logchunk(); + data_.logchunk_.UnsafeSetDefault(logchunk); + ::PROTOBUF_NAMESPACE_ID::Arena* arena = GetArena(); + if (arena != nullptr) { + arena->Own(logchunk); + } } - logchunk_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), logchunk, - GetArena()); // @@protoc_insertion_point(field_set_allocated:backup.PullCompactionResponse.logChunk) } +inline bool PullCompactionResponse::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void PullCompactionResponse::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline PullCompactionResponse::DataCase PullCompactionResponse::data_case() const { + return PullCompactionResponse::DataCase(_oneof_case_[0]); +} #ifdef __GNUC__ #pragma GCC diagnostic pop #endif // __GNUC__ // ------------------------------------------------------------------- // ------------------------------------------------------------------- // ------------------------------------------------------------------- // ------------------------------------------------------------------- // ------------------------------------------------------------------- // ------------------------------------------------------------------- // ------------------------------------------------------------------- // @@protoc_insertion_point(namespace_scope) } // namespace backup // @@protoc_insertion_point(global_scope) #include #endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_backup_2eproto diff --git a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h index 5977d4be6..e8b7e926c 100644 --- a/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h +++ b/native/cpp/CommonCpp/grpc/_generated/tunnelbroker.grpc.pb.h @@ -1,554 +1,554 @@ // @generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: tunnelbroker.proto #ifndef GRPC_tunnelbroker_2eproto__INCLUDED #define GRPC_tunnelbroker_2eproto__INCLUDED #include "tunnelbroker.pb.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace tunnelbroker { class TunnelBrokerService final { public: static constexpr char const* service_full_name() { return "tunnelbroker.TunnelBrokerService"; } class StubInterface { public: virtual ~StubInterface() {} virtual ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::tunnelbroker::CheckResponse* response) = 0; std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>> AsyncCheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>>(AsyncCheckIfPrimaryDeviceOnlineRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>> PrepareAsyncCheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>>(PrepareAsyncCheckIfPrimaryDeviceOnlineRaw(context, request, cq)); } virtual ::grpc::Status BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::tunnelbroker::NewPrimaryResponse* response) = 0; std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>> AsyncBecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>>(AsyncBecomeNewPrimaryDeviceRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>> PrepareAsyncBecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>>(PrepareAsyncBecomeNewPrimaryDeviceRaw(context, request, cq)); } virtual ::grpc::Status SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::tunnelbroker::PongResponse* response) = 0; std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>> AsyncSendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>>(AsyncSendPongRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>> PrepareAsyncSendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>>(PrepareAsyncSendPongRaw(context, request, cq)); } class async_interface { public: virtual ~async_interface() {} virtual void CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response, std::function) = 0; virtual void CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0; virtual void BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response, std::function) = 0; virtual void BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0; virtual void SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response, std::function) = 0; virtual void SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0; }; typedef class async_interface experimental_async_interface; virtual class async_interface* async() { return nullptr; } class async_interface* experimental_async() { return async(); } - private: + private: virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>* AsyncCheckIfPrimaryDeviceOnlineRaw(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::CheckResponse>* PrepareAsyncCheckIfPrimaryDeviceOnlineRaw(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>* AsyncBecomeNewPrimaryDeviceRaw(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::NewPrimaryResponse>* PrepareAsyncBecomeNewPrimaryDeviceRaw(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>* AsyncSendPongRaw(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) = 0; virtual ::grpc::ClientAsyncResponseReaderInterface< ::tunnelbroker::PongResponse>* PrepareAsyncSendPongRaw(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) = 0; }; class Stub final : public StubInterface { public: Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::tunnelbroker::CheckResponse* response) override; std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>> AsyncCheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>>(AsyncCheckIfPrimaryDeviceOnlineRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>> PrepareAsyncCheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>>(PrepareAsyncCheckIfPrimaryDeviceOnlineRaw(context, request, cq)); } ::grpc::Status BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::tunnelbroker::NewPrimaryResponse* response) override; std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>> AsyncBecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>>(AsyncBecomeNewPrimaryDeviceRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>> PrepareAsyncBecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>>(PrepareAsyncBecomeNewPrimaryDeviceRaw(context, request, cq)); } ::grpc::Status SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::tunnelbroker::PongResponse* response) override; std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>> AsyncSendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>>(AsyncSendPongRaw(context, request, cq)); } std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>> PrepareAsyncSendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>>(PrepareAsyncSendPongRaw(context, request, cq)); } class async final : public StubInterface::async_interface { public: void CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response, std::function) override; void CheckIfPrimaryDeviceOnline(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response, ::grpc::ClientUnaryReactor* reactor) override; void BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response, std::function) override; void BecomeNewPrimaryDevice(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response, ::grpc::ClientUnaryReactor* reactor) override; void SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response, std::function) override; void SendPong(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response, ::grpc::ClientUnaryReactor* reactor) override; private: friend class Stub; explicit async(Stub* stub): stub_(stub) { } Stub* stub() { return stub_; } Stub* stub_; }; class async* async() override { return &async_stub_; } private: std::shared_ptr< ::grpc::ChannelInterface> channel_; class async async_stub_{this}; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>* AsyncCheckIfPrimaryDeviceOnlineRaw(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::CheckResponse>* PrepareAsyncCheckIfPrimaryDeviceOnlineRaw(::grpc::ClientContext* context, const ::tunnelbroker::CheckRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>* AsyncBecomeNewPrimaryDeviceRaw(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::NewPrimaryResponse>* PrepareAsyncBecomeNewPrimaryDeviceRaw(::grpc::ClientContext* context, const ::tunnelbroker::NewPrimaryRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>* AsyncSendPongRaw(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) override; ::grpc::ClientAsyncResponseReader< ::tunnelbroker::PongResponse>* PrepareAsyncSendPongRaw(::grpc::ClientContext* context, const ::tunnelbroker::PongRequest& request, ::grpc::CompletionQueue* cq) override; const ::grpc::internal::RpcMethod rpcmethod_CheckIfPrimaryDeviceOnline_; const ::grpc::internal::RpcMethod rpcmethod_BecomeNewPrimaryDevice_; const ::grpc::internal::RpcMethod rpcmethod_SendPong_; }; static std::unique_ptr NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); class Service : public ::grpc::Service { public: Service(); virtual ~Service(); virtual ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response); virtual ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response); virtual ::grpc::Status SendPong(::grpc::ServerContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response); }; template class WithAsyncMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodAsync(0); } ~WithAsyncMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestCheckIfPrimaryDeviceOnline(::grpc::ServerContext* context, ::tunnelbroker::CheckRequest* request, ::grpc::ServerAsyncResponseWriter< ::tunnelbroker::CheckResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag); } }; template class WithAsyncMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodAsync(1); } ~WithAsyncMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestBecomeNewPrimaryDevice(::grpc::ServerContext* context, ::tunnelbroker::NewPrimaryRequest* request, ::grpc::ServerAsyncResponseWriter< ::tunnelbroker::NewPrimaryResponse>* 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); } }; template class WithAsyncMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_SendPong() { ::grpc::Service::MarkMethodAsync(2); } ~WithAsyncMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestSendPong(::grpc::ServerContext* context, ::tunnelbroker::PongRequest* request, ::grpc::ServerAsyncResponseWriter< ::tunnelbroker::PongResponse>* 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); } }; typedef WithAsyncMethod_CheckIfPrimaryDeviceOnline > > AsyncService; template class WithCallbackMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodCallback(0, new ::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::CheckRequest, ::tunnelbroker::CheckResponse>( [this]( ::grpc::CallbackServerContext* context, const ::tunnelbroker::CheckRequest* request, ::tunnelbroker::CheckResponse* response) { return this->CheckIfPrimaryDeviceOnline(context, request, response); }));} void SetMessageAllocatorFor_CheckIfPrimaryDeviceOnline( ::grpc::MessageAllocator< ::tunnelbroker::CheckRequest, ::tunnelbroker::CheckResponse>* allocator) { ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(0); static_cast<::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::CheckRequest, ::tunnelbroker::CheckResponse>*>(handler) ->SetMessageAllocator(allocator); } ~WithCallbackMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* CheckIfPrimaryDeviceOnline( ::grpc::CallbackServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) { return nullptr; } }; template class WithCallbackMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodCallback(1, new ::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::NewPrimaryRequest, ::tunnelbroker::NewPrimaryResponse>( [this]( ::grpc::CallbackServerContext* context, const ::tunnelbroker::NewPrimaryRequest* request, ::tunnelbroker::NewPrimaryResponse* response) { return this->BecomeNewPrimaryDevice(context, request, response); }));} void SetMessageAllocatorFor_BecomeNewPrimaryDevice( ::grpc::MessageAllocator< ::tunnelbroker::NewPrimaryRequest, ::tunnelbroker::NewPrimaryResponse>* allocator) { ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(1); static_cast<::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::NewPrimaryRequest, ::tunnelbroker::NewPrimaryResponse>*>(handler) ->SetMessageAllocator(allocator); } ~WithCallbackMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* BecomeNewPrimaryDevice( ::grpc::CallbackServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) { return nullptr; } }; template class WithCallbackMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithCallbackMethod_SendPong() { ::grpc::Service::MarkMethodCallback(2, new ::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::PongRequest, ::tunnelbroker::PongResponse>( [this]( ::grpc::CallbackServerContext* context, const ::tunnelbroker::PongRequest* request, ::tunnelbroker::PongResponse* response) { return this->SendPong(context, request, response); }));} void SetMessageAllocatorFor_SendPong( ::grpc::MessageAllocator< ::tunnelbroker::PongRequest, ::tunnelbroker::PongResponse>* allocator) { ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(2); static_cast<::grpc::internal::CallbackUnaryHandler< ::tunnelbroker::PongRequest, ::tunnelbroker::PongResponse>*>(handler) ->SetMessageAllocator(allocator); } ~WithCallbackMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* SendPong( ::grpc::CallbackServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) { return nullptr; } }; typedef WithCallbackMethod_CheckIfPrimaryDeviceOnline > > CallbackService; typedef CallbackService ExperimentalCallbackService; template class WithGenericMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodGeneric(0); } ~WithGenericMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithGenericMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodGeneric(1); } ~WithGenericMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithGenericMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_SendPong() { ::grpc::Service::MarkMethodGeneric(2); } ~WithGenericMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithRawMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodRaw(0); } ~WithRawMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestCheckIfPrimaryDeviceOnline(::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(0, context, request, response, new_call_cq, notification_cq, tag); } }; template class WithRawMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodRaw(1); } ~WithRawMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestBecomeNewPrimaryDevice(::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); } }; template class WithRawMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_SendPong() { ::grpc::Service::MarkMethodRaw(2); } ~WithRawMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestSendPong(::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); } }; template class WithRawCallbackMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodRawCallback(0, new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->CheckIfPrimaryDeviceOnline(context, request, response); })); } ~WithRawCallbackMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* CheckIfPrimaryDeviceOnline( ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithRawCallbackMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodRawCallback(1, new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->BecomeNewPrimaryDevice(context, request, response); })); } ~WithRawCallbackMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* BecomeNewPrimaryDevice( ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithRawCallbackMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawCallbackMethod_SendPong() { ::grpc::Service::MarkMethodRawCallback(2, new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( ::grpc::CallbackServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->SendPong(context, request, response); })); } ~WithRawCallbackMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } virtual ::grpc::ServerUnaryReactor* SendPong( ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/) { return nullptr; } }; template class WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline() { ::grpc::Service::MarkMethodStreamed(0, new ::grpc::internal::StreamedUnaryHandler< ::tunnelbroker::CheckRequest, ::tunnelbroker::CheckResponse>( [this](::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::CheckRequest, ::tunnelbroker::CheckResponse>* streamer) { return this->StreamedCheckIfPrimaryDeviceOnline(context, streamer); })); } ~WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline() override { BaseClassMustBeDerivedFromService(this); } // disable regular version of this method ::grpc::Status CheckIfPrimaryDeviceOnline(::grpc::ServerContext* /*context*/, const ::tunnelbroker::CheckRequest* /*request*/, ::tunnelbroker::CheckResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } // replace default version of method with streamed unary virtual ::grpc::Status StreamedCheckIfPrimaryDeviceOnline(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::CheckRequest,::tunnelbroker::CheckResponse>* server_unary_streamer) = 0; }; template class WithStreamedUnaryMethod_BecomeNewPrimaryDevice : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithStreamedUnaryMethod_BecomeNewPrimaryDevice() { ::grpc::Service::MarkMethodStreamed(1, new ::grpc::internal::StreamedUnaryHandler< ::tunnelbroker::NewPrimaryRequest, ::tunnelbroker::NewPrimaryResponse>( [this](::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::NewPrimaryRequest, ::tunnelbroker::NewPrimaryResponse>* streamer) { return this->StreamedBecomeNewPrimaryDevice(context, streamer); })); } ~WithStreamedUnaryMethod_BecomeNewPrimaryDevice() override { BaseClassMustBeDerivedFromService(this); } // disable regular version of this method ::grpc::Status BecomeNewPrimaryDevice(::grpc::ServerContext* /*context*/, const ::tunnelbroker::NewPrimaryRequest* /*request*/, ::tunnelbroker::NewPrimaryResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } // replace default version of method with streamed unary virtual ::grpc::Status StreamedBecomeNewPrimaryDevice(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::NewPrimaryRequest,::tunnelbroker::NewPrimaryResponse>* server_unary_streamer) = 0; }; template class WithStreamedUnaryMethod_SendPong : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithStreamedUnaryMethod_SendPong() { ::grpc::Service::MarkMethodStreamed(2, new ::grpc::internal::StreamedUnaryHandler< ::tunnelbroker::PongRequest, ::tunnelbroker::PongResponse>( [this](::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::PongRequest, ::tunnelbroker::PongResponse>* streamer) { return this->StreamedSendPong(context, streamer); })); } ~WithStreamedUnaryMethod_SendPong() override { BaseClassMustBeDerivedFromService(this); } // disable regular version of this method ::grpc::Status SendPong(::grpc::ServerContext* /*context*/, const ::tunnelbroker::PongRequest* /*request*/, ::tunnelbroker::PongResponse* /*response*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } // replace default version of method with streamed unary virtual ::grpc::Status StreamedSendPong(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::tunnelbroker::PongRequest,::tunnelbroker::PongResponse>* server_unary_streamer) = 0; }; typedef WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline > > StreamedUnaryService; typedef Service SplitStreamedService; typedef WithStreamedUnaryMethod_CheckIfPrimaryDeviceOnline > > StreamedService; }; } // namespace tunnelbroker #endif // GRPC_tunnelbroker_2eproto__INCLUDED diff --git a/native/cpp/CommonCpp/grpc/protos/backup.proto b/native/cpp/CommonCpp/grpc/protos/backup.proto index 0cdad3a0b..66531c6a4 100644 --- a/native/cpp/CommonCpp/grpc/protos/backup.proto +++ b/native/cpp/CommonCpp/grpc/protos/backup.proto @@ -1,59 +1,61 @@ syntax = "proto3"; package backup; service BackupService { rpc ResetKey(stream ResetKeyRequest) returns (ResetKeyResponse) {} rpc SendLog(SendLogRequest) returns (SendLogResponse) {} rpc PullBackupKey(PullBackupKeyRequest) returns (PullBackupKeyResponse) {} rpc PullCompaction(PullCompactionRequest) returns (stream PullCompactionResponse) {} } // ResetKey message ResetKeyRequest { string userId = 1; oneof data { bytes newKey = 2; bytes compactionChunk = 3; } } message ResetKeyResponse { bool success = 1; } // SendLog message SendLogRequest { string userId = 1; bytes data = 2; } message SendLogResponse { bool success = 1; } // PullBackupKey message PullBackupKeyRequest { string userId = 1; bytes pakeKey = 2; } message PullBackupKeyResponse { bool success = 1; bytes encryptedBackupKey = 2; } // PullCompaction message PullCompactionRequest { string userId = 1; bytes message = 2; } message PullCompactionResponse { - bytes compactionChunk = 1; - bytes logChunk = 2; + oneof data { + bytes compactionChunk = 1; + bytes logChunk = 2; + } }