/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/docdb/docdb.pb.cc

Source (jump to first uncovered line)
// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: yb/docdb/docdb.proto

#include "yb/docdb/docdb.pb.h"

#include <algorithm>

#include <google/protobuf/stubs/common.h>
#include <google/protobuf/stubs/port.h>
#include <google/protobuf/stubs/once.h>
#include <google/protobuf/io/coded_stream.h>
#include <google/protobuf/wire_format_lite_inl.h>
#include <google/protobuf/descriptor.h>
#include <google/protobuf/generated_message_reflection.h>
#include <google/protobuf/reflection_ops.h>
#include <google/protobuf/wire_format.h>
// This is a temporary google only hack
#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
#include "third_party/protobuf/version.h"
#endif
#include "yb/util/protobuf-annotations.h"
// @@protoc_insertion_point(includes)
namespace yb {
namespace docdb {
class KeyValuePairPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<KeyValuePairPB>
      _instance;
} _KeyValuePairPB_default_instance_;
class ApplyExternalTransactionPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<ApplyExternalTransactionPB>
      _instance;
} _ApplyExternalTransactionPB_default_instance_;
class KeyValueWriteBatchPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<KeyValueWriteBatchPB>
      _instance;
} _KeyValueWriteBatchPB_default_instance_;
class ConsensusFrontierPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<ConsensusFrontierPB>
      _instance;
} _ConsensusFrontierPB_default_instance_;
class ApplyTransactionStatePBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<ApplyTransactionStatePB>
      _instance;
} _ApplyTransactionStatePB_default_instance_;
}  // namespace docdb
}  // namespace yb
namespace protobuf_yb_2fdocdb_2fdocdb_2eproto {
void InitDefaultsKeyValuePairPBImpl() {
  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
#else
  ::google::protobuf::internal::InitProtobufDefaults();
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  {
    void* ptr = &::yb::docdb::_KeyValuePairPB_default_instance_;
    new (ptr) ::yb::docdb::KeyValuePairPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::docdb::KeyValuePairPB::InitAsDefaultInstance();
}

void InitDefaultsKeyValuePairPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsKeyValuePairPBImpl);
}

void InitDefaultsApplyExternalTransactionPBImpl() {
  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
#else
  ::google::protobuf::internal::InitProtobufDefaults();
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  {
    void* ptr = &::yb::docdb::_ApplyExternalTransactionPB_default_instance_;
    new (ptr) ::yb::docdb::ApplyExternalTransactionPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::docdb::ApplyExternalTransactionPB::InitAsDefaultInstance();
}

void InitDefaultsApplyExternalTransactionPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsApplyExternalTransactionPBImpl);
}

void InitDefaultsKeyValueWriteBatchPBImpl() {
  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
#else
  ::google::protobuf::internal::InitProtobufDefaults();
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
  protobuf_yb_2fcommon_2fcommon_2eproto::InitDefaultsTransactionMetadataPB();
  protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsSubTransactionMetadataPB();
  protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
  {
    void* ptr = &::yb::docdb::_KeyValueWriteBatchPB_default_instance_;
    new (ptr) ::yb::docdb::KeyValueWriteBatchPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::docdb::KeyValueWriteBatchPB::InitAsDefaultInstance();
}

void InitDefaultsKeyValueWriteBatchPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsKeyValueWriteBatchPBImpl);
}

void InitDefaultsConsensusFrontierPBImpl() {
  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
#else
  ::google::protobuf::internal::InitProtobufDefaults();
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  protobuf_yb_2futil_2fopid_2eproto::InitDefaultsOpIdPB();
  {
    void* ptr = &::yb::docdb::_ConsensusFrontierPB_default_instance_;
    new (ptr) ::yb::docdb::ConsensusFrontierPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::docdb::ConsensusFrontierPB::InitAsDefaultInstance();
}

void InitDefaultsConsensusFrontierPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsConsensusFrontierPBImpl);
}

void InitDefaultsApplyTransactionStatePBImpl() {
  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();
#else
  ::google::protobuf::internal::InitProtobufDefaults();
#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS
  protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsAbortedSubTransactionSetPB();
  {
    void* ptr = &::yb::docdb::_ApplyTransactionStatePB_default_instance_;
    new (ptr) ::yb::docdb::ApplyTransactionStatePB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::docdb::ApplyTransactionStatePB::InitAsDefaultInstance();
}

void InitDefaultsApplyTransactionStatePB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsApplyTransactionStatePBImpl);
}

::google::protobuf::Metadata file_level_metadata[5];

const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, key_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, value_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValuePairPB, external_hybrid_time_),
  0,
  1,
  2,
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, transaction_id_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyExternalTransactionPB, commit_hybrid_time_),
  0,
  1,
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, write_pairs_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, transaction_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, subtransaction_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, deprecated_may_have_metadata_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, read_pairs_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, row_mark_type_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, wait_policy_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, apply_external_transactions_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::KeyValueWriteBatchPB, ttl_),
  ~0u,
  0,
  1,
  2,
  ~0u,
  3,
  5,
  ~0u,
  4,
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, op_id_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, hybrid_time_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, history_cutoff_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, hybrid_time_filter_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ConsensusFrontierPB, max_value_level_ttl_expiration_time_),
  0,
  1,
  2,
  3,
  4,
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, key_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, write_id_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, commit_ht_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::docdb::ApplyTransactionStatePB, aborted_),
  0,
  3,
  2,
  1,
};
static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  { 0, 8, sizeof(::yb::docdb::KeyValuePairPB)},
  { 11, 18, sizeof(::yb::docdb::ApplyExternalTransactionPB)},
  { 20, 34, sizeof(::yb::docdb::KeyValueWriteBatchPB)},
  { 43, 53, sizeof(::yb::docdb::ConsensusFrontierPB)},
  { 58, 67, sizeof(::yb::docdb::ApplyTransactionStatePB)},
};

static ::google::protobuf::Message const * const file_default_instances[] = {
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_KeyValuePairPB_default_instance_),
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ApplyExternalTransactionPB_default_instance_),
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_KeyValueWriteBatchPB_default_instance_),
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ConsensusFrontierPB_default_instance_),
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::docdb::_ApplyTransactionStatePB_default_instance_),
};

void protobuf_AssignDescriptors() {
  AddDescriptors();
  ::google::protobuf::MessageFactory* factory = NULL;
  AssignDescriptors(
      "yb/docdb/docdb.proto", schemas, file_default_instances, TableStruct::offsets, factory,
      file_level_metadata, NULL, NULL);
}

void protobuf_AssignDescriptorsOnce() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors);
}

void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;
void protobuf_RegisterTypes(const ::std::string&) {
  protobuf_AssignDescriptorsOnce();
  ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 5);
}

