Function handleHttpRequest

3ds/source/server.cpp:201–302

    }

    static void handleHttpRequest(s32 clientSocket)
    {
        // Read only up to and including the header terminator; the body is either
        // streamed to disk (upload paths) or read into RAM afterwards (others).
        std::string data;
        data.reserve(4096);
        constexpr size_t RECV_CHUNK = 32 * 1024;
        std::unique_ptr<char[]> buffer(new char[RECV_CHUNK]);
        size_t headerEnd = std::string::npos;
        int idleMs       = 0;

        while (true) {
            ssize_t received = pollRecv(clientSocket, buffer.get(), RECV_CHUNK, idleMs, false);
            if (received <= 0) {
                break;
            }
            data.append(buffer.get(), received);
            headerEnd = data.find("\r\n\r\n");
            if (headerEnd != std::string::npos) {
                break;
            }
            if (data.size() > MAX_HEADER_SIZE) {
                break;
            }
        }
        if (headerEnd == std::string::npos) {
            return;
        }

        std::string headers  = data.substr(0, headerEnd);
        std::string path     = extractPath(headers);
        size_t contentLength = parseContentLength(headers);
        size_t bodyStart     = headerEnd + 4;

        // Streaming upload path.
        std::string tmpPath;
        Server::UploadHandler uploadHandler;
        bool isUpload = false;
        {
            std::lock_guard<std::mutex> lock(handlersMutex);
            auto it = uploadHandlers.find(path);
            if (it != uploadHandlers.end()) {
                tmpPath       = it->second.first;
                uploadHandler = it->second.second;
                isUpload      = true;
            }
        }
        if (isUpload) {
            std::u16string tmpU16 = StringUtils::UTF8toUTF16(tmpPath.c_str());
            const char* leftover  = data.data() + bodyStart;
            size_t leftoverLen    = data.size() - bodyStart;
            bool complete         = streamBodyToFile(clientSocket, tmpU16, contentLength, leftover, leftoverLen);
            if (!complete) {
                // Cancelled, stalled, or dropped mid-upload: drop the request and
                // clear the transfer UI; the handler never runs on a partial body.
                FSUSER_DeleteFile(Archive::sdmc(), fsMakePath(PATH_UTF16, tmpU16.data()));
                TransferStatus::end();
                Logging::info("Upload abandoned before the full body arrived.");