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 643 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
854 MockDemuxerStreamVector streams; | 851 MockDemuxerStreamVector streams; |
855 streams.push_back(audio_stream()); | 852 streams.push_back(audio_stream()); |
856 streams.push_back(video_stream()); | 853 streams.push_back(video_stream()); |
857 SetDemuxerExpectations(&streams, base::TimeDelta::FromSeconds(3000)); | 854 SetDemuxerExpectations(&streams, base::TimeDelta::FromSeconds(3000)); |
858 | 855 |
859 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(true)); | 856 EXPECT_CALL(*renderer_, HasAudio()).WillRepeatedly(Return(true)); |
860 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(true)); | 857 EXPECT_CALL(*renderer_, HasVideo()).WillRepeatedly(Return(true)); |
861 | 858 |
862 if (state == kInitRenderer) { | 859 if (state == kInitRenderer) { |
863 if (stop_or_error == kStop) { | 860 if (stop_or_error == kStop) { |
864 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 861 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
865 .WillOnce(DoAll(Stop(pipeline_.get(), stop_cb), | 862 .WillOnce(DoAll(Stop(pipeline_.get(), stop_cb), |
866 PostCallback<1>(PIPELINE_OK))); | 863 PostCallback<1>(PIPELINE_OK))); |
867 ExpectPipelineStopAndDestroyPipeline(); | 864 ExpectPipelineStopAndDestroyPipeline(); |
868 } else { | 865 } else { |
869 status = PIPELINE_ERROR_INITIALIZATION_FAILED; | 866 status = PIPELINE_ERROR_INITIALIZATION_FAILED; |
870 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 867 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
871 .WillOnce(PostCallback<1>(status)); | 868 .WillOnce(PostCallback<1>(status)); |
872 } | 869 } |
873 | 870 |
874 EXPECT_CALL(*demuxer_, Stop()); | 871 EXPECT_CALL(*demuxer_, Stop()); |
875 EXPECT_CALL(callbacks_, OnMetadata(_)); | 872 EXPECT_CALL(callbacks_, OnMetadata(_)); |
876 return status; | 873 return status; |
877 } | 874 } |
878 | 875 |
879 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _, _)) | 876 EXPECT_CALL(*renderer_, Initialize(_, _, _, _, _, _, _)) |
880 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), | 877 .WillOnce(DoAll(SaveArg<3>(&buffering_state_cb_), |
881 PostCallback<1>(PIPELINE_OK))); | 878 PostCallback<1>(PIPELINE_OK))); |
882 | 879 |
883 EXPECT_CALL(callbacks_, OnMetadata(_)); | 880 EXPECT_CALL(callbacks_, OnMetadata(_)); |
884 | 881 |
885 // If we get here it's a successful initialization. | 882 // If we get here it's a successful initialization. |
886 EXPECT_CALL(*renderer_, SetPlaybackRate(0.0f)); | 883 EXPECT_CALL(*renderer_, SetPlaybackRate(0.0f)); |
887 EXPECT_CALL(*renderer_, SetVolume(1.0f)); | 884 EXPECT_CALL(*renderer_, SetVolume(1.0f)); |
888 EXPECT_CALL(*renderer_, StartPlayingFrom(base::TimeDelta())) | 885 EXPECT_CALL(*renderer_, StartPlayingFrom(base::TimeDelta())) |
889 .WillOnce(SetBufferingState(&buffering_state_cb_, | 886 .WillOnce(SetBufferingState(&buffering_state_cb_, |
(...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1008 | 1005 |
1009 INSTANTIATE_TEARDOWN_TEST(Error, InitDemuxer); | 1006 INSTANTIATE_TEARDOWN_TEST(Error, InitDemuxer); |
1010 INSTANTIATE_TEARDOWN_TEST(Error, InitRenderer); | 1007 INSTANTIATE_TEARDOWN_TEST(Error, InitRenderer); |
1011 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); | 1008 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); |
1012 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); | 1009 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); |
1013 INSTANTIATE_TEARDOWN_TEST(Error, Playing); | 1010 INSTANTIATE_TEARDOWN_TEST(Error, Playing); |
1014 | 1011 |
1015 INSTANTIATE_TEARDOWN_TEST(ErrorAndStop, Playing); | 1012 INSTANTIATE_TEARDOWN_TEST(ErrorAndStop, Playing); |
1016 | 1013 |
1017 } // namespace media | 1014 } // namespace media |
OLD | NEW |