YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/docdb/docdb.pb.cc
Line
Count
Source (jump to first uncovered line)
1
// Generated by the protocol buffer compiler.  DO NOT EDIT!
2
// source: yb/docdb/docdb.proto
3
4
#include "yb/docdb/docdb.pb.h"
5
6
#include <algorithm>
7
8
#include <google/protobuf/stubs/common.h>
9
#include <google/protobuf/stubs/port.h>
10
#include <google/protobuf/stubs/once.h>
11
#include <google/protobuf/io/coded_stream.h>
12
#include <google/protobuf/wire_format_lite_inl.h>
13
#include <google/protobuf/descriptor.h>
14
#include <google/protobuf/generated_message_reflection.h>
15
#include <google/protobuf/reflection_ops.h>
16
#include <google/protobuf/wire_format.h>
17
// This is a temporary google only hack
18
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
19
#include "third_party/protobuf/version.h"
20
#endif
21
#include "yb/util/protobuf-annotations.h"
22
// @@protoc_insertion_point(includes)
23
namespace yb {
24
namespace docdb {
25
class KeyValuePairPBDefaultTypeInternal {
26
 public:
27
  ::google::protobuf::internal::ExplicitlyConstructed<KeyValuePairPB>
28
      _instance;
29
} _KeyValuePairPB_default_instance_;
30
class ApplyExternalTransactionPBDefaultTypeInternal {
31
 public:
32
  ::google::protobuf::internal::ExplicitlyConstructed<ApplyExternalTransactionPB>
33
      _instance;
34
} _ApplyExternalTransactionPB_default_instance_;
35
class KeyValueWriteBatchPBDefaultTypeInternal {
36
 public:
37
  ::google::protobuf::internal::ExplicitlyConstructed<KeyValueWriteBatchPB>
38
      _instance;
39
} _KeyValueWriteBatchPB_default_instance_;
40
class ConsensusFrontierPBDefaultTypeInternal {
41
 public:
42
  ::google::protobuf::internal::ExplicitlyConstructed<ConsensusFrontierPB>
43
      _instance;
44
} _ConsensusFrontierPB_default_instance_;
45
class ApplyTransactionStatePBDefaultTypeInternal {
46
 public:
47
  ::google::protobuf::internal::ExplicitlyConstructed<ApplyTransactionStatePB>
48
      _instance;
49
} _ApplyTransactionStatePB_default_instance_;
50
}  // namespace docdb
51
}  // namespace yb
52
namespace protobuf_yb_2fdocdb_2fdocdb_2eproto {
53
17.1k
void InitDefaultsKeyValuePairPBImpl() {
54
17.1k
  GOOGLE_PROTOBUF_VERIFY_VERSION;
55
56
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
57
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
58
#else
59
17.1k
  ::google::protobuf::internal::InitProtobufDefaults();
60
17.1k
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
61
17.1k
  {
62
17.1k
    void* ptr = &::yb::docdb::_KeyValuePairPB_default_instance_;
63
17.1k
    new (ptr) ::yb::docdb::KeyValuePairPB();
64
17.1k
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
65
17.1k
  }
66
17.1k
  ::yb::docdb::KeyValuePairPB::InitAsDefaultInstance();
67
17.1k
}
68
69
90.3M
void InitDefaultsKeyValuePairPB() {
70
90.3M
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
71
90.3M
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsKeyValuePairPBImpl);
72
90.3M
}
73
74
17.1k
void InitDefaultsApplyExternalTransactionPBImpl() {
75
17.1k
  GOOGLE_PROTOBUF_VERIFY_VERSION;
76
77
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
78
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
79
#else
80
17.1k
  ::google::protobuf::internal::InitProtobufDefaults();
81
17.1k
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
82
17.1k
  {
83
17.1k
    void* ptr = &::yb::docdb::_ApplyExternalTransactionPB_default_instance_;
84
17.1k
    new (ptr) ::yb::docdb::ApplyExternalTransactionPB();
85
17.1k
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
86
17.1k
  }
87
17.1k
  ::yb::docdb::ApplyExternalTransactionPB::InitAsDefaultInstance();
88
17.1k
}
89
90
34.2k
void InitDefaultsApplyExternalTransactionPB() {
91
34.2k
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
92
34.2k
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsApplyExternalTransactionPBImpl);
93
34.2k
}
94
95
17.1k
void InitDefaultsKeyValueWriteBatchPBImpl() {
96
17.1k
  GOOGLE_PROTOBUF_VERIFY_VERSION;
97
98
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
99
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
100
#else
101
17.1k
  ::google::protobuf::internal::InitProtobufDefaults();
102
17.1k
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
103
17.1k
  protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
104
17.1k
  protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsTransactionMetadataPB();
105
17.1k
  protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsSubTransactionMetadataPB();
106
17.1k
  protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
107
17.1k
  {
108
17.1k
    void* ptr = &::yb::docdb::_KeyValueWriteBatchPB_default_instance_;
109
17.1k
    new (ptr) ::yb::docdb::KeyValueWriteBatchPB();
110
17.1k
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
111
17.1k
  }
112
17.1k
  ::yb::docdb::KeyValueWriteBatchPB::InitAsDefaultInstance();
113
17.1k
}
114
115
7.32M
void InitDefaultsKeyValueWriteBatchPB() {
116
7.32M
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
117
7.32M
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsKeyValueWriteBatchPBImpl);
118
7.32M
}
119
120
17.1k
void InitDefaultsConsensusFrontierPBImpl() {
121
17.1k
  GOOGLE_PROTOBUF_VERIFY_VERSION;
122
123
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
124
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
125
#else
126
17.1k
  ::google::protobuf::internal::InitProtobufDefaults();
127
17.1k
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
128
17.1k
  protobuf_yb_2futil_2fopid_2eproto::InitDefaultsOpIdPB();
129
17.1k
  {
130
17.1k
    void* ptr = &::yb::docdb::_ConsensusFrontierPB_default_instance_;
131
17.1k
    new (ptr) ::yb::docdb::ConsensusFrontierPB();
132
17.1k
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
133
17.1k
  }
134
17.1k
  ::yb::docdb::ConsensusFrontierPB::InitAsDefaultInstance();
135
17.1k
}
136
137
316k
void InitDefaultsConsensusFrontierPB() {
138
316k
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
139
316k
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsConsensusFrontierPBImpl);
140
316k
}
141
142
17.1k
void InitDefaultsApplyTransactionStatePBImpl() {
143
17.1k
  GOOGLE_PROTOBUF_VERIFY_VERSION;
144
145
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
146
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
147
#else
148
17.1k
  ::google::protobuf::internal::InitProtobufDefaults();
149
17.1k
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
150
17.1k
  protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsAbortedSubTransactionSetPB();
151
17.1k
  {
152
17.1k
    void* ptr = &::yb::docdb::_ApplyTransactionStatePB_default_instance_;
153
17.1k
    new (ptr) ::yb::docdb::ApplyTransactionStatePB();
154
17.1k
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
155
17.1k
  }
156
17.1k
  ::yb::docdb::ApplyTransactionStatePB::InitAsDefaultInstance();
157
17.1k
}
158
159
17.1k
void InitDefaultsApplyTransactionStatePB() {
160
17.1k
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
161
17.1k
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsApplyTransactionStatePBImpl);
162
17.1k
}
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(::yb::docdb::KeyValuePairPB, _has_bits_),
168
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, _internal_metadata_),
169
  ~0u,  // no _extensions_
170
  ~0u,  // no _oneof_case_
171
  ~0u,  // no _weak_field_map_
172
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, key_),
173
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, value_),
174
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, external_hybrid_time_),
175
  0,
176
  1,
177
  2,
178
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, _has_bits_),
179
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, _internal_metadata_),
180
  ~0u,  // no _extensions_
181
  ~0u,  // no _oneof_case_
182
  ~0u,  // no _weak_field_map_
183
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, transaction_id_),
184
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, commit_hybrid_time_),
185
  0,
186
  1,
187
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, _has_bits_),
188
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, _internal_metadata_),
189
  ~0u,  // no _extensions_
190
  ~0u,  // no _oneof_case_
191
  ~0u,  // no _weak_field_map_
192
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, write_pairs_),
193
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, transaction_),
194
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, subtransaction_),
195
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, deprecated_may_have_metadata_),
196
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, read_pairs_),
197
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, row_mark_type_),
198
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, wait_policy_),
199
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, apply_external_transactions_),
200
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, ttl_),
201
  ~0u,
202
  0,
203
  1,
204
  2,
205
  ~0u,
206
  3,
207
  5,
208
  ~0u,
209
  4,
210
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, _has_bits_),
211
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, _internal_metadata_),
212
  ~0u,  // no _extensions_
213
  ~0u,  // no _oneof_case_
214
  ~0u,  // no _weak_field_map_
215
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, op_id_),
216
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, hybrid_time_),
217
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, history_cutoff_),
218
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, hybrid_time_filter_),
219
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, max_value_level_ttl_expiration_time_),
220
  0,
221
  1,
222
  2,
223
  3,
224
  4,
225
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, _has_bits_),
226
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, _internal_metadata_),
227
  ~0u,  // no _extensions_
228
  ~0u,  // no _oneof_case_
229
  ~0u,  // no _weak_field_map_
230
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, key_),
231
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, write_id_),
232
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, commit_ht_),
233
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, aborted_),
234
  0,
235
  3,
236
  2,
237
  1,
238
};
239
static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
240
  { 0, 8, sizeof(::yb::docdb::KeyValuePairPB)},
241
  { 11, 18, sizeof(::yb::docdb::ApplyExternalTransactionPB)},
242
  { 20, 34, sizeof(::yb::docdb::KeyValueWriteBatchPB)},
243
  { 43, 53, sizeof(::yb::docdb::ConsensusFrontierPB)},
244
  { 58, 67, sizeof(::yb::docdb::ApplyTransactionStatePB)},
245
};
246
247
static ::google::protobuf::Message const * const file_default_instances[] = {
248
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_KeyValuePairPB_default_instance_),
249
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ApplyExternalTransactionPB_default_instance_),
250
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_KeyValueWriteBatchPB_default_instance_),
251
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ConsensusFrontierPB_default_instance_),
252
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ApplyTransactionStatePB_default_instance_),
253
};
254
255
7.99k
void protobuf_AssignDescriptors() {
256
7.99k
  AddDescriptors();
257
7.99k
  ::google::protobuf::MessageFactory* factory = NULL;
258
7.99k
  AssignDescriptors(
259
7.99k
      "yb/docdb/docdb.proto", schemas, file_default_instances, TableStruct::offsets, factory,
260
7.99k
      file_level_metadata, NULL, NULL);
261
7.99k
}
262
263
187M
void protobuf_AssignDescriptorsOnce() {
264
187M
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
265
187M
  ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors);
266
187M
}
267
268
void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;
269
0
void protobuf_RegisterTypes(const ::std::string&) {
270
0
  protobuf_AssignDescriptorsOnce();
271
0
  ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 5);
272
0
}
273
274
17.1k
void AddDescriptorsImpl() {
275
17.1k
  InitDefaults();
276
17.1k
  static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
277
17.1k
      "\n\024yb/docdb/docdb.proto\022\010yb.docdb\032\026yb/com"
278
17.1k
      "mon/common.proto\032\033yb/common/transaction."
279
17.1k
      "proto\032\022yb/util/opid.proto\"J\n\016KeyValuePai"
280
17.1k
      "rPB\022\013\n\003key\030\001 \001(\014\022\r\n\005value\030\002 \001(\014\022\034\n\024exter"
281
17.1k
      "nal_hybrid_time\030\003 \001(\006\"P\n\032ApplyExternalTr"
282
17.1k
      "ansactionPB\022\026\n\016transaction_id\030\001 \001(\014\022\032\n\022c"
283
17.1k
      "ommit_hybrid_time\030\002 \001(\006\"\244\003\n\024KeyValueWrit"
284
17.1k
      "eBatchPB\022-\n\013write_pairs\030\001 \003(\0132\030.yb.docdb"
285
17.1k
      ".KeyValuePairPB\022.\n\013transaction\030\002 \001(\0132\031.y"
286
17.1k
      "b.TransactionMetadataPB\0224\n\016subtransactio"
287
17.1k
      "n\030\010 \001(\0132\034.yb.SubTransactionMetadataPB\022$\n"
288
17.1k
      "\034DEPRECATED_may_have_metadata\030\003 \001(\010\022,\n\nr"
289
17.1k
      "ead_pairs\030\005 \003(\0132\030.yb.docdb.KeyValuePairP"
290
17.1k
      "B\022&\n\rrow_mark_type\030\006 \001(\0162\017.yb.RowMarkTyp"
291
17.1k
      "e\022#\n\013wait_policy\030\n \001(\0162\016.yb.WaitPolicy\022I"
292
17.1k
      "\n\033apply_external_transactions\030\007 \003(\0132$.yb"
293
17.1k
      ".docdb.ApplyExternalTransactionPB\022\013\n\003ttl"
294
17.1k
      "\030\t \001(\003\"\246\001\n\023ConsensusFrontierPB\022\031\n\005op_id\030"
295
17.1k
      "\001 \001(\0132\n.yb.OpIdPB\022\023\n\013hybrid_time\030\002 \001(\006\022\026"
296
17.1k
      "\n\016history_cutoff\030\003 \001(\006\022\032\n\022hybrid_time_fi"
297
17.1k
      "lter\030\004 \001(\006\022+\n#max_value_level_ttl_expira"
298
17.1k
      "tion_time\030\005 \001(\006\"|\n\027ApplyTransactionState"
299
17.1k
      "PB\022\013\n\003key\030\001 \001(\014\022\020\n\010write_id\030\002 \001(\r\022\021\n\tcom"
300
17.1k
      "mit_ht\030\003 \001(\006\022/\n\007aborted\030\004 \001(\0132\036.yb.Abort"
301
17.1k
      "edSubTransactionSetPBB\016\n\014org.yb.docdb"
302
17.1k
  };
