[go: nahoru, domu]
Google Git
Sign in
chromium / chromium / src / 16bbeea8c7fed2b76b26bb9c7fcee326806514f7 / . / media / renderers / renderer_impl.h
blob: 22417857058a9332af7516eae24aa4b33191c586 [file] [log] [blame]
xhwangbe9da702014-08-23 21:44:55[diff] [blame]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
3// found in the LICENSE file.
4
servolkf54f5c8f2015-02-24 20:32:39[diff] [blame]5#ifndef MEDIA_RENDERERS_RENDERER_IMPL_H_
6#define MEDIA_RENDERERS_RENDERER_IMPL_H_
xhwangbe9da702014-08-23 21:44:55[diff] [blame]7
danakj4d43bc22016-04-26 03:36:04[diff] [blame]8#include <memory>
dalecurtise92934582015-05-12 06:38:00[diff] [blame]9#include <vector>
10
dalecurtisc11e7bb2015-04-03 05:07:08[diff] [blame]11#include "base/cancelable_callback.h"
avia82b9b52015-12-19 04:27:08[diff] [blame]12#include "base/macros.h"
xhwangbe9da702014-08-23 21:44:55[diff] [blame]13#include "base/memory/ref_counted.h"
xhwangbe9da702014-08-23 21:44:55[diff] [blame]14#include "base/memory/weak_ptr.h"
15#include "base/synchronization/lock.h"
16#include "base/time/clock.h"
17#include "base/time/default_tick_clock.h"
18#include "base/time/time.h"
19#include "media/base/buffering_state.h"
xhwang97de4202014-11-25 08:44:01[diff] [blame]20#include "media/base/decryptor.h"
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]21#include "media/base/demuxer_stream.h"
xhwangbe9da702014-08-23 21:44:55[diff] [blame]22#include "media/base/media_export.h"
23#include "media/base/pipeline_status.h"
24#include "media/base/renderer.h"
25
26namespace base {
27class SingleThreadTaskRunner;
28}
29
30namespace media {
31
32class AudioRenderer;
xhwang1c5668e2014-09-10 02:42:04[diff] [blame]33class DemuxerStreamProvider;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]34class TimeSource;
35class VideoRenderer;
scherkusece89452014-09-09 23:13:38[diff] [blame]36class WallClockTimeSource;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]37
38class MEDIA_EXPORT RendererImpl : public Renderer {
39 public:
xhwangabd95fd2014-10-03 07:10:01[diff] [blame]40 // Renders audio/video streams using |audio_renderer| and |video_renderer|
41 // provided. All methods except for GetMediaTime() run on the |task_runner|.
42 // GetMediaTime() runs on the render main thread because it's part of JS sync
43 // API.
xhwangbe9da702014-08-23 21:44:55[diff] [blame]44 RendererImpl(const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
danakj4d43bc22016-04-26 03:36:04[diff] [blame]45 std::unique_ptr<AudioRenderer> audio_renderer,
46 std::unique_ptr<VideoRenderer> video_renderer);
xhwangbe9da702014-08-23 21:44:55[diff] [blame]47
xhwang97de4202014-11-25 08:44:01[diff] [blame]48 ~RendererImpl() final;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]49
50 // Renderer implementation.
dchengc2456542014-10-21 12:23:27[diff] [blame]51 void Initialize(DemuxerStreamProvider* demuxer_stream_provider,
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]52 RendererClient* client,
53 const PipelineStatusCB& init_cb) final;
xhwang97de4202014-11-25 08:44:01[diff] [blame]54 void SetCdm(CdmContext* cdm_context,
55 const CdmAttachedCB& cdm_attached_cb) final;
56 void Flush(const base::Closure& flush_cb) final;
57 void StartPlayingFrom(base::TimeDelta time) final;
a.berwal338bf002015-04-22 11:14:50[diff] [blame]58 void SetPlaybackRate(double playback_rate) final;
xhwang97de4202014-11-25 08:44:01[diff] [blame]59 void SetVolume(float volume) final;
60 base::TimeDelta GetMediaTime() final;
61 bool HasAudio() final;
62 bool HasVideo() final;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]63
64 // Helper functions for testing purposes. Must be called before Initialize().
65 void DisableUnderflowForTesting();
scherkusece89452014-09-09 23:13:38[diff] [blame]66 void EnableClocklessVideoPlaybackForTesting();
dalecurtisc11e7bb2015-04-03 05:07:08[diff] [blame]67 void set_time_source_for_testing(TimeSource* time_source) {
68 time_source_ = time_source;
69 }
70 void set_video_underflow_threshold_for_testing(base::TimeDelta threshold) {
71 video_underflow_threshold_ = threshold;
72 }
xhwangbe9da702014-08-23 21:44:55[diff] [blame]73
74 private:
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]75 class RendererClientInternal;
76
xhwangbe9da702014-08-23 21:44:55[diff] [blame]77 enum State {
78 STATE_UNINITIALIZED,
xhwanga935e442016-02-11 02:22:45[diff] [blame]79 STATE_INIT_PENDING_CDM, // Initialization is waiting for the CDM to be set.
80 STATE_INITIALIZING, // Initializing audio/video renderers.
xhwangbe9da702014-08-23 21:44:55[diff] [blame]81 STATE_FLUSHING,
82 STATE_PLAYING,
83 STATE_ERROR
84 };
85
dalecurtise92934582015-05-12 06:38:00[diff] [blame]86 bool GetWallClockTimes(const std::vector<base::TimeDelta>& media_timestamps,
87 std::vector<base::TimeTicks>* wall_clock_times);
xhwang97de4202014-11-25 08:44:01[diff] [blame]88
xhwanga935e442016-02-11 02:22:45[diff] [blame]89 bool HasEncryptedStream();
90
91 void FinishInitialization(PipelineStatus status);
xhwangbe9da702014-08-23 21:44:55[diff] [blame]92
93 // Helper functions and callbacks for Initialize().
94 void InitializeAudioRenderer();
95 void OnAudioRendererInitializeDone(PipelineStatus status);
96 void InitializeVideoRenderer();
97 void OnVideoRendererInitializeDone(PipelineStatus status);
98
99 // Helper functions and callbacks for Flush().
100 void FlushAudioRenderer();
101 void OnAudioRendererFlushDone();
102 void FlushVideoRenderer();
103 void OnVideoRendererFlushDone();
xhwangbe9da702014-08-23 21:44:55[diff] [blame]104
105 // Callback executed by filters to update statistics.
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]106 void OnStatisticsUpdate(const PipelineStatistics& stats);
xhwangbe9da702014-08-23 21:44:55[diff] [blame]107
108 // Collection of callback methods and helpers for tracking changes in
109 // buffering state and transition from paused/underflow states and playing
110 // states.
111 //
112 // While in the kPlaying state:
113 // - A waiting to non-waiting transition indicates preroll has completed
114 // and StartPlayback() should be called
115 // - A non-waiting to waiting transition indicates underflow has occurred
116 // and PausePlayback() should be called
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]117 void OnBufferingStateChange(DemuxerStream::Type type,
118 BufferingState new_buffering_state);
xhwangbe9da702014-08-23 21:44:55[diff] [blame]119 bool WaitingForEnoughData() const;
120 void PausePlayback();
121 void StartPlayback();
122
xhwangbe9da702014-08-23 21:44:55[diff] [blame]123 // Callbacks executed when a renderer has ended.
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]124 void OnRendererEnded(DemuxerStream::Type type);
scherkusece89452014-09-09 23:13:38[diff] [blame]125 bool PlaybackHasEnded() const;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]126 void RunEndedCallbackIfNeeded();
127
128 // Callback executed when a runtime error happens.
129 void OnError(PipelineStatus error);
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]130 void OnWaitingForDecryptionKey();
xhwangbe9da702014-08-23 21:44:55[diff] [blame]131
xhwangbe9da702014-08-23 21:44:55[diff] [blame]132 State state_;
133
134 // Task runner used to execute pipeline tasks.
135 scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
136
xhwang1c5668e2014-09-10 02:42:04[diff] [blame]137 DemuxerStreamProvider* demuxer_stream_provider_;
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]138 RendererClient* client_;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]139
140 // Temporary callback used for Initialize() and Flush().
dalecurtis47046112015-01-23 22:58:20[diff] [blame]141 PipelineStatusCB init_cb_;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]142 base::Closure flush_cb_;
143
alokp16bbeea2016-05-12 23:32:36[diff] [blame^]144 std::unique_ptr<RendererClientInternal> audio_renderer_client_;
145 std::unique_ptr<RendererClientInternal> video_renderer_client_;
danakj4d43bc22016-04-26 03:36:04[diff] [blame]146 std::unique_ptr<AudioRenderer> audio_renderer_;
147 std::unique_ptr<VideoRenderer> video_renderer_;
servolk06e3a9f2016-04-16 02:20:10[diff] [blame]148
xhwangbe9da702014-08-23 21:44:55[diff] [blame]149 // Renderer-provided time source used to control playback.
150 TimeSource* time_source_;
danakj4d43bc22016-04-26 03:36:04[diff] [blame]151 std::unique_ptr<WallClockTimeSource> wall_clock_time_source_;
scherkusece89452014-09-09 23:13:38[diff] [blame]152 bool time_ticking_;
a.berwal338bf002015-04-22 11:14:50[diff] [blame]153 double playback_rate_;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]154
155 // The time to start playback from after starting/seeking has completed.
156 base::TimeDelta start_time_;
157
158 BufferingState audio_buffering_state_;
159 BufferingState video_buffering_state_;
160
161 // Whether we've received the audio/video ended events.
162 bool audio_ended_;
163 bool video_ended_;
164
xhwang97de4202014-11-25 08:44:01[diff] [blame]165 CdmContext* cdm_context_;
xhwanga935e442016-02-11 02:22:45[diff] [blame]166 CdmAttachedCB pending_cdm_attached_cb_;
xhwang97de4202014-11-25 08:44:01[diff] [blame]167
xhwangbe9da702014-08-23 21:44:55[diff] [blame]168 bool underflow_disabled_for_testing_;
scherkusece89452014-09-09 23:13:38[diff] [blame]169 bool clockless_video_playback_enabled_for_testing_;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]170
dalecurtisc11e7bb2015-04-03 05:07:08[diff] [blame]171 // Used to defer underflow for video when audio is present.
172 base::CancelableClosure deferred_underflow_cb_;
173
174 // The amount of time to wait before declaring underflow if the video renderer
175 // runs out of data but the audio renderer still has enough.
176 base::TimeDelta video_underflow_threshold_;
177
xhwangbe9da702014-08-23 21:44:55[diff] [blame]178 base::WeakPtr<RendererImpl> weak_this_;
dmichael284c5e92014-12-09 20:02:47[diff] [blame]179 base::WeakPtrFactory<RendererImpl> weak_factory_;
xhwangbe9da702014-08-23 21:44:55[diff] [blame]180
181 DISALLOW_COPY_AND_ASSIGN(RendererImpl);
182};
183
184} // namespace media
185
servolkf54f5c8f2015-02-24 20:32:39[diff] [blame]186#endif // MEDIA_RENDERERS_RENDERER_IMPL_H_