DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
dunedaq::datahandlinglibs::opmon::DataHandlerInfo Class Referencefinal

#include <datahandling_info.pb.h>

Inheritance diagram for dunedaq::datahandlinglibs::opmon::DataHandlerInfo:
[legend]
Collaboration diagram for dunedaq::datahandlinglibs::opmon::DataHandlerInfo:
[legend]

Classes

class  _Internal
 
struct  Impl_
 

Public Types

enum  : int {
  kSumPayloadsFieldNumber = 1 , kNumPayloadsFieldNumber = 2 , kNumDataInputTimeoutsFieldNumber = 3 , kRatePayloadsConsumedFieldNumber = 4 ,
  kNumLbInsertFailuresFieldNumber = 5 , kSumRequestsFieldNumber = 11 , kNumRequestsFieldNumber = 12 , kLastDaqTimestampFieldNumber = 21 ,
  kNewestTimestampFieldNumber = 22 , kOldestTimestampFieldNumber = 23 , kNumPostProcessingDelayMaxWaitsFieldNumber = 31
}
 

Public Member Functions

 DataHandlerInfo ()
 
 ~DataHandlerInfo () override
 
template<typename = void>
PROTOBUF_CONSTEXPR DataHandlerInfo (::google::protobuf::internal::ConstantInitialized)
 
 DataHandlerInfo (const DataHandlerInfo &from)
 
 DataHandlerInfo (DataHandlerInfo &&from) noexcept
 
DataHandlerInfooperator= (const DataHandlerInfo &from)
 
DataHandlerInfooperator= (DataHandlerInfo &&from) noexcept
 
const ::google::protobuf::UnknownFieldSet & unknown_fields () const
 
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields ()
 
void Swap (DataHandlerInfo *other)
 
void UnsafeArenaSwap (DataHandlerInfo *other)
 
DataHandlerInfoNew (::google::protobuf::Arena *arena=nullptr) const final
 
void CopyFrom (const DataHandlerInfo &from)
 
void MergeFrom (const DataHandlerInfo &from)
 
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear () final
 
bool IsInitialized () const final
 
::size_t ByteSizeLong () const final
 
const char * _InternalParse (const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
 
::uint8_t * _InternalSerialize (::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
 
int GetCachedSize () const final
 
const ::google::protobuf::Message::ClassData * GetClassData () const final
 
::google::protobuf::Metadata GetMetadata () const final
 
void clear_sum_payloads ()
 
::uint64_t sum_payloads () const
 
void set_sum_payloads (::uint64_t value)
 
void clear_num_payloads ()
 
::uint64_t num_payloads () const
 
void set_num_payloads (::uint64_t value)
 
void clear_num_data_input_timeouts ()
 
::uint64_t num_data_input_timeouts () const
 
void set_num_data_input_timeouts (::uint64_t value)
 
void clear_rate_payloads_consumed ()
 
double rate_payloads_consumed () const
 
void set_rate_payloads_consumed (double value)
 
void clear_num_lb_insert_failures ()
 
::uint64_t num_lb_insert_failures () const
 
void set_num_lb_insert_failures (::uint64_t value)
 
void clear_sum_requests ()
 
::uint64_t sum_requests () const
 
void set_sum_requests (::uint64_t value)
 
void clear_num_requests ()
 
::uint64_t num_requests () const
 
void set_num_requests (::uint64_t value)
 
void clear_last_daq_timestamp ()
 
::uint64_t last_daq_timestamp () const
 
void set_last_daq_timestamp (::uint64_t value)
 
void clear_newest_timestamp ()
 
::uint64_t newest_timestamp () const
 
void set_newest_timestamp (::uint64_t value)
 
void clear_oldest_timestamp ()
 
::uint64_t oldest_timestamp () const
 
void set_oldest_timestamp (::uint64_t value)
 
void clear_num_post_processing_delay_max_waits ()
 
::uint64_t num_post_processing_delay_max_waits () const
 
void set_num_post_processing_delay_max_waits (::uint64_t value)
 
template<typename >
PROTOBUF_CONSTEXPR DataHandlerInfo (::_pbi::ConstantInitialized)
 

Static Public Member Functions

static const ::google::protobuf::Descriptor * descriptor ()
 
static const ::google::protobuf::Descriptor * GetDescriptor ()
 
static const ::google::protobuf::Reflection * GetReflection ()
 
static const DataHandlerInfodefault_instance ()
 
static const DataHandlerInfointernal_default_instance ()
 

Static Public Attributes

static constexpr int kIndexInFileMessages
 
static const ClassData _class_data_
 

Protected Member Functions

 DataHandlerInfo (::google::protobuf::Arena *arena)
 

Private Types

typedef void InternalArenaConstructable_
 
typedef void DestructorSkippable_
 

Private Member Functions

void SharedCtor (::google::protobuf::Arena *arena)
 
void SharedDtor ()
 
void SetCachedSize (int size) const final
 
void InternalSwap (DataHandlerInfo *other)
 
::uint64_t _internal_sum_payloads () const
 
void _internal_set_sum_payloads (::uint64_t value)
 
::uint64_t _internal_num_payloads () const
 
void _internal_set_num_payloads (::uint64_t value)
 
::uint64_t _internal_num_data_input_timeouts () const
 
void _internal_set_num_data_input_timeouts (::uint64_t value)
 
double _internal_rate_payloads_consumed () const
 
void _internal_set_rate_payloads_consumed (double value)
 
::uint64_t _internal_num_lb_insert_failures () const
 
void _internal_set_num_lb_insert_failures (::uint64_t value)
 
::uint64_t _internal_sum_requests () const
 
void _internal_set_sum_requests (::uint64_t value)
 
::uint64_t _internal_num_requests () const
 
void _internal_set_num_requests (::uint64_t value)
 
::uint64_t _internal_last_daq_timestamp () const
 
void _internal_set_last_daq_timestamp (::uint64_t value)
 
::uint64_t _internal_newest_timestamp () const
 
void _internal_set_newest_timestamp (::uint64_t value)
 
::uint64_t _internal_oldest_timestamp () const
 
void _internal_set_oldest_timestamp (::uint64_t value)
 
::uint64_t _internal_num_post_processing_delay_max_waits () const
 
void _internal_set_num_post_processing_delay_max_waits (::uint64_t value)
 

Static Private Member Functions

static void MergeImpl (::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
 
::absl::string_view FullMessageName ()
 

Private Attributes

union { 
 
   Impl_   _impl_ 
 
};  
 

Static Private Attributes

static const ::google::protobuf::internal::TcParseTable< 4, 11, 0, 0, 2 > _table_
 

Friends

class ::google::protobuf::internal::AnyMetadata
 
class ::google::protobuf::internal::TcParser
 
template<typename T >
class ::google::protobuf::Arena::InternalHelper
 
struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
 
void swap (DataHandlerInfo &a, DataHandlerInfo &b)
 

Detailed Description

Definition at line 449 of file datahandling_info.pb.h.

Member Typedef Documentation

◆ DestructorSkippable_

◆ InternalArenaConstructable_

Member Enumeration Documentation

◆ anonymous enum

anonymous enum : int
Enumerator
kSumPayloadsFieldNumber 
kNumPayloadsFieldNumber 
kNumDataInputTimeoutsFieldNumber 
kRatePayloadsConsumedFieldNumber 
kNumLbInsertFailuresFieldNumber 
kSumRequestsFieldNumber 
kNumRequestsFieldNumber 
kLastDaqTimestampFieldNumber 
kNewestTimestampFieldNumber 
kOldestTimestampFieldNumber 
kNumPostProcessingDelayMaxWaitsFieldNumber 

Definition at line 576 of file datahandling_info.pb.h.

576 : int {
588 };

Constructor & Destructor Documentation

◆ DataHandlerInfo() [1/6]

dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( )
inline

◆ ~DataHandlerInfo()

dunedaq::datahandlinglibs::opmon::DataHandlerInfo::~DataHandlerInfo ( )
override

Definition at line 930 of file datahandling_info.pb.cc.

930 {
931 // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
932 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
933 SharedDtor();
934}

◆ DataHandlerInfo() [2/6]

template<typename = void>
PROTOBUF_CONSTEXPR dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( ::google::protobuf::internal::ConstantInitialized )
explicit

◆ DataHandlerInfo() [3/6]

dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( const DataHandlerInfo & from)

Definition at line 907 of file datahandling_info.pb.cc.

908 : ::google::protobuf::Message(), _impl_(from._impl_) {
909 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
910 from._internal_metadata_);
911 // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
912}

◆ DataHandlerInfo() [4/6]

dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( DataHandlerInfo && from)
inlinenoexcept

Definition at line 458 of file datahandling_info.pb.h.

459 : DataHandlerInfo() {
460 *this = ::std::move(from);
461 }

◆ DataHandlerInfo() [5/6]

dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( ::google::protobuf::Arena * arena)
explicitprotected

Definition at line 902 of file datahandling_info.pb.cc.

903 : ::google::protobuf::Message(arena) {
904 SharedCtor(arena);
905 // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
906}
void SharedCtor(::google::protobuf::Arena *arena)

◆ DataHandlerInfo() [6/6]

template<typename >
PROTOBUF_CONSTEXPR dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo ( ::_pbi::ConstantInitialized )

Definition at line 61 of file datahandling_info.pb.cc.

62 : _impl_{
63 /*decltype(_impl_.sum_payloads_)*/ ::uint64_t{0u},
64 /*decltype(_impl_.num_payloads_)*/ ::uint64_t{0u},
65 /*decltype(_impl_.num_data_input_timeouts_)*/ ::uint64_t{0u},
66 /*decltype(_impl_.rate_payloads_consumed_)*/ 0,
67 /*decltype(_impl_.num_lb_insert_failures_)*/ ::uint64_t{0u},
68 /*decltype(_impl_.sum_requests_)*/ ::uint64_t{0u},
69 /*decltype(_impl_.num_requests_)*/ ::uint64_t{0u},
70 /*decltype(_impl_.last_daq_timestamp_)*/ ::uint64_t{0u},
71 /*decltype(_impl_.newest_timestamp_)*/ ::uint64_t{0u},
72 /*decltype(_impl_.oldest_timestamp_)*/ ::uint64_t{0u},
73 /*decltype(_impl_.num_post_processing_delay_max_waits_)*/ ::uint64_t{0u},
74 /*decltype(_impl_._cached_size_)*/ {},
75 } {}

Member Function Documentation

◆ _internal_last_daq_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_last_daq_timestamp ( ) const
inlineprivate

Definition at line 2623 of file datahandling_info.pb.h.

2623 {
2624 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2626}

◆ _internal_newest_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_newest_timestamp ( ) const
inlineprivate

Definition at line 2645 of file datahandling_info.pb.h.

2645 {
2646 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2648}

◆ _internal_num_data_input_timeouts()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_num_data_input_timeouts ( ) const
inlineprivate

Definition at line 2513 of file datahandling_info.pb.h.

2513 {
2514 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2516}

◆ _internal_num_lb_insert_failures()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_num_lb_insert_failures ( ) const
inlineprivate

Definition at line 2557 of file datahandling_info.pb.h.

2557 {
2558 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2560}

◆ _internal_num_payloads()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_num_payloads ( ) const
inlineprivate

Definition at line 2491 of file datahandling_info.pb.h.

2491 {
2492 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2493 return _impl_.num_payloads_;
2494}

◆ _internal_num_post_processing_delay_max_waits()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_num_post_processing_delay_max_waits ( ) const
inlineprivate

Definition at line 2689 of file datahandling_info.pb.h.

2689 {
2690 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2692}

◆ _internal_num_requests()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_num_requests ( ) const
inlineprivate

Definition at line 2601 of file datahandling_info.pb.h.

2601 {
2602 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2603 return _impl_.num_requests_;
2604}

◆ _internal_oldest_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_oldest_timestamp ( ) const
inlineprivate

Definition at line 2667 of file datahandling_info.pb.h.

2667 {
2668 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2670}

◆ _internal_rate_payloads_consumed()

double dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_rate_payloads_consumed ( ) const
inlineprivate

Definition at line 2535 of file datahandling_info.pb.h.

2535 {
2536 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2538}

◆ _internal_set_last_daq_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_last_daq_timestamp ( ::uint64_t value)
inlineprivate

Definition at line 2627 of file datahandling_info.pb.h.

2627 {
2628 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2629 ;
2631}

◆ _internal_set_newest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_newest_timestamp ( ::uint64_t value)
inlineprivate

Definition at line 2649 of file datahandling_info.pb.h.

2649 {
2650 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2651 ;
2652 _impl_.newest_timestamp_ = value;
2653}

◆ _internal_set_num_data_input_timeouts()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_num_data_input_timeouts ( ::uint64_t value)
inlineprivate

Definition at line 2517 of file datahandling_info.pb.h.

2517 {
2518 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2519 ;
2521}

◆ _internal_set_num_lb_insert_failures()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_num_lb_insert_failures ( ::uint64_t value)
inlineprivate

Definition at line 2561 of file datahandling_info.pb.h.

2561 {
2562 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2563 ;
2565}

◆ _internal_set_num_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_num_payloads ( ::uint64_t value)
inlineprivate

Definition at line 2495 of file datahandling_info.pb.h.

2495 {
2496 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2497 ;
2498 _impl_.num_payloads_ = value;
2499}

◆ _internal_set_num_post_processing_delay_max_waits()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_num_post_processing_delay_max_waits ( ::uint64_t value)
inlineprivate

Definition at line 2693 of file datahandling_info.pb.h.

2693 {
2694 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2695 ;
2697}

◆ _internal_set_num_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_num_requests ( ::uint64_t value)
inlineprivate

Definition at line 2605 of file datahandling_info.pb.h.

2605 {
2606 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2607 ;
2608 _impl_.num_requests_ = value;
2609}

◆ _internal_set_oldest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_oldest_timestamp ( ::uint64_t value)
inlineprivate

Definition at line 2671 of file datahandling_info.pb.h.

2671 {
2672 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2673 ;
2674 _impl_.oldest_timestamp_ = value;
2675}

◆ _internal_set_rate_payloads_consumed()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_rate_payloads_consumed ( double value)
inlineprivate

Definition at line 2539 of file datahandling_info.pb.h.

2539 {
2540 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2541 ;
2543}

◆ _internal_set_sum_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_sum_payloads ( ::uint64_t value)
inlineprivate

Definition at line 2473 of file datahandling_info.pb.h.

2473 {
2474 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2475 ;
2476 _impl_.sum_payloads_ = value;
2477}

◆ _internal_set_sum_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_set_sum_requests ( ::uint64_t value)
inlineprivate

Definition at line 2583 of file datahandling_info.pb.h.

2583 {
2584 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2585 ;
2586 _impl_.sum_requests_ = value;
2587}

◆ _internal_sum_payloads()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_sum_payloads ( ) const
inlineprivate

Definition at line 2469 of file datahandling_info.pb.h.

2469 {
2470 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2471 return _impl_.sum_payloads_;
2472}

◆ _internal_sum_requests()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_internal_sum_requests ( ) const
inlineprivate

Definition at line 2579 of file datahandling_info.pb.h.

2579 {
2580 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2581 return _impl_.sum_requests_;
2582}

◆ _InternalParse()

const char * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_InternalParse ( const char * ptr,
::google::protobuf::internal::ParseContext * ctx )
final

Definition at line 954 of file datahandling_info.pb.cc.

955 {
956 ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
957 return ptr;
958}
static const ::google::protobuf::internal::TcParseTable< 4, 11, 0, 0, 2 > _table_

◆ _InternalSerialize()

uint8_t * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_InternalSerialize ( ::uint8_t * target,
::google::protobuf::io::EpsCopyOutputStream * stream ) const
final

Definition at line 1054 of file datahandling_info.pb.cc.

1056 {
1057 // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
1058 ::uint32_t cached_has_bits = 0;
1059 (void)cached_has_bits;
1060
1061 // uint64 sum_payloads = 1;
1062 if (this->_internal_sum_payloads() != 0) {
1063 target = stream->EnsureSpace(target);
1064 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1065 1, this->_internal_sum_payloads(), target);
1066 }
1067
1068 // uint64 num_payloads = 2;
1069 if (this->_internal_num_payloads() != 0) {
1070 target = stream->EnsureSpace(target);
1071 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1072 2, this->_internal_num_payloads(), target);
1073 }
1074
1075 // uint64 num_data_input_timeouts = 3;
1076 if (this->_internal_num_data_input_timeouts() != 0) {
1077 target = stream->EnsureSpace(target);
1078 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1079 3, this->_internal_num_data_input_timeouts(), target);
1080 }
1081
1082 // double rate_payloads_consumed = 4;
1083 static_assert(sizeof(::uint64_t) == sizeof(double),
1084 "Code assumes ::uint64_t and double are the same size.");
1085 double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
1086 ::uint64_t raw_rate_payloads_consumed;
1087 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
1088 if (raw_rate_payloads_consumed != 0) {
1089 target = stream->EnsureSpace(target);
1090 target = ::_pbi::WireFormatLite::WriteDoubleToArray(
1091 4, this->_internal_rate_payloads_consumed(), target);
1092 }
1093
1094 // uint64 num_lb_insert_failures = 5;
1095 if (this->_internal_num_lb_insert_failures() != 0) {
1096 target = stream->EnsureSpace(target);
1097 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1098 5, this->_internal_num_lb_insert_failures(), target);
1099 }
1100
1101 // uint64 sum_requests = 11;
1102 if (this->_internal_sum_requests() != 0) {
1103 target = stream->EnsureSpace(target);
1104 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1105 11, this->_internal_sum_requests(), target);
1106 }
1107
1108 // uint64 num_requests = 12;
1109 if (this->_internal_num_requests() != 0) {
1110 target = stream->EnsureSpace(target);
1111 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1112 12, this->_internal_num_requests(), target);
1113 }
1114
1115 // uint64 last_daq_timestamp = 21;
1116 if (this->_internal_last_daq_timestamp() != 0) {
1117 target = stream->EnsureSpace(target);
1118 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1119 21, this->_internal_last_daq_timestamp(), target);
1120 }
1121
1122 // uint64 newest_timestamp = 22;
1123 if (this->_internal_newest_timestamp() != 0) {
1124 target = stream->EnsureSpace(target);
1125 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1126 22, this->_internal_newest_timestamp(), target);
1127 }
1128
1129 // uint64 oldest_timestamp = 23;
1130 if (this->_internal_oldest_timestamp() != 0) {
1131 target = stream->EnsureSpace(target);
1132 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1133 23, this->_internal_oldest_timestamp(), target);
1134 }
1135
1136 // uint64 num_post_processing_delay_max_waits = 31;
1138 target = stream->EnsureSpace(target);
1139 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
1141 }
1142
1143 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1144 target =
1145 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
1146 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
1147 }
1148 // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
1149 return target;
1150}

