4#ifndef GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
5#define GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
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
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.
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>
31#include <google/protobuf/extension_set.h>
32#include <google/protobuf/generated_enum_reflection.h>
33#include <google/protobuf/unknown_field_set.h>
35#include <boost/units/quantity.hpp>
36#include <boost/units/absolute.hpp>
37#include <boost/units/dimensionless_type.hpp>
38#include <boost/units/make_scaled_unit.hpp>
40#include <google/protobuf/port_def.inc>
41#define PROTOBUF_INTERNAL_EXPORT_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
42PROTOBUF_NAMESPACE_OPEN
46PROTOBUF_NAMESPACE_CLOSE
57struct InprocControlDefaultTypeInternal;
60struct ManagerRequestDefaultTypeInternal;
63struct ManagerResponseDefaultTypeInternal;
66struct SocketDefaultTypeInternal;
71PROTOBUF_NAMESPACE_OPEN
76PROTOBUF_NAMESPACE_CLOSE
95 static_assert(::std::is_same<T, Socket_SocketType>::value ||
96 ::std::is_integral<T>::value,
97 "Incorrect type passed to function Socket_SocketType_Name.");
98 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
103 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_SocketType>(
121 static_assert(::std::is_same<T, Socket_Transport>::value ||
122 ::std::is_integral<T>::value,
123 "Incorrect type passed to function Socket_Transport_Name.");
124 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
129 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_Transport>(
144 static_assert(::std::is_same<T, Socket_ConnectOrBind>::value ||
145 ::std::is_integral<T>::value,
146 "Incorrect type passed to function Socket_ConnectOrBind_Name.");
147 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
152 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_ConnectOrBind>(
174 static_assert(::std::is_same<T, InprocControl_InprocControlType>::value ||
175 ::std::is_integral<T>::value,
176 "Incorrect type passed to function InprocControl_InprocControlType_Name.");
177 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
182 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<InprocControl_InprocControlType>(
197 static_assert(::std::is_same<T, Request>::value ||
198 ::std::is_integral<T>::value,
199 "Incorrect type passed to function Request_Name.");
200 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
204 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
Request* value) {
205 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Request>(
211 public ::PROTOBUF_NAMESPACE_ID::Message {
215 explicit PROTOBUF_CONSTEXPR
ManagerRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
220 *
this = ::std::move(from);
228 if (
this == &from)
return *
this;
229 if (GetOwningArena() == from.GetOwningArena()
230 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
231 && GetOwningArena() !=
nullptr
242 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
245 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
248 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
271 if (other ==
this)
return;
272 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
273 if (GetOwningArena() !=
nullptr &&
274 GetOwningArena() == other->GetOwningArena()) {
276 if (GetOwningArena() == other->GetOwningArena()) {
280 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
284 if (other ==
this)
return;
285 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
292 return CreateMaybeMessage<ManagerRequest>(arena);
294 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
296 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
298 ManagerRequest::MergeImpl(*
this, from);
301 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
303 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
309 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
313 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned);
315 void SetCachedSize(
int size)
const final;
319 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
320 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
321 return "goby.zeromq.protobuf.ManagerRequest";
325 bool is_message_owned =
false);
329 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*
GetClassData() const final;
346 bool _internal_has_client_name()
const;
350 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
356 const std::string& _internal_client_name()
const;
357 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_client_name(
const std::string& value);
358 std::string* _internal_mutable_client_name();
364 bool _internal_has_client_pid()
const;
370 int32_t _internal_client_pid()
const;
371 void _internal_set_client_pid(int32_t value);
377 bool _internal_has_ready()
const;
383 bool _internal_ready()
const;
384 void _internal_set_ready(
bool value);
390 bool _internal_has_request()
const;
405 size_t RequiredFieldsByteSizeFallback()
const;
407 template <
typename T>
friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
408 typedef void InternalArenaConstructable_;
409 typedef void DestructorSkippable_;
411 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
412 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
413 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_name_;
419 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
424 public ::PROTOBUF_NAMESPACE_ID::Message {
428 explicit PROTOBUF_CONSTEXPR
Socket(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
433 *
this = ::std::move(from);
441 if (
this == &from)
return *
this;
442 if (GetOwningArena() == from.GetOwningArena()
443 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
444 && GetOwningArena() !=
nullptr
455 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
458 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
461 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
462 return GetDescriptor();
465 return default_instance().GetMetadata().descriptor;
468 return default_instance().GetMetadata().reflection;
471 return *internal_default_instance();
474 return reinterpret_cast<const Socket*
>(
477 static constexpr int kIndexInFileMessages =
484 if (other ==
this)
return;
485 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
486 if (GetOwningArena() !=
nullptr &&
487 GetOwningArena() == other->GetOwningArena()) {
489 if (GetOwningArena() == other->GetOwningArena()) {
493 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
497 if (other ==
this)
return;
498 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
504 Socket*
New(::PROTOBUF_NAMESPACE_ID::Arena* arena =
nullptr) const final {
505 return CreateMaybeMessage<Socket>(arena);
507 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
509 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
511 Socket::MergeImpl(*
this, from);
514 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
516 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
517 bool IsInitialized() const final;
520 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
521 uint8_t* _InternalSerialize(
522 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
523 int GetCachedSize() const final {
return _impl_._cached_size_.Get(); }
526 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned);
528 void SetCachedSize(
int size)
const final;
529 void InternalSwap(
Socket* other);
532 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
533 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
534 return "goby.zeromq.protobuf.Socket";
537 explicit Socket(::PROTOBUF_NAMESPACE_ID::Arena* arena,
538 bool is_message_owned =
false);
542 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*
GetClassData() const final;
544 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
550 Socket_SocketType_PUBLISH;
552 Socket_SocketType_SUBSCRIBE;
554 Socket_SocketType_REPLY;
556 Socket_SocketType_REQUEST;
557 static inline
bool SocketType_IsValid(
int value) {
564 static constexpr int SocketType_ARRAYSIZE =
566 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
572 static_assert(::std::is_same<T, SocketType>::value ||
573 ::std::is_integral<T>::value,
574 "Incorrect type passed to function SocketType_Name.");
600 static constexpr int Transport_ARRAYSIZE =
602 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
608 static_assert(::std::is_same<T, Transport>::value ||
609 ::std::is_integral<T>::value,
610 "Incorrect type passed to function Transport_Name.");
630 static constexpr int ConnectOrBind_ARRAYSIZE =
632 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
638 static_assert(::std::is_same<T, ConnectOrBind>::value ||
639 ::std::is_integral<T>::value,
640 "Incorrect type passed to function ConnectOrBind_Name.");
651 kEthernetAddressFieldNumber = 5,
652 kMulticastAddressFieldNumber = 6,
653 kSocketNameFieldNumber = 8,
654 kSocketIdFieldNumber = 2,
655 kSocketTypeFieldNumber = 1,
656 kTransportFieldNumber = 3,
657 kConnectOrBindFieldNumber = 4,
658 kEthernetPortFieldNumber = 7,
659 kSendQueueSizeFieldNumber = 10,
660 kReceiveQueueSizeFieldNumber = 11,
663 bool has_ethernet_address()
const;
665 bool _internal_has_ethernet_address()
const;
667 void clear_ethernet_address();
668 const std::string& ethernet_address()
const;
669 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
671 std::string* mutable_ethernet_address();
672 PROTOBUF_NODISCARD std::string* release_ethernet_address();
673 void set_allocated_ethernet_address(std::string* ethernet_address);
675 const std::string& _internal_ethernet_address()
const;
676 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_ethernet_address(
const std::string& value);
677 std::string* _internal_mutable_ethernet_address();
681 bool has_multicast_address()
const;
683 bool _internal_has_multicast_address()
const;
685 void clear_multicast_address();
686 const std::string& multicast_address()
const;
687 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
689 std::string* mutable_multicast_address();
690 PROTOBUF_NODISCARD std::string* release_multicast_address();
691 void set_allocated_multicast_address(std::string* multicast_address);
693 const std::string& _internal_multicast_address()
const;
694 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_multicast_address(
const std::string& value);
695 std::string* _internal_mutable_multicast_address();
699 bool has_socket_name()
const;
701 bool _internal_has_socket_name()
const;
703 void clear_socket_name();
704 const std::string& socket_name()
const;
705 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
707 std::string* mutable_socket_name();
708 PROTOBUF_NODISCARD std::string* release_socket_name();
709 void set_allocated_socket_name(std::string* socket_name);
711 const std::string& _internal_socket_name()
const;
712 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_socket_name(
const std::string& value);
713 std::string* _internal_mutable_socket_name();
717 bool has_socket_id()
const;
719 bool _internal_has_socket_id()
const;
721 void clear_socket_id();
722 uint32_t socket_id()
const;
723 void set_socket_id(uint32_t value);
725 uint32_t _internal_socket_id()
const;
726 void _internal_set_socket_id(uint32_t value);
730 bool has_socket_type()
const;
732 bool _internal_has_socket_type()
const;
734 void clear_socket_type();
743 bool has_transport()
const;
745 bool _internal_has_transport()
const;
747 void clear_transport();
756 bool has_connect_or_bind()
const;
758 bool _internal_has_connect_or_bind()
const;
760 void clear_connect_or_bind();
769 bool has_ethernet_port()
const;
771 bool _internal_has_ethernet_port()
const;
773 void clear_ethernet_port();
774 uint32_t ethernet_port()
const;
775 void set_ethernet_port(uint32_t value);
777 uint32_t _internal_ethernet_port()
const;
778 void _internal_set_ethernet_port(uint32_t value);
782 bool has_send_queue_size()
const;
784 bool _internal_has_send_queue_size()
const;
786 void clear_send_queue_size();
787 uint32_t send_queue_size()
const;
788 void set_send_queue_size(uint32_t value);
790 uint32_t _internal_send_queue_size()
const;
791 void _internal_set_send_queue_size(uint32_t value);
795 bool has_receive_queue_size()
const;
797 bool _internal_has_receive_queue_size()
const;
799 void clear_receive_queue_size();
800 uint32_t receive_queue_size()
const;
801 void set_receive_queue_size(uint32_t value);
803 uint32_t _internal_receive_queue_size()
const;
804 void _internal_set_receive_queue_size(uint32_t value);
811 template <
typename T>
friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
812 typedef void InternalArenaConstructable_;
813 typedef void DestructorSkippable_;
815 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
816 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
817 static const ::PROTOBUF_NAMESPACE_ID::internal::LazyString _i_give_permission_to_break_this_code_default_ethernet_address_;
818 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr ethernet_address_;
819 static const ::PROTOBUF_NAMESPACE_ID::internal::LazyString _i_give_permission_to_break_this_code_default_multicast_address_;
820 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr multicast_address_;
821 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr socket_name_;
825 int connect_or_bind_;
826 uint32_t ethernet_port_;
827 uint32_t send_queue_size_;
828 uint32_t receive_queue_size_;
831 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
836 public ::PROTOBUF_NAMESPACE_ID::Message {
840 explicit PROTOBUF_CONSTEXPR
ManagerResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
845 *
this = ::std::move(from);
853 if (
this == &from)
return *
this;
854 if (GetOwningArena() == from.GetOwningArena()
855 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
856 && GetOwningArena() !=
nullptr
867 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
870 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
873 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
874 return GetDescriptor();
877 return default_instance().GetMetadata().descriptor;
880 return default_instance().GetMetadata().reflection;
883 return *internal_default_instance();
889 static constexpr int kIndexInFileMessages =
896 if (other ==
this)
return;
897 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
898 if (GetOwningArena() !=
nullptr &&
899 GetOwningArena() == other->GetOwningArena()) {
901 if (GetOwningArena() == other->GetOwningArena()) {
905 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
909 if (other ==
this)
return;
910 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
917 return CreateMaybeMessage<ManagerResponse>(arena);
919 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
921 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
923 ManagerResponse::MergeImpl(*
this, from);
926 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
928 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
929 bool IsInitialized() const final;
932 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
933 uint8_t* _InternalSerialize(
934 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
935 int GetCachedSize() const final {
return _impl_._cached_size_.Get(); }
938 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned);
940 void SetCachedSize(
int size)
const final;
944 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
945 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
946 return "goby.zeromq.protobuf.ManagerResponse";
950 bool is_message_owned =
false);
954 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*
GetClassData() const final;
956 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
963 kClientNameFieldNumber = 2,
964 kPublishSocketFieldNumber = 4,
965 kSubscribeSocketFieldNumber = 5,
966 kClientPidFieldNumber = 3,
967 kRequestFieldNumber = 1,
968 kHoldFieldNumber = 6,
971 bool has_client_name()
const;
973 bool _internal_has_client_name()
const;
975 void clear_client_name();
976 const std::string& client_name()
const;
977 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
979 std::string* mutable_client_name();
980 PROTOBUF_NODISCARD std::string* release_client_name();
981 void set_allocated_client_name(std::string* client_name);
983 const std::string& _internal_client_name()
const;
984 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_client_name(
const std::string& value);
985 std::string* _internal_mutable_client_name();
989 bool has_publish_socket()
const;
991 bool _internal_has_publish_socket()
const;
993 void clear_publish_socket();
994 const ::goby::zeromq::protobuf::Socket& publish_socket()
const;
995 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_publish_socket();
999 const ::goby::zeromq::protobuf::Socket& _internal_publish_socket()
const;
1002 void unsafe_arena_set_allocated_publish_socket(
1007 bool has_subscribe_socket()
const;
1009 bool _internal_has_subscribe_socket()
const;
1011 void clear_subscribe_socket();
1012 const ::goby::zeromq::protobuf::Socket& subscribe_socket()
const;
1013 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_subscribe_socket();
1017 const ::goby::zeromq::protobuf::Socket& _internal_subscribe_socket()
const;
1020 void unsafe_arena_set_allocated_subscribe_socket(
1025 bool has_client_pid()
const;
1027 bool _internal_has_client_pid()
const;
1029 void clear_client_pid();
1030 int32_t client_pid()
const;
1031 void set_client_pid(int32_t value);
1033 int32_t _internal_client_pid()
const;
1034 void _internal_set_client_pid(int32_t value);
1038 bool has_request()
const;
1040 bool _internal_has_request()
const;
1042 void clear_request();
1051 bool has_hold()
const;
1053 bool _internal_has_hold()
const;
1057 void set_hold(
bool value);
1059 bool _internal_hold()
const;
1060 void _internal_set_hold(
bool value);
1068 size_t RequiredFieldsByteSizeFallback()
const;
1070 template <
typename T>
friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1071 typedef void InternalArenaConstructable_;
1072 typedef void DestructorSkippable_;
1074 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1075 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1076 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_name_;
1079 int32_t client_pid_;
1084 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
1089 public ::PROTOBUF_NAMESPACE_ID::Message {
1093 explicit PROTOBUF_CONSTEXPR
InprocControl(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
1098 *
this = ::std::move(from);
1106 if (
this == &from)
return *
this;
1107 if (GetOwningArena() == from.GetOwningArena()
1108 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1109 && GetOwningArena() !=
nullptr
1112 InternalSwap(&from);
1120 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1123 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1127 return GetDescriptor();
1130 return default_instance().GetMetadata().descriptor;
1133 return default_instance().GetMetadata().reflection;
1136 return *internal_default_instance();
1142 static constexpr int kIndexInFileMessages =
1149 if (other ==
this)
return;
1150 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1151 if (GetOwningArena() !=
nullptr &&
1152 GetOwningArena() == other->GetOwningArena()) {
1154 if (GetOwningArena() == other->GetOwningArena()) {
1156 InternalSwap(other);
1158 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
1162 if (other ==
this)
return;
1163 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
1164 InternalSwap(other);
1170 return CreateMaybeMessage<InprocControl>(arena);
1172 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
1174 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
1176 InprocControl::MergeImpl(*
this, from);
1179 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
1181 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
1182 bool IsInitialized() const final;
1185 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
1186 uint8_t* _InternalSerialize(
1187 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1188 int GetCachedSize() const final {
return _impl_._cached_size_.Get(); }
1191 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena,
bool is_message_owned);
1193 void SetCachedSize(
int size)
const final;
1197 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1198 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1199 return "goby.zeromq.protobuf.InprocControl";
1203 bool is_message_owned =
false);
1207 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*
GetClassData() const final;
1209 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1215 InprocControl_InprocControlType_PUB_CONFIGURATION;
1217 InprocControl_InprocControlType_SUBSCRIBE;
1219 InprocControl_InprocControlType_SUBSCRIBE_ACK;
1221 InprocControl_InprocControlType_UNSUBSCRIBE;
1223 InprocControl_InprocControlType_UNSUBSCRIBE_ACK;
1225 InprocControl_InprocControlType_RECEIVE;
1227 InprocControl_InprocControlType_SHUTDOWN;
1229 InprocControl_InprocControlType_REQUEST_HOLD_STATE;
1231 InprocControl_InprocControlType_NOTIFY_HOLD_STATE;
1232 static inline
bool InprocControlType_IsValid(
int value) {
1239 static constexpr int InprocControlType_ARRAYSIZE =
1241 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
1245 template<
typename T>
1247 static_assert(::std::is_same<T, InprocControlType>::value ||
1248 ::std::is_integral<T>::value,
1249 "Incorrect type passed to function InprocControlType_Name.");
1260 kSubscriptionIdentifierFieldNumber = 3,
1261 kReceivedDataFieldNumber = 4,
1262 kPublishSocketFieldNumber = 2,
1263 kHoldFieldNumber = 10,
1264 kTypeFieldNumber = 1,
1267 bool has_subscription_identifier()
const;
1269 bool _internal_has_subscription_identifier()
const;
1271 void clear_subscription_identifier();
1272 const std::string& subscription_identifier()
const;
1273 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
1275 std::string* mutable_subscription_identifier();
1276 PROTOBUF_NODISCARD std::string* release_subscription_identifier();
1277 void set_allocated_subscription_identifier(std::string* subscription_identifier);
1279 const std::string& _internal_subscription_identifier()
const;
1280 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_subscription_identifier(
const std::string& value);
1281 std::string* _internal_mutable_subscription_identifier();
1285 bool has_received_data()
const;
1287 bool _internal_has_received_data()
const;
1289 void clear_received_data();
1290 const std::string& received_data()
const;
1291 template <
typename ArgT0 =
const std::string&,
typename... ArgT>
1293 std::string* mutable_received_data();
1294 PROTOBUF_NODISCARD std::string* release_received_data();
1295 void set_allocated_received_data(std::string* received_data);
1297 const std::string& _internal_received_data()
const;
1298 inline PROTOBUF_ALWAYS_INLINE
void _internal_set_received_data(
const std::string& value);
1299 std::string* _internal_mutable_received_data();
1303 bool has_publish_socket()
const;
1305 bool _internal_has_publish_socket()
const;
1307 void clear_publish_socket();
1308 const ::goby::zeromq::protobuf::Socket& publish_socket()
const;
1309 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_publish_socket();
1313 const ::goby::zeromq::protobuf::Socket& _internal_publish_socket()
const;
1316 void unsafe_arena_set_allocated_publish_socket(
1321 bool has_hold()
const;
1323 bool _internal_has_hold()
const;
1327 void set_hold(
bool value);
1329 bool _internal_hold()
const;
1330 void _internal_set_hold(
bool value);
1334 bool has_type()
const;
1336 bool _internal_has_type()
const;
1350 template <
typename T>
friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1351 typedef void InternalArenaConstructable_;
1352 typedef void DestructorSkippable_;
1354 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1355 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1356 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr subscription_identifier_;
1357 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr received_data_;
1363 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
1371 #pragma GCC diagnostic push
1372 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
1377inline bool ManagerRequest::_internal_has_request()
const {
1378 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
1381inline bool ManagerRequest::has_request()
const {
1382 return _internal_has_request();
1384inline void ManagerRequest::clear_request() {
1385 _impl_.request_ = 1;
1386 _impl_._has_bits_[0] &= ~0x00000008u;
1388inline ::goby::zeromq::protobuf::Request ManagerRequest::_internal_request()
const {
1391inline ::goby::zeromq::protobuf::Request ManagerRequest::request()
const {
1393 return _internal_request();
1397 _impl_._has_bits_[0] |= 0x00000008u;
1398 _impl_.request_ = value;
1401 _internal_set_request(value);
1406inline bool ManagerRequest::_internal_has_client_name()
const {
1407 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1410inline bool ManagerRequest::has_client_name()
const {
1411 return _internal_has_client_name();
1413inline void ManagerRequest::clear_client_name() {
1414 _impl_.client_name_.ClearToEmpty();
1415 _impl_._has_bits_[0] &= ~0x00000001u;
1417inline const std::string& ManagerRequest::client_name()
const {
1419 return _internal_client_name();
1421template <
typename ArgT0,
typename... ArgT>
1422inline PROTOBUF_ALWAYS_INLINE
1423void ManagerRequest::set_client_name(ArgT0&& arg0, ArgT... args) {
1424 _impl_._has_bits_[0] |= 0x00000001u;
1425 _impl_.client_name_.Set(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
1428inline std::string* ManagerRequest::mutable_client_name() {
1429 std::string* _s = _internal_mutable_client_name();
1433inline const std::string& ManagerRequest::_internal_client_name()
const {
1434 return _impl_.client_name_.Get();
1436inline void ManagerRequest::_internal_set_client_name(
const std::string& value) {
1437 _impl_._has_bits_[0] |= 0x00000001u;
1438 _impl_.client_name_.Set(value, GetArenaForAllocation());
1440inline std::string* ManagerRequest::_internal_mutable_client_name() {
1441 _impl_._has_bits_[0] |= 0x00000001u;
1442 return _impl_.client_name_.Mutable(GetArenaForAllocation());
1444inline std::string* ManagerRequest::release_client_name() {
1446 if (!_internal_has_client_name()) {
1449 _impl_._has_bits_[0] &= ~0x00000001u;
1450 auto* p = _impl_.client_name_.Release();
1451#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1452 if (_impl_.client_name_.IsDefault()) {
1453 _impl_.client_name_.Set(
"", GetArenaForAllocation());
1458inline void ManagerRequest::set_allocated_client_name(std::string* client_name) {
1459 if (client_name !=
nullptr) {
1460 _impl_._has_bits_[0] |= 0x00000001u;
1462 _impl_._has_bits_[0] &= ~0x00000001u;
1464 _impl_.client_name_.SetAllocated(client_name, GetArenaForAllocation());
1465#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1466 if (_impl_.client_name_.IsDefault()) {
1467 _impl_.client_name_.Set(
"", GetArenaForAllocation());
1474inline bool ManagerRequest::_internal_has_client_pid()
const {
1475 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
1478inline bool ManagerRequest::has_client_pid()
const {
1479 return _internal_has_client_pid();
1481inline void ManagerRequest::clear_client_pid() {
1482 _impl_.client_pid_ = 0;
1483 _impl_._has_bits_[0] &= ~0x00000002u;
1485inline int32_t ManagerRequest::_internal_client_pid()
const {
1486 return _impl_.client_pid_;
1488inline int32_t ManagerRequest::client_pid()
const {
1490 return _internal_client_pid();
1492inline void ManagerRequest::_internal_set_client_pid(int32_t value) {
1493 _impl_._has_bits_[0] |= 0x00000002u;
1494 _impl_.client_pid_ = value;
1496inline void ManagerRequest::set_client_pid(int32_t value) {
1497 _internal_set_client_pid(value);
1502inline bool ManagerRequest::_internal_has_ready()
const {
1503 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
1506inline bool ManagerRequest::has_ready()
const {
1507 return _internal_has_ready();
1509inline void ManagerRequest::clear_ready() {
1510 _impl_.ready_ =
false;
1511 _impl_._has_bits_[0] &= ~0x00000004u;
1513inline bool ManagerRequest::_internal_ready()
const {
1514 return _impl_.ready_;
1516inline bool ManagerRequest::ready()
const {
1518 return _internal_ready();
1520inline void ManagerRequest::_internal_set_ready(
bool value) {
1521 _impl_._has_bits_[0] |= 0x00000004u;
1522 _impl_.ready_ = value;
1524inline void ManagerRequest::set_ready(
bool value) {
1525 _internal_set_ready(value);
1534inline bool Socket::_internal_has_socket_type()
const {
1535 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
1538inline bool Socket::has_socket_type()
const {
1539 return _internal_has_socket_type();
1541inline void Socket::clear_socket_type() {
1542 _impl_.socket_type_ = 1;
1543 _impl_._has_bits_[0] &= ~0x00000010u;
1545inline ::goby::zeromq::protobuf::Socket_SocketType Socket::_internal_socket_type()
const {
1548inline ::goby::zeromq::protobuf::Socket_SocketType Socket::socket_type()
const {
1550 return _internal_socket_type();
1554 _impl_._has_bits_[0] |= 0x00000010u;
1555 _impl_.socket_type_ = value;
1558 _internal_set_socket_type(value);
1563inline bool Socket::_internal_has_socket_id()
const {
1564 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
1567inline bool Socket::has_socket_id()
const {
1568 return _internal_has_socket_id();
1570inline void Socket::clear_socket_id() {
1571 _impl_.socket_id_ = 0u;
1572 _impl_._has_bits_[0] &= ~0x00000008u;
1574inline uint32_t Socket::_internal_socket_id()
const {
1575 return _impl_.socket_id_;
1577inline uint32_t Socket::socket_id()
const {
1579 return _internal_socket_id();
1581inline void Socket::_internal_set_socket_id(uint32_t value) {
1582 _impl_._has_bits_[0] |= 0x00000008u;
1583 _impl_.socket_id_ = value;
1585inline void Socket::set_socket_id(uint32_t value) {
1586 _internal_set_socket_id(value);
1591inline bool Socket::_internal_has_transport()
const {
1592 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
1595inline bool Socket::has_transport()
const {
1596 return _internal_has_transport();
1598inline void Socket::clear_transport() {
1599 _impl_.transport_ = 5;
1600 _impl_._has_bits_[0] &= ~0x00000020u;
1602inline ::goby::zeromq::protobuf::Socket_Transport Socket::_internal_transport()
const {
1605inline ::goby::zeromq::protobuf::Socket_Transport Socket::transport()
const {
1607 return _internal_transport();
1611 _impl_._has_bits_[0] |= 0x00000020u;
1612 _impl_.transport_ = value;
1615 _internal_set_transport(value);
1620inline bool Socket::_internal_has_connect_or_bind()
const {
1621 bool value = (_impl_._has_bits_[0] & 0x00000040u) != 0;
1624inline bool Socket::has_connect_or_bind()
const {
1625 return _internal_has_connect_or_bind();
1627inline void Socket::clear_connect_or_bind() {
1628 _impl_.connect_or_bind_ = 1;
1629 _impl_._has_bits_[0] &= ~0x00000040u;
1631inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::_internal_connect_or_bind()
const {
1634inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::connect_or_bind()
const {
1636 return _internal_connect_or_bind();
1640 _impl_._has_bits_[0] |= 0x00000040u;
1641 _impl_.connect_or_bind_ = value;
1644 _internal_set_connect_or_bind(value);
1649inline bool Socket::_internal_has_ethernet_address()
const {
1650 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1653inline bool Socket::has_ethernet_address()
const {
1654 return _internal_has_ethernet_address();
1656inline void Socket::clear_ethernet_address() {
1657 _impl_.ethernet_address_.ClearToDefault(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_, GetArenaForAllocation());
1658 _impl_._has_bits_[0] &= ~0x00000001u;
1660inline const std::string& Socket::ethernet_address()
const {
1662 if (_impl_.ethernet_address_.IsDefault())
return Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_.get();
1663 return _internal_ethernet_address();
1665template <
typename ArgT0,
typename... ArgT>
1666inline PROTOBUF_ALWAYS_INLINE
1667void Socket::set_ethernet_address(ArgT0&& arg0, ArgT... args) {
1668 _impl_._has_bits_[0] |= 0x00000001u;
1669 _impl_.ethernet_address_.Set(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
1672inline std::string* Socket::mutable_ethernet_address() {
1673 std::string* _s = _internal_mutable_ethernet_address();
1677inline const std::string& Socket::_internal_ethernet_address()
const {
1678 return _impl_.ethernet_address_.Get();
1680inline void Socket::_internal_set_ethernet_address(
const std::string& value) {
1681 _impl_._has_bits_[0] |= 0x00000001u;
1682 _impl_.ethernet_address_.Set(value, GetArenaForAllocation());
1684inline std::string* Socket::_internal_mutable_ethernet_address() {
1685 _impl_._has_bits_[0] |= 0x00000001u;
1686 return _impl_.ethernet_address_.Mutable(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_, GetArenaForAllocation());
1688inline std::string* Socket::release_ethernet_address() {
1690 if (!_internal_has_ethernet_address()) {
1693 _impl_._has_bits_[0] &= ~0x00000001u;
1694 auto* p = _impl_.ethernet_address_.Release();
1697inline void Socket::set_allocated_ethernet_address(std::string* ethernet_address) {
1698 if (ethernet_address !=
nullptr) {
1699 _impl_._has_bits_[0] |= 0x00000001u;
1701 _impl_._has_bits_[0] &= ~0x00000001u;
1703 _impl_.ethernet_address_.SetAllocated(ethernet_address, GetArenaForAllocation());
1708inline bool Socket::_internal_has_multicast_address()
const {
1709 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
1712inline bool Socket::has_multicast_address()
const {
1713 return _internal_has_multicast_address();
1715inline void Socket::clear_multicast_address() {
1716 _impl_.multicast_address_.ClearToDefault(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_multicast_address_, GetArenaForAllocation());
1717 _impl_._has_bits_[0] &= ~0x00000002u;
1719inline const std::string& Socket::multicast_address()
const {
1721 if (_impl_.multicast_address_.IsDefault())
return Impl_::_i_give_permission_to_break_this_code_default_multicast_address_.get();
1722 return _internal_multicast_address();
1724template <
typename ArgT0,
typename... ArgT>
1725inline PROTOBUF_ALWAYS_INLINE
1726void Socket::set_multicast_address(ArgT0&& arg0, ArgT... args) {
1727 _impl_._has_bits_[0] |= 0x00000002u;
1728 _impl_.multicast_address_.Set(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
1731inline std::string* Socket::mutable_multicast_address() {
1732 std::string* _s = _internal_mutable_multicast_address();
1736inline const std::string& Socket::_internal_multicast_address()
const {
1737 return _impl_.multicast_address_.Get();
1739inline void Socket::_internal_set_multicast_address(
const std::string& value) {
1740 _impl_._has_bits_[0] |= 0x00000002u;
1741 _impl_.multicast_address_.Set(value, GetArenaForAllocation());
1743inline std::string* Socket::_internal_mutable_multicast_address() {
1744 _impl_._has_bits_[0] |= 0x00000002u;
1745 return _impl_.multicast_address_.Mutable(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_multicast_address_, GetArenaForAllocation());
1747inline std::string* Socket::release_multicast_address() {
1749 if (!_internal_has_multicast_address()) {
1752 _impl_._has_bits_[0] &= ~0x00000002u;
1753 auto* p = _impl_.multicast_address_.Release();
1756inline void Socket::set_allocated_multicast_address(std::string* multicast_address) {
1757 if (multicast_address !=
nullptr) {
1758 _impl_._has_bits_[0] |= 0x00000002u;
1760 _impl_._has_bits_[0] &= ~0x00000002u;
1762 _impl_.multicast_address_.SetAllocated(multicast_address, GetArenaForAllocation());
1767inline bool Socket::_internal_has_ethernet_port()
const {
1768 bool value = (_impl_._has_bits_[0] & 0x00000080u) != 0;
1771inline bool Socket::has_ethernet_port()
const {
1772 return _internal_has_ethernet_port();
1774inline void Socket::clear_ethernet_port() {
1775 _impl_.ethernet_port_ = 11142u;
1776 _impl_._has_bits_[0] &= ~0x00000080u;
1778inline uint32_t Socket::_internal_ethernet_port()
const {
1779 return _impl_.ethernet_port_;
1781inline uint32_t Socket::ethernet_port()
const {
1783 return _internal_ethernet_port();
1785inline void Socket::_internal_set_ethernet_port(uint32_t value) {
1786 _impl_._has_bits_[0] |= 0x00000080u;
1787 _impl_.ethernet_port_ = value;
1789inline void Socket::set_ethernet_port(uint32_t value) {
1790 _internal_set_ethernet_port(value);
1795inline bool Socket::_internal_has_socket_name()
const {
1796 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
1799inline bool Socket::has_socket_name()
const {
1800 return _internal_has_socket_name();
1802inline void Socket::clear_socket_name() {
1803 _impl_.socket_name_.ClearToEmpty();
1804 _impl_._has_bits_[0] &= ~0x00000004u;
1806inline const std::string& Socket::socket_name()
const {
1808 return _internal_socket_name();
1810template <
typename ArgT0,
typename... ArgT>
1811inline PROTOBUF_ALWAYS_INLINE
1812void Socket::set_socket_name(ArgT0&& arg0, ArgT... args) {
1813 _impl_._has_bits_[0] |= 0x00000004u;
1814 _impl_.socket_name_.Set(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
1817inline std::string* Socket::mutable_socket_name() {
1818 std::string* _s = _internal_mutable_socket_name();
1822inline const std::string& Socket::_internal_socket_name()
const {
1823 return _impl_.socket_name_.Get();
1825inline void Socket::_internal_set_socket_name(
const std::string& value) {
1826 _impl_._has_bits_[0] |= 0x00000004u;
1827 _impl_.socket_name_.Set(value, GetArenaForAllocation());
1829inline std::string* Socket::_internal_mutable_socket_name() {
1830 _impl_._has_bits_[0] |= 0x00000004u;
1831 return _impl_.socket_name_.Mutable(GetArenaForAllocation());
1833inline std::string* Socket::release_socket_name() {
1835 if (!_internal_has_socket_name()) {
1838 _impl_._has_bits_[0] &= ~0x00000004u;
1839 auto* p = _impl_.socket_name_.Release();
1840#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1841 if (_impl_.socket_name_.IsDefault()) {
1842 _impl_.socket_name_.Set(
"", GetArenaForAllocation());
1847inline void Socket::set_allocated_socket_name(std::string* socket_name) {
1848 if (socket_name !=
nullptr) {
1849 _impl_._has_bits_[0] |= 0x00000004u;
1851 _impl_._has_bits_[0] &= ~0x00000004u;
1853 _impl_.socket_name_.SetAllocated(socket_name, GetArenaForAllocation());
1854#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1855 if (_impl_.socket_name_.IsDefault()) {
1856 _impl_.socket_name_.Set(
"", GetArenaForAllocation());
1863inline bool Socket::_internal_has_send_queue_size()
const {
1864 bool value = (_impl_._has_bits_[0] & 0x00000100u) != 0;
1867inline bool Socket::has_send_queue_size()
const {
1868 return _internal_has_send_queue_size();
1870inline void Socket::clear_send_queue_size() {
1871 _impl_.send_queue_size_ = 1000u;
1872 _impl_._has_bits_[0] &= ~0x00000100u;
1874inline uint32_t Socket::_internal_send_queue_size()
const {
1875 return _impl_.send_queue_size_;
1877inline uint32_t Socket::send_queue_size()
const {
1879 return _internal_send_queue_size();
1881inline void Socket::_internal_set_send_queue_size(uint32_t value) {
1882 _impl_._has_bits_[0] |= 0x00000100u;
1883 _impl_.send_queue_size_ = value;
1885inline void Socket::set_send_queue_size(uint32_t value) {
1886 _internal_set_send_queue_size(value);
1891inline bool Socket::_internal_has_receive_queue_size()
const {
1892 bool value = (_impl_._has_bits_[0] & 0x00000200u) != 0;
1895inline bool Socket::has_receive_queue_size()
const {
1896 return _internal_has_receive_queue_size();
1898inline void Socket::clear_receive_queue_size() {
1899 _impl_.receive_queue_size_ = 1000u;
1900 _impl_._has_bits_[0] &= ~0x00000200u;
1902inline uint32_t Socket::_internal_receive_queue_size()
const {
1903 return _impl_.receive_queue_size_;
1905inline uint32_t Socket::receive_queue_size()
const {
1907 return _internal_receive_queue_size();
1909inline void Socket::_internal_set_receive_queue_size(uint32_t value) {
1910 _impl_._has_bits_[0] |= 0x00000200u;
1911 _impl_.receive_queue_size_ = value;
1913inline void Socket::set_receive_queue_size(uint32_t value) {
1914 _internal_set_receive_queue_size(value);
1923inline bool ManagerResponse::_internal_has_request()
const {
1924 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
1927inline bool ManagerResponse::has_request()
const {
1928 return _internal_has_request();
1930inline void ManagerResponse::clear_request() {
1931 _impl_.request_ = 1;
1932 _impl_._has_bits_[0] &= ~0x00000010u;
1934inline ::goby::zeromq::protobuf::Request ManagerResponse::_internal_request()
const {
1937inline ::goby::zeromq::protobuf::Request ManagerResponse::request()
const {
1939 return _internal_request();
1943 _impl_._has_bits_[0] |= 0x00000010u;
1944 _impl_.request_ = value;
1947 _internal_set_request(value);
1952inline bool ManagerResponse::_internal_has_client_name()
const {
1953 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1956inline bool ManagerResponse::has_client_name()
const {
1957 return _internal_has_client_name();
1959inline void ManagerResponse::clear_client_name() {
1960 _impl_.client_name_.ClearToEmpty();
1961 _impl_._has_bits_[0] &= ~0x00000001u;
1963inline const std::string& ManagerResponse::client_name()
const {
1965 return _internal_client_name();
1967template <
typename ArgT0,
typename... ArgT>
1968inline PROTOBUF_ALWAYS_INLINE
1969void ManagerResponse::set_client_name(ArgT0&& arg0, ArgT... args) {
1970 _impl_._has_bits_[0] |= 0x00000001u;
1971 _impl_.client_name_.Set(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
1974inline std::string* ManagerResponse::mutable_client_name() {
1975 std::string* _s = _internal_mutable_client_name();
1979inline const std::string& ManagerResponse::_internal_client_name()
const {
1980 return _impl_.client_name_.Get();
1982inline void ManagerResponse::_internal_set_client_name(
const std::string& value) {
1983 _impl_._has_bits_[0] |= 0x00000001u;
1984 _impl_.client_name_.Set(value, GetArenaForAllocation());
1986inline std::string* ManagerResponse::_internal_mutable_client_name() {
1987 _impl_._has_bits_[0] |= 0x00000001u;
1988 return _impl_.client_name_.Mutable(GetArenaForAllocation());
1990inline std::string* ManagerResponse::release_client_name() {
1992 if (!_internal_has_client_name()) {
1995 _impl_._has_bits_[0] &= ~0x00000001u;
1996 auto* p = _impl_.client_name_.Release();
1997#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1998 if (_impl_.client_name_.IsDefault()) {
1999 _impl_.client_name_.Set(
"", GetArenaForAllocation());
2004inline void ManagerResponse::set_allocated_client_name(std::string* client_name) {
2005 if (client_name !=
nullptr) {
2006 _impl_._has_bits_[0] |= 0x00000001u;
2008 _impl_._has_bits_[0] &= ~0x00000001u;
2010 _impl_.client_name_.SetAllocated(client_name, GetArenaForAllocation());
2011#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2012 if (_impl_.client_name_.IsDefault()) {
2013 _impl_.client_name_.Set(
"", GetArenaForAllocation());
2020inline bool ManagerResponse::_internal_has_client_pid()
const {
2021 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2024inline bool ManagerResponse::has_client_pid()
const {
2025 return _internal_has_client_pid();
2027inline void ManagerResponse::clear_client_pid() {
2028 _impl_.client_pid_ = 0;
2029 _impl_._has_bits_[0] &= ~0x00000008u;
2031inline int32_t ManagerResponse::_internal_client_pid()
const {
2032 return _impl_.client_pid_;
2034inline int32_t ManagerResponse::client_pid()
const {
2036 return _internal_client_pid();
2038inline void ManagerResponse::_internal_set_client_pid(int32_t value) {
2039 _impl_._has_bits_[0] |= 0x00000008u;
2040 _impl_.client_pid_ = value;
2042inline void ManagerResponse::set_client_pid(int32_t value) {
2043 _internal_set_client_pid(value);
2048inline bool ManagerResponse::_internal_has_publish_socket()
const {
2049 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2050 PROTOBUF_ASSUME(!value || _impl_.publish_socket_ !=
nullptr);
2053inline bool ManagerResponse::has_publish_socket()
const {
2054 return _internal_has_publish_socket();
2056inline void ManagerResponse::clear_publish_socket() {
2057 if (_impl_.publish_socket_ !=
nullptr) _impl_.publish_socket_->Clear();
2058 _impl_._has_bits_[0] &= ~0x00000002u;
2060inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_publish_socket()
const {
2061 const ::goby::zeromq::protobuf::Socket* p = _impl_.publish_socket_;
2065inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::publish_socket()
const {
2067 return _internal_publish_socket();
2069inline void ManagerResponse::unsafe_arena_set_allocated_publish_socket(
2071 if (GetArenaForAllocation() ==
nullptr) {
2072 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(_impl_.publish_socket_);
2074 _impl_.publish_socket_ = publish_socket;
2075 if (publish_socket) {
2076 _impl_._has_bits_[0] |= 0x00000002u;
2078 _impl_._has_bits_[0] &= ~0x00000002u;
2082inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_publish_socket() {
2083 _impl_._has_bits_[0] &= ~0x00000002u;
2085 _impl_.publish_socket_ =
nullptr;
2086#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2087 auto* old =
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(temp);
2088 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2089 if (GetArenaForAllocation() ==
nullptr) {
delete old; }
2091 if (GetArenaForAllocation() !=
nullptr) {
2092 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2097inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_publish_socket() {
2099 _impl_._has_bits_[0] &= ~0x00000002u;
2101 _impl_.publish_socket_ =
nullptr;
2104inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_publish_socket() {
2105 _impl_._has_bits_[0] |= 0x00000002u;
2106 if (_impl_.publish_socket_ ==
nullptr) {
2108 _impl_.publish_socket_ = p;
2110 return _impl_.publish_socket_;
2112inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_publish_socket() {
2118 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2119 if (message_arena ==
nullptr) {
2120 delete _impl_.publish_socket_;
2122 if (publish_socket) {
2123 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2124 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(publish_socket);
2125 if (message_arena != submessage_arena) {
2126 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2127 message_arena, publish_socket, submessage_arena);
2129 _impl_._has_bits_[0] |= 0x00000002u;
2131 _impl_._has_bits_[0] &= ~0x00000002u;
2133 _impl_.publish_socket_ = publish_socket;
2138inline bool ManagerResponse::_internal_has_subscribe_socket()
const {
2139 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2140 PROTOBUF_ASSUME(!value || _impl_.subscribe_socket_ !=
nullptr);
2143inline bool ManagerResponse::has_subscribe_socket()
const {
2144 return _internal_has_subscribe_socket();
2146inline void ManagerResponse::clear_subscribe_socket() {
2147 if (_impl_.subscribe_socket_ !=
nullptr) _impl_.subscribe_socket_->Clear();
2148 _impl_._has_bits_[0] &= ~0x00000004u;
2150inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_subscribe_socket()
const {
2151 const ::goby::zeromq::protobuf::Socket* p = _impl_.subscribe_socket_;
2155inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::subscribe_socket()
const {
2157 return _internal_subscribe_socket();
2159inline void ManagerResponse::unsafe_arena_set_allocated_subscribe_socket(
2161 if (GetArenaForAllocation() ==
nullptr) {
2162 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(_impl_.subscribe_socket_);
2164 _impl_.subscribe_socket_ = subscribe_socket;
2165 if (subscribe_socket) {
2166 _impl_._has_bits_[0] |= 0x00000004u;
2168 _impl_._has_bits_[0] &= ~0x00000004u;
2172inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_subscribe_socket() {
2173 _impl_._has_bits_[0] &= ~0x00000004u;
2175 _impl_.subscribe_socket_ =
nullptr;
2176#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2177 auto* old =
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(temp);
2178 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2179 if (GetArenaForAllocation() ==
nullptr) {
delete old; }
2181 if (GetArenaForAllocation() !=
nullptr) {
2182 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2187inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_subscribe_socket() {
2189 _impl_._has_bits_[0] &= ~0x00000004u;
2191 _impl_.subscribe_socket_ =
nullptr;
2194inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_subscribe_socket() {
2195 _impl_._has_bits_[0] |= 0x00000004u;
2196 if (_impl_.subscribe_socket_ ==
nullptr) {
2198 _impl_.subscribe_socket_ = p;
2200 return _impl_.subscribe_socket_;
2202inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_subscribe_socket() {
2208 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2209 if (message_arena ==
nullptr) {
2210 delete _impl_.subscribe_socket_;
2212 if (subscribe_socket) {
2213 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2214 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(subscribe_socket);
2215 if (message_arena != submessage_arena) {
2216 subscribe_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2217 message_arena, subscribe_socket, submessage_arena);
2219 _impl_._has_bits_[0] |= 0x00000004u;
2221 _impl_._has_bits_[0] &= ~0x00000004u;
2223 _impl_.subscribe_socket_ = subscribe_socket;
2228inline bool ManagerResponse::_internal_has_hold()
const {
2229 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
2232inline bool ManagerResponse::has_hold()
const {
2233 return _internal_has_hold();
2235inline void ManagerResponse::clear_hold() {
2236 _impl_.hold_ =
true;
2237 _impl_._has_bits_[0] &= ~0x00000020u;
2239inline bool ManagerResponse::_internal_hold()
const {
2240 return _impl_.hold_;
2242inline bool ManagerResponse::hold()
const {
2244 return _internal_hold();
2246inline void ManagerResponse::_internal_set_hold(
bool value) {
2247 _impl_._has_bits_[0] |= 0x00000020u;
2248 _impl_.hold_ = value;
2250inline void ManagerResponse::set_hold(
bool value) {
2251 _internal_set_hold(value);
2260inline bool InprocControl::_internal_has_type()
const {
2261 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
2264inline bool InprocControl::has_type()
const {
2265 return _internal_has_type();
2267inline void InprocControl::clear_type() {
2269 _impl_._has_bits_[0] &= ~0x00000010u;
2271inline ::goby::zeromq::protobuf::InprocControl_InprocControlType InprocControl::_internal_type()
const {
2274inline ::goby::zeromq::protobuf::InprocControl_InprocControlType InprocControl::type()
const {
2276 return _internal_type();
2280 _impl_._has_bits_[0] |= 0x00000010u;
2281 _impl_.type_ = value;
2284 _internal_set_type(value);
2289inline bool InprocControl::_internal_has_publish_socket()
const {
2290 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2291 PROTOBUF_ASSUME(!value || _impl_.publish_socket_ !=
nullptr);
2294inline bool InprocControl::has_publish_socket()
const {
2295 return _internal_has_publish_socket();
2297inline void InprocControl::clear_publish_socket() {
2298 if (_impl_.publish_socket_ !=
nullptr) _impl_.publish_socket_->Clear();
2299 _impl_._has_bits_[0] &= ~0x00000004u;
2301inline const ::goby::zeromq::protobuf::Socket& InprocControl::_internal_publish_socket()
const {
2302 const ::goby::zeromq::protobuf::Socket* p = _impl_.publish_socket_;
2306inline const ::goby::zeromq::protobuf::Socket& InprocControl::publish_socket()
const {
2308 return _internal_publish_socket();
2310inline void InprocControl::unsafe_arena_set_allocated_publish_socket(
2312 if (GetArenaForAllocation() ==
nullptr) {
2313 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(_impl_.publish_socket_);
2315 _impl_.publish_socket_ = publish_socket;
2316 if (publish_socket) {
2317 _impl_._has_bits_[0] |= 0x00000004u;
2319 _impl_._has_bits_[0] &= ~0x00000004u;
2323inline ::goby::zeromq::protobuf::Socket* InprocControl::release_publish_socket() {
2324 _impl_._has_bits_[0] &= ~0x00000004u;
2326 _impl_.publish_socket_ =
nullptr;
2327#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2328 auto* old =
reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(temp);
2329 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2330 if (GetArenaForAllocation() ==
nullptr) {
delete old; }
2332 if (GetArenaForAllocation() !=
nullptr) {
2333 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2338inline ::goby::zeromq::protobuf::Socket* InprocControl::unsafe_arena_release_publish_socket() {
2340 _impl_._has_bits_[0] &= ~0x00000004u;
2342 _impl_.publish_socket_ =
nullptr;
2345inline ::goby::zeromq::protobuf::Socket* InprocControl::_internal_mutable_publish_socket() {
2346 _impl_._has_bits_[0] |= 0x00000004u;
2347 if (_impl_.publish_socket_ ==
nullptr) {
2349 _impl_.publish_socket_ = p;
2351 return _impl_.publish_socket_;
2353inline ::goby::zeromq::protobuf::Socket* InprocControl::mutable_publish_socket() {
2359 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2360 if (message_arena ==
nullptr) {
2361 delete _impl_.publish_socket_;
2363 if (publish_socket) {
2364 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2365 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(publish_socket);
2366 if (message_arena != submessage_arena) {
2367 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2368 message_arena, publish_socket, submessage_arena);
2370 _impl_._has_bits_[0] |= 0x00000004u;
2372 _impl_._has_bits_[0] &= ~0x00000004u;
2374 _impl_.publish_socket_ = publish_socket;
2379inline bool InprocControl::_internal_has_subscription_identifier()
const {
2380 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2383inline bool InprocControl::has_subscription_identifier()
const {
2384 return _internal_has_subscription_identifier();
2386inline void InprocControl::clear_subscription_identifier() {
2387 _impl_.subscription_identifier_.ClearToEmpty();
2388 _impl_._has_bits_[0] &= ~0x00000001u;
2390inline const std::string& InprocControl::subscription_identifier()
const {
2392 return _internal_subscription_identifier();
2394template <
typename ArgT0,
typename... ArgT>
2395inline PROTOBUF_ALWAYS_INLINE
2396void InprocControl::set_subscription_identifier(ArgT0&& arg0, ArgT... args) {
2397 _impl_._has_bits_[0] |= 0x00000001u;
2398 _impl_.subscription_identifier_.SetBytes(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
2401inline std::string* InprocControl::mutable_subscription_identifier() {
2402 std::string* _s = _internal_mutable_subscription_identifier();
2406inline const std::string& InprocControl::_internal_subscription_identifier()
const {
2407 return _impl_.subscription_identifier_.Get();
2409inline void InprocControl::_internal_set_subscription_identifier(
const std::string& value) {
2410 _impl_._has_bits_[0] |= 0x00000001u;
2411 _impl_.subscription_identifier_.Set(value, GetArenaForAllocation());
2413inline std::string* InprocControl::_internal_mutable_subscription_identifier() {
2414 _impl_._has_bits_[0] |= 0x00000001u;
2415 return _impl_.subscription_identifier_.Mutable(GetArenaForAllocation());
2417inline std::string* InprocControl::release_subscription_identifier() {
2419 if (!_internal_has_subscription_identifier()) {
2422 _impl_._has_bits_[0] &= ~0x00000001u;
2423 auto* p = _impl_.subscription_identifier_.Release();
2424#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2425 if (_impl_.subscription_identifier_.IsDefault()) {
2426 _impl_.subscription_identifier_.Set(
"", GetArenaForAllocation());
2431inline void InprocControl::set_allocated_subscription_identifier(std::string* subscription_identifier) {
2432 if (subscription_identifier !=
nullptr) {
2433 _impl_._has_bits_[0] |= 0x00000001u;
2435 _impl_._has_bits_[0] &= ~0x00000001u;
2437 _impl_.subscription_identifier_.SetAllocated(subscription_identifier, GetArenaForAllocation());
2438#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2439 if (_impl_.subscription_identifier_.IsDefault()) {
2440 _impl_.subscription_identifier_.Set(
"", GetArenaForAllocation());
2447inline bool InprocControl::_internal_has_received_data()
const {
2448 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2451inline bool InprocControl::has_received_data()
const {
2452 return _internal_has_received_data();
2454inline void InprocControl::clear_received_data() {
2455 _impl_.received_data_.ClearToEmpty();
2456 _impl_._has_bits_[0] &= ~0x00000002u;
2458inline const std::string& InprocControl::received_data()
const {
2460 return _internal_received_data();
2462template <
typename ArgT0,
typename... ArgT>
2463inline PROTOBUF_ALWAYS_INLINE
2464void InprocControl::set_received_data(ArgT0&& arg0, ArgT... args) {
2465 _impl_._has_bits_[0] |= 0x00000002u;
2466 _impl_.received_data_.SetBytes(
static_cast<ArgT0 &&
>(arg0), args..., GetArenaForAllocation());
2469inline std::string* InprocControl::mutable_received_data() {
2470 std::string* _s = _internal_mutable_received_data();
2474inline const std::string& InprocControl::_internal_received_data()
const {
2475 return _impl_.received_data_.Get();
2477inline void InprocControl::_internal_set_received_data(
const std::string& value) {
2478 _impl_._has_bits_[0] |= 0x00000002u;
2479 _impl_.received_data_.Set(value, GetArenaForAllocation());
2481inline std::string* InprocControl::_internal_mutable_received_data() {
2482 _impl_._has_bits_[0] |= 0x00000002u;
2483 return _impl_.received_data_.Mutable(GetArenaForAllocation());
2485inline std::string* InprocControl::release_received_data() {
2487 if (!_internal_has_received_data()) {
2490 _impl_._has_bits_[0] &= ~0x00000002u;
2491 auto* p = _impl_.received_data_.Release();
2492#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2493 if (_impl_.received_data_.IsDefault()) {
2494 _impl_.received_data_.Set(
"", GetArenaForAllocation());
2499inline void InprocControl::set_allocated_received_data(std::string* received_data) {
2500 if (received_data !=
nullptr) {
2501 _impl_._has_bits_[0] |= 0x00000002u;
2503 _impl_._has_bits_[0] &= ~0x00000002u;
2505 _impl_.received_data_.SetAllocated(received_data, GetArenaForAllocation());
2506#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2507 if (_impl_.received_data_.IsDefault()) {
2508 _impl_.received_data_.Set(
"", GetArenaForAllocation());
2515inline bool InprocControl::_internal_has_hold()
const {
2516 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2519inline bool InprocControl::has_hold()
const {
2520 return _internal_has_hold();
2522inline void InprocControl::clear_hold() {
2523 _impl_.hold_ =
false;
2524 _impl_._has_bits_[0] &= ~0x00000008u;
2526inline bool InprocControl::_internal_hold()
const {
2527 return _impl_.hold_;
2529inline bool InprocControl::hold()
const {
2531 return _internal_hold();
2533inline void InprocControl::_internal_set_hold(
bool value) {
2534 _impl_._has_bits_[0] |= 0x00000008u;
2535 _impl_.hold_ = value;
2537inline void InprocControl::set_hold(
bool value) {
2538 _internal_set_hold(value);
2543 #pragma GCC diagnostic pop
2558PROTOBUF_NAMESPACE_OPEN
2563 return ::goby::zeromq::protobuf::Socket_SocketType_descriptor();
2568 return ::goby::zeromq::protobuf::Socket_Transport_descriptor();
2573 return ::goby::zeromq::protobuf::Socket_ConnectOrBind_descriptor();
2578 return ::goby::zeromq::protobuf::InprocControl_InprocControlType_descriptor();
2583 return ::goby::zeromq::protobuf::Request_descriptor();
2586PROTOBUF_NAMESPACE_CLOSE
2590#include <google/protobuf/port_undef.inc>
void CopyFrom(const InprocControl &from)
void Swap(InprocControl *other)
PROTOBUF_CONSTEXPR InprocControl(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
friend void swap(InprocControl &a, InprocControl &b)
InprocControl & operator=(InprocControl &&from) noexcept
static bool InprocControlType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, InprocControlType *value)
void MergeFrom(const InprocControl &from)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControlType_descriptor()
void UnsafeArenaSwap(InprocControl *other)
void set_subscription_identifier(ArgT0 &&arg0, ArgT... args)
InprocControl(const InprocControl &from)
void set_received_data(ArgT0 &&arg0, ArgT... args)
static const InprocControl * internal_default_instance()
~InprocControl() override
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
static const InprocControl & default_instance()
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
InprocControl & operator=(const InprocControl &from)
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
InprocControl * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
InprocControl(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
static const ClassData _class_data_
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
InprocControl(InprocControl &&from) noexcept
static const std::string & InprocControlType_Name(T enum_t_value)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
friend void swap(ManagerRequest &a, ManagerRequest &b)
void set_client_name(ArgT0 &&arg0, ArgT... args)
void CopyFrom(const ManagerRequest &from)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
void set_allocated_client_name(std::string *client_name)
ManagerRequest & operator=(ManagerRequest &&from) noexcept
void UnsafeArenaSwap(ManagerRequest *other)
bool has_client_pid() const
PROTOBUF_NODISCARD std::string * release_client_name()
::goby::zeromq::protobuf::Request request() const
void set_client_pid(int32_t value)
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
void set_request(::goby::zeromq::protobuf::Request value)
int32_t client_pid() const
ManagerRequest(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
ManagerRequest & operator=(const ManagerRequest &from)
bool IsInitialized() const final
void MergeFrom(const ManagerRequest &from)
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
void set_ready(bool value)
~ManagerRequest() override
size_t ByteSizeLong() const final
static const ManagerRequest & default_instance()
const std::string & client_name() const
int GetCachedSize() const final
static const ManagerRequest * internal_default_instance()
ManagerRequest(ManagerRequest &&from) noexcept
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
PROTOBUF_CONSTEXPR ManagerRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
void Swap(ManagerRequest *other)
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
ManagerRequest * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
bool has_client_name() const
ManagerRequest(const ManagerRequest &from)
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
static const ClassData _class_data_
static constexpr int kIndexInFileMessages
std::string * mutable_client_name()
ManagerResponse * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
friend void swap(ManagerResponse &a, ManagerResponse &b)
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
ManagerResponse & operator=(ManagerResponse &&from) noexcept
ManagerResponse(ManagerResponse &&from) noexcept
static const ManagerResponse * internal_default_instance()
~ManagerResponse() override
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
ManagerResponse(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
void CopyFrom(const ManagerResponse &from)
PROTOBUF_CONSTEXPR ManagerResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
void set_client_name(ArgT0 &&arg0, ArgT... args)
void Swap(ManagerResponse *other)
void UnsafeArenaSwap(ManagerResponse *other)
static const ManagerResponse & default_instance()
ManagerResponse & operator=(const ManagerResponse &from)
void MergeFrom(const ManagerResponse &from)
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
ManagerResponse(const ManagerResponse &from)
static const ClassData _class_data_
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
Socket(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Socket(Socket &&from) noexcept
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
Socket(const Socket &from)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
void set_ethernet_address(ArgT0 &&arg0, ArgT... args)
Socket * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * ConnectOrBind_descriptor()
static bool ConnectOrBind_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, ConnectOrBind *value)
Socket & operator=(const Socket &from)
static const Socket & default_instance()
static const Socket * internal_default_instance()
static const std::string & Transport_Name(T enum_t_value)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * SocketType_descriptor()
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
void UnsafeArenaSwap(Socket *other)
void set_multicast_address(ArgT0 &&arg0, ArgT... args)
Socket & operator=(Socket &&from) noexcept
Socket_Transport Transport
static bool Transport_IsValid(int value)
static const std::string & ConnectOrBind_Name(T enum_t_value)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
static const ClassData _class_data_
static bool ConnectOrBind_IsValid(int value)
Socket_ConnectOrBind ConnectOrBind
static const std::string & SocketType_Name(T enum_t_value)
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Transport_descriptor()
void MergeFrom(const Socket &from)
void CopyFrom(const Socket &from)
static bool SocketType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, SocketType *value)
friend void swap(Socket &a, Socket &b)
static bool Transport_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Transport *value)
void set_socket_name(ArgT0 &&arg0, ArgT... args)
PROTOBUF_CONSTEXPR Socket(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType >()
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Request >()
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport >()
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType >()
::goby::zeromq::protobuf::Socket * Arena::CreateMaybeMessage<::goby::zeromq::protobuf::Socket >(Arena *)
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind >()
constexpr Socket_SocketType Socket_SocketType_SocketType_MIN
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Request_descriptor()
constexpr Request Request_MAX
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_SocketType_descriptor()
ManagerRequestDefaultTypeInternal _ManagerRequest_default_instance_
bool Socket_SocketType_IsValid(int value)
bool Socket_Transport_IsValid(int value)
const std::string & Socket_ConnectOrBind_Name(T enum_t_value)
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_ConnectOrBind_descriptor()
constexpr int Socket_Transport_Transport_ARRAYSIZE
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MIN
const std::string & Socket_SocketType_Name(T enum_t_value)
InprocControlDefaultTypeInternal _InprocControl_default_instance_
bool InprocControl_InprocControlType_IsValid(int value)
@ PROVIDE_PUB_SUB_SOCKETS
@ Socket_SocketType_SUBSCRIBE
@ Socket_SocketType_PUBLISH
@ Socket_SocketType_REPLY
@ Socket_SocketType_REQUEST
constexpr Request Request_MIN
constexpr Socket_Transport Socket_Transport_Transport_MAX
const std::string & InprocControl_InprocControlType_Name(T enum_t_value)
constexpr int Socket_SocketType_SocketType_ARRAYSIZE
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MIN
bool Request_IsValid(int value)
@ Socket_Transport_INPROC
bool Socket_ConnectOrBind_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_ConnectOrBind *value)
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MAX
ManagerResponseDefaultTypeInternal _ManagerResponse_default_instance_
InprocControl_InprocControlType
@ InprocControl_InprocControlType_NOTIFY_HOLD_STATE
@ InprocControl_InprocControlType_RECEIVE
@ InprocControl_InprocControlType_SUBSCRIBE
@ InprocControl_InprocControlType_PUB_CONFIGURATION
@ InprocControl_InprocControlType_UNSUBSCRIBE
@ InprocControl_InprocControlType_SUBSCRIBE_ACK
@ InprocControl_InprocControlType_REQUEST_HOLD_STATE
@ InprocControl_InprocControlType_UNSUBSCRIBE_ACK
@ InprocControl_InprocControlType_SHUTDOWN
constexpr int Request_ARRAYSIZE
constexpr int Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE
bool Socket_SocketType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_SocketType *value)
@ Socket_ConnectOrBind_CONNECT
@ Socket_ConnectOrBind_BIND
constexpr Socket_SocketType Socket_SocketType_SocketType_MAX
bool InprocControl_InprocControlType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, InprocControl_InprocControlType *value)
SocketDefaultTypeInternal _Socket_default_instance_
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MAX
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_Transport_descriptor()
constexpr Socket_Transport Socket_Transport_Transport_MIN
const std::string & Socket_Transport_Name(T enum_t_value)
constexpr int InprocControl_InprocControlType_InprocControlType_ARRAYSIZE
bool Request_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Request *value)
const std::string & Request_Name(T enum_t_value)
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControl_InprocControlType_descriptor()
bool Socket_Transport_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_Transport *value)
bool Socket_ConnectOrBind_IsValid(int value)
The global namespace for the Goby project.
static const uint32_t offsets[]