DUNE-DAQ
DUNE Trigger and Data Acquisition software
Loading...
Searching...
No Matches
dunedaq::asiolibs::opmon::SocketWriterStats Class Referencefinal

#include <SocketWriterModule.pb.h>

Inheritance diagram for dunedaq::asiolibs::opmon::SocketWriterStats:
[legend]
Collaboration diagram for dunedaq::asiolibs::opmon::SocketWriterStats:
[legend]

Classes

class  _Internal
 
struct  Impl_
 

Public Types

enum  : int {
  kSumPayloadsFieldNumber = 1 , kNumPayloadsFieldNumber = 2 , kSumBytesFieldNumber = 3 , kNumDataInputTimeoutsFieldNumber = 4 ,
  kRatePayloadsConsumedFieldNumber = 5
}
 

Public Member Functions

 SocketWriterStats ()
 
 ~SocketWriterStats () override
 
template<typename = void>
PROTOBUF_CONSTEXPR SocketWriterStats (::google::protobuf::internal::ConstantInitialized)
 
 SocketWriterStats (const SocketWriterStats &from)
 
 SocketWriterStats (SocketWriterStats &&from) noexcept
 
SocketWriterStatsoperator= (const SocketWriterStats &from)
 
SocketWriterStatsoperator= (SocketWriterStats &&from) noexcept
 
const ::google::protobuf::UnknownFieldSet & unknown_fields () const
 
inline ::google::protobuf::UnknownFieldSet * mutable_unknown_fields ()
 
void Swap (SocketWriterStats *other)
 
void UnsafeArenaSwap (SocketWriterStats *other)
 
SocketWriterStatsNew (::google::protobuf::Arena *arena=nullptr) const final
 
void CopyFrom (const SocketWriterStats &from)
 
void MergeFrom (const SocketWriterStats &from)
 
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear () final
 
bool IsInitialized () const final
 
::size_t ByteSizeLong () const final
 
const char * _InternalParse (const char *ptr, ::google::protobuf::internal::ParseContext *ctx) final
 
::uint8_t * _InternalSerialize (::uint8_t *target, ::google::protobuf::io::EpsCopyOutputStream *stream) const final
 
int GetCachedSize () const final
 
const ::google::protobuf::Message::ClassData * GetClassData () const final
 
::google::protobuf::Metadata GetMetadata () const final
 
void clear_sum_payloads ()
 
::uint64_t sum_payloads () const
 
void set_sum_payloads (::uint64_t value)
 
void clear_num_payloads ()
 
::uint64_t num_payloads () const
 
void set_num_payloads (::uint64_t value)
 
void clear_sum_bytes ()
 
::uint64_t sum_bytes () const
 
void set_sum_bytes (::uint64_t value)
 
void clear_num_data_input_timeouts ()
 
::uint64_t num_data_input_timeouts () const
 
void set_num_data_input_timeouts (::uint64_t value)
 
void clear_rate_payloads_consumed ()
 
double rate_payloads_consumed () const
 
void set_rate_payloads_consumed (double value)
 
template<typename >
PROTOBUF_CONSTEXPR SocketWriterStats (::_pbi::ConstantInitialized)
 

Static Public Member Functions

static const ::google::protobuf::Descriptor * descriptor ()
 
static const ::google::protobuf::Descriptor * GetDescriptor ()
 
static const ::google::protobuf::Reflection * GetReflection ()
 
static const SocketWriterStatsdefault_instance ()
 
static const SocketWriterStatsinternal_default_instance ()
 

Static Public Attributes

static constexpr int kIndexInFileMessages
 
static const ClassData _class_data_
 

Protected Member Functions

 SocketWriterStats (::google::protobuf::Arena *arena)
 

Private Types

typedef void InternalArenaConstructable_
 
typedef void DestructorSkippable_
 

Private Member Functions

void SharedCtor (::google::protobuf::Arena *arena)
 
void SharedDtor ()
 
void SetCachedSize (int size) const final
 
void InternalSwap (SocketWriterStats *other)
 
::uint64_t _internal_sum_payloads () const
 
void _internal_set_sum_payloads (::uint64_t value)
 
::uint64_t _internal_num_payloads () const
 
void _internal_set_num_payloads (::uint64_t value)
 
::uint64_t _internal_sum_bytes () const
 