303
17.1k
  ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
304
17.1k
      descriptor, 997);
305
17.1k
  ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
306
17.1k
    "yb/docdb/docdb.proto", &protobuf_RegisterTypes);
307
17.1k
  ::protobuf_yb_2fcommon_2fcommon_2eproto::AddDescriptors();
308
17.1k
  ::protobuf_yb_2fcommon_2ftransaction_2eproto::AddDescriptors();
309
17.1k
  ::protobuf_yb_2futil_2fopid_2eproto::AddDescriptors();
310
17.1k
}
311
312
56.7k
void AddDescriptors() {
313
56.7k
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
314
56.7k
  ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl);
315
56.7k
}
316
// Force AddDescriptors() to be called at dynamic initialization time.
317
struct StaticDescriptorInitializer {
318
17.1k
  StaticDescriptorInitializer() {
319
17.1k
    AddDescriptors();
320
17.1k
  }
321
} static_descriptor_initializer;
322
}  // namespace protobuf_yb_2fdocdb_2fdocdb_2eproto
323
namespace yb {
324
namespace docdb {
325
326
// ===================================================================
327
328
17.1k
void KeyValuePairPB::InitAsDefaultInstance() {
329
17.1k
}
330
#if !defined(_MSC_VER) || _MSC_VER >= 1900
331
const int KeyValuePairPB::kKeyFieldNumber;
332
const int KeyValuePairPB::kValueFieldNumber;
333
const int KeyValuePairPB::kExternalHybridTimeFieldNumber;
334
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900
335
336
KeyValuePairPB::KeyValuePairPB()
337
90.2M
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
338
90.2M
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
339
90.2M
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
340
90.2M
  }
341
90.2M
  SharedCtor();
342
  // @@protoc_insertion_point(constructor:yb.docdb.KeyValuePairPB)
343
90.2M
}
344
KeyValuePairPB::KeyValuePairPB(const KeyValuePairPB& from)
345
  : ::google::protobuf::Message(),
346
      _internal_metadata_(NULL),
347
      _has_bits_(from._has_bits_),
348
0
      _cached_size_(0) {
349
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
350
0
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
351
0
  if (from.has_key()) {
352
0
    key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
353
0
  }
354
0
  value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
355
0
  if (from.has_value()) {
356
0
    value_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.value_);
357
0
  }
358
0
  external_hybrid_time_ = from.external_hybrid_time_;
359
  // @@protoc_insertion_point(copy_constructor:yb.docdb.KeyValuePairPB)
360
0
}
361
362
90.2M
void KeyValuePairPB::SharedCtor() {
363
90.2M
  _cached_size_ = 0;
364
90.2M
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
365
90.2M
  value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
366
90.2M
  external_hybrid_time_ = GOOGLE_ULONGLONG(0);
367
90.2M
}
368
369
86.7M
KeyValuePairPB::~KeyValuePairPB() {
370
  // @@protoc_insertion_point(destructor:yb.docdb.KeyValuePairPB)
371
86.7M
  SharedDtor();
372
86.7M
}
373
374
86.7M
void KeyValuePairPB::SharedDtor() {
375
86.7M
  key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
376
86.7M
  value_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
377
86.7M
}
378
379
0
void KeyValuePairPB::SetCachedSize(int size) const {
380
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
381
0
  _cached_size_ = size;
382
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
383
0
}
384
0
const ::google::protobuf::Descriptor* KeyValuePairPB::descriptor() {
385
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
386
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
387
0
}
388
389
0
const KeyValuePairPB& KeyValuePairPB::default_instance() {
390
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
391
0
  return *internal_default_instance();
392
0
}
393
394
0
KeyValuePairPB* KeyValuePairPB::New(::google::protobuf::Arena* arena) const {
395
0
  KeyValuePairPB* n = new KeyValuePairPB;
396
0
  if (arena != NULL) {
397
0
    arena->Own(n);
398
0
  }
399
0
  return n;
400
0
}
401
402
498k
void KeyValuePairPB::Clear() {
403
// @@protoc_insertion_point(message_clear_start:yb.docdb.KeyValuePairPB)
404
498k
  ::google::protobuf::uint32 cached_has_bits = 0;
405
  // Prevent compiler warnings about cached_has_bits being unused
406
498k
  (void) cached_has_bits;
407
408
498k
  cached_has_bits = _has_bits_[0];
409
498k
  if (cached_has_bits & 3u) {
410
498k
    if (cached_has_bits & 0x00000001u) {
411
498k
      GOOGLE_DCHECK(!key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
412
498k
      (*key_.UnsafeRawStringPointer())->clear();
413
498k
    }
414
498k
    if (cached_has_bits & 0x00000002u) {
415
498k
      GOOGLE_DCHECK(!value_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
416
498k
      (*value_.UnsafeRawStringPointer())->clear();
417
498k
    }
418
498k
  }
419
498k
  external_hybrid_time_ = GOOGLE_ULONGLONG(0);
420
498k
  _has_bits_.Clear();
421
498k
  _internal_metadata_.Clear();
422
498k
}
423
424
bool KeyValuePairPB::MergePartialFromCodedStream(
425
65.3M
    ::google::protobuf::io::CodedInputStream* input) {
426
130M
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
427
65.3M
  ::google::protobuf::uint32 tag;
428
  // @@protoc_insertion_point(parse_start:yb.docdb.KeyValuePairPB)
429
195M
  for (;;) {
430
195M
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
431
195M
    tag = p.first;
432
195M
    if (!p.second) goto handle_unusual;
433
129M
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
434
      // optional bytes key = 1;
435
65.3M
      case 1: {
436
65.3M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
437
65.3M
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
438
65.3M
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
439
65.3M
                input, this->mutable_key()));
440
18.4E
        } else {
441
18.4E
          goto handle_unusual;
442
18.4E
        }
443
65.3M
        break;
444
65.3M
      }
445
446
      // optional bytes value = 2;
447
65.4M
      case 2: {
448
65.4M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
449
65.4M
            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
450
65.4M
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
451
65.4M
                input, this->mutable_value()));
452
18.4E
        } else {
453
18.4E
          goto handle_unusual;
454
18.4E
        }
455
65.4M
        break;
456
65.4M
      }
457
458
      // optional fixed64 external_hybrid_time = 3;
459
0
      case 3: {
460
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
461
0
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
462
0
          set_has_external_hybrid_time();
463
0
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
464
0
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
465
0
                 input, &external_hybrid_time_)));
466
0
        } else {
467
0
          goto handle_unusual;
468
0
        }
469
0
        break;
470
65.3M
      }
471
472
0
      default: {
473
65.3M
      handle_unusual:
474
65.4M
        if (tag == 0) {
475
65.4M
          goto success;
476
65.4M
        }
477
18.4E
        DO_(::google::protobuf::internal::WireFormat::SkipField(
478
18.4E
              input, tag, _internal_metadata_.mutable_unknown_fields()));
479
18.4E
        break;
480
18.4E
      }
481
129M
    }
482
129M
  }
483
65.3M
success:
484
  // @@protoc_insertion_point(parse_success:yb.docdb.KeyValuePairPB)
485
65.3M
  return true;
486
0
failure:
487
  // @@protoc_insertion_point(parse_failure:yb.docdb.KeyValuePairPB)
488
0
  return false;
489
65.3M
#undef DO_
490
65.3M
}
491
492
void KeyValuePairPB::SerializeWithCachedSizes(
493
0
    ::google::protobuf::io::CodedOutputStream* output) const {
494
  // @@protoc_insertion_point(serialize_start:yb.docdb.KeyValuePairPB)
495
0
  ::google::protobuf::uint32 cached_has_bits = 0;
496
0
  (void) cached_has_bits;
497
498
0
  cached_has_bits = _has_bits_[0];
499
  // optional bytes key = 1;
500
0
  if (cached_has_bits & 0x00000001u) {
501
0
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
502
0
      1, this->key(), output);
503
0
  }
504
505
  // optional bytes value = 2;
506
0
  if (cached_has_bits & 0x00000002u) {
507
0
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
508
0
      2, this->value(), output);
509
0
  }
510
511
  // optional fixed64 external_hybrid_time = 3;
512
0
  if (cached_has_bits & 0x00000004u) {
513
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->external_hybrid_time(), output);
514
0
  }
515
516
0
  if (_internal_metadata_.have_unknown_fields()) {
517
0
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
518
0
        _internal_metadata_.unknown_fields(), output);
519
0
  }
520
  // @@protoc_insertion_point(serialize_end:yb.docdb.KeyValuePairPB)
521
0
}
522
523
::google::protobuf::uint8* KeyValuePairPB::InternalSerializeWithCachedSizesToArray(
524
130M
    bool deterministic, ::google::protobuf::uint8* target) const {
525
130M
  (void)deterministic; // Unused
526
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.KeyValuePairPB)
527
130M
  ::google::protobuf::uint32 cached_has_bits = 0;
528
130M
  (void) cached_has_bits;
529
530
130M
  cached_has_bits = _has_bits_[0];
531
  // optional bytes key = 1;
532
130M
  if (cached_has_bits & 0x00000001u) {
533
130M
    target =
534
130M
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
535
130M
        1, this->key(), target);
536
130M
  }
537
538
  // optional bytes value = 2;
539
130M
  if (cached_has_bits & 0x00000002u) {
540
130M
    target =
541
130M
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
542
130M
        2, this->value(), target);
543
130M
  }
544
545
  // optional fixed64 external_hybrid_time = 3;
546
130M
  if (cached_has_bits & 0x00000004u) {
547
0
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->external_hybrid_time(), target);
548
0
  }
549
550
130M
  if (_internal_metadata_.have_unknown_fields()) {
551
0
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
552
0
        _internal_metadata_.unknown_fields(), target);
553
0
  }
554
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.KeyValuePairPB)
555
130M
  return target;
556
130M
}
557
558
307M
size_t KeyValuePairPB::ByteSizeLong() const {
559
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.KeyValuePairPB)
560
307M
  size_t total_size = 0;
561
562
307M
  if (_internal_metadata_.have_unknown_fields()) {
563
0
    total_size +=
564
0
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
565
0
        _internal_metadata_.unknown_fields());
566
0
  }
567
307M
  if (_has_bits_[0 / 32] & 7u) {
568
    // optional bytes key = 1;
569
306M
    if (has_key()) {
570
306M
      total_size += 1 +
571
306M
        ::google::protobuf::internal::WireFormatLite::BytesSize(
572
306M
          this->key());
573
306M
    }
574
575
    // optional bytes value = 2;
576
306M
    if (has_value()) {
577
303M
      total_size += 1 +
578
303M
        ::google::protobuf::internal::WireFormatLite::BytesSize(
579
303M
          this->value());
580
303M
    }
581
582
    // optional fixed64 external_hybrid_time = 3;
583
306M
    if (has_external_hybrid_time()) {
584
0
      total_size += 1 + 8;
585
0
    }
586
587
306M
  }
588
307M
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
589
307M
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
590
307M
  _cached_size_ = cached_size;
591
307M
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
592
307M
  return total_size;
593
307M
}
594
595
0
void KeyValuePairPB::MergeFrom(const ::google::protobuf::Message& from) {
596
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.KeyValuePairPB)
597
0
  GOOGLE_DCHECK_NE(&from, this);
598
0
  const KeyValuePairPB* source =
599
0
      ::google::protobuf::internal::DynamicCastToGenerated<const KeyValuePairPB>(
600
0
          &from);
601
0
  if (source == NULL) {
602
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.KeyValuePairPB)
603
0
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
604
0
  } else {
605
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.KeyValuePairPB)
606
0
    MergeFrom(*source);
607
0
  }
608
0
}
609
610
5.00k
void KeyValuePairPB::MergeFrom(const KeyValuePairPB& from) {
611
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.KeyValuePairPB)
612
5.00k
  GOOGLE_DCHECK_NE(&from, this);
613
5.00k
  _internal_metadata_.MergeFrom(from._internal_metadata_);
614
5.00k
  ::google::protobuf::uint32 cached_has_bits = 0;
615
5.00k
  (void) cached_has_bits;
