[PATCH v6 0/3] media: ti: cal: Add streams support

[PATCH v6 0/3] media: ti: cal: Add streams support

[Tomi Valkeinen]

This adds streams support to TI CAL driver (and two minor improvements).

The previous version was sent in 2023, but there has been no changes
except from rebasing to upstream.

 Tomi

---
Changes in v6:
- Rebase on top of v4.16-rc7
- Add two small patches (not related to streams as such)
- Dropper the metadata patch for now, to make the series apply to plain
  upstream
- Link to v5: https://lore.kernel.org/r/20230918-cal-streams-v5-0-4851f073f58a@ideasonboard.com

Changes in v5:
- Some improvements in the patch description of the first patch
- Add "media: ti: cal: Add metadata streams support"
- Link to v4: https://lore.kernel.org/r/20230808-cal-streams-v4-1-1f37610e0946@ideasonboard.com

Changes in v4:
- A few minor formatting changes
- Small changes regarding how the code handles metadata formats.
  No metadata formats are supported yet, but we do have some code to
  ensure that metadata formats aren't allowed on video nodes in video
  capture mode. A future patch will enable metadata capture, allowing
  the runtime change of video nodes between video and meta capture.
- Link to v3: https://lore.kernel.org/all/20230302100755.191164-6-tomi.valkeinen@ideasonboard.com/

---
Tomi Valkeinen (3):
      media: ti: cal: Use printk's fourcc formatting
      media: ti: cal: Fix wrong goto on error path
      media: ti: cal: Add streams support

 drivers/media/platform/ti/cal/cal-camerarx.c | 271 +++++++++++++++++++++------
 drivers/media/platform/ti/cal/cal-video.c    | 157 ++++++++++------
 drivers/media/platform/ti/cal/cal.c          |  45 +++--
 drivers/media/platform/ti/cal/cal.h          |   3 +-
 4 files changed, 348 insertions(+), 128 deletions(-)
---
base-commit: 4701f33a10702d5fc577c32434eb62adde0a1ae1
change-id: 20230808-cal-streams-b913802c69f4

Best regards,
-- 
Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>

[PATCH v6 1/3] media: ti: cal: Use printk's fourcc formatting

[Tomi Valkeinen]

Use printk's fourcc formatting instead of a custom one.

Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>
---
 drivers/media/platform/ti/cal/cal-video.c | 26 ++++++--------------------
 1 file changed, 6 insertions(+), 20 deletions(-)

diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
index e29743ae61e2..4eb77f46f030 100644
--- a/drivers/media/platform/ti/cal/cal-video.c
+++ b/drivers/media/platform/ti/cal/cal-video.c
@@ -25,20 +25,6 @@
 
 #include "cal.h"
 
-/*  Print Four-character-code (FOURCC) */
-static char *fourcc_to_str(u32 fmt)
-{
-	static char code[5];
-
-	code[0] = (unsigned char)(fmt & 0xff);
-	code[1] = (unsigned char)((fmt >> 8) & 0xff);
-	code[2] = (unsigned char)((fmt >> 16) & 0xff);
-	code[3] = (unsigned char)((fmt >> 24) & 0xff);
-	code[4] = '\0';
-
-	return code;
-}
-
 /* ------------------------------------------------------------------
  *	V4L2 Common IOCTLs
  * ------------------------------------------------------------------
@@ -180,8 +166,8 @@ static void cal_calc_format_size(struct cal_ctx *ctx,
 	f->fmt.pix.sizeimage = f->fmt.pix.height *
 			       f->fmt.pix.bytesperline;
 
-	ctx_dbg(3, ctx, "%s: fourcc: %s size: %dx%d bpl:%d img_size:%d\n",
-		__func__, fourcc_to_str(f->fmt.pix.pixelformat),
+	ctx_dbg(3, ctx, "%s: fourcc: %p4cc size: %dx%d bpl:%d img_size:%d\n",
+		__func__, &f->fmt.pix.pixelformat,
 		f->fmt.pix.width, f->fmt.pix.height,
 		f->fmt.pix.bytesperline, f->fmt.pix.sizeimage);
 }
@@ -509,8 +495,8 @@ static void cal_mc_try_fmt(struct cal_ctx *ctx, struct v4l2_format *f,
 	if (info)
 		*info = fmtinfo;
 
-	ctx_dbg(3, ctx, "%s: %s %ux%u (bytesperline %u sizeimage %u)\n",
-		__func__, fourcc_to_str(format->pixelformat),
+	ctx_dbg(3, ctx, "%s: %p4cc %ux%u (bytesperline %u sizeimage %u)\n",
+		__func__, &format->pixelformat,
 		format->width, format->height,
 		format->bytesperline, format->sizeimage);
 }
@@ -866,8 +852,8 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
 			if (mbus_code.code == fmtinfo->code) {
 				ctx->active_fmt[i] = fmtinfo;
 				ctx_dbg(2, ctx,
-					"matched fourcc: %s: code: %04x idx: %u\n",
-					fourcc_to_str(fmtinfo->fourcc),
+					"matched fourcc: %p4cc: code: %04x idx: %u\n",
+					&fmtinfo->fourcc,
 					fmtinfo->code, i);
 				ctx->num_active_fmt = ++i;
 			}

-- 
2.43.0

Re: [PATCH v6 1/3] media: ti: cal: Use printk's fourcc formatting

[Kieran Bingham]

Quoting Tomi Valkeinen (2025-03-24 09:29:17)
> Use printk's fourcc formatting instead of a custom one.
> 
> Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>


Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>

> ---
>  drivers/media/platform/ti/cal/cal-video.c | 26 ++++++--------------------
>  1 file changed, 6 insertions(+), 20 deletions(-)
> 
> diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
> index e29743ae61e2..4eb77f46f030 100644
> --- a/drivers/media/platform/ti/cal/cal-video.c
> +++ b/drivers/media/platform/ti/cal/cal-video.c
> @@ -25,20 +25,6 @@
>  
>  #include "cal.h"
>  
> -/*  Print Four-character-code (FOURCC) */
> -static char *fourcc_to_str(u32 fmt)
> -{
> -       static char code[5];
> -
> -       code[0] = (unsigned char)(fmt & 0xff);
> -       code[1] = (unsigned char)((fmt >> 8) & 0xff);
> -       code[2] = (unsigned char)((fmt >> 16) & 0xff);
> -       code[3] = (unsigned char)((fmt >> 24) & 0xff);
> -       code[4] = '\0';
> -
> -       return code;
> -}
> -
>  /* ------------------------------------------------------------------
>   *     V4L2 Common IOCTLs
>   * ------------------------------------------------------------------
> @@ -180,8 +166,8 @@ static void cal_calc_format_size(struct cal_ctx *ctx,
>         f->fmt.pix.sizeimage = f->fmt.pix.height *
>                                f->fmt.pix.bytesperline;
>  
> -       ctx_dbg(3, ctx, "%s: fourcc: %s size: %dx%d bpl:%d img_size:%d\n",
> -               __func__, fourcc_to_str(f->fmt.pix.pixelformat),
> +       ctx_dbg(3, ctx, "%s: fourcc: %p4cc size: %dx%d bpl:%d img_size:%d\n",
> +               __func__, &f->fmt.pix.pixelformat,
>                 f->fmt.pix.width, f->fmt.pix.height,
>                 f->fmt.pix.bytesperline, f->fmt.pix.sizeimage);
>  }
> @@ -509,8 +495,8 @@ static void cal_mc_try_fmt(struct cal_ctx *ctx, struct v4l2_format *f,
>         if (info)
>                 *info = fmtinfo;
>  
> -       ctx_dbg(3, ctx, "%s: %s %ux%u (bytesperline %u sizeimage %u)\n",
> -               __func__, fourcc_to_str(format->pixelformat),
> +       ctx_dbg(3, ctx, "%s: %p4cc %ux%u (bytesperline %u sizeimage %u)\n",
> +               __func__, &format->pixelformat,
>                 format->width, format->height,
>                 format->bytesperline, format->sizeimage);
>  }
> @@ -866,8 +852,8 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>                         if (mbus_code.code == fmtinfo->code) {
>                                 ctx->active_fmt[i] = fmtinfo;
>                                 ctx_dbg(2, ctx,
> -                                       "matched fourcc: %s: code: %04x idx: %u\n",
> -                                       fourcc_to_str(fmtinfo->fourcc),
> +                                       "matched fourcc: %p4cc: code: %04x idx: %u\n",
> +                                       &fmtinfo->fourcc,
>                                         fmtinfo->code, i);
>                                 ctx->num_active_fmt = ++i;
>                         }
> 
> -- 
> 2.43.0
>

[PATCH v6 2/3] media: ti: cal: Fix wrong goto on error path

[Tomi Valkeinen]

If pm_runtime_resume_and_get() fails, we should unprepare the context,
but currently we skip that as we goto to a later line.

Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>
---
 drivers/media/platform/ti/cal/cal-video.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
index 4eb77f46f030..29c38bf8d7a1 100644
--- a/drivers/media/platform/ti/cal/cal-video.c
+++ b/drivers/media/platform/ti/cal/cal-video.c
@@ -744,7 +744,7 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
 
 	ret = pm_runtime_resume_and_get(ctx->cal->dev);
 	if (ret < 0)
-		goto error_pipeline;
+		goto error_unprepare;
 
 	cal_ctx_set_dma_addr(ctx, addr);
 	cal_ctx_start(ctx);
@@ -761,8 +761,8 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
 error_stop:
 	cal_ctx_stop(ctx);
 	pm_runtime_put_sync(ctx->cal->dev);
+error_unprepare:
 	cal_ctx_unprepare(ctx);
-
 error_pipeline:
 	video_device_pipeline_stop(&ctx->vdev);
 error_release_buffers:

-- 
2.43.0

Re: [PATCH v6 2/3] media: ti: cal: Fix wrong goto on error path

[Kieran Bingham]

Quoting Tomi Valkeinen (2025-03-24 09:29:18)
> If pm_runtime_resume_and_get() fails, we should unprepare the context,
> but currently we skip that as we goto to a later line.
> 
> Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>

This looks reasonable and correct to me.


Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>

> ---
>  drivers/media/platform/ti/cal/cal-video.c | 4 ++--
>  1 file changed, 2 insertions(+), 2 deletions(-)
> 
> diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
> index 4eb77f46f030..29c38bf8d7a1 100644
> --- a/drivers/media/platform/ti/cal/cal-video.c
> +++ b/drivers/media/platform/ti/cal/cal-video.c
> @@ -744,7 +744,7 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>  
>         ret = pm_runtime_resume_and_get(ctx->cal->dev);
>         if (ret < 0)
> -               goto error_pipeline;
> +               goto error_unprepare;
>  
>         cal_ctx_set_dma_addr(ctx, addr);
>         cal_ctx_start(ctx);
> @@ -761,8 +761,8 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>  error_stop:
>         cal_ctx_stop(ctx);
>         pm_runtime_put_sync(ctx->cal->dev);
> +error_unprepare:
>         cal_ctx_unprepare(ctx);
> -
>  error_pipeline:
>         video_device_pipeline_stop(&ctx->vdev);
>  error_release_buffers:
> 
> -- 
> 2.43.0
>

[PATCH v6 3/3] media: ti: cal: Add streams support

[Tomi Valkeinen]

Add multiplexed streams support. CAL has 8 DMA-engines and can capture 8
separate streams at the same time. The driver filters the streams based
on CSI-2 virtual channel number and datatype. CAL may have (depending on
the SoC) two CSI-2 RX blocks, which share the 8 DMA-engines, so the
number of capturable streams does not change even if there are two CSI-2
RX blocks.

Add 8 video device nodes, each representing a single DMA-engine, and set
the number of source pads on CSI-2 RX blocks to 8. Each video node can be
connected to any of the source pads on either of the CSI-2 RX instances
using media links. CSI-2 RX block's subdevice internal routing is used
to route the incoming CSI-2 streams to one of the 8 source pads.

Only video data streams are supported at the moment.

Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>
Reviewed-by: Jacopo Mondi <jacopo.mondi@ideasonboard.com>
---
 drivers/media/platform/ti/cal/cal-camerarx.c | 271 +++++++++++++++++++++------
 drivers/media/platform/ti/cal/cal-video.c    | 127 ++++++++++---
 drivers/media/platform/ti/cal/cal.c          |  45 +++--
 drivers/media/platform/ti/cal/cal.h          |   3 +-
 4 files changed, 340 insertions(+), 106 deletions(-)

diff --git a/drivers/media/platform/ti/cal/cal-camerarx.c b/drivers/media/platform/ti/cal/cal-camerarx.c
index 42dfe08b765f..9d8aefdeb430 100644
--- a/drivers/media/platform/ti/cal/cal-camerarx.c
+++ b/drivers/media/platform/ti/cal/cal-camerarx.c
@@ -49,21 +49,38 @@ static s64 cal_camerarx_get_ext_link_freq(struct cal_camerarx *phy)
 {
 	struct v4l2_mbus_config_mipi_csi2 *mipi_csi2 = &phy->endpoint.bus.mipi_csi2;
 	u32 num_lanes = mipi_csi2->num_data_lanes;
-	const struct cal_format_info *fmtinfo;
 	struct v4l2_subdev_state *state;
-	struct v4l2_mbus_framefmt *fmt;
 	u32 bpp;
 	s64 freq;
 
+	/*
+	 * v4l2_get_link_freq() uses V4L2_CID_LINK_FREQ first, and falls back
+	 * to V4L2_CID_PIXEL_RATE if V4L2_CID_LINK_FREQ is not available.
+	 *
+	 * With multistream input there is no single pixel rate, and thus we
+	 * cannot use V4L2_CID_PIXEL_RATE, so we pass 0 as the bpp which
+	 * causes v4l2_get_link_freq() to return an error if it falls back to
+	 * V4L2_CID_PIXEL_RATE.
+	 */
+
 	state = v4l2_subdev_get_locked_active_state(&phy->subdev);
 
-	fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
+	if (state->routing.num_routes > 1) {
+		bpp = 0;
+	} else {
+		struct v4l2_subdev_route *route = &state->routing.routes[0];
+		const struct cal_format_info *fmtinfo;
+		struct v4l2_mbus_framefmt *fmt;
 
-	fmtinfo = cal_format_by_code(fmt->code);
-	if (!fmtinfo)
-		return -EINVAL;
+		fmt = v4l2_subdev_state_get_format(state,
+			route->sink_pad, route->sink_stream);
+
+		fmtinfo = cal_format_by_code(fmt->code);
+		if (!fmtinfo)
+			return -EINVAL;
 
-	bpp = fmtinfo->bpp;
+		bpp = fmtinfo->bpp;
+	}
 
 	freq = v4l2_get_link_freq(phy->source->ctrl_handler, bpp, 2 * num_lanes);
 	if (freq < 0) {
@@ -284,15 +301,32 @@ static void cal_camerarx_ppi_disable(struct cal_camerarx *phy)
 			0, CAL_CSI2_PPI_CTRL_IF_EN_MASK);
 }
 
