Lines Matching defs:Pipeline
5 #include "media/base/pipeline.h"
35 Pipeline::Pipeline(
60 Pipeline::~Pipeline() {
62 << "Pipeline must be destroyed on same thread that created it";
71 void Pipeline::Start(scoped_ptr<FilterCollection> collection,
85 CHECK(!running_) << "Media pipeline is already running";
97 FROM_HERE, base::Bind(&Pipeline::StartTask, base::Unretained(this)));
100 void Pipeline::Stop(const base::Closure& stop_cb) {
103 &Pipeline::StopTask, base::Unretained(this), stop_cb));
106 void Pipeline::Seek(TimeDelta time, const PipelineStatusCB& seek_cb) {
109 NOTREACHED() << "Media pipeline isn't running";
114 &Pipeline::SeekTask, base::Unretained(this), time, seek_cb));
117 bool Pipeline::IsRunning() const {
122 float Pipeline::GetPlaybackRate() const {
127 void Pipeline::SetPlaybackRate(float playback_rate) {
135 &Pipeline::PlaybackRateChangedTask, base::Unretained(this),
140 float Pipeline::GetVolume() const {
145 void Pipeline::SetVolume(float volume) {
153 &Pipeline::VolumeChangedTask, base::Unretained(this), volume));
157 TimeDelta Pipeline::GetMediaTime() const {
162 Ranges<TimeDelta> Pipeline::GetBufferedTimeRanges() const {
167 TimeDelta Pipeline::GetMediaDuration() const {
172 bool Pipeline::DidLoadingProgress() {
179 PipelineStatistics Pipeline::GetStatistics() const {
184 void Pipeline::SetClockForTesting(Clock* clock) {
188 void Pipeline::SetErrorForTesting(PipelineStatus status) {
192 void Pipeline::SetState(State next_state) {
208 const char* Pipeline::GetStateString(State state) {
226 Pipeline::State Pipeline::GetNextState() const {
267 void Pipeline::OnDemuxerError(PipelineStatus error) {
271 void Pipeline::AddTextStream(DemuxerStream* text_stream,
274 &Pipeline::AddTextStreamTask, base::Unretained(this),
278 void Pipeline::RemoveTextStream(DemuxerStream* text_stream) {
280 &Pipeline::RemoveTextStreamTask, base::Unretained(this),
284 void Pipeline::SetError(PipelineStatus error) {
287 VLOG(1) << "Media pipeline error: " << error;
290 &Pipeline::ErrorChangedTask, base::Unretained(this), error));
295 void Pipeline::OnAudioTimeUpdate(TimeDelta time, TimeDelta max_time) {
312 void Pipeline::OnVideoTimeUpdate(TimeDelta max_time) {
326 void Pipeline::SetDuration(TimeDelta duration) {
339 void Pipeline::OnStateTransition(PipelineStatus status) {
342 &Pipeline::StateTransitionTask, base::Unretained(this), status));
345 void Pipeline::StateTransitionTask(PipelineStatus status) {
369 &Pipeline::OnStateTransition, base::Unretained(this));
443 void Pipeline::DoInitialPreroll(const PipelineStatusCB& done_cb) {
476 void Pipeline::DoSeek(
496 bound_fns.Push(base::Bind(&Pipeline::BufferingStateChanged,
507 bound_fns.Push(base::Bind(&Pipeline::BufferingStateChanged,
547 void Pipeline::DoStop(const PipelineStatusCB& done_cb) {
575 void Pipeline::OnStopCompleted(PipelineStatus status) {
601 // NOTE: pipeline may be deleted at this point in time as a result of
611 void Pipeline::AddBufferedTimeRange(base::TimeDelta start,
619 void Pipeline::OnAudioRendererEnded() {
622 &Pipeline::DoAudioRendererEnded, base::Unretained(this)));
626 void Pipeline::OnVideoRendererEnded() {
629 &Pipeline::DoVideoRendererEnded, base::Unretained(this)));
633 void Pipeline::OnTextRendererEnded() {
636 &Pipeline::DoTextRendererEnded, base::Unretained(this)));
641 void Pipeline::OnUpdateStatistics(const PipelineStatistics& stats) {
649 void Pipeline::StartTask() {
652 << "Media pipeline cannot be started more than once";
658 base::Bind(&Pipeline::OnTextRendererEnded, base::Unretained(this)));
664 void Pipeline::StopTask(const base::Closure& stop_cb) {
681 DoStop(base::Bind(&Pipeline::OnStopCompleted, base::Unretained(this)));
684 void Pipeline::ErrorChangedTask(PipelineStatus error) {
695 DoStop(base::Bind(&Pipeline::OnStopCompleted, base::Unretained(this)));
698 void Pipeline::PlaybackRateChangedTask(float playback_rate) {
716 void Pipeline::VolumeChangedTask(float volume) {
727 void Pipeline::SeekTask(TimeDelta time, const PipelineStatusCB& seek_cb) {
738 DVLOG(1) << "Media pipeline has not started, ignoring seek to "
759 &Pipeline::OnStateTransition, base::Unretained(this)));
762 void Pipeline::DoAudioRendererEnded() {
781 void Pipeline::DoVideoRendererEnded() {
793 void Pipeline::DoTextRendererEnded() {
805 void Pipeline::RunEndedCallbackIfNeeded() {
827 void Pipeline::AddTextStreamTask(DemuxerStream* text_stream,
835 void Pipeline::RemoveTextStreamTask(DemuxerStream* text_stream) {
840 void Pipeline::InitializeDemuxer(const PipelineStatusCB& done_cb) {
847 void Pipeline::InitializeAudioRenderer(const PipelineStatusCB& done_cb) {
854 base::Bind(&Pipeline::OnUpdateStatistics, base::Unretained(this)),
855 base::Bind(&Pipeline::OnAudioUnderflow, base::Unretained(this)),
856 base::Bind(&Pipeline::OnAudioTimeUpdate, base::Unretained(this)),
857 base::Bind(&Pipeline::OnAudioRendererEnded, base::Unretained(this)),
858 base::Bind(&Pipeline::SetError, base::Unretained(this)));
861 void Pipeline::InitializeVideoRenderer(const PipelineStatusCB& done_cb) {
869 base::Bind(&Pipeline::OnUpdateStatistics, base::Unretained(this)),
870 base::Bind(&Pipeline::OnVideoTimeUpdate, base::Unretained(this)),
871 base::Bind(&Pipeline::OnVideoRendererEnded, base::Unretained(this)),
872 base::Bind(&Pipeline::SetError, base::Unretained(this)),
873 base::Bind(&Pipeline::GetMediaTime, base::Unretained(this)),
874 base::Bind(&Pipeline::GetMediaDuration, base::Unretained(this)));
877 void Pipeline::OnAudioUnderflow() {
880 &Pipeline::OnAudioUnderflow, base::Unretained(this)));
891 void Pipeline::BufferingStateChanged(BufferingState* buffering_state,
913 bool Pipeline::WaitingForEnoughData() const {
924 void Pipeline::StartWaitingForEnoughData() {
933 void Pipeline::StartPlayback() {
957 void Pipeline::PauseClockAndStopRendering_Locked() {
977 void Pipeline::StartClockIfWaitingForTimeUpdate_Locked() {
