Function runDC004

tests/cpp/integration/engine_destroy_chain_test.cpp:181–225

DC004 body: rapid create/destroy cycles.

// DC004 body: rapid create/destroy cycles.
static void runDC004() {
    auto* engine = ::agenui::getAGenUIEngine();
    if (!engine) _exit(1);

    // Rapid cycles — intentionally skip WaitForWorkerIdle to let
    // worker-thread tasks pile up. No listener in the loop because the
    // SM is destroyed without draining; a stack-local listener would be
    // use-after-scope by the time the worker thread dispatches callbacks.
    for (int i = 0; i < 10; ++i) {
        auto* sm = engine->createSurfaceManager();
        if (!sm) _exit(2);

        sm->beginTextStream();
        sm->receiveTextChunk(
            createSurfaceJson("dc004-" + std::to_string(i)));
        sm->endTextStream();

        engine->destroySurfaceManager(sm);
        // No drain — tasks accumulate on worker thread
    }

    // Drain all accumulated tasks
    ::agenui::testing::WaitForWorkerIdle(5000);

    // Final SM — proves engine is still fully operational after churn
    auto* smFinal = engine->createSurfaceManager();
    if (!smFinal) _exit(3);
    ::agenui::testing::WaitForWorkerIdle();

    ::agenui::testing::MockMessageListener listenerFinal;
    smFinal->addSurfaceEventListener(&listenerFinal);

    smFinal->beginTextStream();
    smFinal->receiveTextChunk(createSurfaceJson("dc004-final"));
    smFinal->endTextStream();
    ::agenui::testing::WaitForWorkerIdle();

    smFinal->removeSurfaceEventListener(&listenerFinal);
    engine->destroySurfaceManager(smFinal);

    // No drain — engine->stop() drains the worker thread itself.
    ::agenui::destroyAGenUIEngine();

    _exit(0);
}

// ---------------------------------------------------------------------------
// Test suite — "DeathTest" suffix makes GTest default to threadsafe style.