Method BeginShutdown

src/platform/linux/cloud_hooks.cpp:921–961

}

void CloudHooks::BeginShutdown() {
    g_shuttingDown.store(true, std::memory_order_release);
    SchemaFetch::Shutdown();
    RecvPktHook::Remove();
    GamesPlayedHook::Remove();
    LivePlaytime::RemoveUserCapture();
    for (int i = 0; i < 300 && g_hookRefCount.load(std::memory_order_acquire) > 0; ++i)
        usleep(10000); // 10ms, up to 3s total

    // Join the poller before statics are destroyed. Wait bounded on its exit
    // signal: join() if it reached its end (instant), else detach if wedged in
    // curl rather than hang Steam's shutdown. See g_cloudPollerThread.
    if (g_cloudPollerThread.joinable()) {
        {
            std::unique_lock<std::mutex> lk(g_pollerExitMtx);
            g_pollerExitCv.wait_for(lk, std::chrono::seconds(5),
                [] { return g_pollerExited.load(std::memory_order_acquire); });
        }
        if (g_pollerExited.load(std::memory_order_acquire)) {
            g_cloudPollerThread.join();
        } else {
            LOG("[CloudHooks] poller wedged in network call -- detaching");
            g_cloudPollerThread.detach();
        }
    }

    // Same bounded-join discipline for the background seed thread.
    if (g_seedThread.joinable()) {
        {
            std::unique_lock<std::mutex> lk(g_seedExitMtx);
            g_seedExitCv.wait_for(lk, std::chrono::seconds(5),
                [] { return g_seedExited.load(std::memory_order_acquire); });
        }
        if (g_seedExited.load(std::memory_order_acquire)) {
            g_seedThread.join();
        } else {
            LOG("[CloudHooks] seed wedged in network call -- detaching");
            g_seedThread.detach();
        }
    }
}