/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tablet/metadata.pb.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: yb/tablet/metadata.proto |
3 | | |
4 | | #include "yb/tablet/metadata.pb.h" |
5 | | |
6 | | #include <algorithm> |
7 | | |
8 | | #include <google/protobuf/stubs/common.h> |
9 | | #include <google/protobuf/stubs/port.h> |
10 | | #include <google/protobuf/stubs/once.h> |
11 | | #include <google/protobuf/io/coded_stream.h> |
12 | | #include <google/protobuf/wire_format_lite_inl.h> |
13 | | #include <google/protobuf/descriptor.h> |
14 | | #include <google/protobuf/generated_message_reflection.h> |
15 | | #include <google/protobuf/reflection_ops.h> |
16 | | #include <google/protobuf/wire_format.h> |
17 | | // This is a temporary google only hack |
18 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
19 | | #include "third_party/protobuf/version.h" |
20 | | #endif |
21 | | #include "yb/util/protobuf-annotations.h" |
22 | | // @@protoc_insertion_point(includes) |
23 | | namespace yb { |
24 | | namespace tablet { |
25 | | class TableInfoPBDefaultTypeInternal { |
26 | | public: |
27 | | ::google::protobuf::internal::ExplicitlyConstructed<TableInfoPB> |
28 | | _instance; |
29 | | } _TableInfoPB_default_instance_; |
30 | | class KvStoreInfoPBDefaultTypeInternal { |
31 | | public: |
32 | | ::google::protobuf::internal::ExplicitlyConstructed<KvStoreInfoPB> |
33 | | _instance; |
34 | | } _KvStoreInfoPB_default_instance_; |
35 | | class RaftGroupReplicaSuperBlockPBDefaultTypeInternal { |
36 | | public: |
37 | | ::google::protobuf::internal::ExplicitlyConstructed<RaftGroupReplicaSuperBlockPB> |
38 | | _instance; |
39 | | } _RaftGroupReplicaSuperBlockPB_default_instance_; |
40 | | class FilePBDefaultTypeInternal { |
41 | | public: |
42 | | ::google::protobuf::internal::ExplicitlyConstructed<FilePB> |
43 | | _instance; |
44 | | } _FilePB_default_instance_; |
45 | | class SnapshotFilePBDefaultTypeInternal { |
46 | | public: |
47 | | ::google::protobuf::internal::ExplicitlyConstructed<SnapshotFilePB> |
48 | | _instance; |
49 | | } _SnapshotFilePB_default_instance_; |
50 | | } // namespace tablet |
51 | | } // namespace yb |
52 | | namespace protobuf_yb_2ftablet_2fmetadata_2eproto { |
53 | 15.8k | void InitDefaultsTableInfoPBImpl() { |
54 | 15.8k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
55 | | |
56 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
57 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
58 | | #else |
59 | 15.8k | ::google::protobuf::internal::InitProtobufDefaults(); |
60 | 15.8k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
61 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsSchemaPB(); |
62 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsPartitionSchemaPB(); |
63 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsIndexInfoPB(); |
64 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsDeletedColumnPB(); |
65 | 15.8k | { |
66 | 15.8k | void* ptr = &::yb::tablet::_TableInfoPB_default_instance_; |
67 | 15.8k | new (ptr) ::yb::tablet::TableInfoPB(); |
68 | 15.8k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
69 | 15.8k | } |
70 | 15.8k | ::yb::tablet::TableInfoPB::InitAsDefaultInstance(); |
71 | 15.8k | } |
72 | | |
73 | 141M | void InitDefaultsTableInfoPB() { |
74 | 141M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
75 | 141M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsTableInfoPBImpl); |
76 | 141M | } |
77 | | |
78 | 15.8k | void InitDefaultsKvStoreInfoPBImpl() { |
79 | 15.8k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
80 | | |
81 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
82 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
83 | | #else |
84 | 15.8k | ::google::protobuf::internal::InitProtobufDefaults(); |
85 | 15.8k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
86 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsFilePB(); |
87 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsSnapshotFilePB(); |
88 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsTableInfoPB(); |
89 | 15.8k | { |
90 | 15.8k | void* ptr = &::yb::tablet::_KvStoreInfoPB_default_instance_; |
91 | 15.8k | new (ptr) ::yb::tablet::KvStoreInfoPB(); |
92 | 15.8k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
93 | 15.8k | } |
94 | 15.8k | ::yb::tablet::KvStoreInfoPB::InitAsDefaultInstance(); |
95 | 15.8k | } |
96 | | |
97 | 856k | void InitDefaultsKvStoreInfoPB() { |
98 | 856k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
99 | 856k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsKvStoreInfoPBImpl); |
100 | 856k | } |
101 | | |
102 | 15.8k | void InitDefaultsRaftGroupReplicaSuperBlockPBImpl() { |
103 | 15.8k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
104 | | |
105 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
106 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
107 | | #else |
108 | 15.8k | ::google::protobuf::internal::InitProtobufDefaults(); |
109 | 15.8k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
110 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsPartitionPB(); |
111 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsSchemaPB(); |
112 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsPartitionSchemaPB(); |
113 | 15.8k | protobuf_yb_2futil_2fopid_2eproto::InitDefaultsOpIdPB(); |
114 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsKvStoreInfoPB(); |
115 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsFilePB(); |
116 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsSnapshotFilePB(); |
117 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsDeletedColumnPB(); |
118 | 15.8k | protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsIndexInfoPB(); |
119 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsTableInfoPB(); |
120 | 15.8k | { |
121 | 15.8k | void* ptr = &::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_; |
122 | 15.8k | new (ptr) ::yb::tablet::RaftGroupReplicaSuperBlockPB(); |
123 | 15.8k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
124 | 15.8k | } |
125 | 15.8k | ::yb::tablet::RaftGroupReplicaSuperBlockPB::InitAsDefaultInstance(); |
126 | 15.8k | } |
127 | | |
128 | 1.68M | void InitDefaultsRaftGroupReplicaSuperBlockPB() { |
129 | 1.68M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
130 | 1.68M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsRaftGroupReplicaSuperBlockPBImpl); |
131 | 1.68M | } |
132 | | |
133 | 15.8k | void InitDefaultsFilePBImpl() { |
134 | 15.8k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
135 | | |
136 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
137 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
138 | | #else |
139 | 15.8k | ::google::protobuf::internal::InitProtobufDefaults(); |
140 | 15.8k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
141 | 15.8k | { |
142 | 15.8k | void* ptr = &::yb::tablet::_FilePB_default_instance_; |
143 | 15.8k | new (ptr) ::yb::tablet::FilePB(); |
144 | 15.8k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
145 | 15.8k | } |
146 | 15.8k | ::yb::tablet::FilePB::InitAsDefaultInstance(); |
147 | 15.8k | } |
148 | | |
149 | 80.5k | void InitDefaultsFilePB() { |
150 | 80.5k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
151 | 80.5k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsFilePBImpl); |
152 | 80.5k | } |
153 | | |
154 | 15.8k | void InitDefaultsSnapshotFilePBImpl() { |
155 | 15.8k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
156 | | |
157 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
158 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
159 | | #else |
160 | 15.8k | ::google::protobuf::internal::InitProtobufDefaults(); |
161 | 15.8k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
162 | 15.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsFilePB(); |
163 | 15.8k | { |
164 | 15.8k | void* ptr = &::yb::tablet::_SnapshotFilePB_default_instance_; |
165 | 15.8k | new (ptr) ::yb::tablet::SnapshotFilePB(); |
166 | 15.8k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
167 | 15.8k | } |
168 | 15.8k | ::yb::tablet::SnapshotFilePB::InitAsDefaultInstance(); |
169 | 15.8k | } |
170 | | |
171 | 47.7k | void InitDefaultsSnapshotFilePB() { |
172 | 47.7k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
173 | 47.7k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsSnapshotFilePBImpl); |
174 | 47.7k | } |
175 | | |
176 | | ::google::protobuf::Metadata file_level_metadata[5]; |
177 | | |
178 | | const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
179 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, _has_bits_), |
180 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, _internal_metadata_), |
181 | | ~0u, // no _extensions_ |
182 | | ~0u, // no _oneof_case_ |
183 | | ~0u, // no _weak_field_map_ |
184 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, table_id_), |
185 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, namespace_name_), |
186 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, table_name_), |
187 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, table_type_), |
188 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, schema_), |
189 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, schema_version_), |
190 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, partition_schema_), |
191 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, indexes_), |
192 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, index_info_), |
193 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::TableInfoPB, deleted_cols_), |
194 | | 0, |
195 | | 2, |
196 | | 1, |
197 | | 7, |
198 | | 3, |
199 | | 6, |
200 | | 4, |
201 | | ~0u, |
202 | | 5, |
203 | | ~0u, |
204 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, _has_bits_), |
205 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, _internal_metadata_), |
206 | | ~0u, // no _extensions_ |
207 | | ~0u, // no _oneof_case_ |
208 | | ~0u, // no _weak_field_map_ |
209 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, kv_store_id_), |
210 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, rocksdb_dir_), |
211 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, rocksdb_files_), |
212 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, snapshot_files_), |
213 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, tables_), |
214 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, lower_bound_key_), |
215 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, upper_bound_key_), |
216 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, has_been_fully_compacted_), |
217 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::KvStoreInfoPB, snapshot_schedules_), |
218 | | 0, |
219 | | 1, |
220 | | ~0u, |
221 | | ~0u, |
222 | | ~0u, |
223 | | 2, |
224 | | 3, |
225 | | 4, |
226 | | ~0u, |
227 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, _has_bits_), |
228 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, _internal_metadata_), |
229 | | ~0u, // no _extensions_ |
230 | | ~0u, // no _oneof_case_ |
231 | | ~0u, // no _weak_field_map_ |
232 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, primary_table_id_), |
233 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, raft_group_id_), |
234 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, partition_), |
235 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_table_name_), |
236 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_table_type_), |
237 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_schema_), |
238 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_schema_version_), |
239 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_partition_schema_), |
240 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, tablet_data_state_), |
241 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, wal_dir_), |
242 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, tombstone_last_logged_opid_), |
243 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, kv_store_), |
244 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_rocksdb_dir_), |
245 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_rocksdb_files_), |
246 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_snapshot_files_), |
247 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_deleted_cols_), |
248 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_indexes_), |
249 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_index_info_), |
250 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, obsolete_tables_), |
251 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, colocated_), |
252 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, cdc_min_replicated_index_), |
253 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, is_under_twodc_replication_), |
254 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, hidden_), |
255 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, restoration_hybrid_time_), |
256 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, split_op_id_), |
257 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, split_child_tablet_ids_), |
258 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::RaftGroupReplicaSuperBlockPB, active_restorations_), |
259 | | 0, |
260 | | 1, |
261 | | 7, |
262 | | 2, |
263 | | 18, |
264 | | 5, |
265 | | 12, |
266 | | 8, |
267 | | 17, |
268 | | 4, |
269 | | 6, |
270 | | 10, |
271 | | 3, |
272 | | ~0u, |
273 | | ~0u, |
274 | | ~0u, |
275 | | ~0u, |
276 | | 9, |
277 | | ~0u, |
278 | | 13, |
279 | | 19, |
280 | | 14, |
281 | | 15, |
282 | | 16, |
283 | | 11, |
284 | | ~0u, |
285 | | ~0u, |
286 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::FilePB, _has_bits_), |
287 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::FilePB, _internal_metadata_), |
288 | | ~0u, // no _extensions_ |
289 | | ~0u, // no _oneof_case_ |
290 | | ~0u, // no _weak_field_map_ |
291 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::FilePB, name_), |
292 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::FilePB, size_bytes_), |
293 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::FilePB, inode_), |
294 | | 0, |
295 | | 1, |
296 | | 2, |
297 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::SnapshotFilePB, _has_bits_), |
298 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::SnapshotFilePB, _internal_metadata_), |
299 | | ~0u, // no _extensions_ |
300 | | ~0u, // no _oneof_case_ |
301 | | ~0u, // no _weak_field_map_ |
302 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::SnapshotFilePB, file_), |
303 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::tablet::SnapshotFilePB, snapshot_id_), |
304 | | 1, |
305 | | 0, |
306 | | }; |
307 | | static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
308 | | { 0, 15, sizeof(::yb::tablet::TableInfoPB)}, |
309 | | { 25, 39, sizeof(::yb::tablet::KvStoreInfoPB)}, |
310 | | { 48, 80, sizeof(::yb::tablet::RaftGroupReplicaSuperBlockPB)}, |
311 | | { 107, 115, sizeof(::yb::tablet::FilePB)}, |
312 | | { 118, 125, sizeof(::yb::tablet::SnapshotFilePB)}, |
313 | | }; |
314 | | |
315 | | static ::google::protobuf::Message const * const file_default_instances[] = { |
316 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::tablet::_TableInfoPB_default_instance_), |
317 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::tablet::_KvStoreInfoPB_default_instance_), |
318 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_), |
319 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::tablet::_FilePB_default_instance_), |
320 | | reinterpret_cast<const ::google::protobuf::Message*>(&::yb::tablet::_SnapshotFilePB_default_instance_), |
321 | | }; |
322 | | |
323 | 9.60k | void protobuf_AssignDescriptors() { |
324 | 9.60k | AddDescriptors(); |
325 | 9.60k | ::google::protobuf::MessageFactory* factory = NULL; |
326 | 9.60k | AssignDescriptors( |
327 | 9.60k | "yb/tablet/metadata.proto", schemas, file_default_instances, TableStruct::offsets, factory, |
328 | 9.60k | file_level_metadata, NULL, NULL); |
329 | 9.60k | } |
330 | | |
331 | 2.93M | void protobuf_AssignDescriptorsOnce() { |
332 | 2.93M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
333 | 2.93M | ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors); |
334 | 2.93M | } |
335 | | |
336 | | void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD; |
337 | 0 | void protobuf_RegisterTypes(const ::std::string&) { |
338 | 0 | protobuf_AssignDescriptorsOnce(); |
339 | 0 | ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 5); |
340 | 0 | } |
341 | | |
342 | 15.8k | void AddDescriptorsImpl() { |
343 | 15.8k | InitDefaults(); |
344 | 15.8k | static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
345 | 15.8k | "\n\030yb/tablet/metadata.proto\022\tyb.tablet\032\026y" |
346 | 15.8k | "b/common/common.proto\032\034yb/common/common_" |
347 | 15.8k | "types.proto\032\034yb/tablet/tablet_types.prot" |
348 | 15.8k | "o\032\022yb/util/opid.proto\"\333\002\n\013TableInfoPB\022\020\n" |
349 | 15.8k | "\010table_id\030\001 \001(\014\022\026\n\016namespace_name\030\n \001(\t\022" |
350 | 15.8k | "\022\n\ntable_name\030\002 \001(\t\0225\n\ntable_type\030\003 \001(\0162" |
351 | 15.8k | "\r.yb.TableType:\022DEFAULT_TABLE_TYPE\022\034\n\006sc" |
352 | 15.8k | "hema\030\004 \001(\0132\014.yb.SchemaPB\022\026\n\016schema_versi" |
353 | 15.8k | "on\030\005 \001(\r\022/\n\020partition_schema\030\006 \001(\0132\025.yb." |
354 | 15.8k | "PartitionSchemaPB\022 \n\007indexes\030\007 \003(\0132\017.yb." |
355 | 15.8k | "IndexInfoPB\022#\n\nindex_info\030\010 \001(\0132\017.yb.Ind" |
356 | 15.8k | "exInfoPB\022)\n\014deleted_cols\030\t \003(\0132\023.yb.Dele" |
357 | 15.8k | "tedColumnPB\"\256\002\n\rKvStoreInfoPB\022\023\n\013kv_stor" |
358 | 15.8k | "e_id\030\001 \002(\014\022\023\n\013rocksdb_dir\030\002 \001(\t\022(\n\rrocks" |
359 | 15.8k | "db_files\030\003 \003(\0132\021.yb.tablet.FilePB\0221\n\016sna" |
360 | 15.8k | "pshot_files\030\004 \003(\0132\031.yb.tablet.SnapshotFi" |
361 | 15.8k | "lePB\022&\n\006tables\030\005 \003(\0132\026.yb.tablet.TableIn" |
362 | 15.8k | "foPB\022\027\n\017lower_bound_key\030\006 \001(\014\022\027\n\017upper_b" |
363 | 15.8k | "ound_key\030\007 \001(\014\022 \n\030has_been_fully_compact" |
364 | 15.8k | "ed\030\010 \001(\010\022\032\n\022snapshot_schedules\030\t \003(\014\"\362\010\n" |
365 | 15.8k | "\034RaftGroupReplicaSuperBlockPB\022\030\n\020primary" |
366 | 15.8k | "_table_id\030\001 \002(\014\022\025\n\rraft_group_id\030\002 \002(\014\022\"" |
367 | 15.8k | "\n\tpartition\030\r \001(\0132\017.yb.PartitionPB\022\033\n\023OB" |
368 | 15.8k | "SOLETE_table_name\030\007 \001(\t\022>\n\023OBSOLETE_tabl" |
369 | 15.8k | "e_type\030\017 \001(\0162\r.yb.TableType:\022DEFAULT_TAB" |
370 | 15.8k | "LE_TYPE\022%\n\017OBSOLETE_schema\030\010 \001(\0132\014.yb.Sc" |
371 | 15.8k | "hemaPB\022\037\n\027OBSOLETE_schema_version\030\t \001(\r\022" |
372 | 15.8k | "8\n\031OBSOLETE_partition_schema\030\016 \001(\0132\025.yb." |
373 | 15.8k | "PartitionSchemaPB\022J\n\021tablet_data_state\030\n" |
374 | 15.8k | " \001(\0162\032.yb.tablet.TabletDataState:\023TABLET" |
375 | 15.8k | "_DATA_UNKNOWN\022\017\n\007wal_dir\030\022 \001(\t\022.\n\032tombst" |
376 | 15.8k | "one_last_logged_opid\030\014 \001(\0132\n.yb.OpIdPB\022*" |
377 | 15.8k | "\n\010kv_store\030\030 \001(\0132\030.yb.tablet.KvStoreInfo" |
378 | 15.8k | "PB\022\034\n\024OBSOLETE_rocksdb_dir\030\020 \001(\t\0221\n\026OBSO" |
379 | 15.8k | "LETE_rocksdb_files\030\021 \003(\0132\021.yb.tablet.Fil" |
380 | 15.8k | "ePB\022:\n\027OBSOLETE_snapshot_files\030\024 \003(\0132\031.y" |
381 | 15.8k | "b.tablet.SnapshotFilePB\0222\n\025OBSOLETE_dele" |
382 | 15.8k | "ted_cols\030\023 \003(\0132\023.yb.DeletedColumnPB\022)\n\020O" |
383 | 15.8k | "BSOLETE_indexes\030\025 \003(\0132\017.yb.IndexInfoPB\022," |
384 | 15.8k | "\n\023OBSOLETE_index_info\030\026 \001(\0132\017.yb.IndexIn" |
385 | 15.8k | "foPB\022/\n\017OBSOLETE_tables\030\027 \003(\0132\026.yb.table" |
386 | 15.8k | "t.TableInfoPB\022\030\n\tcolocated\030\031 \001(\010:\005false\022" |
387 | 15.8k | "5\n\030cdc_min_replicated_index\030\032 \001(\003:\02392233" |
388 | 15.8k | "72036854775807\022\"\n\032is_under_twodc_replica" |
389 | 15.8k | "tion\030\033 \001(\010\022\016\n\006hidden\030\034 \001(\010\022\037\n\027restoratio" |
390 | 15.8k | "n_hybrid_time\030 \001(\006\022\037\n\013split_op_id\030\035 \001(\013" |
391 | 15.8k | "2\n.yb.OpIdPB\022\036\n\026split_child_tablet_ids\030\036" |
392 | 15.8k | " \003(\014\022\033\n\023active_restorations\030\037 \003(\014J\004\010\003\020\004J" |
393 | 15.8k | "\004\010\004\020\005J\004\010\005\020\006J\004\010\013\020\014\"9\n\006FilePB\022\014\n\004name\030\001 \001(" |
394 | 15.8k | "\t\022\022\n\nsize_bytes\030\002 \001(\004\022\r\n\005inode\030\003 \001(\004\"F\n\016" |
395 | 15.8k | "SnapshotFilePB\022\037\n\004file\030\001 \001(\0132\021.yb.tablet" |
396 | 15.8k | ".FilePB\022\023\n\013snapshot_id\030\002 \001(\014B\017\n\rorg.yb.t" |
397 | 15.8k | "ablet" |
398 | 15.8k | }; |
399 | 15.8k | ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( |
400 | 15.8k | descriptor, 2085); |
401 | 15.8k | ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( |
402 | 15.8k | "yb/tablet/metadata.proto", &protobuf_RegisterTypes); |
403 | 15.8k | ::protobuf_yb_2fcommon_2fcommon_2eproto::AddDescriptors(); |
404 | 15.8k | ::protobuf_yb_2fcommon_2fcommon_5ftypes_2eproto::AddDescriptors(); |
405 | 15.8k | ::protobuf_yb_2ftablet_2ftablet_5ftypes_2eproto::AddDescriptors(); |
406 | 15.8k | ::protobuf_yb_2futil_2fopid_2eproto::AddDescriptors(); |
407 | 15.8k | } |
408 | | |
409 | 72.9k | void AddDescriptors() { |
410 | 72.9k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
411 | 72.9k | ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl); |
412 | 72.9k | } |
413 | | // Force AddDescriptors() to be called at dynamic initialization time. |
414 | | struct StaticDescriptorInitializer { |
415 | 15.8k | StaticDescriptorInitializer() { |
416 | 15.8k | AddDescriptors(); |
417 | 15.8k | } |
418 | | } static_descriptor_initializer; |
419 | | } // namespace protobuf_yb_2ftablet_2fmetadata_2eproto |
420 | | namespace yb { |
421 | | namespace tablet { |
422 | | |
423 | | // =================================================================== |
424 | | |
425 | 15.8k | void TableInfoPB::InitAsDefaultInstance() { |
426 | 15.8k | ::yb::tablet::_TableInfoPB_default_instance_._instance.get_mutable()->schema_ = const_cast< ::yb::SchemaPB*>( |
427 | 15.8k | ::yb::SchemaPB::internal_default_instance()); |
428 | 15.8k | ::yb::tablet::_TableInfoPB_default_instance_._instance.get_mutable()->partition_schema_ = const_cast< ::yb::PartitionSchemaPB*>( |
429 | 15.8k | ::yb::PartitionSchemaPB::internal_default_instance()); |
430 | 15.8k | ::yb::tablet::_TableInfoPB_default_instance_._instance.get_mutable()->index_info_ = const_cast< ::yb::IndexInfoPB*>( |
431 | 15.8k | ::yb::IndexInfoPB::internal_default_instance()); |
432 | 15.8k | } |
433 | 0 | void TableInfoPB::clear_schema() { |
434 | 0 | if (schema_ != NULL) schema_->Clear(); |
435 | 0 | clear_has_schema(); |
436 | 0 | } |
437 | 0 | void TableInfoPB::clear_partition_schema() { |
438 | 0 | if (partition_schema_ != NULL) partition_schema_->Clear(); |
439 | 0 | clear_has_partition_schema(); |
440 | 0 | } |
441 | 0 | void TableInfoPB::clear_indexes() { |
442 | 0 | indexes_.Clear(); |
443 | 0 | } |
444 | 0 | void TableInfoPB::clear_index_info() { |
445 | 0 | if (index_info_ != NULL) index_info_->Clear(); |
446 | 0 | clear_has_index_info(); |
447 | 0 | } |
448 | 0 | void TableInfoPB::clear_deleted_cols() { |
449 | 0 | deleted_cols_.Clear(); |
450 | 0 | } |
451 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
452 | | const int TableInfoPB::kTableIdFieldNumber; |
453 | | const int TableInfoPB::kNamespaceNameFieldNumber; |
454 | | const int TableInfoPB::kTableNameFieldNumber; |
455 | | const int TableInfoPB::kTableTypeFieldNumber; |
456 | | const int TableInfoPB::kSchemaFieldNumber; |
457 | | const int TableInfoPB::kSchemaVersionFieldNumber; |
458 | | const int TableInfoPB::kPartitionSchemaFieldNumber; |
459 | | const int TableInfoPB::kIndexesFieldNumber; |
460 | | const int TableInfoPB::kIndexInfoFieldNumber; |
461 | | const int TableInfoPB::kDeletedColsFieldNumber; |
462 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
463 | | |
464 | | TableInfoPB::TableInfoPB() |
465 | 141M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
466 | 141M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
467 | 141M | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsTableInfoPB(); |
468 | 141M | } |
469 | 141M | SharedCtor(); |
470 | | // @@protoc_insertion_point(constructor:yb.tablet.TableInfoPB) |
471 | 141M | } |
472 | | TableInfoPB::TableInfoPB(const TableInfoPB& from) |
473 | | : ::google::protobuf::Message(), |
474 | | _internal_metadata_(NULL), |
475 | | _has_bits_(from._has_bits_), |
476 | | _cached_size_(0), |
477 | | indexes_(from.indexes_), |
478 | 0 | deleted_cols_(from.deleted_cols_) { |
479 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
480 | 0 | table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
481 | 0 | if (from.has_table_id()) { |
482 | 0 | table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.table_id_); |
483 | 0 | } |
484 | 0 | table_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
485 | 0 | if (from.has_table_name()) { |
486 | 0 | table_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.table_name_); |
487 | 0 | } |
488 | 0 | namespace_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
489 | 0 | if (from.has_namespace_name()) { |
490 | 0 | namespace_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.namespace_name_); |
491 | 0 | } |
492 | 0 | if (from.has_schema()) { |
493 | 0 | schema_ = new ::yb::SchemaPB(*from.schema_); |
494 | 0 | } else { |
495 | 0 | schema_ = NULL; |
496 | 0 | } |
497 | 0 | if (from.has_partition_schema()) { |
498 | 0 | partition_schema_ = new ::yb::PartitionSchemaPB(*from.partition_schema_); |
499 | 0 | } else { |
500 | 0 | partition_schema_ = NULL; |
501 | 0 | } |
502 | 0 | if (from.has_index_info()) { |
503 | 0 | index_info_ = new ::yb::IndexInfoPB(*from.index_info_); |
504 | 0 | } else { |
505 | 0 | index_info_ = NULL; |
506 | 0 | } |
507 | 0 | ::memcpy(&schema_version_, &from.schema_version_, |
508 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&table_type_) - |
509 | 0 | reinterpret_cast<char*>(&schema_version_)) + sizeof(table_type_)); |
510 | | // @@protoc_insertion_point(copy_constructor:yb.tablet.TableInfoPB) |
511 | 0 | } |
512 | | |
513 | 141M | void TableInfoPB::SharedCtor() { |
514 | 141M | _cached_size_ = 0; |
515 | 141M | table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
516 | 141M | table_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
517 | 141M | namespace_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
518 | 141M | ::memset(&schema_, 0, static_cast<size_t>( |
519 | 141M | reinterpret_cast<char*>(&schema_version_) - |
520 | 141M | reinterpret_cast<char*>(&schema_)) + sizeof(schema_version_)); |
521 | 141M | table_type_ = 2; |
522 | 141M | } |
523 | | |
524 | 141M | TableInfoPB::~TableInfoPB() { |
525 | | // @@protoc_insertion_point(destructor:yb.tablet.TableInfoPB) |
526 | 141M | SharedDtor(); |
527 | 141M | } |
528 | | |
529 | 141M | void TableInfoPB::SharedDtor() { |
530 | 141M | table_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
531 | 141M | table_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
532 | 141M | namespace_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
533 | 141M | if (this != internal_default_instance()) delete schema_; |
534 | 141M | if (this != internal_default_instance()) delete partition_schema_; |
535 | 141M | if (this != internal_default_instance()) delete index_info_; |
536 | 141M | } |
537 | | |
538 | 0 | void TableInfoPB::SetCachedSize(int size) const { |
539 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
540 | 0 | _cached_size_ = size; |
541 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
542 | 0 | } |
543 | 0 | const ::google::protobuf::Descriptor* TableInfoPB::descriptor() { |
544 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
545 | 0 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
546 | 0 | } |
547 | | |
548 | 0 | const TableInfoPB& TableInfoPB::default_instance() { |
549 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsTableInfoPB(); |
550 | 0 | return *internal_default_instance(); |
551 | 0 | } |
552 | | |
553 | 0 | TableInfoPB* TableInfoPB::New(::google::protobuf::Arena* arena) const { |
554 | 0 | TableInfoPB* n = new TableInfoPB; |
555 | 0 | if (arena != NULL) { |
556 | 0 | arena->Own(n); |
557 | 0 | } |
558 | 0 | return n; |
559 | 0 | } |
560 | | |
561 | 27 | void TableInfoPB::Clear() { |
562 | | // @@protoc_insertion_point(message_clear_start:yb.tablet.TableInfoPB) |
563 | 27 | ::google::protobuf::uint32 cached_has_bits = 0; |
564 | | // Prevent compiler warnings about cached_has_bits being unused |
565 | 27 | (void) cached_has_bits; |
566 | | |
567 | 27 | indexes_.Clear(); |
568 | 27 | deleted_cols_.Clear(); |
569 | 27 | cached_has_bits = _has_bits_[0]; |
570 | 27 | if (cached_has_bits & 63u) { |
571 | 0 | if (cached_has_bits & 0x00000001u) { |
572 | 0 | GOOGLE_DCHECK(!table_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
573 | 0 | (*table_id_.UnsafeRawStringPointer())->clear(); |
574 | 0 | } |
575 | 0 | if (cached_has_bits & 0x00000002u) { |
576 | 0 | GOOGLE_DCHECK(!table_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
577 | 0 | (*table_name_.UnsafeRawStringPointer())->clear(); |
578 | 0 | } |
579 | 0 | if (cached_has_bits & 0x00000004u) { |
580 | 0 | GOOGLE_DCHECK(!namespace_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
581 | 0 | (*namespace_name_.UnsafeRawStringPointer())->clear(); |
582 | 0 | } |
583 | 0 | if (cached_has_bits & 0x00000008u) { |
584 | 0 | GOOGLE_DCHECK(schema_ != NULL); |
585 | 0 | schema_->Clear(); |
586 | 0 | } |
587 | 0 | if (cached_has_bits & 0x00000010u) { |
588 | 0 | GOOGLE_DCHECK(partition_schema_ != NULL); |
589 | 0 | partition_schema_->Clear(); |
590 | 0 | } |
591 | 0 | if (cached_has_bits & 0x00000020u) { |
592 | 0 | GOOGLE_DCHECK(index_info_ != NULL); |
593 | 0 | index_info_->Clear(); |
594 | 0 | } |
595 | 0 | } |
596 | 27 | if (cached_has_bits & 192u) { |
597 | 0 | schema_version_ = 0u; |
598 | 0 | table_type_ = 2; |
599 | 0 | } |
600 | 27 | _has_bits_.Clear(); |
601 | 27 | _internal_metadata_.Clear(); |
602 | 27 | } |
603 | | |
604 | | bool TableInfoPB::MergePartialFromCodedStream( |
605 | 490k | ::google::protobuf::io::CodedInputStream* input) { |
606 | 2.94M | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
607 | 490k | ::google::protobuf::uint32 tag; |
608 | | // @@protoc_insertion_point(parse_start:yb.tablet.TableInfoPB) |
609 | 3.43M | for (;;) { |
610 | 3.43M | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
611 | 3.43M | tag = p.first; |
612 | 3.43M | if (!p.second) goto handle_unusual; |
613 | 2.94M | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
614 | | // optional bytes table_id = 1; |
615 | 490k | case 1: { |
616 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
617 | 490k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
618 | 490k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
619 | 490k | input, this->mutable_table_id())); |
620 | 0 | } else { |
621 | 0 | goto handle_unusual; |
622 | 0 | } |
623 | 490k | break; |
624 | 490k | } |
625 | | |
626 | | // optional string table_name = 2; |
627 | 490k | case 2: { |
628 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
629 | 490k | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
630 | 490k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
631 | 490k | input, this->mutable_table_name())); |
632 | 490k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
633 | 490k | this->table_name().data(), static_cast<int>(this->table_name().length()), |
634 | 490k | ::google::protobuf::internal::WireFormat::PARSE, |
635 | 490k | "yb.tablet.TableInfoPB.table_name"); |
636 | 1 | } else { |
637 | 1 | goto handle_unusual; |
638 | 1 | } |
639 | 490k | break; |
640 | 490k | } |
641 | | |
642 | | // optional .yb.TableType table_type = 3 [default = DEFAULT_TABLE_TYPE]; |
643 | 490k | case 3: { |
644 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
645 | 490k | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
646 | 490k | int value; |
647 | 490k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
648 | 490k | int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>( |
649 | 490k | input, &value))); |
650 | 490k | if (::yb::TableType_IsValid(value)) { |
651 | 490k | set_table_type(static_cast< ::yb::TableType >(value)); |
652 | 8 | } else { |
653 | 8 | mutable_unknown_fields()->AddVarint( |
654 | 8 | 3, static_cast< ::google::protobuf::uint64>(value)); |
655 | 8 | } |
656 | 18.4E | } else { |
657 | 18.4E | goto handle_unusual; |
658 | 18.4E | } |
659 | 490k | break; |
660 | 490k | } |
661 | | |
662 | | // optional .yb.SchemaPB schema = 4; |
663 | 490k | case 4: { |
664 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
665 | 490k | static_cast< ::google::protobuf::uint8>(34u /* 34 & 0xFF */)) { |
666 | 490k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
667 | 490k | input, mutable_schema())); |
668 | 18.4E | } else { |
669 | 18.4E | goto handle_unusual; |
670 | 18.4E | } |
671 | 490k | break; |
672 | 490k | } |
673 | | |
674 | | // optional uint32 schema_version = 5; |
675 | 490k | case 5: { |
676 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
677 | 490k | static_cast< ::google::protobuf::uint8>(40u /* 40 & 0xFF */)) { |
678 | 490k | set_has_schema_version(); |
679 | 490k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
680 | 490k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
681 | 490k | input, &schema_version_))); |
682 | 1 | } else { |
683 | 1 | goto handle_unusual; |
684 | 1 | } |
685 | 490k | break; |
686 | 490k | } |
687 | | |
688 | | // optional .yb.PartitionSchemaPB partition_schema = 6; |
689 | 490k | case 6: { |
690 | 490k | if (static_cast< ::google::protobuf::uint8>(tag) == |
691 | 490k | static_cast< ::google::protobuf::uint8>(50u /* 50 & 0xFF */)) { |
692 | 490k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
693 | 490k | input, mutable_partition_schema())); |
694 | 18.4E | } else { |
695 | 18.4E | goto handle_unusual; |
696 | 18.4E | } |
697 | 490k | break; |
698 | 490k | } |
699 | | |
700 | | // repeated .yb.IndexInfoPB indexes = 7; |
701 | 431 | case 7: { |
702 | 431 | if (static_cast< ::google::protobuf::uint8>(tag) == |
703 | 431 | static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) { |
704 | 431 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_indexes())); |
705 | 0 | } else { |
706 | 0 | goto handle_unusual; |
707 | 0 | } |
708 | 431 | break; |
709 | 431 | } |
710 | | |
711 | | // optional .yb.IndexInfoPB index_info = 8; |
712 | 430 | case 8: { |
713 | 430 | if (static_cast< ::google::protobuf::uint8>(tag) == |
714 | 430 | static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) { |
715 | 430 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
716 | 430 | input, mutable_index_info())); |
717 | 0 | } else { |
718 | 0 | goto handle_unusual; |
719 | 0 | } |
720 | 430 | break; |
721 | 430 | } |
722 | | |
723 | | // repeated .yb.DeletedColumnPB deleted_cols = 9; |
724 | 657 | case 9: { |
725 | 657 | if (static_cast< ::google::protobuf::uint8>(tag) == |
726 | 657 | static_cast< ::google::protobuf::uint8>(74u /* 74 & 0xFF */)) { |
727 | 657 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_deleted_cols())); |
728 | 0 | } else { |
729 | 0 | goto handle_unusual; |
730 | 0 | } |
731 | 657 | break; |
732 | 657 | } |
733 | | |
734 | | // optional string namespace_name = 10; |
735 | 3.23k | case 10: { |
736 | 3.23k | if (static_cast< ::google::protobuf::uint8>(tag) == |
737 | 3.23k | static_cast< ::google::protobuf::uint8>(82u /* 82 & 0xFF */)) { |
738 | 3.23k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
739 | 3.23k | input, this->mutable_namespace_name())); |
740 | 3.23k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
741 | 3.23k | this->namespace_name().data(), static_cast<int>(this->namespace_name().length()), |
742 | 3.23k | ::google::protobuf::internal::WireFormat::PARSE, |
743 | 3.23k | "yb.tablet.TableInfoPB.namespace_name"); |
744 | 0 | } else { |
745 | 0 | goto handle_unusual; |
746 | 0 | } |
747 | 3.23k | break; |
748 | 490k | } |
749 | | |
750 | 0 | default: { |
751 | 490k | handle_unusual: |
752 | 490k | if (tag == 0) { |
753 | 490k | goto success; |
754 | 490k | } |
755 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
756 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
757 | 0 | break; |
758 | 0 | } |
759 | 2.94M | } |
760 | 2.94M | } |
761 | 490k | success: |
762 | | // @@protoc_insertion_point(parse_success:yb.tablet.TableInfoPB) |
763 | 490k | return true; |
764 | 0 | failure: |
765 | | // @@protoc_insertion_point(parse_failure:yb.tablet.TableInfoPB) |
766 | 0 | return false; |
767 | 490k | #undef DO_ |
768 | 490k | } |
769 | | |
770 | | void TableInfoPB::SerializeWithCachedSizes( |
771 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
772 | | // @@protoc_insertion_point(serialize_start:yb.tablet.TableInfoPB) |
773 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
774 | 0 | (void) cached_has_bits; |
775 | |
|
776 | 0 | cached_has_bits = _has_bits_[0]; |
777 | | // optional bytes table_id = 1; |
778 | 0 | if (cached_has_bits & 0x00000001u) { |
779 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
780 | 0 | 1, this->table_id(), output); |
781 | 0 | } |
782 | | |
783 | | // optional string table_name = 2; |
784 | 0 | if (cached_has_bits & 0x00000002u) { |
785 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
786 | 0 | this->table_name().data(), static_cast<int>(this->table_name().length()), |
787 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
788 | 0 | "yb.tablet.TableInfoPB.table_name"); |
789 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
790 | 0 | 2, this->table_name(), output); |
791 | 0 | } |
792 | | |
793 | | // optional .yb.TableType table_type = 3 [default = DEFAULT_TABLE_TYPE]; |
794 | 0 | if (cached_has_bits & 0x00000080u) { |
795 | 0 | ::google::protobuf::internal::WireFormatLite::WriteEnum( |
796 | 0 | 3, this->table_type(), output); |
797 | 0 | } |
798 | | |
799 | | // optional .yb.SchemaPB schema = 4; |
800 | 0 | if (cached_has_bits & 0x00000008u) { |
801 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
802 | 0 | 4, *this->schema_, output); |
803 | 0 | } |
804 | | |
805 | | // optional uint32 schema_version = 5; |
806 | 0 | if (cached_has_bits & 0x00000040u) { |
807 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(5, this->schema_version(), output); |
808 | 0 | } |
809 | | |
810 | | // optional .yb.PartitionSchemaPB partition_schema = 6; |
811 | 0 | if (cached_has_bits & 0x00000010u) { |
812 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
813 | 0 | 6, *this->partition_schema_, output); |
814 | 0 | } |
815 | | |
816 | | // repeated .yb.IndexInfoPB indexes = 7; |
817 | 0 | for (unsigned int i = 0, |
818 | 0 | n = static_cast<unsigned int>(this->indexes_size()); i < n; i++) { |
819 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
820 | 0 | 7, this->indexes(static_cast<int>(i)), output); |
821 | 0 | } |
822 | | |
823 | | // optional .yb.IndexInfoPB index_info = 8; |
824 | 0 | if (cached_has_bits & 0x00000020u) { |
825 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
826 | 0 | 8, *this->index_info_, output); |
827 | 0 | } |
828 | | |
829 | | // repeated .yb.DeletedColumnPB deleted_cols = 9; |
830 | 0 | for (unsigned int i = 0, |
831 | 0 | n = static_cast<unsigned int>(this->deleted_cols_size()); i < n; i++) { |
832 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
833 | 0 | 9, this->deleted_cols(static_cast<int>(i)), output); |
834 | 0 | } |
835 | | |
836 | | // optional string namespace_name = 10; |
837 | 0 | if (cached_has_bits & 0x00000004u) { |
838 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
839 | 0 | this->namespace_name().data(), static_cast<int>(this->namespace_name().length()), |
840 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
841 | 0 | "yb.tablet.TableInfoPB.namespace_name"); |
842 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
843 | 0 | 10, this->namespace_name(), output); |
844 | 0 | } |
845 | |
|
846 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
847 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
848 | 0 | _internal_metadata_.unknown_fields(), output); |
849 | 0 | } |
850 | | // @@protoc_insertion_point(serialize_end:yb.tablet.TableInfoPB) |
851 | 0 | } |
852 | | |
853 | | ::google::protobuf::uint8* TableInfoPB::InternalSerializeWithCachedSizesToArray( |
854 | 141M | bool deterministic, ::google::protobuf::uint8* target) const { |
855 | 141M | (void)deterministic; // Unused |
856 | | // @@protoc_insertion_point(serialize_to_array_start:yb.tablet.TableInfoPB) |
857 | 141M | ::google::protobuf::uint32 cached_has_bits = 0; |
858 | 141M | (void) cached_has_bits; |
859 | | |
860 | 141M | cached_has_bits = _has_bits_[0]; |
861 | | // optional bytes table_id = 1; |
862 | 141M | if (cached_has_bits & 0x00000001u) { |
863 | 141M | target = |
864 | 141M | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
865 | 141M | 1, this->table_id(), target); |
866 | 141M | } |
867 | | |
868 | | // optional string table_name = 2; |
869 | 141M | if (cached_has_bits & 0x00000002u) { |
870 | 141M | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
871 | 141M | this->table_name().data(), static_cast<int>(this->table_name().length()), |
872 | 141M | ::google::protobuf::internal::WireFormat::SERIALIZE, |
873 | 141M | "yb.tablet.TableInfoPB.table_name"); |
874 | 141M | target = |
875 | 141M | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
876 | 141M | 2, this->table_name(), target); |
877 | 141M | } |
878 | | |
879 | | // optional .yb.TableType table_type = 3 [default = DEFAULT_TABLE_TYPE]; |
880 | 141M | if (cached_has_bits & 0x00000080u) { |
881 | 141M | target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray( |
882 | 141M | 3, this->table_type(), target); |
883 | 141M | } |
884 | | |
885 | | // optional .yb.SchemaPB schema = 4; |
886 | 141M | if (cached_has_bits & 0x00000008u) { |
887 | 141M | target = ::google::protobuf::internal::WireFormatLite:: |
888 | 141M | InternalWriteMessageToArray( |
889 | 141M | 4, *this->schema_, deterministic, target); |
890 | 141M | } |
891 | | |
892 | | // optional uint32 schema_version = 5; |
893 | 141M | if (cached_has_bits & 0x00000040u) { |
894 | 141M | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(5, this->schema_version(), target); |
895 | 141M | } |
896 | | |
897 | | // optional .yb.PartitionSchemaPB partition_schema = 6; |
898 | 141M | if (cached_has_bits & 0x00000010u) { |
899 | 141M | target = ::google::protobuf::internal::WireFormatLite:: |
900 | 141M | InternalWriteMessageToArray( |
901 | 141M | 6, *this->partition_schema_, deterministic, target); |
902 | 141M | } |
903 | | |
904 | | // repeated .yb.IndexInfoPB indexes = 7; |
905 | 141M | for (unsigned int i = 0, |
906 | 141M | n = static_cast<unsigned int>(this->indexes_size()); i < n; i++) { |
907 | 69.9k | target = ::google::protobuf::internal::WireFormatLite:: |
908 | 69.9k | InternalWriteMessageToArray( |
909 | 69.9k | 7, this->indexes(static_cast<int>(i)), deterministic, target); |
910 | 69.9k | } |
911 | | |
912 | | // optional .yb.IndexInfoPB index_info = 8; |
913 | 141M | if (cached_has_bits & 0x00000020u) { |
914 | 44.5k | target = ::google::protobuf::internal::WireFormatLite:: |
915 | 44.5k | InternalWriteMessageToArray( |
916 | 44.5k | 8, *this->index_info_, deterministic, target); |
917 | 44.5k | } |
918 | | |
919 | | // repeated .yb.DeletedColumnPB deleted_cols = 9; |
920 | 141M | for (unsigned int i = 0, |
921 | 141M | n = static_cast<unsigned int>(this->deleted_cols_size()); i < n; i++) { |
922 | 12.4k | target = ::google::protobuf::internal::WireFormatLite:: |
923 | 12.4k | InternalWriteMessageToArray( |
924 | 12.4k | 9, this->deleted_cols(static_cast<int>(i)), deterministic, target); |
925 | 12.4k | } |
926 | | |
927 | | // optional string namespace_name = 10; |
928 | 141M | if (cached_has_bits & 0x00000004u) { |
929 | 140M | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
930 | 140M | this->namespace_name().data(), static_cast<int>(this->namespace_name().length()), |
931 | 140M | ::google::protobuf::internal::WireFormat::SERIALIZE, |
932 | 140M | "yb.tablet.TableInfoPB.namespace_name"); |
933 | 140M | target = |
934 | 140M | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
935 | 140M | 10, this->namespace_name(), target); |
936 | 140M | } |
937 | | |
938 | 141M | if (_internal_metadata_.have_unknown_fields()) { |
939 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
940 | 0 | _internal_metadata_.unknown_fields(), target); |
941 | 0 | } |
942 | | // @@protoc_insertion_point(serialize_to_array_end:yb.tablet.TableInfoPB) |
943 | 141M | return target; |
944 | 141M | } |
945 | | |
946 | 142M | size_t TableInfoPB::ByteSizeLong() const { |
947 | | // @@protoc_insertion_point(message_byte_size_start:yb.tablet.TableInfoPB) |
948 | 142M | size_t total_size = 0; |
949 | | |
950 | 142M | if (_internal_metadata_.have_unknown_fields()) { |
951 | 0 | total_size += |
952 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
953 | 0 | _internal_metadata_.unknown_fields()); |
954 | 0 | } |
955 | | // repeated .yb.IndexInfoPB indexes = 7; |
956 | 142M | { |
957 | 142M | unsigned int count = static_cast<unsigned int>(this->indexes_size()); |
958 | 142M | total_size += 1UL * count; |
959 | 142M | for (unsigned int i = 0; i < count; i++) { |
960 | 70.0k | total_size += |
961 | 70.0k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
962 | 70.0k | this->indexes(static_cast<int>(i))); |
963 | 70.0k | } |
964 | 142M | } |
965 | | |
966 | | // repeated .yb.DeletedColumnPB deleted_cols = 9; |
967 | 142M | { |
968 | 142M | unsigned int count = static_cast<unsigned int>(this->deleted_cols_size()); |
969 | 142M | total_size += 1UL * count; |
970 | 142M | for (unsigned int i = 0; i < count; i++) { |
971 | 12.5k | total_size += |
972 | 12.5k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
973 | 12.5k | this->deleted_cols(static_cast<int>(i))); |
974 | 12.5k | } |
975 | 142M | } |
976 | | |
977 | 142M | if (_has_bits_[0 / 32] & 255u) { |
978 | | // optional bytes table_id = 1; |
979 | 142M | if (has_table_id()) { |
980 | 142M | total_size += 1 + |
981 | 142M | ::google::protobuf::internal::WireFormatLite::BytesSize( |
982 | 142M | this->table_id()); |
983 | 142M | } |
984 | | |
985 | | // optional string table_name = 2; |
986 | 142M | if (has_table_name()) { |
987 | 142M | total_size += 1 + |
988 | 142M | ::google::protobuf::internal::WireFormatLite::StringSize( |
989 | 142M | this->table_name()); |
990 | 142M | } |
991 | | |
992 | | // optional string namespace_name = 10; |
993 | 142M | if (has_namespace_name()) { |
994 | 140M | total_size += 1 + |
995 | 140M | ::google::protobuf::internal::WireFormatLite::StringSize( |
996 | 140M | this->namespace_name()); |
997 | 140M | } |
998 | | |
999 | | // optional .yb.SchemaPB schema = 4; |
1000 | 142M | if (has_schema()) { |
1001 | 142M | total_size += 1 + |
1002 | 142M | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1003 | 142M | *this->schema_); |
1004 | 142M | } |
1005 | | |
1006 | | // optional .yb.PartitionSchemaPB partition_schema = 6; |
1007 | 142M | if (has_partition_schema()) { |
1008 | 142M | total_size += 1 + |
1009 | 142M | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1010 | 142M | *this->partition_schema_); |
1011 | 142M | } |
1012 | | |
1013 | | // optional .yb.IndexInfoPB index_info = 8; |
1014 | 142M | if (has_index_info()) { |
1015 | 44.7k | total_size += 1 + |
1016 | 44.7k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1017 | 44.7k | *this->index_info_); |
1018 | 44.7k | } |
1019 | | |
1020 | | // optional uint32 schema_version = 5; |
1021 | 142M | if (has_schema_version()) { |
1022 | 142M | total_size += 1 + |
1023 | 142M | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
1024 | 142M | this->schema_version()); |
1025 | 142M | } |
1026 | | |
1027 | | // optional .yb.TableType table_type = 3 [default = DEFAULT_TABLE_TYPE]; |
1028 | 142M | if (has_table_type()) { |
1029 | 142M | total_size += 1 + |
1030 | 142M | ::google::protobuf::internal::WireFormatLite::EnumSize(this->table_type()); |
1031 | 142M | } |
1032 | | |
1033 | 142M | } |
1034 | 142M | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1035 | 142M | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1036 | 142M | _cached_size_ = cached_size; |
1037 | 142M | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1038 | 142M | return total_size; |
1039 | 142M | } |
1040 | | |
1041 | 0 | void TableInfoPB::MergeFrom(const ::google::protobuf::Message& from) { |
1042 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.tablet.TableInfoPB) |
1043 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1044 | 0 | const TableInfoPB* source = |
1045 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const TableInfoPB>( |
1046 | 0 | &from); |
1047 | 0 | if (source == NULL) { |
1048 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.tablet.TableInfoPB) |
1049 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1050 | 0 | } else { |
1051 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.tablet.TableInfoPB) |
1052 | 0 | MergeFrom(*source); |
1053 | 0 | } |
1054 | 0 | } |
1055 | | |
1056 | 206k | void TableInfoPB::MergeFrom(const TableInfoPB& from) { |
1057 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.tablet.TableInfoPB) |
1058 | 206k | GOOGLE_DCHECK_NE(&from, this); |
1059 | 206k | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1060 | 206k | ::google::protobuf::uint32 cached_has_bits = 0; |
1061 | 206k | (void) cached_has_bits; |
1062 | | |
1063 | 206k | indexes_.MergeFrom(from.indexes_); |
1064 | 206k | deleted_cols_.MergeFrom(from.deleted_cols_); |
1065 | 206k | cached_has_bits = from._has_bits_[0]; |
1066 | 206k | if (cached_has_bits & 255u) { |
1067 | 206k | if (cached_has_bits & 0x00000001u) { |
1068 | 206k | set_has_table_id(); |
1069 | 206k | table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.table_id_); |
1070 | 206k | } |
1071 | 206k | if (cached_has_bits & 0x00000002u) { |
1072 | 206k | set_has_table_name(); |
1073 | 206k | table_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.table_name_); |
1074 | 206k | } |
1075 | 206k | if (cached_has_bits & 0x00000004u) { |
1076 | 2.45k | set_has_namespace_name(); |
1077 | 2.45k | namespace_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.namespace_name_); |
1078 | 2.45k | } |
1079 | 206k | if (cached_has_bits & 0x00000008u) { |
1080 | 206k | mutable_schema()->::yb::SchemaPB::MergeFrom(from.schema()); |
1081 | 206k | } |
1082 | 206k | if (cached_has_bits & 0x00000010u) { |
1083 | 206k | mutable_partition_schema()->::yb::PartitionSchemaPB::MergeFrom(from.partition_schema()); |
1084 | 206k | } |
1085 | 206k | if (cached_has_bits & 0x00000020u) { |
1086 | 215 | mutable_index_info()->::yb::IndexInfoPB::MergeFrom(from.index_info()); |
1087 | 215 | } |
1088 | 206k | if (cached_has_bits & 0x00000040u) { |
1089 | 206k | schema_version_ = from.schema_version_; |
1090 | 206k | } |
1091 | 206k | if (cached_has_bits & 0x00000080u) { |
1092 | 206k | table_type_ = from.table_type_; |
1093 | 206k | } |
1094 | 206k | _has_bits_[0] |= cached_has_bits; |
1095 | 206k | } |
1096 | 206k | } |
1097 | | |
1098 | 0 | void TableInfoPB::CopyFrom(const ::google::protobuf::Message& from) { |
1099 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.tablet.TableInfoPB) |
1100 | 0 | if (&from == this) return; |
1101 | 0 | Clear(); |
1102 | 0 | MergeFrom(from); |
1103 | 0 | } |
1104 | | |
1105 | 27 | void TableInfoPB::CopyFrom(const TableInfoPB& from) { |
1106 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.tablet.TableInfoPB) |
1107 | 27 | if (&from == this) return; |
1108 | 27 | Clear(); |
1109 | 27 | MergeFrom(from); |
1110 | 27 | } |
1111 | | |
1112 | 142M | bool TableInfoPB::IsInitialized() const { |
1113 | 142M | if (!::google::protobuf::internal::AllAreInitialized(this->indexes())) return false; |
1114 | 142M | if (has_schema()) { |
1115 | 142M | if (!this->schema_->IsInitialized()) return false; |
1116 | 142M | } |
1117 | 142M | if (has_partition_schema()) { |
1118 | 142M | if (!this->partition_schema_->IsInitialized()) return false; |
1119 | 142M | } |
1120 | 142M | if (has_index_info()) { |
1121 | 44.9k | if (!this->index_info_->IsInitialized()) return false; |
1122 | 142M | } |
1123 | 142M | return true; |
1124 | 142M | } |
1125 | | |
1126 | 0 | void TableInfoPB::Swap(TableInfoPB* other) { |
1127 | 0 | if (other == this) return; |
1128 | 0 | InternalSwap(other); |
1129 | 0 | } |
1130 | 0 | void TableInfoPB::InternalSwap(TableInfoPB* other) { |
1131 | 0 | using std::swap; |
1132 | 0 | indexes_.InternalSwap(&other->indexes_); |
1133 | 0 | deleted_cols_.InternalSwap(&other->deleted_cols_); |
1134 | 0 | table_id_.Swap(&other->table_id_); |
1135 | 0 | table_name_.Swap(&other->table_name_); |
1136 | 0 | namespace_name_.Swap(&other->namespace_name_); |
1137 | 0 | swap(schema_, other->schema_); |
1138 | 0 | swap(partition_schema_, other->partition_schema_); |
1139 | 0 | swap(index_info_, other->index_info_); |
1140 | 0 | swap(schema_version_, other->schema_version_); |
1141 | 0 | swap(table_type_, other->table_type_); |
1142 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1143 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1144 | 0 | swap(_cached_size_, other->_cached_size_); |
1145 | 0 | } |
1146 | | |
1147 | 1.26M | ::google::protobuf::Metadata TableInfoPB::GetMetadata() const { |
1148 | 1.26M | protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
1149 | 1.26M | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages]; |
1150 | 1.26M | } |
1151 | | |
1152 | | |
1153 | | // =================================================================== |
1154 | | |
1155 | 15.8k | void KvStoreInfoPB::InitAsDefaultInstance() { |
1156 | 15.8k | } |
1157 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1158 | | const int KvStoreInfoPB::kKvStoreIdFieldNumber; |
1159 | | const int KvStoreInfoPB::kRocksdbDirFieldNumber; |
1160 | | const int KvStoreInfoPB::kRocksdbFilesFieldNumber; |
1161 | | const int KvStoreInfoPB::kSnapshotFilesFieldNumber; |
1162 | | const int KvStoreInfoPB::kTablesFieldNumber; |
1163 | | const int KvStoreInfoPB::kLowerBoundKeyFieldNumber; |
1164 | | const int KvStoreInfoPB::kUpperBoundKeyFieldNumber; |
1165 | | const int KvStoreInfoPB::kHasBeenFullyCompactedFieldNumber; |
1166 | | const int KvStoreInfoPB::kSnapshotSchedulesFieldNumber; |
1167 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1168 | | |
1169 | | KvStoreInfoPB::KvStoreInfoPB() |
1170 | 841k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1171 | 824k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1172 | 824k | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsKvStoreInfoPB(); |
1173 | 824k | } |
1174 | 841k | SharedCtor(); |
1175 | | // @@protoc_insertion_point(constructor:yb.tablet.KvStoreInfoPB) |
1176 | 841k | } |
1177 | | KvStoreInfoPB::KvStoreInfoPB(const KvStoreInfoPB& from) |
1178 | | : ::google::protobuf::Message(), |
1179 | | _internal_metadata_(NULL), |
1180 | | _has_bits_(from._has_bits_), |
1181 | | _cached_size_(0), |
1182 | | rocksdb_files_(from.rocksdb_files_), |
1183 | | snapshot_files_(from.snapshot_files_), |
1184 | | tables_(from.tables_), |
1185 | 2 | snapshot_schedules_(from.snapshot_schedules_) { |
1186 | 2 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1187 | 2 | kv_store_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1188 | 2 | if (from.has_kv_store_id()) { |
1189 | 2 | kv_store_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.kv_store_id_); |
1190 | 2 | } |
1191 | 2 | rocksdb_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1192 | 2 | if (from.has_rocksdb_dir()) { |
1193 | 2 | rocksdb_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.rocksdb_dir_); |
1194 | 2 | } |
1195 | 2 | lower_bound_key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1196 | 2 | if (from.has_lower_bound_key()) { |
1197 | 0 | lower_bound_key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.lower_bound_key_); |
1198 | 0 | } |
1199 | 2 | upper_bound_key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1200 | 2 | if (from.has_upper_bound_key()) { |
1201 | 0 | upper_bound_key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.upper_bound_key_); |
1202 | 0 | } |
1203 | 2 | has_been_fully_compacted_ = from.has_been_fully_compacted_; |
1204 | | // @@protoc_insertion_point(copy_constructor:yb.tablet.KvStoreInfoPB) |
1205 | 2 | } |
1206 | | |
1207 | 840k | void KvStoreInfoPB::SharedCtor() { |
1208 | 840k | _cached_size_ = 0; |
1209 | 840k | kv_store_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1210 | 840k | rocksdb_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1211 | 840k | lower_bound_key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1212 | 840k | upper_bound_key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1213 | 840k | has_been_fully_compacted_ = false; |
1214 | 840k | } |
1215 | | |
1216 | 824k | KvStoreInfoPB::~KvStoreInfoPB() { |
1217 | | // @@protoc_insertion_point(destructor:yb.tablet.KvStoreInfoPB) |
1218 | 824k | SharedDtor(); |
1219 | 824k | } |
1220 | | |
1221 | 824k | void KvStoreInfoPB::SharedDtor() { |
1222 | 824k | kv_store_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1223 | 824k | rocksdb_dir_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1224 | 824k | lower_bound_key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1225 | 824k | upper_bound_key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1226 | 824k | } |
1227 | | |
1228 | 0 | void KvStoreInfoPB::SetCachedSize(int size) const { |
1229 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1230 | 0 | _cached_size_ = size; |
1231 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1232 | 0 | } |
1233 | 0 | const ::google::protobuf::Descriptor* KvStoreInfoPB::descriptor() { |
1234 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
1235 | 0 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1236 | 0 | } |
1237 | | |
1238 | 0 | const KvStoreInfoPB& KvStoreInfoPB::default_instance() { |
1239 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsKvStoreInfoPB(); |
1240 | 0 | return *internal_default_instance(); |
1241 | 0 | } |
1242 | | |
1243 | 0 | KvStoreInfoPB* KvStoreInfoPB::New(::google::protobuf::Arena* arena) const { |
1244 | 0 | KvStoreInfoPB* n = new KvStoreInfoPB; |
1245 | 0 | if (arena != NULL) { |
1246 | 0 | arena->Own(n); |
1247 | 0 | } |
1248 | 0 | return n; |
1249 | 0 | } |
1250 | | |
1251 | 0 | void KvStoreInfoPB::Clear() { |
1252 | | // @@protoc_insertion_point(message_clear_start:yb.tablet.KvStoreInfoPB) |
1253 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1254 | | // Prevent compiler warnings about cached_has_bits being unused |
1255 | 0 | (void) cached_has_bits; |
1256 | |
|
1257 | 0 | rocksdb_files_.Clear(); |
1258 | 0 | snapshot_files_.Clear(); |
1259 | 0 | tables_.Clear(); |
1260 | 0 | snapshot_schedules_.Clear(); |
1261 | 0 | cached_has_bits = _has_bits_[0]; |
1262 | 0 | if (cached_has_bits & 15u) { |
1263 | 0 | if (cached_has_bits & 0x00000001u) { |
1264 | 0 | GOOGLE_DCHECK(!kv_store_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1265 | 0 | (*kv_store_id_.UnsafeRawStringPointer())->clear(); |
1266 | 0 | } |
1267 | 0 | if (cached_has_bits & 0x00000002u) { |
1268 | 0 | GOOGLE_DCHECK(!rocksdb_dir_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1269 | 0 | (*rocksdb_dir_.UnsafeRawStringPointer())->clear(); |
1270 | 0 | } |
1271 | 0 | if (cached_has_bits & 0x00000004u) { |
1272 | 0 | GOOGLE_DCHECK(!lower_bound_key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1273 | 0 | (*lower_bound_key_.UnsafeRawStringPointer())->clear(); |
1274 | 0 | } |
1275 | 0 | if (cached_has_bits & 0x00000008u) { |
1276 | 0 | GOOGLE_DCHECK(!upper_bound_key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1277 | 0 | (*upper_bound_key_.UnsafeRawStringPointer())->clear(); |
1278 | 0 | } |
1279 | 0 | } |
1280 | 0 | has_been_fully_compacted_ = false; |
1281 | 0 | _has_bits_.Clear(); |
1282 | 0 | _internal_metadata_.Clear(); |
1283 | 0 | } |
1284 | | |
1285 | | bool KvStoreInfoPB::MergePartialFromCodedStream( |
1286 | 3.22k | ::google::protobuf::io::CodedInputStream* input) { |
1287 | 17.4k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
1288 | 3.22k | ::google::protobuf::uint32 tag; |
1289 | | // @@protoc_insertion_point(parse_start:yb.tablet.KvStoreInfoPB) |
1290 | 20.6k | for (;;) { |
1291 | 20.6k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1292 | 20.6k | tag = p.first; |
1293 | 20.6k | if (!p.second) goto handle_unusual; |
1294 | 17.4k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
1295 | | // required bytes kv_store_id = 1; |
1296 | 3.22k | case 1: { |
1297 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1298 | 3.22k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
1299 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
1300 | 3.22k | input, this->mutable_kv_store_id())); |
1301 | 18.4E | } else { |
1302 | 18.4E | goto handle_unusual; |
1303 | 18.4E | } |
1304 | 3.22k | break; |
1305 | 3.22k | } |
1306 | | |
1307 | | // optional string rocksdb_dir = 2; |
1308 | 3.22k | case 2: { |
1309 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1310 | 3.22k | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
1311 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
1312 | 3.22k | input, this->mutable_rocksdb_dir())); |
1313 | 3.22k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1314 | 3.22k | this->rocksdb_dir().data(), static_cast<int>(this->rocksdb_dir().length()), |
1315 | 3.22k | ::google::protobuf::internal::WireFormat::PARSE, |
1316 | 3.22k | "yb.tablet.KvStoreInfoPB.rocksdb_dir"); |
1317 | 0 | } else { |
1318 | 0 | goto handle_unusual; |
1319 | 0 | } |
1320 | 3.22k | break; |
1321 | 3.22k | } |
1322 | | |
1323 | | // repeated .yb.tablet.FilePB rocksdb_files = 3; |
1324 | 4.42k | case 3: { |
1325 | 4.42k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1326 | 4.42k | static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) { |
1327 | 4.42k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_rocksdb_files())); |
1328 | 0 | } else { |
1329 | 0 | goto handle_unusual; |
1330 | 0 | } |
1331 | 4.42k | break; |
1332 | 4.42k | } |
1333 | | |
1334 | | // repeated .yb.tablet.SnapshotFilePB snapshot_files = 4; |
1335 | 60 | case 4: { |
1336 | 60 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1337 | 60 | static_cast< ::google::protobuf::uint8>(34u /* 34 & 0xFF */)) { |
1338 | 60 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_snapshot_files())); |
1339 | 0 | } else { |
1340 | 0 | goto handle_unusual; |
1341 | 0 | } |
1342 | 60 | break; |
1343 | 60 | } |
1344 | | |
1345 | | // repeated .yb.tablet.TableInfoPB tables = 5; |
1346 | 3.23k | case 5: { |
1347 | 3.23k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1348 | 3.23k | static_cast< ::google::protobuf::uint8>(42u /* 42 & 0xFF */)) { |
1349 | 3.23k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_tables())); |
1350 | 18.4E | } else { |
1351 | 18.4E | goto handle_unusual; |
1352 | 18.4E | } |
1353 | 3.23k | break; |
1354 | 3.23k | } |
1355 | | |
1356 | | // optional bytes lower_bound_key = 6; |
1357 | 14 | case 6: { |
1358 | 14 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1359 | 14 | static_cast< ::google::protobuf::uint8>(50u /* 50 & 0xFF */)) { |
1360 | 14 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
1361 | 14 | input, this->mutable_lower_bound_key())); |
1362 | 0 | } else { |
1363 | 0 | goto handle_unusual; |
1364 | 0 | } |
1365 | 14 | break; |
1366 | 14 | } |
1367 | | |
1368 | | // optional bytes upper_bound_key = 7; |
1369 | 15 | case 7: { |
1370 | 15 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1371 | 15 | static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) { |
1372 | 15 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
1373 | 15 | input, this->mutable_upper_bound_key())); |
1374 | 0 | } else { |
1375 | 0 | goto handle_unusual; |
1376 | 0 | } |
1377 | 15 | break; |
1378 | 15 | } |
1379 | | |
1380 | | // optional bool has_been_fully_compacted = 8; |
1381 | 3.22k | case 8: { |
1382 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1383 | 3.22k | static_cast< ::google::protobuf::uint8>(64u /* 64 & 0xFF */)) { |
1384 | 3.22k | set_has_has_been_fully_compacted(); |
1385 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1386 | 3.22k | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
1387 | 3.22k | input, &has_been_fully_compacted_))); |
1388 | 0 | } else { |
1389 | 0 | goto handle_unusual; |
1390 | 0 | } |
1391 | 3.22k | break; |
1392 | 3.22k | } |
1393 | | |
1394 | | // repeated bytes snapshot_schedules = 9; |
1395 | 0 | case 9: { |
1396 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1397 | 0 | static_cast< ::google::protobuf::uint8>(74u /* 74 & 0xFF */)) { |
1398 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
1399 | 0 | input, this->add_snapshot_schedules())); |
1400 | 0 | } else { |
1401 | 0 | goto handle_unusual; |
1402 | 0 | } |
1403 | 0 | break; |
1404 | 3.21k | } |
1405 | | |
1406 | 0 | default: { |
1407 | 3.21k | handle_unusual: |
1408 | 3.21k | if (tag == 0) { |
1409 | 3.21k | goto success; |
1410 | 3.21k | } |
1411 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1412 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1413 | 18.4E | break; |
1414 | 18.4E | } |
1415 | 17.4k | } |
1416 | 17.4k | } |
1417 | 3.21k | success: |
1418 | | // @@protoc_insertion_point(parse_success:yb.tablet.KvStoreInfoPB) |
1419 | 3.21k | return true; |
1420 | 0 | failure: |
1421 | | // @@protoc_insertion_point(parse_failure:yb.tablet.KvStoreInfoPB) |
1422 | 0 | return false; |
1423 | 3.22k | #undef DO_ |
1424 | 3.22k | } |
1425 | | |
1426 | | void KvStoreInfoPB::SerializeWithCachedSizes( |
1427 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1428 | | // @@protoc_insertion_point(serialize_start:yb.tablet.KvStoreInfoPB) |
1429 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1430 | 0 | (void) cached_has_bits; |
1431 | |
|
1432 | 0 | cached_has_bits = _has_bits_[0]; |
1433 | | // required bytes kv_store_id = 1; |
1434 | 0 | if (cached_has_bits & 0x00000001u) { |
1435 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
1436 | 0 | 1, this->kv_store_id(), output); |
1437 | 0 | } |
1438 | | |
1439 | | // optional string rocksdb_dir = 2; |
1440 | 0 | if (cached_has_bits & 0x00000002u) { |
1441 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1442 | 0 | this->rocksdb_dir().data(), static_cast<int>(this->rocksdb_dir().length()), |
1443 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
1444 | 0 | "yb.tablet.KvStoreInfoPB.rocksdb_dir"); |
1445 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
1446 | 0 | 2, this->rocksdb_dir(), output); |
1447 | 0 | } |
1448 | | |
1449 | | // repeated .yb.tablet.FilePB rocksdb_files = 3; |
1450 | 0 | for (unsigned int i = 0, |
1451 | 0 | n = static_cast<unsigned int>(this->rocksdb_files_size()); i < n; i++) { |
1452 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1453 | 0 | 3, this->rocksdb_files(static_cast<int>(i)), output); |
1454 | 0 | } |
1455 | | |
1456 | | // repeated .yb.tablet.SnapshotFilePB snapshot_files = 4; |
1457 | 0 | for (unsigned int i = 0, |
1458 | 0 | n = static_cast<unsigned int>(this->snapshot_files_size()); i < n; i++) { |
1459 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1460 | 0 | 4, this->snapshot_files(static_cast<int>(i)), output); |
1461 | 0 | } |
1462 | | |
1463 | | // repeated .yb.tablet.TableInfoPB tables = 5; |
1464 | 0 | for (unsigned int i = 0, |
1465 | 0 | n = static_cast<unsigned int>(this->tables_size()); i < n; i++) { |
1466 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1467 | 0 | 5, this->tables(static_cast<int>(i)), output); |
1468 | 0 | } |
1469 | | |
1470 | | // optional bytes lower_bound_key = 6; |
1471 | 0 | if (cached_has_bits & 0x00000004u) { |
1472 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
1473 | 0 | 6, this->lower_bound_key(), output); |
1474 | 0 | } |
1475 | | |
1476 | | // optional bytes upper_bound_key = 7; |
1477 | 0 | if (cached_has_bits & 0x00000008u) { |
1478 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
1479 | 0 | 7, this->upper_bound_key(), output); |
1480 | 0 | } |
1481 | | |
1482 | | // optional bool has_been_fully_compacted = 8; |
1483 | 0 | if (cached_has_bits & 0x00000010u) { |
1484 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(8, this->has_been_fully_compacted(), output); |
1485 | 0 | } |
1486 | | |
1487 | | // repeated bytes snapshot_schedules = 9; |
1488 | 0 | for (int i = 0, n = this->snapshot_schedules_size(); i < n; i++) { |
1489 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytes( |
1490 | 0 | 9, this->snapshot_schedules(i), output); |
1491 | 0 | } |
1492 | |
|
1493 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1494 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1495 | 0 | _internal_metadata_.unknown_fields(), output); |
1496 | 0 | } |
1497 | | // @@protoc_insertion_point(serialize_end:yb.tablet.KvStoreInfoPB) |
1498 | 0 | } |
1499 | | |
1500 | | ::google::protobuf::uint8* KvStoreInfoPB::InternalSerializeWithCachedSizesToArray( |
1501 | 820k | bool deterministic, ::google::protobuf::uint8* target) const { |
1502 | 820k | (void)deterministic; // Unused |
1503 | | // @@protoc_insertion_point(serialize_to_array_start:yb.tablet.KvStoreInfoPB) |
1504 | 820k | ::google::protobuf::uint32 cached_has_bits = 0; |
1505 | 820k | (void) cached_has_bits; |
1506 | | |
1507 | 820k | cached_has_bits = _has_bits_[0]; |
1508 | | // required bytes kv_store_id = 1; |
1509 | 820k | if (cached_has_bits & 0x00000001u) { |
1510 | 820k | target = |
1511 | 820k | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
1512 | 820k | 1, this->kv_store_id(), target); |
1513 | 820k | } |
1514 | | |
1515 | | // optional string rocksdb_dir = 2; |
1516 | 820k | if (cached_has_bits & 0x00000002u) { |
1517 | 820k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
1518 | 820k | this->rocksdb_dir().data(), static_cast<int>(this->rocksdb_dir().length()), |
1519 | 820k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
1520 | 820k | "yb.tablet.KvStoreInfoPB.rocksdb_dir"); |
1521 | 820k | target = |
1522 | 820k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
1523 | 820k | 2, this->rocksdb_dir(), target); |
1524 | 820k | } |
1525 | | |
1526 | | // repeated .yb.tablet.FilePB rocksdb_files = 3; |
1527 | 820k | for (unsigned int i = 0, |
1528 | 829k | n = static_cast<unsigned int>(this->rocksdb_files_size()); i < n; i++) { |
1529 | 8.41k | target = ::google::protobuf::internal::WireFormatLite:: |
1530 | 8.41k | InternalWriteMessageToArray( |
1531 | 8.41k | 3, this->rocksdb_files(static_cast<int>(i)), deterministic, target); |
1532 | 8.41k | } |
1533 | | |
1534 | | // repeated .yb.tablet.SnapshotFilePB snapshot_files = 4; |
1535 | 820k | for (unsigned int i = 0, |
1536 | 820k | n = static_cast<unsigned int>(this->snapshot_files_size()); i < n; i++) { |
1537 | 60 | target = ::google::protobuf::internal::WireFormatLite:: |
1538 | 60 | InternalWriteMessageToArray( |
1539 | 60 | 4, this->snapshot_files(static_cast<int>(i)), deterministic, target); |
1540 | 60 | } |
1541 | | |
1542 | | // repeated .yb.tablet.TableInfoPB tables = 5; |
1543 | 820k | for (unsigned int i = 0, |
1544 | 141M | n = static_cast<unsigned int>(this->tables_size()); i < n; i++) { |
1545 | 140M | target = ::google::protobuf::internal::WireFormatLite:: |
1546 | 140M | InternalWriteMessageToArray( |
1547 | 140M | 5, this->tables(static_cast<int>(i)), deterministic, target); |
1548 | 140M | } |
1549 | | |
1550 | | // optional bytes lower_bound_key = 6; |
1551 | 820k | if (cached_has_bits & 0x00000004u) { |
1552 | 194 | target = |
1553 | 194 | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
1554 | 194 | 6, this->lower_bound_key(), target); |
1555 | 194 | } |
1556 | | |
1557 | | // optional bytes upper_bound_key = 7; |
1558 | 820k | if (cached_has_bits & 0x00000008u) { |
1559 | 277 | target = |
1560 | 277 | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
1561 | 277 | 7, this->upper_bound_key(), target); |
1562 | 277 | } |
1563 | | |
1564 | | // optional bool has_been_fully_compacted = 8; |
1565 | 821k | if (cached_has_bits & 0x00000010u) { |
1566 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(8, this->has_been_fully_compacted(), target); |
1567 | 821k | } |
1568 | | |
1569 | | // repeated bytes snapshot_schedules = 9; |
1570 | 820k | for (int i = 0, n = this->snapshot_schedules_size(); i < n; i++) { |
1571 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
1572 | 0 | WriteBytesToArray(9, this->snapshot_schedules(i), target); |
1573 | 0 | } |
1574 | | |
1575 | 820k | if (_internal_metadata_.have_unknown_fields()) { |
1576 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1577 | 0 | _internal_metadata_.unknown_fields(), target); |
1578 | 0 | } |
1579 | | // @@protoc_insertion_point(serialize_to_array_end:yb.tablet.KvStoreInfoPB) |
1580 | 820k | return target; |
1581 | 820k | } |
1582 | | |
1583 | 823k | size_t KvStoreInfoPB::ByteSizeLong() const { |
1584 | | // @@protoc_insertion_point(message_byte_size_start:yb.tablet.KvStoreInfoPB) |
1585 | 823k | size_t total_size = 0; |
1586 | | |
1587 | 823k | if (_internal_metadata_.have_unknown_fields()) { |
1588 | 0 | total_size += |
1589 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1590 | 0 | _internal_metadata_.unknown_fields()); |
1591 | 0 | } |
1592 | | // required bytes kv_store_id = 1; |
1593 | 823k | if (has_kv_store_id()) { |
1594 | 822k | total_size += 1 + |
1595 | 822k | ::google::protobuf::internal::WireFormatLite::BytesSize( |
1596 | 822k | this->kv_store_id()); |
1597 | 822k | } |
1598 | | // repeated .yb.tablet.FilePB rocksdb_files = 3; |
1599 | 823k | { |
1600 | 823k | unsigned int count = static_cast<unsigned int>(this->rocksdb_files_size()); |
1601 | 823k | total_size += 1UL * count; |
1602 | 836k | for (unsigned int i = 0; i < count; i++) { |
1603 | 12.8k | total_size += |
1604 | 12.8k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1605 | 12.8k | this->rocksdb_files(static_cast<int>(i))); |
1606 | 12.8k | } |
1607 | 823k | } |
1608 | | |
1609 | | // repeated .yb.tablet.SnapshotFilePB snapshot_files = 4; |
1610 | 823k | { |
1611 | 823k | unsigned int count = static_cast<unsigned int>(this->snapshot_files_size()); |
1612 | 823k | total_size += 1UL * count; |
1613 | 823k | for (unsigned int i = 0; i < count; i++) { |
1614 | 120 | total_size += |
1615 | 120 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1616 | 120 | this->snapshot_files(static_cast<int>(i))); |
1617 | 120 | } |
1618 | 823k | } |
1619 | | |
1620 | | // repeated .yb.tablet.TableInfoPB tables = 5; |
1621 | 823k | { |
1622 | 823k | unsigned int count = static_cast<unsigned int>(this->tables_size()); |
1623 | 823k | total_size += 1UL * count; |
1624 | 141M | for (unsigned int i = 0; i < count; i++) { |
1625 | 140M | total_size += |
1626 | 140M | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1627 | 140M | this->tables(static_cast<int>(i))); |
1628 | 140M | } |
1629 | 823k | } |
1630 | | |
1631 | | // repeated bytes snapshot_schedules = 9; |
1632 | 823k | total_size += 1 * |
1633 | 823k | ::google::protobuf::internal::FromIntSize(this->snapshot_schedules_size()); |
1634 | 823k | for (int i = 0, n = this->snapshot_schedules_size(); i < n; i++) { |
1635 | 0 | total_size += ::google::protobuf::internal::WireFormatLite::BytesSize( |
1636 | 0 | this->snapshot_schedules(i)); |
1637 | 0 | } |
1638 | | |
1639 | 823k | if (_has_bits_[0 / 32] & 30u) { |
1640 | | // optional string rocksdb_dir = 2; |
1641 | 823k | if (has_rocksdb_dir()) { |
1642 | 823k | total_size += 1 + |
1643 | 823k | ::google::protobuf::internal::WireFormatLite::StringSize( |
1644 | 823k | this->rocksdb_dir()); |
1645 | 823k | } |
1646 | | |
1647 | | // optional bytes lower_bound_key = 6; |
1648 | 823k | if (has_lower_bound_key()) { |
1649 | 197 | total_size += 1 + |
1650 | 197 | ::google::protobuf::internal::WireFormatLite::BytesSize( |
1651 | 197 | this->lower_bound_key()); |
1652 | 197 | } |
1653 | | |
1654 | | // optional bytes upper_bound_key = 7; |
1655 | 823k | if (has_upper_bound_key()) { |
1656 | 280 | total_size += 1 + |
1657 | 280 | ::google::protobuf::internal::WireFormatLite::BytesSize( |
1658 | 280 | this->upper_bound_key()); |
1659 | 280 | } |
1660 | | |
1661 | | // optional bool has_been_fully_compacted = 8; |
1662 | 823k | if (has_has_been_fully_compacted()) { |
1663 | 822k | total_size += 1 + 1; |
1664 | 822k | } |
1665 | | |
1666 | 823k | } |
1667 | 823k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1668 | 823k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1669 | 823k | _cached_size_ = cached_size; |
1670 | 823k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1671 | 823k | return total_size; |
1672 | 823k | } |
1673 | | |
1674 | 0 | void KvStoreInfoPB::MergeFrom(const ::google::protobuf::Message& from) { |
1675 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.tablet.KvStoreInfoPB) |
1676 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1677 | 0 | const KvStoreInfoPB* source = |
1678 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const KvStoreInfoPB>( |
1679 | 0 | &from); |
1680 | 0 | if (source == NULL) { |
1681 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.tablet.KvStoreInfoPB) |
1682 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1683 | 0 | } else { |
1684 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.tablet.KvStoreInfoPB) |
1685 | 0 | MergeFrom(*source); |
1686 | 0 | } |
1687 | 0 | } |
1688 | | |
1689 | 2.44k | void KvStoreInfoPB::MergeFrom(const KvStoreInfoPB& from) { |
1690 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.tablet.KvStoreInfoPB) |
1691 | 2.44k | GOOGLE_DCHECK_NE(&from, this); |
1692 | 2.44k | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1693 | 2.44k | ::google::protobuf::uint32 cached_has_bits = 0; |
1694 | 2.44k | (void) cached_has_bits; |
1695 | | |
1696 | 2.44k | rocksdb_files_.MergeFrom(from.rocksdb_files_); |
1697 | 2.44k | snapshot_files_.MergeFrom(from.snapshot_files_); |
1698 | 2.44k | tables_.MergeFrom(from.tables_); |
1699 | 2.44k | snapshot_schedules_.MergeFrom(from.snapshot_schedules_); |
1700 | 2.44k | cached_has_bits = from._has_bits_[0]; |
1701 | 2.44k | if (cached_has_bits & 31u) { |
1702 | 2.44k | if (cached_has_bits & 0x00000001u) { |
1703 | 2.44k | set_has_kv_store_id(); |
1704 | 2.44k | kv_store_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.kv_store_id_); |
1705 | 2.44k | } |
1706 | 2.44k | if (cached_has_bits & 0x00000002u) { |
1707 | 2.44k | set_has_rocksdb_dir(); |
1708 | 2.44k | rocksdb_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.rocksdb_dir_); |
1709 | 2.44k | } |
1710 | 2.44k | if (cached_has_bits & 0x00000004u) { |
1711 | 5 | set_has_lower_bound_key(); |
1712 | 5 | lower_bound_key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.lower_bound_key_); |
1713 | 5 | } |
1714 | 2.44k | if (cached_has_bits & 0x00000008u) { |
1715 | 5 | set_has_upper_bound_key(); |
1716 | 5 | upper_bound_key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.upper_bound_key_); |
1717 | 5 | } |
1718 | 2.44k | if (cached_has_bits & 0x00000010u) { |
1719 | 2.44k | has_been_fully_compacted_ = from.has_been_fully_compacted_; |
1720 | 2.44k | } |
1721 | 2.44k | _has_bits_[0] |= cached_has_bits; |
1722 | 2.44k | } |
1723 | 2.44k | } |
1724 | | |
1725 | 0 | void KvStoreInfoPB::CopyFrom(const ::google::protobuf::Message& from) { |
1726 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.tablet.KvStoreInfoPB) |
1727 | 0 | if (&from == this) return; |
1728 | 0 | Clear(); |
1729 | 0 | MergeFrom(from); |
1730 | 0 | } |
1731 | | |
1732 | 0 | void KvStoreInfoPB::CopyFrom(const KvStoreInfoPB& from) { |
1733 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.tablet.KvStoreInfoPB) |
1734 | 0 | if (&from == this) return; |
1735 | 0 | Clear(); |
1736 | 0 | MergeFrom(from); |
1737 | 0 | } |
1738 | | |
1739 | 825k | bool KvStoreInfoPB::IsInitialized() const { |
1740 | 825k | if ((_has_bits_[0] & 0x00000001) != 0x00000001) return false; |
1741 | 825k | if (!::google::protobuf::internal::AllAreInitialized(this->tables())) return false; |
1742 | 825k | return true; |
1743 | 825k | } |
1744 | | |
1745 | 0 | void KvStoreInfoPB::Swap(KvStoreInfoPB* other) { |
1746 | 0 | if (other == this) return; |
1747 | 0 | InternalSwap(other); |
1748 | 0 | } |
1749 | 0 | void KvStoreInfoPB::InternalSwap(KvStoreInfoPB* other) { |
1750 | 0 | using std::swap; |
1751 | 0 | rocksdb_files_.InternalSwap(&other->rocksdb_files_); |
1752 | 0 | snapshot_files_.InternalSwap(&other->snapshot_files_); |
1753 | 0 | tables_.InternalSwap(&other->tables_); |
1754 | 0 | snapshot_schedules_.InternalSwap(&other->snapshot_schedules_); |
1755 | 0 | kv_store_id_.Swap(&other->kv_store_id_); |
1756 | 0 | rocksdb_dir_.Swap(&other->rocksdb_dir_); |
1757 | 0 | lower_bound_key_.Swap(&other->lower_bound_key_); |
1758 | 0 | upper_bound_key_.Swap(&other->upper_bound_key_); |
1759 | 0 | swap(has_been_fully_compacted_, other->has_been_fully_compacted_); |
1760 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1761 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1762 | 0 | swap(_cached_size_, other->_cached_size_); |
1763 | 0 | } |
1764 | | |
1765 | 2.87k | ::google::protobuf::Metadata KvStoreInfoPB::GetMetadata() const { |
1766 | 2.87k | protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
1767 | 2.87k | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages]; |
1768 | 2.87k | } |
1769 | | |
1770 | | |
1771 | | // =================================================================== |
1772 | | |
1773 | 15.8k | void RaftGroupReplicaSuperBlockPB::InitAsDefaultInstance() { |
1774 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->partition_ = const_cast< ::yb::PartitionPB*>( |
1775 | 15.8k | ::yb::PartitionPB::internal_default_instance()); |
1776 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->obsolete_schema_ = const_cast< ::yb::SchemaPB*>( |
1777 | 15.8k | ::yb::SchemaPB::internal_default_instance()); |
1778 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->obsolete_partition_schema_ = const_cast< ::yb::PartitionSchemaPB*>( |
1779 | 15.8k | ::yb::PartitionSchemaPB::internal_default_instance()); |
1780 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->tombstone_last_logged_opid_ = const_cast< ::yb::OpIdPB*>( |
1781 | 15.8k | ::yb::OpIdPB::internal_default_instance()); |
1782 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->kv_store_ = const_cast< ::yb::tablet::KvStoreInfoPB*>( |
1783 | 15.8k | ::yb::tablet::KvStoreInfoPB::internal_default_instance()); |
1784 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->obsolete_index_info_ = const_cast< ::yb::IndexInfoPB*>( |
1785 | 15.8k | ::yb::IndexInfoPB::internal_default_instance()); |
1786 | 15.8k | ::yb::tablet::_RaftGroupReplicaSuperBlockPB_default_instance_._instance.get_mutable()->split_op_id_ = const_cast< ::yb::OpIdPB*>( |
1787 | 15.8k | ::yb::OpIdPB::internal_default_instance()); |
1788 | 15.8k | } |
1789 | 0 | void RaftGroupReplicaSuperBlockPB::clear_partition() { |
1790 | 0 | if (partition_ != NULL) partition_->Clear(); |
1791 | 0 | clear_has_partition(); |
1792 | 0 | } |
1793 | 0 | void RaftGroupReplicaSuperBlockPB::clear_obsolete_schema() { |
1794 | 0 | if (obsolete_schema_ != NULL) obsolete_schema_->Clear(); |
1795 | 0 | clear_has_obsolete_schema(); |
1796 | 0 | } |
1797 | 0 | void RaftGroupReplicaSuperBlockPB::clear_obsolete_partition_schema() { |
1798 | 0 | if (obsolete_partition_schema_ != NULL) obsolete_partition_schema_->Clear(); |
1799 | 0 | clear_has_obsolete_partition_schema(); |
1800 | 0 | } |
1801 | 0 | void RaftGroupReplicaSuperBlockPB::clear_tombstone_last_logged_opid() { |
1802 | 0 | if (tombstone_last_logged_opid_ != NULL) tombstone_last_logged_opid_->Clear(); |
1803 | 0 | clear_has_tombstone_last_logged_opid(); |
1804 | 0 | } |
1805 | 0 | void RaftGroupReplicaSuperBlockPB::clear_obsolete_deleted_cols() { |
1806 | 0 | obsolete_deleted_cols_.Clear(); |
1807 | 0 | } |
1808 | 0 | void RaftGroupReplicaSuperBlockPB::clear_obsolete_indexes() { |
1809 | 0 | obsolete_indexes_.Clear(); |
1810 | 0 | } |
1811 | 0 | void RaftGroupReplicaSuperBlockPB::clear_obsolete_index_info() { |
1812 | 0 | if (obsolete_index_info_ != NULL) obsolete_index_info_->Clear(); |
1813 | 0 | clear_has_obsolete_index_info(); |
1814 | 0 | } |
1815 | 0 | void RaftGroupReplicaSuperBlockPB::clear_split_op_id() { |
1816 | 0 | if (split_op_id_ != NULL) split_op_id_->Clear(); |
1817 | 0 | clear_has_split_op_id(); |
1818 | 0 | } |
1819 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1820 | | const int RaftGroupReplicaSuperBlockPB::kPrimaryTableIdFieldNumber; |
1821 | | const int RaftGroupReplicaSuperBlockPB::kRaftGroupIdFieldNumber; |
1822 | | const int RaftGroupReplicaSuperBlockPB::kPartitionFieldNumber; |
1823 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETETableNameFieldNumber; |
1824 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETETableTypeFieldNumber; |
1825 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETESchemaFieldNumber; |
1826 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETESchemaVersionFieldNumber; |
1827 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETEPartitionSchemaFieldNumber; |
1828 | | const int RaftGroupReplicaSuperBlockPB::kTabletDataStateFieldNumber; |
1829 | | const int RaftGroupReplicaSuperBlockPB::kWalDirFieldNumber; |
1830 | | const int RaftGroupReplicaSuperBlockPB::kTombstoneLastLoggedOpidFieldNumber; |
1831 | | const int RaftGroupReplicaSuperBlockPB::kKvStoreFieldNumber; |
1832 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETERocksdbDirFieldNumber; |
1833 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETERocksdbFilesFieldNumber; |
1834 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETESnapshotFilesFieldNumber; |
1835 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETEDeletedColsFieldNumber; |
1836 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETEIndexesFieldNumber; |
1837 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETEIndexInfoFieldNumber; |
1838 | | const int RaftGroupReplicaSuperBlockPB::kOBSOLETETablesFieldNumber; |
1839 | | const int RaftGroupReplicaSuperBlockPB::kColocatedFieldNumber; |
1840 | | const int RaftGroupReplicaSuperBlockPB::kCdcMinReplicatedIndexFieldNumber; |
1841 | | const int RaftGroupReplicaSuperBlockPB::kIsUnderTwodcReplicationFieldNumber; |
1842 | | const int RaftGroupReplicaSuperBlockPB::kHiddenFieldNumber; |
1843 | | const int RaftGroupReplicaSuperBlockPB::kRestorationHybridTimeFieldNumber; |
1844 | | const int RaftGroupReplicaSuperBlockPB::kSplitOpIdFieldNumber; |
1845 | | const int RaftGroupReplicaSuperBlockPB::kSplitChildTabletIdsFieldNumber; |
1846 | | const int RaftGroupReplicaSuperBlockPB::kActiveRestorationsFieldNumber; |
1847 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1848 | | |
1849 | | RaftGroupReplicaSuperBlockPB::RaftGroupReplicaSuperBlockPB() |
1850 | 1.66M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1851 | 1.65M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1852 | 1.65M | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsRaftGroupReplicaSuperBlockPB(); |
1853 | 1.65M | } |
1854 | 1.66M | SharedCtor(); |
1855 | | // @@protoc_insertion_point(constructor:yb.tablet.RaftGroupReplicaSuperBlockPB) |
1856 | 1.66M | } |
1857 | | RaftGroupReplicaSuperBlockPB::RaftGroupReplicaSuperBlockPB(const RaftGroupReplicaSuperBlockPB& from) |
1858 | | : ::google::protobuf::Message(), |
1859 | | _internal_metadata_(NULL), |
1860 | | _has_bits_(from._has_bits_), |
1861 | | _cached_size_(0), |
1862 | | obsolete_rocksdb_files_(from.obsolete_rocksdb_files_), |
1863 | | obsolete_deleted_cols_(from.obsolete_deleted_cols_), |
1864 | | obsolete_snapshot_files_(from.obsolete_snapshot_files_), |
1865 | | obsolete_indexes_(from.obsolete_indexes_), |
1866 | | obsolete_tables_(from.obsolete_tables_), |
1867 | | split_child_tablet_ids_(from.split_child_tablet_ids_), |
1868 | 2 | active_restorations_(from.active_restorations_) { |
1869 | 2 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1870 | 2 | primary_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1871 | 2 | if (from.has_primary_table_id()) { |
1872 | 2 | primary_table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.primary_table_id_); |
1873 | 2 | } |
1874 | 2 | raft_group_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1875 | 2 | if (from.has_raft_group_id()) { |
1876 | 2 | raft_group_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.raft_group_id_); |
1877 | 2 | } |
1878 | 2 | obsolete_table_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1879 | 2 | if (from.has_obsolete_table_name()) { |
1880 | 0 | obsolete_table_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.obsolete_table_name_); |
1881 | 0 | } |
1882 | 2 | obsolete_rocksdb_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1883 | 2 | if (from.has_obsolete_rocksdb_dir()) { |
1884 | 0 | obsolete_rocksdb_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.obsolete_rocksdb_dir_); |
1885 | 0 | } |
1886 | 2 | wal_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1887 | 2 | if (from.has_wal_dir()) { |
1888 | 2 | wal_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.wal_dir_); |
1889 | 2 | } |
1890 | 2 | if (from.has_obsolete_schema()) { |
1891 | 0 | obsolete_schema_ = new ::yb::SchemaPB(*from.obsolete_schema_); |
1892 | 2 | } else { |
1893 | 2 | obsolete_schema_ = NULL; |
1894 | 2 | } |
1895 | 2 | if (from.has_tombstone_last_logged_opid()) { |
1896 | 0 | tombstone_last_logged_opid_ = new ::yb::OpIdPB(*from.tombstone_last_logged_opid_); |
1897 | 2 | } else { |
1898 | 2 | tombstone_last_logged_opid_ = NULL; |
1899 | 2 | } |
1900 | 2 | if (from.has_partition()) { |
1901 | 2 | partition_ = new ::yb::PartitionPB(*from.partition_); |
1902 | 0 | } else { |
1903 | 0 | partition_ = NULL; |
1904 | 0 | } |
1905 | 2 | if (from.has_obsolete_partition_schema()) { |
1906 | 0 | obsolete_partition_schema_ = new ::yb::PartitionSchemaPB(*from.obsolete_partition_schema_); |
1907 | 2 | } else { |
1908 | 2 | obsolete_partition_schema_ = NULL; |
1909 | 2 | } |
1910 | 2 | if (from.has_obsolete_index_info()) { |
1911 | 0 | obsolete_index_info_ = new ::yb::IndexInfoPB(*from.obsolete_index_info_); |
1912 | 2 | } else { |
1913 | 2 | obsolete_index_info_ = NULL; |
1914 | 2 | } |
1915 | 2 | if (from.has_kv_store()) { |
1916 | 2 | kv_store_ = new ::yb::tablet::KvStoreInfoPB(*from.kv_store_); |
1917 | 0 | } else { |
1918 | 0 | kv_store_ = NULL; |
1919 | 0 | } |
1920 | 2 | if (from.has_split_op_id()) { |
1921 | 0 | split_op_id_ = new ::yb::OpIdPB(*from.split_op_id_); |
1922 | 2 | } else { |
1923 | 2 | split_op_id_ = NULL; |
1924 | 2 | } |
1925 | 2 | ::memcpy(&obsolete_schema_version_, &from.obsolete_schema_version_, |
1926 | 2 | static_cast<size_t>(reinterpret_cast<char*>(&cdc_min_replicated_index_) - |
1927 | 2 | reinterpret_cast<char*>(&obsolete_schema_version_)) + sizeof(cdc_min_replicated_index_)); |
1928 | | // @@protoc_insertion_point(copy_constructor:yb.tablet.RaftGroupReplicaSuperBlockPB) |
1929 | 2 | } |
1930 | | |
1931 | 1.66M | void RaftGroupReplicaSuperBlockPB::SharedCtor() { |
1932 | 1.66M | _cached_size_ = 0; |
1933 | 1.66M | primary_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1934 | 1.66M | raft_group_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1935 | 1.66M | obsolete_table_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1936 | 1.66M | obsolete_rocksdb_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1937 | 1.66M | wal_dir_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1938 | 1.66M | ::memset(&obsolete_schema_, 0, static_cast<size_t>( |
1939 | 1.66M | reinterpret_cast<char*>(&restoration_hybrid_time_) - |
1940 | 1.66M | reinterpret_cast<char*>(&obsolete_schema_)) + sizeof(restoration_hybrid_time_)); |
1941 | 1.66M | tablet_data_state_ = 999; |
1942 | 1.66M | obsolete_table_type_ = 2; |
1943 | 1.66M | cdc_min_replicated_index_ = GOOGLE_LONGLONG(9223372036854775807); |
1944 | 1.66M | } |
1945 | | |
1946 | 1.65M | RaftGroupReplicaSuperBlockPB::~RaftGroupReplicaSuperBlockPB() { |
1947 | | // @@protoc_insertion_point(destructor:yb.tablet.RaftGroupReplicaSuperBlockPB) |
1948 | 1.65M | SharedDtor(); |
1949 | 1.65M | } |
1950 | | |
1951 | 1.65M | void RaftGroupReplicaSuperBlockPB::SharedDtor() { |
1952 | 1.65M | primary_table_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1953 | 1.65M | raft_group_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1954 | 1.65M | obsolete_table_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1955 | 1.65M | obsolete_rocksdb_dir_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1956 | 1.65M | wal_dir_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
1957 | 1.65M | if (this != internal_default_instance()) delete obsolete_schema_; |
1958 | 1.65M | if (this != internal_default_instance()) delete tombstone_last_logged_opid_; |
1959 | 1.65M | if (this != internal_default_instance()) delete partition_; |
1960 | 1.65M | if (this != internal_default_instance()) delete obsolete_partition_schema_; |
1961 | 1.65M | if (this != internal_default_instance()) delete obsolete_index_info_; |
1962 | 1.65M | if (this != internal_default_instance()) delete kv_store_; |
1963 | 1.65M | if (this != internal_default_instance()) delete split_op_id_; |
1964 | 1.65M | } |
1965 | | |
1966 | 0 | void RaftGroupReplicaSuperBlockPB::SetCachedSize(int size) const { |
1967 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1968 | 0 | _cached_size_ = size; |
1969 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1970 | 0 | } |
1971 | 0 | const ::google::protobuf::Descriptor* RaftGroupReplicaSuperBlockPB::descriptor() { |
1972 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
1973 | 0 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1974 | 0 | } |
1975 | | |
1976 | 0 | const RaftGroupReplicaSuperBlockPB& RaftGroupReplicaSuperBlockPB::default_instance() { |
1977 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsRaftGroupReplicaSuperBlockPB(); |
1978 | 0 | return *internal_default_instance(); |
1979 | 0 | } |
1980 | | |
1981 | 0 | RaftGroupReplicaSuperBlockPB* RaftGroupReplicaSuperBlockPB::New(::google::protobuf::Arena* arena) const { |
1982 | 0 | RaftGroupReplicaSuperBlockPB* n = new RaftGroupReplicaSuperBlockPB; |
1983 | 0 | if (arena != NULL) { |
1984 | 0 | arena->Own(n); |
1985 | 0 | } |
1986 | 0 | return n; |
1987 | 0 | } |
1988 | | |
1989 | 4.23k | void RaftGroupReplicaSuperBlockPB::Clear() { |
1990 | | // @@protoc_insertion_point(message_clear_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
1991 | 4.23k | ::google::protobuf::uint32 cached_has_bits = 0; |
1992 | | // Prevent compiler warnings about cached_has_bits being unused |
1993 | 4.23k | (void) cached_has_bits; |
1994 | | |
1995 | 4.23k | obsolete_rocksdb_files_.Clear(); |
1996 | 4.23k | obsolete_deleted_cols_.Clear(); |
1997 | 4.23k | obsolete_snapshot_files_.Clear(); |
1998 | 4.23k | obsolete_indexes_.Clear(); |
1999 | 4.23k | obsolete_tables_.Clear(); |
2000 | 4.23k | split_child_tablet_ids_.Clear(); |
2001 | 4.23k | active_restorations_.Clear(); |
2002 | 4.23k | cached_has_bits = _has_bits_[0]; |
2003 | 4.23k | if (cached_has_bits & 255u) { |
2004 | 0 | if (cached_has_bits & 0x00000001u) { |
2005 | 0 | GOOGLE_DCHECK(!primary_table_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2006 | 0 | (*primary_table_id_.UnsafeRawStringPointer())->clear(); |
2007 | 0 | } |
2008 | 0 | if (cached_has_bits & 0x00000002u) { |
2009 | 0 | GOOGLE_DCHECK(!raft_group_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2010 | 0 | (*raft_group_id_.UnsafeRawStringPointer())->clear(); |
2011 | 0 | } |
2012 | 0 | if (cached_has_bits & 0x00000004u) { |
2013 | 0 | GOOGLE_DCHECK(!obsolete_table_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2014 | 0 | (*obsolete_table_name_.UnsafeRawStringPointer())->clear(); |
2015 | 0 | } |
2016 | 0 | if (cached_has_bits & 0x00000008u) { |
2017 | 0 | GOOGLE_DCHECK(!obsolete_rocksdb_dir_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2018 | 0 | (*obsolete_rocksdb_dir_.UnsafeRawStringPointer())->clear(); |
2019 | 0 | } |
2020 | 0 | if (cached_has_bits & 0x00000010u) { |
2021 | 0 | GOOGLE_DCHECK(!wal_dir_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2022 | 0 | (*wal_dir_.UnsafeRawStringPointer())->clear(); |
2023 | 0 | } |
2024 | 0 | if (cached_has_bits & 0x00000020u) { |
2025 | 0 | GOOGLE_DCHECK(obsolete_schema_ != NULL); |
2026 | 0 | obsolete_schema_->Clear(); |
2027 | 0 | } |
2028 | 0 | if (cached_has_bits & 0x00000040u) { |
2029 | 0 | GOOGLE_DCHECK(tombstone_last_logged_opid_ != NULL); |
2030 | 0 | tombstone_last_logged_opid_->Clear(); |
2031 | 0 | } |
2032 | 0 | if (cached_has_bits & 0x00000080u) { |
2033 | 0 | GOOGLE_DCHECK(partition_ != NULL); |
2034 | 0 | partition_->Clear(); |
2035 | 0 | } |
2036 | 0 | } |
2037 | 4.23k | if (cached_has_bits & 3840u) { |
2038 | 0 | if (cached_has_bits & 0x00000100u) { |
2039 | 0 | GOOGLE_DCHECK(obsolete_partition_schema_ != NULL); |
2040 | 0 | obsolete_partition_schema_->Clear(); |
2041 | 0 | } |
2042 | 0 | if (cached_has_bits & 0x00000200u) { |
2043 | 0 | GOOGLE_DCHECK(obsolete_index_info_ != NULL); |
2044 | 0 | obsolete_index_info_->Clear(); |
2045 | 0 | } |
2046 | 0 | if (cached_has_bits & 0x00000400u) { |
2047 | 0 | GOOGLE_DCHECK(kv_store_ != NULL); |
2048 | 0 | kv_store_->Clear(); |
2049 | 0 | } |
2050 | 0 | if (cached_has_bits & 0x00000800u) { |
2051 | 0 | GOOGLE_DCHECK(split_op_id_ != NULL); |
2052 | 0 | split_op_id_->Clear(); |
2053 | 0 | } |
2054 | 0 | } |
2055 | 4.23k | if (cached_has_bits & 61440u) { |
2056 | 0 | ::memset(&obsolete_schema_version_, 0, static_cast<size_t>( |
2057 | 0 | reinterpret_cast<char*>(&hidden_) - |
2058 | 0 | reinterpret_cast<char*>(&obsolete_schema_version_)) + sizeof(hidden_)); |
2059 | 0 | } |
2060 | 4.23k | if (cached_has_bits & 983040u) { |
2061 | 0 | restoration_hybrid_time_ = GOOGLE_ULONGLONG(0); |
2062 | 0 | tablet_data_state_ = 999; |
2063 | 0 | obsolete_table_type_ = 2; |
2064 | 0 | cdc_min_replicated_index_ = GOOGLE_LONGLONG(9223372036854775807); |
2065 | 0 | } |
2066 | 4.23k | _has_bits_.Clear(); |
2067 | 4.23k | _internal_metadata_.Clear(); |
2068 | 4.23k | } |
2069 | | |
2070 | | bool RaftGroupReplicaSuperBlockPB::MergePartialFromCodedStream( |
2071 | 3.22k | ::google::protobuf::io::CodedInputStream* input) { |
2072 | 35.5k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
2073 | 3.22k | ::google::protobuf::uint32 tag; |
2074 | | // @@protoc_insertion_point(parse_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2075 | 38.6k | for (;;) { |
2076 | 38.6k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(16383u); |
2077 | 38.6k | tag = p.first; |
2078 | 38.6k | if (!p.second) goto handle_unusual; |
2079 | 35.4k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
2080 | | // required bytes primary_table_id = 1; |
2081 | 3.22k | case 1: { |
2082 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2083 | 3.22k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
2084 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
2085 | 3.22k | input, this->mutable_primary_table_id())); |
2086 | 1 | } else { |
2087 | 1 | goto handle_unusual; |
2088 | 1 | } |
2089 | 3.22k | break; |
2090 | 3.22k | } |
2091 | | |
2092 | | // required bytes raft_group_id = 2; |
2093 | 3.22k | case 2: { |
2094 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2095 | 3.22k | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
2096 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
2097 | 3.22k | input, this->mutable_raft_group_id())); |
2098 | 0 | } else { |
2099 | 0 | goto handle_unusual; |
2100 | 0 | } |
2101 | 3.22k | break; |
2102 | 3.22k | } |
2103 | | |
2104 | | // optional string OBSOLETE_table_name = 7; |
2105 | 0 | case 7: { |
2106 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2107 | 0 | static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) { |
2108 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
2109 | 0 | input, this->mutable_obsolete_table_name())); |
2110 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2111 | 0 | this->obsolete_table_name().data(), static_cast<int>(this->obsolete_table_name().length()), |
2112 | 0 | ::google::protobuf::internal::WireFormat::PARSE, |
2113 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_table_name"); |
2114 | 0 | } else { |
2115 | 0 | goto handle_unusual; |
2116 | 0 | } |
2117 | 0 | break; |
2118 | 0 | } |
2119 | | |
2120 | | // optional .yb.SchemaPB OBSOLETE_schema = 8; |
2121 | 0 | case 8: { |
2122 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2123 | 0 | static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) { |
2124 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2125 | 0 | input, mutable_obsolete_schema())); |
2126 | 0 | } else { |
2127 | 0 | goto handle_unusual; |
2128 | 0 | } |
2129 | 0 | break; |
2130 | 0 | } |
2131 | | |
2132 | | // optional uint32 OBSOLETE_schema_version = 9; |
2133 | 0 | case 9: { |
2134 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2135 | 0 | static_cast< ::google::protobuf::uint8>(72u /* 72 & 0xFF */)) { |
2136 | 0 | set_has_obsolete_schema_version(); |
2137 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2138 | 0 | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
2139 | 0 | input, &obsolete_schema_version_))); |
2140 | 0 | } else { |
2141 | 0 | goto handle_unusual; |
2142 | 0 | } |
2143 | 0 | break; |
2144 | 0 | } |
2145 | | |
2146 | | // optional .yb.tablet.TabletDataState tablet_data_state = 10 [default = TABLET_DATA_UNKNOWN]; |
2147 | 3.22k | case 10: { |
2148 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2149 | 3.22k | static_cast< ::google::protobuf::uint8>(80u /* 80 & 0xFF */)) { |
2150 | 3.22k | int value; |
2151 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2152 | 3.22k | int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>( |
2153 | 3.22k | input, &value))); |
2154 | 3.22k | if (::yb::tablet::TabletDataState_IsValid(value)) { |
2155 | 3.22k | set_tablet_data_state(static_cast< ::yb::tablet::TabletDataState >(value)); |
2156 | 1 | } else { |
2157 | 1 | mutable_unknown_fields()->AddVarint( |
2158 | 1 | 10, static_cast< ::google::protobuf::uint64>(value)); |
2159 | 1 | } |
2160 | 0 | } else { |
2161 | 0 | goto handle_unusual; |
2162 | 0 | } |
2163 | 3.22k | break; |
2164 | 3.22k | } |
2165 | | |
2166 | | // optional .yb.OpIdPB tombstone_last_logged_opid = 12; |
2167 | 8 | case 12: { |
2168 | 8 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2169 | 8 | static_cast< ::google::protobuf::uint8>(98u /* 98 & 0xFF */)) { |
2170 | 8 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2171 | 8 | input, mutable_tombstone_last_logged_opid())); |
2172 | 0 | } else { |
2173 | 0 | goto handle_unusual; |
2174 | 0 | } |
2175 | 8 | break; |
2176 | 8 | } |
2177 | | |
2178 | | // optional .yb.PartitionPB partition = 13; |
2179 | 3.22k | case 13: { |
2180 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2181 | 3.22k | static_cast< ::google::protobuf::uint8>(106u /* 106 & 0xFF */)) { |
2182 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2183 | 3.22k | input, mutable_partition())); |
2184 | 18.4E | } else { |
2185 | 18.4E | goto handle_unusual; |
2186 | 18.4E | } |
2187 | 3.22k | break; |
2188 | 3.22k | } |
2189 | | |
2190 | | // optional .yb.PartitionSchemaPB OBSOLETE_partition_schema = 14; |
2191 | 0 | case 14: { |
2192 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2193 | 0 | static_cast< ::google::protobuf::uint8>(114u /* 114 & 0xFF */)) { |
2194 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2195 | 0 | input, mutable_obsolete_partition_schema())); |
2196 | 0 | } else { |
2197 | 0 | goto handle_unusual; |
2198 | 0 | } |
2199 | 0 | break; |
2200 | 0 | } |
2201 | | |
2202 | | // optional .yb.TableType OBSOLETE_table_type = 15 [default = DEFAULT_TABLE_TYPE]; |
2203 | 0 | case 15: { |
2204 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2205 | 0 | static_cast< ::google::protobuf::uint8>(120u /* 120 & 0xFF */)) { |
2206 | 0 | int value; |
2207 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2208 | 0 | int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>( |
2209 | 0 | input, &value))); |
2210 | 0 | if (::yb::TableType_IsValid(value)) { |
2211 | 0 | set_obsolete_table_type(static_cast< ::yb::TableType >(value)); |
2212 | 0 | } else { |
2213 | 0 | mutable_unknown_fields()->AddVarint( |
2214 | 0 | 15, static_cast< ::google::protobuf::uint64>(value)); |
2215 | 0 | } |
2216 | 0 | } else { |
2217 | 0 | goto handle_unusual; |
2218 | 0 | } |
2219 | 0 | break; |
2220 | 0 | } |
2221 | | |
2222 | | // optional string OBSOLETE_rocksdb_dir = 16; |
2223 | 0 | case 16: { |
2224 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2225 | 0 | static_cast< ::google::protobuf::uint8>(130u /* 130 & 0xFF */)) { |
2226 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
2227 | 0 | input, this->mutable_obsolete_rocksdb_dir())); |
2228 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2229 | 0 | this->obsolete_rocksdb_dir().data(), static_cast<int>(this->obsolete_rocksdb_dir().length()), |
2230 | 0 | ::google::protobuf::internal::WireFormat::PARSE, |
2231 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_rocksdb_dir"); |
2232 | 0 | } else { |
2233 | 0 | goto handle_unusual; |
2234 | 0 | } |
2235 | 0 | break; |
2236 | 0 | } |
2237 | | |
2238 | | // repeated .yb.tablet.FilePB OBSOLETE_rocksdb_files = 17; |
2239 | 0 | case 17: { |
2240 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2241 | 0 | static_cast< ::google::protobuf::uint8>(138u /* 138 & 0xFF */)) { |
2242 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_obsolete_rocksdb_files())); |
2243 | 0 | } else { |
2244 | 0 | goto handle_unusual; |
2245 | 0 | } |
2246 | 0 | break; |
2247 | 0 | } |
2248 | | |
2249 | | // optional string wal_dir = 18; |
2250 | 3.22k | case 18: { |
2251 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2252 | 3.22k | static_cast< ::google::protobuf::uint8>(146u /* 146 & 0xFF */)) { |
2253 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
2254 | 3.22k | input, this->mutable_wal_dir())); |
2255 | 3.22k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2256 | 3.22k | this->wal_dir().data(), static_cast<int>(this->wal_dir().length()), |
2257 | 3.22k | ::google::protobuf::internal::WireFormat::PARSE, |
2258 | 3.22k | "yb.tablet.RaftGroupReplicaSuperBlockPB.wal_dir"); |
2259 | 0 | } else { |
2260 | 0 | goto handle_unusual; |
2261 | 0 | } |
2262 | 3.22k | break; |
2263 | 3.22k | } |
2264 | | |
2265 | | // repeated .yb.DeletedColumnPB OBSOLETE_deleted_cols = 19; |
2266 | 0 | case 19: { |
2267 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2268 | 0 | static_cast< ::google::protobuf::uint8>(154u /* 154 & 0xFF */)) { |
2269 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_obsolete_deleted_cols())); |
2270 | 0 | } else { |
2271 | 0 | goto handle_unusual; |
2272 | 0 | } |
2273 | 0 | break; |
2274 | 0 | } |
2275 | | |
2276 | | // repeated .yb.tablet.SnapshotFilePB OBSOLETE_snapshot_files = 20; |
2277 | 0 | case 20: { |
2278 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2279 | 0 | static_cast< ::google::protobuf::uint8>(162u /* 162 & 0xFF */)) { |
2280 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_obsolete_snapshot_files())); |
2281 | 0 | } else { |
2282 | 0 | goto handle_unusual; |
2283 | 0 | } |
2284 | 0 | break; |
2285 | 0 | } |
2286 | | |
2287 | | // repeated .yb.IndexInfoPB OBSOLETE_indexes = 21; |
2288 | 0 | case 21: { |
2289 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2290 | 0 | static_cast< ::google::protobuf::uint8>(170u /* 170 & 0xFF */)) { |
2291 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_obsolete_indexes())); |
2292 | 0 | } else { |
2293 | 0 | goto handle_unusual; |
2294 | 0 | } |
2295 | 0 | break; |
2296 | 0 | } |
2297 | | |
2298 | | // optional .yb.IndexInfoPB OBSOLETE_index_info = 22; |
2299 | 0 | case 22: { |
2300 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2301 | 0 | static_cast< ::google::protobuf::uint8>(178u /* 178 & 0xFF */)) { |
2302 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2303 | 0 | input, mutable_obsolete_index_info())); |
2304 | 0 | } else { |
2305 | 0 | goto handle_unusual; |
2306 | 0 | } |
2307 | 0 | break; |
2308 | 0 | } |
2309 | | |
2310 | | // repeated .yb.tablet.TableInfoPB OBSOLETE_tables = 23; |
2311 | 0 | case 23: { |
2312 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2313 | 0 | static_cast< ::google::protobuf::uint8>(186u /* 186 & 0xFF */)) { |
2314 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_obsolete_tables())); |
2315 | 0 | } else { |
2316 | 0 | goto handle_unusual; |
2317 | 0 | } |
2318 | 0 | break; |
2319 | 0 | } |
2320 | | |
2321 | | // optional .yb.tablet.KvStoreInfoPB kv_store = 24; |
2322 | 3.22k | case 24: { |
2323 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2324 | 3.22k | static_cast< ::google::protobuf::uint8>(194u /* 194 & 0xFF */)) { |
2325 | 3.22k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2326 | 3.22k | input, mutable_kv_store())); |
2327 | 0 | } else { |
2328 | 0 | goto handle_unusual; |
2329 | 0 | } |
2330 | 3.22k | break; |
2331 | 3.22k | } |
2332 | | |
2333 | | // optional bool colocated = 25 [default = false]; |
2334 | 3.22k | case 25: { |
2335 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2336 | 3.22k | static_cast< ::google::protobuf::uint8>(200u /* 200 & 0xFF */)) { |
2337 | 3.22k | set_has_colocated(); |
2338 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2339 | 3.22k | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
2340 | 3.22k | input, &colocated_))); |
2341 | 0 | } else { |
2342 | 0 | goto handle_unusual; |
2343 | 0 | } |
2344 | 3.22k | break; |
2345 | 3.22k | } |
2346 | | |
2347 | | // optional int64 cdc_min_replicated_index = 26 [default = 9223372036854775807]; |
2348 | 3.22k | case 26: { |
2349 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2350 | 3.22k | static_cast< ::google::protobuf::uint8>(208u /* 208 & 0xFF */)) { |
2351 | 3.22k | set_has_cdc_min_replicated_index(); |
2352 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2353 | 3.22k | ::google::protobuf::int64, ::google::protobuf::internal::WireFormatLite::TYPE_INT64>( |
2354 | 3.22k | input, &cdc_min_replicated_index_))); |
2355 | 0 | } else { |
2356 | 0 | goto handle_unusual; |
2357 | 0 | } |
2358 | 3.22k | break; |
2359 | 3.22k | } |
2360 | | |
2361 | | // optional bool is_under_twodc_replication = 27; |
2362 | 3.22k | case 27: { |
2363 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2364 | 3.22k | static_cast< ::google::protobuf::uint8>(216u /* 216 & 0xFF */)) { |
2365 | 3.22k | set_has_is_under_twodc_replication(); |
2366 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2367 | 3.22k | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
2368 | 3.22k | input, &is_under_twodc_replication_))); |
2369 | 0 | } else { |
2370 | 0 | goto handle_unusual; |
2371 | 0 | } |
2372 | 3.22k | break; |
2373 | 3.22k | } |
2374 | | |
2375 | | // optional bool hidden = 28; |
2376 | 3.22k | case 28: { |
2377 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2378 | 3.22k | static_cast< ::google::protobuf::uint8>(224u /* 224 & 0xFF */)) { |
2379 | 3.22k | set_has_hidden(); |
2380 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2381 | 3.22k | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
2382 | 3.22k | input, &hidden_))); |
2383 | 0 | } else { |
2384 | 0 | goto handle_unusual; |
2385 | 0 | } |
2386 | 3.22k | break; |
2387 | 3.22k | } |
2388 | | |
2389 | | // optional .yb.OpIdPB split_op_id = 29; |
2390 | 5 | case 29: { |
2391 | 5 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2392 | 5 | static_cast< ::google::protobuf::uint8>(234u /* 234 & 0xFF */)) { |
2393 | 5 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2394 | 5 | input, mutable_split_op_id())); |
2395 | 0 | } else { |
2396 | 0 | goto handle_unusual; |
2397 | 0 | } |
2398 | 5 | break; |
2399 | 5 | } |
2400 | | |
2401 | | // repeated bytes split_child_tablet_ids = 30; |
2402 | 10 | case 30: { |
2403 | 10 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2404 | 10 | static_cast< ::google::protobuf::uint8>(242u /* 242 & 0xFF */)) { |
2405 | 10 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
2406 | 10 | input, this->add_split_child_tablet_ids())); |
2407 | 0 | } else { |
2408 | 0 | goto handle_unusual; |
2409 | 0 | } |
2410 | 10 | break; |
2411 | 10 | } |
2412 | | |
2413 | | // repeated bytes active_restorations = 31; |
2414 | 0 | case 31: { |
2415 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2416 | 0 | static_cast< ::google::protobuf::uint8>(250u /* 250 & 0xFF */)) { |
2417 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
2418 | 0 | input, this->add_active_restorations())); |
2419 | 0 | } else { |
2420 | 0 | goto handle_unusual; |
2421 | 0 | } |
2422 | 0 | break; |
2423 | 0 | } |
2424 | | |
2425 | | // optional fixed64 restoration_hybrid_time = 32; |
2426 | 3.22k | case 32: { |
2427 | 3.22k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2428 | 3.22k | static_cast< ::google::protobuf::uint8>(1u /* 257 & 0xFF */)) { |
2429 | 3.22k | set_has_restoration_hybrid_time(); |
2430 | 3.22k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2431 | 3.22k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>( |
2432 | 3.22k | input, &restoration_hybrid_time_))); |
2433 | 0 | } else { |
2434 | 0 | goto handle_unusual; |
2435 | 0 | } |
2436 | 3.22k | break; |
2437 | 3.22k | } |
2438 | | |
2439 | 0 | default: { |
2440 | 3.22k | handle_unusual: |
2441 | 3.22k | if (tag == 0) { |
2442 | 3.22k | goto success; |
2443 | 3.22k | } |
2444 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
2445 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
2446 | 0 | break; |
2447 | 0 | } |
2448 | 35.4k | } |
2449 | 35.4k | } |
2450 | 3.22k | success: |
2451 | | // @@protoc_insertion_point(parse_success:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2452 | 3.22k | return true; |
2453 | 0 | failure: |
2454 | | // @@protoc_insertion_point(parse_failure:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2455 | 0 | return false; |
2456 | 3.22k | #undef DO_ |
2457 | 3.22k | } |
2458 | | |
2459 | | void RaftGroupReplicaSuperBlockPB::SerializeWithCachedSizes( |
2460 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
2461 | | // @@protoc_insertion_point(serialize_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2462 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
2463 | 0 | (void) cached_has_bits; |
2464 | |
|
2465 | 0 | cached_has_bits = _has_bits_[0]; |
2466 | | // required bytes primary_table_id = 1; |
2467 | 0 | if (cached_has_bits & 0x00000001u) { |
2468 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
2469 | 0 | 1, this->primary_table_id(), output); |
2470 | 0 | } |
2471 | | |
2472 | | // required bytes raft_group_id = 2; |
2473 | 0 | if (cached_has_bits & 0x00000002u) { |
2474 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
2475 | 0 | 2, this->raft_group_id(), output); |
2476 | 0 | } |
2477 | | |
2478 | | // optional string OBSOLETE_table_name = 7; |
2479 | 0 | if (cached_has_bits & 0x00000004u) { |
2480 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2481 | 0 | this->obsolete_table_name().data(), static_cast<int>(this->obsolete_table_name().length()), |
2482 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2483 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_table_name"); |
2484 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
2485 | 0 | 7, this->obsolete_table_name(), output); |
2486 | 0 | } |
2487 | | |
2488 | | // optional .yb.SchemaPB OBSOLETE_schema = 8; |
2489 | 0 | if (cached_has_bits & 0x00000020u) { |
2490 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2491 | 0 | 8, *this->obsolete_schema_, output); |
2492 | 0 | } |
2493 | | |
2494 | | // optional uint32 OBSOLETE_schema_version = 9; |
2495 | 0 | if (cached_has_bits & 0x00001000u) { |
2496 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(9, this->obsolete_schema_version(), output); |
2497 | 0 | } |
2498 | | |
2499 | | // optional .yb.tablet.TabletDataState tablet_data_state = 10 [default = TABLET_DATA_UNKNOWN]; |
2500 | 0 | if (cached_has_bits & 0x00020000u) { |
2501 | 0 | ::google::protobuf::internal::WireFormatLite::WriteEnum( |
2502 | 0 | 10, this->tablet_data_state(), output); |
2503 | 0 | } |
2504 | | |
2505 | | // optional .yb.OpIdPB tombstone_last_logged_opid = 12; |
2506 | 0 | if (cached_has_bits & 0x00000040u) { |
2507 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2508 | 0 | 12, *this->tombstone_last_logged_opid_, output); |
2509 | 0 | } |
2510 | | |
2511 | | // optional .yb.PartitionPB partition = 13; |
2512 | 0 | if (cached_has_bits & 0x00000080u) { |
2513 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2514 | 0 | 13, *this->partition_, output); |
2515 | 0 | } |
2516 | | |
2517 | | // optional .yb.PartitionSchemaPB OBSOLETE_partition_schema = 14; |
2518 | 0 | if (cached_has_bits & 0x00000100u) { |
2519 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2520 | 0 | 14, *this->obsolete_partition_schema_, output); |
2521 | 0 | } |
2522 | | |
2523 | | // optional .yb.TableType OBSOLETE_table_type = 15 [default = DEFAULT_TABLE_TYPE]; |
2524 | 0 | if (cached_has_bits & 0x00040000u) { |
2525 | 0 | ::google::protobuf::internal::WireFormatLite::WriteEnum( |
2526 | 0 | 15, this->obsolete_table_type(), output); |
2527 | 0 | } |
2528 | | |
2529 | | // optional string OBSOLETE_rocksdb_dir = 16; |
2530 | 0 | if (cached_has_bits & 0x00000008u) { |
2531 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2532 | 0 | this->obsolete_rocksdb_dir().data(), static_cast<int>(this->obsolete_rocksdb_dir().length()), |
2533 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2534 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_rocksdb_dir"); |
2535 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
2536 | 0 | 16, this->obsolete_rocksdb_dir(), output); |
2537 | 0 | } |
2538 | | |
2539 | | // repeated .yb.tablet.FilePB OBSOLETE_rocksdb_files = 17; |
2540 | 0 | for (unsigned int i = 0, |
2541 | 0 | n = static_cast<unsigned int>(this->obsolete_rocksdb_files_size()); i < n; i++) { |
2542 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2543 | 0 | 17, this->obsolete_rocksdb_files(static_cast<int>(i)), output); |
2544 | 0 | } |
2545 | | |
2546 | | // optional string wal_dir = 18; |
2547 | 0 | if (cached_has_bits & 0x00000010u) { |
2548 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2549 | 0 | this->wal_dir().data(), static_cast<int>(this->wal_dir().length()), |
2550 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2551 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.wal_dir"); |
2552 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
2553 | 0 | 18, this->wal_dir(), output); |
2554 | 0 | } |
2555 | | |
2556 | | // repeated .yb.DeletedColumnPB OBSOLETE_deleted_cols = 19; |
2557 | 0 | for (unsigned int i = 0, |
2558 | 0 | n = static_cast<unsigned int>(this->obsolete_deleted_cols_size()); i < n; i++) { |
2559 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2560 | 0 | 19, this->obsolete_deleted_cols(static_cast<int>(i)), output); |
2561 | 0 | } |
2562 | | |
2563 | | // repeated .yb.tablet.SnapshotFilePB OBSOLETE_snapshot_files = 20; |
2564 | 0 | for (unsigned int i = 0, |
2565 | 0 | n = static_cast<unsigned int>(this->obsolete_snapshot_files_size()); i < n; i++) { |
2566 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2567 | 0 | 20, this->obsolete_snapshot_files(static_cast<int>(i)), output); |
2568 | 0 | } |
2569 | | |
2570 | | // repeated .yb.IndexInfoPB OBSOLETE_indexes = 21; |
2571 | 0 | for (unsigned int i = 0, |
2572 | 0 | n = static_cast<unsigned int>(this->obsolete_indexes_size()); i < n; i++) { |
2573 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2574 | 0 | 21, this->obsolete_indexes(static_cast<int>(i)), output); |
2575 | 0 | } |
2576 | | |
2577 | | // optional .yb.IndexInfoPB OBSOLETE_index_info = 22; |
2578 | 0 | if (cached_has_bits & 0x00000200u) { |
2579 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2580 | 0 | 22, *this->obsolete_index_info_, output); |
2581 | 0 | } |
2582 | | |
2583 | | // repeated .yb.tablet.TableInfoPB OBSOLETE_tables = 23; |
2584 | 0 | for (unsigned int i = 0, |
2585 | 0 | n = static_cast<unsigned int>(this->obsolete_tables_size()); i < n; i++) { |
2586 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2587 | 0 | 23, this->obsolete_tables(static_cast<int>(i)), output); |
2588 | 0 | } |
2589 | | |
2590 | | // optional .yb.tablet.KvStoreInfoPB kv_store = 24; |
2591 | 0 | if (cached_has_bits & 0x00000400u) { |
2592 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2593 | 0 | 24, *this->kv_store_, output); |
2594 | 0 | } |
2595 | | |
2596 | | // optional bool colocated = 25 [default = false]; |
2597 | 0 | if (cached_has_bits & 0x00002000u) { |
2598 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(25, this->colocated(), output); |
2599 | 0 | } |
2600 | | |
2601 | | // optional int64 cdc_min_replicated_index = 26 [default = 9223372036854775807]; |
2602 | 0 | if (cached_has_bits & 0x00080000u) { |
2603 | 0 | ::google::protobuf::internal::WireFormatLite::WriteInt64(26, this->cdc_min_replicated_index(), output); |
2604 | 0 | } |
2605 | | |
2606 | | // optional bool is_under_twodc_replication = 27; |
2607 | 0 | if (cached_has_bits & 0x00004000u) { |
2608 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(27, this->is_under_twodc_replication(), output); |
2609 | 0 | } |
2610 | | |
2611 | | // optional bool hidden = 28; |
2612 | 0 | if (cached_has_bits & 0x00008000u) { |
2613 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(28, this->hidden(), output); |
2614 | 0 | } |
2615 | | |
2616 | | // optional .yb.OpIdPB split_op_id = 29; |
2617 | 0 | if (cached_has_bits & 0x00000800u) { |
2618 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2619 | 0 | 29, *this->split_op_id_, output); |
2620 | 0 | } |
2621 | | |
2622 | | // repeated bytes split_child_tablet_ids = 30; |
2623 | 0 | for (int i = 0, n = this->split_child_tablet_ids_size(); i < n; i++) { |
2624 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytes( |
2625 | 0 | 30, this->split_child_tablet_ids(i), output); |
2626 | 0 | } |
2627 | | |
2628 | | // repeated bytes active_restorations = 31; |
2629 | 0 | for (int i = 0, n = this->active_restorations_size(); i < n; i++) { |
2630 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytes( |
2631 | 0 | 31, this->active_restorations(i), output); |
2632 | 0 | } |
2633 | | |
2634 | | // optional fixed64 restoration_hybrid_time = 32; |
2635 | 0 | if (cached_has_bits & 0x00010000u) { |
2636 | 0 | ::google::protobuf::internal::WireFormatLite::WriteFixed64(32, this->restoration_hybrid_time(), output); |
2637 | 0 | } |
2638 | |
|
2639 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
2640 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
2641 | 0 | _internal_metadata_.unknown_fields(), output); |
2642 | 0 | } |
2643 | | // @@protoc_insertion_point(serialize_end:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2644 | 0 | } |
2645 | | |
2646 | | ::google::protobuf::uint8* RaftGroupReplicaSuperBlockPB::InternalSerializeWithCachedSizesToArray( |
2647 | 821k | bool deterministic, ::google::protobuf::uint8* target) const { |
2648 | 821k | (void)deterministic; // Unused |
2649 | | // @@protoc_insertion_point(serialize_to_array_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2650 | 821k | ::google::protobuf::uint32 cached_has_bits = 0; |
2651 | 821k | (void) cached_has_bits; |
2652 | | |
2653 | 821k | cached_has_bits = _has_bits_[0]; |
2654 | | // required bytes primary_table_id = 1; |
2655 | 821k | if (cached_has_bits & 0x00000001u) { |
2656 | 821k | target = |
2657 | 821k | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
2658 | 821k | 1, this->primary_table_id(), target); |
2659 | 821k | } |
2660 | | |
2661 | | // required bytes raft_group_id = 2; |
2662 | 821k | if (cached_has_bits & 0x00000002u) { |
2663 | 821k | target = |
2664 | 821k | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
2665 | 821k | 2, this->raft_group_id(), target); |
2666 | 821k | } |
2667 | | |
2668 | | // optional string OBSOLETE_table_name = 7; |
2669 | 821k | if (cached_has_bits & 0x00000004u) { |
2670 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2671 | 0 | this->obsolete_table_name().data(), static_cast<int>(this->obsolete_table_name().length()), |
2672 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2673 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_table_name"); |
2674 | 0 | target = |
2675 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
2676 | 0 | 7, this->obsolete_table_name(), target); |
2677 | 0 | } |
2678 | | |
2679 | | // optional .yb.SchemaPB OBSOLETE_schema = 8; |
2680 | 821k | if (cached_has_bits & 0x00000020u) { |
2681 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2682 | 0 | InternalWriteMessageToArray( |
2683 | 0 | 8, *this->obsolete_schema_, deterministic, target); |
2684 | 0 | } |
2685 | | |
2686 | | // optional uint32 OBSOLETE_schema_version = 9; |
2687 | 821k | if (cached_has_bits & 0x00001000u) { |
2688 | 0 | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(9, this->obsolete_schema_version(), target); |
2689 | 0 | } |
2690 | | |
2691 | | // optional .yb.tablet.TabletDataState tablet_data_state = 10 [default = TABLET_DATA_UNKNOWN]; |
2692 | 821k | if (cached_has_bits & 0x00020000u) { |
2693 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray( |
2694 | 821k | 10, this->tablet_data_state(), target); |
2695 | 821k | } |
2696 | | |
2697 | | // optional .yb.OpIdPB tombstone_last_logged_opid = 12; |
2698 | 821k | if (cached_has_bits & 0x00000040u) { |
2699 | 94.8k | target = ::google::protobuf::internal::WireFormatLite:: |
2700 | 94.8k | InternalWriteMessageToArray( |
2701 | 94.8k | 12, *this->tombstone_last_logged_opid_, deterministic, target); |
2702 | 94.8k | } |
2703 | | |
2704 | | // optional .yb.PartitionPB partition = 13; |
2705 | 821k | if (cached_has_bits & 0x00000080u) { |
2706 | 821k | target = ::google::protobuf::internal::WireFormatLite:: |
2707 | 821k | InternalWriteMessageToArray( |
2708 | 821k | 13, *this->partition_, deterministic, target); |
2709 | 821k | } |
2710 | | |
2711 | | // optional .yb.PartitionSchemaPB OBSOLETE_partition_schema = 14; |
2712 | 821k | if (cached_has_bits & 0x00000100u) { |
2713 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2714 | 0 | InternalWriteMessageToArray( |
2715 | 0 | 14, *this->obsolete_partition_schema_, deterministic, target); |
2716 | 0 | } |
2717 | | |
2718 | | // optional .yb.TableType OBSOLETE_table_type = 15 [default = DEFAULT_TABLE_TYPE]; |
2719 | 821k | if (cached_has_bits & 0x00040000u) { |
2720 | 0 | target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray( |
2721 | 0 | 15, this->obsolete_table_type(), target); |
2722 | 0 | } |
2723 | | |
2724 | | // optional string OBSOLETE_rocksdb_dir = 16; |
2725 | 821k | if (cached_has_bits & 0x00000008u) { |
2726 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2727 | 0 | this->obsolete_rocksdb_dir().data(), static_cast<int>(this->obsolete_rocksdb_dir().length()), |
2728 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2729 | 0 | "yb.tablet.RaftGroupReplicaSuperBlockPB.OBSOLETE_rocksdb_dir"); |
2730 | 0 | target = |
2731 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
2732 | 0 | 16, this->obsolete_rocksdb_dir(), target); |
2733 | 0 | } |
2734 | | |
2735 | | // repeated .yb.tablet.FilePB OBSOLETE_rocksdb_files = 17; |
2736 | 821k | for (unsigned int i = 0, |
2737 | 821k | n = static_cast<unsigned int>(this->obsolete_rocksdb_files_size()); i < n; i++) { |
2738 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2739 | 0 | InternalWriteMessageToArray( |
2740 | 0 | 17, this->obsolete_rocksdb_files(static_cast<int>(i)), deterministic, target); |
2741 | 0 | } |
2742 | | |
2743 | | // optional string wal_dir = 18; |
2744 | 821k | if (cached_has_bits & 0x00000010u) { |
2745 | 821k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2746 | 821k | this->wal_dir().data(), static_cast<int>(this->wal_dir().length()), |
2747 | 821k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2748 | 821k | "yb.tablet.RaftGroupReplicaSuperBlockPB.wal_dir"); |
2749 | 821k | target = |
2750 | 821k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
2751 | 821k | 18, this->wal_dir(), target); |
2752 | 821k | } |
2753 | | |
2754 | | // repeated .yb.DeletedColumnPB OBSOLETE_deleted_cols = 19; |
2755 | 821k | for (unsigned int i = 0, |
2756 | 821k | n = static_cast<unsigned int>(this->obsolete_deleted_cols_size()); i < n; i++) { |
2757 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2758 | 0 | InternalWriteMessageToArray( |
2759 | 0 | 19, this->obsolete_deleted_cols(static_cast<int>(i)), deterministic, target); |
2760 | 0 | } |
2761 | | |
2762 | | // repeated .yb.tablet.SnapshotFilePB OBSOLETE_snapshot_files = 20; |
2763 | 821k | for (unsigned int i = 0, |
2764 | 821k | n = static_cast<unsigned int>(this->obsolete_snapshot_files_size()); i < n; i++) { |
2765 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2766 | 0 | InternalWriteMessageToArray( |
2767 | 0 | 20, this->obsolete_snapshot_files(static_cast<int>(i)), deterministic, target); |
2768 | 0 | } |
2769 | | |
2770 | | // repeated .yb.IndexInfoPB OBSOLETE_indexes = 21; |
2771 | 821k | for (unsigned int i = 0, |
2772 | 821k | n = static_cast<unsigned int>(this->obsolete_indexes_size()); i < n; i++) { |
2773 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2774 | 0 | InternalWriteMessageToArray( |
2775 | 0 | 21, this->obsolete_indexes(static_cast<int>(i)), deterministic, target); |
2776 | 0 | } |
2777 | | |
2778 | | // optional .yb.IndexInfoPB OBSOLETE_index_info = 22; |
2779 | 821k | if (cached_has_bits & 0x00000200u) { |
2780 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2781 | 0 | InternalWriteMessageToArray( |
2782 | 0 | 22, *this->obsolete_index_info_, deterministic, target); |
2783 | 0 | } |
2784 | | |
2785 | | // repeated .yb.tablet.TableInfoPB OBSOLETE_tables = 23; |
2786 | 821k | for (unsigned int i = 0, |
2787 | 821k | n = static_cast<unsigned int>(this->obsolete_tables_size()); i < n; i++) { |
2788 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2789 | 0 | InternalWriteMessageToArray( |
2790 | 0 | 23, this->obsolete_tables(static_cast<int>(i)), deterministic, target); |
2791 | 0 | } |
2792 | | |
2793 | | // optional .yb.tablet.KvStoreInfoPB kv_store = 24; |
2794 | 821k | if (cached_has_bits & 0x00000400u) { |
2795 | 821k | target = ::google::protobuf::internal::WireFormatLite:: |
2796 | 821k | InternalWriteMessageToArray( |
2797 | 821k | 24, *this->kv_store_, deterministic, target); |
2798 | 821k | } |
2799 | | |
2800 | | // optional bool colocated = 25 [default = false]; |
2801 | 821k | if (cached_has_bits & 0x00002000u) { |
2802 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(25, this->colocated(), target); |
2803 | 821k | } |
2804 | | |
2805 | | // optional int64 cdc_min_replicated_index = 26 [default = 9223372036854775807]; |
2806 | 821k | if (cached_has_bits & 0x00080000u) { |
2807 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteInt64ToArray(26, this->cdc_min_replicated_index(), target); |
2808 | 821k | } |
2809 | | |
2810 | | // optional bool is_under_twodc_replication = 27; |
2811 | 821k | if (cached_has_bits & 0x00004000u) { |
2812 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(27, this->is_under_twodc_replication(), target); |
2813 | 821k | } |
2814 | | |
2815 | | // optional bool hidden = 28; |
2816 | 821k | if (cached_has_bits & 0x00008000u) { |
2817 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(28, this->hidden(), target); |
2818 | 821k | } |
2819 | | |
2820 | | // optional .yb.OpIdPB split_op_id = 29; |
2821 | 821k | if (cached_has_bits & 0x00000800u) { |
2822 | 91 | target = ::google::protobuf::internal::WireFormatLite:: |
2823 | 91 | InternalWriteMessageToArray( |
2824 | 91 | 29, *this->split_op_id_, deterministic, target); |
2825 | 91 | } |
2826 | | |
2827 | | // repeated bytes split_child_tablet_ids = 30; |
2828 | 822k | for (int i = 0, n = this->split_child_tablet_ids_size(); i < n; i++) { |
2829 | 182 | target = ::google::protobuf::internal::WireFormatLite:: |
2830 | 182 | WriteBytesToArray(30, this->split_child_tablet_ids(i), target); |
2831 | 182 | } |
2832 | | |
2833 | | // repeated bytes active_restorations = 31; |
2834 | 821k | for (int i = 0, n = this->active_restorations_size(); i < n; i++) { |
2835 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2836 | 0 | WriteBytesToArray(31, this->active_restorations(i), target); |
2837 | 0 | } |
2838 | | |
2839 | | // optional fixed64 restoration_hybrid_time = 32; |
2840 | 821k | if (cached_has_bits & 0x00010000u) { |
2841 | 821k | target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(32, this->restoration_hybrid_time(), target); |
2842 | 821k | } |
2843 | | |
2844 | 821k | if (_internal_metadata_.have_unknown_fields()) { |
2845 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
2846 | 0 | _internal_metadata_.unknown_fields(), target); |
2847 | 0 | } |
2848 | | // @@protoc_insertion_point(serialize_to_array_end:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2849 | 821k | return target; |
2850 | 821k | } |
2851 | | |
2852 | 0 | size_t RaftGroupReplicaSuperBlockPB::RequiredFieldsByteSizeFallback() const { |
2853 | | // @@protoc_insertion_point(required_fields_byte_size_fallback_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2854 | 0 | size_t total_size = 0; |
2855 | |
|
2856 | 0 | if (has_primary_table_id()) { |
2857 | | // required bytes primary_table_id = 1; |
2858 | 0 | total_size += 1 + |
2859 | 0 | ::google::protobuf::internal::WireFormatLite::BytesSize( |
2860 | 0 | this->primary_table_id()); |
2861 | 0 | } |
2862 | |
|
2863 | 0 | if (has_raft_group_id()) { |
2864 | | // required bytes raft_group_id = 2; |
2865 | 0 | total_size += 1 + |
2866 | 0 | ::google::protobuf::internal::WireFormatLite::BytesSize( |
2867 | 0 | this->raft_group_id()); |
2868 | 0 | } |
2869 | |
|
2870 | 0 | return total_size; |
2871 | 0 | } |
2872 | 823k | size_t RaftGroupReplicaSuperBlockPB::ByteSizeLong() const { |
2873 | | // @@protoc_insertion_point(message_byte_size_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
2874 | 823k | size_t total_size = 0; |
2875 | | |
2876 | 823k | if (_internal_metadata_.have_unknown_fields()) { |
2877 | 0 | total_size += |
2878 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
2879 | 0 | _internal_metadata_.unknown_fields()); |
2880 | 0 | } |
2881 | 823k | if (((_has_bits_[0] & 0x00000003) ^ 0x00000003) == 0) { // All required fields are present. |
2882 | | // required bytes primary_table_id = 1; |
2883 | 823k | total_size += 1 + |
2884 | 823k | ::google::protobuf::internal::WireFormatLite::BytesSize( |
2885 | 823k | this->primary_table_id()); |
2886 | | |
2887 | | // required bytes raft_group_id = 2; |
2888 | 823k | total_size += 1 + |
2889 | 823k | ::google::protobuf::internal::WireFormatLite::BytesSize( |
2890 | 823k | this->raft_group_id()); |
2891 | | |
2892 | 253 | } else { |
2893 | 253 | total_size += RequiredFieldsByteSizeFallback(); |
2894 | 253 | } |
2895 | | // repeated .yb.tablet.FilePB OBSOLETE_rocksdb_files = 17; |
2896 | 823k | { |
2897 | 823k | unsigned int count = static_cast<unsigned int>(this->obsolete_rocksdb_files_size()); |
2898 | 823k | total_size += 2UL * count; |
2899 | 823k | for (unsigned int i = 0; i < count; i++) { |
2900 | 0 | total_size += |
2901 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2902 | 0 | this->obsolete_rocksdb_files(static_cast<int>(i))); |
2903 | 0 | } |
2904 | 823k | } |
2905 | | |
2906 | | // repeated .yb.DeletedColumnPB OBSOLETE_deleted_cols = 19; |
2907 | 823k | { |
2908 | 823k | unsigned int count = static_cast<unsigned int>(this->obsolete_deleted_cols_size()); |
2909 | 823k | total_size += 2UL * count; |
2910 | 823k | for (unsigned int i = 0; i < count; i++) { |
2911 | 0 | total_size += |
2912 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2913 | 0 | this->obsolete_deleted_cols(static_cast<int>(i))); |
2914 | 0 | } |
2915 | 823k | } |
2916 | | |
2917 | | // repeated .yb.tablet.SnapshotFilePB OBSOLETE_snapshot_files = 20; |
2918 | 823k | { |
2919 | 823k | unsigned int count = static_cast<unsigned int>(this->obsolete_snapshot_files_size()); |
2920 | 823k | total_size += 2UL * count; |
2921 | 823k | for (unsigned int i = 0; i < count; i++) { |
2922 | 0 | total_size += |
2923 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2924 | 0 | this->obsolete_snapshot_files(static_cast<int>(i))); |
2925 | 0 | } |
2926 | 823k | } |
2927 | | |
2928 | | // repeated .yb.IndexInfoPB OBSOLETE_indexes = 21; |
2929 | 823k | { |
2930 | 823k | unsigned int count = static_cast<unsigned int>(this->obsolete_indexes_size()); |
2931 | 823k | total_size += 2UL * count; |
2932 | 823k | for (unsigned int i = 0; i < count; i++) { |
2933 | 0 | total_size += |
2934 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2935 | 0 | this->obsolete_indexes(static_cast<int>(i))); |
2936 | 0 | } |
2937 | 823k | } |
2938 | | |
2939 | | // repeated .yb.tablet.TableInfoPB OBSOLETE_tables = 23; |
2940 | 823k | { |
2941 | 823k | unsigned int count = static_cast<unsigned int>(this->obsolete_tables_size()); |
2942 | 823k | total_size += 2UL * count; |
2943 | 823k | for (unsigned int i = 0; i < count; i++) { |
2944 | 0 | total_size += |
2945 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2946 | 0 | this->obsolete_tables(static_cast<int>(i))); |
2947 | 0 | } |
2948 | 823k | } |
2949 | | |
2950 | | // repeated bytes split_child_tablet_ids = 30; |
2951 | 823k | total_size += 2 * |
2952 | 823k | ::google::protobuf::internal::FromIntSize(this->split_child_tablet_ids_size()); |
2953 | 823k | for (int i = 0, n = this->split_child_tablet_ids_size(); i < n; i++) { |
2954 | 184 | total_size += ::google::protobuf::internal::WireFormatLite::BytesSize( |
2955 | 184 | this->split_child_tablet_ids(i)); |
2956 | 184 | } |
2957 | | |
2958 | | // repeated bytes active_restorations = 31; |
2959 | 823k | total_size += 2 * |
2960 | 823k | ::google::protobuf::internal::FromIntSize(this->active_restorations_size()); |
2961 | 823k | for (int i = 0, n = this->active_restorations_size(); i < n; i++) { |
2962 | 0 | total_size += ::google::protobuf::internal::WireFormatLite::BytesSize( |
2963 | 0 | this->active_restorations(i)); |
2964 | 0 | } |
2965 | | |
2966 | 823k | if (_has_bits_[0 / 32] & 252u) { |
2967 | | // optional string OBSOLETE_table_name = 7; |
2968 | 822k | if (has_obsolete_table_name()) { |
2969 | 0 | total_size += 1 + |
2970 | 0 | ::google::protobuf::internal::WireFormatLite::StringSize( |
2971 | 0 | this->obsolete_table_name()); |
2972 | 0 | } |
2973 | | |
2974 | | // optional string OBSOLETE_rocksdb_dir = 16; |
2975 | 822k | if (has_obsolete_rocksdb_dir()) { |
2976 | 0 | total_size += 2 + |
2977 | 0 | ::google::protobuf::internal::WireFormatLite::StringSize( |
2978 | 0 | this->obsolete_rocksdb_dir()); |
2979 | 0 | } |
2980 | | |
2981 | | // optional string wal_dir = 18; |
2982 | 822k | if (has_wal_dir()) { |
2983 | 822k | total_size += 2 + |
2984 | 822k | ::google::protobuf::internal::WireFormatLite::StringSize( |
2985 | 822k | this->wal_dir()); |
2986 | 822k | } |
2987 | | |
2988 | | // optional .yb.SchemaPB OBSOLETE_schema = 8; |
2989 | 822k | if (has_obsolete_schema()) { |
2990 | 0 | total_size += 1 + |
2991 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2992 | 0 | *this->obsolete_schema_); |
2993 | 0 | } |
2994 | | |
2995 | | // optional .yb.OpIdPB tombstone_last_logged_opid = 12; |
2996 | 822k | if (has_tombstone_last_logged_opid()) { |
2997 | 94.8k | total_size += 1 + |
2998 | 94.8k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2999 | 94.8k | *this->tombstone_last_logged_opid_); |
3000 | 94.8k | } |
3001 | | |
3002 | | // optional .yb.PartitionPB partition = 13; |
3003 | 822k | if (has_partition()) { |
3004 | 822k | total_size += 1 + |
3005 | 822k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3006 | 822k | *this->partition_); |
3007 | 822k | } |
3008 | | |
3009 | 822k | } |
3010 | 823k | if (_has_bits_[8 / 32] & 65280u) { |
3011 | | // optional .yb.PartitionSchemaPB OBSOLETE_partition_schema = 14; |
3012 | 823k | if (has_obsolete_partition_schema()) { |
3013 | 0 | total_size += 1 + |
3014 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3015 | 0 | *this->obsolete_partition_schema_); |
3016 | 0 | } |
3017 | | |
3018 | | // optional .yb.IndexInfoPB OBSOLETE_index_info = 22; |
3019 | 823k | if (has_obsolete_index_info()) { |
3020 | 0 | total_size += 2 + |
3021 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3022 | 0 | *this->obsolete_index_info_); |
3023 | 0 | } |
3024 | | |
3025 | | // optional .yb.tablet.KvStoreInfoPB kv_store = 24; |
3026 | 823k | if (has_kv_store()) { |
3027 | 823k | total_size += 2 + |
3028 | 823k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3029 | 823k | *this->kv_store_); |
3030 | 823k | } |
3031 | | |
3032 | | // optional .yb.OpIdPB split_op_id = 29; |
3033 | 823k | if (has_split_op_id()) { |
3034 | 92 | total_size += 2 + |
3035 | 92 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3036 | 92 | *this->split_op_id_); |
3037 | 92 | } |
3038 | | |
3039 | | // optional uint32 OBSOLETE_schema_version = 9; |
3040 | 823k | if (has_obsolete_schema_version()) { |
3041 | 0 | total_size += 1 + |
3042 | 0 | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
3043 | 0 | this->obsolete_schema_version()); |
3044 | 0 | } |
3045 | | |
3046 | | // optional bool colocated = 25 [default = false]; |
3047 | 823k | if (has_colocated()) { |
3048 | 823k | total_size += 2 + 1; |
3049 | 823k | } |
3050 | | |
3051 | | // optional bool is_under_twodc_replication = 27; |
3052 | 823k | if (has_is_under_twodc_replication()) { |
3053 | 823k | total_size += 2 + 1; |
3054 | 823k | } |
3055 | | |
3056 | | // optional bool hidden = 28; |
3057 | 823k | if (has_hidden()) { |
3058 | 822k | total_size += 2 + 1; |
3059 | 822k | } |
3060 | | |
3061 | 823k | } |
3062 | 823k | if (_has_bits_[16 / 32] & 983040u) { |
3063 | | // optional fixed64 restoration_hybrid_time = 32; |
3064 | 822k | if (has_restoration_hybrid_time()) { |
3065 | 822k | total_size += 2 + 8; |
3066 | 822k | } |
3067 | | |
3068 | | // optional .yb.tablet.TabletDataState tablet_data_state = 10 [default = TABLET_DATA_UNKNOWN]; |
3069 | 822k | if (has_tablet_data_state()) { |
3070 | 822k | total_size += 1 + |
3071 | 822k | ::google::protobuf::internal::WireFormatLite::EnumSize(this->tablet_data_state()); |
3072 | 822k | } |
3073 | | |
3074 | | // optional .yb.TableType OBSOLETE_table_type = 15 [default = DEFAULT_TABLE_TYPE]; |
3075 | 822k | if (has_obsolete_table_type()) { |
3076 | 0 | total_size += 1 + |
3077 | 0 | ::google::protobuf::internal::WireFormatLite::EnumSize(this->obsolete_table_type()); |
3078 | 0 | } |
3079 | | |
3080 | | // optional int64 cdc_min_replicated_index = 26 [default = 9223372036854775807]; |
3081 | 822k | if (has_cdc_min_replicated_index()) { |
3082 | 822k | total_size += 2 + |
3083 | 822k | ::google::protobuf::internal::WireFormatLite::Int64Size( |
3084 | 822k | this->cdc_min_replicated_index()); |
3085 | 822k | } |
3086 | | |
3087 | 822k | } |
3088 | 823k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
3089 | 823k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
3090 | 823k | _cached_size_ = cached_size; |
3091 | 823k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
3092 | 823k | return total_size; |
3093 | 823k | } |
3094 | | |
3095 | 0 | void RaftGroupReplicaSuperBlockPB::MergeFrom(const ::google::protobuf::Message& from) { |
3096 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3097 | 0 | GOOGLE_DCHECK_NE(&from, this); |
3098 | 0 | const RaftGroupReplicaSuperBlockPB* source = |
3099 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const RaftGroupReplicaSuperBlockPB>( |
3100 | 0 | &from); |
3101 | 0 | if (source == NULL) { |
3102 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3103 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
3104 | 0 | } else { |
3105 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3106 | 0 | MergeFrom(*source); |
3107 | 0 | } |
3108 | 0 | } |
3109 | | |
3110 | 2.44k | void RaftGroupReplicaSuperBlockPB::MergeFrom(const RaftGroupReplicaSuperBlockPB& from) { |
3111 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3112 | 2.44k | GOOGLE_DCHECK_NE(&from, this); |
3113 | 2.44k | _internal_metadata_.MergeFrom(from._internal_metadata_); |
3114 | 2.44k | ::google::protobuf::uint32 cached_has_bits = 0; |
3115 | 2.44k | (void) cached_has_bits; |
3116 | | |
3117 | 2.44k | obsolete_rocksdb_files_.MergeFrom(from.obsolete_rocksdb_files_); |
3118 | 2.44k | obsolete_deleted_cols_.MergeFrom(from.obsolete_deleted_cols_); |
3119 | 2.44k | obsolete_snapshot_files_.MergeFrom(from.obsolete_snapshot_files_); |
3120 | 2.44k | obsolete_indexes_.MergeFrom(from.obsolete_indexes_); |
3121 | 2.44k | obsolete_tables_.MergeFrom(from.obsolete_tables_); |
3122 | 2.44k | split_child_tablet_ids_.MergeFrom(from.split_child_tablet_ids_); |
3123 | 2.44k | active_restorations_.MergeFrom(from.active_restorations_); |
3124 | 2.44k | cached_has_bits = from._has_bits_[0]; |
3125 | 2.44k | if (cached_has_bits & 255u) { |
3126 | 2.44k | if (cached_has_bits & 0x00000001u) { |
3127 | 2.44k | set_has_primary_table_id(); |
3128 | 2.44k | primary_table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.primary_table_id_); |
3129 | 2.44k | } |
3130 | 2.44k | if (cached_has_bits & 0x00000002u) { |
3131 | 2.44k | set_has_raft_group_id(); |
3132 | 2.44k | raft_group_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.raft_group_id_); |
3133 | 2.44k | } |
3134 | 2.44k | if (cached_has_bits & 0x00000004u) { |
3135 | 0 | set_has_obsolete_table_name(); |
3136 | 0 | obsolete_table_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.obsolete_table_name_); |
3137 | 0 | } |
3138 | 2.44k | if (cached_has_bits & 0x00000008u) { |
3139 | 0 | set_has_obsolete_rocksdb_dir(); |
3140 | 0 | obsolete_rocksdb_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.obsolete_rocksdb_dir_); |
3141 | 0 | } |
3142 | 2.44k | if (cached_has_bits & 0x00000010u) { |
3143 | 2.44k | set_has_wal_dir(); |
3144 | 2.44k | wal_dir_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.wal_dir_); |
3145 | 2.44k | } |
3146 | 2.44k | if (cached_has_bits & 0x00000020u) { |
3147 | 0 | mutable_obsolete_schema()->::yb::SchemaPB::MergeFrom(from.obsolete_schema()); |
3148 | 0 | } |
3149 | 2.44k | if (cached_has_bits & 0x00000040u) { |
3150 | 0 | mutable_tombstone_last_logged_opid()->::yb::OpIdPB::MergeFrom(from.tombstone_last_logged_opid()); |
3151 | 0 | } |
3152 | 2.44k | if (cached_has_bits & 0x00000080u) { |
3153 | 2.44k | mutable_partition()->::yb::PartitionPB::MergeFrom(from.partition()); |
3154 | 2.44k | } |
3155 | 2.44k | } |
3156 | 2.44k | if (cached_has_bits & 65280u) { |
3157 | 2.44k | if (cached_has_bits & 0x00000100u) { |
3158 | 0 | mutable_obsolete_partition_schema()->::yb::PartitionSchemaPB::MergeFrom(from.obsolete_partition_schema()); |
3159 | 0 | } |
3160 | 2.44k | if (cached_has_bits & 0x00000200u) { |
3161 | 0 | mutable_obsolete_index_info()->::yb::IndexInfoPB::MergeFrom(from.obsolete_index_info()); |
3162 | 0 | } |
3163 | 2.44k | if (cached_has_bits & 0x00000400u) { |
3164 | 2.44k | mutable_kv_store()->::yb::tablet::KvStoreInfoPB::MergeFrom(from.kv_store()); |
3165 | 2.44k | } |
3166 | 2.44k | if (cached_has_bits & 0x00000800u) { |
3167 | 2 | mutable_split_op_id()->::yb::OpIdPB::MergeFrom(from.split_op_id()); |
3168 | 2 | } |
3169 | 2.44k | if (cached_has_bits & 0x00001000u) { |
3170 | 0 | obsolete_schema_version_ = from.obsolete_schema_version_; |
3171 | 0 | } |
3172 | 2.44k | if (cached_has_bits & 0x00002000u) { |
3173 | 2.44k | colocated_ = from.colocated_; |
3174 | 2.44k | } |
3175 | 2.44k | if (cached_has_bits & 0x00004000u) { |
3176 | 2.44k | is_under_twodc_replication_ = from.is_under_twodc_replication_; |
3177 | 2.44k | } |
3178 | 2.44k | if (cached_has_bits & 0x00008000u) { |
3179 | 2.44k | hidden_ = from.hidden_; |
3180 | 2.44k | } |
3181 | 2.44k | _has_bits_[0] |= cached_has_bits; |
3182 | 2.44k | } |
3183 | 2.44k | if (cached_has_bits & 983040u) { |
3184 | 2.44k | if (cached_has_bits & 0x00010000u) { |
3185 | 2.44k | restoration_hybrid_time_ = from.restoration_hybrid_time_; |
3186 | 2.44k | } |
3187 | 2.44k | if (cached_has_bits & 0x00020000u) { |
3188 | 2.44k | tablet_data_state_ = from.tablet_data_state_; |
3189 | 2.44k | } |
3190 | 2.44k | if (cached_has_bits & 0x00040000u) { |
3191 | 0 | obsolete_table_type_ = from.obsolete_table_type_; |
3192 | 0 | } |
3193 | 2.44k | if (cached_has_bits & 0x00080000u) { |
3194 | 2.44k | cdc_min_replicated_index_ = from.cdc_min_replicated_index_; |
3195 | 2.44k | } |
3196 | 2.44k | _has_bits_[0] |= cached_has_bits; |
3197 | 2.44k | } |
3198 | 2.44k | } |
3199 | | |
3200 | 0 | void RaftGroupReplicaSuperBlockPB::CopyFrom(const ::google::protobuf::Message& from) { |
3201 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3202 | 0 | if (&from == this) return; |
3203 | 0 | Clear(); |
3204 | 0 | MergeFrom(from); |
3205 | 0 | } |
3206 | | |
3207 | 2.44k | void RaftGroupReplicaSuperBlockPB::CopyFrom(const RaftGroupReplicaSuperBlockPB& from) { |
3208 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.tablet.RaftGroupReplicaSuperBlockPB) |
3209 | 2.44k | if (&from == this) return; |
3210 | 2.44k | Clear(); |
3211 | 2.44k | MergeFrom(from); |
3212 | 2.44k | } |
3213 | | |
3214 | 825k | bool RaftGroupReplicaSuperBlockPB::IsInitialized() const { |
3215 | 825k | if ((_has_bits_[0] & 0x00000003) != 0x00000003) return false; |
3216 | 825k | if (!::google::protobuf::internal::AllAreInitialized(this->obsolete_indexes())) return false; |
3217 | 825k | if (!::google::protobuf::internal::AllAreInitialized(this->obsolete_tables())) return false; |
3218 | 825k | if (has_obsolete_schema()) { |
3219 | 0 | if (!this->obsolete_schema_->IsInitialized()) return false; |
3220 | 825k | } |
3221 | 825k | if (has_tombstone_last_logged_opid()) { |
3222 | 94.8k | if (!this->tombstone_last_logged_opid_->IsInitialized()) return false; |
3223 | 825k | } |
3224 | 825k | if (has_obsolete_partition_schema()) { |
3225 | 0 | if (!this->obsolete_partition_schema_->IsInitialized()) return false; |
3226 | 825k | } |
3227 | 825k | if (has_obsolete_index_info()) { |
3228 | 0 | if (!this->obsolete_index_info_->IsInitialized()) return false; |
3229 | 825k | } |
3230 | 825k | if (has_kv_store()) { |
3231 | 824k | if (!this->kv_store_->IsInitialized()) return false; |
3232 | 825k | } |
3233 | 825k | if (has_split_op_id()) { |
3234 | 96 | if (!this->split_op_id_->IsInitialized()) return false; |
3235 | 825k | } |
3236 | 825k | return true; |
3237 | 825k | } |
3238 | | |
3239 | 819k | void RaftGroupReplicaSuperBlockPB::Swap(RaftGroupReplicaSuperBlockPB* other) { |
3240 | 819k | if (other == this) return; |
3241 | 819k | InternalSwap(other); |
3242 | 819k | } |
3243 | 819k | void RaftGroupReplicaSuperBlockPB::InternalSwap(RaftGroupReplicaSuperBlockPB* other) { |
3244 | 819k | using std::swap; |
3245 | 819k | obsolete_rocksdb_files_.InternalSwap(&other->obsolete_rocksdb_files_); |
3246 | 819k | obsolete_deleted_cols_.InternalSwap(&other->obsolete_deleted_cols_); |
3247 | 819k | obsolete_snapshot_files_.InternalSwap(&other->obsolete_snapshot_files_); |
3248 | 819k | obsolete_indexes_.InternalSwap(&other->obsolete_indexes_); |
3249 | 819k | obsolete_tables_.InternalSwap(&other->obsolete_tables_); |
3250 | 819k | split_child_tablet_ids_.InternalSwap(&other->split_child_tablet_ids_); |
3251 | 819k | active_restorations_.InternalSwap(&other->active_restorations_); |
3252 | 819k | primary_table_id_.Swap(&other->primary_table_id_); |
3253 | 819k | raft_group_id_.Swap(&other->raft_group_id_); |
3254 | 819k | obsolete_table_name_.Swap(&other->obsolete_table_name_); |
3255 | 819k | obsolete_rocksdb_dir_.Swap(&other->obsolete_rocksdb_dir_); |
3256 | 819k | wal_dir_.Swap(&other->wal_dir_); |
3257 | 819k | swap(obsolete_schema_, other->obsolete_schema_); |
3258 | 819k | swap(tombstone_last_logged_opid_, other->tombstone_last_logged_opid_); |
3259 | 819k | swap(partition_, other->partition_); |
3260 | 819k | swap(obsolete_partition_schema_, other->obsolete_partition_schema_); |
3261 | 819k | swap(obsolete_index_info_, other->obsolete_index_info_); |
3262 | 819k | swap(kv_store_, other->kv_store_); |
3263 | 819k | swap(split_op_id_, other->split_op_id_); |
3264 | 819k | swap(obsolete_schema_version_, other->obsolete_schema_version_); |
3265 | 819k | swap(colocated_, other->colocated_); |
3266 | 819k | swap(is_under_twodc_replication_, other->is_under_twodc_replication_); |
3267 | 819k | swap(hidden_, other->hidden_); |
3268 | 819k | swap(restoration_hybrid_time_, other->restoration_hybrid_time_); |
3269 | 819k | swap(tablet_data_state_, other->tablet_data_state_); |
3270 | 819k | swap(obsolete_table_type_, other->obsolete_table_type_); |
3271 | 819k | swap(cdc_min_replicated_index_, other->cdc_min_replicated_index_); |
3272 | 819k | swap(_has_bits_[0], other->_has_bits_[0]); |
3273 | 819k | _internal_metadata_.Swap(&other->_internal_metadata_); |
3274 | 819k | swap(_cached_size_, other->_cached_size_); |
3275 | 819k | } |
3276 | | |
3277 | 1.64M | ::google::protobuf::Metadata RaftGroupReplicaSuperBlockPB::GetMetadata() const { |
3278 | 1.64M | protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
3279 | 1.64M | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages]; |
3280 | 1.64M | } |
3281 | | |
3282 | | |
3283 | | // =================================================================== |
3284 | | |
3285 | 15.8k | void FilePB::InitAsDefaultInstance() { |
3286 | 15.8k | } |
3287 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
3288 | | const int FilePB::kNameFieldNumber; |
3289 | | const int FilePB::kSizeBytesFieldNumber; |
3290 | | const int FilePB::kInodeFieldNumber; |
3291 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
3292 | | |
3293 | | FilePB::FilePB() |
3294 | 33.0k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
3295 | 17.1k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
3296 | 17.1k | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsFilePB(); |
3297 | 17.1k | } |
3298 | 33.0k | SharedCtor(); |
3299 | | // @@protoc_insertion_point(constructor:yb.tablet.FilePB) |
3300 | 33.0k | } |
3301 | | FilePB::FilePB(const FilePB& from) |
3302 | | : ::google::protobuf::Message(), |
3303 | | _internal_metadata_(NULL), |
3304 | | _has_bits_(from._has_bits_), |
3305 | 0 | _cached_size_(0) { |
3306 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
3307 | 0 | name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3308 | 0 | if (from.has_name()) { |
3309 | 0 | name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.name_); |
3310 | 0 | } |
3311 | 0 | ::memcpy(&size_bytes_, &from.size_bytes_, |
3312 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&inode_) - |
3313 | 0 | reinterpret_cast<char*>(&size_bytes_)) + sizeof(inode_)); |
3314 | | // @@protoc_insertion_point(copy_constructor:yb.tablet.FilePB) |
3315 | 0 | } |
3316 | | |
3317 | 33.0k | void FilePB::SharedCtor() { |
3318 | 33.0k | _cached_size_ = 0; |
3319 | 33.0k | name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3320 | 33.0k | ::memset(&size_bytes_, 0, static_cast<size_t>( |
3321 | 33.0k | reinterpret_cast<char*>(&inode_) - |
3322 | 33.0k | reinterpret_cast<char*>(&size_bytes_)) + sizeof(inode_)); |
3323 | 33.0k | } |
3324 | | |
3325 | 15.9k | FilePB::~FilePB() { |
3326 | | // @@protoc_insertion_point(destructor:yb.tablet.FilePB) |
3327 | 15.9k | SharedDtor(); |
3328 | 15.9k | } |
3329 | | |
3330 | 15.9k | void FilePB::SharedDtor() { |
3331 | 15.9k | name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3332 | 15.9k | } |
3333 | | |
3334 | 0 | void FilePB::SetCachedSize(int size) const { |
3335 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
3336 | 0 | _cached_size_ = size; |
3337 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
3338 | 0 | } |
3339 | 0 | const ::google::protobuf::Descriptor* FilePB::descriptor() { |
3340 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
3341 | 0 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
3342 | 0 | } |
3343 | | |
3344 | 0 | const FilePB& FilePB::default_instance() { |
3345 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsFilePB(); |
3346 | 0 | return *internal_default_instance(); |
3347 | 0 | } |
3348 | | |
3349 | 0 | FilePB* FilePB::New(::google::protobuf::Arena* arena) const { |
3350 | 0 | FilePB* n = new FilePB; |
3351 | 0 | if (arena != NULL) { |
3352 | 0 | arena->Own(n); |
3353 | 0 | } |
3354 | 0 | return n; |
3355 | 0 | } |
3356 | | |
3357 | 0 | void FilePB::Clear() { |
3358 | | // @@protoc_insertion_point(message_clear_start:yb.tablet.FilePB) |
3359 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
3360 | | // Prevent compiler warnings about cached_has_bits being unused |
3361 | 0 | (void) cached_has_bits; |
3362 | |
|
3363 | 0 | cached_has_bits = _has_bits_[0]; |
3364 | 0 | if (cached_has_bits & 0x00000001u) { |
3365 | 0 | GOOGLE_DCHECK(!name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
3366 | 0 | (*name_.UnsafeRawStringPointer())->clear(); |
3367 | 0 | } |
3368 | 0 | if (cached_has_bits & 6u) { |
3369 | 0 | ::memset(&size_bytes_, 0, static_cast<size_t>( |
3370 | 0 | reinterpret_cast<char*>(&inode_) - |
3371 | 0 | reinterpret_cast<char*>(&size_bytes_)) + sizeof(inode_)); |
3372 | 0 | } |
3373 | 0 | _has_bits_.Clear(); |
3374 | 0 | _internal_metadata_.Clear(); |
3375 | 0 | } |
3376 | | |
3377 | | bool FilePB::MergePartialFromCodedStream( |
3378 | 4.48k | ::google::protobuf::io::CodedInputStream* input) { |
3379 | 13.4k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
3380 | 4.48k | ::google::protobuf::uint32 tag; |
3381 | | // @@protoc_insertion_point(parse_start:yb.tablet.FilePB) |
3382 | 17.9k | for (;;) { |
3383 | 17.9k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
3384 | 17.9k | tag = p.first; |
3385 | 17.9k | if (!p.second) goto handle_unusual; |
3386 | 13.4k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
3387 | | // optional string name = 1; |
3388 | 4.48k | case 1: { |
3389 | 4.48k | if (static_cast< ::google::protobuf::uint8>(tag) == |
3390 | 4.48k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
3391 | 4.48k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
3392 | 4.48k | input, this->mutable_name())); |
3393 | 4.48k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
3394 | 4.48k | this->name().data(), static_cast<int>(this->name().length()), |
3395 | 4.48k | ::google::protobuf::internal::WireFormat::PARSE, |
3396 | 4.48k | "yb.tablet.FilePB.name"); |
3397 | 1 | } else { |
3398 | 1 | goto handle_unusual; |
3399 | 1 | } |
3400 | 4.48k | break; |
3401 | 4.48k | } |
3402 | | |
3403 | | // optional uint64 size_bytes = 2; |
3404 | 4.48k | case 2: { |
3405 | 4.48k | if (static_cast< ::google::protobuf::uint8>(tag) == |
3406 | 4.48k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
3407 | 4.48k | set_has_size_bytes(); |
3408 | 4.48k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
3409 | 4.48k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
3410 | 4.48k | input, &size_bytes_))); |
3411 | 0 | } else { |
3412 | 0 | goto handle_unusual; |
3413 | 0 | } |
3414 | 4.48k | break; |
3415 | 4.48k | } |
3416 | | |
3417 | | // optional uint64 inode = 3; |
3418 | 4.48k | case 3: { |
3419 | 4.48k | if (static_cast< ::google::protobuf::uint8>(tag) == |
3420 | 4.48k | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
3421 | 4.48k | set_has_inode(); |
3422 | 4.48k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
3423 | 4.48k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
3424 | 4.48k | input, &inode_))); |
3425 | 0 | } else { |
3426 | 0 | goto handle_unusual; |
3427 | 0 | } |
3428 | 4.48k | break; |
3429 | 4.48k | } |
3430 | | |
3431 | 0 | default: { |
3432 | 4.48k | handle_unusual: |
3433 | 4.48k | if (tag == 0) { |
3434 | 4.48k | goto success; |
3435 | 4.48k | } |
3436 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
3437 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
3438 | 0 | break; |
3439 | 0 | } |
3440 | 13.4k | } |
3441 | 13.4k | } |
3442 | 4.48k | success: |
3443 | | // @@protoc_insertion_point(parse_success:yb.tablet.FilePB) |
3444 | 4.48k | return true; |
3445 | 0 | failure: |
3446 | | // @@protoc_insertion_point(parse_failure:yb.tablet.FilePB) |
3447 | 0 | return false; |
3448 | 4.48k | #undef DO_ |
3449 | 4.48k | } |
3450 | | |
3451 | | void FilePB::SerializeWithCachedSizes( |
3452 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
3453 | | // @@protoc_insertion_point(serialize_start:yb.tablet.FilePB) |
3454 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
3455 | 0 | (void) cached_has_bits; |
3456 | |
|
3457 | 0 | cached_has_bits = _has_bits_[0]; |
3458 | | // optional string name = 1; |
3459 | 0 | if (cached_has_bits & 0x00000001u) { |
3460 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
3461 | 0 | this->name().data(), static_cast<int>(this->name().length()), |
3462 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
3463 | 0 | "yb.tablet.FilePB.name"); |
3464 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
3465 | 0 | 1, this->name(), output); |
3466 | 0 | } |
3467 | | |
3468 | | // optional uint64 size_bytes = 2; |
3469 | 0 | if (cached_has_bits & 0x00000002u) { |
3470 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->size_bytes(), output); |
3471 | 0 | } |
3472 | | |
3473 | | // optional uint64 inode = 3; |
3474 | 0 | if (cached_has_bits & 0x00000004u) { |
3475 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->inode(), output); |
3476 | 0 | } |
3477 | |
|
3478 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
3479 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
3480 | 0 | _internal_metadata_.unknown_fields(), output); |
3481 | 0 | } |
3482 | | // @@protoc_insertion_point(serialize_end:yb.tablet.FilePB) |
3483 | 0 | } |
3484 | | |
3485 | | ::google::protobuf::uint8* FilePB::InternalSerializeWithCachedSizesToArray( |
3486 | 8.47k | bool deterministic, ::google::protobuf::uint8* target) const { |
3487 | 8.47k | (void)deterministic; // Unused |
3488 | | // @@protoc_insertion_point(serialize_to_array_start:yb.tablet.FilePB) |
3489 | 8.47k | ::google::protobuf::uint32 cached_has_bits = 0; |
3490 | 8.47k | (void) cached_has_bits; |
3491 | | |
3492 | 8.47k | cached_has_bits = _has_bits_[0]; |
3493 | | // optional string name = 1; |
3494 | 8.47k | if (cached_has_bits & 0x00000001u) { |
3495 | 8.47k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
3496 | 8.47k | this->name().data(), static_cast<int>(this->name().length()), |
3497 | 8.47k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
3498 | 8.47k | "yb.tablet.FilePB.name"); |
3499 | 8.47k | target = |
3500 | 8.47k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
3501 | 8.47k | 1, this->name(), target); |
3502 | 8.47k | } |
3503 | | |
3504 | | // optional uint64 size_bytes = 2; |
3505 | 8.47k | if (cached_has_bits & 0x00000002u) { |
3506 | 8.47k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->size_bytes(), target); |
3507 | 8.47k | } |
3508 | | |
3509 | | // optional uint64 inode = 3; |
3510 | 8.47k | if (cached_has_bits & 0x00000004u) { |
3511 | 8.47k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->inode(), target); |
3512 | 8.47k | } |
3513 | | |
3514 | 8.47k | if (_internal_metadata_.have_unknown_fields()) { |
3515 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
3516 | 0 | _internal_metadata_.unknown_fields(), target); |
3517 | 0 | } |
3518 | | // @@protoc_insertion_point(serialize_to_array_end:yb.tablet.FilePB) |
3519 | 8.47k | return target; |
3520 | 8.47k | } |
3521 | | |
3522 | 12.9k | size_t FilePB::ByteSizeLong() const { |
3523 | | // @@protoc_insertion_point(message_byte_size_start:yb.tablet.FilePB) |
3524 | 12.9k | size_t total_size = 0; |
3525 | | |
3526 | 12.9k | if (_internal_metadata_.have_unknown_fields()) { |
3527 | 0 | total_size += |
3528 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
3529 | 0 | _internal_metadata_.unknown_fields()); |
3530 | 0 | } |
3531 | 12.9k | if (_has_bits_[0 / 32] & 7u) { |
3532 | | // optional string name = 1; |
3533 | 12.9k | if (has_name()) { |
3534 | 12.9k | total_size += 1 + |
3535 | 12.9k | ::google::protobuf::internal::WireFormatLite::StringSize( |
3536 | 12.9k | this->name()); |
3537 | 12.9k | } |
3538 | | |
3539 | | // optional uint64 size_bytes = 2; |
3540 | 12.9k | if (has_size_bytes()) { |
3541 | 12.9k | total_size += 1 + |
3542 | 12.9k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
3543 | 12.9k | this->size_bytes()); |
3544 | 12.9k | } |
3545 | | |
3546 | | // optional uint64 inode = 3; |
3547 | 12.9k | if (has_inode()) { |
3548 | 12.9k | total_size += 1 + |
3549 | 12.9k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
3550 | 12.9k | this->inode()); |
3551 | 12.9k | } |
3552 | | |
3553 | 12.9k | } |
3554 | 12.9k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
3555 | 12.9k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
3556 | 12.9k | _cached_size_ = cached_size; |
3557 | 12.9k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
3558 | 12.9k | return total_size; |
3559 | 12.9k | } |
3560 | | |
3561 | 0 | void FilePB::MergeFrom(const ::google::protobuf::Message& from) { |
3562 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.tablet.FilePB) |
3563 | 0 | GOOGLE_DCHECK_NE(&from, this); |
3564 | 0 | const FilePB* source = |
3565 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const FilePB>( |
3566 | 0 | &from); |
3567 | 0 | if (source == NULL) { |
3568 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.tablet.FilePB) |
3569 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
3570 | 0 | } else { |
3571 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.tablet.FilePB) |
3572 | 0 | MergeFrom(*source); |
3573 | 0 | } |
3574 | 0 | } |
3575 | | |
3576 | 8.07k | void FilePB::MergeFrom(const FilePB& from) { |
3577 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.tablet.FilePB) |
3578 | 8.07k | GOOGLE_DCHECK_NE(&from, this); |
3579 | 8.07k | _internal_metadata_.MergeFrom(from._internal_metadata_); |
3580 | 8.07k | ::google::protobuf::uint32 cached_has_bits = 0; |
3581 | 8.07k | (void) cached_has_bits; |
3582 | | |
3583 | 8.07k | cached_has_bits = from._has_bits_[0]; |
3584 | 8.07k | if (cached_has_bits & 7u) { |
3585 | 8.07k | if (cached_has_bits & 0x00000001u) { |
3586 | 8.07k | set_has_name(); |
3587 | 8.07k | name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.name_); |
3588 | 8.07k | } |
3589 | 8.07k | if (cached_has_bits & 0x00000002u) { |
3590 | 8.07k | size_bytes_ = from.size_bytes_; |
3591 | 8.07k | } |
3592 | 8.07k | if (cached_has_bits & 0x00000004u) { |
3593 | 8.07k | inode_ = from.inode_; |
3594 | 8.07k | } |
3595 | 8.07k | _has_bits_[0] |= cached_has_bits; |
3596 | 8.07k | } |
3597 | 8.07k | } |
3598 | | |
3599 | 0 | void FilePB::CopyFrom(const ::google::protobuf::Message& from) { |
3600 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.tablet.FilePB) |
3601 | 0 | if (&from == this) return; |
3602 | 0 | Clear(); |
3603 | 0 | MergeFrom(from); |
3604 | 0 | } |
3605 | | |
3606 | 0 | void FilePB::CopyFrom(const FilePB& from) { |
3607 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.tablet.FilePB) |
3608 | 0 | if (&from == this) return; |
3609 | 0 | Clear(); |
3610 | 0 | MergeFrom(from); |
3611 | 0 | } |
3612 | | |
3613 | 0 | bool FilePB::IsInitialized() const { |
3614 | 0 | return true; |
3615 | 0 | } |
3616 | | |
3617 | 0 | void FilePB::Swap(FilePB* other) { |
3618 | 0 | if (other == this) return; |
3619 | 0 | InternalSwap(other); |
3620 | 0 | } |
3621 | 114 | void FilePB::InternalSwap(FilePB* other) { |
3622 | 114 | using std::swap; |
3623 | 114 | name_.Swap(&other->name_); |
3624 | 114 | swap(size_bytes_, other->size_bytes_); |
3625 | 114 | swap(inode_, other->inode_); |
3626 | 114 | swap(_has_bits_[0], other->_has_bits_[0]); |
3627 | 114 | _internal_metadata_.Swap(&other->_internal_metadata_); |
3628 | 114 | swap(_cached_size_, other->_cached_size_); |
3629 | 114 | } |
3630 | | |
3631 | 17.8k | ::google::protobuf::Metadata FilePB::GetMetadata() const { |
3632 | 17.8k | protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
3633 | 17.8k | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages]; |
3634 | 17.8k | } |
3635 | | |
3636 | | |
3637 | | // =================================================================== |
3638 | | |
3639 | 15.8k | void SnapshotFilePB::InitAsDefaultInstance() { |
3640 | 15.8k | ::yb::tablet::_SnapshotFilePB_default_instance_._instance.get_mutable()->file_ = const_cast< ::yb::tablet::FilePB*>( |
3641 | 15.8k | ::yb::tablet::FilePB::internal_default_instance()); |
3642 | 15.8k | } |
3643 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
3644 | | const int SnapshotFilePB::kFileFieldNumber; |
3645 | | const int SnapshotFilePB::kSnapshotIdFieldNumber; |
3646 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
3647 | | |
3648 | | SnapshotFilePB::SnapshotFilePB() |
3649 | 16.0k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
3650 | 248 | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
3651 | 248 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsSnapshotFilePB(); |
3652 | 248 | } |
3653 | 16.0k | SharedCtor(); |
3654 | | // @@protoc_insertion_point(constructor:yb.tablet.SnapshotFilePB) |
3655 | 16.0k | } |
3656 | | SnapshotFilePB::SnapshotFilePB(const SnapshotFilePB& from) |
3657 | | : ::google::protobuf::Message(), |
3658 | | _internal_metadata_(NULL), |
3659 | | _has_bits_(from._has_bits_), |
3660 | 0 | _cached_size_(0) { |
3661 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
3662 | 0 | snapshot_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3663 | 0 | if (from.has_snapshot_id()) { |
3664 | 0 | snapshot_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.snapshot_id_); |
3665 | 0 | } |
3666 | 0 | if (from.has_file()) { |
3667 | 0 | file_ = new ::yb::tablet::FilePB(*from.file_); |
3668 | 0 | } else { |
3669 | 0 | file_ = NULL; |
3670 | 0 | } |
3671 | | // @@protoc_insertion_point(copy_constructor:yb.tablet.SnapshotFilePB) |
3672 | 0 | } |
3673 | | |
3674 | 16.0k | void SnapshotFilePB::SharedCtor() { |
3675 | 16.0k | _cached_size_ = 0; |
3676 | 16.0k | snapshot_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3677 | 16.0k | file_ = NULL; |
3678 | 16.0k | } |
3679 | | |
3680 | 248 | SnapshotFilePB::~SnapshotFilePB() { |
3681 | | // @@protoc_insertion_point(destructor:yb.tablet.SnapshotFilePB) |
3682 | 248 | SharedDtor(); |
3683 | 248 | } |
3684 | | |
3685 | 248 | void SnapshotFilePB::SharedDtor() { |
3686 | 248 | snapshot_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
3687 | 248 | if (this != internal_default_instance()) delete file_; |
3688 | 248 | } |
3689 | | |
3690 | 0 | void SnapshotFilePB::SetCachedSize(int size) const { |
3691 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
3692 | 0 | _cached_size_ = size; |
3693 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
3694 | 0 | } |
3695 | 0 | const ::google::protobuf::Descriptor* SnapshotFilePB::descriptor() { |
3696 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
3697 | 0 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
3698 | 0 | } |
3699 | | |
3700 | 0 | const SnapshotFilePB& SnapshotFilePB::default_instance() { |
3701 | 0 | ::protobuf_yb_2ftablet_2fmetadata_2eproto::InitDefaultsSnapshotFilePB(); |
3702 | 0 | return *internal_default_instance(); |
3703 | 0 | } |
3704 | | |
3705 | 0 | SnapshotFilePB* SnapshotFilePB::New(::google::protobuf::Arena* arena) const { |
3706 | 0 | SnapshotFilePB* n = new SnapshotFilePB; |
3707 | 0 | if (arena != NULL) { |
3708 | 0 | arena->Own(n); |
3709 | 0 | } |
3710 | 0 | return n; |
3711 | 0 | } |
3712 | | |
3713 | 0 | void SnapshotFilePB::Clear() { |
3714 | | // @@protoc_insertion_point(message_clear_start:yb.tablet.SnapshotFilePB) |
3715 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
3716 | | // Prevent compiler warnings about cached_has_bits being unused |
3717 | 0 | (void) cached_has_bits; |
3718 | |
|
3719 | 0 | cached_has_bits = _has_bits_[0]; |
3720 | 0 | if (cached_has_bits & 3u) { |
3721 | 0 | if (cached_has_bits & 0x00000001u) { |
3722 | 0 | GOOGLE_DCHECK(!snapshot_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
3723 | 0 | (*snapshot_id_.UnsafeRawStringPointer())->clear(); |
3724 | 0 | } |
3725 | 0 | if (cached_has_bits & 0x00000002u) { |
3726 | 0 | GOOGLE_DCHECK(file_ != NULL); |
3727 | 0 | file_->Clear(); |
3728 | 0 | } |
3729 | 0 | } |
3730 | 0 | _has_bits_.Clear(); |
3731 | 0 | _internal_metadata_.Clear(); |
3732 | 0 | } |
3733 | | |
3734 | | bool SnapshotFilePB::MergePartialFromCodedStream( |
3735 | 60 | ::google::protobuf::io::CodedInputStream* input) { |
3736 | 120 | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure |
3737 | 60 | ::google::protobuf::uint32 tag; |
3738 | | // @@protoc_insertion_point(parse_start:yb.tablet.SnapshotFilePB) |
3739 | 180 | for (;;) { |
3740 | 180 | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
3741 | 180 | tag = p.first; |
3742 | 180 | if (!p.second) goto handle_unusual; |
3743 | 120 | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
3744 | | // optional .yb.tablet.FilePB file = 1; |
3745 | 60 | case 1: { |
3746 | 60 | if (static_cast< ::google::protobuf::uint8>(tag) == |
3747 | 60 | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
3748 | 60 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
3749 | 60 | input, mutable_file())); |
3750 | 0 | } else { |
3751 | 0 | goto handle_unusual; |
3752 | 0 | } |
3753 | 60 | break; |
3754 | 60 | } |
3755 | | |
3756 | | // optional bytes snapshot_id = 2; |
3757 | 60 | case 2: { |
3758 | 60 | if (static_cast< ::google::protobuf::uint8>(tag) == |
3759 | 60 | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
3760 | 60 | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
3761 | 60 | input, this->mutable_snapshot_id())); |
3762 | 0 | } else { |
3763 | 0 | goto handle_unusual; |
3764 | 0 | } |
3765 | 60 | break; |
3766 | 60 | } |
3767 | | |
3768 | 0 | default: { |
3769 | 60 | handle_unusual: |
3770 | 60 | if (tag == 0) { |
3771 | 60 | goto success; |
3772 | 60 | } |
3773 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
3774 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
3775 | 0 | break; |
3776 | 0 | } |
3777 | 120 | } |
3778 | 120 | } |
3779 | 60 | success: |
3780 | | // @@protoc_insertion_point(parse_success:yb.tablet.SnapshotFilePB) |
3781 | 60 | return true; |
3782 | 0 | failure: |
3783 | | // @@protoc_insertion_point(parse_failure:yb.tablet.SnapshotFilePB) |
3784 | 0 | return false; |
3785 | 60 | #undef DO_ |
3786 | 60 | } |
3787 | | |
3788 | | void SnapshotFilePB::SerializeWithCachedSizes( |
3789 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
3790 | | // @@protoc_insertion_point(serialize_start:yb.tablet.SnapshotFilePB) |
3791 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
3792 | 0 | (void) cached_has_bits; |
3793 | |
|
3794 | 0 | cached_has_bits = _has_bits_[0]; |
3795 | | // optional .yb.tablet.FilePB file = 1; |
3796 | 0 | if (cached_has_bits & 0x00000002u) { |
3797 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
3798 | 0 | 1, *this->file_, output); |
3799 | 0 | } |
3800 | | |
3801 | | // optional bytes snapshot_id = 2; |
3802 | 0 | if (cached_has_bits & 0x00000001u) { |
3803 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
3804 | 0 | 2, this->snapshot_id(), output); |
3805 | 0 | } |
3806 | |
|
3807 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
3808 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
3809 | 0 | _internal_metadata_.unknown_fields(), output); |
3810 | 0 | } |
3811 | | // @@protoc_insertion_point(serialize_end:yb.tablet.SnapshotFilePB) |
3812 | 0 | } |
3813 | | |
3814 | | ::google::protobuf::uint8* SnapshotFilePB::InternalSerializeWithCachedSizesToArray( |
3815 | 60 | bool deterministic, ::google::protobuf::uint8* target) const { |
3816 | 60 | (void)deterministic; // Unused |
3817 | | // @@protoc_insertion_point(serialize_to_array_start:yb.tablet.SnapshotFilePB) |
3818 | 60 | ::google::protobuf::uint32 cached_has_bits = 0; |
3819 | 60 | (void) cached_has_bits; |
3820 | | |
3821 | 60 | cached_has_bits = _has_bits_[0]; |
3822 | | // optional .yb.tablet.FilePB file = 1; |
3823 | 60 | if (cached_has_bits & 0x00000002u) { |
3824 | 60 | target = ::google::protobuf::internal::WireFormatLite:: |
3825 | 60 | InternalWriteMessageToArray( |
3826 | 60 | 1, *this->file_, deterministic, target); |
3827 | 60 | } |
3828 | | |
3829 | | // optional bytes snapshot_id = 2; |
3830 | 60 | if (cached_has_bits & 0x00000001u) { |
3831 | 60 | target = |
3832 | 60 | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
3833 | 60 | 2, this->snapshot_id(), target); |
3834 | 60 | } |
3835 | | |
3836 | 60 | if (_internal_metadata_.have_unknown_fields()) { |
3837 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
3838 | 0 | _internal_metadata_.unknown_fields(), target); |
3839 | 0 | } |
3840 | | // @@protoc_insertion_point(serialize_to_array_end:yb.tablet.SnapshotFilePB) |
3841 | 60 | return target; |
3842 | 60 | } |
3843 | | |
3844 | 120 | size_t SnapshotFilePB::ByteSizeLong() const { |
3845 | | // @@protoc_insertion_point(message_byte_size_start:yb.tablet.SnapshotFilePB) |
3846 | 120 | size_t total_size = 0; |
3847 | | |
3848 | 120 | if (_internal_metadata_.have_unknown_fields()) { |
3849 | 0 | total_size += |
3850 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
3851 | 0 | _internal_metadata_.unknown_fields()); |
3852 | 0 | } |
3853 | 120 | if (_has_bits_[0 / 32] & 3u) { |
3854 | | // optional bytes snapshot_id = 2; |
3855 | 120 | if (has_snapshot_id()) { |
3856 | 120 | total_size += 1 + |
3857 | 120 | ::google::protobuf::internal::WireFormatLite::BytesSize( |
3858 | 120 | this->snapshot_id()); |
3859 | 120 | } |
3860 | | |
3861 | | // optional .yb.tablet.FilePB file = 1; |
3862 | 120 | if (has_file()) { |
3863 | 120 | total_size += 1 + |
3864 | 120 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
3865 | 120 | *this->file_); |
3866 | 120 | } |
3867 | | |
3868 | 120 | } |
3869 | 120 | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
3870 | 120 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
3871 | 120 | _cached_size_ = cached_size; |
3872 | 120 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
3873 | 120 | return total_size; |
3874 | 120 | } |
3875 | | |
3876 | 0 | void SnapshotFilePB::MergeFrom(const ::google::protobuf::Message& from) { |
3877 | | // @@protoc_insertion_point(generalized_merge_from_start:yb.tablet.SnapshotFilePB) |
3878 | 0 | GOOGLE_DCHECK_NE(&from, this); |
3879 | 0 | const SnapshotFilePB* source = |
3880 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const SnapshotFilePB>( |
3881 | 0 | &from); |
3882 | 0 | if (source == NULL) { |
3883 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.tablet.SnapshotFilePB) |
3884 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
3885 | 0 | } else { |
3886 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.tablet.SnapshotFilePB) |
3887 | 0 | MergeFrom(*source); |
3888 | 0 | } |
3889 | 0 | } |
3890 | | |
3891 | 124 | void SnapshotFilePB::MergeFrom(const SnapshotFilePB& from) { |
3892 | | // @@protoc_insertion_point(class_specific_merge_from_start:yb.tablet.SnapshotFilePB) |
3893 | 124 | GOOGLE_DCHECK_NE(&from, this); |
3894 | 124 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
3895 | 124 | ::google::protobuf::uint32 cached_has_bits = 0; |
3896 | 124 | (void) cached_has_bits; |
3897 | | |
3898 | 124 | cached_has_bits = from._has_bits_[0]; |
3899 | 124 | if (cached_has_bits & 3u) { |
3900 | 124 | if (cached_has_bits & 0x00000001u) { |
3901 | 124 | set_has_snapshot_id(); |
3902 | 124 | snapshot_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.snapshot_id_); |
3903 | 124 | } |
3904 | 124 | if (cached_has_bits & 0x00000002u) { |
3905 | 124 | mutable_file()->::yb::tablet::FilePB::MergeFrom(from.file()); |
3906 | 124 | } |
3907 | 124 | } |
3908 | 124 | } |
3909 | | |
3910 | 0 | void SnapshotFilePB::CopyFrom(const ::google::protobuf::Message& from) { |
3911 | | // @@protoc_insertion_point(generalized_copy_from_start:yb.tablet.SnapshotFilePB) |
3912 | 0 | if (&from == this) return; |
3913 | 0 | Clear(); |
3914 | 0 | MergeFrom(from); |
3915 | 0 | } |
3916 | | |
3917 | 0 | void SnapshotFilePB::CopyFrom(const SnapshotFilePB& from) { |
3918 | | // @@protoc_insertion_point(class_specific_copy_from_start:yb.tablet.SnapshotFilePB) |
3919 | 0 | if (&from == this) return; |
3920 | 0 | Clear(); |
3921 | 0 | MergeFrom(from); |
3922 | 0 | } |
3923 | | |
3924 | 0 | bool SnapshotFilePB::IsInitialized() const { |
3925 | 0 | return true; |
3926 | 0 | } |
3927 | | |
3928 | 0 | void SnapshotFilePB::Swap(SnapshotFilePB* other) { |
3929 | 0 | if (other == this) return; |
3930 | 0 | InternalSwap(other); |
3931 | 0 | } |
3932 | 0 | void SnapshotFilePB::InternalSwap(SnapshotFilePB* other) { |
3933 | 0 | using std::swap; |
3934 | 0 | snapshot_id_.Swap(&other->snapshot_id_); |
3935 | 0 | swap(file_, other->file_); |
3936 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
3937 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
3938 | 0 | swap(_cached_size_, other->_cached_size_); |
3939 | 0 | } |
3940 | | |
3941 | 248 | ::google::protobuf::Metadata SnapshotFilePB::GetMetadata() const { |
3942 | 248 | protobuf_yb_2ftablet_2fmetadata_2eproto::protobuf_AssignDescriptorsOnce(); |
3943 | 248 | return ::protobuf_yb_2ftablet_2fmetadata_2eproto::file_level_metadata[kIndexInFileMessages]; |
3944 | 248 | } |
3945 | | |
3946 | | |
3947 | | // @@protoc_insertion_point(namespace_scope) |
3948 | | } // namespace tablet |
3949 | | } // namespace yb |
3950 | | |
3951 | | // @@protoc_insertion_point(global_scope) |