Goby3  3.1.5
2024.05.14
interprocess_zeromq.pb.h
Go to the documentation of this file.
1 // Generated by the protocol buffer compiler. DO NOT EDIT!
2 // source: goby/zeromq/protobuf/interprocess_zeromq.proto
3 
4 #ifndef GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
5 #define GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
6 
7 #include <limits>
8 #include <string>
9 
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
14 #error your headers.
15 #endif
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.
20 #endif
21 
22 #include <google/protobuf/port_undef.inc>
23 #include <google/protobuf/io/coded_stream.h>
24 #include <google/protobuf/arena.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> // IWYU pragma: export
33 #include <google/protobuf/extension_set.h> // IWYU pragma: export
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>
41 // @@protoc_insertion_point(includes)
42 #include <google/protobuf/port_def.inc>
43 #define PROTOBUF_INTERNAL_EXPORT_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
44 PROTOBUF_NAMESPACE_OPEN
45 namespace internal {
46 class AnyMetadata;
47 } // namespace internal
48 PROTOBUF_NAMESPACE_CLOSE
49 
50 // Internal implementation detail -- do not use these members.
52  static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTableField entries[]
53  PROTOBUF_SECTION_VARIABLE(protodesc_cold);
54  static const ::PROTOBUF_NAMESPACE_ID::internal::AuxillaryParseTableField aux[]
55  PROTOBUF_SECTION_VARIABLE(protodesc_cold);
56  static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[4]
57  PROTOBUF_SECTION_VARIABLE(protodesc_cold);
58  static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[];
59  static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[];
61 };
62 extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
63 namespace goby {
64 namespace zeromq {
65 namespace protobuf {
66 class InprocControl;
67 class InprocControlDefaultTypeInternal;
68 extern InprocControlDefaultTypeInternal _InprocControl_default_instance_;
69 class ManagerRequest;
70 class ManagerRequestDefaultTypeInternal;
71 extern ManagerRequestDefaultTypeInternal _ManagerRequest_default_instance_;
72 class ManagerResponse;
73 class ManagerResponseDefaultTypeInternal;
74 extern ManagerResponseDefaultTypeInternal _ManagerResponse_default_instance_;
75 class Socket;
76 class SocketDefaultTypeInternal;
77 extern SocketDefaultTypeInternal _Socket_default_instance_;
78 } // namespace protobuf
79 } // namespace zeromq
80 } // namespace goby
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
87 namespace goby {
88 namespace zeromq {
89 namespace protobuf {
90 
91 enum Socket_SocketType : int {
96 };
97 bool Socket_SocketType_IsValid(int value);
101 
102 const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_SocketType_descriptor();
103 template<typename T>
104 inline const std::string& Socket_SocketType_Name(T enum_t_value) {
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(
109  Socket_SocketType_descriptor(), enum_t_value);
110 }
112  const std::string& name, Socket_SocketType* value) {
113  return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_SocketType>(
114  Socket_SocketType_descriptor(), name, value);
115 }
116 enum Socket_Transport : int {
122 };
123 bool Socket_Transport_IsValid(int value);
127 
128 const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_Transport_descriptor();
129 template<typename T>
130 inline const std::string& Socket_Transport_Name(T enum_t_value) {
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(
135  Socket_Transport_descriptor(), enum_t_value);
136 }
138  const std::string& name, Socket_Transport* value) {
139  return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_Transport>(
140  Socket_Transport_descriptor(), name, value);
141 }
145 };
150 
151 const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_ConnectOrBind_descriptor();
152 template<typename T>
153 inline const std::string& Socket_ConnectOrBind_Name(T enum_t_value) {
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(
158  Socket_ConnectOrBind_descriptor(), enum_t_value);
159 }
161  const std::string& name, Socket_ConnectOrBind* value) {
162  return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_ConnectOrBind>(
163  Socket_ConnectOrBind_descriptor(), name, value);
164 }
175 };
180 
181 const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* InprocControl_InprocControlType_descriptor();
182 template<typename T>
183 inline const std::string& InprocControl_InprocControlType_Name(T enum_t_value) {
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(
189 }
191  const std::string& name, InprocControl_InprocControlType* value) {
192  return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<InprocControl_InprocControlType>(
194 }
195 enum Request : int {
198 };
199 bool Request_IsValid(int value);
202 constexpr int Request_ARRAYSIZE = Request_MAX + 1;
203 
204 const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Request_descriptor();
205 template<typename T>
206 inline const std::string& Request_Name(T enum_t_value) {
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(
211  Request_descriptor(), enum_t_value);
212 }
213 inline bool Request_Parse(
214  const std::string& name, Request* value) {
215  return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Request>(
216  Request_descriptor(), name, value);
217 }
218 // ===================================================================
219 
220 class ManagerRequest PROTOBUF_FINAL :
221  public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.ManagerRequest) */ {
222  public:
223  inline ManagerRequest() : ManagerRequest(nullptr) {};
224  virtual ~ManagerRequest();
225 
226  ManagerRequest(const ManagerRequest& from);
227  ManagerRequest(ManagerRequest&& from) noexcept
228  : ManagerRequest() {
229  *this = ::std::move(from);
230  }
231 
232  inline ManagerRequest& operator=(const ManagerRequest& from) {
233  CopyFrom(from);
234  return *this;
235  }
236  inline ManagerRequest& operator=(ManagerRequest&& from) noexcept {
237  if (GetArena() == from.GetArena()) {
238  if (this != &from) InternalSwap(&from);
239  } else {
240  CopyFrom(from);
241  }
242  return *this;
243  }
244 
245  inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
246  return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
247  }
248  inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
249  return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
250  }
251 
252  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
253  return GetDescriptor();
254  }
255  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
256  return GetMetadataStatic().descriptor;
257  }
258  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
259  return GetMetadataStatic().reflection;
260  }
261  static const ManagerRequest& default_instance();
262 
263  static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
264  static inline const ManagerRequest* internal_default_instance() {
265  return reinterpret_cast<const ManagerRequest*>(
267  }
268  static constexpr int kIndexInFileMessages =
269  0;
270 
271  friend void swap(ManagerRequest& a, ManagerRequest& b) {
272  a.Swap(&b);
273  }
274  inline void Swap(ManagerRequest* other) {
275  if (other == this) return;
276  if (GetArena() == other->GetArena()) {
277  InternalSwap(other);
278  } else {
279  ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
280  }
281  }
282  void UnsafeArenaSwap(ManagerRequest* other) {
283  if (other == this) return;
284  GOOGLE_DCHECK(GetArena() == other->GetArena());
285  InternalSwap(other);
286  }
287 
288  // implements Message ----------------------------------------------
289 
290  inline ManagerRequest* New() const final {
291  return CreateMaybeMessage<ManagerRequest>(nullptr);
292  }
293 
294  ManagerRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
295  return CreateMaybeMessage<ManagerRequest>(arena);
296  }
297  void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
298  void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
299  void CopyFrom(const ManagerRequest& from);
300  void MergeFrom(const ManagerRequest& from);
301  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
302  bool IsInitialized() const final;
303 
304  size_t ByteSizeLong() 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(); }
309 
310  private:
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";
318  }
319  protected:
320  explicit ManagerRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena);
321  private:
322  static void ArenaDtor(void* object);
323  inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
324  public:
325 
326  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
327  private:
328  static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
329  ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto);
331  }
332 
333  public:
334 
335  // nested types ----------------------------------------------------
336 
337  // accessors -------------------------------------------------------
338 
339  enum : int {
340  kClientNameFieldNumber = 2,
341  kClientPidFieldNumber = 3,
342  kReadyFieldNumber = 4,
343  kRequestFieldNumber = 1,
344  };
345  // required string client_name = 2 [(.goby.field) = {
346  bool has_client_name() const;
347  private:
348  bool _internal_has_client_name() const;
349  public:
351  const std::string& client_name() const;
352  void set_client_name(const std::string& value);
353  void set_client_name(std::string&& value);
354  void set_client_name(const char* value);
355  void set_client_name(const char* value, size_t size);
356  std::string* mutable_client_name();
357  std::string* release_client_name();
358  void set_allocated_client_name(std::string* client_name);
359  GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
360  " string fields are deprecated and will be removed in a"
361  " future release.")
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"
365  " future release.")
366  void unsafe_arena_set_allocated_client_name(
367  std::string* client_name);
368  private:
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();
372  public:
373 
374  // required int32 client_pid = 3 [(.goby.field) = {
375  bool has_client_pid() const;
376  private:
377  bool _internal_has_client_pid() const;
378  public:
379  void clear_client_pid();
380  ::PROTOBUF_NAMESPACE_ID::int32 client_pid() const;
381  void set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value);
382  private:
383  ::PROTOBUF_NAMESPACE_ID::int32 _internal_client_pid() const;
384  void _internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value);
385  public:
386 
387  // optional bool ready = 4 [default = false, (.goby.field) = {
388  bool has_ready() const;
389  private:
390  bool _internal_has_ready() const;
391  public:
392  void clear_ready();
393  bool ready() const;
394  void set_ready(bool value);
395  private:
396  bool _internal_ready() const;
397  void _internal_set_ready(bool value);
398  public:
399 
400  // required .goby.zeromq.protobuf.Request request = 1 [(.goby.field) = {
401  bool has_request() const;
402  private:
403  bool _internal_has_request() const;
404  public:
405  void clear_request();
406  ::goby::zeromq::protobuf::Request request() const;
407  void set_request(::goby::zeromq::protobuf::Request value);
408  private:
409  ::goby::zeromq::protobuf::Request _internal_request() const;
410  void _internal_set_request(::goby::zeromq::protobuf::Request value);
411  public:
412 
413  // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.ManagerRequest)
414  private:
415  class _Internal;
416 
417  // helper for ByteSizeLong()
418  size_t RequiredFieldsByteSizeFallback() const;
419 
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_;
427  bool ready_;
428  int request_;
430 };
431 // -------------------------------------------------------------------
432 
433 class Socket PROTOBUF_FINAL :
434  public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.Socket) */ {
435  public:
436  inline Socket() : Socket(nullptr) {};
437  virtual ~Socket();
438 
439  Socket(const Socket& from);
440  Socket(Socket&& from) noexcept
441  : Socket() {
442  *this = ::std::move(from);
443  }
444 
445  inline Socket& operator=(const Socket& from) {
446  CopyFrom(from);
447  return *this;
448  }
449  inline Socket& operator=(Socket&& from) noexcept {
450  if (GetArena() == from.GetArena()) {
451  if (this != &from) InternalSwap(&from);
452  } else {
453  CopyFrom(from);
454  }
455  return *this;
456  }
457 
458  inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
459  return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
460  }
461  inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
462  return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
463  }
464 
465  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
466  return GetDescriptor();
467  }
468  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
469  return GetMetadataStatic().descriptor;
470  }
471  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
472  return GetMetadataStatic().reflection;
473  }
474  static const Socket& default_instance();
475 
476  static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
477  static inline const Socket* internal_default_instance() {
478  return reinterpret_cast<const Socket*>(
480  }
481  static constexpr int kIndexInFileMessages =
482  1;
483 
484  friend void swap(Socket& a, Socket& b) {
485  a.Swap(&b);
486  }
487  inline void Swap(Socket* other) {
488  if (other == this) return;
489  if (GetArena() == other->GetArena()) {
490  InternalSwap(other);
491  } else {
492  ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
493  }
494  }
495  void UnsafeArenaSwap(Socket* other) {
496  if (other == this) return;
497  GOOGLE_DCHECK(GetArena() == other->GetArena());
498  InternalSwap(other);
499  }
500 
501  // implements Message ----------------------------------------------
502 
503  inline Socket* New() const final {
504  return CreateMaybeMessage<Socket>(nullptr);
505  }
506 
507  Socket* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
508  return CreateMaybeMessage<Socket>(arena);
509  }
510  void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
511  void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
512  void CopyFrom(const Socket& from);
513  void MergeFrom(const Socket& from);
514  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
515  bool IsInitialized() const final;
516 
517  size_t ByteSizeLong() 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(); }
522 
523  private:
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";
531  }
532  protected:
533  explicit Socket(::PROTOBUF_NAMESPACE_ID::Arena* arena);
534  private:
535  static void ArenaDtor(void* object);
536  inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
537  public:
538 
539  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
540  private:
541  static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
542  ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto);
544  }
545 
546  public:
547 
548  // nested types ----------------------------------------------------
549 
551  static constexpr SocketType PUBLISH =
553  static constexpr SocketType SUBSCRIBE =
555  static constexpr SocketType REPLY =
557  static constexpr SocketType REQUEST =
559  static inline bool SocketType_IsValid(int value) {
560  return Socket_SocketType_IsValid(value);
561  }
562  static constexpr SocketType SocketType_MIN =
564  static constexpr SocketType SocketType_MAX =
566  static constexpr int SocketType_ARRAYSIZE =
568  static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
571  }
572  template<typename T>
573  static inline const std::string& SocketType_Name(T enum_t_value) {
574  static_assert(::std::is_same<T, SocketType>::value ||
575  ::std::is_integral<T>::value,
576  "Incorrect type passed to function SocketType_Name.");
577  return Socket_SocketType_Name(enum_t_value);
578  }
579  static inline bool SocketType_Parse(const std::string& name,
580  SocketType* value) {
581  return Socket_SocketType_Parse(name, value);
582  }
583 
585  static constexpr Transport INPROC =
587  static constexpr Transport IPC =
589  static constexpr Transport TCP =
591  static constexpr Transport PGM =
593  static constexpr Transport EPGM =
595  static inline bool Transport_IsValid(int value) {
596  return Socket_Transport_IsValid(value);
597  }
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*
607  }
608  template<typename T>
609  static inline const std::string& Transport_Name(T enum_t_value) {
610  static_assert(::std::is_same<T, Transport>::value ||
611  ::std::is_integral<T>::value,
612  "Incorrect type passed to function Transport_Name.");
613  return Socket_Transport_Name(enum_t_value);
614  }
615  static inline bool Transport_Parse(const std::string& name,
616  Transport* value) {
617  return Socket_Transport_Parse(name, value);
618  }
619 
621  static constexpr ConnectOrBind CONNECT =
623  static constexpr ConnectOrBind BIND =
625  static inline bool ConnectOrBind_IsValid(int value) {
626  return Socket_ConnectOrBind_IsValid(value);
627  }
628  static constexpr ConnectOrBind ConnectOrBind_MIN =
630  static constexpr ConnectOrBind ConnectOrBind_MAX =
632  static constexpr int ConnectOrBind_ARRAYSIZE =
634  static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
637  }
638  template<typename T>
639  static inline const std::string& ConnectOrBind_Name(T enum_t_value) {
640  static_assert(::std::is_same<T, ConnectOrBind>::value ||
641  ::std::is_integral<T>::value,
642  "Incorrect type passed to function ConnectOrBind_Name.");
643  return Socket_ConnectOrBind_Name(enum_t_value);
644  }
645  static inline bool ConnectOrBind_Parse(const std::string& name,
646  ConnectOrBind* value) {
647  return Socket_ConnectOrBind_Parse(name, value);
648  }
649 
650  // accessors -------------------------------------------------------
651 
652  enum : int {
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,
663  };
664  // optional string ethernet_address = 5 [default = "127.0.0.1", (.goby.field) = {
665  bool has_ethernet_address() const;
666  private:
667  bool _internal_has_ethernet_address() const;
668  public:
670  const std::string& ethernet_address() const;
671  void set_ethernet_address(const std::string& value);
672  void set_ethernet_address(std::string&& value);
673  void set_ethernet_address(const char* value);
674  void set_ethernet_address(const char* value, size_t size);
675  std::string* mutable_ethernet_address();
676  std::string* release_ethernet_address();
677  void set_allocated_ethernet_address(std::string* ethernet_address);
678  GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
679  " string fields are deprecated and will be removed in a"
680  " future release.")
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"
684  " future release.")
685  void unsafe_arena_set_allocated_ethernet_address(
686  std::string* ethernet_address);
687  private:
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();
691  public:
692 
693  // optional string multicast_address = 6 [default = "239.255.7.15", (.goby.field) = {
694  bool has_multicast_address() const;
695  private:
696  bool _internal_has_multicast_address() const;
697  public:
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"
709  " future release.")
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"
713  " future release.")
714  void unsafe_arena_set_allocated_multicast_address(
715  std::string* multicast_address);
716  private:
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();
720  public:
721 
722  // optional string socket_name = 8;
723  bool has_socket_name() const;
724  private:
725  bool _internal_has_socket_name() const;
726  public:
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"
738  " future release.")
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"
742  " future release.")
743  void unsafe_arena_set_allocated_socket_name(
744  std::string* socket_name);
745  private:
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();
749  public:
750 
751  // optional uint32 socket_id = 2 [default = 0, (.goby.field) = {
752  bool has_socket_id() const;
753  private:
754  bool _internal_has_socket_id() const;
755  public:
756  void clear_socket_id();
757  ::PROTOBUF_NAMESPACE_ID::uint32 socket_id() const;
758  void set_socket_id(::PROTOBUF_NAMESPACE_ID::uint32 value);
759  private:
760  ::PROTOBUF_NAMESPACE_ID::uint32 _internal_socket_id() const;
761  void _internal_set_socket_id(::PROTOBUF_NAMESPACE_ID::uint32 value);
762  public:
763 
764  // required .goby.zeromq.protobuf.Socket.SocketType socket_type = 1;
765  bool has_socket_type() const;
766  private:
767  bool _internal_has_socket_type() const;
768  public:
769  void clear_socket_type();
770  ::goby::zeromq::protobuf::Socket_SocketType socket_type() const;
771  void set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value);
772  private:
773  ::goby::zeromq::protobuf::Socket_SocketType _internal_socket_type() const;
774  void _internal_set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value);
775  public:
776 
777  // optional .goby.zeromq.protobuf.Socket.Transport transport = 3 [default = EPGM];
778  bool has_transport() const;
779  private:
780  bool _internal_has_transport() const;
781  public:
782  void clear_transport();
783  ::goby::zeromq::protobuf::Socket_Transport transport() const;
784  void set_transport(::goby::zeromq::protobuf::Socket_Transport value);
785  private:
786  ::goby::zeromq::protobuf::Socket_Transport _internal_transport() const;
787  void _internal_set_transport(::goby::zeromq::protobuf::Socket_Transport value);
788  public:
789 
790  // optional .goby.zeromq.protobuf.Socket.ConnectOrBind connect_or_bind = 4 [default = CONNECT];
791  bool has_connect_or_bind() const;
792  private:
793  bool _internal_has_connect_or_bind() const;
794  public:
795  void clear_connect_or_bind();
796  ::goby::zeromq::protobuf::Socket_ConnectOrBind connect_or_bind() const;
797  void set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value);
798  private:
799  ::goby::zeromq::protobuf::Socket_ConnectOrBind _internal_connect_or_bind() const;
800  void _internal_set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value);
801  public:
802 
803  // optional uint32 ethernet_port = 7 [default = 11142];
804  bool has_ethernet_port() const;
805  private:
806  bool _internal_has_ethernet_port() const;
807  public:
808  void clear_ethernet_port();
809  ::PROTOBUF_NAMESPACE_ID::uint32 ethernet_port() const;
810  void set_ethernet_port(::PROTOBUF_NAMESPACE_ID::uint32 value);
811  private:
812  ::PROTOBUF_NAMESPACE_ID::uint32 _internal_ethernet_port() const;
813  void _internal_set_ethernet_port(::PROTOBUF_NAMESPACE_ID::uint32 value);
814  public:
815 
816  // optional uint32 send_queue_size = 10 [default = 1000];
817  bool has_send_queue_size() const;
818  private:
819  bool _internal_has_send_queue_size() const;
820  public:
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);
824  private:
825  ::PROTOBUF_NAMESPACE_ID::uint32 _internal_send_queue_size() const;
826  void _internal_set_send_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value);
827  public:
828 
829  // optional uint32 receive_queue_size = 11 [default = 1000];
830  bool has_receive_queue_size() const;
831  private:
832  bool _internal_has_receive_queue_size() const;
833  public:
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);
837  private:
838  ::PROTOBUF_NAMESPACE_ID::uint32 _internal_receive_queue_size() const;
839  void _internal_set_receive_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value);
840  public:
841 
842  // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.Socket)
843  private:
844  class _Internal;
845 
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_;
851  public:
852  static ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<std::string> _i_give_permission_to_break_this_code_default_ethernet_address_;
853  private:
854  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr ethernet_address_;
855  public:
856  static ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<std::string> _i_give_permission_to_break_this_code_default_multicast_address_;
857  private:
858  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr multicast_address_;
859  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr socket_name_;
860  ::PROTOBUF_NAMESPACE_ID::uint32 socket_id_;
861  int socket_type_;
862  int transport_;
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_;
868 };
869 // -------------------------------------------------------------------
870 
871 class ManagerResponse PROTOBUF_FINAL :
872  public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.ManagerResponse) */ {
873  public:
874  inline ManagerResponse() : ManagerResponse(nullptr) {};
875  virtual ~ManagerResponse();
876 
877  ManagerResponse(const ManagerResponse& from);
878  ManagerResponse(ManagerResponse&& from) noexcept
879  : ManagerResponse() {
880  *this = ::std::move(from);
881  }
882 
883  inline ManagerResponse& operator=(const ManagerResponse& from) {
884  CopyFrom(from);
885  return *this;
886  }
887  inline ManagerResponse& operator=(ManagerResponse&& from) noexcept {
888  if (GetArena() == from.GetArena()) {
889  if (this != &from) InternalSwap(&from);
890  } else {
891  CopyFrom(from);
892  }
893  return *this;
894  }
895 
896  inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
897  return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
898  }
899  inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
900  return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
901  }
902 
903  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
904  return GetDescriptor();
905  }
906  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
907  return GetMetadataStatic().descriptor;
908  }
909  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
910  return GetMetadataStatic().reflection;
911  }
912  static const ManagerResponse& default_instance();
913 
914  static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
915  static inline const ManagerResponse* internal_default_instance() {
916  return reinterpret_cast<const ManagerResponse*>(
918  }
919  static constexpr int kIndexInFileMessages =
920  2;
921 
922  friend void swap(ManagerResponse& a, ManagerResponse& b) {
923  a.Swap(&b);
924  }
925  inline void Swap(ManagerResponse* other) {
926  if (other == this) return;
927  if (GetArena() == other->GetArena()) {
928  InternalSwap(other);
929  } else {
930  ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
931  }
932  }
933  void UnsafeArenaSwap(ManagerResponse* other) {
934  if (other == this) return;
935  GOOGLE_DCHECK(GetArena() == other->GetArena());
936  InternalSwap(other);
937  }
938 
939  // implements Message ----------------------------------------------
940 
941  inline ManagerResponse* New() const final {
942  return CreateMaybeMessage<ManagerResponse>(nullptr);
943  }
944 
945  ManagerResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
946  return CreateMaybeMessage<ManagerResponse>(arena);
947  }
948  void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
949  void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
950  void CopyFrom(const ManagerResponse& from);
951  void MergeFrom(const ManagerResponse& from);
952  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
953  bool IsInitialized() const final;
954 
955  size_t ByteSizeLong() 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(); }
960 
961  private:
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";
969  }
970  protected:
971  explicit ManagerResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena);
972  private:
973  static void ArenaDtor(void* object);
974  inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
975  public:
976 
977  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
978  private:
979  static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
980  ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto);
982  }
983 
984  public:
985 
986  // nested types ----------------------------------------------------
987 
988  // accessors -------------------------------------------------------
989 
990  enum : int {
991  kClientNameFieldNumber = 2,
992  kPublishSocketFieldNumber = 4,
993  kSubscribeSocketFieldNumber = 5,
994  kClientPidFieldNumber = 3,
995  kRequestFieldNumber = 1,
996  kHoldFieldNumber = 6,
997  };
998  // required string client_name = 2;
999  bool has_client_name() const;
1000  private:
1001  bool _internal_has_client_name() const;
1002  public:
1004  const std::string& client_name() const;
1005  void set_client_name(const std::string& value);
1006  void set_client_name(std::string&& value);
1007  void set_client_name(const char* value);
1008  void set_client_name(const char* value, size_t size);
1009  std::string* mutable_client_name();
1010  std::string* release_client_name();
1011  void set_allocated_client_name(std::string* client_name);
1012  GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1013  " string fields are deprecated and will be removed in a"
1014  " future release.")
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"
1018  " future release.")
1019  void unsafe_arena_set_allocated_client_name(
1020  std::string* client_name);
1021  private:
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();
1025  public:
1026 
1027  // optional .goby.zeromq.protobuf.Socket publish_socket = 4;
1028  bool has_publish_socket() const;
1029  private:
1030  bool _internal_has_publish_socket() const;
1031  public:
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);
1037  private:
1038  const ::goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1039  ::goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1040  public:
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();
1044 
1045  // optional .goby.zeromq.protobuf.Socket subscribe_socket = 5;
1046  bool has_subscribe_socket() const;
1047  private:
1048  bool _internal_has_subscribe_socket() const;
1049  public:
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);
1055  private:
1056  const ::goby::zeromq::protobuf::Socket& _internal_subscribe_socket() const;
1057  ::goby::zeromq::protobuf::Socket* _internal_mutable_subscribe_socket();
1058  public:
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();
1062 
1063  // required int32 client_pid = 3;
1064  bool has_client_pid() const;
1065  private:
1066  bool _internal_has_client_pid() const;
1067  public:
1068  void clear_client_pid();
1069  ::PROTOBUF_NAMESPACE_ID::int32 client_pid() const;
1070  void set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value);
1071  private:
1072  ::PROTOBUF_NAMESPACE_ID::int32 _internal_client_pid() const;
1073  void _internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value);
1074  public:
1075 
1076  // required .goby.zeromq.protobuf.Request request = 1;
1077  bool has_request() const;
1078  private:
1079  bool _internal_has_request() const;
1080  public:
1081  void clear_request();
1082  ::goby::zeromq::protobuf::Request request() const;
1083  void set_request(::goby::zeromq::protobuf::Request value);
1084  private:
1085  ::goby::zeromq::protobuf::Request _internal_request() const;
1086  void _internal_set_request(::goby::zeromq::protobuf::Request value);
1087  public:
1088 
1089  // optional bool hold = 6 [default = true, (.goby.field) = {
1090  bool has_hold() const;
1091  private:
1092  bool _internal_has_hold() const;
1093  public:
1094  void clear_hold();
1095  bool hold() const;
1096  void set_hold(bool value);
1097  private:
1098  bool _internal_hold() const;
1099  void _internal_set_hold(bool value);
1100  public:
1101 
1102  // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.ManagerResponse)
1103  private:
1104  class _Internal;
1105 
1106  // helper for ByteSizeLong()
1107  size_t RequiredFieldsByteSizeFallback() const;
1108 
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_;
1118  int request_;
1119  bool hold_;
1121 };
1122 // -------------------------------------------------------------------
1123 
1124 class InprocControl PROTOBUF_FINAL :
1125  public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.InprocControl) */ {
1126  public:
1127  inline InprocControl() : InprocControl(nullptr) {};
1128  virtual ~InprocControl();
1129 
1130  InprocControl(const InprocControl& from);
1131  InprocControl(InprocControl&& from) noexcept
1132  : InprocControl() {
1133  *this = ::std::move(from);
1134  }
1135 
1136  inline InprocControl& operator=(const InprocControl& from) {
1137  CopyFrom(from);
1138  return *this;
1139  }
1140  inline InprocControl& operator=(InprocControl&& from) noexcept {
1141  if (GetArena() == from.GetArena()) {
1142  if (this != &from) InternalSwap(&from);
1143  } else {
1144  CopyFrom(from);
1145  }
1146  return *this;
1147  }
1148 
1149  inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
1150  return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1151  }
1152  inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
1153  return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1154  }
1155 
1156  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
1157  return GetDescriptor();
1158  }
1159  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
1160  return GetMetadataStatic().descriptor;
1161  }
1162  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
1163  return GetMetadataStatic().reflection;
1164  }
1165  static const InprocControl& default_instance();
1166 
1167  static void InitAsDefaultInstance(); // FOR INTERNAL USE ONLY
1168  static inline const InprocControl* internal_default_instance() {
1169  return reinterpret_cast<const InprocControl*>(
1171  }
1172  static constexpr int kIndexInFileMessages =
1173  3;
1174 
1175  friend void swap(InprocControl& a, InprocControl& b) {
1176  a.Swap(&b);
1177  }
1178  inline void Swap(InprocControl* other) {
1179  if (other == this) return;
1180  if (GetArena() == other->GetArena()) {
1181  InternalSwap(other);
1182  } else {
1183  ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
1184  }
1185  }
1186  void UnsafeArenaSwap(InprocControl* other) {
1187  if (other == this) return;
1188  GOOGLE_DCHECK(GetArena() == other->GetArena());
1189  InternalSwap(other);
1190  }
1191 
1192  // implements Message ----------------------------------------------
1193 
1194  inline InprocControl* New() const final {
1195  return CreateMaybeMessage<InprocControl>(nullptr);
1196  }
1197 
1198  InprocControl* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final {
1199  return CreateMaybeMessage<InprocControl>(arena);
1200  }
1201  void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
1202  void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final;
1203  void CopyFrom(const InprocControl& from);
1204  void MergeFrom(const InprocControl& from);
1205  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1206  bool IsInitialized() const final;
1207 
1208  size_t ByteSizeLong() 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(); }
1213 
1214  private:
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";
1222  }
1223  protected:
1224  explicit InprocControl(::PROTOBUF_NAMESPACE_ID::Arena* arena);
1225  private:
1226  static void ArenaDtor(void* object);
1227  inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena);
1228  public:
1229 
1230  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1231  private:
1232  static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() {
1233  ::PROTOBUF_NAMESPACE_ID::internal::AssignDescriptors(&::descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto);
1235  }
1236 
1237  public:
1238 
1239  // nested types ----------------------------------------------------
1240 
1242  static constexpr InprocControlType PUB_CONFIGURATION =
1244  static constexpr InprocControlType SUBSCRIBE =
1246  static constexpr InprocControlType SUBSCRIBE_ACK =
1248  static constexpr InprocControlType UNSUBSCRIBE =
1250  static constexpr InprocControlType UNSUBSCRIBE_ACK =
1252  static constexpr InprocControlType RECEIVE =
1254  static constexpr InprocControlType SHUTDOWN =
1256  static constexpr InprocControlType REQUEST_HOLD_STATE =
1258  static constexpr InprocControlType NOTIFY_HOLD_STATE =
1260  static inline bool InprocControlType_IsValid(int value) {
1262  }
1263  static constexpr InprocControlType InprocControlType_MIN =
1265  static constexpr InprocControlType InprocControlType_MAX =
1267  static constexpr int InprocControlType_ARRAYSIZE =
1269  static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
1272  }
1273  template<typename T>
1274  static inline const std::string& InprocControlType_Name(T enum_t_value) {
1275  static_assert(::std::is_same<T, InprocControlType>::value ||
1276  ::std::is_integral<T>::value,
1277  "Incorrect type passed to function InprocControlType_Name.");
1278  return InprocControl_InprocControlType_Name(enum_t_value);
1279  }
1280  static inline bool InprocControlType_Parse(const std::string& name,
1281  InprocControlType* value) {
1282  return InprocControl_InprocControlType_Parse(name, value);
1283  }
1284 
1285  // accessors -------------------------------------------------------
1286 
1287  enum : int {
1288  kSubscriptionIdentifierFieldNumber = 3,
1289  kReceivedDataFieldNumber = 4,
1290  kPublishSocketFieldNumber = 2,
1291  kHoldFieldNumber = 10,
1292  kTypeFieldNumber = 1,
1293  };
1294  // optional bytes subscription_identifier = 3;
1296  private:
1297  bool _internal_has_subscription_identifier() const;
1298  public:
1300  const std::string& subscription_identifier() const;
1301  void set_subscription_identifier(const std::string& value);
1302  void set_subscription_identifier(std::string&& value);
1303  void set_subscription_identifier(const char* value);
1304  void set_subscription_identifier(const void* value, size_t size);
1307  void set_allocated_subscription_identifier(std::string* subscription_identifier);
1308  GOOGLE_PROTOBUF_RUNTIME_DEPRECATED("The unsafe_arena_ accessors for"
1309  " string fields are deprecated and will be removed in a"
1310  " future release.")
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"
1314  " future release.")
1315  void unsafe_arena_set_allocated_subscription_identifier(
1316  std::string* subscription_identifier);
1317  private:
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();
1321  public:
1322 
1323  // optional bytes received_data = 4;
1324  bool has_received_data() const;
1325  private:
1326  bool _internal_has_received_data() const;
1327  public:
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"
1339  " future release.")
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"
1343  " future release.")
1344  void unsafe_arena_set_allocated_received_data(
1345  std::string* received_data);
1346  private:
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();
1350  public:
1351 
1352  // optional .goby.zeromq.protobuf.Socket publish_socket = 2;
1353  bool has_publish_socket() const;
1354  private:
1355  bool _internal_has_publish_socket() const;
1356  public:
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);
1362  private:
1363  const ::goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1364  ::goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1365  public:
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();
1369 
1370  // optional bool hold = 10;
1371  bool has_hold() const;
1372  private:
1373  bool _internal_has_hold() const;
1374  public:
1375  void clear_hold();
1376  bool hold() const;
1377  void set_hold(bool value);
1378  private:
1379  bool _internal_hold() const;
1380  void _internal_set_hold(bool value);
1381  public:
1382 
1383  // required .goby.zeromq.protobuf.InprocControl.InprocControlType type = 1;
1384  bool has_type() const;
1385  private:
1386  bool _internal_has_type() const;
1387  public:
1388  void clear_type();
1389  ::goby::zeromq::protobuf::InprocControl_InprocControlType type() const;
1390  void set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value);
1391  private:
1392  ::goby::zeromq::protobuf::InprocControl_InprocControlType _internal_type() const;
1393  void _internal_set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value);
1394  public:
1395 
1396  // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.InprocControl)
1397  private:
1398  class _Internal;
1399 
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_;
1408  bool hold_;
1409  int type_;
1411 };
1412 // ===================================================================
1413 
1414 
1415 // ===================================================================
1416 
1417 #ifdef __GNUC__
1418  #pragma GCC diagnostic push
1419  #pragma GCC diagnostic ignored "-Wstrict-aliasing"
1420 #endif // __GNUC__
1421 // ManagerRequest
1422 
1423 // required .goby.zeromq.protobuf.Request request = 1 [(.goby.field) = {
1424 inline bool ManagerRequest::_internal_has_request() const {
1425  bool value = (_has_bits_[0] & 0x00000008u) != 0;
1426  return value;
1427 }
1428 inline bool ManagerRequest::has_request() const {
1429  return _internal_has_request();
1430 }
1431 inline void ManagerRequest::clear_request() {
1432  request_ = 1;
1433  _has_bits_[0] &= ~0x00000008u;
1434 }
1435 inline ::goby::zeromq::protobuf::Request ManagerRequest::_internal_request() const {
1436  return static_cast< ::goby::zeromq::protobuf::Request >(request_);
1437 }
1438 inline ::goby::zeromq::protobuf::Request ManagerRequest::request() const {
1439  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.request)
1440  return _internal_request();
1441 }
1442 inline void ManagerRequest::_internal_set_request(::goby::zeromq::protobuf::Request value) {
1443  assert(::goby::zeromq::protobuf::Request_IsValid(value));
1444  _has_bits_[0] |= 0x00000008u;
1445  request_ = value;
1446 }
1447 inline void ManagerRequest::set_request(::goby::zeromq::protobuf::Request value) {
1448  _internal_set_request(value);
1449  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.request)
1450 }
1451 
1452 // required string client_name = 2 [(.goby.field) = {
1453 inline bool ManagerRequest::_internal_has_client_name() const {
1454  bool value = (_has_bits_[0] & 0x00000001u) != 0;
1455  return value;
1456 }
1457 inline bool ManagerRequest::has_client_name() const {
1458  return _internal_has_client_name();
1459 }
1460 inline void ManagerRequest::clear_client_name() {
1461  client_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1462  _has_bits_[0] &= ~0x00000001u;
1463 }
1464 inline const std::string& ManagerRequest::client_name() const {
1465  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.client_name)
1466  return _internal_client_name();
1467 }
1468 inline void ManagerRequest::set_client_name(const std::string& value) {
1469  _internal_set_client_name(value);
1470  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.client_name)
1471 }
1472 inline std::string* ManagerRequest::mutable_client_name() {
1473  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerRequest.client_name)
1474  return _internal_mutable_client_name();
1475 }
1476 inline const std::string& ManagerRequest::_internal_client_name() const {
1477  return client_name_.Get();
1478 }
1479 inline void ManagerRequest::_internal_set_client_name(const std::string& value) {
1480  _has_bits_[0] |= 0x00000001u;
1481  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
1482 }
1483 inline void ManagerRequest::set_client_name(std::string&& value) {
1484  _has_bits_[0] |= 0x00000001u;
1485  client_name_.Set(
1486  &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
1487  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.ManagerRequest.client_name)
1488 }
1489 inline void ManagerRequest::set_client_name(const char* value) {
1490  GOOGLE_DCHECK(value != nullptr);
1491  _has_bits_[0] |= 0x00000001u;
1492  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
1493  GetArena());
1494  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.ManagerRequest.client_name)
1495 }
1496 inline void ManagerRequest::set_client_name(const char* value,
1497  size_t size) {
1498  _has_bits_[0] |= 0x00000001u;
1499  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
1500  reinterpret_cast<const char*>(value), size), GetArena());
1501  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.ManagerRequest.client_name)
1502 }
1503 inline std::string* ManagerRequest::_internal_mutable_client_name() {
1504  _has_bits_[0] |= 0x00000001u;
1505  return client_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1506 }
1507 inline std::string* ManagerRequest::release_client_name() {
1508  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerRequest.client_name)
1509  if (!_internal_has_client_name()) {
1510  return nullptr;
1511  }
1512  _has_bits_[0] &= ~0x00000001u;
1513  return client_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1514 }
1515 inline void ManagerRequest::set_allocated_client_name(std::string* client_name) {
1516  if (client_name != nullptr) {
1517  _has_bits_[0] |= 0x00000001u;
1518  } else {
1519  _has_bits_[0] &= ~0x00000001u;
1520  }
1521  client_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), client_name,
1522  GetArena());
1523  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerRequest.client_name)
1524 }
1525 inline std::string* ManagerRequest::unsafe_arena_release_client_name() {
1526  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.ManagerRequest.client_name)
1527  GOOGLE_DCHECK(GetArena() != nullptr);
1528  _has_bits_[0] &= ~0x00000001u;
1529  return client_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
1530  GetArena());
1531 }
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;
1537  } else {
1538  _has_bits_[0] &= ~0x00000001u;
1539  }
1540  client_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
1541  client_name, GetArena());
1542  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerRequest.client_name)
1543 }
1544 
1545 // required int32 client_pid = 3 [(.goby.field) = {
1546 inline bool ManagerRequest::_internal_has_client_pid() const {
1547  bool value = (_has_bits_[0] & 0x00000002u) != 0;
1548  return value;
1549 }
1550 inline bool ManagerRequest::has_client_pid() const {
1551  return _internal_has_client_pid();
1552 }
1553 inline void ManagerRequest::clear_client_pid() {
1554  client_pid_ = 0;
1555  _has_bits_[0] &= ~0x00000002u;
1556 }
1557 inline ::PROTOBUF_NAMESPACE_ID::int32 ManagerRequest::_internal_client_pid() const {
1558  return client_pid_;
1559 }
1560 inline ::PROTOBUF_NAMESPACE_ID::int32 ManagerRequest::client_pid() const {
1561  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.client_pid)
1562  return _internal_client_pid();
1563 }
1564 inline void ManagerRequest::_internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value) {
1565  _has_bits_[0] |= 0x00000002u;
1566  client_pid_ = value;
1567 }
1568 inline void ManagerRequest::set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value) {
1569  _internal_set_client_pid(value);
1570  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.client_pid)
1571 }
1572 
1573 // optional bool ready = 4 [default = false, (.goby.field) = {
1574 inline bool ManagerRequest::_internal_has_ready() const {
1575  bool value = (_has_bits_[0] & 0x00000004u) != 0;
1576  return value;
1577 }
1578 inline bool ManagerRequest::has_ready() const {
1579  return _internal_has_ready();
1580 }
1581 inline void ManagerRequest::clear_ready() {
1582  ready_ = false;
1583  _has_bits_[0] &= ~0x00000004u;
1584 }
1585 inline bool ManagerRequest::_internal_ready() const {
1586  return ready_;
1587 }
1588 inline bool ManagerRequest::ready() const {
1589  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.ready)
1590  return _internal_ready();
1591 }
1592 inline void ManagerRequest::_internal_set_ready(bool value) {
1593  _has_bits_[0] |= 0x00000004u;
1594  ready_ = value;
1595 }
1596 inline void ManagerRequest::set_ready(bool value) {
1597  _internal_set_ready(value);
1598  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.ready)
1599 }
1600 
1601 // -------------------------------------------------------------------
1602 
1603 // Socket
1604 
1605 // required .goby.zeromq.protobuf.Socket.SocketType socket_type = 1;
1606 inline bool Socket::_internal_has_socket_type() const {
1607  bool value = (_has_bits_[0] & 0x00000010u) != 0;
1608  return value;
1609 }
1610 inline bool Socket::has_socket_type() const {
1611  return _internal_has_socket_type();
1612 }
1613 inline void Socket::clear_socket_type() {
1614  socket_type_ = 1;
1615  _has_bits_[0] &= ~0x00000010u;
1616 }
1617 inline ::goby::zeromq::protobuf::Socket_SocketType Socket::_internal_socket_type() const {
1618  return static_cast< ::goby::zeromq::protobuf::Socket_SocketType >(socket_type_);
1619 }
1620 inline ::goby::zeromq::protobuf::Socket_SocketType Socket::socket_type() const {
1621  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_type)
1622  return _internal_socket_type();
1623 }
1624 inline void Socket::_internal_set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value) {
1626  _has_bits_[0] |= 0x00000010u;
1627  socket_type_ = value;
1628 }
1629 inline void Socket::set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value) {
1630  _internal_set_socket_type(value);
1631  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_type)
1632 }
1633 
1634 // optional uint32 socket_id = 2 [default = 0, (.goby.field) = {
1635 inline bool Socket::_internal_has_socket_id() const {
1636  bool value = (_has_bits_[0] & 0x00000008u) != 0;
1637  return value;
1638 }
1639 inline bool Socket::has_socket_id() const {
1640  return _internal_has_socket_id();
1641 }
1642 inline void Socket::clear_socket_id() {
1643  socket_id_ = 0u;
1644  _has_bits_[0] &= ~0x00000008u;
1645 }
1646 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::_internal_socket_id() const {
1647  return socket_id_;
1648 }
1649 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::socket_id() const {
1650  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_id)
1651  return _internal_socket_id();
1652 }
1653 inline void Socket::_internal_set_socket_id(::PROTOBUF_NAMESPACE_ID::uint32 value) {
1654  _has_bits_[0] |= 0x00000008u;
1655  socket_id_ = value;
1656 }
1657 inline void Socket::set_socket_id(::PROTOBUF_NAMESPACE_ID::uint32 value) {
1658  _internal_set_socket_id(value);
1659  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_id)
1660 }
1661 
1662 // optional .goby.zeromq.protobuf.Socket.Transport transport = 3 [default = EPGM];
1663 inline bool Socket::_internal_has_transport() const {
1664  bool value = (_has_bits_[0] & 0x00000020u) != 0;
1665  return value;
1666 }
1667 inline bool Socket::has_transport() const {
1668  return _internal_has_transport();
1669 }
1670 inline void Socket::clear_transport() {
1671  transport_ = 5;
1672  _has_bits_[0] &= ~0x00000020u;
1673 }
1674 inline ::goby::zeromq::protobuf::Socket_Transport Socket::_internal_transport() const {
1675  return static_cast< ::goby::zeromq::protobuf::Socket_Transport >(transport_);
1676 }
1677 inline ::goby::zeromq::protobuf::Socket_Transport Socket::transport() const {
1678  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.transport)
1679  return _internal_transport();
1680 }
1681 inline void Socket::_internal_set_transport(::goby::zeromq::protobuf::Socket_Transport value) {
1683  _has_bits_[0] |= 0x00000020u;
1684  transport_ = value;
1685 }
1686 inline void Socket::set_transport(::goby::zeromq::protobuf::Socket_Transport value) {
1687  _internal_set_transport(value);
1688  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.transport)
1689 }
1690 
1691 // optional .goby.zeromq.protobuf.Socket.ConnectOrBind connect_or_bind = 4 [default = CONNECT];
1692 inline bool Socket::_internal_has_connect_or_bind() const {
1693  bool value = (_has_bits_[0] & 0x00000040u) != 0;
1694  return value;
1695 }
1696 inline bool Socket::has_connect_or_bind() const {
1697  return _internal_has_connect_or_bind();
1698 }
1699 inline void Socket::clear_connect_or_bind() {
1700  connect_or_bind_ = 1;
1701  _has_bits_[0] &= ~0x00000040u;
1702 }
1703 inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::_internal_connect_or_bind() const {
1704  return static_cast< ::goby::zeromq::protobuf::Socket_ConnectOrBind >(connect_or_bind_);
1705 }
1706 inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::connect_or_bind() const {
1707  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.connect_or_bind)
1708  return _internal_connect_or_bind();
1709 }
1710 inline void Socket::_internal_set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value) {
1712  _has_bits_[0] |= 0x00000040u;
1713  connect_or_bind_ = value;
1714 }
1715 inline void Socket::set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value) {
1716  _internal_set_connect_or_bind(value);
1717  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.connect_or_bind)
1718 }
1719 
1720 // optional string ethernet_address = 5 [default = "127.0.0.1", (.goby.field) = {
1721 inline bool Socket::_internal_has_ethernet_address() const {
1722  bool value = (_has_bits_[0] & 0x00000001u) != 0;
1723  return value;
1724 }
1725 inline bool Socket::has_ethernet_address() const {
1726  return _internal_has_ethernet_address();
1727 }
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;
1731 }
1732 inline const std::string& Socket::ethernet_address() const {
1733  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.ethernet_address)
1734  return _internal_ethernet_address();
1735 }
1736 inline void Socket::set_ethernet_address(const std::string& value) {
1737  _internal_set_ethernet_address(value);
1738  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.ethernet_address)
1739 }
1740 inline std::string* Socket::mutable_ethernet_address() {
1741  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.ethernet_address)
1742  return _internal_mutable_ethernet_address();
1743 }
1744 inline const std::string& Socket::_internal_ethernet_address() const {
1745  return ethernet_address_.Get();
1746 }
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());
1750 }
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());
1755  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.Socket.ethernet_address)
1756 }
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),
1761  GetArena());
1762  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.Socket.ethernet_address)
1763 }
1764 inline void Socket::set_ethernet_address(const char* value,
1765  size_t size) {
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());
1769  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.Socket.ethernet_address)
1770 }
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());
1774 }
1775 inline std::string* Socket::release_ethernet_address() {
1776  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.ethernet_address)
1777  if (!_internal_has_ethernet_address()) {
1778  return nullptr;
1779  }
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());
1782 }
1783 inline void Socket::set_allocated_ethernet_address(std::string* ethernet_address) {
1784  if (ethernet_address != nullptr) {
1785  _has_bits_[0] |= 0x00000001u;
1786  } else {
1787  _has_bits_[0] &= ~0x00000001u;
1788  }
1789  ethernet_address_.SetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.get(), ethernet_address,
1790  GetArena());
1791  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.ethernet_address)
1792 }
1793 inline std::string* Socket::unsafe_arena_release_ethernet_address() {
1794  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.Socket.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(),
1798  GetArena());
1799 }
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;
1805  } else {
1806  _has_bits_[0] &= ~0x00000001u;
1807  }
1808  ethernet_address_.UnsafeArenaSetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_ethernet_address_.get(),
1809  ethernet_address, GetArena());
1810  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.Socket.ethernet_address)
1811 }
1812 
1813 // optional string multicast_address = 6 [default = "239.255.7.15", (.goby.field) = {
1814 inline bool Socket::_internal_has_multicast_address() const {
1815  bool value = (_has_bits_[0] & 0x00000002u) != 0;
1816  return value;
1817 }
1818 inline bool Socket::has_multicast_address() const {
1819  return _internal_has_multicast_address();
1820 }
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;
1824 }
1825 inline const std::string& Socket::multicast_address() const {
1826  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.multicast_address)
1827  return _internal_multicast_address();
1828 }
1829 inline void Socket::set_multicast_address(const std::string& value) {
1830  _internal_set_multicast_address(value);
1831  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.multicast_address)
1832 }
1833 inline std::string* Socket::mutable_multicast_address() {
1834  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.multicast_address)
1835  return _internal_mutable_multicast_address();
1836 }
1837 inline const std::string& Socket::_internal_multicast_address() const {
1838  return multicast_address_.Get();
1839 }
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());
1843 }
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());
1848  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.Socket.multicast_address)
1849 }
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),
1854  GetArena());
1855  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.Socket.multicast_address)
1856 }
1857 inline void Socket::set_multicast_address(const char* value,
1858  size_t size) {
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());
1862  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.Socket.multicast_address)
1863 }
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());
1867 }
1868 inline std::string* Socket::release_multicast_address() {
1869  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.multicast_address)
1870  if (!_internal_has_multicast_address()) {
1871  return nullptr;
1872  }
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());
1875 }
1876 inline void Socket::set_allocated_multicast_address(std::string* multicast_address) {
1877  if (multicast_address != nullptr) {
1878  _has_bits_[0] |= 0x00000002u;
1879  } else {
1880  _has_bits_[0] &= ~0x00000002u;
1881  }
1882  multicast_address_.SetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.get(), multicast_address,
1883  GetArena());
1884  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.multicast_address)
1885 }
1886 inline std::string* Socket::unsafe_arena_release_multicast_address() {
1887  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.Socket.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(),
1891  GetArena());
1892 }
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;
1898  } else {
1899  _has_bits_[0] &= ~0x00000002u;
1900  }
1901  multicast_address_.UnsafeArenaSetAllocated(&::goby::zeromq::protobuf::Socket::_i_give_permission_to_break_this_code_default_multicast_address_.get(),
1902  multicast_address, GetArena());
1903  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.Socket.multicast_address)
1904 }
1905 
1906 // optional uint32 ethernet_port = 7 [default = 11142];
1907 inline bool Socket::_internal_has_ethernet_port() const {
1908  bool value = (_has_bits_[0] & 0x00000080u) != 0;
1909  return value;
1910 }
1911 inline bool Socket::has_ethernet_port() const {
1912  return _internal_has_ethernet_port();
1913 }
1914 inline void Socket::clear_ethernet_port() {
1915  ethernet_port_ = 11142u;
1916  _has_bits_[0] &= ~0x00000080u;
1917 }
1918 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::_internal_ethernet_port() const {
1919  return ethernet_port_;
1920 }
1921 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::ethernet_port() const {
1922  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.ethernet_port)
1923  return _internal_ethernet_port();
1924 }
1925 inline void Socket::_internal_set_ethernet_port(::PROTOBUF_NAMESPACE_ID::uint32 value) {
1926  _has_bits_[0] |= 0x00000080u;
1927  ethernet_port_ = value;
1928 }
1929 inline void Socket::set_ethernet_port(::PROTOBUF_NAMESPACE_ID::uint32 value) {
1930  _internal_set_ethernet_port(value);
1931  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.ethernet_port)
1932 }
1933 
1934 // optional string socket_name = 8;
1935 inline bool Socket::_internal_has_socket_name() const {
1936  bool value = (_has_bits_[0] & 0x00000004u) != 0;
1937  return value;
1938 }
1939 inline bool Socket::has_socket_name() const {
1940  return _internal_has_socket_name();
1941 }
1942 inline void Socket::clear_socket_name() {
1943  socket_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1944  _has_bits_[0] &= ~0x00000004u;
1945 }
1946 inline const std::string& Socket::socket_name() const {
1947  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_name)
1948  return _internal_socket_name();
1949 }
1950 inline void Socket::set_socket_name(const std::string& value) {
1951  _internal_set_socket_name(value);
1952  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_name)
1953 }
1954 inline std::string* Socket::mutable_socket_name() {
1955  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.socket_name)
1956  return _internal_mutable_socket_name();
1957 }
1958 inline const std::string& Socket::_internal_socket_name() const {
1959  return socket_name_.Get();
1960 }
1961 inline void Socket::_internal_set_socket_name(const std::string& value) {
1962  _has_bits_[0] |= 0x00000004u;
1963  socket_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
1964 }
1965 inline void Socket::set_socket_name(std::string&& value) {
1966  _has_bits_[0] |= 0x00000004u;
1967  socket_name_.Set(
1968  &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
1969  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.Socket.socket_name)
1970 }
1971 inline void Socket::set_socket_name(const char* value) {
1972  GOOGLE_DCHECK(value != nullptr);
1973  _has_bits_[0] |= 0x00000004u;
1974  socket_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
1975  GetArena());
1976  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.Socket.socket_name)
1977 }
1978 inline void Socket::set_socket_name(const char* value,
1979  size_t size) {
1980  _has_bits_[0] |= 0x00000004u;
1981  socket_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
1982  reinterpret_cast<const char*>(value), size), GetArena());
1983  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.Socket.socket_name)
1984 }
1985 inline std::string* Socket::_internal_mutable_socket_name() {
1986  _has_bits_[0] |= 0x00000004u;
1987  return socket_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1988 }
1989 inline std::string* Socket::release_socket_name() {
1990  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.socket_name)
1991  if (!_internal_has_socket_name()) {
1992  return nullptr;
1993  }
1994  _has_bits_[0] &= ~0x00000004u;
1995  return socket_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
1996 }
1997 inline void Socket::set_allocated_socket_name(std::string* socket_name) {
1998  if (socket_name != nullptr) {
1999  _has_bits_[0] |= 0x00000004u;
2000  } else {
2001  _has_bits_[0] &= ~0x00000004u;
2002  }
2003  socket_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), socket_name,
2004  GetArena());
2005  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.socket_name)
2006 }
2007 inline std::string* Socket::unsafe_arena_release_socket_name() {
2008  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.Socket.socket_name)
2009  GOOGLE_DCHECK(GetArena() != nullptr);
2010  _has_bits_[0] &= ~0x00000004u;
2011  return socket_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2012  GetArena());
2013 }
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;
2019  } else {
2020  _has_bits_[0] &= ~0x00000004u;
2021  }
2022  socket_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2023  socket_name, GetArena());
2024  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.Socket.socket_name)
2025 }
2026 
2027 // optional uint32 send_queue_size = 10 [default = 1000];
2028 inline bool Socket::_internal_has_send_queue_size() const {
2029  bool value = (_has_bits_[0] & 0x00000100u) != 0;
2030  return value;
2031 }
2032 inline bool Socket::has_send_queue_size() const {
2033  return _internal_has_send_queue_size();
2034 }
2035 inline void Socket::clear_send_queue_size() {
2036  send_queue_size_ = 1000u;
2037  _has_bits_[0] &= ~0x00000100u;
2038 }
2039 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::_internal_send_queue_size() const {
2040  return send_queue_size_;
2041 }
2042 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::send_queue_size() const {
2043  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.send_queue_size)
2044  return _internal_send_queue_size();
2045 }
2046 inline void Socket::_internal_set_send_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value) {
2047  _has_bits_[0] |= 0x00000100u;
2048  send_queue_size_ = value;
2049 }
2050 inline void Socket::set_send_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value) {
2051  _internal_set_send_queue_size(value);
2052  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.send_queue_size)
2053 }
2054 
2055 // optional uint32 receive_queue_size = 11 [default = 1000];
2056 inline bool Socket::_internal_has_receive_queue_size() const {
2057  bool value = (_has_bits_[0] & 0x00000200u) != 0;
2058  return value;
2059 }
2060 inline bool Socket::has_receive_queue_size() const {
2061  return _internal_has_receive_queue_size();
2062 }
2063 inline void Socket::clear_receive_queue_size() {
2064  receive_queue_size_ = 1000u;
2065  _has_bits_[0] &= ~0x00000200u;
2066 }
2067 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::_internal_receive_queue_size() const {
2068  return receive_queue_size_;
2069 }
2070 inline ::PROTOBUF_NAMESPACE_ID::uint32 Socket::receive_queue_size() const {
2071  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.receive_queue_size)
2072  return _internal_receive_queue_size();
2073 }
2074 inline void Socket::_internal_set_receive_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value) {
2075  _has_bits_[0] |= 0x00000200u;
2076  receive_queue_size_ = value;
2077 }
2078 inline void Socket::set_receive_queue_size(::PROTOBUF_NAMESPACE_ID::uint32 value) {
2079  _internal_set_receive_queue_size(value);
2080  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.receive_queue_size)
2081 }
2082 
2083 // -------------------------------------------------------------------
2084 
2085 // ManagerResponse
2086 
2087 // required .goby.zeromq.protobuf.Request request = 1;
2088 inline bool ManagerResponse::_internal_has_request() const {
2089  bool value = (_has_bits_[0] & 0x00000010u) != 0;
2090  return value;
2091 }
2092 inline bool ManagerResponse::has_request() const {
2093  return _internal_has_request();
2094 }
2095 inline void ManagerResponse::clear_request() {
2096  request_ = 1;
2097  _has_bits_[0] &= ~0x00000010u;
2098 }
2099 inline ::goby::zeromq::protobuf::Request ManagerResponse::_internal_request() const {
2100  return static_cast< ::goby::zeromq::protobuf::Request >(request_);
2101 }
2102 inline ::goby::zeromq::protobuf::Request ManagerResponse::request() const {
2103  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.request)
2104  return _internal_request();
2105 }
2106 inline void ManagerResponse::_internal_set_request(::goby::zeromq::protobuf::Request value) {
2107  assert(::goby::zeromq::protobuf::Request_IsValid(value));
2108  _has_bits_[0] |= 0x00000010u;
2109  request_ = value;
2110 }
2111 inline void ManagerResponse::set_request(::goby::zeromq::protobuf::Request value) {
2112  _internal_set_request(value);
2113  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.request)
2114 }
2115 
2116 // required string client_name = 2;
2117 inline bool ManagerResponse::_internal_has_client_name() const {
2118  bool value = (_has_bits_[0] & 0x00000001u) != 0;
2119  return value;
2120 }
2121 inline bool ManagerResponse::has_client_name() const {
2122  return _internal_has_client_name();
2123 }
2124 inline void ManagerResponse::clear_client_name() {
2125  client_name_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2126  _has_bits_[0] &= ~0x00000001u;
2127 }
2128 inline const std::string& ManagerResponse::client_name() const {
2129  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.client_name)
2130  return _internal_client_name();
2131 }
2132 inline void ManagerResponse::set_client_name(const std::string& value) {
2133  _internal_set_client_name(value);
2134  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.client_name)
2135 }
2136 inline std::string* ManagerResponse::mutable_client_name() {
2137  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.client_name)
2138  return _internal_mutable_client_name();
2139 }
2140 inline const std::string& ManagerResponse::_internal_client_name() const {
2141  return client_name_.Get();
2142 }
2143 inline void ManagerResponse::_internal_set_client_name(const std::string& value) {
2144  _has_bits_[0] |= 0x00000001u;
2145  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
2146 }
2147 inline void ManagerResponse::set_client_name(std::string&& value) {
2148  _has_bits_[0] |= 0x00000001u;
2149  client_name_.Set(
2150  &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
2151  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.ManagerResponse.client_name)
2152 }
2153 inline void ManagerResponse::set_client_name(const char* value) {
2154  GOOGLE_DCHECK(value != nullptr);
2155  _has_bits_[0] |= 0x00000001u;
2156  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
2157  GetArena());
2158  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.ManagerResponse.client_name)
2159 }
2160 inline void ManagerResponse::set_client_name(const char* value,
2161  size_t size) {
2162  _has_bits_[0] |= 0x00000001u;
2163  client_name_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
2164  reinterpret_cast<const char*>(value), size), GetArena());
2165  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.ManagerResponse.client_name)
2166 }
2167 inline std::string* ManagerResponse::_internal_mutable_client_name() {
2168  _has_bits_[0] |= 0x00000001u;
2169  return client_name_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2170 }
2171 inline std::string* ManagerResponse::release_client_name() {
2172  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.client_name)
2173  if (!_internal_has_client_name()) {
2174  return nullptr;
2175  }
2176  _has_bits_[0] &= ~0x00000001u;
2177  return client_name_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2178 }
2179 inline void ManagerResponse::set_allocated_client_name(std::string* client_name) {
2180  if (client_name != nullptr) {
2181  _has_bits_[0] |= 0x00000001u;
2182  } else {
2183  _has_bits_[0] &= ~0x00000001u;
2184  }
2185  client_name_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), client_name,
2186  GetArena());
2187  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.client_name)
2188 }
2189 inline std::string* ManagerResponse::unsafe_arena_release_client_name() {
2190  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.ManagerResponse.client_name)
2191  GOOGLE_DCHECK(GetArena() != nullptr);
2192  _has_bits_[0] &= ~0x00000001u;
2193  return client_name_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2194  GetArena());
2195 }
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;
2201  } else {
2202  _has_bits_[0] &= ~0x00000001u;
2203  }
2204  client_name_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2205  client_name, GetArena());
2206  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerResponse.client_name)
2207 }
2208 
2209 // required int32 client_pid = 3;
2210 inline bool ManagerResponse::_internal_has_client_pid() const {
2211  bool value = (_has_bits_[0] & 0x00000008u) != 0;
2212  return value;
2213 }
2214 inline bool ManagerResponse::has_client_pid() const {
2215  return _internal_has_client_pid();
2216 }
2217 inline void ManagerResponse::clear_client_pid() {
2218  client_pid_ = 0;
2219  _has_bits_[0] &= ~0x00000008u;
2220 }
2221 inline ::PROTOBUF_NAMESPACE_ID::int32 ManagerResponse::_internal_client_pid() const {
2222  return client_pid_;
2223 }
2224 inline ::PROTOBUF_NAMESPACE_ID::int32 ManagerResponse::client_pid() const {
2225  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.client_pid)
2226  return _internal_client_pid();
2227 }
2228 inline void ManagerResponse::_internal_set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value) {
2229  _has_bits_[0] |= 0x00000008u;
2230  client_pid_ = value;
2231 }
2232 inline void ManagerResponse::set_client_pid(::PROTOBUF_NAMESPACE_ID::int32 value) {
2233  _internal_set_client_pid(value);
2234  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.client_pid)
2235 }
2236 
2237 // optional .goby.zeromq.protobuf.Socket publish_socket = 4;
2238 inline bool ManagerResponse::_internal_has_publish_socket() const {
2239  bool value = (_has_bits_[0] & 0x00000002u) != 0;
2240  PROTOBUF_ASSUME(!value || publish_socket_ != nullptr);
2241  return value;
2242 }
2243 inline bool ManagerResponse::has_publish_socket() const {
2244  return _internal_has_publish_socket();
2245 }
2246 inline void ManagerResponse::clear_publish_socket() {
2247  if (publish_socket_ != nullptr) publish_socket_->Clear();
2248  _has_bits_[0] &= ~0x00000002u;
2249 }
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*>(
2254 }
2255 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::publish_socket() const {
2256  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2257  return _internal_publish_socket();
2258 }
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_);
2263  }
2264  publish_socket_ = publish_socket;
2265  if (publish_socket) {
2266  _has_bits_[0] |= 0x00000002u;
2267  } else {
2268  _has_bits_[0] &= ~0x00000002u;
2269  }
2270  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2271 }
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);
2276  }
2277  return temp;
2278 }
2279 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_publish_socket() {
2280  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2281  _has_bits_[0] &= ~0x00000002u;
2282  ::goby::zeromq::protobuf::Socket* temp = publish_socket_;
2283  publish_socket_ = nullptr;
2284  return temp;
2285 }
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;
2291  }
2292  return publish_socket_;
2293 }
2294 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_publish_socket() {
2295  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2296  return _internal_mutable_publish_socket();
2297 }
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_;
2302  }
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);
2309  }
2310  _has_bits_[0] |= 0x00000002u;
2311  } else {
2312  _has_bits_[0] &= ~0x00000002u;
2313  }
2314  publish_socket_ = publish_socket;
2315  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2316 }
2317 
2318 // optional .goby.zeromq.protobuf.Socket subscribe_socket = 5;
2319 inline bool ManagerResponse::_internal_has_subscribe_socket() const {
2320  bool value = (_has_bits_[0] & 0x00000004u) != 0;
2321  PROTOBUF_ASSUME(!value || subscribe_socket_ != nullptr);
2322  return value;
2323 }
2324 inline bool ManagerResponse::has_subscribe_socket() const {
2325  return _internal_has_subscribe_socket();
2326 }
2327 inline void ManagerResponse::clear_subscribe_socket() {
2328  if (subscribe_socket_ != nullptr) subscribe_socket_->Clear();
2329  _has_bits_[0] &= ~0x00000004u;
2330 }
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*>(
2335 }
2336 inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::subscribe_socket() const {
2337  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2338  return _internal_subscribe_socket();
2339 }
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_);
2344  }
2345  subscribe_socket_ = subscribe_socket;
2346  if (subscribe_socket) {
2347  _has_bits_[0] |= 0x00000004u;
2348  } else {
2349  _has_bits_[0] &= ~0x00000004u;
2350  }
2351  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2352 }
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);
2357  }
2358  return temp;
2359 }
2360 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_subscribe_socket() {
2361  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2362  _has_bits_[0] &= ~0x00000004u;
2363  ::goby::zeromq::protobuf::Socket* temp = subscribe_socket_;
2364  subscribe_socket_ = nullptr;
2365  return temp;
2366 }
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;
2372  }
2373  return subscribe_socket_;
2374 }
2375 inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_subscribe_socket() {
2376  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2377  return _internal_mutable_subscribe_socket();
2378 }
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_;
2383  }
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);
2390  }
2391  _has_bits_[0] |= 0x00000004u;
2392  } else {
2393  _has_bits_[0] &= ~0x00000004u;
2394  }
2395  subscribe_socket_ = subscribe_socket;
2396  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2397 }
2398 
2399 // optional bool hold = 6 [default = true, (.goby.field) = {
2400 inline bool ManagerResponse::_internal_has_hold() const {
2401  bool value = (_has_bits_[0] & 0x00000020u) != 0;
2402  return value;
2403 }
2404 inline bool ManagerResponse::has_hold() const {
2405  return _internal_has_hold();
2406 }
2407 inline void ManagerResponse::clear_hold() {
2408  hold_ = true;
2409  _has_bits_[0] &= ~0x00000020u;
2410 }
2411 inline bool ManagerResponse::_internal_hold() const {
2412  return hold_;
2413 }
2414 inline bool ManagerResponse::hold() const {
2415  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.hold)
2416  return _internal_hold();
2417 }
2418 inline void ManagerResponse::_internal_set_hold(bool value) {
2419  _has_bits_[0] |= 0x00000020u;
2420  hold_ = value;
2421 }
2422 inline void ManagerResponse::set_hold(bool value) {
2423  _internal_set_hold(value);
2424  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.hold)
2425 }
2426 
2427 // -------------------------------------------------------------------
2428 
2429 // InprocControl
2430 
2431 // required .goby.zeromq.protobuf.InprocControl.InprocControlType type = 1;
2432 inline bool InprocControl::_internal_has_type() const {
2433  bool value = (_has_bits_[0] & 0x00000010u) != 0;
2434  return value;
2435 }
2436 inline bool InprocControl::has_type() const {
2437  return _internal_has_type();
2438 }
2439 inline void InprocControl::clear_type() {
2440  type_ = 1;
2441  _has_bits_[0] &= ~0x00000010u;
2442 }
2443 inline ::goby::zeromq::protobuf::InprocControl_InprocControlType InprocControl::_internal_type() const {
2444  return static_cast< ::goby::zeromq::protobuf::InprocControl_InprocControlType >(type_);
2445 }
2447  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.type)
2448  return _internal_type();
2449 }
2450 inline void InprocControl::_internal_set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value) {
2452  _has_bits_[0] |= 0x00000010u;
2453  type_ = value;
2454 }
2455 inline void InprocControl::set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value) {
2456  _internal_set_type(value);
2457  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.type)
2458 }
2459 
2460 // optional .goby.zeromq.protobuf.Socket publish_socket = 2;
2461 inline bool InprocControl::_internal_has_publish_socket() const {
2462  bool value = (_has_bits_[0] & 0x00000004u) != 0;
2463  PROTOBUF_ASSUME(!value || publish_socket_ != nullptr);
2464  return value;
2465 }
2466 inline bool InprocControl::has_publish_socket() const {
2467  return _internal_has_publish_socket();
2468 }
2469 inline void InprocControl::clear_publish_socket() {
2470  if (publish_socket_ != nullptr) publish_socket_->Clear();
2471  _has_bits_[0] &= ~0x00000004u;
2472 }
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*>(
2477 }
2478 inline const ::goby::zeromq::protobuf::Socket& InprocControl::publish_socket() const {
2479  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.publish_socket)
2480  return _internal_publish_socket();
2481 }
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_);
2486  }
2487  publish_socket_ = publish_socket;
2488  if (publish_socket) {
2489  _has_bits_[0] |= 0x00000004u;
2490  } else {
2491  _has_bits_[0] &= ~0x00000004u;
2492  }
2493  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.InprocControl.publish_socket)
2494 }
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);
2499  }
2500  return temp;
2501 }
2502 inline ::goby::zeromq::protobuf::Socket* InprocControl::unsafe_arena_release_publish_socket() {
2503  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.publish_socket)
2504  _has_bits_[0] &= ~0x00000004u;
2505  ::goby::zeromq::protobuf::Socket* temp = publish_socket_;
2506  publish_socket_ = nullptr;
2507  return temp;
2508 }
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;
2514  }
2515  return publish_socket_;
2516 }
2517 inline ::goby::zeromq::protobuf::Socket* InprocControl::mutable_publish_socket() {
2518  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.publish_socket)
2519  return _internal_mutable_publish_socket();
2520 }
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_;
2525  }
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);
2532  }
2533  _has_bits_[0] |= 0x00000004u;
2534  } else {
2535  _has_bits_[0] &= ~0x00000004u;
2536  }
2537  publish_socket_ = publish_socket;
2538  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.publish_socket)
2539 }
2540 
2541 // optional bytes subscription_identifier = 3;
2542 inline bool InprocControl::_internal_has_subscription_identifier() const {
2543  bool value = (_has_bits_[0] & 0x00000001u) != 0;
2544  return value;
2545 }
2546 inline bool InprocControl::has_subscription_identifier() const {
2547  return _internal_has_subscription_identifier();
2548 }
2549 inline void InprocControl::clear_subscription_identifier() {
2550  subscription_identifier_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2551  _has_bits_[0] &= ~0x00000001u;
2552 }
2553 inline const std::string& InprocControl::subscription_identifier() const {
2554  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2555  return _internal_subscription_identifier();
2556 }
2557 inline void InprocControl::set_subscription_identifier(const std::string& value) {
2558  _internal_set_subscription_identifier(value);
2559  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2560 }
2561 inline std::string* InprocControl::mutable_subscription_identifier() {
2562  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2563  return _internal_mutable_subscription_identifier();
2564 }
2565 inline const std::string& InprocControl::_internal_subscription_identifier() const {
2566  return subscription_identifier_.Get();
2567 }
2568 inline void InprocControl::_internal_set_subscription_identifier(const std::string& value) {
2569  _has_bits_[0] |= 0x00000001u;
2570  subscription_identifier_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
2571 }
2572 inline void InprocControl::set_subscription_identifier(std::string&& value) {
2573  _has_bits_[0] |= 0x00000001u;
2574  subscription_identifier_.Set(
2575  &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
2576  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2577 }
2578 inline void InprocControl::set_subscription_identifier(const char* value) {
2579  GOOGLE_DCHECK(value != nullptr);
2580  _has_bits_[0] |= 0x00000001u;
2581  subscription_identifier_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
2582  GetArena());
2583  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2584 }
2585 inline void InprocControl::set_subscription_identifier(const void* value,
2586  size_t size) {
2587  _has_bits_[0] |= 0x00000001u;
2588  subscription_identifier_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
2589  reinterpret_cast<const char*>(value), size), GetArena());
2590  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2591 }
2592 inline std::string* InprocControl::_internal_mutable_subscription_identifier() {
2593  _has_bits_[0] |= 0x00000001u;
2594  return subscription_identifier_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2595 }
2596 inline std::string* InprocControl::release_subscription_identifier() {
2597  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2598  if (!_internal_has_subscription_identifier()) {
2599  return nullptr;
2600  }
2601  _has_bits_[0] &= ~0x00000001u;
2602  return subscription_identifier_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2603 }
2604 inline void InprocControl::set_allocated_subscription_identifier(std::string* subscription_identifier) {
2605  if (subscription_identifier != nullptr) {
2606  _has_bits_[0] |= 0x00000001u;
2607  } else {
2608  _has_bits_[0] &= ~0x00000001u;
2609  }
2610  subscription_identifier_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), subscription_identifier,
2611  GetArena());
2612  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2613 }
2614 inline std::string* InprocControl::unsafe_arena_release_subscription_identifier() {
2615  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2616  GOOGLE_DCHECK(GetArena() != nullptr);
2617  _has_bits_[0] &= ~0x00000001u;
2618  return subscription_identifier_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2619  GetArena());
2620 }
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;
2626  } else {
2627  _has_bits_[0] &= ~0x00000001u;
2628  }
2629  subscription_identifier_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2630  subscription_identifier, GetArena());
2631  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2632 }
2633 
2634 // optional bytes received_data = 4;
2635 inline bool InprocControl::_internal_has_received_data() const {
2636  bool value = (_has_bits_[0] & 0x00000002u) != 0;
2637  return value;
2638 }
2639 inline bool InprocControl::has_received_data() const {
2640  return _internal_has_received_data();
2641 }
2642 inline void InprocControl::clear_received_data() {
2643  received_data_.ClearToEmpty(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2644  _has_bits_[0] &= ~0x00000002u;
2645 }
2646 inline const std::string& InprocControl::received_data() const {
2647  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.received_data)
2648  return _internal_received_data();
2649 }
2650 inline void InprocControl::set_received_data(const std::string& value) {
2651  _internal_set_received_data(value);
2652  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.received_data)
2653 }
2654 inline std::string* InprocControl::mutable_received_data() {
2655  // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.received_data)
2656  return _internal_mutable_received_data();
2657 }
2658 inline const std::string& InprocControl::_internal_received_data() const {
2659  return received_data_.Get();
2660 }
2661 inline void InprocControl::_internal_set_received_data(const std::string& value) {
2662  _has_bits_[0] |= 0x00000002u;
2663  received_data_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), value, GetArena());
2664 }
2665 inline void InprocControl::set_received_data(std::string&& value) {
2666  _has_bits_[0] |= 0x00000002u;
2667  received_data_.Set(
2668  &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::move(value), GetArena());
2669  // @@protoc_insertion_point(field_set_rvalue:goby.zeromq.protobuf.InprocControl.received_data)
2670 }
2671 inline void InprocControl::set_received_data(const char* value) {
2672  GOOGLE_DCHECK(value != nullptr);
2673  _has_bits_[0] |= 0x00000002u;
2674  received_data_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(value),
2675  GetArena());
2676  // @@protoc_insertion_point(field_set_char:goby.zeromq.protobuf.InprocControl.received_data)
2677 }
2678 inline void InprocControl::set_received_data(const void* value,
2679  size_t size) {
2680  _has_bits_[0] |= 0x00000002u;
2681  received_data_.Set(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), ::std::string(
2682  reinterpret_cast<const char*>(value), size), GetArena());
2683  // @@protoc_insertion_point(field_set_pointer:goby.zeromq.protobuf.InprocControl.received_data)
2684 }
2685 inline std::string* InprocControl::_internal_mutable_received_data() {
2686  _has_bits_[0] |= 0x00000002u;
2687  return received_data_.Mutable(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2688 }
2689 inline std::string* InprocControl::release_received_data() {
2690  // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.received_data)
2691  if (!_internal_has_received_data()) {
2692  return nullptr;
2693  }
2694  _has_bits_[0] &= ~0x00000002u;
2695  return received_data_.ReleaseNonDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena());
2696 }
2697 inline void InprocControl::set_allocated_received_data(std::string* received_data) {
2698  if (received_data != nullptr) {
2699  _has_bits_[0] |= 0x00000002u;
2700  } else {
2701  _has_bits_[0] &= ~0x00000002u;
2702  }
2703  received_data_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), received_data,
2704  GetArena());
2705  // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.received_data)
2706 }
2707 inline std::string* InprocControl::unsafe_arena_release_received_data() {
2708  // @@protoc_insertion_point(field_unsafe_arena_release:goby.zeromq.protobuf.InprocControl.received_data)
2709  GOOGLE_DCHECK(GetArena() != nullptr);
2710  _has_bits_[0] &= ~0x00000002u;
2711  return received_data_.UnsafeArenaRelease(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2712  GetArena());
2713 }
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;
2719  } else {
2720  _has_bits_[0] &= ~0x00000002u;
2721  }
2722  received_data_.UnsafeArenaSetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
2723  received_data, GetArena());
2724  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.InprocControl.received_data)
2725 }
2726 
2727 // optional bool hold = 10;
2728 inline bool InprocControl::_internal_has_hold() const {
2729  bool value = (_has_bits_[0] & 0x00000008u) != 0;
2730  return value;
2731 }
2732 inline bool InprocControl::has_hold() const {
2733  return _internal_has_hold();
2734 }
2735 inline void InprocControl::clear_hold() {
2736  hold_ = false;
2737  _has_bits_[0] &= ~0x00000008u;
2738 }
2739 inline bool InprocControl::_internal_hold() const {
2740  return hold_;
2741 }
2742 inline bool InprocControl::hold() const {
2743  // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.hold)
2744  return _internal_hold();
2745 }
2746 inline void InprocControl::_internal_set_hold(bool value) {
2747  _has_bits_[0] |= 0x00000008u;
2748  hold_ = value;
2749 }
2750 inline void InprocControl::set_hold(bool value) {
2751  _internal_set_hold(value);
2752  // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.hold)
2753 }
2754 
2755 #ifdef __GNUC__
2756  #pragma GCC diagnostic pop
2757 #endif // __GNUC__
2758 // -------------------------------------------------------------------
2759 
2760 // -------------------------------------------------------------------
2761 
2762 // -------------------------------------------------------------------
2763 
2764 
2765 // @@protoc_insertion_point(namespace_scope)
2766 
2767 } // namespace protobuf
2768 } // namespace zeromq
2769 } // namespace goby
2770 
2771 PROTOBUF_NAMESPACE_OPEN
2772 
2773 template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_SocketType> : ::std::true_type {};
2774 template <>
2775 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType>() {
2777 }
2778 template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_Transport> : ::std::true_type {};
2779 template <>
2780 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport>() {
2782 }
2783 template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_ConnectOrBind> : ::std::true_type {};
2784 template <>
2785 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind>() {
2787 }
2788 template <> struct is_proto_enum< ::goby::zeromq::protobuf::InprocControl_InprocControlType> : ::std::true_type {};
2789 template <>
2790 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType>() {
2792 }
2793 template <> struct is_proto_enum< ::goby::zeromq::protobuf::Request> : ::std::true_type {};
2794 template <>
2795 inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Request>() {
2797 }
2798 
2799 PROTOBUF_NAMESPACE_CLOSE
2800 
2801 // @@protoc_insertion_point(global_scope)
2802 
2803 #include <google/protobuf/port_undef.inc>
2804 #endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
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)
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
ManagerResponse(const ManagerResponse &from)
void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message &from) final
void set_allocated_ethernet_address(std::string *ethernet_address)
void CopyFrom(const Socket &from)
static const ManagerRequest * internal_default_instance()
void CopyFrom(const ManagerResponse &from)
static bool InprocControlType_Parse(const std::string &name, InprocControlType *value)
void CopyFrom(const ManagerRequest &from)
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)
void set_subscription_identifier(const char *value)
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)
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 ::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
void set_client_name(const char *value)
static const Socket & default_instance()
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * ConnectOrBind_descriptor()
void set_subscription_identifier(std::string &&value)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * SocketType_descriptor()
ManagerResponse(ManagerResponse &&from) noexcept
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
const std::string & client_name() const
void set_ethernet_address(const char *value)
InprocControl(const InprocControl &from)
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControlType_descriptor()
ManagerRequest * New(::PROTOBUF_NAMESPACE_ID::Arena *arena) 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 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
InprocControl(InprocControl &&from) noexcept
friend void swap(Socket &a, Socket &b)
void set_subscription_identifier(const std::string &value)
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
void set_ethernet_address(const std::string &value)
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())
Definition: json.hpp:5271
constexpr Socket_SocketType Socket_SocketType_SocketType_MIN
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)
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_Transport_descriptor()
const std::string & Socket_SocketType_Name(T enum_t_value)
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)
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_SocketType_descriptor()
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MAX
ManagerResponseDefaultTypeInternal _ManagerResponse_default_instance_
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Request_descriptor()
bool InprocControl_InprocControlType_Parse(const std::string &name, InprocControl_InprocControlType *value)
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)
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.
std::int32_t int32
std::uint32_t uint32
PROTOBUF_EXPORT const std::string & GetEmptyStringAlreadyInited()
Definition: message_lite.h:154
type
Generic JSON types used in JWTs.
Definition: jwt.h:2072
#define ByteSizeLong
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)