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

Side by Side Diff: content/common/gpu/media/vaapi_video_decode_accelerator.h

Issue 490233002: VaapiVideoAccelerator: make Vaapi accelerator work with ozone (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 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 (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 // This file contains an implementation of VideoDecoderAccelerator 5 // This file contains an implementation of VideoDecoderAccelerator
6 // that utilizes hardware video decoder present on Intel CPUs. 6 // that utilizes hardware video decoder present on Intel CPUs.
7 7
8 #ifndef CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_ 8 #ifndef CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_
9 #define CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_ 9 #define CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_
10 10
11 #include <map> 11 #include <map>
12 #include <queue> 12 #include <queue>
13 #include <utility> 13 #include <utility>
14 #include <vector> 14 #include <vector>
15 15
16 #include "base/logging.h" 16 #include "base/logging.h"
17 #include "base/memory/linked_ptr.h"
Pawel Osciak 2014/08/25 01:13:23 linked_ptr is used in this file. Please keep this
18 #include "base/memory/shared_memory.h" 17 #include "base/memory/shared_memory.h"
19 #include "base/memory/weak_ptr.h" 18 #include "base/memory/weak_ptr.h"
20 #include "base/message_loop/message_loop.h" 19 #include "base/message_loop/message_loop.h"
21 #include "base/synchronization/condition_variable.h" 20 #include "base/synchronization/condition_variable.h"
22 #include "base/synchronization/lock.h" 21 #include "base/synchronization/lock.h"
23 #include "base/threading/non_thread_safe.h"
24 #include "base/threading/thread.h" 22 #include "base/threading/thread.h"
25 #include "content/common/content_export.h" 23 #include "content/common/content_export.h"
26 #include "content/common/gpu/media/vaapi_h264_decoder.h" 24 #include "content/common/gpu/media/vaapi_h264_decoder.h"
27 #include "content/common/gpu/media/vaapi_wrapper.h" 25 #include "content/common/gpu/media/vaapi_wrapper.h"
28 #include "media/base/bitstream_buffer.h" 26 #include "media/base/bitstream_buffer.h"
29 #include "media/video/picture.h" 27 #include "media/video/picture.h"
30 #include "media/video/video_decode_accelerator.h" 28 #include "media/video/video_decode_accelerator.h"
31 #include "ui/gl/gl_bindings.h" 29
30 namespace gfx {
31 class GLContext;
32 }; // namespace gfx
32 33
33 namespace content { 34 namespace content {
34 35
35 // Class to provide video decode acceleration for Intel systems with hardware 36 // Class to provide video decode acceleration for Intel systems with hardware
36 // support for it, and on which libva is available. 37 // support for it, and on which libva is available.
37 // Decoding tasks are performed in a separate decoding thread. 38 // Decoding tasks are performed in a separate decoding thread.
38 // 39 //
39 // Threading/life-cycle: this object is created & destroyed on the GPU 40 // Threading/life-cycle: this object is created & destroyed on the GPU
40 // ChildThread. A few methods on it are called on the decoder thread which is 41 // ChildThread. A few methods on it are called on the decoder thread which is
41 // stopped during |this->Destroy()|, so any tasks posted to the decoder thread 42 // stopped during |this->Destroy()|, so any tasks posted to the decoder thread
42 // can assume |*this| is still alive. See |weak_this_| below for more details. 43 // can assume |*this| is still alive. See |weak_this_| below for more details.
43 class CONTENT_EXPORT VaapiVideoDecodeAccelerator 44 class CONTENT_EXPORT VaapiVideoDecodeAccelerator
44 : public media::VideoDecodeAccelerator { 45 : public media::VideoDecodeAccelerator {
45 public: 46 public:
46 VaapiVideoDecodeAccelerator( 47 VaapiVideoDecodeAccelerator(
47 Display* x_display, 48 gfx::GLContext* gl_context,
48 const base::Callback<bool(void)>& make_context_current); 49 const base::Callback<bool(void)>& make_context_current);
49 virtual ~VaapiVideoDecodeAccelerator(); 50 virtual ~VaapiVideoDecodeAccelerator();
50 51
51 // media::VideoDecodeAccelerator implementation. 52 // media::VideoDecodeAccelerator implementation.
52 virtual bool Initialize(media::VideoCodecProfile profile, 53 virtual bool Initialize(media::VideoCodecProfile profile,
53 Client* client) OVERRIDE; 54 Client* client) OVERRIDE;
54 virtual void Decode(const media::BitstreamBuffer& bitstream_buffer) OVERRIDE; 55 virtual void Decode(const media::BitstreamBuffer& bitstream_buffer) OVERRIDE;
55 virtual void AssignPictureBuffers( 56 virtual void AssignPictureBuffers(
56 const std::vector<media::PictureBuffer>& buffers) OVERRIDE; 57 const std::vector<media::PictureBuffer>& buffers) OVERRIDE;
57 virtual void ReusePictureBuffer(int32 picture_buffer_id) OVERRIDE; 58 virtual void ReusePictureBuffer(int32 picture_buffer_id) OVERRIDE;
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after
116 void Cleanup(); 117 void Cleanup();
117 118
118 // Get a usable framebuffer configuration for use in binding textures 119 // Get a usable framebuffer configuration for use in binding textures
119 // or return false on failure. 120 // or return false on failure.
120 bool InitializeFBConfig(); 121 bool InitializeFBConfig();
121 122
122 // Callback for the decoder to execute when it wants us to output given 123 // Callback for the decoder to execute when it wants us to output given
123 // |va_surface|. 124 // |va_surface|.
124 void SurfaceReady(int32 input_id, const scoped_refptr<VASurface>& va_surface); 125 void SurfaceReady(int32 input_id, const scoped_refptr<VASurface>& va_surface);
125 126
126 // Represents a texture bound to an X Pixmap for output purposes.
127 class TFPPicture;
128
129 // Callback to be executed once we have a |va_surface| to be output and 127 // Callback to be executed once we have a |va_surface| to be output and
130 // an available |tfp_picture| to use for output. 128 // an available |picture| to use for output.
131 // Puts contents of |va_surface| into given |tfp_picture|, releases the 129 // Puts contents of |va_surface| into given |picture|, releases the
132 // surface and passes the resulting picture to client for output. 130 // surface and passes the resulting picture to client for output.
133 void OutputPicture(const scoped_refptr<VASurface>& va_surface, 131 void OutputPicture(const scoped_refptr<VASurface>& va_surface,
134 int32 input_id, 132 int32 input_id,
135 TFPPicture* tfp_picture); 133 VaapiWrapper::Picture* picture);
136 134
137 // Try to OutputPicture() if we have both a ready surface and picture. 135 // Try to OutputPicture() if we have both a ready surface and picture.
138 void TryOutputSurface(); 136 void TryOutputSurface();
139 137
140 // Called when a VASurface is no longer in use by the decoder or is not being 138 // Called when a VASurface is no longer in use by the decoder or is not being
141 // synced/waiting to be synced to a picture. Returns it to available surfaces 139 // synced/waiting to be synced to a picture. Returns it to available surfaces
142 // pool. 140 // pool.
143 void RecycleVASurfaceID(VASurfaceID va_surface_id); 141 void RecycleVASurfaceID(VASurfaceID va_surface_id);
144 142
145 // Initiate wait cycle for surfaces to be released before we release them 143 // Initiate wait cycle for surfaces to be released before we release them
146 // and allocate new ones, as requested by the decoder. 144 // and allocate new ones, as requested by the decoder.
147 void InitiateSurfaceSetChange(size_t num_pics, gfx::Size size); 145 void InitiateSurfaceSetChange(size_t num_pics, gfx::Size size);
148 // Check if the surfaces have been released or post ourselves for later. 146 // Check if the surfaces have been released or post ourselves for later.
149 void TryFinishSurfaceSetChange(); 147 void TryFinishSurfaceSetChange();
150 148
151 // Client-provided X/GLX state. 149 // Client-provided X/GLX state.
152 Display* x_display_; 150 // Display* x_display_;
spang 2014/08/22 17:20:23 what's this commented out code?
Pawel Osciak 2014/08/25 01:13:23 Please clean up all commented-out code in the whol
151 gfx::GLContext* gl_context_;
153 base::Callback<bool(void)> make_context_current_; 152 base::Callback<bool(void)> make_context_current_;
154 GLXFBConfig fb_config_; 153 // GLXFBConfig fb_config_;
155 154
156 // VAVDA state. 155 // VAVDA state.
157 enum State { 156 enum State {
158 // Initialize() not called yet or failed. 157 // Initialize() not called yet or failed.
159 kUninitialized, 158 kUninitialized,
160 // DecodeTask running. 159 // DecodeTask running.
161 kDecoding, 160 kDecoding,
162 // Resetting, waiting for decoder to finish current task and cleanup. 161 // Resetting, waiting for decoder to finish current task and cleanup.
163 kResetting, 162 kResetting,
164 // Flushing, waiting for decoder to finish current task and cleanup. 163 // Flushing, waiting for decoder to finish current task and cleanup.
(...skipping 24 matching lines...) Expand all
189 // Signalled when input buffers are queued onto the input_buffers_ queue. 188 // Signalled when input buffers are queued onto the input_buffers_ queue.
190 base::ConditionVariable input_ready_; 189 base::ConditionVariable input_ready_;
191 190
192 // Current input buffer at decoder. 191 // Current input buffer at decoder.
193 linked_ptr<InputBuffer> curr_input_buffer_; 192 linked_ptr<InputBuffer> curr_input_buffer_;
194 193
195 // Queue for incoming output buffers (texture ids). 194 // Queue for incoming output buffers (texture ids).
196 typedef std::queue<int32> OutputBuffers; 195 typedef std::queue<int32> OutputBuffers;
197 OutputBuffers output_buffers_; 196 OutputBuffers output_buffers_;
198 197
199 typedef std::map<int32, linked_ptr<TFPPicture> > TFPPictures; 198 typedef std::map<int32, linked_ptr<VaapiWrapper::Picture> > Pictures;
200 // All allocated TFPPictures, regardless of their current state. TFPPictures 199 // All allocated Pictures, regardless of their current state. Pictures
201 // are allocated once and destroyed at the end of decode. 200 // are allocated once and destroyed at the end of decode.
202 TFPPictures tfp_pictures_; 201 Pictures pictures_;
203 202
204 // Return a TFPPicture associated with given client-provided id. 203 // Return a TFPPicture associated with given client-provided id.
205 TFPPicture* TFPPictureById(int32 picture_buffer_id); 204 VaapiWrapper::Picture* PictureById(int32 picture_buffer_id);
206 205
207 // VA Surfaces no longer in use that can be passed back to the decoder for 206 // VA Surfaces no longer in use that can be passed back to the decoder for
208 // reuse, once it requests them. 207 // reuse, once it requests them.
209 std::list<VASurfaceID> available_va_surfaces_; 208 std::list<VASurfaceID> available_va_surfaces_;
210 // Signalled when output surfaces are queued onto the available_va_surfaces_ 209 // Signalled when output surfaces are queued onto the available_va_surfaces_
211 // queue. 210 // queue.
212 base::ConditionVariable surfaces_available_; 211 base::ConditionVariable surfaces_available_;
213 212
214 // Pending output requests from the decoder. When it indicates that we should 213 // Pending output requests from the decoder. When it indicates that we should
215 // output a surface and we have an available TFPPicture (i.e. texture) ready 214 // output a surface and we have an available Picture (i.e. texture) ready
216 // to use, we'll execute the callback passing the TFPPicture. The callback 215 // to use, we'll execute the callback passing the Picture. The callback
217 // will put the contents of the surface into the picture and return it to 216 // will put the contents of the surface into the picture and return it to
218 // the client, releasing the surface as well. 217 // the client, releasing the surface as well.
219 // If we don't have any available TFPPictures at the time when the decoder 218 // If we don't have any available Pictures at the time when the decoder
220 // requests output, we'll store the request on pending_output_cbs_ queue for 219 // requests output, we'll store the request on pending_output_cbs_ queue for
221 // later and run it once the client gives us more textures 220 // later and run it once the client gives us more textures
222 // via ReusePictureBuffer(). 221 // via ReusePictureBuffer().
223 typedef base::Callback<void(TFPPicture*)> OutputCB; 222 typedef base::Callback<void(VaapiWrapper::Picture*)> OutputCB;
224 std::queue<OutputCB> pending_output_cbs_; 223 std::queue<OutputCB> pending_output_cbs_;
225 224
226 // ChildThread's message loop 225 // ChildThread's message loop
227 base::MessageLoop* message_loop_; 226 base::MessageLoop* message_loop_;
228 227
229 // WeakPtr<> pointing to |this| for use in posting tasks from the decoder 228 // WeakPtr<> pointing to |this| for use in posting tasks from the decoder
230 // thread back to the ChildThread. Because the decoder thread is a member of 229 // thread back to the ChildThread. Because the decoder thread is a member of
231 // this class, any task running on the decoder thread is guaranteed that this 230 // this class, any task running on the decoder thread is guaranteed that this
232 // object is still alive. As a result, tasks posted from ChildThread to 231 // object is still alive. As a result, tasks posted from ChildThread to
233 // decoder thread should use base::Unretained(this), and tasks posted from the 232 // decoder thread should use base::Unretained(this), and tasks posted from the
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after
270 269
271 // The WeakPtrFactory for |weak_this_|. 270 // The WeakPtrFactory for |weak_this_|.
272 base::WeakPtrFactory<VaapiVideoDecodeAccelerator> weak_this_factory_; 271 base::WeakPtrFactory<VaapiVideoDecodeAccelerator> weak_this_factory_;
273 272
274 DISALLOW_COPY_AND_ASSIGN(VaapiVideoDecodeAccelerator); 273 DISALLOW_COPY_AND_ASSIGN(VaapiVideoDecodeAccelerator);
275 }; 274 };
276 275
277 } // namespace content 276 } // namespace content
278 277
279 #endif // CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_ 278 #endif // CONTENT_COMMON_GPU_MEDIA_VAAPI_VIDEO_DECODE_ACCELERATOR_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698