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

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

Issue 1053113002: Prime the landing pad for the new video rendering pipeline. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fix cc_unittests Created 5 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
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 "media/base/pipeline.h" 5 #include "media/base/pipeline.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 8
9 #include "base/bind.h" 9 #include "base/bind.h"
10 #include "base/callback.h" 10 #include "base/callback.h"
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after
61 media_log_->CreateEvent(MediaLogEvent::PIPELINE_DESTROYED)); 61 media_log_->CreateEvent(MediaLogEvent::PIPELINE_DESTROYED));
62 } 62 }
63 63
64 void Pipeline::Start(Demuxer* demuxer, 64 void Pipeline::Start(Demuxer* demuxer,
65 scoped_ptr<Renderer> renderer, 65 scoped_ptr<Renderer> renderer,
66 const base::Closure& ended_cb, 66 const base::Closure& ended_cb,
67 const PipelineStatusCB& error_cb, 67 const PipelineStatusCB& error_cb,
68 const PipelineStatusCB& seek_cb, 68 const PipelineStatusCB& seek_cb,
69 const PipelineMetadataCB& metadata_cb, 69 const PipelineMetadataCB& metadata_cb,
70 const BufferingStateCB& buffering_state_cb, 70 const BufferingStateCB& buffering_state_cb,
71 const PaintCB& paint_cb,
72 const base::Closure& duration_change_cb, 71 const base::Closure& duration_change_cb,
73 const AddTextTrackCB& add_text_track_cb, 72 const AddTextTrackCB& add_text_track_cb,
74 const base::Closure& waiting_for_decryption_key_cb) { 73 const base::Closure& waiting_for_decryption_key_cb) {
75 DCHECK(!ended_cb.is_null()); 74 DCHECK(!ended_cb.is_null());
76 DCHECK(!error_cb.is_null()); 75 DCHECK(!error_cb.is_null());
77 DCHECK(!seek_cb.is_null()); 76 DCHECK(!seek_cb.is_null());
78 DCHECK(!metadata_cb.is_null()); 77 DCHECK(!metadata_cb.is_null());
79 DCHECK(!buffering_state_cb.is_null()); 78 DCHECK(!buffering_state_cb.is_null());
80 DCHECK(!paint_cb.is_null());
81 79
82 base::AutoLock auto_lock(lock_); 80 base::AutoLock auto_lock(lock_);
83 CHECK(!running_) << "Media pipeline is already running"; 81 CHECK(!running_) << "Media pipeline is already running";
84 running_ = true; 82 running_ = true;
85 83
86 demuxer_ = demuxer; 84 demuxer_ = demuxer;
87 renderer_ = renderer.Pass(); 85 renderer_ = renderer.Pass();
88 ended_cb_ = ended_cb; 86 ended_cb_ = ended_cb;
89 error_cb_ = error_cb; 87 error_cb_ = error_cb;
90 seek_cb_ = seek_cb; 88 seek_cb_ = seek_cb;
91 metadata_cb_ = metadata_cb; 89 metadata_cb_ = metadata_cb;
92 buffering_state_cb_ = buffering_state_cb; 90 buffering_state_cb_ = buffering_state_cb;
93 paint_cb_ = paint_cb;
94 duration_change_cb_ = duration_change_cb; 91 duration_change_cb_ = duration_change_cb;
95 add_text_track_cb_ = add_text_track_cb; 92 add_text_track_cb_ = add_text_track_cb;
96 waiting_for_decryption_key_cb_ = waiting_for_decryption_key_cb; 93 waiting_for_decryption_key_cb_ = waiting_for_decryption_key_cb;
97 94
98 task_runner_->PostTask( 95 task_runner_->PostTask(
99 FROM_HERE, base::Bind(&Pipeline::StartTask, weak_factory_.GetWeakPtr())); 96 FROM_HERE, base::Bind(&Pipeline::StartTask, weak_factory_.GetWeakPtr()));
100 } 97 }
101 98
102 void Pipeline::Stop(const base::Closure& stop_cb) { 99 void Pipeline::Stop(const base::Closure& stop_cb) {
103 DVLOG(2) << __FUNCTION__; 100 DVLOG(2) << __FUNCTION__;
(...skipping 613 matching lines...) Expand 10 before | Expand all | Expand 10 after
717 OnError(PIPELINE_ERROR_COULD_NOT_RENDER); 714 OnError(PIPELINE_ERROR_COULD_NOT_RENDER);
718 return; 715 return;
719 } 716 }
720 717
721 base::WeakPtr<Pipeline> weak_this = weak_factory_.GetWeakPtr(); 718 base::WeakPtr<Pipeline> weak_this = weak_factory_.GetWeakPtr();
722 renderer_->Initialize( 719 renderer_->Initialize(
723 demuxer_, 720 demuxer_,
724 done_cb, 721 done_cb,
725 base::Bind(&Pipeline::OnUpdateStatistics, weak_this), 722 base::Bind(&Pipeline::OnUpdateStatistics, weak_this),
726 base::Bind(&Pipeline::BufferingStateChanged, weak_this), 723 base::Bind(&Pipeline::BufferingStateChanged, weak_this),
727 base::ResetAndReturn(&paint_cb_),
728 base::Bind(&Pipeline::OnRendererEnded, weak_this), 724 base::Bind(&Pipeline::OnRendererEnded, weak_this),
729 base::Bind(&Pipeline::OnError, weak_this), 725 base::Bind(&Pipeline::OnError, weak_this),
730 waiting_for_decryption_key_cb_); 726 waiting_for_decryption_key_cb_);
731 } 727 }
732 728
733 void Pipeline::ReportMetadata() { 729 void Pipeline::ReportMetadata() {
734 DCHECK(task_runner_->BelongsToCurrentThread()); 730 DCHECK(task_runner_->BelongsToCurrentThread());
735 PipelineMetadata metadata; 731 PipelineMetadata metadata;
736 metadata.timeline_offset = demuxer_->GetTimelineOffset(); 732 metadata.timeline_offset = demuxer_->GetTimelineOffset();
737 DemuxerStream* stream = demuxer_->GetStream(DemuxerStream::VIDEO); 733 DemuxerStream* stream = demuxer_->GetStream(DemuxerStream::VIDEO);
738 if (stream) { 734 if (stream) {
739 metadata.has_video = true; 735 metadata.has_video = true;
740 metadata.natural_size = stream->video_decoder_config().natural_size(); 736 metadata.natural_size = stream->video_decoder_config().natural_size();
741 metadata.video_rotation = stream->video_rotation(); 737 metadata.video_rotation = stream->video_rotation();
742 } 738 }
743 if (demuxer_->GetStream(DemuxerStream::AUDIO)) { 739 if (demuxer_->GetStream(DemuxerStream::AUDIO)) {
744 metadata.has_audio = true; 740 metadata.has_audio = true;
745 } 741 }
746 metadata_cb_.Run(metadata); 742 metadata_cb_.Run(metadata);
747 } 743 }
748 744
749 void Pipeline::BufferingStateChanged(BufferingState new_buffering_state) { 745 void Pipeline::BufferingStateChanged(BufferingState new_buffering_state) {
750 DVLOG(1) << __FUNCTION__ << "(" << new_buffering_state << ") "; 746 DVLOG(1) << __FUNCTION__ << "(" << new_buffering_state << ") ";
751 DCHECK(task_runner_->BelongsToCurrentThread()); 747 DCHECK(task_runner_->BelongsToCurrentThread());
752 buffering_state_cb_.Run(new_buffering_state); 748 buffering_state_cb_.Run(new_buffering_state);
753 } 749 }
754 750
755 } // namespace media 751 } // namespace media
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698