tracktion_LiveMidiOutputNode.cpp

Go to the documentation of this file.

 /*
    ,--.                     ,--.     ,--.  ,--.
  ,-'  '-.,--.--.,--,--.,---.|  |,-.,-'  '-.`--' ,---. ,--,--,      Copyright 2024
  '-.  .-'|  .--' ,-.  | .--'|     /'-.  .-',--.| .-. ||      \   Tracktion Software
    |  |  |  |  \ '-'  \ `--.|  \  \  |  |  |  |' '-' '|  ||  |       Corporation
    `---' `--'   `--`--'`---'`--'`--' `---' `--' `---' `--''--'    www.tracktion.com
 
    Tracktion Engine uses a GPL/commercial licence - see LICENCE.md for details.
*/
 
namespace tracktion { inline namespace engine
{
 
//==============================================================================
//==============================================================================
LiveMidiOutputNode::LiveMidiOutputNode (AudioTrack& at, std::unique_ptr<tracktion::graph::Node> inputNode)
    : track (&at), trackPtr (at), input (std::move (inputNode))
{
    jassert (input);
 
    setOptimisations ({ tracktion::graph::ClearBuffers::no,
                        tracktion::graph::AllocateAudioBuffer::no });
 
    pendingMessages.reserve (50);
    dispatchingMessages.reserve (50);
}
 
LiveMidiOutputNode::LiveMidiOutputNode (Clip& c, std::unique_ptr<tracktion::graph::Node> inputNode)
    : clipPtr (c), input (std::move (inputNode))
{
    jassert (input);
 
    setOptimisations ({ tracktion::graph::ClearBuffers::no,
                        tracktion::graph::AllocateAudioBuffer::no });
 
    pendingMessages.reserve (50);
    dispatchingMessages.reserve (50);
}
 
//==============================================================================
tracktion::graph::NodeProperties LiveMidiOutputNode::getNodeProperties()
{
    auto props = input->getNodeProperties();
    props.nodeID = 0;
 
    return props;
}
 
std::vector<tracktion::graph::Node*> LiveMidiOutputNode::getDirectInputNodes()
{
    return { input.get() };
}
 
void LiveMidiOutputNode::prepareToPlay (const tracktion::graph::PlaybackInitialisationInfo&)
{
}
 
bool LiveMidiOutputNode::isReadyToProcess()
{
    return input->hasProcessed();
}
 
void LiveMidiOutputNode::process (ProcessContext& pc)
{
    auto sourceBuffers = input->getProcessedOutput();
    auto& destMidiBlock = pc.buffers.midi;
    jassert (sourceBuffers.audio.getSize() == pc.buffers.audio.getSize());
 
    // If the source only outputs to this node, we can steal its data
    if (input->numOutputNodes == 1)
        destMidiBlock.swapWith (sourceBuffers.midi);
    else
        destMidiBlock.copyFrom (sourceBuffers.midi);
 
    setAudioOutput (input.get(), sourceBuffers.audio);
 
    bool needToUpdate = false;
 
    if (sourceBuffers.midi.isNotEmpty())
    {
        const std::scoped_lock sl (mutex);
 
        for (auto& m : sourceBuffers.midi)
            pendingMessages.add (m);
 
        needToUpdate = ! pendingMessages.isEmpty();
    }
 
    if (needToUpdate)
        triggerAsyncUpdate();
}
 
//==============================================================================
void LiveMidiOutputNode::handleAsyncUpdate()
{
    {
        const std::scoped_lock sl (mutex);
        pendingMessages.swapWith (dispatchingMessages);
    }
 
    if (track != nullptr)
        for (auto& m : dispatchingMessages)
            track->getListeners().call (&AudioTrack::Listener::recordedMidiMessageSentToPlugins, *track, m);
 
    if (clipPtr != nullptr)
        for (auto& m : dispatchingMessages)
            clipPtr->getListeners().call (&Clip::Listener::midiMessageGenerated, *clipPtr, m);
 
    dispatchingMessages.clear();
}
 
}} // namespace tracktion { inline namespace engine