Method handleRequest

src/Server/InterserverIOHTTPHandler.cpp:85–130

void InterserverIOHTTPHandler::handleRequest(HTTPServerRequest & request, HTTPServerResponse & response, const ProfileEvents::Event & write_event)
{
    DB::setThreadName(ThreadName::INTERSERVER_HANDLER);

    /// In order to work keep-alive.
    if (request.getVersion() == HTTPServerRequest::HTTP_1_1)
        response.setChunkedTransferEncoding(true);

    auto output = std::make_shared<WriteBufferFromHTTPServerResponse>(
        response, request.getMethod() == Poco::Net::HTTPRequest::HTTP_HEAD, write_event);

    try
    {
        auto [message, success] = checkAuthentication(request);
        if (success)
        {
            processQuery(request, response, output);
            output->finalize();
            LOG_DEBUG(log, "Done processing query");
        }
        else
        {
            LOG_WARNING(log, "Query processing failed request: '{}' authentication failed", request.getURI());
            output->cancelWithException(request, ErrorCodes::REQUIRED_PASSWORD, message, nullptr);
        }
    }
    catch (Exception & e)
    {
        /// Sending to remote server was cancelled due to server shutdown or drop table.
        bool is_real_error = e.code() != ErrorCodes::ABORTED;
        PreformattedMessage message = getCurrentExceptionMessageAndPattern(/* with_stacktrace */ is_real_error);
        if (is_real_error)
            LOG_ERROR(log, message);
        else
            LOG_INFO(log, message);

        output->cancelWithException(request, getCurrentExceptionCode(), message.text, nullptr);
    }
    catch (...)
    {
        PreformattedMessage message = getCurrentExceptionMessageAndPattern(/* with_stacktrace */ false);
        LOG_ERROR(log, message);

        output->cancelWithException(request, getCurrentExceptionCode(), message.text, nullptr);
    }
}


}