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

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

#include "yb/common/transaction.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 {
class AbortedSubTransactionSetPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<AbortedSubTransactionSetPB>
      _instance;
} _AbortedSubTransactionSetPB_default_instance_;
class SubTransactionMetadataPBDefaultTypeInternal {
 public:
  ::google::protobuf::internal::ExplicitlyConstructed<SubTransactionMetadataPB>
      _instance;
} _SubTransactionMetadataPB_default_instance_;
}  // namespace yb
namespace protobuf_yb_2fcommon_2ftransaction_2eproto {
void InitDefaultsAbortedSubTransactionSetPBImpl() {
  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::_AbortedSubTransactionSetPB_default_instance_;
    new (ptr) ::yb::AbortedSubTransactionSetPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::AbortedSubTransactionSetPB::InitAsDefaultInstance();
}

void InitDefaultsAbortedSubTransactionSetPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsAbortedSubTransactionSetPBImpl);
}

void InitDefaultsSubTransactionMetadataPBImpl() {
  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::_SubTransactionMetadataPB_default_instance_;
    new (ptr) ::yb::SubTransactionMetadataPB();
    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);
  }
  ::yb::SubTransactionMetadataPB::InitAsDefaultInstance();
}

void InitDefaultsSubTransactionMetadataPB() {
  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);
  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsSubTransactionMetadataPBImpl);
}

::google::protobuf::Metadata file_level_metadata[2];
const ::google::protobuf::EnumDescriptor* file_level_enum_descriptors[4];

const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::AbortedSubTransactionSetPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::AbortedSubTransactionSetPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::AbortedSubTransactionSetPB, set_),
  ~0u,
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::SubTransactionMetadataPB, _has_bits_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::SubTransactionMetadataPB, _internal_metadata_),
  ~0u,  // no _extensions_
  ~0u,  // no _oneof_case_
  ~0u,  // no _weak_field_map_
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::SubTransactionMetadataPB, subtransaction_id_),
  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::SubTransactionMetadataPB, aborted_),
  1,
  0,
};
static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
  { 0, 6, sizeof(::yb::AbortedSubTransactionSetPB)},
  { 7, 14, sizeof(::yb::SubTransactionMetadataPB)},
};

static ::google::protobuf::Message const * const file_default_instances[] = {
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::_AbortedSubTransactionSetPB_default_instance_),
  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::_SubTransactionMetadataPB_default_instance_),
};

void protobuf_AssignDescriptors() {
  AddDescriptors();
  ::google::protobuf::MessageFactory* factory = NULL;
  AssignDescriptors(
      "yb/common/transaction.proto", schemas, file_default_instances, TableStruct::offsets, factory,
      file_level_metadata, file_level_enum_descriptors, 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, 2);
}

void AddDescriptorsImpl() {
  InitDefaults();
  static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {
      "\n\033yb/common/transaction.proto\022\002yb\")\n\032Abo"
      "rtedSubTransactionSetPB\022\013\n\003set\030\001 \003(\r\"f\n\030"
      "SubTransactionMetadataPB\022\031\n\021subtransacti"
      "on_id\030\001 \001(\r\022/\n\007aborted\030\002 \001(\0132\036.yb.Aborte"
      "dSubTransactionSetPB*o\n\016IsolationLevel\022\025"
      "\n\021NON_TRANSACTIONAL\020\000\022\026\n\022SNAPSHOT_ISOLAT"
      "ION\020\001\022\032\n\026SERIALIZABLE_ISOLATION\020\002\022\022\n\016REA"
      "D_COMMITTED\020\003*\335\001\n\021TransactionStatus\022\013\n\007C"
      "REATED\020\001\022\013\n\007PENDING\020\002\022\r\n\tCOMMITTED\020\004\022\n\n\006"
      "SEALED\020\005\022#\n\037APPLIED_IN_ALL_INVOLVED_TABL"
      "ETS\020\007\022\013\n\007ABORTED\020\010\022\014\n\010APPLYING\020\024\022&\n\"APPL"
      "IED_IN_ONE_OF_INVOLVED_TABLETS\020\025\022\025\n\021IMME"
      "DIATE_CLEANUP\020\026\022\024\n\020GRACEFUL_CLEANUP\020\027*,\n"
      "\023TransactionLocality\022\n\n\006GLOBAL\020\001\022\t\n\005LOCA"
      "L\020\002*\255\001\n\013RowMarkType\022\026\n\022ROW_MARK_EXCLUSIV"
      "E\020\000\022\033\n\027ROW_MARK_NOKEYEXCLUSIVE\020\001\022\022\n\016ROW_"
      "MARK_SHARE\020\002\022\025\n\021ROW_MARK_KEYSHARE\020\003\022\026\n\022R"
      "OW_MARK_REFERENCE\020\004\022\021\n\rROW_MARK_COPY\020\005\022\023"
      "\n\017ROW_MARK_ABSENT\020\017B\010\n\006org.yb"
  };
  ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(
      descriptor, 749);
  ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
    "yb/common/transaction.proto", &protobuf_RegisterTypes);
}

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_2fcommon_2ftransaction_2eproto
namespace yb {
const ::google::protobuf::EnumDescriptor* IsolationLevel_descriptor() {
  protobuf_yb_2fcommon_2ftransaction_2eproto::protobuf_AssignDescriptorsOnce();
  return protobuf_yb_2fcommon_2ftransaction_2eproto::file_level_enum_descriptors[0];
}
bool IsolationLevel_IsValid(int value) {
  switch (value) {
    case 0:
    case 1:
    case 2:
    case 3:
      return true;
    default:
      return false;
  }
}

const ::google::protobuf::EnumDescriptor* TransactionStatus_descriptor() {
  protobuf_yb_2fcommon_2ftransaction_2eproto::protobuf_AssignDescriptorsOnce();
  return protobuf_yb_2fcommon_2ftransaction_2eproto::file_level_enum_descriptors[1];
}
bool TransactionStatus_IsValid(int value) {
  switch (value) {
    case 1:
    case 2:
    case 4:
    case 5:
    case 7:
    case 8:
    case 20:
    case 21:
    case 22:
    case 23:
      return true;
    default:
      return false;
  }
}

const ::google::protobuf::EnumDescriptor* TransactionLocality_descriptor() {
  protobuf_yb_2fcommon_2ftransaction_2eproto::protobuf_AssignDescriptorsOnce();
  return protobuf_yb_2fcommon_2ftransaction_2eproto::file_level_enum_descriptors[2];
}
bool TransactionLocality_IsValid(int value) {
  switch (value) {
    case 1:
    case 2:
      return true;
    default:
      return false;
  }
}

const ::google::protobuf::EnumDescriptor* RowMarkType_descriptor() {
  protobuf_yb_2fcommon_2ftransaction_2eproto::protobuf_AssignDescriptorsOnce();
  return protobuf_yb_2fcommon_2ftransaction_2eproto::file_level_enum_descriptors[3];
}
bool RowMarkType_IsValid(int value) {
  switch (value) {
    case 0:
    case 1:
    case 2:
    case 3:
    case 4:
    case 5:
    case 15:
      return true;
    default:
      return false;
  }
}


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

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

AbortedSubTransactionSetPB::AbortedSubTransactionSetPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsAbortedSubTransactionSetPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.AbortedSubTransactionSetPB)
}
AbortedSubTransactionSetPB::AbortedSubTransactionSetPB(const AbortedSubTransactionSetPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0),
      set_(from.set_) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:yb.AbortedSubTransactionSetPB)
}

void AbortedSubTransactionSetPB::SharedCtor() {
  _cached_size_ = 0;
}

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

void AbortedSubTransactionSetPB::SharedDtor() {
}

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

const AbortedSubTransactionSetPB& AbortedSubTransactionSetPB::default_instance() {
  ::protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsAbortedSubTransactionSetPB();
  return *internal_default_instance();
}

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

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

  set_.Clear();
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool AbortedSubTransactionSetPB::MergePartialFromCodedStream(
    ::google::protobuf::io::CodedInputStream* input) {
#define DO_(EXPRESSION) if (44.4k!GOOGLE_PREDICT_TRUE44.4k(EXPRESSION)) goto failure0
  ::google::protobuf::uint32 tag;
  // @@protoc_insertion_point(parse_start:yb.AbortedSubTransactionSetPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual1.41M;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // repeated uint32 set = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) {
          DO_((::google::protobuf::internal::WireFormatLite::ReadRepeatedPrimitive<
                   ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
                 1, 8u, input, this->mutable_set())));
        } else if (
            static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {
          DO_((::google::protobuf::internal::WireFormatLite::ReadPackedPrimitiveNoInline<
                   ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
                 input, this->mutable_set())));
        } else {
          goto handle_unusual;
        }
        break;
      }

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

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

  // repeated uint32 set = 1;
  for (int i = 0, n = this->set_size(); i < n; i++) {
    ::google::protobuf::internal::WireFormatLite::WriteUInt32(
      1, this->set(i), output);
  }

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

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

  // repeated uint32 set = 1;
  target = ::google::protobuf::internal::WireFormatLite::
    WriteUInt32ToArray(1, this->set_, 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.AbortedSubTransactionSetPB)
  return target;
}

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

  if (_internal_metadata_.have_unknown_fields()) {
    total_size +=
      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
        _internal_metadata_.unknown_fields());
  }
  // repeated uint32 set = 1;
  {
    size_t data_size = ::google::protobuf::internal::WireFormatLite::
      UInt32Size(this->set_);
    total_size += 1 *
                  ::google::protobuf::internal::FromIntSize(this->set_size());
    total_size += data_size;
  }

  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 AbortedSubTransactionSetPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.AbortedSubTransactionSetPB)
  GOOGLE_DCHECK_NE(&from, this);
  const AbortedSubTransactionSetPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const AbortedSubTransactionSetPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.AbortedSubTransactionSetPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.AbortedSubTransactionSetPB)
    MergeFrom(*source);
  }
}

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

  set_.MergeFrom(from.set_);
}

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

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

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

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

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


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

void SubTransactionMetadataPB::InitAsDefaultInstance() {
  ::yb::_SubTransactionMetadataPB_default_instance_._instance.get_mutable()->aborted_ = const_cast< ::yb::AbortedSubTransactionSetPB*>(
      ::yb::AbortedSubTransactionSetPB::internal_default_instance());
}
#if !defined(_MSC_VER) || _MSC_VER >= 1900
const int SubTransactionMetadataPB::kSubtransactionIdFieldNumber;
const int SubTransactionMetadataPB::kAbortedFieldNumber;
#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

SubTransactionMetadataPB::SubTransactionMetadataPB()
  : ::google::protobuf::Message(), _internal_metadata_(NULL) {
  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {
    ::protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsSubTransactionMetadataPB();
  }
  SharedCtor();
  // @@protoc_insertion_point(constructor:yb.SubTransactionMetadataPB)
}
SubTransactionMetadataPB::SubTransactionMetadataPB(const SubTransactionMetadataPB& from)
  : ::google::protobuf::Message(),
      _internal_metadata_(NULL),
      _has_bits_(from._has_bits_),
      _cached_size_(0) {
  _internal_metadata_.MergeFrom(from._internal_metadata_);
  if (from.has_aborted()) {
    aborted_ = new ::yb::AbortedSubTransactionSetPB(*from.aborted_);
  } else {
    aborted_ = NULL;
  }
  subtransaction_id_ = from.subtransaction_id_;
  // @@protoc_insertion_point(copy_constructor:yb.SubTransactionMetadataPB)
}

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

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

void SubTransactionMetadataPB::SharedDtor() {
  if (this != internal_default_instance()) delete aborted_109k;
}

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

const SubTransactionMetadataPB& SubTransactionMetadataPB::default_instance() {
  ::protobuf_yb_2fcommon_2ftransaction_2eproto::InitDefaultsSubTransactionMetadataPB();
  return *internal_default_instance();
}

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

