7#include "google/protobuf/io/coded_stream.h"
8#include "google/protobuf/extension_set.h"
9#include "google/protobuf/wire_format_lite.h"
10#include "google/protobuf/descriptor.h"
11#include "google/protobuf/generated_message_reflection.h"
12#include "google/protobuf/reflection_ops.h"
13#include "google/protobuf/wire_format.h"
14#include "google/protobuf/generated_message_tctable_impl.h"
18#include "google/protobuf/port_def.inc"
19PROTOBUF_PRAGMA_INIT_SEG
20namespace _pb = ::google::protobuf;
21namespace _pbi = ::google::protobuf::internal;
22namespace _fl = ::google::protobuf::internal::field_layout;
49PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
52PROTOBUF_CONSTEXPR TriggerInfo::TriggerInfo(::_pbi::ConstantInitialized)
65PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
71static constexpr const ::_pb::EnumDescriptor**
73static constexpr const ::_pb::ServiceDescriptor**
106static const ::_pbi::MigrationSchema
116const char descriptor_table_protodef_ctbmodules_2fopmon_2fCTBModule_2eproto[]
PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
117 "\n ctbmodules/opmon/CTBModule.proto\022\030dune"
118 "daq.ctbmodules.opmon\"\323\002\n\rCTBModuleInfo\022!"
119 "\n\031num_control_messages_sent\030\001 \001(\r\022&\n\036num"
120 "_control_responses_received\030\002 \001(\r\022\034\n\024ctb"
121 "_hardware_running\030\005 \001(\010\022\037\n\027ctb_hardware_"
122 "configured\030\006 \001(\010\022)\n!failed_to_send_hsi_e"
123 "vents_counter\030\014 \001(\004\022\033\n\023last_sent_timesta"
124 "mp\030\017 \001(\004\022\036\n\026last_readout_timestamp\030\020 \001(\004"
125 "\022 \n\030average_buffer_occupancy\030\025 \001(\001\022\027\n\017to"
126 "tal_hlt_count\030\031 \001(\004\022\025\n\rts_word_count\030\032 \001"
127 "(\004\"\034\n\013TriggerInfo\022\r\n\005count\030\001 \001(\004b\006proto3"
134 descriptor_table_protodef_ctbmodules_2fopmon_2fCTBModule_2eproto,
135 "ctbmodules/opmon/CTBModule.proto",
163PROTOBUF_ATTRIBUTE_INIT_PRIORITY2
175 : ::
google::protobuf::Message(arena) {
180 : ::
google::protobuf::Message(), _impl_(from._impl_) {
181 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
182 from._internal_metadata_);
203 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
207 ABSL_DCHECK(GetArenaForAllocation() ==
nullptr);
215 ::uint32_t cached_has_bits = 0;
217 (void) cached_has_bits;
222 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
226 const char* ptr, ::_pbi::ParseContext* ctx) {
227 ptr = ::_pbi::TcParser::ParseLoop(
this, ptr, ctx, &
_table_.header);
232PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
238 offsetof(
decltype(_table_), field_lookup_table),
240 offsetof(
decltype(_table_), field_entries),
243 offsetof(
decltype(_table_), field_names),
245 ::_pbi::TcParser::GenericFallback,
248 {::_pbi::TcParser::FastV64S2,
249 {384, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.last_readout_timestamp_)}},
251 {::_pbi::TcParser::SingularVarintNoZag1<::uint32_t, offsetof(CTBModuleInfo, _impl_.num_control_messages_sent_), 63>(),
252 {8, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.num_control_messages_sent_)}},
254 {::_pbi::TcParser::SingularVarintNoZag1<::uint32_t, offsetof(CTBModuleInfo, _impl_.num_control_responses_received_), 63>(),
255 {16, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.num_control_responses_received_)}},
256 {::_pbi::TcParser::MiniParse, {}},
257 {::_pbi::TcParser::MiniParse, {}},
259 {::_pbi::TcParser::SingularVarintNoZag1<bool, offsetof(CTBModuleInfo, _impl_.ctb_hardware_running_), 63>(),
260 {40, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ctb_hardware_running_)}},
262 {::_pbi::TcParser::SingularVarintNoZag1<bool, offsetof(CTBModuleInfo, _impl_.ctb_hardware_configured_), 63>(),
263 {48, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ctb_hardware_configured_)}},
264 {::_pbi::TcParser::MiniParse, {}},
265 {::_pbi::TcParser::MiniParse, {}},
267 {::_pbi::TcParser::FastV64S2,
268 {456, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.total_hlt_count_)}},
270 {::_pbi::TcParser::FastV64S2,
271 {464, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ts_word_count_)}},
272 {::_pbi::TcParser::MiniParse, {}},
274 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(CTBModuleInfo, _impl_.failed_to_send_hsi_events_counter_), 63>(),
275 {96, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.failed_to_send_hsi_events_counter_)}},
276 {::_pbi::TcParser::MiniParse, {}},
277 {::_pbi::TcParser::MiniParse, {}},
279 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(CTBModuleInfo, _impl_.last_sent_timestamp_), 63>(),
280 {120, 63, 0, PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.last_sent_timestamp_)}},
285 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.num_control_messages_sent_), 0, 0,
286 (0 | ::_fl::kFcSingular | ::_fl::kUInt32)},
288 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.num_control_responses_received_), 0, 0,
289 (0 | ::_fl::kFcSingular | ::_fl::kUInt32)},
291 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ctb_hardware_running_), 0, 0,
292 (0 | ::_fl::kFcSingular | ::_fl::kBool)},
294 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ctb_hardware_configured_), 0, 0,
295 (0 | ::_fl::kFcSingular | ::_fl::kBool)},
297 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.failed_to_send_hsi_events_counter_), 0, 0,
298 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
300 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.last_sent_timestamp_), 0, 0,
301 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
303 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.last_readout_timestamp_), 0, 0,
304 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
306 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.average_buffer_occupancy_), 0, 0,
307 (0 | ::_fl::kFcSingular | ::_fl::kDouble)},
309 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.total_hlt_count_), 0, 0,
310 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
312 {PROTOBUF_FIELD_OFFSET(CTBModuleInfo, _impl_.ts_word_count_), 0, 0,
313 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
322 ::google::protobuf::io::EpsCopyOutputStream* stream)
const {
324 ::uint32_t cached_has_bits = 0;
325 (void)cached_has_bits;
329 target = stream->EnsureSpace(target);
330 target = ::_pbi::WireFormatLite::WriteUInt32ToArray(
336 target = stream->EnsureSpace(target);
337 target = ::_pbi::WireFormatLite::WriteUInt32ToArray(
343 target = stream->EnsureSpace(target);
344 target = ::_pbi::WireFormatLite::WriteBoolToArray(
350 target = stream->EnsureSpace(target);
351 target = ::_pbi::WireFormatLite::WriteBoolToArray(
357 target = stream->EnsureSpace(target);
358 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
364 target = stream->EnsureSpace(target);
365 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
371 target = stream->EnsureSpace(target);
372 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
377 static_assert(
sizeof(::uint64_t) ==
sizeof(double),
378 "Code assumes ::uint64_t and double are the same size.");
380 ::uint64_t raw_average_buffer_occupancy;
381 memcpy(&raw_average_buffer_occupancy, &tmp_average_buffer_occupancy,
sizeof(tmp_average_buffer_occupancy));
382 if (raw_average_buffer_occupancy != 0) {
383 target = stream->EnsureSpace(target);
384 target = ::_pbi::WireFormatLite::WriteDoubleToArray(
390 target = stream->EnsureSpace(target);
391 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
397 target = stream->EnsureSpace(target);
398 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
402 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
404 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
405 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
413 ::size_t total_size = 0;
415 ::uint32_t cached_has_bits = 0;
417 (void) cached_has_bits;
421 total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(
427 total_size += ::_pbi::WireFormatLite::UInt32SizePlusOne(
433 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
439 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
445 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
450 static_assert(
sizeof(::uint64_t) ==
sizeof(double),
451 "Code assumes ::uint64_t and double are the same size.");
453 ::uint64_t raw_average_buffer_occupancy;
454 memcpy(&raw_average_buffer_occupancy, &tmp_average_buffer_occupancy,
sizeof(tmp_average_buffer_occupancy));
455 if (raw_average_buffer_occupancy != 0) {
461 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
467 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
485 ::google::protobuf::Message::CopyWithSourceCheck,
495 ABSL_DCHECK_NE(&from, _this);
496 ::uint32_t cached_has_bits = 0;
497 (void) cached_has_bits;
499 if (from._internal_num_control_messages_sent() != 0) {
500 _this->_internal_set_num_control_messages_sent(from._internal_num_control_messages_sent());
502 if (from._internal_num_control_responses_received() != 0) {
503 _this->_internal_set_num_control_responses_received(from._internal_num_control_responses_received());
505 if (from._internal_failed_to_send_hsi_events_counter() != 0) {
506 _this->_internal_set_failed_to_send_hsi_events_counter(from._internal_failed_to_send_hsi_events_counter());
508 if (from._internal_last_sent_timestamp() != 0) {
509 _this->_internal_set_last_sent_timestamp(from._internal_last_sent_timestamp());
511 if (from._internal_last_readout_timestamp() != 0) {
512 _this->_internal_set_last_readout_timestamp(from._internal_last_readout_timestamp());
514 static_assert(
sizeof(::uint64_t) ==
sizeof(double),
515 "Code assumes ::uint64_t and double are the same size.");
516 double tmp_average_buffer_occupancy = from._internal_average_buffer_occupancy();
517 ::uint64_t raw_average_buffer_occupancy;
518 memcpy(&raw_average_buffer_occupancy, &tmp_average_buffer_occupancy,
sizeof(tmp_average_buffer_occupancy));
519 if (raw_average_buffer_occupancy != 0) {
520 _this->_internal_set_average_buffer_occupancy(from._internal_average_buffer_occupancy());
522 if (from._internal_total_hlt_count() != 0) {
523 _this->_internal_set_total_hlt_count(from._internal_total_hlt_count());
525 if (from._internal_ts_word_count() != 0) {
526 _this->_internal_set_ts_word_count(from._internal_ts_word_count());
528 if (from._internal_ctb_hardware_running() != 0) {
529 _this->_internal_set_ctb_hardware_running(from._internal_ctb_hardware_running());
531 if (from._internal_ctb_hardware_configured() != 0) {
532 _this->_internal_set_ctb_hardware_configured(from._internal_ctb_hardware_configured());
534 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
539 if (&from ==
this)
return;
550 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
551 ::google::protobuf::internal::memswap<
560 return ::_pbi::AssignDescriptors(
571 : ::
google::protobuf::Message(arena) {
576 : ::
google::protobuf::Message(), _impl_(from._impl_) {
577 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
578 from._internal_metadata_);
590 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
594 ABSL_DCHECK(GetArenaForAllocation() ==
nullptr);
602 ::uint32_t cached_has_bits = 0;
604 (void) cached_has_bits;
607 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
611 const char* ptr, ::_pbi::ParseContext* ctx) {
612 ptr = ::_pbi::TcParser::ParseLoop(
this, ptr, ctx, &
_table_.header);
617PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
623 offsetof(
decltype(_table_), field_lookup_table),
625 offsetof(
decltype(_table_), field_entries),
628 offsetof(
decltype(_table_), field_names),
630 ::_pbi::TcParser::GenericFallback,
633 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TriggerInfo, _impl_.count_), 63>(),
634 {8, 63, 0, PROTOBUF_FIELD_OFFSET(TriggerInfo, _impl_.count_)}},
639 {PROTOBUF_FIELD_OFFSET(TriggerInfo, _impl_.count_), 0, 0,
640 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
649 ::google::protobuf::io::EpsCopyOutputStream* stream)
const {
651 ::uint32_t cached_has_bits = 0;
652 (void)cached_has_bits;
656 target = stream->EnsureSpace(target);
657 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
661 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
663 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
664 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
672 ::size_t total_size = 0;
674 ::uint32_t cached_has_bits = 0;
676 (void) cached_has_bits;
680 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
688 ::google::protobuf::Message::CopyWithSourceCheck,
695 auto*
const _this =
static_cast<TriggerInfo*
>(&to_msg);
696 auto& from =
static_cast<const TriggerInfo&
>(from_msg);
698 ABSL_DCHECK_NE(&from, _this);
699 ::uint32_t cached_has_bits = 0;
700 (void) cached_has_bits;
702 if (from._internal_count() != 0) {
703 _this->_internal_set_count(from._internal_count());
705 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
710 if (&from ==
this)
return;
721 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
726 return ::_pbi::AssignDescriptors(
739#include "google/protobuf/port_undef.inc"
PROTOBUF_ATTRIBUTE_WEAKconst ::_pbi::DescriptorTable * descriptor_table_ctbmodules_2fopmon_2fCTBModule_2eproto_getter()
static constexprconst ::_pb::ServiceDescriptor ** file_level_service_descriptors_ctbmodules_2fopmon_2fCTBModule_2eproto
::absl::once_flag descriptor_table_ctbmodules_2fopmon_2fCTBModule_2eproto_once
const ::_pbi::DescriptorTable descriptor_table_ctbmodules_2fopmon_2fCTBModule_2eproto
static constexprconst ::_pb::EnumDescriptor ** file_level_enum_descriptors_ctbmodules_2fopmon_2fCTBModule_2eproto
::_pb::Metadata file_level_metadata_ctbmodules_2fopmon_2fCTBModule_2eproto[2]
::size_t ByteSizeLong() const final
::uint64_t _internal_total_hlt_count() const
~CTBModuleInfo() override
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
::uint64_t _internal_last_sent_timestamp() const
double _internal_average_buffer_occupancy() const
::uint64_t _internal_failed_to_send_hsi_events_counter() const
void CopyFrom(const CTBModuleInfo &from)
void InternalSwap(CTBModuleInfo *other)
bool _internal_ctb_hardware_running() const
::uint64_t _internal_last_readout_timestamp() const
void SharedCtor(::google::protobuf::Arena *arena)
static const ::google::protobuf::internal::TcParseTable< 4, 10, 0, 0, 2 > _table_
::uint32_t _internal_num_control_responses_received() const
::google::protobuf::Metadata GetMetadata() const final
::uint64_t _internal_ts_word_count() const
bool IsInitialized() const final
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
bool _internal_ctb_hardware_configured() const
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
void MergeFrom(const CTBModuleInfo &from)
const ::google::protobuf::Message::ClassData * GetClassData() const final
void SetCachedSize(int size) const final
static const ClassData _class_data_
::uint32_t _internal_num_control_messages_sent() const
static const ::google::protobuf::internal::TcParseTable< 0, 1, 0, 0, 2 > _table_
void MergeFrom(const TriggerInfo &from)
void SetCachedSize(int size) const final
bool IsInitialized() const final
const ::google::protobuf::Message::ClassData * GetClassData() const final
void SharedCtor(::google::protobuf::Arena *arena)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
::google::protobuf::Metadata GetMetadata() const final
void CopyFrom(const TriggerInfo &from)
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
friend void swap(TriggerInfo &a, TriggerInfo &b)
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
::size_t ByteSizeLong() const final
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
::uint64_t _internal_count() const
static const ClassData _class_data_
void InternalSwap(TriggerInfo *other)
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 CTBModuleInfoDefaultTypeInternal _CTBModuleInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TriggerInfoDefaultTypeInternal _TriggerInfo_default_instance_
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
static const ::uint32_t offsets[]
PROTOBUF_CONSTEXPR CTBModuleInfoDefaultTypeInternal()
~CTBModuleInfoDefaultTypeInternal()
::uint64_t last_sent_timestamp_
::uint64_t total_hlt_count_
double average_buffer_occupancy_
bool ctb_hardware_running_
::uint32_t num_control_responses_received_
::uint64_t ts_word_count_
::uint64_t failed_to_send_hsi_events_counter_
::uint32_t num_control_messages_sent_
bool ctb_hardware_configured_
mutable::google::protobuf::internal::CachedSize _cached_size_
::uint64_t last_readout_timestamp_
PROTOBUF_CONSTEXPR TriggerInfoDefaultTypeInternal()
~TriggerInfoDefaultTypeInternal()
mutable::google::protobuf::internal::CachedSize _cached_size_
const ::uint32_t TableStruct_wib_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold)
static const ::_pb::Message *const file_default_instances[]