// Generated by the protocol buffer compiler.  DO NOT EDIT!

// source: brpc/policy/baidu_rpc_meta.proto

#include "brpc/policy/baidu_rpc_meta.pb.h"

#include <algorithm>

#include <google/protobuf/stubs/common.h>

#include <google/protobuf/stubs/port.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>

// This is a temporary google only hack

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

#include "third_party/protobuf/version.h"

#endif

// @@protoc_insertion_point(includes)

namespace protobuf_brpc_2foptions_2eproto {

extern PROTOBUF_INTERNAL_EXPORT_protobuf_brpc_2foptions_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_ChunkInfo;

}  // namespace protobuf_brpc_2foptions_2eproto

namespace protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto {

extern PROTOBUF_INTERNAL_EXPORT_protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_RpcMeta_UserFieldsEntry_DoNotUse;

extern PROTOBUF_INTERNAL_EXPORT_protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_RpcRequestMeta;

extern PROTOBUF_INTERNAL_EXPORT_protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_RpcResponseMeta;

}  // namespace protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto

namespace protobuf_brpc_2fstreaming_5frpc_5fmeta_2eproto {

extern PROTOBUF_INTERNAL_EXPORT_protobuf_brpc_2fstreaming_5frpc_5fmeta_2eproto ::google::protobuf::internal::SCCInfo<0> scc_info_StreamSettings;

}  // namespace protobuf_brpc_2fstreaming_5frpc_5fmeta_2eproto

namespace brpc {

namespace policy {

class RpcMeta_UserFieldsEntry_DoNotUseDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<RpcMeta_UserFieldsEntry_DoNotUse>

      _instance;

} _RpcMeta_UserFieldsEntry_DoNotUse_default_instance_;

class RpcMetaDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<RpcMeta>

      _instance;

} _RpcMeta_default_instance_;

class RpcRequestMetaDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<RpcRequestMeta>

      _instance;

} _RpcRequestMeta_default_instance_;

class RpcResponseMetaDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<RpcResponseMeta>

      _instance;

} _RpcResponseMeta_default_instance_;

}  // namespace policy

}  // namespace brpc

namespace protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto {

static void InitDefaultsRpcMeta_UserFieldsEntry_DoNotUse() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

  {

    void* ptr = &::brpc::policy::_RpcMeta_UserFieldsEntry_DoNotUse_default_instance_;

    new (ptr) ::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse();

  }

  ::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse::InitAsDefaultInstance();

}

::google::protobuf::internal::SCCInfo<0> scc_info_RpcMeta_UserFieldsEntry_DoNotUse =

    {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRpcMeta_UserFieldsEntry_DoNotUse}, {}};

static void InitDefaultsRpcMeta() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

  {

    void* ptr = &::brpc::policy::_RpcMeta_default_instance_;

    new (ptr) ::brpc::policy::RpcMeta();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::brpc::policy::RpcMeta::InitAsDefaultInstance();

}

::google::protobuf::internal::SCCInfo<5> scc_info_RpcMeta =

    {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 5, InitDefaultsRpcMeta}, {

      &protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::scc_info_RpcRequestMeta.base,

      &protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::scc_info_RpcResponseMeta.base,

      &protobuf_brpc_2foptions_2eproto::scc_info_ChunkInfo.base,

      &protobuf_brpc_2fstreaming_5frpc_5fmeta_2eproto::scc_info_StreamSettings.base,

      &protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::scc_info_RpcMeta_UserFieldsEntry_DoNotUse.base,}};

static void InitDefaultsRpcRequestMeta() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

  {

    void* ptr = &::brpc::policy::_RpcRequestMeta_default_instance_;

    new (ptr) ::brpc::policy::RpcRequestMeta();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::brpc::policy::RpcRequestMeta::InitAsDefaultInstance();

}

::google::protobuf::internal::SCCInfo<0> scc_info_RpcRequestMeta =

    {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRpcRequestMeta}, {}};