void AddDescriptorsImpl() {
  InitDefaults();
  static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
      "\n\024yb/docdb/docdb.proto\022\010yb.docdb\032\026yb/com"
      "mon/common.proto\032\033yb/common/transaction."
      "proto\032\022yb/util/opid.proto\"J\n\016KeyValuePai"
      "rPB\022\013\n\003key\030\001 \001(\014\022\r\n\005value\030\002 \001(\014\022\034\n\024exter"
      "nal_hybrid_time\030\003 \001(\006\"P\n\032ApplyExternalTr"
      "ansactionPB\022\026\n\016transaction_id\030\001 \001(\014\022\032\n\022c"
      "ommit_hybrid_time\030\002 \001(\006\"\244\003\n\024KeyValueWrit"
      "eBatchPB\022-\n\013write_pairs\030\001 \003(\0132\030.yb.docdb"
      ".KeyValuePairPB\022.\n\013transaction\030\002 \001(\0132\031.y"
      "b.TransactionMetadataPB\0224\n\016subtransactio"
      "n\030\010 \001(\0132\034.yb.SubTransactionMetadataPB\022$\n"
      "\034DEPRECATED_may_have_metadata\030\003 \001(\010\022,\n\nr"
      "ead_pairs\030\005 \003(\0132\030.yb.docdb.KeyValuePairP"
      "B\022&\n\rrow_mark_type\030\006 \001(\0162\017.yb.RowMarkTyp"
      "e\022#\n\013wait_policy\030\n \001(\0162\016.yb.WaitPolicy\022I"
      "\n\033apply_external_transactions\030\007 \003(\0132$.yb"
      ".docdb.ApplyExternalTransactionPB\022\013\n\003ttl"
      "\030\t \001(\003\"\246\001\n\023ConsensusFrontierPB\022\031\n\005op_id\030"
      "\001 \001(\0132\n.yb.OpIdPB\022\023\n\013hybrid_time\030\002 \001(\006\022\026"
      "\n\016history_cutoff\030\003 \001(\006\022\032\n\022hybrid_time_fi"
      "lter\030\004 \001(\006\022+\n#max_value_level_ttl_expira"
      "tion_time\030\005 \001(\006\"|\n\027ApplyTransactionState"
      "PB\022\013\n\003key\030\001 \001(\014\022\020\n\010write_id\030\002 \001(\r\022\021\n\tcom"
      "mit_ht\030\003 \001(\006\022/\n\007aborted\030\004 \001(\0132\036.yb.Abort"
      "edSubTransactionSetPBB\016\n\014org.yb.docdb"
  };
  ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
      descriptor, 997);
  ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
    "yb/docdb/docdb.proto", &protobuf_RegisterTypes);
  ::protobuf_yb_2fcommon_2fcommon_2eproto::AddDescriptors();
  ::protobuf_yb_2fcommon_2ftransaction_2eproto::AddDescriptors();
  ::protobuf_yb_2futil_2fopid_2eproto::AddDescriptors();
}

void AddDescriptors() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl);
}
// Force AddDescriptors() to be called at dynamic initialization time.
struct StaticDescriptorInitializer {
  StaticDescriptorInitializer() {
    AddDescriptors();
  }
} static_descriptor_initializer;
}  // namespace protobuf_yb_2fdocdb_2fdocdb_2eproto
namespace yb {
namespace docdb {

// ===================================================================

void KeyValuePairPB::InitAsDefaultInstance() {
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int KeyValuePairPB::kKeyFieldNumber;
const int KeyValuePairPB::kValueFieldNumber;
const int KeyValuePairPB::kExternalHybridTimeFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

KeyValuePairPB::KeyValuePairPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.docdb.KeyValuePairPB)
}
KeyValuePairPB::KeyValuePairPB(const KeyValuePairPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  if (from.has_key()) {
    key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
  }
  value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  if (from.has_value()) {
    value_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.value_);
  }
  external_hybrid_time_ = from.external_hybrid_time_;
  // @@protoc_insertion_point(copy_constructor:yb.docdb.KeyValuePairPB)
}

void KeyValuePairPB::SharedCtor() {
  _cached_size_ = 0;
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  external_hybrid_time_ = GOOGLE_ULONGLONG(0);
}

KeyValuePairPB::~KeyValuePairPB() {
  // @@protoc_insertion_point(destructor:yb.docdb.KeyValuePairPB)
  SharedDtor();
}

void KeyValuePairPB::SharedDtor() {
  key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  value_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
}

void KeyValuePairPB::SetCachedSize(int size) const {
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
}
const ::google::protobuf::Descriptor* KeyValuePairPB::descriptor() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
}

const KeyValuePairPB& KeyValuePairPB::default_instance() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValuePairPB();
  return *internal_default_instance();
}

KeyValuePairPB* KeyValuePairPB::New(::google::protobuf::Arena* arena) const {
  KeyValuePairPB* n = new KeyValuePairPB;
  if (arena != NULL) {
    arena->Own(n);
  }
  return n;
}

void KeyValuePairPB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.docdb.KeyValuePairPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  if (cached_has_bits & 3u) {
    if (cached_has_bits & 0x00000001u) {
      GOOGLE_DCHECK(!key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
      (*key_.UnsafeRawStringPointer())->clear();
    }
    if (cached_has_bits & 0x00000002u) {
      GOOGLE_DCHECK(!value_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
      (*value_.UnsafeRawStringPointer())->clear();
    }
  }
  external_hybrid_time_ = GOOGLE_ULONGLONG(0);
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool KeyValuePairPB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.docdb.KeyValuePairPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual155M;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // optional bytes key = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
                input, this->mutable_key()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional bytes value = 2;
      case 2: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
                input, this->mutable_value()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 external_hybrid_time = 3;
      case 3: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
          set_has_external_hybrid_time();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &external_hybrid_time_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      default: {
      handle_unusual:
        if (tag == 0155M) {
          goto success;
        }
        DO_(::google::protobuf::internal::WireFormat::SkipField(
              input, tag, _internal_metadata_.mutable_unknown_fields()));
        break;
      }
    }
  }
success:
  // @@protoc_insertion_point(parse_success:yb.docdb.KeyValuePairPB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.docdb.KeyValuePairPB)
  return false;
#undef DO_
}

void KeyValuePairPB::SerializeWithCachedSizes(
    ::google::protobuf::io::CodedOutputStream* output) const {
  // @@protoc_insertion_point(serialize_start:yb.docdb.KeyValuePairPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes key = 1;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
      1, this->key(), output);
  }

  // optional bytes value = 2;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
      2, this->value(), output);
  }

  // optional fixed64 external_hybrid_time = 3;
  if (cached_has_bits & 0x00000004u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->external_hybrid_time(), output);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
        _internal_metadata_.unknown_fields(), output);
  }
  // @@protoc_insertion_point(serialize_end:yb.docdb.KeyValuePairPB)
}

::google::protobuf::uint8* KeyValuePairPB::InternalSerializeWithCachedSizesToArray(
    bool deterministic, ::google::protobuf::uint8* target) const {
  (void)deterministic; // Unused
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.KeyValuePairPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes key = 1;
  if (cached_has_bits & 0x00000001u343M) {
    target =
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
        1, this->key(), target);
  }

  // optional bytes value = 2;
  if (cached_has_bits & 0x00000002u343M) {
    target =
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
        2, this->value(), target);
  }

  // optional fixed64 external_hybrid_time = 3;
  if (cached_has_bits & 0x00000004u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->external_hybrid_time(), target);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
        _internal_metadata_.unknown_fields(), target);
  }
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.KeyValuePairPB)
  return target;
}

size_t KeyValuePairPB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.KeyValuePairPB)
  size_t total_size = 0;

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  if (_has_bits_[0 / 32] & 7u) {
    // optional bytes key = 1;
    if (has_key()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::BytesSize(
          this->key());
    }

    // optional bytes value = 2;
    if (has_value()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::BytesSize(
          this->value());
    }

    // optional fixed64 external_hybrid_time = 3;
    if (has_external_hybrid_time()) {
      total_size += 1 + 8;
    }

  }
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = cached_size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
  return total_size;
}

void KeyValuePairPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.KeyValuePairPB)
  GOOGLE_DCHECK_NE(&from, this);
  const KeyValuePairPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const KeyValuePairPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.KeyValuePairPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.KeyValuePairPB)
    MergeFrom(*source);
  }
}

void KeyValuePairPB::MergeFrom(const KeyValuePairPB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.KeyValuePairPB)
  GOOGLE_DCHECK_NE(&from, this);
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = from._has_bits_[0];
  if (cached_has_bits & 7u) {
    if (cached_has_bits & 0x00000001u) {
      set_has_key();
      key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
    }
    if (cached_has_bits & 0x00000002u) {
      set_has_value();
      value_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.value_);
    }
    if (cached_has_bits & 0x00000004u) {
      external_hybrid_time_ = from.external_hybrid_time_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

void KeyValuePairPB::CopyFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.KeyValuePairPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

void KeyValuePairPB::CopyFrom(const KeyValuePairPB& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.KeyValuePairPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

bool KeyValuePairPB::IsInitialized() const {
  return true;
}

void KeyValuePairPB::Swap(KeyValuePairPB* other) {
  if (other == this) return;
  InternalSwap(other);
}
void KeyValuePairPB::InternalSwap(KeyValuePairPB* other) {
  using std::swap;
  key_.Swap(&other->key_);
  value_.Swap(&other->value_);
  swap(external_hybrid_time_, other->external_hybrid_time_);
  swap(_has_bits_[0], other->_has_bits_[0]);
  _internal_metadata_.Swap(&other->_internal_metadata_);
  swap(_cached_size_, other->_cached_size_);
}

::google::protobuf::Metadata KeyValuePairPB::GetMetadata() const {
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
}


// ===================================================================

void ApplyExternalTransactionPB::InitAsDefaultInstance() {
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int ApplyExternalTransactionPB::kTransactionIdFieldNumber;
const int ApplyExternalTransactionPB::kCommitHybridTimeFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

ApplyExternalTransactionPB::ApplyExternalTransactionPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.docdb.ApplyExternalTransactionPB)
}
ApplyExternalTransactionPB::ApplyExternalTransactionPB(const ApplyExternalTransactionPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  transaction_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  if (from.has_transaction_id()) {
    transaction_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.transaction_id_);
  }
  commit_hybrid_time_ = from.commit_hybrid_time_;
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ApplyExternalTransactionPB)
}

void ApplyExternalTransactionPB::SharedCtor() {
  _cached_size_ = 0;
  transaction_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  commit_hybrid_time_ = GOOGLE_ULONGLONG(0);
}

ApplyExternalTransactionPB::~ApplyExternalTransactionPB() {
  // @@protoc_insertion_point(destructor:yb.docdb.ApplyExternalTransactionPB)
  SharedDtor();
}

void ApplyExternalTransactionPB::SharedDtor() {
  transaction_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
}

void ApplyExternalTransactionPB::SetCachedSize(int size) const {
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
}
const ::google::protobuf::Descriptor* ApplyExternalTransactionPB::descriptor() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
}

const ApplyExternalTransactionPB& ApplyExternalTransactionPB::default_instance() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyExternalTransactionPB();
  return *internal_default_instance();
}

ApplyExternalTransactionPB* ApplyExternalTransactionPB::New(::google::protobuf::Arena* arena) const {
  ApplyExternalTransactionPB* n = new ApplyExternalTransactionPB;
  if (arena != NULL) {
    arena->Own(n);
  }
  return n;
}

void ApplyExternalTransactionPB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.docdb.ApplyExternalTransactionPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  if (cached_has_bits & 0x00000001u) {
    GOOGLE_DCHECK(!transaction_id_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
    (*transaction_id_.UnsafeRawStringPointer())->clear();
  }
  commit_hybrid_time_ = GOOGLE_ULONGLONG(0);
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool ApplyExternalTransactionPB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.docdb.ApplyExternalTransactionPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // optional bytes transaction_id = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
                input, this->mutable_transaction_id()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 commit_hybrid_time = 2;
      case 2: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(17u /* 17 & 0xFF */)) {
          set_has_commit_hybrid_time();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &commit_hybrid_time_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      default: {
      handle_unusual:
        if (tag == 0) {
          goto success;
        }
        DO_(::google::protobuf::internal::WireFormat::SkipField(
              input, tag, _internal_metadata_.mutable_unknown_fields()));
        break;
      }
    }
  }
success:
  // @@protoc_insertion_point(parse_success:yb.docdb.ApplyExternalTransactionPB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.docdb.ApplyExternalTransactionPB)
  return false;
#undef DO_
}

void ApplyExternalTransactionPB::SerializeWithCachedSizes(
    ::google::protobuf::io::CodedOutputStream* output) const {
  // @@protoc_insertion_point(serialize_start:yb.docdb.ApplyExternalTransactionPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes transaction_id = 1;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
      1, this->transaction_id(), output);
  }

  // optional fixed64 commit_hybrid_time = 2;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(2, this->commit_hybrid_time(), output);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
        _internal_metadata_.unknown_fields(), output);
  }
  // @@protoc_insertion_point(serialize_end:yb.docdb.ApplyExternalTransactionPB)
}

::google::protobuf::uint8* ApplyExternalTransactionPB::InternalSerializeWithCachedSizesToArray(
    bool deterministic, ::google::protobuf::uint8* target) const {
  (void)deterministic; // Unused
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ApplyExternalTransactionPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes transaction_id = 1;
  if (cached_has_bits & 0x00000001u) {
    target =
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
        1, this->transaction_id(), target);
  }

  // optional fixed64 commit_hybrid_time = 2;
  if (cached_has_bits & 0x00000002u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(2, this->commit_hybrid_time(), target);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
        _internal_metadata_.unknown_fields(), target);
  }
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ApplyExternalTransactionPB)
  return target;
}

size_t ApplyExternalTransactionPB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ApplyExternalTransactionPB)
  size_t total_size = 0;

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  if (_has_bits_[0 / 32] & 3u) {
    // optional bytes transaction_id = 1;
    if (has_transaction_id()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::BytesSize(
          this->transaction_id());
    }

    // optional fixed64 commit_hybrid_time = 2;
    if (has_commit_hybrid_time()) {
      total_size += 1 + 8;
    }

  }
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = cached_size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
  return total_size;
}

void ApplyExternalTransactionPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ApplyExternalTransactionPB)
  GOOGLE_DCHECK_NE(&from, this);
  const ApplyExternalTransactionPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const ApplyExternalTransactionPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ApplyExternalTransactionPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ApplyExternalTransactionPB)
    MergeFrom(*source);
  }
}

