// Generated by the protocol buffer compiler. DO NOT EDIT! // source: message.proto #include "message.pb.h" #include #include "google/protobuf/io/coded_stream.h" #include "google/protobuf/extension_set.h" #include "google/protobuf/wire_format_lite.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" #include "google/protobuf/generated_message_tctable_impl.h" // @@protoc_insertion_point(includes) // Must be included last. #include "google/protobuf/port_def.inc" PROTOBUF_PRAGMA_INIT_SEG namespace _pb = ::google::protobuf; namespace _pbi = ::google::protobuf::internal; namespace _fl = ::google::protobuf::internal::field_layout; namespace messages { namespace header { inline constexpr Message::Impl_::Impl_( ::_pbi::ConstantInitialized) noexcept : _cached_size_{0}, senderuuid_( &::google::protobuf::internal::fixed_address_empty_string, ::_pbi::ConstantInitialized()), payload_{nullptr}, topic_{0u}, msgtype_{0u} {} template PROTOBUF_CONSTEXPR Message::Message(::_pbi::ConstantInitialized) : _impl_(::_pbi::ConstantInitialized()) {} struct MessageDefaultTypeInternal { PROTOBUF_CONSTEXPR MessageDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {} ~MessageDefaultTypeInternal() {} union { Message _instance; }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 MessageDefaultTypeInternal _Message_default_instance_; } // namespace header } // namespace messages static ::_pb::Metadata file_level_metadata_message_2eproto[1]; static constexpr const ::_pb::EnumDescriptor** file_level_enum_descriptors_message_2eproto = nullptr; static constexpr const ::_pb::ServiceDescriptor** file_level_service_descriptors_message_2eproto = nullptr; const ::uint32_t TableStruct_message_2eproto::offsets[] ABSL_ATTRIBUTE_SECTION_VARIABLE( protodesc_cold) = { PROTOBUF_FIELD_OFFSET(::messages::header::Message, _impl_._has_bits_), PROTOBUF_FIELD_OFFSET(::messages::header::Message, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ ~0u, // no _inlined_string_donated_ ~0u, // no _split_ ~0u, // no sizeof(Split) PROTOBUF_FIELD_OFFSET(::messages::header::Message, _impl_.topic_), PROTOBUF_FIELD_OFFSET(::messages::header::Message, _impl_.msgtype_), PROTOBUF_FIELD_OFFSET(::messages::header::Message, _impl_.senderuuid_), PROTOBUF_FIELD_OFFSET(::messages::header::Message, _impl_.payload_), ~0u, ~0u, ~0u, 0, }; static const ::_pbi::MigrationSchema schemas[] ABSL_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = { {0, 12, -1, sizeof(::messages::header::Message)}, }; static const ::_pb::Message* const file_default_instances[] = { &::messages::header::_Message_default_instance_._instance, }; const char descriptor_table_protodef_message_2eproto[] ABSL_ATTRIBUTE_SECTION_VARIABLE( protodesc_cold) = { "\n\rmessage.proto\022\017messages.header\032\031google" "/protobuf/any.proto\"d\n\007Message\022\r\n\005topic\030" "\001 \001(\r\022\017\n\007msgType\030\002 \001(\r\022\022\n\nsenderUUID\030\003 \001" "(\t\022%\n\007payload\030\005 \001(\0132\024.google.protobuf.An" "yb\006proto3" }; static const ::_pbi::DescriptorTable* const descriptor_table_message_2eproto_deps[1] = { &::descriptor_table_google_2fprotobuf_2fany_2eproto, }; static ::absl::once_flag descriptor_table_message_2eproto_once; const ::_pbi::DescriptorTable descriptor_table_message_2eproto = { false, false, 169, descriptor_table_protodef_message_2eproto, "message.proto", &descriptor_table_message_2eproto_once, descriptor_table_message_2eproto_deps, 1, 1, schemas, file_default_instances, TableStruct_message_2eproto::offsets, file_level_metadata_message_2eproto, file_level_enum_descriptors_message_2eproto, file_level_service_descriptors_message_2eproto, }; // This function exists to be marked as weak. // It can significantly speed up compilation by breaking up LLVM's SCC // in the .pb.cc translation units. Large translation units see a // reduction of more than 35% of walltime for optimized builds. Without // the weak attribute all the messages in the file, including all the // vtables and everything they use become part of the same SCC through // a cycle like: // GetMetadata -> descriptor table -> default instances -> // vtables -> GetMetadata // By adding a weak function here we break the connection from the // individual vtables back into the descriptor table. PROTOBUF_ATTRIBUTE_WEAK const ::_pbi::DescriptorTable* descriptor_table_message_2eproto_getter() { return &descriptor_table_message_2eproto; } // Force running AddDescriptors() at dynamic initialization time. PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_message_2eproto(&descriptor_table_message_2eproto); namespace messages { namespace header { // =================================================================== class Message::_Internal { public: using HasBits = decltype(std::declval()._impl_._has_bits_); static constexpr ::int32_t kHasBitsOffset = 8 * PROTOBUF_FIELD_OFFSET(Message, _impl_._has_bits_); static const ::google::protobuf::Any& payload(const Message* msg); static void set_has_payload(HasBits* has_bits) { (*has_bits)[0] |= 1u; } }; const ::google::protobuf::Any& Message::_Internal::payload(const Message* msg) { return *msg->_impl_.payload_; } void Message::clear_payload() { PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race); if (_impl_.payload_ != nullptr) _impl_.payload_->Clear(); _impl_._has_bits_[0] &= ~0x00000001u; } Message::Message(::google::protobuf::Arena* arena) : ::google::protobuf::Message(arena) { SharedCtor(arena); // @@protoc_insertion_point(arena_constructor:messages.header.Message) } inline PROTOBUF_NDEBUG_INLINE Message::Impl_::Impl_( ::google::protobuf::internal::InternalVisibility visibility, ::google::protobuf::Arena* arena, const Impl_& from) : _has_bits_{from._has_bits_}, _cached_size_{0}, senderuuid_(arena, from.senderuuid_) {} Message::Message( ::google::protobuf::Arena* arena, const Message& from) : ::google::protobuf::Message(arena) { Message* const _this = this; (void)_this; _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>( from._internal_metadata_); new (&_impl_) Impl_(internal_visibility(), arena, from._impl_); ::uint32_t cached_has_bits = _impl_._has_bits_[0]; _impl_.payload_ = (cached_has_bits & 0x00000001u) ? CreateMaybeMessage<::google::protobuf::Any>(arena, *from._impl_.payload_) : nullptr; ::memcpy(reinterpret_cast(&_impl_) + offsetof(Impl_, topic_), reinterpret_cast(&from._impl_) + offsetof(Impl_, topic_), offsetof(Impl_, msgtype_) - offsetof(Impl_, topic_) + sizeof(Impl_::msgtype_)); // @@protoc_insertion_point(copy_constructor:messages.header.Message) } inline PROTOBUF_NDEBUG_INLINE Message::Impl_::Impl_( ::google::protobuf::internal::InternalVisibility visibility, ::google::protobuf::Arena* arena) : _cached_size_{0}, senderuuid_(arena) {} inline void Message::SharedCtor(::_pb::Arena* arena) { new (&_impl_) Impl_(internal_visibility(), arena); ::memset(reinterpret_cast(&_impl_) + offsetof(Impl_, payload_), 0, offsetof(Impl_, msgtype_) - offsetof(Impl_, payload_) + sizeof(Impl_::msgtype_)); } Message::~Message() { // @@protoc_insertion_point(destructor:messages.header.Message) _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>(); SharedDtor(); } inline void Message::SharedDtor() { ABSL_DCHECK(GetArena() == nullptr); _impl_.senderuuid_.Destroy(); delete _impl_.payload_; _impl_.~Impl_(); } const ::google::protobuf::MessageLite::ClassData* Message::GetClassData() const { PROTOBUF_CONSTINIT static const ::google::protobuf::MessageLite::ClassData _data_ = { Message::MergeImpl, nullptr, // OnDemandRegisterArenaDtor &::google::protobuf::Message::kDescriptorMethods, PROTOBUF_FIELD_OFFSET(Message, _impl_._cached_size_), }; return &_data_; } PROTOBUF_NOINLINE void Message::Clear() { // @@protoc_insertion_point(message_clear_start:messages.header.Message) PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race); ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; _impl_.senderuuid_.ClearToEmpty(); cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { ABSL_DCHECK(_impl_.payload_ != nullptr); _impl_.payload_->Clear(); } ::memset(&_impl_.topic_, 0, static_cast<::size_t>( reinterpret_cast(&_impl_.msgtype_) - reinterpret_cast(&_impl_.topic_)) + sizeof(_impl_.msgtype_)); _impl_._has_bits_.Clear(); _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>(); } const char* Message::_InternalParse( const char* ptr, ::_pbi::ParseContext* ctx) { ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header); return ptr; } PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 const ::_pbi::TcParseTable<3, 4, 1, 42, 2> Message::_table_ = { { PROTOBUF_FIELD_OFFSET(Message, _impl_._has_bits_), 0, // no _extensions_ 5, 56, // max_field_number, fast_idx_mask offsetof(decltype(_table_), field_lookup_table), 4294967272, // skipmap offsetof(decltype(_table_), field_entries), 4, // num_field_entries 1, // num_aux_entries offsetof(decltype(_table_), aux_entries), &_Message_default_instance_._instance, ::_pbi::TcParser::GenericFallback, // fallback }, {{ {::_pbi::TcParser::MiniParse, {}}, // uint32 topic = 1; {::_pbi::TcParser::SingularVarintNoZag1<::uint32_t, offsetof(Message, _impl_.topic_), 63>(), {8, 63, 0, PROTOBUF_FIELD_OFFSET(Message, _impl_.topic_)}}, // uint32 msgType = 2; {::_pbi::TcParser::SingularVarintNoZag1<::uint32_t, offsetof(Message, _impl_.msgtype_), 63>(), {16, 63, 0, PROTOBUF_FIELD_OFFSET(Message, _impl_.msgtype_)}}, // string senderUUID = 3; {::_pbi::TcParser::FastUS1, {26, 63, 0, PROTOBUF_FIELD_OFFSET(Message, _impl_.senderuuid_)}}, {::_pbi::TcParser::MiniParse, {}}, // .google.protobuf.Any payload = 5; {::_pbi::TcParser::FastMtS1, {42, 0, 0, PROTOBUF_FIELD_OFFSET(Message, _impl_.payload_)}}, {::_pbi::TcParser::MiniParse, {}}, {::_pbi::TcParser::MiniParse, {}}, }}, {{ 65535, 65535 }}, {{ // uint32 topic = 1; {PROTOBUF_FIELD_OFFSET(Message, _impl_.topic_), -1, 0, (0 | ::_fl::kFcSingular | ::_fl::kUInt32)}, // uint32 msgType = 2; {PROTOBUF_FIELD_OFFSET(Message, _impl_.msgtype_), -1, 0, (0 | ::_fl::kFcSingular | ::_fl::kUInt32)}, // string senderUUID = 3; {PROTOBUF_FIELD_OFFSET(Message, _impl_.senderuuid_), -1, 0, (0 | ::_fl::kFcSingular | ::_fl::kUtf8String | ::_fl::kRepAString)}, // .google.protobuf.Any payload = 5; {PROTOBUF_FIELD_OFFSET(Message, _impl_.payload_), _Internal::kHasBitsOffset + 0, 0, (0 | ::_fl::kFcOptional | ::_fl::kMessage | ::_fl::kTvTable)}, }}, {{ {::_pbi::TcParser::GetTable<::google::protobuf::Any>()}, }}, {{ "\27\0\0\12\0\0\0\0" "messages.header.Message" "senderUUID" }}, }; ::uint8_t* Message::_InternalSerialize( ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const { // @@protoc_insertion_point(serialize_to_array_start:messages.header.Message) ::uint32_t cached_has_bits = 0; (void)cached_has_bits; // uint32 topic = 1; if (this->_internal_topic() != 0) { target = stream->EnsureSpace(target); target = ::_pbi::WireFormatLite::WriteUInt32ToArray( 1, this->_internal_topic(), target); } // uint32 msgType = 2; if (this->_internal_msgtype() != 0) { target = stream->EnsureSpace(target); target = ::_pbi::WireFormatLite::WriteUInt32ToArray( 2, this->_internal_msgtype(), target); } // string senderUUID = 3; if (!this->_internal_senderuuid().empty()) { const std::string& _s = this->_internal_senderuuid(); ::google::protobuf::internal::WireFormatLite::VerifyUtf8String( _s.data(), static_cast(_s.length()), ::google::protobuf::internal::WireFormatLite::SERIALIZE, "messages.header.Message.senderUUID"); target = stream->WriteStringMaybeAliased(3, _s, target); } cached_has_bits = _impl_._has_bits_[0]; // .google.protobuf.Any payload = 5; if (cached_has_bits & 0x00000001u) { target = ::google::protobuf::internal::WireFormatLite::InternalWriteMessage( 5, _Internal::payload(this), _Internal::payload(this).GetCachedSize(), target, stream); } if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream); } // @@protoc_insertion_point(serialize_to_array_end:messages.header.Message) return target; } ::size_t Message::ByteSizeLong() const { // @@protoc_insertion_point(message_byte_size_start:messages.header.Message) ::size_t total_size = 0; ::uint32_t cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; // string senderUUID = 3; if (!this->_internal_senderuuid().empty()) { total_size += 1 + ::google::protobuf::internal::WireFormatLite::StringSize( this->_internal_senderuuid()); } // .google.protobuf.Any payload = 5; cached_has_bits = _impl_._has_bits_[0]; if (cached_has_bits & 0x00000001u) { total_size += 1 + ::google::protobuf::internal::WireFormatLite::MessageSize(*_impl_.payload_); } // uint32 topic = 1; if (this->_internal_topic() != 0) { total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne( this->_internal_topic()); } // uint32 msgType = 2; if (this->_internal_msgtype() != 0) { total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne( this->_internal_msgtype()); } return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } void Message::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) { auto* const _this = static_cast(&to_msg); auto& from = static_cast(from_msg); // @@protoc_insertion_point(class_specific_merge_from_start:messages.header.Message) ABSL_DCHECK_NE(&from, _this); ::uint32_t cached_has_bits = 0; (void) cached_has_bits; if (!from._internal_senderuuid().empty()) { _this->_internal_set_senderuuid(from._internal_senderuuid()); } if ((from._impl_._has_bits_[0] & 0x00000001u) != 0) { _this->_internal_mutable_payload()->::google::protobuf::Any::MergeFrom( from._internal_payload()); } if (from._internal_topic() != 0) { _this->_internal_set_topic(from._internal_topic()); } if (from._internal_msgtype() != 0) { _this->_internal_set_msgtype(from._internal_msgtype()); } _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_); } void Message::CopyFrom(const Message& from) { // @@protoc_insertion_point(class_specific_copy_from_start:messages.header.Message) if (&from == this) return; Clear(); MergeFrom(from); } PROTOBUF_NOINLINE bool Message::IsInitialized() const { return true; } void Message::InternalSwap(Message* PROTOBUF_RESTRICT other) { using std::swap; auto* arena = GetArena(); ABSL_DCHECK_EQ(arena, other->GetArena()); _internal_metadata_.InternalSwap(&other->_internal_metadata_); swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]); ::_pbi::ArenaStringPtr::InternalSwap(&_impl_.senderuuid_, &other->_impl_.senderuuid_, arena); ::google::protobuf::internal::memswap< PROTOBUF_FIELD_OFFSET(Message, _impl_.msgtype_) + sizeof(Message::_impl_.msgtype_) - PROTOBUF_FIELD_OFFSET(Message, _impl_.payload_)>( reinterpret_cast(&_impl_.payload_), reinterpret_cast(&other->_impl_.payload_)); } ::google::protobuf::Metadata Message::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_message_2eproto_getter, &descriptor_table_message_2eproto_once, file_level_metadata_message_2eproto[0]); } // @@protoc_insertion_point(namespace_scope) } // namespace header } // namespace messages namespace google { namespace protobuf { } // namespace protobuf } // namespace google // @@protoc_insertion_point(global_scope) #include "google/protobuf/port_undef.inc"