/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/rocksdb/db/version_edit.pb.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // Generated by the protocol buffer compiler. DO NOT EDIT! |
2 | | // source: yb/rocksdb/db/version_edit.proto |
3 | | |
4 | | #include "yb/rocksdb/db/version_edit.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 rocksdb { |
24 | | class DeletedFilePBDefaultTypeInternal { |
25 | | public: |
26 | | ::google::protobuf::internal::ExplicitlyConstructed<DeletedFilePB> |
27 | | _instance; |
28 | | } _DeletedFilePB_default_instance_; |
29 | | class UserBoundaryValuePBDefaultTypeInternal { |
30 | | public: |
31 | | ::google::protobuf::internal::ExplicitlyConstructed<UserBoundaryValuePB> |
32 | | _instance; |
33 | | } _UserBoundaryValuePB_default_instance_; |
34 | | class BoundaryValuesPBDefaultTypeInternal { |
35 | | public: |
36 | | ::google::protobuf::internal::ExplicitlyConstructed<BoundaryValuesPB> |
37 | | _instance; |
38 | | } _BoundaryValuesPB_default_instance_; |
39 | | class NewFilePBDefaultTypeInternal { |
40 | | public: |
41 | | ::google::protobuf::internal::ExplicitlyConstructed<NewFilePB> |
42 | | _instance; |
43 | | } _NewFilePB_default_instance_; |
44 | | class VersionEditPBDefaultTypeInternal { |
45 | | public: |
46 | | ::google::protobuf::internal::ExplicitlyConstructed<VersionEditPB> |
47 | | _instance; |
48 | | } _VersionEditPB_default_instance_; |
49 | | } // namespace rocksdb |
50 | | namespace protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto { |
51 | 28.1k | void InitDefaultsDeletedFilePBImpl() { |
52 | 28.1k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
53 | | |
54 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
55 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
56 | | #else |
57 | 28.1k | ::google::protobuf::internal::InitProtobufDefaults(); |
58 | 28.1k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
59 | 28.1k | { |
60 | 28.1k | void* ptr = &::rocksdb::_DeletedFilePB_default_instance_; |
61 | 28.1k | new (ptr) ::rocksdb::DeletedFilePB(); |
62 | 28.1k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
63 | 28.1k | } |
64 | 28.1k | ::rocksdb::DeletedFilePB::InitAsDefaultInstance(); |
65 | 28.1k | } |
66 | | |
67 | 137k | void InitDefaultsDeletedFilePB() { |
68 | 137k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
69 | 137k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsDeletedFilePBImpl); |
70 | 137k | } |
71 | | |
72 | 28.1k | void InitDefaultsUserBoundaryValuePBImpl() { |
73 | 28.1k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
74 | | |
75 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
76 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
77 | | #else |
78 | 28.1k | ::google::protobuf::internal::InitProtobufDefaults(); |
79 | 28.1k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
80 | 28.1k | { |
81 | 28.1k | void* ptr = &::rocksdb::_UserBoundaryValuePB_default_instance_; |
82 | 28.1k | new (ptr) ::rocksdb::UserBoundaryValuePB(); |
83 | 28.1k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
84 | 28.1k | } |
85 | 28.1k | ::rocksdb::UserBoundaryValuePB::InitAsDefaultInstance(); |
86 | 28.1k | } |
87 | | |
88 | 425k | void InitDefaultsUserBoundaryValuePB() { |
89 | 425k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
90 | 425k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsUserBoundaryValuePBImpl); |
91 | 425k | } |
92 | | |
93 | 28.1k | void InitDefaultsBoundaryValuesPBImpl() { |
94 | 28.1k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
95 | | |
96 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
97 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
98 | | #else |
99 | 28.1k | ::google::protobuf::internal::InitProtobufDefaults(); |
100 | 28.1k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
101 | 28.1k | protobuf_google_2fprotobuf_2fany_2eproto::InitDefaultsAny(); |
102 | 28.1k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsUserBoundaryValuePB(); |
103 | 28.1k | { |
104 | 28.1k | void* ptr = &::rocksdb::_BoundaryValuesPB_default_instance_; |
105 | 28.1k | new (ptr) ::rocksdb::BoundaryValuesPB(); |
106 | 28.1k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
107 | 28.1k | } |
108 | 28.1k | ::rocksdb::BoundaryValuesPB::InitAsDefaultInstance(); |
109 | 28.1k | } |
110 | | |
111 | 409k | void InitDefaultsBoundaryValuesPB() { |
112 | 409k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
113 | 409k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsBoundaryValuesPBImpl); |
114 | 409k | } |
115 | | |
116 | 28.1k | void InitDefaultsNewFilePBImpl() { |
117 | 28.1k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
118 | | |
119 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
120 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
121 | | #else |
122 | 28.1k | ::google::protobuf::internal::InitProtobufDefaults(); |
123 | 28.1k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
124 | 28.1k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsBoundaryValuesPB(); |
125 | 28.1k | protobuf_yb_2futil_2fopid_2eproto::InitDefaultsOpIdPB(); |
126 | 28.1k | { |
127 | 28.1k | void* ptr = &::rocksdb::_NewFilePB_default_instance_; |
128 | 28.1k | new (ptr) ::rocksdb::NewFilePB(); |
129 | 28.1k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
130 | 28.1k | } |
131 | 28.1k | ::rocksdb::NewFilePB::InitAsDefaultInstance(); |
132 | 28.1k | } |
133 | | |
134 | 232k | void InitDefaultsNewFilePB() { |
135 | 232k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
136 | 232k | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsNewFilePBImpl); |
137 | 232k | } |
138 | | |
139 | 28.1k | void InitDefaultsVersionEditPBImpl() { |
140 | 28.1k | GOOGLE_PROTOBUF_VERIFY_VERSION; |
141 | | |
142 | | #ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
143 | | ::google::protobuf::internal::InitProtobufDefaultsForceUnique(); |
144 | | #else |
145 | 28.1k | ::google::protobuf::internal::InitProtobufDefaults(); |
146 | 28.1k | #endif // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS |
147 | 28.1k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsDeletedFilePB(); |
148 | 28.1k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsNewFilePB(); |
149 | 28.1k | protobuf_yb_2futil_2fopid_2eproto::InitDefaultsOpIdPB(); |
150 | 28.1k | protobuf_google_2fprotobuf_2fany_2eproto::InitDefaultsAny(); |
151 | 28.1k | { |
152 | 28.1k | void* ptr = &::rocksdb::_VersionEditPB_default_instance_; |
153 | 28.1k | new (ptr) ::rocksdb::VersionEditPB(); |
154 | 28.1k | ::google::protobuf::internal::OnShutdownDestroyMessage(ptr); |
155 | 28.1k | } |
156 | 28.1k | ::rocksdb::VersionEditPB::InitAsDefaultInstance(); |
157 | 28.1k | } |
158 | | |
159 | 2.38M | void InitDefaultsVersionEditPB() { |
160 | 2.38M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
161 | 2.38M | ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsVersionEditPBImpl); |
162 | 2.38M | } |
163 | | |
164 | | ::google::protobuf::Metadata file_level_metadata[5]; |
165 | | |
166 | | const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
167 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::DeletedFilePB, _has_bits_), |
168 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::DeletedFilePB, _internal_metadata_), |
169 | | ~0u, // no _extensions_ |
170 | | ~0u, // no _oneof_case_ |
171 | | ~0u, // no _weak_field_map_ |
172 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::DeletedFilePB, level_), |
173 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::DeletedFilePB, file_number_), |
174 | | 1, |
175 | | 0, |
176 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::UserBoundaryValuePB, _has_bits_), |
177 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::UserBoundaryValuePB, _internal_metadata_), |
178 | | ~0u, // no _extensions_ |
179 | | ~0u, // no _oneof_case_ |
180 | | ~0u, // no _weak_field_map_ |
181 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::UserBoundaryValuePB, tag_), |
182 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::UserBoundaryValuePB, data_), |
183 | | 1, |
184 | | 0, |
185 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, _has_bits_), |
186 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, _internal_metadata_), |
187 | | ~0u, // no _extensions_ |
188 | | ~0u, // no _oneof_case_ |
189 | | ~0u, // no _weak_field_map_ |
190 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, key_), |
191 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, seqno_), |
192 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, user_frontier_), |
193 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::BoundaryValuesPB, user_values_), |
194 | | 0, |
195 | | 2, |
196 | | 1, |
197 | | ~0u, |
198 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, _has_bits_), |
199 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, _internal_metadata_), |
200 | | ~0u, // no _extensions_ |
201 | | ~0u, // no _oneof_case_ |
202 | | ~0u, // no _weak_field_map_ |
203 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, level_), |
204 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, number_), |
205 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, total_file_size_), |
206 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, base_file_size_), |
207 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, smallest_), |
208 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, largest_), |
209 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, path_id_), |
210 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, marked_for_compaction_), |
211 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, obsolete_last_op_id_), |
212 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::NewFilePB, imported_), |
213 | | 6, |
214 | | 3, |
215 | | 4, |
216 | | 5, |
217 | | 0, |
218 | | 1, |
219 | | 7, |
220 | | 8, |
221 | | 2, |
222 | | 9, |
223 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, _has_bits_), |
224 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, _internal_metadata_), |
225 | | ~0u, // no _extensions_ |
226 | | ~0u, // no _oneof_case_ |
227 | | ~0u, // no _weak_field_map_ |
228 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, comparator_), |
229 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, log_number_), |
230 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, prev_log_number_), |
231 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, next_file_number_), |
232 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, max_column_family_), |
233 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, last_sequence_), |
234 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, deleted_files_), |
235 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, new_files_), |
236 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, column_family_), |
237 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, column_family_name_), |
238 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, is_column_family_drop_), |
239 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, obsolete_last_op_id_), |
240 | | GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::rocksdb::VersionEditPB, flushed_frontier_), |
241 | | 0, |
242 | | 4, |
243 | | 5, |
244 | | 6, |
245 | | 8, |
246 | | 7, |
247 | | ~0u, |
248 | | ~0u, |
249 | | 9, |
250 | | 1, |
251 | | 10, |
252 | | 2, |
253 | | 3, |
254 | | }; |
255 | | static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
256 | | { 0, 7, sizeof(::rocksdb::DeletedFilePB)}, |
257 | | { 9, 16, sizeof(::rocksdb::UserBoundaryValuePB)}, |
258 | | { 18, 27, sizeof(::rocksdb::BoundaryValuesPB)}, |
259 | | { 31, 46, sizeof(::rocksdb::NewFilePB)}, |
260 | | { 56, 74, sizeof(::rocksdb::VersionEditPB)}, |
261 | | }; |
262 | | |
263 | | static ::google::protobuf::Message const * const file_default_instances[] = { |
264 | | reinterpret_cast<const ::google::protobuf::Message*>(&::rocksdb::_DeletedFilePB_default_instance_), |
265 | | reinterpret_cast<const ::google::protobuf::Message*>(&::rocksdb::_UserBoundaryValuePB_default_instance_), |
266 | | reinterpret_cast<const ::google::protobuf::Message*>(&::rocksdb::_BoundaryValuesPB_default_instance_), |
267 | | reinterpret_cast<const ::google::protobuf::Message*>(&::rocksdb::_NewFilePB_default_instance_), |
268 | | reinterpret_cast<const ::google::protobuf::Message*>(&::rocksdb::_VersionEditPB_default_instance_), |
269 | | }; |
270 | | |
271 | 3.70k | void protobuf_AssignDescriptors() { |
272 | 3.70k | AddDescriptors(); |
273 | 3.70k | ::google::protobuf::MessageFactory* factory = NULL; |
274 | 3.70k | AssignDescriptors( |
275 | 3.70k | "yb/rocksdb/db/version_edit.proto", schemas, file_default_instances, TableStruct::offsets, factory, |
276 | 3.70k | file_level_metadata, NULL, NULL); |
277 | 3.70k | } |
278 | | |
279 | 1.47M | void protobuf_AssignDescriptorsOnce() { |
280 | 1.47M | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
281 | 1.47M | ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors); |
282 | 1.47M | } |
283 | | |
284 | | void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD; |
285 | 0 | void protobuf_RegisterTypes(const ::std::string&) { |
286 | 0 | protobuf_AssignDescriptorsOnce(); |
287 | 0 | ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 5); |
288 | 0 | } |
289 | | |
290 | 28.1k | void AddDescriptorsImpl() { |
291 | 28.1k | InitDefaults(); |
292 | 28.1k | static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { |
293 | 28.1k | "\n yb/rocksdb/db/version_edit.proto\022\007rock" |
294 | 28.1k | "sdb\032\022yb/util/opid.proto\032\031google/protobuf" |
295 | 28.1k | "/any.proto\"3\n\rDeletedFilePB\022\r\n\005level\030\001 \001" |
296 | 28.1k | "(\r\022\023\n\013file_number\030\002 \001(\004\"0\n\023UserBoundaryV" |
297 | 28.1k | "aluePB\022\013\n\003tag\030\001 \001(\r\022\014\n\004data\030\002 \001(\014\"\216\001\n\020Bo" |
298 | 28.1k | "undaryValuesPB\022\013\n\003key\030\001 \001(\014\022\r\n\005seqno\030\002 \001" |
299 | 28.1k | "(\004\022+\n\ruser_frontier\030\004 \001(\0132\024.google.proto" |
300 | 28.1k | "buf.Any\0221\n\013user_values\030\003 \003(\0132\034.rocksdb.U" |
301 | 28.1k | "serBoundaryValuePB\"\237\002\n\tNewFilePB\022\r\n\005leve" |
302 | 28.1k | "l\030\001 \001(\r\022\016\n\006number\030\002 \001(\004\022\027\n\017total_file_si" |
303 | 28.1k | "ze\030\003 \001(\004\022\026\n\016base_file_size\030\004 \001(\004\022+\n\010smal" |
304 | 28.1k | "lest\030\005 \001(\0132\031.rocksdb.BoundaryValuesPB\022*\n" |
305 | 28.1k | "\007largest\030\006 \001(\0132\031.rocksdb.BoundaryValuesP" |
306 | 28.1k | "B\022\017\n\007path_id\030\007 \001(\r\022\035\n\025marked_for_compact" |
307 | 28.1k | "ion\030\010 \001(\010\022\'\n\023obsolete_last_op_id\030\t \001(\0132\n" |
308 | 28.1k | ".yb.OpIdPB\022\020\n\010imported\030\n \001(\010\"\235\003\n\rVersion" |
309 | 28.1k | "EditPB\022\022\n\ncomparator\030\001 \001(\t\022\022\n\nlog_number" |
310 | 28.1k | "\030\002 \001(\004\022\027\n\017prev_log_number\030\003 \001(\004\022\030\n\020next_" |
311 | 28.1k | "file_number\030\004 \001(\004\022\031\n\021max_column_family\030\005" |
312 | 28.1k | " \001(\r\022\025\n\rlast_sequence\030\006 \001(\004\022-\n\rdeleted_f" |
313 | 28.1k | "iles\030\007 \003(\0132\026.rocksdb.DeletedFilePB\022%\n\tne" |
314 | 28.1k | "w_files\030\010 \003(\0132\022.rocksdb.NewFilePB\022\025\n\rcol" |
315 | 28.1k | "umn_family\030\t \001(\r\022\032\n\022column_family_name\030\n" |
316 | 28.1k | " \001(\t\022\035\n\025is_column_family_drop\030\013 \001(\010\022\'\n\023o" |
317 | 28.1k | "bsolete_last_op_id\030\014 \001(\0132\n.yb.OpIdPB\022.\n\020" |
318 | 28.1k | "flushed_frontier\030\r \001(\0132\024.google.protobuf" |
319 | 28.1k | ".Any" |
320 | 28.1k | }; |
321 | 28.1k | ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( |
322 | 28.1k | descriptor, 1044); |
323 | 28.1k | ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( |
324 | 28.1k | "yb/rocksdb/db/version_edit.proto", &protobuf_RegisterTypes); |
325 | 28.1k | ::protobuf_yb_2futil_2fopid_2eproto::AddDescriptors(); |
326 | 28.1k | ::protobuf_google_2fprotobuf_2fany_2eproto::AddDescriptors(); |
327 | 28.1k | } |
328 | | |
329 | 31.8k | void AddDescriptors() { |
330 | 31.8k | static GOOGLE_PROTOBUF_DECLARE_ONCE(once); |
331 | 31.8k | ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl); |
332 | 31.8k | } |
333 | | // Force AddDescriptors() to be called at dynamic initialization time. |
334 | | struct StaticDescriptorInitializer { |
335 | 28.1k | StaticDescriptorInitializer() { |
336 | 28.1k | AddDescriptors(); |
337 | 28.1k | } |
338 | | } static_descriptor_initializer; |
339 | | } // namespace protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto |
340 | | namespace rocksdb { |
341 | | |
342 | | // =================================================================== |
343 | | |
344 | 28.1k | void DeletedFilePB::InitAsDefaultInstance() { |
345 | 28.1k | } |
346 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
347 | | const int DeletedFilePB::kLevelFieldNumber; |
348 | | const int DeletedFilePB::kFileNumberFieldNumber; |
349 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
350 | | |
351 | | DeletedFilePB::DeletedFilePB() |
352 | 109k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
353 | 109k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
354 | 81.3k | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsDeletedFilePB(); |
355 | 81.3k | } |
356 | 109k | SharedCtor(); |
357 | | // @@protoc_insertion_point(constructor:rocksdb.DeletedFilePB) |
358 | 109k | } |
359 | | DeletedFilePB::DeletedFilePB(const DeletedFilePB& from) |
360 | | : ::google::protobuf::Message(), |
361 | | _internal_metadata_(NULL), |
362 | | _has_bits_(from._has_bits_), |
363 | 0 | _cached_size_(0) { |
364 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
365 | 0 | ::memcpy(&file_number_, &from.file_number_, |
366 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&level_) - |
367 | 0 | reinterpret_cast<char*>(&file_number_)) + sizeof(level_)); |
368 | | // @@protoc_insertion_point(copy_constructor:rocksdb.DeletedFilePB) |
369 | 0 | } |
370 | | |
371 | 109k | void DeletedFilePB::SharedCtor() { |
372 | 109k | _cached_size_ = 0; |
373 | 109k | ::memset(&file_number_, 0, static_cast<size_t>( |
374 | 109k | reinterpret_cast<char*>(&level_) - |
375 | 109k | reinterpret_cast<char*>(&file_number_)) + sizeof(level_)); |
376 | 109k | } |
377 | | |
378 | 81.3k | DeletedFilePB::~DeletedFilePB() { |
379 | | // @@protoc_insertion_point(destructor:rocksdb.DeletedFilePB) |
380 | 81.3k | SharedDtor(); |
381 | 81.3k | } |
382 | | |
383 | 81.3k | void DeletedFilePB::SharedDtor() { |
384 | 81.3k | } |
385 | | |
386 | 0 | void DeletedFilePB::SetCachedSize(int size) const { |
387 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
388 | 0 | _cached_size_ = size; |
389 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
390 | 0 | } |
391 | 0 | const ::google::protobuf::Descriptor* DeletedFilePB::descriptor() { |
392 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
393 | 0 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
394 | 0 | } |
395 | | |
396 | 0 | const DeletedFilePB& DeletedFilePB::default_instance() { |
397 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsDeletedFilePB(); |
398 | 0 | return *internal_default_instance(); |
399 | 0 | } |
400 | | |
401 | 0 | DeletedFilePB* DeletedFilePB::New(::google::protobuf::Arena* arena) const { |
402 | 0 | DeletedFilePB* n = new DeletedFilePB; |
403 | 0 | if (arena != NULL) { |
404 | 0 | arena->Own(n); |
405 | 0 | } |
406 | 0 | return n; |
407 | 0 | } |
408 | | |
409 | 0 | void DeletedFilePB::Clear() { |
410 | | // @@protoc_insertion_point(message_clear_start:rocksdb.DeletedFilePB) |
411 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
412 | | // Prevent compiler warnings about cached_has_bits being unused |
413 | 0 | (void) cached_has_bits; |
414 | |
|
415 | 0 | cached_has_bits = _has_bits_[0]; |
416 | 0 | if (cached_has_bits & 3u) { |
417 | 0 | ::memset(&file_number_, 0, static_cast<size_t>( |
418 | 0 | reinterpret_cast<char*>(&level_) - |
419 | 0 | reinterpret_cast<char*>(&file_number_)) + sizeof(level_)); |
420 | 0 | } |
421 | 0 | _has_bits_.Clear(); |
422 | 0 | _internal_metadata_.Clear(); |
423 | 0 | } |
424 | | |
425 | | bool DeletedFilePB::MergePartialFromCodedStream( |
426 | 15.8k | ::google::protobuf::io::CodedInputStream* input) { |
427 | 31.7k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0 |
428 | 15.8k | ::google::protobuf::uint32 tag; |
429 | | // @@protoc_insertion_point(parse_start:rocksdb.DeletedFilePB) |
430 | 47.6k | for (;;) { |
431 | 47.6k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
432 | 47.6k | tag = p.first; |
433 | 47.6k | if (!p.second) goto handle_unusual15.8k ; |
434 | 31.7k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
435 | | // optional uint32 level = 1; |
436 | 15.8k | case 1: { |
437 | 15.8k | if (static_cast< ::google::protobuf::uint8>(tag) == |
438 | 15.8k | static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) { |
439 | 15.8k | set_has_level(); |
440 | 15.8k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
441 | 15.8k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
442 | 15.8k | input, &level_))); |
443 | 15.8k | } else { |
444 | 0 | goto handle_unusual; |
445 | 0 | } |
446 | 15.8k | break; |
447 | 15.8k | } |
448 | | |
449 | | // optional uint64 file_number = 2; |
450 | 15.8k | case 2: { |
451 | 15.8k | if (static_cast< ::google::protobuf::uint8>(tag) == |
452 | 15.8k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
453 | 15.8k | set_has_file_number(); |
454 | 15.8k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
455 | 15.8k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
456 | 15.8k | input, &file_number_))); |
457 | 15.8k | } else { |
458 | 0 | goto handle_unusual; |
459 | 0 | } |
460 | 15.8k | break; |
461 | 15.8k | } |
462 | | |
463 | 15.8k | default: { |
464 | 15.8k | handle_unusual: |
465 | 15.8k | if (tag == 0) { |
466 | 15.8k | goto success; |
467 | 15.8k | } |
468 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
469 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
470 | 0 | break; |
471 | 0 | } |
472 | 31.7k | } |
473 | 31.7k | } |
474 | 15.8k | success: |
475 | | // @@protoc_insertion_point(parse_success:rocksdb.DeletedFilePB) |
476 | 15.8k | return true; |
477 | 0 | failure: |
478 | | // @@protoc_insertion_point(parse_failure:rocksdb.DeletedFilePB) |
479 | 0 | return false; |
480 | 15.8k | #undef DO_ |
481 | 15.8k | } |
482 | | |
483 | | void DeletedFilePB::SerializeWithCachedSizes( |
484 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
485 | | // @@protoc_insertion_point(serialize_start:rocksdb.DeletedFilePB) |
486 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
487 | 0 | (void) cached_has_bits; |
488 | |
|
489 | 0 | cached_has_bits = _has_bits_[0]; |
490 | | // optional uint32 level = 1; |
491 | 0 | if (cached_has_bits & 0x00000002u) { |
492 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->level(), output); |
493 | 0 | } |
494 | | |
495 | | // optional uint64 file_number = 2; |
496 | 0 | if (cached_has_bits & 0x00000001u) { |
497 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->file_number(), output); |
498 | 0 | } |
499 | |
|
500 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
501 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
502 | 0 | _internal_metadata_.unknown_fields(), output); |
503 | 0 | } |
504 | | // @@protoc_insertion_point(serialize_end:rocksdb.DeletedFilePB) |
505 | 0 | } |
506 | | |
507 | | ::google::protobuf::uint8* DeletedFilePB::InternalSerializeWithCachedSizesToArray( |
508 | 65.3k | bool deterministic, ::google::protobuf::uint8* target) const { |
509 | 65.3k | (void)deterministic; // Unused |
510 | | // @@protoc_insertion_point(serialize_to_array_start:rocksdb.DeletedFilePB) |
511 | 65.3k | ::google::protobuf::uint32 cached_has_bits = 0; |
512 | 65.3k | (void) cached_has_bits; |
513 | | |
514 | 65.3k | cached_has_bits = _has_bits_[0]; |
515 | | // optional uint32 level = 1; |
516 | 65.3k | if (cached_has_bits & 0x00000002u) { |
517 | 65.3k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->level(), target); |
518 | 65.3k | } |
519 | | |
520 | | // optional uint64 file_number = 2; |
521 | 65.3k | if (cached_has_bits & 0x00000001u65.3k ) { |
522 | 65.3k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->file_number(), target); |
523 | 65.3k | } |
524 | | |
525 | 65.3k | if (_internal_metadata_.have_unknown_fields()) { |
526 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
527 | 0 | _internal_metadata_.unknown_fields(), target); |
528 | 0 | } |
529 | | // @@protoc_insertion_point(serialize_to_array_end:rocksdb.DeletedFilePB) |
530 | 65.3k | return target; |
531 | 65.3k | } |
532 | | |
533 | 65.3k | size_t DeletedFilePB::ByteSizeLong() const { |
534 | | // @@protoc_insertion_point(message_byte_size_start:rocksdb.DeletedFilePB) |
535 | 65.3k | size_t total_size = 0; |
536 | | |
537 | 65.3k | if (_internal_metadata_.have_unknown_fields()) { |
538 | 0 | total_size += |
539 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
540 | 0 | _internal_metadata_.unknown_fields()); |
541 | 0 | } |
542 | 65.3k | if (_has_bits_[0 / 32] & 3u) { |
543 | | // optional uint64 file_number = 2; |
544 | 65.3k | if (has_file_number()) { |
545 | 65.3k | total_size += 1 + |
546 | 65.3k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
547 | 65.3k | this->file_number()); |
548 | 65.3k | } |
549 | | |
550 | | // optional uint32 level = 1; |
551 | 65.3k | if (has_level()65.3k ) { |
552 | 65.3k | total_size += 1 + |
553 | 65.3k | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
554 | 65.3k | this->level()); |
555 | 65.3k | } |
556 | | |
557 | 65.3k | } |
558 | 65.3k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
559 | 65.3k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
560 | 65.3k | _cached_size_ = cached_size; |
561 | 65.3k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
562 | 65.3k | return total_size; |
563 | 65.3k | } |
564 | | |
565 | 0 | void DeletedFilePB::MergeFrom(const ::google::protobuf::Message& from) { |
566 | | // @@protoc_insertion_point(generalized_merge_from_start:rocksdb.DeletedFilePB) |
567 | 0 | GOOGLE_DCHECK_NE(&from, this); |
568 | 0 | const DeletedFilePB* source = |
569 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const DeletedFilePB>( |
570 | 0 | &from); |
571 | 0 | if (source == NULL) { |
572 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:rocksdb.DeletedFilePB) |
573 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
574 | 0 | } else { |
575 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:rocksdb.DeletedFilePB) |
576 | 0 | MergeFrom(*source); |
577 | 0 | } |
578 | 0 | } |
579 | | |
580 | 0 | void DeletedFilePB::MergeFrom(const DeletedFilePB& from) { |
581 | | // @@protoc_insertion_point(class_specific_merge_from_start:rocksdb.DeletedFilePB) |
582 | 0 | GOOGLE_DCHECK_NE(&from, this); |
583 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
584 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
585 | 0 | (void) cached_has_bits; |
586 | |
|
587 | 0 | cached_has_bits = from._has_bits_[0]; |
588 | 0 | if (cached_has_bits & 3u) { |
589 | 0 | if (cached_has_bits & 0x00000001u) { |
590 | 0 | file_number_ = from.file_number_; |
591 | 0 | } |
592 | 0 | if (cached_has_bits & 0x00000002u) { |
593 | 0 | level_ = from.level_; |
594 | 0 | } |
595 | 0 | _has_bits_[0] |= cached_has_bits; |
596 | 0 | } |
597 | 0 | } |
598 | | |
599 | 0 | void DeletedFilePB::CopyFrom(const ::google::protobuf::Message& from) { |
600 | | // @@protoc_insertion_point(generalized_copy_from_start:rocksdb.DeletedFilePB) |
601 | 0 | if (&from == this) return; |
602 | 0 | Clear(); |
603 | 0 | MergeFrom(from); |
604 | 0 | } |
605 | | |
606 | 0 | void DeletedFilePB::CopyFrom(const DeletedFilePB& from) { |
607 | | // @@protoc_insertion_point(class_specific_copy_from_start:rocksdb.DeletedFilePB) |
608 | 0 | if (&from == this) return; |
609 | 0 | Clear(); |
610 | 0 | MergeFrom(from); |
611 | 0 | } |
612 | | |
613 | 0 | bool DeletedFilePB::IsInitialized() const { |
614 | 0 | return true; |
615 | 0 | } |
616 | | |
617 | 0 | void DeletedFilePB::Swap(DeletedFilePB* other) { |
618 | 0 | if (other == this) return; |
619 | 0 | InternalSwap(other); |
620 | 0 | } |
621 | 0 | void DeletedFilePB::InternalSwap(DeletedFilePB* other) { |
622 | 0 | using std::swap; |
623 | 0 | swap(file_number_, other->file_number_); |
624 | 0 | swap(level_, other->level_); |
625 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
626 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
627 | 0 | swap(_cached_size_, other->_cached_size_); |
628 | 0 | } |
629 | | |
630 | 194 | ::google::protobuf::Metadata DeletedFilePB::GetMetadata() const { |
631 | 194 | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
632 | 194 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages]; |
633 | 194 | } |
634 | | |
635 | | |
636 | | // =================================================================== |
637 | | |
638 | 28.1k | void UserBoundaryValuePB::InitAsDefaultInstance() { |
639 | 28.1k | } |
640 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
641 | | const int UserBoundaryValuePB::kTagFieldNumber; |
642 | | const int UserBoundaryValuePB::kDataFieldNumber; |
643 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
644 | | |
645 | | UserBoundaryValuePB::UserBoundaryValuePB() |
646 | 397k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
647 | 397k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
648 | 369k | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsUserBoundaryValuePB(); |
649 | 369k | } |
650 | 397k | SharedCtor(); |
651 | | // @@protoc_insertion_point(constructor:rocksdb.UserBoundaryValuePB) |
652 | 397k | } |
653 | | UserBoundaryValuePB::UserBoundaryValuePB(const UserBoundaryValuePB& from) |
654 | | : ::google::protobuf::Message(), |
655 | | _internal_metadata_(NULL), |
656 | | _has_bits_(from._has_bits_), |
657 | 0 | _cached_size_(0) { |
658 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
659 | 0 | data_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
660 | 0 | if (from.has_data()) { |
661 | 0 | data_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.data_); |
662 | 0 | } |
663 | 0 | tag_ = from.tag_; |
664 | | // @@protoc_insertion_point(copy_constructor:rocksdb.UserBoundaryValuePB) |
665 | 0 | } |
666 | | |
667 | 397k | void UserBoundaryValuePB::SharedCtor() { |
668 | 397k | _cached_size_ = 0; |
669 | 397k | data_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
670 | 397k | tag_ = 0u; |
671 | 397k | } |
672 | | |
673 | 369k | UserBoundaryValuePB::~UserBoundaryValuePB() { |
674 | | // @@protoc_insertion_point(destructor:rocksdb.UserBoundaryValuePB) |
675 | 369k | SharedDtor(); |
676 | 369k | } |
677 | | |
678 | 369k | void UserBoundaryValuePB::SharedDtor() { |
679 | 369k | data_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
680 | 369k | } |
681 | | |
682 | 0 | void UserBoundaryValuePB::SetCachedSize(int size) const { |
683 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
684 | 0 | _cached_size_ = size; |
685 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
686 | 0 | } |
687 | 0 | const ::google::protobuf::Descriptor* UserBoundaryValuePB::descriptor() { |
688 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
689 | 0 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
690 | 0 | } |
691 | | |
692 | 0 | const UserBoundaryValuePB& UserBoundaryValuePB::default_instance() { |
693 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsUserBoundaryValuePB(); |
694 | 0 | return *internal_default_instance(); |
695 | 0 | } |
696 | | |
697 | 0 | UserBoundaryValuePB* UserBoundaryValuePB::New(::google::protobuf::Arena* arena) const { |
698 | 0 | UserBoundaryValuePB* n = new UserBoundaryValuePB; |
699 | 0 | if (arena != NULL) { |
700 | 0 | arena->Own(n); |
701 | 0 | } |
702 | 0 | return n; |
703 | 0 | } |
704 | | |
705 | 35 | void UserBoundaryValuePB::Clear() { |
706 | | // @@protoc_insertion_point(message_clear_start:rocksdb.UserBoundaryValuePB) |
707 | 35 | ::google::protobuf::uint32 cached_has_bits = 0; |
708 | | // Prevent compiler warnings about cached_has_bits being unused |
709 | 35 | (void) cached_has_bits; |
710 | | |
711 | 35 | cached_has_bits = _has_bits_[0]; |
712 | 35 | if (cached_has_bits & 0x00000001u) { |
713 | 0 | GOOGLE_DCHECK(!data_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
714 | 0 | (*data_.UnsafeRawStringPointer())->clear(); |
715 | 0 | } |
716 | 35 | tag_ = 0u; |
717 | 35 | _has_bits_.Clear(); |
718 | 35 | _internal_metadata_.Clear(); |
719 | 35 | } |
720 | | |
721 | | bool UserBoundaryValuePB::MergePartialFromCodedStream( |
722 | 101k | ::google::protobuf::io::CodedInputStream* input) { |
723 | 203k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0 |
724 | 101k | ::google::protobuf::uint32 tag; |
725 | | // @@protoc_insertion_point(parse_start:rocksdb.UserBoundaryValuePB) |
726 | 304k | for (;;) { |
727 | 304k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
728 | 304k | tag = p.first; |
729 | 304k | if (!p.second) goto handle_unusual101k ; |
730 | 202k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
731 | | // optional uint32 tag = 1; |
732 | 101k | case 1: { |
733 | 101k | if (static_cast< ::google::protobuf::uint8>(tag) == |
734 | 101k | static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) { |
735 | 101k | set_has_tag(); |
736 | 101k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
737 | 101k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
738 | 101k | input, &tag_))); |
739 | 101k | } else { |
740 | 0 | goto handle_unusual; |
741 | 0 | } |
742 | 101k | break; |
743 | 101k | } |
744 | | |
745 | | // optional bytes data = 2; |
746 | 101k | case 2: { |
747 | 101k | if (static_cast< ::google::protobuf::uint8>(tag) == |
748 | 101k | static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) { |
749 | 101k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
750 | 101k | input, this->mutable_data())); |
751 | 101k | } else { |
752 | 0 | goto handle_unusual; |
753 | 0 | } |
754 | 101k | break; |
755 | 101k | } |
756 | | |
757 | 101k | default: { |
758 | 101k | handle_unusual: |
759 | 101k | if (tag == 0) { |
760 | 101k | goto success; |
761 | 101k | } |
762 | 0 | DO_(::google::protobuf::internal::WireFormat::SkipField( |
763 | 0 | input, tag, _internal_metadata_.mutable_unknown_fields())); |
764 | 0 | break; |
765 | 0 | } |
766 | 202k | } |
767 | 202k | } |
768 | 101k | success: |
769 | | // @@protoc_insertion_point(parse_success:rocksdb.UserBoundaryValuePB) |
770 | 101k | return true; |
771 | 0 | failure: |
772 | | // @@protoc_insertion_point(parse_failure:rocksdb.UserBoundaryValuePB) |
773 | 0 | return false; |
774 | 101k | #undef DO_ |
775 | 101k | } |
776 | | |
777 | | void UserBoundaryValuePB::SerializeWithCachedSizes( |
778 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
779 | | // @@protoc_insertion_point(serialize_start:rocksdb.UserBoundaryValuePB) |
780 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
781 | 0 | (void) cached_has_bits; |
782 | |
|
783 | 0 | cached_has_bits = _has_bits_[0]; |
784 | | // optional uint32 tag = 1; |
785 | 0 | if (cached_has_bits & 0x00000002u) { |
786 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->tag(), output); |
787 | 0 | } |
788 | | |
789 | | // optional bytes data = 2; |
790 | 0 | if (cached_has_bits & 0x00000001u) { |
791 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
792 | 0 | 2, this->data(), output); |
793 | 0 | } |
794 | |
|
795 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
796 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
797 | 0 | _internal_metadata_.unknown_fields(), output); |
798 | 0 | } |
799 | | // @@protoc_insertion_point(serialize_end:rocksdb.UserBoundaryValuePB) |
800 | 0 | } |
801 | | |
802 | | ::google::protobuf::uint8* UserBoundaryValuePB::InternalSerializeWithCachedSizesToArray( |
803 | 177k | bool deterministic, ::google::protobuf::uint8* target) const { |
804 | 177k | (void)deterministic; // Unused |
805 | | // @@protoc_insertion_point(serialize_to_array_start:rocksdb.UserBoundaryValuePB) |
806 | 177k | ::google::protobuf::uint32 cached_has_bits = 0; |
807 | 177k | (void) cached_has_bits; |
808 | | |
809 | 177k | cached_has_bits = _has_bits_[0]; |
810 | | // optional uint32 tag = 1; |
811 | 177k | if (cached_has_bits & 0x00000002u) { |
812 | 177k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->tag(), target); |
813 | 177k | } |
814 | | |
815 | | // optional bytes data = 2; |
816 | 177k | if (cached_has_bits & 0x00000001u) { |
817 | 177k | target = |
818 | 177k | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
819 | 177k | 2, this->data(), target); |
820 | 177k | } |
821 | | |
822 | 177k | if (_internal_metadata_.have_unknown_fields()) { |
823 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
824 | 0 | _internal_metadata_.unknown_fields(), target); |
825 | 0 | } |
826 | | // @@protoc_insertion_point(serialize_to_array_end:rocksdb.UserBoundaryValuePB) |
827 | 177k | return target; |
828 | 177k | } |
829 | | |
830 | 177k | size_t UserBoundaryValuePB::ByteSizeLong() const { |
831 | | // @@protoc_insertion_point(message_byte_size_start:rocksdb.UserBoundaryValuePB) |
832 | 177k | size_t total_size = 0; |
833 | | |
834 | 177k | if (_internal_metadata_.have_unknown_fields()) { |
835 | 0 | total_size += |
836 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
837 | 0 | _internal_metadata_.unknown_fields()); |
838 | 0 | } |
839 | 177k | if (_has_bits_[0 / 32] & 3u) { |
840 | | // optional bytes data = 2; |
841 | 177k | if (has_data()) { |
842 | 177k | total_size += 1 + |
843 | 177k | ::google::protobuf::internal::WireFormatLite::BytesSize( |
844 | 177k | this->data()); |
845 | 177k | } |
846 | | |
847 | | // optional uint32 tag = 1; |
848 | 177k | if (has_tag()) { |
849 | 177k | total_size += 1 + |
850 | 177k | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
851 | 177k | this->tag()); |
852 | 177k | } |
853 | | |
854 | 177k | } |
855 | 177k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
856 | 177k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
857 | 177k | _cached_size_ = cached_size; |
858 | 177k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
859 | 177k | return total_size; |
860 | 177k | } |
861 | | |
862 | 0 | void UserBoundaryValuePB::MergeFrom(const ::google::protobuf::Message& from) { |
863 | | // @@protoc_insertion_point(generalized_merge_from_start:rocksdb.UserBoundaryValuePB) |
864 | 0 | GOOGLE_DCHECK_NE(&from, this); |
865 | 0 | const UserBoundaryValuePB* source = |
866 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const UserBoundaryValuePB>( |
867 | 0 | &from); |
868 | 0 | if (source == NULL) { |
869 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:rocksdb.UserBoundaryValuePB) |
870 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
871 | 0 | } else { |
872 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:rocksdb.UserBoundaryValuePB) |
873 | 0 | MergeFrom(*source); |
874 | 0 | } |
875 | 0 | } |
876 | | |
877 | 0 | void UserBoundaryValuePB::MergeFrom(const UserBoundaryValuePB& from) { |
878 | | // @@protoc_insertion_point(class_specific_merge_from_start:rocksdb.UserBoundaryValuePB) |
879 | 0 | GOOGLE_DCHECK_NE(&from, this); |
880 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
881 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
882 | 0 | (void) cached_has_bits; |
883 | |
|
884 | 0 | cached_has_bits = from._has_bits_[0]; |
885 | 0 | if (cached_has_bits & 3u) { |
886 | 0 | if (cached_has_bits & 0x00000001u) { |
887 | 0 | set_has_data(); |
888 | 0 | data_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.data_); |
889 | 0 | } |
890 | 0 | if (cached_has_bits & 0x00000002u) { |
891 | 0 | tag_ = from.tag_; |
892 | 0 | } |
893 | 0 | _has_bits_[0] |= cached_has_bits; |
894 | 0 | } |
895 | 0 | } |
896 | | |
897 | 0 | void UserBoundaryValuePB::CopyFrom(const ::google::protobuf::Message& from) { |
898 | | // @@protoc_insertion_point(generalized_copy_from_start:rocksdb.UserBoundaryValuePB) |
899 | 0 | if (&from == this) return; |
900 | 0 | Clear(); |
901 | 0 | MergeFrom(from); |
902 | 0 | } |
903 | | |
904 | 0 | void UserBoundaryValuePB::CopyFrom(const UserBoundaryValuePB& from) { |
905 | | // @@protoc_insertion_point(class_specific_copy_from_start:rocksdb.UserBoundaryValuePB) |
906 | 0 | if (&from == this) return; |
907 | 0 | Clear(); |
908 | 0 | MergeFrom(from); |
909 | 0 | } |
910 | | |
911 | 241 | bool UserBoundaryValuePB::IsInitialized() const { |
912 | 241 | return true; |
913 | 241 | } |
914 | | |
915 | 0 | void UserBoundaryValuePB::Swap(UserBoundaryValuePB* other) { |
916 | 0 | if (other == this) return; |
917 | 0 | InternalSwap(other); |
918 | 0 | } |
919 | 0 | void UserBoundaryValuePB::InternalSwap(UserBoundaryValuePB* other) { |
920 | 0 | using std::swap; |
921 | 0 | data_.Swap(&other->data_); |
922 | 0 | swap(tag_, other->tag_); |
923 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
924 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
925 | 0 | swap(_cached_size_, other->_cached_size_); |
926 | 0 | } |
927 | | |
928 | 180k | ::google::protobuf::Metadata UserBoundaryValuePB::GetMetadata() const { |
929 | 180k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
930 | 180k | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages]; |
931 | 180k | } |
932 | | |
933 | | |
934 | | // =================================================================== |
935 | | |
936 | 28.1k | void BoundaryValuesPB::InitAsDefaultInstance() { |
937 | 28.1k | ::rocksdb::_BoundaryValuesPB_default_instance_._instance.get_mutable()->user_frontier_ = const_cast< ::google::protobuf::Any*>( |
938 | 28.1k | ::google::protobuf::Any::internal_default_instance()); |
939 | 28.1k | } |
940 | 0 | void BoundaryValuesPB::clear_user_frontier() { |
941 | 0 | if (user_frontier_ != NULL) user_frontier_->Clear(); |
942 | 0 | clear_has_user_frontier(); |
943 | 0 | } |
944 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
945 | | const int BoundaryValuesPB::kKeyFieldNumber; |
946 | | const int BoundaryValuesPB::kSeqnoFieldNumber; |
947 | | const int BoundaryValuesPB::kUserFrontierFieldNumber; |
948 | | const int BoundaryValuesPB::kUserValuesFieldNumber; |
949 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
950 | | |
951 | | BoundaryValuesPB::BoundaryValuesPB() |
952 | 381k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
953 | 381k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
954 | 353k | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsBoundaryValuesPB(); |
955 | 353k | } |
956 | 381k | SharedCtor(); |
957 | | // @@protoc_insertion_point(constructor:rocksdb.BoundaryValuesPB) |
958 | 381k | } |
959 | | BoundaryValuesPB::BoundaryValuesPB(const BoundaryValuesPB& from) |
960 | | : ::google::protobuf::Message(), |
961 | | _internal_metadata_(NULL), |
962 | | _has_bits_(from._has_bits_), |
963 | | _cached_size_(0), |
964 | 0 | user_values_(from.user_values_) { |
965 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
966 | 0 | key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
967 | 0 | if (from.has_key()) { |
968 | 0 | key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_); |
969 | 0 | } |
970 | 0 | if (from.has_user_frontier()) { |
971 | 0 | user_frontier_ = new ::google::protobuf::Any(*from.user_frontier_); |
972 | 0 | } else { |
973 | 0 | user_frontier_ = NULL; |
974 | 0 | } |
975 | 0 | seqno_ = from.seqno_; |
976 | | // @@protoc_insertion_point(copy_constructor:rocksdb.BoundaryValuesPB) |
977 | 0 | } |
978 | | |
979 | 381k | void BoundaryValuesPB::SharedCtor() { |
980 | 381k | _cached_size_ = 0; |
981 | 381k | key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
982 | 381k | ::memset(&user_frontier_, 0, static_cast<size_t>( |
983 | 381k | reinterpret_cast<char*>(&seqno_) - |
984 | 381k | reinterpret_cast<char*>(&user_frontier_)) + sizeof(seqno_)); |
985 | 381k | } |
986 | | |
987 | 353k | BoundaryValuesPB::~BoundaryValuesPB() { |
988 | | // @@protoc_insertion_point(destructor:rocksdb.BoundaryValuesPB) |
989 | 353k | SharedDtor(); |
990 | 353k | } |
991 | | |
992 | 353k | void BoundaryValuesPB::SharedDtor() { |
993 | 353k | key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
994 | 353k | if (this != internal_default_instance()) delete user_frontier_353k ; |
995 | 353k | } |
996 | | |
997 | 0 | void BoundaryValuesPB::SetCachedSize(int size) const { |
998 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
999 | 0 | _cached_size_ = size; |
1000 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1001 | 0 | } |
1002 | 0 | const ::google::protobuf::Descriptor* BoundaryValuesPB::descriptor() { |
1003 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
1004 | 0 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1005 | 0 | } |
1006 | | |
1007 | 0 | const BoundaryValuesPB& BoundaryValuesPB::default_instance() { |
1008 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsBoundaryValuesPB(); |
1009 | 0 | return *internal_default_instance(); |
1010 | 0 | } |
1011 | | |
1012 | 0 | BoundaryValuesPB* BoundaryValuesPB::New(::google::protobuf::Arena* arena) const { |
1013 | 0 | BoundaryValuesPB* n = new BoundaryValuesPB; |
1014 | 0 | if (arena != NULL) { |
1015 | 0 | arena->Own(n); |
1016 | 0 | } |
1017 | 0 | return n; |
1018 | 0 | } |
1019 | | |
1020 | 0 | void BoundaryValuesPB::Clear() { |
1021 | | // @@protoc_insertion_point(message_clear_start:rocksdb.BoundaryValuesPB) |
1022 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1023 | | // Prevent compiler warnings about cached_has_bits being unused |
1024 | 0 | (void) cached_has_bits; |
1025 | |
|
1026 | 0 | user_values_.Clear(); |
1027 | 0 | cached_has_bits = _has_bits_[0]; |
1028 | 0 | if (cached_has_bits & 3u) { |
1029 | 0 | if (cached_has_bits & 0x00000001u) { |
1030 | 0 | GOOGLE_DCHECK(!key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
1031 | 0 | (*key_.UnsafeRawStringPointer())->clear(); |
1032 | 0 | } |
1033 | 0 | if (cached_has_bits & 0x00000002u) { |
1034 | 0 | GOOGLE_DCHECK(user_frontier_ != NULL); |
1035 | 0 | user_frontier_->Clear(); |
1036 | 0 | } |
1037 | 0 | } |
1038 | 0 | seqno_ = GOOGLE_ULONGLONG(0); |
1039 | 0 | _has_bits_.Clear(); |
1040 | 0 | _internal_metadata_.Clear(); |
1041 | 0 | } |
1042 | | |
1043 | | bool BoundaryValuesPB::MergePartialFromCodedStream( |
1044 | 83.5k | ::google::protobuf::io::CodedInputStream* input) { |
1045 | 291k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0 |
1046 | 83.5k | ::google::protobuf::uint32 tag; |
1047 | | // @@protoc_insertion_point(parse_start:rocksdb.BoundaryValuesPB) |
1048 | 374k | for (;;) { |
1049 | 374k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1050 | 374k | tag = p.first; |
1051 | 374k | if (!p.second) goto handle_unusual83.5k ; |
1052 | 291k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
1053 | | // optional bytes key = 1; |
1054 | 83.5k | case 1: { |
1055 | 83.5k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1056 | 83.5k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
1057 | 83.5k | DO_(::google::protobuf::internal::WireFormatLite::ReadBytes( |
1058 | 83.5k | input, this->mutable_key())); |
1059 | 18.4E | } else { |
1060 | 18.4E | goto handle_unusual; |
1061 | 18.4E | } |
1062 | 83.5k | break; |
1063 | 83.5k | } |
1064 | | |
1065 | | // optional uint64 seqno = 2; |
1066 | 83.5k | case 2: { |
1067 | 83.5k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1068 | 83.5k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
1069 | 83.5k | set_has_seqno(); |
1070 | 83.5k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1071 | 83.5k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
1072 | 83.5k | input, &seqno_))); |
1073 | 83.5k | } else { |
1074 | 0 | goto handle_unusual; |
1075 | 0 | } |
1076 | 83.5k | break; |
1077 | 83.5k | } |
1078 | | |
1079 | | // repeated .rocksdb.UserBoundaryValuePB user_values = 3; |
1080 | 101k | case 3: { |
1081 | 101k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1082 | 101k | static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) { |
1083 | 101k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_user_values())); |
1084 | 101k | } else { |
1085 | 1 | goto handle_unusual; |
1086 | 1 | } |
1087 | 101k | break; |
1088 | 101k | } |
1089 | | |
1090 | | // optional .google.protobuf.Any user_frontier = 4; |
1091 | 101k | case 4: { |
1092 | 22.8k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1093 | 22.8k | static_cast< ::google::protobuf::uint8>(34u /* 34 & 0xFF */)) { |
1094 | 22.8k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
1095 | 22.8k | input, mutable_user_frontier())); |
1096 | 18.4E | } else { |
1097 | 18.4E | goto handle_unusual; |
1098 | 18.4E | } |
1099 | 22.8k | break; |
1100 | 22.8k | } |
1101 | | |
1102 | 22.8k | default: { |
1103 | 83.5k | handle_unusual: |
1104 | 83.5k | if (tag == 083.5k ) { |
1105 | 83.5k | goto success; |
1106 | 83.5k | } |
1107 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1108 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1109 | 18.4E | break; |
1110 | 18.4E | } |
1111 | 291k | } |
1112 | 291k | } |
1113 | 83.5k | success: |
1114 | | // @@protoc_insertion_point(parse_success:rocksdb.BoundaryValuesPB) |
1115 | 83.5k | return true; |
1116 | 0 | failure: |
1117 | | // @@protoc_insertion_point(parse_failure:rocksdb.BoundaryValuesPB) |
1118 | 0 | return false; |
1119 | 83.5k | #undef DO_ |
1120 | 83.5k | } |
1121 | | |
1122 | | void BoundaryValuesPB::SerializeWithCachedSizes( |
1123 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1124 | | // @@protoc_insertion_point(serialize_start:rocksdb.BoundaryValuesPB) |
1125 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1126 | 0 | (void) cached_has_bits; |
1127 | |
|
1128 | 0 | cached_has_bits = _has_bits_[0]; |
1129 | | // optional bytes key = 1; |
1130 | 0 | if (cached_has_bits & 0x00000001u) { |
1131 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased( |
1132 | 0 | 1, this->key(), output); |
1133 | 0 | } |
1134 | | |
1135 | | // optional uint64 seqno = 2; |
1136 | 0 | if (cached_has_bits & 0x00000004u) { |
1137 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->seqno(), output); |
1138 | 0 | } |
1139 | | |
1140 | | // repeated .rocksdb.UserBoundaryValuePB user_values = 3; |
1141 | 0 | for (unsigned int i = 0, |
1142 | 0 | n = static_cast<unsigned int>(this->user_values_size()); i < n; i++) { |
1143 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1144 | 0 | 3, this->user_values(static_cast<int>(i)), output); |
1145 | 0 | } |
1146 | | |
1147 | | // optional .google.protobuf.Any user_frontier = 4; |
1148 | 0 | if (cached_has_bits & 0x00000002u) { |
1149 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1150 | 0 | 4, *this->user_frontier_, output); |
1151 | 0 | } |
1152 | |
|
1153 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1154 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1155 | 0 | _internal_metadata_.unknown_fields(), output); |
1156 | 0 | } |
1157 | | // @@protoc_insertion_point(serialize_end:rocksdb.BoundaryValuesPB) |
1158 | 0 | } |
1159 | | |
1160 | | ::google::protobuf::uint8* BoundaryValuesPB::InternalSerializeWithCachedSizesToArray( |
1161 | 211k | bool deterministic, ::google::protobuf::uint8* target) const { |
1162 | 211k | (void)deterministic; // Unused |
1163 | | // @@protoc_insertion_point(serialize_to_array_start:rocksdb.BoundaryValuesPB) |
1164 | 211k | ::google::protobuf::uint32 cached_has_bits = 0; |
1165 | 211k | (void) cached_has_bits; |
1166 | | |
1167 | 211k | cached_has_bits = _has_bits_[0]; |
1168 | | // optional bytes key = 1; |
1169 | 211k | if (cached_has_bits & 0x00000001u211k ) { |
1170 | 211k | target = |
1171 | 211k | ::google::protobuf::internal::WireFormatLite::WriteBytesToArray( |
1172 | 211k | 1, this->key(), target); |
1173 | 211k | } |
1174 | | |
1175 | | // optional uint64 seqno = 2; |
1176 | 211k | if (cached_has_bits & 0x00000004u) { |
1177 | 211k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->seqno(), target); |
1178 | 211k | } |
1179 | | |
1180 | | // repeated .rocksdb.UserBoundaryValuePB user_values = 3; |
1181 | 211k | for (unsigned int i = 0, |
1182 | 388k | n = static_cast<unsigned int>(this->user_values_size()); i < n; i++177k ) { |
1183 | 177k | target = ::google::protobuf::internal::WireFormatLite:: |
1184 | 177k | InternalWriteMessageToArray( |
1185 | 177k | 3, this->user_values(static_cast<int>(i)), deterministic, target); |
1186 | 177k | } |
1187 | | |
1188 | | // optional .google.protobuf.Any user_frontier = 4; |
1189 | 211k | if (cached_has_bits & 0x00000002u) { |
1190 | 33.6k | target = ::google::protobuf::internal::WireFormatLite:: |
1191 | 33.6k | InternalWriteMessageToArray( |
1192 | 33.6k | 4, *this->user_frontier_, deterministic, target); |
1193 | 33.6k | } |
1194 | | |
1195 | 211k | if (_internal_metadata_.have_unknown_fields()) { |
1196 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1197 | 0 | _internal_metadata_.unknown_fields(), target); |
1198 | 0 | } |
1199 | | // @@protoc_insertion_point(serialize_to_array_end:rocksdb.BoundaryValuesPB) |
1200 | 211k | return target; |
1201 | 211k | } |
1202 | | |
1203 | 211k | size_t BoundaryValuesPB::ByteSizeLong() const { |
1204 | | // @@protoc_insertion_point(message_byte_size_start:rocksdb.BoundaryValuesPB) |
1205 | 211k | size_t total_size = 0; |
1206 | | |
1207 | 211k | if (_internal_metadata_.have_unknown_fields()) { |
1208 | 0 | total_size += |
1209 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1210 | 0 | _internal_metadata_.unknown_fields()); |
1211 | 0 | } |
1212 | | // repeated .rocksdb.UserBoundaryValuePB user_values = 3; |
1213 | 211k | { |
1214 | 211k | unsigned int count = static_cast<unsigned int>(this->user_values_size()); |
1215 | 211k | total_size += 1UL * count; |
1216 | 388k | for (unsigned int i = 0; i < count; i++177k ) { |
1217 | 177k | total_size += |
1218 | 177k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1219 | 177k | this->user_values(static_cast<int>(i))); |
1220 | 177k | } |
1221 | 211k | } |
1222 | | |
1223 | 211k | if (_has_bits_[0 / 32] & 7u) { |
1224 | | // optional bytes key = 1; |
1225 | 211k | if (has_key()211k ) { |
1226 | 211k | total_size += 1 + |
1227 | 211k | ::google::protobuf::internal::WireFormatLite::BytesSize( |
1228 | 211k | this->key()); |
1229 | 211k | } |
1230 | | |
1231 | | // optional .google.protobuf.Any user_frontier = 4; |
1232 | 211k | if (has_user_frontier()) { |
1233 | 33.6k | total_size += 1 + |
1234 | 33.6k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1235 | 33.6k | *this->user_frontier_); |
1236 | 33.6k | } |
1237 | | |
1238 | | // optional uint64 seqno = 2; |
1239 | 211k | if (has_seqno()211k ) { |
1240 | 211k | total_size += 1 + |
1241 | 211k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
1242 | 211k | this->seqno()); |
1243 | 211k | } |
1244 | | |
1245 | 211k | } |
1246 | 211k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1247 | 211k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1248 | 211k | _cached_size_ = cached_size; |
1249 | 211k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1250 | 211k | return total_size; |
1251 | 211k | } |
1252 | | |
1253 | 0 | void BoundaryValuesPB::MergeFrom(const ::google::protobuf::Message& from) { |
1254 | | // @@protoc_insertion_point(generalized_merge_from_start:rocksdb.BoundaryValuesPB) |
1255 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1256 | 0 | const BoundaryValuesPB* source = |
1257 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const BoundaryValuesPB>( |
1258 | 0 | &from); |
1259 | 0 | if (source == NULL) { |
1260 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:rocksdb.BoundaryValuesPB) |
1261 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1262 | 0 | } else { |
1263 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:rocksdb.BoundaryValuesPB) |
1264 | 0 | MergeFrom(*source); |
1265 | 0 | } |
1266 | 0 | } |
1267 | | |
1268 | 0 | void BoundaryValuesPB::MergeFrom(const BoundaryValuesPB& from) { |
1269 | | // @@protoc_insertion_point(class_specific_merge_from_start:rocksdb.BoundaryValuesPB) |
1270 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1271 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1272 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1273 | 0 | (void) cached_has_bits; |
1274 | |
|
1275 | 0 | user_values_.MergeFrom(from.user_values_); |
1276 | 0 | cached_has_bits = from._has_bits_[0]; |
1277 | 0 | if (cached_has_bits & 7u) { |
1278 | 0 | if (cached_has_bits & 0x00000001u) { |
1279 | 0 | set_has_key(); |
1280 | 0 | key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_); |
1281 | 0 | } |
1282 | 0 | if (cached_has_bits & 0x00000002u) { |
1283 | 0 | mutable_user_frontier()->::google::protobuf::Any::MergeFrom(from.user_frontier()); |
1284 | 0 | } |
1285 | 0 | if (cached_has_bits & 0x00000004u) { |
1286 | 0 | seqno_ = from.seqno_; |
1287 | 0 | } |
1288 | 0 | _has_bits_[0] |= cached_has_bits; |
1289 | 0 | } |
1290 | 0 | } |
1291 | | |
1292 | 0 | void BoundaryValuesPB::CopyFrom(const ::google::protobuf::Message& from) { |
1293 | | // @@protoc_insertion_point(generalized_copy_from_start:rocksdb.BoundaryValuesPB) |
1294 | 0 | if (&from == this) return; |
1295 | 0 | Clear(); |
1296 | 0 | MergeFrom(from); |
1297 | 0 | } |
1298 | | |
1299 | 0 | void BoundaryValuesPB::CopyFrom(const BoundaryValuesPB& from) { |
1300 | | // @@protoc_insertion_point(class_specific_copy_from_start:rocksdb.BoundaryValuesPB) |
1301 | 0 | if (&from == this) return; |
1302 | 0 | Clear(); |
1303 | 0 | MergeFrom(from); |
1304 | 0 | } |
1305 | | |
1306 | 0 | bool BoundaryValuesPB::IsInitialized() const { |
1307 | 0 | return true; |
1308 | 0 | } |
1309 | | |
1310 | 0 | void BoundaryValuesPB::Swap(BoundaryValuesPB* other) { |
1311 | 0 | if (other == this) return; |
1312 | 0 | InternalSwap(other); |
1313 | 0 | } |
1314 | 0 | void BoundaryValuesPB::InternalSwap(BoundaryValuesPB* other) { |
1315 | 0 | using std::swap; |
1316 | 0 | user_values_.InternalSwap(&other->user_values_); |
1317 | 0 | key_.Swap(&other->key_); |
1318 | 0 | swap(user_frontier_, other->user_frontier_); |
1319 | 0 | swap(seqno_, other->seqno_); |
1320 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1321 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1322 | 0 | swap(_cached_size_, other->_cached_size_); |
1323 | 0 | } |
1324 | | |
1325 | 116k | ::google::protobuf::Metadata BoundaryValuesPB::GetMetadata() const { |
1326 | 116k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
1327 | 116k | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages]; |
1328 | 116k | } |
1329 | | |
1330 | | |
1331 | | // =================================================================== |
1332 | | |
1333 | 28.1k | void NewFilePB::InitAsDefaultInstance() { |
1334 | 28.1k | ::rocksdb::_NewFilePB_default_instance_._instance.get_mutable()->smallest_ = const_cast< ::rocksdb::BoundaryValuesPB*>( |
1335 | 28.1k | ::rocksdb::BoundaryValuesPB::internal_default_instance()); |
1336 | 28.1k | ::rocksdb::_NewFilePB_default_instance_._instance.get_mutable()->largest_ = const_cast< ::rocksdb::BoundaryValuesPB*>( |
1337 | 28.1k | ::rocksdb::BoundaryValuesPB::internal_default_instance()); |
1338 | 28.1k | ::rocksdb::_NewFilePB_default_instance_._instance.get_mutable()->obsolete_last_op_id_ = const_cast< ::yb::OpIdPB*>( |
1339 | 28.1k | ::yb::OpIdPB::internal_default_instance()); |
1340 | 28.1k | } |
1341 | 0 | void NewFilePB::clear_obsolete_last_op_id() { |
1342 | 0 | if (obsolete_last_op_id_ != NULL) obsolete_last_op_id_->Clear(); |
1343 | 0 | clear_has_obsolete_last_op_id(); |
1344 | 0 | } |
1345 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1346 | | const int NewFilePB::kLevelFieldNumber; |
1347 | | const int NewFilePB::kNumberFieldNumber; |
1348 | | const int NewFilePB::kTotalFileSizeFieldNumber; |
1349 | | const int NewFilePB::kBaseFileSizeFieldNumber; |
1350 | | const int NewFilePB::kSmallestFieldNumber; |
1351 | | const int NewFilePB::kLargestFieldNumber; |
1352 | | const int NewFilePB::kPathIdFieldNumber; |
1353 | | const int NewFilePB::kMarkedForCompactionFieldNumber; |
1354 | | const int NewFilePB::kObsoleteLastOpIdFieldNumber; |
1355 | | const int NewFilePB::kImportedFieldNumber; |
1356 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1357 | | |
1358 | | NewFilePB::NewFilePB() |
1359 | 204k | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
1360 | 204k | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
1361 | 176k | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsNewFilePB(); |
1362 | 176k | } |
1363 | 204k | SharedCtor(); |
1364 | | // @@protoc_insertion_point(constructor:rocksdb.NewFilePB) |
1365 | 204k | } |
1366 | | NewFilePB::NewFilePB(const NewFilePB& from) |
1367 | | : ::google::protobuf::Message(), |
1368 | | _internal_metadata_(NULL), |
1369 | | _has_bits_(from._has_bits_), |
1370 | 0 | _cached_size_(0) { |
1371 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1372 | 0 | if (from.has_smallest()) { |
1373 | 0 | smallest_ = new ::rocksdb::BoundaryValuesPB(*from.smallest_); |
1374 | 0 | } else { |
1375 | 0 | smallest_ = NULL; |
1376 | 0 | } |
1377 | 0 | if (from.has_largest()) { |
1378 | 0 | largest_ = new ::rocksdb::BoundaryValuesPB(*from.largest_); |
1379 | 0 | } else { |
1380 | 0 | largest_ = NULL; |
1381 | 0 | } |
1382 | 0 | if (from.has_obsolete_last_op_id()) { |
1383 | 0 | obsolete_last_op_id_ = new ::yb::OpIdPB(*from.obsolete_last_op_id_); |
1384 | 0 | } else { |
1385 | 0 | obsolete_last_op_id_ = NULL; |
1386 | 0 | } |
1387 | 0 | ::memcpy(&number_, &from.number_, |
1388 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&imported_) - |
1389 | 0 | reinterpret_cast<char*>(&number_)) + sizeof(imported_)); |
1390 | | // @@protoc_insertion_point(copy_constructor:rocksdb.NewFilePB) |
1391 | 0 | } |
1392 | | |
1393 | 204k | void NewFilePB::SharedCtor() { |
1394 | 204k | _cached_size_ = 0; |
1395 | 204k | ::memset(&smallest_, 0, static_cast<size_t>( |
1396 | 204k | reinterpret_cast<char*>(&imported_) - |
1397 | 204k | reinterpret_cast<char*>(&smallest_)) + sizeof(imported_)); |
1398 | 204k | } |
1399 | | |
1400 | 176k | NewFilePB::~NewFilePB() { |
1401 | | // @@protoc_insertion_point(destructor:rocksdb.NewFilePB) |
1402 | 176k | SharedDtor(); |
1403 | 176k | } |
1404 | | |
1405 | 176k | void NewFilePB::SharedDtor() { |
1406 | 176k | if (this != internal_default_instance()) delete smallest_176k ; |
1407 | 176k | if (this != internal_default_instance()) delete largest_176k ; |
1408 | 176k | if (this != internal_default_instance()) delete obsolete_last_op_id_; |
1409 | 176k | } |
1410 | | |
1411 | 0 | void NewFilePB::SetCachedSize(int size) const { |
1412 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1413 | 0 | _cached_size_ = size; |
1414 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1415 | 0 | } |
1416 | 0 | const ::google::protobuf::Descriptor* NewFilePB::descriptor() { |
1417 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
1418 | 0 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
1419 | 0 | } |
1420 | | |
1421 | 0 | const NewFilePB& NewFilePB::default_instance() { |
1422 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsNewFilePB(); |
1423 | 0 | return *internal_default_instance(); |
1424 | 0 | } |
1425 | | |
1426 | 0 | NewFilePB* NewFilePB::New(::google::protobuf::Arena* arena) const { |
1427 | 0 | NewFilePB* n = new NewFilePB; |
1428 | 0 | if (arena != NULL) { |
1429 | 0 | arena->Own(n); |
1430 | 0 | } |
1431 | 0 | return n; |
1432 | 0 | } |
1433 | | |
1434 | 0 | void NewFilePB::Clear() { |
1435 | | // @@protoc_insertion_point(message_clear_start:rocksdb.NewFilePB) |
1436 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1437 | | // Prevent compiler warnings about cached_has_bits being unused |
1438 | 0 | (void) cached_has_bits; |
1439 | |
|
1440 | 0 | cached_has_bits = _has_bits_[0]; |
1441 | 0 | if (cached_has_bits & 7u) { |
1442 | 0 | if (cached_has_bits & 0x00000001u) { |
1443 | 0 | GOOGLE_DCHECK(smallest_ != NULL); |
1444 | 0 | smallest_->Clear(); |
1445 | 0 | } |
1446 | 0 | if (cached_has_bits & 0x00000002u) { |
1447 | 0 | GOOGLE_DCHECK(largest_ != NULL); |
1448 | 0 | largest_->Clear(); |
1449 | 0 | } |
1450 | 0 | if (cached_has_bits & 0x00000004u) { |
1451 | 0 | GOOGLE_DCHECK(obsolete_last_op_id_ != NULL); |
1452 | 0 | obsolete_last_op_id_->Clear(); |
1453 | 0 | } |
1454 | 0 | } |
1455 | 0 | if (cached_has_bits & 248u) { |
1456 | 0 | ::memset(&number_, 0, static_cast<size_t>( |
1457 | 0 | reinterpret_cast<char*>(&path_id_) - |
1458 | 0 | reinterpret_cast<char*>(&number_)) + sizeof(path_id_)); |
1459 | 0 | } |
1460 | 0 | if (cached_has_bits & 768u) { |
1461 | 0 | ::memset(&marked_for_compaction_, 0, static_cast<size_t>( |
1462 | 0 | reinterpret_cast<char*>(&imported_) - |
1463 | 0 | reinterpret_cast<char*>(&marked_for_compaction_)) + sizeof(imported_)); |
1464 | 0 | } |
1465 | 0 | _has_bits_.Clear(); |
1466 | 0 | _internal_metadata_.Clear(); |
1467 | 0 | } |
1468 | | |
1469 | | bool NewFilePB::MergePartialFromCodedStream( |
1470 | 41.7k | ::google::protobuf::io::CodedInputStream* input) { |
1471 | 250k | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0 |
1472 | 41.7k | ::google::protobuf::uint32 tag; |
1473 | | // @@protoc_insertion_point(parse_start:rocksdb.NewFilePB) |
1474 | 292k | for (;;) { |
1475 | 292k | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
1476 | 292k | tag = p.first; |
1477 | 292k | if (!p.second) goto handle_unusual41.7k ; |
1478 | 250k | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
1479 | | // optional uint32 level = 1; |
1480 | 41.7k | case 1: { |
1481 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1482 | 41.7k | static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) { |
1483 | 41.7k | set_has_level(); |
1484 | 41.7k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1485 | 41.7k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
1486 | 41.7k | input, &level_))); |
1487 | 41.7k | } else { |
1488 | 1 | goto handle_unusual; |
1489 | 1 | } |
1490 | 41.7k | break; |
1491 | 41.7k | } |
1492 | | |
1493 | | // optional uint64 number = 2; |
1494 | 41.7k | case 2: { |
1495 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1496 | 41.7k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
1497 | 41.7k | set_has_number(); |
1498 | 41.7k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1499 | 41.7k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
1500 | 41.7k | input, &number_))); |
1501 | 18.4E | } else { |
1502 | 18.4E | goto handle_unusual; |
1503 | 18.4E | } |
1504 | 41.7k | break; |
1505 | 41.7k | } |
1506 | | |
1507 | | // optional uint64 total_file_size = 3; |
1508 | 41.7k | case 3: { |
1509 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1510 | 41.7k | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
1511 | 41.7k | set_has_total_file_size(); |
1512 | 41.7k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1513 | 41.7k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
1514 | 41.7k | input, &total_file_size_))); |
1515 | 41.7k | } else { |
1516 | 5 | goto handle_unusual; |
1517 | 5 | } |
1518 | 41.7k | break; |
1519 | 41.7k | } |
1520 | | |
1521 | | // optional uint64 base_file_size = 4; |
1522 | 41.7k | case 4: { |
1523 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1524 | 41.7k | static_cast< ::google::protobuf::uint8>(32u /* 32 & 0xFF */)) { |
1525 | 41.7k | set_has_base_file_size(); |
1526 | 41.7k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1527 | 41.7k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
1528 | 41.7k | input, &base_file_size_))); |
1529 | 41.7k | } else { |
1530 | 0 | goto handle_unusual; |
1531 | 0 | } |
1532 | 41.7k | break; |
1533 | 41.7k | } |
1534 | | |
1535 | | // optional .rocksdb.BoundaryValuesPB smallest = 5; |
1536 | 41.7k | case 5: { |
1537 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1538 | 41.7k | static_cast< ::google::protobuf::uint8>(42u /* 42 & 0xFF */)) { |
1539 | 41.7k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
1540 | 41.7k | input, mutable_smallest())); |
1541 | 18.4E | } else { |
1542 | 18.4E | goto handle_unusual; |
1543 | 18.4E | } |
1544 | 41.7k | break; |
1545 | 41.7k | } |
1546 | | |
1547 | | // optional .rocksdb.BoundaryValuesPB largest = 6; |
1548 | 41.7k | case 6: { |
1549 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
1550 | 41.7k | static_cast< ::google::protobuf::uint8>(50u /* 50 & 0xFF */)) { |
1551 | 41.7k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
1552 | 41.7k | input, mutable_largest())); |
1553 | 41.7k | } else { |
1554 | 0 | goto handle_unusual; |
1555 | 0 | } |
1556 | 41.7k | break; |
1557 | 41.7k | } |
1558 | | |
1559 | | // optional uint32 path_id = 7; |
1560 | 41.7k | case 7: { |
1561 | 179 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1562 | 179 | static_cast< ::google::protobuf::uint8>(56u /* 56 & 0xFF */)) { |
1563 | 179 | set_has_path_id(); |
1564 | 179 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1565 | 179 | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
1566 | 179 | input, &path_id_))); |
1567 | 179 | } else { |
1568 | 0 | goto handle_unusual; |
1569 | 0 | } |
1570 | 179 | break; |
1571 | 179 | } |
1572 | | |
1573 | | // optional bool marked_for_compaction = 8; |
1574 | 179 | case 8: { |
1575 | 7 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1576 | 7 | static_cast< ::google::protobuf::uint8>(64u /* 64 & 0xFF */)) { |
1577 | 7 | set_has_marked_for_compaction(); |
1578 | 7 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1579 | 7 | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
1580 | 7 | input, &marked_for_compaction_))); |
1581 | 7 | } else { |
1582 | 0 | goto handle_unusual; |
1583 | 0 | } |
1584 | 7 | break; |
1585 | 7 | } |
1586 | | |
1587 | | // optional .yb.OpIdPB obsolete_last_op_id = 9; |
1588 | 7 | case 9: { |
1589 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1590 | 0 | static_cast< ::google::protobuf::uint8>(74u /* 74 & 0xFF */)) { |
1591 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
1592 | 0 | input, mutable_obsolete_last_op_id())); |
1593 | 0 | } else { |
1594 | 0 | goto handle_unusual; |
1595 | 0 | } |
1596 | 0 | break; |
1597 | 0 | } |
1598 | | |
1599 | | // optional bool imported = 10; |
1600 | 0 | case 10: { |
1601 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
1602 | 0 | static_cast< ::google::protobuf::uint8>(80u /* 80 & 0xFF */)) { |
1603 | 0 | set_has_imported(); |
1604 | 0 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
1605 | 0 | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
1606 | 0 | input, &imported_))); |
1607 | 0 | } else { |
1608 | 0 | goto handle_unusual; |
1609 | 0 | } |
1610 | 0 | break; |
1611 | 0 | } |
1612 | | |
1613 | 0 | default: { |
1614 | 41.7k | handle_unusual: |
1615 | 41.7k | if (tag == 041.7k ) { |
1616 | 41.7k | goto success; |
1617 | 41.7k | } |
1618 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
1619 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
1620 | 18.4E | break; |
1621 | 18.4E | } |
1622 | 250k | } |
1623 | 250k | } |
1624 | 41.7k | success: |
1625 | | // @@protoc_insertion_point(parse_success:rocksdb.NewFilePB) |
1626 | 41.7k | return true; |
1627 | 0 | failure: |
1628 | | // @@protoc_insertion_point(parse_failure:rocksdb.NewFilePB) |
1629 | 0 | return false; |
1630 | 41.7k | #undef DO_ |
1631 | 41.7k | } |
1632 | | |
1633 | | void NewFilePB::SerializeWithCachedSizes( |
1634 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
1635 | | // @@protoc_insertion_point(serialize_start:rocksdb.NewFilePB) |
1636 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1637 | 0 | (void) cached_has_bits; |
1638 | |
|
1639 | 0 | cached_has_bits = _has_bits_[0]; |
1640 | | // optional uint32 level = 1; |
1641 | 0 | if (cached_has_bits & 0x00000040u) { |
1642 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->level(), output); |
1643 | 0 | } |
1644 | | |
1645 | | // optional uint64 number = 2; |
1646 | 0 | if (cached_has_bits & 0x00000008u) { |
1647 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->number(), output); |
1648 | 0 | } |
1649 | | |
1650 | | // optional uint64 total_file_size = 3; |
1651 | 0 | if (cached_has_bits & 0x00000010u) { |
1652 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->total_file_size(), output); |
1653 | 0 | } |
1654 | | |
1655 | | // optional uint64 base_file_size = 4; |
1656 | 0 | if (cached_has_bits & 0x00000020u) { |
1657 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(4, this->base_file_size(), output); |
1658 | 0 | } |
1659 | | |
1660 | | // optional .rocksdb.BoundaryValuesPB smallest = 5; |
1661 | 0 | if (cached_has_bits & 0x00000001u) { |
1662 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1663 | 0 | 5, *this->smallest_, output); |
1664 | 0 | } |
1665 | | |
1666 | | // optional .rocksdb.BoundaryValuesPB largest = 6; |
1667 | 0 | if (cached_has_bits & 0x00000002u) { |
1668 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1669 | 0 | 6, *this->largest_, output); |
1670 | 0 | } |
1671 | | |
1672 | | // optional uint32 path_id = 7; |
1673 | 0 | if (cached_has_bits & 0x00000080u) { |
1674 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(7, this->path_id(), output); |
1675 | 0 | } |
1676 | | |
1677 | | // optional bool marked_for_compaction = 8; |
1678 | 0 | if (cached_has_bits & 0x00000100u) { |
1679 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(8, this->marked_for_compaction(), output); |
1680 | 0 | } |
1681 | | |
1682 | | // optional .yb.OpIdPB obsolete_last_op_id = 9; |
1683 | 0 | if (cached_has_bits & 0x00000004u) { |
1684 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
1685 | 0 | 9, *this->obsolete_last_op_id_, output); |
1686 | 0 | } |
1687 | | |
1688 | | // optional bool imported = 10; |
1689 | 0 | if (cached_has_bits & 0x00000200u) { |
1690 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(10, this->imported(), output); |
1691 | 0 | } |
1692 | |
|
1693 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
1694 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
1695 | 0 | _internal_metadata_.unknown_fields(), output); |
1696 | 0 | } |
1697 | | // @@protoc_insertion_point(serialize_end:rocksdb.NewFilePB) |
1698 | 0 | } |
1699 | | |
1700 | | ::google::protobuf::uint8* NewFilePB::InternalSerializeWithCachedSizesToArray( |
1701 | 105k | bool deterministic, ::google::protobuf::uint8* target) const { |
1702 | 105k | (void)deterministic; // Unused |
1703 | | // @@protoc_insertion_point(serialize_to_array_start:rocksdb.NewFilePB) |
1704 | 105k | ::google::protobuf::uint32 cached_has_bits = 0; |
1705 | 105k | (void) cached_has_bits; |
1706 | | |
1707 | 105k | cached_has_bits = _has_bits_[0]; |
1708 | | // optional uint32 level = 1; |
1709 | 105k | if (cached_has_bits & 0x00000040u) { |
1710 | 105k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->level(), target); |
1711 | 105k | } |
1712 | | |
1713 | | // optional uint64 number = 2; |
1714 | 105k | if (cached_has_bits & 0x00000008u) { |
1715 | 105k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->number(), target); |
1716 | 105k | } |
1717 | | |
1718 | | // optional uint64 total_file_size = 3; |
1719 | 105k | if (cached_has_bits & 0x00000010u) { |
1720 | 105k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->total_file_size(), target); |
1721 | 105k | } |
1722 | | |
1723 | | // optional uint64 base_file_size = 4; |
1724 | 105k | if (cached_has_bits & 0x00000020u) { |
1725 | 105k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(4, this->base_file_size(), target); |
1726 | 105k | } |
1727 | | |
1728 | | // optional .rocksdb.BoundaryValuesPB smallest = 5; |
1729 | 105k | if (cached_has_bits & 0x00000001u) { |
1730 | 105k | target = ::google::protobuf::internal::WireFormatLite:: |
1731 | 105k | InternalWriteMessageToArray( |
1732 | 105k | 5, *this->smallest_, deterministic, target); |
1733 | 105k | } |
1734 | | |
1735 | | // optional .rocksdb.BoundaryValuesPB largest = 6; |
1736 | 105k | if (cached_has_bits & 0x00000002u) { |
1737 | 105k | target = ::google::protobuf::internal::WireFormatLite:: |
1738 | 105k | InternalWriteMessageToArray( |
1739 | 105k | 6, *this->largest_, deterministic, target); |
1740 | 105k | } |
1741 | | |
1742 | | // optional uint32 path_id = 7; |
1743 | 105k | if (cached_has_bits & 0x00000080u) { |
1744 | 302 | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(7, this->path_id(), target); |
1745 | 302 | } |
1746 | | |
1747 | | // optional bool marked_for_compaction = 8; |
1748 | 105k | if (cached_has_bits & 0x00000100u) { |
1749 | 14 | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(8, this->marked_for_compaction(), target); |
1750 | 14 | } |
1751 | | |
1752 | | // optional .yb.OpIdPB obsolete_last_op_id = 9; |
1753 | 105k | if (cached_has_bits & 0x00000004u) { |
1754 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
1755 | 0 | InternalWriteMessageToArray( |
1756 | 0 | 9, *this->obsolete_last_op_id_, deterministic, target); |
1757 | 0 | } |
1758 | | |
1759 | | // optional bool imported = 10; |
1760 | 105k | if (cached_has_bits & 0x00000200u) { |
1761 | 0 | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(10, this->imported(), target); |
1762 | 0 | } |
1763 | | |
1764 | 105k | if (_internal_metadata_.have_unknown_fields()) { |
1765 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
1766 | 0 | _internal_metadata_.unknown_fields(), target); |
1767 | 0 | } |
1768 | | // @@protoc_insertion_point(serialize_to_array_end:rocksdb.NewFilePB) |
1769 | 105k | return target; |
1770 | 105k | } |
1771 | | |
1772 | 105k | size_t NewFilePB::ByteSizeLong() const { |
1773 | | // @@protoc_insertion_point(message_byte_size_start:rocksdb.NewFilePB) |
1774 | 105k | size_t total_size = 0; |
1775 | | |
1776 | 105k | if (_internal_metadata_.have_unknown_fields()) { |
1777 | 0 | total_size += |
1778 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
1779 | 0 | _internal_metadata_.unknown_fields()); |
1780 | 0 | } |
1781 | 105k | if (_has_bits_[0 / 32] & 255u) { |
1782 | | // optional .rocksdb.BoundaryValuesPB smallest = 5; |
1783 | 105k | if (has_smallest()) { |
1784 | 105k | total_size += 1 + |
1785 | 105k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1786 | 105k | *this->smallest_); |
1787 | 105k | } |
1788 | | |
1789 | | // optional .rocksdb.BoundaryValuesPB largest = 6; |
1790 | 105k | if (has_largest()105k ) { |
1791 | 105k | total_size += 1 + |
1792 | 105k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1793 | 105k | *this->largest_); |
1794 | 105k | } |
1795 | | |
1796 | | // optional .yb.OpIdPB obsolete_last_op_id = 9; |
1797 | 105k | if (has_obsolete_last_op_id()) { |
1798 | 0 | total_size += 1 + |
1799 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
1800 | 0 | *this->obsolete_last_op_id_); |
1801 | 0 | } |
1802 | | |
1803 | | // optional uint64 number = 2; |
1804 | 105k | if (has_number()105k ) { |
1805 | 105k | total_size += 1 + |
1806 | 105k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
1807 | 105k | this->number()); |
1808 | 105k | } |
1809 | | |
1810 | | // optional uint64 total_file_size = 3; |
1811 | 105k | if (has_total_file_size()) { |
1812 | 105k | total_size += 1 + |
1813 | 105k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
1814 | 105k | this->total_file_size()); |
1815 | 105k | } |
1816 | | |
1817 | | // optional uint64 base_file_size = 4; |
1818 | 105k | if (has_base_file_size()105k ) { |
1819 | 105k | total_size += 1 + |
1820 | 105k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
1821 | 105k | this->base_file_size()); |
1822 | 105k | } |
1823 | | |
1824 | | // optional uint32 level = 1; |
1825 | 105k | if (has_level()105k ) { |
1826 | 105k | total_size += 1 + |
1827 | 105k | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
1828 | 105k | this->level()); |
1829 | 105k | } |
1830 | | |
1831 | | // optional uint32 path_id = 7; |
1832 | 105k | if (has_path_id()) { |
1833 | 302 | total_size += 1 + |
1834 | 302 | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
1835 | 302 | this->path_id()); |
1836 | 302 | } |
1837 | | |
1838 | 105k | } |
1839 | 105k | if (_has_bits_[8 / 32] & 768u) { |
1840 | | // optional bool marked_for_compaction = 8; |
1841 | 14 | if (has_marked_for_compaction()) { |
1842 | 14 | total_size += 1 + 1; |
1843 | 14 | } |
1844 | | |
1845 | | // optional bool imported = 10; |
1846 | 14 | if (has_imported()) { |
1847 | 0 | total_size += 1 + 1; |
1848 | 0 | } |
1849 | | |
1850 | 14 | } |
1851 | 105k | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
1852 | 105k | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
1853 | 105k | _cached_size_ = cached_size; |
1854 | 105k | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
1855 | 105k | return total_size; |
1856 | 105k | } |
1857 | | |
1858 | 0 | void NewFilePB::MergeFrom(const ::google::protobuf::Message& from) { |
1859 | | // @@protoc_insertion_point(generalized_merge_from_start:rocksdb.NewFilePB) |
1860 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1861 | 0 | const NewFilePB* source = |
1862 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const NewFilePB>( |
1863 | 0 | &from); |
1864 | 0 | if (source == NULL) { |
1865 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:rocksdb.NewFilePB) |
1866 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
1867 | 0 | } else { |
1868 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:rocksdb.NewFilePB) |
1869 | 0 | MergeFrom(*source); |
1870 | 0 | } |
1871 | 0 | } |
1872 | | |
1873 | 0 | void NewFilePB::MergeFrom(const NewFilePB& from) { |
1874 | | // @@protoc_insertion_point(class_specific_merge_from_start:rocksdb.NewFilePB) |
1875 | 0 | GOOGLE_DCHECK_NE(&from, this); |
1876 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
1877 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
1878 | 0 | (void) cached_has_bits; |
1879 | |
|
1880 | 0 | cached_has_bits = from._has_bits_[0]; |
1881 | 0 | if (cached_has_bits & 255u) { |
1882 | 0 | if (cached_has_bits & 0x00000001u) { |
1883 | 0 | mutable_smallest()->::rocksdb::BoundaryValuesPB::MergeFrom(from.smallest()); |
1884 | 0 | } |
1885 | 0 | if (cached_has_bits & 0x00000002u) { |
1886 | 0 | mutable_largest()->::rocksdb::BoundaryValuesPB::MergeFrom(from.largest()); |
1887 | 0 | } |
1888 | 0 | if (cached_has_bits & 0x00000004u) { |
1889 | 0 | mutable_obsolete_last_op_id()->::yb::OpIdPB::MergeFrom(from.obsolete_last_op_id()); |
1890 | 0 | } |
1891 | 0 | if (cached_has_bits & 0x00000008u) { |
1892 | 0 | number_ = from.number_; |
1893 | 0 | } |
1894 | 0 | if (cached_has_bits & 0x00000010u) { |
1895 | 0 | total_file_size_ = from.total_file_size_; |
1896 | 0 | } |
1897 | 0 | if (cached_has_bits & 0x00000020u) { |
1898 | 0 | base_file_size_ = from.base_file_size_; |
1899 | 0 | } |
1900 | 0 | if (cached_has_bits & 0x00000040u) { |
1901 | 0 | level_ = from.level_; |
1902 | 0 | } |
1903 | 0 | if (cached_has_bits & 0x00000080u) { |
1904 | 0 | path_id_ = from.path_id_; |
1905 | 0 | } |
1906 | 0 | _has_bits_[0] |= cached_has_bits; |
1907 | 0 | } |
1908 | 0 | if (cached_has_bits & 768u) { |
1909 | 0 | if (cached_has_bits & 0x00000100u) { |
1910 | 0 | marked_for_compaction_ = from.marked_for_compaction_; |
1911 | 0 | } |
1912 | 0 | if (cached_has_bits & 0x00000200u) { |
1913 | 0 | imported_ = from.imported_; |
1914 | 0 | } |
1915 | 0 | _has_bits_[0] |= cached_has_bits; |
1916 | 0 | } |
1917 | 0 | } |
1918 | | |
1919 | 0 | void NewFilePB::CopyFrom(const ::google::protobuf::Message& from) { |
1920 | | // @@protoc_insertion_point(generalized_copy_from_start:rocksdb.NewFilePB) |
1921 | 0 | if (&from == this) return; |
1922 | 0 | Clear(); |
1923 | 0 | MergeFrom(from); |
1924 | 0 | } |
1925 | | |
1926 | 0 | void NewFilePB::CopyFrom(const NewFilePB& from) { |
1927 | | // @@protoc_insertion_point(class_specific_copy_from_start:rocksdb.NewFilePB) |
1928 | 0 | if (&from == this) return; |
1929 | 0 | Clear(); |
1930 | 0 | MergeFrom(from); |
1931 | 0 | } |
1932 | | |
1933 | 147k | bool NewFilePB::IsInitialized() const { |
1934 | 147k | if (has_obsolete_last_op_id()) { |
1935 | 0 | if (!this->obsolete_last_op_id_->IsInitialized()) return false; |
1936 | 0 | } |
1937 | 147k | return true; |
1938 | 147k | } |
1939 | | |
1940 | 0 | void NewFilePB::Swap(NewFilePB* other) { |
1941 | 0 | if (other == this) return; |
1942 | 0 | InternalSwap(other); |
1943 | 0 | } |
1944 | 0 | void NewFilePB::InternalSwap(NewFilePB* other) { |
1945 | 0 | using std::swap; |
1946 | 0 | swap(smallest_, other->smallest_); |
1947 | 0 | swap(largest_, other->largest_); |
1948 | 0 | swap(obsolete_last_op_id_, other->obsolete_last_op_id_); |
1949 | 0 | swap(number_, other->number_); |
1950 | 0 | swap(total_file_size_, other->total_file_size_); |
1951 | 0 | swap(base_file_size_, other->base_file_size_); |
1952 | 0 | swap(level_, other->level_); |
1953 | 0 | swap(path_id_, other->path_id_); |
1954 | 0 | swap(marked_for_compaction_, other->marked_for_compaction_); |
1955 | 0 | swap(imported_, other->imported_); |
1956 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
1957 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
1958 | 0 | swap(_cached_size_, other->_cached_size_); |
1959 | 0 | } |
1960 | | |
1961 | 58.1k | ::google::protobuf::Metadata NewFilePB::GetMetadata() const { |
1962 | 58.1k | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
1963 | 58.1k | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages]; |
1964 | 58.1k | } |
1965 | | |
1966 | | |
1967 | | // =================================================================== |
1968 | | |
1969 | 28.1k | void VersionEditPB::InitAsDefaultInstance() { |
1970 | 28.1k | ::rocksdb::_VersionEditPB_default_instance_._instance.get_mutable()->obsolete_last_op_id_ = const_cast< ::yb::OpIdPB*>( |
1971 | 28.1k | ::yb::OpIdPB::internal_default_instance()); |
1972 | 28.1k | ::rocksdb::_VersionEditPB_default_instance_._instance.get_mutable()->flushed_frontier_ = const_cast< ::google::protobuf::Any*>( |
1973 | 28.1k | ::google::protobuf::Any::internal_default_instance()); |
1974 | 28.1k | } |
1975 | 0 | void VersionEditPB::clear_obsolete_last_op_id() { |
1976 | 0 | if (obsolete_last_op_id_ != NULL) obsolete_last_op_id_->Clear(); |
1977 | 0 | clear_has_obsolete_last_op_id(); |
1978 | 0 | } |
1979 | 0 | void VersionEditPB::clear_flushed_frontier() { |
1980 | 0 | if (flushed_frontier_ != NULL) flushed_frontier_->Clear(); |
1981 | 0 | clear_has_flushed_frontier(); |
1982 | 0 | } |
1983 | | #if !defined(_MSC_VER) || _MSC_VER >= 1900 |
1984 | | const int VersionEditPB::kComparatorFieldNumber; |
1985 | | const int VersionEditPB::kLogNumberFieldNumber; |
1986 | | const int VersionEditPB::kPrevLogNumberFieldNumber; |
1987 | | const int VersionEditPB::kNextFileNumberFieldNumber; |
1988 | | const int VersionEditPB::kMaxColumnFamilyFieldNumber; |
1989 | | const int VersionEditPB::kLastSequenceFieldNumber; |
1990 | | const int VersionEditPB::kDeletedFilesFieldNumber; |
1991 | | const int VersionEditPB::kNewFilesFieldNumber; |
1992 | | const int VersionEditPB::kColumnFamilyFieldNumber; |
1993 | | const int VersionEditPB::kColumnFamilyNameFieldNumber; |
1994 | | const int VersionEditPB::kIsColumnFamilyDropFieldNumber; |
1995 | | const int VersionEditPB::kObsoleteLastOpIdFieldNumber; |
1996 | | const int VersionEditPB::kFlushedFrontierFieldNumber; |
1997 | | #endif // !defined(_MSC_VER) || _MSC_VER >= 1900 |
1998 | | |
1999 | | VersionEditPB::VersionEditPB() |
2000 | 2.38M | : ::google::protobuf::Message(), _internal_metadata_(NULL) { |
2001 | 2.38M | if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) { |
2002 | 2.36M | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsVersionEditPB(); |
2003 | 2.36M | } |
2004 | 2.38M | SharedCtor(); |
2005 | | // @@protoc_insertion_point(constructor:rocksdb.VersionEditPB) |
2006 | 2.38M | } |
2007 | | VersionEditPB::VersionEditPB(const VersionEditPB& from) |
2008 | | : ::google::protobuf::Message(), |
2009 | | _internal_metadata_(NULL), |
2010 | | _has_bits_(from._has_bits_), |
2011 | | _cached_size_(0), |
2012 | | deleted_files_(from.deleted_files_), |
2013 | 0 | new_files_(from.new_files_) { |
2014 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
2015 | 0 | comparator_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2016 | 0 | if (from.has_comparator()) { |
2017 | 0 | comparator_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.comparator_); |
2018 | 0 | } |
2019 | 0 | column_family_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2020 | 0 | if (from.has_column_family_name()) { |
2021 | 0 | column_family_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.column_family_name_); |
2022 | 0 | } |
2023 | 0 | if (from.has_obsolete_last_op_id()) { |
2024 | 0 | obsolete_last_op_id_ = new ::yb::OpIdPB(*from.obsolete_last_op_id_); |
2025 | 0 | } else { |
2026 | 0 | obsolete_last_op_id_ = NULL; |
2027 | 0 | } |
2028 | 0 | if (from.has_flushed_frontier()) { |
2029 | 0 | flushed_frontier_ = new ::google::protobuf::Any(*from.flushed_frontier_); |
2030 | 0 | } else { |
2031 | 0 | flushed_frontier_ = NULL; |
2032 | 0 | } |
2033 | 0 | ::memcpy(&log_number_, &from.log_number_, |
2034 | 0 | static_cast<size_t>(reinterpret_cast<char*>(&is_column_family_drop_) - |
2035 | 0 | reinterpret_cast<char*>(&log_number_)) + sizeof(is_column_family_drop_)); |
2036 | | // @@protoc_insertion_point(copy_constructor:rocksdb.VersionEditPB) |
2037 | 0 | } |
2038 | | |
2039 | 2.38M | void VersionEditPB::SharedCtor() { |
2040 | 2.38M | _cached_size_ = 0; |
2041 | 2.38M | comparator_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2042 | 2.38M | column_family_name_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2043 | 2.38M | ::memset(&obsolete_last_op_id_, 0, static_cast<size_t>( |
2044 | 2.38M | reinterpret_cast<char*>(&is_column_family_drop_) - |
2045 | 2.38M | reinterpret_cast<char*>(&obsolete_last_op_id_)) + sizeof(is_column_family_drop_)); |
2046 | 2.38M | } |
2047 | | |
2048 | 2.36M | VersionEditPB::~VersionEditPB() { |
2049 | | // @@protoc_insertion_point(destructor:rocksdb.VersionEditPB) |
2050 | 2.36M | SharedDtor(); |
2051 | 2.36M | } |
2052 | | |
2053 | 2.36M | void VersionEditPB::SharedDtor() { |
2054 | 2.36M | comparator_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2055 | 2.36M | column_family_name_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited()); |
2056 | 2.36M | if (this != internal_default_instance()) delete obsolete_last_op_id_2.36M ; |
2057 | 2.36M | if (this != internal_default_instance()) delete flushed_frontier_2.36M ; |
2058 | 2.36M | } |
2059 | | |
2060 | 0 | void VersionEditPB::SetCachedSize(int size) const { |
2061 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
2062 | 0 | _cached_size_ = size; |
2063 | 0 | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
2064 | 0 | } |
2065 | 0 | const ::google::protobuf::Descriptor* VersionEditPB::descriptor() { |
2066 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
2067 | 0 | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages].descriptor; |
2068 | 0 | } |
2069 | | |
2070 | 0 | const VersionEditPB& VersionEditPB::default_instance() { |
2071 | 0 | ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::InitDefaultsVersionEditPB(); |
2072 | 0 | return *internal_default_instance(); |
2073 | 0 | } |
2074 | | |
2075 | 0 | VersionEditPB* VersionEditPB::New(::google::protobuf::Arena* arena) const { |
2076 | 0 | VersionEditPB* n = new VersionEditPB; |
2077 | 0 | if (arena != NULL) { |
2078 | 0 | arena->Own(n); |
2079 | 0 | } |
2080 | 0 | return n; |
2081 | 0 | } |
2082 | | |
2083 | 477k | void VersionEditPB::Clear() { |
2084 | | // @@protoc_insertion_point(message_clear_start:rocksdb.VersionEditPB) |
2085 | 477k | ::google::protobuf::uint32 cached_has_bits = 0; |
2086 | | // Prevent compiler warnings about cached_has_bits being unused |
2087 | 477k | (void) cached_has_bits; |
2088 | | |
2089 | 477k | deleted_files_.Clear(); |
2090 | 477k | new_files_.Clear(); |
2091 | 477k | cached_has_bits = _has_bits_[0]; |
2092 | 477k | if (cached_has_bits & 15u) { |
2093 | 0 | if (cached_has_bits & 0x00000001u) { |
2094 | 0 | GOOGLE_DCHECK(!comparator_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2095 | 0 | (*comparator_.UnsafeRawStringPointer())->clear(); |
2096 | 0 | } |
2097 | 0 | if (cached_has_bits & 0x00000002u) { |
2098 | 0 | GOOGLE_DCHECK(!column_family_name_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited())); |
2099 | 0 | (*column_family_name_.UnsafeRawStringPointer())->clear(); |
2100 | 0 | } |
2101 | 0 | if (cached_has_bits & 0x00000004u) { |
2102 | 0 | GOOGLE_DCHECK(obsolete_last_op_id_ != NULL); |
2103 | 0 | obsolete_last_op_id_->Clear(); |
2104 | 0 | } |
2105 | 0 | if (cached_has_bits & 0x00000008u) { |
2106 | 0 | GOOGLE_DCHECK(flushed_frontier_ != NULL); |
2107 | 0 | flushed_frontier_->Clear(); |
2108 | 0 | } |
2109 | 0 | } |
2110 | 477k | if (cached_has_bits & 240u) { |
2111 | 0 | ::memset(&log_number_, 0, static_cast<size_t>( |
2112 | 0 | reinterpret_cast<char*>(&last_sequence_) - |
2113 | 0 | reinterpret_cast<char*>(&log_number_)) + sizeof(last_sequence_)); |
2114 | 0 | } |
2115 | 477k | if (cached_has_bits & 1792u) { |
2116 | 0 | ::memset(&max_column_family_, 0, static_cast<size_t>( |
2117 | 0 | reinterpret_cast<char*>(&is_column_family_drop_) - |
2118 | 0 | reinterpret_cast<char*>(&max_column_family_)) + sizeof(is_column_family_drop_)); |
2119 | 0 | } |
2120 | 477k | _has_bits_.Clear(); |
2121 | 477k | _internal_metadata_.Clear(); |
2122 | 477k | } |
2123 | | |
2124 | | bool VersionEditPB::MergePartialFromCodedStream( |
2125 | 476k | ::google::protobuf::io::CodedInputStream* input) { |
2126 | 1.48M | #define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0 |
2127 | 476k | ::google::protobuf::uint32 tag; |
2128 | | // @@protoc_insertion_point(parse_start:rocksdb.VersionEditPB) |
2129 | 1.95M | for (;;) { |
2130 | 1.95M | ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u); |
2131 | 1.95M | tag = p.first; |
2132 | 1.95M | if (!p.second) goto handle_unusual477k ; |
2133 | 1.47M | switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { |
2134 | | // optional string comparator = 1; |
2135 | 14.2k | case 1: { |
2136 | 14.2k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2137 | 14.2k | static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) { |
2138 | 14.2k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
2139 | 14.2k | input, this->mutable_comparator())); |
2140 | 14.2k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2141 | 14.2k | this->comparator().data(), static_cast<int>(this->comparator().length()), |
2142 | 14.2k | ::google::protobuf::internal::WireFormat::PARSE, |
2143 | 14.2k | "rocksdb.VersionEditPB.comparator"); |
2144 | 18.4E | } else { |
2145 | 18.4E | goto handle_unusual; |
2146 | 18.4E | } |
2147 | 14.2k | break; |
2148 | 14.2k | } |
2149 | | |
2150 | | // optional uint64 log_number = 2; |
2151 | 456k | case 2: { |
2152 | 456k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2153 | 456k | static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) { |
2154 | 456k | set_has_log_number(); |
2155 | 456k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2156 | 456k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
2157 | 456k | input, &log_number_))); |
2158 | 18.4E | } else { |
2159 | 18.4E | goto handle_unusual; |
2160 | 18.4E | } |
2161 | 456k | break; |
2162 | 456k | } |
2163 | | |
2164 | | // optional uint64 prev_log_number = 3; |
2165 | 456k | case 3: { |
2166 | 24.9k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2167 | 24.9k | static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) { |
2168 | 24.9k | set_has_prev_log_number(); |
2169 | 24.9k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2170 | 24.9k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
2171 | 24.9k | input, &prev_log_number_))); |
2172 | 24.9k | } else { |
2173 | 0 | goto handle_unusual; |
2174 | 0 | } |
2175 | 24.9k | break; |
2176 | 24.9k | } |
2177 | | |
2178 | | // optional uint64 next_file_number = 4; |
2179 | 452k | case 4: { |
2180 | 452k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2181 | 452k | static_cast< ::google::protobuf::uint8>(32u /* 32 & 0xFF */)) { |
2182 | 452k | set_has_next_file_number(); |
2183 | 452k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2184 | 452k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
2185 | 452k | input, &next_file_number_))); |
2186 | 452k | } else { |
2187 | 1 | goto handle_unusual; |
2188 | 1 | } |
2189 | 452k | break; |
2190 | 452k | } |
2191 | | |
2192 | | // optional uint32 max_column_family = 5; |
2193 | 452k | case 5: { |
2194 | 2.60k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2195 | 2.60k | static_cast< ::google::protobuf::uint8>(40u /* 40 & 0xFF */)) { |
2196 | 2.60k | set_has_max_column_family(); |
2197 | 2.60k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2198 | 2.60k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
2199 | 2.60k | input, &max_column_family_))); |
2200 | 2.60k | } else { |
2201 | 0 | goto handle_unusual; |
2202 | 0 | } |
2203 | 2.60k | break; |
2204 | 2.60k | } |
2205 | | |
2206 | | // optional uint64 last_sequence = 6; |
2207 | 452k | case 6: { |
2208 | 452k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2209 | 452k | static_cast< ::google::protobuf::uint8>(48u /* 48 & 0xFF */)) { |
2210 | 452k | set_has_last_sequence(); |
2211 | 452k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2212 | 452k | ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_UINT64>( |
2213 | 452k | input, &last_sequence_))); |
2214 | 452k | } else { |
2215 | 125 | goto handle_unusual; |
2216 | 125 | } |
2217 | 452k | break; |
2218 | 452k | } |
2219 | | |
2220 | | // repeated .rocksdb.DeletedFilePB deleted_files = 7; |
2221 | 452k | case 7: { |
2222 | 15.8k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2223 | 15.8k | static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) { |
2224 | 15.8k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_deleted_files())); |
2225 | 15.8k | } else { |
2226 | 0 | goto handle_unusual; |
2227 | 0 | } |
2228 | 15.8k | break; |
2229 | 15.8k | } |
2230 | | |
2231 | | // repeated .rocksdb.NewFilePB new_files = 8; |
2232 | 41.7k | case 8: { |
2233 | 41.7k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2234 | 41.7k | static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) { |
2235 | 41.7k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_new_files())); |
2236 | 41.7k | } else { |
2237 | 4 | goto handle_unusual; |
2238 | 4 | } |
2239 | 41.7k | break; |
2240 | 41.7k | } |
2241 | | |
2242 | | // optional uint32 column_family = 9; |
2243 | 41.7k | case 9: { |
2244 | 7.01k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2245 | 7.01k | static_cast< ::google::protobuf::uint8>(72u /* 72 & 0xFF */)) { |
2246 | 7.01k | set_has_column_family(); |
2247 | 7.01k | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2248 | 7.01k | ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>( |
2249 | 7.01k | input, &column_family_))); |
2250 | 7.01k | } else { |
2251 | 0 | goto handle_unusual; |
2252 | 0 | } |
2253 | 7.01k | break; |
2254 | 7.01k | } |
2255 | | |
2256 | | // optional string column_family_name = 10; |
2257 | 7.01k | case 10: { |
2258 | 2.95k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2259 | 2.95k | static_cast< ::google::protobuf::uint8>(82u /* 82 & 0xFF */)) { |
2260 | 2.95k | DO_(::google::protobuf::internal::WireFormatLite::ReadString( |
2261 | 2.95k | input, this->mutable_column_family_name())); |
2262 | 2.95k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2263 | 2.95k | this->column_family_name().data(), static_cast<int>(this->column_family_name().length()), |
2264 | 2.95k | ::google::protobuf::internal::WireFormat::PARSE, |
2265 | 2.95k | "rocksdb.VersionEditPB.column_family_name"); |
2266 | 2.95k | } else { |
2267 | 0 | goto handle_unusual; |
2268 | 0 | } |
2269 | 2.95k | break; |
2270 | 2.95k | } |
2271 | | |
2272 | | // optional bool is_column_family_drop = 11; |
2273 | 2.95k | case 11: { |
2274 | 11 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2275 | 11 | static_cast< ::google::protobuf::uint8>(88u /* 88 & 0xFF */)) { |
2276 | 11 | set_has_is_column_family_drop(); |
2277 | 11 | DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< |
2278 | 11 | bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( |
2279 | 11 | input, &is_column_family_drop_))); |
2280 | 11 | } else { |
2281 | 0 | goto handle_unusual; |
2282 | 0 | } |
2283 | 11 | break; |
2284 | 11 | } |
2285 | | |
2286 | | // optional .yb.OpIdPB obsolete_last_op_id = 12; |
2287 | 11 | case 12: { |
2288 | 0 | if (static_cast< ::google::protobuf::uint8>(tag) == |
2289 | 0 | static_cast< ::google::protobuf::uint8>(98u /* 98 & 0xFF */)) { |
2290 | 0 | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2291 | 0 | input, mutable_obsolete_last_op_id())); |
2292 | 0 | } else { |
2293 | 0 | goto handle_unusual; |
2294 | 0 | } |
2295 | 0 | break; |
2296 | 0 | } |
2297 | | |
2298 | | // optional .google.protobuf.Any flushed_frontier = 13; |
2299 | 11.4k | case 13: { |
2300 | 11.4k | if (static_cast< ::google::protobuf::uint8>(tag) == |
2301 | 11.4k | static_cast< ::google::protobuf::uint8>(106u /* 106 & 0xFF */)) { |
2302 | 11.4k | DO_(::google::protobuf::internal::WireFormatLite::ReadMessage( |
2303 | 11.4k | input, mutable_flushed_frontier())); |
2304 | 11.4k | } else { |
2305 | 0 | goto handle_unusual; |
2306 | 0 | } |
2307 | 11.4k | break; |
2308 | 11.4k | } |
2309 | | |
2310 | 11.4k | default: { |
2311 | 477k | handle_unusual: |
2312 | 477k | if (tag == 0477k ) { |
2313 | 477k | goto success; |
2314 | 477k | } |
2315 | 18.4E | DO_(::google::protobuf::internal::WireFormat::SkipField( |
2316 | 18.4E | input, tag, _internal_metadata_.mutable_unknown_fields())); |
2317 | 18.4E | break; |
2318 | 18.4E | } |
2319 | 1.47M | } |
2320 | 1.47M | } |
2321 | 18.4E | success: |
2322 | | // @@protoc_insertion_point(parse_success:rocksdb.VersionEditPB) |
2323 | 477k | return true; |
2324 | 0 | failure: |
2325 | | // @@protoc_insertion_point(parse_failure:rocksdb.VersionEditPB) |
2326 | 0 | return false; |
2327 | 476k | #undef DO_ |
2328 | 476k | } |
2329 | | |
2330 | | void VersionEditPB::SerializeWithCachedSizes( |
2331 | 0 | ::google::protobuf::io::CodedOutputStream* output) const { |
2332 | | // @@protoc_insertion_point(serialize_start:rocksdb.VersionEditPB) |
2333 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
2334 | 0 | (void) cached_has_bits; |
2335 | |
|
2336 | 0 | cached_has_bits = _has_bits_[0]; |
2337 | | // optional string comparator = 1; |
2338 | 0 | if (cached_has_bits & 0x00000001u) { |
2339 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2340 | 0 | this->comparator().data(), static_cast<int>(this->comparator().length()), |
2341 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2342 | 0 | "rocksdb.VersionEditPB.comparator"); |
2343 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
2344 | 0 | 1, this->comparator(), output); |
2345 | 0 | } |
2346 | | |
2347 | | // optional uint64 log_number = 2; |
2348 | 0 | if (cached_has_bits & 0x00000010u) { |
2349 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(2, this->log_number(), output); |
2350 | 0 | } |
2351 | | |
2352 | | // optional uint64 prev_log_number = 3; |
2353 | 0 | if (cached_has_bits & 0x00000020u) { |
2354 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(3, this->prev_log_number(), output); |
2355 | 0 | } |
2356 | | |
2357 | | // optional uint64 next_file_number = 4; |
2358 | 0 | if (cached_has_bits & 0x00000040u) { |
2359 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(4, this->next_file_number(), output); |
2360 | 0 | } |
2361 | | |
2362 | | // optional uint32 max_column_family = 5; |
2363 | 0 | if (cached_has_bits & 0x00000100u) { |
2364 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(5, this->max_column_family(), output); |
2365 | 0 | } |
2366 | | |
2367 | | // optional uint64 last_sequence = 6; |
2368 | 0 | if (cached_has_bits & 0x00000080u) { |
2369 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt64(6, this->last_sequence(), output); |
2370 | 0 | } |
2371 | | |
2372 | | // repeated .rocksdb.DeletedFilePB deleted_files = 7; |
2373 | 0 | for (unsigned int i = 0, |
2374 | 0 | n = static_cast<unsigned int>(this->deleted_files_size()); i < n; i++) { |
2375 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2376 | 0 | 7, this->deleted_files(static_cast<int>(i)), output); |
2377 | 0 | } |
2378 | | |
2379 | | // repeated .rocksdb.NewFilePB new_files = 8; |
2380 | 0 | for (unsigned int i = 0, |
2381 | 0 | n = static_cast<unsigned int>(this->new_files_size()); i < n; i++) { |
2382 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2383 | 0 | 8, this->new_files(static_cast<int>(i)), output); |
2384 | 0 | } |
2385 | | |
2386 | | // optional uint32 column_family = 9; |
2387 | 0 | if (cached_has_bits & 0x00000200u) { |
2388 | 0 | ::google::protobuf::internal::WireFormatLite::WriteUInt32(9, this->column_family(), output); |
2389 | 0 | } |
2390 | | |
2391 | | // optional string column_family_name = 10; |
2392 | 0 | if (cached_has_bits & 0x00000002u) { |
2393 | 0 | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2394 | 0 | this->column_family_name().data(), static_cast<int>(this->column_family_name().length()), |
2395 | 0 | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2396 | 0 | "rocksdb.VersionEditPB.column_family_name"); |
2397 | 0 | ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased( |
2398 | 0 | 10, this->column_family_name(), output); |
2399 | 0 | } |
2400 | | |
2401 | | // optional bool is_column_family_drop = 11; |
2402 | 0 | if (cached_has_bits & 0x00000400u) { |
2403 | 0 | ::google::protobuf::internal::WireFormatLite::WriteBool(11, this->is_column_family_drop(), output); |
2404 | 0 | } |
2405 | | |
2406 | | // optional .yb.OpIdPB obsolete_last_op_id = 12; |
2407 | 0 | if (cached_has_bits & 0x00000004u) { |
2408 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2409 | 0 | 12, *this->obsolete_last_op_id_, output); |
2410 | 0 | } |
2411 | | |
2412 | | // optional .google.protobuf.Any flushed_frontier = 13; |
2413 | 0 | if (cached_has_bits & 0x00000008u) { |
2414 | 0 | ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray( |
2415 | 0 | 13, *this->flushed_frontier_, output); |
2416 | 0 | } |
2417 | |
|
2418 | 0 | if (_internal_metadata_.have_unknown_fields()) { |
2419 | 0 | ::google::protobuf::internal::WireFormat::SerializeUnknownFields( |
2420 | 0 | _internal_metadata_.unknown_fields(), output); |
2421 | 0 | } |
2422 | | // @@protoc_insertion_point(serialize_end:rocksdb.VersionEditPB) |
2423 | 0 | } |
2424 | | |
2425 | | ::google::protobuf::uint8* VersionEditPB::InternalSerializeWithCachedSizesToArray( |
2426 | 1.32M | bool deterministic, ::google::protobuf::uint8* target) const { |
2427 | 1.32M | (void)deterministic; // Unused |
2428 | | // @@protoc_insertion_point(serialize_to_array_start:rocksdb.VersionEditPB) |
2429 | 1.32M | ::google::protobuf::uint32 cached_has_bits = 0; |
2430 | 1.32M | (void) cached_has_bits; |
2431 | | |
2432 | 1.32M | cached_has_bits = _has_bits_[0]; |
2433 | | // optional string comparator = 1; |
2434 | 1.32M | if (cached_has_bits & 0x00000001u) { |
2435 | 282k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2436 | 282k | this->comparator().data(), static_cast<int>(this->comparator().length()), |
2437 | 282k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2438 | 282k | "rocksdb.VersionEditPB.comparator"); |
2439 | 282k | target = |
2440 | 282k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
2441 | 282k | 1, this->comparator(), target); |
2442 | 282k | } |
2443 | | |
2444 | | // optional uint64 log_number = 2; |
2445 | 1.32M | if (cached_has_bits & 0x00000010u) { |
2446 | 745k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(2, this->log_number(), target); |
2447 | 745k | } |
2448 | | |
2449 | | // optional uint64 prev_log_number = 3; |
2450 | 1.32M | if (cached_has_bits & 0x00000020u) { |
2451 | 333k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(3, this->prev_log_number(), target); |
2452 | 333k | } |
2453 | | |
2454 | | // optional uint64 next_file_number = 4; |
2455 | 1.32M | if (cached_has_bits & 0x00000040u) { |
2456 | 759k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(4, this->next_file_number(), target); |
2457 | 759k | } |
2458 | | |
2459 | | // optional uint32 max_column_family = 5; |
2460 | 1.32M | if (cached_has_bits & 0x00000100u) { |
2461 | 4.26k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(5, this->max_column_family(), target); |
2462 | 4.26k | } |
2463 | | |
2464 | | // optional uint64 last_sequence = 6; |
2465 | 1.32M | if (cached_has_bits & 0x00000080u) { |
2466 | 759k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt64ToArray(6, this->last_sequence(), target); |
2467 | 759k | } |
2468 | | |
2469 | | // repeated .rocksdb.DeletedFilePB deleted_files = 7; |
2470 | 1.32M | for (unsigned int i = 0, |
2471 | 1.38M | n = static_cast<unsigned int>(this->deleted_files_size()); i < n; i++65.3k ) { |
2472 | 65.3k | target = ::google::protobuf::internal::WireFormatLite:: |
2473 | 65.3k | InternalWriteMessageToArray( |
2474 | 65.3k | 7, this->deleted_files(static_cast<int>(i)), deterministic, target); |
2475 | 65.3k | } |
2476 | | |
2477 | | // repeated .rocksdb.NewFilePB new_files = 8; |
2478 | 1.32M | for (unsigned int i = 0, |
2479 | 1.42M | n = static_cast<unsigned int>(this->new_files_size()); i < n; i++105k ) { |
2480 | 105k | target = ::google::protobuf::internal::WireFormatLite:: |
2481 | 105k | InternalWriteMessageToArray( |
2482 | 105k | 8, this->new_files(static_cast<int>(i)), deterministic, target); |
2483 | 105k | } |
2484 | | |
2485 | | // optional uint32 column_family = 9; |
2486 | 1.32M | if (cached_has_bits & 0x00000200u) { |
2487 | 25.5k | target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(9, this->column_family(), target); |
2488 | 25.5k | } |
2489 | | |
2490 | | // optional string column_family_name = 10; |
2491 | 1.32M | if (cached_has_bits & 0x00000002u) { |
2492 | 5.25k | ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField( |
2493 | 5.25k | this->column_family_name().data(), static_cast<int>(this->column_family_name().length()), |
2494 | 5.25k | ::google::protobuf::internal::WireFormat::SERIALIZE, |
2495 | 5.25k | "rocksdb.VersionEditPB.column_family_name"); |
2496 | 5.25k | target = |
2497 | 5.25k | ::google::protobuf::internal::WireFormatLite::WriteStringToArray( |
2498 | 5.25k | 10, this->column_family_name(), target); |
2499 | 5.25k | } |
2500 | | |
2501 | | // optional bool is_column_family_drop = 11; |
2502 | 1.32M | if (cached_has_bits & 0x00000400u) { |
2503 | 28 | target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(11, this->is_column_family_drop(), target); |
2504 | 28 | } |
2505 | | |
2506 | | // optional .yb.OpIdPB obsolete_last_op_id = 12; |
2507 | 1.32M | if (cached_has_bits & 0x00000004u) { |
2508 | 0 | target = ::google::protobuf::internal::WireFormatLite:: |
2509 | 0 | InternalWriteMessageToArray( |
2510 | 0 | 12, *this->obsolete_last_op_id_, deterministic, target); |
2511 | 0 | } |
2512 | | |
2513 | | // optional .google.protobuf.Any flushed_frontier = 13; |
2514 | 1.32M | if (cached_has_bits & 0x00000008u) { |
2515 | 279k | target = ::google::protobuf::internal::WireFormatLite:: |
2516 | 279k | InternalWriteMessageToArray( |
2517 | 279k | 13, *this->flushed_frontier_, deterministic, target); |
2518 | 279k | } |
2519 | | |
2520 | 1.32M | if (_internal_metadata_.have_unknown_fields()) { |
2521 | 0 | target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( |
2522 | 0 | _internal_metadata_.unknown_fields(), target); |
2523 | 0 | } |
2524 | | // @@protoc_insertion_point(serialize_to_array_end:rocksdb.VersionEditPB) |
2525 | 1.32M | return target; |
2526 | 1.32M | } |
2527 | | |
2528 | 1.32M | size_t VersionEditPB::ByteSizeLong() const { |
2529 | | // @@protoc_insertion_point(message_byte_size_start:rocksdb.VersionEditPB) |
2530 | 1.32M | size_t total_size = 0; |
2531 | | |
2532 | 1.32M | if (_internal_metadata_.have_unknown_fields()) { |
2533 | 0 | total_size += |
2534 | 0 | ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( |
2535 | 0 | _internal_metadata_.unknown_fields()); |
2536 | 0 | } |
2537 | | // repeated .rocksdb.DeletedFilePB deleted_files = 7; |
2538 | 1.32M | { |
2539 | 1.32M | unsigned int count = static_cast<unsigned int>(this->deleted_files_size()); |
2540 | 1.32M | total_size += 1UL * count; |
2541 | 1.38M | for (unsigned int i = 0; i < count; i++65.3k ) { |
2542 | 65.3k | total_size += |
2543 | 65.3k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2544 | 65.3k | this->deleted_files(static_cast<int>(i))); |
2545 | 65.3k | } |
2546 | 1.32M | } |
2547 | | |
2548 | | // repeated .rocksdb.NewFilePB new_files = 8; |
2549 | 1.32M | { |
2550 | 1.32M | unsigned int count = static_cast<unsigned int>(this->new_files_size()); |
2551 | 1.32M | total_size += 1UL * count; |
2552 | 1.42M | for (unsigned int i = 0; i < count; i++105k ) { |
2553 | 105k | total_size += |
2554 | 105k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2555 | 105k | this->new_files(static_cast<int>(i))); |
2556 | 105k | } |
2557 | 1.32M | } |
2558 | | |
2559 | 1.32M | if (_has_bits_[0 / 32] & 255u) { |
2560 | | // optional string comparator = 1; |
2561 | 1.32M | if (has_comparator()) { |
2562 | 282k | total_size += 1 + |
2563 | 282k | ::google::protobuf::internal::WireFormatLite::StringSize( |
2564 | 282k | this->comparator()); |
2565 | 282k | } |
2566 | | |
2567 | | // optional string column_family_name = 10; |
2568 | 1.32M | if (has_column_family_name()) { |
2569 | 5.25k | total_size += 1 + |
2570 | 5.25k | ::google::protobuf::internal::WireFormatLite::StringSize( |
2571 | 5.25k | this->column_family_name()); |
2572 | 5.25k | } |
2573 | | |
2574 | | // optional .yb.OpIdPB obsolete_last_op_id = 12; |
2575 | 1.32M | if (has_obsolete_last_op_id()) { |
2576 | 0 | total_size += 1 + |
2577 | 0 | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2578 | 0 | *this->obsolete_last_op_id_); |
2579 | 0 | } |
2580 | | |
2581 | | // optional .google.protobuf.Any flushed_frontier = 13; |
2582 | 1.32M | if (has_flushed_frontier()) { |
2583 | 279k | total_size += 1 + |
2584 | 279k | ::google::protobuf::internal::WireFormatLite::MessageSize( |
2585 | 279k | *this->flushed_frontier_); |
2586 | 279k | } |
2587 | | |
2588 | | // optional uint64 log_number = 2; |
2589 | 1.32M | if (has_log_number()) { |
2590 | 745k | total_size += 1 + |
2591 | 745k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
2592 | 745k | this->log_number()); |
2593 | 745k | } |
2594 | | |
2595 | | // optional uint64 prev_log_number = 3; |
2596 | 1.32M | if (has_prev_log_number()) { |
2597 | 333k | total_size += 1 + |
2598 | 333k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
2599 | 333k | this->prev_log_number()); |
2600 | 333k | } |
2601 | | |
2602 | | // optional uint64 next_file_number = 4; |
2603 | 1.32M | if (has_next_file_number()) { |
2604 | 759k | total_size += 1 + |
2605 | 759k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
2606 | 759k | this->next_file_number()); |
2607 | 759k | } |
2608 | | |
2609 | | // optional uint64 last_sequence = 6; |
2610 | 1.32M | if (has_last_sequence()) { |
2611 | 759k | total_size += 1 + |
2612 | 759k | ::google::protobuf::internal::WireFormatLite::UInt64Size( |
2613 | 759k | this->last_sequence()); |
2614 | 759k | } |
2615 | | |
2616 | 1.32M | } |
2617 | 1.32M | if (_has_bits_[8 / 32] & 1792u) { |
2618 | | // optional uint32 max_column_family = 5; |
2619 | 28.1k | if (has_max_column_family()) { |
2620 | 4.26k | total_size += 1 + |
2621 | 4.26k | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
2622 | 4.26k | this->max_column_family()); |
2623 | 4.26k | } |
2624 | | |
2625 | | // optional uint32 column_family = 9; |
2626 | 28.1k | if (has_column_family()) { |
2627 | 25.5k | total_size += 1 + |
2628 | 25.5k | ::google::protobuf::internal::WireFormatLite::UInt32Size( |
2629 | 25.5k | this->column_family()); |
2630 | 25.5k | } |
2631 | | |
2632 | | // optional bool is_column_family_drop = 11; |
2633 | 28.1k | if (has_is_column_family_drop()) { |
2634 | 28 | total_size += 1 + 1; |
2635 | 28 | } |
2636 | | |
2637 | 28.1k | } |
2638 | 1.32M | int cached_size = ::google::protobuf::internal::ToCachedSize(total_size); |
2639 | 1.32M | GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); |
2640 | 1.32M | _cached_size_ = cached_size; |
2641 | 1.32M | GOOGLE_SAFE_CONCURRENT_WRITES_END(); |
2642 | 1.32M | return total_size; |
2643 | 1.32M | } |
2644 | | |
2645 | 0 | void VersionEditPB::MergeFrom(const ::google::protobuf::Message& from) { |
2646 | | // @@protoc_insertion_point(generalized_merge_from_start:rocksdb.VersionEditPB) |
2647 | 0 | GOOGLE_DCHECK_NE(&from, this); |
2648 | 0 | const VersionEditPB* source = |
2649 | 0 | ::google::protobuf::internal::DynamicCastToGenerated<const VersionEditPB>( |
2650 | 0 | &from); |
2651 | 0 | if (source == NULL) { |
2652 | | // @@protoc_insertion_point(generalized_merge_from_cast_fail:rocksdb.VersionEditPB) |
2653 | 0 | ::google::protobuf::internal::ReflectionOps::Merge(from, this); |
2654 | 0 | } else { |
2655 | | // @@protoc_insertion_point(generalized_merge_from_cast_success:rocksdb.VersionEditPB) |
2656 | 0 | MergeFrom(*source); |
2657 | 0 | } |
2658 | 0 | } |
2659 | | |
2660 | 0 | void VersionEditPB::MergeFrom(const VersionEditPB& from) { |
2661 | | // @@protoc_insertion_point(class_specific_merge_from_start:rocksdb.VersionEditPB) |
2662 | 0 | GOOGLE_DCHECK_NE(&from, this); |
2663 | 0 | _internal_metadata_.MergeFrom(from._internal_metadata_); |
2664 | 0 | ::google::protobuf::uint32 cached_has_bits = 0; |
2665 | 0 | (void) cached_has_bits; |
2666 | |
|
2667 | 0 | deleted_files_.MergeFrom(from.deleted_files_); |
2668 | 0 | new_files_.MergeFrom(from.new_files_); |
2669 | 0 | cached_has_bits = from._has_bits_[0]; |
2670 | 0 | if (cached_has_bits & 255u) { |
2671 | 0 | if (cached_has_bits & 0x00000001u) { |
2672 | 0 | set_has_comparator(); |
2673 | 0 | comparator_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.comparator_); |
2674 | 0 | } |
2675 | 0 | if (cached_has_bits & 0x00000002u) { |
2676 | 0 | set_has_column_family_name(); |
2677 | 0 | column_family_name_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.column_family_name_); |
2678 | 0 | } |
2679 | 0 | if (cached_has_bits & 0x00000004u) { |
2680 | 0 | mutable_obsolete_last_op_id()->::yb::OpIdPB::MergeFrom(from.obsolete_last_op_id()); |
2681 | 0 | } |
2682 | 0 | if (cached_has_bits & 0x00000008u) { |
2683 | 0 | mutable_flushed_frontier()->::google::protobuf::Any::MergeFrom(from.flushed_frontier()); |
2684 | 0 | } |
2685 | 0 | if (cached_has_bits & 0x00000010u) { |
2686 | 0 | log_number_ = from.log_number_; |
2687 | 0 | } |
2688 | 0 | if (cached_has_bits & 0x00000020u) { |
2689 | 0 | prev_log_number_ = from.prev_log_number_; |
2690 | 0 | } |
2691 | 0 | if (cached_has_bits & 0x00000040u) { |
2692 | 0 | next_file_number_ = from.next_file_number_; |
2693 | 0 | } |
2694 | 0 | if (cached_has_bits & 0x00000080u) { |
2695 | 0 | last_sequence_ = from.last_sequence_; |
2696 | 0 | } |
2697 | 0 | _has_bits_[0] |= cached_has_bits; |
2698 | 0 | } |
2699 | 0 | if (cached_has_bits & 1792u) { |
2700 | 0 | if (cached_has_bits & 0x00000100u) { |
2701 | 0 | max_column_family_ = from.max_column_family_; |
2702 | 0 | } |
2703 | 0 | if (cached_has_bits & 0x00000200u) { |
2704 | 0 | column_family_ = from.column_family_; |
2705 | 0 | } |
2706 | 0 | if (cached_has_bits & 0x00000400u) { |
2707 | 0 | is_column_family_drop_ = from.is_column_family_drop_; |
2708 | 0 | } |
2709 | 0 | _has_bits_[0] |= cached_has_bits; |
2710 | 0 | } |
2711 | 0 | } |
2712 | | |
2713 | 0 | void VersionEditPB::CopyFrom(const ::google::protobuf::Message& from) { |
2714 | | // @@protoc_insertion_point(generalized_copy_from_start:rocksdb.VersionEditPB) |
2715 | 0 | if (&from == this) return; |
2716 | 0 | Clear(); |
2717 | 0 | MergeFrom(from); |
2718 | 0 | } |
2719 | | |
2720 | 0 | void VersionEditPB::CopyFrom(const VersionEditPB& from) { |
2721 | | // @@protoc_insertion_point(class_specific_copy_from_start:rocksdb.VersionEditPB) |
2722 | 0 | if (&from == this) return; |
2723 | 0 | Clear(); |
2724 | 0 | MergeFrom(from); |
2725 | 0 | } |
2726 | | |
2727 | 1.80M | bool VersionEditPB::IsInitialized() const { |
2728 | 1.80M | if (!::google::protobuf::internal::AllAreInitialized(this->new_files())) return false0 ; |
2729 | 1.80M | if (has_obsolete_last_op_id()) { |
2730 | 0 | if (!this->obsolete_last_op_id_->IsInitialized()) return false; |
2731 | 0 | } |
2732 | 1.80M | return true; |
2733 | 1.80M | } |
2734 | | |
2735 | 0 | void VersionEditPB::Swap(VersionEditPB* other) { |
2736 | 0 | if (other == this) return; |
2737 | 0 | InternalSwap(other); |
2738 | 0 | } |
2739 | 0 | void VersionEditPB::InternalSwap(VersionEditPB* other) { |
2740 | 0 | using std::swap; |
2741 | 0 | deleted_files_.InternalSwap(&other->deleted_files_); |
2742 | 0 | new_files_.InternalSwap(&other->new_files_); |
2743 | 0 | comparator_.Swap(&other->comparator_); |
2744 | 0 | column_family_name_.Swap(&other->column_family_name_); |
2745 | 0 | swap(obsolete_last_op_id_, other->obsolete_last_op_id_); |
2746 | 0 | swap(flushed_frontier_, other->flushed_frontier_); |
2747 | 0 | swap(log_number_, other->log_number_); |
2748 | 0 | swap(prev_log_number_, other->prev_log_number_); |
2749 | 0 | swap(next_file_number_, other->next_file_number_); |
2750 | 0 | swap(last_sequence_, other->last_sequence_); |
2751 | 0 | swap(max_column_family_, other->max_column_family_); |
2752 | 0 | swap(column_family_, other->column_family_); |
2753 | 0 | swap(is_column_family_drop_, other->is_column_family_drop_); |
2754 | 0 | swap(_has_bits_[0], other->_has_bits_[0]); |
2755 | 0 | _internal_metadata_.Swap(&other->_internal_metadata_); |
2756 | 0 | swap(_cached_size_, other->_cached_size_); |
2757 | 0 | } |
2758 | | |
2759 | 1.12M | ::google::protobuf::Metadata VersionEditPB::GetMetadata() const { |
2760 | 1.12M | protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::protobuf_AssignDescriptorsOnce(); |
2761 | 1.12M | return ::protobuf_yb_2frocksdb_2fdb_2fversion_5fedit_2eproto::file_level_metadata[kIndexInFileMessages]; |
2762 | 1.12M | } |
2763 | | |
2764 | | |
2765 | | // @@protoc_insertion_point(namespace_scope) |
2766 | | } // namespace rocksdb |
2767 | | |
2768 | | // @@protoc_insertion_point(global_scope) |