void ApplyExternalTransactionPB::MergeFrom(const ApplyExternalTransactionPB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ApplyExternalTransactionPB)
  GOOGLE_DCHECK_NE(&from, this);
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = from._has_bits_[0];
  if (cached_has_bits & 3u) {
    if (cached_has_bits & 0x00000001u) {
      set_has_transaction_id();
      transaction_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.transaction_id_);
    }
    if (cached_has_bits & 0x00000002u) {
      commit_hybrid_time_ = from.commit_hybrid_time_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

void ApplyExternalTransactionPB::CopyFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ApplyExternalTransactionPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

void ApplyExternalTransactionPB::CopyFrom(const ApplyExternalTransactionPB& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ApplyExternalTransactionPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

bool ApplyExternalTransactionPB::IsInitialized() const {
  return true;
}

void ApplyExternalTransactionPB::Swap(ApplyExternalTransactionPB* other) {
  if (other == this) return;
  InternalSwap(other);
}
void ApplyExternalTransactionPB::InternalSwap(ApplyExternalTransactionPB* other) {
  using std::swap;
  transaction_id_.Swap(&other->transaction_id_);
  swap(commit_hybrid_time_, other->commit_hybrid_time_);
  swap(_has_bits_[0], other->_has_bits_[0]);
  _internal_metadata_.Swap(&other->_internal_metadata_);
  swap(_cached_size_, other->_cached_size_);
}

::google::protobuf::Metadata ApplyExternalTransactionPB::GetMetadata() const {
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
}


// ===================================================================

void KeyValueWriteBatchPB::InitAsDefaultInstance() {
  ::yb::docdb::_KeyValueWriteBatchPB_default_instance_._instance.get_mutable()->transaction_ = const_cast< ::yb::TransactionMetadataPB*>(
      ::yb::TransactionMetadataPB::internal_default_instance());
  ::yb::docdb::_KeyValueWriteBatchPB_default_instance_._instance.get_mutable()->subtransaction_ = const_cast< ::yb::SubTransactionMetadataPB*>(
      ::yb::SubTransactionMetadataPB::internal_default_instance());
}
void KeyValueWriteBatchPB::clear_transaction() {
  if (transaction_ != NULL) transaction_->Clear();
  clear_has_transaction();
}
void KeyValueWriteBatchPB::clear_subtransaction() {
  if (subtransaction_ != NULL) subtransaction_->Clear();
  clear_has_subtransaction();
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int KeyValueWriteBatchPB::kWritePairsFieldNumber;
const int KeyValueWriteBatchPB::kTransactionFieldNumber;
const int KeyValueWriteBatchPB::kSubtransactionFieldNumber;
const int KeyValueWriteBatchPB::kDEPRECATEDMayHaveMetadataFieldNumber;
const int KeyValueWriteBatchPB::kReadPairsFieldNumber;
const int KeyValueWriteBatchPB::kRowMarkTypeFieldNumber;
const int KeyValueWriteBatchPB::kWaitPolicyFieldNumber;
const int KeyValueWriteBatchPB::kApplyExternalTransactionsFieldNumber;
const int KeyValueWriteBatchPB::kTtlFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

KeyValueWriteBatchPB::KeyValueWriteBatchPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValueWriteBatchPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.docdb.KeyValueWriteBatchPB)
}
KeyValueWriteBatchPB::KeyValueWriteBatchPB(const KeyValueWriteBatchPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0),
      write_pairs_(from.write_pairs_),
      read_pairs_(from.read_pairs_),
      apply_external_transactions_(from.apply_external_transactions_) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  if (from.has_transaction()) {
    transaction_ = new ::yb::TransactionMetadataPB(*from.transaction_);
  } else {
    transaction_ = NULL;
  }
  if (from.has_subtransaction()) {
    subtransaction_ = new ::yb::SubTransactionMetadataPB(*from.subtransaction_);
  } else {
    subtransaction_ = NULL;
  }
  ::memcpy(&deprecated_may_have_metadata_, &from.deprecated_may_have_metadata_,
    static_cast<size_t>(reinterpret_cast<char*>(&wait_policy_) -
    reinterpret_cast<char*>(&deprecated_may_have_metadata_)) + sizeof(wait_policy_));
  // @@protoc_insertion_point(copy_constructor:yb.docdb.KeyValueWriteBatchPB)
}

void KeyValueWriteBatchPB::SharedCtor() {
  _cached_size_ = 0;
  ::memset(&transaction_, 0, static_cast<size_t>(
      reinterpret_cast<char*>(&wait_policy_) -
      reinterpret_cast<char*>(&transaction_)) + sizeof(wait_policy_));
}

KeyValueWriteBatchPB::~KeyValueWriteBatchPB() {
  // @@protoc_insertion_point(destructor:yb.docdb.KeyValueWriteBatchPB)
  SharedDtor();
}

void KeyValueWriteBatchPB::SharedDtor() {
  if (this != internal_default_instance()) delete transaction_12.5M;
  if (this != internal_default_instance()) delete subtransaction_12.5M;
}

void KeyValueWriteBatchPB::SetCachedSize(int size) const {
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
}
const ::google::protobuf::Descriptor* KeyValueWriteBatchPB::descriptor() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
}

const KeyValueWriteBatchPB& KeyValueWriteBatchPB::default_instance() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsKeyValueWriteBatchPB();
  return *internal_default_instance();
}

KeyValueWriteBatchPB* KeyValueWriteBatchPB::New(::google::protobuf::Arena* arena) const {
  KeyValueWriteBatchPB* n = new KeyValueWriteBatchPB;
  if (arena != NULL) {
    arena->Own(n);
  }
  return n;
}

void KeyValueWriteBatchPB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.docdb.KeyValueWriteBatchPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;

  write_pairs_.Clear();
  read_pairs_.Clear();
  apply_external_transactions_.Clear();
  cached_has_bits = _has_bits_[0];
  if (cached_has_bits & 3u) {
    if (cached_has_bits & 0x00000001u) {
      GOOGLE_DCHECK(transaction_ != NULL);
      transaction_->Clear();
    }
    if (cached_has_bits & 0x00000002u) {
      GOOGLE_DCHECK(subtransaction_ != NULL);
      subtransaction_->Clear();
    }
  }
  if (cached_has_bits & 60u) {
    ::memset(&deprecated_may_have_metadata_, 0, static_cast<size_t>(
        reinterpret_cast<char*>(&wait_policy_) -
        reinterpret_cast<char*>(&deprecated_may_have_metadata_)) + sizeof(wait_policy_));
  }
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool KeyValueWriteBatchPB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.docdb.KeyValueWriteBatchPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual8.04M;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_write_pairs()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.TransactionMetadataPB transaction = 2;
      case 2: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
               input, mutable_transaction()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional bool DEPRECATED_may_have_metadata = 3;
      case 3: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) {
          set_has_deprecated_may_have_metadata();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(
                 input, &deprecated_may_have_metadata_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
      case 5: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(42u /* 42 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_read_pairs()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.RowMarkType row_mark_type = 6;
      case 6: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(48u /* 48 & 0xFF */)) {
          int value;
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
                 input, &value)));
          if (::yb::RowMarkType_IsValid(value)) {
            set_row_mark_type(static_cast< ::yb::RowMarkType >(value));
          } else {
            mutable_unknown_fields()->AddVarint(
                6, static_cast< ::google::protobuf::uint64>(value));
          }
        } else {
          goto handle_unusual;
        }
        break;
      }

      // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
      case 7: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(input, add_apply_external_transactions()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.SubTransactionMetadataPB subtransaction = 8;
      case 8: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
               input, mutable_subtransaction()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional int64 ttl = 9;
      case 9: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(72u /* 72 & 0xFF */)) {
          set_has_ttl();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::int64, ::google::protobuf::internal::WireFormatLite::TYPE_INT64>(
                 input, &ttl_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.WaitPolicy wait_policy = 10;
      case 10: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(80u /* 80 & 0xFF */)) {
          int value;
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
                 input, &value)));
          if (::yb::WaitPolicy_IsValid(value)) {
            set_wait_policy(static_cast< ::yb::WaitPolicy >(value));
          } else {
            mutable_unknown_fields()->AddVarint(
                10, static_cast< ::google::protobuf::uint64>(value));
          }
        } else {
          goto handle_unusual;
        }
        break;
      }

      default: {
      handle_unusual:
        if (tag == 08.04M) {
          goto success;
        }
        DO_(::google::protobuf::internal::WireFormat::SkipField(
              input, tag, _internal_metadata_.mutable_unknown_fields()));
        break;
      }
    }
  }