616
617
5.00k
  cached_has_bits = from._has_bits_[0];
618
5.00k
  if (cached_has_bits & 7u) {
619
5.00k
    if (cached_has_bits & 0x00000001u) {
620
5.00k
      set_has_key();
621
5.00k
      key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
622
5.00k
    }
623
5.00k
    if (cached_has_bits & 0x00000002u) {
624
5.00k
      set_has_value();
625
5.00k
      value_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.value_);
626
5.00k
    }
627
5.00k
    if (cached_has_bits & 0x00000004u) {
628
0
      external_hybrid_time_ = from.external_hybrid_time_;
629
0
    }
630
5.00k
    _has_bits_[0] |= cached_has_bits;
631
5.00k
  }
632
5.00k
}
633
634
0
void KeyValuePairPB::CopyFrom(const ::google::protobuf::Message& from) {
635
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.KeyValuePairPB)
636
0
  if (&from == this) return;
637
0
  Clear();
638
0
  MergeFrom(from);
639
0
}
640
641
0
void KeyValuePairPB::CopyFrom(const KeyValuePairPB& from) {
642
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.KeyValuePairPB)
643
0
  if (&from == this) return;
644
0
  Clear();
645
0
  MergeFrom(from);
646
0
}
647
648
0
bool KeyValuePairPB::IsInitialized() const {
649
0
  return true;
650
0
}
651
652
0
void KeyValuePairPB::Swap(KeyValuePairPB* other) {
653
0
  if (other == this) return;
654
0
  InternalSwap(other);
655
0
}
656
0
void KeyValuePairPB::InternalSwap(KeyValuePairPB* other) {
657
0
  using std::swap;
658
0
  key_.Swap(&other->key_);
659
0
  value_.Swap(&other->value_);
660
0
  swap(external_hybrid_time_, other->external_hybrid_time_);
661
0
  swap(_has_bits_[0], other->_has_bits_[0]);
662
0
  _internal_metadata_.Swap(&other->_internal_metadata_);
663
0
  swap(_cached_size_, other->_cached_size_);
664
0
}
665
666
174M
::google::protobuf::Metadata KeyValuePairPB::GetMetadata() const {
667
174M
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
668
174M
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
669
174M
}
670
671
672
// ===================================================================
673
674
17.1k
void ApplyExternalTransactionPB::InitAsDefaultInstance() {
675
17.1k
}
676
#if !defined(_MSC_VER) || _MSC_VER >= 1900
677
const int ApplyExternalTransactionPB::kTransactionIdFieldNumber;
678
const int ApplyExternalTransactionPB::kCommitHybridTimeFieldNumber;
679
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900
680
681
ApplyExternalTransactionPB::ApplyExternalTransactionPB()
682
17.1k
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
683
0
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
684
0
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
685
0
  }
686
17.1k
  SharedCtor();
687
  // @@protoc_insertion_point(constructor:yb.docdb.ApplyExternalTransactionPB)
688
17.1k
}
689
ApplyExternalTransactionPB::ApplyExternalTransactionPB(const ApplyExternalTransactionPB& from)
690
  : ::google::protobuf::Message(),
691
      _internal_metadata_(NULL),
692
      _has_bits_(from._has_bits_),
693
0
      _cached_size_(0) {
694
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
695
0
  transaction_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
696
0
  if (from.has_transaction_id()) {
697
0
    transaction_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.transaction_id_);
698
0
  }
699
0
  commit_hybrid_time_ = from.commit_hybrid_time_;
700
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ApplyExternalTransactionPB)
701
0
}
702
703
17.1k
void ApplyExternalTransactionPB::SharedCtor() {
704
17.1k
  _cached_size_ = 0;
705
17.1k
  transaction_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
706
17.1k
  commit_hybrid_time_ = GOOGLE_ULONGLONG(0);
707
17.1k
}
708
709
0
ApplyExternalTransactionPB::~ApplyExternalTransactionPB() {
710
  // @@protoc_insertion_point(destructor:yb.docdb.ApplyExternalTransactionPB)
711
0
  SharedDtor();
712
0
}
713
714
0
void ApplyExternalTransactionPB::SharedDtor() {
715
0
  transaction_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
716
0
}
717
718
0
void ApplyExternalTransactionPB::SetCachedSize(int size) const {
719
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
720
0
  _cached_size_ = size;
721
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
722
0
}
723
0
const ::google::protobuf::Descriptor* ApplyExternalTransactionPB::descriptor() {
724
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
725
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
726
0
}
727
728
0
const ApplyExternalTransactionPB& ApplyExternalTransactionPB::default_instance() {
729
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
730
0
  return *internal_default_instance();
731
0
}
732
733
0
ApplyExternalTransactionPB* ApplyExternalTransactionPB::New(::google::protobuf::Arena* arena) const {
734
0
  ApplyExternalTransactionPB* n = new ApplyExternalTransactionPB;
735
0
  if (arena != NULL) {
736
0
    arena->Own(n);
737
0
  }
738
0
  return n;
739
0
}
740
741
0
void ApplyExternalTransactionPB::Clear() {
742
// @@protoc_insertion_point(message_clear_start:yb.docdb.ApplyExternalTransactionPB)
743
0
  ::google::protobuf::uint32 cached_has_bits = 0;
744
  // Prevent compiler warnings about cached_has_bits being unused
745
0
  (void) cached_has_bits;
746
747
0
  cached_has_bits = _has_bits_[0];
748
0
  if (cached_has_bits & 0x00000001u) {
749
0
    GOOGLE_DCHECK(!transaction_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
750
0
    (*transaction_id_.UnsafeRawStringPointer())->clear();
751
0
  }
752
0
  commit_hybrid_time_ = GOOGLE_ULONGLONG(0);
753
0
  _has_bits_.Clear();
754
0
  _internal_metadata_.Clear();
755
0
}
756
757
bool ApplyExternalTransactionPB::MergePartialFromCodedStream(
758
0
    ::google::protobuf::io::CodedInputStream* input) {
759
0
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
760
0
  ::google::protobuf::uint32 tag;
761
  // @@protoc_insertion_point(parse_start:yb.docdb.ApplyExternalTransactionPB)
762
0
  for (;;) {
763
0
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
764
0
    tag = p.first;
765
0
    if (!p.second) goto handle_unusual;
766
0
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
767
      // optional bytes transaction_id = 1;
768
0
      case 1: {
769
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
770
0
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
771
0
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
772
0
                input, this->mutable_transaction_id()));
773
0
        } else {
774
0
          goto handle_unusual;
775
0
        }
776
0
        break;
777
0
      }
778
779
      // optional fixed64 commit_hybrid_time = 2;
780
0
      case 2: {
781
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
782
0
            static_cast< ::google::protobuf::uint8>(17u /* 17 & 0xFF */)) {
783
0
          set_has_commit_hybrid_time();
784
0
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
785
0
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
786
0
                 input, &commit_hybrid_time_)));
787
0
        } else {
788
0
          goto handle_unusual;
789
0
        }
790
0
        break;
791
0
      }
792
793
0
      default: {
794
0
      handle_unusual:
795
0
        if (tag == 0) {
796
0
          goto success;
797
0
        }
798
0
        DO_(::google::protobuf::internal::WireFormat::SkipField(
799
0
              input, tag, _internal_metadata_.mutable_unknown_fields()));
800
0
        break;
801
0
      }
802
0
    }
803
0
  }
804
0
success:
805
  // @@protoc_insertion_point(parse_success:yb.docdb.ApplyExternalTransactionPB)
806
0
  return true;
807
0
failure:
808
  // @@protoc_insertion_point(parse_failure:yb.docdb.ApplyExternalTransactionPB)
809
0
  return false;
810
0
#undef DO_
811
0
}
812
813
void ApplyExternalTransactionPB::SerializeWithCachedSizes(
814
0
    ::google::protobuf::io::CodedOutputStream* output) const {
815
  // @@protoc_insertion_point(serialize_start:yb.docdb.ApplyExternalTransactionPB)
816
0
  ::google::protobuf::uint32 cached_has_bits = 0;
817
0
  (void) cached_has_bits;
818
819
0
  cached_has_bits = _has_bits_[0];
820
  // optional bytes transaction_id = 1;
821
0
  if (cached_has_bits & 0x00000001u) {
822
0
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
823
0
      1, this->transaction_id(), output);
824
0
  }
825
826
  // optional fixed64 commit_hybrid_time = 2;
827
0
  if (cached_has_bits & 0x00000002u) {
828
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(2, this->commit_hybrid_time(), output);
829
0
  }
830
831
0
  if (_internal_metadata_.have_unknown_fields()) {
832
0
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
833
0
        _internal_metadata_.unknown_fields(), output);
834
0
  }
835
  // @@protoc_insertion_point(serialize_end:yb.docdb.ApplyExternalTransactionPB)
836
0
}
837
838
::google::protobuf::uint8* ApplyExternalTransactionPB::InternalSerializeWithCachedSizesToArray(
839
0
    bool deterministic, ::google::protobuf::uint8* target) const {
840
0
  (void)deterministic; // Unused
841
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ApplyExternalTransactionPB)
842
0
  ::google::protobuf::uint32 cached_has_bits = 0;
843
0
  (void) cached_has_bits;
844
845
0
  cached_has_bits = _has_bits_[0];
846
  // optional bytes transaction_id = 1;
847
0
  if (cached_has_bits & 0x00000001u) {
848
0
    target =
849
0
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
850
0
        1, this->transaction_id(), target);
851
0
  }
852
853
  // optional fixed64 commit_hybrid_time = 2;
854
0
  if (cached_has_bits & 0x00000002u) {
855
0
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(2, this->commit_hybrid_time(), target);
856
0
  }
857
858
0
  if (_internal_metadata_.have_unknown_fields()) {
859
0
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
860
0
        _internal_metadata_.unknown_fields(), target);
861
0
  }
862
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ApplyExternalTransactionPB)
863
0
  return target;
864
0
}
865
866
0
size_t ApplyExternalTransactionPB::ByteSizeLong() const {
867
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ApplyExternalTransactionPB)
868
0
  size_t total_size = 0;
869
870
0
  if (_internal_metadata_.have_unknown_fields()) {
871
0
    total_size +=
872
0
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
873
0
        _internal_metadata_.unknown_fields());
874
0
  }
875
0
  if (_has_bits_[0 / 32] & 3u) {
876
    // optional bytes transaction_id = 1;
877
0
    if (has_transaction_id()) {
878
0
      total_size += 1 +
879
0
        ::google::protobuf::internal::WireFormatLite::BytesSize(
880
0
          this->transaction_id());
881
0
    }
882
883
    // optional fixed64 commit_hybrid_time = 2;
884
0
    if (has_commit_hybrid_time()) {
885
0
      total_size += 1 + 8;
886
0
    }
887
888
0
  }
889
0
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
890
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
891
0
  _cached_size_ = cached_size;
892
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
893
0
  return total_size;
894
0
}
895
896
0
void ApplyExternalTransactionPB::MergeFrom(const ::google::protobuf::Message& from) {
897
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ApplyExternalTransactionPB)
898
0
  GOOGLE_DCHECK_NE(&from, this);
899
0
  const ApplyExternalTransactionPB* source =
900
0
      ::google::protobuf::internal::DynamicCastToGenerated<const ApplyExternalTransactionPB>(
901
0
          &from);
902
0
  if (source == NULL) {
903
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ApplyExternalTransactionPB)
904
0
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
905
0
  } else {
906
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ApplyExternalTransactionPB)
907
0
    MergeFrom(*source);
908
0
  }
909
0
}
910
911
0
void ApplyExternalTransactionPB::MergeFrom(const ApplyExternalTransactionPB& from) {
912
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ApplyExternalTransactionPB)
913
0
  GOOGLE_DCHECK_NE(&from, this);
914
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
915
0
  ::google::protobuf::uint32 cached_has_bits = 0;
916
0
  (void) cached_has_bits;
917
918
0
  cached_has_bits = from._has_bits_[0];
919
0
  if (cached_has_bits & 3u) {
920
0
    if (cached_has_bits & 0x00000001u) {
921
0
      set_has_transaction_id();
922
0
      transaction_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.transaction_id_);
923
0
    }
924
0
    if (cached_has_bits & 0x00000002u) {
925
0
      commit_hybrid_time_ = from.commit_hybrid_time_;
926
0
    }
927
0
    _has_bits_[0] |= cached_has_bits;
928
0
  }
929
0
}
930
931
0
void ApplyExternalTransactionPB::CopyFrom(const ::google::protobuf::Message& from) {
932
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ApplyExternalTransactionPB)
933
0
  if (&from == this) return;
934
0
  Clear();
935
0
  MergeFrom(from);
936
0
}
937
938
0
void ApplyExternalTransactionPB::CopyFrom(const ApplyExternalTransactionPB& from) {
939
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ApplyExternalTransactionPB)
940
0
  if (&from == this) return;
941
0
  Clear();
942
0
  MergeFrom(from);