◆ ByteSizeLong()

size_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::ByteSizeLong ( ) const
final

Definition at line 1152 of file datahandling_info.pb.cc.

1152 {
1153// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
1154 ::size_t total_size = 0;
1155
1156 ::uint32_t cached_has_bits = 0;
1157 // Prevent compiler warnings about cached_has_bits being unused
1158 (void) cached_has_bits;
1159
1160 // uint64 sum_payloads = 1;
1161 if (this->_internal_sum_payloads() != 0) {
1162 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1163 this->_internal_sum_payloads());
1164 }
1165
1166 // uint64 num_payloads = 2;
1167 if (this->_internal_num_payloads() != 0) {
1168 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1169 this->_internal_num_payloads());
1170 }
1171
1172 // uint64 num_data_input_timeouts = 3;
1173 if (this->_internal_num_data_input_timeouts() != 0) {
1174 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1176 }
1177
1178 // double rate_payloads_consumed = 4;
1179 static_assert(sizeof(::uint64_t) == sizeof(double),
1180 "Code assumes ::uint64_t and double are the same size.");
1181 double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
1182 ::uint64_t raw_rate_payloads_consumed;
1183 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
1184 if (raw_rate_payloads_consumed != 0) {
1185 total_size += 9;
1186 }
1187
1188 // uint64 num_lb_insert_failures = 5;
1189 if (this->_internal_num_lb_insert_failures() != 0) {
1190 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1192 }
1193
1194 // uint64 sum_requests = 11;
1195 if (this->_internal_sum_requests() != 0) {
1196 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1197 this->_internal_sum_requests());
1198 }
1199
1200 // uint64 num_requests = 12;
1201 if (this->_internal_num_requests() != 0) {
1202 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
1203 this->_internal_num_requests());
1204 }
1205
1206 // uint64 last_daq_timestamp = 21;
1207 if (this->_internal_last_daq_timestamp() != 0) {
1208 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
1210 }
1211
1212 // uint64 newest_timestamp = 22;
1213 if (this->_internal_newest_timestamp() != 0) {
1214 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
1216 }
1217
1218 // uint64 oldest_timestamp = 23;
1219 if (this->_internal_oldest_timestamp() != 0) {
1220 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
1222 }
1223
1224 // uint64 num_post_processing_delay_max_waits = 31;
1226 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
1228 }
1229
1230 return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
1231}
mutable::google::protobuf::internal::CachedSize _cached_size_