success:
  // @@protoc_insertion_point(parse_success:yb.docdb.KeyValueWriteBatchPB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.docdb.KeyValueWriteBatchPB)
  return false;
#undef DO_
}

void KeyValueWriteBatchPB::SerializeWithCachedSizes(
    ::google::protobuf::io::CodedOutputStream* output) const {
  // @@protoc_insertion_point(serialize_start:yb.docdb.KeyValueWriteBatchPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->write_pairs_size()); i < n; i++) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      1, this->write_pairs(static_cast<int>(i)), output);
  }

  cached_has_bits = _has_bits_[0];
  // optional .yb.TransactionMetadataPB transaction = 2;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      2, *this->transaction_, output);
  }

  // optional bool DEPRECATED_may_have_metadata = 3;
  if (cached_has_bits & 0x00000004u) {
    ::google::protobuf::internal::WireFormatLite::WriteBool(3, this->deprecated_may_have_metadata(), output);
  }

  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->read_pairs_size()); i < n; i++) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      5, this->read_pairs(static_cast<int>(i)), output);
  }

  // optional .yb.RowMarkType row_mark_type = 6;
  if (cached_has_bits & 0x00000008u) {
    ::google::protobuf::internal::WireFormatLite::WriteEnum(
      6, this->row_mark_type(), output);
  }

  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->apply_external_transactions_size()); i < n; i++) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      7, this->apply_external_transactions(static_cast<int>(i)), output);
  }

  // optional .yb.SubTransactionMetadataPB subtransaction = 8;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      8, *this->subtransaction_, output);
  }

  // optional int64 ttl = 9;
  if (cached_has_bits & 0x00000010u) {
    ::google::protobuf::internal::WireFormatLite::WriteInt64(9, this->ttl(), output);
  }

  // optional .yb.WaitPolicy wait_policy = 10;
  if (cached_has_bits & 0x00000020u) {
    ::google::protobuf::internal::WireFormatLite::WriteEnum(
      10, this->wait_policy(), output);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
        _internal_metadata_.unknown_fields(), output);
  }
  // @@protoc_insertion_point(serialize_end:yb.docdb.KeyValueWriteBatchPB)
}

::google::protobuf::uint8* KeyValueWriteBatchPB::InternalSerializeWithCachedSizesToArray(
    bool deterministic, ::google::protobuf::uint8* target) const {
  (void)deterministic; // Unused
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.KeyValueWriteBatchPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->write_pairs_size()); i < n; i++331M) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        1, this->write_pairs(static_cast<int>(i)), deterministic, target);
  }

  cached_has_bits = _has_bits_[0];
  // optional .yb.TransactionMetadataPB transaction = 2;
  if (cached_has_bits & 0x00000001u) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        2, *this->transaction_, deterministic, target);
  }

  // optional bool DEPRECATED_may_have_metadata = 3;
  if (cached_has_bits & 0x00000004u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(3, this->deprecated_may_have_metadata(), target);
  }

  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->read_pairs_size()); i < n; i++11.7M) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        5, this->read_pairs(static_cast<int>(i)), deterministic, target);
  }

  // optional .yb.RowMarkType row_mark_type = 6;
  if (cached_has_bits & 0x00000008u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
      6, this->row_mark_type(), target);
  }

  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
  for (unsigned int i = 0,
      n = static_cast<unsigned int>(this->apply_external_transactions_size()); i < n; i++0) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        7, this->apply_external_transactions(static_cast<int>(i)), deterministic, target);
  }

  // optional .yb.SubTransactionMetadataPB subtransaction = 8;
  if (cached_has_bits & 0x00000002u) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        8, *this->subtransaction_, deterministic, target);
  }

  // optional int64 ttl = 9;
  if (cached_has_bits & 0x00000010u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteInt64ToArray(9, this->ttl(), target);
  }

  // optional .yb.WaitPolicy wait_policy = 10;
  if (cached_has_bits & 0x00000020u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
      10, this->wait_policy(), target);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
        _internal_metadata_.unknown_fields(), target);
  }
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.KeyValueWriteBatchPB)
  return target;
}

size_t KeyValueWriteBatchPB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.KeyValueWriteBatchPB)
  size_t total_size = 0;

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  // repeated .yb.docdb.KeyValuePairPB write_pairs = 1;
  {
    unsigned int count = static_cast<unsigned int>(this->write_pairs_size());
    total_size += 1UL * count;
    for (unsigned int i = 0; i < count; i++716M) {
      total_size +=
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          this->write_pairs(static_cast<int>(i)));
    }
  }

  // repeated .yb.docdb.KeyValuePairPB read_pairs = 5;
  {
    unsigned int count = static_cast<unsigned int>(this->read_pairs_size());
    total_size += 1UL * count;
    for (unsigned int i = 0; i < count; i++28.1M) {
      total_size +=
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          this->read_pairs(static_cast<int>(i)));
    }
  }

  // repeated .yb.docdb.ApplyExternalTransactionPB apply_external_transactions = 7;
  {
    unsigned int count = static_cast<unsigned int>(this->apply_external_transactions_size());
    total_size += 1UL * count;
    for (unsigned int i = 0; i < count; i++0) {
      total_size +=
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          this->apply_external_transactions(static_cast<int>(i)));
    }
  }

  if (_has_bits_[0 / 32] & 63u) {
    // optional .yb.TransactionMetadataPB transaction = 2;
    if (has_transaction()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          *this->transaction_);
    }

    // optional .yb.SubTransactionMetadataPB subtransaction = 8;
    if (has_subtransaction()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          *this->subtransaction_);
    }

    // optional bool DEPRECATED_may_have_metadata = 3;
    if (has_deprecated_may_have_metadata()) {
      total_size += 1 + 1;
    }

    // optional .yb.RowMarkType row_mark_type = 6;
    if (has_row_mark_type()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::EnumSize(this->row_mark_type());
    }

    // optional int64 ttl = 9;
    if (has_ttl()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::Int64Size(
          this->ttl());
    }

    // optional .yb.WaitPolicy wait_policy = 10;
    if (has_wait_policy()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::EnumSize(this->wait_policy());
    }

  }
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = cached_size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
  return total_size;
}

void KeyValueWriteBatchPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.KeyValueWriteBatchPB)
  GOOGLE_DCHECK_NE(&from, this);
  const KeyValueWriteBatchPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const KeyValueWriteBatchPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.KeyValueWriteBatchPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.KeyValueWriteBatchPB)
    MergeFrom(*source);
  }
}

