4#ifndef GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fDFOModule_2eproto_2epb_2eh
5#define GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fDFOModule_2eproto_2epb_2eh
11#include "google/protobuf/port_def.inc"
12#if PROTOBUF_VERSION < 4024000
13#error "This file was generated by a newer version of protoc which is"
14#error "incompatible with your Protocol Buffer headers. Please update"
18#if 4024004 < PROTOBUF_MIN_PROTOC_VERSION
19#error "This file was generated by an older version of protoc which is"
20#error "incompatible with your Protocol Buffer headers. Please"
21#error "regenerate this file with a newer version of protoc."
23#include "google/protobuf/port_undef.inc"
24#include "google/protobuf/io/coded_stream.h"
25#include "google/protobuf/arena.h"
26#include "google/protobuf/arenastring.h"
27#include "google/protobuf/generated_message_tctable_decl.h"
28#include "google/protobuf/generated_message_util.h"
29#include "google/protobuf/metadata_lite.h"
30#include "google/protobuf/generated_message_reflection.h"
31#include "google/protobuf/message.h"
32#include "google/protobuf/repeated_field.h"
33#include "google/protobuf/extension_set.h"
34#include "google/protobuf/unknown_field_set.h"
38#include "google/protobuf/port_def.inc"
40#define PROTOBUF_INTERNAL_EXPORT_dfmodules_2fopmon_2fDFOModule_2eproto
54extern const ::google::protobuf::internal::DescriptorTable
60struct DFOInfoDefaultTypeInternal;
63struct TriggerInfoDefaultTypeInternal;
83 public ::google::protobuf::Message {
87 template<
typename =
void>
88 explicit PROTOBUF_CONSTEXPR
DFOInfo(::google::protobuf::internal::ConstantInitialized);
93 *
this = ::std::move(from);
101 if (
this == &from)
return *
this;
102 if (GetOwningArena() == from.GetOwningArena()
103 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
104 && GetOwningArena() !=
nullptr
115 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
118 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
134 return reinterpret_cast<const DFOInfo*
>(
144 if (other ==
this)
return;
145 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
146 if (GetOwningArena() !=
nullptr &&
147 GetOwningArena() == other->GetOwningArena()) {
149 if (GetOwningArena() == other->GetOwningArena()) {
153 ::google::protobuf::internal::GenericSwap(
this, other);
157 if (other ==
this)
return;
158 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
164 DFOInfo*
New(::google::protobuf::Arena* arena =
nullptr) const final {
165 return CreateMaybeMessage<DFOInfo>(arena);
167 using ::google::protobuf::Message::CopyFrom;
169 using ::google::protobuf::Message::MergeFrom;
174 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
176 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
180 const
char*
_InternalParse(const
char* ptr, ::
google::protobuf::internal::ParseContext* ctx) final;
182 ::uint8_t* target, ::
google::protobuf::io::EpsCopyOutputStream* stream) const final;
186 void SharedCtor(::google::protobuf::Arena* arena);
192 friend class ::google::protobuf::internal::AnyMetadata;
194 return "dunedaq.dfmodules.opmon.DFOInfo";
197 explicit DFOInfo(::google::protobuf::Arena* arena);
201 const ::google::protobuf::Message::ClassData*
GetClassData() const final;
303 friend class ::google::protobuf::internal::TcParser;
304 static const ::google::protobuf::internal::TcParseTable<4, 8, 0, 0, 2>
_table_;
305 template <
typename T>
friend class ::google::protobuf::Arena::InternalHelper;
318 PROTOBUF_TSAN_DECLARE_MEMBER
321 friend struct ::TableStruct_dfmodules_2fopmon_2fDFOModule_2eproto;
325 public ::google::protobuf::Message {
329 template<
typename =
void>
330 explicit PROTOBUF_CONSTEXPR
TriggerInfo(::google::protobuf::internal::ConstantInitialized);
335 *
this = ::std::move(from);
343 if (
this == &from)
return *
this;
344 if (GetOwningArena() == from.GetOwningArena()
345 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
346 && GetOwningArena() !=
nullptr
357 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
360 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
386 if (other ==
this)
return;
387 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
388 if (GetOwningArena() !=
nullptr &&
389 GetOwningArena() == other->GetOwningArena()) {
391 if (GetOwningArena() == other->GetOwningArena()) {
395 ::google::protobuf::internal::GenericSwap(
this, other);
399 if (other ==
this)
return;
400 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
407 return CreateMaybeMessage<TriggerInfo>(arena);
409 using ::google::protobuf::Message::CopyFrom;
411 using ::google::protobuf::Message::MergeFrom;
416 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
418 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
419 bool IsInitialized() const final;
421 ::
size_t ByteSizeLong() const final;
424 ::uint8_t* target, ::
google::protobuf::io::EpsCopyOutputStream* stream) const final;
434 friend class ::google::protobuf::internal::AnyMetadata;
436 return "dunedaq.dfmodules.opmon.TriggerInfo";
439 explicit TriggerInfo(::google::protobuf::Arena* arena);
443 const ::google::protobuf::Message::ClassData*
GetClassData() const final;
456 void clear_received() ;
457 ::uint64_t received()
const;
458 void set_received(::uint64_t value);
461 ::uint64_t _internal_received()
const;
462 void _internal_set_received(::uint64_t value);
466 void clear_completed() ;
467 ::uint64_t completed()
const;
468 void set_completed(::uint64_t value);
471 ::uint64_t _internal_completed()
const;
472 void _internal_set_completed(::uint64_t value);
479 friend class ::google::protobuf::internal::TcParser;
480 static const ::google::protobuf::internal::TcParseTable<1, 2, 0, 0, 2>
_table_;
481 template <
typename T>
friend class ::google::protobuf::Arena::InternalHelper;
488 PROTOBUF_TSAN_DECLARE_MEMBER
491 friend struct ::TableStruct_dfmodules_2fopmon_2fDFOModule_2eproto;
503#pragma GCC diagnostic push
504#pragma GCC diagnostic ignored "-Wstrict-aliasing"
512 _impl_.tokens_received_ = ::uint64_t{0u};
523 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
524 return _impl_.tokens_received_;
527 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
529 _impl_.tokens_received_ = value;
534 _impl_.decisions_received_ = ::uint64_t{0u};
545 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
546 return _impl_.decisions_received_;
549 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
551 _impl_.decisions_received_ = value;
556 _impl_.decisions_sent_ = ::uint64_t{0u};
567 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
568 return _impl_.decisions_sent_;
571 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
573 _impl_.decisions_sent_ = value;
578 _impl_.waiting_for_decision_ = ::uint64_t{0u};
589 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
590 return _impl_.waiting_for_decision_;
593 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
595 _impl_.waiting_for_decision_ = value;
600 _impl_.deciding_destination_ = ::uint64_t{0u};
611 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
612 return _impl_.deciding_destination_;
615 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
617 _impl_.deciding_destination_ = value;
622 _impl_.forwarding_decision_ = ::uint64_t{0u};
633 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
634 return _impl_.forwarding_decision_;
637 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
639 _impl_.forwarding_decision_ = value;
644 _impl_.waiting_for_token_ = ::uint64_t{0u};
655 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
656 return _impl_.waiting_for_token_;
659 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
661 _impl_.waiting_for_token_ = value;
666 _impl_.processing_token_ = ::uint64_t{0u};
677 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
678 return _impl_.processing_token_;
681 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
683 _impl_.processing_token_ = value;
692 _impl_.received_ = ::uint64_t{0u};
703 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
707 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
714 _impl_.completed_ = ::uint64_t{0u};
725 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
729 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
731 _impl_.completed_ = value;
735#pragma GCC diagnostic pop
746#include "google/protobuf/port_undef.inc"
const ::_pbi::DescriptorTable descriptor_table_dfmodules_2fopmon_2fDFOModule_2eproto
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
void UnsafeArenaSwap(DFOInfo *other)
::uint64_t forwarding_decision() const
void _internal_set_decisions_received(::uint64_t value)
void clear_waiting_for_decision()
void clear_tokens_received()
::uint64_t _internal_tokens_received() const
void set_waiting_for_token(::uint64_t value)
void set_deciding_destination(::uint64_t value)
const ::google::protobuf::Message::ClassData * GetClassData() const final
void _internal_set_waiting_for_decision(::uint64_t value)
void set_forwarding_decision(::uint64_t value)
static const ::google::protobuf::internal::TcParseTable< 4, 8, 0, 0, 2 > _table_
::uint64_t decisions_received() const
void set_decisions_sent(::uint64_t value)
::uint64_t _internal_decisions_sent() const
void _internal_set_waiting_for_token(::uint64_t value)
void InternalSwap(DFOInfo *other)
::uint64_t deciding_destination() const
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
void InternalArenaConstructable_
DFOInfo * New(::google::protobuf::Arena *arena=nullptr) const final
void Swap(DFOInfo *other)
friend void swap(DFOInfo &a, DFOInfo &b)
void _internal_set_processing_token(::uint64_t value)
::uint64_t decisions_sent() const
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
::uint64_t processing_token() const
void _internal_set_decisions_sent(::uint64_t value)
::uint64_t _internal_waiting_for_token() const
bool IsInitialized() const final
PROTOBUF_CONSTEXPR DFOInfo(::google::protobuf::internal::ConstantInitialized)
void set_processing_token(::uint64_t value)
DFOInfo & operator=(const DFOInfo &from)
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
void clear_processing_token()
void MergeFrom(const DFOInfo &from)
static const ::google::protobuf::Reflection * GetReflection()
DFOInfo(DFOInfo &&from) noexcept
::uint64_t waiting_for_token() const
::uint64_t _internal_forwarding_decision() const
static const ::google::protobuf::Descriptor * descriptor()
void SharedCtor(::google::protobuf::Arena *arena)
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
static constexpr int kIndexInFileMessages
::size_t ByteSizeLong() const final
static const DFOInfo & default_instance()
void _internal_set_tokens_received(::uint64_t value)
static const ClassData _class_data_
void _internal_set_deciding_destination(::uint64_t value)
@ kWaitingForDecisionFieldNumber
@ kWaitingForTokenFieldNumber
@ kDecisionsReceivedFieldNumber
@ kProcessingTokenFieldNumber
@ kDecisionsSentFieldNumber
@ kTokensReceivedFieldNumber
@ kForwardingDecisionFieldNumber
@ kDecidingDestinationFieldNumber
void clear_deciding_destination()
::uint64_t _internal_deciding_destination() const
void _internal_set_forwarding_decision(::uint64_t value)
::uint64_t _internal_processing_token() const
::uint64_t _internal_waiting_for_decision() const
void clear_decisions_received()
::google::protobuf::Metadata GetMetadata() const final
void clear_decisions_sent()
static const DFOInfo * internal_default_instance()
void SetCachedSize(int size) const final
void set_decisions_received(::uint64_t value)
::uint64_t tokens_received() const
int GetCachedSize() const final
DFOInfo & operator=(DFOInfo &&from) noexcept
::uint64_t _internal_decisions_received() const
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
void DestructorSkippable_
::absl::string_view FullMessageName()
void clear_waiting_for_token()
void CopyFrom(const DFOInfo &from)
void set_waiting_for_decision(::uint64_t value)
void clear_forwarding_decision()
::uint64_t waiting_for_decision() const
void set_tokens_received(::uint64_t value)
static const ::google::protobuf::Descriptor * GetDescriptor()
static const TriggerInfo * internal_default_instance()
static const ::google::protobuf::Descriptor * descriptor()
void set_completed(::uint64_t value)
TriggerInfo & operator=(TriggerInfo &&from) noexcept
void UnsafeArenaSwap(TriggerInfo *other)
TriggerInfo * New(::google::protobuf::Arena *arena=nullptr) const final
PROTOBUF_CONSTEXPR TriggerInfo(::google::protobuf::internal::ConstantInitialized)
void _internal_set_completed(::uint64_t value)
::google::protobuf::Metadata GetMetadata() const final
TriggerInfo & operator=(const TriggerInfo &from)
void SharedCtor(::google::protobuf::Arena *arena)
::uint64_t completed() const
const ::google::protobuf::Message::ClassData * GetClassData() const final
void _internal_set_received(::uint64_t value)
TriggerInfo(TriggerInfo &&from) noexcept
::absl::string_view FullMessageName()
::uint64_t received() const
void set_received(::uint64_t value)
static const ::google::protobuf::Descriptor * GetDescriptor()
static const ClassData _class_data_
void DestructorSkippable_
static const ::google::protobuf::Reflection * GetReflection()
void CopyFrom(const TriggerInfo &from)
static const TriggerInfo & default_instance()
::uint64_t _internal_received() const
static const ::google::protobuf::internal::TcParseTable< 1, 2, 0, 0, 2 > _table_
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
void InternalArenaConstructable_
void MergeFrom(const TriggerInfo &from)
friend void swap(TriggerInfo &a, TriggerInfo &b)
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
void InternalSwap(TriggerInfo *other)
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
void Swap(TriggerInfo *other)
void SetCachedSize(int size) const final
int GetCachedSize() const final
::uint64_t _internal_completed() const
static constexpr int kIndexInFileMessages
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TriggerInfoDefaultTypeInternal _TriggerInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DFOInfoDefaultTypeInternal _DFOInfo_default_instance_
An ERS Issue for DataStore creation failure.
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
static const ::uint32_t offsets[]
::uint64_t processing_token_
::uint64_t forwarding_decision_
::uint64_t deciding_destination_
mutable::google::protobuf::internal::CachedSize _cached_size_
::uint64_t decisions_sent_
::uint64_t tokens_received_
::uint64_t waiting_for_token_
::uint64_t waiting_for_decision_
::uint64_t decisions_received_
mutable::google::protobuf::internal::CachedSize _cached_size_