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 |