lists.openwall.net   lists  /  announce  owl-users  owl-dev  john-users  john-dev  passwdqc-users  yescrypt  popa3d-users  /  oss-security  kernel-hardening  musl  sabotage  tlsify  passwords  /  crypt-dev  xvendor  /  Bugtraq  Full-Disclosure  linux-kernel  linux-netdev  linux-ext4  linux-hardening  linux-cve-announce  PHC 
Open Source and information security mailing list archives
 
Hash Suite: Windows password security audit tool. GUI, reports in PDF.
[<prev] [next>] [<thread-prev] [day] [month] [year] [list]
Message-ID: <d60193e5-2ce1-49d6-b6e3-a7318c3184f0@ideasonboard.com>
Date: Thu, 3 Oct 2024 15:40:08 +0300
From: Tomi Valkeinen <tomi.valkeinen@...asonboard.com>
To: Cosmin Tanislav <demonsingur@...il.com>
Cc: Mauro Carvalho Chehab <mchehab@...nel.org>, linux-media@...r.kernel.org,
 linux-kernel@...r.kernel.org
Subject: Re: [PATCH] media: i2c: ub960: clarify stream_enable_mask indexing

Hi,

On 02/10/2024 19:43, Cosmin Tanislav wrote:
> Variables containing port numbers are used to index
> arrays which should be indexed by pad numbers.
> Coincidentally, the order in which pad numbers are
> assigned makes it avoid any conflicts, but it's still
> confusing.
> 
> Clarify the situation by adding port_to_pad helpers
> and using them.
> 

Please use the same prefix as the previous patches use:

media: i2c: ds90ub960:

Also, while at it, you could re-format the desc a bit, as it's quite 
narrow and slightly oddly formatted.

As for the code itself, it works for me and looks good:

Reviewed-by: Tomi Valkeinen <tomi.valkeinen@...asonboard.com>

  Tomi

