OLD | NEW |
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 #ifndef MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ | 5 #ifndef MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ |
6 #define MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ | 6 #define MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ |
7 | 7 |
8 #include <deque> | 8 #include <deque> |
9 | 9 |
10 #include "base/memory/ref_counted.h" | 10 #include "base/memory/ref_counted.h" |
| 11 #include "base/memory/scoped_vector.h" |
11 #include "base/memory/weak_ptr.h" | 12 #include "base/memory/weak_ptr.h" |
12 #include "base/synchronization/condition_variable.h" | 13 #include "base/synchronization/condition_variable.h" |
13 #include "base/synchronization/lock.h" | 14 #include "base/synchronization/lock.h" |
14 #include "base/threading/platform_thread.h" | 15 #include "base/threading/platform_thread.h" |
15 #include "media/base/decryptor.h" | 16 #include "media/base/decryptor.h" |
16 #include "media/base/demuxer_stream.h" | 17 #include "media/base/demuxer_stream.h" |
17 #include "media/base/pipeline_status.h" | 18 #include "media/base/pipeline_status.h" |
18 #include "media/base/video_decoder.h" | 19 #include "media/base/video_decoder.h" |
19 #include "media/base/video_frame.h" | 20 #include "media/base/video_frame.h" |
20 #include "media/base/video_renderer.h" | 21 #include "media/base/video_renderer.h" |
(...skipping 14 matching lines...) Expand all Loading... |
35 class MEDIA_EXPORT VideoRendererBase | 36 class MEDIA_EXPORT VideoRendererBase |
36 : public VideoRenderer, | 37 : public VideoRenderer, |
37 public base::PlatformThread::Delegate { | 38 public base::PlatformThread::Delegate { |
38 public: | 39 public: |
39 typedef base::Callback<void(const scoped_refptr<VideoFrame>&)> PaintCB; | 40 typedef base::Callback<void(const scoped_refptr<VideoFrame>&)> PaintCB; |
40 typedef base::Callback<void(bool)> SetOpaqueCB; | 41 typedef base::Callback<void(bool)> SetOpaqueCB; |
41 | 42 |
42 // Maximum duration of the last frame. | 43 // Maximum duration of the last frame. |
43 static base::TimeDelta kMaxLastFrameDuration(); | 44 static base::TimeDelta kMaxLastFrameDuration(); |
44 | 45 |
| 46 // |decoders| contains the VideoDecoders to use when initializing. |
| 47 // |
45 // |paint_cb| is executed on the video frame timing thread whenever a new | 48 // |paint_cb| is executed on the video frame timing thread whenever a new |
46 // frame is available for painting. | 49 // frame is available for painting. |
47 // | 50 // |
48 // |set_opaque_cb| is executed when the renderer is initialized to inform | 51 // |set_opaque_cb| is executed when the renderer is initialized to inform |
49 // the player whether the decoder's output will be opaque or not. | 52 // the player whether the decoder's output will be opaque or not. |
50 // | 53 // |
51 // Implementors should avoid doing any sort of heavy work in this method and | 54 // Implementors should avoid doing any sort of heavy work in this method and |
52 // instead post a task to a common/worker thread to handle rendering. Slowing | 55 // instead post a task to a common/worker thread to handle rendering. Slowing |
53 // down the video thread may result in losing synchronization with audio. | 56 // down the video thread may result in losing synchronization with audio. |
54 // | 57 // |
55 // Setting |drop_frames_| to true causes the renderer to drop expired frames. | 58 // Setting |drop_frames_| to true causes the renderer to drop expired frames. |
56 VideoRendererBase(const scoped_refptr<base::MessageLoopProxy>& message_loop, | 59 VideoRendererBase(const scoped_refptr<base::MessageLoopProxy>& message_loop, |
| 60 ScopedVector<VideoDecoder> decoders, |
57 const SetDecryptorReadyCB& set_decryptor_ready_cb, | 61 const SetDecryptorReadyCB& set_decryptor_ready_cb, |
58 const PaintCB& paint_cb, | 62 const PaintCB& paint_cb, |
59 const SetOpaqueCB& set_opaque_cb, | 63 const SetOpaqueCB& set_opaque_cb, |
60 bool drop_frames); | 64 bool drop_frames); |
61 virtual ~VideoRendererBase(); | 65 virtual ~VideoRendererBase(); |
62 | 66 |
63 // VideoRenderer implementation. | 67 // VideoRenderer implementation. |
64 virtual void Initialize(const scoped_refptr<DemuxerStream>& stream, | 68 virtual void Initialize(const scoped_refptr<DemuxerStream>& stream, |
65 const VideoDecoderList& decoders, | |
66 const PipelineStatusCB& init_cb, | 69 const PipelineStatusCB& init_cb, |
67 const StatisticsCB& statistics_cb, | 70 const StatisticsCB& statistics_cb, |
68 const TimeCB& max_time_cb, | 71 const TimeCB& max_time_cb, |
69 const NaturalSizeChangedCB& size_changed_cb, | 72 const NaturalSizeChangedCB& size_changed_cb, |
70 const base::Closure& ended_cb, | 73 const base::Closure& ended_cb, |
71 const PipelineStatusCB& error_cb, | 74 const PipelineStatusCB& error_cb, |
72 const TimeDeltaCB& get_time_cb, | 75 const TimeDeltaCB& get_time_cb, |
73 const TimeDeltaCB& get_duration_cb) OVERRIDE; | 76 const TimeDeltaCB& get_duration_cb) OVERRIDE; |
74 virtual void Play(const base::Closure& callback) OVERRIDE; | 77 virtual void Play(const base::Closure& callback) OVERRIDE; |
75 virtual void Pause(const base::Closure& callback) OVERRIDE; | 78 virtual void Pause(const base::Closure& callback) OVERRIDE; |
76 virtual void Flush(const base::Closure& callback) OVERRIDE; | 79 virtual void Flush(const base::Closure& callback) OVERRIDE; |
77 virtual void Preroll(base::TimeDelta time, | 80 virtual void Preroll(base::TimeDelta time, |
78 const PipelineStatusCB& cb) OVERRIDE; | 81 const PipelineStatusCB& cb) OVERRIDE; |
79 virtual void Stop(const base::Closure& callback) OVERRIDE; | 82 virtual void Stop(const base::Closure& callback) OVERRIDE; |
80 virtual void SetPlaybackRate(float playback_rate) OVERRIDE; | 83 virtual void SetPlaybackRate(float playback_rate) OVERRIDE; |
81 | 84 |
82 // PlatformThread::Delegate implementation. | 85 // PlatformThread::Delegate implementation. |
83 virtual void ThreadMain() OVERRIDE; | 86 virtual void ThreadMain() OVERRIDE; |
84 | 87 |
85 private: | 88 private: |
86 // Called when |decoder_selector_| selected the |selected_decoder|. | 89 // Called when |decoder_selector_| has selected |decoder| or is null if no |
87 // |decrypting_demuxer_stream| was also populated if a DecryptingDemuxerStream | 90 // decoder could be selected. |
| 91 // |
| 92 // |decrypting_demuxer_stream| is non-null if a DecryptingDemuxerStream was |
88 // created to help decrypt the encrypted stream. | 93 // created to help decrypt the encrypted stream. |
89 // Note: |decoder_selector| is passed here to keep the VideoDecoderSelector | |
90 // alive until OnDecoderSelected() finishes. | |
91 void OnDecoderSelected( | 94 void OnDecoderSelected( |
92 scoped_ptr<VideoDecoderSelector> decoder_selector, | 95 scoped_ptr<VideoDecoder> decoder, |
93 const scoped_refptr<VideoDecoder>& selected_decoder, | |
94 const scoped_refptr<DecryptingDemuxerStream>& decrypting_demuxer_stream); | 96 const scoped_refptr<DecryptingDemuxerStream>& decrypting_demuxer_stream); |
95 | 97 |
96 // Callback from the video decoder delivering decoded video frames and | 98 // Callback from the video decoder delivering decoded video frames and |
97 // reporting video decoder status. | 99 // reporting video decoder status. |
98 void FrameReady(VideoDecoder::Status status, | 100 void FrameReady(VideoDecoder::Status status, |
99 const scoped_refptr<VideoFrame>& frame); | 101 const scoped_refptr<VideoFrame>& frame); |
100 | 102 |
101 // Helper method for adding a frame to |ready_frames_|. | 103 // Helper method for adding a frame to |ready_frames_|. |
102 void AddReadyFrame_Locked(const scoped_refptr<VideoFrame>& frame); | 104 void AddReadyFrame_Locked(const scoped_refptr<VideoFrame>& frame); |
103 | 105 |
(...skipping 27 matching lines...) Expand all Loading... |
131 void PaintNextReadyFrame_Locked(); | 133 void PaintNextReadyFrame_Locked(); |
132 | 134 |
133 // Drops the next frame from |ready_frames_| and runs |statistics_cb_|. | 135 // Drops the next frame from |ready_frames_| and runs |statistics_cb_|. |
134 // | 136 // |
135 // A read is scheduled to replace the frame. | 137 // A read is scheduled to replace the frame. |
136 void DropNextReadyFrame_Locked(); | 138 void DropNextReadyFrame_Locked(); |
137 | 139 |
138 void ResetDecoder(); | 140 void ResetDecoder(); |
139 void StopDecoder(const base::Closure& callback); | 141 void StopDecoder(const base::Closure& callback); |
140 | 142 |
141 // Pops the front of |decoders|, assigns it to |decoder_| and then | |
142 // calls initialize on the new decoder. | |
143 void InitializeNextDecoder(const scoped_refptr<DemuxerStream>& demuxer_stream, | |
144 scoped_ptr<VideoDecoderList> decoders); | |
145 | |
146 // Called when |decoder_| initialization completes. | |
147 // |demuxer_stream| & |decoders| are used if initialization failed and | |
148 // InitializeNextDecoder() needs to be called again. | |
149 void OnDecoderInitDone(const scoped_refptr<DemuxerStream>& demuxer_stream, | |
150 scoped_ptr<VideoDecoderList> decoders, | |
151 PipelineStatus status); | |
152 | |
153 void TransitionToPrerolled_Locked(); | 143 void TransitionToPrerolled_Locked(); |
154 | 144 |
155 scoped_refptr<base::MessageLoopProxy> message_loop_; | 145 scoped_refptr<base::MessageLoopProxy> message_loop_; |
156 base::WeakPtrFactory<VideoRendererBase> weak_factory_; | 146 base::WeakPtrFactory<VideoRendererBase> weak_factory_; |
157 base::WeakPtr<VideoRendererBase> weak_this_; | 147 base::WeakPtr<VideoRendererBase> weak_this_; |
158 | 148 |
| 149 scoped_ptr<VideoDecoderSelector> decoder_selector_; |
| 150 |
159 // Used for accessing data members. | 151 // Used for accessing data members. |
160 base::Lock lock_; | 152 base::Lock lock_; |
161 | 153 |
162 SetDecryptorReadyCB set_decryptor_ready_cb_; | |
163 | |
164 // These two will be set by VideoDecoderSelector::SelectVideoDecoder(). | 154 // These two will be set by VideoDecoderSelector::SelectVideoDecoder(). |
165 scoped_refptr<VideoDecoder> decoder_; | 155 scoped_ptr<VideoDecoder> decoder_; |
166 scoped_refptr<DecryptingDemuxerStream> decrypting_demuxer_stream_; | 156 scoped_refptr<DecryptingDemuxerStream> decrypting_demuxer_stream_; |
167 | 157 |
168 // Queue of incoming frames yet to be painted. | 158 // Queue of incoming frames yet to be painted. |
169 typedef std::deque<scoped_refptr<VideoFrame> > VideoFrameQueue; | 159 typedef std::deque<scoped_refptr<VideoFrame> > VideoFrameQueue; |
170 VideoFrameQueue ready_frames_; | 160 VideoFrameQueue ready_frames_; |
171 | 161 |
172 // Keeps track of whether we received the end of stream buffer. | 162 // Keeps track of whether we received the end of stream buffer. |
173 bool received_end_of_stream_; | 163 bool received_end_of_stream_; |
174 | 164 |
175 // Used to signal |thread_| as frames are added to |frames_|. Rule of thumb: | 165 // Used to signal |thread_| as frames are added to |frames_|. Rule of thumb: |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
263 // either for calling |paint_cb_| or for dropping. Set to kNoTimestamp() | 253 // either for calling |paint_cb_| or for dropping. Set to kNoTimestamp() |
264 // during flushing. | 254 // during flushing. |
265 base::TimeDelta last_timestamp_; | 255 base::TimeDelta last_timestamp_; |
266 | 256 |
267 DISALLOW_COPY_AND_ASSIGN(VideoRendererBase); | 257 DISALLOW_COPY_AND_ASSIGN(VideoRendererBase); |
268 }; | 258 }; |
269 | 259 |
270 } // namespace media | 260 } // namespace media |
271 | 261 |
272 #endif // MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ | 262 #endif // MEDIA_FILTERS_VIDEO_RENDERER_BASE_H_ |
OLD | NEW |