mostlyharmless_AudioHelpers.h

Go to the documentation of this file.

//
// Created by Syl on 19/08/2024.
//
 
#ifndef MOSTLYHARMLESS_MOSTLYHARMLESS_AUDIOHELPERS_H
#define MOSTLYHARMLESS_MOSTLYHARMLESS_AUDIOHELPERS_H
#include "mostly_harmless/events/mostlyharmless_InputEventContext.h"
#include "marvin/containers/marvin_BufferView.h"
#include <functional>
namespace mostly_harmless {
    template <marvin::FloatType SampleType>
    void runBlockDispatch(marvin::containers::BufferView<SampleType> buffer,
                          mostly_harmless::events::InputEventContext eventContext,
                          std::function<void(const clap_event_header* event)>&& eventCallback,
                          std::function<void(marvin::containers::BufferView<SampleType>)>&& blockCallback) {
        const auto numChannels = buffer.getNumChannels();
        auto** channelArray = static_cast<SampleType**>(alloca(sizeof(SampleType*) * numChannels));
        size_t lastEventIndex{ 0 };
        auto* const* rawBuff = buffer.getArrayOfWritePointers();
        for (size_t i = 0; i < buffer.getNumSamples(); ++i) {
            if (eventContext.next() && eventContext.next()->time == static_cast<std::uint32_t>(i)) {
                while (eventContext.next() && eventContext.next()->time == static_cast<std::uint32_t>(i)) {
                    eventCallback(eventContext.next());
                    ++eventContext;
                }
                for (size_t channel = 0; channel < numChannels; ++channel) {
                    auto* offsetChannelPtr = rawBuff[channel] + static_cast<std::ptrdiff_t>(lastEventIndex);
                    channelArray[channel] = offsetChannelPtr;
                }
                const auto numSamples = i - lastEventIndex;
                marvin::containers::BufferView<SampleType> slice{ channelArray, buffer.getNumChannels(), numSamples };
                blockCallback(slice);
                lastEventIndex = i;
            }
        }
        const auto remaining = static_cast<std::int64_t>(buffer.getNumSamples()) - static_cast<std::int64_t>(lastEventIndex);
        if (remaining <= 0) return;
        for (size_t channel = 0; channel < numChannels; ++channel) {
            auto* offsetChannelPtr = rawBuff[channel] + static_cast<std::ptrdiff_t>(lastEventIndex);
            channelArray[channel] = offsetChannelPtr;
        }
        marvin::containers::BufferView<SampleType> slice{ channelArray, buffer.getNumChannels(), static_cast<size_t>(remaining) };
        blockCallback(slice);
    }
} // namespace mostly_harmless
 
#endif // MOSTLYHARMLESS_MOSTLYHARMLESS_AUDIOHELPERS_H