static void InitDefaultsRpcResponseMeta() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

  {

    void* ptr = &::brpc::policy::_RpcResponseMeta_default_instance_;

    new (ptr) ::brpc::policy::RpcResponseMeta();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::brpc::policy::RpcResponseMeta::InitAsDefaultInstance();

}

::google::protobuf::internal::SCCInfo<0> scc_info_RpcResponseMeta =

    {{ATOMIC_VAR_INIT(::google::protobuf::internal::SCCInfoBase::kUninitialized), 0, InitDefaultsRpcResponseMeta}, {}};

void InitDefaults() {

  ::google::protobuf::internal::InitSCC(&scc_info_RpcMeta_UserFieldsEntry_DoNotUse.base);

  ::google::protobuf::internal::InitSCC(&scc_info_RpcMeta.base);

  ::google::protobuf::internal::InitSCC(&scc_info_RpcRequestMeta.base);

  ::google::protobuf::internal::InitSCC(&scc_info_RpcResponseMeta.base);

}

::google::protobuf::Metadata file_level_metadata[4];

const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse, key_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse, value_),

  0,

  1,

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, request_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, response_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, compress_type_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, correlation_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, attachment_size_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, chunk_info_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, authentication_data_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, stream_settings_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, user_fields_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, content_type_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, checksum_type_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcMeta, checksum_value_),

  2,

  3,

  7,

  6,

  8,

  4,

  0,

  5,

  ~0u,

  9,

  10,

  1,

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, service_name_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, method_name_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, log_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, trace_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, span_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, parent_span_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, request_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcRequestMeta, timeout_ms_),

  0,

  1,

  3,

  4,

  5,

  6,

  2,

  7,

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcResponseMeta, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcResponseMeta, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcResponseMeta, error_code_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::brpc::policy::RpcResponseMeta, error_text_),

  1,

  0,

};

static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

  { 0, 7, sizeof(::brpc::policy::RpcMeta_UserFieldsEntry_DoNotUse)},

  { 9, 26, sizeof(::brpc::policy::RpcMeta)},

  { 38, 51, sizeof(::brpc::policy::RpcRequestMeta)},

  { 59, 66, sizeof(::brpc::policy::RpcResponseMeta)},

};

static ::google::protobuf::Message const * const file_default_instances[] = {

  reinterpret_cast<const ::google::protobuf::Message*>(&::brpc::policy::_RpcMeta_UserFieldsEntry_DoNotUse_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::brpc::policy::_RpcMeta_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::brpc::policy::_RpcRequestMeta_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::brpc::policy::_RpcResponseMeta_default_instance_),

};

void protobuf_AssignDescriptors() {

  AddDescriptors();

  AssignDescriptors(

      "brpc/policy/baidu_rpc_meta.proto", schemas, file_default_instances, TableStruct::offsets,

      file_level_metadata, NULL, NULL);

}

void protobuf_AssignDescriptorsOnce() {

  static ::google::protobuf::internal::once_flag once;

  ::google::protobuf::internal::call_once(once, protobuf_AssignDescriptors);

}

void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;

void protobuf_RegisterTypes(const ::std::string&) {

  protobuf_AssignDescriptorsOnce();

  ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 4);

}