void KeyValueWriteBatchPB::MergeFrom(const KeyValueWriteBatchPB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.KeyValueWriteBatchPB)
  GOOGLE_DCHECK_NE(&from, this);
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  write_pairs_.MergeFrom(from.write_pairs_);
  read_pairs_.MergeFrom(from.read_pairs_);
  apply_external_transactions_.MergeFrom(from.apply_external_transactions_);
  cached_has_bits = from._has_bits_[0];
  if (cached_has_bits & 63u) {
    if (cached_has_bits & 0x00000001u669k) {
      mutable_transaction()->::yb::TransactionMetadataPB::MergeFrom(from.transaction());
    }
    if (cached_has_bits & 0x00000002u) {
      mutable_subtransaction()->::yb::SubTransactionMetadataPB::MergeFrom(from.subtransaction());
    }
    if (cached_has_bits & 0x00000004u669k) {
      deprecated_may_have_metadata_ = from.deprecated_may_have_metadata_;
    }
    if (cached_has_bits & 0x00000008u) {
      row_mark_type_ = from.row_mark_type_;
    }
    if (cached_has_bits & 0x00000010u) {
      ttl_ = from.ttl_;
    }
    if (cached_has_bits & 0x00000020u) {
      wait_policy_ = from.wait_policy_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

void KeyValueWriteBatchPB::CopyFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.KeyValueWriteBatchPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

void KeyValueWriteBatchPB::CopyFrom(const KeyValueWriteBatchPB& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.KeyValueWriteBatchPB)
  if (&from == this) return0;
  Clear();
  MergeFrom(from);
}

bool KeyValueWriteBatchPB::IsInitialized() const {
  return true;
}

void KeyValueWriteBatchPB::Swap(KeyValueWriteBatchPB* other) {
  if (other == this) return;
  InternalSwap(other);
}
void KeyValueWriteBatchPB::InternalSwap(KeyValueWriteBatchPB* other) {
  using std::swap;
  write_pairs_.InternalSwap(&other->write_pairs_);
  read_pairs_.InternalSwap(&other->read_pairs_);
  apply_external_transactions_.InternalSwap(&other->apply_external_transactions_);
  swap(transaction_, other->transaction_);
  swap(subtransaction_, other->subtransaction_);
  swap(deprecated_may_have_metadata_, other->deprecated_may_have_metadata_);
  swap(row_mark_type_, other->row_mark_type_);
  swap(ttl_, other->ttl_);
  swap(wait_policy_, other->wait_policy_);
  swap(_has_bits_[0], other->_has_bits_[0]);
  _internal_metadata_.Swap(&other->_internal_metadata_);
  swap(_cached_size_, other->_cached_size_);
}

::google::protobuf::Metadata KeyValueWriteBatchPB::GetMetadata() const {
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
}


// ===================================================================

void ConsensusFrontierPB::InitAsDefaultInstance() {
  ::yb::docdb::_ConsensusFrontierPB_default_instance_._instance.get_mutable()->op_id_ = const_cast< ::yb::OpIdPB*>(
      ::yb::OpIdPB::internal_default_instance());
}
void ConsensusFrontierPB::clear_op_id() {
  if (op_id_ != NULL) op_id_->Clear();
  clear_has_op_id();
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int ConsensusFrontierPB::kOpIdFieldNumber;
const int ConsensusFrontierPB::kHybridTimeFieldNumber;
const int ConsensusFrontierPB::kHistoryCutoffFieldNumber;
const int ConsensusFrontierPB::kHybridTimeFilterFieldNumber;
const int ConsensusFrontierPB::kMaxValueLevelTtlExpirationTimeFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

ConsensusFrontierPB::ConsensusFrontierPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsConsensusFrontierPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.docdb.ConsensusFrontierPB)
}
ConsensusFrontierPB::ConsensusFrontierPB(const ConsensusFrontierPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  if (from.has_op_id()) {
    op_id_ = new ::yb::OpIdPB(*from.op_id_);
  } else {
    op_id_ = NULL;
  }
  ::memcpy(&hybrid_time_, &from.hybrid_time_,
    static_cast<size_t>(reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
    reinterpret_cast<char*>(&hybrid_time_)) + sizeof(max_value_level_ttl_expiration_time_));
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ConsensusFrontierPB)
}

void ConsensusFrontierPB::SharedCtor() {
  _cached_size_ = 0;
  ::memset(&op_id_, 0, static_cast<size_t>(
      reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
      reinterpret_cast<char*>(&op_id_)) + sizeof(max_value_level_ttl_expiration_time_));
}

ConsensusFrontierPB::~ConsensusFrontierPB() {
  // @@protoc_insertion_point(destructor:yb.docdb.ConsensusFrontierPB)
  SharedDtor();
}

void ConsensusFrontierPB::SharedDtor() {
  if (this != internal_default_instance()) delete op_id_370k;
}

void ConsensusFrontierPB::SetCachedSize(int size) const {
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
}
const ::google::protobuf::Descriptor* ConsensusFrontierPB::descriptor() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
}

const ConsensusFrontierPB& ConsensusFrontierPB::default_instance() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsConsensusFrontierPB();
  return *internal_default_instance();
}

ConsensusFrontierPB* ConsensusFrontierPB::New(::google::protobuf::Arena* arena) const {
  ConsensusFrontierPB* n = new ConsensusFrontierPB;
  if (arena != NULL) {
    arena->Own(n);
  }
  return n;
}

void ConsensusFrontierPB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.docdb.ConsensusFrontierPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  if (cached_has_bits & 0x00000001u) {
    GOOGLE_DCHECK(op_id_ != NULL);
    op_id_->Clear();
  }
  if (cached_has_bits & 30u) {
    ::memset(&hybrid_time_, 0, static_cast<size_t>(
        reinterpret_cast<char*>(&max_value_level_ttl_expiration_time_) -
        reinterpret_cast<char*>(&hybrid_time_)) + sizeof(max_value_level_ttl_expiration_time_));
  }
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool ConsensusFrontierPB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure0
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.docdb.ConsensusFrontierPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual34.2k;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // optional .yb.OpIdPB op_id = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
               input, mutable_op_id()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 hybrid_time = 2;
      case 2: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(17u /* 17 & 0xFF */)) {
          set_has_hybrid_time();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &hybrid_time_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 history_cutoff = 3;
      case 3: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
          set_has_history_cutoff();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &history_cutoff_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 hybrid_time_filter = 4;
      case 4: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(33u /* 33 & 0xFF */)) {
          set_has_hybrid_time_filter();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &hybrid_time_filter_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 max_value_level_ttl_expiration_time = 5;
      case 5: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(41u /* 41 & 0xFF */)) {
          set_has_max_value_level_ttl_expiration_time();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &max_value_level_ttl_expiration_time_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      default: {
      handle_unusual:
        if (tag == 0) {
          goto success;
        }
        DO_(::google::protobuf::internal::WireFormat::SkipField(
              input, tag, _internal_metadata_.mutable_unknown_fields()));
        break;
      }
    }
  }
success:
  // @@protoc_insertion_point(parse_success:yb.docdb.ConsensusFrontierPB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.docdb.ConsensusFrontierPB)
  return false;
#undef DO_
}

void ConsensusFrontierPB::SerializeWithCachedSizes(
    ::google::protobuf::io::CodedOutputStream* output) const {
  // @@protoc_insertion_point(serialize_start:yb.docdb.ConsensusFrontierPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional .yb.OpIdPB op_id = 1;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      1, *this->op_id_, output);
  }

  // optional fixed64 hybrid_time = 2;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(2, this->hybrid_time(), output);
  }

  // optional fixed64 history_cutoff = 3;
  if (cached_has_bits & 0x00000004u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->history_cutoff(), output);
  }

  // optional fixed64 hybrid_time_filter = 4;
  if (cached_has_bits & 0x00000008u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(4, this->hybrid_time_filter(), output);
  }

  // optional fixed64 max_value_level_ttl_expiration_time = 5;
  if (cached_has_bits & 0x00000010u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(5, this->max_value_level_ttl_expiration_time(), output);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
        _internal_metadata_.unknown_fields(), output);
  }
  // @@protoc_insertion_point(serialize_end:yb.docdb.ConsensusFrontierPB)
}

