Function ProtoMessageToProtoJson

src/brpc/policy/http_rpc_protocol.cpp:334–347

}

static bool ProtoMessageToProtoJson(const google::protobuf::Message& message,
                                    butil::IOBufAsZeroCopyOutputStream* wrapper,
                                    Controller* cntl, int error_code) {
    json2pb::Pb2ProtoJsonOptions options;
    AlwaysPrintPrimitiveFields(options) = cntl->has_always_print_primitive_fields();
    options.always_print_enums_as_ints = FLAGS_pb_enum_as_number;
    std::string error;
    bool ok = json2pb::ProtoMessageToProtoJson(message, wrapper, options, &error);
    if (!ok) {
        cntl->SetFailed(error_code, "Fail to convert %s to proto-json: %s",
                        butil::EnsureString(message.GetDescriptor()->full_name()).c_str(), error.c_str());
    }
    return ok;
}

void ProcessHttpResponse(InputMessageBase* msg) {
    const int64_t start_parse_us = butil::cpuwide_time_us();