Method Process

modules/import-export/mod-wavpack/ExportWavPack.cpp:505–613

}

ExportResult WavPackExportProcessor::Process(ExportProcessorDelegate& delegate)
{
   delegate.SetStatusString(context.status);

   const size_t bufferSize = SAMPLES_PER_RUN * context.numChannels;

   ArrayOf<int32_t> wavpackBuffer{ bufferSize };

   auto exportResult = ExportResult::Success;
   {

      while (exportResult == ExportResult::Success) {
         auto samplesThisRun = context.mixer->Process();

         if (samplesThisRun == 0)
            break;

            const auto bytesPerSample = context.bytesPerSample;
            auto& md5 = context.md5;
            const auto updateMd5 = [&](uint32_t sampleValue) {
               unsigned char sampleBytes[4];
               sampleBytes[0] = static_cast<unsigned char>(sampleValue & 0xFF);
               sampleBytes[1]
                  = static_cast<unsigned char>((sampleValue >> 8) & 0xFF);
               sampleBytes[2]
                  = static_cast<unsigned char>((sampleValue >> 16) & 0xFF);
               sampleBytes[3]
                  = static_cast<unsigned char>((sampleValue >> 24) & 0xFF);
               md5.Update(sampleBytes, bytesPerSample);
            };

         if (context.format == int16Sample) {
            const int16_t *mixed = reinterpret_cast<const int16_t*>(context.mixer->GetBuffer());
            for (decltype(samplesThisRun) j = 0; j < samplesThisRun; j++) {
               for (size_t i = 0; i < context.numChannels; i++) {
                  const auto sampleValue = (static_cast<int32_t>(*mixed++) * 65536) >> 16;
                  wavpackBuffer[j*context.numChannels + i] = sampleValue;
                  updateMd5(sampleValue);
               }
            }
         } else {
            const int *mixed = reinterpret_cast<const int*>(context.mixer->GetBuffer());
            for (decltype(samplesThisRun) j = 0; j < samplesThisRun; j++) {
               for (size_t i = 0; i < context.numChannels; i++) {
                  const auto sampleValue = *mixed++;
                  wavpackBuffer[j*context.numChannels + i] = sampleValue;
                  updateMd5(sampleValue);
               }
            }
         }

         if (!WavpackPackSamples(context.wpc, wavpackBuffer.get(), samplesThisRun)) {
            throw ExportErrorException(WavpackGetErrorMessage(context.wpc));
         }
         exportResult = ExportPluginHelpers::UpdateProgress(
            delegate, *context.mixer, context.t0, context.t1);
      }
   }