[Chromecast] Fade in after a mixer input stream has skipped

chromecast/media/cma/backend/alsa/stream_mixer_alsa_unittest.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/stream_mixer_alsa.h"
 
 #include <algorithm>
 #include <cmath>
 #include <limits>
 #include <utility>
@@ skipping 133 matching lines @@
   // StreamMixerAlsa::InputQueue implementation:
   int input_samples_per_second() const override { return samples_per_second_; }
   float volume_multiplier() const override { return multiplier_; }
   bool primary() const override { return primary_; }
   bool IsDeleting() const override { return deleting_; }
   MOCK_METHOD1(Initialize,
                void(const MediaPipelineBackendAlsa::RenderingDelay&
                         mixer_rendering_delay));
   int MaxReadSize() override { return max_read_size_; }
   MOCK_METHOD2(GetResampledData, void(::media::AudioBus* dest, int frames));
+  MOCK_METHOD0(OnSkipped, void());
   MOCK_METHOD1(AfterWriteFrames,
                void(const MediaPipelineBackendAlsa::RenderingDelay&
                         mixer_rendering_delay));
   MOCK_METHOD1(SignalError, void(StreamMixerAlsaInput::MixerError error));
   MOCK_METHOD1(PrepareToDelete, void(const OnReadyToDeleteCb& delete_cb));
 
   // Setters and getters for test control.
   void SetPaused(bool paused) { paused_ = paused; }
   void SetMaxReadSize(int max_read_size) { max_read_size_ = max_read_size; }
   void SetData(std::unique_ptr<::media::AudioBus> data) {
@@ skipping 205 matching lines @@
 
   // TODO(slan): Verify that the data is mixed properly with math.
   EXPECT_CALL(*mock_alsa(), PcmWritei(_, _, 512)).Times(1);
   mixer->WriteFramesForTest();
 
   // Make two of these streams non-primary, and exhaust a non-primary stream.
   // All non-empty streams shall be polled for data and the mixer shall write
   // to ALSA.
   inputs[1]->SetPrimary(false);
   inputs[1]->SetMaxReadSize(0);
+  EXPECT_CALL(*inputs[1], OnSkipped());
   inputs[2]->SetPrimary(false);
   for (auto* input : inputs) {
     if (input != inputs[1])
       EXPECT_CALL(*input, GetResampledData(_, 1024)).Times(1);
     EXPECT_CALL(*input, AfterWriteFrames(_)).Times(1);
   }
   // Note that the new smallest stream shall dictate the length of the write.
   EXPECT_CALL(*mock_alsa(), PcmWritei(_, _, 1024)).Times(1);
   mixer->WriteFramesForTest();
 
@@ skipping 258 matching lines @@
 
   // Poll the inputs for data. The first input will provide data (since the
   // output is in an underrun condition); the second input can't provide any
   // data, but AfterWriteFrames() will still be called on it so that it has the
   // correct rendering delay.
   const int kNumFrames = 32;
   inputs[0]->SetData(GetTestData(0));
   EXPECT_CALL(*inputs[0], GetResampledData(_, kNumFrames));
   EXPECT_CALL(*inputs[0], AfterWriteFrames(_));
   EXPECT_CALL(*inputs[1], GetResampledData(_, _)).Times(0);
+  EXPECT_CALL(*inputs[1], OnSkipped());
   EXPECT_CALL(*inputs[1], AfterWriteFrames(_));
 
   EXPECT_CALL(*mock_alsa(), PcmWritei(_, _, kNumFrames)).Times(1);
   mixer->WriteFramesForTest();
 }
 
 TEST_F(StreamMixerAlsaTest, StuckStreamWithLowBuffer) {
   // Create a group of input streams.
   std::vector<testing::StrictMock<MockInputQueue>*> inputs;
   const int kNumInputs = 2;
@@ skipping 14 matching lines @@
 
   // Poll the inputs for data. The first input will provide data (since the
   // output is in an low buffer condition); the second input can't provide any
   // data, but AfterWriteFrames() will still be called on it so that it has the
   // correct rendering delay.
   const int kNumFrames = 32;
   inputs[0]->SetData(GetTestData(0));
   EXPECT_CALL(*inputs[0], GetResampledData(_, kNumFrames));
   EXPECT_CALL(*inputs[0], AfterWriteFrames(_));
   EXPECT_CALL(*inputs[1], GetResampledData(_, _)).Times(0);
+  EXPECT_CALL(*inputs[1], OnSkipped());
   EXPECT_CALL(*inputs[1], AfterWriteFrames(_));
 
   EXPECT_CALL(*mock_alsa(), PcmWritei(_, _, kNumFrames)).Times(1);
   mixer->WriteFramesForTest();
 }
 
 }  // namespace media
 }  // namespace chromecast