void _internal_set_sum_bytes (::uint64_t value)
 
::uint64_t _internal_num_data_input_timeouts () const
 
void _internal_set_num_data_input_timeouts (::uint64_t value)
 
double _internal_rate_payloads_consumed () const
 
void _internal_set_rate_payloads_consumed (double value)
 

Static Private Member Functions

static void MergeImpl (::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)
 
::absl::string_view FullMessageName ()
 

Private Attributes

union { 
 
   Impl_   _impl_ 
 
};  
 

Static Private Attributes

static const ::google::protobuf::internal::TcParseTable< 3, 5, 0, 0, 2 > _table_
 

Friends

class ::google::protobuf::internal::AnyMetadata
 
class ::google::protobuf::internal::TcParser
 
template<typename T >
class ::google::protobuf::Arena::InternalHelper
 
struct ::TableStruct_asiolibs_2fopmon_2fSocketWriterModule_2eproto
 
void swap (SocketWriterStats &a, SocketWriterStats &b)
 

Detailed Description

Definition at line 79 of file SocketWriterModule.pb.h.

Member Typedef Documentation

◆ DestructorSkippable_

◆ InternalArenaConstructable_

Member Enumeration Documentation

◆ anonymous enum

anonymous enum : int
Enumerator
kSumPayloadsFieldNumber 
kNumPayloadsFieldNumber 
kSumBytesFieldNumber 
kNumDataInputTimeoutsFieldNumber 
kRatePayloadsConsumedFieldNumber 

Definition at line 206 of file SocketWriterModule.pb.h.

Constructor & Destructor Documentation

◆ SocketWriterStats() [1/6]

dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( )
inline

◆ ~SocketWriterStats()

dunedaq::asiolibs::opmon::SocketWriterStats::~SocketWriterStats ( )
override

Definition at line 154 of file SocketWriterModule.pb.cc.

154 {
155 // @@protoc_insertion_point(destructor:dunedaq.asiolibs.opmon.SocketWriterStats)
156 _internal_metadata_.Delete<::google::protobuf::UnknownFieldSet>();
157 SharedDtor();
158}

◆ SocketWriterStats() [2/6]

template<typename = void>
PROTOBUF_CONSTEXPR dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( ::google::protobuf::internal::ConstantInitialized )
explicit

◆ SocketWriterStats() [3/6]

dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( const SocketWriterStats & from)

Definition at line 137 of file SocketWriterModule.pb.cc.

138 : ::google::protobuf::Message(), _impl_(from._impl_) {
139 _internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(
140 from._internal_metadata_);
141 // @@protoc_insertion_point(copy_constructor:dunedaq.asiolibs.opmon.SocketWriterStats)
142}

◆ SocketWriterStats() [4/6]

dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( SocketWriterStats && from)
inlinenoexcept

Definition at line 88 of file SocketWriterModule.pb.h.

90 *this = ::std::move(from);
91 }

◆ SocketWriterStats() [5/6]

dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( ::google::protobuf::Arena * arena)
explicitprotected

Definition at line 132 of file SocketWriterModule.pb.cc.

133 : ::google::protobuf::Message(arena) {
134 SharedCtor(arena);
135 // @@protoc_insertion_point(arena_constructor:dunedaq.asiolibs.opmon.SocketWriterStats)
136}
void SharedCtor(::google::protobuf::Arena *arena)

◆ SocketWriterStats() [6/6]

template<typename >
PROTOBUF_CONSTEXPR dunedaq::asiolibs::opmon::SocketWriterStats::SocketWriterStats ( ::_pbi::ConstantInitialized )

Definition at line 27 of file SocketWriterModule.pb.cc.

28 : _impl_{
29 /*decltype(_impl_.sum_payloads_)*/ ::uint64_t{0u},
30 /*decltype(_impl_.num_payloads_)*/ ::uint64_t{0u},
31 /*decltype(_impl_.sum_bytes_)*/ ::uint64_t{0u},
32 /*decltype(_impl_.num_data_input_timeouts_)*/ ::uint64_t{0u},
33 /*decltype(_impl_.rate_payloads_consumed_)*/ 0,
34 /*decltype(_impl_._cached_size_)*/ {},
35 } {}

Member Function Documentation

◆ _internal_num_data_input_timeouts()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::_internal_num_data_input_timeouts ( ) const
inlineprivate