void SubTransactionMetadataPB::Clear() {
// @@protoc_insertion_point(message_clear_start:yb.SubTransactionMetadataPB)
  ::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(aborted_ != NULL);
    aborted_->Clear();
  }
  subtransaction_id_ = 0u;
  _has_bits_.Clear();
  _internal_metadata_.Clear();
}

bool SubTransactionMetadataPB::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.SubTransactionMetadataPB)
  for (;;) {
    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);
    tag = p.first;
    if (!p.second) goto handle_unusual43.5k;
    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
      // optional uint32 subtransaction_id = 1;
      case 1: {
        if (static_cast< ::google::protobuf::uint8>(tag) ==
            static_cast< ::google::protobuf::uint8>(8u /* 8 & 0xFF */)) {
          set_has_subtransaction_id();
          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
                   ::google::protobuf::uint32, ::google::protobuf::internal::WireFormatLite::TYPE_UINT32>(
                 input, &subtransaction_id_)));
        } else {
          goto handle_unusual;
        }
        break;
      }

      // optional .yb.AbortedSubTransactionSetPB aborted = 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_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.SubTransactionMetadataPB)
  return true;
failure:
  // @@protoc_insertion_point(parse_failure:yb.SubTransactionMetadataPB)
  return false;
#undef DO_
}

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

  cached_has_bits = _has_bits_[0];
  // optional uint32 subtransaction_id = 1;
  if (cached_has_bits & 0x00000002u) {
    ::google::protobuf::internal::WireFormatLite::WriteUInt32(1, this->subtransaction_id(), output);
  }

  // optional .yb.AbortedSubTransactionSetPB aborted = 2;
  if (cached_has_bits & 0x00000001u) {
    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(
      2, *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.SubTransactionMetadataPB)
}

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

  cached_has_bits = _has_bits_[0];
  // optional uint32 subtransaction_id = 1;
  if (cached_has_bits & 0x00000002u) {
    target = ::google::protobuf::internal::WireFormatLite::WriteUInt32ToArray(1, this->subtransaction_id(), target);
  }

  // optional .yb.AbortedSubTransactionSetPB aborted = 2;
  if (cached_has_bits & 0x00000001u) {
    target = ::google::protobuf::internal::WireFormatLite::
      InternalWriteMessageToArray(
        2, *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.SubTransactionMetadataPB)
  return target;
}

size_t SubTransactionMetadataPB::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:yb.SubTransactionMetadataPB)
  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 .yb.AbortedSubTransactionSetPB aborted = 2;
    if (has_aborted()) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::MessageSize(
          *this->aborted_);
    }

    // optional uint32 subtransaction_id = 1;
    if (has_subtransaction_id()111k) {
      total_size += 1 +
        ::google::protobuf::internal::WireFormatLite::UInt32Size(
          this->subtransaction_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 SubTransactionMetadataPB::MergeFrom(const ::google::protobuf::Message& from) {
// @@protoc_insertion_point(generalized_merge_from_start:yb.SubTransactionMetadataPB)
  GOOGLE_DCHECK_NE(&from, this);
  const SubTransactionMetadataPB* source =
      ::google::protobuf::internal::DynamicCastToGenerated<const SubTransactionMetadataPB>(
          &from);
  if (source == NULL) {
  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.SubTransactionMetadataPB)
    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
  } else {
  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.SubTransactionMetadataPB)
    MergeFrom(*source);
  }
}

void SubTransactionMetadataPB::MergeFrom(const SubTransactionMetadataPB& from) {
// @@protoc_insertion_point(class_specific_merge_from_start:yb.SubTransactionMetadataPB)
  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) {
      mutable_aborted()->::yb::AbortedSubTransactionSetPB::MergeFrom(from.aborted());
    }
    if (cached_has_bits & 0x00000002u) {
      subtransaction_id_ = from.subtransaction_id_;
    }
    _has_bits_[0] |= cached_has_bits;
  }
}

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

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

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

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

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


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

// @@protoc_insertion_point(global_scope)

YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

Coverage Report

Created: 2022-03-22 16:43