src/camera/drivers/hw_accel/ge2d/ge2d_task.h

// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef SRC_CAMERA_DRIVERS_HW_ACCEL_GE2D_GE2D_TASK_H_
#define SRC_CAMERA_DRIVERS_HW_ACCEL_GE2D_GE2D_TASK_H_

#include <fuchsia/hardware/amlogiccanvas/cpp/banjo.h>
#include <fuchsia/hardware/ge2d/cpp/banjo.h>

#include <deque>
#include <unordered_map>
#include <vector>

#include "src/camera/drivers/hw_accel/task/task.h"

namespace ge2d {

// Move-only amlogic canvas ID wrappper.
class ScopedCanvasId {
 public:
  ScopedCanvasId() = default;
  ScopedCanvasId(const amlogic_canvas_protocol_t* canvas, uint8_t id) : canvas_(canvas), id_(id) {}
  ScopedCanvasId(ScopedCanvasId&& other);
  ScopedCanvasId(const ScopedCanvasId&) = delete;

  ScopedCanvasId& operator=(ScopedCanvasId&& other);
  ScopedCanvasId& operator=(ScopedCanvasId&) = delete;

  ~ScopedCanvasId() { Reset(); }

  void Reset();
  uint8_t id() const { return id_; }
  bool valid() const { return static_cast<bool>(canvas_); }

 private:
  const amlogic_canvas_protocol_t* canvas_ = nullptr;
  uint8_t id_ = 0;
};

static const uint8_t kYComponent = 0;
static const uint8_t kUVComponent = 1;

typedef struct image_canvas_id {
  ScopedCanvasId canvas_idx[2];
} image_canvas_id_t;

typedef struct input_image_canvas_id {
  image_canvas_id_t canvas_ids;
  zx::vmo vmo;
} input_image_canvas_id_t;

class Ge2dTask : public generictask::GenericTask {
 public:
  enum Ge2dTaskType { GE2D_RESIZE, GE2D_WATERMARK, GE2D_IN_PLACE_WATERMARK };

  // Note on Input and Output image formats :
  // Resize task takes 1 input format and a table of output formats. The resize
  // task only supports changing the Output Resolution.
  // Watermark task takes 1 table of image formats. The Watermark task only
  // supports changing the input and output resolution. Both are changed.

  // Static function to create a task object.
  // |input_buffer_collection|              : Input buffer collection.
  // |output_buffer_collection|             : Output buffer collection.
  // [info]                                 : Either Resize or Watermark Info.
  // [input_image_format]                   : input image format.
  // [output_image_format_table_list]       : List of output image formats.
  // [output_image_format_table_count]      : Size of output image format table.
  // [output_image_format_index]            : Index of output mage format to initialize with.
  // |callback|                             : Callback function to call for.
  // this task. |out|                       : Pointer to a task.
  // object returned to the caller.
  zx_status_t InitResize(const buffer_collection_info_2_t* input_buffer_collection,
                         const buffer_collection_info_2_t* output_buffer_collection,
                         const resize_info_t* info, const image_format_2_t* input_image_format,
                         const image_format_2_t* output_image_format_table_list,
                         size_t output_image_format_table_count, uint32_t output_image_format_index,
                         const hw_accel_frame_callback_t* frame_callback,
                         const hw_accel_res_change_callback_t* res_callback,
                         const hw_accel_remove_task_callback_t* remove_task_callback,
                         const zx::bti& bti, amlogic_canvas_protocol_t canvas);

  // We use the same image format list (and image format index) for both input and output
  // for watermark tasks.
  zx_status_t InitWatermark(const buffer_collection_info_2_t* input_buffer_collection,
                            const buffer_collection_info_2_t* output_buffer_collection,
                            const water_mark_info_t* info_list,
                            const image_format_2_t* image_format_table_list,
                            size_t image_format_table_count, uint32_t image_format_index,
                            const hw_accel_frame_callback_t* frame_callback,
                            const hw_accel_res_change_callback_t* res_callback,
                            const hw_accel_remove_task_callback_t* remove_task_callback,
                            const zx::bti& bti, amlogic_canvas_protocol_t canvas);

  // We use the same image format list (and image format index) for both input and output
  // for watermark tasks.
  zx_status_t InitInPlaceWatermark(const buffer_collection_info_2_t* input_buffer_collection,
                                   const water_mark_info_t* info_list,
                                   const image_format_2_t* image_format_table_list,
                                   size_t image_format_table_count, uint32_t image_format_index,
                                   const hw_accel_frame_callback_t* frame_callback,
                                   const hw_accel_res_change_callback_t* res_callback,
                                   const hw_accel_remove_task_callback_t* remove_task_callback,
                                   const zx::bti& bti, amlogic_canvas_protocol_t canvas);

