datahandling_info.pb.cc

Go to the documentation of this file.

// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: datahandlinglibs/opmon/datahandling_info.proto
 
#include "datahandlinglibs/opmon/datahandling_info.pb.h"
 
#include <algorithm>
#include "google/protobuf/io/coded_stream.h"
#include "google/protobuf/extension_set.h"
#include "google/protobuf/wire_format_lite.h"
#include "google/protobuf/descriptor.h"
#include "google/protobuf/generated_message_reflection.h"
#include "google/protobuf/reflection_ops.h"
#include "google/protobuf/wire_format.h"
#include "google/protobuf/generated_message_tctable_impl.h"
// @@protoc_insertion_point(includes)
 
// Must be included last.
#include "google/protobuf/port_def.inc"
PROTOBUF_PRAGMA_INIT_SEG
namespace _pb = ::google::protobuf;
namespace _pbi = ::google::protobuf::internal;
namespace _fl = ::google::protobuf::internal::field_layout;
namespace dunedaq {
namespace datahandlinglibs {
namespace opmon {
        template <typename>
PROTOBUF_CONSTEXPR LatencyBufferInfo::LatencyBufferInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.num_buffer_elements_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct LatencyBufferInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR LatencyBufferInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~LatencyBufferInfoDefaultTypeInternal() {}
  union {
    LatencyBufferInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 LatencyBufferInfoDefaultTypeInternal _LatencyBufferInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR DataSourceInfo::DataSourceInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.sum_packets_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_packets_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_dropped_packets_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct DataSourceInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR DataSourceInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~DataSourceInfoDefaultTypeInternal() {}
  union {
    DataSourceInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataSourceInfoDefaultTypeInternal _DataSourceInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR DataHandlerInfo::DataHandlerInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.sum_payloads_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_payloads_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_data_input_timeouts_)*/ ::uint64_t{0u},
      /*decltype(_impl_.rate_payloads_consumed_)*/ 0,
      /*decltype(_impl_.num_lb_insert_failures_)*/ ::uint64_t{0u},
      /*decltype(_impl_.sum_requests_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_)*/ ::uint64_t{0u},
      /*decltype(_impl_.last_daq_timestamp_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct DataHandlerInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR DataHandlerInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~DataHandlerInfoDefaultTypeInternal() {}
  union {
    DataHandlerInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataHandlerInfoDefaultTypeInternal _DataHandlerInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR RequestHandlerInfo::RequestHandlerInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.num_requests_handled_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_found_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_bad_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_old_window_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_delayed_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_uncategorized_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_timed_out_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_requests_waiting_)*/ ::uint64_t{0u},
      /*decltype(_impl_.avg_request_response_time_)*/ ::uint64_t{0u},
      /*decltype(_impl_.tot_request_response_time_)*/ ::uint64_t{0u},
      /*decltype(_impl_.min_request_response_time_)*/ ::uint64_t{0u},
      /*decltype(_impl_.max_request_response_time_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_buffer_cleanups_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_periodic_sent_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_periodic_send_failed_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct RequestHandlerInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR RequestHandlerInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~RequestHandlerInfoDefaultTypeInternal() {}
  union {
    RequestHandlerInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RequestHandlerInfoDefaultTypeInternal _RequestHandlerInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR RecordingInfo::RecordingInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.recording_status_)*/ {
          &::_pbi::fixed_address_empty_string,
          ::_pbi::ConstantInitialized{},
      },
      /*decltype(_impl_.packets_recorded_)*/ ::uint64_t{0u},
      /*decltype(_impl_.bytes_recorded_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct RecordingInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR RecordingInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~RecordingInfoDefaultTypeInternal() {}
  union {
    RecordingInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RecordingInfoDefaultTypeInternal _RecordingInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR DataProcessorInfo::DataProcessorInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.elements_queued_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct DataProcessorInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR DataProcessorInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~DataProcessorInfoDefaultTypeInternal() {}
  union {
    DataProcessorInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DataProcessorInfoDefaultTypeInternal _DataProcessorInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR FixedRateDataProcessorInfo::FixedRateDataProcessorInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.num_seq_id_errors_)*/ ::uint64_t{0u},
      /*decltype(_impl_.min_seq_id_jump_)*/ ::uint64_t{0u},
      /*decltype(_impl_.max_seq_id_jump_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_ts_errors_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct FixedRateDataProcessorInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR FixedRateDataProcessorInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~FixedRateDataProcessorInfoDefaultTypeInternal() {}
  union {
    FixedRateDataProcessorInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FixedRateDataProcessorInfoDefaultTypeInternal _FixedRateDataProcessorInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR HitFindingInfo::HitFindingInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.num_tps_sent_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_tps_send_failed_)*/ ::uint64_t{0u},
      /*decltype(_impl_.num_tps_suppressed_too_long_)*/ ::uint64_t{0u},
      /*decltype(_impl_.rate_tp_hits_)*/ 0,
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct HitFindingInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR HitFindingInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~HitFindingInfoDefaultTypeInternal() {}
  union {
    HitFindingInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 HitFindingInfoDefaultTypeInternal _HitFindingInfo_default_instance_;
        template <typename>
PROTOBUF_CONSTEXPR TPChannelInfo::TPChannelInfo(::_pbi::ConstantInitialized)
    : _impl_{
      /*decltype(_impl_.channel_id_)*/ ::uint64_t{0u},
      /*decltype(_impl_.number_of_tps_)*/ ::uint64_t{0u},
      /*decltype(_impl_._cached_size_)*/ {},
    } {}
struct TPChannelInfoDefaultTypeInternal {
  PROTOBUF_CONSTEXPR TPChannelInfoDefaultTypeInternal() : _instance(::_pbi::ConstantInitialized{}) {}
  ~TPChannelInfoDefaultTypeInternal() {}
  union {
    TPChannelInfo _instance;
  };
};
 
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT
    PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPChannelInfoDefaultTypeInternal _TPChannelInfo_default_instance_;
}  // namespace opmon
}  // namespace datahandlinglibs
}  // namespace dunedaq
static ::_pb::Metadata file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[9];
static constexpr const ::_pb::EnumDescriptor**
    file_level_enum_descriptors_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto = nullptr;
static constexpr const ::_pb::ServiceDescriptor**
    file_level_service_descriptors_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto = nullptr;
const ::uint32_t TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(
    protodesc_cold) = {
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::LatencyBufferInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::LatencyBufferInfo, _impl_.num_buffer_elements_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataSourceInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataSourceInfo, _impl_.sum_packets_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataSourceInfo, _impl_.num_packets_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataSourceInfo, _impl_.num_dropped_packets_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.sum_payloads_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.num_payloads_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.num_data_input_timeouts_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.rate_payloads_consumed_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.num_lb_insert_failures_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.sum_requests_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.num_requests_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo, _impl_.last_daq_timestamp_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_handled_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_found_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_bad_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_old_window_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_delayed_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_uncategorized_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_timed_out_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_requests_waiting_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.avg_request_response_time_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.tot_request_response_time_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.min_request_response_time_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.max_request_response_time_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_buffer_cleanups_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_periodic_sent_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo, _impl_.num_periodic_send_failed_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RecordingInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RecordingInfo, _impl_.recording_status_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RecordingInfo, _impl_.packets_recorded_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::RecordingInfo, _impl_.bytes_recorded_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataProcessorInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::DataProcessorInfo, _impl_.elements_queued_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo, _impl_.num_seq_id_errors_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo, _impl_.min_seq_id_jump_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo, _impl_.max_seq_id_jump_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo, _impl_.num_ts_errors_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::HitFindingInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::HitFindingInfo, _impl_.rate_tp_hits_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::HitFindingInfo, _impl_.num_tps_sent_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::HitFindingInfo, _impl_.num_tps_send_failed_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::HitFindingInfo, _impl_.num_tps_suppressed_too_long_),
    ~0u,  // no _has_bits_
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::TPChannelInfo, _internal_metadata_),
    ~0u,  // no _extensions_
    ~0u,  // no _oneof_case_
    ~0u,  // no _weak_field_map_
    ~0u,  // no _inlined_string_donated_
    ~0u,  // no _split_
    ~0u,  // no sizeof(Split)
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::TPChannelInfo, _impl_.channel_id_),
    PROTOBUF_FIELD_OFFSET(::dunedaq::datahandlinglibs::opmon::TPChannelInfo, _impl_.number_of_tps_),
};
 
