DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
TPStreamWriter.pb.h
Go to the documentation of this file.
1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: dfmodules/opmon/TPStreamWriter.proto
3
4#ifndef GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fTPStreamWriter_2eproto_2epb_2eh
5#define GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fTPStreamWriter_2eproto_2epb_2eh
6
7#include <limits>
8#include <string>
9#include <type_traits>
10
11#include "google/protobuf/port_def.inc"
12#if PROTOBUF_VERSION < 4024000
13#error "This file was generated by a newer version of protoc which is"
14#error "incompatible with your Protocol Buffer headers. Please update"
15#error "your headers."
16#endif // PROTOBUF_VERSION
17
18#if 4024004 < PROTOBUF_MIN_PROTOC_VERSION
19#error "This file was generated by an older version of protoc which is"
20#error "incompatible with your Protocol Buffer headers. Please"
21#error "regenerate this file with a newer version of protoc."
22#endif // PROTOBUF_MIN_PROTOC_VERSION
23#include "google/protobuf/port_undef.inc"
24#include "google/protobuf/io/coded_stream.h"
25#include "google/protobuf/arena.h"
26#include "google/protobuf/arenastring.h"
27#include "google/protobuf/generated_message_tctable_decl.h"
28#include "google/protobuf/generated_message_util.h"
29#include "google/protobuf/metadata_lite.h"
30#include "google/protobuf/generated_message_reflection.h"
31#include "google/protobuf/message.h"
32#include "google/protobuf/repeated_field.h" // IWYU pragma: export
33#include "google/protobuf/extension_set.h" // IWYU pragma: export
34#include "google/protobuf/unknown_field_set.h"
35// @@protoc_insertion_point(includes)
36
37// Must be included last.
38#include "google/protobuf/port_def.inc"
39
40#define PROTOBUF_INTERNAL_EXPORT_dfmodules_2fopmon_2fTPStreamWriter_2eproto
41
42namespace google {
43namespace protobuf {
44namespace internal {
45class AnyMetadata;
46} // namespace internal
47} // namespace protobuf
48} // namespace google
49
50// Internal implementation detail -- do not use these members.
54extern const ::google::protobuf::internal::DescriptorTable
56namespace dunedaq {
57namespace dfmodules {
58namespace opmon {
59class TPStreamWriterInfo;
60struct TPStreamWriterInfoDefaultTypeInternal;
61extern TPStreamWriterInfoDefaultTypeInternal _TPStreamWriterInfo_default_instance_;
62} // namespace opmon
63} // namespace dfmodules
64} // namespace dunedaq
65namespace google {
66namespace protobuf {
67} // namespace protobuf
68} // namespace google
69
70namespace dunedaq {
71namespace dfmodules {
72namespace opmon {
73
74// ===================================================================
75
76
77// -------------------------------------------------------------------
78
79class TPStreamWriterInfo final :
80 public ::google::protobuf::Message /* @@protoc_insertion_point(class_definition:dunedaq.dfmodules.opmon.TPStreamWriterInfo) */ {
81 public:
83 ~TPStreamWriterInfo() override;
84 template<typename = void>
85 explicit PROTOBUF_CONSTEXPR TPStreamWriterInfo(::google::protobuf::internal::ConstantInitialized);
86
90 *this = ::std::move(from);
91 }
92
94 CopyFrom(from);
95 return *this;
96 }
98 if (this == &from) return *this;
99 if (GetOwningArena() == from.GetOwningArena()
100 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
101 && GetOwningArena() != nullptr
102 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
103 ) {
104 InternalSwap(&from);
105 } else {
106 CopyFrom(from);
107 }
108 return *this;
109 }
110
111 inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
112 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
113 }
114 inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
115 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
116 }
117
118 static const ::google::protobuf::Descriptor* descriptor() {
119 return GetDescriptor();
120 }
121 static const ::google::protobuf::Descriptor* GetDescriptor() {
122 return default_instance().GetMetadata().descriptor;
123 }
124 static const ::google::protobuf::Reflection* GetReflection() {
125 return default_instance().GetMetadata().reflection;
126 }
129 }
131 return reinterpret_cast<const TPStreamWriterInfo*>(
133 }
134 static constexpr int kIndexInFileMessages =
135 0;
136
138 a.Swap(&b);
139 }
140 inline void Swap(TPStreamWriterInfo* other) {
141 if (other == this) return;
142 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
143 if (GetOwningArena() != nullptr &&
144 GetOwningArena() == other->GetOwningArena()) {
145 #else // PROTOBUF_FORCE_COPY_IN_SWAP
146 if (GetOwningArena() == other->GetOwningArena()) {
147 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
148 InternalSwap(other);
149 } else {
150 ::google::protobuf::internal::GenericSwap(this, other);
151 }
152 }
154 if (other == this) return;
155 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
156 InternalSwap(other);
157 }
158
159 // implements Message ----------------------------------------------
160
161 TPStreamWriterInfo* New(::google::protobuf::Arena* arena = nullptr) const final {
162 return CreateMaybeMessage<TPStreamWriterInfo>(arena);
163 }
164 using ::google::protobuf::Message::CopyFrom;
165 void CopyFrom(const TPStreamWriterInfo& from);
166 using ::google::protobuf::Message::MergeFrom;
167 void MergeFrom( const TPStreamWriterInfo& from) {
169 }
170 private:
171 static void MergeImpl(::google::protobuf::Message& to_msg, const ::google::protobuf::Message& from_msg);
172 public:
173 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
174 bool IsInitialized() const final;
175
176 ::size_t ByteSizeLong() const final;
177 const char* _InternalParse(const char* ptr, ::google::protobuf::internal::ParseContext* ctx) final;
178 ::uint8_t* _InternalSerialize(
179 ::uint8_t* target, ::google::protobuf::io::EpsCopyOutputStream* stream) const final;
180 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
181
182 private:
183 void SharedCtor(::google::protobuf::Arena* arena);
184 void SharedDtor();
185 void SetCachedSize(int size) const final;
186 void InternalSwap(TPStreamWriterInfo* other);
187
188 private:
189 friend class ::google::protobuf::internal::AnyMetadata;
190 static ::absl::string_view FullMessageName() {
191 return "dunedaq.dfmodules.opmon.TPStreamWriterInfo";
192 }
193 protected:
194 explicit TPStreamWriterInfo(::google::protobuf::Arena* arena);
195 public:
196
197 static const ClassData _class_data_;
198 const ::google::protobuf::Message::ClassData*GetClassData() const final;
199
200 ::google::protobuf::Metadata GetMetadata() const final;
201
202 // nested types ----------------------------------------------------
203
204 // accessors -------------------------------------------------------
205
206 enum : int {
216 };
217 // uint64 heartbeat_tpsets_received = 1;
219 ::uint64_t heartbeat_tpsets_received() const;
220 void set_heartbeat_tpsets_received(::uint64_t value);
221
222 private:
223 ::uint64_t _internal_heartbeat_tpsets_received() const;
224 void _internal_set_heartbeat_tpsets_received(::uint64_t value);
225
226 public:
227 // uint64 tpsets_with_tps_received = 2;
229 ::uint64_t tpsets_with_tps_received() const;
230 void set_tpsets_with_tps_received(::uint64_t value);
231
232 private:
233 ::uint64_t _internal_tpsets_with_tps_received() const;
234 void _internal_set_tpsets_with_tps_received(::uint64_t value);
235
236 public:
237 // uint64 tps_received = 11;
238 void clear_tps_received() ;
239 ::uint64_t tps_received() const;
240 void set_tps_received(::uint64_t value);
241
242 private:
243 ::uint64_t _internal_tps_received() const;
244 void _internal_set_tps_received(::uint64_t value);
245
246 public:
247 // uint64 tps_written = 12;
248 void clear_tps_written() ;
249 ::uint64_t tps_written() const;
250 void set_tps_written(::uint64_t value);
251
252 private:
253 ::uint64_t _internal_tps_written() const;
254 void _internal_set_tps_written(::uint64_t value);
255
256 public:
257 // uint64 total_tps_received = 16;
259 ::uint64_t total_tps_received() const;
260 void set_total_tps_received(::uint64_t value);
261
262 private:
263 ::uint64_t _internal_total_tps_received() const;
264 void _internal_set_total_tps_received(::uint64_t value);
265
266 public:
267 // uint64 total_tps_written = 17;
269 ::uint64_t total_tps_written() const;
270 void set_total_tps_written(::uint64_t value);
271
272 private:
273 ::uint64_t _internal_total_tps_written() const;
274 void _internal_set_total_tps_written(::uint64_t value);
275
276 public:
277 // uint64 tardy_timeslice_max_seconds = 21;
279 ::uint64_t tardy_timeslice_max_seconds() const;
280 void set_tardy_timeslice_max_seconds(::uint64_t value);
281
282 private:
283 ::uint64_t _internal_tardy_timeslice_max_seconds() const;
284 void _internal_set_tardy_timeslice_max_seconds(::uint64_t value);
285
286 public:
287 // uint64 timeslices_written = 31;
289 ::uint64_t timeslices_written() const;
290 void set_timeslices_written(::uint64_t value);
291
292 private:
293 ::uint64_t _internal_timeslices_written() const;
294 void _internal_set_timeslices_written(::uint64_t value);
295
296 public:
297 // uint64 bytes_output = 32;
298 void clear_bytes_output() ;
299 ::uint64_t bytes_output() const;
300 void set_bytes_output(::uint64_t value);
301
302 private:
303 ::uint64_t _internal_bytes_output() const;
304 void _internal_set_bytes_output(::uint64_t value);
305
306 public:
307 // @@protoc_insertion_point(class_scope:dunedaq.dfmodules.opmon.TPStreamWriterInfo)
308 private:
309 class _Internal;
310
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;
316 struct Impl_ {
319 ::uint64_t tps_received_;
320 ::uint64_t tps_written_;
325 ::uint64_t bytes_output_;
326 mutable ::google::protobuf::internal::CachedSize _cached_size_;
327 PROTOBUF_TSAN_DECLARE_MEMBER
328 };
329 union { Impl_ _impl_; };
330 friend struct ::TableStruct_dfmodules_2fopmon_2fTPStreamWriter_2eproto;
331};
332
333// ===================================================================
334
335
336
337
338// ===================================================================
339
340
341#ifdef __GNUC__
342#pragma GCC diagnostic push
343#pragma GCC diagnostic ignored "-Wstrict-aliasing"
344#endif // __GNUC__
345// -------------------------------------------------------------------
346
347// TPStreamWriterInfo
348
349// uint64 heartbeat_tpsets_received = 1;
354 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.heartbeat_tpsets_received)
356}
359 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.heartbeat_tpsets_received)
360}
362 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
364}
366 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
367 ;
369}
370
371// uint64 tpsets_with_tps_received = 2;
376 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tpsets_with_tps_received)
378}
381 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tpsets_with_tps_received)
382}
384 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
386}
388 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
389 ;
391}
392
393// uint64 tps_received = 11;
395 _impl_.tps_received_ = ::uint64_t{0u};
396}
397inline ::uint64_t TPStreamWriterInfo::tps_received() const {
398 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_received)
399 return _internal_tps_received();
400}
401inline void TPStreamWriterInfo::set_tps_received(::uint64_t value) {
403 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_received)
404}
406 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
407 return _impl_.tps_received_;
408}
410 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
411 ;
412 _impl_.tps_received_ = value;
413}
414
415// uint64 tps_written = 12;
417 _impl_.tps_written_ = ::uint64_t{0u};
418}
419inline ::uint64_t TPStreamWriterInfo::tps_written() const {
420 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_written)
421 return _internal_tps_written();
422}
423inline void TPStreamWriterInfo::set_tps_written(::uint64_t value) {
425 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_written)
426}
428 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
429 return _impl_.tps_written_;
430}
432 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
433 ;
434 _impl_.tps_written_ = value;
435}
436
437// uint64 total_tps_received = 16;
441inline ::uint64_t TPStreamWriterInfo::total_tps_received() const {
442 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_received)
444}
445inline void TPStreamWriterInfo::set_total_tps_received(::uint64_t value) {
447 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_received)
448}
450 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
452}
454 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
455 ;
457}
458
459// uint64 total_tps_written = 17;
463inline ::uint64_t TPStreamWriterInfo::total_tps_written() const {
464 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_written)
466}
467inline void TPStreamWriterInfo::set_total_tps_written(::uint64_t value) {
469 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_written)
470}
472 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
474}
476 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
477 ;
479}
480
481// uint64 tardy_timeslice_max_seconds = 21;
486 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tardy_timeslice_max_seconds)
488}
491 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tardy_timeslice_max_seconds)
492}
494 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
496}
498 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
499 ;
501}
502
503// uint64 timeslices_written = 31;
507inline ::uint64_t TPStreamWriterInfo::timeslices_written() const {
508 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.timeslices_written)
510}
511inline void TPStreamWriterInfo::set_timeslices_written(::uint64_t value) {
513 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.timeslices_written)
514}
516 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
518}
520 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
521 ;
523}
524
525// uint64 bytes_output = 32;
527 _impl_.bytes_output_ = ::uint64_t{0u};
528}
529inline ::uint64_t TPStreamWriterInfo::bytes_output() const {
530 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.bytes_output)
531 return _internal_bytes_output();
532}
533inline void TPStreamWriterInfo::set_bytes_output(::uint64_t value) {
535 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.bytes_output)
536}
538 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
539 return _impl_.bytes_output_;
540}
542 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
543 ;
544 _impl_.bytes_output_ = value;
545}
546
547#ifdef __GNUC__
548#pragma GCC diagnostic pop
549#endif // __GNUC__
550
551// @@protoc_insertion_point(namespace_scope)
552} // namespace opmon
553} // namespace dfmodules
554} // namespace dunedaq
555
556
557// @@protoc_insertion_point(global_scope)
558
559#include "google/protobuf/port_undef.inc"
560
561#endif // GOOGLE_PROTOBUF_INCLUDED_dfmodules_2fopmon_2fTPStreamWriter_2eproto_2epb_2eh
const ::google::protobuf::internal::DescriptorTable descriptor_table_dfmodules_2fopmon_2fTPStreamWriter_2eproto
void CopyFrom(const TPStreamWriterInfo &from)
const ::google::protobuf::UnknownFieldSet & unknown_fields() const
void UnsafeArenaSwap(TPStreamWriterInfo *other)
void MergeFrom(const TPStreamWriterInfo &from)
const char * _InternalParse(const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
void _internal_set_tardy_timeslice_max_seconds(::uint64_t value)
static const TPStreamWriterInfo * internal_default_instance()
static const ::google::protobuf::Reflection * GetReflection()
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_
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
void SharedCtor(::google::protobuf::Arena *arena)
static const ::google::protobuf::Descriptor * descriptor()
TPStreamWriterInfo & operator=(const TPStreamWriterInfo &from)
TPStreamWriterInfo * New(::google::protobuf::Arena *arena=nullptr) const final
TPStreamWriterInfo & operator=(TPStreamWriterInfo &&from) noexcept
const ::google::protobuf::Message::ClassData * GetClassData() const final
void _internal_set_tpsets_with_tps_received(::uint64_t value)
TPStreamWriterInfo(TPStreamWriterInfo &&from) noexcept
friend void swap(TPStreamWriterInfo &a, TPStreamWriterInfo &b)
static const ::google::protobuf::Descriptor * GetDescriptor()
static const TPStreamWriterInfo & default_instance()
::google::protobuf::Metadata GetMetadata() const final
PROTOBUF_CONSTEXPR TPStreamWriterInfo(::google::protobuf::internal::ConstantInitialized)
void _internal_set_heartbeat_tpsets_received(::uint64_t value)
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 TPStreamWriterInfoDefaultTypeInternal _TPStreamWriterInfo_default_instance_
Including Qt Headers.
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
mutable::google::protobuf::internal::CachedSize _cached_size_