datahandling_info.pb.h

Go to the documentation of this file.

// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: datahandlinglibs/opmon/datahandling_info.proto
 
#ifndef GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh
#define GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh
 
#include <limits>
#include <string>
#include <type_traits>
 
#include "google/protobuf/port_def.inc"
#if PROTOBUF_VERSION < 4024000
#error "This file was generated by a newer version of protoc which is"
#error "incompatible with your Protocol Buffer headers. Please update"
#error "your headers."
#endif  // PROTOBUF_VERSION
 
#if 4024004 < PROTOBUF_MIN_PROTOC_VERSION
#error "This file was generated by an older version of protoc which is"
#error "incompatible with your Protocol Buffer headers. Please"
#error "regenerate this file with a newer version of protoc."
#endif  // PROTOBUF_MIN_PROTOC_VERSION
#include "google/protobuf/port_undef.inc"
#include "google/protobuf/io/coded_stream.h"
#include "google/protobuf/arena.h"
#include "google/protobuf/arenastring.h"
#include "google/protobuf/generated_message_tctable_decl.h"
#include "google/protobuf/generated_message_util.h"
#include "google/protobuf/metadata_lite.h"
#include "google/protobuf/generated_message_reflection.h"
#include "google/protobuf/message.h"
#include "google/protobuf/repeated_field.h"  // IWYU pragma: export
#include "google/protobuf/extension_set.h"  // IWYU pragma: export
#include "google/protobuf/unknown_field_set.h"
// @@protoc_insertion_point(includes)
 
// Must be included last.
#include "google/protobuf/port_def.inc"
 
#define PROTOBUF_INTERNAL_EXPORT_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto
 
namespace google {
namespace protobuf {
namespace internal {
class AnyMetadata;
}  // namespace internal
}  // namespace protobuf
}  // namespace google
 
// Internal implementation detail -- do not use these members.
struct TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto {
  static const ::uint32_t offsets[];
};
extern const ::google::protobuf::internal::DescriptorTable
    descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
namespace dunedaq {
namespace datahandlinglibs {
namespace opmon {
class DataHandlerInfo;
struct DataHandlerInfoDefaultTypeInternal;
extern DataHandlerInfoDefaultTypeInternal _DataHandlerInfo_default_instance_;
class DataProcessorInfo;
struct DataProcessorInfoDefaultTypeInternal;
extern DataProcessorInfoDefaultTypeInternal _DataProcessorInfo_default_instance_;
class DataSourceInfo;
struct DataSourceInfoDefaultTypeInternal;
extern DataSourceInfoDefaultTypeInternal _DataSourceInfo_default_instance_;
class FixedRateDataProcessorInfo;
struct FixedRateDataProcessorInfoDefaultTypeInternal;
extern FixedRateDataProcessorInfoDefaultTypeInternal _FixedRateDataProcessorInfo_default_instance_;
class HitFindingInfo;
struct HitFindingInfoDefaultTypeInternal;
extern HitFindingInfoDefaultTypeInternal _HitFindingInfo_default_instance_;
class LatencyBufferInfo;
struct LatencyBufferInfoDefaultTypeInternal;
extern LatencyBufferInfoDefaultTypeInternal _LatencyBufferInfo_default_instance_;
class RecordingInfo;
struct RecordingInfoDefaultTypeInternal;
extern RecordingInfoDefaultTypeInternal _RecordingInfo_default_instance_;
class RequestHandlerInfo;
struct RequestHandlerInfoDefaultTypeInternal;
extern RequestHandlerInfoDefaultTypeInternal _RequestHandlerInfo_default_instance_;
class TPChannelInfo;
struct TPChannelInfoDefaultTypeInternal;
extern TPChannelInfoDefaultTypeInternal _TPChannelInfo_default_instance_;
class TPGProcessorInfo;
struct TPGProcessorInfoDefaultTypeInternal;
extern TPGProcessorInfoDefaultTypeInternal _TPGProcessorInfo_default_instance_;
class TPGProcessorReducedInfo;
struct TPGProcessorReducedInfoDefaultTypeInternal;
extern TPGProcessorReducedInfoDefaultTypeInternal _TPGProcessorReducedInfo_default_instance_;
}  // namespace opmon
}  // namespace datahandlinglibs
}  // namespace dunedaq
namespace google {
namespace protobuf {
}  // namespace protobuf
}  // namespace google
 
namespace dunedaq {
namespace datahandlinglibs {
namespace opmon {
 
// ===================================================================
 
 
// -------------------------------------------------------------------
 
class LatencyBufferInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo) */ {
 public:
  inline LatencyBufferInfo() : LatencyBufferInfo(nullptr) {}
  ~LatencyBufferInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR LatencyBufferInfo(::google::protobuf::internal::ConstantInitialized);
 
  LatencyBufferInfo(const LatencyBufferInfo& from);
  LatencyBufferInfo(LatencyBufferInfo&& from) noexcept
    : LatencyBufferInfo() {
    *this = ::std::move(from);
  }
 
