extract_implementation()

Datum< Kakshya::RegionGroup > MayaFlux::Yantra::Granular::SegmentOp::extract_implementation ( const Datum< Kakshya::RegionGroup > &  input )

overrideprotected

Definition at line 341 of file GranularWorkflow.cpp.

{
    std::shared_ptr<Kakshya::SignalSourceContainer> container;
 
    if (input.container && *input.container) {
        container = *input.container;
    } else {
        auto param = this->get_parameter("container");
        if (param.has_value()) {
            container = safe_any_cast_or_default<std::shared_ptr<Kakshya::SignalSourceContainer>>(
                param, nullptr);
        }
    }
 
    if (!container) {
        error<std::runtime_error>(
            Journal::Component::Yantra, Journal::Context::ComputeMatrix,
            std::source_location::current(),
            "SegmentOp: no container available via Datum or parameters");
    }
 
    const auto grain_size = this->template get_parameter_or_default<uint32_t>("grain_size", 1024U);
    const auto hop_size = this->template get_parameter_or_default<uint32_t>("hop_size", 512U);
    const auto channel = this->template get_parameter_or_default<uint32_t>("channel", 0U);
 
    const auto& structure = container->get_structure();
 
    if (channel >= structure.get_channel_count()) {
        error<std::runtime_error>(
            Journal::Component::Yantra, Journal::Context::ComputeMatrix,
            std::source_location::current(),
            "SegmentOp: channel {} out of range (container has {})",
            channel, structure.get_channel_count());
    }
 
    const auto num_channels = structure.get_channel_count();
    const auto total = container->get_num_frames();
 
    Datum<Kakshya::RegionGroup> out { input.data, container };
    out.data.regions.clear();
    out.data.current_region_index = 0;
    out.data.active_indices.clear();
 
    for (uint64_t onset = 0; onset + grain_size <= total; onset += hop_size) {
        Kakshya::Region grain {
            std::vector<uint64_t> { onset, 0 },
            std::vector<uint64_t> { onset + grain_size - 1, num_channels - 1 }
        };
        grain.set_attribute("onset", static_cast<double>(onset));
        out.data.regions.push_back(std::move(grain));
    }
 
    out.data.set_attribute<uint32_t>("grain_size", grain_size);
    out.data.set_attribute<uint32_t>("hop_size", hop_size);
    out.data.set_attribute<uint32_t>("channel", channel);
 
    return out;
}

References channel, MayaFlux::Journal::ComputeMatrix, MayaFlux::Yantra::Datum< T >::container, MayaFlux::Yantra::Datum< T >::data, MayaFlux::Yantra::UniversalExtractor< InputType, OutputType >::get_parameter(), MayaFlux::Kakshya::Region::set_attribute(), and MayaFlux::Journal::Yantra.

Here is the call graph for this function: