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 {
218 };
219 // uint64 heartbeat_tpsets_received = 1;
221 ::uint64_t heartbeat_tpsets_received() const;
222 void set_heartbeat_tpsets_received(::uint64_t value);
223
224 private:
225 ::uint64_t _internal_heartbeat_tpsets_received() const;
226 void _internal_set_heartbeat_tpsets_received(::uint64_t value);
227
228 public:
229 // uint64 tpsets_with_tps_received = 2;
231 ::uint64_t tpsets_with_tps_received() const;
232 void set_tpsets_with_tps_received(::uint64_t value);
233
234 private:
235 ::uint64_t _internal_tpsets_with_tps_received() const;
236 void _internal_set_tpsets_with_tps_received(::uint64_t value);
237
238 public:
239 // uint64 tps_received = 11;
240 void clear_tps_received() ;
241 ::uint64_t tps_received() const;
242 void set_tps_received(::uint64_t value);
243
244 private:
245 ::uint64_t _internal_tps_received() const;
246 void _internal_set_tps_received(::uint64_t value);
247
248 public:
249 // uint64 tps_written = 12;
250 void clear_tps_written() ;
251 ::uint64_t tps_written() const;
252 void set_tps_written(::uint64_t value);
253
254 private:
255 ::uint64_t _internal_tps_written() const;
256 void _internal_set_tps_written(::uint64_t value);
257
258 public:
259 // uint64 tps_discarded = 13;
260 void clear_tps_discarded() ;
261 ::uint64_t tps_discarded() const;
262 void set_tps_discarded(::uint64_t value);
263
264 private:
265 ::uint64_t _internal_tps_discarded() const;
266 void _internal_set_tps_discarded(::uint64_t value);
267
268 public:
269 // uint64 total_tps_received = 16;
271 ::uint64_t total_tps_received() const;
272 void set_total_tps_received(::uint64_t value);
273
274 private:
275 ::uint64_t _internal_total_tps_received() const;
276 void _internal_set_total_tps_received(::uint64_t value);
277
278 public:
279 // uint64 total_tps_written = 17;
281 ::uint64_t total_tps_written() const;
282 void set_total_tps_written(::uint64_t value);
283
284 private:
285 ::uint64_t _internal_total_tps_written() const;
286 void _internal_set_total_tps_written(::uint64_t value);
287
288 public:
289 // uint64 total_tps_discarded = 18;
291 ::uint64_t total_tps_discarded() const;
292 void set_total_tps_discarded(::uint64_t value);
293
294 private:
295 ::uint64_t _internal_total_tps_discarded() const;
296 void _internal_set_total_tps_discarded(::uint64_t value);
297
298 public:
299 // uint64 tardy_timeslice_max_seconds = 21;
301 ::uint64_t tardy_timeslice_max_seconds() const;
302 void set_tardy_timeslice_max_seconds(::uint64_t value);
303
304 private:
305 ::uint64_t _internal_tardy_timeslice_max_seconds() const;
306 void _internal_set_tardy_timeslice_max_seconds(::uint64_t value);
307
308 public:
309 // uint64 timeslices_written = 31;
311 ::uint64_t timeslices_written() const;
312 void set_timeslices_written(::uint64_t value);
313
314 private:
315 ::uint64_t _internal_timeslices_written() const;
316 void _internal_set_timeslices_written(::uint64_t value);
317
318 public:
319 // uint64 bytes_output = 32;
320 void clear_bytes_output() ;
321 ::uint64_t bytes_output() const;
322 void set_bytes_output(::uint64_t value);
323
324 private:
325 ::uint64_t _internal_bytes_output() const;
326 void _internal_set_bytes_output(::uint64_t value);
327
328 public:
329 // @@protoc_insertion_point(class_scope:dunedaq.dfmodules.opmon.TPStreamWriterInfo)
330 private:
331 class _Internal;
332
333 friend class ::google::protobuf::internal::TcParser;
334 static const ::google::protobuf::internal::TcParseTable<4, 11, 0, 0, 2> _table_;
335 template <typename T> friend class ::google::protobuf::Arena::InternalHelper;
338 struct Impl_ {
341 ::uint64_t tps_received_;
342 ::uint64_t tps_written_;
343 ::uint64_t tps_discarded_;
349 ::uint64_t bytes_output_;
350 mutable ::google::protobuf::internal::CachedSize _cached_size_;
351 PROTOBUF_TSAN_DECLARE_MEMBER
352 };
353 union { Impl_ _impl_; };
354 friend struct ::TableStruct_dfmodules_2fopmon_2fTPStreamWriter_2eproto;
355};
356
357// ===================================================================
358
359
360
361
362// ===================================================================
363
364
365#ifdef __GNUC__
366#pragma GCC diagnostic push
367#pragma GCC diagnostic ignored "-Wstrict-aliasing"
368#endif // __GNUC__
369// -------------------------------------------------------------------
370
371// TPStreamWriterInfo
372
373// uint64 heartbeat_tpsets_received = 1;
378 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.heartbeat_tpsets_received)
380}
383 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.heartbeat_tpsets_received)
384}
386 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
388}
390 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
391 ;
393}
394
395// uint64 tpsets_with_tps_received = 2;
400 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tpsets_with_tps_received)
402}
405 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tpsets_with_tps_received)
406}
408 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
410}
412 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
413 ;
415}
416
417// uint64 tps_received = 11;
419 _impl_.tps_received_ = ::uint64_t{0u};
420}
421inline ::uint64_t TPStreamWriterInfo::tps_received() const {
422 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_received)
423 return _internal_tps_received();
424}
425inline void TPStreamWriterInfo::set_tps_received(::uint64_t value) {
427 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_received)
428}
430 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
431 return _impl_.tps_received_;
432}
434 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
435 ;
436 _impl_.tps_received_ = value;
437}
438
439// uint64 tps_written = 12;
441 _impl_.tps_written_ = ::uint64_t{0u};
442}
443inline ::uint64_t TPStreamWriterInfo::tps_written() const {
444 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_written)
445 return _internal_tps_written();
446}
447inline void TPStreamWriterInfo::set_tps_written(::uint64_t value) {
449 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_written)
450}
452 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
453 return _impl_.tps_written_;
454}
456 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
457 ;
458 _impl_.tps_written_ = value;
459}
460
461// uint64 tps_discarded = 13;
463 _impl_.tps_discarded_ = ::uint64_t{0u};
464}
465inline ::uint64_t TPStreamWriterInfo::tps_discarded() const {
466 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_discarded)
468}
469inline void TPStreamWriterInfo::set_tps_discarded(::uint64_t value) {
471 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tps_discarded)
472}
474 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
475 return _impl_.tps_discarded_;
476}
478 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
479 ;
480 _impl_.tps_discarded_ = value;
481}
482
483// uint64 total_tps_received = 16;
487inline ::uint64_t TPStreamWriterInfo::total_tps_received() const {
488 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_received)
490}
491inline void TPStreamWriterInfo::set_total_tps_received(::uint64_t value) {
493 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_received)
494}
496 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
498}
500 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
501 ;
503}
504
505// uint64 total_tps_written = 17;
509inline ::uint64_t TPStreamWriterInfo::total_tps_written() const {
510 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_written)
512}
513inline void TPStreamWriterInfo::set_total_tps_written(::uint64_t value) {
515 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_written)
516}
518 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
520}
522 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
523 ;
525}
526
527// uint64 total_tps_discarded = 18;
532 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_discarded)
534}
535inline void TPStreamWriterInfo::set_total_tps_discarded(::uint64_t value) {
537 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.total_tps_discarded)
538}
540 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
542}
544 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
545 ;
547}
548
549// uint64 tardy_timeslice_max_seconds = 21;
554 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tardy_timeslice_max_seconds)
556}
559 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.tardy_timeslice_max_seconds)
560}
562 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
564}
566 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
567 ;
569}
570
571// uint64 timeslices_written = 31;
575inline ::uint64_t TPStreamWriterInfo::timeslices_written() const {
576 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.timeslices_written)
578}
579inline void TPStreamWriterInfo::set_timeslices_written(::uint64_t value) {
581 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.timeslices_written)
582}
584 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
586}
588 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
589 ;
591}
592
593// uint64 bytes_output = 32;
595 _impl_.bytes_output_ = ::uint64_t{0u};
596}
597inline ::uint64_t TPStreamWriterInfo::bytes_output() const {
598 // @@protoc_insertion_point(field_get:dunedaq.dfmodules.opmon.TPStreamWriterInfo.bytes_output)
599 return _internal_bytes_output();
600}
601inline void TPStreamWriterInfo::set_bytes_output(::uint64_t value) {
603 // @@protoc_insertion_point(field_set:dunedaq.dfmodules.opmon.TPStreamWriterInfo.bytes_output)
604}
606 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
607 return _impl_.bytes_output_;
608}
610 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
611 ;
612 _impl_.bytes_output_ = value;
613}
614
615#ifdef __GNUC__
616#pragma GCC diagnostic pop
617#endif // __GNUC__
618
619// @@protoc_insertion_point(namespace_scope)
620} // namespace opmon
621} // namespace dfmodules
622} // namespace dunedaq
623
624
625// @@protoc_insertion_point(global_scope)
626
627#include "google/protobuf/port_undef.inc"
628
629#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 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::internal::TcParseTable< 4, 11, 0, 0, 2 > _table_
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_
The DUNE-DAQ namespace.
Definition DataStore.hpp:57
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size
mutable::google::protobuf::internal::CachedSize _cached_size_