static const ::_pbi::MigrationSchema
    schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
        {0, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::LatencyBufferInfo)},
        {9, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::DataSourceInfo)},
        {20, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::DataHandlerInfo)},
        {36, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::RequestHandlerInfo)},
        {59, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::RecordingInfo)},
        {70, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::DataProcessorInfo)},
        {79, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::FixedRateDataProcessorInfo)},
        {91, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::HitFindingInfo)},
        {103, -1, -1, sizeof(::dunedaq::datahandlinglibs::opmon::TPChannelInfo)},
};
 
static const ::_pb::Message* const file_default_instances[] = {
    &::dunedaq::datahandlinglibs::opmon::_LatencyBufferInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_DataSourceInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_DataHandlerInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_RequestHandlerInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_RecordingInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_DataProcessorInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_FixedRateDataProcessorInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_HitFindingInfo_default_instance_._instance,
    &::dunedaq::datahandlinglibs::opmon::_TPChannelInfo_default_instance_._instance,
};
const char descriptor_table_protodef_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
    "\n.datahandlinglibs/opmon/datahandling_in"
    "fo.proto\022\036dunedaq.datahandlinglibs.opmon"
    "\"0\n\021LatencyBufferInfo\022\033\n\023num_buffer_elem"
    "ents\030\001 \001(\004\"W\n\016DataSourceInfo\022\023\n\013sum_pack"
    "ets\030\001 \001(\004\022\023\n\013num_packets\030\002 \001(\004\022\033\n\023num_dr"
    "opped_packets\030\003 \001(\004\"\346\001\n\017DataHandlerInfo\022"
    "\024\n\014sum_payloads\030\001 \001(\004\022\024\n\014num_payloads\030\002 "
    "\001(\004\022\037\n\027num_data_input_timeouts\030\003 \001(\004\022\036\n\026"
    "rate_payloads_consumed\030\004 \001(\001\022\036\n\026num_lb_i"
    "nsert_failures\030\005 \001(\004\022\024\n\014sum_requests\030\013 \001"
    "(\004\022\024\n\014num_requests\030\014 \001(\004\022\032\n\022last_daq_tim"
    "estamp\030\025 \001(\004\"\357\003\n\022RequestHandlerInfo\022\034\n\024n"
    "um_requests_handled\030\001 \001(\004\022\032\n\022num_request"
    "s_found\030\002 \001(\004\022\030\n\020num_requests_bad\030\003 \001(\004\022"
    "\037\n\027num_requests_old_window\030\004 \001(\004\022\034\n\024num_"
    "requests_delayed\030\005 \001(\004\022\"\n\032num_requests_u"
    "ncategorized\030\006 \001(\004\022\036\n\026num_requests_timed"
    "_out\030\007 \001(\004\022\034\n\024num_requests_waiting\030\010 \001(\004"
    "\022!\n\031avg_request_response_time\030\025 \001(\004\022!\n\031t"
    "ot_request_response_time\030\026 \001(\004\022!\n\031min_re"
    "quest_response_time\030\027 \001(\004\022!\n\031max_request"
    "_response_time\030\030 \001(\004\022\033\n\023num_buffer_clean"
    "ups\030\037 \001(\004\022\031\n\021num_periodic_sent\030) \001(\004\022 \n\030"
    "num_periodic_send_failed\030* \001(\004\"[\n\rRecord"
    "ingInfo\022\030\n\020recording_status\030\001 \001(\t\022\030\n\020pac"
    "kets_recorded\030\002 \001(\004\022\026\n\016bytes_recorded\030\003 "
    "\001(\004\",\n\021DataProcessorInfo\022\027\n\017elements_que"
    "ued\030\001 \001(\004\"\200\001\n\032FixedRateDataProcessorInfo"
    "\022\031\n\021num_seq_id_errors\030\001 \001(\004\022\027\n\017min_seq_i"
    "d_jump\030\002 \001(\004\022\027\n\017max_seq_id_jump\030\003 \001(\004\022\025\n"
    "\rnum_ts_errors\030\004 \001(\004\"~\n\016HitFindingInfo\022\024"
    "\n\014rate_tp_hits\030\001 \001(\002\022\024\n\014num_tps_sent\030\002 \001"
    "(\004\022\033\n\023num_tps_send_failed\030\003 \001(\004\022#\n\033num_t"
    "ps_suppressed_too_long\030\004 \001(\004\":\n\rTPChanne"
    "lInfo\022\022\n\nchannel_id\030\001 \001(\004\022\025\n\rnumber_of_t"
    "ps\030\002 \001(\004b\006proto3"
};
static ::absl::once_flag descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once;
const ::_pbi::DescriptorTable descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto = {
    false,
    false,
    1416,
    descriptor_table_protodef_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto,
    "datahandlinglibs/opmon/datahandling_info.proto",
    &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
    nullptr,
    0,
    9,
    schemas,
    file_default_instances,
    TableStruct_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto::offsets,
    file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto,
    file_level_enum_descriptors_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto,
    file_level_service_descriptors_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto,
};
 