-static int cal_camerarx_start(struct cal_camerarx *phy)
+static int cal_camerarx_start(struct cal_camerarx *phy, u32 sink_stream)
 {
+	struct media_pad *remote_pad;
 	s64 link_freq;
 	u32 sscounter;
 	u32 val;
 	int ret;
 
+	remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
+
+	/*
+	 * We need to enable the PHY hardware when enabling the first stream,
+	 * but for the following streams we just propagate the enable_streams
+	 * to the source.
+	 */
+
 	if (phy->enable_count > 0) {
+		ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
+						 BIT(sink_stream));
+		if (ret) {
+			phy_err(phy, "enable streams failed in source: %d\n", ret);
+			return ret;
+		}
+
 		phy->enable_count++;
+
 		return 0;
 	}
 
@@ -394,7 +428,8 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
 	 * Start the source to enable the CSI-2 HS clock. We can now wait for
 	 * CSI-2 PHY reset to complete.
 	 */
-	ret = v4l2_subdev_call(phy->source, video, s_stream, 1);
+	ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
+					 BIT(sink_stream));
 	if (ret) {
 		v4l2_subdev_call(phy->source, core, s_power, 0);
 		cal_camerarx_disable_irqs(phy);
@@ -425,12 +460,22 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
 	return 0;
 }
 
-static void cal_camerarx_stop(struct cal_camerarx *phy)
+static void cal_camerarx_stop(struct cal_camerarx *phy, u32 sink_stream)
 {
+	struct media_pad *remote_pad;
 	int ret;
 
-	if (--phy->enable_count > 0)
+	remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
+
+	if (--phy->enable_count > 0) {
+		ret = v4l2_subdev_disable_streams(phy->source,
+						  remote_pad->index,
+						  BIT(sink_stream));
+		if (ret)
+			phy_err(phy, "stream off failed in subdev\n");
+
 		return;
+	}
 
 	cal_camerarx_ppi_disable(phy);
 
@@ -450,7 +495,9 @@ static void cal_camerarx_stop(struct cal_camerarx *phy)
 	/* Disable the phy */
 	cal_camerarx_disable(phy);
 
-	if (v4l2_subdev_call(phy->source, video, s_stream, 0))
+	ret = v4l2_subdev_disable_streams(phy->source, remote_pad->index,
+					  BIT(sink_stream));
+	if (ret)
 		phy_err(phy, "stream off failed in subdev\n");
 
 	ret = v4l2_subdev_call(phy->source, core, s_power, 0);
@@ -599,22 +646,50 @@ static inline struct cal_camerarx *to_cal_camerarx(struct v4l2_subdev *sd)
 	return container_of(sd, struct cal_camerarx, subdev);
 }
 
-static int cal_camerarx_sd_s_stream(struct v4l2_subdev *sd, int enable)
+struct cal_camerarx *
+cal_camerarx_get_phy_from_entity(struct media_entity *entity)
+{
+	struct v4l2_subdev *sd;
+
+	sd = media_entity_to_v4l2_subdev(entity);
+	if (!sd)
+		return NULL;
+
+	return to_cal_camerarx(sd);
+}
+
+static int cal_camerarx_sd_enable_streams(struct v4l2_subdev *sd,
+					  struct v4l2_subdev_state *state,
+					  u32 pad, u64 streams_mask)
 {
 	struct cal_camerarx *phy = to_cal_camerarx(sd);
-	struct v4l2_subdev_state *state;
-	int ret = 0;
+	u32 sink_stream;
+	int ret;
 
-	state = v4l2_subdev_lock_and_get_active_state(sd);
+	ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
+						    NULL, &sink_stream);
+	if (ret)
+		return ret;
 
-	if (enable)
-		ret = cal_camerarx_start(phy);
-	else
-		cal_camerarx_stop(phy);
+	return cal_camerarx_start(phy, sink_stream);
+}
 
-	v4l2_subdev_unlock_state(state);
+static int cal_camerarx_sd_disable_streams(struct v4l2_subdev *sd,
+					   struct v4l2_subdev_state *state,
+					   u32 pad, u64 streams_mask)
+{
+	struct cal_camerarx *phy = to_cal_camerarx(sd);
+	u32 sink_stream;
+	int ret;
 
-	return ret;
+	ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
+						    NULL, &sink_stream);
+	if (ret)
+		return ret;
+
+	cal_camerarx_stop(phy, sink_stream);
+
+	return 0;
 }
 
 static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
@@ -628,8 +703,12 @@ static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
 		if (code->index > 0)
 			return -EINVAL;
 
