Page Menu
Home
Phabricator
Search
Configure Global Search
Log In
Files
F3299594
D4229.diff
No One
Temporary
Actions
View File
Edit File
Delete File
View Transforms
Subscribe
Mute Notifications
Award Token
Flag For Later
Size
9 KB
Referenced Files
None
Subscribers
None
D4229.diff
View Options
diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h
--- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.h
+++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.h
@@ -1454,9 +1454,19 @@
// accessors -------------------------------------------------------
enum : int {
+ kChunkCounterFieldNumber = 3,
kCompactionChunkFieldNumber = 1,
kLogChunkFieldNumber = 2,
};
+ // int32 chunkCounter = 3;
+ void clear_chunkcounter();
+ ::PROTOBUF_NAMESPACE_ID::int32 chunkcounter() const;
+ void set_chunkcounter(::PROTOBUF_NAMESPACE_ID::int32 value);
+ private:
+ ::PROTOBUF_NAMESPACE_ID::int32 _internal_chunkcounter() const;
+ void _internal_set_chunkcounter(::PROTOBUF_NAMESPACE_ID::int32 value);
+ public:
+
// bytes compactionChunk = 1;
bool has_compactionchunk() const;
private:
@@ -1511,6 +1521,7 @@
template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
typedef void InternalArenaConstructable_;
typedef void DestructorSkippable_;
+ ::PROTOBUF_NAMESPACE_ID::int32 chunkcounter_;
union DataUnion {
constexpr DataUnion() : _constinit_{} {}
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_;
@@ -3353,6 +3364,26 @@
// @@protoc_insertion_point(field_set_allocated:backup.PullBackupResponse.logChunk)
}
+// int32 chunkCounter = 3;
+inline void PullBackupResponse::clear_chunkcounter() {
+ chunkcounter_ = 0;
+}
+inline ::PROTOBUF_NAMESPACE_ID::int32 PullBackupResponse::_internal_chunkcounter() const {
+ return chunkcounter_;
+}
+inline ::PROTOBUF_NAMESPACE_ID::int32 PullBackupResponse::chunkcounter() const {
+ // @@protoc_insertion_point(field_get:backup.PullBackupResponse.chunkCounter)
+ return _internal_chunkcounter();
+}
+inline void PullBackupResponse::_internal_set_chunkcounter(::PROTOBUF_NAMESPACE_ID::int32 value) {
+
+ chunkcounter_ = value;
+}
+inline void PullBackupResponse::set_chunkcounter(::PROTOBUF_NAMESPACE_ID::int32 value) {
+ _internal_set_chunkcounter(value);
+ // @@protoc_insertion_point(field_set:backup.PullBackupResponse.chunkCounter)
+}
+
inline bool PullBackupResponse::has_data() const {
return data_case() != DATA_NOT_SET;
}
diff --git a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc
--- a/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc
+++ b/native/cpp/CommonCpp/grpc/_generated/backup.pb.cc
@@ -104,7 +104,8 @@
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PullBackupRequestDefaultTypeInternal _PullBackupRequest_default_instance_;
constexpr PullBackupResponse::PullBackupResponse(
::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
- : _oneof_case_{}{}
+ : chunkcounter_(0)
+ , _oneof_case_{}{}
struct PullBackupResponseDefaultTypeInternal {
constexpr PullBackupResponseDefaultTypeInternal()
: _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {}
@@ -194,6 +195,7 @@
~0u, // no _weak_field_map_
::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag,
::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag,
+ PROTOBUF_FIELD_OFFSET(::backup::PullBackupResponse, chunkcounter_),
PROTOBUF_FIELD_OFFSET(::backup::PullBackupResponse, data_),
~0u, // no _has_bits_
PROTOBUF_FIELD_OFFSET(::backup::AddAttachmentsRequest, _internal_metadata_),
@@ -214,7 +216,7 @@
{ 39, -1, sizeof(::backup::RecoverBackupKeyResponse)},
{ 45, -1, sizeof(::backup::PullBackupRequest)},
{ 52, -1, sizeof(::backup::PullBackupResponse)},
- { 60, -1, sizeof(::backup::AddAttachmentsRequest)},
+ { 61, -1, sizeof(::backup::AddAttachmentsRequest)},
};
static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
@@ -243,29 +245,29 @@
"coverBackupKeyRequest\022\016\n\006userID\030\001 \001(\t\",\n"
"\030RecoverBackupKeyResponse\022\020\n\010backupID\030\004 "
"\001(\t\"5\n\021PullBackupRequest\022\016\n\006userID\030\001 \001(\t"
- "\022\020\n\010backupID\030\002 \001(\t\"K\n\022PullBackupResponse"
+ "\022\020\n\010backupID\030\002 \001(\t\"a\n\022PullBackupResponse"
"\022\031\n\017compactionChunk\030\001 \001(\014H\000\022\022\n\010logChunk\030"
- "\002 \001(\014H\000B\006\n\004data\"Y\n\025AddAttachmentsRequest"
- "\022\016\n\006userID\030\001 \001(\t\022\020\n\010backupID\030\002 \001(\t\022\r\n\005lo"
- "gID\030\003 \001(\t\022\017\n\007holders\030\004 \001(\t2\232\003\n\rBackupSer"
- "vice\022X\n\017CreateNewBackup\022\036.backup.CreateN"
- "ewBackupRequest\032\037.backup.CreateNewBackup"
- "Response\"\000(\0010\001\022>\n\007SendLog\022\026.backup.SendL"
- "ogRequest\032\027.backup.SendLogResponse\"\000(\001\022["
- "\n\020RecoverBackupKey\022\037.backup.RecoverBacku"
- "pKeyRequest\032 .backup.RecoverBackupKeyRes"
- "ponse\"\000(\0010\001\022G\n\nPullBackup\022\031.backup.PullB"
- "ackupRequest\032\032.backup.PullBackupResponse"
- "\"\0000\001\022I\n\016AddAttachments\022\035.backup.AddAttac"
- "hmentsRequest\032\026.google.protobuf.Empty\"\000b"
- "\006proto3"
+ "\002 \001(\014H\000\022\024\n\014chunkCounter\030\003 \001(\005B\006\n\004data\"Y\n"
+ "\025AddAttachmentsRequest\022\016\n\006userID\030\001 \001(\t\022\020"
+ "\n\010backupID\030\002 \001(\t\022\r\n\005logID\030\003 \001(\t\022\017\n\007holde"
+ "rs\030\004 \001(\t2\232\003\n\rBackupService\022X\n\017CreateNewB"
+ "ackup\022\036.backup.CreateNewBackupRequest\032\037."
+ "backup.CreateNewBackupResponse\"\000(\0010\001\022>\n\007"
+ "SendLog\022\026.backup.SendLogRequest\032\027.backup"
+ ".SendLogResponse\"\000(\001\022[\n\020RecoverBackupKey"
+ "\022\037.backup.RecoverBackupKeyRequest\032 .back"
+ "up.RecoverBackupKeyResponse\"\000(\0010\001\022G\n\nPul"
+ "lBackup\022\031.backup.PullBackupRequest\032\032.bac"
+ "kup.PullBackupResponse\"\0000\001\022I\n\016AddAttachm"
+ "ents\022\035.backup.AddAttachmentsRequest\032\026.go"
+ "ogle.protobuf.Empty\"\000b\006proto3"
;
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_backup_2eproto_deps[1] = {
&::descriptor_table_google_2fprotobuf_2fempty_2eproto,
};
static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_backup_2eproto_once;
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_backup_2eproto = {
- false, false, 1127, descriptor_table_protodef_backup_2eproto, "backup.proto",
+ false, false, 1149, descriptor_table_protodef_backup_2eproto, "backup.proto",
&descriptor_table_backup_2eproto_once, descriptor_table_backup_2eproto_deps, 1, 9,
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,
@@ -2042,6 +2044,7 @@
PullBackupResponse::PullBackupResponse(const PullBackupResponse& from)
: ::PROTOBUF_NAMESPACE_ID::Message() {
_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+ chunkcounter_ = from.chunkcounter_;
clear_has_data();
switch (from.data_case()) {
case kCompactionChunk: {
@@ -2060,6 +2063,7 @@
}
void PullBackupResponse::SharedCtor() {
+chunkcounter_ = 0;
clear_has_data();
}
@@ -2111,6 +2115,7 @@
// Prevent compiler warnings about cached_has_bits being unused
(void) cached_has_bits;
+ chunkcounter_ = 0;
clear_data();
_internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
}
@@ -2138,6 +2143,13 @@
CHK_(ptr);
} else goto handle_unusual;
continue;
+ // int32 chunkCounter = 3;
+ case 3:
+ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 24)) {
+ chunkcounter_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
+ CHK_(ptr);
+ } else goto handle_unusual;
+ continue;
default: {
handle_unusual:
if ((tag & 7) == 4 || tag == 0) {
@@ -2178,6 +2190,12 @@
2, this->_internal_logchunk(), target);
}
+ // int32 chunkCounter = 3;
+ if (this->chunkcounter() != 0) {
+ target = stream->EnsureSpace(target);
+ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt32ToArray(3, this->_internal_chunkcounter(), 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);
@@ -2194,6 +2212,13 @@
// Prevent compiler warnings about cached_has_bits being unused
(void) cached_has_bits;
+ // int32 chunkCounter = 3;
+ if (this->chunkcounter() != 0) {
+ total_size += 1 +
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int32Size(
+ this->_internal_chunkcounter());
+ }
+
switch (data_case()) {
// bytes compactionChunk = 1;
case kCompactionChunk: {
@@ -2244,6 +2269,9 @@
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
(void) cached_has_bits;
+ if (from.chunkcounter() != 0) {
+ _internal_set_chunkcounter(from._internal_chunkcounter());
+ }
switch (from.data_case()) {
case kCompactionChunk: {
_internal_set_compactionchunk(from._internal_compactionchunk());
@@ -2280,6 +2308,7 @@
void PullBackupResponse::InternalSwap(PullBackupResponse* other) {
using std::swap;
_internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_);
+ swap(chunkcounter_, other->chunkcounter_);
swap(data_, other->data_);
swap(_oneof_case_[0], other->_oneof_case_[0]);
}
diff --git a/native/cpp/CommonCpp/grpc/protos/backup.proto b/native/cpp/CommonCpp/grpc/protos/backup.proto
--- a/native/cpp/CommonCpp/grpc/protos/backup.proto
+++ b/native/cpp/CommonCpp/grpc/protos/backup.proto
@@ -79,6 +79,7 @@
bytes compactionChunk = 1;
bytes logChunk = 2;
}
+ int32 chunkCounter = 3;
}
// AddAttachment
File Metadata
Details
Attached
Mime Type
text/plain
Expires
Mon, Nov 18, 1:58 PM (20 h, 20 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2535018
Default Alt Text
D4229.diff (9 KB)
Attached To
Mode
D4229: [services] Backup - Add chunk counter to proto
Attached
Detach File
Event Timeline
Log In to Comment