> Signed-off-by: Cosmin Tanislav <demonsingur@...il.com>
> ---
>   drivers/media/i2c/ds90ub960.c | 41 +++++++++++++++++++++++++----------
>   1 file changed, 30 insertions(+), 11 deletions(-)
> 
> diff --git a/drivers/media/i2c/ds90ub960.c b/drivers/media/i2c/ds90ub960.c
> index ffe5f25f86476..d1595c88f7632 100644
> --- a/drivers/media/i2c/ds90ub960.c
> +++ b/drivers/media/i2c/ds90ub960.c
> @@ -527,6 +527,7 @@ struct ub960_data {
>   
>   	u8 stored_fwd_ctl;
>   
> +	/* Indexed by pad number */
>   	u64 stream_enable_mask[UB960_MAX_NPORTS];
>   
>   	/* These are common to all ports */
> @@ -561,6 +562,16 @@ static inline unsigned int ub960_pad_to_port(struct ub960_data *priv, u32 pad)
>   		return pad - priv->hw_data->num_rxports;
>   }
>   
> +static inline unsigned int ub960_rxport_to_pad(struct ub960_data *priv, u32 port)
> +{
> +	return port;
> +}
> +
> +static inline unsigned int ub960_txport_to_pad(struct ub960_data *priv, u32 port)
> +{
> +	return port + priv->hw_data->num_rxports;
> +}
> +
>   struct ub960_format_info {
>   	u32 code;
>   	u32 bpp;
> @@ -2558,6 +2569,7 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   {
>   	struct ub960_data *priv = sd_to_ub960(sd);
>   	struct device *dev = &priv->client->dev;
> +	/* Indexed by rx port number */
>   	u64 sink_streams[UB960_MAX_RX_NPORTS] = {};
>   	struct v4l2_subdev_route *route;
>   	unsigned int failed_port;
> @@ -2595,11 +2607,13 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   	}
>   
>   	for (nport = 0; nport < priv->hw_data->num_rxports; nport++) {
> +		unsigned int sink_pad = ub960_rxport_to_pad(priv, nport);
> +
>   		if (!sink_streams[nport])
>   			continue;
>   
>   		/* Enable the RX port if not yet enabled */
> -		if (!priv->stream_enable_mask[nport]) {
> +		if (!priv->stream_enable_mask[sink_pad]) {
>   			ret = ub960_enable_rx_port(priv, nport);
>   			if (ret) {
>   				failed_port = nport;
> @@ -2607,7 +2621,7 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   			}
>   		}
>   
> -		priv->stream_enable_mask[nport] |= sink_streams[nport];
> +		priv->stream_enable_mask[sink_pad] |= sink_streams[nport];
>   
>   		dev_dbg(dev, "enable RX port %u streams %#llx\n", nport,
>   			sink_streams[nport]);
> @@ -2617,9 +2631,9 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   			priv->rxports[nport]->source.pad,
>   			sink_streams[nport]);
>   		if (ret) {
> -			priv->stream_enable_mask[nport] &= ~sink_streams[nport];
> +			priv->stream_enable_mask[sink_pad] &= ~sink_streams[nport];
>   
> -			if (!priv->stream_enable_mask[nport])
> +			if (!priv->stream_enable_mask[sink_pad])
>   				ub960_disable_rx_port(priv, nport);
>   
>   			failed_port = nport;
> @@ -2633,6 +2647,8 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   
>   err:
>   	for (nport = 0; nport < failed_port; nport++) {
> +		unsigned int sink_pad = ub960_rxport_to_pad(priv, nport);
> +
>   		if (!sink_streams[nport])
>   			continue;
>   
> @@ -2646,10 +2662,10 @@ static int ub960_enable_streams(struct v4l2_subdev *sd,
>   		if (ret)
>   			dev_err(dev, "Failed to disable streams: %d\n", ret);
>   
> -		priv->stream_enable_mask[nport] &= ~sink_streams[nport];
> +		priv->stream_enable_mask[sink_pad] &= ~sink_streams[nport];
>   
>   		/* Disable RX port if no active streams */
> -		if (!priv->stream_enable_mask[nport])
> +		if (!priv->stream_enable_mask[sink_pad])
>   			ub960_disable_rx_port(priv, nport);
>   	}
>   
> @@ -2689,6 +2705,8 @@ static int ub960_disable_streams(struct v4l2_subdev *sd,
>   	}
>   
>   	for (nport = 0; nport < priv->hw_data->num_rxports; nport++) {
> +		unsigned int sink_pad = ub960_rxport_to_pad(priv, nport);
> +
>   		if (!sink_streams[nport])
>   			continue;
>   
> @@ -2702,10 +2720,10 @@ static int ub960_disable_streams(struct v4l2_subdev *sd,
>   		if (ret)
>   			dev_err(dev, "Failed to disable streams: %d\n", ret);
>   
> -		priv->stream_enable_mask[nport] &= ~sink_streams[nport];
> +		priv->stream_enable_mask[sink_pad] &= ~sink_streams[nport];
>   
>   		/* Disable RX port if no active streams */
> -		if (!priv->stream_enable_mask[nport])
> +		if (!priv->stream_enable_mask[sink_pad])
>   			ub960_disable_rx_port(priv, nport);
>   	}
>   
> @@ -3460,6 +3478,7 @@ static int ub960_parse_dt_rxports(struct ub960_data *priv)
>   	priv->strobe.manual = fwnode_property_read_bool(links_fwnode, "ti,manual-strobe");
>   
>   	for (nport = 0; nport < priv->hw_data->num_rxports; nport++) {
> +		unsigned int pad = ub960_rxport_to_pad(priv, nport);
>   		struct fwnode_handle *link_fwnode;
>   		struct fwnode_handle *ep_fwnode;
>   
> @@ -3468,7 +3487,7 @@ static int ub960_parse_dt_rxports(struct ub960_data *priv)
>   			continue;
>   
>   		ep_fwnode = fwnode_graph_get_endpoint_by_id(dev_fwnode(dev),
> -							    nport, 0, 0);
> +							    pad, 0, 0);
>   		if (!ep_fwnode) {
>   			fwnode_handle_put(link_fwnode);
>   			continue;
> @@ -3503,11 +3522,11 @@ static int ub960_parse_dt_txports(struct ub960_data *priv)
>   	int ret;
>   
>   	for (nport = 0; nport < priv->hw_data->num_txports; nport++) {
> -		unsigned int port = nport + priv->hw_data->num_rxports;
> +		unsigned int pad = ub960_txport_to_pad(priv, nport);
>   		struct fwnode_handle *ep_fwnode;
>   
>   		ep_fwnode = fwnode_graph_get_endpoint_by_id(dev_fwnode(dev),
> -							    port, 0, 0);
> +							    pad, 0, 0);
>   		if (!ep_fwnode)
>   			continue;
>   


Powered by blists - more mailing lists

Powered by Openwall GNU/*/Linux Powered by OpenVZ