◆ Clear()

PROTOBUF_NOINLINE void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Clear ( )
final

Definition at line 942 of file datahandling_info.pb.cc.

942 {
943// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
944 ::uint32_t cached_has_bits = 0;
945 // Prevent compiler warnings about cached_has_bits being unused
946 (void) cached_has_bits;
947
948 ::memset(&_impl_.sum_payloads_, 0, static_cast<::size_t>(
949 reinterpret_cast<char*>(&_impl_.num_post_processing_delay_max_waits_) -
950 reinterpret_cast<char*>(&_impl_.sum_payloads_)) + sizeof(_impl_.num_post_processing_delay_max_waits_));
951 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
952}

◆ clear_last_daq_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_last_daq_timestamp ( )
inline

Definition at line 2612 of file datahandling_info.pb.h.

2612 {
2613 _impl_.last_daq_timestamp_ = ::uint64_t{0u};
2614}

◆ clear_newest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_newest_timestamp ( )
inline

Definition at line 2634 of file datahandling_info.pb.h.

2634 {
2635 _impl_.newest_timestamp_ = ::uint64_t{0u};
2636}

◆ clear_num_data_input_timeouts()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_num_data_input_timeouts ( )
inline

Definition at line 2502 of file datahandling_info.pb.h.

2502 {
2503 _impl_.num_data_input_timeouts_ = ::uint64_t{0u};
2504}

