diff --git a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp --- a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp +++ b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp @@ -16,7 +16,7 @@ } std::lock_guard guard{this->onReadDoneCallbackMutex}; if (this->onReadDoneCallback) { - this->onReadDoneCallback(this->response.payload()); + this->onReadDoneCallback(this->response.responsemessage().payload()); } StartRead(&(this->response)); } diff --git a/services/tunnelbroker/src/Service/TunnelbrokerServiceImpl.cpp b/services/tunnelbroker/src/Service/TunnelbrokerServiceImpl.cpp --- a/services/tunnelbroker/src/Service/TunnelbrokerServiceImpl.cpp +++ b/services/tunnelbroker/src/Service/TunnelbrokerServiceImpl.cpp @@ -197,8 +197,8 @@ tunnelbroker::GetResponse response; auto respondToWriter = [&writer, &response](std::string fromDeviceID, std::string payload) { - response.set_fromdeviceid(fromDeviceID); - response.set_payload(payload); + response.mutable_responsemessage()->set_fromdeviceid(fromDeviceID); + response.mutable_responsemessage()->set_payload(payload); if (!writer->Write(response)) { throw std::runtime_error( "gRPC: 'Get' writer error on sending data to the client"); diff --git a/shared/protos/_generated/tunnelbroker.pb.h b/shared/protos/_generated/tunnelbroker.pb.h --- a/shared/protos/_generated/tunnelbroker.pb.h +++ b/shared/protos/_generated/tunnelbroker.pb.h @@ -48,7 +48,7 @@ PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::PROTOBUF_NAMESPACE_ID::internal::AuxiliaryParseTableField aux[] PROTOBUF_SECTION_VARIABLE(protodesc_cold); - static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[19] + static const ::PROTOBUF_NAMESPACE_ID::internal::ParseTable schema[20] PROTOBUF_SECTION_VARIABLE(protodesc_cold); static const ::PROTOBUF_NAMESPACE_ID::internal::FieldMetadata field_metadata[]; static const ::PROTOBUF_NAMESPACE_ID::internal::SerializationTable serialization_table[]; @@ -69,6 +69,9 @@ class GetResponse; struct GetResponseDefaultTypeInternal; extern GetResponseDefaultTypeInternal _GetResponse_default_instance_; +class GetResponseMessage; +struct GetResponseMessageDefaultTypeInternal; +extern GetResponseMessageDefaultTypeInternal _GetResponseMessage_default_instance_; class MessageToClient; struct MessageToClientDefaultTypeInternal; extern MessageToClientDefaultTypeInternal _MessageToClient_default_instance_; @@ -120,6 +123,7 @@ template<> ::tunnelbroker::CheckResponse* Arena::CreateMaybeMessage<::tunnelbroker::CheckResponse>(Arena*); template<> ::tunnelbroker::GetRequest* Arena::CreateMaybeMessage<::tunnelbroker::GetRequest>(Arena*); template<> ::tunnelbroker::GetResponse* Arena::CreateMaybeMessage<::tunnelbroker::GetResponse>(Arena*); +template<> ::tunnelbroker::GetResponseMessage* Arena::CreateMaybeMessage<::tunnelbroker::GetResponseMessage>(Arena*); template<> ::tunnelbroker::MessageToClient* Arena::CreateMaybeMessage<::tunnelbroker::MessageToClient>(Arena*); template<> ::tunnelbroker::MessageToClientStruct* Arena::CreateMaybeMessage<::tunnelbroker::MessageToClientStruct>(Arena*); template<> ::tunnelbroker::MessageToTunnelbroker* Arena::CreateMaybeMessage<::tunnelbroker::MessageToTunnelbroker>(Arena*); @@ -1257,24 +1261,24 @@ }; // ------------------------------------------------------------------- -class GetResponse PROTOBUF_FINAL : - public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.GetResponse) */ { +class GetResponseMessage PROTOBUF_FINAL : + public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.GetResponseMessage) */ { public: - inline GetResponse() : GetResponse(nullptr) {} - virtual ~GetResponse(); - explicit constexpr GetResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + inline GetResponseMessage() : GetResponseMessage(nullptr) {} + virtual ~GetResponseMessage(); + explicit constexpr GetResponseMessage(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); - GetResponse(const GetResponse& from); - GetResponse(GetResponse&& from) noexcept - : GetResponse() { + GetResponseMessage(const GetResponseMessage& from); + GetResponseMessage(GetResponseMessage&& from) noexcept + : GetResponseMessage() { *this = ::std::move(from); } - inline GetResponse& operator=(const GetResponse& from) { + inline GetResponseMessage& operator=(const GetResponseMessage& from) { CopyFrom(from); return *this; } - inline GetResponse& operator=(GetResponse&& from) noexcept { + inline GetResponseMessage& operator=(GetResponseMessage&& from) noexcept { if (GetArena() == from.GetArena()) { if (this != &from) InternalSwap(&from); } else { @@ -1292,20 +1296,20 @@ static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { return GetMetadataStatic().reflection; } - static const GetResponse& default_instance() { + static const GetResponseMessage& default_instance() { return *internal_default_instance(); } - static inline const GetResponse* internal_default_instance() { - return reinterpret_cast( - &_GetResponse_default_instance_); + static inline const GetResponseMessage* internal_default_instance() { + return reinterpret_cast( + &_GetResponseMessage_default_instance_); } static constexpr int kIndexInFileMessages = 6; - friend void swap(GetResponse& a, GetResponse& b) { + friend void swap(GetResponseMessage& a, GetResponseMessage& b) { a.Swap(&b); } - inline void Swap(GetResponse* other) { + inline void Swap(GetResponseMessage* other) { if (other == this) return; if (GetArena() == other->GetArena()) { InternalSwap(other); @@ -1313,7 +1317,7 @@ ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); } } - void UnsafeArenaSwap(GetResponse* other) { + void UnsafeArenaSwap(GetResponseMessage* other) { if (other == this) return; GOOGLE_DCHECK(GetArena() == other->GetArena()); InternalSwap(other); @@ -1321,17 +1325,17 @@ // implements Message ---------------------------------------------- - inline GetResponse* New() const final { - return CreateMaybeMessage(nullptr); + inline GetResponseMessage* New() const final { + return CreateMaybeMessage(nullptr); } - GetResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final { - return CreateMaybeMessage(arena); + GetResponseMessage* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final { + return CreateMaybeMessage(arena); } void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; - void CopyFrom(const GetResponse& from); - void MergeFrom(const GetResponse& from); + void CopyFrom(const GetResponseMessage& from); + void MergeFrom(const GetResponseMessage& from); PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; bool IsInitialized() const final; @@ -1345,13 +1349,13 @@ inline void SharedCtor(); inline void SharedDtor(); void SetCachedSize(int size) const final; - void InternalSwap(GetResponse* other); + void InternalSwap(GetResponseMessage* other); friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { - return "tunnelbroker.GetResponse"; + return "tunnelbroker.GetResponseMessage"; } protected: - explicit GetResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + explicit GetResponseMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena); private: static void ArenaDtor(void* object); inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); @@ -1430,7 +1434,7 @@ std::string* _internal_mutable_payload(); public: - // @@protoc_insertion_point(class_scope:tunnelbroker.GetResponse) + // @@protoc_insertion_point(class_scope:tunnelbroker.GetResponseMessage) private: class _Internal; @@ -1445,6 +1449,191 @@ }; // ------------------------------------------------------------------- +class GetResponse PROTOBUF_FINAL : + public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.GetResponse) */ { + public: + inline GetResponse() : GetResponse(nullptr) {} + virtual ~GetResponse(); + explicit constexpr GetResponse(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + + GetResponse(const GetResponse& from); + GetResponse(GetResponse&& from) noexcept + : GetResponse() { + *this = ::std::move(from); + } + + inline GetResponse& operator=(const GetResponse& from) { + CopyFrom(from); + return *this; + } + inline GetResponse& operator=(GetResponse&& from) noexcept { + if (GetArena() == from.GetArena()) { + if (this != &from) InternalSwap(&from); + } else { + CopyFrom(from); + } + return *this; + } + + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() { + return GetDescriptor(); + } + static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() { + return GetMetadataStatic().descriptor; + } + static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() { + return GetMetadataStatic().reflection; + } + static const GetResponse& default_instance() { + return *internal_default_instance(); + } + enum DataCase { + kResponseMessage = 1, + kPing = 2, + DATA_NOT_SET = 0, + }; + + static inline const GetResponse* internal_default_instance() { + return reinterpret_cast( + &_GetResponse_default_instance_); + } + static constexpr int kIndexInFileMessages = + 7; + + friend void swap(GetResponse& a, GetResponse& b) { + a.Swap(&b); + } + inline void Swap(GetResponse* other) { + if (other == this) return; + if (GetArena() == other->GetArena()) { + InternalSwap(other); + } else { + ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other); + } + } + void UnsafeArenaSwap(GetResponse* other) { + if (other == this) return; + GOOGLE_DCHECK(GetArena() == other->GetArena()); + InternalSwap(other); + } + + // implements Message ---------------------------------------------- + + inline GetResponse* New() const final { + return CreateMaybeMessage(nullptr); + } + + GetResponse* New(::PROTOBUF_NAMESPACE_ID::Arena* arena) const final { + return CreateMaybeMessage(arena); + } + void CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; + void MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) final; + void CopyFrom(const GetResponse& from); + void MergeFrom(const GetResponse& from); + PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final; + bool IsInitialized() const final; + + size_t ByteSizeLong() const final; + const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final; + ::PROTOBUF_NAMESPACE_ID::uint8* _InternalSerialize( + ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final; + int GetCachedSize() const final { return _cached_size_.Get(); } + + private: + inline void SharedCtor(); + inline void SharedDtor(); + void SetCachedSize(int size) const final; + void InternalSwap(GetResponse* other); + friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata; + static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() { + return "tunnelbroker.GetResponse"; + } + protected: + explicit GetResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + private: + static void ArenaDtor(void* object); + inline void RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena* arena); + public: + + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + private: + static ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadataStatic() { + return ::descriptor_table_tunnelbroker_2eproto_metadata_getter(kIndexInFileMessages); + } + + public: + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + enum : int { + kResponseMessageFieldNumber = 1, + kPingFieldNumber = 2, + }; + // .tunnelbroker.GetResponseMessage responseMessage = 1; + bool has_responsemessage() const; + private: + bool _internal_has_responsemessage() const; + public: + void clear_responsemessage(); + const ::tunnelbroker::GetResponseMessage& responsemessage() const; + ::tunnelbroker::GetResponseMessage* release_responsemessage(); + ::tunnelbroker::GetResponseMessage* mutable_responsemessage(); + void set_allocated_responsemessage(::tunnelbroker::GetResponseMessage* responsemessage); + private: + const ::tunnelbroker::GetResponseMessage& _internal_responsemessage() const; + ::tunnelbroker::GetResponseMessage* _internal_mutable_responsemessage(); + public: + void unsafe_arena_set_allocated_responsemessage( + ::tunnelbroker::GetResponseMessage* responsemessage); + ::tunnelbroker::GetResponseMessage* unsafe_arena_release_responsemessage(); + + // .google.protobuf.Empty ping = 2; + bool has_ping() const; + private: + bool _internal_has_ping() const; + public: + void clear_ping(); + const PROTOBUF_NAMESPACE_ID::Empty& ping() const; + PROTOBUF_NAMESPACE_ID::Empty* release_ping(); + PROTOBUF_NAMESPACE_ID::Empty* mutable_ping(); + void set_allocated_ping(PROTOBUF_NAMESPACE_ID::Empty* ping); + private: + const PROTOBUF_NAMESPACE_ID::Empty& _internal_ping() const; + PROTOBUF_NAMESPACE_ID::Empty* _internal_mutable_ping(); + public: + void unsafe_arena_set_allocated_ping( + PROTOBUF_NAMESPACE_ID::Empty* ping); + PROTOBUF_NAMESPACE_ID::Empty* unsafe_arena_release_ping(); + + void clear_data(); + DataCase data_case() const; + // @@protoc_insertion_point(class_scope:tunnelbroker.GetResponse) + private: + class _Internal; + void set_has_responsemessage(); + void set_has_ping(); + + inline bool has_data() const; + inline void clear_has_data(); + + template friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper; + typedef void InternalArenaConstructable_; + typedef void DestructorSkippable_; + union DataUnion { + constexpr DataUnion() : _constinit_{} {} + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized _constinit_; + ::tunnelbroker::GetResponseMessage* responsemessage_; + PROTOBUF_NAMESPACE_ID::Empty* ping_; + } data_; + mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; + ::PROTOBUF_NAMESPACE_ID::uint32 _oneof_case_[1]; + + friend struct ::TableStruct_tunnelbroker_2eproto; +}; +// ------------------------------------------------------------------- + class ProcessedMessages PROTOBUF_FINAL : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:tunnelbroker.ProcessedMessages) */ { public: @@ -1488,7 +1677,7 @@ &_ProcessedMessages_default_instance_); } static constexpr int kIndexInFileMessages = - 7; + 8; friend void swap(ProcessedMessages& a, ProcessedMessages& b) { a.Swap(&b); @@ -1640,7 +1829,7 @@ &_MessageToTunnelbrokerStruct_default_instance_); } static constexpr int kIndexInFileMessages = - 8; + 9; friend void swap(MessageToTunnelbrokerStruct& a, MessageToTunnelbrokerStruct& b) { a.Swap(&b); @@ -1846,7 +2035,7 @@ &_MessagesToSend_default_instance_); } static constexpr int kIndexInFileMessages = - 9; + 10; friend void swap(MessagesToSend& a, MessagesToSend& b) { a.Swap(&b); @@ -1998,7 +2187,7 @@ &_MessageToTunnelbroker_default_instance_); } static constexpr int kIndexInFileMessages = - 10; + 11; friend void swap(MessageToTunnelbroker& a, MessageToTunnelbroker& b) { a.Swap(&b); @@ -2195,7 +2384,7 @@ &_MessageToClientStruct_default_instance_); } static constexpr int kIndexInFileMessages = - 11; + 12; friend void swap(MessageToClientStruct& a, MessageToClientStruct& b) { a.Swap(&b); @@ -2401,7 +2590,7 @@ &_MessagesToDeliver_default_instance_); } static constexpr int kIndexInFileMessages = - 12; + 13; friend void swap(MessagesToDeliver& a, MessagesToDeliver& b) { a.Swap(&b); @@ -2553,7 +2742,7 @@ &_MessageToClient_default_instance_); } static constexpr int kIndexInFileMessages = - 13; + 14; friend void swap(MessageToClient& a, MessageToClient& b) { a.Swap(&b); @@ -2732,7 +2921,7 @@ &_CheckRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 14; + 15; friend void swap(CheckRequest& a, CheckRequest& b) { a.Swap(&b); @@ -2894,7 +3083,7 @@ &_CheckResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 15; + 16; friend void swap(CheckResponse& a, CheckResponse& b) { a.Swap(&b); @@ -3031,7 +3220,7 @@ &_NewPrimaryRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 16; + 17; friend void swap(NewPrimaryRequest& a, NewPrimaryRequest& b) { a.Swap(&b); @@ -3193,7 +3382,7 @@ &_NewPrimaryResponse_default_instance_); } static constexpr int kIndexInFileMessages = - 17; + 18; friend void swap(NewPrimaryResponse& a, NewPrimaryResponse& b) { a.Swap(&b); @@ -3330,7 +3519,7 @@ &_PongRequest_default_instance_); } static constexpr int kIndexInFileMessages = - 18; + 19; friend void swap(PongRequest& a, PongRequest& b) { a.Swap(&b); @@ -4379,59 +4568,59 @@ // ------------------------------------------------------------------- -// GetResponse +// GetResponseMessage // string fromDeviceID = 1; -inline void GetResponse::clear_fromdeviceid() { +inline void GetResponseMessage::clear_fromdeviceid() { fromdeviceid_.ClearToEmpty(); } -inline const std::string& GetResponse::fromdeviceid() const { - // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.fromDeviceID) +inline const std::string& GetResponseMessage::fromdeviceid() const { + // @@protoc_insertion_point(field_get:tunnelbroker.GetResponseMessage.fromDeviceID) return _internal_fromdeviceid(); } -inline void GetResponse::set_fromdeviceid(const std::string& value) { +inline void GetResponseMessage::set_fromdeviceid(const std::string& value) { _internal_set_fromdeviceid(value); - // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.fromDeviceID) + // @@protoc_insertion_point(field_set:tunnelbroker.GetResponseMessage.fromDeviceID) } -inline std::string* GetResponse::mutable_fromdeviceid() { - // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.fromDeviceID) +inline std::string* GetResponseMessage::mutable_fromdeviceid() { + // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponseMessage.fromDeviceID) return _internal_mutable_fromdeviceid(); } -inline const std::string& GetResponse::_internal_fromdeviceid() const { +inline const std::string& GetResponseMessage::_internal_fromdeviceid() const { return fromdeviceid_.Get(); } -inline void GetResponse::_internal_set_fromdeviceid(const std::string& value) { +inline void GetResponseMessage::_internal_set_fromdeviceid(const std::string& value) { fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void GetResponse::set_fromdeviceid(std::string&& value) { +inline void GetResponseMessage::set_fromdeviceid(std::string&& value) { fromdeviceid_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.fromDeviceID) + // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponseMessage.fromDeviceID) } -inline void GetResponse::set_fromdeviceid(const char* value) { +inline void GetResponseMessage::set_fromdeviceid(const char* value) { GOOGLE_DCHECK(value != nullptr); fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.fromDeviceID) + // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponseMessage.fromDeviceID) } -inline void GetResponse::set_fromdeviceid(const char* value, +inline void GetResponseMessage::set_fromdeviceid(const char* value, size_t size) { fromdeviceid_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.fromDeviceID) + // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponseMessage.fromDeviceID) } -inline std::string* GetResponse::_internal_mutable_fromdeviceid() { +inline std::string* GetResponseMessage::_internal_mutable_fromdeviceid() { return fromdeviceid_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } -inline std::string* GetResponse::release_fromdeviceid() { - // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.fromDeviceID) +inline std::string* GetResponseMessage::release_fromdeviceid() { + // @@protoc_insertion_point(field_release:tunnelbroker.GetResponseMessage.fromDeviceID) return fromdeviceid_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } -inline void GetResponse::set_allocated_fromdeviceid(std::string* fromdeviceid) { +inline void GetResponseMessage::set_allocated_fromdeviceid(std::string* fromdeviceid) { if (fromdeviceid != nullptr) { } else { @@ -4439,60 +4628,60 @@ } fromdeviceid_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), fromdeviceid, GetArena()); - // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.fromDeviceID) + // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponseMessage.fromDeviceID) } // bytes payload = 2; -inline void GetResponse::clear_payload() { +inline void GetResponseMessage::clear_payload() { payload_.ClearToEmpty(); } -inline const std::string& GetResponse::payload() const { - // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.payload) +inline const std::string& GetResponseMessage::payload() const { + // @@protoc_insertion_point(field_get:tunnelbroker.GetResponseMessage.payload) return _internal_payload(); } -inline void GetResponse::set_payload(const std::string& value) { +inline void GetResponseMessage::set_payload(const std::string& value) { _internal_set_payload(value); - // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.payload) + // @@protoc_insertion_point(field_set:tunnelbroker.GetResponseMessage.payload) } -inline std::string* GetResponse::mutable_payload() { - // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.payload) +inline std::string* GetResponseMessage::mutable_payload() { + // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponseMessage.payload) return _internal_mutable_payload(); } -inline const std::string& GetResponse::_internal_payload() const { +inline const std::string& GetResponseMessage::_internal_payload() const { return payload_.Get(); } -inline void GetResponse::_internal_set_payload(const std::string& value) { +inline void GetResponseMessage::_internal_set_payload(const std::string& value) { payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, value, GetArena()); } -inline void GetResponse::set_payload(std::string&& value) { +inline void GetResponseMessage::set_payload(std::string&& value) { payload_.Set( ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::move(value), GetArena()); - // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponse.payload) + // @@protoc_insertion_point(field_set_rvalue:tunnelbroker.GetResponseMessage.payload) } -inline void GetResponse::set_payload(const char* value) { +inline void GetResponseMessage::set_payload(const char* value) { GOOGLE_DCHECK(value != nullptr); payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string(value), GetArena()); - // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.payload) + // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponseMessage.payload) } -inline void GetResponse::set_payload(const void* value, +inline void GetResponseMessage::set_payload(const void* value, size_t size) { payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, ::std::string( reinterpret_cast(value), size), GetArena()); - // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.payload) + // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponseMessage.payload) } -inline std::string* GetResponse::_internal_mutable_payload() { +inline std::string* GetResponseMessage::_internal_mutable_payload() { return payload_.Mutable(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, GetArena()); } -inline std::string* GetResponse::release_payload() { - // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.payload) +inline std::string* GetResponseMessage::release_payload() { + // @@protoc_insertion_point(field_release:tunnelbroker.GetResponseMessage.payload) return payload_.Release(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); } -inline void GetResponse::set_allocated_payload(std::string* payload) { +inline void GetResponseMessage::set_allocated_payload(std::string* payload) { if (payload != nullptr) { } else { @@ -4500,85 +4689,236 @@ } payload_.SetAllocated(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), payload, GetArena()); - // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.payload) + // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponseMessage.payload) } // repeated string blobHashes = 3; -inline int GetResponse::_internal_blobhashes_size() const { +inline int GetResponseMessage::_internal_blobhashes_size() const { return blobhashes_.size(); } -inline int GetResponse::blobhashes_size() const { +inline int GetResponseMessage::blobhashes_size() const { return _internal_blobhashes_size(); } -inline void GetResponse::clear_blobhashes() { +inline void GetResponseMessage::clear_blobhashes() { blobhashes_.Clear(); } -inline std::string* GetResponse::add_blobhashes() { - // @@protoc_insertion_point(field_add_mutable:tunnelbroker.GetResponse.blobHashes) +inline std::string* GetResponseMessage::add_blobhashes() { + // @@protoc_insertion_point(field_add_mutable:tunnelbroker.GetResponseMessage.blobHashes) return _internal_add_blobhashes(); } -inline const std::string& GetResponse::_internal_blobhashes(int index) const { +inline const std::string& GetResponseMessage::_internal_blobhashes(int index) const { return blobhashes_.Get(index); } -inline const std::string& GetResponse::blobhashes(int index) const { - // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.blobHashes) +inline const std::string& GetResponseMessage::blobhashes(int index) const { + // @@protoc_insertion_point(field_get:tunnelbroker.GetResponseMessage.blobHashes) return _internal_blobhashes(index); } -inline std::string* GetResponse::mutable_blobhashes(int index) { - // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.blobHashes) +inline std::string* GetResponseMessage::mutable_blobhashes(int index) { + // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponseMessage.blobHashes) return blobhashes_.Mutable(index); } -inline void GetResponse::set_blobhashes(int index, const std::string& value) { - // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes) +inline void GetResponseMessage::set_blobhashes(int index, const std::string& value) { + // @@protoc_insertion_point(field_set:tunnelbroker.GetResponseMessage.blobHashes) blobhashes_.Mutable(index)->assign(value); } -inline void GetResponse::set_blobhashes(int index, std::string&& value) { - // @@protoc_insertion_point(field_set:tunnelbroker.GetResponse.blobHashes) +inline void GetResponseMessage::set_blobhashes(int index, std::string&& value) { + // @@protoc_insertion_point(field_set:tunnelbroker.GetResponseMessage.blobHashes) blobhashes_.Mutable(index)->assign(std::move(value)); } -inline void GetResponse::set_blobhashes(int index, const char* value) { +inline void GetResponseMessage::set_blobhashes(int index, const char* value) { GOOGLE_DCHECK(value != nullptr); blobhashes_.Mutable(index)->assign(value); - // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_set_char:tunnelbroker.GetResponseMessage.blobHashes) } -inline void GetResponse::set_blobhashes(int index, const char* value, size_t size) { +inline void GetResponseMessage::set_blobhashes(int index, const char* value, size_t size) { blobhashes_.Mutable(index)->assign( reinterpret_cast(value), size); - // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_set_pointer:tunnelbroker.GetResponseMessage.blobHashes) } -inline std::string* GetResponse::_internal_add_blobhashes() { +inline std::string* GetResponseMessage::_internal_add_blobhashes() { return blobhashes_.Add(); } -inline void GetResponse::add_blobhashes(const std::string& value) { +inline void GetResponseMessage::add_blobhashes(const std::string& value) { blobhashes_.Add()->assign(value); - // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_add:tunnelbroker.GetResponseMessage.blobHashes) } -inline void GetResponse::add_blobhashes(std::string&& value) { +inline void GetResponseMessage::add_blobhashes(std::string&& value) { blobhashes_.Add(std::move(value)); - // @@protoc_insertion_point(field_add:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_add:tunnelbroker.GetResponseMessage.blobHashes) } -inline void GetResponse::add_blobhashes(const char* value) { +inline void GetResponseMessage::add_blobhashes(const char* value) { GOOGLE_DCHECK(value != nullptr); blobhashes_.Add()->assign(value); - // @@protoc_insertion_point(field_add_char:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_add_char:tunnelbroker.GetResponseMessage.blobHashes) } -inline void GetResponse::add_blobhashes(const char* value, size_t size) { +inline void GetResponseMessage::add_blobhashes(const char* value, size_t size) { blobhashes_.Add()->assign(reinterpret_cast(value), size); - // @@protoc_insertion_point(field_add_pointer:tunnelbroker.GetResponse.blobHashes) + // @@protoc_insertion_point(field_add_pointer:tunnelbroker.GetResponseMessage.blobHashes) } inline const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField& -GetResponse::blobhashes() const { - // @@protoc_insertion_point(field_list:tunnelbroker.GetResponse.blobHashes) +GetResponseMessage::blobhashes() const { + // @@protoc_insertion_point(field_list:tunnelbroker.GetResponseMessage.blobHashes) return blobhashes_; } inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField* -GetResponse::mutable_blobhashes() { - // @@protoc_insertion_point(field_mutable_list:tunnelbroker.GetResponse.blobHashes) +GetResponseMessage::mutable_blobhashes() { + // @@protoc_insertion_point(field_mutable_list:tunnelbroker.GetResponseMessage.blobHashes) return &blobhashes_; } // ------------------------------------------------------------------- +// GetResponse + +// .tunnelbroker.GetResponseMessage responseMessage = 1; +inline bool GetResponse::_internal_has_responsemessage() const { + return data_case() == kResponseMessage; +} +inline bool GetResponse::has_responsemessage() const { + return _internal_has_responsemessage(); +} +inline void GetResponse::set_has_responsemessage() { + _oneof_case_[0] = kResponseMessage; +} +inline void GetResponse::clear_responsemessage() { + if (_internal_has_responsemessage()) { + if (GetArena() == nullptr) { + delete data_.responsemessage_; + } + clear_has_data(); + } +} +inline ::tunnelbroker::GetResponseMessage* GetResponse::release_responsemessage() { + // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.responseMessage) + if (_internal_has_responsemessage()) { + clear_has_data(); + ::tunnelbroker::GetResponseMessage* temp = data_.responsemessage_; + if (GetArena() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } + data_.responsemessage_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline const ::tunnelbroker::GetResponseMessage& GetResponse::_internal_responsemessage() const { + return _internal_has_responsemessage() + ? *data_.responsemessage_ + : reinterpret_cast< ::tunnelbroker::GetResponseMessage&>(::tunnelbroker::_GetResponseMessage_default_instance_); +} +inline const ::tunnelbroker::GetResponseMessage& GetResponse::responsemessage() const { + // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.responseMessage) + return _internal_responsemessage(); +} +inline ::tunnelbroker::GetResponseMessage* GetResponse::unsafe_arena_release_responsemessage() { + // @@protoc_insertion_point(field_unsafe_arena_release:tunnelbroker.GetResponse.responseMessage) + if (_internal_has_responsemessage()) { + clear_has_data(); + ::tunnelbroker::GetResponseMessage* temp = data_.responsemessage_; + data_.responsemessage_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline void GetResponse::unsafe_arena_set_allocated_responsemessage(::tunnelbroker::GetResponseMessage* responsemessage) { + clear_data(); + if (responsemessage) { + set_has_responsemessage(); + data_.responsemessage_ = responsemessage; + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:tunnelbroker.GetResponse.responseMessage) +} +inline ::tunnelbroker::GetResponseMessage* GetResponse::_internal_mutable_responsemessage() { + if (!_internal_has_responsemessage()) { + clear_data(); + set_has_responsemessage(); + data_.responsemessage_ = CreateMaybeMessage< ::tunnelbroker::GetResponseMessage >(GetArena()); + } + return data_.responsemessage_; +} +inline ::tunnelbroker::GetResponseMessage* GetResponse::mutable_responsemessage() { + // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.responseMessage) + return _internal_mutable_responsemessage(); +} + +// .google.protobuf.Empty ping = 2; +inline bool GetResponse::_internal_has_ping() const { + return data_case() == kPing; +} +inline bool GetResponse::has_ping() const { + return _internal_has_ping(); +} +inline void GetResponse::set_has_ping() { + _oneof_case_[0] = kPing; +} +inline PROTOBUF_NAMESPACE_ID::Empty* GetResponse::release_ping() { + // @@protoc_insertion_point(field_release:tunnelbroker.GetResponse.ping) + if (_internal_has_ping()) { + clear_has_data(); + PROTOBUF_NAMESPACE_ID::Empty* temp = data_.ping_; + if (GetArena() != nullptr) { + temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp); + } + data_.ping_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline const PROTOBUF_NAMESPACE_ID::Empty& GetResponse::_internal_ping() const { + return _internal_has_ping() + ? *data_.ping_ + : reinterpret_cast< PROTOBUF_NAMESPACE_ID::Empty&>(PROTOBUF_NAMESPACE_ID::_Empty_default_instance_); +} +inline const PROTOBUF_NAMESPACE_ID::Empty& GetResponse::ping() const { + // @@protoc_insertion_point(field_get:tunnelbroker.GetResponse.ping) + return _internal_ping(); +} +inline PROTOBUF_NAMESPACE_ID::Empty* GetResponse::unsafe_arena_release_ping() { + // @@protoc_insertion_point(field_unsafe_arena_release:tunnelbroker.GetResponse.ping) + if (_internal_has_ping()) { + clear_has_data(); + PROTOBUF_NAMESPACE_ID::Empty* temp = data_.ping_; + data_.ping_ = nullptr; + return temp; + } else { + return nullptr; + } +} +inline void GetResponse::unsafe_arena_set_allocated_ping(PROTOBUF_NAMESPACE_ID::Empty* ping) { + clear_data(); + if (ping) { + set_has_ping(); + data_.ping_ = ping; + } + // @@protoc_insertion_point(field_unsafe_arena_set_allocated:tunnelbroker.GetResponse.ping) +} +inline PROTOBUF_NAMESPACE_ID::Empty* GetResponse::_internal_mutable_ping() { + if (!_internal_has_ping()) { + clear_data(); + set_has_ping(); + data_.ping_ = CreateMaybeMessage< PROTOBUF_NAMESPACE_ID::Empty >(GetArena()); + } + return data_.ping_; +} +inline PROTOBUF_NAMESPACE_ID::Empty* GetResponse::mutable_ping() { + // @@protoc_insertion_point(field_mutable:tunnelbroker.GetResponse.ping) + return _internal_mutable_ping(); +} + +inline bool GetResponse::has_data() const { + return data_case() != DATA_NOT_SET; +} +inline void GetResponse::clear_has_data() { + _oneof_case_[0] = DATA_NOT_SET; +} +inline GetResponse::DataCase GetResponse::data_case() const { + return GetResponse::DataCase(_oneof_case_[0]); +} +// ------------------------------------------------------------------- + // ProcessedMessages // repeated string messageID = 1; @@ -6107,6 +6447,8 @@ // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) diff --git a/shared/protos/_generated/tunnelbroker.pb.cc b/shared/protos/_generated/tunnelbroker.pb.cc --- a/shared/protos/_generated/tunnelbroker.pb.cc +++ b/shared/protos/_generated/tunnelbroker.pb.cc @@ -99,11 +99,23 @@ }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT GetRequestDefaultTypeInternal _GetRequest_default_instance_; -constexpr GetResponse::GetResponse( +constexpr GetResponseMessage::GetResponseMessage( ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) : blobhashes_() , fromdeviceid_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string) , payload_(&::PROTOBUF_NAMESPACE_ID::internal::fixed_address_empty_string){} +struct GetResponseMessageDefaultTypeInternal { + constexpr GetResponseMessageDefaultTypeInternal() + : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} + ~GetResponseMessageDefaultTypeInternal() {} + union { + GetResponseMessage _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT GetResponseMessageDefaultTypeInternal _GetResponseMessage_default_instance_; +constexpr GetResponse::GetResponse( + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized) + : _oneof_case_{}{} struct GetResponseDefaultTypeInternal { constexpr GetResponseDefaultTypeInternal() : _instance(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized{}) {} @@ -269,7 +281,7 @@ }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PongRequestDefaultTypeInternal _PongRequest_default_instance_; } // namespace tunnelbroker -static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tunnelbroker_2eproto[19]; +static ::PROTOBUF_NAMESPACE_ID::Metadata file_level_metadata_tunnelbroker_2eproto[20]; static const ::PROTOBUF_NAMESPACE_ID::EnumDescriptor* file_level_enum_descriptors_tunnelbroker_2eproto[2]; static constexpr ::PROTOBUF_NAMESPACE_ID::ServiceDescriptor const** file_level_service_descriptors_tunnelbroker_2eproto = nullptr; @@ -327,13 +339,21 @@ ~0u, // no _weak_field_map_ PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetRequest, sessionid_), ~0u, // no _has_bits_ - PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, _internal_metadata_), + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponseMessage, _internal_metadata_), ~0u, // no _extensions_ ~0u, // no _oneof_case_ ~0u, // no _weak_field_map_ - PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, fromdeviceid_), - PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, payload_), - PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, blobhashes_), + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponseMessage, fromdeviceid_), + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponseMessage, payload_), + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponseMessage, blobhashes_), + ~0u, // no _has_bits_ + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, _internal_metadata_), + ~0u, // no _extensions_ + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, _oneof_case_[0]), + ~0u, // no _weak_field_map_ + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + ::PROTOBUF_NAMESPACE_ID::internal::kInvalidFieldOffsetTag, + PROTOBUF_FIELD_OFFSET(::tunnelbroker::GetResponse, data_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::tunnelbroker::ProcessedMessages, _internal_metadata_), ~0u, // no _extensions_ @@ -428,19 +448,20 @@ { 31, -1, sizeof(::tunnelbroker::NewSessionResponse)}, { 37, -1, sizeof(::tunnelbroker::SendRequest)}, { 46, -1, sizeof(::tunnelbroker::GetRequest)}, - { 52, -1, sizeof(::tunnelbroker::GetResponse)}, - { 60, -1, sizeof(::tunnelbroker::ProcessedMessages)}, - { 66, -1, sizeof(::tunnelbroker::MessageToTunnelbrokerStruct)}, - { 75, -1, sizeof(::tunnelbroker::MessagesToSend)}, - { 81, -1, sizeof(::tunnelbroker::MessageToTunnelbroker)}, - { 90, -1, sizeof(::tunnelbroker::MessageToClientStruct)}, - { 99, -1, sizeof(::tunnelbroker::MessagesToDeliver)}, - { 105, -1, sizeof(::tunnelbroker::MessageToClient)}, - { 113, -1, sizeof(::tunnelbroker::CheckRequest)}, - { 120, -1, sizeof(::tunnelbroker::CheckResponse)}, - { 126, -1, sizeof(::tunnelbroker::NewPrimaryRequest)}, - { 133, -1, sizeof(::tunnelbroker::NewPrimaryResponse)}, - { 139, -1, sizeof(::tunnelbroker::PongRequest)}, + { 52, -1, sizeof(::tunnelbroker::GetResponseMessage)}, + { 60, -1, sizeof(::tunnelbroker::GetResponse)}, + { 68, -1, sizeof(::tunnelbroker::ProcessedMessages)}, + { 74, -1, sizeof(::tunnelbroker::MessageToTunnelbrokerStruct)}, + { 83, -1, sizeof(::tunnelbroker::MessagesToSend)}, + { 89, -1, sizeof(::tunnelbroker::MessageToTunnelbroker)}, + { 98, -1, sizeof(::tunnelbroker::MessageToClientStruct)}, + { 107, -1, sizeof(::tunnelbroker::MessagesToDeliver)}, + { 113, -1, sizeof(::tunnelbroker::MessageToClient)}, + { 121, -1, sizeof(::tunnelbroker::CheckRequest)}, + { 128, -1, sizeof(::tunnelbroker::CheckResponse)}, + { 134, -1, sizeof(::tunnelbroker::NewPrimaryRequest)}, + { 141, -1, sizeof(::tunnelbroker::NewPrimaryResponse)}, + { 147, -1, sizeof(::tunnelbroker::PongRequest)}, }; static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = { @@ -450,6 +471,7 @@ reinterpret_cast(&::tunnelbroker::_NewSessionResponse_default_instance_), reinterpret_cast(&::tunnelbroker::_SendRequest_default_instance_), reinterpret_cast(&::tunnelbroker::_GetRequest_default_instance_), + reinterpret_cast(&::tunnelbroker::_GetResponseMessage_default_instance_), reinterpret_cast(&::tunnelbroker::_GetResponse_default_instance_), reinterpret_cast(&::tunnelbroker::_ProcessedMessages_default_instance_), reinterpret_cast(&::tunnelbroker::_MessageToTunnelbrokerStruct_default_instance_), @@ -480,62 +502,66 @@ "essionResponse\022\021\n\tsessionID\030\001 \001(\t\"Y\n\013Sen" "dRequest\022\021\n\tsessionID\030\001 \001(\t\022\022\n\ntoDeviceI" "D\030\002 \001(\t\022\017\n\007payload\030\003 \001(\014\022\022\n\nblobHashes\030\004" - " \003(\t\"\037\n\nGetRequest\022\021\n\tsessionID\030\001 \001(\t\"H\n" - "\013GetResponse\022\024\n\014fromDeviceID\030\001 \001(\t\022\017\n\007pa" - "yload\030\002 \001(\014\022\022\n\nblobHashes\030\003 \003(\t\"&\n\021Proce" - "ssedMessages\022\021\n\tmessageID\030\001 \003(\t\"i\n\033Messa" - "geToTunnelbrokerStruct\022\021\n\tmessageID\030\001 \001(" - "\t\022\022\n\ntoDeviceID\030\002 \001(\t\022\017\n\007payload\030\003 \001(\t\022\022" - "\n\nblobHashes\030\004 \003(\t\"M\n\016MessagesToSend\022;\n\010" - "messages\030\001 \003(\0132).tunnelbroker.MessageToT" - "unnelbrokerStruct\"\250\001\n\025MessageToTunnelbro" - "ker\022\021\n\tsessionID\030\001 \001(\t\0226\n\016messagesToSend" - "\030\002 \001(\0132\034.tunnelbroker.MessagesToSendH\000\022<" - "\n\021processedMessages\030\003 \001(\0132\037.tunnelbroker" - ".ProcessedMessagesH\000B\006\n\004data\"e\n\025MessageT" - "oClientStruct\022\021\n\tmessageID\030\001 \001(\t\022\024\n\014from" - "DeviceID\030\002 \001(\t\022\017\n\007payload\030\003 \001(\t\022\022\n\nblobH" - "ashes\030\004 \003(\t\"J\n\021MessagesToDeliver\0225\n\010mess" - "ages\030\001 \003(\0132#.tunnelbroker.MessageToClien" - "tStruct\"\225\001\n\017MessageToClient\022<\n\021messagesT" - "oDeliver\030\001 \001(\0132\037.tunnelbroker.MessagesTo" - "DeliverH\000\022<\n\021processedMessages\030\002 \001(\0132\037.t" + " \003(\t\"\037\n\nGetRequest\022\021\n\tsessionID\030\001 \001(\t\"O\n" + "\022GetResponseMessage\022\024\n\014fromDeviceID\030\001 \001(" + "\t\022\017\n\007payload\030\002 \001(\014\022\022\n\nblobHashes\030\003 \003(\t\"z" + "\n\013GetResponse\022;\n\017responseMessage\030\001 \001(\0132 " + ".tunnelbroker.GetResponseMessageH\000\022&\n\004pi" + "ng\030\002 \001(\0132\026.google.protobuf.EmptyH\000B\006\n\004da" + "ta\"&\n\021ProcessedMessages\022\021\n\tmessageID\030\001 \003" + "(\t\"i\n\033MessageToTunnelbrokerStruct\022\021\n\tmes" + "sageID\030\001 \001(\t\022\022\n\ntoDeviceID\030\002 \001(\t\022\017\n\007payl" + "oad\030\003 \001(\t\022\022\n\nblobHashes\030\004 \003(\t\"M\n\016Message" + "sToSend\022;\n\010messages\030\001 \003(\0132).tunnelbroker" + ".MessageToTunnelbrokerStruct\"\250\001\n\025Message" + "ToTunnelbroker\022\021\n\tsessionID\030\001 \001(\t\0226\n\016mes" + "sagesToSend\030\002 \001(\0132\034.tunnelbroker.Message" + "sToSendH\000\022<\n\021processedMessages\030\003 \001(\0132\037.t" "unnelbroker.ProcessedMessagesH\000B\006\n\004data\"" - "3\n\014CheckRequest\022\016\n\006userId\030\001 \001(\t\022\023\n\013devic" - "eToken\030\002 \001(\t\"K\n\rCheckResponse\022:\n\021checkRe" - "sponseType\030\001 \001(\0162\037.tunnelbroker.CheckRes" - "ponseType\"8\n\021NewPrimaryRequest\022\016\n\006userId" - "\030\001 \001(\t\022\023\n\013deviceToken\030\002 \001(\t\"%\n\022NewPrimar" - "yResponse\022\017\n\007success\030\001 \001(\010\"2\n\013PongReques" - "t\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceToken\030\002 \001(\t*n" - "\n\021CheckResponseType\022\030\n\024PRIMARY_DOESNT_EX" - "IST\020\000\022\022\n\016PRIMARY_ONLINE\020\001\022\023\n\017PRIMARY_OFF" - "LINE\020\002\022\026\n\022CURRENT_IS_PRIMARY\020\0032\237\005\n\023Tunne" - "lbrokerService\022W\n\032CheckIfPrimaryDeviceOn" - "line\022\032.tunnelbroker.CheckRequest\032\033.tunne" - "lbroker.CheckResponse\"\000\022]\n\026BecomeNewPrim" - "aryDevice\022\037.tunnelbroker.NewPrimaryReque" - "st\032 .tunnelbroker.NewPrimaryResponse\"\000\022\?" - "\n\010SendPong\022\031.tunnelbroker.PongRequest\032\026." - "google.protobuf.Empty\"\000\022c\n\020SessionSignat" - "ure\022%.tunnelbroker.SessionSignatureReque" - "st\032&.tunnelbroker.SessionSignatureRespon" - "se\"\000\022Q\n\nNewSession\022\037.tunnelbroker.NewSes" - "sionRequest\032 .tunnelbroker.NewSessionRes" - "ponse\"\000\022;\n\004Send\022\031.tunnelbroker.SendReque" - "st\032\026.google.protobuf.Empty\"\000\022>\n\003Get\022\030.tu" - "nnelbroker.GetRequest\032\031.tunnelbroker.Get" - "Response\"\0000\001\022Z\n\016MessagesStream\022#.tunnelb" - "roker.MessageToTunnelbroker\032\035.tunnelbrok" - "er.MessageToClient\"\000(\0010\001b\006proto3" + "e\n\025MessageToClientStruct\022\021\n\tmessageID\030\001 " + "\001(\t\022\024\n\014fromDeviceID\030\002 \001(\t\022\017\n\007payload\030\003 \001" + "(\t\022\022\n\nblobHashes\030\004 \003(\t\"J\n\021MessagesToDeli" + "ver\0225\n\010messages\030\001 \003(\0132#.tunnelbroker.Mes" + "sageToClientStruct\"\225\001\n\017MessageToClient\022<" + "\n\021messagesToDeliver\030\001 \001(\0132\037.tunnelbroker" + ".MessagesToDeliverH\000\022<\n\021processedMessage" + "s\030\002 \001(\0132\037.tunnelbroker.ProcessedMessages" + "H\000B\006\n\004data\"3\n\014CheckRequest\022\016\n\006userId\030\001 \001" + "(\t\022\023\n\013deviceToken\030\002 \001(\t\"K\n\rCheckResponse" + "\022:\n\021checkResponseType\030\001 \001(\0162\037.tunnelbrok" + "er.CheckResponseType\"8\n\021NewPrimaryReques" + "t\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceToken\030\002 \001(\t\"%" + "\n\022NewPrimaryResponse\022\017\n\007success\030\001 \001(\010\"2\n" + "\013PongRequest\022\016\n\006userId\030\001 \001(\t\022\023\n\013deviceTo" + "ken\030\002 \001(\t*n\n\021CheckResponseType\022\030\n\024PRIMAR" + "Y_DOESNT_EXIST\020\000\022\022\n\016PRIMARY_ONLINE\020\001\022\023\n\017" + "PRIMARY_OFFLINE\020\002\022\026\n\022CURRENT_IS_PRIMARY\020" + "\0032\237\005\n\023TunnelbrokerService\022W\n\032CheckIfPrim" + "aryDeviceOnline\022\032.tunnelbroker.CheckRequ" + "est\032\033.tunnelbroker.CheckResponse\"\000\022]\n\026Be" + "comeNewPrimaryDevice\022\037.tunnelbroker.NewP" + "rimaryRequest\032 .tunnelbroker.NewPrimaryR" + "esponse\"\000\022\?\n\010SendPong\022\031.tunnelbroker.Pon" + "gRequest\032\026.google.protobuf.Empty\"\000\022c\n\020Se" + "ssionSignature\022%.tunnelbroker.SessionSig" + "natureRequest\032&.tunnelbroker.SessionSign" + "atureResponse\"\000\022Q\n\nNewSession\022\037.tunnelbr" + "oker.NewSessionRequest\032 .tunnelbroker.Ne" + "wSessionResponse\"\000\022;\n\004Send\022\031.tunnelbroke" + "r.SendRequest\032\026.google.protobuf.Empty\"\000\022" + ">\n\003Get\022\030.tunnelbroker.GetRequest\032\031.tunne" + "lbroker.GetResponse\"\0000\001\022Z\n\016MessagesStrea" + "m\022#.tunnelbroker.MessageToTunnelbroker\032\035" + ".tunnelbroker.MessageToClient\"\000(\0010\001b\006pro" + "to3" ; static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_tunnelbroker_2eproto_deps[1] = { &::descriptor_table_google_2fprotobuf_2fempty_2eproto, }; static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_tunnelbroker_2eproto_once; const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_tunnelbroker_2eproto = { - false, false, 2472, descriptor_table_protodef_tunnelbroker_2eproto, "tunnelbroker.proto", - &descriptor_table_tunnelbroker_2eproto_once, descriptor_table_tunnelbroker_2eproto_deps, 1, 19, + false, false, 2603, descriptor_table_protodef_tunnelbroker_2eproto, "tunnelbroker.proto", + &descriptor_table_tunnelbroker_2eproto_once, descriptor_table_tunnelbroker_2eproto_deps, 1, 20, schemas, file_default_instances, TableStruct_tunnelbroker_2eproto::offsets, file_level_metadata_tunnelbroker_2eproto, file_level_enum_descriptors_tunnelbroker_2eproto, file_level_service_descriptors_tunnelbroker_2eproto, }; @@ -2129,18 +2155,18 @@ // =================================================================== -class GetResponse::_Internal { +class GetResponseMessage::_Internal { public: }; -GetResponse::GetResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) +GetResponseMessage::GetResponseMessage(::PROTOBUF_NAMESPACE_ID::Arena* arena) : ::PROTOBUF_NAMESPACE_ID::Message(arena), blobhashes_(arena) { SharedCtor(); RegisterArenaDtor(arena); - // @@protoc_insertion_point(arena_constructor:tunnelbroker.GetResponse) + // @@protoc_insertion_point(arena_constructor:tunnelbroker.GetResponseMessage) } -GetResponse::GetResponse(const GetResponse& from) +GetResponseMessage::GetResponseMessage(const GetResponseMessage& from) : ::PROTOBUF_NAMESPACE_ID::Message(), blobhashes_(from.blobhashes_) { _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); @@ -2154,38 +2180,38 @@ payload_.Set(::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::EmptyDefault{}, from._internal_payload(), GetArena()); } - // @@protoc_insertion_point(copy_constructor:tunnelbroker.GetResponse) + // @@protoc_insertion_point(copy_constructor:tunnelbroker.GetResponseMessage) } -void GetResponse::SharedCtor() { +void GetResponseMessage::SharedCtor() { fromdeviceid_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); payload_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } -GetResponse::~GetResponse() { - // @@protoc_insertion_point(destructor:tunnelbroker.GetResponse) +GetResponseMessage::~GetResponseMessage() { + // @@protoc_insertion_point(destructor:tunnelbroker.GetResponseMessage) SharedDtor(); _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } -void GetResponse::SharedDtor() { +void GetResponseMessage::SharedDtor() { GOOGLE_DCHECK(GetArena() == nullptr); fromdeviceid_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); payload_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited()); } -void GetResponse::ArenaDtor(void* object) { - GetResponse* _this = reinterpret_cast< GetResponse* >(object); +void GetResponseMessage::ArenaDtor(void* object) { + GetResponseMessage* _this = reinterpret_cast< GetResponseMessage* >(object); (void)_this; } -void GetResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { +void GetResponseMessage::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { } -void GetResponse::SetCachedSize(int size) const { +void GetResponseMessage::SetCachedSize(int size) const { _cached_size_.Set(size); } -void GetResponse::Clear() { -// @@protoc_insertion_point(message_clear_start:tunnelbroker.GetResponse) +void GetResponseMessage::Clear() { +// @@protoc_insertion_point(message_clear_start:tunnelbroker.GetResponseMessage) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; @@ -2196,7 +2222,7 @@ _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } -const char* GetResponse::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { +const char* GetResponseMessage::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { #define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure while (!ctx->Done(&ptr)) { ::PROTOBUF_NAMESPACE_ID::uint32 tag; @@ -2208,7 +2234,7 @@ if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { auto str = _internal_mutable_fromdeviceid(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.GetResponse.fromDeviceID")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.GetResponseMessage.fromDeviceID")); CHK_(ptr); } else goto handle_unusual; continue; @@ -2228,7 +2254,7 @@ ptr += 1; auto str = _internal_add_blobhashes(); ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx); - CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.GetResponse.blobHashes")); + CHK_(::PROTOBUF_NAMESPACE_ID::internal::VerifyUTF8(str, "tunnelbroker.GetResponseMessage.blobHashes")); CHK_(ptr); if (!ctx->DataAvailable(ptr)) break; } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<26>(ptr)); @@ -2256,9 +2282,9 @@ #undef CHK_ } -::PROTOBUF_NAMESPACE_ID::uint8* GetResponse::_InternalSerialize( +::PROTOBUF_NAMESPACE_ID::uint8* GetResponseMessage::_InternalSerialize( ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { - // @@protoc_insertion_point(serialize_to_array_start:tunnelbroker.GetResponse) + // @@protoc_insertion_point(serialize_to_array_start:tunnelbroker.GetResponseMessage) ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; @@ -2267,7 +2293,7 @@ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( this->_internal_fromdeviceid().data(), static_cast(this->_internal_fromdeviceid().length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "tunnelbroker.GetResponse.fromDeviceID"); + "tunnelbroker.GetResponseMessage.fromDeviceID"); target = stream->WriteStringMaybeAliased( 1, this->_internal_fromdeviceid(), target); } @@ -2284,7 +2310,7 @@ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( s.data(), static_cast(s.length()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, - "tunnelbroker.GetResponse.blobHashes"); + "tunnelbroker.GetResponseMessage.blobHashes"); target = stream->WriteString(3, s, target); } @@ -2292,12 +2318,12 @@ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::InternalSerializeUnknownFieldsToArray( _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); } - // @@protoc_insertion_point(serialize_to_array_end:tunnelbroker.GetResponse) + // @@protoc_insertion_point(serialize_to_array_end:tunnelbroker.GetResponseMessage) return target; } -size_t GetResponse::ByteSizeLong() const { -// @@protoc_insertion_point(message_byte_size_start:tunnelbroker.GetResponse) +size_t GetResponseMessage::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:tunnelbroker.GetResponseMessage) size_t total_size = 0; ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; @@ -2335,6 +2361,317 @@ return total_size; } +void GetResponseMessage::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { +// @@protoc_insertion_point(generalized_merge_from_start:tunnelbroker.GetResponseMessage) + GOOGLE_DCHECK_NE(&from, this); + const GetResponseMessage* source = + ::PROTOBUF_NAMESPACE_ID::DynamicCastToGenerated( + &from); + if (source == nullptr) { + // @@protoc_insertion_point(generalized_merge_from_cast_fail:tunnelbroker.GetResponseMessage) + ::PROTOBUF_NAMESPACE_ID::internal::ReflectionOps::Merge(from, this); + } else { + // @@protoc_insertion_point(generalized_merge_from_cast_success:tunnelbroker.GetResponseMessage) + MergeFrom(*source); + } +} + +void GetResponseMessage::MergeFrom(const GetResponseMessage& from) { +// @@protoc_insertion_point(class_specific_merge_from_start:tunnelbroker.GetResponseMessage) + GOOGLE_DCHECK_NE(&from, this); + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + blobhashes_.MergeFrom(from.blobhashes_); + if (from.fromdeviceid().size() > 0) { + _internal_set_fromdeviceid(from._internal_fromdeviceid()); + } + if (from.payload().size() > 0) { + _internal_set_payload(from._internal_payload()); + } +} + +void GetResponseMessage::CopyFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { +// @@protoc_insertion_point(generalized_copy_from_start:tunnelbroker.GetResponseMessage) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +void GetResponseMessage::CopyFrom(const GetResponseMessage& from) { +// @@protoc_insertion_point(class_specific_copy_from_start:tunnelbroker.GetResponseMessage) + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool GetResponseMessage::IsInitialized() const { + return true; +} + +void GetResponseMessage::InternalSwap(GetResponseMessage* other) { + using std::swap; + _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); + blobhashes_.InternalSwap(&other->blobhashes_); + fromdeviceid_.Swap(&other->fromdeviceid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + payload_.Swap(&other->payload_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); +} + +::PROTOBUF_NAMESPACE_ID::Metadata GetResponseMessage::GetMetadata() const { + return GetMetadataStatic(); +} + + +// =================================================================== + +class GetResponse::_Internal { + public: + static const ::tunnelbroker::GetResponseMessage& responsemessage(const GetResponse* msg); + static const PROTOBUF_NAMESPACE_ID::Empty& ping(const GetResponse* msg); +}; + +const ::tunnelbroker::GetResponseMessage& +GetResponse::_Internal::responsemessage(const GetResponse* msg) { + return *msg->data_.responsemessage_; +} +const PROTOBUF_NAMESPACE_ID::Empty& +GetResponse::_Internal::ping(const GetResponse* msg) { + return *msg->data_.ping_; +} +void GetResponse::set_allocated_responsemessage(::tunnelbroker::GetResponseMessage* responsemessage) { + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena(); + clear_data(); + if (responsemessage) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + ::PROTOBUF_NAMESPACE_ID::Arena::GetArena(responsemessage); + if (message_arena != submessage_arena) { + responsemessage = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, responsemessage, submessage_arena); + } + set_has_responsemessage(); + data_.responsemessage_ = responsemessage; + } + // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.responseMessage) +} +void GetResponse::set_allocated_ping(PROTOBUF_NAMESPACE_ID::Empty* ping) { + ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArena(); + clear_data(); + if (ping) { + ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = + reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(ping)->GetArena(); + if (message_arena != submessage_arena) { + ping = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage( + message_arena, ping, submessage_arena); + } + set_has_ping(); + data_.ping_ = ping; + } + // @@protoc_insertion_point(field_set_allocated:tunnelbroker.GetResponse.ping) +} +void GetResponse::clear_ping() { + if (_internal_has_ping()) { + if (GetArena() == nullptr) { + delete data_.ping_; + } + clear_has_data(); + } +} +GetResponse::GetResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena) + : ::PROTOBUF_NAMESPACE_ID::Message(arena) { + SharedCtor(); + RegisterArenaDtor(arena); + // @@protoc_insertion_point(arena_constructor:tunnelbroker.GetResponse) +} +GetResponse::GetResponse(const GetResponse& from) + : ::PROTOBUF_NAMESPACE_ID::Message() { + _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + clear_has_data(); + switch (from.data_case()) { + case kResponseMessage: { + _internal_mutable_responsemessage()->::tunnelbroker::GetResponseMessage::MergeFrom(from._internal_responsemessage()); + break; + } + case kPing: { + _internal_mutable_ping()->PROTOBUF_NAMESPACE_ID::Empty::MergeFrom(from._internal_ping()); + break; + } + case DATA_NOT_SET: { + break; + } + } + // @@protoc_insertion_point(copy_constructor:tunnelbroker.GetResponse) +} + +void GetResponse::SharedCtor() { +clear_has_data(); +} + +GetResponse::~GetResponse() { + // @@protoc_insertion_point(destructor:tunnelbroker.GetResponse) + SharedDtor(); + _internal_metadata_.Delete<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); +} + +void GetResponse::SharedDtor() { + GOOGLE_DCHECK(GetArena() == nullptr); + if (has_data()) { + clear_data(); + } +} + +void GetResponse::ArenaDtor(void* object) { + GetResponse* _this = reinterpret_cast< GetResponse* >(object); + (void)_this; +} +void GetResponse::RegisterArenaDtor(::PROTOBUF_NAMESPACE_ID::Arena*) { +} +void GetResponse::SetCachedSize(int size) const { + _cached_size_.Set(size); +} + +void GetResponse::clear_data() { +// @@protoc_insertion_point(one_of_clear_start:tunnelbroker.GetResponse) + switch (data_case()) { + case kResponseMessage: { + if (GetArena() == nullptr) { + delete data_.responsemessage_; + } + break; + } + case kPing: { + if (GetArena() == nullptr) { + delete data_.ping_; + } + break; + } + case DATA_NOT_SET: { + break; + } + } + _oneof_case_[0] = DATA_NOT_SET; +} + + +void GetResponse::Clear() { +// @@protoc_insertion_point(message_clear_start:tunnelbroker.GetResponse) + ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + clear_data(); + _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); +} + +const char* GetResponse::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) { +#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure + while (!ctx->Done(&ptr)) { + ::PROTOBUF_NAMESPACE_ID::uint32 tag; + ptr = ::PROTOBUF_NAMESPACE_ID::internal::ReadTag(ptr, &tag); + CHK_(ptr); + switch (tag >> 3) { + // .tunnelbroker.GetResponseMessage responseMessage = 1; + case 1: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) { + ptr = ctx->ParseMessage(_internal_mutable_responsemessage(), ptr); + CHK_(ptr); + } else goto handle_unusual; + continue; + // .google.protobuf.Empty ping = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) { + ptr = ctx->ParseMessage(_internal_mutable_ping(), ptr); + CHK_(ptr); + } else goto handle_unusual; + continue; + default: { + handle_unusual: + if ((tag & 7) == 4 || tag == 0) { + ctx->SetLastTag(tag); + goto success; + } + ptr = UnknownFieldParse(tag, + _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(), + ptr, ctx); + CHK_(ptr != nullptr); + continue; + } + } // switch + } // while +success: + return ptr; +failure: + ptr = nullptr; + goto success; +#undef CHK_ +} + +::PROTOBUF_NAMESPACE_ID::uint8* GetResponse::_InternalSerialize( + ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { + // @@protoc_insertion_point(serialize_to_array_start:tunnelbroker.GetResponse) + ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; + (void) cached_has_bits; + + // .tunnelbroker.GetResponseMessage responseMessage = 1; + if (_internal_has_responsemessage()) { + target = stream->EnsureSpace(target); + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage( + 1, _Internal::responsemessage(this), target, stream); + } + + // .google.protobuf.Empty ping = 2; + if (_internal_has_ping()) { + target = stream->EnsureSpace(target); + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite:: + InternalWriteMessage( + 2, _Internal::ping(this), target, stream); + } + + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { + target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::InternalSerializeUnknownFieldsToArray( + _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); + } + // @@protoc_insertion_point(serialize_to_array_end:tunnelbroker.GetResponse) + return target; +} + +size_t GetResponse::ByteSizeLong() const { +// @@protoc_insertion_point(message_byte_size_start:tunnelbroker.GetResponse) + size_t total_size = 0; + + ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; + // Prevent compiler warnings about cached_has_bits being unused + (void) cached_has_bits; + + switch (data_case()) { + // .tunnelbroker.GetResponseMessage responseMessage = 1; + case kResponseMessage: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *data_.responsemessage_); + break; + } + // .google.protobuf.Empty ping = 2; + case kPing: { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize( + *data_.ping_); + break; + } + case DATA_NOT_SET: { + break; + } + } + if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) { + return ::PROTOBUF_NAMESPACE_ID::internal::ComputeUnknownFieldsSize( + _internal_metadata_, total_size, &_cached_size_); + } + int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size); + SetCachedSize(cached_size); + return total_size; +} + void GetResponse::MergeFrom(const ::PROTOBUF_NAMESPACE_ID::Message& from) { // @@protoc_insertion_point(generalized_merge_from_start:tunnelbroker.GetResponse) GOOGLE_DCHECK_NE(&from, this); @@ -2357,12 +2694,18 @@ ::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0; (void) cached_has_bits; - blobhashes_.MergeFrom(from.blobhashes_); - if (from.fromdeviceid().size() > 0) { - _internal_set_fromdeviceid(from._internal_fromdeviceid()); - } - if (from.payload().size() > 0) { - _internal_set_payload(from._internal_payload()); + switch (from.data_case()) { + case kResponseMessage: { + _internal_mutable_responsemessage()->::tunnelbroker::GetResponseMessage::MergeFrom(from._internal_responsemessage()); + break; + } + case kPing: { + _internal_mutable_ping()->PROTOBUF_NAMESPACE_ID::Empty::MergeFrom(from._internal_ping()); + break; + } + case DATA_NOT_SET: { + break; + } } } @@ -2387,9 +2730,8 @@ void GetResponse::InternalSwap(GetResponse* other) { using std::swap; _internal_metadata_.Swap<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(&other->_internal_metadata_); - blobhashes_.InternalSwap(&other->blobhashes_); - fromdeviceid_.Swap(&other->fromdeviceid_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); - payload_.Swap(&other->payload_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), GetArena()); + swap(data_, other->data_); + swap(_oneof_case_[0], other->_oneof_case_[0]); } ::PROTOBUF_NAMESPACE_ID::Metadata GetResponse::GetMetadata() const { @@ -5376,6 +5718,9 @@ template<> PROTOBUF_NOINLINE ::tunnelbroker::GetRequest* Arena::CreateMaybeMessage< ::tunnelbroker::GetRequest >(Arena* arena) { return Arena::CreateMessageInternal< ::tunnelbroker::GetRequest >(arena); } +template<> PROTOBUF_NOINLINE ::tunnelbroker::GetResponseMessage* Arena::CreateMaybeMessage< ::tunnelbroker::GetResponseMessage >(Arena* arena) { + return Arena::CreateMessageInternal< ::tunnelbroker::GetResponseMessage >(arena); +} template<> PROTOBUF_NOINLINE ::tunnelbroker::GetResponse* Arena::CreateMaybeMessage< ::tunnelbroker::GetResponse >(Arena* arena) { return Arena::CreateMessageInternal< ::tunnelbroker::GetResponse >(arena); } diff --git a/shared/protos/tunnelbroker.proto b/shared/protos/tunnelbroker.proto --- a/shared/protos/tunnelbroker.proto +++ b/shared/protos/tunnelbroker.proto @@ -70,12 +70,19 @@ string sessionID = 1; } -message GetResponse { +message GetResponseMessage { string fromDeviceID = 1; bytes payload = 2; repeated string blobHashes = 3; } +message GetResponse { + oneof data { + GetResponseMessage responseMessage = 1; + google.protobuf.Empty ping = 2; + } +} + // Common messages structures for the MessagesStream message ProcessedMessages {