// This function exists to be marked as weak.
// It can significantly speed up compilation by breaking up LLVM's SCC
// in the .pb.cc translation units. Large translation units see a
// reduction of more than 35% of walltime for optimized builds. Without
// the weak attribute all the messages in the file, including all the
// vtables and everything they use become part of the same SCC through
// a cycle like:
// GetMetadata -> descriptor table -> default instances ->
//   vtables -> GetMetadata
// By adding a weak function here we break the connection from the
// individual vtables back into the descriptor table.
PROTOBUF_ATTRIBUTE_WEAK const ::_pbi::DescriptorTable* descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter() {
  return &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto;
}
// Force running AddDescriptors() at dynamic initialization time.
PROTOBUF_ATTRIBUTE_INIT_PRIORITY2
static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto(&descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto);
namespace dunedaq {
namespace datahandlinglibs {
namespace opmon {
// ===================================================================
 
class LatencyBufferInfo::_Internal {
 public:
};
 
LatencyBufferInfo::LatencyBufferInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
}
LatencyBufferInfo::LatencyBufferInfo(const LatencyBufferInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
}
inline void LatencyBufferInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.num_buffer_elements_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
LatencyBufferInfo::~LatencyBufferInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void LatencyBufferInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void LatencyBufferInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void LatencyBufferInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  _impl_.num_buffer_elements_ = ::uint64_t{0u};
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* LatencyBufferInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<0, 1, 0, 0, 2> LatencyBufferInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    1, 0,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967294,  // skipmap
    offsetof(decltype(_table_), field_entries),
    1,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_LatencyBufferInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    // uint64 num_buffer_elements = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(LatencyBufferInfo, _impl_.num_buffer_elements_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(LatencyBufferInfo, _impl_.num_buffer_elements_)}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 num_buffer_elements = 1;
    {PROTOBUF_FIELD_OFFSET(LatencyBufferInfo, _impl_.num_buffer_elements_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* LatencyBufferInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 num_buffer_elements = 1;
  if (this->_internal_num_buffer_elements() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_num_buffer_elements(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  return target;
}
 
::size_t LatencyBufferInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 num_buffer_elements = 1;
  if (this->_internal_num_buffer_elements() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_buffer_elements());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData LatencyBufferInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    LatencyBufferInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*LatencyBufferInfo::GetClassData() const { return &_class_data_; }
 
 
void LatencyBufferInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<LatencyBufferInfo*>(&to_msg);
  auto& from = static_cast<const LatencyBufferInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_num_buffer_elements() != 0) {
    _this->_internal_set_num_buffer_elements(from._internal_num_buffer_elements());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void LatencyBufferInfo::CopyFrom(const LatencyBufferInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.LatencyBufferInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool LatencyBufferInfo::IsInitialized() const {
  return true;
}
 
void LatencyBufferInfo::InternalSwap(LatencyBufferInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
        swap(_impl_.num_buffer_elements_, other->_impl_.num_buffer_elements_);
}
 
::google::protobuf::Metadata LatencyBufferInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[0]);
}
// ===================================================================
 
class DataSourceInfo::_Internal {
 public:
};
 
DataSourceInfo::DataSourceInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
}
DataSourceInfo::DataSourceInfo(const DataSourceInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
}
inline void DataSourceInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.sum_packets_){::uint64_t{0u}},
      decltype(_impl_.num_packets_){::uint64_t{0u}},
      decltype(_impl_.num_dropped_packets_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
DataSourceInfo::~DataSourceInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void DataSourceInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void DataSourceInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void DataSourceInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.sum_packets_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.num_dropped_packets_) -
      reinterpret_cast<char*>(&_impl_.sum_packets_)) + sizeof(_impl_.num_dropped_packets_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* DataSourceInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<2, 3, 0, 0, 2> DataSourceInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    3, 24,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967288,  // skipmap
    offsetof(decltype(_table_), field_entries),
    3,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_DataSourceInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    {::_pbi::TcParser::MiniParse, {}},
    // uint64 sum_packets = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataSourceInfo, _impl_.sum_packets_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.sum_packets_)}},
    // uint64 num_packets = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataSourceInfo, _impl_.num_packets_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.num_packets_)}},
    // uint64 num_dropped_packets = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataSourceInfo, _impl_.num_dropped_packets_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.num_dropped_packets_)}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 sum_packets = 1;
    {PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.sum_packets_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_packets = 2;
    {PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.num_packets_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_dropped_packets = 3;
    {PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.num_dropped_packets_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* DataSourceInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 sum_packets = 1;
  if (this->_internal_sum_packets() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_sum_packets(), target);
  }
 
  // uint64 num_packets = 2;
  if (this->_internal_num_packets() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_num_packets(), target);
  }
 
  // uint64 num_dropped_packets = 3;
  if (this->_internal_num_dropped_packets() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_num_dropped_packets(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  return target;
}
 
::size_t DataSourceInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 sum_packets = 1;
  if (this->_internal_sum_packets() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_sum_packets());
  }
 
  // uint64 num_packets = 2;
  if (this->_internal_num_packets() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_packets());
  }
 
  // uint64 num_dropped_packets = 3;
  if (this->_internal_num_dropped_packets() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_dropped_packets());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData DataSourceInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    DataSourceInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*DataSourceInfo::GetClassData() const { return &_class_data_; }
 
 
void DataSourceInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<DataSourceInfo*>(&to_msg);
  auto& from = static_cast<const DataSourceInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_sum_packets() != 0) {
    _this->_internal_set_sum_packets(from._internal_sum_packets());
  }
  if (from._internal_num_packets() != 0) {
    _this->_internal_set_num_packets(from._internal_num_packets());
  }
  if (from._internal_num_dropped_packets() != 0) {
    _this->_internal_set_num_dropped_packets(from._internal_num_dropped_packets());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void DataSourceInfo::CopyFrom(const DataSourceInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.DataSourceInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool DataSourceInfo::IsInitialized() const {
  return true;
}
 
void DataSourceInfo::InternalSwap(DataSourceInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.num_dropped_packets_)
      + sizeof(DataSourceInfo::_impl_.num_dropped_packets_)
      - PROTOBUF_FIELD_OFFSET(DataSourceInfo, _impl_.sum_packets_)>(
          reinterpret_cast<char*>(&_impl_.sum_packets_),
          reinterpret_cast<char*>(&other->_impl_.sum_packets_));
}
 
::google::protobuf::Metadata DataSourceInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[1]);
}
// ===================================================================
 
class DataHandlerInfo::_Internal {
 public:
};
 
DataHandlerInfo::DataHandlerInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
}
DataHandlerInfo::DataHandlerInfo(const DataHandlerInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
}
inline void DataHandlerInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.sum_payloads_){::uint64_t{0u}},
      decltype(_impl_.num_payloads_){::uint64_t{0u}},
      decltype(_impl_.num_data_input_timeouts_){::uint64_t{0u}},
      decltype(_impl_.rate_payloads_consumed_){0},
      decltype(_impl_.num_lb_insert_failures_){::uint64_t{0u}},
      decltype(_impl_.sum_requests_){::uint64_t{0u}},
      decltype(_impl_.num_requests_){::uint64_t{0u}},
      decltype(_impl_.last_daq_timestamp_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
DataHandlerInfo::~DataHandlerInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void DataHandlerInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void DataHandlerInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void DataHandlerInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.sum_payloads_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.last_daq_timestamp_) -
      reinterpret_cast<char*>(&_impl_.sum_payloads_)) + sizeof(_impl_.last_daq_timestamp_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* DataHandlerInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<4, 8, 0, 0, 2> DataHandlerInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    21, 120,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4293915616,  // skipmap
    offsetof(decltype(_table_), field_entries),
    8,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_DataHandlerInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    {::_pbi::TcParser::MiniParse, {}},
    // uint64 sum_payloads = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.sum_payloads_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_payloads_)}},
    // uint64 num_payloads = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.num_payloads_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_payloads_)}},
    // uint64 num_data_input_timeouts = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.num_data_input_timeouts_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_data_input_timeouts_)}},
    // double rate_payloads_consumed = 4;
    {::_pbi::TcParser::FastF64S1,
     {33, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.rate_payloads_consumed_)}},
    // uint64 num_lb_insert_failures = 5;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.num_lb_insert_failures_), 63>(),
     {40, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_lb_insert_failures_)}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    // uint64 sum_requests = 11;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.sum_requests_), 63>(),
     {88, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_requests_)}},
    // uint64 num_requests = 12;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataHandlerInfo, _impl_.num_requests_), 63>(),
     {96, 63, 0, PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_requests_)}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 sum_payloads = 1;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_payloads_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_payloads = 2;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_payloads_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_data_input_timeouts = 3;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_data_input_timeouts_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // double rate_payloads_consumed = 4;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.rate_payloads_consumed_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kDouble)},
    // uint64 num_lb_insert_failures = 5;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_lb_insert_failures_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 sum_requests = 11;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_requests_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests = 12;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.num_requests_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 last_daq_timestamp = 21;
    {PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.last_daq_timestamp_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* DataHandlerInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 sum_payloads = 1;
  if (this->_internal_sum_payloads() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_sum_payloads(), target);
  }
 
  // uint64 num_payloads = 2;
  if (this->_internal_num_payloads() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_num_payloads(), target);
  }
 
  // uint64 num_data_input_timeouts = 3;
  if (this->_internal_num_data_input_timeouts() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_num_data_input_timeouts(), target);
  }
 
  // double rate_payloads_consumed = 4;
  static_assert(sizeof(::uint64_t) == sizeof(double),
                "Code assumes ::uint64_t and double are the same size.");
  double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
  ::uint64_t raw_rate_payloads_consumed;
  memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
  if (raw_rate_payloads_consumed != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(
        4, this->_internal_rate_payloads_consumed(), target);
  }
 
  // uint64 num_lb_insert_failures = 5;
  if (this->_internal_num_lb_insert_failures() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        5, this->_internal_num_lb_insert_failures(), target);
  }
 
  // uint64 sum_requests = 11;
  if (this->_internal_sum_requests() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        11, this->_internal_sum_requests(), target);
  }
 
  // uint64 num_requests = 12;
  if (this->_internal_num_requests() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        12, this->_internal_num_requests(), target);
  }
 
  // uint64 last_daq_timestamp = 21;
  if (this->_internal_last_daq_timestamp() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        21, this->_internal_last_daq_timestamp(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  return target;
}
 
::size_t DataHandlerInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 sum_payloads = 1;
  if (this->_internal_sum_payloads() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_sum_payloads());
  }
 
  // uint64 num_payloads = 2;
  if (this->_internal_num_payloads() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_payloads());
  }
 
  // uint64 num_data_input_timeouts = 3;
  if (this->_internal_num_data_input_timeouts() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_data_input_timeouts());
  }
 
  // double rate_payloads_consumed = 4;
  static_assert(sizeof(::uint64_t) == sizeof(double),
                "Code assumes ::uint64_t and double are the same size.");
  double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
  ::uint64_t raw_rate_payloads_consumed;
  memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
  if (raw_rate_payloads_consumed != 0) {
    total_size += 9;
  }
 
  // uint64 num_lb_insert_failures = 5;
  if (this->_internal_num_lb_insert_failures() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_lb_insert_failures());
  }
 
  // uint64 sum_requests = 11;
  if (this->_internal_sum_requests() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_sum_requests());
  }
 
  // uint64 num_requests = 12;
  if (this->_internal_num_requests() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests());
  }
 
  // uint64 last_daq_timestamp = 21;
  if (this->_internal_last_daq_timestamp() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_last_daq_timestamp());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData DataHandlerInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    DataHandlerInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*DataHandlerInfo::GetClassData() const { return &_class_data_; }
 
 
void DataHandlerInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<DataHandlerInfo*>(&to_msg);
  auto& from = static_cast<const DataHandlerInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_sum_payloads() != 0) {
    _this->_internal_set_sum_payloads(from._internal_sum_payloads());
  }
  if (from._internal_num_payloads() != 0) {
    _this->_internal_set_num_payloads(from._internal_num_payloads());
  }
  if (from._internal_num_data_input_timeouts() != 0) {
    _this->_internal_set_num_data_input_timeouts(from._internal_num_data_input_timeouts());
  }
  static_assert(sizeof(::uint64_t) == sizeof(double),
                "Code assumes ::uint64_t and double are the same size.");
  double tmp_rate_payloads_consumed = from._internal_rate_payloads_consumed();
  ::uint64_t raw_rate_payloads_consumed;
  memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
  if (raw_rate_payloads_consumed != 0) {
    _this->_internal_set_rate_payloads_consumed(from._internal_rate_payloads_consumed());
  }
  if (from._internal_num_lb_insert_failures() != 0) {
    _this->_internal_set_num_lb_insert_failures(from._internal_num_lb_insert_failures());
  }
  if (from._internal_sum_requests() != 0) {
    _this->_internal_set_sum_requests(from._internal_sum_requests());
  }
  if (from._internal_num_requests() != 0) {
    _this->_internal_set_num_requests(from._internal_num_requests());
  }
  if (from._internal_last_daq_timestamp() != 0) {
    _this->_internal_set_last_daq_timestamp(from._internal_last_daq_timestamp());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void DataHandlerInfo::CopyFrom(const DataHandlerInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.DataHandlerInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool DataHandlerInfo::IsInitialized() const {
  return true;
}
 
void DataHandlerInfo::InternalSwap(DataHandlerInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.last_daq_timestamp_)
      + sizeof(DataHandlerInfo::_impl_.last_daq_timestamp_)
      - PROTOBUF_FIELD_OFFSET(DataHandlerInfo, _impl_.sum_payloads_)>(
          reinterpret_cast<char*>(&_impl_.sum_payloads_),
          reinterpret_cast<char*>(&other->_impl_.sum_payloads_));
}
 
::google::protobuf::Metadata DataHandlerInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[2]);
}
// ===================================================================
 
class RequestHandlerInfo::_Internal {
 public:
};
 
