Function SendUnauthorizedResponse

src/brpc/policy/http_rpc_protocol.cpp:1338–1374

}

static void SendUnauthorizedResponse(const std::string& user_error_text, Socket* socket, const InputMessageBase* msg) {
    HttpContext* http_request = (HttpContext*)msg;
    const bool is_http2 = http_request->header().is_http2();
    if (is_http2) {
        // for grpc client
        const H2StreamContext* h2_sctx = static_cast<const H2StreamContext*>(msg);
        brpc::Controller cntl;
        cntl.http_response().set_status_code(200);
        cntl.http_response().set_content_type("application/grpc");
        cntl.SetFailed(ERPCAUTH, "%s", user_error_text.empty() ? "Fail to authenticate" : user_error_text.c_str());

        SocketMessagePtr<H2UnsentResponse> h2_response(
            H2UnsentResponse::New(&cntl, h2_sctx->stream_id(), true));
        brpc::Socket::WriteOptions opt;
        opt.ignore_eovercrowded = true;
        socket->Write(h2_response, &opt);
        return;
    }

    // Send 403(forbidden) to client.
    HttpHeader header;
    header.set_status_code(HTTP_STATUS_FORBIDDEN);
    butil::IOBuf content;
    content.append(butil::string_printf("[%d]", ERPCAUTH));
    content.append("Fail to authenticate");
    if (!user_error_text.empty()) {
        content.append(": ");
        content.append(user_error_text);
    }
    butil::IOBuf res_buf;
    MakeRawHttpResponse(&res_buf, &header, &content);
    Socket::WriteOptions opt;
    opt.ignore_eovercrowded = true;
    if (socket->Write(&res_buf, &opt) != 0) {
        PLOG_IF(WARNING, errno != EPIPE) << "Fail to write into " << *socket;
    }
}

bool VerifyHttpRequest(const InputMessageBase* msg) {
    Server* server = (Server*)msg->arg();