Definition at line 379 of file SocketWriterModule.pb.h.

379 {
380 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
382}

◆ _internal_num_payloads()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::_internal_num_payloads ( ) const
inlineprivate

Definition at line 335 of file SocketWriterModule.pb.h.

335 {
336 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
337 return _impl_.num_payloads_;
338}

◆ _internal_rate_payloads_consumed()

double dunedaq::asiolibs::opmon::SocketWriterStats::_internal_rate_payloads_consumed ( ) const
inlineprivate

Definition at line 401 of file SocketWriterModule.pb.h.

401 {
402 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
404}

◆ _internal_set_num_data_input_timeouts()

void dunedaq::asiolibs::opmon::SocketWriterStats::_internal_set_num_data_input_timeouts ( ::uint64_t value)
inlineprivate

Definition at line 383 of file SocketWriterModule.pb.h.

383 {
384 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
385 ;
387}

◆ _internal_set_num_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::_internal_set_num_payloads ( ::uint64_t value)
inlineprivate

Definition at line 339 of file SocketWriterModule.pb.h.

339 {
340 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
341 ;
342 _impl_.num_payloads_ = value;
343}

◆ _internal_set_rate_payloads_consumed()

void dunedaq::asiolibs::opmon::SocketWriterStats::_internal_set_rate_payloads_consumed ( double value)
inlineprivate

Definition at line 405 of file SocketWriterModule.pb.h.

405 {
406 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
407 ;
409}

◆ _internal_set_sum_bytes()

void dunedaq::asiolibs::opmon::SocketWriterStats::_internal_set_sum_bytes ( ::uint64_t value)
inlineprivate

Definition at line 361 of file SocketWriterModule.pb.h.

361 {
362 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
363 ;
364 _impl_.sum_bytes_ = value;
365}

◆ _internal_set_sum_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::_internal_set_sum_payloads ( ::uint64_t value)
inlineprivate

Definition at line 317 of file SocketWriterModule.pb.h.

317 {
318 PROTOBUF_TSAN_WRITE(&_impl_._tsan_detect_race);
319 ;
320 _impl_.sum_payloads_ = value;
321}

◆ _internal_sum_bytes()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::_internal_sum_bytes ( ) const
inlineprivate

Definition at line 357 of file SocketWriterModule.pb.h.

357 {
358 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
359 return _impl_.sum_bytes_;
360}

◆ _internal_sum_payloads()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::_internal_sum_payloads ( ) const
inlineprivate

Definition at line 313 of file SocketWriterModule.pb.h.

313 {
314 PROTOBUF_TSAN_READ(&_impl_._tsan_detect_race);
315 return _impl_.sum_payloads_;
316}

◆ _InternalParse()

const char * dunedaq::asiolibs::opmon::SocketWriterStats::_InternalParse ( const char * ptr,
::google::protobuf::internal::ParseContext * ctx )
final

Definition at line 178 of file SocketWriterModule.pb.cc.

179 {
180 ptr = ::_pbi::TcParser::ParseLoop(this, ptr, ctx, &_table_.header);
181 return ptr;
182}
static const ::google::protobuf::internal::TcParseTable< 3, 5, 0, 0, 2 > _table_

◆ _InternalSerialize()

uint8_t * dunedaq::asiolibs::opmon::SocketWriterStats::_InternalSerialize ( ::uint8_t * target,
::google::protobuf::io::EpsCopyOutputStream * stream ) const
final

Definition at line 242 of file SocketWriterModule.pb.cc.

