]> git.ipfire.org Git - thirdparty/linux.git/commitdiff
media: qcom: camss: vfe: Move common code into vfe core
authorDepeng Shao <quic_depengs@quicinc.com>
Mon, 13 Jan 2025 04:31:25 +0000 (10:01 +0530)
committerHans Verkuil <hverkuil@xs4all.nl>
Thu, 6 Feb 2025 12:49:31 +0000 (13:49 +0100)
Some v4l2 buffer related logic functions can be moved to vfe core as
common code, then the vfe driver of different hw version can reuse them,
this also can avoid adding duplicate code for new version supporting.

Suggested-by: Bryan O'Donoghue <bryan.odonoghue@linaro.org>
Signed-off-by: Depeng Shao <quic_depengs@quicinc.com>
Signed-off-by: Hans Verkuil <hverkuil@xs4all.nl>
drivers/media/platform/qcom/camss/camss-vfe-17x.c
drivers/media/platform/qcom/camss/camss-vfe-4-1.c
drivers/media/platform/qcom/camss/camss-vfe-4-7.c
drivers/media/platform/qcom/camss/camss-vfe-4-8.c
drivers/media/platform/qcom/camss/camss-vfe-480.c
drivers/media/platform/qcom/camss/camss-vfe.c
drivers/media/platform/qcom/camss/camss-vfe.h

index 380c99321030ecfe359a82fce228a45015b7b581..e5ee7e717b3bcb88916249cb710d90e840082a4a 100644 (file)
@@ -14,8 +14,6 @@
 #include "camss.h"
 #include "camss-vfe.h"
 
-#define VFE_HW_VERSION                         (0x000)
-
 #define VFE_GLOBAL_RESET_CMD                   (0x018)
 #define                GLOBAL_RESET_CMD_CORE           BIT(0)
 #define                GLOBAL_RESET_CMD_CAMIF          BIT(1)
 #define VFE_BUS_WM_FRAME_INC(n)                        (0x2258 + (n) * 0x100)
 #define VFE_BUS_WM_BURST_LIMIT(n)              (0x225c + (n) * 0x100)
 
-static u32 vfe_hw_version(struct vfe_device *vfe)
-{
-       u32 hw_version = readl_relaxed(vfe->base + VFE_HW_VERSION);
-
-       u32 gen = (hw_version >> 28) & 0xF;
-       u32 rev = (hw_version >> 16) & 0xFFF;
-       u32 step = hw_version & 0xFFFF;
-
-       dev_dbg(vfe->camss->dev, "VFE HW Version = %u.%u.%u\n",
-               gen, rev, step);
-
-       return hw_version;
-}
-
 static inline void vfe_reg_set(struct vfe_device *vfe, u32 reg, u32 set_bits)
 {
        u32 bits = readl_relaxed(vfe->base + reg);
@@ -438,62 +422,6 @@ error:
        return -EINVAL;
 }
 
