read_from_container() [1/2]

Kakshya::DataVariant MayaFlux::Kriya::detail::read_from_container	(	const std::shared_ptr< Kakshya::DynamicSoundStream > &	container,
		uint64_t	,
		uint32_t	length
	)

Definition at line 72 of file PipelineBufferData.cpp.

{
    try {
        uint32_t read_length = length;
        if (read_length == 0) {
            read_length = static_cast<uint32_t>(container->get_total_elements() / container->get_num_channels());
        }
 
        std::vector<double> output_data(static_cast<size_t>(read_length * container->get_num_channels()));
        std::span<double> output_span(output_data.data(), output_data.size());
 
        uint64_t frames_read = container->read_frames(output_span, read_length);
 
        if (frames_read < output_data.size()) {
            output_data.resize(frames_read);
        }
 
        return output_data;
 
    } catch (const std::exception& e) {
        error_rethrow(Journal::Component::Kriya,
            Journal::Context::CoroutineScheduling,
            std::source_location::current(),
            "Error reading from container: {}",
            e.what());
 
        return std::vector<double> {};
    }
}

References MayaFlux::Journal::CoroutineScheduling, MayaFlux::Journal::Kriya, and length.

Referenced by MayaFlux::Kriya::BufferPipeline::process_fuse(), and MayaFlux::Kriya::BufferPipeline::process_load().

Here is the caller graph for this function: