Introduce AudioBufferMemoryPool to avoid thrashing on audio buffers.

chromecast/media/cma/backend/alsa/audio_decoder_alsa.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chromecast/media/cma/backend/alsa/audio_decoder_alsa.h"
 
 #include <time.h>
 
 #include <algorithm>
 #include <limits>
 
 #include "base/callback_helpers.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/trace_event/trace_event.h"
 #include "chromecast/base/task_runner_impl.h"
 #include "chromecast/media/cma/backend/alsa/media_pipeline_backend_alsa.h"
 #include "chromecast/media/cma/base/decoder_buffer_adapter.h"
 #include "chromecast/media/cma/base/decoder_buffer_base.h"
 #include "chromecast/public/media/cast_decoder_buffer.h"
-#include "media/base/audio_buffer.h"
 #include "media/base/audio_bus.h"
 #include "media/base/channel_layout.h"
 #include "media/base/decoder_buffer.h"
 #include "media/base/sample_format.h"
 #include "media/filters/audio_renderer_algorithm.h"
 
 #define TRACE_FUNCTION_ENTRY0() TRACE_EVENT0("cma", __FUNCTION__)
 
 #define TRACE_FUNCTION_ENTRY1(arg1) \
   TRACE_EVENT1("cma", __FUNCTION__, #arg1, arg1)
@@ skipping 33 matching lines @@
       delegate_(nullptr),
       pending_buffer_complete_(false),
       got_eos_(false),
       pushed_eos_(false),
       mixer_error_(false),
       rate_shifter_output_(
           ::media::AudioBus::Create(kNumChannels, kDefaultFramesPerBuffer)),
       current_pts_(kInvalidTimestamp),
       pending_output_frames_(kNoPendingOutput),
       volume_multiplier_(1.0f),
+      pool_(new ::media::AudioBufferMemoryPool()),
       weak_factory_(this) {
   TRACE_FUNCTION_ENTRY0();
   DCHECK(backend_);
   DCHECK(task_runner_.get());
   DCHECK(task_runner_->BelongsToCurrentThread());
 }
 
 AudioDecoderAlsa::~AudioDecoderAlsa() {
   TRACE_FUNCTION_ENTRY0();
   DCHECK(task_runner_->BelongsToCurrentThread());
@@ skipping 288 matching lines @@
       return;
     }
 
     // Otherwise, queue data into the rate shifter, and then try to push the
     // rate-shifted data.
     const uint8_t* channels[kNumChannels] = {
         decoded->data(), decoded->data() + input_frames * sizeof(float)};
     scoped_refptr<::media::AudioBuffer> buffer = ::media::AudioBuffer::CopyFrom(
         ::media::kSampleFormatPlanarF32, ::media::CHANNEL_LAYOUT_STEREO,
         kNumChannels, config_.samples_per_second, input_frames, channels,
-        base::TimeDelta());
+        base::TimeDelta(), pool_);
     rate_shifter_->EnqueueBuffer(buffer);
     rate_shifter_info_.back().input_frames += input_frames;
   }
 
   PushRateShifted();
   DCHECK(!rate_shifter_info_.empty());
   CheckBufferComplete();
 }
 
 void AudioDecoderAlsa::CheckBufferComplete() {
@@ skipping 144 matching lines @@
   TRACE_FUNCTION_ENTRY0();
   DCHECK(task_runner_->BelongsToCurrentThread());
   if (error != MixerError::kInputIgnored)
     LOG(ERROR) << "Mixer error occurred.";
   mixer_error_ = true;
   delegate_->OnDecoderError();
 }
 
 }  // namespace media
 }  // namespace chromecast