void AddDescriptorsImpl() {

  InitDefaults();

  static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

      "\n brpc/policy/baidu_rpc_meta.proto\022\013brpc"

      ".policy\032\022brpc/options.proto\032\035brpc/stream"

      "ing_rpc_meta.proto\"\346\003\n\007RpcMeta\022,\n\007reques"

      "t\030\001 \001(\0132\033.brpc.policy.RpcRequestMeta\022.\n\010"

      "response\030\002 \001(\0132\034.brpc.policy.RpcResponse"

      "Meta\022\025\n\rcompress_type\030\003 \001(\005\022\026\n\016correlati"

      "on_id\030\004 \001(\003\022\027\n\017attachment_size\030\005 \001(\005\022#\n\n"

      "chunk_info\030\006 \001(\0132\017.brpc.ChunkInfo\022\033\n\023aut"

      "hentication_data\030\007 \001(\014\022-\n\017stream_setting"

      "s\030\010 \001(\0132\024.brpc.StreamSettings\0229\n\013user_fi"

      "elds\030\t \003(\0132$.brpc.policy.RpcMeta.UserFie"

      "ldsEntry\022\'\n\014content_type\030\n \001(\0162\021.brpc.Co"

      "ntentType\022\025\n\rchecksum_type\030\013 \001(\005\022\026\n\016chec"

      "ksum_value\030\014 \001(\014\0321\n\017UserFieldsEntry\022\013\n\003k"

      "ey\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\256\001\n\016RpcReque"

      "stMeta\022\024\n\014service_name\030\001 \002(\t\022\023\n\013method_n"

      "ame\030\002 \002(\t\022\016\n\006log_id\030\003 \001(\003\022\020\n\010trace_id\030\004 "

      "\001(\003\022\017\n\007span_id\030\005 \001(\003\022\026\n\016parent_span_id\030\006"

      " \001(\003\022\022\n\nrequest_id\030\007 \001(\t\022\022\n\ntimeout_ms\030\010"

      " \001(\005\"9\n\017RpcResponseMeta\022\022\n\nerror_code\030\001 "

      "\001(\005\022\022\n\nerror_text\030\002 \001(\tB \n\017com.brpc.poli"

      "cyB\rBaiduRpcProto"

  };

  ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(

      descriptor, 857);

  ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(

    "brpc/policy/baidu_rpc_meta.proto", &protobuf_RegisterTypes);

  ::protobuf_brpc_2foptions_2eproto::AddDescriptors();

  ::protobuf_brpc_2fstreaming_5frpc_5fmeta_2eproto::AddDescriptors();

}

void AddDescriptors() {

  static ::google::protobuf::internal::once_flag once;

  ::google::protobuf::internal::call_once(once, AddDescriptorsImpl);

}

// Force AddDescriptors() to be called at dynamic initialization time.

struct StaticDescriptorInitializer {

  StaticDescriptorInitializer() {

    AddDescriptors();

  }

} static_descriptor_initializer;

}  // namespace protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto

namespace brpc {

namespace policy {

// ===================================================================

RpcMeta_UserFieldsEntry_DoNotUse::RpcMeta_UserFieldsEntry_DoNotUse() {}

RpcMeta_UserFieldsEntry_DoNotUse::RpcMeta_UserFieldsEntry_DoNotUse(::google::protobuf::Arena* arena) : SuperType(arena) {}

void RpcMeta_UserFieldsEntry_DoNotUse::MergeFrom(const RpcMeta_UserFieldsEntry_DoNotUse& other) {

  MergeFromInternal(other);

}

::google::protobuf::Metadata RpcMeta_UserFieldsEntry_DoNotUse::GetMetadata() const {

  ::protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::file_level_metadata[0];

}

void RpcMeta_UserFieldsEntry_DoNotUse::MergeFrom(

    const ::google::protobuf::Message& other) {

  ::google::protobuf::Message::MergeFrom(other);

}

// ===================================================================

void RpcMeta::InitAsDefaultInstance() {

  ::brpc::policy::_RpcMeta_default_instance_._instance.get_mutable()->request_ = const_cast< ::brpc::policy::RpcRequestMeta*>(

      ::brpc::policy::RpcRequestMeta::internal_default_instance());

  ::brpc::policy::_RpcMeta_default_instance_._instance.get_mutable()->response_ = const_cast< ::brpc::policy::RpcResponseMeta*>(

      ::brpc::policy::RpcResponseMeta::internal_default_instance());

  ::brpc::policy::_RpcMeta_default_instance_._instance.get_mutable()->chunk_info_ = const_cast< ::brpc::ChunkInfo*>(

      ::brpc::ChunkInfo::internal_default_instance());

  ::brpc::policy::_RpcMeta_default_instance_._instance.get_mutable()->stream_settings_ = const_cast< ::brpc::StreamSettings*>(

      ::brpc::StreamSettings::internal_default_instance());

}

void RpcMeta::clear_chunk_info() {

  if (chunk_info_ != NULL) chunk_info_->Clear();

  clear_has_chunk_info();

}

void RpcMeta::clear_stream_settings() {

  if (stream_settings_ != NULL) stream_settings_->Clear();

  clear_has_stream_settings();

}

#if !defined(_MSC_VER) || _MSC_VER >= 1900

const int RpcMeta::kRequestFieldNumber;

const int RpcMeta::kResponseFieldNumber;

const int RpcMeta::kCompressTypeFieldNumber;

const int RpcMeta::kCorrelationIdFieldNumber;

const int RpcMeta::kAttachmentSizeFieldNumber;

const int RpcMeta::kChunkInfoFieldNumber;

const int RpcMeta::kAuthenticationDataFieldNumber;

const int RpcMeta::kStreamSettingsFieldNumber;

const int RpcMeta::kUserFieldsFieldNumber;

const int RpcMeta::kContentTypeFieldNumber;

const int RpcMeta::kChecksumTypeFieldNumber;

const int RpcMeta::kChecksumValueFieldNumber;

#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

RpcMeta::RpcMeta()

