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

Side by Side Diff: chromecast/media/cma/pipeline/media_pipeline_impl.cc

Issue 1257013003: Load CMA backend from shared library (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Unit test + android fixes Created 5 years, 4 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
OLDNEW
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
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698