MJPEG acceleration for V4L2

content/common/gpu/media/gpu_jpeg_decode_accelerator.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/common/gpu/media/gpu_jpeg_decode_accelerator.h"
 
 #include <stdint.h>
 
 #include "base/bind.h"
 #include "base/containers/hash_tables.h"
 #include "base/logging.h"
 #include "base/memory/shared_memory.h"
 #include "base/single_thread_task_runner.h"
 #include "base/stl_util.h"
 #include "base/trace_event/trace_event.h"
 #include "content/common/gpu/gpu_channel.h"
 #include "content/common/gpu/gpu_messages.h"
 #include "ipc/ipc_message_macros.h"
 #include "ipc/message_filter.h"
 #include "media/filters/jpeg_parser.h"
 #include "ui/gfx/geometry/size.h"
 
-#if defined(OS_CHROMEOS) && defined(ARCH_CPU_X86_FAMILY)
+#if defined(OS_CHROMEOS)
+#if defined(ARCH_CPU_X86_FAMILY)
 #include "content/common/gpu/media/vaapi_jpeg_decode_accelerator.h"
 #endif
+#if defined(USE_V4L2_CODEC)
+#include "content/common/gpu/media/v4l2_device.h"
+#include "content/common/gpu/media/v4l2_jpeg_decode_accelerator.h"
+#endif
+#endif
 
 namespace {
 
 void DecodeFinished(scoped_ptr<base::SharedMemory> shm) {
   // Do nothing. Because VideoFrame is backed by |shm|, the purpose of this
   // function is to just keep reference of |shm| to make sure it lives util
   // decode finishes.
 }
 
 bool VerifyDecodeParams(const AcceleratedJpegDecoderMsg_Decode_Params& params) {
@@ skipping 283 matching lines @@
 
 void GpuJpegDecodeAccelerator::AddClient(int32 route_id,
                                          IPC::Message* reply_msg) {
   DCHECK(CalledOnValidThread());
   scoped_ptr<media::JpegDecodeAccelerator> accelerator;
 
 // When adding more platforms, VideoCaptureGpuJpegDecoder::Supported need
 // update as well.
 #if defined(OS_CHROMEOS) && defined(ARCH_CPU_X86_FAMILY)
   accelerator.reset(new VaapiJpegDecodeAccelerator(io_task_runner_));
+#elif defined(OS_CHROMEOS) && defined(USE_V4L2_CODEC)
+  scoped_refptr<V4L2Device> device = V4L2Device::Create(
+      V4L2Device::kJpegDecoder);
+  if (device) {
+    accelerator.reset(new V4L2JpegDecodeAccelerator(
+        device, io_task_runner_));
+  }
 #else
   DVLOG(1) << "HW JPEG decode acceleration not available.";
 #endif
 
   scoped_ptr<Client> client(new Client(this, route_id));
   if (!accelerator.get() || !accelerator->Initialize(client.get())) {
     DLOG(ERROR) << "JPEG accelerator Initialize failed";
     GpuMsg_CreateJpegDecoder::WriteReplyParams(reply_msg, false);
     Send(reply_msg);
     return;
@@ skipping 36 matching lines @@
     filter_ = nullptr;
   }
 }
 
 bool GpuJpegDecodeAccelerator::Send(IPC::Message* message) {
   DCHECK(CalledOnValidThread());
   return channel_->Send(message);
 }
 
 }  // namespace content