  inline LatencyBufferInfo& operator=(const LatencyBufferInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline LatencyBufferInfo& operator=(LatencyBufferInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const LatencyBufferInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const LatencyBufferInfo* internal_default_instance() {
    return reinterpret_cast<const LatencyBufferInfo*>(
               &_LatencyBufferInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    0;
 
  friend void swap(LatencyBufferInfo& a, LatencyBufferInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(LatencyBufferInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(LatencyBufferInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  LatencyBufferInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<LatencyBufferInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const LatencyBufferInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const LatencyBufferInfo& from) {
    LatencyBufferInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(LatencyBufferInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.LatencyBufferInfo";
  }
  protected:
  explicit LatencyBufferInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kNumBufferElementsFieldNumber = 1,
  };
  // uint64 num_buffer_elements = 1;
  void clear_num_buffer_elements() ;
  ::uint64_t num_buffer_elements() const;
  void set_num_buffer_elements(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_buffer_elements() const;
  void _internal_set_num_buffer_elements(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<0, 1, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t num_buffer_elements_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class DataSourceInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataSourceInfo) */ {
 public:
  inline DataSourceInfo() : DataSourceInfo(nullptr) {}
  ~DataSourceInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR DataSourceInfo(::google::protobuf::internal::ConstantInitialized);
 
  DataSourceInfo(const DataSourceInfo& from);
  DataSourceInfo(DataSourceInfo&& from) noexcept
    : DataSourceInfo() {
    *this = ::std::move(from);
  }
 
  inline DataSourceInfo& operator=(const DataSourceInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline DataSourceInfo& operator=(DataSourceInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const DataSourceInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const DataSourceInfo* internal_default_instance() {
    return reinterpret_cast<const DataSourceInfo*>(
               &_DataSourceInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    1;
 
  friend void swap(DataSourceInfo& a, DataSourceInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(DataSourceInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(DataSourceInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  DataSourceInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<DataSourceInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const DataSourceInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const DataSourceInfo& from) {
    DataSourceInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(DataSourceInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.DataSourceInfo";
  }
  protected:
  explicit DataSourceInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kSumPacketsFieldNumber = 1,
    kNumPacketsFieldNumber = 2,
    kNumDroppedPacketsFieldNumber = 3,
  };
  // uint64 sum_packets = 1;
  void clear_sum_packets() ;
  ::uint64_t sum_packets() const;
  void set_sum_packets(::uint64_t value);
 
  private:
  ::uint64_t _internal_sum_packets() const;
  void _internal_set_sum_packets(::uint64_t value);
 
  public:
  // uint64 num_packets = 2;
  void clear_num_packets() ;
  ::uint64_t num_packets() const;
  void set_num_packets(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_packets() const;
  void _internal_set_num_packets(::uint64_t value);
 
  public:
  // uint64 num_dropped_packets = 3;
  void clear_num_dropped_packets() ;
  ::uint64_t num_dropped_packets() const;
  void set_num_dropped_packets(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_dropped_packets() const;
  void _internal_set_num_dropped_packets(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<2, 3, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t sum_packets_;
    ::uint64_t num_packets_;
    ::uint64_t num_dropped_packets_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class DataHandlerInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataHandlerInfo) */ {
 public:
  inline DataHandlerInfo() : DataHandlerInfo(nullptr) {}
  ~DataHandlerInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR DataHandlerInfo(::google::protobuf::internal::ConstantInitialized);
 
  DataHandlerInfo(const DataHandlerInfo& from);
  DataHandlerInfo(DataHandlerInfo&& from) noexcept
    : DataHandlerInfo() {
    *this = ::std::move(from);
  }
 
  inline DataHandlerInfo& operator=(const DataHandlerInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline DataHandlerInfo& operator=(DataHandlerInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const DataHandlerInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const DataHandlerInfo* internal_default_instance() {
    return reinterpret_cast<const DataHandlerInfo*>(
               &_DataHandlerInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    2;
 
  friend void swap(DataHandlerInfo& a, DataHandlerInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(DataHandlerInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(DataHandlerInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  DataHandlerInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<DataHandlerInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const DataHandlerInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const DataHandlerInfo& from) {
    DataHandlerInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(DataHandlerInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.DataHandlerInfo";
  }
  protected:
  explicit DataHandlerInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kSumPayloadsFieldNumber = 1,
    kNumPayloadsFieldNumber = 2,
    kNumDataInputTimeoutsFieldNumber = 3,
    kRatePayloadsConsumedFieldNumber = 4,
    kNumLbInsertFailuresFieldNumber = 5,
    kSumRequestsFieldNumber = 11,
    kNumRequestsFieldNumber = 12,
    kLastDaqTimestampFieldNumber = 21,
    kNumPostProcessingDelayMaxWaitsFieldNumber = 31,
  };
  // uint64 sum_payloads = 1;
  void clear_sum_payloads() ;
  ::uint64_t sum_payloads() const;
  void set_sum_payloads(::uint64_t value);
 
  private:
  ::uint64_t _internal_sum_payloads() const;
  void _internal_set_sum_payloads(::uint64_t value);
 
  public:
  // uint64 num_payloads = 2;
  void clear_num_payloads() ;
  ::uint64_t num_payloads() const;
  void set_num_payloads(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_payloads() const;
  void _internal_set_num_payloads(::uint64_t value);
 
  public:
  // uint64 num_data_input_timeouts = 3;
  void clear_num_data_input_timeouts() ;
  ::uint64_t num_data_input_timeouts() const;
  void set_num_data_input_timeouts(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_data_input_timeouts() const;
  void _internal_set_num_data_input_timeouts(::uint64_t value);
 
  public:
  // double rate_payloads_consumed = 4;
  void clear_rate_payloads_consumed() ;
  double rate_payloads_consumed() const;
  void set_rate_payloads_consumed(double value);
 
  private:
  double _internal_rate_payloads_consumed() const;
  void _internal_set_rate_payloads_consumed(double value);
 
  public:
  // uint64 num_lb_insert_failures = 5;
  void clear_num_lb_insert_failures() ;
  ::uint64_t num_lb_insert_failures() const;
  void set_num_lb_insert_failures(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_lb_insert_failures() const;
  void _internal_set_num_lb_insert_failures(::uint64_t value);
 
  public:
  // uint64 sum_requests = 11;
  void clear_sum_requests() ;
  ::uint64_t sum_requests() const;
  void set_sum_requests(::uint64_t value);
 
  private:
  ::uint64_t _internal_sum_requests() const;
  void _internal_set_sum_requests(::uint64_t value);
 
  public:
  // uint64 num_requests = 12;
  void clear_num_requests() ;
  ::uint64_t num_requests() const;
  void set_num_requests(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests() const;
  void _internal_set_num_requests(::uint64_t value);
 
  public:
  // uint64 last_daq_timestamp = 21;
  void clear_last_daq_timestamp() ;
  ::uint64_t last_daq_timestamp() const;
  void set_last_daq_timestamp(::uint64_t value);
 
  private:
  ::uint64_t _internal_last_daq_timestamp() const;
  void _internal_set_last_daq_timestamp(::uint64_t value);
 
  public:
  // uint64 num_post_processing_delay_max_waits = 31;
  void clear_num_post_processing_delay_max_waits() ;
  ::uint64_t num_post_processing_delay_max_waits() const;
  void set_num_post_processing_delay_max_waits(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_post_processing_delay_max_waits() const;
  void _internal_set_num_post_processing_delay_max_waits(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<4, 9, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t sum_payloads_;
    ::uint64_t num_payloads_;
    ::uint64_t num_data_input_timeouts_;
    double rate_payloads_consumed_;
    ::uint64_t num_lb_insert_failures_;
    ::uint64_t sum_requests_;
    ::uint64_t num_requests_;
    ::uint64_t last_daq_timestamp_;
    ::uint64_t num_post_processing_delay_max_waits_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class RequestHandlerInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo) */ {
 public:
  inline RequestHandlerInfo() : RequestHandlerInfo(nullptr) {}
  ~RequestHandlerInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR RequestHandlerInfo(::google::protobuf::internal::ConstantInitialized);
 
  RequestHandlerInfo(const RequestHandlerInfo& from);
  RequestHandlerInfo(RequestHandlerInfo&& from) noexcept
    : RequestHandlerInfo() {
    *this = ::std::move(from);
  }
 
  inline RequestHandlerInfo& operator=(const RequestHandlerInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline RequestHandlerInfo& operator=(RequestHandlerInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const RequestHandlerInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const RequestHandlerInfo* internal_default_instance() {
    return reinterpret_cast<const RequestHandlerInfo*>(
               &_RequestHandlerInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    3;
 
  friend void swap(RequestHandlerInfo& a, RequestHandlerInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(RequestHandlerInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(RequestHandlerInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  RequestHandlerInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<RequestHandlerInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const RequestHandlerInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const RequestHandlerInfo& from) {
    RequestHandlerInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(RequestHandlerInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.RequestHandlerInfo";
  }
  protected:
  explicit RequestHandlerInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kNumRequestsHandledFieldNumber = 1,
    kNumRequestsFoundFieldNumber = 2,
    kNumRequestsBadFieldNumber = 3,
    kNumRequestsOldWindowFieldNumber = 4,
    kNumRequestsDelayedFieldNumber = 5,
    kNumRequestsUncategorizedFieldNumber = 6,
    kNumRequestsTimedOutFieldNumber = 7,
    kNumRequestsWaitingFieldNumber = 8,
    kAvgRequestResponseTimeFieldNumber = 21,
    kTotRequestResponseTimeFieldNumber = 22,
    kMinRequestResponseTimeFieldNumber = 23,
    kMaxRequestResponseTimeFieldNumber = 24,
    kNumBufferCleanupsFieldNumber = 31,
    kNumPeriodicSentFieldNumber = 41,
    kNumPeriodicSendFailedFieldNumber = 42,
  };
  // uint64 num_requests_handled = 1;
  void clear_num_requests_handled() ;
  ::uint64_t num_requests_handled() const;
  void set_num_requests_handled(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_handled() const;
  void _internal_set_num_requests_handled(::uint64_t value);
 
  public:
  // uint64 num_requests_found = 2;
  void clear_num_requests_found() ;
  ::uint64_t num_requests_found() const;
  void set_num_requests_found(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_found() const;
  void _internal_set_num_requests_found(::uint64_t value);
 
  public:
  // uint64 num_requests_bad = 3;
  void clear_num_requests_bad() ;
  ::uint64_t num_requests_bad() const;
  void set_num_requests_bad(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_bad() const;
  void _internal_set_num_requests_bad(::uint64_t value);
 
  public:
  // uint64 num_requests_old_window = 4;
  void clear_num_requests_old_window() ;
  ::uint64_t num_requests_old_window() const;
  void set_num_requests_old_window(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_old_window() const;
  void _internal_set_num_requests_old_window(::uint64_t value);
 
  public:
  // uint64 num_requests_delayed = 5;
  void clear_num_requests_delayed() ;
  ::uint64_t num_requests_delayed() const;
  void set_num_requests_delayed(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_delayed() const;
  void _internal_set_num_requests_delayed(::uint64_t value);
 
  public:
  // uint64 num_requests_uncategorized = 6;
  void clear_num_requests_uncategorized() ;
  ::uint64_t num_requests_uncategorized() const;
  void set_num_requests_uncategorized(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_uncategorized() const;
  void _internal_set_num_requests_uncategorized(::uint64_t value);
 
  public:
  // uint64 num_requests_timed_out = 7;
  void clear_num_requests_timed_out() ;
  ::uint64_t num_requests_timed_out() const;
  void set_num_requests_timed_out(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_timed_out() const;
  void _internal_set_num_requests_timed_out(::uint64_t value);
 
  public:
  // uint64 num_requests_waiting = 8;
  void clear_num_requests_waiting() ;
  ::uint64_t num_requests_waiting() const;
  void set_num_requests_waiting(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_requests_waiting() const;
  void _internal_set_num_requests_waiting(::uint64_t value);
 
  public:
  // uint64 avg_request_response_time = 21;
  void clear_avg_request_response_time() ;
  ::uint64_t avg_request_response_time() const;
  void set_avg_request_response_time(::uint64_t value);
 
  private:
  ::uint64_t _internal_avg_request_response_time() const;
  void _internal_set_avg_request_response_time(::uint64_t value);
 
  public:
  // uint64 tot_request_response_time = 22;
  void clear_tot_request_response_time() ;
  ::uint64_t tot_request_response_time() const;
  void set_tot_request_response_time(::uint64_t value);
 
  private:
  ::uint64_t _internal_tot_request_response_time() const;
  void _internal_set_tot_request_response_time(::uint64_t value);
 
  public:
  // uint64 min_request_response_time = 23;
  void clear_min_request_response_time() ;
  ::uint64_t min_request_response_time() const;
  void set_min_request_response_time(::uint64_t value);
 
  private:
  ::uint64_t _internal_min_request_response_time() const;
  void _internal_set_min_request_response_time(::uint64_t value);
 
  public:
  // uint64 max_request_response_time = 24;
  void clear_max_request_response_time() ;
  ::uint64_t max_request_response_time() const;
  void set_max_request_response_time(::uint64_t value);
 
  private:
  ::uint64_t _internal_max_request_response_time() const;
  void _internal_set_max_request_response_time(::uint64_t value);
 
  public:
  // uint64 num_buffer_cleanups = 31;
  void clear_num_buffer_cleanups() ;
  ::uint64_t num_buffer_cleanups() const;
  void set_num_buffer_cleanups(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_buffer_cleanups() const;
  void _internal_set_num_buffer_cleanups(::uint64_t value);
 
  public:
  // uint64 num_periodic_sent = 41;
  void clear_num_periodic_sent() ;
  ::uint64_t num_periodic_sent() const;
  void set_num_periodic_sent(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_periodic_sent() const;
  void _internal_set_num_periodic_sent(::uint64_t value);
 
  public:
  // uint64 num_periodic_send_failed = 42;
  void clear_num_periodic_send_failed() ;
  ::uint64_t num_periodic_send_failed() const;
  void set_num_periodic_send_failed(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_periodic_send_failed() const;
  void _internal_set_num_periodic_send_failed(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<4, 15, 0, 0, 7> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t num_requests_handled_;
    ::uint64_t num_requests_found_;
    ::uint64_t num_requests_bad_;
    ::uint64_t num_requests_old_window_;
    ::uint64_t num_requests_delayed_;
    ::uint64_t num_requests_uncategorized_;
    ::uint64_t num_requests_timed_out_;
    ::uint64_t num_requests_waiting_;
    ::uint64_t avg_request_response_time_;
    ::uint64_t tot_request_response_time_;
    ::uint64_t min_request_response_time_;
    ::uint64_t max_request_response_time_;
    ::uint64_t num_buffer_cleanups_;
    ::uint64_t num_periodic_sent_;
    ::uint64_t num_periodic_send_failed_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class RecordingInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.RecordingInfo) */ {
 public:
  inline RecordingInfo() : RecordingInfo(nullptr) {}
  ~RecordingInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR RecordingInfo(::google::protobuf::internal::ConstantInitialized);
 
  RecordingInfo(const RecordingInfo& from);
  RecordingInfo(RecordingInfo&& from) noexcept
    : RecordingInfo() {
    *this = ::std::move(from);
  }
 
  inline RecordingInfo& operator=(const RecordingInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline RecordingInfo& operator=(RecordingInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const RecordingInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const RecordingInfo* internal_default_instance() {
    return reinterpret_cast<const RecordingInfo*>(
               &_RecordingInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    4;
 
  friend void swap(RecordingInfo& a, RecordingInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(RecordingInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(RecordingInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  RecordingInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<RecordingInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const RecordingInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const RecordingInfo& from) {
    RecordingInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(RecordingInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.RecordingInfo";
  }
  protected:
  explicit RecordingInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kRecordingStatusFieldNumber = 1,
    kPacketsRecordedFieldNumber = 2,
    kBytesRecordedFieldNumber = 3,
  };
  // string recording_status = 1;
  void clear_recording_status() ;
  const std::string& recording_status() const;
  template <typename Arg_ = const std::string&, typename... Args_>
  void set_recording_status(Arg_&& arg, Args_... args);
  std::string* mutable_recording_status();
  PROTOBUF_NODISCARD std::string* release_recording_status();
  void set_allocated_recording_status(std::string* ptr);
 
  private:
  const std::string& _internal_recording_status() const;
  inline PROTOBUF_ALWAYS_INLINE void _internal_set_recording_status(
      const std::string& value);
  std::string* _internal_mutable_recording_status();
 
  public:
  // uint64 packets_recorded = 2;
  void clear_packets_recorded() ;
  ::uint64_t packets_recorded() const;
  void set_packets_recorded(::uint64_t value);
 
  private:
  ::uint64_t _internal_packets_recorded() const;
  void _internal_set_packets_recorded(::uint64_t value);
 
  public:
  // uint64 bytes_recorded = 3;
  void clear_bytes_recorded() ;
  ::uint64_t bytes_recorded() const;
  void set_bytes_recorded(::uint64_t value);
 
  private:
  ::uint64_t _internal_bytes_recorded() const;
  void _internal_set_bytes_recorded(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.RecordingInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<2, 3, 0, 69, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::google::protobuf::internal::ArenaStringPtr recording_status_;
    ::uint64_t packets_recorded_;
    ::uint64_t bytes_recorded_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class DataProcessorInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.DataProcessorInfo) */ {
 public:
  inline DataProcessorInfo() : DataProcessorInfo(nullptr) {}
  ~DataProcessorInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR DataProcessorInfo(::google::protobuf::internal::ConstantInitialized);
 
  DataProcessorInfo(const DataProcessorInfo& from);
  DataProcessorInfo(DataProcessorInfo&& from) noexcept
    : DataProcessorInfo() {
    *this = ::std::move(from);
  }
 
  inline DataProcessorInfo& operator=(const DataProcessorInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline DataProcessorInfo& operator=(DataProcessorInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const DataProcessorInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const DataProcessorInfo* internal_default_instance() {
    return reinterpret_cast<const DataProcessorInfo*>(
               &_DataProcessorInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    5;
 
  friend void swap(DataProcessorInfo& a, DataProcessorInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(DataProcessorInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(DataProcessorInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  DataProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<DataProcessorInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const DataProcessorInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const DataProcessorInfo& from) {
    DataProcessorInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(DataProcessorInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.DataProcessorInfo";
  }
  protected:
  explicit DataProcessorInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kElementsQueuedFieldNumber = 1,
  };
  // uint64 elements_queued = 1;
  void clear_elements_queued() ;
  ::uint64_t elements_queued() const;
  void set_elements_queued(::uint64_t value);
 
  private:
  ::uint64_t _internal_elements_queued() const;
  void _internal_set_elements_queued(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<0, 1, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t elements_queued_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class FixedRateDataProcessorInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo) */ {
 public:
  inline FixedRateDataProcessorInfo() : FixedRateDataProcessorInfo(nullptr) {}
  ~FixedRateDataProcessorInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR FixedRateDataProcessorInfo(::google::protobuf::internal::ConstantInitialized);
 
  FixedRateDataProcessorInfo(const FixedRateDataProcessorInfo& from);
  FixedRateDataProcessorInfo(FixedRateDataProcessorInfo&& from) noexcept
    : FixedRateDataProcessorInfo() {
    *this = ::std::move(from);
  }
 
  inline FixedRateDataProcessorInfo& operator=(const FixedRateDataProcessorInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline FixedRateDataProcessorInfo& operator=(FixedRateDataProcessorInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const FixedRateDataProcessorInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const FixedRateDataProcessorInfo* internal_default_instance() {
    return reinterpret_cast<const FixedRateDataProcessorInfo*>(
               &_FixedRateDataProcessorInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    6;
 
  friend void swap(FixedRateDataProcessorInfo& a, FixedRateDataProcessorInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(FixedRateDataProcessorInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(FixedRateDataProcessorInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  FixedRateDataProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<FixedRateDataProcessorInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const FixedRateDataProcessorInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const FixedRateDataProcessorInfo& from) {
    FixedRateDataProcessorInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(FixedRateDataProcessorInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo";
  }
  protected:
  explicit FixedRateDataProcessorInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kNumSeqIdErrorsFieldNumber = 1,
    kMinSeqIdJumpFieldNumber = 2,
    kMaxSeqIdJumpFieldNumber = 3,
    kNumTsErrorsFieldNumber = 4,
  };
  // uint64 num_seq_id_errors = 1;
  void clear_num_seq_id_errors() ;
  ::uint64_t num_seq_id_errors() const;
  void set_num_seq_id_errors(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_seq_id_errors() const;
  void _internal_set_num_seq_id_errors(::uint64_t value);
 
  public:
  // uint64 min_seq_id_jump = 2;
  void clear_min_seq_id_jump() ;
  ::uint64_t min_seq_id_jump() const;
  void set_min_seq_id_jump(::uint64_t value);
 
  private:
  ::uint64_t _internal_min_seq_id_jump() const;
  void _internal_set_min_seq_id_jump(::uint64_t value);
 
  public:
  // uint64 max_seq_id_jump = 3;
  void clear_max_seq_id_jump() ;
  ::uint64_t max_seq_id_jump() const;
  void set_max_seq_id_jump(::uint64_t value);
 
  private:
  ::uint64_t _internal_max_seq_id_jump() const;
  void _internal_set_max_seq_id_jump(::uint64_t value);
 
  public:
  // uint64 num_ts_errors = 4;
  void clear_num_ts_errors() ;
  ::uint64_t num_ts_errors() const;
  void set_num_ts_errors(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_ts_errors() const;
  void _internal_set_num_ts_errors(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<2, 4, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t num_seq_id_errors_;
    ::uint64_t min_seq_id_jump_;
    ::uint64_t max_seq_id_jump_;
    ::uint64_t num_ts_errors_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class HitFindingInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.HitFindingInfo) */ {
 public:
  inline HitFindingInfo() : HitFindingInfo(nullptr) {}
  ~HitFindingInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR HitFindingInfo(::google::protobuf::internal::ConstantInitialized);
 
  HitFindingInfo(const HitFindingInfo& from);
  HitFindingInfo(HitFindingInfo&& from) noexcept
    : HitFindingInfo() {
    *this = ::std::move(from);
  }
 
  inline HitFindingInfo& operator=(const HitFindingInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline HitFindingInfo& operator=(HitFindingInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const HitFindingInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const HitFindingInfo* internal_default_instance() {
    return reinterpret_cast<const HitFindingInfo*>(
               &_HitFindingInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    7;
 
  friend void swap(HitFindingInfo& a, HitFindingInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(HitFindingInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(HitFindingInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  HitFindingInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<HitFindingInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const HitFindingInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const HitFindingInfo& from) {
    HitFindingInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(HitFindingInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.HitFindingInfo";
  }
  protected:
  explicit HitFindingInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kNumTpsSentFieldNumber = 2,
    kNumTpsSendFailedFieldNumber = 3,
    kNumTpsSuppressedTooLongFieldNumber = 4,
    kRateTpHitsFieldNumber = 1,
  };
  // uint64 num_tps_sent = 2;
  void clear_num_tps_sent() ;
  ::uint64_t num_tps_sent() const;
  void set_num_tps_sent(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_tps_sent() const;
  void _internal_set_num_tps_sent(::uint64_t value);
 
  public:
  // uint64 num_tps_send_failed = 3;
  void clear_num_tps_send_failed() ;
  ::uint64_t num_tps_send_failed() const;
  void set_num_tps_send_failed(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_tps_send_failed() const;
  void _internal_set_num_tps_send_failed(::uint64_t value);
 
  public:
  // uint64 num_tps_suppressed_too_long = 4;
  void clear_num_tps_suppressed_too_long() ;
  ::uint64_t num_tps_suppressed_too_long() const;
  void set_num_tps_suppressed_too_long(::uint64_t value);
 
  private:
  ::uint64_t _internal_num_tps_suppressed_too_long() const;
  void _internal_set_num_tps_suppressed_too_long(::uint64_t value);
 
  public:
  // float rate_tp_hits = 1;
  void clear_rate_tp_hits() ;
  float rate_tp_hits() const;
  void set_rate_tp_hits(float value);
 
  private:
  float _internal_rate_tp_hits() const;
  void _internal_set_rate_tp_hits(float value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<2, 4, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t num_tps_sent_;
    ::uint64_t num_tps_send_failed_;
    ::uint64_t num_tps_suppressed_too_long_;
    float rate_tp_hits_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class TPChannelInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPChannelInfo) */ {
 public:
  inline TPChannelInfo() : TPChannelInfo(nullptr) {}
  ~TPChannelInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR TPChannelInfo(::google::protobuf::internal::ConstantInitialized);
 
  TPChannelInfo(const TPChannelInfo& from);
  TPChannelInfo(TPChannelInfo&& from) noexcept
    : TPChannelInfo() {
    *this = ::std::move(from);
  }
 
  inline TPChannelInfo& operator=(const TPChannelInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline TPChannelInfo& operator=(TPChannelInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const TPChannelInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const TPChannelInfo* internal_default_instance() {
    return reinterpret_cast<const TPChannelInfo*>(
               &_TPChannelInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    8;
 
  friend void swap(TPChannelInfo& a, TPChannelInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(TPChannelInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(TPChannelInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  TPChannelInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<TPChannelInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const TPChannelInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const TPChannelInfo& from) {
    TPChannelInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(TPChannelInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.TPChannelInfo";
  }
  protected:
  explicit TPChannelInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kChannelIdFieldNumber = 1,
    kNumberOfTpsFieldNumber = 2,
  };
  // uint64 channel_id = 1;
  void clear_channel_id() ;
  ::uint64_t channel_id() const;
  void set_channel_id(::uint64_t value);
 
  private:
  ::uint64_t _internal_channel_id() const;
  void _internal_set_channel_id(::uint64_t value);
 
  public:
  // uint64 number_of_tps = 2;
  void clear_number_of_tps() ;
  ::uint64_t number_of_tps() const;
  void set_number_of_tps(::uint64_t value);
 
  private:
  ::uint64_t _internal_number_of_tps() const;
  void _internal_set_number_of_tps(::uint64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<1, 2, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::uint64_t channel_id_;
    ::uint64_t number_of_tps_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class TPGProcessorInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo) */ {
 public:
  inline TPGProcessorInfo() : TPGProcessorInfo(nullptr) {}
  ~TPGProcessorInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR TPGProcessorInfo(::google::protobuf::internal::ConstantInitialized);
 
  TPGProcessorInfo(const TPGProcessorInfo& from);
  TPGProcessorInfo(TPGProcessorInfo&& from) noexcept
    : TPGProcessorInfo() {
    *this = ::std::move(from);
  }
 
  inline TPGProcessorInfo& operator=(const TPGProcessorInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline TPGProcessorInfo& operator=(TPGProcessorInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const TPGProcessorInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const TPGProcessorInfo* internal_default_instance() {
    return reinterpret_cast<const TPGProcessorInfo*>(
               &_TPGProcessorInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    9;
 
  friend void swap(TPGProcessorInfo& a, TPGProcessorInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(TPGProcessorInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(TPGProcessorInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  TPGProcessorInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<TPGProcessorInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const TPGProcessorInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const TPGProcessorInfo& from) {
    TPGProcessorInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(TPGProcessorInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.TPGProcessorInfo";
  }
  protected:
  explicit TPGProcessorInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kPedestalFieldNumber = 1,
    kAccumFieldNumber = 2,
  };
  // int64 pedestal = 1;
  void clear_pedestal() ;
  ::int64_t pedestal() const;
  void set_pedestal(::int64_t value);
 
  private:
  ::int64_t _internal_pedestal() const;
  void _internal_set_pedestal(::int64_t value);
 
  public:
  // int64 accum = 2;
  void clear_accum() ;
  ::int64_t accum() const;
  void set_accum(::int64_t value);
 
  private:
  ::int64_t _internal_accum() const;
  void _internal_set_accum(::int64_t value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<1, 2, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    ::int64_t pedestal_;
    ::int64_t accum_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};// -------------------------------------------------------------------
 
class TPGProcessorReducedInfo final :
    public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo) */ {
 public:
  inline TPGProcessorReducedInfo() : TPGProcessorReducedInfo(nullptr) {}
  ~TPGProcessorReducedInfo() override;
  template<typename = void>
  explicit PROTOBUF_CONSTEXPR TPGProcessorReducedInfo(::google::protobuf::internal::ConstantInitialized);
 
  TPGProcessorReducedInfo(const TPGProcessorReducedInfo& from);
  TPGProcessorReducedInfo(TPGProcessorReducedInfo&& from) noexcept
    : TPGProcessorReducedInfo() {
    *this = ::std::move(from);
  }
 
  inline TPGProcessorReducedInfo& operator=(const TPGProcessorReducedInfo& from) {
    CopyFrom(from);
    return *this;
  }
  inline TPGProcessorReducedInfo& operator=(TPGProcessorReducedInfo&& from) noexcept {
    if (this == &from) return *this;
    if (GetOwningArena() == from.GetOwningArena()
  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
        && GetOwningArena() != nullptr
  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
    ) {
      InternalSwap(&from);
    } else {
      CopyFrom(from);
    }
    return *this;
  }
 
  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
  }
  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
  }
 
  static const ::google::protobuf::Descriptor* descriptor() {
    return GetDescriptor();
  }
  static const ::google::protobuf::Descriptor* GetDescriptor() {
    return default_instance().GetMetadata().descriptor;
  }
  static const ::google::protobuf::Reflection* GetReflection() {
    return default_instance().GetMetadata().reflection;
  }
  static const TPGProcessorReducedInfo& default_instance() {
    return *internal_default_instance();
  }
  static inline const TPGProcessorReducedInfo* internal_default_instance() {
    return reinterpret_cast<const TPGProcessorReducedInfo*>(
               &_TPGProcessorReducedInfo_default_instance_);
  }
  static constexpr int kIndexInFileMessages =
    10;
 
  friend void swap(TPGProcessorReducedInfo& a, TPGProcessorReducedInfo& b) {
    a.Swap(&b);
  }
  inline void Swap(TPGProcessorReducedInfo* other) {
    if (other == this) return;
  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() != nullptr &&
        GetOwningArena() == other->GetOwningArena()) {
   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
    if (GetOwningArena() == other->GetOwningArena()) {
  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
      InternalSwap(other);
    } else {
      ::google::protobuf::internal::GenericSwap(this, other);
    }
  }
  void UnsafeArenaSwap(TPGProcessorReducedInfo* other) {
    if (other == this) return;
    ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
    InternalSwap(other);
  }
 
  // implements Message ----------------------------------------------
 
  TPGProcessorReducedInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
    return CreateMaybeMessage<TPGProcessorReducedInfo>(arena);
  }
  using ::google::protobuf::Message::CopyFrom;
  void CopyFrom(const TPGProcessorReducedInfo& from);
  using ::google::protobuf::Message::MergeFrom;
  void MergeFrom( const TPGProcessorReducedInfo& from) {
    TPGProcessorReducedInfo::MergeImpl(*this, from);
  }
  private:
  static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
  public:
  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
  bool IsInitialized() const final;
 
  ::size_t ByteSizeLong() const final;
  const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
  ::uint8_t* _InternalSerialize(
      ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
 
  private:
  void SharedCtor(::google::protobuf::Arena* arena);
  void SharedDtor();
  void SetCachedSize(int size) const final;
  void InternalSwap(TPGProcessorReducedInfo* other);
 
  private:
  friend class ::google::protobuf::internal::AnyMetadata;
  static ::absl::string_view FullMessageName() {
    return "dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo";
  }
  protected:
  explicit TPGProcessorReducedInfo(::google::protobuf::Arena* arena);
  public:
 
  static const ClassData _class_data_;
  const ::google::protobuf::Message::ClassData*GetClassData() const final;
 
  ::google::protobuf::Metadata GetMetadata() const final;
 
  // nested types ----------------------------------------------------
 
  // accessors -------------------------------------------------------
 
  enum : int {
    kAverageFieldNumber = 1,
    kMaxFieldNumber = 2,
    kMinFieldNumber = 3,
    kMaxChannelIdFieldNumber = 4,
    kMinChannelIdFieldNumber = 5,
    kStandardDevFieldNumber = 6,
  };
  // float average = 1;
  void clear_average() ;
  float average() const;
  void set_average(float value);
 
  private:
  float _internal_average() const;
  void _internal_set_average(float value);
 
  public:
  // int32 max = 2;
  void clear_max() ;
  ::int32_t max() const;
  void set_max(::int32_t value);
 
  private:
  ::int32_t _internal_max() const;
  void _internal_set_max(::int32_t value);
 
  public:
  // int32 min = 3;
  void clear_min() ;
  ::int32_t min() const;
  void set_min(::int32_t value);
 
  private:
  ::int32_t _internal_min() const;
  void _internal_set_min(::int32_t value);
 
  public:
  // uint32 max_channel_id = 4;
  void clear_max_channel_id() ;
  ::uint32_t max_channel_id() const;
  void set_max_channel_id(::uint32_t value);
 
  private:
  ::uint32_t _internal_max_channel_id() const;
  void _internal_set_max_channel_id(::uint32_t value);
 
  public:
  // uint32 min_channel_id = 5;
  void clear_min_channel_id() ;
  ::uint32_t min_channel_id() const;
  void set_min_channel_id(::uint32_t value);
 
  private:
  ::uint32_t _internal_min_channel_id() const;
  void _internal_set_min_channel_id(::uint32_t value);
 
  public:
  // float standard_dev = 6;
  void clear_standard_dev() ;
  float standard_dev() const;
  void set_standard_dev(float value);
 
  private:
  float _internal_standard_dev() const;
  void _internal_set_standard_dev(float value);
 
  public:
  // @@protoc_insertion_point(class_scope:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo)
 private:
  class _Internal;
 
  friend class ::google::protobuf::internal::TcParser;
  static const ::google::protobuf::internal::TcParseTable<3, 6, 0, 0, 2> _table_;
  template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
  typedef void InternalArenaConstructable_;
  typedef void DestructorSkippable_;
  struct Impl_ {
    float average_;
    ::int32_t max_;
    ::int32_t min_;
    ::uint32_t max_channel_id_;
    ::uint32_t min_channel_id_;
    float standard_dev_;
    mutable ::google::protobuf::internal::CachedSize _cached_size_;
    PROTOBUF_TSAN_DECLARE_MEMBER
  };
  union { Impl_ _impl_; };
  friend struct ::TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
};
 
// ===================================================================
 
 
 
 
// ===================================================================
 
 
#ifdef __GNUC__
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wstrict-aliasing"
#endif  // __GNUC__
// -------------------------------------------------------------------
 
// LatencyBufferInfo
 
// uint64 num_buffer_elements = 1;
inline void LatencyBufferInfo::clear_num_buffer_elements() {
  _impl_.num_buffer_elements_ = ::uint64_t{0u};
}
inline ::uint64_t LatencyBufferInfo::num_buffer_elements() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo.num_buffer_elements)
  return _internal_num_buffer_elements();
}
inline void LatencyBufferInfo::set_num_buffer_elements(::uint64_t value) {
  _internal_set_num_buffer_elements(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo.num_buffer_elements)
}
inline ::uint64_t LatencyBufferInfo::_internal_num_buffer_elements() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_buffer_elements_;
}
inline void LatencyBufferInfo::_internal_set_num_buffer_elements(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_buffer_elements_ = value;
}
 
// -------------------------------------------------------------------
 
// DataSourceInfo
 
// uint64 sum_packets = 1;
inline void DataSourceInfo::clear_sum_packets() {
  _impl_.sum_packets_ = ::uint64_t{0u};
}
inline ::uint64_t DataSourceInfo::sum_packets() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.sum_packets)
  return _internal_sum_packets();
}
inline void DataSourceInfo::set_sum_packets(::uint64_t value) {
  _internal_set_sum_packets(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.sum_packets)
}
inline ::uint64_t DataSourceInfo::_internal_sum_packets() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.sum_packets_;
}
inline void DataSourceInfo::_internal_set_sum_packets(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.sum_packets_ = value;
}
 
// uint64 num_packets = 2;
inline void DataSourceInfo::clear_num_packets() {
  _impl_.num_packets_ = ::uint64_t{0u};
}
inline ::uint64_t DataSourceInfo::num_packets() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_packets)
  return _internal_num_packets();
}
inline void DataSourceInfo::set_num_packets(::uint64_t value) {
  _internal_set_num_packets(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_packets)
}
inline ::uint64_t DataSourceInfo::_internal_num_packets() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_packets_;
}
inline void DataSourceInfo::_internal_set_num_packets(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_packets_ = value;
}
 
// uint64 num_dropped_packets = 3;
inline void DataSourceInfo::clear_num_dropped_packets() {
  _impl_.num_dropped_packets_ = ::uint64_t{0u};
}
inline ::uint64_t DataSourceInfo::num_dropped_packets() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_dropped_packets)
  return _internal_num_dropped_packets();
}
inline void DataSourceInfo::set_num_dropped_packets(::uint64_t value) {
  _internal_set_num_dropped_packets(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataSourceInfo.num_dropped_packets)
}
inline ::uint64_t DataSourceInfo::_internal_num_dropped_packets() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_dropped_packets_;
}
inline void DataSourceInfo::_internal_set_num_dropped_packets(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_dropped_packets_ = value;
}
 
// -------------------------------------------------------------------
 
// DataHandlerInfo
 
// uint64 sum_payloads = 1;
inline void DataHandlerInfo::clear_sum_payloads() {
  _impl_.sum_payloads_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::sum_payloads() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
  return _internal_sum_payloads();
}
inline void DataHandlerInfo::set_sum_payloads(::uint64_t value) {
  _internal_set_sum_payloads(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_payloads)
}
inline ::uint64_t DataHandlerInfo::_internal_sum_payloads() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.sum_payloads_;
}
inline void DataHandlerInfo::_internal_set_sum_payloads(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.sum_payloads_ = value;
}
 
// uint64 num_payloads = 2;
inline void DataHandlerInfo::clear_num_payloads() {
  _impl_.num_payloads_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::num_payloads() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
  return _internal_num_payloads();
}
inline void DataHandlerInfo::set_num_payloads(::uint64_t value) {
  _internal_set_num_payloads(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_payloads)
}
inline ::uint64_t DataHandlerInfo::_internal_num_payloads() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_payloads_;
}
inline void DataHandlerInfo::_internal_set_num_payloads(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_payloads_ = value;
}
 
// uint64 num_data_input_timeouts = 3;
inline void DataHandlerInfo::clear_num_data_input_timeouts() {
  _impl_.num_data_input_timeouts_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::num_data_input_timeouts() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
  return _internal_num_data_input_timeouts();
}
inline void DataHandlerInfo::set_num_data_input_timeouts(::uint64_t value) {
  _internal_set_num_data_input_timeouts(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_data_input_timeouts)
}
inline ::uint64_t DataHandlerInfo::_internal_num_data_input_timeouts() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_data_input_timeouts_;
}
inline void DataHandlerInfo::_internal_set_num_data_input_timeouts(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_data_input_timeouts_ = value;
}
 
// double rate_payloads_consumed = 4;
inline void DataHandlerInfo::clear_rate_payloads_consumed() {
  _impl_.rate_payloads_consumed_ = 0;
}
inline double DataHandlerInfo::rate_payloads_consumed() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
  return _internal_rate_payloads_consumed();
}
inline void DataHandlerInfo::set_rate_payloads_consumed(double value) {
  _internal_set_rate_payloads_consumed(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.rate_payloads_consumed)
}
inline double DataHandlerInfo::_internal_rate_payloads_consumed() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.rate_payloads_consumed_;
}
inline void DataHandlerInfo::_internal_set_rate_payloads_consumed(double value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.rate_payloads_consumed_ = value;
}
 
// uint64 num_lb_insert_failures = 5;
inline void DataHandlerInfo::clear_num_lb_insert_failures() {
  _impl_.num_lb_insert_failures_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::num_lb_insert_failures() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
  return _internal_num_lb_insert_failures();
}
inline void DataHandlerInfo::set_num_lb_insert_failures(::uint64_t value) {
  _internal_set_num_lb_insert_failures(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_lb_insert_failures)
}
inline ::uint64_t DataHandlerInfo::_internal_num_lb_insert_failures() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_lb_insert_failures_;
}
inline void DataHandlerInfo::_internal_set_num_lb_insert_failures(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_lb_insert_failures_ = value;
}
 
// uint64 sum_requests = 11;
inline void DataHandlerInfo::clear_sum_requests() {
  _impl_.sum_requests_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::sum_requests() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
  return _internal_sum_requests();
}
inline void DataHandlerInfo::set_sum_requests(::uint64_t value) {
  _internal_set_sum_requests(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.sum_requests)
}
inline ::uint64_t DataHandlerInfo::_internal_sum_requests() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.sum_requests_;
}
inline void DataHandlerInfo::_internal_set_sum_requests(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.sum_requests_ = value;
}
 
// uint64 num_requests = 12;
inline void DataHandlerInfo::clear_num_requests() {
  _impl_.num_requests_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::num_requests() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
  return _internal_num_requests();
}
inline void DataHandlerInfo::set_num_requests(::uint64_t value) {
  _internal_set_num_requests(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_requests)
}
inline ::uint64_t DataHandlerInfo::_internal_num_requests() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_;
}
inline void DataHandlerInfo::_internal_set_num_requests(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_ = value;
}
 
// uint64 last_daq_timestamp = 21;
inline void DataHandlerInfo::clear_last_daq_timestamp() {
  _impl_.last_daq_timestamp_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::last_daq_timestamp() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
  return _internal_last_daq_timestamp();
}
inline void DataHandlerInfo::set_last_daq_timestamp(::uint64_t value) {
  _internal_set_last_daq_timestamp(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.last_daq_timestamp)
}
inline ::uint64_t DataHandlerInfo::_internal_last_daq_timestamp() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.last_daq_timestamp_;
}
inline void DataHandlerInfo::_internal_set_last_daq_timestamp(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.last_daq_timestamp_ = value;
}
 
// uint64 num_post_processing_delay_max_waits = 31;
inline void DataHandlerInfo::clear_num_post_processing_delay_max_waits() {
  _impl_.num_post_processing_delay_max_waits_ = ::uint64_t{0u};
}
inline ::uint64_t DataHandlerInfo::num_post_processing_delay_max_waits() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
  return _internal_num_post_processing_delay_max_waits();
}
inline void DataHandlerInfo::set_num_post_processing_delay_max_waits(::uint64_t value) {
  _internal_set_num_post_processing_delay_max_waits(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataHandlerInfo.num_post_processing_delay_max_waits)
}
inline ::uint64_t DataHandlerInfo::_internal_num_post_processing_delay_max_waits() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_post_processing_delay_max_waits_;
}
inline void DataHandlerInfo::_internal_set_num_post_processing_delay_max_waits(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_post_processing_delay_max_waits_ = value;
}
 
// -------------------------------------------------------------------
 
// RequestHandlerInfo
 
// uint64 num_requests_handled = 1;
inline void RequestHandlerInfo::clear_num_requests_handled() {
  _impl_.num_requests_handled_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_handled() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_handled)
  return _internal_num_requests_handled();
}
inline void RequestHandlerInfo::set_num_requests_handled(::uint64_t value) {
  _internal_set_num_requests_handled(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_handled)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_handled() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_handled_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_handled(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_handled_ = value;
}
 
// uint64 num_requests_found = 2;
inline void RequestHandlerInfo::clear_num_requests_found() {
  _impl_.num_requests_found_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_found() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_found)
  return _internal_num_requests_found();
}
inline void RequestHandlerInfo::set_num_requests_found(::uint64_t value) {
  _internal_set_num_requests_found(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_found)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_found() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_found_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_found(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_found_ = value;
}
 
// uint64 num_requests_bad = 3;
inline void RequestHandlerInfo::clear_num_requests_bad() {
  _impl_.num_requests_bad_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_bad() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_bad)
  return _internal_num_requests_bad();
}
inline void RequestHandlerInfo::set_num_requests_bad(::uint64_t value) {
  _internal_set_num_requests_bad(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_bad)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_bad() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_bad_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_bad(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_bad_ = value;
}
 
// uint64 num_requests_old_window = 4;
inline void RequestHandlerInfo::clear_num_requests_old_window() {
  _impl_.num_requests_old_window_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_old_window() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_old_window)
  return _internal_num_requests_old_window();
}
inline void RequestHandlerInfo::set_num_requests_old_window(::uint64_t value) {
  _internal_set_num_requests_old_window(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_old_window)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_old_window() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_old_window_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_old_window(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_old_window_ = value;
}
 
// uint64 num_requests_delayed = 5;
inline void RequestHandlerInfo::clear_num_requests_delayed() {
  _impl_.num_requests_delayed_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_delayed() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_delayed)
  return _internal_num_requests_delayed();
}
inline void RequestHandlerInfo::set_num_requests_delayed(::uint64_t value) {
  _internal_set_num_requests_delayed(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_delayed)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_delayed() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_delayed_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_delayed(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_delayed_ = value;
}
 
// uint64 num_requests_uncategorized = 6;
inline void RequestHandlerInfo::clear_num_requests_uncategorized() {
  _impl_.num_requests_uncategorized_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_uncategorized() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_uncategorized)
  return _internal_num_requests_uncategorized();
}
inline void RequestHandlerInfo::set_num_requests_uncategorized(::uint64_t value) {
  _internal_set_num_requests_uncategorized(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_uncategorized)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_uncategorized() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_uncategorized_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_uncategorized(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_uncategorized_ = value;
}
 
// uint64 num_requests_timed_out = 7;
inline void RequestHandlerInfo::clear_num_requests_timed_out() {
  _impl_.num_requests_timed_out_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_timed_out() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_timed_out)
  return _internal_num_requests_timed_out();
}
inline void RequestHandlerInfo::set_num_requests_timed_out(::uint64_t value) {
  _internal_set_num_requests_timed_out(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_timed_out)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_timed_out() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_timed_out_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_timed_out(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_timed_out_ = value;
}
 
// uint64 num_requests_waiting = 8;
inline void RequestHandlerInfo::clear_num_requests_waiting() {
  _impl_.num_requests_waiting_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_requests_waiting() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_waiting)
  return _internal_num_requests_waiting();
}
inline void RequestHandlerInfo::set_num_requests_waiting(::uint64_t value) {
  _internal_set_num_requests_waiting(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_requests_waiting)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_requests_waiting() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_requests_waiting_;
}
inline void RequestHandlerInfo::_internal_set_num_requests_waiting(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_requests_waiting_ = value;
}
 
// uint64 avg_request_response_time = 21;
inline void RequestHandlerInfo::clear_avg_request_response_time() {
  _impl_.avg_request_response_time_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::avg_request_response_time() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.avg_request_response_time)
  return _internal_avg_request_response_time();
}
inline void RequestHandlerInfo::set_avg_request_response_time(::uint64_t value) {
  _internal_set_avg_request_response_time(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.avg_request_response_time)
}
inline ::uint64_t RequestHandlerInfo::_internal_avg_request_response_time() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.avg_request_response_time_;
}
inline void RequestHandlerInfo::_internal_set_avg_request_response_time(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.avg_request_response_time_ = value;
}
 
// uint64 tot_request_response_time = 22;
inline void RequestHandlerInfo::clear_tot_request_response_time() {
  _impl_.tot_request_response_time_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::tot_request_response_time() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.tot_request_response_time)
  return _internal_tot_request_response_time();
}
inline void RequestHandlerInfo::set_tot_request_response_time(::uint64_t value) {
  _internal_set_tot_request_response_time(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.tot_request_response_time)
}
inline ::uint64_t RequestHandlerInfo::_internal_tot_request_response_time() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.tot_request_response_time_;
}
inline void RequestHandlerInfo::_internal_set_tot_request_response_time(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.tot_request_response_time_ = value;
}
 
// uint64 min_request_response_time = 23;
inline void RequestHandlerInfo::clear_min_request_response_time() {
  _impl_.min_request_response_time_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::min_request_response_time() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.min_request_response_time)
  return _internal_min_request_response_time();
}
inline void RequestHandlerInfo::set_min_request_response_time(::uint64_t value) {
  _internal_set_min_request_response_time(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.min_request_response_time)
}
inline ::uint64_t RequestHandlerInfo::_internal_min_request_response_time() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.min_request_response_time_;
}
inline void RequestHandlerInfo::_internal_set_min_request_response_time(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.min_request_response_time_ = value;
}
 
// uint64 max_request_response_time = 24;
inline void RequestHandlerInfo::clear_max_request_response_time() {
  _impl_.max_request_response_time_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::max_request_response_time() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.max_request_response_time)
  return _internal_max_request_response_time();
}
inline void RequestHandlerInfo::set_max_request_response_time(::uint64_t value) {
  _internal_set_max_request_response_time(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.max_request_response_time)
}
inline ::uint64_t RequestHandlerInfo::_internal_max_request_response_time() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.max_request_response_time_;
}
inline void RequestHandlerInfo::_internal_set_max_request_response_time(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.max_request_response_time_ = value;
}
 
// uint64 num_buffer_cleanups = 31;
inline void RequestHandlerInfo::clear_num_buffer_cleanups() {
  _impl_.num_buffer_cleanups_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_buffer_cleanups() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_buffer_cleanups)
  return _internal_num_buffer_cleanups();
}
inline void RequestHandlerInfo::set_num_buffer_cleanups(::uint64_t value) {
  _internal_set_num_buffer_cleanups(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_buffer_cleanups)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_buffer_cleanups() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_buffer_cleanups_;
}
inline void RequestHandlerInfo::_internal_set_num_buffer_cleanups(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_buffer_cleanups_ = value;
}
 
// uint64 num_periodic_sent = 41;
inline void RequestHandlerInfo::clear_num_periodic_sent() {
  _impl_.num_periodic_sent_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_periodic_sent() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_sent)
  return _internal_num_periodic_sent();
}
inline void RequestHandlerInfo::set_num_periodic_sent(::uint64_t value) {
  _internal_set_num_periodic_sent(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_sent)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_periodic_sent() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_periodic_sent_;
}
inline void RequestHandlerInfo::_internal_set_num_periodic_sent(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_periodic_sent_ = value;
}
 
// uint64 num_periodic_send_failed = 42;
inline void RequestHandlerInfo::clear_num_periodic_send_failed() {
  _impl_.num_periodic_send_failed_ = ::uint64_t{0u};
}
inline ::uint64_t RequestHandlerInfo::num_periodic_send_failed() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_send_failed)
  return _internal_num_periodic_send_failed();
}
inline void RequestHandlerInfo::set_num_periodic_send_failed(::uint64_t value) {
  _internal_set_num_periodic_send_failed(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo.num_periodic_send_failed)
}
inline ::uint64_t RequestHandlerInfo::_internal_num_periodic_send_failed() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_periodic_send_failed_;
}
inline void RequestHandlerInfo::_internal_set_num_periodic_send_failed(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_periodic_send_failed_ = value;
}
 
// -------------------------------------------------------------------
 
// RecordingInfo
 
// string recording_status = 1;
inline void RecordingInfo::clear_recording_status() {
  _impl_.recording_status_.ClearToEmpty();
}
inline const std::string& RecordingInfo::recording_status() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
  return _internal_recording_status();
}
template <typename Arg_, typename... Args_>
inline PROTOBUF_ALWAYS_INLINE void RecordingInfo::set_recording_status(Arg_&& arg,
                                                     Args_... args) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.recording_status_.Set(static_cast<Arg_&&>(arg), args..., GetArenaForAllocation());
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
}
inline std::string* RecordingInfo::mutable_recording_status() {
  std::string* _s = _internal_mutable_recording_status();
  // @@protoc_insertion_point(field_mutable:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
  return _s;
}
inline const std::string& RecordingInfo::_internal_recording_status() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.recording_status_.Get();
}
inline void RecordingInfo::_internal_set_recording_status(const std::string& value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.recording_status_.Set(value, GetArenaForAllocation());
}
inline std::string* RecordingInfo::_internal_mutable_recording_status() {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  return _impl_.recording_status_.Mutable( GetArenaForAllocation());
}
inline std::string* RecordingInfo::release_recording_status() {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  // @@protoc_insertion_point(field_release:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
  return _impl_.recording_status_.Release();
}
inline void RecordingInfo::set_allocated_recording_status(std::string* value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  _impl_.recording_status_.SetAllocated(value, GetArenaForAllocation());
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
        if (_impl_.recording_status_.IsDefault()) {
          _impl_.recording_status_.Set("", GetArenaForAllocation());
        }
  #endif  // PROTOBUF_FORCE_COPY_DEFAULT_STRING
  // @@protoc_insertion_point(field_set_allocated:dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status)
}
 
// uint64 packets_recorded = 2;
inline void RecordingInfo::clear_packets_recorded() {
  _impl_.packets_recorded_ = ::uint64_t{0u};
}
inline ::uint64_t RecordingInfo::packets_recorded() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.packets_recorded)
  return _internal_packets_recorded();
}
inline void RecordingInfo::set_packets_recorded(::uint64_t value) {
  _internal_set_packets_recorded(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.packets_recorded)
}
inline ::uint64_t RecordingInfo::_internal_packets_recorded() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.packets_recorded_;
}
inline void RecordingInfo::_internal_set_packets_recorded(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.packets_recorded_ = value;
}
 
// uint64 bytes_recorded = 3;
inline void RecordingInfo::clear_bytes_recorded() {
  _impl_.bytes_recorded_ = ::uint64_t{0u};
}
inline ::uint64_t RecordingInfo::bytes_recorded() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.RecordingInfo.bytes_recorded)
  return _internal_bytes_recorded();
}
inline void RecordingInfo::set_bytes_recorded(::uint64_t value) {
  _internal_set_bytes_recorded(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.RecordingInfo.bytes_recorded)
}
inline ::uint64_t RecordingInfo::_internal_bytes_recorded() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.bytes_recorded_;
}
inline void RecordingInfo::_internal_set_bytes_recorded(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.bytes_recorded_ = value;
}
 
// -------------------------------------------------------------------
 
// DataProcessorInfo
 
// uint64 elements_queued = 1;
inline void DataProcessorInfo::clear_elements_queued() {
  _impl_.elements_queued_ = ::uint64_t{0u};
}
inline ::uint64_t DataProcessorInfo::elements_queued() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.DataProcessorInfo.elements_queued)
  return _internal_elements_queued();
}
inline void DataProcessorInfo::set_elements_queued(::uint64_t value) {
  _internal_set_elements_queued(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.DataProcessorInfo.elements_queued)
}
inline ::uint64_t DataProcessorInfo::_internal_elements_queued() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.elements_queued_;
}
inline void DataProcessorInfo::_internal_set_elements_queued(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.elements_queued_ = value;
}
 
// -------------------------------------------------------------------
 
// FixedRateDataProcessorInfo
 
// uint64 num_seq_id_errors = 1;
inline void FixedRateDataProcessorInfo::clear_num_seq_id_errors() {
  _impl_.num_seq_id_errors_ = ::uint64_t{0u};
}
inline ::uint64_t FixedRateDataProcessorInfo::num_seq_id_errors() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_seq_id_errors)
  return _internal_num_seq_id_errors();
}
inline void FixedRateDataProcessorInfo::set_num_seq_id_errors(::uint64_t value) {
  _internal_set_num_seq_id_errors(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_seq_id_errors)
}
inline ::uint64_t FixedRateDataProcessorInfo::_internal_num_seq_id_errors() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_seq_id_errors_;
}
inline void FixedRateDataProcessorInfo::_internal_set_num_seq_id_errors(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_seq_id_errors_ = value;
}
 
// uint64 min_seq_id_jump = 2;
inline void FixedRateDataProcessorInfo::clear_min_seq_id_jump() {
  _impl_.min_seq_id_jump_ = ::uint64_t{0u};
}
inline ::uint64_t FixedRateDataProcessorInfo::min_seq_id_jump() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.min_seq_id_jump)
  return _internal_min_seq_id_jump();
}
inline void FixedRateDataProcessorInfo::set_min_seq_id_jump(::uint64_t value) {
  _internal_set_min_seq_id_jump(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.min_seq_id_jump)
}
inline ::uint64_t FixedRateDataProcessorInfo::_internal_min_seq_id_jump() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.min_seq_id_jump_;
}
inline void FixedRateDataProcessorInfo::_internal_set_min_seq_id_jump(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.min_seq_id_jump_ = value;
}
 
// uint64 max_seq_id_jump = 3;
inline void FixedRateDataProcessorInfo::clear_max_seq_id_jump() {
  _impl_.max_seq_id_jump_ = ::uint64_t{0u};
}
inline ::uint64_t FixedRateDataProcessorInfo::max_seq_id_jump() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.max_seq_id_jump)
  return _internal_max_seq_id_jump();
}
inline void FixedRateDataProcessorInfo::set_max_seq_id_jump(::uint64_t value) {
  _internal_set_max_seq_id_jump(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.max_seq_id_jump)
}
inline ::uint64_t FixedRateDataProcessorInfo::_internal_max_seq_id_jump() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.max_seq_id_jump_;
}
inline void FixedRateDataProcessorInfo::_internal_set_max_seq_id_jump(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.max_seq_id_jump_ = value;
}
 
// uint64 num_ts_errors = 4;
inline void FixedRateDataProcessorInfo::clear_num_ts_errors() {
  _impl_.num_ts_errors_ = ::uint64_t{0u};
}
inline ::uint64_t FixedRateDataProcessorInfo::num_ts_errors() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_ts_errors)
  return _internal_num_ts_errors();
}
inline void FixedRateDataProcessorInfo::set_num_ts_errors(::uint64_t value) {
  _internal_set_num_ts_errors(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo.num_ts_errors)
}
inline ::uint64_t FixedRateDataProcessorInfo::_internal_num_ts_errors() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_ts_errors_;
}
inline void FixedRateDataProcessorInfo::_internal_set_num_ts_errors(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_ts_errors_ = value;
}
 
// -------------------------------------------------------------------
 
// HitFindingInfo
 
// float rate_tp_hits = 1;
inline void HitFindingInfo::clear_rate_tp_hits() {
  _impl_.rate_tp_hits_ = 0;
}
inline float HitFindingInfo::rate_tp_hits() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.rate_tp_hits)
  return _internal_rate_tp_hits();
}
inline void HitFindingInfo::set_rate_tp_hits(float value) {
  _internal_set_rate_tp_hits(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.rate_tp_hits)
}
inline float HitFindingInfo::_internal_rate_tp_hits() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.rate_tp_hits_;
}
inline void HitFindingInfo::_internal_set_rate_tp_hits(float value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.rate_tp_hits_ = value;
}
 
// uint64 num_tps_sent = 2;
inline void HitFindingInfo::clear_num_tps_sent() {
  _impl_.num_tps_sent_ = ::uint64_t{0u};
}
inline ::uint64_t HitFindingInfo::num_tps_sent() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_sent)
  return _internal_num_tps_sent();
}
inline void HitFindingInfo::set_num_tps_sent(::uint64_t value) {
  _internal_set_num_tps_sent(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_sent)
}
inline ::uint64_t HitFindingInfo::_internal_num_tps_sent() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_tps_sent_;
}
inline void HitFindingInfo::_internal_set_num_tps_sent(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_tps_sent_ = value;
}
 
// uint64 num_tps_send_failed = 3;
inline void HitFindingInfo::clear_num_tps_send_failed() {
  _impl_.num_tps_send_failed_ = ::uint64_t{0u};
}
inline ::uint64_t HitFindingInfo::num_tps_send_failed() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_send_failed)
  return _internal_num_tps_send_failed();
}
inline void HitFindingInfo::set_num_tps_send_failed(::uint64_t value) {
  _internal_set_num_tps_send_failed(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_send_failed)
}
inline ::uint64_t HitFindingInfo::_internal_num_tps_send_failed() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_tps_send_failed_;
}
inline void HitFindingInfo::_internal_set_num_tps_send_failed(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_tps_send_failed_ = value;
}
 
// uint64 num_tps_suppressed_too_long = 4;
inline void HitFindingInfo::clear_num_tps_suppressed_too_long() {
  _impl_.num_tps_suppressed_too_long_ = ::uint64_t{0u};
}
inline ::uint64_t HitFindingInfo::num_tps_suppressed_too_long() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_suppressed_too_long)
  return _internal_num_tps_suppressed_too_long();
}
inline void HitFindingInfo::set_num_tps_suppressed_too_long(::uint64_t value) {
  _internal_set_num_tps_suppressed_too_long(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.HitFindingInfo.num_tps_suppressed_too_long)
}
inline ::uint64_t HitFindingInfo::_internal_num_tps_suppressed_too_long() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.num_tps_suppressed_too_long_;
}
inline void HitFindingInfo::_internal_set_num_tps_suppressed_too_long(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.num_tps_suppressed_too_long_ = value;
}
 
// -------------------------------------------------------------------
 
// TPChannelInfo
 
// uint64 channel_id = 1;
inline void TPChannelInfo::clear_channel_id() {
  _impl_.channel_id_ = ::uint64_t{0u};
}
inline ::uint64_t TPChannelInfo::channel_id() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPChannelInfo.channel_id)
  return _internal_channel_id();
}
inline void TPChannelInfo::set_channel_id(::uint64_t value) {
  _internal_set_channel_id(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPChannelInfo.channel_id)
}
inline ::uint64_t TPChannelInfo::_internal_channel_id() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.channel_id_;
}
inline void TPChannelInfo::_internal_set_channel_id(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.channel_id_ = value;
}
 
// uint64 number_of_tps = 2;
inline void TPChannelInfo::clear_number_of_tps() {
  _impl_.number_of_tps_ = ::uint64_t{0u};
}
inline ::uint64_t TPChannelInfo::number_of_tps() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPChannelInfo.number_of_tps)
  return _internal_number_of_tps();
}
inline void TPChannelInfo::set_number_of_tps(::uint64_t value) {
  _internal_set_number_of_tps(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPChannelInfo.number_of_tps)
}
inline ::uint64_t TPChannelInfo::_internal_number_of_tps() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.number_of_tps_;
}
inline void TPChannelInfo::_internal_set_number_of_tps(::uint64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.number_of_tps_ = value;
}
 
// -------------------------------------------------------------------
 
// TPGProcessorInfo
 
// int64 pedestal = 1;
inline void TPGProcessorInfo::clear_pedestal() {
  _impl_.pedestal_ = ::int64_t{0};
}
inline ::int64_t TPGProcessorInfo::pedestal() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.pedestal)
  return _internal_pedestal();
}
inline void TPGProcessorInfo::set_pedestal(::int64_t value) {
  _internal_set_pedestal(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.pedestal)
}
inline ::int64_t TPGProcessorInfo::_internal_pedestal() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.pedestal_;
}
inline void TPGProcessorInfo::_internal_set_pedestal(::int64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.pedestal_ = value;
}
 
// int64 accum = 2;
inline void TPGProcessorInfo::clear_accum() {
  _impl_.accum_ = ::int64_t{0};
}
inline ::int64_t TPGProcessorInfo::accum() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.accum)
  return _internal_accum();
}
inline void TPGProcessorInfo::set_accum(::int64_t value) {
  _internal_set_accum(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorInfo.accum)
}
inline ::int64_t TPGProcessorInfo::_internal_accum() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.accum_;
}
inline void TPGProcessorInfo::_internal_set_accum(::int64_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.accum_ = value;
}
 
// -------------------------------------------------------------------
 
// TPGProcessorReducedInfo
 
// float average = 1;
inline void TPGProcessorReducedInfo::clear_average() {
  _impl_.average_ = 0;
}
inline float TPGProcessorReducedInfo::average() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.average)
  return _internal_average();
}
inline void TPGProcessorReducedInfo::set_average(float value) {
  _internal_set_average(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.average)
}
inline float TPGProcessorReducedInfo::_internal_average() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.average_;
}
inline void TPGProcessorReducedInfo::_internal_set_average(float value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.average_ = value;
}
 
// int32 max = 2;
inline void TPGProcessorReducedInfo::clear_max() {
  _impl_.max_ = 0;
}
inline ::int32_t TPGProcessorReducedInfo::max() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max)
  return _internal_max();
}
inline void TPGProcessorReducedInfo::set_max(::int32_t value) {
  _internal_set_max(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max)
}
inline ::int32_t TPGProcessorReducedInfo::_internal_max() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.max_;
}
inline void TPGProcessorReducedInfo::_internal_set_max(::int32_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.max_ = value;
}
 
// int32 min = 3;
inline void TPGProcessorReducedInfo::clear_min() {
  _impl_.min_ = 0;
}
inline ::int32_t TPGProcessorReducedInfo::min() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min)
  return _internal_min();
}
inline void TPGProcessorReducedInfo::set_min(::int32_t value) {
  _internal_set_min(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min)
}
inline ::int32_t TPGProcessorReducedInfo::_internal_min() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.min_;
}
inline void TPGProcessorReducedInfo::_internal_set_min(::int32_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.min_ = value;
}
 