244 {
245 // @@protoc_insertion_point(serialize_to_array_start:dunedaq.asiolibs.opmon.SocketWriterStats)
246 ::uint32_t cached_has_bits = 0;
247 (void)cached_has_bits;
248
249 // uint64 sum_payloads = 1;
250 if (this->_internal_sum_payloads() != 0) {
251 target = stream->EnsureSpace(target);
252 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
253 1, this->_internal_sum_payloads(), target);
254 }
255
256 // uint64 num_payloads = 2;
257 if (this->_internal_num_payloads() != 0) {
258 target = stream->EnsureSpace(target);
259 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
260 2, this->_internal_num_payloads(), target);
261 }
262
263 // uint64 sum_bytes = 3;
264 if (this->_internal_sum_bytes() != 0) {
265 target = stream->EnsureSpace(target);
266 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
267 3, this->_internal_sum_bytes(), target);
268 }
269
270 // uint64 num_data_input_timeouts = 4;
271 if (this->_internal_num_data_input_timeouts() != 0) {
272 target = stream->EnsureSpace(target);
273 target = ::_pbi::WireFormatLite::WriteUInt64ToArray(
274 4, this->_internal_num_data_input_timeouts(), target);
275 }
276
277 // double rate_payloads_consumed = 5;
278 static_assert(sizeof(::uint64_t) == sizeof(double),
279 "Code assumes ::uint64_t and double are the same size.");
280 double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
281 ::uint64_t raw_rate_payloads_consumed;
282 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
283 if (raw_rate_payloads_consumed != 0) {
284 target = stream->EnsureSpace(target);
285 target = ::_pbi::WireFormatLite::WriteDoubleToArray(
286 5, this->_internal_rate_payloads_consumed(), target);
287 }
288
289 if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
290 target =
291 ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
292 _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance), target, stream);
293 }
294 // @@protoc_insertion_point(serialize_to_array_end:dunedaq.asiolibs.opmon.SocketWriterStats)
295 return target;
296}

◆ ByteSizeLong()

size_t dunedaq::asiolibs::opmon::SocketWriterStats::ByteSizeLong ( ) const
final

Definition at line 298 of file SocketWriterModule.pb.cc.

298 {
299// @@protoc_insertion_point(message_byte_size_start:dunedaq.asiolibs.opmon.SocketWriterStats)
300 ::size_t total_size = 0;
301
302 ::uint32_t cached_has_bits = 0;
303 // Prevent compiler warnings about cached_has_bits being unused
304 (void) cached_has_bits;
305
306 // uint64 sum_payloads = 1;
307 if (this->_internal_sum_payloads() != 0) {
308 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
309 this->_internal_sum_payloads());
310 }
311
312 // uint64 num_payloads = 2;
313 if (this->_internal_num_payloads() != 0) {
314 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
315 this->_internal_num_payloads());
316 }
317
318 // uint64 sum_bytes = 3;
319 if (this->_internal_sum_bytes() != 0) {
320 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
321 this->_internal_sum_bytes());
322 }
323
324 // uint64 num_data_input_timeouts = 4;
325 if (this->_internal_num_data_input_timeouts() != 0) {
326 total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(
328 }
329
330 // double rate_payloads_consumed = 5;
331 static_assert(sizeof(::uint64_t) == sizeof(double),
332 "Code assumes ::uint64_t and double are the same size.");
333 double tmp_rate_payloads_consumed = this->_internal_rate_payloads_consumed();
334 ::uint64_t raw_rate_payloads_consumed;
335 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
336 if (raw_rate_payloads_consumed != 0) {
337 total_size += 9;
338 }
339
340 return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
341}
mutable::google::protobuf::internal::CachedSize _cached_size_

◆ Clear()

PROTOBUF_NOINLINE void dunedaq::asiolibs::opmon::SocketWriterStats::Clear ( )
final

Definition at line 166 of file SocketWriterModule.pb.cc.

166 {
167// @@protoc_insertion_point(message_clear_start:dunedaq.asiolibs.opmon.SocketWriterStats)
168 ::uint32_t cached_has_bits = 0;
169 // Prevent compiler warnings about cached_has_bits being unused
170 (void) cached_has_bits;
171
172 ::memset(&_impl_.sum_payloads_, 0, static_cast<::size_t>(
173 reinterpret_cast<char*>(&_impl_.rate_payloads_consumed_) -
174 reinterpret_cast<char*>(&_impl_.sum_payloads_)) + sizeof(_impl_.rate_payloads_consumed_));
175 _internal_metadata_.Clear<::google::protobuf::UnknownFieldSet>();
176}

◆ clear_num_data_input_timeouts()

void dunedaq::asiolibs::opmon::SocketWriterStats::clear_num_data_input_timeouts ( )
inline

Definition at line 368 of file SocketWriterModule.pb.h.

368 {
369 _impl_.num_data_input_timeouts_ = ::uint64_t{0u};
370}

◆ clear_num_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::clear_num_payloads ( )
inline

Definition at line 324 of file SocketWriterModule.pb.h.

324 {
325 _impl_.num_payloads_ = ::uint64_t{0u};
326}