-		fmt = v4l2_subdev_state_get_format(state,
-						   CAL_CAMERARX_PAD_SINK);
+		fmt = v4l2_subdev_state_get_opposite_stream_format(state,
+								   code->pad,
+								   code->stream);
+		if (!fmt)
+			return -EINVAL;
+
 		code->code = fmt->code;
 	} else {
 		if (code->index >= cal_num_formats)
@@ -654,8 +733,12 @@ static int cal_camerarx_sd_enum_frame_size(struct v4l2_subdev *sd,
 	if (cal_rx_pad_is_source(fse->pad)) {
 		struct v4l2_mbus_framefmt *fmt;
 
-		fmt = v4l2_subdev_state_get_format(state,
-						   CAL_CAMERARX_PAD_SINK);
+		fmt = v4l2_subdev_state_get_opposite_stream_format(state,
+								   fse->pad,
+								   fse->stream);
+		if (!fmt)
+			return -EINVAL;
+
 		if (fse->code != fmt->code)
 			return -EINVAL;
 
@@ -711,36 +794,78 @@ static int cal_camerarx_sd_set_fmt(struct v4l2_subdev *sd,
 
 	/* Store the format and propagate it to the source pad. */
 
-	fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
+	fmt = v4l2_subdev_state_get_format(state, format->pad,
+						  format->stream);
+	if (!fmt)
+		return -EINVAL;
+
 	*fmt = format->format;
 
-	fmt = v4l2_subdev_state_get_format(state,
-					   CAL_CAMERARX_PAD_FIRST_SOURCE);
+	fmt = v4l2_subdev_state_get_opposite_stream_format(state, format->pad,
+							   format->stream);
+	if (!fmt)
+		return -EINVAL;
+
 	*fmt = format->format;
 
 	return 0;
 }
 
+static int cal_camerarx_set_routing(struct v4l2_subdev *sd,
+				    struct v4l2_subdev_state *state,
+				    struct v4l2_subdev_krouting *routing)
+{
+	static const struct v4l2_mbus_framefmt format = {
+		.width = 640,
+		.height = 480,
+		.code = MEDIA_BUS_FMT_UYVY8_1X16,
+		.field = V4L2_FIELD_NONE,
+		.colorspace = V4L2_COLORSPACE_SRGB,
+		.ycbcr_enc = V4L2_YCBCR_ENC_601,
+		.quantization = V4L2_QUANTIZATION_LIM_RANGE,
+		.xfer_func = V4L2_XFER_FUNC_SRGB,
+	};
+	int ret;
+
+	ret = v4l2_subdev_routing_validate(sd, routing,
+					   V4L2_SUBDEV_ROUTING_ONLY_1_TO_1 |
+					   V4L2_SUBDEV_ROUTING_NO_SOURCE_MULTIPLEXING);
+	if (ret)
+		return ret;
+
+	ret = v4l2_subdev_set_routing_with_fmt(sd, state, routing, &format);
+	if (ret)
+		return ret;
+
+	return 0;
+}
+
+static int cal_camerarx_sd_set_routing(struct v4l2_subdev *sd,
+				       struct v4l2_subdev_state *state,
+				       enum v4l2_subdev_format_whence which,
+				       struct v4l2_subdev_krouting *routing)
+{
+	return cal_camerarx_set_routing(sd, state, routing);
+}
+
 static int cal_camerarx_sd_init_state(struct v4l2_subdev *sd,
-				      struct v4l2_subdev_state *state)
-{
-	struct v4l2_subdev_format format = {
-		.which = state ? V4L2_SUBDEV_FORMAT_TRY
-		: V4L2_SUBDEV_FORMAT_ACTIVE,
-		.pad = CAL_CAMERARX_PAD_SINK,
-		.format = {
-			.width = 640,
-			.height = 480,
-			.code = MEDIA_BUS_FMT_UYVY8_1X16,
-			.field = V4L2_FIELD_NONE,
-			.colorspace = V4L2_COLORSPACE_SRGB,
-			.ycbcr_enc = V4L2_YCBCR_ENC_601,
-			.quantization = V4L2_QUANTIZATION_LIM_RANGE,
-			.xfer_func = V4L2_XFER_FUNC_SRGB,
-		},
+				    struct v4l2_subdev_state *state)
+{
+	struct v4l2_subdev_route routes[] = { {
+		.sink_pad = 0,
+		.sink_stream = 0,
+		.source_pad = 1,
+		.source_stream = 0,
+		.flags = V4L2_SUBDEV_ROUTE_FL_ACTIVE,
+	} };
+
+	struct v4l2_subdev_krouting routing = {
+		.num_routes = 1,
+		.routes = routes,
 	};
 
-	return cal_camerarx_sd_set_fmt(sd, state, &format);
+	/* Initialize routing to single route to the fist source pad */
+	return cal_camerarx_set_routing(sd, state, &routing);
 }
 
 static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
@@ -749,48 +874,71 @@ static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
 	struct cal_camerarx *phy = to_cal_camerarx(sd);
 	struct v4l2_mbus_frame_desc remote_desc;
 	const struct media_pad *remote_pad;
+	struct v4l2_subdev_state *state;
+	u32 sink_stream;
+	unsigned int i;
 	int ret;
 
+	state = v4l2_subdev_lock_and_get_active_state(sd);
+
+	ret = v4l2_subdev_routing_find_opposite_end(&state->routing,
+						    pad, 0,
+						    NULL, &sink_stream);
+	if (ret)
+		goto out_unlock;
+
 	remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
-	if (!remote_pad)
-		return -EPIPE;
+	if (!remote_pad) {
+		ret = -EPIPE;
+		goto out_unlock;
+	}
 
 	ret = v4l2_subdev_call(phy->source, pad, get_frame_desc,
 			       remote_pad->index, &remote_desc);
 	if (ret)
-		return ret;
+		goto out_unlock;
 
 	if (remote_desc.type != V4L2_MBUS_FRAME_DESC_TYPE_CSI2) {
 		cal_err(phy->cal,
 			"Frame descriptor does not describe CSI-2 link");
-		return -EINVAL;
+		ret = -EINVAL;
+		goto out_unlock;
 	}
 
-	if (remote_desc.num_entries > 1)
-		cal_err(phy->cal,
-			"Multiple streams not supported in remote frame descriptor, using the first one\n");
+	for (i = 0; i < remote_desc.num_entries; i++) {
+		if (remote_desc.entry[i].stream == sink_stream)
+			break;
+	}
+
+	if (i == remote_desc.num_entries) {
+		cal_err(phy->cal, "Stream %u not found in remote frame desc\n",
+			sink_stream);
+		ret = -EINVAL;
+		goto out_unlock;
+	}
 
 	fd->type = V4L2_MBUS_FRAME_DESC_TYPE_CSI2;
 	fd->num_entries = 1;
-	fd->entry[0] = remote_desc.entry[0];
+	fd->entry[0] = remote_desc.entry[i];
 
-	return 0;
-}
+out_unlock:
+	v4l2_subdev_unlock_state(state);
 
-static const struct v4l2_subdev_video_ops cal_camerarx_video_ops = {
-	.s_stream = cal_camerarx_sd_s_stream,
-};
+	return ret;
+}
 
 static const struct v4l2_subdev_pad_ops cal_camerarx_pad_ops = {
+	.enable_streams = cal_camerarx_sd_enable_streams,
+	.disable_streams = cal_camerarx_sd_disable_streams,
 	.enum_mbus_code = cal_camerarx_sd_enum_mbus_code,
 	.enum_frame_size = cal_camerarx_sd_enum_frame_size,
 	.get_fmt = v4l2_subdev_get_fmt,
 	.set_fmt = cal_camerarx_sd_set_fmt,
+	.set_routing = cal_camerarx_sd_set_routing,
 	.get_frame_desc = cal_camerarx_get_frame_desc,
 };
 
 static const struct v4l2_subdev_ops cal_camerarx_subdev_ops = {
-	.video = &cal_camerarx_video_ops,
 	.pad = &cal_camerarx_pad_ops,
 };
 
@@ -800,6 +948,7 @@ static const struct v4l2_subdev_internal_ops cal_camerarx_internal_ops = {
 
 static const struct media_entity_operations cal_camerarx_media_ops = {
 	.link_validate = v4l2_subdev_link_validate,
+	.has_pad_interdep = v4l2_subdev_has_pad_interdep,
 };
 
 /* ------------------------------------------------------------------
@@ -851,7 +1000,7 @@ struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,
 	v4l2_subdev_init(sd, &cal_camerarx_subdev_ops);
 	sd->internal_ops = &cal_camerarx_internal_ops;
 	sd->entity.function = MEDIA_ENT_F_VID_IF_BRIDGE;
-	sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE;
+	sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE | V4L2_SUBDEV_FL_STREAMS;
 	snprintf(sd->name, sizeof(sd->name), "CAMERARX%u", instance);
 	sd->dev = cal->dev;
 
diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
index 29c38bf8d7a1..97a14ceaf237 100644
--- a/drivers/media/platform/ti/cal/cal-video.c
+++ b/drivers/media/platform/ti/cal/cal-video.c
@@ -108,9 +108,10 @@ static int __subdev_get_format(struct cal_ctx *ctx,
 		.pad = 0,
 	};
 	struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
+	struct v4l2_subdev *sd = ctx->phy->source;
 	int ret;
 
-	ret = v4l2_subdev_call(ctx->phy->source, pad, get_fmt, NULL, &sd_fmt);
+	ret = v4l2_subdev_call_state_active(sd, pad, get_fmt, &sd_fmt);
 	if (ret)
 		return ret;
 
@@ -130,11 +131,12 @@ static int __subdev_set_format(struct cal_ctx *ctx,
 		.pad = 0,
 	};
 	struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
+	struct v4l2_subdev *sd = ctx->phy->source;
 	int ret;
 
 	*mbus_fmt = *fmt;
 
-	ret = v4l2_subdev_call(ctx->phy->source, pad, set_fmt, NULL, &sd_fmt);
+	ret = v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);
 	if (ret)
 		return ret;
 
@@ -176,6 +178,7 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
 				      struct v4l2_format *f)
 {
 	struct cal_ctx *ctx = video_drvdata(file);
+	struct v4l2_subdev *sd = ctx->phy->source;
 	const struct cal_format_info *fmtinfo;
 	struct v4l2_subdev_frame_size_enum fse = {
 		.which = V4L2_SUBDEV_FORMAT_ACTIVE,
@@ -201,8 +204,8 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
 	for (fse.index = 0; ; fse.index++) {
 		int ret;
 
-		ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size,
-				       NULL, &fse);
+		ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size,
+						    &fse);
 		if (ret)
 			break;
 
@@ -238,6 +241,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
 				    struct v4l2_format *f)
 {
 	struct cal_ctx *ctx = video_drvdata(file);
+	struct v4l2_subdev *sd = &ctx->phy->subdev;
 	struct vb2_queue *q = &ctx->vb_vidq;
 	struct v4l2_subdev_format sd_fmt = {
 		.which = V4L2_SUBDEV_FORMAT_ACTIVE,
@@ -277,7 +281,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
 	ctx->v_fmt.fmt.pix.field = sd_fmt.format.field;
 	cal_calc_format_size(ctx, fmtinfo, &ctx->v_fmt);
 
-	v4l2_subdev_call(&ctx->phy->subdev, pad, set_fmt, NULL, &sd_fmt);
+	v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);
 
 	ctx->fmtinfo = fmtinfo;
 	*f = ctx->v_fmt;
@@ -289,6 +293,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
 				      struct v4l2_frmsizeenum *fsize)
 {
 	struct cal_ctx *ctx = video_drvdata(file);
+	struct v4l2_subdev *sd = ctx->phy->source;
 	const struct cal_format_info *fmtinfo;
 	struct v4l2_subdev_frame_size_enum fse = {
 		.index = fsize->index,
@@ -307,8 +312,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
 
 	fse.code = fmtinfo->code;
 
-	ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size, NULL,
-			       &fse);
+	ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size, &fse);
 	if (ret)
 		return ret;
 
@@ -350,6 +354,7 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
 					  struct v4l2_frmivalenum *fival)
 {
 	struct cal_ctx *ctx = video_drvdata(file);
+	struct v4l2_subdev *sd = ctx->phy->source;
 	const struct cal_format_info *fmtinfo;
 	struct v4l2_subdev_frame_interval_enum fie = {
 		.index = fival->index,
@@ -364,8 +369,8 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
 		return -EINVAL;
 
 	fie.code = fmtinfo->code;
-	ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_interval,
-			       NULL, &fie);
+
+	ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_interval, &fie);
 	if (ret)
 		return ret;
 	fival->type = V4L2_FRMIVAL_TYPE_DISCRETE;
@@ -432,6 +437,9 @@ static int cal_mc_enum_fmt_vid_cap(struct file *file, void  *priv,
 	idx = 0;
 
 	for (i = 0; i < cal_num_formats; ++i) {
+		if (cal_formats[i].meta)
+			continue;
+
 		if (f->mbus_code && cal_formats[i].code != f->mbus_code)
 			continue;
 
@@ -459,7 +467,7 @@ static void cal_mc_try_fmt(struct cal_ctx *ctx, struct v4l2_format *f,
 	 * supported.
 	 */
 	fmtinfo = cal_format_by_fourcc(f->fmt.pix.pixelformat);
-	if (!fmtinfo)
+	if (!fmtinfo || fmtinfo->meta)
 		fmtinfo = &cal_formats[0];
 
 	/*
@@ -675,16 +683,16 @@ static int cal_video_check_format(struct cal_ctx *ctx)
 {
 	const struct v4l2_mbus_framefmt *format;
 	struct v4l2_subdev_state *state;
-	struct media_pad *remote_pad;
+	struct media_pad *phy_source_pad;
 	int ret = 0;
 
-	remote_pad = media_pad_remote_pad_first(&ctx->pad);
-	if (!remote_pad)
+	phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
+	if (!phy_source_pad)
 		return -ENODEV;
 
 	state = v4l2_subdev_lock_and_get_active_state(&ctx->phy->subdev);
 
-	format = v4l2_subdev_state_get_format(state, remote_pad->index);
+	format = v4l2_subdev_state_get_format(state, phy_source_pad->index, 0);
 	if (!format) {
 		ret = -EINVAL;
 		goto out;
@@ -707,16 +715,28 @@ static int cal_video_check_format(struct cal_ctx *ctx)
 static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
 {
 	struct cal_ctx *ctx = vb2_get_drv_priv(vq);
+	struct media_pad *phy_source_pad;
 	struct cal_buffer *buf;
 	dma_addr_t addr;
 	int ret;
 
+	phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
+	if (!phy_source_pad) {
+		ctx_err(ctx, "Context not connected\n");
+		ret = -ENODEV;
+		goto error_release_buffers;
+	}
+
 	ret = video_device_pipeline_alloc_start(&ctx->vdev);
 	if (ret < 0) {
 		ctx_err(ctx, "Failed to start media pipeline: %d\n", ret);
 		goto error_release_buffers;
 	}
 
+	/* Find the PHY connected to this video device */
+	if (cal_mc_api)
+		ctx->phy = cal_camerarx_get_phy_from_entity(phy_source_pad->entity);
+
 	/*
 	 * Verify that the currently configured format matches the output of
 	 * the connected CAMERARX.
@@ -749,7 +769,8 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
 	cal_ctx_set_dma_addr(ctx, addr);
 	cal_ctx_start(ctx);
 
-	ret = v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 1);
+	ret = v4l2_subdev_enable_streams(&ctx->phy->subdev,
+					 phy_source_pad->index, BIT(0));
 	if (ret)
 		goto error_stop;
 
@@ -774,10 +795,14 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
 static void cal_stop_streaming(struct vb2_queue *vq)
 {
 	struct cal_ctx *ctx = vb2_get_drv_priv(vq);
+	struct media_pad *phy_source_pad;
 
 	cal_ctx_stop(ctx);
 
-	v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 0);
+	phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
+
+	v4l2_subdev_disable_streams(&ctx->phy->subdev, phy_source_pad->index,
+				    BIT(0));
 
 	pm_runtime_put_sync(ctx->cal->dev);
 
@@ -786,6 +811,9 @@ static void cal_stop_streaming(struct vb2_queue *vq)
 	cal_release_buffers(ctx, VB2_BUF_STATE_ERROR);
 
 	video_device_pipeline_stop(&ctx->vdev);
+
+	if (cal_mc_api)
+		ctx->phy = NULL;
 }
 
 static const struct vb2_ops cal_video_qops = {
@@ -812,6 +840,7 @@ static const struct v4l2_file_operations cal_fops = {
 
 static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
 {
+	struct v4l2_subdev *sd = ctx->phy->source;
 	struct v4l2_mbus_framefmt mbus_fmt;
 	const struct cal_format_info *fmtinfo;
 	unsigned int i, j, k;
@@ -831,20 +860,20 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
 			.which = V4L2_SUBDEV_FORMAT_ACTIVE,
 		};
 
-		ret = v4l2_subdev_call(ctx->phy->source, pad, enum_mbus_code,
-				       NULL, &mbus_code);
+		ret = v4l2_subdev_call_state_active(sd, pad, enum_mbus_code,
+						    &mbus_code);
 		if (ret == -EINVAL)
 			break;
 
 		if (ret) {
 			ctx_err(ctx, "Error enumerating mbus codes in subdev %s: %d\n",
-				ctx->phy->source->name, ret);
+				sd->name, ret);
 			return ret;
 		}
 
 		ctx_dbg(2, ctx,
 			"subdev %s: code: %04x idx: %u\n",
-			ctx->phy->source->name, mbus_code.code, j);
+			sd->name, mbus_code.code, j);
 
 		for (k = 0; k < cal_num_formats; k++) {
 			fmtinfo = &cal_formats[k];
@@ -862,7 +891,7 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
 
 	if (i == 0) {
 		ctx_err(ctx, "No suitable format reported by subdev %s\n",
-			ctx->phy->source->name);
+			sd->name);
 		return -EINVAL;
 	}
 
@@ -948,16 +977,52 @@ int cal_ctx_v4l2_register(struct cal_ctx *ctx)
 		return ret;
 	}
 
-	ret = media_create_pad_link(&ctx->phy->subdev.entity,
-				    CAL_CAMERARX_PAD_FIRST_SOURCE,
-				    &vfd->entity, 0,
-				    MEDIA_LNK_FL_IMMUTABLE |
-				    MEDIA_LNK_FL_ENABLED);
-	if (ret) {
-		ctx_err(ctx, "Failed to create media link for context %u\n",
-			ctx->dma_ctx);
-		video_unregister_device(vfd);
-		return ret;
+	if (cal_mc_api) {
+		u16 phy_idx;
+		u16 pad_idx;
+
+		/* Create links from all video nodes to all PHYs */
+
+		for (phy_idx = 0; phy_idx < ctx->cal->data->num_csi2_phy;
+		     ++phy_idx) {
+			struct media_entity *phy_entity =
+				&ctx->cal->phy[phy_idx]->subdev.entity;
+
+			for (pad_idx = 1; pad_idx < CAL_CAMERARX_NUM_PADS;
+			     ++pad_idx) {
+				/*
+				 * Enable only links from video0 to PHY0 pad 1,
+				 * and video1 to PHY1 pad 1.
+				 */
+				bool enable = (ctx->dma_ctx == 0 &&
+					       phy_idx == 0 && pad_idx == 1) ||
+					      (ctx->dma_ctx == 1 &&
+					       phy_idx == 1 && pad_idx == 1);
+
+				ret = media_create_pad_link(phy_entity, pad_idx,
+					&vfd->entity, 0,
+					enable ? MEDIA_LNK_FL_ENABLED : 0);
+				if (ret) {
+					ctx_err(ctx,
+						"Failed to create media link for context %u\n",
+						ctx->dma_ctx);
+					video_unregister_device(vfd);
+					return ret;
+				}
+			}
+		}
+	} else {
+		ret = media_create_pad_link(&ctx->phy->subdev.entity,
+					    CAL_CAMERARX_PAD_FIRST_SOURCE,
+					    &vfd->entity, 0,
+					    MEDIA_LNK_FL_IMMUTABLE | MEDIA_LNK_FL_ENABLED);
+		if (ret) {
+			ctx_err(ctx,
+				"Failed to create media link for context %u\n",
+				ctx->dma_ctx);
+			video_unregister_device(vfd);
+			return ret;
+		}
 	}
 
 	ctx_info(ctx, "V4L2 device registered as %s\n",
diff --git a/drivers/media/platform/ti/cal/cal.c b/drivers/media/platform/ti/cal/cal.c
index 4bd2092e0255..9389c444400e 100644
--- a/drivers/media/platform/ti/cal/cal.c
+++ b/drivers/media/platform/ti/cal/cal.c
@@ -481,8 +481,9 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
 		ctx->vc = 0;
 		ctx->datatype = CAL_CSI2_CTX_DT_ANY;
 	} else if (!ret) {
-		ctx_dbg(2, ctx, "Framedesc: len %u, vc %u, dt %#x\n",
-			entry.length, entry.bus.csi2.vc, entry.bus.csi2.dt);
+		ctx_dbg(2, ctx, "Framedesc: stream %u, len %u, vc %u, dt %#x\n",
+			entry.stream, entry.length, entry.bus.csi2.vc,
+			entry.bus.csi2.dt);
 
 		ctx->vc = entry.bus.csi2.vc;
 		ctx->datatype = entry.bus.csi2.dt;
@@ -490,7 +491,7 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
 		return ret;
 	}
 
-	ctx->use_pix_proc = !ctx->fmtinfo->meta;
+	ctx->use_pix_proc = ctx->vb_vidq.type == V4L2_BUF_TYPE_VIDEO_CAPTURE;
 
 	if (ctx->use_pix_proc) {
 		ret = cal_reserve_pix_proc(ctx->cal);
@@ -1014,7 +1015,6 @@ static struct cal_ctx *cal_ctx_create(struct cal_dev *cal, int inst)
 		return NULL;
 
 	ctx->cal = cal;
-	ctx->phy = cal->phy[inst];
 	ctx->dma_ctx = inst;
 	ctx->csi2_ctx = inst;
 	ctx->cport = inst;
@@ -1226,18 +1226,37 @@ static int cal_probe(struct platform_device *pdev)
 	}
 
 	/* Create contexts. */
-	for (i = 0; i < cal->data->num_csi2_phy; ++i) {
-		if (!cal->phy[i]->source_node)
-			continue;
+	if (!cal_mc_api) {
+		for (i = 0; i < cal->data->num_csi2_phy; ++i) {
+			struct cal_ctx *ctx;
+
+			if (!cal->phy[i]->source_node)
+				continue;
+
+			ctx = cal_ctx_create(cal, i);
+			if (!ctx) {
+				cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
+				ret = -ENODEV;
+				goto error_context;
+			}
+
+			ctx->phy = cal->phy[i];
 
-		cal->ctx[cal->num_contexts] = cal_ctx_create(cal, i);
-		if (!cal->ctx[cal->num_contexts]) {
-			cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
-			ret = -ENODEV;
-			goto error_context;
+			cal->ctx[cal->num_contexts++] = ctx;
 		}
+	} else {
+		for (i = 0; i < ARRAY_SIZE(cal->ctx); ++i) {
+			struct cal_ctx *ctx;
+
+			ctx = cal_ctx_create(cal, i);
+			if (!ctx) {
+				cal_err(cal, "Failed to create context %u\n", i);
+				ret = -ENODEV;
+				goto error_context;
+			}
 
-		cal->num_contexts++;
+			cal->ctx[cal->num_contexts++] = ctx;
+		}
 	}
 
 	/* Register the media device. */
diff --git a/drivers/media/platform/ti/cal/cal.h b/drivers/media/platform/ti/cal/cal.h
index 0856297adc0b..44ee0bece56e 100644
--- a/drivers/media/platform/ti/cal/cal.h
+++ b/drivers/media/platform/ti/cal/cal.h
@@ -45,7 +45,7 @@
 
 #define CAL_CAMERARX_PAD_SINK		0
 #define CAL_CAMERARX_PAD_FIRST_SOURCE	1
-#define CAL_CAMERARX_NUM_SOURCE_PADS	1
+#define CAL_CAMERARX_NUM_SOURCE_PADS	8
 #define CAL_CAMERARX_NUM_PADS		(1 + CAL_CAMERARX_NUM_SOURCE_PADS)
 
 static inline bool cal_rx_pad_is_sink(u32 pad)
@@ -319,6 +319,7 @@ const struct cal_format_info *cal_format_by_code(u32 code);
 
 void cal_quickdump_regs(struct cal_dev *cal);
 
+struct cal_camerarx *cal_camerarx_get_phy_from_entity(struct media_entity *entity);
 void cal_camerarx_disable(struct cal_camerarx *phy);
 void cal_camerarx_i913_errata(struct cal_camerarx *phy);
 struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,

-- 
2.43.0

Re: [PATCH v6 3/3] media: ti: cal: Add streams support

[Kieran Bingham]

Quoting Tomi Valkeinen (2025-03-24 09:29:19)
> Add multiplexed streams support. CAL has 8 DMA-engines and can capture 8
> separate streams at the same time. The driver filters the streams based
> on CSI-2 virtual channel number and datatype. CAL may have (depending on
> the SoC) two CSI-2 RX blocks, which share the 8 DMA-engines, so the
> number of capturable streams does not change even if there are two CSI-2
> RX blocks.
> 
> Add 8 video device nodes, each representing a single DMA-engine, and set
> the number of source pads on CSI-2 RX blocks to 8. Each video node can be
> connected to any of the source pads on either of the CSI-2 RX instances
> using media links. CSI-2 RX block's subdevice internal routing is used
> to route the incoming CSI-2 streams to one of the 8 source pads.
> 
> Only video data streams are supported at the moment.

That's a big chunk of patch, so it's taken me a while to get through,
but aside from random comment's I couldn't see anything that scared me
so:

Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>

> 
> Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>
> Reviewed-by: Jacopo Mondi <jacopo.mondi@ideasonboard.com>
> ---
>  drivers/media/platform/ti/cal/cal-camerarx.c | 271 +++++++++++++++++++++------
>  drivers/media/platform/ti/cal/cal-video.c    | 127 ++++++++++---
>  drivers/media/platform/ti/cal/cal.c          |  45 +++--
>  drivers/media/platform/ti/cal/cal.h          |   3 +-
>  4 files changed, 340 insertions(+), 106 deletions(-)
> 
> diff --git a/drivers/media/platform/ti/cal/cal-camerarx.c b/drivers/media/platform/ti/cal/cal-camerarx.c
> index 42dfe08b765f..9d8aefdeb430 100644
> --- a/drivers/media/platform/ti/cal/cal-camerarx.c
> +++ b/drivers/media/platform/ti/cal/cal-camerarx.c
> @@ -49,21 +49,38 @@ static s64 cal_camerarx_get_ext_link_freq(struct cal_camerarx *phy)
>  {
>         struct v4l2_mbus_config_mipi_csi2 *mipi_csi2 = &phy->endpoint.bus.mipi_csi2;
>         u32 num_lanes = mipi_csi2->num_data_lanes;
> -       const struct cal_format_info *fmtinfo;
>         struct v4l2_subdev_state *state;
> -       struct v4l2_mbus_framefmt *fmt;
>         u32 bpp;
>         s64 freq;
>  
> +       /*
> +        * v4l2_get_link_freq() uses V4L2_CID_LINK_FREQ first, and falls back
> +        * to V4L2_CID_PIXEL_RATE if V4L2_CID_LINK_FREQ is not available.
> +        *
> +        * With multistream input there is no single pixel rate, and thus we
> +        * cannot use V4L2_CID_PIXEL_RATE, so we pass 0 as the bpp which
> +        * causes v4l2_get_link_freq() to return an error if it falls back to
> +        * V4L2_CID_PIXEL_RATE.

Seems like a convenient 'trick'. I wonder if the documentation of
v4l2_get_link_freq() should be extended to state this is possible, as I
expect other platforms will need the same thing when using streams?

Aha, actually it does already state bpp for D-PHY... 0 otherwise, but
perhaps something could be more explicit about streams usage.

Anyway, not an impact for this patch directly.


> +        */
> +
>         state = v4l2_subdev_get_locked_active_state(&phy->subdev);
>  
> -       fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
> +       if (state->routing.num_routes > 1) {
> +               bpp = 0;
> +       } else {
> +               struct v4l2_subdev_route *route = &state->routing.routes[0];
> +               const struct cal_format_info *fmtinfo;
> +               struct v4l2_mbus_framefmt *fmt;
>  
> -       fmtinfo = cal_format_by_code(fmt->code);
> -       if (!fmtinfo)
> -               return -EINVAL;
> +               fmt = v4l2_subdev_state_get_format(state,
> +                       route->sink_pad, route->sink_stream);
> +
> +               fmtinfo = cal_format_by_code(fmt->code);
> +               if (!fmtinfo)
> +                       return -EINVAL;
>  
> -       bpp = fmtinfo->bpp;
> +               bpp = fmtinfo->bpp;
> +       }
>  
>         freq = v4l2_get_link_freq(phy->source->ctrl_handler, bpp, 2 * num_lanes);
>         if (freq < 0) {
> @@ -284,15 +301,32 @@ static void cal_camerarx_ppi_disable(struct cal_camerarx *phy)
>                         0, CAL_CSI2_PPI_CTRL_IF_EN_MASK);
>  }
>  
> -static int cal_camerarx_start(struct cal_camerarx *phy)
> +static int cal_camerarx_start(struct cal_camerarx *phy, u32 sink_stream)
>  {
> +       struct media_pad *remote_pad;
>         s64 link_freq;
>         u32 sscounter;
>         u32 val;
>         int ret;
>  
> +       remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
> +
> +       /*
> +        * We need to enable the PHY hardware when enabling the first stream,
> +        * but for the following streams we just propagate the enable_streams
> +        * to the source.
> +        */
> +
>         if (phy->enable_count > 0) {
> +               ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
> +                                                BIT(sink_stream));
> +               if (ret) {
> +                       phy_err(phy, "enable streams failed in source: %d\n", ret);
> +                       return ret;
> +               }
> +
>                 phy->enable_count++;
> +
>                 return 0;
>         }
>  
> @@ -394,7 +428,8 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
>          * Start the source to enable the CSI-2 HS clock. We can now wait for
>          * CSI-2 PHY reset to complete.
>          */
> -       ret = v4l2_subdev_call(phy->source, video, s_stream, 1);
> +       ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
> +                                        BIT(sink_stream));
>         if (ret) {
>                 v4l2_subdev_call(phy->source, core, s_power, 0);
>                 cal_camerarx_disable_irqs(phy);
> @@ -425,12 +460,22 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
>         return 0;
>  }
>  
> -static void cal_camerarx_stop(struct cal_camerarx *phy)
> +static void cal_camerarx_stop(struct cal_camerarx *phy, u32 sink_stream)
>  {
> +       struct media_pad *remote_pad;
>         int ret;
>  
> -       if (--phy->enable_count > 0)
> +       remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
> +
> +       if (--phy->enable_count > 0) {
> +               ret = v4l2_subdev_disable_streams(phy->source,
> +                                                 remote_pad->index,
> +                                                 BIT(sink_stream));
> +               if (ret)
> +                       phy_err(phy, "stream off failed in subdev\n");
> +
>                 return;
> +       }
>  
>         cal_camerarx_ppi_disable(phy);
>  
> @@ -450,7 +495,9 @@ static void cal_camerarx_stop(struct cal_camerarx *phy)
>         /* Disable the phy */
>         cal_camerarx_disable(phy);
>  
> -       if (v4l2_subdev_call(phy->source, video, s_stream, 0))
> +       ret = v4l2_subdev_disable_streams(phy->source, remote_pad->index,
> +                                         BIT(sink_stream));
> +       if (ret)
>                 phy_err(phy, "stream off failed in subdev\n");
>  
>         ret = v4l2_subdev_call(phy->source, core, s_power, 0);
> @@ -599,22 +646,50 @@ static inline struct cal_camerarx *to_cal_camerarx(struct v4l2_subdev *sd)
>         return container_of(sd, struct cal_camerarx, subdev);
>  }
>  
> -static int cal_camerarx_sd_s_stream(struct v4l2_subdev *sd, int enable)
> +struct cal_camerarx *
> +cal_camerarx_get_phy_from_entity(struct media_entity *entity)
> +{
> +       struct v4l2_subdev *sd;
> +
> +       sd = media_entity_to_v4l2_subdev(entity);
> +       if (!sd)
> +               return NULL;
> +
> +       return to_cal_camerarx(sd);
> +}
> +
> +static int cal_camerarx_sd_enable_streams(struct v4l2_subdev *sd,
> +                                         struct v4l2_subdev_state *state,
> +                                         u32 pad, u64 streams_mask)
>  {
>         struct cal_camerarx *phy = to_cal_camerarx(sd);
> -       struct v4l2_subdev_state *state;
> -       int ret = 0;
> +       u32 sink_stream;
> +       int ret;
>  
> -       state = v4l2_subdev_lock_and_get_active_state(sd);
> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
> +                                                   NULL, &sink_stream);
> +       if (ret)
> +               return ret;
>  
> -       if (enable)
> -               ret = cal_camerarx_start(phy);
> -       else
> -               cal_camerarx_stop(phy);
> +       return cal_camerarx_start(phy, sink_stream);
> +}
>  
> -       v4l2_subdev_unlock_state(state);
> +static int cal_camerarx_sd_disable_streams(struct v4l2_subdev *sd,
> +                                          struct v4l2_subdev_state *state,
> +                                          u32 pad, u64 streams_mask)
> +{
> +       struct cal_camerarx *phy = to_cal_camerarx(sd);
> +       u32 sink_stream;
> +       int ret;
>  
> -       return ret;
> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
> +                                                   NULL, &sink_stream);
> +       if (ret)
> +               return ret;
> +
> +       cal_camerarx_stop(phy, sink_stream);
> +
> +       return 0;
>  }
>  
>  static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
> @@ -628,8 +703,12 @@ static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
>                 if (code->index > 0)
>                         return -EINVAL;
>  
> -               fmt = v4l2_subdev_state_get_format(state,
> -                                                  CAL_CAMERARX_PAD_SINK);
> +               fmt = v4l2_subdev_state_get_opposite_stream_format(state,
> +                                                                  code->pad,
> +                                                                  code->stream);
> +               if (!fmt)
> +                       return -EINVAL;
> +
>                 code->code = fmt->code;
>         } else {
>                 if (code->index >= cal_num_formats)
> @@ -654,8 +733,12 @@ static int cal_camerarx_sd_enum_frame_size(struct v4l2_subdev *sd,
>         if (cal_rx_pad_is_source(fse->pad)) {
>                 struct v4l2_mbus_framefmt *fmt;
>  
> -               fmt = v4l2_subdev_state_get_format(state,
> -                                                  CAL_CAMERARX_PAD_SINK);
> +               fmt = v4l2_subdev_state_get_opposite_stream_format(state,
> +                                                                  fse->pad,
> +                                                                  fse->stream);
> +               if (!fmt)
> +                       return -EINVAL;
> +
>                 if (fse->code != fmt->code)
>                         return -EINVAL;
>  
> @@ -711,36 +794,78 @@ static int cal_camerarx_sd_set_fmt(struct v4l2_subdev *sd,
>  
>         /* Store the format and propagate it to the source pad. */
>  
> -       fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
> +       fmt = v4l2_subdev_state_get_format(state, format->pad,
> +                                                 format->stream);
> +       if (!fmt)
> +               return -EINVAL;
> +
>         *fmt = format->format;
>  
> -       fmt = v4l2_subdev_state_get_format(state,
> -                                          CAL_CAMERARX_PAD_FIRST_SOURCE);
> +       fmt = v4l2_subdev_state_get_opposite_stream_format(state, format->pad,
> +                                                          format->stream);
> +       if (!fmt)
> +               return -EINVAL;
> +
>         *fmt = format->format;
>  
>         return 0;
>  }
>  
> +static int cal_camerarx_set_routing(struct v4l2_subdev *sd,
> +                                   struct v4l2_subdev_state *state,
> +                                   struct v4l2_subdev_krouting *routing)
> +{
> +       static const struct v4l2_mbus_framefmt format = {
> +               .width = 640,
> +               .height = 480,

This feels a bit arbitrary ... ? 

Which would be fine if it's just called from init_state, but I see calls
from
	.set_routing = cal_camerarx_sd_set_routing,

too?

> +               .code = MEDIA_BUS_FMT_UYVY8_1X16,
> +               .field = V4L2_FIELD_NONE,
> +               .colorspace = V4L2_COLORSPACE_SRGB,
> +               .ycbcr_enc = V4L2_YCBCR_ENC_601,
> +               .quantization = V4L2_QUANTIZATION_LIM_RANGE,
> +               .xfer_func = V4L2_XFER_FUNC_SRGB,
> +       };
> +       int ret;
> +
> +       ret = v4l2_subdev_routing_validate(sd, routing,
> +                                          V4L2_SUBDEV_ROUTING_ONLY_1_TO_1 |
> +                                          V4L2_SUBDEV_ROUTING_NO_SOURCE_MULTIPLEXING);
> +       if (ret)
> +               return ret;
> +
> +       ret = v4l2_subdev_set_routing_with_fmt(sd, state, routing, &format);
> +       if (ret)
> +               return ret;
> +
> +       return 0;
> +}
> +
> +static int cal_camerarx_sd_set_routing(struct v4l2_subdev *sd,
> +                                      struct v4l2_subdev_state *state,
> +                                      enum v4l2_subdev_format_whence which,
> +                                      struct v4l2_subdev_krouting *routing)
> +{
> +       return cal_camerarx_set_routing(sd, state, routing);

Do the routes persist across both TRY/ACTIVE? I.e. there's only ever a
single routing table?

> +}
> +
>  static int cal_camerarx_sd_init_state(struct v4l2_subdev *sd,
> -                                     struct v4l2_subdev_state *state)
> -{
> -       struct v4l2_subdev_format format = {
> -               .which = state ? V4L2_SUBDEV_FORMAT_TRY
> -               : V4L2_SUBDEV_FORMAT_ACTIVE,
> -               .pad = CAL_CAMERARX_PAD_SINK,
> -               .format = {
> -                       .width = 640,
> -                       .height = 480,

Aha, So the size was already arbitrary - not newly added anyway.

> -                       .code = MEDIA_BUS_FMT_UYVY8_1X16,
> -                       .field = V4L2_FIELD_NONE,
> -                       .colorspace = V4L2_COLORSPACE_SRGB,
> -                       .ycbcr_enc = V4L2_YCBCR_ENC_601,
> -                       .quantization = V4L2_QUANTIZATION_LIM_RANGE,
> -                       .xfer_func = V4L2_XFER_FUNC_SRGB,
> -               },
> +                                   struct v4l2_subdev_state *state)
> +{
> +       struct v4l2_subdev_route routes[] = { {
> +               .sink_pad = 0,
> +               .sink_stream = 0,
> +               .source_pad = 1,
> +               .source_stream = 0,
> +               .flags = V4L2_SUBDEV_ROUTE_FL_ACTIVE,
> +       } };
> +
> +       struct v4l2_subdev_krouting routing = {
> +               .num_routes = 1,
> +               .routes = routes,
>         };
>  
> -       return cal_camerarx_sd_set_fmt(sd, state, &format);
> +       /* Initialize routing to single route to the fist source pad */
> +       return cal_camerarx_set_routing(sd, state, &routing);
>  }
>  
>  static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
> @@ -749,48 +874,71 @@ static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
>         struct cal_camerarx *phy = to_cal_camerarx(sd);
>         struct v4l2_mbus_frame_desc remote_desc;
>         const struct media_pad *remote_pad;
> +       struct v4l2_subdev_state *state;
> +       u32 sink_stream;
> +       unsigned int i;
>         int ret;
>  
> +       state = v4l2_subdev_lock_and_get_active_state(sd);
> +
> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing,
> +                                                   pad, 0,
> +                                                   NULL, &sink_stream);
> +       if (ret)
> +               goto out_unlock;
> +
>         remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
> -       if (!remote_pad)
> -               return -EPIPE;
> +       if (!remote_pad) {
> +               ret = -EPIPE;
> +               goto out_unlock;
> +       }
>  
>         ret = v4l2_subdev_call(phy->source, pad, get_frame_desc,
>                                remote_pad->index, &remote_desc);
>         if (ret)
> -               return ret;
> +               goto out_unlock;
>  
>         if (remote_desc.type != V4L2_MBUS_FRAME_DESC_TYPE_CSI2) {
>                 cal_err(phy->cal,
>                         "Frame descriptor does not describe CSI-2 link");
> -               return -EINVAL;
> +               ret = -EINVAL;
> +               goto out_unlock;
>         }
>  
> -       if (remote_desc.num_entries > 1)
> -               cal_err(phy->cal,
> -                       "Multiple streams not supported in remote frame descriptor, using the first one\n");
> +       for (i = 0; i < remote_desc.num_entries; i++) {
> +               if (remote_desc.entry[i].stream == sink_stream)
> +                       break;
> +       }
> +
> +       if (i == remote_desc.num_entries) {
> +               cal_err(phy->cal, "Stream %u not found in remote frame desc\n",
> +                       sink_stream);
> +               ret = -EINVAL;
> +               goto out_unlock;
> +       }
>  
>         fd->type = V4L2_MBUS_FRAME_DESC_TYPE_CSI2;
>         fd->num_entries = 1;
> -       fd->entry[0] = remote_desc.entry[0];
> +       fd->entry[0] = remote_desc.entry[i];
>  
> -       return 0;
> -}
> +out_unlock:
> +       v4l2_subdev_unlock_state(state);
>  
> -static const struct v4l2_subdev_video_ops cal_camerarx_video_ops = {
> -       .s_stream = cal_camerarx_sd_s_stream,
> -};
> +       return ret;
> +}
>  
>  static const struct v4l2_subdev_pad_ops cal_camerarx_pad_ops = {
> +       .enable_streams = cal_camerarx_sd_enable_streams,
> +       .disable_streams = cal_camerarx_sd_disable_streams,
>         .enum_mbus_code = cal_camerarx_sd_enum_mbus_code,
>         .enum_frame_size = cal_camerarx_sd_enum_frame_size,
>         .get_fmt = v4l2_subdev_get_fmt,
>         .set_fmt = cal_camerarx_sd_set_fmt,
> +       .set_routing = cal_camerarx_sd_set_routing,
>         .get_frame_desc = cal_camerarx_get_frame_desc,
>  };
>  
>  static const struct v4l2_subdev_ops cal_camerarx_subdev_ops = {
> -       .video = &cal_camerarx_video_ops,
>         .pad = &cal_camerarx_pad_ops,
>  };
>  
> @@ -800,6 +948,7 @@ static const struct v4l2_subdev_internal_ops cal_camerarx_internal_ops = {
>  
>  static const struct media_entity_operations cal_camerarx_media_ops = {
>         .link_validate = v4l2_subdev_link_validate,
> +       .has_pad_interdep = v4l2_subdev_has_pad_interdep,
>  };
>  
>  /* ------------------------------------------------------------------
> @@ -851,7 +1000,7 @@ struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,
>         v4l2_subdev_init(sd, &cal_camerarx_subdev_ops);
>         sd->internal_ops = &cal_camerarx_internal_ops;
>         sd->entity.function = MEDIA_ENT_F_VID_IF_BRIDGE;
> -       sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE;
> +       sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE | V4L2_SUBDEV_FL_STREAMS;
>         snprintf(sd->name, sizeof(sd->name), "CAMERARX%u", instance);
>         sd->dev = cal->dev;
>  
> diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
> index 29c38bf8d7a1..97a14ceaf237 100644
> --- a/drivers/media/platform/ti/cal/cal-video.c
> +++ b/drivers/media/platform/ti/cal/cal-video.c
> @@ -108,9 +108,10 @@ static int __subdev_get_format(struct cal_ctx *ctx,
>                 .pad = 0,
>         };
>         struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         int ret;
>  
> -       ret = v4l2_subdev_call(ctx->phy->source, pad, get_fmt, NULL, &sd_fmt);
> +       ret = v4l2_subdev_call_state_active(sd, pad, get_fmt, &sd_fmt);
>         if (ret)
>                 return ret;
>  
> @@ -130,11 +131,12 @@ static int __subdev_set_format(struct cal_ctx *ctx,
>                 .pad = 0,
>         };
>         struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         int ret;
>  
>         *mbus_fmt = *fmt;
>  
> -       ret = v4l2_subdev_call(ctx->phy->source, pad, set_fmt, NULL, &sd_fmt);
> +       ret = v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);
>         if (ret)
>                 return ret;
>  
> @@ -176,6 +178,7 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
>                                       struct v4l2_format *f)
>  {
>         struct cal_ctx *ctx = video_drvdata(file);
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         const struct cal_format_info *fmtinfo;
>         struct v4l2_subdev_frame_size_enum fse = {
>                 .which = V4L2_SUBDEV_FORMAT_ACTIVE,
> @@ -201,8 +204,8 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
>         for (fse.index = 0; ; fse.index++) {
>                 int ret;
>  
> -               ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size,
> -                                      NULL, &fse);
> +               ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size,
> +                                                   &fse);
>                 if (ret)
>                         break;
>  
> @@ -238,6 +241,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
>                                     struct v4l2_format *f)
>  {
>         struct cal_ctx *ctx = video_drvdata(file);
> +       struct v4l2_subdev *sd = &ctx->phy->subdev;
>         struct vb2_queue *q = &ctx->vb_vidq;
>         struct v4l2_subdev_format sd_fmt = {
>                 .which = V4L2_SUBDEV_FORMAT_ACTIVE,
> @@ -277,7 +281,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
>         ctx->v_fmt.fmt.pix.field = sd_fmt.format.field;
>         cal_calc_format_size(ctx, fmtinfo, &ctx->v_fmt);
>  
> -       v4l2_subdev_call(&ctx->phy->subdev, pad, set_fmt, NULL, &sd_fmt);
> +       v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);

No return checks required here from set_fmt? But it wasn't there before
so not this patch anyway.

>  
>         ctx->fmtinfo = fmtinfo;
>         *f = ctx->v_fmt;
> @@ -289,6 +293,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
>                                       struct v4l2_frmsizeenum *fsize)
>  {
>         struct cal_ctx *ctx = video_drvdata(file);
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         const struct cal_format_info *fmtinfo;
>         struct v4l2_subdev_frame_size_enum fse = {
>                 .index = fsize->index,
> @@ -307,8 +312,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
>  
>         fse.code = fmtinfo->code;
>  
> -       ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size, NULL,
> -                              &fse);
> +       ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size, &fse);
>         if (ret)
>                 return ret;
>  
> @@ -350,6 +354,7 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
>                                           struct v4l2_frmivalenum *fival)
>  {
>         struct cal_ctx *ctx = video_drvdata(file);
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         const struct cal_format_info *fmtinfo;
>         struct v4l2_subdev_frame_interval_enum fie = {
>                 .index = fival->index,
> @@ -364,8 +369,8 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
>                 return -EINVAL;
>  
>         fie.code = fmtinfo->code;
> -       ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_interval,
> -                              NULL, &fie);
> +
> +       ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_interval, &fie);
>         if (ret)
>                 return ret;
>         fival->type = V4L2_FRMIVAL_TYPE_DISCRETE;
> @@ -432,6 +437,9 @@ static int cal_mc_enum_fmt_vid_cap(struct file *file, void  *priv,
>         idx = 0;
>  
>         for (i = 0; i < cal_num_formats; ++i) {
> +               if (cal_formats[i].meta)
> +                       continue;
> +
>                 if (f->mbus_code && cal_formats[i].code != f->mbus_code)
>                         continue;
>  
> @@ -459,7 +467,7 @@ static void cal_mc_try_fmt(struct cal_ctx *ctx, struct v4l2_format *f,
>          * supported.
>          */
>         fmtinfo = cal_format_by_fourcc(f->fmt.pix.pixelformat);
> -       if (!fmtinfo)
> +       if (!fmtinfo || fmtinfo->meta)
>                 fmtinfo = &cal_formats[0];
>  
>         /*
> @@ -675,16 +683,16 @@ static int cal_video_check_format(struct cal_ctx *ctx)
>  {
>         const struct v4l2_mbus_framefmt *format;
>         struct v4l2_subdev_state *state;
> -       struct media_pad *remote_pad;
> +       struct media_pad *phy_source_pad;
>         int ret = 0;
>  
> -       remote_pad = media_pad_remote_pad_first(&ctx->pad);
> -       if (!remote_pad)
> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
> +       if (!phy_source_pad)
>                 return -ENODEV;
>  
>         state = v4l2_subdev_lock_and_get_active_state(&ctx->phy->subdev);
>  
> -       format = v4l2_subdev_state_get_format(state, remote_pad->index);
> +       format = v4l2_subdev_state_get_format(state, phy_source_pad->index, 0);
>         if (!format) {
>                 ret = -EINVAL;
>                 goto out;
> @@ -707,16 +715,28 @@ static int cal_video_check_format(struct cal_ctx *ctx)
>  static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>  {
>         struct cal_ctx *ctx = vb2_get_drv_priv(vq);
> +       struct media_pad *phy_source_pad;
>         struct cal_buffer *buf;
>         dma_addr_t addr;
>         int ret;
>  
> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
> +       if (!phy_source_pad) {
> +               ctx_err(ctx, "Context not connected\n");
> +               ret = -ENODEV;
> +               goto error_release_buffers;
> +       }
> +
>         ret = video_device_pipeline_alloc_start(&ctx->vdev);
>         if (ret < 0) {
>                 ctx_err(ctx, "Failed to start media pipeline: %d\n", ret);
>                 goto error_release_buffers;
>         }
>  
> +       /* Find the PHY connected to this video device */
> +       if (cal_mc_api)
> +               ctx->phy = cal_camerarx_get_phy_from_entity(phy_source_pad->entity);
> +
>         /*
>          * Verify that the currently configured format matches the output of
>          * the connected CAMERARX.
> @@ -749,7 +769,8 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>         cal_ctx_set_dma_addr(ctx, addr);
>         cal_ctx_start(ctx);
>  
> -       ret = v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 1);
> +       ret = v4l2_subdev_enable_streams(&ctx->phy->subdev,
> +                                        phy_source_pad->index, BIT(0));
>         if (ret)
>                 goto error_stop;
>  
> @@ -774,10 +795,14 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>  static void cal_stop_streaming(struct vb2_queue *vq)
>  {
>         struct cal_ctx *ctx = vb2_get_drv_priv(vq);
> +       struct media_pad *phy_source_pad;
>  
>         cal_ctx_stop(ctx);
>  
> -       v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 0);
> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
> +
> +       v4l2_subdev_disable_streams(&ctx->phy->subdev, phy_source_pad->index,
> +                                   BIT(0));
>  
>         pm_runtime_put_sync(ctx->cal->dev);
>  
> @@ -786,6 +811,9 @@ static void cal_stop_streaming(struct vb2_queue *vq)
>         cal_release_buffers(ctx, VB2_BUF_STATE_ERROR);
>  
>         video_device_pipeline_stop(&ctx->vdev);
> +
> +       if (cal_mc_api)
> +               ctx->phy = NULL;
>  }
>  
>  static const struct vb2_ops cal_video_qops = {
> @@ -812,6 +840,7 @@ static const struct v4l2_file_operations cal_fops = {
>  
>  static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>  {
> +       struct v4l2_subdev *sd = ctx->phy->source;
>         struct v4l2_mbus_framefmt mbus_fmt;
>         const struct cal_format_info *fmtinfo;
>         unsigned int i, j, k;
> @@ -831,20 +860,20 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>                         .which = V4L2_SUBDEV_FORMAT_ACTIVE,
>                 };
>  
> -               ret = v4l2_subdev_call(ctx->phy->source, pad, enum_mbus_code,
> -                                      NULL, &mbus_code);
> +               ret = v4l2_subdev_call_state_active(sd, pad, enum_mbus_code,
> +                                                   &mbus_code);
>                 if (ret == -EINVAL)
>                         break;
>  
>                 if (ret) {
>                         ctx_err(ctx, "Error enumerating mbus codes in subdev %s: %d\n",
> -                               ctx->phy->source->name, ret);
> +                               sd->name, ret);
>                         return ret;
>                 }
>  
>                 ctx_dbg(2, ctx,
>                         "subdev %s: code: %04x idx: %u\n",
> -                       ctx->phy->source->name, mbus_code.code, j);
> +                       sd->name, mbus_code.code, j);
>  
>                 for (k = 0; k < cal_num_formats; k++) {
>                         fmtinfo = &cal_formats[k];
> @@ -862,7 +891,7 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>  
>         if (i == 0) {
>                 ctx_err(ctx, "No suitable format reported by subdev %s\n",
> -                       ctx->phy->source->name);
> +                       sd->name);
>                 return -EINVAL;
>         }
>  
> @@ -948,16 +977,52 @@ int cal_ctx_v4l2_register(struct cal_ctx *ctx)
>                 return ret;
>         }
>  
> -       ret = media_create_pad_link(&ctx->phy->subdev.entity,
> -                                   CAL_CAMERARX_PAD_FIRST_SOURCE,
> -                                   &vfd->entity, 0,
> -                                   MEDIA_LNK_FL_IMMUTABLE |
> -                                   MEDIA_LNK_FL_ENABLED);
> -       if (ret) {
> -               ctx_err(ctx, "Failed to create media link for context %u\n",
> -                       ctx->dma_ctx);
> -               video_unregister_device(vfd);
> -               return ret;
> +       if (cal_mc_api) {
> +               u16 phy_idx;
> +               u16 pad_idx;
> +
> +               /* Create links from all video nodes to all PHYs */
> +
> +               for (phy_idx = 0; phy_idx < ctx->cal->data->num_csi2_phy;
> +                    ++phy_idx) {
> +                       struct media_entity *phy_entity =
> +                               &ctx->cal->phy[phy_idx]->subdev.entity;
> +
> +                       for (pad_idx = 1; pad_idx < CAL_CAMERARX_NUM_PADS;
> +                            ++pad_idx) {
> +                               /*
> +                                * Enable only links from video0 to PHY0 pad 1,
> +                                * and video1 to PHY1 pad 1.
> +                                */
> +                               bool enable = (ctx->dma_ctx == 0 &&
> +                                              phy_idx == 0 && pad_idx == 1) ||
> +                                             (ctx->dma_ctx == 1 &&
> +                                              phy_idx == 1 && pad_idx == 1);
> +
> +                               ret = media_create_pad_link(phy_entity, pad_idx,
> +                                       &vfd->entity, 0,
> +                                       enable ? MEDIA_LNK_FL_ENABLED : 0);
> +                               if (ret) {
> +                                       ctx_err(ctx,
> +                                               "Failed to create media link for context %u\n",
> +                                               ctx->dma_ctx);
> +                                       video_unregister_device(vfd);
> +                                       return ret;
> +                               }
> +                       }
> +               }
> +       } else {
> +               ret = media_create_pad_link(&ctx->phy->subdev.entity,
> +                                           CAL_CAMERARX_PAD_FIRST_SOURCE,
> +                                           &vfd->entity, 0,
> +                                           MEDIA_LNK_FL_IMMUTABLE | MEDIA_LNK_FL_ENABLED);
> +               if (ret) {
> +                       ctx_err(ctx,
> +                               "Failed to create media link for context %u\n",
> +                               ctx->dma_ctx);
> +                       video_unregister_device(vfd);
> +                       return ret;
> +               }
>         }
>  
>         ctx_info(ctx, "V4L2 device registered as %s\n",
> diff --git a/drivers/media/platform/ti/cal/cal.c b/drivers/media/platform/ti/cal/cal.c
> index 4bd2092e0255..9389c444400e 100644
> --- a/drivers/media/platform/ti/cal/cal.c
> +++ b/drivers/media/platform/ti/cal/cal.c
> @@ -481,8 +481,9 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
>                 ctx->vc = 0;
>                 ctx->datatype = CAL_CSI2_CTX_DT_ANY;
>         } else if (!ret) {
> -               ctx_dbg(2, ctx, "Framedesc: len %u, vc %u, dt %#x\n",
> -                       entry.length, entry.bus.csi2.vc, entry.bus.csi2.dt);
> +               ctx_dbg(2, ctx, "Framedesc: stream %u, len %u, vc %u, dt %#x\n",
> +                       entry.stream, entry.length, entry.bus.csi2.vc,
> +                       entry.bus.csi2.dt);
>  
>                 ctx->vc = entry.bus.csi2.vc;
>                 ctx->datatype = entry.bus.csi2.dt;
> @@ -490,7 +491,7 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
>                 return ret;
>         }
>  
> -       ctx->use_pix_proc = !ctx->fmtinfo->meta;
> +       ctx->use_pix_proc = ctx->vb_vidq.type == V4L2_BUF_TYPE_VIDEO_CAPTURE;
>  
>         if (ctx->use_pix_proc) {
>                 ret = cal_reserve_pix_proc(ctx->cal);
> @@ -1014,7 +1015,6 @@ static struct cal_ctx *cal_ctx_create(struct cal_dev *cal, int inst)
>                 return NULL;
>  
>         ctx->cal = cal;
> -       ctx->phy = cal->phy[inst];
>         ctx->dma_ctx = inst;
>         ctx->csi2_ctx = inst;
>         ctx->cport = inst;
> @@ -1226,18 +1226,37 @@ static int cal_probe(struct platform_device *pdev)
>         }
>  
>         /* Create contexts. */
> -       for (i = 0; i < cal->data->num_csi2_phy; ++i) {
> -               if (!cal->phy[i]->source_node)
> -                       continue;
> +       if (!cal_mc_api) {
> +               for (i = 0; i < cal->data->num_csi2_phy; ++i) {
> +                       struct cal_ctx *ctx;
> +
> +                       if (!cal->phy[i]->source_node)
> +                               continue;
> +
> +                       ctx = cal_ctx_create(cal, i);
> +                       if (!ctx) {
> +                               cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
> +                               ret = -ENODEV;
> +                               goto error_context;
> +                       }
> +
> +                       ctx->phy = cal->phy[i];
>  
> -               cal->ctx[cal->num_contexts] = cal_ctx_create(cal, i);
> -               if (!cal->ctx[cal->num_contexts]) {
> -                       cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
> -                       ret = -ENODEV;
> -                       goto error_context;
> +                       cal->ctx[cal->num_contexts++] = ctx;
>                 }
> +       } else {
> +               for (i = 0; i < ARRAY_SIZE(cal->ctx); ++i) {
> +                       struct cal_ctx *ctx;
> +
> +                       ctx = cal_ctx_create(cal, i);
> +                       if (!ctx) {
> +                               cal_err(cal, "Failed to create context %u\n", i);
> +                               ret = -ENODEV;
> +                               goto error_context;
> +                       }
>  
> -               cal->num_contexts++;
> +                       cal->ctx[cal->num_contexts++] = ctx;
> +               }
>         }
>  
>         /* Register the media device. */
> diff --git a/drivers/media/platform/ti/cal/cal.h b/drivers/media/platform/ti/cal/cal.h
> index 0856297adc0b..44ee0bece56e 100644
> --- a/drivers/media/platform/ti/cal/cal.h
> +++ b/drivers/media/platform/ti/cal/cal.h
> @@ -45,7 +45,7 @@
>  
>  #define CAL_CAMERARX_PAD_SINK          0
>  #define CAL_CAMERARX_PAD_FIRST_SOURCE  1
> -#define CAL_CAMERARX_NUM_SOURCE_PADS   1
> +#define CAL_CAMERARX_NUM_SOURCE_PADS   8
>  #define CAL_CAMERARX_NUM_PADS          (1 + CAL_CAMERARX_NUM_SOURCE_PADS)
>  
>  static inline bool cal_rx_pad_is_sink(u32 pad)
> @@ -319,6 +319,7 @@ const struct cal_format_info *cal_format_by_code(u32 code);
>  
>  void cal_quickdump_regs(struct cal_dev *cal);
>  
> +struct cal_camerarx *cal_camerarx_get_phy_from_entity(struct media_entity *entity);
>  void cal_camerarx_disable(struct cal_camerarx *phy);
>  void cal_camerarx_i913_errata(struct cal_camerarx *phy);
>  struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,
> 
> -- 
> 2.43.0
>

Re: [PATCH v6 3/3] media: ti: cal: Add streams support

[Tomi Valkeinen]

Hi,

On 24/03/2025 15:12, Kieran Bingham wrote:
> Quoting Tomi Valkeinen (2025-03-24 09:29:19)
>> Add multiplexed streams support. CAL has 8 DMA-engines and can capture 8
>> separate streams at the same time. The driver filters the streams based
>> on CSI-2 virtual channel number and datatype. CAL may have (depending on
>> the SoC) two CSI-2 RX blocks, which share the 8 DMA-engines, so the
>> number of capturable streams does not change even if there are two CSI-2
>> RX blocks.
>>
>> Add 8 video device nodes, each representing a single DMA-engine, and set
>> the number of source pads on CSI-2 RX blocks to 8. Each video node can be
>> connected to any of the source pads on either of the CSI-2 RX instances
>> using media links. CSI-2 RX block's subdevice internal routing is used
>> to route the incoming CSI-2 streams to one of the 8 source pads.
>>
>> Only video data streams are supported at the moment.
> 
> That's a big chunk of patch, so it's taken me a while to get through,
> but aside from random comment's I couldn't see anything that scared me
> so:
> 
> Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>

Thanks!

>>
>> Signed-off-by: Tomi Valkeinen <tomi.valkeinen@ideasonboard.com>
>> Reviewed-by: Jacopo Mondi <jacopo.mondi@ideasonboard.com>
>> ---
>>   drivers/media/platform/ti/cal/cal-camerarx.c | 271 +++++++++++++++++++++------
>>   drivers/media/platform/ti/cal/cal-video.c    | 127 ++++++++++---
>>   drivers/media/platform/ti/cal/cal.c          |  45 +++--
>>   drivers/media/platform/ti/cal/cal.h          |   3 +-
>>   4 files changed, 340 insertions(+), 106 deletions(-)
>>
>> diff --git a/drivers/media/platform/ti/cal/cal-camerarx.c b/drivers/media/platform/ti/cal/cal-camerarx.c
>> index 42dfe08b765f..9d8aefdeb430 100644
>> --- a/drivers/media/platform/ti/cal/cal-camerarx.c
>> +++ b/drivers/media/platform/ti/cal/cal-camerarx.c
>> @@ -49,21 +49,38 @@ static s64 cal_camerarx_get_ext_link_freq(struct cal_camerarx *phy)
>>   {
>>          struct v4l2_mbus_config_mipi_csi2 *mipi_csi2 = &phy->endpoint.bus.mipi_csi2;
>>          u32 num_lanes = mipi_csi2->num_data_lanes;
>> -       const struct cal_format_info *fmtinfo;
>>          struct v4l2_subdev_state *state;
>> -       struct v4l2_mbus_framefmt *fmt;
>>          u32 bpp;
>>          s64 freq;
>>   
>> +       /*
>> +        * v4l2_get_link_freq() uses V4L2_CID_LINK_FREQ first, and falls back
>> +        * to V4L2_CID_PIXEL_RATE if V4L2_CID_LINK_FREQ is not available.
>> +        *
>> +        * With multistream input there is no single pixel rate, and thus we
>> +        * cannot use V4L2_CID_PIXEL_RATE, so we pass 0 as the bpp which
>> +        * causes v4l2_get_link_freq() to return an error if it falls back to
>> +        * V4L2_CID_PIXEL_RATE.
> 
> Seems like a convenient 'trick'. I wonder if the documentation of
> v4l2_get_link_freq() should be extended to state this is possible, as I
> expect other platforms will need the same thing when using streams?
> 
> Aha, actually it does already state bpp for D-PHY... 0 otherwise, but
> perhaps something could be more explicit about streams usage.
> 
> Anyway, not an impact for this patch directly.

For new drivers I think it should be fine to rely on proper link-freq 
support (i.e. always pass 0, 0 as parameters). But, indeed, the 
documentation doesn't really cover this.

> 
>> +        */
>> +
>>          state = v4l2_subdev_get_locked_active_state(&phy->subdev);
>>   
>> -       fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
>> +       if (state->routing.num_routes > 1) {
>> +               bpp = 0;
>> +       } else {
>> +               struct v4l2_subdev_route *route = &state->routing.routes[0];
>> +               const struct cal_format_info *fmtinfo;
>> +               struct v4l2_mbus_framefmt *fmt;
>>   
>> -       fmtinfo = cal_format_by_code(fmt->code);
>> -       if (!fmtinfo)
>> -               return -EINVAL;
>> +               fmt = v4l2_subdev_state_get_format(state,
>> +                       route->sink_pad, route->sink_stream);
>> +
>> +               fmtinfo = cal_format_by_code(fmt->code);
>> +               if (!fmtinfo)
>> +                       return -EINVAL;
>>   
>> -       bpp = fmtinfo->bpp;
>> +               bpp = fmtinfo->bpp;
>> +       }
>>   
>>          freq = v4l2_get_link_freq(phy->source->ctrl_handler, bpp, 2 * num_lanes);
>>          if (freq < 0) {
>> @@ -284,15 +301,32 @@ static void cal_camerarx_ppi_disable(struct cal_camerarx *phy)
>>                          0, CAL_CSI2_PPI_CTRL_IF_EN_MASK);
>>   }
>>   
>> -static int cal_camerarx_start(struct cal_camerarx *phy)
>> +static int cal_camerarx_start(struct cal_camerarx *phy, u32 sink_stream)
>>   {
>> +       struct media_pad *remote_pad;
>>          s64 link_freq;
>>          u32 sscounter;
>>          u32 val;
>>          int ret;
>>   
>> +       remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
>> +
>> +       /*
>> +        * We need to enable the PHY hardware when enabling the first stream,
>> +        * but for the following streams we just propagate the enable_streams
>> +        * to the source.
>> +        */
>> +
>>          if (phy->enable_count > 0) {
>> +               ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
>> +                                                BIT(sink_stream));
>> +               if (ret) {
>> +                       phy_err(phy, "enable streams failed in source: %d\n", ret);
>> +                       return ret;
>> +               }
>> +
>>                  phy->enable_count++;
>> +
>>                  return 0;
>>          }
>>   
>> @@ -394,7 +428,8 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
>>           * Start the source to enable the CSI-2 HS clock. We can now wait for
>>           * CSI-2 PHY reset to complete.
>>           */
>> -       ret = v4l2_subdev_call(phy->source, video, s_stream, 1);
>> +       ret = v4l2_subdev_enable_streams(phy->source, remote_pad->index,
>> +                                        BIT(sink_stream));
>>          if (ret) {
>>                  v4l2_subdev_call(phy->source, core, s_power, 0);
>>                  cal_camerarx_disable_irqs(phy);
>> @@ -425,12 +460,22 @@ static int cal_camerarx_start(struct cal_camerarx *phy)
>>          return 0;
>>   }
>>   
>> -static void cal_camerarx_stop(struct cal_camerarx *phy)
>> +static void cal_camerarx_stop(struct cal_camerarx *phy, u32 sink_stream)
>>   {
>> +       struct media_pad *remote_pad;
>>          int ret;
>>   
>> -       if (--phy->enable_count > 0)
>> +       remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
>> +
>> +       if (--phy->enable_count > 0) {
>> +               ret = v4l2_subdev_disable_streams(phy->source,
>> +                                                 remote_pad->index,
>> +                                                 BIT(sink_stream));
>> +               if (ret)
>> +                       phy_err(phy, "stream off failed in subdev\n");
>> +
>>                  return;
>> +       }
>>   
>>          cal_camerarx_ppi_disable(phy);
>>   
>> @@ -450,7 +495,9 @@ static void cal_camerarx_stop(struct cal_camerarx *phy)
>>          /* Disable the phy */
>>          cal_camerarx_disable(phy);
>>   
>> -       if (v4l2_subdev_call(phy->source, video, s_stream, 0))
>> +       ret = v4l2_subdev_disable_streams(phy->source, remote_pad->index,
>> +                                         BIT(sink_stream));
>> +       if (ret)
>>                  phy_err(phy, "stream off failed in subdev\n");
>>   
>>          ret = v4l2_subdev_call(phy->source, core, s_power, 0);
>> @@ -599,22 +646,50 @@ static inline struct cal_camerarx *to_cal_camerarx(struct v4l2_subdev *sd)
>>          return container_of(sd, struct cal_camerarx, subdev);
>>   }
>>   
>> -static int cal_camerarx_sd_s_stream(struct v4l2_subdev *sd, int enable)
>> +struct cal_camerarx *
>> +cal_camerarx_get_phy_from_entity(struct media_entity *entity)
>> +{
>> +       struct v4l2_subdev *sd;
>> +
>> +       sd = media_entity_to_v4l2_subdev(entity);
>> +       if (!sd)
>> +               return NULL;
>> +
>> +       return to_cal_camerarx(sd);
>> +}
>> +
>> +static int cal_camerarx_sd_enable_streams(struct v4l2_subdev *sd,
>> +                                         struct v4l2_subdev_state *state,
>> +                                         u32 pad, u64 streams_mask)
>>   {
>>          struct cal_camerarx *phy = to_cal_camerarx(sd);
>> -       struct v4l2_subdev_state *state;
>> -       int ret = 0;
>> +       u32 sink_stream;
>> +       int ret;
>>   
>> -       state = v4l2_subdev_lock_and_get_active_state(sd);
>> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
>> +                                                   NULL, &sink_stream);
>> +       if (ret)
>> +               return ret;
>>   
>> -       if (enable)
>> -               ret = cal_camerarx_start(phy);
>> -       else
>> -               cal_camerarx_stop(phy);
>> +       return cal_camerarx_start(phy, sink_stream);
>> +}
>>   
>> -       v4l2_subdev_unlock_state(state);
>> +static int cal_camerarx_sd_disable_streams(struct v4l2_subdev *sd,
>> +                                          struct v4l2_subdev_state *state,
>> +                                          u32 pad, u64 streams_mask)
>> +{
>> +       struct cal_camerarx *phy = to_cal_camerarx(sd);
>> +       u32 sink_stream;
>> +       int ret;
>>   
>> -       return ret;
>> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing, pad, 0,
>> +                                                   NULL, &sink_stream);
>> +       if (ret)
>> +               return ret;
>> +
>> +       cal_camerarx_stop(phy, sink_stream);
>> +
>> +       return 0;
>>   }
>>   
>>   static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
>> @@ -628,8 +703,12 @@ static int cal_camerarx_sd_enum_mbus_code(struct v4l2_subdev *sd,
>>                  if (code->index > 0)
>>                          return -EINVAL;
>>   
>> -               fmt = v4l2_subdev_state_get_format(state,
>> -                                                  CAL_CAMERARX_PAD_SINK);
>> +               fmt = v4l2_subdev_state_get_opposite_stream_format(state,
>> +                                                                  code->pad,
>> +                                                                  code->stream);
>> +               if (!fmt)
>> +                       return -EINVAL;
>> +
>>                  code->code = fmt->code;
>>          } else {
>>                  if (code->index >= cal_num_formats)
>> @@ -654,8 +733,12 @@ static int cal_camerarx_sd_enum_frame_size(struct v4l2_subdev *sd,
>>          if (cal_rx_pad_is_source(fse->pad)) {
>>                  struct v4l2_mbus_framefmt *fmt;
>>   
>> -               fmt = v4l2_subdev_state_get_format(state,
>> -                                                  CAL_CAMERARX_PAD_SINK);
>> +               fmt = v4l2_subdev_state_get_opposite_stream_format(state,
>> +                                                                  fse->pad,
>> +                                                                  fse->stream);
>> +               if (!fmt)
>> +                       return -EINVAL;
>> +
>>                  if (fse->code != fmt->code)
>>                          return -EINVAL;
>>   
>> @@ -711,36 +794,78 @@ static int cal_camerarx_sd_set_fmt(struct v4l2_subdev *sd,
>>   
>>          /* Store the format and propagate it to the source pad. */
>>   
>> -       fmt = v4l2_subdev_state_get_format(state, CAL_CAMERARX_PAD_SINK);
>> +       fmt = v4l2_subdev_state_get_format(state, format->pad,
>> +                                                 format->stream);
>> +       if (!fmt)
>> +               return -EINVAL;
>> +
>>          *fmt = format->format;
>>   
>> -       fmt = v4l2_subdev_state_get_format(state,
>> -                                          CAL_CAMERARX_PAD_FIRST_SOURCE);
>> +       fmt = v4l2_subdev_state_get_opposite_stream_format(state, format->pad,
>> +                                                          format->stream);
>> +       if (!fmt)
>> +               return -EINVAL;
>> +
>>          *fmt = format->format;
>>   
>>          return 0;
>>   }
>>   
>> +static int cal_camerarx_set_routing(struct v4l2_subdev *sd,
>> +                                   struct v4l2_subdev_state *state,
>> +                                   struct v4l2_subdev_krouting *routing)
>> +{
>> +       static const struct v4l2_mbus_framefmt format = {
>> +               .width = 640,
>> +               .height = 480,
> 
> This feels a bit arbitrary ... ?

Isn't any default setting a bit (well, totally) arbitrary? But, as you 
notice below, these were already used by the driver.

> Which would be fine if it's just called from init_state, but I see calls
> from
> 	.set_routing = cal_camerarx_sd_set_routing,
> 
> too?
> 
>> +               .code = MEDIA_BUS_FMT_UYVY8_1X16,
>> +               .field = V4L2_FIELD_NONE,
>> +               .colorspace = V4L2_COLORSPACE_SRGB,
>> +               .ycbcr_enc = V4L2_YCBCR_ENC_601,
>> +               .quantization = V4L2_QUANTIZATION_LIM_RANGE,
>> +               .xfer_func = V4L2_XFER_FUNC_SRGB,
>> +       };
>> +       int ret;
>> +
>> +       ret = v4l2_subdev_routing_validate(sd, routing,
>> +                                          V4L2_SUBDEV_ROUTING_ONLY_1_TO_1 |
>> +                                          V4L2_SUBDEV_ROUTING_NO_SOURCE_MULTIPLEXING);
>> +       if (ret)
>> +               return ret;
>> +
>> +       ret = v4l2_subdev_set_routing_with_fmt(sd, state, routing, &format);
>> +       if (ret)
>> +               return ret;
>> +
>> +       return 0;
>> +}
>> +
>> +static int cal_camerarx_sd_set_routing(struct v4l2_subdev *sd,
>> +                                      struct v4l2_subdev_state *state,
>> +                                      enum v4l2_subdev_format_whence which,
>> +                                      struct v4l2_subdev_krouting *routing)
>> +{
>> +       return cal_camerarx_set_routing(sd, state, routing);
> 
> Do the routes persist across both TRY/ACTIVE? I.e. there's only ever a
> single routing table?

The routing is in the state, so it's separate for try and active.

>> +}
>> +
>>   static int cal_camerarx_sd_init_state(struct v4l2_subdev *sd,
>> -                                     struct v4l2_subdev_state *state)
>> -{
>> -       struct v4l2_subdev_format format = {
>> -               .which = state ? V4L2_SUBDEV_FORMAT_TRY
>> -               : V4L2_SUBDEV_FORMAT_ACTIVE,
>> -               .pad = CAL_CAMERARX_PAD_SINK,
>> -               .format = {
>> -                       .width = 640,
>> -                       .height = 480,
> 
> Aha, So the size was already arbitrary - not newly added anyway.

Yes. And we set up a single default route. This is to make the default 
behavior similar to the current upstream.

> 
>> -                       .code = MEDIA_BUS_FMT_UYVY8_1X16,
>> -                       .field = V4L2_FIELD_NONE,
>> -                       .colorspace = V4L2_COLORSPACE_SRGB,
>> -                       .ycbcr_enc = V4L2_YCBCR_ENC_601,
>> -                       .quantization = V4L2_QUANTIZATION_LIM_RANGE,
>> -                       .xfer_func = V4L2_XFER_FUNC_SRGB,
>> -               },
>> +                                   struct v4l2_subdev_state *state)
>> +{
>> +       struct v4l2_subdev_route routes[] = { {
>> +               .sink_pad = 0,
>> +               .sink_stream = 0,
>> +               .source_pad = 1,
>> +               .source_stream = 0,
>> +               .flags = V4L2_SUBDEV_ROUTE_FL_ACTIVE,
>> +       } };
>> +
>> +       struct v4l2_subdev_krouting routing = {
>> +               .num_routes = 1,
>> +               .routes = routes,
>>          };
>>   
>> -       return cal_camerarx_sd_set_fmt(sd, state, &format);
>> +       /* Initialize routing to single route to the fist source pad */
>> +       return cal_camerarx_set_routing(sd, state, &routing);
>>   }
>>   
>>   static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
>> @@ -749,48 +874,71 @@ static int cal_camerarx_get_frame_desc(struct v4l2_subdev *sd, unsigned int pad,
>>          struct cal_camerarx *phy = to_cal_camerarx(sd);
>>          struct v4l2_mbus_frame_desc remote_desc;
>>          const struct media_pad *remote_pad;
>> +       struct v4l2_subdev_state *state;
>> +       u32 sink_stream;
>> +       unsigned int i;
>>          int ret;
>>   
>> +       state = v4l2_subdev_lock_and_get_active_state(sd);
>> +
>> +       ret = v4l2_subdev_routing_find_opposite_end(&state->routing,
>> +                                                   pad, 0,
>> +                                                   NULL, &sink_stream);
>> +       if (ret)
>> +               goto out_unlock;
>> +
>>          remote_pad = media_pad_remote_pad_first(&phy->pads[CAL_CAMERARX_PAD_SINK]);
>> -       if (!remote_pad)
>> -               return -EPIPE;
>> +       if (!remote_pad) {
>> +               ret = -EPIPE;
>> +               goto out_unlock;
>> +       }
>>   
>>          ret = v4l2_subdev_call(phy->source, pad, get_frame_desc,
>>                                 remote_pad->index, &remote_desc);
>>          if (ret)
>> -               return ret;
>> +               goto out_unlock;
>>   
>>          if (remote_desc.type != V4L2_MBUS_FRAME_DESC_TYPE_CSI2) {
>>                  cal_err(phy->cal,
>>                          "Frame descriptor does not describe CSI-2 link");
>> -               return -EINVAL;
>> +               ret = -EINVAL;
>> +               goto out_unlock;
>>          }
>>   
>> -       if (remote_desc.num_entries > 1)
>> -               cal_err(phy->cal,
>> -                       "Multiple streams not supported in remote frame descriptor, using the first one\n");
>> +       for (i = 0; i < remote_desc.num_entries; i++) {
>> +               if (remote_desc.entry[i].stream == sink_stream)
>> +                       break;
>> +       }
>> +
>> +       if (i == remote_desc.num_entries) {
>> +               cal_err(phy->cal, "Stream %u not found in remote frame desc\n",
>> +                       sink_stream);
>> +               ret = -EINVAL;
>> +               goto out_unlock;
>> +       }
>>   
>>          fd->type = V4L2_MBUS_FRAME_DESC_TYPE_CSI2;
>>          fd->num_entries = 1;
>> -       fd->entry[0] = remote_desc.entry[0];
>> +       fd->entry[0] = remote_desc.entry[i];
>>   
>> -       return 0;
>> -}
>> +out_unlock:
>> +       v4l2_subdev_unlock_state(state);
>>   
>> -static const struct v4l2_subdev_video_ops cal_camerarx_video_ops = {
>> -       .s_stream = cal_camerarx_sd_s_stream,
>> -};
>> +       return ret;
>> +}
>>   
>>   static const struct v4l2_subdev_pad_ops cal_camerarx_pad_ops = {
>> +       .enable_streams = cal_camerarx_sd_enable_streams,
>> +       .disable_streams = cal_camerarx_sd_disable_streams,
>>          .enum_mbus_code = cal_camerarx_sd_enum_mbus_code,
>>          .enum_frame_size = cal_camerarx_sd_enum_frame_size,
>>          .get_fmt = v4l2_subdev_get_fmt,
>>          .set_fmt = cal_camerarx_sd_set_fmt,
>> +       .set_routing = cal_camerarx_sd_set_routing,
>>          .get_frame_desc = cal_camerarx_get_frame_desc,
>>   };
>>   
>>   static const struct v4l2_subdev_ops cal_camerarx_subdev_ops = {
>> -       .video = &cal_camerarx_video_ops,
>>          .pad = &cal_camerarx_pad_ops,
>>   };
>>   
>> @@ -800,6 +948,7 @@ static const struct v4l2_subdev_internal_ops cal_camerarx_internal_ops = {
>>   
>>   static const struct media_entity_operations cal_camerarx_media_ops = {
>>          .link_validate = v4l2_subdev_link_validate,
>> +       .has_pad_interdep = v4l2_subdev_has_pad_interdep,
>>   };
>>   
>>   /* ------------------------------------------------------------------
>> @@ -851,7 +1000,7 @@ struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,
>>          v4l2_subdev_init(sd, &cal_camerarx_subdev_ops);
>>          sd->internal_ops = &cal_camerarx_internal_ops;
>>          sd->entity.function = MEDIA_ENT_F_VID_IF_BRIDGE;
>> -       sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE;
>> +       sd->flags = V4L2_SUBDEV_FL_HAS_DEVNODE | V4L2_SUBDEV_FL_STREAMS;
>>          snprintf(sd->name, sizeof(sd->name), "CAMERARX%u", instance);
>>          sd->dev = cal->dev;
>>   
>> diff --git a/drivers/media/platform/ti/cal/cal-video.c b/drivers/media/platform/ti/cal/cal-video.c
>> index 29c38bf8d7a1..97a14ceaf237 100644
>> --- a/drivers/media/platform/ti/cal/cal-video.c
>> +++ b/drivers/media/platform/ti/cal/cal-video.c
>> @@ -108,9 +108,10 @@ static int __subdev_get_format(struct cal_ctx *ctx,
>>                  .pad = 0,
>>          };
>>          struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          int ret;
>>   
>> -       ret = v4l2_subdev_call(ctx->phy->source, pad, get_fmt, NULL, &sd_fmt);
>> +       ret = v4l2_subdev_call_state_active(sd, pad, get_fmt, &sd_fmt);
>>          if (ret)
>>                  return ret;
>>   
>> @@ -130,11 +131,12 @@ static int __subdev_set_format(struct cal_ctx *ctx,
>>                  .pad = 0,
>>          };
>>          struct v4l2_mbus_framefmt *mbus_fmt = &sd_fmt.format;
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          int ret;
>>   
>>          *mbus_fmt = *fmt;
>>   
>> -       ret = v4l2_subdev_call(ctx->phy->source, pad, set_fmt, NULL, &sd_fmt);
>> +       ret = v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);
>>          if (ret)
>>                  return ret;
>>   
>> @@ -176,6 +178,7 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
>>                                        struct v4l2_format *f)
>>   {
>>          struct cal_ctx *ctx = video_drvdata(file);
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          const struct cal_format_info *fmtinfo;
>>          struct v4l2_subdev_frame_size_enum fse = {
>>                  .which = V4L2_SUBDEV_FORMAT_ACTIVE,
>> @@ -201,8 +204,8 @@ static int cal_legacy_try_fmt_vid_cap(struct file *file, void *priv,
>>          for (fse.index = 0; ; fse.index++) {
>>                  int ret;
>>   
>> -               ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size,
>> -                                      NULL, &fse);
>> +               ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size,
>> +                                                   &fse);
>>                  if (ret)
>>                          break;
>>   
>> @@ -238,6 +241,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
>>                                      struct v4l2_format *f)
>>   {
>>          struct cal_ctx *ctx = video_drvdata(file);
>> +       struct v4l2_subdev *sd = &ctx->phy->subdev;
>>          struct vb2_queue *q = &ctx->vb_vidq;
>>          struct v4l2_subdev_format sd_fmt = {
>>                  .which = V4L2_SUBDEV_FORMAT_ACTIVE,
>> @@ -277,7 +281,7 @@ static int cal_legacy_s_fmt_vid_cap(struct file *file, void *priv,
>>          ctx->v_fmt.fmt.pix.field = sd_fmt.format.field;
>>          cal_calc_format_size(ctx, fmtinfo, &ctx->v_fmt);
>>   
>> -       v4l2_subdev_call(&ctx->phy->subdev, pad, set_fmt, NULL, &sd_fmt);
>> +       v4l2_subdev_call_state_active(sd, pad, set_fmt, &sd_fmt);
> 
> No return checks required here from set_fmt? But it wasn't there before
> so not this patch anyway.

Yep. And this is for the legacy code, i.e. pre-media-controller. I hope 
nobody is running that version anymore =).

>>   
>>          ctx->fmtinfo = fmtinfo;
>>          *f = ctx->v_fmt;
>> @@ -289,6 +293,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
>>                                        struct v4l2_frmsizeenum *fsize)
>>   {
>>          struct cal_ctx *ctx = video_drvdata(file);
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          const struct cal_format_info *fmtinfo;
>>          struct v4l2_subdev_frame_size_enum fse = {
>>                  .index = fsize->index,
>> @@ -307,8 +312,7 @@ static int cal_legacy_enum_framesizes(struct file *file, void *fh,
>>   
>>          fse.code = fmtinfo->code;
>>   
>> -       ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_size, NULL,
>> -                              &fse);
>> +       ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_size, &fse);
>>          if (ret)
>>                  return ret;
>>   
>> @@ -350,6 +354,7 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
>>                                            struct v4l2_frmivalenum *fival)
>>   {
>>          struct cal_ctx *ctx = video_drvdata(file);
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          const struct cal_format_info *fmtinfo;
>>          struct v4l2_subdev_frame_interval_enum fie = {
>>                  .index = fival->index,
>> @@ -364,8 +369,8 @@ static int cal_legacy_enum_frameintervals(struct file *file, void *priv,
>>                  return -EINVAL;
>>   
>>          fie.code = fmtinfo->code;
>> -       ret = v4l2_subdev_call(ctx->phy->source, pad, enum_frame_interval,
>> -                              NULL, &fie);
>> +
>> +       ret = v4l2_subdev_call_state_active(sd, pad, enum_frame_interval, &fie);
>>          if (ret)
>>                  return ret;
>>          fival->type = V4L2_FRMIVAL_TYPE_DISCRETE;
>> @@ -432,6 +437,9 @@ static int cal_mc_enum_fmt_vid_cap(struct file *file, void  *priv,
>>          idx = 0;
>>   
>>          for (i = 0; i < cal_num_formats; ++i) {
>> +               if (cal_formats[i].meta)
>> +                       continue;
>> +
>>                  if (f->mbus_code && cal_formats[i].code != f->mbus_code)
>>                          continue;
>>   
>> @@ -459,7 +467,7 @@ static void cal_mc_try_fmt(struct cal_ctx *ctx, struct v4l2_format *f,
>>           * supported.
>>           */
>>          fmtinfo = cal_format_by_fourcc(f->fmt.pix.pixelformat);
>> -       if (!fmtinfo)
>> +       if (!fmtinfo || fmtinfo->meta)
>>                  fmtinfo = &cal_formats[0];
>>   
>>          /*
>> @@ -675,16 +683,16 @@ static int cal_video_check_format(struct cal_ctx *ctx)
>>   {
>>          const struct v4l2_mbus_framefmt *format;
>>          struct v4l2_subdev_state *state;
>> -       struct media_pad *remote_pad;
>> +       struct media_pad *phy_source_pad;
>>          int ret = 0;
>>   
>> -       remote_pad = media_pad_remote_pad_first(&ctx->pad);
>> -       if (!remote_pad)
>> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
>> +       if (!phy_source_pad)
>>                  return -ENODEV;
>>   
>>          state = v4l2_subdev_lock_and_get_active_state(&ctx->phy->subdev);
>>   
>> -       format = v4l2_subdev_state_get_format(state, remote_pad->index);
>> +       format = v4l2_subdev_state_get_format(state, phy_source_pad->index, 0);
>>          if (!format) {
>>                  ret = -EINVAL;
>>                  goto out;
>> @@ -707,16 +715,28 @@ static int cal_video_check_format(struct cal_ctx *ctx)
>>   static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>>   {
>>          struct cal_ctx *ctx = vb2_get_drv_priv(vq);
>> +       struct media_pad *phy_source_pad;
>>          struct cal_buffer *buf;
>>          dma_addr_t addr;
>>          int ret;
>>   
>> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
>> +       if (!phy_source_pad) {
>> +               ctx_err(ctx, "Context not connected\n");
>> +               ret = -ENODEV;
>> +               goto error_release_buffers;
>> +       }
>> +
>>          ret = video_device_pipeline_alloc_start(&ctx->vdev);
>>          if (ret < 0) {
>>                  ctx_err(ctx, "Failed to start media pipeline: %d\n", ret);
>>                  goto error_release_buffers;
>>          }
>>   
>> +       /* Find the PHY connected to this video device */
>> +       if (cal_mc_api)
>> +               ctx->phy = cal_camerarx_get_phy_from_entity(phy_source_pad->entity);
>> +
>>          /*
>>           * Verify that the currently configured format matches the output of
>>           * the connected CAMERARX.
>> @@ -749,7 +769,8 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>>          cal_ctx_set_dma_addr(ctx, addr);
>>          cal_ctx_start(ctx);
>>   
>> -       ret = v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 1);
>> +       ret = v4l2_subdev_enable_streams(&ctx->phy->subdev,
>> +                                        phy_source_pad->index, BIT(0));
>>          if (ret)
>>                  goto error_stop;
>>   
>> @@ -774,10 +795,14 @@ static int cal_start_streaming(struct vb2_queue *vq, unsigned int count)
>>   static void cal_stop_streaming(struct vb2_queue *vq)
>>   {
>>          struct cal_ctx *ctx = vb2_get_drv_priv(vq);
>> +       struct media_pad *phy_source_pad;
>>   
>>          cal_ctx_stop(ctx);
>>   
>> -       v4l2_subdev_call(&ctx->phy->subdev, video, s_stream, 0);
>> +       phy_source_pad = media_pad_remote_pad_first(&ctx->pad);
>> +
>> +       v4l2_subdev_disable_streams(&ctx->phy->subdev, phy_source_pad->index,
>> +                                   BIT(0));
>>   
>>          pm_runtime_put_sync(ctx->cal->dev);
>>   
>> @@ -786,6 +811,9 @@ static void cal_stop_streaming(struct vb2_queue *vq)
>>          cal_release_buffers(ctx, VB2_BUF_STATE_ERROR);
>>   
>>          video_device_pipeline_stop(&ctx->vdev);
>> +
>> +       if (cal_mc_api)
>> +               ctx->phy = NULL;
>>   }
>>   
>>   static const struct vb2_ops cal_video_qops = {
>> @@ -812,6 +840,7 @@ static const struct v4l2_file_operations cal_fops = {
>>   
>>   static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>>   {
>> +       struct v4l2_subdev *sd = ctx->phy->source;
>>          struct v4l2_mbus_framefmt mbus_fmt;
>>          const struct cal_format_info *fmtinfo;
>>          unsigned int i, j, k;
>> @@ -831,20 +860,20 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>>                          .which = V4L2_SUBDEV_FORMAT_ACTIVE,
>>                  };
>>   
>> -               ret = v4l2_subdev_call(ctx->phy->source, pad, enum_mbus_code,
>> -                                      NULL, &mbus_code);
>> +               ret = v4l2_subdev_call_state_active(sd, pad, enum_mbus_code,
>> +                                                   &mbus_code);
>>                  if (ret == -EINVAL)
>>                          break;
>>   
>>                  if (ret) {
>>                          ctx_err(ctx, "Error enumerating mbus codes in subdev %s: %d\n",
>> -                               ctx->phy->source->name, ret);
>> +                               sd->name, ret);
>>                          return ret;
>>                  }
>>   
>>                  ctx_dbg(2, ctx,
>>                          "subdev %s: code: %04x idx: %u\n",
>> -                       ctx->phy->source->name, mbus_code.code, j);
>> +                       sd->name, mbus_code.code, j);
>>   
>>                  for (k = 0; k < cal_num_formats; k++) {
>>                          fmtinfo = &cal_formats[k];
>> @@ -862,7 +891,7 @@ static int cal_ctx_v4l2_init_formats(struct cal_ctx *ctx)
>>   
>>          if (i == 0) {
>>                  ctx_err(ctx, "No suitable format reported by subdev %s\n",
>> -                       ctx->phy->source->name);
>> +                       sd->name);
>>                  return -EINVAL;
>>          }
>>   
>> @@ -948,16 +977,52 @@ int cal_ctx_v4l2_register(struct cal_ctx *ctx)
>>                  return ret;
>>          }
>>   
>> -       ret = media_create_pad_link(&ctx->phy->subdev.entity,
>> -                                   CAL_CAMERARX_PAD_FIRST_SOURCE,
>> -                                   &vfd->entity, 0,
>> -                                   MEDIA_LNK_FL_IMMUTABLE |
>> -                                   MEDIA_LNK_FL_ENABLED);
>> -       if (ret) {
>> -               ctx_err(ctx, "Failed to create media link for context %u\n",
>> -                       ctx->dma_ctx);
>> -               video_unregister_device(vfd);
>> -               return ret;
>> +       if (cal_mc_api) {
>> +               u16 phy_idx;
>> +               u16 pad_idx;
>> +
>> +               /* Create links from all video nodes to all PHYs */
>> +
>> +               for (phy_idx = 0; phy_idx < ctx->cal->data->num_csi2_phy;
>> +                    ++phy_idx) {
>> +                       struct media_entity *phy_entity =
>> +                               &ctx->cal->phy[phy_idx]->subdev.entity;
>> +
>> +                       for (pad_idx = 1; pad_idx < CAL_CAMERARX_NUM_PADS;
>> +                            ++pad_idx) {
>> +                               /*
>> +                                * Enable only links from video0 to PHY0 pad 1,
>> +                                * and video1 to PHY1 pad 1.
>> +                                */
>> +                               bool enable = (ctx->dma_ctx == 0 &&
>> +                                              phy_idx == 0 && pad_idx == 1) ||
>> +                                             (ctx->dma_ctx == 1 &&
>> +                                              phy_idx == 1 && pad_idx == 1);
>> +
>> +                               ret = media_create_pad_link(phy_entity, pad_idx,
>> +                                       &vfd->entity, 0,
>> +                                       enable ? MEDIA_LNK_FL_ENABLED : 0);
>> +                               if (ret) {
>> +                                       ctx_err(ctx,
>> +                                               "Failed to create media link for context %u\n",
>> +                                               ctx->dma_ctx);
>> +                                       video_unregister_device(vfd);
>> +                                       return ret;
>> +                               }
>> +                       }
>> +               }
>> +       } else {
>> +               ret = media_create_pad_link(&ctx->phy->subdev.entity,
>> +                                           CAL_CAMERARX_PAD_FIRST_SOURCE,
>> +                                           &vfd->entity, 0,
>> +                                           MEDIA_LNK_FL_IMMUTABLE | MEDIA_LNK_FL_ENABLED);
>> +               if (ret) {
>> +                       ctx_err(ctx,
>> +                               "Failed to create media link for context %u\n",
>> +                               ctx->dma_ctx);
>> +                       video_unregister_device(vfd);
>> +                       return ret;
>> +               }
>>          }
>>   
>>          ctx_info(ctx, "V4L2 device registered as %s\n",
>> diff --git a/drivers/media/platform/ti/cal/cal.c b/drivers/media/platform/ti/cal/cal.c
>> index 4bd2092e0255..9389c444400e 100644
>> --- a/drivers/media/platform/ti/cal/cal.c
>> +++ b/drivers/media/platform/ti/cal/cal.c
>> @@ -481,8 +481,9 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
>>                  ctx->vc = 0;
>>                  ctx->datatype = CAL_CSI2_CTX_DT_ANY;
>>          } else if (!ret) {
>> -               ctx_dbg(2, ctx, "Framedesc: len %u, vc %u, dt %#x\n",
>> -                       entry.length, entry.bus.csi2.vc, entry.bus.csi2.dt);
>> +               ctx_dbg(2, ctx, "Framedesc: stream %u, len %u, vc %u, dt %#x\n",
>> +                       entry.stream, entry.length, entry.bus.csi2.vc,
>> +                       entry.bus.csi2.dt);
>>   
>>                  ctx->vc = entry.bus.csi2.vc;
>>                  ctx->datatype = entry.bus.csi2.dt;
>> @@ -490,7 +491,7 @@ int cal_ctx_prepare(struct cal_ctx *ctx)
>>                  return ret;
>>          }
>>   
>> -       ctx->use_pix_proc = !ctx->fmtinfo->meta;
>> +       ctx->use_pix_proc = ctx->vb_vidq.type == V4L2_BUF_TYPE_VIDEO_CAPTURE;
>>   
>>          if (ctx->use_pix_proc) {
>>                  ret = cal_reserve_pix_proc(ctx->cal);
>> @@ -1014,7 +1015,6 @@ static struct cal_ctx *cal_ctx_create(struct cal_dev *cal, int inst)
>>                  return NULL;
>>   
>>          ctx->cal = cal;
>> -       ctx->phy = cal->phy[inst];
>>          ctx->dma_ctx = inst;
>>          ctx->csi2_ctx = inst;
>>          ctx->cport = inst;
>> @@ -1226,18 +1226,37 @@ static int cal_probe(struct platform_device *pdev)
>>          }
>>   
>>          /* Create contexts. */
>> -       for (i = 0; i < cal->data->num_csi2_phy; ++i) {
>> -               if (!cal->phy[i]->source_node)
>> -                       continue;
>> +       if (!cal_mc_api) {
>> +               for (i = 0; i < cal->data->num_csi2_phy; ++i) {
>> +                       struct cal_ctx *ctx;
>> +
>> +                       if (!cal->phy[i]->source_node)
>> +                               continue;
>> +
>> +                       ctx = cal_ctx_create(cal, i);
>> +                       if (!ctx) {
>> +                               cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
>> +                               ret = -ENODEV;
>> +                               goto error_context;
>> +                       }
>> +
>> +                       ctx->phy = cal->phy[i];
>>   
>> -               cal->ctx[cal->num_contexts] = cal_ctx_create(cal, i);
>> -               if (!cal->ctx[cal->num_contexts]) {
>> -                       cal_err(cal, "Failed to create context %u\n", cal->num_contexts);
>> -                       ret = -ENODEV;
>> -                       goto error_context;
>> +                       cal->ctx[cal->num_contexts++] = ctx;
>>                  }
>> +       } else {
>> +               for (i = 0; i < ARRAY_SIZE(cal->ctx); ++i) {
>> +                       struct cal_ctx *ctx;
>> +
>> +                       ctx = cal_ctx_create(cal, i);
>> +                       if (!ctx) {
>> +                               cal_err(cal, "Failed to create context %u\n", i);
>> +                               ret = -ENODEV;
>> +                               goto error_context;
>> +                       }
>>   
>> -               cal->num_contexts++;
>> +                       cal->ctx[cal->num_contexts++] = ctx;
>> +               }
>>          }
>>   
>>          /* Register the media device. */
>> diff --git a/drivers/media/platform/ti/cal/cal.h b/drivers/media/platform/ti/cal/cal.h
>> index 0856297adc0b..44ee0bece56e 100644
>> --- a/drivers/media/platform/ti/cal/cal.h
>> +++ b/drivers/media/platform/ti/cal/cal.h
>> @@ -45,7 +45,7 @@
>>   
>>   #define CAL_CAMERARX_PAD_SINK          0
>>   #define CAL_CAMERARX_PAD_FIRST_SOURCE  1
>> -#define CAL_CAMERARX_NUM_SOURCE_PADS   1
>> +#define CAL_CAMERARX_NUM_SOURCE_PADS   8
>>   #define CAL_CAMERARX_NUM_PADS          (1 + CAL_CAMERARX_NUM_SOURCE_PADS)
>>   
>>   static inline bool cal_rx_pad_is_sink(u32 pad)
>> @@ -319,6 +319,7 @@ const struct cal_format_info *cal_format_by_code(u32 code);
>>   
>>   void cal_quickdump_regs(struct cal_dev *cal);
>>   
>> +struct cal_camerarx *cal_camerarx_get_phy_from_entity(struct media_entity *entity);
>>   void cal_camerarx_disable(struct cal_camerarx *phy);
>>   void cal_camerarx_i913_errata(struct cal_camerarx *phy);
>>   struct cal_camerarx *cal_camerarx_create(struct cal_dev *cal,
>>
>> -- 
>> 2.43.0
>>