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 < 3012000
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 3012004 < 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_table_driven.h>
27 #include <google/protobuf/generated_message_util.h>
28 #include <google/protobuf/inlined_string_field.h>
29 #include <google/protobuf/metadata_lite.h>
30 #include <google/protobuf/generated_message_reflection.h>
32 #include <google/protobuf/repeated_field.h>
33 #include <google/protobuf/extension_set.h>
34 #include <google/protobuf/generated_enum_reflection.h>
35 #include <google/protobuf/unknown_field_set.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>
42 #include <google/protobuf/port_def.inc>
43 #define PROTOBUF_INTERNAL_EXPORT_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
44 PROTOBUF_NAMESPACE_OPEN
48 PROTOBUF_NAMESPACE_CLOSE
52 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[]
54 static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
56 static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[4]
58 static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata
field_metadata[];
67 class InprocControlDefaultTypeInternal;
70 class ManagerRequestDefaultTypeInternal;
72 class ManagerResponse;
73 class ManagerResponseDefaultTypeInternal;
76 class SocketDefaultTypeInternal;
81 PROTOBUF_NAMESPACE_OPEN
82 template<> ::goby::zeromq::protobuf::InprocControl* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::InprocControl>(Arena*);
83 template<> ::goby::zeromq::protobuf::ManagerRequest* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::ManagerRequest>(Arena*);
84 template<> ::goby::zeromq::protobuf::ManagerResponse* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::ManagerResponse>(Arena*);
85 template<> ::goby::zeromq::protobuf::Socket* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(Arena*);
86 PROTOBUF_NAMESPACE_CLOSE
105 static_assert(::std::is_same<T, Socket_SocketType>::value ||
106 ::std::is_integral<T>::value,
107 "Incorrect type passed to function Socket_SocketType_Name.");
108 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
113 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_SocketType>(
131 static_assert(::std::is_same<T, Socket_Transport>::value ||
132 ::std::is_integral<T>::value,
133 "Incorrect type passed to function Socket_Transport_Name.");
134 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
139 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_Transport>(
154 static_assert(::std::is_same<T, Socket_ConnectOrBind>::value ||
155 ::std::is_integral<T>::value,
156 "Incorrect type passed to function Socket_ConnectOrBind_Name.");
157 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
162 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_ConnectOrBind>(
184 static_assert(::std::is_same<T, InprocControl_InprocControlType>::value ||
185 ::std::is_integral<T>::value,
186 "Incorrect type passed to function InprocControl_InprocControlType_Name.");
187 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
192 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<InprocControl_InprocControlType>(
207 static_assert(::std::is_same<T, Request>::value ||
208 ::std::is_integral<T>::value,
209 "Incorrect type passed to function Request_Name.");
210 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
214 const std::string& name,
Request* value) {
215 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Request>(
221 public ::PROTOBUF_NAMESPACE_ID::Message {
229 *
this = ::std::move(from);
232 inline ManagerRequest&
operator=(
const ManagerRequest& from) {
236 inline ManagerRequest&
operator=(ManagerRequest&& from) noexcept {
237 if (GetArena() == from.GetArena()) {
238 if (
this != &from) InternalSwap(&from);
246 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
249 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
252 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
253 return GetDescriptor();
256 return GetMetadataStatic().descriptor;
259 return GetMetadataStatic().reflection;
265 return reinterpret_cast<const ManagerRequest*
>(
268 static constexpr
int kIndexInFileMessages =
271 friend void swap(ManagerRequest& a, ManagerRequest& b) {
274 inline void Swap(ManagerRequest* other) {
275 if (other ==
this)
return;
276 if (GetArena() == other->GetArena()) {
279 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
283 if (other ==
this)
return;
284 GOOGLE_DCHECK(GetArena() == other->GetArena());
290 inline ManagerRequest*
New() const final {
291 return CreateMaybeMessage<ManagerRequest>(
nullptr);
294 ManagerRequest*
New(::PROTOBUF_NAMESPACE_ID::Arena* arena)
const final {
295 return CreateMaybeMessage<ManagerRequest>(arena);
297 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
298 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
301 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
302 bool IsInitialized() const final;
305 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
306 ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
307 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
308 int GetCachedSize() const final {
return _cached_size_.Get(); }
311 inline void SharedCtor();
312 inline void SharedDtor();
313 void SetCachedSize(
int size)
const final;
314 void InternalSwap(ManagerRequest* other);
315 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
316 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
317 return "goby.zeromq.protobuf.ManagerRequest";
322 static void ArenaDtor(
void*
object);
323 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
328 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
340 kClientNameFieldNumber = 2,
341 kClientPidFieldNumber = 3,
342 kReadyFieldNumber = 4,
343 kRequestFieldNumber = 1,
348 bool _internal_has_client_name()
const;
359 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED(
"The unsafe_arena_ accessors for"
360 " string fields are deprecated and will be removed in a"
362 std::
string* unsafe_arena_release_client_name();
363 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
364 "
string fields are deprecated and will be removed in a"
366 void unsafe_arena_set_allocated_client_name(
367 std::
string* client_name);
369 const std::
string& _internal_client_name() const;
370 void _internal_set_client_name(const std::
string& value);
371 std::
string* _internal_mutable_client_name();
375 bool has_client_pid() const;
377 bool _internal_has_client_pid() const;
379 void clear_client_pid();
380 ::PROTOBUF_NAMESPACE_ID::
int32 client_pid() const;
381 void set_client_pid(::PROTOBUF_NAMESPACE_ID::
int32 value);
383 ::PROTOBUF_NAMESPACE_ID::
int32 _internal_client_pid() const;
384 void _internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::
int32 value);
388 bool has_ready() const;
390 bool _internal_has_ready() const;
394 void set_ready(
bool value);
396 bool _internal_ready() const;
397 void _internal_set_ready(
bool value);
401 bool has_request() const;
403 bool _internal_has_request() const;
405 void clear_request();
409 ::
goby::zeromq::protobuf::
Request _internal_request() const;
410 void _internal_set_request(::
goby::zeromq::protobuf::
Request value);
418 size_t RequiredFieldsByteSizeFallback() const;
420 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
421 typedef
void InternalArenaConstructable_;
422 typedef
void DestructorSkippable_;
423 ::PROTOBUF_NAMESPACE_ID::
internal::HasBits<1> _has_bits_;
424 mutable ::PROTOBUF_NAMESPACE_ID::
internal::CachedSize _cached_size_;
425 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr client_name_;
426 ::PROTOBUF_NAMESPACE_ID::
int32 client_pid_;
434 public ::PROTOBUF_NAMESPACE_ID::Message {
442 *
this = ::std::move(from);
450 if (GetArena() == from.GetArena()) {
451 if (
this != &from) InternalSwap(&from);
459 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
462 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
465 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
466 return GetDescriptor();
469 return GetMetadataStatic().descriptor;
472 return GetMetadataStatic().reflection;
478 return reinterpret_cast<const Socket*
>(
481 static constexpr
int kIndexInFileMessages =
484 friend void swap(Socket& a, Socket& b) {
487 inline void Swap(Socket* other) {
488 if (other ==
this)
return;
489 if (GetArena() == other->GetArena()) {
492 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
496 if (other ==
this)
return;
497 GOOGLE_DCHECK(GetArena() == other->GetArena());
503 inline Socket*
New() const final {
504 return CreateMaybeMessage<Socket>(
nullptr);
507 Socket*
New(::PROTOBUF_NAMESPACE_ID::Arena* arena)
const final {
508 return CreateMaybeMessage<Socket>(arena);
510 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
511 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
514 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
515 bool IsInitialized() const final;
518 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
519 ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
520 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
521 int GetCachedSize() const final {
return _cached_size_.Get(); }
524 inline void SharedCtor();
525 inline void SharedDtor();
526 void SetCachedSize(
int size)
const final;
527 void InternalSwap(Socket* other);
528 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
529 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
530 return "goby.zeromq.protobuf.Socket";
533 explicit Socket(::PROTOBUF_NAMESPACE_ID::Arena* arena);
535 static void ArenaDtor(
void*
object);
536 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
541 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
566 static constexpr
int SocketType_ARRAYSIZE =
568 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
574 static_assert(::std::is_same<T, SocketType>::value ||
575 ::std::is_integral<T>::value,
576 "Incorrect type passed to function SocketType_Name.");
598 static constexpr Transport Transport_MIN =
600 static constexpr Transport Transport_MAX =
602 static constexpr
int Transport_ARRAYSIZE =
604 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
610 static_assert(::std::is_same<T, Transport>::value ||
611 ::std::is_integral<T>::value,
612 "Incorrect type passed to function Transport_Name.");
632 static constexpr
int ConnectOrBind_ARRAYSIZE =
634 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
640 static_assert(::std::is_same<T, ConnectOrBind>::value ||
641 ::std::is_integral<T>::value,
642 "Incorrect type passed to function ConnectOrBind_Name.");
653 kEthernetAddressFieldNumber = 5,
654 kMulticastAddressFieldNumber = 6,
655 kSocketNameFieldNumber = 8,
656 kSocketIdFieldNumber = 2,
657 kSocketTypeFieldNumber = 1,
658 kTransportFieldNumber = 3,
659 kConnectOrBindFieldNumber = 4,
660 kEthernetPortFieldNumber = 7,
661 kSendQueueSizeFieldNumber = 10,
662 kReceiveQueueSizeFieldNumber = 11,
667 bool _internal_has_ethernet_address()
const;
678 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED(
"The unsafe_arena_ accessors for"
679 " string fields are deprecated and will be removed in a"
681 std::
string* unsafe_arena_release_ethernet_address();
682 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
683 "
string fields are deprecated and will be removed in a"
685 void unsafe_arena_set_allocated_ethernet_address(
686 std::
string* ethernet_address);
688 const std::
string& _internal_ethernet_address() const;
689 void _internal_set_ethernet_address(const std::
string& value);
690 std::
string* _internal_mutable_ethernet_address();
694 bool has_multicast_address() const;
696 bool _internal_has_multicast_address() const;
698 void clear_multicast_address();
699 const std::
string& multicast_address() const;
700 void set_multicast_address(const std::
string& value);
701 void set_multicast_address(std::
string&& value);
702 void set_multicast_address(const
char* value);
703 void set_multicast_address(const
char* value,
size_t size);
704 std::
string* mutable_multicast_address();
705 std::
string* release_multicast_address();
706 void set_allocated_multicast_address(std::
string* multicast_address);
707 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
708 "
string fields are deprecated and will be removed in a"
710 std::
string* unsafe_arena_release_multicast_address();
711 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
712 "
string fields are deprecated and will be removed in a"
714 void unsafe_arena_set_allocated_multicast_address(
715 std::
string* multicast_address);
717 const std::
string& _internal_multicast_address() const;
718 void _internal_set_multicast_address(const std::
string& value);
719 std::
string* _internal_mutable_multicast_address();
723 bool has_socket_name() const;
725 bool _internal_has_socket_name() const;
727 void clear_socket_name();
728 const std::
string& socket_name() const;
729 void set_socket_name(const std::
string& value);
730 void set_socket_name(std::
string&& value);
731 void set_socket_name(const
char* value);
732 void set_socket_name(const
char* value,
size_t size);
733 std::
string* mutable_socket_name();
734 std::
string* release_socket_name();
735 void set_allocated_socket_name(std::
string* socket_name);
736 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
737 "
string fields are deprecated and will be removed in a"
739 std::
string* unsafe_arena_release_socket_name();
740 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
741 "
string fields are deprecated and will be removed in a"
743 void unsafe_arena_set_allocated_socket_name(
744 std::
string* socket_name);
746 const std::
string& _internal_socket_name() const;
747 void _internal_set_socket_name(const std::
string& value);
748 std::
string* _internal_mutable_socket_name();
752 bool has_socket_id() const;
754 bool _internal_has_socket_id() const;
756 void clear_socket_id();
757 ::PROTOBUF_NAMESPACE_ID::
uint32 socket_id() const;
758 void set_socket_id(::PROTOBUF_NAMESPACE_ID::
uint32 value);
760 ::PROTOBUF_NAMESPACE_ID::
uint32 _internal_socket_id() const;
761 void _internal_set_socket_id(::PROTOBUF_NAMESPACE_ID::
uint32 value);
765 bool has_socket_type() const;
767 bool _internal_has_socket_type() const;
769 void clear_socket_type();
778 bool has_transport() const;
780 bool _internal_has_transport() const;
782 void clear_transport();
791 bool has_connect_or_bind() const;
793 bool _internal_has_connect_or_bind() const;
795 void clear_connect_or_bind();
804 bool has_ethernet_port() const;
806 bool _internal_has_ethernet_port() const;
808 void clear_ethernet_port();
809 ::PROTOBUF_NAMESPACE_ID::
uint32 ethernet_port() const;
810 void set_ethernet_port(::PROTOBUF_NAMESPACE_ID::
uint32 value);
812 ::PROTOBUF_NAMESPACE_ID::
uint32 _internal_ethernet_port() const;
813 void _internal_set_ethernet_port(::PROTOBUF_NAMESPACE_ID::
uint32 value);
817 bool has_send_queue_size() const;
819 bool _internal_has_send_queue_size() const;
821 void clear_send_queue_size();
822 ::PROTOBUF_NAMESPACE_ID::
uint32 send_queue_size() const;
823 void set_send_queue_size(::PROTOBUF_NAMESPACE_ID::
uint32 value);
825 ::PROTOBUF_NAMESPACE_ID::
uint32 _internal_send_queue_size() const;
826 void _internal_set_send_queue_size(::PROTOBUF_NAMESPACE_ID::
uint32 value);
830 bool has_receive_queue_size() const;
832 bool _internal_has_receive_queue_size() const;
834 void clear_receive_queue_size();
835 ::PROTOBUF_NAMESPACE_ID::
uint32 receive_queue_size() const;
836 void set_receive_queue_size(::PROTOBUF_NAMESPACE_ID::
uint32 value);
838 ::PROTOBUF_NAMESPACE_ID::
uint32 _internal_receive_queue_size() const;
839 void _internal_set_receive_queue_size(::PROTOBUF_NAMESPACE_ID::
uint32 value);
846 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
847 typedef
void InternalArenaConstructable_;
848 typedef
void DestructorSkippable_;
849 ::PROTOBUF_NAMESPACE_ID::
internal::HasBits<1> _has_bits_;
850 mutable ::PROTOBUF_NAMESPACE_ID::
internal::CachedSize _cached_size_;
852 static ::PROTOBUF_NAMESPACE_ID::
internal::ExplicitlyConstructed<std::
string> _i_give_permission_to_break_this_code_default_ethernet_address_;
854 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr ethernet_address_;
856 static ::PROTOBUF_NAMESPACE_ID::
internal::ExplicitlyConstructed<std::
string> _i_give_permission_to_break_this_code_default_multicast_address_;
858 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr multicast_address_;
859 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr socket_name_;
860 ::PROTOBUF_NAMESPACE_ID::
uint32 socket_id_;
863 int connect_or_bind_;
864 ::PROTOBUF_NAMESPACE_ID::
uint32 ethernet_port_;
865 ::PROTOBUF_NAMESPACE_ID::
uint32 send_queue_size_;
866 ::PROTOBUF_NAMESPACE_ID::
uint32 receive_queue_size_;
872 public ::PROTOBUF_NAMESPACE_ID::Message {
879 : ManagerResponse() {
880 *
this = ::std::move(from);
883 inline ManagerResponse&
operator=(
const ManagerResponse& from) {
887 inline ManagerResponse&
operator=(ManagerResponse&& from) noexcept {
888 if (GetArena() == from.GetArena()) {
889 if (
this != &from) InternalSwap(&from);
897 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
900 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
903 static const ::PROTOBUF_NAMESPACE_ID::Descriptor*
descriptor() {
904 return GetDescriptor();
907 return GetMetadataStatic().descriptor;
910 return GetMetadataStatic().reflection;
916 return reinterpret_cast<const ManagerResponse*
>(
919 static constexpr
int kIndexInFileMessages =
922 friend void swap(ManagerResponse& a, ManagerResponse& b) {
925 inline void Swap(ManagerResponse* other) {
926 if (other ==
this)
return;
927 if (GetArena() == other->GetArena()) {
930 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
934 if (other ==
this)
return;
935 GOOGLE_DCHECK(GetArena() == other->GetArena());
941 inline ManagerResponse*
New() const final {
942 return CreateMaybeMessage<ManagerResponse>(
nullptr);
945 ManagerResponse*
New(::PROTOBUF_NAMESPACE_ID::Arena* arena)
const final {
946 return CreateMaybeMessage<ManagerResponse>(arena);
948 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
949 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
952 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
953 bool IsInitialized() const final;
956 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
957 ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
958 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
959 int GetCachedSize() const final {
return _cached_size_.Get(); }
962 inline void SharedCtor();
963 inline void SharedDtor();
964 void SetCachedSize(
int size)
const final;
965 void InternalSwap(ManagerResponse* other);
966 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
967 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
968 return "goby.zeromq.protobuf.ManagerResponse";
973 static void ArenaDtor(
void*
object);
974 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
979 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
991 kClientNameFieldNumber = 2,
992 kPublishSocketFieldNumber = 4,
993 kSubscribeSocketFieldNumber = 5,
994 kClientPidFieldNumber = 3,
995 kRequestFieldNumber = 1,
996 kHoldFieldNumber = 6,
1001 bool _internal_has_client_name()
const;
1012 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED(
"The unsafe_arena_ accessors for"
1013 " string fields are deprecated and will be removed in a"
1015 std::
string* unsafe_arena_release_client_name();
1016 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1017 "
string fields are deprecated and will be removed in a"
1019 void unsafe_arena_set_allocated_client_name(
1020 std::
string* client_name);
1022 const std::
string& _internal_client_name() const;
1023 void _internal_set_client_name(const std::
string& value);
1024 std::
string* _internal_mutable_client_name();
1028 bool has_publish_socket() const;
1030 bool _internal_has_publish_socket() const;
1032 void clear_publish_socket();
1033 const ::
goby::zeromq::protobuf::Socket& publish_socket() const;
1034 ::
goby::zeromq::protobuf::Socket* release_publish_socket();
1035 ::
goby::zeromq::protobuf::Socket* mutable_publish_socket();
1036 void set_allocated_publish_socket(::
goby::zeromq::protobuf::Socket* publish_socket);
1038 const ::
goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1039 ::
goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1041 void unsafe_arena_set_allocated_publish_socket(
1042 ::
goby::zeromq::protobuf::Socket* publish_socket);
1043 ::
goby::zeromq::protobuf::Socket* unsafe_arena_release_publish_socket();
1046 bool has_subscribe_socket() const;
1048 bool _internal_has_subscribe_socket() const;
1050 void clear_subscribe_socket();
1051 const ::
goby::zeromq::protobuf::Socket& subscribe_socket() const;
1052 ::
goby::zeromq::protobuf::Socket* release_subscribe_socket();
1053 ::
goby::zeromq::protobuf::Socket* mutable_subscribe_socket();
1054 void set_allocated_subscribe_socket(::
goby::zeromq::protobuf::Socket* subscribe_socket);
1056 const ::
goby::zeromq::protobuf::Socket& _internal_subscribe_socket() const;
1057 ::
goby::zeromq::protobuf::Socket* _internal_mutable_subscribe_socket();
1059 void unsafe_arena_set_allocated_subscribe_socket(
1060 ::
goby::zeromq::protobuf::Socket* subscribe_socket);
1061 ::
goby::zeromq::protobuf::Socket* unsafe_arena_release_subscribe_socket();
1064 bool has_client_pid() const;
1066 bool _internal_has_client_pid() const;
1068 void clear_client_pid();
1069 ::PROTOBUF_NAMESPACE_ID::
int32 client_pid() const;
1070 void set_client_pid(::PROTOBUF_NAMESPACE_ID::
int32 value);
1072 ::PROTOBUF_NAMESPACE_ID::
int32 _internal_client_pid() const;
1073 void _internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::
int32 value);
1077 bool has_request() const;
1079 bool _internal_has_request() const;
1081 void clear_request();
1085 ::
goby::zeromq::protobuf::
Request _internal_request() const;
1086 void _internal_set_request(::
goby::zeromq::protobuf::
Request value);
1090 bool has_hold() const;
1092 bool _internal_has_hold() const;
1096 void set_hold(
bool value);
1098 bool _internal_hold() const;
1099 void _internal_set_hold(
bool value);
1107 size_t RequiredFieldsByteSizeFallback() const;
1109 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1110 typedef
void InternalArenaConstructable_;
1111 typedef
void DestructorSkippable_;
1112 ::PROTOBUF_NAMESPACE_ID::
internal::HasBits<1> _has_bits_;
1113 mutable ::PROTOBUF_NAMESPACE_ID::
internal::CachedSize _cached_size_;
1114 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr client_name_;
1115 ::
goby::zeromq::protobuf::Socket* publish_socket_;
1116 ::
goby::zeromq::protobuf::Socket* subscribe_socket_;
1117 ::PROTOBUF_NAMESPACE_ID::
int32 client_pid_;
1125 public ::PROTOBUF_NAMESPACE_ID::Message {
1133 *
this = ::std::move(from);
1136 inline InprocControl&
operator=(
const InprocControl& from) {
1140 inline InprocControl&
operator=(InprocControl&& from) noexcept {
1141 if (GetArena() == from.GetArena()) {
1142 if (
this != &from) InternalSwap(&from);
1150 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1153 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1157 return GetDescriptor();
1160 return GetMetadataStatic().descriptor;
1163 return GetMetadataStatic().reflection;
1169 return reinterpret_cast<const InprocControl*
>(
1172 static constexpr
int kIndexInFileMessages =
1175 friend void swap(InprocControl& a, InprocControl& b) {
1178 inline void Swap(InprocControl* other) {
1179 if (other ==
this)
return;
1180 if (GetArena() == other->GetArena()) {
1181 InternalSwap(other);
1183 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(
this, other);
1187 if (other ==
this)
return;
1188 GOOGLE_DCHECK(GetArena() == other->GetArena());
1189 InternalSwap(other);
1194 inline InprocControl*
New() const final {
1195 return CreateMaybeMessage<InprocControl>(
nullptr);
1198 InprocControl*
New(::PROTOBUF_NAMESPACE_ID::Arena* arena)
const final {
1199 return CreateMaybeMessage<InprocControl>(arena);
1201 void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
1202 void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from)
final;
1205 PROTOBUF_ATTRIBUTE_REINITIALIZES
void Clear() final;
1206 bool IsInitialized() const final;
1209 const
char* _InternalParse(const
char* ptr, ::PROTOBUF_NAMESPACE_ID::
internal::ParseContext* ctx) final;
1210 ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize(
1211 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1212 int GetCachedSize() const final {
return _cached_size_.Get(); }
1215 inline void SharedCtor();
1216 inline void SharedDtor();
1217 void SetCachedSize(
int size)
const final;
1218 void InternalSwap(InprocControl* other);
1219 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1220 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1221 return "goby.zeromq.protobuf.InprocControl";
1226 static void ArenaDtor(
void*
object);
1227 inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
1232 static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
1267 static constexpr
int InprocControlType_ARRAYSIZE =
1269 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
1273 template<
typename T>
1275 static_assert(::std::is_same<T, InprocControlType>::value ||
1276 ::std::is_integral<T>::value,
1277 "Incorrect type passed to function InprocControlType_Name.");
1288 kSubscriptionIdentifierFieldNumber = 3,
1289 kReceivedDataFieldNumber = 4,
1290 kPublishSocketFieldNumber = 2,
1291 kHoldFieldNumber = 10,
1292 kTypeFieldNumber = 1,
1297 bool _internal_has_subscription_identifier()
const;
1308 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED(
"The unsafe_arena_ accessors for"
1309 " string fields are deprecated and will be removed in a"
1311 std::
string* unsafe_arena_release_subscription_identifier();
1312 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1313 "
string fields are deprecated and will be removed in a"
1315 void unsafe_arena_set_allocated_subscription_identifier(
1316 std::
string* subscription_identifier);
1318 const std::
string& _internal_subscription_identifier() const;
1319 void _internal_set_subscription_identifier(const std::
string& value);
1320 std::
string* _internal_mutable_subscription_identifier();
1324 bool has_received_data() const;
1326 bool _internal_has_received_data() const;
1328 void clear_received_data();
1329 const std::
string& received_data() const;
1330 void set_received_data(const std::
string& value);
1331 void set_received_data(std::
string&& value);
1332 void set_received_data(const
char* value);
1333 void set_received_data(const
void* value,
size_t size);
1334 std::
string* mutable_received_data();
1335 std::
string* release_received_data();
1336 void set_allocated_received_data(std::
string* received_data);
1337 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1338 "
string fields are deprecated and will be removed in a"
1340 std::
string* unsafe_arena_release_received_data();
1341 GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1342 "
string fields are deprecated and will be removed in a"
1344 void unsafe_arena_set_allocated_received_data(
1345 std::
string* received_data);
1347 const std::
string& _internal_received_data() const;
1348 void _internal_set_received_data(const std::
string& value);
1349 std::
string* _internal_mutable_received_data();
1353 bool has_publish_socket() const;
1355 bool _internal_has_publish_socket() const;
1357 void clear_publish_socket();
1358 const ::
goby::zeromq::protobuf::Socket& publish_socket() const;
1359 ::
goby::zeromq::protobuf::Socket* release_publish_socket();
1360 ::
goby::zeromq::protobuf::Socket* mutable_publish_socket();
1361 void set_allocated_publish_socket(::
goby::zeromq::protobuf::Socket* publish_socket);
1363 const ::
goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1364 ::
goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1366 void unsafe_arena_set_allocated_publish_socket(
1367 ::
goby::zeromq::protobuf::Socket* publish_socket);
1368 ::
goby::zeromq::protobuf::Socket* unsafe_arena_release_publish_socket();
1371 bool has_hold() const;
1373 bool _internal_has_hold() const;
1377 void set_hold(
bool value);
1379 bool _internal_hold() const;
1380 void _internal_set_hold(
bool value);
1384 bool has_type() const;
1386 bool _internal_has_type() const;
1400 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1401 typedef
void InternalArenaConstructable_;
1402 typedef
void DestructorSkippable_;
1403 ::PROTOBUF_NAMESPACE_ID::
internal::HasBits<1> _has_bits_;
1404 mutable ::PROTOBUF_NAMESPACE_ID::
internal::CachedSize _cached_size_;
1405 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr subscription_identifier_;
1406 ::PROTOBUF_NAMESPACE_ID::
internal::ArenaStringPtr received_data_;
1407 ::
goby::zeromq::protobuf::Socket* publish_socket_;
1418 #pragma GCC diagnostic push
1419 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
1424 inline bool ManagerRequest::_internal_has_request()
const {
1425 bool value = (_has_bits_[0] & 0x00000008u) != 0;
1428 inline bool ManagerRequest::has_request()
const {
1429 return _internal_has_request();
1431 inline void ManagerRequest::clear_request() {
1433 _has_bits_[0] &= ~0x00000008u;
1440 return _internal_request();
1444 _has_bits_[0] |= 0x00000008u;
1448 _internal_set_request(value);
1453 inline bool ManagerRequest::_internal_has_client_name()
const {
1454 bool value = (_has_bits_[0] & 0x00000001u) != 0;
1457 inline bool ManagerRequest::has_client_name()
const {
1458 return _internal_has_client_name();
1460 inline void ManagerRequest::clear_client_name() {
1462 _has_bits_[0] &= ~0x00000001u;
1464 inline const std::string& ManagerRequest::client_name()
const {
1466 return _internal_client_name();
1468 inline void ManagerRequest::set_client_name(
const std::string& value) {
1469 _internal_set_client_name(value);
1472 inline std::string* ManagerRequest::mutable_client_name() {
1474 return _internal_mutable_client_name();
1476 inline const std::string& ManagerRequest::_internal_client_name()
const {
1477 return client_name_.Get();
1479 inline void ManagerRequest::_internal_set_client_name(
const std::string& value) {
1480 _has_bits_[0] |= 0x00000001u;
1483 inline void ManagerRequest::set_client_name(std::string&& value) {
1484 _has_bits_[0] |= 0x00000001u;
1489 inline void ManagerRequest::set_client_name(
const char* value) {
1490 GOOGLE_DCHECK(value !=
nullptr);
1491 _has_bits_[0] |= 0x00000001u;
1496 inline void ManagerRequest::set_client_name(
const char* value,
1498 _has_bits_[0] |= 0x00000001u;
1500 reinterpret_cast<const char*
>(value), size), GetArena());
1503 inline std::string* ManagerRequest::_internal_mutable_client_name() {
1504 _has_bits_[0] |= 0x00000001u;
1507 inline std::string* ManagerRequest::release_client_name() {
1509 if (!_internal_has_client_name()) {
1512 _has_bits_[0] &= ~0x00000001u;
1515 inline void ManagerRequest::set_allocated_client_name(std::string* client_name) {
1516 if (client_name !=
nullptr) {
1517 _has_bits_[0] |= 0x00000001u;
1519 _has_bits_[0] &= ~0x00000001u;
1525 inline std::string* ManagerRequest::unsafe_arena_release_client_name() {
1527 GOOGLE_DCHECK(GetArena() !=
nullptr);
1528 _has_bits_[0] &= ~0x00000001u;
1532 inline void ManagerRequest::unsafe_arena_set_allocated_client_name(
1533 std::string* client_name) {
1534 GOOGLE_DCHECK(GetArena() !=
nullptr);
1535 if (client_name !=
nullptr) {
1536 _has_bits_[0] |= 0x00000001u;
1538 _has_bits_[0] &= ~0x00000001u;
1541 client_name, GetArena());
1546 inline bool ManagerRequest::_internal_has_client_pid()
const {
1547 bool value = (_has_bits_[0] & 0x00000002u) != 0;
1550 inline bool ManagerRequest::has_client_pid()
const {
1551 return _internal_has_client_pid();
1553 inline void ManagerRequest::clear_client_pid() {
1555 _has_bits_[0] &= ~0x00000002u;
1562 return _internal_client_pid();
1565 _has_bits_[0] |= 0x00000002u;
1566 client_pid_ =
value;
1569 _internal_set_client_pid(value);
1574 inline bool ManagerRequest::_internal_has_ready()
const {
1575 bool value = (_has_bits_[0] & 0x00000004u) != 0;
1578 inline bool ManagerRequest::has_ready()
const {
1579 return _internal_has_ready();
1581 inline void ManagerRequest::clear_ready() {
1583 _has_bits_[0] &= ~0x00000004u;
1585 inline bool ManagerRequest::_internal_ready()
const {
1588 inline bool ManagerRequest::ready()
const {
1590 return _internal_ready();
1592 inline void ManagerRequest::_internal_set_ready(
bool value) {
1593 _has_bits_[0] |= 0x00000004u;
1596 inline void ManagerRequest::set_ready(
bool value) {
1597 _internal_set_ready(value);
1606 inline bool Socket::_internal_has_socket_type()
const {
1607 bool value = (_has_bits_[0] & 0x00000010u) != 0;
1610 inline bool Socket::has_socket_type()
const {
1611 return _internal_has_socket_type();
1613 inline void Socket::clear_socket_type() {
1615 _has_bits_[0] &= ~0x00000010u;
1622 return _internal_socket_type();
1626 _has_bits_[0] |= 0x00000010u;
1627 socket_type_ =
value;
1630 _internal_set_socket_type(value);
1635 inline bool Socket::_internal_has_socket_id()
const {
1636 bool value = (_has_bits_[0] & 0x00000008u) != 0;
1639 inline bool Socket::has_socket_id()
const {
1640 return _internal_has_socket_id();
1642 inline void Socket::clear_socket_id() {
1644 _has_bits_[0] &= ~0x00000008u;
1651 return _internal_socket_id();
1654 _has_bits_[0] |= 0x00000008u;
1658 _internal_set_socket_id(value);
1663 inline bool Socket::_internal_has_transport()
const {
1664 bool value = (_has_bits_[0] & 0x00000020u) != 0;
1667 inline bool Socket::has_transport()
const {
1668 return _internal_has_transport();
1670 inline void Socket::clear_transport() {
1672 _has_bits_[0] &= ~0x00000020u;
1679 return _internal_transport();
1683 _has_bits_[0] |= 0x00000020u;
1687 _internal_set_transport(value);
1692 inline bool Socket::_internal_has_connect_or_bind()
const {
1693 bool value = (_has_bits_[0] & 0x00000040u) != 0;
1696 inline bool Socket::has_connect_or_bind()
const {
1697 return _internal_has_connect_or_bind();
1699 inline void Socket::clear_connect_or_bind() {
1700 connect_or_bind_ = 1;
1701 _has_bits_[0] &= ~0x00000040u;
1708 return _internal_connect_or_bind();
1712 _has_bits_[0] |= 0x00000040u;
1713 connect_or_bind_ =
value;
1716 _internal_set_connect_or_bind(value);
1721 inline bool Socket::_internal_has_ethernet_address()
const {
1722 bool value = (_has_bits_[0] & 0x00000001u) != 0;
1725 inline bool Socket::has_ethernet_address()
const {
1726 return _internal_has_ethernet_address();
1728 inline void Socket::clear_ethernet_address() {
1729 ethernet_address_.ClearToDefault(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), GetArena());
1730 _has_bits_[0] &= ~0x00000001u;
1732 inline const std::string& Socket::ethernet_address()
const {
1734 return _internal_ethernet_address();
1736 inline void Socket::set_ethernet_address(
const std::string& value) {
1737 _internal_set_ethernet_address(value);
1740 inline std::string* Socket::mutable_ethernet_address() {
1742 return _internal_mutable_ethernet_address();
1744 inline const std::string& Socket::_internal_ethernet_address()
const {
1745 return ethernet_address_.Get();
1747 inline void Socket::_internal_set_ethernet_address(
const std::string& value) {
1748 _has_bits_[0] |= 0x00000001u;
1749 ethernet_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), value, GetArena());
1751 inline void Socket::set_ethernet_address(std::string&& value) {
1752 _has_bits_[0] |= 0x00000001u;
1753 ethernet_address_.Set(
1754 &::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), ::std::move(value), GetArena());
1757 inline void Socket::set_ethernet_address(
const char* value) {
1758 GOOGLE_DCHECK(value !=
nullptr);
1759 _has_bits_[0] |= 0x00000001u;
1760 ethernet_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), ::std::string(value),
1764 inline void Socket::set_ethernet_address(
const char* value,
1766 _has_bits_[0] |= 0x00000001u;
1767 ethernet_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), ::std::string(
1768 reinterpret_cast<const char*
>(value), size), GetArena());
1771 inline std::string* Socket::_internal_mutable_ethernet_address() {
1772 _has_bits_[0] |= 0x00000001u;
1773 return ethernet_address_.Mutable(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), GetArena());
1775 inline std::string* Socket::release_ethernet_address() {
1777 if (!_internal_has_ethernet_address()) {
1780 _has_bits_[0] &= ~0x00000001u;
1781 return ethernet_address_.ReleaseNonDefault(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), GetArena());
1783 inline void Socket::set_allocated_ethernet_address(std::string* ethernet_address) {
1784 if (ethernet_address !=
nullptr) {
1785 _has_bits_[0] |= 0x00000001u;
1787 _has_bits_[0] &= ~0x00000001u;
1789 ethernet_address_.SetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(), ethernet_address,
1793 inline std::string* Socket::unsafe_arena_release_ethernet_address() {
1795 GOOGLE_DCHECK(GetArena() !=
nullptr);
1796 _has_bits_[0] &= ~0x00000001u;
1797 return ethernet_address_.UnsafeArenaRelease(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(),
1800 inline void Socket::unsafe_arena_set_allocated_ethernet_address(
1801 std::string* ethernet_address) {
1802 GOOGLE_DCHECK(GetArena() !=
nullptr);
1803 if (ethernet_address !=
nullptr) {
1804 _has_bits_[0] |= 0x00000001u;
1806 _has_bits_[0] &= ~0x00000001u;
1808 ethernet_address_.UnsafeArenaSetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.
get(),
1809 ethernet_address, GetArena());
1814 inline bool Socket::_internal_has_multicast_address()
const {
1815 bool value = (_has_bits_[0] & 0x00000002u) != 0;
1818 inline bool Socket::has_multicast_address()
const {
1819 return _internal_has_multicast_address();
1821 inline void Socket::clear_multicast_address() {
1822 multicast_address_.ClearToDefault(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), GetArena());
1823 _has_bits_[0] &= ~0x00000002u;
1825 inline const std::string& Socket::multicast_address()
const {
1827 return _internal_multicast_address();
1829 inline void Socket::set_multicast_address(
const std::string& value) {
1830 _internal_set_multicast_address(value);
1833 inline std::string* Socket::mutable_multicast_address() {
1835 return _internal_mutable_multicast_address();
1837 inline const std::string& Socket::_internal_multicast_address()
const {
1838 return multicast_address_.Get();
1840 inline void Socket::_internal_set_multicast_address(
const std::string& value) {
1841 _has_bits_[0] |= 0x00000002u;
1842 multicast_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), value, GetArena());
1844 inline void Socket::set_multicast_address(std::string&& value) {
1845 _has_bits_[0] |= 0x00000002u;
1846 multicast_address_.Set(
1847 &::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), ::std::move(value), GetArena());
1850 inline void Socket::set_multicast_address(
const char* value) {
1851 GOOGLE_DCHECK(value !=
nullptr);
1852 _has_bits_[0] |= 0x00000002u;
1853 multicast_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), ::std::string(value),
1857 inline void Socket::set_multicast_address(
const char* value,
1859 _has_bits_[0] |= 0x00000002u;
1860 multicast_address_.Set(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), ::std::string(
1861 reinterpret_cast<const char*
>(value), size), GetArena());
1864 inline std::string* Socket::_internal_mutable_multicast_address() {
1865 _has_bits_[0] |= 0x00000002u;
1866 return multicast_address_.Mutable(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), GetArena());
1868 inline std::string* Socket::release_multicast_address() {
1870 if (!_internal_has_multicast_address()) {
1873 _has_bits_[0] &= ~0x00000002u;
1874 return multicast_address_.ReleaseNonDefault(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), GetArena());
1876 inline void Socket::set_allocated_multicast_address(std::string* multicast_address) {
1877 if (multicast_address !=
nullptr) {
1878 _has_bits_[0] |= 0x00000002u;
1880 _has_bits_[0] &= ~0x00000002u;
1882 multicast_address_.SetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(), multicast_address,
1886 inline std::string* Socket::unsafe_arena_release_multicast_address() {
1888 GOOGLE_DCHECK(GetArena() !=
nullptr);
1889 _has_bits_[0] &= ~0x00000002u;
1890 return multicast_address_.UnsafeArenaRelease(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(),
1893 inline void Socket::unsafe_arena_set_allocated_multicast_address(
1894 std::string* multicast_address) {
1895 GOOGLE_DCHECK(GetArena() !=
nullptr);
1896 if (multicast_address !=
nullptr) {
1897 _has_bits_[0] |= 0x00000002u;
1899 _has_bits_[0] &= ~0x00000002u;
1901 multicast_address_.UnsafeArenaSetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.
get(),
1902 multicast_address, GetArena());
1907 inline bool Socket::_internal_has_ethernet_port()
const {
1908 bool value = (_has_bits_[0] & 0x00000080u) != 0;
1911 inline bool Socket::has_ethernet_port()
const {
1912 return _internal_has_ethernet_port();
1914 inline void Socket::clear_ethernet_port() {
1915 ethernet_port_ = 11142u;
1916 _has_bits_[0] &= ~0x00000080u;
1919 return ethernet_port_;
1923 return _internal_ethernet_port();
1926 _has_bits_[0] |= 0x00000080u;
1927 ethernet_port_ =
value;
1930 _internal_set_ethernet_port(value);
1935 inline bool Socket::_internal_has_socket_name()
const {
1936 bool value = (_has_bits_[0] & 0x00000004u) != 0;
1939 inline bool Socket::has_socket_name()
const {
1940 return _internal_has_socket_name();
1942 inline void Socket::clear_socket_name() {
1944 _has_bits_[0] &= ~0x00000004u;
1946 inline const std::string& Socket::socket_name()
const {
1948 return _internal_socket_name();
1950 inline void Socket::set_socket_name(
const std::string& value) {
1951 _internal_set_socket_name(value);
1954 inline std::string* Socket::mutable_socket_name() {
1956 return _internal_mutable_socket_name();
1958 inline const std::string& Socket::_internal_socket_name()
const {
1959 return socket_name_.Get();
1961 inline void Socket::_internal_set_socket_name(
const std::string& value) {
1962 _has_bits_[0] |= 0x00000004u;
1965 inline void Socket::set_socket_name(std::string&& value) {
1966 _has_bits_[0] |= 0x00000004u;
1971 inline void Socket::set_socket_name(
const char* value) {
1972 GOOGLE_DCHECK(value !=
nullptr);
1973 _has_bits_[0] |= 0x00000004u;
1978 inline void Socket::set_socket_name(
const char* value,
1980 _has_bits_[0] |= 0x00000004u;
1982 reinterpret_cast<const char*
>(value), size), GetArena());
1985 inline std::string* Socket::_internal_mutable_socket_name() {
1986 _has_bits_[0] |= 0x00000004u;
1989 inline std::string* Socket::release_socket_name() {
1991 if (!_internal_has_socket_name()) {
1994 _has_bits_[0] &= ~0x00000004u;
1997 inline void Socket::set_allocated_socket_name(std::string* socket_name) {
1998 if (socket_name !=
nullptr) {
1999 _has_bits_[0] |= 0x00000004u;
2001 _has_bits_[0] &= ~0x00000004u;
2007 inline std::string* Socket::unsafe_arena_release_socket_name() {
2009 GOOGLE_DCHECK(GetArena() !=
nullptr);
2010 _has_bits_[0] &= ~0x00000004u;
2014 inline void Socket::unsafe_arena_set_allocated_socket_name(
2015 std::string* socket_name) {
2016 GOOGLE_DCHECK(GetArena() !=
nullptr);
2017 if (socket_name !=
nullptr) {
2018 _has_bits_[0] |= 0x00000004u;
2020 _has_bits_[0] &= ~0x00000004u;
2023 socket_name, GetArena());
2028 inline bool Socket::_internal_has_send_queue_size()
const {
2029 bool value = (_has_bits_[0] & 0x00000100u) != 0;
2032 inline bool Socket::has_send_queue_size()
const {
2033 return _internal_has_send_queue_size();
2035 inline void Socket::clear_send_queue_size() {
2036 send_queue_size_ = 1000u;
2037 _has_bits_[0] &= ~0x00000100u;
2040 return send_queue_size_;
2044 return _internal_send_queue_size();
2047 _has_bits_[0] |= 0x00000100u;
2048 send_queue_size_ =
value;
2051 _internal_set_send_queue_size(value);
2056 inline bool Socket::_internal_has_receive_queue_size()
const {
2057 bool value = (_has_bits_[0] & 0x00000200u) != 0;
2060 inline bool Socket::has_receive_queue_size()
const {
2061 return _internal_has_receive_queue_size();
2063 inline void Socket::clear_receive_queue_size() {
2064 receive_queue_size_ = 1000u;
2065 _has_bits_[0] &= ~0x00000200u;
2068 return receive_queue_size_;
2072 return _internal_receive_queue_size();
2075 _has_bits_[0] |= 0x00000200u;
2076 receive_queue_size_ =
value;
2079 _internal_set_receive_queue_size(value);
2088 inline bool ManagerResponse::_internal_has_request()
const {
2089 bool value = (_has_bits_[0] & 0x00000010u) != 0;
2092 inline bool ManagerResponse::has_request()
const {
2093 return _internal_has_request();
2095 inline void ManagerResponse::clear_request() {
2097 _has_bits_[0] &= ~0x00000010u;
2104 return _internal_request();
2108 _has_bits_[0] |= 0x00000010u;
2112 _internal_set_request(value);
2117 inline bool ManagerResponse::_internal_has_client_name()
const {
2118 bool value = (_has_bits_[0] & 0x00000001u) != 0;
2121 inline bool ManagerResponse::has_client_name()
const {
2122 return _internal_has_client_name();
2124 inline void ManagerResponse::clear_client_name() {
2126 _has_bits_[0] &= ~0x00000001u;
2128 inline const std::string& ManagerResponse::client_name()
const {
2130 return _internal_client_name();
2132 inline void ManagerResponse::set_client_name(
const std::string& value) {
2133 _internal_set_client_name(value);
2136 inline std::string* ManagerResponse::mutable_client_name() {
2138 return _internal_mutable_client_name();
2140 inline const std::string& ManagerResponse::_internal_client_name()
const {
2141 return client_name_.Get();
2143 inline void ManagerResponse::_internal_set_client_name(
const std::string& value) {
2144 _has_bits_[0] |= 0x00000001u;
2147 inline void ManagerResponse::set_client_name(std::string&& value) {
2148 _has_bits_[0] |= 0x00000001u;
2153 inline void ManagerResponse::set_client_name(
const char* value) {
2154 GOOGLE_DCHECK(value !=
nullptr);
2155 _has_bits_[0] |= 0x00000001u;
2160 inline void ManagerResponse::set_client_name(
const char* value,
2162 _has_bits_[0] |= 0x00000001u;
2164 reinterpret_cast<const char*
>(value), size), GetArena());
2167 inline std::string* ManagerResponse::_internal_mutable_client_name() {
2168 _has_bits_[0] |= 0x00000001u;
2171 inline std::string* ManagerResponse::release_client_name() {
2173 if (!_internal_has_client_name()) {
2176 _has_bits_[0] &= ~0x00000001u;
2179 inline void ManagerResponse::set_allocated_client_name(std::string* client_name) {
2180 if (client_name !=
nullptr) {
2181 _has_bits_[0] |= 0x00000001u;
2183 _has_bits_[0] &= ~0x00000001u;
2189 inline std::string* ManagerResponse::unsafe_arena_release_client_name() {
2191 GOOGLE_DCHECK(GetArena() !=
nullptr);
2192 _has_bits_[0] &= ~0x00000001u;
2196 inline void ManagerResponse::unsafe_arena_set_allocated_client_name(
2197 std::string* client_name) {
2198 GOOGLE_DCHECK(GetArena() !=
nullptr);
2199 if (client_name !=
nullptr) {
2200 _has_bits_[0] |= 0x00000001u;
2202 _has_bits_[0] &= ~0x00000001u;
2205 client_name, GetArena());
2210 inline bool ManagerResponse::_internal_has_client_pid()
const {
2211 bool value = (_has_bits_[0] & 0x00000008u) != 0;
2214 inline bool ManagerResponse::has_client_pid()
const {
2215 return _internal_has_client_pid();
2217 inline void ManagerResponse::clear_client_pid() {
2219 _has_bits_[0] &= ~0x00000008u;
2226 return _internal_client_pid();
2229 _has_bits_[0] |= 0x00000008u;
2230 client_pid_ =
value;
2233 _internal_set_client_pid(value);
2238 inline bool ManagerResponse::_internal_has_publish_socket()
const {
2239 bool value = (_has_bits_[0] & 0x00000002u) != 0;
2240 PROTOBUF_ASSUME(!value || publish_socket_ !=
nullptr);
2243 inline bool ManagerResponse::has_publish_socket()
const {
2244 return _internal_has_publish_socket();
2246 inline void ManagerResponse::clear_publish_socket() {
2247 if (publish_socket_ !=
nullptr) publish_socket_->Clear();
2248 _has_bits_[0] &= ~0x00000002u;
2250 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_publish_socket()
const {
2251 const ::goby::zeromq::protobuf::Socket* p = publish_socket_;
2252 return p !=
nullptr ? *p : *
reinterpret_cast<const ::goby::zeromq::protobuf::Socket*
>(
2255 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::publish_socket()
const {
2257 return _internal_publish_socket();
2259 inline void ManagerResponse::unsafe_arena_set_allocated_publish_socket(
2260 ::goby::zeromq::protobuf::Socket* publish_socket) {
2261 if (GetArena() ==
nullptr) {
2262 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(publish_socket_);
2264 publish_socket_ = publish_socket;
2265 if (publish_socket) {
2266 _has_bits_[0] |= 0x00000002u;
2268 _has_bits_[0] &= ~0x00000002u;
2272 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_publish_socket() {
2273 auto temp = unsafe_arena_release_publish_socket();
2274 if (GetArena() !=
nullptr) {
2275 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2279 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_publish_socket() {
2281 _has_bits_[0] &= ~0x00000002u;
2282 ::goby::zeromq::protobuf::Socket* temp = publish_socket_;
2283 publish_socket_ =
nullptr;
2286 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_publish_socket() {
2287 _has_bits_[0] |= 0x00000002u;
2288 if (publish_socket_ ==
nullptr) {
2289 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArena());
2290 publish_socket_ = p;
2292 return publish_socket_;
2294 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_publish_socket() {
2296 return _internal_mutable_publish_socket();
2298 inline void ManagerResponse::set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket) {
2299 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena();
2300 if (message_arena ==
nullptr) {
2301 delete publish_socket_;
2303 if (publish_socket) {
2304 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2305 ::PROTOBUF_NAMESPACE_ID::Arena::GetArena(publish_socket);
2306 if (message_arena != submessage_arena) {
2307 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2308 message_arena, publish_socket, submessage_arena);
2310 _has_bits_[0] |= 0x00000002u;
2312 _has_bits_[0] &= ~0x00000002u;
2314 publish_socket_ = publish_socket;
2319 inline bool ManagerResponse::_internal_has_subscribe_socket()
const {
2320 bool value = (_has_bits_[0] & 0x00000004u) != 0;
2321 PROTOBUF_ASSUME(!value || subscribe_socket_ !=
nullptr);
2324 inline bool ManagerResponse::has_subscribe_socket()
const {
2325 return _internal_has_subscribe_socket();
2327 inline void ManagerResponse::clear_subscribe_socket() {
2328 if (subscribe_socket_ !=
nullptr) subscribe_socket_->Clear();
2329 _has_bits_[0] &= ~0x00000004u;
2331 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_subscribe_socket()
const {
2332 const ::goby::zeromq::protobuf::Socket* p = subscribe_socket_;
2333 return p !=
nullptr ? *p : *
reinterpret_cast<const ::goby::zeromq::protobuf::Socket*
>(
2336 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::subscribe_socket()
const {
2338 return _internal_subscribe_socket();
2340 inline void ManagerResponse::unsafe_arena_set_allocated_subscribe_socket(
2341 ::goby::zeromq::protobuf::Socket* subscribe_socket) {
2342 if (GetArena() ==
nullptr) {
2343 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(subscribe_socket_);
2345 subscribe_socket_ = subscribe_socket;
2346 if (subscribe_socket) {
2347 _has_bits_[0] |= 0x00000004u;
2349 _has_bits_[0] &= ~0x00000004u;
2353 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_subscribe_socket() {
2354 auto temp = unsafe_arena_release_subscribe_socket();
2355 if (GetArena() !=
nullptr) {
2356 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2360 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_subscribe_socket() {
2362 _has_bits_[0] &= ~0x00000004u;
2363 ::goby::zeromq::protobuf::Socket* temp = subscribe_socket_;
2364 subscribe_socket_ =
nullptr;
2367 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_subscribe_socket() {
2368 _has_bits_[0] |= 0x00000004u;
2369 if (subscribe_socket_ ==
nullptr) {
2370 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArena());
2371 subscribe_socket_ = p;
2373 return subscribe_socket_;
2375 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_subscribe_socket() {
2377 return _internal_mutable_subscribe_socket();
2379 inline void ManagerResponse::set_allocated_subscribe_socket(::goby::zeromq::protobuf::Socket* subscribe_socket) {
2380 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena();
2381 if (message_arena ==
nullptr) {
2382 delete subscribe_socket_;
2384 if (subscribe_socket) {
2385 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2386 ::PROTOBUF_NAMESPACE_ID::Arena::GetArena(subscribe_socket);
2387 if (message_arena != submessage_arena) {
2388 subscribe_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2389 message_arena, subscribe_socket, submessage_arena);
2391 _has_bits_[0] |= 0x00000004u;
2393 _has_bits_[0] &= ~0x00000004u;
2395 subscribe_socket_ = subscribe_socket;
2400 inline bool ManagerResponse::_internal_has_hold()
const {
2401 bool value = (_has_bits_[0] & 0x00000020u) != 0;
2404 inline bool ManagerResponse::has_hold()
const {
2405 return _internal_has_hold();
2407 inline void ManagerResponse::clear_hold() {
2409 _has_bits_[0] &= ~0x00000020u;
2411 inline bool ManagerResponse::_internal_hold()
const {
2414 inline bool ManagerResponse::hold()
const {
2416 return _internal_hold();
2418 inline void ManagerResponse::_internal_set_hold(
bool value) {
2419 _has_bits_[0] |= 0x00000020u;
2422 inline void ManagerResponse::set_hold(
bool value) {
2423 _internal_set_hold(value);
2432 inline bool InprocControl::_internal_has_type()
const {
2433 bool value = (_has_bits_[0] & 0x00000010u) != 0;
2436 inline bool InprocControl::has_type()
const {
2437 return _internal_has_type();
2439 inline void InprocControl::clear_type() {
2441 _has_bits_[0] &= ~0x00000010u;
2448 return _internal_type();
2452 _has_bits_[0] |= 0x00000010u;
2456 _internal_set_type(value);
2461 inline bool InprocControl::_internal_has_publish_socket()
const {
2462 bool value = (_has_bits_[0] & 0x00000004u) != 0;
2463 PROTOBUF_ASSUME(!value || publish_socket_ !=
nullptr);
2466 inline bool InprocControl::has_publish_socket()
const {
2467 return _internal_has_publish_socket();
2469 inline void InprocControl::clear_publish_socket() {
2470 if (publish_socket_ !=
nullptr) publish_socket_->Clear();
2471 _has_bits_[0] &= ~0x00000004u;
2473 inline const ::goby::zeromq::protobuf::Socket& InprocControl::_internal_publish_socket()
const {
2474 const ::goby::zeromq::protobuf::Socket* p = publish_socket_;
2475 return p !=
nullptr ? *p : *
reinterpret_cast<const ::goby::zeromq::protobuf::Socket*
>(
2478 inline const ::goby::zeromq::protobuf::Socket& InprocControl::publish_socket()
const {
2480 return _internal_publish_socket();
2482 inline void InprocControl::unsafe_arena_set_allocated_publish_socket(
2483 ::goby::zeromq::protobuf::Socket* publish_socket) {
2484 if (GetArena() ==
nullptr) {
2485 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*
>(publish_socket_);
2487 publish_socket_ = publish_socket;
2488 if (publish_socket) {
2489 _has_bits_[0] |= 0x00000004u;
2491 _has_bits_[0] &= ~0x00000004u;
2495 inline ::goby::zeromq::protobuf::Socket* InprocControl::release_publish_socket() {
2496 auto temp = unsafe_arena_release_publish_socket();
2497 if (GetArena() !=
nullptr) {
2498 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2502 inline ::goby::zeromq::protobuf::Socket* InprocControl::unsafe_arena_release_publish_socket() {
2504 _has_bits_[0] &= ~0x00000004u;
2505 ::goby::zeromq::protobuf::Socket* temp = publish_socket_;
2506 publish_socket_ =
nullptr;
2509 inline ::goby::zeromq::protobuf::Socket* InprocControl::_internal_mutable_publish_socket() {
2510 _has_bits_[0] |= 0x00000004u;
2511 if (publish_socket_ ==
nullptr) {
2512 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArena());
2513 publish_socket_ = p;
2515 return publish_socket_;
2517 inline ::goby::zeromq::protobuf::Socket* InprocControl::mutable_publish_socket() {
2519 return _internal_mutable_publish_socket();
2521 inline void InprocControl::set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket) {
2522 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena();
2523 if (message_arena ==
nullptr) {
2524 delete publish_socket_;
2526 if (publish_socket) {
2527 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2528 ::PROTOBUF_NAMESPACE_ID::Arena::GetArena(publish_socket);
2529 if (message_arena != submessage_arena) {
2530 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2531 message_arena, publish_socket, submessage_arena);
2533 _has_bits_[0] |= 0x00000004u;
2535 _has_bits_[0] &= ~0x00000004u;
2537 publish_socket_ = publish_socket;
2542 inline bool InprocControl::_internal_has_subscription_identifier()
const {
2543 bool value = (_has_bits_[0] & 0x00000001u) != 0;
2546 inline bool InprocControl::has_subscription_identifier()
const {
2547 return _internal_has_subscription_identifier();
2549 inline void InprocControl::clear_subscription_identifier() {
2551 _has_bits_[0] &= ~0x00000001u;
2553 inline const std::string& InprocControl::subscription_identifier()
const {
2555 return _internal_subscription_identifier();
2557 inline void InprocControl::set_subscription_identifier(
const std::string& value) {
2558 _internal_set_subscription_identifier(value);
2561 inline std::string* InprocControl::mutable_subscription_identifier() {
2563 return _internal_mutable_subscription_identifier();
2565 inline const std::string& InprocControl::_internal_subscription_identifier()
const {
2566 return subscription_identifier_.Get();
2568 inline void InprocControl::_internal_set_subscription_identifier(
const std::string& value) {
2569 _has_bits_[0] |= 0x00000001u;
2572 inline void InprocControl::set_subscription_identifier(std::string&& value) {
2573 _has_bits_[0] |= 0x00000001u;
2574 subscription_identifier_.Set(
2578 inline void InprocControl::set_subscription_identifier(
const char* value) {
2579 GOOGLE_DCHECK(value !=
nullptr);
2580 _has_bits_[0] |= 0x00000001u;
2585 inline void InprocControl::set_subscription_identifier(
const void* value,
2587 _has_bits_[0] |= 0x00000001u;
2589 reinterpret_cast<const char*
>(value), size), GetArena());
2592 inline std::string* InprocControl::_internal_mutable_subscription_identifier() {
2593 _has_bits_[0] |= 0x00000001u;
2596 inline std::string* InprocControl::release_subscription_identifier() {
2598 if (!_internal_has_subscription_identifier()) {
2601 _has_bits_[0] &= ~0x00000001u;
2604 inline void InprocControl::set_allocated_subscription_identifier(std::string* subscription_identifier) {
2605 if (subscription_identifier !=
nullptr) {
2606 _has_bits_[0] |= 0x00000001u;
2608 _has_bits_[0] &= ~0x00000001u;
2614 inline std::string* InprocControl::unsafe_arena_release_subscription_identifier() {
2616 GOOGLE_DCHECK(GetArena() !=
nullptr);
2617 _has_bits_[0] &= ~0x00000001u;
2621 inline void InprocControl::unsafe_arena_set_allocated_subscription_identifier(
2622 std::string* subscription_identifier) {
2623 GOOGLE_DCHECK(GetArena() !=
nullptr);
2624 if (subscription_identifier !=
nullptr) {
2625 _has_bits_[0] |= 0x00000001u;
2627 _has_bits_[0] &= ~0x00000001u;
2630 subscription_identifier, GetArena());
2635 inline bool InprocControl::_internal_has_received_data()
const {
2636 bool value = (_has_bits_[0] & 0x00000002u) != 0;
2639 inline bool InprocControl::has_received_data()
const {
2640 return _internal_has_received_data();
2642 inline void InprocControl::clear_received_data() {
2644 _has_bits_[0] &= ~0x00000002u;
2646 inline const std::string& InprocControl::received_data()
const {
2648 return _internal_received_data();
2650 inline void InprocControl::set_received_data(
const std::string& value) {
2651 _internal_set_received_data(value);
2654 inline std::string* InprocControl::mutable_received_data() {
2656 return _internal_mutable_received_data();
2658 inline const std::string& InprocControl::_internal_received_data()
const {
2659 return received_data_.Get();
2661 inline void InprocControl::_internal_set_received_data(
const std::string& value) {
2662 _has_bits_[0] |= 0x00000002u;
2665 inline void InprocControl::set_received_data(std::string&& value) {
2666 _has_bits_[0] |= 0x00000002u;
2671 inline void InprocControl::set_received_data(
const char* value) {
2672 GOOGLE_DCHECK(value !=
nullptr);
2673 _has_bits_[0] |= 0x00000002u;
2678 inline void InprocControl::set_received_data(
const void* value,
2680 _has_bits_[0] |= 0x00000002u;
2682 reinterpret_cast<const char*
>(value), size), GetArena());
2685 inline std::string* InprocControl::_internal_mutable_received_data() {
2686 _has_bits_[0] |= 0x00000002u;
2689 inline std::string* InprocControl::release_received_data() {
2691 if (!_internal_has_received_data()) {
2694 _has_bits_[0] &= ~0x00000002u;
2697 inline void InprocControl::set_allocated_received_data(std::string* received_data) {
2698 if (received_data !=
nullptr) {
2699 _has_bits_[0] |= 0x00000002u;
2701 _has_bits_[0] &= ~0x00000002u;
2707 inline std::string* InprocControl::unsafe_arena_release_received_data() {
2709 GOOGLE_DCHECK(GetArena() !=
nullptr);
2710 _has_bits_[0] &= ~0x00000002u;
2714 inline void InprocControl::unsafe_arena_set_allocated_received_data(
2715 std::string* received_data) {
2716 GOOGLE_DCHECK(GetArena() !=
nullptr);
2717 if (received_data !=
nullptr) {
2718 _has_bits_[0] |= 0x00000002u;
2720 _has_bits_[0] &= ~0x00000002u;
2723 received_data, GetArena());
2728 inline bool InprocControl::_internal_has_hold()
const {
2729 bool value = (_has_bits_[0] & 0x00000008u) != 0;
2732 inline bool InprocControl::has_hold()
const {
2733 return _internal_has_hold();
2735 inline void InprocControl::clear_hold() {
2737 _has_bits_[0] &= ~0x00000008u;
2739 inline bool InprocControl::_internal_hold()
const {
2742 inline bool InprocControl::hold()
const {
2744 return _internal_hold();
2746 inline void InprocControl::_internal_set_hold(
bool value) {
2747 _has_bits_[0] |= 0x00000008u;
2750 inline void InprocControl::set_hold(
bool value) {
2751 _internal_set_hold(value);
2756 #pragma GCC diagnostic pop
2771 PROTOBUF_NAMESPACE_OPEN
2775 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType>() {
2780 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport>() {
2785 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind>() {
2790 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType>() {
2795 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Request>() {
2799 PROTOBUF_NAMESPACE_CLOSE
2803 #include <google/protobuf/port_undef.inc>
ManagerRequest(::PROTOBUF_NAMESPACE_ID::Arena *arena)
void set_ethernet_address(const char *value, size_t size)
ManagerRequest & operator=(const ManagerRequest &from)
static const InprocControl & default_instance()
friend void swap(ManagerRequest &a, ManagerRequest &b)
static const std::string & SocketType_Name(T enum_t_value)
Socket(::PROTOBUF_NAMESPACE_ID::Arena *arena)
void set_client_name(const char *value, size_t size)
std::string * release_client_name()
void MergeFrom(const InprocControl &from)
void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message &from) final
friend void swap(ManagerResponse &a, ManagerResponse &b)
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Socket & operator=(const Socket &from)
ManagerResponse(const ManagerResponse &from)
Socket(const Socket &from)
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message &from) final
void set_allocated_ethernet_address(std::string *ethernet_address)
void CopyFrom(const Socket &from)
std::string * release_subscription_identifier()
InprocControl * New() const final
static const ManagerRequest * internal_default_instance()
void CopyFrom(const ManagerResponse &from)
bool has_subscription_identifier() const
static bool InprocControlType_Parse(const std::string &name, InprocControlType *value)
void UnsafeArenaSwap(InprocControl *other)
void UnsafeArenaSwap(Socket *other)
void CopyFrom(const ManagerRequest &from)
Socket_SocketType SocketType
static const std::string & InprocControlType_Name(T enum_t_value)
friend void swap(InprocControl &a, InprocControl &b)
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
static const ManagerResponse * internal_default_instance()
ManagerResponse(::PROTOBUF_NAMESPACE_ID::Arena *arena)
Socket * New() const final
void set_subscription_identifier(const char *value)
std::string * release_ethernet_address()
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
static bool SocketType_Parse(const std::string &name, SocketType *value)
ManagerRequest & operator=(ManagerRequest &&from) noexcept
void MergeFrom(const Socket &from)
void Swap(InprocControl *other)
Socket(Socket &&from) noexcept
void UnsafeArenaSwap(ManagerRequest *other)
Socket_ConnectOrBind ConnectOrBind
ManagerRequest(const ManagerRequest &from)
ManagerResponse & operator=(const ManagerResponse &from)
static bool ConnectOrBind_Parse(const std::string &name, ConnectOrBind *value)
void CopyFrom(const InprocControl &from)
static const Socket * internal_default_instance()
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Transport_descriptor()
Socket & operator=(Socket &&from) noexcept
static const std::string & Transport_Name(T enum_t_value)
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
InprocControl & operator=(const InprocControl &from)
const std::string & ethernet_address() const
static bool InprocControlType_IsValid(int value)
void set_client_name(const char *value)
bool has_client_name() const
Socket_Transport Transport
static const Socket & default_instance()
void Swap(ManagerResponse *other)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * ConnectOrBind_descriptor()
void set_subscription_identifier(std::string &&value)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * SocketType_descriptor()
void clear_ethernet_address()
bool has_ethernet_address() const
static bool Transport_IsValid(int value)
ManagerResponse(ManagerResponse &&from) noexcept
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
static bool ConnectOrBind_IsValid(int value)
const std::string & client_name() const
void set_ethernet_address(const char *value)
std::string * mutable_ethernet_address()
InprocControl(const InprocControl &from)
std::string * mutable_subscription_identifier()
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControlType_descriptor()
ManagerRequest * New(::PROTOBUF_NAMESPACE_ID::Arena *arena) const final
ManagerResponse * New() const final
static const std::string & ConnectOrBind_Name(T enum_t_value)
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
void set_ethernet_address(std::string &&value)
Socket * New(::PROTOBUF_NAMESPACE_ID::Arena *arena) const final
InprocControl_InprocControlType InprocControlType
ManagerResponse & operator=(ManagerResponse &&from) noexcept
static const InprocControl * internal_default_instance()
void set_allocated_client_name(std::string *client_name)
void MergeFrom(const ManagerRequest &from)
InprocControl * New(::PROTOBUF_NAMESPACE_ID::Arena *arena) const final
void clear_subscription_identifier()
ManagerRequest * New() const final
void set_subscription_identifier(const void *value, size_t size)
void UnsafeArenaSwap(ManagerResponse *other)
void set_allocated_subscription_identifier(std::string *subscription_identifier)
void set_client_name(std::string &&value)
void set_client_name(const std::string &value)
InprocControl(::PROTOBUF_NAMESPACE_ID::Arena *arena)
static const ManagerRequest & default_instance()
static bool Transport_Parse(const std::string &name, Transport *value)
ManagerRequest(ManagerRequest &&from) noexcept
static bool SocketType_IsValid(int value)
std::string * mutable_client_name()
InprocControl(InprocControl &&from) noexcept
void Swap(ManagerRequest *other)
friend void swap(Socket &a, Socket &b)
void set_subscription_identifier(const std::string &value)
static void InitAsDefaultInstance()
static const ManagerResponse & default_instance()
ManagerResponse * New(::PROTOBUF_NAMESPACE_ID::Arena *arena) const final
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
InprocControl & operator=(InprocControl &&from) noexcept
virtual ~ManagerResponse()
void set_ethernet_address(const std::string &value)
virtual ~ManagerRequest()
const std::string & subscription_identifier() const
void MergeFrom(const ManagerResponse &from)
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
@ value
the parser finished reading a JSON value
auto get(const nlohmann::detail::iteration_proxy_value< IteratorType > &i) -> decltype(i.key())
constexpr Socket_SocketType Socket_SocketType_SocketType_MIN
constexpr Request Request_MAX
InterProcessPortalConfig_Transport
const std::string & Socket_ConnectOrBind_Name(T enum_t_value)
ManagerRequestDefaultTypeInternal _ManagerRequest_default_instance_
bool Socket_SocketType_IsValid(int value)
bool Socket_Transport_IsValid(int value)
constexpr int Socket_Transport_Transport_ARRAYSIZE
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MIN
const std::string & Socket_Transport_Name(T enum_t_value)
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControl_InprocControlType_descriptor()
bool Request_Parse(const std::string &name, Request *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
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_Transport_descriptor()
const std::string & Socket_SocketType_Name(T enum_t_value)
constexpr Request Request_MIN
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_ConnectOrBind_descriptor()
constexpr Socket_Transport Socket_Transport_Transport_MAX
constexpr int Socket_SocketType_SocketType_ARRAYSIZE
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MIN
bool Request_IsValid(int value)
@ Socket_Transport_INPROC
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_SocketType_descriptor()
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
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Request_descriptor()
bool InprocControl_InprocControlType_Parse(const std::string &name, InprocControl_InprocControlType *value)
constexpr int Request_ARRAYSIZE
constexpr int Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE
bool Socket_SocketType_Parse(const std::string &name, Socket_SocketType *value)
const std::string & Request_Name(T enum_t_value)
@ Socket_ConnectOrBind_CONNECT
@ Socket_ConnectOrBind_BIND
constexpr Socket_SocketType Socket_SocketType_SocketType_MAX
SocketDefaultTypeInternal _Socket_default_instance_
const std::string & InprocControl_InprocControlType_Name(T enum_t_value)
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MAX
constexpr Socket_Transport Socket_Transport_Transport_MIN
constexpr int InprocControl_InprocControlType_InprocControlType_ARRAYSIZE
bool Socket_ConnectOrBind_Parse(const std::string &name, Socket_ConnectOrBind *value)
bool Socket_ConnectOrBind_IsValid(int value)
bool Socket_Transport_Parse(const std::string &name, Socket_Transport *value)
The global namespace for the Goby project.
PROTOBUF_EXPORT const std::string & GetEmptyStringAlreadyInited()
type
Generic JSON types used in JWTs.
static const ::PROTOBUF_NAMESPACE_ID::uint32 offsets[]
static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[]
static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[]
static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[] PROTOBUF_SECTION_VARIABLE(protodesc_cold)
static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[] PROTOBUF_SECTION_VARIABLE(protodesc_cold)
static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[4] PROTOBUF_SECTION_VARIABLE(protodesc_cold)