| 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.h" | 8 #include "base/message_loop.h" |
| 9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
| 10 #include "base/test/simple_test_clock.h" | 10 #include "base/test/simple_test_clock.h" |
| (...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 135 typedef std::vector<MockDemuxerStream*> MockDemuxerStreamVector; | 135 typedef std::vector<MockDemuxerStream*> MockDemuxerStreamVector; |
| 136 void InitializeDemuxer(MockDemuxerStreamVector* streams, | 136 void InitializeDemuxer(MockDemuxerStreamVector* streams, |
| 137 const base::TimeDelta& duration) { | 137 const base::TimeDelta& duration) { |
| 138 EXPECT_CALL(callbacks_, OnDurationChange()); | 138 EXPECT_CALL(callbacks_, OnDurationChange()); |
| 139 EXPECT_CALL(*demuxer_, Initialize(_, _)) | 139 EXPECT_CALL(*demuxer_, Initialize(_, _)) |
| 140 .WillOnce(DoAll(SetDemuxerProperties(duration), | 140 .WillOnce(DoAll(SetDemuxerProperties(duration), |
| 141 RunCallback<1>(PIPELINE_OK))); | 141 RunCallback<1>(PIPELINE_OK))); |
| 142 | 142 |
| 143 // Configure the demuxer to return the streams. | 143 // Configure the demuxer to return the streams. |
| 144 for (size_t i = 0; i < streams->size(); ++i) { | 144 for (size_t i = 0; i < streams->size(); ++i) { |
| 145 scoped_refptr<DemuxerStream> stream((*streams)[i]); | 145 DemuxerStream* stream = (*streams)[i]; |
| 146 EXPECT_CALL(*demuxer_, GetStream(stream->type())) | 146 EXPECT_CALL(*demuxer_, GetStream(stream->type())) |
| 147 .WillRepeatedly(Return(stream)); | 147 .WillRepeatedly(Return(stream)); |
| 148 } | 148 } |
| 149 } | 149 } |
| 150 | 150 |
| 151 void InitializeDemuxer(MockDemuxerStreamVector* streams) { | 151 void InitializeDemuxer(MockDemuxerStreamVector* streams) { |
| 152 // Initialize with a default non-zero duration. | 152 // Initialize with a default non-zero duration. |
| 153 InitializeDemuxer(streams, base::TimeDelta::FromSeconds(10)); | 153 InitializeDemuxer(streams, base::TimeDelta::FromSeconds(10)); |
| 154 } | 154 } |
| 155 | 155 |
| 156 StrictMock<MockDemuxerStream>* CreateStream(DemuxerStream::Type type) { | 156 scoped_ptr<StrictMock<MockDemuxerStream> > CreateStream( |
| 157 StrictMock<MockDemuxerStream>* stream = | 157 DemuxerStream::Type type) { |
| 158 new StrictMock<MockDemuxerStream>(); | 158 scoped_ptr<StrictMock<MockDemuxerStream> > stream( |
| 159 new StrictMock<MockDemuxerStream>()); |
| 159 EXPECT_CALL(*stream, type()) | 160 EXPECT_CALL(*stream, type()) |
| 160 .WillRepeatedly(Return(type)); | 161 .WillRepeatedly(Return(type)); |
| 161 return stream; | 162 return stream.Pass(); |
| 162 } | 163 } |
| 163 | 164 |
| 164 // Sets up expectations to allow the video renderer to initialize. | 165 // Sets up expectations to allow the video renderer to initialize. |
| 165 void InitializeVideoRenderer(const scoped_refptr<DemuxerStream>& stream) { | 166 void InitializeVideoRenderer(DemuxerStream* stream) { |
| 166 EXPECT_CALL(*video_renderer_, Initialize(stream, _, _, _, _, _, _, _, _)) | 167 EXPECT_CALL(*video_renderer_, Initialize(stream, _, _, _, _, _, _, _, _)) |
| 167 .WillOnce(RunCallback<1>(PIPELINE_OK)); | 168 .WillOnce(RunCallback<1>(PIPELINE_OK)); |
| 168 EXPECT_CALL(*video_renderer_, SetPlaybackRate(0.0f)); | 169 EXPECT_CALL(*video_renderer_, SetPlaybackRate(0.0f)); |
| 169 | 170 |
| 170 // Startup sequence. | 171 // Startup sequence. |
| 171 EXPECT_CALL(*video_renderer_, Preroll(demuxer_->GetStartTime(), _)) | 172 EXPECT_CALL(*video_renderer_, Preroll(demuxer_->GetStartTime(), _)) |
| 172 .WillOnce(RunCallback<1>(PIPELINE_OK)); | 173 .WillOnce(RunCallback<1>(PIPELINE_OK)); |
| 173 EXPECT_CALL(*video_renderer_, Play(_)) | 174 EXPECT_CALL(*video_renderer_, Play(_)) |
| 174 .WillOnce(RunClosure<0>()); | 175 .WillOnce(RunClosure<0>()); |
| 175 } | 176 } |
| 176 | 177 |
| 177 // Sets up expectations to allow the audio renderer to initialize. | 178 // Sets up expectations to allow the audio renderer to initialize. |
| 178 void InitializeAudioRenderer(const scoped_refptr<DemuxerStream>& stream, | 179 void InitializeAudioRenderer(DemuxerStream* stream, |
| 179 bool disable_after_init_cb) { | 180 bool disable_after_init_cb) { |
| 180 if (disable_after_init_cb) { | 181 if (disable_after_init_cb) { |
| 181 EXPECT_CALL(*audio_renderer_, Initialize(stream, _, _, _, _, _, _, _)) | 182 EXPECT_CALL(*audio_renderer_, Initialize(stream, _, _, _, _, _, _, _)) |
| 182 .WillOnce(DoAll(RunCallback<1>(PIPELINE_OK), | 183 .WillOnce(DoAll(RunCallback<1>(PIPELINE_OK), |
| 183 WithArg<6>(RunClosure<0>()))); // |disabled_cb|. | 184 WithArg<6>(RunClosure<0>()))); // |disabled_cb|. |
| 184 } else { | 185 } else { |
| 185 EXPECT_CALL(*audio_renderer_, Initialize(stream, _, _, _, _, _, _, _)) | 186 EXPECT_CALL(*audio_renderer_, Initialize(stream, _, _, _, _, _, _, _)) |
| 186 .WillOnce(DoAll(SaveArg<4>(&audio_time_cb_), | 187 .WillOnce(DoAll(SaveArg<4>(&audio_time_cb_), |
| 187 RunCallback<1>(PIPELINE_OK))); | 188 RunCallback<1>(PIPELINE_OK))); |
| 188 } | 189 } |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 226 audio_stream_ = CreateStream(DemuxerStream::AUDIO); | 227 audio_stream_ = CreateStream(DemuxerStream::AUDIO); |
| 227 } | 228 } |
| 228 | 229 |
| 229 void CreateVideoStream() { | 230 void CreateVideoStream() { |
| 230 video_stream_ = CreateStream(DemuxerStream::VIDEO); | 231 video_stream_ = CreateStream(DemuxerStream::VIDEO); |
| 231 EXPECT_CALL(*video_stream_, video_decoder_config()) | 232 EXPECT_CALL(*video_stream_, video_decoder_config()) |
| 232 .WillRepeatedly(ReturnRef(video_decoder_config_)); | 233 .WillRepeatedly(ReturnRef(video_decoder_config_)); |
| 233 } | 234 } |
| 234 | 235 |
| 235 MockDemuxerStream* audio_stream() { | 236 MockDemuxerStream* audio_stream() { |
| 236 return audio_stream_; | 237 return audio_stream_.get(); |
| 237 } | 238 } |
| 238 | 239 |
| 239 MockDemuxerStream* video_stream() { | 240 MockDemuxerStream* video_stream() { |
| 240 return video_stream_; | 241 return video_stream_.get(); |
| 241 } | 242 } |
| 242 | 243 |
| 243 void ExpectSeek(const base::TimeDelta& seek_time) { | 244 void ExpectSeek(const base::TimeDelta& seek_time) { |
| 244 // Every filter should receive a call to Seek(). | 245 // Every filter should receive a call to Seek(). |
| 245 EXPECT_CALL(*demuxer_, Seek(seek_time, _)) | 246 EXPECT_CALL(*demuxer_, Seek(seek_time, _)) |
| 246 .WillOnce(RunCallback<1>(PIPELINE_OK)); | 247 .WillOnce(RunCallback<1>(PIPELINE_OK)); |
| 247 EXPECT_CALL(*demuxer_, SetPlaybackRate(_)); | 248 EXPECT_CALL(*demuxer_, SetPlaybackRate(_)); |
| 248 | 249 |
| 249 if (audio_stream_) { | 250 if (audio_stream_) { |
| 250 EXPECT_CALL(*audio_renderer_, Pause(_)) | 251 EXPECT_CALL(*audio_renderer_, Pause(_)) |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 291 // Fixture members. | 292 // Fixture members. |
| 292 StrictMock<CallbackHelper> callbacks_; | 293 StrictMock<CallbackHelper> callbacks_; |
| 293 base::SimpleTestClock test_clock_; | 294 base::SimpleTestClock test_clock_; |
| 294 MessageLoop message_loop_; | 295 MessageLoop message_loop_; |
| 295 scoped_refptr<Pipeline> pipeline_; | 296 scoped_refptr<Pipeline> pipeline_; |
| 296 | 297 |
| 297 scoped_ptr<FilterCollection> filter_collection_; | 298 scoped_ptr<FilterCollection> filter_collection_; |
| 298 scoped_ptr<MockDemuxer> demuxer_; | 299 scoped_ptr<MockDemuxer> demuxer_; |
| 299 MockVideoRenderer* video_renderer_; | 300 MockVideoRenderer* video_renderer_; |
| 300 MockAudioRenderer* audio_renderer_; | 301 MockAudioRenderer* audio_renderer_; |
| 301 scoped_refptr<StrictMock<MockDemuxerStream> > audio_stream_; | 302 scoped_ptr<StrictMock<MockDemuxerStream> > audio_stream_; |
| 302 scoped_refptr<StrictMock<MockDemuxerStream> > video_stream_; | 303 scoped_ptr<StrictMock<MockDemuxerStream> > video_stream_; |
| 303 AudioRenderer::TimeCB audio_time_cb_; | 304 AudioRenderer::TimeCB audio_time_cb_; |
| 304 VideoDecoderConfig video_decoder_config_; | 305 VideoDecoderConfig video_decoder_config_; |
| 305 | 306 |
| 306 private: | 307 private: |
| 307 DISALLOW_COPY_AND_ASSIGN(PipelineTest); | 308 DISALLOW_COPY_AND_ASSIGN(PipelineTest); |
| 308 }; | 309 }; |
| 309 | 310 |
| 310 // Test that playback controls methods no-op when the pipeline hasn't been | 311 // Test that playback controls methods no-op when the pipeline hasn't been |
| 311 // started. | 312 // started. |
| 312 TEST_F(PipelineTest, NotStarted) { | 313 TEST_F(PipelineTest, NotStarted) { |
| (...skipping 895 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1208 INSTANTIATE_TEARDOWN_TEST(Error, InitAudioRenderer); | 1209 INSTANTIATE_TEARDOWN_TEST(Error, InitAudioRenderer); |
| 1209 INSTANTIATE_TEARDOWN_TEST(Error, InitVideoRenderer); | 1210 INSTANTIATE_TEARDOWN_TEST(Error, InitVideoRenderer); |
| 1210 INSTANTIATE_TEARDOWN_TEST(Error, Pausing); | 1211 INSTANTIATE_TEARDOWN_TEST(Error, Pausing); |
| 1211 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); | 1212 INSTANTIATE_TEARDOWN_TEST(Error, Flushing); |
| 1212 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); | 1213 INSTANTIATE_TEARDOWN_TEST(Error, Seeking); |
| 1213 INSTANTIATE_TEARDOWN_TEST(Error, Prerolling); | 1214 INSTANTIATE_TEARDOWN_TEST(Error, Prerolling); |
| 1214 INSTANTIATE_TEARDOWN_TEST(Error, Starting); | 1215 INSTANTIATE_TEARDOWN_TEST(Error, Starting); |
| 1215 INSTANTIATE_TEARDOWN_TEST(Error, Playing); | 1216 INSTANTIATE_TEARDOWN_TEST(Error, Playing); |
| 1216 | 1217 |
| 1217 } // namespace media | 1218 } // namespace media |
| OLD | NEW |