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/renderers/renderer_impl.h" | 5 #include "media/renderers/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" |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
49 // need |time_source_| (which can be |audio_renderer_|) to be alive. | 49 // need |time_source_| (which can be |audio_renderer_|) to be alive. |
50 video_renderer_.reset(); | 50 video_renderer_.reset(); |
51 audio_renderer_.reset(); | 51 audio_renderer_.reset(); |
52 | 52 |
53 if (!init_cb_.is_null()) | 53 if (!init_cb_.is_null()) |
54 base::ResetAndReturn(&init_cb_).Run(PIPELINE_ERROR_ABORT); | 54 base::ResetAndReturn(&init_cb_).Run(PIPELINE_ERROR_ABORT); |
55 else if (!flush_cb_.is_null()) | 55 else if (!flush_cb_.is_null()) |
56 base::ResetAndReturn(&flush_cb_).Run(); | 56 base::ResetAndReturn(&flush_cb_).Run(); |
57 } | 57 } |
58 | 58 |
59 void RendererImpl::Initialize(DemuxerStreamProvider* demuxer_stream_provider, | 59 void RendererImpl::Initialize( |
60 const PipelineStatusCB& init_cb, | 60 DemuxerStreamProvider* demuxer_stream_provider, |
61 const StatisticsCB& statistics_cb, | 61 const PipelineStatusCB& init_cb, |
62 const BufferingStateCB& buffering_state_cb, | 62 const StatisticsCB& statistics_cb, |
63 const PaintCB& paint_cb, | 63 const BufferingStateCB& buffering_state_cb, |
64 const base::Closure& ended_cb, | 64 const PaintCB& paint_cb, |
65 const PipelineStatusCB& error_cb) { | 65 const base::Closure& ended_cb, |
| 66 const PipelineStatusCB& error_cb, |
| 67 const base::Closure& waiting_for_decryption_key_cb) { |
66 DVLOG(1) << __FUNCTION__; | 68 DVLOG(1) << __FUNCTION__; |
67 DCHECK(task_runner_->BelongsToCurrentThread()); | 69 DCHECK(task_runner_->BelongsToCurrentThread()); |
68 DCHECK_EQ(state_, STATE_UNINITIALIZED); | 70 DCHECK_EQ(state_, STATE_UNINITIALIZED); |
69 DCHECK(!init_cb.is_null()); | 71 DCHECK(!init_cb.is_null()); |
70 DCHECK(!statistics_cb.is_null()); | 72 DCHECK(!statistics_cb.is_null()); |
71 DCHECK(!buffering_state_cb.is_null()); | 73 DCHECK(!buffering_state_cb.is_null()); |
72 DCHECK(!paint_cb.is_null()); | 74 DCHECK(!paint_cb.is_null()); |
73 DCHECK(!ended_cb.is_null()); | 75 DCHECK(!ended_cb.is_null()); |
74 DCHECK(!error_cb.is_null()); | 76 DCHECK(!error_cb.is_null()); |
75 DCHECK(demuxer_stream_provider->GetStream(DemuxerStream::AUDIO) || | 77 DCHECK(demuxer_stream_provider->GetStream(DemuxerStream::AUDIO) || |
76 demuxer_stream_provider->GetStream(DemuxerStream::VIDEO)); | 78 demuxer_stream_provider->GetStream(DemuxerStream::VIDEO)); |
77 | 79 |
78 demuxer_stream_provider_ = demuxer_stream_provider; | 80 demuxer_stream_provider_ = demuxer_stream_provider; |
79 statistics_cb_ = statistics_cb; | 81 statistics_cb_ = statistics_cb; |
80 buffering_state_cb_ = buffering_state_cb; | 82 buffering_state_cb_ = buffering_state_cb; |
81 paint_cb_ = paint_cb; | 83 paint_cb_ = paint_cb; |
82 ended_cb_ = ended_cb; | 84 ended_cb_ = ended_cb; |
83 error_cb_ = error_cb; | 85 error_cb_ = error_cb; |
84 init_cb_ = init_cb; | 86 init_cb_ = init_cb; |
| 87 waiting_for_decryption_key_cb_ = waiting_for_decryption_key_cb; |
85 | 88 |
86 state_ = STATE_INITIALIZING; | 89 state_ = STATE_INITIALIZING; |
87 InitializeAudioRenderer(); | 90 InitializeAudioRenderer(); |
88 } | 91 } |
89 | 92 |
90 void RendererImpl::SetCdm(CdmContext* cdm_context, | 93 void RendererImpl::SetCdm(CdmContext* cdm_context, |
91 const CdmAttachedCB& cdm_attached_cb) { | 94 const CdmAttachedCB& cdm_attached_cb) { |
92 DVLOG(1) << __FUNCTION__; | 95 DVLOG(1) << __FUNCTION__; |
93 DCHECK(task_runner_->BelongsToCurrentThread()); | 96 DCHECK(task_runner_->BelongsToCurrentThread()); |
94 DCHECK(cdm_context); | 97 DCHECK(cdm_context); |
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
251 | 254 |
252 // Note: After the initialization of a renderer, error events from it may | 255 // Note: After the initialization of a renderer, error events from it may |
253 // happen at any time and all future calls must guard against STATE_ERROR. | 256 // happen at any time and all future calls must guard against STATE_ERROR. |
254 audio_renderer_->Initialize( | 257 audio_renderer_->Initialize( |
255 demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO), done_cb, | 258 demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO), done_cb, |
256 base::Bind(&RendererImpl::SetDecryptorReadyCallback, weak_this_), | 259 base::Bind(&RendererImpl::SetDecryptorReadyCallback, weak_this_), |
257 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), | 260 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), |
258 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, | 261 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, |
259 &audio_buffering_state_), | 262 &audio_buffering_state_), |
260 base::Bind(&RendererImpl::OnAudioRendererEnded, weak_this_), | 263 base::Bind(&RendererImpl::OnAudioRendererEnded, weak_this_), |
261 base::Bind(&RendererImpl::OnError, weak_this_)); | 264 base::Bind(&RendererImpl::OnError, weak_this_), |
| 265 waiting_for_decryption_key_cb_); |
262 } | 266 } |
263 | 267 |
264 void RendererImpl::OnAudioRendererInitializeDone(PipelineStatus status) { | 268 void RendererImpl::OnAudioRendererInitializeDone(PipelineStatus status) { |
265 DVLOG(1) << __FUNCTION__ << ": " << status; | 269 DVLOG(1) << __FUNCTION__ << ": " << status; |
266 DCHECK(task_runner_->BelongsToCurrentThread()); | 270 DCHECK(task_runner_->BelongsToCurrentThread()); |
267 | 271 |
268 // OnError() may be fired at any time by the renderers, even if they thought | 272 // OnError() may be fired at any time by the renderers, even if they thought |
269 // they initialized successfully (due to delayed output device setup). | 273 // they initialized successfully (due to delayed output device setup). |
270 if (state_ != STATE_INITIALIZING) { | 274 if (state_ != STATE_INITIALIZING) { |
271 DCHECK(init_cb_.is_null()); | 275 DCHECK(init_cb_.is_null()); |
(...skipping 28 matching lines...) Expand all Loading... |
300 video_renderer_->Initialize( | 304 video_renderer_->Initialize( |
301 demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO), done_cb, | 305 demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO), done_cb, |
302 base::Bind(&RendererImpl::SetDecryptorReadyCallback, weak_this_), | 306 base::Bind(&RendererImpl::SetDecryptorReadyCallback, weak_this_), |
303 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), | 307 base::Bind(&RendererImpl::OnUpdateStatistics, weak_this_), |
304 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, | 308 base::Bind(&RendererImpl::OnBufferingStateChanged, weak_this_, |
305 &video_buffering_state_), | 309 &video_buffering_state_), |
306 base::ResetAndReturn(&paint_cb_), | 310 base::ResetAndReturn(&paint_cb_), |
307 base::Bind(&RendererImpl::OnVideoRendererEnded, weak_this_), | 311 base::Bind(&RendererImpl::OnVideoRendererEnded, weak_this_), |
308 base::Bind(&RendererImpl::OnError, weak_this_), | 312 base::Bind(&RendererImpl::OnError, weak_this_), |
309 base::Bind(&RendererImpl::GetMediaTimeForSyncingVideo, | 313 base::Bind(&RendererImpl::GetMediaTimeForSyncingVideo, |
310 base::Unretained(this))); | 314 base::Unretained(this)), |
| 315 waiting_for_decryption_key_cb_); |
311 } | 316 } |
312 | 317 |
313 void RendererImpl::OnVideoRendererInitializeDone(PipelineStatus status) { | 318 void RendererImpl::OnVideoRendererInitializeDone(PipelineStatus status) { |
314 DVLOG(1) << __FUNCTION__ << ": " << status; | 319 DVLOG(1) << __FUNCTION__ << ": " << status; |
315 DCHECK(task_runner_->BelongsToCurrentThread()); | 320 DCHECK(task_runner_->BelongsToCurrentThread()); |
316 | 321 |
317 // OnError() may be fired at any time by the renderers, even if they thought | 322 // OnError() may be fired at any time by the renderers, even if they thought |
318 // they initialized successfully (due to delayed output device setup). | 323 // they initialized successfully (due to delayed output device setup). |
319 if (state_ != STATE_INITIALIZING) { | 324 if (state_ != STATE_INITIALIZING) { |
320 DCHECK(init_cb_.is_null()); | 325 DCHECK(init_cb_.is_null()); |
(...skipping 246 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
567 } | 572 } |
568 | 573 |
569 // After OnError() returns, the pipeline may destroy |this|. | 574 // After OnError() returns, the pipeline may destroy |this|. |
570 base::ResetAndReturn(&error_cb_).Run(error); | 575 base::ResetAndReturn(&error_cb_).Run(error); |
571 | 576 |
572 if (!flush_cb_.is_null()) | 577 if (!flush_cb_.is_null()) |
573 base::ResetAndReturn(&flush_cb_).Run(); | 578 base::ResetAndReturn(&flush_cb_).Run(); |
574 } | 579 } |
575 | 580 |
576 } // namespace media | 581 } // namespace media |
OLD | NEW |