Function Shutdown

src/common/cloud_work_queue.cpp:704–762

}

void Shutdown() {
    g_shuttingDown.store(true, std::memory_order_seq_cst);
    g_workerRunning = false;
    g_queueCV.notify_all();

    // 5s bounded wait for workers; detach stragglers blocked on cloud I/O.
    auto joinDeadline = std::chrono::steady_clock::now() + std::chrono::seconds(5);
    for (auto& t : g_workerThreads) {
        if (!t.joinable()) continue;
        auto remaining = joinDeadline - std::chrono::steady_clock::now();
        if (remaining <= std::chrono::milliseconds(0)) {
            LOG("[CloudStorage] WorkQueue shutdown: detaching worker (join deadline exceeded)");
            t.detach();
            continue;
        }
#ifdef _WIN32
        DWORD waitMs = (DWORD)std::chrono::duration_cast<std::chrono::milliseconds>(remaining).count();
        HANDLE h = t.native_handle();
        if (WaitForSingleObject(h, waitMs) == WAIT_TIMEOUT) {
            LOG("[CloudStorage] WorkQueue shutdown: detaching worker (join timed out after %lu ms)", waitMs);
            t.detach();
        } else {
            t.join();
        }
#else
        // No timed join on POSIX; best-effort sleep then join.
        std::this_thread::sleep_for(std::chrono::milliseconds(50));
        if (t.joinable()) {
            t.join();
        }
#endif
    }
    g_workerThreads.clear();

    int spinCount = 0;
    while (g_activeWorkers.load(std::memory_order_acquire) > 0) {
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
        if (++spinCount > 500) { // 5 seconds max
            LOG("[CloudStorage] WorkQueue shutdown: timed out waiting for %d active workers",
                g_activeWorkers.load());
            break;
        }
    }

    {
        std::lock_guard<std::mutex> lock(g_queueMutex);
        g_workQueue.clear();
        g_uploadIndex.clear();
        g_activePaths.clear();
        g_activeDeletes.clear();
        g_activeBestEffortPaths.clear();
        g_recentUploadFingerprints.clear();
        g_failedPaths.clear();
        g_failedWorkItems.clear();
    }
    g_drainCV.notify_all();

    LOG("[CloudStorage] Background work queue shutdown complete");