Fixed ended event when playing audio on linux.

media/audio/linux/alsa_output_unittest.cc

 // Copyright (c) 2010 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 "base/logging.h"
 #include "base/message_loop.h"
 #include "base/string_util.h"
 #include "media/audio/linux/alsa_output.h"
 #include "media/audio/linux/alsa_wrapper.h"
 #include "media/audio/linux/audio_manager_linux.h"
@@ skipping 414 matching lines @@
   message_loop_.RunAllPending();
 
   // Expect Device setup.
   EXPECT_CALL(mock_alsa_wrapper_, PcmDrop(kFakeHandle))
       .WillOnce(Return(0));
   EXPECT_CALL(mock_alsa_wrapper_, PcmPrepare(kFakeHandle))
       .WillOnce(Return(0));
 
   // Expect the pre-roll.
   MockAudioSourceCallback mock_callback;
-  EXPECT_CALL(mock_alsa_wrapper_, PcmState(kFakeHandle))
-      .Times(2)
-      .WillRepeatedly(Return(SND_PCM_STATE_RUNNING));
-  EXPECT_CALL(mock_alsa_wrapper_, PcmDelay(kFakeHandle, _))
-      .Times(2)
-      .WillRepeatedly(DoAll(SetArgumentPointee<1>(0), Return(0)));
   EXPECT_CALL(mock_callback,
               OnMoreData(test_stream_.get(), _, kTestPacketSize, 0))
       .Times(2)
       .WillOnce(Return(kTestPacketSize))
       .WillOnce(Return(0));
   EXPECT_CALL(mock_alsa_wrapper_, PcmWritei(kFakeHandle, _, _))
        .WillOnce(Return(kTestFramesPerPacket));
 
   // Expect scheduling.
   EXPECT_CALL(mock_alsa_wrapper_, PcmAvailUpdate(kFakeHandle))
@@ skipping 86 matching lines @@
   test_stream_->WritePacket();
   EXPECT_EQ(0u, test_stream_->buffer_->forward_bytes());
 }
 
 TEST_F(AlsaPcmOutputStreamTest, BufferPacket) {
   InitBuffer();
   test_stream_->buffer_->Clear();
 
   // Return a partially filled packet.
   MockAudioSourceCallback mock_callback;
-  EXPECT_CALL(mock_alsa_wrapper_, PcmState(_))
-      .WillOnce(Return(SND_PCM_STATE_RUNNING));
-  EXPECT_CALL(mock_alsa_wrapper_, PcmDelay(_, _))
-      .WillOnce(DoAll(SetArgumentPointee<1>(1), Return(0)));
   EXPECT_CALL(mock_callback,
-              OnMoreData(test_stream_.get(), _, _, kTestBytesPerFrame))
+              OnMoreData(test_stream_.get(), _, _, 0))
       .WillOnce(Return(10));
 
   bool source_exhausted;
   test_stream_->shared_data_.set_source_callback(&mock_callback);
   test_stream_->packet_size_ = kTestPacketSize;
   test_stream_->BufferPacket(&source_exhausted);
 
   EXPECT_EQ(10u, test_stream_->buffer_->forward_bytes());
   EXPECT_FALSE(source_exhausted);
 }
 
 TEST_F(AlsaPcmOutputStreamTest, BufferPacket_Negative) {
   InitBuffer();
   test_stream_->buffer_->Clear();
 
   // Simulate where the underrun has occurred right after checking the delay.
   MockAudioSourceCallback mock_callback;
-  EXPECT_CALL(mock_alsa_wrapper_, PcmState(_))
-      .WillOnce(Return(SND_PCM_STATE_RUNNING));
-  EXPECT_CALL(mock_alsa_wrapper_, PcmDelay(_, _))
-      .WillOnce(DoAll(SetArgumentPointee<1>(-1), Return(0)));
   EXPECT_CALL(mock_callback,
               OnMoreData(test_stream_.get(), _, _, 0))
       .WillOnce(Return(10));
 
   bool source_exhausted;
   test_stream_->shared_data_.set_source_callback(&mock_callback);
   test_stream_->packet_size_ = kTestPacketSize;
   test_stream_->BufferPacket(&source_exhausted);
 
   EXPECT_EQ(10u, test_stream_->buffer_->forward_bytes());
   EXPECT_FALSE(source_exhausted);
 }
 
 TEST_F(AlsaPcmOutputStreamTest, BufferPacket_Underrun) {
   InitBuffer();
   test_stream_->buffer_->Clear();
 
   // If ALSA has underrun then we should assume a delay of zero.
   MockAudioSourceCallback mock_callback;
-  EXPECT_CALL(mock_alsa_wrapper_, PcmState(_))
-      .WillOnce(Return(SND_PCM_STATE_XRUN));
   EXPECT_CALL(mock_callback,
               OnMoreData(test_stream_.get(), _, _, 0))
       .WillOnce(Return(10));
 
   bool source_exhausted;
   test_stream_->shared_data_.set_source_callback(&mock_callback);
   test_stream_->packet_size_ = kTestPacketSize;
   test_stream_->BufferPacket(&source_exhausted);
 
   EXPECT_EQ(10u, test_stream_->buffer_->forward_bytes());
@@ skipping 170 matching lines @@
 
   test_stream_->stop_stream_ = true;
   test_stream_->ScheduleNextWrite(true);
 
   // TODO(ajwong): Find a way to test whether or not another task has been
   // posted so we can verify that the Alsa code will indeed break the task
   // posting loop.
 
   test_stream_->shared_data_.TransitionTo(AlsaPcmOutputStream::kIsClosed);
 }