DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
TRBModule.pb.cc
Go to the documentation of this file.
1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: dfmodules/opmon/TRBModule.proto
3
5
6#include <algorithm>
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"
15// @@protoc_insertion_point(includes)
16
17// Must be included last.
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;
23namespace dunedaq {
24namespace dfmodules {
25namespace opmon {
26 template <typename>
27PROTOBUF_CONSTEXPR TRBInfo::TRBInfo(::_pbi::ConstantInitialized)
28 : _impl_{
29 /*decltype(_impl_.pending_trigger_decisions_)*/ ::uint64_t{0u},
30 /*decltype(_impl_.fragments_in_the_book_)*/ ::uint64_t{0u},
31 /*decltype(_impl_.pending_fragments_)*/ ::uint64_t{0u},
32 /*decltype(_impl_.received_trigger_decisions_)*/ ::uint64_t{0u},
33 /*decltype(_impl_.generated_trigger_records_)*/ ::uint64_t{0u},
34 /*decltype(_impl_.generated_data_requests_)*/ ::uint64_t{0u},
35 /*decltype(_impl_.received_fragments_)*/ ::uint64_t{0u},
36 /*decltype(_impl_.data_waiting_time_)*/ ::uint64_t{0u},
37 /*decltype(_impl_.data_request_width_)*/ ::uint64_t{0u},
38 /*decltype(_impl_.trigger_decision_width_)*/ ::uint64_t{0u},
39 /*decltype(_impl_.received_trmon_requests_)*/ ::uint64_t{0u},
40 /*decltype(_impl_.sent_trmon_)*/ ::uint64_t{0u},
41 /*decltype(_impl_.td_processing_us_)*/ ::uint64_t{0u},
42 /*decltype(_impl_.fragment_processing_us_)*/ ::uint64_t{0u},
43 /*decltype(_impl_._cached_size_)*/ {},
44 } {}
46 PROTOBUF_CONSTEXPR TRBInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
48 union {
50 };
51};
52
53PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
54 PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TRBInfoDefaultTypeInternal _TRBInfo_default_instance_;
55 template <typename>
56PROTOBUF_CONSTEXPR TRBErrors::TRBErrors(::_pbi::ConstantInitialized)
57 : _impl_{
58 /*decltype(_impl_.timed_out_trigger_records_)*/ ::uint64_t{0u},
59 /*decltype(_impl_.unexpected_fragments_)*/ ::uint64_t{0u},
60 /*decltype(_impl_.unexpected_trigger_decisions_)*/ ::uint64_t{0u},
61 /*decltype(_impl_.abandoned_trigger_records_)*/ ::uint64_t{0u},
62 /*decltype(_impl_.lost_fragments_)*/ ::uint64_t{0u},
63 /*decltype(_impl_.invalid_requests_)*/ ::uint64_t{0u},
64 /*decltype(_impl_.duplicated_trigger_ids_)*/ ::uint64_t{0u},
65 /*decltype(_impl_._cached_size_)*/ {},
66 } {}
68 PROTOBUF_CONSTEXPR TRBErrorsDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
70 union {
72 };
73};
74
75PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
77} // namespace opmon
78} // namespace dfmodules
79} // namespace dunedaq
81static constexpr const ::_pb::EnumDescriptor**
83static constexpr const ::_pb::ServiceDescriptor**
86 protodesc_cold) = {
87 ~0u, // no _has_bits_
88 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _internal_metadata_),
89 ~0u, // no _extensions_
90 ~0u, // no _oneof_case_
91 ~0u, // no _weak_field_map_
92 ~0u, // no _inlined_string_donated_
93 ~0u, // no _split_
94 ~0u, // no sizeof(Split)
95 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.pending_trigger_decisions_),
96 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.fragments_in_the_book_),
97 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.pending_fragments_),
98 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.received_trigger_decisions_),
99 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.generated_trigger_records_),
100 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.generated_data_requests_),
101 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.received_fragments_),
102 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.data_waiting_time_),
103 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.data_request_width_),
104 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.trigger_decision_width_),
105 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.received_trmon_requests_),
106 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.sent_trmon_),
107 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.td_processing_us_),
108 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBInfo, _impl_.fragment_processing_us_),
109 ~0u, // no _has_bits_
110 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _internal_metadata_),
111 ~0u, // no _extensions_
112 ~0u, // no _oneof_case_
113 ~0u, // no _weak_field_map_
114 ~0u, // no _inlined_string_donated_
115 ~0u, // no _split_
116 ~0u, // no sizeof(Split)
117 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.timed_out_trigger_records_),
118 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.unexpected_fragments_),
119 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.unexpected_trigger_decisions_),
120 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.abandoned_trigger_records_),
121 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.lost_fragments_),
122 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.invalid_requests_),
123 PROTOBUF_FIELD_OFFSET(::dunedaq::dfmodules::opmon::TRBErrors, _impl_.duplicated_trigger_ids_),
124};
125
126static const ::_pbi::MigrationSchema
127 schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
128 {0, -1, -1, sizeof(::dunedaq::dfmodules::opmon::TRBInfo)},
129 {22, -1, -1, sizeof(::dunedaq::dfmodules::opmon::TRBErrors)},
130};
131
136const char descriptor_table_protodef_dfmodules_2fopmon_2fTRBModule_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
137 "\n\037dfmodules/opmon/TRBModule.proto\022\027duned"
138 "aq.dfmodules.opmon\"\260\003\n\007TRBInfo\022!\n\031pendin"
139 "g_trigger_decisions\030\001 \001(\004\022\035\n\025fragments_i"
140 "n_the_book\030\002 \001(\004\022\031\n\021pending_fragments\030\003 "
141 "\001(\004\022\"\n\032received_trigger_decisions\030\024 \001(\004\022"
142 "!\n\031generated_trigger_records\030\025 \001(\004\022\037\n\027ge"
143 "nerated_data_requests\030\026 \001(\004\022\032\n\022received_"
144 "fragments\030\027 \001(\004\022\031\n\021data_waiting_time\030\031 \001"
145 "(\004\022\032\n\022data_request_width\030\032 \001(\004\022\036\n\026trigge"
146 "r_decision_width\030\033 \001(\004\022\037\n\027received_trmon"
147 "_requests\030\034 \001(\004\022\022\n\nsent_trmon\030\035 \001(\004\022\030\n\020t"
148 "d_processing_us\030( \001(\004\022\036\n\026fragment_proces"
149 "sing_us\030) \001(\004\"\347\001\n\tTRBErrors\022!\n\031timed_out"
150 "_trigger_records\030\001 \001(\004\022\034\n\024unexpected_fra"
151 "gments\030\002 \001(\004\022$\n\034unexpected_trigger_decis"
152 "ions\030\003 \001(\004\022!\n\031abandoned_trigger_records\030"
153 "\004 \001(\004\022\026\n\016lost_fragments\030\005 \001(\004\022\030\n\020invalid"
154 "_requests\030\006 \001(\004\022\036\n\026duplicated_trigger_id"
155 "s\030\007 \001(\004b\006proto3"
156};
175
176// This function exists to be marked as weak.
177// It can significantly speed up compilation by breaking up LLVM's SCC
178// in the .pb.cc translation units. Large translation units see a
179// reduction of more than 35% of walltime for optimized builds. Without
180// the weak attribute all the messages in the file, including all the
181// vtables and everything they use become part of the same SCC through
182// a cycle like:
183// GetMetadata -> descriptor table -> default instances ->
184// vtables -> GetMetadata
185// By adding a weak function here we break the connection from the
186// individual vtables back into the descriptor table.
190// Force running AddDescriptors() at dynamic initialization time.
191PROTOBUF_ATTRIBUTE_INIT_PRIORITY2
192static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_dfmodules_2fopmon_2fTRBModule_2eproto(&descriptor_table_dfmodules_2fopmon_2fTRBModule_2eproto);
193namespace dunedaq {
194namespace dfmodules {
195namespace opmon {
196// ===================================================================
197
199 public:
200};
201
202TRBInfo::TRBInfo(::google::protobuf::Arena* arena)
203 : ::google::protobuf::Message(arena) {
204 SharedCtor(arena);
205 // @@protoc_insertion_point(arena_constructor:dunedaq.dfmodules.opmon.TRBInfo)
206}
208 : ::google::protobuf::Message(), _impl_(from._impl_) {
209 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
210 from._internal_metadata_);
211 // @@protoc_insertion_point(copy_constructor:dunedaq.dfmodules.opmon.TRBInfo)
212}
213inline void TRBInfo::SharedCtor(::_pb::Arena* arena) {
214 (void)arena;
215 new (&_impl_) Impl_{
216 decltype(_impl_.pending_trigger_decisions_){::uint64_t{0u}},
217 decltype(_impl_.fragments_in_the_book_){::uint64_t{0u}},
218 decltype(_impl_.pending_fragments_){::uint64_t{0u}},
219 decltype(_impl_.received_trigger_decisions_){::uint64_t{0u}},
220 decltype(_impl_.generated_trigger_records_){::uint64_t{0u}},
221 decltype(_impl_.generated_data_requests_){::uint64_t{0u}},
222 decltype(_impl_.received_fragments_){::uint64_t{0u}},
223 decltype(_impl_.data_waiting_time_){::uint64_t{0u}},
224 decltype(_impl_.data_request_width_){::uint64_t{0u}},
225 decltype(_impl_.trigger_decision_width_){::uint64_t{0u}},
226 decltype(_impl_.received_trmon_requests_){::uint64_t{0u}},
227 decltype(_impl_.sent_trmon_){::uint64_t{0u}},
228 decltype(_impl_.td_processing_us_){::uint64_t{0u}},
229 decltype(_impl_.fragment_processing_us_){::uint64_t{0u}},
230 /*decltype(_impl_._cached_size_)*/ {},
231 };
232}
234 // @@protoc_insertion_point(destructor:dunedaq.dfmodules.opmon.TRBInfo)
235 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
236 SharedDtor();
237}
238inline void TRBInfo::SharedDtor() {
239 ABSL_DCHECK(GetArenaForAllocation() == nullptr);
240}
243}
244
245PROTOBUF_NOINLINE void TRBInfo::Clear() {
246// @@protoc_insertion_point(message_clear_start:dunedaq.dfmodules.opmon.TRBInfo)
247 ::uint32_t cached_has_bits = 0;
248 // Prevent compiler warnings about cached_has_bits being unused
249 (void) cached_has_bits;
250
251 ::memset(&_impl_.pending_trigger_decisions_, 0, static_cast<::size_t>(
252 reinterpret_cast<char*>(&_impl_.fragment_processing_us_) -
253 reinterpret_cast<char*>(&_impl_.pending_trigger_decisions_)) + sizeof(_impl_.fragment_processing_us_));
254 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
255}
256
258 const char* ptr, ::_pbi::ParseContext* ctx) {
259 ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
260 return ptr;
261}
262
263
264PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
265const ::_pbi::TcParseTable<4, 14, 0, 0, 7> TRBInfo::_table_ = {
266 {
267 0, // no _has_bits_
268 0, // no _extensions_
269 41, 120, // max_field_number, fast_idx_mask
270 offsetof(decltype(_table_), field_lookup_table),
271 3767009272, // skipmap
272 offsetof(decltype(_table_), field_entries),
273 14, // num_field_entries
274 0, // num_aux_entries
275 offsetof(decltype(_table_), field_names), // no aux_entries
277 ::_pbi::TcParser::GenericFallback, // fallback
278 }, {{
279 {::_pbi::TcParser::MiniParse, {}},
280 // uint64 pending_trigger_decisions = 1;
281 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBInfo, _impl_.pending_trigger_decisions_), 63>(),
282 {8, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.pending_trigger_decisions_)}},
283 // uint64 fragments_in_the_book = 2;
284 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBInfo, _impl_.fragments_in_the_book_), 63>(),
285 {16, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.fragments_in_the_book_)}},
286 // uint64 pending_fragments = 3;
287 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBInfo, _impl_.pending_fragments_), 63>(),
288 {24, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.pending_fragments_)}},
289 // uint64 received_trigger_decisions = 20;
290 {::_pbi::TcParser::FastV64S2,
291 {416, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_trigger_decisions_)}},
292 // uint64 generated_trigger_records = 21;
293 {::_pbi::TcParser::FastV64S2,
294 {424, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.generated_trigger_records_)}},
295 // uint64 generated_data_requests = 22;
296 {::_pbi::TcParser::FastV64S2,
297 {432, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.generated_data_requests_)}},
298 // uint64 received_fragments = 23;
299 {::_pbi::TcParser::FastV64S2,
300 {440, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_fragments_)}},
301 // uint64 td_processing_us = 40;
302 {::_pbi::TcParser::FastV64S2,
303 {704, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.td_processing_us_)}},
304 // uint64 data_waiting_time = 25;
305 {::_pbi::TcParser::FastV64S2,
306 {456, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.data_waiting_time_)}},
307 // uint64 data_request_width = 26;
308 {::_pbi::TcParser::FastV64S2,
309 {464, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.data_request_width_)}},
310 // uint64 trigger_decision_width = 27;
311 {::_pbi::TcParser::FastV64S2,
312 {472, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.trigger_decision_width_)}},
313 // uint64 received_trmon_requests = 28;
314 {::_pbi::TcParser::FastV64S2,
315 {480, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_trmon_requests_)}},
316 // uint64 sent_trmon = 29;
317 {::_pbi::TcParser::FastV64S2,
318 {488, 63, 0, PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.sent_trmon_)}},
319 {::_pbi::TcParser::MiniParse, {}},
320 {::_pbi::TcParser::MiniParse, {}},
321 }}, {{
322 40, 0, 1,
323 65532, 12,
324 65535, 65535
325 }}, {{
326 // uint64 pending_trigger_decisions = 1;
327 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.pending_trigger_decisions_), 0, 0,
328 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
329 // uint64 fragments_in_the_book = 2;
330 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.fragments_in_the_book_), 0, 0,
331 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
332 // uint64 pending_fragments = 3;
333 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.pending_fragments_), 0, 0,
334 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
335 // uint64 received_trigger_decisions = 20;
336 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_trigger_decisions_), 0, 0,
337 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
338 // uint64 generated_trigger_records = 21;
339 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.generated_trigger_records_), 0, 0,
340 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
341 // uint64 generated_data_requests = 22;
342 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.generated_data_requests_), 0, 0,
343 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
344 // uint64 received_fragments = 23;
345 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_fragments_), 0, 0,
346 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
347 // uint64 data_waiting_time = 25;
348 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.data_waiting_time_), 0, 0,
349 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
350 // uint64 data_request_width = 26;
351 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.data_request_width_), 0, 0,
352 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
353 // uint64 trigger_decision_width = 27;
354 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.trigger_decision_width_), 0, 0,
355 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
356 // uint64 received_trmon_requests = 28;
357 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.received_trmon_requests_), 0, 0,
358 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
359 // uint64 sent_trmon = 29;
360 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.sent_trmon_), 0, 0,
361 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
362 // uint64 td_processing_us = 40;
363 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.td_processing_us_), 0, 0,
364 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
365 // uint64 fragment_processing_us = 41;
366 {PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.fragment_processing_us_), 0, 0,
367 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
368 }},
369 // no aux_entries
370 {{
371 }},
372};
373
375 ::uint8_t* target,
376 ::google::protobuf::io::EpsCopyOutputStream* stream) const {
377 // @@protoc_insertion_point(serialize_to_array_start:dunedaq.dfmodules.opmon.TRBInfo)
378 ::uint32_t cached_has_bits = 0;
379 (void)cached_has_bits;
380
381 // uint64 pending_trigger_decisions = 1;
382 if (this->_internal_pending_trigger_decisions() != 0) {
383 target = stream->EnsureSpace(target);
384 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
385 1, this->_internal_pending_trigger_decisions(), target);
386 }
387
388 // uint64 fragments_in_the_book = 2;
389 if (this->_internal_fragments_in_the_book() != 0) {
390 target = stream->EnsureSpace(target);
391 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
392 2, this->_internal_fragments_in_the_book(), target);
393 }
394
395 // uint64 pending_fragments = 3;
396 if (this->_internal_pending_fragments() != 0) {
397 target = stream->EnsureSpace(target);
398 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
399 3, this->_internal_pending_fragments(), target);
400 }
401
402 // uint64 received_trigger_decisions = 20;
403 if (this->_internal_received_trigger_decisions() != 0) {
404 target = stream->EnsureSpace(target);
405 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
406 20, this->_internal_received_trigger_decisions(), target);
407 }
408
409 // uint64 generated_trigger_records = 21;
410 if (this->_internal_generated_trigger_records() != 0) {
411 target = stream->EnsureSpace(target);
412 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
413 21, this->_internal_generated_trigger_records(), target);
414 }
415
416 // uint64 generated_data_requests = 22;
417 if (this->_internal_generated_data_requests() != 0) {
418 target = stream->EnsureSpace(target);
419 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
420 22, this->_internal_generated_data_requests(), target);
421 }
422
423 // uint64 received_fragments = 23;
424 if (this->_internal_received_fragments() != 0) {
425 target = stream->EnsureSpace(target);
426 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
427 23, this->_internal_received_fragments(), target);
428 }
429
430 // uint64 data_waiting_time = 25;
431 if (this->_internal_data_waiting_time() != 0) {
432 target = stream->EnsureSpace(target);
433 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
434 25, this->_internal_data_waiting_time(), target);
435 }
436
437 // uint64 data_request_width = 26;
438 if (this->_internal_data_request_width() != 0) {
439 target = stream->EnsureSpace(target);
440 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
441 26, this->_internal_data_request_width(), target);
442 }
443
444 // uint64 trigger_decision_width = 27;
445 if (this->_internal_trigger_decision_width() != 0) {
446 target = stream->EnsureSpace(target);
447 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
448 27, this->_internal_trigger_decision_width(), target);
449 }
450
451 // uint64 received_trmon_requests = 28;
452 if (this->_internal_received_trmon_requests() != 0) {
453 target = stream->EnsureSpace(target);
454 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
455 28, this->_internal_received_trmon_requests(), target);
456 }
457
458 // uint64 sent_trmon = 29;
459 if (this->_internal_sent_trmon() != 0) {
460 target = stream->EnsureSpace(target);
461 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
462 29, this->_internal_sent_trmon(), target);
463 }
464
465 // uint64 td_processing_us = 40;
466 if (this->_internal_td_processing_us() != 0) {
467 target = stream->EnsureSpace(target);
468 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
469 40, this->_internal_td_processing_us(), target);
470 }
471
472 // uint64 fragment_processing_us = 41;
473 if (this->_internal_fragment_processing_us() != 0) {
474 target = stream->EnsureSpace(target);
475 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
476 41, this->_internal_fragment_processing_us(), target);
477 }
478
479 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
480 target =
481 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
482 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
483 }
484 // @@protoc_insertion_point(serialize_to_array_end:dunedaq.dfmodules.opmon.TRBInfo)
485 return target;
486}
487
488::size_t TRBInfo::ByteSizeLong() const {
489// @@protoc_insertion_point(message_byte_size_start:dunedaq.dfmodules.opmon.TRBInfo)
490 ::size_t total_size = 0;
491
492 ::uint32_t cached_has_bits = 0;
493 // Prevent compiler warnings about cached_has_bits being unused
494 (void) cached_has_bits;
495
496 // uint64 pending_trigger_decisions = 1;
497 if (this->_internal_pending_trigger_decisions() != 0) {
498 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
500 }
501
502 // uint64 fragments_in_the_book = 2;
503 if (this->_internal_fragments_in_the_book() != 0) {
504 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
506 }
507
508 // uint64 pending_fragments = 3;
509 if (this->_internal_pending_fragments() != 0) {
510 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
512 }
513
514 // uint64 received_trigger_decisions = 20;
515 if (this->_internal_received_trigger_decisions() != 0) {
516 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
518 }
519
520 // uint64 generated_trigger_records = 21;
521 if (this->_internal_generated_trigger_records() != 0) {
522 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
524 }
525
526 // uint64 generated_data_requests = 22;
527 if (this->_internal_generated_data_requests() != 0) {
528 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
530 }
531
532 // uint64 received_fragments = 23;
533 if (this->_internal_received_fragments() != 0) {
534 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
536 }
537
538 // uint64 data_waiting_time = 25;
539 if (this->_internal_data_waiting_time() != 0) {
540 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
542 }
543
544 // uint64 data_request_width = 26;
545 if (this->_internal_data_request_width() != 0) {
546 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
548 }
549
550 // uint64 trigger_decision_width = 27;
551 if (this->_internal_trigger_decision_width() != 0) {
552 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
554 }
555
556 // uint64 received_trmon_requests = 28;
557 if (this->_internal_received_trmon_requests() != 0) {
558 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
560 }
561
562 // uint64 sent_trmon = 29;
563 if (this->_internal_sent_trmon() != 0) {
564 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
565 this->_internal_sent_trmon());
566 }
567
568 // uint64 td_processing_us = 40;
569 if (this->_internal_td_processing_us() != 0) {
570 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
572 }
573
574 // uint64 fragment_processing_us = 41;
575 if (this->_internal_fragment_processing_us() != 0) {
576 total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
578 }
579
580 return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
581}
582
583const ::google::protobuf::Message::ClassData TRBInfo::_class_data_ = {
584 ::google::protobuf::Message::CopyWithSourceCheck,
586};
587const ::google::protobuf::Message::ClassData*TRBInfo::GetClassData() const { return &_class_data_; }
588
589
590void TRBInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
591 auto* const _this = static_cast<TRBInfo*>(&to_msg);
592 auto& from = static_cast<const TRBInfo&>(from_msg);
593 // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.dfmodules.opmon.TRBInfo)
594 ABSL_DCHECK_NE(&from, _this);
595 ::uint32_t cached_has_bits = 0;
596 (void) cached_has_bits;
597
598 if (from._internal_pending_trigger_decisions() != 0) {
599 _this->_internal_set_pending_trigger_decisions(from._internal_pending_trigger_decisions());
600 }
601 if (from._internal_fragments_in_the_book() != 0) {
602 _this->_internal_set_fragments_in_the_book(from._internal_fragments_in_the_book());
603 }
604 if (from._internal_pending_fragments() != 0) {
605 _this->_internal_set_pending_fragments(from._internal_pending_fragments());
606 }
607 if (from._internal_received_trigger_decisions() != 0) {
608 _this->_internal_set_received_trigger_decisions(from._internal_received_trigger_decisions());
609 }
610 if (from._internal_generated_trigger_records() != 0) {
611 _this->_internal_set_generated_trigger_records(from._internal_generated_trigger_records());
612 }
613 if (from._internal_generated_data_requests() != 0) {
614 _this->_internal_set_generated_data_requests(from._internal_generated_data_requests());
615 }
616 if (from._internal_received_fragments() != 0) {
617 _this->_internal_set_received_fragments(from._internal_received_fragments());
618 }
619 if (from._internal_data_waiting_time() != 0) {
620 _this->_internal_set_data_waiting_time(from._internal_data_waiting_time());
621 }
622 if (from._internal_data_request_width() != 0) {
623 _this->_internal_set_data_request_width(from._internal_data_request_width());
624 }
625 if (from._internal_trigger_decision_width() != 0) {
626 _this->_internal_set_trigger_decision_width(from._internal_trigger_decision_width());
627 }
628 if (from._internal_received_trmon_requests() != 0) {
629 _this->_internal_set_received_trmon_requests(from._internal_received_trmon_requests());
630 }
631 if (from._internal_sent_trmon() != 0) {
632 _this->_internal_set_sent_trmon(from._internal_sent_trmon());
633 }
634 if (from._internal_td_processing_us() != 0) {
635 _this->_internal_set_td_processing_us(from._internal_td_processing_us());
636 }
637 if (from._internal_fragment_processing_us() != 0) {
638 _this->_internal_set_fragment_processing_us(from._internal_fragment_processing_us());
639 }
640 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
641}
642
643void TRBInfo::CopyFrom(const TRBInfo& from) {
644// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.dfmodules.opmon.TRBInfo)
645 if (&from == this) return;
646 Clear();
647 MergeFrom(from);
648}
649
650PROTOBUF_NOINLINE bool TRBInfo::IsInitialized() const {
651 return true;
652}
653
655 using std::swap;
656 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
657 ::google::protobuf::internal::memswap<
658 PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.fragment_processing_us_)
660 - PROTOBUF_FIELD_OFFSET(TRBInfo, _impl_.pending_trigger_decisions_)>(
661 reinterpret_cast<char*>(&_impl_.pending_trigger_decisions_),
662 reinterpret_cast<char*>(&other->_impl_.pending_trigger_decisions_));
663}
664
670// ===================================================================
671
673 public:
674};
675
676TRBErrors::TRBErrors(::google::protobuf::Arena* arena)
677 : ::google::protobuf::Message(arena) {
678 SharedCtor(arena);
679 // @@protoc_insertion_point(arena_constructor:dunedaq.dfmodules.opmon.TRBErrors)
680}
682 : ::google::protobuf::Message(), _impl_(from._impl_) {
683 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
684 from._internal_metadata_);
685 // @@protoc_insertion_point(copy_constructor:dunedaq.dfmodules.opmon.TRBErrors)
686}
687inline void TRBErrors::SharedCtor(::_pb::Arena* arena) {
688 (void)arena;
689 new (&_impl_) Impl_{
690 decltype(_impl_.timed_out_trigger_records_){::uint64_t{0u}},
691 decltype(_impl_.unexpected_fragments_){::uint64_t{0u}},
692 decltype(_impl_.unexpected_trigger_decisions_){::uint64_t{0u}},
693 decltype(_impl_.abandoned_trigger_records_){::uint64_t{0u}},
694 decltype(_impl_.lost_fragments_){::uint64_t{0u}},
695 decltype(_impl_.invalid_requests_){::uint64_t{0u}},
696 decltype(_impl_.duplicated_trigger_ids_){::uint64_t{0u}},
697 /*decltype(_impl_._cached_size_)*/ {},
698 };
699}
701 // @@protoc_insertion_point(destructor:dunedaq.dfmodules.opmon.TRBErrors)
702 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
703 SharedDtor();
704}
706 ABSL_DCHECK(GetArenaForAllocation() == nullptr);
707}
710}
711
712PROTOBUF_NOINLINE void TRBErrors::Clear() {
713// @@protoc_insertion_point(message_clear_start:dunedaq.dfmodules.opmon.TRBErrors)
714 ::uint32_t cached_has_bits = 0;
715 // Prevent compiler warnings about cached_has_bits being unused
716 (void) cached_has_bits;
717
718 ::memset(&_impl_.timed_out_trigger_records_, 0, static_cast<::size_t>(
719 reinterpret_cast<char*>(&_impl_.duplicated_trigger_ids_) -
720 reinterpret_cast<char*>(&_impl_.timed_out_trigger_records_)) + sizeof(_impl_.duplicated_trigger_ids_));
721 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
722}
723
725 const char* ptr, ::_pbi::ParseContext* ctx) {
726 ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
727 return ptr;
728}
729
730
731PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
732const ::_pbi::TcParseTable<3, 7, 0, 0, 2> TRBErrors::_table_ = {
733 {
734 0, // no _has_bits_
735 0, // no _extensions_
736 7, 56, // max_field_number, fast_idx_mask
737 offsetof(decltype(_table_), field_lookup_table),
738 4294967168, // skipmap
739 offsetof(decltype(_table_), field_entries),
740 7, // num_field_entries
741 0, // num_aux_entries
742 offsetof(decltype(_table_), field_names), // no aux_entries
744 ::_pbi::TcParser::GenericFallback, // fallback
745 }, {{
746 {::_pbi::TcParser::MiniParse, {}},
747 // uint64 timed_out_trigger_records = 1;
748 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.timed_out_trigger_records_), 63>(),
749 {8, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.timed_out_trigger_records_)}},
750 // uint64 unexpected_fragments = 2;
751 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.unexpected_fragments_), 63>(),
752 {16, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.unexpected_fragments_)}},
753 // uint64 unexpected_trigger_decisions = 3;
754 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.unexpected_trigger_decisions_), 63>(),
755 {24, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.unexpected_trigger_decisions_)}},
756 // uint64 abandoned_trigger_records = 4;
757 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.abandoned_trigger_records_), 63>(),
758 {32, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.abandoned_trigger_records_)}},
759 // uint64 lost_fragments = 5;
760 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.lost_fragments_), 63>(),
761 {40, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.lost_fragments_)}},
762 // uint64 invalid_requests = 6;
763 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.invalid_requests_), 63>(),
764 {48, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.invalid_requests_)}},
765 // uint64 duplicated_trigger_ids = 7;
766 {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TRBErrors, _impl_.duplicated_trigger_ids_), 63>(),
767 {56, 63, 0, PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.duplicated_trigger_ids_)}},
768 }}, {{
769 65535, 65535
770 }}, {{
771 // uint64 timed_out_trigger_records = 1;
772 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.timed_out_trigger_records_), 0, 0,
773 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
774 // uint64 unexpected_fragments = 2;
775 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.unexpected_fragments_), 0, 0,
776 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
777 // uint64 unexpected_trigger_decisions = 3;
778 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.unexpected_trigger_decisions_), 0, 0,
779 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
780 // uint64 abandoned_trigger_records = 4;
781 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.abandoned_trigger_records_), 0, 0,
782 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
783 // uint64 lost_fragments = 5;
784 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.lost_fragments_), 0, 0,
785 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
786 // uint64 invalid_requests = 6;
787 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.invalid_requests_), 0, 0,
788 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
789 // uint64 duplicated_trigger_ids = 7;
790 {PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.duplicated_trigger_ids_), 0, 0,
791 (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
792 }},
793 // no aux_entries
794 {{
795 }},
796};
797
799 ::uint8_t* target,
800 ::google::protobuf::io::EpsCopyOutputStream* stream) const {
801 // @@protoc_insertion_point(serialize_to_array_start:dunedaq.dfmodules.opmon.TRBErrors)
802 ::uint32_t cached_has_bits = 0;
803 (void)cached_has_bits;
804
805 // uint64 timed_out_trigger_records = 1;
806 if (this->_internal_timed_out_trigger_records() != 0) {
807 target = stream->EnsureSpace(target);
808 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
809 1, this->_internal_timed_out_trigger_records(), target);
810 }
811
812 // uint64 unexpected_fragments = 2;
813 if (this->_internal_unexpected_fragments() != 0) {
814 target = stream->EnsureSpace(target);
815 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
816 2, this->_internal_unexpected_fragments(), target);
817 }
818
819 // uint64 unexpected_trigger_decisions = 3;
821 target = stream->EnsureSpace(target);
822 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
823 3, this->_internal_unexpected_trigger_decisions(), target);
824 }
825
826 // uint64 abandoned_trigger_records = 4;
827 if (this->_internal_abandoned_trigger_records() != 0) {
828 target = stream->EnsureSpace(target);
829 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
830 4, this->_internal_abandoned_trigger_records(), target);
831 }
832
833 // uint64 lost_fragments = 5;
834 if (this->_internal_lost_fragments() != 0) {
835 target = stream->EnsureSpace(target);
836 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
837 5, this->_internal_lost_fragments(), target);
838 }
839
840 // uint64 invalid_requests = 6;
841 if (this->_internal_invalid_requests() != 0) {
842 target = stream->EnsureSpace(target);
843 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
844 6, this->_internal_invalid_requests(), target);
845 }
846
847 // uint64 duplicated_trigger_ids = 7;
848 if (this->_internal_duplicated_trigger_ids() != 0) {
849 target = stream->EnsureSpace(target);
850 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
851 7, this->_internal_duplicated_trigger_ids(), target);
852 }
853
854 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
855 target =
856 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
857 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
858 }
859 // @@protoc_insertion_point(serialize_to_array_end:dunedaq.dfmodules.opmon.TRBErrors)
860 return target;
861}
862
863::size_t TRBErrors::ByteSizeLong() const {
864// @@protoc_insertion_point(message_byte_size_start:dunedaq.dfmodules.opmon.TRBErrors)
865 ::size_t total_size = 0;
866
867 ::uint32_t cached_has_bits = 0;
868 // Prevent compiler warnings about cached_has_bits being unused
869 (void) cached_has_bits;
870
871 // uint64 timed_out_trigger_records = 1;
872 if (this->_internal_timed_out_trigger_records() != 0) {
873 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
875 }
876
877 // uint64 unexpected_fragments = 2;
878 if (this->_internal_unexpected_fragments() != 0) {
879 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
881 }
882
883 // uint64 unexpected_trigger_decisions = 3;
885 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
887 }
888
889 // uint64 abandoned_trigger_records = 4;
890 if (this->_internal_abandoned_trigger_records() != 0) {
891 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
893 }
894
895 // uint64 lost_fragments = 5;
896 if (this->_internal_lost_fragments() != 0) {
897 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
899 }
900
901 // uint64 invalid_requests = 6;
902 if (this->_internal_invalid_requests() != 0) {
903 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
905 }
906
907 // uint64 duplicated_trigger_ids = 7;
908 if (this->_internal_duplicated_trigger_ids() != 0) {
909 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
911 }
912
913 return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
914}
915
916const ::google::protobuf::Message::ClassData TRBErrors::_class_data_ = {
917 ::google::protobuf::Message::CopyWithSourceCheck,
919};
920const ::google::protobuf::Message::ClassData*TRBErrors::GetClassData() const { return &_class_data_; }
921
922
923void TRBErrors::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
924 auto* const _this = static_cast<TRBErrors*>(&to_msg);
925 auto& from = static_cast<const TRBErrors&>(from_msg);
926 // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.dfmodules.opmon.TRBErrors)
927 ABSL_DCHECK_NE(&from, _this);
928 ::uint32_t cached_has_bits = 0;
929 (void) cached_has_bits;
930
931 if (from._internal_timed_out_trigger_records() != 0) {
932 _this->_internal_set_timed_out_trigger_records(from._internal_timed_out_trigger_records());
933 }
934 if (from._internal_unexpected_fragments() != 0) {
935 _this->_internal_set_unexpected_fragments(from._internal_unexpected_fragments());
936 }
937 if (from._internal_unexpected_trigger_decisions() != 0) {
938 _this->_internal_set_unexpected_trigger_decisions(from._internal_unexpected_trigger_decisions());
939 }
940 if (from._internal_abandoned_trigger_records() != 0) {
941 _this->_internal_set_abandoned_trigger_records(from._internal_abandoned_trigger_records());
942 }
943 if (from._internal_lost_fragments() != 0) {
944 _this->_internal_set_lost_fragments(from._internal_lost_fragments());
945 }
946 if (from._internal_invalid_requests() != 0) {
947 _this->_internal_set_invalid_requests(from._internal_invalid_requests());
948 }
949 if (from._internal_duplicated_trigger_ids() != 0) {
950 _this->_internal_set_duplicated_trigger_ids(from._internal_duplicated_trigger_ids());
951 }
952 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
953}
954
956// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.dfmodules.opmon.TRBErrors)
957 if (&from == this) return;
958 Clear();
959 MergeFrom(from);
960}
961
962PROTOBUF_NOINLINE bool TRBErrors::IsInitialized() const {
963 return true;
964}
965
967 using std::swap;
968 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
969 ::google::protobuf::internal::memswap<
970 PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.duplicated_trigger_ids_)
972 - PROTOBUF_FIELD_OFFSET(TRBErrors, _impl_.timed_out_trigger_records_)>(
973 reinterpret_cast<char*>(&_impl_.timed_out_trigger_records_),
974 reinterpret_cast<char*>(&other->_impl_.timed_out_trigger_records_));
975}
976
982// @@protoc_insertion_point(namespace_scope)
983} // namespace opmon
984} // namespace dfmodules
985} // namespace dunedaq
986namespace google {
987namespace protobuf {
988} // namespace protobuf
989} // namespace google
990// @@protoc_insertion_point(global_scope)
991#include "google/protobuf/port_undef.inc"
::absl::once_flag descriptor_table_dfmodules_2fopmon_2fTRBModule_2eproto_once
static constexprconst ::_pb::EnumDescriptor ** file_level_enum_descriptors_dfmodules_2fopmon_2fTRBModule_2eproto
::_pb::Metadata file_level_metadata_dfmodules_2fopmon_2fTRBModule_2eproto[2]
const ::_pbi::DescriptorTable descriptor_table_dfmodules_2fopmon_2fTRBModule_2eproto
PROTOBUF_ATTRIBUTE_WEAKconst ::_pbi::DescriptorTable * descriptor_table_dfmodules_2fopmon_2fTRBModule_2eproto_getter()
static constexprconst ::_pb::ServiceDescriptor ** file_level_service_descriptors_dfmodules_2fopmon_2fTRBModule_2eproto
::uint64_t _internal_abandoned_trigger_records() const
void MergeFrom(const TRBErrors &from)
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
::uint64_t _internal_duplicated_trigger_ids() const
::uint64_t _internal_unexpected_fragments() const
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
void SharedCtor(::google::protobuf::Arena *arena)
::size_t ByteSizeLong() const final
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
void InternalSwap(TRBErrors *other)
void CopyFrom(const TRBErrors &from)
static const ClassData _class_data_
::uint64_t _internal_invalid_requests() const
void SetCachedSize(int size) const final
::uint64_t _internal_timed_out_trigger_records() const
static const ::google::protobuf::internal::TcParseTable< 3, 7, 0, 0, 2 > _table_
::google::protobuf::Metadata GetMetadata() const final
::uint64_t _internal_lost_fragments() const
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
const ::google::protobuf::Message::ClassData * GetClassData() const final
::uint64_t _internal_unexpected_trigger_decisions() const
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
void CopyFrom(const TRBInfo &from)
::uint64_t _internal_fragment_processing_us() const
::uint64_t _internal_trigger_decision_width() const
static const ::google::protobuf::internal::TcParseTable< 4, 14, 0, 0, 7 > _table_
void MergeFrom(const TRBInfo &from)
::uint64_t _internal_received_trigger_decisions() const
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
::uint64_t _internal_data_request_width() const
void SetCachedSize(int size) const final
::uint64_t _internal_data_waiting_time() const
::uint64_t _internal_generated_trigger_records() const
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
::uint64_t _internal_pending_trigger_decisions() const
::size_t ByteSizeLong() const final
::uint64_t _internal_pending_fragments() const
const ::google::protobuf::Message::ClassData * GetClassData() const final
void SharedCtor(::google::protobuf::Arena *arena)
::uint64_t _internal_received_fragments() const
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
::uint64_t _internal_received_trmon_requests() const
::google::protobuf::Metadata GetMetadata() const final
::uint64_t _internal_sent_trmon() const
::uint64_t _internal_fragments_in_the_book() const
static const ClassData _class_data_
::uint64_t _internal_generated_data_requests() const
::uint64_t _internal_td_processing_us() const
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TRBInfoDefaultTypeInternal _TRBInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TRBErrorsDefaultTypeInternal _TRBErrors_default_instance_
The DUNE-DAQ namespace.
Definition DataStore.hpp:57
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
mutable::google::protobuf::internal::CachedSize _cached_size_
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[]
Definition wib.pb.cc:1192