943
0
}
944
945
0
bool ApplyExternalTransactionPB::IsInitialized() const {
946
0
  return true;
947
0
}
948
949
0
void ApplyExternalTransactionPB::Swap(ApplyExternalTransactionPB* other) {
950
0
  if (other == this) return;
951
0
  InternalSwap(other);
952
0
}
953
0
void ApplyExternalTransactionPB::InternalSwap(ApplyExternalTransactionPB* other) {
954
0
  using std::swap;
955
0
  transaction_id_.Swap(&other->transaction_id_);
956
0
  swap(commit_hybrid_time_, other->commit_hybrid_time_);
957
0
  swap(_has_bits_[0], other->_has_bits_[0]);
958
0
  _internal_metadata_.Swap(&other->_internal_metadata_);
959
0
  swap(_cached_size_, other->_cached_size_);
960
0
}
961
962
0
::google::protobuf::Metadata ApplyExternalTransactionPB::GetMetadata() const {
963
0
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
964
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
965
0
}
966
967
968
// ===================================================================
969
970
17.1k
void KeyValueWriteBatchPB::InitAsDefaultInstance() {
971
17.1k
  ::yb::docdb::_KeyValueWriteBatchPB_default_instance_._instance.get_mutable()->transaction_ = const_cast< ::yb::TransactionMetadataPB*>(
972
17.1k
      ::yb::TransactionMetadataPB::internal_default_instance());
973
17.1k
  ::yb::docdb::_KeyValueWriteBatchPB_default_instance_._instance.get_mutable()->subtransaction_ = const_cast< ::yb::SubTransactionMetadataPB*>(
974
17.1k
      ::yb::SubTransactionMetadataPB::internal_default_instance());
975
17.1k
}
976
0
void KeyValueWriteBatchPB::clear_transaction() {
977
0
  if (transaction_ != NULL) transaction_->Clear();
978
0
  clear_has_transaction();
979
0
}
980
0
void KeyValueWriteBatchPB::clear_subtransaction() {
981
0
  if (subtransaction_ != NULL) subtransaction_->Clear();
982
0
  clear_has_subtransaction();
983
0
}
984
#if !defined(_MSC_VER) || _MSC_VER >= 1900
985
const int KeyValueWriteBatchPB::kWritePairsFieldNumber;
986
const int KeyValueWriteBatchPB::kTransactionFieldNumber;
987
const int KeyValueWriteBatchPB::kSubtransactionFieldNumber;
988
const int KeyValueWriteBatchPB::kDEPRECATEDMayHaveMetadataFieldNumber;
989
const int KeyValueWriteBatchPB::kReadPairsFieldNumber;
990
const int KeyValueWriteBatchPB::kRowMarkTypeFieldNumber;
991
const int KeyValueWriteBatchPB::kWaitPolicyFieldNumber;
992
const int KeyValueWriteBatchPB::kApplyExternalTransactionsFieldNumber;
993
const int KeyValueWriteBatchPB::kTtlFieldNumber;
994
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900
995
996
KeyValueWriteBatchPB::KeyValueWriteBatchPB()
997
7.29M
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
998
7.27M
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
999
7.27M
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValueWriteBatchPB();
1000
7.27M
  }
1001
7.29M
  SharedCtor();
1002
  // @@protoc_insertion_point(constructor:yb.docdb.KeyValueWriteBatchPB)
1003
7.29M
}
1004
KeyValueWriteBatchPB::KeyValueWriteBatchPB(const KeyValueWriteBatchPB& from)
1005
  : ::google::protobuf::Message(),
1006
      _internal_metadata_(NULL),
1007
      _has_bits_(from._has_bits_),
1008
      _cached_size_(0),
1009
      write_pairs_(from.write_pairs_),
1010
      read_pairs_(from.read_pairs_),
1011
90
      apply_external_transactions_(from.apply_external_transactions_) {
1012
90
  _internal_metadata_.MergeFrom(from._internal_metadata_);
1013
90
  if (from.has_transaction()) {
1014
0
    transaction_ = new ::yb::TransactionMetadataPB(*from.transaction_);
1015
90
  } else {
1016
90
    transaction_ = NULL;
1017
90
  }
1018
90
  if (from.has_subtransaction()) {
1019
0
    subtransaction_ = new ::yb::SubTransactionMetadataPB(*from.subtransaction_);
1020
90
  } else {
1021
90
    subtransaction_ = NULL;
1022
90
  }
1023
90
  ::memcpy(&deprecated_may_have_metadata_, &from.deprecated_may_have_metadata_,
1024
90
    static_cast<size_t>(reinterpret_cast<char*>(&wait_policy_) -
1025
90
    reinterpret_cast<char*>(&deprecated_may_have_metadata_)) + sizeof(wait_policy_));
1026
  // @@protoc_insertion_point(copy_constructor:yb.docdb.KeyValueWriteBatchPB)
1027
90
}
1028
1029
7.29M
void KeyValueWriteBatchPB::SharedCtor() {
1030
7.29M
  _cached_size_ = 0;
1031
7.29M
  ::memset(&transaction_, 0, static_cast<size_t>(
1032
7.29M
      reinterpret_cast<char*>(&wait_policy_) -
1033
7.29M
      reinterpret_cast<char*>(&transaction_)) + sizeof(wait_policy_));
1034
7.29M
}
1035
1036
7.27M
KeyValueWriteBatchPB::~KeyValueWriteBatchPB() {
1037
  // @@protoc_insertion_point(destructor:yb.docdb.KeyValueWriteBatchPB)
1038
7.27M
  SharedDtor();
1039
7.27M
}
1040
1041
7.27M
void KeyValueWriteBatchPB::SharedDtor() {
1042
7.27M
  if (this != internal_default_instance()) delete transaction_;
1043
7.27M
  if (this != internal_default_instance()) delete subtransaction_;
1044
7.27M
}
1045
1046
0
void KeyValueWriteBatchPB::SetCachedSize(int size) const {
1047
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1048
0
  _cached_size_ = size;
1049
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
1050
0
}
1051
0
const ::google::protobuf::Descriptor* KeyValueWriteBatchPB::descriptor() {
1052
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
1053
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1054
0
}
1055
1056
0
const KeyValueWriteBatchPB& KeyValueWriteBatchPB::default_instance() {
1057
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValueWriteBatchPB();
1058
0
  return *internal_default_instance();
1059
0
}
1060
1061
0
KeyValueWriteBatchPB* KeyValueWriteBatchPB::New(::google::protobuf::Arena* arena) const {
1062
0
  KeyValueWriteBatchPB* n = new KeyValueWriteBatchPB;
1063
0
  if (arena != NULL) {
1064
0
    arena->Own(n);
1065
0
  }
1066
0
  return n;
1067
0
}
1068
1069
407k
void KeyValueWriteBatchPB::Clear() {
1070
// @@protoc_insertion_point(message_clear_start:yb.docdb.KeyValueWriteBatchPB)
1071
407k
  ::google::protobuf::uint32 cached_has_bits = 0;
1072
  // Prevent compiler warnings about cached_has_bits being unused
1073
407k
  (void) cached_has_bits;
1074
1075
407k
  write_pairs_.Clear();
1076
407k
  read_pairs_.Clear();
1077
407k
  apply_external_transactions_.Clear();
1078
407k
  cached_has_bits = _has_bits_[0];
1079
407k
  if (cached_has_bits & 3u) {
1080
0
    if (cached_has_bits & 0x00000001u) {
1081
0
      GOOGLE_DCHECK(transaction_ != NULL);
1082
0
      transaction_->Clear();
1083
0
    }
1084
0
    if (cached_has_bits & 0x00000002u) {
1085
0
      GOOGLE_DCHECK(subtransaction_ != NULL);
1086
0
      subtransaction_->Clear();
1087
0
    }
1088
0
  }
1089
407k
  if (cached_has_bits & 60u) {
1090
506
    ::memset(&deprecated_may_have_metadata_, 0, static_cast<size_t>(
1091
506
        reinterpret_cast<char*>(&wait_policy_) -
1092
506
        reinterpret_cast<char*>(&deprecated_may_have_metadata_)) + sizeof(wait_policy_));
1093
506
  }
1094
407k
  _has_bits_.Clear();
1095
407k
  _internal_metadata_.Clear();
1096
407k
}
1097
1098
bool KeyValueWriteBatchPB::MergePartialFromCodedStream(
1099
4.60M
    ::google::protobuf::io::CodedInputStream* input) {
1100
71.3M
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1101
4.60M
  ::google::protobuf::uint32 tag;
1102
  // @@protoc_insertion_point(parse_start:yb.docdb.KeyValueWriteBatchPB)
1103
75.9M
  for (;;) {
1104
75.9M
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1105
75.9M
    tag = p.first;
1106
75.9M
    if (!p.second) goto handle_unusual;
1107
71.3M
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1108
      // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
1109
63.0M
      case 1: {
1110
63.0M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1111
63.0M
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
1112
63.0M
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_write_pairs()));
1113
18.4E
        } else {
1114
18.4E
          goto handle_unusual;
1115
18.4E
        }
1116
63.0M
        break;
1117
63.0M
      }
1118
1119
      // optional .yb.TransactionMetadataPB transaction = 2;
1120
1.39M
      case 2: {
1121
1.39M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1122
1.39M
            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
1123
1.39M
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
1124
1.39M
               input, mutable_transaction()));
1125
18.4E
        } else {
1126
18.4E
          goto handle_unusual;
1127
18.4E
        }
1128
1.39M
        break;
1129
1.39M
      }
1130
1131
      // optional bool DEPRECATED_may_have_metadata = 3;
1132
4.25M
      case 3: {
1133
4.25M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1134
4.25M
            static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) {
1135
4.25M
          set_has_deprecated_may_have_metadata();
1136
4.25M
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1137
4.25M
                   bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
1138
4.25M
                 input, &deprecated_may_have_metadata_)));
1139
18.4E
        } else {
1140
18.4E
          goto handle_unusual;
1141
18.4E
        }
1142
4.25M
        break;
1143
4.25M
      }
1144
1145
      // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
1146
2.34M
      case 5: {
1147
2.34M
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1148
2.34M
            static_cast< ::google::protobuf::uint8>(42u /* 42 & 0xFF */)) {
1149
2.34M
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_read_pairs()));
1150
18.4E
        } else {
1151
18.4E
          goto handle_unusual;
1152
18.4E
        }
1153
2.34M
        break;
1154
2.34M
      }
1155
1156
      // optional .yb.RowMarkType row_mark_type = 6;
1157
5.82k
      case 6: {
1158
5.82k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1159
5.82k
            static_cast< ::google::protobuf::uint8>(48u /* 48 & 0xFF */)) {
1160
5.82k
          int value;
1161
5.82k
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1162
5.82k
                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
1163
5.82k
                 input, &value)));
1164
5.82k
          if (::yb::RowMarkType_IsValid(value)) {
1165
5.82k
            set_row_mark_type(static_cast< ::yb::RowMarkType >(value));
1166
1
          } else {
1167
1
            mutable_unknown_fields()->AddVarint(
1168
1
                6, static_cast< ::google::protobuf::uint64>(value));
1169
1
          }
1170
18.4E
        } else {
1171
18.4E
          goto handle_unusual;
1172
18.4E
        }
1173
5.82k
        break;
1174
5.82k
      }
1175
1176
      // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
1177
0
      case 7: {
1178
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1179
0
            static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) {
1180
0
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_apply_external_transactions()));
1181
0
        } else {
1182
0
          goto handle_unusual;
1183
0
        }
1184
0
        break;
1185
0
      }
1186
1187
      // optional .yb.SubTransactionMetadataPB subtransaction = 8;
1188
14.4k
      case 8: {
1189
14.4k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1190
14.4k
            static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) {
1191
14.4k
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
1192
14.4k
               input, mutable_subtransaction()));
1193
18.4E
        } else {
1194
18.4E
          goto handle_unusual;
1195
18.4E
        }
1196
14.4k
        break;
1197
14.4k
      }
1198
1199
      // optional int64 ttl = 9;
1200
184
      case 9: {
1201
184
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1202
184
            static_cast< ::google::protobuf::uint8>(72u /* 72 & 0xFF */)) {
1203
184
          set_has_ttl();
1204
184
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1205
184
                   ::google::protobuf::int64, ::google::protobuf::internal::WireFormatLite::TYPE_INT64>(
1206
184
                 input, &ttl_)));
1207
0
        } else {
1208
0
          goto handle_unusual;
1209
0
        }
1210
184
        break;
1211
184
      }
1212
1213
      // optional .yb.WaitPolicy wait_policy = 10;
1214
286k
      case 10: {
1215
286k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1216
286k
            static_cast< ::google::protobuf::uint8>(80u /* 80 & 0xFF */)) {
1217
286k
          int value;
1218
286k
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1219
286k
                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
1220
286k
                 input, &value)));
1221
286k
          if (::yb::WaitPolicy_IsValid(value)) {
1222
286k
            set_wait_policy(static_cast< ::yb::WaitPolicy >(value));
1223
8
          } else {
1224
8
            mutable_unknown_fields()->AddVarint(
1225
8
                10, static_cast< ::google::protobuf::uint64>(value));
1226
8
          }
