Goby3 3.5.1
2026.06.04
Loading...
Searching...
No Matches
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 < 3021000
12#error This file was generated by a newer version of protoc which is
13#error incompatible with your Protocol Buffer headers. Please update
14#error your headers.
15#endif
16#if 3021012 < PROTOBUF_MIN_PROTOC_VERSION
17#error This file was generated by an older version of protoc which is
18#error incompatible with your Protocol Buffer headers. Please
19#error regenerate this file with a newer version of protoc.
20#endif
21
22#include <google/protobuf/port_undef.inc>
23#include <google/protobuf/io/coded_stream.h>
24#include <google/protobuf/arena.h>
25#include <google/protobuf/arenastring.h>
26#include <google/protobuf/generated_message_util.h>
27#include <google/protobuf/metadata_lite.h>
28#include <google/protobuf/generated_message_reflection.h>
29#include <google/protobuf/message.h>
30#include <google/protobuf/repeated_field.h> // IWYU pragma: export
31#include <google/protobuf/extension_set.h> // IWYU pragma: export
32#include <google/protobuf/generated_enum_reflection.h>
33#include <google/protobuf/unknown_field_set.h>
34#include "goby/protobuf/option_extensions.pb.h"
35#include <boost/units/quantity.hpp>
36#include <boost/units/absolute.hpp>
37#include <boost/units/dimensionless_type.hpp>
38#include <boost/units/make_scaled_unit.hpp>
39// @@protoc_insertion_point(includes)
40#include <google/protobuf/port_def.inc>
41#define PROTOBUF_INTERNAL_EXPORT_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
42PROTOBUF_NAMESPACE_OPEN
43namespace internal {
44class AnyMetadata;
45} // namespace internal
46PROTOBUF_NAMESPACE_CLOSE
47
48// Internal implementation detail -- do not use these members.
52extern const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
53namespace goby {
54namespace zeromq {
55namespace protobuf {
56class InprocControl;
57struct InprocControlDefaultTypeInternal;
58extern InprocControlDefaultTypeInternal _InprocControl_default_instance_;
59class ManagerRequest;
60struct ManagerRequestDefaultTypeInternal;
61extern ManagerRequestDefaultTypeInternal _ManagerRequest_default_instance_;
62class ManagerResponse;
63struct ManagerResponseDefaultTypeInternal;
64extern ManagerResponseDefaultTypeInternal _ManagerResponse_default_instance_;
65class Socket;
66struct SocketDefaultTypeInternal;
67extern SocketDefaultTypeInternal _Socket_default_instance_;
68} // namespace protobuf
69} // namespace zeromq
70} // namespace goby
71PROTOBUF_NAMESPACE_OPEN
72template<> ::goby::zeromq::protobuf::InprocControl* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::InprocControl>(Arena*);
73template<> ::goby::zeromq::protobuf::ManagerRequest* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::ManagerRequest>(Arena*);
74template<> ::goby::zeromq::protobuf::ManagerResponse* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::ManagerResponse>(Arena*);
75template<> ::goby::zeromq::protobuf::Socket* Arena::CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(Arena*);
76PROTOBUF_NAMESPACE_CLOSE
77namespace goby {
78namespace zeromq {
79namespace protobuf {
80
87bool Socket_SocketType_IsValid(int value);
88constexpr Socket_SocketType Socket_SocketType_SocketType_MIN = Socket_SocketType_PUBLISH;
89constexpr Socket_SocketType Socket_SocketType_SocketType_MAX = Socket_SocketType_REQUEST;
90constexpr int Socket_SocketType_SocketType_ARRAYSIZE = Socket_SocketType_SocketType_MAX + 1;
91
92const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_SocketType_descriptor();
93template<typename T>
94inline const std::string& Socket_SocketType_Name(T enum_t_value) {
95 static_assert(::std::is_same<T, Socket_SocketType>::value ||
96 ::std::is_integral<T>::value,
97 "Incorrect type passed to function Socket_SocketType_Name.");
98 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
99 Socket_SocketType_descriptor(), enum_t_value);
100}
101inline bool Socket_SocketType_Parse(
102 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_SocketType* value) {
103 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_SocketType>(
104 Socket_SocketType_descriptor(), name, value);
105}
113bool Socket_Transport_IsValid(int value);
114constexpr Socket_Transport Socket_Transport_Transport_MIN = Socket_Transport_INPROC;
115constexpr Socket_Transport Socket_Transport_Transport_MAX = Socket_Transport_EPGM;
116constexpr int Socket_Transport_Transport_ARRAYSIZE = Socket_Transport_Transport_MAX + 1;
117
118const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_Transport_descriptor();
119template<typename T>
120inline const std::string& Socket_Transport_Name(T enum_t_value) {
121 static_assert(::std::is_same<T, Socket_Transport>::value ||
122 ::std::is_integral<T>::value,
123 "Incorrect type passed to function Socket_Transport_Name.");
124 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
125 Socket_Transport_descriptor(), enum_t_value);
126}
127inline bool Socket_Transport_Parse(
128 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_Transport* value) {
129 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_Transport>(
130 Socket_Transport_descriptor(), name, value);
131}
136bool Socket_ConnectOrBind_IsValid(int value);
137constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MIN = Socket_ConnectOrBind_CONNECT;
138constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MAX = Socket_ConnectOrBind_BIND;
139constexpr int Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE = Socket_ConnectOrBind_ConnectOrBind_MAX + 1;
140
141const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Socket_ConnectOrBind_descriptor();
142template<typename T>
143inline const std::string& Socket_ConnectOrBind_Name(T enum_t_value) {
144 static_assert(::std::is_same<T, Socket_ConnectOrBind>::value ||
145 ::std::is_integral<T>::value,
146 "Incorrect type passed to function Socket_ConnectOrBind_Name.");
147 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
148 Socket_ConnectOrBind_descriptor(), enum_t_value);
149}
150inline bool Socket_ConnectOrBind_Parse(
151 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_ConnectOrBind* value) {
152 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Socket_ConnectOrBind>(
153 Socket_ConnectOrBind_descriptor(), name, value);
154}
166bool InprocControl_InprocControlType_IsValid(int value);
167constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MIN = InprocControl_InprocControlType_PUB_CONFIGURATION;
168constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MAX = InprocControl_InprocControlType_NOTIFY_HOLD_STATE;
169constexpr int InprocControl_InprocControlType_InprocControlType_ARRAYSIZE = InprocControl_InprocControlType_InprocControlType_MAX + 1;
170
171const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* InprocControl_InprocControlType_descriptor();
172template<typename T>
173inline const std::string& InprocControl_InprocControlType_Name(T enum_t_value) {
174 static_assert(::std::is_same<T, InprocControl_InprocControlType>::value ||
175 ::std::is_integral<T>::value,
176 "Incorrect type passed to function InprocControl_InprocControlType_Name.");
177 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
178 InprocControl_InprocControlType_descriptor(), enum_t_value);
179}
180inline bool InprocControl_InprocControlType_Parse(
181 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, InprocControl_InprocControlType* value) {
182 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<InprocControl_InprocControlType>(
183 InprocControl_InprocControlType_descriptor(), name, value);
184}
189bool Request_IsValid(int value);
190constexpr Request Request_MIN = PROVIDE_PUB_SUB_SOCKETS;
191constexpr Request Request_MAX = PROVIDE_HOLD_STATE;
192constexpr int Request_ARRAYSIZE = Request_MAX + 1;
193
194const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* Request_descriptor();
195template<typename T>
196inline const std::string& Request_Name(T enum_t_value) {
197 static_assert(::std::is_same<T, Request>::value ||
198 ::std::is_integral<T>::value,
199 "Incorrect type passed to function Request_Name.");
200 return ::PROTOBUF_NAMESPACE_ID::internal::NameOfEnum(
201 Request_descriptor(), enum_t_value);
202}
203inline bool Request_Parse(
204 ::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Request* value) {
205 return ::PROTOBUF_NAMESPACE_ID::internal::ParseNamedEnum<Request>(
206 Request_descriptor(), name, value);
207}
208// ===================================================================
209
210class ManagerRequest final :
211 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.ManagerRequest) */ {
212 public:
213 inline ManagerRequest() : ManagerRequest(nullptr) {}
214 ~ManagerRequest() override;
215 explicit PROTOBUF_CONSTEXPR ManagerRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
216
217 ManagerRequest(const ManagerRequest& from);
218 ManagerRequest(ManagerRequest&& from) noexcept
219 : ManagerRequest() {
220 *this = ::std::move(from);
221 }
222
223 inline ManagerRequest& operator=(const ManagerRequest& from) {
224 CopyFrom(from);
225 return *this;
226 }
227 inline ManagerRequest& operator=(ManagerRequest&& from) noexcept {
228 if (this == &from) return *this;
229 if (GetOwningArena() == from.GetOwningArena()
230 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
231 && GetOwningArena() != nullptr
232 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
233 ) {
234 InternalSwap(&from);
235 } else {
236 CopyFrom(from);
237 }
238 return *this;
239 }
240
241 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
242 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
243 }
244 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
245 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
246 }
247
248 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
249 return GetDescriptor();
250 }
251 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
252 return default_instance().GetMetadata().descriptor;
253 }
254 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
255 return default_instance().GetMetadata().reflection;
256 }
257 static const ManagerRequest& default_instance() {
258 return *internal_default_instance();
259 }
260 static inline const ManagerRequest* internal_default_instance() {
261 return reinterpret_cast<const ManagerRequest*>(
262 &_ManagerRequest_default_instance_);
263 }
264 static constexpr int kIndexInFileMessages =
265 0;
266
267 friend void swap(ManagerRequest& a, ManagerRequest& b) {
268 a.Swap(&b);
269 }
270 inline void Swap(ManagerRequest* other) {
271 if (other == this) return;
272 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
273 if (GetOwningArena() != nullptr &&
274 GetOwningArena() == other->GetOwningArena()) {
275 #else // PROTOBUF_FORCE_COPY_IN_SWAP
276 if (GetOwningArena() == other->GetOwningArena()) {
277 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
278 InternalSwap(other);
279 } else {
280 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
281 }
282 }
283 void UnsafeArenaSwap(ManagerRequest* other) {
284 if (other == this) return;
285 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
286 InternalSwap(other);
287 }
288
289 // implements Message ----------------------------------------------
290
291 ManagerRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
292 return CreateMaybeMessage<ManagerRequest>(arena);
293 }
294 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
295 void CopyFrom(const ManagerRequest& from);
296 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
297 void MergeFrom( const ManagerRequest& from) {
298 ManagerRequest::MergeImpl(*this, from);
299 }
300 private:
301 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
302 public:
303 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
304 bool IsInitialized() const final;
305
306 size_t ByteSizeLong() const final;
307 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
308 uint8_t* _InternalSerialize(
309 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
310 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
311
312 private:
313 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
314 void SharedDtor();
315 void SetCachedSize(int size) const final;
316 void InternalSwap(ManagerRequest* other);
317
318 private:
319 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
320 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
321 return "goby.zeromq.protobuf.ManagerRequest";
322 }
323 protected:
324 explicit ManagerRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
325 bool is_message_owned = false);
326 public:
327
328 static const ClassData _class_data_;
329 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
330
331 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
332
333 // nested types ----------------------------------------------------
334
335 // accessors -------------------------------------------------------
336
337 enum : int {
338 kClientNameFieldNumber = 2,
339 kClientPidFieldNumber = 3,
340 kReadyFieldNumber = 4,
341 kRequestFieldNumber = 1,
342 };
343 // required string client_name = 2 [(.goby.field) = {
344 bool has_client_name() const;
345 private:
346 bool _internal_has_client_name() const;
347 public:
348 void clear_client_name();
349 const std::string& client_name() const;
350 template <typename ArgT0 = const std::string&, typename... ArgT>
351 void set_client_name(ArgT0&& arg0, ArgT... args);
352 std::string* mutable_client_name();
353 PROTOBUF_NODISCARD std::string* release_client_name();
354 void set_allocated_client_name(std::string* client_name);
355 private:
356 const std::string& _internal_client_name() const;
357 inline PROTOBUF_ALWAYS_INLINE void _internal_set_client_name(const std::string& value);
358 std::string* _internal_mutable_client_name();
359 public:
360
361 // required int32 client_pid = 3 [(.goby.field) = {
362 bool has_client_pid() const;
363 private:
364 bool _internal_has_client_pid() const;
365 public:
366 void clear_client_pid();
367 int32_t client_pid() const;
368 void set_client_pid(int32_t value);
369 private:
370 int32_t _internal_client_pid() const;
371 void _internal_set_client_pid(int32_t value);
372 public:
373
374 // optional bool ready = 4 [default = false, (.goby.field) = {
375 bool has_ready() const;
376 private:
377 bool _internal_has_ready() const;
378 public:
379 void clear_ready();
380 bool ready() const;
381 void set_ready(bool value);
382 private:
383 bool _internal_ready() const;
384 void _internal_set_ready(bool value);
385 public:
386
387 // required .goby.zeromq.protobuf.Request request = 1 [(.goby.field) = {
388 bool has_request() const;
389 private:
390 bool _internal_has_request() const;
391 public:
392 void clear_request();
393 ::goby::zeromq::protobuf::Request request() const;
394 void set_request(::goby::zeromq::protobuf::Request value);
395 private:
396 ::goby::zeromq::protobuf::Request _internal_request() const;
397 void _internal_set_request(::goby::zeromq::protobuf::Request value);
398 public:
399
400 // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.ManagerRequest)
401 private:
402 class _Internal;
403
404 // helper for ByteSizeLong()
405 size_t RequiredFieldsByteSizeFallback() const;
406
407 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
408 typedef void InternalArenaConstructable_;
409 typedef void DestructorSkippable_;
410 struct Impl_ {
411 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
412 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
413 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_name_;
414 int32_t client_pid_;
415 bool ready_;
416 int request_;
417 };
418 union { Impl_ _impl_; };
419 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
420};
421// -------------------------------------------------------------------
422
423class Socket final :
424 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.Socket) */ {
425 public:
426 inline Socket() : Socket(nullptr) {}
427 ~Socket() override;
428 explicit PROTOBUF_CONSTEXPR Socket(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
429
430 Socket(const Socket& from);
431 Socket(Socket&& from) noexcept
432 : Socket() {
433 *this = ::std::move(from);
434 }
435
436 inline Socket& operator=(const Socket& from) {
437 CopyFrom(from);
438 return *this;
439 }
440 inline Socket& operator=(Socket&& from) noexcept {
441 if (this == &from) return *this;
442 if (GetOwningArena() == from.GetOwningArena()
443 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
444 && GetOwningArena() != nullptr
445 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
446 ) {
447 InternalSwap(&from);
448 } else {
449 CopyFrom(from);
450 }
451 return *this;
452 }
453
454 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
455 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
456 }
457 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
458 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
459 }
460
461 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
462 return GetDescriptor();
463 }
464 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
465 return default_instance().GetMetadata().descriptor;
466 }
467 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
468 return default_instance().GetMetadata().reflection;
469 }
470 static const Socket& default_instance() {
471 return *internal_default_instance();
472 }
473 static inline const Socket* internal_default_instance() {
474 return reinterpret_cast<const Socket*>(
475 &_Socket_default_instance_);
476 }
477 static constexpr int kIndexInFileMessages =
478 1;
479
480 friend void swap(Socket& a, Socket& b) {
481 a.Swap(&b);
482 }
483 inline void Swap(Socket* other) {
484 if (other == this) return;
485 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
486 if (GetOwningArena() != nullptr &&
487 GetOwningArena() == other->GetOwningArena()) {
488 #else // PROTOBUF_FORCE_COPY_IN_SWAP
489 if (GetOwningArena() == other->GetOwningArena()) {
490 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
491 InternalSwap(other);
492 } else {
493 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
494 }
495 }
496 void UnsafeArenaSwap(Socket* other) {
497 if (other == this) return;
498 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
499 InternalSwap(other);
500 }
501
502 // implements Message ----------------------------------------------
503
504 Socket* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
505 return CreateMaybeMessage<Socket>(arena);
506 }
507 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
508 void CopyFrom(const Socket& from);
509 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
510 void MergeFrom( const Socket& from) {
511 Socket::MergeImpl(*this, from);
512 }
513 private:
514 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
515 public:
516 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
517 bool IsInitialized() const final;
518
519 size_t ByteSizeLong() const final;
520 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
521 uint8_t* _InternalSerialize(
522 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
523 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
524
525 private:
526 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
527 void SharedDtor();
528 void SetCachedSize(int size) const final;
529 void InternalSwap(Socket* other);
530
531 private:
532 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
533 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
534 return "goby.zeromq.protobuf.Socket";
535 }
536 protected:
537 explicit Socket(::PROTOBUF_NAMESPACE_ID::Arena* arena,
538 bool is_message_owned = false);
539 public:
540
541 static const ClassData _class_data_;
542 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
543
544 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
545
546 // nested types ----------------------------------------------------
547
548 typedef Socket_SocketType SocketType;
549 static constexpr SocketType PUBLISH =
550 Socket_SocketType_PUBLISH;
551 static constexpr SocketType SUBSCRIBE =
552 Socket_SocketType_SUBSCRIBE;
553 static constexpr SocketType REPLY =
554 Socket_SocketType_REPLY;
555 static constexpr SocketType REQUEST =
556 Socket_SocketType_REQUEST;
557 static inline bool SocketType_IsValid(int value) {
558 return Socket_SocketType_IsValid(value);
559 }
560 static constexpr SocketType SocketType_MIN =
561 Socket_SocketType_SocketType_MIN;
562 static constexpr SocketType SocketType_MAX =
563 Socket_SocketType_SocketType_MAX;
564 static constexpr int SocketType_ARRAYSIZE =
565 Socket_SocketType_SocketType_ARRAYSIZE;
566 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
570 template<typename T>
571 static inline const std::string& SocketType_Name(T enum_t_value) {
572 static_assert(::std::is_same<T, SocketType>::value ||
573 ::std::is_integral<T>::value,
574 "Incorrect type passed to function SocketType_Name.");
575 return Socket_SocketType_Name(enum_t_value);
576 }
577 static inline bool SocketType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
578 SocketType* value) {
579 return Socket_SocketType_Parse(name, value);
580 }
581
582 typedef Socket_Transport Transport;
583 static constexpr Transport INPROC =
584 Socket_Transport_INPROC;
585 static constexpr Transport IPC =
586 Socket_Transport_IPC;
587 static constexpr Transport TCP =
588 Socket_Transport_TCP;
589 static constexpr Transport PGM =
590 Socket_Transport_PGM;
591 static constexpr Transport EPGM =
592 Socket_Transport_EPGM;
593 static inline bool Transport_IsValid(int value) {
594 return Socket_Transport_IsValid(value);
595 }
596 static constexpr Transport Transport_MIN =
597 Socket_Transport_Transport_MIN;
598 static constexpr Transport Transport_MAX =
599 Socket_Transport_Transport_MAX;
600 static constexpr int Transport_ARRAYSIZE =
601 Socket_Transport_Transport_ARRAYSIZE;
602 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
606 template<typename T>
607 static inline const std::string& Transport_Name(T enum_t_value) {
608 static_assert(::std::is_same<T, Transport>::value ||
609 ::std::is_integral<T>::value,
610 "Incorrect type passed to function Transport_Name.");
611 return Socket_Transport_Name(enum_t_value);
612 }
613 static inline bool Transport_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
614 Transport* value) {
615 return Socket_Transport_Parse(name, value);
616 }
617
618 typedef Socket_ConnectOrBind ConnectOrBind;
619 static constexpr ConnectOrBind CONNECT =
620 Socket_ConnectOrBind_CONNECT;
621 static constexpr ConnectOrBind BIND =
622 Socket_ConnectOrBind_BIND;
623 static inline bool ConnectOrBind_IsValid(int value) {
624 return Socket_ConnectOrBind_IsValid(value);
625 }
626 static constexpr ConnectOrBind ConnectOrBind_MIN =
627 Socket_ConnectOrBind_ConnectOrBind_MIN;
628 static constexpr ConnectOrBind ConnectOrBind_MAX =
629 Socket_ConnectOrBind_ConnectOrBind_MAX;
630 static constexpr int ConnectOrBind_ARRAYSIZE =
631 Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE;
632 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
636 template<typename T>
637 static inline const std::string& ConnectOrBind_Name(T enum_t_value) {
638 static_assert(::std::is_same<T, ConnectOrBind>::value ||
639 ::std::is_integral<T>::value,
640 "Incorrect type passed to function ConnectOrBind_Name.");
641 return Socket_ConnectOrBind_Name(enum_t_value);
642 }
643 static inline bool ConnectOrBind_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
644 ConnectOrBind* value) {
645 return Socket_ConnectOrBind_Parse(name, value);
646 }
647
648 // accessors -------------------------------------------------------
649
650 enum : int {
651 kEthernetAddressFieldNumber = 5,
652 kMulticastAddressFieldNumber = 6,
653 kSocketNameFieldNumber = 8,
654 kSocketIdFieldNumber = 2,
655 kSocketTypeFieldNumber = 1,
656 kTransportFieldNumber = 3,
657 kConnectOrBindFieldNumber = 4,
658 kEthernetPortFieldNumber = 7,
659 kSendQueueSizeFieldNumber = 10,
660 kReceiveQueueSizeFieldNumber = 11,
661 };
662 // optional string ethernet_address = 5 [default = "127.0.0.1", (.goby.field) = {
663 bool has_ethernet_address() const;
664 private:
665 bool _internal_has_ethernet_address() const;
666 public:
667 void clear_ethernet_address();
668 const std::string& ethernet_address() const;
669 template <typename ArgT0 = const std::string&, typename... ArgT>
670 void set_ethernet_address(ArgT0&& arg0, ArgT... args);
671 std::string* mutable_ethernet_address();
672 PROTOBUF_NODISCARD std::string* release_ethernet_address();
673 void set_allocated_ethernet_address(std::string* ethernet_address);
674 private:
675 const std::string& _internal_ethernet_address() const;
676 inline PROTOBUF_ALWAYS_INLINE void _internal_set_ethernet_address(const std::string& value);
677 std::string* _internal_mutable_ethernet_address();
678 public:
679
680 // optional string multicast_address = 6 [default = "239.255.7.15", (.goby.field) = {
681 bool has_multicast_address() const;
682 private:
683 bool _internal_has_multicast_address() const;
684 public:
685 void clear_multicast_address();
686 const std::string& multicast_address() const;
687 template <typename ArgT0 = const std::string&, typename... ArgT>
688 void set_multicast_address(ArgT0&& arg0, ArgT... args);
689 std::string* mutable_multicast_address();
690 PROTOBUF_NODISCARD std::string* release_multicast_address();
691 void set_allocated_multicast_address(std::string* multicast_address);
692 private:
693 const std::string& _internal_multicast_address() const;
694 inline PROTOBUF_ALWAYS_INLINE void _internal_set_multicast_address(const std::string& value);
695 std::string* _internal_mutable_multicast_address();
696 public:
697
698 // optional string socket_name = 8;
699 bool has_socket_name() const;
700 private:
701 bool _internal_has_socket_name() const;
702 public:
703 void clear_socket_name();
704 const std::string& socket_name() const;
705 template <typename ArgT0 = const std::string&, typename... ArgT>
706 void set_socket_name(ArgT0&& arg0, ArgT... args);
707 std::string* mutable_socket_name();
708 PROTOBUF_NODISCARD std::string* release_socket_name();
709 void set_allocated_socket_name(std::string* socket_name);
710 private:
711 const std::string& _internal_socket_name() const;
712 inline PROTOBUF_ALWAYS_INLINE void _internal_set_socket_name(const std::string& value);
713 std::string* _internal_mutable_socket_name();
714 public:
715
716 // optional uint32 socket_id = 2 [default = 0, (.goby.field) = {
717 bool has_socket_id() const;
718 private:
719 bool _internal_has_socket_id() const;
720 public:
721 void clear_socket_id();
722 uint32_t socket_id() const;
723 void set_socket_id(uint32_t value);
724 private:
725 uint32_t _internal_socket_id() const;
726 void _internal_set_socket_id(uint32_t value);
727 public:
728
729 // required .goby.zeromq.protobuf.Socket.SocketType socket_type = 1;
730 bool has_socket_type() const;
731 private:
732 bool _internal_has_socket_type() const;
733 public:
734 void clear_socket_type();
735 ::goby::zeromq::protobuf::Socket_SocketType socket_type() const;
736 void set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value);
737 private:
738 ::goby::zeromq::protobuf::Socket_SocketType _internal_socket_type() const;
739 void _internal_set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value);
740 public:
741
742 // optional .goby.zeromq.protobuf.Socket.Transport transport = 3 [default = EPGM];
743 bool has_transport() const;
744 private:
745 bool _internal_has_transport() const;
746 public:
747 void clear_transport();
748 ::goby::zeromq::protobuf::Socket_Transport transport() const;
749 void set_transport(::goby::zeromq::protobuf::Socket_Transport value);
750 private:
751 ::goby::zeromq::protobuf::Socket_Transport _internal_transport() const;
752 void _internal_set_transport(::goby::zeromq::protobuf::Socket_Transport value);
753 public:
754
755 // optional .goby.zeromq.protobuf.Socket.ConnectOrBind connect_or_bind = 4 [default = CONNECT];
756 bool has_connect_or_bind() const;
757 private:
758 bool _internal_has_connect_or_bind() const;
759 public:
760 void clear_connect_or_bind();
761 ::goby::zeromq::protobuf::Socket_ConnectOrBind connect_or_bind() const;
762 void set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value);
763 private:
764 ::goby::zeromq::protobuf::Socket_ConnectOrBind _internal_connect_or_bind() const;
765 void _internal_set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value);
766 public:
767
768 // optional uint32 ethernet_port = 7 [default = 11142];
769 bool has_ethernet_port() const;
770 private:
771 bool _internal_has_ethernet_port() const;
772 public:
773 void clear_ethernet_port();
774 uint32_t ethernet_port() const;
775 void set_ethernet_port(uint32_t value);
776 private:
777 uint32_t _internal_ethernet_port() const;
778 void _internal_set_ethernet_port(uint32_t value);
779 public:
780
781 // optional uint32 send_queue_size = 10 [default = 1000];
782 bool has_send_queue_size() const;
783 private:
784 bool _internal_has_send_queue_size() const;
785 public:
786 void clear_send_queue_size();
787 uint32_t send_queue_size() const;
788 void set_send_queue_size(uint32_t value);
789 private:
790 uint32_t _internal_send_queue_size() const;
791 void _internal_set_send_queue_size(uint32_t value);
792 public:
793
794 // optional uint32 receive_queue_size = 11 [default = 1000];
795 bool has_receive_queue_size() const;
796 private:
797 bool _internal_has_receive_queue_size() const;
798 public:
799 void clear_receive_queue_size();
800 uint32_t receive_queue_size() const;
801 void set_receive_queue_size(uint32_t value);
802 private:
803 uint32_t _internal_receive_queue_size() const;
804 void _internal_set_receive_queue_size(uint32_t value);
805 public:
806
807 // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.Socket)
808 private:
809 class _Internal;
810
811 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
812 typedef void InternalArenaConstructable_;
813 typedef void DestructorSkippable_;
814 struct Impl_ {
815 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
816 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
817 static const ::PROTOBUF_NAMESPACE_ID::internal::LazyString _i_give_permission_to_break_this_code_default_ethernet_address_;
818 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr ethernet_address_;
819 static const ::PROTOBUF_NAMESPACE_ID::internal::LazyString _i_give_permission_to_break_this_code_default_multicast_address_;
820 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr multicast_address_;
821 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr socket_name_;
822 uint32_t socket_id_;
823 int socket_type_;
824 int transport_;
825 int connect_or_bind_;
826 uint32_t ethernet_port_;
827 uint32_t send_queue_size_;
828 uint32_t receive_queue_size_;
829 };
830 union { Impl_ _impl_; };
831 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
832};
833// -------------------------------------------------------------------
834
835class ManagerResponse final :
836 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.ManagerResponse) */ {
837 public:
838 inline ManagerResponse() : ManagerResponse(nullptr) {}
839 ~ManagerResponse() override;
840 explicit PROTOBUF_CONSTEXPR ManagerResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
841
842 ManagerResponse(const ManagerResponse& from);
843 ManagerResponse(ManagerResponse&& from) noexcept
844 : ManagerResponse() {
845 *this = ::std::move(from);
846 }
847
848 inline ManagerResponse& operator=(const ManagerResponse& from) {
849 CopyFrom(from);
850 return *this;
851 }
852 inline ManagerResponse& operator=(ManagerResponse&& from) noexcept {
853 if (this == &from) return *this;
854 if (GetOwningArena() == from.GetOwningArena()
855 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
856 && GetOwningArena() != nullptr
857 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
858 ) {
859 InternalSwap(&from);
860 } else {
861 CopyFrom(from);
862 }
863 return *this;
864 }
865
866 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
867 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
868 }
869 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
870 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
871 }
872
873 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
874 return GetDescriptor();
875 }
876 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
877 return default_instance().GetMetadata().descriptor;
878 }
879 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
880 return default_instance().GetMetadata().reflection;
881 }
882 static const ManagerResponse& default_instance() {
883 return *internal_default_instance();
884 }
885 static inline const ManagerResponse* internal_default_instance() {
886 return reinterpret_cast<const ManagerResponse*>(
887 &_ManagerResponse_default_instance_);
888 }
889 static constexpr int kIndexInFileMessages =
890 2;
891
892 friend void swap(ManagerResponse& a, ManagerResponse& b) {
893 a.Swap(&b);
894 }
895 inline void Swap(ManagerResponse* other) {
896 if (other == this) return;
897 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
898 if (GetOwningArena() != nullptr &&
899 GetOwningArena() == other->GetOwningArena()) {
900 #else // PROTOBUF_FORCE_COPY_IN_SWAP
901 if (GetOwningArena() == other->GetOwningArena()) {
902 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
903 InternalSwap(other);
904 } else {
905 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
906 }
907 }
908 void UnsafeArenaSwap(ManagerResponse* other) {
909 if (other == this) return;
910 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
911 InternalSwap(other);
912 }
913
914 // implements Message ----------------------------------------------
915
916 ManagerResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
917 return CreateMaybeMessage<ManagerResponse>(arena);
918 }
919 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
920 void CopyFrom(const ManagerResponse& from);
921 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
922 void MergeFrom( const ManagerResponse& from) {
923 ManagerResponse::MergeImpl(*this, from);
924 }
925 private:
926 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
927 public:
928 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
929 bool IsInitialized() const final;
930
931 size_t ByteSizeLong() const final;
932 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
933 uint8_t* _InternalSerialize(
934 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
935 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
936
937 private:
938 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
939 void SharedDtor();
940 void SetCachedSize(int size) const final;
941 void InternalSwap(ManagerResponse* other);
942
943 private:
944 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
945 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
946 return "goby.zeromq.protobuf.ManagerResponse";
947 }
948 protected:
949 explicit ManagerResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
950 bool is_message_owned = false);
951 public:
952
953 static const ClassData _class_data_;
954 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
955
956 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
957
958 // nested types ----------------------------------------------------
959
960 // accessors -------------------------------------------------------
961
962 enum : int {
963 kClientNameFieldNumber = 2,
964 kPublishSocketFieldNumber = 4,
965 kSubscribeSocketFieldNumber = 5,
966 kClientPidFieldNumber = 3,
967 kRequestFieldNumber = 1,
968 kHoldFieldNumber = 6,
969 };
970 // required string client_name = 2;
971 bool has_client_name() const;
972 private:
973 bool _internal_has_client_name() const;
974 public:
975 void clear_client_name();
976 const std::string& client_name() const;
977 template <typename ArgT0 = const std::string&, typename... ArgT>
978 void set_client_name(ArgT0&& arg0, ArgT... args);
979 std::string* mutable_client_name();
980 PROTOBUF_NODISCARD std::string* release_client_name();
981 void set_allocated_client_name(std::string* client_name);
982 private:
983 const std::string& _internal_client_name() const;
984 inline PROTOBUF_ALWAYS_INLINE void _internal_set_client_name(const std::string& value);
985 std::string* _internal_mutable_client_name();
986 public:
987
988 // optional .goby.zeromq.protobuf.Socket publish_socket = 4;
989 bool has_publish_socket() const;
990 private:
991 bool _internal_has_publish_socket() const;
992 public:
993 void clear_publish_socket();
994 const ::goby::zeromq::protobuf::Socket& publish_socket() const;
995 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_publish_socket();
996 ::goby::zeromq::protobuf::Socket* mutable_publish_socket();
997 void set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket);
998 private:
999 const ::goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1000 ::goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1001 public:
1002 void unsafe_arena_set_allocated_publish_socket(
1003 ::goby::zeromq::protobuf::Socket* publish_socket);
1004 ::goby::zeromq::protobuf::Socket* unsafe_arena_release_publish_socket();
1005
1006 // optional .goby.zeromq.protobuf.Socket subscribe_socket = 5;
1007 bool has_subscribe_socket() const;
1008 private:
1009 bool _internal_has_subscribe_socket() const;
1010 public:
1011 void clear_subscribe_socket();
1012 const ::goby::zeromq::protobuf::Socket& subscribe_socket() const;
1013 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_subscribe_socket();
1014 ::goby::zeromq::protobuf::Socket* mutable_subscribe_socket();
1015 void set_allocated_subscribe_socket(::goby::zeromq::protobuf::Socket* subscribe_socket);
1016 private:
1017 const ::goby::zeromq::protobuf::Socket& _internal_subscribe_socket() const;
1018 ::goby::zeromq::protobuf::Socket* _internal_mutable_subscribe_socket();
1019 public:
1020 void unsafe_arena_set_allocated_subscribe_socket(
1021 ::goby::zeromq::protobuf::Socket* subscribe_socket);
1022 ::goby::zeromq::protobuf::Socket* unsafe_arena_release_subscribe_socket();
1023
1024 // required int32 client_pid = 3;
1025 bool has_client_pid() const;
1026 private:
1027 bool _internal_has_client_pid() const;
1028 public:
1029 void clear_client_pid();
1030 int32_t client_pid() const;
1031 void set_client_pid(int32_t value);
1032 private:
1033 int32_t _internal_client_pid() const;
1034 void _internal_set_client_pid(int32_t value);
1035 public:
1036
1037 // required .goby.zeromq.protobuf.Request request = 1;
1038 bool has_request() const;
1039 private:
1040 bool _internal_has_request() const;
1041 public:
1042 void clear_request();
1043 ::goby::zeromq::protobuf::Request request() const;
1044 void set_request(::goby::zeromq::protobuf::Request value);
1045 private:
1046 ::goby::zeromq::protobuf::Request _internal_request() const;
1047 void _internal_set_request(::goby::zeromq::protobuf::Request value);
1048 public:
1049
1050 // optional bool hold = 6 [default = true, (.goby.field) = {
1051 bool has_hold() const;
1052 private:
1053 bool _internal_has_hold() const;
1054 public:
1055 void clear_hold();
1056 bool hold() const;
1057 void set_hold(bool value);
1058 private:
1059 bool _internal_hold() const;
1060 void _internal_set_hold(bool value);
1061 public:
1062
1063 // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.ManagerResponse)
1064 private:
1065 class _Internal;
1066
1067 // helper for ByteSizeLong()
1068 size_t RequiredFieldsByteSizeFallback() const;
1069
1070 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1071 typedef void InternalArenaConstructable_;
1072 typedef void DestructorSkippable_;
1073 struct Impl_ {
1074 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1075 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1076 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr client_name_;
1077 ::goby::zeromq::protobuf::Socket* publish_socket_;
1078 ::goby::zeromq::protobuf::Socket* subscribe_socket_;
1079 int32_t client_pid_;
1080 int request_;
1081 bool hold_;
1082 };
1083 union { Impl_ _impl_; };
1084 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
1085};
1086// -------------------------------------------------------------------
1087
1088class InprocControl final :
1089 public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:goby.zeromq.protobuf.InprocControl) */ {
1090 public:
1091 inline InprocControl() : InprocControl(nullptr) {}
1092 ~InprocControl() override;
1093 explicit PROTOBUF_CONSTEXPR InprocControl(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
1094
1095 InprocControl(const InprocControl& from);
1096 InprocControl(InprocControl&& from) noexcept
1097 : InprocControl() {
1098 *this = ::std::move(from);
1099 }
1100
1101 inline InprocControl& operator=(const InprocControl& from) {
1102 CopyFrom(from);
1103 return *this;
1104 }
1105 inline InprocControl& operator=(InprocControl&& from) noexcept {
1106 if (this == &from) return *this;
1107 if (GetOwningArena() == from.GetOwningArena()
1108 #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
1109 && GetOwningArena() != nullptr
1110 #endif // !PROTOBUF_FORCE_COPY_IN_MOVE
1111 ) {
1112 InternalSwap(&from);
1113 } else {
1114 CopyFrom(from);
1115 }
1116 return *this;
1117 }
1118
1119 inline const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet& unknown_fields() const {
1120 return _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance);
1121 }
1122 inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet* mutable_unknown_fields() {
1123 return _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1124 }
1125
1126 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
1127 return GetDescriptor();
1128 }
1129 static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
1130 return default_instance().GetMetadata().descriptor;
1131 }
1132 static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
1133 return default_instance().GetMetadata().reflection;
1134 }
1135 static const InprocControl& default_instance() {
1136 return *internal_default_instance();
1137 }
1138 static inline const InprocControl* internal_default_instance() {
1139 return reinterpret_cast<const InprocControl*>(
1140 &_InprocControl_default_instance_);
1141 }
1142 static constexpr int kIndexInFileMessages =
1143 3;
1144
1145 friend void swap(InprocControl& a, InprocControl& b) {
1146 a.Swap(&b);
1147 }
1148 inline void Swap(InprocControl* other) {
1149 if (other == this) return;
1150 #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
1151 if (GetOwningArena() != nullptr &&
1152 GetOwningArena() == other->GetOwningArena()) {
1153 #else // PROTOBUF_FORCE_COPY_IN_SWAP
1154 if (GetOwningArena() == other->GetOwningArena()) {
1155 #endif // !PROTOBUF_FORCE_COPY_IN_SWAP
1156 InternalSwap(other);
1157 } else {
1158 ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
1159 }
1160 }
1161 void UnsafeArenaSwap(InprocControl* other) {
1162 if (other == this) return;
1163 GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
1164 InternalSwap(other);
1165 }
1166
1167 // implements Message ----------------------------------------------
1168
1169 InprocControl* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
1170 return CreateMaybeMessage<InprocControl>(arena);
1171 }
1172 using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
1173 void CopyFrom(const InprocControl& from);
1174 using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
1175 void MergeFrom( const InprocControl& from) {
1176 InprocControl::MergeImpl(*this, from);
1177 }
1178 private:
1179 static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
1180 public:
1181 PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
1182 bool IsInitialized() const final;
1183
1184 size_t ByteSizeLong() const final;
1185 const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
1186 uint8_t* _InternalSerialize(
1187 uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
1188 int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
1189
1190 private:
1191 void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
1192 void SharedDtor();
1193 void SetCachedSize(int size) const final;
1194 void InternalSwap(InprocControl* other);
1195
1196 private:
1197 friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
1198 static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
1199 return "goby.zeromq.protobuf.InprocControl";
1200 }
1201 protected:
1202 explicit InprocControl(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1203 bool is_message_owned = false);
1204 public:
1205
1206 static const ClassData _class_data_;
1207 const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
1208
1209 ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
1210
1211 // nested types ----------------------------------------------------
1212
1213 typedef InprocControl_InprocControlType InprocControlType;
1214 static constexpr InprocControlType PUB_CONFIGURATION =
1215 InprocControl_InprocControlType_PUB_CONFIGURATION;
1216 static constexpr InprocControlType SUBSCRIBE =
1217 InprocControl_InprocControlType_SUBSCRIBE;
1218 static constexpr InprocControlType SUBSCRIBE_ACK =
1219 InprocControl_InprocControlType_SUBSCRIBE_ACK;
1220 static constexpr InprocControlType UNSUBSCRIBE =
1221 InprocControl_InprocControlType_UNSUBSCRIBE;
1222 static constexpr InprocControlType UNSUBSCRIBE_ACK =
1223 InprocControl_InprocControlType_UNSUBSCRIBE_ACK;
1224 static constexpr InprocControlType RECEIVE =
1225 InprocControl_InprocControlType_RECEIVE;
1226 static constexpr InprocControlType SHUTDOWN =
1227 InprocControl_InprocControlType_SHUTDOWN;
1228 static constexpr InprocControlType REQUEST_HOLD_STATE =
1229 InprocControl_InprocControlType_REQUEST_HOLD_STATE;
1230 static constexpr InprocControlType NOTIFY_HOLD_STATE =
1231 InprocControl_InprocControlType_NOTIFY_HOLD_STATE;
1232 static inline bool InprocControlType_IsValid(int value) {
1233 return InprocControl_InprocControlType_IsValid(value);
1234 }
1235 static constexpr InprocControlType InprocControlType_MIN =
1236 InprocControl_InprocControlType_InprocControlType_MIN;
1237 static constexpr InprocControlType InprocControlType_MAX =
1238 InprocControl_InprocControlType_InprocControlType_MAX;
1239 static constexpr int InprocControlType_ARRAYSIZE =
1240 InprocControl_InprocControlType_InprocControlType_ARRAYSIZE;
1241 static inline const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor*
1245 template<typename T>
1246 static inline const std::string& InprocControlType_Name(T enum_t_value) {
1247 static_assert(::std::is_same<T, InprocControlType>::value ||
1248 ::std::is_integral<T>::value,
1249 "Incorrect type passed to function InprocControlType_Name.");
1250 return InprocControl_InprocControlType_Name(enum_t_value);
1251 }
1252 static inline bool InprocControlType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name,
1253 InprocControlType* value) {
1254 return InprocControl_InprocControlType_Parse(name, value);
1255 }
1256
1257 // accessors -------------------------------------------------------
1258
1259 enum : int {
1260 kSubscriptionIdentifierFieldNumber = 3,
1261 kReceivedDataFieldNumber = 4,
1262 kPublishSocketFieldNumber = 2,
1263 kHoldFieldNumber = 10,
1264 kTypeFieldNumber = 1,
1265 };
1266 // optional bytes subscription_identifier = 3;
1267 bool has_subscription_identifier() const;
1268 private:
1269 bool _internal_has_subscription_identifier() const;
1270 public:
1271 void clear_subscription_identifier();
1272 const std::string& subscription_identifier() const;
1273 template <typename ArgT0 = const std::string&, typename... ArgT>
1274 void set_subscription_identifier(ArgT0&& arg0, ArgT... args);
1275 std::string* mutable_subscription_identifier();
1276 PROTOBUF_NODISCARD std::string* release_subscription_identifier();
1277 void set_allocated_subscription_identifier(std::string* subscription_identifier);
1278 private:
1279 const std::string& _internal_subscription_identifier() const;
1280 inline PROTOBUF_ALWAYS_INLINE void _internal_set_subscription_identifier(const std::string& value);
1281 std::string* _internal_mutable_subscription_identifier();
1282 public:
1283
1284 // optional bytes received_data = 4;
1285 bool has_received_data() const;
1286 private:
1287 bool _internal_has_received_data() const;
1288 public:
1289 void clear_received_data();
1290 const std::string& received_data() const;
1291 template <typename ArgT0 = const std::string&, typename... ArgT>
1292 void set_received_data(ArgT0&& arg0, ArgT... args);
1293 std::string* mutable_received_data();
1294 PROTOBUF_NODISCARD std::string* release_received_data();
1295 void set_allocated_received_data(std::string* received_data);
1296 private:
1297 const std::string& _internal_received_data() const;
1298 inline PROTOBUF_ALWAYS_INLINE void _internal_set_received_data(const std::string& value);
1299 std::string* _internal_mutable_received_data();
1300 public:
1301
1302 // optional .goby.zeromq.protobuf.Socket publish_socket = 2;
1303 bool has_publish_socket() const;
1304 private:
1305 bool _internal_has_publish_socket() const;
1306 public:
1307 void clear_publish_socket();
1308 const ::goby::zeromq::protobuf::Socket& publish_socket() const;
1309 PROTOBUF_NODISCARD ::goby::zeromq::protobuf::Socket* release_publish_socket();
1310 ::goby::zeromq::protobuf::Socket* mutable_publish_socket();
1311 void set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket);
1312 private:
1313 const ::goby::zeromq::protobuf::Socket& _internal_publish_socket() const;
1314 ::goby::zeromq::protobuf::Socket* _internal_mutable_publish_socket();
1315 public:
1316 void unsafe_arena_set_allocated_publish_socket(
1317 ::goby::zeromq::protobuf::Socket* publish_socket);
1318 ::goby::zeromq::protobuf::Socket* unsafe_arena_release_publish_socket();
1319
1320 // optional bool hold = 10;
1321 bool has_hold() const;
1322 private:
1323 bool _internal_has_hold() const;
1324 public:
1325 void clear_hold();
1326 bool hold() const;
1327 void set_hold(bool value);
1328 private:
1329 bool _internal_hold() const;
1330 void _internal_set_hold(bool value);
1331 public:
1332
1333 // required .goby.zeromq.protobuf.InprocControl.InprocControlType type = 1;
1334 bool has_type() const;
1335 private:
1336 bool _internal_has_type() const;
1337 public:
1338 void clear_type();
1339 ::goby::zeromq::protobuf::InprocControl_InprocControlType type() const;
1340 void set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value);
1341 private:
1342 ::goby::zeromq::protobuf::InprocControl_InprocControlType _internal_type() const;
1343 void _internal_set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value);
1344 public:
1345
1346 // @@protoc_insertion_point(class_scope:goby.zeromq.protobuf.InprocControl)
1347 private:
1348 class _Internal;
1349
1350 template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
1351 typedef void InternalArenaConstructable_;
1352 typedef void DestructorSkippable_;
1353 struct Impl_ {
1354 ::PROTOBUF_NAMESPACE_ID::internal::HasBits<1> _has_bits_;
1355 mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
1356 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr subscription_identifier_;
1357 ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr received_data_;
1358 ::goby::zeromq::protobuf::Socket* publish_socket_;
1359 bool hold_;
1360 int type_;
1361 };
1362 union { Impl_ _impl_; };
1363 friend struct ::TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto;
1364};
1365// ===================================================================
1366
1367
1368// ===================================================================
1369
1370#ifdef __GNUC__
1371 #pragma GCC diagnostic push
1372 #pragma GCC diagnostic ignored "-Wstrict-aliasing"
1373#endif // __GNUC__
1374// ManagerRequest
1375
1376// required .goby.zeromq.protobuf.Request request = 1 [(.goby.field) = {
1377inline bool ManagerRequest::_internal_has_request() const {
1378 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
1379 return value;
1380}
1381inline bool ManagerRequest::has_request() const {
1382 return _internal_has_request();
1383}
1384inline void ManagerRequest::clear_request() {
1385 _impl_.request_ = 1;
1386 _impl_._has_bits_[0] &= ~0x00000008u;
1387}
1388inline ::goby::zeromq::protobuf::Request ManagerRequest::_internal_request() const {
1389 return static_cast< ::goby::zeromq::protobuf::Request >(_impl_.request_);
1390}
1391inline ::goby::zeromq::protobuf::Request ManagerRequest::request() const {
1392 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.request)
1393 return _internal_request();
1394}
1395inline void ManagerRequest::_internal_set_request(::goby::zeromq::protobuf::Request value) {
1396 assert(::goby::zeromq::protobuf::Request_IsValid(value));
1397 _impl_._has_bits_[0] |= 0x00000008u;
1398 _impl_.request_ = value;
1399}
1400inline void ManagerRequest::set_request(::goby::zeromq::protobuf::Request value) {
1401 _internal_set_request(value);
1402 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.request)
1403}
1404
1405// required string client_name = 2 [(.goby.field) = {
1406inline bool ManagerRequest::_internal_has_client_name() const {
1407 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1408 return value;
1409}
1410inline bool ManagerRequest::has_client_name() const {
1411 return _internal_has_client_name();
1412}
1413inline void ManagerRequest::clear_client_name() {
1414 _impl_.client_name_.ClearToEmpty();
1415 _impl_._has_bits_[0] &= ~0x00000001u;
1416}
1417inline const std::string& ManagerRequest::client_name() const {
1418 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.client_name)
1419 return _internal_client_name();
1420}
1421template <typename ArgT0, typename... ArgT>
1422inline PROTOBUF_ALWAYS_INLINE
1423void ManagerRequest::set_client_name(ArgT0&& arg0, ArgT... args) {
1424 _impl_._has_bits_[0] |= 0x00000001u;
1425 _impl_.client_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1426 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.client_name)
1427}
1428inline std::string* ManagerRequest::mutable_client_name() {
1429 std::string* _s = _internal_mutable_client_name();
1430 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerRequest.client_name)
1431 return _s;
1432}
1433inline const std::string& ManagerRequest::_internal_client_name() const {
1434 return _impl_.client_name_.Get();
1435}
1436inline void ManagerRequest::_internal_set_client_name(const std::string& value) {
1437 _impl_._has_bits_[0] |= 0x00000001u;
1438 _impl_.client_name_.Set(value, GetArenaForAllocation());
1439}
1440inline std::string* ManagerRequest::_internal_mutable_client_name() {
1441 _impl_._has_bits_[0] |= 0x00000001u;
1442 return _impl_.client_name_.Mutable(GetArenaForAllocation());
1443}
1444inline std::string* ManagerRequest::release_client_name() {
1445 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerRequest.client_name)
1446 if (!_internal_has_client_name()) {
1447 return nullptr;
1448 }
1449 _impl_._has_bits_[0] &= ~0x00000001u;
1450 auto* p = _impl_.client_name_.Release();
1451#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1452 if (_impl_.client_name_.IsDefault()) {
1453 _impl_.client_name_.Set("", GetArenaForAllocation());
1454 }
1455#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1456 return p;
1457}
1458inline void ManagerRequest::set_allocated_client_name(std::string* client_name) {
1459 if (client_name != nullptr) {
1460 _impl_._has_bits_[0] |= 0x00000001u;
1461 } else {
1462 _impl_._has_bits_[0] &= ~0x00000001u;
1463 }
1464 _impl_.client_name_.SetAllocated(client_name, GetArenaForAllocation());
1465#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1466 if (_impl_.client_name_.IsDefault()) {
1467 _impl_.client_name_.Set("", GetArenaForAllocation());
1468 }
1469#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1470 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerRequest.client_name)
1471}
1472
1473// required int32 client_pid = 3 [(.goby.field) = {
1474inline bool ManagerRequest::_internal_has_client_pid() const {
1475 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
1476 return value;
1477}
1478inline bool ManagerRequest::has_client_pid() const {
1479 return _internal_has_client_pid();
1480}
1481inline void ManagerRequest::clear_client_pid() {
1482 _impl_.client_pid_ = 0;
1483 _impl_._has_bits_[0] &= ~0x00000002u;
1484}
1485inline int32_t ManagerRequest::_internal_client_pid() const {
1486 return _impl_.client_pid_;
1487}
1488inline int32_t ManagerRequest::client_pid() const {
1489 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.client_pid)
1490 return _internal_client_pid();
1491}
1492inline void ManagerRequest::_internal_set_client_pid(int32_t value) {
1493 _impl_._has_bits_[0] |= 0x00000002u;
1494 _impl_.client_pid_ = value;
1495}
1496inline void ManagerRequest::set_client_pid(int32_t value) {
1497 _internal_set_client_pid(value);
1498 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.client_pid)
1499}
1500
1501// optional bool ready = 4 [default = false, (.goby.field) = {
1502inline bool ManagerRequest::_internal_has_ready() const {
1503 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
1504 return value;
1505}
1506inline bool ManagerRequest::has_ready() const {
1507 return _internal_has_ready();
1508}
1509inline void ManagerRequest::clear_ready() {
1510 _impl_.ready_ = false;
1511 _impl_._has_bits_[0] &= ~0x00000004u;
1512}
1513inline bool ManagerRequest::_internal_ready() const {
1514 return _impl_.ready_;
1515}
1516inline bool ManagerRequest::ready() const {
1517 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerRequest.ready)
1518 return _internal_ready();
1519}
1520inline void ManagerRequest::_internal_set_ready(bool value) {
1521 _impl_._has_bits_[0] |= 0x00000004u;
1522 _impl_.ready_ = value;
1523}
1524inline void ManagerRequest::set_ready(bool value) {
1525 _internal_set_ready(value);
1526 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerRequest.ready)
1527}
1528
1529// -------------------------------------------------------------------
1530
1531// Socket
1532
1533// required .goby.zeromq.protobuf.Socket.SocketType socket_type = 1;
1534inline bool Socket::_internal_has_socket_type() const {
1535 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
1536 return value;
1537}
1538inline bool Socket::has_socket_type() const {
1539 return _internal_has_socket_type();
1540}
1541inline void Socket::clear_socket_type() {
1542 _impl_.socket_type_ = 1;
1543 _impl_._has_bits_[0] &= ~0x00000010u;
1544}
1545inline ::goby::zeromq::protobuf::Socket_SocketType Socket::_internal_socket_type() const {
1546 return static_cast< ::goby::zeromq::protobuf::Socket_SocketType >(_impl_.socket_type_);
1547}
1548inline ::goby::zeromq::protobuf::Socket_SocketType Socket::socket_type() const {
1549 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_type)
1550 return _internal_socket_type();
1551}
1552inline void Socket::_internal_set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value) {
1553 assert(::goby::zeromq::protobuf::Socket_SocketType_IsValid(value));
1554 _impl_._has_bits_[0] |= 0x00000010u;
1555 _impl_.socket_type_ = value;
1556}
1557inline void Socket::set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value) {
1558 _internal_set_socket_type(value);
1559 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_type)
1560}
1561
1562// optional uint32 socket_id = 2 [default = 0, (.goby.field) = {
1563inline bool Socket::_internal_has_socket_id() const {
1564 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
1565 return value;
1566}
1567inline bool Socket::has_socket_id() const {
1568 return _internal_has_socket_id();
1569}
1570inline void Socket::clear_socket_id() {
1571 _impl_.socket_id_ = 0u;
1572 _impl_._has_bits_[0] &= ~0x00000008u;
1573}
1574inline uint32_t Socket::_internal_socket_id() const {
1575 return _impl_.socket_id_;
1576}
1577inline uint32_t Socket::socket_id() const {
1578 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_id)
1579 return _internal_socket_id();
1580}
1581inline void Socket::_internal_set_socket_id(uint32_t value) {
1582 _impl_._has_bits_[0] |= 0x00000008u;
1583 _impl_.socket_id_ = value;
1584}
1585inline void Socket::set_socket_id(uint32_t value) {
1586 _internal_set_socket_id(value);
1587 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_id)
1588}
1589
1590// optional .goby.zeromq.protobuf.Socket.Transport transport = 3 [default = EPGM];
1591inline bool Socket::_internal_has_transport() const {
1592 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
1593 return value;
1594}
1595inline bool Socket::has_transport() const {
1596 return _internal_has_transport();
1597}
1598inline void Socket::clear_transport() {
1599 _impl_.transport_ = 5;
1600 _impl_._has_bits_[0] &= ~0x00000020u;
1601}
1602inline ::goby::zeromq::protobuf::Socket_Transport Socket::_internal_transport() const {
1603 return static_cast< ::goby::zeromq::protobuf::Socket_Transport >(_impl_.transport_);
1604}
1605inline ::goby::zeromq::protobuf::Socket_Transport Socket::transport() const {
1606 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.transport)
1607 return _internal_transport();
1608}
1609inline void Socket::_internal_set_transport(::goby::zeromq::protobuf::Socket_Transport value) {
1610 assert(::goby::zeromq::protobuf::Socket_Transport_IsValid(value));
1611 _impl_._has_bits_[0] |= 0x00000020u;
1612 _impl_.transport_ = value;
1613}
1614inline void Socket::set_transport(::goby::zeromq::protobuf::Socket_Transport value) {
1615 _internal_set_transport(value);
1616 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.transport)
1617}
1618
1619// optional .goby.zeromq.protobuf.Socket.ConnectOrBind connect_or_bind = 4 [default = CONNECT];
1620inline bool Socket::_internal_has_connect_or_bind() const {
1621 bool value = (_impl_._has_bits_[0] & 0x00000040u) != 0;
1622 return value;
1623}
1624inline bool Socket::has_connect_or_bind() const {
1625 return _internal_has_connect_or_bind();
1626}
1627inline void Socket::clear_connect_or_bind() {
1628 _impl_.connect_or_bind_ = 1;
1629 _impl_._has_bits_[0] &= ~0x00000040u;
1630}
1631inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::_internal_connect_or_bind() const {
1632 return static_cast< ::goby::zeromq::protobuf::Socket_ConnectOrBind >(_impl_.connect_or_bind_);
1633}
1634inline ::goby::zeromq::protobuf::Socket_ConnectOrBind Socket::connect_or_bind() const {
1635 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.connect_or_bind)
1636 return _internal_connect_or_bind();
1637}
1638inline void Socket::_internal_set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value) {
1639 assert(::goby::zeromq::protobuf::Socket_ConnectOrBind_IsValid(value));
1640 _impl_._has_bits_[0] |= 0x00000040u;
1641 _impl_.connect_or_bind_ = value;
1642}
1643inline void Socket::set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value) {
1644 _internal_set_connect_or_bind(value);
1645 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.connect_or_bind)
1646}
1647
1648// optional string ethernet_address = 5 [default = "127.0.0.1", (.goby.field) = {
1649inline bool Socket::_internal_has_ethernet_address() const {
1650 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1651 return value;
1652}
1653inline bool Socket::has_ethernet_address() const {
1654 return _internal_has_ethernet_address();
1655}
1656inline void Socket::clear_ethernet_address() {
1657 _impl_.ethernet_address_.ClearToDefault(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_, GetArenaForAllocation());
1658 _impl_._has_bits_[0] &= ~0x00000001u;
1659}
1660inline const std::string& Socket::ethernet_address() const {
1661 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.ethernet_address)
1662 if (_impl_.ethernet_address_.IsDefault()) return Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_.get();
1663 return _internal_ethernet_address();
1664}
1665template <typename ArgT0, typename... ArgT>
1666inline PROTOBUF_ALWAYS_INLINE
1667void Socket::set_ethernet_address(ArgT0&& arg0, ArgT... args) {
1668 _impl_._has_bits_[0] |= 0x00000001u;
1669 _impl_.ethernet_address_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1670 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.ethernet_address)
1671}
1672inline std::string* Socket::mutable_ethernet_address() {
1673 std::string* _s = _internal_mutable_ethernet_address();
1674 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.ethernet_address)
1675 return _s;
1676}
1677inline const std::string& Socket::_internal_ethernet_address() const {
1678 return _impl_.ethernet_address_.Get();
1679}
1680inline void Socket::_internal_set_ethernet_address(const std::string& value) {
1681 _impl_._has_bits_[0] |= 0x00000001u;
1682 _impl_.ethernet_address_.Set(value, GetArenaForAllocation());
1683}
1684inline std::string* Socket::_internal_mutable_ethernet_address() {
1685 _impl_._has_bits_[0] |= 0x00000001u;
1686 return _impl_.ethernet_address_.Mutable(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_ethernet_address_, GetArenaForAllocation());
1687}
1688inline std::string* Socket::release_ethernet_address() {
1689 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.ethernet_address)
1690 if (!_internal_has_ethernet_address()) {
1691 return nullptr;
1692 }
1693 _impl_._has_bits_[0] &= ~0x00000001u;
1694 auto* p = _impl_.ethernet_address_.Release();
1695 return p;
1696}
1697inline void Socket::set_allocated_ethernet_address(std::string* ethernet_address) {
1698 if (ethernet_address != nullptr) {
1699 _impl_._has_bits_[0] |= 0x00000001u;
1700 } else {
1701 _impl_._has_bits_[0] &= ~0x00000001u;
1702 }
1703 _impl_.ethernet_address_.SetAllocated(ethernet_address, GetArenaForAllocation());
1704 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.ethernet_address)
1705}
1706
1707// optional string multicast_address = 6 [default = "239.255.7.15", (.goby.field) = {
1708inline bool Socket::_internal_has_multicast_address() const {
1709 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
1710 return value;
1711}
1712inline bool Socket::has_multicast_address() const {
1713 return _internal_has_multicast_address();
1714}
1715inline void Socket::clear_multicast_address() {
1716 _impl_.multicast_address_.ClearToDefault(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_multicast_address_, GetArenaForAllocation());
1717 _impl_._has_bits_[0] &= ~0x00000002u;
1718}
1719inline const std::string& Socket::multicast_address() const {
1720 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.multicast_address)
1721 if (_impl_.multicast_address_.IsDefault()) return Impl_::_i_give_permission_to_break_this_code_default_multicast_address_.get();
1722 return _internal_multicast_address();
1723}
1724template <typename ArgT0, typename... ArgT>
1725inline PROTOBUF_ALWAYS_INLINE
1726void Socket::set_multicast_address(ArgT0&& arg0, ArgT... args) {
1727 _impl_._has_bits_[0] |= 0x00000002u;
1728 _impl_.multicast_address_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1729 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.multicast_address)
1730}
1731inline std::string* Socket::mutable_multicast_address() {
1732 std::string* _s = _internal_mutable_multicast_address();
1733 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.multicast_address)
1734 return _s;
1735}
1736inline const std::string& Socket::_internal_multicast_address() const {
1737 return _impl_.multicast_address_.Get();
1738}
1739inline void Socket::_internal_set_multicast_address(const std::string& value) {
1740 _impl_._has_bits_[0] |= 0x00000002u;
1741 _impl_.multicast_address_.Set(value, GetArenaForAllocation());
1742}
1743inline std::string* Socket::_internal_mutable_multicast_address() {
1744 _impl_._has_bits_[0] |= 0x00000002u;
1745 return _impl_.multicast_address_.Mutable(::goby::zeromq::protobuf::Socket::Impl_::_i_give_permission_to_break_this_code_default_multicast_address_, GetArenaForAllocation());
1746}
1747inline std::string* Socket::release_multicast_address() {
1748 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.multicast_address)
1749 if (!_internal_has_multicast_address()) {
1750 return nullptr;
1751 }
1752 _impl_._has_bits_[0] &= ~0x00000002u;
1753 auto* p = _impl_.multicast_address_.Release();
1754 return p;
1755}
1756inline void Socket::set_allocated_multicast_address(std::string* multicast_address) {
1757 if (multicast_address != nullptr) {
1758 _impl_._has_bits_[0] |= 0x00000002u;
1759 } else {
1760 _impl_._has_bits_[0] &= ~0x00000002u;
1761 }
1762 _impl_.multicast_address_.SetAllocated(multicast_address, GetArenaForAllocation());
1763 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.multicast_address)
1764}
1765
1766// optional uint32 ethernet_port = 7 [default = 11142];
1767inline bool Socket::_internal_has_ethernet_port() const {
1768 bool value = (_impl_._has_bits_[0] & 0x00000080u) != 0;
1769 return value;
1770}
1771inline bool Socket::has_ethernet_port() const {
1772 return _internal_has_ethernet_port();
1773}
1774inline void Socket::clear_ethernet_port() {
1775 _impl_.ethernet_port_ = 11142u;
1776 _impl_._has_bits_[0] &= ~0x00000080u;
1777}
1778inline uint32_t Socket::_internal_ethernet_port() const {
1779 return _impl_.ethernet_port_;
1780}
1781inline uint32_t Socket::ethernet_port() const {
1782 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.ethernet_port)
1783 return _internal_ethernet_port();
1784}
1785inline void Socket::_internal_set_ethernet_port(uint32_t value) {
1786 _impl_._has_bits_[0] |= 0x00000080u;
1787 _impl_.ethernet_port_ = value;
1788}
1789inline void Socket::set_ethernet_port(uint32_t value) {
1790 _internal_set_ethernet_port(value);
1791 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.ethernet_port)
1792}
1793
1794// optional string socket_name = 8;
1795inline bool Socket::_internal_has_socket_name() const {
1796 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
1797 return value;
1798}
1799inline bool Socket::has_socket_name() const {
1800 return _internal_has_socket_name();
1801}
1802inline void Socket::clear_socket_name() {
1803 _impl_.socket_name_.ClearToEmpty();
1804 _impl_._has_bits_[0] &= ~0x00000004u;
1805}
1806inline const std::string& Socket::socket_name() const {
1807 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.socket_name)
1808 return _internal_socket_name();
1809}
1810template <typename ArgT0, typename... ArgT>
1811inline PROTOBUF_ALWAYS_INLINE
1812void Socket::set_socket_name(ArgT0&& arg0, ArgT... args) {
1813 _impl_._has_bits_[0] |= 0x00000004u;
1814 _impl_.socket_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1815 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.socket_name)
1816}
1817inline std::string* Socket::mutable_socket_name() {
1818 std::string* _s = _internal_mutable_socket_name();
1819 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.Socket.socket_name)
1820 return _s;
1821}
1822inline const std::string& Socket::_internal_socket_name() const {
1823 return _impl_.socket_name_.Get();
1824}
1825inline void Socket::_internal_set_socket_name(const std::string& value) {
1826 _impl_._has_bits_[0] |= 0x00000004u;
1827 _impl_.socket_name_.Set(value, GetArenaForAllocation());
1828}
1829inline std::string* Socket::_internal_mutable_socket_name() {
1830 _impl_._has_bits_[0] |= 0x00000004u;
1831 return _impl_.socket_name_.Mutable(GetArenaForAllocation());
1832}
1833inline std::string* Socket::release_socket_name() {
1834 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.Socket.socket_name)
1835 if (!_internal_has_socket_name()) {
1836 return nullptr;
1837 }
1838 _impl_._has_bits_[0] &= ~0x00000004u;
1839 auto* p = _impl_.socket_name_.Release();
1840#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1841 if (_impl_.socket_name_.IsDefault()) {
1842 _impl_.socket_name_.Set("", GetArenaForAllocation());
1843 }
1844#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1845 return p;
1846}
1847inline void Socket::set_allocated_socket_name(std::string* socket_name) {
1848 if (socket_name != nullptr) {
1849 _impl_._has_bits_[0] |= 0x00000004u;
1850 } else {
1851 _impl_._has_bits_[0] &= ~0x00000004u;
1852 }
1853 _impl_.socket_name_.SetAllocated(socket_name, GetArenaForAllocation());
1854#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1855 if (_impl_.socket_name_.IsDefault()) {
1856 _impl_.socket_name_.Set("", GetArenaForAllocation());
1857 }
1858#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1859 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.Socket.socket_name)
1860}
1861
1862// optional uint32 send_queue_size = 10 [default = 1000];
1863inline bool Socket::_internal_has_send_queue_size() const {
1864 bool value = (_impl_._has_bits_[0] & 0x00000100u) != 0;
1865 return value;
1866}
1867inline bool Socket::has_send_queue_size() const {
1868 return _internal_has_send_queue_size();
1869}
1870inline void Socket::clear_send_queue_size() {
1871 _impl_.send_queue_size_ = 1000u;
1872 _impl_._has_bits_[0] &= ~0x00000100u;
1873}
1874inline uint32_t Socket::_internal_send_queue_size() const {
1875 return _impl_.send_queue_size_;
1876}
1877inline uint32_t Socket::send_queue_size() const {
1878 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.send_queue_size)
1879 return _internal_send_queue_size();
1880}
1881inline void Socket::_internal_set_send_queue_size(uint32_t value) {
1882 _impl_._has_bits_[0] |= 0x00000100u;
1883 _impl_.send_queue_size_ = value;
1884}
1885inline void Socket::set_send_queue_size(uint32_t value) {
1886 _internal_set_send_queue_size(value);
1887 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.send_queue_size)
1888}
1889
1890// optional uint32 receive_queue_size = 11 [default = 1000];
1891inline bool Socket::_internal_has_receive_queue_size() const {
1892 bool value = (_impl_._has_bits_[0] & 0x00000200u) != 0;
1893 return value;
1894}
1895inline bool Socket::has_receive_queue_size() const {
1896 return _internal_has_receive_queue_size();
1897}
1898inline void Socket::clear_receive_queue_size() {
1899 _impl_.receive_queue_size_ = 1000u;
1900 _impl_._has_bits_[0] &= ~0x00000200u;
1901}
1902inline uint32_t Socket::_internal_receive_queue_size() const {
1903 return _impl_.receive_queue_size_;
1904}
1905inline uint32_t Socket::receive_queue_size() const {
1906 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.Socket.receive_queue_size)
1907 return _internal_receive_queue_size();
1908}
1909inline void Socket::_internal_set_receive_queue_size(uint32_t value) {
1910 _impl_._has_bits_[0] |= 0x00000200u;
1911 _impl_.receive_queue_size_ = value;
1912}
1913inline void Socket::set_receive_queue_size(uint32_t value) {
1914 _internal_set_receive_queue_size(value);
1915 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.Socket.receive_queue_size)
1916}
1917
1918// -------------------------------------------------------------------
1919
1920// ManagerResponse
1921
1922// required .goby.zeromq.protobuf.Request request = 1;
1923inline bool ManagerResponse::_internal_has_request() const {
1924 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
1925 return value;
1926}
1927inline bool ManagerResponse::has_request() const {
1928 return _internal_has_request();
1929}
1930inline void ManagerResponse::clear_request() {
1931 _impl_.request_ = 1;
1932 _impl_._has_bits_[0] &= ~0x00000010u;
1933}
1934inline ::goby::zeromq::protobuf::Request ManagerResponse::_internal_request() const {
1935 return static_cast< ::goby::zeromq::protobuf::Request >(_impl_.request_);
1936}
1937inline ::goby::zeromq::protobuf::Request ManagerResponse::request() const {
1938 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.request)
1939 return _internal_request();
1940}
1941inline void ManagerResponse::_internal_set_request(::goby::zeromq::protobuf::Request value) {
1942 assert(::goby::zeromq::protobuf::Request_IsValid(value));
1943 _impl_._has_bits_[0] |= 0x00000010u;
1944 _impl_.request_ = value;
1945}
1946inline void ManagerResponse::set_request(::goby::zeromq::protobuf::Request value) {
1947 _internal_set_request(value);
1948 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.request)
1949}
1950
1951// required string client_name = 2;
1952inline bool ManagerResponse::_internal_has_client_name() const {
1953 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
1954 return value;
1955}
1956inline bool ManagerResponse::has_client_name() const {
1957 return _internal_has_client_name();
1958}
1959inline void ManagerResponse::clear_client_name() {
1960 _impl_.client_name_.ClearToEmpty();
1961 _impl_._has_bits_[0] &= ~0x00000001u;
1962}
1963inline const std::string& ManagerResponse::client_name() const {
1964 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.client_name)
1965 return _internal_client_name();
1966}
1967template <typename ArgT0, typename... ArgT>
1968inline PROTOBUF_ALWAYS_INLINE
1969void ManagerResponse::set_client_name(ArgT0&& arg0, ArgT... args) {
1970 _impl_._has_bits_[0] |= 0x00000001u;
1971 _impl_.client_name_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
1972 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.client_name)
1973}
1974inline std::string* ManagerResponse::mutable_client_name() {
1975 std::string* _s = _internal_mutable_client_name();
1976 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.client_name)
1977 return _s;
1978}
1979inline const std::string& ManagerResponse::_internal_client_name() const {
1980 return _impl_.client_name_.Get();
1981}
1982inline void ManagerResponse::_internal_set_client_name(const std::string& value) {
1983 _impl_._has_bits_[0] |= 0x00000001u;
1984 _impl_.client_name_.Set(value, GetArenaForAllocation());
1985}
1986inline std::string* ManagerResponse::_internal_mutable_client_name() {
1987 _impl_._has_bits_[0] |= 0x00000001u;
1988 return _impl_.client_name_.Mutable(GetArenaForAllocation());
1989}
1990inline std::string* ManagerResponse::release_client_name() {
1991 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.client_name)
1992 if (!_internal_has_client_name()) {
1993 return nullptr;
1994 }
1995 _impl_._has_bits_[0] &= ~0x00000001u;
1996 auto* p = _impl_.client_name_.Release();
1997#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1998 if (_impl_.client_name_.IsDefault()) {
1999 _impl_.client_name_.Set("", GetArenaForAllocation());
2000 }
2001#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2002 return p;
2003}
2004inline void ManagerResponse::set_allocated_client_name(std::string* client_name) {
2005 if (client_name != nullptr) {
2006 _impl_._has_bits_[0] |= 0x00000001u;
2007 } else {
2008 _impl_._has_bits_[0] &= ~0x00000001u;
2009 }
2010 _impl_.client_name_.SetAllocated(client_name, GetArenaForAllocation());
2011#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2012 if (_impl_.client_name_.IsDefault()) {
2013 _impl_.client_name_.Set("", GetArenaForAllocation());
2014 }
2015#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2016 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.client_name)
2017}
2018
2019// required int32 client_pid = 3;
2020inline bool ManagerResponse::_internal_has_client_pid() const {
2021 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2022 return value;
2023}
2024inline bool ManagerResponse::has_client_pid() const {
2025 return _internal_has_client_pid();
2026}
2027inline void ManagerResponse::clear_client_pid() {
2028 _impl_.client_pid_ = 0;
2029 _impl_._has_bits_[0] &= ~0x00000008u;
2030}
2031inline int32_t ManagerResponse::_internal_client_pid() const {
2032 return _impl_.client_pid_;
2033}
2034inline int32_t ManagerResponse::client_pid() const {
2035 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.client_pid)
2036 return _internal_client_pid();
2037}
2038inline void ManagerResponse::_internal_set_client_pid(int32_t value) {
2039 _impl_._has_bits_[0] |= 0x00000008u;
2040 _impl_.client_pid_ = value;
2041}
2042inline void ManagerResponse::set_client_pid(int32_t value) {
2043 _internal_set_client_pid(value);
2044 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.client_pid)
2045}
2046
2047// optional .goby.zeromq.protobuf.Socket publish_socket = 4;
2048inline bool ManagerResponse::_internal_has_publish_socket() const {
2049 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2050 PROTOBUF_ASSUME(!value || _impl_.publish_socket_ != nullptr);
2051 return value;
2052}
2053inline bool ManagerResponse::has_publish_socket() const {
2054 return _internal_has_publish_socket();
2055}
2056inline void ManagerResponse::clear_publish_socket() {
2057 if (_impl_.publish_socket_ != nullptr) _impl_.publish_socket_->Clear();
2058 _impl_._has_bits_[0] &= ~0x00000002u;
2059}
2060inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_publish_socket() const {
2061 const ::goby::zeromq::protobuf::Socket* p = _impl_.publish_socket_;
2062 return p != nullptr ? *p : reinterpret_cast<const ::goby::zeromq::protobuf::Socket&>(
2063 ::goby::zeromq::protobuf::_Socket_default_instance_);
2064}
2065inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::publish_socket() const {
2066 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2067 return _internal_publish_socket();
2068}
2069inline void ManagerResponse::unsafe_arena_set_allocated_publish_socket(
2070 ::goby::zeromq::protobuf::Socket* publish_socket) {
2071 if (GetArenaForAllocation() == nullptr) {
2072 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.publish_socket_);
2073 }
2074 _impl_.publish_socket_ = publish_socket;
2075 if (publish_socket) {
2076 _impl_._has_bits_[0] |= 0x00000002u;
2077 } else {
2078 _impl_._has_bits_[0] &= ~0x00000002u;
2079 }
2080 // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2081}
2082inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_publish_socket() {
2083 _impl_._has_bits_[0] &= ~0x00000002u;
2084 ::goby::zeromq::protobuf::Socket* temp = _impl_.publish_socket_;
2085 _impl_.publish_socket_ = nullptr;
2086#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2087 auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
2088 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2089 if (GetArenaForAllocation() == nullptr) { delete old; }
2090#else // PROTOBUF_FORCE_COPY_IN_RELEASE
2091 if (GetArenaForAllocation() != nullptr) {
2092 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2093 }
2094#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
2095 return temp;
2096}
2097inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_publish_socket() {
2098 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2099 _impl_._has_bits_[0] &= ~0x00000002u;
2100 ::goby::zeromq::protobuf::Socket* temp = _impl_.publish_socket_;
2101 _impl_.publish_socket_ = nullptr;
2102 return temp;
2103}
2104inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_publish_socket() {
2105 _impl_._has_bits_[0] |= 0x00000002u;
2106 if (_impl_.publish_socket_ == nullptr) {
2107 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArenaForAllocation());
2108 _impl_.publish_socket_ = p;
2109 }
2110 return _impl_.publish_socket_;
2111}
2112inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_publish_socket() {
2113 ::goby::zeromq::protobuf::Socket* _msg = _internal_mutable_publish_socket();
2114 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2115 return _msg;
2116}
2117inline void ManagerResponse::set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket) {
2118 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2119 if (message_arena == nullptr) {
2120 delete _impl_.publish_socket_;
2121 }
2122 if (publish_socket) {
2123 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2124 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(publish_socket);
2125 if (message_arena != submessage_arena) {
2126 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2127 message_arena, publish_socket, submessage_arena);
2128 }
2129 _impl_._has_bits_[0] |= 0x00000002u;
2130 } else {
2131 _impl_._has_bits_[0] &= ~0x00000002u;
2132 }
2133 _impl_.publish_socket_ = publish_socket;
2134 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.publish_socket)
2135}
2136
2137// optional .goby.zeromq.protobuf.Socket subscribe_socket = 5;
2138inline bool ManagerResponse::_internal_has_subscribe_socket() const {
2139 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2140 PROTOBUF_ASSUME(!value || _impl_.subscribe_socket_ != nullptr);
2141 return value;
2142}
2143inline bool ManagerResponse::has_subscribe_socket() const {
2144 return _internal_has_subscribe_socket();
2145}
2146inline void ManagerResponse::clear_subscribe_socket() {
2147 if (_impl_.subscribe_socket_ != nullptr) _impl_.subscribe_socket_->Clear();
2148 _impl_._has_bits_[0] &= ~0x00000004u;
2149}
2150inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::_internal_subscribe_socket() const {
2151 const ::goby::zeromq::protobuf::Socket* p = _impl_.subscribe_socket_;
2152 return p != nullptr ? *p : reinterpret_cast<const ::goby::zeromq::protobuf::Socket&>(
2153 ::goby::zeromq::protobuf::_Socket_default_instance_);
2154}
2155inline const ::goby::zeromq::protobuf::Socket& ManagerResponse::subscribe_socket() const {
2156 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2157 return _internal_subscribe_socket();
2158}
2159inline void ManagerResponse::unsafe_arena_set_allocated_subscribe_socket(
2160 ::goby::zeromq::protobuf::Socket* subscribe_socket) {
2161 if (GetArenaForAllocation() == nullptr) {
2162 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.subscribe_socket_);
2163 }
2164 _impl_.subscribe_socket_ = subscribe_socket;
2165 if (subscribe_socket) {
2166 _impl_._has_bits_[0] |= 0x00000004u;
2167 } else {
2168 _impl_._has_bits_[0] &= ~0x00000004u;
2169 }
2170 // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2171}
2172inline ::goby::zeromq::protobuf::Socket* ManagerResponse::release_subscribe_socket() {
2173 _impl_._has_bits_[0] &= ~0x00000004u;
2174 ::goby::zeromq::protobuf::Socket* temp = _impl_.subscribe_socket_;
2175 _impl_.subscribe_socket_ = nullptr;
2176#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2177 auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
2178 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2179 if (GetArenaForAllocation() == nullptr) { delete old; }
2180#else // PROTOBUF_FORCE_COPY_IN_RELEASE
2181 if (GetArenaForAllocation() != nullptr) {
2182 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2183 }
2184#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
2185 return temp;
2186}
2187inline ::goby::zeromq::protobuf::Socket* ManagerResponse::unsafe_arena_release_subscribe_socket() {
2188 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2189 _impl_._has_bits_[0] &= ~0x00000004u;
2190 ::goby::zeromq::protobuf::Socket* temp = _impl_.subscribe_socket_;
2191 _impl_.subscribe_socket_ = nullptr;
2192 return temp;
2193}
2194inline ::goby::zeromq::protobuf::Socket* ManagerResponse::_internal_mutable_subscribe_socket() {
2195 _impl_._has_bits_[0] |= 0x00000004u;
2196 if (_impl_.subscribe_socket_ == nullptr) {
2197 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArenaForAllocation());
2198 _impl_.subscribe_socket_ = p;
2199 }
2200 return _impl_.subscribe_socket_;
2201}
2202inline ::goby::zeromq::protobuf::Socket* ManagerResponse::mutable_subscribe_socket() {
2203 ::goby::zeromq::protobuf::Socket* _msg = _internal_mutable_subscribe_socket();
2204 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2205 return _msg;
2206}
2207inline void ManagerResponse::set_allocated_subscribe_socket(::goby::zeromq::protobuf::Socket* subscribe_socket) {
2208 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2209 if (message_arena == nullptr) {
2210 delete _impl_.subscribe_socket_;
2211 }
2212 if (subscribe_socket) {
2213 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2214 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(subscribe_socket);
2215 if (message_arena != submessage_arena) {
2216 subscribe_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2217 message_arena, subscribe_socket, submessage_arena);
2218 }
2219 _impl_._has_bits_[0] |= 0x00000004u;
2220 } else {
2221 _impl_._has_bits_[0] &= ~0x00000004u;
2222 }
2223 _impl_.subscribe_socket_ = subscribe_socket;
2224 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.ManagerResponse.subscribe_socket)
2225}
2226
2227// optional bool hold = 6 [default = true, (.goby.field) = {
2228inline bool ManagerResponse::_internal_has_hold() const {
2229 bool value = (_impl_._has_bits_[0] & 0x00000020u) != 0;
2230 return value;
2231}
2232inline bool ManagerResponse::has_hold() const {
2233 return _internal_has_hold();
2234}
2235inline void ManagerResponse::clear_hold() {
2236 _impl_.hold_ = true;
2237 _impl_._has_bits_[0] &= ~0x00000020u;
2238}
2239inline bool ManagerResponse::_internal_hold() const {
2240 return _impl_.hold_;
2241}
2242inline bool ManagerResponse::hold() const {
2243 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.ManagerResponse.hold)
2244 return _internal_hold();
2245}
2246inline void ManagerResponse::_internal_set_hold(bool value) {
2247 _impl_._has_bits_[0] |= 0x00000020u;
2248 _impl_.hold_ = value;
2249}
2250inline void ManagerResponse::set_hold(bool value) {
2251 _internal_set_hold(value);
2252 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.ManagerResponse.hold)
2253}
2254
2255// -------------------------------------------------------------------
2256
2257// InprocControl
2258
2259// required .goby.zeromq.protobuf.InprocControl.InprocControlType type = 1;
2260inline bool InprocControl::_internal_has_type() const {
2261 bool value = (_impl_._has_bits_[0] & 0x00000010u) != 0;
2262 return value;
2263}
2264inline bool InprocControl::has_type() const {
2265 return _internal_has_type();
2266}
2267inline void InprocControl::clear_type() {
2268 _impl_.type_ = 1;
2269 _impl_._has_bits_[0] &= ~0x00000010u;
2270}
2271inline ::goby::zeromq::protobuf::InprocControl_InprocControlType InprocControl::_internal_type() const {
2272 return static_cast< ::goby::zeromq::protobuf::InprocControl_InprocControlType >(_impl_.type_);
2273}
2274inline ::goby::zeromq::protobuf::InprocControl_InprocControlType InprocControl::type() const {
2275 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.type)
2276 return _internal_type();
2277}
2278inline void InprocControl::_internal_set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value) {
2279 assert(::goby::zeromq::protobuf::InprocControl_InprocControlType_IsValid(value));
2280 _impl_._has_bits_[0] |= 0x00000010u;
2281 _impl_.type_ = value;
2282}
2283inline void InprocControl::set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value) {
2284 _internal_set_type(value);
2285 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.type)
2286}
2287
2288// optional .goby.zeromq.protobuf.Socket publish_socket = 2;
2289inline bool InprocControl::_internal_has_publish_socket() const {
2290 bool value = (_impl_._has_bits_[0] & 0x00000004u) != 0;
2291 PROTOBUF_ASSUME(!value || _impl_.publish_socket_ != nullptr);
2292 return value;
2293}
2294inline bool InprocControl::has_publish_socket() const {
2295 return _internal_has_publish_socket();
2296}
2297inline void InprocControl::clear_publish_socket() {
2298 if (_impl_.publish_socket_ != nullptr) _impl_.publish_socket_->Clear();
2299 _impl_._has_bits_[0] &= ~0x00000004u;
2300}
2301inline const ::goby::zeromq::protobuf::Socket& InprocControl::_internal_publish_socket() const {
2302 const ::goby::zeromq::protobuf::Socket* p = _impl_.publish_socket_;
2303 return p != nullptr ? *p : reinterpret_cast<const ::goby::zeromq::protobuf::Socket&>(
2304 ::goby::zeromq::protobuf::_Socket_default_instance_);
2305}
2306inline const ::goby::zeromq::protobuf::Socket& InprocControl::publish_socket() const {
2307 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.publish_socket)
2308 return _internal_publish_socket();
2309}
2310inline void InprocControl::unsafe_arena_set_allocated_publish_socket(
2311 ::goby::zeromq::protobuf::Socket* publish_socket) {
2312 if (GetArenaForAllocation() == nullptr) {
2313 delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.publish_socket_);
2314 }
2315 _impl_.publish_socket_ = publish_socket;
2316 if (publish_socket) {
2317 _impl_._has_bits_[0] |= 0x00000004u;
2318 } else {
2319 _impl_._has_bits_[0] &= ~0x00000004u;
2320 }
2321 // @@protoc_insertion_point(field_unsafe_arena_set_allocated:goby.zeromq.protobuf.InprocControl.publish_socket)
2322}
2323inline ::goby::zeromq::protobuf::Socket* InprocControl::release_publish_socket() {
2324 _impl_._has_bits_[0] &= ~0x00000004u;
2325 ::goby::zeromq::protobuf::Socket* temp = _impl_.publish_socket_;
2326 _impl_.publish_socket_ = nullptr;
2327#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
2328 auto* old = reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
2329 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2330 if (GetArenaForAllocation() == nullptr) { delete old; }
2331#else // PROTOBUF_FORCE_COPY_IN_RELEASE
2332 if (GetArenaForAllocation() != nullptr) {
2333 temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
2334 }
2335#endif // !PROTOBUF_FORCE_COPY_IN_RELEASE
2336 return temp;
2337}
2338inline ::goby::zeromq::protobuf::Socket* InprocControl::unsafe_arena_release_publish_socket() {
2339 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.publish_socket)
2340 _impl_._has_bits_[0] &= ~0x00000004u;
2341 ::goby::zeromq::protobuf::Socket* temp = _impl_.publish_socket_;
2342 _impl_.publish_socket_ = nullptr;
2343 return temp;
2344}
2345inline ::goby::zeromq::protobuf::Socket* InprocControl::_internal_mutable_publish_socket() {
2346 _impl_._has_bits_[0] |= 0x00000004u;
2347 if (_impl_.publish_socket_ == nullptr) {
2348 auto* p = CreateMaybeMessage<::goby::zeromq::protobuf::Socket>(GetArenaForAllocation());
2349 _impl_.publish_socket_ = p;
2350 }
2351 return _impl_.publish_socket_;
2352}
2353inline ::goby::zeromq::protobuf::Socket* InprocControl::mutable_publish_socket() {
2354 ::goby::zeromq::protobuf::Socket* _msg = _internal_mutable_publish_socket();
2355 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.publish_socket)
2356 return _msg;
2357}
2358inline void InprocControl::set_allocated_publish_socket(::goby::zeromq::protobuf::Socket* publish_socket) {
2359 ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
2360 if (message_arena == nullptr) {
2361 delete _impl_.publish_socket_;
2362 }
2363 if (publish_socket) {
2364 ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
2365 ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(publish_socket);
2366 if (message_arena != submessage_arena) {
2367 publish_socket = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
2368 message_arena, publish_socket, submessage_arena);
2369 }
2370 _impl_._has_bits_[0] |= 0x00000004u;
2371 } else {
2372 _impl_._has_bits_[0] &= ~0x00000004u;
2373 }
2374 _impl_.publish_socket_ = publish_socket;
2375 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.publish_socket)
2376}
2377
2378// optional bytes subscription_identifier = 3;
2379inline bool InprocControl::_internal_has_subscription_identifier() const {
2380 bool value = (_impl_._has_bits_[0] & 0x00000001u) != 0;
2381 return value;
2382}
2383inline bool InprocControl::has_subscription_identifier() const {
2384 return _internal_has_subscription_identifier();
2385}
2386inline void InprocControl::clear_subscription_identifier() {
2387 _impl_.subscription_identifier_.ClearToEmpty();
2388 _impl_._has_bits_[0] &= ~0x00000001u;
2389}
2390inline const std::string& InprocControl::subscription_identifier() const {
2391 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2392 return _internal_subscription_identifier();
2393}
2394template <typename ArgT0, typename... ArgT>
2395inline PROTOBUF_ALWAYS_INLINE
2396void InprocControl::set_subscription_identifier(ArgT0&& arg0, ArgT... args) {
2397 _impl_._has_bits_[0] |= 0x00000001u;
2398 _impl_.subscription_identifier_.SetBytes(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
2399 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2400}
2401inline std::string* InprocControl::mutable_subscription_identifier() {
2402 std::string* _s = _internal_mutable_subscription_identifier();
2403 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2404 return _s;
2405}
2406inline const std::string& InprocControl::_internal_subscription_identifier() const {
2407 return _impl_.subscription_identifier_.Get();
2408}
2409inline void InprocControl::_internal_set_subscription_identifier(const std::string& value) {
2410 _impl_._has_bits_[0] |= 0x00000001u;
2411 _impl_.subscription_identifier_.Set(value, GetArenaForAllocation());
2412}
2413inline std::string* InprocControl::_internal_mutable_subscription_identifier() {
2414 _impl_._has_bits_[0] |= 0x00000001u;
2415 return _impl_.subscription_identifier_.Mutable(GetArenaForAllocation());
2416}
2417inline std::string* InprocControl::release_subscription_identifier() {
2418 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2419 if (!_internal_has_subscription_identifier()) {
2420 return nullptr;
2421 }
2422 _impl_._has_bits_[0] &= ~0x00000001u;
2423 auto* p = _impl_.subscription_identifier_.Release();
2424#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2425 if (_impl_.subscription_identifier_.IsDefault()) {
2426 _impl_.subscription_identifier_.Set("", GetArenaForAllocation());
2427 }
2428#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2429 return p;
2430}
2431inline void InprocControl::set_allocated_subscription_identifier(std::string* subscription_identifier) {
2432 if (subscription_identifier != nullptr) {
2433 _impl_._has_bits_[0] |= 0x00000001u;
2434 } else {
2435 _impl_._has_bits_[0] &= ~0x00000001u;
2436 }
2437 _impl_.subscription_identifier_.SetAllocated(subscription_identifier, GetArenaForAllocation());
2438#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2439 if (_impl_.subscription_identifier_.IsDefault()) {
2440 _impl_.subscription_identifier_.Set("", GetArenaForAllocation());
2441 }
2442#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2443 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.subscription_identifier)
2444}
2445
2446// optional bytes received_data = 4;
2447inline bool InprocControl::_internal_has_received_data() const {
2448 bool value = (_impl_._has_bits_[0] & 0x00000002u) != 0;
2449 return value;
2450}
2451inline bool InprocControl::has_received_data() const {
2452 return _internal_has_received_data();
2453}
2454inline void InprocControl::clear_received_data() {
2455 _impl_.received_data_.ClearToEmpty();
2456 _impl_._has_bits_[0] &= ~0x00000002u;
2457}
2458inline const std::string& InprocControl::received_data() const {
2459 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.received_data)
2460 return _internal_received_data();
2461}
2462template <typename ArgT0, typename... ArgT>
2463inline PROTOBUF_ALWAYS_INLINE
2464void InprocControl::set_received_data(ArgT0&& arg0, ArgT... args) {
2465 _impl_._has_bits_[0] |= 0x00000002u;
2466 _impl_.received_data_.SetBytes(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
2467 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.received_data)
2468}
2469inline std::string* InprocControl::mutable_received_data() {
2470 std::string* _s = _internal_mutable_received_data();
2471 // @@protoc_insertion_point(field_mutable:goby.zeromq.protobuf.InprocControl.received_data)
2472 return _s;
2473}
2474inline const std::string& InprocControl::_internal_received_data() const {
2475 return _impl_.received_data_.Get();
2476}
2477inline void InprocControl::_internal_set_received_data(const std::string& value) {
2478 _impl_._has_bits_[0] |= 0x00000002u;
2479 _impl_.received_data_.Set(value, GetArenaForAllocation());
2480}
2481inline std::string* InprocControl::_internal_mutable_received_data() {
2482 _impl_._has_bits_[0] |= 0x00000002u;
2483 return _impl_.received_data_.Mutable(GetArenaForAllocation());
2484}
2485inline std::string* InprocControl::release_received_data() {
2486 // @@protoc_insertion_point(field_release:goby.zeromq.protobuf.InprocControl.received_data)
2487 if (!_internal_has_received_data()) {
2488 return nullptr;
2489 }
2490 _impl_._has_bits_[0] &= ~0x00000002u;
2491 auto* p = _impl_.received_data_.Release();
2492#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2493 if (_impl_.received_data_.IsDefault()) {
2494 _impl_.received_data_.Set("", GetArenaForAllocation());
2495 }
2496#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2497 return p;
2498}
2499inline void InprocControl::set_allocated_received_data(std::string* received_data) {
2500 if (received_data != nullptr) {
2501 _impl_._has_bits_[0] |= 0x00000002u;
2502 } else {
2503 _impl_._has_bits_[0] &= ~0x00000002u;
2504 }
2505 _impl_.received_data_.SetAllocated(received_data, GetArenaForAllocation());
2506#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
2507 if (_impl_.received_data_.IsDefault()) {
2508 _impl_.received_data_.Set("", GetArenaForAllocation());
2509 }
2510#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
2511 // @@protoc_insertion_point(field_set_allocated:goby.zeromq.protobuf.InprocControl.received_data)
2512}
2513
2514// optional bool hold = 10;
2515inline bool InprocControl::_internal_has_hold() const {
2516 bool value = (_impl_._has_bits_[0] & 0x00000008u) != 0;
2517 return value;
2518}
2519inline bool InprocControl::has_hold() const {
2520 return _internal_has_hold();
2521}
2522inline void InprocControl::clear_hold() {
2523 _impl_.hold_ = false;
2524 _impl_._has_bits_[0] &= ~0x00000008u;
2525}
2526inline bool InprocControl::_internal_hold() const {
2527 return _impl_.hold_;
2528}
2529inline bool InprocControl::hold() const {
2530 // @@protoc_insertion_point(field_get:goby.zeromq.protobuf.InprocControl.hold)
2531 return _internal_hold();
2532}
2533inline void InprocControl::_internal_set_hold(bool value) {
2534 _impl_._has_bits_[0] |= 0x00000008u;
2535 _impl_.hold_ = value;
2536}
2537inline void InprocControl::set_hold(bool value) {
2538 _internal_set_hold(value);
2539 // @@protoc_insertion_point(field_set:goby.zeromq.protobuf.InprocControl.hold)
2540}
2541
2542#ifdef __GNUC__
2543 #pragma GCC diagnostic pop
2544#endif // __GNUC__
2545// -------------------------------------------------------------------
2546
2547// -------------------------------------------------------------------
2548
2549// -------------------------------------------------------------------
2550
2551
2552// @@protoc_insertion_point(namespace_scope)
2553
2554} // namespace protobuf
2555} // namespace zeromq
2556} // namespace goby
2557
2558PROTOBUF_NAMESPACE_OPEN
2559
2560template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_SocketType> : ::std::true_type {};
2561template <>
2562inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType>() {
2563 return ::goby::zeromq::protobuf::Socket_SocketType_descriptor();
2564}
2565template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_Transport> : ::std::true_type {};
2566template <>
2567inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport>() {
2568 return ::goby::zeromq::protobuf::Socket_Transport_descriptor();
2569}
2570template <> struct is_proto_enum< ::goby::zeromq::protobuf::Socket_ConnectOrBind> : ::std::true_type {};
2571template <>
2572inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind>() {
2573 return ::goby::zeromq::protobuf::Socket_ConnectOrBind_descriptor();
2574}
2575template <> struct is_proto_enum< ::goby::zeromq::protobuf::InprocControl_InprocControlType> : ::std::true_type {};
2576template <>
2577inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType>() {
2578 return ::goby::zeromq::protobuf::InprocControl_InprocControlType_descriptor();
2579}
2580template <> struct is_proto_enum< ::goby::zeromq::protobuf::Request> : ::std::true_type {};
2581template <>
2582inline const EnumDescriptor* GetEnumDescriptor< ::goby::zeromq::protobuf::Request>() {
2583 return ::goby::zeromq::protobuf::Request_descriptor();
2584}
2585
2586PROTOBUF_NAMESPACE_CLOSE
2587
2588// @@protoc_insertion_point(global_scope)
2589
2590#include <google/protobuf/port_undef.inc>
2591#endif // GOOGLE_PROTOBUF_INCLUDED_GOOGLE_PROTOBUF_INCLUDED_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
goby::zeromq::protobuf::InprocControl::CopyFrom
void CopyFrom(const InprocControl &from)
goby::zeromq::protobuf::InprocControl::release_subscription_identifier
PROTOBUF_NODISCARD std::string * release_subscription_identifier()
Definition interprocess_zeromq.pb.h:2417
goby::zeromq::protobuf::InprocControl::set_allocated_subscription_identifier
void set_allocated_subscription_identifier(std::string *subscription_identifier)
Definition interprocess_zeromq.pb.h:2431
goby::zeromq::protobuf::InprocControl::set_type
void set_type(::goby::zeromq::protobuf::InprocControl_InprocControlType value)
Definition interprocess_zeromq.pb.h:2283
goby::zeromq::protobuf::InprocControl::unsafe_arena_set_allocated_publish_socket
void unsafe_arena_set_allocated_publish_socket(::goby::zeromq::protobuf::Socket *publish_socket)
Definition interprocess_zeromq.pb.h:2310
goby::zeromq::protobuf::InprocControl::SHUTDOWN
static constexpr InprocControlType SHUTDOWN
Definition interprocess_zeromq.pb.h:1226
goby::zeromq::protobuf::InprocControl::InprocControl
PROTOBUF_CONSTEXPR InprocControl(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
goby::zeromq::protobuf::InprocControl::GetReflection
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition interprocess_zeromq.pb.h:1132
goby::zeromq::protobuf::InprocControl::REQUEST_HOLD_STATE
static constexpr InprocControlType REQUEST_HOLD_STATE
Definition interprocess_zeromq.pb.h:1228
goby::zeromq::protobuf::InprocControl::subscription_identifier
const std::string & subscription_identifier() const
Definition interprocess_zeromq.pb.h:2390
goby::zeromq::protobuf::InprocControl::GetMetadata
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
goby::zeromq::protobuf::InprocControl::Clear
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
goby::zeromq::protobuf::InprocControl::swap
friend void swap(InprocControl &a, InprocControl &b)
Definition interprocess_zeromq.pb.h:1145
goby::zeromq::protobuf::InprocControl::operator=
InprocControl & operator=(InprocControl &&from) noexcept
Definition interprocess_zeromq.pb.h:1105
goby::zeromq::protobuf::InprocControl::release_received_data
PROTOBUF_NODISCARD std::string * release_received_data()
Definition interprocess_zeromq.pb.h:2485
goby::zeromq::protobuf::InprocControl::InprocControlType_Parse
static bool InprocControlType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, InprocControlType *value)
Definition interprocess_zeromq.pb.h:1252
goby::zeromq::protobuf::InprocControl::mutable_publish_socket
::goby::zeromq::protobuf::Socket * mutable_publish_socket()
Definition interprocess_zeromq.pb.h:2353
goby::zeromq::protobuf::InprocControl::InprocControlType_MAX
static constexpr InprocControlType InprocControlType_MAX
Definition interprocess_zeromq.pb.h:1237
goby::zeromq::protobuf::InprocControl::MergeFrom
void MergeFrom(const InprocControl &from)
Definition interprocess_zeromq.pb.h:1175
goby::zeromq::protobuf::InprocControl::InprocControlType_descriptor
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControlType_descriptor()
Definition interprocess_zeromq.pb.h:1242
goby::zeromq::protobuf::InprocControl::RECEIVE
static constexpr InprocControlType RECEIVE
Definition interprocess_zeromq.pb.h:1224
goby::zeromq::protobuf::InprocControl::release_publish_socket
PROTOBUF_NODISCARD::goby::zeromq::protobuf::Socket * release_publish_socket()
Definition interprocess_zeromq.pb.h:2323
goby::zeromq::protobuf::InprocControl::_InternalSerialize
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
goby::zeromq::protobuf::InprocControl::SUBSCRIBE_ACK
static constexpr InprocControlType SUBSCRIBE_ACK
Definition interprocess_zeromq.pb.h:1218
goby::zeromq::protobuf::InprocControl::UNSUBSCRIBE_ACK
static constexpr InprocControlType UNSUBSCRIBE_ACK
Definition interprocess_zeromq.pb.h:1222
goby::zeromq::protobuf::InprocControl::set_subscription_identifier
void set_subscription_identifier(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::InprocControl::type
::goby::zeromq::protobuf::InprocControl_InprocControlType type() const
Definition interprocess_zeromq.pb.h:2274
goby::zeromq::protobuf::InprocControl::set_allocated_publish_socket
void set_allocated_publish_socket(::goby::zeromq::protobuf::Socket *publish_socket)
Definition interprocess_zeromq.pb.h:2358
goby::zeromq::protobuf::InprocControl::InprocControl
InprocControl(const InprocControl &from)
goby::zeromq::protobuf::InprocControl::set_received_data
void set_received_data(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::InprocControl::internal_default_instance
static const InprocControl * internal_default_instance()
Definition interprocess_zeromq.pb.h:1138
goby::zeromq::protobuf::InprocControl::GetClassData
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
goby::zeromq::protobuf::InprocControl::default_instance
static const InprocControl & default_instance()
Definition interprocess_zeromq.pb.h:1135
goby::zeromq::protobuf::InprocControl::GetDescriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition interprocess_zeromq.pb.h:1129
goby::zeromq::protobuf::InprocControl::operator=
InprocControl & operator=(const InprocControl &from)
Definition interprocess_zeromq.pb.h:1101
goby::zeromq::protobuf::InprocControl::unknown_fields
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition interprocess_zeromq.pb.h:1119
goby::zeromq::protobuf::InprocControl::New
InprocControl * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition interprocess_zeromq.pb.h:1169
goby::zeromq::protobuf::InprocControl::PUB_CONFIGURATION
static constexpr InprocControlType PUB_CONFIGURATION
Definition interprocess_zeromq.pb.h:1214
goby::zeromq::protobuf::InprocControl::InprocControlType_MIN
static constexpr InprocControlType InprocControlType_MIN
Definition interprocess_zeromq.pb.h:1235
goby::zeromq::protobuf::InprocControl::InprocControl
InprocControl(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
goby::zeromq::protobuf::InprocControl::_InternalParse
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
goby::zeromq::protobuf::InprocControl::NOTIFY_HOLD_STATE
static constexpr InprocControlType NOTIFY_HOLD_STATE
Definition interprocess_zeromq.pb.h:1230
goby::zeromq::protobuf::InprocControl::set_allocated_received_data
void set_allocated_received_data(std::string *received_data)
Definition interprocess_zeromq.pb.h:2499
goby::zeromq::protobuf::InprocControl::UNSUBSCRIBE
static constexpr InprocControlType UNSUBSCRIBE
Definition interprocess_zeromq.pb.h:1220
goby::zeromq::protobuf::InprocControl::InprocControlType
InprocControl_InprocControlType InprocControlType
Definition interprocess_zeromq.pb.h:1213
goby::zeromq::protobuf::InprocControl::mutable_unknown_fields
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition interprocess_zeromq.pb.h:1122
goby::zeromq::protobuf::InprocControl::publish_socket
const ::goby::zeromq::protobuf::Socket & publish_socket() const
Definition interprocess_zeromq.pb.h:2306
goby::zeromq::protobuf::InprocControl::descriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition interprocess_zeromq.pb.h:1126
goby::zeromq::protobuf::InprocControl::SUBSCRIBE
static constexpr InprocControlType SUBSCRIBE
Definition interprocess_zeromq.pb.h:1216
goby::zeromq::protobuf::InprocControl::InprocControl
InprocControl(InprocControl &&from) noexcept
Definition interprocess_zeromq.pb.h:1096
goby::zeromq::protobuf::InprocControl::InprocControlType_Name
static const std::string & InprocControlType_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:1246
goby::zeromq::protobuf::InprocControl::unsafe_arena_release_publish_socket
::goby::zeromq::protobuf::Socket * unsafe_arena_release_publish_socket()
Definition interprocess_zeromq.pb.h:2338
goby::zeromq::protobuf::ManagerRequest::mutable_unknown_fields
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition interprocess_zeromq.pb.h:244
goby::zeromq::protobuf::ManagerRequest::swap
friend void swap(ManagerRequest &a, ManagerRequest &b)
Definition interprocess_zeromq.pb.h:267
goby::zeromq::protobuf::ManagerRequest::set_client_name
void set_client_name(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::ManagerRequest::CopyFrom
void CopyFrom(const ManagerRequest &from)
goby::zeromq::protobuf::ManagerRequest::GetDescriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition interprocess_zeromq.pb.h:251
goby::zeromq::protobuf::ManagerRequest::set_allocated_client_name
void set_allocated_client_name(std::string *client_name)
Definition interprocess_zeromq.pb.h:1458
goby::zeromq::protobuf::ManagerRequest::operator=
ManagerRequest & operator=(ManagerRequest &&from) noexcept
Definition interprocess_zeromq.pb.h:227
goby::zeromq::protobuf::ManagerRequest::release_client_name
PROTOBUF_NODISCARD std::string * release_client_name()
Definition interprocess_zeromq.pb.h:1444
goby::zeromq::protobuf::ManagerRequest::request
::goby::zeromq::protobuf::Request request() const
Definition interprocess_zeromq.pb.h:1391
goby::zeromq::protobuf::ManagerRequest::Clear
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
goby::zeromq::protobuf::ManagerRequest::set_request
void set_request(::goby::zeromq::protobuf::Request value)
Definition interprocess_zeromq.pb.h:1400
goby::zeromq::protobuf::ManagerRequest::ManagerRequest
ManagerRequest(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
goby::zeromq::protobuf::ManagerRequest::descriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition interprocess_zeromq.pb.h:248
goby::zeromq::protobuf::ManagerRequest::operator=
ManagerRequest & operator=(const ManagerRequest &from)
Definition interprocess_zeromq.pb.h:223
goby::zeromq::protobuf::ManagerRequest::MergeFrom
void MergeFrom(const ManagerRequest &from)
Definition interprocess_zeromq.pb.h:297
goby::zeromq::protobuf::ManagerRequest::unknown_fields
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition interprocess_zeromq.pb.h:241
goby::zeromq::protobuf::ManagerRequest::default_instance
static const ManagerRequest & default_instance()
Definition interprocess_zeromq.pb.h:257
goby::zeromq::protobuf::ManagerRequest::internal_default_instance
static const ManagerRequest * internal_default_instance()
Definition interprocess_zeromq.pb.h:260
goby::zeromq::protobuf::ManagerRequest::ManagerRequest
ManagerRequest(ManagerRequest &&from) noexcept
Definition interprocess_zeromq.pb.h:218
goby::zeromq::protobuf::ManagerRequest::GetReflection
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition interprocess_zeromq.pb.h:254
goby::zeromq::protobuf::ManagerRequest::_InternalSerialize
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
goby::zeromq::protobuf::ManagerRequest::ManagerRequest
PROTOBUF_CONSTEXPR ManagerRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
goby::zeromq::protobuf::ManagerRequest::GetMetadata
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
goby::zeromq::protobuf::ManagerRequest::New
ManagerRequest * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition interprocess_zeromq.pb.h:291
goby::zeromq::protobuf::ManagerRequest::_InternalParse
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
goby::zeromq::protobuf::ManagerRequest::ManagerRequest
ManagerRequest(const ManagerRequest &from)
goby::zeromq::protobuf::ManagerRequest::GetClassData
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
goby::zeromq::protobuf::ManagerResponse::New
ManagerResponse * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition interprocess_zeromq.pb.h:916
goby::zeromq::protobuf::ManagerResponse::descriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition interprocess_zeromq.pb.h:873
goby::zeromq::protobuf::ManagerResponse::GetClassData
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
goby::zeromq::protobuf::ManagerResponse::swap
friend void swap(ManagerResponse &a, ManagerResponse &b)
Definition interprocess_zeromq.pb.h:892
goby::zeromq::protobuf::ManagerResponse::unknown_fields
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition interprocess_zeromq.pb.h:866
goby::zeromq::protobuf::ManagerResponse::operator=
ManagerResponse & operator=(ManagerResponse &&from) noexcept
Definition interprocess_zeromq.pb.h:852
goby::zeromq::protobuf::ManagerResponse::mutable_publish_socket
::goby::zeromq::protobuf::Socket * mutable_publish_socket()
Definition interprocess_zeromq.pb.h:2112
goby::zeromq::protobuf::ManagerResponse::ManagerResponse
ManagerResponse(ManagerResponse &&from) noexcept
Definition interprocess_zeromq.pb.h:843
goby::zeromq::protobuf::ManagerResponse::set_allocated_publish_socket
void set_allocated_publish_socket(::goby::zeromq::protobuf::Socket *publish_socket)
Definition interprocess_zeromq.pb.h:2117
goby::zeromq::protobuf::ManagerResponse::subscribe_socket
const ::goby::zeromq::protobuf::Socket & subscribe_socket() const
Definition interprocess_zeromq.pb.h:2155
goby::zeromq::protobuf::ManagerResponse::publish_socket
const ::goby::zeromq::protobuf::Socket & publish_socket() const
Definition interprocess_zeromq.pb.h:2065
goby::zeromq::protobuf::ManagerResponse::internal_default_instance
static const ManagerResponse * internal_default_instance()
Definition interprocess_zeromq.pb.h:885
goby::zeromq::protobuf::ManagerResponse::GetMetadata
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
goby::zeromq::protobuf::ManagerResponse::release_publish_socket
PROTOBUF_NODISCARD::goby::zeromq::protobuf::Socket * release_publish_socket()
Definition interprocess_zeromq.pb.h:2082
goby::zeromq::protobuf::ManagerResponse::GetDescriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition interprocess_zeromq.pb.h:876
goby::zeromq::protobuf::ManagerResponse::ManagerResponse
ManagerResponse(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
goby::zeromq::protobuf::ManagerResponse::unsafe_arena_set_allocated_publish_socket
void unsafe_arena_set_allocated_publish_socket(::goby::zeromq::protobuf::Socket *publish_socket)
Definition interprocess_zeromq.pb.h:2069
goby::zeromq::protobuf::ManagerResponse::CopyFrom
void CopyFrom(const ManagerResponse &from)
goby::zeromq::protobuf::ManagerResponse::ManagerResponse
PROTOBUF_CONSTEXPR ManagerResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
goby::zeromq::protobuf::ManagerResponse::mutable_unknown_fields
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition interprocess_zeromq.pb.h:869
goby::zeromq::protobuf::ManagerResponse::unsafe_arena_set_allocated_subscribe_socket
void unsafe_arena_set_allocated_subscribe_socket(::goby::zeromq::protobuf::Socket *subscribe_socket)
Definition interprocess_zeromq.pb.h:2159
goby::zeromq::protobuf::ManagerResponse::set_allocated_subscribe_socket
void set_allocated_subscribe_socket(::goby::zeromq::protobuf::Socket *subscribe_socket)
Definition interprocess_zeromq.pb.h:2207
goby::zeromq::protobuf::ManagerResponse::set_client_name
void set_client_name(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::ManagerResponse::_InternalParse
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
goby::zeromq::protobuf::ManagerResponse::default_instance
static const ManagerResponse & default_instance()
Definition interprocess_zeromq.pb.h:882
goby::zeromq::protobuf::ManagerResponse::set_request
void set_request(::goby::zeromq::protobuf::Request value)
Definition interprocess_zeromq.pb.h:1946
goby::zeromq::protobuf::ManagerResponse::request
::goby::zeromq::protobuf::Request request() const
Definition interprocess_zeromq.pb.h:1937
goby::zeromq::protobuf::ManagerResponse::operator=
ManagerResponse & operator=(const ManagerResponse &from)
Definition interprocess_zeromq.pb.h:848
goby::zeromq::protobuf::ManagerResponse::MergeFrom
void MergeFrom(const ManagerResponse &from)
Definition interprocess_zeromq.pb.h:922
goby::zeromq::protobuf::ManagerResponse::unsafe_arena_release_subscribe_socket
::goby::zeromq::protobuf::Socket * unsafe_arena_release_subscribe_socket()
Definition interprocess_zeromq.pb.h:2187
goby::zeromq::protobuf::ManagerResponse::GetReflection
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition interprocess_zeromq.pb.h:879
goby::zeromq::protobuf::ManagerResponse::ManagerResponse
ManagerResponse(const ManagerResponse &from)
goby::zeromq::protobuf::ManagerResponse::mutable_subscribe_socket
::goby::zeromq::protobuf::Socket * mutable_subscribe_socket()
Definition interprocess_zeromq.pb.h:2202
goby::zeromq::protobuf::ManagerResponse::release_client_name
PROTOBUF_NODISCARD std::string * release_client_name()
Definition interprocess_zeromq.pb.h:1990
goby::zeromq::protobuf::ManagerResponse::release_subscribe_socket
PROTOBUF_NODISCARD::goby::zeromq::protobuf::Socket * release_subscribe_socket()
Definition interprocess_zeromq.pb.h:2172
goby::zeromq::protobuf::ManagerResponse::set_allocated_client_name
void set_allocated_client_name(std::string *client_name)
Definition interprocess_zeromq.pb.h:2004
goby::zeromq::protobuf::ManagerResponse::_InternalSerialize
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
goby::zeromq::protobuf::ManagerResponse::unsafe_arena_release_publish_socket
::goby::zeromq::protobuf::Socket * unsafe_arena_release_publish_socket()
Definition interprocess_zeromq.pb.h:2097
goby::zeromq::protobuf::ManagerResponse::Clear
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
goby::zeromq::protobuf::Socket::Socket
Socket(::PROTOBUF_NAMESPACE_ID::Arena *arena, bool is_message_owned=false)
goby::zeromq::protobuf::Socket::set_allocated_multicast_address
void set_allocated_multicast_address(std::string *multicast_address)
Definition interprocess_zeromq.pb.h:1756
goby::zeromq::protobuf::Socket::unknown_fields
const ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet & unknown_fields() const
Definition interprocess_zeromq.pb.h:454
goby::zeromq::protobuf::Socket::ConnectOrBind_MIN
static constexpr ConnectOrBind ConnectOrBind_MIN
Definition interprocess_zeromq.pb.h:626
goby::zeromq::protobuf::Socket::Clear
PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final
goby::zeromq::protobuf::Socket::set_connect_or_bind
void set_connect_or_bind(::goby::zeromq::protobuf::Socket_ConnectOrBind value)
Definition interprocess_zeromq.pb.h:1643
goby::zeromq::protobuf::Socket::IsInitialized
bool IsInitialized() const final
goby::zeromq::protobuf::Socket::Socket
Socket(const Socket &from)
goby::zeromq::protobuf::Socket::descriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * descriptor()
Definition interprocess_zeromq.pb.h:461
goby::zeromq::protobuf::Socket::GetDescriptor
static const ::PROTOBUF_NAMESPACE_ID::Descriptor * GetDescriptor()
Definition interprocess_zeromq.pb.h:464
goby::zeromq::protobuf::Socket::set_ethernet_address
void set_ethernet_address(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::Socket::New
Socket * New(::PROTOBUF_NAMESPACE_ID::Arena *arena=nullptr) const final
Definition interprocess_zeromq.pb.h:504
goby::zeromq::protobuf::Socket::ConnectOrBind_descriptor
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * ConnectOrBind_descriptor()
Definition interprocess_zeromq.pb.h:633
goby::zeromq::protobuf::Socket::_InternalParse
const char * _InternalParse(const char *ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext *ctx) final
goby::zeromq::protobuf::Socket::ConnectOrBind_Parse
static bool ConnectOrBind_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, ConnectOrBind *value)
Definition interprocess_zeromq.pb.h:643
goby::zeromq::protobuf::Socket::operator=
Socket & operator=(const Socket &from)
Definition interprocess_zeromq.pb.h:436
goby::zeromq::protobuf::Socket::default_instance
static const Socket & default_instance()
Definition interprocess_zeromq.pb.h:470
goby::zeromq::protobuf::Socket::set_socket_type
void set_socket_type(::goby::zeromq::protobuf::Socket_SocketType value)
Definition interprocess_zeromq.pb.h:1557
goby::zeromq::protobuf::Socket::BIND
static constexpr ConnectOrBind BIND
Definition interprocess_zeromq.pb.h:621
goby::zeromq::protobuf::Socket::internal_default_instance
static const Socket * internal_default_instance()
Definition interprocess_zeromq.pb.h:473
goby::zeromq::protobuf::Socket::Transport_Name
static const std::string & Transport_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:607
goby::zeromq::protobuf::Socket::SocketType_descriptor
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * SocketType_descriptor()
Definition interprocess_zeromq.pb.h:567
goby::zeromq::protobuf::Socket::GetReflection
static const ::PROTOBUF_NAMESPACE_ID::Reflection * GetReflection()
Definition interprocess_zeromq.pb.h:467
goby::zeromq::protobuf::Socket::set_transport
void set_transport(::goby::zeromq::protobuf::Socket_Transport value)
Definition interprocess_zeromq.pb.h:1614
goby::zeromq::protobuf::Socket::ConnectOrBind_MAX
static constexpr ConnectOrBind ConnectOrBind_MAX
Definition interprocess_zeromq.pb.h:628
goby::zeromq::protobuf::Socket::REPLY
static constexpr SocketType REPLY
Definition interprocess_zeromq.pb.h:553
goby::zeromq::protobuf::Socket::SocketType_MAX
static constexpr SocketType SocketType_MAX
Definition interprocess_zeromq.pb.h:562
goby::zeromq::protobuf::Socket::set_multicast_address
void set_multicast_address(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::Socket::connect_or_bind
::goby::zeromq::protobuf::Socket_ConnectOrBind connect_or_bind() const
Definition interprocess_zeromq.pb.h:1634
goby::zeromq::protobuf::Socket::Transport_MAX
static constexpr Transport Transport_MAX
Definition interprocess_zeromq.pb.h:598
goby::zeromq::protobuf::Socket::release_ethernet_address
PROTOBUF_NODISCARD std::string * release_ethernet_address()
Definition interprocess_zeromq.pb.h:1688
goby::zeromq::protobuf::Socket::operator=
Socket & operator=(Socket &&from) noexcept
Definition interprocess_zeromq.pb.h:440
goby::zeromq::protobuf::Socket::ConnectOrBind_Name
static const std::string & ConnectOrBind_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:637
goby::zeromq::protobuf::Socket::INPROC
static constexpr Transport INPROC
Definition interprocess_zeromq.pb.h:583
goby::zeromq::protobuf::Socket::socket_name
const std::string & socket_name() const
Definition interprocess_zeromq.pb.h:1806
goby::zeromq::protobuf::Socket::CONNECT
static constexpr ConnectOrBind CONNECT
Definition interprocess_zeromq.pb.h:619
goby::zeromq::protobuf::Socket::Transport_MIN
static constexpr Transport Transport_MIN
Definition interprocess_zeromq.pb.h:596
goby::zeromq::protobuf::Socket::mutable_unknown_fields
inline ::PROTOBUF_NAMESPACE_ID::UnknownFieldSet * mutable_unknown_fields()
Definition interprocess_zeromq.pb.h:457
goby::zeromq::protobuf::Socket::PUBLISH
static constexpr SocketType PUBLISH
Definition interprocess_zeromq.pb.h:549
goby::zeromq::protobuf::Socket::set_allocated_socket_name
void set_allocated_socket_name(std::string *socket_name)
Definition interprocess_zeromq.pb.h:1847
goby::zeromq::protobuf::Socket::ConnectOrBind_IsValid
static bool ConnectOrBind_IsValid(int value)
Definition interprocess_zeromq.pb.h:623
goby::zeromq::protobuf::Socket::release_multicast_address
PROTOBUF_NODISCARD std::string * release_multicast_address()
Definition interprocess_zeromq.pb.h:1747
goby::zeromq::protobuf::Socket::set_allocated_ethernet_address
void set_allocated_ethernet_address(std::string *ethernet_address)
Definition interprocess_zeromq.pb.h:1697
goby::zeromq::protobuf::Socket::SocketType_Name
static const std::string & SocketType_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:571
goby::zeromq::protobuf::Socket::GetMetadata
::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final
goby::zeromq::protobuf::Socket::ByteSizeLong
size_t ByteSizeLong() const final
goby::zeromq::protobuf::Socket::GetClassData
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData * GetClassData() const final
goby::zeromq::protobuf::Socket::Transport_descriptor
static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Transport_descriptor()
Definition interprocess_zeromq.pb.h:603
goby::zeromq::protobuf::Socket::ethernet_address
const std::string & ethernet_address() const
Definition interprocess_zeromq.pb.h:1660
goby::zeromq::protobuf::Socket::release_socket_name
PROTOBUF_NODISCARD std::string * release_socket_name()
Definition interprocess_zeromq.pb.h:1833
goby::zeromq::protobuf::Socket::SocketType_MIN
static constexpr SocketType SocketType_MIN
Definition interprocess_zeromq.pb.h:560
goby::zeromq::protobuf::Socket::CopyFrom
void CopyFrom(const Socket &from)
goby::zeromq::protobuf::Socket::SocketType_Parse
static bool SocketType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, SocketType *value)
Definition interprocess_zeromq.pb.h:577
goby::zeromq::protobuf::Socket::REQUEST
static constexpr SocketType REQUEST
Definition interprocess_zeromq.pb.h:555
goby::zeromq::protobuf::Socket::swap
friend void swap(Socket &a, Socket &b)
Definition interprocess_zeromq.pb.h:480
goby::zeromq::protobuf::Socket::multicast_address
const std::string & multicast_address() const
Definition interprocess_zeromq.pb.h:1719
goby::zeromq::protobuf::Socket::Transport_Parse
static bool Transport_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Transport *value)
Definition interprocess_zeromq.pb.h:613
goby::zeromq::protobuf::Socket::set_socket_name
void set_socket_name(ArgT0 &&arg0, ArgT... args)
goby::zeromq::protobuf::Socket::transport
::goby::zeromq::protobuf::Socket_Transport transport() const
Definition interprocess_zeromq.pb.h:1605
goby::zeromq::protobuf::Socket::_InternalSerialize
uint8_t * _InternalSerialize(uint8_t *target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream *stream) const final
goby::zeromq::protobuf::Socket::Socket
PROTOBUF_CONSTEXPR Socket(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized)
goby::zeromq::protobuf::Socket::SUBSCRIBE
static constexpr SocketType SUBSCRIBE
Definition interprocess_zeromq.pb.h:551
goby::zeromq::protobuf::Socket::SocketType_IsValid
static bool SocketType_IsValid(int value)
Definition interprocess_zeromq.pb.h:557
goby::zeromq::protobuf::Socket::socket_type
::goby::zeromq::protobuf::Socket_SocketType socket_type() const
Definition interprocess_zeromq.pb.h:1548
GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType >
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_SocketType >()
Definition interprocess_zeromq.pb.h:2562
GetEnumDescriptor< ::goby::zeromq::protobuf::Request >
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Request >()
Definition interprocess_zeromq.pb.h:2582
GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport >
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_Transport >()
Definition interprocess_zeromq.pb.h:2567
descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType >
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::InprocControl_InprocControlType >()
Definition interprocess_zeromq.pb.h:2577
CreateMaybeMessage<::goby::zeromq::protobuf::Socket >
::goby::zeromq::protobuf::Socket * Arena::CreateMaybeMessage<::goby::zeromq::protobuf::Socket >(Arena *)
GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind >
const EnumDescriptor * GetEnumDescriptor< ::goby::zeromq::protobuf::Socket_ConnectOrBind >()
Definition interprocess_zeromq.pb.h:2572
b
*brief create JSON pointer *sa reference_tokens const string_t const string_t & b
Definition json.hpp:14577
a
*brief create JSON pointer *sa reference_tokens const string_t & a
Definition json.hpp:14576
nullptr
*brief remove last reference token *sa JSON pointer has no nullptr
Definition json.hpp:14667
ptr
*brief write string representation of the JSON pointer to stream *sa const json_pointer & ptr
Definition json.hpp:14594
goby::zeromq::protobuf::Socket_SocketType_SocketType_MIN
constexpr Socket_SocketType Socket_SocketType_SocketType_MIN
Definition interprocess_zeromq.pb.h:88
goby::zeromq::protobuf::Request_descriptor
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Request_descriptor()
goby::zeromq::protobuf::Socket_SocketType_descriptor
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_SocketType_descriptor()
goby::zeromq::protobuf::_ManagerRequest_default_instance_
ManagerRequestDefaultTypeInternal _ManagerRequest_default_instance_
goby::zeromq::protobuf::Socket_SocketType_IsValid
bool Socket_SocketType_IsValid(int value)
goby::zeromq::protobuf::Socket_Transport_IsValid
bool Socket_Transport_IsValid(int value)
goby::zeromq::protobuf::Socket_ConnectOrBind_Name
const std::string & Socket_ConnectOrBind_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:143
goby::zeromq::protobuf::Socket_ConnectOrBind_descriptor
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_ConnectOrBind_descriptor()
goby::zeromq::protobuf::Socket_Transport_Transport_ARRAYSIZE
constexpr int Socket_Transport_Transport_ARRAYSIZE
Definition interprocess_zeromq.pb.h:116
goby::zeromq::protobuf::Socket_ConnectOrBind_ConnectOrBind_MIN
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MIN
Definition interprocess_zeromq.pb.h:137
goby::zeromq::protobuf::Socket_SocketType_Name
const std::string & Socket_SocketType_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:94
goby::zeromq::protobuf::_InprocControl_default_instance_
InprocControlDefaultTypeInternal _InprocControl_default_instance_
goby::zeromq::protobuf::InprocControl_InprocControlType_IsValid
bool InprocControl_InprocControlType_IsValid(int value)
goby::zeromq::protobuf::Socket_Transport_Transport_MAX
constexpr Socket_Transport Socket_Transport_Transport_MAX
Definition interprocess_zeromq.pb.h:115
goby::zeromq::protobuf::InprocControl_InprocControlType_Name
const std::string & InprocControl_InprocControlType_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:173
goby::zeromq::protobuf::Socket_SocketType_SocketType_ARRAYSIZE
constexpr int Socket_SocketType_SocketType_ARRAYSIZE
Definition interprocess_zeromq.pb.h:90
goby::zeromq::protobuf::InprocControl_InprocControlType_InprocControlType_MIN
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MIN
Definition interprocess_zeromq.pb.h:167
goby::zeromq::protobuf::Request_IsValid
bool Request_IsValid(int value)
goby::zeromq::protobuf::Socket_ConnectOrBind_Parse
bool Socket_ConnectOrBind_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_ConnectOrBind *value)
Definition interprocess_zeromq.pb.h:150
goby::zeromq::protobuf::Socket_ConnectOrBind_ConnectOrBind_MAX
constexpr Socket_ConnectOrBind Socket_ConnectOrBind_ConnectOrBind_MAX
Definition interprocess_zeromq.pb.h:138
goby::zeromq::protobuf::_ManagerResponse_default_instance_
ManagerResponseDefaultTypeInternal _ManagerResponse_default_instance_
goby::zeromq::protobuf::Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE
constexpr int Socket_ConnectOrBind_ConnectOrBind_ARRAYSIZE
Definition interprocess_zeromq.pb.h:139
goby::zeromq::protobuf::Socket_SocketType_Parse
bool Socket_SocketType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_SocketType *value)
Definition interprocess_zeromq.pb.h:101
goby::zeromq::protobuf::Socket_SocketType_SocketType_MAX
constexpr Socket_SocketType Socket_SocketType_SocketType_MAX
Definition interprocess_zeromq.pb.h:89
goby::zeromq::protobuf::InprocControl_InprocControlType_Parse
bool InprocControl_InprocControlType_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, InprocControl_InprocControlType *value)
Definition interprocess_zeromq.pb.h:180
goby::zeromq::protobuf::_Socket_default_instance_
SocketDefaultTypeInternal _Socket_default_instance_
goby::zeromq::protobuf::InprocControl_InprocControlType_InprocControlType_MAX
constexpr InprocControl_InprocControlType InprocControl_InprocControlType_InprocControlType_MAX
Definition interprocess_zeromq.pb.h:168
goby::zeromq::protobuf::Socket_Transport_descriptor
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * Socket_Transport_descriptor()
goby::zeromq::protobuf::Socket_Transport_Transport_MIN
constexpr Socket_Transport Socket_Transport_Transport_MIN
Definition interprocess_zeromq.pb.h:114
goby::zeromq::protobuf::Socket_Transport_Name
const std::string & Socket_Transport_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:120
goby::zeromq::protobuf::InprocControl_InprocControlType_InprocControlType_ARRAYSIZE
constexpr int InprocControl_InprocControlType_InprocControlType_ARRAYSIZE
Definition interprocess_zeromq.pb.h:169
goby::zeromq::protobuf::Request_Parse
bool Request_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Request *value)
Definition interprocess_zeromq.pb.h:203
goby::zeromq::protobuf::Request_Name
const std::string & Request_Name(T enum_t_value)
Definition interprocess_zeromq.pb.h:196
goby::zeromq::protobuf::InprocControl_InprocControlType_descriptor
const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor * InprocControl_InprocControlType_descriptor()
goby::zeromq::protobuf::Socket_Transport_Parse
bool Socket_Transport_Parse(::PROTOBUF_NAMESPACE_ID::ConstStringParam name, Socket_Transport *value)
Definition interprocess_zeromq.pb.h:127
goby::zeromq::protobuf::Socket_ConnectOrBind_IsValid
bool Socket_ConnectOrBind_IsValid(int value)
goby
The global namespace for the Goby project.
Definition acomms_constants.h:34
option_extensions.pb.h
TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto
Definition interprocess_zeromq.pb.h:49
TableStruct_goby_2fzeromq_2fprotobuf_2finterprocess_5fzeromq_2eproto::offsets
static const uint32_t offsets[]
Definition interprocess_zeromq.pb.h:50