◆ clear_num_lb_insert_failures()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_num_lb_insert_failures ( )
inline

Definition at line 2546 of file datahandling_info.pb.h.

2546 {
2547 _impl_.num_lb_insert_failures_ = ::uint64_t{0u};
2548}

◆ clear_num_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_num_payloads ( )
inline

Definition at line 2480 of file datahandling_info.pb.h.

2480 {
2481 _impl_.num_payloads_ = ::uint64_t{0u};
2482}

◆ clear_num_post_processing_delay_max_waits()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_num_post_processing_delay_max_waits ( )
inline

Definition at line 2678 of file datahandling_info.pb.h.

2678 {
2680}

◆ clear_num_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_num_requests ( )
inline

Definition at line 2590 of file datahandling_info.pb.h.

2590 {
2591 _impl_.num_requests_ = ::uint64_t{0u};
2592}

◆ clear_oldest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_oldest_timestamp ( )
inline

Definition at line 2656 of file datahandling_info.pb.h.

2656 {
2657 _impl_.oldest_timestamp_ = ::uint64_t{0u};
2658}

◆ clear_rate_payloads_consumed()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_rate_payloads_consumed ( )
inline

Definition at line 2524 of file datahandling_info.pb.h.

2524 {
2526}

◆ clear_sum_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_sum_payloads ( )
inline

Definition at line 2458 of file datahandling_info.pb.h.

2458 {
2459 _impl_.sum_payloads_ = ::uint64_t{0u};
2460}

◆ clear_sum_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::clear_sum_requests ( )
inline

Definition at line 2568 of file datahandling_info.pb.h.

2568 {
2569 _impl_.sum_requests_ = ::uint64_t{0u};
2570}

◆ CopyFrom()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::CopyFrom ( const DataHandlerInfo & from)

Definition at line 1289 of file datahandling_info.pb.cc.

1289 {
1290// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
1291 if (&from == this) return;
1292 Clear();
1293 MergeFrom(from);
1294}
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final

◆ default_instance()

static const DataHandlerInfo & dunedaq::datahandlinglibs::opmon::DataHandlerInfo::default_instance ( )
inlinestatic

Definition at line 497 of file datahandling_info.pb.h.

497 {
499 }
static const DataHandlerInfo * internal_default_instance()

◆ descriptor()

static const ::google::protobuf::Descriptor * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::descriptor ( )
inlinestatic

Definition at line 488 of file datahandling_info.pb.h.

488 {
489 return GetDescriptor();
490 }
static const ::google::protobuf::Descriptor * GetDescriptor()

◆ FullMessageName()

::absl::string_view dunedaq::datahandlinglibs::opmon::DataHandlerInfo::FullMessageName ( )
inlinestaticprivate

Definition at line 560 of file datahandling_info.pb.h.

560 {
561 return "dunedaq.datahandlinglibs.opmon.DataHandlerInfo";
562 }