1227
18.4E
        } else {
1228
18.4E
          goto handle_unusual;
1229
18.4E
        }
1230
286k
        break;
1231
4.60M
      }
1232
1233
0
      default: {
1234
4.60M
      handle_unusual:
1235
4.60M
        if (tag == 0) {
1236
4.60M
          goto success;
1237
4.60M
        }
1238
18.4E
        DO_(::google::protobuf::internal::WireFormat::SkipField(
1239
18.4E
              input, tag, _internal_metadata_.mutable_unknown_fields()));
1240
18.4E
        break;
1241
18.4E
      }
1242
71.3M
    }
1243
71.3M
  }
1244
4.60M
success:
1245
  // @@protoc_insertion_point(parse_success:yb.docdb.KeyValueWriteBatchPB)
1246
4.60M
  return true;
1247
0
failure:
1248
  // @@protoc_insertion_point(parse_failure:yb.docdb.KeyValueWriteBatchPB)
1249
0
  return false;
1250
4.60M
#undef DO_
1251
4.60M
}
1252
1253
void KeyValueWriteBatchPB::SerializeWithCachedSizes(
1254
0
    ::google::protobuf::io::CodedOutputStream* output) const {
1255
  // @@protoc_insertion_point(serialize_start:yb.docdb.KeyValueWriteBatchPB)
1256
0
  ::google::protobuf::uint32 cached_has_bits = 0;
1257
0
  (void) cached_has_bits;
1258
1259
  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
1260
0
  for (unsigned int i = 0,
1261
0
      n = static_cast<unsigned int>(this->write_pairs_size()); i < n; i++) {
1262
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1263
0
      1, this->write_pairs(static_cast<int>(i)), output);
1264
0
  }
1265
1266
0
  cached_has_bits = _has_bits_[0];
1267
  // optional .yb.TransactionMetadataPB transaction = 2;
1268
0
  if (cached_has_bits & 0x00000001u) {
1269
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1270
0
      2, *this->transaction_, output);
1271
0
  }
1272
1273
  // optional bool DEPRECATED_may_have_metadata = 3;
1274
0
  if (cached_has_bits & 0x00000004u) {
1275
0
    ::google::protobuf::internal::WireFormatLite::WriteBool(3, this->deprecated_may_have_metadata(), output);
1276
0
  }
1277
1278
  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
1279
0
  for (unsigned int i = 0,
1280
0
      n = static_cast<unsigned int>(this->read_pairs_size()); i < n; i++) {
1281
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1282
0
      5, this->read_pairs(static_cast<int>(i)), output);
1283
0
  }
1284
1285
  // optional .yb.RowMarkType row_mark_type = 6;
1286
0
  if (cached_has_bits & 0x00000008u) {
1287
0
    ::google::protobuf::internal::WireFormatLite::WriteEnum(
1288
0
      6, this->row_mark_type(), output);
1289
0
  }
1290
1291
  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
1292
0
  for (unsigned int i = 0,
1293
0
      n = static_cast<unsigned int>(this->apply_external_transactions_size()); i < n; i++) {
1294
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1295
0
      7, this->apply_external_transactions(static_cast<int>(i)), output);
1296
0
  }
1297
1298
  // optional .yb.SubTransactionMetadataPB subtransaction = 8;
1299
0
  if (cached_has_bits & 0x00000002u) {
1300
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1301
0
      8, *this->subtransaction_, output);
1302
0
  }
1303
1304
  // optional int64 ttl = 9;
1305
0
  if (cached_has_bits & 0x00000010u) {
1306
0
    ::google::protobuf::internal::WireFormatLite::WriteInt64(9, this->ttl(), output);
1307
0
  }
1308
1309
  // optional .yb.WaitPolicy wait_policy = 10;
1310
0
  if (cached_has_bits & 0x00000020u) {
1311
0
    ::google::protobuf::internal::WireFormatLite::WriteEnum(
1312
0
      10, this->wait_policy(), output);
1313
0
  }
1314
1315
0
  if (_internal_metadata_.have_unknown_fields()) {
1316
0
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1317
0
        _internal_metadata_.unknown_fields(), output);
1318
0
  }
1319
  // @@protoc_insertion_point(serialize_end:yb.docdb.KeyValueWriteBatchPB)
1320
0
}
1321
1322
::google::protobuf::uint8* KeyValueWriteBatchPB::InternalSerializeWithCachedSizesToArray(
1323
8.23M
    bool deterministic, ::google::protobuf::uint8* target) const {
1324
8.23M
  (void)deterministic; // Unused
1325
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.KeyValueWriteBatchPB)
1326
8.23M
  ::google::protobuf::uint32 cached_has_bits = 0;
1327
8.23M
  (void) cached_has_bits;
1328
1329
  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
1330
8.23M
  for (unsigned int i = 0,
1331
132M
      n = static_cast<unsigned int>(this->write_pairs_size()); i < n; i++) {
1332
124M
    target = ::google::protobuf::internal::WireFormatLite::
1333
124M
      InternalWriteMessageToArray(
1334
124M
        1, this->write_pairs(static_cast<int>(i)), deterministic, target);
1335
124M
  }
1336
1337
8.23M
  cached_has_bits = _has_bits_[0];
1338
  // optional .yb.TransactionMetadataPB transaction = 2;
1339
8.23M
  if (cached_has_bits & 0x00000001u) {
1340
2.61M
    target = ::google::protobuf::internal::WireFormatLite::
1341
2.61M
      InternalWriteMessageToArray(
1342
2.61M
        2, *this->transaction_, deterministic, target);
1343
2.61M
  }
1344
1345
  // optional bool DEPRECATED_may_have_metadata = 3;
1346
8.23M
  if (cached_has_bits & 0x00000004u) {
1347
7.71M
    target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(3, this->deprecated_may_have_metadata(), target);
1348
7.71M
  }
1349
1350
  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
1351
8.23M
  for (unsigned int i = 0,
1352
14.1M
      n = static_cast<unsigned int>(this->read_pairs_size()); i < n; i++) {
1353
5.90M
    target = ::google::protobuf::internal::WireFormatLite::
1354
5.90M
      InternalWriteMessageToArray(
1355
5.90M
        5, this->read_pairs(static_cast<int>(i)), deterministic, target);
1356
5.90M
  }
1357
1358
  // optional .yb.RowMarkType row_mark_type = 6;
1359
8.23M
  if (cached_has_bits & 0x00000008u) {
1360
14.6k
    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
1361
14.6k
      6, this->row_mark_type(), target);
1362
14.6k
  }
1363
1364
  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
1365
8.23M
  for (unsigned int i = 0,
1366
8.23M
      n = static_cast<unsigned int>(this->apply_external_transactions_size()); i < n; i++) {
1367
0
    target = ::google::protobuf::internal::WireFormatLite::
1368
0
      InternalWriteMessageToArray(
1369
0
        7, this->apply_external_transactions(static_cast<int>(i)), deterministic, target);
1370
0
  }
1371
1372
  // optional .yb.SubTransactionMetadataPB subtransaction = 8;
1373
8.23M
  if (cached_has_bits & 0x00000002u) {
1374
14.7k
    target = ::google::protobuf::internal::WireFormatLite::
1375
14.7k
      InternalWriteMessageToArray(
1376
14.7k
        8, *this->subtransaction_, deterministic, target);
1377
14.7k
  }
1378
1379
  // optional int64 ttl = 9;
1380
8.23M
  if (cached_has_bits & 0x00000010u) {
1381
460
    target = ::google::protobuf::internal::WireFormatLite::WriteInt64ToArray(9, this->ttl(), target);
1382
460
  }
1383
1384
  // optional .yb.WaitPolicy wait_policy = 10;
1385
8.23M
  if (cached_has_bits & 0x00000020u) {
1386
715k
    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
1387
715k
      10, this->wait_policy(), target);
1388
715k
  }
1389
1390
8.23M
  if (_internal_metadata_.have_unknown_fields()) {
1391
0
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1392
0
        _internal_metadata_.unknown_fields(), target);
1393
0
  }
1394
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.KeyValueWriteBatchPB)
1395
8.23M
  return target;
1396
8.23M
}
1397
1398
19.4M
size_t KeyValueWriteBatchPB::ByteSizeLong() const {
1399
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.KeyValueWriteBatchPB)
1400
19.4M
  size_t total_size = 0;
1401
1402
19.4M
  if (_internal_metadata_.have_unknown_fields()) {
1403
0
    total_size +=
1404
0
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1405
0
        _internal_metadata_.unknown_fields());
1406
0
  }
1407
  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
1408
19.4M
  {
1409
19.4M
    unsigned int count = static_cast<unsigned int>(this->write_pairs_size());
1410
19.4M
    total_size += 1UL * count;
1411
313M
    for (unsigned int i = 0; i < count; i++) {
1412
293M
      total_size +=
1413
293M
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1414
293M
          this->write_pairs(static_cast<int>(i)));
1415
293M
    }
1416
19.4M
  }
1417
1418
  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
1419
19.4M
  {
1420
19.4M
    unsigned int count = static_cast<unsigned int>(this->read_pairs_size());
1421
19.4M
    total_size += 1UL * count;
1422
33.5M
    for (unsigned int i = 0; i < count; i++) {
1423
14.1M
      total_size +=
1424
14.1M
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1425
14.1M
          this->read_pairs(static_cast<int>(i)));
1426
14.1M
    }
1427
19.4M
  }
1428
1429
  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
1430
19.4M
  {
1431
19.4M
    unsigned int count = static_cast<unsigned int>(this->apply_external_transactions_size());
1432
19.4M
    total_size += 1UL * count;
1433
19.4M
    for (unsigned int i = 0; i < count; i++) {
1434
0
      total_size +=
1435
0
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1436
0
          this->apply_external_transactions(static_cast<int>(i)));
1437
0
    }
1438
19.4M
  }
1439
1440
19.4M
  if (_has_bits_[0 / 32] & 63u) {
1441
    // optional .yb.TransactionMetadataPB transaction = 2;
1442
18.6M
    if (has_transaction()) {
1443
6.11M
      total_size += 1 +
1444
6.11M
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1445
6.11M
          *this->transaction_);
1446
6.11M
    }
1447
1448
    // optional .yb.SubTransactionMetadataPB subtransaction = 8;
1449
18.6M
    if (has_subtransaction()) {
1450
29.6k
      total_size += 1 +
1451
29.6k
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1452
29.6k
          *this->subtransaction_);
1453
29.6k
    }
1454
1455
    // optional bool DEPRECATED_may_have_metadata = 3;
1456
18.6M
    if (has_deprecated_may_have_metadata()) {
1457
18.3M
      total_size += 1 + 1;
1458
18.3M
    }
1459
1460
    // optional .yb.RowMarkType row_mark_type = 6;
1461
18.6M
    if (has_row_mark_type()) {
1462
35.1k
      total_size += 1 +
1463
35.1k
        ::google::protobuf::internal::WireFormatLite::EnumSize(this->row_mark_type());
1464
35.1k
    }
1465
1466
    // optional int64 ttl = 9;
1467
18.6M
    if (has_ttl()) {
1468
1.10k
      total_size += 1 +
1469
1.10k
        ::google::protobuf::internal::WireFormatLite::Int64Size(
1470
1.10k
          this->ttl());
1471
1.10k
    }
1472
1473
    // optional .yb.WaitPolicy wait_policy = 10;
1474
18.6M
    if (has_wait_policy()) {
1475
1.71M
      total_size += 1 +
1476
1.71M
        ::google::protobuf::internal::WireFormatLite::EnumSize(this->wait_policy());
1477
1.71M
    }
1478
1479
18.6M
  }
1480
19.4M
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1481
19.4M
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1482
19.4M
  _cached_size_ = cached_size;
1483
19.4M
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
1484
19.4M
  return total_size;
1485
19.4M
}
1486
1487
0
void KeyValueWriteBatchPB::MergeFrom(const ::google::protobuf::Message& from) {
1488
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.KeyValueWriteBatchPB)
1489
0
  GOOGLE_DCHECK_NE(&from, this);
1490
0
  const KeyValueWriteBatchPB* source =
1491
0
      ::google::protobuf::internal::DynamicCastToGenerated<const KeyValueWriteBatchPB>(
1492
0
          &from);
1493
0
  if (source == NULL) {
1494
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.KeyValueWriteBatchPB)
1495
0
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1496
0
  } else {
1497
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.KeyValueWriteBatchPB)
1498
0
    MergeFrom(*source);
1499
0
  }
1500
0
}
1501
1502
406k
void KeyValueWriteBatchPB::MergeFrom(const KeyValueWriteBatchPB& from) {
1503
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.KeyValueWriteBatchPB)
1504
406k
  GOOGLE_DCHECK_NE(&from, this);
1505
406k
  _internal_metadata_.MergeFrom(from._internal_metadata_);
1506
406k
  ::google::protobuf::uint32 cached_has_bits = 0;