RequestHandlerInfo::RequestHandlerInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
}
RequestHandlerInfo::RequestHandlerInfo(const RequestHandlerInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
}
inline void RequestHandlerInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.num_requests_handled_){::uint64_t{0u}},
      decltype(_impl_.num_requests_found_){::uint64_t{0u}},
      decltype(_impl_.num_requests_bad_){::uint64_t{0u}},
      decltype(_impl_.num_requests_old_window_){::uint64_t{0u}},
      decltype(_impl_.num_requests_delayed_){::uint64_t{0u}},
      decltype(_impl_.num_requests_uncategorized_){::uint64_t{0u}},
      decltype(_impl_.num_requests_timed_out_){::uint64_t{0u}},
      decltype(_impl_.num_requests_waiting_){::uint64_t{0u}},
      decltype(_impl_.avg_request_response_time_){::uint64_t{0u}},
      decltype(_impl_.tot_request_response_time_){::uint64_t{0u}},
      decltype(_impl_.min_request_response_time_){::uint64_t{0u}},
      decltype(_impl_.max_request_response_time_){::uint64_t{0u}},
      decltype(_impl_.num_buffer_cleanups_){::uint64_t{0u}},
      decltype(_impl_.num_periodic_sent_){::uint64_t{0u}},
      decltype(_impl_.num_periodic_send_failed_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
RequestHandlerInfo::~RequestHandlerInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void RequestHandlerInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void RequestHandlerInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void RequestHandlerInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.num_requests_handled_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.num_periodic_send_failed_) -
      reinterpret_cast<char*>(&_impl_.num_requests_handled_)) + sizeof(_impl_.num_periodic_send_failed_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* RequestHandlerInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<4, 15, 0, 0, 7> RequestHandlerInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    42, 120,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    3205496576,  // skipmap
    offsetof(decltype(_table_), field_entries),
    15,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_RequestHandlerInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    {::_pbi::TcParser::MiniParse, {}},
    // uint64 num_requests_handled = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_handled_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_handled_)}},
    // uint64 num_requests_found = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_found_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_found_)}},
    // uint64 num_requests_bad = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_bad_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_bad_)}},
    // uint64 num_requests_old_window = 4;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_old_window_), 63>(),
     {32, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_old_window_)}},
    // uint64 num_requests_delayed = 5;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_delayed_), 63>(),
     {40, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_delayed_)}},
    // uint64 num_requests_uncategorized = 6;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_uncategorized_), 63>(),
     {48, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_uncategorized_)}},
    // uint64 num_requests_timed_out = 7;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_timed_out_), 63>(),
     {56, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_timed_out_)}},
    // uint64 num_requests_waiting = 8;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RequestHandlerInfo, _impl_.num_requests_waiting_), 63>(),
     {64, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_waiting_)}},
    // uint64 num_periodic_sent = 41;
    {::_pbi::TcParser::FastV64S2,
     {712, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_periodic_sent_)}},
    // uint64 num_periodic_send_failed = 42;
    {::_pbi::TcParser::FastV64S2,
     {720, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_periodic_send_failed_)}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    {::_pbi::TcParser::MiniParse, {}},
    // uint64 num_buffer_cleanups = 31;
    {::_pbi::TcParser::FastV64S2,
     {504, 63, 0, PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_buffer_cleanups_)}},
  }}, {{
    41, 0, 1,
    65532, 13,
    65535, 65535
  }}, {{
    // uint64 num_requests_handled = 1;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_handled_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_found = 2;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_found_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_bad = 3;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_bad_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_old_window = 4;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_old_window_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_delayed = 5;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_delayed_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_uncategorized = 6;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_uncategorized_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_timed_out = 7;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_timed_out_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_requests_waiting = 8;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_waiting_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 avg_request_response_time = 21;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.avg_request_response_time_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 tot_request_response_time = 22;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.tot_request_response_time_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 min_request_response_time = 23;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.min_request_response_time_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 max_request_response_time = 24;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.max_request_response_time_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_buffer_cleanups = 31;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_buffer_cleanups_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_periodic_sent = 41;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_periodic_sent_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_periodic_send_failed = 42;
    {PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_periodic_send_failed_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* RequestHandlerInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 num_requests_handled = 1;
  if (this->_internal_num_requests_handled() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_num_requests_handled(), target);
  }
 
  // uint64 num_requests_found = 2;
  if (this->_internal_num_requests_found() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_num_requests_found(), target);
  }
 
  // uint64 num_requests_bad = 3;
  if (this->_internal_num_requests_bad() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_num_requests_bad(), target);
  }
 
  // uint64 num_requests_old_window = 4;
  if (this->_internal_num_requests_old_window() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        4, this->_internal_num_requests_old_window(), target);
  }
 
  // uint64 num_requests_delayed = 5;
  if (this->_internal_num_requests_delayed() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        5, this->_internal_num_requests_delayed(), target);
  }
 
  // uint64 num_requests_uncategorized = 6;
  if (this->_internal_num_requests_uncategorized() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        6, this->_internal_num_requests_uncategorized(), target);
  }
 
  // uint64 num_requests_timed_out = 7;
  if (this->_internal_num_requests_timed_out() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        7, this->_internal_num_requests_timed_out(), target);
  }
 
  // uint64 num_requests_waiting = 8;
  if (this->_internal_num_requests_waiting() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        8, this->_internal_num_requests_waiting(), target);
  }
 
  // uint64 avg_request_response_time = 21;
  if (this->_internal_avg_request_response_time() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        21, this->_internal_avg_request_response_time(), target);
  }
 
  // uint64 tot_request_response_time = 22;
  if (this->_internal_tot_request_response_time() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        22, this->_internal_tot_request_response_time(), target);
  }
 
  // uint64 min_request_response_time = 23;
  if (this->_internal_min_request_response_time() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        23, this->_internal_min_request_response_time(), target);
  }
 
  // uint64 max_request_response_time = 24;
  if (this->_internal_max_request_response_time() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        24, this->_internal_max_request_response_time(), target);
  }
 
  // uint64 num_buffer_cleanups = 31;
  if (this->_internal_num_buffer_cleanups() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        31, this->_internal_num_buffer_cleanups(), target);
  }
 
  // uint64 num_periodic_sent = 41;
  if (this->_internal_num_periodic_sent() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        41, this->_internal_num_periodic_sent(), target);
  }
 
  // uint64 num_periodic_send_failed = 42;
  if (this->_internal_num_periodic_send_failed() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        42, this->_internal_num_periodic_send_failed(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  return target;
}
 
::size_t RequestHandlerInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 num_requests_handled = 1;
  if (this->_internal_num_requests_handled() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_handled());
  }
 
  // uint64 num_requests_found = 2;
  if (this->_internal_num_requests_found() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_found());
  }
 
  // uint64 num_requests_bad = 3;
  if (this->_internal_num_requests_bad() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_bad());
  }
 
  // uint64 num_requests_old_window = 4;
  if (this->_internal_num_requests_old_window() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_old_window());
  }
 
  // uint64 num_requests_delayed = 5;
  if (this->_internal_num_requests_delayed() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_delayed());
  }
 
  // uint64 num_requests_uncategorized = 6;
  if (this->_internal_num_requests_uncategorized() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_uncategorized());
  }
 
  // uint64 num_requests_timed_out = 7;
  if (this->_internal_num_requests_timed_out() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_timed_out());
  }
 
  // uint64 num_requests_waiting = 8;
  if (this->_internal_num_requests_waiting() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_requests_waiting());
  }
 
  // uint64 avg_request_response_time = 21;
  if (this->_internal_avg_request_response_time() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_avg_request_response_time());
  }
 
  // uint64 tot_request_response_time = 22;
  if (this->_internal_tot_request_response_time() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_tot_request_response_time());
  }
 
  // uint64 min_request_response_time = 23;
  if (this->_internal_min_request_response_time() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_min_request_response_time());
  }
 
  // uint64 max_request_response_time = 24;
  if (this->_internal_max_request_response_time() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_max_request_response_time());
  }
 
  // uint64 num_buffer_cleanups = 31;
  if (this->_internal_num_buffer_cleanups() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_num_buffer_cleanups());
  }
 
  // uint64 num_periodic_sent = 41;
  if (this->_internal_num_periodic_sent() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_num_periodic_sent());
  }
 
  // uint64 num_periodic_send_failed = 42;
  if (this->_internal_num_periodic_send_failed() != 0) {
    total_size += 2 + ::_pbi::WireFormatLite::UInt64Size(
                                    this->_internal_num_periodic_send_failed());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData RequestHandlerInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    RequestHandlerInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*RequestHandlerInfo::GetClassData() const { return &_class_data_; }
 
 
void RequestHandlerInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<RequestHandlerInfo*>(&to_msg);
  auto& from = static_cast<const RequestHandlerInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_num_requests_handled() != 0) {
    _this->_internal_set_num_requests_handled(from._internal_num_requests_handled());
  }
  if (from._internal_num_requests_found() != 0) {
    _this->_internal_set_num_requests_found(from._internal_num_requests_found());
  }
  if (from._internal_num_requests_bad() != 0) {
    _this->_internal_set_num_requests_bad(from._internal_num_requests_bad());
  }
  if (from._internal_num_requests_old_window() != 0) {
    _this->_internal_set_num_requests_old_window(from._internal_num_requests_old_window());
  }
  if (from._internal_num_requests_delayed() != 0) {
    _this->_internal_set_num_requests_delayed(from._internal_num_requests_delayed());
  }
  if (from._internal_num_requests_uncategorized() != 0) {
    _this->_internal_set_num_requests_uncategorized(from._internal_num_requests_uncategorized());
  }
  if (from._internal_num_requests_timed_out() != 0) {
    _this->_internal_set_num_requests_timed_out(from._internal_num_requests_timed_out());
  }
  if (from._internal_num_requests_waiting() != 0) {
    _this->_internal_set_num_requests_waiting(from._internal_num_requests_waiting());
  }
  if (from._internal_avg_request_response_time() != 0) {
    _this->_internal_set_avg_request_response_time(from._internal_avg_request_response_time());
  }
  if (from._internal_tot_request_response_time() != 0) {
    _this->_internal_set_tot_request_response_time(from._internal_tot_request_response_time());
  }
  if (from._internal_min_request_response_time() != 0) {
    _this->_internal_set_min_request_response_time(from._internal_min_request_response_time());
  }
  if (from._internal_max_request_response_time() != 0) {
    _this->_internal_set_max_request_response_time(from._internal_max_request_response_time());
  }
  if (from._internal_num_buffer_cleanups() != 0) {
    _this->_internal_set_num_buffer_cleanups(from._internal_num_buffer_cleanups());
  }
  if (from._internal_num_periodic_sent() != 0) {
    _this->_internal_set_num_periodic_sent(from._internal_num_periodic_sent());
  }
  if (from._internal_num_periodic_send_failed() != 0) {
    _this->_internal_set_num_periodic_send_failed(from._internal_num_periodic_send_failed());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void RequestHandlerInfo::CopyFrom(const RequestHandlerInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.RequestHandlerInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool RequestHandlerInfo::IsInitialized() const {
  return true;
}
 
void RequestHandlerInfo::InternalSwap(RequestHandlerInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_periodic_send_failed_)
      + sizeof(RequestHandlerInfo::_impl_.num_periodic_send_failed_)
      - PROTOBUF_FIELD_OFFSET(RequestHandlerInfo, _impl_.num_requests_handled_)>(
          reinterpret_cast<char*>(&_impl_.num_requests_handled_),
          reinterpret_cast<char*>(&other->_impl_.num_requests_handled_));
}
 
::google::protobuf::Metadata RequestHandlerInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[3]);
}
// ===================================================================
 
class RecordingInfo::_Internal {
 public:
};
 
RecordingInfo::RecordingInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.RecordingInfo)
}
RecordingInfo::RecordingInfo(const RecordingInfo& from) : ::google::protobuf::Message() {
  RecordingInfo* const _this = this;
  (void)_this;
  new (&_impl_) Impl_{
      decltype(_impl_.recording_status_){},
      decltype(_impl_.packets_recorded_){},
      decltype(_impl_.bytes_recorded_){},
      /*decltype(_impl_._cached_size_)*/ {},
  };
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  _impl_.recording_status_.InitDefault();
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
        _impl_.recording_status_.Set("", GetArenaForAllocation());
  #endif  // PROTOBUF_FORCE_COPY_DEFAULT_STRING
  if (!from._internal_recording_status().empty()) {
    _this->_impl_.recording_status_.Set(from._internal_recording_status(), _this->GetArenaForAllocation());
  }
  ::memcpy(&_impl_.packets_recorded_, &from._impl_.packets_recorded_,
    static_cast<::size_t>(reinterpret_cast<char*>(&_impl_.bytes_recorded_) -
    reinterpret_cast<char*>(&_impl_.packets_recorded_)) + sizeof(_impl_.bytes_recorded_));
 
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.RecordingInfo)
}
inline void RecordingInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.recording_status_){},
      decltype(_impl_.packets_recorded_){::uint64_t{0u}},
      decltype(_impl_.bytes_recorded_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
  _impl_.recording_status_.InitDefault();
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
        _impl_.recording_status_.Set("", GetArenaForAllocation());
  #endif  // PROTOBUF_FORCE_COPY_DEFAULT_STRING
}
RecordingInfo::~RecordingInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void RecordingInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
  _impl_.recording_status_.Destroy();
}
void RecordingInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void RecordingInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  _impl_.recording_status_.ClearToEmpty();
  ::memset(&_impl_.packets_recorded_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.bytes_recorded_) -
      reinterpret_cast<char*>(&_impl_.packets_recorded_)) + sizeof(_impl_.bytes_recorded_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* RecordingInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<2, 3, 0, 69, 2> RecordingInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    3, 24,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967288,  // skipmap
    offsetof(decltype(_table_), field_entries),
    3,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_RecordingInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    {::_pbi::TcParser::MiniParse, {}},
    // string recording_status = 1;
    {::_pbi::TcParser::FastUS1,
     {10, 63, 0, PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.recording_status_)}},
    // uint64 packets_recorded = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RecordingInfo, _impl_.packets_recorded_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.packets_recorded_)}},
    // uint64 bytes_recorded = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(RecordingInfo, _impl_.bytes_recorded_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.bytes_recorded_)}},
  }}, {{
    65535, 65535
  }}, {{
    // string recording_status = 1;
    {PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.recording_status_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUtf8String | ::_fl::kRepAString)},
    // uint64 packets_recorded = 2;
    {PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.packets_recorded_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 bytes_recorded = 3;
    {PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.bytes_recorded_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
    "\54\20\0\0\0\0\0\0"
    "dunedaq.datahandlinglibs.opmon.RecordingInfo"
    "recording_status"
  }},
};
 
::uint8_t* RecordingInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // string recording_status = 1;
  if (!this->_internal_recording_status().empty()) {
    const std::string& _s = this->_internal_recording_status();
    ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(
        _s.data(), static_cast<int>(_s.length()), ::google::protobuf::internal::WireFormatLite::SERIALIZE, "dunedaq.datahandlinglibs.opmon.RecordingInfo.recording_status");
    target = stream->WriteStringMaybeAliased(1, _s, target);
  }
 
  // uint64 packets_recorded = 2;
  if (this->_internal_packets_recorded() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_packets_recorded(), target);
  }
 
  // uint64 bytes_recorded = 3;
  if (this->_internal_bytes_recorded() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_bytes_recorded(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  return target;
}
 
::size_t RecordingInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // string recording_status = 1;
  if (!this->_internal_recording_status().empty()) {
    total_size += 1 + ::google::protobuf::internal::WireFormatLite::StringSize(
                                    this->_internal_recording_status());
  }
 
  // uint64 packets_recorded = 2;
  if (this->_internal_packets_recorded() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_packets_recorded());
  }
 
  // uint64 bytes_recorded = 3;
  if (this->_internal_bytes_recorded() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_bytes_recorded());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData RecordingInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    RecordingInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*RecordingInfo::GetClassData() const { return &_class_data_; }
 
 
void RecordingInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<RecordingInfo*>(&to_msg);
  auto& from = static_cast<const RecordingInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (!from._internal_recording_status().empty()) {
    _this->_internal_set_recording_status(from._internal_recording_status());
  }
  if (from._internal_packets_recorded() != 0) {
    _this->_internal_set_packets_recorded(from._internal_packets_recorded());
  }
  if (from._internal_bytes_recorded() != 0) {
    _this->_internal_set_bytes_recorded(from._internal_bytes_recorded());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void RecordingInfo::CopyFrom(const RecordingInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.RecordingInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool RecordingInfo::IsInitialized() const {
  return true;
}
 
void RecordingInfo::InternalSwap(RecordingInfo* other) {
  using std::swap;
  auto* lhs_arena = GetArenaForAllocation();
  auto* rhs_arena = other->GetArenaForAllocation();
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::_pbi::ArenaStringPtr::InternalSwap(&_impl_.recording_status_, lhs_arena,
                                       &other->_impl_.recording_status_, rhs_arena);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.bytes_recorded_)
      + sizeof(RecordingInfo::_impl_.bytes_recorded_)
      - PROTOBUF_FIELD_OFFSET(RecordingInfo, _impl_.packets_recorded_)>(
          reinterpret_cast<char*>(&_impl_.packets_recorded_),
          reinterpret_cast<char*>(&other->_impl_.packets_recorded_));
}
 
::google::protobuf::Metadata RecordingInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[4]);
}
// ===================================================================
 
class DataProcessorInfo::_Internal {
 public:
};
 
DataProcessorInfo::DataProcessorInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
}
DataProcessorInfo::DataProcessorInfo(const DataProcessorInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
}
inline void DataProcessorInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.elements_queued_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
DataProcessorInfo::~DataProcessorInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void DataProcessorInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void DataProcessorInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void DataProcessorInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  _impl_.elements_queued_ = ::uint64_t{0u};
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* DataProcessorInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<0, 1, 0, 0, 2> DataProcessorInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    1, 0,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967294,  // skipmap
    offsetof(decltype(_table_), field_entries),
    1,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_DataProcessorInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    // uint64 elements_queued = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(DataProcessorInfo, _impl_.elements_queued_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(DataProcessorInfo, _impl_.elements_queued_)}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 elements_queued = 1;
    {PROTOBUF_FIELD_OFFSET(DataProcessorInfo, _impl_.elements_queued_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* DataProcessorInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 elements_queued = 1;
  if (this->_internal_elements_queued() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_elements_queued(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  return target;
}
 
::size_t DataProcessorInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 elements_queued = 1;
  if (this->_internal_elements_queued() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_elements_queued());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData DataProcessorInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    DataProcessorInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*DataProcessorInfo::GetClassData() const { return &_class_data_; }
 
 
void DataProcessorInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<DataProcessorInfo*>(&to_msg);
  auto& from = static_cast<const DataProcessorInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_elements_queued() != 0) {
    _this->_internal_set_elements_queued(from._internal_elements_queued());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void DataProcessorInfo::CopyFrom(const DataProcessorInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.DataProcessorInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool DataProcessorInfo::IsInitialized() const {
  return true;
}
 
void DataProcessorInfo::InternalSwap(DataProcessorInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
        swap(_impl_.elements_queued_, other->_impl_.elements_queued_);
}
 
::google::protobuf::Metadata DataProcessorInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[5]);
}
// ===================================================================
 
class FixedRateDataProcessorInfo::_Internal {
 public:
};
 
FixedRateDataProcessorInfo::FixedRateDataProcessorInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
}
FixedRateDataProcessorInfo::FixedRateDataProcessorInfo(const FixedRateDataProcessorInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
}
inline void FixedRateDataProcessorInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.num_seq_id_errors_){::uint64_t{0u}},
      decltype(_impl_.min_seq_id_jump_){::uint64_t{0u}},
      decltype(_impl_.max_seq_id_jump_){::uint64_t{0u}},
      decltype(_impl_.num_ts_errors_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
FixedRateDataProcessorInfo::~FixedRateDataProcessorInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void FixedRateDataProcessorInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void FixedRateDataProcessorInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void FixedRateDataProcessorInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.num_seq_id_errors_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.num_ts_errors_) -
      reinterpret_cast<char*>(&_impl_.num_seq_id_errors_)) + sizeof(_impl_.num_ts_errors_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* FixedRateDataProcessorInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<2, 4, 0, 0, 2> FixedRateDataProcessorInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    4, 24,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967280,  // skipmap
    offsetof(decltype(_table_), field_entries),
    4,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_FixedRateDataProcessorInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    // uint64 num_ts_errors = 4;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(FixedRateDataProcessorInfo, _impl_.num_ts_errors_), 63>(),
     {32, 63, 0, PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_ts_errors_)}},
    // uint64 num_seq_id_errors = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(FixedRateDataProcessorInfo, _impl_.num_seq_id_errors_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_seq_id_errors_)}},
    // uint64 min_seq_id_jump = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(FixedRateDataProcessorInfo, _impl_.min_seq_id_jump_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.min_seq_id_jump_)}},
    // uint64 max_seq_id_jump = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(FixedRateDataProcessorInfo, _impl_.max_seq_id_jump_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.max_seq_id_jump_)}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 num_seq_id_errors = 1;
    {PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_seq_id_errors_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 min_seq_id_jump = 2;
    {PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.min_seq_id_jump_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 max_seq_id_jump = 3;
    {PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.max_seq_id_jump_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_ts_errors = 4;
    {PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_ts_errors_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* FixedRateDataProcessorInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 num_seq_id_errors = 1;
  if (this->_internal_num_seq_id_errors() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_num_seq_id_errors(), target);
  }
 
  // uint64 min_seq_id_jump = 2;
  if (this->_internal_min_seq_id_jump() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_min_seq_id_jump(), target);
  }
 
  // uint64 max_seq_id_jump = 3;
  if (this->_internal_max_seq_id_jump() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_max_seq_id_jump(), target);
  }
 
  // uint64 num_ts_errors = 4;
  if (this->_internal_num_ts_errors() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        4, this->_internal_num_ts_errors(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  return target;
}
 
::size_t FixedRateDataProcessorInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 num_seq_id_errors = 1;
  if (this->_internal_num_seq_id_errors() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_seq_id_errors());
  }
 
  // uint64 min_seq_id_jump = 2;
  if (this->_internal_min_seq_id_jump() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_min_seq_id_jump());
  }
 
  // uint64 max_seq_id_jump = 3;
  if (this->_internal_max_seq_id_jump() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_max_seq_id_jump());
  }
 
  // uint64 num_ts_errors = 4;
  if (this->_internal_num_ts_errors() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_ts_errors());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData FixedRateDataProcessorInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    FixedRateDataProcessorInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*FixedRateDataProcessorInfo::GetClassData() const { return &_class_data_; }
 
 
void FixedRateDataProcessorInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<FixedRateDataProcessorInfo*>(&to_msg);
  auto& from = static_cast<const FixedRateDataProcessorInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_num_seq_id_errors() != 0) {
    _this->_internal_set_num_seq_id_errors(from._internal_num_seq_id_errors());
  }
  if (from._internal_min_seq_id_jump() != 0) {
    _this->_internal_set_min_seq_id_jump(from._internal_min_seq_id_jump());
  }
  if (from._internal_max_seq_id_jump() != 0) {
    _this->_internal_set_max_seq_id_jump(from._internal_max_seq_id_jump());
  }
  if (from._internal_num_ts_errors() != 0) {
    _this->_internal_set_num_ts_errors(from._internal_num_ts_errors());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void FixedRateDataProcessorInfo::CopyFrom(const FixedRateDataProcessorInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.FixedRateDataProcessorInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool FixedRateDataProcessorInfo::IsInitialized() const {
  return true;
}
 
void FixedRateDataProcessorInfo::InternalSwap(FixedRateDataProcessorInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_ts_errors_)
      + sizeof(FixedRateDataProcessorInfo::_impl_.num_ts_errors_)
      - PROTOBUF_FIELD_OFFSET(FixedRateDataProcessorInfo, _impl_.num_seq_id_errors_)>(
          reinterpret_cast<char*>(&_impl_.num_seq_id_errors_),
          reinterpret_cast<char*>(&other->_impl_.num_seq_id_errors_));
}
 
::google::protobuf::Metadata FixedRateDataProcessorInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[6]);
}
// ===================================================================
 
class HitFindingInfo::_Internal {
 public:
};
 
HitFindingInfo::HitFindingInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
}
HitFindingInfo::HitFindingInfo(const HitFindingInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
}
inline void HitFindingInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.num_tps_sent_){::uint64_t{0u}},
      decltype(_impl_.num_tps_send_failed_){::uint64_t{0u}},
      decltype(_impl_.num_tps_suppressed_too_long_){::uint64_t{0u}},
      decltype(_impl_.rate_tp_hits_){0},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
HitFindingInfo::~HitFindingInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void HitFindingInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void HitFindingInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void HitFindingInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.num_tps_sent_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.rate_tp_hits_) -
      reinterpret_cast<char*>(&_impl_.num_tps_sent_)) + sizeof(_impl_.rate_tp_hits_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* HitFindingInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<2, 4, 0, 0, 2> HitFindingInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    4, 24,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967280,  // skipmap
    offsetof(decltype(_table_), field_entries),
    4,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_HitFindingInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    // uint64 num_tps_suppressed_too_long = 4;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(HitFindingInfo, _impl_.num_tps_suppressed_too_long_), 63>(),
     {32, 63, 0, PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_suppressed_too_long_)}},
    // float rate_tp_hits = 1;
    {::_pbi::TcParser::FastF32S1,
     {13, 63, 0, PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.rate_tp_hits_)}},
    // uint64 num_tps_sent = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(HitFindingInfo, _impl_.num_tps_sent_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_sent_)}},
    // uint64 num_tps_send_failed = 3;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(HitFindingInfo, _impl_.num_tps_send_failed_), 63>(),
     {24, 63, 0, PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_send_failed_)}},
  }}, {{
    65535, 65535
  }}, {{
    // float rate_tp_hits = 1;
    {PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.rate_tp_hits_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kFloat)},
    // uint64 num_tps_sent = 2;
    {PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_sent_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_tps_send_failed = 3;
    {PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_send_failed_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 num_tps_suppressed_too_long = 4;
    {PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_suppressed_too_long_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* HitFindingInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // float rate_tp_hits = 1;
  static_assert(sizeof(::uint32_t) == sizeof(float),
                "Code assumes ::uint32_t and float are the same size.");
  float tmp_rate_tp_hits = this->_internal_rate_tp_hits();
  ::uint32_t raw_rate_tp_hits;
  memcpy(&raw_rate_tp_hits, &tmp_rate_tp_hits, sizeof(tmp_rate_tp_hits));
  if (raw_rate_tp_hits != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteFloatToArray(
        1, this->_internal_rate_tp_hits(), target);
  }
 
  // uint64 num_tps_sent = 2;
  if (this->_internal_num_tps_sent() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_num_tps_sent(), target);
  }
 
  // uint64 num_tps_send_failed = 3;
  if (this->_internal_num_tps_send_failed() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        3, this->_internal_num_tps_send_failed(), target);
  }
 
  // uint64 num_tps_suppressed_too_long = 4;
  if (this->_internal_num_tps_suppressed_too_long() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        4, this->_internal_num_tps_suppressed_too_long(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  return target;
}
 
::size_t HitFindingInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 num_tps_sent = 2;
  if (this->_internal_num_tps_sent() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_tps_sent());
  }
 
  // uint64 num_tps_send_failed = 3;
  if (this->_internal_num_tps_send_failed() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_tps_send_failed());
  }
 
  // uint64 num_tps_suppressed_too_long = 4;
  if (this->_internal_num_tps_suppressed_too_long() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_num_tps_suppressed_too_long());
  }
 
  // float rate_tp_hits = 1;
  static_assert(sizeof(::uint32_t) == sizeof(float),
                "Code assumes ::uint32_t and float are the same size.");
  float tmp_rate_tp_hits = this->_internal_rate_tp_hits();
  ::uint32_t raw_rate_tp_hits;
  memcpy(&raw_rate_tp_hits, &tmp_rate_tp_hits, sizeof(tmp_rate_tp_hits));
  if (raw_rate_tp_hits != 0) {
    total_size += 5;
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData HitFindingInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    HitFindingInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*HitFindingInfo::GetClassData() const { return &_class_data_; }
 
 
void HitFindingInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<HitFindingInfo*>(&to_msg);
  auto& from = static_cast<const HitFindingInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_num_tps_sent() != 0) {
    _this->_internal_set_num_tps_sent(from._internal_num_tps_sent());
  }
  if (from._internal_num_tps_send_failed() != 0) {
    _this->_internal_set_num_tps_send_failed(from._internal_num_tps_send_failed());
  }
  if (from._internal_num_tps_suppressed_too_long() != 0) {
    _this->_internal_set_num_tps_suppressed_too_long(from._internal_num_tps_suppressed_too_long());
  }
  static_assert(sizeof(::uint32_t) == sizeof(float),
                "Code assumes ::uint32_t and float are the same size.");
  float tmp_rate_tp_hits = from._internal_rate_tp_hits();
  ::uint32_t raw_rate_tp_hits;
  memcpy(&raw_rate_tp_hits, &tmp_rate_tp_hits, sizeof(tmp_rate_tp_hits));
  if (raw_rate_tp_hits != 0) {
    _this->_internal_set_rate_tp_hits(from._internal_rate_tp_hits());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void HitFindingInfo::CopyFrom(const HitFindingInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.HitFindingInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool HitFindingInfo::IsInitialized() const {
  return true;
}
 
void HitFindingInfo::InternalSwap(HitFindingInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.rate_tp_hits_)
      + sizeof(HitFindingInfo::_impl_.rate_tp_hits_)
      - PROTOBUF_FIELD_OFFSET(HitFindingInfo, _impl_.num_tps_sent_)>(
          reinterpret_cast<char*>(&_impl_.num_tps_sent_),
          reinterpret_cast<char*>(&other->_impl_.num_tps_sent_));
}
 
::google::protobuf::Metadata HitFindingInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[7]);
}
// ===================================================================
 
