| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <vector> | 5 #include <vector> |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "base/test/simple_test_tick_clock.h" | 10 #include "base/test/simple_test_tick_clock.h" |
| (...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 77 CallbackHelper() {} | 77 CallbackHelper() {} |
| 78 virtual ~CallbackHelper() {} | 78 virtual ~CallbackHelper() {} |
| 79 | 79 |
| 80 MOCK_METHOD1(OnStart, void(PipelineStatus)); | 80 MOCK_METHOD1(OnStart, void(PipelineStatus)); |
| 81 MOCK_METHOD1(OnSeek, void(PipelineStatus)); | 81 MOCK_METHOD1(OnSeek, void(PipelineStatus)); |
| 82 MOCK_METHOD0(OnStop, void()); | 82 MOCK_METHOD0(OnStop, void()); |
| 83 MOCK_METHOD0(OnEnded, void()); | 83 MOCK_METHOD0(OnEnded, void()); |
| 84 MOCK_METHOD1(OnError, void(PipelineStatus)); | 84 MOCK_METHOD1(OnError, void(PipelineStatus)); |
| 85 MOCK_METHOD1(OnMetadata, void(PipelineMetadata)); | 85 MOCK_METHOD1(OnMetadata, void(PipelineMetadata)); |
| 86 MOCK_METHOD1(OnBufferingStateChange, void(BufferingState)); | 86 MOCK_METHOD1(OnBufferingStateChange, void(BufferingState)); |
| 87 MOCK_METHOD1(OnVideoFramePaint, void(const scoped_refptr<VideoFrame>&)); | |
| 88 MOCK_METHOD0(OnDurationChange, void()); | 87 MOCK_METHOD0(OnDurationChange, void()); |
| 89 | 88 |
| 90 private: | 89 private: |
| 91 DISALLOW_COPY_AND_ASSIGN(CallbackHelper); | 90 DISALLOW_COPY_AND_ASSIGN(CallbackHelper); |
| 92 }; | 91 }; |
| 93 | 92 |
| 94 PipelineTest() | 93 PipelineTest() |
| 95 : pipeline_(new Pipeline(message_loop_.message_loop_proxy(), | 94 : pipeline_(new Pipeline(message_loop_.message_loop_proxy(), |
| 96 new MediaLog())), | 95 new MediaLog())), |
| 97 demuxer_(new StrictMock<MockDemuxer>()), | 96 demuxer_(new StrictMock<MockDemuxer>()), |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 163 | 162 |
| 164 scoped_ptr<StrictMock<MockDemuxerStream> > CreateStream( | 163 scoped_ptr<StrictMock<MockDemuxerStream> > CreateStream( |
| 165 DemuxerStream::Type type) { | 164 DemuxerStream::Type type) { |
| 166 scoped_ptr<StrictMock<MockDemuxerStream> > stream( | 165 scoped_ptr<StrictMock<MockDemuxerStream> > stream( |
| 167 new StrictMock<MockDemuxerStream>(type)); | 166 new StrictMock<MockDemuxerStream>(type)); |
| 168 return stream.Pass(); | 167 return stream.Pass(); |
| 169 } | 168 } |
| 170 | 169 |
| 171 // Sets up expectations to allow the video renderer to initialize. | 170 // Sets up expectations to allow the video renderer to initialize. |
| 172 void SetRendererExpectations() { | 171 void SetRendererExpectations() { |
| 173 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 172 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
| 174 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), | 173 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), |
| 175 SaveArg<5>(&ended_cb_), | 174 SaveArg<4>(&ended_cb_), |
| 176 PostCallback<1>(PIPELINE_OK))); | 175 PostCallback<1>(PIPELINE_OK))); |
| 177 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(audio_stream())); | 176 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(audio_stream())); |
| 178 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(video_stream())); | 177 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(video_stream())); |
| 179 } | 178 } |
| 180 | 179 |
| 181 void AddTextStream() { | 180 void AddTextStream() { |
| 182 EXPECT_CALL(*this, OnAddTextTrack(_,_)) | 181 EXPECT_CALL(*this, OnAddTextTrack(_,_)) |
| 183 .WillOnce(Invoke(this, &PipelineTest::DoOnAddTextTrack)); | 182 .WillOnce(Invoke(this, &PipelineTest::DoOnAddTextTrack)); |
| 184 static_cast<DemuxerHost*>(pipeline_.get())->AddTextStream(text_stream(), | 183 static_cast<DemuxerHost*>(pipeline_.get())->AddTextStream(text_stream(), |
| 185 TextTrackConfig(kTextSubtitles, "", "", "")); | 184 TextTrackConfig(kTextSubtitles, "", "", "")); |
| 186 message_loop_.RunUntilIdle(); | 185 message_loop_.RunUntilIdle(); |
| 187 } | 186 } |
| 188 | 187 |
| 189 void StartPipeline() { | 188 void StartPipeline() { |
| 190 EXPECT_CALL(*this, OnWaitingForDecryptionKey()).Times(0); | 189 EXPECT_CALL(*this, OnWaitingForDecryptionKey()).Times(0); |
| 191 pipeline_->Start( | 190 pipeline_->Start( |
| 192 demuxer_.get(), scoped_renderer_.Pass(), | 191 demuxer_.get(), scoped_renderer_.Pass(), |
| 193 base::Bind(&CallbackHelper::OnEnded, base::Unretained(&callbacks_)), | 192 base::Bind(&CallbackHelper::OnEnded, base::Unretained(&callbacks_)), |
| 194 base::Bind(&CallbackHelper::OnError, base::Unretained(&callbacks_)), | 193 base::Bind(&CallbackHelper::OnError, base::Unretained(&callbacks_)), |
| 195 base::Bind(&CallbackHelper::OnStart, base::Unretained(&callbacks_)), | 194 base::Bind(&CallbackHelper::OnStart, base::Unretained(&callbacks_)), |
| 196 base::Bind(&CallbackHelper::OnMetadata, base::Unretained(&callbacks_)), | 195 base::Bind(&CallbackHelper::OnMetadata, base::Unretained(&callbacks_)), |
| 197 base::Bind(&CallbackHelper::OnBufferingStateChange, | 196 base::Bind(&CallbackHelper::OnBufferingStateChange, |
| 198 base::Unretained(&callbacks_)), | 197 base::Unretained(&callbacks_)), |
| 199 base::Bind(&CallbackHelper::OnVideoFramePaint, | |
| 200 base::Unretained(&callbacks_)), | |
| 201 base::Bind(&CallbackHelper::OnDurationChange, | 198 base::Bind(&CallbackHelper::OnDurationChange, |
| 202 base::Unretained(&callbacks_)), | 199 base::Unretained(&callbacks_)), |
| 203 base::Bind(&PipelineTest::OnAddTextTrack, base::Unretained(this)), | 200 base::Bind(&PipelineTest::OnAddTextTrack, base::Unretained(this)), |
| 204 base::Bind(&PipelineTest::OnWaitingForDecryptionKey, | 201 base::Bind(&PipelineTest::OnWaitingForDecryptionKey, |
| 205 base::Unretained(this))); | 202 base::Unretained(this))); |
| 206 } | 203 } |
| 207 | 204 |
| 208 // Sets up expectations on the callback and initializes the pipeline. Called | 205 // Sets up expectations on the callback and initializes the pipeline. Called |
| 209 // after tests have set expectations any filters they wish to use. | 206 // after tests have set expectations any filters they wish to use. |
| 210 void StartPipelineAndExpect(PipelineStatus start_status) { | 207 void StartPipelineAndExpect(PipelineStatus start_status) { |
| (...skipping 640 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 851 MockDemuxerStreamVector streams; | 848 MockDemuxerStreamVector streams; |
| 852 streams.push_back(audio_stream()); | 849 streams.push_back(audio_stream()); |
| 853 streams.push_back(video_stream()); | 850 streams.push_back(video_stream()); |
| 854 SetDemuxerExpectations(&streams, base::TimeDelta::FromSeconds(3000)); | 851 SetDemuxerExpectations(&streams, base::TimeDelta::FromSeconds(3000)); |
| 855 | 852 |
| 856 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(true)); | 853 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(true)); |
| 857 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(true)); | 854 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(true)); |
| 858 | 855 |
| 859 if (state == kInitRenderer) { | 856 if (state == kInitRenderer) { |
| 860 if (stop_or_error == kStop) { | 857 if (stop_or_error == kStop) { |
| 861 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 858 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
| 862 .WillOnce(DoAll(Stop(pipeline_.get(), stop_cb), | 859 .WillOnce(DoAll(Stop(pipeline_.get(), stop_cb), |
| 863 PostCallback<1>(PIPELINE_OK))); | 860 PostCallback<1>(PIPELINE_OK))); |
| 864 ExpectPipelineStopAndDestroyPipeline(); | 861 ExpectPipelineStopAndDestroyPipeline(); |
| 865 } else { | 862 } else { |
| 866 status = PIPELINE_ERROR_INITIALIZATION_FAILED; | 863 status = PIPELINE_ERROR_INITIALIZATION_FAILED; |
| 867 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 864 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
| 868 .WillOnce(PostCallback<1>(status)); | 865 .WillOnce(PostCallback<1>(status)); |
| 869 } | 866 } |
| 870 | 867 |
| 871 EXPECT_CALL(*demuxer_, Stop()); | 868 EXPECT_CALL(*demuxer_, Stop()); |
| 872 EXPECT_CALL(callbacks_, OnMetadata(_)); | 869 EXPECT_CALL(callbacks_, OnMetadata(_)); |
| 873 return status; | 870 return status; |
| 874 } | 871 } |
| 875 | 872 |
| 876 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 873 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
| 877 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), | 874 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), |
| 878 PostCallback<1>(PIPELINE_OK))); | 875 PostCallback<1>(PIPELINE_OK))); |
| 879 | 876 |
| 880 EXPECT_CALL(callbacks_, OnMetadata(_)); | 877 EXPECT_CALL(callbacks_, OnMetadata(_)); |
| 881 | 878 |
| 882 // If we get here it's a successful initialization. | 879 // If we get here it's a successful initialization. |
| 883 EXPECT_CALL(*renderer_, SetPlaybackRate(0.0f)); | 880 EXPECT_CALL(*renderer_, SetPlaybackRate(0.0f)); |
| 884 EXPECT_CALL(*renderer_, SetVolume(1.0f)); | 881 EXPECT_CALL(*renderer_, SetVolume(1.0f)); |
| 885 EXPECT_CALL(*renderer_, StartPlayingFrom(base::TimeDelta())) | 882 EXPECT_CALL(*renderer_, StartPlayingFrom(base::TimeDelta())) |
| 886 .WillOnce(SetBufferingState(&buffering_state_cb_, | 883 .WillOnce(SetBufferingState(&buffering_state_cb_, |
| (...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1005 | 1002 |
| 1006 INSTANTIATE_TEARDOWN_TEST(Error, InitDemuxer); | 1003 INSTANTIATE_TEARDOWN_TEST(Error, InitDemuxer); |
| 1007 INSTANTIATE_TEARDOWN_TEST(Error, InitRenderer); | 1004 INSTANTIATE_TEARDOWN_TEST(Error, InitRenderer); |
| 1008 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); | 1005 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); |
| 1009 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); | 1006 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); |
| 1010 INSTANTIATE_TEARDOWN_TEST(Error, Playing); | 1007 INSTANTIATE_TEARDOWN_TEST(Error, Playing); |
| 1011 | 1008 |
| 1012 INSTANTIATE_TEARDOWN_TEST(ErrorAndStop, Playing); | 1009 INSTANTIATE_TEARDOWN_TEST(ErrorAndStop, Playing); |
| 1013 | 1010 |
| 1014 } // namespace media | 1011 } // namespace media |
| OLD | NEW |