DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
datahandling_info.pb.h
Go to the documentation of this file.
1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: datahandlinglibs/opmon/datahandling_info.proto
3
4#ifndef GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh
5#define GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh
6
7#include <limits>
8#include <string>
9#include <type_traits>
10
11#include "google/protobuf/port_def.inc"
12#if PROTOBUF_VERSION < 4024000
13#error "This file was generated by a newer version of protoc which is"
14#error "incompatible with your Protocol Buffer headers. Please update"
15#error "your headers."
16#endif // PROTOBUF_VERSION
17
18#if 4024004 < PROTOBUF_MIN_PROTOC_VERSION
19#error "This file was generated by an older version of protoc which is"
20#error "incompatible with your Protocol Buffer headers. Please"
21#error "regenerate this file with a newer version of protoc."
22#endif // PROTOBUF_MIN_PROTOC_VERSION
23#include "google/protobuf/port_undef.inc"
24#include "google/protobuf/io/coded_stream.h"
25#include "google/protobuf/arena.h"
26#include "google/protobuf/arenastring.h"
27#include "google/protobuf/generated_message_tctable_decl.h"
28#include "google/protobuf/generated_message_util.h"
29#include "google/protobuf/metadata_lite.h"
30#include "google/protobuf/generated_message_reflection.h"
31#include "google/protobuf/message.h"
32#include "google/protobuf/repeated_field.h" // IWYU pragma: export
33#include "google/protobuf/extension_set.h" // IWYU pragma: export
34#include "google/protobuf/unknown_field_set.h"
35// @@protoc_insertion_point(includes)
36
37// Must be included last.
38#include "google/protobuf/port_def.inc"
39
40#define PROTOBUF_INTERNAL_EXPORT_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
41
42namespace google {
43namespace protobuf {
44namespace internal {
45class AnyMetadata;
46} // namespace internal
47} // namespace protobuf
48} // namespace google
49
50// Internal implementation detail -- do not use these members.
54extern const ::google::protobuf::internal::DescriptorTable
55 descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
56namespace dunedaq {
57namespace datahandlinglibs {
58namespace opmon {
59class DataHandlerInfo;
60struct DataHandlerInfoDefaultTypeInternal;
61extern DataHandlerInfoDefaultTypeInternal _DataHandlerInfo_default_instance_;
62class DataProcessorInfo;
63struct DataProcessorInfoDefaultTypeInternal;
64extern DataProcessorInfoDefaultTypeInternal _DataProcessorInfo_default_instance_;
65class DataSourceInfo;
66struct DataSourceInfoDefaultTypeInternal;
67extern DataSourceInfoDefaultTypeInternal _DataSourceInfo_default_instance_;
68class FixedRateDataProcessorInfo;
69struct FixedRateDataProcessorInfoDefaultTypeInternal;
70extern FixedRateDataProcessorInfoDefaultTypeInternal _FixedRateDataProcessorInfo_default_instance_;
71class HitFindingInfo;
72struct HitFindingInfoDefaultTypeInternal;
73extern HitFindingInfoDefaultTypeInternal _HitFindingInfo_default_instance_;
74class LatencyBufferInfo;
75struct LatencyBufferInfoDefaultTypeInternal;
76extern LatencyBufferInfoDefaultTypeInternal _LatencyBufferInfo_default_instance_;
77class RecordingInfo;
78struct RecordingInfoDefaultTypeInternal;
79extern RecordingInfoDefaultTypeInternal _RecordingInfo_default_instance_;
80class RequestHandlerInfo;
81struct RequestHandlerInfoDefaultTypeInternal;
82extern RequestHandlerInfoDefaultTypeInternal _RequestHandlerInfo_default_instance_;
83class TPChannelInfo;
84struct TPChannelInfoDefaultTypeInternal;
85extern TPChannelInfoDefaultTypeInternal _TPChannelInfo_default_instance_;
86class TPGProcessorInfo;
87struct TPGProcessorInfoDefaultTypeInternal;
88extern TPGProcessorInfoDefaultTypeInternal _TPGProcessorInfo_default_instance_;
89class TPGProcessorReducedInfo;
90struct TPGProcessorReducedInfoDefaultTypeInternal;
91extern TPGProcessorReducedInfoDefaultTypeInternal _TPGProcessorReducedInfo_default_instance_;
92} // namespace opmon
93} // namespace datahandlinglibs
94} // namespace dunedaq
95namespace google {
96namespace protobuf {
97} // namespace protobuf
98} // namespace google
99
100namespace dunedaq {
101namespace datahandlinglibs {
102namespace opmon {
103
104// ===================================================================
105
106
107// -------------------------------------------------------------------
108
109class LatencyBufferInfo final :
110 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo) */ {
111 public:
112 inline LatencyBufferInfo() : LatencyBufferInfo(nullptr) {}
113 ~LatencyBufferInfo() override;
114 template<typename = void>
115 explicit PROTOBUF_CONSTEXPR LatencyBufferInfo(::google::protobuf::internal::ConstantInitialized);
116
117 LatencyBufferInfo(const LatencyBufferInfo& from);
118 LatencyBufferInfo(LatencyBufferInfo&& from) noexcept
119 : LatencyBufferInfo() {
120 *this = ::std::move(from);
121 }
122
123 inline LatencyBufferInfo& operator=(const LatencyBufferInfo& from) {
124 CopyFrom(from);
125 return *this;
126 }
127 inline LatencyBufferInfo& operator=(LatencyBufferInfo&& from) noexcept {
128 if (this == &from) return *this;
129 if (GetOwningArena() == from.GetOwningArena()
130 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
131 && GetOwningArena() != nullptr
132 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
133 ) {
134 InternalSwap(&from);
135 } else {
136 CopyFrom(from);
137 }
138 return *this;
139 }
140
141 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
142 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
143 }
144 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
145 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
146 }
147
148 static const ::google::protobuf::Descriptor* descriptor() {
149 return GetDescriptor();
150 }
151 static const ::google::protobuf::Descriptor* GetDescriptor() {
152 return default_instance().GetMetadata().descriptor;
153 }
154 static const ::google::protobuf::Reflection* GetReflection() {
155 return default_instance().GetMetadata().reflection;
156 }
157 static const LatencyBufferInfo& default_instance() {
158 return *internal_default_instance();
159 }
160 static inline const LatencyBufferInfo* internal_default_instance() {
161 return reinterpret_cast<const LatencyBufferInfo*>(
162 &_LatencyBufferInfo_default_instance_);
163 }
164 static constexpr int kIndexInFileMessages =
165 0;
166
167 friend void swap(LatencyBufferInfo& a, LatencyBufferInfo& b) {
168 a.Swap(&b);
169 }
170 inline void Swap(LatencyBufferInfo* other) {
171 if (other == this) return;
172 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
173 if (GetOwningArena() != nullptr &&
174 GetOwningArena() == other->GetOwningArena()) {
175 #else // PROTOBUF_FORCE_COPY_IN_SWAP
176 if (GetOwningArena() == other->GetOwningArena()) {
177 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
178 InternalSwap(other);
179 } else {
180 ::google::protobuf::internal::GenericSwap(this, other);
181 }
182 }
183 void UnsafeArenaSwap(LatencyBufferInfo* other) {
184 if (other == this) return;
185 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
186 InternalSwap(other);
187 }
188
189 // implements Message ----------------------------------------------
190
191 LatencyBufferInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
192 return CreateMaybeMessage<LatencyBufferInfo>(arena);
193 }
194 using ::google::protobuf::Message::CopyFrom;
195 void CopyFrom(const LatencyBufferInfo& from);
196 using ::google::protobuf::Message::MergeFrom;
197 void MergeFrom( const LatencyBufferInfo& from) {
198 LatencyBufferInfo::MergeImpl(*this, from);
199 }
200 private:
201 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
202 public:
203 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
204 bool IsInitialized() const final;
205
206 ::size_t ByteSizeLong() const final;
207 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
208 ::uint8_t* _InternalSerialize(
209 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
210 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
211
212 private:
213 void SharedCtor(::google::protobuf::Arena* arena);
214 void SharedDtor();
215 void SetCachedSize(int size) const final;
216 void InternalSwap(LatencyBufferInfo* other);
217
218 private:
219 friend class ::google::protobuf::internal::AnyMetadata;
220 static ::absl::string_view FullMessageName() {
221 return "dunedaq.datahandlinglibs.opmon.LatencyBufferInfo";
222 }
223 protected:
224 explicit LatencyBufferInfo(::google::protobuf::Arena* arena);
225 public:
226
227 static const ClassData _class_data_;
228 const ::google::protobuf::Message::ClassData*GetClassData() const final;
229
230 ::google::protobuf::Metadata GetMetadata() const final;
231
232 // nested types ----------------------------------------------------
233
234 // accessors -------------------------------------------------------
235
236 enum : int {
237 kNumBufferElementsFieldNumber = 1,
238 };
239 // uint64 num_buffer_elements = 1;
240 void clear_num_buffer_elements() ;
241 ::uint64_t num_buffer_elements() const;
242 void set_num_buffer_elements(::uint64_t value);
243
244 private:
245 ::uint64_t _internal_num_buffer_elements() const;
246 void _internal_set_num_buffer_elements(::uint64_t value);
247
248 public:
249 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
250 private:
251 class _Internal;
252
253 friend class ::google::protobuf::internal::TcParser;
254 static const ::google::protobuf::internal::TcParseTable<0, 1, 0, 0, 2> _table_;
255 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
256 typedef void InternalArenaConstructable_;
257 typedef void DestructorSkippable_;
258 struct Impl_ {
259 ::uint64_t num_buffer_elements_;
260 mutable ::google::protobuf::internal::CachedSize _cached_size_;
261 PROTOBUF_TSAN_DECLARE_MEMBER
262 };
263 union { Impl_ _impl_; };
264 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
265};// -------------------------------------------------------------------
266
267class DataSourceInfo final :
268 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataSourceInfo) */ {
269 public:
270 inline DataSourceInfo() : DataSourceInfo(nullptr) {}
271 ~DataSourceInfo() override;
272 template<typename = void>
273 explicit PROTOBUF_CONSTEXPR DataSourceInfo(::google::protobuf::internal::ConstantInitialized);
274
275 DataSourceInfo(const DataSourceInfo& from);
276 DataSourceInfo(DataSourceInfo&& from) noexcept
277 : DataSourceInfo() {
278 *this = ::std::move(from);
279 }
280
281 inline DataSourceInfo& operator=(const DataSourceInfo& from) {
282 CopyFrom(from);
283 return *this;
284 }
285 inline DataSourceInfo& operator=(DataSourceInfo&& from) noexcept {
286 if (this == &from) return *this;
287 if (GetOwningArena() == from.GetOwningArena()
288 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
289 && GetOwningArena() != nullptr
290 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
291 ) {
292 InternalSwap(&from);
293 } else {
294 CopyFrom(from);
295 }
296 return *this;
297 }
298
299 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
300 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
301 }
302 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
303 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
304 }
305
306 static const ::google::protobuf::Descriptor* descriptor() {
307 return GetDescriptor();
308 }
309 static const ::google::protobuf::Descriptor* GetDescriptor() {
310 return default_instance().GetMetadata().descriptor;
311 }
312 static const ::google::protobuf::Reflection* GetReflection() {
313 return default_instance().GetMetadata().reflection;
314 }
315 static const DataSourceInfo& default_instance() {
316 return *internal_default_instance();
317 }
318 static inline const DataSourceInfo* internal_default_instance() {
319 return reinterpret_cast<const DataSourceInfo*>(
320 &_DataSourceInfo_default_instance_);
321 }
322 static constexpr int kIndexInFileMessages =
323 1;
324
325 friend void swap(DataSourceInfo& a, DataSourceInfo& b) {
326 a.Swap(&b);
327 }
328 inline void Swap(DataSourceInfo* other) {
329 if (other == this) return;
330 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
331 if (GetOwningArena() != nullptr &&
332 GetOwningArena() == other->GetOwningArena()) {
333 #else // PROTOBUF_FORCE_COPY_IN_SWAP
334 if (GetOwningArena() == other->GetOwningArena()) {
335 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
336 InternalSwap(other);
337 } else {
338 ::google::protobuf::internal::GenericSwap(this, other);
339 }
340 }
341 void UnsafeArenaSwap(DataSourceInfo* other) {
342 if (other == this) return;
343 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
344 InternalSwap(other);
345 }
346
347 // implements Message ----------------------------------------------
348
349 DataSourceInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
350 return CreateMaybeMessage<DataSourceInfo>(arena);
351 }
352 using ::google::protobuf::Message::CopyFrom;
353 void CopyFrom(const DataSourceInfo& from);
354 using ::google::protobuf::Message::MergeFrom;
355 void MergeFrom( const DataSourceInfo& from) {
356 DataSourceInfo::MergeImpl(*this, from);
357 }
358 private:
359 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
360 public:
361 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
362 bool IsInitialized() const final;
363
364 ::size_t ByteSizeLong() const final;
365 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
366 ::uint8_t* _InternalSerialize(
367 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
368 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
369
370 private:
371 void SharedCtor(::google::protobuf::Arena* arena);
372 void SharedDtor();
373 void SetCachedSize(int size) const final;
374 void InternalSwap(DataSourceInfo* other);
375
376 private:
377 friend class ::google::protobuf::internal::AnyMetadata;
378 static ::absl::string_view FullMessageName() {
379 return "dunedaq.datahandlinglibs.opmon.DataSourceInfo";
380 }
381 protected:
382 explicit DataSourceInfo(::google::protobuf::Arena* arena);
383 public:
384
385 static const ClassData _class_data_;
386 const ::google::protobuf::Message::ClassData*GetClassData() const final;
387
388 ::google::protobuf::Metadata GetMetadata() const final;
389
390 // nested types ----------------------------------------------------
391
392 // accessors -------------------------------------------------------
393
394 enum : int {
395 kSumPacketsFieldNumber = 1,
396 kNumPacketsFieldNumber = 2,
397 kNumDroppedPacketsFieldNumber = 3,
398 };
399 // uint64 sum_packets = 1;
400 void clear_sum_packets() ;
401 ::uint64_t sum_packets() const;
402 void set_sum_packets(::uint64_t value);
403
404 private:
405 ::uint64_t _internal_sum_packets() const;
406 void _internal_set_sum_packets(::uint64_t value);
407
408 public:
409 // uint64 num_packets = 2;
410 void clear_num_packets() ;
411 ::uint64_t num_packets() const;
412 void set_num_packets(::uint64_t value);
413
414 private:
415 ::uint64_t _internal_num_packets() const;
416 void _internal_set_num_packets(::uint64_t value);
417
418 public:
419 // uint64 num_dropped_packets = 3;
420 void clear_num_dropped_packets() ;
421 ::uint64_t num_dropped_packets() const;
422 void set_num_dropped_packets(::uint64_t value);
423
424 private:
425 ::uint64_t _internal_num_dropped_packets() const;
426 void _internal_set_num_dropped_packets(::uint64_t value);
427
428 public:
429 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
430 private:
431 class _Internal;
432
433 friend class ::google::protobuf::internal::TcParser;
434 static const ::google::protobuf::internal::TcParseTable<2, 3, 0, 0, 2> _table_;
435 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
436 typedef void InternalArenaConstructable_;
437 typedef void DestructorSkippable_;
438 struct Impl_ {
439 ::uint64_t sum_packets_;
440 ::uint64_t num_packets_;
441 ::uint64_t num_dropped_packets_;
442 mutable ::google::protobuf::internal::CachedSize _cached_size_;
443 PROTOBUF_TSAN_DECLARE_MEMBER
444 };
445 union { Impl_ _impl_; };
446 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
447};// -------------------------------------------------------------------
448
449class DataHandlerInfo final :
450 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataHandlerInfo) */ {
451 public:
452 inline DataHandlerInfo() : DataHandlerInfo(nullptr) {}
453 ~DataHandlerInfo() override;
454 template<typename = void>
455 explicit PROTOBUF_CONSTEXPR DataHandlerInfo(::google::protobuf::internal::ConstantInitialized);
456
457 DataHandlerInfo(const DataHandlerInfo& from);
458 DataHandlerInfo(DataHandlerInfo&& from) noexcept
459 : DataHandlerInfo() {
460 *this = ::std::move(from);
461 }
462
463 inline DataHandlerInfo& operator=(const DataHandlerInfo& from) {
464 CopyFrom(from);
465 return *this;
466 }
467 inline DataHandlerInfo& operator=(DataHandlerInfo&& from) noexcept {
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 }
480
481 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
482 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
483 }
484 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
485 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
486 }
487
488 static const ::google::protobuf::Descriptor* descriptor() {
489 return GetDescriptor();
490 }
491 static const ::google::protobuf::Descriptor* GetDescriptor() {
492 return default_instance().GetMetadata().descriptor;
493 }
494 static const ::google::protobuf::Reflection* GetReflection() {
495 return default_instance().GetMetadata().reflection;
496 }
497 static const DataHandlerInfo& default_instance() {
498 return *internal_default_instance();
499 }
500 static inline const DataHandlerInfo* internal_default_instance() {
501 return reinterpret_cast<const DataHandlerInfo*>(
502 &_DataHandlerInfo_default_instance_);
503 }
504 static constexpr int kIndexInFileMessages =
505 2;
506
507 friend void swap(DataHandlerInfo& a, DataHandlerInfo& b) {
508 a.Swap(&b);
509 }
510 inline void Swap(DataHandlerInfo* other) {
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 }
523 void UnsafeArenaSwap(DataHandlerInfo* other) {
524 if (other == this) return;
525 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
526 InternalSwap(other);
527 }
528
529 // implements Message ----------------------------------------------
530
531 DataHandlerInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
532 return CreateMaybeMessage<DataHandlerInfo>(arena);
533 }
534 using ::google::protobuf::Message::CopyFrom;
535 void CopyFrom(const DataHandlerInfo& from);
536 using ::google::protobuf::Message::MergeFrom;
537 void MergeFrom( const DataHandlerInfo& from) {
538 DataHandlerInfo::MergeImpl(*this, from);
539 }
540 private:
541 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
542 public:
543 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
544 bool IsInitialized() const final;
545
546 ::size_t ByteSizeLong() const final;
547 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
548 ::uint8_t* _InternalSerialize(
549 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
550 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
551
552 private:
553 void SharedCtor(::google::protobuf::Arena* arena);
554 void SharedDtor();
555 void SetCachedSize(int size) const final;
556 void InternalSwap(DataHandlerInfo* other);
557
558 private:
559 friend class ::google::protobuf::internal::AnyMetadata;
560 static ::absl::string_view FullMessageName() {
561 return "dunedaq.datahandlinglibs.opmon.DataHandlerInfo";
562 }
563 protected:
564 explicit DataHandlerInfo(::google::protobuf::Arena* arena);
565 public:
566
567 static const ClassData _class_data_;
568 const ::google::protobuf::Message::ClassData*GetClassData() const final;
569
570 ::google::protobuf::Metadata GetMetadata() const final;
571
572 // nested types ----------------------------------------------------
573
574 // accessors -------------------------------------------------------
575
576 enum : int {
577 kSumPayloadsFieldNumber = 1,
578 kNumPayloadsFieldNumber = 2,
579 kNumDataInputTimeoutsFieldNumber = 3,
580 kRatePayloadsConsumedFieldNumber = 4,
581 kNumLbInsertFailuresFieldNumber = 5,
582 kSumRequestsFieldNumber = 11,
583 kNumRequestsFieldNumber = 12,
584 kLastDaqTimestampFieldNumber = 21,
585 kNewestTimestampFieldNumber = 22,
586 kOldestTimestampFieldNumber = 23,
587 kNumPostProcessingDelayMaxWaitsFieldNumber = 31,
588 };
589 // uint64 sum_payloads = 1;
590 void clear_sum_payloads() ;
591 ::uint64_t sum_payloads() const;
592 void set_sum_payloads(::uint64_t value);
593
594 private:
595 ::uint64_t _internal_sum_payloads() const;
596 void _internal_set_sum_payloads(::uint64_t value);
597
598 public:
599 // uint64 num_payloads = 2;
600 void clear_num_payloads() ;
601 ::uint64_t num_payloads() const;
602 void set_num_payloads(::uint64_t value);
603
604 private:
605 ::uint64_t _internal_num_payloads() const;
606 void _internal_set_num_payloads(::uint64_t value);
607
608 public:
609 // uint64 num_data_input_timeouts = 3;
610 void clear_num_data_input_timeouts() ;
611 ::uint64_t num_data_input_timeouts() const;
612 void set_num_data_input_timeouts(::uint64_t value);
613
614 private:
615 ::uint64_t _internal_num_data_input_timeouts() const;
616 void _internal_set_num_data_input_timeouts(::uint64_t value);
617
618 public:
619 // double rate_payloads_consumed = 4;
620 void clear_rate_payloads_consumed() ;
621 double rate_payloads_consumed() const;
622 void set_rate_payloads_consumed(double value);
623
624 private:
625 double _internal_rate_payloads_consumed() const;
626 void _internal_set_rate_payloads_consumed(double value);
627
628 public:
629 // uint64 num_lb_insert_failures = 5;
630 void clear_num_lb_insert_failures() ;
631 ::uint64_t num_lb_insert_failures() const;
632 void set_num_lb_insert_failures(::uint64_t value);
633
634 private:
635 ::uint64_t _internal_num_lb_insert_failures() const;
636 void _internal_set_num_lb_insert_failures(::uint64_t value);
637
638 public:
639 // uint64 sum_requests = 11;
640 void clear_sum_requests() ;
641 ::uint64_t sum_requests() const;
642 void set_sum_requests(::uint64_t value);
643
644 private:
645 ::uint64_t _internal_sum_requests() const;
646 void _internal_set_sum_requests(::uint64_t value);
647
648 public:
649 // uint64 num_requests = 12;
650 void clear_num_requests() ;
651 ::uint64_t num_requests() const;
652 void set_num_requests(::uint64_t value);
653
654 private:
655 ::uint64_t _internal_num_requests() const;
656 void _internal_set_num_requests(::uint64_t value);
657
658 public:
659 // uint64 last_daq_timestamp = 21;
660 void clear_last_daq_timestamp() ;
661 ::uint64_t last_daq_timestamp() const;
662 void set_last_daq_timestamp(::uint64_t value);
663
664 private:
665 ::uint64_t _internal_last_daq_timestamp() const;
666 void _internal_set_last_daq_timestamp(::uint64_t value);
667
668 public:
669 // uint64 newest_timestamp = 22;
670 void clear_newest_timestamp() ;
671 ::uint64_t newest_timestamp() const;
672 void set_newest_timestamp(::uint64_t value);
673
674 private:
675 ::uint64_t _internal_newest_timestamp() const;
676 void _internal_set_newest_timestamp(::uint64_t value);
677
678 public:
679 // uint64 oldest_timestamp = 23;
680 void clear_oldest_timestamp() ;
681 ::uint64_t oldest_timestamp() const;
682 void set_oldest_timestamp(::uint64_t value);
683
684 private:
685 ::uint64_t _internal_oldest_timestamp() const;
686 void _internal_set_oldest_timestamp(::uint64_t value);
687
688 public:
689 // uint64 num_post_processing_delay_max_waits = 31;
690 void clear_num_post_processing_delay_max_waits() ;
691 ::uint64_t num_post_processing_delay_max_waits() const;
692 void set_num_post_processing_delay_max_waits(::uint64_t value);
693
694 private:
695 ::uint64_t _internal_num_post_processing_delay_max_waits() const;
696 void _internal_set_num_post_processing_delay_max_waits(::uint64_t value);
697
698 public:
699 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
700 private:
701 class _Internal;
702
703 friend class ::google::protobuf::internal::TcParser;
704 static const ::google::protobuf::internal::TcParseTable<4, 11, 0, 0, 2> _table_;
705 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
706 typedef void InternalArenaConstructable_;
707 typedef void DestructorSkippable_;
708 struct Impl_ {
709 ::uint64_t sum_payloads_;
710 ::uint64_t num_payloads_;
711 ::uint64_t num_data_input_timeouts_;
712 double rate_payloads_consumed_;
713 ::uint64_t num_lb_insert_failures_;
714 ::uint64_t sum_requests_;
715 ::uint64_t num_requests_;
716 ::uint64_t last_daq_timestamp_;
717 ::uint64_t newest_timestamp_;
718 ::uint64_t oldest_timestamp_;
719 ::uint64_t num_post_processing_delay_max_waits_;
720 mutable ::google::protobuf::internal::CachedSize _cached_size_;
721 PROTOBUF_TSAN_DECLARE_MEMBER
722 };
723 union { Impl_ _impl_; };
724 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
725};// -------------------------------------------------------------------
726
727class RequestHandlerInfo final :
728 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo) */ {
729 public:
730 inline RequestHandlerInfo() : RequestHandlerInfo(nullptr) {}
731 ~RequestHandlerInfo() override;
732 template<typename = void>
733 explicit PROTOBUF_CONSTEXPR RequestHandlerInfo(::google::protobuf::internal::ConstantInitialized);
734
735 RequestHandlerInfo(const RequestHandlerInfo& from);
736 RequestHandlerInfo(RequestHandlerInfo&& from) noexcept
737 : RequestHandlerInfo() {
738 *this = ::std::move(from);
739 }
740
741 inline RequestHandlerInfo& operator=(const RequestHandlerInfo& from) {
742 CopyFrom(from);
743 return *this;
744 }
745 inline RequestHandlerInfo& operator=(RequestHandlerInfo&& from) noexcept {
746 if (this == &from) return *this;
747 if (GetOwningArena() == from.GetOwningArena()
748 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
749 && GetOwningArena() != nullptr
750 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
751 ) {
752 InternalSwap(&from);
753 } else {
754 CopyFrom(from);
755 }
756 return *this;
757 }
758
759 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
760 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
761 }
762 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
763 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
764 }
765
766 static const ::google::protobuf::Descriptor* descriptor() {
767 return GetDescriptor();
768 }
769 static const ::google::protobuf::Descriptor* GetDescriptor() {
770 return default_instance().GetMetadata().descriptor;
771 }
772 static const ::google::protobuf::Reflection* GetReflection() {
773 return default_instance().GetMetadata().reflection;
774 }
775 static const RequestHandlerInfo& default_instance() {
776 return *internal_default_instance();
777 }
778 static inline const RequestHandlerInfo* internal_default_instance() {
779 return reinterpret_cast<const RequestHandlerInfo*>(
780 &_RequestHandlerInfo_default_instance_);
781 }
782 static constexpr int kIndexInFileMessages =
783 3;
784
785 friend void swap(RequestHandlerInfo& a, RequestHandlerInfo& b) {
786 a.Swap(&b);
787 }
788 inline void Swap(RequestHandlerInfo* other) {
789 if (other == this) return;
790 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
791 if (GetOwningArena() != nullptr &&
792 GetOwningArena() == other->GetOwningArena()) {
793 #else // PROTOBUF_FORCE_COPY_IN_SWAP
794 if (GetOwningArena() == other->GetOwningArena()) {
795 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
796 InternalSwap(other);
797 } else {
798 ::google::protobuf::internal::GenericSwap(this, other);
799 }
800 }
801 void UnsafeArenaSwap(RequestHandlerInfo* other) {
802 if (other == this) return;
803 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
804 InternalSwap(other);
805 }
806
807 // implements Message ----------------------------------------------
808
809 RequestHandlerInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
810 return CreateMaybeMessage<RequestHandlerInfo>(arena);
811 }
812 using ::google::protobuf::Message::CopyFrom;
813 void CopyFrom(const RequestHandlerInfo& from);
814 using ::google::protobuf::Message::MergeFrom;
815 void MergeFrom( const RequestHandlerInfo& from) {
816 RequestHandlerInfo::MergeImpl(*this, from);
817 }
818 private:
819 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
820 public:
821 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
822 bool IsInitialized() const final;
823
824 ::size_t ByteSizeLong() const final;
825 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
826 ::uint8_t* _InternalSerialize(
827 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
828 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
829
830 private:
831 void SharedCtor(::google::protobuf::Arena* arena);
832 void SharedDtor();
833 void SetCachedSize(int size) const final;
834 void InternalSwap(RequestHandlerInfo* other);
835
836 private:
837 friend class ::google::protobuf::internal::AnyMetadata;
838 static ::absl::string_view FullMessageName() {
839 return "dunedaq.datahandlinglibs.opmon.RequestHandlerInfo";
840 }
841 protected:
842 explicit RequestHandlerInfo(::google::protobuf::Arena* arena);
843 public:
844
845 static const ClassData _class_data_;
846 const ::google::protobuf::Message::ClassData*GetClassData() const final;
847
848 ::google::protobuf::Metadata GetMetadata() const final;
849
850 // nested types ----------------------------------------------------
851
852 // accessors -------------------------------------------------------
853
854 enum : int {
855 kNumRequestsHandledFieldNumber = 1,
856 kNumRequestsFoundFieldNumber = 2,
857 kNumRequestsBadFieldNumber = 3,
858 kNumRequestsOldWindowFieldNumber = 4,
859 kNumRequestsDelayedFieldNumber = 5,
860 kNumRequestsUncategorizedFieldNumber = 6,
861 kNumRequestsTimedOutFieldNumber = 7,
862 kNumRequestsWaitingFieldNumber = 8,
863 kAvgRequestResponseTimeFieldNumber = 21,
864 kTotRequestResponseTimeFieldNumber = 22,
865 kMinRequestResponseTimeFieldNumber = 23,
866 kMaxRequestResponseTimeFieldNumber = 24,
867 kNumBufferCleanupsFieldNumber = 31,
868 kNumPeriodicSentFieldNumber = 41,
869 kNumPeriodicSendFailedFieldNumber = 42,
870 };
871 // uint64 num_requests_handled = 1;
872 void clear_num_requests_handled() ;
873 ::uint64_t num_requests_handled() const;
874 void set_num_requests_handled(::uint64_t value);
875
876 private:
877 ::uint64_t _internal_num_requests_handled() const;
878 void _internal_set_num_requests_handled(::uint64_t value);
879
880 public:
881 // uint64 num_requests_found = 2;
882 void clear_num_requests_found() ;
883 ::uint64_t num_requests_found() const;
884 void set_num_requests_found(::uint64_t value);
885
886 private:
887 ::uint64_t _internal_num_requests_found() const;
888 void _internal_set_num_requests_found(::uint64_t value);
889
890 public:
891 // uint64 num_requests_bad = 3;
892 void clear_num_requests_bad() ;
893 ::uint64_t num_requests_bad() const;
894 void set_num_requests_bad(::uint64_t value);
895
896 private:
897 ::uint64_t _internal_num_requests_bad() const;
898 void _internal_set_num_requests_bad(::uint64_t value);
899
900 public:
901 // uint64 num_requests_old_window = 4;
902 void clear_num_requests_old_window() ;
903 ::uint64_t num_requests_old_window() const;
904 void set_num_requests_old_window(::uint64_t value);
905
906 private:
907 ::uint64_t _internal_num_requests_old_window() const;
908 void _internal_set_num_requests_old_window(::uint64_t value);
909
910 public:
911 // uint64 num_requests_delayed = 5;
912 void clear_num_requests_delayed() ;
913 ::uint64_t num_requests_delayed() const;
914 void set_num_requests_delayed(::uint64_t value);
915
916 private:
917 ::uint64_t _internal_num_requests_delayed() const;
918 void _internal_set_num_requests_delayed(::uint64_t value);
919
920 public:
921 // uint64 num_requests_uncategorized = 6;
922 void clear_num_requests_uncategorized() ;
923 ::uint64_t num_requests_uncategorized() const;
924 void set_num_requests_uncategorized(::uint64_t value);
925
926 private:
927 ::uint64_t _internal_num_requests_uncategorized() const;
928 void _internal_set_num_requests_uncategorized(::uint64_t value);
929
930 public:
931 // uint64 num_requests_timed_out = 7;
932 void clear_num_requests_timed_out() ;
933 ::uint64_t num_requests_timed_out() const;
934 void set_num_requests_timed_out(::uint64_t value);
935
936 private:
937 ::uint64_t _internal_num_requests_timed_out() const;
938 void _internal_set_num_requests_timed_out(::uint64_t value);
939
940 public:
941 // uint64 num_requests_waiting = 8;
942 void clear_num_requests_waiting() ;
943 ::uint64_t num_requests_waiting() const;
944 void set_num_requests_waiting(::uint64_t value);
945
946 private:
947 ::uint64_t _internal_num_requests_waiting() const;
948 void _internal_set_num_requests_waiting(::uint64_t value);
949
950 public:
951 // uint64 avg_request_response_time = 21;
952 void clear_avg_request_response_time() ;
953 ::uint64_t avg_request_response_time() const;
954 void set_avg_request_response_time(::uint64_t value);
955
956 private:
957 ::uint64_t _internal_avg_request_response_time() const;
958 void _internal_set_avg_request_response_time(::uint64_t value);
959
960 public:
961 // uint64 tot_request_response_time = 22;
962 void clear_tot_request_response_time() ;
963 ::uint64_t tot_request_response_time() const;
964 void set_tot_request_response_time(::uint64_t value);
965
966 private:
967 ::uint64_t _internal_tot_request_response_time() const;
968 void _internal_set_tot_request_response_time(::uint64_t value);
969
970 public:
971 // uint64 min_request_response_time = 23;
972 void clear_min_request_response_time() ;
973 ::uint64_t min_request_response_time() const;
974 void set_min_request_response_time(::uint64_t value);
975
976 private:
977 ::uint64_t _internal_min_request_response_time() const;
978 void _internal_set_min_request_response_time(::uint64_t value);
979
980 public:
981 // uint64 max_request_response_time = 24;
982 void clear_max_request_response_time() ;
983 ::uint64_t max_request_response_time() const;
984 void set_max_request_response_time(::uint64_t value);
985
986 private:
987 ::uint64_t _internal_max_request_response_time() const;
988 void _internal_set_max_request_response_time(::uint64_t value);
989
990 public:
991 // uint64 num_buffer_cleanups = 31;
992 void clear_num_buffer_cleanups() ;
993 ::uint64_t num_buffer_cleanups() const;
994 void set_num_buffer_cleanups(::uint64_t value);
995
996 private:
997 ::uint64_t _internal_num_buffer_cleanups() const;
998 void _internal_set_num_buffer_cleanups(::uint64_t value);
999
1000 public:
1001 // uint64 num_periodic_sent = 41;
1002 void clear_num_periodic_sent() ;
1003 ::uint64_t num_periodic_sent() const;
1004 void set_num_periodic_sent(::uint64_t value);
1005
1006 private:
1007 ::uint64_t _internal_num_periodic_sent() const;
1008 void _internal_set_num_periodic_sent(::uint64_t value);
1009
1010 public:
1011 // uint64 num_periodic_send_failed = 42;
1012 void clear_num_periodic_send_failed() ;
1013 ::uint64_t num_periodic_send_failed() const;
1014 void set_num_periodic_send_failed(::uint64_t value);
1015
1016 private:
1017 ::uint64_t _internal_num_periodic_send_failed() const;
1018 void _internal_set_num_periodic_send_failed(::uint64_t value);
1019
1020 public:
1021 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
1022 private:
1023 class _Internal;
1024
1025 friend class ::google::protobuf::internal::TcParser;
1026 static const ::google::protobuf::internal::TcParseTable<4, 15, 0, 0, 7> _table_;
1027 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1028 typedef void InternalArenaConstructable_;
1029 typedef void DestructorSkippable_;
1030 struct Impl_ {
1031 ::uint64_t num_requests_handled_;
1032 ::uint64_t num_requests_found_;
1033 ::uint64_t num_requests_bad_;
1034 ::uint64_t num_requests_old_window_;
1035 ::uint64_t num_requests_delayed_;
1036 ::uint64_t num_requests_uncategorized_;
1037 ::uint64_t num_requests_timed_out_;
1038 ::uint64_t num_requests_waiting_;
1039 ::uint64_t avg_request_response_time_;
1040 ::uint64_t tot_request_response_time_;
1041 ::uint64_t min_request_response_time_;
1042 ::uint64_t max_request_response_time_;
1043 ::uint64_t num_buffer_cleanups_;
1044 ::uint64_t num_periodic_sent_;
1045 ::uint64_t num_periodic_send_failed_;
1046 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1047 PROTOBUF_TSAN_DECLARE_MEMBER
1048 };
1049 union { Impl_ _impl_; };
1050 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1051};// -------------------------------------------------------------------
1052
1053class RecordingInfo final :
1054 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.RecordingInfo) */ {
1055 public:
1056 inline RecordingInfo() : RecordingInfo(nullptr) {}
1057 ~RecordingInfo() override;
1058 template<typename = void>
1059 explicit PROTOBUF_CONSTEXPR RecordingInfo(::google::protobuf::internal::ConstantInitialized);
1060
1061 RecordingInfo(const RecordingInfo& from);
1062 RecordingInfo(RecordingInfo&& from) noexcept
1063 : RecordingInfo() {
1064 *this = ::std::move(from);
1065 }
1066
1067 inline RecordingInfo& operator=(const RecordingInfo& from) {
1068 CopyFrom(from);
1069 return *this;
1070 }
1071 inline RecordingInfo& operator=(RecordingInfo&& from) noexcept {
1072 if (this == &from) return *this;
1073 if (GetOwningArena() == from.GetOwningArena()
1074 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1075 && GetOwningArena() != nullptr
1076 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1077 ) {
1078 InternalSwap(&from);
1079 } else {
1080 CopyFrom(from);
1081 }
1082 return *this;
1083 }
1084
1085 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1086 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1087 }
1088 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1089 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1090 }
1091
1092 static const ::google::protobuf::Descriptor* descriptor() {
1093 return GetDescriptor();
1094 }
1095 static const ::google::protobuf::Descriptor* GetDescriptor() {
1096 return default_instance().GetMetadata().descriptor;
1097 }
1098 static const ::google::protobuf::Reflection* GetReflection() {
1099 return default_instance().GetMetadata().reflection;
1100 }
1101 static const RecordingInfo& default_instance() {
1102 return *internal_default_instance();
1103 }
1104 static inline const RecordingInfo* internal_default_instance() {
1105 return reinterpret_cast<const RecordingInfo*>(
1106 &_RecordingInfo_default_instance_);
1107 }
1108 static constexpr int kIndexInFileMessages =
1109 4;
1110
1111 friend void swap(RecordingInfo& a, RecordingInfo& b) {
1112 a.Swap(&b);
1113 }
1114 inline void Swap(RecordingInfo* other) {
1115 if (other == this) return;
1116 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1117 if (GetOwningArena() != nullptr &&
1118 GetOwningArena() == other->GetOwningArena()) {
1119 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1120 if (GetOwningArena() == other->GetOwningArena()) {
1121 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1122 InternalSwap(other);
1123 } else {
1124 ::google::protobuf::internal::GenericSwap(this, other);
1125 }
1126 }
1127 void UnsafeArenaSwap(RecordingInfo* other) {
1128 if (other == this) return;
1129 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
1130 InternalSwap(other);
1131 }
1132
1133 // implements Message ----------------------------------------------
1134
1135 RecordingInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
1136 return CreateMaybeMessage<RecordingInfo>(arena);
1137 }
1138 using ::google::protobuf::Message::CopyFrom;
1139 void CopyFrom(const RecordingInfo& from);
1140 using ::google::protobuf::Message::MergeFrom;
1141 void MergeFrom( const RecordingInfo& from) {
1142 RecordingInfo::MergeImpl(*this, from);
1143 }
1144 private:
1145 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
1146 public:
1147 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1148 bool IsInitialized() const final;
1149
1150 ::size_t ByteSizeLong() const final;
1151 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
1152 ::uint8_t* _InternalSerialize(
1153 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
1154 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1155
1156 private:
1157 void SharedCtor(::google::protobuf::Arena* arena);
1158 void SharedDtor();
1159 void SetCachedSize(int size) const final;
1160 void InternalSwap(RecordingInfo* other);
1161
1162 private:
1163 friend class ::google::protobuf::internal::AnyMetadata;
1164 static ::absl::string_view FullMessageName() {
1165 return "dunedaq.datahandlinglibs.opmon.RecordingInfo";
1166 }
1167 protected:
1168 explicit RecordingInfo(::google::protobuf::Arena* arena);
1169 public:
1170
1171 static const ClassData _class_data_;
1172 const ::google::protobuf::Message::ClassData*GetClassData() const final;
1173
1174 ::google::protobuf::Metadata GetMetadata() const final;
1175
1176 // nested types ----------------------------------------------------
1177
1178 // accessors -------------------------------------------------------
1179
1180 enum : int {
1181 kRecordingStatusFieldNumber = 1,
1182 kPacketsRecordedFieldNumber = 2,
1183 kBytesRecordedFieldNumber = 3,
1184 };
1185 // string recording_status = 1;
1186 void clear_recording_status() ;
1187 const std::string& recording_status() const;
1188 template <typename Arg_ = const std::string&, typename... Args_>
1189 void set_recording_status(Arg_&& arg, Args_... args);
1190 std::string* mutable_recording_status();
1191 PROTOBUF_NODISCARD std::string* release_recording_status();
1192 void set_allocated_recording_status(std::string* ptr);
1193
1194 private:
1195 const std::string& _internal_recording_status() const;
1196 inline PROTOBUF_ALWAYS_INLINE void _internal_set_recording_status(
1197 const std::string& value);
1198 std::string* _internal_mutable_recording_status();
1199
1200 public:
1201 // uint64 packets_recorded = 2;
1202 void clear_packets_recorded() ;
1203 ::uint64_t packets_recorded() const;
1204 void set_packets_recorded(::uint64_t value);
1205
1206 private:
1207 ::uint64_t _internal_packets_recorded() const;
1208 void _internal_set_packets_recorded(::uint64_t value);
1209
1210 public:
1211 // uint64 bytes_recorded = 3;
1212 void clear_bytes_recorded() ;
1213 ::uint64_t bytes_recorded() const;
1214 void set_bytes_recorded(::uint64_t value);
1215
1216 private:
1217 ::uint64_t _internal_bytes_recorded() const;
1218 void _internal_set_bytes_recorded(::uint64_t value);
1219
1220 public:
1221 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.RecordingInfo)
1222 private:
1223 class _Internal;
1224
1225 friend class ::google::protobuf::internal::TcParser;
1226 static const ::google::protobuf::internal::TcParseTable<2, 3, 0, 69, 2> _table_;
1227 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1228 typedef void InternalArenaConstructable_;
1229 typedef void DestructorSkippable_;
1230 struct Impl_ {
1231 ::google::protobuf::internal::ArenaStringPtr recording_status_;
1232 ::uint64_t packets_recorded_;
1233 ::uint64_t bytes_recorded_;
1234 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1235 PROTOBUF_TSAN_DECLARE_MEMBER
1236 };
1237 union { Impl_ _impl_; };
1238 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1239};// -------------------------------------------------------------------
1240
1241class DataProcessorInfo final :
1242 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataProcessorInfo) */ {
1243 public:
1244 inline DataProcessorInfo() : DataProcessorInfo(nullptr) {}
1245 ~DataProcessorInfo() override;
1246 template<typename = void>
1247 explicit PROTOBUF_CONSTEXPR DataProcessorInfo(::google::protobuf::internal::ConstantInitialized);
1248
1249 DataProcessorInfo(const DataProcessorInfo& from);
1250 DataProcessorInfo(DataProcessorInfo&& from) noexcept
1251 : DataProcessorInfo() {
1252 *this = ::std::move(from);
1253 }
1254
1255 inline DataProcessorInfo& operator=(const DataProcessorInfo& from) {
1256 CopyFrom(from);
1257 return *this;
1258 }
1259 inline DataProcessorInfo& operator=(DataProcessorInfo&& from) noexcept {
1260 if (this == &from) return *this;
1261 if (GetOwningArena() == from.GetOwningArena()
1262 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1263 && GetOwningArena() != nullptr
1264 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1265 ) {
1266 InternalSwap(&from);
1267 } else {
1268 CopyFrom(from);
1269 }
1270 return *this;
1271 }
1272
1273 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1274 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1275 }
1276 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1277 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1278 }
1279
1280 static const ::google::protobuf::Descriptor* descriptor() {
1281 return GetDescriptor();
1282 }
1283 static const ::google::protobuf::Descriptor* GetDescriptor() {
1284 return default_instance().GetMetadata().descriptor;
1285 }
1286 static const ::google::protobuf::Reflection* GetReflection() {
1287 return default_instance().GetMetadata().reflection;
1288 }
1289 static const DataProcessorInfo& default_instance() {
1290 return *internal_default_instance();
1291 }
1292 static inline const DataProcessorInfo* internal_default_instance() {
1293 return reinterpret_cast<const DataProcessorInfo*>(
1294 &_DataProcessorInfo_default_instance_);
1295 }
1296 static constexpr int kIndexInFileMessages =
1297 5;
1298
1299 friend void swap(DataProcessorInfo& a, DataProcessorInfo& b) {
1300 a.Swap(&b);
1301 }
1302 inline void Swap(DataProcessorInfo* other) {
1303 if (other == this) return;
1304 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1305 if (GetOwningArena() != nullptr &&
1306 GetOwningArena() == other->GetOwningArena()) {
1307 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1308 if (GetOwningArena() == other->GetOwningArena()) {
1309 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1310 InternalSwap(other);
1311 } else {
1312 ::google::protobuf::internal::GenericSwap(this, other);
1313 }
1314 }
1315 void UnsafeArenaSwap(DataProcessorInfo* other) {
1316 if (other == this) return;
1317 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
1318 InternalSwap(other);
1319 }
1320
1321 // implements Message ----------------------------------------------
1322
1323 DataProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
1324 return CreateMaybeMessage<DataProcessorInfo>(arena);
1325 }
1326 using ::google::protobuf::Message::CopyFrom;
1327 void CopyFrom(const DataProcessorInfo& from);
1328 using ::google::protobuf::Message::MergeFrom;
1329 void MergeFrom( const DataProcessorInfo& from) {
1330 DataProcessorInfo::MergeImpl(*this, from);
1331 }
1332 private:
1333 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
1334 public:
1335 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1336 bool IsInitialized() const final;
1337
1338 ::size_t ByteSizeLong() const final;
1339 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
1340 ::uint8_t* _InternalSerialize(
1341 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
1342 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1343
1344 private:
1345 void SharedCtor(::google::protobuf::Arena* arena);
1346 void SharedDtor();
1347 void SetCachedSize(int size) const final;
1348 void InternalSwap(DataProcessorInfo* other);
1349
1350 private:
1351 friend class ::google::protobuf::internal::AnyMetadata;
1352 static ::absl::string_view FullMessageName() {
1353 return "dunedaq.datahandlinglibs.opmon.DataProcessorInfo";
1354 }
1355 protected:
1356 explicit DataProcessorInfo(::google::protobuf::Arena* arena);
1357 public:
1358
1359 static const ClassData _class_data_;
1360 const ::google::protobuf::Message::ClassData*GetClassData() const final;
1361
1362 ::google::protobuf::Metadata GetMetadata() const final;
1363
1364 // nested types ----------------------------------------------------
1365
1366 // accessors -------------------------------------------------------
1367
1368 enum : int {
1369 kElementsQueuedFieldNumber = 1,
1370 };
1371 // uint64 elements_queued = 1;
1372 void clear_elements_queued() ;
1373 ::uint64_t elements_queued() const;
1374 void set_elements_queued(::uint64_t value);
1375
1376 private:
1377 ::uint64_t _internal_elements_queued() const;
1378 void _internal_set_elements_queued(::uint64_t value);
1379
1380 public:
1381 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
1382 private:
1383 class _Internal;
1384
1385 friend class ::google::protobuf::internal::TcParser;
1386 static const ::google::protobuf::internal::TcParseTable<0, 1, 0, 0, 2> _table_;
1387 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1388 typedef void InternalArenaConstructable_;
1389 typedef void DestructorSkippable_;
1390 struct Impl_ {
1391 ::uint64_t elements_queued_;
1392 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1393 PROTOBUF_TSAN_DECLARE_MEMBER
1394 };
1395 union { Impl_ _impl_; };
1396 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1397};// -------------------------------------------------------------------
1398
1399class FixedRateDataProcessorInfo final :
1400 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo) */ {
1401 public:
1402 inline FixedRateDataProcessorInfo() : FixedRateDataProcessorInfo(nullptr) {}
1403 ~FixedRateDataProcessorInfo() override;
1404 template<typename = void>
1405 explicit PROTOBUF_CONSTEXPR FixedRateDataProcessorInfo(::google::protobuf::internal::ConstantInitialized);
1406
1407 FixedRateDataProcessorInfo(const FixedRateDataProcessorInfo& from);
1408 FixedRateDataProcessorInfo(FixedRateDataProcessorInfo&& from) noexcept
1409 : FixedRateDataProcessorInfo() {
1410 *this = ::std::move(from);
1411 }
1412
1413 inline FixedRateDataProcessorInfo& operator=(const FixedRateDataProcessorInfo& from) {
1414 CopyFrom(from);
1415 return *this;
1416 }
1417 inline FixedRateDataProcessorInfo& operator=(FixedRateDataProcessorInfo&& from) noexcept {
1418 if (this == &from) return *this;
1419 if (GetOwningArena() == from.GetOwningArena()
1420 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1421 && GetOwningArena() != nullptr
1422 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1423 ) {
1424 InternalSwap(&from);
1425 } else {
1426 CopyFrom(from);
1427 }
1428 return *this;
1429 }
1430
1431 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1432 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1433 }
1434 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1435 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1436 }
1437
1438 static const ::google::protobuf::Descriptor* descriptor() {
1439 return GetDescriptor();
1440 }
1441 static const ::google::protobuf::Descriptor* GetDescriptor() {
1442 return default_instance().GetMetadata().descriptor;
1443 }
1444 static const ::google::protobuf::Reflection* GetReflection() {
1445 return default_instance().GetMetadata().reflection;
1446 }
1447 static const FixedRateDataProcessorInfo& default_instance() {
1448 return *internal_default_instance();
1449 }
1454 static constexpr int kIndexInFileMessages =
1455 6;
1456
1457 friend void swap(FixedRateDataProcessorInfo& a, FixedRateDataProcessorInfo& b) {
1458 a.Swap(&b);
1459 }
1460 inline void Swap(FixedRateDataProcessorInfo* other) {
1461 if (other == this) return;
1462 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1463 if (GetOwningArena() != nullptr &&
1464 GetOwningArena() == other->GetOwningArena()) {
1465 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1466 if (GetOwningArena() == other->GetOwningArena()) {
1467 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1468 InternalSwap(other);
1469 } else {
1470 ::google::protobuf::internal::GenericSwap(this, other);
1471 }
1472 }
1473 void UnsafeArenaSwap(FixedRateDataProcessorInfo* other) {
1474 if (other == this) return;
1475 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
1476 InternalSwap(other);
1477 }
1478
1479 // implements Message ----------------------------------------------
1480
1481 FixedRateDataProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
1482 return CreateMaybeMessage<FixedRateDataProcessorInfo>(arena);
1483 }
1484 using ::google::protobuf::Message::CopyFrom;
1485 void CopyFrom(const FixedRateDataProcessorInfo& from);
1486 using ::google::protobuf::Message::MergeFrom;
1487 void MergeFrom( const FixedRateDataProcessorInfo& from) {
1488 FixedRateDataProcessorInfo::MergeImpl(*this, from);
1489 }
1490 private:
1491 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
1492 public:
1493 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1494 bool IsInitialized() const final;
1495
1496 ::size_t ByteSizeLong() const final;
1497 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
1498 ::uint8_t* _InternalSerialize(
1499 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
1500 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1501
1502 private:
1503 void SharedCtor(::google::protobuf::Arena* arena);
1504 void SharedDtor();
1505 void SetCachedSize(int size) const final;
1506 void InternalSwap(FixedRateDataProcessorInfo* other);
1507
1508 private:
1509 friend class ::google::protobuf::internal::AnyMetadata;
1510 static ::absl::string_view FullMessageName() {
1511 return "dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo";
1512 }
1513 protected:
1514 explicit FixedRateDataProcessorInfo(::google::protobuf::Arena* arena);
1515 public:
1516
1517 static const ClassData _class_data_;
1518 const ::google::protobuf::Message::ClassData*GetClassData() const final;
1519
1520 ::google::protobuf::Metadata GetMetadata() const final;
1521
1522 // nested types ----------------------------------------------------
1523
1524 // accessors -------------------------------------------------------
1525
1526 enum : int {
1527 kNumSeqIdErrorsFieldNumber = 1,
1528 kMinSeqIdJumpFieldNumber = 2,
1529 kMaxSeqIdJumpFieldNumber = 3,
1530 kNumTsErrorsFieldNumber = 4,
1531 };
1532 // uint64 num_seq_id_errors = 1;
1533 void clear_num_seq_id_errors() ;
1534 ::uint64_t num_seq_id_errors() const;
1535 void set_num_seq_id_errors(::uint64_t value);
1536
1537 private:
1538 ::uint64_t _internal_num_seq_id_errors() const;
1539 void _internal_set_num_seq_id_errors(::uint64_t value);
1540
1541 public:
1542 // uint64 min_seq_id_jump = 2;
1543 void clear_min_seq_id_jump() ;
1544 ::uint64_t min_seq_id_jump() const;
1545 void set_min_seq_id_jump(::uint64_t value);
1546
1547 private:
1548 ::uint64_t _internal_min_seq_id_jump() const;
1549 void _internal_set_min_seq_id_jump(::uint64_t value);
1550
1551 public:
1552 // uint64 max_seq_id_jump = 3;
1553 void clear_max_seq_id_jump() ;
1554 ::uint64_t max_seq_id_jump() const;
1555 void set_max_seq_id_jump(::uint64_t value);
1556
1557 private:
1558 ::uint64_t _internal_max_seq_id_jump() const;
1559 void _internal_set_max_seq_id_jump(::uint64_t value);
1560
1561 public:
1562 // uint64 num_ts_errors = 4;
1563 void clear_num_ts_errors() ;
1564 ::uint64_t num_ts_errors() const;
1565 void set_num_ts_errors(::uint64_t value);
1566
1567 private:
1568 ::uint64_t _internal_num_ts_errors() const;
1569 void _internal_set_num_ts_errors(::uint64_t value);
1570
1571 public:
1572 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
1573 private:
1574 class _Internal;
1575
1576 friend class ::google::protobuf::internal::TcParser;
1577 static const ::google::protobuf::internal::TcParseTable<2, 4, 0, 0, 2> _table_;
1578 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1579 typedef void InternalArenaConstructable_;
1580 typedef void DestructorSkippable_;
1581 struct Impl_ {
1582 ::uint64_t num_seq_id_errors_;
1583 ::uint64_t min_seq_id_jump_;
1584 ::uint64_t max_seq_id_jump_;
1585 ::uint64_t num_ts_errors_;
1586 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1587 PROTOBUF_TSAN_DECLARE_MEMBER
1588 };
1589 union { Impl_ _impl_; };
1590 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1591};// -------------------------------------------------------------------
1592
1593class HitFindingInfo final :
1594 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.HitFindingInfo) */ {
1595 public:
1596 inline HitFindingInfo() : HitFindingInfo(nullptr) {}
1597 ~HitFindingInfo() override;
1598 template<typename = void>
1599 explicit PROTOBUF_CONSTEXPR HitFindingInfo(::google::protobuf::internal::ConstantInitialized);
1600
1601 HitFindingInfo(const HitFindingInfo& from);
1602 HitFindingInfo(HitFindingInfo&& from) noexcept
1603 : HitFindingInfo() {
1604 *this = ::std::move(from);
1605 }
1606
1607 inline HitFindingInfo& operator=(const HitFindingInfo& from) {
1608 CopyFrom(from);
1609 return *this;
1610 }
1611 inline HitFindingInfo& operator=(HitFindingInfo&& from) noexcept {
1612 if (this == &from) return *this;
1613 if (GetOwningArena() == from.GetOwningArena()
1614 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1615 && GetOwningArena() != nullptr
1616 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1617 ) {
1618 InternalSwap(&from);
1619 } else {
1620 CopyFrom(from);
1621 }
1622 return *this;
1623 }
1624
1625 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1626 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1627 }
1628 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1629 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1630 }
1631
1632 static const ::google::protobuf::Descriptor* descriptor() {
1633 return GetDescriptor();
1634 }
1635 static const ::google::protobuf::Descriptor* GetDescriptor() {
1636 return default_instance().GetMetadata().descriptor;
1637 }
1638 static const ::google::protobuf::Reflection* GetReflection() {
1639 return default_instance().GetMetadata().reflection;
1640 }
1641 static const HitFindingInfo& default_instance() {
1642 return *internal_default_instance();
1643 }
1644 static inline const HitFindingInfo* internal_default_instance() {
1645 return reinterpret_cast<const HitFindingInfo*>(
1646 &_HitFindingInfo_default_instance_);
1647 }
1648 static constexpr int kIndexInFileMessages =
1649 7;
1650
1651 friend void swap(HitFindingInfo& a, HitFindingInfo& b) {
1652 a.Swap(&b);
1653 }
1654 inline void Swap(HitFindingInfo* other) {
1655 if (other == this) return;
1656 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1657 if (GetOwningArena() != nullptr &&
1658 GetOwningArena() == other->GetOwningArena()) {
1659 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1660 if (GetOwningArena() == other->GetOwningArena()) {
1661 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1662 InternalSwap(other);
1663 } else {
1664 ::google::protobuf::internal::GenericSwap(this, other);
1665 }
1666 }
1667 void UnsafeArenaSwap(HitFindingInfo* other) {
1668 if (other == this) return;
1669 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
1670 InternalSwap(other);
1671 }
1672
1673 // implements Message ----------------------------------------------
1674
1675 HitFindingInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
1676 return CreateMaybeMessage<HitFindingInfo>(arena);
1677 }
1678 using ::google::protobuf::Message::CopyFrom;
1679 void CopyFrom(const HitFindingInfo& from);
1680 using ::google::protobuf::Message::MergeFrom;
1681 void MergeFrom( const HitFindingInfo& from) {
1682 HitFindingInfo::MergeImpl(*this, from);
1683 }
1684 private:
1685 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
1686 public:
1687 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1688 bool IsInitialized() const final;
1689
1690 ::size_t ByteSizeLong() const final;
1691 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
1692 ::uint8_t* _InternalSerialize(
1693 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
1694 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1695
1696 private:
1697 void SharedCtor(::google::protobuf::Arena* arena);
1698 void SharedDtor();
1699 void SetCachedSize(int size) const final;
1700 void InternalSwap(HitFindingInfo* other);
1701
1702 private:
1703 friend class ::google::protobuf::internal::AnyMetadata;
1704 static ::absl::string_view FullMessageName() {
1705 return "dunedaq.datahandlinglibs.opmon.HitFindingInfo";
1706 }
1707 protected:
1708 explicit HitFindingInfo(::google::protobuf::Arena* arena);
1709 public:
1710
1711 static const ClassData _class_data_;
1712 const ::google::protobuf::Message::ClassData*GetClassData() const final;
1713
1714 ::google::protobuf::Metadata GetMetadata() const final;
1715
1716 // nested types ----------------------------------------------------
1717
1718 // accessors -------------------------------------------------------
1719
1720 enum : int {
1721 kNumTpsSentFieldNumber = 2,
1722 kNumTpsSendFailedFieldNumber = 3,
1723 kNumTpsSuppressedTooLongFieldNumber = 4,
1724 kRateTpHitsFieldNumber = 1,
1725 };
1726 // uint64 num_tps_sent = 2;
1727 void clear_num_tps_sent() ;
1728 ::uint64_t num_tps_sent() const;
1729 void set_num_tps_sent(::uint64_t value);
1730
1731 private:
1732 ::uint64_t _internal_num_tps_sent() const;
1733 void _internal_set_num_tps_sent(::uint64_t value);
1734
1735 public:
1736 // uint64 num_tps_send_failed = 3;
1737 void clear_num_tps_send_failed() ;
1738 ::uint64_t num_tps_send_failed() const;
1739 void set_num_tps_send_failed(::uint64_t value);
1740
1741 private:
1742 ::uint64_t _internal_num_tps_send_failed() const;
1743 void _internal_set_num_tps_send_failed(::uint64_t value);
1744
1745 public:
1746 // uint64 num_tps_suppressed_too_long = 4;
1747 void clear_num_tps_suppressed_too_long() ;
1748 ::uint64_t num_tps_suppressed_too_long() const;
1749 void set_num_tps_suppressed_too_long(::uint64_t value);
1750
1751 private:
1752 ::uint64_t _internal_num_tps_suppressed_too_long() const;
1753 void _internal_set_num_tps_suppressed_too_long(::uint64_t value);
1754
1755 public:
1756 // float rate_tp_hits = 1;
1757 void clear_rate_tp_hits() ;
1758 float rate_tp_hits() const;
1759 void set_rate_tp_hits(float value);
1760
1761 private:
1762 float _internal_rate_tp_hits() const;
1763 void _internal_set_rate_tp_hits(float value);
1764
1765 public:
1766 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
1767 private:
1768 class _Internal;
1769
1770 friend class ::google::protobuf::internal::TcParser;
1771 static const ::google::protobuf::internal::TcParseTable<2, 4, 0, 0, 2> _table_;
1772 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1773 typedef void InternalArenaConstructable_;
1774 typedef void DestructorSkippable_;
1775 struct Impl_ {
1776 ::uint64_t num_tps_sent_;
1777 ::uint64_t num_tps_send_failed_;
1778 ::uint64_t num_tps_suppressed_too_long_;
1779 float rate_tp_hits_;
1780 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1781 PROTOBUF_TSAN_DECLARE_MEMBER
1782 };
1783 union { Impl_ _impl_; };
1784 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1785};// -------------------------------------------------------------------
1786
1787class TPChannelInfo final :
1788 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPChannelInfo) */ {
1789 public:
1790 inline TPChannelInfo() : TPChannelInfo(nullptr) {}
1791 ~TPChannelInfo() override;
1792 template<typename = void>
1793 explicit PROTOBUF_CONSTEXPR TPChannelInfo(::google::protobuf::internal::ConstantInitialized);
1794
1795 TPChannelInfo(const TPChannelInfo& from);
1796 TPChannelInfo(TPChannelInfo&& from) noexcept
1797 : TPChannelInfo() {
1798 *this = ::std::move(from);
1799 }
1800
1801 inline TPChannelInfo& operator=(const TPChannelInfo& from) {
1802 CopyFrom(from);
1803 return *this;
1804 }
1805 inline TPChannelInfo& operator=(TPChannelInfo&& from) noexcept {
1806 if (this == &from) return *this;
1807 if (GetOwningArena() == from.GetOwningArena()
1808 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1809 && GetOwningArena() != nullptr
1810 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1811 ) {
1812 InternalSwap(&from);
1813 } else {
1814 CopyFrom(from);
1815 }
1816 return *this;
1817 }
1818
1819 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1820 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1821 }
1822 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1823 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1824 }
1825
1826 static const ::google::protobuf::Descriptor* descriptor() {
1827 return GetDescriptor();
1828 }
1829 static const ::google::protobuf::Descriptor* GetDescriptor() {
1830 return default_instance().GetMetadata().descriptor;
1831 }
1832 static const ::google::protobuf::Reflection* GetReflection() {
1833 return default_instance().GetMetadata().reflection;
1834 }
1835 static const TPChannelInfo& default_instance() {
1836 return *internal_default_instance();
1837 }
1838 static inline const TPChannelInfo* internal_default_instance() {
1839 return reinterpret_cast<const TPChannelInfo*>(
1840 &_TPChannelInfo_default_instance_);
1841 }
1842 static constexpr int kIndexInFileMessages =
1843 8;
1844
1845 friend void swap(TPChannelInfo& a, TPChannelInfo& b) {
1846 a.Swap(&b);
1847 }
1848 inline void Swap(TPChannelInfo* other) {
1849 if (other == this) return;
1850 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1851 if (GetOwningArena() != nullptr &&
1852 GetOwningArena() == other->GetOwningArena()) {
1853 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1854 if (GetOwningArena() == other->GetOwningArena()) {
1855 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1856 InternalSwap(other);
1857 } else {
1858 ::google::protobuf::internal::GenericSwap(this, other);
1859 }
1860 }
1861 void UnsafeArenaSwap(TPChannelInfo* other) {
1862 if (other == this) return;
1863 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
1864 InternalSwap(other);
1865 }
1866
1867 // implements Message ----------------------------------------------
1868
1869 TPChannelInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
1870 return CreateMaybeMessage<TPChannelInfo>(arena);
1871 }
1872 using ::google::protobuf::Message::CopyFrom;
1873 void CopyFrom(const TPChannelInfo& from);
1874 using ::google::protobuf::Message::MergeFrom;
1875 void MergeFrom( const TPChannelInfo& from) {
1876 TPChannelInfo::MergeImpl(*this, from);
1877 }
1878 private:
1879 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
1880 public:
1881 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1882 bool IsInitialized() const final;
1883
1884 ::size_t ByteSizeLong() const final;
1885 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
1886 ::uint8_t* _InternalSerialize(
1887 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
1888 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1889
1890 private:
1891 void SharedCtor(::google::protobuf::Arena* arena);
1892 void SharedDtor();
1893 void SetCachedSize(int size) const final;
1894 void InternalSwap(TPChannelInfo* other);
1895
1896 private:
1897 friend class ::google::protobuf::internal::AnyMetadata;
1898 static ::absl::string_view FullMessageName() {
1899 return "dunedaq.datahandlinglibs.opmon.TPChannelInfo";
1900 }
1901 protected:
1902 explicit TPChannelInfo(::google::protobuf::Arena* arena);
1903 public:
1904
1905 static const ClassData _class_data_;
1906 const ::google::protobuf::Message::ClassData*GetClassData() const final;
1907
1908 ::google::protobuf::Metadata GetMetadata() const final;
1909
1910 // nested types ----------------------------------------------------
1911
1912 // accessors -------------------------------------------------------
1913
1914 enum : int {
1915 kChannelIdFieldNumber = 1,
1916 kNumberOfTpsFieldNumber = 2,
1917 };
1918 // uint64 channel_id = 1;
1919 void clear_channel_id() ;
1920 ::uint64_t channel_id() const;
1921 void set_channel_id(::uint64_t value);
1922
1923 private:
1924 ::uint64_t _internal_channel_id() const;
1925 void _internal_set_channel_id(::uint64_t value);
1926
1927 public:
1928 // uint64 number_of_tps = 2;
1929 void clear_number_of_tps() ;
1930 ::uint64_t number_of_tps() const;
1931 void set_number_of_tps(::uint64_t value);
1932
1933 private:
1934 ::uint64_t _internal_number_of_tps() const;
1935 void _internal_set_number_of_tps(::uint64_t value);
1936
1937 public:
1938 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
1939 private:
1940 class _Internal;
1941
1942 friend class ::google::protobuf::internal::TcParser;
1943 static const ::google::protobuf::internal::TcParseTable<1, 2, 0, 0, 2> _table_;
1944 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
1945 typedef void InternalArenaConstructable_;
1946 typedef void DestructorSkippable_;
1947 struct Impl_ {
1948 ::uint64_t channel_id_;
1949 ::uint64_t number_of_tps_;
1950 mutable ::google::protobuf::internal::CachedSize _cached_size_;
1951 PROTOBUF_TSAN_DECLARE_MEMBER
1952 };
1953 union { Impl_ _impl_; };
1954 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
1955};// -------------------------------------------------------------------
1956
1957class TPGProcessorInfo final :
1958 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo) */ {
1959 public:
1960 inline TPGProcessorInfo() : TPGProcessorInfo(nullptr) {}
1961 ~TPGProcessorInfo() override;
1962 template<typename = void>
1963 explicit PROTOBUF_CONSTEXPR TPGProcessorInfo(::google::protobuf::internal::ConstantInitialized);
1964
1965 TPGProcessorInfo(const TPGProcessorInfo& from);
1966 TPGProcessorInfo(TPGProcessorInfo&& from) noexcept
1967 : TPGProcessorInfo() {
1968 *this = ::std::move(from);
1969 }
1970
1971 inline TPGProcessorInfo& operator=(const TPGProcessorInfo& from) {
1972 CopyFrom(from);
1973 return *this;
1974 }
1975 inline TPGProcessorInfo& operator=(TPGProcessorInfo&& from) noexcept {
1976 if (this == &from) return *this;
1977 if (GetOwningArena() == from.GetOwningArena()
1978 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1979 && GetOwningArena() != nullptr
1980 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1981 ) {
1982 InternalSwap(&from);
1983 } else {
1984 CopyFrom(from);
1985 }
1986 return *this;
1987 }
1988
1989 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
1990 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
1991 }
1992 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
1993 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
1994 }
1995
1996 static const ::google::protobuf::Descriptor* descriptor() {
1997 return GetDescriptor();
1998 }
1999 static const ::google::protobuf::Descriptor* GetDescriptor() {
2000 return default_instance().GetMetadata().descriptor;
2001 }
2002 static const ::google::protobuf::Reflection* GetReflection() {
2003 return default_instance().GetMetadata().reflection;
2004 }
2005 static const TPGProcessorInfo& default_instance() {
2006 return *internal_default_instance();
2007 }
2008 static inline const TPGProcessorInfo* internal_default_instance() {
2009 return reinterpret_cast<const TPGProcessorInfo*>(
2010 &_TPGProcessorInfo_default_instance_);
2011 }
2012 static constexpr int kIndexInFileMessages =
2013 9;
2014
2015 friend void swap(TPGProcessorInfo& a, TPGProcessorInfo& b) {
2016 a.Swap(&b);
2017 }
2018 inline void Swap(TPGProcessorInfo* other) {
2019 if (other == this) return;
2020 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
2021 if (GetOwningArena() != nullptr &&
2022 GetOwningArena() == other->GetOwningArena()) {
2023 #else // PROTOBUF_FORCE_COPY_IN_SWAP
2024 if (GetOwningArena() == other->GetOwningArena()) {
2025 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
2026 InternalSwap(other);
2027 } else {
2028 ::google::protobuf::internal::GenericSwap(this, other);
2029 }
2030 }
2031 void UnsafeArenaSwap(TPGProcessorInfo* other) {
2032 if (other == this) return;
2033 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
2034 InternalSwap(other);
2035 }
2036
2037 // implements Message ----------------------------------------------
2038
2039 TPGProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
2040 return CreateMaybeMessage<TPGProcessorInfo>(arena);
2041 }
2042 using ::google::protobuf::Message::CopyFrom;
2043 void CopyFrom(const TPGProcessorInfo& from);
2044 using ::google::protobuf::Message::MergeFrom;
2045 void MergeFrom( const TPGProcessorInfo& from) {
2046 TPGProcessorInfo::MergeImpl(*this, from);
2047 }
2048 private:
2049 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
2050 public:
2051 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
2052 bool IsInitialized() const final;
2053
2054 ::size_t ByteSizeLong() const final;
2055 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
2056 ::uint8_t* _InternalSerialize(
2057 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
2058 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
2059
2060 private:
2061 void SharedCtor(::google::protobuf::Arena* arena);
2062 void SharedDtor();
2063 void SetCachedSize(int size) const final;
2064 void InternalSwap(TPGProcessorInfo* other);
2065
2066 private:
2067 friend class ::google::protobuf::internal::AnyMetadata;
2068 static ::absl::string_view FullMessageName() {
2069 return "dunedaq.datahandlinglibs.opmon.TPGProcessorInfo";
2070 }
2071 protected:
2072 explicit TPGProcessorInfo(::google::protobuf::Arena* arena);
2073 public:
2074
2075 static const ClassData _class_data_;
2076 const ::google::protobuf::Message::ClassData*GetClassData() const final;
2077
2078 ::google::protobuf::Metadata GetMetadata() const final;
2079
2080 // nested types ----------------------------------------------------
2081
2082 // accessors -------------------------------------------------------
2083
2084 enum : int {
2085 kPedestalFieldNumber = 1,
2086 kAccumFieldNumber = 2,
2087 };
2088 // int64 pedestal = 1;
2089 void clear_pedestal() ;
2090 ::int64_t pedestal() const;
2091 void set_pedestal(::int64_t value);
2092
2093 private:
2094 ::int64_t _internal_pedestal() const;
2095 void _internal_set_pedestal(::int64_t value);
2096
2097 public:
2098 // int64 accum = 2;
2099 void clear_accum() ;
2100 ::int64_t accum() const;
2101 void set_accum(::int64_t value);
2102
2103 private:
2104 ::int64_t _internal_accum() const;
2105 void _internal_set_accum(::int64_t value);
2106
2107 public:
2108 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo)
2109 private:
2110 class _Internal;
2111
2112 friend class ::google::protobuf::internal::TcParser;
2113 static const ::google::protobuf::internal::TcParseTable<1, 2, 0, 0, 2> _table_;
2114 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
2115 typedef void InternalArenaConstructable_;
2116 typedef void DestructorSkippable_;
2117 struct Impl_ {
2118 ::int64_t pedestal_;
2119 ::int64_t accum_;
2120 mutable ::google::protobuf::internal::CachedSize _cached_size_;
2121 PROTOBUF_TSAN_DECLARE_MEMBER
2122 };
2123 union { Impl_ _impl_; };
2124 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
2125};// -------------------------------------------------------------------
2126
2127class TPGProcessorReducedInfo final :
2128 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo) */ {
2129 public:
2130 inline TPGProcessorReducedInfo() : TPGProcessorReducedInfo(nullptr) {}
2131 ~TPGProcessorReducedInfo() override;
2132 template<typename = void>
2133 explicit PROTOBUF_CONSTEXPR TPGProcessorReducedInfo(::google::protobuf::internal::ConstantInitialized);
2134
2135 TPGProcessorReducedInfo(const TPGProcessorReducedInfo& from);
2136 TPGProcessorReducedInfo(TPGProcessorReducedInfo&& from) noexcept
2137 : TPGProcessorReducedInfo() {
2138 *this = ::std::move(from);
2139 }
2140
2141 inline TPGProcessorReducedInfo& operator=(const TPGProcessorReducedInfo& from) {
2142 CopyFrom(from);
2143 return *this;
2144 }
2145 inline TPGProcessorReducedInfo& operator=(TPGProcessorReducedInfo&& from) noexcept {
2146 if (this == &from) return *this;
2147 if (GetOwningArena() == from.GetOwningArena()
2148 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
2149 && GetOwningArena() != nullptr
2150 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
2151 ) {
2152 InternalSwap(&from);
2153 } else {
2154 CopyFrom(from);
2155 }
2156 return *this;
2157 }
2158
2159 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
2160 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
2161 }
2162 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
2163 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
2164 }
2165
2166 static const ::google::protobuf::Descriptor* descriptor() {
2167 return GetDescriptor();
2168 }
2169 static const ::google::protobuf::Descriptor* GetDescriptor() {
2170 return default_instance().GetMetadata().descriptor;
2171 }
2172 static const ::google::protobuf::Reflection* GetReflection() {
2173 return default_instance().GetMetadata().reflection;
2174 }
2175 static const TPGProcessorReducedInfo& default_instance() {
2176 return *internal_default_instance();
2177 }
2178 static inline const TPGProcessorReducedInfo* internal_default_instance() {
2179 return reinterpret_cast<const TPGProcessorReducedInfo*>(
2180 &_TPGProcessorReducedInfo_default_instance_);
2181 }
2182 static constexpr int kIndexInFileMessages =
2183 10;
2184
2185 friend void swap(TPGProcessorReducedInfo& a, TPGProcessorReducedInfo& b) {
2186 a.Swap(&b);
2187 }
2188 inline void Swap(TPGProcessorReducedInfo* other) {
2189 if (other == this) return;
2190 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
2191 if (GetOwningArena() != nullptr &&
2192 GetOwningArena() == other->GetOwningArena()) {
2193 #else // PROTOBUF_FORCE_COPY_IN_SWAP
2194 if (GetOwningArena() == other->GetOwningArena()) {
2195 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
2196 InternalSwap(other);
2197 } else {
2198 ::google::protobuf::internal::GenericSwap(this, other);
2199 }
2200 }
2201 void UnsafeArenaSwap(TPGProcessorReducedInfo* other) {
2202 if (other == this) return;
2203 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
2204 InternalSwap(other);
2205 }
2206
2207 // implements Message ----------------------------------------------
2208
2209 TPGProcessorReducedInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
2210 return CreateMaybeMessage<TPGProcessorReducedInfo>(arena);
2211 }
2212 using ::google::protobuf::Message::CopyFrom;
2213 void CopyFrom(const TPGProcessorReducedInfo& from);
2214 using ::google::protobuf::Message::MergeFrom;
2215 void MergeFrom( const TPGProcessorReducedInfo& from) {
2216 TPGProcessorReducedInfo::MergeImpl(*this, from);
2217 }
2218 private:
2219 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
2220 public:
2221 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
2222 bool IsInitialized() const final;
2223
2224 ::size_t ByteSizeLong() const final;
2225 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
2226 ::uint8_t* _InternalSerialize(
2227 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
2228 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
2229
2230 private:
2231 void SharedCtor(::google::protobuf::Arena* arena);
2232 void SharedDtor();
2233 void SetCachedSize(int size) const final;
2234 void InternalSwap(TPGProcessorReducedInfo* other);
2235
2236 private:
2237 friend class ::google::protobuf::internal::AnyMetadata;
2238 static ::absl::string_view FullMessageName() {
2239 return "dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo";
2240 }
2241 protected:
2242 explicit TPGProcessorReducedInfo(::google::protobuf::Arena* arena);
2243 public:
2244
2245 static const ClassData _class_data_;
2246 const ::google::protobuf::Message::ClassData*GetClassData() const final;
2247
2248 ::google::protobuf::Metadata GetMetadata() const final;
2249
2250 // nested types ----------------------------------------------------
2251
2252 // accessors -------------------------------------------------------
2253
2254 enum : int {
2255 kAverageFieldNumber = 1,
2256 kMaxFieldNumber = 2,
2257 kMinFieldNumber = 3,
2258 kMaxChannelIdFieldNumber = 4,
2259 kMinChannelIdFieldNumber = 5,
2260 kStandardDevFieldNumber = 6,
2261 };
2262 // float average = 1;
2263 void clear_average() ;
2264 float average() const;
2265 void set_average(float value);
2266
2267 private:
2268 float _internal_average() const;
2269 void _internal_set_average(float value);
2270
2271 public:
2272 // int32 max = 2;
2273 void clear_max() ;
2274 ::int32_t max() const;
2275 void set_max(::int32_t value);
2276
2277 private:
2278 ::int32_t _internal_max() const;
2279 void _internal_set_max(::int32_t value);
2280
2281 public:
2282 // int32 min = 3;
2283 void clear_min() ;
2284 ::int32_t min() const;
2285 void set_min(::int32_t value);
2286
2287 private:
2288 ::int32_t _internal_min() const;
2289 void _internal_set_min(::int32_t value);
2290
2291 public:
2292 // uint32 max_channel_id = 4;
2293 void clear_max_channel_id() ;
2294 ::uint32_t max_channel_id() const;
2295 void set_max_channel_id(::uint32_t value);
2296
2297 private:
2298 ::uint32_t _internal_max_channel_id() const;
2299 void _internal_set_max_channel_id(::uint32_t value);
2300
2301 public:
2302 // uint32 min_channel_id = 5;
2303 void clear_min_channel_id() ;
2304 ::uint32_t min_channel_id() const;
2305 void set_min_channel_id(::uint32_t value);
2306
2307 private:
2308 ::uint32_t _internal_min_channel_id() const;
2309 void _internal_set_min_channel_id(::uint32_t value);
2310
2311 public:
2312 // float standard_dev = 6;
2313 void clear_standard_dev() ;
2314 float standard_dev() const;
2315 void set_standard_dev(float value);
2316
2317 private:
2318 float _internal_standard_dev() const;
2319 void _internal_set_standard_dev(float value);
2320
2321 public:
2322 // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo)
2323 private:
2324 class _Internal;
2325
2326 friend class ::google::protobuf::internal::TcParser;
2327 static const ::google::protobuf::internal::TcParseTable<3, 6, 0, 0, 2> _table_;
2328 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
2329 typedef void InternalArenaConstructable_;
2330 typedef void DestructorSkippable_;
2331 struct Impl_ {
2332 float average_;
2333 ::int32_t max_;
2334 ::int32_t min_;
2335 ::uint32_t max_channel_id_;
2336 ::uint32_t min_channel_id_;
2337 float standard_dev_;
2338 mutable ::google::protobuf::internal::CachedSize _cached_size_;
2339 PROTOBUF_TSAN_DECLARE_MEMBER
2340 };
2341 union { Impl_ _impl_; };
2342 friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
2343};
2344
2345// ===================================================================
2346
2347
2348
2349
2350// ===================================================================
2351
2352
2353#ifdef __GNUC__
2354#pragma GCC diagnostic push
2355#pragma GCC diagnostic ignored "-Wstrict-aliasing"
2356#endif // __GNUC__
2357// -------------------------------------------------------------------
2358
2359// LatencyBufferInfo
2360
2361// uint64 num_buffer_elements = 1;
2362inline void LatencyBufferInfo::clear_num_buffer_elements() {
2363 _impl_.num_buffer_elements_ = ::uint64_t{0u};
2364}
2365inline ::uint64_t LatencyBufferInfo::num_buffer_elements() const {
2366 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo.num_buffer_elements)
2367 return _internal_num_buffer_elements();
2368}
2369inline void LatencyBufferInfo::set_num_buffer_elements(::uint64_t value) {
2370 _internal_set_num_buffer_elements(value);
2371 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo.num_buffer_elements)
2372}
2373inline ::uint64_t LatencyBufferInfo::_internal_num_buffer_elements() const {
2374 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2375 return _impl_.num_buffer_elements_;
2376}
2377inline void LatencyBufferInfo::_internal_set_num_buffer_elements(::uint64_t value) {
2378 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2379 ;
2380 _impl_.num_buffer_elements_ = value;
2381}
2382
2383// -------------------------------------------------------------------
2384
2385// DataSourceInfo
2386
2387// uint64 sum_packets = 1;
2388inline void DataSourceInfo::clear_sum_packets() {
2389 _impl_.sum_packets_ = ::uint64_t{0u};
2390}
2391inline ::uint64_t DataSourceInfo::sum_packets() const {
2392 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.sum_packets)
2393 return _internal_sum_packets();
2394}
2395inline void DataSourceInfo::set_sum_packets(::uint64_t value) {
2396 _internal_set_sum_packets(value);
2397 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.sum_packets)
2398}
2399inline ::uint64_t DataSourceInfo::_internal_sum_packets() const {
2400 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2401 return _impl_.sum_packets_;
2402}
2403inline void DataSourceInfo::_internal_set_sum_packets(::uint64_t value) {
2404 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2405 ;
2406 _impl_.sum_packets_ = value;
2407}
2408
2409// uint64 num_packets = 2;
2410inline void DataSourceInfo::clear_num_packets() {
2411 _impl_.num_packets_ = ::uint64_t{0u};
2412}
2413inline ::uint64_t DataSourceInfo::num_packets() const {
2414 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_packets)
2415 return _internal_num_packets();
2416}
2417inline void DataSourceInfo::set_num_packets(::uint64_t value) {
2418 _internal_set_num_packets(value);
2419 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_packets)
2420}
2421inline ::uint64_t DataSourceInfo::_internal_num_packets() const {
2422 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2423 return _impl_.num_packets_;
2424}
2425inline void DataSourceInfo::_internal_set_num_packets(::uint64_t value) {
2426 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2427 ;
2428 _impl_.num_packets_ = value;
2429}
2430
2431// uint64 num_dropped_packets = 3;
2432inline void DataSourceInfo::clear_num_dropped_packets() {
2433 _impl_.num_dropped_packets_ = ::uint64_t{0u};
2434}
2435inline ::uint64_t DataSourceInfo::num_dropped_packets() const {
2436 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_dropped_packets)
2437 return _internal_num_dropped_packets();
2438}
2439inline void DataSourceInfo::set_num_dropped_packets(::uint64_t value) {
2440 _internal_set_num_dropped_packets(value);
2441 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_dropped_packets)
2442}
2443inline ::uint64_t DataSourceInfo::_internal_num_dropped_packets() const {
2444 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2445 return _impl_.num_dropped_packets_;
2446}
2447inline void DataSourceInfo::_internal_set_num_dropped_packets(::uint64_t value) {
2448 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2449 ;
2450 _impl_.num_dropped_packets_ = value;
2451}
2452
2453// -------------------------------------------------------------------
2454
2455// DataHandlerInfo
2456
2457// uint64 sum_payloads = 1;
2458inline void DataHandlerInfo::clear_sum_payloads() {
2459 _impl_.sum_payloads_ = ::uint64_t{0u};
2460}
2461inline ::uint64_t DataHandlerInfo::sum_payloads() const {
2462 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
2463 return _internal_sum_payloads();
2464}
2465inline void DataHandlerInfo::set_sum_payloads(::uint64_t value) {
2466 _internal_set_sum_payloads(value);
2467 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
2468}
2469inline ::uint64_t DataHandlerInfo::_internal_sum_payloads() const {
2470 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2471 return _impl_.sum_payloads_;
2472}
2473inline void DataHandlerInfo::_internal_set_sum_payloads(::uint64_t value) {
2474 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2475 ;
2476 _impl_.sum_payloads_ = value;
2477}
2478
2479// uint64 num_payloads = 2;
2480inline void DataHandlerInfo::clear_num_payloads() {
2481 _impl_.num_payloads_ = ::uint64_t{0u};
2482}
2483inline ::uint64_t DataHandlerInfo::num_payloads() const {
2484 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
2485 return _internal_num_payloads();
2486}
2487inline void DataHandlerInfo::set_num_payloads(::uint64_t value) {
2488 _internal_set_num_payloads(value);
2489 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
2490}
2491inline ::uint64_t DataHandlerInfo::_internal_num_payloads() const {
2492 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2493 return _impl_.num_payloads_;
2494}
2495inline void DataHandlerInfo::_internal_set_num_payloads(::uint64_t value) {
2496 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2497 ;
2498 _impl_.num_payloads_ = value;
2499}
2500
2501// uint64 num_data_input_timeouts = 3;
2502inline void DataHandlerInfo::clear_num_data_input_timeouts() {
2503 _impl_.num_data_input_timeouts_ = ::uint64_t{0u};
2504}
2505inline ::uint64_t DataHandlerInfo::num_data_input_timeouts() const {
2506 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
2507 return _internal_num_data_input_timeouts();
2508}
2509inline void DataHandlerInfo::set_num_data_input_timeouts(::uint64_t value) {
2510 _internal_set_num_data_input_timeouts(value);
2511 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
2512}
2513inline ::uint64_t DataHandlerInfo::_internal_num_data_input_timeouts() const {
2514 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2515 return _impl_.num_data_input_timeouts_;
2516}
2517inline void DataHandlerInfo::_internal_set_num_data_input_timeouts(::uint64_t value) {
2518 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2519 ;
2520 _impl_.num_data_input_timeouts_ = value;
2521}
2522
2523// double rate_payloads_consumed = 4;
2524inline void DataHandlerInfo::clear_rate_payloads_consumed() {
2525 _impl_.rate_payloads_consumed_ = 0;
2526}
2527inline double DataHandlerInfo::rate_payloads_consumed() const {
2528 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
2529 return _internal_rate_payloads_consumed();
2530}
2531inline void DataHandlerInfo::set_rate_payloads_consumed(double value) {
2532 _internal_set_rate_payloads_consumed(value);
2533 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
2534}
2535inline double DataHandlerInfo::_internal_rate_payloads_consumed() const {
2536 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2537 return _impl_.rate_payloads_consumed_;
2538}
2539inline void DataHandlerInfo::_internal_set_rate_payloads_consumed(double value) {
2540 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2541 ;
2542 _impl_.rate_payloads_consumed_ = value;
2543}
2544
2545// uint64 num_lb_insert_failures = 5;
2546inline void DataHandlerInfo::clear_num_lb_insert_failures() {
2547 _impl_.num_lb_insert_failures_ = ::uint64_t{0u};
2548}
2549inline ::uint64_t DataHandlerInfo::num_lb_insert_failures() const {
2550 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
2551 return _internal_num_lb_insert_failures();
2552}
2553inline void DataHandlerInfo::set_num_lb_insert_failures(::uint64_t value) {
2554 _internal_set_num_lb_insert_failures(value);
2555 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
2556}
2557inline ::uint64_t DataHandlerInfo::_internal_num_lb_insert_failures() const {
2558 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2559 return _impl_.num_lb_insert_failures_;
2560}
2561inline void DataHandlerInfo::_internal_set_num_lb_insert_failures(::uint64_t value) {
2562 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2563 ;
2564 _impl_.num_lb_insert_failures_ = value;
2565}
2566
2567// uint64 sum_requests = 11;
2568inline void DataHandlerInfo::clear_sum_requests() {
2569 _impl_.sum_requests_ = ::uint64_t{0u};
2570}
2571inline ::uint64_t DataHandlerInfo::sum_requests() const {
2572 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
2573 return _internal_sum_requests();
2574}
2575inline void DataHandlerInfo::set_sum_requests(::uint64_t value) {
2576 _internal_set_sum_requests(value);
2577 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
2578}
2579inline ::uint64_t DataHandlerInfo::_internal_sum_requests() const {
2580 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2581 return _impl_.sum_requests_;
2582}
2583inline void DataHandlerInfo::_internal_set_sum_requests(::uint64_t value) {
2584 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2585 ;
2586 _impl_.sum_requests_ = value;
2587}
2588
2589// uint64 num_requests = 12;
2590inline void DataHandlerInfo::clear_num_requests() {
2591 _impl_.num_requests_ = ::uint64_t{0u};
2592}
2593inline ::uint64_t DataHandlerInfo::num_requests() const {
2594 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
2595 return _internal_num_requests();
2596}
2597inline void DataHandlerInfo::set_num_requests(::uint64_t value) {
2598 _internal_set_num_requests(value);
2599 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
2600}
2601inline ::uint64_t DataHandlerInfo::_internal_num_requests() const {
2602 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2603 return _impl_.num_requests_;
2604}
2605inline void DataHandlerInfo::_internal_set_num_requests(::uint64_t value) {
2606 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2607 ;
2608 _impl_.num_requests_ = value;
2609}
2610
2611// uint64 last_daq_timestamp = 21;
2612inline void DataHandlerInfo::clear_last_daq_timestamp() {
2613 _impl_.last_daq_timestamp_ = ::uint64_t{0u};
2614}
2615inline ::uint64_t DataHandlerInfo::last_daq_timestamp() const {
2616 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
2617 return _internal_last_daq_timestamp();
2618}
2619inline void DataHandlerInfo::set_last_daq_timestamp(::uint64_t value) {
2620 _internal_set_last_daq_timestamp(value);
2621 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
2622}
2623inline ::uint64_t DataHandlerInfo::_internal_last_daq_timestamp() const {
2624 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2625 return _impl_.last_daq_timestamp_;
2626}
2627inline void DataHandlerInfo::_internal_set_last_daq_timestamp(::uint64_t value) {
2628 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2629 ;
2630 _impl_.last_daq_timestamp_ = value;
2631}
2632
2633// uint64 newest_timestamp = 22;
2634inline void DataHandlerInfo::clear_newest_timestamp() {
2635 _impl_.newest_timestamp_ = ::uint64_t{0u};
2636}
2637inline ::uint64_t DataHandlerInfo::newest_timestamp() const {
2638 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.newest_timestamp)
2639 return _internal_newest_timestamp();
2640}
2641inline void DataHandlerInfo::set_newest_timestamp(::uint64_t value) {
2642 _internal_set_newest_timestamp(value);
2643 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.newest_timestamp)
2644}
2645inline ::uint64_t DataHandlerInfo::_internal_newest_timestamp() const {
2646 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2647 return _impl_.newest_timestamp_;
2648}
2649inline void DataHandlerInfo::_internal_set_newest_timestamp(::uint64_t value) {
2650 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2651 ;
2652 _impl_.newest_timestamp_ = value;
2653}
2654
2655// uint64 oldest_timestamp = 23;
2656inline void DataHandlerInfo::clear_oldest_timestamp() {
2657 _impl_.oldest_timestamp_ = ::uint64_t{0u};
2658}
2659inline ::uint64_t DataHandlerInfo::oldest_timestamp() const {
2660 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.oldest_timestamp)
2661 return _internal_oldest_timestamp();
2662}
2663inline void DataHandlerInfo::set_oldest_timestamp(::uint64_t value) {
2664 _internal_set_oldest_timestamp(value);
2665 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.oldest_timestamp)
2666}
2667inline ::uint64_t DataHandlerInfo::_internal_oldest_timestamp() const {
2668 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2669 return _impl_.oldest_timestamp_;
2670}
2671inline void DataHandlerInfo::_internal_set_oldest_timestamp(::uint64_t value) {
2672 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2673 ;
2674 _impl_.oldest_timestamp_ = value;
2675}
2676
2677// uint64 num_post_processing_delay_max_waits = 31;
2678inline void DataHandlerInfo::clear_num_post_processing_delay_max_waits() {
2679 _impl_.num_post_processing_delay_max_waits_ = ::uint64_t{0u};
2680}
2681inline ::uint64_t DataHandlerInfo::num_post_processing_delay_max_waits() const {
2682 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
2683 return _internal_num_post_processing_delay_max_waits();
2684}
2685inline void DataHandlerInfo::set_num_post_processing_delay_max_waits(::uint64_t value) {
2686 _internal_set_num_post_processing_delay_max_waits(value);
2687 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
2688}
2689inline ::uint64_t DataHandlerInfo::_internal_num_post_processing_delay_max_waits() const {
2690 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2691 return _impl_.num_post_processing_delay_max_waits_;
2692}
2693inline void DataHandlerInfo::_internal_set_num_post_processing_delay_max_waits(::uint64_t value) {
2694 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2695 ;
2696 _impl_.num_post_processing_delay_max_waits_ = value;
2697}
2698
2699// -------------------------------------------------------------------
2700
2701// RequestHandlerInfo
2702
2703// uint64 num_requests_handled = 1;
2704inline void RequestHandlerInfo::clear_num_requests_handled() {
2705 _impl_.num_requests_handled_ = ::uint64_t{0u};
2706}
2707inline ::uint64_t RequestHandlerInfo::num_requests_handled() const {
2708 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_handled)
2709 return _internal_num_requests_handled();
2710}
2711inline void RequestHandlerInfo::set_num_requests_handled(::uint64_t value) {
2712 _internal_set_num_requests_handled(value);
2713 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_handled)
2714}
2715inline ::uint64_t RequestHandlerInfo::_internal_num_requests_handled() const {
2716 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2717 return _impl_.num_requests_handled_;
2718}
2719inline void RequestHandlerInfo::_internal_set_num_requests_handled(::uint64_t value) {
2720 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2721 ;
2722 _impl_.num_requests_handled_ = value;
2723}
2724
2725// uint64 num_requests_found = 2;
2726inline void RequestHandlerInfo::clear_num_requests_found() {
2727 _impl_.num_requests_found_ = ::uint64_t{0u};
2728}
2729inline ::uint64_t RequestHandlerInfo::num_requests_found() const {
2730 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_found)
2731 return _internal_num_requests_found();
2732}
2733inline void RequestHandlerInfo::set_num_requests_found(::uint64_t value) {
2734 _internal_set_num_requests_found(value);
2735 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_found)
2736}
2737inline ::uint64_t RequestHandlerInfo::_internal_num_requests_found() const {
2738 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2739 return _impl_.num_requests_found_;
2740}
2741inline void RequestHandlerInfo::_internal_set_num_requests_found(::uint64_t value) {
2742 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2743 ;
2744 _impl_.num_requests_found_ = value;
2745}
2746
2747// uint64 num_requests_bad = 3;
2748inline void RequestHandlerInfo::clear_num_requests_bad() {
2749 _impl_.num_requests_bad_ = ::uint64_t{0u};
2750}
2751inline ::uint64_t RequestHandlerInfo::num_requests_bad() const {
2752 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_bad)
2753 return _internal_num_requests_bad();
2754}
2755inline void RequestHandlerInfo::set_num_requests_bad(::uint64_t value) {
2756 _internal_set_num_requests_bad(value);
2757 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_bad)
2758}
2759inline ::uint64_t RequestHandlerInfo::_internal_num_requests_bad() const {
2760 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2761 return _impl_.num_requests_bad_;
2762}
2763inline void RequestHandlerInfo::_internal_set_num_requests_bad(::uint64_t value) {
2764 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2765 ;
2766 _impl_.num_requests_bad_ = value;
2767}
2768
2769// uint64 num_requests_old_window = 4;
2770inline void RequestHandlerInfo::clear_num_requests_old_window() {
2771 _impl_.num_requests_old_window_ = ::uint64_t{0u};
2772}
2773inline ::uint64_t RequestHandlerInfo::num_requests_old_window() const {
2774 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_old_window)
2775 return _internal_num_requests_old_window();
2776}
2777inline void RequestHandlerInfo::set_num_requests_old_window(::uint64_t value) {
2778 _internal_set_num_requests_old_window(value);
2779 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_old_window)
2780}
2781inline ::uint64_t RequestHandlerInfo::_internal_num_requests_old_window() const {
2782 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2783 return _impl_.num_requests_old_window_;
2784}
2785inline void RequestHandlerInfo::_internal_set_num_requests_old_window(::uint64_t value) {
2786 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2787 ;
2788 _impl_.num_requests_old_window_ = value;
2789}
2790
2791// uint64 num_requests_delayed = 5;
2792inline void RequestHandlerInfo::clear_num_requests_delayed() {
2793 _impl_.num_requests_delayed_ = ::uint64_t{0u};
2794}
2795inline ::uint64_t RequestHandlerInfo::num_requests_delayed() const {
2796 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_delayed)
2797 return _internal_num_requests_delayed();
2798}
2799inline void RequestHandlerInfo::set_num_requests_delayed(::uint64_t value) {
2800 _internal_set_num_requests_delayed(value);
2801 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_delayed)
2802}
2803inline ::uint64_t RequestHandlerInfo::_internal_num_requests_delayed() const {
2804 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2805 return _impl_.num_requests_delayed_;
2806}
2807inline void RequestHandlerInfo::_internal_set_num_requests_delayed(::uint64_t value) {
2808 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2809 ;
2810 _impl_.num_requests_delayed_ = value;
2811}
2812
2813// uint64 num_requests_uncategorized = 6;
2814inline void RequestHandlerInfo::clear_num_requests_uncategorized() {
2815 _impl_.num_requests_uncategorized_ = ::uint64_t{0u};
2816}
2817inline ::uint64_t RequestHandlerInfo::num_requests_uncategorized() const {
2818 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_uncategorized)
2819 return _internal_num_requests_uncategorized();
2820}
2821inline void RequestHandlerInfo::set_num_requests_uncategorized(::uint64_t value) {
2822 _internal_set_num_requests_uncategorized(value);
2823 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_uncategorized)
2824}
2825inline ::uint64_t RequestHandlerInfo::_internal_num_requests_uncategorized() const {
2826 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2827 return _impl_.num_requests_uncategorized_;
2828}
2829inline void RequestHandlerInfo::_internal_set_num_requests_uncategorized(::uint64_t value) {
2830 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2831 ;
2832 _impl_.num_requests_uncategorized_ = value;
2833}
2834
2835// uint64 num_requests_timed_out = 7;
2836inline void RequestHandlerInfo::clear_num_requests_timed_out() {
2837 _impl_.num_requests_timed_out_ = ::uint64_t{0u};
2838}
2839inline ::uint64_t RequestHandlerInfo::num_requests_timed_out() const {
2840 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_timed_out)
2841 return _internal_num_requests_timed_out();
2842}
2843inline void RequestHandlerInfo::set_num_requests_timed_out(::uint64_t value) {
2844 _internal_set_num_requests_timed_out(value);
2845 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_timed_out)
2846}
2847inline ::uint64_t RequestHandlerInfo::_internal_num_requests_timed_out() const {
2848 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2849 return _impl_.num_requests_timed_out_;
2850}
2851inline void RequestHandlerInfo::_internal_set_num_requests_timed_out(::uint64_t value) {
2852 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2853 ;
2854 _impl_.num_requests_timed_out_ = value;
2855}
2856
2857// uint64 num_requests_waiting = 8;
2858inline void RequestHandlerInfo::clear_num_requests_waiting() {
2859 _impl_.num_requests_waiting_ = ::uint64_t{0u};
2860}
2861inline ::uint64_t RequestHandlerInfo::num_requests_waiting() const {
2862 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_waiting)
2863 return _internal_num_requests_waiting();
2864}
2865inline void RequestHandlerInfo::set_num_requests_waiting(::uint64_t value) {
2866 _internal_set_num_requests_waiting(value);
2867 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_waiting)
2868}
2869inline ::uint64_t RequestHandlerInfo::_internal_num_requests_waiting() const {
2870 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2871 return _impl_.num_requests_waiting_;
2872}
2873inline void RequestHandlerInfo::_internal_set_num_requests_waiting(::uint64_t value) {
2874 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2875 ;
2876 _impl_.num_requests_waiting_ = value;
2877}
2878
2879// uint64 avg_request_response_time = 21;
2880inline void RequestHandlerInfo::clear_avg_request_response_time() {
2881 _impl_.avg_request_response_time_ = ::uint64_t{0u};
2882}
2883inline ::uint64_t RequestHandlerInfo::avg_request_response_time() const {
2884 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.avg_request_response_time)
2885 return _internal_avg_request_response_time();
2886}
2887inline void RequestHandlerInfo::set_avg_request_response_time(::uint64_t value) {
2888 _internal_set_avg_request_response_time(value);
2889 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.avg_request_response_time)
2890}
2891inline ::uint64_t RequestHandlerInfo::_internal_avg_request_response_time() const {
2892 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2893 return _impl_.avg_request_response_time_;
2894}
2895inline void RequestHandlerInfo::_internal_set_avg_request_response_time(::uint64_t value) {
2896 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2897 ;
2898 _impl_.avg_request_response_time_ = value;
2899}
2900
2901// uint64 tot_request_response_time = 22;
2902inline void RequestHandlerInfo::clear_tot_request_response_time() {
2903 _impl_.tot_request_response_time_ = ::uint64_t{0u};
2904}
2905inline ::uint64_t RequestHandlerInfo::tot_request_response_time() const {
2906 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.tot_request_response_time)
2907 return _internal_tot_request_response_time();
2908}
2909inline void RequestHandlerInfo::set_tot_request_response_time(::uint64_t value) {
2910 _internal_set_tot_request_response_time(value);
2911 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.tot_request_response_time)
2912}
2913inline ::uint64_t RequestHandlerInfo::_internal_tot_request_response_time() const {
2914 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2915 return _impl_.tot_request_response_time_;
2916}
2917inline void RequestHandlerInfo::_internal_set_tot_request_response_time(::uint64_t value) {
2918 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2919 ;
2920 _impl_.tot_request_response_time_ = value;
2921}
2922
2923// uint64 min_request_response_time = 23;
2924inline void RequestHandlerInfo::clear_min_request_response_time() {
2925 _impl_.min_request_response_time_ = ::uint64_t{0u};
2926}
2927inline ::uint64_t RequestHandlerInfo::min_request_response_time() const {
2928 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.min_request_response_time)
2929 return _internal_min_request_response_time();
2930}
2931inline void RequestHandlerInfo::set_min_request_response_time(::uint64_t value) {
2932 _internal_set_min_request_response_time(value);
2933 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.min_request_response_time)
2934}
2935inline ::uint64_t RequestHandlerInfo::_internal_min_request_response_time() const {
2936 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2937 return _impl_.min_request_response_time_;
2938}
2939inline void RequestHandlerInfo::_internal_set_min_request_response_time(::uint64_t value) {
2940 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2941 ;
2942 _impl_.min_request_response_time_ = value;
2943}
2944
2945// uint64 max_request_response_time = 24;
2946inline void RequestHandlerInfo::clear_max_request_response_time() {
2947 _impl_.max_request_response_time_ = ::uint64_t{0u};
2948}
2949inline ::uint64_t RequestHandlerInfo::max_request_response_time() const {
2950 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.max_request_response_time)
2951 return _internal_max_request_response_time();
2952}
2953inline void RequestHandlerInfo::set_max_request_response_time(::uint64_t value) {
2954 _internal_set_max_request_response_time(value);
2955 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.max_request_response_time)
2956}
2957inline ::uint64_t RequestHandlerInfo::_internal_max_request_response_time() const {
2958 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2959 return _impl_.max_request_response_time_;
2960}
2961inline void RequestHandlerInfo::_internal_set_max_request_response_time(::uint64_t value) {
2962 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2963 ;
2964 _impl_.max_request_response_time_ = value;
2965}
2966
2967// uint64 num_buffer_cleanups = 31;
2968inline void RequestHandlerInfo::clear_num_buffer_cleanups() {
2969 _impl_.num_buffer_cleanups_ = ::uint64_t{0u};
2970}
2971inline ::uint64_t RequestHandlerInfo::num_buffer_cleanups() const {
2972 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_buffer_cleanups)
2973 return _internal_num_buffer_cleanups();
2974}
2975inline void RequestHandlerInfo::set_num_buffer_cleanups(::uint64_t value) {
2976 _internal_set_num_buffer_cleanups(value);
2977 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_buffer_cleanups)
2978}
2979inline ::uint64_t RequestHandlerInfo::_internal_num_buffer_cleanups() const {
2980 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
2981 return _impl_.num_buffer_cleanups_;
2982}
2983inline void RequestHandlerInfo::_internal_set_num_buffer_cleanups(::uint64_t value) {
2984 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
2985 ;
2986 _impl_.num_buffer_cleanups_ = value;
2987}
2988
2989// uint64 num_periodic_sent = 41;
2990inline void RequestHandlerInfo::clear_num_periodic_sent() {
2991 _impl_.num_periodic_sent_ = ::uint64_t{0u};
2992}
2993inline ::uint64_t RequestHandlerInfo::num_periodic_sent() const {
2994 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_sent)
2995 return _internal_num_periodic_sent();
2996}
2997inline void RequestHandlerInfo::set_num_periodic_sent(::uint64_t value) {
2998 _internal_set_num_periodic_sent(value);
2999 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_sent)
3000}
3001inline ::uint64_t RequestHandlerInfo::_internal_num_periodic_sent() const {
3002 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3003 return _impl_.num_periodic_sent_;
3004}
3005inline void RequestHandlerInfo::_internal_set_num_periodic_sent(::uint64_t value) {
3006 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3007 ;
3008 _impl_.num_periodic_sent_ = value;
3009}
3010
3011// uint64 num_periodic_send_failed = 42;
3012inline void RequestHandlerInfo::clear_num_periodic_send_failed() {
3013 _impl_.num_periodic_send_failed_ = ::uint64_t{0u};
3014}
3015inline ::uint64_t RequestHandlerInfo::num_periodic_send_failed() const {
3016 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_send_failed)
3017 return _internal_num_periodic_send_failed();
3018}
3019inline void RequestHandlerInfo::set_num_periodic_send_failed(::uint64_t value) {
3020 _internal_set_num_periodic_send_failed(value);
3021 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_send_failed)
3022}
3023inline ::uint64_t RequestHandlerInfo::_internal_num_periodic_send_failed() const {
3024 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3025 return _impl_.num_periodic_send_failed_;
3026}
3027inline void RequestHandlerInfo::_internal_set_num_periodic_send_failed(::uint64_t value) {
3028 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3029 ;
3030 _impl_.num_periodic_send_failed_ = value;
3031}
3032
3033// -------------------------------------------------------------------
3034
3035// RecordingInfo
3036
3037// string recording_status = 1;
3038inline void RecordingInfo::clear_recording_status() {
3039 _impl_.recording_status_.ClearToEmpty();
3040}
3041inline const std::string& RecordingInfo::recording_status() const {
3042 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
3043 return _internal_recording_status();
3044}
3045template <typename Arg_, typename... Args_>
3046inline PROTOBUF_ALWAYS_INLINE void RecordingInfo::set_recording_status(Arg_&& arg,
3047 Args_... args) {
3048 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3049 ;
3050 _impl_.recording_status_.Set(static_cast<Arg_&&>(arg), args..., GetArenaForAllocation());
3051 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
3052}
3053inline std::string* RecordingInfo::mutable_recording_status() {
3054 std::string* _s = _internal_mutable_recording_status();
3055 // @@protoc_insertion_point(field_mutable:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
3056 return _s;
3057}
3058inline const std::string& RecordingInfo::_internal_recording_status() const {
3059 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3060 return _impl_.recording_status_.Get();
3061}
3062inline void RecordingInfo::_internal_set_recording_status(const std::string& value) {
3063 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3064 ;
3065 _impl_.recording_status_.Set(value, GetArenaForAllocation());
3066}
3067inline std::string* RecordingInfo::_internal_mutable_recording_status() {
3068 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3069 ;
3070 return _impl_.recording_status_.Mutable( GetArenaForAllocation());
3071}
3072inline std::string* RecordingInfo::release_recording_status() {
3073 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3074 // @@protoc_insertion_point(field_release:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
3075 return _impl_.recording_status_.Release();
3076}
3077inline void RecordingInfo::set_allocated_recording_status(std::string* value) {
3078 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3079 _impl_.recording_status_.SetAllocated(value, GetArenaForAllocation());
3080 #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3081 if (_impl_.recording_status_.IsDefault()) {
3082 _impl_.recording_status_.Set("", GetArenaForAllocation());
3083 }
3084 #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3085 // @@protoc_insertion_point(field_set_allocated:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
3086}
3087
3088// uint64 packets_recorded = 2;
3089inline void RecordingInfo::clear_packets_recorded() {
3090 _impl_.packets_recorded_ = ::uint64_t{0u};
3091}
3092inline ::uint64_t RecordingInfo::packets_recorded() const {
3093 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.packets_recorded)
3094 return _internal_packets_recorded();
3095}
3096inline void RecordingInfo::set_packets_recorded(::uint64_t value) {
3097 _internal_set_packets_recorded(value);
3098 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.packets_recorded)
3099}
3100inline ::uint64_t RecordingInfo::_internal_packets_recorded() const {
3101 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3102 return _impl_.packets_recorded_;
3103}
3104inline void RecordingInfo::_internal_set_packets_recorded(::uint64_t value) {
3105 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3106 ;
3107 _impl_.packets_recorded_ = value;
3108}
3109
3110// uint64 bytes_recorded = 3;
3111inline void RecordingInfo::clear_bytes_recorded() {
3112 _impl_.bytes_recorded_ = ::uint64_t{0u};
3113}
3114inline ::uint64_t RecordingInfo::bytes_recorded() const {
3115 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.bytes_recorded)
3116 return _internal_bytes_recorded();
3117}
3118inline void RecordingInfo::set_bytes_recorded(::uint64_t value) {
3119 _internal_set_bytes_recorded(value);
3120 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.bytes_recorded)
3121}
3122inline ::uint64_t RecordingInfo::_internal_bytes_recorded() const {
3123 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3124 return _impl_.bytes_recorded_;
3125}
3126inline void RecordingInfo::_internal_set_bytes_recorded(::uint64_t value) {
3127 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3128 ;
3129 _impl_.bytes_recorded_ = value;
3130}
3131
3132// -------------------------------------------------------------------
3133
3134// DataProcessorInfo
3135
3136// uint64 elements_queued = 1;
3137inline void DataProcessorInfo::clear_elements_queued() {
3138 _impl_.elements_queued_ = ::uint64_t{0u};
3139}
3140inline ::uint64_t DataProcessorInfo::elements_queued() const {
3141 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataProcessorInfo.elements_queued)
3142 return _internal_elements_queued();
3143}
3144inline void DataProcessorInfo::set_elements_queued(::uint64_t value) {
3145 _internal_set_elements_queued(value);
3146 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataProcessorInfo.elements_queued)
3147}
3148inline ::uint64_t DataProcessorInfo::_internal_elements_queued() const {
3149 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3150 return _impl_.elements_queued_;
3151}
3152inline void DataProcessorInfo::_internal_set_elements_queued(::uint64_t value) {
3153 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3154 ;
3155 _impl_.elements_queued_ = value;
3156}
3157
3158// -------------------------------------------------------------------
3159
3160// FixedRateDataProcessorInfo
3161
3162// uint64 num_seq_id_errors = 1;
3163inline void FixedRateDataProcessorInfo::clear_num_seq_id_errors() {
3164 _impl_.num_seq_id_errors_ = ::uint64_t{0u};
3165}
3166inline ::uint64_t FixedRateDataProcessorInfo::num_seq_id_errors() const {
3167 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_seq_id_errors)
3168 return _internal_num_seq_id_errors();
3169}
3170inline void FixedRateDataProcessorInfo::set_num_seq_id_errors(::uint64_t value) {
3171 _internal_set_num_seq_id_errors(value);
3172 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_seq_id_errors)
3173}
3174inline ::uint64_t FixedRateDataProcessorInfo::_internal_num_seq_id_errors() const {
3175 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3176 return _impl_.num_seq_id_errors_;
3177}
3178inline void FixedRateDataProcessorInfo::_internal_set_num_seq_id_errors(::uint64_t value) {
3179 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3180 ;
3181 _impl_.num_seq_id_errors_ = value;
3182}
3183
3184// uint64 min_seq_id_jump = 2;
3185inline void FixedRateDataProcessorInfo::clear_min_seq_id_jump() {
3186 _impl_.min_seq_id_jump_ = ::uint64_t{0u};
3187}
3188inline ::uint64_t FixedRateDataProcessorInfo::min_seq_id_jump() const {
3189 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.min_seq_id_jump)
3190 return _internal_min_seq_id_jump();
3191}
3192inline void FixedRateDataProcessorInfo::set_min_seq_id_jump(::uint64_t value) {
3193 _internal_set_min_seq_id_jump(value);
3194 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.min_seq_id_jump)
3195}
3196inline ::uint64_t FixedRateDataProcessorInfo::_internal_min_seq_id_jump() const {
3197 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3198 return _impl_.min_seq_id_jump_;
3199}
3200inline void FixedRateDataProcessorInfo::_internal_set_min_seq_id_jump(::uint64_t value) {
3201 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3202 ;
3203 _impl_.min_seq_id_jump_ = value;
3204}
3205
3206// uint64 max_seq_id_jump = 3;
3207inline void FixedRateDataProcessorInfo::clear_max_seq_id_jump() {
3208 _impl_.max_seq_id_jump_ = ::uint64_t{0u};
3209}
3210inline ::uint64_t FixedRateDataProcessorInfo::max_seq_id_jump() const {
3211 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.max_seq_id_jump)
3212 return _internal_max_seq_id_jump();
3213}
3214inline void FixedRateDataProcessorInfo::set_max_seq_id_jump(::uint64_t value) {
3215 _internal_set_max_seq_id_jump(value);
3216 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.max_seq_id_jump)
3217}
3218inline ::uint64_t FixedRateDataProcessorInfo::_internal_max_seq_id_jump() const {
3219 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3220 return _impl_.max_seq_id_jump_;
3221}
3222inline void FixedRateDataProcessorInfo::_internal_set_max_seq_id_jump(::uint64_t value) {
3223 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3224 ;
3225 _impl_.max_seq_id_jump_ = value;
3226}
3227
3228// uint64 num_ts_errors = 4;
3229inline void FixedRateDataProcessorInfo::clear_num_ts_errors() {
3230 _impl_.num_ts_errors_ = ::uint64_t{0u};
3231}
3232inline ::uint64_t FixedRateDataProcessorInfo::num_ts_errors() const {
3233 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_ts_errors)
3234 return _internal_num_ts_errors();
3235}
3236inline void FixedRateDataProcessorInfo::set_num_ts_errors(::uint64_t value) {
3237 _internal_set_num_ts_errors(value);
3238 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_ts_errors)
3239}
3240inline ::uint64_t FixedRateDataProcessorInfo::_internal_num_ts_errors() const {
3241 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3242 return _impl_.num_ts_errors_;
3243}
3244inline void FixedRateDataProcessorInfo::_internal_set_num_ts_errors(::uint64_t value) {
3245 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3246 ;
3247 _impl_.num_ts_errors_ = value;
3248}
3249
3250// -------------------------------------------------------------------
3251
3252// HitFindingInfo
3253
3254// float rate_tp_hits = 1;
3255inline void HitFindingInfo::clear_rate_tp_hits() {
3256 _impl_.rate_tp_hits_ = 0;
3257}
3258inline float HitFindingInfo::rate_tp_hits() const {
3259 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.rate_tp_hits)
3260 return _internal_rate_tp_hits();
3261}
3262inline void HitFindingInfo::set_rate_tp_hits(float value) {
3263 _internal_set_rate_tp_hits(value);
3264 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.rate_tp_hits)
3265}
3266inline float HitFindingInfo::_internal_rate_tp_hits() const {
3267 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3268 return _impl_.rate_tp_hits_;
3269}
3270inline void HitFindingInfo::_internal_set_rate_tp_hits(float value) {
3271 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3272 ;
3273 _impl_.rate_tp_hits_ = value;
3274}
3275
3276// uint64 num_tps_sent = 2;
3277inline void HitFindingInfo::clear_num_tps_sent() {
3278 _impl_.num_tps_sent_ = ::uint64_t{0u};
3279}
3280inline ::uint64_t HitFindingInfo::num_tps_sent() const {
3281 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_sent)
3282 return _internal_num_tps_sent();
3283}
3284inline void HitFindingInfo::set_num_tps_sent(::uint64_t value) {
3285 _internal_set_num_tps_sent(value);
3286 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_sent)
3287}
3288inline ::uint64_t HitFindingInfo::_internal_num_tps_sent() const {
3289 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3290 return _impl_.num_tps_sent_;
3291}
3292inline void HitFindingInfo::_internal_set_num_tps_sent(::uint64_t value) {
3293 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3294 ;
3295 _impl_.num_tps_sent_ = value;
3296}
3297
3298// uint64 num_tps_send_failed = 3;
3299inline void HitFindingInfo::clear_num_tps_send_failed() {
3300 _impl_.num_tps_send_failed_ = ::uint64_t{0u};
3301}
3302inline ::uint64_t HitFindingInfo::num_tps_send_failed() const {
3303 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_send_failed)
3304 return _internal_num_tps_send_failed();
3305}
3306inline void HitFindingInfo::set_num_tps_send_failed(::uint64_t value) {
3307 _internal_set_num_tps_send_failed(value);
3308 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_send_failed)
3309}
3310inline ::uint64_t HitFindingInfo::_internal_num_tps_send_failed() const {
3311 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3312 return _impl_.num_tps_send_failed_;
3313}
3314inline void HitFindingInfo::_internal_set_num_tps_send_failed(::uint64_t value) {
3315 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3316 ;
3317 _impl_.num_tps_send_failed_ = value;
3318}
3319
3320// uint64 num_tps_suppressed_too_long = 4;
3321inline void HitFindingInfo::clear_num_tps_suppressed_too_long() {
3322 _impl_.num_tps_suppressed_too_long_ = ::uint64_t{0u};
3323}
3324inline ::uint64_t HitFindingInfo::num_tps_suppressed_too_long() const {
3325 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_suppressed_too_long)
3326 return _internal_num_tps_suppressed_too_long();
3327}
3328inline void HitFindingInfo::set_num_tps_suppressed_too_long(::uint64_t value) {
3329 _internal_set_num_tps_suppressed_too_long(value);
3330 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_suppressed_too_long)
3331}
3332inline ::uint64_t HitFindingInfo::_internal_num_tps_suppressed_too_long() const {
3333 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3334 return _impl_.num_tps_suppressed_too_long_;
3335}
3336inline void HitFindingInfo::_internal_set_num_tps_suppressed_too_long(::uint64_t value) {
3337 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3338 ;
3339 _impl_.num_tps_suppressed_too_long_ = value;
3340}
3341
3342// -------------------------------------------------------------------
3343
3344// TPChannelInfo
3345
3346// uint64 channel_id = 1;
3347inline void TPChannelInfo::clear_channel_id() {
3348 _impl_.channel_id_ = ::uint64_t{0u};
3349}
3350inline ::uint64_t TPChannelInfo::channel_id() const {
3351 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPChannelInfo.channel_id)
3352 return _internal_channel_id();
3353}
3354inline void TPChannelInfo::set_channel_id(::uint64_t value) {
3355 _internal_set_channel_id(value);
3356 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPChannelInfo.channel_id)
3357}
3358inline ::uint64_t TPChannelInfo::_internal_channel_id() const {
3359 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3360 return _impl_.channel_id_;
3361}
3362inline void TPChannelInfo::_internal_set_channel_id(::uint64_t value) {
3363 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3364 ;
3365 _impl_.channel_id_ = value;
3366}
3367
3368// uint64 number_of_tps = 2;
3369inline void TPChannelInfo::clear_number_of_tps() {
3370 _impl_.number_of_tps_ = ::uint64_t{0u};
3371}
3372inline ::uint64_t TPChannelInfo::number_of_tps() const {
3373 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPChannelInfo.number_of_tps)
3374 return _internal_number_of_tps();
3375}
3376inline void TPChannelInfo::set_number_of_tps(::uint64_t value) {
3377 _internal_set_number_of_tps(value);
3378 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPChannelInfo.number_of_tps)
3379}
3380inline ::uint64_t TPChannelInfo::_internal_number_of_tps() const {
3381 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3382 return _impl_.number_of_tps_;
3383}
3384inline void TPChannelInfo::_internal_set_number_of_tps(::uint64_t value) {
3385 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3386 ;
3387 _impl_.number_of_tps_ = value;
3388}
3389
3390// -------------------------------------------------------------------
3391
3392// TPGProcessorInfo
3393
3394// int64 pedestal = 1;
3395inline void TPGProcessorInfo::clear_pedestal() {
3396 _impl_.pedestal_ = ::int64_t{0};
3397}
3398inline ::int64_t TPGProcessorInfo::pedestal() const {
3399 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.pedestal)
3400 return _internal_pedestal();
3401}
3402inline void TPGProcessorInfo::set_pedestal(::int64_t value) {
3403 _internal_set_pedestal(value);
3404 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.pedestal)
3405}
3406inline ::int64_t TPGProcessorInfo::_internal_pedestal() const {
3407 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3408 return _impl_.pedestal_;
3409}
3410inline void TPGProcessorInfo::_internal_set_pedestal(::int64_t value) {
3411 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3412 ;
3413 _impl_.pedestal_ = value;
3414}
3415
3416// int64 accum = 2;
3417inline void TPGProcessorInfo::clear_accum() {
3418 _impl_.accum_ = ::int64_t{0};
3419}
3420inline ::int64_t TPGProcessorInfo::accum() const {
3421 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.accum)
3422 return _internal_accum();
3423}
3424inline void TPGProcessorInfo::set_accum(::int64_t value) {
3425 _internal_set_accum(value);
3426 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.accum)
3427}
3428inline ::int64_t TPGProcessorInfo::_internal_accum() const {
3429 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3430 return _impl_.accum_;
3431}
3432inline void TPGProcessorInfo::_internal_set_accum(::int64_t value) {
3433 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3434 ;
3435 _impl_.accum_ = value;
3436}
3437
3438// -------------------------------------------------------------------
3439
3440// TPGProcessorReducedInfo
3441
3442// float average = 1;
3443inline void TPGProcessorReducedInfo::clear_average() {
3444 _impl_.average_ = 0;
3445}
3446inline float TPGProcessorReducedInfo::average() const {
3447 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.average)
3448 return _internal_average();
3449}
3450inline void TPGProcessorReducedInfo::set_average(float value) {
3451 _internal_set_average(value);
3452 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.average)
3453}
3454inline float TPGProcessorReducedInfo::_internal_average() const {
3455 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3456 return _impl_.average_;
3457}
3458inline void TPGProcessorReducedInfo::_internal_set_average(float value) {
3459 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3460 ;
3461 _impl_.average_ = value;
3462}
3463
3464// int32 max = 2;
3465inline void TPGProcessorReducedInfo::clear_max() {
3466 _impl_.max_ = 0;
3467}
3468inline ::int32_t TPGProcessorReducedInfo::max() const {
3469 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max)
3470 return _internal_max();
3471}
3472inline void TPGProcessorReducedInfo::set_max(::int32_t value) {
3473 _internal_set_max(value);
3474 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max)
3475}
3476inline ::int32_t TPGProcessorReducedInfo::_internal_max() const {
3477 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3478 return _impl_.max_;
3479}
3480inline void TPGProcessorReducedInfo::_internal_set_max(::int32_t value) {
3481 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3482 ;
3483 _impl_.max_ = value;
3484}
3485
3486// int32 min = 3;
3487inline void TPGProcessorReducedInfo::clear_min() {
3488 _impl_.min_ = 0;
3489}
3490inline ::int32_t TPGProcessorReducedInfo::min() const {
3491 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min)
3492 return _internal_min();
3493}
3494inline void TPGProcessorReducedInfo::set_min(::int32_t value) {
3495 _internal_set_min(value);
3496 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min)
3497}
3498inline ::int32_t TPGProcessorReducedInfo::_internal_min() const {
3499 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3500 return _impl_.min_;
3501}
3502inline void TPGProcessorReducedInfo::_internal_set_min(::int32_t value) {
3503 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3504 ;
3505 _impl_.min_ = value;
3506}
3507
3508// uint32 max_channel_id = 4;
3509inline void TPGProcessorReducedInfo::clear_max_channel_id() {
3510 _impl_.max_channel_id_ = 0u;
3511}
3512inline ::uint32_t TPGProcessorReducedInfo::max_channel_id() const {
3513 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max_channel_id)
3514 return _internal_max_channel_id();
3515}
3516inline void TPGProcessorReducedInfo::set_max_channel_id(::uint32_t value) {
3517 _internal_set_max_channel_id(value);
3518 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max_channel_id)
3519}
3520inline ::uint32_t TPGProcessorReducedInfo::_internal_max_channel_id() const {
3521 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3522 return _impl_.max_channel_id_;
3523}
3524inline void TPGProcessorReducedInfo::_internal_set_max_channel_id(::uint32_t value) {
3525 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3526 ;
3527 _impl_.max_channel_id_ = value;
3528}
3529
3530// uint32 min_channel_id = 5;
3531inline void TPGProcessorReducedInfo::clear_min_channel_id() {
3532 _impl_.min_channel_id_ = 0u;
3533}
3534inline ::uint32_t TPGProcessorReducedInfo::min_channel_id() const {
3535 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min_channel_id)
3536 return _internal_min_channel_id();
3537}
3538inline void TPGProcessorReducedInfo::set_min_channel_id(::uint32_t value) {
3539 _internal_set_min_channel_id(value);
3540 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min_channel_id)
3541}
3542inline ::uint32_t TPGProcessorReducedInfo::_internal_min_channel_id() const {
3543 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3544 return _impl_.min_channel_id_;
3545}
3546inline void TPGProcessorReducedInfo::_internal_set_min_channel_id(::uint32_t value) {
3547 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3548 ;
3549 _impl_.min_channel_id_ = value;
3550}
3551
3552// float standard_dev = 6;
3553inline void TPGProcessorReducedInfo::clear_standard_dev() {
3554 _impl_.standard_dev_ = 0;
3555}
3556inline float TPGProcessorReducedInfo::standard_dev() const {
3557 // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.standard_dev)
3558 return _internal_standard_dev();
3559}
3560inline void TPGProcessorReducedInfo::set_standard_dev(float value) {
3561 _internal_set_standard_dev(value);
3562 // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.standard_dev)
3563}
3564inline float TPGProcessorReducedInfo::_internal_standard_dev() const {
3565 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
3566 return _impl_.standard_dev_;
3567}
3568inline void TPGProcessorReducedInfo::_internal_set_standard_dev(float value) {
3569 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
3570 ;
3571 _impl_.standard_dev_ = value;
3572}
3573
3574#ifdef __GNUC__
3575#pragma GCC diagnostic pop
3576#endif // __GNUC__
3577
3578// @@protoc_insertion_point(namespace_scope)
3579} // namespace opmon
3580} // namespace datahandlinglibs
3581} // namespace dunedaq
3582
3583
3584// @@protoc_insertion_point(global_scope)
3585
3586#include "google/protobuf/port_undef.inc"
3587
3588#endif // GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:491
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::New
DataHandlerInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:531
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::operator=
DataHandlerInfo & operator=(DataHandlerInfo &&from) noexcept
Definition datahandling_info.pb.h:467
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::operator=
DataHandlerInfo & operator=(const DataHandlerInfo &from)
Definition datahandling_info.pb.h:463
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::internal_default_instance
static const DataHandlerInfo * internal_default_instance()
Definition datahandling_info.pb.h:500
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:481
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::swap
friend void swap(DataHandlerInfo &a, DataHandlerInfo &b)
Definition datahandling_info.pb.h:507
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:488
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:494
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:484
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::DataHandlerInfo
PROTOBUF_CONSTEXPR DataHandlerInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 4, 11, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:704
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 0, 1, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:1386
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::New
DataProcessorInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:1323
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::operator=
DataProcessorInfo & operator=(const DataProcessorInfo &from)
Definition datahandling_info.pb.h:1255
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1283
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:1286
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::operator=
DataProcessorInfo & operator=(DataProcessorInfo &&from) noexcept
Definition datahandling_info.pb.h:1259
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1276
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::DataProcessorInfo
PROTOBUF_CONSTEXPR DataProcessorInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1280
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::swap
friend void swap(DataProcessorInfo &a, DataProcessorInfo &b)
Definition datahandling_info.pb.h:1299
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::internal_default_instance
static const DataProcessorInfo * internal_default_instance()
Definition datahandling_info.pb.h:1292
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1273
dunedaq::datahandlinglibs::opmon::DataSourceInfo::operator=
DataSourceInfo & operator=(const DataSourceInfo &from)
Definition datahandling_info.pb.h:281
dunedaq::datahandlinglibs::opmon::DataSourceInfo::DataSourceInfo
PROTOBUF_CONSTEXPR DataSourceInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::DataSourceInfo::internal_default_instance
static const DataSourceInfo * internal_default_instance()
Definition datahandling_info.pb.h:318
dunedaq::datahandlinglibs::opmon::DataSourceInfo::New
DataSourceInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:349
dunedaq::datahandlinglibs::opmon::DataSourceInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:312
dunedaq::datahandlinglibs::opmon::DataSourceInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:309
dunedaq::datahandlinglibs::opmon::DataSourceInfo::swap
friend void swap(DataSourceInfo &a, DataSourceInfo &b)
Definition datahandling_info.pb.h:325
dunedaq::datahandlinglibs::opmon::DataSourceInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:306
dunedaq::datahandlinglibs::opmon::DataSourceInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:302
dunedaq::datahandlinglibs::opmon::DataSourceInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:299
dunedaq::datahandlinglibs::opmon::DataSourceInfo::operator=
DataSourceInfo & operator=(DataSourceInfo &&from) noexcept
Definition datahandling_info.pb.h:285
dunedaq::datahandlinglibs::opmon::DataSourceInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 2, 3, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:434
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::swap
friend void swap(FixedRateDataProcessorInfo &a, FixedRateDataProcessorInfo &b)
Definition datahandling_info.pb.h:1457
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::operator=
FixedRateDataProcessorInfo & operator=(const FixedRateDataProcessorInfo &from)
Definition datahandling_info.pb.h:1413
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::FixedRateDataProcessorInfo
PROTOBUF_CONSTEXPR FixedRateDataProcessorInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1431
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::New
FixedRateDataProcessorInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:1481
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::internal_default_instance
static const FixedRateDataProcessorInfo * internal_default_instance()
Definition datahandling_info.pb.h:1450
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1441
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:1444
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1438
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::operator=
FixedRateDataProcessorInfo & operator=(FixedRateDataProcessorInfo &&from) noexcept
Definition datahandling_info.pb.h:1417
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::default_instance
static const FixedRateDataProcessorInfo & default_instance()
Definition datahandling_info.pb.h:1447
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::FixedRateDataProcessorInfo
FixedRateDataProcessorInfo(FixedRateDataProcessorInfo &&from) noexcept
Definition datahandling_info.pb.h:1408
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1434
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 2, 4, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:1577
dunedaq::datahandlinglibs::opmon::HitFindingInfo::HitFindingInfo
PROTOBUF_CONSTEXPR HitFindingInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::HitFindingInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1628
dunedaq::datahandlinglibs::opmon::HitFindingInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 2, 4, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:1771
dunedaq::datahandlinglibs::opmon::HitFindingInfo::New
HitFindingInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:1675
dunedaq::datahandlinglibs::opmon::HitFindingInfo::operator=
HitFindingInfo & operator=(const HitFindingInfo &from)
Definition datahandling_info.pb.h:1607
dunedaq::datahandlinglibs::opmon::HitFindingInfo::operator=
HitFindingInfo & operator=(HitFindingInfo &&from) noexcept
Definition datahandling_info.pb.h:1611
dunedaq::datahandlinglibs::opmon::HitFindingInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1625
dunedaq::datahandlinglibs::opmon::HitFindingInfo::swap
friend void swap(HitFindingInfo &a, HitFindingInfo &b)
Definition datahandling_info.pb.h:1651
dunedaq::datahandlinglibs::opmon::HitFindingInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1635
dunedaq::datahandlinglibs::opmon::HitFindingInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:1638
dunedaq::datahandlinglibs::opmon::HitFindingInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1632
dunedaq::datahandlinglibs::opmon::HitFindingInfo::internal_default_instance
static const HitFindingInfo * internal_default_instance()
Definition datahandling_info.pb.h:1644
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::_InternalSerialize
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
Definition datahandling_info.pb.cc:593
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::_InternalParse
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
Definition datahandling_info.pb.cc:556
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 0, 1, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:254
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::operator=
LatencyBufferInfo & operator=(const LatencyBufferInfo &from)
Definition datahandling_info.pb.h:123
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:144
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::GetMetadata
::google::protobuf::Metadata GetMetadata() const final
Definition datahandling_info.pb.cc:671
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:154
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:141
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::Clear
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
Definition datahandling_info.pb.cc:546
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::New
LatencyBufferInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:191
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::swap
friend void swap(LatencyBufferInfo &a, LatencyBufferInfo &b)
Definition datahandling_info.pb.h:167
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::SharedCtor
void SharedCtor(::google::protobuf::Arena *arena)
Definition datahandling_info.pb.cc:527
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::operator=
LatencyBufferInfo & operator=(LatencyBufferInfo &&from) noexcept
Definition datahandling_info.pb.h:127
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::GetClassData
const ::google::protobuf::Message::ClassData * GetClassData() const final
Definition datahandling_info.pb.cc:637
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::LatencyBufferInfo
PROTOBUF_CONSTEXPR LatencyBufferInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::MergeImpl
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
Definition datahandling_info.pb.cc:640
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::internal_default_instance
static const LatencyBufferInfo * internal_default_instance()
Definition datahandling_info.pb.h:160
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:151
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:148
dunedaq::datahandlinglibs::opmon::RecordingInfo::_Internal
Definition datahandling_info.pb.cc:1808
dunedaq::datahandlinglibs::opmon::RecordingInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1085
dunedaq::datahandlinglibs::opmon::RecordingInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1095
dunedaq::datahandlinglibs::opmon::RecordingInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1088
dunedaq::datahandlinglibs::opmon::RecordingInfo::operator=
RecordingInfo & operator=(const RecordingInfo &from)
Definition datahandling_info.pb.h:1067
dunedaq::datahandlinglibs::opmon::RecordingInfo::swap
friend void swap(RecordingInfo &a, RecordingInfo &b)
Definition datahandling_info.pb.h:1111
dunedaq::datahandlinglibs::opmon::RecordingInfo::New
RecordingInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:1135
dunedaq::datahandlinglibs::opmon::RecordingInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1092
dunedaq::datahandlinglibs::opmon::RecordingInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 2, 3, 0, 69, 2 > _table_
Definition datahandling_info.pb.h:1226
dunedaq::datahandlinglibs::opmon::RecordingInfo::RecordingInfo
PROTOBUF_CONSTEXPR RecordingInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::RecordingInfo::set_recording_status
void set_recording_status(Arg_ &&arg, Args_... args)
dunedaq::datahandlinglibs::opmon::RecordingInfo::operator=
RecordingInfo & operator=(RecordingInfo &&from) noexcept
Definition datahandling_info.pb.h:1071
dunedaq::datahandlinglibs::opmon::RecordingInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:1098
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::New
RequestHandlerInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:809
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:772
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:759
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::swap
friend void swap(RequestHandlerInfo &a, RequestHandlerInfo &b)
Definition datahandling_info.pb.h:785
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:766
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:762
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::operator=
RequestHandlerInfo & operator=(RequestHandlerInfo &&from) noexcept
Definition datahandling_info.pb.h:745
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::operator=
RequestHandlerInfo & operator=(const RequestHandlerInfo &from)
Definition datahandling_info.pb.h:741
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::RequestHandlerInfo
PROTOBUF_CONSTEXPR RequestHandlerInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 4, 15, 0, 0, 7 > _table_
Definition datahandling_info.pb.h:1026
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::internal_default_instance
static const RequestHandlerInfo * internal_default_instance()
Definition datahandling_info.pb.h:778
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:769
dunedaq::datahandlinglibs::opmon::TPChannelInfo::operator=
TPChannelInfo & operator=(const TPChannelInfo &from)
Definition datahandling_info.pb.h:1801
dunedaq::datahandlinglibs::opmon::TPChannelInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:1832
dunedaq::datahandlinglibs::opmon::TPChannelInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1826
dunedaq::datahandlinglibs::opmon::TPChannelInfo::swap
friend void swap(TPChannelInfo &a, TPChannelInfo &b)
Definition datahandling_info.pb.h:1845
dunedaq::datahandlinglibs::opmon::TPChannelInfo::New
TPChannelInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:1869
dunedaq::datahandlinglibs::opmon::TPChannelInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 1, 2, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:1943
dunedaq::datahandlinglibs::opmon::TPChannelInfo::TPChannelInfo
PROTOBUF_CONSTEXPR TPChannelInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::TPChannelInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1829
dunedaq::datahandlinglibs::opmon::TPChannelInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1819
dunedaq::datahandlinglibs::opmon::TPChannelInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1822
dunedaq::datahandlinglibs::opmon::TPChannelInfo::operator=
TPChannelInfo & operator=(TPChannelInfo &&from) noexcept
Definition datahandling_info.pb.h:1805
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:1999
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::TPGProcessorInfo
PROTOBUF_CONSTEXPR TPGProcessorInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:1989
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::internal_default_instance
static const TPGProcessorInfo * internal_default_instance()
Definition datahandling_info.pb.h:2008
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::New
TPGProcessorInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:2039
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 1, 2, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:2113
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:2002
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:1992
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::operator=
TPGProcessorInfo & operator=(const TPGProcessorInfo &from)
Definition datahandling_info.pb.h:1971
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:1996
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::swap
friend void swap(TPGProcessorInfo &a, TPGProcessorInfo &b)
Definition datahandling_info.pb.h:2015
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::operator=
TPGProcessorInfo & operator=(TPGProcessorInfo &&from) noexcept
Definition datahandling_info.pb.h:1975
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::unknown_fields
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
Definition datahandling_info.pb.h:2159
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::GetReflection
static const ::google::protobuf::Reflection * GetReflection()
Definition datahandling_info.pb.h:2172
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::TPGProcessorReducedInfo
TPGProcessorReducedInfo(TPGProcessorReducedInfo &&from) noexcept
Definition datahandling_info.pb.h:2136
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::TPGProcessorReducedInfo
PROTOBUF_CONSTEXPR TPGProcessorReducedInfo(::google::protobuf::internal::ConstantInitialized)
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::descriptor
static const ::google::protobuf::Descriptor * descriptor()
Definition datahandling_info.pb.h:2166
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::mutable_unknown_fields
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
Definition datahandling_info.pb.h:2162
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::swap
friend void swap(TPGProcessorReducedInfo &a, TPGProcessorReducedInfo &b)
Definition datahandling_info.pb.h:2185
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::internal_default_instance
static const TPGProcessorReducedInfo * internal_default_instance()
Definition datahandling_info.pb.h:2178
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::default_instance
static const TPGProcessorReducedInfo & default_instance()
Definition datahandling_info.pb.h:2175
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::operator=
TPGProcessorReducedInfo & operator=(TPGProcessorReducedInfo &&from) noexcept
Definition datahandling_info.pb.h:2145
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::operator=
TPGProcessorReducedInfo & operator=(const TPGProcessorReducedInfo &from)
Definition datahandling_info.pb.h:2141
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::New
TPGProcessorReducedInfo * New(::google::protobuf::Arena *arena=nullptr) const final
Definition datahandling_info.pb.h:2209
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::GetDescriptor
static const ::google::protobuf::Descriptor * GetDescriptor()
Definition datahandling_info.pb.h:2169
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::_table_
static const ::google::protobuf::internal::TcParseTable< 3, 6, 0, 0, 2 > _table_
Definition datahandling_info.pb.h:2327
descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
const ::google::protobuf::internal::DescriptorTable descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
Definition datahandling_info.pb.cc:472
dunedaq::datahandlinglibs::opmon::_DataHandlerInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataHandlerInfoDefaultTypeInternal _DataHandlerInfo_default_instance_
Definition datahandling_info.pb.cc:85
dunedaq::datahandlinglibs::opmon::_TPGProcessorInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPGProcessorInfoDefaultTypeInternal _TPGProcessorInfo_default_instance_
Definition datahandling_info.pb.cc:224
dunedaq::datahandlinglibs::opmon::_HitFindingInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 HitFindingInfoDefaultTypeInternal _HitFindingInfo_default_instance_
Definition datahandling_info.pb.cc:190
dunedaq::datahandlinglibs::opmon::_LatencyBufferInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 LatencyBufferInfoDefaultTypeInternal _LatencyBufferInfo_default_instance_
Definition datahandling_info.pb.cc:41
dunedaq::datahandlinglibs::opmon::_FixedRateDataProcessorInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FixedRateDataProcessorInfoDefaultTypeInternal _FixedRateDataProcessorInfo_default_instance_
Definition datahandling_info.pb.cc:171
dunedaq::datahandlinglibs::opmon::_TPGProcessorReducedInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPGProcessorReducedInfoDefaultTypeInternal _TPGProcessorReducedInfo_default_instance_
Definition datahandling_info.pb.cc:245
dunedaq::datahandlinglibs::opmon::_RecordingInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RecordingInfoDefaultTypeInternal _RecordingInfo_default_instance_
Definition datahandling_info.pb.cc:136
dunedaq::datahandlinglibs::opmon::_RequestHandlerInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RequestHandlerInfoDefaultTypeInternal _RequestHandlerInfo_default_instance_
Definition datahandling_info.pb.cc:115
dunedaq::datahandlinglibs::opmon::_DataProcessorInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataProcessorInfoDefaultTypeInternal _DataProcessorInfo_default_instance_
Definition datahandling_info.pb.cc:152
dunedaq::datahandlinglibs::opmon::_TPChannelInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPChannelInfoDefaultTypeInternal _TPChannelInfo_default_instance_
Definition datahandling_info.pb.cc:207
dunedaq::datahandlinglibs::opmon::_DataSourceInfo_default_instance_
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataSourceInfoDefaultTypeInternal _DataSourceInfo_default_instance_
Definition datahandling_info.pb.cc:59
dunedaq
The DUNE-DAQ namespace.
Definition DaphneV2Interface.hpp:29
dunedaq::size
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
Definition FelixIssues.hpp:28
TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
Definition datahandling_info.pb.h:51
TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto::offsets
static const ::uint32_t offsets[]
Definition datahandling_info.pb.h:52
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_
Definition datahandling_info.pb.h:708
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::sum_payloads_
::uint64_t sum_payloads_
Definition datahandling_info.pb.h:709
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:720
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::num_post_processing_delay_max_waits_
::uint64_t num_post_processing_delay_max_waits_
Definition datahandling_info.pb.h:719
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::num_payloads_
::uint64_t num_payloads_
Definition datahandling_info.pb.h:710
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::sum_requests_
::uint64_t sum_requests_
Definition datahandling_info.pb.h:714
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::rate_payloads_consumed_
double rate_payloads_consumed_
Definition datahandling_info.pb.h:712
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::num_lb_insert_failures_
::uint64_t num_lb_insert_failures_
Definition datahandling_info.pb.h:713
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::newest_timestamp_
::uint64_t newest_timestamp_
Definition datahandling_info.pb.h:717
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::oldest_timestamp_
::uint64_t oldest_timestamp_
Definition datahandling_info.pb.h:718
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::last_daq_timestamp_
::uint64_t last_daq_timestamp_
Definition datahandling_info.pb.h:716
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::num_data_input_timeouts_
::uint64_t num_data_input_timeouts_
Definition datahandling_info.pb.h:711
dunedaq::datahandlinglibs::opmon::DataHandlerInfo::Impl_::num_requests_
::uint64_t num_requests_
Definition datahandling_info.pb.h:715
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::Impl_
Definition datahandling_info.pb.h:1390
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::Impl_::elements_queued_
::uint64_t elements_queued_
Definition datahandling_info.pb.h:1391
dunedaq::datahandlinglibs::opmon::DataProcessorInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1392
dunedaq::datahandlinglibs::opmon::DataSourceInfo::Impl_
Definition datahandling_info.pb.h:438
dunedaq::datahandlinglibs::opmon::DataSourceInfo::Impl_::num_packets_
::uint64_t num_packets_
Definition datahandling_info.pb.h:440
dunedaq::datahandlinglibs::opmon::DataSourceInfo::Impl_::num_dropped_packets_
::uint64_t num_dropped_packets_
Definition datahandling_info.pb.h:441
dunedaq::datahandlinglibs::opmon::DataSourceInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:442
dunedaq::datahandlinglibs::opmon::DataSourceInfo::Impl_::sum_packets_
::uint64_t sum_packets_
Definition datahandling_info.pb.h:439
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_
Definition datahandling_info.pb.h:1581
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_::num_ts_errors_
::uint64_t num_ts_errors_
Definition datahandling_info.pb.h:1585
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_::min_seq_id_jump_
::uint64_t min_seq_id_jump_
Definition datahandling_info.pb.h:1583
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_::num_seq_id_errors_
::uint64_t num_seq_id_errors_
Definition datahandling_info.pb.h:1582
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1586
dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo::Impl_::max_seq_id_jump_
::uint64_t max_seq_id_jump_
Definition datahandling_info.pb.h:1584
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_
Definition datahandling_info.pb.h:1775
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_::num_tps_suppressed_too_long_
::uint64_t num_tps_suppressed_too_long_
Definition datahandling_info.pb.h:1778
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1780
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_::num_tps_sent_
::uint64_t num_tps_sent_
Definition datahandling_info.pb.h:1776
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_::rate_tp_hits_
float rate_tp_hits_
Definition datahandling_info.pb.h:1779
dunedaq::datahandlinglibs::opmon::HitFindingInfo::Impl_::num_tps_send_failed_
::uint64_t num_tps_send_failed_
Definition datahandling_info.pb.h:1777
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::Impl_
Definition datahandling_info.pb.h:258
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:260
dunedaq::datahandlinglibs::opmon::LatencyBufferInfo::Impl_::num_buffer_elements_
::uint64_t num_buffer_elements_
Definition datahandling_info.pb.h:259
dunedaq::datahandlinglibs::opmon::RecordingInfo::Impl_
Definition datahandling_info.pb.h:1230
dunedaq::datahandlinglibs::opmon::RecordingInfo::Impl_::bytes_recorded_
::uint64_t bytes_recorded_
Definition datahandling_info.pb.h:1233
dunedaq::datahandlinglibs::opmon::RecordingInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1234
dunedaq::datahandlinglibs::opmon::RecordingInfo::Impl_::recording_status_
::google::protobuf::internal::ArenaStringPtr recording_status_
Definition datahandling_info.pb.h:1231
dunedaq::datahandlinglibs::opmon::RecordingInfo::Impl_::packets_recorded_
::uint64_t packets_recorded_
Definition datahandling_info.pb.h:1232
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_
Definition datahandling_info.pb.h:1030
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::tot_request_response_time_
::uint64_t tot_request_response_time_
Definition datahandling_info.pb.h:1040
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_periodic_send_failed_
::uint64_t num_periodic_send_failed_
Definition datahandling_info.pb.h:1045
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_buffer_cleanups_
::uint64_t num_buffer_cleanups_
Definition datahandling_info.pb.h:1043
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_periodic_sent_
::uint64_t num_periodic_sent_
Definition datahandling_info.pb.h:1044
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::min_request_response_time_
::uint64_t min_request_response_time_
Definition datahandling_info.pb.h:1041
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_old_window_
::uint64_t num_requests_old_window_
Definition datahandling_info.pb.h:1034
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_delayed_
::uint64_t num_requests_delayed_
Definition datahandling_info.pb.h:1035
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_handled_
::uint64_t num_requests_handled_
Definition datahandling_info.pb.h:1031
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_waiting_
::uint64_t num_requests_waiting_
Definition datahandling_info.pb.h:1038
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::avg_request_response_time_
::uint64_t avg_request_response_time_
Definition datahandling_info.pb.h:1039
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_bad_
::uint64_t num_requests_bad_
Definition datahandling_info.pb.h:1033
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_uncategorized_
::uint64_t num_requests_uncategorized_
Definition datahandling_info.pb.h:1036
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_timed_out_
::uint64_t num_requests_timed_out_
Definition datahandling_info.pb.h:1037
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1046
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::num_requests_found_
::uint64_t num_requests_found_
Definition datahandling_info.pb.h:1032
dunedaq::datahandlinglibs::opmon::RequestHandlerInfo::Impl_::max_request_response_time_
::uint64_t max_request_response_time_
Definition datahandling_info.pb.h:1042
dunedaq::datahandlinglibs::opmon::TPChannelInfo::Impl_
Definition datahandling_info.pb.h:1947
dunedaq::datahandlinglibs::opmon::TPChannelInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:1950
dunedaq::datahandlinglibs::opmon::TPChannelInfo::Impl_::channel_id_
::uint64_t channel_id_
Definition datahandling_info.pb.h:1948
dunedaq::datahandlinglibs::opmon::TPChannelInfo::Impl_::number_of_tps_
::uint64_t number_of_tps_
Definition datahandling_info.pb.h:1949
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::Impl_
Definition datahandling_info.pb.h:2117
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:2120
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::Impl_::pedestal_
::int64_t pedestal_
Definition datahandling_info.pb.h:2118
dunedaq::datahandlinglibs::opmon::TPGProcessorInfo::Impl_::accum_
::int64_t accum_
Definition datahandling_info.pb.h:2119
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_
Definition datahandling_info.pb.h:2331
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::max_
::int32_t max_
Definition datahandling_info.pb.h:2333
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::min_
::int32_t min_
Definition datahandling_info.pb.h:2334
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::_cached_size_
mutable::google::protobuf::internal::CachedSize _cached_size_
Definition datahandling_info.pb.h:2338
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::min_channel_id_
::uint32_t min_channel_id_
Definition datahandling_info.pb.h:2336
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::average_
float average_
Definition datahandling_info.pb.h:2332
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::standard_dev_
float standard_dev_
Definition datahandling_info.pb.h:2337
dunedaq::datahandlinglibs::opmon::TPGProcessorReducedInfo::Impl_::max_channel_id_
::uint32_t max_channel_id_
Definition datahandling_info.pb.h:2335
Generated on Wed Oct 22 2025 for DUNE-DAQ by doxygen 1.12.0