Method process_request

external/cpp-httplib/httplib.h:5727–5848

    }

    inline bool
        Server::process_request(Stream& strm, bool close_connection,
            bool& connection_closed,
            const std::function<void(Request&)>& setup_request) {
        std::array<char, 2048> buf{};

        detail::stream_line_reader line_reader(strm, buf.data(), buf.size());

        // Connection has been closed on client
        if (!line_reader.getline()) { return false; }

        Request req;
        Response res;

        res.version = "HTTP/1.1";

        for (const auto& header : default_headers_) {
            if (res.headers.find(header.first) == res.headers.end()) {
                res.headers.insert(header);
            }
        }

#ifdef _WIN32
        // TODO: Increase FD_SETSIZE statically (libzmq), dynamically (MySQL).
#else
#ifndef CPPHTTPLIB_USE_POLL
        // Socket file descriptor exceeded FD_SETSIZE...
        if (strm.socket() >= FD_SETSIZE) {
            Headers dummy;
            detail::read_headers(strm, dummy);
            res.status = 500;
            return write_response(strm, close_connection, req, res);
        }
#endif
#endif

        // Check if the request URI doesn't exceed the limit
        if (line_reader.size() > CPPHTTPLIB_REQUEST_URI_MAX_LENGTH) {
            Headers dummy;
            detail::read_headers(strm, dummy);
            res.status = 414;
            return write_response(strm, close_connection, req, res);
        }

        // Request line and headers
        if (!parse_request_line(line_reader.ptr(), req) ||
            !detail::read_headers(strm, req.headers)) {
            res.status = 400;
            return write_response(strm, close_connection, req, res);
        }

        if (req.get_header_value("Connection") == "close") {
            connection_closed = true;
        }

        if (req.version == "HTTP/1.0" &&
            req.get_header_value("Connection") != "Keep-Alive") {
            connection_closed = true;