From d62c100ddc8da7854d0c233ecb78039f310a8090 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 25 Aug 2020 15:02:23 +0800 Subject: [PATCH] 1 --- cpp/im_msgid.pb.cc | 94 +++++++ cpp/im_msgid.pb.h | 83 ++++++ cpp/im_proto.pb.cc | 677 +++++++++++++++++++++++++++++++++++++++++++++ cpp/im_proto.pb.h | 520 ++++++++++++++++++++++++++++++++++ 4 files changed, 1374 insertions(+) create mode 100644 cpp/im_msgid.pb.cc create mode 100644 cpp/im_msgid.pb.h create mode 100644 cpp/im_proto.pb.cc create mode 100644 cpp/im_proto.pb.h diff --git a/cpp/im_msgid.pb.cc b/cpp/im_msgid.pb.cc new file mode 100644 index 0000000..4afb679 --- /dev/null +++ b/cpp/im_msgid.pb.cc @@ -0,0 +1,94 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: im_msgid.proto + +#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION +#include "im_msgid.pb.h" + +#include + +#include +#include +#include +#include +#include +#include +#include +#include +// @@protoc_insertion_point(includes) + +namespace im { + +namespace { + +const ::google::protobuf::EnumDescriptor* IMMessageId_e_descriptor_ = NULL; + +} // namespace + + +void protobuf_AssignDesc_im_5fmsgid_2eproto() { + protobuf_AddDesc_im_5fmsgid_2eproto(); + const ::google::protobuf::FileDescriptor* file = + ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName( + "im_msgid.proto"); + GOOGLE_CHECK(file != NULL); + IMMessageId_e_descriptor_ = file->enum_type(0); +} + +namespace { + +GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_); +inline void protobuf_AssignDescriptorsOnce() { + ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_, + &protobuf_AssignDesc_im_5fmsgid_2eproto); +} + +void protobuf_RegisterTypes(const ::std::string&) { + protobuf_AssignDescriptorsOnce(); +} + +} // namespace + +void protobuf_ShutdownFile_im_5fmsgid_2eproto() { +} + +void protobuf_AddDesc_im_5fmsgid_2eproto() { + static bool already_here = false; + if (already_here) return; + already_here = true; + GOOGLE_PROTOBUF_VERIFY_VERSION; + + ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( + "\n\016im_msgid.proto\022\002im*>\n\rIMMessageId_e\022\024\n" + "\020_IMSocketConnect\020\001\022\027\n\023_IMSocketDisconne" + "ct\020\002", 84); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( + "im_msgid.proto", &protobuf_RegisterTypes); + ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_im_5fmsgid_2eproto); +} + +// Force AddDescriptors() to be called at static initialization time. +struct StaticDescriptorInitializer_im_5fmsgid_2eproto { + StaticDescriptorInitializer_im_5fmsgid_2eproto() { + protobuf_AddDesc_im_5fmsgid_2eproto(); + } +} static_descriptor_initializer_im_5fmsgid_2eproto_; +const ::google::protobuf::EnumDescriptor* IMMessageId_e_descriptor() { + protobuf_AssignDescriptorsOnce(); + return IMMessageId_e_descriptor_; +} +bool IMMessageId_e_IsValid(int value) { + switch(value) { + case 1: + case 2: + return true; + default: + return false; + } +} + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace im + +// @@protoc_insertion_point(global_scope) diff --git a/cpp/im_msgid.pb.h b/cpp/im_msgid.pb.h new file mode 100644 index 0000000..1a2b2bb --- /dev/null +++ b/cpp/im_msgid.pb.h @@ -0,0 +1,83 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: im_msgid.proto + +#ifndef PROTOBUF_im_5fmsgid_2eproto__INCLUDED +#define PROTOBUF_im_5fmsgid_2eproto__INCLUDED + +#include + +#include + +#if GOOGLE_PROTOBUF_VERSION < 2005000 +#error This file was generated by a newer version of protoc which is +#error incompatible with your Protocol Buffer headers. Please update +#error your headers. +#endif +#if 2005000 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION +#error This file was generated by an older version of protoc which is +#error incompatible with your Protocol Buffer headers. Please +#error regenerate this file with a newer version of protoc. +#endif + +#include +#include +#include +#include +// @@protoc_insertion_point(includes) + +namespace im { + +// Internal implementation detail -- do not call these. +void protobuf_AddDesc_im_5fmsgid_2eproto(); +void protobuf_AssignDesc_im_5fmsgid_2eproto(); +void protobuf_ShutdownFile_im_5fmsgid_2eproto(); + + +enum IMMessageId_e { + _IMSocketConnect = 1, + _IMSocketDisconnect = 2 +}; +bool IMMessageId_e_IsValid(int value); +const IMMessageId_e IMMessageId_e_MIN = _IMSocketConnect; +const IMMessageId_e IMMessageId_e_MAX = _IMSocketDisconnect; +const int IMMessageId_e_ARRAYSIZE = IMMessageId_e_MAX + 1; + +const ::google::protobuf::EnumDescriptor* IMMessageId_e_descriptor(); +inline const ::std::string& IMMessageId_e_Name(IMMessageId_e value) { + return ::google::protobuf::internal::NameOfEnum( + IMMessageId_e_descriptor(), value); +} +inline bool IMMessageId_e_Parse( + const ::std::string& name, IMMessageId_e* value) { + return ::google::protobuf::internal::ParseNamedEnum( + IMMessageId_e_descriptor(), name, value); +} +// =================================================================== + + +// =================================================================== + + +// =================================================================== + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace im + +#ifndef SWIG +namespace google { +namespace protobuf { + +template <> +inline const EnumDescriptor* GetEnumDescriptor< ::im::IMMessageId_e>() { + return ::im::IMMessageId_e_descriptor(); +} + +} // namespace google +} // namespace protobuf +#endif // SWIG + +// @@protoc_insertion_point(global_scope) + +#endif // PROTOBUF_im_5fmsgid_2eproto__INCLUDED diff --git a/cpp/im_proto.pb.cc b/cpp/im_proto.pb.cc new file mode 100644 index 0000000..33d8882 --- /dev/null +++ b/cpp/im_proto.pb.cc @@ -0,0 +1,677 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: im_proto.proto + +#define INTERNAL_SUPPRESS_PROTOBUF_FIELD_DEPRECATION +#include "im_proto.pb.h" + +#include + +#include +#include +#include +#include +#include +#include +#include +#include +// @@protoc_insertion_point(includes) + +namespace im { + +namespace { + +const ::google::protobuf::Descriptor* IMSocketConnect_descriptor_ = NULL; +const ::google::protobuf::internal::GeneratedMessageReflection* + IMSocketConnect_reflection_ = NULL; +const ::google::protobuf::Descriptor* IMSocketDisconnect_descriptor_ = NULL; +const ::google::protobuf::internal::GeneratedMessageReflection* + IMSocketDisconnect_reflection_ = NULL; +const ::google::protobuf::EnumDescriptor* Constant_e_descriptor_ = NULL; + +} // namespace + + +void protobuf_AssignDesc_im_5fproto_2eproto() { + protobuf_AddDesc_im_5fproto_2eproto(); + const ::google::protobuf::FileDescriptor* file = + ::google::protobuf::DescriptorPool::generated_pool()->FindFileByName( + "im_proto.proto"); + GOOGLE_CHECK(file != NULL); + IMSocketConnect_descriptor_ = file->message_type(0); + static const int IMSocketConnect_offsets_[4] = { + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, is_websocket_), + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, host_), + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, url_), + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, query_str_), + }; + IMSocketConnect_reflection_ = + new ::google::protobuf::internal::GeneratedMessageReflection( + IMSocketConnect_descriptor_, + IMSocketConnect::default_instance_, + IMSocketConnect_offsets_, + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, _has_bits_[0]), + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketConnect, _unknown_fields_), + -1, + ::google::protobuf::DescriptorPool::generated_pool(), + ::google::protobuf::MessageFactory::generated_factory(), + sizeof(IMSocketConnect)); + IMSocketDisconnect_descriptor_ = file->message_type(1); + static const int IMSocketDisconnect_offsets_[1] = { + }; + IMSocketDisconnect_reflection_ = + new ::google::protobuf::internal::GeneratedMessageReflection( + IMSocketDisconnect_descriptor_, + IMSocketDisconnect::default_instance_, + IMSocketDisconnect_offsets_, + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketDisconnect, _has_bits_[0]), + GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(IMSocketDisconnect, _unknown_fields_), + -1, + ::google::protobuf::DescriptorPool::generated_pool(), + ::google::protobuf::MessageFactory::generated_factory(), + sizeof(IMSocketDisconnect)); + Constant_e_descriptor_ = file->enum_type(0); +} + +namespace { + +GOOGLE_PROTOBUF_DECLARE_ONCE(protobuf_AssignDescriptors_once_); +inline void protobuf_AssignDescriptorsOnce() { + ::google::protobuf::GoogleOnceInit(&protobuf_AssignDescriptors_once_, + &protobuf_AssignDesc_im_5fproto_2eproto); +} + +void protobuf_RegisterTypes(const ::std::string&) { + protobuf_AssignDescriptorsOnce(); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage( + IMSocketConnect_descriptor_, &IMSocketConnect::default_instance()); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage( + IMSocketDisconnect_descriptor_, &IMSocketDisconnect::default_instance()); +} + +} // namespace + +void protobuf_ShutdownFile_im_5fproto_2eproto() { + delete IMSocketConnect::default_instance_; + delete IMSocketConnect_reflection_; + delete IMSocketDisconnect::default_instance_; + delete IMSocketDisconnect_reflection_; +} + +void protobuf_AddDesc_im_5fproto_2eproto() { + static bool already_here = false; + if (already_here) return; + already_here = true; + GOOGLE_PROTOBUF_VERIFY_VERSION; + + ::google::protobuf::DescriptorPool::InternalAddGeneratedFile( + "\n\016im_proto.proto\022\002im\"U\n\017IMSocketConnect\022" + "\024\n\014is_websocket\030\001 \001(\010\022\014\n\004host\030\002 \001(\t\022\013\n\003u" + "rl\030\003 \001(\t\022\021\n\tquery_str\030\004 \001(\t\"\024\n\022IMSocketD" + "isconnect*\034\n\nConstant_e\022\016\n\nMaxIMMsgId\020\007", 159); + ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile( + "im_proto.proto", &protobuf_RegisterTypes); + IMSocketConnect::default_instance_ = new IMSocketConnect(); + IMSocketDisconnect::default_instance_ = new IMSocketDisconnect(); + IMSocketConnect::default_instance_->InitAsDefaultInstance(); + IMSocketDisconnect::default_instance_->InitAsDefaultInstance(); + ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_im_5fproto_2eproto); +} + +// Force AddDescriptors() to be called at static initialization time. +struct StaticDescriptorInitializer_im_5fproto_2eproto { + StaticDescriptorInitializer_im_5fproto_2eproto() { + protobuf_AddDesc_im_5fproto_2eproto(); + } +} static_descriptor_initializer_im_5fproto_2eproto_; +const ::google::protobuf::EnumDescriptor* Constant_e_descriptor() { + protobuf_AssignDescriptorsOnce(); + return Constant_e_descriptor_; +} +bool Constant_e_IsValid(int value) { + switch(value) { + case 7: + return true; + default: + return false; + } +} + + +// =================================================================== + +#ifndef _MSC_VER +const int IMSocketConnect::kIsWebsocketFieldNumber; +const int IMSocketConnect::kHostFieldNumber; +const int IMSocketConnect::kUrlFieldNumber; +const int IMSocketConnect::kQueryStrFieldNumber; +#endif // !_MSC_VER + +IMSocketConnect::IMSocketConnect() + : ::google::protobuf::Message() { + SharedCtor(); +} + +void IMSocketConnect::InitAsDefaultInstance() { +} + +IMSocketConnect::IMSocketConnect(const IMSocketConnect& from) + : ::google::protobuf::Message() { + SharedCtor(); + MergeFrom(from); +} + +void IMSocketConnect::SharedCtor() { + _cached_size_ = 0; + is_websocket_ = false; + host_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + url_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + query_str_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + ::memset(_has_bits_, 0, sizeof(_has_bits_)); +} + +IMSocketConnect::~IMSocketConnect() { + SharedDtor(); +} + +void IMSocketConnect::SharedDtor() { + if (host_ != &::google::protobuf::internal::kEmptyString) { + delete host_; + } + if (url_ != &::google::protobuf::internal::kEmptyString) { + delete url_; + } + if (query_str_ != &::google::protobuf::internal::kEmptyString) { + delete query_str_; + } + if (this != default_instance_) { + } +} + +void IMSocketConnect::SetCachedSize(int size) const { + GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); + _cached_size_ = size; + GOOGLE_SAFE_CONCURRENT_WRITES_END(); +} +const ::google::protobuf::Descriptor* IMSocketConnect::descriptor() { + protobuf_AssignDescriptorsOnce(); + return IMSocketConnect_descriptor_; +} + +const IMSocketConnect& IMSocketConnect::default_instance() { + if (default_instance_ == NULL) protobuf_AddDesc_im_5fproto_2eproto(); + return *default_instance_; +} + +IMSocketConnect* IMSocketConnect::default_instance_ = NULL; + +IMSocketConnect* IMSocketConnect::New() const { + return new IMSocketConnect; +} + +void IMSocketConnect::Clear() { + if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) { + is_websocket_ = false; + if (has_host()) { + if (host_ != &::google::protobuf::internal::kEmptyString) { + host_->clear(); + } + } + if (has_url()) { + if (url_ != &::google::protobuf::internal::kEmptyString) { + url_->clear(); + } + } + if (has_query_str()) { + if (query_str_ != &::google::protobuf::internal::kEmptyString) { + query_str_->clear(); + } + } + } + ::memset(_has_bits_, 0, sizeof(_has_bits_)); + mutable_unknown_fields()->Clear(); +} + +bool IMSocketConnect::MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) { +#define DO_(EXPRESSION) if (!(EXPRESSION)) return false + ::google::protobuf::uint32 tag; + while ((tag = input->ReadTag()) != 0) { + switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) { + // optional bool is_websocket = 1; + case 1: { + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) { + DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive< + bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>( + input, &is_websocket_))); + set_has_is_websocket(); + } else { + goto handle_uninterpreted; + } + if (input->ExpectTag(18)) goto parse_host; + break; + } + + // optional string host = 2; + case 2: { + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) { + parse_host: + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_host())); + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->host().data(), this->host().length(), + ::google::protobuf::internal::WireFormat::PARSE); + } else { + goto handle_uninterpreted; + } + if (input->ExpectTag(26)) goto parse_url; + break; + } + + // optional string url = 3; + case 3: { + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) { + parse_url: + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_url())); + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->url().data(), this->url().length(), + ::google::protobuf::internal::WireFormat::PARSE); + } else { + goto handle_uninterpreted; + } + if (input->ExpectTag(34)) goto parse_query_str; + break; + } + + // optional string query_str = 4; + case 4: { + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) { + parse_query_str: + DO_(::google::protobuf::internal::WireFormatLite::ReadString( + input, this->mutable_query_str())); + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->query_str().data(), this->query_str().length(), + ::google::protobuf::internal::WireFormat::PARSE); + } else { + goto handle_uninterpreted; + } + if (input->ExpectAtEnd()) return true; + break; + } + + default: { + handle_uninterpreted: + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) { + return true; + } + DO_(::google::protobuf::internal::WireFormat::SkipField( + input, tag, mutable_unknown_fields())); + break; + } + } + } + return true; +#undef DO_ +} + +void IMSocketConnect::SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const { + // optional bool is_websocket = 1; + if (has_is_websocket()) { + ::google::protobuf::internal::WireFormatLite::WriteBool(1, this->is_websocket(), output); + } + + // optional string host = 2; + if (has_host()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->host().data(), this->host().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + ::google::protobuf::internal::WireFormatLite::WriteString( + 2, this->host(), output); + } + + // optional string url = 3; + if (has_url()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->url().data(), this->url().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + ::google::protobuf::internal::WireFormatLite::WriteString( + 3, this->url(), output); + } + + // optional string query_str = 4; + if (has_query_str()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->query_str().data(), this->query_str().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + ::google::protobuf::internal::WireFormatLite::WriteString( + 4, this->query_str(), output); + } + + if (!unknown_fields().empty()) { + ::google::protobuf::internal::WireFormat::SerializeUnknownFields( + unknown_fields(), output); + } +} + +::google::protobuf::uint8* IMSocketConnect::SerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const { + // optional bool is_websocket = 1; + if (has_is_websocket()) { + target = ::google::protobuf::internal::WireFormatLite::WriteBoolToArray(1, this->is_websocket(), target); + } + + // optional string host = 2; + if (has_host()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->host().data(), this->host().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 2, this->host(), target); + } + + // optional string url = 3; + if (has_url()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->url().data(), this->url().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 3, this->url(), target); + } + + // optional string query_str = 4; + if (has_query_str()) { + ::google::protobuf::internal::WireFormat::VerifyUTF8String( + this->query_str().data(), this->query_str().length(), + ::google::protobuf::internal::WireFormat::SERIALIZE); + target = + ::google::protobuf::internal::WireFormatLite::WriteStringToArray( + 4, this->query_str(), target); + } + + if (!unknown_fields().empty()) { + target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( + unknown_fields(), target); + } + return target; +} + +int IMSocketConnect::ByteSize() const { + int total_size = 0; + + if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) { + // optional bool is_websocket = 1; + if (has_is_websocket()) { + total_size += 1 + 1; + } + + // optional string host = 2; + if (has_host()) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->host()); + } + + // optional string url = 3; + if (has_url()) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->url()); + } + + // optional string query_str = 4; + if (has_query_str()) { + total_size += 1 + + ::google::protobuf::internal::WireFormatLite::StringSize( + this->query_str()); + } + + } + if (!unknown_fields().empty()) { + total_size += + ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( + unknown_fields()); + } + GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); + _cached_size_ = total_size; + GOOGLE_SAFE_CONCURRENT_WRITES_END(); + return total_size; +} + +void IMSocketConnect::MergeFrom(const ::google::protobuf::Message& from) { + GOOGLE_CHECK_NE(&from, this); + const IMSocketConnect* source = + ::google::protobuf::internal::dynamic_cast_if_available( + &from); + if (source == NULL) { + ::google::protobuf::internal::ReflectionOps::Merge(from, this); + } else { + MergeFrom(*source); + } +} + +void IMSocketConnect::MergeFrom(const IMSocketConnect& from) { + GOOGLE_CHECK_NE(&from, this); + if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) { + if (from.has_is_websocket()) { + set_is_websocket(from.is_websocket()); + } + if (from.has_host()) { + set_host(from.host()); + } + if (from.has_url()) { + set_url(from.url()); + } + if (from.has_query_str()) { + set_query_str(from.query_str()); + } + } + mutable_unknown_fields()->MergeFrom(from.unknown_fields()); +} + +void IMSocketConnect::CopyFrom(const ::google::protobuf::Message& from) { + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +void IMSocketConnect::CopyFrom(const IMSocketConnect& from) { + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool IMSocketConnect::IsInitialized() const { + + return true; +} + +void IMSocketConnect::Swap(IMSocketConnect* other) { + if (other != this) { + std::swap(is_websocket_, other->is_websocket_); + std::swap(host_, other->host_); + std::swap(url_, other->url_); + std::swap(query_str_, other->query_str_); + std::swap(_has_bits_[0], other->_has_bits_[0]); + _unknown_fields_.Swap(&other->_unknown_fields_); + std::swap(_cached_size_, other->_cached_size_); + } +} + +::google::protobuf::Metadata IMSocketConnect::GetMetadata() const { + protobuf_AssignDescriptorsOnce(); + ::google::protobuf::Metadata metadata; + metadata.descriptor = IMSocketConnect_descriptor_; + metadata.reflection = IMSocketConnect_reflection_; + return metadata; +} + + +// =================================================================== + +#ifndef _MSC_VER +#endif // !_MSC_VER + +IMSocketDisconnect::IMSocketDisconnect() + : ::google::protobuf::Message() { + SharedCtor(); +} + +void IMSocketDisconnect::InitAsDefaultInstance() { +} + +IMSocketDisconnect::IMSocketDisconnect(const IMSocketDisconnect& from) + : ::google::protobuf::Message() { + SharedCtor(); + MergeFrom(from); +} + +void IMSocketDisconnect::SharedCtor() { + _cached_size_ = 0; + ::memset(_has_bits_, 0, sizeof(_has_bits_)); +} + +IMSocketDisconnect::~IMSocketDisconnect() { + SharedDtor(); +} + +void IMSocketDisconnect::SharedDtor() { + if (this != default_instance_) { + } +} + +void IMSocketDisconnect::SetCachedSize(int size) const { + GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); + _cached_size_ = size; + GOOGLE_SAFE_CONCURRENT_WRITES_END(); +} +const ::google::protobuf::Descriptor* IMSocketDisconnect::descriptor() { + protobuf_AssignDescriptorsOnce(); + return IMSocketDisconnect_descriptor_; +} + +const IMSocketDisconnect& IMSocketDisconnect::default_instance() { + if (default_instance_ == NULL) protobuf_AddDesc_im_5fproto_2eproto(); + return *default_instance_; +} + +IMSocketDisconnect* IMSocketDisconnect::default_instance_ = NULL; + +IMSocketDisconnect* IMSocketDisconnect::New() const { + return new IMSocketDisconnect; +} + +void IMSocketDisconnect::Clear() { + ::memset(_has_bits_, 0, sizeof(_has_bits_)); + mutable_unknown_fields()->Clear(); +} + +bool IMSocketDisconnect::MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input) { +#define DO_(EXPRESSION) if (!(EXPRESSION)) return false + ::google::protobuf::uint32 tag; + while ((tag = input->ReadTag()) != 0) { + if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) == + ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) { + return true; + } + DO_(::google::protobuf::internal::WireFormat::SkipField( + input, tag, mutable_unknown_fields())); + } + return true; +#undef DO_ +} + +void IMSocketDisconnect::SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const { + if (!unknown_fields().empty()) { + ::google::protobuf::internal::WireFormat::SerializeUnknownFields( + unknown_fields(), output); + } +} + +::google::protobuf::uint8* IMSocketDisconnect::SerializeWithCachedSizesToArray( + ::google::protobuf::uint8* target) const { + if (!unknown_fields().empty()) { + target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray( + unknown_fields(), target); + } + return target; +} + +int IMSocketDisconnect::ByteSize() const { + int total_size = 0; + + if (!unknown_fields().empty()) { + total_size += + ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize( + unknown_fields()); + } + GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN(); + _cached_size_ = total_size; + GOOGLE_SAFE_CONCURRENT_WRITES_END(); + return total_size; +} + +void IMSocketDisconnect::MergeFrom(const ::google::protobuf::Message& from) { + GOOGLE_CHECK_NE(&from, this); + const IMSocketDisconnect* source = + ::google::protobuf::internal::dynamic_cast_if_available( + &from); + if (source == NULL) { + ::google::protobuf::internal::ReflectionOps::Merge(from, this); + } else { + MergeFrom(*source); + } +} + +void IMSocketDisconnect::MergeFrom(const IMSocketDisconnect& from) { + GOOGLE_CHECK_NE(&from, this); + mutable_unknown_fields()->MergeFrom(from.unknown_fields()); +} + +void IMSocketDisconnect::CopyFrom(const ::google::protobuf::Message& from) { + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +void IMSocketDisconnect::CopyFrom(const IMSocketDisconnect& from) { + if (&from == this) return; + Clear(); + MergeFrom(from); +} + +bool IMSocketDisconnect::IsInitialized() const { + + return true; +} + +void IMSocketDisconnect::Swap(IMSocketDisconnect* other) { + if (other != this) { + _unknown_fields_.Swap(&other->_unknown_fields_); + std::swap(_cached_size_, other->_cached_size_); + } +} + +::google::protobuf::Metadata IMSocketDisconnect::GetMetadata() const { + protobuf_AssignDescriptorsOnce(); + ::google::protobuf::Metadata metadata; + metadata.descriptor = IMSocketDisconnect_descriptor_; + metadata.reflection = IMSocketDisconnect_reflection_; + return metadata; +} + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace im + +// @@protoc_insertion_point(global_scope) diff --git a/cpp/im_proto.pb.h b/cpp/im_proto.pb.h new file mode 100644 index 0000000..fd9ef93 --- /dev/null +++ b/cpp/im_proto.pb.h @@ -0,0 +1,520 @@ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: im_proto.proto + +#ifndef PROTOBUF_im_5fproto_2eproto__INCLUDED +#define PROTOBUF_im_5fproto_2eproto__INCLUDED + +#include + +#include + +#if GOOGLE_PROTOBUF_VERSION < 2005000 +#error This file was generated by a newer version of protoc which is +#error incompatible with your Protocol Buffer headers. Please update +#error your headers. +#endif +#if 2005000 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION +#error This file was generated by an older version of protoc which is +#error incompatible with your Protocol Buffer headers. Please +#error regenerate this file with a newer version of protoc. +#endif + +#include +#include +#include +#include +#include +#include +// @@protoc_insertion_point(includes) + +namespace im { + +// Internal implementation detail -- do not call these. +void protobuf_AddDesc_im_5fproto_2eproto(); +void protobuf_AssignDesc_im_5fproto_2eproto(); +void protobuf_ShutdownFile_im_5fproto_2eproto(); + +class IMSocketConnect; +class IMSocketDisconnect; + +enum Constant_e { + MaxIMMsgId = 7 +}; +bool Constant_e_IsValid(int value); +const Constant_e Constant_e_MIN = MaxIMMsgId; +const Constant_e Constant_e_MAX = MaxIMMsgId; +const int Constant_e_ARRAYSIZE = Constant_e_MAX + 1; + +const ::google::protobuf::EnumDescriptor* Constant_e_descriptor(); +inline const ::std::string& Constant_e_Name(Constant_e value) { + return ::google::protobuf::internal::NameOfEnum( + Constant_e_descriptor(), value); +} +inline bool Constant_e_Parse( + const ::std::string& name, Constant_e* value) { + return ::google::protobuf::internal::ParseNamedEnum( + Constant_e_descriptor(), name, value); +} +// =================================================================== + +class IMSocketConnect : public ::google::protobuf::Message { + public: + IMSocketConnect(); + virtual ~IMSocketConnect(); + + IMSocketConnect(const IMSocketConnect& from); + + inline IMSocketConnect& operator=(const IMSocketConnect& from) { + CopyFrom(from); + return *this; + } + + inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { + return _unknown_fields_; + } + + inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { + return &_unknown_fields_; + } + + static const ::google::protobuf::Descriptor* descriptor(); + static const IMSocketConnect& default_instance(); + + void Swap(IMSocketConnect* other); + + // implements Message ---------------------------------------------- + + IMSocketConnect* New() const; + void CopyFrom(const ::google::protobuf::Message& from); + void MergeFrom(const ::google::protobuf::Message& from); + void CopyFrom(const IMSocketConnect& from); + void MergeFrom(const IMSocketConnect& from); + void Clear(); + bool IsInitialized() const; + + int ByteSize() const; + bool MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input); + void SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const; + ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const; + int GetCachedSize() const { return _cached_size_; } + private: + void SharedCtor(); + void SharedDtor(); + void SetCachedSize(int size) const; + public: + + ::google::protobuf::Metadata GetMetadata() const; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + // optional bool is_websocket = 1; + inline bool has_is_websocket() const; + inline void clear_is_websocket(); + static const int kIsWebsocketFieldNumber = 1; + inline bool is_websocket() const; + inline void set_is_websocket(bool value); + + // optional string host = 2; + inline bool has_host() const; + inline void clear_host(); + static const int kHostFieldNumber = 2; + inline const ::std::string& host() const; + inline void set_host(const ::std::string& value); + inline void set_host(const char* value); + inline void set_host(const char* value, size_t size); + inline ::std::string* mutable_host(); + inline ::std::string* release_host(); + inline void set_allocated_host(::std::string* host); + + // optional string url = 3; + inline bool has_url() const; + inline void clear_url(); + static const int kUrlFieldNumber = 3; + inline const ::std::string& url() const; + inline void set_url(const ::std::string& value); + inline void set_url(const char* value); + inline void set_url(const char* value, size_t size); + inline ::std::string* mutable_url(); + inline ::std::string* release_url(); + inline void set_allocated_url(::std::string* url); + + // optional string query_str = 4; + inline bool has_query_str() const; + inline void clear_query_str(); + static const int kQueryStrFieldNumber = 4; + inline const ::std::string& query_str() const; + inline void set_query_str(const ::std::string& value); + inline void set_query_str(const char* value); + inline void set_query_str(const char* value, size_t size); + inline ::std::string* mutable_query_str(); + inline ::std::string* release_query_str(); + inline void set_allocated_query_str(::std::string* query_str); + + // @@protoc_insertion_point(class_scope:im.IMSocketConnect) + private: + inline void set_has_is_websocket(); + inline void clear_has_is_websocket(); + inline void set_has_host(); + inline void clear_has_host(); + inline void set_has_url(); + inline void clear_has_url(); + inline void set_has_query_str(); + inline void clear_has_query_str(); + + ::google::protobuf::UnknownFieldSet _unknown_fields_; + + ::std::string* host_; + ::std::string* url_; + ::std::string* query_str_; + bool is_websocket_; + + mutable int _cached_size_; + ::google::protobuf::uint32 _has_bits_[(4 + 31) / 32]; + + friend void protobuf_AddDesc_im_5fproto_2eproto(); + friend void protobuf_AssignDesc_im_5fproto_2eproto(); + friend void protobuf_ShutdownFile_im_5fproto_2eproto(); + + void InitAsDefaultInstance(); + static IMSocketConnect* default_instance_; +}; +// ------------------------------------------------------------------- + +class IMSocketDisconnect : public ::google::protobuf::Message { + public: + IMSocketDisconnect(); + virtual ~IMSocketDisconnect(); + + IMSocketDisconnect(const IMSocketDisconnect& from); + + inline IMSocketDisconnect& operator=(const IMSocketDisconnect& from) { + CopyFrom(from); + return *this; + } + + inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const { + return _unknown_fields_; + } + + inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() { + return &_unknown_fields_; + } + + static const ::google::protobuf::Descriptor* descriptor(); + static const IMSocketDisconnect& default_instance(); + + void Swap(IMSocketDisconnect* other); + + // implements Message ---------------------------------------------- + + IMSocketDisconnect* New() const; + void CopyFrom(const ::google::protobuf::Message& from); + void MergeFrom(const ::google::protobuf::Message& from); + void CopyFrom(const IMSocketDisconnect& from); + void MergeFrom(const IMSocketDisconnect& from); + void Clear(); + bool IsInitialized() const; + + int ByteSize() const; + bool MergePartialFromCodedStream( + ::google::protobuf::io::CodedInputStream* input); + void SerializeWithCachedSizes( + ::google::protobuf::io::CodedOutputStream* output) const; + ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const; + int GetCachedSize() const { return _cached_size_; } + private: + void SharedCtor(); + void SharedDtor(); + void SetCachedSize(int size) const; + public: + + ::google::protobuf::Metadata GetMetadata() const; + + // nested types ---------------------------------------------------- + + // accessors ------------------------------------------------------- + + // @@protoc_insertion_point(class_scope:im.IMSocketDisconnect) + private: + + ::google::protobuf::UnknownFieldSet _unknown_fields_; + + + mutable int _cached_size_; + ::google::protobuf::uint32 _has_bits_[1]; + + friend void protobuf_AddDesc_im_5fproto_2eproto(); + friend void protobuf_AssignDesc_im_5fproto_2eproto(); + friend void protobuf_ShutdownFile_im_5fproto_2eproto(); + + void InitAsDefaultInstance(); + static IMSocketDisconnect* default_instance_; +}; +// =================================================================== + + +// =================================================================== + +// IMSocketConnect + +// optional bool is_websocket = 1; +inline bool IMSocketConnect::has_is_websocket() const { + return (_has_bits_[0] & 0x00000001u) != 0; +} +inline void IMSocketConnect::set_has_is_websocket() { + _has_bits_[0] |= 0x00000001u; +} +inline void IMSocketConnect::clear_has_is_websocket() { + _has_bits_[0] &= ~0x00000001u; +} +inline void IMSocketConnect::clear_is_websocket() { + is_websocket_ = false; + clear_has_is_websocket(); +} +inline bool IMSocketConnect::is_websocket() const { + return is_websocket_; +} +inline void IMSocketConnect::set_is_websocket(bool value) { + set_has_is_websocket(); + is_websocket_ = value; +} + +// optional string host = 2; +inline bool IMSocketConnect::has_host() const { + return (_has_bits_[0] & 0x00000002u) != 0; +} +inline void IMSocketConnect::set_has_host() { + _has_bits_[0] |= 0x00000002u; +} +inline void IMSocketConnect::clear_has_host() { + _has_bits_[0] &= ~0x00000002u; +} +inline void IMSocketConnect::clear_host() { + if (host_ != &::google::protobuf::internal::kEmptyString) { + host_->clear(); + } + clear_has_host(); +} +inline const ::std::string& IMSocketConnect::host() const { + return *host_; +} +inline void IMSocketConnect::set_host(const ::std::string& value) { + set_has_host(); + if (host_ == &::google::protobuf::internal::kEmptyString) { + host_ = new ::std::string; + } + host_->assign(value); +} +inline void IMSocketConnect::set_host(const char* value) { + set_has_host(); + if (host_ == &::google::protobuf::internal::kEmptyString) { + host_ = new ::std::string; + } + host_->assign(value); +} +inline void IMSocketConnect::set_host(const char* value, size_t size) { + set_has_host(); + if (host_ == &::google::protobuf::internal::kEmptyString) { + host_ = new ::std::string; + } + host_->assign(reinterpret_cast(value), size); +} +inline ::std::string* IMSocketConnect::mutable_host() { + set_has_host(); + if (host_ == &::google::protobuf::internal::kEmptyString) { + host_ = new ::std::string; + } + return host_; +} +inline ::std::string* IMSocketConnect::release_host() { + clear_has_host(); + if (host_ == &::google::protobuf::internal::kEmptyString) { + return NULL; + } else { + ::std::string* temp = host_; + host_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + return temp; + } +} +inline void IMSocketConnect::set_allocated_host(::std::string* host) { + if (host_ != &::google::protobuf::internal::kEmptyString) { + delete host_; + } + if (host) { + set_has_host(); + host_ = host; + } else { + clear_has_host(); + host_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + } +} + +// optional string url = 3; +inline bool IMSocketConnect::has_url() const { + return (_has_bits_[0] & 0x00000004u) != 0; +} +inline void IMSocketConnect::set_has_url() { + _has_bits_[0] |= 0x00000004u; +} +inline void IMSocketConnect::clear_has_url() { + _has_bits_[0] &= ~0x00000004u; +} +inline void IMSocketConnect::clear_url() { + if (url_ != &::google::protobuf::internal::kEmptyString) { + url_->clear(); + } + clear_has_url(); +} +inline const ::std::string& IMSocketConnect::url() const { + return *url_; +} +inline void IMSocketConnect::set_url(const ::std::string& value) { + set_has_url(); + if (url_ == &::google::protobuf::internal::kEmptyString) { + url_ = new ::std::string; + } + url_->assign(value); +} +inline void IMSocketConnect::set_url(const char* value) { + set_has_url(); + if (url_ == &::google::protobuf::internal::kEmptyString) { + url_ = new ::std::string; + } + url_->assign(value); +} +inline void IMSocketConnect::set_url(const char* value, size_t size) { + set_has_url(); + if (url_ == &::google::protobuf::internal::kEmptyString) { + url_ = new ::std::string; + } + url_->assign(reinterpret_cast(value), size); +} +inline ::std::string* IMSocketConnect::mutable_url() { + set_has_url(); + if (url_ == &::google::protobuf::internal::kEmptyString) { + url_ = new ::std::string; + } + return url_; +} +inline ::std::string* IMSocketConnect::release_url() { + clear_has_url(); + if (url_ == &::google::protobuf::internal::kEmptyString) { + return NULL; + } else { + ::std::string* temp = url_; + url_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + return temp; + } +} +inline void IMSocketConnect::set_allocated_url(::std::string* url) { + if (url_ != &::google::protobuf::internal::kEmptyString) { + delete url_; + } + if (url) { + set_has_url(); + url_ = url; + } else { + clear_has_url(); + url_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + } +} + +// optional string query_str = 4; +inline bool IMSocketConnect::has_query_str() const { + return (_has_bits_[0] & 0x00000008u) != 0; +} +inline void IMSocketConnect::set_has_query_str() { + _has_bits_[0] |= 0x00000008u; +} +inline void IMSocketConnect::clear_has_query_str() { + _has_bits_[0] &= ~0x00000008u; +} +inline void IMSocketConnect::clear_query_str() { + if (query_str_ != &::google::protobuf::internal::kEmptyString) { + query_str_->clear(); + } + clear_has_query_str(); +} +inline const ::std::string& IMSocketConnect::query_str() const { + return *query_str_; +} +inline void IMSocketConnect::set_query_str(const ::std::string& value) { + set_has_query_str(); + if (query_str_ == &::google::protobuf::internal::kEmptyString) { + query_str_ = new ::std::string; + } + query_str_->assign(value); +} +inline void IMSocketConnect::set_query_str(const char* value) { + set_has_query_str(); + if (query_str_ == &::google::protobuf::internal::kEmptyString) { + query_str_ = new ::std::string; + } + query_str_->assign(value); +} +inline void IMSocketConnect::set_query_str(const char* value, size_t size) { + set_has_query_str(); + if (query_str_ == &::google::protobuf::internal::kEmptyString) { + query_str_ = new ::std::string; + } + query_str_->assign(reinterpret_cast(value), size); +} +inline ::std::string* IMSocketConnect::mutable_query_str() { + set_has_query_str(); + if (query_str_ == &::google::protobuf::internal::kEmptyString) { + query_str_ = new ::std::string; + } + return query_str_; +} +inline ::std::string* IMSocketConnect::release_query_str() { + clear_has_query_str(); + if (query_str_ == &::google::protobuf::internal::kEmptyString) { + return NULL; + } else { + ::std::string* temp = query_str_; + query_str_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + return temp; + } +} +inline void IMSocketConnect::set_allocated_query_str(::std::string* query_str) { + if (query_str_ != &::google::protobuf::internal::kEmptyString) { + delete query_str_; + } + if (query_str) { + set_has_query_str(); + query_str_ = query_str; + } else { + clear_has_query_str(); + query_str_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString); + } +} + +// ------------------------------------------------------------------- + +// IMSocketDisconnect + + +// @@protoc_insertion_point(namespace_scope) + +} // namespace im + +#ifndef SWIG +namespace google { +namespace protobuf { + +template <> +inline const EnumDescriptor* GetEnumDescriptor< ::im::Constant_e>() { + return ::im::Constant_e_descriptor(); +} + +} // namespace google +} // namespace protobuf +#endif // SWIG + +// @@protoc_insertion_point(global_scope) + +#endif // PROTOBUF_im_5fproto_2eproto__INCLUDED