  : ::google::protobuf::Message(), _internal_metadata_(NULL) {

  ::google::protobuf::internal::InitSCC(

      &protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::scc_info_RpcMeta.base);

  SharedCtor();

  // @@protoc_insertion_point(constructor:brpc.policy.RpcMeta)

}

RpcMeta::RpcMeta(const RpcMeta& from)

  : ::google::protobuf::Message(),

      _internal_metadata_(NULL),

      _has_bits_(from._has_bits_) {

  _internal_metadata_.MergeFrom(from._internal_metadata_);

  user_fields_.MergeFrom(from.user_fields_);

  authentication_data_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  if (from.has_authentication_data()) {

    authentication_data_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.authentication_data_);

  }

  checksum_value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  if (from.has_checksum_value()) {

    checksum_value_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.checksum_value_);

  }

  if (from.has_request()) {

    request_ = new ::brpc::policy::RpcRequestMeta(*from.request_);

  } else {

    request_ = NULL;

  }

  if (from.has_response()) {

    response_ = new ::brpc::policy::RpcResponseMeta(*from.response_);

  } else {

    response_ = NULL;

  }

  if (from.has_chunk_info()) {

    chunk_info_ = new ::brpc::ChunkInfo(*from.chunk_info_);

  } else {

    chunk_info_ = NULL;

  }

  if (from.has_stream_settings()) {

    stream_settings_ = new ::brpc::StreamSettings(*from.stream_settings_);

  } else {

    stream_settings_ = NULL;

  }

  ::memcpy(&correlation_id_, &from.correlation_id_,

    static_cast<size_t>(reinterpret_cast<char*>(&checksum_type_) -

    reinterpret_cast<char*>(&correlation_id_)) + sizeof(checksum_type_));

  // @@protoc_insertion_point(copy_constructor:brpc.policy.RpcMeta)

}

void RpcMeta::SharedCtor() {

  authentication_data_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  checksum_value_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  ::memset(&request_, 0, static_cast<size_t>(

      reinterpret_cast<char*>(&checksum_type_) -

      reinterpret_cast<char*>(&request_)) + sizeof(checksum_type_));

}

RpcMeta::~RpcMeta() {

  // @@protoc_insertion_point(destructor:brpc.policy.RpcMeta)

  SharedDtor();

}

void RpcMeta::SharedDtor() {

  authentication_data_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  checksum_value_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  if (this != internal_default_instance()) delete request_;

  if (this != internal_default_instance()) delete response_;

  if (this != internal_default_instance()) delete chunk_info_;

  if (this != internal_default_instance()) delete stream_settings_;

}

void RpcMeta::SetCachedSize(int size) const {

  _cached_size_.Set(size);

}

const ::google::protobuf::Descriptor* RpcMeta::descriptor() {

  ::protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;

}

