Method process

src/extended/SpectralMonitorNode.cpp:123–194

}

void SpectralMonitorNode::process(ContextRenderLock &r, int bufferSize)
{
    // deal with the output in case the power monitor node is embedded in a signal chain for some reason.
    // It's merely a pass through though.

    AudioBus * outputBus = output(0)->bus(r);

    if (!isInitialized() || !input(0)->isConnected())
    {
        if (outputBus)
            outputBus->zero();
        return;
    }

    AudioBus * bus = input(0)->bus(r);
    bool isBusGood = bus && bus->numberOfChannels() > 0 && bus->channel(0)->length() >= bufferSize;
    if (!isBusGood)
    {
        outputBus->zero();
        return;
    }

    // specific to this node
    {
        std::vector<const float *> channels;
        int numberOfChannels = bus->numberOfChannels();
        for (int c = 0; c < numberOfChannels; ++c)
            channels.push_back(bus->channel(c)->data());

        int sz = internalNode->windowSize->valueUint32();

        // if the fft is smaller than the quantum, just grab a chunk
        if (sz < bufferSize)
        {
            internalNode->cursor = 0;
            bufferSize = internalNode->windowSize->valueUint32();
        }

        // if the quantum overlaps the end of the window, just fill up the buffer
        if (internalNode->cursor + bufferSize > sz)
            bufferSize = sz - internalNode->cursor;

        {
            std::lock_guard<std::recursive_mutex> lock(internalNode->magMutex);

            internalNode->buffer.resize(sz);

            for (int i = 0; i < bufferSize; ++i)
            {
                internalNode->buffer[i + internalNode->cursor] = 0;
            }

            for (int c = 0; c < numberOfChannels; ++c)
            {
                for (int i = 0; i < bufferSize; ++i)
                {
                    float p = channels[c][i];
                    internalNode->buffer[i + internalNode->cursor] += p;