Dynamically allocate more memory to AudioBlockFifo

media/audio/pulse/pulse_input.cc

 // Copyright (c) 2012 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 "media/audio/pulse/pulse_input.h"
 
 #include <pulse/pulseaudio.h>
 
 #include "base/logging.h"
 #include "media/audio/pulse/audio_manager_pulse.h"
@@ skipping 252 matching lines @@
   normalized_volume = volume_ / GetMaxVolume();
 
   do {
     size_t length = 0;
     const void* data = NULL;
     pa_stream_peek(handle_, &data, &length);
     if (!data || length == 0)
       break;
 
     const int number_of_frames = length / params_.GetBytesPerFrame();
+    if (number_of_frames > fifo_.GetUnfilledFrames()) {
+      // Dynamically append buffers to the FIFO to handle larger buffer got
+      // from Pulse.
+      const int append_blocks_of_buffer = static_cast<int>(
+          (number_of_frames - fifo_.GetUnfilledFrames()) /
+              params_.frames_per_buffer()) + 1;
+      fifo_.Append(append_blocks_of_buffer);
+    }
+
     fifo_.Push(data, number_of_frames, params_.bits_per_sample() / 8);
 
     // Checks if we still have data.
     pa_stream_drop(handle_);
   } while (pa_stream_readable_size(handle_) > 0);
 
   while (fifo_.available_blocks()) {
     const AudioBus* audio_bus = fifo_.Consume();
 
     // Compensate the audio delay caused by the FIFO.
     hardware_delay += fifo_.GetAvailableFrames() * params_.GetBytesPerFrame();
     callback_->OnData(this, audio_bus, hardware_delay, normalized_volume);
 
     // Sleep 5ms to wait until render consumes the data in order to avoid
     // back to back OnData() method.
     if (fifo_.available_blocks())
       base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(5));
   }
 
   pa_threaded_mainloop_signal(pa_mainloop_, 0);
 }
 
 }  // namespace media