const RpcMeta& RpcMeta::default_instance() {

  ::google::protobuf::internal::InitSCC(&protobuf_brpc_2fpolicy_2fbaidu_5frpc_5fmeta_2eproto::scc_info_RpcMeta.base);

  return *internal_default_instance();

}

void RpcMeta::Clear() {

// @@protoc_insertion_point(message_clear_start:brpc.policy.RpcMeta)

  ::google::protobuf::uint32 cached_has_bits = 0;

  // Prevent compiler warnings about cached_has_bits being unused

  (void) cached_has_bits;

  user_fields_.Clear();

  cached_has_bits = _has_bits_[0];

  if (cached_has_bits & 63u) {

    if (cached_has_bits & 0x00000001u) {

      authentication_data_.ClearNonDefaultToEmptyNoArena();

    }

    if (cached_has_bits & 0x00000002u) {

      checksum_value_.ClearNonDefaultToEmptyNoArena();

    }

    if (cached_has_bits & 0x00000004u) {

      GOOGLE_DCHECK(request_ != NULL);

      request_->Clear();

    }

    if (cached_has_bits & 0x00000008u) {

      GOOGLE_DCHECK(response_ != NULL);

      response_->Clear();

    }

    if (cached_has_bits & 0x00000010u) {

      GOOGLE_DCHECK(chunk_info_ != NULL);

      chunk_info_->Clear();

    }

    if (cached_has_bits & 0x00000020u) {

      GOOGLE_DCHECK(stream_settings_ != NULL);

      stream_settings_->Clear();

    }

  }

  if (cached_has_bits & 192u) {

    ::memset(&correlation_id_, 0, static_cast<size_t>(

        reinterpret_cast<char*>(&compress_type_) -

        reinterpret_cast<char*>(&correlation_id_)) + sizeof(compress_type_));

  }

  if (cached_has_bits & 1792u) {

    ::memset(&attachment_size_, 0, static_cast<size_t>(

        reinterpret_cast<char*>(&checksum_type_) -

        reinterpret_cast<char*>(&attachment_size_)) + sizeof(checksum_type_));

  }

  _has_bits_.Clear();

  _internal_metadata_.Clear();

}

