Method run

src/Server/HTTP/HTTPServerConnection.cpp:38–191

}

void HTTPServerConnection::run()
{
    DB::setThreadName(ThreadName::HTTP_SERVER_CONN);

    std::string server = params->getSoftwareVersion();
    Poco::Net::HTTPServerSession session(socket(), params);

    ProfileEvents::increment(ProfileEvents::HTTPServerConnectionsCreated);

    while (!stopped && tcp_server.isOpen() && session.connected())
    {
        const bool is_first_request = params->getMaxKeepAliveRequests() == session.getMaxKeepAliveRequests();

        if (!session.hasMoreRequests())
        {
            if (is_first_request)
                // it is strange to have a connection being opened but no request has been sent, account it as an error case
                ProfileEvents::increment(ProfileEvents::HTTPServerConnectionsReset);
            else
                ProfileEvents::increment(ProfileEvents::HTTPServerConnectionsExpired);

            return;
        }
        else
        {
            if (!is_first_request)
                ProfileEvents::increment(ProfileEvents::HTTPServerConnectionsReused);
        }

        try
        {
            std::lock_guard lock(mutex);
            if (!stopped && tcp_server.isOpen() && session.connected())
            {
                HTTPServerResponse response(session);
                HTTPServerRequest request(context, response, session, read_event);

                Poco::Timestamp now;

                if (!forwarded_for.empty())
                    request.set("X-Forwarded-For", forwarded_for);

                if (request.isSecure())
                {
                    size_t hsts_max_age = context->getMaxHstsAge();

                    if (hsts_max_age > 0)
                        response.add("Strict-Transport-Security", "max-age=" + std::to_string(hsts_max_age));

                }

                response.setDate(now);
                response.setVersion(request.getVersion());
                response.setKeepAlive(params->getKeepAlive() && request.getKeepAlive() && session.canKeepAlive());
                if (!server.empty())
                    response.set("Server", server);
                try
                {