-static int vfe_enable_output(struct vfe_line *line)
-{
-       struct vfe_device *vfe = to_vfe(line);
-       struct vfe_output *output = &line->output;
-       const struct vfe_hw_ops *ops = vfe->res->hw_ops;
-       struct media_entity *sensor;
-       unsigned long flags;
-       unsigned int frame_skip = 0;
-       unsigned int i;
-
-       sensor = camss_find_sensor(&line->subdev.entity);
-       if (sensor) {
-               struct v4l2_subdev *subdev = media_entity_to_v4l2_subdev(sensor);
-
-               v4l2_subdev_call(subdev, sensor, g_skip_frames, &frame_skip);
-               /* Max frame skip is 29 frames */
-               if (frame_skip > VFE_FRAME_DROP_VAL - 1)
-                       frame_skip = VFE_FRAME_DROP_VAL - 1;
-       }
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       ops->reg_update_clear(vfe, line->id);
-
-       if (output->state > VFE_OUTPUT_RESERVED) {
-               dev_err(vfe->camss->dev, "Output is not in reserved state %d\n",
-                       output->state);
-               spin_unlock_irqrestore(&vfe->output_lock, flags);
-               return -EINVAL;
-       }
-
-       WARN_ON(output->gen2.active_num);
-
-       output->state = VFE_OUTPUT_ON;
-
-       output->sequence = 0;
-       output->wait_reg_update = 0;
-       reinit_completion(&output->reg_update);
-
-       vfe_wm_start(vfe, output->wm_idx[0], line);
-
-       for (i = 0; i < 2; i++) {
-               output->buf[i] = vfe_buf_get_pending(output);
-               if (!output->buf[i])
-                       break;
-               output->gen2.active_num++;
-               vfe_wm_update(vfe, output->wm_idx[0], output->buf[i]->addr[0], line);
-       }
-
-       ops->reg_update(vfe, line->id);
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       return 0;
-}
-
 /*
  * vfe_enable - Enable streaming on VFE line
  * @line: VFE line
@@ -518,7 +446,7 @@ static int vfe_enable(struct vfe_line *line)
        if (ret < 0)
                goto error_get_output;
 
-       ret = vfe_enable_output(line);
+       ret = vfe_enable_output_v2(line);
        if (ret < 0)
                goto error_enable_output;
 
@@ -627,40 +555,6 @@ out_unlock:
        spin_unlock_irqrestore(&vfe->output_lock, flags);
 }
 
-/*
- * vfe_queue_buffer - Add empty buffer
- * @vid: Video device structure
- * @buf: Buffer to be enqueued
- *
- * Add an empty buffer - depending on the current number of buffers it will be
- * put in pending buffer queue or directly given to the hardware to be filled.
- *
- * Return 0 on success or a negative error code otherwise
- */
-static int vfe_queue_buffer(struct camss_video *vid,
-                           struct camss_buffer *buf)
-{
-       struct vfe_line *line = container_of(vid, struct vfe_line, video_out);
-       struct vfe_device *vfe = to_vfe(line);
-       struct vfe_output *output;
-       unsigned long flags;
-
-       output = &line->output;
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       if (output->state == VFE_OUTPUT_ON && output->gen2.active_num < 2) {
-               output->buf[output->gen2.active_num++] = buf;
-               vfe_wm_update(vfe, output->wm_idx[0], buf->addr[0], line);
-       } else {
-               vfe_buf_add_pending(output, buf);
-       }
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       return 0;
-}
-
 static const struct vfe_isr_ops vfe_isr_ops_170 = {
        .reset_ack = vfe_isr_reset_ack,
        .halt_ack = vfe_isr_halt_ack,
@@ -671,7 +565,7 @@ static const struct vfe_isr_ops vfe_isr_ops_170 = {
 };
 
 static const struct camss_video_ops vfe_video_ops_170 = {
-       .queue_buffer = vfe_queue_buffer,
+       .queue_buffer = vfe_queue_buffer_v2,
        .flush_buffers = vfe_flush_buffers,
 };
 
@@ -695,5 +589,7 @@ const struct vfe_hw_ops vfe_ops_170 = {
        .vfe_enable = vfe_enable,
        .vfe_halt = vfe_halt,
        .violation_read = vfe_violation_read,
+       .vfe_wm_start = vfe_wm_start,
        .vfe_wm_stop = vfe_wm_stop,
+       .vfe_wm_update = vfe_wm_update,
 };
index 9a9007c3ff33b40f4c88cd30283f0ad42f8e8d00..901677293d971cf761944a660ef719af38203f22 100644 (file)
 #define MSM_VFE_VFE0_UB_SIZE 1023
 #define MSM_VFE_VFE0_UB_SIZE_RDI (MSM_VFE_VFE0_UB_SIZE / 3)
 
-static u32 vfe_hw_version(struct vfe_device *vfe)
-{
-       u32 hw_version = readl_relaxed(vfe->base + VFE_0_HW_VERSION);
-
-       dev_dbg(vfe->camss->dev, "VFE HW Version = 0x%08x\n", hw_version);
-
-       return hw_version;
-}
-
 static u16 vfe_get_ub_size(u8 vfe_id)
 {
        if (vfe_id == 0)
index ce0719106bd344f606c80c60f50b6c63bc69419d..76729607db02dab835251b8df27e92dff20f8116 100644 (file)
@@ -18,8 +18,6 @@
 #include "camss-vfe-gen1.h"
 
 
-#define VFE_0_HW_VERSION               0x000
-
 #define VFE_0_GLOBAL_RESET_CMD         0x018
 #define VFE_0_GLOBAL_RESET_CMD_CORE    BIT(0)
 #define VFE_0_GLOBAL_RESET_CMD_CAMIF   BIT(1)
 #define MSM_VFE_VFE1_UB_SIZE 1535
 #define MSM_VFE_VFE1_UB_SIZE_RDI (MSM_VFE_VFE1_UB_SIZE / 3)
 
-static u32 vfe_hw_version(struct vfe_device *vfe)
-{
-       u32 hw_version = readl_relaxed(vfe->base + VFE_0_HW_VERSION);
-
-       dev_dbg(vfe->camss->dev, "VFE HW Version = 0x%08x\n", hw_version);
-
-       return hw_version;
-}
-
 static u16 vfe_get_ub_size(u8 vfe_id)
 {
        if (vfe_id == 0)
index 6b59c8107a3c7d004db035530ea3894659b588bd..b2f7d855d8dd0f3abe1259bfdce775bfa095c978 100644 (file)
@@ -17,8 +17,6 @@
 #include "camss-vfe.h"
 #include "camss-vfe-gen1.h"
 
-#define VFE_0_HW_VERSION               0x000
-
 #define VFE_0_GLOBAL_RESET_CMD         0x018
 #define VFE_0_GLOBAL_RESET_CMD_CORE    BIT(0)
 #define VFE_0_GLOBAL_RESET_CMD_CAMIF   BIT(1)
 #define MSM_VFE_VFE1_UB_SIZE 1535
 #define MSM_VFE_VFE1_UB_SIZE_RDI (MSM_VFE_VFE1_UB_SIZE / 3)
 
-static u32 vfe_hw_version(struct vfe_device *vfe)
-{
-       u32 hw_version = readl_relaxed(vfe->base + VFE_0_HW_VERSION);
-
-       dev_dbg(vfe->camss->dev, "VFE HW Version = 0x%08x\n", hw_version);
-
-       return hw_version;
-}
-
 static inline void vfe_reg_clr(struct vfe_device *vfe, u32 reg, u32 clr_bits)
 {
        u32 bits = readl_relaxed(vfe->base + reg);
index dc2735476c82315a0bb4520b9c18e323535459e5..4feea590a47bc3355051f462814ece9539335641 100644 (file)
@@ -15,8 +15,6 @@
 #include "camss.h"
 #include "camss-vfe.h"
 
-#define VFE_HW_VERSION                 (0x00)
-
 #define VFE_GLOBAL_RESET_CMD           (vfe_is_lite(vfe) ? 0x0c : 0x1c)
 #define            GLOBAL_RESET_HW_AND_REG     (vfe_is_lite(vfe) ? BIT(1) : BIT(0))
 
@@ -92,19 +90,6 @@ static inline int bus_irq_mask_0_comp_done(struct vfe_device *vfe, int n)
 
 #define MAX_VFE_OUTPUT_LINES   4
 
-static u32 vfe_hw_version(struct vfe_device *vfe)
-{
-       u32 hw_version = readl_relaxed(vfe->base + VFE_HW_VERSION);
-
-       u32 gen = (hw_version >> 28) & 0xF;
-       u32 rev = (hw_version >> 16) & 0xFFF;
-       u32 step = hw_version & 0xFFFF;
-
-       dev_dbg(vfe->camss->dev, "VFE HW Version = %u.%u.%u\n", gen, rev, step);
-
-       return hw_version;
-}
-
 static void vfe_global_reset(struct vfe_device *vfe)
 {
        writel_relaxed(IRQ_MASK_0_RESET_ACK, vfe->base + VFE_IRQ_MASK(0));
@@ -167,18 +152,16 @@ static inline void vfe_reg_update_clear(struct vfe_device *vfe,
        vfe->reg_update &= ~REG_UPDATE_RDI(vfe, line_id);
 }
 
-static void vfe_enable_irq_common(struct vfe_device *vfe)
-{
-       /* enable reset ack IRQ and top BUS status IRQ */
-       writel_relaxed(IRQ_MASK_0_RESET_ACK | IRQ_MASK_0_BUS_TOP_IRQ,
-                      vfe->base + VFE_IRQ_MASK(0));
-}
-
-static void vfe_enable_lines_irq(struct vfe_device *vfe)
+static void vfe_enable_irq(struct vfe_device *vfe)
 {
        int i;
        u32 bus_irq_mask = 0;
 
+       if (!vfe->stream_count)
+               /* enable reset ack IRQ and top BUS status IRQ */
+               writel(IRQ_MASK_0_RESET_ACK | IRQ_MASK_0_BUS_TOP_IRQ,
+                      vfe->base + VFE_IRQ_MASK(0));
+
        for (i = 0; i < MAX_VFE_OUTPUT_LINES; i++) {
                /* Enable IRQ for newly added lines, but also keep already running lines's IRQ */
                if (vfe->line[i].output.state == VFE_OUTPUT_RESERVED ||
@@ -188,11 +171,10 @@ static void vfe_enable_lines_irq(struct vfe_device *vfe)
                        }
        }
 
-       writel_relaxed(bus_irq_mask, vfe->base + VFE_BUS_IRQ_MASK(0));
+       writel(bus_irq_mask, vfe->base + VFE_BUS_IRQ_MASK(0));
 }
 
 static void vfe_isr_reg_update(struct vfe_device *vfe, enum vfe_line_id line_id);
-static void vfe_isr_wm_done(struct vfe_device *vfe, u8 wm);
 
 /*
  * vfe_isr - VFE module interrupt handler
@@ -226,7 +208,7 @@ static irqreturn_t vfe_isr(int irq, void *dev)
                                vfe_isr_reg_update(vfe, i);
 
                        if (status & BUS_IRQ_MASK_0_COMP_DONE(vfe, RDI_COMP_GROUP(i)))
-                               vfe_isr_wm_done(vfe, i);
+                               vfe_buf_done(vfe, i);
                }
        }
 
@@ -245,132 +227,6 @@ static int vfe_halt(struct vfe_device *vfe)
        return 0;
 }
 
-static int vfe_get_output(struct vfe_line *line)
-{
-       struct vfe_device *vfe = to_vfe(line);
-       struct vfe_output *output;
-       unsigned long flags;
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       output = &line->output;
-       if (output->state > VFE_OUTPUT_RESERVED) {
-               dev_err(vfe->camss->dev, "Output is running\n");
-               goto error;
-       }
-
-       output->wm_num = 1;
-
-       /* Correspondence between VFE line number and WM number.
-        * line 0 -> RDI 0, line 1 -> RDI1, line 2 -> RDI2, line 3 -> PIX/RDI3
-        * Note this 1:1 mapping will not work for PIX streams.
-        */
-       output->wm_idx[0] = line->id;
-       vfe->wm_output_map[line->id] = line->id;
-
-       output->drop_update_idx = 0;
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       return 0;
-
-error:
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-       output->state = VFE_OUTPUT_OFF;
-
-       return -EINVAL;
-}
-
-static int vfe_enable_output(struct vfe_line *line)
-{
-       struct vfe_device *vfe = to_vfe(line);
-       struct vfe_output *output = &line->output;
-       unsigned long flags;
-       unsigned int i;
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       vfe_reg_update_clear(vfe, line->id);
-
-       if (output->state > VFE_OUTPUT_RESERVED) {
-               dev_err(vfe->camss->dev, "Output is not in reserved state %d\n",
-                       output->state);
-               spin_unlock_irqrestore(&vfe->output_lock, flags);
-               return -EINVAL;
-       }
-
-       WARN_ON(output->gen2.active_num);
-
-       output->state = VFE_OUTPUT_ON;
-
-       output->sequence = 0;
-       output->wait_reg_update = 0;
-       reinit_completion(&output->reg_update);
-
-       vfe_wm_start(vfe, output->wm_idx[0], line);
-
-       for (i = 0; i < 2; i++) {
-               output->buf[i] = vfe_buf_get_pending(output);
-               if (!output->buf[i])
-                       break;
-               output->gen2.active_num++;
-               vfe_wm_update(vfe, output->wm_idx[0], output->buf[i]->addr[0], line);
-       }
-
-       vfe_reg_update(vfe, line->id);
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       return 0;
-}
-
-/*
- * vfe_enable - Enable streaming on VFE line
- * @line: VFE line
- *
- * Return 0 on success or a negative error code otherwise
- */
-static int vfe_enable(struct vfe_line *line)
-{
-       struct vfe_device *vfe = to_vfe(line);
-       int ret;
-
-       mutex_lock(&vfe->stream_lock);
-
-       if (!vfe->stream_count)
-               vfe_enable_irq_common(vfe);
-
-       vfe->stream_count++;
-
-       vfe_enable_lines_irq(vfe);
-
-       mutex_unlock(&vfe->stream_lock);
-
-       ret = vfe_get_output(line);
-       if (ret < 0)
-               goto error_get_output;
-
-       ret = vfe_enable_output(line);
-       if (ret < 0)
-               goto error_enable_output;
-
-       vfe->was_streaming = 1;
-
-       return 0;
-
-error_enable_output:
-       vfe_put_output(line);
-
-error_get_output:
-       mutex_lock(&vfe->stream_lock);
-
-       vfe->stream_count--;
-
-       mutex_unlock(&vfe->stream_lock);
-
-       return ret;
-}
-
 /*
  * vfe_isr_reg_update - Process reg update interrupt
  * @vfe: VFE Device
@@ -394,114 +250,48 @@ static void vfe_isr_reg_update(struct vfe_device *vfe, enum vfe_line_id line_id)
        spin_unlock_irqrestore(&vfe->output_lock, flags);
 }
 
-/*
- * vfe_isr_wm_done - Process write master done interrupt
- * @vfe: VFE Device
- * @wm: Write master id
- */
-static void vfe_isr_wm_done(struct vfe_device *vfe, u8 wm)
-{
-       struct vfe_line *line = &vfe->line[vfe->wm_output_map[wm]];
-       struct camss_buffer *ready_buf;
-       struct vfe_output *output;
-       unsigned long flags;
-       u32 index;
-       u64 ts = ktime_get_ns();
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       if (vfe->wm_output_map[wm] == VFE_LINE_NONE) {
-               dev_err_ratelimited(vfe->camss->dev,
-                                   "Received wm done for unmapped index\n");
-               goto out_unlock;
-       }
-       output = &vfe->line[vfe->wm_output_map[wm]].output;
-
-       ready_buf = output->buf[0];
-       if (!ready_buf) {
-               dev_err_ratelimited(vfe->camss->dev,
-                                   "Missing ready buf %d!\n", output->state);
-               goto out_unlock;
-       }
-
-       ready_buf->vb.vb2_buf.timestamp = ts;
-       ready_buf->vb.sequence = output->sequence++;
-
-       index = 0;
-       output->buf[0] = output->buf[1];
-       if (output->buf[0])
-               index = 1;
-
-       output->buf[index] = vfe_buf_get_pending(output);
-
-       if (output->buf[index])
-               vfe_wm_update(vfe, output->wm_idx[0], output->buf[index]->addr[0], line);
-       else
-               output->gen2.active_num--;
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       vb2_buffer_done(&ready_buf->vb.vb2_buf, VB2_BUF_STATE_DONE);
-
-       return;
+static const struct camss_video_ops vfe_video_ops_480 = {
+       .queue_buffer = vfe_queue_buffer_v2,
+       .flush_buffers = vfe_flush_buffers,
+};
 
-out_unlock:
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
+static void vfe_subdev_init(struct device *dev, struct vfe_device *vfe)
+{
+       vfe->video_ops = vfe_video_ops_480;
 }
 
-/*
- * vfe_queue_buffer - Add empty buffer
- * @vid: Video device structure
- * @buf: Buffer to be enqueued
- *
- * Add an empty buffer - depending on the current number of buffers it will be
- * put in pending buffer queue or directly given to the hardware to be filled.
- *
- * Return 0 on success or a negative error code otherwise
- */
-static int vfe_queue_buffer(struct camss_video *vid,
-                           struct camss_buffer *buf)
+static void vfe_isr_read(struct vfe_device *vfe, u32 *value0, u32 *value1)
 {
-       struct vfe_line *line = container_of(vid, struct vfe_line, video_out);
-       struct vfe_device *vfe = to_vfe(line);
-       struct vfe_output *output;
-       unsigned long flags;
-
-       output = &line->output;
-
-       spin_lock_irqsave(&vfe->output_lock, flags);
-
-       if (output->state == VFE_OUTPUT_ON && output->gen2.active_num < 2) {
-               output->buf[output->gen2.active_num++] = buf;
-               vfe_wm_update(vfe, output->wm_idx[0], buf->addr[0], line);
-       } else {
-               vfe_buf_add_pending(output, buf);
-       }
-
-       spin_unlock_irqrestore(&vfe->output_lock, flags);
-
-       return 0;
+       /* nop */
 }
 
-static const struct camss_video_ops vfe_video_ops_480 = {
-       .queue_buffer = vfe_queue_buffer,
-       .flush_buffers = vfe_flush_buffers,
-};
+static void vfe_violation_read(struct vfe_device *vfe)
+{
+       /* nop */
+}
 
-static void vfe_subdev_init(struct device *dev, struct vfe_device *vfe)
+static void vfe_buf_done_480(struct vfe_device *vfe, int port_id)
 {
-       vfe->video_ops = vfe_video_ops_480;
+       /* nop */
 }
 
 const struct vfe_hw_ops vfe_ops_480 = {
+       .enable_irq = vfe_enable_irq,
        .global_reset = vfe_global_reset,
        .hw_version = vfe_hw_version,
        .isr = vfe_isr,
+       .isr_read = vfe_isr_read,
+       .reg_update = vfe_reg_update,
+       .reg_update_clear = vfe_reg_update_clear,
        .pm_domain_off = vfe_pm_domain_off,
        .pm_domain_on = vfe_pm_domain_on,
        .subdev_init = vfe_subdev_init,
        .vfe_disable = vfe_disable,
-       .vfe_enable = vfe_enable,
+       .vfe_enable = vfe_enable_v2,
        .vfe_halt = vfe_halt,
+       .violation_read = vfe_violation_read,
+       .vfe_wm_start = vfe_wm_start,
        .vfe_wm_stop = vfe_wm_stop,
+       .vfe_buf_done = vfe_buf_done_480,
+       .vfe_wm_update = vfe_wm_update,
 };
index 95f6a1ac7eaf53d868926cb89f6e9b6997d758e2..818dba4b14dcc192c02224965583d257d4a98206 100644 (file)
 
 #define SCALER_RATIO_MAX 16
 
+#define VFE_HW_VERSION         0x0
+#define                HW_VERSION_STEPPING     0
+#define                HW_VERSION_REVISION     16
+#define                HW_VERSION_GENERATION   28
+
 static const struct camss_format_info formats_rdi_8x16[] = {
        { MEDIA_BUS_FMT_UYVY8_1X16, 8, V4L2_PIX_FMT_UYVY, 1,
          PER_PLANE_DATA(0, 1, 1, 1, 1, 16) },
@@ -404,6 +409,269 @@ static u32 vfe_src_pad_code(struct vfe_line *line, u32 sink_code,
        return 0;
 }
 
+/*
+ * vfe_hw_version - Process write master done interrupt
+ * @vfe: VFE Device
+ *
+ * Return vfe hw version
+ */
+u32 vfe_hw_version(struct vfe_device *vfe)
+{
+       u32 hw_version = readl_relaxed(vfe->base + VFE_HW_VERSION);
+
+       u32 gen = (hw_version >> HW_VERSION_GENERATION) & 0xF;
+       u32 rev = (hw_version >> HW_VERSION_REVISION) & 0xFFF;
+       u32 step = (hw_version >> HW_VERSION_STEPPING) & 0xFFFF;
+
+       dev_info(vfe->camss->dev, "VFE:%d HW Version = %u.%u.%u\n",
+                vfe->id, gen, rev, step);
+
+       return hw_version;
+}
+
+/*
+ * vfe_buf_done - Process write master done interrupt
+ * @vfe: VFE Device
+ * @wm: Write master id
+ */
+void vfe_buf_done(struct vfe_device *vfe, int wm)
+{
+       struct vfe_line *line = &vfe->line[vfe->wm_output_map[wm]];
+       const struct vfe_hw_ops *ops = vfe->res->hw_ops;
+       struct camss_buffer *ready_buf;
+       struct vfe_output *output;
+       unsigned long flags;
+       u32 index;
+       u64 ts = ktime_get_ns();
+
+       spin_lock_irqsave(&vfe->output_lock, flags);
+
+       if (vfe->wm_output_map[wm] == VFE_LINE_NONE) {
+               dev_err_ratelimited(vfe->camss->dev,
+                                   "Received wm done for unmapped index\n");
+               goto out_unlock;
+       }
+       output = &vfe->line[vfe->wm_output_map[wm]].output;
+
+       ready_buf = output->buf[0];
+       if (!ready_buf) {
+               dev_err_ratelimited(vfe->camss->dev,
+                                   "Missing ready buf %d!\n", output->state);
+               goto out_unlock;
+       }
+
+       ready_buf->vb.vb2_buf.timestamp = ts;
+       ready_buf->vb.sequence = output->sequence++;
+
+       index = 0;
+       output->buf[0] = output->buf[1];
+       if (output->buf[0])
+               index = 1;
+
+       output->buf[index] = vfe_buf_get_pending(output);
+
+       if (output->buf[index]) {
+               ops->vfe_wm_update(vfe, output->wm_idx[0],
+                                  output->buf[index]->addr[0],
+                                  line);
+               ops->reg_update(vfe, line->id);
+       } else {
+               output->gen2.active_num--;
+       }
+
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+
+       vb2_buffer_done(&ready_buf->vb.vb2_buf, VB2_BUF_STATE_DONE);
+
+       return;
+
+out_unlock:
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+}
+
+int vfe_enable_output_v2(struct vfe_line *line)
+{
+       struct vfe_device *vfe = to_vfe(line);
+       struct vfe_output *output = &line->output;
+       const struct vfe_hw_ops *ops = vfe->res->hw_ops;
+       struct media_entity *sensor;
+       unsigned long flags;
+       unsigned int frame_skip = 0;
+       unsigned int i;
+
+       sensor = camss_find_sensor(&line->subdev.entity);
+       if (sensor) {
+               struct v4l2_subdev *subdev = media_entity_to_v4l2_subdev(sensor);
+
+               v4l2_subdev_call(subdev, sensor, g_skip_frames, &frame_skip);
+               /* Max frame skip is 29 frames */
+               if (frame_skip > VFE_FRAME_DROP_VAL - 1)
+                       frame_skip = VFE_FRAME_DROP_VAL - 1;
+       }
+
+       spin_lock_irqsave(&vfe->output_lock, flags);
+
+       ops->reg_update_clear(vfe, line->id);
+
+       if (output->state > VFE_OUTPUT_RESERVED) {
+               dev_err(vfe->camss->dev,
+                       "Output is not in reserved state %d\n",
+                       output->state);
+               spin_unlock_irqrestore(&vfe->output_lock, flags);
+               return -EINVAL;
+       }
+
+       WARN_ON(output->gen2.active_num);
+
+       output->state = VFE_OUTPUT_ON;
+
+       output->sequence = 0;
+       output->wait_reg_update = 0;
+       reinit_completion(&output->reg_update);
+
+       ops->vfe_wm_start(vfe, output->wm_idx[0], line);
+
+       for (i = 0; i < 2; i++) {
+               output->buf[i] = vfe_buf_get_pending(output);
+               if (!output->buf[i])
+                       break;
+               output->gen2.active_num++;
+               ops->vfe_wm_update(vfe, output->wm_idx[0],
+                                  output->buf[i]->addr[0], line);
+               ops->reg_update(vfe, line->id);
+       }
+
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+
+       return 0;
+}
+
+/*
+ * vfe_queue_buffer_v2 - Add empty buffer
+ * @vid: Video device structure
+ * @buf: Buffer to be enqueued
+ *
+ * Add an empty buffer - depending on the current number of buffers it will be
+ * put in pending buffer queue or directly given to the hardware to be filled.
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_queue_buffer_v2(struct camss_video *vid,
+                       struct camss_buffer *buf)
+{
+       struct vfe_line *line = container_of(vid, struct vfe_line, video_out);
+       struct vfe_device *vfe = to_vfe(line);
+       const struct vfe_hw_ops *ops = vfe->res->hw_ops;
+       struct vfe_output *output;
+       unsigned long flags;
+
+       output = &line->output;
+
+       spin_lock_irqsave(&vfe->output_lock, flags);
+
+       if (output->state == VFE_OUTPUT_ON &&
+           output->gen2.active_num < 2) {
+               output->buf[output->gen2.active_num++] = buf;
+               ops->vfe_wm_update(vfe, output->wm_idx[0],
+                                  buf->addr[0], line);
+               ops->reg_update(vfe, line->id);
+       } else {
+               vfe_buf_add_pending(output, buf);
+       }
+
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+
+       return 0;
+}
+
+/*
+ * vfe_enable_v2 - Enable streaming on VFE line
+ * @line: VFE line
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_enable_v2(struct vfe_line *line)
+{
+       struct vfe_device *vfe = to_vfe(line);
+       const struct vfe_hw_ops *ops = vfe->res->hw_ops;
+       int ret;
+
+       mutex_lock(&vfe->stream_lock);
+
+       if (vfe->res->hw_ops->enable_irq)
+               ops->enable_irq(vfe);
+
+       vfe->stream_count++;
+
+       mutex_unlock(&vfe->stream_lock);
+
+       ret = vfe_get_output_v2(line);
+       if (ret < 0)
+               goto error_get_output;
+
+       ret = vfe_enable_output_v2(line);
+       if (ret < 0)
+               goto error_enable_output;
+
+       vfe->was_streaming = 1;
+
+       return 0;
+
+error_enable_output:
+       vfe_put_output(line);
+
+error_get_output:
+       mutex_lock(&vfe->stream_lock);
+
+       vfe->stream_count--;
+
+       mutex_unlock(&vfe->stream_lock);
+
+       return ret;
+}
+
+/*
+ * vfe_get_output_v2 - Get vfe output port for corresponding VFE line
+ * @line: VFE line
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_get_output_v2(struct vfe_line *line)
+{
+       struct vfe_device *vfe = to_vfe(line);
+       struct vfe_output *output;
+       unsigned long flags;
+
+       spin_lock_irqsave(&vfe->output_lock, flags);
+
+       output = &line->output;
+       if (output->state > VFE_OUTPUT_RESERVED) {
+               dev_err(vfe->camss->dev, "Output is running\n");
+               goto error;
+       }
+
+       output->wm_num = 1;
+
+       /* Correspondence between VFE line number and WM number.
+        * line 0 -> RDI 0, line 1 -> RDI1, line 2 -> RDI2, line 3 -> PIX/RDI3
+        * Note this 1:1 mapping will not work for PIX streams.
+        */
+       output->wm_idx[0] = line->id;
+       vfe->wm_output_map[line->id] = line->id;
+
+       output->drop_update_idx = 0;
+
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+
+       return 0;
+
+error:
+       spin_unlock_irqrestore(&vfe->output_lock, flags);
+       output->state = VFE_OUTPUT_OFF;
+
+       return -EINVAL;
+}
+
 int vfe_reset(struct vfe_device *vfe)
 {
        unsigned long time;
index 10e2cc3c0b8398e137cb1968fce8dfaa921f4c96..fcbf4f609129898fe31220c96a56b5796dda7240 100644 (file)
@@ -99,7 +99,7 @@ struct vfe_line {
 struct vfe_device;
 
 struct vfe_hw_ops {
-       void (*enable_irq_common)(struct vfe_device *vfe);
+       void (*enable_irq)(struct vfe_device *vfe);
        void (*global_reset)(struct vfe_device *vfe);
        u32 (*hw_version)(struct vfe_device *vfe);
        irqreturn_t (*isr)(int irq, void *dev);
@@ -114,7 +114,12 @@ struct vfe_hw_ops {
        int (*vfe_enable)(struct vfe_line *line);
        int (*vfe_halt)(struct vfe_device *vfe);
        void (*violation_read)(struct vfe_device *vfe);
+       void (*vfe_wm_start)(struct vfe_device *vfe, u8 wm,
+                            struct vfe_line *line);
        void (*vfe_wm_stop)(struct vfe_device *vfe, u8 wm);
+       void (*vfe_buf_done)(struct vfe_device *vfe, int port_id);
+       void (*vfe_wm_update)(struct vfe_device *vfe, u8 wm, u32 addr,
+                             struct vfe_line *line);
 };
 
 struct vfe_isr_ops {
@@ -252,4 +257,55 @@ void vfe_put(struct vfe_device *vfe);
  */
 bool vfe_is_lite(struct vfe_device *vfe);
 
+/*
+ * vfe_hw_version - Process write master done interrupt
+ * @vfe: VFE Device
+ *
+ * Return vfe hw version
+ */
+u32 vfe_hw_version(struct vfe_device *vfe);
+/*
+ * vfe_enable - Enable streaming on VFE line
+ * @line: VFE line
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_enable_v2(struct vfe_line *line);
+
+/*
+ * vfe_buf_done - Process write master done interrupt
+ * @vfe: VFE Device
+ * @wm: Write master id
+ */
+void vfe_buf_done(struct vfe_device *vfe, int wm);
+
+/*
+ * vfe_get_output_v2 - Get vfe output line
+ * line: VFE line
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_get_output_v2(struct vfe_line *line);
+
+/*
+ * vfe_enable_output_v2 - Enable vfe output line
+ * line: VFE line
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_enable_output_v2(struct vfe_line *line);
+
+/*
+ * vfe_queue_buffer_v2 - Add empty buffer
+ * @vid: Video device structure
+ * @buf: Buffer to be enqueued
+ *
+ * Add an empty buffer - depending on the current number of buffers it will be
+ * put in pending buffer queue or directly given to the hardware to be filled.
+ *
+ * Return 0 on success or a negative error code otherwise
+ */
+int vfe_queue_buffer_v2(struct camss_video *vid,
+                       struct camss_buffer *buf);
+
 #endif /* QC_MSM_CAMSS_VFE_H */