Function TEST_F

tests/cpp/concurrency/queue_pressure_test.cpp:40–54

QP001: Burst 10K small tasks via receiveTextChunk, then drain. Memory (queue depth) is observable indirectly via worker-idle latency.

// QP001: Burst 10K small tasks via receiveTextChunk, then drain. Memory
// (queue depth) is observable indirectly via worker-idle latency.
TEST_F(QueuePressureTest, QP001_BurstReceive10K_DrainsCleanly) {
    ::agenui::testing::ScopedSurfaceManager sm;
    constexpr int N = 10000;
    auto begin = std::chrono::steady_clock::now();
    sm->beginTextStream();
    for (int i = 0; i < N; ++i) {
        sm->receiveTextChunk("x");
    }
    sm->endTextStream();
    ASSERT_TRUE(::agenui::testing::WaitForWorkerIdle(30000));
    auto elapsed = std::chrono::duration_cast<std::chrono::milliseconds>(
        std::chrono::steady_clock::now() - begin).count();
    // No hard latency contract; just sanity bound to catch infinite loops.
    EXPECT_LT(elapsed, 30000) << "elapsed ms=" << elapsed;
}

// QP002: Burst then immediately destroy. All queued tasks hold a shared_ptr
// to the SM via lambda capture. Destroy enqueues uninit; queue must drain