bool RpcMeta::MergePartialFromCodedStream(

    ::google::protobuf::io::CodedInputStream* input) {

#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure

  ::google::protobuf::uint32 tag;

  // @@protoc_insertion_point(parse_start:brpc.policy.RpcMeta)

  for (;;) {

    ::std::pair<::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);

    tag = p.first;

    if (!p.second) goto handle_unusual;

    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {

      // optional .brpc.policy.RpcRequestMeta request = 1;

      case 1: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(

               input, mutable_request()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional .brpc.policy.RpcResponseMeta response = 2;

      case 2: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(

               input, mutable_response()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional int32 compress_type = 3;

      case 3: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(24u /* 24 & 0xFF */)) {

          set_has_compress_type();

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(

                 input, &compress_type_)));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional int64 correlation_id = 4;

      case 4: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(32u /* 32 & 0xFF */)) {

          set_has_correlation_id();

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   ::google::protobuf::int64, ::google::protobuf::internal::WireFormatLite::TYPE_INT64>(

                 input, &correlation_id_)));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional int32 attachment_size = 5;

      case 5: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(40u /* 40 & 0xFF */)) {

          set_has_attachment_size();

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(

                 input, &attachment_size_)));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional .brpc.ChunkInfo chunk_info = 6;

      case 6: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(50u /* 50 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(

               input, mutable_chunk_info()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional bytes authentication_data = 7;

      case 7: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(58u /* 58 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(

                input, this->mutable_authentication_data()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional .brpc.StreamSettings stream_settings = 8;

      case 8: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(66u /* 66 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessage(

               input, mutable_stream_settings()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // map<string, string> user_fields = 9;

      case 9: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(74u /* 74 & 0xFF */)) {

          RpcMeta_UserFieldsEntry_DoNotUse::Parser< ::google::protobuf::internal::MapField<

              RpcMeta_UserFieldsEntry_DoNotUse,

              ::std::string, ::std::string,

              ::google::protobuf::internal::WireFormatLite::TYPE_STRING,

              ::google::protobuf::internal::WireFormatLite::TYPE_STRING,

              0 >,

            ::google::protobuf::Map< ::std::string, ::std::string > > parser(&user_fields_);

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(

              input, &parser));

          ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

            parser.key().data(), static_cast<int>(parser.key().length()),

            ::google::protobuf::internal::WireFormat::PARSE,

            "brpc.policy.RpcMeta.UserFieldsEntry.key");

          ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

            parser.value().data(), static_cast<int>(parser.value().length()),

            ::google::protobuf::internal::WireFormat::PARSE,

            "brpc.policy.RpcMeta.UserFieldsEntry.value");

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional .brpc.ContentType content_type = 10;

      case 10: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(80u /* 80 & 0xFF */)) {

          int value;

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(

                 input, &value)));

          if (::brpc::ContentType_IsValid(value)) {

            set_content_type(static_cast< ::brpc::ContentType >(value));

          } else {

            mutable_unknown_fields()->AddVarint(

                10, static_cast< ::google::protobuf::uint64>(value));

          }

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional int32 checksum_type = 11;

      case 11: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(88u /* 88 & 0xFF */)) {

          set_has_checksum_type();

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   ::google::protobuf::int32, ::google::protobuf::internal::WireFormatLite::TYPE_INT32>(

                 input, &checksum_type_)));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // optional bytes checksum_value = 12;

      case 12: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(98u /* 98 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(

                input, this->mutable_checksum_value()));

        } else {

          goto handle_unusual;

        }

        break;

      }

      default: {

      handle_unusual:

        if (tag == 0) {

          goto success;

        }

        DO_(::google::protobuf::internal::WireFormat::SkipField(

              input, tag, _internal_metadata_.mutable_unknown_fields()));

        break;

      }

    }

  }

success:

  // @@protoc_insertion_point(parse_success:brpc.policy.RpcMeta)

  return true;

failure:

  // @@protoc_insertion_point(parse_failure:brpc.policy.RpcMeta)

  return false;

#undef DO_

}

void RpcMeta::SerializeWithCachedSizes(

    ::google::protobuf::io::CodedOutputStream* output) const {

  // @@protoc_insertion_point(serialize_start:brpc.policy.RpcMeta)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];

  // optional .brpc.policy.RpcRequestMeta request = 1;

  if (cached_has_bits & 0x00000004u) {

    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

      1, this->_internal_request(), output);

  }

  // optional .brpc.policy.RpcResponseMeta response = 2;

  if (cached_has_bits & 0x00000008u) {

    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

      2, this->_internal_response(), output);

  }

  // optional int32 compress_type = 3;

  if (cached_has_bits & 0x00000080u) {

    ::google::protobuf::internal::WireFormatLite::WriteInt32(3, this->compress_type(), output);

  }

  // optional int64 correlation_id = 4;

  if (cached_has_bits & 0x00000040u) {

    ::google::protobuf::internal::WireFormatLite::WriteInt64(4, this->correlation_id(), output);

  }

  // optional int32 attachment_size = 5;

  if (cached_has_bits & 0x00000100u) {

    ::google::protobuf::internal::WireFormatLite::WriteInt32(5, this->attachment_size(), output);

  }

  // optional .brpc.ChunkInfo chunk_info = 6;

  if (cached_has_bits & 0x00000010u) {

    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

      6, this->_internal_chunk_info(), output);

  }

  // optional bytes authentication_data = 7;

  if (cached_has_bits & 0x00000001u) {

    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(

      7, this->authentication_data(), output);

  }

  // optional .brpc.StreamSettings stream_settings = 8;

  if (cached_has_bits & 0x00000020u) {

    ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

      8, this->_internal_stream_settings(), output);

  }

  // map<string, string> user_fields = 9;

  if (!this->user_fields().empty()) {

    typedef ::google::protobuf::Map< ::std::string, ::std::string >::const_pointer

        ConstPtr;

    typedef ConstPtr SortItem;

    typedef ::google::protobuf::internal::CompareByDerefFirst<SortItem> Less;

    struct Utf8Check {

      static void Check(ConstPtr p) {

        ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

          p->first.data(), static_cast<int>(p->first.length()),

          ::google::protobuf::internal::WireFormat::SERIALIZE,

          "brpc.policy.RpcMeta.UserFieldsEntry.key");

        ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

          p->second.data(), static_cast<int>(p->second.length()),

          ::google::protobuf::internal::WireFormat::SERIALIZE,

          "brpc.policy.RpcMeta.UserFieldsEntry.value");

      }

    };

    if (output->IsSerializationDeterministic() &&

        this->user_fields().size() > 1) {

      ::std::unique_ptr<SortItem[]> items(

          new SortItem[this->user_fields().size()]);

      typedef ::google::protobuf::Map< ::std::string, ::std::string >::size_type size_type;

      size_type n = 0;

      for (::google::protobuf::Map< ::std::string, ::std::string >::const_iterator

          it = this->user_fields().begin();

          it != this->user_fields().end(); ++it, ++n) {

        items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);

      }

      ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());

      ::std::unique_ptr<RpcMeta_UserFieldsEntry_DoNotUse> entry;

      for (size_type i = 0; i < n; i++) {

        entry.reset(user_fields_.NewEntryWrapper(

            items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second));

        ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

            9, *entry, output);

        Utf8Check::Check(items[static_cast<ptrdiff_t>(i)]);

      }

    } else {

      ::std::unique_ptr<RpcMeta_UserFieldsEntry_DoNotUse> entry;

      for (::google::protobuf::Map< ::std::string, ::std::string >::const_iterator

          it = this->user_fields().begin();

          it != this->user_fields().end(); ++it) {

        entry.reset(user_fields_.NewEntryWrapper(

            it->first, it->second));

        ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

            9, *entry, output);

        Utf8Check::Check(&*it);

      }

    }

  }

  // optional .brpc.ContentType content_type = 10;

  if (cached_has_bits & 0x00000200u) {

    ::google::protobuf::internal::WireFormatLite::WriteEnum(

      10, this->content_type(), output);

  }

  // optional int32 checksum_type = 11;

  if (cached_has_bits & 0x00000400u) {

    ::google::protobuf::internal::WireFormatLite::WriteInt32(11, this->checksum_type(), output);

  }

  // optional bytes checksum_value = 12;

  if (cached_has_bits & 0x00000002u) {

    ::google::protobuf::internal::WireFormatLite::WriteBytesMaybeAliased(

      12, this->checksum_value(), output);

  }

  if (_internal_metadata_.have_unknown_fields()) {

    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(

        _internal_metadata_.unknown_fields(), output);

  }

  // @@protoc_insertion_point(serialize_end:brpc.policy.RpcMeta)

}

::google::protobuf::uint8* RpcMeta::InternalSerializeWithCachedSizesToArray(

    bool deterministic, ::google::protobuf::uint8* target) const {

  (void)deterministic; // Unused

  // @@protoc_insertion_point(serialize_to_array_start:brpc.policy.RpcMeta)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  cached_has_bits = _has_bits_[0];

  // optional .brpc.policy.RpcRequestMeta request = 1;

  if (cached_has_bits & 0x00000004u) {

    target = ::google::protobuf::internal::WireFormatLite::

      InternalWriteMessageToArray(

        1, this->_internal_request(), deterministic, target);

  }

  // optional .brpc.policy.RpcResponseMeta response = 2;

  if (cached_has_bits & 0x00000008u) {

    target = ::google::protobuf::internal::WireFormatLite::

      InternalWriteMessageToArray(

        2, this->_internal_response(), deterministic, target);

  }

  // optional int32 compress_type = 3;

  if (cached_has_bits & 0x00000080u) {

    target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(3, this->compress_type(), target);

  }

  // optional int64 correlation_id = 4;

  if (cached_has_bits & 0x00000040u) {

    target = ::google::protobuf::internal::WireFormatLite::WriteInt64ToArray(4, this->correlation_id(), target);

  }

  // optional int32 attachment_size = 5;

  if (cached_has_bits & 0x00000100u) {

    target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(5, this->attachment_size(), target);

  }

  // optional .brpc.ChunkInfo chunk_info = 6;

  if (cached_has_bits & 0x00000010u) {

    target = ::google::protobuf::internal::WireFormatLite::

      InternalWriteMessageToArray(

        6, this->_internal_chunk_info(), deterministic, target);

  }

  // optional bytes authentication_data = 7;

  if (cached_has_bits & 0x00000001u) {

    target =

      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(

        7, this->authentication_data(), target);

  }

  // optional .brpc.StreamSettings stream_settings = 8;

  if (cached_has_bits & 0x00000020u) {

    target = ::google::protobuf::internal::WireFormatLite::

      InternalWriteMessageToArray(

        8, this->_internal_stream_settings(), deterministic, target);

  }

  // map<string, string> user_fields = 9;

  if (!this->user_fields().empty()) {

    typedef ::google::protobuf::Map< ::std::string, ::std::string >::const_pointer

        ConstPtr;

    typedef ConstPtr SortItem;

    typedef ::google::protobuf::internal::CompareByDerefFirst<SortItem> Less;

    struct Utf8Check {

      static void Check(ConstPtr p) {

        ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

          p->first.data(), static_cast<int>(p->first.length()),

          ::google::protobuf::internal::WireFormat::SERIALIZE,

          "brpc.policy.RpcMeta.UserFieldsEntry.key");

        ::google::protobuf::internal::WireFormat::VerifyUTF8StringNamedField(

          p->second.data(), static_cast<int>(p->second.length()),

          ::google::protobuf::internal::WireFormat::SERIALIZE,

          "brpc.policy.RpcMeta.UserFieldsEntry.value");

      }

    };

    if (deterministic &&

        this->user_fields().size() > 1) {

      ::std::unique_ptr<SortItem[]> items(

          new SortItem[this->user_fields().size()]);

      typedef ::google::protobuf::Map< ::std::string, ::std::string >::size_type size_type;

      size_type n = 0;

      for (::google::protobuf::Map< ::std::string, ::std::string >::const_iterator

          it = this->user_fields().begin();

          it != this->user_fields().end(); ++it, ++n) {

        items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);

      }

      ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());

      ::std::unique_ptr<RpcMeta_UserFieldsEntry_DoNotUse> entry;

      for (size_type i = 0; i < n; i++) {

        entry.reset(user_fields_.NewEntryWrapper(

            items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second));

        target = ::google::protobuf::internal::WireFormatLite::

                   InternalWriteMessageNoVirtualToArray(

                       9, *entry, deterministic, target);

;

        Utf8Check::Check(items[static_cast<ptrdiff_t>(i)]);

      }

    } else {

      ::std::unique_ptr<RpcMeta_UserFieldsEntry_DoNotUse> entry;

      for (::google::protobuf::Map< ::std::string, ::std::string >::const_iterator

          it = this->user_fields().begin();

          it != this->user_fields().end(); ++it) {

        entry.reset(user_fields_.NewEntryWrapper(

            it->first, it->second));

        target = ::google::protobuf::internal::WireFormatLite::

                   InternalWriteMessageNoVirtualToArray(

                       9, *entry, deterministic, target);

;

        Utf8Check::Check(&*it);

      }

    }

  }

  // optional .brpc.ContentType content_type = 10;

  if (cached_has_bits & 0x00000200u) {

    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(

      10, this->content_type(), target);

  }

  // optional int32 checksum_type = 11;

  if (cached_has_bits & 0x00000400u) {

    target = ::google::protobuf::internal::WireFormatLite::WriteInt32ToArray(11, this->checksum_type(), target);

  }

  // optional bytes checksum_value = 12;

  if (cached_has_bits & 0x00000002u) {