  const image_canvas_id_t& GetOutputCanvasIds(zx_handle_t vmo) {
    auto entry = buffer_map_.find(vmo);
    ZX_ASSERT(entry != buffer_map_.end());

    return entry->second;
  }

  const image_canvas_id_t& GetInputCanvasIds(uint32_t index) {
    return input_image_canvas_ids_[index].canvas_ids;
  }

  ~Ge2dTask() { FreeCanvasIds(); }

  void Ge2dChangeOutputRes(uint32_t new_output_buffer_index);
  void Ge2dChangeInputRes(uint32_t new_input_buffer_index);

  Ge2dTaskType Ge2dTaskType() const { return task_type_; }

  resize_info_t resize_info() const { return res_info_; }

  void SetCropRect(const rect_t& rect) { res_info_.crop = rect; }

  // Use input_format_index because that's valid for both in-place and non-in-place watermark tasks.
  image_format_2_t WatermarkFormat() { return wm_[input_format_index()].image_format; }
  uint32_t watermark_loc_x() const { return wm_[input_format_index()].loc_x; }
  uint32_t watermark_loc_y() const { return wm_[input_format_index()].loc_y; }

  const image_canvas_id& watermark_input_canvas() {
    return wm_[input_format_index()].input_canvas_id;
  }
  const image_canvas_id& watermark_blended_canvas() { return wm_blended_canvas_id_; }

  zx::vmo& watermark_blended_vmo() { return watermark_blended_vmo_; }

  bool has_output_images() const { return Ge2dTaskType() != Ge2dTask::GE2D_IN_PLACE_WATERMARK; }

 private:
  zx_status_t Init(const buffer_collection_info_2_t* input_buffer_collection,
                   const buffer_collection_info_2_t* output_buffer_collection,
                   const image_format_2_t* input_image_format_table_list,
                   size_t input_image_format_table_count, uint32_t input_image_format_index,
                   const image_format_2_t* output_image_format_table_list,
                   size_t output_image_format_table_count, uint32_t output_image_format_index,
                   const hw_accel_frame_callback_t* frame_callback,
                   const hw_accel_res_change_callback_t* res_callback,
                   const hw_accel_remove_task_callback_t* remove_task_callback, const zx::bti& bti);
  zx_status_t InitializeWatermarkImages(const water_mark_info_t* wm_info,
                                        size_t image_format_table_count, const zx::bti& bti,
                                        amlogic_canvas_protocol_t canvas);
  // Allocates canvas ids for every frame in the input and output buffer collections
  // (amlogic). One canvas id is allocated per plane of the image frame. Internally,
  // canvas id allocation pins the vmos (zx_bit_pin()).
  zx_status_t AllocCanvasIds(const buffer_collection_info_2_t* input_buffer_collection,
                             const buffer_collection_info_2_t* output_buffer_collection,
                             const image_format_2_t* input_image_format,
                             const image_format_2_t* output_image_format);
  zx_status_t AllocCanvasId(const image_format_2_t* image_format, zx_handle_t vmo_in,
                            image_canvas_id_t& canvas_ids, uint32_t alloc_flag);
  // Called from AllocCanvasIds() to allocate canvas ids for input and output buffer
  // collections.
  zx_status_t AllocInputCanvasIds(const buffer_collection_info_2_t* input_buffer_collection,
                                  const image_format_2_t* input_image_format, bool enable_write);
  zx_status_t AllocOutputCanvasIds(const buffer_collection_info_2_t* output_buffer_collection,
                                   const image_format_2_t* output_image_format);
  void FreeCanvasIds();
  void AllocateWatermarkCanvasIds();

  enum Ge2dTaskType task_type_;
  amlogic_canvas_protocol_t canvas_ = {};
  std::unique_ptr<image_format_2_t[]> output_image_format_list_;
  struct watermark_info {
    uint32_t loc_x;
    uint32_t loc_y;
    image_format_2_t image_format;
    image_canvas_id input_canvas_id;
    // Allocate a contig vmo to hold the input watermark image.
    zx::vmo watermark_input_vmo;
  };
  std::vector<watermark_info> wm_;
  // Canvas id for the watermark image and the blended watermark image.
  // Both are RGBA images.
  image_canvas_id wm_blended_canvas_id_;
  // vmo to hold blended watermark image.
  zx::vmo watermark_blended_vmo_;
  resize_info_t res_info_;
  std::unordered_map<zx_handle_t, image_canvas_id_t> buffer_map_;
  uint32_t num_input_canvas_ids_;
  std::unique_ptr<input_image_canvas_id_t[]> input_image_canvas_ids_;
};
}  // namespace ge2d

#endif  // SRC_CAMERA_DRIVERS_HW_ACCEL_GE2D_GE2D_TASK_H_