Method Process

Source/SampleCapturer.cpp:58–158

}

void SampleCapturer::Process(double time)
{
   PROFILER(SampleCapturer);

   IAudioReceiver* target = GetTarget();

   if (target == nullptr)
      return;

   SyncBuffers();

   if (!mEnabled)
   {
      for (int ch = 0; ch < GetBuffer()->NumActiveChannels(); ++ch)
      {
         Add(target->GetBuffer()->GetChannel(ch), GetBuffer()->GetChannel(ch), GetBuffer()->BufferSize());
         GetVizBuffer()->WriteChunk(GetBuffer()->GetChannel(ch), GetBuffer()->BufferSize(), ch);
      }

      GetBuffer()->Reset();

      return;
   }

   int bufferSize = GetBuffer()->BufferSize();

   ChannelBuffer* out = target->GetBuffer();
   gWorkChannelBuffer.SetNumActiveChannels(GetBuffer()->NumActiveChannels());
   for (int ch = 0; ch < GetBuffer()->NumActiveChannels(); ++ch)
   {
      Add(out->GetChannel(ch), GetBuffer()->GetChannel(ch), GetBuffer()->BufferSize());
      BufferCopy(gWorkChannelBuffer.GetChannel(ch), GetBuffer()->GetChannel(ch), GetBuffer()->BufferSize());
   }

   for (int i = 0; i < bufferSize; ++i)
   {
      if (mWantRecord)
      {
         for (int ch = 0; ch < GetBuffer()->NumActiveChannels(); ++ch)
         {
            if (mIsRecording || GetBuffer()->GetChannel(ch)[i] != 0)
            {
               auto& sample = mSamples[mCurrentSampleIndex];
               if (!mIsRecording)
               {
                  mIsRecording = true;
                  sample.mBuffer.SetNumActiveChannels(GetBuffer()->NumActiveChannels());
                  sample.mBuffer.Clear();
               }

               sample.mBuffer.GetChannel(ch)[sample.mRecordingLength] = GetBuffer()->GetChannel(ch)[i];
            }
         }

         if (mIsRecording)
         {
            ++mSamples[mCurrentSampleIndex].mRecordingLength;
            if (mSamples[mCurrentSampleIndex].mRecordingLength >= mSamples[mCurrentSampleIndex].mBuffer.BufferSize())