// uint32 max_channel_id = 4;
inline void TPGProcessorReducedInfo::clear_max_channel_id() {
  _impl_.max_channel_id_ = 0u;
}
inline ::uint32_t TPGProcessorReducedInfo::max_channel_id() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max_channel_id)
  return _internal_max_channel_id();
}
inline void TPGProcessorReducedInfo::set_max_channel_id(::uint32_t value) {
  _internal_set_max_channel_id(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.max_channel_id)
}
inline ::uint32_t TPGProcessorReducedInfo::_internal_max_channel_id() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.max_channel_id_;
}
inline void TPGProcessorReducedInfo::_internal_set_max_channel_id(::uint32_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.max_channel_id_ = value;
}
 
// uint32 min_channel_id = 5;
inline void TPGProcessorReducedInfo::clear_min_channel_id() {
  _impl_.min_channel_id_ = 0u;
}
inline ::uint32_t TPGProcessorReducedInfo::min_channel_id() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min_channel_id)
  return _internal_min_channel_id();
}
inline void TPGProcessorReducedInfo::set_min_channel_id(::uint32_t value) {
  _internal_set_min_channel_id(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.min_channel_id)
}
inline ::uint32_t TPGProcessorReducedInfo::_internal_min_channel_id() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.min_channel_id_;
}
inline void TPGProcessorReducedInfo::_internal_set_min_channel_id(::uint32_t value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.min_channel_id_ = value;
}
 
