capture_output()

uint32_t MayaFlux::IO::IOManager::capture_output	(	const std::string &	filepath,
		AVCodecID	codec_id = AV_CODEC_ID_NONE
	)

Begin continuous capture of live audio output to a file.

Registers an observer with AudioBackendService. Each output cycle the observer drives an AudioOutputContainer and posts its processed_data to a SoundFileWriter. Returns an opaque capture id for use with stop_capture().

Returns 0 and logs an error if AudioBackendService is unavailable.

Parameters

filepath	Output file path.
codec_id	Encoder override; AV_CODEC_ID_NONE = container default.

Returns

Capture handle; pass to stop_capture() to finalise.

Definition at line 380 of file IOManager.cpp.

{
 
    if (!m_audio_backend_service) {
        m_audio_backend_service = Registry::BackendRegistry::instance()
                                      .get_service<Registry::Service::AudioBackendService>();
    }
 
    if (!m_audio_backend_service) {
        error<std::runtime_error>(Journal::Component::IO, Journal::Context::FileIO, std::source_location::current(),
            "capture_output: AudioBackendService unavailable");
    }
 
    auto ct = std::make_shared<Kakshya::AudioOutputContainer>(m_stream_info);
    ct->create_default_processor();
 
    auto writer = std::make_shared<SoundFileWriter>();
    if (!writer->open(filepath,
            m_stream_info.output.channels,
            m_stream_info.sample_rate,
            codec_id)) {
        MF_ERROR(Journal::Component::IO, Journal::Context::FileIO,
            "capture_output: writer open failed for '{}': {}", filepath, writer->last_error());
        return 0;
    }
 
    uint32_t obs_id = m_audio_backend_service->register_output_observer(
        [ct, writer](const double*, uint32_t) {
            ct->process_default();
            const auto& vt = ct->get_processed_data();
            if (!vt.empty())
                writer->write(vt);
        });
 
    {
        std::lock_guard lock(m_save_tasks_mutex);
        m_writers.push_back(writer);
    }
 
    std::lock_guard lock(m_audio_captures_mutex);
    m_audio_captures.emplace(obs_id, AudioCaptureState { .container = ct, .writer = writer, .observer_id = obs_id });
    return obs_id;
}

References MayaFlux::Core::GlobalStreamInfo::ChannelConfig::channels, MayaFlux::IO::IOManager::AudioCaptureState::container, MayaFlux::Journal::FileIO, MayaFlux::Registry::BackendRegistry::get_service(), MayaFlux::Registry::BackendRegistry::instance(), MayaFlux::Journal::IO, m_audio_backend_service, m_audio_captures, m_audio_captures_mutex, m_save_tasks_mutex, m_stream_info, m_writers, MF_ERROR, MayaFlux::Core::GlobalStreamInfo::output, MayaFlux::Registry::Service::AudioBackendService::register_output_observer, and MayaFlux::Core::GlobalStreamInfo::sample_rate.

Here is the call graph for this function: