Method processBlockInternal

Server/Source/ProcessorClient.cpp:625–685

template <typename T>
void ProcessorClient::processBlockInternal(AudioBuffer<T>& buffer, MidiBuffer& midiMessages) {
    traceScope();

    AudioPlayHead::PositionInfo posInfo;
    if (nullptr != m_playhead) {
        if (auto optPosInfo = m_playhead->getPosition()) {
            posInfo = *optPosInfo;
        }
    }

    int sendBufChannels = m_activeChannels.getNumActiveChannelsCombined();
    AudioBuffer<T>* sendBuffer;
    std::unique_ptr<AudioBuffer<T>> tmpBuffer;

    if (sendBufChannels != buffer.getNumChannels()) {
        tmpBuffer = std::make_unique<AudioBuffer<T>>(sendBufChannels, buffer.getNumSamples());
        sendBuffer = tmpBuffer.get();
    } else {
        sendBuffer = &buffer;
    }

    MessageHelper::Error e;
    AudioMessage msg(this);

    TimeTrace::addTracePoint("pc_prep_buffer");

    m_channelMapper.map(&buffer, sendBuffer);
    TimeTrace::addTracePoint("pc_ch_map");

    {
        std::lock_guard<std::mutex> lock(m_audioMtx);

        if (nullptr != m_sockAudio) {
            TimeTrace::addTracePoint("pc_lock");

            if (!msg.sendToServer(m_sockAudio.get(), *sendBuffer, midiMessages, posInfo, sendBuffer->getNumChannels(),
                                  sendBuffer->getNumSamples(), &e, *m_bytesOutMeter)) {
                logln("error while sending audio message to sandbox: " << e.toString());
                m_sockAudio->close();
                return;
            }

            TimeTrace::addTracePoint("pc_send");

            if (!msg.readFromServer(m_sockAudio.get(), *sendBuffer, midiMessages, &e, *m_bytesInMeter)) {
                logln("error while reading audio message from sandbox: " << e.toString());
                m_sockAudio->close();
                return;
            }

            TimeTrace::addTracePoint("pc_read");
        } else {
            logln("error while sending audio message: no socket");
            return;
        }
    }

    m_channelMapper.mapReverse(sendBuffer, &buffer);