// float standard_dev = 6;
inline void TPGProcessorReducedInfo::clear_standard_dev() {
  _impl_.standard_dev_ = 0;
}
inline float TPGProcessorReducedInfo::standard_dev() const {
  // @@protoc_insertion_point(field_get:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.standard_dev)
  return _internal_standard_dev();
}
inline void TPGProcessorReducedInfo::set_standard_dev(float value) {
  _internal_set_standard_dev(value);
  // @@protoc_insertion_point(field_set:dunedaq.datahandlinglibs.opmon.TPGProcessorReducedInfo.standard_dev)
}
inline float TPGProcessorReducedInfo::_internal_standard_dev() const {
  PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
  return _impl_.standard_dev_;
}
inline void TPGProcessorReducedInfo::_internal_set_standard_dev(float value) {
  PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
  ;
  _impl_.standard_dev_ = value;
}
 
#ifdef __GNUC__
#pragma GCC diagnostic pop
#endif  // __GNUC__
 
// @@protoc_insertion_point(namespace_scope)
}  // namespace opmon
}  // namespace datahandlinglibs
}  // namespace dunedaq
 
 
// @@protoc_insertion_point(global_scope)
 
#include "google/protobuf/port_undef.inc"
 
#endif  // GOOGLE_PROTOBUF_INCLUDED_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_2epb_2eh