stop()

void MayaFlux::IO::IOManager::stop

(

)

Finalizes all in-flight output while consumers are still running.

Stops every audio, video, volume and spatial capture through its stop_*_capture() call, closes the sound writers and waits for pending saves. A capture the caller never stopped is still finalized (an Ogawa archive or video container left open is not a valid file), and volume/spatial captures release their scheduler reference here instead of reaching into an already-destroyed scheduler.

The IOService stays registered and readers stay alive, so threads that consume them keep working. Idempotent. Call before the subsystems stop (see Engine::End()), while backend services and logging sinks are alive.

Definition at line 106 of file IOManager.cpp.

{
    if (m_stop_done.exchange(true)) {
        return;
    }
 
    {
        std::vector<uint32_t> ids;
        {
            std::lock_guard lock(m_audio_captures_mutex);
            ids.reserve(m_audio_captures.size());
            for (const auto& [id, _] : m_audio_captures)
                ids.push_back(id);
        }
        for (auto id : ids)
            stop_audio_capture(id);
    }
 
    {
        std::vector<uint32_t> ids;
        {
            std::lock_guard lock(m_video_captures_mutex);
            ids.reserve(m_video_captures.size());
            for (const auto& [id, _] : m_video_captures)
                ids.push_back(id);
        }
        for (auto id : ids)
            stop_video_capture(id);
    }
 
    {
        std::vector<uint32_t> ids;
        {
            std::lock_guard lock(m_volume_captures_mutex);
            ids.reserve(m_volume_captures.size());
            for (const auto& [id, _] : m_volume_captures)
                ids.push_back(id);
        }
        for (auto id : ids)
            stop_volume_capture(id);
    }
 
    {
        std::vector<uint32_t> ids;
        {
            std::lock_guard lock(m_spatial_captures_mutex);
            ids.reserve(m_spatial_captures.size());
            for (const auto& [id, _] : m_spatial_captures)
                ids.push_back(id);
        }
        for (auto id : ids)
            stop_spatial_capture(id);
    }
 
    for (auto& w : m_writers) {
        if (w->is_open()) {
            auto fut = w->close();
            fut.wait();
        }
    }
 
    wait_for_pending_saves();
 
    MF_TRACE(Journal::Component::IO, Journal::Context::Init, "IOManager stopped");
}

References ids, MayaFlux::Journal::Init, MayaFlux::Journal::IO, m_audio_captures, m_audio_captures_mutex, m_spatial_captures, m_spatial_captures_mutex, m_stop_done, m_video_captures, m_video_captures_mutex, m_volume_captures, m_volume_captures_mutex, m_writers, MF_TRACE, stop_audio_capture(), stop_spatial_capture(), stop_video_capture(), stop_volume_capture(), and wait_for_pending_saves().

Referenced by shutdown().

Here is the call graph for this function:

Here is the caller graph for this function: