read_from_container()

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

staticprivate

Definition at line 276 of file BufferPipeline.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, and MayaFlux::Journal::Kriya.

Referenced by process_operation().

Here is the caller graph for this function: