4#ifndef GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fTPStreamWriter_2eproto_2epb_2eh
5#define GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fTPStreamWriter_2eproto_2epb_2eh
11#include "google/protobuf/port_def.inc"
12#if PROTOBUF_VERSION < 4024000
13#error "This file was generated by a newer version of protoc which is"
14#error "incompatible with your Protocol Buffer headers. Please update"
18#if 4024004 < PROTOBUF_MIN_PROTOC_VERSION
19#error "This file was generated by an older version of protoc which is"
20#error "incompatible with your Protocol Buffer headers. Please"
21#error "regenerate this file with a newer version of protoc."
23#include "google/protobuf/port_undef.inc"
24#include "google/protobuf/io/coded_stream.h"
25#include "google/protobuf/arena.h"
26#include "google/protobuf/arenastring.h"
27#include "google/protobuf/generated_message_tctable_decl.h"
28#include "google/protobuf/generated_message_util.h"
29#include "google/protobuf/metadata_lite.h"
30#include "google/protobuf/generated_message_reflection.h"
31#include "google/protobuf/message.h"
32#include "google/protobuf/repeated_field.h"
33#include "google/protobuf/extension_set.h"
34#include "google/protobuf/unknown_field_set.h"
38#include "google/protobuf/port_def.inc"
40#define PROTOBUF_INTERNAL_EXPORT_dfmodules_2fopmon_2fTPStreamWriter_2eproto
54extern const ::google::protobuf::internal::DescriptorTable
59class TPStreamWriterInfo;
60struct TPStreamWriterInfoDefaultTypeInternal;
80 public ::google::protobuf::Message {
84 template<
typename =
void>
85 explicit PROTOBUF_CONSTEXPR
TPStreamWriterInfo(::google::protobuf::internal::ConstantInitialized);
90 *
this = ::std::move(from);
98 if (
this == &from)
return *
this;
99 if (GetOwningArena() == from.GetOwningArena()
100 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
101 && GetOwningArena() !=
nullptr
112 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
115 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
141 if (other ==
this)
return;
142 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
143 if (GetOwningArena() !=
nullptr &&
144 GetOwningArena() == other->GetOwningArena()) {
146 if (GetOwningArena() == other->GetOwningArena()) {
150 ::google::protobuf::internal::GenericSwap(
this, other);
154 if (other ==
this)
return;
155 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
162 return CreateMaybeMessage<TPStreamWriterInfo>(arena);
164 using ::google::protobuf::Message::CopyFrom;
166 using ::google::protobuf::Message::MergeFrom;
171 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
173 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
177 const
char*
_InternalParse(const
char* ptr, ::
google::protobuf::internal::ParseContext* ctx) final;
179 ::uint8_t* target, ::
google::protobuf::io::EpsCopyOutputStream* stream) const final;
183 void SharedCtor(::google::protobuf::Arena* arena);
189 friend class ::google::protobuf::internal::AnyMetadata;
191 return "dunedaq.dfmodules.opmon.TPStreamWriterInfo";
198 const ::google::protobuf::Message::ClassData*
GetClassData() const final;
311 friend class ::google::protobuf::internal::TcParser;
312 static const ::google::protobuf::internal::TcParseTable<3, 9, 0, 0, 2>
_table_;
313 template <
typename T>
friend class ::google::protobuf::Arena::InternalHelper;
327 PROTOBUF_TSAN_DECLARE_MEMBER
330 friend struct ::TableStruct_dfmodules_2fopmon_2fTPStreamWriter_2eproto;
342#pragma GCC diagnostic push
343#pragma GCC diagnostic ignored "-Wstrict-aliasing"
362 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
366 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
384 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
388 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
406 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
410 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
428 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
432 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
450 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
454 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
472 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
476 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
494 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
498 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
516 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
520 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
538 PROTOBUF_TSAN_READ(&
_impl_._tsan_detect_race);
542 PROTOBUF_TSAN_WRITE(&
_impl_._tsan_detect_race);
548#pragma GCC diagnostic pop
559#include "google/protobuf/port_undef.inc"
const ::google::protobuf::internal::DescriptorTable descriptor_table_dfmodules_2fopmon_2fTPStreamWriter_2eproto
void clear_timeslices_written()
::size_t ByteSizeLong() const final
void CopyFrom(const TPStreamWriterInfo &from)
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
::uint64_t tpsets_with_tps_received() const
void UnsafeArenaSwap(TPStreamWriterInfo *other)
static constexpr int kIndexInFileMessages
void clear_heartbeat_tpsets_received()
void MergeFrom(const TPStreamWriterInfo &from)
::uint64_t bytes_output() const
void _internal_set_timeslices_written(::uint64_t value)
::uint64_t _internal_timeslices_written() const
void set_tardy_timeslice_max_seconds(::uint64_t value)
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
void clear_bytes_output()
void InternalArenaConstructable_
void set_tps_received(::uint64_t value)
void InternalSwap(TPStreamWriterInfo *other)
int GetCachedSize() const final
::absl::string_view FullMessageName()
void _internal_set_tardy_timeslice_max_seconds(::uint64_t value)
void _internal_set_tps_received(::uint64_t value)
~TPStreamWriterInfo() override
::uint64_t _internal_tardy_timeslice_max_seconds() const
void set_bytes_output(::uint64_t value)
void Swap(TPStreamWriterInfo *other)
static const ClassData _class_data_
::uint64_t _internal_tpsets_with_tps_received() const
void clear_total_tps_received()
void _internal_set_bytes_output(::uint64_t value)
void clear_tardy_timeslice_max_seconds()
void clear_tpsets_with_tps_received()
::uint64_t timeslices_written() const
static const TPStreamWriterInfo * internal_default_instance()
::uint64_t total_tps_received() const
static const ::google::protobuf::Reflection * GetReflection()
::uint64_t total_tps_written() const
void set_timeslices_written(::uint64_t value)
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields()
::uint8_t * _InternalSerialize(::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
static const ::google::protobuf::internal::TcParseTable< 3, 9, 0, 0, 2 > _table_
void set_tpsets_with_tps_received(::uint64_t value)
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
void _internal_set_tps_written(::uint64_t value)
::uint64_t tardy_timeslice_max_seconds() const
void clear_tps_received()
::uint64_t _internal_total_tps_received() const
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
@ kTpsetsWithTpsReceivedFieldNumber
@ kTardyTimesliceMaxSecondsFieldNumber
@ kTpsReceivedFieldNumber
@ kTotalTpsWrittenFieldNumber
@ kTotalTpsReceivedFieldNumber
@ kBytesOutputFieldNumber
@ kHeartbeatTpsetsReceivedFieldNumber
@ kTimeslicesWrittenFieldNumber
void SharedCtor(::google::protobuf::Arena *arena)
static const ::google::protobuf::Descriptor * descriptor()
void SetCachedSize(int size) const final
TPStreamWriterInfo & operator=(const TPStreamWriterInfo &from)
TPStreamWriterInfo * New(::google::protobuf::Arena *arena=nullptr) const final
void set_total_tps_written(::uint64_t value)
::uint64_t _internal_total_tps_written() const
void set_tps_written(::uint64_t value)
TPStreamWriterInfo & operator=(TPStreamWriterInfo &&from) noexcept
const ::google::protobuf::Message::ClassData * GetClassData() const final
void _internal_set_tpsets_with_tps_received(::uint64_t value)
::uint64_t heartbeat_tpsets_received() const
::uint64_t tps_received() const
::uint64_t tps_written() const
::uint64_t _internal_tps_written() const
void _internal_set_total_tps_written(::uint64_t value)
TPStreamWriterInfo(TPStreamWriterInfo &&from) noexcept
void set_heartbeat_tpsets_received(::uint64_t value)
::uint64_t _internal_heartbeat_tpsets_received() const
friend void swap(TPStreamWriterInfo &a, TPStreamWriterInfo &b)
static const ::google::protobuf::Descriptor * GetDescriptor()
static const TPStreamWriterInfo & default_instance()
::google::protobuf::Metadata GetMetadata() const final
void clear_total_tps_written()
PROTOBUF_CONSTEXPR TPStreamWriterInfo(::google::protobuf::internal::ConstantInitialized)
void DestructorSkippable_
void _internal_set_heartbeat_tpsets_received(::uint64_t value)
bool IsInitialized() const final
void set_total_tps_received(::uint64_t value)
::uint64_t _internal_tps_received() const
::uint64_t _internal_bytes_output() const
void _internal_set_total_tps_received(::uint64_t value)
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPStreamWriterInfoDefaultTypeInternal _TPStreamWriterInfo_default_instance_
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
static const ::uint32_t offsets[]
::uint64_t total_tps_written_
::uint64_t tardy_timeslice_max_seconds_
::uint64_t tpsets_with_tps_received_
::uint64_t total_tps_received_
::uint64_t heartbeat_tpsets_received_
::uint64_t timeslices_written_
mutable::google::protobuf::internal::CachedSize _cached_size_