Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(84)

Side by Side Diff: media/base/pipeline_unittest.cc

Issue 14217008: Remove reference counting from media::DemuxerStream and friends. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698