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

Side by Side Diff: content/common/gpu/media/v4l2_slice_video_decode_accelerator.cc

Issue 852103002: Revert of Add accelerated video decoder interface, VP8 and H.264 implementations and hook up to V4L2SVDA (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 11 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
(Empty)
1 // Copyright 2015 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
5 #include <fcntl.h>
6 #include <linux/videodev2.h>
7 #include <poll.h>
8 #include <sys/eventfd.h>
9 #include <sys/ioctl.h>
10 #include <sys/mman.h>
11
12 #include "base/bind.h"
13 #include "base/bind_helpers.h"
14 #include "base/callback.h"
15 #include "base/callback_helpers.h"
16 #include "base/command_line.h"
17 #include "base/message_loop/message_loop_proxy.h"
18 #include "base/numerics/safe_conversions.h"
19 #include "base/strings/stringprintf.h"
20 #include "content/common/gpu/media/v4l2_slice_video_decode_accelerator.h"
21 #include "media/base/bind_to_current_loop.h"
22 #include "media/base/media_switches.h"
23 #include "ui/gl/scoped_binders.h"
24
25 #define LOGF(level) LOG(level) << __FUNCTION__ << "(): "
26 #define DVLOGF(level) DVLOG(level) << __FUNCTION__ << "(): "
27
28 #define NOTIFY_ERROR(x) \
29 do { \
30 LOG(ERROR) << "Setting error state:" << x; \
31 SetErrorState(x); \
32 } while (0)
33
34 #define IOCTL_OR_ERROR_RETURN_VALUE(type, arg, value) \
35 do { \
36 if (device_->Ioctl(type, arg) != 0) { \
37 PLOG(ERROR) << __FUNCTION__ << "(): ioctl() failed: " << #type; \
38 return value; \
39 } \
40 } while (0)
41
42 #define IOCTL_OR_ERROR_RETURN(type, arg) \
43 IOCTL_OR_ERROR_RETURN_VALUE(type, arg, ((void)0))
44
45 #define IOCTL_OR_ERROR_RETURN_FALSE(type, arg) \
46 IOCTL_OR_ERROR_RETURN_VALUE(type, arg, false)
47
48 #define IOCTL_OR_LOG_ERROR(type, arg) \
49 do { \
50 if (device_->Ioctl(type, arg) != 0) \
51 PLOG(ERROR) << __FUNCTION__ << "(): ioctl() failed: " << #type; \
52 } while (0)
53
54 namespace content {
55
56 class V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface
57 : public base::RefCounted<V4L2DecodeSurface> {
58 public:
59 using ReleaseCB = base::Callback<void(int)>;
60
61 V4L2DecodeSurface(int32 bitstream_id,
62 int input_record,
63 int output_record,
64 const ReleaseCB& release_cb);
65
66 // Mark the surface as decoded. This will also release all references, as
67 // they are not needed anymore.
68 void SetDecoded();
69 bool decoded() const { return decoded_; }
70
71 int32 bitstream_id() const { return bitstream_id_; }
72 int input_record() const { return input_record_; }
73 int output_record() const { return output_record_; }
74 uint32_t config_store() const { return config_store_; }
75
76 // Take references to each reference surface and keep them until the
77 // target surface is decoded.
78 void SetReferenceSurfaces(
79 const std::vector<scoped_refptr<V4L2DecodeSurface>>& ref_surfaces);
80
81 std::string ToString() const;
82
83 private:
84 friend class base::RefCounted<V4L2DecodeSurface>;
85 ~V4L2DecodeSurface();
86
87 int32 bitstream_id_;
88 int input_record_;
89 int output_record_;
90 uint32_t config_store_;
91
92 bool decoded_;
93 ReleaseCB release_cb_;
94
95 std::vector<scoped_refptr<V4L2DecodeSurface>> reference_surfaces_;
96
97 DISALLOW_COPY_AND_ASSIGN(V4L2DecodeSurface);
98 };
99
100 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface::V4L2DecodeSurface(
101 int32 bitstream_id,
102 int input_record,
103 int output_record,
104 const ReleaseCB& release_cb)
105 : bitstream_id_(bitstream_id),
106 input_record_(input_record),
107 output_record_(output_record),
108 config_store_(input_record + 1),
109 decoded_(false),
110 release_cb_(release_cb) {
111 }
112
113 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface::~V4L2DecodeSurface() {
114 DVLOGF(5) << "Releasing output record id=" << output_record_;
115 release_cb_.Run(output_record_);
116 }
117
118 void V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface::SetReferenceSurfaces(
119 const std::vector<scoped_refptr<V4L2DecodeSurface>>& ref_surfaces) {
120 DCHECK(reference_surfaces_.empty());
121 reference_surfaces_ = ref_surfaces;
122 }
123
124 void V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface::SetDecoded() {
125 DCHECK(!decoded_);
126 decoded_ = true;
127
128 // We can now drop references to all reference surfaces for this surface
129 // as we are done with decoding.
130 reference_surfaces_.clear();
131 }
132
133 std::string V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface::ToString()
134 const {
135 std::string out;
136 base::StringAppendF(&out, "Buffer %d -> %d. ", input_record_, output_record_);
137 base::StringAppendF(&out, "Reference surfaces:");
138 for (const auto& ref : reference_surfaces_) {
139 DCHECK_NE(ref->output_record(), output_record_);
140 base::StringAppendF(&out, " %d", ref->output_record());
141 }
142 return out;
143 }
144
145 V4L2SliceVideoDecodeAccelerator::InputRecord::InputRecord()
146 : input_id(-1),
147 address(nullptr),
148 length(0),
149 bytes_used(0),
150 at_device(false) {
151 }
152
153 V4L2SliceVideoDecodeAccelerator::OutputRecord::OutputRecord()
154 : at_device(false),
155 at_client(false),
156 picture_id(-1),
157 egl_image(EGL_NO_IMAGE_KHR),
158 egl_sync(EGL_NO_SYNC_KHR),
159 cleared(false) {
160 }
161
162 struct V4L2SliceVideoDecodeAccelerator::BitstreamBufferRef {
163 BitstreamBufferRef(
164 base::WeakPtr<VideoDecodeAccelerator::Client>& client,
165 const scoped_refptr<base::MessageLoopProxy>& client_message_loop_proxy,
166 base::SharedMemory* shm,
167 size_t size,
168 int32 input_id);
169 ~BitstreamBufferRef();
170 const base::WeakPtr<VideoDecodeAccelerator::Client> client;
171 const scoped_refptr<base::MessageLoopProxy> client_message_loop_proxy;
172 const scoped_ptr<base::SharedMemory> shm;
173 const size_t size;
174 off_t bytes_used;
175 const int32 input_id;
176 };
177
178 V4L2SliceVideoDecodeAccelerator::BitstreamBufferRef::BitstreamBufferRef(
179 base::WeakPtr<VideoDecodeAccelerator::Client>& client,
180 const scoped_refptr<base::MessageLoopProxy>& client_message_loop_proxy,
181 base::SharedMemory* shm,
182 size_t size,
183 int32 input_id)
184 : client(client),
185 client_message_loop_proxy(client_message_loop_proxy),
186 shm(shm),
187 size(size),
188 bytes_used(0),
189 input_id(input_id) {
190 }
191
192 V4L2SliceVideoDecodeAccelerator::BitstreamBufferRef::~BitstreamBufferRef() {
193 if (input_id >= 0) {
194 DVLOGF(5) << "returning input_id: " << input_id;
195 client_message_loop_proxy->PostTask(
196 FROM_HERE,
197 base::Bind(&VideoDecodeAccelerator::Client::NotifyEndOfBitstreamBuffer,
198 client, input_id));
199 }
200 }
201
202 struct V4L2SliceVideoDecodeAccelerator::EGLSyncKHRRef {
203 EGLSyncKHRRef(EGLDisplay egl_display, EGLSyncKHR egl_sync);
204 ~EGLSyncKHRRef();
205 EGLDisplay const egl_display;
206 EGLSyncKHR egl_sync;
207 };
208
209 V4L2SliceVideoDecodeAccelerator::EGLSyncKHRRef::EGLSyncKHRRef(
210 EGLDisplay egl_display,
211 EGLSyncKHR egl_sync)
212 : egl_display(egl_display), egl_sync(egl_sync) {
213 }
214
215 V4L2SliceVideoDecodeAccelerator::EGLSyncKHRRef::~EGLSyncKHRRef() {
216 // We don't check for eglDestroySyncKHR failures, because if we get here
217 // with a valid sync object, something went wrong and we are getting
218 // destroyed anyway.
219 if (egl_sync != EGL_NO_SYNC_KHR)
220 eglDestroySyncKHR(egl_display, egl_sync);
221 }
222
223 struct V4L2SliceVideoDecodeAccelerator::PictureRecord {
224 PictureRecord(bool cleared, const media::Picture& picture);
225 ~PictureRecord();
226 bool cleared; // Whether the texture is cleared and safe to render from.
227 media::Picture picture; // The decoded picture.
228 };
229
230 V4L2SliceVideoDecodeAccelerator::PictureRecord::PictureRecord(
231 bool cleared,
232 const media::Picture& picture)
233 : cleared(cleared), picture(picture) {
234 }
235
236 V4L2SliceVideoDecodeAccelerator::PictureRecord::~PictureRecord() {
237 }
238
239 class V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator
240 : public H264Decoder::H264Accelerator {
241 public:
242 V4L2H264Accelerator(V4L2SliceVideoDecodeAccelerator* v4l2_dec);
243 virtual ~V4L2H264Accelerator() override;
244
245 // H264Decoder::H264Accelerator implementation.
246 scoped_refptr<H264Picture> CreateH264Picture() override;
247
248 bool SubmitFrameMetadata(const media::H264SPS* sps,
249 const media::H264PPS* pps,
250 const H264DPB& dpb,
251 const H264Picture::Vector& ref_pic_listp0,
252 const H264Picture::Vector& ref_pic_listb0,
253 const H264Picture::Vector& ref_pic_listb1,
254 const scoped_refptr<H264Picture>& pic) override;
255
256 bool SubmitSlice(const media::H264PPS* pps,
257 const media::H264SliceHeader* slice_hdr,
258 const H264Picture::Vector& ref_pic_list0,
259 const H264Picture::Vector& ref_pic_list1,
260 const scoped_refptr<H264Picture>& pic,
261 const uint8_t* data,
262 size_t size) override;
263
264 bool SubmitDecode(const scoped_refptr<H264Picture>& pic) override;
265 bool OutputPicture(const scoped_refptr<H264Picture>& pic) override;
266
267 private:
268 // Max size of reference list.
269 static const size_t kDPBIndicesListSize = 32;
270 void H264PictureListToDPBIndicesList(const H264Picture::Vector& src_pic_list,
271 uint8_t dst_list[kDPBIndicesListSize]);
272
273 void H264DPBToV4L2DPB(
274 const H264DPB& dpb,
275 std::vector<scoped_refptr<V4L2DecodeSurface>>* ref_surfaces);
276
277 scoped_refptr<V4L2DecodeSurface> H264PictureToV4L2DecodeSurface(
278 const scoped_refptr<H264Picture>& pic);
279
280 size_t num_slices_;
281 V4L2SliceVideoDecodeAccelerator* v4l2_dec_;
282
283 // TODO(posciak): This should be queried from hardware once supported.
284 static const size_t kMaxSlices = 16;
285 struct v4l2_ctrl_h264_slice_param v4l2_slice_params_[kMaxSlices];
286 struct v4l2_ctrl_h264_decode_param v4l2_decode_param_;
287
288 DISALLOW_COPY_AND_ASSIGN(V4L2H264Accelerator);
289 };
290
291 class V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator
292 : public VP8Decoder::VP8Accelerator {
293 public:
294 V4L2VP8Accelerator(V4L2SliceVideoDecodeAccelerator* v4l2_dec);
295 ~V4L2VP8Accelerator() override;
296
297 // H264Decoder::VP8Accelerator implementation.
298 scoped_refptr<VP8Picture> CreateVP8Picture() override;
299
300 bool SubmitDecode(const scoped_refptr<VP8Picture>& pic,
301 const media::Vp8FrameHeader* frame_hdr,
302 const scoped_refptr<VP8Picture>& last_frame,
303 const scoped_refptr<VP8Picture>& golden_frame,
304 const scoped_refptr<VP8Picture>& alt_frame) override;
305
306 bool OutputPicture(const scoped_refptr<VP8Picture>& pic) override;
307
308 private:
309 scoped_refptr<V4L2DecodeSurface> VP8PictureToV4L2DecodeSurface(
310 const scoped_refptr<VP8Picture>& pic);
311
312 V4L2SliceVideoDecodeAccelerator* v4l2_dec_;
313
314 DISALLOW_COPY_AND_ASSIGN(V4L2VP8Accelerator);
315 };
316
317 // Codec-specific subclasses of software decoder picture classes.
318 // This allows us to keep decoders oblivious of our implementation details.
319 class V4L2H264Picture : public H264Picture {
320 public:
321 V4L2H264Picture(const scoped_refptr<
322 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>& dec_surface);
323 virtual ~V4L2H264Picture() override;
324
325 V4L2H264Picture* AsV4L2H264Picture() override { return this; }
326 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
327 dec_surface() {
328 return dec_surface_;
329 }
330
331 private:
332 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
333 dec_surface_;
334
335 DISALLOW_COPY_AND_ASSIGN(V4L2H264Picture);
336 };
337
338 V4L2H264Picture::V4L2H264Picture(const scoped_refptr<
339 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>& dec_surface)
340 : dec_surface_(dec_surface) {
341 }
342
343 V4L2H264Picture::~V4L2H264Picture() {
344 }
345
346 class V4L2VP8Picture : public VP8Picture {
347 public:
348 V4L2VP8Picture(const scoped_refptr<
349 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>& dec_surface);
350 virtual ~V4L2VP8Picture() override;
351
352 V4L2VP8Picture* AsV4L2VP8Picture() override { return this; }
353 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
354 dec_surface() {
355 return dec_surface_;
356 }
357
358 private:
359 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
360 dec_surface_;
361
362 DISALLOW_COPY_AND_ASSIGN(V4L2VP8Picture);
363 };
364
365 V4L2VP8Picture::V4L2VP8Picture(const scoped_refptr<
366 V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>& dec_surface)
367 : dec_surface_(dec_surface) {
368 }
369
370 V4L2VP8Picture::~V4L2VP8Picture() {
371 }
372
373 V4L2SliceVideoDecodeAccelerator::V4L2SliceVideoDecodeAccelerator(
374 const scoped_refptr<V4L2Device>& device,
375 EGLDisplay egl_display,
376 EGLContext egl_context,
377 const base::WeakPtr<Client>& io_client,
378 const base::Callback<bool(void)>& make_context_current,
379 const scoped_refptr<base::MessageLoopProxy>& io_message_loop_proxy)
380 : input_planes_count_(0),
381 output_planes_count_(0),
382 child_message_loop_proxy_(base::MessageLoopProxy::current()),
383 io_message_loop_proxy_(io_message_loop_proxy),
384 io_client_(io_client),
385 device_(device),
386 decoder_thread_("V4L2SliceVideoDecodeAcceleratorThread"),
387 device_poll_thread_("V4L2SliceVideoDecodeAcceleratorDevicePollThread"),
388 input_streamon_(false),
389 input_buffer_queued_count_(0),
390 output_streamon_(false),
391 output_buffer_queued_count_(0),
392 video_profile_(media::VIDEO_CODEC_PROFILE_UNKNOWN),
393 output_format_fourcc_(0),
394 output_dpb_size_(0),
395 state_(kUninitialized),
396 decoder_flushing_(false),
397 decoder_resetting_(false),
398 surface_set_change_pending_(false),
399 picture_clearing_count_(0),
400 pictures_assigned_(false, false),
401 make_context_current_(make_context_current),
402 egl_display_(egl_display),
403 egl_context_(egl_context),
404 weak_this_factory_(this) {
405 weak_this_ = weak_this_factory_.GetWeakPtr();
406 }
407
408 V4L2SliceVideoDecodeAccelerator::~V4L2SliceVideoDecodeAccelerator() {
409 DVLOGF(2);
410
411 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
412 DCHECK(!decoder_thread_.IsRunning());
413 DCHECK(!device_poll_thread_.IsRunning());
414
415 DCHECK(input_buffer_map_.empty());
416 DCHECK(output_buffer_map_.empty());
417 }
418
419 void V4L2SliceVideoDecodeAccelerator::NotifyError(Error error) {
420 if (!child_message_loop_proxy_->BelongsToCurrentThread()) {
421 child_message_loop_proxy_->PostTask(
422 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::NotifyError,
423 weak_this_, error));
424 return;
425 }
426
427 if (client_) {
428 client_->NotifyError(error);
429 client_ptr_factory_.reset();
430 }
431 }
432
433 bool V4L2SliceVideoDecodeAccelerator::Initialize(
434 media::VideoCodecProfile profile,
435 VideoDecodeAccelerator::Client* client) {
436 DVLOGF(3) << "profile: " << profile;
437 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
438 DCHECK_EQ(state_, kUninitialized);
439
440 client_ptr_factory_.reset(
441 new base::WeakPtrFactory<VideoDecodeAccelerator::Client>(client));
442 client_ = client_ptr_factory_->GetWeakPtr();
443
444 video_profile_ = profile;
445
446 if (video_profile_ >= media::H264PROFILE_MIN &&
447 video_profile_ <= media::H264PROFILE_MAX) {
448 h264_accelerator_.reset(new V4L2H264Accelerator(this));
449 decoder_.reset(new H264Decoder(h264_accelerator_.get()));
450 } else if (video_profile_ >= media::VP8PROFILE_MIN &&
451 video_profile_ <= media::VP8PROFILE_MAX) {
452 vp8_accelerator_.reset(new V4L2VP8Accelerator(this));
453 decoder_.reset(new VP8Decoder(vp8_accelerator_.get()));
454 } else {
455 DLOG(ERROR) << "Unsupported profile " << video_profile_;
456 return false;
457 }
458
459 // TODO(posciak): This needs to be queried once supported.
460 input_planes_count_ = 1;
461 output_planes_count_ = 1;
462
463 if (egl_display_ == EGL_NO_DISPLAY) {
464 LOG(ERROR) << "Initialize(): could not get EGLDisplay";
465 return false;
466 }
467
468 // We need the context to be initialized to query extensions.
469 if (!make_context_current_.Run()) {
470 LOG(ERROR) << "Initialize(): could not make context current";
471 return false;
472 }
473
474 if (!gfx::g_driver_egl.ext.b_EGL_KHR_fence_sync) {
475 LOG(ERROR) << "Initialize(): context does not have EGL_KHR_fence_sync";
476 return false;
477 }
478
479 // Capabilities check.
480 struct v4l2_capability caps;
481 const __u32 kCapsRequired =
482 V4L2_CAP_VIDEO_CAPTURE_MPLANE |
483 V4L2_CAP_VIDEO_OUTPUT_MPLANE |
484 V4L2_CAP_STREAMING;
485 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_QUERYCAP, &caps);
486 if ((caps.capabilities & kCapsRequired) != kCapsRequired) {
487 DLOG(ERROR) << "Initialize(): ioctl() failed: VIDIOC_QUERYCAP"
488 ", caps check failed: 0x" << std::hex << caps.capabilities;
489 return false;
490 }
491
492 if (!SetupFormats())
493 return false;
494
495 if (!decoder_thread_.Start()) {
496 DLOG(ERROR) << "Initialize(): device thread failed to start";
497 return false;
498 }
499 decoder_thread_proxy_ = decoder_thread_.message_loop_proxy();
500
501 state_ = kInitialized;
502
503 // InitializeTask will NOTIFY_ERROR on failure.
504 decoder_thread_proxy_->PostTask(
505 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::InitializeTask,
506 base::Unretained(this)));
507
508 DVLOGF(1) << "V4L2SliceVideoDecodeAccelerator initialized";
509 return true;
510 }
511
512 void V4L2SliceVideoDecodeAccelerator::InitializeTask() {
513 DVLOGF(3);
514 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
515 DCHECK_EQ(state_, kInitialized);
516
517 if (!CreateInputBuffers())
518 NOTIFY_ERROR(PLATFORM_FAILURE);
519
520 // Output buffers will be created once decoder gives us information
521 // about their size and required count.
522 state_ = kDecoding;
523 }
524
525 void V4L2SliceVideoDecodeAccelerator::Destroy() {
526 DVLOGF(3);
527 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
528
529 if (decoder_thread_.IsRunning()) {
530 decoder_thread_proxy_->PostTask(
531 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::DestroyTask,
532 base::Unretained(this)));
533
534 // Wait for tasks to finish/early-exit.
535 decoder_thread_.Stop();
536 }
537
538 delete this;
539 DVLOGF(3) << "Destroyed";
540 }
541
542 void V4L2SliceVideoDecodeAccelerator::DestroyTask() {
543 DVLOGF(3);
544 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
545
546 state_ = kError;
547
548 decoder_->Reset();
549
550 decoder_current_bitstream_buffer_.reset();
551 while (!decoder_input_queue_.empty())
552 decoder_input_queue_.pop();
553
554 // Stop streaming and the device_poll_thread_.
555 StopDevicePoll(false);
556
557 DestroyInputBuffers();
558 DestroyOutputs(false);
559
560 DCHECK(surfaces_at_device_.empty());
561 DCHECK(surfaces_at_display_.empty());
562 DCHECK(decoder_display_queue_.empty());
563 }
564
565 bool V4L2SliceVideoDecodeAccelerator::SetupFormats() {
566 DCHECK_EQ(state_, kUninitialized);
567
568 __u32 input_format_fourcc =
569 V4L2Device::VideoCodecProfileToV4L2PixFmt(video_profile_, true);
570 if (!input_format_fourcc) {
571 NOTREACHED();
572 return false;
573 }
574
575 size_t input_size;
576 if (base::CommandLine::ForCurrentProcess()->HasSwitch(
577 switches::kIgnoreResolutionLimitsForAcceleratedVideoDecode))
578 input_size = kInputBufferMaxSizeFor4k;
579 else
580 input_size = kInputBufferMaxSizeFor1080p;
581
582 struct v4l2_format format;
583 memset(&format, 0, sizeof(format));
584 format.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
585 format.fmt.pix_mp.pixelformat = input_format_fourcc;
586 format.fmt.pix_mp.plane_fmt[0].sizeimage = input_size;
587 format.fmt.pix_mp.num_planes = input_planes_count_;
588 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_S_FMT, &format);
589
590 // We have to set up the format for output, because the driver may not allow
591 // changing it once we start streaming; whether it can support our chosen
592 // output format or not may depend on the input format.
593 struct v4l2_fmtdesc fmtdesc;
594 memset(&fmtdesc, 0, sizeof(fmtdesc));
595 fmtdesc.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
596 output_format_fourcc_ = 0;
597 while (device_->Ioctl(VIDIOC_ENUM_FMT, &fmtdesc) == 0) {
598 if (device_->CanCreateEGLImageFrom(fmtdesc.pixelformat)) {
599 output_format_fourcc_ = fmtdesc.pixelformat;
600 break;
601 }
602 ++fmtdesc.index;
603 }
604
605 if (output_format_fourcc_ == 0) {
606 LOG(ERROR) << "Could not find a usable output format";
607 return false;
608 }
609
610 // Only set fourcc for output; resolution, etc., will come from the
611 // driver once it extracts it from the stream.
612 memset(&format, 0, sizeof(format));
613 format.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
614 format.fmt.pix_mp.pixelformat = output_format_fourcc_;
615 format.fmt.pix_mp.num_planes = output_planes_count_;
616 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_S_FMT, &format);
617
618 return true;
619 }
620
621 bool V4L2SliceVideoDecodeAccelerator::CreateInputBuffers() {
622 DVLOGF(3);
623 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
624 DCHECK(!input_streamon_);
625 DCHECK(input_buffer_map_.empty());
626
627 struct v4l2_requestbuffers reqbufs;
628 memset(&reqbufs, 0, sizeof(reqbufs));
629 reqbufs.count = kNumInputBuffers;
630 reqbufs.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
631 reqbufs.memory = V4L2_MEMORY_MMAP;
632 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_REQBUFS, &reqbufs);
633 if (reqbufs.count < kNumInputBuffers) {
634 PLOG(ERROR) << "Could not allocate enough output buffers";
635 return false;
636 }
637 input_buffer_map_.resize(reqbufs.count);
638 for (size_t i = 0; i < input_buffer_map_.size(); ++i) {
639 free_input_buffers_.push_back(i);
640
641 // Query for the MEMORY_MMAP pointer.
642 struct v4l2_plane planes[VIDEO_MAX_PLANES];
643 struct v4l2_buffer buffer;
644 memset(&buffer, 0, sizeof(buffer));
645 memset(planes, 0, sizeof(planes));
646 buffer.index = i;
647 buffer.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
648 buffer.memory = V4L2_MEMORY_MMAP;
649 buffer.m.planes = planes;
650 buffer.length = input_planes_count_;
651 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_QUERYBUF, &buffer);
652 void* address = device_->Mmap(nullptr,
653 buffer.m.planes[0].length,
654 PROT_READ | PROT_WRITE,
655 MAP_SHARED,
656 buffer.m.planes[0].m.mem_offset);
657 if (address == MAP_FAILED) {
658 PLOG(ERROR) << "CreateInputBuffers(): mmap() failed";
659 return false;
660 }
661 input_buffer_map_[i].address = address;
662 input_buffer_map_[i].length = buffer.m.planes[0].length;
663 }
664
665 return true;
666 }
667
668 bool V4L2SliceVideoDecodeAccelerator::CreateOutputBuffers() {
669 DVLOGF(3);
670 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
671 DCHECK(!output_streamon_);
672 DCHECK(output_buffer_map_.empty());
673 DCHECK(surfaces_at_display_.empty());
674 DCHECK(surfaces_at_device_.empty());
675
676 frame_buffer_size_ = decoder_->GetPicSize();
677 output_dpb_size_ = decoder_->GetRequiredNumOfPictures();
678
679 DCHECK_GT(output_dpb_size_, 0u);
680 DCHECK(!frame_buffer_size_.IsEmpty());
681
682 struct v4l2_format format;
683 memset(&format, 0, sizeof(format));
684 format.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
685 format.fmt.pix_mp.pixelformat = output_format_fourcc_;
686 format.fmt.pix_mp.width = frame_buffer_size_.width();
687 format.fmt.pix_mp.height = frame_buffer_size_.height();
688 format.fmt.pix_mp.num_planes = input_planes_count_;
689
690 if (device_->Ioctl(VIDIOC_S_FMT, &format) != 0) {
691 PLOG(ERROR) << "Failed setting format to: " << output_format_fourcc_;
692 NOTIFY_ERROR(PLATFORM_FAILURE);
693 return false;
694 }
695
696 struct v4l2_requestbuffers reqbufs;
697 memset(&reqbufs, 0, sizeof(reqbufs));
698 reqbufs.count = output_dpb_size_;
699 reqbufs.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
700 reqbufs.memory = V4L2_MEMORY_MMAP;
701 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_REQBUFS, &reqbufs);
702
703 if (reqbufs.count < output_dpb_size_) {
704 PLOG(ERROR) << "Could not allocate enough output buffers";
705 return false;
706 }
707
708 output_buffer_map_.resize(reqbufs.count);
709
710 DVLOGF(3) << "buffer_count=" << output_buffer_map_.size()
711 << ", size=" << frame_buffer_size_.ToString();
712
713 child_message_loop_proxy_->PostTask(
714 FROM_HERE,
715 base::Bind(&VideoDecodeAccelerator::Client::ProvidePictureBuffers,
716 client_, output_buffer_map_.size(), frame_buffer_size_,
717 device_->GetTextureTarget()));
718
719 // Wait for the client to call AssignPictureBuffers() on the Child thread.
720 // We do this, because if we continue decoding without finishing buffer
721 // allocation, we may end up Resetting before AssignPictureBuffers arrives,
722 // resulting in unnecessary complications and subtle bugs.
723 pictures_assigned_.Wait();
724
725 return true;
726 }
727
728 void V4L2SliceVideoDecodeAccelerator::DestroyInputBuffers() {
729 DVLOGF(3);
730 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread() ||
731 !decoder_thread_.IsRunning());
732 DCHECK(!input_streamon_);
733
734 for (auto& input_record : input_buffer_map_) {
735 if (input_record.address != nullptr)
736 device_->Munmap(input_record.address, input_record.length);
737 }
738
739 struct v4l2_requestbuffers reqbufs;
740 memset(&reqbufs, 0, sizeof(reqbufs));
741 reqbufs.count = 0;
742 reqbufs.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
743 reqbufs.memory = V4L2_MEMORY_MMAP;
744 IOCTL_OR_LOG_ERROR(VIDIOC_REQBUFS, &reqbufs);
745
746 input_buffer_map_.clear();
747 free_input_buffers_.clear();
748 }
749
750 void V4L2SliceVideoDecodeAccelerator::DismissPictures(
751 std::vector<int32> picture_buffer_ids,
752 base::WaitableEvent* done) {
753 DVLOGF(3);
754 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
755
756 for (auto picture_buffer_id : picture_buffer_ids) {
757 DVLOGF(1) << "dismissing PictureBuffer id=" << picture_buffer_id;
758 client_->DismissPictureBuffer(picture_buffer_id);
759 }
760
761 done->Signal();
762 }
763
764 void V4L2SliceVideoDecodeAccelerator::DevicePollTask(bool poll_device) {
765 DVLOGF(4);
766 DCHECK_EQ(device_poll_thread_.message_loop(), base::MessageLoop::current());
767
768 bool event_pending;
769 if (!device_->Poll(poll_device, &event_pending)) {
770 NOTIFY_ERROR(PLATFORM_FAILURE);
771 return;
772 }
773
774 // All processing should happen on ServiceDeviceTask(), since we shouldn't
775 // touch encoder state from this thread.
776 decoder_thread_proxy_->PostTask(
777 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::ServiceDeviceTask,
778 base::Unretained(this)));
779 }
780
781 void V4L2SliceVideoDecodeAccelerator::ServiceDeviceTask() {
782 DVLOGF(4);
783 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
784
785 // ServiceDeviceTask() should only ever be scheduled from DevicePollTask().
786
787 Dequeue();
788 SchedulePollIfNeeded();
789 }
790
791 void V4L2SliceVideoDecodeAccelerator::SchedulePollIfNeeded() {
792 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
793
794 if (!device_poll_thread_.IsRunning()) {
795 DVLOGF(2) << "Device poll thread stopped, will not schedule poll";
796 return;
797 }
798
799 DCHECK(input_streamon_ || output_streamon_);
800
801 if (input_buffer_queued_count_ + output_buffer_queued_count_ == 0) {
802 DVLOGF(4) << "No buffers queued, will not schedule poll";
803 return;
804 }
805
806 DVLOGF(4) << "Scheduling device poll task";
807
808 device_poll_thread_.message_loop()->PostTask(
809 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::DevicePollTask,
810 base::Unretained(this), true));
811
812 DVLOGF(2) << "buffer counts: "
813 << "INPUT[" << decoder_input_queue_.size() << "]"
814 << " => DEVICE["
815 << free_input_buffers_.size() << "+"
816 << input_buffer_queued_count_ << "/"
817 << input_buffer_map_.size() << "]->["
818 << free_output_buffers_.size() << "+"
819 << output_buffer_queued_count_ << "/"
820 << output_buffer_map_.size() << "]"
821 << " => DISPLAYQ[" << decoder_display_queue_.size() << "]"
822 << " => CLIENT[" << surfaces_at_display_.size() << "]";
823 }
824
825 void V4L2SliceVideoDecodeAccelerator::Enqueue(
826 const scoped_refptr<V4L2DecodeSurface>& dec_surface) {
827 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
828
829 const int old_inputs_queued = input_buffer_queued_count_;
830 const int old_outputs_queued = output_buffer_queued_count_;
831
832 if (!EnqueueInputRecord(dec_surface->input_record(),
833 dec_surface->config_store())) {
834 DVLOGF(1) << "Failed queueing an input buffer";
835 NOTIFY_ERROR(PLATFORM_FAILURE);
836 return;
837 }
838
839 if (!EnqueueOutputRecord(dec_surface->output_record())) {
840 DVLOGF(1) << "Failed queueing an output buffer";
841 NOTIFY_ERROR(PLATFORM_FAILURE);
842 return;
843 }
844
845 bool inserted =
846 surfaces_at_device_.insert(std::make_pair(dec_surface->output_record(),
847 dec_surface)).second;
848 DCHECK(inserted);
849
850 if (old_inputs_queued == 0 && old_outputs_queued == 0)
851 SchedulePollIfNeeded();
852 }
853
854 void V4L2SliceVideoDecodeAccelerator::Dequeue() {
855 DVLOGF(3);
856 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
857
858 struct v4l2_buffer dqbuf;
859 struct v4l2_plane planes[VIDEO_MAX_PLANES];
860 while (input_buffer_queued_count_ > 0) {
861 DCHECK(input_streamon_);
862 memset(&dqbuf, 0, sizeof(dqbuf));
863 memset(&planes, 0, sizeof(planes));
864 dqbuf.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
865 dqbuf.memory = V4L2_MEMORY_USERPTR;
866 dqbuf.m.planes = planes;
867 dqbuf.length = input_planes_count_;
868 if (device_->Ioctl(VIDIOC_DQBUF, &dqbuf) != 0) {
869 if (errno == EAGAIN) {
870 // EAGAIN if we're just out of buffers to dequeue.
871 break;
872 }
873 PLOG(ERROR) << "ioctl() failed: VIDIOC_DQBUF";
874 NOTIFY_ERROR(PLATFORM_FAILURE);
875 return;
876 }
877 InputRecord& input_record = input_buffer_map_[dqbuf.index];
878 DCHECK(input_record.at_device);
879 input_record.at_device = false;
880 input_record.input_id = -1;
881 input_record.bytes_used = 0;
882 free_input_buffers_.push_back(dqbuf.index);
883 input_buffer_queued_count_--;
884 DVLOGF(4) << "Dequeued input=" << dqbuf.index
885 << " count: " << input_buffer_queued_count_;
886 }
887
888 while (output_buffer_queued_count_ > 0) {
889 DCHECK(output_streamon_);
890 memset(&dqbuf, 0, sizeof(dqbuf));
891 memset(&planes, 0, sizeof(planes));
892 dqbuf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
893 dqbuf.memory = V4L2_MEMORY_MMAP;
894 dqbuf.m.planes = planes;
895 dqbuf.length = output_planes_count_;
896 if (device_->Ioctl(VIDIOC_DQBUF, &dqbuf) != 0) {
897 if (errno == EAGAIN) {
898 // EAGAIN if we're just out of buffers to dequeue.
899 break;
900 }
901 PLOG(ERROR) << "ioctl() failed: VIDIOC_DQBUF";
902 NOTIFY_ERROR(PLATFORM_FAILURE);
903 return;
904 }
905 OutputRecord& output_record = output_buffer_map_[dqbuf.index];
906 DCHECK(output_record.at_device);
907 output_record.at_device = false;
908 DCHECK_NE(output_record.picture_id, -1);
909 output_buffer_queued_count_--;
910 DVLOGF(3) << "Dequeued output=" << dqbuf.index
911 << " count " << output_buffer_queued_count_;
912
913 V4L2DecodeSurfaceByOutputId::iterator it =
914 surfaces_at_device_.find(dqbuf.index);
915 if (it == surfaces_at_device_.end()) {
916 DLOG(ERROR) << "Got invalid surface from device.";
917 NOTIFY_ERROR(PLATFORM_FAILURE);
918 }
919
920 it->second->SetDecoded();
921 surfaces_at_device_.erase(it);
922 }
923
924 // A frame was decoded, see if we can output it.
925 TryOutputSurfaces();
926
927 ProcessPendingEventsIfNeeded();
928 }
929
930 void V4L2SliceVideoDecodeAccelerator::ProcessPendingEventsIfNeeded() {
931 // Process pending events, if any, in the correct order.
932 // We always first process the surface set change, as it is an internal
933 // event from the decoder and interleaving it with external requests would
934 // put the decoder in an undefined state.
935 FinishSurfaceSetChangeIfNeeded();
936
937 // Process external (client) requests.
938 FinishFlushIfNeeded();
939 FinishResetIfNeeded();
940 }
941
942 void V4L2SliceVideoDecodeAccelerator::ReuseOutputBuffer(int index) {
943 DCHECK_LT(index, static_cast<int>(output_buffer_map_.size()));
944 DVLOGF(4) << "Reusing output buffer, index=" << index;
945 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
946
947 OutputRecord& output_record = output_buffer_map_[index];
948 DCHECK(!output_record.at_device);
949 output_record.at_client = false;
950
951 free_output_buffers_.push_back(index);
952
953 ScheduleDecodeBufferTaskIfNeeded();
954 }
955
956 bool V4L2SliceVideoDecodeAccelerator::EnqueueInputRecord(
957 int index,
958 uint32_t config_store) {
959 DVLOGF(3);
960 DCHECK_LT(index, static_cast<int>(input_buffer_map_.size()));
961 DCHECK_GT(config_store, 0u);
962
963 // Enqueue an input (VIDEO_OUTPUT) buffer for an input video frame.
964 InputRecord& input_record = input_buffer_map_[index];
965 DCHECK(!input_record.at_device);
966 struct v4l2_buffer qbuf;
967 struct v4l2_plane qbuf_planes[VIDEO_MAX_PLANES];
968 memset(&qbuf, 0, sizeof(qbuf));
969 memset(qbuf_planes, 0, sizeof(qbuf_planes));
970 qbuf.index = index;
971 qbuf.type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
972 qbuf.memory = V4L2_MEMORY_MMAP;
973 qbuf.m.planes = qbuf_planes;
974 qbuf.m.planes[0].bytesused = input_record.bytes_used;
975 qbuf.length = input_planes_count_;
976 qbuf.config_store = config_store;
977 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_QBUF, &qbuf);
978 input_record.at_device = true;
979 input_buffer_queued_count_++;
980 DVLOGF(4) << "Enqueued input=" << qbuf.index
981 << " count: " << input_buffer_queued_count_;
982
983 return true;
984 }
985
986 bool V4L2SliceVideoDecodeAccelerator::EnqueueOutputRecord(int index) {
987 DVLOGF(3);
988 DCHECK_LT(index, static_cast<int>(output_buffer_map_.size()));
989
990 // Enqueue an output (VIDEO_CAPTURE) buffer.
991 OutputRecord& output_record = output_buffer_map_[index];
992 DCHECK(!output_record.at_device);
993 DCHECK(!output_record.at_client);
994 DCHECK_NE(output_record.egl_image, EGL_NO_IMAGE_KHR);
995 DCHECK_NE(output_record.picture_id, -1);
996 if (output_record.egl_sync != EGL_NO_SYNC_KHR) {
997 // If we have to wait for completion, wait. Note that
998 // free_output_buffers_ is a FIFO queue, so we always wait on the
999 // buffer that has been in the queue the longest.
1000 if (eglClientWaitSyncKHR(egl_display_, output_record.egl_sync, 0,
1001 EGL_FOREVER_KHR) == EGL_FALSE) {
1002 // This will cause tearing, but is safe otherwise.
1003 DVLOGF(1) << "eglClientWaitSyncKHR failed!";
1004 }
1005 if (eglDestroySyncKHR(egl_display_, output_record.egl_sync) != EGL_TRUE) {
1006 LOGF(ERROR) << "eglDestroySyncKHR failed!";
1007 NOTIFY_ERROR(PLATFORM_FAILURE);
1008 return false;
1009 }
1010 output_record.egl_sync = EGL_NO_SYNC_KHR;
1011 }
1012
1013 struct v4l2_buffer qbuf;
1014 struct v4l2_plane qbuf_planes[VIDEO_MAX_PLANES];
1015 memset(&qbuf, 0, sizeof(qbuf));
1016 memset(qbuf_planes, 0, sizeof(qbuf_planes));
1017 qbuf.index = index;
1018 qbuf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
1019 qbuf.memory = V4L2_MEMORY_MMAP;
1020 qbuf.m.planes = qbuf_planes;
1021 qbuf.length = output_planes_count_;
1022 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_QBUF, &qbuf);
1023 output_record.at_device = true;
1024 output_buffer_queued_count_++;
1025 DVLOGF(4) << "Enqueued output=" << qbuf.index
1026 << " count: " << output_buffer_queued_count_;
1027
1028 return true;
1029 }
1030
1031 bool V4L2SliceVideoDecodeAccelerator::StartDevicePoll() {
1032 DVLOGF(3) << "Starting device poll";
1033 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1034 DCHECK(!device_poll_thread_.IsRunning());
1035
1036 // Start up the device poll thread and schedule its first DevicePollTask().
1037 if (!device_poll_thread_.Start()) {
1038 DLOG(ERROR) << "StartDevicePoll(): Device thread failed to start";
1039 NOTIFY_ERROR(PLATFORM_FAILURE);
1040 return false;
1041 }
1042 if (!input_streamon_) {
1043 __u32 type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
1044 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_STREAMON, &type);
1045 input_streamon_ = true;
1046 }
1047
1048 if (!output_streamon_) {
1049 __u32 type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
1050 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_STREAMON, &type);
1051 output_streamon_ = true;
1052 }
1053
1054 device_poll_thread_.message_loop()->PostTask(
1055 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::DevicePollTask,
1056 base::Unretained(this), true));
1057
1058 return true;
1059 }
1060
1061 bool V4L2SliceVideoDecodeAccelerator::StopDevicePoll(bool keep_input_state) {
1062 DVLOGF(3) << "Stopping device poll";
1063 if (decoder_thread_.IsRunning())
1064 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1065
1066 // Signal the DevicePollTask() to stop, and stop the device poll thread.
1067 if (!device_->SetDevicePollInterrupt()) {
1068 PLOG(ERROR) << "SetDevicePollInterrupt(): failed";
1069 NOTIFY_ERROR(PLATFORM_FAILURE);
1070 return false;
1071 }
1072 device_poll_thread_.Stop();
1073 DVLOGF(3) << "Device poll thread stopped";
1074
1075 // Clear the interrupt now, to be sure.
1076 if (!device_->ClearDevicePollInterrupt()) {
1077 NOTIFY_ERROR(PLATFORM_FAILURE);
1078 return false;
1079 }
1080
1081 if (!keep_input_state) {
1082 if (input_streamon_) {
1083 __u32 type = V4L2_BUF_TYPE_VIDEO_OUTPUT_MPLANE;
1084 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_STREAMOFF, &type);
1085 }
1086 input_streamon_ = false;
1087 }
1088
1089 if (output_streamon_) {
1090 __u32 type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
1091 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_STREAMOFF, &type);
1092 }
1093 output_streamon_ = false;
1094
1095 if (!keep_input_state) {
1096 free_input_buffers_.clear();
1097 for (size_t i = 0; i < input_buffer_map_.size(); ++i) {
1098 InputRecord& input_record = input_buffer_map_[i];
1099 input_record.at_device = false;
1100 input_record.bytes_used = 0;
1101 input_record.input_id = -1;
1102 free_input_buffers_.push_back(i);
1103 }
1104 input_buffer_queued_count_ = 0;
1105 }
1106
1107 surfaces_at_device_.clear();
1108
1109 free_output_buffers_.clear();
1110 for (size_t i = 0; i < output_buffer_map_.size(); ++i) {
1111 OutputRecord& output_record = output_buffer_map_[i];
1112 DCHECK(!(output_record.at_client && output_record.at_device));
1113 output_record.at_device = false;
1114 if (!output_record.at_client)
1115 free_output_buffers_.push_back(i);
1116 }
1117 output_buffer_queued_count_ = 0;
1118
1119 DVLOGF(3) << "Device poll stopped";
1120 return true;
1121 }
1122
1123 void V4L2SliceVideoDecodeAccelerator::Decode(
1124 const media::BitstreamBuffer& bitstream_buffer) {
1125 DVLOGF(3) << "input_id=" << bitstream_buffer.id()
1126 << ", size=" << bitstream_buffer.size();
1127 DCHECK(io_message_loop_proxy_->BelongsToCurrentThread());
1128
1129 decoder_thread_proxy_->PostTask(
1130 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::DecodeTask,
1131 base::Unretained(this), bitstream_buffer));
1132 }
1133
1134 void V4L2SliceVideoDecodeAccelerator::DecodeTask(
1135 const media::BitstreamBuffer& bitstream_buffer) {
1136 DVLOGF(3) << "input_id=" << bitstream_buffer.id()
1137 << " size=" << bitstream_buffer.size();
1138 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1139
1140 scoped_ptr<BitstreamBufferRef> bitstream_record(new BitstreamBufferRef(
1141 io_client_, io_message_loop_proxy_,
1142 new base::SharedMemory(bitstream_buffer.handle(), true),
1143 bitstream_buffer.size(), bitstream_buffer.id()));
1144 if (!bitstream_record->shm->Map(bitstream_buffer.size())) {
1145 LOGF(ERROR) << "Could not map bitstream_buffer";
1146 NOTIFY_ERROR(UNREADABLE_INPUT);
1147 return;
1148 }
1149 DVLOGF(3) << "mapped at=" << bitstream_record->shm->memory();
1150
1151 decoder_input_queue_.push(
1152 linked_ptr<BitstreamBufferRef>(bitstream_record.release()));
1153
1154 ScheduleDecodeBufferTaskIfNeeded();
1155 }
1156
1157 bool V4L2SliceVideoDecodeAccelerator::TrySetNewBistreamBuffer() {
1158 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1159 DCHECK(!decoder_current_bitstream_buffer_);
1160
1161 if (decoder_input_queue_.empty())
1162 return false;
1163
1164 decoder_current_bitstream_buffer_.reset(
1165 decoder_input_queue_.front().release());
1166 decoder_input_queue_.pop();
1167
1168 if (decoder_current_bitstream_buffer_->input_id == kFlushBufferId) {
1169 // This is a buffer we queued for ourselves to trigger flush at this time.
1170 InitiateFlush();
1171 return false;
1172 }
1173
1174 const uint8_t* const data = reinterpret_cast<const uint8_t*>(
1175 decoder_current_bitstream_buffer_->shm->memory());
1176 const size_t data_size = decoder_current_bitstream_buffer_->size;
1177 decoder_->SetStream(data, data_size);
1178
1179 return true;
1180 }
1181
1182 void V4L2SliceVideoDecodeAccelerator::ScheduleDecodeBufferTaskIfNeeded() {
1183 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1184 if (state_ == kDecoding) {
1185 decoder_thread_proxy_->PostTask(
1186 FROM_HERE,
1187 base::Bind(&V4L2SliceVideoDecodeAccelerator::DecodeBufferTask,
1188 base::Unretained(this)));
1189 }
1190 }
1191
1192 void V4L2SliceVideoDecodeAccelerator::DecodeBufferTask() {
1193 DVLOGF(3);
1194 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1195
1196 if (state_ != kDecoding) {
1197 DVLOGF(3) << "Early exit, not in kDecoding";
1198 return;
1199 }
1200
1201 while (true) {
1202 AcceleratedVideoDecoder::DecodeResult res;
1203 res = decoder_->Decode();
1204 switch (res) {
1205 case AcceleratedVideoDecoder::kAllocateNewSurfaces:
1206 DVLOGF(2) << "Decoder requesting a new set of surfaces";
1207 InitiateSurfaceSetChange();
1208 return;
1209
1210 case AcceleratedVideoDecoder::kRanOutOfStreamData:
1211 decoder_current_bitstream_buffer_.reset();
1212 if (!TrySetNewBistreamBuffer())
1213 return;
1214
1215 break;
1216
1217 case AcceleratedVideoDecoder::kRanOutOfSurfaces:
1218 // No more surfaces for the decoder, we'll come back once we have more.
1219 DVLOGF(4) << "Ran out of surfaces";
1220 return;
1221
1222 case AcceleratedVideoDecoder::kDecodeError:
1223 DVLOGF(1) << "Error decoding stream";
1224 NOTIFY_ERROR(PLATFORM_FAILURE);
1225 return;
1226 }
1227 }
1228 }
1229
1230 void V4L2SliceVideoDecodeAccelerator::InitiateSurfaceSetChange() {
1231 DVLOGF(2);
1232 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1233
1234 DCHECK_EQ(state_, kDecoding);
1235 state_ = kIdle;
1236
1237 DCHECK(!surface_set_change_pending_);
1238 surface_set_change_pending_ = true;
1239
1240 FinishSurfaceSetChangeIfNeeded();
1241 }
1242
1243 void V4L2SliceVideoDecodeAccelerator::FinishSurfaceSetChangeIfNeeded() {
1244 DVLOGF(2);
1245 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1246
1247 if (!surface_set_change_pending_ || !surfaces_at_device_.empty())
1248 return;
1249
1250 DCHECK_EQ(state_, kIdle);
1251 DCHECK(decoder_display_queue_.empty());
1252
1253 // Keep input queue running while we switch outputs.
1254 if (!StopDevicePoll(true)) {
1255 NOTIFY_ERROR(PLATFORM_FAILURE);
1256 return;
1257 }
1258
1259 // This will return only once all buffers are dismissed and destroyed.
1260 // This does not wait until they are displayed however, as display retains
1261 // references to the buffers bound to textures and will release them
1262 // after displaying.
1263 if (!DestroyOutputs(true)) {
1264 NOTIFY_ERROR(PLATFORM_FAILURE);
1265 return;
1266 }
1267
1268 if (!CreateOutputBuffers()) {
1269 NOTIFY_ERROR(PLATFORM_FAILURE);
1270 return;
1271 }
1272
1273 if (!StartDevicePoll()) {
1274 NOTIFY_ERROR(PLATFORM_FAILURE);
1275 return;
1276 }
1277
1278 DVLOGF(3) << "Surface set change finished";
1279
1280 surface_set_change_pending_ = false;
1281 state_ = kDecoding;
1282 ScheduleDecodeBufferTaskIfNeeded();
1283 }
1284
1285 bool V4L2SliceVideoDecodeAccelerator::DestroyOutputs(bool dismiss) {
1286 DVLOGF(3);
1287 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1288 std::vector<EGLImageKHR> egl_images_to_destroy;
1289 std::vector<int32> picture_buffers_to_dismiss;
1290
1291 if (output_buffer_map_.empty())
1292 return true;
1293
1294 for (auto output_record : output_buffer_map_) {
1295 DCHECK(!output_record.at_device);
1296 output_record.at_client = false;
1297
1298 if (output_record.egl_sync != EGL_NO_SYNC_KHR) {
1299 if (eglDestroySyncKHR(egl_display_, output_record.egl_sync) != EGL_TRUE)
1300 DVLOGF(1) << "eglDestroySyncKHR failed.";
1301 }
1302
1303 if (output_record.egl_image != EGL_NO_IMAGE_KHR) {
1304 child_message_loop_proxy_->PostTask(
1305 FROM_HERE,
1306 base::Bind(base::IgnoreResult(&V4L2Device::DestroyEGLImage), device_,
1307 egl_display_, output_record.egl_image));
1308 }
1309
1310 picture_buffers_to_dismiss.push_back(output_record.picture_id);
1311 }
1312
1313 if (dismiss) {
1314 DVLOGF(2) << "Scheduling picture dismissal";
1315 base::WaitableEvent done(false, false);
1316 child_message_loop_proxy_->PostTask(
1317 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::DismissPictures,
1318 weak_this_, picture_buffers_to_dismiss, &done));
1319 done.Wait();
1320 }
1321
1322 // At this point client can't call ReusePictureBuffer on any of the pictures
1323 // anymore, so it's safe to destroy.
1324 return DestroyOutputBuffers();
1325 }
1326
1327 bool V4L2SliceVideoDecodeAccelerator::DestroyOutputBuffers() {
1328 DVLOGF(3);
1329 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread() ||
1330 !decoder_thread_.IsRunning());
1331 DCHECK(!output_streamon_);
1332 DCHECK(surfaces_at_device_.empty());
1333 DCHECK(decoder_display_queue_.empty());
1334 DCHECK_EQ(surfaces_at_display_.size() + free_output_buffers_.size(),
1335 output_buffer_map_.size());
1336
1337 if (output_buffer_map_.empty())
1338 return true;
1339
1340 // It's ok to do this, client will retain references to textures, but we are
1341 // not interested in reusing the surfaces anymore.
1342 // This will prevent us from reusing old surfaces in case we have some
1343 // ReusePictureBuffer() pending on ChildThread already. It's ok to ignore
1344 // them, because we have already dismissed them (in DestroyOutputs()).
1345 surfaces_at_display_.clear();
1346 DCHECK_EQ(free_output_buffers_.size(), output_buffer_map_.size());
1347
1348 free_output_buffers_.clear();
1349 output_buffer_map_.clear();
1350
1351 struct v4l2_requestbuffers reqbufs;
1352 memset(&reqbufs, 0, sizeof(reqbufs));
1353 reqbufs.count = 0;
1354 reqbufs.type = V4L2_BUF_TYPE_VIDEO_CAPTURE_MPLANE;
1355 reqbufs.memory = V4L2_MEMORY_MMAP;
1356 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_REQBUFS, &reqbufs);
1357
1358 return true;
1359 }
1360
1361 void V4L2SliceVideoDecodeAccelerator::AssignPictureBuffers(
1362 const std::vector<media::PictureBuffer>& buffers) {
1363 DVLOGF(3);
1364 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
1365
1366 if (buffers.size() != output_buffer_map_.size()) {
1367 DLOG(ERROR) << "Failed to provide requested picture buffers. "
1368 << "(Got " << buffers.size()
1369 << ", requested " << output_buffer_map_.size() << ")";
1370 NOTIFY_ERROR(INVALID_ARGUMENT);
1371 return;
1372 }
1373
1374 if (!make_context_current_.Run()) {
1375 DLOG(ERROR) << "could not make context current";
1376 NOTIFY_ERROR(PLATFORM_FAILURE);
1377 return;
1378 }
1379
1380 gfx::ScopedTextureBinder bind_restore(GL_TEXTURE_EXTERNAL_OES, 0);
1381
1382 // It's safe to manipulate all the buffer state here, because the decoder
1383 // thread is waiting on pictures_assigned_.
1384 DCHECK(free_output_buffers_.empty());
1385 for (size_t i = 0; i < output_buffer_map_.size(); ++i) {
1386 DCHECK(buffers[i].size() == frame_buffer_size_);
1387
1388 OutputRecord& output_record = output_buffer_map_[i];
1389 DCHECK(!output_record.at_device);
1390 DCHECK(!output_record.at_client);
1391 DCHECK_EQ(output_record.egl_image, EGL_NO_IMAGE_KHR);
1392 DCHECK_EQ(output_record.egl_sync, EGL_NO_SYNC_KHR);
1393 DCHECK_EQ(output_record.picture_id, -1);
1394 DCHECK_EQ(output_record.cleared, false);
1395
1396 EGLImageKHR egl_image = device_->CreateEGLImage(egl_display_,
1397 egl_context_,
1398 buffers[i].texture_id(),
1399 frame_buffer_size_,
1400 i,
1401 output_format_fourcc_,
1402 output_planes_count_);
1403 if (egl_image == EGL_NO_IMAGE_KHR) {
1404 LOGF(ERROR) << "Could not create EGLImageKHR";
1405 // Ownership of EGLImages allocated in previous iterations of this loop
1406 // has been transferred to output_buffer_map_. After we error-out here
1407 // the destructor will handle their cleanup.
1408 NOTIFY_ERROR(PLATFORM_FAILURE);
1409 return;
1410 }
1411
1412 output_record.egl_image = egl_image;
1413 output_record.picture_id = buffers[i].id();
1414 free_output_buffers_.push_back(i);
1415 DVLOGF(3) << "buffer[" << i << "]: picture_id=" << output_record.picture_id;
1416 }
1417
1418 pictures_assigned_.Signal();
1419 }
1420
1421 void V4L2SliceVideoDecodeAccelerator::ReusePictureBuffer(
1422 int32 picture_buffer_id) {
1423 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
1424 DVLOGF(4) << "picture_buffer_id=" << picture_buffer_id;
1425
1426 if (!make_context_current_.Run()) {
1427 LOGF(ERROR) << "could not make context current";
1428 NOTIFY_ERROR(PLATFORM_FAILURE);
1429 return;
1430 }
1431
1432 EGLSyncKHR egl_sync =
1433 eglCreateSyncKHR(egl_display_, EGL_SYNC_FENCE_KHR, NULL);
1434 if (egl_sync == EGL_NO_SYNC_KHR) {
1435 LOGF(ERROR) << "eglCreateSyncKHR() failed";
1436 NOTIFY_ERROR(PLATFORM_FAILURE);
1437 return;
1438 }
1439
1440 scoped_ptr<EGLSyncKHRRef> egl_sync_ref(
1441 new EGLSyncKHRRef(egl_display_, egl_sync));
1442 decoder_thread_proxy_->PostTask(
1443 FROM_HERE,
1444 base::Bind(&V4L2SliceVideoDecodeAccelerator::ReusePictureBufferTask,
1445 base::Unretained(this), picture_buffer_id,
1446 base::Passed(&egl_sync_ref)));
1447 }
1448
1449 void V4L2SliceVideoDecodeAccelerator::ReusePictureBufferTask(
1450 int32 picture_buffer_id,
1451 scoped_ptr<EGLSyncKHRRef> egl_sync_ref) {
1452 DVLOGF(3) << "picture_buffer_id=" << picture_buffer_id;
1453 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1454
1455 V4L2DecodeSurfaceByPictureBufferId::iterator it =
1456 surfaces_at_display_.find(picture_buffer_id);
1457 if (it == surfaces_at_display_.end()) {
1458 // It's possible that we've already posted a DismissPictureBuffer for this
1459 // picture, but it has not yet executed when this ReusePictureBuffer was
1460 // posted to us by the client. In that case just ignore this (we've already
1461 // dismissed it and accounted for that) and let the sync object get
1462 // destroyed.
1463 DVLOGF(3) << "got picture id=" << picture_buffer_id
1464 << " not in use (anymore?).";
1465 return;
1466 }
1467
1468 OutputRecord& output_record = output_buffer_map_[it->second->output_record()];
1469 if (output_record.at_device || !output_record.at_client) {
1470 DVLOGF(1) << "picture_buffer_id not reusable";
1471 NOTIFY_ERROR(INVALID_ARGUMENT);
1472 return;
1473 }
1474
1475 DCHECK_EQ(output_record.egl_sync, EGL_NO_SYNC_KHR);
1476 DCHECK(!output_record.at_device);
1477 output_record.at_client = false;
1478 output_record.egl_sync = egl_sync_ref->egl_sync;
1479 // Take ownership of the EGLSync.
1480 egl_sync_ref->egl_sync = EGL_NO_SYNC_KHR;
1481 surfaces_at_display_.erase(it);
1482 }
1483
1484 void V4L2SliceVideoDecodeAccelerator::Flush() {
1485 DVLOGF(3);
1486 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
1487
1488 decoder_thread_proxy_->PostTask(
1489 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::FlushTask,
1490 base::Unretained(this)));
1491 }
1492
1493 void V4L2SliceVideoDecodeAccelerator::FlushTask() {
1494 DVLOGF(3);
1495 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1496
1497 if (!decoder_input_queue_.empty()) {
1498 // We are not done with pending inputs, so queue an empty buffer,
1499 // which - when reached - will trigger flush sequence.
1500 decoder_input_queue_.push(
1501 linked_ptr<BitstreamBufferRef>(new BitstreamBufferRef(
1502 io_client_, io_message_loop_proxy_, nullptr, 0, kFlushBufferId)));
1503 return;
1504 }
1505
1506 // No more inputs pending, so just finish flushing here.
1507 InitiateFlush();
1508 }
1509
1510 void V4L2SliceVideoDecodeAccelerator::InitiateFlush() {
1511 DVLOGF(3);
1512 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1513
1514 DCHECK(!decoder_flushing_);
1515 DCHECK_EQ(state_, kDecoding);
1516 state_ = kIdle;
1517
1518 // This will trigger output for all remaining surfaces in the decoder.
1519 // However, not all of them may be decoded yet (they would be queued
1520 // in hardware then).
1521 if (!decoder_->Flush()) {
1522 DVLOGF(1) << "Failed flushing the decoder.";
1523 NOTIFY_ERROR(PLATFORM_FAILURE);
1524 return;
1525 }
1526
1527 // Put the decoder in an idle state, ready to resume.
1528 decoder_->Reset();
1529
1530 decoder_flushing_ = true;
1531
1532 decoder_thread_proxy_->PostTask(
1533 FROM_HERE,
1534 base::Bind(&V4L2SliceVideoDecodeAccelerator::FinishFlushIfNeeded,
1535 base::Unretained(this)));
1536 }
1537
1538 void V4L2SliceVideoDecodeAccelerator::FinishFlushIfNeeded() {
1539 DVLOGF(3);
1540 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1541
1542 if (!decoder_flushing_ || !surfaces_at_device_.empty())
1543 return;
1544
1545 DCHECK_EQ(state_, kIdle);
1546
1547 // At this point, all remaining surfaces are decoded and dequeued, and since
1548 // we have already scheduled output for them in InitiateFlush(), their
1549 // respective PictureReady calls have been posted (or they have been queued on
1550 // pending_picture_ready_). So at this time, once we SendPictureReady(),
1551 // we will have all remaining PictureReady() posted to the client and we
1552 // can post NotifyFlushDone().
1553 DCHECK(decoder_display_queue_.empty());
1554 SendPictureReady();
1555
1556 child_message_loop_proxy_->PostTask(
1557 FROM_HERE, base::Bind(&Client::NotifyFlushDone, client_));
1558
1559 decoder_flushing_ = false;
1560
1561 DVLOGF(3) << "Flush finished";
1562 state_ = kDecoding;
1563 ScheduleDecodeBufferTaskIfNeeded();
1564 }
1565
1566 void V4L2SliceVideoDecodeAccelerator::Reset() {
1567 DVLOGF(3);
1568 DCHECK(child_message_loop_proxy_->BelongsToCurrentThread());
1569
1570 decoder_thread_proxy_->PostTask(
1571 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::ResetTask,
1572 base::Unretained(this)));
1573 }
1574
1575 void V4L2SliceVideoDecodeAccelerator::ResetTask() {
1576 DVLOGF(3);
1577 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1578
1579 if (decoder_resetting_) {
1580 // This is a bug in the client, multiple Reset()s before NotifyResetDone()
1581 // are not allowed.
1582 NOTREACHED() << "Client should not be requesting multiple Reset()s";
1583 return;
1584 }
1585
1586 DCHECK_EQ(state_, kDecoding);
1587 state_ = kIdle;
1588
1589 // Put the decoder in an idle state, ready to resume.
1590 decoder_->Reset();
1591
1592 decoder_resetting_ = true;
1593
1594 // Drop all remaining inputs.
1595 decoder_current_bitstream_buffer_.reset();
1596 while (!decoder_input_queue_.empty())
1597 decoder_input_queue_.pop();
1598
1599 FinishResetIfNeeded();
1600 }
1601
1602 void V4L2SliceVideoDecodeAccelerator::FinishResetIfNeeded() {
1603 DVLOGF(3);
1604 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1605
1606 if (!decoder_resetting_ || !surfaces_at_device_.empty())
1607 return;
1608
1609 DCHECK_EQ(state_, kIdle);
1610 DCHECK(!decoder_flushing_);
1611 SendPictureReady();
1612
1613 // Drop any pending outputs.
1614 while (!decoder_display_queue_.empty())
1615 decoder_display_queue_.pop();
1616
1617 decoder_resetting_ = false;
1618
1619 child_message_loop_proxy_->PostTask(
1620 FROM_HERE, base::Bind(&Client::NotifyResetDone, client_));
1621
1622 DVLOGF(3) << "Reset finished";
1623
1624 state_ = kDecoding;
1625 ScheduleDecodeBufferTaskIfNeeded();
1626 }
1627
1628 void V4L2SliceVideoDecodeAccelerator::SetErrorState(Error error) {
1629 // We can touch decoder_state_ only if this is the decoder thread or the
1630 // decoder thread isn't running.
1631 if (decoder_thread_.IsRunning() &&
1632 !decoder_thread_proxy_->BelongsToCurrentThread()) {
1633 decoder_thread_proxy_->PostTask(
1634 FROM_HERE, base::Bind(&V4L2SliceVideoDecodeAccelerator::SetErrorState,
1635 base::Unretained(this), error));
1636 return;
1637 }
1638
1639 // Post NotifyError only if we are already initialized, as the API does
1640 // not allow doing so before that.
1641 if (state_ != kError && state_ != kUninitialized)
1642 NotifyError(error);
1643
1644 state_ = kError;
1645 }
1646
1647 V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::V4L2H264Accelerator(
1648 V4L2SliceVideoDecodeAccelerator* v4l2_dec)
1649 : num_slices_(0), v4l2_dec_(v4l2_dec) {
1650 DCHECK(v4l2_dec_);
1651 }
1652
1653 V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::~V4L2H264Accelerator() {
1654 }
1655
1656 scoped_refptr<H264Picture>
1657 V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::CreateH264Picture() {
1658 scoped_refptr<V4L2DecodeSurface> dec_surface = v4l2_dec_->CreateSurface();
1659 if (!dec_surface)
1660 return nullptr;
1661
1662 return new V4L2H264Picture(dec_surface);
1663 }
1664
1665 void V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::
1666 H264PictureListToDPBIndicesList(const H264Picture::Vector& src_pic_list,
1667 uint8_t dst_list[kDPBIndicesListSize]) {
1668 size_t i;
1669 for (i = 0; i < src_pic_list.size() && i < kDPBIndicesListSize; ++i) {
1670 const scoped_refptr<H264Picture>& pic = src_pic_list[i];
1671 dst_list[i] = pic ? pic->dpb_position : VIDEO_MAX_FRAME;
1672 }
1673
1674 while (i < kDPBIndicesListSize)
1675 dst_list[i++] = VIDEO_MAX_FRAME;
1676 }
1677
1678 void V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::H264DPBToV4L2DPB(
1679 const H264DPB& dpb,
1680 std::vector<scoped_refptr<V4L2DecodeSurface>>* ref_surfaces) {
1681 memset(v4l2_decode_param_.dpb, 0, sizeof(v4l2_decode_param_.dpb));
1682 size_t i = 0;
1683 for (const auto& pic : dpb) {
1684 if (i >= arraysize(v4l2_decode_param_.dpb)) {
1685 DVLOG(1) << "Invalid DPB size";
1686 break;
1687 }
1688 struct v4l2_h264_dpb_entry& entry = v4l2_decode_param_.dpb[i++];
1689 scoped_refptr<V4L2DecodeSurface> dec_surface =
1690 H264PictureToV4L2DecodeSurface(pic);
1691 entry.buf_index = dec_surface->output_record();
1692 entry.frame_num = pic->frame_num;
1693 entry.pic_num = pic->pic_num;
1694 entry.top_field_order_cnt = pic->top_field_order_cnt;
1695 entry.bottom_field_order_cnt = pic->bottom_field_order_cnt;
1696 entry.flags = (pic->ref ? V4L2_H264_DPB_ENTRY_FLAG_ACTIVE : 0) |
1697 (pic->long_term ? V4L2_H264_DPB_ENTRY_FLAG_LONG_TERM : 0);
1698
1699 ref_surfaces->push_back(dec_surface);
1700 }
1701 }
1702
1703 bool V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::SubmitFrameMetadata(
1704 const media::H264SPS* sps,
1705 const media::H264PPS* pps,
1706 const H264DPB& dpb,
1707 const H264Picture::Vector& ref_pic_listp0,
1708 const H264Picture::Vector& ref_pic_listb0,
1709 const H264Picture::Vector& ref_pic_listb1,
1710 const scoped_refptr<H264Picture>& pic) {
1711 struct v4l2_ext_control ctrl;
1712 std::vector<struct v4l2_ext_control> ctrls;
1713
1714 struct v4l2_ctrl_h264_sps v4l2_sps;
1715 memset(&v4l2_sps, 0, sizeof(v4l2_sps));
1716 v4l2_sps.constraint_set_flags =
1717 sps->constraint_set0_flag ? V4L2_H264_SPS_CONSTRAINT_SET0_FLAG : 0 |
1718 sps->constraint_set1_flag ? V4L2_H264_SPS_CONSTRAINT_SET1_FLAG : 0 |
1719 sps->constraint_set2_flag ? V4L2_H264_SPS_CONSTRAINT_SET2_FLAG : 0 |
1720 sps->constraint_set3_flag ? V4L2_H264_SPS_CONSTRAINT_SET3_FLAG : 0 |
1721 sps->constraint_set4_flag ? V4L2_H264_SPS_CONSTRAINT_SET4_FLAG : 0 |
1722 sps->constraint_set5_flag ? V4L2_H264_SPS_CONSTRAINT_SET5_FLAG : 0;
1723 #define SPS_TO_V4L2SPS(a) v4l2_sps.a = sps->a
1724 SPS_TO_V4L2SPS(profile_idc);
1725 SPS_TO_V4L2SPS(level_idc);
1726 SPS_TO_V4L2SPS(seq_parameter_set_id);
1727 SPS_TO_V4L2SPS(chroma_format_idc);
1728 SPS_TO_V4L2SPS(bit_depth_luma_minus8);
1729 SPS_TO_V4L2SPS(bit_depth_chroma_minus8);
1730 SPS_TO_V4L2SPS(log2_max_frame_num_minus4);
1731 SPS_TO_V4L2SPS(pic_order_cnt_type);
1732 SPS_TO_V4L2SPS(log2_max_pic_order_cnt_lsb_minus4);
1733 SPS_TO_V4L2SPS(offset_for_non_ref_pic);
1734 SPS_TO_V4L2SPS(offset_for_top_to_bottom_field);
1735 SPS_TO_V4L2SPS(num_ref_frames_in_pic_order_cnt_cycle);
1736
1737 static_assert(arraysize(v4l2_sps.offset_for_ref_frame) ==
1738 arraysize(sps->offset_for_ref_frame),
1739 "offset_for_ref_frame arrays must be same size");
1740 for (size_t i = 0; i < arraysize(v4l2_sps.offset_for_ref_frame); ++i)
1741 v4l2_sps.offset_for_ref_frame[i] = sps->offset_for_ref_frame[i];
1742 SPS_TO_V4L2SPS(max_num_ref_frames);
1743 SPS_TO_V4L2SPS(pic_width_in_mbs_minus1);
1744 SPS_TO_V4L2SPS(pic_height_in_map_units_minus1);
1745 #undef SPS_TO_V4L2SPS
1746
1747 #define SET_V4L2_SPS_FLAG_IF(cond, flag) \
1748 v4l2_sps.flags |= ((sps->cond) ? (flag) : 0)
1749 SET_V4L2_SPS_FLAG_IF(separate_colour_plane_flag,
1750 V4L2_H264_SPS_FLAG_SEPARATE_COLOUR_PLANE);
1751 SET_V4L2_SPS_FLAG_IF(qpprime_y_zero_transform_bypass_flag,
1752 V4L2_H264_SPS_FLAG_QPPRIME_Y_ZERO_TRANSFORM_BYPASS);
1753 SET_V4L2_SPS_FLAG_IF(delta_pic_order_always_zero_flag,
1754 V4L2_H264_SPS_FLAG_DELTA_PIC_ORDER_ALWAYS_ZERO);
1755 SET_V4L2_SPS_FLAG_IF(gaps_in_frame_num_value_allowed_flag,
1756 V4L2_H264_SPS_FLAG_GAPS_IN_FRAME_NUM_VALUE_ALLOWED);
1757 SET_V4L2_SPS_FLAG_IF(frame_mbs_only_flag, V4L2_H264_SPS_FLAG_FRAME_MBS_ONLY);
1758 SET_V4L2_SPS_FLAG_IF(mb_adaptive_frame_field_flag,
1759 V4L2_H264_SPS_FLAG_MB_ADAPTIVE_FRAME_FIELD);
1760 SET_V4L2_SPS_FLAG_IF(direct_8x8_inference_flag,
1761 V4L2_H264_SPS_FLAG_DIRECT_8X8_INFERENCE);
1762 #undef SET_FLAG
1763 memset(&ctrl, 0, sizeof(ctrl));
1764 ctrl.id = V4L2_CID_MPEG_VIDEO_H264_SPS;
1765 ctrl.size = sizeof(v4l2_sps);
1766 ctrl.p_h264_sps = &v4l2_sps;
1767 ctrls.push_back(ctrl);
1768
1769 struct v4l2_ctrl_h264_pps v4l2_pps;
1770 memset(&v4l2_pps, 0, sizeof(v4l2_pps));
1771 #define PPS_TO_V4L2PPS(a) v4l2_pps.a = pps->a
1772 PPS_TO_V4L2PPS(pic_parameter_set_id);
1773 PPS_TO_V4L2PPS(seq_parameter_set_id);
1774 PPS_TO_V4L2PPS(num_slice_groups_minus1);
1775 PPS_TO_V4L2PPS(num_ref_idx_l0_default_active_minus1);
1776 PPS_TO_V4L2PPS(num_ref_idx_l1_default_active_minus1);
1777 PPS_TO_V4L2PPS(weighted_bipred_idc);
1778 PPS_TO_V4L2PPS(pic_init_qp_minus26);
1779 PPS_TO_V4L2PPS(pic_init_qs_minus26);
1780 PPS_TO_V4L2PPS(chroma_qp_index_offset);
1781 PPS_TO_V4L2PPS(second_chroma_qp_index_offset);
1782 #undef PPS_TO_V4L2PPS
1783
1784 #define SET_V4L2_PPS_FLAG_IF(cond, flag) \
1785 v4l2_pps.flags |= ((pps->cond) ? (flag) : 0)
1786 SET_V4L2_PPS_FLAG_IF(entropy_coding_mode_flag,
1787 V4L2_H264_PPS_FLAG_ENTROPY_CODING_MODE);
1788 SET_V4L2_PPS_FLAG_IF(
1789 bottom_field_pic_order_in_frame_present_flag,
1790 V4L2_H264_PPS_FLAG_BOTTOM_FIELD_PIC_ORDER_IN_FRAME_PRESENT);
1791 SET_V4L2_PPS_FLAG_IF(weighted_pred_flag, V4L2_H264_PPS_FLAG_WEIGHTED_PRED);
1792 SET_V4L2_PPS_FLAG_IF(deblocking_filter_control_present_flag,
1793 V4L2_H264_PPS_FLAG_DEBLOCKING_FILTER_CONTROL_PRESENT);
1794 SET_V4L2_PPS_FLAG_IF(constrained_intra_pred_flag,
1795 V4L2_H264_PPS_FLAG_CONSTRAINED_INTRA_PRED);
1796 SET_V4L2_PPS_FLAG_IF(redundant_pic_cnt_present_flag,
1797 V4L2_H264_PPS_FLAG_REDUNDANT_PIC_CNT_PRESENT);
1798 SET_V4L2_PPS_FLAG_IF(transform_8x8_mode_flag,
1799 V4L2_H264_PPS_FLAG_TRANSFORM_8X8_MODE);
1800 SET_V4L2_PPS_FLAG_IF(pic_scaling_matrix_present_flag,
1801 V4L2_H264_PPS_FLAG_PIC_SCALING_MATRIX_PRESENT);
1802 #undef SET_V4L2_PPS_FLAG_IF
1803 memset(&ctrl, 0, sizeof(ctrl));
1804 ctrl.id = V4L2_CID_MPEG_VIDEO_H264_PPS;
1805 ctrl.size = sizeof(v4l2_pps);
1806 ctrl.p_h264_pps = &v4l2_pps;
1807 ctrls.push_back(ctrl);
1808
1809 struct v4l2_ctrl_h264_scaling_matrix v4l2_scaling_matrix;
1810 memset(&v4l2_scaling_matrix, 0, sizeof(v4l2_scaling_matrix));
1811 static_assert(arraysize(v4l2_scaling_matrix.scaling_list_4x4) <=
1812 arraysize(pps->scaling_list4x4) &&
1813 arraysize(v4l2_scaling_matrix.scaling_list_4x4[0]) <=
1814 arraysize(pps->scaling_list4x4[0]) &&
1815 arraysize(v4l2_scaling_matrix.scaling_list_8x8) <=
1816 arraysize(pps->scaling_list8x8) &&
1817 arraysize(v4l2_scaling_matrix.scaling_list_8x8[0]) <=
1818 arraysize(pps->scaling_list8x8[0]),
1819 "scaling_lists must be of correct size");
1820 for (size_t i = 0; i < arraysize(v4l2_scaling_matrix.scaling_list_4x4); ++i) {
1821 for (size_t j = 0; j < arraysize(v4l2_scaling_matrix.scaling_list_4x4[i]);
1822 ++j) {
1823 v4l2_scaling_matrix.scaling_list_4x4[i][j] = pps->scaling_list4x4[i][j];
1824 }
1825 }
1826 for (size_t i = 0; i < arraysize(v4l2_scaling_matrix.scaling_list_8x8); ++i) {
1827 for (size_t j = 0; j < arraysize(v4l2_scaling_matrix.scaling_list_8x8[i]);
1828 ++j) {
1829 v4l2_scaling_matrix.scaling_list_8x8[i][j] = pps->scaling_list8x8[i][j];
1830 }
1831 }
1832 memset(&ctrl, 0, sizeof(ctrl));
1833 ctrl.id = V4L2_CID_MPEG_VIDEO_H264_SCALING_MATRIX;
1834 ctrl.size = sizeof(v4l2_scaling_matrix);
1835 ctrl.p_h264_scal_mtrx = &v4l2_scaling_matrix;
1836 ctrls.push_back(ctrl);
1837
1838 scoped_refptr<V4L2DecodeSurface> dec_surface =
1839 H264PictureToV4L2DecodeSurface(pic);
1840
1841 struct v4l2_ext_controls ext_ctrls;
1842 memset(&ext_ctrls, 0, sizeof(ext_ctrls));
1843 ext_ctrls.count = ctrls.size();
1844 ext_ctrls.controls = &ctrls[0];
1845 ext_ctrls.config_store = dec_surface->config_store();
1846 v4l2_dec_->SubmitExtControls(&ext_ctrls);
1847
1848 H264PictureListToDPBIndicesList(ref_pic_listp0,
1849 v4l2_decode_param_.ref_pic_list_p0);
1850 H264PictureListToDPBIndicesList(ref_pic_listb0,
1851 v4l2_decode_param_.ref_pic_list_b0);
1852 H264PictureListToDPBIndicesList(ref_pic_listb1,
1853 v4l2_decode_param_.ref_pic_list_b1);
1854
1855 std::vector<scoped_refptr<V4L2DecodeSurface>> ref_surfaces;
1856 H264DPBToV4L2DPB(dpb, &ref_surfaces);
1857 dec_surface->SetReferenceSurfaces(ref_surfaces);
1858
1859 return true;
1860 }
1861
1862 bool V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::SubmitSlice(
1863 const media::H264PPS* pps,
1864 const media::H264SliceHeader* slice_hdr,
1865 const H264Picture::Vector& ref_pic_list0,
1866 const H264Picture::Vector& ref_pic_list1,
1867 const scoped_refptr<H264Picture>& pic,
1868 const uint8_t* data,
1869 size_t size) {
1870 if (num_slices_ == kMaxSlices) {
1871 LOGF(ERROR) << "Over limit of supported slices per frame";
1872 return false;
1873 }
1874
1875 struct v4l2_ctrl_h264_slice_param& v4l2_slice_param =
1876 v4l2_slice_params_[num_slices_++];
1877 memset(&v4l2_slice_param, 0, sizeof(v4l2_slice_param));
1878
1879 v4l2_slice_param.size = size;
1880 #define SHDR_TO_V4L2SPARM(a) v4l2_slice_param.a = slice_hdr->a
1881 SHDR_TO_V4L2SPARM(header_bit_size);
1882 SHDR_TO_V4L2SPARM(first_mb_in_slice);
1883 SHDR_TO_V4L2SPARM(slice_type);
1884 SHDR_TO_V4L2SPARM(pic_parameter_set_id);
1885 SHDR_TO_V4L2SPARM(colour_plane_id);
1886 SHDR_TO_V4L2SPARM(frame_num);
1887 SHDR_TO_V4L2SPARM(idr_pic_id);
1888 SHDR_TO_V4L2SPARM(pic_order_cnt_lsb);
1889 SHDR_TO_V4L2SPARM(delta_pic_order_cnt_bottom);
1890 SHDR_TO_V4L2SPARM(delta_pic_order_cnt0);
1891 SHDR_TO_V4L2SPARM(delta_pic_order_cnt1);
1892 SHDR_TO_V4L2SPARM(redundant_pic_cnt);
1893 SHDR_TO_V4L2SPARM(dec_ref_pic_marking_bit_size);
1894 SHDR_TO_V4L2SPARM(cabac_init_idc);
1895 SHDR_TO_V4L2SPARM(slice_qp_delta);
1896 SHDR_TO_V4L2SPARM(slice_qs_delta);
1897 SHDR_TO_V4L2SPARM(disable_deblocking_filter_idc);
1898 SHDR_TO_V4L2SPARM(slice_alpha_c0_offset_div2);
1899 SHDR_TO_V4L2SPARM(slice_beta_offset_div2);
1900 SHDR_TO_V4L2SPARM(num_ref_idx_l0_active_minus1);
1901 SHDR_TO_V4L2SPARM(num_ref_idx_l1_active_minus1);
1902 SHDR_TO_V4L2SPARM(pic_order_cnt_bit_size);
1903 #undef SHDR_TO_V4L2SPARM
1904
1905 #define SET_V4L2_SPARM_FLAG_IF(cond, flag) \
1906 v4l2_slice_param.flags |= ((slice_hdr->cond) ? (flag) : 0)
1907 SET_V4L2_SPARM_FLAG_IF(field_pic_flag, V4L2_SLICE_FLAG_FIELD_PIC);
1908 SET_V4L2_SPARM_FLAG_IF(bottom_field_flag, V4L2_SLICE_FLAG_BOTTOM_FIELD);
1909 SET_V4L2_SPARM_FLAG_IF(direct_spatial_mv_pred_flag,
1910 V4L2_SLICE_FLAG_DIRECT_SPATIAL_MV_PRED);
1911 SET_V4L2_SPARM_FLAG_IF(sp_for_switch_flag, V4L2_SLICE_FLAG_SP_FOR_SWITCH);
1912 #undef SET_V4L2_SPARM_FLAG_IF
1913
1914 struct v4l2_h264_pred_weight_table* pred_weight_table =
1915 &v4l2_slice_param.pred_weight_table;
1916
1917 if (((slice_hdr->IsPSlice() || slice_hdr->IsSPSlice()) &&
1918 pps->weighted_pred_flag) ||
1919 (slice_hdr->IsBSlice() && pps->weighted_bipred_idc == 1)) {
1920 pred_weight_table->luma_log2_weight_denom =
1921 slice_hdr->luma_log2_weight_denom;
1922 pred_weight_table->chroma_log2_weight_denom =
1923 slice_hdr->chroma_log2_weight_denom;
1924
1925 struct v4l2_h264_weight_factors* factorsl0 =
1926 &pred_weight_table->weight_factors[0];
1927
1928 for (int i = 0; i < 32; ++i) {
1929 factorsl0->luma_weight[i] =
1930 slice_hdr->pred_weight_table_l0.luma_weight[i];
1931 factorsl0->luma_offset[i] =
1932 slice_hdr->pred_weight_table_l0.luma_offset[i];
1933
1934 for (int j = 0; j < 2; ++j) {
1935 factorsl0->chroma_weight[i][j] =
1936 slice_hdr->pred_weight_table_l0.chroma_weight[i][j];
1937 factorsl0->chroma_offset[i][j] =
1938 slice_hdr->pred_weight_table_l0.chroma_offset[i][j];
1939 }
1940 }
1941
1942 if (slice_hdr->IsBSlice()) {
1943 struct v4l2_h264_weight_factors* factorsl1 =
1944 &pred_weight_table->weight_factors[1];
1945
1946 for (int i = 0; i < 32; ++i) {
1947 factorsl1->luma_weight[i] =
1948 slice_hdr->pred_weight_table_l1.luma_weight[i];
1949 factorsl1->luma_offset[i] =
1950 slice_hdr->pred_weight_table_l1.luma_offset[i];
1951
1952 for (int j = 0; j < 2; ++j) {
1953 factorsl1->chroma_weight[i][j] =
1954 slice_hdr->pred_weight_table_l1.chroma_weight[i][j];
1955 factorsl1->chroma_offset[i][j] =
1956 slice_hdr->pred_weight_table_l1.chroma_offset[i][j];
1957 }
1958 }
1959 }
1960 }
1961
1962 H264PictureListToDPBIndicesList(ref_pic_list0,
1963 v4l2_slice_param.ref_pic_list0);
1964 H264PictureListToDPBIndicesList(ref_pic_list1,
1965 v4l2_slice_param.ref_pic_list1);
1966
1967 scoped_refptr<V4L2DecodeSurface> dec_surface =
1968 H264PictureToV4L2DecodeSurface(pic);
1969
1970 v4l2_decode_param_.nal_ref_idc = slice_hdr->nal_ref_idc;
1971
1972 // TODO(posciak): Don't add start code back here, but have it passed from
1973 // the parser.
1974 size_t data_copy_size = size + 3;
1975 scoped_ptr<uint8_t[]> data_copy(new uint8_t[data_copy_size]);
1976 memset(data_copy.get(), 0, data_copy_size);
1977 data_copy[2] = 0x01;
1978 memcpy(data_copy.get() + 3, data, size);
1979 return v4l2_dec_->SubmitSlice(dec_surface->input_record(), data_copy.get(),
1980 data_copy_size);
1981 }
1982
1983 bool V4L2SliceVideoDecodeAccelerator::SubmitSlice(int index,
1984 const uint8_t* data,
1985 size_t size) {
1986 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
1987
1988 InputRecord& input_record = input_buffer_map_[index];
1989
1990 if (input_record.bytes_used + size > input_record.length) {
1991 DVLOGF(1) << "Input buffer too small";
1992 return false;
1993 }
1994
1995 memcpy(static_cast<uint8_t*>(input_record.address) + input_record.bytes_used,
1996 data, size);
1997 input_record.bytes_used += size;
1998
1999 return true;
2000 }
2001
2002 bool V4L2SliceVideoDecodeAccelerator::SubmitExtControls(
2003 struct v4l2_ext_controls* ext_ctrls) {
2004 DCHECK_GT(ext_ctrls->config_store, 0u);
2005 IOCTL_OR_ERROR_RETURN_FALSE(VIDIOC_S_EXT_CTRLS, ext_ctrls);
2006 return true;
2007 }
2008
2009 bool V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::SubmitDecode(
2010 const scoped_refptr<H264Picture>& pic) {
2011 scoped_refptr<V4L2DecodeSurface> dec_surface =
2012 H264PictureToV4L2DecodeSurface(pic);
2013
2014 v4l2_decode_param_.num_slices = num_slices_;
2015 v4l2_decode_param_.idr_pic_flag = pic->idr;
2016 v4l2_decode_param_.top_field_order_cnt = pic->top_field_order_cnt;
2017 v4l2_decode_param_.bottom_field_order_cnt = pic->bottom_field_order_cnt;
2018
2019 struct v4l2_ext_control ctrl;
2020 std::vector<struct v4l2_ext_control> ctrls;
2021
2022 memset(&ctrl, 0, sizeof(ctrl));
2023 ctrl.id = V4L2_CID_MPEG_VIDEO_H264_SLICE_PARAM;
2024 ctrl.size = sizeof(v4l2_slice_params_);
2025 ctrl.p_h264_slice_param = v4l2_slice_params_;
2026 ctrls.push_back(ctrl);
2027
2028 memset(&ctrl, 0, sizeof(ctrl));
2029 ctrl.id = V4L2_CID_MPEG_VIDEO_H264_DECODE_PARAM;
2030 ctrl.size = sizeof(v4l2_decode_param_);
2031 ctrl.p_h264_decode_param = &v4l2_decode_param_;
2032 ctrls.push_back(ctrl);
2033
2034 struct v4l2_ext_controls ext_ctrls;
2035 memset(&ext_ctrls, 0, sizeof(ext_ctrls));
2036 ext_ctrls.count = ctrls.size();
2037 ext_ctrls.controls = &ctrls[0];
2038 ext_ctrls.config_store = dec_surface->config_store();
2039 v4l2_dec_->SubmitExtControls(&ext_ctrls);
2040
2041 num_slices_ = 0;
2042 memset(&v4l2_decode_param_, 0, sizeof(v4l2_decode_param_));
2043 memset(&v4l2_slice_params_, 0, sizeof(v4l2_slice_params_));
2044
2045 v4l2_dec_->DecodeSurface(dec_surface);
2046 return true;
2047 }
2048
2049 bool V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::OutputPicture(
2050 const scoped_refptr<H264Picture>& pic) {
2051 scoped_refptr<V4L2DecodeSurface> dec_surface =
2052 H264PictureToV4L2DecodeSurface(pic);
2053 v4l2_dec_->SurfaceReady(dec_surface);
2054 return true;
2055 }
2056
2057 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
2058 V4L2SliceVideoDecodeAccelerator::V4L2H264Accelerator::
2059 H264PictureToV4L2DecodeSurface(const scoped_refptr<H264Picture>& pic) {
2060 V4L2H264Picture* v4l2_pic = pic->AsV4L2H264Picture();
2061 CHECK(v4l2_pic);
2062 return v4l2_pic->dec_surface();
2063 }
2064
2065 V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::V4L2VP8Accelerator(
2066 V4L2SliceVideoDecodeAccelerator* v4l2_dec)
2067 : v4l2_dec_(v4l2_dec) {
2068 DCHECK(v4l2_dec_);
2069 }
2070
2071 V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::~V4L2VP8Accelerator() {
2072 }
2073
2074 scoped_refptr<VP8Picture>
2075 V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::CreateVP8Picture() {
2076 scoped_refptr<V4L2DecodeSurface> dec_surface = v4l2_dec_->CreateSurface();
2077 if (!dec_surface)
2078 return nullptr;
2079
2080 return new V4L2VP8Picture(dec_surface);
2081 }
2082
2083 #define ARRAY_MEMCPY_CHECKED(to, from) \
2084 do { \
2085 static_assert(sizeof(to) == sizeof(from), \
2086 #from " and " #to " arrays must be of same size"); \
2087 memcpy(to, from, sizeof(to)); \
2088 } while (0)
2089
2090 static void FillV4L2SegmentationHeader(
2091 const media::Vp8SegmentationHeader& vp8_sgmnt_hdr,
2092 struct v4l2_vp8_sgmnt_hdr* v4l2_sgmnt_hdr) {
2093 #define SET_V4L2_SGMNT_HDR_FLAG_IF(cond, flag) \
2094 v4l2_sgmnt_hdr->flags |= ((vp8_sgmnt_hdr.cond) ? (flag) : 0)
2095 SET_V4L2_SGMNT_HDR_FLAG_IF(segmentation_enabled,
2096 V4L2_VP8_SEGMNT_HDR_FLAG_ENABLED);
2097 SET_V4L2_SGMNT_HDR_FLAG_IF(update_mb_segmentation_map,
2098 V4L2_VP8_SEGMNT_HDR_FLAG_UPDATE_MAP);
2099 SET_V4L2_SGMNT_HDR_FLAG_IF(update_segment_feature_data,
2100 V4L2_VP8_SEGMNT_HDR_FLAG_UPDATE_FEATURE_DATA);
2101 #undef SET_V4L2_SPARM_FLAG_IF
2102 v4l2_sgmnt_hdr->segment_feature_mode = vp8_sgmnt_hdr.segment_feature_mode;
2103
2104 ARRAY_MEMCPY_CHECKED(v4l2_sgmnt_hdr->quant_update,
2105 vp8_sgmnt_hdr.quantizer_update_value);
2106 ARRAY_MEMCPY_CHECKED(v4l2_sgmnt_hdr->lf_update,
2107 vp8_sgmnt_hdr.lf_update_value);
2108 ARRAY_MEMCPY_CHECKED(v4l2_sgmnt_hdr->segment_probs,
2109 vp8_sgmnt_hdr.segment_prob);
2110 }
2111
2112 static void FillV4L2LoopfilterHeader(
2113 const media::Vp8LoopFilterHeader& vp8_loopfilter_hdr,
2114 struct v4l2_vp8_loopfilter_hdr* v4l2_lf_hdr) {
2115 #define SET_V4L2_LF_HDR_FLAG_IF(cond, flag) \
2116 v4l2_lf_hdr->flags |= ((vp8_loopfilter_hdr.cond) ? (flag) : 0)
2117 SET_V4L2_LF_HDR_FLAG_IF(loop_filter_adj_enable, V4L2_VP8_LF_HDR_ADJ_ENABLE);
2118 SET_V4L2_LF_HDR_FLAG_IF(mode_ref_lf_delta_update,
2119 V4L2_VP8_LF_HDR_DELTA_UPDATE);
2120 #undef SET_V4L2_SGMNT_HDR_FLAG_IF
2121
2122 #define LF_HDR_TO_V4L2_LF_HDR(a) v4l2_lf_hdr->a = vp8_loopfilter_hdr.a;
2123 LF_HDR_TO_V4L2_LF_HDR(type);
2124 LF_HDR_TO_V4L2_LF_HDR(level);
2125 LF_HDR_TO_V4L2_LF_HDR(sharpness_level);
2126 #undef LF_HDR_TO_V4L2_LF_HDR
2127
2128 ARRAY_MEMCPY_CHECKED(v4l2_lf_hdr->ref_frm_delta_magnitude,
2129 vp8_loopfilter_hdr.ref_frame_delta);
2130 ARRAY_MEMCPY_CHECKED(v4l2_lf_hdr->mb_mode_delta_magnitude,
2131 vp8_loopfilter_hdr.mb_mode_delta);
2132 }
2133
2134 static void FillV4L2QuantizationHeader(
2135 const media::Vp8QuantizationHeader& vp8_quant_hdr,
2136 struct v4l2_vp8_quantization_hdr* v4l2_quant_hdr) {
2137 v4l2_quant_hdr->y_ac_qi = vp8_quant_hdr.y_ac_qi;
2138 v4l2_quant_hdr->y_dc_delta = vp8_quant_hdr.y_dc_delta;
2139 v4l2_quant_hdr->y2_dc_delta = vp8_quant_hdr.y2_dc_delta;
2140 v4l2_quant_hdr->y2_ac_delta = vp8_quant_hdr.y2_ac_delta;
2141 v4l2_quant_hdr->uv_dc_delta = vp8_quant_hdr.uv_dc_delta;
2142 v4l2_quant_hdr->uv_ac_delta = vp8_quant_hdr.uv_ac_delta;
2143 }
2144
2145 static void FillV4L2EntropyHeader(
2146 const media::Vp8EntropyHeader& vp8_entropy_hdr,
2147 struct v4l2_vp8_entropy_hdr* v4l2_entropy_hdr) {
2148 ARRAY_MEMCPY_CHECKED(v4l2_entropy_hdr->coeff_probs,
2149 vp8_entropy_hdr.coeff_probs);
2150 ARRAY_MEMCPY_CHECKED(v4l2_entropy_hdr->y_mode_probs,
2151 vp8_entropy_hdr.y_mode_probs);
2152 ARRAY_MEMCPY_CHECKED(v4l2_entropy_hdr->uv_mode_probs,
2153 vp8_entropy_hdr.uv_mode_probs);
2154 ARRAY_MEMCPY_CHECKED(v4l2_entropy_hdr->mv_probs,
2155 vp8_entropy_hdr.mv_probs);
2156 }
2157
2158 bool V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::SubmitDecode(
2159 const scoped_refptr<VP8Picture>& pic,
2160 const media::Vp8FrameHeader* frame_hdr,
2161 const scoped_refptr<VP8Picture>& last_frame,
2162 const scoped_refptr<VP8Picture>& golden_frame,
2163 const scoped_refptr<VP8Picture>& alt_frame) {
2164 struct v4l2_ctrl_vp8_frame_hdr v4l2_frame_hdr;
2165 memset(&v4l2_frame_hdr, 0, sizeof(v4l2_frame_hdr));
2166
2167 #define FHDR_TO_V4L2_FHDR(a) v4l2_frame_hdr.a = frame_hdr->a
2168 FHDR_TO_V4L2_FHDR(key_frame);
2169 FHDR_TO_V4L2_FHDR(version);
2170 FHDR_TO_V4L2_FHDR(width);
2171 FHDR_TO_V4L2_FHDR(horizontal_scale);
2172 FHDR_TO_V4L2_FHDR(height);
2173 FHDR_TO_V4L2_FHDR(vertical_scale);
2174 FHDR_TO_V4L2_FHDR(sign_bias_golden);
2175 FHDR_TO_V4L2_FHDR(sign_bias_alternate);
2176 FHDR_TO_V4L2_FHDR(prob_skip_false);
2177 FHDR_TO_V4L2_FHDR(prob_intra);
2178 FHDR_TO_V4L2_FHDR(prob_last);
2179 FHDR_TO_V4L2_FHDR(prob_gf);
2180 FHDR_TO_V4L2_FHDR(bool_dec_range);
2181 FHDR_TO_V4L2_FHDR(bool_dec_value);
2182 FHDR_TO_V4L2_FHDR(bool_dec_count);
2183 #undef FHDR_TO_V4L2_FHDR
2184
2185 #define SET_V4L2_FRM_HDR_FLAG_IF(cond, flag) \
2186 v4l2_frame_hdr.flags |= ((frame_hdr->cond) ? (flag) : 0)
2187 SET_V4L2_FRM_HDR_FLAG_IF(is_experimental,
2188 V4L2_VP8_FRAME_HDR_FLAG_EXPERIMENTAL);
2189 SET_V4L2_FRM_HDR_FLAG_IF(show_frame, V4L2_VP8_FRAME_HDR_FLAG_SHOW_FRAME);
2190 SET_V4L2_FRM_HDR_FLAG_IF(mb_no_skip_coeff,
2191 V4L2_VP8_FRAME_HDR_FLAG_MB_NO_SKIP_COEFF);
2192 #undef SET_V4L2_FRM_HDR_FLAG_IF
2193
2194 FillV4L2SegmentationHeader(frame_hdr->segmentation_hdr,
2195 &v4l2_frame_hdr.sgmnt_hdr);
2196
2197 FillV4L2LoopfilterHeader(frame_hdr->loopfilter_hdr, &v4l2_frame_hdr.lf_hdr);
2198
2199 FillV4L2QuantizationHeader(frame_hdr->quantization_hdr,
2200 &v4l2_frame_hdr.quant_hdr);
2201
2202 FillV4L2EntropyHeader(frame_hdr->entropy_hdr, &v4l2_frame_hdr.entropy_hdr);
2203
2204 v4l2_frame_hdr.first_part_size =
2205 base::checked_cast<__u32>(frame_hdr->first_part_size);
2206 v4l2_frame_hdr.first_part_offset =
2207 base::checked_cast<__u32>(frame_hdr->first_part_offset);
2208 v4l2_frame_hdr.macroblock_bit_offset =
2209 base::checked_cast<__u32>(frame_hdr->macroblock_bit_offset);
2210 v4l2_frame_hdr.num_dct_parts = frame_hdr->num_of_dct_partitions;
2211
2212 static_assert(arraysize(v4l2_frame_hdr.dct_part_sizes) ==
2213 arraysize(frame_hdr->dct_partition_sizes),
2214 "DCT partition size arrays must have equal number of elements");
2215 for (size_t i = 0; i < frame_hdr->num_of_dct_partitions &&
2216 i < arraysize(v4l2_frame_hdr.dct_part_sizes); ++i)
2217 v4l2_frame_hdr.dct_part_sizes[i] = frame_hdr->dct_partition_sizes[i];
2218
2219 scoped_refptr<V4L2DecodeSurface> dec_surface =
2220 VP8PictureToV4L2DecodeSurface(pic);
2221 std::vector<scoped_refptr<V4L2DecodeSurface>> ref_surfaces;
2222
2223 if (last_frame) {
2224 scoped_refptr<V4L2DecodeSurface> last_frame_surface =
2225 VP8PictureToV4L2DecodeSurface(last_frame);
2226 v4l2_frame_hdr.last_frame = last_frame_surface->output_record();
2227 ref_surfaces.push_back(last_frame_surface);
2228 } else {
2229 v4l2_frame_hdr.last_frame = VIDEO_MAX_FRAME;
2230 }
2231
2232 if (golden_frame) {
2233 scoped_refptr<V4L2DecodeSurface> golden_frame_surface =
2234 VP8PictureToV4L2DecodeSurface(golden_frame);
2235 v4l2_frame_hdr.golden_frame = golden_frame_surface->output_record();
2236 ref_surfaces.push_back(golden_frame_surface);
2237 } else {
2238 v4l2_frame_hdr.golden_frame = VIDEO_MAX_FRAME;
2239 }
2240
2241 if (alt_frame) {
2242 scoped_refptr<V4L2DecodeSurface> alt_frame_surface =
2243 VP8PictureToV4L2DecodeSurface(alt_frame);
2244 v4l2_frame_hdr.alt_frame = alt_frame_surface->output_record();
2245 ref_surfaces.push_back(alt_frame_surface);
2246 } else {
2247 v4l2_frame_hdr.alt_frame = VIDEO_MAX_FRAME;
2248 }
2249
2250 struct v4l2_ext_control ctrl;
2251 memset(&ctrl, 0, sizeof(ctrl));
2252 ctrl.id = V4L2_CID_MPEG_VIDEO_VP8_FRAME_HDR;
2253 ctrl.size = sizeof(v4l2_frame_hdr);
2254 ctrl.p_vp8_frame_hdr = &v4l2_frame_hdr;
2255
2256 struct v4l2_ext_controls ext_ctrls;
2257 memset(&ext_ctrls, 0, sizeof(ext_ctrls));
2258 ext_ctrls.count = 1;
2259 ext_ctrls.controls = &ctrl;
2260 ext_ctrls.config_store = dec_surface->config_store();
2261
2262 if (!v4l2_dec_->SubmitExtControls(&ext_ctrls))
2263 return false;
2264
2265 dec_surface->SetReferenceSurfaces(ref_surfaces);
2266
2267 if (!v4l2_dec_->SubmitSlice(dec_surface->input_record(), frame_hdr->data,
2268 frame_hdr->frame_size))
2269 return false;
2270
2271 v4l2_dec_->DecodeSurface(dec_surface);
2272 return true;
2273 }
2274
2275 bool V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::OutputPicture(
2276 const scoped_refptr<VP8Picture>& pic) {
2277 scoped_refptr<V4L2DecodeSurface> dec_surface =
2278 VP8PictureToV4L2DecodeSurface(pic);
2279
2280 v4l2_dec_->SurfaceReady(dec_surface);
2281 return true;
2282 }
2283
2284 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
2285 V4L2SliceVideoDecodeAccelerator::V4L2VP8Accelerator::
2286 VP8PictureToV4L2DecodeSurface(const scoped_refptr<VP8Picture>& pic) {
2287 V4L2VP8Picture* v4l2_pic = pic->AsV4L2VP8Picture();
2288 CHECK(v4l2_pic);
2289 return v4l2_pic->dec_surface();
2290 }
2291
2292 void V4L2SliceVideoDecodeAccelerator::DecodeSurface(
2293 const scoped_refptr<V4L2DecodeSurface>& dec_surface) {
2294 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2295
2296 DVLOGF(3) << "Submitting decode for surface: " << dec_surface->ToString();
2297 Enqueue(dec_surface);
2298 }
2299
2300 void V4L2SliceVideoDecodeAccelerator::SurfaceReady(
2301 const scoped_refptr<V4L2DecodeSurface>& dec_surface) {
2302 DVLOGF(3);
2303 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2304
2305 decoder_display_queue_.push(dec_surface);
2306 TryOutputSurfaces();
2307 }
2308
2309 void V4L2SliceVideoDecodeAccelerator::TryOutputSurfaces() {
2310 while (!decoder_display_queue_.empty()) {
2311 scoped_refptr<V4L2DecodeSurface> dec_surface =
2312 decoder_display_queue_.front();
2313
2314 if (!dec_surface->decoded())
2315 break;
2316
2317 decoder_display_queue_.pop();
2318 OutputSurface(dec_surface);
2319 }
2320 }
2321
2322 void V4L2SliceVideoDecodeAccelerator::OutputSurface(
2323 const scoped_refptr<V4L2DecodeSurface>& dec_surface) {
2324 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2325
2326 OutputRecord& output_record =
2327 output_buffer_map_[dec_surface->output_record()];
2328
2329 bool inserted =
2330 surfaces_at_display_.insert(std::make_pair(output_record.picture_id,
2331 dec_surface)).second;
2332 DCHECK(inserted);
2333
2334 DCHECK(!output_record.at_client);
2335 DCHECK(!output_record.at_device);
2336 DCHECK_NE(output_record.egl_image, EGL_NO_IMAGE_KHR);
2337 DCHECK_NE(output_record.picture_id, -1);
2338 output_record.at_client = true;
2339
2340 media::Picture picture(output_record.picture_id, dec_surface->bitstream_id(),
2341 gfx::Rect(frame_buffer_size_));
2342 DVLOGF(3) << dec_surface->ToString()
2343 << ", bitstream_id: " << picture.bitstream_buffer_id()
2344 << ", picture_id: " << picture.picture_buffer_id();
2345 pending_picture_ready_.push(PictureRecord(output_record.cleared, picture));
2346 SendPictureReady();
2347 output_record.cleared = true;
2348 }
2349
2350 scoped_refptr<V4L2SliceVideoDecodeAccelerator::V4L2DecodeSurface>
2351 V4L2SliceVideoDecodeAccelerator::CreateSurface() {
2352 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2353
2354 if (free_input_buffers_.empty() || free_output_buffers_.empty())
2355 return nullptr;
2356
2357 int input = free_input_buffers_.front();
2358 free_input_buffers_.pop_front();
2359 int output = free_output_buffers_.front();
2360 free_output_buffers_.pop_front();
2361
2362 InputRecord& input_record = input_buffer_map_[input];
2363 DCHECK_EQ(input_record.bytes_used, 0u);
2364 DCHECK_EQ(input_record.input_id, -1);
2365 DCHECK(decoder_current_bitstream_buffer_ != nullptr);
2366 input_record.input_id = decoder_current_bitstream_buffer_->input_id;
2367
2368 scoped_refptr<V4L2DecodeSurface> dec_surface = new V4L2DecodeSurface(
2369 decoder_current_bitstream_buffer_->input_id, input, output,
2370 base::Bind(&V4L2SliceVideoDecodeAccelerator::ReuseOutputBuffer,
2371 base::Unretained(this)));
2372
2373 DVLOGF(4) << "Created surface " << input << " -> " << output;
2374 return dec_surface;
2375 }
2376
2377 void V4L2SliceVideoDecodeAccelerator::SendPictureReady() {
2378 DVLOGF(3);
2379 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2380 bool resetting_or_flushing = (decoder_resetting_ || decoder_flushing_);
2381 while (!pending_picture_ready_.empty()) {
2382 bool cleared = pending_picture_ready_.front().cleared;
2383 const media::Picture& picture = pending_picture_ready_.front().picture;
2384 if (cleared && picture_clearing_count_ == 0) {
2385 DVLOGF(4) << "Posting picture ready to IO for: "
2386 << picture.picture_buffer_id();
2387 // This picture is cleared. Post it to IO thread to reduce latency. This
2388 // should be the case after all pictures are cleared at the beginning.
2389 io_message_loop_proxy_->PostTask(
2390 FROM_HERE, base::Bind(&Client::PictureReady, io_client_, picture));
2391 pending_picture_ready_.pop();
2392 } else if (!cleared || resetting_or_flushing) {
2393 DVLOGF(3) << "cleared=" << pending_picture_ready_.front().cleared
2394 << ", decoder_resetting_=" << decoder_resetting_
2395 << ", decoder_flushing_=" << decoder_flushing_
2396 << ", picture_clearing_count_=" << picture_clearing_count_;
2397 DVLOGF(4) << "Posting picture ready to GPU for: "
2398 << picture.picture_buffer_id();
2399 // If the picture is not cleared, post it to the child thread because it
2400 // has to be cleared in the child thread. A picture only needs to be
2401 // cleared once. If the decoder is resetting or flushing, send all
2402 // pictures to ensure PictureReady arrive before reset or flush done.
2403 child_message_loop_proxy_->PostTaskAndReply(
2404 FROM_HERE, base::Bind(&Client::PictureReady, client_, picture),
2405 // Unretained is safe. If Client::PictureReady gets to run, |this| is
2406 // alive. Destroy() will wait the decode thread to finish.
2407 base::Bind(&V4L2SliceVideoDecodeAccelerator::PictureCleared,
2408 base::Unretained(this)));
2409 picture_clearing_count_++;
2410 pending_picture_ready_.pop();
2411 } else {
2412 // This picture is cleared. But some pictures are about to be cleared on
2413 // the child thread. To preserve the order, do not send this until those
2414 // pictures are cleared.
2415 break;
2416 }
2417 }
2418 }
2419
2420 void V4L2SliceVideoDecodeAccelerator::PictureCleared() {
2421 DVLOGF(3) << "clearing count=" << picture_clearing_count_;
2422 DCHECK(decoder_thread_proxy_->BelongsToCurrentThread());
2423 DCHECK_GT(picture_clearing_count_, 0);
2424 picture_clearing_count_--;
2425 SendPictureReady();
2426 }
2427
2428 bool V4L2SliceVideoDecodeAccelerator::CanDecodeOnIOThread() {
2429 return true;
2430 }
2431
2432 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698