OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "media/filters/renderer_impl.h" | 5 #include "media/filters/renderer_impl.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/callback.h" | 8 #include "base/callback.h" |
9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
11 #include "base/location.h" | 11 #include "base/location.h" |
12 #include "base/single_thread_task_runner.h" | 12 #include "base/single_thread_task_runner.h" |
13 #include "media/base/audio_renderer.h" | 13 #include "media/base/audio_renderer.h" |
14 #include "media/base/demuxer.h" | 14 #include "media/base/demuxer_stream_provider.h" |
15 #include "media/base/time_source.h" | 15 #include "media/base/time_source.h" |
16 #include "media/base/video_renderer.h" | 16 #include "media/base/video_renderer.h" |
17 #include "media/base/wall_clock_time_source.h" | 17 #include "media/base/wall_clock_time_source.h" |
18 | 18 |
19 namespace media { | 19 namespace media { |
20 | 20 |
21 RendererImpl::RendererImpl( | 21 RendererImpl::RendererImpl( |
22 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, | 22 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
23 Demuxer* demuxer, | 23 DemuxerStreamProvider* demuxer_stream_provider, |
24 scoped_ptr<AudioRenderer> audio_renderer, | 24 scoped_ptr<AudioRenderer> audio_renderer, |
25 scoped_ptr<VideoRenderer> video_renderer) | 25 scoped_ptr<VideoRenderer> video_renderer) |
26 : state_(STATE_UNINITIALIZED), | 26 : state_(STATE_UNINITIALIZED), |
27 task_runner_(task_runner), | 27 task_runner_(task_runner), |
28 demuxer_(demuxer), | 28 demuxer_stream_provider_(demuxer_stream_provider), |
29 audio_renderer_(audio_renderer.Pass()), | 29 audio_renderer_(audio_renderer.Pass()), |
30 video_renderer_(video_renderer.Pass()), | 30 video_renderer_(video_renderer.Pass()), |
31 time_source_(NULL), | 31 time_source_(NULL), |
32 time_ticking_(false), | 32 time_ticking_(false), |
33 audio_buffering_state_(BUFFERING_HAVE_NOTHING), | 33 audio_buffering_state_(BUFFERING_HAVE_NOTHING), |
34 video_buffering_state_(BUFFERING_HAVE_NOTHING), | 34 video_buffering_state_(BUFFERING_HAVE_NOTHING), |
35 audio_ended_(false), | 35 audio_ended_(false), |
36 video_ended_(false), | 36 video_ended_(false), |
37 underflow_disabled_for_testing_(false), | 37 underflow_disabled_for_testing_(false), |
38 clockless_video_playback_enabled_for_testing_(false), | 38 clockless_video_playback_enabled_for_testing_(false), |
(...skipping 20 matching lines...) Expand all Loading... |
59 const PipelineStatusCB& error_cb, | 59 const PipelineStatusCB& error_cb, |
60 const BufferingStateCB& buffering_state_cb) { | 60 const BufferingStateCB& buffering_state_cb) { |
61 DVLOG(1) << __FUNCTION__; | 61 DVLOG(1) << __FUNCTION__; |
62 DCHECK(task_runner_->BelongsToCurrentThread()); | 62 DCHECK(task_runner_->BelongsToCurrentThread()); |
63 DCHECK_EQ(state_, STATE_UNINITIALIZED) << state_; | 63 DCHECK_EQ(state_, STATE_UNINITIALIZED) << state_; |
64 DCHECK(!init_cb.is_null()); | 64 DCHECK(!init_cb.is_null()); |
65 DCHECK(!statistics_cb.is_null()); | 65 DCHECK(!statistics_cb.is_null()); |
66 DCHECK(!ended_cb.is_null()); | 66 DCHECK(!ended_cb.is_null()); |
67 DCHECK(!error_cb.is_null()); | 67 DCHECK(!error_cb.is_null()); |
68 DCHECK(!buffering_state_cb.is_null()); | 68 DCHECK(!buffering_state_cb.is_null()); |
69 DCHECK(demuxer_->GetStream(DemuxerStream::AUDIO) || | 69 DCHECK(demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO) || |
70 demuxer_->GetStream(DemuxerStream::VIDEO)); | 70 demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO)); |
71 | 71 |
72 statistics_cb_ = statistics_cb; | 72 statistics_cb_ = statistics_cb; |
73 ended_cb_ = ended_cb; | 73 ended_cb_ = ended_cb; |
74 error_cb_ = error_cb; | 74 error_cb_ = error_cb; |
75 buffering_state_cb_ = buffering_state_cb; | 75 buffering_state_cb_ = buffering_state_cb; |
76 | 76 |
77 init_cb_ = init_cb; | 77 init_cb_ = init_cb; |
78 state_ = STATE_INITIALIZING; | 78 state_ = STATE_INITIALIZING; |
79 InitializeAudioRenderer(); | 79 InitializeAudioRenderer(); |
80 } | 80 } |
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
182 | 182 |
183 void RendererImpl::InitializeAudioRenderer() { | 183 void RendererImpl::InitializeAudioRenderer() { |
184 DVLOG(1) << __FUNCTION__; | 184 DVLOG(1) << __FUNCTION__; |
185 DCHECK(task_runner_->BelongsToCurrentThread()); | 185 DCHECK(task_runner_->BelongsToCurrentThread()); |
186 DCHECK_EQ(state_, STATE_INITIALIZING) << state_; | 186 DCHECK_EQ(state_, STATE_INITIALIZING) << state_; |
187 DCHECK(!init_cb_.is_null()); | 187 DCHECK(!init_cb_.is_null()); |
188 | 188 |
189 PipelineStatusCB done_cb = | 189 PipelineStatusCB done_cb = |
190 base::Bind(&RendererImpl::OnAudioRendererInitializeDone, weak_this_); | 190 base::Bind(&RendererImpl::OnAudioRendererInitializeDone, weak_this_); |
191 | 191 |
192 if (!demuxer_->GetStream(DemuxerStream::AUDIO)) { | 192 if (!demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO)) { |
193 audio_renderer_.reset(); | 193 audio_renderer_.reset(); |
194 task_runner_->PostTask(FROM_HERE, base::Bind(done_cb, PIPELINE_OK)); | 194 task_runner_->PostTask(FROM_HERE, base::Bind(done_cb, PIPELINE_OK)); |
195 return; | 195 return; |
196 } | 196 } |
197 | 197 |
198 audio_renderer_->Initialize( | 198 audio_renderer_->Initialize( |
199 demuxer_->GetStream(DemuxerStream::AUDIO), | 199 demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO), |
200 done_cb, | 200 done_cb, |
201 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), | 201 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), |
202 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, | 202 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, |
203 &audio_buffering_state_), | 203 &audio_buffering_state_), |
204 base::Bind(&RendererImpl::OnAudioRendererEnded, weak_this_), | 204 base::Bind(&RendererImpl::OnAudioRendererEnded, weak_this_), |
205 base::Bind(&RendererImpl::OnError, weak_this_)); | 205 base::Bind(&RendererImpl::OnError, weak_this_)); |
206 } | 206 } |
207 | 207 |
208 void RendererImpl::OnAudioRendererInitializeDone(PipelineStatus status) { | 208 void RendererImpl::OnAudioRendererInitializeDone(PipelineStatus status) { |
209 DVLOG(1) << __FUNCTION__ << ": " << status; | 209 DVLOG(1) << __FUNCTION__ << ": " << status; |
(...skipping 12 matching lines...) Expand all Loading... |
222 | 222 |
223 void RendererImpl::InitializeVideoRenderer() { | 223 void RendererImpl::InitializeVideoRenderer() { |
224 DVLOG(1) << __FUNCTION__; | 224 DVLOG(1) << __FUNCTION__; |
225 DCHECK(task_runner_->BelongsToCurrentThread()); | 225 DCHECK(task_runner_->BelongsToCurrentThread()); |
226 DCHECK_EQ(state_, STATE_INITIALIZING) << state_; | 226 DCHECK_EQ(state_, STATE_INITIALIZING) << state_; |
227 DCHECK(!init_cb_.is_null()); | 227 DCHECK(!init_cb_.is_null()); |
228 | 228 |
229 PipelineStatusCB done_cb = | 229 PipelineStatusCB done_cb = |
230 base::Bind(&RendererImpl::OnVideoRendererInitializeDone, weak_this_); | 230 base::Bind(&RendererImpl::OnVideoRendererInitializeDone, weak_this_); |
231 | 231 |
232 if (!demuxer_->GetStream(DemuxerStream::VIDEO)) { | 232 if (!demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO)) { |
233 video_renderer_.reset(); | 233 video_renderer_.reset(); |
234 task_runner_->PostTask(FROM_HERE, base::Bind(done_cb, PIPELINE_OK)); | 234 task_runner_->PostTask(FROM_HERE, base::Bind(done_cb, PIPELINE_OK)); |
235 return; | 235 return; |
236 } | 236 } |
237 | 237 |
238 video_renderer_->Initialize( | 238 video_renderer_->Initialize( |
239 demuxer_->GetStream(DemuxerStream::VIDEO), | 239 demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO), |
240 demuxer_->GetLiveness() == Demuxer::LIVENESS_LIVE, | 240 demuxer_stream_provider_->GetLiveness() == |
| 241 DemuxerStreamProvider::LIVENESS_LIVE, |
241 done_cb, | 242 done_cb, |
242 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), | 243 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), |
243 base::Bind(&RendererImpl::OnBufferingStateChanged, | 244 base::Bind(&RendererImpl::OnBufferingStateChanged, |
244 weak_this_, | 245 weak_this_, |
245 &video_buffering_state_), | 246 &video_buffering_state_), |
246 base::Bind(&RendererImpl::OnVideoRendererEnded, weak_this_), | 247 base::Bind(&RendererImpl::OnVideoRendererEnded, weak_this_), |
247 base::Bind(&RendererImpl::OnError, weak_this_), | 248 base::Bind(&RendererImpl::OnError, weak_this_), |
248 base::Bind(&RendererImpl::GetMediaTimeForSyncingVideo, | 249 base::Bind(&RendererImpl::GetMediaTimeForSyncingVideo, |
249 base::Unretained(this))); | 250 base::Unretained(this))); |
250 } | 251 } |
(...skipping 244 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
495 DCHECK(task_runner_->BelongsToCurrentThread()); | 496 DCHECK(task_runner_->BelongsToCurrentThread()); |
496 | 497 |
497 if (!init_cb_.is_null()) | 498 if (!init_cb_.is_null()) |
498 base::ResetAndReturn(&init_cb_).Run(); | 499 base::ResetAndReturn(&init_cb_).Run(); |
499 | 500 |
500 if (!flush_cb_.is_null()) | 501 if (!flush_cb_.is_null()) |
501 base::ResetAndReturn(&flush_cb_).Run(); | 502 base::ResetAndReturn(&flush_cb_).Run(); |
502 } | 503 } |
503 | 504 |
504 } // namespace media | 505 } // namespace media |
OLD | NEW |