Method run

server/src/server/http_server.cpp:1090–1227

        ssize_t n = ::send(fd, ping, sizeof(ping) - 1, MSG_NOSIGNAL | MSG_DONTWAIT);
        if (n <= 0) {
            dead.push_back(fd);
        }
    }
    for (SocketHandle fd : dead) {
        socket_close(fd);
        sse_fds_.erase(std::remove(sse_fds_.begin(), sse_fds_.end(), fd),
                       sse_fds_.end());
    }
}

HttpServer::~HttpServer() {
    shutdown();
    #ifdef DFLASH_HAS_CURL
    curl_global_cleanup();
    #endif
}

void HttpServer::shutdown() {
    // Signal worker and accept loop to stop.
    stopping_.store(true);
    queue_cv_.notify_all();
    if (socket_is_valid(listen_fd_)) {
        socket_close(listen_fd_);
        listen_fd_ = kInvalidSocket;
    }
    if (worker_thread_.joinable()) {
        worker_thread_.join();
    }

    // Close SSE client connections.
    {
        std::lock_guard<std::mutex> lk(sse_mu_);
        for (SocketHandle fd : sse_fds_) socket_close(fd);
        sse_fds_.clear();
    }

    // Drain any pending jobs.
    {
        std::lock_guard<std::mutex> lk(queue_mu_);
        while (queue_head_) {
            ServerJob * j = queue_head_;
            queue_head_ = j->next;
            j->next = nullptr;
            std::lock_guard<std::mutex> jlk(j->mu);
            j->done = true;
            j->cv.notify_one();
        }
        queue_tail_ = nullptr;
    }

    // Shutdown save: persist all tracked snapshot slots to disk.
    // Safe to access slot_tokens_ without locking — worker is joined.
    if (!disk_cache_.disabled() && !slot_tokens_.empty()) {
        std::fprintf(stderr, "[disk-cache] shutdown: saving %zu tracked slots\n",
                     slot_tokens_.size());
        for (auto & [slot, tokens] : slot_tokens_) {
            if (backend_.snapshot_used(slot)) {
                disk_cache_.learn_layout(slot);