Function SerializeResponse

src/brpc/policy/baidu_rpc_protocol.cpp:218–246

}

static bool SerializeResponse(const google::protobuf::Message& res,
                              Controller& cntl, butil::IOBuf& buf) {
    if (res.GetDescriptor() == SerializedResponse::descriptor()) {
        buf.swap(((SerializedResponse&)res).serialized_data());
        return true;
    }

    if (!res.IsInitialized()) {
        cntl.SetFailed(ERESPONSE, "Missing required fields in response: %s",
                       res.InitializationErrorString().c_str());
        return false;
    }

    ContentType content_type = cntl.response_content_type();
    CompressType compress_type = cntl.response_compress_type();
    ChecksumType checksum_type = cntl.response_checksum_type();
    if (!SerializeRpcMessage(res, cntl, content_type, compress_type,
                             checksum_type, &buf)) {
        cntl.SetFailed(ERESPONSE,
                       "Fail to serialize response=%s, "
                       "ContentType=%s, CompressType=%s, ChecksumType=%s",
                       butil::EnsureString(res.GetDescriptor()->full_name()).c_str(),
                       ContentTypeToCStr(content_type),
                       CompressTypeToCStr(compress_type),
                       ChecksumTypeToCStr(checksum_type));
        return false;
    }
    return true;
}

namespace {
struct BaiduProxyPBMessages : public RpcPBMessages {