◆ clear_rate_payloads_consumed()

void dunedaq::asiolibs::opmon::SocketWriterStats::clear_rate_payloads_consumed ( )
inline

Definition at line 390 of file SocketWriterModule.pb.h.

390 {
392}

◆ clear_sum_bytes()

void dunedaq::asiolibs::opmon::SocketWriterStats::clear_sum_bytes ( )
inline

Definition at line 346 of file SocketWriterModule.pb.h.

346 {
347 _impl_.sum_bytes_ = ::uint64_t{0u};
348}

◆ clear_sum_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::clear_sum_payloads ( )
inline

Definition at line 302 of file SocketWriterModule.pb.h.

302 {
303 _impl_.sum_payloads_ = ::uint64_t{0u};
304}

◆ CopyFrom()

void dunedaq::asiolibs::opmon::SocketWriterStats::CopyFrom ( const SocketWriterStats & from)

Definition at line 381 of file SocketWriterModule.pb.cc.

381 {
382// @@protoc_insertion_point(class_specific_copy_from_start:dunedaq.asiolibs.opmon.SocketWriterStats)
383 if (&from == this) return;
384 Clear();
385 MergeFrom(from);
386}
void MergeFrom(const SocketWriterStats &from)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final

◆ default_instance()

static const SocketWriterStats & dunedaq::asiolibs::opmon::SocketWriterStats::default_instance ( )
inlinestatic

Definition at line 127 of file SocketWriterModule.pb.h.

127 {
129 }
static const SocketWriterStats * internal_default_instance()

◆ descriptor()

static const ::google::protobuf::Descriptor * dunedaq::asiolibs::opmon::SocketWriterStats::descriptor ( )
inlinestatic

Definition at line 118 of file SocketWriterModule.pb.h.

118 {
119 return GetDescriptor();
120 }
static const ::google::protobuf::Descriptor * GetDescriptor()

◆ FullMessageName()

::absl::string_view dunedaq::asiolibs::opmon::SocketWriterStats::FullMessageName ( )
inlinestaticprivate

Definition at line 190 of file SocketWriterModule.pb.h.

190 {
191 return "dunedaq.asiolibs.opmon.SocketWriterStats";
192 }

◆ GetCachedSize()

int dunedaq::asiolibs::opmon::SocketWriterStats::GetCachedSize ( ) const
inlinefinal

Definition at line 180 of file SocketWriterModule.pb.h.

180{ return _impl_._cached_size_.Get(); }

◆ GetClassData()

const::google::protobuf::Message::ClassData * dunedaq::asiolibs::opmon::SocketWriterStats::GetClassData ( ) const
final

Definition at line 347 of file SocketWriterModule.pb.cc.

347{ return &_class_data_; }

◆ GetDescriptor()

static const ::google::protobuf::Descriptor * dunedaq::asiolibs::opmon::SocketWriterStats::GetDescriptor ( )
inlinestatic

Definition at line 121 of file SocketWriterModule.pb.h.

121 {
122 return default_instance().GetMetadata().descriptor;
123 }
static const SocketWriterStats & default_instance()
::google::protobuf::Metadata GetMetadata() const final

◆ GetMetadata()

google::protobuf::Metadata dunedaq::asiolibs::opmon::SocketWriterStats::GetMetadata ( ) const
final

Definition at line 403 of file SocketWriterModule.pb.cc.

403 {
404 return ::_pbi::AssignDescriptors(
407}
::absl::once_flag descriptor_table_asiolibs_2fopmon_2fSocketWriterModule_2eproto_once
PROTOBUF_ATTRIBUTE_WEAKconst ::_pbi::DescriptorTable * descriptor_table_asiolibs_2fopmon_2fSocketWriterModule_2eproto_getter()
::_pb::Metadata file_level_metadata_asiolibs_2fopmon_2fSocketWriterModule_2eproto[1]

◆ GetReflection()

static const ::google::protobuf::Reflection * dunedaq::asiolibs::opmon::SocketWriterStats::GetReflection ( )
inlinestatic

Definition at line 124 of file SocketWriterModule.pb.h.

124 {
125 return default_instance().GetMetadata().reflection;
126 }

◆ internal_default_instance()

static const SocketWriterStats * dunedaq::asiolibs::opmon::SocketWriterStats::internal_default_instance ( )
inlinestatic

Definition at line 130 of file SocketWriterModule.pb.h.

130 {
131 return reinterpret_cast<const SocketWriterStats*>(
133 }
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 SocketWriterStatsDefaultTypeInternal _SocketWriterStats_default_instance_

◆ InternalSwap()

void dunedaq::asiolibs::opmon::SocketWriterStats::InternalSwap ( SocketWriterStats * other)
private

Definition at line 392 of file SocketWriterModule.pb.cc.

392 {
393 using std::swap;
394 _internal_metadata_.InternalSwap(&other->_internal_metadata_);
395 ::google::protobuf::internal::memswap<
396 PROTOBUF_FIELD_OFFSET(SocketWriterStats, _impl_.rate_payloads_consumed_)
398 - PROTOBUF_FIELD_OFFSET(SocketWriterStats, _impl_.sum_payloads_)>(
399 reinterpret_cast<char*>(&_impl_.sum_payloads_),
400 reinterpret_cast<char*>(&other->_impl_.sum_payloads_));
401}

◆ IsInitialized()

PROTOBUF_NOINLINE bool dunedaq::asiolibs::opmon::SocketWriterStats::IsInitialized ( ) const
final

Definition at line 388 of file SocketWriterModule.pb.cc.

388 {
389 return true;
390}

◆ MergeFrom()

void dunedaq::asiolibs::opmon::SocketWriterStats::MergeFrom ( const SocketWriterStats & from)
inline

Definition at line 167 of file SocketWriterModule.pb.h.

167 {
168 SocketWriterStats::MergeImpl(*this, from);
169 }
static void MergeImpl(::google::protobuf::Message &to_msg, const ::google::protobuf::Message &from_msg)

◆ MergeImpl()

void dunedaq::asiolibs::opmon::SocketWriterStats::MergeImpl ( ::google::protobuf::Message & to_msg,
const ::google::protobuf::Message & from_msg )
staticprivate

Definition at line 350 of file SocketWriterModule.pb.cc.

350 {
351 auto* const _this = static_cast<SocketWriterStats*>(&to_msg);
352 auto& from = static_cast<const SocketWriterStats&>(from_msg);
353 // @@protoc_insertion_point(class_specific_merge_from_start:dunedaq.asiolibs.opmon.SocketWriterStats)
354 ABSL_DCHECK_NE(&from, _this);
355 ::uint32_t cached_has_bits = 0;
356 (void) cached_has_bits;
357
358 if (from._internal_sum_payloads() != 0) {
359 _this->_internal_set_sum_payloads(from._internal_sum_payloads());
360 }
361 if (from._internal_num_payloads() != 0) {
362 _this->_internal_set_num_payloads(from._internal_num_payloads());
363 }
364 if (from._internal_sum_bytes() != 0) {
365 _this->_internal_set_sum_bytes(from._internal_sum_bytes());
366 }
367 if (from._internal_num_data_input_timeouts() != 0) {
368 _this->_internal_set_num_data_input_timeouts(from._internal_num_data_input_timeouts());
369 }
370 static_assert(sizeof(::uint64_t) == sizeof(double),
371 "Code assumes ::uint64_t and double are the same size.");
372 double tmp_rate_payloads_consumed = from._internal_rate_payloads_consumed();
373 ::uint64_t raw_rate_payloads_consumed;
374 memcpy(&raw_rate_payloads_consumed, &tmp_rate_payloads_consumed, sizeof(tmp_rate_payloads_consumed));
375 if (raw_rate_payloads_consumed != 0) {
376 _this->_internal_set_rate_payloads_consumed(from._internal_rate_payloads_consumed());
377 }
378 _this->_internal_metadata_.MergeFrom<::google::protobuf::UnknownFieldSet>(from._internal_metadata_);
379}

◆ mutable_unknown_fields()

inline ::google::protobuf::UnknownFieldSet * dunedaq::asiolibs::opmon::SocketWriterStats::mutable_unknown_fields ( )
inline

Definition at line 114 of file SocketWriterModule.pb.h.

114 {
115 return _internal_metadata_.mutable_unknown_fields<::google::protobuf::UnknownFieldSet>();
116 }

◆ New()

SocketWriterStats * dunedaq::asiolibs::opmon::SocketWriterStats::New ( ::google::protobuf::Arena * arena = nullptr) const
inlinefinal

Definition at line 161 of file SocketWriterModule.pb.h.

161 {
162 return CreateMaybeMessage<SocketWriterStats>(arena);
163 }

◆ num_data_input_timeouts()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::num_data_input_timeouts ( ) const
inline

Definition at line 371 of file SocketWriterModule.pb.h.

371 {
372 // @@protoc_insertion_point(field_get:dunedaq.asiolibs.opmon.SocketWriterStats.num_data_input_timeouts)
374}

◆ num_payloads()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::num_payloads ( ) const
inline

Definition at line 327 of file SocketWriterModule.pb.h.

327 {
328 // @@protoc_insertion_point(field_get:dunedaq.asiolibs.opmon.SocketWriterStats.num_payloads)
329 return _internal_num_payloads();
330}

◆ operator=() [1/2]

SocketWriterStats & dunedaq::asiolibs::opmon::SocketWriterStats::operator= ( const SocketWriterStats & from)
inline

Definition at line 93 of file SocketWriterModule.pb.h.

93 {
94 CopyFrom(from);
95 return *this;
96 }
void CopyFrom(const SocketWriterStats &from)

◆ operator=() [2/2]

SocketWriterStats & dunedaq::asiolibs::opmon::SocketWriterStats::operator= ( SocketWriterStats && from)
inlinenoexcept

Definition at line 97 of file SocketWriterModule.pb.h.

97 {
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 }

◆ rate_payloads_consumed()

double dunedaq::asiolibs::opmon::SocketWriterStats::rate_payloads_consumed ( ) const
inline

Definition at line 393 of file SocketWriterModule.pb.h.

393 {
394 // @@protoc_insertion_point(field_get:dunedaq.asiolibs.opmon.SocketWriterStats.rate_payloads_consumed)
396}

◆ set_num_data_input_timeouts()

void dunedaq::asiolibs::opmon::SocketWriterStats::set_num_data_input_timeouts ( ::uint64_t value)
inline

Definition at line 375 of file SocketWriterModule.pb.h.

375 {
377 // @@protoc_insertion_point(field_set:dunedaq.asiolibs.opmon.SocketWriterStats.num_data_input_timeouts)
378}

◆ set_num_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::set_num_payloads ( ::uint64_t value)
inline

Definition at line 331 of file SocketWriterModule.pb.h.

331 {
333 // @@protoc_insertion_point(field_set:dunedaq.asiolibs.opmon.SocketWriterStats.num_payloads)
334}

◆ set_rate_payloads_consumed()

void dunedaq::asiolibs::opmon::SocketWriterStats::set_rate_payloads_consumed ( double value)
inline

Definition at line 397 of file SocketWriterModule.pb.h.

397 {
399 // @@protoc_insertion_point(field_set:dunedaq.asiolibs.opmon.SocketWriterStats.rate_payloads_consumed)
400}

◆ set_sum_bytes()

void dunedaq::asiolibs::opmon::SocketWriterStats::set_sum_bytes ( ::uint64_t value)
inline

Definition at line 353 of file SocketWriterModule.pb.h.

353 {
355 // @@protoc_insertion_point(field_set:dunedaq.asiolibs.opmon.SocketWriterStats.sum_bytes)
356}

◆ set_sum_payloads()

void dunedaq::asiolibs::opmon::SocketWriterStats::set_sum_payloads ( ::uint64_t value)
inline

Definition at line 309 of file SocketWriterModule.pb.h.

309 {
311 // @@protoc_insertion_point(field_set:dunedaq.asiolibs.opmon.SocketWriterStats.sum_payloads)
312}

◆ SetCachedSize()

void dunedaq::asiolibs::opmon::SocketWriterStats::SetCachedSize ( int size) const
finalprivate

Definition at line 162 of file SocketWriterModule.pb.cc.

162 {
164}
FELIX Initialization std::string initerror FELIX queue timed std::string queuename Unexpected chunk size

◆ SharedCtor()

void dunedaq::asiolibs::opmon::SocketWriterStats::SharedCtor ( ::google::protobuf::Arena * arena)
inlineprivate

Definition at line 143 of file SocketWriterModule.pb.cc.

143 {
144 (void)arena;
145 new (&_impl_) Impl_{
146 decltype(_impl_.sum_payloads_){::uint64_t{0u}},
147 decltype(_impl_.num_payloads_){::uint64_t{0u}},
148 decltype(_impl_.sum_bytes_){::uint64_t{0u}},
149 decltype(_impl_.num_data_input_timeouts_){::uint64_t{0u}},
150 decltype(_impl_.rate_payloads_consumed_){0},
151 /*decltype(_impl_._cached_size_)*/ {},
152 };
153}

◆ SharedDtor()

void dunedaq::asiolibs::opmon::SocketWriterStats::SharedDtor ( )
inlineprivate

Definition at line 159 of file SocketWriterModule.pb.cc.

159 {
160 ABSL_DCHECK(GetArenaForAllocation() == nullptr);
161}

◆ sum_bytes()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::sum_bytes ( ) const
inline

Definition at line 349 of file SocketWriterModule.pb.h.

349 {
350 // @@protoc_insertion_point(field_get:dunedaq.asiolibs.opmon.SocketWriterStats.sum_bytes)
351 return _internal_sum_bytes();
352}

◆ sum_payloads()

uint64_t dunedaq::asiolibs::opmon::SocketWriterStats::sum_payloads ( ) const
inline

Definition at line 305 of file SocketWriterModule.pb.h.

305 {
306 // @@protoc_insertion_point(field_get:dunedaq.asiolibs.opmon.SocketWriterStats.sum_payloads)
307 return _internal_sum_payloads();
308}

◆ Swap()

void dunedaq::asiolibs::opmon::SocketWriterStats::Swap ( SocketWriterStats * other)
inline

Definition at line 140 of file SocketWriterModule.pb.h.

140 {
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 }

◆ unknown_fields()

const ::google::protobuf::UnknownFieldSet & dunedaq::asiolibs::opmon::SocketWriterStats::unknown_fields ( ) const
inline

Definition at line 111 of file SocketWriterModule.pb.h.

111 {
112 return _internal_metadata_.unknown_fields<::google::protobuf::UnknownFieldSet>(::google::protobuf::UnknownFieldSet::default_instance);
113 }

◆ UnsafeArenaSwap()

void dunedaq::asiolibs::opmon::SocketWriterStats::UnsafeArenaSwap ( SocketWriterStats * other)
inline

Definition at line 153 of file SocketWriterModule.pb.h.

153 {
154 if (other == this) return;
155 ABSL_DCHECK(GetOwningArena() == other->GetOwningArena());
156 InternalSwap(other);
157 }

Friends And Related Symbol Documentation

◆ ::google::protobuf::Arena::InternalHelper

template<typename T >
friend class ::google::protobuf::Arena::InternalHelper
friend

Definition at line 269 of file SocketWriterModule.pb.h.

◆ ::google::protobuf::internal::AnyMetadata

friend class ::google::protobuf::internal::AnyMetadata
friend

Definition at line 189 of file SocketWriterModule.pb.h.

◆ ::google::protobuf::internal::TcParser

friend class ::google::protobuf::internal::TcParser
friend

Definition at line 267 of file SocketWriterModule.pb.h.

◆ ::TableStruct_asiolibs_2fopmon_2fSocketWriterModule_2eproto

◆ swap

void swap ( SocketWriterStats & a,
SocketWriterStats & b )
friend

Definition at line 137 of file SocketWriterModule.pb.h.

137 {
138 a.Swap(&b);
139 }

Member Data Documentation

◆ [union]

◆ _class_data_

const::google::protobuf::Message::ClassData dunedaq::asiolibs::opmon::SocketWriterStats::_class_data_
static
Initial value:
= {
::google::protobuf::Message::CopyWithSourceCheck,
}

Definition at line 197 of file SocketWriterModule.pb.h.

◆ _impl_

Impl_ dunedaq::asiolibs::opmon::SocketWriterStats::_impl_

Definition at line 281 of file SocketWriterModule.pb.h.

◆ _table_

PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 const::_pbi::TcParseTable< 3, 5, 0, 0, 2 > dunedaq::asiolibs::opmon::SocketWriterStats::_table_
staticprivate

Definition at line 268 of file SocketWriterModule.pb.h.

◆ kIndexInFileMessages

int dunedaq::asiolibs::opmon::SocketWriterStats::kIndexInFileMessages
staticconstexpr
Initial value:
=
0

Definition at line 134 of file SocketWriterModule.pb.h.


The documentation for this class was generated from the following files: