// Generated by the protocol buffer compiler. DO NOT EDIT!
|
// source: bhome_msg.proto
|
|
#include "bhome_msg.pb.h"
|
|
#include <algorithm>
|
|
#include <google/protobuf/io/coded_stream.h>
|
#include <google/protobuf/extension_set.h>
|
#include <google/protobuf/wire_format_lite.h>
|
#include <google/protobuf/io/zero_copy_stream_impl_lite.h>
|
// @@protoc_insertion_point(includes)
|
#include <google/protobuf/port_def.inc>
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_5fapi_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_BHAddress_bhome_5fmsg_5fapi_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_error_5fmsg_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_ErrorMsg_error_5fmsg_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_5fapi_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgQueryTopic_bhome_5fmsg_5fapi_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_5fapi_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgRegister_bhome_5fmsg_5fapi_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgReply_bhome_5fmsg_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<3> scc_info_MsgRequest_bhome_5fmsg_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_5fapi_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgRequestTopic_bhome_5fmsg_5fapi_2eproto;
|
extern PROTOBUF_INTERNAL_EXPORT_bhome_5fmsg_5fapi_2eproto ::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgTopicList_bhome_5fmsg_5fapi_2eproto;
|
namespace bhome_msg {
|
class BHMsgHeadDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<BHMsgHead> _instance;
|
} _BHMsgHead_default_instance_;
|
class MsgSubscribeDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgSubscribe> _instance;
|
} _MsgSubscribe_default_instance_;
|
class MsgUnsubscribeDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgUnsubscribe> _instance;
|
} _MsgUnsubscribe_default_instance_;
|
class MsgRegisterRPCDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgRegisterRPC> _instance;
|
} _MsgRegisterRPC_default_instance_;
|
class MsgProcInitDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgProcInit> _instance;
|
} _MsgProcInit_default_instance_;
|
class MsgProcInitReplyDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgProcInitReply> _instance;
|
} _MsgProcInitReply_default_instance_;
|
class MsgRequestDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgRequest> _instance;
|
const ::bhome_msg::MsgRegister* register__;
|
const ::bhome_msg::MsgRequestTopic* topic_request_;
|
const ::bhome_msg::MsgQueryTopic* topic_query_;
|
} _MsgRequest_default_instance_;
|
class MsgReplyDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<MsgReply> _instance;
|
} _MsgReply_default_instance_;
|
class BHMsgBodyDefaultTypeInternal {
|
public:
|
::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<BHMsgBody> _instance;
|
const ::bhome_msg::MsgRequest* request_;
|
const ::bhome_msg::MsgReply* reply_;
|
} _BHMsgBody_default_instance_;
|
} // namespace bhome_msg
|
static void InitDefaultsscc_info_BHMsgBody_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_BHMsgBody_default_instance_;
|
new (ptr) ::bhome_msg::BHMsgBody();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::BHMsgBody::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<2> scc_info_BHMsgBody_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 2, 0, InitDefaultsscc_info_BHMsgBody_bhome_5fmsg_2eproto}, {
|
&scc_info_MsgRequest_bhome_5fmsg_2eproto.base,
|
&scc_info_MsgReply_bhome_5fmsg_2eproto.base,}};
|
|
static void InitDefaultsscc_info_BHMsgHead_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_BHMsgHead_default_instance_;
|
new (ptr) ::bhome_msg::BHMsgHead();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::BHMsgHead::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_BHMsgHead_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, 0, InitDefaultsscc_info_BHMsgHead_bhome_5fmsg_2eproto}, {
|
&scc_info_BHAddress_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgProcInit_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgProcInit_default_instance_;
|
new (ptr) ::bhome_msg::MsgProcInit();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgProcInit::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<0> scc_info_MsgProcInit_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 0, 0, InitDefaultsscc_info_MsgProcInit_bhome_5fmsg_2eproto}, {}};
|
|
static void InitDefaultsscc_info_MsgProcInitReply_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgProcInitReply_default_instance_;
|
new (ptr) ::bhome_msg::MsgProcInitReply();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgProcInitReply::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<2> scc_info_MsgProcInitReply_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 2, 0, InitDefaultsscc_info_MsgProcInitReply_bhome_5fmsg_2eproto}, {
|
&scc_info_ErrorMsg_error_5fmsg_2eproto.base,
|
&scc_info_BHAddress_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgRegisterRPC_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgRegisterRPC_default_instance_;
|
new (ptr) ::bhome_msg::MsgRegisterRPC();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgRegisterRPC::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgRegisterRPC_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, 0, InitDefaultsscc_info_MsgRegisterRPC_bhome_5fmsg_2eproto}, {
|
&scc_info_MsgTopicList_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgReply_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgReply_default_instance_;
|
new (ptr) ::bhome_msg::MsgReply();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgReply::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgReply_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, 0, InitDefaultsscc_info_MsgReply_bhome_5fmsg_2eproto}, {
|
&scc_info_ErrorMsg_error_5fmsg_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgRequest_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgRequest_default_instance_;
|
new (ptr) ::bhome_msg::MsgRequest();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgRequest::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<3> scc_info_MsgRequest_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 3, 0, InitDefaultsscc_info_MsgRequest_bhome_5fmsg_2eproto}, {
|
&scc_info_MsgRegister_bhome_5fmsg_5fapi_2eproto.base,
|
&scc_info_MsgRequestTopic_bhome_5fmsg_5fapi_2eproto.base,
|
&scc_info_MsgQueryTopic_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgSubscribe_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgSubscribe_default_instance_;
|
new (ptr) ::bhome_msg::MsgSubscribe();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgSubscribe::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgSubscribe_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, 0, InitDefaultsscc_info_MsgSubscribe_bhome_5fmsg_2eproto}, {
|
&scc_info_MsgTopicList_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
static void InitDefaultsscc_info_MsgUnsubscribe_bhome_5fmsg_2eproto() {
|
GOOGLE_PROTOBUF_VERIFY_VERSION;
|
|
{
|
void* ptr = &::bhome_msg::_MsgUnsubscribe_default_instance_;
|
new (ptr) ::bhome_msg::MsgUnsubscribe();
|
::PROTOBUF_NAMESPACE_ID::internal::OnShutdownDestroyMessage(ptr);
|
}
|
::bhome_msg::MsgUnsubscribe::InitAsDefaultInstance();
|
}
|
|
::PROTOBUF_NAMESPACE_ID::internal::SCCInfo<1> scc_info_MsgUnsubscribe_bhome_5fmsg_2eproto =
|
{{ATOMIC_VAR_INIT(::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase::kUninitialized), 1, 0, InitDefaultsscc_info_MsgUnsubscribe_bhome_5fmsg_2eproto}, {
|
&scc_info_MsgTopicList_bhome_5fmsg_5fapi_2eproto.base,}};
|
|
namespace bhome_msg {
|
bool MsgType_IsValid(int value) {
|
switch (value) {
|
case 0:
|
case 1:
|
case 2:
|
case 8:
|
case 9:
|
case 10:
|
case 12:
|
case 14:
|
case 15:
|
case 16:
|
case 17:
|
case 18:
|
case 20:
|
case 22:
|
case 24:
|
case 26:
|
case 28:
|
case 29:
|
return true;
|
default:
|
return false;
|
}
|
}
|
|
static ::PROTOBUF_NAMESPACE_ID::internal::ExplicitlyConstructed<std::string> MsgType_strings[18] = {};
|
|
static const char MsgType_names[] =
|
"kMsgTypeCommonReply"
|
"kMsgTypeHeartbeat"
|
"kMsgTypeInvalid"
|
"kMsgTypeProcInit"
|
"kMsgTypeProcInitReply"
|
"kMsgTypePublish"
|
"kMsgTypeQueryProc"
|
"kMsgTypeQueryProcReply"
|
"kMsgTypeQueryTopic"
|
"kMsgTypeQueryTopicReply"
|
"kMsgTypeRawData"
|
"kMsgTypeRegister"
|
"kMsgTypeRegisterRPC"
|
"kMsgTypeRequestTopic"
|
"kMsgTypeRequestTopicReply"
|
"kMsgTypeSubscribe"
|
"kMsgTypeUnregister"
|
"kMsgTypeUnsubscribe";
|
|
static const ::PROTOBUF_NAMESPACE_ID::internal::EnumEntry MsgType_entries[] = {
|
{ {MsgType_names + 0, 19}, 2 },
|
{ {MsgType_names + 19, 17}, 12 },
|
{ {MsgType_names + 36, 15}, 0 },
|
{ {MsgType_names + 51, 16}, 8 },
|
{ {MsgType_names + 67, 21}, 9 },
|
{ {MsgType_names + 88, 15}, 20 },
|
{ {MsgType_names + 103, 17}, 28 },
|
{ {MsgType_names + 120, 22}, 29 },
|
{ {MsgType_names + 142, 18}, 14 },
|
{ {MsgType_names + 160, 23}, 15 },
|
{ {MsgType_names + 183, 15}, 1 },
|
{ {MsgType_names + 198, 16}, 10 },
|
{ {MsgType_names + 214, 19}, 18 },
|
{ {MsgType_names + 233, 20}, 16 },
|
{ {MsgType_names + 253, 25}, 17 },
|
{ {MsgType_names + 278, 17}, 22 },
|
{ {MsgType_names + 295, 18}, 26 },
|
{ {MsgType_names + 313, 19}, 24 },
|
};
|
|
static const int MsgType_entries_by_number[] = {
|
2, // 0 -> kMsgTypeInvalid
|
10, // 1 -> kMsgTypeRawData
|
0, // 2 -> kMsgTypeCommonReply
|
3, // 8 -> kMsgTypeProcInit
|
4, // 9 -> kMsgTypeProcInitReply
|
11, // 10 -> kMsgTypeRegister
|
1, // 12 -> kMsgTypeHeartbeat
|
8, // 14 -> kMsgTypeQueryTopic
|
9, // 15 -> kMsgTypeQueryTopicReply
|
13, // 16 -> kMsgTypeRequestTopic
|
14, // 17 -> kMsgTypeRequestTopicReply
|
12, // 18 -> kMsgTypeRegisterRPC
|
5, // 20 -> kMsgTypePublish
|
15, // 22 -> kMsgTypeSubscribe
|
17, // 24 -> kMsgTypeUnsubscribe
|
16, // 26 -> kMsgTypeUnregister
|
6, // 28 -> kMsgTypeQueryProc
|
7, // 29 -> kMsgTypeQueryProcReply
|
};
|
|
const std::string& MsgType_Name(
|
MsgType value) {
|
static const bool dummy =
|
::PROTOBUF_NAMESPACE_ID::internal::InitializeEnumStrings(
|
MsgType_entries,
|
MsgType_entries_by_number,
|
18, MsgType_strings);
|
(void) dummy;
|
int idx = ::PROTOBUF_NAMESPACE_ID::internal::LookUpEnumName(
|
MsgType_entries,
|
MsgType_entries_by_number,
|
18, value);
|
return idx == -1 ? ::PROTOBUF_NAMESPACE_ID::internal::GetEmptyString() :
|
MsgType_strings[idx].get();
|
}
|
bool MsgType_Parse(
|
const std::string& name, MsgType* value) {
|
int int_value;
|
bool success = ::PROTOBUF_NAMESPACE_ID::internal::LookUpEnumValue(
|
MsgType_entries, 18, name, &int_value);
|
if (success) {
|
*value = static_cast<MsgType>(int_value);
|
}
|
return success;
|
}
|
|
// ===================================================================
|
|
void BHMsgHead::InitAsDefaultInstance() {
|
::bhome_msg::_BHMsgHead_default_instance_._instance.get_mutable()->dest_ = const_cast< ::bhome_msg::BHAddress*>(
|
::bhome_msg::BHAddress::internal_default_instance());
|
}
|
class BHMsgHead::_Internal {
|
public:
|
static const ::bhome_msg::BHAddress& dest(const BHMsgHead* msg);
|
};
|
|
const ::bhome_msg::BHAddress&
|
BHMsgHead::_Internal::dest(const BHMsgHead* msg) {
|
return *msg->dest_;
|
}
|
void BHMsgHead::clear_route() {
|
route_.Clear();
|
}
|
void BHMsgHead::clear_dest() {
|
if (GetArenaNoVirtual() == nullptr && dest_ != nullptr) {
|
delete dest_;
|
}
|
dest_ = nullptr;
|
}
|
BHMsgHead::BHMsgHead()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.BHMsgHead)
|
}
|
BHMsgHead::BHMsgHead(const BHMsgHead& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr),
|
route_(from.route_) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
msg_id_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
if (!from._internal_msg_id().empty()) {
|
msg_id_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.msg_id_);
|
}
|
proc_id_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
if (!from._internal_proc_id().empty()) {
|
proc_id_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.proc_id_);
|
}
|
topic_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
if (!from._internal_topic().empty()) {
|
topic_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.topic_);
|
}
|
if (from._internal_has_dest()) {
|
dest_ = new ::bhome_msg::BHAddress(*from.dest_);
|
} else {
|
dest_ = nullptr;
|
}
|
::memcpy(×tamp_, &from.timestamp_,
|
static_cast<size_t>(reinterpret_cast<char*>(&type_) -
|
reinterpret_cast<char*>(×tamp_)) + sizeof(type_));
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.BHMsgHead)
|
}
|
|
void BHMsgHead::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_BHMsgHead_bhome_5fmsg_2eproto.base);
|
msg_id_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
proc_id_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
topic_.UnsafeSetDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
::memset(&dest_, 0, static_cast<size_t>(
|
reinterpret_cast<char*>(&type_) -
|
reinterpret_cast<char*>(&dest_)) + sizeof(type_));
|
}
|
|
BHMsgHead::~BHMsgHead() {
|
// @@protoc_insertion_point(destructor:bhome_msg.BHMsgHead)
|
SharedDtor();
|
}
|
|
void BHMsgHead::SharedDtor() {
|
msg_id_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
proc_id_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
topic_.DestroyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
if (this != internal_default_instance()) delete dest_;
|
}
|
|
void BHMsgHead::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const BHMsgHead& BHMsgHead::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_BHMsgHead_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void BHMsgHead::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.BHMsgHead)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
route_.Clear();
|
msg_id_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
proc_id_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
topic_.ClearToEmptyNoArena(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited());
|
if (GetArenaNoVirtual() == nullptr && dest_ != nullptr) {
|
delete dest_;
|
}
|
dest_ = nullptr;
|
::memset(×tamp_, 0, static_cast<size_t>(
|
reinterpret_cast<char*>(&type_) -
|
reinterpret_cast<char*>(×tamp_)) + sizeof(type_));
|
_internal_metadata_.Clear();
|
}
|
|
const char* BHMsgHead::_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) {
|
// bytes msg_id = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
auto str = _internal_mutable_msg_id();
|
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// repeated .bhome_msg.BHAddress route = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
|
ptr -= 1;
|
do {
|
ptr += 1;
|
ptr = ctx->ParseMessage(_internal_add_route(), ptr);
|
CHK_(ptr);
|
if (!ctx->DataAvailable(ptr)) break;
|
} while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
|
} else goto handle_unusual;
|
continue;
|
// int64 timestamp = 3;
|
case 3:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 24)) {
|
timestamp_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// int32 type = 4;
|
case 4:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 32)) {
|
type_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// uint64 ssn_id = 5;
|
case 5:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 40)) {
|
ssn_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// bytes proc_id = 6;
|
case 6:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 50)) {
|
auto str = _internal_mutable_proc_id();
|
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// bytes topic = 7;
|
case 7:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 58)) {
|
auto str = _internal_mutable_topic();
|
ptr = ::PROTOBUF_NAMESPACE_ID::internal::InlineGreedyStringParser(str, ptr, ctx);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// .bhome_msg.BHAddress dest = 8;
|
case 8:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 66)) {
|
ptr = ctx->ParseMessage(_internal_mutable_dest(), 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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* BHMsgHead::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.BHMsgHead)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// bytes msg_id = 1;
|
if (this->msg_id().size() > 0) {
|
target = stream->WriteBytesMaybeAliased(
|
1, this->_internal_msg_id(), target);
|
}
|
|
// repeated .bhome_msg.BHAddress route = 2;
|
for (unsigned int i = 0,
|
n = static_cast<unsigned int>(this->_internal_route_size()); i < n; i++) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(2, this->_internal_route(i), target, stream);
|
}
|
|
// int64 timestamp = 3;
|
if (this->timestamp() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt64ToArray(3, this->_internal_timestamp(), target);
|
}
|
|
// int32 type = 4;
|
if (this->type() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt32ToArray(4, this->_internal_type(), target);
|
}
|
|
// uint64 ssn_id = 5;
|
if (this->ssn_id() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteUInt64ToArray(5, this->_internal_ssn_id(), target);
|
}
|
|
// bytes proc_id = 6;
|
if (this->proc_id().size() > 0) {
|
target = stream->WriteBytesMaybeAliased(
|
6, this->_internal_proc_id(), target);
|
}
|
|
// bytes topic = 7;
|
if (this->topic().size() > 0) {
|
target = stream->WriteBytesMaybeAliased(
|
7, this->_internal_topic(), target);
|
}
|
|
// .bhome_msg.BHAddress dest = 8;
|
if (this->has_dest()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
8, _Internal::dest(this), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.BHMsgHead)
|
return target;
|
}
|
|
size_t BHMsgHead::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.BHMsgHead)
|
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;
|
|
// repeated .bhome_msg.BHAddress route = 2;
|
total_size += 1UL * this->_internal_route_size();
|
for (const auto& msg : this->route_) {
|
total_size +=
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
|
}
|
|
// bytes msg_id = 1;
|
if (this->msg_id().size() > 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
|
this->_internal_msg_id());
|
}
|
|
// bytes proc_id = 6;
|
if (this->proc_id().size() > 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
|
this->_internal_proc_id());
|
}
|
|
// bytes topic = 7;
|
if (this->topic().size() > 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
|
this->_internal_topic());
|
}
|
|
// .bhome_msg.BHAddress dest = 8;
|
if (this->has_dest()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*dest_);
|
}
|
|
// int64 timestamp = 3;
|
if (this->timestamp() != 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int64Size(
|
this->_internal_timestamp());
|
}
|
|
// uint64 ssn_id = 5;
|
if (this->ssn_id() != 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::UInt64Size(
|
this->_internal_ssn_id());
|
}
|
|
// int32 type = 4;
|
if (this->type() != 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int32Size(
|
this->_internal_type());
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void BHMsgHead::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const BHMsgHead*>(
|
&from));
|
}
|
|
void BHMsgHead::MergeFrom(const BHMsgHead& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.BHMsgHead)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
route_.MergeFrom(from.route_);
|
if (from.msg_id().size() > 0) {
|
|
msg_id_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.msg_id_);
|
}
|
if (from.proc_id().size() > 0) {
|
|
proc_id_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.proc_id_);
|
}
|
if (from.topic().size() > 0) {
|
|
topic_.AssignWithDefault(&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(), from.topic_);
|
}
|
if (from.has_dest()) {
|
_internal_mutable_dest()->::bhome_msg::BHAddress::MergeFrom(from._internal_dest());
|
}
|
if (from.timestamp() != 0) {
|
_internal_set_timestamp(from._internal_timestamp());
|
}
|
if (from.ssn_id() != 0) {
|
_internal_set_ssn_id(from._internal_ssn_id());
|
}
|
if (from.type() != 0) {
|
_internal_set_type(from._internal_type());
|
}
|
}
|
|
void BHMsgHead::CopyFrom(const BHMsgHead& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.BHMsgHead)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool BHMsgHead::IsInitialized() const {
|
return true;
|
}
|
|
void BHMsgHead::InternalSwap(BHMsgHead* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
route_.InternalSwap(&other->route_);
|
msg_id_.Swap(&other->msg_id_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
|
GetArenaNoVirtual());
|
proc_id_.Swap(&other->proc_id_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
|
GetArenaNoVirtual());
|
topic_.Swap(&other->topic_, &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited(),
|
GetArenaNoVirtual());
|
swap(dest_, other->dest_);
|
swap(timestamp_, other->timestamp_);
|
swap(ssn_id_, other->ssn_id_);
|
swap(type_, other->type_);
|
}
|
|
std::string BHMsgHead::GetTypeName() const {
|
return "bhome_msg.BHMsgHead";
|
}
|
|
|
// ===================================================================
|
|
void MsgSubscribe::InitAsDefaultInstance() {
|
::bhome_msg::_MsgSubscribe_default_instance_._instance.get_mutable()->topics_ = const_cast< ::bhome_msg::MsgTopicList*>(
|
::bhome_msg::MsgTopicList::internal_default_instance());
|
}
|
class MsgSubscribe::_Internal {
|
public:
|
static const ::bhome_msg::MsgTopicList& topics(const MsgSubscribe* msg);
|
};
|
|
const ::bhome_msg::MsgTopicList&
|
MsgSubscribe::_Internal::topics(const MsgSubscribe* msg) {
|
return *msg->topics_;
|
}
|
void MsgSubscribe::clear_topics() {
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
}
|
MsgSubscribe::MsgSubscribe()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgSubscribe)
|
}
|
MsgSubscribe::MsgSubscribe(const MsgSubscribe& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
if (from._internal_has_topics()) {
|
topics_ = new ::bhome_msg::MsgTopicList(*from.topics_);
|
} else {
|
topics_ = nullptr;
|
}
|
network_ = from.network_;
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgSubscribe)
|
}
|
|
void MsgSubscribe::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgSubscribe_bhome_5fmsg_2eproto.base);
|
::memset(&topics_, 0, static_cast<size_t>(
|
reinterpret_cast<char*>(&network_) -
|
reinterpret_cast<char*>(&topics_)) + sizeof(network_));
|
}
|
|
MsgSubscribe::~MsgSubscribe() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgSubscribe)
|
SharedDtor();
|
}
|
|
void MsgSubscribe::SharedDtor() {
|
if (this != internal_default_instance()) delete topics_;
|
}
|
|
void MsgSubscribe::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgSubscribe& MsgSubscribe::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgSubscribe_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgSubscribe::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgSubscribe)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
network_ = false;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgSubscribe::_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) {
|
// .bhome_msg.MsgTopicList topics = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_topics(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// bool network = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 16)) {
|
network_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgSubscribe::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgSubscribe)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::topics(this), target, stream);
|
}
|
|
// bool network = 2;
|
if (this->network() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(2, this->_internal_network(), target);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgSubscribe)
|
return target;
|
}
|
|
size_t MsgSubscribe::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgSubscribe)
|
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;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*topics_);
|
}
|
|
// bool network = 2;
|
if (this->network() != 0) {
|
total_size += 1 + 1;
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgSubscribe::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgSubscribe*>(
|
&from));
|
}
|
|
void MsgSubscribe::MergeFrom(const MsgSubscribe& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgSubscribe)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
if (from.has_topics()) {
|
_internal_mutable_topics()->::bhome_msg::MsgTopicList::MergeFrom(from._internal_topics());
|
}
|
if (from.network() != 0) {
|
_internal_set_network(from._internal_network());
|
}
|
}
|
|
void MsgSubscribe::CopyFrom(const MsgSubscribe& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgSubscribe)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgSubscribe::IsInitialized() const {
|
return true;
|
}
|
|
void MsgSubscribe::InternalSwap(MsgSubscribe* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(topics_, other->topics_);
|
swap(network_, other->network_);
|
}
|
|
std::string MsgSubscribe::GetTypeName() const {
|
return "bhome_msg.MsgSubscribe";
|
}
|
|
|
// ===================================================================
|
|
void MsgUnsubscribe::InitAsDefaultInstance() {
|
::bhome_msg::_MsgUnsubscribe_default_instance_._instance.get_mutable()->topics_ = const_cast< ::bhome_msg::MsgTopicList*>(
|
::bhome_msg::MsgTopicList::internal_default_instance());
|
}
|
class MsgUnsubscribe::_Internal {
|
public:
|
static const ::bhome_msg::MsgTopicList& topics(const MsgUnsubscribe* msg);
|
};
|
|
const ::bhome_msg::MsgTopicList&
|
MsgUnsubscribe::_Internal::topics(const MsgUnsubscribe* msg) {
|
return *msg->topics_;
|
}
|
void MsgUnsubscribe::clear_topics() {
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
}
|
MsgUnsubscribe::MsgUnsubscribe()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgUnsubscribe)
|
}
|
MsgUnsubscribe::MsgUnsubscribe(const MsgUnsubscribe& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
if (from._internal_has_topics()) {
|
topics_ = new ::bhome_msg::MsgTopicList(*from.topics_);
|
} else {
|
topics_ = nullptr;
|
}
|
network_ = from.network_;
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgUnsubscribe)
|
}
|
|
void MsgUnsubscribe::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgUnsubscribe_bhome_5fmsg_2eproto.base);
|
::memset(&topics_, 0, static_cast<size_t>(
|
reinterpret_cast<char*>(&network_) -
|
reinterpret_cast<char*>(&topics_)) + sizeof(network_));
|
}
|
|
MsgUnsubscribe::~MsgUnsubscribe() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgUnsubscribe)
|
SharedDtor();
|
}
|
|
void MsgUnsubscribe::SharedDtor() {
|
if (this != internal_default_instance()) delete topics_;
|
}
|
|
void MsgUnsubscribe::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgUnsubscribe& MsgUnsubscribe::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgUnsubscribe_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgUnsubscribe::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgUnsubscribe)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
network_ = false;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgUnsubscribe::_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) {
|
// .bhome_msg.MsgTopicList topics = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_topics(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// bool network = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 16)) {
|
network_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgUnsubscribe::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgUnsubscribe)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::topics(this), target, stream);
|
}
|
|
// bool network = 2;
|
if (this->network() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteBoolToArray(2, this->_internal_network(), target);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgUnsubscribe)
|
return target;
|
}
|
|
size_t MsgUnsubscribe::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgUnsubscribe)
|
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;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*topics_);
|
}
|
|
// bool network = 2;
|
if (this->network() != 0) {
|
total_size += 1 + 1;
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgUnsubscribe::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgUnsubscribe*>(
|
&from));
|
}
|
|
void MsgUnsubscribe::MergeFrom(const MsgUnsubscribe& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgUnsubscribe)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
if (from.has_topics()) {
|
_internal_mutable_topics()->::bhome_msg::MsgTopicList::MergeFrom(from._internal_topics());
|
}
|
if (from.network() != 0) {
|
_internal_set_network(from._internal_network());
|
}
|
}
|
|
void MsgUnsubscribe::CopyFrom(const MsgUnsubscribe& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgUnsubscribe)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgUnsubscribe::IsInitialized() const {
|
return true;
|
}
|
|
void MsgUnsubscribe::InternalSwap(MsgUnsubscribe* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(topics_, other->topics_);
|
swap(network_, other->network_);
|
}
|
|
std::string MsgUnsubscribe::GetTypeName() const {
|
return "bhome_msg.MsgUnsubscribe";
|
}
|
|
|
// ===================================================================
|
|
void MsgRegisterRPC::InitAsDefaultInstance() {
|
::bhome_msg::_MsgRegisterRPC_default_instance_._instance.get_mutable()->topics_ = const_cast< ::bhome_msg::MsgTopicList*>(
|
::bhome_msg::MsgTopicList::internal_default_instance());
|
}
|
class MsgRegisterRPC::_Internal {
|
public:
|
static const ::bhome_msg::MsgTopicList& topics(const MsgRegisterRPC* msg);
|
};
|
|
const ::bhome_msg::MsgTopicList&
|
MsgRegisterRPC::_Internal::topics(const MsgRegisterRPC* msg) {
|
return *msg->topics_;
|
}
|
void MsgRegisterRPC::clear_topics() {
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
}
|
MsgRegisterRPC::MsgRegisterRPC()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgRegisterRPC)
|
}
|
MsgRegisterRPC::MsgRegisterRPC(const MsgRegisterRPC& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
if (from._internal_has_topics()) {
|
topics_ = new ::bhome_msg::MsgTopicList(*from.topics_);
|
} else {
|
topics_ = nullptr;
|
}
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgRegisterRPC)
|
}
|
|
void MsgRegisterRPC::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgRegisterRPC_bhome_5fmsg_2eproto.base);
|
topics_ = nullptr;
|
}
|
|
MsgRegisterRPC::~MsgRegisterRPC() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgRegisterRPC)
|
SharedDtor();
|
}
|
|
void MsgRegisterRPC::SharedDtor() {
|
if (this != internal_default_instance()) delete topics_;
|
}
|
|
void MsgRegisterRPC::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgRegisterRPC& MsgRegisterRPC::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgRegisterRPC_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgRegisterRPC::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgRegisterRPC)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
if (GetArenaNoVirtual() == nullptr && topics_ != nullptr) {
|
delete topics_;
|
}
|
topics_ = nullptr;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgRegisterRPC::_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) {
|
// .bhome_msg.MsgTopicList topics = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_topics(), 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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgRegisterRPC::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgRegisterRPC)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::topics(this), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgRegisterRPC)
|
return target;
|
}
|
|
size_t MsgRegisterRPC::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgRegisterRPC)
|
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;
|
|
// .bhome_msg.MsgTopicList topics = 1;
|
if (this->has_topics()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*topics_);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgRegisterRPC::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgRegisterRPC*>(
|
&from));
|
}
|
|
void MsgRegisterRPC::MergeFrom(const MsgRegisterRPC& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgRegisterRPC)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
if (from.has_topics()) {
|
_internal_mutable_topics()->::bhome_msg::MsgTopicList::MergeFrom(from._internal_topics());
|
}
|
}
|
|
void MsgRegisterRPC::CopyFrom(const MsgRegisterRPC& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgRegisterRPC)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgRegisterRPC::IsInitialized() const {
|
return true;
|
}
|
|
void MsgRegisterRPC::InternalSwap(MsgRegisterRPC* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(topics_, other->topics_);
|
}
|
|
std::string MsgRegisterRPC::GetTypeName() const {
|
return "bhome_msg.MsgRegisterRPC";
|
}
|
|
|
// ===================================================================
|
|
void MsgProcInit::InitAsDefaultInstance() {
|
}
|
class MsgProcInit::_Internal {
|
public:
|
};
|
|
MsgProcInit::MsgProcInit()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgProcInit)
|
}
|
MsgProcInit::MsgProcInit(const MsgProcInit& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
extra_mq_num_ = from.extra_mq_num_;
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgProcInit)
|
}
|
|
void MsgProcInit::SharedCtor() {
|
extra_mq_num_ = 0;
|
}
|
|
MsgProcInit::~MsgProcInit() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgProcInit)
|
SharedDtor();
|
}
|
|
void MsgProcInit::SharedDtor() {
|
}
|
|
void MsgProcInit::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgProcInit& MsgProcInit::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgProcInit_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgProcInit::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgProcInit)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
extra_mq_num_ = 0;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgProcInit::_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) {
|
// int32 extra_mq_num = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 8)) {
|
extra_mq_num_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgProcInit::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgProcInit)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// int32 extra_mq_num = 1;
|
if (this->extra_mq_num() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt32ToArray(1, this->_internal_extra_mq_num(), target);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgProcInit)
|
return target;
|
}
|
|
size_t MsgProcInit::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgProcInit)
|
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;
|
|
// int32 extra_mq_num = 1;
|
if (this->extra_mq_num() != 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int32Size(
|
this->_internal_extra_mq_num());
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgProcInit::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgProcInit*>(
|
&from));
|
}
|
|
void MsgProcInit::MergeFrom(const MsgProcInit& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgProcInit)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
if (from.extra_mq_num() != 0) {
|
_internal_set_extra_mq_num(from._internal_extra_mq_num());
|
}
|
}
|
|
void MsgProcInit::CopyFrom(const MsgProcInit& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgProcInit)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgProcInit::IsInitialized() const {
|
return true;
|
}
|
|
void MsgProcInit::InternalSwap(MsgProcInit* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(extra_mq_num_, other->extra_mq_num_);
|
}
|
|
std::string MsgProcInit::GetTypeName() const {
|
return "bhome_msg.MsgProcInit";
|
}
|
|
|
// ===================================================================
|
|
void MsgProcInitReply::InitAsDefaultInstance() {
|
::bhome_msg::_MsgProcInitReply_default_instance_._instance.get_mutable()->errmsg_ = const_cast< ::bhome_msg::ErrorMsg*>(
|
::bhome_msg::ErrorMsg::internal_default_instance());
|
}
|
class MsgProcInitReply::_Internal {
|
public:
|
static const ::bhome_msg::ErrorMsg& errmsg(const MsgProcInitReply* msg);
|
};
|
|
const ::bhome_msg::ErrorMsg&
|
MsgProcInitReply::_Internal::errmsg(const MsgProcInitReply* msg) {
|
return *msg->errmsg_;
|
}
|
void MsgProcInitReply::clear_errmsg() {
|
if (GetArenaNoVirtual() == nullptr && errmsg_ != nullptr) {
|
delete errmsg_;
|
}
|
errmsg_ = nullptr;
|
}
|
void MsgProcInitReply::clear_extra_mqs() {
|
extra_mqs_.Clear();
|
}
|
MsgProcInitReply::MsgProcInitReply()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgProcInitReply)
|
}
|
MsgProcInitReply::MsgProcInitReply(const MsgProcInitReply& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr),
|
extra_mqs_(from.extra_mqs_) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
if (from._internal_has_errmsg()) {
|
errmsg_ = new ::bhome_msg::ErrorMsg(*from.errmsg_);
|
} else {
|
errmsg_ = nullptr;
|
}
|
proc_index_ = from.proc_index_;
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgProcInitReply)
|
}
|
|
void MsgProcInitReply::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgProcInitReply_bhome_5fmsg_2eproto.base);
|
::memset(&errmsg_, 0, static_cast<size_t>(
|
reinterpret_cast<char*>(&proc_index_) -
|
reinterpret_cast<char*>(&errmsg_)) + sizeof(proc_index_));
|
}
|
|
MsgProcInitReply::~MsgProcInitReply() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgProcInitReply)
|
SharedDtor();
|
}
|
|
void MsgProcInitReply::SharedDtor() {
|
if (this != internal_default_instance()) delete errmsg_;
|
}
|
|
void MsgProcInitReply::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgProcInitReply& MsgProcInitReply::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgProcInitReply_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgProcInitReply::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgProcInitReply)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
extra_mqs_.Clear();
|
if (GetArenaNoVirtual() == nullptr && errmsg_ != nullptr) {
|
delete errmsg_;
|
}
|
errmsg_ = nullptr;
|
proc_index_ = 0;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgProcInitReply::_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) {
|
// .bhome_msg.ErrorMsg errmsg = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_errmsg(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// int32 proc_index = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 16)) {
|
proc_index_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint(&ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// repeated .bhome_msg.BHAddress extra_mqs = 3;
|
case 3:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) {
|
ptr -= 1;
|
do {
|
ptr += 1;
|
ptr = ctx->ParseMessage(_internal_add_extra_mqs(), ptr);
|
CHK_(ptr);
|
if (!ctx->DataAvailable(ptr)) break;
|
} while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<26>(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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgProcInitReply::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgProcInitReply)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.ErrorMsg errmsg = 1;
|
if (this->has_errmsg()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::errmsg(this), target, stream);
|
}
|
|
// int32 proc_index = 2;
|
if (this->proc_index() != 0) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteInt32ToArray(2, this->_internal_proc_index(), target);
|
}
|
|
// repeated .bhome_msg.BHAddress extra_mqs = 3;
|
for (unsigned int i = 0,
|
n = static_cast<unsigned int>(this->_internal_extra_mqs_size()); i < n; i++) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(3, this->_internal_extra_mqs(i), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgProcInitReply)
|
return target;
|
}
|
|
size_t MsgProcInitReply::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgProcInitReply)
|
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;
|
|
// repeated .bhome_msg.BHAddress extra_mqs = 3;
|
total_size += 1UL * this->_internal_extra_mqs_size();
|
for (const auto& msg : this->extra_mqs_) {
|
total_size +=
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
|
}
|
|
// .bhome_msg.ErrorMsg errmsg = 1;
|
if (this->has_errmsg()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*errmsg_);
|
}
|
|
// int32 proc_index = 2;
|
if (this->proc_index() != 0) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::Int32Size(
|
this->_internal_proc_index());
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgProcInitReply::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgProcInitReply*>(
|
&from));
|
}
|
|
void MsgProcInitReply::MergeFrom(const MsgProcInitReply& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgProcInitReply)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
extra_mqs_.MergeFrom(from.extra_mqs_);
|
if (from.has_errmsg()) {
|
_internal_mutable_errmsg()->::bhome_msg::ErrorMsg::MergeFrom(from._internal_errmsg());
|
}
|
if (from.proc_index() != 0) {
|
_internal_set_proc_index(from._internal_proc_index());
|
}
|
}
|
|
void MsgProcInitReply::CopyFrom(const MsgProcInitReply& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgProcInitReply)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgProcInitReply::IsInitialized() const {
|
return true;
|
}
|
|
void MsgProcInitReply::InternalSwap(MsgProcInitReply* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
extra_mqs_.InternalSwap(&other->extra_mqs_);
|
swap(errmsg_, other->errmsg_);
|
swap(proc_index_, other->proc_index_);
|
}
|
|
std::string MsgProcInitReply::GetTypeName() const {
|
return "bhome_msg.MsgProcInitReply";
|
}
|
|
|
// ===================================================================
|
|
void MsgRequest::InitAsDefaultInstance() {
|
}
|
class MsgRequest::_Internal {
|
public:
|
static const ::bhome_msg::MsgRegister& register_(const MsgRequest* msg);
|
static const ::bhome_msg::MsgRequestTopic& topic_request(const MsgRequest* msg);
|
static const ::bhome_msg::MsgQueryTopic& topic_query(const MsgRequest* msg);
|
};
|
|
const ::bhome_msg::MsgRegister&
|
MsgRequest::_Internal::register_(const MsgRequest* msg) {
|
return *msg->request_.register__;
|
}
|
const ::bhome_msg::MsgRequestTopic&
|
MsgRequest::_Internal::topic_request(const MsgRequest* msg) {
|
return *msg->request_.topic_request_;
|
}
|
const ::bhome_msg::MsgQueryTopic&
|
MsgRequest::_Internal::topic_query(const MsgRequest* msg) {
|
return *msg->request_.topic_query_;
|
}
|
void MsgRequest::set_allocated_register_(::bhome_msg::MsgRegister* register_) {
|
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaNoVirtual();
|
clear_request();
|
if (register_) {
|
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = nullptr;
|
if (message_arena != submessage_arena) {
|
register_ = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
message_arena, register_, submessage_arena);
|
}
|
set_has_register_();
|
request_.register__ = register_;
|
}
|
// @@protoc_insertion_point(field_set_allocated:bhome_msg.MsgRequest.register)
|
}
|
void MsgRequest::clear_register_() {
|
if (_internal_has_register_()) {
|
delete request_.register__;
|
clear_has_request();
|
}
|
}
|
void MsgRequest::set_allocated_topic_request(::bhome_msg::MsgRequestTopic* topic_request) {
|
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaNoVirtual();
|
clear_request();
|
if (topic_request) {
|
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = nullptr;
|
if (message_arena != submessage_arena) {
|
topic_request = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
message_arena, topic_request, submessage_arena);
|
}
|
set_has_topic_request();
|
request_.topic_request_ = topic_request;
|
}
|
// @@protoc_insertion_point(field_set_allocated:bhome_msg.MsgRequest.topic_request)
|
}
|
void MsgRequest::clear_topic_request() {
|
if (_internal_has_topic_request()) {
|
delete request_.topic_request_;
|
clear_has_request();
|
}
|
}
|
void MsgRequest::set_allocated_topic_query(::bhome_msg::MsgQueryTopic* topic_query) {
|
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaNoVirtual();
|
clear_request();
|
if (topic_query) {
|
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = nullptr;
|
if (message_arena != submessage_arena) {
|
topic_query = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
message_arena, topic_query, submessage_arena);
|
}
|
set_has_topic_query();
|
request_.topic_query_ = topic_query;
|
}
|
// @@protoc_insertion_point(field_set_allocated:bhome_msg.MsgRequest.topic_query)
|
}
|
void MsgRequest::clear_topic_query() {
|
if (_internal_has_topic_query()) {
|
delete request_.topic_query_;
|
clear_has_request();
|
}
|
}
|
MsgRequest::MsgRequest()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgRequest)
|
}
|
MsgRequest::MsgRequest(const MsgRequest& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
clear_has_request();
|
switch (from.request_case()) {
|
case kRegister: {
|
_internal_mutable_register_()->::bhome_msg::MsgRegister::MergeFrom(from._internal_register_());
|
break;
|
}
|
case kTopicRequest: {
|
_internal_mutable_topic_request()->::bhome_msg::MsgRequestTopic::MergeFrom(from._internal_topic_request());
|
break;
|
}
|
case kTopicQuery: {
|
_internal_mutable_topic_query()->::bhome_msg::MsgQueryTopic::MergeFrom(from._internal_topic_query());
|
break;
|
}
|
case REQUEST_NOT_SET: {
|
break;
|
}
|
}
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgRequest)
|
}
|
|
void MsgRequest::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgRequest_bhome_5fmsg_2eproto.base);
|
clear_has_request();
|
}
|
|
MsgRequest::~MsgRequest() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgRequest)
|
SharedDtor();
|
}
|
|
void MsgRequest::SharedDtor() {
|
if (has_request()) {
|
clear_request();
|
}
|
}
|
|
void MsgRequest::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgRequest& MsgRequest::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgRequest_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgRequest::clear_request() {
|
// @@protoc_insertion_point(one_of_clear_start:bhome_msg.MsgRequest)
|
switch (request_case()) {
|
case kRegister: {
|
delete request_.register__;
|
break;
|
}
|
case kTopicRequest: {
|
delete request_.topic_request_;
|
break;
|
}
|
case kTopicQuery: {
|
delete request_.topic_query_;
|
break;
|
}
|
case REQUEST_NOT_SET: {
|
break;
|
}
|
}
|
_oneof_case_[0] = REQUEST_NOT_SET;
|
}
|
|
|
void MsgRequest::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgRequest)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
clear_request();
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgRequest::_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) {
|
// .bhome_msg.MsgRegister register = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_register_(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// .bhome_msg.MsgRequestTopic topic_request = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
|
ptr = ctx->ParseMessage(_internal_mutable_topic_request(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// .bhome_msg.MsgQueryTopic topic_query = 3;
|
case 3:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 26)) {
|
ptr = ctx->ParseMessage(_internal_mutable_topic_query(), 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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgRequest::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgRequest)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.MsgRegister register = 1;
|
if (_internal_has_register_()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::register_(this), target, stream);
|
}
|
|
// .bhome_msg.MsgRequestTopic topic_request = 2;
|
if (_internal_has_topic_request()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
2, _Internal::topic_request(this), target, stream);
|
}
|
|
// .bhome_msg.MsgQueryTopic topic_query = 3;
|
if (_internal_has_topic_query()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
3, _Internal::topic_query(this), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgRequest)
|
return target;
|
}
|
|
size_t MsgRequest::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgRequest)
|
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 (request_case()) {
|
// .bhome_msg.MsgRegister register = 1;
|
case kRegister: {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*request_.register__);
|
break;
|
}
|
// .bhome_msg.MsgRequestTopic topic_request = 2;
|
case kTopicRequest: {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*request_.topic_request_);
|
break;
|
}
|
// .bhome_msg.MsgQueryTopic topic_query = 3;
|
case kTopicQuery: {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*request_.topic_query_);
|
break;
|
}
|
case REQUEST_NOT_SET: {
|
break;
|
}
|
}
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgRequest::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgRequest*>(
|
&from));
|
}
|
|
void MsgRequest::MergeFrom(const MsgRequest& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgRequest)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
switch (from.request_case()) {
|
case kRegister: {
|
_internal_mutable_register_()->::bhome_msg::MsgRegister::MergeFrom(from._internal_register_());
|
break;
|
}
|
case kTopicRequest: {
|
_internal_mutable_topic_request()->::bhome_msg::MsgRequestTopic::MergeFrom(from._internal_topic_request());
|
break;
|
}
|
case kTopicQuery: {
|
_internal_mutable_topic_query()->::bhome_msg::MsgQueryTopic::MergeFrom(from._internal_topic_query());
|
break;
|
}
|
case REQUEST_NOT_SET: {
|
break;
|
}
|
}
|
}
|
|
void MsgRequest::CopyFrom(const MsgRequest& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgRequest)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgRequest::IsInitialized() const {
|
return true;
|
}
|
|
void MsgRequest::InternalSwap(MsgRequest* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(request_, other->request_);
|
swap(_oneof_case_[0], other->_oneof_case_[0]);
|
}
|
|
std::string MsgRequest::GetTypeName() const {
|
return "bhome_msg.MsgRequest";
|
}
|
|
|
// ===================================================================
|
|
void MsgReply::InitAsDefaultInstance() {
|
::bhome_msg::_MsgReply_default_instance_._instance.get_mutable()->err_msg_ = const_cast< ::bhome_msg::ErrorMsg*>(
|
::bhome_msg::ErrorMsg::internal_default_instance());
|
}
|
class MsgReply::_Internal {
|
public:
|
static const ::bhome_msg::ErrorMsg& err_msg(const MsgReply* msg);
|
};
|
|
const ::bhome_msg::ErrorMsg&
|
MsgReply::_Internal::err_msg(const MsgReply* msg) {
|
return *msg->err_msg_;
|
}
|
void MsgReply::clear_err_msg() {
|
if (GetArenaNoVirtual() == nullptr && err_msg_ != nullptr) {
|
delete err_msg_;
|
}
|
err_msg_ = nullptr;
|
}
|
MsgReply::MsgReply()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.MsgReply)
|
}
|
MsgReply::MsgReply(const MsgReply& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
if (from._internal_has_err_msg()) {
|
err_msg_ = new ::bhome_msg::ErrorMsg(*from.err_msg_);
|
} else {
|
err_msg_ = nullptr;
|
}
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.MsgReply)
|
}
|
|
void MsgReply::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_MsgReply_bhome_5fmsg_2eproto.base);
|
err_msg_ = nullptr;
|
}
|
|
MsgReply::~MsgReply() {
|
// @@protoc_insertion_point(destructor:bhome_msg.MsgReply)
|
SharedDtor();
|
}
|
|
void MsgReply::SharedDtor() {
|
if (this != internal_default_instance()) delete err_msg_;
|
}
|
|
void MsgReply::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const MsgReply& MsgReply::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_MsgReply_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void MsgReply::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.MsgReply)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
if (GetArenaNoVirtual() == nullptr && err_msg_ != nullptr) {
|
delete err_msg_;
|
}
|
err_msg_ = nullptr;
|
_internal_metadata_.Clear();
|
}
|
|
const char* MsgReply::_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) {
|
// .bhome_msg.ErrorMsg err_msg = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_err_msg(), 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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* MsgReply::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.MsgReply)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.ErrorMsg err_msg = 1;
|
if (this->has_err_msg()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::err_msg(this), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.MsgReply)
|
return target;
|
}
|
|
size_t MsgReply::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.MsgReply)
|
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;
|
|
// .bhome_msg.ErrorMsg err_msg = 1;
|
if (this->has_err_msg()) {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*err_msg_);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void MsgReply::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const MsgReply*>(
|
&from));
|
}
|
|
void MsgReply::MergeFrom(const MsgReply& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.MsgReply)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
if (from.has_err_msg()) {
|
_internal_mutable_err_msg()->::bhome_msg::ErrorMsg::MergeFrom(from._internal_err_msg());
|
}
|
}
|
|
void MsgReply::CopyFrom(const MsgReply& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.MsgReply)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool MsgReply::IsInitialized() const {
|
return true;
|
}
|
|
void MsgReply::InternalSwap(MsgReply* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(err_msg_, other->err_msg_);
|
}
|
|
std::string MsgReply::GetTypeName() const {
|
return "bhome_msg.MsgReply";
|
}
|
|
|
// ===================================================================
|
|
void BHMsgBody::InitAsDefaultInstance() {
|
}
|
class BHMsgBody::_Internal {
|
public:
|
static const ::bhome_msg::MsgRequest& request(const BHMsgBody* msg);
|
static const ::bhome_msg::MsgReply& reply(const BHMsgBody* msg);
|
};
|
|
const ::bhome_msg::MsgRequest&
|
BHMsgBody::_Internal::request(const BHMsgBody* msg) {
|
return *msg->reqrep_.request_;
|
}
|
const ::bhome_msg::MsgReply&
|
BHMsgBody::_Internal::reply(const BHMsgBody* msg) {
|
return *msg->reqrep_.reply_;
|
}
|
void BHMsgBody::set_allocated_request(::bhome_msg::MsgRequest* request) {
|
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaNoVirtual();
|
clear_reqrep();
|
if (request) {
|
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = nullptr;
|
if (message_arena != submessage_arena) {
|
request = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
message_arena, request, submessage_arena);
|
}
|
set_has_request();
|
reqrep_.request_ = request;
|
}
|
// @@protoc_insertion_point(field_set_allocated:bhome_msg.BHMsgBody.request)
|
}
|
void BHMsgBody::set_allocated_reply(::bhome_msg::MsgReply* reply) {
|
::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaNoVirtual();
|
clear_reqrep();
|
if (reply) {
|
::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena = nullptr;
|
if (message_arena != submessage_arena) {
|
reply = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
|
message_arena, reply, submessage_arena);
|
}
|
set_has_reply();
|
reqrep_.reply_ = reply;
|
}
|
// @@protoc_insertion_point(field_set_allocated:bhome_msg.BHMsgBody.reply)
|
}
|
BHMsgBody::BHMsgBody()
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(), _internal_metadata_(nullptr) {
|
SharedCtor();
|
// @@protoc_insertion_point(constructor:bhome_msg.BHMsgBody)
|
}
|
BHMsgBody::BHMsgBody(const BHMsgBody& from)
|
: ::PROTOBUF_NAMESPACE_ID::MessageLite(),
|
_internal_metadata_(nullptr) {
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
clear_has_reqrep();
|
switch (from.reqrep_case()) {
|
case kRequest: {
|
_internal_mutable_request()->::bhome_msg::MsgRequest::MergeFrom(from._internal_request());
|
break;
|
}
|
case kReply: {
|
_internal_mutable_reply()->::bhome_msg::MsgReply::MergeFrom(from._internal_reply());
|
break;
|
}
|
case REQREP_NOT_SET: {
|
break;
|
}
|
}
|
// @@protoc_insertion_point(copy_constructor:bhome_msg.BHMsgBody)
|
}
|
|
void BHMsgBody::SharedCtor() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&scc_info_BHMsgBody_bhome_5fmsg_2eproto.base);
|
clear_has_reqrep();
|
}
|
|
BHMsgBody::~BHMsgBody() {
|
// @@protoc_insertion_point(destructor:bhome_msg.BHMsgBody)
|
SharedDtor();
|
}
|
|
void BHMsgBody::SharedDtor() {
|
if (has_reqrep()) {
|
clear_reqrep();
|
}
|
}
|
|
void BHMsgBody::SetCachedSize(int size) const {
|
_cached_size_.Set(size);
|
}
|
const BHMsgBody& BHMsgBody::default_instance() {
|
::PROTOBUF_NAMESPACE_ID::internal::InitSCC(&::scc_info_BHMsgBody_bhome_5fmsg_2eproto.base);
|
return *internal_default_instance();
|
}
|
|
|
void BHMsgBody::clear_reqrep() {
|
// @@protoc_insertion_point(one_of_clear_start:bhome_msg.BHMsgBody)
|
switch (reqrep_case()) {
|
case kRequest: {
|
delete reqrep_.request_;
|
break;
|
}
|
case kReply: {
|
delete reqrep_.reply_;
|
break;
|
}
|
case REQREP_NOT_SET: {
|
break;
|
}
|
}
|
_oneof_case_[0] = REQREP_NOT_SET;
|
}
|
|
|
void BHMsgBody::Clear() {
|
// @@protoc_insertion_point(message_clear_start:bhome_msg.BHMsgBody)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
// Prevent compiler warnings about cached_has_bits being unused
|
(void) cached_has_bits;
|
|
clear_reqrep();
|
_internal_metadata_.Clear();
|
}
|
|
const char* BHMsgBody::_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) {
|
// .bhome_msg.MsgRequest request = 1;
|
case 1:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 10)) {
|
ptr = ctx->ParseMessage(_internal_mutable_request(), ptr);
|
CHK_(ptr);
|
} else goto handle_unusual;
|
continue;
|
// .bhome_msg.MsgReply reply = 2;
|
case 2:
|
if (PROTOBUF_PREDICT_TRUE(static_cast<::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 18)) {
|
ptr = ctx->ParseMessage(_internal_mutable_reply(), 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_, ptr, ctx);
|
CHK_(ptr != nullptr);
|
continue;
|
}
|
} // switch
|
} // while
|
success:
|
return ptr;
|
failure:
|
ptr = nullptr;
|
goto success;
|
#undef CHK_
|
}
|
|
::PROTOBUF_NAMESPACE_ID::uint8* BHMsgBody::_InternalSerialize(
|
::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
|
// @@protoc_insertion_point(serialize_to_array_start:bhome_msg.BHMsgBody)
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
// .bhome_msg.MsgRequest request = 1;
|
if (_internal_has_request()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
1, _Internal::request(this), target, stream);
|
}
|
|
// .bhome_msg.MsgReply reply = 2;
|
if (_internal_has_reply()) {
|
target = stream->EnsureSpace(target);
|
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
|
InternalWriteMessage(
|
2, _Internal::reply(this), target, stream);
|
}
|
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
target = stream->WriteRaw(_internal_metadata_.unknown_fields().data(),
|
static_cast<int>(_internal_metadata_.unknown_fields().size()), target);
|
}
|
// @@protoc_insertion_point(serialize_to_array_end:bhome_msg.BHMsgBody)
|
return target;
|
}
|
|
size_t BHMsgBody::ByteSizeLong() const {
|
// @@protoc_insertion_point(message_byte_size_start:bhome_msg.BHMsgBody)
|
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 (reqrep_case()) {
|
// .bhome_msg.MsgRequest request = 1;
|
case kRequest: {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*reqrep_.request_);
|
break;
|
}
|
// .bhome_msg.MsgReply reply = 2;
|
case kReply: {
|
total_size += 1 +
|
::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
|
*reqrep_.reply_);
|
break;
|
}
|
case REQREP_NOT_SET: {
|
break;
|
}
|
}
|
if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
|
total_size += _internal_metadata_.unknown_fields().size();
|
}
|
int cached_size = ::PROTOBUF_NAMESPACE_ID::internal::ToCachedSize(total_size);
|
SetCachedSize(cached_size);
|
return total_size;
|
}
|
|
void BHMsgBody::CheckTypeAndMergeFrom(
|
const ::PROTOBUF_NAMESPACE_ID::MessageLite& from) {
|
MergeFrom(*::PROTOBUF_NAMESPACE_ID::internal::DownCast<const BHMsgBody*>(
|
&from));
|
}
|
|
void BHMsgBody::MergeFrom(const BHMsgBody& from) {
|
// @@protoc_insertion_point(class_specific_merge_from_start:bhome_msg.BHMsgBody)
|
GOOGLE_DCHECK_NE(&from, this);
|
_internal_metadata_.MergeFrom(from._internal_metadata_);
|
::PROTOBUF_NAMESPACE_ID::uint32 cached_has_bits = 0;
|
(void) cached_has_bits;
|
|
switch (from.reqrep_case()) {
|
case kRequest: {
|
_internal_mutable_request()->::bhome_msg::MsgRequest::MergeFrom(from._internal_request());
|
break;
|
}
|
case kReply: {
|
_internal_mutable_reply()->::bhome_msg::MsgReply::MergeFrom(from._internal_reply());
|
break;
|
}
|
case REQREP_NOT_SET: {
|
break;
|
}
|
}
|
}
|
|
void BHMsgBody::CopyFrom(const BHMsgBody& from) {
|
// @@protoc_insertion_point(class_specific_copy_from_start:bhome_msg.BHMsgBody)
|
if (&from == this) return;
|
Clear();
|
MergeFrom(from);
|
}
|
|
bool BHMsgBody::IsInitialized() const {
|
return true;
|
}
|
|
void BHMsgBody::InternalSwap(BHMsgBody* other) {
|
using std::swap;
|
_internal_metadata_.Swap(&other->_internal_metadata_);
|
swap(reqrep_, other->reqrep_);
|
swap(_oneof_case_[0], other->_oneof_case_[0]);
|
}
|
|
std::string BHMsgBody::GetTypeName() const {
|
return "bhome_msg.BHMsgBody";
|
}
|
|
|
// @@protoc_insertion_point(namespace_scope)
|
} // namespace bhome_msg
|
PROTOBUF_NAMESPACE_OPEN
|
template<> PROTOBUF_NOINLINE ::bhome_msg::BHMsgHead* Arena::CreateMaybeMessage< ::bhome_msg::BHMsgHead >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::BHMsgHead >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgSubscribe* Arena::CreateMaybeMessage< ::bhome_msg::MsgSubscribe >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgSubscribe >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgUnsubscribe* Arena::CreateMaybeMessage< ::bhome_msg::MsgUnsubscribe >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgUnsubscribe >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgRegisterRPC* Arena::CreateMaybeMessage< ::bhome_msg::MsgRegisterRPC >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgRegisterRPC >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgProcInit* Arena::CreateMaybeMessage< ::bhome_msg::MsgProcInit >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgProcInit >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgProcInitReply* Arena::CreateMaybeMessage< ::bhome_msg::MsgProcInitReply >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgProcInitReply >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgRequest* Arena::CreateMaybeMessage< ::bhome_msg::MsgRequest >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgRequest >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::MsgReply* Arena::CreateMaybeMessage< ::bhome_msg::MsgReply >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::MsgReply >(arena);
|
}
|
template<> PROTOBUF_NOINLINE ::bhome_msg::BHMsgBody* Arena::CreateMaybeMessage< ::bhome_msg::BHMsgBody >(Arena* arena) {
|
return Arena::CreateInternal< ::bhome_msg::BHMsgBody >(arena);
|
}
|
PROTOBUF_NAMESPACE_CLOSE
|
|
// @@protoc_insertion_point(global_scope)
|
#include <google/protobuf/port_undef.inc>
|
