Method RealtimeProcess

libraries/lib-builtin-effects/CompressorInstance.cpp:156–193

} // namespace

size_t CompressorInstance::RealtimeProcess(
   size_t group, EffectSettings& settings, const float* const* inbuf,
   float* const* outbuf, size_t numSamples)
{
   if (group >= mSlaves.size())
      return 0;
   auto& slave = mSlaves[group];
   auto& compressor = *slave.mCompressor;
   const auto numProcessedSamples =
      InstanceProcess(settings, compressor, inbuf, outbuf, numSamples);
   if (const auto queue = slave.mOutputQueue.lock())
   {
      const auto& frameStats = compressor.GetLastFrameStats();
      const auto& compressorSettings = compressor.GetSettings();
      const float netGain = compressorSettings.outCompressionThreshDb -
                            compressorSettings.inCompressionThreshDb;
      const auto targetCompressionDb =
         compressor.EvaluateTransferFunction(frameStats.maxInputSampleDb) -
         frameStats.maxInputSampleDb - netGain;
      DynamicRangeProcessorOutputPacket newPacket;
      newPacket.indexOfFirstSample = slave.mSampleCounter;
      newPacket.numSamples = numProcessedSamples;
      newPacket.targetCompressionDb = targetCompressionDb;
      newPacket.actualCompressionDb = frameStats.dbGainOfMaxInputSample;
      newPacket.inputDb = frameStats.maxInputSampleDb;
      newPacket.outputDb = GetOutputDb(frameStats, compressorSettings);
      queue->Put(newPacket);
   }

   if (const auto queue = slave.mCompressionValueQueue.lock())
      queue->Put(MeterValues {
         compressor.GetLastFrameStats().dbGainOfMaxInputSample,
         GetOutputDb(
            compressor.GetLastFrameStats(), compressor.GetSettings()) });

   slave.mSampleCounter += numProcessedSamples;
   return numProcessedSamples;
}

void CompressorInstance::RealtimePassThrough(
   size_t group, EffectSettings& settings, const float* const* inbuf,