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 "chromecast/media/cma/pipeline/media_pipeline_impl.h" | 5 #include "chromecast/media/cma/pipeline/media_pipeline_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/location.h" | 10 #include "base/location.h" |
11 #include "base/logging.h" | 11 #include "base/logging.h" |
12 #include "base/single_thread_task_runner.h" | 12 #include "base/single_thread_task_runner.h" |
13 #include "base/thread_task_runner_handle.h" | 13 #include "base/thread_task_runner_handle.h" |
14 #include "base/time/time.h" | 14 #include "base/time/time.h" |
15 #include "chromecast/base/time_conversions.h" | |
15 #include "chromecast/media/cdm/browser_cdm_cast.h" | 16 #include "chromecast/media/cdm/browser_cdm_cast.h" |
16 #include "chromecast/media/cma/backend/media_clock_device.h" | |
17 #include "chromecast/media/cma/backend/media_pipeline_device.h" | |
18 #include "chromecast/media/cma/base/buffering_controller.h" | 17 #include "chromecast/media/cma/base/buffering_controller.h" |
19 #include "chromecast/media/cma/base/buffering_state.h" | 18 #include "chromecast/media/cma/base/buffering_state.h" |
20 #include "chromecast/media/cma/base/cma_logging.h" | 19 #include "chromecast/media/cma/base/cma_logging.h" |
21 #include "chromecast/media/cma/base/coded_frame_provider.h" | 20 #include "chromecast/media/cma/base/coded_frame_provider.h" |
22 #include "chromecast/media/cma/pipeline/audio_pipeline_impl.h" | 21 #include "chromecast/media/cma/pipeline/audio_pipeline_impl.h" |
23 #include "chromecast/media/cma/pipeline/video_pipeline_impl.h" | 22 #include "chromecast/media/cma/pipeline/video_pipeline_impl.h" |
23 #include "chromecast/public/media/media_clock_device.h" | |
24 #include "chromecast/public/media/media_pipeline_backend.h" | |
24 #include "media/base/buffers.h" | 25 #include "media/base/buffers.h" |
25 | 26 |
26 namespace chromecast { | 27 namespace chromecast { |
27 namespace media { | 28 namespace media { |
28 | 29 |
29 namespace { | 30 namespace { |
30 | 31 |
31 // Buffering parameters when load_type is kLoadTypeUrl. | 32 // Buffering parameters when load_type is kLoadTypeUrl. |
32 const base::TimeDelta kLowBufferThresholdURL( | 33 const base::TimeDelta kLowBufferThresholdURL( |
33 base::TimeDelta::FromMilliseconds(2000)); | 34 base::TimeDelta::FromMilliseconds(2000)); |
(...skipping 29 matching lines...) Expand all Loading... | |
63 thread_checker_.DetachFromThread(); | 64 thread_checker_.DetachFromThread(); |
64 } | 65 } |
65 | 66 |
66 MediaPipelineImpl::~MediaPipelineImpl() { | 67 MediaPipelineImpl::~MediaPipelineImpl() { |
67 CMALOG(kLogControl) << __FUNCTION__; | 68 CMALOG(kLogControl) << __FUNCTION__; |
68 DCHECK(thread_checker_.CalledOnValidThread()); | 69 DCHECK(thread_checker_.CalledOnValidThread()); |
69 } | 70 } |
70 | 71 |
71 void MediaPipelineImpl::Initialize( | 72 void MediaPipelineImpl::Initialize( |
72 LoadType load_type, | 73 LoadType load_type, |
73 scoped_ptr<MediaPipelineDevice> media_pipeline_device) { | 74 scoped_ptr<MediaPipelineBackend> media_device_components) { |
gunsch
2015/07/27 17:14:49
media_device_components --> media_pipeline_backend
halliwell
2015/07/28 02:19:35
Done.
| |
74 CMALOG(kLogControl) << __FUNCTION__; | 75 CMALOG(kLogControl) << __FUNCTION__; |
75 DCHECK(thread_checker_.CalledOnValidThread()); | 76 DCHECK(thread_checker_.CalledOnValidThread()); |
76 media_pipeline_device_.reset(media_pipeline_device.release()); | 77 media_device_components_.reset(media_device_components.release()); |
77 clock_device_ = media_pipeline_device_->GetMediaClockDevice(); | 78 clock_device_ = media_device_components_->GetClock(); |
78 | 79 |
79 if (load_type == kLoadTypeURL || load_type == kLoadTypeMediaSource) { | 80 if (load_type == kLoadTypeURL || load_type == kLoadTypeMediaSource) { |
80 base::TimeDelta low_threshold(kLowBufferThresholdURL); | 81 base::TimeDelta low_threshold(kLowBufferThresholdURL); |
81 base::TimeDelta high_threshold(kHighBufferThresholdURL); | 82 base::TimeDelta high_threshold(kHighBufferThresholdURL); |
82 if (load_type == kLoadTypeMediaSource) { | 83 if (load_type == kLoadTypeMediaSource) { |
83 low_threshold = kLowBufferThresholdMediaSource; | 84 low_threshold = kLowBufferThresholdMediaSource; |
84 high_threshold = kHighBufferThresholdMediaSource; | 85 high_threshold = kHighBufferThresholdMediaSource; |
85 } | 86 } |
86 scoped_refptr<BufferingConfig> buffering_config( | 87 scoped_refptr<BufferingConfig> buffering_config( |
87 new BufferingConfig(low_threshold, high_threshold)); | 88 new BufferingConfig(low_threshold, high_threshold)); |
88 buffering_controller_.reset(new BufferingController( | 89 buffering_controller_.reset(new BufferingController( |
89 buffering_config, | 90 buffering_config, |
90 base::Bind(&MediaPipelineImpl::OnBufferingNotification, weak_this_))); | 91 base::Bind(&MediaPipelineImpl::OnBufferingNotification, weak_this_))); |
91 } | 92 } |
92 | 93 |
93 audio_pipeline_.reset(new AudioPipelineImpl( | 94 audio_pipeline_.reset( |
94 media_pipeline_device_->GetAudioPipelineDevice())); | 95 new AudioPipelineImpl(media_device_components_->GetAudio())); |
95 | 96 |
96 video_pipeline_.reset(new VideoPipelineImpl( | 97 video_pipeline_.reset( |
97 media_pipeline_device_->GetVideoPipelineDevice())); | 98 new VideoPipelineImpl(media_device_components_->GetVideo())); |
98 } | 99 } |
99 | 100 |
100 void MediaPipelineImpl::SetClient(const MediaPipelineClient& client) { | 101 void MediaPipelineImpl::SetClient(const MediaPipelineClient& client) { |
101 DCHECK(thread_checker_.CalledOnValidThread()); | 102 DCHECK(thread_checker_.CalledOnValidThread()); |
102 DCHECK(!client.error_cb.is_null()); | 103 DCHECK(!client.error_cb.is_null()); |
103 DCHECK(!client.time_update_cb.is_null()); | 104 DCHECK(!client.time_update_cb.is_null()); |
104 DCHECK(!client.buffering_state_cb.is_null()); | 105 DCHECK(!client.buffering_state_cb.is_null()); |
105 client_ = client; | 106 client_ = client; |
106 } | 107 } |
107 | 108 |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
159 } | 160 } |
160 | 161 |
161 void MediaPipelineImpl::StartPlayingFrom(base::TimeDelta time) { | 162 void MediaPipelineImpl::StartPlayingFrom(base::TimeDelta time) { |
162 CMALOG(kLogControl) << __FUNCTION__ << " t0=" << time.InMilliseconds(); | 163 CMALOG(kLogControl) << __FUNCTION__ << " t0=" << time.InMilliseconds(); |
163 DCHECK(thread_checker_.CalledOnValidThread()); | 164 DCHECK(thread_checker_.CalledOnValidThread()); |
164 DCHECK(has_audio_ || has_video_); | 165 DCHECK(has_audio_ || has_video_); |
165 DCHECK(!pending_flush_callbacks_); | 166 DCHECK(!pending_flush_callbacks_); |
166 | 167 |
167 // Reset the start of the timeline. | 168 // Reset the start of the timeline. |
168 DCHECK_EQ(clock_device_->GetState(), MediaClockDevice::kStateIdle); | 169 DCHECK_EQ(clock_device_->GetState(), MediaClockDevice::kStateIdle); |
169 clock_device_->ResetTimeline(time); | 170 clock_device_->ResetTimeline(FromBaseTimeDelta(time)); |
170 | 171 |
171 // Start the clock. If the playback rate is 0, then the clock is started | 172 // Start the clock. If the playback rate is 0, then the clock is started |
172 // but does not increase. | 173 // but does not increase. |
173 if (!clock_device_->SetState(MediaClockDevice::kStateRunning)) { | 174 if (!clock_device_->SetState(MediaClockDevice::kStateRunning)) { |
174 OnError(::media::PIPELINE_ERROR_ABORT); | 175 OnError(::media::PIPELINE_ERROR_ABORT); |
175 return; | 176 return; |
176 } | 177 } |
177 | 178 |
178 // Enable time updates. | 179 // Enable time updates. |
179 enable_time_update_ = true; | 180 enable_time_update_ = true; |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
265 audio_pipeline_->Stop(); | 266 audio_pipeline_->Stop(); |
266 if (has_video_) | 267 if (has_video_) |
267 video_pipeline_->Stop(); | 268 video_pipeline_->Stop(); |
268 } | 269 } |
269 | 270 |
270 void MediaPipelineImpl::SetPlaybackRate(double rate) { | 271 void MediaPipelineImpl::SetPlaybackRate(double rate) { |
271 CMALOG(kLogControl) << __FUNCTION__ << " rate=" << rate; | 272 CMALOG(kLogControl) << __FUNCTION__ << " rate=" << rate; |
272 DCHECK(thread_checker_.CalledOnValidThread()); | 273 DCHECK(thread_checker_.CalledOnValidThread()); |
273 target_playback_rate_ = rate; | 274 target_playback_rate_ = rate; |
274 if (!buffering_controller_ || !buffering_controller_->IsBuffering()) | 275 if (!buffering_controller_ || !buffering_controller_->IsBuffering()) |
275 media_pipeline_device_->GetMediaClockDevice()->SetRate(rate); | 276 media_device_components_->GetClock()->SetRate(rate); |
276 } | 277 } |
277 | 278 |
278 AudioPipelineImpl* MediaPipelineImpl::GetAudioPipelineImpl() const { | 279 AudioPipelineImpl* MediaPipelineImpl::GetAudioPipelineImpl() const { |
279 return audio_pipeline_.get(); | 280 return audio_pipeline_.get(); |
280 } | 281 } |
281 | 282 |
282 VideoPipelineImpl* MediaPipelineImpl::GetVideoPipelineImpl() const { | 283 VideoPipelineImpl* MediaPipelineImpl::GetVideoPipelineImpl() const { |
283 return video_pipeline_.get(); | 284 return video_pipeline_.get(); |
284 } | 285 } |
285 | 286 |
286 void MediaPipelineImpl::StateTransition( | 287 void MediaPipelineImpl::StateTransition( |
287 const ::media::PipelineStatusCB& status_cb, | 288 const ::media::PipelineStatusCB& status_cb, |
288 ::media::PipelineStatus status) { | 289 ::media::PipelineStatus status) { |
289 pending_flush_callbacks_.reset(); | 290 pending_flush_callbacks_.reset(); |
290 status_cb.Run(status); | 291 status_cb.Run(status); |
291 } | 292 } |
292 | 293 |
293 void MediaPipelineImpl::OnBufferingNotification(bool is_buffering) { | 294 void MediaPipelineImpl::OnBufferingNotification(bool is_buffering) { |
294 CMALOG(kLogControl) << __FUNCTION__ << " is_buffering=" << is_buffering; | 295 CMALOG(kLogControl) << __FUNCTION__ << " is_buffering=" << is_buffering; |
295 DCHECK(thread_checker_.CalledOnValidThread()); | 296 DCHECK(thread_checker_.CalledOnValidThread()); |
296 DCHECK(buffering_controller_); | 297 DCHECK(buffering_controller_); |
297 | 298 |
298 if (!client_.buffering_state_cb.is_null()) { | 299 if (!client_.buffering_state_cb.is_null()) { |
299 ::media::BufferingState buffering_state = is_buffering ? | 300 ::media::BufferingState buffering_state = is_buffering ? |
300 ::media::BUFFERING_HAVE_NOTHING : ::media::BUFFERING_HAVE_ENOUGH; | 301 ::media::BUFFERING_HAVE_NOTHING : ::media::BUFFERING_HAVE_ENOUGH; |
301 client_.buffering_state_cb.Run(buffering_state); | 302 client_.buffering_state_cb.Run(buffering_state); |
302 } | 303 } |
303 | 304 |
304 if (media_pipeline_device_->GetMediaClockDevice()->GetState() == | 305 if (media_device_components_->GetClock()->GetState() == |
305 MediaClockDevice::kStateUninitialized) { | 306 MediaClockDevice::kStateUninitialized) { |
306 return; | 307 return; |
307 } | 308 } |
308 | 309 |
309 if (is_buffering) { | 310 if (is_buffering) { |
310 // Do not consume data in a rebuffering phase. | 311 // Do not consume data in a rebuffering phase. |
311 media_pipeline_device_->GetMediaClockDevice()->SetRate(0.0); | 312 media_device_components_->GetClock()->SetRate(0.0); |
312 } else { | 313 } else { |
313 media_pipeline_device_->GetMediaClockDevice()->SetRate( | 314 media_device_components_->GetClock()->SetRate(target_playback_rate_); |
314 target_playback_rate_); | |
315 } | 315 } |
316 } | 316 } |
317 | 317 |
318 void MediaPipelineImpl::UpdateMediaTime() { | 318 void MediaPipelineImpl::UpdateMediaTime() { |
319 pending_time_update_task_ = false; | 319 pending_time_update_task_ = false; |
320 if (!enable_time_update_) | 320 if (!enable_time_update_) |
321 return; | 321 return; |
322 | 322 |
323 if (statistics_rolling_counter_ == 0) { | 323 if (statistics_rolling_counter_ == 0) { |
324 audio_pipeline_->UpdateStatistics(); | 324 audio_pipeline_->UpdateStatistics(); |
325 video_pipeline_->UpdateStatistics(); | 325 video_pipeline_->UpdateStatistics(); |
326 } | 326 } |
327 statistics_rolling_counter_ = | 327 statistics_rolling_counter_ = |
328 (statistics_rolling_counter_ + 1) % kStatisticsUpdatePeriod; | 328 (statistics_rolling_counter_ + 1) % kStatisticsUpdatePeriod; |
329 | 329 |
330 base::TimeDelta media_time(clock_device_->GetTime()); | 330 base::TimeDelta media_time = ToBaseTimeDelta(clock_device_->GetTime()); |
331 if (media_time == ::media::kNoTimestamp()) { | 331 if (media_time == ::media::kNoTimestamp()) { |
332 pending_time_update_task_ = true; | 332 pending_time_update_task_ = true; |
333 base::ThreadTaskRunnerHandle::Get()->PostDelayedTask( | 333 base::ThreadTaskRunnerHandle::Get()->PostDelayedTask( |
334 FROM_HERE, base::Bind(&MediaPipelineImpl::UpdateMediaTime, weak_this_), | 334 FROM_HERE, base::Bind(&MediaPipelineImpl::UpdateMediaTime, weak_this_), |
335 kTimeUpdateInterval); | 335 kTimeUpdateInterval); |
336 return; | 336 return; |
337 } | 337 } |
338 base::TimeTicks stc = base::TimeTicks::Now(); | 338 base::TimeTicks stc = base::TimeTicks::Now(); |
339 | 339 |
340 base::TimeDelta max_rendering_time = media_time; | 340 base::TimeDelta max_rendering_time = media_time; |
(...skipping 25 matching lines...) Expand all Loading... | |
366 | 366 |
367 void MediaPipelineImpl::OnError(::media::PipelineStatus error) { | 367 void MediaPipelineImpl::OnError(::media::PipelineStatus error) { |
368 DCHECK(thread_checker_.CalledOnValidThread()); | 368 DCHECK(thread_checker_.CalledOnValidThread()); |
369 DCHECK_NE(error, ::media::PIPELINE_OK) << "PIPELINE_OK is not an error!"; | 369 DCHECK_NE(error, ::media::PIPELINE_OK) << "PIPELINE_OK is not an error!"; |
370 if (!client_.error_cb.is_null()) | 370 if (!client_.error_cb.is_null()) |
371 client_.error_cb.Run(error); | 371 client_.error_cb.Run(error); |
372 } | 372 } |
373 | 373 |
374 } // namespace media | 374 } // namespace media |
375 } // namespace chromecast | 375 } // namespace chromecast |
OLD | NEW |