1507
406k
  (void) cached_has_bits;
1508
1509
406k
  write_pairs_.MergeFrom(from.write_pairs_);
1510
406k
  read_pairs_.MergeFrom(from.read_pairs_);
1511
406k
  apply_external_transactions_.MergeFrom(from.apply_external_transactions_);
1512
406k
  cached_has_bits = from._has_bits_[0];
1513
406k
  if (cached_has_bits & 63u) {
1514
406k
    if (cached_has_bits & 0x00000001u) {
1515
406k
      mutable_transaction()->::yb::TransactionMetadataPB::MergeFrom(from.transaction());
1516
406k
    }
1517
404k
    if (cached_has_bits & 0x00000002u) {
1518
18.9k
      mutable_subtransaction()->::yb::SubTransactionMetadataPB::MergeFrom(from.subtransaction());
1519
18.9k
    }
1520
404k
    if (cached_has_bits & 0x00000004u) {
1521
403k
      deprecated_may_have_metadata_ = from.deprecated_may_have_metadata_;
1522
403k
    }
1523
404k
    if (cached_has_bits & 0x00000008u) {
1524
0
      row_mark_type_ = from.row_mark_type_;
1525
0
    }
1526
404k
    if (cached_has_bits & 0x00000010u) {
1527
0
      ttl_ = from.ttl_;
1528
0
    }
1529
404k
    if (cached_has_bits & 0x00000020u) {
1530
0
      wait_policy_ = from.wait_policy_;
1531
0
    }
1532
404k
    _has_bits_[0] |= cached_has_bits;
1533
404k
  }
1534
406k
}
1535
1536
0
void KeyValueWriteBatchPB::CopyFrom(const ::google::protobuf::Message& from) {
1537
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.KeyValueWriteBatchPB)
1538
0
  if (&from == this) return;
1539
0
  Clear();
1540
0
  MergeFrom(from);
1541
0
}
1542
1543
407k
void KeyValueWriteBatchPB::CopyFrom(const KeyValueWriteBatchPB& from) {
1544
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.KeyValueWriteBatchPB)
1545
407k
  if (&from == this) return;
1546
407k
  Clear();
1547
407k
  MergeFrom(from);
1548
407k
}
1549
1550
0
bool KeyValueWriteBatchPB::IsInitialized() const {
1551
0
  return true;
1552
0
}
1553
1554
0
void KeyValueWriteBatchPB::Swap(KeyValueWriteBatchPB* other) {
1555
0
  if (other == this) return;
1556
0
  InternalSwap(other);
1557
0
}
1558
0
void KeyValueWriteBatchPB::InternalSwap(KeyValueWriteBatchPB* other) {
1559
0
  using std::swap;
1560
0
  write_pairs_.InternalSwap(&other->write_pairs_);
1561
0
  read_pairs_.InternalSwap(&other->read_pairs_);
1562
0
  apply_external_transactions_.InternalSwap(&other->apply_external_transactions_);
1563
0
  swap(transaction_, other->transaction_);
1564
0
  swap(subtransaction_, other->subtransaction_);
1565
0
  swap(deprecated_may_have_metadata_, other->deprecated_may_have_metadata_);
1566
0
  swap(row_mark_type_, other->row_mark_type_);
1567
0
  swap(ttl_, other->ttl_);
1568
0
  swap(wait_policy_, other->wait_policy_);
1569
0
  swap(_has_bits_[0], other->_has_bits_[0]);
1570
0
  _internal_metadata_.Swap(&other->_internal_metadata_);
1571
0
  swap(_cached_size_, other->_cached_size_);
1572
0
}
1573
1574
12.1M
::google::protobuf::Metadata KeyValueWriteBatchPB::GetMetadata() const {
1575
12.1M
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
1576
12.1M
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
1577
12.1M
}
1578
1579
1580
// ===================================================================
1581
1582
17.1k
void ConsensusFrontierPB::InitAsDefaultInstance() {
1583
17.1k
  ::yb::docdb::_ConsensusFrontierPB_default_instance_._instance.get_mutable()->op_id_ = const_cast< ::yb::OpIdPB*>(
1584
17.1k
      ::yb::OpIdPB::internal_default_instance());
1585
17.1k
}
1586
0
void ConsensusFrontierPB::clear_op_id() {
1587
0
  if (op_id_ != NULL) op_id_->Clear();
1588
0
  clear_has_op_id();
1589
0
}
1590
#if !defined(_MSC_VER) || _MSC_VER >= 1900
1591
const int ConsensusFrontierPB::kOpIdFieldNumber;
1592
const int ConsensusFrontierPB::kHybridTimeFieldNumber;
1593
const int ConsensusFrontierPB::kHistoryCutoffFieldNumber;
1594
const int ConsensusFrontierPB::kHybridTimeFilterFieldNumber;
1595
const int ConsensusFrontierPB::kMaxValueLevelTtlExpirationTimeFieldNumber;
1596
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900
1597
1598
ConsensusFrontierPB::ConsensusFrontierPB()
1599
316k
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
1600
299k
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
1601
299k
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsConsensusFrontierPB();
1602
299k
  }
1603
316k
  SharedCtor();
1604
  // @@protoc_insertion_point(constructor:yb.docdb.ConsensusFrontierPB)
1605
316k
}
1606
ConsensusFrontierPB::ConsensusFrontierPB(const ConsensusFrontierPB& from)
1607
  : ::google::protobuf::Message(),
1608
      _internal_metadata_(NULL),
1609
      _has_bits_(from._has_bits_),
1610
0
      _cached_size_(0) {
1611
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
1612
0
  if (from.has_op_id()) {
1613
0
    op_id_ = new ::yb::OpIdPB(*from.op_id_);
1614
0
  } else {
1615
0
    op_id_ = NULL;
1616
0
  }
1617
0
  ::memcpy(&hybrid_time_, &from.hybrid_time_,
1618
0
    static_cast<size_t>(reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
1619
0
    reinterpret_cast<char*>(&hybrid_time_)) + sizeof(max_value_level_ttl_expiration_time_));
1620
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ConsensusFrontierPB)
1621
0
}
1622
1623
316k
void ConsensusFrontierPB::SharedCtor() {
1624
316k
  _cached_size_ = 0;
1625
316k
  ::memset(&op_id_, 0, static_cast<size_t>(
1626
316k
      reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
1627
316k
      reinterpret_cast<char*>(&op_id_)) + sizeof(max_value_level_ttl_expiration_time_));
1628
316k
}
1629
1630
299k
ConsensusFrontierPB::~ConsensusFrontierPB() {
1631
  // @@protoc_insertion_point(destructor:yb.docdb.ConsensusFrontierPB)
1632
299k
  SharedDtor();
1633
299k
}
1634
1635
299k
void ConsensusFrontierPB::SharedDtor() {
1636
299k
  if (this != internal_default_instance()) delete op_id_;
1637
299k
}
1638
1639
0
void ConsensusFrontierPB::SetCachedSize(int size) const {
1640
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1641
0
  _cached_size_ = size;
1642
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
1643
0
}
1644
0
const ::google::protobuf::Descriptor* ConsensusFrontierPB::descriptor() {
1645
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
1646
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
1647
0
}
1648
1649
0
const ConsensusFrontierPB& ConsensusFrontierPB::default_instance() {
1650
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsConsensusFrontierPB();
1651
0
  return *internal_default_instance();
1652
0
}
1653
1654
0
ConsensusFrontierPB* ConsensusFrontierPB::New(::google::protobuf::Arena* arena) const {
1655
0
  ConsensusFrontierPB* n = new ConsensusFrontierPB;
1656
0
  if (arena != NULL) {
1657
0
    arena->Own(n);
1658
0
  }
1659
0
  return n;
1660
0
}
1661
1662
18.6k
void ConsensusFrontierPB::Clear() {
1663
// @@protoc_insertion_point(message_clear_start:yb.docdb.ConsensusFrontierPB)
1664
18.6k
  ::google::protobuf::uint32 cached_has_bits = 0;
1665
  // Prevent compiler warnings about cached_has_bits being unused
1666
18.6k
  (void) cached_has_bits;
1667
1668
18.6k
  cached_has_bits = _has_bits_[0];
1669
18.6k
  if (cached_has_bits & 0x00000001u) {
1670
0
    GOOGLE_DCHECK(op_id_ != NULL);
1671
0
    op_id_->Clear();
1672
0
  }
1673
18.6k
  if (cached_has_bits & 30u) {
1674
0
    ::memset(&hybrid_time_, 0, static_cast<size_t>(
1675
0
        reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
1676
0
        reinterpret_cast<char*>(&hybrid_time_)) + sizeof(max_value_level_ttl_expiration_time_));
1677
0
  }
1678
18.6k
  _has_bits_.Clear();
1679
18.6k
  _internal_metadata_.Clear();
1680
18.6k
}
1681
1682
bool ConsensusFrontierPB::MergePartialFromCodedStream(
1683
18.6k
    ::google::protobuf::io::CodedInputStream* input) {
1684
74.6k
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
1685
18.6k
  ::google::protobuf::uint32 tag;
1686
  // @@protoc_insertion_point(parse_start:yb.docdb.ConsensusFrontierPB)
1687
93.2k
  for (;;) {
1688
93.2k
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
1689
93.2k
    tag = p.first;
1690
93.2k
    if (!p.second) goto handle_unusual;
1691
74.5k
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
1692
      // optional .yb.OpIdPB op_id = 1;
1693
18.6k
      case 1: {
1694
18.6k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1695
18.6k
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
1696
18.6k
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
1697
18.6k
               input, mutable_op_id()));
1698
0
        } else {
1699
0
          goto handle_unusual;
1700
0
        }
1701
18.6k
        break;
1702
18.6k
      }
1703
1704
      // optional fixed64 hybrid_time = 2;
1705
18.6k
      case 2: {
1706
18.6k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1707
18.6k
            static_cast< ::google::protobuf::uint8>(17u /* 17 & 0xFF */)) {
1708
18.6k
          set_has_hybrid_time();
1709
18.6k
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1710
18.6k
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
1711
18.6k
                 input, &hybrid_time_)));
1712
0
        } else {
1713
0
          goto handle_unusual;
1714
0
        }
1715
18.6k
        break;
1716
18.6k
      }
1717
1718
      // optional fixed64 history_cutoff = 3;
1719
18.6k
      case 3: {
1720
18.6k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1721
18.6k
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
1722
18.6k
          set_has_history_cutoff();
1723
18.6k
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1724
18.6k
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
1725
18.6k
                 input, &history_cutoff_)));
1726
0
        } else {
1727
0
          goto handle_unusual;
1728
0
        }
1729
18.6k
        break;
1730
18.6k
      }
1731
1732
      // optional fixed64 hybrid_time_filter = 4;
1733
0
      case 4: {
1734
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1735
0
            static_cast< ::google::protobuf::uint8>(33u /* 33 & 0xFF */)) {
1736
0
          set_has_hybrid_time_filter();
1737
0
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1738
0
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
1739
0
                 input, &hybrid_time_filter_)));
1740
0
        } else {
1741
0
          goto handle_unusual;
1742
0
        }
1743
0
        break;
1744
0
      }
1745
1746
      // optional fixed64 max_value_level_ttl_expiration_time = 5;
1747
18.6k
      case 5: {
1748
18.6k
        if (static_cast< ::google::protobuf::uint8>(tag) ==
1749
18.6k
            static_cast< ::google::protobuf::uint8>(41u /* 41 & 0xFF */)) {
1750
18.6k
          set_has_max_value_level_ttl_expiration_time();
1751
18.6k
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
1752
18.6k
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
1753
18.6k
                 input, &max_value_level_ttl_expiration_time_)));
1754
0
        } else {
1755
0
          goto handle_unusual;
1756
0
        }
1757
18.6k
        break;
1758
18.6k
      }
1759
1760
0
      default: {
1761
18.6k
      handle_unusual:
1762
18.6k
        if (tag == 0) {
1763
18.6k
          goto success;
1764
18.6k
        }
1765
18.4E
        DO_(::google::protobuf::internal::WireFormat::SkipField(
1766
18.4E
              input, tag, _internal_metadata_.mutable_unknown_fields()));
1767
18.4E
        break;
1768
18.4E
      }
1769
74.5k
    }
1770
74.5k
  }
1771
18.6k
success:
1772
  // @@protoc_insertion_point(parse_success:yb.docdb.ConsensusFrontierPB)
1773
18.6k
  return true;
1774
0
failure:
1775
  // @@protoc_insertion_point(parse_failure:yb.docdb.ConsensusFrontierPB)
1776
0
  return false;
1777
18.6k
#undef DO_
1778
18.6k
}
1779
1780
void ConsensusFrontierPB::SerializeWithCachedSizes(
1781
0
    ::google::protobuf::io::CodedOutputStream* output) const {
1782
  // @@protoc_insertion_point(serialize_start:yb.docdb.ConsensusFrontierPB)
1783
0
  ::google::protobuf::uint32 cached_has_bits = 0;
1784
0
  (void) cached_has_bits;
1785
1786
0
  cached_has_bits = _has_bits_[0];
1787
  // optional .yb.OpIdPB op_id = 1;
1788
0
  if (cached_has_bits & 0x00000001u) {
1789
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
1790
0
      1, *this->op_id_, output);
1791
0
  }
