Goby3 3.2.3
2025.05.13
Loading...
Searching...
No Matches
queue.pb.h
Go to the documentation of this file.
1// Generated by the protocol buffer compiler. DO NOT EDIT!
2// source: goby/acomms/protobuf/queue.proto
3
4#ifndef GOOGLE_PROTOBUF_INCLUDED_goby_2facomms_2fprotobuf_2fqueue_2eproto
5#define GOOGLE_PROTOBUF_INCLUDED_goby_2facomms_2fprotobuf_2fqueue_2eproto
6
7#include <limits>
8#include <string>
9
10#include <google/protobuf/port_def.inc>
11#if PROTOBUF_VERSION < 3021000
12#error This file was generated by a newer version of protoc which is
13#error incompatible with your Protocol Buffer headers. Please update
14#error your headers.
15#endif
16#if 3021012 < PROTOBUF_MIN_PROTOC_VERSION
17#error This file was generated by an older version of protoc which is
18#error incompatible with your Protocol Buffer headers. Please
19#error regenerate this file with a newer version of protoc.
20#endif
21
22#include <google/protobuf/port_undef.inc>
23#include <google/protobuf/io/coded_stream.h>
25#include <google/protobuf/arenastring.h>
26#include <google/protobuf/generated_message_util.h>
27#include <google/protobuf/metadata_lite.h>
28#include <google/protobuf/generated_message_reflection.h>
30#include <google/protobuf/repeated_field.h> // IWYU pragma: export
31#include <google/protobuf/extension_set.h> // IWYU pragma: export
32#include <google/protobuf/generated_enum_reflection.h>
33#include <google/protobuf/unknown_field_set.h>
34#include "dccl/option_extensions.pb.h"
37#include <boost/units/quantity.hpp>
38#include <boost/units/absolute.hpp>
39#include <boost/units/dimensionless_type.hpp>
40#include <boost/units/make_scaled_unit.hpp>
41
42#include <boost/units/systems/si.hpp>
43// @@protoc_insertion_point(includes)
44#include <google/protobuf/port_def.inc>
45#define PROTOBUF_INTERNAL_EXPORT_goby_2facomms_2fprotobuf_2fqueue_2eproto
46PROTOBUF_NAMESPACE_OPEN
47namespace internal {
48class AnyMetadata;
49} // namespace internal
50PROTOBUF_NAMESPACE_CLOSE
51
52// Internal implementation detail -- do not use these members.
56extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2facomms_2fprotobuf_2fqueue_2eproto;
57namespace goby {
58namespace acomms {
59namespace protobuf {
60class QueueFlush;
61struct QueueFlushDefaultTypeInternal;
62extern QueueFlushDefaultTypeInternal _QueueFlush_default_instance_;
63class QueueManagerConfig;
64struct QueueManagerConfigDefaultTypeInternal;
65extern QueueManagerConfigDefaultTypeInternal _QueueManagerConfig_default_instance_;
66class QueueManagerConfig_DCCLEncryptRule;
67struct QueueManagerConfig_DCCLEncryptRuleDefaultTypeInternal;
68extern QueueManagerConfig_DCCLEncryptRuleDefaultTypeInternal _QueueManagerConfig_DCCLEncryptRule_default_instance_;
69class QueueSize;
70struct QueueSizeDefaultTypeInternal;
71extern QueueSizeDefaultTypeInternal _QueueSize_default_instance_;
72class QueuedMessageEntry;
73struct QueuedMessageEntryDefaultTypeInternal;
74extern QueuedMessageEntryDefaultTypeInternal _QueuedMessageEntry_default_instance_;
75class QueuedMessageEntry_Role;
76struct QueuedMessageEntry_RoleDefaultTypeInternal;
77extern QueuedMessageEntry_RoleDefaultTypeInternal _QueuedMessageEntry_Role_default_instance_;
78class QueuedMessageMeta;
79struct QueuedMessageMetaDefaultTypeInternal;
80extern QueuedMessageMetaDefaultTypeInternal _QueuedMessageMeta_default_instance_;
81} // namespace protobuf
82} // namespace acomms
83} // namespace goby
84PROTOBUF_NAMESPACE_OPEN
85template<> ::goby::acomms::protobuf::QueueFlush* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueueFlush>(Arena*);
86template<> ::goby::acomms::protobuf::QueueManagerConfig* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueueManagerConfig>(Arena*);
87template<> ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule>(Arena*);
88template<> ::goby::acomms::protobuf::QueueSize* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueueSize>(Arena*);
89template<> ::goby::acomms::protobuf::QueuedMessageEntry* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueuedMessageEntry>(Arena*);
90template<> ::goby::acomms::protobuf::QueuedMessageEntry_Role* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueuedMessageEntry_Role>(Arena*);
91template<> ::goby::acomms::protobuf::QueuedMessageMeta* Arena::CreateMaybeMessage<::goby::acomms::protobuf::QueuedMessageMeta>(Arena*);
92PROTOBUF_NAMESPACE_CLOSE
93namespace goby {
94namespace acomms {
95namespace protobuf {
96
105
106const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* QueuedMessageEntry_Role_RoleSetting_descriptor();
107template<typename T>
108inline const std::string& QueuedMessageEntry_Role_RoleSetting_Name(T enum_t_value) {
109 static_assert(::std::is_same<T, QueuedMessageEntry_Role_RoleSetting>::value ||
110 ::std::is_integral<T>::value,
111 "Incorrect type passed to function QueuedMessageEntry_Role_RoleSetting_Name.");
112 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
114}
116 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, QueuedMessageEntry_Role_RoleSetting* value) {
117 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<QueuedMessageEntry_Role_RoleSetting>(
119}
129
130const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* QueuedMessageEntry_RoleType_descriptor();
131template<typename T>
132inline const std::string& QueuedMessageEntry_RoleType_Name(T enum_t_value) {
133 static_assert(::std::is_same<T, QueuedMessageEntry_RoleType>::value ||
134 ::std::is_integral<T>::value,
135 "Incorrect type passed to function QueuedMessageEntry_RoleType_Name.");
136 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
138}
140 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, QueuedMessageEntry_RoleType* value) {
141 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<QueuedMessageEntry_RoleType>(
143}
144// ===================================================================
145
147 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueuedMessageEntry.Role) */ {
148 public:
151 explicit PROTOBUF_CONSTEXPR QueuedMessageEntry_Role(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
152
156 *this = ::std::move(from);
157 }
158
160 CopyFrom(from);
161 return *this;
162 }
164 if (this == &from) return *this;
165 if (GetOwningArena() == from.GetOwningArena()
166 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
167 && GetOwningArena() != nullptr
168 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
169 ) {
170 InternalSwap(&from);
171 } else {
172 CopyFrom(from);
173 }
174 return *this;
175 }
176
177 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
178 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
179 }
180 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
181 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
182 }
183
184 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
185 return GetDescriptor();
186 }
187 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
188 return default_instance().GetMetadata().descriptor;
189 }
190 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
191 return default_instance().GetMetadata().reflection;
192 }
197 return reinterpret_cast<const QueuedMessageEntry_Role*>(
199 }
200 static constexpr int kIndexInFileMessages =
201 0;
202
204 a.Swap(&b);
205 }
206 inline void Swap(QueuedMessageEntry_Role* other) {
207 if (other == this) return;
208 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
209 if (GetOwningArena() != nullptr &&
210 GetOwningArena() == other->GetOwningArena()) {
211 #else // PROTOBUF_FORCE_COPY_IN_SWAP
212 if (GetOwningArena() == other->GetOwningArena()) {
213 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
214 InternalSwap(other);
215 } else {
216 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
217 }
218 }
220 if (other == this) return;
221 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
222 InternalSwap(other);
223 }
224
225 // implements Message ----------------------------------------------
226
227 QueuedMessageEntry_Role* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
228 return CreateMaybeMessage<QueuedMessageEntry_Role>(arena);
229 }
230 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
232 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
234 QueuedMessageEntry_Role::MergeImpl(*this, from);
235 }
236 private:
237 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
238 public:
239 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
240 bool IsInitialized() const final;
241
242 size_t ByteSizeLong() const final;
243 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
245 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
246 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
247
248 private:
249 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
250 void SharedDtor();
251 void SetCachedSize(int size) const final;
252 void InternalSwap(QueuedMessageEntry_Role* other);
253
254 private:
255 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
256 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
257 return "goby.acomms.protobuf.QueuedMessageEntry.Role";
258 }
259 protected:
260 explicit QueuedMessageEntry_Role(::PROTOBUF_NAMESPACE_ID::Arena* arena,
261 bool is_message_owned = false);
262 public:
263
264 static const ClassData _class_data_;
265 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
266
267 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
268
269 // nested types ----------------------------------------------------
270
272 static constexpr RoleSetting STATIC =
274 static constexpr RoleSetting FIELD_VALUE =
276 static inline bool RoleSetting_IsValid(int value) {
278 }
279 static constexpr RoleSetting RoleSetting_MIN =
281 static constexpr RoleSetting RoleSetting_MAX =
283 static constexpr int RoleSetting_ARRAYSIZE =
285 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
289 template<typename T>
290 static inline const std::string& RoleSetting_Name(T enum_t_value) {
291 static_assert(::std::is_same<T, RoleSetting>::value ||
292 ::std::is_integral<T>::value,
293 "Incorrect type passed to function RoleSetting_Name.");
294 return QueuedMessageEntry_Role_RoleSetting_Name(enum_t_value);
295 }
296 static inline bool RoleSetting_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
297 RoleSetting* value) {
299 }
300
301 // accessors -------------------------------------------------------
302
303 enum : int {
308 };
309 // optional string field = 3;
310 bool has_field() const;
311 private:
312 bool _internal_has_field() const;
313 public:
314 void clear_field();
315 const std::string& field() const;
316 template <typename ArgT0 = const std::string&, typename... ArgT>
317 void set_field(ArgT0&& arg0, ArgT... args);
318 std::string* mutable_field();
319 PROTOBUF_NODISCARD std::string* release_field();
320 void set_allocated_field(std::string* field);
321 private:
322 const std::string& _internal_field() const;
323 inline PROTOBUF_ALWAYS_INLINE void _internal_set_field(const std::string& value);
324 std::string* _internal_mutable_field();
325 public:
326
327 // optional int32 static_value = 4;
328 bool has_static_value() const;
329 private:
330 bool _internal_has_static_value() const;
331 public:
332 void clear_static_value();
333 int32_t static_value() const;
334 void set_static_value(int32_t value);
335 private:
336 int32_t _internal_static_value() const;
337 void _internal_set_static_value(int32_t value);
338 public:
339
340 // required .goby.acomms.protobuf.QueuedMessageEntry.RoleType type = 1;
341 bool has_type() const;
342 private:
343 bool _internal_has_type() const;
344 public:
345 void clear_type();
348 private:
350 void _internal_set_type(::goby::acomms::protobuf::QueuedMessageEntry_RoleType value);
351 public:
352
353 // optional .goby.acomms.protobuf.QueuedMessageEntry.Role.RoleSetting setting = 2 [default = FIELD_VALUE];
354 bool has_setting() const;
355 private:
356 bool _internal_has_setting() const;
357 public:
358 void clear_setting();
361 private:
364 public:
365
366 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueuedMessageEntry.Role)
367 private:
368 class _Internal;
369
370 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
371 typedef void InternalArenaConstructable_;
372 typedef void DestructorSkippable_;
373 struct Impl_ {
374 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
375 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
376 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr field_;
377 int32_t static_value_;
378 int type_;
379 int setting_;
380 };
381 union { Impl_ _impl_; };
382 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
383};
384// -------------------------------------------------------------------
385
387 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueuedMessageEntry) */ {
388 public:
391 explicit PROTOBUF_CONSTEXPR QueuedMessageEntry(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
392
396 *this = ::std::move(from);
397 }
398
400 CopyFrom(from);
401 return *this;
402 }
404 if (this == &from) return *this;
405 if (GetOwningArena() == from.GetOwningArena()
406 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
407 && GetOwningArena() != nullptr
408 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
409 ) {
410 InternalSwap(&from);
411 } else {
412 CopyFrom(from);
413 }
414 return *this;
415 }
416
417 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
418 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
419 }
420 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
421 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
422 }
423
424 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
425 return GetDescriptor();
426 }
427 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
428 return default_instance().GetMetadata().descriptor;
429 }
430 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
431 return default_instance().GetMetadata().reflection;
432 }
434 return *internal_default_instance();
435 }
437 return reinterpret_cast<const QueuedMessageEntry*>(
439 }
440 static constexpr int kIndexInFileMessages =
441 1;
442
444 a.Swap(&b);
445 }
446 inline void Swap(QueuedMessageEntry* other) {
447 if (other == this) return;
448 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
449 if (GetOwningArena() != nullptr &&
450 GetOwningArena() == other->GetOwningArena()) {
451 #else // PROTOBUF_FORCE_COPY_IN_SWAP
452 if (GetOwningArena() == other->GetOwningArena()) {
453 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
454 InternalSwap(other);
455 } else {
456 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
457 }
458 }
460 if (other == this) return;
461 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
462 InternalSwap(other);
463 }
464
465 // implements Message ----------------------------------------------
466
467 QueuedMessageEntry* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
468 return CreateMaybeMessage<QueuedMessageEntry>(arena);
469 }
470 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
471 void CopyFrom(const QueuedMessageEntry& from);
472 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
473 void MergeFrom( const QueuedMessageEntry& from) {
474 QueuedMessageEntry::MergeImpl(*this, from);
475 }
476 private:
477 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
478 public:
479 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
480 bool IsInitialized() const final;
481
482 size_t ByteSizeLong() const final;
483 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
484 uint8_t* _InternalSerialize(
485 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
486 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
487
488 private:
489 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
490 void SharedDtor();
491 void SetCachedSize(int size) const final;
492 void InternalSwap(QueuedMessageEntry* other);
493
494 private:
495 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
496 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
497 return "goby.acomms.protobuf.QueuedMessageEntry";
498 }
499 protected:
500 explicit QueuedMessageEntry(::PROTOBUF_NAMESPACE_ID::Arena* arena,
501 bool is_message_owned = false);
502 public:
503
504 static const ClassData _class_data_;
505 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
506
507 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
508
509 // nested types ----------------------------------------------------
510
512
514 static constexpr RoleType SOURCE_ID =
515 QueuedMessageEntry_RoleType_SOURCE_ID;
516 static constexpr RoleType DESTINATION_ID =
517 QueuedMessageEntry_RoleType_DESTINATION_ID;
518 static constexpr RoleType TIMESTAMP =
519 QueuedMessageEntry_RoleType_TIMESTAMP;
520 static inline bool RoleType_IsValid(int value) {
522 }
523 static constexpr RoleType RoleType_MIN =
525 static constexpr RoleType RoleType_MAX =
527 static constexpr int RoleType_ARRAYSIZE =
529 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
533 template<typename T>
534 static inline const std::string& RoleType_Name(T enum_t_value) {
535 static_assert(::std::is_same<T, RoleType>::value ||
536 ::std::is_integral<T>::value,
537 "Incorrect type passed to function RoleType_Name.");
538 return QueuedMessageEntry_RoleType_Name(enum_t_value);
539 }
540 static inline bool RoleType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
541 RoleType* value) {
542 return QueuedMessageEntry_RoleType_Parse(name, value);
543 }
544
545 // accessors -------------------------------------------------------
546
547 enum : int {
548 kManipulatorFieldNumber = 10,
549 kRoleFieldNumber = 20,
550 kProtobufNameFieldNumber = 1,
551 kBlackoutTimeFieldNumber = 3,
552 kTtlFieldNumber = 6,
553 kAckFieldNumber = 2,
554 kNewestFirstFieldNumber = 5,
555 kMaxQueueFieldNumber = 4,
556 kValueBaseFieldNumber = 7,
557 };
558 // repeated .goby.acomms.protobuf.Manipulator manipulator = 10 [(.goby.field) = {
559 int manipulator_size() const;
560 private:
561 int _internal_manipulator_size() const;
562 public:
563 void clear_manipulator();
564 private:
565 ::goby::acomms::protobuf::Manipulator _internal_manipulator(int index) const;
566 void _internal_add_manipulator(::goby::acomms::protobuf::Manipulator value);
567 ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>* _internal_mutable_manipulator();
568 public:
569 ::goby::acomms::protobuf::Manipulator manipulator(int index) const;
570 void set_manipulator(int index, ::goby::acomms::protobuf::Manipulator value);
571 void add_manipulator(::goby::acomms::protobuf::Manipulator value);
572 const ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>& manipulator() const;
573 ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>* mutable_manipulator();
574
575 // repeated .goby.acomms.protobuf.QueuedMessageEntry.Role role = 20 [(.goby.field) = {
576 int role_size() const;
577 private:
578 int _internal_role_size() const;
579 public:
580 void clear_role();
582 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry_Role >*
583 mutable_role();
584 private:
585 const ::goby::acomms::protobuf::QueuedMessageEntry_Role& _internal_role(int index) const;
587 public:
588 const ::goby::acomms::protobuf::QueuedMessageEntry_Role& role(int index) const;
590 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry_Role >&
591 role() const;
592
593 // required string protobuf_name = 1;
594 bool has_protobuf_name() const;
595 private:
596 bool _internal_has_protobuf_name() const;
597 public:
598 void clear_protobuf_name();
599 const std::string& protobuf_name() const;
600 template <typename ArgT0 = const std::string&, typename... ArgT>
601 void set_protobuf_name(ArgT0&& arg0, ArgT... args);
602 std::string* mutable_protobuf_name();
603 PROTOBUF_NODISCARD std::string* release_protobuf_name();
604 void set_allocated_protobuf_name(std::string* protobuf_name);
605 private:
606 const std::string& _internal_protobuf_name() const;
607 inline PROTOBUF_ALWAYS_INLINE void _internal_set_protobuf_name(const std::string& value);
608 std::string* _internal_mutable_protobuf_name();
609 public:
610
611 // optional uint32 blackout_time = 3 [default = 0];
612 bool has_blackout_time() const;
613 private:
614 bool _internal_has_blackout_time() const;
615 public:
616 void clear_blackout_time();
617 uint32_t blackout_time() const;
618 void set_blackout_time(uint32_t value);
619 private:
620 uint32_t _internal_blackout_time() const;
621 void _internal_set_blackout_time(uint32_t value);
622 public:
623
624 // optional int32 ttl = 6 [default = 1800];
625 bool has_ttl() const;
626 private:
627 bool _internal_has_ttl() const;
628 public:
629 void clear_ttl();
630 int32_t ttl() const;
631 void set_ttl(int32_t value);
632 private:
633 int32_t _internal_ttl() const;
634 void _internal_set_ttl(int32_t value);
635 public:
636
637 // optional bool ack = 2 [default = true];
638 bool has_ack() const;
639 private:
640 bool _internal_has_ack() const;
641 public:
642 void clear_ack();
643 bool ack() const;
644 void set_ack(bool value);
645 private:
646 bool _internal_ack() const;
647 void _internal_set_ack(bool value);
648 public:
649
650 // optional bool newest_first = 5 [default = true];
651 bool has_newest_first() const;
652 private:
653 bool _internal_has_newest_first() const;
654 public:
655 void clear_newest_first();
656 bool newest_first() const;
657 void set_newest_first(bool value);
658 private:
659 bool _internal_newest_first() const;
660 void _internal_set_newest_first(bool value);
661 public:
662
663 // optional uint32 max_queue = 4 [default = 100];
664 bool has_max_queue() const;
665 private:
666 bool _internal_has_max_queue() const;
667 public:
668 void clear_max_queue();
669 uint32_t max_queue() const;
670 void set_max_queue(uint32_t value);
671 private:
672 uint32_t _internal_max_queue() const;
673 void _internal_set_max_queue(uint32_t value);
674 public:
675
676 // optional double value_base = 7 [default = 1];
677 bool has_value_base() const;
678 private:
679 bool _internal_has_value_base() const;
680 public:
681 void clear_value_base();
682 double value_base() const;
683 void set_value_base(double value);
684 private:
685 double _internal_value_base() const;
686 void _internal_set_value_base(double value);
687 public:
688
689 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueuedMessageEntry)
690 private:
691 class _Internal;
692
693 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
694 typedef void InternalArenaConstructable_;
695 typedef void DestructorSkippable_;
696 struct Impl_ {
697 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
698 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
699 ::PROTOBUF_NAMESPACE_ID::RepeatedField<int> manipulator_;
700 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry_Role > role_;
701 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr protobuf_name_;
702 uint32_t blackout_time_;
703 int32_t ttl_;
704 bool ack_;
705 bool newest_first_;
706 uint32_t max_queue_;
707 double value_base_;
708 };
709 union { Impl_ _impl_; };
710 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
711};
712// -------------------------------------------------------------------
713
715 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule) */ {
716 public:
719 explicit PROTOBUF_CONSTEXPR QueueManagerConfig_DCCLEncryptRule(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
720
726
728 CopyFrom(from);
729 return *this;
730 }
732 if (this == &from) return *this;
733 if (GetOwningArena() == from.GetOwningArena()
734 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
735 && GetOwningArena() != nullptr
736 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
737 ) {
738 InternalSwap(&from);
739 } else {
740 CopyFrom(from);
741 }
742 return *this;
743 }
744
745 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
746 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
747 }
748 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
749 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
750 }
751
752 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
753 return GetDescriptor();
754 }
755 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
756 return default_instance().GetMetadata().descriptor;
757 }
758 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
759 return default_instance().GetMetadata().reflection;
760 }
762 return *internal_default_instance();
763 }
768 static constexpr int kIndexInFileMessages =
769 2;
770
775 if (other == this) return;
776 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
777 if (GetOwningArena() != nullptr &&
778 GetOwningArena() == other->GetOwningArena()) {
779 #else // PROTOBUF_FORCE_COPY_IN_SWAP
780 if (GetOwningArena() == other->GetOwningArena()) {
781 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
782 InternalSwap(other);
783 } else {
784 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
785 }
786 }
788 if (other == this) return;
789 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
790 InternalSwap(other);
791 }
792
793 // implements Message ----------------------------------------------
794
795 QueueManagerConfig_DCCLEncryptRule* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
796 return CreateMaybeMessage<QueueManagerConfig_DCCLEncryptRule>(arena);
797 }
798 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
800 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
802 QueueManagerConfig_DCCLEncryptRule::MergeImpl(*this, from);
803 }
804 private:
805 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
806 public:
807 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
808 bool IsInitialized() const final;
809
810 size_t ByteSizeLong() const final;
811 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
812 uint8_t* _InternalSerialize(
813 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
814 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
815
816 private:
817 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
818 void SharedDtor();
819 void SetCachedSize(int size) const final;
820 void InternalSwap(QueueManagerConfig_DCCLEncryptRule* other);
821
822 private:
823 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
824 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
825 return "goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule";
826 }
827 protected:
828 explicit QueueManagerConfig_DCCLEncryptRule(::PROTOBUF_NAMESPACE_ID::Arena* arena,
829 bool is_message_owned = false);
830 public:
831
832 static const ClassData _class_data_;
833 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
834
835 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
836
837 // nested types ----------------------------------------------------
838
839 // accessors -------------------------------------------------------
840
841 enum : int {
842 kCryptoPassphraseFieldNumber = 2,
843 kIdFieldNumber = 1,
844 };
845 // required string crypto_passphrase = 2;
846 bool has_crypto_passphrase() const;
847 private:
848 bool _internal_has_crypto_passphrase() const;
849 public:
850 void clear_crypto_passphrase();
851 const std::string& crypto_passphrase() const;
852 template <typename ArgT0 = const std::string&, typename... ArgT>
853 void set_crypto_passphrase(ArgT0&& arg0, ArgT... args);
854 std::string* mutable_crypto_passphrase();
855 PROTOBUF_NODISCARD std::string* release_crypto_passphrase();
856 void set_allocated_crypto_passphrase(std::string* crypto_passphrase);
857 private:
858 const std::string& _internal_crypto_passphrase() const;
859 inline PROTOBUF_ALWAYS_INLINE void _internal_set_crypto_passphrase(const std::string& value);
860 std::string* _internal_mutable_crypto_passphrase();
861 public:
862
863 // optional int32 id = 1;
864 bool has_id() const;
865 private:
866 bool _internal_has_id() const;
867 public:
868 void clear_id();
869 int32_t id() const;
870 void set_id(int32_t value);
871 private:
872 int32_t _internal_id() const;
873 void _internal_set_id(int32_t value);
874 public:
875
876 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule)
877 private:
878 class _Internal;
879
880 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
881 typedef void InternalArenaConstructable_;
882 typedef void DestructorSkippable_;
883 struct Impl_ {
884 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
885 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
886 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr crypto_passphrase_;
887 int32_t id_;
888 };
889 union { Impl_ _impl_; };
890 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
891};
892// -------------------------------------------------------------------
893
895 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueueManagerConfig) */ {
896 public:
899 explicit PROTOBUF_CONSTEXPR QueueManagerConfig(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
900
904 *this = ::std::move(from);
905 }
906
908 CopyFrom(from);
909 return *this;
910 }
912 if (this == &from) return *this;
913 if (GetOwningArena() == from.GetOwningArena()
914 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
915 && GetOwningArena() != nullptr
916 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
917 ) {
918 InternalSwap(&from);
919 } else {
920 CopyFrom(from);
921 }
922 return *this;
923 }
924
925 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
926 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
927 }
928 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
929 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
930 }
931
932 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
933 return GetDescriptor();
934 }
935 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
936 return default_instance().GetMetadata().descriptor;
937 }
938 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
939 return default_instance().GetMetadata().reflection;
940 }
942 return *internal_default_instance();
943 }
945 return reinterpret_cast<const QueueManagerConfig*>(
947 }
948 static constexpr int kIndexInFileMessages =
949 3;
950
952 a.Swap(&b);
953 }
954 inline void Swap(QueueManagerConfig* other) {
955 if (other == this) return;
956 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
957 if (GetOwningArena() != nullptr &&
958 GetOwningArena() == other->GetOwningArena()) {
959 #else // PROTOBUF_FORCE_COPY_IN_SWAP
960 if (GetOwningArena() == other->GetOwningArena()) {
961 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
962 InternalSwap(other);
963 } else {
964 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
965 }
966 }
968 if (other == this) return;
969 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
970 InternalSwap(other);
971 }
972
973 // implements Message ----------------------------------------------
974
975 QueueManagerConfig* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
976 return CreateMaybeMessage<QueueManagerConfig>(arena);
977 }
978 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
979 void CopyFrom(const QueueManagerConfig& from);
980 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
981 void MergeFrom( const QueueManagerConfig& from) {
982 QueueManagerConfig::MergeImpl(*this, from);
983 }
984 private:
985 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
986 public:
987 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
988 bool IsInitialized() const final;
989
990 size_t ByteSizeLong() const final;
991 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
992 uint8_t* _InternalSerialize(
993 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
994 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
995
996 private:
997 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
998 void SharedDtor();
999 void SetCachedSize(int size) const final;
1000 void InternalSwap(QueueManagerConfig* other);
1001
1002 private:
1003 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1004 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1005 return "goby.acomms.protobuf.QueueManagerConfig";
1006 }
1007 protected:
1008 explicit QueueManagerConfig(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1009 bool is_message_owned = false);
1010 public:
1011
1012 static const ClassData _class_data_;
1013 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
1014
1015 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1016
1017 // nested types ----------------------------------------------------
1018
1020
1021 // accessors -------------------------------------------------------
1022
1023 enum : int {
1024 kMessageEntryFieldNumber = 10,
1025 kMakeNetworkAckForSrcIdFieldNumber = 30,
1026 kRouteForAdditionalModemIdFieldNumber = 40,
1027 kEncryptRuleFieldNumber = 50,
1028 kModemIdFieldNumber = 1,
1029 kSkipDecodingFieldNumber = 21,
1030 kMinimumAckWaitSecondsFieldNumber = 20,
1031 kOnDemandSkewSecondsFieldNumber = 11,
1032 };
1033 // repeated .goby.acomms.protobuf.QueuedMessageEntry message_entry = 10;
1034 int message_entry_size() const;
1035 private:
1036 int _internal_message_entry_size() const;
1037 public:
1038 void clear_message_entry();
1039 ::goby::acomms::protobuf::QueuedMessageEntry* mutable_message_entry(int index);
1040 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry >*
1041 mutable_message_entry();
1042 private:
1043 const ::goby::acomms::protobuf::QueuedMessageEntry& _internal_message_entry(int index) const;
1044 ::goby::acomms::protobuf::QueuedMessageEntry* _internal_add_message_entry();
1045 public:
1046 const ::goby::acomms::protobuf::QueuedMessageEntry& message_entry(int index) const;
1048 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry >&
1049 message_entry() const;
1050
1051 // repeated int32 make_network_ack_for_src_id = 30;
1052 int make_network_ack_for_src_id_size() const;
1053 private:
1054 int _internal_make_network_ack_for_src_id_size() const;
1055 public:
1056 void clear_make_network_ack_for_src_id();
1057 private:
1058 int32_t _internal_make_network_ack_for_src_id(int index) const;
1059 const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
1060 _internal_make_network_ack_for_src_id() const;
1061 void _internal_add_make_network_ack_for_src_id(int32_t value);
1062 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
1063 _internal_mutable_make_network_ack_for_src_id();
1064 public:
1065 int32_t make_network_ack_for_src_id(int index) const;
1066 void set_make_network_ack_for_src_id(int index, int32_t value);
1067 void add_make_network_ack_for_src_id(int32_t value);
1068 const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
1069 make_network_ack_for_src_id() const;
1070 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
1071 mutable_make_network_ack_for_src_id();
1072
1073 // repeated int32 route_for_additional_modem_id = 40 [(.goby.field) = {
1074 int route_for_additional_modem_id_size() const;
1075 private:
1076 int _internal_route_for_additional_modem_id_size() const;
1077 public:
1078 void clear_route_for_additional_modem_id();
1079 private:
1080 int32_t _internal_route_for_additional_modem_id(int index) const;
1081 const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
1082 _internal_route_for_additional_modem_id() const;
1083 void _internal_add_route_for_additional_modem_id(int32_t value);
1084 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
1085 _internal_mutable_route_for_additional_modem_id();
1086 public:
1087 int32_t route_for_additional_modem_id(int index) const;
1088 void set_route_for_additional_modem_id(int index, int32_t value);
1089 void add_route_for_additional_modem_id(int32_t value);
1090 const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
1091 route_for_additional_modem_id() const;
1092 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
1093 mutable_route_for_additional_modem_id();
1094
1095 // repeated .goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule encrypt_rule = 50;
1096 int encrypt_rule_size() const;
1097 private:
1098 int _internal_encrypt_rule_size() const;
1099 public:
1100 void clear_encrypt_rule();
1101 ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* mutable_encrypt_rule(int index);
1102 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule >*
1103 mutable_encrypt_rule();
1104 private:
1105 const ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule& _internal_encrypt_rule(int index) const;
1107 public:
1108 const ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule& encrypt_rule(int index) const;
1110 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule >&
1111 encrypt_rule() const;
1112
1113 // optional int32 modem_id = 1 [(.goby.field) = {
1114 bool has_modem_id() const;
1115 private:
1116 bool _internal_has_modem_id() const;
1117 public:
1118 void clear_modem_id();
1119 int32_t modem_id() const;
1120 void set_modem_id(int32_t value);
1121 private:
1122 int32_t _internal_modem_id() const;
1123 void _internal_set_modem_id(int32_t value);
1124 public:
1125
1126 // optional bool skip_decoding = 21 [default = false, (.goby.field) = {
1127 bool has_skip_decoding() const;
1128 private:
1129 bool _internal_has_skip_decoding() const;
1130 public:
1131 void clear_skip_decoding();
1132 bool skip_decoding() const;
1133 void set_skip_decoding(bool value);
1134 private:
1135 bool _internal_skip_decoding() const;
1136 void _internal_set_skip_decoding(bool value);
1137 public:
1138
1139 // optional double minimum_ack_wait_seconds = 20 [default = 0];
1140 bool has_minimum_ack_wait_seconds() const;
1141 private:
1142 bool _internal_has_minimum_ack_wait_seconds() const;
1143 public:
1144 void clear_minimum_ack_wait_seconds();
1145 double minimum_ack_wait_seconds() const;
1146 void set_minimum_ack_wait_seconds(double value);
1147 private:
1148 double _internal_minimum_ack_wait_seconds() const;
1149 void _internal_set_minimum_ack_wait_seconds(double value);
1150 public:
1151
1152 // optional double on_demand_skew_seconds = 11 [default = 1];
1153 bool has_on_demand_skew_seconds() const;
1154 private:
1155 bool _internal_has_on_demand_skew_seconds() const;
1156 public:
1157 void clear_on_demand_skew_seconds();
1158 double on_demand_skew_seconds() const;
1159 void set_on_demand_skew_seconds(double value);
1160 private:
1161 double _internal_on_demand_skew_seconds() const;
1162 void _internal_set_on_demand_skew_seconds(double value);
1163 public:
1164
1165 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueueManagerConfig)
1166 private:
1167 class _Internal;
1168
1169 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1170 typedef void InternalArenaConstructable_;
1171 typedef void DestructorSkippable_;
1172 struct Impl_ {
1173 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1174 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1175 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry > message_entry_;
1176 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t > make_network_ack_for_src_id_;
1177 ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t > route_for_additional_modem_id_;
1178 ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule > encrypt_rule_;
1179 int32_t modem_id_;
1180 bool skip_decoding_;
1181 double minimum_ack_wait_seconds_;
1182 double on_demand_skew_seconds_;
1183 };
1184 union { Impl_ _impl_; };
1185 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
1186};
1187// -------------------------------------------------------------------
1188
1189class QueueSize final :
1190 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueueSize) */ {
1191 public:
1192 inline QueueSize() : QueueSize(nullptr) {}
1193 ~QueueSize() override;
1194 explicit PROTOBUF_CONSTEXPR QueueSize(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
1195
1196 QueueSize(const QueueSize& from);
1197 QueueSize(QueueSize&& from) noexcept
1198 : QueueSize() {
1199 *this = ::std::move(from);
1200 }
1201
1202 inline QueueSize& operator=(const QueueSize& from) {
1203 CopyFrom(from);
1204 return *this;
1205 }
1206 inline QueueSize& operator=(QueueSize&& from) noexcept {
1207 if (this == &from) return *this;
1208 if (GetOwningArena() == from.GetOwningArena()
1209 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1210 && GetOwningArena() != nullptr
1211 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1212 ) {
1213 InternalSwap(&from);
1214 } else {
1215 CopyFrom(from);
1216 }
1217 return *this;
1218 }
1219
1220 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
1221 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1222 }
1223 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
1224 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1225 }
1226
1227 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
1228 return GetDescriptor();
1229 }
1230 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
1231 return default_instance().GetMetadata().descriptor;
1232 }
1233 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
1234 return default_instance().GetMetadata().reflection;
1235 }
1236 static const QueueSize& default_instance() {
1237 return *internal_default_instance();
1238 }
1239 static inline const QueueSize* internal_default_instance() {
1240 return reinterpret_cast<const QueueSize*>(
1242 }
1243 static constexpr int kIndexInFileMessages =
1244 4;
1245
1246 friend void swap(QueueSize& a, QueueSize& b) {
1247 a.Swap(&b);
1248 }
1249 inline void Swap(QueueSize* other) {
1250 if (other == this) return;
1251 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1252 if (GetOwningArena() != nullptr &&
1253 GetOwningArena() == other->GetOwningArena()) {
1254 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1255 if (GetOwningArena() == other->GetOwningArena()) {
1256 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1257 InternalSwap(other);
1258 } else {
1259 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
1260 }
1261 }
1263 if (other == this) return;
1264 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
1265 InternalSwap(other);
1266 }
1267
1268 // implements Message ----------------------------------------------
1269
1270 QueueSize* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
1271 return CreateMaybeMessage<QueueSize>(arena);
1272 }
1273 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
1274 void CopyFrom(const QueueSize& from);
1275 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
1276 void MergeFrom( const QueueSize& from) {
1277 QueueSize::MergeImpl(*this, from);
1278 }
1279 private:
1280 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
1281 public:
1282 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1283 bool IsInitialized() const final;
1284
1285 size_t ByteSizeLong() const final;
1286 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
1287 uint8_t* _InternalSerialize(
1288 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1289 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1290
1291 private:
1292 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
1293 void SharedDtor();
1294 void SetCachedSize(int size) const final;
1295 void InternalSwap(QueueSize* other);
1296
1297 private:
1298 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1299 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1300 return "goby.acomms.protobuf.QueueSize";
1301 }
1302 protected:
1303 explicit QueueSize(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1304 bool is_message_owned = false);
1305 public:
1306
1307 static const ClassData _class_data_;
1308 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
1309
1310 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1311
1312 // nested types ----------------------------------------------------
1313
1314 // accessors -------------------------------------------------------
1315
1316 enum : int {
1317 kDcclIdFieldNumber = 1,
1318 kSizeFieldNumber = 2,
1319 };
1320 // required uint32 dccl_id = 1;
1321 bool has_dccl_id() const;
1322 private:
1323 bool _internal_has_dccl_id() const;
1324 public:
1325 void clear_dccl_id();
1326 uint32_t dccl_id() const;
1327 void set_dccl_id(uint32_t value);
1328 private:
1329 uint32_t _internal_dccl_id() const;
1330 void _internal_set_dccl_id(uint32_t value);
1331 public:
1332
1333 // required uint32 size = 2;
1334 bool has_size() const;
1335 private:
1336 bool _internal_has_size() const;
1337 public:
1338 void clear_size();
1339 uint32_t size() const;
1340 void set_size(uint32_t value);
1341 private:
1342 uint32_t _internal_size() const;
1343 void _internal_set_size(uint32_t value);
1344 public:
1345
1346 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueueSize)
1347 private:
1348 class _Internal;
1349
1350 // helper for ByteSizeLong()
1351 size_t RequiredFieldsByteSizeFallback() const;
1352
1353 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1354 typedef void InternalArenaConstructable_;
1355 typedef void DestructorSkippable_;
1356 struct Impl_ {
1357 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1358 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1359 uint32_t dccl_id_;
1360 uint32_t size_;
1361 };
1362 union { Impl_ _impl_; };
1363 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
1364};
1365// -------------------------------------------------------------------
1366
1367class QueueFlush final :
1368 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueueFlush) */ {
1369 public:
1370 inline QueueFlush() : QueueFlush(nullptr) {}
1371 ~QueueFlush() override;
1372 explicit PROTOBUF_CONSTEXPR QueueFlush(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
1373
1375 QueueFlush(QueueFlush&& from) noexcept
1376 : QueueFlush() {
1377 *this = ::std::move(from);
1378 }
1379
1380 inline QueueFlush& operator=(const QueueFlush& from) {
1381 CopyFrom(from);
1382 return *this;
1383 }
1384 inline QueueFlush& operator=(QueueFlush&& from) noexcept {
1385 if (this == &from) return *this;
1386 if (GetOwningArena() == from.GetOwningArena()
1387 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1388 && GetOwningArena() != nullptr
1389 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1390 ) {
1391 InternalSwap(&from);
1392 } else {
1393 CopyFrom(from);
1394 }
1395 return *this;
1396 }
1397
1398 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
1399 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1400 }
1401 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
1402 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1403 }
1404
1405 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
1406 return GetDescriptor();
1407 }
1408 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
1409 return default_instance().GetMetadata().descriptor;
1410 }
1411 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
1412 return default_instance().GetMetadata().reflection;
1413 }
1415 return *internal_default_instance();
1416 }
1417 static inline const QueueFlush* internal_default_instance() {
1418 return reinterpret_cast<const QueueFlush*>(
1420 }
1421 static constexpr int kIndexInFileMessages =
1422 5;
1423
1424 friend void swap(QueueFlush& a, QueueFlush& b) {
1425 a.Swap(&b);
1426 }
1427 inline void Swap(QueueFlush* other) {
1428 if (other == this) return;
1429 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1430 if (GetOwningArena() != nullptr &&
1431 GetOwningArena() == other->GetOwningArena()) {
1432 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1433 if (GetOwningArena() == other->GetOwningArena()) {
1434 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1435 InternalSwap(other);
1436 } else {
1437 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
1438 }
1439 }
1441 if (other == this) return;
1442 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
1443 InternalSwap(other);
1444 }
1445
1446 // implements Message ----------------------------------------------
1447
1448 QueueFlush* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
1449 return CreateMaybeMessage<QueueFlush>(arena);
1450 }
1451 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
1452 void CopyFrom(const QueueFlush& from);
1453 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
1454 void MergeFrom( const QueueFlush& from) {
1455 QueueFlush::MergeImpl(*this, from);
1456 }
1457 private:
1458 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
1459 public:
1460 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1461 bool IsInitialized() const final;
1462
1463 size_t ByteSizeLong() const final;
1464 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
1465 uint8_t* _InternalSerialize(
1466 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1467 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1468
1469 private:
1470 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
1471 void SharedDtor();
1472 void SetCachedSize(int size) const final;
1473 void InternalSwap(QueueFlush* other);
1474
1475 private:
1476 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1477 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1478 return "goby.acomms.protobuf.QueueFlush";
1479 }
1480 protected:
1481 explicit QueueFlush(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1482 bool is_message_owned = false);
1483 public:
1484
1485 static const ClassData _class_data_;
1486 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
1487
1488 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1489
1490 // nested types ----------------------------------------------------
1491
1492 // accessors -------------------------------------------------------
1493
1494 enum : int {
1495 kDcclIdFieldNumber = 1,
1496 };
1497 // required uint32 dccl_id = 1;
1498 bool has_dccl_id() const;
1499 private:
1500 bool _internal_has_dccl_id() const;
1501 public:
1502 void clear_dccl_id();
1503 uint32_t dccl_id() const;
1504 void set_dccl_id(uint32_t value);
1505 private:
1506 uint32_t _internal_dccl_id() const;
1507 void _internal_set_dccl_id(uint32_t value);
1508 public:
1509
1510 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueueFlush)
1511 private:
1512 class _Internal;
1513
1514 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1515 typedef void InternalArenaConstructable_;
1516 typedef void DestructorSkippable_;
1517 struct Impl_ {
1518 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1519 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1520 uint32_t dccl_id_;
1521 };
1522 union { Impl_ _impl_; };
1523 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
1524};
1525// -------------------------------------------------------------------
1526
1528 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.acomms.protobuf.QueuedMessageMeta) */ {
1529 public:
1532 explicit PROTOBUF_CONSTEXPR QueuedMessageMeta(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
1533
1536 : QueuedMessageMeta() {
1537 *this = ::std::move(from);
1538 }
1539
1541 CopyFrom(from);
1542 return *this;
1543 }
1545 if (this == &from) return *this;
1546 if (GetOwningArena() == from.GetOwningArena()
1547 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1548 && GetOwningArena() != nullptr
1549 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1550 ) {
1551 InternalSwap(&from);
1552 } else {
1553 CopyFrom(from);
1554 }
1555 return *this;
1556 }
1557
1558 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
1559 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1560 }
1561 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
1562 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1563 }
1564
1565 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
1566 return GetDescriptor();
1567 }
1568 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
1569 return default_instance().GetMetadata().descriptor;
1570 }
1571 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
1572 return default_instance().GetMetadata().reflection;
1573 }
1575 return *internal_default_instance();
1576 }
1578 return reinterpret_cast<const QueuedMessageMeta*>(
1580 }
1581 static constexpr int kIndexInFileMessages =
1582 6;
1583
1585 a.Swap(&b);
1586 }
1587 inline void Swap(QueuedMessageMeta* other) {
1588 if (other == this) return;
1589 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1590 if (GetOwningArena() != nullptr &&
1591 GetOwningArena() == other->GetOwningArena()) {
1592 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1593 if (GetOwningArena() == other->GetOwningArena()) {
1594 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1595 InternalSwap(other);
1596 } else {
1597 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
1598 }
1599 }
1601 if (other == this) return;
1602 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
1603 InternalSwap(other);
1604 }
1605
1606 // implements Message ----------------------------------------------
1607
1608 QueuedMessageMeta* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
1609 return CreateMaybeMessage<QueuedMessageMeta>(arena);
1610 }
1611 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
1612 void CopyFrom(const QueuedMessageMeta& from);
1613 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
1614 void MergeFrom( const QueuedMessageMeta& from) {
1615 QueuedMessageMeta::MergeImpl(*this, from);
1616 }
1617 private:
1618 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
1619 public:
1620 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1621 bool IsInitialized() const final;
1622
1623 size_t ByteSizeLong() const final;
1624 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
1625 uint8_t* _InternalSerialize(
1626 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1627 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1628
1629 private:
1630 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
1631 void SharedDtor();
1632 void SetCachedSize(int size) const final;
1633 void InternalSwap(QueuedMessageMeta* other);
1634
1635 private:
1636 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1637 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1638 return "goby.acomms.protobuf.QueuedMessageMeta";
1639 }
1640 protected:
1641 explicit QueuedMessageMeta(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1642 bool is_message_owned = false);
1643 public:
1644
1645 static const ClassData _class_data_;
1646 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
1647
1648 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1649
1650 // nested types ----------------------------------------------------
1651
1652 // accessors -------------------------------------------------------
1653
1654 enum : int {
1655 kEncodedMessageFieldNumber = 20,
1656 kNonRepeatedSizeFieldNumber = 1,
1657 kAckRequestedFieldNumber = 2,
1658 kSrcFieldNumber = 3,
1659 kDestFieldNumber = 4,
1660 kTimeFieldNumber = 5,
1661 kLastSentTimeFieldNumber = 10,
1662 };
1663 // optional bytes encoded_message = 20;
1664 bool has_encoded_message() const;
1665 private:
1666 bool _internal_has_encoded_message() const;
1667 public:
1668 void clear_encoded_message();
1669 const std::string& encoded_message() const;
1670 template <typename ArgT0 = const std::string&, typename... ArgT>
1671 void set_encoded_message(ArgT0&& arg0, ArgT... args);
1672 std::string* mutable_encoded_message();
1673 PROTOBUF_NODISCARD std::string* release_encoded_message();
1674 void set_allocated_encoded_message(std::string* encoded_message);
1675 private:
1676 const std::string& _internal_encoded_message() const;
1677 inline PROTOBUF_ALWAYS_INLINE void _internal_set_encoded_message(const std::string& value);
1678 std::string* _internal_mutable_encoded_message();
1679 public:
1680
1681 // optional uint32 non_repeated_size = 1;
1682 bool has_non_repeated_size() const;
1683 private:
1684 bool _internal_has_non_repeated_size() const;
1685 public:
1686 void clear_non_repeated_size();
1687 uint32_t non_repeated_size() const;
1688 void set_non_repeated_size(uint32_t value);
1689 private:
1690 uint32_t _internal_non_repeated_size() const;
1691 void _internal_set_non_repeated_size(uint32_t value);
1692 public:
1693
1694 // optional bool ack_requested = 2;
1695 bool has_ack_requested() const;
1696 private:
1697 bool _internal_has_ack_requested() const;
1698 public:
1699 void clear_ack_requested();
1700 bool ack_requested() const;
1701 void set_ack_requested(bool value);
1702 private:
1703 bool _internal_ack_requested() const;
1704 void _internal_set_ack_requested(bool value);
1705 public:
1706
1707 // optional int32 src = 3;
1708 bool has_src() const;
1709 private:
1710 bool _internal_has_src() const;
1711 public:
1712 void clear_src();
1713 int32_t src() const;
1714 void set_src(int32_t value);
1715 private:
1716 int32_t _internal_src() const;
1717 void _internal_set_src(int32_t value);
1718 public:
1719
1720 // optional int32 dest = 4;
1721 bool has_dest() const;
1722 private:
1723 bool _internal_has_dest() const;
1724 public:
1725 void clear_dest();
1726 int32_t dest() const;
1727 void set_dest(int32_t value);
1728 private:
1729 int32_t _internal_dest() const;
1730 void _internal_set_dest(int32_t value);
1731 public:
1732
1733 // optional uint64 time = 5 [(.dccl.field) = {
1734 bool has_time() const;
1735 private:
1736 bool _internal_has_time() const;
1737 public:
1738 void clear_time();
1739 uint64_t time() const;
1740 void set_time(uint64_t value);
1741 private:
1742 uint64_t _internal_time() const;
1743 void _internal_set_time(uint64_t value);
1744 public:
1745
1746 // optional uint64 last_sent_time = 10 [(.dccl.field) = {
1747 bool has_last_sent_time() const;
1748 private:
1749 bool _internal_has_last_sent_time() const;
1750 public:
1751 void clear_last_sent_time();
1752 uint64_t last_sent_time() const;
1753 void set_last_sent_time(uint64_t value);
1754 private:
1755 uint64_t _internal_last_sent_time() const;
1756 void _internal_set_last_sent_time(uint64_t value);
1757 public:
1758
1759 typedef boost::units::derived_dimension< boost::units::time_base_dimension,1 >::type time_dimension;
1760
1761 typedef boost::units::make_scaled_unit<boost::units::unit<time_dimension,boost::units::si::system> , boost::units::scale<10, boost::units::static_rational<-6> > >::type time_unit;
1762
1763 template<typename Quantity >
1764 void set_time_with_units(Quantity value_w_units)
1765 { set_time(boost::units::quantity<time_unit,google::protobuf::uint64 >(value_w_units).value() ); };
1766
1767 template<typename Quantity >
1768 Quantity time_with_units() const
1769 { return Quantity(time() * time_unit()); };
1770
1771 boost::units::quantity< time_unit,google::protobuf::uint64 > time_with_units() const
1772 { return time_with_units<boost::units::quantity< time_unit,google::protobuf::uint64 > >(); };
1773
1774 typedef boost::units::derived_dimension< boost::units::time_base_dimension,1 >::type last_sent_time_dimension;
1775
1776 typedef boost::units::make_scaled_unit<boost::units::unit<last_sent_time_dimension,boost::units::si::system> , boost::units::scale<10, boost::units::static_rational<-6> > >::type last_sent_time_unit;
1777
1778 template<typename Quantity >
1779 void set_last_sent_time_with_units(Quantity value_w_units)
1780 { set_last_sent_time(boost::units::quantity<last_sent_time_unit,google::protobuf::uint64 >(value_w_units).value() ); };
1781
1782 template<typename Quantity >
1784 { return Quantity(last_sent_time() * last_sent_time_unit()); };
1785
1786 boost::units::quantity< last_sent_time_unit,google::protobuf::uint64 > last_sent_time_with_units() const
1787 { return last_sent_time_with_units<boost::units::quantity< last_sent_time_unit,google::protobuf::uint64 > >(); };
1788
1789 // @@protoc_insertion_point(class_scope:goby.acomms.protobuf.QueuedMessageMeta)
1790 private:
1791 class _Internal;
1792
1793 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1794 typedef void InternalArenaConstructable_;
1795 typedef void DestructorSkippable_;
1796 struct Impl_ {
1797 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1798 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1799 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr encoded_message_;
1800 uint32_t non_repeated_size_;
1801 bool ack_requested_;
1802 int32_t src_;
1803 int32_t dest_;
1804 uint64_t time_;
1805 uint64_t last_sent_time_;
1806 };
1807 union { Impl_ _impl_; };
1808 friend struct ::TableStruct_goby_2facomms_2fprotobuf_2fqueue_2eproto;
1809};
1810// ===================================================================
1811
1812
1813// ===================================================================
1814
1815#ifdef __GNUC__
1816 #pragma GCC diagnostic push
1817 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
1818#endif // __GNUC__
1819// QueuedMessageEntry_Role
1820
1821// required .goby.acomms.protobuf.QueuedMessageEntry.RoleType type = 1;
1822inline bool QueuedMessageEntry_Role::_internal_has_type() const {
1823 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
1824 return value;
1825}
1826inline bool QueuedMessageEntry_Role::has_type() const {
1827 return _internal_has_type();
1828}
1829inline void QueuedMessageEntry_Role::clear_type() {
1830 _impl_.type_ = 1;
1831 _impl_._has_bits_[0] &= ~0x00000004u;
1832}
1833inline ::goby::acomms::protobuf::QueuedMessageEntry_RoleType QueuedMessageEntry_Role::_internal_type() const {
1834 return static_cast< ::goby::acomms::protobuf::QueuedMessageEntry_RoleType >(_impl_.type_);
1835}
1836inline ::goby::acomms::protobuf::QueuedMessageEntry_RoleType QueuedMessageEntry_Role::type() const {
1837 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.Role.type)
1838 return _internal_type();
1839}
1840inline void QueuedMessageEntry_Role::_internal_set_type(::goby::acomms::protobuf::QueuedMessageEntry_RoleType value) {
1842 _impl_._has_bits_[0] |= 0x00000004u;
1843 _impl_.type_ = value;
1844}
1845inline void QueuedMessageEntry_Role::set_type(::goby::acomms::protobuf::QueuedMessageEntry_RoleType value) {
1846 _internal_set_type(value);
1847 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.Role.type)
1848}
1849
1850// optional .goby.acomms.protobuf.QueuedMessageEntry.Role.RoleSetting setting = 2 [default = FIELD_VALUE];
1851inline bool QueuedMessageEntry_Role::_internal_has_setting() const {
1852 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
1853 return value;
1854}
1855inline bool QueuedMessageEntry_Role::has_setting() const {
1856 return _internal_has_setting();
1857}
1858inline void QueuedMessageEntry_Role::clear_setting() {
1859 _impl_.setting_ = 2;
1860 _impl_._has_bits_[0] &= ~0x00000008u;
1861}
1862inline ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting QueuedMessageEntry_Role::_internal_setting() const {
1863 return static_cast< ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting >(_impl_.setting_);
1864}
1865inline ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting QueuedMessageEntry_Role::setting() const {
1866 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.Role.setting)
1867 return _internal_setting();
1868}
1869inline void QueuedMessageEntry_Role::_internal_set_setting(::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting value) {
1871 _impl_._has_bits_[0] |= 0x00000008u;
1872 _impl_.setting_ = value;
1873}
1874inline void QueuedMessageEntry_Role::set_setting(::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting value) {
1875 _internal_set_setting(value);
1876 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.Role.setting)
1877}
1878
1879// optional string field = 3;
1880inline bool QueuedMessageEntry_Role::_internal_has_field() const {
1881 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1882 return value;
1883}
1884inline bool QueuedMessageEntry_Role::has_field() const {
1885 return _internal_has_field();
1886}
1887inline void QueuedMessageEntry_Role::clear_field() {
1888 _impl_.field_.ClearToEmpty();
1889 _impl_._has_bits_[0] &= ~0x00000001u;
1890}
1891inline const std::string& QueuedMessageEntry_Role::field() const {
1892 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.Role.field)
1893 return _internal_field();
1894}
1895template <typename ArgT0, typename... ArgT>
1896inline PROTOBUF_ALWAYS_INLINE
1897void QueuedMessageEntry_Role::set_field(ArgT0&& arg0, ArgT... args) {
1898 _impl_._has_bits_[0] |= 0x00000001u;
1899 _impl_.field_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1900 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.Role.field)
1901}
1902inline std::string* QueuedMessageEntry_Role::mutable_field() {
1903 std::string* _s = _internal_mutable_field();
1904 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueuedMessageEntry.Role.field)
1905 return _s;
1906}
1907inline const std::string& QueuedMessageEntry_Role::_internal_field() const {
1908 return _impl_.field_.Get();
1909}
1910inline void QueuedMessageEntry_Role::_internal_set_field(const std::string& value) {
1911 _impl_._has_bits_[0] |= 0x00000001u;
1912 _impl_.field_.Set(value, GetArenaForAllocation());
1913}
1914inline std::string* QueuedMessageEntry_Role::_internal_mutable_field() {
1915 _impl_._has_bits_[0] |= 0x00000001u;
1916 return _impl_.field_.Mutable(GetArenaForAllocation());
1917}
1918inline std::string* QueuedMessageEntry_Role::release_field() {
1919 // @@protoc_insertion_point(field_release:goby.acomms.protobuf.QueuedMessageEntry.Role.field)
1920 if (!_internal_has_field()) {
1921 return nullptr;
1922 }
1923 _impl_._has_bits_[0] &= ~0x00000001u;
1924 auto* p = _impl_.field_.Release();
1925#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1926 if (_impl_.field_.IsDefault()) {
1927 _impl_.field_.Set("", GetArenaForAllocation());
1928 }
1929#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1930 return p;
1931}
1932inline void QueuedMessageEntry_Role::set_allocated_field(std::string* field) {
1933 if (field != nullptr) {
1934 _impl_._has_bits_[0] |= 0x00000001u;
1935 } else {
1936 _impl_._has_bits_[0] &= ~0x00000001u;
1937 }
1938 _impl_.field_.SetAllocated(field, GetArenaForAllocation());
1939#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1940 if (_impl_.field_.IsDefault()) {
1941 _impl_.field_.Set("", GetArenaForAllocation());
1942 }
1943#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1944 // @@protoc_insertion_point(field_set_allocated:goby.acomms.protobuf.QueuedMessageEntry.Role.field)
1945}
1946
1947// optional int32 static_value = 4;
1948inline bool QueuedMessageEntry_Role::_internal_has_static_value() const {
1949 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
1950 return value;
1951}
1952inline bool QueuedMessageEntry_Role::has_static_value() const {
1953 return _internal_has_static_value();
1954}
1955inline void QueuedMessageEntry_Role::clear_static_value() {
1956 _impl_.static_value_ = 0;
1957 _impl_._has_bits_[0] &= ~0x00000002u;
1958}
1959inline int32_t QueuedMessageEntry_Role::_internal_static_value() const {
1960 return _impl_.static_value_;
1961}
1962inline int32_t QueuedMessageEntry_Role::static_value() const {
1963 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.Role.static_value)
1964 return _internal_static_value();
1965}
1966inline void QueuedMessageEntry_Role::_internal_set_static_value(int32_t value) {
1967 _impl_._has_bits_[0] |= 0x00000002u;
1968 _impl_.static_value_ = value;
1969}
1970inline void QueuedMessageEntry_Role::set_static_value(int32_t value) {
1971 _internal_set_static_value(value);
1972 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.Role.static_value)
1973}
1974
1975// -------------------------------------------------------------------
1976
1977// QueuedMessageEntry
1978
1979// required string protobuf_name = 1;
1980inline bool QueuedMessageEntry::_internal_has_protobuf_name() const {
1981 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1982 return value;
1983}
1984inline bool QueuedMessageEntry::has_protobuf_name() const {
1985 return _internal_has_protobuf_name();
1986}
1987inline void QueuedMessageEntry::clear_protobuf_name() {
1988 _impl_.protobuf_name_.ClearToEmpty();
1989 _impl_._has_bits_[0] &= ~0x00000001u;
1990}
1991inline const std::string& QueuedMessageEntry::protobuf_name() const {
1992 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.protobuf_name)
1993 return _internal_protobuf_name();
1994}
1995template <typename ArgT0, typename... ArgT>
1996inline PROTOBUF_ALWAYS_INLINE
1997void QueuedMessageEntry::set_protobuf_name(ArgT0&& arg0, ArgT... args) {
1998 _impl_._has_bits_[0] |= 0x00000001u;
1999 _impl_.protobuf_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
2000 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.protobuf_name)
2001}
2002inline std::string* QueuedMessageEntry::mutable_protobuf_name() {
2003 std::string* _s = _internal_mutable_protobuf_name();
2004 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueuedMessageEntry.protobuf_name)
2005 return _s;
2006}
2007inline const std::string& QueuedMessageEntry::_internal_protobuf_name() const {
2008 return _impl_.protobuf_name_.Get();
2009}
2010inline void QueuedMessageEntry::_internal_set_protobuf_name(const std::string& value) {
2011 _impl_._has_bits_[0] |= 0x00000001u;
2012 _impl_.protobuf_name_.Set(value, GetArenaForAllocation());
2013}
2014inline std::string* QueuedMessageEntry::_internal_mutable_protobuf_name() {
2015 _impl_._has_bits_[0] |= 0x00000001u;
2016 return _impl_.protobuf_name_.Mutable(GetArenaForAllocation());
2017}
2018inline std::string* QueuedMessageEntry::release_protobuf_name() {
2019 // @@protoc_insertion_point(field_release:goby.acomms.protobuf.QueuedMessageEntry.protobuf_name)
2020 if (!_internal_has_protobuf_name()) {
2021 return nullptr;
2022 }
2023 _impl_._has_bits_[0] &= ~0x00000001u;
2024 auto* p = _impl_.protobuf_name_.Release();
2025#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2026 if (_impl_.protobuf_name_.IsDefault()) {
2027 _impl_.protobuf_name_.Set("", GetArenaForAllocation());
2028 }
2029#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2030 return p;
2031}
2032inline void QueuedMessageEntry::set_allocated_protobuf_name(std::string* protobuf_name) {
2033 if (protobuf_name != nullptr) {
2034 _impl_._has_bits_[0] |= 0x00000001u;
2035 } else {
2036 _impl_._has_bits_[0] &= ~0x00000001u;
2037 }
2038 _impl_.protobuf_name_.SetAllocated(protobuf_name, GetArenaForAllocation());
2039#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2040 if (_impl_.protobuf_name_.IsDefault()) {
2041 _impl_.protobuf_name_.Set("", GetArenaForAllocation());
2042 }
2043#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2044 // @@protoc_insertion_point(field_set_allocated:goby.acomms.protobuf.QueuedMessageEntry.protobuf_name)
2045}
2046
2047// optional bool ack = 2 [default = true];
2048inline bool QueuedMessageEntry::_internal_has_ack() const {
2049 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2050 return value;
2051}
2052inline bool QueuedMessageEntry::has_ack() const {
2053 return _internal_has_ack();
2054}
2055inline void QueuedMessageEntry::clear_ack() {
2056 _impl_.ack_ = true;
2057 _impl_._has_bits_[0] &= ~0x00000008u;
2058}
2059inline bool QueuedMessageEntry::_internal_ack() const {
2060 return _impl_.ack_;
2061}
2062inline bool QueuedMessageEntry::ack() const {
2063 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.ack)
2064 return _internal_ack();
2065}
2066inline void QueuedMessageEntry::_internal_set_ack(bool value) {
2067 _impl_._has_bits_[0] |= 0x00000008u;
2068 _impl_.ack_ = value;
2069}
2070inline void QueuedMessageEntry::set_ack(bool value) {
2071 _internal_set_ack(value);
2072 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.ack)
2073}
2074
2075// optional uint32 blackout_time = 3 [default = 0];
2076inline bool QueuedMessageEntry::_internal_has_blackout_time() const {
2077 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2078 return value;
2079}
2080inline bool QueuedMessageEntry::has_blackout_time() const {
2081 return _internal_has_blackout_time();
2082}
2083inline void QueuedMessageEntry::clear_blackout_time() {
2084 _impl_.blackout_time_ = 0u;
2085 _impl_._has_bits_[0] &= ~0x00000002u;
2086}
2087inline uint32_t QueuedMessageEntry::_internal_blackout_time() const {
2088 return _impl_.blackout_time_;
2089}
2090inline uint32_t QueuedMessageEntry::blackout_time() const {
2091 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.blackout_time)
2092 return _internal_blackout_time();
2093}
2094inline void QueuedMessageEntry::_internal_set_blackout_time(uint32_t value) {
2095 _impl_._has_bits_[0] |= 0x00000002u;
2096 _impl_.blackout_time_ = value;
2097}
2098inline void QueuedMessageEntry::set_blackout_time(uint32_t value) {
2099 _internal_set_blackout_time(value);
2100 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.blackout_time)
2101}
2102
2103// optional uint32 max_queue = 4 [default = 100];
2104inline bool QueuedMessageEntry::_internal_has_max_queue() const {
2105 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
2106 return value;
2107}
2108inline bool QueuedMessageEntry::has_max_queue() const {
2109 return _internal_has_max_queue();
2110}
2111inline void QueuedMessageEntry::clear_max_queue() {
2112 _impl_.max_queue_ = 100u;
2113 _impl_._has_bits_[0] &= ~0x00000020u;
2114}
2115inline uint32_t QueuedMessageEntry::_internal_max_queue() const {
2116 return _impl_.max_queue_;
2117}
2118inline uint32_t QueuedMessageEntry::max_queue() const {
2119 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.max_queue)
2120 return _internal_max_queue();
2121}
2122inline void QueuedMessageEntry::_internal_set_max_queue(uint32_t value) {
2123 _impl_._has_bits_[0] |= 0x00000020u;
2124 _impl_.max_queue_ = value;
2125}
2126inline void QueuedMessageEntry::set_max_queue(uint32_t value) {
2127 _internal_set_max_queue(value);
2128 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.max_queue)
2129}
2130
2131// optional bool newest_first = 5 [default = true];
2132inline bool QueuedMessageEntry::_internal_has_newest_first() const {
2133 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
2134 return value;
2135}
2136inline bool QueuedMessageEntry::has_newest_first() const {
2137 return _internal_has_newest_first();
2138}
2139inline void QueuedMessageEntry::clear_newest_first() {
2140 _impl_.newest_first_ = true;
2141 _impl_._has_bits_[0] &= ~0x00000010u;
2142}
2143inline bool QueuedMessageEntry::_internal_newest_first() const {
2144 return _impl_.newest_first_;
2145}
2146inline bool QueuedMessageEntry::newest_first() const {
2147 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.newest_first)
2148 return _internal_newest_first();
2149}
2150inline void QueuedMessageEntry::_internal_set_newest_first(bool value) {
2151 _impl_._has_bits_[0] |= 0x00000010u;
2152 _impl_.newest_first_ = value;
2153}
2154inline void QueuedMessageEntry::set_newest_first(bool value) {
2155 _internal_set_newest_first(value);
2156 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.newest_first)
2157}
2158
2159// optional int32 ttl = 6 [default = 1800];
2160inline bool QueuedMessageEntry::_internal_has_ttl() const {
2161 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2162 return value;
2163}
2164inline bool QueuedMessageEntry::has_ttl() const {
2165 return _internal_has_ttl();
2166}
2167inline void QueuedMessageEntry::clear_ttl() {
2168 _impl_.ttl_ = 1800;
2169 _impl_._has_bits_[0] &= ~0x00000004u;
2170}
2171inline int32_t QueuedMessageEntry::_internal_ttl() const {
2172 return _impl_.ttl_;
2173}
2174inline int32_t QueuedMessageEntry::ttl() const {
2175 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.ttl)
2176 return _internal_ttl();
2177}
2178inline void QueuedMessageEntry::_internal_set_ttl(int32_t value) {
2179 _impl_._has_bits_[0] |= 0x00000004u;
2180 _impl_.ttl_ = value;
2181}
2182inline void QueuedMessageEntry::set_ttl(int32_t value) {
2183 _internal_set_ttl(value);
2184 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.ttl)
2185}
2186
2187// optional double value_base = 7 [default = 1];
2188inline bool QueuedMessageEntry::_internal_has_value_base() const {
2189 bool value = (_impl_._has_bits_[0] & 0x00000040u) != 0;
2190 return value;
2191}
2192inline bool QueuedMessageEntry::has_value_base() const {
2193 return _internal_has_value_base();
2194}
2195inline void QueuedMessageEntry::clear_value_base() {
2196 _impl_.value_base_ = 1;
2197 _impl_._has_bits_[0] &= ~0x00000040u;
2198}
2199inline double QueuedMessageEntry::_internal_value_base() const {
2200 return _impl_.value_base_;
2201}
2202inline double QueuedMessageEntry::value_base() const {
2203 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.value_base)
2204 return _internal_value_base();
2205}
2206inline void QueuedMessageEntry::_internal_set_value_base(double value) {
2207 _impl_._has_bits_[0] |= 0x00000040u;
2208 _impl_.value_base_ = value;
2209}
2210inline void QueuedMessageEntry::set_value_base(double value) {
2211 _internal_set_value_base(value);
2212 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.value_base)
2213}
2214
2215// repeated .goby.acomms.protobuf.Manipulator manipulator = 10 [(.goby.field) = {
2216inline int QueuedMessageEntry::_internal_manipulator_size() const {
2217 return _impl_.manipulator_.size();
2218}
2219inline int QueuedMessageEntry::manipulator_size() const {
2220 return _internal_manipulator_size();
2221}
2222inline void QueuedMessageEntry::clear_manipulator() {
2223 _impl_.manipulator_.Clear();
2224}
2225inline ::goby::acomms::protobuf::Manipulator QueuedMessageEntry::_internal_manipulator(int index) const {
2226 return static_cast< ::goby::acomms::protobuf::Manipulator >(_impl_.manipulator_.Get(index));
2227}
2228inline ::goby::acomms::protobuf::Manipulator QueuedMessageEntry::manipulator(int index) const {
2229 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.manipulator)
2230 return _internal_manipulator(index);
2231}
2232inline void QueuedMessageEntry::set_manipulator(int index, ::goby::acomms::protobuf::Manipulator value) {
2234 _impl_.manipulator_.Set(index, value);
2235 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageEntry.manipulator)
2236}
2237inline void QueuedMessageEntry::_internal_add_manipulator(::goby::acomms::protobuf::Manipulator value) {
2239 _impl_.manipulator_.Add(value);
2240}
2241inline void QueuedMessageEntry::add_manipulator(::goby::acomms::protobuf::Manipulator value) {
2242 _internal_add_manipulator(value);
2243 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueuedMessageEntry.manipulator)
2244}
2245inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>&
2246QueuedMessageEntry::manipulator() const {
2247 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueuedMessageEntry.manipulator)
2248 return _impl_.manipulator_;
2249}
2250inline ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>*
2251QueuedMessageEntry::_internal_mutable_manipulator() {
2252 return &_impl_.manipulator_;
2253}
2254inline ::PROTOBUF_NAMESPACE_ID::RepeatedField<int>*
2255QueuedMessageEntry::mutable_manipulator() {
2256 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueuedMessageEntry.manipulator)
2257 return _internal_mutable_manipulator();
2258}
2259
2260// repeated .goby.acomms.protobuf.QueuedMessageEntry.Role role = 20 [(.goby.field) = {
2261inline int QueuedMessageEntry::_internal_role_size() const {
2262 return _impl_.role_.size();
2263}
2264inline int QueuedMessageEntry::role_size() const {
2265 return _internal_role_size();
2266}
2267inline void QueuedMessageEntry::clear_role() {
2268 _impl_.role_.Clear();
2269}
2270inline ::goby::acomms::protobuf::QueuedMessageEntry_Role* QueuedMessageEntry::mutable_role(int index) {
2271 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueuedMessageEntry.role)
2272 return _impl_.role_.Mutable(index);
2273}
2274inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry_Role >*
2275QueuedMessageEntry::mutable_role() {
2276 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueuedMessageEntry.role)
2277 return &_impl_.role_;
2278}
2279inline const ::goby::acomms::protobuf::QueuedMessageEntry_Role& QueuedMessageEntry::_internal_role(int index) const {
2280 return _impl_.role_.Get(index);
2281}
2282inline const ::goby::acomms::protobuf::QueuedMessageEntry_Role& QueuedMessageEntry::role(int index) const {
2283 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageEntry.role)
2284 return _internal_role(index);
2285}
2286inline ::goby::acomms::protobuf::QueuedMessageEntry_Role* QueuedMessageEntry::_internal_add_role() {
2287 return _impl_.role_.Add();
2288}
2289inline ::goby::acomms::protobuf::QueuedMessageEntry_Role* QueuedMessageEntry::add_role() {
2290 ::goby::acomms::protobuf::QueuedMessageEntry_Role* _add = _internal_add_role();
2291 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueuedMessageEntry.role)
2292 return _add;
2293}
2294inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry_Role >&
2295QueuedMessageEntry::role() const {
2296 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueuedMessageEntry.role)
2297 return _impl_.role_;
2298}
2299
2300// -------------------------------------------------------------------
2301
2302// QueueManagerConfig_DCCLEncryptRule
2303
2304// optional int32 id = 1;
2305inline bool QueueManagerConfig_DCCLEncryptRule::_internal_has_id() const {
2306 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2307 return value;
2308}
2309inline bool QueueManagerConfig_DCCLEncryptRule::has_id() const {
2310 return _internal_has_id();
2311}
2312inline void QueueManagerConfig_DCCLEncryptRule::clear_id() {
2313 _impl_.id_ = 0;
2314 _impl_._has_bits_[0] &= ~0x00000002u;
2315}
2316inline int32_t QueueManagerConfig_DCCLEncryptRule::_internal_id() const {
2317 return _impl_.id_;
2318}
2319inline int32_t QueueManagerConfig_DCCLEncryptRule::id() const {
2320 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.id)
2321 return _internal_id();
2322}
2323inline void QueueManagerConfig_DCCLEncryptRule::_internal_set_id(int32_t value) {
2324 _impl_._has_bits_[0] |= 0x00000002u;
2325 _impl_.id_ = value;
2326}
2327inline void QueueManagerConfig_DCCLEncryptRule::set_id(int32_t value) {
2328 _internal_set_id(value);
2329 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.id)
2330}
2331
2332// required string crypto_passphrase = 2;
2333inline bool QueueManagerConfig_DCCLEncryptRule::_internal_has_crypto_passphrase() const {
2334 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2335 return value;
2336}
2337inline bool QueueManagerConfig_DCCLEncryptRule::has_crypto_passphrase() const {
2338 return _internal_has_crypto_passphrase();
2339}
2340inline void QueueManagerConfig_DCCLEncryptRule::clear_crypto_passphrase() {
2341 _impl_.crypto_passphrase_.ClearToEmpty();
2342 _impl_._has_bits_[0] &= ~0x00000001u;
2343}
2344inline const std::string& QueueManagerConfig_DCCLEncryptRule::crypto_passphrase() const {
2345 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.crypto_passphrase)
2346 return _internal_crypto_passphrase();
2347}
2348template <typename ArgT0, typename... ArgT>
2349inline PROTOBUF_ALWAYS_INLINE
2350void QueueManagerConfig_DCCLEncryptRule::set_crypto_passphrase(ArgT0&& arg0, ArgT... args) {
2351 _impl_._has_bits_[0] |= 0x00000001u;
2352 _impl_.crypto_passphrase_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
2353 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.crypto_passphrase)
2354}
2355inline std::string* QueueManagerConfig_DCCLEncryptRule::mutable_crypto_passphrase() {
2356 std::string* _s = _internal_mutable_crypto_passphrase();
2357 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.crypto_passphrase)
2358 return _s;
2359}
2360inline const std::string& QueueManagerConfig_DCCLEncryptRule::_internal_crypto_passphrase() const {
2361 return _impl_.crypto_passphrase_.Get();
2362}
2363inline void QueueManagerConfig_DCCLEncryptRule::_internal_set_crypto_passphrase(const std::string& value) {
2364 _impl_._has_bits_[0] |= 0x00000001u;
2365 _impl_.crypto_passphrase_.Set(value, GetArenaForAllocation());
2366}
2367inline std::string* QueueManagerConfig_DCCLEncryptRule::_internal_mutable_crypto_passphrase() {
2368 _impl_._has_bits_[0] |= 0x00000001u;
2369 return _impl_.crypto_passphrase_.Mutable(GetArenaForAllocation());
2370}
2371inline std::string* QueueManagerConfig_DCCLEncryptRule::release_crypto_passphrase() {
2372 // @@protoc_insertion_point(field_release:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.crypto_passphrase)
2373 if (!_internal_has_crypto_passphrase()) {
2374 return nullptr;
2375 }
2376 _impl_._has_bits_[0] &= ~0x00000001u;
2377 auto* p = _impl_.crypto_passphrase_.Release();
2378#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2379 if (_impl_.crypto_passphrase_.IsDefault()) {
2380 _impl_.crypto_passphrase_.Set("", GetArenaForAllocation());
2381 }
2382#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2383 return p;
2384}
2385inline void QueueManagerConfig_DCCLEncryptRule::set_allocated_crypto_passphrase(std::string* crypto_passphrase) {
2386 if (crypto_passphrase != nullptr) {
2387 _impl_._has_bits_[0] |= 0x00000001u;
2388 } else {
2389 _impl_._has_bits_[0] &= ~0x00000001u;
2390 }
2391 _impl_.crypto_passphrase_.SetAllocated(crypto_passphrase, GetArenaForAllocation());
2392#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2393 if (_impl_.crypto_passphrase_.IsDefault()) {
2394 _impl_.crypto_passphrase_.Set("", GetArenaForAllocation());
2395 }
2396#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2397 // @@protoc_insertion_point(field_set_allocated:goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule.crypto_passphrase)
2398}
2399
2400// -------------------------------------------------------------------
2401
2402// QueueManagerConfig
2403
2404// optional int32 modem_id = 1 [(.goby.field) = {
2405inline bool QueueManagerConfig::_internal_has_modem_id() const {
2406 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2407 return value;
2408}
2409inline bool QueueManagerConfig::has_modem_id() const {
2410 return _internal_has_modem_id();
2411}
2412inline void QueueManagerConfig::clear_modem_id() {
2413 _impl_.modem_id_ = 0;
2414 _impl_._has_bits_[0] &= ~0x00000001u;
2415}
2416inline int32_t QueueManagerConfig::_internal_modem_id() const {
2417 return _impl_.modem_id_;
2418}
2419inline int32_t QueueManagerConfig::modem_id() const {
2420 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.modem_id)
2421 return _internal_modem_id();
2422}
2423inline void QueueManagerConfig::_internal_set_modem_id(int32_t value) {
2424 _impl_._has_bits_[0] |= 0x00000001u;
2425 _impl_.modem_id_ = value;
2426}
2427inline void QueueManagerConfig::set_modem_id(int32_t value) {
2428 _internal_set_modem_id(value);
2429 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.modem_id)
2430}
2431
2432// repeated .goby.acomms.protobuf.QueuedMessageEntry message_entry = 10;
2433inline int QueueManagerConfig::_internal_message_entry_size() const {
2434 return _impl_.message_entry_.size();
2435}
2436inline int QueueManagerConfig::message_entry_size() const {
2437 return _internal_message_entry_size();
2438}
2439inline void QueueManagerConfig::clear_message_entry() {
2440 _impl_.message_entry_.Clear();
2441}
2442inline ::goby::acomms::protobuf::QueuedMessageEntry* QueueManagerConfig::mutable_message_entry(int index) {
2443 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueueManagerConfig.message_entry)
2444 return _impl_.message_entry_.Mutable(index);
2445}
2446inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry >*
2447QueueManagerConfig::mutable_message_entry() {
2448 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueueManagerConfig.message_entry)
2449 return &_impl_.message_entry_;
2450}
2451inline const ::goby::acomms::protobuf::QueuedMessageEntry& QueueManagerConfig::_internal_message_entry(int index) const {
2452 return _impl_.message_entry_.Get(index);
2453}
2454inline const ::goby::acomms::protobuf::QueuedMessageEntry& QueueManagerConfig::message_entry(int index) const {
2455 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.message_entry)
2456 return _internal_message_entry(index);
2457}
2458inline ::goby::acomms::protobuf::QueuedMessageEntry* QueueManagerConfig::_internal_add_message_entry() {
2459 return _impl_.message_entry_.Add();
2460}
2461inline ::goby::acomms::protobuf::QueuedMessageEntry* QueueManagerConfig::add_message_entry() {
2462 ::goby::acomms::protobuf::QueuedMessageEntry* _add = _internal_add_message_entry();
2463 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueueManagerConfig.message_entry)
2464 return _add;
2465}
2466inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueuedMessageEntry >&
2467QueueManagerConfig::message_entry() const {
2468 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueueManagerConfig.message_entry)
2469 return _impl_.message_entry_;
2470}
2471
2472// optional double on_demand_skew_seconds = 11 [default = 1];
2473inline bool QueueManagerConfig::_internal_has_on_demand_skew_seconds() const {
2474 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2475 return value;
2476}
2477inline bool QueueManagerConfig::has_on_demand_skew_seconds() const {
2478 return _internal_has_on_demand_skew_seconds();
2479}
2480inline void QueueManagerConfig::clear_on_demand_skew_seconds() {
2481 _impl_.on_demand_skew_seconds_ = 1;
2482 _impl_._has_bits_[0] &= ~0x00000008u;
2483}
2484inline double QueueManagerConfig::_internal_on_demand_skew_seconds() const {
2485 return _impl_.on_demand_skew_seconds_;
2486}
2487inline double QueueManagerConfig::on_demand_skew_seconds() const {
2488 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.on_demand_skew_seconds)
2489 return _internal_on_demand_skew_seconds();
2490}
2491inline void QueueManagerConfig::_internal_set_on_demand_skew_seconds(double value) {
2492 _impl_._has_bits_[0] |= 0x00000008u;
2493 _impl_.on_demand_skew_seconds_ = value;
2494}
2495inline void QueueManagerConfig::set_on_demand_skew_seconds(double value) {
2496 _internal_set_on_demand_skew_seconds(value);
2497 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.on_demand_skew_seconds)
2498}
2499
2500// optional double minimum_ack_wait_seconds = 20 [default = 0];
2501inline bool QueueManagerConfig::_internal_has_minimum_ack_wait_seconds() const {
2502 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2503 return value;
2504}
2505inline bool QueueManagerConfig::has_minimum_ack_wait_seconds() const {
2506 return _internal_has_minimum_ack_wait_seconds();
2507}
2508inline void QueueManagerConfig::clear_minimum_ack_wait_seconds() {
2509 _impl_.minimum_ack_wait_seconds_ = 0;
2510 _impl_._has_bits_[0] &= ~0x00000004u;
2511}
2512inline double QueueManagerConfig::_internal_minimum_ack_wait_seconds() const {
2513 return _impl_.minimum_ack_wait_seconds_;
2514}
2515inline double QueueManagerConfig::minimum_ack_wait_seconds() const {
2516 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.minimum_ack_wait_seconds)
2517 return _internal_minimum_ack_wait_seconds();
2518}
2519inline void QueueManagerConfig::_internal_set_minimum_ack_wait_seconds(double value) {
2520 _impl_._has_bits_[0] |= 0x00000004u;
2521 _impl_.minimum_ack_wait_seconds_ = value;
2522}
2523inline void QueueManagerConfig::set_minimum_ack_wait_seconds(double value) {
2524 _internal_set_minimum_ack_wait_seconds(value);
2525 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.minimum_ack_wait_seconds)
2526}
2527
2528// optional bool skip_decoding = 21 [default = false, (.goby.field) = {
2529inline bool QueueManagerConfig::_internal_has_skip_decoding() const {
2530 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2531 return value;
2532}
2533inline bool QueueManagerConfig::has_skip_decoding() const {
2534 return _internal_has_skip_decoding();
2535}
2536inline void QueueManagerConfig::clear_skip_decoding() {
2537 _impl_.skip_decoding_ = false;
2538 _impl_._has_bits_[0] &= ~0x00000002u;
2539}
2540inline bool QueueManagerConfig::_internal_skip_decoding() const {
2541 return _impl_.skip_decoding_;
2542}
2543inline bool QueueManagerConfig::skip_decoding() const {
2544 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.skip_decoding)
2545 return _internal_skip_decoding();
2546}
2547inline void QueueManagerConfig::_internal_set_skip_decoding(bool value) {
2548 _impl_._has_bits_[0] |= 0x00000002u;
2549 _impl_.skip_decoding_ = value;
2550}
2551inline void QueueManagerConfig::set_skip_decoding(bool value) {
2552 _internal_set_skip_decoding(value);
2553 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.skip_decoding)
2554}
2555
2556// repeated int32 make_network_ack_for_src_id = 30;
2557inline int QueueManagerConfig::_internal_make_network_ack_for_src_id_size() const {
2558 return _impl_.make_network_ack_for_src_id_.size();
2559}
2560inline int QueueManagerConfig::make_network_ack_for_src_id_size() const {
2561 return _internal_make_network_ack_for_src_id_size();
2562}
2563inline void QueueManagerConfig::clear_make_network_ack_for_src_id() {
2564 _impl_.make_network_ack_for_src_id_.Clear();
2565}
2566inline int32_t QueueManagerConfig::_internal_make_network_ack_for_src_id(int index) const {
2567 return _impl_.make_network_ack_for_src_id_.Get(index);
2568}
2569inline int32_t QueueManagerConfig::make_network_ack_for_src_id(int index) const {
2570 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.make_network_ack_for_src_id)
2571 return _internal_make_network_ack_for_src_id(index);
2572}
2573inline void QueueManagerConfig::set_make_network_ack_for_src_id(int index, int32_t value) {
2574 _impl_.make_network_ack_for_src_id_.Set(index, value);
2575 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.make_network_ack_for_src_id)
2576}
2577inline void QueueManagerConfig::_internal_add_make_network_ack_for_src_id(int32_t value) {
2578 _impl_.make_network_ack_for_src_id_.Add(value);
2579}
2580inline void QueueManagerConfig::add_make_network_ack_for_src_id(int32_t value) {
2581 _internal_add_make_network_ack_for_src_id(value);
2582 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueueManagerConfig.make_network_ack_for_src_id)
2583}
2584inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
2585QueueManagerConfig::_internal_make_network_ack_for_src_id() const {
2586 return _impl_.make_network_ack_for_src_id_;
2587}
2588inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
2589QueueManagerConfig::make_network_ack_for_src_id() const {
2590 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueueManagerConfig.make_network_ack_for_src_id)
2591 return _internal_make_network_ack_for_src_id();
2592}
2593inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
2594QueueManagerConfig::_internal_mutable_make_network_ack_for_src_id() {
2595 return &_impl_.make_network_ack_for_src_id_;
2596}
2597inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
2598QueueManagerConfig::mutable_make_network_ack_for_src_id() {
2599 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueueManagerConfig.make_network_ack_for_src_id)
2600 return _internal_mutable_make_network_ack_for_src_id();
2601}
2602
2603// repeated int32 route_for_additional_modem_id = 40 [(.goby.field) = {
2604inline int QueueManagerConfig::_internal_route_for_additional_modem_id_size() const {
2605 return _impl_.route_for_additional_modem_id_.size();
2606}
2607inline int QueueManagerConfig::route_for_additional_modem_id_size() const {
2608 return _internal_route_for_additional_modem_id_size();
2609}
2610inline void QueueManagerConfig::clear_route_for_additional_modem_id() {
2611 _impl_.route_for_additional_modem_id_.Clear();
2612}
2613inline int32_t QueueManagerConfig::_internal_route_for_additional_modem_id(int index) const {
2614 return _impl_.route_for_additional_modem_id_.Get(index);
2615}
2616inline int32_t QueueManagerConfig::route_for_additional_modem_id(int index) const {
2617 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.route_for_additional_modem_id)
2618 return _internal_route_for_additional_modem_id(index);
2619}
2620inline void QueueManagerConfig::set_route_for_additional_modem_id(int index, int32_t value) {
2621 _impl_.route_for_additional_modem_id_.Set(index, value);
2622 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueManagerConfig.route_for_additional_modem_id)
2623}
2624inline void QueueManagerConfig::_internal_add_route_for_additional_modem_id(int32_t value) {
2625 _impl_.route_for_additional_modem_id_.Add(value);
2626}
2627inline void QueueManagerConfig::add_route_for_additional_modem_id(int32_t value) {
2628 _internal_add_route_for_additional_modem_id(value);
2629 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueueManagerConfig.route_for_additional_modem_id)
2630}
2631inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
2632QueueManagerConfig::_internal_route_for_additional_modem_id() const {
2633 return _impl_.route_for_additional_modem_id_;
2634}
2635inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >&
2636QueueManagerConfig::route_for_additional_modem_id() const {
2637 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueueManagerConfig.route_for_additional_modem_id)
2638 return _internal_route_for_additional_modem_id();
2639}
2640inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
2641QueueManagerConfig::_internal_mutable_route_for_additional_modem_id() {
2642 return &_impl_.route_for_additional_modem_id_;
2643}
2644inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< int32_t >*
2645QueueManagerConfig::mutable_route_for_additional_modem_id() {
2646 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueueManagerConfig.route_for_additional_modem_id)
2647 return _internal_mutable_route_for_additional_modem_id();
2648}
2649
2650// repeated .goby.acomms.protobuf.QueueManagerConfig.DCCLEncryptRule encrypt_rule = 50;
2651inline int QueueManagerConfig::_internal_encrypt_rule_size() const {
2652 return _impl_.encrypt_rule_.size();
2653}
2654inline int QueueManagerConfig::encrypt_rule_size() const {
2655 return _internal_encrypt_rule_size();
2656}
2657inline void QueueManagerConfig::clear_encrypt_rule() {
2658 _impl_.encrypt_rule_.Clear();
2659}
2660inline ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* QueueManagerConfig::mutable_encrypt_rule(int index) {
2661 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueueManagerConfig.encrypt_rule)
2662 return _impl_.encrypt_rule_.Mutable(index);
2663}
2664inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule >*
2665QueueManagerConfig::mutable_encrypt_rule() {
2666 // @@protoc_insertion_point(field_mutable_list:goby.acomms.protobuf.QueueManagerConfig.encrypt_rule)
2667 return &_impl_.encrypt_rule_;
2668}
2669inline const ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule& QueueManagerConfig::_internal_encrypt_rule(int index) const {
2670 return _impl_.encrypt_rule_.Get(index);
2671}
2672inline const ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule& QueueManagerConfig::encrypt_rule(int index) const {
2673 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueManagerConfig.encrypt_rule)
2674 return _internal_encrypt_rule(index);
2675}
2676inline ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* QueueManagerConfig::_internal_add_encrypt_rule() {
2677 return _impl_.encrypt_rule_.Add();
2678}
2679inline ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* QueueManagerConfig::add_encrypt_rule() {
2680 ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule* _add = _internal_add_encrypt_rule();
2681 // @@protoc_insertion_point(field_add:goby.acomms.protobuf.QueueManagerConfig.encrypt_rule)
2682 return _add;
2683}
2684inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::goby::acomms::protobuf::QueueManagerConfig_DCCLEncryptRule >&
2685QueueManagerConfig::encrypt_rule() const {
2686 // @@protoc_insertion_point(field_list:goby.acomms.protobuf.QueueManagerConfig.encrypt_rule)
2687 return _impl_.encrypt_rule_;
2688}
2689
2690// -------------------------------------------------------------------
2691
2692// QueueSize
2693
2694// required uint32 dccl_id = 1;
2695inline bool QueueSize::_internal_has_dccl_id() const {
2696 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2697 return value;
2698}
2699inline bool QueueSize::has_dccl_id() const {
2700 return _internal_has_dccl_id();
2701}
2702inline void QueueSize::clear_dccl_id() {
2703 _impl_.dccl_id_ = 0u;
2704 _impl_._has_bits_[0] &= ~0x00000001u;
2705}
2706inline uint32_t QueueSize::_internal_dccl_id() const {
2707 return _impl_.dccl_id_;
2708}
2709inline uint32_t QueueSize::dccl_id() const {
2710 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueSize.dccl_id)
2711 return _internal_dccl_id();
2712}
2713inline void QueueSize::_internal_set_dccl_id(uint32_t value) {
2714 _impl_._has_bits_[0] |= 0x00000001u;
2715 _impl_.dccl_id_ = value;
2716}
2717inline void QueueSize::set_dccl_id(uint32_t value) {
2718 _internal_set_dccl_id(value);
2719 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueSize.dccl_id)
2720}
2721
2722// required uint32 size = 2;
2723inline bool QueueSize::_internal_has_size() const {
2724 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2725 return value;
2726}
2727inline bool QueueSize::has_size() const {
2728 return _internal_has_size();
2729}
2730inline void QueueSize::clear_size() {
2731 _impl_.size_ = 0u;
2732 _impl_._has_bits_[0] &= ~0x00000002u;
2733}
2734inline uint32_t QueueSize::_internal_size() const {
2735 return _impl_.size_;
2736}
2737inline uint32_t QueueSize::size() const {
2738 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueSize.size)
2739 return _internal_size();
2740}
2741inline void QueueSize::_internal_set_size(uint32_t value) {
2742 _impl_._has_bits_[0] |= 0x00000002u;
2743 _impl_.size_ = value;
2744}
2745inline void QueueSize::set_size(uint32_t value) {
2746 _internal_set_size(value);
2747 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueSize.size)
2748}
2749
2750// -------------------------------------------------------------------
2751
2752// QueueFlush
2753
2754// required uint32 dccl_id = 1;
2755inline bool QueueFlush::_internal_has_dccl_id() const {
2756 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2757 return value;
2758}
2759inline bool QueueFlush::has_dccl_id() const {
2760 return _internal_has_dccl_id();
2761}
2762inline void QueueFlush::clear_dccl_id() {
2763 _impl_.dccl_id_ = 0u;
2764 _impl_._has_bits_[0] &= ~0x00000001u;
2765}
2766inline uint32_t QueueFlush::_internal_dccl_id() const {
2767 return _impl_.dccl_id_;
2768}
2769inline uint32_t QueueFlush::dccl_id() const {
2770 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueueFlush.dccl_id)
2771 return _internal_dccl_id();
2772}
2773inline void QueueFlush::_internal_set_dccl_id(uint32_t value) {
2774 _impl_._has_bits_[0] |= 0x00000001u;
2775 _impl_.dccl_id_ = value;
2776}
2777inline void QueueFlush::set_dccl_id(uint32_t value) {
2778 _internal_set_dccl_id(value);
2779 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueueFlush.dccl_id)
2780}
2781
2782// -------------------------------------------------------------------
2783
2784// QueuedMessageMeta
2785
2786// optional uint32 non_repeated_size = 1;
2787inline bool QueuedMessageMeta::_internal_has_non_repeated_size() const {
2788 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2789 return value;
2790}
2791inline bool QueuedMessageMeta::has_non_repeated_size() const {
2792 return _internal_has_non_repeated_size();
2793}
2794inline void QueuedMessageMeta::clear_non_repeated_size() {
2795 _impl_.non_repeated_size_ = 0u;
2796 _impl_._has_bits_[0] &= ~0x00000002u;
2797}
2798inline uint32_t QueuedMessageMeta::_internal_non_repeated_size() const {
2799 return _impl_.non_repeated_size_;
2800}
2801inline uint32_t QueuedMessageMeta::non_repeated_size() const {
2802 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.non_repeated_size)
2803 return _internal_non_repeated_size();
2804}
2805inline void QueuedMessageMeta::_internal_set_non_repeated_size(uint32_t value) {
2806 _impl_._has_bits_[0] |= 0x00000002u;
2807 _impl_.non_repeated_size_ = value;
2808}
2809inline void QueuedMessageMeta::set_non_repeated_size(uint32_t value) {
2810 _internal_set_non_repeated_size(value);
2811 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.non_repeated_size)
2812}
2813
2814// optional bool ack_requested = 2;
2815inline bool QueuedMessageMeta::_internal_has_ack_requested() const {
2816 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2817 return value;
2818}
2819inline bool QueuedMessageMeta::has_ack_requested() const {
2820 return _internal_has_ack_requested();
2821}
2822inline void QueuedMessageMeta::clear_ack_requested() {
2823 _impl_.ack_requested_ = false;
2824 _impl_._has_bits_[0] &= ~0x00000004u;
2825}
2826inline bool QueuedMessageMeta::_internal_ack_requested() const {
2827 return _impl_.ack_requested_;
2828}
2829inline bool QueuedMessageMeta::ack_requested() const {
2830 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.ack_requested)
2831 return _internal_ack_requested();
2832}
2833inline void QueuedMessageMeta::_internal_set_ack_requested(bool value) {
2834 _impl_._has_bits_[0] |= 0x00000004u;
2835 _impl_.ack_requested_ = value;
2836}
2837inline void QueuedMessageMeta::set_ack_requested(bool value) {
2838 _internal_set_ack_requested(value);
2839 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.ack_requested)
2840}
2841
2842// optional int32 src = 3;
2843inline bool QueuedMessageMeta::_internal_has_src() const {
2844 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2845 return value;
2846}
2847inline bool QueuedMessageMeta::has_src() const {
2848 return _internal_has_src();
2849}
2850inline void QueuedMessageMeta::clear_src() {
2851 _impl_.src_ = 0;
2852 _impl_._has_bits_[0] &= ~0x00000008u;
2853}
2854inline int32_t QueuedMessageMeta::_internal_src() const {
2855 return _impl_.src_;
2856}
2857inline int32_t QueuedMessageMeta::src() const {
2858 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.src)
2859 return _internal_src();
2860}
2861inline void QueuedMessageMeta::_internal_set_src(int32_t value) {
2862 _impl_._has_bits_[0] |= 0x00000008u;
2863 _impl_.src_ = value;
2864}
2865inline void QueuedMessageMeta::set_src(int32_t value) {
2866 _internal_set_src(value);
2867 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.src)
2868}
2869
2870// optional int32 dest = 4;
2871inline bool QueuedMessageMeta::_internal_has_dest() const {
2872 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
2873 return value;
2874}
2875inline bool QueuedMessageMeta::has_dest() const {
2876 return _internal_has_dest();
2877}
2878inline void QueuedMessageMeta::clear_dest() {
2879 _impl_.dest_ = 0;
2880 _impl_._has_bits_[0] &= ~0x00000010u;
2881}
2882inline int32_t QueuedMessageMeta::_internal_dest() const {
2883 return _impl_.dest_;
2884}
2885inline int32_t QueuedMessageMeta::dest() const {
2886 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.dest)
2887 return _internal_dest();
2888}
2889inline void QueuedMessageMeta::_internal_set_dest(int32_t value) {
2890 _impl_._has_bits_[0] |= 0x00000010u;
2891 _impl_.dest_ = value;
2892}
2893inline void QueuedMessageMeta::set_dest(int32_t value) {
2894 _internal_set_dest(value);
2895 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.dest)
2896}
2897
2898// optional uint64 time = 5 [(.dccl.field) = {
2899inline bool QueuedMessageMeta::_internal_has_time() const {
2900 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
2901 return value;
2902}
2903inline bool QueuedMessageMeta::has_time() const {
2904 return _internal_has_time();
2905}
2906inline void QueuedMessageMeta::clear_time() {
2907 _impl_.time_ = uint64_t{0u};
2908 _impl_._has_bits_[0] &= ~0x00000020u;
2909}
2910inline uint64_t QueuedMessageMeta::_internal_time() const {
2911 return _impl_.time_;
2912}
2913inline uint64_t QueuedMessageMeta::time() const {
2914 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.time)
2915 return _internal_time();
2916}
2917inline void QueuedMessageMeta::_internal_set_time(uint64_t value) {
2918 _impl_._has_bits_[0] |= 0x00000020u;
2919 _impl_.time_ = value;
2920}
2921inline void QueuedMessageMeta::set_time(uint64_t value) {
2922 _internal_set_time(value);
2923 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.time)
2924}
2925
2926// optional uint64 last_sent_time = 10 [(.dccl.field) = {
2927inline bool QueuedMessageMeta::_internal_has_last_sent_time() const {
2928 bool value = (_impl_._has_bits_[0] & 0x00000040u) != 0;
2929 return value;
2930}
2931inline bool QueuedMessageMeta::has_last_sent_time() const {
2932 return _internal_has_last_sent_time();
2933}
2934inline void QueuedMessageMeta::clear_last_sent_time() {
2935 _impl_.last_sent_time_ = uint64_t{0u};
2936 _impl_._has_bits_[0] &= ~0x00000040u;
2937}
2938inline uint64_t QueuedMessageMeta::_internal_last_sent_time() const {
2939 return _impl_.last_sent_time_;
2940}
2941inline uint64_t QueuedMessageMeta::last_sent_time() const {
2942 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.last_sent_time)
2943 return _internal_last_sent_time();
2944}
2945inline void QueuedMessageMeta::_internal_set_last_sent_time(uint64_t value) {
2946 _impl_._has_bits_[0] |= 0x00000040u;
2947 _impl_.last_sent_time_ = value;
2948}
2949inline void QueuedMessageMeta::set_last_sent_time(uint64_t value) {
2950 _internal_set_last_sent_time(value);
2951 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.last_sent_time)
2952}
2953
2954// optional bytes encoded_message = 20;
2955inline bool QueuedMessageMeta::_internal_has_encoded_message() const {
2956 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2957 return value;
2958}
2959inline bool QueuedMessageMeta::has_encoded_message() const {
2960 return _internal_has_encoded_message();
2961}
2962inline void QueuedMessageMeta::clear_encoded_message() {
2963 _impl_.encoded_message_.ClearToEmpty();
2964 _impl_._has_bits_[0] &= ~0x00000001u;
2965}
2966inline const std::string& QueuedMessageMeta::encoded_message() const {
2967 // @@protoc_insertion_point(field_get:goby.acomms.protobuf.QueuedMessageMeta.encoded_message)
2968 return _internal_encoded_message();
2969}
2970template <typename ArgT0, typename... ArgT>
2971inline PROTOBUF_ALWAYS_INLINE
2972void QueuedMessageMeta::set_encoded_message(ArgT0&& arg0, ArgT... args) {
2973 _impl_._has_bits_[0] |= 0x00000001u;
2974 _impl_.encoded_message_.SetBytes(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
2975 // @@protoc_insertion_point(field_set:goby.acomms.protobuf.QueuedMessageMeta.encoded_message)
2976}
2977inline std::string* QueuedMessageMeta::mutable_encoded_message() {
2978 std::string* _s = _internal_mutable_encoded_message();
2979 // @@protoc_insertion_point(field_mutable:goby.acomms.protobuf.QueuedMessageMeta.encoded_message)
2980 return _s;
2981}
2982inline const std::string& QueuedMessageMeta::_internal_encoded_message() const {
2983 return _impl_.encoded_message_.Get();
2984}
2985inline void QueuedMessageMeta::_internal_set_encoded_message(const std::string& value) {
2986 _impl_._has_bits_[0] |= 0x00000001u;
2987 _impl_.encoded_message_.Set(value, GetArenaForAllocation());
2988}
2989inline std::string* QueuedMessageMeta::_internal_mutable_encoded_message() {
2990 _impl_._has_bits_[0] |= 0x00000001u;
2991 return _impl_.encoded_message_.Mutable(GetArenaForAllocation());
2992}
2993inline std::string* QueuedMessageMeta::release_encoded_message() {
2994 // @@protoc_insertion_point(field_release:goby.acomms.protobuf.QueuedMessageMeta.encoded_message)
2995 if (!_internal_has_encoded_message()) {
2996 return nullptr;
2997 }
2998 _impl_._has_bits_[0] &= ~0x00000001u;
2999 auto* p = _impl_.encoded_message_.Release();
3000#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3001 if (_impl_.encoded_message_.IsDefault()) {
3002 _impl_.encoded_message_.Set("", GetArenaForAllocation());
3003 }
3004#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3005 return p;
3006}
3007inline void QueuedMessageMeta::set_allocated_encoded_message(std::string* encoded_message) {
3008 if (encoded_message != nullptr) {
3009 _impl_._has_bits_[0] |= 0x00000001u;
3010 } else {
3011 _impl_._has_bits_[0] &= ~0x00000001u;
3012 }
3013 _impl_.encoded_message_.SetAllocated(encoded_message, GetArenaForAllocation());
3014#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
3015 if (_impl_.encoded_message_.IsDefault()) {
3016 _impl_.encoded_message_.Set("", GetArenaForAllocation());
3017 }
3018#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
3019 // @@protoc_insertion_point(field_set_allocated:goby.acomms.protobuf.QueuedMessageMeta.encoded_message)
3020}
3021
3022#ifdef __GNUC__
3023 #pragma GCC diagnostic pop
3024#endif // __GNUC__
3025// -------------------------------------------------------------------
3026
3027// -------------------------------------------------------------------
3028
3029// -------------------------------------------------------------------
3030
3031// -------------------------------------------------------------------
3032
3033// -------------------------------------------------------------------
3034
3035// -------------------------------------------------------------------
3036
3037
3038// @@protoc_insertion_point(namespace_scope)
3039
3040} // namespace protobuf
3041} // namespace acomms
3042} // namespace goby
3043
3044PROTOBUF_NAMESPACE_OPEN
3045
3046template <> struct is_proto_enum< ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting> : ::std::true_type {};
3047template <>
3049 return ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting_descriptor();
3050}
3051template <> struct is_proto_enum< ::goby::acomms::protobuf::QueuedMessageEntry_RoleType> : ::std::true_type {};
3052template <>
3054 return ::goby::acomms::protobuf::QueuedMessageEntry_RoleType_descriptor();
3055}
3056
3057PROTOBUF_NAMESPACE_CLOSE
3058
3059// @@protoc_insertion_point(global_scope)
3060
3061#include <google/protobuf/port_undef.inc>
3062#endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_goby_2facomms_2fprotobuf_2fqueue_2eproto
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:1408
static const ClassData _class_data_
Definition queue.pb.h:1485
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
QueueFlush(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
QueueFlush & operator=(const QueueFlush &from)
Definition queue.pb.h:1380
QueueFlush * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:1448
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:1411
static const QueueFlush & default_instance()
Definition queue.pb.h:1414
PROTOBUF_CONSTEXPR QueueFlush(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
void Swap(QueueFlush *other)
Definition queue.pb.h:1427
QueueFlush(const QueueFlush &from)
void CopyFrom(const QueueFlush &from)
friend void swap(QueueFlush &a, QueueFlush &b)
Definition queue.pb.h:1424
QueueFlush & operator=(QueueFlush &&from) noexcept
Definition queue.pb.h:1384
void MergeFrom(const QueueFlush &from)
Definition queue.pb.h:1454
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:1398
void UnsafeArenaSwap(QueueFlush *other)
Definition queue.pb.h:1440
QueueFlush(QueueFlush &&from) noexcept
Definition queue.pb.h:1375
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:1401
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:1405
static const QueueFlush * internal_default_instance()
Definition queue.pb.h:1417
QueueManagerConfig_DCCLEncryptRule & operator=(QueueManagerConfig_DCCLEncryptRule &&from) noexcept
Definition queue.pb.h:731
void CopyFrom(const QueueManagerConfig_DCCLEncryptRule &from)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:752
friend void swap(QueueManagerConfig_DCCLEncryptRule &a, QueueManagerConfig_DCCLEncryptRule &b)
Definition queue.pb.h:771
static const QueueManagerConfig_DCCLEncryptRule * internal_default_instance()
Definition queue.pb.h:764
void Swap(QueueManagerConfig_DCCLEncryptRule *other)
Definition queue.pb.h:774
static const QueueManagerConfig_DCCLEncryptRule & default_instance()
Definition queue.pb.h:761
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:745
QueueManagerConfig_DCCLEncryptRule(QueueManagerConfig_DCCLEncryptRule &&from) noexcept
Definition queue.pb.h:722
void set_crypto_passphrase(ArgT0 &&arg0, ArgT... args)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:755
void UnsafeArenaSwap(QueueManagerConfig_DCCLEncryptRule *other)
Definition queue.pb.h:787
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:758
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
PROTOBUF_CONSTEXPR QueueManagerConfig_DCCLEncryptRule(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
QueueManagerConfig_DCCLEncryptRule & operator=(const QueueManagerConfig_DCCLEncryptRule &from)
Definition queue.pb.h:727
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:748
QueueManagerConfig_DCCLEncryptRule(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
QueueManagerConfig_DCCLEncryptRule(const QueueManagerConfig_DCCLEncryptRule &from)
void MergeFrom(const QueueManagerConfig_DCCLEncryptRule &from)
Definition queue.pb.h:801
QueueManagerConfig_DCCLEncryptRule * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:795
PROTOBUF_CONSTEXPR QueueManagerConfig(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:935
QueueManagerConfig(const QueueManagerConfig &from)
static const QueueManagerConfig * internal_default_instance()
Definition queue.pb.h:944
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:932
void MergeFrom(const QueueManagerConfig &from)
Definition queue.pb.h:981
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:925
QueueManagerConfig(QueueManagerConfig &&from) noexcept
Definition queue.pb.h:902
QueueManagerConfig * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:975
QueueManagerConfig & operator=(const QueueManagerConfig &from)
Definition queue.pb.h:907
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:938
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:928
friend void swap(QueueManagerConfig &a, QueueManagerConfig &b)
Definition queue.pb.h:951
void CopyFrom(const QueueManagerConfig &from)
void Swap(QueueManagerConfig *other)
Definition queue.pb.h:954
QueueManagerConfig & operator=(QueueManagerConfig &&from) noexcept
Definition queue.pb.h:911
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
QueueManagerConfig(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
void UnsafeArenaSwap(QueueManagerConfig *other)
Definition queue.pb.h:967
static const QueueManagerConfig & default_instance()
Definition queue.pb.h:941
void MergeFrom(const QueueSize &from)
Definition queue.pb.h:1276
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
PROTOBUF_CONSTEXPR QueueSize(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:1223
static const QueueSize & default_instance()
Definition queue.pb.h:1236
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:1230
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:1227
void Swap(QueueSize *other)
Definition queue.pb.h:1249
QueueSize * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:1270
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:1220
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:1233
friend void swap(QueueSize &a, QueueSize &b)
Definition queue.pb.h:1246
QueueSize & operator=(const QueueSize &from)
Definition queue.pb.h:1202
QueueSize & operator=(QueueSize &&from) noexcept
Definition queue.pb.h:1206
static const ClassData _class_data_
Definition queue.pb.h:1307
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
static const QueueSize * internal_default_instance()
Definition queue.pb.h:1239
QueueSize(const QueueSize &from)
void UnsafeArenaSwap(QueueSize *other)
Definition queue.pb.h:1262
void CopyFrom(const QueueSize &from)
QueueSize(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
QueueSize(QueueSize &&from) noexcept
Definition queue.pb.h:1197
static constexpr RoleSetting RoleSetting_MIN
Definition queue.pb.h:279
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
void set_field(ArgT0 &&arg0, ArgT... args)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * RoleSetting_descriptor()
Definition queue.pb.h:286
QueuedMessageEntry_Role(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
static constexpr RoleSetting STATIC
Definition queue.pb.h:272
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
static const std::string & RoleSetting_Name(T enum_t_value)
Definition queue.pb.h:290
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
static constexpr RoleSetting FIELD_VALUE
Definition queue.pb.h:274
void UnsafeArenaSwap(QueuedMessageEntry_Role *other)
Definition queue.pb.h:219
::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting setting() const
Definition queue.pb.h:1865
static const QueuedMessageEntry_Role * internal_default_instance()
Definition queue.pb.h:196
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
QueuedMessageEntry_Role & operator=(QueuedMessageEntry_Role &&from) noexcept
Definition queue.pb.h:163
QueuedMessageEntry_Role(const QueuedMessageEntry_Role &from)
static const QueuedMessageEntry_Role & default_instance()
Definition queue.pb.h:193
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:184
void CopyFrom(const QueuedMessageEntry_Role &from)
friend void swap(QueuedMessageEntry_Role &a, QueuedMessageEntry_Role &b)
Definition queue.pb.h:203
QueuedMessageEntry_Role(QueuedMessageEntry_Role &&from) noexcept
Definition queue.pb.h:154
void Swap(QueuedMessageEntry_Role *other)
Definition queue.pb.h:206
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:187
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:180
void set_setting(::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting value)
Definition queue.pb.h:1874
QueuedMessageEntry_Role * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:227
static constexpr RoleSetting RoleSetting_MAX
Definition queue.pb.h:281
QueuedMessageEntry_Role & operator=(const QueuedMessageEntry_Role &from)
Definition queue.pb.h:159
PROTOBUF_NODISCARD std::string * release_field()
Definition queue.pb.h:1918
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:190
void MergeFrom(const QueuedMessageEntry_Role &from)
Definition queue.pb.h:233
static bool RoleSetting_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, RoleSetting *value)
Definition queue.pb.h:296
::goby::acomms::protobuf::QueuedMessageEntry_RoleType type() const
Definition queue.pb.h:1836
PROTOBUF_CONSTEXPR QueuedMessageEntry_Role(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
void set_type(::goby::acomms::protobuf::QueuedMessageEntry_RoleType value)
Definition queue.pb.h:1845
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:177
void CopyFrom(const QueuedMessageEntry &from)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:420
void set_protobuf_name(ArgT0 &&arg0, ArgT... args)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
QueuedMessageEntry(const QueuedMessageEntry &from)
QueuedMessageEntry & operator=(const QueuedMessageEntry &from)
Definition queue.pb.h:399
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:417
void UnsafeArenaSwap(QueuedMessageEntry *other)
Definition queue.pb.h:459
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
static bool RoleType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, RoleType *value)
Definition queue.pb.h:540
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:424
PROTOBUF_CONSTEXPR QueuedMessageEntry(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
friend void swap(QueuedMessageEntry &a, QueuedMessageEntry &b)
Definition queue.pb.h:443
static const QueuedMessageEntry * internal_default_instance()
Definition queue.pb.h:436
QueuedMessageEntry(QueuedMessageEntry &&from) noexcept
Definition queue.pb.h:394
QueuedMessageEntry(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
QueuedMessageEntry * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:467
QueuedMessageEntry & operator=(QueuedMessageEntry &&from) noexcept
Definition queue.pb.h:403
static const QueuedMessageEntry & default_instance()
Definition queue.pb.h:433
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * RoleType_descriptor()
Definition queue.pb.h:530
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:427
void MergeFrom(const QueuedMessageEntry &from)
Definition queue.pb.h:473
void Swap(QueuedMessageEntry *other)
Definition queue.pb.h:446
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:430
static const std::string & RoleType_Name(T enum_t_value)
Definition queue.pb.h:534
void set_encoded_message(ArgT0 &&arg0, ArgT... args)
void CopyFrom(const QueuedMessageMeta &from)
QueuedMessageMeta & operator=(QueuedMessageMeta &&from) noexcept
Definition queue.pb.h:1544
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition queue.pb.h:1558
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
PROTOBUF_CONSTEXPR QueuedMessageMeta(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
static const QueuedMessageMeta & default_instance()
Definition queue.pb.h:1574
QueuedMessageMeta(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
boost::units::make_scaled_unit< boost::units::unit< time_dimension, boost::units::si::system >, boost::units::scale< 10, boost::units::static_rational<-6 > > >::type time_unit
Definition queue.pb.h:1761
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition queue.pb.h:1571
QueuedMessageMeta(QueuedMessageMeta &&from) noexcept
Definition queue.pb.h:1535
boost::units::quantity< time_unit, google::protobuf::uint64 > time_with_units() const
Definition queue.pb.h:1771
QueuedMessageMeta & operator=(const QueuedMessageMeta &from)
Definition queue.pb.h:1540
void Swap(QueuedMessageMeta *other)
Definition queue.pb.h:1587
friend void swap(QueuedMessageMeta &a, QueuedMessageMeta &b)
Definition queue.pb.h:1584
void UnsafeArenaSwap(QueuedMessageMeta *other)
Definition queue.pb.h:1600
static const QueuedMessageMeta * internal_default_instance()
Definition queue.pb.h:1577
QueuedMessageMeta(const QueuedMessageMeta &from)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
void set_last_sent_time_with_units(Quantity value_w_units)
Definition queue.pb.h:1779
void MergeFrom(const QueuedMessageMeta &from)
Definition queue.pb.h:1614
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition queue.pb.h:1568
boost::units::derived_dimension< boost::units::time_base_dimension, 1 >::type time_dimension
Definition queue.pb.h:1759
boost::units::quantity< last_sent_time_unit, google::protobuf::uint64 > last_sent_time_with_units() const
Definition queue.pb.h:1786
boost::units::make_scaled_unit< boost::units::unit< last_sent_time_dimension, boost::units::si::system >, boost::units::scale< 10, boost::units::static_rational<-6 > > >::type last_sent_time_unit
Definition queue.pb.h:1776
void set_time_with_units(Quantity value_w_units)
Definition queue.pb.h:1764
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition queue.pb.h:1565
QueuedMessageMeta * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition queue.pb.h:1608
boost::units::derived_dimension< boost::units::time_base_dimension, 1 >::type last_sent_time_dimension
Definition queue.pb.h:1774
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition queue.pb.h:1561
QueueSizeDefaultTypeInternal _QueueSize_default_instance_
constexpr QueuedMessageEntry_Role_RoleSetting QueuedMessageEntry_Role_RoleSetting_RoleSetting_MAX
Definition queue.pb.h:103
QueuedMessageEntry_RoleDefaultTypeInternal _QueuedMessageEntry_Role_default_instance_
QueuedMessageEntryDefaultTypeInternal _QueuedMessageEntry_default_instance_
constexpr QueuedMessageEntry_RoleType QueuedMessageEntry_RoleType_RoleType_MAX
Definition queue.pb.h:127
bool QueuedMessageEntry_RoleType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, QueuedMessageEntry_RoleType *value)
Definition queue.pb.h:139
QueueFlushDefaultTypeInternal _QueueFlush_default_instance_
const std::string & QueuedMessageEntry_RoleType_Name(T enum_t_value)
Definition queue.pb.h:132
bool Manipulator_IsValid(int value)
QueueManagerConfig_DCCLEncryptRuleDefaultTypeInternal _QueueManagerConfig_DCCLEncryptRule_default_instance_
@ QueuedMessageEntry_RoleType_DESTINATION_ID
Definition queue.pb.h:122
@ QueuedMessageEntry_RoleType_TIMESTAMP
Definition queue.pb.h:123
@ QueuedMessageEntry_RoleType_SOURCE_ID
Definition queue.pb.h:121
constexpr QueuedMessageEntry_RoleType QueuedMessageEntry_RoleType_RoleType_MIN
Definition queue.pb.h:126
bool QueuedMessageEntry_Role_RoleSetting_IsValid(int value)
bool QueuedMessageEntry_Role_RoleSetting_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, QueuedMessageEntry_Role_RoleSetting *value)
Definition queue.pb.h:115
const std::string & QueuedMessageEntry_Role_RoleSetting_Name(T enum_t_value)
Definition queue.pb.h:108
constexpr int QueuedMessageEntry_Role_RoleSetting_RoleSetting_ARRAYSIZE
Definition queue.pb.h:104
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * QueuedMessageEntry_RoleType_descriptor()
QueuedMessageMetaDefaultTypeInternal _QueuedMessageMeta_default_instance_
constexpr int QueuedMessageEntry_RoleType_RoleType_ARRAYSIZE
Definition queue.pb.h:128
@ QueuedMessageEntry_Role_RoleSetting_STATIC
Definition queue.pb.h:98
@ QueuedMessageEntry_Role_RoleSetting_FIELD_VALUE
Definition queue.pb.h:99
bool QueuedMessageEntry_RoleType_IsValid(int value)
constexpr QueuedMessageEntry_Role_RoleSetting QueuedMessageEntry_Role_RoleSetting_RoleSetting_MIN
Definition queue.pb.h:102
QueueManagerConfigDefaultTypeInternal _QueueManagerConfig_default_instance_
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * QueuedMessageEntry_Role_RoleSetting_descriptor()
The global namespace for the Goby project.
extern ::PROTOBUF_NAMESPACE_ID::internal::ExtensionIdentifier< ::PROTOBUF_NAMESPACE_ID::FieldOptions, ::PROTOBUF_NAMESPACE_ID::internal::MessageTypeTraits< ::goby::GobyFieldOptions >, 11, false > field
#define ByteSizeLong
const EnumDescriptor * GetEnumDescriptor< ::goby::acomms::protobuf::QueuedMessageEntry_Role_RoleSetting >()
Definition queue.pb.h:3048
const EnumDescriptor * GetEnumDescriptor< ::goby::acomms::protobuf::QueuedMessageEntry_RoleType >()
Definition queue.pb.h:3053
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2facomms_2fprotobuf_2fqueue_2eproto