::google::protobuf::uint8* ConsensusFrontierPB::InternalSerializeWithCachedSizesToArray(
    bool deterministic, ::google::protobuf::uint8* target) const {
  (void)deterministic; // Unused
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ConsensusFrontierPB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional .yb.OpIdPB op_id = 1;
  if (cached_has_bits & 0x00000001u) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        1, *this->op_id_, deterministic, target);
  }

  // optional fixed64 hybrid_time = 2;
  if (cached_has_bits & 0x00000002u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(2, this->hybrid_time(), target);
  }

  // optional fixed64 history_cutoff = 3;
  if (cached_has_bits & 0x00000004u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->history_cutoff(), target);
  }

  // optional fixed64 hybrid_time_filter = 4;
  if (cached_has_bits & 0x00000008u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(4, this->hybrid_time_filter(), target);
  }

  // optional fixed64 max_value_level_ttl_expiration_time = 5;
  if (cached_has_bits & 0x00000010u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(5, this->max_value_level_ttl_expiration_time(), target);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
        _internal_metadata_.unknown_fields(), target);
  }
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ConsensusFrontierPB)
  return target;
}

size_t ConsensusFrontierPB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ConsensusFrontierPB)
  size_t total_size = 0;

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  if (_has_bits_[0 / 32] & 31u) {
    // optional .yb.OpIdPB op_id = 1;
    if (has_op_id()336k) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          *this->op_id_);
    }

    // optional fixed64 hybrid_time = 2;
    if (has_hybrid_time()336k) {
      total_size += 1 + 8;
    }

    // optional fixed64 history_cutoff = 3;
    if (has_history_cutoff()) {
      total_size += 1 + 8;
    }

    // optional fixed64 hybrid_time_filter = 4;
    if (has_hybrid_time_filter()) {
      total_size += 1 + 8;
    }

    // optional fixed64 max_value_level_ttl_expiration_time = 5;
    if (has_max_value_level_ttl_expiration_time()) {
      total_size += 1 + 8;
    }

  }
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = cached_size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
  return total_size;
}

void ConsensusFrontierPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ConsensusFrontierPB)
  GOOGLE_DCHECK_NE(&from, this);
  const ConsensusFrontierPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const ConsensusFrontierPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ConsensusFrontierPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ConsensusFrontierPB)
    MergeFrom(*source);
  }
}

void ConsensusFrontierPB::MergeFrom(const ConsensusFrontierPB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ConsensusFrontierPB)
  GOOGLE_DCHECK_NE(&from, this);
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = from._has_bits_[0];
  if (cached_has_bits & 31u) {
    if (cached_has_bits & 0x00000001u) {
      mutable_op_id()->::yb::OpIdPB::MergeFrom(from.op_id());
    }
    if (cached_has_bits & 0x00000002u) {
      hybrid_time_ = from.hybrid_time_;
    }
    if (cached_has_bits & 0x00000004u) {
      history_cutoff_ = from.history_cutoff_;
    }
    if (cached_has_bits & 0x00000008u) {
      hybrid_time_filter_ = from.hybrid_time_filter_;
    }
    if (cached_has_bits & 0x00000010u) {
      max_value_level_ttl_expiration_time_ = from.max_value_level_ttl_expiration_time_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

void ConsensusFrontierPB::CopyFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ConsensusFrontierPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

void ConsensusFrontierPB::CopyFrom(const ConsensusFrontierPB& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ConsensusFrontierPB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

bool ConsensusFrontierPB::IsInitialized() const {
  if (has_op_id()) {
    if (!this->op_id_->IsInitialized()) return false0;
  }
  return true;
}

void ConsensusFrontierPB::Swap(ConsensusFrontierPB* other) {
  if (other == this) return;
  InternalSwap(other);
}
void ConsensusFrontierPB::InternalSwap(ConsensusFrontierPB* other) {
  using std::swap;
  swap(op_id_, other->op_id_);
  swap(hybrid_time_, other->hybrid_time_);
  swap(history_cutoff_, other->history_cutoff_);
  swap(hybrid_time_filter_, other->hybrid_time_filter_);
  swap(max_value_level_ttl_expiration_time_, other->max_value_level_ttl_expiration_time_);
  swap(_has_bits_[0], other->_has_bits_[0]);
  _internal_metadata_.Swap(&other->_internal_metadata_);
  swap(_cached_size_, other->_cached_size_);
}

::google::protobuf::Metadata ConsensusFrontierPB::GetMetadata() const {
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
}


// ===================================================================

void ApplyTransactionStatePB::InitAsDefaultInstance() {
  ::yb::docdb::_ApplyTransactionStatePB_default_instance_._instance.get_mutable()->aborted_ = const_cast< ::yb::AbortedSubTransactionSetPB*>(
      ::yb::AbortedSubTransactionSetPB::internal_default_instance());
}
void ApplyTransactionStatePB::clear_aborted() {
  if (aborted_ != NULL) aborted_->Clear();
  clear_has_aborted();
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int ApplyTransactionStatePB::kKeyFieldNumber;
const int ApplyTransactionStatePB::kWriteIdFieldNumber;
const int ApplyTransactionStatePB::kCommitHtFieldNumber;
const int ApplyTransactionStatePB::kAbortedFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

ApplyTransactionStatePB::ApplyTransactionStatePB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyTransactionStatePB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.docdb.ApplyTransactionStatePB)
}
ApplyTransactionStatePB::ApplyTransactionStatePB(const ApplyTransactionStatePB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  if (from.has_key()) {
    key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
  }
  if (from.has_aborted()) {
    aborted_ = new ::yb::AbortedSubTransactionSetPB(*from.aborted_);
  } else {
    aborted_ = NULL;
  }
  ::memcpy(&commit_ht_, &from.commit_ht_,
    static_cast<size_t>(reinterpret_cast<char*>(&write_id_) -
    reinterpret_cast<char*>(&commit_ht_)) + sizeof(write_id_));
  // @@protoc_insertion_point(copy_constructor:yb.docdb.ApplyTransactionStatePB)
}

void ApplyTransactionStatePB::SharedCtor() {
  _cached_size_ = 0;
  key_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  ::memset(&aborted_, 0, static_cast<size_t>(
      reinterpret_cast<char*>(&write_id_) -
      reinterpret_cast<char*>(&aborted_)) + sizeof(write_id_));
}

ApplyTransactionStatePB::~ApplyTransactionStatePB() {
  // @@protoc_insertion_point(destructor:yb.docdb.ApplyTransactionStatePB)
  SharedDtor();
}

void ApplyTransactionStatePB::SharedDtor() {
  key_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());
  if (this != internal_default_instance()) delete aborted_;
}

void ApplyTransactionStatePB::SetCachedSize(int size) const {
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
}
const ::google::protobuf::Descriptor* ApplyTransactionStatePB::descriptor() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;
}

const ApplyTransactionStatePB& ApplyTransactionStatePB::default_instance() {
  ::protobuf_yb_2fdocdb_2fdocdb_2eproto::InitDefaultsApplyTransactionStatePB();
  return *internal_default_instance();
}

ApplyTransactionStatePB* ApplyTransactionStatePB::New(::google::protobuf::Arena* arena) const {
  ApplyTransactionStatePB* n = new ApplyTransactionStatePB;
  if (arena != NULL) {
    arena->Own(n);
  }
  return n;
}

void ApplyTransactionStatePB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.docdb.ApplyTransactionStatePB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  if (cached_has_bits & 3u) {
    if (cached_has_bits & 0x00000001u) {
      GOOGLE_DCHECK(!key_.IsDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited()));
      (*key_.UnsafeRawStringPointer())->clear();
    }
    if (cached_has_bits & 0x00000002u) {
      GOOGLE_DCHECK(aborted_ != NULL);
      aborted_->Clear();
    }
  }
  if (cached_has_bits & 12u) {
    ::memset(&commit_ht_, 0, static_cast<size_t>(
        reinterpret_cast<char*>(&write_id_) -
        reinterpret_cast<char*>(&commit_ht_)) + sizeof(write_id_));
  }
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool ApplyTransactionStatePB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.docdb.ApplyTransactionStatePB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // optional bytes key = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
                input, this->mutable_key()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional uint32 write_id = 2;
      case 2: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(16u /* 16 & 0xFF */)) {
          set_has_write_id();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
                 input, &write_id_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional fixed64 commit_ht = 3;
      case 3: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(25u /* 25 & 0xFF */)) {
          set_has_commit_ht();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint64, ::google::protobuf::internal::WireFormatLite::TYPE_FIXED64>(
                 input, &commit_ht_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.AbortedSubTransactionSetPB aborted = 4;
      case 4: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(34u /* 34 & 0xFF */)) {
          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(
               input, mutable_aborted()));
        } else {
          goto handle_unusual;
        }
        break;
      }

      default: {
      handle_unusual:
        if (tag == 0) {
          goto success;
        }
        DO_(::google::protobuf::internal::WireFormat::SkipField(
              input, tag, _internal_metadata_.mutable_unknown_fields()));
        break;
      }
    }
  }
success:
  // @@protoc_insertion_point(parse_success:yb.docdb.ApplyTransactionStatePB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.docdb.ApplyTransactionStatePB)
  return false;
#undef DO_
}

void ApplyTransactionStatePB::SerializeWithCachedSizes(
    ::google::protobuf::io::CodedOutputStream* output) const {
  // @@protoc_insertion_point(serialize_start:yb.docdb.ApplyTransactionStatePB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes key = 1;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(
      1, this->key(), output);
  }

  // optional uint32 write_id = 2;
  if (cached_has_bits & 0x00000008u) {
    ::google::protobuf::internal::WireFormatLite::WriteUInt32(2, this->write_id(), output);
  }

  // optional fixed64 commit_ht = 3;
  if (cached_has_bits & 0x00000004u) {
    ::google::protobuf::internal::WireFormatLite::WriteFixed64(3, this->commit_ht(), output);
  }

  // optional .yb.AbortedSubTransactionSetPB aborted = 4;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      4, *this->aborted_, output);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
        _internal_metadata_.unknown_fields(), output);
  }
  // @@protoc_insertion_point(serialize_end:yb.docdb.ApplyTransactionStatePB)
}

::google::protobuf::uint8* ApplyTransactionStatePB::InternalSerializeWithCachedSizesToArray(
    bool deterministic, ::google::protobuf::uint8* target) const {
  (void)deterministic; // Unused
  // @@protoc_insertion_point(serialize_to_array_start:yb.docdb.ApplyTransactionStatePB)
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];
  // optional bytes key = 1;
  if (cached_has_bits & 0x00000001u) {
    target =
      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
        1, this->key(), target);
  }

  // optional uint32 write_id = 2;
  if (cached_has_bits & 0x00000008u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(2, this->write_id(), target);
  }

  // optional fixed64 commit_ht = 3;
  if (cached_has_bits & 0x00000004u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteFixed64ToArray(3, this->commit_ht(), target);
  }

  // optional .yb.AbortedSubTransactionSetPB aborted = 4;
  if (cached_has_bits & 0x00000002u) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        4, *this->aborted_, deterministic, target);
  }

  if (_internal_metadata_.have_unknown_fields()) {
    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
        _internal_metadata_.unknown_fields(), target);
  }
  // @@protoc_insertion_point(serialize_to_array_end:yb.docdb.ApplyTransactionStatePB)
  return target;
}

size_t ApplyTransactionStatePB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.docdb.ApplyTransactionStatePB)
  size_t total_size = 0;

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  if (_has_bits_[0 / 32] & 15u) {
    // optional bytes key = 1;
    if (has_key()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::BytesSize(
          this->key());
    }

    // optional .yb.AbortedSubTransactionSetPB aborted = 4;
    if (has_aborted()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          *this->aborted_);
    }

    // optional fixed64 commit_ht = 3;
    if (has_commit_ht()) {
      total_size += 1 + 8;
    }

    // optional uint32 write_id = 2;
    if (has_write_id()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::UInt32Size(
          this->write_id());
    }

  }
  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);
  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
  _cached_size_ = cached_size;
  GOOGLE_SAFE_CONCURRENT_WRITES_END();
  return total_size;
}

void ApplyTransactionStatePB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.docdb.ApplyTransactionStatePB)
  GOOGLE_DCHECK_NE(&from, this);
  const ApplyTransactionStatePB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const ApplyTransactionStatePB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.docdb.ApplyTransactionStatePB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.docdb.ApplyTransactionStatePB)
    MergeFrom(*source);
  }
}

void ApplyTransactionStatePB::MergeFrom(const ApplyTransactionStatePB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.docdb.ApplyTransactionStatePB)
  GOOGLE_DCHECK_NE(&from, this);
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  ::google::protobuf::uint32 cached_has_bits = 0;
  (void) cached_has_bits;

  cached_has_bits = from._has_bits_[0];
  if (cached_has_bits & 15u) {
    if (cached_has_bits & 0x00000001u) {
      set_has_key();
      key_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.key_);
    }
    if (cached_has_bits & 0x00000002u) {
      mutable_aborted()->::yb::AbortedSubTransactionSetPB::MergeFrom(from.aborted());
    }
    if (cached_has_bits & 0x00000004u) {
      commit_ht_ = from.commit_ht_;
    }
    if (cached_has_bits & 0x00000008u) {
      write_id_ = from.write_id_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

void ApplyTransactionStatePB::CopyFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_copy_from_start:yb.docdb.ApplyTransactionStatePB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

void ApplyTransactionStatePB::CopyFrom(const ApplyTransactionStatePB& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:yb.docdb.ApplyTransactionStatePB)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}

bool ApplyTransactionStatePB::IsInitialized() const {
  return true;
}

void ApplyTransactionStatePB::Swap(ApplyTransactionStatePB* other) {
  if (other == this) return;
  InternalSwap(other);
}
void ApplyTransactionStatePB::InternalSwap(ApplyTransactionStatePB* other) {
  using std::swap;
  key_.Swap(&other->key_);
  swap(aborted_, other->aborted_);
  swap(commit_ht_, other->commit_ht_);
  swap(write_id_, other->write_id_);
  swap(_has_bits_[0], other->_has_bits_[0]);
  _internal_metadata_.Swap(&other->_internal_metadata_);
  swap(_cached_size_, other->_cached_size_);
}

::google::protobuf::Metadata ApplyTransactionStatePB::GetMetadata() const {
  protobuf_yb_2fdocdb_2fdocdb_2eproto::protobuf_AssignDescriptorsOnce();
  return ::protobuf_yb_2fdocdb_2fdocdb_2eproto::file_level_metadata[kIndexInFileMessages];
}


// @@protoc_insertion_point(namespace_scope)
}  // namespace docdb
}  // namespace yb

// @@protoc_insertion_point(global_scope)

YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

Coverage Report

Created: 2022-03-22 16:43