1792
1793
  // optional fixed64 hybrid_time = 2;
1794
0
  if (cached_has_bits & 0x00000002u) {
1795
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(2, this->hybrid_time(), output);
1796
0
  }
1797
1798
  // optional fixed64 history_cutoff = 3;
1799
0
  if (cached_has_bits & 0x00000004u) {
1800
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->history_cutoff(), output);
1801
0
  }
1802
1803
  // optional fixed64 hybrid_time_filter = 4;
1804
0
  if (cached_has_bits & 0x00000008u) {
1805
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(4, this->hybrid_time_filter(), output);
1806
0
  }
1807
1808
  // optional fixed64 max_value_level_ttl_expiration_time = 5;
1809
0
  if (cached_has_bits & 0x00000010u) {
1810
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(5, this->max_value_level_ttl_expiration_time(), output);
1811
0
  }
1812
1813
0
  if (_internal_metadata_.have_unknown_fields()) {
1814
0
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
1815
0
        _internal_metadata_.unknown_fields(), output);
1816
0
  }
1817
  // @@protoc_insertion_point(serialize_end:yb.docdb.ConsensusFrontierPB)
1818
0
}
1819
1820
::google::protobuf::uint8* ConsensusFrontierPB::InternalSerializeWithCachedSizesToArray(
1821
281k
    bool deterministic, ::google::protobuf::uint8* target) const {
1822
281k
  (void)deterministic; // Unused
1823
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ConsensusFrontierPB)
1824
281k
  ::google::protobuf::uint32 cached_has_bits = 0;
1825
281k
  (void) cached_has_bits;
1826
1827
281k
  cached_has_bits = _has_bits_[0];
1828
  // optional .yb.OpIdPB op_id = 1;
1829
281k
  if (cached_has_bits & 0x00000001u) {
1830
281k
    target = ::google::protobuf::internal::WireFormatLite::
1831
281k
      InternalWriteMessageToArray(
1832
281k
        1, *this->op_id_, deterministic, target);
1833
281k
  }
1834
1835
  // optional fixed64 hybrid_time = 2;
1836
281k
  if (cached_has_bits & 0x00000002u) {
1837
281k
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(2, this->hybrid_time(), target);
1838
281k
  }
1839
1840
  // optional fixed64 history_cutoff = 3;
1841
281k
  if (cached_has_bits & 0x00000004u) {
1842
281k
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->history_cutoff(), target);
1843
281k
  }
1844
1845
  // optional fixed64 hybrid_time_filter = 4;
1846
281k
  if (cached_has_bits & 0x00000008u) {
1847
0
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(4, this->hybrid_time_filter(), target);
1848
0
  }
1849
1850
  // optional fixed64 max_value_level_ttl_expiration_time = 5;
1851
281k
  if (cached_has_bits & 0x00000010u) {
1852
281k
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(5, this->max_value_level_ttl_expiration_time(), target);
1853
281k
  }
1854
1855
281k
  if (_internal_metadata_.have_unknown_fields()) {
1856
0
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
1857
0
        _internal_metadata_.unknown_fields(), target);
1858
0
  }
1859
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ConsensusFrontierPB)
1860
281k
  return target;
1861
281k
}
1862
1863
281k
size_t ConsensusFrontierPB::ByteSizeLong() const {
1864
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ConsensusFrontierPB)
1865
281k
  size_t total_size = 0;
1866
1867
281k
  if (_internal_metadata_.have_unknown_fields()) {
1868
0
    total_size +=
1869
0
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
1870
0
        _internal_metadata_.unknown_fields());
1871
0
  }
1872
281k
  if (_has_bits_[0 / 32] & 31u) {
1873
    // optional .yb.OpIdPB op_id = 1;
1874
281k
    if (has_op_id()) {
1875
281k
      total_size += 1 +
1876
281k
        ::google::protobuf::internal::WireFormatLite::MessageSize(
1877
281k
          *this->op_id_);
1878
281k
    }
1879
1880
    // optional fixed64 hybrid_time = 2;
1881
281k
    if (has_hybrid_time()) {
1882
281k
      total_size += 1 + 8;
1883
281k
    }
1884
1885
    // optional fixed64 history_cutoff = 3;
1886
281k
    if (has_history_cutoff()) {
1887
281k
      total_size += 1 + 8;
1888
281k
    }
1889
1890
    // optional fixed64 hybrid_time_filter = 4;
1891
281k
    if (has_hybrid_time_filter()) {
1892
0
      total_size += 1 + 8;
1893
0
    }
1894
1895
    // optional fixed64 max_value_level_ttl_expiration_time = 5;
1896
281k
    if (has_max_value_level_ttl_expiration_time()) {
1897
281k
      total_size += 1 + 8;
1898
281k
    }
1899
1900
281k
  }
1901
281k
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
1902
281k
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
1903
281k
  _cached_size_ = cached_size;
1904
281k
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
1905
281k
  return total_size;
1906
281k
}
1907
1908
0
void ConsensusFrontierPB::MergeFrom(const ::google::protobuf::Message& from) {
1909
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ConsensusFrontierPB)
1910
0
  GOOGLE_DCHECK_NE(&from, this);
1911
0
  const ConsensusFrontierPB* source =
1912
0
      ::google::protobuf::internal::DynamicCastToGenerated<const ConsensusFrontierPB>(
1913
0
          &from);
1914
0
  if (source == NULL) {
1915
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ConsensusFrontierPB)
1916
0
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
1917
0
  } else {
1918
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ConsensusFrontierPB)
1919
0
    MergeFrom(*source);
1920
0
  }
1921
0
}
1922
1923
0
void ConsensusFrontierPB::MergeFrom(const ConsensusFrontierPB& from) {
1924
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ConsensusFrontierPB)
1925
0
  GOOGLE_DCHECK_NE(&from, this);
1926
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
1927
0
  ::google::protobuf::uint32 cached_has_bits = 0;
1928
0
  (void) cached_has_bits;
1929
1930
0
  cached_has_bits = from._has_bits_[0];
1931
0
  if (cached_has_bits & 31u) {
1932
0
    if (cached_has_bits & 0x00000001u) {
1933
0
      mutable_op_id()->::yb::OpIdPB::MergeFrom(from.op_id());
1934
0
    }
1935
0
    if (cached_has_bits & 0x00000002u) {
1936
0
      hybrid_time_ = from.hybrid_time_;
1937
0
    }
1938
0
    if (cached_has_bits & 0x00000004u) {
1939
0
      history_cutoff_ = from.history_cutoff_;
1940
0
    }
1941
0
    if (cached_has_bits & 0x00000008u) {
1942
0
      hybrid_time_filter_ = from.hybrid_time_filter_;
1943
0
    }
1944
0
    if (cached_has_bits & 0x00000010u) {
1945
0
      max_value_level_ttl_expiration_time_ = from.max_value_level_ttl_expiration_time_;
1946
0
    }
1947
0
    _has_bits_[0] |= cached_has_bits;
1948
0
  }
1949
0
}
1950
1951
0
void ConsensusFrontierPB::CopyFrom(const ::google::protobuf::Message& from) {
1952
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ConsensusFrontierPB)
1953
0
  if (&from == this) return;
1954
0
  Clear();
1955
0
  MergeFrom(from);
1956
0
}
1957
1958
0
void ConsensusFrontierPB::CopyFrom(const ConsensusFrontierPB& from) {
1959
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ConsensusFrontierPB)
1960
0
  if (&from == this) return;
1961
0
  Clear();
1962
0
  MergeFrom(from);
1963
0
}
1964
1965
299k
bool ConsensusFrontierPB::IsInitialized() const {
1966
299k
  if (has_op_id()) {
1967
299k
    if (!this->op_id_->IsInitialized()) return false;
1968
299k
  }
1969
299k
  return true;
1970
299k
}
1971
1972
0
void ConsensusFrontierPB::Swap(ConsensusFrontierPB* other) {
1973
0
  if (other == this) return;
1974
0
  InternalSwap(other);
1975
0
}
1976
0
void ConsensusFrontierPB::InternalSwap(ConsensusFrontierPB* other) {
1977
0
  using std::swap;
1978
0
  swap(op_id_, other->op_id_);
1979
0
  swap(hybrid_time_, other->hybrid_time_);
1980
0
  swap(history_cutoff_, other->history_cutoff_);
1981
0
  swap(hybrid_time_filter_, other->hybrid_time_filter_);
1982
0
  swap(max_value_level_ttl_expiration_time_, other->max_value_level_ttl_expiration_time_);
1983
0
  swap(_has_bits_[0], other->_has_bits_[0]);
1984
0
  _internal_metadata_.Swap(&other->_internal_metadata_);
1985
0
  swap(_cached_size_, other->_cached_size_);
1986
0
}
1987
1988
299k
::google::protobuf::Metadata ConsensusFrontierPB::GetMetadata() const {
1989
299k
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
1990
299k
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
1991
299k
}
1992
1993
1994
// ===================================================================
1995
1996
17.1k
void ApplyTransactionStatePB::InitAsDefaultInstance() {
1997
17.1k
  ::yb::docdb::_ApplyTransactionStatePB_default_instance_._instance.get_mutable()->aborted_ = const_cast< ::yb::AbortedSubTransactionSetPB*>(
1998
17.1k
      ::yb::AbortedSubTransactionSetPB::internal_default_instance());
1999
17.1k
}
2000
0
void ApplyTransactionStatePB::clear_aborted() {
2001
0
  if (aborted_ != NULL) aborted_->Clear();
2002
0
  clear_has_aborted();
2003
0
}
2004
#if !defined(_MSC_VER) || _MSC_VER >= 1900
2005
const int ApplyTransactionStatePB::kKeyFieldNumber;
2006
const int ApplyTransactionStatePB::kWriteIdFieldNumber;
2007
const int ApplyTransactionStatePB::kCommitHtFieldNumber;
2008
const int ApplyTransactionStatePB::kAbortedFieldNumber;
2009
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900
2010
2011
ApplyTransactionStatePB::ApplyTransactionStatePB()
2012
17.1k
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
2013
1
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
2014
1
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyTransactionStatePB();
2015
1
  }
2016
17.1k
  SharedCtor();
2017
  // @@protoc_insertion_point(constructor:yb.docdb.ApplyTransactionStatePB)
2018
17.1k
}
2019
ApplyTransactionStatePB::ApplyTransactionStatePB(const ApplyTransactionStatePB& from)
2020
  : ::google::protobuf::Message(),
2021
      _internal_metadata_(NULL),
2022
      _has_bits_(from._has_bits_),