◆ GetCachedSize()

int dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetCachedSize ( ) const
inlinefinal

Definition at line 550 of file datahandling_info.pb.h.

550{ return _impl_._cached_size_.Get(); }

◆ GetClassData()

const::google::protobuf::Message::ClassData * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetClassData ( ) const
final

Definition at line 1237 of file datahandling_info.pb.cc.

◆ GetDescriptor()

static const ::google::protobuf::Descriptor * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetDescriptor ( )
inlinestatic

Definition at line 491 of file datahandling_info.pb.h.

491 {
492 return default_instance().GetMetadata().descriptor;
493 }
::google::protobuf::Metadata GetMetadata() const final

◆ GetMetadata()

google::protobuf::Metadata dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetMetadata ( ) const
final

Definition at line 1311 of file datahandling_info.pb.cc.

1311 {
1312 return ::_pbi::AssignDescriptors(
1315}
::absl::once_flag descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once
::_pb::Metadata file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[11]
PROTOBUF_ATTRIBUTE_WEAKconst ::_pbi::DescriptorTable * descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter()

◆ GetReflection()

static const ::google::protobuf::Reflection * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetReflection ( )
inlinestatic

Definition at line 494 of file datahandling_info.pb.h.

494 {
495 return default_instance().GetMetadata().reflection;
496 }

◆ internal_default_instance()

static const DataHandlerInfo * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::internal_default_instance ( )
inlinestatic

Definition at line 500 of file datahandling_info.pb.h.

500 {
501 return reinterpret_cast<const DataHandlerInfo*>(
503 }
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataHandlerInfoDefaultTypeInternal _DataHandlerInfo_default_instance_

◆ InternalSwap()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::InternalSwap ( DataHandlerInfo * other)
private

Definition at line 1300 of file datahandling_info.pb.cc.

1300 {
1301 using std::swap;
1302 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1303 ::google::protobuf::internal::memswap<
1306 - PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_payloads_)>(
1307 reinterpret_cast<char*>(&_impl_.sum_payloads_),
1308 reinterpret_cast<char*>(&other->_impl_.sum_payloads_));
1309}

◆ IsInitialized()

PROTOBUF_NOINLINE bool dunedaq::datahandlinglibs::opmon::DataHandlerInfo::IsInitialized ( ) const
final

Definition at line 1296 of file datahandling_info.pb.cc.

1296 {
1297 return true;
1298}

◆ last_daq_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::last_daq_timestamp ( ) const
inline

Definition at line 2615 of file datahandling_info.pb.h.

2615 {
2616 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
2618}

◆ MergeFrom()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::MergeFrom ( const DataHandlerInfo & from)
inline

Definition at line 537 of file datahandling_info.pb.h.

537 {
538 DataHandlerInfo::MergeImpl(*this, from);
539 }
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)

◆ MergeImpl()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::MergeImpl ( ::google::protobuf::Message & to_msg,
const ::google::protobuf::Message & from_msg )
staticprivate

Definition at line 1240 of file datahandling_info.pb.cc.

1240 {
1241 auto* const _this = static_cast<DataHandlerInfo*>(&to_msg);
1242 auto& from = static_cast<const DataHandlerInfo&>(from_msg);
1243 // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
1244 ABSL_DCHECK_NE(&from, _this);
1245 ::uint32_t cached_has_bits = 0;
1246 (void) cached_has_bits;
1247
1248 if (from._internal_sum_payloads() != 0) {
1249 _this->_internal_set_sum_payloads(from._internal_sum_payloads());
1250 }
1251 if (from._internal_num_payloads() != 0) {
1252 _this->_internal_set_num_payloads(from._internal_num_payloads());
1253 }
1254 if (from._internal_num_data_input_timeouts() != 0) {
1255 _this->_internal_set_num_data_input_timeouts(from._internal_num_data_input_timeouts());
1256 }
1257 static_assert(sizeof(::uint64_t) == sizeof(double),
1258 "Code assumes ::uint64_t and double are the same size.");
1259 double tmp_rate_payloads_consumed = from._internal_rate_payloads_consumed();
1260 ::uint64_t raw_rate_payloads_consumed;
1261 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
1262 if (raw_rate_payloads_consumed != 0) {
1263 _this->_internal_set_rate_payloads_consumed(from._internal_rate_payloads_consumed());
1264 }
1265 if (from._internal_num_lb_insert_failures() != 0) {
1266 _this->_internal_set_num_lb_insert_failures(from._internal_num_lb_insert_failures());
1267 }
1268 if (from._internal_sum_requests() != 0) {
1269 _this->_internal_set_sum_requests(from._internal_sum_requests());
1270 }
1271 if (from._internal_num_requests() != 0) {
1272 _this->_internal_set_num_requests(from._internal_num_requests());
1273 }
1274 if (from._internal_last_daq_timestamp() != 0) {
1275 _this->_internal_set_last_daq_timestamp(from._internal_last_daq_timestamp());
1276 }
1277 if (from._internal_newest_timestamp() != 0) {
1278 _this->_internal_set_newest_timestamp(from._internal_newest_timestamp());
1279 }
1280 if (from._internal_oldest_timestamp() != 0) {
1281 _this->_internal_set_oldest_timestamp(from._internal_oldest_timestamp());
1282 }
1283 if (from._internal_num_post_processing_delay_max_waits() != 0) {
1284 _this->_internal_set_num_post_processing_delay_max_waits(from._internal_num_post_processing_delay_max_waits());
1285 }
1286 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
1287}

◆ mutable_unknown_fields()

inline ::google::protobuf::UnknownFieldSet * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::mutable_unknown_fields ( )
inline

Definition at line 484 of file datahandling_info.pb.h.

484 {
485 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
486 }

◆ New()

DataHandlerInfo * dunedaq::datahandlinglibs::opmon::DataHandlerInfo::New ( ::google::protobuf::Arena * arena = nullptr) const
inlinefinal

Definition at line 531 of file datahandling_info.pb.h.

531 {
532 return CreateMaybeMessage<DataHandlerInfo>(arena);
533 }

◆ newest_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::newest_timestamp ( ) const
inline

Definition at line 2637 of file datahandling_info.pb.h.

2637 {
2638 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.newest_timestamp)
2640}

◆ num_data_input_timeouts()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::num_data_input_timeouts ( ) const
inline

Definition at line 2505 of file datahandling_info.pb.h.

2505 {
2506 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
2508}

◆ num_lb_insert_failures()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::num_lb_insert_failures ( ) const
inline

Definition at line 2549 of file datahandling_info.pb.h.

2549 {
2550 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
2552}

◆ num_payloads()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::num_payloads ( ) const
inline

Definition at line 2483 of file datahandling_info.pb.h.

2483 {
2484 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
2485 return _internal_num_payloads();
2486}

◆ num_post_processing_delay_max_waits()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::num_post_processing_delay_max_waits ( ) const
inline

Definition at line 2681 of file datahandling_info.pb.h.

2681 {
2682 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
2684}

◆ num_requests()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::num_requests ( ) const
inline

Definition at line 2593 of file datahandling_info.pb.h.

2593 {
2594 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
2595 return _internal_num_requests();
2596}

◆ oldest_timestamp()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::oldest_timestamp ( ) const
inline

Definition at line 2659 of file datahandling_info.pb.h.

2659 {
2660 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.oldest_timestamp)
2662}

◆ operator=() [1/2]

DataHandlerInfo & dunedaq::datahandlinglibs::opmon::DataHandlerInfo::operator= ( const DataHandlerInfo & from)
inline

Definition at line 463 of file datahandling_info.pb.h.

463 {
464 CopyFrom(from);
465 return *this;
466 }

◆ operator=() [2/2]

DataHandlerInfo & dunedaq::datahandlinglibs::opmon::DataHandlerInfo::operator= ( DataHandlerInfo && from)
inlinenoexcept

Definition at line 467 of file datahandling_info.pb.h.

467 {
468 if (this == &from) return *this;
469 if (GetOwningArena() == from.GetOwningArena()
470 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
471 && GetOwningArena() != nullptr
472 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
473 ) {
474 InternalSwap(&from);
475 } else {
476 CopyFrom(from);
477 }
478 return *this;
479 }

◆ rate_payloads_consumed()

double dunedaq::datahandlinglibs::opmon::DataHandlerInfo::rate_payloads_consumed ( ) const
inline

Definition at line 2527 of file datahandling_info.pb.h.

2527 {
2528 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
2530}

◆ set_last_daq_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_last_daq_timestamp ( ::uint64_t value)
inline

Definition at line 2619 of file datahandling_info.pb.h.

2619 {
2621 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
2622}

◆ set_newest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_newest_timestamp ( ::uint64_t value)
inline

Definition at line 2641 of file datahandling_info.pb.h.

2641 {
2643 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.newest_timestamp)
2644}

◆ set_num_data_input_timeouts()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_num_data_input_timeouts ( ::uint64_t value)
inline

Definition at line 2509 of file datahandling_info.pb.h.

2509 {
2511 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
2512}

◆ set_num_lb_insert_failures()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_num_lb_insert_failures ( ::uint64_t value)
inline

Definition at line 2553 of file datahandling_info.pb.h.

2553 {
2555 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
2556}

◆ set_num_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_num_payloads ( ::uint64_t value)
inline

Definition at line 2487 of file datahandling_info.pb.h.

2487 {
2489 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
2490}

◆ set_num_post_processing_delay_max_waits()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_num_post_processing_delay_max_waits ( ::uint64_t value)
inline

Definition at line 2685 of file datahandling_info.pb.h.

2685 {
2687 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
2688}

◆ set_num_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_num_requests ( ::uint64_t value)
inline

Definition at line 2597 of file datahandling_info.pb.h.

2597 {
2599 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
2600}

◆ set_oldest_timestamp()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_oldest_timestamp ( ::uint64_t value)
inline

Definition at line 2663 of file datahandling_info.pb.h.

2663 {
2665 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.oldest_timestamp)
2666}

◆ set_rate_payloads_consumed()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_rate_payloads_consumed ( double value)
inline

Definition at line 2531 of file datahandling_info.pb.h.

2531 {
2533 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
2534}

◆ set_sum_payloads()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_sum_payloads ( ::uint64_t value)
inline