class TPChannelInfo::_Internal {
 public:
};
 
TPChannelInfo::TPChannelInfo(::google::protobuf::Arena* arena)
    : ::google::protobuf::Message(arena) {
  SharedCtor(arena);
  // @@protoc_insertion_point(arena_constructor:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
}
TPChannelInfo::TPChannelInfo(const TPChannelInfo& from)
    : ::google::protobuf::Message(), _impl_(from._impl_) {
  _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
      from._internal_metadata_);
  // @@protoc_insertion_point(copy_constructor:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
}
inline void TPChannelInfo::SharedCtor(::_pb::Arena* arena) {
  (void)arena;
  new (&_impl_) Impl_{
      decltype(_impl_.channel_id_){::uint64_t{0u}},
      decltype(_impl_.number_of_tps_){::uint64_t{0u}},
      /*decltype(_impl_._cached_size_)*/ {},
  };
}
TPChannelInfo::~TPChannelInfo() {
  // @@protoc_insertion_point(destructor:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
  SharedDtor();
}
inline void TPChannelInfo::SharedDtor() {
  ABSL_DCHECK(GetArenaForAllocation() == nullptr);
}
void TPChannelInfo::SetCachedSize(int size) const {
  _impl_._cached_size_.Set(size);
}
 
PROTOBUF_NOINLINE void TPChannelInfo::Clear() {
// @@protoc_insertion_point(message_clear_start:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  ::memset(&_impl_.channel_id_, 0, static_cast<::size_t>(
      reinterpret_cast<char*>(&_impl_.number_of_tps_) -
      reinterpret_cast<char*>(&_impl_.channel_id_)) + sizeof(_impl_.number_of_tps_));
  _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
}
 
const char* TPChannelInfo::_InternalParse(
    const char* ptr, ::_pbi::ParseContext* ctx) {
  ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
  return ptr;
}
 
 
PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1
const ::_pbi::TcParseTable<1, 2, 0, 0, 2> TPChannelInfo::_table_ = {
  {
    0,  // no _has_bits_
    0, // no _extensions_
    2, 8,  // max_field_number, fast_idx_mask
    offsetof(decltype(_table_), field_lookup_table),
    4294967292,  // skipmap
    offsetof(decltype(_table_), field_entries),
    2,  // num_field_entries
    0,  // num_aux_entries
    offsetof(decltype(_table_), field_names),  // no aux_entries
    &_TPChannelInfo_default_instance_._instance,
    ::_pbi::TcParser::GenericFallback,  // fallback
  }, {{
    // uint64 number_of_tps = 2;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TPChannelInfo, _impl_.number_of_tps_), 63>(),
     {16, 63, 0, PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.number_of_tps_)}},
    // uint64 channel_id = 1;
    {::_pbi::TcParser::SingularVarintNoZag1<::uint64_t, offsetof(TPChannelInfo, _impl_.channel_id_), 63>(),
     {8, 63, 0, PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.channel_id_)}},
  }}, {{
    65535, 65535
  }}, {{
    // uint64 channel_id = 1;
    {PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.channel_id_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
    // uint64 number_of_tps = 2;
    {PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.number_of_tps_), 0, 0,
    (0 | ::_fl::kFcSingular | ::_fl::kUInt64)},
  }},
  // no aux_entries
  {{
  }},
};
 
::uint8_t* TPChannelInfo::_InternalSerialize(
    ::uint8_t* target,
    ::google::protobuf::io::EpsCopyOutputStream* stream) const {
  // @@protoc_insertion_point(serialize_to_array_start:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  ::uint32_t cached_has_bits = 0;
  (void)cached_has_bits;
 
  // uint64 channel_id = 1;
  if (this->_internal_channel_id() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        1, this->_internal_channel_id(), target);
  }
 
  // uint64 number_of_tps = 2;
  if (this->_internal_number_of_tps() != 0) {
    target = stream->EnsureSpace(target);
    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
        2, this->_internal_number_of_tps(), target);
  }
 
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
    target =
        ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
            _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
  }
  // @@protoc_insertion_point(serialize_to_array_end:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  return target;
}
 
::size_t TPChannelInfo::ByteSizeLong() const {
// @@protoc_insertion_point(message_byte_size_start:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  ::size_t total_size = 0;
 
  ::uint32_t cached_has_bits = 0;
  // Prevent compiler warnings about cached_has_bits being unused
  (void) cached_has_bits;
 
  // uint64 channel_id = 1;
  if (this->_internal_channel_id() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_channel_id());
  }
 
  // uint64 number_of_tps = 2;
  if (this->_internal_number_of_tps() != 0) {
    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
        this->_internal_number_of_tps());
  }
 
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
}
 
const ::google::protobuf::Message::ClassData TPChannelInfo::_class_data_ = {
    ::google::protobuf::Message::CopyWithSourceCheck,
    TPChannelInfo::MergeImpl
};
const ::google::protobuf::Message::ClassData*TPChannelInfo::GetClassData() const { return &_class_data_; }
 
 
void TPChannelInfo::MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg) {
  auto* const _this = static_cast<TPChannelInfo*>(&to_msg);
  auto& from = static_cast<const TPChannelInfo&>(from_msg);
  // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  ABSL_DCHECK_NE(&from, _this);
  ::uint32_t cached_has_bits = 0;
  (void) cached_has_bits;
 
  if (from._internal_channel_id() != 0) {
    _this->_internal_set_channel_id(from._internal_channel_id());
  }
  if (from._internal_number_of_tps() != 0) {
    _this->_internal_set_number_of_tps(from._internal_number_of_tps());
  }
  _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
}
 
void TPChannelInfo::CopyFrom(const TPChannelInfo& from) {
// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.datahandlinglibs.opmon.TPChannelInfo)
  if (&from == this) return;
  Clear();
  MergeFrom(from);
}
 
PROTOBUF_NOINLINE bool TPChannelInfo::IsInitialized() const {
  return true;
}
 
void TPChannelInfo::InternalSwap(TPChannelInfo* other) {
  using std::swap;
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
  ::google::protobuf::internal::memswap<
      PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.number_of_tps_)
      + sizeof(TPChannelInfo::_impl_.number_of_tps_)
      - PROTOBUF_FIELD_OFFSET(TPChannelInfo, _impl_.channel_id_)>(
          reinterpret_cast<char*>(&_impl_.channel_id_),
          reinterpret_cast<char*>(&other->_impl_.channel_id_));
}
 
::google::protobuf::Metadata TPChannelInfo::GetMetadata() const {
  return ::_pbi::AssignDescriptors(
      &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_getter, &descriptor_table_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto_once,
      file_level_metadata_datahandlinglibs_2fopmon_2fdatahandling_5finfo_2eproto[8]);
}
// @@protoc_insertion_point(namespace_scope)
}  // namespace opmon
}  // namespace datahandlinglibs
}  // namespace dunedaq
namespace google {
namespace protobuf {
}  // namespace protobuf
}  // namespace google
// @@protoc_insertion_point(global_scope)
#include "google/protobuf/port_undef.inc"