2023
0
      _cached_size_(0) {
2024
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
2025
0
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2026
0
  if (from.has_key()) {
2027
0
    key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
2028
0
  }
2029
0
  if (from.has_aborted()) {
2030
0
    aborted_ = new ::yb::AbortedSubTransactionSetPB(*from.aborted_);
2031
0
  } else {
2032
0
    aborted_ = NULL;
2033
0
  }
2034
0
  ::memcpy(&commit_ht_, &from.commit_ht_,
2035
0
    static_cast<size_t>(reinterpret_cast<char*>(&write_id_) -
2036
0
    reinterpret_cast<char*>(&commit_ht_)) + sizeof(write_id_));
2037
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ApplyTransactionStatePB)
2038
0
}
2039
2040
17.1k
void ApplyTransactionStatePB::SharedCtor() {
2041
17.1k
  _cached_size_ = 0;
2042
17.1k
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2043
17.1k
  ::memset(&aborted_, 0, static_cast<size_t>(
2044
17.1k
      reinterpret_cast<char*>(&write_id_) -
2045
17.1k
      reinterpret_cast<char*>(&aborted_)) + sizeof(write_id_));
2046
17.1k
}
2047
2048
1
ApplyTransactionStatePB::~ApplyTransactionStatePB() {
2049
  // @@protoc_insertion_point(destructor:yb.docdb.ApplyTransactionStatePB)
2050
1
  SharedDtor();
2051
1
}
2052
2053
1
void ApplyTransactionStatePB::SharedDtor() {
2054
1
  key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
2055
1
  if (this != internal_default_instance()) delete aborted_;
2056
1
}
2057
2058
0
void ApplyTransactionStatePB::SetCachedSize(int size) const {
2059
0
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2060
0
  _cached_size_ = size;
2061
0
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
2062
0
}
2063
0
const ::google::protobuf::Descriptor* ApplyTransactionStatePB::descriptor() {
2064
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
2065
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
2066
0
}
2067
2068
0
const ApplyTransactionStatePB& ApplyTransactionStatePB::default_instance() {
2069
0
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyTransactionStatePB();
2070
0
  return *internal_default_instance();
2071
0
}
2072
2073
0
ApplyTransactionStatePB* ApplyTransactionStatePB::New(::google::protobuf::Arena* arena) const {
2074
0
  ApplyTransactionStatePB* n = new ApplyTransactionStatePB;
2075
0
  if (arena != NULL) {
2076
0
    arena->Own(n);
2077
0
  }
2078
0
  return n;
2079
0
}
2080
2081
0
void ApplyTransactionStatePB::Clear() {
2082
// @@protoc_insertion_point(message_clear_start:yb.docdb.ApplyTransactionStatePB)
2083
0
  ::google::protobuf::uint32 cached_has_bits = 0;
2084
  // Prevent compiler warnings about cached_has_bits being unused
2085
0
  (void) cached_has_bits;
2086
2087
0
  cached_has_bits = _has_bits_[0];
2088
0
  if (cached_has_bits & 3u) {
2089
0
    if (cached_has_bits & 0x00000001u) {
2090
0
      GOOGLE_DCHECK(!key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
2091
0
      (*key_.UnsafeRawStringPointer())->clear();
2092
0
    }
2093
0
    if (cached_has_bits & 0x00000002u) {
2094
0
      GOOGLE_DCHECK(aborted_ != NULL);
2095
0
      aborted_->Clear();
2096
0
    }
2097
0
  }
2098
0
  if (cached_has_bits & 12u) {
2099
0
    ::memset(&commit_ht_, 0, static_cast<size_t>(
2100
0
        reinterpret_cast<char*>(&write_id_) -
2101
0
        reinterpret_cast<char*>(&commit_ht_)) + sizeof(write_id_));
2102
0
  }
2103
0
  _has_bits_.Clear();
2104
0
  _internal_metadata_.Clear();
2105
0
}
2106
2107
bool ApplyTransactionStatePB::MergePartialFromCodedStream(
2108
0
    ::google::protobuf::io::CodedInputStream* input) {
2109
0
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
2110
0
  ::google::protobuf::uint32 tag;
2111
  // @@protoc_insertion_point(parse_start:yb.docdb.ApplyTransactionStatePB)
2112
0
  for (;;) {
2113
0
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
2114
0
    tag = p.first;
2115
0
    if (!p.second) goto handle_unusual;
2116
0
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
2117
      // optional bytes key = 1;
2118
0
      case 1: {
2119
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
2120
0
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
2121
0
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
2122
0
                input, this->mutable_key()));
2123
0
        } else {
2124
0
          goto handle_unusual;
2125
0
        }
2126
0
        break;
2127
0
      }
2128
2129
      // optional uint32 write_id = 2;
2130
0
      case 2: {
2131
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
2132
0
            static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) {
2133
0
          set_has_write_id();
2134
0
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2135
0
                   ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
2136
0
                 input, &write_id_)));
2137
0
        } else {
2138
0
          goto handle_unusual;
2139
0
        }
2140
0
        break;
2141
0
      }
2142
2143
      // optional fixed64 commit_ht = 3;
2144
0
      case 3: {
2145
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
2146
0
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
2147
0
          set_has_commit_ht();
2148
0
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
2149
0
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
2150
0
                 input, &commit_ht_)));
2151
0
        } else {
2152
0
          goto handle_unusual;
2153
0
        }
2154
0
        break;
2155
0
      }
2156
2157
      // optional .yb.AbortedSubTransactionSetPB aborted = 4;
2158
0
      case 4: {
2159
0
        if (static_cast< ::google::protobuf::uint8>(tag) ==
2160
0
            static_cast< ::google::protobuf::uint8>(34u /* 34 & 0xFF */)) {
2161
0
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
2162
0
               input, mutable_aborted()));
2163
0
        } else {
2164
0
          goto handle_unusual;
2165
0
        }
2166
0
        break;
2167
0
      }
2168
2169
0
      default: {
2170
0
      handle_unusual:
2171
0
        if (tag == 0) {
2172
0
          goto success;
2173
0
        }
2174
0
        DO_(::google::protobuf::internal::WireFormat::SkipField(
2175
0
              input, tag, _internal_metadata_.mutable_unknown_fields()));
2176
0
        break;
2177
0
      }
2178
0
    }
2179
0
  }
2180
0
success:
2181
  // @@protoc_insertion_point(parse_success:yb.docdb.ApplyTransactionStatePB)
2182
0
  return true;
2183
0
failure:
2184
  // @@protoc_insertion_point(parse_failure:yb.docdb.ApplyTransactionStatePB)
2185
0
  return false;
2186
0
#undef DO_
2187
0
}
2188
2189
void ApplyTransactionStatePB::SerializeWithCachedSizes(
2190
0
    ::google::protobuf::io::CodedOutputStream* output) const {
2191
  // @@protoc_insertion_point(serialize_start:yb.docdb.ApplyTransactionStatePB)
2192
0
  ::google::protobuf::uint32 cached_has_bits = 0;
2193
0
  (void) cached_has_bits;
2194
2195
0
  cached_has_bits = _has_bits_[0];
2196
  // optional bytes key = 1;
2197
0
  if (cached_has_bits & 0x00000001u) {
2198
0
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
2199
0
      1, this->key(), output);
2200
0
  }
2201
2202
  // optional uint32 write_id = 2;
2203
0
  if (cached_has_bits & 0x00000008u) {
2204
0
    ::google::protobuf::internal::WireFormatLite::WriteUInt32(2, this->write_id(), output);
2205
0
  }
2206
2207
  // optional fixed64 commit_ht = 3;
2208
0
  if (cached_has_bits & 0x00000004u) {
2209
0
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->commit_ht(), output);
2210
0
  }
2211
2212
  // optional .yb.AbortedSubTransactionSetPB aborted = 4;
2213
0
  if (cached_has_bits & 0x00000002u) {
2214
0
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
2215
0
      4, *this->aborted_, output);
2216
0
  }
2217
2218
0
  if (_internal_metadata_.have_unknown_fields()) {
2219
0
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
2220
0
        _internal_metadata_.unknown_fields(), output);
2221
0
  }
2222
  // @@protoc_insertion_point(serialize_end:yb.docdb.ApplyTransactionStatePB)
2223
0
}
2224
2225
::google::protobuf::uint8* ApplyTransactionStatePB::InternalSerializeWithCachedSizesToArray(
2226
1
    bool deterministic, ::google::protobuf::uint8* target) const {
2227
1
  (void)deterministic; // Unused
2228
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ApplyTransactionStatePB)
2229
1
  ::google::protobuf::uint32 cached_has_bits = 0;
2230
1
  (void) cached_has_bits;
2231
2232
1
  cached_has_bits = _has_bits_[0];
2233
  // optional bytes key = 1;
2234
1
  if (cached_has_bits & 0x00000001u) {
2235
1
    target =
2236
1
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
2237
1
        1, this->key(), target);
2238
1
  }
2239
2240
  // optional uint32 write_id = 2;
2241
1
  if (cached_has_bits & 0x00000008u) {
2242
1
    target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(2, this->write_id(), target);
2243
1
  }
2244
2245
  // optional fixed64 commit_ht = 3;
2246
1
  if (cached_has_bits & 0x00000004u) {
2247
1
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->commit_ht(), target);
2248
1
  }
2249
2250
  // optional .yb.AbortedSubTransactionSetPB aborted = 4;
2251
1
  if (cached_has_bits & 0x00000002u) {
2252
1
    target = ::google::protobuf::internal::WireFormatLite::
2253
1
      InternalWriteMessageToArray(
2254
1
        4, *this->aborted_, deterministic, target);
2255
1
  }
2256
2257
1
  if (_internal_metadata_.have_unknown_fields()) {
2258
0
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
2259
0
        _internal_metadata_.unknown_fields(), target);
2260
0
  }
2261
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ApplyTransactionStatePB)
2262
1
  return target;
2263
1
}
2264
2265
1
size_t ApplyTransactionStatePB::ByteSizeLong() const {
2266
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ApplyTransactionStatePB)
2267
1
  size_t total_size = 0;
2268
2269
1
  if (_internal_metadata_.have_unknown_fields()) {
2270
0
    total_size +=
2271
0
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
2272
0
        _internal_metadata_.unknown_fields());
2273
0
  }
2274
1
  if (_has_bits_[0 / 32] & 15u) {
2275
    // optional bytes key = 1;
2276
1
    if (has_key()) {
2277
1
      total_size += 1 +
2278
1
        ::google::protobuf::internal::WireFormatLite::BytesSize(
2279
1
          this->key());
2280
1
    }
2281
2282
    // optional .yb.AbortedSubTransactionSetPB aborted = 4;
2283
1
    if (has_aborted()) {
2284
1
      total_size += 1 +
2285
1
        ::google::protobuf::internal::WireFormatLite::MessageSize(
2286
1
          *this->aborted_);
2287
1
    }
2288
2289
    // optional fixed64 commit_ht = 3;
2290
1
    if (has_commit_ht()) {
2291
1
      total_size += 1 + 8;
2292
1
    }
2293
2294
    // optional uint32 write_id = 2;
2295
1
    if (has_write_id()) {
2296
1
      total_size += 1 +
2297
1
        ::google::protobuf::internal::WireFormatLite::UInt32Size(
2298
1
          this->write_id());
2299
1
    }
2300
2301
1
  }
2302
1
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
2303
1
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
2304
1
  _cached_size_ = cached_size;
2305
1
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
2306
1
  return total_size;
2307
1
}
2308
2309
0
void ApplyTransactionStatePB::MergeFrom(const ::google::protobuf::Message& from) {
2310
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ApplyTransactionStatePB)
2311
0
  GOOGLE_DCHECK_NE(&from, this);
2312
0
  const ApplyTransactionStatePB* source =
2313
0
      ::google::protobuf::internal::DynamicCastToGenerated<const ApplyTransactionStatePB>(
2314
0
          &from);
2315
0
  if (source == NULL) {
2316
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ApplyTransactionStatePB)
2317
0
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
2318
0
  } else {
2319
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ApplyTransactionStatePB)
2320
0
    MergeFrom(*source);
2321
0
  }
2322
0
}
2323
2324
0
void ApplyTransactionStatePB::MergeFrom(const ApplyTransactionStatePB& from) {
2325
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ApplyTransactionStatePB)
2326
0
  GOOGLE_DCHECK_NE(&from, this);
2327
0
  _internal_metadata_.MergeFrom(from._internal_metadata_);
2328
0
  ::google::protobuf::uint32 cached_has_bits = 0;
2329
0
  (void) cached_has_bits;
2330
2331
0
  cached_has_bits = from._has_bits_[0];
2332
0
  if (cached_has_bits & 15u) {
2333
0
    if (cached_has_bits & 0x00000001u) {
2334
0
      set_has_key();
2335
0
      key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
2336
0
    }
2337
0
    if (cached_has_bits & 0x00000002u) {
2338
0
      mutable_aborted()->::yb::AbortedSubTransactionSetPB::MergeFrom(from.aborted());
2339
0
    }
2340
0
    if (cached_has_bits & 0x00000004u) {
2341
0
      commit_ht_ = from.commit_ht_;
2342
0
    }
2343
0
    if (cached_has_bits & 0x00000008u) {
2344
0
      write_id_ = from.write_id_;
2345
0
    }
2346
0
    _has_bits_[0] |= cached_has_bits;
2347
0
  }
2348
0
}
2349
2350
0
void ApplyTransactionStatePB::CopyFrom(const ::google::protobuf::Message& from) {
2351
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ApplyTransactionStatePB)
2352
0
  if (&from == this) return;
2353
0
  Clear();
2354
0
  MergeFrom(from);
2355
0
}
2356
2357
0
void ApplyTransactionStatePB::CopyFrom(const ApplyTransactionStatePB& from) {
2358
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ApplyTransactionStatePB)
2359
0
  if (&from == this) return;
2360
0
  Clear();
2361
0
  MergeFrom(from);
2362
0
}
2363
2364
1
bool ApplyTransactionStatePB::IsInitialized() const {
2365
1
  return true;
2366
1
}
2367
2368
0
void ApplyTransactionStatePB::Swap(ApplyTransactionStatePB* other) {
2369
0
  if (other == this) return;
2370
0
  InternalSwap(other);
2371
0
}
2372
0
void ApplyTransactionStatePB::InternalSwap(ApplyTransactionStatePB* other) {
2373
0
  using std::swap;
2374
0
  key_.Swap(&other->key_);
2375
0
  swap(aborted_, other->aborted_);
2376
0
  swap(commit_ht_, other->commit_ht_);
2377
0
  swap(write_id_, other->write_id_);
2378
0
  swap(_has_bits_[0], other->_has_bits_[0]);
2379
0
  _internal_metadata_.Swap(&other->_internal_metadata_);
2380
0
  swap(_cached_size_, other->_cached_size_);
2381
0
}
2382
2383
0
::google::protobuf::Metadata ApplyTransactionStatePB::GetMetadata() const {
2384
0
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
2385
0
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
2386
0
}
2387
2388
2389
// @@protoc_insertion_point(namespace_scope)
2390
}  // namespace docdb
2391
}  // namespace yb
2392
2393
// @@protoc_insertion_point(global_scope)