Function SerializeRpcRequest

src/brpc/policy/baidu_rpc_protocol.cpp:1015–1043

}

void SerializeRpcRequest(butil::IOBuf* request_buf, Controller* cntl,
                         const google::protobuf::Message* request) {
    // Check sanity of request.
    if (NULL == request) {
        return cntl->SetFailed(EREQUEST, "`request' is NULL");
    }
    if (request->GetDescriptor() == SerializedRequest::descriptor()) {
        request_buf->append(((SerializedRequest*)request)->serialized_data());
        return;
    }
    if (!request->IsInitialized()) {
        return cntl->SetFailed(EREQUEST, "Missing required fields in request: %s",
                               request->InitializationErrorString().c_str());
    }

    ContentType content_type = cntl->request_content_type();
    CompressType compress_type = cntl->request_compress_type();
    ChecksumType checksum_type = cntl->request_checksum_type();
    if (!SerializeRpcMessage(*request, *cntl, content_type, compress_type,
                             checksum_type, request_buf)) {
        return cntl->SetFailed(
            EREQUEST,
            "Fail to compress request=%s, "
            "ContentType=%s, CompressType=%s, ChecksumType=%s",
            butil::EnsureString(request->GetDescriptor()->full_name()).c_str(),
            ContentTypeToCStr(content_type), CompressTypeToCStr(compress_type),
            ChecksumTypeToCStr(checksum_type));
    }
}

void PackRpcRequest(butil::IOBuf* req_buf,
                    SocketMessage**,