| OLD | NEW |
| (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 | |
| OLD | NEW |