Definition at line 2465 of file datahandling_info.pb.h.

2465 {
2467 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
2468}

◆ set_sum_requests()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::set_sum_requests ( ::uint64_t value)
inline

Definition at line 2575 of file datahandling_info.pb.h.

2575 {
2577 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
2578}

◆ SetCachedSize()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::SetCachedSize ( int size) const
finalprivate

Definition at line 938 of file datahandling_info.pb.cc.

938 {
940}
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size

◆ SharedCtor()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::SharedCtor ( ::google::protobuf::Arena * arena)
inlineprivate

Definition at line 913 of file datahandling_info.pb.cc.

913 {
914 (void)arena;
915 new (&_impl_) Impl_{
916 decltype(_impl_.sum_payloads_){::uint64_t{0u}},
917 decltype(_impl_.num_payloads_){::uint64_t{0u}},
918 decltype(_impl_.num_data_input_timeouts_){::uint64_t{0u}},
919 decltype(_impl_.rate_payloads_consumed_){0},
920 decltype(_impl_.num_lb_insert_failures_){::uint64_t{0u}},
921 decltype(_impl_.sum_requests_){::uint64_t{0u}},
922 decltype(_impl_.num_requests_){::uint64_t{0u}},
923 decltype(_impl_.last_daq_timestamp_){::uint64_t{0u}},
924 decltype(_impl_.newest_timestamp_){::uint64_t{0u}},
925 decltype(_impl_.oldest_timestamp_){::uint64_t{0u}},
926 decltype(_impl_.num_post_processing_delay_max_waits_){::uint64_t{0u}},
927 /*decltype(_impl_._cached_size_)*/ {},
928 };
929}

◆ SharedDtor()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::SharedDtor ( )
inlineprivate

Definition at line 935 of file datahandling_info.pb.cc.

935 {
936 ABSL_DCHECK(GetArenaForAllocation() == nullptr);
937}

◆ sum_payloads()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::sum_payloads ( ) const
inline

Definition at line 2461 of file datahandling_info.pb.h.

2461 {
2462 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
2463 return _internal_sum_payloads();
2464}

◆ sum_requests()

uint64_t dunedaq::datahandlinglibs::opmon::DataHandlerInfo::sum_requests ( ) const
inline

Definition at line 2571 of file datahandling_info.pb.h.

2571 {
2572 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
2573 return _internal_sum_requests();
2574}

◆ Swap()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Swap ( DataHandlerInfo * other)
inline

Definition at line 510 of file datahandling_info.pb.h.

510 {
511 if (other == this) return;
512 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
513 if (GetOwningArena() != nullptr &&
514 GetOwningArena() == other->GetOwningArena()) {
515 #else // PROTOBUF_FORCE_COPY_IN_SWAP
516 if (GetOwningArena() == other->GetOwningArena()) {
517 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
518 InternalSwap(other);
519 } else {
520 ::google::protobuf::internal::GenericSwap(this, other);
521 }
522 }

◆ unknown_fields()

const ::google::protobuf::UnknownFieldSet & dunedaq::datahandlinglibs::opmon::DataHandlerInfo::unknown_fields ( ) const
inline

Definition at line 481 of file datahandling_info.pb.h.

481 {
482 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
483 }

◆ UnsafeArenaSwap()

void dunedaq::datahandlinglibs::opmon::DataHandlerInfo::UnsafeArenaSwap ( DataHandlerInfo * other)
inline

Definition at line 523 of file datahandling_info.pb.h.

523 {
524 if (other == this) return;
525 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
526 InternalSwap(other);
527 }

Friends And Related Symbol Documentation

◆ ::google::protobuf::Arena::InternalHelper

template<typename T >
friend class ::google::protobuf::Arena::InternalHelper
friend

Definition at line 705 of file datahandling_info.pb.h.

◆ ::google::protobuf::internal::AnyMetadata

friend class ::google::protobuf::internal::AnyMetadata
friend

Definition at line 559 of file datahandling_info.pb.h.

◆ ::google::protobuf::internal::TcParser

friend class ::google::protobuf::internal::TcParser
friend

Definition at line 703 of file datahandling_info.pb.h.

◆ ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto

◆ swap

void swap ( DataHandlerInfo & a,
DataHandlerInfo & b )
friend

Definition at line 507 of file datahandling_info.pb.h.

507 {
508 a.Swap(&b);
509 }

Member Data Documentation

◆ [union]

◆ _class_data_

const::google::protobuf::Message::ClassData dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_class_data_
static
Initial value:
= {
::google::protobuf::Message::CopyWithSourceCheck,
}

Definition at line 567 of file datahandling_info.pb.h.

◆ _impl_

Impl_ dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_impl_

Definition at line 723 of file datahandling_info.pb.h.

◆ _table_

PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 const::_pbi::TcParseTable< 4, 11, 0, 0, 2 > dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_table_
staticprivate

Definition at line 704 of file datahandling_info.pb.h.

◆ kIndexInFileMessages

int dunedaq::datahandlinglibs::opmon::DataHandlerInfo::kIndexInFileMessages
staticconstexpr
Initial value:
=
2

Definition at line 504 of file datahandling_info.pb.h.


The documentation for this class was generated from the following files: