1

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 <algorithm>
+
+#include <google/protobuf/stubs/common.h>
+#include <google/protobuf/stubs/once.h>
+#include <google/protobuf/io/coded_stream.h>
+#include <google/protobuf/wire_format_lite_inl.h>
+#include <google/protobuf/descriptor.h>
+#include <google/protobuf/generated_message_reflection.h>
+#include <google/protobuf/reflection_ops.h>
+#include <google/protobuf/wire_format.h>
+// @@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)

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 <string>
+
+#include <google/protobuf/stubs/common.h>
+
+#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 <google/protobuf/generated_message_util.h>
+#include <google/protobuf/repeated_field.h>
+#include <google/protobuf/extension_set.h>
+#include <google/protobuf/generated_enum_reflection.h>
+// @@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>(
+    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

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 <algorithm>
+
+#include <google/protobuf/stubs/common.h>
+#include <google/protobuf/stubs/once.h>
+#include <google/protobuf/io/coded_stream.h>
+#include <google/protobuf/wire_format_lite_inl.h>
+#include <google/protobuf/descriptor.h>
+#include <google/protobuf/generated_message_reflection.h>
+#include <google/protobuf/reflection_ops.h>
+#include <google/protobuf/wire_format.h>
+// @@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<const IMSocketConnect*>(
+      &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<const IMSocketDisconnect*>(
+      &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)

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 <string>
+
+#include <google/protobuf/stubs/common.h>
+
+#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 <google/protobuf/generated_message_util.h>
+#include <google/protobuf/message.h>
+#include <google/protobuf/repeated_field.h>
+#include <google/protobuf/extension_set.h>
+#include <google/protobuf/generated_enum_reflection.h>
+#include <google/protobuf/unknown_field_set.h>
+// @@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>(
+    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<const char*>(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<const char*>(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<const char*>(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